推送服务完善

admin

2021-09-17 a2c56bd6b79d2b8ca2c4c44a254ad2958fb72bca

 service-push/src/main/java/com/ks/push/consumer/mq/PushTaskConsumer.java

@@ -42,13 +42,13 @@
        if (platform == null) {
            return;
        }
        logger.info("消费消息开始:{}  Thread:{}", platform.name(),Thread.currentThread().getId());
//        logger.info("消费消息开始:{}  Thread:{}", platform.name(), Thread.currentThread().getId());
        List<CMQManager.MQMsgConsumeResult> resultList = null;
        try {
            resultList = CMQManager.getInstance().consumePushQueue(platform, 1);
        } catch (Exception e) {
        }
        logger.info("消费消息结束:{} Thread:{}", platform.name(),Thread.currentThread().getId());
//        logger.info("消费消息结束:{} Thread:{}", platform.name(), Thread.currentThread().getId());
        if (resultList != null) {
            for (CMQManager.MQMsgConsumeResult result : resultList) {
                try {
@@ -59,10 +59,12 @@
                            BPushPlatformAppInfo platformAppInfo = bPushPlatformAppInfoManager.selectByAppCodeAndPlatform(task.getAppCode(), platform);
                            if (platformAppInfo != null) {
                                try {
                                    PushUtil.pushNotifyCation(platform, platformAppInfo.getPushAppInfo(), task.getMessage(), dataSet.getDeviceTokenList());
                                    logger.info("推送任务执行成功,taskId-{},batchId-{}", dataSet.getTaskId(), dataSet.getBatchId());
                                    PushUtil.pushNotifyCation(platform, platformAppInfo.getPushAppInfo(), task.getMessage(), task.getId() + "#" + dataSet.getBatchId(), dataSet.getDeviceTokenList());
                                    logger.info("{}推送任务执行成功,taskId-{},batchId-{}", platform.name(), dataSet.getTaskId(), dataSet.getBatchId());
                                } catch (Exception e) {
                                    e.printStackTrace();
                                    logger.error("推送出错：ttaskId-{},batchId-{}，错误原因：{}", task.getId(), dataSet.getBatchId(), e.getMessage());
                                    logger.error("推送出错", e);
                                }
                            }
                        } else {
@@ -77,11 +79,12 @@
                        logger.error("任务为空，taskId-{},batchId-{}", dataSet.getTaskId(), dataSet.getBatchId());
                    }
                    //删除消息
                    logger.info("推送任务执行完成,taskId-{},batchId-{}", dataSet.getTaskId(), dataSet.getBatchId());
                    CMQManager.getInstance().deleteMsg(result.getQueueName(), result.getReceiptHandle());
                    pushExcuteResultManager.batchPushFinish(dataSet, platform);
                    logger.info("{}推送任务执行结束,taskId-{},batchId-{}", platform.name(), dataSet.getTaskId(), dataSet.getBatchId());
                } catch (Exception e) {
//                    e.printStackTrace();
                    logger.error("推送出错:", e);
                }
            }