From 14ecea8537d5b29ca64c75aad4ff49265018415d Mon Sep 17 00:00:00 2001
From: zjh <1084500556@qq.com>
Date: 星期三, 02 七月 2025 08:51:22 +0800
Subject: [PATCH] zjh20250702

---
 ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjSamplingServiceImpl.java |  102 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 101 insertions(+), 1 deletions(-)

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 5f5c43f..1cc25ec 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
@@ -1,16 +1,23 @@
 package com.ltkj.hosp.service.impl;
 
-import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
+import cn.hutool.core.bean.BeanUtil;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ltkj.common.core.domain.AjaxResult;
 import com.ltkj.common.utils.DateUtils;
+import com.ltkj.hosp.idutil.IdUtils;
+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 +25,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;
 
     /**
      * 鏌ヨ浣撴閲囨牱绠$悊
@@ -130,4 +144,90 @@
     public boolean updateHeBingXm(List<String> ids) {
         return tjSamplingMapper.updateHeBingXms(ids);
     }
+
+    @Override
+    public String getBuKeHebingProName(List<String> ids) {
+        return tjSamplingMapper.getBuKeHebingProName(ids);
+    }
+
+    @Transactional
+    @Override
+    public AjaxResult mergeCaiYangTran(List<String> ids,String prefix) {
+        return mergeCaiYang(ids,prefix);
+    }
+
+    @Override
+    public String mergeCaiYangApi(List<String> ids,String prefix) {
+        AjaxResult ajaxResult = mergeCaiYang(ids,prefix);
+        log.info("鍚堝苟閲囨牱杩斿洖 ->{}",ajaxResult);
+        return ajaxResult.get("data").toString();
+    }
+
+    private AjaxResult mergeCaiYang(List<String> ids,String prefix) {
+        try {
+            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(prefix));
+                    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("鎿嶄綔澶辫触!");
+                }
+            }
+        } catch (Exception e) {
+            log.error(e.getMessage());
+        }
+        return AjaxResult.error("璇烽�夋嫨浣犺鍚堝苟鐨勯」鐩�!!!");
+    }
+
+    @Override
+    public int isMergeItem(String id) {
+        return baseMapper.isMergeItem(id);
+    }
+
+    @Override
+    public int isExistProId(String tjh, String proId) {
+        return baseMapper.isExistProId(tjh,proId);
+    }
 }

--
Gitblit v1.8.0