From b107dfe2088921a66a4ecac1708d322d241dfae6 Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 11 六月 2020 14:27:43 +0800 Subject: [PATCH] 云发单群组关键词激活 --- fanli/src/main/java/com/yeshi/fanli/controller/CallBackController.java | 23 ++++++++++++++++++++++- 1 files changed, 22 insertions(+), 1 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/CallBackController.java b/fanli/src/main/java/com/yeshi/fanli/controller/CallBackController.java index 503fb38..6609362 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/CallBackController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/CallBackController.java @@ -31,6 +31,7 @@ import com.yeshi.fanli.entity.bus.activity.ActivityRuleUser; import com.yeshi.fanli.entity.bus.activity.ActivityUser; import com.yeshi.fanli.entity.bus.msg.MsgDeviceReadState; +import com.yeshi.fanli.entity.bus.user.cloud.UserCloud; import com.yeshi.fanli.entity.dynamic.ImgInfo; import com.yeshi.fanli.entity.dynamic.ImgInfo.ImgEnum; import com.yeshi.fanli.entity.dynamic.SimpleGoods; @@ -48,6 +49,7 @@ import com.yeshi.fanli.service.inter.order.config.HongBaoManageService; import com.yeshi.fanli.service.inter.push.PushService; import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService; +import com.yeshi.fanli.service.inter.user.cloud.UserCloudService; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.factory.goods.GoodsDetailVOFactory; @@ -97,6 +99,9 @@ @Resource private ActivityUserService activityUserService; + + @Resource + private UserCloudService userCloudService; /** * 瀹㈡湇娑堟伅鍥炶皟 @@ -357,7 +362,23 @@ } catch (IOException e) { e.printStackTrace(); } - LogHelper.test("浜戝彂鍗曞洖璋冨唴瀹�:"+stringBuilder.toString()); + + try { + JSONObject root = JSONObject.fromObject(stringBuilder.toString()); + if (root.optInt("messageType") == 9) { + String content = root.optJSONObject("data").optString("content"); + LogHelper.test("浜戝彂鍗曠兢鍐呭:" + content); + if (content.trim().equalsIgnoreCase(Constant.YHG_CLOUD_GROUP_AWAKEN_KEY)) { + LogHelper.test("浜戝彂鍗曠兢鍖归厤:" + root.optString("wcId") + "-" + + root.optJSONObject("data").optString("fromGroup")); + userCloudService.cacheMatchGroup(root.optString("wcId"), + root.optJSONObject("data").optString("fromGroup")); + } + } + } catch (Exception e) { + + } + } } -- Gitblit v1.8.0