| | |
|---|
| | | package com.ruoyi.statistical.service.impl; |
|---|
| | | |
|---|
| | | import com.alibaba.fastjson.JSONObject; |
|---|
| | | import com.alibaba.fastjson2.JSONArray; |
|---|
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|---|
| | | import com.ruoyi.alarm.access.mapper.ArdAlarmAccessMapper; |
|---|
| | | import com.ruoyi.alarm.apponekey.mapper.ArdAlarmApponekeyMapper; |
|---|
| | |
|---|
| | | return list; |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void data(String msg) { |
|---|
| | | JSONObject jsonObject = JSONObject.parseObject(msg); |
|---|
| | | String alarmTime = jsonObject.getString("alarmTime"); |
|---|
| | | List<JSONObject> list = (List<JSONObject>) jsonObject.get("ardAlarmRadars"); |
|---|
| | | if(list.size()>0){ |
|---|
| | | for (int i = 0; i < list.size(); i++) { |
|---|
| | | JSONObject j = list.get(i); |
|---|
| | | QueryWrapper<PumpStatus> queryWrapper = new QueryWrapper<>(); |
|---|
| | | queryWrapper.eq("target_id",j.getInteger("targetId")).eq("name",j.getString("name")); |
|---|
| | | PumpStatus pumpStatus1 = pumpStatusMapper.selectOne(queryWrapper); |
|---|
| | | if(pumpStatus1==null){ |
|---|
| | | PumpStatus pumpStatus = new PumpStatus(); |
|---|
| | | pumpStatus.setTargetId(j.getInteger("targetId")); |
|---|
| | | pumpStatus.setName(j.getString("name")); |
|---|
| | | if(j.containsKey("alarmType")){ |
|---|
| | | pumpStatus.setAlarmType(j.getString("alarmType")); |
|---|
| | | }else if(j.containsKey("alarm")){ |
|---|
| | | pumpStatus.setAlarmType(j.getString("alarm")); |
|---|
| | | } |
|---|
| | | pumpStatus.setAlarmTime(alarmTime); |
|---|
| | | pumpStatusMapper.insert(pumpStatus); |
|---|
| | | }else { |
|---|
| | | String alarmType = pumpStatus1.getAlarmType(); |
|---|
| | | Boolean bo = false; |
|---|
| | | if(j.containsKey("alarmType")){ |
|---|
| | | if(alarmType.equals(j.getString("alarmType"))){ |
|---|
| | | bo = true; |
|---|
| | | } |
|---|
| | | }else if(j.containsKey("alarm")){ |
|---|
| | | if(alarmType.equals(j.getString("alarm"))){ |
|---|
| | | bo = true; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(!bo){ |
|---|
| | | pumpStatus1.setAlarmType(j.getString("alarmType")); |
|---|
| | | pumpStatus1.setAlarmTime(alarmTime); |
|---|
| | | pumpStatusMapper.updateById(pumpStatus1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public List<CountVo> es(List<CountVo> list){ |
|---|
| | | List<CountVo> countVoList = new ArrayList<>(); |
|---|
| | | for (int i = 1; i <= 12 ; i++) { |
|---|
