From cdcbed9af813b2a02cdc01eefa24db8bec6b51a9 Mon Sep 17 00:00:00 2001 From: yujian <yujian> Date: 星期三, 27 三月 2019 12:17:33 +0800 Subject: [PATCH] 主分类 + 子分类 DAO改造 --- fanli/src/main/java/com/yeshi/fanli/controller/client/UserCouponController.java | 482 ++++++++++++++++++++++++++++++++++++++++++++++------- 1 files changed, 419 insertions(+), 63 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserCouponController.java b/fanli/src/main/java/com/yeshi/fanli/controller/client/UserCouponController.java index 96a3768..73c27c9 100644 --- a/fanli/src/main/java/com/yeshi/fanli/controller/client/UserCouponController.java +++ b/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 鍒竔d + * @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; + } + } -- Gitblit v1.8.0