推送服务完善

admin

2021-09-17 a2c56bd6b79d2b8ca2c4c44a254ad2958fb72bca

 service-push/src/main/java/com/ks/push/manager/PushManager.java

@@ -36,10 +36,10 @@
    private BPushPlatformAppInfoManager bPushPlatformAppInfoManager;

    @Resource
    private RedisTemplate<String, Object> redisTemplate;
    private PushExcuteResultManager pushExcuteResultManager;

    @Resource
    private PushExcuteResultManager pushExcuteResultManager;
    private RedisTemplate redisTemplate;


    /**
@@ -81,13 +81,18 @@
        }

        String key = "task-" + taskId;
        if (!redisTemplate.opsForValue().setIfAbsent(key, "1", 5 * 60, TimeUnit.SECONDS)) {

        Boolean s = redisTemplate.opsForValue().setIfAbsent(key, "1", 5 * 60, TimeUnit.SECONDS);

        if (s == null || !s) {
            throw new BPushTaskException(BPushTaskException.CODE_BUSY, "服务器繁忙，请稍后再试");
        }


        logger.info("开始启动推送#taskId:{}", task.getId());
        updateState(taskId, BPushTask.STATE_PUSHING, null);
        boolean hasDevice = false;
        try {

            // 查询可推送的平台
            List<BPushPlatformAppInfo> list = bPushPlatformAppInfoManager.listByAppCode(task.getAppCode());

@@ -136,15 +141,12 @@
                }
                logger.info("加入推送队列#任务Id:{}#平台:{}#推送数量:{}", task.getId(), result.getPushPlatform().name(), count);
            }
        } finally {
            redisTemplate.delete(key);
        }

        //没有可推送的设备

        if (!hasDevice) {
            updateState(taskId, BPushTask.STATE_FINSIH, "没有满足条件的可推送设备");
        }

        //没有可推送的设备
        logger.info("启动推送结束#taskId:{}", task.getId());
    }