Merge branch 'develop' of https://gitlab.dituhui.com/bsh/project/project into develop-16542

# Conflicts:
#	project-order/src/main/java/com/dituhui/pea/order/dto/ScheduleEngineerOverviewResp.java

.gitignore

@@ -11,5 +11,5 @@
 /logs/
 /logs/
 /*/.gitignore
 /*/.gitignore
 dispatchSolution-*.json
 dispatchSolution-*.json
-/project-order/src/main/resources/application-dev.yaml
 *.idea
 *.idea
+*.json

project-dispatch/pom.xml

@@ -46,10 +46,10 @@
             <version>${mysql.version}</version>
             <version>${mysql.version}</version>
         </dependency>
         </dependency>
 
 
-<!--        <dependency>-->
-<!--            <groupId>com.alibaba.cloud</groupId>-->
-<!--            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>-->
-<!--        </dependency>-->
+        <!--        <dependency>-->
+        <!--            <groupId>com.alibaba.cloud</groupId>-->
+        <!--            <artifactId>spring-cloud-starter-alibaba-seata</artifactId>-->
+        <!--        </dependency>-->
 
 
         <dependency>
         <dependency>
             <groupId>com.alibaba.cloud</groupId>
             <groupId>com.alibaba.cloud</groupId>
@@ -141,7 +141,11 @@
             <artifactId>gson</artifactId>
             <artifactId>gson</artifactId>
         </dependency>
         </dependency>
 
 
-
+        <!-- quartz依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-quartz</artifactId>
+        </dependency>
 
 
     </dependencies>
     </dependencies>
     <build>
     <build>

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/DispatchEngineerRepository.java

 package com.dituhui.pea.dispatch.dao;
 package com.dituhui.pea.dispatch.dao;
 
 
 import com.dituhui.pea.dispatch.entity.DispatchEngineer;
 import com.dituhui.pea.dispatch.entity.DispatchEngineer;
+import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.data.repository.CrudRepository;
 
 
 import java.util.List;
 import java.util.List;
 
 
-public interface DispatchEngineerRepository extends CrudRepository<DispatchEngineer, Long> {
+public interface DispatchEngineerRepository extends CrudRepository<DispatchEngineer, Long>, JpaRepository<DispatchEngineer, Long> {
 
 
     List<DispatchEngineer> findByGroupId(String groupId);
     List<DispatchEngineer> findByGroupId(String groupId);
 
 

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/DispatchOrderRepository.java

 package com.dituhui.pea.dispatch.dao;
 package com.dituhui.pea.dispatch.dao;
 
 
 import com.dituhui.pea.dispatch.entity.DispatchOrder;
 import com.dituhui.pea.dispatch.entity.DispatchOrder;
+import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.CrudRepository;
 import org.springframework.data.repository.CrudRepository;
 
 
 import java.util.List;
 import java.util.List;
 import java.util.Optional;
 import java.util.Optional;
 
 
-public interface DispatchOrderRepository extends CrudRepository<DispatchOrder, Long> {
+public interface DispatchOrderRepository extends CrudRepository<DispatchOrder, Long>, JpaRepository<DispatchOrder, Long> {
 
 
 
 
     // 查看未指派非confirm的，供算法计算
     // 查看未指派非confirm的，供算法计算
@@ -31,4 +32,6 @@ public interface DispatchOrderRepository extends CrudRepository<DispatchOrder, L
     List<DispatchOrder> findAllWithoutConfirm2(String teamId, String batchNo);
     List<DispatchOrder> findAllWithoutConfirm2(String teamId, String batchNo);
 
 
     Optional<DispatchOrder> findByGroupIdAndBatchNoAndOrderIdAndDt(String groupId, String batchNo, String orderId, String dt);
     Optional<DispatchOrder> findByGroupIdAndBatchNoAndOrderIdAndDt(String groupId, String batchNo, String orderId, String dt);
+
+    List<DispatchOrder> findByTeamIdAndBatchNo(String teamId, String batchNo);
 }
 }
\ No newline at end of file

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/OrgBranchDao.java

+package com.dituhui.pea.dispatch.dao;
+
+import com.dituhui.pea.dispatch.entity.OrgBranchEntity;
+import org.hibernate.annotations.Where;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+@Where(clause = "status = 1")
+public interface OrgBranchDao  extends JpaRepository<OrgBranchEntity, Integer> {
+
+    List<OrgBranchEntity> findAllByClusterId(String clusterId);
+
+    OrgBranchEntity getByBranchId(String branchId);
+    
+    public List<OrgBranchEntity> findByBranchIdIn(List<String> ids);
+
+    public OrgBranchEntity findByCitycodeListLike(String citycodeList);
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/OrgClusterDao.java

+package com.dituhui.pea.dispatch.dao;
+
+import com.dituhui.pea.dispatch.entity.OrgClusterEntity;
+import org.hibernate.annotations.Where;
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Repository
+@Where(clause = "status = 1")
+public interface OrgClusterDao extends JpaRepository <OrgClusterEntity, Integer> {
+
+    OrgClusterEntity getByClusterId(String clusterId);
+    
+    public List<OrgClusterEntity> findByClusterIdIn(List<String> ids);
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/OrgGroupRepository.java

@@ -12,4 +12,6 @@ import org.springframework.stereotype.Repository;
 @Repository
 @Repository
 public interface OrgGroupRepository extends CrudRepository<OrgGroup, Long> {
 public interface OrgGroupRepository extends CrudRepository<OrgGroup, Long> {
     Optional<OrgGroup> findByGroupId(String groupId);
     Optional<OrgGroup> findByGroupId(String groupId);
+
+    List<OrgGroup> findAllByBranchId(String branchId);
 }
 }

project-dispatch/src/main/java/com/dituhui/pea/dispatch/dao/OrgTeamDao.java

@@ -4,6 +4,7 @@ import java.util.List;
 
 
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.data.jpa.repository.Query;
 import org.springframework.stereotype.Repository;
 import org.springframework.stereotype.Repository;
 
 
 import com.dituhui.pea.dispatch.entity.OrgTeamEntity;
 import com.dituhui.pea.dispatch.entity.OrgTeamEntity;
@@ -17,4 +18,10 @@ public interface OrgTeamDao extends JpaRepository<OrgTeamEntity, Integer>, JpaSp
 
 
     OrgTeamEntity findByTeamId(String teamId);
     OrgTeamEntity findByTeamId(String teamId);
 
 
+    @Query(value = "select t.* from org_team t\n" +
+            "join org_group g on g.group_id=t.group_id and t.`status`=1 and g.`status`=1\n" +
+            "join org_branch b on b.branch_id=g.branch_id and b.`status`=1\n" +
+            "join org_cluster c on c.cluster_id=b.cluster_id and c.`status`=1",
+            nativeQuery = true)
+    List<OrgTeamEntity> findAllTeam();
 }
 }

project-dispatch/src/main/java/com/dituhui/pea/dispatch/entity/OrgBranchEntity.java

+package com.dituhui.pea.dispatch.entity;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.time.LocalDateTime;
+
+@Entity
+@Data
+@Table(name = "org_branch")
+public class OrgBranchEntity {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+
+    private String branchId;
+
+
+    private String branchName;
+
+
+    private String clusterId;
+
+
+    private String address;
+
+
+    private String x;
+
+
+    private String y;
+
+
+    private String citycodeList;
+
+
+    private Integer kind;
+
+
+    private String layerId;
+
+
+    private String memo;
+
+
+    private LocalDateTime createTime = LocalDateTime.now();
+
+
+    private LocalDateTime updateTime = LocalDateTime.now();
+
+    public OrgBranchEntity() {
+    }
+
+    /**
+     * 部门缩写
+     */
+    private String abbreviation;
+    /**
+     * 部门编号
+     */
+    private String code;
+    /**
+     * 部门负责人联系方式
+     */
+    private String phone;
+    /**
+     * 是否启用外围仓 0未启用 1启用
+     */
+    private Integer warehouseEnabled = 0;
+    /**
+     * 最长配件保留时长（天）
+     */
+    private Integer reserveTimeMax = 0;
+    /**
+     * 帐号状态（0无效 1有效）
+     */
+    private Integer status = 1;
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/entity/OrgClusterEntity.java

+package com.dituhui.pea.dispatch.entity;
+
+import lombok.Data;
+
+import javax.persistence.*;
+import java.time.LocalDateTime;
+
+@Entity
+@Data
+@Table(name = "org_cluster")
+public class OrgClusterEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Integer id;
+
+
+    private String clusterId;
+
+
+    private String name;
+
+
+    private String citycodeList;
+
+
+    private String address;
+
+
+    private String cityName;
+
+
+    private Integer status = 1;
+
+
+    private String updateUser;
+
+
+    private LocalDateTime createTime = LocalDateTime.now();
+
+
+    private LocalDateTime updateTime = LocalDateTime.now();
+
+    public OrgClusterEntity() {
+    }
+
+    /**
+     * 部门描述 非必须
+     */
+    private String memo;
+
+    /**
+     * 部门缩写
+     */
+    private String abbreviation;
+    /**
+     * 部门编号
+     */
+    private String code;
+    /**
+     * 部门负责人联系方式
+     */
+    private String phone;
+    /**
+     * 是否启用外围仓 0未启用 1启用
+     */
+    private Integer warehouseEnabled = 0;
+    /**
+     * 最长配件保留时长（天）
+     */
+    private Integer reserveTimeMax = 0;
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/quartz/AutoDispatchJob.java

+package com.dituhui.pea.dispatch.quartz;
+
+import com.dituhui.pea.dispatch.service.SchedulerService;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.quartz.JobKey;
+import org.springframework.scheduling.quartz.QuartzJobBean;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+
+/**
+ * 自动派工任务
+ *
+ * @author RenPing
+ * @date 2023/11/02
+ */
+@Component
+@Slf4j
+public class AutoDispatchJob extends QuartzJobBean {
+
+    public static final String TEAM_JOB_PREFIX="BOXI_TEAM_";
+
+    @Resource
+    private SchedulerService schedulerService;
+
+    @Override
+    protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
+        try {
+            JobKey jobKey = jobExecutionContext.getJobDetail().getKey();
+            String name = jobKey.getName();
+            String teamId = name.substring(TEAM_JOB_PREFIX.length());
+            long start = System.currentTimeMillis();
+            log.info(">>> 自动派工(teamId:{}) 自动任务开始", teamId);
+            schedulerService.dispatchRun2(teamId);
+            long end = System.currentTimeMillis();
+            log.info(">>> 自动派工(teamId:{}) 自动任务结束，耗时：{}", teamId, end - start);
+        } catch (Exception e) {
+            log.error(e.getMessage(), e);
+        }
+    }
+}
\ No newline at end of file

project-dispatch/src/main/java/com/dituhui/pea/dispatch/quartz/MyQuartzJobFactory.java

+package com.dituhui.pea.dispatch.quartz;
+
+import org.quartz.Job;
+import org.quartz.spi.TriggerFiredBundle;
+import org.springframework.beans.BeansException;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.ApplicationContextAware;
+import org.springframework.scheduling.quartz.AdaptableJobFactory;
+import org.springframework.stereotype.Component;
+
+/**
+ * 自定义JobFactory，从Spring容器中拿单例Job
+ *
+ * @author RenPing
+ * @date 2023/11/02
+ */
+@Component
+public class MyQuartzJobFactory extends AdaptableJobFactory implements ApplicationContextAware {
+    private ApplicationContext applicationContext;
+
+    @Override
+    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
+        this.applicationContext = applicationContext;
+    }
+
+    @Override
+    protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
+        Job job = applicationContext.getBean(bundle.getJobDetail().getJobClass());
+        return job;
+    }
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/quartz/QuartzConfig.java

+package com.dituhui.pea.dispatch.quartz;
+
+import org.quartz.spi.JobFactory;
+import org.springframework.boot.autoconfigure.quartz.QuartzProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.quartz.SchedulerFactoryBean;
+
+import javax.annotation.Resource;
+import javax.sql.DataSource;
+import java.io.IOException;
+import java.util.Properties;
+
+@Configuration
+public class QuartzConfig {
+    @Resource
+    private JobFactory jobFactory;
+
+    @Resource
+    private QuartzProperties quartzProperties;
+    @Bean
+    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) throws IOException {
+        SchedulerFactoryBean factory = new SchedulerFactoryBean();
+        factory.setDataSource(dataSource);
+
+        Properties properties = new Properties();
+
+        for (String key : quartzProperties.getProperties().keySet()) {
+            properties.put(key, quartzProperties.getProperties().get(key));
+        }
+        factory.setQuartzProperties(properties);
+        factory.setJobFactory(jobFactory);
+        return factory;
+    }
+}

project-dispatch/src/main/java/com/dituhui/pea/dispatch/quartz/QuartzTaskListener.java

+package com.dituhui.pea.dispatch.quartz;
+
+import cn.hutool.core.collection.CollectionUtil;
+import com.dituhui.pea.dispatch.dao.OrgTeamDao;
+import com.dituhui.pea.dispatch.entity.OrgTeamEntity;
+import lombok.extern.slf4j.Slf4j;
+import org.quartz.*;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.event.ApplicationStartedEvent;
+import org.springframework.context.ApplicationListener;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * 手动触发定时任务
+ *
+ * @author RenPing
+ * @date 2023/11/01
+ */
+@Component
+@Slf4j
+public class QuartzTaskListener implements ApplicationListener<ApplicationStartedEvent> {
+
+    @Resource
+    private Scheduler scheduler;
+
+    @Resource
+    private OrgTeamDao orgTeamDao;
+
+    @Value("${dispatch.cron.expr}")
+    private String dispatchCron;
+
+    @Override
+    public void onApplicationEvent(ApplicationStartedEvent applicationStartedEvent) {
+
+        List<OrgTeamEntity> teamList = orgTeamDao.findAllTeam();
+        teamList.forEach(orgTeamEntity -> {
+            String jobName = AutoDispatchJob.TEAM_JOB_PREFIX + orgTeamEntity.getTeamId();
+            JobDetail jobDetail = JobBuilder.newJob(AutoDispatchJob.class)
+                    .withIdentity(jobName, jobName)
+                    .storeDurably()
+                    .build();
+            Trigger trigger = TriggerBuilder.newTrigger()
+                    .forJob(jobDetail)
+                    .withIdentity(jobName, jobName)
+                    .startNow()
+                    .withSchedule(CronScheduleBuilder.cronSchedule(dispatchCron))
+                    .build();
+
+            try {
+                scheduler.scheduleJob(jobDetail, CollectionUtil.newHashSet(trigger), true);
+            } catch (SchedulerException e) {
+                //log.error(e.getMessage(), e);
+            }
+        });
+
+    }
+}
\ No newline at end of file

project-dispatch/src/main/java/com/dituhui/pea/dispatch/scheduler/BatchScheduler.java

@@ -26,7 +26,7 @@ import com.dituhui.pea.dispatch.utils.DispatchSolutionUtils;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 
 
 @Slf4j
 @Slf4j
-@Component
+//@Component
 public class BatchScheduler {
 public class BatchScheduler {
 
 
     @Value("${dispatch.cron.next-day-limit}")
     @Value("${dispatch.cron.next-day-limit}")
@@ -55,7 +55,7 @@ public class BatchScheduler {
 	/*
 	/*
 	 * 异步执行任务开始
 	 * 异步执行任务开始
 	 */
 	 */
-	@Scheduled(cron = "${dispatch.cron.expr}")
+	//@Scheduled(cron = "${dispatch.cron.expr}")
 	public void dispatchRun2() {
 	public void dispatchRun2() {
 		String groupId = "gsuzhou";
 		String groupId = "gsuzhou";
 		log.info("dispatchRun group:{}", groupId);
 		log.info("dispatchRun group:{}", groupId);
@@ -83,12 +83,12 @@ public class BatchScheduler {
                 DispatchSolution solution = solver.solve(problem);
                 DispatchSolution solution = solver.solve(problem);
                 DispatchSolutionUtils.removeHardConstraintCustomer(solution, solverFactory);
                 DispatchSolutionUtils.removeHardConstraintCustomer(solution, solverFactory);
                 log.info("dispatchRun solve done, teamId:{}, day:{}, batch:{}, problemId:{}, score:{}", teamId, currDay, batchNo, problemId, solution.getScore().toShortString());
                 log.info("dispatchRun solve done, teamId:{}, day:{}, batch:{}, problemId:{}, score:{}", teamId, currDay, batchNo, problemId, solution.getScore().toShortString());
-                this.solveService.saveSolutionWrp(solution);
+                this.solveService.saveSolutionWrp2(solution);
                 this.extractService.extractDispatchToOrder2(teamId, batchNo, false);
                 this.extractService.extractDispatchToOrder2(teamId, batchNo, false);
                 log.info("dispatchRun done ------ teamId:{}, day:{}", teamId, currDay);
                 log.info("dispatchRun done ------ teamId:{}, day:{}", teamId, currDay);
 
 
                 JacksonSolutionFileIO<DispatchSolution> exporter = new JacksonSolutionFileIO<DispatchSolution>(DispatchSolution.class);
                 JacksonSolutionFileIO<DispatchSolution> exporter = new JacksonSolutionFileIO<DispatchSolution>(DispatchSolution.class);
-                exporter.write(solution, new File(String.format("dispatchSolution_%s_%s.json",groupId, currDay)));
+                exporter.write(solution, new File(String.format("dispatchSolution_%s_%s.json",teamId, currDay)));
 			}
 			}
 		}
 		}
 
 

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

+package com.dituhui.pea.dispatch.service;
+
+public interface SchedulerService {
+
+    /**
+     * 以工作队为批次
+     *
+     * @param teamId  工作队 ID
+     * @author RenPing
+     * @date 2023/11/02
+     */
+    void dispatchRun2(String teamId);
+}

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

@@ -35,6 +35,13 @@ public interface SolveService {
     void saveSolutionWrp(DispatchSolution solution) throws RuntimeException;
     void saveSolutionWrp(DispatchSolution solution) throws RuntimeException;
 
 
 
 
+    /*
+     * 将计算结果回写到dispatch2个表
+     * 是下面两个方法的包装
+     * */
+    void saveSolutionWrp2(DispatchSolution solution) throws RuntimeException;
+
+
 
 
 
 
 }
 }

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

@@ -5,10 +5,16 @@ import java.time.LocalDateTime;
 import java.time.LocalTime;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.time.format.DateTimeFormatter;
 import java.util.List;
 import java.util.List;
+import java.util.Map;
 import java.util.Optional;
 import java.util.Optional;
 
 
 import javax.persistence.EntityManager;
 import javax.persistence.EntityManager;
 
 
+import com.alibaba.fastjson.JSONObject;
+import com.dituhui.pea.dispatch.dao.DispatchEngineerRepository;
+import com.dituhui.pea.dispatch.dao.DispatchOrderRepository;
+import com.dituhui.pea.dispatch.entity.DispatchEngineer;
+import com.dituhui.pea.dispatch.entity.DispatchOrder;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
@@ -38,6 +44,12 @@ public class BatchServiceImpl implements BatchService {
     DispatchBatchRepository batchRepository;
     DispatchBatchRepository batchRepository;
 
 
     @Autowired
     @Autowired
+    DispatchOrderRepository dispatchOrderRepository;
+
+    @Autowired
+    DispatchEngineerRepository dispatchEngineerRepository;
+
+    @Autowired
     OrderInfoRepository orderInfoRepository;
     OrderInfoRepository orderInfoRepository;
 
 
     @Autowired
     @Autowired
@@ -181,7 +193,7 @@ public class BatchServiceImpl implements BatchService {
     }
     }
 
 
     // 检查给定小队、日期是否有在运行的批次任务，没则返回，没有则创建
     // 检查给定小队、日期是否有在运行的批次任务，没则返回，没有则创建
-    @Transactional(isolation = Isolation.READ_COMMITTED)
+    @Transactional(isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)
     @Override
     @Override
     public String buildBatchData2(String teamId, String day) {
     public String buildBatchData2(String teamId, String day) {
         entityManager.clear();
         entityManager.clear();
@@ -206,8 +218,12 @@ public class BatchServiceImpl implements BatchService {
         }
         }
 
 
         log.info("清理原批次数据, teamId:{}, day:{}, batchNo:{}", teamId, batchDay, batchNo);
         log.info("清理原批次数据, teamId:{}, day:{}, batchNo:{}", teamId, batchDay, batchNo);
+        //并发出现死锁
         jdbcTemplate.update("delete from dispatch_engineer where team_id=? and batch_no=?", teamId, batchNo);
         jdbcTemplate.update("delete from dispatch_engineer where team_id=? and batch_no=?", teamId, batchNo);
+        //dispatchEngineerRepository.deleteAllInBatch(dispatchEngineerRepository.findByTeamIdAndBatchNo(teamId,batchNo));
+        //并发出现死锁
         jdbcTemplate.update("delete from dispatch_order where team_id=? and batch_no=?", teamId, batchNo);
         jdbcTemplate.update("delete from dispatch_order where team_id=? and batch_no=?", teamId, batchNo);
+        //dispatchOrderRepository.deleteAllInBatch(dispatchOrderRepository.findByTeamIdAndBatchNo(teamId,batchNo));
 
 
         log.info("写入新批次技术员、工单数据,  teamId:{}, day:{}, batchNo:{}", teamId, batchDay, batchNo);
         log.info("写入新批次技术员、工单数据,  teamId:{}, day:{}, batchNo:{}", teamId, batchDay, batchNo);
 		String sqlEngineer = "INSERT INTO dispatch_engineer (team_id,  batch_no, engineer_code, engineer_name,  x, y, max_num, max_minute, max_distance, vehicle_type)\n"
 		String sqlEngineer = "INSERT INTO dispatch_engineer (team_id,  batch_no, engineer_code, engineer_name,  x, y, max_num, max_minute, max_distance, vehicle_type)\n"

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

+package com.dituhui.pea.dispatch.service.impl;
+
+import com.dituhui.pea.dispatch.dao.OrgTeamDao;
+import com.dituhui.pea.dispatch.entity.OrgTeamEntity;
+import com.dituhui.pea.dispatch.pojo.DispatchSolution;
+import com.dituhui.pea.dispatch.service.BatchService;
+import com.dituhui.pea.dispatch.service.ExtractService;
+import com.dituhui.pea.dispatch.service.SchedulerService;
+import com.dituhui.pea.dispatch.service.SolveService;
+import com.dituhui.pea.dispatch.utils.DispatchSolutionUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.optaplanner.core.api.solver.Solver;
+import org.optaplanner.core.impl.solver.DefaultSolverFactory;
+import org.optaplanner.persistence.jackson.impl.domain.solution.JacksonSolutionFileIO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Isolation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.io.File;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+import java.util.UUID;
+
+/**
+ * 自动排班算法
+ *
+ * @author RenPing
+ * @date 2023/11/02
+ */
+@Service
+@Slf4j
+public class SchedulerServiceImpl implements SchedulerService {
+
+    @Value("${dispatch.cron.next-day-limit}")
+    int nextDaysLimit = 2;
+
+    @Autowired
+    BatchService batchService;
+
+    @Autowired
+    SolveService solveService;
+
+    @Autowired
+    ExtractService extractService;
+
+    @Autowired
+    OrgTeamDao orgTeamDao;
+
+    private DefaultSolverFactory<DispatchSolution> solverFactory;
+    private Solver<DispatchSolution> solver;
+
+    public SchedulerServiceImpl() {
+        solverFactory = DispatchSolutionUtils.getSolverFactory(30, 60 * 5);
+        solver = solverFactory.buildSolver();
+    }
+
+    @Override
+    @Transactional(isolation = Isolation.READ_COMMITTED, rollbackFor = Exception.class)
+    public void dispatchRun2(String teamId) {
+        OrgTeamEntity orgTeamEntity = orgTeamDao.findByTeamId(teamId);
+        String groupId = orgTeamEntity.getGroupId();
+        log.info("dispatchRun group:{}, team:{} done", groupId, teamId);
+
+        try {
+            for (int i = 1; i <= nextDaysLimit; i++) {
+                String currDay = LocalDate.now().plusDays(i).format(DateTimeFormatter.ISO_LOCAL_DATE);
+                log.info("dispatchRun begin----- teamId:{}, day:{}", teamId, currDay);
+
+                String batchNo = batchService.buildBatchData2(teamId, currDay);
+                UUID problemId = solveService.generateProblemId(teamId, batchNo);
+                log.info("dispatchRun teamId:{}, day:{}, batch:{}, problemId:{}", teamId, currDay, batchNo, problemId);
+
+                DispatchSolution problem = solveService.prepareSolution2(teamId, batchNo);
+
+                if (problem.getCustomerList().size() <= 0) {
+                    log.info("dispatchRun 当前批次没有待指派工单 , teamId:{}, day:{}, batch:{}, problemId:{}, order-size:{}", teamId, currDay, batchNo, problemId, problem.getCustomerList().size());
+                    continue;
+                }
+                log.info("dispatchRun prepare done, teamId:{}, day:{}, batch:{}, problemId:{}", teamId, currDay, batchNo, problemId);
+                DispatchSolution solution = solver.solve(problem);
+                DispatchSolutionUtils.removeHardConstraintCustomer(solution, solverFactory);
+                log.info("dispatchRun solve done, teamId:{}, day:{}, batch:{}, problemId:{}, score:{}", teamId, currDay, batchNo, problemId, solution.getScore().toShortString());
+                this.solveService.saveSolutionWrp2(solution);
+                this.extractService.extractDispatchToOrder2(teamId, batchNo, false);
+                log.info("dispatchRun done ------ teamId:{}, day:{}", teamId, currDay);
+
+                JacksonSolutionFileIO<DispatchSolution> exporter = new JacksonSolutionFileIO<DispatchSolution>(DispatchSolution.class);
+                exporter.write(solution, new File(String.format("dispatchSolution_%s_%s.json", teamId, currDay)));
+
+                //log.info("dispatchRun group:{}, team:{} done", groupId, teamId);
+            }
+        } catch (Exception e) {
+            log.error(">>> (teamId:{})自动排班失败：{}", teamId, e.getMessage(), e);
+            throw e;
+        }
+    }
+}
\ No newline at end of file

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

@@ -390,6 +390,35 @@ public class SolveServiceImpl implements SolveService {
 
 
     }
     }
 
 
+    @Transactional(isolation = Isolation.READ_COMMITTED)
+    @Override
+    public void saveSolutionWrp2(DispatchSolution solution) throws RuntimeException {
+        String teamId = solution.getTeamId();
+        String batchNo = solution.getBatchNo();
+        log.info("算法结果回写包装方法, teamId:{}, batchNo:{}", teamId, batchNo);
+
+
+        JacksonSolutionFileIO<DispatchSolution> exporter = new JacksonSolutionFileIO<DispatchSolution>(DispatchSolution.class);
+        String fileName = String.format("dispatchSolution-%s-%s.json", teamId, batchNo);
+        File tempFile = new File(fileName);
+        exporter.write(solution, tempFile);
+        String dispatchResultJson = "{}";
+       /*
+       try {
+            dispatchResultJson = FileUtil.readAsString(tempFile);
+        } catch (IOException e) {
+            log.error("json算法结果回写 error , teamId:{}, batchNo:{} ", teamId, batchNo, e);
+        }
+        */
+
+        Object[] paramBatch = {LocalDateTime.now(), dispatchResultJson, teamId, batchNo};
+        jdbcTemplate.update(" update dispatch_batch set status='DONE', end_time=? , ext=?  where team_id=? and batch_no=? ", paramBatch);
+
+
+        saveSolutionToDispatch2(teamId, batchNo, solution);
+
+    }
+
 
 
     /**
     /**
      * 将计算结果回写到dispatch_order表（更新补充技术员工号、上门时间）
      * 将计算结果回写到dispatch_order表（更新补充技术员工号、上门时间）
@@ -442,4 +471,55 @@ public class SolveServiceImpl implements SolveService {
 
 
     }
     }
 
 
+    /**
+     * 将计算结果回写到dispatch_order表（更新补充技术员工号、上门时间）
+     */
+
+    void saveSolutionToDispatch2(String teamId, String batchNo, DispatchSolution solution) throws RuntimeException {
+        log.info("算法结果回写dispatch, teamId:{}, batchNo:{}", teamId, batchNo);
+        // 清理当前批次指派结果
+        entityManager.clear();
+
+        log.info("算法结果回写dispatch, step1-清除历史, groupId:{}, batchNo:{}", teamId, batchNo);
+        Object[] paramClear = {teamId, batchNo};
+        String sqlReset = "update dispatch_order set engineer_code='', seq=0, time_begin=null, time_end=null, path_time=0, path_distance=0 " + "where team_id=? and batch_no=? and status!='CONFIRM' ";
+        jdbcTemplate.update(sqlReset, paramClear);
+
+        log.info("算法结果回写dispatch, step2-开始回写, teamId:{}, batchNo:{}", teamId, batchNo);
+        // 保存当前批次指派结果
+        solution.getTechnicianList().forEach(technician -> {
+            log.info("算法结果回写dispatch, step2.1-按技术员逐个回写, teamId:{}, batchNo:{}, technician: {}, max-minute:{}, customlist.size:{}", teamId, batchNo, technician.getCode(), technician.getMaxMinute(), technician.getCustomerList().size());
+
+            AtomicInteger seq = new AtomicInteger();
+            technician.getCustomerList().forEach(customer -> {
+                int idx = seq.getAndIncrement();
+
+                // 时间相加操作
+                //   LocalDateTime localExpectBegin = LocalDateTime.ofInstant(expectBegin[0].toInstant(), ZoneId.systemDefault());
+                //   LocalDateTime localEndTime = localExpectBegin.plusMinutes(dOrder.getTakeTime());
+                //   Date end = Date.from(localEndTime.atZone(ZoneId.systemDefault()).toInstant());
+
+                log.info("算法结果回写dispatch, step3-逐个客户处理, teamId:{}, batchNo:{}, employ: {}, customer:{}, service-duration:{} ", teamId, batchNo, technician.getCode(), customer.getCode(), customer.getServiceDuration());
+                log.info(customer.toString());
+                LocalDateTime customDateTime = LocalDateTime.parse(customer.getDt()+" 00:00:00", DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss"));
+                LocalDateTime arriveTime = customDateTime.plusMinutes(customer.getArrivalTime());
+                LocalDateTime leaveTime = customDateTime.plusMinutes(customer.getDepartureTime());
+
+
+                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 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);
+
+            });
+
+        });
+
+
+        log.info("算法结果回写dispatch完成, teamId:{}, batchNo:{}", teamId, batchNo);
+
+    }
+
 }
 }

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

@@ -3,7 +3,7 @@ server:
 
 
 dispatch:
 dispatch:
   cron:
   cron:
-    expr: 0 43 8-18 * * ?
+    expr: 0 26 8-19 * * ?
     next-day-limit: 2
     next-day-limit: 2
 #    expr: 0 */10 8-18 * * ?
 #    expr: 0 */10 8-18 * * ?
 
 
@@ -28,9 +28,12 @@ spring:
           enabled: false
           enabled: false
   datasource:
   datasource:
     driver-class-name: com.mysql.cj.jdbc.Driver
     driver-class-name: com.mysql.cj.jdbc.Driver
-    url: jdbc:mysql://127.0.0.1:3388/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
     type: com.alibaba.druid.pool.DruidDataSource
 
 
   jpa:
   jpa:

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

@@ -32,10 +32,48 @@ spring:
     password: boxi_dev_0725
     password: boxi_dev_0725
     type: com.alibaba.druid.pool.DruidDataSource
     type: com.alibaba.druid.pool.DruidDataSource
 
 
-  jpa:
-    show-sql: false
-    hibernate:
-      ddl-auto: none
+  # quartz 配置
+  quartz:
+    # 应用关闭时，是否等待定时任务执行完成。默认为 false，建议设置为 true
+    wait-for-jobs-to-complete-on-shutdown: true
+    # 是否覆盖已有 Job 的配置，注意为false时，修改已存在的任务调度cron，周期不生效
+    overwrite-existing-jobs: true
+    #相关属性配置
+    properties:
+      org:
+        quartz:
+          scheduler:
+            #调度标识名 集群中每一个实例都必须使用相同的名称
+            instanceName: Scheduler
+            #ID设置为自动获取 每一个必须不同
+            instanceId: AUTO
+            makeSchedulerThreadDaemon: false
+          jobStore:
+            #class: org.quartz.impl.jdbcjobstore.JobStoreTX
+            #spring-boot-starter-quartz V2.5.7及以上
+            class: org.springframework.scheduling.quartz.LocalDataSourceJobStore
+            driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
+            #表的前缀，默认QRTZ_
+            tablePrefix: QRTZ_
+            #是否加入集群
+            isClustered: true
+            #调度实例失效的检查时间间隔
+            clusterCheckinInterval: 10000
+            useProperties: false
+          threadPool:
+            class: org.quartz.simpl.SimpleThreadPool
+            # 指定在线程池里面创建的线程是否是守护线程
+            makeThreadsDaemons: false
+            #指定线程数，至少为1(无默认值，一般设置为1-100)
+            threadCount: 5
+            #设置线程的优先级（最大为java.lang.Thread.MAX_PRIORITY 10，最小为Thread.MIN_PRIORITY 1，默认为5）
+            threadPriority: 5
+            threadsInheritContextClassLoaderOfInitializingThread: true
+    #数据库方式
+    job-store-type: jdbc
+    #初始化表结构，初始化：always，再次重启改为 embedded
+    jdbc:
+      initialize-schema: embedded
 
 
 seata:
 seata:
   application-id: ${spring.application.name}
   application-id: ${spring.application.name}

project-dispatch/src/main/resources/logback-spring.xml

+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--该日志将日志级别不同的log信息保存到不同的文件中 -->
+<configuration>
+    <include resource="org/springframework/boot/logging/logback/defaults.xml"/>
+
+    <springProperty name="LOG_MAXFILESIZE" scope="context" source="logback.filesize" defaultValue="100MB"/>
+    <springProperty name="LOG_FILEMAXDAY" scope="context" source="logback.filemaxday" defaultValue="30"/>
+    <springProperty name="spring.application.name" scope="context" source="spring.application.name" defaultValue="spring-boot-fusion"/>
+
+    <!-- 日志在工程中的输出位置 -->
+    <property name="LOG_FILE" value="logs/${spring.application.name:-}"/>
+
+    <!-- 控制台的日志输出样式 -->
+    <property name="CONSOLE_LOG_PATTERN"
+              value="%clr(%d{yyyy-MM-dd HH:mm:ss.SSS}){faint} %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}}"/>
+    <!--日志文件输出格式-->
+    <property name="FILE_LOG_PATTERN"
+              value="%d{yyyy-MM-dd HH:mm:ss} %-5level ${spring.application.name:-} %thread %logger %msg%n"/>
+    <!-- 控制台输出 -->
+    <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
+        <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
+            <level>INFO</level>
+        </filter>
+        <!-- 日志输出编码 -->
+        <encoder>
+            <pattern>${CONSOLE_LOG_PATTERN}</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+    </appender>
+
+    <!-- 按照每天生成常规日志文件 -->
+    <appender name="FileAppender" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_FILE}/info/${spring.application.name:-}.log</file>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${FILE_LOG_PATTERN}</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <!-- 基于时间的分包策略 -->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_FILE}/info/${spring.application.name:-}.%d{yyyy-MM-dd}.%i.log</fileNamePattern>
+            <!--保留时间,单位:天-->
+            <maxHistory>${LOG_FILEMAXDAY}</maxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>${LOG_MAXFILESIZE}</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>INFO</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+    </appender>
+
+    <!-- 异常文件输出设置，将异常堆栈另外保存一份到单独的文件中，方便查找 -->
+    <appender name="FILE_ERROR"
+              class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <File>${LOG_FILE}/error/${spring.application.name:-}.error.log</File>
+        <rollingPolicy
+                class="ch.qos.logback.core.rolling.SizeAndTimeBasedRollingPolicy">
+            <FileNamePattern>${LOG_FILE}/error/${spring.application.name:-}.error-%d{yyyy-MM-dd}-%i.zip
+            </FileNamePattern>
+            <maxFileSize>${LOG_MAXFILESIZE}</maxFileSize>
+            <maxHistory>${LOG_FILEMAXDAY}</maxHistory>
+            <totalSizeCap>500MB</totalSizeCap>
+        </rollingPolicy>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level - %msg%n</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter"><!-- 只打印错误日志 -->
+            <level>ERROR</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter"><!-- 只打印警告日志 -->
+            <level>WARN</level>
+            <onMatch>ACCEPT</onMatch>
+            <onMismatch>DENY</onMismatch>
+        </filter>
+    </appender>
+
+    <appender name="FILE_DEBUG" class="ch.qos.logback.core.rolling.RollingFileAppender">
+        <file>${LOG_FILE}/debug/${spring.application.name:-}.log</file>
+        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
+            <pattern>${FILE_LOG_PATTERN}</pattern>
+            <charset>UTF-8</charset>
+        </encoder>
+        <!-- 基于时间的分包策略 -->
+        <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
+            <fileNamePattern>${LOG_FILE}/debug/${spring.application.name:-}.%d{yyyy-MM-dd}.%i.log</fileNamePattern>
+            <!--保留时间,单位:天-->
+            <maxHistory>${LOG_FILEMAXDAY}</maxHistory>
+            <timeBasedFileNamingAndTriggeringPolicy class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
+                <maxFileSize>${LOG_MAXFILESIZE}</maxFileSize>
+            </timeBasedFileNamingAndTriggeringPolicy>
+        </rollingPolicy>
+        <filter class="ch.qos.logback.classic.filter.LevelFilter">
+            <level>DEBUG</level>
+        </filter>
+    </appender>
+
+    <!-- 异步输出 -->
+    <appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender">
+        <!-- 0-不丢失日志.默认的,如果队列的80%已满,则会丢弃TRACT、DEBUG、INFO级别的日志 -->
+        <discardingThreshold>0</discardingThreshold>
+        <!-- 更改默认的队列的深度,该值会影响性能.默认值为256 -->
+        <queueSize>256</queueSize>
+        <!-- 添加附加的appender,最多只能添加一个 -->
+        <appender-ref ref="FileAppender"/>
+    </appender>
+
+    <logger name="org.optaplanner" level="info"/>
+
+    <!-- 日志输出级别 -->
+    <root level="debug">
+        <appender-ref ref="console"/>
+        <appender-ref ref="FileAppender"/>
+        <appender-ref ref="FILE_ERROR"/>
+        <appender-ref ref="FILE_DEBUG"/>
+    </root>
+
+</configuration>
\ No newline at end of file

project-order/src/main/java/com/dituhui/pea/order/controller/ScheduleController.java

@@ -46,11 +46,14 @@ public class ScheduleController {
     }
     }
 
 
     @GetMapping("/schedule/engineer/overview")
     @GetMapping("/schedule/engineer/overview")
-	public Result<?> getScheduleEngineerOverview(@RequestParam String date, @RequestParam String engineerCode) {
+    public Result<?> getScheduleEngineerOverview(@RequestParam String date,
+                                                 @RequestParam String engineerCode,
+                                                 @RequestParam(required = false) String sort,
+                                                 @RequestParam(required = false) String sortType) {
         Result<?> res = null;
         Result<?> res = null;
         LocalDate localDate = TimeUtils.IsoDate2LocalDate(date);
         LocalDate localDate = TimeUtils.IsoDate2LocalDate(date);
         try {
         try {
-			res = scheduleService.getScheduleEngineerOverview(localDate, engineerCode);
+            res = scheduleService.getScheduleEngineerOverview(localDate, engineerCode, sort, sortType);
         } catch (BusinessException e) {
         } catch (BusinessException e) {
             return Result.failed(e.getMessage());
             return Result.failed(e.getMessage());
         }
         }

project-order/src/main/java/com/dituhui/pea/order/dao/OrderInfoDao.java

 package com.dituhui.pea.order.dao;
 package com.dituhui.pea.order.dao;
 
 
 import com.dituhui.pea.order.entity.OrderInfoEntity;
 import com.dituhui.pea.order.entity.OrderInfoEntity;
+import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.jpa.repository.Query;
@@ -26,7 +27,7 @@ public interface OrderInfoDao extends JpaRepository<OrderInfoEntity, Long>, JpaS
 
 
     List<OrderInfoEntity> findAllByDtAndOrderIdIn(LocalDate dt, List<String> orderIds);
     List<OrderInfoEntity> findAllByDtAndOrderIdIn(LocalDate dt, List<String> orderIds);
 
 
-    List<OrderInfoEntity> findByEngineerCodeAndDtAndAppointmentStatusIn(String engineerCode, LocalDate dt, List<String> appointmentStatus);
+    List<OrderInfoEntity> findByEngineerCodeAndDtAndAppointmentStatusIn(String engineerCode, LocalDate dt, List<String> appointmentStatus, Sort sort);
 
 
     List<OrderInfoEntity> findByDtAndOrgTeamIdAndAppointmentStatusIn(LocalDate dt, String orgTeamId, List<String> appointmentStatus);
     List<OrderInfoEntity> findByDtAndOrgTeamIdAndAppointmentStatusIn(LocalDate dt, String orgTeamId, List<String> appointmentStatus);
 
 

project-order/src/main/java/com/dituhui/pea/order/dto/ScheduleEngineerOverviewDynamics.java

+package com.dituhui.pea.order.dto;
+
+import lombok.Data;
+
+@Data
+public class ScheduleEngineerOverviewDynamics {
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 工程师工号
+     */
+    private String engineerCode;
+
+    /**
+     * 手机号码
+     */
+    private String phone;
+
+    /**
+     * 职级，c2，c1...
+     */
+    private String grade;
+
+    /**
+     * 日期
+     */
+    private String date;
+
+    /**
+     * 状态
+     */
+    private String status;
+
+    /**
+     * 总单数
+     */
+    private Integer orderCount;
+
+    /**
+     * 待服务数量
+     */
+    private Integer toServiceCount;
+
+    /**
+     * 服务中数量
+     */
+    private Integer inServiceCount;
+
+    /**
+     * 已完成数量
+     */
+    private Integer finishedCount;
+
+    /**
+     * 已取消数量
+     */
+    private Integer canceledCount;
+
+    /**
+     * 已改约数量
+     */
+    private Integer rescheduledCount;
+
+    /**
+     * 在途总耗时
+     */
+    private String roadTotalElapsedTime;
+
+    /**
+     * 在途里程数
+     */
+    private String roadTotalDistance;
+
+    /**
+     * 工作时间
+     */
+    private String workTime;
+
+    /**
+     * 交通工具
+     */
+    private String vehicleName;
+}

project-order/src/main/java/com/dituhui/pea/order/dto/ScheduleEngineerOverviewResp.java

@@ -6,19 +6,12 @@ import java.util.List;
 
 
 @Data
 @Data
 public class ScheduleEngineerOverviewResp {
 public class ScheduleEngineerOverviewResp {
-    private String title;
+	//private String title;
 	private String engineerCode;
 	private String engineerCode;
 	private String startTime;
 	private String startTime;
 	private String endTime;
 	private String endTime;
-    /**
-     * 手机号
-     */
-    private String phoneNumber;
-    /**
-     * 技能等级
-     */
-    private String skillLevel;
-    private List<LabelValueDTO> dynamics;
+	//private List<LabelValueDTO> dynamics;
+	private ScheduleEngineerOverviewDynamics dynamics;
 	private List<TimeLineDTO> orders;
 	private List<TimeLineDTO> orders;
 	private List<Order> orderDetails;
 	private List<Order> orderDetails;
 
 

project-order/src/main/java/com/dituhui/pea/order/enums/VehicleEnum.java

@@ -12,9 +12,9 @@ import java.util.Objects;
  * @date 2023/10/24
  * @date 2023/10/24
  */
  */
 public enum VehicleEnum {
 public enum VehicleEnum {
-    CAR(1, "汽车"),
+    CAR(1, "驾车"),
     ELECTRIC_CAR(2, "电动车"),
     ELECTRIC_CAR(2, "电动车"),
-    BICYCLE(3, "自行车"),
+    BICYCLE(3, "骑行"),
     WALK(4, "步行");
     WALK(4, "步行");
 
 
     private Integer code;
     private Integer code;

project-order/src/main/java/com/dituhui/pea/order/service/ScheduleService.java

@@ -11,5 +11,5 @@ public interface ScheduleService {
 
 
 	Result<?> getScheduleOverview(long page, long size, LocalDate date, String levelType, List<String> levelIds);
 	Result<?> getScheduleOverview(long page, long size, LocalDate date, String levelType, List<String> levelIds);
 
 
-	Result<?> getScheduleEngineerOverview(LocalDate date, String engineerCode);
+	Result<?> getScheduleEngineerOverview(LocalDate date, String engineerCode, String sortColumn, String sortType);
 }
 }

project-order/src/main/java/com/dituhui/pea/order/service/impl/EngineerServiceImpl.java

@@ -242,6 +242,13 @@ public class EngineerServiceImpl implements EngineerService {
         update.where(cb.equal(root.get("engineerCode"), engineerCode));
         update.where(cb.equal(root.get("engineerCode"), engineerCode));
         entityManager.createQuery(update).executeUpdate();
         entityManager.createQuery(update).executeUpdate();
 
 
+        CriteriaBuilder cb2 = entityManager.getCriteriaBuilder();
+        CriteriaUpdate<EngineerInfoEntity> update2 = cb2.createCriteriaUpdate(EngineerInfoEntity.class);
+        Root<EngineerInfoEntity> root2 = update2.from(EngineerInfoEntity.class);
+        update2.set(root2.get("vehicle"), Integer.valueOf(transportMode));
+        update2.where(cb2.equal(root2.get("engineerCode"), engineerCode));
+        entityManager.createQuery(update2).executeUpdate();
+
         return Result.success(null);
         return Result.success(null);
     }
     }
 
 

project-order/src/main/java/com/dituhui/pea/order/service/impl/EngineerTimelineServiceImpl.java

@@ -89,7 +89,7 @@ public class EngineerTimelineServiceImpl implements EngineerTimelineService {
 
 
 	private List<OrderInfoEntity> selectEngineerOrders(String engineerCode, LocalDate dt){
 	private List<OrderInfoEntity> selectEngineerOrders(String engineerCode, LocalDate dt){
 		List<OrderInfoEntity> orders = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
 		List<OrderInfoEntity> orders = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
-				engineerCode, dt, List.of(OrderFlowEnum.PRE.name(), OrderFlowEnum.CONFIRM.name()));
+				engineerCode, dt, List.of(OrderFlowEnum.PRE.name(), OrderFlowEnum.CONFIRM.name()), null);
 		return orders.stream().filter(o -> !o.getOrderStatus().equals("CANCEL")).collect(Collectors.toList());
 		return orders.stream().filter(o -> !o.getOrderStatus().equals("CANCEL")).collect(Collectors.toList());
 	}
 	}
 
 

project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderAssignImpl.java

@@ -111,7 +111,7 @@ public class OrderAssignImpl implements OrderAssign {
 
 
             // 获取已技术员已指派订单列表
             // 获取已技术员已指派订单列表
             List<OrderInfoEntity> orderAppointments = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
             List<OrderInfoEntity> orderAppointments = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
-                    engineer.getEngineerCode(), order.getDt(), List.of(OrderFlowEnum.CONFIRM.name()));
+                    engineer.getEngineerCode(), order.getDt(), List.of(OrderFlowEnum.CONFIRM.name()), null);
 
 
             // 获取订单tips
             // 获取订单tips
             HashMap<String, List<LabelValueDTO>> orderTips = new HashMap<>();
             HashMap<String, List<LabelValueDTO>> orderTips = new HashMap<>();

project-order/src/main/java/com/dituhui/pea/order/service/impl/ScheduleServiceImpl.java

@@ -3,6 +3,7 @@ package com.dituhui.pea.order.service.impl;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import cn.hutool.core.date.LocalDateTimeUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.ObjectUtil;
+import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.dituhui.pea.common.BusinessException;
 import com.dituhui.pea.common.BusinessException;
 import com.dituhui.pea.common.Result;
 import com.dituhui.pea.common.Result;
@@ -19,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Pageable;
+import org.springframework.data.domain.Sort;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.data.jpa.domain.Specification;
 import org.springframework.stereotype.Service;
 import org.springframework.stereotype.Service;
 
 
@@ -126,6 +128,10 @@ public class ScheduleServiceImpl implements ScheduleService {
 
 
             List<ScheduleOverviewResp.Item> children = new ArrayList<>();
             List<ScheduleOverviewResp.Item> children = new ArrayList<>();
             Integer teamDistance = 0;
             Integer teamDistance = 0;
+            Integer minOrderSum=null;
+            Integer maxOrderSum=null;
+            Integer minDistance=null;
+            Integer maxDistance=null;
             for (Map.Entry<String, List<EngineerInfoEntity>> entry : engineers.entrySet()) {
             for (Map.Entry<String, List<EngineerInfoEntity>> entry : engineers.entrySet()) {
                 ScheduleOverviewResp.Item child = new ScheduleOverviewResp.Item();
                 ScheduleOverviewResp.Item child = new ScheduleOverviewResp.Item();
 
 
@@ -146,12 +152,45 @@ public class ScheduleServiceImpl implements ScheduleService {
                 child.setDistanceDesc(distanceSum + "");
                 child.setDistanceDesc(distanceSum + "");
 
 
                 children.add(child);
                 children.add(child);
+
+                if(null==minOrderSum||null==maxOrderSum){
+                    minOrderSum=child.getOrder().getTotal();
+                    maxOrderSum=child.getOrder().getTotal();
+                }else {
+                    if(child.getOrder().getTotal()<minOrderSum){
+                        minOrderSum=child.getOrder().getTotal();
+                    }
+                    if(child.getOrder().getTotal()>maxOrderSum){
+                        maxOrderSum=child.getOrder().getTotal();
+                    }
+                }
+
+                if(null==minDistance||null==maxDistance){
+                    minDistance=distanceSum;
+                    maxDistance=distanceSum;
+                }else {
+                    if(distanceSum<minDistance){
+                        minDistance=distanceSum;
+                    }
+                    if(distanceSum>maxDistance){
+                        maxDistance=distanceSum;
+                    }
+                }
             }
             }
 
 
             team.setChildren(children);
             team.setChildren(children);
 
 
-            team.setOrderDesc(String.format("人均:%d", teamEngineers.size() > 0 ? (orders.size() / teamEngineers.size()) : 0));
-            team.setDistanceDesc(teamDistance + "");
+            team.setOrderDesc(String.format("人数:%d，人均:%d，%s-%s",
+                    teamEngineers.size(),
+                    teamEngineers.size() > 0 ? (orders.size() / teamEngineers.size()) : 0,
+                    minOrderSum,
+                    maxOrderSum));
+            team.setDistanceDesc(String.format("人均:%s，%s-%s",
+                    teamEngineers.size() > 0 ? new BigDecimal(teamDistance)
+                            .divide(new BigDecimal(teamEngineers.size()), 2, RoundingMode.HALF_UP)
+                            .stripTrailingZeros() : 0,
+                    minDistance,
+                    maxDistance));
 
 
             teams.add(team);
             teams.add(team);
         }
         }
@@ -165,7 +204,7 @@ public class ScheduleServiceImpl implements ScheduleService {
     }
     }
 
 
     @Override
     @Override
-    public Result<?> getScheduleEngineerOverview(LocalDate date, String engineerCode) throws BusinessException {
+    public Result<?> getScheduleEngineerOverview(LocalDate date, String engineerCode, String sortColumn, String sortType) throws BusinessException {
         // 获取技术员已排班概况
         // 获取技术员已排班概况
 
 
         EngineerInfoEntity engineer = engineerInfoDao.getByEngineerCode(engineerCode);
         EngineerInfoEntity engineer = engineerInfoDao.getByEngineerCode(engineerCode);
@@ -175,8 +214,16 @@ public class ScheduleServiceImpl implements ScheduleService {
         EngineerBusinessEntity engineerBusinessEntity = engineerBusinessDao.getByEngineerCode(engineerCode);
         EngineerBusinessEntity engineerBusinessEntity = engineerBusinessDao.getByEngineerCode(engineerCode);
         List<LabelValueDTO> emptyTips = new ArrayList<>();
         List<LabelValueDTO> emptyTips = new ArrayList<>();
 
 
+        if (!"orderId".equals(sortColumn)) {
+            sortColumn = "actualStartTime";
+        }
+        if (!"desc".equals(sortType)) {
+            sortType = "asc";
+        }
+        Sort sort = Sort.by(Sort.Direction.valueOf(sortType.toUpperCase()), sortColumn);
+
         List<OrderInfoEntity> orderAppointments = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
         List<OrderInfoEntity> orderAppointments = orderInfoDao.findByEngineerCodeAndDtAndAppointmentStatusIn(
-                engineerCode, date, List.of(OrderFlowEnum.PRE.name(), OrderFlowEnum.CONFIRM.name()));
+                engineerCode, date, List.of(OrderFlowEnum.PRE.name(), OrderFlowEnum.CONFIRM.name()), sort);
         List<TimeLineDTO> timelines = new ArrayList<>();
         List<TimeLineDTO> timelines = new ArrayList<>();
         int sumDistance = 0;
         int sumDistance = 0;
         int sumElapsed = 0;
         int sumElapsed = 0;
@@ -196,34 +243,38 @@ public class ScheduleServiceImpl implements ScheduleService {
         List<OrderInfoEntity> empty = new ArrayList<>();
         List<OrderInfoEntity> empty = new ArrayList<>();
         Integer countPending = statusGroup.getOrDefault("INIT", empty).size() + statusGroup.getOrDefault("CONTACTED", empty).size() + statusGroup.getOrDefault("PENDING", empty).size();
         Integer countPending = statusGroup.getOrDefault("INIT", empty).size() + statusGroup.getOrDefault("CONTACTED", empty).size() + statusGroup.getOrDefault("PENDING", empty).size();
 
 
-        List<LabelValueDTO> dynamics = new ArrayList<>();
-        dynamics.add(new LabelValueDTO("姓名", engineer.getName()));
-        dynamics.add(new LabelValueDTO("日期", TimeUtils.IsoLocalDate2String(date)));
-        dynamics.add(new LabelValueDTO("状态", "上班"));
-        dynamics.add(new LabelValueDTO("待服务", Integer.toString(countPending)));
-        dynamics.add(new LabelValueDTO("服务中", Integer.toString(statusGroup.getOrDefault("STARTED", empty).size())));
-        dynamics.add(new LabelValueDTO("已完成", Integer.toString(statusGroup.getOrDefault("FINISHED", empty).size())));
-        dynamics.add(new LabelValueDTO("已取消", Integer.toString(statusGroup.getOrDefault("CANCELED", empty).size())));
-        dynamics.add(new LabelValueDTO("已改约", Integer.toString(statusGroup.getOrDefault("RESCHEDULED", empty).size())));
-        dynamics.add(new LabelValueDTO("预计总耗时", new BigDecimal(sumElapsed)
+        ScheduleEngineerOverviewDynamics dynamics = new ScheduleEngineerOverviewDynamics();
+        dynamics.setName(engineer.getName());
+        dynamics.setEngineerCode(engineer.getEngineerCode());
+        dynamics.setPhone(engineer.getPhone());
+        dynamics.setGrade(engineer.getGrade());
+        dynamics.setDate(TimeUtils.IsoLocalDate2String(date));
+        dynamics.setStatus("上班");
+        dynamics.setOrderCount(orderAppointments.size());
+        dynamics.setToServiceCount(countPending);
+        dynamics.setInServiceCount(statusGroup.getOrDefault("STARTED", empty).size());
+        dynamics.setFinishedCount(statusGroup.getOrDefault("FINISHED", empty).size());
+        dynamics.setCanceledCount(statusGroup.getOrDefault("CANCELED", empty).size());
+        dynamics.setRescheduledCount(statusGroup.getOrDefault("RESCHEDULED", empty).size());
+        dynamics.setRoadTotalElapsedTime(new BigDecimal(sumElapsed)
                 .divide(new BigDecimal(60), 2, RoundingMode.HALF_UP)
                 .divide(new BigDecimal(60), 2, RoundingMode.HALF_UP)
                 .stripTrailingZeros()
                 .stripTrailingZeros()
-                + "小时"));
-        dynamics.add(new LabelValueDTO("公里数", sumDistance + ""));
+                + "时");
+        dynamics.setRoadTotalDistance(sumDistance + "公里");
         if (Objects.nonNull(engineerBusinessEntity)) {
         if (Objects.nonNull(engineerBusinessEntity)) {
-            dynamics.add(new LabelValueDTO("工作时间", engineerBusinessEntity.getWorkOn() + "-" + engineerBusinessEntity.getWorkOff()));
+            dynamics.setWorkTime(engineerBusinessEntity.getWorkOn() + "-" + engineerBusinessEntity.getWorkOff());
         } else {
         } else {
-            dynamics.add(new LabelValueDTO("工作时间", "08:00-18:00"));
+            dynamics.setWorkTime("08:00-18:00");
         }
         }
-        dynamics.add(new LabelValueDTO("交通工具", VehicleEnum.getNameByValue(engineer.getVehicle())));
+        dynamics.setVehicleName(VehicleEnum.getNameByValue(engineer.getVehicle()));
 
 
-        List<String> orderIds = orderAppointments.stream().map(OrderInfoEntity::getOrderId).collect(Collectors.toList());
-        List<OrderInfoEntity> orderRequests = new ArrayList<>();
-        if (orderIds != null && !orderIds.isEmpty()) {
-            orderRequests = orderInfoDao.findAllByDtAndOrderIdIn(date, orderIds);
-        }
+//        List<String> orderIds = orderAppointments.stream().map(OrderInfoEntity::getOrderId).collect(Collectors.toList());
+//        List<OrderInfoEntity> orderRequests = new ArrayList<>();
+//        if (orderIds != null && !orderIds.isEmpty()) {
+//            orderRequests = orderInfoDao.findAllByDtAndOrderIdIn(date, orderIds);
+//        }
         List<ScheduleEngineerOverviewResp.Order> orders = new ArrayList<>();
         List<ScheduleEngineerOverviewResp.Order> orders = new ArrayList<>();
-        for (OrderInfoEntity o : orderRequests) {
+        for (OrderInfoEntity o : orderAppointments) {
             ScheduleEngineerOverviewResp.Order item = new ScheduleEngineerOverviewResp.Order();
             ScheduleEngineerOverviewResp.Order item = new ScheduleEngineerOverviewResp.Order();
             item.setOrderId(o.getOrderId());
             item.setOrderId(o.getOrderId());
             item.setLocation(String.format("%s,%s", o.getX(), o.getY()));
             item.setLocation(String.format("%s,%s", o.getX(), o.getY()));
@@ -266,9 +317,13 @@ public class ScheduleServiceImpl implements ScheduleService {
         }
         }
 
 
         ScheduleEngineerOverviewResp res = new ScheduleEngineerOverviewResp();
         ScheduleEngineerOverviewResp res = new ScheduleEngineerOverviewResp();
-        res.setTitle(String.format("%s_%s", groupName, engineer.getName()));
+//        res.setTitle(String.format("%s_%s_%s_%s_%s", groupName,
+//                engineer.getName(),
+//                engineer.getEngineerCode(),
+//                engineer.getPhone(),
+//                engineer.getGrade()));
         res.setEngineerCode(engineerCode);
         res.setEngineerCode(engineerCode);
-        res.setStartTime(String.format("%s 08:00:00", date));  // TODO
+        res.setStartTime(String.format("%s 08:00:00", date));
         res.setEndTime(String.format("%s 18:00:00", date));
         res.setEndTime(String.format("%s 18:00:00", date));
         res.setDynamics(dynamics);
         res.setDynamics(dynamics);
         res.setOrders(timelines);
         res.setOrders(timelines);

project-order/src/main/resources/logback-spring.xml

@@ -7,6 +7,7 @@
 
 
     <springProperty name="LOG_MAXFILESIZE" scope="context" source="logback.filesize" defaultValue="100MB"/>
     <springProperty name="LOG_MAXFILESIZE" scope="context" source="logback.filesize" defaultValue="100MB"/>
     <springProperty name="LOG_FILEMAXDAY" scope="context" source="logback.filemaxday" defaultValue="30"/>
     <springProperty name="LOG_FILEMAXDAY" scope="context" source="logback.filemaxday" defaultValue="30"/>
+    <springProperty name="spring.application.name" scope="context" source="spring.application.name" defaultValue="spring-boot-fusion"/>
 
 
     <!-- 日志在工程中的输出位置 -->
     <!-- 日志在工程中的输出位置 -->
     <property name="LOG_FILE" value="logs/${spring.application.name:-}"/>
     <property name="LOG_FILE" value="logs/${spring.application.name:-}"/>