Commit 0d6e553a authored by tangwei's avatar tangwei

修改td 电站数据

parent 3a85bcdc
...@@ -224,12 +224,11 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe ...@@ -224,12 +224,11 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.isDelete?0:1);
if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} }
HYGFJPStationPowerHistory hygfjpStationPowerHistory = new HYGFJPStationPowerHistory(); HYGFJPStationPowerHistory hygfjpStationPowerHistory = new HYGFJPStationPowerHistory();
hygfjpStationPowerHistory.setCreatedTime(System.currentTimeMillis()); hygfjpStationPowerHistory.setCreatedTime(System.currentTimeMillis());
hygfjpStationPowerHistory.setThirdStationId(jpStation.getThirdStationId()); hygfjpStationPowerHistory.setThirdStationId(jpStation.getThirdStationId());
......
...@@ -148,7 +148,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe ...@@ -148,7 +148,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.isDelete?0:1);
if (!org.springframework.util.ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!org.springframework.util.ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
......
...@@ -314,10 +314,10 @@ public class ImasterDataServiceImpl implements ImasterDataService { ...@@ -314,10 +314,10 @@ public class ImasterDataServiceImpl implements ImasterDataService {
tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdJpStation.setThirdStationId( imasterStationList.getPlantCode()); tdJpStation.setThirdStationId( imasterStationList.getPlantCode());
tdJpStation.setThirdCode(PVProducerInfoEnum.HUAWEI.getCode()); tdJpStation.setThirdCode(PVProducerInfoEnum.HUAWEI.getCode());
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.getIsDelete()?0:1);
if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
......
...@@ -254,28 +254,16 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe ...@@ -254,28 +254,16 @@ public class KsolarDataAcquisitionServiceImpl implements KSolarDataAcquisitionSe
tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdJpStation.setThirdStationId( ksolarStation.getStationId()); tdJpStation.setThirdStationId( ksolarStation.getStationId());
tdJpStation.setThirdCode(PVProducerInfoEnum.KSOLAR.getCode()); tdJpStation.setThirdCode(PVProducerInfoEnum.KSOLAR.getCode());
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.getIsDelete()?0:1);
if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} }
HYGFJPStationPowerHistory hygfjpStationPowerHistory = new HYGFJPStationPowerHistory(); HYGFJPStationPowerHistory hygfjpStationPowerHistory = new HYGFJPStationPowerHistory();
hygfjpStationPowerHistory.setCreatedTime(System.currentTimeMillis()); hygfjpStationPowerHistory.setCreatedTime(System.currentTimeMillis());
hygfjpStationPowerHistory.setThirdStationId(jpStation.getThirdStationId()); hygfjpStationPowerHistory.setThirdStationId(jpStation.getThirdStationId());
......
...@@ -325,10 +325,10 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ ...@@ -325,10 +325,10 @@ public class SofarDataAcquisitionServiceImpl implements SofarDataAcquisitionServ
tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdJpStation.setThirdStationId( jpStation.getThirdStationId()); tdJpStation.setThirdStationId( jpStation.getThirdStationId());
tdJpStation.setThirdCode(PVProducerInfoEnum.SH.getCode()); tdJpStation.setThirdCode(PVProducerInfoEnum.SH.getCode());
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.getIsDelete()?0:1);
if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
......
...@@ -317,9 +317,9 @@ public class SunlightServiceImpl implements SunlightService { ...@@ -317,9 +317,9 @@ public class SunlightServiceImpl implements SunlightService {
tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode()); tdJpStation.setRegionalCompaniesCode(jpStation.getRegionalCompaniesCode());
tdJpStation.setThirdStationId( jpStation.getThirdStationId()); tdJpStation.setThirdStationId( jpStation.getThirdStationId());
tdJpStation.setThirdCode( PVProducerInfoEnum.YG.getCode()); tdJpStation.setThirdCode( PVProducerInfoEnum.YG.getCode());
tdJpStation.setIsDelete(jpStation.isDelete?0:1); tdJpStation.setIsDelete(jpStation.getIsDelete()?0:1);
if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) { if (!ObjectUtils.isEmpty(tdJpStation.getCreatedTime())) {
tdJpStationMapper.updateById(tdJpStation); tdJpStationMapper.insert(tdJpStation);
} else { } else {
tdJpStation.setCreatedTime(System.currentTimeMillis()); tdJpStation.setCreatedTime(System.currentTimeMillis());
tdJpStationMapper.insert(tdJpStation); tdJpStationMapper.insert(tdJpStation);
......
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