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

刘鑫
Commit 03f90606 authored Nov 14, 2023 by 刘鑫
Showing with 46 additions and 20 deletions
project-order/src/main/java/com/dituhui/pea/order/service/impl/DispatchServiceImpl.java
project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderAssignImpl.java
project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderCreateServiceImpl.java
project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderInfoServiceImpl.java
--- a/project-order/src/main/java/com/dituhui/pea/order/service/impl/DispatchServiceImpl.java
+++ b/project-order/src/main/java/com/dituhui/pea/order/service/impl/DispatchServiceImpl.java
@@ -298,6 +298,8 @@ public class DispatchServiceImpl implements DispatchService {
    public Result<?> dispatchOrderConfirm(String engineerCode, String date, List<String> orderIds) throws BusinessException {
        // 派工台确认派单
        LocalDate localDate = TimeUtils.IsoDate2LocalDate(date);
+        List<String> successList = new ArrayList<>();
+        List<String> errorList = new ArrayList<>();
        EngineerInfoEntity engineer = engineerInfoDao.getByEngineerCode(engineerCode);
        if (engineer == null) {
@@ -320,13 +322,12 @@ public class DispatchServiceImpl implements DispatchService {
            }
            SkillInfoEntity skill = skillInfoDao.getByBrandAndTypeAndSkill(CommonUtil.fixBrand(entity.getBrand()), entity.getType(), entity.getSkill());
            List<OrderInfoEntity> engineerOrders = orderInfoDao.findByDtAndEngineerCode(localDate, engineer.getEngineerCode());
-            if (CollectionUtils.isNotEmpty(engineerOrders)) {
+            Result<OrderInfoEntity> entityResult = orderInfoService.insterEngineerOrders(engineerOrders, entity, skill, byTeamId, engineer);
-                Result<OrderInfoEntity> entityResult = orderInfoService.insterEngineerOrders(engineerOrders, entity, skill, byTeamId, engineer);
+            if (!entityResult.getCode().equals(ResultEnum.SUCCESS.getCode())) {
-                if (!entityResult.getCode().equals(ResultEnum.SUCCESS.getCode())) {
+                // return Result.failed("当前工程师无法预约合适时间");
-                    return Result.failed("当前工程师无法预约合适时间");
+                errorList.add(entity.getOrderId());
-                }
-                entity = entityResult.getResult();
            }
+            entity = entityResult.getResult();
            entity.setTakeTime(skill.getTakeTime());
            entity.setEngineerCode(engineer.getEngineerCode());
            entity.setEngineerName(engineer.getName());
@@ -341,8 +342,16 @@ public class DispatchServiceImpl implements DispatchService {
            commonService.addOrderEvent(entity.getOrderId(), "", "PEA", "PEA", OrderEventEnum.reassignment.getEvent(),
                    String.format(OrderEventEnum.reassignment.getMsg(), engineer.getName() + "-" + (ObjectUtil.isNotNull(byTeamId) ? byTeamId.getTeamName() : "")),
                    "", LocalDateTime.now());
+            successList.add(entity.getOrderId());
+        }
+        List<String> resultList = new ArrayList<>();
+        if (CollectionUtils.isNotEmpty(successList)) {
+            resultList.add(String.format("%s订单指派(改派)成功", String.join(",", successList)));
+        }
+        if (CollectionUtils.isNotEmpty(errorList)) {
+            resultList.add(String.format("%s订单指派(改派)失败,当前工程师无法预约合适时间", String.join(",", errorList)));
        }
-        return Result.success(null);
+        return Result.success(CollectionUtils.isNotEmpty(resultList) ? String.join(",", resultList) : null);
    }
    @Override

--- a/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderAssignImpl.java
+++ b/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderAssignImpl.java
@@ -164,13 +164,11 @@ public class OrderAssignImpl implements OrderAssign {
        SkillInfoEntity skill = skillInfoDao.getByBrandAndTypeAndSkill(CommonUtil.fixBrand(entity.getBrand()), entity.getType(), entity.getSkill());
        //判断工程师订单当日工单时间安排
        List<OrderInfoEntity> engineerOrders = orderInfoDao.findByDtAndEngineerCode(entity.getDt(), engineer.getEngineerCode());
-        if (CollectionUtils.isNotEmpty(engineerOrders)) {
+        Result<OrderInfoEntity> entityResult = orderInfoService.insterEngineerOrders(engineerOrders, entity, skill, byTeamId, engineer);
-            Result<OrderInfoEntity> entityResult = orderInfoService.insterEngineerOrders(engineerOrders, entity, skill, byTeamId, engineer);
+        if (!entityResult.getCode().equals(ResultEnum.SUCCESS.getCode())) {
-            if (!entityResult.getCode().equals(ResultEnum.SUCCESS.getCode())) {
+            return Result.failed("当前工程师工单已满");
-                return Result.failed("当前工程师工单已满");
-            }
-            entity = entityResult.getResult();
        }
+        entity = entityResult.getResult();
        entity.setEngineerCode(engineer.getEngineerCode());
        entity.setEngineerName(engineer.getName());

--- a/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderCreateServiceImpl.java
+++ b/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderCreateServiceImpl.java
@@ -359,7 +359,6 @@ public class OrderCreateServiceImpl implements OrderCreateService {
                entity.setOrgBranchId(teamInfo.getBranchId());
                entity.setOrgGroupId(teamInfo.getGroupId());
                entity.setOrgTeamId(teamInfo.getTeamId());
-                entity.setAppointmentStatus(OrderFlowEnum.PRE.name());
                //特殊时间段
                Integer special = CommonUtil.isSpecial(entity.getExpectTimeBegin().toLocalTime(),
                        entity.getExpectTimeEnd().toLocalTime(), teamInfo.getWorkOn(), teamInfo.getWorkOff());
@@ -376,7 +375,6 @@ public class OrderCreateServiceImpl implements OrderCreateService {
                    entity.setIsCutoff(cutoff);
                    entity.setIsSpecialTime(special);
                    entity.setAppointmentMethod(AppointmentMethodEnum.MANUAL.name());
-                    entity.setAppointmentStatus(OrderFlowEnum.INIT.name());
                    //发送通知分部消息
                    sendMsg(teamInfo.getBranchId(), orderId, entity.getExpectTimeBegin().toLocalDate(), tags, cutoff, special);
                }

--- a/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderInfoServiceImpl.java
+++ b/project-order/src/main/java/com/dituhui/pea/order/service/impl/OrderInfoServiceImpl.java
@@ -238,7 +238,9 @@ public class OrderInfoServiceImpl implements OrderInfoService {
        order.setDt(expectBegin.toLocalDate());
        order.setExpectTimeBegin(expectBegin);
        order.setExpectTimeEnd(expectEnd);
-        order.setExpectTimeDesc(req.getExpectDesc());
+        if (StringUtils.isNotBlank(req.getExpectDesc())) {
+            order.setExpectTimeDesc(req.getExpectDesc());
+        }
        order.setTranscend(0);
        order.setOrderStatus(OrderStatusEnum.RESCHEDULED.getCode());
        order.setReschedulingReason(StringUtils.isNotBlank(req.getReschedulingReason()) ? req.getReschedulingReason() : order.getReschedulingReason());
@@ -386,6 +388,14 @@ public class OrderInfoServiceImpl implements OrderInfoService {
            }
        }
+        // 修改技能时处理工单耗时
+        if (skillUpdate) {
+            SkillInfoEntity skillInfoEntity = skillInfoDao.getByBrandAndTypeAndSkill(order.getBrand(), order.getType(), order.getSkill());
+            if (ObjectUtil.isNull(skillInfoEntity)) {
+                return Result.failed(StatusCodeEnum.ORDER_SKILL_NOT_EXISTS);
+            }
+            order.setTakeTime(skillInfoEntity.getTakeTime());
+        }
        //处理一家多单
        // order = handleMultipleOrders(order);
@@ -442,15 +452,26 @@ public class OrderInfoServiceImpl implements OrderInfoService {
    @Transactional
    @Override
    public Result<OrderInfoEntity> insterEngineerOrders(List<OrderInfoEntity> engineerOrders, OrderInfoEntity insertOrder, SkillInfoEntity skillInfo, OrgTeamEntity orgTeam, EngineerInfoEntity engineer) {
-        int takeTime = skillInfo.getTakeTime();
+        // 没有单直接返回
-        // 获取客户期望时间段
-        LocalDateTime start = insertOrder.getExpectTimeBegin();
-        LocalDateTime end = insertOrder.getExpectTimeEnd();
        // 获取团队工作起止时间
        String[] teamWorkStartTime = orgTeam.getWorkOn().split(":");
        String[] teamWorkEndTime = orgTeam.getWorkOff().split(":");
        LocalDateTime startTeam = insertOrder.getDt().atTime(Integer.parseInt(teamWorkStartTime[0]), Integer.parseInt(teamWorkStartTime[1]), 0);
        LocalDateTime endTeam = insertOrder.getDt().atTime(Integer.parseInt(teamWorkEndTime[0]), Integer.parseInt(teamWorkEndTime[1]), 0);
+        // 获取客户期望时间段
+        LocalDateTime start = insertOrder.getExpectTimeBegin();
+        LocalDateTime end = insertOrder.getExpectTimeEnd();
+        if (CollectionUtils.isEmpty(engineerOrders)) {
+            // 特殊时间不插单
+            if (LocalDateTime.now().isBefore(startTeam) || LocalDateTime.now().isAfter(endTeam) || end.isAfter(endTeam) || end.isBefore(startTeam)) {
+                return Result.failed(insertOrder);
+            }
+            insertOrder.setTakeTime(skillInfo.getTakeTime());
+            insertOrder.setPlanStartTime(insertOrder.getExpectTimeBegin());
+            insertOrder.setPlanEndTime(insertOrder.getExpectTimeBegin().plusMinutes(skillInfo.getTakeTime()));
+            return Result.success(insertOrder);
+        }
+        int takeTime = skillInfo.getTakeTime();
        // 计算最早派工和最晚派工时间
        LocalDateTime workStartTime = start.isAfter(startTeam) ? start : startTeam;
        LocalDateTime workEndTime = end.isBefore(endTeam) ? end : endTeam;