blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2020-02-23 b59fef5c00b15fdfdfa9d4be26e5bf6b41c75458 
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/UserAccountControllerV2.java


@@ -1,6 +1,13 @@


package com.yeshi.fanli.controller.client.v2;







import java.io.PrintWriter;



import java.lang.reflect.Type;



import java.math.BigDecimal;



import java.text.ParseException;



import java.text.SimpleDateFormat;



import java.util.ArrayList;



import java.util.Date;



import java.util.List;







import javax.annotation.Resource;



import javax.servlet.http.HttpServletRequest;



@@ -10,23 +17,42 @@


import org.springframework.web.bind.annotation.RequestMethod;



import org.yeshi.utils.JsonUtil;







import com.google.gson.Gson;



import com.google.gson.GsonBuilder;



import com.google.gson.JsonElement;



import com.google.gson.JsonPrimitive;



import com.google.gson.JsonSerializationContext;



import com.google.gson.JsonSerializer;



import com.yeshi.fanli.entity.accept.AcceptData;



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



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



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



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



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



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



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



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



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



import com.yeshi.fanli.exception.user.UserAccountException;



import com.yeshi.fanli.exception.user.vip.UserVIPInfoException;



import com.yeshi.fanli.log.LogHelper;



import com.yeshi.fanli.service.inter.config.BusinessSystemService;



import com.yeshi.fanli.service.inter.config.ConfigService;



import com.yeshi.fanli.service.inter.count.HongBaoV2CountService;



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.LostOrderService;



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;



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.shop.BanLiShopOrderService;



import com.yeshi.fanli.service.inter.taobao.TaoBaoUnionConfigService;



import com.yeshi.fanli.service.inter.tlj.UserTaoLiJinOriginService;



import com.yeshi.fanli.service.inter.user.BindRemindService;



import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService;



import com.yeshi.fanli.service.inter.user.ShamUserService;



import com.yeshi.fanli.service.inter.user.SpreadUserImgService;



@@ -34,18 +60,24 @@


import com.yeshi.fanli.service.inter.user.UserAccountBindingHistoryService;



import com.yeshi.fanli.service.inter.user.UserAccountService;



import com.yeshi.fanli.service.inter.user.UserInfoDeleteRecordService;



import com.yeshi.fanli.service.inter.user.UserInfoExtraService;



import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;



import com.yeshi.fanli.service.inter.user.UserInfoService;



import com.yeshi.fanli.service.inter.user.UserShareGoodsRecordService;



import com.yeshi.fanli.service.inter.user.UserSystemCouponService;



import com.yeshi.fanli.service.inter.user.integral.IntegralDetailService;



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



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



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



import com.yeshi.fanli.util.Constant;



import com.yeshi.fanli.util.MoneyBigDecimalUtil;



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.TimeUtil;



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



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



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







import net.sf.json.JSONObject;







@@ -93,6 +125,12 @@


   private DeviceTokenOPPOService deviceTokenOPPOService;







   @Resource



   private DeviceTokenXMService deviceTokenXMService;







   @Resource



   private DeviceTokenVIVOService deviceTokenVIVOService;







   @Resource



   private TaoBaoUnionConfigService taoBaoUnionConfigService;







   @Resource



@@ -128,7 +166,32 @@


   @Resource



   private DeviceActiveService deviceActiveService;







   @Resource



   private BindRemindService bindRemindService;







   @Resource



   private UserVIPInfoService userVIPInfoService;







   @Resource



   private HongBaoV2CountService hongBaoV2CountService;







   @Resource



   private IntegralDetailService integralDetailService;







   @Resource



   private BanLiShopOrderService banLiShopOrderService;







   @Resource



   private ConfigService configService;







   @Resource



   private UserVipConfigService userVipConfigService;







   @Resource



   private UserInfoExtraService userInfoExtraService;







   @Resource



   private UserMoneyDetailService userMoneyDetailService;







   /**



    * 新版登录 V1.5.3



@@ -143,7 +206,7 @@


    * @param out



    */



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



   public void login(AcceptData acceptData, int loginType, String vcode, String phone, String code, 


   public void login(AcceptData acceptData, int loginType, String vcode, String phone, String code,



         HttpServletRequest request, PrintWriter out) {



      try {



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



@@ -169,6 +232,7 @@


         } else {



            JSONObject data = new JSONObject();



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



            data.put("inviteCode", userInfoExtraService.getInviteCodeByUid(userInfo.getId()));



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







            final UserInfo uuser = userInfo;



@@ -182,19 +246,12 @@


                     LogHelper.errorDetailInfo(e);



                  }







                  if (VersionUtil.greaterThan_1_5_60(acceptData.getPlatform(), acceptData.getVersion())) {



                     /* 新人红包 */



                     try {



                        userTaoLiJinOriginService.synchDeviceHongbao(uuser.getId(), device);



                     } catch (Exception e) {



                        e.printStackTrace();



                     }



                  }



						


                  // 绑定oppo推送



                  // 绑定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());



                  }



               }



            });



@@ -212,12 +269,12 @@


         } else {



            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();



            }



         }



			






      } catch (Exception e) {



         out.print(JsonUtil.loadFalseResult("登录失败"));



         try {



@@ -228,8 +285,6 @@


      }



   }







	


	


   /**



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



    * 



@@ -240,7 +295,8 @@


    */



   @RequestSerializableByKey(key = "'bindPhoneLogin-'+#phone")



   @RequestMapping(value = "bindPhoneLogin")



   public void bindPhoneLogin(AcceptData acceptData,String vcode, String phone, String key, HttpServletRequest request, PrintWriter out) {



   public void bindPhoneLogin(AcceptData acceptData, String vcode, String phone, String key,



         HttpServletRequest request, PrintWriter out) {



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



            acceptData.getPackages());



      if (system == null) {



@@ -262,7 +318,7 @@


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



         return;



      }



		






      phone = phone.replaceAll(" ", "");







      String oldVCode = redisManager.getSMSVCode(phone, SMSHistory.TYPE_BIND);



@@ -286,5 +342,241 @@


         out.print(JsonUtil.loadFalseResult(1, "绑定失败"));



      }



   }



	






   /**



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



    * 


    * @param acceptData



    * @param vcode



    * @param phone



    * @param out



    */



   @RequestMapping(value = "recordBind")



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



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



         out.print(JsonUtil.loadFalseResult("用户id为空"));



         return;



      }







      bindRemindService.addBindPhone(uid);



      out.print(JsonUtil.loadTrueResult("记录成功"));



   }







   /**



    * 获取vip信息



    * 


    * @param acceptData



    * @param uid



    * @param out



    */



   @RequestMapping(value = "getVIPInfo")



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



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



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



         return;



      }







      UserInfo userInfo = userInfoService.selectByPKey(uid);



      if (userInfo == null) {



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



         return;



      }



      //



      String inviteCode = userInfoExtraService.getInviteCodeByUid(uid);







      UserVipRateVO vo = new UserVipRateVO();



      vo.setId(uid);



      vo.setInviteCode(inviteCode);



      vo.setNickName(userInfo.getNickName());



      vo.setPortrait(userInfo.getPortrait());



      vo.setHelpLink(userVipConfigService.getValueByKey("help_link_vip_h5"));



      vo.setCsdLink(configService.get(ConfigKeyEnum.customerServiceLink.getKey()));







      Date now = new Date();



      Date start = new Date(0);







      // 返利订单、奖励券提成



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



      typeFanli.add(UserMoneyDetailTypeEnum.fanli);



      typeFanli.add(UserMoneyDetailTypeEnum.orderReward);



      BigDecimal finishMoney = userMoneyDetailService.statisticUserTypeMoneyWithDate(uid, typeFanli, start, now)



            .abs();







      // 邀请订单、分享订单、补贴



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



      typeList.add(UserMoneyDetailTypeEnum.share);



      typeList.add(UserMoneyDetailTypeEnum.invite);



      typeList.add(UserMoneyDetailTypeEnum.inviteAndShare);



      typeList.add(UserMoneyDetailTypeEnum.systemEqualize);



      typeList.add(UserMoneyDetailTypeEnum.subsidy);



      BigDecimal rewardMoney = userMoneyDetailService.statisticUserTypeMoneyWithDate(uid, typeList, start, now).abs();







      UserVIPInfo userVIPInfo = userVIPInfoService.selectByUid(uid);



      vo.setVipInfo(userVIPInfo);



      String leftTime = "";



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



         // TODO 计算时间



         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;



         }



      }



      vo.setLeftTime(leftTime);







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



            && userVIPInfo.getState() == UserVIPInfo.STATE_SUCCESS) { // VIP



         vo.setSuccessTime(TimeUtil.getGernalTime(userVIPInfo.getSuccessTime().getTime(), "yyyy.MM.dd"));



         vo.setConserveMoney(finishMoney);



         vo.setEarnMoney(rewardMoney);



      } else {



         BigDecimal rate = new BigDecimal("0.409");



         vo.setConserveMoney(MoneyBigDecimalUtil.mul2(finishMoney, rate));



         vo.setEarnMoney(MoneyBigDecimalUtil.mul2(rewardMoney, rate));



      }



      vo.setFinishMoney(hongBaoV2CountService.getRewardMoneyBySelf(uid));







      List<Integer> list = new ArrayList<Integer>();



      list.add(BanLiShopOrder.STATE_SUCCESS);



      BigDecimal payMoney = new BigDecimal(userVipConfigService.getValueByKey("require_order_pay"));







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



      vo.setFinishTeam(hongBaoV2CountService.countValidOrderTeamUserByUid(uid,



            TimeUtil.convertDateToTemp(Constant.VIP_ONLINE_TIME), payMoney));



      vo.setFinishHongBao(banLiShopOrderService.countByUidAndState(uid, list));







      // 区分老用户和新用户



      String limtDate = userVipConfigService.getValueByKey("vip_execute_time");



      Date executeDate = null;



      try {



         SimpleDateFormat format = new SimpleDateFormat("yyyy-mm-dd");



         executeDate = format.parse(limtDate);



      } catch (ParseException e) {



         e.printStackTrace();



      }



      UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);



      if (extra != null



            && (extra.getFirstLoginTime() == null || extra.getFirstLoginTime().getTime() < executeDate.getTime())) {



         vo.setLimitTeam(Long.parseLong(userVipConfigService.getValueByKey("require_invite_num_old_user")));



      } else {



         vo.setLimitTeam(Long.parseLong(userVipConfigService.getValueByKey("require_invite_num_new_user")));



      }



      vo.setLimitHongBao(Long.parseLong(userVipConfigService.getValueByKey("require_shop_buy")));



      vo.setLimitMoney(new BigDecimal(userVipConfigService.getValueByKey("require_fan_money")));



      vo.setLimitgoldCoin(Long.parseLong(userVipConfigService.getValueByKey("require_gold_coin")));







      GsonBuilder gsonBuilder = new GsonBuilder();



      gsonBuilder.registerTypeAdapter(BigDecimal.class, new JsonSerializer<BigDecimal>() {



         @Override



         public JsonElement serialize(BigDecimal value, Type theType, JsonSerializationContext context) {



            if (value == null) {



               return new JsonPrimitive("");



            } else {



               // 保留2位小数



               value = value.setScale(2);



               return new JsonPrimitive(value.toString());



            }



         }



      });



      Gson gson = gsonBuilder.create();







      if (!StringUtil.isNullOrEmpty(callback)) {



         out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadTrueResult(gson.toJson(vo))));



      } else {



         out.print(JsonUtil.loadTrueResult(gson.toJson(vo)));



      }



   }







   /**



    * 开通VIP



    * 


    * @param callback



    * @param acceptData



    * @param uid



    * @param out



    */



   @RequestMapping(value = "applyVip")



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



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



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



         return;



      }







      UserInfo userInfo = userInfoService.selectByPKey(uid);



      if (userInfo == null) {



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



         return;



      }







      // 省钱 -自购产生返利







      List<Integer> list = new ArrayList<Integer>();



      list.add(BanLiShopOrder.STATE_SUCCESS);



      BigDecimal payMoney = new BigDecimal(userVipConfigService.getValueByKey("require_order_pay"));







      BigDecimal finishGoldCoin = integralDetailService.getCumulativeMoney(uid);



      long finishTeam = hongBaoV2CountService.countValidOrderTeamUserByUid(uid,



            TimeUtil.convertDateToTemp(Constant.VIP_ONLINE_TIME), payMoney);



      long finishHongBao = banLiShopOrderService.countByUidAndState(uid, list);



      BigDecimal finishMoney = hongBaoV2CountService.getRewardMoneyBySelf(uid);







      long limitTeam = 0;







      // 区分老用户和新用户



      String limtDate = userVipConfigService.getValueByKey("vip_execute_time");



      Date executeDate = null;



      try {



         SimpleDateFormat format = new SimpleDateFormat("yyyy-mm-dd");



         executeDate = format.parse(limtDate);



      } catch (ParseException e) {



         e.printStackTrace();



      }







      UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);



      if (extra != null



            && (extra.getFirstLoginTime() == null || extra.getFirstLoginTime().getTime() < executeDate.getTime())) {



         limitTeam = (Long.parseLong(userVipConfigService.getValueByKey("require_invite_num_old_user")));



      } else {



         limitTeam = (Long.parseLong(userVipConfigService.getValueByKey("require_invite_num_new_user")));



      }



      long limitHongBao = (Long.parseLong(userVipConfigService.getValueByKey("require_shop_buy")));



      BigDecimal limitMoney = (new BigDecimal(userVipConfigService.getValueByKey("require_fan_money")));



      BigDecimal limitgoldCoin = (new BigDecimal(userVipConfigService.getValueByKey("require_gold_coin")));







      if (finishGoldCoin.compareTo(limitgoldCoin) >= 0 && finishTeam >= limitTeam && finishHongBao >= limitHongBao



            && finishMoney.compareTo(limitMoney) >= 0) {// 条件符合



         ;



      } else {



         if (!StringUtil.isNullOrEmpty(callback)) {



            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未达到开通条件")));



         } else {



            out.print(JsonUtil.loadFalseResult("未达到开通条件"));



         }



         return;



      }



      // 开通



      try {



         userVIPInfoService.applyVIP(uid);



      } catch (UserVIPInfoException e) {



         if (!StringUtil.isNullOrEmpty(callback)) {



            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult(e.getMsg())));



         } else {



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



         }



         return;



      }







      if (!StringUtil.isNullOrEmpty(callback)) {



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



      } else {



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



      }



   }







}