kafka日志集成

admin

2021-08-02 e89de9319d8f771f8e53cb5f876d06465a580c57

 src/main/java/com/yeshi/buwan/util/push/PushManager.java

@@ -9,7 +9,6 @@
import com.yeshi.buwan.service.imp.DetailSystemConfigService;
import com.yeshi.buwan.service.inter.push.PushDeviceTokenService;
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.push.*;
import org.yeshi.utils.push.entity.PushAppInfo;
import org.yeshi.utils.push.entity.PushMessage;

@@ -156,17 +155,17 @@
        }


        if (platform == PushDeviceToken.PushPlatform.xm) {
            XiaoMiPushUtil.pushNotificationByRegIds(appInfo, message, tempTokens);
        } else if (platform == PushDeviceToken.PushPlatform.hw) {
            HuaWeiPushUtil.pushNotificationByTokens(appInfo, message, tempTokens);
        } else if (platform == PushDeviceToken.PushPlatform.oppo) {
            OppoPushUtil.pushNotificationAll(appInfo, message, tempTokens);
        } else if (platform == PushDeviceToken.PushPlatform.vivo) {
            VIVOPushUtil.pushNotificationByRegIds(appInfo, message, tempTokens);
        } else if (platform == PushDeviceToken.PushPlatform.mz) {
            MeiZuPushUtil.pushNotificationByPushId(appInfo, message, tempTokens);
        }
//        if (platform == PushDeviceToken.PushPlatform.xm) {
//            XiaoMiPushUtil.pushNotificationByRegIds(appInfo, message, tempTokens);
//        } else if (platform == PushDeviceToken.PushPlatform.hw) {
//            HuaWeiPushUtil.pushNotificationByTokens(appInfo, message, tempTokens);
//        } else if (platform == PushDeviceToken.PushPlatform.oppo) {
//            OppoPushUtil.pushNotificationAll(appInfo, message, tempTokens);
//        } else if (platform == PushDeviceToken.PushPlatform.vivo) {
//            VIVOPushUtil.pushNotificationByRegIds(appInfo, message, tempTokens);
//        } else if (platform == PushDeviceToken.PushPlatform.mz) {
//            MeiZuPushUtil.pushNotificationByPushId(appInfo, message, tempTokens);
//        }

        if (leftTokens != null && leftTokens.size() > 0) {
            pushAndroidNotifycation(message, appInfo, leftTokens, platform);