|
|
@ -3816,7 +3816,7 @@ public class EamServiceImpl implements EamService { |
|
|
@Override |
|
|
@Override |
|
|
public void sendLoraRedLight() { |
|
|
public void sendLoraRedLight() { |
|
|
//查询随身机类型的并能发送信息的消息 |
|
|
//查询随身机类型的并能发送信息的消息 |
|
|
List<TpmMessageNotification> notifications = tpmMessageNotificationService.lambdaQuery().eq(TpmMessageNotification::getMesTypNo, "D").eq(TpmMessageNotification::getSendFlag, "Y").list(); |
|
|
|
|
|
|
|
|
List<TpmMessageNotification> notifications = tpmMessageNotificationService.lambdaQuery().eq(TpmMessageNotification::getMesTypNo, "D").eq(TpmMessageNotification::getSendFlag, "Y").isNotNull(TpmMessageNotification::getIp).list(); |
|
|
|
|
|
|
|
|
//根据ip区分多个lora |
|
|
//根据ip区分多个lora |
|
|
Map<String, List<TpmMessageNotification>> loranotifications = notifications.stream().collect(Collectors.groupingBy(TpmMessageNotification::getIp)); |
|
|
Map<String, List<TpmMessageNotification>> loranotifications = notifications.stream().collect(Collectors.groupingBy(TpmMessageNotification::getIp)); |
|
|
|