订单搜索引擎增量更新

admin

2020-01-07 6fdcc0c26dd33e87a024a69ed635d9aedb59cad6

 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/InviteControllerV2.java

@@ -44,6 +44,7 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.RedisKeyEnum;

import com.yeshi.fanli.util.RedisManager;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.VersionUtil;

@@ -135,8 +136,8 @@
         if (wxUnionId == null || wxUnionId.trim().length() == 0)

            throw new UserInfoExtraException(1, "微信授权失败");



         String activeWX = StringUtil.Md5("activeWX:" + weiXinUser.getUnionid());

         redisManager.cacheCommonString(activeWX, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);

         String key = RedisKeyEnum.getRedisKey(RedisKeyEnum.emptyKey, StringUtil.Md5("activeWX:" + weiXinUser.getUnionid()));

         redisManager.cacheCommonString(key, JsonUtil.getSimpleGson().toJson(weiXinUser), 60 * 20);



         // 邀请关系用户信息

         UserInfo userInfo = userInfoExtraService.getInviterInfo(uid, wxUnionId);

@@ -145,7 +146,7 @@
         data.put("nickName", userInfo.getNickName());

         data.put("portrait", userInfo.getPortrait());

         data.put("tips", "确认要成为TA的直接粉丝吗？邀请关系一旦建立不可更改。");

         data.put("key", activeWX);

         data.put("key", key);

         out.print(JsonUtil.loadTrueResult(data));

      } catch (UserInfoExtraException e) {

         out.print(JsonUtil.loadFalseResult(e.getMsg()));

@@ -211,7 +212,7 @@
      }



      boolean needVIPInfo = false;

      if (VersionUtil.greaterThan_2_1(acceptData.getPlatform(), acceptData.getVersion()))

      if (VersionUtil.greaterThan_2_0_5(acceptData.getPlatform(), acceptData.getVersion()))

         needVIPInfo = true;



      // 组织数据

@@ -370,7 +371,7 @@
    */

   @RequestMapping(value = "countMyTeam", method = RequestMethod.POST)

   public void countMyTeam(AcceptData acceptData, long uid, PrintWriter out) {

      JSONObject bossData = getBossInfo(acceptData, uid, threeSaleSerivce.getMyBoss(uid));

      JSONObject bossData = getBossInfo(uid, threeSaleSerivce.getMyBoss(uid));

      JSONObject resultData = new JSONObject();



      long firstTeam = threeSaleSerivce.countFirstTeam(uid, 1);

@@ -423,6 +424,23 @@
   }



   /**

    * 获取用户信息

    * @param acceptData

    * @param uid

    * @param out

    */

   @RequestMapping(value = "getBossInfo", method = RequestMethod.POST)

   public void getBossInfo(AcceptData acceptData, Long uid, PrintWriter out) {

      if (uid == null || uid <= 0) {

         out.print(JsonUtil.loadFalseResult("用户未登录"));

         return;

      }

      JSONObject bossData = getBossInfo(uid, threeSaleSerivce.getMyBoss(uid));

      out.print(JsonUtil.loadTrueResult(bossData));

   }

	
	
   /**

    * 上级信息组织

    * 

    * @param acceptData

@@ -430,7 +448,7 @@
    * @param threeSale

    * @return

    */

   private JSONObject getBossInfo(AcceptData acceptData, long uid, ThreeSale threeSale) {

   private JSONObject getBossInfo(long uid, ThreeSale threeSale) {

      JSONObject bossData = new JSONObject();

      if (threeSale != null && threeSale.getBoss() != null) {

         UserInfo boss = threeSale.getBoss();

@@ -608,4 +626,28 @@
         out.print(JsonUtil.loadFalseResult("邀请信息获取失败"));

      }

   }

	
   /**

    * 站内信提醒队员添加微信号

    * 
    * @param acceptData

    * @param uid

    * @param inviteId

    * @param out

    */

   @RequestMapping(value = "tailorCode")

   public void tailorCode(AcceptData acceptData, String callback, Long uid, PrintWriter out) {

      if (uid == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户id缺失"));

         return;

      }



      JSONObject data = new JSONObject();

      data.put("num", threeSaleSerivce.countFirstTeam(uid, 1));

      data.put("limit", Constant.INVITE_CODRE_TAILOR_LIMIT);

      JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));

   }

	
	
	
}