package com.ruoyi.system.service.impl;
|
|
import com.alibaba.fastjson2.JSONArray;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.ruoyi.system.mapper.ProjectInfoMapper;
|
import com.ruoyi.system.model.Project;
|
import com.ruoyi.system.model.ProjectInfo;
|
import com.ruoyi.system.model.Record;
|
import com.ruoyi.system.model.Task;
|
import com.ruoyi.system.query.ProjectDangerousTrendQuery;
|
import com.ruoyi.system.query.ProjectHiddenDangerTrendListQuery;
|
import com.ruoyi.system.service.*;
|
import com.ruoyi.system.vo.ProjectDangerousTrendVo;
|
import com.ruoyi.system.vo.ProjectHiddenDangerList;
|
import com.ruoyi.system.vo.ProjectHiddenDangerNextList;
|
import com.ruoyi.system.vo.ProjectHiddenDangerTrendVo;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
|
import java.math.BigDecimal;
|
import java.math.RoundingMode;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDate;
|
import java.time.YearMonth;
|
import java.time.temporal.ChronoUnit;
|
import java.time.temporal.TemporalAdjusters;
|
import java.util.*;
|
|
import static java.util.stream.Collectors.groupingBy;
|
|
/**
|
* <p>
|
* 服务实现类
|
* </p>
|
*
|
* @author l
|
* @since 2026-01-12
|
*/
|
@Service
|
public class ProjectInfoServiceImpl extends ServiceImpl<ProjectInfoMapper, ProjectInfo> implements ProjectInfoService {
|
|
|
@Autowired
|
private ProjectCategoryCalculator projectCategoryCalculator;
|
|
@Autowired
|
private ProjectService projectService;
|
|
@Autowired
|
private TaskService taskService;
|
|
@Autowired
|
private RecordService recordService;
|
|
@Override
|
public List<ProjectHiddenDangerTrendVo> getProjectHiddenDangerTrend(Integer projectId) {
|
|
|
List<ProjectHiddenDangerTrendVo> resultList = new ArrayList<>();
|
// 找出最近的的2个计划任务
|
List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getProjectId, projectId).in(Task::getState, Arrays.asList(3,7)).orderByDesc(Task::getCreateTime).last("limit 2"));
|
if(tasks.size()==1){
|
Task task = tasks.get(0);
|
List<Record> list0 = recordService.list(new LambdaQueryWrapper<Record>().eq(Record::getCheckTaskId, task.getId()));
|
for (Record record : list0) {
|
String hierarchyNames = record.getHierarchyNames();
|
JSONArray jsonArray = JSONArray.parseArray(hierarchyNames);
|
if(record.getDeviceId()!=null){
|
// 取出倒数第3个
|
String name = jsonArray.getString(jsonArray.size()-3);
|
|
record.setHierarchyName( name);
|
}else {
|
// 取出倒数第4个
|
String name = jsonArray.getString(jsonArray.size()-4);
|
|
record.setHierarchyName( name);
|
record.setCategory(1);
|
}
|
|
|
}
|
|
|
Map<String, List<Record>> map = list0.stream().collect(groupingBy(Record::getHierarchyName));
|
for (Map.Entry<String, List<Record>> entry : map.entrySet()) {
|
ProjectHiddenDangerTrendVo vo = new ProjectHiddenDangerTrendVo();
|
vo.setName(entry.getKey());
|
List<Record> value = entry.getValue();
|
long count = value.stream().filter(record -> record.getCategory()==1).count();
|
// 根据value集合中的createTime 选出本月的数据
|
vo.setThisMonth((int) count);
|
vo.setLastMonth(0);
|
|
int num = vo.getThisMonth() - vo.getLastMonth();
|
if (num != 0) {
|
if(vo.getLastMonth()>0){
|
Double rate = BigDecimal.valueOf(num).divide(BigDecimal.valueOf(vo.getLastMonth()), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).doubleValue();
|
vo.setRate(rate);
|
}else {
|
vo.setRate(100.00d);
|
}
|
}else {
|
vo.setRate(0.00d);
|
}
|
resultList.add(vo) ;
|
}
|
|
}
|
if(tasks.size()==2){
|
Task task0 = tasks.get(0);
|
List<Record> list0 = recordService.list(new LambdaQueryWrapper<Record>().eq(Record::getCheckTaskId, task0.getId()));
|
for (Record record : list0) {
|
String hierarchyNames = record.getHierarchyNames();
|
JSONArray jsonArray = JSONArray.parseArray(hierarchyNames);
|
if(record.getDeviceId()!=null){
|
// 取出倒数第3个
|
String name = jsonArray.getString(jsonArray.size()-3);
|
|
record.setHierarchyName( name);
|
}else {
|
// 取出倒数第4个
|
String name = jsonArray.getString(jsonArray.size()-4);
|
|
record.setHierarchyName( name);
|
record.setCategory(1);
|
}
|
|
|
}
|
|
|
Task task1 = tasks.get(1);
|
List<Record> list1 = recordService.list(new LambdaQueryWrapper<Record>().eq(Record::getCheckTaskId, task1.getId()));
|
for (Record record : list1) {
|
String hierarchyNames = record.getHierarchyNames();
|
JSONArray jsonArray = JSONArray.parseArray(hierarchyNames);
|
if(record.getDeviceId()!=null){
|
// 取出倒数第3个
|
String name = jsonArray.getString(jsonArray.size()-3);
|
|
record.setHierarchyName( name);
|
}else {
|
// 取出倒数第4个
|
String name = jsonArray.getString(jsonArray.size()-4);
|
|
record.setHierarchyName( name);
|
record.setCategory(2);
|
}
|
}
|
list0.addAll(list1);
|
|
|
Map<String, List<Record>> map = list0.stream().collect(groupingBy(Record::getHierarchyName));
|
for (Map.Entry<String, List<Record>> entry : map.entrySet()) {
|
ProjectHiddenDangerTrendVo vo = new ProjectHiddenDangerTrendVo();
|
vo.setName(entry.getKey());
|
List<Record> value = entry.getValue();
|
long count = value.stream().filter(record -> record.getCategory()==1).count();
|
// 根据value集合中的createTime 选出本月的数据
|
vo.setThisMonth((int) count);
|
vo.setLastMonth(value.size()-(int) count);
|
|
int num = vo.getThisMonth() - vo.getLastMonth();
|
if (num != 0) {
|
if(vo.getLastMonth()>0){
|
Double rate = BigDecimal.valueOf(num).divide(BigDecimal.valueOf(vo.getLastMonth()), 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)).setScale(2, RoundingMode.HALF_UP).doubleValue();
|
vo.setRate(rate);
|
}else {
|
vo.setRate(100.00d);
|
}
|
}else {
|
vo.setRate(0.00d);
|
}
|
resultList.add(vo) ;
|
}
|
|
}
|
|
|
|
return resultList;
|
|
|
|
|
}
|
|
@Override
|
public List<ProjectHiddenDangerList> getProjectHiddenDangerTrendList(ProjectHiddenDangerTrendListQuery query) {
|
List<Record> list = this.baseMapper.getProjectHiddenDangerTrend(query.getProjectId(),getMonthBoundaries(query.getStartTime(),true)+" 00:00:00",getMonthBoundaries(query.getEndTime(),false)+" 23:59:59");
|
for (Record record : list) {
|
String hierarchyNames = record.getHierarchyNames();
|
JSONArray jsonArray = JSONArray.parseArray(hierarchyNames);
|
if(record.getDeviceId()!=null){
|
// 取出倒数第3个
|
String name = jsonArray.getString(jsonArray.size()-3);
|
|
record.setHierarchyName( name);
|
}else {
|
// 取出倒数第4个
|
String name = jsonArray.getString(jsonArray.size()-4);
|
|
record.setHierarchyName( name);
|
}
|
|
}
|
|
// 算出跨度几个月
|
int months = calculateMonthsBetween(query.getStartTime(),query.getEndTime());
|
|
|
ArrayList<ProjectHiddenDangerList> projectHiddenDangerLists = new ArrayList<>();
|
|
Map<String, List<Record>> map = list.stream().collect(groupingBy(Record::getHierarchyName));
|
for (Map.Entry<String, List<Record>> stringListEntry : map.entrySet()) {
|
String key = stringListEntry.getKey();
|
if(query.getContent()!=null && !query.getContent().isEmpty()){
|
if(!key.contains( query.getContent())){
|
continue;
|
}
|
}
|
|
List<Record> value = stringListEntry.getValue();
|
ProjectHiddenDangerList projectHiddenDangerList1 = new ProjectHiddenDangerList();
|
projectHiddenDangerList1.setName(key);
|
ArrayList<ProjectHiddenDangerNextList> projectHiddenDangerNextLists = new ArrayList<>();
|
for (int i = 0; i < months; i++) {
|
ProjectHiddenDangerNextList projectHiddenDangerNextList = new ProjectHiddenDangerNextList();
|
LocalDate localDate = getMonthBoundaries(query.getStartTime(), true).plusMonths(i);
|
String dateStr = localDate.toString().substring(0, 7);
|
long count = value.stream().filter(record -> record.getCreateTime().toString().contains(dateStr)).count();
|
ProjectHiddenDangerList projectHiddenDangerList = new ProjectHiddenDangerList();
|
projectHiddenDangerList.setName(key);
|
projectHiddenDangerNextList.setTime(dateStr);
|
projectHiddenDangerNextList.setNum((int) count);
|
projectHiddenDangerNextLists.add(projectHiddenDangerNextList);
|
}
|
projectHiddenDangerList1.setList(projectHiddenDangerNextLists);
|
projectHiddenDangerLists.add(projectHiddenDangerList1);
|
}
|
|
return projectHiddenDangerLists;
|
|
}
|
|
@Override
|
public List<ProjectDangerousTrendVo> getProjectDangerousTrend(ProjectDangerousTrendQuery query) {
|
List<ProjectDangerousTrendVo> list = new ArrayList<>();
|
Project project = projectService.getById(query.getProjectId());
|
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
|
// 算出跨度几个月
|
int months = calculateMonthsBetween(query.getStartTime(),query.getEndTime());
|
ArrayList<Project> projects = new ArrayList<>();
|
projects.add( project);
|
String temp=null;
|
try {
|
for (int i = 0; i < months; i++) {
|
ProjectDangerousTrendVo vo = new ProjectDangerousTrendVo();
|
LocalDate localDate = getMonthBoundaries(query.getStartTime(), true).plusMonths(i);
|
String dateStr = localDate.toString().substring(0, 7);
|
String start = localDate+" 00:00:00";
|
String end = getMonthBoundaries(query.getStartTime(), false).plusMonths(i)+" 23:59:59";
|
Date startDate = simpleDateFormat.parse(start);
|
Date endDate = simpleDateFormat.parse(end);
|
vo.setTime(dateStr);
|
|
if(project.getType()==2){
|
Map<Integer, String> integerStringMap = projectCategoryCalculator.calculateFixedAssetCategories(projects, Long.valueOf(project.getClientId()), startDate, endDate);
|
String s = integerStringMap.get(query.getProjectId());
|
vo.setLevel(s);
|
if(integerStringMap.isEmpty()){
|
vo.setStatus(2);
|
}
|
}else {
|
Map<Integer, String> integerStringMap = projectCategoryCalculator.calculateOngoingProjectCategories(projects, Long.valueOf(project.getClientId()), startDate, endDate);
|
String s = integerStringMap.get(query.getProjectId());
|
vo.setLevel(s);
|
if(integerStringMap.isEmpty()){
|
vo.setStatus(2);
|
}
|
}
|
// 如果没有则沿用上次的
|
if(vo.getLevel()!=null){
|
temp=vo.getLevel();
|
}else {
|
vo.setLevel(temp);
|
}
|
list.add( vo);
|
}
|
}catch (ParseException e){
|
e.printStackTrace();
|
}
|
|
return list;
|
}
|
|
|
public static LocalDate getMonthBoundaries(String yearMonthStr,boolean isInclusive) {
|
// 解析字符串为YearMonth
|
YearMonth yearMonth = YearMonth.parse(yearMonthStr);
|
if(isInclusive){
|
// 获取第一天
|
LocalDate firstDay = yearMonth.atDay(1);
|
return firstDay;
|
}else {
|
// 获取最后一天
|
LocalDate lastDay = yearMonth.atEndOfMonth();
|
return lastDay;
|
}
|
}
|
|
|
|
public static int calculateMonthsBetween(String startYearMonth, String endYearMonth) {
|
YearMonth start = YearMonth.parse(startYearMonth);
|
YearMonth end = YearMonth.parse(endYearMonth);
|
|
// 计算月份差 + 1（包含结束月份）
|
return (int) ChronoUnit.MONTHS.between(start, end) + 1;
|
}
|
}
|
