zgyw.git - Gitblit

			@@ -8,6 +8,7 @@
			import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
			import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
			import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
			import com.github.pagehelper.util.StringUtil;
			import com.ycl.config.PlatformConfig;
			import com.ycl.exception.ServiceException;
			import com.ycl.platform.domain.entity.*;
			@@ -30,6 +31,7 @@
			import com.ycl.system.mapper.SysConfigMapper;
			import com.ycl.system.model.LoginUser;
			import com.ycl.system.page.PageUtil;
			import com.ycl.task.DeleteWorkOrderImgTask;
			import com.ycl.utils.DateUtils;
			import com.ycl.utils.SecurityUtils;
			import com.ycl.utils.http.HttpUtils;
			@@ -60,7 +62,9 @@
			import org.springframework.util.CollectionUtils;
			import org.springframework.util.StringUtils;
			import pojo.CascadeOption;
			import utils.file.FileUtils;

			import java.time.LocalDate;
			import java.time.LocalDateTime;
			import java.time.ZoneId;
			import java.util.*;
			@@ -104,6 +108,8 @@

			@Autowired
			private RedisCache redisCache;
			@Autowired
			private DeleteWorkOrderImgTask deleteWorkOrderImgTask;

			@Override
			public synchronized Boolean innerAddWorkOrder(List<WorkOrder> workOrderList) {
			@@ -215,6 +221,7 @@
			}
			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::getImportantCommandImageTag)
			.in(YwPoint::getSerialNumber, willAddSerialNumber)
			@@ -287,6 +294,7 @@
			}
			log.info("即将生成的工单:{}", workOrder);
			}

			redisCache.setCacheObject(RedisConstant.WORKORDER_NUM, workOrderNum);
			redisCache.releaseLock(RedisConstant.WORKORDER_NUM_LOCK, requestId);
			// 保存工单和故障类型
			@@ -605,9 +613,41 @@
			img.setWorkOrderNo(workOrder.getWorkOrderNo());
			img.setImgUrl(frameImg);
			img.setCreateTime(new Date());
			//保留最新的5张
			workOrderCheckImgMapper.insert(img);
			}
			}

			/**
			* 清理工单图片
			* */
			public void clearWorkOrderImg(String workOrderNo) {
			//判断该工单的图片是否已经大于5张了
			//按照创建日期降序排列
			if (StringUtil.isEmpty(workOrderNo)) {
			return;
			}
			List<WorkOrderCheckImg> workOrderList = new LambdaQueryChainWrapper<WorkOrderCheckImg>(workOrderCheckImgMapper)
			.select()
			.eq(WorkOrderCheckImg::getWorkOrderNo, workOrderNo)
			.orderByDesc(WorkOrderCheckImg::getCreateTime)
			.list();
			if (workOrderList.size()>=5){
			List<String> imgList = workOrderList.subList(4,workOrderList.size()).stream().map(WorkOrderCheckImg::getImgUrl).collect(Collectors.toList());
			List<Integer> idList = workOrderList.subList(4, workOrderList.size()).stream().map(WorkOrderCheckImg::getId).collect(Collectors.toList());
			//删除照片，并且物理删除服务器内对应照片的名字

			// /profile/2024-11-18_1d8e6d37-a4d0-4bba-8473-ff4e50eda83d.png
			log.error("删除工单照片集合url:{}",imgList);
			log.error("删除工单存储数据集合id:{}",idList);
			for (String filePath: imgList){
			delImgFormClient(filePath);
			}
			workOrderCheckImgMapper.deleteBatchIds(idList);
			}

			}


			@Override
			public List<WorkOrderYwConditionRecordVO> selectYwConditionByYwId(String workOrderNo) {
			@@ -650,9 +690,29 @@
			@Override
			public Result remove(List<String> ids) {
			if (baseMapper.deleteBatchIds(ids) > 0) {
			//批量删除是否被用到?

			return Result.ok("删除成功");
			}
			return Result.error("删除失败");
			}

			/***
			* 通过url删除服务器内的图片
			* @param url
			*/
			public void delImgFormClient(String url){
			//提取文件名 /profile/2024-11-17_79c02666-da1e-45ba-9f29-7523c848fa4a.png
			// 这部分2024-11-17_79c02666-da1e-45ba-9f29-7523c848fa4a.png
			String imgPath = FileUtils.getImgName(url);
			if (imgPath.isEmpty()){
			log.error("url错误：{}",imgPath);
			}else{
			//提取日期部分组装目录 : /opt/zgyw/uploadPath + / + yyyy-MM-dd +
			String pathName = DeleteWorkOrderImgTask.imgSaveBasePath + "/" + FileUtils.extractDateFromString(url);
			log.error("删除工单图片集合{}",pathName+"/" + imgPath);
			FileUtils.deleteFile(pathName+"/" + imgPath);
			}
			}

			/**
			@@ -667,6 +727,18 @@
			String workOrderNo = workOrder.getWorkOrderNo();
			//删除工单审核记录
			workOrderAuditingRecordMapper.delete(new QueryWrapper<WorkOrderAuditingRecord>().eq("work_order_no", workOrderNo));
			//需要物理删除服务器中的图片
			//查询到工单照片集合
			List<String> workOrderImg = workOrderCheckImgMapper
			.selectList(new QueryWrapper<WorkOrderCheckImg>().eq("work_order_no", workOrderNo))
			.stream().map(WorkOrderCheckImg::getImgUrl).collect(Collectors.toList());
			log.error("删除工单图片集合:{}",workOrderImg);
			log.error("删除路径:{}",PlatformConfig.getUploadPath());

			for (String filePath: workOrderImg){
			delImgFormClient(filePath);
			}

			//删除工单图片记录
			workOrderCheckImgMapper.delete(new QueryWrapper<WorkOrderCheckImg>().eq("work_order_no", workOrderNo));
			//删除工单下发记录
			@@ -681,6 +753,9 @@
			}
			return Result.error("删除失败");
			}




			/**
			* 分页查询
			@@ -745,6 +820,11 @@
			}

			@Override
			public List<WorkOrderVO> distributeList(){
			return baseMapper.distributeList();
			}

			@Override
			@Transactional
			public Result distributeFast(DistributeWorkOrderVO data) {
			// 获取当前时间
			@@ -800,6 +880,9 @@
			distributeUnLock();
			}
			}




			@Override
			@Transactional
			@@ -1147,6 +1230,11 @@
			@Override
			public Result detailByNo(String workOrderNo) {
			WorkOrderDetailVO workOrder = baseMapper.detailByNo(workOrderNo);
			//报空原因1. sql 中 inner join 表 t_work_order_distribute_record 中无与该表关联的记录 wo.work_order_no = dr.work_order_no
			if(workOrder == null){
			workOrder = baseMapper.detailByNoButNoDistributeRecord(workOrderNo);
			}

			// 是否报备
			boolean hasReport = new LambdaQueryChainWrapper<>(reportMapper)
			.eq(Report::getSerialNumber, workOrder.getSerialNumber())
			@@ -1156,6 +1244,8 @@
			List<SysDictData> errorList = workOrderErrorTypeService.getBaseMapper().getErrorList(workOrder.getWorkOrderNo());
			List<String> errList = errorList.stream().map(SysDictData::getDictLabel).collect(Collectors.toList());
			workOrder.setErrorTypeList(errList);
			//详情时再次清理
			clearWorkOrderImg(workOrderNo);
			// 检测图片
			List<WorkOrderCheckImg> imgList = new LambdaQueryChainWrapper<>(workOrderCheckImgMapper)
			.eq(WorkOrderCheckImg::getWorkOrderNo, workOrderNo)
			@@ -1165,6 +1255,9 @@
			workOrder.setImgList(imgList);
			return Result.ok().data(workOrder);
			}

			@Autowired
			private WorkOrderMapper workOrderMapper;

			/**
			* 工单导出的逻辑
			@@ -1195,6 +1288,30 @@
			query.setErrorTypeList(errorTypeList);
			}
			List<WorkOrderVO> export = baseMapper.export(query);


			List<String> workOrderNos = export.stream().map(WorkOrderVO::getWorkOrderNo).collect(Collectors.toList());
			List<WorkOrderVO> auditTimeList = workOrderMapper.getAuditTimeList(workOrderNos);
			Map<String, List<Date>> auditTimeMap = auditTimeList.stream()
			.collect(Collectors.groupingBy(
			WorkOrderVO::getWorkOrderNo, // 分组的键
			Collectors.mapping(WorkOrderVO::getAuditTime, Collectors.toList())));
			if (!CollectionUtils.isEmpty(workOrderNos)){
			export.forEach(workOrderVO -> {
			List<Date> auditTimes = auditTimeMap.get(workOrderVO.getWorkOrderNo());
			if (!CollectionUtils.isEmpty(auditTimes)){
			//审核通过时间
			Date passTime = Collections.max(auditTimes);
			ZoneId zoneId = ZoneId.systemDefault();
			workOrderVO.setPassTime(passTime.toInstant().atZone(zoneId).toLocalDateTime());
			}
			});
			}





			if (CollectionUtils.isEmpty(export)) return new ArrayList<WorkOrderVO>();
			List<String> ips = export.stream().map(WorkOrderVO::getIp).collect(Collectors.toList());
			//查出相同ip的设备、并查出标签