package com.ruoyi.device.service.impl; import cn.hutool.core.collection.CollectionUtil; import com.alibaba.fastjson.JSONArray; import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.ruoyi.common.utils.RedisUtil; import com.ruoyi.device.constant.DCResistanceMqttConstants; import com.ruoyi.device.mapper.CollectBridgeMapper; import com.ruoyi.device.pojo.CollectBridge; import com.ruoyi.device.service.CollectBridgeService; import com.ruoyi.device.vo.DCResistanceMqttVO; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; import java.math.BigDecimal; import java.time.Duration; import java.time.Instant; import java.time.LocalDateTime; import java.time.ZoneId; import java.util.List; import java.util.Map; import java.util.Objects; /** * 数字电桥采集 * * @author zhuo * @since 2025-02-19 */ @Service @Slf4j public class CollectBridgeServiceImpl extends ServiceImpl implements CollectBridgeService { /** * 填充采集数据 * @param jsonObject */ @Override public void addBridgeValue(JSONObject jsonObject) { JSONArray dataArray = jsonObject.getJSONArray("data"); for (int i = 0; i < dataArray.size(); i++) { JSONObject listInfo = dataArray.getJSONObject(i); // 存储数据 String dataStream = listInfo.getString("dataStream"); if (dataStream.equals("DQCS.DQCS.SN")) { JSONArray dataPoints = listInfo.getJSONArray("dataPoints"); JSONObject pointsJSONObject = dataPoints.getJSONObject(0); String entrustCode = pointsJSONObject.getString("value"); // 解析时间戳 Instant instant = Instant.ofEpochMilli(pointsJSONObject.getLong("time")); LocalDateTime collectDate = LocalDateTime.ofInstant(instant, ZoneId.systemDefault()); // 先存储编号, 后续存储值 CollectBridge collectBridge = new CollectBridge(); collectBridge.setEntrustCode(entrustCode); collectBridge.setCollectDate(collectDate); baseMapper.insert(collectBridge); } // 寄存器地址等于64获取结果值 if (dataStream.equals("DQCS.DQCS.64")) { JSONArray dataPoints = listInfo.getJSONArray("dataPoints"); JSONObject pointsJSONObject = dataPoints.getJSONObject(0); String value = pointsJSONObject.getString("value"); if (value.equals("64")) { for (int j = 0; j < dataArray.size(); j++) { JSONObject listInfo2 = dataArray.getJSONObject(j); String dataStream2 = listInfo2.getString("dataStream"); // 寄存器地址等于64获取结果值 if (dataStream2.equals("DQCS.DQCS.DZZ")) { JSONArray dataPoints2 = listInfo2.getJSONArray("dataPoints"); JSONObject pointsJSONObject2 = dataPoints2.getJSONObject(0); String collectValue = pointsJSONObject2.getString("value"); // 解析时间戳 Instant instant = Instant.ofEpochMilli(pointsJSONObject2.getLong("time")); LocalDateTime collectDate = LocalDateTime.ofInstant(instant, ZoneId.systemDefault()); // 查询最新一条数据 CollectBridge collectBridge = baseMapper.selectOne(Wrappers.lambdaQuery() .orderByDesc(CollectBridge::getCollectDate) .last("limit 1")); // 判断两条数据是否相差在10分钟之内和有没有编号 if (isWithinTenMinutes(collectDate, collectBridge.getCollectDate()) && StringUtils.isNotBlank(collectBridge.getEntrustCode())) { // 修改检验值 collectBridge.setCollectValue(collectValue); baseMapper.updateById(collectBridge); } else { // 只存储值 CollectBridge bridge = new CollectBridge(); bridge.setCollectValue(collectValue); bridge.setCollectDate(collectDate); baseMapper.insert(bridge); } } } } } } } @Override public void addBridgeValueByNS(String jsonStr) { Map dataMap = JSONObject.parseObject(jsonStr, new TypeReference>(){}.getType()); if(CollectionUtil.isNotEmpty(dataMap) && Objects.nonNull(dataMap.get("data"))){ List dataList = JSONArray.parseObject(dataMap.get("data").toString(), new TypeReference>(){}.getType()); //过滤出包含实际电阻值的对象 // 处理 NSDQCS.DQCS.DZZ 数据 processSingleValueDataStream(dataList, DCResistanceMqttConstants.NSDQCS_DQCS_DZZ); // 处理 NSTSSC.TSSC.WY 数据 processThreeTimesValueDataStream(dataList, DCResistanceMqttConstants.NSTSSC_TSSC_WY); // DCResistanceMqttVO dcResistanceMqttVO = dataList.stream().filter(f -> StringUtils.equals(f.getDataStream(), DCResistanceMqttConstants.NSDQCS_DQCS_DZZ)).findFirst().orElse(null); // if(Objects.nonNull(dcResistanceMqttVO)){ // List dataPoints = dcResistanceMqttVO.getDataPoints(); // BigDecimal value = CollectionUtil.isNotEmpty(dataPoints)?dataPoints.get(0).getValue():BigDecimal.ZERO; // //保存实际电阻值到redis // RedisUtil.set(DCResistanceMqttConstants.NSDQCS_DQCS_DZZ,value.doubleValue()); // } } } /** * 处理单值数据流的数据并保存到 Redis * @param dataList 数据列表 * @param dataStream 数据流标识 */ private void processSingleValueDataStream(List dataList, String dataStream) { DCResistanceMqttVO dcResistanceMqttVO = dataList.stream() .filter(f -> StringUtils.equals(f.getDataStream(), dataStream)) .findFirst() .orElse(null); if(Objects.nonNull(dcResistanceMqttVO)){ List dataPoints = dcResistanceMqttVO.getDataPoints(); BigDecimal value = CollectionUtil.isNotEmpty(dataPoints)?dataPoints.get(0).getValue():BigDecimal.ZERO; // 保存单个值到 redis RedisUtil.set(dataStream, value.doubleValue()); } } /** * 处理需要获取三次不同值的数据流,并保存到 Redis * @param dataList 数据列表 * @param dataStream 数据流标识 */ private void processThreeTimesValueDataStream(List dataList, String dataStream) { // 从 Redis 获取已存储的值 Object valueFromRedis = RedisUtil.get(dataStream); JSONArray valueArray = new JSONArray(); if (valueFromRedis != null) { if (valueFromRedis instanceof String) { try { valueArray = JSONArray.parseArray((String) valueFromRedis); } catch (Exception e) { // 如果解析失败,说明 Redis 中的值可能不是合法的 JSON 数组,创建空数组 valueArray = new JSONArray(); } } else if (valueFromRedis instanceof Double) { // 如果是 Double 类型,将其添加到数组中 valueArray.add(valueFromRedis); } } // 筛选出当前数据流对应的数据 DCResistanceMqttVO dcResistanceMqttVO = dataList.stream() .filter(f -> StringUtils.equals(f.getDataStream(), dataStream)) .findFirst() .orElse(null); if (Objects.nonNull(dcResistanceMqttVO)) { List dataPoints = dcResistanceMqttVO.getDataPoints(); if (CollectionUtil.isNotEmpty(dataPoints)) { BigDecimal value = dataPoints.get(0).getValue(); valueArray.add(value.doubleValue()); // 只保留最新的三个值 if (valueArray.size() > 3) { valueArray.remove(0); } } } // 将更新后的值保存到 Redis RedisUtil.set(dataStream, valueArray.toJSONString()); } public static boolean isWithinTenMinutes(LocalDateTime dateTime1, LocalDateTime dateTime2) { Duration duration = Duration.between(dateTime1, dateTime2); long minutesDifference = Math.abs(duration.toMinutes()); return minutesDifference <= 10; } }