rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

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

@@ -6,6 +6,7 @@
import java.text.ParseException;

import java.text.SimpleDateFormat;

import java.util.ArrayList;

import java.util.Calendar;

import java.util.Date;

import java.util.List;



@@ -30,8 +31,12 @@
import com.yeshi.fanli.entity.bus.user.UserInfo;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.bus.user.UserInviteValidNum;

import com.yeshi.fanli.entity.bus.user.vip.TearcherInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserLevelEnum;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPInfo;

import com.yeshi.fanli.entity.bus.user.vip.UserVIPPreInfo;

import com.yeshi.fanli.entity.money.UserMoneyDetail.UserMoneyDetailTypeEnum;

import com.yeshi.fanli.entity.order.OrderMoneyDailyCount;

import com.yeshi.fanli.entity.push.DeviceActive;

import com.yeshi.fanli.entity.shop.BanLiShopOrder;

import com.yeshi.fanli.entity.system.BusinessSystem;

@@ -45,7 +50,10 @@
import com.yeshi.fanli.service.inter.homemodule.HomeNavbarUserService;

import com.yeshi.fanli.service.inter.money.UserMoneyDetailService;

import com.yeshi.fanli.service.inter.money.UserMoneyService;

import com.yeshi.fanli.service.inter.order.CommonOrderService;

import com.yeshi.fanli.service.inter.order.HongBaoV2Service;

import com.yeshi.fanli.service.inter.order.LostOrderService;

import com.yeshi.fanli.service.inter.order.OrderMoneyDailyCountService;

import com.yeshi.fanli.service.inter.order.config.HongBaoManageService;

import com.yeshi.fanli.service.inter.push.DeviceActiveService;

import com.yeshi.fanli.service.inter.push.DeviceTokenHWService;

@@ -72,7 +80,9 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.invite.UserInviteService;

import com.yeshi.fanli.service.inter.user.invite.UserInviteValidNumService;

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

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

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

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.MoneyBigDecimalUtil;

@@ -82,6 +92,7 @@
import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.account.UserUtil;

import com.yeshi.fanli.util.annotation.RequestSerializableByKey;

import com.yeshi.fanli.util.user.UserLevelUtil;

import com.yeshi.fanli.vo.user.UserVipRateVO;



import net.sf.json.JSONObject;

@@ -200,10 +211,26 @@


   @Resource

   private UserInviteService userInviteService;

	


   @Resource

   private UserInviteValidNumService userInviteValidNumService;



   @Resource

   private CommonOrderService commonOrderService;



   @Resource

   private TearcherService tearcherService;



   @Resource

   private UserVIPPreInfoService userVIPPreInfoService;



   

   @Resource

   private HongBaoV2Service hongBaoV2Service;

	
   @Resource

   private OrderMoneyDailyCountService orderMoneyDailyCountService;



   

   /**

    * 新版登录 V1.5.3

@@ -272,6 +299,13 @@
      } catch (UserAccountException e) {

         int errorCode = e.getCode();

         if (errorCode == 101) { // 需要绑定手机号

            JSONObject data = new JSONObject();

            data.put("key", e.getMsg());

            JSONObject object = new JSONObject();

            object.put("code", errorCode);

            object.put("data", data);

            out.print(object.toString());

         } else if (errorCode == 102) { // 需要绑定微信号

            JSONObject data = new JSONObject();

            data.put("key", e.getMsg());

            JSONObject object = new JSONObject();

@@ -355,6 +389,50 @@
      }

   }



	


   /**

    * 绑定微信V2.1.3 电话号码 登录

    * 
    * @param acceptData

    * @param vcode

    * @param phone

    * @param out

    */

   @RequestSerializableByKey(key = "'bindWXLogin-'+#code")

   @RequestMapping(value = "bindWXLogin")

   public void bindWXLogin(AcceptData acceptData, Long uid, String code, String key, HttpServletRequest request,

         PrintWriter out) {

      BusinessSystem system = businessSystemService.getBusinessSystemCache(acceptData.getPlatform(),

            acceptData.getPackages());

      if (system == null) {

         out.print(JsonUtil.loadFalseResult("系统不存在"));

         return;

      }



      if (StringUtil.isNullOrEmpty(code)) {

         out.print(JsonUtil.loadFalseResult("请上传code"));

         return;

      }



      if (StringUtil.isNullOrEmpty(key)) {

         out.print(JsonUtil.loadFalseResult("key值不能为空"));

         return;

      }



      try {

         UserInfo userInfo = userAccountService.bindWXToLogin(request, acceptData, code, system.getAppid(), key);

         JSONObject data = new JSONObject();

         data.put("userInfo", UserUtil.filterForClientUser(userInfo));

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

      } catch (UserAccountException e) {

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

      }



   }



	
	
   /**

    * 绑定电话号码 V2.0.1 微信登录

    * 

@@ -459,23 +537,23 @@
      BigDecimal payMoney = new BigDecimal(userVipConfigService.getValueByKey("require_order_pay"));



      vo.setFinishGoldCoin(Long.parseLong(integralDetailService.getCumulativeMoney(uid).setScale(0).toString()));

		
//      vo.setFinishTeam(hongBaoV2CountService.countValidOrderTeamUserByUid(uid,

//            , payMoney));

		


      // vo.setFinishTeam(hongBaoV2CountService.countValidOrderTeamUserByUid(uid,

      // , payMoney));



      int finishTeam = 0;

      long vipBegin = TimeUtil.convertDateToTemp(Constant.VIP_ONLINE_TIME);

      List<ThreeSale> listThreeSale = threeSaleSerivce.getValidWorkerIdsByTime(uid, vipBegin);

      if (listThreeSale != null && listThreeSale.size() > 0) {

         for (ThreeSale three: listThreeSale) {

         for (ThreeSale three : listThreeSale) {

            UserInfo worker = three.getWorker();

            if (worker == null || worker.getId() == null) {

               continue;

            }

            // 1、邀请关系成功后；2、单（分享 + 自购）实付款大于1元

            long countValid = hongBaoV2CountService.countValidOrderByUidAndTime(worker.getId(), three.getSucceedTime(), payMoney);

            long countValid = commonOrderService.countOrderByUidAndSettled(worker.getId(), payMoney);

            if (countValid > 0) {

               finishTeam ++;

               finishTeam++;

            }

         }

      }

@@ -538,7 +616,7 @@
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(1, "用户未登录"));

         return;

      }

		


      try {

         userVIPInfoService.applyVIP(uid);

      } catch (UserVIPInfoException e) {

@@ -557,8 +635,6 @@
      }

   }



	
	
   /**

    * 获取vip信息

    * 

@@ -581,12 +657,12 @@
      }

      // 获取等级

      UserInviteLevelEnum level = userInviteService.getUserInviteLevelNew(uid);

		


      // 达人

      long limitOrder = 0;

      long limitFirst = 0;

      long limitSecond = 0;

      if (level == UserInviteLevelEnum.actived ||  level == UserInviteLevelEnum.noActive) {

      if (level == UserInviteLevelEnum.actived || level == UserInviteLevelEnum.noActive) {

         String orderCount = userVipConfigService.getValueByKey("vip_pre_7_order_count");

         if (!StringUtil.isNullOrEmpty(orderCount)) {

            limitOrder = Long.parseLong(orderCount);

@@ -614,11 +690,11 @@
         }

      } else if (level == UserInviteLevelEnum.vip || level == UserInviteLevelEnum.tearcherApply) {

         // TODO 比例

			


      } else if (level == UserInviteLevelEnum.tearcher) {

         // TODO

      }

		


      // 自购订单

      long doneOrder = hongBaoV2CountService.countMyDirectOrderByCashArrival(uid, Constant.VIP_ORDER_PAY);

      // 有效粉丝

@@ -629,7 +705,7 @@
         doneFirst = userInviteValidNum.getNumFirst() == null ? 0 : userInviteValidNum.getNumFirst();

         doneSecond = userInviteValidNum.getNumSecond() == null ? 0 : userInviteValidNum.getNumSecond();

      }

		


      Date now = new Date();

      Date start = new Date(0);

      // 省钱： ---返利订单、奖励券提成

@@ -637,7 +713,7 @@
      typeFanli.add(UserMoneyDetailTypeEnum.fanli);

      typeFanli.add(UserMoneyDetailTypeEnum.orderReward);

      BigDecimal saveMoney = userMoneyDetailService.statisticUserTypeMoneyWithDate(uid, typeFanli, start, now).abs();

		


      // 赚钱： 邀请订单、分享订单、补贴

      List<UserMoneyDetailTypeEnum> typeList = new ArrayList<>();

      typeList.add(UserMoneyDetailTypeEnum.share);

@@ -651,7 +727,7 @@
         saveMoney = MoneyBigDecimalUtil.mul2(saveMoney, rate);

         earnMoney = MoneyBigDecimalUtil.mul2(earnMoney, rate);

      }

		


      String shareRate = "可享佣金的<label style=\"color:#E5005C;\">%s</label>";

      String teamRate = "最高佣金的<label style=\"color:#E5005C;\">%s</label>";

      // 达人版

@@ -659,20 +735,19 @@
      jsonrRed1.put("enjoyRate", String.format(shareRate, "145%"));

      jsonrRed1.put("teamRate", String.format(teamRate, "25%"));

      jsonrRed1.put("teamIncome", "高级会员以上专属");

		


      // 高级会员

      JSONObject jsonrRed2 = new JSONObject();

      jsonrRed2.put("enjoyRate", String.format(shareRate, "195%"));

      jsonrRed2.put("teamRate", String.format(teamRate, "50%"));

      jsonrRed2.put("teamIncome", "享高级团队收益");

		


      // 超级会员

      JSONObject jsonrRed3 = new JSONObject();

      jsonrRed3.put("enjoyRate", String.format(shareRate, "210%"));

      jsonrRed3.put("teamRate", String.format(teamRate, "110%"));

      jsonrRed3.put("teamIncome", "享超级团队收益");

		
		


      JSONObject json = new JSONObject();

      json.put("level", level.name());

      json.put("nickName", userInfo.getNickName());

@@ -680,29 +755,53 @@
      json.put("ruleLink", userVipConfigService.getValueByKey("help_link_vip_h5"));

      json.put("saveMoney", saveMoney);

      json.put("earnMoney", earnMoney);

		


      String tearcherWX = "";

      TearcherInfo tearcherInfo = tearcherService.selectByUid(uid);

      if (tearcherInfo != null && !StringUtil.isNullOrEmpty(tearcherInfo.getWxID())) {

         tearcherWX = tearcherInfo.getWxID();

      }

      json.put("tearcherWX", tearcherWX);

      json.put("tearcherTip", "我是你的导师，为你在省赚过程中解难答疑，对你一对一辅导，倾听你的需求总结并反馈给板栗快省官方运营团队，快来添加我吧。");

      json.put("tearcherWX", userVipConfigService.getValueByKey("tearcher_weixin_num"));

      json.put("newerGongLue", configService.get(ConfigKeyEnum.newerGonglue.getKey()));

		


      // 已完成

      json.put("doneOrder", doneOrder);

      json.put("doneFirst", doneFirst);

      json.put("doneSecond", doneSecond);

		


      // 标准

      json.put("limitOrder", limitOrder);

      json.put("limitFirst", limitFirst);

      json.put("limitSecond", limitSecond);

		


      // 已完成

      json.put("daRen", jsonrRed1);

      json.put("highVIP", jsonrRed2);

      json.put("superVIP", jsonrRed3);

		


      // 人工客服链接

      json.put("csdLink", configService.get(ConfigKeyEnum.customerServiceLink.getKey()));

		


      UserVIPInfo userVIPInfo = userVIPInfoService.selectByUid(uid);

      String leftTime = "";

      if (userVIPInfo != null && userVIPInfo.getState() == UserVIPInfo.STATE_VERIFING

            && userVIPInfo.getApplyTime() != null) {

         long s = 48 * 60 * 60 - ((System.currentTimeMillis() - userVIPInfo.getApplyTime().getTime()) / 1000);

         if (s > 3600) {

            leftTime = s / 3600 + "小时";

            leftTime = "还剩" + leftTime;

         } else if (s >= 60) {

            leftTime = s / 60 + "分钟";

            leftTime = "还剩" + leftTime;

         } else if (s > 0) {

            leftTime = s + "秒";

            leftTime = "还剩" + leftTime;

         } else {

            leftTime = "还剩0秒";

         }

      }

      json.put("leftTime", leftTime);

      if (!StringUtil.isNullOrEmpty(callback)) {

         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(json)));

      } else {

@@ -710,4 +809,202 @@
      }

   }



   /**

    * 获取vip信息

    * 
    * @param acceptData

    * @param uid

    * @param out

    */

   @RequestMapping(value = "getVIPSuccessInfo")

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

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

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(1, "用户未登录"));

         return;

      }



      UserVIPPreInfo vipInfo = userVIPPreInfoService.getLatestProcessInfo(uid);

      if (vipInfo == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(1, "还未升级成为会员"));

         return;

      }



      UserLevelEnum level = UserLevelUtil.getByLevel(vipInfo.getProcess());

      if (level == null) {

         level = UserLevelEnum.daRen;

      }

      UserLevelEnum showLevel = UserLevelUtil.getShowLevel(level);



      String desc = "你于" + TimeUtil.formatDateDot(vipInfo.getCreateTime()) + "升级为" + showLevel.getName();



      JSONObject json = new JSONObject();

      json.put("desc", desc);

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

   }



   @RequestMapping(value = "getTearcherWX")

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

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

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(1, "用户未登录"));

         return;

      }

      TearcherInfo tearcher = tearcherService.selectByUid(uid);

      if (tearcher == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("无导师"));

         return;

      } else {

         JSONObject data = new JSONObject();

         data.put("wx", tearcher.getWxID());

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

         return;

      }

   }



   //获取电话号码

   @RequestMapping(value = "getPhone")

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

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

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(1, "用户未登录"));

         return;

      }

      UserInfo user = userInfoService.selectAvailableByPrimaryKey(uid);

      if(user==null){

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "用户不存在"));

         return;

      }

		
      JSONObject data=new JSONObject();

      data.put("phone", user.getPhone());

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

   }



	
   /**

    * 账户注销

    * @param acceptData

    * @param callback

    * @param uid

    * @param out

    */

   @RequestMapping("accountRemove")

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

      if (uid == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户未登录"));

         return;

      }

		
      if (StringUtil.isNullOrEmpty(vcode)) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("请输入验证码"));

         return;

      }

		
      UserInfo userInfo = userInfoService.selectByPKey(uid);

      if (userInfo == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户不存在"));

         return;

      }

		
      if (userInfo.getState() == UserInfo.STATE_FORBIDDEN) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(Constant.CODE_FORBIDDEN_USER, Constant.FORBIDDEN_USER_REASON_DESC));

         return;

      }



      if (userInfo.getState() == UserInfo.STATE_DELETE || userInfo.getState() == UserInfo.STATE_DELETE_OUT_OF_DATE) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(Constant.CODE_FORBIDDEN_USER, "帐户已被注销，请重新登录"));

         return;

      }

		
      String phone = userInfo.getPhone();

      if (StringUtil.isNullOrEmpty(phone)) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("未绑定有效电话号码"));

         return;

      }

		
      if (!Constant.IS_TEST) {

         String oldVcode = redisManager.getSMSVCode(phone, SMSHistory.TYPE_REMVOE);

         if (StringUtil.isNullOrEmpty(oldVcode) || !oldVcode.equalsIgnoreCase(vcode)) {

            JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("验证码错误，重新输入"));

            return;

         } 
         redisManager.clearSMSVCode(phone, SMSHistory.TYPE_REMVOE);

      }

		
      UserInfo user = new UserInfo(uid);

      user.setState(UserInfo.STATE_DELETE);

      user.setStateDesc("用户主动注销账户");

      userInfoService.updateByPrimaryKeySelective(user);

      JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult("注销成功"));

   }

	
	
   /**

    * 注销账户数据

    * @param acceptData

    * @param callback

    * @param uid

    * @param out

    */

   @RequestMapping("getAccountData")

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

      if (uid == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户未登录"));

         return;

      }

		
      UserInfo user = userInfoService.getUserById(uid);

      if (user == null) {

         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户不存在"));

         return;

      }

		
      Date minDate = null;

      Date maxDate = null;

      long timeStamp = System.currentTimeMillis();

      Calendar calendar = Calendar.getInstance();

      calendar.setTimeInMillis(timeStamp);

		
      // 全部未到账

      minDate = new Date(0);

      maxDate = new Date(timeStamp);

      BigDecimal totalMoney = hongBaoV2Service.getUnRecievedMoneyWithCreateTime(uid, minDate, maxDate);

      if (totalMoney == null) 
         totalMoney = BigDecimal.ZERO;

      totalMoney = totalMoney.add(user.getMyHongBao());

		
      // 本月预估

      maxDate = new Date(timeStamp);

      calendar = Calendar.getInstance();

      minDate = new Date(TimeUtil.convertToTimeTemp(calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1), "yyyy-M"));

      calendar.add(Calendar.MONTH, -1);

      BigDecimal monthMoney = getMoney(orderMoneyDailyCountService.query(uid, minDate, maxDate));

		
      // 上月预估

      maxDate = new Date(TimeUtil

            .convertToTimeTemp(calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1), "yyyy-M"));

      calendar.add(Calendar.MONTH, -1);

      minDate = new Date(TimeUtil

            .convertToTimeTemp(calendar.get(Calendar.YEAR) + "-" + (calendar.get(Calendar.MONTH) + 1), "yyyy-M"));

      BigDecimal lastMoney = getMoney(orderMoneyDailyCountService.query(uid, minDate, maxDate));

		
      JSONObject data = new JSONObject();

      data.put("totalMoney", totalMoney.setScale(2, BigDecimal.ROUND_DOWN));

      data.put("monthMoney", monthMoney.setScale(2, BigDecimal.ROUND_DOWN));

      data.put("lastMoney", lastMoney.setScale(2, BigDecimal.ROUND_DOWN));

      data.put("link", configService.get(ConfigKeyEnum.accountLogoutProtocolLink.getKey()));

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

   }

	
   private BigDecimal getMoney(List<OrderMoneyDailyCount> list) {

      BigDecimal money = BigDecimal.ZERO;

      BigDecimal hundred = BigDecimal.valueOf(100);

      if (list != null && list.size() > 0) {

         for (OrderMoneyDailyCount dailyCount : list) {

            if (dailyCount.getIncome() != null)

               money = money.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncome()), hundred));

            if (dailyCount.getIncomeTeam() != null)

               money = money.add(MoneyBigDecimalUtil.div(BigDecimal.valueOf(dailyCount.getIncomeTeam()), hundred));

         }

      }

      return money;

   }

}