From 75605bab29e6e5db93f4ba1f12d9f2fe9015990c Mon Sep 17 00:00:00 2001
From: 赵文轩 <1652863494@qq.com>
Date: 星期四, 31 十月 2024 10:04:50 +0800
Subject: [PATCH] 采样登记抽出合并以及确认采样接口

---
 ltkj-hosp/src/main/java/com/ltkj/hosp/service/ITjSamplingService.java             |   12 +++
 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java     |   91 ++++++++++++++++++++++
 ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjSamplingMapper.java                |   12 +++
 ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java |   75 ++++--------------
 4 files changed, 133 insertions(+), 57 deletions(-)

diff --git a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java
index 0665064..0f529eb 100644
--- a/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java
+++ b/ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjSamplingController.java
@@ -68,8 +68,6 @@
     @Autowired
     private LisApiMethod lisApiMethod;
     @Autowired
-    private IdUtils idUtils;
-    @Autowired
     private ISysConfigService configService;
 
     /**
@@ -277,59 +275,8 @@
 
     @PostMapping("/mergeCaiYang")
     @ApiOperation(value = "閲囨牱鐧昏鍚堝苟椤圭洰鎺ュ彛")
-    @Transactional
     public AjaxResult mergeCaiYang(@RequestBody List<String> ids) {
-        if (null != ids && !ids.isEmpty()) {
-            if(ids.size()==1)return AjaxResult.error("璇烽�夋嫨鑷冲皯涓ゆ潯椤圭洰杩涜鍚堝苟!");
-            int i = tjSamplingService.panduanshifoukeyihebing(ids);
-            if (i > 1) {
-                return AjaxResult.error("鏍囨湰绫诲瀷涓嶄竴鑷�,涓嶅彲鍚堝苟");
-            }
-            int pdsfczhbxm = tjSamplingService.pdsfczhbxm(ids);
-            if (pdsfczhbxm == ids.size()) return AjaxResult.error("澶氫釜鍚堝苟椤圭洰涓嶅彲鍐嶇户缁悎骞�!");
-            if (pdsfczhbxm > 1) return AjaxResult.error("鏈�澶氬厑璁搁�夋嫨涓�涓悎骞惰繃鐨勯」鐩�!");
-//            鏌ヨ鍑洪噷闈笉鍙悎骞剁殑鍖栭獙椤圭洰
-            String string = tjSamplingService.getBuKeHebingProName(ids);
-            if(null !=string){
-                return AjaxResult.error(string+"杩欏嚑涓」鐩笉鍙悎骞�!");
-            }
-            if (pdsfczhbxm == 0) {
-                TjSampling tjSampling = tjSamplingService.getById(ids.get(0));
-                Map<String, Object> map = tjSamplingService.hebingCaiYangInFo(ids);
-                TjSampling sampling = new TjSampling();
-                String proId = map.get("proId").toString();
-                String proName = map.get("proName").toString();
-                BeanUtil.copyProperties(tjSampling, sampling, new String[]{"id"});
-                sampling.setProId(proId);
-                sampling.setProName(proName);
-                sampling.setIsMerge(1);
-                sampling.setJyxh(idUtils.generateLisID());
-                if (tjSamplingService.save(sampling)) {
-                    if (tjSamplingService.updateHeBingXm(ids, sampling.getId())) {
-                        return AjaxResult.success("鍚堝苟椤圭洰鎴愬姛!");
-                    }
-                }
-                return AjaxResult.error("鎿嶄綔澶辫触!");
-            } else {
-                TjSampling tjSampling = tjSamplingService.getTjSamplingByHb(ids);
-                List<TjSampling> samplingList = tjSamplingService.getTjSamplingListByHb(ids);
-                if (null != tjSampling && null != samplingList && !samplingList.isEmpty()) {
-                    List<String> stringList = samplingList.stream().map(TjSampling::getId).collect(Collectors.toList());
-                    Map<String, Object> map = tjSamplingService.hebingCaiYangInFo(stringList);
-                    String proId = map.get("proId").toString();
-                    String proName = map.get("proName").toString();
-                    tjSampling.setProId(proId);
-                    tjSampling.setProName(proName);
-                    if (tjSamplingService.updateById(tjSampling)) {
-                        if (tjSamplingService.updateHeBingXm(stringList, tjSampling.getParentId())) {
-                            return AjaxResult.success("鍚堝苟椤圭洰鎴愬姛!");
-                        }
-                    }
-                }
-                return AjaxResult.error("鎿嶄綔澶辫触!");
-            }
-        }
-        return AjaxResult.error("璇烽�夋嫨浣犺鍚堝苟鐨勯」鐩�!!!");
+        return tjSamplingService.mergeCaiYangTran(ids);
     }
 
 
@@ -412,6 +359,21 @@
     @ApiOperation(value = "纭閲囨牱鎺ュ彛")
     @Transactional
     public AjaxResult confirmSampling(@RequestBody List<String> ids) {
+        String config = configService.selectConfigByKey("sfkqdyhis");
+        String mergeRequest = configService.selectConfigByKey("use_lis_pacs_is_auto_merge_request");
+        return confirm(ids,config,mergeRequest);
+    }
+
+    /**
+     * 纭閲囨牱鎺ュ彛
+     */
+    public Boolean confirmSamplingApi(List<String> ids,String sfkqdyhis,String mergeRequest) {
+        AjaxResult confirm = confirm(ids, sfkqdyhis, mergeRequest);
+        log.info("纭閲囨牱杩斿洖 ->{}",confirm);
+        return confirm.get("code").toString().equals("200");
+    }
+
+    private AjaxResult confirm(List<String> ids,String config,String mergeRequest) {
         if (null == ids || ids.isEmpty()) {
             return AjaxResult.error("璇烽�夋嫨瑕佺‘璁ら」");
         }
@@ -442,12 +404,11 @@
 //                    }
 //                }
             TjOrder tjOrder = orderService.getOrderByTjNum(sampling.getTjNum());
-            if(null==tjOrder)return AjaxResult.error("浣撴璁板綍涓嶅瓨鍦�");
+            if(null==tjOrder) return AjaxResult.error("浣撴璁板綍涓嶅瓨鍦�");
             TjCustomer tjCustomer = customerService.getById(tjOrder.getUserId());
             boolean updChild;
-            String config = configService.selectConfigByKey("sfkqdyhis");
             Boolean save;
-            if (null != config && config.equals("Y")) {
+            if (null != config && config.equals("Y") && !mergeRequest.equals("Y")) {
                 save = lisApiMethod.save(sampling, tjOrder, tjCustomer);
             }else {
                 save = true;
diff --git a/ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjSamplingMapper.java b/ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjSamplingMapper.java
index b0de598..40e3b74 100644
--- a/ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjSamplingMapper.java
+++ b/ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjSamplingMapper.java
@@ -162,4 +162,16 @@
             +") aa " + "WHERE\n" + "  aa.jyfldm NOT IN ( SELECT c.flbm FROM lis_jyflhb c);",
             "</script>"})
     String getBuKeHebingProName(@Param("ids")List<String> ids);
+
+    @Select("SELECT COUNT( 1 ) FROM(\n" +
+            "\tSELECT\n" +
+            "\t\ta.jyxmdm,\n" +
+            "\t\tb.jyfldm \n" +
+            "\tFROM\n" +
+            "\t\t`tj_sampling` a\n" +
+            "\t\tLEFT JOIN ltkj_jyxmzd b ON a.jyxmdm = b.jyxmdm \n" +
+            "\tWHERE\n" +
+            "\t\ta.id = #{id} \n" +
+            "\t) aa WHERE aa.jyfldm NOT IN ( SELECT c.flbm FROM lis_jyflhb c )")
+    int isMergeItem(@Param("id") String id);
 }
diff --git a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/ITjSamplingService.java b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/ITjSamplingService.java
index 0d0e8fd..b81c736 100644
--- a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/ITjSamplingService.java
+++ b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/ITjSamplingService.java
@@ -4,6 +4,7 @@
 import java.util.Map;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.ltkj.common.core.domain.AjaxResult;
 import com.ltkj.hosp.domain.TjSampling;
 import org.apache.ibatis.annotations.Param;
 
@@ -87,4 +88,15 @@
     boolean updateHeBingXm(@Param("ids") List<String> ids);
 
     String getBuKeHebingProName(List<String> ids);
+
+    AjaxResult mergeCaiYangTran(List<String> ids);
+
+    String mergeCaiYangApi(List<String> ids);
+
+    /**
+     * 鍒ゆ柇椤圭洰鏄惁鑳借繘琛屽悎骞�
+     * @param id 閲囨牱琛╥d
+     * @return
+     */
+    int isMergeItem(String id);
 }
diff --git a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java
index 64f49cc..2699780 100644
--- a/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java
+++ b/ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java
@@ -3,14 +3,26 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
+import cn.hutool.core.bean.BeanUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ltkj.common.core.domain.AjaxResult;
 import com.ltkj.common.utils.DateUtils;
+import com.ltkj.common.utils.IdUtils;
+import com.ltkj.hosp.domain.TjCustomer;
+import com.ltkj.hosp.domain.TjOrder;
+import com.ltkj.hosp.service.ITjCustomerService;
+import com.ltkj.hosp.service.ITjOrderService;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import com.ltkj.hosp.mapper.TjSamplingMapper;
 import com.ltkj.hosp.domain.TjSampling;
 import com.ltkj.hosp.service.ITjSamplingService;
+import org.springframework.transaction.annotation.Transactional;
 
 /**
  * 浣撴閲囨牱绠$悊Service涓氬姟灞傚鐞�
@@ -18,10 +30,17 @@
  * @author ltkj_璧典匠璞�&鏉庢牸
  * @date 2023-04-11
  */
+@Slf4j
 @Service
 public class TjSamplingServiceImpl extends ServiceImpl<TjSamplingMapper,TjSampling> implements ITjSamplingService {
     @Autowired
     private TjSamplingMapper tjSamplingMapper;
+    @Autowired
+    private IdUtils idUtils;
+    @Autowired
+    private ITjOrderService orderService;
+    @Autowired
+    private ITjCustomerService customerService;
 
     /**
      * 鏌ヨ浣撴閲囨牱绠$悊
@@ -135,4 +154,76 @@
     public String getBuKeHebingProName(List<String> ids) {
         return tjSamplingMapper.getBuKeHebingProName(ids);
     }
+
+    @Transactional
+    @Override
+    public AjaxResult mergeCaiYangTran(List<String> ids) {
+        return mergeCaiYang(ids);
+    }
+
+    @Override
+    public String mergeCaiYangApi(List<String> ids) {
+        AjaxResult ajaxResult = mergeCaiYang(ids);
+        log.info("鍚堝苟閲囨牱杩斿洖 ->{}",ajaxResult);
+        return ajaxResult.get("data").toString();
+    }
+
+    private AjaxResult mergeCaiYang(List<String> ids) {
+        if (null != ids && !ids.isEmpty()) {
+            if(ids.size()==1) return AjaxResult.error("璇烽�夋嫨鑷冲皯涓ゆ潯椤圭洰杩涜鍚堝苟!");
+            int i = panduanshifoukeyihebing(ids);
+            if (i > 1) {
+                return AjaxResult.error("鏍囨湰绫诲瀷涓嶄竴鑷�,涓嶅彲鍚堝苟");
+            }
+            int pdsfczhbxm = pdsfczhbxm(ids);
+            if (pdsfczhbxm == ids.size()) return AjaxResult.error("澶氫釜鍚堝苟椤圭洰涓嶅彲鍐嶇户缁悎骞�!");
+            if (pdsfczhbxm > 1) return AjaxResult.error("鏈�澶氬厑璁搁�夋嫨涓�涓悎骞惰繃鐨勯」鐩�!");
+//            鏌ヨ鍑洪噷闈笉鍙悎骞剁殑鍖栭獙椤圭洰
+            String string = getBuKeHebingProName(ids);
+            if(null !=string){
+                return AjaxResult.error(string + "杩欏嚑涓」鐩笉鍙悎骞�!");
+            }
+            if (pdsfczhbxm == 0) {
+                TjSampling tjSampling = getById(ids.get(0));
+                Map<String, Object> map = hebingCaiYangInFo(ids);
+                TjSampling sampling = new TjSampling();
+                String proId = map.get("proId").toString();
+                String proName = map.get("proName").toString();
+                BeanUtil.copyProperties(tjSampling, sampling, new String[]{"id"});
+                sampling.setProId(proId);
+                sampling.setProName(proName);
+                sampling.setIsMerge(1);
+                sampling.setJyxh(idUtils.generateLisID());
+                if (save(sampling)) {
+                    if (updateHeBingXm(ids, sampling.getId())) {
+                        return AjaxResult.success("鍚堝苟椤圭洰鎴愬姛!", sampling.getId());
+                    }
+                }
+                return AjaxResult.error("鎿嶄綔澶辫触!");
+            } else {
+                TjSampling tjSampling = getTjSamplingByHb(ids);
+                List<TjSampling> samplingList = getTjSamplingListByHb(ids);
+                if (null != tjSampling && null != samplingList && !samplingList.isEmpty()) {
+                    List<String> stringList = samplingList.stream().map(TjSampling::getId).collect(Collectors.toList());
+                    Map<String, Object> map = hebingCaiYangInFo(stringList);
+                    String proId = map.get("proId").toString();
+                    String proName = map.get("proName").toString();
+                    tjSampling.setProId(proId);
+                    tjSampling.setProName(proName);
+                    if (updateById(tjSampling)) {
+                        if (updateHeBingXm(stringList, tjSampling.getParentId())) {
+                            return AjaxResult.success("鍚堝苟椤圭洰鎴愬姛!", tjSampling.getId());
+                        }
+                    }
+                }
+                return AjaxResult.error("鎿嶄綔澶辫触!");
+            }
+        }
+        return AjaxResult.error("璇烽�夋嫨浣犺鍚堝苟鐨勯」鐩�!!!");
+    }
+
+    @Override
+    public int isMergeItem(String id) {
+        return baseMapper.isMergeItem(id);
+    }
 }

--
Gitblit v1.8.0