service-push/src/main/java/com/ks/push/manager/PushManager.java
@@ -89,6 +89,7 @@ } try { logger.info("开始启动推送#taskId:{}", task.getId()); updateState(taskId, BPushTask.STATE_PUSHING, null); boolean hasDevice = false; @@ -142,10 +143,12 @@ logger.info("加入推送队列#任务Id:{}#平台:{}#推送数量:{}", task.getId(), result.getPushPlatform().name(), count); } if (!hasDevice) { updateState(taskId, BPushTask.STATE_FINSIH, "没有满足条件的可推送设备"); } } finally { redisTemplate.delete(key); } //没有可推送的设备 logger.info("启动推送结束#taskId:{}", task.getId()); }