添加办件重新推送接口

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

@@ -71,6 +71,7 @@ public class ApplyAndAcceptInformationTaskImpl implements ITaskExcuteService {
             List<InformationEntity> entities = informationEntities.parallelStream().map(e -> {
                 ArameterEntity extCache = new ArameterEntity();
                 extCache.setSysCode(e.getSystemCode());
+                extCache.setAreaCode(e.getAreaCode());
                 extCache = arameterService.find(extCache).get(0);
                 Map<String, Object> dataMap = assembleData(e);
                 String post = "";

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

@@ -111,6 +111,7 @@ public class DecideInformationTaskImpl implements ITaskExcuteService {
                 try {
                     ArameterEntity extCache = new ArameterEntity();
                     extCache.setSysCode(e.getSystemCode());
+                    extCache.setAreaCode(e.getAreaCode());
                     extCache = arameterService.find(extCache).get(0);
                     post = HttpUtil.post(extCache.getDecideAdress(), JSONObject.toJSONString(dataMap));
                     if(StringUtils.isEmpty(post)){

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

@@ -112,6 +112,7 @@ public class ReviewInformationTaskImpl implements ITaskExcuteService {
                 try {
                     ArameterEntity extCache = new ArameterEntity();
                     extCache.setSysCode(e.getSystemCode());
+                    extCache.setAreaCode(e.getAreaCode());
                     extCache = arameterService.find(extCache).get(0);
                     post = HttpUtil.post(extCache.getReviewAdress(), JSONObject.toJSONString(dataMap));
                     if(StringUtils.isEmpty(post)){

dataCenter-manager/src/main/java/com/mortals/xhx/modules/supplement/task/SupplementTaskImpl.java

@@ -13,6 +13,8 @@ import com.mortals.xhx.common.code.PushTypeEnum;
 import com.mortals.xhx.common.utils.DateByAffairUtils;
 import com.mortals.xhx.common.utils.FilterSuppDataUtils;
 import com.mortals.xhx.common.utils.SnowFlakeUtil;
+import com.mortals.xhx.modules.arameter.model.ArameterEntity;
+import com.mortals.xhx.modules.arameter.service.ArameterService;
 import com.mortals.xhx.modules.implementlist.model.ImplementlistEntity;
 import com.mortals.xhx.modules.implementlist.model.RybMatterListEntry;
 import com.mortals.xhx.modules.implementlist.service.ImplementlistService;
@@ -58,6 +60,9 @@ public class SupplementTaskImpl implements ITaskExcuteService {
     @Autowired
     private InformationDao informationDao;
 
+    @Autowired
+    private ArameterService arameterService;
+
     @Override
     public void excuteTask(ITask task) throws AppException {
         //1.查询上月的表是否存在未清洗的数据 //蓉易办
@@ -95,7 +100,10 @@ public class SupplementTaskImpl implements ITaskExcuteService {
                         informationQuery.setDeptCode(thImplement.getDeptCode());
                         informationQuery.setEventCode(thImplement.getMatterCode());
                         informationQuery.setEventName(thImplement.getMatterName());
-                        informationQuery.setAreaCode(area);
+                        ArameterEntity extCache = new ArameterEntity();
+                        extCache.setSysCode(e.getSysCode());
+                        extCache = arameterService.find(extCache).get(0);
+                        informationQuery.setAreaCode(extCache.getAreaCode());
                         //是否转化成功：0默认 1成功
                         informationQuery.setIsSuccess("1");
                         //是否推送（0 否 1是）