From b8133c73f45a1ce79ce25a45b62b3f800430adbb Mon Sep 17 00:00:00 2001 From: liwenxuan <1298531568@qq.com> Date: Tue, 11 Mar 2025 14:43:06 +0800 Subject: [PATCH] =?UTF-8?q?=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?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../doubleprevent/FxfxdxJobHandler.java | 46 +++++++++++------ .../doubleprevent/FxfxdyJobHandler.java | 46 +++++++++++------ .../doubleprevent/FxgkcsJobHandler.java | 44 +++++++++++------ .../doubleprevent/FxsjJobHandler.java | 46 +++++++++++------ .../doubleprevent/YhpcjhJobHandler.java | 45 +++++++++++------ .../doubleprevent/YhpcrwJobHandler.java | 44 +++++++++++------ .../doubleprevent/YhzldaJobHandler.java | 47 ++++++++++++------ .../doubleprevent/ZztyjwxjlJobHandler.java | 49 ++++++++++++------- 8 files changed, 245 insertions(+), 122 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 2653d18..7819c89 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdxJobHandler.java @@ -6,6 +6,7 @@ import com.hxjt.dataupload.service.FxfxdxService; import com.hxjt.dataupload.utils.HttpUtils; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; +import org.apache.commons.lang3.StringUtils; import org.apache.http.protocol.HTTP; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -91,27 +92,42 @@ public class FxfxdxJobHandler { String post = null; try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "avRdnP4OxPigMalwzipa9F643CF443BE2F93"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(i+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(i+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ - System.out.println("失败"+(i+1)+",风险分析对象"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(i+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage()+jsonObject); } break; //System.out.println("post:"+post1.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 1cb9e45..7d52132 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxfxdyJobHandler.java @@ -7,6 +7,7 @@ import com.hxjt.dataupload.service.FxfxdxService; import com.hxjt.dataupload.utils.HttpUtils; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; +import org.apache.commons.lang3.StringUtils; import org.apache.http.protocol.HTTP; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -89,27 +90,42 @@ public class FxfxdyJobHandler { String post = null; try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "RZdFEDt03BmZvGwkuL6KAE15B7F9249CFBE9"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(i+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(i+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ - System.out.println("失败"+(i+1)+",风险分析单元"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(i+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage()+jsonObject); } break; //System.out.println("post:"+post1.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 e8b72e7..8b6c141 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxgkcsJobHandler.java @@ -7,6 +7,7 @@ import com.hxjt.dataupload.service.FxfxdxService; import com.hxjt.dataupload.utils.HttpUtils; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; +import org.apache.commons.lang3.StringUtils; import org.apache.http.protocol.HTTP; import org.apache.ibatis.annotations.Param; import org.slf4j.Logger; @@ -48,27 +49,42 @@ public class FxgkcsJobHandler { String post = null; try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "7CTkAyBoL26Jo7ZMNVmg0EA57A0791FD71AB"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(i+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(i+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); - success++; + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ - System.out.println("失败"+(i+1)+",风险管控措施"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(i+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage()+jsonObject); } break; } 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 e4ced2e..4ec2b32 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/FxsjJobHandler.java @@ -8,6 +8,7 @@ import com.hxjt.dataupload.service.FxfxdxService; import com.hxjt.dataupload.utils.HttpUtils; import com.xxl.job.core.context.XxlJobHelper; import com.xxl.job.core.handler.annotation.XxlJob; +import org.apache.commons.lang3.StringUtils; import org.apache.http.protocol.HTTP; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -45,27 +46,42 @@ public class FxsjJobHandler { try { //success++; post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "GGUIPRh5bemgUmX8bvyn76E2ACA7DEE82AB4"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(i+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(i+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ - System.out.println("失败"+(i+1)+",风险事件"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(i+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage()+jsonObject); } break; //System.out.println("post:"+post1.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 360bdbd..729d0f5 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcjhJobHandler.java @@ -102,27 +102,42 @@ public class YhpcjhJobHandler { String post = null; try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "5JzJFKkwF5aHJ0GQUz3Y3D76035B58D84048"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(i+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(i+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ - System.out.println("失败"+(i+1)+",隐患排查计划"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(i+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage()+jsonObject); } break; } 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 6955db1..1b78f89 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhpcrwJobHandler.java @@ -123,28 +123,42 @@ public class YhpcrwJobHandler { String post = null; try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "tp9tNKR6nGsS2mpdWzrQ02D93621E3411A0F"); - - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(x+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(x+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 System.out.println("失败"+(x+1)+",隐患排查任务"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail( "-->任务执行失败" + e.getMessage()+jsonObject); } break; } 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 5f0f223..69e8aad 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/YhzldaJobHandler.java @@ -83,27 +83,42 @@ public class YhzldaJobHandler { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "Tk4xNbES1nIUaIzEOPnc29269B98C15B1EE4"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if (postJsonObj.get("msg").equals("成功") && postJsonObj.get("code").toString().equals("1000000") && postJsonObj.get("status").toString().equals("200")) {//status - //成功 - System.out.println("隐患排查档案--第" + (x + 1) + "条成功,"); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; - } else { - System.out.println("隐患排查档案--第" + (x + 1) + "条失败,"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString() + jsonObject); + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(x+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } + }else{ + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 + System.out.println("失败"+(x+1)+",隐患排查任务"); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); - //XxlJobHelper.handleFail("-->任务执行失败" + e.getMessage() + jsonObject); } break; } 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 d400dc3..ff0b8d3 100644 --- a/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java +++ b/src/main/java/com/hxjt/dataupload/jobhandler/doubleprevent/ZztyjwxjlJobHandler.java @@ -1,7 +1,6 @@ package com.hxjt.dataupload.jobhandler.doubleprevent; import com.alibaba.fastjson.JSONObject; - import com.github.pagehelper.PageHelper; import com.github.pagehelper.PageInfo; import com.hxjt.dataupload.model.entity.doubleprevent.Fxfxdx; @@ -23,14 +22,14 @@ import java.util.List; @Component -public class YhpcrwJobHandler { +public class ZztyjwxjlJobHandler { - private Logger log = LoggerFactory.getLogger(YhpcrwJobHandler.class); + private Logger log = LoggerFactory.getLogger(ZztyjwxjlJobHandler.class); @Autowired FxfxdxService fxfxdxService; - @XxlJob(value = "YhpcrwJobHandler", init = "init", destroy = "destroy") + @XxlJob(value = "ZztyjwxjlJobHandler", init = "init", destroy = "destroy") public void execute(String param) { String jobParam = XxlJobHelper.getJobParam(); @@ -124,26 +123,42 @@ public class YhpcrwJobHandler { try { post = HttpUtils.sendDataUpload(url, jsonObject, HTTP.UTF_8, "tp9tNKR6nGsS2mpdWzrQ02D93621E3411A0F"); - JSONObject postJsonObj = JSONObject.parseObject(post); - if(postJsonObj.get("msg").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status - //成功 - System.out.println("成功"+(x+1)+","); - //System.out.println(jsonObject); - //System.out.println("post:" + post.toString()); - //XxlJobHelper.log("执行日志:" + company + post.toString()); - - success++; + boolean thisFailFlag = false; + boolean postIsNull = false; + 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").equals("成功")&&postJsonObj.get("code").toString().equals("1000000")&&postJsonObj.get("status").toString().equals("200")){//status + //成功 + System.out.println("成功"+(x+1)+","); + //System.out.println(jsonObject); + //System.out.println("post:" + post.toString()); + //XxlJobHelper.log("执行日志:" + company + post.toString()); + + success++; + }else{ + thisFailFlag = true; + } + }else{ + thisFailFlag = true; + postNoMsgs = true; + } }else{ + postIsNull = true; + thisFailFlag = true; + } + if(thisFailFlag){//异常情况 System.out.println("失败"+(x+1)+",隐患排查任务"); - System.out.println("post:" + post.toString()); - XxlJobHelper.log("执行日志:" + company + post.toString()+jsonObject); + if(!postIsNull){ + System.out.println("post:" + post.toString()); + XxlJobHelper.log("执行日志:" + company + post.toString()); + } fail++; } } catch (IOException e) { - fail++; e.printStackTrace(); - System.out.println(jsonObject); } break; }