提取公共方法

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

@@ -73,21 +73,18 @@ public class ApplyAndAcceptInformationTaskImpl implements ITaskExcuteService {
                         e.setProcessStatusName("审查");
                         informationService.update(e, null);
                         log.info("推送省一体化申请并受理成功，办件编码：" + ifResultInfo.getJSONObject("data").getString("code"));
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     } else {
                         e.setFailTimes(e.getFailTimes() + 1);
                         e.setFailReason(ifResultInfo.getString("message"));
                         informationService.update(e, null);
                         log.info("省一体化申请并受理数据推送失败：" + ifResultInfo.getString("message"));
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     }
+                    //记录接口交换记录
+                    recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                 } catch (Exception ex) {
                     log.error("省一体化申请并受理数据推送失败：连接异常" + ex.getMessage());
                     //记录接口交换记录
                     recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
-
                 }
             });
         } else {

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

@@ -107,16 +107,14 @@ public class DecideInformationTaskImpl implements ITaskExcuteService {
                         e.setProcessStatusName("办结");
                         informationService.update(e, null);
                         log.info("推送一体化决定数据成功，办件编码：" + ifResultInfo.getJSONObject("data").getString("code"));
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     } else {
                         e.setFailTimes(e.getFailTimes() + 1);
                         e.setFailReason(ifResultInfo.getString("message"));
                         informationService.update(e, null);
                         log.info("省一体化申请并受理数据推送失败：" + ifResultInfo.getString("message"));
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     }
+                    //记录接口交换记录
+                    recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                 } catch (Exception ex) {
                     log.error("省一体化决定数据推送失败：连接异常" + post);
                     //记录接口交换记录

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

@@ -107,16 +107,14 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
                         e.setProcessStatusName("决定");
                         informationService.update(e, null);
                         log.info("推送一体化审查数据成功，");
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     } else {
                         e.setFailTimes(e.getFailTimes() + 1);
                         e.setFailReason(ifResultInfo.getString("message"));
                         informationService.update(e, null);
                         log.info("省一体化申请并受理数据推送失败：" + ifResultInfo.getString("message"));
-                        //记录接口交换记录
-                        recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                     }
+                    //记录接口交换记录
+                    recordInterfaceExchangeRecord(post, ifResultInfo, e, dataMap);
                 } catch (Exception ex) {
                     log.error("省一体化审查数据推送失败：连接异常" + post);
                     //记录接口交换记录

dataCenter-manager/src/main/resources/bootstrap.yml

@@ -12,13 +12,30 @@ spring:
       maxRequestSize: 1000Mb
 #  autoconfigure:
 #    exclude: org.springframework.cloud.netflix.eureka.EurekaClientAutoConfiguration
+
+#本地环境
+#  cloud:
+#    nacos:
+#      # Nacos 作为注册中心的配置项，对应 NacosDiscoveryProperties 配置类
+#      discovery:
+#        server-addr: 127.0.0.1:8848 # Nacos 服务器地址
+#        group: DEFAULT_GROUP
+#        namespace: 00d2fea1-874c-42cf-bf70-df75db75800a
+#      config:
+#        server-addr: ${spring.cloud.nacos.discovery.server-addr} # Nacos 服务器地址
+#        group: ${spring.cloud.nacos.discovery.group}
+#        namespace: ${spring.cloud.nacos.discovery.namespace} # Nacos 命名空间 dev 的编号
+#        file-extension: yaml
+
+
+#测试环境
   cloud:
     nacos:
       # Nacos 作为注册中心的配置项，对应 NacosDiscoveryProperties 配置类
       discovery:
-        server-addr: 127.0.0.1:8848 # Nacos 服务器地址
+        server-addr: 192.168.0.252:8848/nacos # Nacos 服务器地址
         group: DEFAULT_GROUP
-        namespace: 00d2fea1-874c-42cf-bf70-df75db75800a
+        namespace: dataCenter
       config:
         server-addr: ${spring.cloud.nacos.discovery.server-addr} # Nacos 服务器地址
         group: ${spring.cloud.nacos.discovery.group}

dataCenter-manager/src/main/resources/sqlmap/mortails_affair_supplement.sql

+/*
+ Navicat Premium Data Transfer
+
+ Source Server         : local
+ Source Server Type    : MySQL
+ Source Server Version : 80025
+ Source Host           : localhost:3306
+ Source Schema         : xhx-base
+
+ Target Server Type    : MySQL
+ Target Server Version : 80025
+ File Encoding         : 65001
+
+ Date: 04/08/2021 17:10:29
+*/
+
+SET NAMES utf8mb4;
+SET FOREIGN_KEY_CHECKS = 0;
+
+-- ----------------------------
+-- Table structure for mortails_affair_supplement
+-- ----------------------------
+DROP TABLE IF EXISTS `mortails_affair_supplement`;
+CREATE TABLE `mortails_affair_supplement`  (
+  `id` bigint NOT NULL COMMENT '主键',
+  `impl_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '实施清单名称',
+  `impl_code` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '实施清单编码',
+  `application_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '申请人属性',
+  `application_card_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '申请人证件类型',
+  `application_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '申请人姓名',
+  `application_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '申请人证件号码',
+  `application_phone` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '申请人手机号码',
+  `mechanism_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '机构名称',
+  `mechanism_address` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '机构地址',
+  `mechanism_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '机构性质',
+  `mechanism_id_type` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '机构证件类型',
+  `mechanism_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '机构编码',
+  `legal_person` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '法人姓名',
+  `apply_time` datetime NULL DEFAULT NULL COMMENT '办件申请日期',
+  `accept_name` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '受理人姓名',
+  `accept_id` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '受理人身份证号码',
+  `accept_phone` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '受理人手机号',
+  `sys_code` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '系统编码',
+  `is_execute` varchar(1) CHARACTER SET utf8 COLLATE utf8_general_ci NULL DEFAULT '0' COMMENT '是否执行转化（0.未执行  1.已执行）',
+  `is_success` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT '0' COMMENT '是否转化成功（0默认 1成功）',
+  `fail_reason` varchar(255) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci NULL DEFAULT NULL COMMENT '失败原因',
+  PRIMARY KEY (`id`) USING BTREE
+) ENGINE = InnoDB CHARACTER SET = utf8mb4 COLLATE = utf8mb4_0900_ai_ci COMMENT = '办件补录表' ROW_FORMAT = Dynamic;
+
+SET FOREIGN_KEY_CHECKS = 1;