From 87a2fe3e6f1472a7e87e02d3fd956eee17b85352 Mon Sep 17 00:00:00 2001
From: aijinhui <aijinhui>
Date: 星期四, 12 十月 2023 15:28:33 +0800
Subject: [PATCH] 抽油机状态入库
---
ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java | 45 +++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 45 insertions(+), 0 deletions(-)
diff --git a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
index 2275bda..f5b13e3 100644
--- a/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
+++ b/ard-work/src/main/java/com/ruoyi/statistical/service/impl/StatisticalServiceImpl.java
@@ -1,6 +1,7 @@
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;
@@ -397,6 +398,50 @@
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++) {
--
Gitblit v1.9.3