第三方接口调整

whyczh

2022-07-05 935e250f4a891c346894b7fe73edfa4b46dafcb3

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
package com.whyc.service;
 
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.AlarmDaoFactory;
import com.whyc.dto.InterfaceParam;
import com.whyc.dto.Response;
import com.whyc.dto.result.AlarmRes;
import com.whyc.mapper.*;
import com.whyc.pojo.*;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import javax.annotation.Resource;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
@Slf4j
@Service
public class InterfaceService {
    @Resource
    private BattInfMapper battInfMapper;
    @Resource
    private PowerInfMapper powerInfMapper;
    @Resource
    private BattalarmDataMapper battalarmDataMapper;
    @Resource
    private PwrdevAlarmMapper pwrdevAlarmMapper;
    @Resource
    private DevalarmDataMapper devalarmDataMapper;
    @Resource
    private PwrdevAcdcdataMapper pwrdevAcdcdataMapper;
    @Resource
    private Fbs9100StateMapper fbs9100StateMapper;
    @Resource
    private BattRtdataMapper battRtdataMapper;
    @Resource
    private BattRtstateMapper battRtstateMapper;
 
    public Response getBattinf(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List list = battInfMapper.getBattInf();
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
 
    public Response getPowerInf(int pageNum,int pageSize){
        //分页信息
        PageHelper.startPage(pageNum,pageSize);
        List list = powerInfMapper.selectList(null);
        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,pageInfo);
    }
 
    //电池告警实时查询-websocket使用
    @Transactional
    public Response getBattAlarm(List battgroupIds) {
//        //分页信息
//        PageHelper.startPage(pageNum,pageSize);
        List<AlarmRes> list=battalarmDataMapper.getBattAlarm(battgroupIds);
        for (AlarmRes a:list) {
            List<BattalarmData> l=a.getAdatas();
            for (BattalarmData adata:l) {
                adata.setAlmSignalIdName(AlarmDaoFactory.getAlarmName(adata.getAlmSignalId()));
                adata.setAlmLevelName(AlarmDaoFactory.getAlarmType(adata.getAlmLevel()));
            }
        }
//        PageInfo<AlarmRes> pinfo=new PageInfo<AlarmRes>(list);
        return new Response().set(1,list);
    }
 
    //电源实时告警查询--第三方接口-websocket
    @Transactional
    public Response getPwrdevAlarm(List powerDeviceIds){
//        //分页信息
//        PageHelper.startPage(pageNum,pageSize);
        List<PwrdevAlarm> list=pwrdevAlarmMapper.getPwrdevAlarm(powerDeviceIds);
        for (PwrdevAlarm p:list) {
            p.setAlarmName(AlarmDaoFactory.getAllAlarmName(p.getAlmType()));
            if(p.getAlmIndex()!=0){
                p.setAlarmName(p.getAlarmName().replace("N","第"+p.getAlmIndex()+"路"));
            }
        }
//        PageInfo pageInfo=new PageInfo(list);
        return new Response().set(1,list);
    }
 
 
    //设备告警实时查询-webSocket
    public Response getDevAlarm(List deviceIds) {
//        PageHelper.startPage(pageNum,pageSize);
        List list=devalarmDataMapper.getDevAlarm(deviceIds);
//        PageInfo pageInfo=new PageInfo(list);
        return  new Response().set(1,list);
    }
 
    public Response getRealTime(InterfaceParam param){
        List<PwrdevAcdcdata> powerRts = pwrdevAcdcdataMapper.getPowerRealtime(param.getPowerDeviceIds());
        List<Fbs9100State> fbs9100States = fbs9100StateMapper.getRealtime(param.getDeviceIds());
        List<BattRtdata> battRtDatas = battRtdataMapper.getRealtime(param.getStationIds());
        List<BattRtstate> battRtstates = battRtstateMapper.getRealtime(param.getBattgroupIds());
        Map<String,Object> map = new HashMap<>();
        map.put("powerRts",powerRts);
        map.put("fbs9100States",fbs9100States);
        map.put("battRtDatas",battRtDatas);
        map.put("battRtstates",battRtstates);
        return new Response().set(1,map);
    }
 
 
}