yujian
2019-08-20 df300df7832cc3d24f1b09297998e8bee8cfd126
fanli/src/main/java/com/yeshi/fanli/controller/client/v2/IntegralControllerV2.java
@@ -1,5 +1,6 @@
package com.yeshi.fanli.controller.client.v2;
import java.io.IOException;
import java.io.PrintWriter;
import java.lang.reflect.Type;
import java.util.ArrayList;
@@ -22,13 +23,16 @@
import com.google.gson.JsonPrimitive;
import com.google.gson.JsonSerializationContext;
import com.google.gson.JsonSerializer;
import com.google.gson.TypeAdapter;
import com.google.gson.reflect.TypeToken;
import com.google.gson.stream.JsonReader;
import com.google.gson.stream.JsonWriter;
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.UserRank;
import com.yeshi.fanli.entity.integral.CodePublishRecord;
import com.yeshi.fanli.entity.integral.IntegralExchange;
import com.yeshi.fanli.entity.integral.IntegralTaskClass;
import com.yeshi.fanli.entity.integral.IntegralTaskClass.UniqueKeyEnum;
import com.yeshi.fanli.entity.integral.IntegralTaskRecord;
import com.yeshi.fanli.exception.integral.IntegralExchangeException;
@@ -36,6 +40,7 @@
import com.yeshi.fanli.log.LogHelper;
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.IntegralTaskClassService;
@@ -44,8 +49,10 @@
import com.yeshi.fanli.service.inter.user.UserInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.TimeUtil;
import com.yeshi.fanli.vo.integral.DailySignVO;
import com.yeshi.fanli.vo.integral.ExchangeTipVO;
import com.yeshi.fanli.vo.integral.IntegralDetailVO;
import com.yeshi.fanli.vo.integral.IntegralTaskClassVO;
import com.yeshi.fanli.vo.user.UserInfoExtraVO;
@@ -75,6 +82,9 @@
   @Resource
   private IntegralExchangeRecordService integralExchangeRecordService;
   @Resource
   private IntegralDetailService integralDetailService;
   @Resource
   private CodePublishRecordService codePublishRecordService;
@@ -109,8 +119,18 @@
            list = new ArrayList<IntegralTaskClassVO>();
         }
         long count = integralTaskClassService.countTaskClass();
         // 用户签到
         Integer signState = 0;
         if (page == 1) {
            // 签到
            try {
               signState = integralTaskClassService.finishedDailySign(uid);
            } catch (Exception e) {
               e.printStackTrace();
            }
            UserInfoExtraVO extraVO = userInfoExtraService.getInfoExtraVOByUid(uid);
            if (extraVO == null) {
               out.print(JsonUtil.loadFalseResult(1, "用户相关信息不存在"));
@@ -128,21 +148,65 @@
               out.print(JsonUtil.loadFalseResult(1, "用户等级不存在"));
               return;
            }
            boolean signState = false;
            IntegralTaskClass taskClass = integralTaskClassService.getByUniqueKey(UniqueKeyEnum.dailySign.name());
            if (taskClass != null)
               signState = integralTaskRecordService.isToDaySign(uid, taskClass.getId());
            // 签到日期
            // 签到日期信息
            DailySignVO dailySignVO = integralTaskClassService.getDailySignList(uid, userRank.getId());
            data.put("signState", signState);
            boolean ejectSign = false;
            if (signState == 1)
               ejectSign = true;
            data.put("signState", ejectSign);
            data.put("goldCoin", extraVO.getGoldCoin());
            data.put("portrait", userInfo.getPortrait());
            data.put("userRank", gson.toJson(userRank));
            data.put("dailySign", dailySignVO);
         }
         for (IntegralTaskClassVO taskClassVO : list) {
            String progress = taskClassVO.getProgress();
            if (StringUtil.isNullOrEmpty(progress))
               continue;
            Integer taskNum = taskClassVO.getTaskNum();
            if (taskNum == null)
               continue;
            UniqueKeyEnum uniqueKey = taskClassVO.getUniqueKey();
            if (uniqueKey == UniqueKeyEnum.dailySign) {
               if (signState == 0) {
                  taskClassVO.setLightUp(true); // 签到失败
               } else if (signState == 1) {
                  taskClassVO.setLightUp(false);
               } else if (signState == 2) {
                  taskClassVO.setLightUp(false);
               }
            } else {
               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);
            if (totalGoldCoin != null && totalGoldCoin > 0) {
               taskClassVO.setFinishedCoin("+" + totalGoldCoin);
               if (uniqueKey != UniqueKeyEnum.dailySign)
                  countFinished = integralTaskRecordService.countFinished(uid, id, dateType);
            }
            progress = progress.replace("{已完成}", countFinished + "").replace("{总任务}", taskNum + "");
            if (signState == 0 && uniqueKey == UniqueKeyEnum.dailySign) {
               progress = "未签到";
               taskClassVO.setBtnName("签到");
            }
            taskClassVO.setProgress(progress);
         }
         data.put("count", count);
         data.put("list", gson.toJson(list));
         out.print(JsonUtil.loadTrueResult(data));
@@ -165,7 +229,12 @@
         return;
      }
      List<IntegralTaskRecord> list = integralTaskRecordService.listNotReceived(5, uid);
      int count = 5;
      if ("android".equalsIgnoreCase(acceptData.getPlatform())) {
         count = Integer.MAX_VALUE;
      }
      List<IntegralTaskRecord> list = integralTaskRecordService.listNotReceived(count, uid);
      if (list == null) {
         list = new ArrayList<IntegralTaskRecord>();
      }
@@ -188,30 +257,37 @@
    * @param out
    */
   @RequestMapping(value = "receiveGoldCoin", method = RequestMethod.POST)
   public void receiveGoldCoin(AcceptData acceptData, Long uid, String ids, String gids, PrintWriter out) {
   public void receiveGoldCoin(AcceptData acceptData, Long uid, Integer type, String ids, String gids, PrintWriter out) {
      if (uid == null || uid <= 0) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
         return;
      }
      Gson gson = new Gson();
      Set<Long> idList = gson.fromJson(ids, new TypeToken<HashSet<Long>>() {
      }.getType());
      if (idList == null || idList.size() == 0) {
         out.print(JsonUtil.loadFalseResult("领取id不能为空"));
         return;
      }
      
      Set<Long> gidList = gson.fromJson(gids, new TypeToken<HashSet<Long>>() {}.getType());
      try {
         Integer goldCoin = integralTaskRecordService.receiveGoldCoin(uid, idList);
         // 全部领取
         if (type != null && type == 1) {
            Integer goldCoin = integralTaskRecordService.receiveGoldCoinALL(uid);
            JSONObject data = new JSONObject();
            data.put("goldCoin", goldCoin);
            out.print(JsonUtil.loadTrueResult(data));
            return;
         }
         
         // 部分领取
         Gson gson = new Gson();
         Set<Long> idList = gson.fromJson(ids, new TypeToken<HashSet<Long>>() {
         }.getType());
         if (idList == null || idList.size() == 0) {
            out.print(JsonUtil.loadFalseResult("领取id不能为空"));
            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.listNotReceived(5 - gidList.size(), uid);
            list = integralTaskRecordService.listNotReceivedExcludeId(5 - gidList.size(), uid, gidList);
         } else {
            list = integralTaskRecordService.listNotReceived(5, uid);
            list = integralTaskRecordService.listNotReceivedExcludeId(5, uid, null);
         }
         
         if (list == null) {
@@ -219,7 +295,7 @@
         }
         GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();
         Gson gson2 = gsonBuilder.create();
         JSONObject data = new JSONObject();
         data.put("goldCoin", goldCoin);
         data.put("list", gson2.toJson(list));
@@ -260,14 +336,14 @@
      if (list == null)
         list = new ArrayList<IntegralExchange>();
      Long count = integralExchangeService.countValid();
      //Long count = integralExchangeService.countValid();
      GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();
      Gson gson = gsonBuilder.create();
      JSONObject data = new JSONObject();
      data.put("goldCoin", extraVO.getGoldCoin() + "枚");
      data.put("count", count);
      data.put("count", list.size());
      data.put("list", gson.toJson(list));
      out.print(JsonUtil.loadTrueResult(data));
   }
@@ -419,15 +495,15 @@
         
         case "recommendSearch":
            notify.put("name", "完成一次智能搜索");
            notify.put("score", "+20");
            notify.put("score", "+20金币");
            break;
         case "scanGoods":
            notify.put("name", "完成一次商品浏览");
            notify.put("score", "+10");
            notify.put("score", "+100金币");
            break;
         case "scanTBCart":
            notify.put("name", "完成一次购物车浏览");
            notify.put("score", "+30");
            notify.put("score", "+300金币");
            break;
         }
@@ -502,4 +578,78 @@
      return gson;
   }
   /**
    * 明细详情
    *
    * @param acceptData
    * @param uid
    * @param index
    *            List最末的主键ID
    * @param year
    *            年份
    * @param month
    *            月份
    *  @param type  统计类型  0全部  1
    * @param out
    */
   @RequestMapping(value = "getDetails")
   public void getDetails(AcceptData acceptData, Long uid, Long index, Integer year, Integer month, Integer type,
         PrintWriter out) {
      if (uid == null || uid == 0) {
         out.print(JsonUtil.loadFalseResult(1, "用户未登录"));
         return;
      }
      if ((year == null && month != null) || (year != null && month == null)) {
         out.print(JsonUtil.loadFalseResult(1, "日期不完整"));
         return;
      }
      Date date = null;
      if (year != null && month != null) {
         date = new Date(TimeUtil.convertToTimeTemp(year + "-" + month, "yyyy-M"));
         Calendar ca = Calendar.getInstance();
         ca.setTime(date);
         ca.add(Calendar.MONTH, 1);
         date = new Date(ca.getTimeInMillis() - 1);
      }
      // 查询列表
      List<IntegralDetailVO> list = integralDetailService.listDetailForClient(uid, index, date);
      // 统计总条数
      long count = integralDetailService.countDetailForClient(uid, index, date);
      GsonBuilder gsonBuilder = new GsonBuilder().excludeFieldsWithoutExposeAnnotation();
      gsonBuilder.registerTypeAdapter(TaoLiJinDetailTypeEnum.class, new TypeAdapter<TaoLiJinDetailTypeEnum>() {
         @Override
         public TaoLiJinDetailTypeEnum read(JsonReader arg0) throws IOException {
            return null;
         }
         @Override
         public void write(JsonWriter out, TaoLiJinDetailTypeEnum arg1) throws IOException {
            out.beginObject();
            out.name("portrait").value(arg1.getPicture());
            out.endObject();
         }
      }).registerTypeAdapter(Date.class, new JsonSerializer<Date>() {
         @Override
         public JsonElement serialize(Date value, Type theType, JsonSerializationContext context) {
            if (value == null) {
               return new JsonPrimitive("");
            } else {
               return new JsonPrimitive(TimeUtil.getGernalTime(value.getTime(), "yyyy.MM.dd HH:mm"));
            }
         }
      });
      Gson gson = gsonBuilder.create();
      JSONObject data = new JSONObject();
      data.put("count", count);
      data.put("data", gson.toJson(list));
      out.print(JsonUtil.loadTrueResult(data));
   }
}