fanli-server.git

			@@ -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;
			@@ -18,6 +19,7 @@
			import com.yeshi.fanli.entity.bus.user.HongBaoV2;
			import com.yeshi.fanli.entity.bus.user.Order;
			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.UserSystemCouponRecord;
			import com.yeshi.fanli.entity.common.JumpDetailV2;
			@@ -26,15 +28,19 @@
			import com.yeshi.fanli.entity.system.SystemCoupon;
			import com.yeshi.fanli.entity.system.SystemCoupon.CouponTypeEnum;
			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;
			import com.yeshi.fanli.service.inter.order.OrderService;
			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.UserSystemCouponRecordService;
			@@ -90,6 +96,16 @@

			@Resource
			private UserMoneyMsgNotificationService userMoneyMsgNotificationService;

			@Resource
			private UserInfoExtraService userInfoExtraService;

			@Resource
			private ThreeSaleSerivce threeSaleSerivce;

			@Resource
			private UserOtherMsgNotificationService userOtherMsgNotificationService;


			// 券失效图片
			public final static String PIC_INVALID = "http://192.168.1.200/icon/mian_invalid.png";
			@@ -130,20 +146,87 @@
			}

			@Override
			public void insertUserCoupon(Long uid, String couponType,String source)throws UserSystemCouponException,Exception{

			if (couponType == null \|\| uid == null) {
			throw new UserSystemCouponException(1, "参数不正确");
			}

			SystemCoupon coupon= systemCouponService.getCouponByType(couponType);
			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;
			}
			}

			// 结束日期
			String endDay = DateUtil.plusDay(coupon.getExpiryDay(), 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(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);


			// 消息推送
			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();
			}
			}
			}



			@Override
			public List<UserSystemCouponVO> getUserCouponVOList(long start, int count, Long uid)
			throws UserSystemCouponException, Exception {

			if (uid == null) {
			return null;
			}


			// 更新过期券
			updateCounponInvalid(uid);
			// 退回券
			sendBackCoupon(uid);

			List<UserSystemCouponVO> listVO = userSystemCouponMapper.getUserCouponVOList(start, count, uid);
			if (listVO == null \|\| listVO.size() == 0) {
			return listVO;
			}

			// 数据组织
			listDataFactory(listVO);
			listDataFactory(listVO, uid);

			return listVO;
			}
			@@ -153,7 +236,7 @@
			*
			* @param listVO
			*/
			public void listDataFactory(List<UserSystemCouponVO> listVO) throws Exception{
			public void listDataFactory(List<UserSystemCouponVO> listVO, Long uid) throws Exception{

			for (UserSystemCouponVO userCouponVO : listVO) {

			@@ -174,21 +257,18 @@
			userCouponVO.setCouponEffect(systemCoupon.getEffect());
			userCouponVO.setCouponRule(systemCoupon.getRule());

			// 使用中状态改变为已使用
			// 使用状态
			Integer state = userCouponVO.getState();
			if (UserSystemCoupon.STATE_IN_USE == state) {
			state = UserSystemCoupon.STATE_END_USE;
			userCouponVO.setState(state);
			}

			// 按钮跳转

			Map<String, Object> jumpBtn = null;

			Integer stateActivated = userCouponVO.getStateActivated();

			if (stateActivated == null \|\| stateActivated == 0) {
			// 显示规则
			userCouponVO.setCouponRule(systemCoupon.getRemark());
			systemCoupon.setEffect("待激活");
			userCouponVO.setCouponEffect("待激活");

			// 状态未激活 -且未被使用
			if (UserSystemCoupon.STATE_CAN_USE == state) {
			@@ -197,9 +277,21 @@

			jumpBtn = new HashMap<String, Object>();
			Map<String, Object> jumpLink = new HashMap<String, Object>();
			jumpLink.put("url", configService.get("invite_activation_url"));

			UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);

			// 邀请队员界面
			if (userInfoExtra != null && userInfoExtra.getInviteCode() != null
			&& userInfoExtra.getInviteCode().trim().length() > 0) {
			// 邀请激活成功界面
			jumpLink.put("url", configService.get("invite_activation_success_url") + "?alert=true");
			} else {
			// 激活邀请码界面
			jumpLink.put("url", configService.get("invite_activation_url"));
			}

			jumpBtn.put("params", jumpLink);
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite"));
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("invite_web"));

			} else if (stateActivated == 1) {
			// 显示规则
			@@ -220,21 +312,26 @@
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("web"));

			} else if (CouponTypeEnum.rebatePercentCoupon == type) {
			// 返利奖励券
			// 返利奖励券- 跳转至订单到账界面
			jumpLink.put("state", 2);

			jumpBtn = new HashMap<String, Object>();
			jumpBtn.put("params", jumpLink);

			// 跳转订单列表
			jumpBtn.put("jumpDetail", jumpDetailV2Service.getByTypeCache("orderList"));

			}
			} else if (UserSystemCoupon.STATE_END_USE == state \|\| UserSystemCoupon.STATE_OVERDUE == state) {
			userCouponVO.setCouponPicture(PIC_INVALID);

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

			}

			// 券失效图片替换
			if (UserSystemCoupon.STATE_END_USE == state \|\| UserSystemCoupon.STATE_OVERDUE == state) {
			userCouponVO.setCouponPicture(PIC_INVALID);
			}

			userCouponVO.setJumpBtn(jumpBtn);

			String couponTerm = "有效期：";
			@@ -255,7 +352,6 @@
			differentDays = 0;
			}
			}

			// 剩余天数
			Map<String, Object> remainDays = new HashMap<String, Object>();
			remainDays.put("content", "还剩" + differentDays + "天过期");
			@@ -365,6 +461,12 @@
			if (uid == null) {
			throw new UserSystemCouponException(1, "用户未登录");
			}

			// 更新过期券
			updateCounponInvalid(uid);
			// 退回券
			sendBackCoupon(uid);

			// 订单相关的券
			List<SystemCoupon> couponList = systemCouponService.getOrderCouponList();
			if (couponList == null \|\| couponList.size() == 0) {
			@@ -379,6 +481,12 @@
			if (uid == null) {
			throw new UserSystemCouponException(1, "用户未登录");
			}

			// 更新过期券
			updateCounponInvalid(uid);
			// 退回券
			sendBackCoupon(uid);

			// 商品相关的券
			List<SystemCoupon> couponList = systemCouponService.getGoodsCouponList();
			if (couponList == null \|\| couponList.size() == 0) {
			@@ -437,6 +545,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
			@@ -542,6 +663,13 @@
			couponRecord.setCreateTime(date);
			couponRecord.setUpdateTime(date);
			userSystemCouponRecordService.insertSelective(couponRecord);

			// 消息推送
			try {
			userOtherMsgNotificationService.rewardCouponUsed(userSystemCoupon);
			} catch(Exception e) {
			LogHelper.errorDetailInfo(e);
			}
			}

			}
			@@ -822,4 +950,95 @@
			return userRecordVO;
			}

			@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 sendBackCoupon(Long uid) {
			// 超过120秒未被匹配的券
			List<UserSystemCouponRecord> list = userSystemCouponRecordService.getCouponByUsingTimeOut(uid, 120);
			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();
			// 状态初始化
			userSystemCoupon.setState(UserSystemCoupon.STATE_CAN_USE);
			userSystemCoupon.setUseTime(null);

			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.setStartTime(new Date());
			userSystemCoupon.setEndTime(endTime);
			userSystemCoupon.setUpdateTime(new Date());
			userSystemCouponMapper.updateByPrimaryKey(userSystemCoupon);
			}

			}




			}