whycrzg
2021-02-23 351b9a53cb9ecebdf8f79db0117f540d9c42c2a4
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
package com.fgkj.services;
 
import com.fgkj.dto.Dev_param;
import com.fgkj.dto.Process_survey;
import com.fgkj.dto.ServiceModel;
import com.fgkj.mapper.ProcessServerDao;
import com.fgkj.mapper.impl.Dev_paramMapper;
import com.fgkj.mapper.impl.Process_surveyMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Service;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
 
import java.util.List;
 
import javax.annotation.Resource;
@Service
public class Dev_paramService {
 
    ServiceModel model = new ServiceModel();
 
    @Resource
    private Dev_paramMapper mapper;
    @Resource
    private Process_surveyMapper surveyMapper;
    
     //给设备添加参数
    public ServiceModel add(Object obj){
        boolean bl=mapper.add(obj);
        if(bl){
            model.setCode(1);
            model.setMsg("插入成功!");
        }else{
            model.setCode(0);
            model.setMsg("插入失败!");
        }        
        return model;
    }
    //查询所有设备的所有的告警参数
    public ServiceModel update(Dev_param obj) {
        ServiceModel model = new ServiceModel();
        Boolean bl = true;
        try {
            bl = mapper.update(obj) > 0;
        } catch (Exception e) {
            e.printStackTrace();
            model.setCode(0);
            model.setMsg("修改失败!");
            return model;
        }
        if (bl) {
            //告警参数修改成功后重启服务
            int alarm_id = ((Dev_param) obj).getAlm_id();
            Process_survey process = new Process_survey();
            //将电池告警的服务设为重启
            process.setProcessName(ProcessServerDao.BMS_FBSDEV_ALARM_BATT);
            Boolean b = surveyMapper.update(process);
            model.setCode(1);
            model.setMsg("修改成功!");
        } else {
            model.setCode(0);
            model.setMsg("修改失败!");
        }
        return model;
    }
     //查询所有设备的所有的告警参数
    public ServiceModel searchAll(){
        ServiceModel model = new ServiceModel();
        List list=mapper.searchAll();
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }        
        return model;
    }
    //根据设备id和告警类型查设备告警参数
    public ServiceModel serchByCondition(Dev_param obj){
        ServiceModel model = new ServiceModel();
        List list=mapper.serchByCondition(obj);
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }        
        return model;
    }
    //查询所有存在设备告警参数的机房
    public ServiceModel serchAllDevId(){
        ServiceModel model = new ServiceModel();
        List list=mapper.serchAllDevId();
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }        
        return model;
    }
    //根据设备id查询设备对应的告警参数种类
    public ServiceModel serchByInfo(Dev_param obj){
        ServiceModel model = new ServiceModel();
        List list=mapper.serchByInfo(obj);
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }        
        return model;
    }
    
     //根据设备id查询设备所有的参数
    public ServiceModel serchParamById(Dev_param obj){
        ServiceModel model = new ServiceModel();
        List list=mapper.serchParamById(obj);
        if(list!=null && list.size()>0){
            model.setCode(1);
            model.setData(list);
            model.setMsg("查询成功!");
        }else{
            model.setCode(0);
            model.setMsg("查询失败!");
        }        
        return model;
    }
 
}