+ * Mapper 接口 + *
+ * + * @author cdf + * @since 2022-01-04 + */ +public interface LineBakMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author cdf + * @since 2022-01-04 + */ +public interface LineDetailMapper extends BaseMapper+ * Mapper 接口 + *
+ * + * @author cdf + * @since 2022-01-04 + */ +public interface LineMapper extends BaseMapper+ * + *
+ * + * @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+ *
+ * + * @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; + + +} diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/LineDetail.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/LineDetail.java new file mode 100644 index 0000000..31eef46 --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/LineDetail.java @@ -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; + + +/** + *+ * + *
+ * + * @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; +} diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgConPlantBNewenergy.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgConPlantBNewenergy.java new file mode 100644 index 0000000..e05eece --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgConPlantBNewenergy.java @@ -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; +} \ No newline at end of file diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgDevAclineB.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgDevAclineB.java new file mode 100644 index 0000000..2974829 --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SgDevAclineB.java @@ -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; +} diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SupervisionUserReportBak.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SupervisionUserReportBak.java new file mode 100644 index 0000000..da5da0d --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/SupervisionUserReportBak.java @@ -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; + + +} diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportBakPO.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportBakPO.java new file mode 100644 index 0000000..1aa942e --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportBakPO.java @@ -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; + +} diff --git a/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportPO.java b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportPO.java new file mode 100644 index 0000000..ce746fa --- /dev/null +++ b/relational_migration/relational_comm/src/main/java/com/njcn/relational/pojo/po/UserReportPO.java @@ -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; + + + + +} diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/DcloudBusController.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/DcloudBusController.java index 39a772d..7776ba4 100644 --- a/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/DcloudBusController.java +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/DcloudBusController.java @@ -42,4 +42,16 @@ public class DcloudBusController { DcloudSyncQuery query = DcloudSyncQuery.buildPlantBdC(null, null, null, null); dcloudBusService.syncDataToDb(query); } + + @GetMapping("/sync5") + public void syncData5() { + DcloudSyncQuery query = DcloudSyncQuery.buildSgConPlantBNewenergy(null, null, null, null); + dcloudBusService.syncDataToDb(query); + } + + @GetMapping("/sync6") + public void syncData6() { + DcloudSyncQuery query = DcloudSyncQuery.buildSgSgDevAclineB(null, null, null, null); + dcloudBusService.syncDataToDb(query); + } } diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/IndexController.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/IndexController.java index 9ce96b2..f80abe3 100644 --- a/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/IndexController.java +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/IndexController.java @@ -34,4 +34,10 @@ public class IndexController { public String logs() { return "forward:/pages/logs.html"; } + + @GetMapping("/taizhang") + public String taizhang() { + return "forward:/pages/userLedger.html"; + } + } \ No newline at end of file diff --git a/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/UserLedgerController.java b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/UserLedgerController.java new file mode 100644 index 0000000..e6f9701 --- /dev/null +++ b/relational_migration/relational_target/src/main/java/com/njcn/relational/controller/UserLedgerController.java @@ -0,0 +1,81 @@ +package com.njcn.relational.controller; + +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.njcn.relational.pojo.po.Line; +import com.njcn.relational.pojo.po.UserReportPO; +import com.njcn.relational.service.LineService; +import com.njcn.relational.service.UserLedgerService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.GetMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; +import org.springframework.web.bind.annotation.RestController; + +@RestController +@RequestMapping("/userLedger") +@RequiredArgsConstructor +@Slf4j +public class UserLedgerController { + + private final LineService lineService; + private final UserLedgerService userLedgerService; + + /** + * ҳѯ (Line, level=6) + */ + @GetMapping("/line/page") + public IPage