diff --git a/src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java b/src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java index 98cdb5c..d627f76 100644 --- a/src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java +++ b/src/main/java/com/bootdo/datasend/dianxin/task/StandardTask.java @@ -16,6 +16,7 @@ import lombok.RequiredArgsConstructor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.amqp.rabbit.core.RabbitTemplate; +import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.client.RestTemplate; @@ -32,11 +33,13 @@ public class StandardTask { private final RabbitTemplate rabbitTemplate; // @Scheduled(cron = "0/5 * * * * ? ") + @Scheduled(cron = "0/30 * * * * ? ") public void sendVehicleRecord() { List lists = vehicleRecordService.list(new QueryWrapper() .eq("is_send", "0") .last("limit 100") + .orderByAsc("id") ); for (BaseVehicleRecord h : lists) { @@ -80,6 +83,7 @@ public class StandardTask { dataDTO.setRequestDataList(list); dto.setRequestData(dataDTO); boolean b = sendVehicleMq(dto); + logger.info("车辆数据发送成功:" + JSON.toJSONString(dto)); if (b) { h.setIsSend(1); vehicleRecordService.saveOrUpdate(h); @@ -90,11 +94,13 @@ public class StandardTask { } + @Scheduled(cron = "0/30 * * * * ? ") public void sendUserRecord() { List lists = userRecordService.list(new QueryWrapper() .eq("is_send", "0") .last("limit 100") + .orderByAsc("id") ); for (BaseUserRecord h : lists) { @@ -131,6 +137,7 @@ public class StandardTask { dto.setRequestData(dataDTO); boolean result = sendUserMq(dto); + logger.info("人脸数据发送成功:" + JSON.toJSONString(dto)); if (result) { h.setIsSend(1); userRecordService.saveOrUpdate(h); @@ -142,6 +149,7 @@ public class StandardTask { public boolean sendVehicleMq(VehicleRecordDto bean) { try { rabbitTemplate.convertAndSend("warnrecord", "routing.key.vehiclerecord", JSON.toJSONString(bean)); + logger.info("车辆数据发送成功:" + JSON.toJSONString(bean)); } catch (Exception e) { return false; } @@ -152,6 +160,7 @@ public class StandardTask { public boolean sendUserMq(UserRecordDto bean) { try { rabbitTemplate.convertAndSend("warnrecord", "routing.key.userrecord", JSON.toJSONString(bean)); + logger.info("人脸数据发送成功:" + JSON.toJSONString(bean)); } catch (Exception e) { return false; } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 1f66954..c34df1d 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -4,7 +4,7 @@ spring: username: root password: 'puxing@18912915666' url: jdbc:mysql://110.1.53.162:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT -# url: jdbc:mysql://127.0.0.1:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT + # url: jdbc:mysql://127.0.0.1:55306/multidimensional_box?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true&serverTimezone=GMT driver-class-name: com.mysql.cj.jdbc.Driver initialSize: 5 # 配置初始化大小、最小、最大 minIdle: 5 @@ -31,18 +31,18 @@ spring: properties: hibernate: format_sql: true + # rabbitmq: + # host: 221.229.107.118 + # port: 30529 + # username: root + # password: 'sm@rtC@m!n23ty' + # dynamic: true rabbitmq: - host: 221.229.107.118 - port: 30529 + host: 110.1.200.11 + port: 19000 username: root - password: 'sm@rtC@m!n23ty' + password: sm@rtC@m!n23ty dynamic: true -# rabbitmq: -# host: 110.1.200.11 -# port: 19000 -# username: root -# password: 'sm@rtC@m!n23ty' -# dynamic: true