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


@@ -16,10 +16,7 @@


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


import com.ycl.platform.service.NotifyService;


import com.ycl.platform.service.WorkOrderAuditingRecordService;


import com.ycl.platform.service.WorkOrderService;


@@ -36,6 +33,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 +53,7 @@


 * @author xp


 * @since 2024-03-05


 */


@Slf4j


@Service


@RequiredArgsConstructor


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


@@ -66,6 +65,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 +74,15 @@


    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());


        });


        int real = workOrderList.size();


        boolean result = this.saveBatch(workOrderList);


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


        return result;


    }




    /**