feat:任务执行分布式

project-dispatch/src/main/java/com/dituhui/pea/dispatch/service/impl/SolveServiceImpl.java

@@ -508,7 +508,7 @@ public class SolveServiceImpl implements SolveService {
 
                 int pathTime = customer.getPathTimeFromPreviousStandstill();
                 long pathDistance = customer.getDistanceFromPreviousStandstill();
-                String sql = "update dispatch_order set engineer_code=?, seq=?, time_begin=? ,time_end=?, path_time=?, path_distance=? " + " where teamId=? and batch_no=? and order_id=? and dt=? and status!='CONFIRM' ";
+                String sql = "update dispatch_order set engineer_code=?, seq=?, time_begin=? ,time_end=?, path_time=?, path_distance=? " + " where team_id=? and batch_no=? and order_id=? and dt=? and status!='CONFIRM' ";
                 Object[] param = {technician.getCode(), idx, arriveTime, leaveTime, pathTime, pathDistance, teamId, batchNo, customer.getCode(), customer.getDt()};
                 int rowUpdated = jdbcTemplate.update(sql, param);
                 log.info("算法结果回写dispatch, step3-逐个客户处理, order_id:{}, engineer_code:{}, seq: {}, begin:{}, end:{} ,rowUpdated:{}", customer.getCode(), technician.getCode(), seq, arriveTime, leaveTime, rowUpdated);

project-dispatch/src/main/resources/application-dev.yaml

@@ -3,7 +3,7 @@ server:
 
 dispatch:
   cron:
-    expr: 0 58 8-18 * * ?
+    expr: 0 20 8-19 * * ?
     next-day-limit: 2
 #    expr: 0 */10 8-18 * * ?
 
@@ -28,9 +28,12 @@ spring:
           enabled: false
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://127.0.0.1:3306/saas_aftersale_test?serverTimezone=Asia/Shanghai
-    username: root
-    password: 123456
+#    url: jdbc:mysql://127.0.0.1:3306/saas_aftersale_test?serverTimezone=Asia/Shanghai
+#    username: root
+#    password: 123456
+    url: jdbc:mysql://localhost:32306/saas_aftersale_test?serverTimezone=Asia/Shanghai
+    username: boxi
+    password: boxi_dev_0725
     type: com.alibaba.druid.pool.DruidDataSource
 
   jpa: