blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-07-31 f284c5ef6a1aa6e9ba5d4e94e4b2abe83b6ea18c 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -12,6 +12,7 @@


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.service.NotifyService;


import com.ycl.platform.service.WorkOrderAuditingRecordService;


@@ -22,6 +23,8 @@


import com.ycl.utils.DateUtils;


import com.ycl.utils.SecurityUtils;


import com.ycl.utils.redis.RedisCache;


import com.ycl.utils.uuid.IdUtils;


import constant.PointConfigConstants;


import enumeration.general.*;


import lombok.RequiredArgsConstructor;


import org.apache.commons.lang3.ArrayUtils;


@@ -30,6 +33,7 @@


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.Assert;


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;




import java.time.LocalDateTime;


@@ -60,6 +64,7 @@


    private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;




    private final String DISTRIBUTE_LOCK_KEY = "distributeLock";


    private final static String IMPORTANT = "important";




    @Autowired


    private RedisCache redisCache;


@@ -72,10 +77,9 @@


    @Override


    public Result add(WorkOrderForm form) {


        WorkOrder entity = WorkOrderForm.getEntityByForm(form, null);


        entity.setWorkOrderNo(DateUtils.dateTimeNow());


        entity.setWorkOrderNo(IdUtils.timeAddRandomNO(5));


        entity.setCreateTime(DateUtils.getNowDate());


        entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);


        entity.setDeleted("0");


        if(baseMapper.insert(entity) > 0) {


            return Result.ok("添加成功");


        }


@@ -128,14 +132,24 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result batchAuditing(WorkOrderBatchAuditingForm form) {


        // 根据故障类型获取列表


        List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper)


                .in(WorkOrder::getStatus, WorkOrderStatusEnum.YW_HANDLE.getValue())


                .in(WorkOrder::getErrorType, form.getErrorTypes())


                .select(WorkOrder::getId, WorkOrder::getUnitId, WorkOrder::getWorkOrderNo)


                .list();


        if (list.isEmpty()) {


            return Result.error("没有工单可以审核");


        }


        List<Integer> ids = list.stream().map(WorkOrder::getId).collect(Collectors.toList());


        // 工单状态


        LambdaUpdateWrapper<WorkOrder> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();


        lambdaUpdateWrapper.in(WorkOrder::getId, form.getIds());


        lambdaUpdateWrapper.in(WorkOrder::getId, ids);


        lambdaUpdateWrapper.set(WorkOrder::getStatus, form.getAuditingResult());


        baseMapper.update(lambdaUpdateWrapper);


        // 添加多条审核记录


        List<WorkOrderAuditingRecord> workOrderAuditingRecords = new ArrayList<>();


        for (Integer id : form.getIds()) {


        for (Integer id : ids) {


            WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();


            workOrderAuditingRecord.setWorkOrderId(id);


            workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());


@@ -145,7 +159,6 @@


        }


        workOrderAuditingRecordService.saveBatch(workOrderAuditingRecords);


        // 添加新通知


        List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper).in(WorkOrder::getId, form.getIds()).select(WorkOrder::getUnitId, WorkOrder::getWorkOrderNo).list();


        List<Notify> notifies = new ArrayList<>();


        for (WorkOrder workOrder : list) {


            Notify notify = Notify.genEntityByUnit(NotifyTypeEnum.WORK_ORDER,


@@ -181,21 +194,9 @@


    }




    @Override


    public Result selectYwConditionByYwId(String id) {


        return Result.ok().data(


                new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)


                        .eq(WorkOrderYwConditionRecord::getWorkOrderId, id)


                        .orderByAsc(WorkOrderYwConditionRecord::getCreateTime)


                        .list());


    }




    @Override


    public Result selectYwConditionListByYwId(String id) {


        return Result.ok().data(


                new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)


                        .eq(WorkOrderYwConditionRecord::getWorkOrderId, id)


                        .orderByAsc(WorkOrderYwConditionRecord::getCreateTime)


                        .list());


    public Result selectYwConditionByYwId(Integer id) {


        List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id);


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


    }




    @Override


@@ -259,6 +260,11 @@


    public Result distributePage(DistributeWorkOrderQuery query) {


        IPage<WorkOrderVO> page = PageUtil.getPage(query, WorkOrderVO.class);


        baseMapper.distributePage(page, query);


        page.getRecords().stream().forEach(workOrder -> {


            if (StringUtils.hasText(workOrder.getPointTag()) && workOrder.getPointTag().contains(IMPORTANT)) {


                workOrder.setImportant(Boolean.TRUE);


            }


        });


        return Result.ok().data(page).total(page.getTotal());


    }