线程睡

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

@@ -2919,14 +2919,16 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
         }
         if (ItemGridPlatformHandleStatusEnum.HANDLE_PQ.getValue() == dto.getState()) {
             pushToCityGridService.appealDispatch(dto);//2.2 诉求派遣
-            pushToCityGridService.dispatchAudit(dto);//2.4  派遣审核
+            //pushToCityGridService.dispatchAudit(dto);//2.4  派遣审核
+            new DataReport().myRun(dto, "2");
         } else if (ItemGridPlatformHandleStatusEnum.HANDLE_CZ.getValue() == dto.getState()) {
             if ("区中心".equals(dto.getGridNextpartname())) {
                 // 诉求上报
                 pushToCityGridService.appealReporting(dto.getId(), NumConstant.ONE_STR);
             } else {
                 pushToCityGridService.appealDispatch(dto);//2.2 诉求派遣
-                pushToCityGridService.dispatchAudit(dto);//2.4  派遣审核
+                //pushToCityGridService.dispatchAudit(dto);//2.4  派遣审核
+                new DataReport().myRun(dto, "2");
             }
         } else if (ItemGridPlatformHandleStatusEnum.HANDLE_TD.getValue() == dto.getState()) {
             pushToCityGridService.rebut(dto);//2.8 诉求退件
@@ -2956,7 +2958,29 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
         if (ItemGridPlatformHandleStatusEnum.HANDLE_CL.getValue() == dto.getState()) {
             pushToCityGridService.appealHandling(dto);
             // 诉求审核，上报市平台
-            pushToCityGridService.appealAudit(dto.getId());
+            //pushToCityGridService.appealAudit(dto.getId());
+            new DataReport().myRun(dto, "2");
+        }
+    }
+
+    public class DataReport {
+        public void myRun(ItemHandleProcessDTO dto ,String type) {
+            new Thread(new Runnable() {
+                @SneakyThrows
+                @Override
+                public void run() {
+                    try {
+                        Thread.sleep(131000);
+                        if("1".equals(type)){
+                            pushToCityGridService.dispatchAudit(dto);//2.4  派遣审核
+                        }else if("2".equals(type)){
+                            pushToCityGridService.appealAudit(dto.getId());   // 诉求审核
+                        }
+                    } catch (Exception e) {
+                        e.printStackTrace();
+                    }
+                }
+            }).start();
         }
     }
 

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

@@ -55,7 +55,6 @@ import com.elink.esua.epdc.modules.item.entity.ItemHandleProcessEntity;
 import com.elink.esua.epdc.modules.item.entity.ItemReportInterfaceLogEntity;
 import com.elink.esua.epdc.modules.item.service.ItemService;
 import com.elink.esua.epdc.modules.item.service.PushToCityGridService;
-import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
@@ -365,10 +364,8 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
      * @date 2022/9/19 9:44
      */
     @Override
-    @SneakyThrows
     public Result dispatchAudit(ItemHandleProcessDTO formDTO) {
         /*String state = "1001";*/
-        Thread.sleep(130000);
         List<ItemHandleProcessDTO> list = new ArrayList<>();
         if (null != formDTO && StringUtils.isNotBlank(formDTO.getItemId())) {
             ItemHandleProcessEntity entity = itemHandleProcessDao.selectById(formDTO.getId());
@@ -1225,10 +1222,8 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
     }
 
     @Override
-    @SneakyThrows
     public void appealAudit(String processId) {
         // 诉求审核，固定在结案之前，查询结案数据即可
-        Thread.sleep(130000);
         ItemHandleProcessEntity entity = itemHandleProcessDao.selectById(processId);
         // 拼接数据
         AppealAuditResultDTO dto = new AppealAuditResultDTO();