blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2024-08-09 614ff877d7dc97bf923e5782d04b222e38ae62b6 
 ycl-server/src/main/java/com/ycl/platform/service/impl/WorkOrderServiceImpl.java


@@ -8,18 +8,14 @@


import com.ycl.exception.ServiceException;


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.query.*;


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.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.domain.vo.screen.WorkOrderRegionVO;


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


import com.ycl.platform.mapper.*;


import com.ycl.platform.service.NotifyService;


import com.ycl.platform.service.WorkOrderAuditingRecordService;


import com.ycl.platform.service.WorkOrderService;


@@ -36,6 +32,7 @@


import enumeration.general.WorkOrderDistributeWayEnum;


import enumeration.general.WorkOrderStatusEnum;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


import org.apache.commons.lang3.ObjectUtils;


import org.springframework.beans.BeanUtils;


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


@@ -55,6 +52,7 @@


 * @author xp


 * @since 2024-03-05


 */


@Slf4j


@Service


@RequiredArgsConstructor


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


@@ -66,6 +64,7 @@


    private final WorkOrderYwConditionRecordMapper workOrderYwConditionRecordMapper;


    private final NotifyService notifyService;


    private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;


    private final TMonitorMapper monitorMapper;




    private final String DISTRIBUTE_LOCK_KEY = "distributeLock";


    private final static String IMPORTANT = "important";


@@ -74,9 +73,16 @@


    private RedisCache redisCache;




    @Override


    public Result innerAdd(WorkOrder workOrder) {




        return null;


    public Boolean innerAdd(List<WorkOrder> workOrderList) {


        int total = workOrderList.size();


        workOrderList.stream().filter(item -> {


            return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && StringUtils.hasText(item.getErrorType());


        });


        // TODO 自动下发工单


        int real = workOrderList.size();


        boolean result = this.saveBatch(workOrderList);


        log.info("传入工单总数: {}，实际添加工单数：{}", total, real);


        return result;


    }




    /**


@@ -458,4 +464,14 @@


        dataMap.put("pending", data3);


        return dataMap;


    }




    @Override


    public WorkOrderTotalVO workOrderTotal(DashboardQuery dashboardQuery) {


        return baseMapper.workOrderTotal(dashboardQuery);


    }




    @Override


    public List<WorkOrderRegionVO> workOrderRegion(DashboardQuery dashboardQuery) {


        return baseMapper.workOrderRegion(dashboardQuery);


    }


}