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