推送通知栏

core/src/main/java/com/wecloud/im/mq/MqSender.java

@@ -107,6 +107,7 @@ public class MqSender {
                 new QueryWrapper<ImClientDevice>().lambda()
                         .eq(ImClientDevice::getFkClientId, imClientReceiver.getId()));
         if (CollectionUtils.isEmpty(clientDeviceList)) {
+            log.info("接收人信息 {} 查无推送设备", imClientReceiver.getId());
             return null;
         }
         List<ClientDeviceDTO> deviceDTOList = Lists.newArrayList();
@@ -115,6 +116,7 @@ public class MqSender {
             clientDeviceDTO.setValid(imClientDevice.getValid());
             clientDeviceDTO.setDeviceType(imClientDevice.getDeviceType());
             clientDeviceDTO.setDeviceToken(imClientDevice.getDeviceToken());
+            deviceDTOList.add(clientDeviceDTO);
         }
         clientDTO.setDeviceDTOList(deviceDTOList);
         messageDTO.setClientDTO(clientDTO);