From 207dc8655711cddac2653e18b51e58a88dba2084 Mon Sep 17 00:00:00 2001 From: yj <Administrator@192> Date: 星期五, 06 三月 2020 18:14:36 +0800 Subject: [PATCH] 发圈处理 --- fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java | 83 +++++++++++++++-------------------------- 1 files changed, 31 insertions(+), 52 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java index 4d571c5..cf95a76 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java +++ b/fanli/src/main/java/com/yeshi/fanli/controller/client/v1/UserAccountController.java @@ -47,6 +47,8 @@ import com.yeshi.fanli.service.inter.push.DeviceActiveService; import com.yeshi.fanli.service.inter.push.DeviceTokenHWService; import com.yeshi.fanli.service.inter.push.DeviceTokenOPPOService; +import com.yeshi.fanli.service.inter.push.DeviceTokenVIVOService; +import com.yeshi.fanli.service.inter.push.DeviceTokenXMService; import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService; import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService; import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService; @@ -63,10 +65,10 @@ import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce; import com.yeshi.fanli.util.Constant; import com.yeshi.fanli.util.GsonUtil; +import com.yeshi.fanli.util.RedisKeyEnum; import com.yeshi.fanli.util.RedisManager; import com.yeshi.fanli.util.StringUtil; import com.yeshi.fanli.util.ThreadUtil; -import com.yeshi.fanli.util.VersionUtil; import com.yeshi.fanli.util.account.UserUtil; import com.yeshi.fanli.util.wx.WXLoginUtil; @@ -131,6 +133,12 @@ private DeviceTokenOPPOService deviceTokenOPPOService; @Resource + private DeviceTokenXMService deviceTokenXMService; + + @Resource + private DeviceTokenVIVOService deviceTokenVIVOService; + + @Resource private TaoBaoUnionConfigService taoBaoUnionConfigService; @Resource @@ -166,9 +174,6 @@ @Resource private DeviceActiveService deviceActiveService; - private static final String PASSWORD_MAX_ERROR = "password_max_error"; - private static final String EXTRACT_MIN_MONEY = "extract_min_money"; - private static final String EXTRACT_MAX_MONEY = "extract_max_money"; /** * @@ -262,6 +267,13 @@ platformType = 2; } userSystemCouponService.copyLotteryPrize(uuser.getId(), platformType, acceptData.getDevice()); + // 缁戝畾oppo,vivo鎺ㄩ�� + DeviceActive active = deviceActiveService.getFirstActiveInfo(acceptData.getDevice()); + if (active != null) { + deviceTokenOPPOService.bindUid(uuser.getId(), active.getId()); + deviceTokenVIVOService.bindUid(uuser.getId(), active.getId()); + deviceTokenXMService.bindUid(active.getId(), uuser.getId()); + } } catch (Exception e) { e.printStackTrace(); } @@ -270,7 +282,7 @@ } catch (UserAccountException e) { try { - LogHelper.cookieLog("鐧诲綍鍑洪敊:" + e.getCode() + "-" + e.getMessage()); + LogHelper.error("鐧诲綍鍑洪敊:" + e.getCode() + "-" + e.getMessage()); } catch (Exception e1) { e1.printStackTrace(); } @@ -344,39 +356,6 @@ } } - /** - * 璐﹀彿鎵撻�� - * - * @param acceptData - * @param mainUid - * @param lessUid - * @param session - * @param out - */ - @RequestMapping(value = "connect") - public void connect(AcceptData acceptData, long mainUid, long lessUid, HttpSession session, PrintWriter out) { - BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(), - acceptData.getPackages()); - if (system == null) { - out.print(JsonUtil.loadFalseResult("绯荤粺涓嶅瓨鍦�")); - return; - } - - if (mainUid == 0 || lessUid == 0) { - out.print(JsonUtil.loadFalseResult(1, "璇蜂笂浼犳墦閫氱敤鎴稩D")); - return; - } - - try { - userAccountService.connectUsers(new UserInfo(mainUid), new UserInfo(lessUid)); - UserInfo user = userInfoService.getUserByIdWithMybatis(mainUid); - JSONObject data = new JSONObject(); - data.put("user", GsonUtil.toJsonExpose(UserUtil.filterForClientUser(user))); - out.print(JsonUtil.loadTrueResult(data)); - } catch (UserAccountException e) { - out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); - } - } /** * 鑾峰彇鐢ㄦ埛ID @@ -782,8 +761,7 @@ return; } - String key = "bindalipay-" + uid; - + String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + ""); if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) { out.print(JsonUtil.loadFalseResult(2, "鏈嶅姟鍣ㄧ箒蹇欙紝璇风◢鍚庨噸璇�")); return; @@ -838,8 +816,7 @@ return; } - String key = "bindalipay-" + uid; - + String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + ""); if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) { out.print(JsonUtil.loadFalseResult(1001, "鏈嶅姟鍣ㄧ箒蹇欙紝璇风◢鍚庨噸璇�")); return; @@ -929,8 +906,7 @@ return; } - String key = "bindalipay-" + uid; - + String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.bindAlipay, uid + ""); if (!StringUtil.isNullOrEmpty(redisManager.getCommonString(key))) { out.print(JsonUtil.loadFalseResult(1001, "鏈嶅姟鍣ㄧ箒蹇欙紝璇风◢鍚庨噸璇�")); return; @@ -1144,6 +1120,10 @@ if (deviceActive != null) { // 瑙g粦OPPO鎺ㄩ�佺殑鐢ㄦ埛缁戝畾 deviceTokenOPPOService.unBindUid(uid, deviceActive.getId()); + // 瑙g粦VIVO鎺ㄩ�佺殑鐢ㄦ埛缁戝畾 + deviceTokenVIVOService.unBindUid(uid, deviceActive.getId()); + // 瑙g粦XM鎺ㄩ�佺殑鐢ㄦ埛缁戝畾 + deviceTokenXMService.unBindUid(deviceActive.getId()); } } out.print(JsonUtil.loadTrueResult("")); @@ -1216,13 +1196,12 @@ e.printStackTrace(); } - if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion())) { - /* 鏂颁汉绾㈠寘 */ - try { - userTaoLiJinOriginService.synchDeviceHongbao(uuser.getId(), device); - } catch (Exception e) { - e.printStackTrace(); - } + // 缁戝畾oppo鎺ㄩ�� + DeviceActive active = deviceActiveService.getFirstActiveInfo(acceptData.getDevice()); + if (active != null) { + deviceTokenOPPOService.bindUid(uuser.getId(), active.getId()); + deviceTokenVIVOService.bindUid(uuser.getId(), active.getId()); + deviceTokenXMService.bindUid(active.getId(), uuser.getId()); } } }); @@ -1231,7 +1210,7 @@ } catch (UserAccountException e) { out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg())); try { - LogHelper.cookieLog("鐧诲綍鍑洪敊:" + e.getCode() + "-" + e.getMessage()); + LogHelper.error("鐧诲綍鍑洪敊:" + e.getCode() + "-" + e.getMessage()); } catch (Exception e1) { e1.printStackTrace(); } -- Gitblit v1.8.0