在线监测-实时监控-获取配电柜的实时数据

whyclxw

2022-01-15 b9addeffbf718561d507f593367775cfe3a79ed1

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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
package com.whyc.service;
 
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.Response;
import com.whyc.mapper.PwrdevAcdataMapper;
import com.whyc.mapper.PwrdevAcdcdataMapper;
import com.whyc.mapper.PwrdevDcdataMapper;
import com.whyc.pojo.PwrdevAcdata;
import com.whyc.pojo.PwrdevAcdcdata;
import com.whyc.pojo.PwrdevDcdata;
import org.springframework.stereotype.Service;
 
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
@Service
public class PwrdevAcdcdataService {
    @Resource
    private PwrdevAcdcdataMapper mapper;
 
    @Resource
    private PwrdevAcdataMapper acdataMapper;
 
    @Resource
    private PwrdevDcdataMapper dcdataMapper;
 
    //查询电源的ＡＣＤＣ信息
    public Response getDataByDevId(int powerDeviceId) {
        QueryWrapper wrapper=new QueryWrapper();
        wrapper.eq("PowerDeviceId",powerDeviceId);
        List list=mapper.selectList(wrapper);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
 
    //获取配电柜的实时数据
    public Response getPowerInfoById(int powerDeviceId) {
        Map<String, Object> resultMap = new HashMap<>();
        PwrdevAcdata ac=acdataMapper.getInfo(powerDeviceId);
        PwrdevDcdata dc=dcdataMapper.getInfo(powerDeviceId);
        PwrdevAcdcdata acdc=mapper.getInfo(powerDeviceId);
        //时间30秒为超时基准
        int timeoutMilliSecond = 30*1000;
        if(ac==null){
            ac = new PwrdevAcdata();
            ac.setCommStatus(0);
        }
        else{
            if(System.currentTimeMillis()-ac.getRecordDatetime().getTime()>timeoutMilliSecond) {
                ac.setCommStatus(0);
            }else{
                ac.setCommStatus(1);
            }
        }
        if(dc==null){
            dc = new PwrdevDcdata();
            dc.setCommStatus(0);
        }else{
            if(System.currentTimeMillis()-dc.getRecordDatetime().getTime()>timeoutMilliSecond){
                dc.setCommStatus(0);
            }else{
                dc.setCommStatus(1);
            }
        }
        if(acdc==null){
            acdc = new PwrdevAcdcdata();
            acdc.setCommStatus(0);
        }else{
            if(System.currentTimeMillis()-acdc.getRecordDatetime().getTime()>timeoutMilliSecond){
                acdc.setCommStatus(0);
            }else{
                acdc.setCommStatus(1);
            }
        }
        int flag=0;
        //有一个模块通讯状态正常,则整体通讯状态为正常
        if(ac.getCommStatus()==0 && dc.getCommStatus()==0 && acdc.getCommStatus()==0){
            flag = 0;
        }else{
            flag = 1;
        }
        resultMap.put("ac", ac);
        resultMap.put("dc", dc);
        resultMap.put("acdc", acdc);
 
        return new Response().setII(1,flag,resultMap,flag>0?"通讯正常":"通讯不正常");
    }
 
    //获取配电柜的实时数据-ws接口专用
    public Response getPowerInfoById2(int powerDeviceId) {
        Map<String, Object> resultMap = new HashMap<>();
        PwrdevAcdata ac=acdataMapper.getInfo(powerDeviceId);
        PwrdevDcdata dc=dcdataMapper.getInfo(powerDeviceId);
        PwrdevAcdcdata acdc=mapper.getInfo(powerDeviceId);
        //时间30秒为超时基准
        int timeoutMilliSecond = 30*1000;
        if(ac==null){
            ac = new PwrdevAcdata();
            ac.setCommStatus(0);
        }
        else{
            if(System.currentTimeMillis()-ac.getRecordDatetime().getTime()>timeoutMilliSecond) {
                ac.setCommStatus(0);
            }else{
                ac.setCommStatus(1);
            }
        }
        if(dc==null){
            dc = new PwrdevDcdata();
            dc.setCommStatus(0);
        }else{
            if(System.currentTimeMillis()-dc.getRecordDatetime().getTime()>timeoutMilliSecond){
                dc.setCommStatus(0);
            }else{
                dc.setCommStatus(1);
            }
        }
        if(acdc==null){
            acdc = new PwrdevAcdcdata();
            acdc.setCommStatus(0);
        }else{
            if(System.currentTimeMillis()-acdc.getRecordDatetime().getTime()>timeoutMilliSecond){
                acdc.setCommStatus(0);
            }else{
                acdc.setCommStatus(1);
            }
        }
        int flag=0;
        //有一个模块通讯状态正常,则整体通讯状态为正常
        if(ac.getCommStatus()==0 && dc.getCommStatus()==0 && acdc.getCommStatus()==0){
            flag = 0;
        }else{
            flag = 1;
        }
        resultMap.put("ac", ac);
        resultMap.put("dc", dc);
        resultMap.put("acdc", acdc);
 
        Response response = new Response();
        response.set(1,flag);
        response.setData2(resultMap);
        return response;
    }
}