diff --git a/src/main/java/com/realtime/protection/configuration/kafka/MyKafkaListenerErrorHandler.java b/src/main/java/com/realtime/protection/configuration/kafka/MyKafkaListenerErrorHandler.java index 4abaf8c..e23867c 100644 --- a/src/main/java/com/realtime/protection/configuration/kafka/MyKafkaListenerErrorHandler.java +++ b/src/main/java/com/realtime/protection/configuration/kafka/MyKafkaListenerErrorHandler.java @@ -24,6 +24,7 @@ public class MyKafkaListenerErrorHandler implements KafkaListenerErrorHandler { log.error("消息详情:" + message); log.error("异常信息::" + exception.getCause()); + exception.printStackTrace(); log.error("消费者详情::" + consumer.groupMetadata()); log.error("监听主题::" + consumer.listTopics()); return KafkaListenerErrorHandler.super.handleError(message, exception, consumer); diff --git a/src/main/resources/mappers/AlertMessageMapper.xml b/src/main/resources/mappers/AlertMessageMapper.xml index 0f36aef..36d3e93 100644 --- a/src/main/resources/mappers/AlertMessageMapper.xml +++ b/src/main/resources/mappers/AlertMessageMapper.xml @@ -95,34 +95,31 @@ c_provid, c_event_id, c_priority, - c_time, + t_time, c_flowid, - c_s_boundary, - c_src_ipv6, c_s_tunnel_ip, c_s_tunnel_port, c_dest_ipv6, c_d_tunnel_ip, c_d_tunnel_port, - c_des_IPv6, - c_proto_type, --- c_return_info, c_s_boundary, c_s_region, c_s_city, c_s_district, - c_s_operators, + c_s_operator, c_s_owner, c_d_boundary, c_d_region, c_d_city, c_d_district, - c_d_operators, + c_d_operator, c_d_owner, c_ret_file_type, - c_ret_file_name, - c_curl + c_ret_filename, + c_url, + display_id, + c_return_info ) values ( #{taskId}, @@ -152,18 +149,12 @@ #{c_priority}, #{c_time}, #{c_flowid}, --- #{c_src_ipv4}, #{c_src_ipv6}, --- #{c_src_port}, #{c_s_tunnel_ip}, #{c_s_tunnel_port}, --- #{c_dest_ipv4}, #{c_dest_ipv6}, --- #{c_dest_port}, - #{c_d_tunnel_ip}, + #{c_d_tunnel_ip}, #{c_d_tunnel_port}, --- #{c_proto_type}, --- #{c_return_info}, #{c_s_boundary}, #{c_s_region}, #{c_s_city}, @@ -178,7 +169,9 @@ #{c_d_owner}, #{c_ret_file_type}, #{c_ret_file_name}, - #{c_curl} + #{c_url}, + #{display_id}, + #{c_return_info} ) diff --git a/src/main/resources/mappers/CommandMapper.xml b/src/main/resources/mappers/CommandMapper.xml index fee5ed7..7eeadad 100644 --- a/src/main/resources/mappers/CommandMapper.xml +++ b/src/main/resources/mappers/CommandMapper.xml @@ -9,7 +9,7 @@ MASK_SRC_IP, MASK_SRC_PORT, MASK_DST_IP, MASK_DST_PORT, MASK_PROTOCOL, VALID_TIME, INVALID_TIME, IS_VALID, IS_JUDGED, SEND_TIMES, SUCCESS_TIMES, CREATE_TIME, LAST_UPDATE, IS_DELETED, - TASKTYPE, RULE_ID) + TASKTYPE, RULE_ID, display_id) values (#{info.UUID}, #{info.taskId}, #{info.taskAct}, #{info.taskName}, #{info.eventType}, #{info.taskCreateDepart}, #{info.distributePoint}, #{info.frequency}, DEFAULT, @@ -22,7 +22,8 @@ #{info.startTime}, #{info.endTime}, #{info.isValid}, #{info.isJudged}, 0, 0, - NOW(), NOW(), FALSE, #{info.taskType}, #{info.ruleId}) + NOW(), NOW(), FALSE, #{info.taskType}, #{info.ruleId}, #{info.displayId} + ) @@ -32,7 +33,7 @@ MASK_SRC_IP, MASK_SRC_PORT, MASK_DST_IP, MASK_DST_PORT, MASK_PROTOCOL, VALID_TIME, INVALID_TIME, IS_VALID, IS_JUDGED, SEND_TIMES, SUCCESS_TIMES, CREATE_TIME, LAST_UPDATE, IS_DELETED, - TASKTYPE, RULE_ID) + TASKTYPE, RULE_ID, display_id) values (#{info.UUID}, #{info.taskId}, #{info.taskAct}, #{info.taskName}, #{info.eventType}, #{info.taskCreateDepart}, #{info.distributePoint}, @@ -47,7 +48,7 @@ #{info.startTime}, #{info.endTime}, #{info.isValid}, #{info.isJudged}, 0, 0, - NOW(), NOW(), FALSE, #{info.taskType}, #{info.ruleId} + NOW(), NOW(), FALSE, #{info.taskType}, #{info.ruleId}, #{info.displayId} )