Commit de882b4b authored by caotao's avatar caotao

mysql户用光伏-逆变器数据没有存储三方场站id问题修改

parent c88740b8
...@@ -56,11 +56,11 @@ public class HouseholdTestController { ...@@ -56,11 +56,11 @@ public class HouseholdTestController {
@ApiOperation(httpMethod = "POST", value = "锦浪云", notes = "锦浪云") @ApiOperation(httpMethod = "POST", value = "锦浪云", notes = "锦浪云")
public void golangnew() throws IOException { public void golangnew() throws IOException {
// goLangDataAcquisitionService.stationList(); // goLangDataAcquisitionService.stationList();
goLangDataAcquisitionService.stationDetail(); // goLangDataAcquisitionService.stationDetail();
// goLangDataAcquisitionService.collectorList(); // goLangDataAcquisitionService.collectorList();
//// goLangDataAcquisitionService.inverterList(); //// goLangDataAcquisitionService.inverterList();
goLangDataAcquisitionService.collectorDetail(); goLangDataAcquisitionService.collectorDetail();
goLangDataAcquisitionService.inverterDetail(); // goLangDataAcquisitionService.inverterDetail();
// goLangDataAcquisitionService.inverAlramInfo(); // goLangDataAcquisitionService.inverAlramInfo();
} }
} }
...@@ -13,6 +13,7 @@ public class CollectorDetailDto { ...@@ -13,6 +13,7 @@ public class CollectorDetailDto {
private String stationId; private String stationId;
private String rssiLevel; private String rssiLevel;
private String model; private String model;
private String name;
private String addr; private String addr;
private String stationName; private String stationName;
} }
...@@ -126,5 +126,9 @@ public class JpCollector implements Serializable { ...@@ -126,5 +126,9 @@ public class JpCollector implements Serializable {
*/ */
@TableField("addr") @TableField("addr")
private String addr; private String addr;
/**
* 场站地址
*/
@TableField("name")
private String name;
} }
...@@ -287,6 +287,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe ...@@ -287,6 +287,7 @@ public class GoLangDataAcquisitionServiceImpl implements GoLangDataAcquisitionSe
jpCollector.setState(GoLangConstant.stationStaus.get(collectorDetailDto.getState())); jpCollector.setState(GoLangConstant.stationStaus.get(collectorDetailDto.getState()));
jpCollector.setStationName(collectorDetailDto.getStationName()); jpCollector.setStationName(collectorDetailDto.getStationName());
jpCollector.setAddr(collectorDetailDto.getAddr()); jpCollector.setAddr(collectorDetailDto.getAddr());
jpCollector.setName(collectorDetailDto.getName());
if (ObjectUtils.isEmpty(jpCollector.getSequenceNbr())) { if (ObjectUtils.isEmpty(jpCollector.getSequenceNbr())) {
jpCollectorMapper.insert(jpCollector); jpCollectorMapper.insert(jpCollector);
} else { } else {
......
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