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()));