0915

controllers/auth.go

@@ -39,10 +39,10 @@ func (c *BaseController) authenticate() {
 
 // SetTokenExipre 设置 token 过期
 func (c *BaseController) SetTokenExipre() {
-	token := c.Context.Get("token")
-	if token != nil {
-		c.serv.UpdateTokenExpire(token.(string))
-	}
+	// token := c.Context.Get("token")
+	// if token != nil {
+	// 	c.serv.UpdateTokenExpire(token.(string))
+	// }
 
 	c.Context.Set("token", "")
 }

controllers/card/card.go

@@ -9,6 +9,7 @@ import (
 	"spaceofcheng/services/service/card"
 	"spaceofcheng/services/utils"
 	"strings"
+	"tolet/models/model"
 )
 
 // CardController 商品
@@ -210,3 +211,25 @@ func (c *CardController) GetCaseUsableCard() {
 
 	c.ResponseJSON(cards)
 }
+
+// ReceiveCard 卡领取
+func (c *CardController) ReceiveCard() {
+	id := c.GetString(":id")
+	saleid := c.GetString("saleid")
+	serialcode := c.GetString("serialcode")
+	cust := c.Context.Get("customer").(model.TaCustomer)
+
+	if cust.Phone == "" {
+		c.ResponseError(
+			errors.New("用户未登录或绑定"),
+			http.StatusNotAcceptable,
+		)
+	}
+
+	err := c.serv.ReceiveCard(id, saleid, serialcode)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("领取成功！")
+}

controllers/coupon/coupon.go

@@ -9,6 +9,7 @@ import (
 	"spaceofcheng/services/service/coupon"
 	"spaceofcheng/services/utils"
 	"strings"
+	"tolet/models/model"
 )
 
 // CouponController 商品
@@ -219,6 +220,47 @@ func (c *CouponController) GetCaseUsableCoupon() {
 	if err != nil {
 		c.ResponseError(err)
 	}
-
 	c.ResponseJSON(coupons)
 }
+
+// ReceiveCoupon 卡领取
+func (c *CouponController) ReceiveCoupon() {
+	id := c.GetString(":id")
+	saleid := c.GetString("saleid")
+	serialcode := c.GetString("serialcode")
+	cust := c.Context.Get("customer").(model.TaCustomer)
+
+	if cust.Phone == "" {
+		c.ResponseError(
+			errors.New("用户未登录或绑定"),
+			http.StatusNotAcceptable,
+		)
+	}
+
+	err := c.serv.ReceiveCoupon(id, saleid, serialcode)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("领取成功！")
+}
+
+// ChannelReceiveCoupon 渠道端卡领取
+func (c *CouponController) ChannelReceiveCoupon() {
+	id := c.GetString(":id")
+	cust := c.Context.Get("customer").(model.TaCustomer)
+
+	if cust.Phone == "" {
+		c.ResponseError(
+			errors.New("用户未登录或绑定"),
+			http.StatusNotAcceptable,
+		)
+	}
+
+	err := c.serv.ChannelReceiveCoupon(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("领取成功！")
+}

controllers/gymcard/gymcard.go

@@ -130,3 +130,21 @@ func (c *GymcardController) VerifyCustomerGymcard() {
 	}
 	c.ResponseJSON("核销成功")
 }
+
+// GiveGymToCustomer 赠送健身卡给客户
+func (c *GymcardController) GiveGymToCustomer() {
+	id := c.GetString(":id")
+	if id == "" {
+		c.ResponseError(errors.New("未指定卡"))
+	}
+
+	uids := c.GetString(":users")
+	if uids == "" {
+		c.ResponseError(errors.New("未指定赠送人"))
+	}
+	err := c.dao.GiveCardToCustomer(id, uids)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON("赠送成功！")
+}

log/common.log

@@ -9,3 +9,341 @@
 		JOIN sys_user_type s ON t.user_id = s.user_id
 		JOIN td_use' at line 4
 2018/09/14 18:49:55 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:51:10 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:51:28 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:51:50 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:51:57 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:52:05 [E] 解析 Token 失败: token contains an invalid number of segments
+2018/09/14 18:53:02 [E] 用户没有设置默认案场
+2018/09/14 18:56:00 [E] 获取优惠券失败: a pointer to a pointer is not allowed
+2018/09/14 18:56:01 [E] 获取优惠券失败: a pointer to a pointer is not allowed
+2018/09/14 18:57:23 [E] 获取优惠券失败: Error 1146: Table 'spaceofcheng.ta_coupon_coupon' doesn't exist
+2018/09/14 18:57:29 [E] 获取优惠券失败: Error 1146: Table 'spaceofcheng.ta_coupon_coupon' doesn't exist
+2018/09/14 18:57:55 [E] 获取优惠券失败: 无优惠券信息
+2018/09/14 18:57:56 [E] 获取优惠券失败: 无优惠券信息
+2018/09/14 18:59:40 [E] 获取人员信息失败: 您没有权限查看此用户的数据！
+2018/09/14 19:03:57 [E] 用户没有设置默认案场
+2018/09/14 19:04:01 [E] 用户没有设置默认案场
+2018/09/14 19:04:04 [E] 用户没有设置默认案场
+2018/09/14 19:04:06 [E] 用户没有设置默认案场
+2018/09/14 19:04:08 [E] 用户没有设置默认案场
+2018/09/14 19:04:12 [E] 用户没有设置默认案场
+2018/09/14 19:04:14 [E] 用户没有设置默认案场
+2018/09/14 19:04:15 [E] 用户没有设置默认案场
+2018/09/14 19:04:15 [E] 用户没有设置默认案场
+2018/09/14 19:04:18 [E] 用户没有设置默认案场
+2018/09/14 19:04:31 [E] 用户没有设置默认案场
+2018/09/14 19:04:33 [E] 用户没有设置默认案场
+2018/09/14 19:04:35 [E] 用户没有设置默认案场
+2018/09/14 19:04:49 [E] 用户没有设置默认案场
+2018/09/14 19:06:08 [E] 用户没有设置默认案场
+2018/09/14 19:06:12 [E] 用户没有设置默认案场
+2018/09/14 19:06:12 [E] 用户没有设置默认案场
+2018/09/14 19:06:13 [E] 用户没有设置默认案场
+2018/09/14 19:06:14 [E] 用户没有设置默认案场
+2018/09/14 19:33:44 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/14 19:33:44 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/14 19:33:48 [E] 用户没有设置默认案场
+2018/09/14 19:33:48 [E] 用户没有设置默认案场
+2018/09/14 19:33:48 [E] 用户没有设置默认案场
+2018/09/14 19:33:50 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/14 19:33:50 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/14 19:33:55 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/14 19:33:55 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/14 19:41:54 [E] 用户没有设置默认案场
+2018/09/14 19:41:54 [E] 用户没有设置默认案场
+2018/09/14 19:41:55 [E] 用户没有设置默认案场
+2018/09/14 19:42:03 [E] 用户没有设置默认案场
+2018/09/14 19:42:03 [E] 用户没有设置默认案场
+2018/09/14 19:42:03 [E] 用户没有设置默认案场
+2018/09/14 19:42:44 [E] 用户没有设置默认案场
+2018/09/14 19:42:44 [E] 用户没有设置默认案场
+2018/09/14 19:42:45 [E] 用户没有设置默认案场
+2018/09/14 19:43:42 [E] 用户没有设置默认案场
+2018/09/14 19:43:42 [E] 用户没有设置默认案场
+2018/09/14 19:43:42 [E] 用户没有设置默认案场
+2018/09/14 19:43:57 [E] 用户没有设置默认案场
+2018/09/14 19:43:57 [E] 用户没有设置默认案场
+2018/09/14 19:43:58 [E] 用户没有设置默认案场
+2018/09/14 19:44:47 [E] 用户没有设置默认案场
+2018/09/14 19:44:47 [E] 用户没有设置默认案场
+2018/09/14 19:44:47 [E] 用户没有设置默认案场
+2018/09/14 19:45:28 [E] 用户没有设置默认案场
+2018/09/14 19:45:28 [E] 用户没有设置默认案场
+2018/09/14 19:45:28 [E] 用户没有设置默认案场
+2018/09/14 20:11:26 [E] 用户没有设置默认案场
+2018/09/14 20:11:28 [E] 用户没有设置默认案场
+2018/09/14 20:11:28 [E] 用户没有设置默认案场
+2018/09/14 20:11:39 [E] 用户没有设置默认案场
+2018/09/14 20:11:39 [E] 用户没有设置默认案场
+2018/09/14 20:11:40 [E] 用户没有设置默认案场
+2018/09/14 20:11:42 [E] 用户没有设置默认案场
+2018/09/14 20:11:42 [E] 用户没有设置默认案场
+2018/09/14 20:11:42 [E] 用户没有设置默认案场
+2018/09/14 20:11:43 [E] 用户没有设置默认案场
+2018/09/14 20:11:43 [E] 用户没有设置默认案场
+2018/09/14 20:11:43 [E] 用户没有设置默认案场
+2018/09/14 20:11:52 [E] 用户没有设置默认案场
+2018/09/14 20:12:02 [E] 用户没有设置默认案场
+2018/09/14 20:13:30 [E] 用户没有设置默认案场
+2018/09/14 20:13:30 [E] 用户没有设置默认案场
+2018/09/14 20:13:30 [E] 用户没有设置默认案场
+2018/09/14 20:13:40 [E] 用户没有设置默认案场
+2018/09/14 20:13:40 [E] 用户没有设置默认案场
+2018/09/14 20:13:46 [E] 用户没有设置默认案场
+2018/09/14 20:13:46 [E] 用户没有设置默认案场
+2018/09/14 20:13:46 [E] 用户没有设置默认案场
+2018/09/14 20:13:55 [E] 用户没有设置默认案场
+2018/09/14 20:14:26 [E] 用户没有设置默认案场
+2018/09/14 20:14:29 [E] 用户没有设置默认案场
+2018/09/14 20:14:29 [E] 用户没有设置默认案场
+2018/09/14 20:14:29 [E] 用户没有设置默认案场
+2018/09/14 20:14:30 [E] 用户没有设置默认案场
+2018/09/14 20:14:30 [E] 用户没有设置默认案场
+2018/09/14 20:14:30 [E] 用户没有设置默认案场
+2018/09/14 20:14:36 [E] 用户没有设置默认案场
+2018/09/14 20:15:35 [E] 用户没有设置默认案场
+2018/09/14 20:15:35 [E] 用户没有设置默认案场
+2018/09/14 20:15:35 [E] 用户没有设置默认案场
+2018/09/14 20:15:41 [E] 用户没有设置默认案场
+2018/09/14 20:15:41 [E] 用户没有设置默认案场
+2018/09/14 20:15:42 [E] 用户没有设置默认案场
+2018/09/14 20:15:42 [E] 用户没有设置默认案场
+2018/09/14 20:15:46 [E] 用户没有设置默认案场
+2018/09/14 20:24:55 [E] 用户没有设置默认案场
+2018/09/14 20:24:55 [E] 用户没有设置默认案场
+2018/09/14 20:24:55 [E] 用户没有设置默认案场
+2018/09/14 22:08:53 [E] 用户没有设置默认案场
+2018/09/14 22:08:56 [E] 用户没有设置默认案场
+2018/09/14 22:08:56 [E] 用户没有设置默认案场
+2018/09/14 22:08:57 [E] 用户没有设置默认案场
+2018/09/14 22:08:57 [E] 用户没有设置默认案场
+2018/09/14 22:08:58 [E] 用户没有设置默认案场
+2018/09/14 22:10:27 [E] 用户没有设置默认案场
+2018/09/14 22:10:28 [E] 用户没有设置默认案场
+2018/09/14 22:10:28 [E] 用户没有设置默认案场
+2018/09/14 22:10:30 [E] 用户没有设置默认案场
+2018/09/14 22:10:32 [E] 用户没有设置默认案场
+2018/09/14 22:10:32 [E] 用户没有设置默认案场
+2018/09/14 22:10:36 [E] 用户没有设置默认案场
+2018/09/14 22:10:37 [E] 用户没有设置默认案场
+2018/09/14 22:10:37 [E] 用户没有设置默认案场
+2018/09/14 22:10:39 [E] 用户没有设置默认案场
+2018/09/14 22:10:42 [E] 用户没有设置默认案场
+2018/09/14 22:10:43 [E] 用户没有设置默认案场
+2018/09/14 22:11:18 [E] 用户没有设置默认案场
+2018/09/14 22:11:18 [E] 用户没有设置默认案场
+2018/09/14 22:11:32 [E] 用户没有设置默认案场
+2018/09/14 22:11:48 [E] 用户没有设置默认案场
+2018/09/14 22:11:56 [E] 用户没有设置默认案场
+2018/09/14 22:11:56 [E] 用户没有设置默认案场
+2018/09/14 22:13:30 [E] 用户没有设置默认案场
+2018/09/14 22:13:32 [E] 用户没有设置默认案场
+2018/09/14 22:13:32 [E] 用户没有设置默认案场
+2018/09/14 22:15:12 [E] 用户没有设置默认案场
+2018/09/14 22:15:12 [E] 用户没有设置默认案场
+2018/09/14 22:15:22 [E] 用户没有设置默认案场
+2018/09/14 22:15:23 [E] 用户没有设置默认案场
+2018/09/14 22:15:24 [E] 用户没有设置默认案场
+2018/09/14 22:15:47 [E] 用户没有设置默认案场
+2018/09/14 22:15:47 [E] 用户没有设置默认案场
+2018/09/14 22:15:52 [E] 用户没有设置默认案场
+2018/09/14 22:15:55 [E] 用户没有设置默认案场
+2018/09/14 22:15:55 [E] 用户没有设置默认案场
+2018/09/14 22:15:57 [E] 用户没有设置默认案场
+2018/09/14 22:15:57 [E] 用户没有设置默认案场
+2018/09/14 22:16:05 [E] 用户没有设置默认案场
+2018/09/14 22:16:06 [E] 用户没有设置默认案场
+2018/09/14 22:16:06 [E] 用户没有设置默认案场
+2018/09/14 22:16:08 [E] 用户没有设置默认案场
+2018/09/14 22:16:08 [E] 用户没有设置默认案场
+2018/09/14 22:16:54 [E] 用户没有设置默认案场
+2018/09/14 22:16:54 [E] 用户没有设置默认案场
+2018/09/14 22:16:55 [E] 用户没有设置默认案场
+2018/09/14 22:17:17 [E] 用户没有设置默认案场
+2018/09/14 22:17:17 [E] 用户没有设置默认案场
+2018/09/14 22:17:18 [E] 用户没有设置默认案场
+2018/09/14 22:17:48 [E] 用户没有设置默认案场
+2018/09/14 22:17:48 [E] 用户没有设置默认案场
+2018/09/14 22:17:49 [E] 用户没有设置默认案场
+2018/09/14 22:18:43 [E] 用户没有设置默认案场
+2018/09/14 22:18:43 [E] 用户没有设置默认案场
+2018/09/14 22:18:43 [E] 用户没有设置默认案场
+2018/09/14 22:19:23 [E] 用户没有设置默认案场
+2018/09/14 22:19:23 [E] 用户没有设置默认案场
+2018/09/14 22:19:24 [E] 用户没有设置默认案场
+2018/09/14 22:19:43 [E] 用户没有设置默认案场
+2018/09/14 22:19:43 [E] 用户没有设置默认案场
+2018/09/14 22:19:44 [E] 用户没有设置默认案场
+2018/09/14 22:20:23 [E] 用户没有设置默认案场
+2018/09/14 22:20:24 [E] 用户没有设置默认案场
+2018/09/14 22:24:13 [E] 用户没有设置默认案场
+2018/09/14 22:24:24 [E] 用户没有设置默认案场
+2018/09/14 22:24:31 [E] 用户没有设置默认案场
+2018/09/14 22:24:31 [E] 用户没有设置默认案场
+2018/09/14 22:27:41 [E] 用户没有设置默认案场
+2018/09/14 22:27:41 [E] 用户没有设置默认案场
+2018/09/14 22:27:44 [E] 用户没有设置默认案场
+2018/09/14 22:27:46 [E] 用户没有设置默认案场
+2018/09/14 22:27:47 [E] 用户没有设置默认案场
+2018/09/14 22:27:49 [E] 用户没有设置默认案场
+2018/09/14 22:27:52 [E] 用户没有设置默认案场
+2018/09/14 22:27:53 [E] 用户没有设置默认案场
+2018/09/14 22:27:54 [E] 用户没有设置默认案场
+2018/09/14 22:27:56 [E] 用户没有设置默认案场
+2018/09/14 22:27:56 [E] 用户没有设置默认案场
+2018/09/14 22:27:58 [E] 用户没有设置默认案场
+2018/09/14 22:28:02 [E] 用户没有设置默认案场
+2018/09/14 22:28:03 [E] 用户没有设置默认案场
+2018/09/14 22:28:03 [E] 用户没有设置默认案场
+2018/09/14 22:28:06 [E] 用户没有设置默认案场
+2018/09/14 22:28:06 [E] 用户没有设置默认案场
+2018/09/14 22:28:10 [E] 用户没有设置默认案场
+2018/09/14 22:28:12 [E] 用户没有设置默认案场
+2018/09/14 22:28:12 [E] 用户没有设置默认案场
+2018/09/14 22:28:14 [E] 用户没有设置默认案场
+2018/09/14 22:28:15 [E] 用户没有设置默认案场
+2018/09/14 22:28:24 [E] 用户没有设置默认案场
+2018/09/14 22:28:24 [E] 用户没有设置默认案场
+2018/09/14 22:28:35 [E] 用户没有设置默认案场
+2018/09/14 22:30:28 [E] 用户没有设置默认案场
+2018/09/14 22:30:28 [E] 用户没有设置默认案场
+2018/09/14 22:30:28 [E] 用户没有设置默认案场
+2018/09/14 22:30:30 [E] 用户没有设置默认案场
+2018/09/14 22:30:32 [E] 用户没有设置默认案场
+2018/09/14 22:30:32 [E] 用户没有设置默认案场
+2018/09/14 22:31:11 [E] 用户没有设置默认案场
+2018/09/14 22:31:11 [E] 用户没有设置默认案场
+2018/09/14 22:31:14 [E] 用户没有设置默认案场
+2018/09/14 22:31:14 [E] 用户没有设置默认案场
+2018/09/14 22:31:17 [E] 用户没有设置默认案场
+2018/09/14 22:31:17 [E] 用户没有设置默认案场
+2018/09/14 22:31:17 [E] 用户没有设置默认案场
+2018/09/14 22:31:20 [E] 用户没有设置默认案场
+2018/09/14 22:31:21 [E] 用户没有设置默认案场
+2018/09/14 22:31:21 [E] 用户没有设置默认案场
+2018/09/14 22:31:22 [E] 用户没有设置默认案场
+2018/09/14 22:31:22 [E] 用户没有设置默认案场
+2018/09/14 22:31:22 [E] 用户没有设置默认案场
+2018/09/14 22:31:25 [E] 用户没有设置默认案场
+2018/09/14 22:31:25 [E] 用户没有设置默认案场
+2018/09/14 22:31:31 [E] 用户没有设置默认案场
+2018/09/14 22:31:34 [E] 用户没有设置默认案场
+2018/09/14 22:31:34 [E] 用户没有设置默认案场
+2018/09/14 22:31:51 [E] 用户没有设置默认案场
+2018/09/14 22:31:51 [E] 课程截止时间必须大于开始时间！
+2018/09/14 22:32:05 [E] 用户没有设置默认案场
+2018/09/14 22:32:05 [E] 用户没有设置默认案场
+2018/09/14 22:32:05 [E] 用户没有设置默认案场
+2018/09/14 22:32:19 [E] 用户没有设置默认案场
+2018/09/14 22:32:23 [E] 用户没有设置默认案场
+2018/09/14 22:32:24 [E] 用户没有设置默认案场
+2018/09/14 22:32:37 [E] 用户没有设置默认案场
+2018/09/14 22:32:38 [E] 用户没有设置默认案场
+2018/09/14 22:32:45 [E] 用户没有设置默认案场
+2018/09/14 22:33:03 [E] 用户没有设置默认案场
+2018/09/14 22:33:03 [E] 用户没有设置默认案场
+2018/09/14 22:33:10 [E] 用户没有设置默认案场
+2018/09/14 22:33:11 [E] 用户没有设置默认案场
+2018/09/14 22:33:15 [E] 用户没有设置默认案场
+2018/09/14 22:33:15 [E] 用户没有设置默认案场
+2018/09/14 22:33:18 [E] 用户没有设置默认案场
+2018/09/14 22:33:18 [E] 用户没有设置默认案场
+2018/09/14 22:33:35 [E] 用户没有设置默认案场
+2018/09/14 22:33:35 [E] 用户没有设置默认案场
+2018/09/14 22:33:48 [E] 用户没有设置默认案场
+2018/09/14 22:33:50 [E] 用户没有设置默认案场
+2018/09/14 22:33:52 [E] 用户没有设置默认案场
+2018/09/14 22:33:52 [E] 用户没有设置默认案场
+2018/09/14 22:33:54 [E] 用户没有设置默认案场
+2018/09/14 22:33:54 [E] 用户没有设置默认案场
+2018/09/14 22:33:57 [E] 用户没有设置默认案场
+2018/09/14 22:33:58 [E] 用户没有设置默认案场
+2018/09/14 22:33:58 [E] 用户没有设置默认案场
+2018/09/14 22:33:59 [E] 用户没有设置默认案场
+2018/09/14 22:34:02 [E] 用户没有设置默认案场
+2018/09/14 22:34:38 [E] 用户没有设置默认案场
+2018/09/14 22:34:41 [E] 用户没有设置默认案场
+2018/09/14 22:35:24 [E] 用户没有设置默认案场
+2018/09/14 22:35:24 [E] 接收优惠券信息失败: parsing time """" as ""2006-01-02T15:04:05Z07:00"": cannot parse """ as "2006"
+2018/09/14 22:36:00 [E] 用户没有设置默认案场
+2018/09/14 22:36:00 [E] 接收优惠券信息失败: parsing time """" as ""2006-01-02T15:04:05Z07:00"": cannot parse """ as "2006"
+2018/09/14 22:39:29 [E] 用户没有设置默认案场
+2018/09/14 22:39:36 [E] 用户没有设置默认案场
+2018/09/14 22:39:37 [E] 用户没有设置默认案场
+2018/09/14 22:39:48 [E] 用户没有设置默认案场
+2018/09/14 22:39:49 [E] 用户没有设置默认案场
+2018/09/14 22:39:50 [E] 用户没有设置默认案场
+2018/09/14 22:39:50 [E] 用户没有设置默认案场
+2018/09/14 22:39:51 [E] 用户没有设置默认案场
+2018/09/14 22:39:52 [E] 用户没有设置默认案场
+2018/09/14 22:39:53 [E] 用户没有设置默认案场
+2018/09/14 22:39:53 [E] 用户没有设置默认案场
+2018/09/15 11:29:11 [E] 用户没有设置默认案场
+2018/09/15 11:29:47 [E] 用户没有设置默认案场
+2018/09/15 11:30:22 [E] 用户没有设置默认案场
+2018/09/15 11:30:22 [E] 用户没有设置默认案场
+2018/09/15 11:30:23 [E] 用户没有设置默认案场
+2018/09/15 11:30:23 [E] 用户没有设置默认案场
+2018/09/15 11:30:30 [E] 用户没有设置默认案场
+2018/09/15 11:30:31 [E] 用户没有设置默认案场
+2018/09/15 11:30:31 [E] 用户没有设置默认案场
+2018/09/15 11:30:32 [E] 用户没有设置默认案场
+2018/09/15 11:30:33 [E] 用户没有设置默认案场
+2018/09/15 11:30:33 [E] 用户没有设置默认案场
+2018/09/15 11:36:00 [E] 用户没有设置默认案场
+2018/09/15 11:36:00 [E] 用户没有设置默认案场
+2018/09/15 11:36:10 [E] 用户没有设置默认案场
+2018/09/15 11:36:11 [E] 用户没有设置默认案场
+2018/09/15 11:36:13 [E] 用户没有设置默认案场
+2018/09/15 11:36:13 [E] 用户没有设置默认案场
+2018/09/15 11:36:19 [E] 用户没有设置默认案场
+2018/09/15 11:36:19 [E] 用户没有设置默认案场
+2018/09/15 11:36:50 [E] 用户没有设置默认案场
+2018/09/15 11:36:50 [E] 用户没有设置默认案场
+2018/09/15 11:36:54 [E] 用户没有设置默认案场
+2018/09/15 11:36:54 [E] 用户没有设置默认案场
+2018/09/15 11:36:54 [E] 用户没有设置默认案场
+2018/09/15 11:37:07 [E] 用户没有设置默认案场
+2018/09/15 11:37:08 [E] 用户没有设置默认案场
+2018/09/15 11:37:10 [E] 用户没有设置默认案场
+2018/09/15 11:37:10 [E] 用户没有设置默认案场
+2018/09/15 11:37:10 [E] 用户没有设置默认案场
+2018/09/15 11:37:18 [E] 用户没有设置默认案场
+2018/09/15 11:37:18 [E] 用户没有设置默认案场
+2018/09/15 11:37:23 [E] 用户没有设置默认案场
+2018/09/15 11:37:23 [E] 用户没有设置默认案场
+2018/09/15 11:37:23 [E] 用户没有设置默认案场
+2018/09/15 11:37:32 [E] 用户没有设置默认案场
+2018/09/15 11:37:36 [E] 用户没有设置默认案场
+2018/09/15 11:45:20 [E] 用户没有设置默认案场
+2018/09/15 11:45:22 [E] 用户没有设置默认案场
+2018/09/15 11:45:22 [E] 用户没有设置默认案场
+2018/09/15 11:46:04 [E] 用户没有设置默认案场
+2018/09/15 11:46:04 [E] 用户没有设置默认案场
+2018/09/15 11:46:11 [E] 用户没有设置默认案场
+2018/09/15 11:46:11 [E] 用户没有设置默认案场
+2018/09/15 11:46:16 [E] 用户没有设置默认案场
+2018/09/15 11:46:16 [E] 用户没有设置默认案场
+2018/09/15 11:46:20 [E] 用户没有设置默认案场
+2018/09/15 11:46:23 [E] 用户没有设置默认案场
+2018/09/15 11:46:56 [E] 用户没有设置默认案场
+2018/09/15 11:47:01 [E] 用户没有设置默认案场
+2018/09/15 11:47:25 [E] 用户没有设置默认案场
+2018/09/15 11:47:25 [E] 用户没有设置默认案场
+2018/09/15 11:47:36 [E] 用户没有设置默认案场
+2018/09/15 11:47:36 [E] 用户没有设置默认案场
+2018/09/15 13:28:31 [E] 用户没有设置默认案场
+2018/09/15 13:28:34 [E] 用户没有设置默认案场
+2018/09/15 13:29:21 [E] 用户没有设置默认案场
+2018/09/15 13:29:56 [E] 用户没有设置默认案场
+2018/09/15 13:30:01 [E] 用户没有设置默认案场
+2018/09/15 13:30:04 [E] 用户没有设置默认案场
+2018/09/15 13:30:04 [E] 用户没有设置默认案场
+2018/09/15 13:30:07 [E] 用户没有设置默认案场
+2018/09/15 13:30:10 [E] 用户没有设置默认案场
+2018/09/15 13:45:16 [E] 用户没有设置默认案场
+2018/09/15 13:45:16 [E] 用户没有设置默认案场
+2018/09/15 13:45:18 [E] 用户没有设置默认案场
+2018/09/15 13:45:24 [E] 用户没有设置默认案场
+2018/09/15 13:45:24 [E] 用户没有设置默认案场

models/card/card.go

@@ -10,8 +10,6 @@ import (
 	"strings"
 	"time"
 
-	"github.com/astaxie/beego"
-
 	"github.com/go-xorm/xorm"
 	"github.com/yl10/kit/guid"
 )
@@ -110,6 +108,13 @@ func (m *CardDAO) AddCard(card *model.TaCouponCard) error {
 	return nil
 }
 
+// GetCardInfoByID 获取卡信息
+func (m *CardDAO) GetCardInfoByID(cardid string) (*model.TaCouponCard, error) {
+	var card = model.TaCouponCard{}
+	_, err := m.db.Where("card_id=?", cardid).Get(&card)
+	return &card, err
+}
+
 // UpdateCard 更新体验卡
 func (m *CardDAO) UpdateCard(card *model.TaCouponCard, cols []string) error {
 	if card.CardId == "" {
@@ -218,22 +223,27 @@ func (m *CardDAO) CheckCustCard(custID, CardID string, startDate, endDate time.T
 type CaseUsableCard struct {
 	model.TaCouponCard `xorm:"extends"`
 	CustomerCard       []model.TaCustomerCard
+	Share              *model.TaExperienceCardShare
 }
 
 // GetCaseUsableCard 获取案场可用卡信息
 func (m *CardDAO) GetCaseUsableCard(caseid, userid string, page, pageSize int) ([]CaseUsableCard, error) {
 	var cards []CaseUsableCard
 	sql := `select * from ta_coupon_card where case_id=? and status=? and end_date>now() order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
-	beego.Error(sql)
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL).Find(&cards)
-	if userid != "" {
-		for inx, card := range cards {
+	for inx, card := range cards {
+		if userid != "" {
 			cCards, err := m.GetCustomerCardByCardAndUser(card.CardId, userid)
 			if err != nil {
 				return nil, err
 			}
 			cards[inx].CustomerCard = cCards
 		}
+		share, err := m.GetCardShareByCardID(card.CardId)
+		if err != nil {
+			return nil, err
+		}
+		cards[inx].Share = share
 	}
 	return cards, err
 }
@@ -349,3 +359,16 @@ func (m *CardDAO) GetCustomerCardByID(id string) (*CustomerCardWithShare, error)
 	customerCard.Share = share
 	return customerCard, err
 }
+
+// CheckBySerialCode 根据批次码判断
+func (m *CardDAO) CheckBySerialCode(cardid, code string) (bool, error) {
+	var customerCards []model.TaCustomerCard
+	err := m.db.Where("card_id=?", cardid).And("serial_code=?", code).Find(&customerCards)
+	if err != nil {
+		return false, err
+	}
+	if len(customerCards) == 0 {
+		return true, nil
+	}
+	return false, nil
+}

models/coupon/coupon.go

@@ -76,15 +76,15 @@ func (m *CouponDAO) GetCouponInfoByID(id string) (*CouponInfo, error) {
 	}
 
 	// 分享
-	share := new(model.TaCouponShare)
-	if _, err := m.db.Where("coupon_id=?", id).And("status=?", models.STATUS_NORMAL).Get(share); err != nil {
+	share, err := m.GetCouponShareByCouponID(id)
+	if err != nil {
 		return nil, err
 	}
 
 	cp.Targets = targes
 	cp.Images = imgs
 	cp.Rules = rules
-	cp.Share = *share
+	cp.Share = share
 
 	return cp, nil
 }
@@ -293,18 +293,30 @@ func (m *CouponDAO) GetCaseUsableCoupon(caseid, userid string, page, pageSize in
 	var Coupons []CaseCouponDetail
 	sql := `select * from ta_coupon where case_id=? and status=? and end_date>now() order by create_date limit ` + strconv.Itoa((page-1)*pageSize) + `, ` + strconv.Itoa(pageSize)
 	err := m.db.Sql(sql, caseid, models.STATUS_NORMAL).Find(&Coupons)
-	if userid != "" {
-		for inx, Coupon := range Coupons {
-			cCoupons, err := m.GetCustomerCouponByCouponAndUser(Coupon.CouponId, userid)
+	for inx, coupon := range Coupons {
+		if userid != "" {
+			cCoupons, err := m.GetCustomerCouponByCouponAndUser(coupon.CouponId, userid)
 			if err != nil {
 				return nil, err
 			}
 			Coupons[inx].CustomerCoupon = cCoupons
 		}
+		share, err := m.GetCouponShareByCouponID(coupon.CouponId)
+		if err != nil {
+			return nil, err
+		}
+		Coupons[inx].Share = share
 	}
 	return Coupons, err
 }
 
+// GetCouponShareByCouponID 根据优惠券信息获取分享信息
+func (m *CouponDAO) GetCouponShareByCouponID(couponid string) (*model.TaCouponShare, error) {
+	var share = model.TaCouponShare{}
+	_, err := m.db.Where("coupon_id=?", couponid).Get(&share)
+	return &share, err
+}
+
 // GetCaseUsableCouponCount 获取案场可用优惠券数量
 func (m *CouponDAO) GetCaseUsableCouponCount(caseid, userid string) (int, error) {
 	var Coupons []CaseCouponDetail
@@ -324,8 +336,8 @@ func (m *CouponDAO) GetCustomerCouponByCouponAndUser(couponid, userid string) ([
 // GetCouponDetail 获取优惠券详情
 func (m *CouponDAO) GetCouponDetail(couponid string) (*CaseCouponDetail, error) {
 	var coupon = new(CaseCouponDetail)
-	sql := `select * from ta_coupon_Coupon where coupon_id=? and status>?`
-	_, err := m.db.Sql(sql, couponid, models.STATUS_DEL).Get(&coupon)
+	sql := `select * from ta_coupon where coupon_id=? and status>?`
+	_, err := m.db.Sql(sql, couponid, models.STATUS_DEL).Get(coupon)
 	if err != nil {
 		return nil, err
 	}
@@ -408,8 +420,8 @@ func (m *CouponDAO) GetCustomerCouponByID(id string) (*CustomerCouponWithShare,
 	if err != nil {
 		return nil, err
 	}
-	share := new(model.TaCouponShare)
-	if _, err := m.db.Where("coupon_id=?", id).And("status=?", models.STATUS_NORMAL).Get(share); err != nil {
+	share, err := m.GetCouponShareByCouponID(id)
+	if err != nil {
 		return nil, err
 	}
 	customerCoupon.Share = share
@@ -460,7 +472,15 @@ func (m *CouponDAO) VerifyCustomerCoupon(id string) error {
 	return err
 }
 
-// ReceiveCoupon 领取优惠券
-func (m *CouponDAO) ReceiveCoupon(couponid string) {
-
+// CheckBySerialCode 根据批次码判断
+func (m *CouponDAO) CheckBySerialCode(couponid, code string) (bool, error) {
+	var customerCoupons []model.TaCustomerCoupon
+	err := m.db.Where("coupon_id=?", couponid).And("serial_code=?", code).Find(&customerCoupons)
+	if err != nil {
+		return false, err
+	}
+	if len(customerCoupons) == 0 {
+		return true, nil
+	}
+	return false, nil
 }

models/coupon/types.go

@@ -13,7 +13,7 @@ const (
 // CouponInfo 优惠券信息
 type CouponInfo struct {
 	model.TaCoupon `xorm:"extends"`
-	Share          model.TaCouponShare
+	Share          *model.TaCouponShare
 	Targets        []model.TaCouponTarget
 	Images         []model.TaCouponImage
 	Rules          []model.TaCouponRule
@@ -23,6 +23,7 @@ type CouponInfo struct {
 type CaseCouponDetail struct {
 	model.TaCoupon `xorm:"extends"`
 	CustomerCoupon []model.TaCustomerCoupon
+	Share          *model.TaCouponShare
 }
 
 // CustomerCoupon 用户优惠券

models/gymcard/gymcard.go

@@ -278,6 +278,7 @@ func (m *GymcardDAO) SendGymcardToCustomer(gymcard *model.TaGymCard, customerId,
 	customerGym.Status = models.STATUS_NORMAL
 	customerGym.SalesId = salesId
 	customerGym.SalesName = salesName
+	customerGym.CardStatus = models.CARD_COUPON_RECEIVED
 	_, err := m.db.Insert(customerGym)
 	return &customerGym, err
 }

npm-debug.log

@@ -2,13 +2,13 @@
 1 verbose cli [ 'D:\\Application\\Node\\node.exe',
 1 verbose cli   'C:\\Users\\Administrator\\AppData\\Roaming\\npm\\node_modules\\npm\\bin\\npm-cli.js',
 1 verbose cli   'run',
-1 verbose cli   'build' ]
+1 verbose cli   'dev' ]
 2 info using npm@4.0.5
 3 info using node@v8.2.1
 4 verbose stack Error: ENOENT: no such file or directory, open 'E:\GoProject\src\spaceofcheng\services\package.json'
 5 verbose cwd E:\GoProject\src\spaceofcheng\services
 6 error Windows_NT 10.0.17134
-7 error argv "D:\\Application\\Node\\node.exe" "C:\\Users\\Administrator\\AppData\\Roaming\\npm\\node_modules\\npm\\bin\\npm-cli.js" "run" "build"
+7 error argv "D:\\Application\\Node\\node.exe" "C:\\Users\\Administrator\\AppData\\Roaming\\npm\\node_modules\\npm\\bin\\npm-cli.js" "run" "dev"
 8 error node v8.2.1
 9 error npm  v4.0.5
 10 error path E:\GoProject\src\spaceofcheng\services\package.json

routers/common.go

@@ -178,7 +178,8 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/gymcard/:phone", &gymcard.GymcardController{}, "get:GetCustomerGymByPhone"),
 		beego.NSRouter("/gymcard", &gymcard.GymcardController{}, "post:SaveGymcard"),
 		beego.NSRouter("/gymcard", &gymcard.GymcardController{}, "put:SaveGymcard"),
-		beego.NSRouter("/gymcard/:customerGymId", &gymcard.GymcardController{}, "put:VerifyCustomerGymcard"),
+		beego.NSRouter("/gymcard/:id/to/:users", &gymcard.GymcardController{}, "post:GiveGymToCustomer"),
+
 		// luckdrawlist 抽奖
 		beego.NSRouter("luckdrawlist", &luckdrawlist.LuckdrawlistController{}, "get:GetLuckdrawList"),
 		beego.NSRouter("luckdrawlist/:toPhone/:fromPhone", &luckdrawlist.LuckdrawlistController{}, "get:GetLuckShareList"),

routers/wechat.go

@@ -56,10 +56,12 @@ func getWechatRoutes() beego.LinkNamespace {
 		beego.NSRouter("/coupon", &coupon.CouponController{}, "get:GetCaseUsableCoupon"),
 		beego.NSRouter("/coupon/:id", &coupon.CouponController{}, "get:GetCouponByID"),
 		beego.NSRouter("/coupon/detail/:id", &coupon.CouponController{}, "get:GetCouponWithCustomer"),
+		beego.NSRouter("/coupon/:id", &coupon.CouponController{}, "post:ReceiveCoupon"),
 
 		// 卡
 		beego.NSRouter("/card", &card.CardController{}, "get:GetCaseUsableCard"),
 		beego.NSRouter("/card/:id", &card.CardController{}, "get:GetCardByID"),
 		beego.NSRouter("/card/detail/:id", &card.CardController{}, "get:GetCardWithCustomer"),
+		beego.NSRouter("/card/:id", &card.CardController{}, "post:ReceiveCard"),
 	)
 }

service/card/card.go

@@ -4,6 +4,7 @@ import (
 	"errors"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/card"
+	"spaceofcheng/services/models/course"
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/system"
@@ -17,19 +18,21 @@ import (
 
 // CardServ 系统处理
 type CardServ struct {
-	ctx     *utils.Context
-	dao     *card.CardDAO
-	custDao *customer.CustomerDAO
-	userDao *system.UserDAO
+	ctx       *utils.Context
+	dao       *card.CardDAO
+	custDao   *customer.CustomerDAO
+	userDao   *system.UserDAO
+	courseDao *course.CourseDAO
 }
 
 // NewCardServ 初始化
 func NewCardServ(ctx *utils.Context) *CardServ {
 	return &CardServ{
-		ctx:     ctx,
-		dao:     card.NewCardDAO(ctx),
-		custDao: customer.NewCustomerDAO(ctx),
-		userDao: system.NewUserDAO(ctx),
+		ctx:       ctx,
+		dao:       card.NewCardDAO(ctx),
+		custDao:   customer.NewCustomerDAO(ctx),
+		userDao:   system.NewUserDAO(ctx),
+		courseDao: course.NewCourseDAO(ctx),
 	}
 }
 
@@ -230,6 +233,7 @@ func (s *CardServ) GiveCardTo(from *model.SysUser, to *model.TaCustomer, card *c
 
 	// 放入我的卡券
 	custcard := model.TaCustomerCard{
+		CustomerCardId:   utils.GetGUID(),
 		CardId:           card.CardId,
 		CustomerCardName: card.CardName,
 		CustomerId:       to.CustomerId,
@@ -246,9 +250,25 @@ func (s *CardServ) GiveCardTo(from *model.SysUser, to *model.TaCustomer, card *c
 		return errors.New("保存客户卡失败")
 	}
 
+	// 加入我的课程信息
+	err := s.SaveCustomerCourseByCard(&custcard)
+	if err != nil {
+		return err
+	}
+
 	// TODO
 	// 券库存处理
-
+	var cardinfo = model.TaCouponCard{
+		CardId:    card.CardId,
+		SentCount: card.SentCount + 1,
+	}
+	cols := []string{
+		"sent_count",
+	}
+	if err := s.dao.UpdateCard(&cardinfo, cols); err != nil {
+		utils.LogError("回填体验卡信息失败:", err)
+		return errors.New("回填体验卡信息失败！")
+	}
 	return nil
 }
 
@@ -359,3 +379,150 @@ func (s *CardServ) GetCaseUsableCard(page, pageSize int) (map[string]interface{}
 		"page":     page,
 	}, nil
 }
+
+// ReceiveCard 卡领取
+func (s *CardServ) ReceiveCard(id, saleid, serialcode string) error {
+	if saleid == "" || serialcode == "" {
+		return errors.New("参数不全！不允许领取")
+	}
+
+	// 数据校验
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	if customer.Phone == "" {
+		return errors.New("用户未绑定手机号！")
+	}
+	if customer.UserId != "" {
+		return errors.New("不允许内部人员领取卡券！")
+	}
+
+	card, err := s.dao.GetCardInfoByID(id)
+	if err != nil {
+		utils.LogError("领取卡获取卡信息失败：", err)
+		return errors.New("领取卡失败！")
+	}
+	if card.TotalCount <= card.SentCount && card.IsOver == 0 {
+		return errors.New("卡券已领完！")
+	}
+	if card.EndDate.Before(time.Now()) {
+		return errors.New("卡券已过期")
+	}
+
+	// 销售校验
+	saler, err := s.custDao.GetUserByID(saleid)
+	if err != nil {
+		utils.LogError("领取卡获取销售信息失败：", err)
+		return errors.New("领取卡失败！")
+	}
+	caseinfo, err := s.userDao.GetUserBelongCase(saleid)
+	if err != nil {
+		utils.LogError("领取卡获取销售案场信息失败：", err)
+		return errors.New("领取卡失败！")
+	}
+	if caseinfo.CaseId != card.CaseId {
+		return errors.New("销售不合法！")
+	}
+
+	// 验证码判断
+	isok, err := s.dao.CheckBySerialCode(card.CardId, serialcode)
+	if err != nil {
+		utils.LogError("获取卡批次码判断失败：", err)
+		return errors.New("领取卡失败！")
+	}
+	if !isok {
+		return errors.New("该卡已被领取！")
+	}
+
+	// 领取
+	var customerCard = model.TaCustomerCard{
+		CustomerCardId:   utils.GetGUID(),
+		CardId:           card.CardId,
+		CustomerCardName: card.CardName,
+		CustomerId:       customer.CustomerId,
+		SalesId:          saler.UserId,
+		SalesName:        saler.UserName,
+		StartDate:        card.StartDate,
+		EndDate:          card.EndDate,
+		CaseId:           card.CaseId,
+		OrgId:            card.OrgId,
+		SerialCode:       serialcode,
+	}
+
+	err = s.dao.SaveCustomerCard(&customerCard)
+	if err != nil {
+		utils.LogError("保存用户体验卡信息失败：", err)
+		return errors.New("领取卡失败！")
+	}
+	// 加入我的课程信息
+	err = s.SaveCustomerCourseByCard(&customerCard)
+	if err != nil {
+		return err
+	}
+	// 回填体验卡信息
+	card.SentCount = card.SentCount + 1
+	cols := []string{
+		"sent_count",
+	}
+	err = s.dao.UpdateCard(card, cols)
+	if err != nil {
+		utils.LogError("回填体验卡信息失败:", err)
+		return errors.New("领取卡失败！")
+	}
+	return nil
+}
+
+// SaveCustomerCourseByCard 保存用户的课程信息
+func (s *CardServ) SaveCustomerCourseByCard(customerCard *model.TaCustomerCard) error {
+	customer, err := s.custDao.GetCustomerByID(customerCard.CustomerId)
+	if err != nil {
+		utils.LogError("获取客户信息失败:", err)
+		return errors.New("获取客户信息失败")
+	}
+	card, err := s.dao.GetCardByID(customerCard.CardId)
+	if err != nil {
+		utils.LogError("获取体验卡信息失败:", err)
+		return errors.New("领取卡失败！")
+	}
+	for _, target := range card.Targets {
+		course, err := s.courseDao.GetCourseInfo(target.TargetId)
+		if err != nil {
+			utils.LogError("领取卡时课程获取失败:", err)
+			return errors.New("领取卡时课程获取失败！")
+		}
+		// 我的课程信息
+		custCourse := model.TaCustomerCourse{
+			CourseId:         course.CourseId,
+			CustomerId:       customer.CustomerId,
+			OrgId:            card.OrgId,
+			CaseId:           card.CaseId,
+			CourseName:       course.CourseName,
+			LocationId:       course.LocationId,
+			Price:            course.Price,
+			CourseNum:        course.CourseNum,
+			JoinNum:          0,
+			CreateDate:       time.Now().Local(),
+			CourseObtaimType: models.COURSE_GETBY_CARD,
+			SourceId:         customerCard.CustomerCardId,
+			IsDone:           models.BOOL_FALSE,
+		}
+
+		custCourseDetails := make([]model.TaCustomerCourseDetail, 0)
+
+		for _, subCourse := range course.CourseDetail {
+			d2 := model.TaCustomerCourseDetail{
+				CourseId:     course.CourseId,
+				DetailId:     subCourse.DetailId,
+				StartDate:    subCourse.BeginDate,
+				EndDate:      subCourse.EndDate,
+				VerifyStatus: models.VERIFY_USEABLE,
+				CaseId:       customerCard.CaseId,
+			}
+			custCourseDetails = append(custCourseDetails, d2)
+		}
+
+		if err := s.courseDao.SaveCourseOfCustomer(&custCourse, custCourseDetails); err != nil {
+			utils.LogError("插入我的课程失败: " + err.Error())
+			return errors.New("写入我的课程失败")
+		}
+	}
+	return nil
+}

service/coupon/coupon.go

@@ -107,7 +107,7 @@ func (s *CouponServ) SaveCoupon(cp *coupon.CouponInfo) error {
 	share := cp.Share
 	share.CouponId = cp.CouponId
 	// cols := []string{"coupon_share_info", "use_rule", "use_instruction"}
-	if err := s.dao.SaveCouponShare(&share); err != nil {
+	if err := s.dao.SaveCouponShare(share); err != nil {
 		utils.LogError("保存优惠券分享失败: " + err.Error())
 		return errors.New("保存优惠券分享失败")
 	}
@@ -166,7 +166,7 @@ func (s *CouponServ) UpdateCoupon(cp *coupon.CouponInfo) error {
 	share := cp.Share
 	share.CouponId = cp.CouponId
 	cols := []string{"coupon_share_info", "use_rule", "use_instruction"}
-	if err := s.dao.UpdateCouponShare(&share, cols); err != nil {
+	if err := s.dao.UpdateCouponShare(share, cols); err != nil {
 		utils.LogError("更新优惠券分享失败: " + err.Error())
 		return errors.New("更新优惠券分享失败")
 	}
@@ -408,7 +408,6 @@ func (s *CouponServ) GetCustomerCouponByID(id string) (*coupon.CustomerCouponWit
 
 // GetCaseUsableCoupon 获取案场可用券
 func (s *CouponServ) GetCaseUsableCoupon(page, pageSize int) (map[string]interface{}, error) {
-
 	if pageSize == 0 {
 		pageSize = service.PAGENUM
 	}
@@ -424,7 +423,7 @@ func (s *CouponServ) GetCaseUsableCoupon(page, pageSize int) (map[string]interfa
 		utils.LogError("获取用户信息失败: " + err.Error())
 		return nil, errors.New("获取用户信息失败")
 	}
-	if len(userTypes) > 0 {
+	if len(userTypes) == 0 {
 		return nil, errors.New("您没有权限查看数据")
 	}
 	caseinfo, err := s.userDao.GetUserBelongCase(customer.UserId)
@@ -451,3 +450,138 @@ func (s *CouponServ) GetCaseUsableCoupon(page, pageSize int) (map[string]interfa
 		"page":     page,
 	}, nil
 }
+
+// ReceiveCoupon 优惠券领取
+func (s *CouponServ) ReceiveCoupon(id, saleid, serialcode string) error {
+	if saleid == "" || serialcode == "" {
+		return errors.New("参数不全！不允许领取")
+	}
+
+	// 数据校验
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	if customer.Phone == "" {
+		return errors.New("用户未绑定手机号！")
+	}
+	if customer.UserId != "" {
+		return errors.New("不允许内部人员领取优惠券券！")
+	}
+
+	coupon, err := s.dao.GetCouponByID(id)
+	if err != nil {
+		utils.LogError("领取优惠券获取优惠券信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	if coupon.TotalCount <= coupon.SentCount && coupon.IsOver == 0 {
+		return errors.New("优惠券券已领完！")
+	}
+	if coupon.EndDate.Before(time.Now()) {
+		return errors.New("优惠券券已过期")
+	}
+
+	// 销售校验
+	saler, err := s.custDao.GetUserByID(saleid)
+	if err != nil {
+		utils.LogError("领取优惠券获取销售信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	caseinfo, err := s.userDao.GetUserBelongCase(saleid)
+	if err != nil {
+		utils.LogError("领取优惠券获取销售案场信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	if caseinfo.CaseId != coupon.CaseId {
+		return errors.New("销售不合法！")
+	}
+
+	// 验证码判断
+	isok, err := s.dao.CheckBySerialCode(coupon.CouponId, serialcode)
+	if err != nil {
+		utils.LogError("获取优惠券批次码判断失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	if !isok {
+		return errors.New("该优惠券已被领取！")
+	}
+
+	// 领取
+	var customerCoupon = model.TaCustomerCoupon{
+		CouponId:           coupon.CouponId,
+		CustomerCouponName: coupon.CouponName,
+		CustomerId:         customer.CustomerId,
+		SalesId:            saler.UserId,
+		SalesName:          saler.UserName,
+		StartDate:          coupon.StartDate,
+		EndDate:            coupon.EndDate,
+		CaseId:             coupon.CaseId,
+		OrgId:              coupon.OrgId,
+		SerialCode:         serialcode,
+	}
+
+	err = s.dao.SaveCustomerCoupon(&customerCoupon)
+	if err != nil {
+		utils.LogError("保存用户体验优惠券信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	// 回填体验优惠券信息
+	coupon.SentCount = coupon.SentCount + 1
+	cols := []string{
+		"sent_count",
+	}
+	err = s.dao.UpdateCoupon(coupon, cols)
+	if err != nil {
+		utils.LogError("回填体验优惠券信息失败:", err)
+		return errors.New("领取优惠券失败！")
+	}
+	return nil
+}
+
+// ChannelReceiveCoupon 渠道端优惠券领取
+func (s *CouponServ) ChannelReceiveCoupon(id string) error {
+	// 数据校验
+	customer := s.ctx.Get("customer").(model.TaCustomer)
+	if customer.Phone == "" {
+		return errors.New("用户未绑定手机号！")
+	}
+	if customer.UserId != "" {
+		return errors.New("不允许内部人员领取优惠券券！")
+	}
+
+	coupon, err := s.dao.GetCouponByID(id)
+	if err != nil {
+		utils.LogError("领取优惠券获取优惠券信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	if coupon.TotalCount <= coupon.SentCount && coupon.IsOver == 0 {
+		return errors.New("优惠券券已领完！")
+	}
+	if coupon.EndDate.Before(time.Now()) {
+		return errors.New("优惠券券已过期")
+	}
+	// 领取
+	var customerCoupon = model.TaCustomerCoupon{
+		CouponId:           coupon.CouponId,
+		CustomerCouponName: coupon.CouponName,
+		CustomerId:         customer.CustomerId,
+		StartDate:          coupon.StartDate,
+		EndDate:            coupon.EndDate,
+		CaseId:             coupon.CaseId,
+		OrgId:              coupon.OrgId,
+	}
+
+	err = s.dao.SaveCustomerCoupon(&customerCoupon)
+	if err != nil {
+		utils.LogError("保存用户体验优惠券信息失败：", err)
+		return errors.New("领取优惠券失败！")
+	}
+	// 回填体验优惠券信息
+	coupon.SentCount = coupon.SentCount + 1
+	cols := []string{
+		"sent_count",
+	}
+	err = s.dao.UpdateCoupon(coupon, cols)
+	if err != nil {
+		utils.LogError("回填体验优惠券信息失败:", err)
+		return errors.New("领取优惠券失败！")
+	}
+	return nil
+}

service/gymcard/gymcard.go

@@ -172,6 +172,9 @@ func (s *GymcardServ) SendGymCardToUser(gymcardId, sysuserId string) (*model.TaC
 		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
 		return nil, errors.New("发送游泳健身卡给客户失败")
 	}
+	if gymCard.TotalCount-gymCard.SentCount < 1 {
+		return nil, errors.New("健身卡剩余数量不足！")
+	}
 	sysuser, err = s.cdao.GetUserByID(sysuserId)
 	if err != nil {
 		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
@@ -279,3 +282,31 @@ func (s *GymcardServ) deleteGymCard(gymcardId string) error {
 	return err
 
 }
+
+// GiveCardToCustomer 赠送健身卡
+func (s *GymcardServ) GiveCardToCustomer(gymcardId, uids string) error {
+	gymCard, err := s.dao.GetGymcardById(gymcardId)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return errors.New("发送游泳健身卡给客户失败")
+	}
+	arrUID := strings.Split(uids, ",")
+	if gymCard.TotalCount-gymCard.SentCount < len(arrUID) {
+		return errors.New("健身卡剩余数量不足！")
+	}
+
+	for _, uid := range arrUID {
+		_, err := s.dao.SendGymcardToCustomer(&gymCard.TaGymCard, uid, "", "")
+		if err != nil {
+			utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+			return errors.New("发送游泳健身卡给客户失败")
+		}
+		gymCard.SentCount = gymCard.SentCount + 1
+	}
+	err = s.dao.EditGymcard(&gymCard.TaGymCard)
+	if err != nil {
+		utils.LogError("发送游泳健身卡给客户失败" + err.Error())
+		return errors.New("发送游泳健身卡给客户失败")
+	}
+	return nil
+}