yujian
2019-03-27 cdcbed9af813b2a02cdc01eefa24db8bec6b51a9
fanli/src/main/java/com/yeshi/fanli/controller/client/InviteGetMoneyController.java
@@ -2,7 +2,6 @@
import java.io.IOException;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
@@ -14,19 +13,18 @@
import org.springframework.web.bind.annotation.RequestMethod;
import org.yeshi.utils.JsonUtil;
import com.yeshi.fanli.dto.money.InviteGetMoney;
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.admin.InviteGetMoney;
import com.yeshi.fanli.entity.bus.homemodule.SwiperPicture;
import com.yeshi.fanli.entity.bus.user.ThreeSale;
import com.yeshi.fanli.entity.bus.user.UserInfo;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.system.System;
import com.yeshi.fanli.entity.system.BusinessSystem;
import com.yeshi.fanli.entity.system.SystemClientParams;
import com.yeshi.fanli.exception.NotExistObjectException;
import com.yeshi.fanli.exception.banner.SwiperPictureException;
import com.yeshi.fanli.exception.user.UserInfoExtraException;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.InviteGetMoneyService;
import com.yeshi.fanli.service.inter.config.SystemClientParamsService;
import com.yeshi.fanli.service.inter.homemodule.SwiperPictureService;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
@@ -36,6 +34,8 @@
import com.yeshi.fanli.service.inter.user.UserRankingsService;
import com.yeshi.fanli.tag.PageEntity;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.RedisManager;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.account.UserUtil;
import net.sf.json.JSONArray;
@@ -52,10 +52,6 @@
@Controller
@RequestMapping("api/v1/invite")
public class InviteGetMoneyController {
   @Resource
   private InviteGetMoneyService inviteGetMoneyService;
   @Resource
   private SystemClientParamsService systemClientParamsService;
@@ -70,38 +66,27 @@
   @Resource
   private SwiperPictureService swiperPictureService;
   @Resource
   private UserInfoExtraService userInfoExtraService;
   @Resource
   private UserInfoService userInfoService;
   @Resource
   private ThreeSaleSerivce threeSaleSerivce;
   @Resource
   private RedisManager redisManager;
   @RequestMapping(value = "/inviteGetMoney", method = RequestMethod.POST)
   public void everyDayTaskList(AcceptData acceptData, int pageIndex, PrintWriter out, String uid)
         throws NotExistObjectException {
         throws NotExistObjectException, UserInfoExtraException {
      // 查询商品总数
      Integer totalCount = 0;
      int totalPage = totalCount % Constant.PAGE_SIZE == 0 ? totalCount / Constant.PAGE_SIZE
            : totalCount / Constant.PAGE_SIZE + 1;
      PageEntity pageEntity = new PageEntity(pageIndex, Constant.PAGE_SIZE, totalCount, totalPage);
      /*
       * // 分页查询邀请提成榜 List<InviteGetMoney> inviteGetMoneyList =
       * inviteGetMoneyService.inviteGetMoneyList(pageIndex - 1, "");
       *
       * // 名字*处理 for (InviteGetMoney inviteGetMoney : inviteGetMoneyList) {
       *
       * String name = inviteGetMoney.getName(); if (name != null) { if
       * (name.length() > 2) { name = Utils.getStarString(name, 1,
       * name.length() - 1); } else { name = name.substring(0, 1) + "**" +
       * name.substring(name.length() - 1); } } inviteGetMoney.setName(name);
       * inviteGetMoney.setRankIcon(UserUtil.getRankIcon(3)); }
       */
      List<InviteGetMoney> inviteGetMoneyList = userRankingsService.getRank(0, 5);
@@ -110,37 +95,26 @@
      data.put("everyDayTaskList", new JSONArray());
      data.put("inviteGetMoneyList",
            JSONArray.fromObject(JsonUtil.getSimpleGsonWithDate().toJson(inviteGetMoneyList)));
      if (uid.equals("0") || uid == null) {
      if (StringUtil.isNullOrEmpty(uid) || uid.equalsIgnoreCase("0")) {
         data.put("myTeam", "---");
         data.put("moneyToday", "---");
         data.put("moneyMonth", "---");
         data.put("moneyLastMonth", "---");
      } else {
         // 我的队员
         int myFirstTeamCount = inviteGetMoneyService.myFirstTeamCount(uid);
         int mySecondTeamCount = inviteGetMoneyService.mySecondTeamCount(uid);
         int myTeamCount = myFirstTeamCount + mySecondTeamCount;
         long myFirstTeamCount = threeSaleSerivce.getFirstUsersCount(Long.parseLong(uid));
         long mySecondTeamCount = threeSaleSerivce.getSecondUsersCount(Long.parseLong(uid));
         long myTeamCount = myFirstTeamCount + mySecondTeamCount;
         data.put("myTeam", myTeamCount);
         // 今日 本月预估收益
         BigDecimal moneyToday = inviteGetMoneyService.getMoneyToday(uid + "");
         if (moneyToday == null) {
            moneyToday = new BigDecimal(0);
         }
         BigDecimal moneyMonth = inviteGetMoneyService.getMoneyMonth(uid + "");
         if (moneyMonth == null) {
            moneyMonth = new BigDecimal(0);
         }
         BigDecimal moneyLastMonth = inviteGetMoneyService.getMoneyLastMonth(uid + "");
         data.put("moneyToday", moneyToday.setScale(2, BigDecimal.ROUND_DOWN).toString());
         data.put("moneyMonth", moneyMonth.setScale(2, BigDecimal.ROUND_DOWN).toString());
         data.put("moneyLastMonth", moneyLastMonth.toString());
         // 1.5.0后已经不使用此字段
         data.put("moneyToday", "0");
         data.put("moneyMonth", "0");
         data.put("moneyLastMonth", "0");
      }
      // 活动规则
      String key = "activityRules"; // key值
      com.yeshi.fanli.entity.system.System system = new System();
      BusinessSystem system = new BusinessSystem();
      system.setCreatetime(java.lang.System.currentTimeMillis());
      system.setPlatform(1);
      system.setId(4L);
@@ -168,6 +142,21 @@
      }
      data.put("desc", configService.get("invite_desc"));
      boolean hasCode = false;
      if (uid != null && uid.trim().length() > 0) {
         String inviteCode = userInfoExtraService.getUserInviteCode(Long.parseLong(uid));
         if (inviteCode != null && inviteCode.trim().length() > 0) {
            hasCode = true; // 已有邀请码
         }
      }
      // 邀请激活链接
      if (!hasCode) {
         data.put("activationlink", configService.get("invite_activation_url"));
      }
      data.put("hasCode", hasCode);
      com.alibaba.fastjson.JSONObject root = new com.alibaba.fastjson.JSONObject();
      root.put("code", 0);
@@ -197,7 +186,7 @@
      // 邀请规则
      String key = "inviteRules"; // key值
      com.yeshi.fanli.entity.system.System system = new System();
      com.yeshi.fanli.entity.system.BusinessSystem system = new BusinessSystem();
      system.setCreatetime(java.lang.System.currentTimeMillis());
      system.setPlatform(1);
      system.setId(4L);
@@ -209,10 +198,10 @@
      data.put("inviteRules", valueBr);
      out.print(JsonUtil.loadTrue(0, JsonUtil.getSimpleGson().toJson(data), "成功"));
   }
   /**
    * 邀请激活-特别提示语
    *
    * @param callback
    * @param out
    */
@@ -224,12 +213,12 @@
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂无提醒"));
            return;
         }
         JSONObject data = new JSONObject();
         data.put("tip", tip);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("获取失败"));
         e.printStackTrace();
@@ -238,27 +227,31 @@
   /**
    * 激活邀请
    *
    * @param callback
    * @param uid  用户id
    * @param inviteCode 邀请嘛
    * @param uid
    *            用户id
    * @param inviteCode
    *            邀请嘛
    * @param out
    */
   @RequestMapping(value = "activationInvite")
   public void activationInvite(AcceptData acceptData, String callback, Long uid, String inviteCode, PrintWriter out) {
      try {
         if (uid == null || inviteCode == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("传递参数不正确"));
            return;
         }
         String newCode = userInfoExtraService.activateInviteCode(uid, inviteCode);
         if (newCode == null || newCode.trim().length() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("激活失败"));
            return;
         }
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("激活成功"));
      } catch (UserInfoExtraException e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(e.getMsg()));
      } catch (Exception e) {
@@ -266,59 +259,70 @@
         e.printStackTrace();
      }
   }
   /**
    * 获取邀请码
    *
    * @param callback
    * @param uid  用户id
    * @param uid
    *            用户id
    * @param out
    */
   @RequestMapping(value = "getInviteCode")
   public void getInviteCode(AcceptData acceptData, String callback, Long uid, PrintWriter out) {
      try {
         if (uid == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("传递参数不正确"));
            return;
         }
         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
         UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
         if (userInfoExtra == null || userInfoExtra.getInviteCode() == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("邀请码不存在"));
            return;
         }
         String tip = configService.get("invite_activation_success_tip");
         JSONObject data = new JSONObject();
         data.put("inviteCode", userInfoExtra.getInviteCode());
         data.put("tip", tip);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("获取数据失败"));
         e.printStackTrace();
      }
      }
   }
   /**
    * 获取邀请短连接
    *
    * @param callback
    * @param uid  用户id
    * @param uid
    *            用户id
    * @param out
    */
   @RequestMapping(value = "getShortLink")
   public void getShortLink(AcceptData acceptData, String callback, Long uid, PrintWriter out) {
      try {
         if (uid == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("传递参数不正确"));
            return;
         }
         String inviteShortLink = redisManager.getInviteShortLink(uid);
         if (inviteShortLink != null && inviteShortLink.trim().length() > 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请1分钟后再试"));
            return;
         }
         String shortLink = UserUtil.getInviteShortLink(uid);
         // 缓存1分钟
         redisManager.setInviteShortLink(uid, shortLink);
         JSONObject data = new JSONObject();
         data.put("shortLink", shortLink);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
@@ -327,39 +331,42 @@
         e.printStackTrace();
      }
   }
   /**
    * 获取邀请电话号码
    *
    * @param callback
    * @param uid  用户id
    * @param uid
    *            用户id
    * @param out
    */
   @RequestMapping(value = "getUserPhone")
   public void getUserPhone(AcceptData acceptData, String callback, Long uid, PrintWriter out) {
      try {
         if (uid == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("传递参数不正确"));
            return;
         }
         UserInfo userInfo = userInfoService.selectByPKey(uid);
         if (userInfo == null || userInfo.getPhone() == null) {
         if (userInfo == null || userInfo.getPhone() == null || userInfo.getPhone().trim().length() == 0) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("暂未绑定电话号码"));
            return;
         }
         JSONObject data = new JSONObject();
         data.put("phone", userInfo.getPhone());
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("获取数据失败"));
         e.printStackTrace();
      }
   }
   /**
    * 获取用户邀请上级
    *
    * @param callback
    * @param uid
    * @param out
@@ -370,15 +377,14 @@
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("传递参数不正确"));
         return;
      }
      try {
         ThreeSale threeSale = threeSaleSerivce.getMyBoss(uid);
         if (threeSale == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("无上级邀请人"));
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "无上级邀请人"));
            return;
         }
         UserInfo boss = threeSale.getBoss();
         if (boss == null) {
            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("上级邀请人获取失败"));
@@ -388,13 +394,13 @@
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");
         Long createTime = threeSale.getCreateTime();
         Date inviteTime = new Date(createTime);
         JSONObject data = new JSONObject();
         data.put("nickName", boss.getNickName());
         data.put("portrait", boss.getPortrait());
         data.put("inviteTime", sdf.format(inviteTime));
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("获取数据失败"));
         e.printStackTrace();