blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
龚焕茏
2024-08-02 5e859a25ddf7d61753e5849b3c6ef36cb0cbf68c 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -9,14 +9,21 @@


import com.ycl.platform.domain.entity.*;


import com.ycl.platform.domain.form.*;


import com.ycl.platform.domain.query.DistributeWorkOrderQuery;


import com.ycl.platform.domain.query.HomeQuery;


import com.ycl.platform.domain.query.ScreenQuery;


import com.ycl.platform.domain.query.WorkOrderQuery;


import com.ycl.platform.domain.vo.DistributeWorkOrderVO;


import com.ycl.platform.domain.vo.WorkOrderVO;


import com.ycl.platform.domain.vo.WorkOrderYwConditionRecordVO;


import com.ycl.platform.mapper.*;


import com.ycl.platform.domain.vo.screen.ScreenWorkOrderVO;


import com.ycl.platform.mapper.WorkOrderAuditingRecordMapper;


import com.ycl.platform.mapper.WorkOrderDistributeRecordMapper;


import com.ycl.platform.mapper.WorkOrderMapper;


import com.ycl.platform.mapper.WorkOrderYwConditionRecordMapper;


import com.ycl.platform.service.NotifyService;


import com.ycl.platform.service.WorkOrderAuditingRecordService;


import com.ycl.platform.service.WorkOrderService;


import com.ycl.platform.service.YwPointService;


import com.ycl.system.Result;


import com.ycl.system.model.LoginUser;


import com.ycl.system.page.PageUtil;


@@ -29,6 +36,7 @@


import enumeration.general.WorkOrderDistributeWayEnum;


import enumeration.general.WorkOrderStatusEnum;


import lombok.RequiredArgsConstructor;


import org.apache.commons.lang3.ObjectUtils;


import org.springframework.beans.BeanUtils;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.stereotype.Service;


@@ -38,9 +46,7 @@




import java.time.LocalDateTime;


import java.time.ZoneId;


import java.util.ArrayList;


import java.util.List;


import java.util.Objects;


import java.util.*;


import java.util.stream.Collectors;




/**


@@ -54,8 +60,7 @@


public class WorkOrderServiceImpl extends ServiceImpl<WorkOrderMapper, WorkOrder> implements WorkOrderService {




    private final WorkOrderMapper workOrderMapper;


    private final YwUnitMapper ywUnitMapper;


    private final YwPeopleMapper ywPeopleMapper;


    private final YwPointService ywPointService;


    private final WorkOrderAuditingRecordMapper workOrderAuditingRecordMapper;


    private final WorkOrderAuditingRecordService workOrderAuditingRecordService;


    private final WorkOrderYwConditionRecordMapper workOrderYwConditionRecordMapper;


@@ -125,6 +130,10 @@


                UrgentLevelEnum.WARNING,


                workOrder.getWorkOrderNo());


        notifyService.save(notify);


        // 同步点位状态


        if (form.getAuditingResult() == WorkOrderStatusEnum.AUDITING_SUCCESS) {


            ywPointService.updateRecovery(Collections.singletonList(workOrder.getPointId()), 0);


        }


        return Result.ok("操作成功");


    }




@@ -268,6 +277,7 @@


    }




    @Override


    @Transactional


    public Result distributeFast(DistributeWorkOrderVO data) {


        // 获取当前时间


        LocalDateTime now = LocalDateTime.now(ZoneId.systemDefault());


@@ -308,6 +318,8 @@


                    .in(WorkOrder::getId, ids)


                    .update();


            addDistributeRecord(ids, WorkOrderDistributeWayEnum.FAST_DISTRIBUTE);


            // 同步点位状态


            ywPointService.updateRecovery(pointIds, 1);


            return Result.ok("成功下发" + ids.size() + "条工单");


        } catch (Exception e) {


            return Result.error("操作失败");


@@ -317,6 +329,7 @@


    }




    @Override


    @Transactional


    public Result selectedIdsDistribute(DistributeWorkOrderQuery query) {


        WorkOrderDistributeWayEnum distributeWayEnum = WorkOrderDistributeWayEnum.SELECTED_DISTRIBUTE;


        if (!getDistributeLock()) { return Result.error("此刻有人下发中，为避免冲突，请稍后重试"); }


@@ -338,6 +351,9 @@


                    .in(WorkOrder::getId, query.getIds())


                    .update();


            addDistributeRecord(query.getIds(), distributeWayEnum);


            // 同步点位状态


            List<Integer> pointIds = new LambdaQueryChainWrapper<>(baseMapper).select(WorkOrder::getPointId).in(WorkOrder::getId, query.getIds()).list().stream().map(WorkOrder::getPointId).toList();


            ywPointService.updateRecovery(pointIds, 1);


            return Result.ok("成功下发" + query.getIds().size() + "条工单");


        } catch (Exception e) {


            return Result.error("操作失败");


@@ -407,4 +423,33 @@


                .collect(Collectors.toList());


        return Result.ok().data(vos);


    }




    @Override


    public Result screenWorkOrder(ScreenQuery query) {


        ScreenWorkOrderVO screen = baseMapper.screenWorkOrder(query);


        return Result.ok().data(screen);


    }




    @Override


    public Map<String, Object> home(HomeQuery monitorQuery) {


        Map<String, Object> dataMap = new HashMap<>();


        Map<String, Object> data1 = new HashMap<>();


        Map<String, Object> data2 = new HashMap<>();


        Map<String, Object> data3 = new HashMap<>();


        List<Map<String, Object>> home = baseMapper.home(monitorQuery);


        if (ObjectUtils.isNotEmpty(home)) {


            for (Map<String, Object> map : home) {


                if (Objects.nonNull(map.get("dateType")) && StringUtils.hasText(map.get("dateType").toString())) {


                    data1.put(map.get("dateType").toString(), map.get("num1"));


                    data2.put(map.get("dateType").toString(), map.get("num2"));


                    data3.put(map.get("dateType").toString(), map.get("num3"));


                }


            }


            dataMap.put("name", home.get(0).get("name"));


        }


        dataMap.put("complete", data1);


        dataMap.put("waiting", data2);


        dataMap.put("pending", data3);


        return dataMap;


    }


}