zgyw.git - Gitblit

			@@ -1,5 +1,6 @@
			package com.ycl.platform.service.impl;

			import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
			import com.baomidou.mybatisplus.core.metadata.IPage;
			import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
			import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;
			@@ -8,21 +9,34 @@
			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.vo.DistributeWorkOrderVO;
			import com.ycl.platform.domain.vo.WorkOrderVO;
			import com.ycl.platform.mapper.*;
			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.service.NotifyService;
			import com.ycl.platform.service.WorkOrderAuditingRecordService;
			import com.ycl.platform.service.WorkOrderService;
			import com.ycl.platform.service.YwPointService;
			import com.ycl.system.Result;
			import com.ycl.system.model.LoginUser;
			import com.ycl.system.page.PageUtil;
			import com.ycl.utils.DateUtils;
			import com.ycl.utils.SecurityUtils;
			import com.ycl.utils.redis.RedisCache;
			import enumeration.general.*;
			import com.ycl.utils.uuid.IdUtils;
			import enumeration.general.NotifyTypeEnum;
			import enumeration.general.UrgentLevelEnum;
			import enumeration.general.WorkOrderDistributeWayEnum;
			import enumeration.general.WorkOrderStatusEnum;
			import lombok.RequiredArgsConstructor;
			import org.apache.commons.lang3.ArrayUtils;
			import org.apache.commons.lang3.ObjectUtils;
			import org.springframework.beans.BeanUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.stereotype.Service;
			@@ -32,9 +46,7 @@

			import java.time.LocalDateTime;
			import java.time.ZoneId;
			import java.util.List;
			import java.util.Objects;
			import java.util.concurrent.TimeUnit;
			import java.util.*;
			import java.util.stream.Collectors;

			/**
			@@ -48,14 +60,15 @@
			public class WorkOrderServiceImpl extends ServiceImpl<WorkOrderMapper, WorkOrder> implements WorkOrderService {

			private final WorkOrderMapper workOrderMapper;
			private final YwUnitMapper ywUnitMapper;
			private final YwPeopleMapper ywPeopleMapper;
			private final YwPointService ywPointService;
			private final WorkOrderAuditingRecordMapper workOrderAuditingRecordMapper;
			private final WorkOrderAuditingRecordService workOrderAuditingRecordService;
			private final WorkOrderYwConditionRecordMapper workOrderYwConditionRecordMapper;
			private final NotifyService notifyService;
			private final WorkOrderDistributeRecordMapper workOrderDistributeRecordMapper;

			private final String DISTRIBUTE_LOCK_KEY = "distributeLock";
			private final static String IMPORTANT = "important";

			@Autowired
			private RedisCache redisCache;
			@@ -68,10 +81,9 @@
			@Override
			public Result add(WorkOrderForm form) {
			WorkOrder entity = WorkOrderForm.getEntityByForm(form, null);
			entity.setWorkOrderNo(DateUtils.dateTimeNow());
			entity.setWorkOrderNo(IdUtils.timeAddRandomNO(5));
			entity.setCreateTime(DateUtils.getNowDate());
			entity.setStatus(WorkOrderStatusEnum.WAIT_DISTRIBUTE);
			entity.setDeleted("0");
			if(baseMapper.insert(entity) > 0) {
			return Result.ok("添加成功");
			}
			@@ -118,6 +130,53 @@
			UrgentLevelEnum.WARNING,
			workOrder.getWorkOrderNo());
			notifyService.save(notify);
			// 同步点位状态
			if (form.getAuditingResult() == WorkOrderStatusEnum.AUDITING_SUCCESS) {
			ywPointService.updateRecovery(Collections.singletonList(workOrder.getPointId()), 0);
			}
			return Result.ok("操作成功");
			}

			@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)
			.list();
			if (list.isEmpty()) {
			return Result.error("没有工单可以审核");
			}
			List<Integer> ids = list.stream().map(WorkOrder::getId).collect(Collectors.toList());
			// 工单状态
			LambdaUpdateWrapper<WorkOrder> lambdaUpdateWrapper = new LambdaUpdateWrapper<>();
			lambdaUpdateWrapper.in(WorkOrder::getId, ids);
			lambdaUpdateWrapper.set(WorkOrder::getStatus, form.getAuditingResult());
			baseMapper.update(lambdaUpdateWrapper);
			// 添加多条审核记录
			List<WorkOrderAuditingRecord> workOrderAuditingRecords = new ArrayList<>();
			for (Integer id : ids) {
			WorkOrderAuditingRecord workOrderAuditingRecord = new WorkOrderAuditingRecord();
			workOrderAuditingRecord.setWorkOrderId(id);
			workOrderAuditingRecord.setAuditingUser(SecurityUtils.getLoginUser().getUserId().intValue());
			workOrderAuditingRecord.setResult(form.getAuditingResult().getDesc());
			workOrderAuditingRecord.setRemark(form.getAuditingRemark());
			workOrderAuditingRecords.add(workOrderAuditingRecord);
			}
			workOrderAuditingRecordService.saveBatch(workOrderAuditingRecords);
			// 添加新通知
			List<Notify> notifies = new ArrayList<>();
			for (WorkOrder workOrder : list) {
			Notify notify = Notify.genEntityByUnit(NotifyTypeEnum.WORK_ORDER,
			form.getAuditingResult().getDesc(),
			workOrder.getUnitId(),
			UrgentLevelEnum.WARNING,
			workOrder.getWorkOrderNo());
			notifies.add(notify);
			}
			notifyService.saveBatch(notifies);
			return Result.ok("操作成功");
			}

			@@ -143,22 +202,9 @@
			}

			@Override
			public Result selectYwConditionByYwId(String id) {
			return Result.ok().data(
			new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)
			.eq(WorkOrderYwConditionRecord::getWorkOrderId, id)
			.orderByAsc(WorkOrderYwConditionRecord::getCreateTime)
			.last("limit 1")
			.one());
			}

			@Override
			public Result selectYwConditionListByYwId(String id) {
			return Result.ok().data(
			new LambdaQueryChainWrapper<>(workOrderYwConditionRecordMapper)
			.eq(WorkOrderYwConditionRecord::getWorkOrderId, id)
			.orderByAsc(WorkOrderYwConditionRecord::getCreateTime)
			.list());
			public Result selectYwConditionByYwId(Integer id) {
			List<WorkOrderYwConditionRecordVO> ywConditionList = workOrderYwConditionRecordMapper.selectYwConditionByYwId(id);
			return Result.ok().data(ywConditionList);
			}

			@Override
			@@ -222,57 +268,58 @@
			public Result distributePage(DistributeWorkOrderQuery query) {
			IPage<WorkOrderVO> page = PageUtil.getPage(query, WorkOrderVO.class);
			baseMapper.distributePage(page, query);
			page.getRecords().stream().forEach(workOrder -> {
			if (StringUtils.hasText(workOrder.getPointTag()) && workOrder.getPointTag().contains(IMPORTANT)) {
			workOrder.setImportant(Boolean.TRUE);
			}
			});
			return Result.ok().data(page).total(page.getTotal());
			}

			@Override
			@Transactional
			public Result distributeFast(DistributeWorkOrderVO data) {
			// 获取当前时间
			LocalDateTime now = LocalDateTime.now(ZoneId.systemDefault());
			data.setEnd(now);
			switch (data.getFastWay()) {
			case LAST_HALF_HOUR:
			data.setStart(now.minusMinutes(30));
			data.setEnd(now);
			break;
			case LAST_HOUR:
			data.setStart(now.minusHours(1));
			data.setEnd(now);
			break;
			case LAST_TWO_HOUR:
			data.setStart(now.minusHours(2));
			data.setEnd(now);
			break;
			case LAST_DAY:
			data.setStart(now.minusDays(1));
			data.setEnd(now);
			break;
			}

			// 查询符合条件的工单
			List<Integer> ids = new LambdaQueryChainWrapper<>(baseMapper)
			List<WorkOrder> list = new LambdaQueryChainWrapper<>(baseMapper)
			.select(WorkOrder::getId, WorkOrder::getPointId)
			.eq(WorkOrder::getStatus, WorkOrderStatusEnum.WAIT_DISTRIBUTE)
			.eq(Objects.nonNull(data.getUnitId()), WorkOrder::getUnitId, data.getUnitId())
			.eq(WorkOrder::getErrorType, data.getErrorType())
			.between(WorkOrder::getCreateTime, data.getStart(), data.getEnd())
			.orderByDesc(WorkOrder::getCreateTime)
			.last("limit " + data.getFastNumLimit())
			.list()
			.stream()
			.map(WorkOrder::getId)
			.toList();
			.list();
			List<Integer> ids = list.stream().map(WorkOrder::getId).toList();
			List<Integer> pointIds = list.stream().map(WorkOrder::getPointId).toList();

			if (ids.isEmpty()) {
			return Result.error("没有符合条件的工单");
			}
			if (!getDistributeLock()) {
			return Result.error("此刻有人下发中，为避免冲突，请稍后重试");
			}
			if (ids.isEmpty()) { return Result.error("没有符合条件的工单"); }
			if (!getDistributeLock()) { return Result.error("此刻有人下发中，为避免冲突，请稍后重试"); }
			try {
			new LambdaUpdateChainWrapper<>(baseMapper)
			.set(WorkOrder::getStatus, WorkOrderStatusEnum.DISTRIBUTED)
			.in(WorkOrder::getId, ids)
			.update();
			addDistributeRecord(ids, WorkOrderDistributeWayEnum.FAST_DISTRIBUTE);
			// 同步点位状态
			ywPointService.updateRecovery(pointIds, 1);
			return Result.ok("成功下发" + ids.size() + "条工单");
			} catch (Exception e) {
			return Result.error("操作失败");
			@@ -282,11 +329,10 @@
			}

			@Override
			@Transactional
			public Result selectedIdsDistribute(DistributeWorkOrderQuery query) {
			WorkOrderDistributeWayEnum distributeWayEnum = WorkOrderDistributeWayEnum.SELECTED_DISTRIBUTE;
			if (!getDistributeLock()) {
			return Result.error("此刻有人下发中，为避免冲突，请稍后重试");
			}
			if (!getDistributeLock()) { return Result.error("此刻有人下发中，为避免冲突，请稍后重试"); }
			try {
			if (query.getIds().isEmpty()) {
			query.setIds(new LambdaQueryChainWrapper<>(baseMapper)
			@@ -299,14 +345,15 @@
			.collect(Collectors.toList()));
			distributeWayEnum = WorkOrderDistributeWayEnum.ALL_DISTRIBUTE;
			}
			if (query.getIds().isEmpty()) {
			return Result.error("没有工单待下发");
			}
			if (query.getIds().isEmpty()) { return Result.error("没有工单待下发"); }
			new LambdaUpdateChainWrapper<>(baseMapper)
			.set(WorkOrder::getStatus, WorkOrderStatusEnum.DISTRIBUTED)
			.in(WorkOrder::getId, query.getIds())
			.update();
			addDistributeRecord(query.getIds(), distributeWayEnum);
			// 同步点位状态
			List<Integer> pointIds = new LambdaQueryChainWrapper<>(baseMapper).select(WorkOrder::getPointId).in(WorkOrder::getId, query.getIds()).list().stream().map(WorkOrder::getPointId).toList();
			ywPointService.updateRecovery(pointIds, 1);
			return Result.ok("成功下发" + query.getIds().size() + "条工单");
			} catch (Exception e) {
			return Result.error("操作失败");
			@@ -376,4 +423,33 @@
			.collect(Collectors.toList());
			return Result.ok().data(vos);
			}

			@Override
			public Result screenWorkOrder(ScreenQuery query) {
			ScreenWorkOrderVO screen = baseMapper.screenWorkOrder(query);
			return Result.ok().data(screen);
			}

			@Override
			public Map<String, Object> home(HomeQuery monitorQuery) {
			Map<String, Object> dataMap = new HashMap<>();
			Map<String, Object> data1 = new HashMap<>();
			Map<String, Object> data2 = new HashMap<>();
			Map<String, Object> data3 = new HashMap<>();
			List<Map<String, Object>> home = baseMapper.home(monitorQuery);
			if (ObjectUtils.isNotEmpty(home)) {
			for (Map<String, Object> map : home) {
			if (Objects.nonNull(map.get("dateType")) && StringUtils.hasText(map.get("dateType").toString())) {
			data1.put(map.get("dateType").toString(), map.get("num1"));
			data2.put(map.get("dateType").toString(), map.get("num2"));
			data3.put(map.get("dateType").toString(), map.get("num3"));
			}
			}
			dataMap.put("name", home.get(0).get("name"));
			}
			dataMap.put("complete", data1);
			dataMap.put("waiting", data2);
			dataMap.put("pending", data3);
			return dataMap;
			}
			}