[add] 优化控制表中无数据插入逻辑；优化事件告警逻辑

signal-utc-service/src/main/java/net/wanji/utc/task/SignalCommandSyncTask.java

@@ -99,12 +99,13 @@ public class SignalCommandSyncTask {
                     signalCommandPOMapper.updateBatch(updateList);
                     List<SignalCommandLogPO> signalCommandLogPOS = new ArrayList<>(updateList.size());
                     BeanListUtils.populateList(updateList, signalCommandLogPOS, SignalCommandLogPO.class);
-                    signalCommandLogPOMapper.updateBatch(signalCommandLogPOS);
+                    signalCommandLogPOMapper.insertBatch(signalCommandLogPOS);
                     log.info("路口状态控制模式变动，数据库更新成功：{}", updateList);
                 }
-                signalCommandPOS.addAll(insertList);
-                signalCommandPOS.addAll(updateList);
-                sendAlarmKafka(signalCommandPOS);
+                List<SignalCommandPO> sendList = new ArrayList<>();
+                sendList.addAll(insertList);
+                sendList.addAll(updateList);
+                sendAlarmKafka(sendList);
             } else {
                 log.error("从路口灯态缓存获取控制模式在线离线状态为空：{}", crossLightsStatusMap);
             }

wj-databus/src/main/resources/mapper/SignalCommandLogPOMapper.xml

@@ -17,7 +17,6 @@
         <foreach collection="list" item="item" index="index" open="" separator=";" close="">
             UPDATE t_signal_command_log
             <set>
-                <if test="item.commandResult != null">command_result = #{item.commandResult},</if>
                 <if test="item.runMode != null">run_mode = #{item.runMode},</if>
                 <if test="item.updateTime != null">update_time = #{item.updateTime},</if>
                 <if test="item.status != null">status = #{item.status},</if>

wj-databus/src/main/resources/mapper/SignalCommandPOMapper.xml

@@ -17,7 +17,6 @@
         <foreach collection="list" item="item" index="index" open="" separator=";" close="">
             UPDATE t_signal_command
             <set>
-                <if test="item.commandResult != null">command_result = #{item.commandResult},</if>
                 <if test="item.runMode != null">run_mode = #{item.runMode},</if>
                 <if test="item.updateTime != null">update_time = #{item.updateTime},</if>
                 <if test="item.status != null">status = #{item.status},</if>