From e2b90ab5fa5c12d945751a08b97e252ce68341fd Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 08 八月 2019 09:45:06 +0800 Subject: [PATCH] 华为推送修改,商品更新循环依赖修改 --- fanli/src/main/java/com/yeshi/fanli/service/impl/push/HWPushServiceImpl.java | 34 ++++++++++++++++++++++++---------- 1 files changed, 24 insertions(+), 10 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/HWPushServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/HWPushServiceImpl.java index 9040384..5bb1802 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/push/HWPushServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/push/HWPushServiceImpl.java @@ -5,6 +5,7 @@ import javax.annotation.Resource; +import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; import com.yeshi.fanli.controller.admin.PushController; @@ -29,8 +30,12 @@ @Resource private DeviceTokenHWService deviceTokenHWService; + @Async("pushExecutor") @Override - public void pushGoods(Long uid, Long auctionId, String title, String content, List<String> listVersion) throws PushException { + public void pushGoods(Long uid, Long auctionId, String title, String content, String versions) + throws PushException { + if (1 > 0) + return; String gid = auctionId + ""; JSONObject json = new JSONObject(); json.put("url", ""); @@ -82,8 +87,11 @@ } } + @Async("pushExecutor") @Override - public void pushUrl(Long uid, String url, String title, String content, List<String> listVersion) throws PushException { + public void pushUrl(Long uid, String url, String title, String content, String versions) throws PushException { + if (1 > 0) + return; JSONObject json = new JSONObject(); json.put("url", url); json.put("type", "url"); @@ -128,7 +136,7 @@ } } try { - HWPushUtil.pushWeb(deviceTokens, title, content, url); + HWPushUtil.pushUrl(deviceTokens, title, content, url); } catch (Exception e) { PushLogHelper.hwError(e); } @@ -143,7 +151,7 @@ for (DeviceTokenHW dt : hwDeviceList) deviceList.add(dt.getDeviceToken()); try { - HWPushUtil.pushWeb(deviceList, title, content, url); + HWPushUtil.pushUrl(deviceList, title, content, url); } catch (Exception e) { PushLogHelper.hwError(e); } @@ -151,9 +159,11 @@ } } + @Async("pushExecutor") @Override - public void pushZNX(Long uid, AccountMessage msg, SystemZnx systemZNX, List<String> listVersion) throws PushException { - + public void pushZNX(Long uid, AccountMessage msg, SystemZnx systemZNX, String versions) throws PushException { + if (1 > 0) + return; JSONObject contentJson = new JSONObject(); contentJson.put("isOpen", 0); contentJson.put("createTime", java.lang.System.currentTimeMillis()); @@ -203,22 +213,26 @@ } } + @Async("pushExecutor") @Override - public void pushWEEX(Long uid, String title, String content, String weexUrl, List<String> listVersion) throws PushException { + public void pushWEEX(Long uid, String title, String content, String weexUrl, String versions) throws PushException { // TODO 鎺ㄩ�亀eex椤甸潰 } + @Async("pushExecutor") @Override - public void pushBaiChuanUrl(Long uid, String title, String content, String url, List<String> listVersion) throws PushException { + public void pushBaiChuanUrl(Long uid, String title, String content, String url, String versions) + throws PushException { // TODO 鎺ㄩ�佹窐瀹㈢櫨宸濋摼鎺� } + @Async("pushExecutor") @Override - public void pushWelfareCenter(Long uid, String title, String content, List<String> listVersion) throws PushException { + public void pushWelfareCenter(Long uid, String title, String content, String versions) throws PushException { // TODO Auto-generated method stub - + } } -- Gitblit v1.8.0