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


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


import com.ycl.config.ServerConfig;


import com.ycl.exception.ServiceException;


import com.ycl.platform.domain.entity.*;


import com.ycl.platform.domain.excel.PointExport;


import com.ycl.platform.domain.form.*;


import com.ycl.platform.domain.query.*;


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


@@ -39,6 +40,8 @@


import com.ycl.utils.http.HttpUtils;


import com.ycl.utils.redis.RedisCache;


import com.ycl.utils.uuid.IdUtils;


import constant.ApiConstants;


import constant.CheckConstants;


import constant.Constants;


import constant.RedisConstant;


import enumeration.general.*;


@@ -51,7 +54,9 @@


import org.springframework.beans.BeanUtils;


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


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


import org.springframework.context.ApplicationContext;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.scheduling.annotation.Async;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.Assert;


@@ -97,6 +102,8 @@


    private final ReportMapper reportMapper;


    private final WorkOrderCheckImgMapper workOrderCheckImgMapper;


    private final WorkOrderWhiteMapper workOrderWhiteMapper;


    private final DeviceInfoMapper deviceInfoMapper;


    private final ApplicationContext applicationContext;


    @Value("${rtsp.server:http://127.0.0.1:7788}")


    private String rtspServer;




@@ -107,12 +114,23 @@


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


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


        // 查询出白名单列表


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


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


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


                .collect(Collectors.toList());


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


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


        });


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


        if (CollectionUtils.isEmpty(workOrderList)) {


            return Boolean.TRUE;


        }


@@ -164,7 +182,10 @@


                            willAddErrorType.add(workOrderErrorType);


                        }


                    }


                    databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED);


                    //避免代下发的工单直接变成下发


                    if(!databaseWorkOrder.getStatus().equals(WorkOrderStatusEnum.WAIT_DISTRIBUTE)) {


                        databaseWorkOrder.setStatus(WorkOrderStatusEnum.DISTRIBUTED);


                    }


                    databaseWorkOrder.setUpdateTime(now);


                    willUpdateStatusWorkOrderList.add(databaseWorkOrder);


                    updateNum++;


@@ -202,9 +223,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));


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


@@ -299,7 +323,6 @@


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


        return Boolean.TRUE;


    }




    /**


     * 添加


     *


@@ -324,19 +347,26 @@


            return Result.error("工单正在添加，请稍后再试");


        }


        WorkOrder entity = WorkOrderForm.getEntityByForm(form, null);


        entity.setCreateTime(DateUtils.getNowDate());


        entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);


        Date now = new Date();


        entity.setCreateTime(now);


        entity.setUpdateTime(now);


        entity.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));


        entity.setErrorType(String.join(",", form.getErrorType()));


        List<WorkOrderErrorType> workOrderErrorTypes = form.getErrorType().stream().map(errorType -> new WorkOrderErrorType(entity.getWorkOrderNo(), errorType)).toList();


        workOrderErrorTypeService.getBaseMapper().insertWorkOrderErrorTypeList(workOrderErrorTypes);


        if (baseMapper.insert(entity) > 0) {


            return Result.ok("添加成功");


        // 查询出白名单列表


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


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


         if (serialNumbers.contains(entity.getSerialNumber())){


            return Result.error("该设备在白名单中，不能添加工单");


        }else {


            entity.setCreateTime(DateUtils.getNowDate());


            entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);


            Date now = new Date();


            entity.setCreateTime(now);


            entity.setUpdateTime(now);


            entity.setWorkOrderNo(IdUtils.workOrderNO(now, String.format("%05d", workOrderNum)));


            entity.setErrorType(String.join(",", form.getErrorType()));


            List<WorkOrderErrorType> workOrderErrorTypes = form.getErrorType().stream().map(errorType -> new WorkOrderErrorType(entity.getWorkOrderNo(), errorType)).toList();


            workOrderErrorTypeService.getBaseMapper().insertWorkOrderErrorTypeList(workOrderErrorTypes);


            if (baseMapper.insert(entity) > 0) {


                return Result.ok("添加成功");


            }


            return Result.error("添加失败");


        }


        return Result.error("添加失败");


    }




    /**


@@ -439,6 +469,7 @@


    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result ywCondition(WorkOrderYWConditionForm form) {




        WorkOrder workOrder = baseMapper.selectById(form.getId());


        if (Objects.isNull(workOrder)) {


            throw new ServiceException("工单不存在");


@@ -455,9 +486,37 @@


        workOrderYwConditionRecord.setYwProofMaterials(form.getYwProofMaterials());


        workOrderYwConditionRecord.setSysMsg(Boolean.FALSE);


        workOrderYwConditionRecordMapper.insert(workOrderYwConditionRecord);


        //异步获取图片


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


        self.getImage(workOrder);


        return Result.ok("操作成功");


    }




    @Async("threadPoolTaskExecutor")


    public void getImage(WorkOrder workOrder) {


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


                .orderByDesc(DeviceInfo::getUpdateTime)


                .last("limit 1")


                .list();


        if (CollectionUtils.isEmpty(gbDevices)) {


            return;


        }


        // 国标设备的编码就是取视频流的设备编码，国标设备就一个。国标设备的每一个通道代表一个摄像头，也就是设备id是取流的通道id


        String frameImg = null;


        try {


            log.info("国标平台:{},设备编码:{},工单号:{}",gbDevices.get(0).getDeviceId(), workOrder.getSerialNumber(), workOrder.getWorkOrderNo());


            frameImg = this.getFrameImgByDevice(gbDevices.get(0).getDeviceId(), workOrder.getSerialNumber(), workOrder.getWorkOrderNo());


        } catch (Exception e) {


            e.printStackTrace();


        }


        if (StringUtils.hasText(frameImg)) {


            WorkOrderCheckImg img = new WorkOrderCheckImg();


            img.setWorkOrderNo(workOrder.getWorkOrderNo());


            img.setImgUrl(frameImg);


            img.setCreateTime(new Date());


            workOrderCheckImgMapper.insert(img);


        }


    }


    @Override


    public List<WorkOrderYwConditionRecordVO> selectYwConditionByYwId(String workOrderNo) {


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


@@ -509,6 +568,9 @@


     */


    @Override


    public Result removeById(String id) {


        WorkOrder workOrder = baseMapper.selectById(id);


        String workOrderNo = workOrder.getWorkOrderNo();


        workOrderDistributeRecordMapper.deleteByWorkOrder(workOrderNo);


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


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


        }


@@ -524,9 +586,11 @@


    @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 -> {


@@ -544,6 +608,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());


    }


@@ -771,6 +837,7 @@


    @Override


    public synchronized 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);


        log.info("拿到取流图片响应结果：" + result);


        WVPResult wvpResult = JSON.parseObject(result, WVPResult.class);


@@ -971,22 +1038,10 @@


    @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.getEnd() == null) {


            query.setStart(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);


    }




    /**


@@ -1041,4 +1096,28 @@


        workOrderWhiteMapper.batchDelete(ids);


        return Result.ok();


    }




    /**


     * 批量导入白名单


     *


     * @param dataList 数据列表


     * @author


     */


    @Override


    public void batchImportWhite(List<PointExport> dataList) {


        // 获得所有需要新增的白名单对象


        List<WorkOrderWhite> whitelist = dataList.stream().map(pointExport ->


                        new WorkOrderWhite(pointExport.getSerialNumber(), pointExport.getPointName(), SecurityUtils.getUsername()))


                .collect(Collectors.toList());


        // 获得所有已存在的白名单设备编码


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


        // 筛选出新增、修改的白名单对象


        List<WorkOrderWhite> updateWhiteList = whitelist.stream().filter(white -> serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList());


        List<WorkOrderWhite> insertWhiteList = whitelist.stream().filter(white ->!serialNumbers.contains(white.getSerialNumber())).collect(Collectors.toList());


        // 新增/修改白名单设备记录


        updateWhiteList.stream().forEach(white -> workOrderWhiteMapper.updateBySerialNumber(white));


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


    }






}