From 43020fc4ad84ea5a074fcdd5c57a97fb52a1670a Mon Sep 17 00:00:00 2001 From: liwenxuan <1298531568@qq.com> Date: Wed, 12 Mar 2025 08:34:02 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E5=A4=8D=E5=BD=93=E7=A9=BA=E6=8C=87?= =?UTF-8?q?=E9=92=88=E5=BC=82=E5=B8=B8=E6=97=B6,=E4=BB=BB=E5=8A=A1?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E7=BB=A7=E7=BB=ADbug=202.=E6=97=A5=E5=BF=97?= =?UTF-8?q?=E4=BC=98=E5=8C=96,=E5=A2=9E=E5=8A=A0=E5=A4=B1=E8=B4=A5?= =?UTF-8?q?=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../doubleprevent/FxfxdxJobHandler.java | 7 ++++++- .../doubleprevent/FxfxdyJobHandler.java | 11 ++++++++--- .../doubleprevent/FxgkcsJobHandler.java | 7 ++++++- .../jobhandler/doubleprevent/FxsjJobHandler.java | 7 ++++++- .../doubleprevent/YhpcjhJobHandler.java | 7 ++++++- .../doubleprevent/YhpcrwJobHandler.java | 7 ++++++- .../doubleprevent/YhzldaJobHandler.java | 7 ++++++- .../doubleprevent/ZztyjwxjlJobHandler.java | 16 ++++++---------- 8 files changed, 50 insertions(+), 19 deletions(-) diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java index 7819c89..ca76c13 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java @@ -14,6 +14,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -97,7 +99,7 @@ public class FxfxdxJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(i+1)+","); @@ -118,6 +120,9 @@ public class FxfxdxJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(i+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java index 7d52132..6daf550 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java @@ -15,6 +15,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -32,7 +34,7 @@ public class FxfxdyJobHandler { ArrayList fxfxdxs = fxfxdxService.getFxfxdys(); ArrayList zdwxys = fxfxdxService.getZdwxys(); for (int i = 0; i < fxfxdxs.size(); i++) { - System.out.println(fxfxdxs.get(i)); + //System.out.println(fxfxdxs.get(i)); String HAZARD_NAME = fxfxdxs.get(i).getFengxianfenxiduixian(); for (int j = 0; j < zdwxys.size(); j++) { String DANGESOURCE_NAME = zdwxys.get(j).getZhongdaweixianyuanmi(); @@ -75,7 +77,7 @@ public class FxfxdyJobHandler { break; } } - System.out.println(fxfxdxs.get(i)); + //System.out.println(fxfxdxs.get(i)); } int success = 0; int fail = 0; @@ -95,7 +97,7 @@ public class FxfxdyJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(i+1)+","); @@ -116,6 +118,9 @@ public class FxfxdyJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(i+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java index 8b6c141..b6559f6 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java @@ -16,6 +16,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -54,7 +56,7 @@ public class FxgkcsJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(i+1)+","); @@ -75,6 +77,9 @@ public class FxgkcsJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(i+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java index 4ec2b32..061186b 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java @@ -16,6 +16,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -51,7 +53,7 @@ public class FxsjJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(i+1)+","); @@ -72,6 +74,9 @@ public class FxsjJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(i+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java index 729d0f5..59e00d5 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java @@ -16,6 +16,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; @@ -107,7 +109,7 @@ public class YhpcjhJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(i+1)+","); @@ -128,6 +130,9 @@ public class YhpcjhJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(i+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java index 1b78f89..5bbaf2c 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java @@ -18,6 +18,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; @@ -128,7 +130,7 @@ public class YhpcrwJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(x+1)+","); @@ -149,6 +151,9 @@ public class YhpcrwJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(x+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java index 69e8aad..78b93b0 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java @@ -19,6 +19,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; @@ -88,7 +90,7 @@ public class YhzldaJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(x+1)+","); @@ -109,6 +111,9 @@ public class YhzldaJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(x+1)+",隐患排查任务"); if(!postIsNull){ System.out.println("post:" + post.toString()); diff --git a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java index 5b94297..cf20817 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java @@ -18,6 +18,8 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.io.IOException; +import java.time.LocalDateTime; +import java.time.format.DateTimeFormatter; import java.util.ArrayList; import java.util.List; @@ -61,16 +63,7 @@ public class ZztyjwxjlJobHandler { System.out.println("本页条数:" + pageInfo.getList().size()); //对本页数据进行上传 for (int x = 0; x < pageInfo.getList().size(); x++) { - - - //在此进行上传 - - - - - - String company = pageInfo.getList().get(x).getQiyemingcheng(); String url = "https://www.ny-fxfk.com/space-ningyanghuagongchany/sapi/qpaas/tiga/dys/keyAuthentication/zhuangzhitingyongjia/v1/zhuangzhitingyongjia"; switch (company) { @@ -86,7 +79,7 @@ public class ZztyjwxjlJobHandler { boolean postNoMsgs = false; if(!StringUtils.isBlank(post)){ JSONObject postJsonObj = JSONObject.parseObject(post); - if(!StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ + if(postJsonObj.get("msg")!=null && postJsonObj.get("code")!=null && postJsonObj.get("status")!=null && !StringUtils.isBlank(postJsonObj.get("msg").toString())&&!StringUtils.isBlank(postJsonObj.get("code").toString())&&!StringUtils.isBlank(postJsonObj.get("status").toString())){ if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status //成功 System.out.println("成功"+(x+1)+","); @@ -107,6 +100,9 @@ public class ZztyjwxjlJobHandler { thisFailFlag = true; } if(thisFailFlag){//异常情况 + DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"); + String formattedDate = LocalDateTime.now().format(formatter); + System.out.println(" 当前时间: " + formattedDate); // 示例输出：2025-03-12 08:29:25 System.out.println("失败"+(x+1)+",装置停用检维修记录"); if(!postIsNull){ System.out.println("post:" + post.toString());