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


@@ -44,6 +44,7 @@


import constant.CheckConstants;


import constant.Constants;


import constant.RedisConstant;


import enumeration.ErrorType;


import enumeration.general.*;


import lombok.RequiredArgsConstructor;


import lombok.extern.slf4j.Slf4j;


@@ -62,6 +63,7 @@


import org.springframework.util.Assert;


import org.springframework.util.CollectionUtils;


import org.springframework.util.StringUtils;


import pojo.CascadeOption;




import javax.imageio.ImageIO;


import javax.swing.*;


@@ -98,6 +100,7 @@


    private final NotifyService notifyService;


    private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;


    private final WorkOrderErrorTypeServiceImpl workOrderErrorTypeService;


    private final WorkOrderErrorTypeMapper workOrderErrorTypeMapper;


    private final SysConfigMapper configMapper;


    private final ReportMapper reportMapper;


    private final WorkOrderCheckImgMapper workOrderCheckImgMapper;


@@ -114,14 +117,20 @@


    private RedisCache redisCache;




    @Override


    @Transactional(rollbackFor = Exception.class)


    public synchronized Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) {


        //避免坑(事务加锁会失效、方法内部调用事务会失效)


        WorkOrderServiceImpl self = applicationContext.getBean(WorkOrderServiceImpl.class);


        return self.batchAddWorkOrder(workOrderList);


    }




    @Transactional(rollbackFor = Exception.class)


    public Boolean batchAddWorkOrder(List<WorkOrder> workOrderList){


        int total = workOrderList.size();


        // 查询出白名单列表


        List<String> serialNumbers = workOrderWhiteMapper.selectList().stream().map(WorkOrderWhite::getSerialNumber).collect(Collectors.toList());


        // 遍历工单列表，判断是否在白名单中


        workOrderList = workOrderList.stream().filter(item -> !serialNumbers.contains(item.getSerialNumber()))


                        .collect(Collectors.toList());


                .collect(Collectors.toList());


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


            return StringUtils.hasText(item.getSerialNumber()) && Objects.nonNull(item.getStatus()) && !CollectionUtils.isEmpty(item.getErrorTypeList());


        }).collect(Collectors.toList());


@@ -217,11 +226,12 @@


            return Boolean.TRUE;


        }


        List<String> willAddSerialNumber = waitAddList.stream().map(WorkOrder::getSerialNumber).collect(Collectors.toList());


        //只生成考核设备的工单


        //只生成考核设备、且有运维单位的工单


        List<YwPoint> pointList = new LambdaQueryChainWrapper<>(ywPointService.getBaseMapper())


                .select(YwPoint::getUnitId, YwPoint::getSerialNumber, YwPoint::getImportantTag, YwPoint::getImportantTag, YwPoint::getProvinceTag, YwPoint::getImportantCommandImageTag)


                .in(YwPoint::getSerialNumber, willAddSerialNumber)


                .eq(YwPoint::getExamineStatus, Boolean.TRUE)


                .isNotNull(YwPoint::getUnitId)


                .list();


        Map<String, YwPoint> pointMapping = pointList.stream().collect(Collectors.toMap(YwPoint::getSerialNumber, point -> point));


        // 查出重点点位、普通点位的处理时间


@@ -316,7 +326,6 @@


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


        return Boolean.TRUE;


    }




    /**


     * 添加


     *


@@ -415,14 +424,10 @@


    @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, WorkOrder::getSerialNumber)


                .list();


        //根据工单编号获取工单


        List<WorkOrder> list = baseMapper.selectByNos(form.getWorkOrderNumbers());


        if (list.isEmpty()) {


            return Result.error("没有工单可以审核");


            return Result.error("没有待审核工单");


        }


        List<String> workOrderNoList = list.stream().map(WorkOrder::getWorkOrderNo).collect(Collectors.toList());


        List<String> serialNumbers = list.stream().map(WorkOrder::getSerialNumber).toList();


@@ -515,6 +520,9 @@


    public List<WorkOrderYwConditionRecordVO> selectYwConditionByYwId(String workOrderNo) {


        List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(workOrderNo);


        ywConditionList.stream().forEach(item -> {


            if(item.getUserId().equals(1)){


                item.setUnitName("管理员");


            }


            if (Objects.nonNull(item.getSysMsg()) && item.getSysMsg()) {


                item.setUnitName("系统消息");


            }


@@ -562,6 +570,19 @@


     */


    @Override


    public Result removeById(String id) {


        WorkOrder workOrder = baseMapper.selectById(id);


        String workOrderNo = workOrder.getWorkOrderNo();


        //删除工单审核记录


        workOrderAuditingRecordMapper.delete(new QueryWrapper<WorkOrderAuditingRecord>().eq("work_order_no", workOrderNo));


        //删除工单图片记录


        workOrderCheckImgMapper.delete(new QueryWrapper<WorkOrderCheckImg>().eq("work_order_no", workOrderNo));


        //删除工单下发记录


        workOrderDistributeRecordMapper.delete(new QueryWrapper<WorkOrderDistributeRecord>().eq("work_order_no", workOrderNo));


        //删除工单故障类型


        workOrderErrorTypeMapper.delete(new QueryWrapper<WorkOrderErrorType>().eq("work_order_no", workOrderNo));


        //删除工单情况记录


        workOrderYwConditionRecordMapper.delete(new QueryWrapper<WorkOrderYwConditionRecord>().eq("work_order_no", workOrderNo));




        if (baseMapper.deleteById(id) > 0) {


            return Result.ok("删除成功");


        }


@@ -577,14 +598,27 @@


    @Override


    public Result page(WorkOrderQuery query) {


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


        query.setUnitId(SecurityUtils.getUnitId());


        query.setStart(DateUtils.getDayStart(query.getStart()));


        query.setEnd(DateUtils.getDayEnd(query.getEnd()));


        if(query.getUnitId()==null) {


            query.setUnitId(SecurityUtils.getUnitId());


        }


        if(query.getStart()!=null) query.setStart(DateUtils.getDayStart(query.getStart()));


        if(query.getEnd()!=null) query.setEnd(DateUtils.getDayEnd(query.getEnd()));


        baseMapper.page(page, query);


        if (!CollectionUtils.isEmpty(page.getRecords())) {


            page.getRecords().stream().forEach(item -> {


                if (StringUtils.hasText(item.getErrorType())) {


                    item.setErrorTypeList(List.of(item.getErrorType().split(",")));


                    List<String> errorTypeList = new ArrayList<>(List.of(item.getErrorType().split(",")));


                    int index = errorTypeList.indexOf(query.getErrorTypeLabel());


                    if (index != -1) {


                        // 保存要移动的元素


                        String firstOccurrence = errorTypeList.get(index);


                        // 从列表中移除该元素（第一次出现的位置）


                        errorTypeList.remove(index);


                        // 将该元素添加到列表的首位


                        errorTypeList.add(0, firstOccurrence);


                    }


                    // 设置更新后的列表


                    item.setErrorTypeList(errorTypeList);


                }


                if (StringUtils.hasText(item.getImgListStr())) {


                    item.setImgList(List.of(item.getImgListStr().split(",")));


@@ -597,6 +631,8 @@


    @Override


    public Result distributePage(DistributeWorkOrderQuery query) {


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


        if(query.getStart()!=null) query.setStart(DateUtils.getDayStart(query.getStart()));


        if(query.getEnd()!=null) query.setEnd(DateUtils.getDayEnd(query.getEnd()));


        baseMapper.distributePage(page, query);


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


    }


@@ -822,7 +858,7 @@






    @Override


    public synchronized String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) throws Exception {


    public String getFrameImgByDevice(String deviceId, String channelId, String workOrderNo) throws Exception {


        String url = String.format(this.rtspServer + "/api/play/start/img/%s/%s", deviceId, channelId);


        log.info("访问路径{}",url);


        String result = HttpUtils.sendGet(url);


@@ -1024,23 +1060,13 @@




    @Override


    public List<WorkOrderVO> export (WorkOrderExportQuery query){


        query.setUnitId(SecurityUtils.getUnitId());


        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


        if (query.getStart() == null) {


            query.setStart(format.format(DateUtils.getDayStart(new Date())));


        } else {


            query.setStart(query.getStart() + " 00:00:00");


        if(query.getUnitId()==null) {


            query.setUnitId(SecurityUtils.getUnitId());


        }


        if (query.getEnd() == null) {


            query.setEnd(format.format(DateUtils.getDayEnd(new Date())));


        } else {


            query.setEnd(query.getEnd() + " 23:59:59");


        }


        if (query.getStart() != null) query.setStart(query.getStart() + " 00:00:00");


        if (query.getEnd() != null) query.setEnd(query.getEnd() + " 23:59:59");




        List<WorkOrderVO> export = baseMapper.export(query);




        System.out.println(export);


        return export;


        return baseMapper.export(query);


    }




    /**


@@ -1118,5 +1144,102 @@


        insertWhiteList.stream().forEach(white -> workOrderWhiteMapper.insert(white));


    }




    /**


     * 检测工单按钮


     * @param workOrderNo


     * @return


     */


    @Override


    public Result checkImage(String workOrderNo,String serialNumber) {


        // 查出国标设备，就一条数据


        List<DeviceInfo> gbDevices = new LambdaQueryChainWrapper<>(deviceInfoMapper)


                .orderByDesc(DeviceInfo::getUpdateTime)


                .last("limit 1")


                .list();


        if (!CollectionUtils.isEmpty(gbDevices)) {


            try {


                String imgUrl = this.getFrameImgByDevice(gbDevices.get(0).getDeviceId(), serialNumber,workOrderNo);


                if (StringUtils.hasText(imgUrl)) {


                    WorkOrderCheckImg img = new WorkOrderCheckImg();


                    img.setWorkOrderNo(workOrderNo);


                    img.setImgUrl(imgUrl);


                    img.setCreateTime(new Date());


                    workOrderCheckImgMapper.insert(img);


                }


                return Result.ok().data(imgUrl);


            } catch (Exception e) {


                e.printStackTrace();


            }


        }


        return Result.ok();


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result batchDeleteWorkOrder(List<String> workOrderNos) {


        if(!CollectionUtils.isEmpty(workOrderNos)) {


            //删除工单审核记录


            workOrderAuditingRecordMapper.delete(new QueryWrapper<WorkOrderAuditingRecord>().in("work_order_no", workOrderNos));


            //删除工单图片记录


            workOrderCheckImgMapper.delete(new QueryWrapper<WorkOrderCheckImg>().in("work_order_no", workOrderNos));


            //删除工单下发记录


            workOrderDistributeRecordMapper.delete(new QueryWrapper<WorkOrderDistributeRecord>().in("work_order_no", workOrderNos));


            //删除工单故障类型


            workOrderErrorTypeMapper.delete(new QueryWrapper<WorkOrderErrorType>().in("work_order_no", workOrderNos));


            //删除工单情况记录


            workOrderYwConditionRecordMapper.delete(new QueryWrapper<WorkOrderYwConditionRecord>().in("work_order_no", workOrderNos));


            //删除工单


            this.baseMapper.delete(new QueryWrapper<WorkOrder>().in("work_order_no", workOrderNos));


        }


        return Result.ok();


    }




    @Override


    public Result errorAll() {


        List<CascadeOption> results = new ArrayList<>();


        CascadeOption video = new CascadeOption();


        video.setLabel("视频");


        video.setValue("VIDEO");


        List<ErrorType> videoErr = ErrorType.getErrorTypesByCategory("VIDEO");


        List<ErrorType> videoErr1 = ErrorType.getErrorTypesByCategory("COMMON");


        videoErr.addAll(videoErr1);


        List<CascadeOption> videoChildren = videoErr.stream().map(item -> CascadeOption.builder()


                .value(item.getValue())


                .label(item.getDesc())


                .build()).collect(Collectors.toList());


        video.setChildren(videoChildren);




        CascadeOption car = new CascadeOption();


        car.setLabel("车辆");


        car.setValue("CAR");


        List<ErrorType> carErr = ErrorType.getErrorTypesByCategory("CAR");


        List<ErrorType> carErr1 = ErrorType.getErrorTypesByCategory("COMMON");


        List<ErrorType> carErr2 = ErrorType.getErrorTypesByCategory("CARORFACE");


        carErr.addAll(carErr1);


        carErr.addAll(carErr2);


        List<CascadeOption> carChildren = carErr.stream().map(item -> CascadeOption.builder()


                .value(item.getValue())


                .label(item.getDesc())


                .build()).collect(Collectors.toList());


        car.setChildren(carChildren);




        CascadeOption face = new CascadeOption();


        face.setLabel("人脸");


        face.setValue("FACE");


        List<ErrorType> faceErr = ErrorType.getErrorTypesByCategory("FACE");


        List<ErrorType> faceErr1 = ErrorType.getErrorTypesByCategory("COMMON");


        List<ErrorType> faceErr2 = ErrorType.getErrorTypesByCategory("CARORFACE");


        faceErr.addAll(faceErr1);


        faceErr.addAll(faceErr2);


        List<CascadeOption> faceChildren = faceErr.stream().map(item -> CascadeOption.builder()


                .value(item.getValue())


                .label(item.getDesc())


                .build()).collect(Collectors.toList());


        face.setChildren(faceChildren);




        results.add(video);


        results.add(car);


        results.add(face);


        return Result.ok().data(results);


    }


}