diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/PqDataVerifyServiceImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/PqDataVerifyServiceImpl.java index abd3f96..b74477d 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/PqDataVerifyServiceImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/PqDataVerifyServiceImpl.java @@ -27,7 +27,7 @@ public class PqDataVerifyServiceImpl extends MppServiceImpl list) { - this.saveOrUpdateBatchByMultiId(list); + this.saveOrUpdateBatchByMultiId(list,500); } @Override diff --git a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataComAssImpl.java b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataComAssImpl.java index 2600d35..ce2d160 100644 --- a/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataComAssImpl.java +++ b/data-processing/data-processing-boot/src/main/java/com/njcn/dataProcess/service/impl/relation/RelationDataComAssImpl.java @@ -31,6 +31,6 @@ public class RelationDataComAssImpl extends MppServiceImpl syncDevStatusUpdate(@RequestBody List list); + + @PostMapping("/syncLineStatusUpdate") + HttpResult syncLineStatusUpdate(@RequestBody List list); + +} diff --git a/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/api/fallback/SyncStatusFeignClientFallbackFactory.java b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/api/fallback/SyncStatusFeignClientFallbackFactory.java new file mode 100644 index 0000000..9388e62 --- /dev/null +++ b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/api/fallback/SyncStatusFeignClientFallbackFactory.java @@ -0,0 +1,55 @@ +package com.njcn.api.fallback; + +import com.njcn.api.SyncStatusFeignClient; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.exception.BusinessException; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.dataProcess.util.DataProcessingEnumUtil; +import com.njcn.po.mysql.Device; +import com.njcn.po.mysql.LineDetail; +import feign.hystrix.FallbackFactory; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.List; + + +/** + * @Description: + * @Author: wr + * @Date: 2025/3/19 10:19 + */ +@Slf4j +@Component +public class SyncStatusFeignClientFallbackFactory implements FallbackFactory { + + + /** + * 输出远程请求接口异常日志 + * @param cause RPC请求异常 + */ + @Override + public SyncStatusFeignClient create(Throwable cause) { + //判断抛出异常是否为解码器抛出的业务异常 + Enum exceptionEnum = CommonResponseEnum.SERVICE_FALLBACK; + if(cause.getCause() instanceof BusinessException){ + BusinessException businessException = (BusinessException) cause.getCause(); + exceptionEnum = DataProcessingEnumUtil.getExceptionEnum(businessException.getResult()); + } + Enum finalExceptionEnum = exceptionEnum; + return new SyncStatusFeignClient() { + + @Override + public HttpResult syncDevStatusUpdate(List list) { + log.error("{}异常，降级处理，异常为：{}","同步装置运行状态",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } + + @Override + public HttpResult syncLineStatusUpdate(List list) { + log.error("{}异常，降级处理，异常为：{}","同步监测点运行状态",cause.toString()); + throw new BusinessException(finalExceptionEnum); + } + }; + } +} diff --git a/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/Device.java b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/Device.java new file mode 100644 index 0000000..8c48830 --- /dev/null +++ b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/Device.java @@ -0,0 +1,165 @@ +package com.njcn.po.mysql; + +import com.baomidou.mybatisplus.annotation.TableId; +import com.baomidou.mybatisplus.annotation.TableName; +import lombok.Data; + +import java.io.Serializable; +import java.time.LocalDate; +import java.time.LocalDateTime; + +/** + *

+ * + *

+ * + * @author cdf + * @since 2022-01-04 + */ +@Data +@TableName("pq_device") +public class Device implements Serializable{ + + private static final long serialVersionUID = 1L; + + /** + * 装置序号 + */ + @TableId + private String id; + + /** + * 装置模型（0：虚拟设备；1：实际设备；2：离线设备；）默认是实际设备 + */ + private Integer devModel; + + /** + * 数据类型（0：暂态系统；1：稳态系统；2：两个系统） + */ + private Integer devDataType; + + /** + * 终端运行状态（0：运行；1：检修；2：停运；3：调试；4：退运） + */ + private Integer runFlag; + + /** + * 通讯状态（0：中断；1：正常） + */ + private Integer comFlag; + + /** + * 设备制造商，字典表 + */ + private String manufacturer; + + /** + * 定检状态（0：未检 1：已检） + */ + private Integer checkFlag; + + /** + * 前置类型（MMS、CLD）字典表 + */ + private String frontType; + + /** + * 终端型号（570、580……）字典表 + */ + private String devType; + + /** + * 网络参数 + */ + private String ip; + + /** + * 召唤标志（0：周期触发；1：变为触发） + */ + private Integer callFlag; + + /** + * 端口 + */ + private Integer port; + + /** + * 装置识别码（3ds加密） + */ + private String series; + + /** + * 装置秘钥（3ds加密） + */ + private String devKey; + + /** + * 前置序号Id,前置表 + */ + private String nodeId; + + /** + * 投运时间 + */ + private LocalDate loginTime; + + /** + * 数据更新时间 + */ + private LocalDateTime updateTime; + + /** + * 本次定检时间，默认等于投运时间 + */ + private LocalDate thisTimeCheck; + + /** + * 下次定检时间,默认为投运时间后推3年，假如时间小于3个月则为待检 + */ + private LocalDate nextTimeCheck; + + /** + * 电度功能 0 关闭 1开启 + */ + private Integer electroplate; + + /** + * 对时功能 0 关闭， 1开启 + */ + private Integer onTime; + + /** + * 合同号 + */ + private String contract; + + /** + * 设备sim卡号 + */ + private String sim; + + + /** + * 装置系列 + */ + private String devSeries; + + + /** + * 监测装置安装位置 + */ + private String devLocation; + + + /** + * 监测厂家设备编号 + */ + private String devNo; + + + /** + * 告警功能 0:关闭 null、1:开启 + */ + private Integer isAlarm; + +} diff --git a/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/LineDetail.java b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/LineDetail.java new file mode 100644 index 0000000..bd5917d --- /dev/null +++ b/migration-influxdb/migration-influxdb-api/src/main/java/com/njcn/po/mysql/LineDetail.java @@ -0,0 +1,215 @@ +package com.njcn.po.mysql; + +import com.baomidou.mybatisplus.annotation.TableField; +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; + + /** + * 监测点序号 + */ + private String id; + + /** + * 线路号（在同一台设备中的监测点号） + */ + 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; + + /** + * 监测点对象名称 + */ + @Deprecated + 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; + + /** + * 监测点拥有者 + */ + @Deprecated + private String owner; + + /** + * 拥有者职务 + */ + @Deprecated + private String ownerDuty; + + /** + * 拥有者联系方式 + */ + @Deprecated + 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/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/controller/SyncStatusUpdateController.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/controller/SyncStatusUpdateController.java new file mode 100644 index 0000000..c4b6676 --- /dev/null +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/controller/SyncStatusUpdateController.java @@ -0,0 +1,53 @@ +package com.njcn.migration.insert.controller; + +import com.njcn.common.pojo.annotation.OperateInfo; +import com.njcn.common.pojo.enums.common.LogEnum; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.common.utils.HttpResultUtil; +import com.njcn.migration.insert.service.ISyncStatusUpdateService; +import com.njcn.po.mysql.Device; +import com.njcn.po.mysql.LineDetail; +import com.njcn.web.controller.BaseController; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestBody; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +import java.util.List; + +/** + * @author xy + */ +@Slf4j +@RestController +@RequestMapping("/syncStatusUpdate") +@Api(tags = "同步状态") +@AllArgsConstructor +public class SyncStatusUpdateController extends BaseController { + + private final ISyncStatusUpdateService syncStatusUpdateService; + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/syncDevStatusUpdate") + @ApiOperation("同步装置状态") + public HttpResult syncDevStatusUpdate(@RequestBody List list){ + String methodDescribe = getMethodDescribe("syncDevStatusUpdate"); + syncStatusUpdateService.syncDevStatusUpdate(list); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/syncLineStatusUpdate") + @ApiOperation("同步监测点状态") + public HttpResult syncLineStatusUpdate(@RequestBody List list){ + String methodDescribe = getMethodDescribe("syncLineStatusUpdate"); + syncStatusUpdateService.syncLineStatusUpdate(list); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + +} diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/DeviceMapper.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/DeviceMapper.java new file mode 100644 index 0000000..8e08673 --- /dev/null +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/DeviceMapper.java @@ -0,0 +1,17 @@ +package com.njcn.migration.insert.mapper; + + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.po.mysql.Device; + +/** + *

+ * Mapper 接口 + *

+ * + * @author cdf + * @since 2022-01-04 + */ +public interface DeviceMapper extends BaseMapper { + +} diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/LineDetailMapper.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/LineDetailMapper.java new file mode 100644 index 0000000..5428b7d --- /dev/null +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/mapper/LineDetailMapper.java @@ -0,0 +1,16 @@ +package com.njcn.migration.insert.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.po.mysql.LineDetail; + +/** + *

+ * Mapper 接口 + *

+ * + * @author cdf + * @since 2022-01-04 + */ +public interface LineDetailMapper extends BaseMapper { + +} diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/ISyncStatusUpdateService.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/ISyncStatusUpdateService.java new file mode 100644 index 0000000..177ab22 --- /dev/null +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/ISyncStatusUpdateService.java @@ -0,0 +1,15 @@ +package com.njcn.migration.insert.service; + +import com.njcn.po.mysql.Device; +import com.njcn.po.mysql.LineDetail; + +import java.util.List; +import java.util.Map; + +public interface ISyncStatusUpdateService { + + void syncDevStatusUpdate(List list); + + void syncLineStatusUpdate(List list); + +} diff --git a/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/SyncStatusUpdateServiceImpl.java b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/SyncStatusUpdateServiceImpl.java new file mode 100644 index 0000000..f6b752f --- /dev/null +++ b/migration-influxdb/migration-influxdb-insert-boot/src/main/java/com/njcn/migration/insert/service/impl/SyncStatusUpdateServiceImpl.java @@ -0,0 +1,32 @@ +package com.njcn.migration.insert.service.impl; + +import com.njcn.migration.insert.mapper.DeviceMapper; +import com.njcn.migration.insert.mapper.LineDetailMapper; +import com.njcn.migration.insert.service.ISyncStatusUpdateService; +import com.njcn.po.mysql.Device; +import com.njcn.po.mysql.LineDetail; +import lombok.AllArgsConstructor; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @author xy + */ +@Service +@AllArgsConstructor +public class SyncStatusUpdateServiceImpl implements ISyncStatusUpdateService { + + private final DeviceMapper deviceMapper; + private final LineDetailMapper lineDetailMapper; + + @Override + public void syncDevStatusUpdate(List list) { + list.forEach(deviceMapper::updateById); + } + + @Override + public void syncLineStatusUpdate(List list) { + list.forEach(lineDetailMapper::updateById); + } +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/controller/SyncStatusController.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/controller/SyncStatusController.java new file mode 100644 index 0000000..295a046 --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/controller/SyncStatusController.java @@ -0,0 +1,48 @@ +package com.njcn.migration.read.controller; + +import com.njcn.common.pojo.annotation.OperateInfo; +import com.njcn.common.pojo.enums.common.LogEnum; +import com.njcn.common.pojo.enums.response.CommonResponseEnum; +import com.njcn.common.pojo.response.HttpResult; +import com.njcn.common.utils.HttpResultUtil; +import com.njcn.migration.read.service.ISyncStatusService; +import com.njcn.web.controller.BaseController; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.web.bind.annotation.PostMapping; +import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RestController; + +/** + * @author xy + */ +@Slf4j +@RestController +@RequestMapping("/syncStatus") +@Api(tags = "同步状态") +@AllArgsConstructor +public class SyncStatusController extends BaseController { + + private final ISyncStatusService syncStatusService; + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/syncDevStatus") + @ApiOperation("同步装置状态") + public HttpResult syncDevStatus(){ + String methodDescribe = getMethodDescribe("syncDevStatus"); + syncStatusService.syncDevStatus(); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + + @OperateInfo(info = LogEnum.BUSINESS_COMMON) + @PostMapping("/syncLineStatus") + @ApiOperation("同步监测点状态") + public HttpResult syncLineStatus(){ + String methodDescribe = getMethodDescribe("syncLineStatus"); + syncStatusService.syncLineStatus(); + return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); + } + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/MigrationInfluxDBJob.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/MigrationInfluxDBJob.java index 6051a55..fa5a00d 100644 --- a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/MigrationInfluxDBJob.java +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/MigrationInfluxDBJob.java @@ -45,8 +45,8 @@ public class MigrationInfluxDBJob { public void InfluxDBJob() { // 获取当前时间 LocalDateTime now = LocalDateTime.now(); - // 减去一个小时 - LocalDateTime oneHourAgo = now.minusHours(1); + // 减去2个小时 + LocalDateTime oneHourAgo = now.minusHours(2); // 将分钟和秒设置为0 LocalDateTime result = oneHourAgo.truncatedTo(ChronoUnit.HOURS); // 加上59分钟59秒 diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/SyncStatusJob.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/SyncStatusJob.java new file mode 100644 index 0000000..f56f38e --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/job/SyncStatusJob.java @@ -0,0 +1,33 @@ +package com.njcn.migration.read.job; + +import com.njcn.migration.read.service.ISyncStatusService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.scheduling.annotation.EnableScheduling; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + + +/** + * Description: + * Date: 2024/1/18 10:15【需求编号】 + * + * @author clam + * @version V1.0.0 + */ +@Component +@EnableScheduling +@RequiredArgsConstructor +@Slf4j +public class SyncStatusJob { + + private final ISyncStatusService syncStatusService; + + @Scheduled(cron="0 0/10 * * * ?") + public void syncRunFlag() { + System.out.println("--------------------------------装置、监测点运行状态同步------------------------------------"); + syncStatusService.syncDevStatus(); + syncStatusService.syncLineStatus(); + } + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/DeviceMapper.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/DeviceMapper.java new file mode 100644 index 0000000..e09551a --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/DeviceMapper.java @@ -0,0 +1,17 @@ +package com.njcn.migration.read.mapper; + + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.po.mysql.Device; + +/** + *

+ * Mapper 接口 + *

+ * + * @author cdf + * @since 2022-01-04 + */ +public interface DeviceMapper extends BaseMapper { + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/LineDetailMapper.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/LineDetailMapper.java new file mode 100644 index 0000000..6945a60 --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/mapper/LineDetailMapper.java @@ -0,0 +1,16 @@ +package com.njcn.migration.read.mapper; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.njcn.po.mysql.LineDetail; + +/** + *

+ * Mapper 接口 + *

+ * + * @author cdf + * @since 2022-01-04 + */ +public interface LineDetailMapper extends BaseMapper { + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/ISyncStatusService.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/ISyncStatusService.java new file mode 100644 index 0000000..277c535 --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/ISyncStatusService.java @@ -0,0 +1,9 @@ +package com.njcn.migration.read.service; + +public interface ISyncStatusService { + + void syncDevStatus(); + + void syncLineStatus(); + +} diff --git a/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/SyncStatusServiceImpl.java b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/SyncStatusServiceImpl.java new file mode 100644 index 0000000..171f427 --- /dev/null +++ b/migration-influxdb/migration-influxdb-read-boot/src/main/java/com/njcn/migration/read/service/impl/SyncStatusServiceImpl.java @@ -0,0 +1,49 @@ +package com.njcn.migration.read.service.impl; + +import com.baomidou.mybatisplus.core.conditions.Wrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.njcn.api.SyncStatusFeignClient; +import com.njcn.migration.read.mapper.DeviceMapper; +import com.njcn.migration.read.mapper.LineDetailMapper; +import com.njcn.migration.read.service.ISyncStatusService; +import com.njcn.po.mysql.Device; +import com.njcn.po.mysql.LineDetail; +import lombok.AllArgsConstructor; +import org.springframework.stereotype.Service; + +import java.util.HashMap; +import java.util.List; +import java.util.Map; + +/** + * @author xy + */ +@Service +@AllArgsConstructor +public class SyncStatusServiceImpl implements ISyncStatusService { + + private final DeviceMapper deviceMapper; + private final LineDetailMapper lineDetailMapper; + private final SyncStatusFeignClient syncStatusFeignClient; + + @Override + public void syncDevStatus() { + Wrapper wrapper = new QueryWrapper<>(); + List list = deviceMapper.selectList(wrapper); + if (!list.isEmpty()) { + //调用修改程序 + syncStatusFeignClient.syncDevStatusUpdate(list); + } + } + + @Override + public void syncLineStatus() { + Wrapper wrapper = new QueryWrapper<>(); + List list = lineDetailMapper.selectList(wrapper); + if (!list.isEmpty()) { + //调用修改程序 + syncStatusFeignClient.syncLineStatusUpdate(list); + } + } + +}