From dc9f340fa83555c30655a0e42c175a91d81d65d2 Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期二, 25 三月 2025 18:24:03 +0800
Subject: [PATCH] zjh20250325

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java |  245 +++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 196 insertions(+), 49 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
index 82c2df8..1ac6726 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjOrderController.java
@@ -90,6 +90,7 @@
 import org.aspectj.weaver.ast.Var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.http.HttpRequest;
 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.security.access.prepost.PreAuthorize;
@@ -240,6 +241,8 @@
     @Autowired
     private TbTransitionMapper tbTransitionMapper;
 
+    private static final String TJH = "tjhs:tjh";
+
     //灏嗘柟娉曡繑鍥炲�艰В鏋愭垚json鏍煎紡
     public JSONObject getJSONObject(String builder) {
         String Response = JSONUtil.parseObj(builder).getStr("Response");
@@ -305,7 +308,7 @@
             wqq.like(TjCustomer::getCusName, name);
             List<TjCustomer> customerList = tjCustomerService.list(wqq);
             List<TjOrder> list2 = new ArrayList<>();
-            if (null != customerList && customerList.size() > 0) {
+            if (null != customerList && !customerList.isEmpty()) {
                 List<TjOrder> list = new ArrayList<>();
                 for (TjCustomer customer : customerList) {
                     LambdaQueryWrapper<TjOrder> wq = new LambdaQueryWrapper<>();
@@ -316,13 +319,13 @@
                     list.addAll(tjOrderService.list(wq));
                 }
                 List<TjOrder> collect = null;
-                if (list.size() > 0) {
+                if (!list.isEmpty()) {
                     for (TjOrder order : list) {
                         //绛涢�夋湁璋冩煡闂嵎鐨�
                         LambdaQueryWrapper<TjSurveyRecord> wqq1 = new LambdaQueryWrapper<>();
                         wqq1.eq(TjSurveyRecord::getTjnumber, order.getTjNumber());
                         List<TjSurveyRecord> one = surveyRecordService.list(wqq1);
-                        if (one.size() == 0) {
+                        if (one.isEmpty()) {
                             TjCustomer tjCustomer = tjCustomerService.getById(order.getUserId());
                             if (null != tjCustomer) {
                                 order.setTjCustomerName(MatchUtils.hideCusName(tjCustomer.getCusName()));
@@ -383,7 +386,7 @@
                 LambdaQueryWrapper<TjSurveyRecord> wqq = new LambdaQueryWrapper<>();
                 wqq.eq(TjSurveyRecord::getTjnumber, order.getTjNumber());
                 List<TjSurveyRecord> one = surveyRecordService.list(wqq);
-                if (one.size() == 0) {
+                if (one.isEmpty()) {
                     TjCustomer tjCustomer = tjCustomerService.getById(order.getUserId());
                     if (null != tjCustomer) {
                         order.setTjCustomerName(MatchUtils.hideCusName(tjCustomer.getCusName()));
@@ -547,7 +550,7 @@
                 wq.isNull(TjOrder::getPrintLastTime);
             }
             if (zt == 6) {
-                //宸插嚭鎶ュ憡
+                //宸叉墦鍗�
                 wq.isNotNull(TjOrder::getPrintLastTime);
                 wq.eq(TjOrder::getHeshouStatus, 1);
                 wq.isNotNull(TjOrder::getPrintLastTime);
@@ -606,7 +609,7 @@
                         order.setZt("鎶ュ憡鏍告敹");
                     }
                     if (zt == 6) {
-                        order.setZt("宸插嚭鎶ュ憡");
+                        order.setZt("宸叉墦鍗�");
                     }
                 } else {
                     if (czwj == 0) {
@@ -634,8 +637,8 @@
                         order.setZt("鎶ュ憡鏍告敹");
                     }
                     if (null != lastTime) {
-                        //宸插嚭鎶ュ憡6
-                        order.setZt("宸插嚭鎶ュ憡");
+                        //宸叉墦鍗�6
+                        order.setZt("宸叉墦鍗�");
                     }
                 }
             }
@@ -1034,7 +1037,7 @@
             }
             tjReservation.setIsExpire(1);
             tjReservationService.updateById(tjReservation);
-            if (null != tjReservation.getTeamNo() && tjOrder.getTjType().equals("1")) {
+            if (null != tjReservation.getTeamNo()) {
                 tjOrder.setTjType("1");
             } else if (tjOrder.getTjType().equals("2")) {
                 tjOrder.setTjType("2");
@@ -1082,7 +1085,10 @@
                 tjOrderService.tjQiandaodengji(tjOrder.getTjNumber());
                 return result;
             }
-        } finally {
+        }catch (Exception e){
+            log.error(String.valueOf(e));
+        }
+        finally {
             lock.unlock();
         }
         return AjaxResult.error();
@@ -1092,14 +1098,19 @@
     public AjaxResult processOrderWithTransaction(TjOrder tjOrder, TjCustomer tjCustomer, TjReservation tjReservation, TjFlowingWater tjFlowingWater, MallOrder mallOrder, SysUser sysUser) {
 
         //鑾峰彇鎷兼帴鍓嶇紑
-        String makeLisTmhPrefix = configService.selectConfigByKey("make_lis_tmh_prefix");
+        String sfkqtjhqz = configService.selectConfigByKey("sfkqtjhqz");
+        String makeLisTmhPrefix = "";
+        if(sfkqtjhqz.equalsIgnoreCase("Y")){
+             makeLisTmhPrefix = configService.selectConfigByKey("make_lis_tmh_prefix");
+        }
 
         //鐢熸垚浣撴鍙�
 //        String tjNumber = (SecurityUtils.getUsername() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
 //        if(StringUtil.isNotBlank(makeLisTmhPrefix)) tjNumber=makeLisTmhPrefix+tjNumber;
 
 
-        String tjNumber = (SecurityUtils.getUsername() + IdUtils.getTjNumber());
+//        String tjNumber = (SecurityUtils.getUsername() + idUtils.getTjNumber());
+        String tjNumber = idUtils.getTjNumber();
         if (StringUtil.isNotBlank(makeLisTmhPrefix)) tjNumber = makeLisTmhPrefix + tjNumber;
         tjOrder.setTjNumber(tjNumber);
 
@@ -1229,6 +1240,7 @@
                 }*/
                 // 鏌ヨ 瀵规帴Lis銆丳acs鐢宠濡傛灉绫诲瀷鍖呭惈鍦ㄩ厤缃唴鍒欎娇鐢ㄥ鎺is銆乸acs
                 if (lisApiMethod.isUseLisAndPacsRegister(tjOrder)) {
+                    log.info("璋冪敤his寮�鍚� 杩涘叆涓嶆敹璐规柟娉� 璇ヤ綋妫�浜哄憳涓嶆敹璐�:"+tjOrder.getTjNumber());
                     // 杩欐槸涓婇潰涓汉鏂规硶寮曞叆鏁版嵁
                     tjFlowingWater.setPayStasus(1L);
                     newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
@@ -1239,14 +1251,18 @@
                     remarkService.updateTjOrderRemarkSfbzByJxbzisnull(tjOrder.getOrderId().toString(), tjFlowingWater.getTjSerialNumber().toString());
                     List<TjXdPicture> xdPictureList = xdPictureService.saveTjXdPicture(tjOrder.getTjNumber());
                     xdPictureService.saveBatch(xdPictureList);
-//                    List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(tjOrder.getOrderId());
-//                    addCaiYangDengJi(detailList, !detailList.isEmpty(), tjOrder, sysUser, null);
+                    List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(tjOrder.getOrderId());
+                    addCaiYangDengJi(detailList, !detailList.isEmpty(), tjOrder, sysUser, null);
+                    log.info("璋冪敤his寮�鍚� 杩涘叆涓嶆敹璐规柟娉� 璇ユ柟娉曟墽琛屽畬姣�");
                 } else {
+                    log.info("璋冪敤his寮�鍚� 杩涘叆鏀惰垂鏂规硶 璇ヤ綋妫�浜哄憳涓嶆敹璐�:"+tjOrder.getTjNumber());
                     newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
                     List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(tjOrder.getOrderId());
                     addCaiYangDengJi(detailList, !detailList.isEmpty(), tjOrder, sysUser, null);
-
-                    hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
+                    String isUseMx = configService.selectConfigByKey("jcxhis_is_use_mx");
+                    if (isUseMx.equalsIgnoreCase("Y"))
+                        hisApiMethod.tijianshenqing(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
+                    else hisApiMethod.tijianshenqingJinchuanNew(tjCustomer, DateUtil.format(date1, "yyyy-MM-dd HH:mm:ss"), tjOrder.getCardId());
                 }
                 return AjaxResult.success(tjNumber);
             } else {
@@ -1343,7 +1359,9 @@
 
             // 鏌ヨ 瀵规帴Lis銆丳acs鐢宠濡傛灉绫诲瀷鍖呭惈鍦ㄩ厤缃唴鍒欎娇鐢ㄥ鎺is銆乸acs
 
+            log.info("绛惧埌鐧昏鎺ュ彛璇ヤ汉鍛�: "+tjOrder.getTjNumber()+" 鐨勪綋妫�绫诲瀷鏄�:"+tjOrder.getTjType());
             if (lisApiMethod.isUseLisAndPacsRegister(tjOrder)) {
+                log.info(tjOrder.getTjNumber()+"绛惧埌鐧昏杩涘叆鏈敹璐规柟娉�");
                 // 杩欐槸涓婇潰涓汉鏂规硶寮曞叆鏁版嵁
                 tjFlowingWater.setPayStasus(1L);
                 newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
@@ -1353,9 +1371,11 @@
                 List<TjXdPicture> xdPictureList = xdPictureService.saveTjXdPicture(tjOrder.getTjNumber());
                 xdPictureService.saveBatch(xdPictureList);
                 List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(tjOrder.getOrderId());
+                log.info(tjOrder.getTjNumber()+"绛惧埌鐧昏:閲囨牱鏁版嵁鏌ヨ涓暟"+detailList.size());
                 addCaiYangDengJi(detailList, !detailList.isEmpty(), tjOrder, sysUser, null);
                 return AjaxResult.success(tjNumber);
             } else {
+                log.info(tjOrder.getTjNumber()+"else绛惧埌鐧昏杩涘叆鏀惰垂鏂规硶");
                 newSaveextracted(tjOrder, tjCustomer, discount, sysUser, tjReservation, tjFlowingWater);
                 AjaxResult error = isRequestCommonHisApi(tjOrder, tjCustomer, tjFlowingWater);
                 if (error != null) return error;
@@ -1393,6 +1413,7 @@
             wrapper.gt(TbTransition::getNowPrice, 0);
 
             List<TbTransition> list = tbTransitionService.list(wrapper);
+            BigDecimal zongjia = new BigDecimal("0.0");
             for (TbTransition transition : list) {
                 LambdaQueryWrapper<TjProject> wrapper1 = new LambdaQueryWrapper<>();
                 wrapper1.eq(TjProject::getProId, transition.getProId());
@@ -1403,7 +1424,8 @@
                 SysDept dept = sysDeptService.getOne(wrapper2);
 
                 JSONObject obj = JSONUtil.createObj();
-                Integer sl = project.getSl();
+//                Integer sl = project.getSl();
+                int sl = 1;
                 BigDecimal danjia = transition.getNowPrice();
                 BigDecimal allPrice = danjia.multiply(new BigDecimal(sl));
                 obj.putOpt("danJia", danjia);
@@ -1414,8 +1436,10 @@
                 obj.putOpt("shouFeiXmId", project.getHisXmbm());
                 obj.putOpt("shouFeiXmMc", project.getHisXmmc());
                 array.add(obj);
+                zongjia = zongjia.add(allPrice);
             }
             map.put("feiYongInfoList", array);
+            log.info("璋冪敤His鎺ュ彛鍓� 鏀惰垂鎬讳环:{}", zongjia.toString());
 
             String post = HttpClientUtils.sendPost(apiUrl + "/api/his/" + hospbm + "/creatCostInfo", map);
             JSONObject object = JSONUtil.parseObj(post);
@@ -1522,6 +1546,28 @@
     }
 
 
+
+    @GetMapping("/addCaiYangDengJi")
+    @ApiOperation(value = "鎵嬪姩娣诲姞閲囨牱璁板綍鎺ュ彛")
+    public AjaxResult addCaiYangDengJi(@RequestParam("tjNum") String tjNum){
+
+        try {
+            TjOrder order = tjOrderService.getOrderByTjNum(tjNum);
+            if(null !=order){
+                Long userId = Long.valueOf(SecurityUtils.getLoginUser().getUserId());
+                SysUser sysUser = userService.getById(userId);
+                List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(order.getOrderId());
+                log.info("绛惧埌鐧昏:閲囨牱鏁版嵁鏌ヨ涓暟"+detailList.size());
+                addCaiYangDengJi(detailList, !detailList.isEmpty(), order, sysUser, null);
+            }
+        } catch (NumberFormatException e) {
+            log.error(String.valueOf(e));
+        }
+
+        return AjaxResult.success();
+    }
+
+
     @PostMapping("/addPlOrderAndDetail")
     @ApiOperation(value = "浣撴鎵归噺绛惧埌鐧昏鎺ュ彛")
 //    @Transactional  //(鍒囨崲鏁版嵁搴撳嚭閿欙紝鎵�浠ユ敞閲�)
@@ -1558,15 +1604,11 @@
 //                            }
 //                        }
 //                    });
-                    String tjh = (sysUser.getUserName() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
 
-
-
-                    String finalTjh = tjh;
                     Future<AjaxResult> future = executor.submit(new Callable<AjaxResult>() {
                         @Override
                         public AjaxResult call() throws Exception {
-                            return getAjaxResult(aLong, sysUser, daoDto.getTjCategory(), finalTjh);
+                            return getAjaxResult(aLong, sysUser, daoDto.getTjCategory());
                         }
                     });
                     try {
@@ -1580,7 +1622,7 @@
                             errTjh.add(userId);
                         }
                     } catch (InterruptedException | ExecutionException e) {
-                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//                        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                         e.printStackTrace();
                     }
                 }
@@ -1588,7 +1630,7 @@
             }
             // TODO 鍥犱负鏈変綋妫�鍙蜂細鏌ュ嚭绌烘暟鎹� 鍏堜娇鐢ㄦ鏁版嵁  鎵撳嵃瀵艰瘖鍗�
             if (!tjNumbers.isEmpty()) {
-                Map<String, Object> map = null;
+            /*    Map<String, Object> map = null;
                 try {
                     map = PDFDocumentUtil.getDocument();
                     Document document = (Document) map.get("document");
@@ -1643,19 +1685,33 @@
                 } catch (IOException | DocumentException e) {
                     TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
                     e.printStackTrace();
-                }
-                return AjaxResult.success("鎿嶄綔鎴愬姛");
+                }*/
+                Map<String,Object> map=new HashMap<>();
+                map.put("tjh",tjNumbers);
+                return AjaxResult.success("鎿嶄綔鎴愬姛",map);
             }
             if (!errTjh.isEmpty()){
-                return AjaxResult.success("浠ヤ笂浜哄憳绛惧埌澶辫触",errTjh);
+                Map<String,Object> map=new HashMap<>();
+                map.put("errtjh",errTjh);
+                return AjaxResult.success("浠ヤ笂浜哄憳绛惧埌澶辫触",map);
             }
             return AjaxResult.success();
         }
-        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
+//        TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
         return AjaxResult.error();
     }
 
-//    @Transactional
+    @GetMapping("/signOrderInfo")
+    public AjaxResult signOrderInfo(@RequestParam("tjNum") String tjNum){
+        List<Map<String, Object>> djdInfos = tjOrderService.selectDjdInfo(tjNum);
+        Map<String, Object> userInfo = tjOrderService.selectDjdUserInfo(tjNum);
+        HashMap<String, Object> hashMap = new HashMap<>();
+        hashMap.put("djd",djdInfos);
+        hashMap.put("user",userInfo);
+        return AjaxResult.success(hashMap);
+    }
+
+    @Transactional
     public void getAjaxResults(String cusIdcard) {
         if (!"".equals(cusIdcard) && cusIdcard != null) {
             //鏍规嵁閰嶇疆璋冨彇瀛樺偍杩囩▼ 灏嗕复鏃惰〃鏁版嵁瀛樺叆棰勭害琛�2023.12.12
@@ -1790,8 +1846,8 @@
         DynamicDataSourceContextHolder.clearDataSourceType();
     }
 
-//    @Transactional
-    public AjaxResult getAjaxResult(Long userId, SysUser sysUser, String tjCategory,String tjh) throws IOException {
+    @Transactional
+    public AjaxResult getAjaxResult(Long userId, SysUser sysUser, String tjCategory) throws IOException {
 
         LambdaQueryWrapper<TjCustomer> wq = new LambdaQueryWrapper<>();
         wq.eq(TjCustomer::getCusId, userId);
@@ -1848,14 +1904,34 @@
 //            tjReservationService.updateById(tjReservation);
 
             //鐢熸垚浣撴鍙�
-            String tjNumber = (sysUser.getUserName() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
+//            String tjNumber = (sysUser.getUserName() + new SimpleDateFormat("yyMMddHHmmss").format(new Date()));
+//            tjNumber = tjNumber.replaceAll(".{6}$", userId.toString().substring(userId.toString().length() - 6));
 
-            tjNumber = tjNumber.replaceAll(".{4}$", userId.toString().substring(userId.toString().length() - 4));
 
-            tjh = tjh.replaceAll(".{4}$", userId.toString().substring(userId.toString().length() - 4));
+            //鑾峰彇鎷兼帴鍓嶇紑
+            String makeLisTmhPrefix = configService.selectConfigByKey("make_lis_tmh_prefix");
+//            String tjNumber = (sysUser.getUserName() + idUtils.getTjNumber());
+            String tjNumber = idUtils.getTjNumber();
+            if (StringUtil.isNotBlank(makeLisTmhPrefix)) tjNumber = makeLisTmhPrefix + tjNumber;
 
-//            tjOrder.setTjNumber(tjNumber);
-            tjOrder.setTjNumber(tjh);
+
+//            if (redisCache.hasKey(TJH)) {
+//                while (true){
+//                    List<String> tjh = redisCache.getCacheList(TJH);
+//                    if(tjh.contains(tjNumber)){
+//                        tjNumber =(sysUser.getUserName() + IdUtils.getTjNumber());
+//                        if (StringUtil.isNotBlank(makeLisTmhPrefix)) tjNumber = makeLisTmhPrefix + tjNumber;
+//                    }else {
+//                        tjh.add(tjNumber);
+//                    }
+//                }
+//            }else {
+//                List<String> stringList = tjOrderService.
+//                        list(new LambdaQueryWrapper<TjOrder>().select(TjOrder::getTjNumber)).stream().map(TjOrder::getTjNumber).collect(Collectors.toList());
+//                stringList.add(tjNumber);
+//                redisCache.setCacheList(TJH,stringList);
+//            }
+            tjOrder.setTjNumber(tjNumber);
             if (null != tjOrder.getPhoto()) {
                 File file = new File(tjOrder.getPhoto());
                 if (file.isFile()) {
@@ -1900,8 +1976,12 @@
                 tjFlowingWater.setUpdateTime(date);
                 tjFlowingWater.setCreateBy(sysUser.getNickName());
                 tjFlowingWater.setUpdateBy(sysUser.getNickName());
-                tjFlowingWater.setCopeWith(tbTransitionMapper.sumTbTransitionOrdPriceByTjNum(tjOrder.getTjNumber()));
-                tjFlowingWater.setPaidIn(tbTransitionMapper.sumTbTransitionNowPriceByTjNum(tjOrder.getTjNumber()));
+//                BigDecimal bigDecimal = tbTransitionMapper.sumTbTransitionOrdPriceByTjNum(tjOrder.getTjNumber());
+                BigDecimal bigDecimal = tbTransitionMapper.sumTbTransitionOrdPriceByTjNumIsNull(tjCustomer.getCusIdcard());
+                tjFlowingWater.setCopeWith(bigDecimal);
+//                BigDecimal bigDecimal1 = tbTransitionMapper.sumTbTransitionNowPriceByTjNum(tjOrder.getTjNumber());
+                BigDecimal bigDecimal1 = tbTransitionMapper.sumTbTransitionNowPriceByTjNumIsNull(tjCustomer.getCusIdcard());
+                tjFlowingWater.setPaidIn(bigDecimal1);
                 tjFlowingWater.setDiscount(String.valueOf(10));
                 tjFlowingWater.setPayStasus(1L);
                 tjFlowingWater.setPayType(3L);
@@ -2075,9 +2155,11 @@
                     transitionService.saveRedisTransitionByPacId(cusId, cardId, pacId);
 
                     //琛ュ樊浠�
-                    List<Map<String, Object>> cjMaps = groupingProService.huoquxiangmuchajia(pacId.toString(), cusId);
+                    List<Map<String, Object>> cjMaps = transitionService.addTbhuoquxiangmuchajia(pacId.toString(), cusId);
                     if (null != cjMaps && !cjMaps.isEmpty()) {
+                        log.info("璇ュ椁�"+pacId+"涓湁宸环:"+cjMaps.size()+"涓�");
                         for (Map<String, Object> cjMap : cjMaps) {
+                            log.info("娣诲姞涓存椂琛ㄥ椁愭暟鎹椂鎵�閫夌殑宸环涓�:"+ cjMap.get("cj").toString());
                             transitionService.buxiangmuchajia(cusId, pacId.toString(), cjMap.get("xmid").toString(), new BigDecimal(cjMap.get("cj").toString()));
                         }
                     }
@@ -3690,6 +3772,20 @@
     }
 
 
+    @GetMapping("/chushenyemianyijianjiekou")
+    @ApiOperation(value = "鍒濆椤甸潰寮冩鎺ュ彛")
+    @Transactional
+    public AjaxResult chushenyemianyijianjiekou(@RequestParam String tjNUm, @RequestParam String proId) {
+        LambdaQueryWrapper<TjOrderRemark> wq = new LambdaQueryWrapper<>();
+        wq.eq(TjOrderRemark::getTjNumber, tjNUm);
+        wq.eq(TjOrderRemark::getProId, proId);
+        TjOrderRemark remark = remarkService.getOne(wq);
+        remark.setType(1);
+        remarkService.updateById(remark);
+        return AjaxResult.success("鎿嶄綔鎴愬姛!");
+    }
+
+
     @PostMapping("/zongjanyemianshjianzhou")
     @ApiOperation(value = "鎬绘鑾峰彇鏃堕棿杞存帴鍙�")
     @Transactional
@@ -3733,7 +3829,7 @@
                         a = 5;
                     }
                     if (null != lastTime) {
-                        //宸插嚭鎶ュ憡
+                        //宸叉墦鍗�
                         a = 6;
                     }
                     map.put("tjNUm", tjNUm);
@@ -3884,7 +3980,10 @@
     public AjaxResult updateTransitionnewPrice(@RequestBody List<UpdateTransitionnewPriceDto> dtos) {
 
         if (null != dtos && !dtos.isEmpty()) {
+            int index = 0;
+            boolean flag = false;
             for (UpdateTransitionnewPriceDto dto : dtos) {
+                index++;
                 LambdaQueryWrapper<TbTransition> wq = new LambdaQueryWrapper<>();
                 wq.eq(TbTransition::getCusId, dto.getCusIdCard());
                 wq.eq(TbTransition::getParentProId, dto.getParentProId());
@@ -3894,22 +3993,31 @@
                 log.info("鐖堕」鐩甶d涓�: " + dto.getParentProId());
                 log.info("鎶樻墸涓�: " + new BigDecimal(dto.getDiscount()));
                 if (null != list && !list.isEmpty()) {
-                    BigDecimal dxzj = transitionService.getTbTransitionPriceAndOrdPrice(dto.getCusIdCard(), dto.getParentProId());
+
                     for (TbTransition transition : list) {
                         BigDecimal ordPrice = transition.getOrdPrice();
                         BigDecimal multiply = ordPrice.multiply((new BigDecimal(dto.getDiscount()).divide(BigDecimal.valueOf(10))));
-                        log.info("鍚庣璁$畻鐨勯噾棰�: " + multiply);
+                        log.info("鍚庣璁$畻鐨勯噾棰�: " + multiply.toString());
                         transition.setNowPrice(multiply);
                         transition.setDiscount(new BigDecimal(dto.getDiscount()));
                         transitionService.updateById(transition);
                     }
-                    if (null != dto.getYhj() && dto.getYhj().compareTo(BigDecimal.ZERO) >= 0) {
-                        List<TbTransition> transitionList = list.stream().filter(a ->
-                                transitionService.getTbTransitionPriceAndOrdPrice(dto.getCusIdCard(), dto.getParentProId()).subtract(dto.getYhj()).compareTo(BigDecimal.ZERO) >= 0).collect(Collectors.toList());
-                        if (!transitionList.isEmpty()) {
-                            TbTransition tbTransition = transitionList.get(0);
-                            tbTransition.setNowPrice(dxzj);
-                            transitionService.updateById(tbTransition);
+
+                    BigDecimal dxzj = transitionService.getTbTransitionPriceAndOrdPrice(dto.getCusIdCard(), dto.getParentProId());
+
+                    BigDecimal yhj = dto.getYhj();
+                    log.info("鍓嶇浼犻�掔殑浠锋牸锛歿}",yhj.toString());
+                    BigDecimal cj = yhj.subtract(dxzj);
+                    log.info("璁$畻鐨勫樊浠凤細{}",cj.toString());
+                    for (TbTransition transition : list) {
+                        BigDecimal result = transition.getNowPrice().add(cj);
+                        log.info("琛ヤ笂宸环鍓嶇殑浠锋牸涓猴細{}",transition.getNowPrice().toString());
+                        if (result.compareTo(BigDecimal.ZERO)>0 && !flag && cj.compareTo(BigDecimal.ZERO) != 0){
+                            transition.setNowPrice(result);
+                            transitionService.updateById(transition);
+                            log.info("淇敼 琛ヤ笂宸环鍚庣殑浠锋牸涓猴細{}",result.toString());
+                            flag = true;
+                            break;
                         }
                     }
                 }
@@ -3951,5 +4059,44 @@
         }
         return AjaxResult.error();
     }
+
+
+
+    @PostMapping("/addBlTransition")
+    @ApiOperation(value = "琛ュ綍娣诲姞杩囨浮琛ㄦ暟鎹�")
+    @Transactional
+    public AjaxResult addBlTransition(@RequestBody Map<String, Object> map) {
+        Object packId = map.get("pacId");
+        if (null == map.get("cusId")) return AjaxResult.error("璇烽�夋嫨浣撴浜�");
+        String cusId = map.get("cusId").toString();
+        Object proIds1 = map.get("proIds");
+        List<Long> proIds = null;
+        if (null != proIds1 && !proIds1.equals("")) {
+            proIds = JSON.parseArray(proIds1.toString(), Long.class);
+        }
+        TjCustomer tjCustomer = tjCustomerService.getTjCustomerByCusIdCard(cusId);
+        String cardId = "0";
+        if (null != tjCustomer) {
+            cardId = tjCustomer.getCardId();
+        }
+        if ((null == proIds || proIds.isEmpty()) && (null == packId || packId.equals(""))) {
+            transitionService.deletedTbTransitionByCusId(cusId);
+        }
+
+        //鍗曢」
+        if (null != proIds && !proIds.isEmpty()) {
+            //寮傛淇濆瓨鏁版嵁搴撹〃
+            for (Long proId : proIds) {
+                TjProject project = projectService.selectTjProjectByProId(proId);
+                if (null != project) {
+                    List<TbTransition> transitionList = transitionService.getTbTransitionListByCusIdAndPacIdAndProId(cusId, String.valueOf(proId));
+                    if (null == transitionList || transitionList.isEmpty()) {
+                        transitionService.saveRedisTransitionByProId(cusId, cardId, proId);
+                    }
+                }
+            }
+        }
+        return AjaxResult.success();
+    }
 }
 

--
Gitblit v1.8.0