‘liusuyi’
2023-06-14 e4b75d402e8cb84a70e2f84f4e19f566ffd38d85
ard-work/src/main/java/com/ruoyi/alarm/globalAlarm/service/impl/GlobalAlarmServiceImpl.java
@@ -128,7 +128,6 @@
        switch (topic) {
            case "stealelec":
                ArdAlarmStealelec ardAlarmStealelec = JSONObject.parseObject(message, ArdAlarmStealelec.class);
                ardAlarmStealelec.setId(uuid);
                ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(ardAlarmStealelec.getDescribe());
                if(well!=null)
                {
@@ -136,8 +135,13 @@
                    ardAlarmStealelec.setLatitude(well.getLatitude());
                    ardAlarmStealelec.setDeptId(well.getDeptId());
                }
                int insertaas = ardAlarmStealelecMapper.insert(ardAlarmStealelec);
                if(insertaas>0)
                ArdAlarmStealelec existe = ardAlarmStealelecMapper.selectByPrimaryKey(ardAlarmStealelec.getId());
                if(StringUtils.isNotNull(existe))
                {
                    return;
                }
                int aas = ardAlarmStealelecMapper.insert(ardAlarmStealelec);
                if(aas>0)
                {
                    log.info("stealelec入库成功:" +ardAlarmStealelec);
                }
@@ -162,8 +166,8 @@
                        ardAlarmTube.setAltitude(geoPoint.getAltitude());
                    }
                }
                int i = ardAlarmTubeMapper.insertArdAlarmTube(ardAlarmTube);
                if (i > 0) {
                int aat = ardAlarmTubeMapper.insertArdAlarmTube(ardAlarmTube);
                if (aat > 0) {
                    log.info("tube入库成功:" + ardAlarmTube);
                }
                break;