package com.gkhy.safePlatform.safeCheck.service.baseService.impl;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.gkhy.safePlatform.commons.enums.E;
|
import com.gkhy.safePlatform.commons.exception.AusinessException;
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckTask;
|
import com.gkhy.safePlatform.safeCheck.entity.SafeCheckTaskAndQuota;
|
import com.gkhy.safePlatform.safeCheck.entity.WorkOrderRelatedDataDO;
|
import com.gkhy.safePlatform.safeCheck.enums.TaskResultEnum;
|
import com.gkhy.safePlatform.safeCheck.repository.SafeCheckTaskAndQuotaRepository;
|
import com.gkhy.safePlatform.safeCheck.service.baseService.SafeCheckTaskAndQuotaService;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.util.Date;
|
import java.util.List;
|
|
|
@Service("SafeCheckTaskAndQuotaService")
|
public class SafeCheckTaskAndQuotaServiceImpl extends ServiceImpl<SafeCheckTaskAndQuotaRepository, SafeCheckTaskAndQuota> implements SafeCheckTaskAndQuotaService {
|
|
@Autowired
|
private SafeCheckTaskAndQuotaRepository safeCheckTaskAndQuotaRepository;
|
/**
|
* @description 将任务关联的指标插入到任务指标关联表中
|
*/
|
@Override
|
public int saveTaskAndQuotas(List<SafeCheckTaskAndQuota> taskAndQuotas) {
|
int insertResult = safeCheckTaskAndQuotaRepository.saveTaskAndQuotas(taskAndQuotas);
|
return insertResult;
|
}
|
|
/**
|
* @description 根据任务id查询该任务下所有的巡检点检查结果
|
*/
|
@Override
|
public Page listTaskAndQuotaByPage(Page pageInfo, Long taskId) {
|
LambdaQueryWrapper<SafeCheckTaskAndQuota> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(taskId != null,SafeCheckTaskAndQuota::getTaskId,taskId);
|
Page page = safeCheckTaskAndQuotaRepository.selectPage(pageInfo,queryWrapper);
|
return page;
|
}
|
|
/**
|
* @description 根据任务与巡检点关联表查询数据
|
*/
|
@Override
|
public SafeCheckTaskAndQuota getTaskAndQuotaById(int taskAndQuotaId) {
|
SafeCheckTaskAndQuota safeCheckTaskAndQuota = safeCheckTaskAndQuotaRepository.getTaskAndQuotaById(taskAndQuotaId);
|
return safeCheckTaskAndQuota;
|
}
|
|
/**
|
* @description 将任务关联的巡检点rfid相同的数据rfid定位状态都改为已定位
|
*/
|
@Override
|
public int updateRfidPositionStatusByTaskIdAndRfid(Long taskId, String rfid,Byte rifdPositionStatus) {
|
int updateResult = safeCheckTaskAndQuotaRepository.updateRfidPositionStatusByTaskIdAndRfid(taskId,rfid,rifdPositionStatus);
|
if (updateResult == 0){
|
throw new AusinessException(E.UPDATE_FAIL,"任务关联巡检点定位状态更新失败");
|
}
|
return updateResult;
|
}
|
|
/**
|
* @description 统计同一个任务的巡检点rfid相同的数量
|
*/
|
@Override
|
public int countRfidSameByTaskId(Long taskId, String rfid) {
|
int countResult = safeCheckTaskAndQuotaRepository.countRfidSameByTaskId(taskId,rfid);
|
return countResult;
|
}
|
|
/**
|
* @description 将巡检点检查结果信息进行修改
|
*/
|
@Override
|
public void updatePointCheckResultByIdAndTaskId(SafeCheckTaskAndQuota safeCheckTaskAndQuota) {
|
int updateResult = safeCheckTaskAndQuotaRepository.updatePointCheckResultByIdAndTaskId(safeCheckTaskAndQuota);
|
if (updateResult == 0){
|
throw new AusinessException(E.UPDATE_FAIL,"巡检点巡检结果更新失败");
|
}
|
|
}
|
|
/**
|
* @description 查询该任务下巡检点是否还有没有定位的
|
*/
|
@Override
|
public List<String> selectNoRfidPositionByTaskId(Long taskId) {
|
List<String> points = safeCheckTaskAndQuotaRepository.selectNoRfidPositionByTaskId(taskId);
|
return points;
|
}
|
|
/**
|
* @description 查询该任务下巡检点是否还有没提交的
|
*/
|
@Override
|
public List<String> selectRfidNoReportByTaskId(Long taskId) {
|
List<String> points = safeCheckTaskAndQuotaRepository.selectRfidNoReportByTaskId(taskId);
|
return points;
|
}
|
|
/**
|
* @description 统计巡检点中是否存在巡检异常的数据
|
*/
|
@Override
|
public int countRfidReportIsAbnormalByTaskId(Long taskId,Byte reportResult) {
|
int countResult = safeCheckTaskAndQuotaRepository.countRfidReportIsAbnormalByTaskId(taskId,reportResult);
|
return countResult;
|
}
|
|
/**
|
* @description 根据任务id查询所有的巡检链数据
|
*/
|
@Override
|
public List<SafeCheckTaskAndQuota> listTaskAndQuotaByTaskId(Long taskId) {
|
List<SafeCheckTaskAndQuota> taskAndQuotas = safeCheckTaskAndQuotaRepository.listTaskAndQuotaByTaskId(taskId);
|
return taskAndQuotas;
|
}
|
|
/**
|
* @description 根据任务id和巡检点对应的id查询巡检记录
|
*/
|
@Override
|
public SafeCheckTaskAndQuota getTaskAndQuotaByIdAndTaskId(int id, Long taskId) {
|
SafeCheckTaskAndQuota safeCheckTaskAndQuota = safeCheckTaskAndQuotaRepository.getTaskAndQuotaByIdAndTaskId(id,taskId);
|
return safeCheckTaskAndQuota;
|
}
|
|
/**
|
* 根据巡检指标id查询所有相关的数据rifd、region、point
|
*/
|
@Override
|
public WorkOrderRelatedDataDO getWorkOrderRelatedData(int id) {
|
return safeCheckTaskAndQuotaRepository.getWorkOrderRelatedData(id);
|
}
|
}
|
