From 47518928e0c06a7d9000c55c68bfb90c4358df6a Mon Sep 17 00:00:00 2001 From: wr <1754607820@qq.com> Date: Mon, 25 Nov 2024 12:10:31 +0800 Subject: [PATCH] =?UTF-8?q?1.mysql=E5=9F=BA=E6=9C=AC=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/njcn/influx/bo/po/OraclePqLineDetail.java | 2 +- .../impl/OracleMonitorStatusToMysqlServiceImpl.java | 7 ++++++- 2 files changed, 7 insertions(+), 2 deletions(-) diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/bo/po/OraclePqLineDetail.java b/influx-data/influx-source/src/main/java/com/njcn/influx/bo/po/OraclePqLineDetail.java index 2afd632..7a88ac2 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/bo/po/OraclePqLineDetail.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/bo/po/OraclePqLineDetail.java @@ -106,7 +106,7 @@ public class OraclePqLineDetail { * 统计类型 */ @TableField(value = "STATFLAG") - private Short statflag; + private Integer statflag; /** * diff --git a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleMonitorStatusToMysqlServiceImpl.java b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleMonitorStatusToMysqlServiceImpl.java index 1c1a31a..5bf7727 100644 --- a/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleMonitorStatusToMysqlServiceImpl.java +++ b/influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleMonitorStatusToMysqlServiceImpl.java @@ -5,7 +5,6 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.njcn.influx.bo.po.*; -import com.njcn.influx.config.IdMappingCache; import com.njcn.influx.config.RedisUtil; import com.njcn.influx.mapper.OracleRmpEventDetailPOMapper; import com.njcn.influx.mapper.PqDeviceMapper; @@ -168,6 +167,12 @@ public class OracleMonitorStatusToMysqlServiceImpl implements OracleMonitorStatu .set(PqLineDetail::getDealCapacity, oraclePqLineDetail.getXycMp()) .set(PqLineDetail::getPtType, oraclePqLineDetail.getPttype()) .set(PqLineDetail::getTimeInterval, oraclePqLineDetail.getTinterval()) + + .set(PqLineDetail::getPowerFlag, oraclePqLineDetail.getPowerid()) + .set(PqLineDetail::getObjName, oraclePqLineDetail.getObjname()) + .set(PqLineDetail::getMonitorId, oraclePqLineDetail.getMonitorId()) + .set(PqLineDetail::getStatFlag, oraclePqLineDetail.getStatflag()) + .set(PqLineDetail::getPowerSubstationName, oraclePqLineDetail.getPowerSubstationName()) .eq(PqLineDetail::getId, line.getId()); if(loadTypeMap.containsKey(oraclePqLineDetail.getLoadtype())){ DictData loadType= rmpEventDetailPOMapper.getDicDataByNameAndTypeName("干扰源类型", loadTypeMap.get(oraclePqLineDetail.getLoadtype()));