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

1.调整

Browse Source
This commit is contained in:
chendaofei
2026-07-25 14:25:26 +08:00
parent d27cf48571
commit b461169df5
34 changed files with 1782 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/LineBakMapper.java Normal file
View File

@@ -0,0 +1,19 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.LineBak;
/**
* <p>
* Mapper 接口
* </p>
*
* @author cdf
* @since 2022-01-04
*/
public interface LineBakMapper extends BaseMapper<LineBak> {
}

25
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/LineDetailMapper.java Normal file
View File

@@ -0,0 +1,25 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.LineDetail;
import org.apache.ibatis.annotations.Param;
import org.apache.ibatis.annotations.Select;
import java.util.List;
/**
* <p>
* Mapper 接口
* </p>
*
* @author cdf
* @since 2022-01-04
*/
public interface LineDetailMapper extends BaseMapper<LineDetail> {
}

18
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/LineMapper.java Normal file
View File

@@ -0,0 +1,18 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.Line;
/**
* <p>
* Mapper 接口
* </p>
*
* @author cdf
* @since 2022-01-04
*/
public interface LineMapper extends BaseMapper<Line> {
}

10
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/SgConPlantBNewenergyMapper.java Normal file
View File

@@ -0,0 +1,10 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.SgConPlantBNewenergy;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface SgConPlantBNewenergyMapper extends BaseMapper<SgConPlantBNewenergy> {
}

10
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/SgDevAclineBMapper.java Normal file
View File

@@ -0,0 +1,10 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.SgDevAclineB;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface SgDevAclineBMapper extends BaseMapper<SgDevAclineB> {
}

11
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/SupervisionUserReportBakMapper.java Normal file
View File

@@ -0,0 +1,11 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.SupervisionUserReportBak;
/**
* 监测对象中间关系表 Mapper
*/
public interface SupervisionUserReportBakMapper extends BaseMapper<SupervisionUserReportBak> {
}

10
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/UserReportBakMapper.java Normal file
View File

@@ -0,0 +1,10 @@
package com.njcn.relational.mapper;
import com.github.jeffreyning.mybatisplus.base.MppBaseMapper;
import com.njcn.relational.pojo.po.UserReportBakPO;
import org.apache.ibatis.annotations.Mapper;
@Mapper
public interface UserReportBakMapper extends MppBaseMapper<UserReportBakPO> {
}

17
relational_migration/relational_comm/src/main/java/com/njcn/relational/mapper/UserReportPOMapper.java Normal file
View File

@@ -0,0 +1,17 @@
package com.njcn.relational.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.njcn.relational.pojo.po.UserReportPO;
/**
*
* Description:
* Date: 2024/4/25 10:07【需求编号】
*
* @author clam
* @version V1.0.0
*/
public interface UserReportPOMapper extends BaseMapper<UserReportPO> {
}

22
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/dto/DcloudSyncQuery.java
View File

@@ -82,4 +82,26 @@ public class DcloudSyncQuery {
query.setPropertyList("D5000_ID,D5000_NAME,DCC_ID,DCLOUD_ID,DCLOUD_NAME,DCLOUD_VOLTAGELEVEL,OMS_ID,OMS_NAME,OWNER,PMS_ID,PSDB_DEV_TYPE,PSDB_ID,PSDB_NAME,SETTING_ID,SETTING_NAME,STATUS");
return query;
}
public static DcloudSyncQuery buildSgConPlantBNewenergy(String filter, String orderStr, Integer pageIndex, Integer pageSize) {
DcloudSyncQuery query = new DcloudSyncQuery();
query.setTableName("SG_CON_PLANT_B_NEWENERGY");
query.setFilter(filter);
query.setOrderStr(orderStr);
query.setPageIndex(pageIndex);
query.setPageSize(pageSize);
query.setPropertyList("ID,COMPENSATION_VAR_CAP,CONNECTIVE_STATION_ID,ENERGY_STORAGE_CAPACITY,ENERGY_STORAGE_DEVICE_COUNT,INVERTER_COUNT,OWNER,STAMP,TYPE_NUM,WINDTURBINE_NUM,GROUND_TYPE,FILT_NUM,HOUR_NUM,WINDTOWER_NUM,PHOTOMETER_NUM,WINDRANGE,INSTALL_LOCATION");
return query;
}
public static DcloudSyncQuery buildSgSgDevAclineB(String filter, String orderStr, Integer pageIndex, Integer pageSize) {
DcloudSyncQuery query = new DcloudSyncQuery();
query.setTableName("SG_DEV_ACLINE_B");
query.setFilter(filter);
query.setOrderStr(orderStr);
query.setPageIndex(pageIndex);
query.setPageSize(pageSize);
query.setPropertyList("ID,NAME,VOLTAGE_TYPE,GRID_ID,SUPPLIER_ID,SYS_FLAG,TAG,ASSETS_COMPANY_ID,CHECK_CODE,COMPACT_ZONE,DEV_ID,DISPATCH_ORG_ID,START_BAY_ID,START_ST_ID,START_TOWER_ID,END_BAY_ID,END_ST_ID,END_TOWER_ID,ERECTINGMETHOD,EXPIRY_DATE,OFF_TIME,ON_TIME,OPERATE_DATE,OWNER,RUNNING_STATE,STAMP,ISOPTICFIBEREQUIPED,IS_COMPACT,LENGTH,LICENSE_ORG_ID,LINETYPE,MEMBER_FEATURE_TAG,STRIDE_FEATURE_TAG");
return query;
}
}

71
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/Line.java Normal file
View File

@@ -0,0 +1,71 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.njcn.relational.pojo.bo.BaseEntity;
import lombok.Data;
import lombok.EqualsAndHashCode;
import java.util.List;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-01-04
*/
@Data
@EqualsAndHashCode(callSuper = true)
@TableName("pq_line")
public class Line extends BaseEntity {
private static final long serialVersionUID = 1L;
/**
* 监测点Id
*/
private String id;
/**
* 父节点（0为根节点）
*/
private String pid;
/**
* 上层所有节点
*/
private String pids;
/**
* 名称
*/
private String name;
/**
* 等级：0-项目名称；1- 工程名称；2-单位；3-部门；4-终端；5-母线；6-监测点
*/
private Integer level;
/**
* 排序（默认为0，有特殊排序需要时候人为输入）
*/
private Integer sort;
/**
* 备注
*/
private String remark;
/**
* 状态 0-删除；1-正常；默认正常
*/
private Integer state;
@TableField(exist = false)
private List<Line> children;
}

31
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/LineBak.java Normal file
View File

@@ -0,0 +1,31 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* <p>
* </p>
*
* @author cdf
* @since 2022-01-04
*/
@Data
@TableName("pq_line_bak")
public class LineBak {
private static final long serialVersionUID = 1L;
/**
* 监测点Id
*/
private String id;
/**
* 原始监测点Id
*/
private Integer lineId;
}

217
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/LineDetail.java Normal file
View File

@@ -0,0 +1,217 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* <p>
*
* </p>
*
* @author cdf
* @since 2022-01-04
*/
@Data
@TableName("pq_line_detail")
public class LineDetail {
private static final long serialVersionUID = 1L;
/**
* 监测点序号
*/
@TableId
private String id;
@TableField(exist = false)
private String monitorName;
/**
* 线路号（在同一台设备中的监测点号）
*/
private Integer num;
/**
* PT一次变比
*/
private Float pt1;
/**
* PT二次变比
*/
private Float pt2;
/**
* CT一次变比
*/
private Float ct1;
/**
* CT二次变比
*/
private Float ct2;
/**
* 设备容量
*/
private Float devCapacity;
/**
* 短路容量
*/
private Float shortCapacity;
/**
* 基准容量
*/
private Float standardCapacity;
/**
* 协议容量
*/
private Float dealCapacity;
/**
* 接线类型(0:星型接法;1:三角型接法;2:开口三角型接法)
*/
private Integer ptType;
/**
* 测量间隔（1-10分钟）
*/
private Integer timeInterval;
/**
* 干扰源类型,字典表
*/
private String loadType;
/**
* 行业类型，字典表
*/
private String businessType;
/**
* 网公司谐波监测平台标志(0-否;1-是)，默认否
*/
private Integer monitorFlag;
/**
* 电网标志（0-电网侧；1-非电网侧）
*/
private Integer powerFlag;
/**
* 国网谐波监测平台监测点号
*/
private String monitorId;
/**
* 监测点对象名称
*/
private String objName;
/**
* 监测点对象id
*/
private String objId;
/**
* 监测对象大类
*/
private String bigObjType;
/**
* 监测对象小类
*/
private String smallObjType;
/**
* 人为干预 0 不参与统计 1 参与统计
*/
private Integer statFlag;
/**
* 关联字典的终端等级
*/
private String lineGrade;
/**
* 备注
*/
private String remark;
/**
* 电网侧变电站
*/
private String powerSubstationName;
/**
* 分类等级
*/
private String calssificationGrade;
/**
* 上级电站
*/
@Deprecated
private String superiorsSubstation;
/**
* 挂接线路
*/
@Deprecated
private String hangLine;
/**
* 监测点拥有者
*/
private String owner;
/**
* 拥有者职务
*/
private String ownerDuty;
/**
* 拥有者联系方式
*/
private String ownerTel;
/**
* 接线图
*/
private String wiringDiagram;
/**
* 监测点接线相别（0，单相,1，三相，默认三相）
*/
private Integer ptPhaseType;
/**
* 监测点实际安装位置
*/
private String actualArea;
/**
* 监测点运行状态（0：运行；1：检修；2：停运；3：调试；4：退运）
*/
private Integer runFlag;
/**
* 新能源场站信息ID
*/
@Deprecated
private String newStationId;
/**
* 通讯状态
*/
@TableField(exist = false)
private Integer comFlag;
}

121
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgConPlantBNewenergy.java Normal file
View File

@@ -0,0 +1,121 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableField;
import java.io.Serializable;
import java.math.BigDecimal;
import lombok.Data;
/**
* 新能源发电厂基础信息
* 表名：SG_CON_PLANT_B_NEWENERGY
*/
@Data
@TableName("SG_CON_PLANT_B_NEWENERGY")
public class SgConPlantBNewenergy implements Serializable {
private static final long serialVersionUID = 1L;
/**
* 电站ID（主键）
*/
@TableId("ID")
private String id;
/**
* 无功补偿容量(Mvar)
*/
@TableField("COMPENSATION_VAR_CAP")
private BigDecimal compensationVarCap;
/**
* 并网变电站ID，引用变电站基本信息表
*/
@TableField("CONNECTIVE_STATION_ID")
private String connectiveStationId;
/**
* 储能容量(MW)
*/
@TableField("ENERGY_STORAGE_CAPACITY")
private BigDecimal energyStorageCapacity;
/**
* 储能设备台数
*/
@TableField("ENERGY_STORAGE_DEVICE_COUNT")
private Integer energyStorageDeviceCount;
/**
* 逆变器台数
*/
@TableField("INVERTER_COUNT")
private Integer inverterCount;
/**
* 拥有者
*/
@TableField("OWNER")
private String owner;
/**
* 更新标志：机构代码+人员代码+时间
*/
@TableField("STAMP")
private String stamp;
/**
* 逆变器或风机类型数
*/
@TableField("TYPE_NUM")
private Integer typeNum;
/**
* 风机台数
*/
@TableField("WINDTURBINE_NUM")
private Integer windturbineNum;
/**
* 汇集系统中性点接地方式
*/
@TableField("GROUND_TYPE")
private Integer groundType;
/**
* 滤波器组数
*/
@TableField("FILT_NUM")
private Integer filtNum;
/**
* 设计利用小时数
*/
@TableField("HOUR_NUM")
private BigDecimal hourNum;
/**
* 测风塔数量
*/
@TableField("WINDTOWER_NUM")
private Integer windtowerNum;
/**
* 测光检测仪器数量
*/
@TableField("PHOTOMETER_NUM")
private Integer photometerNum;
/**
* 风电布置类型
*/
@TableField("WINDRANGE")
private Integer windrange;
/**
* 风电场安装位置
*/
@TableField("INSTALL_LOCATION")
private Integer installLocation;
}

223
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgDevAclineB.java Normal file
View File

@@ -0,0 +1,223 @@
package com.njcn.relational.pojo.po;
/**
* @Author: cdf
* @CreateTime: 2026-07-22
* @Description:
*/
import com.baomidou.mybatisplus.annotation.TableName;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableField;
import lombok.Data;
import java.io.Serializable;
import java.math.BigDecimal;
import java.time.LocalDate;
import java.time.LocalDateTime;
/**
* 交流线路基础信息
* 表名：SG_DEV_ACLINE_B
*/
@Data
@TableName("SG_DEV_ACLINE_B")
public class SgDevAclineB implements Serializable {
private static final long serialVersionUID = 1L;
/**
* ID 主键
*/
@TableId("ID")
private String id;
/**
* 线路名称
*/
@TableField("NAME")
private String name;
/**
* 电压等级
*/
@TableField("VOLTAGE_TYPE")
private Integer voltageType;
/**
* 所属电网
*/
@TableField("GRID_ID")
private String gridId;
/**
* 生产厂家
*/
@TableField("SUPPLIER_ID")
private String supplierId;
/**
* 系统属性
*/
@TableField("SYS_FLAG")
private String sysFlag;
/**
* 标签
*/
@TableField("TAG")
private String tag;
/**
* 资产单位
*/
@TableField("ASSETS_COMPANY_ID")
private String assetsCompanyId;
/**
* 校验码
*/
@TableField("CHECK_CODE")
private String checkCode;
/**
* 紧凑型区段
*/
@TableField("COMPACT_ZONE")
private String compactZone;
/**
* 设备ID
*/
@TableField("DEV_ID")
private String devId;
/**
* 调度机构
*/
@TableField("DISPATCH_ORG_ID")
private String dispatchOrgId;
/**
* 起点所属间隔
*/
@TableField("START_BAY_ID")
private String startBayId;
/**
* 起点厂站
*/
@TableField("START_ST_ID")
private String startStId;
/**
* 起点杆塔
*/
@TableField("START_TOWER_ID")
private String startTowerId;
/**
* 终点所属间隔
*/
@TableField("END_BAY_ID")
private String endBayId;
/**
* 终点厂站
*/
@TableField("END_ST_ID")
private String endStId;
/**
* 终点杆塔
*/
@TableField("END_TOWER_ID")
private String endTowerId;
/**
* 架设方式
*/
@TableField("ERECTINGMETHOD")
private Integer erectingmethod;
/**
* 退役日期
*/
@TableField("EXPIRY_DATE")
private String expiryDate;
/**
* 失效时间
*/
@TableField("OFF_TIME")
private String offTime;
/**
* 生效时间
*/
@TableField("ON_TIME")
private String onTime;
/**
* 投运日期
*/
@TableField("OPERATE_DATE")
private String operateDate;
/**
* 拥有者
*/
@TableField("OWNER")
private String owner;
/**
* 运行状态
*/
@TableField("RUNNING_STATE")
private Integer runningState;
/**
* 更新标志
*/
@TableField("STAMP")
private String stamp;
/**
* 光纤类型
*/
@TableField("ISOPTICFIBEREQUIPED")
private String isopticfiberequiped;
/**
* 是否紧凑型
*/
@TableField("IS_COMPACT")
private String isCompact;
/**
* 线路全长(km)
*/
@TableField("LENGTH")
private BigDecimal length;
/**
* 许可机构
*/
@TableField("LICENSE_ORG_ID")
private String licenseOrgId;
/**
* 线路类型
*/
@TableField("LINETYPE")
private Integer linetype;
/**
* 成员特征标签
*/
@TableField("MEMBER_FEATURE_TAG")
private String memberFeatureTag;
/**
* 跨域特征标签
*/
@TableField("STRIDE_FEATURE_TAG")
private String strideFeatureTag;
}

30
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SupervisionUserReportBak.java Normal file
View File

@@ -0,0 +1,30 @@
package com.njcn.relational.pojo.po;
/**
* @Author: cdf
* @CreateTime: 2026-07-23
* @Description:
*/
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
/**
* 监测对象中间关系表
*/
@Data
@TableName("SUPERVISION_USER_REPORT_BAK")
public class SupervisionUserReportBak {
/**
* 本地系统监测对象id
*/
private String userId;
/**
* 其他系统监测对象id
*/
private String midId;
}

29
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportBakPO.java Normal file
View File

@@ -0,0 +1,29 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableName;
import com.github.jeffreyning.mybatisplus.anno.MppMultiId;
import lombok.Data;
/**
* @Author: cdf
* @CreateTime: 2026-07-25
* @Description:
*/
@Data
@TableName("user_report_bak")
public class UserReportBakPO {
/**
* 用户id
*/
@MppMultiId
private String userId;
/**
* 中间表id
*/
@MppMultiId
private String midId;
}

182
relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportPO.java Normal file
View File

@@ -0,0 +1,182 @@
package com.njcn.relational.pojo.po;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import com.njcn.relational.pojo.bo.BaseEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.NoArgsConstructor;
import java.math.BigDecimal;
import java.time.LocalDate;
/**
*
* Description:
* Date: 2024/4/25 10:07【需求编号】
*
* @author clam
* @version V1.0.0
*/
@EqualsAndHashCode(callSuper = true)
@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName(value = "supervision_user_report")
public class UserReportPO extends BaseEntity {
/**
* id
*/
@TableId(value = "id", type = IdType.ASSIGN_UUID)
private String id;
/**
* 填报人
*/
@TableField(value = "reporter")
private String reporter;
/**
* 填报日期
*/
@TableField(value = "report_date")
private LocalDate reportDate;
/**
* 填报部门
*/
@TableField(value = "org_id")
private String orgId;
/**
* 工程预期投产日期
*/
@TableField(value = "expected_production_date")
private LocalDate expectedProductionDate;
/**
* 用户性质
*/
@TableField(value = "user_type")
private Integer userType;
/**
* 所属地市
*/
@TableField(value = "city")
private String city;
/**
* 归口管理部门
*/
@TableField(value = "responsible_department")
private String responsibleDepartment;
/**
* 用户状态
*/
@TableField(value = "user_status")
private Integer userStatus;
/**
* 变电站
*/
@TableField(value = "substation")
private String substation;
/**
* 电压等级
*/
@TableField(value = "voltage_level")
private String voltageLevel;
/**
* 工程名称
*/
@TableField(value = "project_name")
private String projectName;
/**
* 预测评估单位
*/
@TableField(value = "evaluation_dept")
private String evaluationDept;
/**
* 预测评估结论
*/
@TableField(value = "evaluation_conclusion")
private String evaluationConclusion;
/**
* 流程实例的编号
*/
@TableField(value = "process_instance_id")
private String processInstanceId;
@TableField(value = "history_instance_id")
private String historyInstanceId;
/**
* 数据来源类型 0.正常流程审核入库 1.批量导入
*/
@TableField(value = "data_type")
private Integer dataType;
/**
* 电站id
*/
private String stationId;
/**
* 额定容量
*/
private Double ratePower;
/**
* 经度
*/
private BigDecimal longitude;
/**
* 纬度
*/
private BigDecimal latitude;
/**
* 终端id
*/
@TableField(value = "dev_id")
private String devId;
/**
* 监测点id
*/
@TableField(value = "line_id")
private String lineId;
@TableField(value = "second_assessment_id")
private String secondAssessmentId;
/**
* 审批状态：1:审批中；2：审批通过；3：审批不通过；4：已取消
*/
@TableField(value = "status")
private Integer status;
/**
* 状态：0-删除 1-正常
*/
@TableField(value = "State")
private Integer state;
}