From 2f640b1038fa331954f78ed1f4317212cf5bb34d Mon Sep 17 00:00:00 2001
From: chenlu <1320612696@qq.com>
Date: 星期五, 07 六月 2024 16:56:06 +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 |   68 +++++++++++++++++++++++----------
 1 files changed, 47 insertions(+), 21 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 956c65e..b78390d 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
@@ -3,14 +3,15 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.dynamic.datasource.annotation.DS;
-import com.example.erp.entity.pp.FlowCard;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.example.erp.entity.pp.PatchLog;
-import com.example.erp.entity.pp.Rework;
+import com.example.erp.entity.pp.ReportingWork;
 import com.example.erp.entity.userInfo.SysError;
 import com.example.erp.mapper.pp.PatchLogMapper;
+import com.example.erp.mapper.pp.ReportingWorkMapper;
 import com.example.erp.service.userInfo.SysErrorService;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
 
 import java.text.SimpleDateFormat;
@@ -20,12 +21,22 @@
 
 @Service
 @DS("pp")
+@Transactional(rollbackFor = Exception.class)
 public class ReplenishService {
-    @Autowired
+    final
     PatchLogMapper patchMapper;
 
-    @Autowired
+    final
     SysErrorService sysErrorService;
+
+    final
+    ReportingWorkMapper reportingWorkMapper;
+
+    public ReplenishService(PatchLogMapper patchMapper, SysErrorService sysErrorService, ReportingWorkMapper reportingWorkMapper) {
+        this.patchMapper = patchMapper;
+        this.sysErrorService = sysErrorService;
+        this.reportingWorkMapper = reportingWorkMapper;
+    }
 
 
     public List<Map<String, Object>> getSelectReplenish(Integer pageNum, Integer pageSize) {
@@ -97,24 +108,39 @@
 
     public Boolean updateReplenish(Map<String,Object> object) {
         boolean saveState = true;
-
-        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) {
-                //瀹℃牳
-                patchMapper.updateReplenish(patchLog,userName);
+        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) {
+                    //瀹℃牳
+                   patchMapper.updateReplenish(patchLog,userName);
+                    ReportingWork reportingWork = reportingWorkMapper
+                            .selectOne(new QueryWrapper<ReportingWork>().eq("reporting_work_id",patchLog.getReportingWorkId()));
+                    //淇敼灏忕墖娴佺▼鍗℃暟閲�
+                    patchMapper.updateOrderProcessDetail(patchLog,reportingWork);
+                }
+            }
 
+        } catch (Exception e) {
+            TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
+            //灏嗗紓甯镐紶鍏ユ暟鎹簱
+            SysError sysError = new SysError();
+            sysError.setError(e.toString());
+            sysError.setFunc("saveOrder");
+            sysErrorService.insert(sysError);
+            saveState = false;
+
+        }
 
         return saveState;
 

--
Gitblit v1.8.0