修改批量提交逻辑

bill-manager/src/main/java/com/mortals/xhx/module/ph/web/PhQueueController.java

@@ -111,6 +111,9 @@ public class PhQueueController extends BaseCRUDJsonBodyMappingController<PhQueue
             public void run() {
                 for (PhQueueEntity entity : list) {
                     getSite(entity);
+                    entity.setCreateTime(new Date());
+                    entity.setCreateUserId(1L);
+                    entity.setCreateUserName("admin");
                 }
                 removeDuplicate(list);
 

bill-manager/src/main/java/com/mortals/xhx/module/pj/web/PjEvaluateController.java

@@ -60,6 +60,8 @@ public class PjEvaluateController extends BaseCRUDJsonBodyMappingController<PjEv
 
     @Autowired
     private ICacheService cacheService;
+    @Autowired
+    private PjEvaluateService pjEvaluateService;
 
 
     public PjEvaluateController() {
@@ -85,7 +87,7 @@ public class PjEvaluateController extends BaseCRUDJsonBodyMappingController<PjEv
     @UnAuth
     public String save(@RequestBody PjEvaluateEntity entity) {
         //获取站点信息
-       this.service.getSite(entity);
+        this.service.getSite(entity);
 
         //todo 去重
         if (!ObjectUtils.isEmpty(entity.getExtNum())) {
@@ -108,17 +110,21 @@ public class PjEvaluateController extends BaseCRUDJsonBodyMappingController<PjEv
     public String batchSave(@RequestBody List<PjEvaluateEntity> list) {
 
 
-        BatchSavePjTask batchSavePjTask = new BatchSavePjTask(list);
+/*        BatchSavePjTask batchSavePjTask = new BatchSavePjTask(list);
+
+        ThreadPool.getInstance().execute(batchSavePjTask);*/
 
-        ThreadPool.getInstance().execute(batchSavePjTask);
 
-/*
         Runnable runnable = new Runnable() {
 
             @Override
             public void run() {
                 for (PjEvaluateEntity entity : list) {
                     getSite(entity);
+                    entity.setCreateTime(new Date());
+                    entity.setCreateUserId(1L);
+                    entity.setCreateUserName("admin");
+
                 }
                 removeDuplicate(list);
                 if (ObjectUtils.isEmpty(list)) return;
@@ -126,10 +132,9 @@ public class PjEvaluateController extends BaseCRUDJsonBodyMappingController<PjEv
             }
         };
 
-        ThreadPool.getInstance().execute(runnable);*/
+        ThreadPool.getInstance().execute(runnable);
 
         return JSON.toJSONString(Rest.ok("接收成功"));
-        //  return super.batchSave(list);
     }