From 9ca45195f78b74e9181cbbe7e82eb683ee49fabf Mon Sep 17 00:00:00 2001
From: liu <2021943741@qq.com>
Date: 星期五, 30 十月 2026 17:54:15 +0800
Subject: [PATCH] 质量管理模块:指标按产品/类别/工序维护与绑定、不合格处理方式、检验提交入库判定

---
 src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java |  286 ++++++++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 243 insertions(+), 43 deletions(-)

diff --git a/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java b/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
index 22055fc..e8bfb84 100644
--- a/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
+++ b/src/main/java/com/ruoyi/quality/service/impl/QualityInspectServiceImpl.java
@@ -2,30 +2,47 @@
 
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.deepoove.poi.XWPFTemplate;
+import com.deepoove.poi.config.Configure;
 import com.ruoyi.common.exception.base.BaseException;
+import com.ruoyi.common.exception.ServiceException;
+import com.ruoyi.common.utils.HackLoopTableRenderPolicy;
+import com.ruoyi.common.utils.SecurityUtils;
 import com.ruoyi.common.utils.poi.ExcelUtil;
+import com.ruoyi.framework.security.LoginUser;
+import com.ruoyi.procurementrecord.dto.Details;
+import com.ruoyi.procurementrecord.dto.ProcurementAddDto;
+import com.ruoyi.procurementrecord.pojo.ProcurementRecordStorage;
+import com.ruoyi.procurementrecord.service.ProcurementRecordService;
+import com.ruoyi.quality.dto.QualityInspectDto;
 import com.ruoyi.quality.mapper.QualityInspectMapper;
-import com.ruoyi.quality.mapper.QualityInspectParamMapper;
 import com.ruoyi.quality.mapper.QualityTestStandardMapper;
+import com.ruoyi.quality.mapper.QualityUnqualifiedMapper;
 import com.ruoyi.quality.pojo.QualityInspect;
 import com.ruoyi.quality.pojo.QualityInspectParam;
-import com.ruoyi.quality.pojo.QualityTestStandard;
+import com.ruoyi.quality.pojo.QualityUnqualified;
 import com.ruoyi.quality.service.IQualityInspectParamService;
 import com.ruoyi.quality.service.IQualityInspectService;
-import com.ruoyi.staff.mapper.StaffJoinLeaveRecordMapper;
-import com.ruoyi.staff.mapper.StaffOnJobMapper;
-import com.ruoyi.staff.pojo.StaffJoinLeaveRecord;
-import com.ruoyi.staff.pojo.StaffOnJob;
-import com.ruoyi.staff.service.IStaffOnJobService;
+import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
 import lombok.AllArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.servlet.http.HttpServletResponse;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.math.BigDecimal;
+import java.net.URLEncoder;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.stream.Collectors;
 
@@ -40,48 +57,229 @@
 
     private QualityTestStandardMapper qualityTestStandardMapper;
 
+    private QualityUnqualifiedMapper qualityUnqualifiedMapper;
+
+    private SalesLedgerProductMapper salesLedgerProductMapper;
+
+    private ProcurementRecordService procurementRecordService;
+
     @Override
-    public int add(QualityInspect qualityInspect) {
-        String[] ignoreProperties = {"id"};//鎺掗櫎id灞炴��
-        //鏍规嵁浜у搧id鏌ヨ鎸囨爣缁存姢瀵瑰簲鏂板妫�楠屽弬鏁�
-        List<QualityTestStandard> qualityTestStandards = qualityTestStandardMapper.selectList(Wrappers.<QualityTestStandard>lambdaQuery()
-                .eq(QualityTestStandard::getProductId, qualityInspect.getProductId()));
-        if (qualityTestStandards.size()>0){
-            qualityInspectMapper.insert(qualityInspect);
-            List<QualityInspectParam> qualityInspectParams = qualityTestStandards.stream().map(qualityTestStandard -> {
-                QualityInspectParam qualityInspectParam = new QualityInspectParam();
-                BeanUtils.copyProperties(qualityTestStandard, qualityInspectParam,ignoreProperties);
-                qualityInspectParam.setInspectId(qualityInspect.getId());
-                return qualityInspectParam;
-            }).collect(Collectors.toList());
-            qualityInspectParamService.saveBatch(qualityInspectParams);
-        }else{
-            throw new BaseException("璇ヤ骇鍝佹病鏈夌淮鎶ゆ楠屾寚鏍�,璇锋鏌�!!!!!!!!");
+    public int add(QualityInspectDto qualityInspectDto) {
+        QualityInspect qualityInspect = new QualityInspect();
+        BeanUtils.copyProperties(qualityInspectDto,qualityInspect);
+        qualityInspect.setInspectState(0);//榛樿鏈彁浜�
+        int inserted = qualityInspectMapper.insert(qualityInspect);
+        if (inserted <= 0 || qualityInspect.getId() == null) {
+            throw new ServiceException("鏂板妫�楠岃褰曞け璐�");
         }
-        return 0;
+        for (QualityInspectParam qualityInspectParam : qualityInspectDto.getQualityInspectParams()) {
+            qualityInspectParam.setInspectId(qualityInspect.getId());
+        }
+        if (!qualityInspectParamService.saveBatch(qualityInspectDto.getQualityInspectParams())) {
+            throw new ServiceException("淇濆瓨妫�楠岄」鐩け璐�");
+        }
+        return inserted;
     }
 
     @Override
-    public int updateQualityInspect(QualityInspect qualityInspect) {
-        String[] ignoreProperties = {"id"};//鎺掗櫎id灞炴��
-        //鍏堝垹闄ゆ墍鏈夋楠屽弬鏁板啀鏂板
-        qualityInspectParamService.remove(Wrappers.<QualityInspectParam>lambdaQuery()
-                .eq(QualityInspectParam::getInspectId,qualityInspect.getId()));
-        //鏍规嵁浜у搧id鏌ヨ鎸囨爣缁存姢瀵瑰簲鏂板妫�楠屽弬鏁�
-        List<QualityTestStandard> qualityTestStandards = qualityTestStandardMapper.selectList(Wrappers.<QualityTestStandard>lambdaQuery()
-                .eq(QualityTestStandard::getProductId, qualityInspect.getProductId()));
-        if (qualityTestStandards.size()>0){
-            List<QualityInspectParam> qualityInspectParams = qualityTestStandards.stream().map(qualityTestStandard -> {
-                QualityInspectParam qualityInspectParam = new QualityInspectParam();
-                BeanUtils.copyProperties(qualityTestStandard, qualityInspectParam,ignoreProperties);
-                qualityInspectParam.setInspectId(qualityInspect.getId());
-                return qualityInspectParam;
-            }).collect(Collectors.toList());
-            qualityInspectParamService.saveBatch(qualityInspectParams);
-        }else{
-            throw new BaseException("璇ヤ骇鍝佹病鏈夌淮鎶ゆ楠屾寚鏍�,璇锋鏌�!!!!!!!!");
+    public QualityInspectDto getDetailById(Integer id) {
+        QualityInspect qualityInspect = qualityInspectMapper.selectById(id);
+        if (qualityInspect == null) {
+            throw new ServiceException("妫�楠岃褰曚笉瀛樺湪");
         }
-        return  qualityInspectMapper.updateById(qualityInspect);
+        List<QualityInspectParam> qualityInspectParams = qualityInspectParamService.list(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId, id));
+        QualityInspectDto qualityInspectDto = new QualityInspectDto();
+        BeanUtils.copyProperties(qualityInspect,qualityInspectDto);
+        qualityInspectDto.setQualityInspectParams(qualityInspectParams);
+        return qualityInspectDto;
+    }
+
+    //鎻愪氦
+    @Override
+    public int submit(QualityInspect inspect) {
+        if (inspect == null || inspect.getId() == null) {
+            throw new ServiceException("妫�楠岃褰旾D涓嶈兘涓虹┖");
+        }
+        QualityInspect qualityInspect = qualityInspectMapper.selectById(inspect.getId());
+        if (qualityInspect == null) {
+            throw new ServiceException("妫�楠岃褰曚笉瀛樺湪");
+        }
+        if (Integer.valueOf(1).equals(qualityInspect.getInspectState())) {
+            throw new ServiceException("妫�楠岃褰曞凡鎻愪氦锛岃鍕块噸澶嶆搷浣�");
+        }
+        if (!"鍚堟牸".equals(qualityInspect.getCheckResult())
+                && !"涓嶅悎鏍�".equals(qualityInspect.getCheckResult())) {
+            throw new ServiceException("璇峰厛瀹屾垚妫�楠岀粨鏋滃垽瀹�");
+        }
+        List<QualityInspectParam> inspectParams = qualityInspectParamService.list(
+                Wrappers.<QualityInspectParam>lambdaQuery()
+                        .eq(QualityInspectParam::getInspectId, inspect.getId()));
+        if (inspectParams.isEmpty()) {
+            throw new ServiceException("妫�楠岄」鐩负绌猴紝涓嶈兘鎻愪氦");
+        }
+        for (QualityInspectParam parameter : inspectParams) {
+            if (StringUtils.isBlank(parameter.getTestValue())) {
+                throw new ServiceException("妫�楠岄」鐩��" + parameter.getParameterItem() + "鈥濆皻鏈~鍐欐楠屽��");
+            }
+        }
+        /*鍒ゆ柇涓嶅悎鏍�*/
+        if (ObjectUtils.isNotNull(qualityInspect.getCheckResult()) && qualityInspect.getCheckResult().equals("涓嶅悎鏍�")){
+            QualityUnqualified qualityUnqualified = new QualityUnqualified();
+            BeanUtils.copyProperties(qualityInspect,qualityUnqualified);
+            qualityUnqualified.setInspectState(0);//寰呭鐞�
+            String text = inspectParams.stream().map(QualityInspectParam::getParameterItem).collect(Collectors.joining(","));
+            qualityUnqualified.setDefectivePhenomena(text+"杩欎簺鎸囨爣涓瓨鍦ㄤ笉鍚堟牸");//涓嶅悎鏍肩幇璞�
+            qualityUnqualifiedMapper.insert(qualityUnqualified);
+        }
+
+        LoginUser loginUser = SecurityUtils.getLoginUser();
+        if (qualityInspect.getInspectType() == 0) {
+            // 鍚堟牸涓斿叧鑱斾簡閲囪喘鍗�/浜у搧淇℃伅鏃舵墠鑷姩鍏ュ簱锛屼俊鎭笉鍏ㄦ椂璺宠繃鍏ュ簱浣嗘甯告彁浜�
+            if ("鍚堟牸".equals(qualityInspect.getCheckResult())
+                    && qualityInspect.getPurchaseLedgerId() != null) {
+                SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectById(qualityInspect.getProductId());
+                if (salesLedgerProduct != null) {
+                    ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
+                    procurementRecordOutAdd.setType(1);
+                    procurementRecordOutAdd.setTypeName("閲囪喘鍘熸潗鏂欐楠屽悎鏍煎叆搴�");
+                    procurementRecordOutAdd.setNickName(loginUser.getNickName());
+                    procurementRecordOutAdd.setPurchaseLedgerId(Math.toIntExact(qualityInspect.getPurchaseLedgerId()));
+
+                    ArrayList<Details> detailss = new ArrayList<>();
+                    Details details = new Details();
+                    details.setId(Math.toIntExact(salesLedgerProduct.getId()));
+                    details.setInboundQuantity(qualityInspect.getQuantity());
+                    details.setWarnNum(salesLedgerProduct.getWarnNum());
+                    details.setUnitPrice(salesLedgerProduct.getTaxInclusiveUnitPrice());
+                    details.setTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice());
+                    details.setProductModelId(qualityInspect.getProductModelId());
+                    detailss.add( details);
+                    procurementRecordOutAdd.setDetails(detailss);
+                    procurementRecordOutAdd.setQualityInspectId(qualityInspect.getId());
+                    procurementRecordService.add(procurementRecordOutAdd);
+                }
+            }
+        }else if (qualityInspect.getInspectType() == 1) {
+            // 杩囩▼妫�楠屼粎鍚堟牸鏃跺叆搴擄紝涓嶅悎鏍煎搧鐢变笂闈㈢殑涓嶅悎鏍肩鐞嗘祦绋嬪鐞�
+            if ("鍚堟牸".equals(qualityInspect.getCheckResult())) {
+                ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
+                procurementRecordOutAdd.setType(2);
+                procurementRecordOutAdd.setTypeName("鐢熶骇杩囩▼妫�楠屽悎鏍煎叆搴�");
+                procurementRecordOutAdd.setNickName(loginUser.getNickName());
+                List<Details> details = new ArrayList<>();
+                Details details1 = new Details();
+                details1.setInboundQuantity(qualityInspect.getQuantity());
+                details1.setProductModelId(qualityInspect.getProductModelId());
+                procurementRecordOutAdd.setDetails(details);
+
+                ProcurementRecordStorage.ProcurementRecordStorageBuilder procurementRecordBuilder = ProcurementRecordStorage.builder()
+                        .salesLedgerProductId(0)
+                        .inboundBatches( "鐢熶骇鍗婃垚鍝佸叆搴�")
+                        .inboundNum(details1.getInboundQuantity())
+                        .type(2)
+                        .warnNum(new BigDecimal(0))
+                        .unitPrice(new BigDecimal(0))
+                        .totalPrice(new BigDecimal(0))
+                        .createTime(LocalDateTime.now())
+                        .createUser(loginUser.getUserId())
+                        .updateTime(LocalDateTime.now())
+                        .updateUser(loginUser.getUserId())
+                        .createBy(procurementRecordOutAdd.getNickName())
+                        .productModelId(details1.getProductModelId())
+                        .qualityInspectId(qualityInspect.getId());
+                procurementRecordService.save(procurementRecordBuilder.build());
+            }
+        }else if (qualityInspect.getInspectType() == 2) {
+            // 鍑哄巶妫�楠屼粎鍚堟牸鏃跺叆搴擄紝缂哄皯浜у搧淇℃伅鏃惰烦杩囧叆搴撲絾姝e父鎻愪氦
+            if ("鍚堟牸".equals(qualityInspect.getCheckResult())) {
+                SalesLedgerProduct salesLedgerProduct = salesLedgerProductMapper.selectSalesLedgerProductByMainId(qualityInspect.getProductMainId());
+                if (salesLedgerProduct != null) {
+                    ProcurementAddDto procurementRecordOutAdd = new ProcurementAddDto();
+                    procurementRecordOutAdd.setType(2);
+                    procurementRecordOutAdd.setTypeName("鐢熶骇鍑哄巶妫�楠屽悎鏍煎叆搴�");
+                    procurementRecordOutAdd.setNickName(loginUser.getNickName());
+                    List<Details> details = new ArrayList<>();
+                    Details details1 = new Details();
+                    details1.setInboundQuantity(qualityInspect.getQuantity());
+                    details1.setId(Math.toIntExact(salesLedgerProduct.getId()));
+                    details1.setUnitPrice(salesLedgerProduct.getTaxInclusiveUnitPrice());
+                    details1.setTotalPrice(salesLedgerProduct.getTaxInclusiveTotalPrice());
+                    details1.setProductModelId(salesLedgerProduct.getProductModelId());
+                    details.add(details1);
+                    procurementRecordOutAdd.setDetails(details);
+                    procurementRecordOutAdd.setQualityInspectId(qualityInspect.getId());
+                    procurementRecordService.add(procurementRecordOutAdd);
+                }
+            }
+        }
+        qualityInspect.setInspectState(1);//宸叉彁浜�
+        return qualityInspectMapper.updateById(qualityInspect);
+    }
+
+    /*鐢熸垚妫�楠屾姤鍛�*/
+    @Override
+    public void down(HttpServletResponse response, QualityInspect qualityInspect) {
+        QualityInspect inspect = qualityInspectMapper.selectById(qualityInspect.getId());
+        String inspectType="";
+        switch (inspect.getInspectType()){
+            case 0:
+                inspectType="鍘熸潗鏂欐楠�";
+                break;
+            case 1:
+                inspectType="杩囩▼妫�楠�";
+                break;
+            case 2:
+                inspectType="鍑哄巶妫�楠�";
+                break;
+        }
+        List<QualityInspectParam> paramList = qualityInspectParamService.list(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId, inspect.getId()));
+        int index = 1;
+        for (QualityInspectParam detail : paramList) {
+            detail.setIndex(index);
+            index++;
+        }
+        InputStream inputStream = this.getClass().getResourceAsStream("/static/report-template.docx");
+        Configure configure = Configure.builder()
+                .bind("paramList", new HackLoopTableRenderPolicy())
+                .build();
+        String finalInspectType = inspectType;
+        XWPFTemplate template = XWPFTemplate.compile(inputStream, configure).render(
+                new HashMap<String, Object>() {{
+                    put("inspect", inspect);
+                    put("inspectType", finalInspectType);
+                    put("paramList", paramList);
+                }});
+
+        try {
+            response.setContentType("application/msword");
+            String fileName = URLEncoder.encode(
+                    "妫�楠屾姤鍛�", "UTF-8");
+            response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
+            response.setHeader("Content-disposition",
+                    "attachment;filename=" + fileName + ".docx");
+            OutputStream os = response.getOutputStream();
+            template.write(os);
+            os.flush();
+            os.close();
+            inputStream.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+            throw new RuntimeException("瀵煎嚭澶辫触");
+        }
+    }
+
+    @Override
+    public int updateQualityInspect(QualityInspectDto qualityInspectDto) {
+        if (ObjectUtils.isNotNull(qualityInspectDto.getQualityInspectParams())) {
+            qualityInspectParamService.remove(Wrappers.<QualityInspectParam>lambdaQuery().eq(QualityInspectParam::getInspectId,qualityInspectDto.getId()));
+            for (QualityInspectParam qualityInspectParam : qualityInspectDto.getQualityInspectParams()) {
+                qualityInspectParam.setInspectId(qualityInspectDto.getId());
+            }
+            qualityInspectParamService.saveBatch(qualityInspectDto.getQualityInspectParams());
+        }
+        QualityInspect qualityInspect = new QualityInspect();
+        BeanUtils.copyProperties(qualityInspectDto,qualityInspect);
+        return qualityInspectMapper.updateById(qualityInspect);
     }
 
     @Override
@@ -106,4 +304,6 @@
         }
 
     }
+
+
 }

--
Gitblit v1.9.3