| | |
| | | switch (topic) { |
| | | case "stealelec": |
| | | ArdAlarmStealelec ardAlarmStealelec = JSONObject.parseObject(message, ArdAlarmStealelec.class); |
| | | ardAlarmStealelec.setId(uuid); |
| | | ArdAlarmpointsWell well = ardAlarmpointsWellMapper.selectArdAlarmpointsWellByWellId(ardAlarmStealelec.getDescribe()); |
| | | if(well!=null) |
| | | { |
| | |
| | | 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); |
| | | } |
| | |
| | | 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; |