From e83f7fa1f5648745940863444fed16f7f9135ce7 Mon Sep 17 00:00:00 2001 From: 935090232@qq.com <ak473600000> Date: Sun, 06 Jun 2021 10:34:34 +0800 Subject: [PATCH] 业绩规则3 --- zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysProjServicesServiceImpl.java | 353 +++++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 283 insertions(+), 70 deletions(-) diff --git a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysProjServicesServiceImpl.java b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysProjServicesServiceImpl.java index cfb58f7..e57a138 100644 --- a/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysProjServicesServiceImpl.java +++ b/zq-erp/src/main/java/com/matrix/system/hive/service/imp/SysProjServicesServiceImpl.java @@ -1,24 +1,32 @@ package com.matrix.system.hive.service.imp; -import com.alibaba.fastjson.JSONObject; +import cn.hutool.core.collection.CollUtil; import com.matrix.component.rabbitmq.RabiitMqTemplate; import com.matrix.core.constance.MatrixConstance; import com.matrix.core.exception.GlobleException; import com.matrix.core.pojo.PaginationVO; import com.matrix.core.pojo.VerifyResult; -import com.matrix.core.tools.*; +import com.matrix.core.tools.DateUtil; +import com.matrix.core.tools.LogUtil; +import com.matrix.core.tools.StringUtils; +import com.matrix.core.tools.WebUtil; import com.matrix.system.app.dto.ServiceOrderListDto; import com.matrix.system.app.vo.ServiceOrderListVo; +import com.matrix.system.common.bean.BusParameterSettings; import com.matrix.system.common.bean.SysUsers; +import com.matrix.system.common.constance.AppConstance; +import com.matrix.system.common.dao.BusParameterSettingsDao; import com.matrix.system.common.dao.SysUsersDao; import com.matrix.system.constance.Dictionary; import com.matrix.system.hive.bean.*; import com.matrix.system.hive.dao.*; -import com.matrix.core.tools.DateUtil; import com.matrix.system.hive.plugin.util.MoneyUtil; -import com.matrix.system.hive.pojo.MyBeauticianCount; import com.matrix.system.hive.service.*; +import com.matrix.system.score.constant.ScoreSettingConstant; +import com.matrix.system.score.entity.ScoreVipDetail; +import com.matrix.system.score.service.ScoreVipDetailService; import com.matrix.system.shopXcx.mqTask.MQTaskRouting; +import com.matrix.system.wechart.templateMsg.UniformMsgParam; import org.apache.commons.collections.CollectionUtils; import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; @@ -105,6 +113,16 @@ @Autowired private RabiitMqTemplate rabiitMqTemplate; + + @Autowired + BusParameterSettingsDao busParameterSettingsDao; + + @Autowired + ScoreVipDetailService scoreVipDetailService; + + @Autowired + SysVipInfoDao sysVipInfoDao; + @Value("${evn}") private String evn; @@ -119,16 +137,21 @@ public SysProjServices addSysProjServices(SysProjServices sysProjServices) throws GlobleException { //创建服务单 - SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); - sysProjServices.setCreateStaffId(user.getSuId()); - sysProjServices.setShopId(user.getShopId()); - sysProjServices.setCompanyId(user.getCompanyId()); - sysProjServices.setCreateTime(new Date()); - // 设置状态为待预约 - sysProjServices.setState(Dictionary.SERVICE_STATU_DYY); - sysProjServices.setServiceNo(codeService.getServiceOrderCode()); + if (WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY) != null) { + SysUsers user = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); + sysProjServices.setCreateStaffId(user.getSuId()); + sysProjServices.setShopId(user.getShopId()); + sysProjServices.setCompanyId(user.getCompanyId()); + } + + + if (sysProjServices.getId() == null) { + sysProjServices.setCreateTime(new Date()); + sysProjServices.setServiceNo(codeService.getServiceOrderCode()); + int i = sysProjServicesDao.insert(sysProjServices); + } + Double hkPrice = 0.0; - int i = sysProjServicesDao.insert(sysProjServices); // 计算项目总时长 int totalTime = 0; //处理订单明细 @@ -209,8 +232,8 @@ //插入订单明细 sysBeauticianState.setProjId(sysProjInfo.getId()); sysBeauticianState.setServicesId(sysProjServices.getId()); - sysBeauticianState.setShopId(user.getShopId()); - sysBeauticianState.setState(Dictionary.BEATUI_STATE_DYY); + sysBeauticianState.setShopId(sysProjServices.getShopId()); + sysBeauticianState.setState(sysProjServices.getState()); beauticianStateDao.insert(sysBeauticianState); } // 设置项目总时长 @@ -296,15 +319,13 @@ */ @Override public VerifyResult checkArrears(SysProjServices sysProjServices) { - //检测欠款 - /* for (SysBeauticianState sysBeauticianState : sysProjServices.getServiceItems()) { - + // 检测欠款 + /*for (SysBeauticianState sysBeauticianState : sysProjServices.getServiceItems()) { SysProjUse sysProjUse = projUseService.findById(sysBeauticianState.getPuseId()); - - ShoppingGoods shoppingGoods = shoppingGoodsDao.selectById(sysProjUse.getProjId()); - SysOrderItem orderItem = sysOrderItemService.findById(sysProjUse.getOrderItemId()); + SysOrderItem item = sysOrderItemService.findById(sysProjUse.getOrderItemId()); + SysOrder orderItem = sysOrderService.findById(item.getOrderId()); if ("购买".equals(sysProjUse.getSource())) { // 如果用户有欠款,服务单总价不能超过已付金额 if (orderItem!=null && orderItem.getArrears() > 0) { @@ -320,13 +341,13 @@ double money = MoneyUtil.sub((bj - orderItem.getArrears()), (yxfje + bcxfje)); // 如果 已付金额 - (已消费金额+本次消费金额)<0 则不能再消费 if (money < 0) { - return new VerifyResult(true, shoppingGoods.getName() + "存在欠款" + orderItem.getArrears() + "元 , 订单编号[ " + sysOrderService.findById(orderItem.getOrderId()).getOrderNo() + " ] "); + return new VerifyResult(true, shoppingGoods.getName() + "存在欠款" + orderItem.getArrears() + "元 , 订单编号[ " + orderItem.getOrderNo() + " ] "); } } } else if ("赠送".equals(sysProjUse.getSource())) { - if (orderItem!=null &&orderItem.getArrears() > 0) { + if (orderItem!=null && orderItem.getArrears()!=null&&orderItem.getArrears() > 0) { return new VerifyResult(true, shoppingGoods.getName() + "存在欠款" + orderItem.getArrears() + "元 , 不能消费赠送项目,订单编号[ " + sysOrderService.findById(orderItem.getOrderId()).getOrderNo() + " ] "); } } @@ -341,8 +362,8 @@ /** 验证数据是否正确 */ SysProjServices checkProjServices = sysProjServicesDao.selectById(projServices.getId()); // 验证服务单是否存在或者取消 - if (!checkProjServices.getState().equals(Dictionary.SERVICE_STATU_DYY) - && !checkProjServices.getState().equals(Dictionary.SERVICE_STATU_YYCG)) { + if (checkProjServices.getState().equals(Dictionary.SERVICE_STATU_YYQX) + || checkProjServices.getState().equals(Dictionary.SERVICE_STATU_FFJS)) { throw new GlobleException("该服务单已被取消或者不存在!"); } // 验证是否选择床位 @@ -369,7 +390,7 @@ } // 判断是否是编辑,还是新增,编辑则需要先释放资源 - if (checkProjServices.getState().equals(Dictionary.SERVICE_STATU_YYCG)) { + if (!checkProjServices.getState().equals(Dictionary.SERVICE_STATU_DYY)) { // 释放床位资源 bedStateDao.deleteByServiceId(checkProjServices.getId()); } @@ -387,6 +408,7 @@ if (beauticianStateDao.checkBeauticianClash(beauticianState) > 0) { throw new GlobleException("该美疗师已被占用,请重新分配!"); } +// beauticianState.setExcTime(beauticianState.getProjInfo().getTimeLength()); beauticianState.setState(Dictionary.BEATUI_STATE_YYY); beauticianStateDao.update(beauticianState); @@ -396,8 +418,10 @@ } - // 设置成功状态 - projServices.setState(Dictionary.SERVICE_STATU_YYCG); + if (Dictionary.SERVICE_STATU_DYY.equals(projServices.getState())) { + // 设置成功状态 + projServices.setState(Dictionary.SERVICE_STATU_XPL); + } // 判断当前门店是否有历史美疗师 LastestWorkBeatuistaff lastWorkStaff = new LastestWorkBeatuistaff(); lastWorkStaff.setShopId(checkProjServices.getShopId()); @@ -479,6 +503,9 @@ sysOutStoreDao.deleteById(sysOutStore.getId()); sysOutStoreItemDao.deleteByOrderId(sysOutStore.getId()); } + //删除积分 + scoreVipDetailService.removeByBusinessId(checkProjServices.getVipId(), checkProjServices.getId()); + //更新服务单状态 return sysProjServicesDao.update(checkProjServices); } @@ -491,12 +518,20 @@ private void backProjCount(SysProjServices projServices) { List<SysBeauticianState> beauticianStateList = beauticianStateDao.selectBySerIds(projServices.getId()); - Map<Long ,List<SysProjUse>> taocanMap = new HashMap<>(); + backProjCountItems(beauticianStateList, 1); + } + + private void backProjCountItems(List<SysBeauticianState> beauticianStateList, int type) { + Map<Long, List<SysProjUse>> taocanMap = new HashMap<>(); // 回退项目余额 for (SysBeauticianState beauticianState : beauticianStateList) { - // 该修改为 有效日期判断更新所有 - beauticianState.setState(Dictionary.BEATUI_STATE_YYQX); - beauticianStateDao.update(beauticianState); + if (type == 1) { + // 该修改为 有效日期判断更新所有 + beauticianState.setState(Dictionary.BEATUI_STATE_YYQX); + beauticianStateDao.update(beauticianState); + } else { + beauticianStateDao.deleteById(beauticianState.getId()); + } SysProjUse sysProjUse = sysProjUseDao.selectById(beauticianState.getPuseId()); if (sysProjUse != null && sysProjUse.getId() != null) { @@ -564,6 +599,16 @@ } } + @Override + public int deleteProjServiceItemById(Long id) { + SysBeauticianState sysBeauticianState = beauticianStateDao.selectById(id); + List<SysBeauticianState> list = new ArrayList<>(); + list.add(sysBeauticianState); + + backProjCountItems(list, 2); + return 1; + } + // 划扣 jyy @Transactional(rollbackFor = Exception.class) @Override @@ -572,18 +617,153 @@ if (!projServices.getState().equals(Dictionary.SERVICE_STATU_FWWC)) { throw new GlobleException("该服务单状态为" + projServices.getState() + ",不可以进行当前操作!"); } else { + SysUsers users = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); + if (skipServiceOrderStep(Dictionary.SERVICE_OVER_BEGIN_END)) { + SysBeauticianState checkBeauticianState = new SysBeauticianState(); + checkBeauticianState.setServicesId(projServices.getId()); + checkBeauticianState.setState(Dictionary.BEATUI_STATE_FWJS); + beauticianStateDao.chengItemState(checkBeauticianState); + + // 释放床位资源 + SysBedState checkBedState = sysBedStateDao.selectBySerIdAndBedId(projServices.getId(), projServices.getBedId()); + if (checkBedState != null) { + checkBedState.setBedState(Dictionary.BED_STATE_SYJS); + bedStateDao.update(checkBedState); + } + projServices.setEndTime(new Date()); + // 计算时差 + long minspace = DateUtil.getDifTimeMin(projServices.getStartTime(), projServices.getEndTime()) - projServices.getTotalTime(); + // 判断是服务超时还是服务提前结束,如果minspace大于0则是超时服务,小于0则是提前结束服务 + projServices.setIsOverTime(minspace + ""); + projServices.setState(Dictionary.SERVICE_STATU_FWWC); + sysProjServicesDao.update(projServices); + } + projServices.setState(Dictionary.SERVICE_STATU_FFJS); projServices.setConsumeTime(new Date()); - int result=sysProjServicesDao.update(projServices); + int result = sysProjServicesDao.update(projServices); + achieveNewService.addAchieveByServiceOrder(projServices); + + //设置会员积分 + addVipScore(projServices); + //发送微信公众号提醒 - JSONObject param=new JSONObject(); - param.put("companyId",projServices.getCompanyId()); - param.put("serviceId",projServices.getId()); - rabiitMqTemplate.sendMsg(MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG+evn,param.toJSONString()); + UniformMsgParam uniformMsgParam = new UniformMsgParam(projServices.getCompanyId(), UniformMsgParam.GZH_FWWC); + uniformMsgParam.put("serviceId", projServices.getId()); + rabiitMqTemplate.sendMsg(MQTaskRouting.SEND_UNIFORM_TEMPLATE_MSG + evn, uniformMsgParam.toJSONString()); + + + + return result; } + + } + /** + * 设置会员消费积分 + */ + private void addVipScore(SysProjServices projServices) { + + SysVipInfo vipInfo =sysVipInfoDao.selectById(projServices.getVipId()); + + List<SysBeauticianState> sysBeauticianStates = beauticianStateDao.selectBySerIds(projServices.getId()); + + + double principalPrice = 0D; + double giftPrice = 0D; + for (SysBeauticianState sysBeauticianState : sysBeauticianStates) { + SysProjUse projUse = sysBeauticianState.getProjUse(); + if (projUse.getSource().equals(Dictionary.TAOCAN_SOURCE_ZS)) { + giftPrice += projUse.getPrice(); + } else { + principalPrice += projUse.getPrice(); + } + } + + int[] principalConsumScore = {0, 0, 0}; + BusParameterSettings principalConsumption = busParameterSettingsDao.selectCompanyParamByCode(ScoreSettingConstant.PRINCIPAL_CONSUMPTION, vipInfo.getCompanyId()); + //本金消耗 + if (principalPrice > 0 + && StringUtils.isNotBlank(principalConsumption.getParamValue())) { + + principalConsumScore[0] = (int) (principalPrice / Double.parseDouble(principalConsumption.getParamValue())); + + if (StringUtils.isNotBlank(principalConsumption.getParamValue1())) { + principalConsumScore[1] = (int) (principalPrice / Double.parseDouble(principalConsumption.getParamValue1())); + } + + if (StringUtils.isNotBlank(principalConsumption.getParamValue2())) { + principalConsumScore[2] = (int) (principalPrice / Double.parseDouble(principalConsumption.getParamValue2())); + } + } + + int[] giveConsumScore = {0, 0, 0}; + BusParameterSettings giveConsumption = busParameterSettingsDao.selectCompanyParamByCode(ScoreSettingConstant.GIVE_CONSUMPTION, vipInfo.getCompanyId()); + //本金消耗 + if (giftPrice > 0 + && StringUtils.isNotBlank(giveConsumption.getParamValue())) { + + giveConsumScore[0] = (int) (giftPrice / Double.parseDouble(giveConsumption.getParamValue())); + + if (StringUtils.isNotBlank(giveConsumption.getParamValue1())) { + giveConsumScore[1] = (int) (giftPrice / Double.parseDouble(giveConsumption.getParamValue1())); + } + + if (StringUtils.isNotBlank(giveConsumption.getParamValue2())) { + giveConsumScore[2] = (int) (giftPrice / Double.parseDouble(giveConsumption.getParamValue2())); + } + } + + int selfScore =principalConsumScore[0]+giveConsumScore[0]; + int parentScore =principalConsumScore[1]+giveConsumScore[1]; + int topParentScore =principalConsumScore[2]+giveConsumScore[2]; + + //添加自己的积分 + if (selfScore > 0) { + scoreVipDetailService.addScore( + vipInfo.getId(), + projServices.getCreateStaffId(), + projServices.getShopId(), + selfScore, + projServices.getId(), + ScoreVipDetail.SCORE_VIP_TYPE_CASH, + "消耗奖励" + ); + } + + if (vipInfo.getRecommendId() != null) { + //推荐注册老带新积分奖励 + SysVipInfo referrerVip = sysVipInfoDao.selectById(vipInfo.getRecommendId()); + if (parentScore > 0) { + scoreVipDetailService.addScore( + referrerVip.getId(), + projServices.getCreateStaffId(), + projServices.getShopId(), + parentScore, + projServices.getId(), + ScoreVipDetail.SCORE_VIP_TYPE_CASH, + "推荐消耗奖励" + ); + } + //推荐注册二级带新积分奖励 + if (referrerVip.getRecommendId() != null) { + SysVipInfo topVipInfo = sysVipInfoDao.selectById(referrerVip.getRecommendId()); + if (topParentScore > 0) { + scoreVipDetailService.addScore( + topVipInfo.getId(), + projServices.getCreateStaffId(), + projServices.getShopId(), + topParentScore, + projServices.getId(), + ScoreVipDetail.SCORE_VIP_TYPE_CASH, + "推荐消耗奖励" + ); + } + } + } + } // 派单 jyy @@ -616,10 +796,11 @@ @Override public int modifyPLProjServices(SysProjServices projServicesVo) throws GlobleException { SysProjServices projServices = sysProjServicesDao.selectById(projServicesVo.getId()); - + SysUsers sysUsers = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); if (!projServices.getState().equals(Dictionary.SERVICE_STATU_XPL)) { throw new GlobleException("该服务单状态为" + projServices.getState() + ",不可以进行当前操作!"); } + projServicesVo.setCompanyId(projServices.getCompanyId()); if (isNeedOutStore(projServicesVo)) { // 生成出库单 @@ -628,10 +809,10 @@ outStore.setOutStoreNo(codeService.getOutStoreCode()); outStore.setShopId(projServices.getShopId()); - if(projServices.getDevisionId()!=null){ + if (projServices.getDevisionId() != null) { outStore.setStaffId(projServices.getDevisionId()); - }else{ - SysUsers sysUsers = WebUtil.getSessionAttribute(MatrixConstance.LOGIN_KEY); + } else { + outStore.setStaffId(sysUsers.getSuId()); } outStore.setServiceId(projServices.getId()); @@ -655,7 +836,7 @@ double sum = stores.stream().mapToDouble(item2 -> item2.getStoreTotal()).sum(); Double needAmount = MoneyUtil.div(item.getAmount(), Double.valueOf(shoppingGoods.getVolume())); if (sum < needAmount) { - throw new GlobleException("出库失败:【" + shoppingGoods.getName() + "库存不足】"); + throw new GlobleException("出库失败:【" + shoppingGoods.getName() + "-" + shoppingGoods.getCode() + "库存不足】"); } //循环获取所有批次产品,并扣减库存 for (SysStoreInfo storeInfo : stores) { @@ -671,8 +852,6 @@ sysOutStoreItem.setStoreId(storeInfo.getId()); sysOutStoreItem.setAmount(oldStoreTotal - storeInfo.getStoreTotal()); realOutStoreItemList.add(sysOutStoreItem); - - storeInfoDao.update(storeInfo); //扣除后剩余库存大于0则跳出扣除,否则剩余数量的负数的绝对值就是再次扣减的数量 if (surplus > 0) { @@ -686,43 +865,55 @@ LogUtil.debug("未选择配料跳过sku={},amount={}", item.getSkuId(), item.getAmount()); } } - sysOutStoreItemDao.batchInsert(realOutStoreItemList); + } + // 设置服务单状态 +// projServices.setState(Dictionary.SERVICE_STATU_PLWC); + if (projServices.getDevisionId() == null) { + //如果没有设置配料师则默认为操作配料的人为配料师 + projServices.setDevisionId(sysUsers.getSuId()); } - // 设置服务单状态 - projServices.setState(Dictionary.SERVICE_STATU_PLWC); - // 设置服务单操作流水 - // TODO 本功能待完善记录最新的排班员工 - /* List<LastestWorkBeatuistaff> lastList = LastestWorkBeatuistaffDao.selectByModel(null); - LastestWorkBeatuistaff lastWork = new LastestWorkBeatuistaff(); - if (lastList.size() > 0) { - lastWork.setChangeDate(new Date()); - lastWork.setStaffId(projServices.getBeauticianId()); - LastestWorkBeatuistaffDao.insert(lastWork); - } else { - - //TODO 有bug集合为零了 - LastestWorkBeatuistaff modifyObj = lastList.get(0); - modifyObj.setChangeDate(new Date()); - modifyObj.setStaffId(projServices.getBeauticianId()); - LastestWorkBeatuistaffDao.update(modifyObj); - }*/ - + // 判断是否跳过开始/结束服务 + if (skipServiceOrderStep(Dictionary.SERVICE_OVER_BEGIN_END)) { + projServices.setStartTime(new Date()); + projServices.setState(Dictionary.SERVICE_STATU_FWWC); + } else { + projServices.setState(Dictionary.SERVICE_STATU_PLWC); + } + // 释放床位资源 +// SysBedState checkBedState = sysBedStateDao.selectBySerIdAndBedId(projServices.getBedId(), projServices.getId()); +// if (checkBedState != null) { +// checkBedState.setBedState(Dictionary.BED_STATE_SYJS); +// bedStateDao.update(checkBedState); +// } +// projServices.setStartTime(new Date()); +// projServices.setEndTime(new Date()); +// // 计算时差 +// long minspace = DateUtil.getDifTimeMin(projServices.getStartTime(), projServices.getEndTime()) +// - projServices.getTotalTime(); +// // 判断是服务超时还是服务提前结束,如果minspace大于0则是超时服务,小于0则是提前结束服务 +// projServices.setIsOverTime(minspace + ""); +// projServices.setState(Dictionary.SERVICE_STATU_FWWC); return sysProjServicesDao.update(projServices); } /** * 服务单收费需要生成出库记录 + * * @param projServicesVo * @return */ private boolean isNeedOutStore(SysProjServices projServicesVo) { - if(CollectionUtils.isNotEmpty(projServicesVo.getOutStoreItem())){ - for (SysOutStoreItem item : projServicesVo.getOutStoreItem()) { - if (item.getAmount() != null && item.getAmount() > 0) { - return true; + + if (CollectionUtils.isNotEmpty(projServicesVo.getOutStoreItem())) { + BusParameterSettings manageStockSetting = busParameterSettingsDao.selectCompanyParamByCode(AppConstance.WAREHOUSE_MANAGE_STOCK, projServicesVo.getCompanyId()); + if(AppConstance.IS_Y.equals(manageStockSetting.getParamValue())){ + for (SysOutStoreItem item : projServicesVo.getOutStoreItem()) { + if (item.getAmount() != null && item.getAmount() > 0) { + return true; + } } } } @@ -776,7 +967,6 @@ SysBeauticianState checkBeauticianState = new SysBeauticianState(); checkBeauticianState.setServicesId(projServices.getId()); checkBeauticianState.setState(Dictionary.BEATUI_STATE_FWJS); - checkBeauticianState.setStaffId(users.getSuId()); int rerunlt = beauticianStateDao.chengItemState(checkBeauticianState); // 验证是否是最后一个美疗师结束服务 @@ -806,7 +996,6 @@ } return rerunlt; - } @Override @@ -830,4 +1019,28 @@ public int findApiServiceOrderListTotal(ServiceOrderListDto serviceOrderListDto) { return sysProjServicesDao.selectApiServiceOrderListTotal(serviceOrderListDto); } + + /** + * 跳过服务单某步骤 + */ + @Override + public boolean skipServiceOrderStep(String step) { + SysUsers users = (SysUsers) WebUtil.getSession().getAttribute(MatrixConstance.LOGIN_KEY); + ParameterSettings ps = new ParameterSettings(); + ps.setCompanyId(users.getCompanyId()); + ps.setCategory("店务配置"); + List<ParameterSettings> settings = parameterSettingsDao.getByCategory(ps); + + boolean flag = false; + if (CollUtil.isNotEmpty(settings)) { + for (ParameterSettings setting : settings) { + if (step.equals(setting.getCode()) && Dictionary.FLAG_YES.equals(setting.getUserValue())) { + flag = true; + break; + } + } + } + + return flag; + } } -- Gitblit v1.9.1