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


@@ -8,18 +8,12 @@


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


import com.ycl.platform.service.NotifyService;


import com.ycl.platform.service.WorkOrderAuditingRecordService;


import com.ycl.platform.service.WorkOrderService;


@@ -36,6 +30,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 +50,7 @@


 * @author xp


 * @since 2024-03-05


 */


@Slf4j


@Service


@RequiredArgsConstructor


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


@@ -66,6 +62,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 +71,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 +462,12 @@


        dataMap.put("pending", data3);


        return dataMap;


    }




    @Override


    public Map<String, Object> dashboard(DashboardQuery dashboardQuery) {


        HashMap<String, Object> map = new HashMap<>();


        map.put("workOrderTotal", baseMapper.workOrderTotal(dashboardQuery));


        map.put("workOrderRegion", baseMapper.workOrderRegion(dashboardQuery));


        return map;


    }


}