blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-07-09 ce7964aba19721cebdd9eb7d475ac651a6dca6bf 
 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;


@@ -13,6 +14,7 @@


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


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;


@@ -28,10 +30,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 +55,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;


@@ -123,6 +128,49 @@




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result batchAuditing(WorkOrderBatchAuditingForm form) {


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


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


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


                .eq(WorkOrder::getErrorType, form.getErrorType())


                .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)) {


@@ -148,8 +196,7 @@


                new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)


                        .eq(WorkOrderYwConditionRecord::getWorkOrderId, id)


                        .orderByAsc(WorkOrderYwConditionRecord::getCreateTime)


                        .last("limit 1")


                        .one());


                        .list());


    }




    @Override