| | |
| | | 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; |
ÎļþÃû´Ó ard-work/src/main/resources/mapper/stealAlarm/ArdAlarmStealelecMapper.xml ÐÞ¸Ä |
| | |
| | | <mapper namespace="com.ruoyi.alarm.stealAlarm.mapper.ArdAlarmStealelecMapper"> |
| | | <resultMap id="BaseResultMap" type="ArdAlarmStealelec"> |
| | | <id column="id" property="id"/> |
| | | <result column="command" property="command"/> |
| | | <result column="name" property="name"/> |
| | | <result column="describe" property="describe"/> |
| | | <result column="catalog_text" property="catalogText"/> |
| | |
| | | <result column="dept_id" property="deptId"/> |
| | | </resultMap> |
| | | <sql id="Base_Column_List"> |
| | | id |
| | | ,command, name, describe, catalog_text, description, start_time, end_time,view_time,longitude,latitude,create_by,create_time,user_id,dept_id |
| | | id, name, describe, catalog_text, description, start_time, end_time,view_time,longitude,latitude,create_by,create_time,user_id,dept_id |
| | | </sql> |
| | | <select id="selectByPrimaryKey" parameterType="java.lang.String" resultMap="BaseResultMap"> |
| | | select |
| | |
| | | </update> |
| | | <insert id="insert" parameterType="ArdAlarmStealelec"> |
| | | insert into ard_alarm_stealelec(<include refid="Base_Column_List"/>) |
| | | values (#{id},#{command}, #{name},#{describe},#{catalogText},#{description}, #{startTime}, #{endTime}, |
| | | values (#{id}, #{name},#{describe},#{catalogText},#{description}, #{startTime}, #{endTime}, |
| | | #{viewTime},#{longitude},#{latitude},#{createBy},#{createTime},#{userId},#{deptId}) |
| | | </insert> |
| | | </mapper> |
| | |
| | | clientId: m3c |
| | | username: admin |
| | | password: xzx12345 |
| | | topic: tube |
| | | topic: tube,stealelec |
| | | timeout: 100 |
| | | keepalive: 60 |
| | | enabled: true |