Commit cd2c5f24 authored by zhangsen's avatar zhangsen

跑马灯消息重复问题补充

parent 729111aa
...@@ -266,7 +266,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService { ...@@ -266,7 +266,7 @@ public class MqttReceiveServiceImpl implements MqttReceiveService {
} }
for (IotDataVO item : iotDatalist) { for (IotDataVO item : iotDatalist) {
int count = equipmentSpecificAlarmMapper.selectCountByIotCode(iotCode, item.getKey(), String.valueOf(item.getValue())); int count = equipmentSpecificAlarmMapper.selectCountByIotCode(iotCode, item.getKey(), String.valueOf(item.getValue()));
if (count > 0) { if (count > 0 && "true".equals(item.getValue())) {
return; return;
} }
} }
......
...@@ -1105,5 +1105,6 @@ ...@@ -1105,5 +1105,6 @@
iot_code = #{iotCode,jdbcType=VARCHAR} iot_code = #{iotCode,jdbcType=VARCHAR}
AND equipment_specific_index_value = #{indexValue,jdbcType=VARCHAR} AND equipment_specific_index_value = #{indexValue,jdbcType=VARCHAR}
AND equipment_specific_index_key = #{indexKey,jdbcType=VARCHAR} AND equipment_specific_index_key = #{indexKey,jdbcType=VARCHAR}
and `status` = 1
</select> </select>
</mapper> </mapper>
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment