省一体化营山推送

dataCenter-manager/src/main/java/com/mortals/xhx/modules/information/task/ApplyAndAcceptInformationTaskImpl.java

@@ -74,13 +74,13 @@ public class ApplyAndAcceptInformationTaskImpl implements ITaskExcuteService {
                 extCache = arameterService.find(extCache).get(0);
                 Map<String, Object> dataMap = assembleData(e);
                 String post = "";
-//                String post = "1";
                 JSONObject ifResultInfo = null;
                 CallRecordEntity recordEntity = new CallRecordEntity();
                 try {
                     post = HttpUtil.post(extCache.getAcceptAdress(), JSONObject.toJSONString(dataMap));
-                    ifResultInfo = JSONObject.parseObject(post).getJSONObject("ifResultInfo");
-                    if ("200".equals("200")) {
+                    ifResultInfo = JSONObject.parseObject(JSONObject.parseObject(post).getString("ifResultInfo"));
+                    log.info("响应值" + ifResultInfo);
+                    if ("200".equals(ifResultInfo.getString("code"))) {
                         e.setIsReport("1");
                         e.setIsSuccess("1");
                         e.setOfficeCode(ifResultInfo.getJSONObject("data").getString("code"));
@@ -92,7 +92,7 @@ public class ApplyAndAcceptInformationTaskImpl implements ITaskExcuteService {
                         recordEntity=recordInterfaceExchangeRecord(post,ifResultInfo,e,dataMap);
                         log.info("推送省一体化申请并受理成功，办件编码：" + ifResultInfo.getJSONObject("data").getString("code"));
                     } else {
-                        e.setIsReport("0");
+                        e.setIsReport("1");
                         if (0 == e.getFailTimes()) {
                             e.setFailTimes(1);
                         } else {

dataCenter-manager/src/main/java/com/mortals/xhx/modules/information/task/DecideInformationTaskImpl.java

@@ -113,8 +113,9 @@ public class DecideInformationTaskImpl implements ITaskExcuteService {
                     extCache.setSysCode(e.getSystemCode());
                     extCache = arameterService.find(extCache).get(0);
                     post = HttpUtil.post(extCache.getDecideAdress(), JSONObject.toJSONString(dataMap));
-                    ifResultInfo = JSONObject.parseObject(post).getJSONObject("ifResultInfo");
-                    if ("200".equals("200")) {
+                    ifResultInfo = JSONObject.parseObject(JSONObject.parseObject(post).getString("ifResultInfo"));
+                    log.info("响应值" + ifResultInfo);
+                    if ("200".equals(ifResultInfo.getString("code"))) {
                         e.setBizStatus(NodeTypeEnum.办结.getDesc());
                         e.setNodeType(NodeTypeEnum.办结.getCode());
                         e.setProcessStatusName("办结");
@@ -124,7 +125,7 @@ public class DecideInformationTaskImpl implements ITaskExcuteService {
                         log.info("推送一体化决定数据成功");
                     } else {
                         //推送失败后，设置标识符，不在重复推送
-                        e.setIsReport("0");
+                        e.setIsSuccess("0");
                         if (0 == e.getFailTimes()) {
                             e.setFailTimes(1);
                         } else {
@@ -140,7 +141,7 @@ public class DecideInformationTaskImpl implements ITaskExcuteService {
                 } catch (Exception ex) {
                     ex.printStackTrace();
                     //推送失败后，设置标识符，不在重复推送
-                    e.setIsReport("0");
+                    e.setIsSuccess("0");
                     if (0 == e.getFailTimes()) {
                         e.setFailTimes(1);
                     } else {

dataCenter-manager/src/main/java/com/mortals/xhx/modules/information/task/ReviewInformationTaskImpl.java

@@ -64,7 +64,6 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
     }
 
     private void reviewData(List<InformationEntity> informationEntities) {
-        ArameterEntity arameterEntity = new ArameterEntity();
         if (!informationEntities.isEmpty()) {
             List<CallRecordEntity> callRecordEntities = new ArrayList<>();
             List<InformationEntity> collect = informationEntities.parallelStream().map(e -> {
@@ -115,9 +114,9 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
                     extCache.setSysCode(e.getSystemCode());
                     extCache = arameterService.find(extCache).get(0);
                     post = HttpUtil.post(extCache.getReviewAdress(), JSONObject.toJSONString(dataMap));
-                    ifResultInfo = JSONObject.parseObject(post).getJSONObject("ifResultInfo");
-                    ifResultInfo.getString("code");
-                    if ("200".equals("200")) {
+                    ifResultInfo = JSONObject.parseObject(JSONObject.parseObject(post).getString("ifResultInfo"));
+                    log.info("响应值" + ifResultInfo);
+                    if ("200".equals(ifResultInfo.getString("code"))) {
                         e.setBizStatus(NodeTypeEnum.决定.getDesc());
                         e.setNodeType(NodeTypeEnum.决定.getCode());
                         e.setProcessStatusName("决定");
@@ -127,7 +126,7 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
                         log.info("推送一体化审查数据成功，");
                     } else {
                         //推送失败后，设置标识符，不在重复推送
-                        e.setIsReport("0");
+                        e.setIsSuccess("0");
                         if (0 == e.getFailTimes()) {
                             e.setFailTimes(1);
                         } else {
@@ -143,7 +142,7 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
                 } catch (Exception ex) {
                     ex.printStackTrace();
                     //推送失败后，设置标识符，不在重复推送
-                    e.setIsReport("0");
+                    e.setIsSuccess("0");
                     if (0 == e.getFailTimes()) {
                         e.setFailTimes(1);
                     } else {