package com.yssh.service.impl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.yssh.dao.DictRecordMapper;
|
import com.yssh.dao.Yssh3dreliMapper;
|
import com.yssh.entity.DictRecord;
|
import com.yssh.entity.Yssh2dreli;
|
import com.yssh.entity.Yssh3dreli;
|
import com.yssh.service.Yssh3dreliService;
|
import com.yssh.utils.StringUtils;
|
import lombok.Synchronized;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
import java.util.ArrayList;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author lishijia
|
* @ClassName Yssh3dreliServiceImpl
|
* @Description TODO
|
* @date 2022/12/3 21:25
|
* @Version 1.0
|
*/
|
@Service
|
public class Yssh3dreliServiceImpl extends ServiceImpl<Yssh3dreliMapper, Yssh3dreli> implements Yssh3dreliService {
|
@Autowired
|
private Yssh3dreliMapper mapper;
|
|
@Autowired
|
private DictRecordMapper dictRecordMapper;
|
|
|
@Override
|
public List<Yssh3dreli> getAll() {
|
return mapper.getAll();
|
}
|
|
@Override
|
public List<Yssh3dreli> query(String name) {
|
return mapper.query(name);
|
}
|
|
|
/**
|
* 创建3维热力表接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int create3dreliTable() {
|
String tablePrefix = "yssh_3dreli_";
|
// Date date = new Date();
|
// SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
|
// String localDday = dateFormat.format(date);
|
// System.out.println("localDday = " + localDday);
|
// String tableName = tablePrefix+localDday;
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
|
Calendar calendar = Calendar.getInstance();
|
//明天
|
calendar.add(Calendar.DATE, +1);
|
Date start = calendar.getTime();
|
String tomorrow = dateFormat.format(start);
|
String tableName = tablePrefix + tomorrow;
|
System.out.println("tableName = " + tableName);
|
|
//把新增的表增加到字典表中
|
DictRecord dictRecord = new DictRecord();
|
dictRecord.setTableName(tableName);
|
dictRecord.setResOne("3");
|
dictRecord.setResTwo(tomorrow);
|
dictRecord.setCreateTime(dateFormat("yyyy-MM-dd HH:mm:ss"));
|
dictRecordMapper.insertDictRecord(dictRecord);
|
return mapper.create3dreliTable(tableName);
|
}
|
|
|
/**
|
* 创建当天3维热力表接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int preRreate3dreliTable() {
|
String tablePrefix = "yssh_3dreli_";
|
Date date = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
|
String localDday = dateFormat.format(date);
|
System.out.println("localDday = " + localDday);
|
String tableName = tablePrefix + localDday;
|
|
//把新增的表增加到字典表中
|
DictRecord dictRecord = new DictRecord();
|
dictRecord.setTableName(tableName);
|
dictRecord.setResOne("3");
|
dictRecord.setResTwo(localDday);
|
dictRecord.setCreateTime(dateFormat("yyyy-MM-dd HH:mm:ss"));
|
dictRecordMapper.insertDictRecord(dictRecord);
|
return mapper.create3dreliTable(tableName);
|
}
|
|
/**
|
* 删除3维热力表接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int drop3dreliTable() {
|
String tablePrefix = "yssh_3dreli_";
|
//定义日期格式
|
SimpleDateFormat format2 = new SimpleDateFormat("yyyyMMdd");
|
Calendar calendar = Calendar.getInstance();
|
//前一年
|
calendar.add(Calendar.YEAR, -1);
|
Date start = calendar.getTime();
|
String yearBefore = format2.format(start);
|
String tableName = tablePrefix + yearBefore;
|
return mapper.drop3dreliTable(tableName);
|
}
|
|
|
/**
|
* 批量新增3维热力记录
|
*
|
* @param yssh3dreli 3维热力记录
|
* @return 结果
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int batchInsert3dreliData(List<Yssh3dreli> yssh3dreli) {
|
/*Yssh3dreli yssh3dreli1 =new Yssh3dreli();
|
for (Yssh3dreli yssh3dre2: yssh3dreli) {
|
System.out.println("yssh3dre2 = " + yssh3dre2.getName());
|
yssh3dreli1.setName(yssh3dre2.getName());
|
yssh3dreli1.setLat(yssh3dre2.getLat());
|
yssh3dreli1.setLon(yssh3dre2.getLon());
|
yssh3dreli1.setHeight0(yssh3dre2.getHeight0());
|
yssh3dreli1.setHeight10(yssh3dre2.getHeight10());
|
yssh3dreli1.setHeight20(yssh3dre2.getHeight20());
|
yssh3dreli1.setHeight30(yssh3dre2.getHeight30());
|
yssh3dreli1.setHeight40(yssh3dre2.getHeight40());
|
yssh3dreli1.setHeight50(yssh3dre2.getHeight50());
|
yssh3dreli1.setHeight60(yssh3dre2.getHeight60());
|
yssh3dreli1.setHeight70(yssh3dre2.getHeight70());
|
yssh3dreli1.setHeight80(yssh3dre2.getHeight80());
|
yssh3dreli1.setHeight90(yssh3dre2.getHeight90());
|
yssh3dreli1.setTime(yssh3dre2.getTime());
|
}*/
|
String tablePrefix = "yssh_3dreli_";
|
Date date = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
|
String localDday = dateFormat.format(date);
|
String tableName = tablePrefix + localDday;
|
return mapper.batchInsert3dreliData(tableName, yssh3dreli);
|
}
|
|
/**
|
* 批量新增2维热力记录
|
*
|
* @param yssh2drelis 2维热力记录
|
* @return 结果
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int batchInsert2dreliData(List<Yssh2dreli> yssh2drelis) {
|
String tablePrefix = "yssh_2dreli_";
|
Date date = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyyMMdd");
|
String localDday = dateFormat.format(date);
|
String tableName = tablePrefix + localDday;
|
return mapper.batchInsert2dreliData(tableName, yssh2drelis);
|
}
|
|
|
/**
|
* 查询接口
|
*/
|
@Override
|
public List<Yssh3dreli> query3data(Yssh3dreli yssh3dreli, String tableName) {
|
List<Yssh3dreli> resultList = mapper.query3data(yssh3dreli.getTime(), tableName);
|
return resultList;
|
}
|
|
/**
|
* 查询3维热力表接口
|
* 1、根据time字段传入的开始时间和结束时间
|
* 2、根据时间查询记录表，获取数据表名
|
* 3、查询出结果、合并结果并返回结果
|
* ①time为同一天的不同时间
|
* ②time为不同一天的范围时间
|
*/
|
@Override
|
public List<Yssh3dreli> thrDDataQuery(String startTime, String endOfTime) {
|
String tablePrefix = "yssh_3dreli_";
|
String tableName = "";
|
System.out.println("startTime = " + startTime);
|
System.out.println("endOfTime = " + endOfTime);
|
String strTime = startTime.substring(0, 8);
|
String endTime = endOfTime.substring(0, 8);
|
List<Yssh3dreli> resultList = new ArrayList<>();
|
//根据查询时间判断查询的数据表
|
//①同一个表范围查询
|
if (strTime.equals(endTime)) {
|
tableName = tablePrefix + strTime;
|
System.out.println("tableName = " + tableName);
|
resultList = mapper.thrDDataQuery1(tableName, startTime, endOfTime);
|
} else {
|
//②不在同一个表查询
|
List<Yssh3dreli> list1 = new ArrayList<>();
|
tableName = tablePrefix + strTime;
|
list1 = mapper.thrDDataQuery2(tableName, startTime);
|
|
List<Yssh3dreli> list2 = new ArrayList<>();
|
tableName = tablePrefix + endTime;
|
list2 = mapper.thrDDataQuery3(tableName, endOfTime);
|
//合并结果
|
resultList.addAll(list1);
|
resultList.addAll(list2);
|
}
|
return resultList;
|
}
|
|
|
/**
|
* 查询3维热力表接口
|
* 1、根据time字段传入的开始时间和结束时间
|
* 2、根据时间查询记录表，获取数据表名
|
* 3、查询出结果、合并结果并返回结果
|
* ①time为同一天的不同时间
|
* ②time为不同一天的范围时间
|
*/
|
@Override
|
public List<Yssh3dreli> qubyt(String name, String startTime, String endOfTime) throws ParseException {
|
String tablePrefix = "yssh_3dreli_";
|
String tableName = "";
|
System.out.println("startTime = " + startTime);
|
System.out.println("endOfTime = " + endOfTime);
|
String strTime = startTime.substring(0, 8);
|
String endTime = endOfTime.substring(0, 8);
|
List<Yssh3dreli> resultList = new ArrayList<>();
|
//根据查询时间判断查询的数据表
|
//①同一个表范围查询
|
if (strTime.equals(endTime)) {
|
tableName = tablePrefix + strTime;
|
System.out.println("tableName = " + tableName);
|
resultList = mapper.thrDDataQuery11(name, tableName, startTime, endOfTime);
|
return resultList;
|
} else {
|
//②不在同一个表查询 创建一个返回的list
|
List<Yssh3dreli> lists = new ArrayList<>();
|
//去字典记录表中查询出需要查询的表名
|
List<DictRecord> resDictRecords = dictRecordMapper.selectDictRecordList3dByTime(strTime, endTime);
|
for (DictRecord dicts : resDictRecords) {
|
System.out.println("dicts = " + dicts.getTableName());
|
lists.addAll(mapper.thrDDataQuery01(name, dicts.getTableName()));//将返回的结果添加到list中
|
}
|
return lists;
|
}
|
|
}
|
|
/**
|
* 将字符串格式转日期，如：yyyy-MM-dd ||自定义格式
|
*
|
* @param date 日期字符串
|
* @param dateFormat 设置将字符串格式转日期格式，这个与date的格式必须一致
|
* @param tarFormat 设置目标格式
|
* @return 返回格式化的日期，默认格式：yyyy-MM-dd
|
* @throws ParseException 分析时意外地出现了错误异常
|
*/
|
public String strToDateFormat(String date, String dateFormat, String tarFormat) throws ParseException {
|
SimpleDateFormat formatter = new SimpleDateFormat(StringUtils.isBlank(dateFormat) ? "yyyyMMdd" : dateFormat);
|
formatter.setLenient(false);
|
Date newDate = formatter.parse(date);
|
formatter = new SimpleDateFormat(StringUtils.isBlank(tarFormat) ? "yyyy-MM-dd" : tarFormat);
|
return formatter.format(newDate);
|
}
|
|
/**
|
* 获取LocalDateTime的指定日期格式
|
*
|
* @param ofPattern 设置时间格式：yyyy-MM-dd HH:mm:ss
|
* @return 2023-02-09 09:51:43
|
*/
|
public String dateFormat(String ofPattern) {
|
return LocalDateTime.now().format(DateTimeFormatter.ofPattern(ofPattern));
|
}
|
|
/**
|
* JAVA计算两个日期相差多少天
|
*
|
* @param date1str
|
* @param date2str
|
* @return
|
*/
|
public int daysBetween(String date1str, String date2str) throws ParseException {
|
int count = 0;
|
if ("".equals(date1str) || date1str == null || "".equals(date2str) || date2str == null) {
|
return count;
|
}
|
SimpleDateFormat format = new SimpleDateFormat("yyyyMMdd");
|
Date date1 = format.parse(date1str);
|
Date date2 = format.parse(date2str);
|
count = Math.abs((int) ((date1.getTime() - date2.getTime()) / (1000 * 3600 * 24)));
|
return count;
|
/*System.out.println("当前时间：" + dateFormat("yyyy-MM-dd HH:mm:ss"));
|
String date1 = strToDateFormat(startTime, "yyyyMMddHH", "yyyy-MM-dd HH:mm:ss");
|
String date2 = strToDateFormat(endOfTime, "yyyyMMddHH", "yyyy-MM-dd HH:mm:ss");
|
//String转Date
|
Date date11 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(date1);
|
Date date22 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").parse(date2);
|
// 获取相差的天数
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date11);
|
long timeInMillis1 = calendar.getTimeInMillis();
|
calendar.setTime(date22);
|
long timeInMillis2 = calendar.getTimeInMillis();
|
long betweenDays = ((timeInMillis2 - timeInMillis1) / (1000L * 3600L * 24L)) + 2;
|
System.out.println("betweenDays = " + betweenDays);*/
|
}
|
|
|
}
|
