From 82a5de6d2ec80b45660149c84be28734032562f6 Mon Sep 17 00:00:00 2001
From: chenlu <1320612696@qq.com>
Date: 星期五, 11 十月 2024 15:21:53 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/ERP_override

---
 north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java |  183 +++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 166 insertions(+), 17 deletions(-)

diff --git a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java
index abf91c4..04f0a32 100644
--- a/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java
+++ b/north-glass-erp/src/main/java/com/example/erp/service/pp/ReplenishService.java
@@ -4,13 +4,17 @@
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.dynamic.datasource.annotation.DS;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.example.erp.dto.pp.PatchLogAddDTO;
+import com.example.erp.dto.pp.PatchLogDTO;
 import com.example.erp.entity.pp.FlowCard;
 import com.example.erp.entity.pp.PatchLog;
 import com.example.erp.entity.pp.ReportingWork;
+import com.example.erp.entity.userInfo.Log;
 import com.example.erp.entity.userInfo.SysError;
 import com.example.erp.mapper.pp.FlowCardMapper;
 import com.example.erp.mapper.pp.PatchLogMapper;
 import com.example.erp.mapper.pp.ReportingWorkMapper;
+import com.example.erp.service.userInfo.LogService;
 import com.example.erp.service.userInfo.SysErrorService;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -37,21 +41,24 @@
     final
     FlowCardMapper flowCardMapper;
 
-    public ReplenishService(PatchLogMapper patchMapper, SysErrorService sysErrorService, ReportingWorkMapper reportingWorkMapper,FlowCardMapper flowCardMapper) {
+    final LogService logService;
+
+    public ReplenishService(PatchLogMapper patchMapper, SysErrorService sysErrorService, ReportingWorkMapper reportingWorkMapper,FlowCardMapper flowCardMapper,LogService logService) {
         this.patchMapper = patchMapper;
         this.sysErrorService = sysErrorService;
         this.reportingWorkMapper = reportingWorkMapper;
         this.flowCardMapper = flowCardMapper;
+        this.logService = logService;
     }
 
 
-    public List<Map<String, Object>> getSelectReplenish(Integer pageNum, Integer pageSize) {
+    public List<PatchLogAddDTO> getSelectReplenish(Integer pageNum, Integer pageSize,PatchLogAddDTO patchLogAddDTO) {
         Integer offset = (pageNum - 1) * pageSize;
-        return patchMapper.getSelectReplenish(offset,pageSize);
+        return patchMapper.getSelectReplenish(offset,pageSize,patchLogAddDTO);
 
     }
 
-    public Map<String, Object> SelectReplenish(Integer pageNum, Integer pageSize,List<String> selectDate,PatchLog patchLog) {
+    public Map<String, Object> SelectReplenish(Integer pageNum, Integer pageSize, List<String> selectDate, PatchLogDTO patchLogDTO) {
         Integer offset = (pageNum-1)*pageSize;
         String endDate = LocalDate.now().toString();
         String startDate = LocalDate.now().minusDays(15).toString();
@@ -64,8 +71,8 @@
             }
         }
         Map<String,Object> map = new HashMap<>();
-        map.put("data",patchMapper.SelectReplenish(offset,pageSize,startDate,endDate,patchLog));
-        map.put("total",patchMapper.SelectReplenishPageTotal(offset,pageSize,startDate,endDate,patchLog));
+        map.put("data",patchMapper.SelectReplenish(offset,pageSize,startDate,endDate,patchLogDTO));
+        map.put("total",patchMapper.SelectReplenishPageTotal(offset,pageSize,startDate,endDate,patchLogDTO));
 
         List<String> list = new ArrayList<>();
         list.add(startDate);
@@ -94,6 +101,7 @@
                     //娣诲姞杩斿伐璁板綍锛屼慨鏀规鐮存槑缁嗘暟閲�
                     patchMapper.insertReplenish(patchLog,oddNumber);
                     patchMapper.updateDamageDetails(patchLog);
+                    patchMapper.updateReportingWorkDetail(patchLog.getReportingWorkId(), Integer.valueOf(patchLog.getOrderSort()),patchLog.getTechnologyNumber());
                 }
             }
 
@@ -107,6 +115,14 @@
             saveState = false;
 
         }
+
+        //淇濆瓨鏃ュ織
+        Log log = new Log();
+        log.setContent(object.toString());
+        log.setFunction("saveReplenish琛ョ墖鏂板");
+        log.setOperatorId((String) object.get("userId"));
+        log.setOperator((String) object.get("userName"));
+        logService.saveLog(log);
 
         return saveState;
 
@@ -128,12 +144,25 @@
             List<PatchLog> patchLoglist = JSONArray.parseArray(JSONObject.toJSONString(object.get("patchLog")), PatchLog.class);
             if (!patchLoglist.isEmpty()){
                 for (PatchLog patchLog : patchLoglist) {
-                    //瀹℃牳
-                   patchMapper.updateReplenish(patchLog,userName);
-                    ReportingWork reportingWork = reportingWorkMapper
-                            .selectOne(new QueryWrapper<ReportingWork>().eq("reporting_work_id",patchLog.getReportingWorkId()));
-                    //淇敼灏忕墖娴佺▼鍗℃暟閲�
-                    patchMapper.updateOrderProcessDetail(patchLog,reportingWork);
+                    PatchLog patchLog1=patchMapper.selectOne(new QueryWrapper<PatchLog>().eq("id",patchLog.getId()));
+                    //鍒ゆ柇鏄惁宸茬粡瀹℃牳
+                    if(patchLog1.getReviewStatus()==0){
+                        ReportingWork reportingWork = reportingWorkMapper
+                                .selectOne(new QueryWrapper<ReportingWork>().eq("reporting_work_id",patchLog.getReportingWorkId()));
+                        //淇敼灏忕墖娴佺▼鍗℃暟閲�
+                        patchMapper.updateOrderProcessDetail(patchLog,reportingWork);
+                        //瀹℃牳
+                        patchMapper.updateReplenish(patchLog,userName);
+                    }else{
+                        saveState = false;
+                    }
+
+                    Log log = new Log();
+                    log.setContent(object.toString());
+                    log.setFunction("updateReplenish琛ョ墖瀹℃牳");
+                    log.setOperatorId((String) object.get("userId"));
+                    log.setOperator((String) object.get("userName"));
+                    logService.saveLog(log);
                 }
             }
 
@@ -142,7 +171,7 @@
             //灏嗗紓甯镐紶鍏ユ暟鎹簱
             SysError sysError = new SysError();
             sysError.setError(e.toString());
-            sysError.setFunc("saveOrder");
+            sysError.setFunc("updateReplenish");
             sysErrorService.insert(sysError);
             saveState = false;
 
@@ -177,16 +206,23 @@
         return map;
     }
 
-    public Map<String, Object> getSelectPrintCustomLabelSv(String type, Map<String, Object> object) {
+    public Map<String, Object> getSelectPrintCustomLabelSv(String type, Integer lableType, Map<String, Object> object) {
         Map<String, Object> map = new HashMap<>();
         List<Map<String, Object>> list = new ArrayList<Map<String, Object>>();//鏈�缁堢粨鏋�
         List<FlowCard> flowCardList = JSONArray.parseArray(JSONObject.toJSONString(object.get("printList")), FlowCard.class);
         if (!flowCardList.isEmpty()) {
             for (FlowCard flowCard : flowCardList) {
+                if (lableType != 2){
+                    Map<String, Object> itemmap = new HashMap<>();
+                    itemmap.put("data", flowCardMapper.getRepairPrintCustomData(flowCard.getProcessId(),flowCard.getTechnologyNumber(),flowCard.getReportingWorkId()));
+                    list.add(itemmap);
+                }
+                else{
+                    Map<String, Object> itemmap = new HashMap<>();
+                    itemmap.put("data", flowCardMapper.getRepairPrintCustomDataSemi(flowCard.getProcessId(),flowCard.getTechnologyNumber(),flowCard.getReportingWorkId()));
+                    list.add(itemmap);
+                }
 
-                Map<String, Object> itemmap = new HashMap<>();
-                itemmap.put("data", flowCardMapper.getRepairPrintCustomData(flowCard.getProcessId(),flowCard.getTechnologyNumber()));
-                list.add(itemmap);
 
 
             }
@@ -195,5 +231,118 @@
         map.put("title", flowCardMapper.getPrintTitle(type));
         return map;
     }
+
+    public Boolean deleteReplenishSv(Map<String, Object> object) {
+        boolean saveState = true;
+        Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
+        try {
+            String userName = "";
+            String userId = "";
+            if (object.get("userName") != null) {
+                userName = object.get("userName").toString();
+            }
+            if (object.get("userId") != null) {
+                userId = object.get("userId").toString();
+            }
+            //鑾峰彇瀵硅薄闆嗗悎寰幆杩涜鏂板淇敼
+            List<PatchLog> patchLoglist = JSONArray.parseArray(JSONObject.toJSONString(object.get("patchLog")), PatchLog.class);
+            if (!patchLoglist.isEmpty()){
+                for (PatchLog patchLog : patchLoglist) {
+                    PatchLog patchLog1=patchMapper.selectOne(new QueryWrapper<PatchLog>().eq("id",patchLog.getId()));
+                    //鍒ゆ柇鏄惁宸茬粡瀹℃牳
+                    if(patchLog1.getReviewStatus()==0){
+                        //鍒犻櫎琛ョ墖琛ㄥ搴旇ˉ鐗噄d鏁版嵁
+                        patchMapper.deleteReplenishMp(patchLog1.getId());
+                        //鍒犻櫎娆$牬鏄庣粏琛�
+                        patchMapper.updatePatchDdMp(patchLog1.getReportingWorkId(),patchLog1.getOrderSort(),patchLog1.getTechnologyNumber(),patchLog1.getPatchNum(),patchLog1.getPatchReason());
+                        //淇敼鎶ュ伐鏄庣粏琛ㄧ姸鎬�
+                        patchMapper.updatePatchBgMp(patchLog1.getReportingWorkId(),patchLog1.getOrderSort(),patchLog1.getTechnologyNumber());
+                        //淇敼鎶ュ伐涓昏〃娆$牬鏁伴噺
+                        reportingWorkMapper.updateRWPatchNum(patchLog1.getReportingWorkId(),patchLog1.getPatchNum());
+                        //淇敼鎶ュ伐鍓〃娆$牬鏁伴噺
+                        reportingWorkMapper.updateRWDPatchNum(patchLog1.getReportingWorkId(),patchLog1.getOrderSort(),patchLog1.getTechnologyNumber(),patchLog1.getPatchNum());
+                        //鏇存柊鎶ュ伐娴佺▼琛ㄦ暟鎹�
+                        reportingWorkMapper.updateReplenishWorkProcess(patchLog1.getProcessId(),patchLog1.getOrderSort(),patchLog1.getTechnologyNumber(),patchLog1.getPatchNum(),patchLog1.getPatchProcesses());
+                    }
+                    else{
+                        saveState = false;
+                    }
+                }
+            }
+
+        } catch (Exception e) {
+            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
+            //灏嗗紓甯镐紶鍏ユ暟鎹簱
+            SysError sysError = new SysError();
+            sysError.setError(e.toString());
+            sysError.setFunc("deleteReplenishSv");
+            sysErrorService.insert(sysError);
+            saveState = false;
+
+        }
+
+        return saveState;
+    }
+
+    public Boolean updateCancelReviewSv(Map<String, Object> object) {
+        boolean saveState = true;
+        Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
+        //try {
+            String userName = "";
+            String userId = "";
+            if (object.get("userName") != null) {
+                userName = object.get("userName").toString();
+            }
+            if (object.get("userId") != null) {
+                userId = object.get("userId").toString();
+            }
+            //鑾峰彇瀵硅薄闆嗗悎寰幆杩涜鏂板淇敼
+            List<PatchLog> patchLoglist = JSONArray.parseArray(JSONObject.toJSONString(object.get("patchLog")), PatchLog.class);
+            if (!patchLoglist.isEmpty()){
+                for (PatchLog patchLog : patchLoglist) {
+                    //鏌ヨ娴佺▼鍗″伐鑹烘祦绋�
+                    String technologicalProcess = reportingWorkMapper.SelectTechnologicalProcess(patchLog.getProcessId(), String.valueOf(patchLog.getTechnologyNumber()));
+                    if (technologicalProcess!=null || !technologicalProcess.equals("")) {
+                        String[] processList = technologicalProcess.split("->");
+                        //鑾峰彇宸ヨ壓娴佺▼绗竴涓伐搴�
+                        String interceptProcess = processList[0];
+                        Integer firstStep=reportingWorkMapper.getFirstStep(patchLog.getProcessId(),patchLog.getOrderSort(),patchLog.getTechnologyNumber(),interceptProcess);
+                          if (firstStep>=patchLog.getPatchNum()){
+                              ReportingWork reportingWork = reportingWorkMapper
+                                      .selectOne(new QueryWrapper<ReportingWork>().eq("reporting_work_id",patchLog.getReportingWorkId()));
+                              //淇敼灏忕墖娴佺▼鍗℃暟閲�
+                              patchMapper.updateOrderProcessDetailCancel(patchLog,reportingWork);
+                              //瀹℃牳
+                              patchMapper.updateReplenishCancel(patchLog);
+                          }
+                          else {
+                              saveState = false;
+                          }
+                    }else{
+                        saveState = false;
+                    }
+
+                    Log log = new Log();
+                    log.setContent(object.toString());
+                    log.setFunction("updateCancelReviewSv琛ョ墖鍙嶅");
+                    log.setOperatorId((String) object.get("userId"));
+                    log.setOperator((String) object.get("userName"));
+                    logService.saveLog(log);
+                }
+            }
+
+//        } catch (Exception e) {
+//            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
+//            //灏嗗紓甯镐紶鍏ユ暟鎹簱
+//            SysError sysError = new SysError();
+//            sysError.setError(e.toString());
+//            sysError.setFunc("updateCancelReviewSv");
+//            sysErrorService.insert(sysError);
+//            saveState = false;
+//
+//        }
+
+        return saveState;
+    }
 }
 

--
Gitblit v1.8.0