fanli-server.git

			@@ -10,16 +10,26 @@

			import javax.annotation.Resource;

			import org.springframework.context.annotation.Lazy;
			import org.springframework.core.task.TaskExecutor;
			import org.springframework.jdbc.datasource.DataSourceTransactionManager;
			import org.springframework.scheduling.annotation.Async;
			import org.springframework.stereotype.Service;
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.transaction.support.DefaultTransactionDefinition;
			import org.yeshi.utils.DateUtil;
			import org.yeshi.utils.entity.DateInfo;

			import com.aliyun.openservices.ons.api.Message;
			import com.aliyun.openservices.ons.api.Producer;
			import com.aliyun.openservices.ons.api.SendResult;
			import com.aliyun.openservices.ons.api.transaction.LocalTransactionExecuter;
			import com.aliyun.openservices.ons.api.transaction.TransactionProducer;
			import com.aliyun.openservices.ons.api.transaction.TransactionStatus;
			import com.yeshi.fanli.dao.mybatis.user.UserSystemCouponMapper;
			import com.yeshi.fanli.dto.msg.MsgOtherCouponActivateDTO;
			import com.yeshi.fanli.dto.msg.MsgOtherGiveContentDTO;
			import com.yeshi.fanli.entity.bus.msg.MsgOtherDetail.MsgTypeOtherTypeEnum;
			import com.yeshi.fanli.entity.bus.user.DeviceLotteryRecord;
			import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
			import com.yeshi.fanli.dto.mq.user.body.UserSystemCouponUseMQMsg;
			import com.yeshi.fanli.entity.accept.AcceptData;
			import com.yeshi.fanli.entity.bus.user.HongBaoV2;
			import com.yeshi.fanli.entity.bus.user.Order;
			import com.yeshi.fanli.entity.bus.user.TokenRecord;
			@@ -27,45 +37,53 @@
			import com.yeshi.fanli.entity.bus.user.UserInfo;
			import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
			import com.yeshi.fanli.entity.bus.user.UserSystemCoupon;
			import com.yeshi.fanli.entity.bus.user.UserSystemCouponActivate;
			import com.yeshi.fanli.entity.bus.user.UserSystemCouponGiveRecord;
			import com.yeshi.fanli.entity.bus.user.UserSystemCouponRecord;
			import com.yeshi.fanli.entity.common.JumpDetailV2;
			import com.yeshi.fanli.entity.money.UserMoneyDetail;
			import com.yeshi.fanli.entity.order.CommonOrder;
			import com.yeshi.fanli.entity.order.HongBaoOrder;
			import com.yeshi.fanli.entity.system.ConfigKeyEnum;
			import com.yeshi.fanli.entity.system.SystemCoupon;
			import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
			import com.yeshi.fanli.entity.taobao.TaoBaoGoodsBrief;
			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.money.UserMoneyDetailService;
			import com.yeshi.fanli.service.inter.money.msg.UserMoneyMsgNotificationService;
			import com.yeshi.fanli.service.inter.msg.UserOtherMsgNotificationService;
			import com.yeshi.fanli.service.inter.order.CommonOrderCountService;
			import com.yeshi.fanli.service.inter.order.CommonOrderService;
			import com.yeshi.fanli.service.inter.order.HongBaoOrderService;
			import com.yeshi.fanli.service.inter.order.HongBaoV2Service;
			import com.yeshi.fanli.service.inter.order.OrderHongBaoMapService;
			import com.yeshi.fanli.service.inter.order.OrderService;
			import com.yeshi.fanli.service.inter.push.PushCouponRecordService;
			import com.yeshi.fanli.service.inter.push.PushCouponService;
			import com.yeshi.fanli.service.inter.user.DeviceLotteryRecordService;
			import com.yeshi.fanli.service.inter.user.TokenRecordService;
			import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
			import com.yeshi.fanli.service.inter.user.UserInfoService;
			import com.yeshi.fanli.service.inter.user.UserMoneyDetailService;
			import com.yeshi.fanli.service.inter.user.UserSystemCouponActivateService;
			import com.yeshi.fanli.service.inter.user.UserSystemCouponGiveRecordService;
			import com.yeshi.fanli.service.inter.user.UserSystemCouponRecordService;
			import com.yeshi.fanli.service.inter.user.UserSystemCouponService;
			import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
			import com.yeshi.fanli.service.inter.user.invite.UserInviteService;
			import com.yeshi.fanli.util.Constant;
			import com.yeshi.fanli.util.MoneyBigDecimalUtil;
			import com.yeshi.fanli.util.RedisManager;
			import com.yeshi.fanli.util.StringUtil;
			import com.yeshi.fanli.util.TimeUtil;
			import com.yeshi.fanli.util.TokenUtil;
			import com.yeshi.fanli.util.VersionUtil;
			import com.yeshi.fanli.util.annotation.RequestSerializableByKeyService;
			import com.yeshi.fanli.util.factory.UserMoneyDetailFactory;
			import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
			import com.yeshi.fanli.util.rocketmq.MQTopicName;
			import com.yeshi.fanli.util.taobao.TaoBaoUtil;
			import com.yeshi.fanli.vo.msg.ClientTextStyleVO;
			import com.yeshi.fanli.vo.order.CommonOrderVO;
			@@ -88,7 +106,7 @@

			@Resource
			private UserSystemCouponGiveRecordService userSystemCouponGiveRecordService;


			@Resource
			private ConfigService configService;

			@@ -98,6 +116,7 @@
			@Resource
			private SystemCouponService systemCouponService;

			@Lazy
			@Resource
			private CommonOrderService commonOrderService;

			@@ -105,6 +124,7 @@
			private UserSystemCouponRecordService userSystemCouponRecordService;

			@Resource
			@Lazy
			private HongBaoV2Service hongBaoV2Service;

			@Resource
			@@ -134,22 +154,35 @@
			@Resource
			private UserOtherMsgNotificationService userOtherMsgNotificationService;

			@Resource
			private DeviceLotteryRecordService deviceLotteryRecordService;

			@Lazy
			@Resource
			private CommonOrderCountService commonOrderCountService;


			@Resource
			@Lazy
			private PushCouponService pushCouponService;


			@Resource
			private PushCouponRecordService pushCouponRecordService;


			@Resource
			private TokenRecordService tokenRecordService;



			@Resource(name = "transactionManager")
			private DataSourceTransactionManager transactionManager;

			@Resource(name = "orderTransactionProducer")
			private TransactionProducer orderTransactionProducer;

			@Resource
			private UserSystemCouponActivateService userSystemCouponActivateService;

			@Resource(name = "producer")
			private Producer producer;

			@Resource
			private UserInviteService userInviteService;

			@Override
			public int insertSelective(UserSystemCoupon record) {
			return userSystemCouponMapper.insertSelective(record);
			@@ -179,132 +212,183 @@
			public List<UserSystemCoupon> getUserCouponBySource(Long uid, String source) {
			return userSystemCouponMapper.getUserCouponBySource(uid, source);
			}


			@Override
			public int countTodatyUserCouponBySource(Long uid, String source) {
			return userSystemCouponMapper.countTodatyUserCouponBySource(uid, source);
			}


			@Override
			public long countCouponOld(Long uid) {
			return userSystemCouponMapper.countCouponOld(uid);
			}


			@Override
			public long countUserCouponList(Long uid) {
			return userSystemCouponMapper.countUserCouponList(uid);
			}

			@Override
			@Transactional
			public UserSystemCoupon insertUserCoupon(Long uid, String couponType, String source, BigDecimal percent)
			@Transactional(rollbackFor = Exception.class)
			public UserSystemCoupon freeCouponWin(Long uid, CouponTypeEnum typeEnum, String source, int num, boolean notify)
			throws UserSystemCouponException, Exception {

			if (couponType == null \|\| uid == null) {
			if (typeEnum == null \|\| uid == null \|\| StringUtil.isNullOrEmpty(source) \|\| num < 1) {
			throw new UserSystemCouponException(1, "参数不正确");
			}

			SystemCoupon coupon = null;
			if (couponType.equals(CouponTypeEnum.welfareFreeCoupon.name()) \|\| couponType.equals(CouponTypeEnum.freeCoupon.name())
			\| couponType.equals(CouponTypeEnum.freeCouponBuy.name())) {
			// 免单券
			coupon = systemCouponService.getCouponByType(couponType);
			} else if (couponType.equals(CouponTypeEnum.rebatePercentCoupon.name())) {
			// 随机奖励券
			if (percent == null \|\| percent.compareTo(new BigDecimal(0)) < 1) {
			randomRewardCoupon(1, uid, source);
			return null;
			} else {
			coupon = systemCouponService.getCouponByTypeAndPercent(couponType, percent);
			}
			}

			SystemCoupon coupon = systemCouponService.getCouponByType(typeEnum.name());
			if (coupon == null) {
			throw new UserSystemCouponException(1, "券类型不正确");
			}

			int stateActivated = 1;
			if (coupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
			// 福利券状态
			long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);
			// 没有下级队员 --待激活
			if (countSuccess == 0) {
			stateActivated = 0;
			}
			} else if (coupon.getType() == CouponTypeEnum.freeCoupon) {
			stateActivated = 0;
			// 激活状态
			int stateActivated = 0;
			// 自购免单券、赠送免单券可直接使用
			if (coupon.getType() == CouponTypeEnum.freeCouponBuy \|\| coupon.getType() == CouponTypeEnum.freeCouponGive) {
			stateActivated = 1;
			}

			// 有效时长
			Integer expiryDay = null;
			if (stateActivated == 0)
			if (stateActivated == 0)
			expiryDay = coupon.getActivateDay();

			if (expiryDay == null \|\| expiryDay == 0)
			if (expiryDay == null \|\| expiryDay == 0)
			expiryDay = coupon.getExpiryDay();

			// 结束日期
			// 今天在内减去一天
			String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");

			// 计算结束日期
			Date nowTime = new Date();
			String endDay = DateUtil.plusDay(expiryDay - 1, nowTime);
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			if (endDay != null && endDay.trim().length() > 0) {
			endDay += " 23:59:59";
			}
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setUid(uid);
			userCoupon.setSource(source);
			userCoupon.setSystemCoupon(coupon);
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userCoupon.setStateActivated(stateActivated);
			userCoupon.setStartTime(new Date());
			userCoupon.setEndTime(endTime);
			userCoupon.setCreateTime(new Date());
			userCoupon.setUpdateTime(new Date());
			// 插入数据库
			insertSelective(userCoupon);
			UserSystemCoupon userSystemCoupon = null;
			for (int i = 0; i < num; i++) {
			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setUid(uid);
			userCoupon.setSource(source);
			userCoupon.setSystemCoupon(coupon);
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userCoupon.setStateActivated(stateActivated);
			userCoupon.setStartTime(nowTime);
			userCoupon.setEndTime(endTime);
			userCoupon.setCreateTime(nowTime);
			userCoupon.setUpdateTime(nowTime);
			userSystemCouponMapper.insertSelective(userCoupon);
			// 需要激活券
			if (typeEnum == CouponTypeEnum.freeCoupon) {
			userSystemCouponActivateService.addActivateRecord(userCoupon.getId());
			}

			if (num == 1) {
			userSystemCoupon = userCoupon;
			}
			}

			executor.execute(new Runnable() {
			@Override
			public void run() {
			UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
			// 添加一条消息
			if (userInfoExtra != null) {
			if (userInfoExtra.getCouponNews() == null) {
			userInfoExtra.setCouponNews(1);
			} else {
			userInfoExtra.setCouponNews(userInfoExtra.getCouponNews() + 1);
			}

			if (notify) { // 消息推送
			try {
			userInfoExtraService.saveUserInfoExtra(userInfoExtra);
			} catch (UserInfoExtraException e) {
			userOtherMsgNotificationService.freeCouponWinMsg(uid, typeEnum.getDesc(), source, num, "成功获得",
			nowTime, endTime);
			} catch (Exception e) {
			e.printStackTrace();
			}
			}

			// 福利中心红点
			UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);
			if (extra != null) {
			UserInfoExtra updateExtra = new UserInfoExtra();
			updateExtra.setId(extra.getId());
			if (extra.getCouponNews() == null) {
			updateExtra.setCouponNews(1);
			} else {
			updateExtra.setCouponNews(extra.getCouponNews() + 1);
			}
			userInfoExtraService.updateByPrimaryKeySelective(updateExtra);
			}
			}
			});

			// 消息推送
			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, coupon.getPercent().intValue());
			}

			} catch (Exception e) {
			try {
			LogHelper.errorDetailInfo(e);
			} catch (Exception e1) {
			e1.printStackTrace();
			}
			}

			return userCoupon;
			return userSystemCoupon;
			}

			@Transactional
			@Override
			@Transactional(rollbackFor = Exception.class)
			public UserSystemCoupon rewardCouponWin(Long uid, String source, int num, boolean notify, BigDecimal percent)
			throws UserSystemCouponException, Exception {
			if (uid == null \|\| percent == null \|\| StringUtil.isNullOrEmpty(source) \|\| num < 1) {
			throw new UserSystemCouponException(1, "参数不正确");
			}

			String name = CouponTypeEnum.rebatePercentCoupon.name();
			SystemCoupon coupon = systemCouponService.getCouponByTypeAndPercent(name, percent);
			if (coupon == null) {
			throw new UserSystemCouponException(1, "券类型不正确");
			}

			// 计算结束日期
			Date nowTime = new Date();
			Integer expiryDay = coupon.getExpiryDay();
			String endDay = DateUtil.plusDay(expiryDay - 1, nowTime);
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			if (endDay != null && endDay.trim().length() > 0) {
			endDay += " 23:59:59";
			}
			Date endTime = format.parse(endDay);

			UserSystemCoupon userSystemCoupon = null;
			for (int i = 0; i < num; i++) {
			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setUid(uid);
			userCoupon.setSource(source);
			userCoupon.setSystemCoupon(coupon);
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userCoupon.setStateActivated(1);
			userCoupon.setStartTime(nowTime);
			userCoupon.setEndTime(endTime);
			userCoupon.setCreateTime(nowTime);
			userCoupon.setUpdateTime(nowTime);
			userSystemCouponMapper.insertSelective(userCoupon);
			if (num == 1) {
			userSystemCoupon = userCoupon;
			}
			}

			executor.execute(new Runnable() {
			@Override
			public void run() {
			if (notify) { // 消息推送
			try {
			userOtherMsgNotificationService.rewardCouponWinMsg(uid, source, num, "成功获得", nowTime, endTime);
			} catch (Exception e) {
			e.printStackTrace();
			}
			}

			// 福利中心红点
			UserInfoExtra extra = userInfoExtraService.getUserInfoExtra(uid);
			if (extra != null) {
			UserInfoExtra updateExtra = new UserInfoExtra();
			updateExtra.setId(extra.getId());
			if (extra.getCouponNews() == null) {
			updateExtra.setCouponNews(1);
			} else {
			updateExtra.setCouponNews(extra.getCouponNews() + 1);
			}
			userInfoExtraService.updateByPrimaryKeySelective(updateExtra);
			}
			}
			});

			return userSystemCoupon;
			}

			@Transactional(rollbackFor = Exception.class)
			@Override
			public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid, boolean changeJump)
			throws UserSystemCouponException, Exception {
			@@ -315,10 +399,10 @@

			// 过期券
			updateInvalidSate(uid);


			// 退回券
			sendBackTimeOutCoupon(uid);


			List<UserSystemCouponVO> listVO = userSystemCouponMapper.getCouponListOld(start, count, uid);
			if (listVO == null \|\| listVO.size() == 0) {
			return listVO;
			@@ -342,7 +426,7 @@
			if (userInfoExtra != null) {
			inviteCode = userInfoExtra.getInviteCode();
			}


			for (UserSystemCouponVO userCouponVO : listVO) {

			SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
			@@ -384,7 +468,7 @@
			}

			jumpBtn = new HashMap<String, Object>();


			// 福利券需要激活界面
			if (!changeJump) {
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
			@@ -397,7 +481,7 @@
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
			}
			}


			} else if (stateActivated == 1) {
			// 显示规则
			userCouponVO.setCouponRule(systemCoupon.getRule());
			@@ -409,7 +493,7 @@
			// 免单券、福利免单券

			// 免单商品列表
			jumpLink.put("url", configService.get("free_goods_list"));
			jumpLink.put("url", configService.get(ConfigKeyEnum.freeGoodsList.getKey()));

			jumpBtn = new HashMap<String, Object>();
			jumpBtn.put("params", jumpLink);
			@@ -427,7 +511,7 @@

			} else if (UserSystemCoupon.STATE_IN_USE == state) {
			// 使用中
			userCouponVO.setInUseExplain(configService.get("free_coupon_using-help"));
			userCouponVO.setInUseExplain(configService.get(ConfigKeyEnum.freeCouponUsingHelp.getKey()));
			}
			}

			@@ -498,7 +582,7 @@
			if (source != null && "奖励券天天抽".equals(source)) {
			source = "天天抽";
			}


			userCouponVO.setSource("来源：" + source);
			userCouponVO.setCouponName(systemCoupon.getName());
			userCouponVO.setCouponEffect(systemCoupon.getEffect());
			@@ -546,7 +630,6 @@
			return listVO;
			}


			/**
			* 是否存在奖励券
			*
			@@ -571,17 +654,17 @@
			return hasCoupon;
			}

			@Transactional
			@Transactional(rollbackFor = Exception.class)
			@Override
			public List<UserSystemCouponVO> getOrderCouponList(Long uid) throws UserSystemCouponException, Exception {


			if (uid == null) {
			throw new UserSystemCouponException(1, "用户未登录");
			}

			// 过期券
			updateInvalidSate(uid);


			// 退回券
			sendBackTimeOutCoupon(uid);

			@@ -594,7 +677,7 @@
			return getEnableListByCouponId(uid, 1, couponList);
			}

			@Transactional
			@Transactional(rollbackFor = Exception.class)
			@Override
			public List<UserSystemCouponVO> getGoodsCouponList(Long uid, Long auctionId)
			throws UserSystemCouponException, Exception {
			@@ -609,10 +692,10 @@

			// 过期券
			updateInvalidSate(uid);


			// 退回券
			sendBackTimeOutCoupon(uid);


			// 商品相关的券
			List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
			if (couponList == null \|\| couponList.size() == 0) {
			@@ -620,7 +703,7 @@
			}

			List<UserSystemCouponVO> list = getEnableListByCouponId(uid, null, couponList);


			// 获取商品详情
			TaoBaoGoodsBrief taoBaoGoodsBrief = redisManager.getTaoBaoGoodsBrief(auctionId);
			if (taoBaoGoodsBrief != null) {
			@@ -646,9 +729,61 @@
			return list;
			}

			@Transactional
			@Override
			public void useGoodsCoupon(Long uid, Long id, Long goodId, Integer sourceType) throws UserSystemCouponException, Exception {
			public long countUsableFreeCouponForBuy(Long uid) {
			if (uid == null)
			return 0;

			List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
			if (couponList == null \|\| couponList.size() == 0)
			return 0;

			List<Long> listCouponId = new ArrayList<Long>();
			for (SystemCoupon systemCoupon : couponList) {
			listCouponId.add(systemCoupon.getId());
			}

			return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
			}

			@Override
			public long countGiveFreeCoupon(Long uid) {
			if (uid == null)
			return 0;

			List<SystemCoupon> couponList = systemCouponService.getGiveFreeCouponList();
			if (couponList == null \|\| couponList.size() == 0)
			return 0;

			List<Long> listCouponId = new ArrayList<Long>();
			for (SystemCoupon systemCoupon : couponList) {
			listCouponId.add(systemCoupon.getId());
			}

			return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
			}

			@Override
			public long countUsableRewardCoupon(Long uid) {
			if (uid == null)
			return 0;

			List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
			if (couponList == null \|\| couponList.size() == 0)
			return 0;

			List<Long> listCouponId = new ArrayList<Long>();
			for (SystemCoupon systemCoupon : couponList) {
			listCouponId.add(systemCoupon.getId());
			}

			return userSystemCouponMapper.countUsableByUid(uid, listCouponId);
			}

			@Transactional(rollbackFor = Exception.class)
			@Override
			public void useGoodsCoupon(Long uid, Long id, Long goodId, Integer sourceType)
			throws UserSystemCouponException, Exception {
			if (uid == null) {
			throw new UserSystemCouponException(1, "用户未登录");
			}
			@@ -661,7 +796,7 @@
			if (userSystemCoupon == null) {
			throw new UserSystemCouponException(1, "券数据不正确");
			}


			if (userSystemCoupon.getUid().longValue() != uid) {
			throw new UserSystemCouponException(1, "不属于该用户的券");
			}
			@@ -722,58 +857,102 @@

			}

			@Transactional
			@Transactional(rollbackFor = Exception.class)
			@Override
			public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType) throws UserSystemCouponException, Exception {

			if (id == null) {
			public void useOrderCoupon(Long uid, Long id, String orderNo, Integer sourceType, AcceptData acceptData)
			throws UserSystemCouponException, Exception {
			if (id == null)
			throw new UserSystemCouponException(1, "券id不存在");
			}

			if (sourceType == null) {

			if (sourceType == null)
			sourceType = Constant.SOURCE_TYPE_TAOBAO;
			}


			// 用户券
			UserSystemCoupon userSystemCoupon = selectByPrimaryKey(id);
			if (userSystemCoupon == null) {
			if (userSystemCoupon == null)
			throw new UserSystemCouponException(1, "券信息不存在");
			}

			if (userSystemCoupon.getUid().longValue() != uid) {
			if (userSystemCoupon.getUid().longValue() != uid)
			throw new UserSystemCouponException(1, "不属于该用户的券");
			}

			Integer state = userSystemCoupon.getState();
			Integer stateActivated = userSystemCoupon.getStateActivated();
			if (UserSystemCoupon.STATE_CAN_USE != state \|\| 1 != stateActivated) {
			if (UserSystemCoupon.STATE_CAN_USE != state \|\| 1 != stateActivated)
			throw new UserSystemCouponException(1, "该券不能被使用");
			}

			// 系统券信息
			SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
			if (systemCoupon != null && systemCoupon.getId() != null) {
			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
			if (systemCoupon == null) {
			if (systemCoupon == null)
			throw new UserSystemCouponException(1, "券已不存在");
			}

			if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon)
			throw new UserSystemCouponException(1, "券类型不匹配");

			if (orderNo == null \|\| orderNo.trim().length() == 0)
			throw new UserSystemCouponException(1, "订单号不存在");

			// 检查订单号是否维权
			List<CommonOrder> commonOrderList = commonOrderService.listBySourceTypeAndOrderId(sourceType, orderNo);
			boolean weiquan = false;
			if (commonOrderList != null) {
			for (CommonOrder commonOrder : commonOrderList) {
			if (commonOrder.getState() == CommonOrder.STATE_WQ) {
			weiquan = true;
			break;
			}
			}
			}

			if (systemCoupon.getType() != CouponTypeEnum.rebatePercentCoupon) {
			throw new UserSystemCouponException(1, "券类型不匹配");
			}

			if (orderNo == null \|\| orderNo.trim().length() == 0) {
			throw new UserSystemCouponException(1, "订单号不存在");
			if (weiquan) {
			throw new UserSystemCouponException(1, "亲，很遗憾，售后维权订单不能使用返利奖励券~");
			}

			// 订单
			CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(uid, orderNo, CommonOrder.STATE_JS, sourceType);
			if (orderVO == null) {
			throw new UserSystemCouponException(1, "订单信息获取失败");
			List<CommonOrderVO> listVo = commonOrderService.listGroupOrderNoByUid(0, 1, uid, 2, 1, 1, orderNo, null, null,
			null, sourceType);
			if (listVo == null \|\| listVo.size() == 0)
			throw new UserSystemCouponException(1, "亲，很遗憾，该订单已不能使用返利奖励券~");

			CommonOrderVO orderVO = listVo.get(0);

			// 2.1新版
			Date thirdCreateTime = orderVO.getThirdCreateTime();
			Date accountTime = orderVO.getAccountTime();
			if (thirdCreateTime == null \|\| accountTime == null)
			throw new UserSystemCouponException(1, "该订单不能使用奖励券");

			long downOrderTime = thirdCreateTime.getTime();
			long limitDate = TimeUtil.convertDateToTemp(Constant.VIP_ONLINE_TIME);
			if (downOrderTime > limitDate) {
			boolean valid = false;
			Date endDay = DateUtil.plusDayDate(Constant.COUPON_REWARD_LIMIT_DAY, accountTime);
			long currentTime = java.lang.System.currentTimeMillis();
			if (endDay.getTime() > currentTime) {
			DateInfo dateInfo = DateUtil.dateDiff3(currentTime, endDay.getTime());
			if (dateInfo != null) {
			if (dateInfo.getDay() > 0)
			valid = true;

			if (!valid && dateInfo.getHour() > 0)
			valid = true;

			if (!valid && dateInfo.getMinute() > 0)
			valid = true;

			if (!valid && dateInfo.getSecond() > 0)
			valid = true;
			}
			}

			if (!valid)
			throw new UserSystemCouponException(1, "该订单不能使用奖励券");
			}

			BigDecimal hongBao = orderVO.getHongBao();

			// 红包状态
			Integer hongBaoState = orderVO.getHongBaoState();
			// 红包类型
			@@ -784,8 +963,13 @@

			Order order = orderService.findOrderByOrderIdAndType(orderNo, sourceType);
			if (order == null)
			return;
			throw new UserSystemCouponException(1, "该订单不存在");

			// 使用奖励券金额额限制
			if (hongBao.compareTo(Constant.REWARD_COUPON_LIMIT_MONEY) > 0){
			throw new UserSystemCouponException(1, "该订单不能使用奖励券");
			}

			/* 奖金计算以及相关红包信息处理 */

			// 转换成小数点
			@@ -793,6 +977,40 @@
			// 提成金额
			BigDecimal money = MoneyBigDecimalUtil.mul(hongBao, percent);

			UserSystemCouponUseMQMsg mqMsg = new UserSystemCouponUseMQMsg(userSystemCoupon.getId(), order.getOrderId(),
			sourceType, systemCoupon.getType().name());

			if (Constant.IS_TEST) {
			useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
			} else { // 事务消息
			Message msg = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.useSystemCoupon, mqMsg);
			try {
			SendResult result = orderTransactionProducer.send(msg, new LocalTransactionExecuter() {
			@Override
			public TransactionStatus execute(Message arg0, Object arg1) {
			try {
			useRewardCouponCore(userSystemCoupon, money, hongBao, uid, order);
			return TransactionStatus.CommitTransaction;
			} catch (Exception e) {
			return TransactionStatus.RollbackTransaction;
			}
			}
			}, null);
			System.out.println(result);
			} catch (Exception e) {
			e.printStackTrace();
			throw e;
			}
			}
			}
			}

			@Transactional(rollbackFor = Exception.class)
			public void useRewardCouponCore(UserSystemCoupon userSystemCoupon, BigDecimal money, BigDecimal hongBao, Long uid,
			Order order) throws Exception {
			org.springframework.transaction.TransactionStatus transactionStatus = transactionManager
			.getTransaction(new DefaultTransactionDefinition());
			try {
			// 1、插入红包数据
			HongBaoV2 hongBaoV2 = new HongBaoV2();
			hongBaoV2.setMoney(money);
			@@ -804,21 +1022,27 @@
			hongBaoV2.setUserInfo(new UserInfo(uid));
			hongBaoV2.setPreGetTime(new Date());
			hongBaoV2.setGetTime(new Date());


			hongBaoV2Service.insertSelective(hongBaoV2);

			// 2.插入关联
			orderHongBaoMapService.addOrderHongBaoMap(hongBaoV2, order);

			// 计算该订单原有返利
			List<HongBaoOrder> hongBaoOrderlist = hongBaoOrderService
			.listDetailByOrderIdAndSourceType(order.getOrderId(), order.getOrderType());
			BigDecimal originalMoney = new BigDecimal(0);
			if (hongBaoOrderlist != null)
			for (HongBaoOrder ho : hongBaoOrderlist) {
			if (ho.getHongBaoV2() != null && ho.getHongBaoV2().getState() == HongBaoV2.STATE_YILINGQU)
			originalMoney = originalMoney.add(ho.getHongBaoV2().getMoney());
			}

			// 3.插入资金明细,用户余额
			UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(orderNo, sourceType, money,
			new UserInfo(uid));
			UserMoneyDetail userMoneyDetail = UserMoneyDetailFactory.createOrderReward(order.getOrderId(),
			order.getOrderType(), money, originalMoney, new UserInfo(uid));
			userMoneyDetailService.addUserMoneyDetail(userMoneyDetail);
			userInfoService.addMoney(new UserInfo(uid), money);

			// 插入资金通知
			userMoneyMsgNotificationService.orderReward(uid, orderNo, sourceType, money,
			userInfoService.selectByPKey(uid).getMyHongBao());

			/* 用户券信息状态及记录处理 */

			@@ -829,29 +1053,52 @@
			userSystemCoupon.setUpdateTime(date);
			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			SystemCoupon coupon = systemCouponService.selectByPrimaryKey(userSystemCoupon.getSystemCoupon().getId());

			// 插入使用券记录
			UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
			couponRecord.setState(UserSystemCouponRecord.STATE_SUCCESS);
			couponRecord.setGoodSource(sourceType);
			couponRecord.setOrderNo(orderNo);
			couponRecord.setGoodSource(order.getOrderType());
			couponRecord.setOrderNo(order.getOrderId());
			couponRecord.setUserSystemCoupon(userSystemCoupon);
			couponRecord.setCouponType(systemCoupon.getType().name());
			couponRecord.setCouponType(coupon.getType().name());
			couponRecord.setCreateTime(date);
			couponRecord.setUpdateTime(date);
			userSystemCouponRecordService.insertSelective(couponRecord);

			// 消息推送
			int goodsCount = 0;
			String orderId = order.getOrderId();
			Integer orderType = order.getOrderType();
			List<CommonOrder> orderList = commonOrderService.listBySourceTypeAndOrderId(orderType, orderId);
			if (orderList != null && orderList.size() > 0) {
			for (CommonOrder co : orderList) {
			goodsCount += co.getCount();
			}
			}

			// 资金消息
			UserInfo userInfo = userInfoService.selectByPKey(uid);
			userMoneyMsgNotificationService.rewardCounponReceived(uid, orderId, orderType, goodsCount,
			money, userInfo.getMyHongBao(), order.getThirdCreateTime());

			// 券使用成功消息
			try {
			userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon, hongBao, money, orderNo);
			userOtherMsgNotificationService.rewardCouponEndMsg(uid, userSystemCoupon.getSource(), 1, "使用成功");
			} catch (Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			transactionManager.commit(transactionStatus);
			} catch (Exception e) {
			e.printStackTrace();
			transactionManager.rollback(transactionStatus);
			throw new Exception();
			}

			}

			@Override
			public UserSystemCouponRecordVO getRewardCouponRecord(String orderNo, Integer sourceType) throws UserSystemCouponException, Exception {
			public UserSystemCouponRecordVO getRewardCouponRecord(String orderNo, Integer sourceType)
			throws UserSystemCouponException, Exception {

			if (orderNo == null \|\| orderNo.trim().length() == 0) {
			throw new UserSystemCouponException(1, "订单号不存在");
			@@ -918,9 +1165,9 @@
			userRecordVO.setJumpWelfare(jumpWelfare);

			// 跳转奖励券规则
			userRecordVO.setRuleLink(configService.get("reward_coupon_help"));
			userRecordVO.setRuleLink(configService.get(ConfigKeyEnum.rewardCouponHelp.getKey()));

			String rewardCouponRemark = configService.get("reward_coupon_remark");
			String rewardCouponRemark = configService.get(ConfigKeyEnum.rewardCouponRemark.getKey());
			if (rewardCouponRemark != null && rewardCouponRemark.trim().length() > 0) {
			userRecordVO.setRemark(JSONObject.fromObject(rewardCouponRemark));
			}
			@@ -929,7 +1176,8 @@
			}

			@Override
			public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo, Integer sourceType) throws UserSystemCouponException, Exception {
			public UserSystemCouponRecordVO getFreeCouponRecord(String orderNo, Integer sourceType)
			throws UserSystemCouponException, Exception {

			if (orderNo == null \|\| orderNo.trim().length() == 0) {
			throw new UserSystemCouponException(1, "订单号不存在");
			@@ -957,7 +1205,8 @@
			}

			// 订单
			CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null, sourceType);
			CommonOrderVO orderVO = commonOrderService.getCommonOrderByOrderNo(userSystemCoupon.getUid(), orderNo, null,
			sourceType);
			if (orderVO == null) {
			throw new UserSystemCouponException(1, "订单信息获取失败");
			}
			@@ -977,7 +1226,7 @@
			String progressMsg = "";
			String progressColor = "";
			// 跳转奖励券规则
			userRecordVO.setRuleLink(configService.get("free_coupon_help"));
			userRecordVO.setRuleLink(configService.get(ConfigKeyEnum.freeCouponHelp.getKey()));

			// 进度： 1 灰色 2 红色 3 绿色
			String progressState1 = "3";
			@@ -1015,7 +1264,7 @@

			jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore");

			rewardCouponRemark = configService.get("free_coupon_back_remark");
			rewardCouponRemark = configService.get(ConfigKeyEnum.freeCouponBackRemark.getKey());

			} else if (UserSystemCouponRecord.STATE_FAIL_DRAWBACK == stateRecord) {
			// 退款
			@@ -1034,7 +1283,7 @@

			jumpDetail = jumpDetailV2Service.getByTypeCache("welfareCore");

			rewardCouponRemark = configService.get("free_coupon_back_remark");
			rewardCouponRemark = configService.get(ConfigKeyEnum.freeCouponBackRemark.getKey());

			} else if (UserSystemCouponRecord.STATE_FREE_ON == stateRecord) {
			// 免单中
			@@ -1048,7 +1297,7 @@
			progressMsg = "免单发起，等待收货";
			}

			rewardCouponRemark = configService.get("free_coupon_remark");
			rewardCouponRemark = configService.get(ConfigKeyEnum.freeCouponRemark.getKey());

			} else if (UserSystemCouponRecord.STATE_SUCCESS == stateRecord) {
			// 免单成功
			@@ -1070,7 +1319,7 @@

			jumpDetail = jumpDetailV2Service.getByTypeCache("capitalDetails");

			rewardCouponRemark = configService.get("free_coupon_remark");
			rewardCouponRemark = configService.get(ConfigKeyEnum.freeCouponRemark.getKey());
			}
			userRecordVO.setProgressState(progressState);
			userRecordVO.setPayMoney(payMoney);
			@@ -1129,59 +1378,7 @@
			return userRecordVO;
			}

			@Transactional
			@Override
			public void activatedWelfareFreeCoupon(Long uid, String fromNickName) {

			LogHelper.test("券激活:" + 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 update = new UserSystemCoupon();
			update.setId(userSystemCoupon.getId());
			update.setStateActivated(1);
			update.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKeySelective(update);

			Integer state = userSystemCoupon.getState();
			if (UserSystemCoupon.STATE_OVERDUE == state) {
			continue; // 已失效不做消息推送
			}

			// 消息推送
			try {
			UserInfo userInfo = new UserInfo();
			userInfo.setId(uid);
			userInfo.setNickName(fromNickName);

			userOtherMsgNotificationService.welfareCouponActive(userSystemCoupon, userInfo);
			} catch (Exception e) {
			try {
			LogHelper.errorDetailInfo(e);
			} catch (Exception e1) {
			e1.printStackTrace();
			}
			}
			}
			}

			@Transactional
			@Transactional(rollbackFor = Exception.class)
			@Override
			public void updateStateByDrawback(String orderNo) throws Exception {

			@@ -1203,7 +1400,7 @@
			sendBackCoupon(record.getUserSystemCoupon(), record);
			}

			@Transactional
			@Transactional(rollbackFor = Exception.class)
			@Override
			public void updateStateByArrivalAccount(String orderNo) throws Exception {

			@@ -1220,24 +1417,14 @@
			record.setUpdateTime(new Date());
			record.setState(UserSystemCouponRecord.STATE_SUCCESS);
			userSystemCouponRecordService.updateByPrimaryKeySelective(record);

			// 消息推送
			if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.welfareCouponUsed(record.getUserSystemCoupon(), orderNo);
			} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.freeSheetCouponUsed(record.getUserSystemCoupon(), orderNo);
			} else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.couponUsedFreeSheet(record.getUserSystemCoupon(), orderNo, MsgTypeOtherTypeEnum.freeCouponBuy);
			}
			}

			@Override
			public List<UserSystemCoupon> getCounponNowInvalid(int count) {
			return userSystemCouponMapper.getCounponNowInvalid(count);
			}


			@Transactional

			@Transactional(rollbackFor = Exception.class)
			@Override
			public boolean updateCouponRecordUsed(Long uid, String orderNo, BigDecimal payment, Long auctionId)
			throws Exception {
			@@ -1301,204 +1488,19 @@
			if (couponType == null \|\| couponType.trim().length() == 0) {
			throw new Exception("券类型未被记录");
			}

			if (CouponTypeEnum.welfareFreeCoupon.name().equals(couponType)) {
			userOtherMsgNotificationService.welfareCouponUsing(userSystemCoupon, orderNo, payment);
			} else if (CouponTypeEnum.freeCoupon.name().equals(couponType)) {
			userOtherMsgNotificationService.freeSheetCouponUsing(userSystemCoupon, orderNo, payment);
			} else if (CouponTypeEnum.freeCouponBuy.name().equals(couponType)) {
			userOtherMsgNotificationService.couponUsingFreeSheet(userSystemCoupon, orderNo, payment, MsgTypeOtherTypeEnum.freeCouponBuy);
			}
			}
			}

			return isfree;
			}



			@Override
			@Transactional
			public void copyLotteryPrize(Long uid, int platform, String device) throws Exception {

			if (uid == null \|\| device == null) {
			return;
			}

			// 未登陆之前抽奖记录
			List<DeviceLotteryRecord> list = deviceLotteryRecordService.listByPlatformAndDevice(platform, device);
			if (list == null \|\| list.size() == 0) {
			return;
			}

			// 获取额外信息
			UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

			// 已经抽过奖的或者已经进入过抽奖页面的
			if (userInfoExtra != null && userInfoExtra.getLotteryNewbies() != null) {
			return;
			}

			// 是否是新用户
			boolean isNewUser = userInfoExtraService.isNewUser(uid);
			if (!isNewUser) {
			return;
			}

			int coupon = 0;

			for (DeviceLotteryRecord reviceLotteryRecord : list) {

			// 删除记录
			deviceLotteryRecordService.deleteByPrimaryKey(reviceLotteryRecord.getId());

			Long systemCouponId = reviceLotteryRecord.getSystemCouponId();
			if (systemCouponId == null) {
			continue;
			}
			SystemCoupon systemCoupon = systemCouponService.selectByPrimaryKey(systemCouponId);
			if (systemCoupon == null) {
			continue;
			}

			int stateActivated = 1;
			if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
			// 福利券状态
			long countSuccess = threeSaleSerivce.countSuccessFirstTeam(uid);
			// 没有下级队员 --待激活
			if (countSuccess == 0) {
			stateActivated = 0;
			}
			}

			// 结束日期
			// 今天在内减去一天
			String endDay = DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setUid(uid);
			userCoupon.setSource(UserSystemCoupon.SOURCE_NEWBIES);
			userCoupon.setSystemCoupon(systemCoupon);
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userCoupon.setStateActivated(stateActivated);
			userCoupon.setStartTime(new Date());
			userCoupon.setEndTime(endTime);
			userCoupon.setCreateTime(new Date());
			userCoupon.setUpdateTime(new Date());
			// 插入数据库
			insertSelective(userCoupon);

			// 券数量
			coupon++;

			// 消息推送
			try {
			if (systemCoupon.getType() == CouponTypeEnum.welfareFreeCoupon) {
			userOtherMsgNotificationService.welfareCouponGet(userCoupon);
			} else if (systemCoupon.getType() == CouponTypeEnum.freeCoupon) {
			userOtherMsgNotificationService.freeSheetCouponGet(userCoupon);
			} else if (systemCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
			userOtherMsgNotificationService.rewardCouponGet(userCoupon, systemCoupon.getPercent().intValue());
			}

			} catch (Exception e) {
			try {
			LogHelper.errorDetailInfo(e);
			} catch (Exception e1) {
			e1.printStackTrace();
			}
			}
			}

			if (userInfoExtra == null) {
			userInfoExtra = new UserInfoExtra();
			userInfoExtra.setUserInfo(new UserInfo(uid));
			}

			userInfoExtra.setLotteryNewbies(Constant.MAX_COUNT_LOTTERY_NEWBIES - list.size());
			Integer couponNews = userInfoExtra.getCouponNews();
			if (couponNews == null) {
			userInfoExtra.setCouponNews(coupon);
			} else {
			userInfoExtra.setCouponNews(couponNews + coupon);
			}
			userInfoExtraService.saveUserInfoExtra(userInfoExtra);

			}


			@Override
			@Transactional
			public void randomRewardCoupon(int num, Long uid, String source) throws Exception {
			if (num < 1) {
			return;
			}

			for (int i = 0; i < num; i++) {

			// 返利比-随机
			BigDecimal percent = new BigDecimal(randomNum());
			// 查询奖励券
			SystemCoupon systemCoupon = systemCouponService.getCouponByTypeAndPercent(
			CouponTypeEnum.rebatePercentCoupon.name(),percent);
			if (systemCoupon == null) {
			return;
			}

			// 结束日期今天在内减去一天
			String endDay = DateUtil.plusDay(systemCoupon.getExpiryDay() - 1, new Date());
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setUid(uid);
			userCoupon.setSource(source);
			userCoupon.setSystemCoupon(systemCoupon);
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userCoupon.setStateActivated(1);
			userCoupon.setStartTime(new Date());
			userCoupon.setEndTime(endTime);
			userCoupon.setCreateTime(new Date());
			userCoupon.setUpdateTime(new Date());
			// 插入数据库
			insertSelective(userCoupon);

			// 消息推送
			try {
			userOtherMsgNotificationService.rewardCouponGet(userCoupon,systemCoupon.getPercent().intValue());
			} catch(Exception e) {
			try {
			LogHelper.errorDetailInfo(e);
			} catch (Exception e1) {
			e1.printStackTrace();
			}
			}
			}

			// 福利中心红点
			UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
			if (userInfoExtra == null) {
			return;
			}
			Integer couponNews = userInfoExtra.getCouponNews();
			if (couponNews == null) {
			userInfoExtra.setCouponNews(num);
			} else {
			userInfoExtra.setCouponNews(couponNews + num);
			}
			userInfoExtraService.saveUserInfoExtra(userInfoExtra);
			}

			/**
			* 随机券比例
			*
			* @return
			*/
			public int randomNum() {

			private int randomCounponPercent() {
			int result = 1;

			List<RandomProportion> list = new ArrayList<RandomProportion>();
			list.add(new RandomProportion(1, 22));
			list.add(new RandomProportion(2, 22));
			@@ -1519,40 +1521,36 @@
			int minRange = 0;
			int maxRange = 0;
			int randomNum = (int) (1 + Math.round(Math.random() * (199)));

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

			RandomProportion proportion = list.get(i);
			int probability = proportion.probability;

			maxRange = maxRange + probability;
			minRange = maxRange - probability;

			if(randomNum > minRange && randomNum <= maxRange) {
			if (randomNum > minRange && randomNum <= maxRange) {
			result = proportion.num;
			break;
			}
			}

			return result;
			}


			class RandomProportion {
			public int num;//券值
			public int num;// 券值
			public int probability; // 概率

			RandomProportion () {}

			RandomProportion (int num, int probability) {

			RandomProportion() {
			}

			RandomProportion(int num, int probability) {
			this.num = num;
			this.probability = probability;
			}
			}



			@Override
			@Transactional
			public void exchangeCoupon(Long uid, String couponType, String source, BigDecimal percent) throws UserSystemCouponException, Exception {
			@Transactional(rollbackFor = Exception.class)
			public void exchangeCoupon(Long uid, String couponType, String source, BigDecimal percent)
			throws UserSystemCouponException, Exception {
			if (couponType == null \|\| uid == null) {
			throw new UserSystemCouponException(1, "参数不正确");
			}
			@@ -1563,7 +1561,7 @@
			} else {
			coupon = systemCouponService.getCouponByType(couponType);
			}


			if (coupon == null) {
			throw new UserSystemCouponException(1, "券类型不正确");
			}
			@@ -1571,22 +1569,24 @@
			int stateActivated = 1;
			if (couponType == CouponTypeEnum.freeCoupon.name()) {
			stateActivated = 0; //
			} else if (couponType == CouponTypeEnum.welfareFreeCoupon.name() && threeSaleSerivce.countSuccessFirstTeam(uid) <= 0) {
			stateActivated = 0; // 无下级队员 --待激活
			}


			} else if (couponType == CouponTypeEnum.welfareFreeCoupon.name()
			&& threeSaleSerivce.countFirstTeam(uid) <= 0) {
			stateActivated = 0; // 无下级队员 --待激活
			}

			Integer expiryDay = null;
			if (stateActivated == 0)
			if (stateActivated == 0)
			expiryDay = coupon.getActivateDay();

			if (expiryDay == null \|\| expiryDay == 0)

			if (expiryDay == null \|\| expiryDay == 0)
			expiryDay = coupon.getExpiryDay();


			// 计算结束日期：今天在内减去一天

			// 计算结束日期：今天在内减去一天
			String endDay = DateUtil.plusDay(expiryDay - 1, new Date());
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			if (endDay != null && endDay.trim().length() > 0) {
			endDay += " 23:59:59";
			}
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			@@ -1600,26 +1600,24 @@
			userCoupon.setCreateTime(new Date());
			userCoupon.setUpdateTime(new Date());
			userCoupon.setState(UserSystemCoupon.STATE_CAN_USE);


			insertSelective(userCoupon);
			}


			@Transactional

			@Transactional(rollbackFor = Exception.class)
			@Override
			public List<UserSystemCouponVO> getCouponList(long start, int count, Long uid)
			public List<UserSystemCouponVO> getCouponList(AcceptData acceptData, long start, int count, Long uid)
			throws UserSystemCouponException, Exception {


			// 过期券
			updateInvalidSate(uid);


			// 退回券
			sendBackTimeOutCoupon(uid);


			// 赠送的退回
			sendBackGiveUser(uid);



			List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);
			if (listVO == null \|\| listVO.size() == 0) {
			return listVO;
			@@ -1646,7 +1644,7 @@
			if (source != null && "奖励券天天抽".equals(source)) {
			source = "天天抽";
			}


			userCouponVO.setSource("来源：" + source);
			userCouponVO.setCouponName(systemCoupon.getName());
			userCouponVO.setCouponEffect(systemCoupon.getEffect());
			@@ -1703,15 +1701,13 @@
			listTip.add("满足条件后，系统将自动激活，并在消息-其它消息中提醒。");
			userCouponVO.setTips(listTip);
			userCouponVO.setPopup(true);

			// 验证是否已累计3单
			executor.execute(new Runnable() {
			@Override
			public void run() {
			freeCouponActivate(userCouponVO.getId(), uid, userCouponVO.getCreateTime());
			}
			});

			// 统计待激活数量
			if (VersionUtil.greaterThan_2_0_2(acceptData.getPlatform(), acceptData.getVersion())) {
			int activateCount = userSystemCouponActivateService.getActivateCount(userCouponVO.getId());
			String activateNum = configService.get(ConfigKeyEnum.freeCouponActivateNum.getKey());
			userCouponVO.setCouponEffect(
			"(" + activateCount + "/" + Integer.parseInt(activateNum) + ")待激活");
			}
			} else if (CouponTypeEnum.welfareFreeCoupon == type) {
			jumpBtn = new HashMap<String, Object>();
			if (inviteCode != null && inviteCode.trim().length() > 0) {
			@@ -1720,7 +1716,7 @@
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_activate"));
			}
			}
			}
			}
			}

			if (UserSystemCoupon.STATE_IN_USE == state && (CouponTypeEnum.freeCouponBuy == type
			@@ -1737,63 +1733,69 @@
			if (give == null) {
			give = false;
			}


			SimpleDateFormat sdf = new SimpleDateFormat("yyyy.MM.dd");


			if (UserSystemCoupon.STATE_CAN_USE == state) {
			Map<String, Object> jumpLink = new HashMap<String, Object>();
			if (CouponTypeEnum.freeCouponGive == type) {
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_ONLY);
			} else if (CouponTypeEnum.freeCoupon == type \|\| CouponTypeEnum.welfareFreeCoupon == type
			\|\| CouponTypeEnum.freeCouponBuy == type) {
			jumpLink.put("url", configService.get("free_goods_list"));
			jumpLink.put("url", configService.get(ConfigKeyEnum.freeGoodsList.getKey()));
			jumpBtn = new HashMap<String, Object>();
			jumpBtn.put("params", jumpLink);
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web"));
			} else if (CouponTypeEnum.rebatePercentCoupon == type) {
			// 可使用、可赠送
			userCouponVO.setState(UserSystemCoupon.STATE_USE_GIVE);
			if (userInviteService.verifyVIP(uid)) { // 会员只可赠送
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_ONLY);
			} else {// 可使用可赠送
			userCouponVO.setState(UserSystemCoupon.STATE_USE_GIVE);

			// 订单列表
			jumpLink.put("state", "2"); // 已收货
			jumpLink.put("type", "1"); // 返利订单
			jumpLink.put("title", "返利订单"); // 标题名
			jumpLink.put("goodsType", "0"); // 订单来源
			jumpBtn = new HashMap<String, Object>();
			jumpBtn.put("params", jumpLink);
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("order_screen_list"));
			jumpLink.put("state", "2"); // 已收货
			jumpLink.put("showNav", false); // 不显示上方统计信息
			jumpLink.put("type", "1"); // 返利订单
			jumpLink.put("title", "返利订单"); // 标题名
			jumpLink.put("goodsType", "0"); // 订单来源
			jumpBtn = new HashMap<String, Object>();
			jumpBtn.put("params", jumpLink);
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("order_screen_list"));
			}
			}
			} else if (UserSystemCoupon.STATE_IN_USE == state && give) {
			userCouponVO.setCouponEffect("赠送中");
			userCouponVO.setCouponRule(systemCoupon.getRemark());
			String tips = null;


			TokenTypeEnum tokenType = null;
			if (CouponTypeEnum.freeCouponGive == type) {
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);
			tips = configService.get("give_free_coupon_tips");
			tips = configService.get(ConfigKeyEnum.giveFreeCouponTips.getKey());
			tokenType = TokenTypeEnum.freeCoupon;
			}


			if (CouponTypeEnum.rebatePercentCoupon == type) {
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_IN);
			tips = configService.get("give_free_coupon_tips");
			tips = configService.get(ConfigKeyEnum.giveRebatePercentCouponTips.getKey());
			tokenType = TokenTypeEnum.rebatePercentCoupon;
			}


			if (!StringUtil.isNullOrEmpty(tips) && tokenType != null) {
			UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, userCouponVO.getId());
			UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid,
			userCouponVO.getId());
			if (record != null) {
			TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenType.name(), record.getId().toString());
			TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenType.name(),
			record.getId().toString());
			if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {
			String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
			while(tips.contains("{APP名称}")) {
			while (tips.contains("{APP名称}")) {
			tips = tips.replace("{APP名称}", projectChineseName);
			}
			tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}", configService.get("app_down_link"));
			tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}",
			configService.get(ConfigKeyEnum.appDownLink.getKey()));
			userCouponVO.setGiveTips(tips);
			}


			Date endTimeGive = record.getEndTime();
			if (endTimeGive != null) {
			Map<String, Object> remainDays = new HashMap<String, Object>();
			@@ -1801,21 +1803,21 @@
			remainDays.put("fontColor", "#F14242");
			userCouponVO.setRemainDays(remainDays);
			}
			}
			}
			}
			}
			} else if (UserSystemCoupon.STATE_END_USE == state) {


			if (give) {
			userCouponVO.setCouponRule(systemCoupon.getRemark());
			if (CouponTypeEnum.freeCouponGive == type) {
			userCouponVO.setCouponEffect("任性0元购");
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);
			}


			if (CouponTypeEnum.rebatePercentCoupon == type) {
			userCouponVO.setState(UserSystemCoupon.STATE_GIVE_END);
			}


			Date useTime = userCouponVO.getUseTime();
			if (useTime != null) {
			Map<String, Object> remainDays = new HashMap<String, Object>();
			@@ -1832,109 +1834,108 @@
			userCouponVO.setRemainDays(remainDays);
			}
			}

			}else if (UserSystemCoupon.STATE_OVERDUE == state) {

			} else if (UserSystemCoupon.STATE_OVERDUE == state) {
			if (endTime != null) {
			Map<String, Object> remainDays = new HashMap<String, Object>();
			remainDays.put("content", "于" + sdf.format(endTime) + "过期");
			remainDays.put("fontColor", "#CCCCCC");
			userCouponVO.setRemainDays(remainDays);
			}

			if(give)

			if (give)
			userCouponVO.setCouponRule(systemCoupon.getRemark());
			}
			userCouponVO.setJumpBtn(jumpBtn);
			}
			return listVO;
			}


			@Transactional

			@Transactional(rollbackFor = Exception.class)
			@Override
			public UserSystemCouponVO giveCoupon(Long uid, Long id) throws UserSystemCouponException {
			UserSystemCoupon userSystemCoupon = userSystemCouponMapper.selectByPrimaryKey(id);
			if (userSystemCoupon == null)
			throw new UserSystemCouponException(1, "该券已不存在");


			SystemCoupon systemCoupon = userSystemCoupon.getSystemCoupon();
			if (systemCoupon == null)
			throw new UserSystemCouponException(1, "该券已不存在");


			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
			if (systemCoupon == null)
			throw new UserSystemCouponException(1, "该券已失效");


			Integer state = userSystemCoupon.getState();
			if (state != UserSystemCoupon.STATE_CAN_USE)
			if (state != UserSystemCoupon.STATE_CAN_USE)
			throw new UserSystemCouponException(1, "该券已被使用或赠送");


			CouponTypeEnum type = systemCoupon.getType();
			if (type != CouponTypeEnum.freeCouponGive && type != CouponTypeEnum.rebatePercentCoupon )
			if (type != CouponTypeEnum.freeCouponGive && type != CouponTypeEnum.rebatePercentCoupon)
			throw new UserSystemCouponException(1, "该券不支持赠送");


			String tips = null;
			TokenTypeEnum tokenTypeEnum = null;
			if (type == CouponTypeEnum.freeCouponGive) {
			tokenTypeEnum = TokenTypeEnum.freeCoupon;
			tips = configService.get("give_free_coupon_tips");
			} else if (type == CouponTypeEnum.rebatePercentCoupon){
			tips = configService.get(ConfigKeyEnum.giveFreeCouponTips.getKey());
			} else if (type == CouponTypeEnum.rebatePercentCoupon) {
			tokenTypeEnum = TokenTypeEnum.rebatePercentCoupon;
			tips = configService.get("give_rebate_percent_coupon_tips");
			tips = configService.get(ConfigKeyEnum.giveRebatePercentCouponTips.getKey());
			} else {
			throw new UserSystemCouponException(1, "该券不支持赠送");
			}


			if (StringUtil.isNullOrEmpty(tips))
			throw new UserSystemCouponException(1, "tips数据缺失");



			// 是否最近生成口令有效
			UserSystemCouponGiveRecord record = userSystemCouponGiveRecordService.getRecordByUidAndCouponId(uid, id);
			if (record != null) {
			TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id+"");
			TokenRecord tokenRecord = tokenRecordService.getNearByTypeAndIdentify(tokenTypeEnum.name(), id + "");
			if (tokenRecord != null && !StringUtil.isNullOrEmpty(tokenRecord.getToken())) {
			String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
			while(tips.contains("{APP名称}")) {
			while (tips.contains("{APP名称}")) {
			tips = tips.replace("{APP名称}", projectChineseName);
			}
			tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}", configService.get("app_down_link"));

			tips = tips.replace("{口令}", tokenRecord.getToken()).replace("{下载链接}",
			configService.get(ConfigKeyEnum.appDownLink.getKey()));

			return createUserCouponVOo(userSystemCoupon, systemCoupon, record, tips);
			}
			}



			Date nowDate = new Date();
			Date endTime = DateUtil.plusDayDate(Constant.GIVE_DAYS, nowDate);
			// 插入赠送记录
			UserSystemCouponGiveRecord giveRecord = new UserSystemCouponGiveRecord();
			giveRecord.setCouponId(id);
			giveRecord.setGiveUid(uid);
			giveRecord.setGiveTime(nowDate);
			giveRecord.setEndTime(DateUtil.plusDayDate(Constant.GIVE_DAYS, nowDate));
			giveRecord.setEndTime(endTime);
			userSystemCouponGiveRecordService.insertSelective(giveRecord);


			// 创建记录
			TokenRecord tokenRecord = new TokenRecord();
			tokenRecord.setUid(uid);
			tokenRecord.setIdentify(giveRecord.getId()+"");
			tokenRecord.setIdentify(giveRecord.getId() + "");
			tokenRecord.setType(tokenTypeEnum);
			tokenRecord.setStartTime(nowDate);
			tokenRecord.setEndTime(DateUtil.plusDayDate(Constant.TOKEN_DAYS, nowDate));
			tokenRecord.setEndTime(endTime);
			tokenRecord.setState(0);
			tokenRecordService.insertSelective(tokenRecord);


			// 创建口令
			String token = TokenUtil.createToken(tokenRecord.getId());
			tokenRecord.setToken(token);
			tokenRecordService.updateByPrimaryKeySelective(tokenRecord);


			// 券状态
			userSystemCoupon.setState(UserSystemCoupon.STATE_IN_USE);
			userSystemCoupon.setGive(true);
			userSystemCoupon.setUpdateTime(nowDate);
			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);


			// 插入使用券记录
			UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
			couponRecord.setState(UserSystemCouponRecord.STATE_GIVE_ON);
			@@ -1943,18 +1944,31 @@
			couponRecord.setCreateTime(nowDate);
			couponRecord.setUpdateTime(nowDate);
			userSystemCouponRecordService.insertSelective(couponRecord);


			String projectChineseName = Constant.systemCommonConfig.getProjectChineseName();
			while(tips.contains("{APP名称}")) {
			while (tips.contains("{APP名称}")) {
			tips = tips.replace("{APP名称}", projectChineseName);
			}
			tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get("app_down_link"));

			return createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips);
			tips = tips.replace("{口令}", token).replace("{下载链接}", configService.get(ConfigKeyEnum.appDownLink.getKey()));

			UserSystemCouponVO couponVO = createUserCouponVOo(userSystemCoupon, systemCoupon, giveRecord, tips);

			UserSystemCouponUseMQMsg msg = new UserSystemCouponUseMQMsg();
			msg.setUserSystemCouponId(id);
			msg.setCouponType(type.name());
			Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.systemCouponDrawback, msg);
			// 延迟一分钟
			message.setStartDeliverTime(endTime.getTime() + 1000 * 60);
			try {
			producer.send(message);
			} catch (Exception e) {
			throw new UserSystemCouponException(1, "创建赠送信息失败");
			}

			return couponVO;
			}


			private UserSystemCouponVO createUserCouponVOo(UserSystemCoupon userSystemCoupon, SystemCoupon systemCoupon,

			private UserSystemCouponVO createUserCouponVOo(UserSystemCoupon userSystemCoupon, SystemCoupon systemCoupon,
			UserSystemCouponGiveRecord record, String tips) {
			UserSystemCouponVO userCouponVO = new UserSystemCouponVO();
			userCouponVO.setId(userSystemCoupon.getId());
			@@ -1967,7 +1981,7 @@
			userCouponVO.setCouponRuleLink(systemCoupon.getRuleLink());
			userCouponVO.setCouponPicture(systemCoupon.getPicture());
			userCouponVO.setGiveTips(tips);


			String couponTerm = "有效期：";
			Date startTime = userCouponVO.getStartTime();
			Date endTime = userCouponVO.getEndTime();
			@@ -1976,90 +1990,15 @@
			couponTerm = couponTerm + sdf.format(startTime) + "-" + sdf.format(endTime);
			}
			userCouponVO.setCouponTerm(couponTerm);


			Map<String, Object> remainDays = new HashMap<String, Object>();
			remainDays.put("content", "剩余23时59分过期");
			remainDays.put("fontColor", "#F14242");
			userCouponVO.setRemainDays(remainDays);


			return userCouponVO;
			}


			/**
			* 免单券激活
			* @param uid
			*/
			public void freeCouponActivate(Long id,Long uid, Date date) {
			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			long count = commonOrderCountService.countValidOrderByDate(uid, sdf.format(date));

			String activateNum = configService.get("free_coupon_activate_num");
			int num = Integer.parseInt(activateNum);

			if (count >= num) {
			UserSystemCoupon coupon = userSystemCouponMapper.selectByPrimaryKey(id);
			if (coupon == null \|\| coupon.getState() != UserSystemCoupon.STATE_CAN_USE
			\|\| coupon.getStateActivated() != 0)
			return;

			Date nowDate = new Date();
			Date endTime2 = coupon.getEndTime();
			if (endTime2 != null && endTime2.getTime() <= nowDate.getTime())
			return;


			SystemCoupon systemCoupon = coupon.getSystemCoupon();
			if (systemCoupon == null)
			return;

			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());
			if (systemCoupon == null \|\| systemCoupon.getType() != CouponTypeEnum.freeCoupon)
			return;


			try {
			Integer expiryDay = systemCoupon.getExpiryDay();
			String endDay = DateUtil.plusDay(expiryDay - 1, nowDate);
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setId(coupon.getId());
			userCoupon.setStateActivated(1);
			userCoupon.setEndTime(endTime);
			userCoupon.setStartTime(nowDate);
			userCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);

			// 赠送记录
			UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByReceiveId(id);
			if (giveRecord == null)
			return;

			Long giveUid = giveRecord.getGiveUid();
			UserInfo userInfo = userInfoService.selectByPKey(giveUid);
			if (userInfo == null)
			return;

			String beiZhu = "请到我的-福利中心中查看";
			SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
			MsgOtherCouponActivateDTO msgOther = new MsgOtherCouponActivateDTO();
			msgOther.setTitle("免单券激活");
			msgOther.setType("免单券系统已自动激活");
			msgOther.setExplain("满足"+ systemCoupon.getActivateDay() +"天内产生"+ num +"笔已到账返利订单");
			msgOther.setGiveUser("昵称："+ userInfo.getNickName() +" ID：" + giveUid);
			msgOther.setReceiveTime(sd.format(giveRecord.getReceiveTime()));
			msgOther.setValidityTime(expiryDay + "天");
			userOtherMsgNotificationService.giveCouponActivateMsg(uid, beiZhu, msgOther);
			} catch (Exception e) {
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
			}
			}
			}


			@Transactional
			@Override
			public void updateInvalidSate(Long uid) {
			@@ -2069,8 +2008,7 @@
			}
			updateCounponInvalid(list);
			}



			@Override
			public void updateCounponInvalid(List<UserSystemCoupon> list) {
			if (list == null \|\| list.size() == 0) {
			@@ -2087,36 +2025,30 @@
			if (baseCoupon == null) {
			continue;
			}


			baseCoupon = systemCouponService.selectByPrimaryKey(baseCoupon.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);
			}else if (baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) {
			userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponBuy);
			try { // 消息推送
			Long uid = userCoupon.getUid();
			String source = userCoupon.getSource();
			if (baseCoupon.getType() == CouponTypeEnum.freeCoupon
			\|\| baseCoupon.getType() == CouponTypeEnum.freeCouponBuy) {
			userOtherMsgNotificationService.freeCouponEndMsg(uid, "自购免单券", source, 1, "已过期");
			} else if (baseCoupon.getType() == CouponTypeEnum.freeCouponGive) {
			userOtherMsgNotificationService.outOfDate(userSystemCoupon, MsgTypeOtherTypeEnum.freeCouponGive);
			userOtherMsgNotificationService.freeCouponEndMsg(uid, "赠送免单券", source, 1, "已过期");
			}
			if (baseCoupon.getType() == CouponTypeEnum.rebatePercentCoupon) {
			userOtherMsgNotificationService.rewardCouponEndMsg(uid, source, 1, "已过期");
			}
			} catch (Exception e) {
			try {
			LogHelper.errorDetailInfo(e);
			} catch (Exception e1) {
			e1.printStackTrace();
			}
			e.printStackTrace();
			}
			}
			}



			/**
			* 退回券初始数据
			*
			@@ -2125,11 +2057,11 @@
			public void sendBackCoupon(UserSystemCoupon userCoupon, UserSystemCouponRecord record) throws Exception {
			if (userCoupon == null)
			return;


			Integer state = userCoupon.getState();
			if (state != UserSystemCoupon.STATE_IN_USE)
			if (state != UserSystemCoupon.STATE_IN_USE)
			return;


			Date now = new Date();
			Date endTime = userCoupon.getEndTime();
			if (endTime != null && endTime.getTime() < now.getTime()) {
			@@ -2139,7 +2071,7 @@
			updateCounponInvalid(list);
			return;
			}


			// 退回券
			UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
			userSystemCoupon.setId(userCoupon.getId());
			@@ -2147,86 +2079,177 @@
			userSystemCoupon.setUseTime(null);
			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userSystemCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			// 使用记录
			if (record != null) {
			UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();
			useRecordUpdate.setId(record.getId());
			useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
			useRecordUpdate.setUpdateTime(new Date());
			userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);

			if (CouponTypeEnum.welfareFreeCoupon.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.welfareCouponDrawBack(userSystemCoupon, record.getOrderNo());
			} else if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.freeSheetCouponDrawBack(userSystemCoupon, record.getOrderNo());
			} else if (CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.couponDrawBack(userSystemCoupon, record.getOrderNo(), MsgTypeOtherTypeEnum.freeCouponBuy);
			if (record != null) {
			Long uid = userCoupon.getUid();
			String source = userCoupon.getSource();
			Date startTime = userCoupon.getStartTime();
			if (CouponTypeEnum.freeCoupon.name().equals(record.getCouponType())
			\|\| CouponTypeEnum.freeCouponBuy.name().equals(record.getCouponType())) {
			userOtherMsgNotificationService.freeCouponWinMsg(uid, "自购免单券", source, 1, "使用退回", startTime, endTime);
			}
			}
			}



			@Async()
			@Transactional
			@Override
			public void sendBackTimeOutCoupon(Long uid) {
			// 超过10分钟未被匹配的券
			List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 600L);
			if (list == null \|\| list.size() == 0) {
			// 商品相关的券
			List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
			if (couponList == null \|\| couponList.size() == 0) {
			return;
			}

			for (UserSystemCouponRecord couponRecord : list) {
			// 更新状态：匹配超时
			couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
			couponRecord.setUpdateTime(new Date());
			userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);
			List<Long> list = new ArrayList<Long>();
			for (SystemCoupon systemCoupon : couponList) {
			list.add(systemCoupon.getId());
			}

			// 超过10分钟未被匹配的免单券
			List<UserSystemCoupon> listUserCoupon = userSystemCouponMapper.getCouponByUsingTimeOut(uid, list, 600L);
			if (listUserCoupon == null \|\| listUserCoupon.size() == 0) {
			return;
			}

			for (UserSystemCoupon userCoupon : listUserCoupon) {
			// 状态初始化
			UserSystemCoupon userSystemCoupon = couponRecord.getUserSystemCoupon();
			UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
			userSystemCoupon.setId(userCoupon.getId());
			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userSystemCoupon.setUseTime(null);
			userSystemCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			UserSystemCouponRecord record = userSystemCouponRecordService.getNearByUserCouponId(userCoupon.getId());
			if (record != null) {
			UserSystemCouponRecord couponRecord = new UserSystemCouponRecord();
			couponRecord.setId(record.getId());
			couponRecord.setUpdateTime(new Date());
			couponRecord.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
			userSystemCouponRecordService.updateByPrimaryKeySelective(couponRecord);
			}
			}
			}


			@Transactional
			@Override
			public void sendBackGiveUser(Long uid) {
			List<UserSystemCouponGiveRecord> list =userSystemCouponGiveRecordService.overdueListByUser(uid);
			List<UserSystemCouponGiveRecord> list = userSystemCouponGiveRecordService.overdueListByUser(uid);
			if (list == null \|\| list.size() == 0) {
			return;
			}
			sendBackGiveCoupon(list);
			}


			@Override
			@RequestSerializableByKeyService(key = "#couponId")
			@Transactional(rollbackFor = Exception.class)
			public void sendBackByGiveId(Long couponId) {
			if (couponId == null)
			return;

			UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId);
			if (userCoupon == null)
			return;

			Integer state = userCoupon.getState();
			if (state != UserSystemCoupon.STATE_IN_USE)
			return;

			UserSystemCouponGiveRecord giveRecord = userSystemCouponGiveRecordService.getByCouponId(couponId);
			if (giveRecord == null)
			return;

			if (giveRecord.getState() != null && giveRecord.getState() != UserSystemCouponGiveRecord.STATE_INIT)
			return;

			// 更新赠送记录
			UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();
			updateRecord.setId(giveRecord.getId());
			updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE);
			userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord);

			// 口令失效
			tokenRecordService.invalidByCoupon(giveRecord.getId());

			Date now = new Date();
			Date endTime = userCoupon.getEndTime();
			if (endTime != null && endTime.getTime() < now.getTime()) {
			List<UserSystemCoupon> list = new ArrayList<UserSystemCoupon>();
			list.add(userCoupon);
			updateCounponInvalid(list);
			return;
			}

			// 退回券
			UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
			userSystemCoupon.setId(userCoupon.getId());
			userSystemCoupon.setGive(false);
			userSystemCoupon.setUseTime(null);
			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userSystemCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			// 使用记录
			UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId);
			if (useRecord != null) {
			UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();
			useRecordUpdate.setId(useRecord.getId());
			useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
			useRecordUpdate.setUpdateTime(new Date());
			userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);
			}

			SystemCoupon systemCoupon = userCoupon.getSystemCoupon();
			if (systemCoupon != null)
			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());

			if (systemCoupon == null)
			return;

			// 退回消息
			Long uid = userCoupon.getUid();
			String source = userCoupon.getSource();
			CouponTypeEnum type = systemCoupon.getType();
			if (CouponTypeEnum.freeCouponGive == type) {
			userOtherMsgNotificationService.freeCouponWinMsg(uid, type.getDesc(), source, 1, "使用退回",
			userCoupon.getStartTime(), userCoupon.getEndTime());
			} else if (CouponTypeEnum.rebatePercentCoupon == systemCoupon.getType()) {
			userOtherMsgNotificationService.rewardCouponWinMsg(uid, source, 1, "使用退回", userCoupon.getStartTime(),
			userCoupon.getEndTime());
			}
			}

			@Override
			public void sendBackGiveCoupon(List<UserSystemCouponGiveRecord> overdueList) {
			for (UserSystemCouponGiveRecord record: overdueList) {
			for (UserSystemCouponGiveRecord record : overdueList) {
			if (record.getState() != null && record.getState() != UserSystemCouponGiveRecord.STATE_INIT)
			continue;

			// 更新赠送记录
			UserSystemCouponGiveRecord updateRecord = new UserSystemCouponGiveRecord();
			updateRecord.setId(record.getId());
			updateRecord.setState(UserSystemCouponGiveRecord.STATE_OVERDUE);
			userSystemCouponGiveRecordService.updateByPrimaryKeySelective(updateRecord);


			// 更新券信息
			Long couponId = record.getCouponId();
			if (couponId == null) {
			continue;
			}


			// 券列表
			UserSystemCoupon userCoupon = userSystemCouponMapper.selectByPrimaryKey(couponId);
			if (userCoupon == null)
			continue;


			Integer state = userCoupon.getState();
			if (state != UserSystemCoupon.STATE_IN_USE)
			if (state != UserSystemCoupon.STATE_IN_USE)
			return;


			Date now = new Date();
			Date endTime = userCoupon.getEndTime();
			if (endTime != null && endTime.getTime() < now.getTime()) {
			@@ -2235,7 +2258,7 @@
			updateCounponInvalid(list);
			continue;
			}


			// 退回券
			UserSystemCoupon userSystemCoupon = new UserSystemCoupon();
			userSystemCoupon.setId(userCoupon.getId());
			@@ -2243,90 +2266,61 @@
			userSystemCoupon.setUseTime(null);
			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userSystemCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);

			userSystemCouponMapper.updateByPrimaryKeySelective(userSystemCoupon);

			// 使用记录
			UserSystemCouponRecord useRecord = userSystemCouponRecordService.getNearByUserCouponId(couponId);
			if (useRecord != null) {
			if (useRecord != null) {
			UserSystemCouponRecord useRecordUpdate = new UserSystemCouponRecord();
			useRecordUpdate.setId(useRecord.getId());
			useRecordUpdate.setState(UserSystemCouponRecord.STATE_WAIT_TIME_OUT);
			useRecordUpdate.setUpdateTime(new Date());
			userSystemCouponRecordService.updateByPrimaryKeySelective(useRecordUpdate);
			}


			SystemCoupon systemCoupon = userCoupon.getSystemCoupon();
			if (systemCoupon != null)
			if (systemCoupon != null)
			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());


			if (systemCoupon == null)
			continue;



			// 退回消息
			String couponName = systemCoupon.getName();
			if (CouponTypeEnum.freeCouponGive == systemCoupon.getType()) {
			couponName = "免单券";
			Long uid = userCoupon.getUid();
			String source = userCoupon.getSource();
			CouponTypeEnum type = systemCoupon.getType();
			if (CouponTypeEnum.freeCouponGive == type) {
			userOtherMsgNotificationService.freeCouponWinMsg(uid, type.getDesc(), source, 1, "使用退回",
			userCoupon.getStartTime(), userCoupon.getEndTime());
			} else if (CouponTypeEnum.rebatePercentCoupon == systemCoupon.getType()) {
			couponName = "奖励券";
			userOtherMsgNotificationService.rewardCouponWinMsg(uid, source, 1, "使用退回", userCoupon.getStartTime(),
			userCoupon.getEndTime());
			}

			String beiZhu = "请到我的-福利中心查看";
			SimpleDateFormat sd = new SimpleDateFormat("yyyy.MM.dd HH:mm");
			MsgOtherGiveContentDTO msgOther = new MsgOtherGiveContentDTO();
			msgOther.setType(MsgOtherGiveContentDTO.TYEP_COUPON);
			msgOther.setTitle(couponName + "退回");
			msgOther.setGiveType("你赠送的"+ couponName + "未被成功领取");
			msgOther.setGiveTime(sd.format(record.getGiveTime()));
			msgOther.setReturnTime(sd.format(new Date()));
			userOtherMsgNotificationService.tokenGiveMsg(record.getGiveUid(), beiZhu, msgOther);
			}
			}



			@Override
			public boolean getIncludeExchange(Long uid) {
			public boolean getValidRebateCoupon(Long uid) {
			// 过期券
			updateInvalidSate(uid);

			String percent = configService.get("exchange_rebate_percent");
			if (StringUtil.isNullOrEmpty(percent))
			percent = "35";
			List<UserSystemCoupon> listCoupon = userSystemCouponMapper.getIncludeExchange(uid, Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());
			if (listCoupon == null \|\| listCoupon.size() == 0)
			return false;
			return true;
			}


			@Override
			public boolean getIncludeNotExchange(Long uid) {
			// 过期券
			updateInvalidSate(uid);

			String percent = configService.get("exchange_rebate_percent");
			if (StringUtil.isNullOrEmpty(percent))
			percent = "35";
			List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid, Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());

			List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getValidByUidAndType(uid,
			CouponTypeEnum.rebatePercentCoupon.name());
			if (listCoupon == null \|\| listCoupon.size() == 0)
			return false;
			return true;
			}


			@Override
			public List<UserSystemCouponVO> listIncludeNotExchange(Long uid) throws Exception{
			public List<UserSystemCouponVO> listIncludeNotExchange(Long uid) throws Exception {
			// 过期券
			updateInvalidSate(uid);


			// 退回券
			sendBackTimeOutCoupon(uid);

			String percent = configService.get("exchange_rebate_percent");
			if (StringUtil.isNullOrEmpty(percent))
			percent = "35";

			List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getIncludeNotExchange(uid, Integer.parseInt(percent), CouponTypeEnum.rebatePercentCoupon.name());

			List<UserSystemCouponVO> listCoupon = userSystemCouponMapper.getValidByUidAndType(uid,
			CouponTypeEnum.rebatePercentCoupon.name());
			if (listCoupon == null \|\| listCoupon.size() == 0)
			return null;

			@@ -2335,14 +2329,14 @@
			if (source != null && "奖励券天天抽".equals(source)) {
			source = "天天抽";
			}


			SystemCoupon systemCoupon = userCouponVO.getSystemCoupon();
			if (systemCoupon == null) {
			continue; // 券信息不完整
			}

			systemCoupon = systemCouponService.selectByPrimaryKey(systemCoupon.getId());


			userCouponVO.setSource("来源：" + source);
			userCouponVO.setCouponName(systemCoupon.getName());
			userCouponVO.setCouponEffect(systemCoupon.getEffect());
			@@ -2389,4 +2383,114 @@

			return listCoupon;
			}

			@Override
			public List<UserSystemCoupon> getFreeCouponByType(Long uid, String type) {
			return userSystemCouponMapper.getFreeCouponByType(uid, type);
			}

			@RequestSerializableByKeyService(key = "#uid")
			@Override
			@Transactional(rollbackFor = Exception.class)
			public void triggerFreeCouponActivate(Long uid, String orderNo, Integer source) {
			if (uid == null \|\| source == null \|\| StringUtil.isNullOrEmpty(orderNo))
			return;

			UserSystemCoupon coupon = userSystemCouponMapper.getNeedActivateCouponByType(uid,
			CouponTypeEnum.freeCoupon.name());
			if (coupon == null)
			return;

			Long id = coupon.getId();
			UserSystemCouponActivate couponActivate = userSystemCouponActivateService.selectForUpdate(id);
			if (couponActivate == null)
			return;

			// 验证同订单是否存在
			String key = orderNo + "_" + source;
			String ordernos = couponActivate.getOrdernos();
			if (!StringUtil.isNullOrEmpty(ordernos)) {
			String[] array = ordernos.split(",");
			if (array != null)
			for (int i = 0; i < array.length; i++) {
			if (array[i].equals(key))
			return;
			}
			}

			// 激活数量
			boolean result = false;
			int limitNum = Integer.parseInt(configService.get(ConfigKeyEnum.freeCouponActivateNum.getKey()));

			Integer state = couponActivate.getState();
			int count = couponActivate.getCount();
			count++;
			if (count >= limitNum) {
			result = true;
			state = UserSystemCouponActivate.STATE_END;
			}

			if (StringUtil.isNullOrEmpty(ordernos)) {
			ordernos = key;
			} else {
			ordernos = ordernos + "," + key;
			}

			UserSystemCouponActivate updateActivate = new UserSystemCouponActivate();
			updateActivate.setId(id);
			updateActivate.setState(state);
			updateActivate.setCount(count);
			updateActivate.setOrdernos(ordernos);
			updateActivate.setUpdateTime(new Date());
			userSystemCouponActivateService.updateByPrimaryKeySelective(updateActivate);

			// 激活奖励券
			if (result) {
			activateFreeCoupon(coupon, limitNum);
			}
			}

			/**
			* 激活券
			*
			* @param coupon
			* @param activateNum
			*/
			@Transactional
			private void activateFreeCoupon(UserSystemCoupon coupon, int limitNum) {
			try {
			Date nowDate = new Date();
			SystemCoupon systemCoupon = coupon.getSystemCoupon();

			Integer expiryDay = systemCoupon.getExpiryDay();
			String endDay = DateUtil.plusDay(expiryDay - 1, nowDate);
			SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
			if (endDay != null && endDay.trim().length() > 0) {
			endDay += " 23:59:59";
			}
			Date endTime = format.parse(endDay);

			UserSystemCoupon userCoupon = new UserSystemCoupon();
			userCoupon.setId(coupon.getId());
			userCoupon.setStateActivated(1);
			userCoupon.setEndTime(endTime);
			userCoupon.setStartTime(nowDate);
			userCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKeySelective(userCoupon);

			// 消息
			executor.execute(new Runnable() {
			@Override
			public void run() {
			Long uid = coupon.getUid();
			String source = coupon.getSource();
			userOtherMsgNotificationService.freeCouponWinMsg(uid, "自购免单券", source, 1, "激活成功", nowDate, endTime);
			}
			});
			} catch (Exception e) {
			e.printStackTrace();
			LogHelper.errorDetailInfo(e);
			}
			}

			}