package com.gkhy.safePlatform.safeCheck.service.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.gkhy.safePlatform.account.rpc.apimodel.AccountAuthService;
|
import com.gkhy.safePlatform.account.rpc.apimodel.model.resp.UserRPCRespDTO;
|
import com.gkhy.safePlatform.commons.co.ContextCacheUser;
|
import com.gkhy.safePlatform.commons.enums.E;
|
import com.gkhy.safePlatform.commons.exception.AusinessException;
|
import com.gkhy.safePlatform.commons.vo.ResultVO;
|
import com.gkhy.safePlatform.safeCheck.entity.AbnormalWorkOrder;
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckRfid;
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckTask;
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckTaskAndQuota;
|
import com.gkhy.safePlatform.safeCheck.enums.DelectStatusEnum;
|
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckSmartScreenRepsDTO;
|
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckTaskAndQuotaGBRfidAndExcpOrderRespDTO;
|
import com.gkhy.safePlatform.safeCheck.model.dto.resp.SafeCheckTaskAndQuotaRespDTO;
|
import com.gkhy.safePlatform.safeCheck.rpc.apimodel.model.resp.SafeCheckTaskAndQuotaExcepOrderRPCRespDTO;
|
import com.gkhy.safePlatform.safeCheck.rpc.apimodel.model.resp.SafeCheckTaskAndQuotaGBRfidAndExcpOrderRPCRespDTO;
|
import com.gkhy.safePlatform.safeCheck.service.SafeCheckMinioAccessService;
|
import com.gkhy.safePlatform.safeCheck.service.SafeCheckSmartScreenService;
|
import com.gkhy.safePlatform.safeCheck.service.baseService.AbnormalWorkOrderService;
|
import com.gkhy.safePlatform.safeCheck.service.baseService.SafeCheckRfidService;
|
import com.gkhy.safePlatform.safeCheck.service.baseService.SafeCheckTaskAndQuotaService;
|
import com.gkhy.safePlatform.safeCheck.service.baseService.SafeCheckTaskService;
|
import com.gkhy.safePlatform.safeCheck.util.UserInfoUtil;
|
import org.apache.commons.collections4.CollectionUtils;
|
import org.apache.dubbo.config.annotation.DubboReference;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.util.ArrayList;
|
import java.util.HashSet;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
@Service
|
public class SafeCheckSmartScreenServiceImpl implements SafeCheckSmartScreenService {
|
|
@DubboReference(check = false)
|
private AccountAuthService accountAuthService;
|
|
|
@Autowired
|
private SafeCheckTaskService taskService;
|
|
@Autowired
|
private SafeCheckTaskAndQuotaService taskAndQuotaService;
|
|
@Autowired
|
private SafeCheckRfidService safeCheckRfidService;
|
|
@Autowired
|
private AbnormalWorkOrderService abnormalWorkOrderService;
|
|
@Autowired
|
private SafeCheckMinioAccessService safeCheckMinioAccessService;
|
|
/**
|
* @description 根据巡检任务id获取所有的巡检链数据，对相同的rfid进行分组反馈
|
*/
|
@Transactional
|
@Override
|
public List<SafeCheckSmartScreenRepsDTO> getSmartScreenData(Long taskId) {
|
|
if (taskId == null){
|
throw new AusinessException(E.DATA_PARAM_NULL,"巡检任务id不能为空");
|
}
|
SafeCheckTask task = taskService.getTaskById(taskId);
|
if (task == null){
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT,"任务不存在");
|
}
|
List<SafeCheckTaskAndQuota> taskAndQuotasSource = taskAndQuotaService.listTaskAndQuotaByTaskId(taskId);
|
|
|
if (taskAndQuotasSource == null){
|
throw new AusinessException(E.DATA_DATABASE_NO_EXISTENT,"该任务无对应的巡检链数据");
|
}
|
List<SafeCheckTaskAndQuotaRespDTO> taskAndQuotas = taskAndQuotasSource.stream().map((taskAndQuotaSource)->{
|
SafeCheckTaskAndQuotaRespDTO taskAndQuota = new SafeCheckTaskAndQuotaRespDTO();
|
BeanUtils.copyProperties(taskAndQuotaSource,taskAndQuota);
|
return taskAndQuota;
|
}).collect(Collectors.toList());
|
|
|
List<SafeCheckSmartScreenRepsDTO> smartScreenDataS = new ArrayList<>();
|
//首先获取有哪些巡检点 利用set属性进行去重
|
HashSet<String> rfids = new HashSet<>();
|
|
for (SafeCheckTaskAndQuotaRespDTO taskAndQuota : taskAndQuotas) {
|
String rfid = taskAndQuota.getRfid();
|
rfids.add(rfid);
|
}
|
if (rfids.size() == 0){
|
return smartScreenDataS;
|
}
|
|
for (String rfid : rfids) {
|
SafeCheckSmartScreenRepsDTO smartScreenData = new SafeCheckSmartScreenRepsDTO();
|
List<SafeCheckTaskAndQuotaRespDTO> points = new ArrayList<>();
|
HashSet<String> regionNames = new HashSet<>();
|
for (int i = 0; i < taskAndQuotas.size(); i++) {
|
String sonRfid = taskAndQuotas.get(i).getRfid();
|
if (rfid.equals(sonRfid)){
|
if(smartScreenData.getRfid() == null){
|
SafeCheckRfid safeCheckRfid = safeCheckRfidService.getRfid(rfid, DelectStatusEnum.DELECT_NO.getStatus().intValue());
|
if (safeCheckRfid.getRfidImage() == null){
|
smartScreenData.setRfidImage(null);
|
}else {
|
String rfidImageAddress = safeCheckMinioAccessService.viewFile(safeCheckRfid.getRfidImage());
|
smartScreenData.setRfidImage(rfidImageAddress);
|
}
|
smartScreenData.setId(taskAndQuotas.get(i).getTaskId());
|
smartScreenData.setTaskUuid(taskAndQuotas.get(i).getTaskUuid());
|
smartScreenData.setRfid(taskAndQuotas.get(i).getRfid());
|
smartScreenData.setRfidName(taskAndQuotas.get(i).getRfidName());
|
}
|
regionNames.add(taskAndQuotas.get(i).getRegion());
|
points.add(taskAndQuotas.get(i));
|
smartScreenData.setPoints(points);
|
}
|
}
|
ArrayList<String> regions = new ArrayList<>();
|
for (String regionName : regionNames) {
|
if (regionName != null){
|
regions.add(regionName);
|
}
|
}
|
smartScreenData.setRegion(regions);
|
smartScreenDataS.add(smartScreenData);
|
}
|
return smartScreenDataS;
|
}
|
|
/**
|
* @description 根据巡检任务id获取该任务的异常工单信息
|
*/
|
@Override
|
public List<SafeCheckTaskAndQuotaExcepOrderRPCRespDTO> getSmartScreenExcepOrderInfos(Long taskId) {
|
LambdaQueryWrapper<AbnormalWorkOrder> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(AbnormalWorkOrder::getTaskId,taskId)
|
.orderByDesc(AbnormalWorkOrder::getOccurrenceTime);
|
List<AbnormalWorkOrder> abnormalWorkOrders = abnormalWorkOrderService.list(wrapper);
|
if (CollectionUtils.isEmpty(abnormalWorkOrders)){
|
return null;
|
}
|
List<SafeCheckTaskAndQuotaExcepOrderRPCRespDTO> dtos = abnormalWorkOrders.stream().map((abnormalWorkOrder) -> {
|
SafeCheckTaskAndQuotaExcepOrderRPCRespDTO excepOrderRPCRespDTO = new SafeCheckTaskAndQuotaExcepOrderRPCRespDTO();
|
BeanUtils.copyProperties(abnormalWorkOrder, excepOrderRPCRespDTO);
|
return excepOrderRPCRespDTO;
|
}).collect(Collectors.toList());
|
return dtos;
|
}
|
|
/**
|
* @description 根据巡检任务id获取所有的巡检链数据，对相同的rfid进行分组反馈 以及异常信息
|
*/
|
@Override
|
public SafeCheckTaskAndQuotaGBRfidAndExcpOrderRespDTO getSmartScreenDataAndExcOrderInfo(Long taskId) {
|
SafeCheckTaskAndQuotaGBRfidAndExcpOrderRespDTO dto = new SafeCheckTaskAndQuotaGBRfidAndExcpOrderRespDTO();
|
List<SafeCheckTaskAndQuotaExcepOrderRPCRespDTO> excepOrderInfos = getSmartScreenExcepOrderInfos(taskId);
|
List<SafeCheckSmartScreenRepsDTO> screenData = getSmartScreenData(taskId);
|
dto.setExcepOrder(excepOrderInfos);
|
dto.setRfidInfos(screenData);
|
return dto;
|
}
|
}
|
