package com.terra.bigdata.service.impl;
|
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.terra.bigdata.domain.Yssh2dreli;
|
import com.terra.bigdata.domain.Yssh3dreli;
|
import com.terra.bigdata.mapper.Yssh3dreliMapper;
|
import com.terra.bigdata.service.Yssh3dreliService;
|
import lombok.Synchronized;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
|
|
/**
|
* <p>
|
* 前端控制器
|
* </p>
|
*
|
* @author hyy
|
* @since 2022-12-22
|
*/
|
@Service
|
public class Yssh3dreliServiceImpl extends ServiceImpl<Yssh3dreliMapper, Yssh3dreli> implements Yssh3dreliService {
|
|
@Autowired
|
private Yssh3dreliMapper yssh3dreliMapper;
|
|
/**
|
* 创建3维热力表接口
|
*/
|
/*@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int create3dreliTable() {
|
String tablePrefix = "yssh_3dreli_";
|
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);
|
|
|
return yssh3dreliMapper.create3dreliTable(tableName);
|
}
|
*/
|
|
/**
|
* 创建3维热力表接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int create3dreliTable() {
|
String tablePrefix = "yssh_3dreli_";
|
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);
|
dictRecordMapper.insertDictRecord(dictRecord);*/
|
return yssh3dreliMapper.create3dreliTable(tableName);
|
}
|
|
|
/**
|
* 创建2维热力表接口
|
*/
|
@Transactional(rollbackFor = Exception.class)
|
@Synchronized
|
@Override
|
public int create2dreliTable() {
|
String tablePrefix = "yssh_2dreli_";
|
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);
|
return yssh3dreliMapper.create2dreliTable(tableName);
|
}
|
|
|
/**
|
* 新增3维热力记录
|
*
|
* @param yssh3dreli 3维热力记录
|
* @return 结果
|
*/
|
@Override
|
public int insert3dreliData(Yssh3dreli yssh3dreli) {
|
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;
|
return yssh3dreliMapper.insert3dreliData(tableName, yssh3dreli);
|
}
|
|
|
/**
|
* 批量新增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 yssh3dreliMapper.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 yssh3dreliMapper.batchInsert2dreliData(tableName, yssh2drelis);
|
}
|
|
|
/**
|
* 删除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 yssh3dreliMapper.drop3dreliTable(tableName);
|
}
|
|
}
|
