保存代码优化

amos-boot-system-tzs/amos-boot-module-tzspatrol/amos-boot-module-tzspatrol-api/src/main/java/com/yeejoin/amos/patrol/core/common/request/MyIdGeneratorConfig.java

@@ -43,7 +43,7 @@ public class MyIdGeneratorConfig implements IdentifierGenerator {
     }
 
     public synchronized long snowflakeId(long workerId, long datacenterId) {
-        Snowflake snowflake = IdUtil.createSnowflake(workerId, datacenterId);
+        Snowflake snowflake = IdUtil.getSnowflake(workerId, datacenterId);
         return snowflake.nextId();
     }
 

amos-boot-system-tzs/amos-boot-module-tzspatrol/amos-boot-module-tzspatrol-biz/src/main/java/com/yeejoin/amos/patrol/business/service/impl/PlanTaskServiceImpl.java

@@ -16,9 +16,7 @@ import com.yeejoin.amos.feign.privilege.model.AgencyUserModel;
 import com.yeejoin.amos.feign.privilege.model.DepartmentModel;
 import com.yeejoin.amos.feign.systemctl.Systemctl;
 import com.yeejoin.amos.patrol.business.constants.XJConstant;
-import com.yeejoin.amos.patrol.business.dao.mapper.PlanMapper;
-import com.yeejoin.amos.patrol.business.dao.mapper.PlanTaskDetailMapper;
-import com.yeejoin.amos.patrol.business.dao.mapper.PlanTaskMapper;
+import com.yeejoin.amos.patrol.business.dao.mapper.*;
 import com.yeejoin.amos.patrol.business.dao.repository.*;
 import com.yeejoin.amos.patrol.business.dto.MsgRo;
 import com.yeejoin.amos.patrol.business.dto.UserDetailsDto;
@@ -110,6 +108,9 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
     IRoutePointDao iRoutePointDao;
 
     @Autowired
+    MybatisService mybatisService;
+
+    @Autowired
     IRouteDao routeDao;
 
     @Autowired
@@ -145,6 +146,7 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
     @Autowired
     private ICheckShotDao iCheckShotDao;
 
+
     @Autowired
     private RepositoryTs repositoryTs;
 
@@ -663,7 +665,6 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
         List<Long> ids = planTaskMapper.getGenPlanTask(param);
         for (long id : ids) {
             iplanTaskDao.deleteById(id);
-            ;
         }
 
     }
@@ -813,11 +814,8 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
                 // 发送APP待办消息       (20220617  改为定时任务发送消息)
 //                sendMessage(plan, planTask);
                 String executorId = planTask.getUserId();
-
                 em.persist(planTask);
-                em.flush();
-                em.clear();
-                
+
                 for (int i1 = 0; i1 < pointIdList.size(); i1++) {
                     Number pointId = pointIdList.get(i1);
                     PlanTaskDetail planTaskDetailInstance = new PlanTaskDetail();
@@ -837,8 +835,12 @@ public class PlanTaskServiceImpl implements IPlanTaskService {
                     planTaskDetailListSync.add(planTaskDetailInstance);
                 }
             }
+            em.flush();
+            em.clear();
+         //   mybatisService.saveBatch(taskList);
+
 //            repositoryTs.batchSave(taskList);
-            repositoryTs.batchSave(planTaskDetailListSync);
+             repositoryTs.batchSave(planTaskDetailListSync);
             // 定时任务监控
             log.error("计划重做开始添加定时任务监控========");
             jobService.planTaskAddJob(planTask);

amos-boot-system-tzs/amos-boot-module-tzspatrol/amos-boot-module-tzspatrol-biz/src/main/java/com/yeejoin/amos/patrol/business/service/impl/RepositoryTImpl.java

@@ -12,7 +12,7 @@ import java.util.Iterator;
 @Service
 public class RepositoryTImpl implements RepositoryTs {
 
-    private static final int BATCH_SIZE = 1 ;
+    private static final int BATCH_SIZE = 1000 ;
 
     @PersistenceContext
     private final EntityManager em;
@@ -23,6 +23,7 @@ public class RepositoryTImpl implements RepositoryTs {
 
     @Override
     @Transactional
+    @Async("asyncServiceExecutor")
     public <S> Iterable<S> batchSave(Iterable<S> var1) {
         Iterator<S> iterator = var1.iterator();
         int index = 0;