blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
admin
2020-05-19 744594ef1a2f530fc3e86ea9dc48b62247f79420 
 fanli/src/main/java/com/yeshi/fanli/controller/client/v2/IntegralControllerV2.java


@@ -30,31 +30,38 @@


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



import com.yeshi.fanli.entity.bus.tlj.UserTaoLiJinDetail.TaoLiJinDetailTypeEnum;



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



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



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



import com.yeshi.fanli.entity.common.JumpDetailV2;



import com.yeshi.fanli.entity.integral.CodePublishRecord;



import com.yeshi.fanli.entity.integral.IntegralExchange;



import com.yeshi.fanli.entity.integral.IntegralExchange.ExchangeTypeEnum;



import com.yeshi.fanli.entity.integral.IntegralTask;



import com.yeshi.fanli.entity.integral.IntegralTask.TaskUniqueKeyEnum;



import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;



import com.yeshi.fanli.entity.integral.IntegralTaskRecord;



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



import com.yeshi.fanli.exception.integral.IntegralExchangeException;



import com.yeshi.fanli.exception.integral.IntegralGetException;



import com.yeshi.fanli.exception.integral.IntegralTaskRecordException;



import com.yeshi.fanli.log.LogHelper;



import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;



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



import com.yeshi.fanli.service.inter.integral.CodePublishRecordService;



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



import com.yeshi.fanli.service.inter.integral.IntegralExchangeRecordService;



import com.yeshi.fanli.service.inter.integral.IntegralExchangeService;



import com.yeshi.fanli.service.inter.integral.IntegralGetService;



import com.yeshi.fanli.service.inter.integral.IntegralTaskClassService;



import com.yeshi.fanli.service.inter.integral.IntegralTaskRankService;



import com.yeshi.fanli.service.inter.integral.IntegralTaskRecordService;



import com.yeshi.fanli.service.inter.integral.IntegralTaskService;



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



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



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



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



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



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



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



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



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



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



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



import com.yeshi.fanli.util.Constant;



import com.yeshi.fanli.util.StringUtil;



import com.yeshi.fanli.util.TimeUtil;



import com.yeshi.fanli.util.VersionUtil;



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



import com.yeshi.fanli.vo.integral.DailySignVO;



import com.yeshi.fanli.vo.integral.ExchangeTipVO;



import com.yeshi.fanli.vo.integral.IntegralDetailVO;



@@ -103,6 +110,9 @@


   @Resource



   private IntegralGetService integralGetService;







   @Resource



   private JumpDetailV2Service jumpDetailV2Service;







   /**



    * 获取任务列表



    * 



@@ -111,7 +121,7 @@


    * @param page



    * @param out



    */



//   @RequestSerializableByKey(key="#acceptData.device")



   // @RequestSerializableByKey(key="#acceptData.device")



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



   public void getTaskList(AcceptData acceptData, Long uid, Integer page, PrintWriter out) {



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



@@ -137,7 +147,6 @@






         // 用户签到



         Integer signState = 0;



         int signDays = 1;



         if (page == 1) {







            // 签到



@@ -167,9 +176,6 @@






            // 签到日期信息



            DailySignVO dailySignVO = integralTaskClassService.getDailySignList(uid, userRank.getId());



            if (dailySignVO != null) {



               signDays = dailySignVO.getDays();



            }







            boolean ejectSign = false;



            if (signState == 1)



@@ -181,8 +187,22 @@


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



            data.put("dailySign", dailySignVO);



         }



         for (int i = 0; i < list.size(); i++) {



            IntegralTaskClassVO taskClassVO = list.get(i);







         for (IntegralTaskClassVO taskClassVO : list) {



            UniqueKeyEnum uniqueKey = taskClassVO.getUniqueKey();







            // 邀请好友：是否激活邀请码



            if (uniqueKey == UniqueKeyEnum.inviteTeam) {



               UserInfoExtraVO extraVO = userInfoExtraService.getInfoExtraVOByUid(uid);



               if (extraVO == null || StringUtil.isNullOrEmpty(extraVO.getInviteCode())) {



                  JumpDetailV2 jumpDetailV2 = jumpDetailV2Service.getByTypeCache("invite_activate",



                        Constant.getPlatformCode(acceptData.getPlatform()),



                        Integer.parseInt(acceptData.getVersion()));



                  taskClassVO.setJumpDetail(jumpDetailV2);



               }



            }







            String progress = taskClassVO.getProgress();



            if (StringUtil.isNullOrEmpty(progress))



               continue;



@@ -191,7 +211,6 @@


            if (taskNum == null)



               continue;







            UniqueKeyEnum uniqueKey = taskClassVO.getUniqueKey();



            if (uniqueKey == UniqueKeyEnum.dailySign) {



               if (signState == 0) {



                  taskClassVO.setLightUp(true); // 签到失败



@@ -219,18 +238,27 @@


               taskClassVO.setLightUp(true);



            }







            Integer dateType = 1; // 查询当日



            if (uniqueKey == UniqueKeyEnum.orderReward)



               dateType = null; // 查询历史







            Long id = taskClassVO.getId();



            int countFinished = 0;



            Integer totalGoldCoin = integralTaskRecordService.getTotalGoldCoin(uid, id, dateType);



            Long id = taskClassVO.getId();



            // 查询当日



            Integer totalGoldCoin = integralTaskRecordService.getTotalGoldCoin(uid, id, 1);



            if (totalGoldCoin != null && totalGoldCoin > 0) {



               taskClassVO.setFinishedCoin("+" + totalGoldCoin);



               if (uniqueKey != UniqueKeyEnum.dailySign)



                  countFinished = integralTaskRecordService.countFinished(uid, id, dateType);



               if (uniqueKey != UniqueKeyEnum.dailySign && uniqueKey != UniqueKeyEnum.accountMaintain) {



                  countFinished = integralTaskRecordService.countFinished(uid, id, 1);



               }



            }







            if (uniqueKey == UniqueKeyEnum.accountMaintain) {



               countFinished = integralTaskRecordService.countFinished(uid, id, null); // 查询历史



            }







            /*



             * // 完善信息完成后，列表中消失 if (uniqueKey ==



             * UniqueKeyEnum.accountMaintain && taskNum == countFinished) {



             * list.remove(i); i --; continue; }



             */







            progress = progress.replace("{已完成}", countFinished + "").replace("{总任务}", taskNum + "");







            if (signState == 0 && uniqueKey == UniqueKeyEnum.dailySign) {



@@ -262,10 +290,7 @@


         return;



      }







      int count = 5;



      if ("android".equalsIgnoreCase(acceptData.getPlatform())) {



         count = Integer.MAX_VALUE;



      }



      int count = Integer.MAX_VALUE;







      List<IntegralTaskRecord> list = integralTaskRecordService.listNotReceived(count, uid);



      if (list == null) {



@@ -291,6 +316,7 @@


    *            // 未领取id



    * @param out



    */



   @RequestSerializableByKey(key = "'receiveGoldCoin-'+#uid")



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



   public void receiveGoldCoin(AcceptData acceptData, Long uid, Integer type, String ids, String gids,



         PrintWriter out) {



@@ -318,24 +344,8 @@


            return;



         }



         Integer goldCoin = integralTaskRecordService.receiveGoldCoin(uid, idList);



         Set<Long> gidList = gson.fromJson(gids, new TypeToken<HashSet<Long>>() {



         }.getType());



         List<IntegralTaskRecord> list = null;



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



            list = integralTaskRecordService.listNotReceivedExcludeId(5 - gidList.size(), uid, gidList);



         } else {



            list = integralTaskRecordService.listNotReceivedExcludeId(5, uid, null);



         }







         if (list == null) {



            list = new ArrayList<IntegralTaskRecord>();



         }



         GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();



         Gson gson2 = gsonBuilder.create();







         JSONObject data = new JSONObject();



         data.put("goldCoin", goldCoin);



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



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



      } catch (IntegralTaskRecordException e) {



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



@@ -370,8 +380,22 @@






      List<IntegralExchange> list = integralExchangeRecordService.listExchange((page - 1) * Constant.PAGE_SIZE,



            Constant.PAGE_SIZE, uid);



      if (list == null)



         list = new ArrayList<IntegralExchange>();



		


      List<IntegralExchange> listNew = new ArrayList<>();



      if (list != null)



         listNew.addAll(list);



		


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



         for (int i=0; i < listNew.size(); i ++) {



            IntegralExchange integralExchange = listNew.get(i);



            ExchangeTypeEnum type = integralExchange.getType();



            if (type != null &&



                  (type == ExchangeTypeEnum.inviteCodeActivate || type == ExchangeTypeEnum.inviteCodePublish)) {



               listNew.remove(i);



               i--;



            }



         }



      }







      // Long count = integralExchangeService.countValid();







@@ -380,9 +404,31 @@






      JSONObject data = new JSONObject();



      data.put("goldCoin", extraVO.getGoldCoin() + "枚");



      data.put("count", list.size());



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



      data.put("count", listNew.size());



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



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



   }







   @RequestMapping(value = "getExchangeDetail")



   public void getExchangeDetail(AcceptData acceptData, Long id, String callback, PrintWriter out) {



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



         out.print(JsonUtil.loadFalseResult(1, "兑换ID有误"));



         return;



      }



      IntegralExchange exchange = integralExchangeService.selectByPrimaryKey(id);



      if (exchange != null) {



         GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();



         Gson gson = gsonBuilder.create();



         if (StringUtil.isNullOrEmpty(callback))



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



         else



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



      } else {



         if (StringUtil.isNullOrEmpty(callback))



            out.print(JsonUtil.loadFalseResult("未找到"));



         else



            out.print(JsonUtil.loadJSONP(callback, JsonUtil.loadFalseResult("未找到")));



      }



   }







   /**



@@ -393,22 +439,28 @@


    * @param id



    * @param out



    */



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



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



   @RequestMapping(value = "verifyExchange")



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



      try {



         ExchangeTipVO exchange = integralExchangeService.verifyExchange(uid, id);







         GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();



         Gson gson = gsonBuilder.create();







         JSONObject data = new JSONObject();



         data.put("result", gson.toJson(exchange));



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



         if (StringUtil.isNullOrEmpty(callback)) {



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



         } else {



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



         }



      } catch (IntegralExchangeException e) {



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



         if (StringUtil.isNullOrEmpty(callback)) {



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



         } else {



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



         }



      }



   }



	






   /**



    * 兑换金币



@@ -418,19 +470,29 @@


    * @param id



    * @param out



    */



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



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



   @RequestSerializableByKey(key = "'integralexchange-'+#uid")



   @RequestMapping(value = "exchange")



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



      try {



         IntegralExchange exchange = integralExchangeService.exchange(uid, id);







         UserInfoExtra extraVO = userInfoExtraService.getUserInfoExtra(uid);







         GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();



         Gson gson = gsonBuilder.create();







         JSONObject data = new JSONObject();



         data.put("result", gson.toJson(exchange));



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



         data.put("goldCoin", extraVO.getGoldCoin() + "枚");



         if (StringUtil.isNullOrEmpty(callback))



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



         else



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



      } catch (IntegralExchangeException e) {



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



         if (StringUtil.isNullOrEmpty(callback))



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



         else



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



      }



   }







@@ -466,11 +528,15 @@


    * @param id



    * @param out



    */



   @RequestSerializableByKey(key = "'exchangeInviteCode-'+#uid")



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



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



      try {



         integralExchangeService.exchangeInviteCode(uid, id);



         out.print(JsonUtil.loadTrueResult("邀请码激活成功"));



         String inviteCode = integralExchangeService.exchangeInviteCode(uid, id);



         JSONObject data = new JSONObject();



         data.put("msg", "兑换成功，金币已消耗 ");



         data.put("inviteCode", inviteCode);



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



      } catch (IntegralExchangeException e) {



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



      }



@@ -490,19 +556,24 @@


         return;



      }







      List<CodePublishRecord> list = codePublishRecordService.listValid((page - 1) * Constant.PAGE_SIZE,



            Constant.PAGE_SIZE);



      if (list == null) {



         list = new ArrayList<CodePublishRecord>();



      try {



         List<CodePublishRecord> list = codePublishRecordService.listValid(null, (page - 1) * Constant.PAGE_SIZE,



               Constant.PAGE_SIZE);



         if (list == null) {



            list = new ArrayList<CodePublishRecord>();



         }







         long count = codePublishRecordService.countValid();







         JSONObject data = new JSONObject();



         data.put("count", count);



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



         data.put("helpLink", configService.get(ConfigKeyEnum.publishListHelpLink.getKey()));



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



      } catch (Exception e) {



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



         return;



      }







      long count = codePublishRecordService.countValid();







      JSONObject data = new JSONObject();



      data.put("count", count);



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



      data.put("helpLink", configService.get("publish_list_help_link"));



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



   }







   /**



@@ -514,7 +585,7 @@


    * @param out



    */



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



   public void pushEvent(AcceptData acceptData, String event, Long uid, PrintWriter out) {



   public void pushEvent(AcceptData acceptData, String event, Long uid, String data, PrintWriter out) {



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



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



         return;



@@ -525,34 +596,53 @@


         return;



      }



      IntegralTaskRecord record = null;



      try {



         record = integralGetService.addEventStatistic(uid, event, null);



      } catch (IntegralGetException e) {



      }



      if (record == null) {



         out.print(JsonUtil.loadFalseResult("添加失败"));



         return;



      }







      JSONObject data = new JSONObject();



      if ("recommendSearch".equalsIgnoreCase(event) || "scanGoods".equalsIgnoreCase(event)



            || "scanTBCart".equalsIgnoreCase(event)) {



         JSONObject notify = new JSONObject();



         switch (event) {



         case "recommendSearch":



            notify.put("name", "完成一次智能搜索");



            break;



         case "scanGoods":



            notify.put("name", "完成一次商品浏览");



            break;



         case "scanTBCart":



            notify.put("name", "完成一次购物车浏览");



            break;



      try {



         if (TaskUniqueKeyEnum.recommendSearch.name().equalsIgnoreCase(event)) {



            record = integralGetService.addRecommendSearch(uid);



         } else if (TaskUniqueKeyEnum.shareInvite.name().equalsIgnoreCase(event)) {



            record = integralGetService.addShareInvite(uid);



         } else if (TaskUniqueKeyEnum.inShop.name().equalsIgnoreCase(event)) {



            JSONObject json = JSONObject.fromObject(data);



            record = integralGetService.addIntoShop(uid, StringUtil.Md5(json.optString("url")));



         } else if (TaskUniqueKeyEnum.scanPush.name().equalsIgnoreCase(event)) {



            record = integralGetService.addScanPushHistory(uid);



         } else if (TaskUniqueKeyEnum.scanGoods.name().equalsIgnoreCase(event)) {



            JSONObject json = JSONObject.fromObject(data);



            record = integralGetService.addScanGoodsDetail(uid, json.optInt("goodsType"), json.optLong("goodsId"));



         } else if (TaskUniqueKeyEnum.scanHomeBanner.name().equalsIgnoreCase(event)) {



            JSONObject json = JSONObject.fromObject(data);



            record = integralGetService.addScanRecommendBanner(uid, json.optString("id"));



         } else if (TaskUniqueKeyEnum.scanSpecial.name().equalsIgnoreCase(event)) {



            JSONObject json = JSONObject.fromObject(data);



            record = integralGetService.addScanRecommendSpecial(uid, json.optString("id"));



         } else if (TaskUniqueKeyEnum.scanTBCart.name().equalsIgnoreCase(event)) {



            record = integralGetService.addScanTaoBaoCart(uid);



         }



         notify.put("score", String.format("+%s金币", record.getGoldCoin()));



         data.put("notify", notify);







         if (record != null) {



            JSONObject notifyData = new JSONObject();



            if (TaskUniqueKeyEnum.recommendSearch.name().equalsIgnoreCase(event)



                  || TaskUniqueKeyEnum.scanGoods.name().equalsIgnoreCase(event)



                  || TaskUniqueKeyEnum.scanTBCart.name().equalsIgnoreCase(event)) {



               JSONObject notify = new JSONObject();



               if (TaskUniqueKeyEnum.recommendSearch.name().equalsIgnoreCase(event))



                  notify.put("name", "完成一次智能搜索");



               else if (TaskUniqueKeyEnum.scanGoods.name().equalsIgnoreCase(event))



                  notify.put("name", "完成一次商品浏览");



               else if (TaskUniqueKeyEnum.scanTBCart.name().equalsIgnoreCase(event))



                  notify.put("name", "完成一次购物车浏览");







               notify.put("score", String.format("+%s金币", record.getGoldCoin()));



               notifyData.put("notify", notify);



            }



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



         } else {



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



         }



      } catch (Exception e) {



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



      }



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



   }







   /**