From afd4b25f5744725c92be40217aae0760289b4671 Mon Sep 17 00:00:00 2001
From: chenrui <1187576398@qq.com>
Date: 星期二, 08 四月 2025 11:19:05 +0800
Subject: [PATCH] 标准库添加委托要求功能

---
 basic-server/src/main/java/com/ruoyi/basic/service/impl/StandardProductListServiceImpl.java |  197 +++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 150 insertions(+), 47 deletions(-)

diff --git a/basic-server/src/main/java/com/ruoyi/basic/service/impl/StandardProductListServiceImpl.java b/basic-server/src/main/java/com/ruoyi/basic/service/impl/StandardProductListServiceImpl.java
index 55ade8f..305e77c 100644
--- a/basic-server/src/main/java/com/ruoyi/basic/service/impl/StandardProductListServiceImpl.java
+++ b/basic-server/src/main/java/com/ruoyi/basic/service/impl/StandardProductListServiceImpl.java
@@ -1,26 +1,23 @@
 package com.ruoyi.basic.service.impl;
 
 import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONArray;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.*;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.ruoyi.basic.dto.*;
-import com.ruoyi.basic.enums.BasicTreeEnums;
 import com.ruoyi.basic.enums.StandardProductListChcekTypeEnums;
-import com.ruoyi.basic.enums.StandardProductListOperationTypeEnums;
 import com.ruoyi.basic.mapper.*;
 import com.ruoyi.basic.pojo.*;
 import com.ruoyi.basic.service.StandardMethodListService;
-import com.ruoyi.basic.service.StandardMethodService;
+import com.ruoyi.basic.service.StandardProductListSupplierAskService;
 import com.ruoyi.common.exception.base.BaseException;
 import com.ruoyi.common.utils.QueryWrappers;
 import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.basic.service.StandardProductListService;
 import lombok.AllArgsConstructor;
-import org.apache.catalina.security.SecurityUtil;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -69,6 +66,18 @@
     @Autowired
     private StandardProductListUpdateRecordMapper standardProductListUpdateRecordMapper;
 
+    @Autowired
+    private StandardProductListUpdateRecordRelMapper standardProductListUpdateRecordRelMapper;
+
+    @Autowired
+    private StandardProductListSupplierAskService standardProductListSupplierAskService;
+
+    @Autowired
+    private StandardProductListSupplierAskBackupRelMapper  standardProductListSupplierAskBackupRelMapper;
+
+    @Autowired
+    private StandardMethodMapper standardMethodMapper;
+
 
     @Override
     public int upStandardProductList(StandardProductList list) {
@@ -88,6 +97,10 @@
             BeanUtils.copyProperties(standardProductList, productListBackupRel);
             standardProductListBackupRelMapper.insert(productListBackupRel);
         }
+        // 鍏宠仈鍟嗗澶囦唤
+        StandardProductListSupplierAsk standardProductListSupplierAsk = new StandardProductListSupplierAsk();
+        standardProductListSupplierAsk.setProductListId(list.getId());
+        standardProductListSupplierAskService.backupSupplierAsk(standardProductListSupplierAsk);
         // 淇敼鐘舵��
         list.setCheckStatus(StandardProductListChcekTypeEnums.WAIT_CHECK.getCode());
         return standardProductListMapper.updateById(list);
@@ -373,14 +386,27 @@
         if(StringUtils.isEmpty(checkItemQueryTree.toString())){
             return map;
         }
+        // 鍒ゆ柇鏄惁涓哄鎵樿姹傛爣鍑�
+        StandardMethod standardMethod = standardMethodMapper.selectById(id);
+        if(ObjectUtils.isEmpty(standardMethod)){
+            return map;
+        }
+        StructureItemParameterDto structureItemParameterDto = new StructureItemParameterDto();
+        if(standardMethod.getName().equals("濮旀墭瑕佹眰")){
+            structureItemParameterDto.setDelegateRequestFlag("1");
+        }else {
+            structureItemParameterDto.setDelegateRequestFlag("0");
+        }
+        structureItemParameterDto.setTree(checkItemQueryTree.toString());
+
         // 鏍规嵁妫�楠屽璞�/浜у搧鏌ヨ妫�楠岄」
-        List<StructureItemParameter> structureItemParameterList = structureItemParameterMapper.selectItemParameterBySample(checkItemQueryTree.toString());
+        List<StructureItemParameter> structureItemParameterList = structureItemParameterMapper.selectItemParameterBySample(structureItemParameterDto);
         // 濡傛灉鏄骇鍝佺殑妫�鏌ラ」涓虹┖鍚戜笂鎺�
         if(CollectionUtils.isEmpty(structureItemParameterList)){
             String query = "[\"" + sampleType + "\"]";
-            structureItemParameterList = structureItemParameterMapper.selectItemParameterBySample(query);
+            structureItemParameterDto.setTree(query);
+            structureItemParameterList = structureItemParameterMapper.selectItemParameterBySample(structureItemParameterDto);
         }
-
         // 鏌ヨ鏍囧噯搴撳凡缁戝畾妫�鏌ラ」鐩�
         List<StandardProductList> standardProductList = standardProductListMapper.selectList(Wrappers.<StandardProductList>lambdaQuery()
                 .eq(StandardProductList::getStandardMethodListId, id)
@@ -490,6 +516,28 @@
      */
     @Override
     public boolean updateSection(StandardProductList list) {
+        // 鏍规嵁id 鏌ヨ鍒板師濮嬪��
+        StandardProductList standardProductList = standardProductListMapper.selectById(list.getId());
+        if(ObjectUtils.isEmpty(standardProductList)){
+            throw new RuntimeException("鏇存柊澶辫触,鏈煡鎵惧埌妫�鏌ラ」");
+        }
+        // 鍒ゆ柇褰撳墠鐘舵�� 濡傛灉鏄鏍镐腑
+        if(StandardProductListChcekTypeEnums.CHECK_ING.getCode().equals(list.getCheckStatus())){
+            throw new RuntimeException("瀹℃牳涓笉鏀寔淇敼");
+        }
+        // 鏌ヨ鏈�鏂扮殑涓�娆″叧鑱斿浠� 濡傛灉瀛樺湪璇存槑鏈鏍稿畬缁х画淇敼浜嗐�備笉鍋氭暟鎹鐞嗐��
+        StandardProductListBackupRel standardProductListBackupRel = standardProductListBackupRelMapper.selectById(list.getId());
+        if(ObjectUtils.isEmpty(standardProductListBackupRel)){
+            StandardProductListBackupRel productListBackupRel = new StandardProductListBackupRel();
+            BeanUtils.copyProperties(standardProductList, productListBackupRel);
+            standardProductListBackupRelMapper.insert(productListBackupRel);
+        }
+        // 鍏宠仈鍟嗗澶囦唤
+        StandardProductListSupplierAsk standardProductListSupplierAsk = new StandardProductListSupplierAsk();
+        standardProductListSupplierAsk.setProductListId(list.getId());
+        standardProductListSupplierAskService.backupSupplierAsk(standardProductListSupplierAsk);
+        // 淇敼鐘舵��
+        list.setCheckStatus(StandardProductListChcekTypeEnums.WAIT_CHECK.getCode());
         standardProductListMapper.updateSection(list);
         return true;
     }
@@ -644,57 +692,112 @@
     }
 
     /**
-     * 鏍囧噯鏍戜笅妫�楠岄」澶勭悊
-     * @param standardProductListDto
+     * 鏍囧噯鏍戜笅妫�楠岄」鎻愪氦
      */
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void productListOperate(StandardProductListDto standardProductListDto) {
-        StandardProductList standardProductList = new StandardProductList();
-        standardProductList.setId(standardProductListDto.getId());
-        StandardProductListUpdateRecord standardProductListUpdateRecord = new StandardProductListUpdateRecord();
-        // 瀹℃牳閫氳繃
-        if(StandardProductListOperationTypeEnums.PASS_CHECK_OP.getCode().equals(standardProductListDto.getOperationStatus())){
-            // 鍒犻櫎澶囦唤鏁版嵁
-            standardProductListBackupRelMapper.deleteById(standardProductListDto.getId());
-            standardProductList.setCheckStatus(StandardProductListChcekTypeEnums.PASS_CHECK.getCode());
-        // 瀹℃牳涓嶉�氳繃
-        }else if(StandardProductListOperationTypeEnums.NO_PASS_CHECK_OP.getCode().equals(standardProductListDto.getOperationStatus())) {
-            // 杩樺師鏁版嵁
-            StandardProductListBackupRel standardProductListBackupRel = standardProductListBackupRelMapper.selectById(standardProductListDto.getId());
-            if(ObjectUtils.isEmpty(standardProductListBackupRel)){
-                throw new RuntimeException("澶囦唤鏁版嵁鏌ユ壘澶辫触");
-            }
-            BeanUtils.copyProperties(standardProductListBackupRel, standardProductList);
-            standardProductList.setCheckStatus(StandardProductListChcekTypeEnums.NO_PASS_CHECK.getCode());
-        // 鎻愪氦
-        }else if(StandardProductListOperationTypeEnums.SUBMIT_OP.getCode().equals(standardProductListDto.getOperationStatus())) {
-            standardProductListUpdateRecord.setOperationType(StandardProductListOperationTypeEnums.PASS_CHECK_OP.getCode());
-            standardProductList.setCheckStatus(StandardProductListChcekTypeEnums.CHECK_ING.getCode());
-        } else {
-            throw new RuntimeException("鎿嶄綔鏈夎");
+    public void productListSubmit(StandardProductListUpdateRecord standardProductListUpdateRecord) {
+        // 鏌ヨ鎵�鏈夊緟瀹℃牳鐨勬暟鎹�
+        QueryWrapper<StandardProductList> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("check_status",StandardProductListChcekTypeEnums.WAIT_CHECK.getCode());
+        List<StandardProductList> unCheckStandardProductListArray = standardProductListMapper.selectList(queryWrapper);
+        if(CollectionUtils.isEmpty(unCheckStandardProductListArray)){
+            throw new RuntimeException("鏆傛棤淇敼鏁版嵁");
         }
-        // 鏂板鎿嶄綔璁板綍
-        standardProductListUpdateRecord.setStandardProductListId(standardProductListDto.getId());
-        standardProductListUpdateRecord.setOperationType(standardProductListDto.getOperationStatus());
+        List<Long> standardProductListIds = new ArrayList<>();
+        // 鎻掑叆淇敼璁板綍
         standardProductListUpdateRecordMapper.insert(standardProductListUpdateRecord);
-        // 淇敼瀹℃牳鐘舵��
-        standardProductList.setCheckStatus(standardProductListDto.getOperationStatus());
-        standardProductListMapper.updateById(standardProductList);
+        // 鎻掑叆淇敼璁板綍鍏宠仈琛�
+        List<StandardProductListUpdateRecordRel> standardProductListUpdateRecordRelList = new ArrayList<>();
+        for (StandardProductList standardProductList : unCheckStandardProductListArray) {
+            StandardProductListUpdateRecordRel standardProductListUpdateRecordRel = new StandardProductListUpdateRecordRel();
+            BeanUtils.copyProperties(standardProductList, standardProductListUpdateRecordRel);
+            standardProductListUpdateRecordRel.setId(null);
+            standardProductListUpdateRecordRel.setStandardProductListId(standardProductList.getId());
+            standardProductListUpdateRecordRel.setStandardProductListUpdateRecordId(standardProductListUpdateRecord.getId());
+            standardProductListUpdateRecordRelList.add(standardProductListUpdateRecordRel);
+            standardProductListUpdateRecordRelMapper.insert(standardProductListUpdateRecordRel);
+            standardProductListIds.add(standardProductList.getId());
+        }
+
+        // 淇敼鏍囧噯鏍戜笅妫�鏌ラ」鐘舵�佷负瀹℃牳涓�
+        standardProductListMapper.updateProductListCheckStatus(standardProductListIds,StandardProductListChcekTypeEnums.CHECK_ING.getCode());
     }
 
     /**
-     * 鏍囧噯鏍戜笅妫�楠岄」淇敼璁板綍鍒嗛〉鏌ヨ
-     * @param page
-     * @param record
+     * 鏍囧噯鏍戜笅妫�楠岄」瀹℃牳
+     * @param standardProductListUpdateRecord
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void productListCheck(StandardProductListUpdateRecord standardProductListUpdateRecord) {
+        // 鏌ヨ鎵�鏈夊鏍镐腑鐨勬暟鎹�
+        QueryWrapper<StandardProductList> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("check_status",StandardProductListChcekTypeEnums.CHECK_ING.getCode());
+        List<StandardProductList> standardProductListArray = standardProductListMapper.selectList(queryWrapper);
+        if(CollectionUtils.isEmpty(standardProductListArray)){
+            return;
+        }
+        List<Long> standardProductListIds = new ArrayList<>();
+        for (StandardProductList standardProductList : standardProductListArray) {
+            standardProductListIds.add(standardProductList.getId());
+        }
+        // 瀹℃牳閫氳繃
+        if(StandardProductListChcekTypeEnums.PASS_CHECK.getCode().equals(standardProductListUpdateRecord.getCheckStatus())){
+            // 淇敼鐘舵��
+            standardProductListMapper.updateProductListCheckStatus(standardProductListIds,StandardProductListChcekTypeEnums.PASS_CHECK.getCode());
+        }
+        // 瀹℃牳鏈�氳繃
+        if(StandardProductListChcekTypeEnums.NO_PASS_CHECK.getCode().equals(standardProductListUpdateRecord.getCheckStatus())){
+            // 鏌ヨ鎵�鏈夋爣鍑嗘爲涓嬬殑妫�楠岄」鐩浠芥暟鎹�
+            List<StandardProductListBackupRel> standardProductListBackupRelList = standardProductListBackupRelMapper.selectBatchIds(standardProductListIds);
+            // 鍥炴粴鏍囧噯鏍戜笅鐨勬楠岄」鐩暟鎹�
+            for (StandardProductListBackupRel standardProductListBackupRel : standardProductListBackupRelList) {
+                StandardProductList standardProductList = new StandardProductList();
+                BeanUtils.copyProperties(standardProductListBackupRel, standardProductList);
+                standardProductListMapper.updateById(standardProductList);
+            }
+            // 鍥炴粴妫�楠岄」鐩巶瀹跺瘑搴︾粦瀹氳〃鏁版嵁
+            QueryWrapper<StandardProductListSupplierAskBackupRel> supplierAskBackupRelQueryWrapper = new QueryWrapper<>();
+            supplierAskBackupRelQueryWrapper.in("product_list_id",standardProductListIds);
+            List<StandardProductListSupplierAskBackupRel> standardProductListSupplierAskBackupRelList = standardProductListSupplierAskBackupRelMapper.selectList(supplierAskBackupRelQueryWrapper);
+            if(!CollectionUtils.isEmpty(standardProductListSupplierAskBackupRelList)){
+                QueryWrapper<StandardProductListSupplierAsk> deleteWrapper = new QueryWrapper<>();
+                deleteWrapper.in("product_list_id",standardProductListIds);
+                standardProductListSupplierAskMapper.delete(deleteWrapper);
+                ArrayList<StandardProductListSupplierAsk> supplierAskRollBackList = new ArrayList<>();
+                for (StandardProductListSupplierAskBackupRel standardProductListSupplierAskBackupRel : standardProductListSupplierAskBackupRelList) {
+                    StandardProductListSupplierAsk standardProductListSupplierAsk = new StandardProductListSupplierAsk();
+                    BeanUtils.copyProperties(standardProductListSupplierAskBackupRel, standardProductListSupplierAsk);
+                    supplierAskRollBackList.add(standardProductListSupplierAsk);
+                }
+                standardProductListSupplierAskMapper.batchInsertSupplierAsk(supplierAskRollBackList);
+            }
+
+        }
+        // 鍒犻櫎鏍囧噯鏍戜笅鐨勬楠岄」鐩浠芥暟鎹�
+        standardProductListBackupRelMapper.deleteBatchIds(standardProductListIds);
+        // 鍒犻櫎缁戝畾鍘傚澶囦唤鏁版嵁
+        standardProductListSupplierAskBackupRelMapper.batchDeleteByProductIds(standardProductListIds);
+        standardProductListUpdateRecordMapper.updateById(standardProductListUpdateRecord);
+    }
+
+    /**
+     * 鏌ヨ鏍囧噯搴撴槸鍚﹀瓨鍦ㄥ鏍镐腑鐘舵��
+     *
      * @return
      */
     @Override
-    public IPage<StandardProductListUpdateRecord> standardProductListRecordPage(Page page, StandardProductListUpdateRecord record) {
-        return standardProductListUpdateRecordMapper.standardProductListRecordPage(page,QueryWrappers.queryWrappers(record));
+    public boolean existCheckingRecord() {
+        QueryWrapper<StandardProductListUpdateRecord> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("check_status",StandardProductListChcekTypeEnums.CHECK_ING.getCode());
+        List<StandardProductListUpdateRecord> standardProductListUpdateRecordList = standardProductListUpdateRecordMapper.selectList(queryWrapper);
+        if(CollectionUtils.isEmpty(standardProductListUpdateRecordList)){
+            return false;
+        }else {
+            return true;
+        }
     }
-
-
 }
 
 

--
Gitblit v1.9.3