From f7200af79bd10609f00a63587aff2586dc948cee Mon Sep 17 00:00:00 2001 From: lige <bestlige@outlook.com> Date: 星期二, 05 十二月 2023 10:54:12 +0800 Subject: [PATCH] 列表重大阳性标记 --- ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java | 377 ++++++++++++++++++++++++++++++----------------------- 1 files changed, 210 insertions(+), 167 deletions(-) diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java index ac5be6f..82561aa 100644 --- a/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java +++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/service/TjSysAsyncServiceImpl.java @@ -41,7 +41,7 @@ @Service @Transactional -public class TjSysAsyncServiceImpl implements TjAsyncService { +public class TjSysAsyncServiceImpl implements TjAsyncService { @Resource private ITjProjectService projectService; @Resource @@ -102,20 +102,20 @@ public void newSaveextracted(TjOrder tjOrder, TjCustomer tjCustomer, BigDecimal discount, SysUser sysUser, TjReservation tjReservation, TjFlowingWater tjFlowingWater) { long l = System.currentTimeMillis(); - LambdaQueryWrapper<TjAskMedicalHistory> wq=new LambdaQueryWrapper<>(); - wq.eq(TjAskMedicalHistory::getCusId,tjCustomer.getCusId()); + LambdaQueryWrapper<TjAskMedicalHistory> wq = new LambdaQueryWrapper<>(); + wq.eq(TjAskMedicalHistory::getCusId, tjCustomer.getCusId()); wq.isNull(TjAskMedicalHistory::getTjNum); TjAskMedicalHistory history = tjAskMedicalHistoryService.getOne(wq); - if(null !=history){ + if (null != history) { history.setTjNum(tjOrder.getTjNumber()); tjAskMedicalHistoryService.updateById(history); } - List<TbTransition> tbTransitionList =null; + List<TbTransition> tbTransitionList = null; if (redisCache.hasKey(tjCustomer.getCusIdcard())) { tbTransitionList = redisCache.getCacheList(tjCustomer.getCusIdcard()); redisCache.deleteObject(tjCustomer.getCusIdcard()); - }else { + } else { LambdaQueryWrapper<TbTransition> wqq = new LambdaQueryWrapper<>(); wqq.eq(TbTransition::getCusId, tjCustomer.getCusIdcard()); tbTransitionList = transitionService.list(wqq); @@ -124,7 +124,7 @@ redisCache.deleteObject(tjCustomer.getCusIdcard() + "cusId"); if (null != tbTransitionList && tbTransitionList.size() > 0) { - tjOrderDetailService.saveTjOrderDetailsByCusId(tjCustomer.getCusIdcard(),String.valueOf(tjOrder.getOrderId()),sysUser.getNickName(),String.valueOf(sysUser.getUserId())); + tjOrderDetailService.saveTjOrderDetailsByCusId(tjCustomer.getCusIdcard(), String.valueOf(tjOrder.getOrderId()), sysUser.getNickName(), String.valueOf(sysUser.getUserId())); //淇敼姣忛」鐨勫師浠风幇浠� for (TbTransition transition : tbTransitionList) { @@ -136,10 +136,10 @@ LambdaQueryWrapper<TjOrderDetail> wrapper1 = new LambdaQueryWrapper<>(); wrapper1.eq(TjOrderDetail::getOrderId, tjOrder.getOrderId()); List<TjOrderDetail> list = tjOrderDetailService.list(wrapper1); - if (list != null && list.size()>0) { + if (list != null && list.size() > 0) { for (TjOrderDetail tjOrderDetail : list) { TjProject tjProject = projectService.getById(tjOrderDetail.getProId()); - if(tjProject==null){ + if (tjProject == null) { continue; } tjOrderDetail.setProject(tjProject); @@ -162,25 +162,25 @@ tjOrderDetail.setFlowingWaterId(String.valueOf(tjFlowingWater.getTjSerialNumber())); } } - if(tjFlowingWater.getPayStasus()==1){ + if (tjFlowingWater.getPayStasus() == 1) { tjOrderDetail.setFlowingWaterId(String.valueOf(tjFlowingWater.getTjSerialNumber())); } tjOrderDetailService.updateById(tjOrderDetail); } } - System.out.println("杩欐浠g爜鏃堕棿"+(l-System.currentTimeMillis())); + System.out.println("杩欐浠g爜鏃堕棿" + (l - System.currentTimeMillis())); } @Override @Async("async") - public void ttextracted(TjOrder tjOrder, TjCustomer tjCustomer,SysUser sysUser, TjReservation tjReservation, TjFlowingWater tjFlowingWater) { + public void ttextracted(TjOrder tjOrder, TjCustomer tjCustomer, SysUser sysUser, TjReservation tjReservation, TjFlowingWater tjFlowingWater) { - tjAskMedicalHistoryService.updateTjAskMedicalHistoryByCusId(tjOrder.getTjNumber(),sysUser.getNickName(),String.valueOf(sysUser.getUserId()), String.valueOf(tjCustomer.getCusId())); + tjAskMedicalHistoryService.updateTjAskMedicalHistoryByCusId(tjOrder.getTjNumber(), sysUser.getNickName(), String.valueOf(sysUser.getUserId()), String.valueOf(tjCustomer.getCusId())); boolean b = tjOrderDetailService.saveTjOrderDetailsByCusId(tjCustomer.getCusIdcard(), String.valueOf(tjOrder.getOrderId()), sysUser.getNickName(), String.valueOf(sysUser.getUserId())); - if (!b){ - List<TjGroupingPro> proList = groupingProService.list(new LambdaQueryWrapper<TjGroupingPro>().eq(TjGroupingPro::getGroupingId,tjOrder.getGroupId())); - if(null !=proList && proList.size()>0){ + if (!b) { + List<TjGroupingPro> proList = groupingProService.list(new LambdaQueryWrapper<TjGroupingPro>().eq(TjGroupingPro::getGroupingId, tjOrder.getGroupId())); + if (null != proList && proList.size() > 0) { for (TjGroupingPro groupingPro : proList) { TjOrderDetail detail = new TjOrderDetail(); // if (null != transition.getPacId()) { @@ -213,9 +213,9 @@ detail.setCreateId(String.valueOf(sysUser.getUserId())); detail.setUpdateId(String.valueOf(sysUser.getUserId())); //鑾峰彇璇ラ」鐩殑榛樿鍊艰祴鍊肩粰缁撴灉 - if(null !=project.getProDefault()){ + if (null != project.getProDefault()) { detail.setProResult(project.getProDefault()); - }else { + } else { detail.setProResult(null); } detail.setIsSampling(String.valueOf(project.getIsSampling())); @@ -226,18 +226,18 @@ } //娣诲姞remark琛ㄦ暟鎹� - orderRemarkService.saveTjOrderRemarkByOrderId(tjOrder.getTjNumber(),sysUser.getNickName(),String.valueOf(sysUser.getUserId()), String.valueOf(tjOrder.getOrderId())); + orderRemarkService.saveTjOrderRemarkByOrderId(tjOrder.getTjNumber(), sysUser.getNickName(), String.valueOf(sysUser.getUserId()), String.valueOf(tjOrder.getOrderId())); //鍒ゆ柇鏄惁浜ら挶 if ("1".equals(tjOrder.getTjType())) { if (null != tjReservation && tjReservation.getPayType() == 1) { tjOrderDetailService.updateTjOrderDetailsByOrderId(String.valueOf(tjOrder.getOrderId()), - sysUser.getNickName(), String.valueOf(sysUser.getUserId()),String.valueOf(tjFlowingWater.getTjSerialNumber())); + sysUser.getNickName(), String.valueOf(sysUser.getUserId()), String.valueOf(tjFlowingWater.getTjSerialNumber())); } } if (tjFlowingWater.getPayStasus() == 1) { tjOrderDetailService.updateTjOrderDetailsByOrderId(String.valueOf(tjOrder.getOrderId()), - sysUser.getNickName(), String.valueOf(sysUser.getUserId()),String.valueOf(tjFlowingWater.getTjSerialNumber())); + sysUser.getNickName(), String.valueOf(sysUser.getUserId()), String.valueOf(tjFlowingWater.getTjSerialNumber())); } // List<TjOrderDetail> list = tjOrderDetailService.getTjOrderDetailsByOrderId(String.valueOf(tjOrder.getOrderId())); @@ -279,7 +279,7 @@ @Async("async") public void collectFees(TjOrder order, List<TjConsumables> list2, List<TbTransition> tbTransitionList, SysUser sysUser, String discount) { orderRemarkService.deletedOrderRemarkByTjNum(order.getTjNumber()); - redisCache.deleteObject("getOrderDetailByProParentId"+order.getTjNumber()); + redisCache.deleteObject("getOrderDetailByProParentId" + order.getTjNumber()); for (TbTransition transition : tbTransitionList) { transition.setNowPrice(transition.getOrdPrice().multiply(BigDecimal.valueOf(Double.parseDouble(discount)).divide(BigDecimal.valueOf(10)))); transitionService.updateById(transition); @@ -317,7 +317,7 @@ list2.add(tjConsumables); } } - TjOrderRemark tjOrderRemark=new TjOrderRemark(); + TjOrderRemark tjOrderRemark = new TjOrderRemark(); tjOrderRemark.setProId(parentProId); tjOrderRemark.setProName(parentProject.getProName()); tjOrderRemark.setDeptId(parentProject.getDeptId()); @@ -330,7 +330,7 @@ tjOrderRemark.setUpdateId(String.valueOf(sysUser.getUserId())); orderRemarkService.save(tjOrderRemark); Map<String, Object> map = getOrderDetailByProParentId(String.valueOf(parentProId), order.getTjNumber()); - redisCache.setCacheMapValue("getOrderDetailByProParentId"+order.getTjNumber(),String.valueOf(parentProId),map); + redisCache.setCacheMapValue("getOrderDetailByProParentId" + order.getTjNumber(), String.valueOf(parentProId), map); } } } @@ -354,25 +354,25 @@ } LambdaQueryWrapper<TjOrderDetail> wq = new LambdaQueryWrapper<>(); - wq.eq(TjOrderDetail::getOrderId,order.getOrderId()); + wq.eq(TjOrderDetail::getOrderId, order.getOrderId()); wq.isNotNull(TjOrderDetail::getFlowingWaterId); - wq.eq(TjOrderDetail::getIsSampling,0); + wq.eq(TjOrderDetail::getIsSampling, 0); List<TjOrderDetail> detailList = tjOrderDetailService.list(wq); - if(null !=detailList && detailList.size()>0){ + if (null != detailList && detailList.size() > 0) { String format = DateUtil.format(new Date(), "yyMMddHHmmssSSS"); for (TjOrderDetail detail : detailList) { - TjSampling sampling=new TjSampling(); - if(null==projectService.getById(detail.getProId())) continue; + TjSampling sampling = new TjSampling(); + if (null == projectService.getById(detail.getProId())) continue; Long proParentId = projectService.getById(detail.getProId()).getProParentId(); - if(null !=proParentId && proParentId ==0){ + if (null != proParentId && proParentId == 0) { sampling.setSpecimenType(projectService.getById(detail.getProId()).getSpecimenType()); - }else { + } else { sampling.setSpecimenType(projectService.getById(projectService.getById(detail.getProId()).getProParentId()).getSpecimenType()); } sampling.setSamplingNumber(format); sampling.setTjNum(order.getTjNumber()); sampling.setCusId(String.valueOf(order.getUserId())); - if (tjCustomerService.getById(String.valueOf(order.getUserId()))!=null) { + if (tjCustomerService.getById(String.valueOf(order.getUserId())) != null) { sampling.setCusName(tjCustomerService.getById(String.valueOf(order.getUserId())).getCusName()); } sampling.setApplicationTime(new Date()); @@ -392,7 +392,7 @@ @Override @Async("async") - public void abandonCheck(String tjNumber, TjOrder tjOrder, List<TjOrderDetail> list, SysUser sysUser) { + public void abandonCheck(String tjNumber, TjOrder tjOrder, List<TjOrderDetail> list, SysUser sysUser) { for (TjOrderDetail tjOrderDetail : list) { LambdaQueryWrapper<TjProject> wq1 = new LambdaQueryWrapper<>(); wq1.eq(TjProject::getProId, tjOrderDetail.getProId()); @@ -444,12 +444,12 @@ @Override @Async("async") - public void iundividualCharges(TjFlowingWater tjFlowingWater, TjOrder order, TjCustomer customer, SysUser sysUser) { + public void iundividualCharges(TjFlowingWater tjFlowingWater, TjOrder order, TjCustomer customer, SysUser sysUser) { List<TjConsumables> list2 = new ArrayList<>(); String[] tjProIds = tjFlowingWater.getTjProIds(); for (String tjProId : tjProIds) { TjProject project = projectService.selectTjProjectByProId(Long.valueOf(tjProId)); - TjOrderRemark tjOrderRemark=new TjOrderRemark(); + TjOrderRemark tjOrderRemark = new TjOrderRemark(); tjOrderRemark.setProId(Long.valueOf(tjProId)); tjOrderRemark.setProName(project.getProName()); tjOrderRemark.setDeptId(project.getDeptId()); @@ -555,8 +555,8 @@ public void dockerSetCustomerLisByRedis(List<Long> ksproList, String ksId) { List<TjCustomer> yjAjaxResult = getYjAjaxResult(ksproList); List<TjCustomer> wjAjaxResult = getWjAjaxResult(ksproList); - redisCache.setCacheMapValue(ksId + "ks", "wj",wjAjaxResult); - redisCache.setCacheMapValue(ksId + "ks", "yj",yjAjaxResult); + redisCache.setCacheMapValue(ksId + "ks", "wj", wjAjaxResult); + redisCache.setCacheMapValue(ksId + "ks", "yj", yjAjaxResult); } @Override @@ -564,16 +564,16 @@ public void checkSetCustomerLisByRedis(String config) { List<TjCustomer> wsResult = getWsResult(config); List<TjCustomer> ysResult = getYsResult(config); - redisCache.setCacheMapValue("check", "ws",wsResult); - redisCache.setCacheMapValue("check", "ys",ysResult); + redisCache.setCacheMapValue("check", "ws", wsResult); + redisCache.setCacheMapValue("check", "ys", ysResult); //鏌ヨ } @Override @Async("async") - public void wCScheckSetCustomerLisByRedis( List<TjOrder> orderList) { + public void wCScheckSetCustomerLisByRedis(List<TjOrder> orderList) { List<TjCustomer> customerList = new ArrayList<>(); - if(null !=orderList && orderList.size()>0){ + if (null != orderList && orderList.size() > 0) { for (TjOrder tjOrder : orderList) { if (null != tjOrder) { TjCustomer customer = tjCustomerService.selectTjCustomerByCusId(tjOrder.getUserId()); @@ -601,14 +601,14 @@ } } } - redisCache.setCacheMapValue("cScheck", "ws",customerList); + redisCache.setCacheMapValue("cScheck", "ws", customerList); } @Override @Async("async") - public void yCScheckSetCustomerLisByRedis( List<TjOrder> orderList) { + public void yCScheckSetCustomerLisByRedis(List<TjOrder> orderList) { List<TjCustomer> customerList = new ArrayList<>(); - if(null !=orderList && orderList.size()>0){ + if (null != orderList && orderList.size() > 0) { for (TjOrder tjOrder : orderList) { if (null != tjOrder) { TjCustomer customer = tjCustomerService.selectTjCustomerByCusId(tjOrder.getUserId()); @@ -636,7 +636,7 @@ } } } - redisCache.setCacheMapValue("cScheck", "ys",customerList); + redisCache.setCacheMapValue("cScheck", "ys", customerList); } @@ -647,24 +647,25 @@ LambdaQueryWrapper<TjProject> wq0 = new LambdaQueryWrapper<>(); wq0.eq(TjProject::getProParentId, refundPro.getProId()); List<Long> collect = projectService.list(wq0).stream().map(TjProject::getProId).collect(Collectors.toList()); - LambdaQueryWrapper<TjSampling>wq1=new LambdaQueryWrapper<>(); - wq1.eq(TjSampling::getTjNum,tjNum); - wq1.in(TjSampling::getProId,collect); + LambdaQueryWrapper<TjSampling> wq1 = new LambdaQueryWrapper<>(); + wq1.eq(TjSampling::getTjNum, tjNum); + wq1.in(TjSampling::getProId, collect); List<TjSampling> list = samplingService.list(wq1); - if(null !=list && list.size()>0) samplingService.removeByIds(list.stream().map(TjSampling::getId).collect(Collectors.toList())); - LambdaQueryWrapper<TjSampling>wq2=new LambdaQueryWrapper<>(); - wq2.eq(TjSampling::getTjNum,tjNum); - wq2.eq(TjSampling::getProId,refundPro.getProId()); + if (null != list && list.size() > 0) + samplingService.removeByIds(list.stream().map(TjSampling::getId).collect(Collectors.toList())); + LambdaQueryWrapper<TjSampling> wq2 = new LambdaQueryWrapper<>(); + wq2.eq(TjSampling::getTjNum, tjNum); + wq2.eq(TjSampling::getProId, refundPro.getProId()); samplingService.remove(wq2); - redisCache.deleteCacheMapValue("getOrderDetailByProParentId"+tjNum, String.valueOf(refundPro.getProId())); + redisCache.deleteCacheMapValue("getOrderDetailByProParentId" + tjNum, String.valueOf(refundPro.getProId())); } } @Override @Async("async") public void saveSampling() { - redisCache.setCacheMapValue("sampling", "yqs",getYWqsResult(0)); - redisCache.setCacheMapValue("sampling", "wqs",getYWqsResult(1)); + redisCache.setCacheMapValue("sampling", "yqs", getYWqsResult(0)); + redisCache.setCacheMapValue("sampling", "wqs", getYWqsResult(1)); } @Override @@ -674,7 +675,7 @@ TjOrderRemark remark = orderRemarkService.getById(domainVo.getRemarkId()); TjOrder order = orderService.getOrderByTjNum(domainVo.getTjNumber()); //缁欏純妫�琛ㄦ坊鍔犺褰� - if(domainVo.getType().equals(2)){ + if (domainVo.getType().equals(2)) { TjDiscardInspection td = new TjDiscardInspection(); td.setProId(String.valueOf(remark.getProId())); td.setProName(projectService.selectTjProjectByProId(remark.getProId()).getProName()); @@ -689,23 +690,23 @@ td.setCreateId(String.valueOf(sysUser.getUserId())); td.setUpdateId(String.valueOf(sysUser.getUserId())); discardInspectionService.save(td); - redisCache.deleteCacheMapValue("getOrderDetailByProParentId"+domainVo.getTjNumber(),String.valueOf(remark.getProId())); + redisCache.deleteCacheMapValue("getOrderDetailByProParentId" + domainVo.getTjNumber(), String.valueOf(remark.getProId())); } - LambdaQueryWrapper<TjProject>wq1=new LambdaQueryWrapper<>(); - wq1.eq(TjProject::getProParentId,remark.getProId()); + LambdaQueryWrapper<TjProject> wq1 = new LambdaQueryWrapper<>(); + wq1.eq(TjProject::getProParentId, remark.getProId()); List<TjProject> projectList = projectService.list(wq1); - if(null !=projectList && projectList.size()>0){ + if (null != projectList && projectList.size() > 0) { List<Long> collect = projectList.stream().map(TjProject::getProId).collect(Collectors.toList()); - LambdaQueryWrapper<TjOrderDetail>wq2=new LambdaQueryWrapper<>(); - wq2.eq(TjOrderDetail::getOrderId,order.getOrderId()); - wq2.in(TjOrderDetail::getProId,collect); + LambdaQueryWrapper<TjOrderDetail> wq2 = new LambdaQueryWrapper<>(); + wq2.eq(TjOrderDetail::getOrderId, order.getOrderId()); + wq2.in(TjOrderDetail::getProId, collect); List<TjOrderDetail> detailList = tjOrderDetailService.list(wq2); - if(null !=detailList && detailList.size()>0){ + if (null != detailList && detailList.size() > 0) { for (TjOrderDetail detail : detailList) { detail.setTjStatus(Long.valueOf(remark.getType())); - if(null !=remark.getRemark()) detail.setRemark(domainVo.getRemark()); - if(null !=remark.getYqDeadline()) detail.setYqDeadline(remark.getYqDeadline()); + if (null != remark.getRemark()) detail.setRemark(domainVo.getRemark()); + if (null != remark.getYqDeadline()) detail.setYqDeadline(remark.getYqDeadline()); tjOrderDetailService.updateById(detail); } } @@ -722,7 +723,7 @@ tjOrder.setUpdateId(String.valueOf(sysUser.getUserId())); orderService.updateById(tjOrder); TjCustomer customer = tjCustomerService.selectTjCustomerByCusId(tjOrder.getUserId()); - TjYqOrder yqOrder=new TjYqOrder(); + TjYqOrder yqOrder = new TjYqOrder(); yqOrder.setTjNum(s); yqOrder.setCusName(customer.getCusName()); yqOrder.setSex(String.valueOf(customer.getCusSex())); @@ -751,7 +752,7 @@ for (TjPackageProject tjPackageProject : ppList) { TjProject project = projectService.getById(tjPackageProject.getProId()); if (null != project) { - BigDecimal divide = tjPackageProject.getPriceNow().divide(project.getProPrice(),5, RoundingMode.DOWN); + BigDecimal divide = tjPackageProject.getPriceNow().divide(project.getProPrice(), 5, RoundingMode.DOWN); LambdaQueryWrapper<TjProject> wq2 = new LambdaQueryWrapper<>(); wq2.eq(TjProject::getProParentId, project.getProId()); List<TjProject> tjProSonList = projectService.list(wq2); @@ -762,8 +763,8 @@ tbTransition.setPacId(pacId); if (null != tjPackageProject.getPriceNow() && divide.compareTo(BigDecimal.valueOf(0)) > 0) { - tbTransition.setNowPrice(tjProject.getProPrice().multiply(divide).setScale(2,RoundingMode.HALF_DOWN)); - tbTransition.setOrdPrice(tjProject.getProPrice().multiply(divide).setScale(2,RoundingMode.HALF_DOWN)); + tbTransition.setNowPrice(tjProject.getProPrice().multiply(divide).setScale(2, RoundingMode.HALF_DOWN)); + tbTransition.setOrdPrice(tjProject.getProPrice().multiply(divide).setScale(2, RoundingMode.HALF_DOWN)); } else { tbTransition.setNowPrice(BigDecimal.valueOf(0.00)); tbTransition.setOrdPrice(BigDecimal.valueOf(0.00)); @@ -786,12 +787,12 @@ @Override @Async("async") - public void saveRedisTransitionByPacId(String cusId, Long pacId,List<Long> proIds) { - if(null != pacId){ - transitionService.saveRedisTransitionByPacId(cusId,pacId); + public void saveRedisTransitionByPacId(String cusId, Long pacId, List<Long> proIds) { + if (null != pacId) { + transitionService.saveRedisTransitionByPacId(cusId, pacId); } - if(null != proIds && proIds.size() > 0){ - saveRedisTransitionByProId(cusId,proIds); + if (null != proIds && proIds.size() > 0) { + saveRedisTransitionByProId(cusId, proIds); } } @@ -848,19 +849,19 @@ getTjPackageListByWoMan(tjPackageService.getTjPackageListByWoMan()); //鏈煡 - getTjPackageListByManAndWoMan(tjPackageService.list(new LambdaQueryWrapper<TjPackage>().eq(TjPackage::getPacStatus,0))); + getTjPackageListByManAndWoMan(tjPackageService.list(new LambdaQueryWrapper<TjPackage>().eq(TjPackage::getPacStatus, 0))); } @Override @Async("async") - public void addNewReservationConfirm(List<TjReservation> rightList ) { - if(null !=rightList && rightList.size()>0){ + public void addNewReservationConfirm(List<TjReservation> rightList) { + if (null != rightList && rightList.size() > 0) { for (TjReservation reservation : rightList) { transitionService.deletedTbTransitionByCusId(reservation.getIdCard()); List<AddNewReservationConfirm> confirmList = groupingProService.getAddNewReservationConfirm(reservation.getGroupingId()); - if (null !=confirmList && confirmList.size()>0){ + if (null != confirmList && confirmList.size() > 0) { for (AddNewReservationConfirm confirm : confirmList) { - List<TbTransition> transitionss = transitionService.getTbTransitionListByCusIdAndPacIdAndProId(reservation.getIdCard(),confirm.getPid()); + List<TbTransition> transitionss = transitionService.getTbTransitionListByCusIdAndPacIdAndProId(reservation.getIdCard(), confirm.getPid()); if (null != transitionss && transitionss.size() > 0) { continue; } @@ -889,7 +890,7 @@ @Override @Async("async") public void saveNewReservationConfirm(List<TjReservation> rightList) { - if(null !=rightList && rightList.size()>0){ + if (null != rightList && rightList.size() > 0) { //鍒涘缓绾跨▼姹� ExecutorService threadPool = Executors.newFixedThreadPool(rightList.size()); for (TjReservation reservation : rightList) { @@ -900,7 +901,7 @@ @Override public void run() { try { - transitionService.saveTemoTransitionByGroupingId(reservation.getIdCard(),reservation.getGroupingId()); + transitionService.saveTemoTransitionByGroupingId(reservation.getIdCard(), reservation.getGroupingId()); threadPool.shutdown(); } catch (Exception e) { @@ -915,16 +916,16 @@ @Override @Async("async") public void updateCheckType(String tjNum) { - redisCache.setCacheMapValue("updateCheckType"+tjNum,tjNum,getAjaxResult(tjNum)); - redisCache.setHashKeyExpireTime("updateCheckType"+tjNum,7L, TimeUnit.DAYS); + redisCache.setCacheMapValue("updateCheckType" + tjNum, tjNum, getAjaxResult(tjNum)); + redisCache.setHashKeyExpireTime("updateCheckType" + tjNum, 7L, TimeUnit.DAYS); } @Override @Async("async") public void getPrintOrderList(List<TjOrder> list) { - redisCache.setCacheMapValue("getPrintOrderList","0",extracted(0, list)); - redisCache.setCacheMapValue("getPrintOrderList","1",extracted(1, list)); + redisCache.setCacheMapValue("getPrintOrderList", "0", extracted(0, list)); + redisCache.setCacheMapValue("getPrintOrderList", "1", extracted(1, list)); } @@ -932,31 +933,31 @@ @Async("async") public void getDictSfxms() { List<DictSfxm> dictSfxm = getDictSfxm(); - redisCache.setCacheObject("getDictSfxms",dictSfxm); + redisCache.setCacheObject("getDictSfxms", dictSfxm); } @Override @Async("async") - public void getOrderDetailByProParentId(String tjNumber,Map<String, Object> map,String proParentId) { - if(null !=map && !map.isEmpty()){ - redisCache.setCacheMapValue("getOrderDetailByProParentId"+tjNumber,proParentId,map); - }else { - redisCache.setCacheMapValue("getOrderDetailByProParentId"+tjNumber,proParentId,getOrderDetailByProParentId(proParentId,tjNumber)); + public void getOrderDetailByProParentId(String tjNumber, Map<String, Object> map, String proParentId) { + if (null != map && !map.isEmpty()) { + redisCache.setCacheMapValue("getOrderDetailByProParentId" + tjNumber, proParentId, map); + } else { + redisCache.setCacheMapValue("getOrderDetailByProParentId" + tjNumber, proParentId, getOrderDetailByProParentId(proParentId, tjNumber)); } - redisCache.setHashKeyExpireTime("getOrderDetailByProParentId"+tjNumber,7L,TimeUnit.DAYS); + redisCache.setHashKeyExpireTime("getOrderDetailByProParentId" + tjNumber, 7L, TimeUnit.DAYS); } @Override @Async("async") public void getLineChart() { - redisCache.setCacheObject("getLineChart",getLineCharts()); + redisCache.setCacheObject("getLineChart", getLineCharts()); } @Override @Async("async") public void getPieChart() { - redisCache.setCacheObject("getPieChart",getPieCharts()); + redisCache.setCacheObject("getPieChart", getPieCharts()); } //棣栭〉楗肩姸鍥剧櫥璁颁汉鏁版帴鍙� @@ -1103,8 +1104,9 @@ } return dictSfxms; } + private List<TjOrder> extracted(Integer type, List<TjOrder> list) { - List<TjOrder> list1=new ArrayList<>(); + List<TjOrder> list1 = new ArrayList<>(); for (TjOrder order : list) { TjCustomer tjCustomer = tjCustomerService.selectTjCustomerByCusId(order.getUserId()); if (null != tjCustomer) { @@ -1112,8 +1114,10 @@ order.setTjCustomerAge(DateUtil.ageOfNow(tjCustomer.getCusBrithday())); order.setGrMoBanId(reportService.getGrMoBanIds()); order.setTjCustomerName(MatchUtils.hideCusName(tjCustomer.getCusName())); - if(null!=tjCustomer.getCusPhone())order.setTjCustomerPhone(MatchUtils.hidePhoneNum(tjCustomer.getCusPhone())); - if(null!=tjCustomer.getCusIdcard())order.setTjCusIdCard(MatchUtils.hideIdCardNum(tjCustomer.getCusIdcard())); + if (null != tjCustomer.getCusPhone()) + order.setTjCustomerPhone(MatchUtils.hidePhoneNum(tjCustomer.getCusPhone())); + if (null != tjCustomer.getCusIdcard()) + order.setTjCusIdCard(MatchUtils.hideIdCardNum(tjCustomer.getCusIdcard())); } String firmId = order.getFirmId(); if (firmId != null && null != compService.selectDictCompByDrugManufacturerId(String.valueOf(order.getFirmId()))) { @@ -1142,6 +1146,7 @@ } return list1; } + private void getTjPackageListsByMan(List<TjPackage> tjPackageList) { if (null != tjPackageList && tjPackageList.size() > 0) { for (TjPackage aPackage : tjPackageList) { @@ -1179,12 +1184,13 @@ aPackage.setAllProName(allProName.toString()); aPackage.setAllSonName(allSonName); } - if(redisCache.hasKey("getTjPackageListBySex")){ - redisCache.deleteCacheMapValue("getTjPackageListBySex","getTjPackageListByMan"); + if (redisCache.hasKey("getTjPackageListBySex")) { + redisCache.deleteCacheMapValue("getTjPackageListBySex", "getTjPackageListByMan"); } - redisCache.setCacheMapValue("getTjPackageListBySex","getTjPackageListByMan",tjPackageList); + redisCache.setCacheMapValue("getTjPackageListBySex", "getTjPackageListByMan", tjPackageList); } } + private void getTjPackageListByWoMan(List<TjPackage> tjPackageList) { if (null != tjPackageList && tjPackageList.size() > 0) { for (TjPackage aPackage : tjPackageList) { @@ -1222,12 +1228,13 @@ aPackage.setAllProName(allProName.toString()); aPackage.setAllSonName(allSonName); } - if(redisCache.hasKey("getTjPackageListBySex")){ - redisCache.deleteCacheMapValue("getTjPackageListBySex","getTjPackageListByWoMan"); + if (redisCache.hasKey("getTjPackageListBySex")) { + redisCache.deleteCacheMapValue("getTjPackageListBySex", "getTjPackageListByWoMan"); } - redisCache.setCacheMapValue("getTjPackageListBySex","getTjPackageListByWoMan",tjPackageList); + redisCache.setCacheMapValue("getTjPackageListBySex", "getTjPackageListByWoMan", tjPackageList); } } + private void getTjPackageListByManAndWoMan(List<TjPackage> tjPackageList) { if (null != tjPackageList && tjPackageList.size() > 0) { for (TjPackage aPackage : tjPackageList) { @@ -1253,12 +1260,13 @@ aPackage.setAllProName(allProName.toString()); aPackage.setAllSonName(allSonName); } - if(redisCache.hasKey("getTjPackageListBySex")){ - redisCache.deleteCacheMapValue("getTjPackageListBySex","getTjPackageListByManAndWoMan"); + if (redisCache.hasKey("getTjPackageListBySex")) { + redisCache.deleteCacheMapValue("getTjPackageListBySex", "getTjPackageListByManAndWoMan"); } - redisCache.setCacheMapValue("getTjPackageListBySex","getTjPackageListByManAndWoMan",tjPackageList); + redisCache.setCacheMapValue("getTjPackageListBySex", "getTjPackageListByManAndWoMan", tjPackageList); } } + //宸叉 public List<TjCustomer> getYjAjaxResult(List<Long> ksproList) { List<TjCustomer> customerLis = new ArrayList<>(); @@ -1276,20 +1284,28 @@ for (Long orderId : orderIds) { if (null != orderId) { TjOrder order = orderService.getById(orderId); - if(null ==order){ + if (null == order) { continue; } LambdaQueryWrapper<TjOrderDetail> qww = new LambdaQueryWrapper<>(); qww.eq(TjOrderDetail::getOrderId, order.getOrderId()); - qww.eq(TjOrderDetail::getTjStatus, 0); + qww.eq(TjOrderDetail::getTjStatus,0); qww.isNotNull(TjOrderDetail::getFlowingWaterId); List<TjOrderDetail> lists = tjOrderDetailService.list(qww); - if (null != lists && lists.size() > 0) { + if (null != lists&&lists.size()>0) { continue; } TjCustomer customer = tjCustomerService.getById(order.getUserId()); if (null != customer) { + //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬� 鏍囪 + for (TjOrderDetail tjOrderDetail11 : lists) { + customer.setIsPositive(tjOrderDetail11.getIsPositive()); + if (tjOrderDetail11.getIsPositive()==1){ + break; + } + } + customer.setCusName(hideCusName(customer.getCusName())); customer.setCusPhone(hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(hideIdCardNum(customer.getCusIdcard())); @@ -1306,7 +1322,7 @@ customer.setIsHz(order.getIsHz()); LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>(); wq.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); - wq.in(TjOrderRemark::getType, 0,3); + wq.in(TjOrderRemark::getType, 0, 3); List<TjOrderRemark> list = orderRemarkService.list(wq); if (null != list && list.size() > 0) { StringBuilder stringBuilder = new StringBuilder(); @@ -1315,7 +1331,7 @@ stringBuilder.append(byId.getProName()).append(";"); } customer.setNotCheckeds(String.valueOf(stringBuilder)); - if(null ==customer.getNotCheckeds())customer.setNotCheckeds("鍏ㄩ儴宸叉"); + if (null == customer.getNotCheckeds()) customer.setNotCheckeds("鍏ㄩ儴宸叉"); } customerLis.add(customer); } @@ -1324,6 +1340,7 @@ } return customerLis; } + //鏈 public List<TjCustomer> getWjAjaxResult(List<Long> ksproList) { List<TjCustomer> customerLis = new ArrayList<>(); @@ -1341,11 +1358,27 @@ for (Long orderId : orderIds) { if (null != orderId) { TjOrder order = orderService.getById(orderId); - if(null ==order){ + if (null == order) { continue; } + TjCustomer customer = tjCustomerService.getById(order.getUserId()); + if (null != customer) { + LambdaQueryWrapper<TjOrderDetail> qww = new LambdaQueryWrapper<>(); + qww.eq(TjOrderDetail::getOrderId, order.getOrderId()); + qww.isNotNull(TjOrderDetail::getFlowingWaterId); + List<TjOrderDetail> lists = tjOrderDetailService.list(qww); + if (null != lists) { + //閬嶅巻椤圭洰 鍒ゆ柇鏄惁鏈夐噸澶ч槼鎬� 鏍囪 + for (TjOrderDetail tjOrderDetail11 : lists) { + customer.setIsPositive(tjOrderDetail11.getIsPositive()); + if (tjOrderDetail11.getIsPositive()==1){ + break; + } + } + } + customer.setCusName(hideCusName(customer.getCusName())); customer.setCusPhone(hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(hideIdCardNum(customer.getCusIdcard())); @@ -1363,7 +1396,7 @@ customer.setTjStatus(0L); LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>(); wq.eq(TjOrderRemark::getTjNumber, order.getTjNumber()); - wq.in(TjOrderRemark::getType, 0,3); + wq.in(TjOrderRemark::getType, 0, 3); List<TjOrderRemark> list = orderRemarkService.list(wq); if (null != list && list.size() > 0) { StringBuilder stringBuilder = new StringBuilder(); @@ -1372,7 +1405,7 @@ stringBuilder.append(byId.getProName()).append(";"); } customer.setNotCheckeds(String.valueOf(stringBuilder)); - if(null ==customer.getNotCheckeds())customer.setNotCheckeds("鍏ㄩ儴宸叉"); + if (null == customer.getNotCheckeds()) customer.setNotCheckeds("鍏ㄩ儴宸叉"); } customerLis.add(customer); } @@ -1381,22 +1414,24 @@ } return customerLis; } + //宸插 private List<TjCustomer> getYsResult(String config) { List<TjOrder> orderList = null; - if("Y".equals(config)){ - orderList = orderService.getCsTjOrderList1(null,1,null,null,null); - }else { - orderList = orderService.getTjOrderList(null,1,null,null,null); + if ("Y".equals(config)) { + orderList = orderService.getCsTjOrderList1(null, 1, null, null, null); + } else { + orderList = orderService.getTjOrderList(null, 1, null, null, null); } List<TjCustomer> customerList = new ArrayList<>(); - if(null !=orderList && orderList.size()>0){ + if (null != orderList && orderList.size() > 0) { for (TjOrder tjOrder : orderList) { if (null != tjOrder) { TjCustomer customer = tjCustomerService.selectTjCustomerByCusId(tjOrder.getUserId()); if (customer == null) { continue; } + customer.setCusName(hideCusName(customer.getCusName())); customer.setCusPhone(hidePhoneNum(customer.getCusPhone())); customer.setCusIdcard(hideIdCardNum(customer.getCusIdcard())); @@ -1420,16 +1455,17 @@ } return customerList; } + //鏈 private List<TjCustomer> getWsResult(String config) { List<TjOrder> orderList = null; - if("Y".equals(config)){ - orderList = orderService.getCsTjOrderList1(null,0,null,null,null); - }else { - orderList = orderService.getTjOrderList(null,0,null,null,null); + if ("Y".equals(config)) { + orderList = orderService.getCsTjOrderList1(null, 0, null, null, null); + } else { + orderList = orderService.getTjOrderList(null, 0, null, null, null); } List<TjCustomer> customerList = new ArrayList<>(); - if(null !=orderList && orderList.size()>0) { + if (null != orderList && orderList.size() > 0) { for (TjOrder tjOrder : orderList) { if (null != tjOrder) { TjCustomer customer = tjCustomerService.selectTjCustomerByCusId(tjOrder.getUserId()); @@ -1459,6 +1495,7 @@ } return customerList; } + //鎬绘鐐瑰嚮浣撴淇℃伅璇︽儏 private List<Map<String, Object>> getAjaxResult(String tjNumber) { List<Map<String, Object>> list = new ArrayList<>(); @@ -1482,10 +1519,10 @@ if (null != tjOrderDetails && tjOrderDetails.size() > 0) { for (TjOrderDetail tjOrderDetail : tjOrderDetails) { final TjProject byId = projectService.selectTjProjectByProId(tjOrderDetail.getProId()); - if(null==byId){ - tjOrderDetailService.removeById(tjOrderDetail.getOrderDetailId()); - }else { - tjOrderDetail.setProject(byId); + if (null == byId) { + tjOrderDetailService.removeById(tjOrderDetail.getOrderDetailId()); + } else { + tjOrderDetail.setProject(byId); } List<TjStandard> list2 = tjStandardService.getTjStandardListByProId(String.valueOf(tjOrderDetail.getProId())); if (list2.size() == 0) { @@ -1494,7 +1531,7 @@ tjOrderDetail.setStandard(list2.get(0)); } else { final int ageType = StringUtils.getAgeType(DateUtil.ageOfNow(customer.getCusBrithday())); - TjStandard tjStandard1=tjStandardService.getListBySexAndType(customer.getCusSex(),ageType, String.valueOf(tjOrderDetail.getProId())); + TjStandard tjStandard1 = tjStandardService.getListBySexAndType(customer.getCusSex(), ageType, String.valueOf(tjOrderDetail.getProId())); tjOrderDetail.setStandard(tjStandard1); } } @@ -1524,19 +1561,20 @@ } return list; } + //宸茬鏀�/鏈鏀� - private List<Map<String, Object>> getYWqsResult(int a) { - LambdaQueryWrapper<TjSampling>wq=new LambdaQueryWrapper<>(); - List<Map<String,Object>> arrayList=new ArrayList<>(); + private List<Map<String, Object>> getYWqsResult(int a) { + LambdaQueryWrapper<TjSampling> wq = new LambdaQueryWrapper<>(); + List<Map<String, Object>> arrayList = new ArrayList<>(); wq.orderByDesc(TjSampling::getApplicationTime); - wq.eq(TjSampling::getIsSignFor,a); + wq.eq(TjSampling::getIsSignFor, a); List<TjSampling> list = tjSamplingService.list(wq); - if(null != list && list.size()>0 ){ + if (null != list && list.size() > 0) { Map<String, List<TjSampling>> stringListMap = list.stream().collect(Collectors.groupingBy(TjSampling::getCusId)); for (Map.Entry<String, List<TjSampling>> entry : stringListMap.entrySet()) { - Map<String,Object>map=new HashMap<>(); + Map<String, Object> map = new HashMap<>(); TjCustomer customer = tjCustomerService.getById(entry.getKey()); - if (customer==null){ + if (customer == null) { continue; } customer.setCusName(hideCusName(customer.getCusName())); @@ -1545,43 +1583,44 @@ customer.setTjNumber(entry.getValue().get(0).getTjNum()); customer.setApplicationTime(entry.getValue().get(0).getApplicationTime()); List<TjSampling> samplings = entry.getValue(); - if(null !=samplings && samplings.size()>0){ - List<TjSampling> projectList=new ArrayList<>(); + if (null != samplings && samplings.size() > 0) { + List<TjSampling> projectList = new ArrayList<>(); for (TjSampling sampling : samplings) { TjProject project = projectService.getById(sampling.getProId()); - if(null !=project && project.getProParentId()==0){ + if (null != project && project.getProParentId() == 0) { projectList.add(sampling); } } - map.put("list",projectList); + map.put("list", projectList); } - map.put("customer",customer); + map.put("customer", customer); arrayList.add(map); } } return arrayList; } + /** * 闅愯棌鎵嬫満鍙� * * @param phoneNum * @return */ - public static String hidePhoneNum(String phoneNum){ - if(null==phoneNum){ + public static String hidePhoneNum(String phoneNum) { + if (null == phoneNum) { return ""; } - if(phoneNum.contains("*")){ + if (phoneNum.contains("*")) { return phoneNum; } Pattern pattern = Pattern.compile("((13[0-9])|(14[5,7,9])|(15([0-3]|[5-9]))|(17[0,1,3,5,6,7,8])|(18[0-9])|(19[8|9]))\\d{8}"); Matcher matcher = pattern.matcher(phoneNum); StringBuffer sb = new StringBuffer(); try { - while(matcher.find()) { + while (matcher.find()) { String phoneStr = matcher.group(); phoneStr = phoneStr.substring(0, 3) + "****" + phoneStr.substring(7, phoneStr.length()); - matcher.appendReplacement(sb,phoneStr); + matcher.appendReplacement(sb, phoneStr); } matcher.appendTail(sb); } catch (Exception ex) { @@ -1589,30 +1628,31 @@ } return sb.toString(); } + /** * 闅愯棌韬唤璇佸彿鐮� * * @param idCardNum * @return */ - public static String hideIdCardNum(String idCardNum){ - if(null==idCardNum){ + public static String hideIdCardNum(String idCardNum) { + if (null == idCardNum) { return ""; } - if(idCardNum.contains("*")){ + if (idCardNum.contains("*")) { return idCardNum; } Pattern pattern = Pattern.compile("(\\d{6})(19|20)(\\d{2})(1[0-2]|0[1-9])(0[1-9]|[1-2][0-9]|3[0-1])(\\d{3})(\\d|X|x)"); Matcher matcher = pattern.matcher(idCardNum); StringBuffer sb = new StringBuffer(); try { - while(matcher.find()) { + while (matcher.find()) { String idCardStr = matcher.group(); - int len=idCardStr.length(); - if(len>=9){ - idCardStr = idCardStr.replaceAll("(.{"+(len<12?3:6)+"})(.*)(.{4})", "$1" + "****" + "$3"); + int len = idCardStr.length(); + if (len >= 9) { + idCardStr = idCardStr.replaceAll("(.{" + (len < 12 ? 3 : 6) + "})(.*)(.{4})", "$1" + "****" + "$3"); } - matcher.appendReplacement(sb,idCardStr); + matcher.appendReplacement(sb, idCardStr); } matcher.appendTail(sb); } catch (Exception ex) { @@ -1620,32 +1660,34 @@ } return sb.toString(); } + /** * 闅愯棌鐢ㄦ埛濮撳悕 * * @param cusName * @return */ - public static String hideCusName(String cusName){ - if(null==cusName){ + public static String hideCusName(String cusName) { + if (null == cusName) { return ""; } - if(!cusName.contains("*")){ - String realname=null; - char[] r = cusName.toCharArray(); - if(r.length ==1){ - realname = cusName; + if (!cusName.contains("*")) { + String realname = null; + char[] r = cusName.toCharArray(); + if (r.length == 1) { + realname = cusName; } - if(r.length == 2){ - realname = cusName.replaceFirst(cusName.substring(1),"*"); + if (r.length == 2) { + realname = cusName.replaceFirst(cusName.substring(1), "*"); } if (r.length > 2) { - realname = cusName.replaceFirst(cusName.substring(1,r.length-1) ,"*"); + realname = cusName.replaceFirst(cusName.substring(1, r.length - 1), "*"); } return realname; } return cusName; } + //涓存椂琛ㄦ坊鍔犲崟椤� public void saveRedisTransitionByProId(String cusId, List<Long> proIds) { for (Long proId : proIds) { @@ -1653,9 +1695,10 @@ if (null != transitionList && transitionList.size() > 0) { continue; } - transitionService.saveRedisTransitionByProId(cusId,proId); + transitionService.saveRedisTransitionByProId(cusId, proId); } } + //鍚戠紦瀛樹腑娣诲姞 鐖堕」鐩殑瀛愰」鐩鎯� private Map<String, Object> getOrderDetailByProParentId(String proParentId, String tjNumber) { TjOrderRemark remark = orderRemarkService.getTjOrderRemarkByTjNumAndProParentId(tjNumber, proParentId); @@ -1736,7 +1779,7 @@ List<TjAdvice> adviceList = new ArrayList<>(); if (null != remark) { String[] strings = StringUtils.split(remark.getSummary(), ";"); - if(null !=strings && strings.length>0){ + if (null != strings && strings.length > 0) { List<TjAdvice> list = tjAdviceService.getAdviceStringByIds(strings); adviceList.addAll(list); } -- Gitblit v1.8.0