yujian
2019-03-27 cdcbed9af813b2a02cdc01eefa24db8bec6b51a9
fanli/src/main/java/com/yeshi/fanli/controller/client/UserCouponController.java
@@ -2,11 +2,12 @@
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import javax.annotation.Resource;
import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
@@ -14,10 +15,21 @@
import com.yeshi.fanli.entity.accept.AcceptData;
import com.yeshi.fanli.entity.bus.homemodule.SwiperPicture;
import com.yeshi.fanli.entity.bus.user.DeviceLotteryRecord;
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
import com.yeshi.fanli.entity.system.SystemCoupon;
import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
import com.yeshi.fanli.exception.user.UserInfoExtraException;
import com.yeshi.fanli.exception.user.UserSystemCouponException;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SystemCouponService;
import com.yeshi.fanli.service.inter.homemodule.SwiperPictureService;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.order.CommonOrderCountService;
import com.yeshi.fanli.service.inter.order.CommonOrderService;
import com.yeshi.fanli.service.inter.user.DeviceLotteryRecordService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.vo.user.UserSystemCouponRecordVO;
@@ -27,12 +39,16 @@
/**
 * 福利中心
 *
 * @author Administrator
 *
 */
@Controller
@RequestMapping("api/v1/user/coupon")
public class UserCouponController {
   @Resource(name = "taskExecutor")
   private TaskExecutor executor;
   @Resource
   private ConfigService configService;
@@ -41,13 +57,33 @@
   private UserSystemCouponService UserSystemCouponService;
   @Resource
   private  SwiperPictureService swiperPictureService;
   private SwiperPictureService swiperPictureService;
   @Resource
   private CommonOrderService commonOrderService;
   @Resource
   private DeviceLotteryRecordService deviceLotteryRecordService;
   @Resource
   private SystemCouponService systemCouponService;
   @Resource
   private UserSystemCouponService userSystemCouponService;
   @Resource
   private UserInfoExtraService userInfoExtraService;
   @Resource
   private CommonOrderCountService commonOrderCountService;
   @Resource
   private ThreeSaleSerivce threeSaleSerivce;
   /**
    * 用户券列表查询
    *
    * @param acceptData
    * @param page
    * @param uid
@@ -59,31 +95,31 @@
         out.print(JsonUtil.loadFalseResult("用户未登录"));
         return;
      }
      try {
         if (page == null || page < 1) {
            page = 1;
         }
         // 福利中心图片
         String topPicture = null;
         if(page == 1) {
         String topPicture = null;
         if (page == 1) {
            List<SwiperPicture> listswiper = swiperPictureService.getByBannerCard("welfare_top");
            if (listswiper != null && listswiper.size() > 0) {
               topPicture = listswiper.get(0).getSrc();
            }
         }
         long count = 0;
         List<UserSystemCouponVO> resultList = UserSystemCouponService.getUserCouponVOList((page - 1) * Constant.PAGE_SIZE,
               Constant.PAGE_SIZE, uid );
         List<UserSystemCouponVO> resultList = UserSystemCouponService
               .getUserCouponVOList((page - 1) * Constant.PAGE_SIZE, Constant.PAGE_SIZE, uid);
         if (resultList != null && resultList.size() > 0) {
            count = UserSystemCouponService.countUserCouponList(uid);
         } else if (resultList == null) {
            resultList = new ArrayList<UserSystemCouponVO>();
         }
         JSONObject data = new JSONObject();
         data.put("topPicture", topPicture);
         data.put("count", count);
@@ -91,6 +127,26 @@
         out.print(JsonUtil.loadTrueResult(data));
         // 更新福利中心未读数量
         if (page == 1) {
            executor.execute(new Runnable() {
               @Override
               public void run() {
                  UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
                  // 未读券是否大于0
                  if (userInfoExtra != null && userInfoExtra.getCouponNews() > 0) {
                     userInfoExtra.setCouponNews(0);
                     try {
                        userInfoExtraService.saveUserInfoExtra(userInfoExtra);
                     } catch (UserInfoExtraException e) {
                        e.printStackTrace();
                     }
                  }
               }
            });
         }
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -98,40 +154,42 @@
         e.printStackTrace();
      }
   }
   /**
    * 用户奖励券
    *
    * @param acceptData
    * @param page
    * @param uid
    * @param auctionId  商品id
    * @param out
    */
   @RequestMapping(value = "getGoodsCouponList", method = RequestMethod.POST)
   public void getGoodsCouponList(AcceptData acceptData, Long uid, PrintWriter out) {
   public void getGoodsCouponList(AcceptData acceptData, Long uid, Long auctionId, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult("用户未登录"));
         return;
      }
      try {
         List<UserSystemCouponVO> resultList = UserSystemCouponService.getGoodsCouponList(uid);
         if (resultList == null ) {
            resultList =new ArrayList<UserSystemCouponVO>();
         List<UserSystemCouponVO> resultList = UserSystemCouponService.getGoodsCouponList(uid, auctionId);
         if (resultList == null) {
            resultList = new ArrayList<UserSystemCouponVO>();
         }
         JSONObject dataTip = new JSONObject();
         dataTip.put("content", configService.get("free_coupon_tip"));
         dataTip.put("fontColor", "#F14242");
         JSONObject data = new JSONObject();
         data.put("helpLink", configService.get("free_coupon_help"));
         data.put("tip", dataTip);
         data.put("count", resultList.size());
         data.put("result_list", JsonUtil.getApiCommonGson().toJson(resultList));
         out.print(JsonUtil.loadTrueResult(data));
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -139,10 +197,10 @@
         e.printStackTrace();
      }
   }
   /**
    *  免单券使用记录 以及状态修改
    * 免单券使用记录 以及状态修改
    *
    * @param acceptData
    * @param page
    * @param uid
@@ -154,7 +212,7 @@
         out.print(JsonUtil.loadFalseResult("用户未登录"));
         return;
      }
      try {
         UserSystemCouponService.useGoodsCoupon(uid, cid, goodId);
         out.print(JsonUtil.loadTrueResult("使用成功"));
@@ -165,10 +223,10 @@
         e.printStackTrace();
      }
   }
   /**
    * 用户奖励券
    *
    * @param acceptData
    * @param page
    * @param uid
@@ -176,26 +234,26 @@
    */
   @RequestMapping(value = "getOrderCouponList", method = RequestMethod.POST)
   public void getOrderCouponList(AcceptData acceptData, Long uid, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult("用户未登录"));
         return;
      }
      try {
         List<UserSystemCouponVO> resultList = UserSystemCouponService.getOrderCouponList(uid);
         if (resultList == null ) {
            resultList =new ArrayList<UserSystemCouponVO>();
         if (resultList == null) {
            resultList = new ArrayList<UserSystemCouponVO>();
         }
         JSONObject data = new JSONObject();
         data.put("helpLink", configService.get("reward_coupon_help"));
         data.put("count", resultList.size());
         data.put("result_list", JsonUtil.getApiCommonGson().toJson(resultList));
         out.print(JsonUtil.loadTrueResult(data));
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -203,10 +261,10 @@
         e.printStackTrace();
      }
   }
   /**
    *  免单券使用记录 以及状态修改
    * 免单券使用记录 以及状态修改
    *
    * @param acceptData
    * @param page
    * @param uid
@@ -214,19 +272,19 @@
    */
   @RequestMapping(value = "useRewardCoupon", method = RequestMethod.POST)
   public void useRewardCoupon(AcceptData acceptData, Long uid, Long cid, String orderNo, PrintWriter out) {
      if (uid == null) {
         out.print(JsonUtil.loadFalseResult("用户未登录"));
         return;
      }
      try {
         UserSystemCouponService.useOrderCoupon(uid, cid, orderNo);
         JSONObject data = commonOrderService.getRewardJumpInfo(orderNo);
         out.print(JsonUtil.loadTrueResult(data));
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -234,25 +292,26 @@
         e.printStackTrace();
      }
   }
   /**
    *  订单-奖励进度详情
    * 订单-奖励进度详情
    *
    * @param acceptData
    * @param orderNo 订单号
    * @param orderNo    订单号
    * @param out
    */
   @RequestMapping(value = "getRewardRecord", method = RequestMethod.POST)
   public void getRewardCounponRecord(AcceptData acceptData, String orderNo, PrintWriter out) {
      try {
         UserSystemCouponRecordVO rewardRecord = UserSystemCouponService.getRewardCouponRecord(orderNo);
         JSONObject data = new JSONObject();
         data.put("rewardRecord", rewardRecord);
         out.print(JsonUtil.loadTrueResult(data));
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -260,25 +319,26 @@
         e.printStackTrace();
      }
   }
   /**
    *  订单-奖励进度详情
    * 订单-奖励进度详情
    *
    * @param acceptData
    * @param orderNo 订单号
    * @param orderNo    订单号
    * @param out
    */
   @RequestMapping(value = "getFreeCounponRecord", method = RequestMethod.POST)
   public void getFreeCounponRecord(AcceptData acceptData, String orderNo, PrintWriter out) {
      try {
         UserSystemCouponRecordVO rewardRecord = UserSystemCouponService.getFreeCouponRecord(orderNo);
         JSONObject data = new JSONObject();
         data.put("frreCouponRecord", rewardRecord);
         out.print(JsonUtil.loadTrueResult(data));
      } catch (UserSystemCouponException e) {
         out.print(JsonUtil.loadFalseResult(e.getCode(), e.getMsg()));
      } catch (Exception e) {
@@ -286,5 +346,301 @@
         e.printStackTrace();
      }
   }
   /**
    * 获取抽奖次数
    *
    * @param callback
    * @param acceptData
    * @param uid
    * @param out
    */
   @RequestMapping(value = "getLotteryCount")
   public void getLotteryCount(String callback, AcceptData acceptData, Long uid, PrintWriter out) {
      try {
         // 默认最大抽奖次数
         int count = 5;
         if (uid == null || uid == 0) { // 未登录
            int platformType = 0;
            String platform = acceptData.getPlatform();
            if ("android".equals(platform)) {
               platformType = 1;
            } else if ("ios".equals(platform)) {
               platformType = 2;
            } else {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("平台有误"));
               return;
            }
            String device = acceptData.getDevice();
            if (device == null || device.trim().length() == 0) {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("设备不存在"));
               return;
            }
            List<DeviceLotteryRecord> list = deviceLotteryRecordService.listByPlatformAndDevice(platformType,
                  device);
            if (list != null && list.size() > 0) {
               count = count - list.size();
            }
         } else { // 已登录
            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
            if (userInfoExtra == null) {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("用户信息不存在"));
               return;
            }
            Integer lotteryNewbies = userInfoExtra.getLotteryNewbies();
            if (lotteryNewbies == null) { // 未抽过
               // 是否有过订单:返利、分享订单
               boolean hasOrder = commonOrderCountService.hasRebateAndShareOrder(uid);
               if (hasOrder) {
                  count = 0; // 不算新用户
               }
               userInfoExtra.setLotteryNewbies(count);
               userInfoExtraService.saveUserInfoExtra(userInfoExtra);
            } else {
               count = lotteryNewbies; // 剩余次数
            }
         }
         // 抽奖规则
         String lotteryRule = configService.get("lottery_rule_newbies");
         JSONObject data = new JSONObject();
         data.put("count", count);
         data.put("rule", lotteryRule);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("操作失败"));
         e.printStackTrace();
      }
   }
   /**
    * 获取抽奖结果
    *
    * @param callback
    * @param acceptData
    * @param uid
    * @param out
    */
   @RequestMapping(value = "getLotteryResult")
   public void getLotteryResult(String callback, AcceptData acceptData, Long uid, PrintWriter out) {
      try {
         // 剩余抽奖次数
         int count = 0;
         // 本次抽中的奖品
         String prize = null;
         // 已使用抽奖次数
         int countUsed = 0;
         // 已拥有奖品数量
         int countPrize = 0;
         // 已有券类型
         String couponType = null;
         if (uid == null || uid == 0) { // 未登录
            int platformType = 0;
            String platform = acceptData.getPlatform();
            if ("android".equals(platform)) {
               platformType = 1;
            } else if ("ios".equals(platform)) {
               platformType = 2;
            } else {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("平台有误"));
               return;
            }
            String device = acceptData.getDevice();
            if (device == null || device.trim().length() == 0) {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("设备不存在"));
               return;
            }
            List<DeviceLotteryRecord> list = deviceLotteryRecordService.listByPlatformAndDevice(platformType,
                  device);
            if (list != null && list.size() >= Constant.MAX_COUNT_LOTTERY_NEWBIES) { // 无抽奖机会
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "抽奖次数不足"));
               return;
            }
            Long couponId = null;
            if (list == null || list.size() == 0) { // 拥有抽奖机会
               count = Constant.MAX_COUNT_LOTTERY_NEWBIES - 1;
            } else {
               for (DeviceLotteryRecord deviceLotteryRecord : list) {
                  Long systemCouponId = deviceLotteryRecord.getSystemCouponId();
                  if (systemCouponId != null) {
                     countPrize++;
                     couponId = systemCouponId;
                  }
               }
               count = Constant.MAX_COUNT_LOTTERY_NEWBIES - 1 - list.size();
            }
            // 奖品小于2时才抽奖
            if (countPrize < 2) {
               if (couponId != null) {
                  SystemCoupon coupon = systemCouponService.selectByPrimaryKey(couponId);
                  // 已有券
                  couponType = coupon.getType().name();
               }
               // 奖品
               prize = getLotteryPrize(Constant.MAX_COUNT_LOTTERY_NEWBIES, countPrize, list.size(), couponType);
            }
            // 抽中
            Long newCouponId = null;
            if (prize != null && prize.trim().length() > 0) {
               // 已存在此券
               if (prize.equals(couponType)) {
                  prize = null;
               } else {
                  SystemCoupon coupon = systemCouponService.getCouponByType(prize);
                  if (coupon != null) {
                     newCouponId = coupon.getId();
                  }
               }
            }
            // 插入记录
            DeviceLotteryRecord record = new DeviceLotteryRecord();
            record.setDevice(device);
            record.setPlatform(platformType);
            record.setSystemCouponId(newCouponId);
            record.setCreateTime(new Date());
            deviceLotteryRecordService.insertSelective(record);
         } else { // 已登录
            UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
            if (userInfoExtra == null) {
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("信息不正确"));
               return;
            }
            // 剩余抽奖次数
            Integer lotteryNewbies = userInfoExtra.getLotteryNewbies();
            if (lotteryNewbies == null || lotteryNewbies < 1) { // 次数已用光
               JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult(2, "抽奖次数不足"));
               return;
            }
            // 剩余次数
            count = lotteryNewbies - 1;
            // 已使用次数
            countUsed = Constant.MAX_COUNT_LOTTERY_NEWBIES - lotteryNewbies;
            // 已抽中的奖品
            List<UserSystemCoupon> list = userSystemCouponService.getUserCouponBySource(uid,
                  UserSystemCoupon.SOURCE_CHOUJIANG);
            if (list == null || list.size() == 0) {
               // 抽奖
               prize = getLotteryPrize(Constant.MAX_COUNT_LOTTERY_NEWBIES, countPrize , countUsed, couponType);
            } else if (list.size() == 1) {
               UserSystemCoupon userSystemCoupon = list.get(0);
               SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
               if (systemCoupon != null) {
                  SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
                  // 已有券
                  couponType = coupon.getType().name();
               }
               // 拥有奖品数量
               countPrize = 1;
               // 抽奖
               prize = getLotteryPrize(Constant.MAX_COUNT_LOTTERY_NEWBIES, countPrize, countUsed, couponType);
            }
            // 抽中
            if (prize != null && prize.trim().length() > 0) {
               if (prize.equals(couponType)) {
                  // 已有此券
                  prize = null;
               } else {
                  // 插入券信息
                  userSystemCouponService.insertUserCoupon(uid, prize, UserSystemCoupon.SOURCE_CHOUJIANG);
               }
            }
            // 剩余次数
            userInfoExtra.setLotteryNewbies(count);
            userInfoExtraService.saveUserInfoExtra(userInfoExtra);
         }
         if (prize == null || prize.trim().length() == 0) {
            prize = "NoPrize";
         }
         JSONObject data = new JSONObject();
         data.put("count", count);
         data.put("result", prize);
         JsonUtil.printMode(out, callback, JsonUtil.loadTrueResult(data));
      } catch (Exception e) {
         JsonUtil.printMode(out, callback, JsonUtil.loadFalseResult("抽奖失败"));
         e.printStackTrace();
      }
   }
   /**
    * 奖品抽取
    *
    * @param maxCount 最大次数
    * @param hasPrize 拥有奖品数量
    * @param record   已抽次数
    * @param couponId 券id
    * @return
    */
   public String getLotteryPrize(int maxCount, int countPrize, int record, String couponType) {
      String prize = null;
      String freeCoupon = CouponTypeEnum.welfareFreeCoupon.name(); // 福利免费券
      String rebateCoupon = CouponTypeEnum.rebatePercentCoupon.name(); // 奖励券
      if (countPrize == 1 && record == maxCount - 1) {
         // 最后一次: 只收到一个奖品
         if (rebateCoupon.equals(couponType)) {
            prize = freeCoupon; // 福利免费券
         } else {
            prize = rebateCoupon;  // 奖励券
         }
      } else if (countPrize == 0 && record == maxCount - 2) {
         // 前3次没有奖励时、后面两次必中
         long result = (1 + Math.round(Math.random() * (9)));
         if (result <= 5) {
            prize = freeCoupon; // 福利免费券
         } else {
            prize = rebateCoupon; // 奖励券
         }
      } else { // 大于3次机会
         if (countPrize < 2) { // 不足两个奖品
            long result = (1 + Math.round(Math.random() * (9)));
            if (result <= 3) {
               prize = freeCoupon; // 福利免费券
            } else if (result <= 6) {
               prize = rebateCoupon; // 奖励券
            }
         }
      }
      return prize;
   }
}