From 1a9ed8d682a5d03506bc768379f9f7d56ae2f0a1 Mon Sep 17 00:00:00 2001
From: guoyuji <guoyujie@ng.com>
Date: 星期一, 11 三月 2024 14:10:21 +0800
Subject: [PATCH] 报工相关文件

---
 north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java |  107 ++++++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 81 insertions(+), 26 deletions(-)

diff --git a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java
index eb184ae..9e5daf6 100644
--- a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java
+++ b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReportingWorkService.java
@@ -1,22 +1,23 @@
 package com.example.erp.service.pp;
 
+import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
 import com.example.erp.common.Constants;
 import com.example.erp.entity.pp.DamageDetails;
+import com.example.erp.entity.pp.FlowCard;
 import com.example.erp.entity.pp.ReportingWork;
 import com.example.erp.entity.pp.ReportingWorkDetail;
 import com.example.erp.entity.sd.Order;
 import com.example.erp.entity.sd.OrderDetail;
 import com.example.erp.entity.sd.OrderProcessDetail;
 import com.example.erp.exception.ServiceException;
-import com.example.erp.mapper.pp.BasicDateProduceMapper;
-import com.example.erp.mapper.pp.DamageDetailsMapper;
-import com.example.erp.mapper.pp.ReportingWorkDetailMapper;
-import com.example.erp.mapper.pp.ReportingWorkMapper;
+import com.example.erp.mapper.pp.*;
 import com.baomidou.dynamic.datasource.annotation.DS;
+import com.example.erp.mapper.sd.OrderMapper;
 import com.example.erp.mapper.sd.OrderProcessDetailMapper;
 import com.example.erp.service.sd.OrderProcessDetailService;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -24,10 +25,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.text.SimpleDateFormat;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 @Service
 @DS("pp")
@@ -43,19 +41,26 @@
     final
     ReportingWorkDetailMapper
     reportingWorkDetailMapper;
+    final OrderMapper
+    orderMapper;
+
+    final
+    FlowCardMapper flowCardMapper;
 
     final
     OrderProcessDetailService orderProcessDetailService;
 
 
 
-    public ReportingWorkService(ReportingWorkMapper reportingWorkMapper, BasicDateProduceMapper basicDateProduceMapper, DamageDetailsMapper damageDetailsMapper, ReportingWorkDetailMapper reportingWorkDetailMapper, OrderProcessDetailMapper orderProcessDetailMapper, OrderProcessDetailService orderProcessDetailService) {
+    public ReportingWorkService(ReportingWorkMapper reportingWorkMapper, BasicDateProduceMapper basicDateProduceMapper, DamageDetailsMapper damageDetailsMapper, ReportingWorkDetailMapper reportingWorkDetailMapper, OrderProcessDetailMapper orderProcessDetailMapper, OrderProcessDetailService orderProcessDetailService, OrderMapper orderMapper, FlowCardMapper flowCardMapper) {
         this.reportingWorkMapper = reportingWorkMapper;
         this.basicDateProduceMapper = basicDateProduceMapper;
         this.damageDetailsMapper = damageDetailsMapper;
         this.reportingWorkDetailMapper = reportingWorkDetailMapper;
         this.orderProcessDetailMapper = orderProcessDetailMapper;
         this.orderProcessDetailService = orderProcessDetailService;
+        this.orderMapper = orderMapper;
+        this.flowCardMapper = flowCardMapper;
     }
 
     public Map<String, Object> AddSelectLastWorkSv(String processIdStr, String technologyStr, String process) {
@@ -91,7 +96,7 @@
                 }
                 //System.out.println("褰撳墠宸ュ簭锛�" + process + " 涓婁竴閬撳伐搴忥細" + previousProcess + " 涓嬩竴閬撳伐搴忥細" + nextProcess);
                 //鏌ヨ褰撳墠宸ュ簭鐨勮〃澶存暟鎹�
-               // System.out.println(reportingWorkMapper.AddSelectLastWorkMp(processIdStr, technologyStr,previousProcess,nextProcess,process));
+               //System.out.println(reportingWorkMapper.AddSelectLastWorkMp(processIdStr, technologyStr,previousProcess,nextProcess,process));
                 map.put("data", reportingWorkMapper.AddSelectLastWorkMp(processIdStr, technologyStr,previousProcess,nextProcess,process));
                 map.put("thisProcess", processList);
                 break;
@@ -159,6 +164,14 @@
         String reportingWorkId =  "BG"+formattedDate+formattedNumber;
         reportingWork.setReportingWorkId(reportingWorkId);
         reportingWork.setProcessId(reportingWork.getProcessId().substring(0,13));
+
+        int reviewState = (int) reportingWorkJson.get("type");
+        if(reviewState==1){
+            reportingWork.setReviewed(reportingWork.getCreator());
+            reportingWork.setReviewedState(1);
+        }else{
+            reportingWork.setReviewedState(0);
+        }
         //涓昏〃鎻掑叆
         reportingWorkMapper.insert(reportingWork);
 
@@ -203,25 +216,19 @@
 
             //鍒ゆ柇鏄惁澶т簬褰撳墠鏁伴噺骞朵笖鎶涘嚭寮傚父
             if(processNum<(reportingWorkDetail.getBreakageQuantity()+reportingWorkDetail.getCompletedQuantity())){
-//                System.out.println(processNum);
-//                System.out.println(reportingWorkDetail.getBreakageQuantity());
-//                System.out.println(reportingWorkDetail.getCompletedQuantity());
-                throw new ServiceException(Constants.Code_600,"褰撳墠宸ュ簭鏁伴噺澶т簬娴佺▼鍗¤〃鏁伴噺");
+                Map<String,Object> map = new HashMap<>();
+                map.put("orderNumber",reportingWorkDetail.getOrderNumber());
+                map.put("technologyNumber",reportingWorkDetail.getOrderNumber());
+                map.put("processNum",processNum);
+                map.put("sumNum",reportingWorkDetail.getBreakageQuantity()+reportingWorkDetail.getCompletedQuantity());
+                String msg = JSON.toJSONString(map);
+                throw new ServiceException(Constants.Code_600,msg);
             }
-
-
-
-
 
             OrderProcessDetail orderProcessDetail = new OrderProcessDetail();
             orderProcessDetail.setBrokenNum(reportingWorkDetail.getBreakageQuantity());
             orderProcessDetail.setReportingWorkNum(reportingWorkDetail.getCompletedQuantity());
             orderProcessDetail.setReportingWorkNumCount(reportingWorkDetail.getCompletedQuantity());
-
-
-
-
-
 
             //鏍规嵁璁㈠崟id锛岃鍗曞簭鍙凤紝浠ュ強灏忕墖搴忓彿 鏇存柊灏忕墖娴佺▼鐨勫畬宸ユ暟閲忎互鍙婂埡鐮存暟閲�
             LambdaUpdateWrapper<OrderProcessDetail> updateWrapper = new LambdaUpdateWrapper<>();
@@ -230,13 +237,61 @@
                     .eq(OrderProcessDetail::getOrderId, reportingWork.getOrderId())
                     .eq(OrderProcessDetail::getProcess, reportingWork.getThisProcess())
                     .eq(OrderProcessDetail::getTechnologyNumber, reportingWorkDetail.getTechnologyNumber())
-                    .setSql("reporting_work_num_count =reporting_work_num_count +"+orderProcessDetail.getReportingWorkNum())
+                    .setSql("reporting_work_num_count = reporting_work_num_count +"+orderProcessDetail.getReportingWorkNum())
                     .setSql("reporting_work_num =reporting_work_num +"+orderProcessDetail.getReportingWorkNum())
                     .setSql("broken_num =broken_num +"+orderProcessDetail.getBrokenNum());
-
             orderProcessDetailMapper.update(null,updateWrapper);
             reportingWorkDetailMapper.insert(reportingWorkDetail);
+            //鏇存柊娴佺▼鍗¤〃鐨勬姤宸ユ暟閲�
+            if(Objects.equals(reportingWork.getNextProcess(), "")){
+                LambdaUpdateWrapper<FlowCard> flowCardLambdaUpdateWrapper =
+                        new LambdaUpdateWrapper<>();
+                flowCardLambdaUpdateWrapper
+                        .eq(FlowCard::getProcessId, reportingWork.getProcessId())
+                        .eq(FlowCard::getOrderNumber, reportingWorkDetail.getOrderNumber())
+                        .eq(FlowCard::getTechnologyNumber, reportingWorkDetail.getTechnologyNumber())
+                        .setSql("inventory_quantity = inventory_quantity +"+orderProcessDetail.getReportingWorkNum());
+                flowCardMapper.update(null,flowCardLambdaUpdateWrapper);
+            }
+
+
         });
-        return  false;
+        return  true;
+    }
+
+    //涓嬪伐搴忓鏍告柟娉�
+    public boolean ReviewReportingWorkSv(Map<String, String> reportingWork) {
+
+       String processId = reportingWork.get("processId");
+
+        LambdaUpdateWrapper
+                <ReportingWork> updateWrapper = new LambdaUpdateWrapper<>();
+        updateWrapper
+                .eq(ReportingWork::getProcessId, processId.substring(0,13))
+                .eq(ReportingWork::getThisProcess,reportingWork.get("process"))
+                .eq(ReportingWork::getReviewedState,0)
+                .setSql("reviewed_state =1");
+        reportingWorkMapper.update(null,updateWrapper);
+
+
+        return  true;
+    }
+
+    public Map<String,Object> selectUpdateReportingWorkSv(String reportingWorkId) {
+        ReportingWork reportingWork =reportingWorkMapper.selectOne(new LambdaQueryWrapper<ReportingWork>()
+                                        .eq(ReportingWork::getReportingWorkId,reportingWorkId));
+        reportingWork.setOrder(
+            orderMapper.selectOne(new LambdaQueryWrapper<Order>()
+                                        .eq(Order::getOrderId,reportingWork.getOrderId())));
+        reportingWork.setFlowCard(new FlowCard());
+
+        List<ReportingWorkDetail> reportingWorkDetails = reportingWorkDetailMapper.selectByreportingWorkId(reportingWorkId);
+
+
+        Map<String,Object> map = new HashMap<>();
+        map.put("reportingWork",reportingWork);
+        map.put("reportingWorkDetails",reportingWorkDetails);
+        return map;
+
     }
 }

--
Gitblit v1.8.0