CREATE TABLE `coupon` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自动增加ID',`region_id` bigint(20) DEFAULT NULL COMMENT '所属区域',`type` int(11) DEFAULT NULL COMMENT '所属类型,1为满减',`name` varchar(32) DEFAULT NULL COMMENT '优惠券名称',`img` varchar(64) DEFAULT NULL COMMENT '图片的URL地址',`start_time` datetime DEFAULT NULL COMMENT '优惠券开始时间',`end_time` datetime DEFAULT NULL COMMENT '优惠券结束时间',`money` decimal(11,2) DEFAULT NULL COMMENT '优惠券金额，用整数，固定值目前。',`status` int(11) DEFAULT NULL COMMENT '状态，0表示未开始，1表示进行中，-1表示结束',`remarks` varchar(512) DEFAULT NULL COMMENT '优惠券的说明',`create_time` datetime DEFAULT NULL COMMENT '创建时间',`full_money` decimal(12,2) DEFAULT NULL COMMENT '金额满',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='优惠券基础配置表';

CREATE TABLE `coupon_receive` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自动增加ID',`buyer_id` bigint(20) DEFAULT NULL COMMENT '买家ID',`coupon_id` bigint(20) DEFAULT NULL COMMENT '优惠券编号',`coupon_money` decimal(12,2) DEFAULT NULL COMMENT '券额',`create_time` datetime DEFAULT NULL COMMENT '领取时间',`full_money` decimal(12,2) DEFAULT NULL COMMENT '金额满',`status` int(11) DEFAULT NULL COMMENT '状态，1为已使用，0为已领取未使用，-1为已过期',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='优惠券领取记录表';

CREATE TABLE `coupon_logs` (`id` bigint(20) unsigned NOT NULL AUTO_INCREMENT COMMENT '自动增加ID',`buyer_id` bigint(20) DEFAULT NULL COMMENT '买家ID',`coupon_receive_id` bigint(20) DEFAULT NULL COMMENT '优惠券id',`order_number` varchar(64) DEFAULT NULL COMMENT '订单号',`order_original_amount` decimal(12,2) DEFAULT NULL COMMENT '原订单金额',`coupon_amount` decimal(11,2) DEFAULT NULL COMMENT '优惠券的金额',`order_final_amount` decimal(12,2) DEFAULT NULL COMMENT '抵扣优惠券之后的订单金额',`create_time` datetime DEFAULT NULL COMMENT '领取时间',`status` int(2) DEFAULT '0' COMMENT '日志状态: 默认为0，支付回调成功后为1',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='优惠券消费记录表';

/*** 优惠券controller*/
@RestController
@RequestMapping("/buyer/coupon")
public class CouponController extends BaseController {private static final Logger logger = LoggerFactory.getLogger(CouponController.class);@Autowiredprivate CouponReceiveService couponReceiveService;@Autowiredprivate UsersService usersService;/*** 查询买家所有优惠券* * @param request* @param response* @param buyerId* @return*/@RequestMapping(value = "/list", method = { RequestMethod.GET, RequestMethod.POST })public JsonResult getCouponList(HttpServletRequest request, HttpServletResponse response, Long buyerId) {try {if (buyerId == null) {return new JsonResult(JsonResultCode.FAILURE, "买家不存在", "");}List<CouponReceive> result = couponReceiveService.selectAllByBuyerId(buyerId);return new JsonResult(JsonResultCode.SUCCESS, "查询成功", result);} catch (Exception ex) {logger.error("[CouponController][getCouponList] exception", ex);return new JsonResult(JsonResultCode.FAILURE, "系统错误,请稍后重试", "");}}/*** 判断买家是否可以领取优惠券* * @param request* @param response* @param buyerId* @return*/@RequestMapping(value = "/judge", method = { RequestMethod.GET, RequestMethod.POST })public JsonResult judgeReceive(HttpServletRequest request, HttpServletResponse response, Long buyerId) {try {// 判断当前用户是否可用Users users = usersService.getUsersById(buyerId);if (users == null) {logger.info("OrderController.judgeReceive.buyerId " + buyerId);return new JsonResult(JsonResultCode.FAILURE, "你的账号有误，请重新登录", "");}int status = users.getStatus();if (UserStatus.FORBIDDEN == status) {return new JsonResult(JsonResultCode.FAILURE, "你的账号已经被禁用了,请联系公司客服", "");}List<Coupon> result = couponReceiveService.selectByBuyerId(buyerId);if (CollectionUtils.isEmpty(result)) {result = new ArrayList<Coupon>();}return new JsonResult(JsonResultCode.SUCCESS, "查询成功", result);} catch (Exception ex) {logger.error("[CouponController][judgeReceive] exception", ex);return new JsonResult(JsonResultCode.FAILURE, "系统错误,请稍后重试", "");}}/*** 买家领取优惠券* * @param request* @param response* @param buyerId* @return*/@RequestMapping(value = "/add", method = { RequestMethod.GET, RequestMethod.POST })public JsonResult saveCoupon(HttpServletRequest request, HttpServletResponse response, Long buyerId,Long couponId) {try {// 判断当前用户是否可用Users users = usersService.getUsersById(buyerId);if (users == null) {logger.info("OrderController.saveCoupon.buyerId " + buyerId);return new JsonResult(JsonResultCode.FAILURE, "你的账号有误，请重新登录", "");}//判断当前用户的状态是否可用int status = users.getStatus();if (UserStatus.FORBIDDEN == status) {return new JsonResult(JsonResultCode.FAILURE, "你的账号已经被禁用了,请联系公司客服", "");}if (couponId == null) {return new JsonResult(JsonResultCode.SUCCESS, "活动已经结束", "");}//新增int result = couponReceiveService.insert(buyerId, couponId);if (result == -1) {return new JsonResult(JsonResultCode.SUCCESS, "领取失败,已经领取过优惠券了", "");} else if (result == 0) {return new JsonResult(JsonResultCode.FAILURE, "领取失败,活动已经结束", "");} else {return new JsonResult(JsonResultCode.SUCCESS, "领取成功", "");}} catch (Exception ex) {logger.error("[CouponController][saveCoupon] exception", ex);return new JsonResult(JsonResultCode.FAILURE, "系统错误,请稍后重试", "");}}
}