From 1b188bf36d999590af33cf4a7463fc5e1aa73757 Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期三, 15 二月 2023 12:41:31 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/ints/task/scheduler/ErpPrdtScheduler.java |   34 +++++++++++++++++++++-------------
 1 files changed, 21 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/zy/ints/task/scheduler/ErpPrdtScheduler.java b/src/main/java/com/zy/ints/task/scheduler/ErpPrdtScheduler.java
index 088dbb9..fa38275 100644
--- a/src/main/java/com/zy/ints/task/scheduler/ErpPrdtScheduler.java
+++ b/src/main/java/com/zy/ints/task/scheduler/ErpPrdtScheduler.java
@@ -51,7 +51,7 @@
     @Scheduled(cron = "${erp.refreshtime}")
     public void obtainPedt() {
         if (!enabledErpPrdt) return;
-        String sqlSelectPrdt = "select prd_no as prdNo,name,ut,spc,status,type from ERP_PRDT where 1=1";
+        String sqlSelectPrdt = "select prd_no as prdNo,name,ut,spc,status,type,temp1 from ERP_PRDT where 1=1 and temp1 is null";
         String sqlUpDatePrdtOne = "update ERP_PRDT set status=1 where prd_no=";
         String sqlUpDatePrdtTwo = "update ERP_PRDT set status=2 ";
         try {
@@ -80,14 +80,18 @@
                                     erpSqlServer.update(sqlUpDatePrdtOne + "'" + prdt.getPrdNo() + "'");
                                     callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佹坊鍔犲晢鍝佷俊鎭垚鍔燂紒", true);
                                 } else {
-                                    erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='娣诲姞ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佺姸鎬佸紓甯革紒锛侊紒'"
-                                            + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
-                                    callApiLogSave(prdt, "ERP_PRDT", "娣诲姞ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佺姸鎬佸紓甯革紒锛侊紒", false);
+                                    if (Cools.isEmpty(prdt.getTemp1())){
+                                        erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='娣诲姞ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佺姸鎬佸紓甯革紒锛侊紒'"
+                                                + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
+                                        callApiLogSave(prdt, "ERP_PRDT", "娣诲姞ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佺姸鎬佸紓甯革紒锛侊紒", false);
+                                    }
                                 }
                             } else {
-                                erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佸晢鍝佸凡瀛樺湪锛侊紒锛�'"
-                                        + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
-                                callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佸晢鍝佸凡瀛樺湪锛侊紒锛�", false);
+                                if (Cools.isEmpty(prdt.getTemp1())){
+                                    erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佸晢鍝佸凡瀛樺湪锛侊紒锛�'"
+                                            + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
+                                    callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佸晢鍝佸凡瀛樺湪锛侊紒锛�", false);
+                                }
                             }
                         } else if (type == 2) {
                             Mat mat = matService.selectByMatnr(prdt.getPrdNo());
@@ -99,9 +103,11 @@
                                     erpSqlServer.update(sqlUpDatePrdtOne + "'" + prdt.getPrdNo() + "'");
                                     callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佷慨鏀瑰晢鍝佷俊鎭垚鍔燂紒", true);
                                 } else {
-                                    erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佷慨鏀瑰晢鍝佷俊鎭け璐ワ紒锛侊紒'"
-                                            + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
-                                    callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佷慨鏀瑰晢鍝佷俊鎭け璐ワ紒锛侊紒", false);
+                                    if (Cools.isEmpty(prdt.getTemp1())){
+                                        erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佷慨鏀瑰晢鍝佷俊鎭け璐ワ紒锛侊紒'"
+                                                + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
+                                        callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅澶辫触锛侊紒锛佷慨鏀瑰晢鍝佷俊鎭け璐ワ紒锛侊紒", false);
+                                    }
                                 }
                             }
                         } else if (type == 3) {
@@ -111,9 +117,11 @@
                                     erpSqlServer.update(sqlUpDatePrdtOne + "'" + prdt.getPrdNo() + "'");
                                     callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佸垹闄ゅ晢鍝佷俊鎭垚鍔燂紒", true);
                                 } else {
-                                    erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佸垹闄ゅ晢鍝佷俊鎭け璐ワ紒'"
-                                            + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
-                                    callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佸垹闄ゅ晢鍝佷俊鎭け璐ワ紒", false);
+                                    if (Cools.isEmpty(prdt.getTemp1())){
+                                        erpSqlServer.update(sqlUpDatePrdtTwo +",Temp1='鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佸垹闄ゅ晢鍝佷俊鎭け璐ワ紒'"
+                                                + "where 1=1 " +" and PRD_NO=" + "'" + prdt.getPrdNo() + "'");
+                                        callApiLogSave(prdt, "ERP_PRDT", "鎺ユ敹ERP涓嬪彂鍟嗗搧淇℃伅鎴愬姛锛佸垹闄ゅ晢鍝佷俊鎭け璐ワ紒", false);
+                                    }
                                 }
                             }
                         } else {

--
Gitblit v1.9.1