blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-07-23 95f0a8b4d82a859f2018c9d77e1a8a3a38b2d523 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -1,5 +1,6 @@


package com.ycl.platform.service.impl;




import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;


import com.baomidou.mybatisplus.core.metadata.IPage;


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;


@@ -11,8 +12,10 @@


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;


import com.ycl.platform.service.WorkOrderService;


import com.ycl.system.Result;


import com.ycl.system.model.LoginUser;


@@ -20,6 +23,7 @@


import com.ycl.utils.DateUtils;


import com.ycl.utils.SecurityUtils;


import com.ycl.utils.redis.RedisCache;


import com.ycl.utils.uuid.IdUtils;


import enumeration.general.*;


import lombok.RequiredArgsConstructor;


import org.apache.commons.lang3.ArrayUtils;


@@ -28,10 +32,12 @@


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;


import java.time.ZoneId;


import java.util.ArrayList;


import java.util.List;


import java.util.Objects;


import java.util.concurrent.TimeUnit;


@@ -51,6 +57,7 @@


    private final YwUnitMapper ywUnitMapper;


    private final YwPeopleMapper ywPeopleMapper;


    private final WorkOrderAuditingRecordMapper workOrderAuditingRecordMapper;


    private final WorkOrderAuditingRecordService workOrderAuditingRecordService;


    private final WorkOrderYwConditionRecordMapper workOrderYwConditionRecordMapper;


    private final NotifyService notifyService;


    private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;


@@ -68,10 +75,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("添加成功");


        }


@@ -123,6 +129,49 @@




    @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, ids);


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


        baseMapper.update(lambdaUpdateWrapper);


        // 添加多条审核记录


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


        for (Integer id : ids) {


            WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();


            workOrderAuditingRecord.setWorkOrderId(id);


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


            workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());


            workOrderAuditingRecord.setRemark(form.getAuditingRemark());


            workOrderAuditingRecords.add(workOrderAuditingRecord);


        }


        workOrderAuditingRecordService.saveBatch(workOrderAuditingRecords);


        // 添加新通知


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


        for (WorkOrder workOrder : list) {


            Notify notify = Notify.genEntityByUnit(NotifyTypeEnum.WORK_ORDER,


                    form.getAuditingResult().getDesc(),


                    workOrder.getUnitId(),


                    UrgentLevelEnum.WARNING,


                    workOrder.getWorkOrderNo());


            notifies.add(notify);


        }


        notifyService.saveBatch(notifies);


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


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result ywCondition(WorkOrderYWConditionForm form) {


        WorkOrder workOrder = baseMapper.selectById(form.getId());


        if (Objects.isNull(workOrder)) {


@@ -143,22 +192,9 @@


    }




    @Override


    public Result selectYwConditionByYwId(String id) {


        return Result.ok().data(


                new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)


                        .eq(WorkOrderYwConditionRecord::getWorkOrderId, id)


                        .orderByAsc(WorkOrderYwConditionRecord::getCreateTime)


                        .last("limit 1")


                        .one());


    }




    @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


@@ -221,6 +257,7 @@


    @Override


    public Result distributePage(DistributeWorkOrderQuery query) {


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


        // todo 关键词搜索


        baseMapper.distributePage(page, query);


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


    }