Other/data-migration
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.mysql基本信息同步

Browse Source
This commit is contained in:
wr
2024-11-25 12:10:31 +08:00
parent 00beb8efa8
commit 47518928e0
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
influx-data/influx-source/src/main/java/com/njcn/influx/bo/po/OraclePqLineDetail.java
View File

@@ -106,7 +106,7 @@ public class OraclePqLineDetail {
* 统计类型 * 统计类型
*/ */
@TableField(value = "STATFLAG") @TableField(value = "STATFLAG")
private Short statflag; private Integer statflag;
/** /**
* *

7
influx-data/influx-source/src/main/java/com/njcn/influx/service/impl/OracleMonitorStatusToMysqlServiceImpl.java
View File

@@ -5,7 +5,6 @@ import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.njcn.influx.bo.po.*; import com.njcn.influx.bo.po.*;
import com.njcn.influx.config.IdMappingCache;
import com.njcn.influx.config.RedisUtil; import com.njcn.influx.config.RedisUtil;
import com.njcn.influx.mapper.OracleRmpEventDetailPOMapper; import com.njcn.influx.mapper.OracleRmpEventDetailPOMapper;
import com.njcn.influx.mapper.PqDeviceMapper; import com.njcn.influx.mapper.PqDeviceMapper;
@@ -168,6 +167,12 @@ public class OracleMonitorStatusToMysqlServiceImpl implements OracleMonitorStatu
.set(PqLineDetail::getDealCapacity, oraclePqLineDetail.getXycMp()) .set(PqLineDetail::getDealCapacity, oraclePqLineDetail.getXycMp())
.set(PqLineDetail::getPtType, oraclePqLineDetail.getPttype()) .set(PqLineDetail::getPtType, oraclePqLineDetail.getPttype())
.set(PqLineDetail::getTimeInterval, oraclePqLineDetail.getTinterval()) .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()); .eq(PqLineDetail::getId, line.getId());
if(loadTypeMap.containsKey(oraclePqLineDetail.getLoadtype())){ if(loadTypeMap.containsKey(oraclePqLineDetail.getLoadtype())){
DictData loadType= rmpEventDetailPOMapper.getDicDataByNameAndTypeName("干扰源类型", loadTypeMap.get(oraclePqLineDetail.getLoadtype())); DictData loadType= rmpEventDetailPOMapper.getDicDataByNameAndTypeName("干扰源类型", loadTypeMap.get(oraclePqLineDetail.getLoadtype()));