From 37e2d3c73caac445d1d8e229747b439e3719c13b Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期二, 03 六月 2025 17:04:13 +0800
Subject: [PATCH] zjh20250603

---
 ltkj-admin/src/main/java/com/ltkj/web/controller/callback/CallBackController.java |   63 ++++++++++++++++++++++++++++++-
 1 files changed, 61 insertions(+), 2 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/callback/CallBackController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/callback/CallBackController.java
index 5e7b337..ee9c8d3 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/callback/CallBackController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/callback/CallBackController.java
@@ -7,11 +7,14 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.ltkj.common.core.domain.AjaxResult;
+import com.ltkj.common.core.domain.entity.SysUser;
 import com.ltkj.hosp.domain.*;
 import com.ltkj.hosp.mapper.TjProjectMapper;
 import com.ltkj.hosp.mapper.TjSamplingMapper;
 import com.ltkj.hosp.service.*;
 import com.ltkj.system.service.ISysConfigService;
+import com.ltkj.system.service.ISysUserService;
+import com.ltkj.web.controller.system.TjOrderController;
 import com.ltkj.web.wxUtils.HttpClientUtils;
 import jodd.util.StringUtil;
 import lombok.extern.slf4j.Slf4j;
@@ -22,6 +25,7 @@
 import org.springframework.web.bind.annotation.RestController;
 
 import java.util.Arrays;
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.stream.Collectors;
@@ -55,6 +59,15 @@
     private ITjOrderService orderService;
     @Autowired
     private TjProjectMapper tjProjectMapper;
+    @Autowired
+    private ISysConfigService sysConfigService;
+    @Autowired
+    private TjOrderController tjOrderController;
+    @Autowired
+    private ISysUserService userService;
+    @Autowired
+    private TjOrderYcxmService ycxmService;
+
     /**
      * 鏀堕��璐瑰洖璋冩帴鍙�
      * @param params
@@ -94,6 +107,13 @@
 //                            wrapper1.set(TjSampling::getIsPay,1);
 //                            tjSamplingService.update(wrapper1);
                         }
+                        SysUser user = null;
+                        if (water.getCreateId()!= null)
+                            user = userService.getById(water.getCreateId());
+                        else user = userService.getById(1L);
+                        TjOrder tjOrder = orderService.getById(water.getOrderId());
+                        List<TjOrderDetail> detailList = tjOrderDetailService.getCaiYangDengJi(water.getOrderId());
+                        tjOrderController.addCaiYangDengJi(detailList, !detailList.isEmpty(), tjOrder, user, null);
                     }
                 }else {
                     return AjaxResult.error("鏌ヤ笉鍒版祦姘村彿: "+feiYongId);
@@ -106,7 +126,7 @@
                 if (order != null){
                     // 閫�璐�
                     String bldh = water.getJxbz();
-                    //TODO 鏄惁鍙戦�佷綔搴熺敵璇�
+//                    lisRevoke(water.getTjNumber(),bldh);
                     if (bldh != null){
                         remarkService.deleteTjOrderDetailByjxbz(bldh);
                         tjOrderDetailService.deleteTjOrderDetailByjxbz(bldh);
@@ -120,7 +140,7 @@
                         remarkService.deletedOrderRemarkByTjNum(order.getTjNumber());
                         tjFlowingWaterService.deleteTjFlowingWaterByOrderId(String.valueOf(order.getOrderId()));
                         transitionService.deletedTbTransitionByTjNum(order.getTjNumber());
-
+                        ycxmService.delOrderYcXmJyByTjh(order.getTjNumber());
                         TjCustomer customer = tjCustomerService.getById(order.getUserId());
                         customer.setCardId("0");
                         tjCustomerService.updateById(customer);
@@ -132,6 +152,45 @@
         return AjaxResult.success();
     }
 
+    private void lisRevoke(String tjNum,String jxbz){
+        LambdaQueryWrapper<TjSampling> wrapper = new LambdaQueryWrapper<>();
+        wrapper.eq(TjSampling::getTjNum,tjNum);
+        if (StrUtil.isNotBlank(jxbz))
+            wrapper.eq(TjSampling::getJxbz,jxbz);
+        List<TjSampling> list = tjSamplingMapper.selectList(wrapper);
+        List<TjSampling> isMergeList = list.stream().filter(i -> i.getIsMerge() == 1).collect(Collectors.toList());
+        JSONArray array = JSONUtil.createArray();
+        for (TjSampling sampling : isMergeList) {
+            String[] proIds = sampling.getProId().split(",");
+            for (String proId : proIds) {
+                JSONObject object = JSONUtil.createObj();
+                TjProject project = tjProjectMapper.selectById(proId);
+                object.putOpt("txm",sampling.getJyxh());
+                object.putOpt("sfxmid",project.getProId());
+                object.putOpt("sfxmname",project.getProName());
+                object.putOpt("primaryKey",proId);
+                array.add(object);
+            }
+            list = list.stream().filter(i -> !i.getProId().equals(sampling.getProId())).collect(Collectors.toList());
+        }
+        for (TjSampling sampling : list) {
+            String proId = sampling.getProId();
+            JSONObject object = JSONUtil.createObj();
+            TjProject project = tjProjectMapper.selectById(proId);
+            object.putOpt("txm",sampling.getJyxh());
+            object.putOpt("sfxmid",project.getProId());
+            object.putOpt("sfxmname",project.getProName());
+            object.putOpt("primaryKey",proId);
+            array.add(object);
+        }
+        String apiUrl = sysConfigService.selectConfigByKey("common_api_url");
+        String hospbm = sysConfigService.selectConfigByKey("common_api_service_hospbm");
+        HashMap<String, Object> hashMap = new HashMap<>();
+        hashMap.put("list",array);
+        String post = HttpClientUtils.sendPost(apiUrl + "/api/lis/"+ hospbm +"/revoke", hashMap);
+
+    }
+
     /**
      * 鑾峰彇鎵�鏈夌殑His瀛楀吀闆嗗悎
      * @param params

--
Gitblit v1.8.0