Commit 42f8b181 authored by caotao's avatar caotao

固德威场站数据入库到mysql、tdengine

parent 83241be3
package com.yeejoin.amos.api.householdapi.face.service.impl; package com.yeejoin.amos.api.householdapi.face.service.impl;
import cn.hutool.core.bean.BeanUtil; import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
...@@ -76,6 +77,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe ...@@ -76,6 +77,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
if(ObjectUtils.isEmpty(jpStation)){ if(ObjectUtils.isEmpty(jpStation)){
jpStation = new JpStation(); jpStation = new JpStation();
} }
jpStation.setThirdStationId(goodWeStationList.getPowerstation_id());
jpStation.setThirdCode(PVProducerInfoEnum.GDW.getCode()); jpStation.setThirdCode(PVProducerInfoEnum.GDW.getCode());
jpStation.setSnCode(goodWeStationList.getPowerstation_id()); jpStation.setSnCode(goodWeStationList.getPowerstation_id());
jpStation.setCapacity(goodWeStationList.getCapacity()); jpStation.setCapacity(goodWeStationList.getCapacity());
...@@ -222,6 +224,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe ...@@ -222,6 +224,7 @@ public class GoodWeDataAcquisitionServiceImpl implements GoodWeDataAcquisitionSe
jpStation.setUserName(goodWeStationDetail.getOwner_name()); jpStation.setUserName(goodWeStationDetail.getOwner_name());
jpStation.setUserPhone(goodWeStationDetail.getOwner_phone()); jpStation.setUserPhone(goodWeStationDetail.getOwner_phone());
jpStation.setStationContact(goodWeStationDetail.getOwner_name()); jpStation.setStationContact(goodWeStationDetail.getOwner_name());
jpStation.setAccessTime(DateUtil.parse(goodWeStationDetail.getTurnon_time(), DatePattern.NORM_DATETIME_PATTERN));
if(!ObjectUtils.isEmpty(jpStation.getSequenceNbr())){ if(!ObjectUtils.isEmpty(jpStation.getSequenceNbr())){
jpStationMapper.updateById(jpStation); jpStationMapper.updateById(jpStation);
} }
......
...@@ -4,7 +4,7 @@ package com.yeejoin.amos.openapi.enums; ...@@ -4,7 +4,7 @@ package com.yeejoin.amos.openapi.enums;
public enum PVProducerInfoEnum { public enum PVProducerInfoEnum {
GDW("固德威","GDW"), GDW("固德威","GOODWE"),
SH("首航","SH"), SH("首航","SH"),
JLY("锦浪云","JLY"), JLY("锦浪云","JLY"),
KSOLAR("科士达","KSD"), KSOLAR("科士达","KSD"),
......
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