|
@@ -10,6 +10,7 @@ import com.jiayue.ipfcst.common.data.entity.CutOutSpeedSpecifyInfo;
|
|
import com.jiayue.ipfcst.common.data.entity.FanUnitInfo;
|
|
import com.jiayue.ipfcst.common.data.entity.FanUnitInfo;
|
|
import com.jiayue.ipfcst.common.data.entity.WindSpeedPointInfo;
|
|
import com.jiayue.ipfcst.common.data.entity.WindSpeedPointInfo;
|
|
import com.jiayue.ipfcst.common.data.entity.WindTurbinePowerCurve;
|
|
import com.jiayue.ipfcst.common.data.entity.WindTurbinePowerCurve;
|
|
|
|
+import com.jiayue.ipfcst.common.data.repository.CutOutSpeedSpecifyInfoRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.FanUnitInfoRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.FanUnitInfoRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.WindSpeedPointInfoRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.WindSpeedPointInfoRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.WindTurbinePowerCurveRepository;
|
|
import com.jiayue.ipfcst.common.data.repository.WindTurbinePowerCurveRepository;
|
|
@@ -30,17 +31,20 @@ import java.util.*;
|
|
*/
|
|
*/
|
|
@Service
|
|
@Service
|
|
public class ReadToMysqlService extends BaseService {
|
|
public class ReadToMysqlService extends BaseService {
|
|
- private static WindSpeedPointInfoRepository windSpeedPointInfoRepository;
|
|
|
|
- private static WindTurbinePowerCurveRepository windTurbinePowerCurveRepository;
|
|
|
|
- private static FanUnitInfoRepository fanUnitInfoRepository;
|
|
|
|
|
|
+ private WindSpeedPointInfoRepository windSpeedPointInfoRepository;
|
|
|
|
+ private WindTurbinePowerCurveRepository windTurbinePowerCurveRepository;
|
|
|
|
+ private FanUnitInfoRepository fanUnitInfoRepository;
|
|
|
|
+ private CutOutSpeedSpecifyInfoRepository cutOutSpeedSpecifyInfoRepository;
|
|
|
|
|
|
@Autowired
|
|
@Autowired
|
|
public ReadToMysqlService(WindSpeedPointInfoRepository windSpeedPointInfoRepository,
|
|
public ReadToMysqlService(WindSpeedPointInfoRepository windSpeedPointInfoRepository,
|
|
- FanUnitInfoRepository fanUnitInfoRepository,
|
|
|
|
- WindTurbinePowerCurveRepository windTurbinePowerCurveRepository) {
|
|
|
|
|
|
+ FanUnitInfoRepository fanUnitInfoRepository,
|
|
|
|
+ WindTurbinePowerCurveRepository windTurbinePowerCurveRepository,
|
|
|
|
+ CutOutSpeedSpecifyInfoRepository cutOutSpeedSpecifyInfoRepository) {
|
|
this.windSpeedPointInfoRepository = windSpeedPointInfoRepository;
|
|
this.windSpeedPointInfoRepository = windSpeedPointInfoRepository;
|
|
this.fanUnitInfoRepository = fanUnitInfoRepository;
|
|
this.fanUnitInfoRepository = fanUnitInfoRepository;
|
|
this.windTurbinePowerCurveRepository = windTurbinePowerCurveRepository;
|
|
this.windTurbinePowerCurveRepository = windTurbinePowerCurveRepository;
|
|
|
|
+ this.cutOutSpeedSpecifyInfoRepository = cutOutSpeedSpecifyInfoRepository;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
@@ -49,8 +53,7 @@ public class ReadToMysqlService extends BaseService {
|
|
*
|
|
*
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
- public static ResponseVO readFanUnitInfo(MultipartFile multipartFile) throws Exception {
|
|
|
|
- // 机组信息读取 sheet 0
|
|
|
|
|
|
+ public ResponseVO readFanUnitInfo(MultipartFile multipartFile) throws Exception {
|
|
try (
|
|
try (
|
|
ExcelReader reader = ExcelUtil.getReader(multipartFile.getInputStream(), 0)) {
|
|
ExcelReader reader = ExcelUtil.getReader(multipartFile.getInputStream(), 0)) {
|
|
reader.addHeaderAlias("序号", "fanId");
|
|
reader.addHeaderAlias("序号", "fanId");
|
|
@@ -72,7 +75,7 @@ public class ReadToMysqlService extends BaseService {
|
|
/**
|
|
/**
|
|
* 读取 8个风向 sheet表风速点表
|
|
* 读取 8个风向 sheet表风速点表
|
|
*/
|
|
*/
|
|
- public static ResponseVO readSpeedSheet(MultipartFile multipartFile){
|
|
|
|
|
|
+ public ResponseVO readSpeedSheet(MultipartFile multipartFile){
|
|
Map<Integer, List<String>> fanidInfo = new HashMap<>();
|
|
Map<Integer, List<String>> fanidInfo = new HashMap<>();
|
|
List<WindSpeedPointInfo> windSpeedPointInfoList = new ArrayList<>();
|
|
List<WindSpeedPointInfo> windSpeedPointInfoList = new ArrayList<>();
|
|
DecimalFormat decimalFormat = new DecimalFormat(".00");
|
|
DecimalFormat decimalFormat = new DecimalFormat(".00");
|
|
@@ -136,7 +139,7 @@ public class ReadToMysqlService extends BaseService {
|
|
/**
|
|
/**
|
|
* 读取风速曲线
|
|
* 读取风速曲线
|
|
*/
|
|
*/
|
|
- public static ResponseVO readWindTurbinePowerCurveMap(MultipartFile multipartFile) throws Exception {
|
|
|
|
|
|
+ public ResponseVO readWindTurbinePowerCurveMap(MultipartFile multipartFile) throws Exception {
|
|
for (int sheelIndex = 10; sheelIndex <= 14; sheelIndex++) {
|
|
for (int sheelIndex = 10; sheelIndex <= 14; sheelIndex++) {
|
|
//读取风速曲线 sheet
|
|
//读取风速曲线 sheet
|
|
String sheetName;
|
|
String sheetName;
|
|
@@ -171,24 +174,15 @@ public class ReadToMysqlService extends BaseService {
|
|
*
|
|
*
|
|
* @return
|
|
* @return
|
|
*/
|
|
*/
|
|
- public static ResponseVO readFanCutOutSpeedInfo(MultipartFile multipartFile) throws SQLException, IOException {
|
|
|
|
- List<CutOutSpeedSpecifyInfo> cutOutSpeedSpecifyInfoList;
|
|
|
|
|
|
+ public ResponseVO readFanCutOutSpeedInfo(MultipartFile multipartFile) throws SQLException, IOException {
|
|
try (ExcelReader reader = ExcelUtil.getReader(multipartFile.getInputStream(), 9)) {
|
|
try (ExcelReader reader = ExcelUtil.getReader(multipartFile.getInputStream(), 9)) {
|
|
reader.addHeaderAlias("序号", "id");
|
|
reader.addHeaderAlias("序号", "id");
|
|
reader.addHeaderAlias("风速下限(包含)m/s", "lowerWindSpeedLimit");
|
|
reader.addHeaderAlias("风速下限(包含)m/s", "lowerWindSpeedLimit");
|
|
reader.addHeaderAlias("风速上限(不包含)m/s", "highWindSpeedLimit");
|
|
reader.addHeaderAlias("风速上限(不包含)m/s", "highWindSpeedLimit");
|
|
reader.addHeaderAlias("发电功率kW", "powerGeneration");
|
|
reader.addHeaderAlias("发电功率kW", "powerGeneration");
|
|
- reader.addHeaderAlias("所属机组", "UnitBelongs");
|
|
|
|
- cutOutSpeedSpecifyInfoList = reader.readAll(CutOutSpeedSpecifyInfo.class);
|
|
|
|
- for (CutOutSpeedSpecifyInfo cs : cutOutSpeedSpecifyInfoList) {
|
|
|
|
- Db.use().insertForGeneratedKey(
|
|
|
|
- Entity.create("t_cut_out_speed_specify_info")
|
|
|
|
- .set("C_LOWER_WIND_SPEED_LIMIT", cs.getLowerWindSpeedLimit())
|
|
|
|
- .set("C_HIGH_WIND_SPEED_LIMIT", cs.getHighWindSpeedLimit())
|
|
|
|
- .set("C_POWER_GENERATION", cs.getPowerGeneration())
|
|
|
|
- .set("C_UNIT_BELONGS", cs.getFanId())
|
|
|
|
- );
|
|
|
|
- }
|
|
|
|
|
|
+ reader.addHeaderAlias("所属机组", "fanId");
|
|
|
|
+ List<CutOutSpeedSpecifyInfo> cutOutSpeedSpecifyInfoList = reader.readAll(CutOutSpeedSpecifyInfo.class);
|
|
|
|
+ cutOutSpeedSpecifyInfoRepository.saveAll(cutOutSpeedSpecifyInfoList);
|
|
} catch (cn.hutool.poi.exceptions.POIException e) {
|
|
} catch (cn.hutool.poi.exceptions.POIException e) {
|
|
return ResponseVO.error(e);
|
|
return ResponseVO.error(e);
|
|
}
|
|
}
|