Commit 0e2eef80 authored by wujiang's avatar wujiang

修改月统一

parent 4796f712
...@@ -55,7 +55,7 @@ public class HouseholdTestController { ...@@ -55,7 +55,7 @@ public class HouseholdTestController {
@Autowired @Autowired
private TdHYGFStationDayGenerateImpl tdHYGFStationDayGenerateImpl; private TdHYGFStationDayGenerateImpl tdHYGFStationDayGenerateImpl;
@Autowired @Autowired
private TdHYGFStationMonthGenerateImpl tdHYGFStationMonthGenerateImpl; private TdHYGFStationYearGenerateImpl tdHYGFStationMonthGenerateImpl;
@Autowired @Autowired
private TdHYGFInverterTotalGenerateImpl tdHYGFInverterTotalGenerateImpl; private TdHYGFInverterTotalGenerateImpl tdHYGFInverterTotalGenerateImpl;
......
package com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine; package com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine;
import java.io.Serializable;
import com.baomidou.mybatisplus.annotation.TableName; import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable; import lombok.Data;
/** /**
* @author DELL * @author DELL
*/ */
@Data @Data
@TableName(value = "td_hygf_station_generate_year" ,autoResultMap = true) @TableName(value = "td_hygf_station_generate_year" ,autoResultMap = true)
public class TdHYGFStationMonthGenerate implements Serializable { public class TdHYGFStationYearGenerate implements Serializable {
/** /**
* 创建时间 * 创建时间
*/ */
......
package com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine; package com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine;
import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationMonthGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationYearGenerate;
public interface TdHYGFStationMonthGenerateMapper extends BaseMapper<TdHYGFStationMonthGenerate> { public interface TdHYGFStationYearGenerateMapper extends BaseMapper<TdHYGFStationYearGenerate> {
} }
...@@ -25,7 +25,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService { ...@@ -25,7 +25,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService {
@Autowired @Autowired
private JpStationMapper jpStationMapper; private JpStationMapper jpStationMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper tdHYGFStationYearGenerateMapper; private TdHYGFStationAllGenerateMapper tdHYGFStationAllGenerateMapper;
@Override @Override
public void updateAscription(String timeNum) { public void updateAscription(String timeNum) {
try { try {
...@@ -34,7 +34,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService { ...@@ -34,7 +34,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService {
Date star = dft.parse(timeNum);//开始时间 Date star = dft.parse(timeNum);//开始时间
String yearMonth= dfty.format(star); String yearMonth= dfty.format(star);
List<TdHYGFStationAllGenerate> hygfjpDayPower = tdHYGFStationYearGenerateMapper.selectList( List<TdHYGFStationAllGenerate> hygfjpDayPower = tdHYGFStationAllGenerateMapper.selectList(
new QueryWrapper<TdHYGFStationAllGenerate>(). new QueryWrapper<TdHYGFStationAllGenerate>().
eq("year", yearMonth).and(wrapper -> { eq("year", yearMonth).and(wrapper -> {
wrapper.isNull("regional_companies_code") wrapper.isNull("regional_companies_code")
...@@ -56,7 +56,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService { ...@@ -56,7 +56,7 @@ public class TdHYGFStationAllGenerateImpl implements AscriptionService {
dayPower.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); dayPower.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
dayPower.setStationName(jpStation.getName()); dayPower.setStationName(jpStation.getName());
dayPower.setStationState(jpStation.getState()); dayPower.setStationState(jpStation.getState());
tdHYGFStationYearGenerateMapper.insert(dayPower); tdHYGFStationAllGenerateMapper.insert(dayPower);
} }
} }
} }
......
package com.yeejoin.amos.api.householdapi.face.service.business; package com.yeejoin.amos.api.householdapi.face.service.business;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.hygf.JpStation;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFInverterYearGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationMonthGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpStationMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationMonthGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.service.AscriptionService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.text.DateFormat; import java.text.DateFormat;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.hygf.JpStation;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationYearGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpStationMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationYearGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.service.AscriptionService;
/** /**
* @description: * @description:
* @author: tw * @author: tw
* @createDate: 2024/4/9 * @createDate: 2024/4/9
*/ */
@Service @Service
public class TdHYGFStationMonthGenerateImpl implements AscriptionService { public class TdHYGFStationYearGenerateImpl implements AscriptionService {
@Autowired @Autowired
private JpStationMapper jpStationMapper; private JpStationMapper jpStationMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper tdHYGFStationYearGenerateMapper;
@Override @Override
public void updateAscription(String timeNum) { public void updateAscription(String timeNum) {
try { try {
...@@ -34,8 +34,8 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService { ...@@ -34,8 +34,8 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService {
Date star = dft.parse(timeNum);//开始时间 Date star = dft.parse(timeNum);//开始时间
String yearMonth= dfty.format(star); String yearMonth= dfty.format(star);
List<TdHYGFStationMonthGenerate> hygfjpDayPower = tdHYGFStationMonthGenerateMapper.selectList( List<TdHYGFStationYearGenerate> hygfjpDayPower = tdHYGFStationYearGenerateMapper.selectList(
new QueryWrapper<TdHYGFStationMonthGenerate>(). new QueryWrapper<TdHYGFStationYearGenerate>().
eq("month_time", yearMonth).and(wrapper -> { eq("month_time", yearMonth).and(wrapper -> {
wrapper.isNull("regional_companies_code") wrapper.isNull("regional_companies_code")
.or() .or()
...@@ -48,7 +48,7 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService { ...@@ -48,7 +48,7 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService {
); );
if(hygfjpDayPower!=null&&!hygfjpDayPower.isEmpty()){ if(hygfjpDayPower!=null&&!hygfjpDayPower.isEmpty()){
for (TdHYGFStationMonthGenerate dayPower : hygfjpDayPower) { for (TdHYGFStationYearGenerate dayPower : hygfjpDayPower) {
JpStation jpStation = jpStationMapper.selectOne(new QueryWrapper<JpStation>(). JpStation jpStation = jpStationMapper.selectOne(new QueryWrapper<JpStation>().
eq("third_station_id", dayPower.getThirdStationId())); eq("third_station_id", dayPower.getThirdStationId()));
if(jpStation!=null){ if(jpStation!=null){
...@@ -56,7 +56,7 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService { ...@@ -56,7 +56,7 @@ public class TdHYGFStationMonthGenerateImpl implements AscriptionService {
dayPower.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); dayPower.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
dayPower.setStationName(jpStation.getName()); dayPower.setStationName(jpStation.getName());
dayPower.setStationState(jpStation.getState()); dayPower.setStationState(jpStation.getState());
tdHYGFStationMonthGenerateMapper.insert(dayPower); tdHYGFStationYearGenerateMapper.insert(dayPower);
} }
} }
} }
......
...@@ -99,7 +99,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe ...@@ -99,7 +99,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
...@@ -310,30 +310,30 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe ...@@ -310,30 +310,30 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
// 户用场站月发电量 // 户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper.selectOne( TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper.selectOne(
new QueryWrapper<TdHYGFStationMonthGenerate>().eq("third_station_id", stationIds.get(i)) new QueryWrapper<TdHYGFStationYearGenerate>().eq("third_station_id", stationIds.get(i))
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(stationIds.get(i)); TdHYGFStationYearGenerate.setThirdStationId(stationIds.get(i));
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
tdHYGFStationMonthGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity()); TdHYGFStationYearGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity());
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
// 新加 // 新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
// 户用场站年发电量 // 户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne( TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne(
......
...@@ -86,7 +86,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe ...@@ -86,7 +86,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
...@@ -255,33 +255,33 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe ...@@ -255,33 +255,33 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
// 户用场站月发电量 // 户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper
.selectOne(new QueryWrapper<TdHYGFStationMonthGenerate>() .selectOne(new QueryWrapper<TdHYGFStationYearGenerate>()
.eq("third_station_id", jpStation.getThirdStationId()) .eq("third_station_id", jpStation.getThirdStationId())
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (org.springframework.util.ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (org.springframework.util.ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(jpStation.getThirdStationId()); TdHYGFStationYearGenerate.setThirdStationId(jpStation.getThirdStationId());
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
if (ObjectUtils.isNotEmpty(jpStation.getMonthGenerate())) { if (ObjectUtils.isNotEmpty(jpStation.getMonthGenerate())) {
tdHYGFStationMonthGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity()); TdHYGFStationYearGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity());
} }
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
// 新加 // 新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (org.springframework.util.ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (org.springframework.util.ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
// 户用场站年发电量 // 户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper
......
...@@ -113,7 +113,7 @@ public class ImasterDataServiceImpl implements ImasterDataService { ...@@ -113,7 +113,7 @@ public class ImasterDataServiceImpl implements ImasterDataService {
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
@Autowired @Autowired
...@@ -417,30 +417,30 @@ public class ImasterDataServiceImpl implements ImasterDataService { ...@@ -417,30 +417,30 @@ public class ImasterDataServiceImpl implements ImasterDataService {
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
//户用场站月发电量 //户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper.selectOne(new QueryWrapper<TdHYGFStationMonthGenerate>() TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper.selectOne(new QueryWrapper<TdHYGFStationYearGenerate>()
.eq("third_station_id", jpStation.getThirdStationId()) .eq("third_station_id", jpStation.getThirdStationId())
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(jpStation.getThirdStationId()); TdHYGFStationYearGenerate.setThirdStationId(jpStation.getThirdStationId());
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
tdHYGFStationMonthGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity()); TdHYGFStationYearGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity());
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
//新加 //新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
//户用场站年发电量 //户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne(new QueryWrapper<TdHYGFStationAllGenerate>() TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne(new QueryWrapper<TdHYGFStationAllGenerate>()
......
...@@ -107,7 +107,7 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe ...@@ -107,7 +107,7 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
@Autowired @Autowired
...@@ -340,31 +340,31 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe ...@@ -340,31 +340,31 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
// 户用场站月发电量 // 户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper
.selectOne(new QueryWrapper<TdHYGFStationMonthGenerate>().eq("third_station_id", stationId) .selectOne(new QueryWrapper<TdHYGFStationYearGenerate>().eq("third_station_id", stationId)
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(stationId); TdHYGFStationYearGenerate.setThirdStationId(stationId);
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
tdHYGFStationMonthGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity()); TdHYGFStationYearGenerate.setFullhour(jpStation.getMonthGenerate() / jpStation.getCapacity());
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
// 新加 // 新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
// 户用场站年发电量 // 户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper
......
...@@ -42,7 +42,7 @@ import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHY ...@@ -42,7 +42,7 @@ import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHY
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFInverterTotalGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFInverterTotalGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFInverterYearGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFInverterYearGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationDayGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationDayGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationMonthGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationYearGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationAllGenerate; import com.yeejoin.amos.api.householdapi.face.orm.houseapi.entity.tdeingine.TdHYGFStationAllGenerate;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpCollectorMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpCollectorMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpInverterElectricityMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.hygf.JpInverterElectricityMapper;
...@@ -58,7 +58,7 @@ import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverter ...@@ -58,7 +58,7 @@ import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverter
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverterTotalGenerateMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverterTotalGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverterYearGenerateMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFInverterYearGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationDayGenerateMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationDayGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationMonthGenerateMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationYearGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationAllGenerateMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdHYGFStationAllGenerateMapper;
import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdJpStationMapper; import com.yeejoin.amos.api.householdapi.face.orm.mapper.tdengine.TdJpStationMapper;
import com.yeejoin.amos.api.householdapi.face.service.SofarDataAcquisitionService; import com.yeejoin.amos.api.householdapi.face.service.SofarDataAcquisitionService;
...@@ -86,7 +86,7 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ ...@@ -86,7 +86,7 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
@Autowired @Autowired
...@@ -554,35 +554,35 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ ...@@ -554,35 +554,35 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
// 户用场站月发电量 // 户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper.selectOne( TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper.selectOne(
new QueryWrapper<TdHYGFStationMonthGenerate>().eq("third_station_id", jpStation.getThirdStationId()) new QueryWrapper<TdHYGFStationYearGenerate>().eq("third_station_id", jpStation.getThirdStationId())
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(jpStation.getThirdStationId()); TdHYGFStationYearGenerate.setThirdStationId(jpStation.getThirdStationId());
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
tdHYGFStationMonthGenerate.setFullhour( TdHYGFStationYearGenerate.setFullhour(
// jpStation.getMonthGenerate() / jpStation.getCapacity() // jpStation.getMonthGenerate() / jpStation.getCapacity()
(jpStation.getMonthGenerate() == null || jpStation.getCapacity() == null) ? null (jpStation.getMonthGenerate() == null || jpStation.getCapacity() == null) ? null
: (jpStation.getCapacity() <= 0.0 ? null : (jpStation.getCapacity() <= 0.0 ? null
: jpStation.getMonthGenerate() / jpStation.getCapacity())); : jpStation.getMonthGenerate() / jpStation.getCapacity()));
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
// 新加 // 新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
// 户用场站年发电量 // 户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne( TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne(
......
...@@ -79,7 +79,7 @@ public class SunlightServiceImpl implements SunlightService { ...@@ -79,7 +79,7 @@ public class SunlightServiceImpl implements SunlightService {
@Autowired @Autowired
private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper; private TdHYGFStationDayGenerateMapper tdHYGFStationDayGenerateMapper;
@Autowired @Autowired
private TdHYGFStationMonthGenerateMapper tdHYGFStationMonthGenerateMapper; private TdHYGFStationYearGenerateMapper TdHYGFStationYearGenerateMapper;
@Autowired @Autowired
private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper; private TdHYGFStationAllGenerateMapper TdHYGFStationAllGenerateMapper;
@Autowired @Autowired
...@@ -458,18 +458,18 @@ public class SunlightServiceImpl implements SunlightService { ...@@ -458,18 +458,18 @@ public class SunlightServiceImpl implements SunlightService {
tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate); tdHYGFStationDayGenerateMapper.insert(tdHYGFStationDayGenerate);
} }
// 户用场站月发电量 // 户用场站月发电量
TdHYGFStationMonthGenerate tdHYGFStationMonthGenerate = tdHYGFStationMonthGenerateMapper.selectOne( TdHYGFStationYearGenerate TdHYGFStationYearGenerate = TdHYGFStationYearGenerateMapper.selectOne(
new QueryWrapper<TdHYGFStationMonthGenerate>().eq("third_station_id", jpStation.getThirdStationId()) new QueryWrapper<TdHYGFStationYearGenerate>().eq("third_station_id", jpStation.getThirdStationId())
.eq("month_time", DateUtil.format(today1, "yyyy-MM")) .eq("month_time", DateUtil.format(today1, "yyyy-MM"))
.eq("year", DateUtil.format(today1, "yyyy"))); .eq("year", DateUtil.format(today1, "yyyy")));
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate)) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate)) {
tdHYGFStationMonthGenerate = new TdHYGFStationMonthGenerate(); TdHYGFStationYearGenerate = new TdHYGFStationYearGenerate();
} }
tdHYGFStationMonthGenerate.setThirdStationId(jpStation.getThirdStationId()); TdHYGFStationYearGenerate.setThirdStationId(jpStation.getThirdStationId());
tdHYGFStationMonthGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM")); TdHYGFStationYearGenerate.setMonthTime(DateUtil.format(today1, "yyyy-MM"));
tdHYGFStationMonthGenerate.setYear(DateUtil.format(today1, "yyyy")); TdHYGFStationYearGenerate.setYear(DateUtil.format(today1, "yyyy"));
tdHYGFStationMonthGenerate.setGenerate(jpStation.getMonthGenerate()); TdHYGFStationYearGenerate.setGenerate(jpStation.getMonthGenerate());
tdHYGFStationMonthGenerate.setFullhour( TdHYGFStationYearGenerate.setFullhour(
// jpStation.getMonthGenerate() / jpStation.getCapacity() // jpStation.getMonthGenerate() / jpStation.getCapacity()
...@@ -479,19 +479,19 @@ public class SunlightServiceImpl implements SunlightService { ...@@ -479,19 +479,19 @@ public class SunlightServiceImpl implements SunlightService {
: jpStation.getMonthGenerate() / jpStation.getCapacity()) : jpStation.getMonthGenerate() / jpStation.getCapacity())
); );
tdHYGFStationMonthGenerate.setIncome(jpStation.getMonthIncome()); TdHYGFStationYearGenerate.setIncome(jpStation.getMonthIncome());
// 新加 // 新加
tdHYGFStationMonthGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode()); TdHYGFStationYearGenerate.setAmosCompanyCode(jpStation.getAmosCompanyCode());
tdHYGFStationMonthGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); TdHYGFStationYearGenerate.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdHYGFStationMonthGenerate.setStationName(jpStation.getName()); TdHYGFStationYearGenerate.setStationName(jpStation.getName());
tdHYGFStationMonthGenerate.setStationState(jpStation.getState()); TdHYGFStationYearGenerate.setStationState(jpStation.getState());
if (ObjectUtils.isEmpty(tdHYGFStationMonthGenerate.getCreatedTime())) { if (ObjectUtils.isEmpty(TdHYGFStationYearGenerate.getCreatedTime())) {
tdHYGFStationMonthGenerate.setCreatedTime(System.currentTimeMillis()); TdHYGFStationYearGenerate.setCreatedTime(System.currentTimeMillis());
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} else { } else {
tdHYGFStationMonthGenerateMapper.insert(tdHYGFStationMonthGenerate); TdHYGFStationYearGenerateMapper.insert(TdHYGFStationYearGenerate);
} }
// 户用场站年发电量 // 户用场站年发电量
TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne( TdHYGFStationAllGenerate TdHYGFStationAllGenerate = TdHYGFStationAllGenerateMapper.selectOne(
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment