定时任务

esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/redis/ItemAutoProcessRedis.java

@@ -31,8 +31,7 @@ import org.springframework.stereotype.Component;
 
 import javax.annotation.Resource;
 import java.io.IOException;
-import java.util.Date;
-import java.util.Set;
+import java.util.*;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
@@ -93,7 +92,13 @@ public class ItemAutoProcessRedis{
             for (ZSetOperations.TypedTuple<String> itemSerialNo : itemSerialNos) {
                 log.info("诉求" + itemSerialNo.getValue() + "开始处理");
                 try{
-                    itemService.itemClosed(itemSerialNo.getValue());
+                    List<String> list = Arrays.asList(Objects.requireNonNull(itemSerialNo.getValue()).split(":"));
+                    String id = list.get(0);
+                    String type = null;
+                    if (list.size() > 1) {
+                        type = list.get(1);
+                    }
+                    itemService.itemClosed(id, type);
                 }
                 catch(Exception ex){
                     ex.printStackTrace();

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

@@ -742,7 +742,7 @@ public interface ItemService extends BaseService<ItemEntity> {
     /**
      * 定时任务：是否可以结案处理
      */
-    void itemClosed(String itemId);
+    void itemClosed(String itemId, String type);
 
     /**
      * 诉求初验

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

@@ -4468,7 +4468,7 @@ public class ItemServiceImpl extends BaseServiceImpl<ItemDao, ItemEntity> implem
      * 定时任务：是否可以结案处理
      */
     @Override
-    public void itemClosed(String itemId) {
+    public void itemClosed(String itemId, String type) {
         logger.info("开始执行结案操作,项目Id->"+itemId);
         //1.获取项目基础数据
         ItemEntity entity = baseDao.selectById(itemId);