From 60200c7ced052a8148b1511d8c0c2807b3ffd89f Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 27 二月 2019 17:07:03 +0800
Subject: [PATCH] 免单券相关修改
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java | 375 ++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 369 insertions(+), 6 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
index e7f8f74..8adeccd 100644
--- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
+++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserSystemCouponServiceImpl.java
@@ -1,6 +1,7 @@
package com.yeshi.fanli.service.impl.user;
import java.math.BigDecimal;
+import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
@@ -10,6 +11,7 @@
import javax.annotation.Resource;
+import org.springframework.core.task.TaskExecutor;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.yeshi.utils.DateUtil;
@@ -26,13 +28,16 @@
import com.yeshi.fanli.entity.order.CommonOrder;
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.log.LogHelper;
import com.yeshi.fanli.service.inter.common.JumpDetailV2Service;
import com.yeshi.fanli.service.inter.config.ConfigService;
import com.yeshi.fanli.service.inter.config.SystemCouponService;
import com.yeshi.fanli.service.inter.hongbao.HongBaoV2Service;
import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
import com.yeshi.fanli.service.inter.msg.UserMoneyMsgNotificationService;
+import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
import com.yeshi.fanli.service.inter.order.CommonOrderService;
import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
@@ -55,6 +60,9 @@
@Service
public class UserSystemCouponServiceImpl implements UserSystemCouponService {
+ @Resource(name = "taskExecutor")
+ private TaskExecutor executor;
+
@Resource
private UserSystemCouponMapper userSystemCouponMapper;
@@ -99,6 +107,10 @@
@Resource
private ThreeSaleSerivce threeSaleSerivce;
+
+ @Resource
+ private UserOtherMsgNotificationService userOtherMsgNotificationService;
+
// 鍒稿け鏁堝浘鐗�
public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png";
@@ -177,6 +189,41 @@
userCoupon.setUpdateTime(new Date());
// 鎻掑叆鏁版嵁搴�
insertSelective(userCoupon);
+
+ executor.execute(new Runnable() {
+ @Override
+ public void run() {
+ UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
+ // 娣诲姞涓�鏉℃秷鎭�
+ if (userInfoExtra != null) {
+ userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
+ try {
+ userInfoExtraService.saveUserInfoExtra(userInfoExtra);
+ } catch (UserInfoExtraException e) {
+ e.printStackTrace();
+ }
+ }
+
+ }
+ });
+
+ // 娑堟伅鎺ㄩ��
+ try {
+ if (coupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
+ userOtherMsgNotificationService.welfareCouponGet(userCoupon);
+ } else if (coupon.getType() != CouponTypeEnum.freeCoupon) {
+ userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
+ } else if (coupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
+ userOtherMsgNotificationService.rewardCouponGet(userCoupon);
+ }
+
+ } catch(Exception e) {
+ try {
+ LogHelper.errorDetailInfo(e);
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ }
+ }
}
@@ -188,7 +235,12 @@
if (uid == null) {
return null;
}
-
+
+ // 鏇存柊杩囨湡鍒�
+ updateCounponInvalid(uid);
+ // 閫�鍥炲埜
+ sendBackTimeOutCoupon(uid);
+
List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);
if (listVO == null || listVO.size() == 0) {
return listVO;
@@ -430,6 +482,12 @@
if (uid == null) {
throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�");
}
+
+ // 鏇存柊杩囨湡鍒�
+ updateCounponInvalid(uid);
+ // 閫�鍥炲埜
+ sendBackTimeOutCoupon(uid);
+
// 璁㈠崟鐩稿叧鐨勫埜
List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
if (couponList == null || couponList.size() == 0) {
@@ -444,6 +502,12 @@
if (uid == null) {
throw new UserSystemCouponException(1, "鐢ㄦ埛鏈櫥褰�");
}
+
+ // 鏇存柊杩囨湡鍒�
+ updateCounponInvalid(uid);
+ // 閫�鍥炲埜
+ sendBackTimeOutCoupon(uid);
+
// 鍟嗗搧鐩稿叧鐨勫埜
List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
if (couponList == null || couponList.size() == 0) {
@@ -502,6 +566,19 @@
couponRecord.setCreateTime(date);
couponRecord.setUpdateTime(date);
userSystemCouponRecordService.insertSelective(couponRecord);
+
+ // 娑堟伅鎺ㄩ��
+ try {
+ if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
+ userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon);
+ } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
+ userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon);
+ }
+
+ } catch(Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
+
}
@Transactional
@@ -607,6 +684,13 @@
couponRecord.setCreateTime(date);
couponRecord.setUpdateTime(date);
userSystemCouponRecordService.insertSelective(couponRecord);
+
+ // 娑堟伅鎺ㄩ��
+ try {
+ userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);
+ } catch(Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
}
}
@@ -655,17 +739,20 @@
}
// 鑾峰彇濂栧姳閲戦
- Map<String, BigDecimal> map = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);
-
+ BigDecimal couponMoney = orderHongBaoMapService.getCouponHongbaoByOrderNo(orderNo, uid);
+
UserSystemCouponRecordVO userRecordVO = new UserSystemCouponRecordVO();
userRecordVO.setCouponMoneyState("宸插埌璐�");
userRecordVO.setCommonOrder(commonOrderVO);
- userRecordVO.setCouponName("濂栧姳閲�: 楼" + map.get("couponMoney").setScale(2, BigDecimal.ROUND_DOWN));
+ userRecordVO.setCouponName("濂栧姳閲�: 楼" + couponMoney.setScale(2, BigDecimal.ROUND_DOWN));
// 姣斾緥
BigDecimal percent = baseCoupon.getPercent();
- BigDecimal hongBao = map.get("totalMoney").setScale(2, BigDecimal.ROUND_DOWN);
- userRecordVO.setCouponEffect("杩斿埄楼" + hongBao + "宸茶繑" + percent + "%");
+ BigDecimal hongBao = commonOrderVO.getHongBao();
+ if (hongBao == null) {
+ hongBao = new BigDecimal(0);
+ }
+ userRecordVO.setCouponEffect("杩斿埄楼" + hongBao.setScale(2, BigDecimal.ROUND_DOWN) + "宸茶繑" + percent + "%");
// 璺宠浆绂忓埄涓績
JumpDetailV2 welfareCore = jumpDetailV2Service.getByTypeCache("welfareCore");
@@ -886,7 +973,283 @@
return userRecordVO;
}
+
+
+ @Override
+ public void activatedWelfareFreeCoupon(Long uid) {
+ if (uid == null) {
+ return;
+ }
+ // 绂忓埄鍏嶅崟鍒�
+ String welfareFree = CouponTypeEnum.welfareFreeCoupon.name();
+
+ SystemCoupon systemCoupon = systemCouponService.getCouponByType(welfareFree);
+ if (systemCoupon == null) {
+ return;
+ }
+
+ // 寰呮椿绂忓埄鍏嶅崟鍒�
+ List<UserSystemCoupon> list = userSystemCouponMapper.getCouponByTypeAndNotActivated(uid, systemCoupon.getId());
+ if (list == null || list.size() == 0) {
+ return;
+ }
+
+ for (UserSystemCoupon userSystemCoupon: list) {
+ // 婵�娲�
+ userSystemCoupon.setStateActivated(1);
+ userSystemCoupon.setUpdateTime(new Date());
+ userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
+
+ // 娑堟伅鎺ㄩ��
+ try {
+ userOtherMsgNotificationService.welfareCouponGet(userSystemCoupon);
+ } catch(Exception e) {
+ try {
+ LogHelper.errorDetailInfo(e);
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+ }
+
+ @Override
+ public void updateStateByDrawback(String orderNo) throws Exception {
+
+ if (orderNo == null || orderNo.trim().length() == 0) {
+ return;
+ }
+ UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, null);
+ if (record == null) {
+ return;
+ }
+
+ record.setOrderNo(orderNo);
+ record.setUpdateTime(new Date());
+ record.setState(UserSystemCouponRecord.STATE_FAIL_DRAWBACK);
+ userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+ // 鍒搁��鍥�
+ sendBackCoupon(record.getUserSystemCoupon());
+ }
+
+ @Override
+ public void updateStateByArrivalAccount(String orderNo) throws Exception {
+
+ if (orderNo == null || orderNo.trim().length() == 0) {
+ return;
+ }
+
+ UserSystemCouponRecord record = userSystemCouponRecordService.getRecordByOrderNo(orderNo, 2);
+ if (record == null) {
+ return;
+ }
+
+ record.setOrderNo(orderNo);
+ record.setUpdateTime(new Date());
+ record.setState(UserSystemCouponRecord.STATE_SUCCESS);
+ userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+ }
+
+ @Override
+ public void updateCounponInvalid(Long uid) {
+ List<UserSystemCoupon> list = userSystemCouponMapper.getCounponNowInvalid(uid);
+ if (list == null || list.size() == 0) {
+ return;
+ }
+
+ for (UserSystemCoupon userSystemCoupon: list) {
+ // 鏇存柊鍒稿凡杩囨湡
+ userSystemCoupon.setState(UserSystemCoupon.STATE_OVERDUE);
+ userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
+
+ SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+ if (systemCoupon == null) {
+ continue;
+ }
+
+ SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+ if (baseCoupon == null || baseCoupon.getId() == null) {
+ continue;
+ }
+
+ // 娑堟伅鎺ㄩ��
+ try {
+ if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
+ userOtherMsgNotificationService.welfareCouponAlreadyOutOfDate(userSystemCoupon);
+ } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
+ userOtherMsgNotificationService.freeSheetCouponAlreadyOutOfDate(userSystemCoupon);
+ } else if (baseCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
+ userOtherMsgNotificationService.rewardCouponAlreadyOutOfDate(userSystemCoupon);
+ }
+
+ } catch(Exception e) {
+ try {
+ LogHelper.errorDetailInfo(e);
+ } catch (Exception e1) {
+ e1.printStackTrace();
+ }
+ }
+ }
+ }
+
+ @Override
+ public void sendBackTimeOutCoupon(Long uid) {
+ // 瓒呰繃120绉� 鏈鍖归厤鐨勫埜
+ List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120L);
+ if (list == null || list.size() == 0) {
+ return;
+ }
+
+ for (UserSystemCouponRecord couponRecord: list) {
+ // 鏇存柊鐘舵�侊細鍖归厤瓒呮椂
+ couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
+ couponRecord.setUpdateTime(new Date());
+ userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);
+
+ UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();
+
+ int expiryDay = 15;
+
+ SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+ SystemCoupon coupon= systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+ if (coupon != null) {
+ expiryDay = coupon.getExpiryDay();
+ }
+
+ // 缁撴潫鏃ユ湡
+ Date endTime = null;
+ try {
+ String endDay = DateUtil.plusDay(expiryDay, new Date());
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+ endTime = format.parse(endDay);
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ // 鐘舵�佸垵濮嬪寲
+ userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+ userSystemCoupon.setUseTime(null);
+
+ // 鏈夋晥鏈熸椂闂撮噸鏂板畾涔�
+ userSystemCoupon.setStartTime(new Date());
+ userSystemCoupon.setEndTime(endTime);
+ userSystemCoupon.setUpdateTime(new Date());
+ userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
+ }
+ }
+
+ @Override
+ public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment,
+ Long auctionId) throws Exception{
+
+ boolean isfree = false;
+
+ if (uid == null || payment == null || auctionId == null || orderNo == null ||
+ orderNo.trim().length() == 0 ) {
+ throw new Exception("浼犻�掑弬鏁颁笉鑳戒负绌�");
+ }
+
+ // 鏌ヨ绛夊緟鍖归厤鐨勫埜璁板綍
+ List<UserSystemCouponRecord> list = userSystemCouponRecordService.getRecordByState(uid, UserSystemCouponRecord.STATE_WAIT);
+ if (list == null || list.size() == 0) {
+ return isfree;
+ }
+
+ // 鍖归厤
+ boolean matching = false;
+ UserSystemCouponRecord record = null;
+
+ for (UserSystemCouponRecord userSystemCouponRecord : list) {
+ Long goodId = userSystemCouponRecord.getGoodId();
+ if (auctionId.equals(goodId)) {
+ matching = true; // 鍖归厤鎴愬姛
+ record = userSystemCouponRecord;
+ break;
+ }
+ }
+
+ // 鍟嗗搧鍖归厤鎴愬姛
+ if (matching) {
+
+ record.setOrderNo(orderNo);
+ record.setUpdateTime(new Date());
+
+ UserSystemCoupon userSystemCoupon = record.getUserSystemCoupon();
+
+ if (payment.compareTo(new BigDecimal(10)) > 0) {
+ // 鏇存柊璁板綍 -- 閲戦涓嶅尮閰� 澶�10鍏�
+ record.setState(UserSystemCouponRecord.STATE_FAIL_RULE);
+ userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+ // 閫�鍥炲埜
+ sendBackCoupon(userSystemCoupon);
+
+ } else {
+ // 鍏嶅崟鍖归厤鎴愬姛
+ isfree = true;
+
+ //鏇存柊璁板綍--鍏嶅崟涓�
+ record.setState(UserSystemCouponRecord.STATE_FREE_ON);
+ userSystemCouponRecordService.updateByPrimaryKeySelective(record);
+
+ // 鍒哥粨鏉熶娇鐢�
+ userSystemCoupon.setState(UserSystemCoupon.STATE_END_USE);
+ userSystemCoupon.setUpdateTime(new Date());
+ userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);
+
+ SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+
+ SystemCoupon baseCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+ if (baseCoupon == null) {
+ // 鍒稿凡浣跨敤
+ userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon);
+ } else if (baseCoupon.getType() != CouponTypeEnum.welfareFreeCoupon) {
+ userOtherMsgNotificationService.welfareCouponUsed(userSystemCoupon);
+ } else if (baseCoupon.getType() != CouponTypeEnum.freeCoupon) {
+ userOtherMsgNotificationService.freeSheetCouponUsed(userSystemCoupon);
+ }
+ }
+ }
+
+ return isfree;
+ }
+
+ /**
+ * 閫�鍥炲埜 鍒濆鏁版嵁
+ * @param userSystemCoupon
+ */
+ public void sendBackCoupon(UserSystemCoupon userSystemCoupon) throws Exception{
+
+ int expiryDay = 15;
+
+ SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
+ SystemCoupon coupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
+ if (coupon != null) {
+ expiryDay = coupon.getExpiryDay();
+ }
+
+ // 缁撴潫鏃ユ湡
+ Date endTime = null;
+ try {
+ String endDay = DateUtil.plusDay(expiryDay, new Date());
+ SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
+ endTime = format.parse(endDay);
+ } catch (ParseException e) {
+ e.printStackTrace();
+ }
+ // 鐘舵�佸垵濮嬪寲
+ userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
+ userSystemCoupon.setUseTime(null);
+ // 鏈夋晥鏈熸椂闂撮噸鏂板畾涔�
+ userSystemCoupon.setStartTime(new Date());
+ userSystemCoupon.setEndTime(endTime);
+
+ userSystemCoupon.setUpdateTime(new Date());
+
+ userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
+ }
+
}
--
Gitblit v1.8.0