邀请码添加返回状态

yujian

2019-01-22 88b54772dbcf5ecab1e2316e4e4626ac901b8908

 fanli/src/main/java/com/yeshi/fanli/controller/client/UserInfoController.java

@@ -10,14 +10,12 @@
import java.util.ArrayList;

import java.util.Arrays;

import java.util.Date;

import java.util.Iterator;

import java.util.List;

import java.util.UUID;



import javax.annotation.Resource;

import javax.servlet.http.HttpServletRequest;



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



import org.apache.commons.beanutils.PropertyUtils;

import org.springframework.stereotype.Controller;

@@ -27,6 +25,7 @@
import org.yeshi.utils.IPUtil;

import org.yeshi.utils.JsonUtil;

import org.yeshi.utils.NumberUtil;

import org.yeshi.utils.taobao.TbImgUtil;

import org.yeshi.utils.tencentcloud.COSManager;



import com.google.gson.Gson;

@@ -35,6 +34,7 @@
import com.google.gson.JsonPrimitive;

import com.google.gson.JsonSerializationContext;

import com.google.gson.JsonSerializer;

import com.yeshi.fanli.dto.HongBaoDTO;

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

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

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

@@ -57,6 +57,8 @@
import com.yeshi.fanli.entity.common.Config;

import com.yeshi.fanli.entity.goods.CollectionGoodsV2;

import com.yeshi.fanli.entity.goods.CommonGoods;

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

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

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

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;

import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBriefExtra;

@@ -65,6 +67,8 @@
import com.yeshi.fanli.exception.goods.CollectionGoodsException;

import com.yeshi.fanli.exception.taobao.TaoKeApiException;

import com.yeshi.fanli.exception.taobao.TaobaoGoodsDownException;

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

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

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.service.AdminUserService;

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

@@ -72,12 +76,13 @@
import com.yeshi.fanli.service.inter.goods.CollectionGoodsV2Service;

import com.yeshi.fanli.service.inter.hongbao.HongBaoManageService;

import com.yeshi.fanli.service.inter.hongbao.HongBaoService;

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

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleExtraInfoSerivce;

import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;

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

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

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

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

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

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

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

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

@@ -85,9 +90,14 @@
import com.yeshi.fanli.service.inter.user.MoneyRecordService;

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

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

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

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

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

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

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

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

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

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

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

import com.yeshi.fanli.util.AESUtil;

import com.yeshi.fanli.util.Constant;

@@ -100,9 +110,17 @@
import com.yeshi.fanli.util.Utils;

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

import com.yeshi.fanli.util.email.MailSenderUtil;

import com.yeshi.fanli.util.factory.AccountDetailsFactory;

import com.yeshi.fanli.util.factory.HongBaoFactory;

import com.yeshi.fanli.util.factory.OrderItemFactory;

import com.yeshi.fanli.util.taobao.TaoBaoUtil;

import com.yeshi.fanli.util.taobao.TaoKeApiUtil;

import com.yeshi.fanli.util.wx.WXLoginUtil;

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

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



import net.sf.json.JSONArray;

import net.sf.json.JSONObject;



@Controller

@RequestMapping("api/v1/customer")

@@ -151,9 +169,6 @@
   private OrderItemServcie orderItemServcie;



   @Resource

   private AccountDetailsService accountDetailsService;



   @Resource

   private AccountMessageService accountMessageService;



   @Resource

@@ -179,6 +194,28 @@


   @Resource

   private AdminUserService adminUserService;



   @Resource

   private UserMoneyDetailService userMoneyDetailService;



   @Resource

   private HongBaoOrderService hongBaoOrderService;



   @Resource

   private HongBaoV2Service hongBaoV2Service;



   @Resource

   private SpreadUserImgService spreadUserImgService;



   @Resource

   private UserShareGoodsRecordService userShareGoodsRecordService;

	
   @Resource

   private UserCustomSettingsService userCustomSettingsService;

	
   @Resource

   private UserInfoExtraService userInfoExtraService;

	


   private static final String PASSWORD_MAX_ERROR = "password_max_error";

   private static final String EXTRACT_MIN_MONEY = "extract_min_money";

@@ -474,12 +511,54 @@
      data.put("user", JsonUtil.getConvertBigDecimalToStringBuilder(gsonBuilder).create()

            .toJson(UserUtil.filterForClientUser(user)));

      data.put("first", 0);

      int spreadImgCount = spreadUserImgService.countUserSpreadImg(user.getId());

      long shareCount = userShareGoodsRecordService.countShareRecordByUid(user.getId());

		
      int showTiCheng = 1; // 不显示

      if ("ios".equalsIgnoreCase(acceptData.getPlatform())

            && configService.iosOnLining(Integer.parseInt(acceptData.getVersion())))

         data.put("showTiCheng", false);

      else {

         data.put("showTiCheng", spreadImgCount + shareCount > 0);

         if (spreadImgCount + shareCount > 0) {

            showTiCheng = 0;

         }

      }



      if ("ios".equalsIgnoreCase(acceptData.getPlatform())

            && configService.iosOnLining(Integer.parseInt(acceptData.getVersion())))

         data.put("inviteList", String.format("http://%s/%s/client/share/friends_new_online.html",

               Constant.systemCommonConfig.getProjectHost(), Constant.systemCommonConfig.getProjectName()));

      else

         data.put("inviteList", configService.get("team_list"));

	
      // 界面状态

      UserSettingsVO mySettings = null; 
      try {

         mySettings = userCustomSettingsService.getMySettings(user.getId());

      } catch (UserCustomSettingsException e) {

         mySettings = new UserSettingsVO();

         e.printStackTrace();

      }

		
      if (mySettings.getCancelNotice() == null) {

         mySettings.setCancelNotice(0);

      }

      if (mySettings.getNoBonusCount() == null) {

         mySettings.setNoBonusCount(showTiCheng); // 根据showTiCheng来判断

      }

      if (mySettings.getNoNewsRedDot() == null) {

         mySettings.setNoNewsRedDot(0);

      }

      if (mySettings.getNoShareRecordAndStorage() == null) {

         mySettings.setNoShareRecordAndStorage(showTiCheng); // 根据showTiCheng来判断

      }

      if (mySettings.getNoInvitationBonus() == null) {

         mySettings.setNoInvitationBonus(0);

      }

		
      data.put("moduleState", mySettings);

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

      final UserInfo uuser = user;

      ThreadUtil.run(new Runnable() {

@@ -1363,15 +1442,20 @@


   @RequestMapping("findOrderItemList")

   public void findOrderItemList(AcceptData acceptData, long uid, int page, PrintWriter out) {

      List<OrderItem> list = orderItemServcie.findOrderItemList(uid, page);

      list.parallelStream().forEach(oi -> {

         oi.setDesc();

      });

      int count = orderItemServcie.getCount(uid);

      List<HongBaoOrder> list = hongBaoOrderService.listFanLiOrder(uid, page, Constant.PAGE_SIZE);



      List<OrderItem> orderList = new ArrayList<>();

      for (HongBaoOrder oi : list) {

         OrderItem orderItem = OrderItemFactory.create(oi);

         orderItem.setDesc();

         orderItem.setPicture(TbImgUtil.getTBSize220Img(orderItem.getPicture()));

         orderList.add(orderItem);

      }

      long count = hongBaoOrderService.countFanLiOrder(uid);

      Gson gson = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder())

            .excludeFieldsWithoutExposeAnnotation().create();

      JSONObject data = new JSONObject();

      data.put("list", gson.toJson(list));

      data.put("list", gson.toJson(orderList));

      data.put("count", count);

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

   }

@@ -1386,8 +1470,13 @@
    */

   @RequestMapping("getTiChengOrderList")

   public void getTiChengOrderList(AcceptData acceptData, long uid, int page, PrintWriter out) {

      List<HongBao> list = hongBaoService.getTiChengHongBaoList(uid, page);

      long count = hongBaoService.getTiChengHongBaoListCount(uid);

      List<HongBaoDTO> hongBaoDTOList = hongBaoV2Service.listJiangJinByUid(uid, page, Constant.PAGE_SIZE);

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

      if (hongBaoDTOList != null)

         for (HongBaoDTO dto : hongBaoDTOList) {

            list.add(HongBaoFactory.createHongBao(dto));

         }

      long count = hongBaoV2Service.countJiangJinByUid(uid);

      List<OrderItem> orderItemList = HongBaoUtil.convertToTiChengOrder(list);

      Gson gson = JsonUtil.getApiCommonGson();

      JSONObject data = new JSONObject();

@@ -1518,17 +1607,15 @@
            Constant.PAGE_SIZE);



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

		
		


      long count = collectionGoodsV2Service.getCollectionGoodsCount(uid);

      JSONObject data = new JSONObject();

	
		


      List<TaoBaoGoodsBrief> listTaoKeGoods = new ArrayList<TaoBaoGoodsBrief>();

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

			


         BigDecimal proportion = hongBaoManageService.getFanLiRate();

			


         List<Long> listGid = new ArrayList<Long>();

         for (CollectionGoodsV2 collectionGoodsV2 : collectionGoodsList) {

            CommonGoods commonGoods = collectionGoodsV2.getCommonGoods();

@@ -1537,7 +1624,7 @@
            }

            listGid.add(commonGoods.getGoodsId());

         }

			


         try {

            // API网络接口验证是否在售

            listTaoKeGoods = TaoKeApiUtil.getBatchGoodsInfo(listGid);

@@ -1548,17 +1635,17 @@
         } catch (Exception e) {

            e.printStackTrace();

         }

			


         for (CollectionGoodsV2 collectionGoodsV2 : collectionGoodsList) {

            CommonGoods commonGoods = collectionGoodsV2.getCommonGoods();

            if (commonGoods == null) {

               continue;

            }

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

               int state = 1;  // 默认停售



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

               int state = 1; // 默认停售

               Long goodsId = commonGoods.getGoodsId();

               for (TaoBaoGoodsBrief taoKeGoods: listTaoKeGoods) {

               for (TaoBaoGoodsBrief taoKeGoods : listTaoKeGoods) {

                  Long auctionId = taoKeGoods.getAuctionId();

                  if (goodsId == auctionId || goodsId.equals(auctionId)) {

                     state = 0; // 在售

@@ -1567,18 +1654,18 @@
               }

               commonGoods.setState(state);

            }

				


            TaoBaoGoodsBrief goodsBrief = TaoBaoUtil.convert(commonGoods);

            goodsBrief.setSalesCount(TaoBaoUtil.getSaleCount(goodsBrief.getBiz30day()));

            TaoBaoGoodsBriefExtra taoBaoGoodsBriefExtra = TaoBaoUtil.getTaoBaoGoodsBriefExtra(goodsBrief,

                  proportion.toString(), "");

            taoBaoGoodsBriefExtra.setCreatetime(commonGoods.getCreateTime());

				
            taoBaoGoodsBriefExtra.setCreatetime(collectionGoodsV2.getCreateTime());



            list.add(taoBaoGoodsBriefExtra);

         }

			


      }

		


      GsonBuilder builder = new GsonBuilder().registerTypeAdapter(Date.class, new JsonSerializer<Date>() {

         @Override

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

@@ -1640,8 +1727,11 @@


   @RequestMapping("findAccountDetailsList")

   public void findAccountDetailsList(AcceptData acceptData, long uid, int page, PrintWriter out) {

      List<AccountDetails> list = accountDetailsService.findAccountDetailsList(uid, page);

      int count = accountDetailsService.getCount(uid);

      List<UserMoneyDetail> detailList = userMoneyDetailService.listByUidWithState(uid, page, Constant.PAGE_SIZE);

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

      for (UserMoneyDetail detail : detailList)

         list.add(AccountDetailsFactory.create(detail));

      long count = userMoneyDetailService.countByUidWithState(uid);

      JSONObject data = new JSONObject();

      data.put("list", GsonUtil.toJsonExpose(list));

      data.put("count", count);

@@ -1649,9 +1739,21 @@
   }



   @RequestMapping("findAccountDetailsListV2")

   public void findAccountDetailsListNew(AcceptData acceptData, long uid, int page, PrintWriter out) {

      List<AccountDetails> list = accountDetailsService.findAccountDetailsListWithState(uid, page);

      long count = accountDetailsService.getCountWithState(uid);

   public void findAccountDetailsListNew(AcceptData acceptData, Long uid, int page, PrintWriter out) {



      if (uid == null) {

         out.print(JsonUtil.loadFalseResult(1, "UID为空"));

         return;

      }



      List<UserMoneyDetail> detailList = userMoneyDetailService.listByUidWithState(uid, page, Constant.PAGE_SIZE);



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

      for (UserMoneyDetail detail : detailList)

         list.add(AccountDetailsFactory.create(detail));



      long count = userMoneyDetailService.countByUidWithState(uid);



      JSONObject data = new JSONObject();

      JSONArray array = new JSONArray();

      for (AccountDetails ad : list) {

@@ -1880,7 +1982,123 @@
         out.print(JsonUtil.loadFalseResult("删除失败"));

         e.printStackTrace();

      }

   }

	
	
   /**

    *  设置界面开关状态

    * @param acceptData

    * @param uid

    * @param params

    * @param out

    */

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

   public void setModuleState(AcceptData acceptData, Long uid, String params, PrintWriter out) {



      if (uid == null) {

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

         return;

      }

		
      try {

         if (params == null || params.trim().length() == 0) {

            out.print(JsonUtil.loadFalseResult("传递参数为空"));

            return;

         }

			
         JSONObject json = JSONObject.fromObject(params);

           Iterator<String> iterator = json.keys();

         while(iterator.hasNext()){

               String type = (String) iterator.next();

               int state = json.getInt(type);

               userCustomSettingsService.saveModuleState(uid, type, state);

         }

         out.print(JsonUtil.loadTrueResult("设置成功"));

			
      } catch (UserCustomSettingsException e) {

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

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult("设置失败"));

         e.printStackTrace();

      }

   }



	
   /**

    *  获取等级信息

    * @param acceptData

    * @param uid

    * @param out

    */

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

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



      if (uid == null) {

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

         return;

      }

		
      try {

			
         UserInfoExtraVO rankInfo = userInfoExtraService.getRankInfo(uid);

			
         GsonBuilder gsonBuilder = JsonUtil.getConvertBigDecimalToStringSubZeroBuilder(new GsonBuilder());

         gsonBuilder.excludeFieldsWithoutExposeAnnotation();

         Gson gson = gsonBuilder.setDateFormat("yyyy.MM.dd").create();

			
         JSONObject resultData = new JSONObject();

         resultData.put("rankInfo", gson.toJson(rankInfo));

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

			
      } catch (UserInfoExtraException e) {

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

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult("获取失败"));

         e.printStackTrace();

      }

   }



	
   /**

    *  获取等级信息

    * @param acceptData

    * @param uid

    * @param out

    */

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

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



      if (uid == null) {

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

         return;

      }

		
      try {

			
         String inviteCode = userInfoExtraService.getUserInviteCode(uid);

			
         JSONObject inviteData = new JSONObject();

         if (inviteCode == null || inviteCode.trim().length() == 0) {

            // 无邀请码

            inviteData.put("content", "邀请激活");

            inviteData.put("link", configService.get("invite_activation_url"));

         } else {

            // 已有邀请码

            inviteData.put("content", "邀请码");

            inviteData.put("link", configService.get("invite_activation_success_url"));

         }

			
         JSONObject data = new JSONObject();

         data.put("invite", inviteData);

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

			
      } catch (UserInfoExtraException e) {

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

      } catch (Exception e) {

         out.print(JsonUtil.loadFalseResult("获取失败"));

         e.printStackTrace();

      }

   }

}