From 8bcf258496e7c6cdaa3921acec4db1d4f77fe6f2 Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期四, 24 四月 2025 13:34:59 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev

---
 aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderProcessServiceImpl.java |   50 ++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 40 insertions(+), 10 deletions(-)

diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderProcessServiceImpl.java b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderProcessServiceImpl.java
index de015e2..1a8a684 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderProcessServiceImpl.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderProcessServiceImpl.java
@@ -7,6 +7,7 @@
 import com.aps.job.domain.ApsWorkOrderJob;
 import com.aps.job.domain.ApsWorkOrderJobLog;
 import com.aps.job.domain.ApsWorkOrderProcess;
+import com.aps.job.mapper.ApsWorkOrderJobLogMapper;
 import com.aps.job.mapper.ApsWorkOrderJobMapper;
 import com.aps.job.mapper.ApsWorkOrderProcessMapper;
 import com.aps.job.service.IApsWorkOrderJobLogService;
@@ -53,6 +54,9 @@
 
     @Autowired
     private IApsWorkOrderJobLogService apsWorkOrderJobLogService;
+
+    @Autowired
+    private ApsWorkOrderJobLogMapper apsWorkOrderJobLogMapper;
 
     /**
      * 鏌ヨ宸ュ崟宸ュ簭
@@ -174,7 +178,7 @@
                             apsWorkOrderProcess.setDocNo(process.getString("DocNo"));
                             apsWorkOrderProcess.setOpNum(process.getString("OpNum"));
                             apsWorkOrderProcess.setOpId(process.getString("OpID"));
-                            apsWorkOrderProcess.setProcessName(process.getString("WorkCenter"));
+                            apsWorkOrderProcess.setProcessName(process.getString("StdOp"));
                             apsWorkOrderProcess.setStandardTime(process.getFloat("StandardTime"));
                             apsWorkOrderProcess.setPalnStartDate(process.getDate("PlanStartDate"));
                             apsWorkOrderProcess.setPlanCompleteDate(process.getDate("PlanCompleteDate"));
@@ -183,6 +187,7 @@
                             apsWorkOrderProcess.setOpStatus(process.getString("OpStatus"));
                             apsWorkOrderProcess.setOrg(process.getString("Org"));
                             apsWorkOrderProcess.setOrgCode(process.getString("OrgCode"));
+                            apsWorkOrderProcess.setWorkCenter(process.getString("WorkCenter"));
                             if (existsId != null) {
                                 apsWorkOrderProcess.setId(existsId);
                                 apsWorkOrderProcess.setUpdateTime(DateUtils.getNowDate());
@@ -241,11 +246,8 @@
         try{
             //鍒嗛〉鏌ヨ宸ュ崟
             ApsWorkOrderJob apsWorkOrderJob = new ApsWorkOrderJob();
-            if(status==null){
+            if("".equals(status)){
                 status = "0";
-            }
-            if(pageSize==null){
-                pageSize = 100;
             }
             apsWorkOrderJob.setProcessStatus(status);
             // 琛ユ煡涔嬪墠娌℃湁鏌ュ埌宸ュ簭鐨勫伐鍗�
@@ -275,12 +277,18 @@
                         long startTime = System.currentTimeMillis();
                         List<String> docNos = new ArrayList<>();
                         for (ApsWorkOrderJob apsWorkOrderJob1 : pageList){
-                            docNos.add(apsWorkOrderJob1.getDocNo());
+                            if(apsWorkOrderJob1.getDocNo()!=null){
+                                docNos.add(apsWorkOrderJob1.getDocNo());
+                            }
                         }
-                        getWorkOrderProcessFromU9(docNos);
-                        long endTime = System.currentTimeMillis(); // 璁板綍缁撴潫鏃堕棿
-                        long duration = endTime - startTime; // 璁$畻杩愯鏃堕棿
-                        System.out.println("杩愯鏃堕棿锛�"+ duration +"姣");
+                        if(!docNos.isEmpty()){
+                            getWorkOrderProcessFromU9(docNos);
+                            long endTime = System.currentTimeMillis(); // 璁板綍缁撴潫鏃堕棿
+                            long duration = endTime - startTime; // 璁$畻杩愯鏃堕棿
+                            System.out.println("杩愯鏃堕棿锛�"+ duration +"姣");
+                        }else{
+                            break;
+                        }
                     }else{
                         break;
                     }
@@ -301,4 +309,26 @@
     public void deleteApsProcessRoute() {
         apsWorkOrderProcessMapper.deleteApsProcessRoute();
     }
+
+    @Override
+    public boolean retryRequestWorkOrderProcessByLogId(Long id) {
+        try {
+            ApsWorkOrderJobLog apsWorkOrderJobLog = apsWorkOrderJobLogMapper.selectApsWorkOrderJobLogById(id);
+            JSONObject requestBodyJson = JSONObject.parseObject(apsWorkOrderJobLog.getRequestData());
+            JSONArray docListArray = requestBodyJson.getJSONArray("DocList");
+            List<String> docNos = new ArrayList<>();
+            for (int i = 0; i < docListArray.size(); i++) {
+                if(docListArray.getString(i)!=null){
+                    docNos.add(docListArray.getString(i));
+                }
+            }
+            if(!docNos.isEmpty()){
+                getWorkOrderProcessFromU9(docNos);
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+            return false;
+        }
+        return true;
+    }
 }

--
Gitblit v1.9.3