批量推送

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java

@@ -129,6 +129,7 @@ import java.math.BigDecimal;
 import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
 import java.util.*;
+import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
 /**
@@ -6230,8 +6231,15 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
         LambdaQueryWrapper<ItemEntity> itemEntityLambdaQueryWrapper = new LambdaQueryWrapper<ItemEntity>()
                 .isNull(ItemEntity::getSqid).eq(ItemEntity::getPeopleFlag,0).ne(ItemEntity::getAppealSource,0);
         List<ItemEntity> itemList = baseDao.selectList(itemEntityLambdaQueryWrapper);
+/*        LambdaQueryWrapper<ItemEntity> itemEntityLambdaQueryWrapper = new LambdaQueryWrapper<ItemEntity>()
+                .isNull(ItemEntity::getSqid).eq(ItemEntity::getPeopleFlag,0).ne(ItemEntity::getAppealSource,0)
+                .eq(ItemEntity::getId,"52ba27c1cfc04827d4efd4d487fb312c");
+        List<ItemEntity> itemList = baseDao.selectList(itemEntityLambdaQueryWrapper);*/
 
         itemList.forEach(entity -> {
+            try {
+                Thread.sleep(1000);
+
                 LambdaQueryWrapper<ItemHandleProcessEntity> hanprocessThree = new LambdaQueryWrapper<ItemHandleProcessEntity>()
                         .eq(ItemHandleProcessEntity::getItemId,entity.getId()).eq(ItemHandleProcessEntity::getState,"11").orderByAsc(ItemHandleProcessEntity::getCreatedTime).last("limit 1");
                 ItemHandleProcessEntity itemThree = itemHandleProcessDao.selectOne(hanprocessThree);
@@ -6300,6 +6308,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
 
                     // todo 第二步 诉求响应
                     // 找到这一条的processid
+                    Thread.sleep(1000);
                     LambdaQueryWrapper<ItemReportInterfaceLogEntity> reportqw = new LambdaQueryWrapper<ItemReportInterfaceLogEntity>()
                             .eq(ItemReportInterfaceLogEntity::getItemId,entity.getId()).eq(ItemReportInterfaceLogEntity::getInterfaceName,"响应接收").orderByAsc(ItemReportInterfaceLogEntity::getCreatedTime).last("limit 1");
                     ItemReportInterfaceLogEntity itemReportInterfaceLogEntity = itemReportInterfaceLogDao.selectOne(reportqw);
@@ -6335,6 +6344,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
                     }
 
                     // todo 第三步 诉求处理
+                    Thread.sleep(1000);
                     if (itemThree!=null){
 
                         AppealHandlingToCityResultDTO item = itemHandleProcessDao.getAppealHandling(itemThree.getId(), itemThree.getItemId());
@@ -6345,7 +6355,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
                         // 诉求性质
                         data.setSqxz(itemThree.getNature());
                         // 诉求id
-                    data.setSqid(getSqid(itemThree.getItemId()));
+                        data.setSqid(entity.getSqid());
                         // 诉求状态
                         data.setSqzt(CityPushStateEnum.DSH.getCode());
                         // 当前处理环节
@@ -6428,7 +6438,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
                             dto.setSsbm(item.getGridUnitname());
                         } else {
                             // 操作人姓名
-                        dto.setXm(null == SecurityUser.getUser() ? "" : SecurityUser.getUser().getUsername());
+                            dto.setXm(entity.getHandlePeopleName());
                             // 操作人员唯一标识
                             dto.setId(item.getCreatedBy());
                             // 所属机构id
@@ -6450,13 +6460,13 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
 
                     // todo 第四步 诉求审核
                     // 找到这一条的processid
+                    Thread.sleep(1000);
                     reportqw = new LambdaQueryWrapper<ItemReportInterfaceLogEntity>()
                             .eq(ItemReportInterfaceLogEntity::getItemId,entity.getId()).eq(ItemReportInterfaceLogEntity::getInterfaceName,"诉求审核").orderByAsc(ItemReportInterfaceLogEntity::getCreatedTime).last("limit 1");
                     ItemReportInterfaceLogEntity itemReportInterfaceLogEntityFour = itemReportInterfaceLogDao.selectOne(reportqw);
                     if (itemReportInterfaceLogEntityFour!=null){
                         ItemHandleProcessEntity item = itemHandleProcessDao.selectById(itemReportInterfaceLogEntityFour.getProcessId());
                         // 拼接数据
-                    AppealAuditResultDTO dto = new AppealAuditResultDTO();
                         ObjectMapper objectMapper = new ObjectMapper();
                         AppealHandlingResultDTO appealHandlingResultDTO = new AppealHandlingResultDTO();
                         try {
@@ -6467,14 +6477,15 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
                         if (appealHandlingResultDTO != null){
                             appealHandlingResultDTO.setSqid(entity.getSqid());
                             // 组装好直接推送
-                        String result = cityGridApi.sendItemToCity(dto, PushToCityGridConstant.APPEAL_AUDIT, "诉求审核");
+                            String result = cityGridApi.sendItemToCity(appealHandlingResultDTO, PushToCityGridConstant.APPEAL_AUDIT, "诉求审核");
-                        pushToCityGridServiceImpl.saveLog(item.getItemId(), item.getId(), "诉求审核-2", PushToCityGridConstant.APPEAL_AUDIT, JSONObject.toJSONString(dto), result);
+                            pushToCityGridServiceImpl.saveLog(item.getItemId(), item.getId(), "诉求审核-2", PushToCityGridConstant.APPEAL_AUDIT, JSONObject.toJSONString(appealHandlingResultDTO), result);
                         }
                     }
 
                     // todo 第五步 诉求评价
                     // 找到这一条的processid
                     //已评价的item
+                    Thread.sleep(1000);
                     LambdaQueryWrapper<ItemEntity> wrapper = new LambdaQueryWrapper<>();
                     wrapper.eq(StringUtils.isNotBlank(entity.getId()), ItemEntity::getId, entity.getId());
                     List<ItemEntity> list = baseDao.selectList(wrapper);
@@ -6533,6 +6544,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
 
                     // todo 第六步 诉求结案
                     // 找到这一条的processid
+                    Thread.sleep(1000);
                     LambdaQueryWrapper<ItemHandleProcessEntity> hanprocess = new LambdaQueryWrapper<ItemHandleProcessEntity>()
                             .eq(ItemHandleProcessEntity::getItemId,entity.getId()).eq(ItemHandleProcessEntity::getState,"60").orderByAsc(ItemHandleProcessEntity::getCreatedTime).last("limit 1");
                     ItemHandleProcessEntity item = itemHandleProcessDao.selectOne(hanprocess);
@@ -6572,6 +6584,9 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
                         pushToCityGridServiceImpl.saveLog(item.getItemId(), item.getId(), "诉求结案-2", PushToCityGridConstant.CASE_CLOSED, JSONObject.toJSONString(data), result);
                     }
                 }
+            } catch (InterruptedException e) {
+                throw new RuntimeException(e);
+            }
         });
         return new Result();
     }