第三方接口调整

whyczh

2022-07-04 374713dc55c1aeaf256ba6fa310bb0dea888442a

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
package com.whyc.service;
 
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.whyc.dto.AlarmDaoFactory;
import com.whyc.dto.Response;
import com.whyc.dto.result.AlarmRes;
import com.whyc.mapper.*;
import com.whyc.pojo.BattalarmData;
import com.whyc.pojo.PwrdevAlarm;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
 
import javax.annotation.Resource;
import java.util.List;
 
@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;
 
    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(){
 
        return null;
    }
 
 
}