13693261870
2025-07-02 6708810c4de34dfb9513061432d656f91d56ee3a
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
package com.ruoyi.fuzhou.service.impl;
 
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.fuzhou.domain.DpEquipment;
import com.ruoyi.fuzhou.domain.ReceiveOilInfo;
import com.ruoyi.fuzhou.domain.ReceiveOilValue;
import com.ruoyi.fuzhou.mapper.ReceiveOilInfoMapper;
import com.ruoyi.fuzhou.service.ReceiveOilInfoService;
import com.ruoyi.fuzhou.service.ReceiveOilValueService;
import com.ruoyi.fuzhou.utils.oilmodbus.ModbusOilServerUtils;
import com.ruoyi.fuzhou.websocket.WebSocketOilServer;
import jakarta.annotation.Resource;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;
 
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
 
/**
 * <p>
 * 油数据接收管理 服务实现类
 * </p>
 *
 * @author zhangyy
 * @since 2025-03-12
 */
@Service
public class ReceiveOilInfoServiceImpl extends ServiceImpl<ReceiveOilInfoMapper, ReceiveOilInfo> implements ReceiveOilInfoService {
 
    @Resource
    private ReceiveOilValueService receiveOilValueService;
 
    @Resource
    private RedisTemplate redisTemplate;
 
    @Override
    public void saveOil(List<ReceiveOilInfo> list, DpEquipment info) {
        JSONObject jsonObject = ModbusOilServerUtils.getValue(list.get(0).getIp(), list.get(0).getPort(), list);
        if (jsonObject != null && jsonObject.size() > 0) {
            ReceiveOilValue receiveOilValue = JSON.toJavaObject(jsonObject, ReceiveOilValue.class);
            receiveOilValue.setCreateTime(new Date());
            receiveOilValue.setDeviceName(list.get(0).getDeviceName());
            if (Math.abs(Double.valueOf(receiveOilValue.getOilTimeFlow())) > 0) {
                redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
                receiveOilValueService.save(receiveOilValue);
            } else {
                Object obj = redisTemplate.opsForValue().get("VALUE@" + receiveOilValue.getDeviceName());
                if (obj == null) {
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
                    receiveOilValueService.save(receiveOilValue);
                } else if (!obj.toString().equals(receiveOilValue.getOilTimeFlow())) {
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
                    receiveOilValueService.save(receiveOilValue);
                }
            }
        }
        //制造socket数据
//        JSONArray header = new JSONArray();
//        list.forEach(item -> {
//            JSONObject head = new JSONObject();
//            head.put("param", item.getParam());
//            head.put("paramCode", item.getParamCode());
//            head.put("unit", item.getUnit());
//            header.add(head);
//        });
//        ReceiveOilValue receiveOilValue = receiveOilValueService.getOne(new LambdaQueryWrapper<ReceiveOilValue>() {{
//            or().eq(ReceiveOilValue::getDeviceName, list.get(0).getDeviceName()).orderByDesc(ReceiveOilValue::getCreateTime).last("limit 1");
//        }});
//        if (receiveOilValue != null) {
//            JSONObject object = new JSONObject();
//            object.put("header", header);
//            object.put("body", JSONObject.parseObject(JSON.toJSONString(receiveOilValue)));
//            object.put("info", JSONObject.parseObject(JSON.toJSONString(info)));
//            object.put("status", "1");
////            WebSocketOilServer.sendAllMessage(object.toJSONString());
//        }
    }
 
    @Override
    public void saveOilLijiuNingde(List<ReceiveOilInfo> list, DpEquipment info) {
        JSONObject jsonObject = ModbusOilServerUtils.getValue(list.get(0).getIp(), list.get(0).getPort(), list);
        if (jsonObject != null && jsonObject.size() > 0) {
            ReceiveOilValue receiveOilValue = JSON.toJavaObject(jsonObject, ReceiveOilValue.class);
            receiveOilValue.setCreateTime(new Date());
            receiveOilValue.setDeviceName(list.get(0).getDeviceName());
            if (Math.abs(Double.valueOf(receiveOilValue.getOilTimeFlow())) > 0 || Math.abs(Double.valueOf(receiveOilValue.getVolumeFlow())) > 0) {
                redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow() + receiveOilValue.getVolumeFlow(), 30, TimeUnit.MINUTES);
                receiveOilValueService.save(receiveOilValue);
            } else {
                Object obj = redisTemplate.opsForValue().get("VALUE@" + receiveOilValue.getDeviceName());
                if (obj == null) {
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow() + receiveOilValue.getVolumeFlow(), 30, TimeUnit.MINUTES);
                    receiveOilValueService.save(receiveOilValue);
                } else if (!obj.toString().equals(receiveOilValue.getOilTimeFlow() + receiveOilValue.getVolumeFlow())) {
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow() + receiveOilValue.getVolumeFlow(), 30, TimeUnit.MINUTES);
                    receiveOilValueService.save(receiveOilValue);
                }
            }
        }
    }
 
    @Override
    public void saveLijiuOil(List<ReceiveOilInfo> list, DpEquipment info) {
        JSONObject jsonObject = ModbusOilServerUtils.getLijiuValue(list.get(0).getIp(), list.get(0).getPort(), list);
        if (jsonObject != null && jsonObject.size() > 0) {
            ReceiveOilValue receiveOilValue = JSON.toJavaObject(jsonObject, ReceiveOilValue.class);
            receiveOilValue.setDeviceName(list.get(0).getDeviceName());
            receiveOilValue.setCreateTime(new Date());
            if (Math.abs(Double.valueOf(receiveOilValue.getOilTimeFlow())) > 0) {
                receiveOilValueService.save(receiveOilValue);
                redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
            }else {
                Object obj = redisTemplate.opsForValue().get("VALUE@" + receiveOilValue.getDeviceName());
                if (obj == null) {
                    receiveOilValueService.save(receiveOilValue);
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
                } else if (!obj.toString().equals(receiveOilValue.getOilTimeFlow())) {
                    redisTemplate.opsForValue().set("VALUE@" + receiveOilValue.getDeviceName(), receiveOilValue.getOilTimeFlow(), 30, TimeUnit.MINUTES);
                    receiveOilValueService.save(receiveOilValue);
                }
            }
        }
    }
 
}