Merge branch 'dev' of http://git.ycjcjy.com/SpaceOfCheng/services into dev

conf/log.conf

@@ -1,4 +1,4 @@
 [common]
-filename="E:\\GoProject\\src\\spaceofcheng\\services\\log\\common.log"
+filename="E:\\GoProjects\\src\\spaceofcheng\\services\\log\\common.log"
 # log level "emergency", "alert", "critical", "error", "warning", "notice", "info", "debug"
 level="debug"

controllers/coupon/coupon.go

@@ -0,0 +1,169 @@
+package coupon
+
+import (
+	"encoding/json"
+	"errors"
+	"net/http"
+	"spaceofcheng/services/controllers"
+	cpModel "spaceofcheng/services/models/coupon"
+	"spaceofcheng/services/service/coupon"
+	"spaceofcheng/services/utils"
+	"strings"
+)
+
+// CouponController 商品
+type CouponController struct {
+	serv *coupon.CouponServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *CouponController) Constructor() {
+	c.serv = coupon.NewCouponServ(c.Context)
+}
+
+// ListByCase 获取券列表
+func (c *CouponController) ListByCase() {
+	caseID := c.GetString("caseid")
+
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	if page < 0 {
+		page = 1
+	}
+
+	if pagesize <= 0 {
+		pagesize = 10
+	}
+
+	list, total, err := c.serv.GetCouponList(caseID, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"list":     list,
+		"page":     page,
+		"pagesize": pagesize,
+		"pagenum":  total,
+	})
+}
+
+// GetCouponByIDForAdmin 获取优惠券
+// 管理端
+func (c *CouponController) GetCouponByIDForAdmin() {
+	id := c.GetString(":id")
+	if id == "" {
+		c.ResponseError(errors.New("未指定券"))
+	}
+
+	cp, err := c.serv.GetCouponByIDWithCheck(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"coupon": cp,
+	})
+}
+
+// GetCouponByID 获取优惠券
+// 微信端
+func (c *CouponController) GetCouponByID() {
+	id := c.GetString(":id")
+	if id == "" {
+		c.ResponseError(errors.New("未指定券"))
+	}
+
+	cp, err := c.serv.GetCouponByID(id)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"coupon": cp,
+	})
+}
+
+// SaveCoupon 保存优惠券
+func (c *CouponController) SaveCoupon() {
+	jsnStr := c.GetString("info")
+	if jsnStr == "" {
+		c.ResponseError(errors.New("未接收到保存内容"))
+	}
+
+	cp := cpModel.CouponInfo{}
+
+	if err := json.Unmarshal([]byte(jsnStr), &cp); err != nil {
+		utils.LogError("接收优惠券信息失败: " + err.Error())
+		c.ResponseError(errors.New("接收参数失败"), http.StatusInternalServerError)
+	}
+
+	// TODO
+	// 校验各字段不能为空
+
+	// 入库
+	cp.CouponId = ""
+	if err := c.serv.SaveCoupon(&cp); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"coupon": cp,
+	})
+}
+
+// UpdateCoupon 更新优惠券
+func (c *CouponController) UpdateCoupon() {
+	jsnStr := c.GetString("info")
+	if jsnStr == "" {
+		c.ResponseError(errors.New("未接收到更新内容"))
+	}
+
+	id := c.GetString(":id")
+	if id == "" {
+		c.ResponseError(errors.New("未指定券"))
+	}
+
+	cp := cpModel.CouponInfo{}
+
+	if err := json.Unmarshal([]byte(jsnStr), &cp); err != nil {
+		utils.LogError("接收优惠券信息失败: " + err.Error())
+		c.ResponseError(errors.New("接收参数失败"), http.StatusInternalServerError)
+	}
+
+	// TODO
+	// 校验各字段不能为空
+
+	// 入库
+	cp.CouponId = id
+	if err := c.serv.UpdateCoupon(&cp); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"coupon": cp,
+	})
+}
+
+// GiveCoupon 赠送优惠券
+func (c *CouponController) GiveCoupon() {
+	id := c.GetString(":id")
+	if id == "" {
+		c.ResponseError(errors.New("未指定券"))
+	}
+
+	uids := c.GetString(":users")
+	if uids == "" {
+		c.ResponseError(errors.New("未指定赠送人"))
+	}
+
+	err := c.serv.GiveCoupon(id, strings.Split(uids, ","))
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("ok")
+}

log/common.log

@@ -3060,3 +3060,606 @@
 2018/09/11 17:57:59 [E] 用户没有设置默认案场
 2018/09/11 17:58:51 [E] 用户没有设置默认案场
 2018/09/11 18:00:05 [E] 用户没有设置默认案场
+2018/09/12 09:39:30 [E] 用户没有设置默认案场
+2018/09/12 09:40:06 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 09:40:06 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_OC15Gmge9rmTgj9gghR_fcN6dwBUGKeKYm2z-QpGRi5hcBwdzb690dlyJjw4HMm2khywsPH2Eb-f75dx7YmAE9k6y_T_YLiNLw_9XJjts1tChoN6PTPeKeBurmt8CO-eO6AAfeGCETqAEJl2ZALfABASTE","expires_in":7200})
+2018/09/12 09:40:06 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_OC15Gmge9rmTgj9gghR_fcN6dwBUGKeKYm2z-QpGRi5hcBwdzb690dlyJjw4HMm2khywsPH2Eb-f75dx7YmAE9k6y_T_YLiNLw_9XJjts1tChoN6PTPeKeBurmt8CO-eO6AAfeGCETqAEJl2ZALfABASTE expires_in:7200])
+2018/09/12 09:41:35 [E] 用户没有设置默认案场
+2018/09/12 09:41:36 [E] 用户没有设置默认案场
+2018/09/12 09:42:26 [E] 用户没有设置默认案场
+2018/09/12 09:42:26 [E] 用户没有设置默认案场
+2018/09/12 09:42:26 [E] 用户没有设置默认案场
+2018/09/12 09:43:03 [E] 用户没有设置默认案场
+2018/09/12 09:43:03 [E] 用户没有设置默认案场
+2018/09/12 09:43:06 [E] 用户没有设置默认案场
+2018/09/12 09:43:06 [E] 用户没有设置默认案场
+2018/09/12 09:43:23 [E] 用户没有设置默认案场
+2018/09/12 09:43:23 [E] 用户没有设置默认案场
+2018/09/12 09:43:26 [E] 用户没有设置默认案场
+2018/09/12 09:43:27 [E] 用户没有设置默认案场
+2018/09/12 09:43:28 [E] 用户没有设置默认案场
+2018/09/12 09:43:28 [E] 用户没有设置默认案场
+2018/09/12 09:43:39 [E] 用户没有设置默认案场
+2018/09/12 09:43:39 [E] 用户没有设置默认案场
+2018/09/12 09:43:47 [E] 用户没有设置默认案场
+2018/09/12 09:43:47 [E] 用户没有设置默认案场
+2018/09/12 09:48:14 [E] 用户没有设置默认案场
+2018/09/12 09:48:14 [E] 用户没有设置默认案场
+2018/09/12 09:48:52 [E] 用户没有设置默认案场
+2018/09/12 09:48:59 [E] 用户没有设置默认案场
+2018/09/12 09:48:59 [E] 用户没有设置默认案场
+2018/09/12 09:49:21 [E] 用户没有设置默认案场
+2018/09/12 09:49:24 [E] 用户没有设置默认案场
+2018/09/12 09:49:24 [E] 用户没有设置默认案场
+2018/09/12 09:49:33 [E] 用户没有设置默认案场
+2018/09/12 09:49:39 [E] 用户没有设置默认案场
+2018/09/12 09:49:39 [E] 用户没有设置默认案场
+2018/09/12 09:50:00 [E] 用户没有设置默认案场
+2018/09/12 09:50:06 [E] 用户没有设置默认案场
+2018/09/12 09:50:08 [E] 用户没有设置默认案场
+2018/09/12 09:50:11 [E] 用户没有设置默认案场
+2018/09/12 09:50:11 [E] 用户没有设置默认案场
+2018/09/12 09:50:16 [E] 用户没有设置默认案场
+2018/09/12 09:50:16 [E] 用户没有设置默认案场
+2018/09/12 09:50:31 [E] 用户没有设置默认案场
+2018/09/12 09:50:34 [E] 用户没有设置默认案场
+2018/09/12 09:50:34 [E] 用户没有设置默认案场
+2018/09/12 09:51:21 [E] 用户没有设置默认案场
+2018/09/12 09:51:21 [E] 用户没有设置默认案场
+2018/09/12 09:51:56 [E] 用户没有设置默认案场
+2018/09/12 09:52:25 [E] 用户没有设置默认案场
+2018/09/12 09:53:22 [E] 用户没有设置默认案场
+2018/09/12 09:53:22 [E] 用户没有设置默认案场
+2018/09/12 09:53:24 [E] 用户没有设置默认案场
+2018/09/12 09:53:24 [E] 用户没有设置默认案场
+2018/09/12 09:53:25 [E] 用户没有设置默认案场
+2018/09/12 09:53:35 [E] 用户没有设置默认案场
+2018/09/12 09:53:38 [E] 用户没有设置默认案场
+2018/09/12 09:53:38 [E] 用户没有设置默认案场
+2018/09/12 09:53:40 [E] 用户没有设置默认案场
+2018/09/12 09:53:43 [E] 用户没有设置默认案场
+2018/09/12 09:53:43 [E] 用户没有设置默认案场
+2018/09/12 09:54:57 [E] 用户没有设置默认案场
+2018/09/12 09:54:57 [E] 用户没有设置默认案场
+2018/09/12 09:54:58 [E] 用户没有设置默认案场
+2018/09/12 09:54:58 [E] 用户没有设置默认案场
+2018/09/12 09:54:59 [E] 用户没有设置默认案场
+2018/09/12 09:59:23 [E] 用户没有设置默认案场
+2018/09/12 10:00:22 [E] 用户没有设置默认案场
+2018/09/12 10:00:22 [E] 用户没有设置默认案场
+2018/09/12 10:00:48 [E] 用户没有设置默认案场
+2018/09/12 10:01:02 [E] 用户没有设置默认案场
+2018/09/12 10:01:02 [E] 用户没有设置默认案场
+2018/09/12 10:01:03 [E] 用户没有设置默认案场
+2018/09/12 10:01:05 [E] 用户没有设置默认案场
+2018/09/12 10:01:05 [E] 用户没有设置默认案场
+2018/09/12 10:01:05 [E] 用户没有设置默认案场
+2018/09/12 10:03:10 [E] 用户没有设置默认案场
+2018/09/12 10:03:10 [E] 用户没有设置默认案场
+2018/09/12 10:03:10 [E] 用户没有设置默认案场
+2018/09/12 10:03:10 [E] 用户没有设置默认案场
+2018/09/12 10:03:25 [E] 用户没有设置默认案场
+2018/09/12 10:03:26 [E] 用户没有设置默认案场
+2018/09/12 10:03:26 [E] 用户没有设置默认案场
+2018/09/12 10:04:16 [E] 用户没有设置默认案场
+2018/09/12 10:04:16 [E] 用户没有设置默认案场
+2018/09/12 10:04:16 [E] 用户没有设置默认案场
+2018/09/12 10:07:16 [E] 用户没有设置默认案场
+2018/09/12 10:08:31 [E] 用户没有设置默认案场
+2018/09/12 10:08:31 [E] 用户没有设置默认案场
+2018/09/12 10:08:31 [E] 用户没有设置默认案场
+2018/09/12 10:08:33 [E] 用户没有设置默认案场
+2018/09/12 10:08:34 [E] 用户没有设置默认案场
+2018/09/12 10:08:34 [E] 用户没有设置默认案场
+2018/09/12 10:08:45 [E] 用户没有设置默认案场
+2018/09/12 10:08:45 [E] 用户没有设置默认案场
+2018/09/12 10:08:45 [E] 用户没有设置默认案场
+2018/09/12 10:09:00 [E] 用户没有设置默认案场
+2018/09/12 10:09:01 [E] 用户没有设置默认案场
+2018/09/12 10:09:01 [E] 用户没有设置默认案场
+2018/09/12 10:12:11 [E] 用户没有设置默认案场
+2018/09/12 10:12:11 [E] 用户没有设置默认案场
+2018/09/12 10:22:46 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 10:22:47 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_EwN2cbZUMOEXEUiNcIlzH2dMOQRu-NPQ0Pm92O6d1PyBc7-Y3qTnvtbGssRgu6ahy7xdZC2mWuhBZoUXwujJp-qScWSRXTBTVR2eaRzY1BDr0JkgQ3JyEO-Tw71CYSDkneFJ01HMrbwXDQaiWZFfAAAKNT","expires_in":7200})
+2018/09/12 10:22:47 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_EwN2cbZUMOEXEUiNcIlzH2dMOQRu-NPQ0Pm92O6d1PyBc7-Y3qTnvtbGssRgu6ahy7xdZC2mWuhBZoUXwujJp-qScWSRXTBTVR2eaRzY1BDr0JkgQ3JyEO-Tw71CYSDkneFJ01HMrbwXDQaiWZFfAAAKNT expires_in:7200])
+2018/09/12 10:35:17 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 10:35:17 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_8inPAb7cKbz4aVIf2IuhpSDriQBy87UH-yeqoMuC5I6sCcXbszS8xECxNXGv06IyhS-4SmdxkKD5-RgjjxTs4UMJ-LTP4mbEsNEtdzmENm06KYXAS4W3sLw45GNYqtkB1DsHASxr9koxohDZAGPeAFAKQZ","expires_in":7200})
+2018/09/12 10:35:17 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_8inPAb7cKbz4aVIf2IuhpSDriQBy87UH-yeqoMuC5I6sCcXbszS8xECxNXGv06IyhS-4SmdxkKD5-RgjjxTs4UMJ-LTP4mbEsNEtdzmENm06KYXAS4W3sLw45GNYqtkB1DsHASxr9koxohDZAGPeAFAKQZ expires_in:7200])
+2018/09/12 10:54:13 [E] 用户没有设置默认案场
+2018/09/12 10:54:52 [E] 用户没有设置默认案场
+2018/09/12 11:10:11 [E] 用户没有设置默认案场
+2018/09/12 11:14:01 [E] 用户没有设置默认案场
+2018/09/12 11:14:57 [E] 用户没有设置默认案场
+2018/09/12 11:15:00 [E] 用户没有设置默认案场
+2018/09/12 11:15:02 [E] 用户没有设置默认案场
+2018/09/12 11:15:03 [E] 用户没有设置默认案场
+2018/09/12 11:15:09 [E] 用户没有设置默认案场
+2018/09/12 11:15:09 [E] 用户没有设置默认案场
+2018/09/12 11:15:25 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/12 11:15:25 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/12 11:15:25 [E] 用户没有设置默认案场
+2018/09/12 11:15:48 [E] 用户没有设置默认案场
+2018/09/12 11:16:26 [E] 用户没有设置默认案场
+2018/09/12 11:16:29 [E] 用户没有设置默认案场
+2018/09/12 11:16:45 [E] 用户没有设置默认案场
+2018/09/12 11:16:45 [E] 用户没有设置默认案场
+2018/09/12 11:16:54 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/12 11:16:54 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/12 11:16:54 [E] 用户没有设置默认案场
+2018/09/12 11:17:01 [E] 用户没有设置默认案场
+2018/09/12 11:17:05 [E] 用户没有设置默认案场
+2018/09/12 11:17:08 [E] 用户没有设置默认案场
+2018/09/12 11:17:09 [E] 用户没有设置默认案场
+2018/09/12 11:17:09 [E] 用户没有设置默认案场
+2018/09/12 11:17:12 [E] 用户没有设置默认案场
+2018/09/12 11:17:12 [E] 用户没有设置默认案场
+2018/09/12 11:17:25 [E] 用户没有设置默认案场
+2018/09/12 11:17:37 [E] 用户没有设置默认案场
+2018/09/12 11:20:32 [E] 用户没有设置默认案场
+2018/09/12 11:20:51 [E] 用户没有设置默认案场
+2018/09/12 11:20:57 [E] 用户没有设置默认案场
+2018/09/12 11:20:57 [E] 用户没有设置默认案场
+2018/09/12 11:20:58 [E] 用户没有设置默认案场
+2018/09/12 11:21:08 [E] 用户没有设置默认案场
+2018/09/12 11:21:08 [E] 用户没有设置默认案场
+2018/09/12 11:21:10 [E] 用户没有设置默认案场
+2018/09/12 11:21:15 [E] 用户没有设置默认案场
+2018/09/12 11:21:18 [E] 用户没有设置默认案场
+2018/09/12 11:21:18 [E] 用户没有设置默认案场
+2018/09/12 11:21:22 [E] 用户没有设置默认案场
+2018/09/12 11:21:22 [E] 用户没有设置默认案场
+2018/09/12 11:21:24 [E] 用户没有设置默认案场
+2018/09/12 11:21:26 [E] 用户没有设置默认案场
+2018/09/12 11:21:44 [E] 用户没有设置默认案场
+2018/09/12 11:21:53 [E] 用户没有设置默认案场
+2018/09/12 11:22:10 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 11:22:11 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_H0YONvl0O6RxeMajJpx7FaGHTMbuGAJ0c3XHxFQdxnQLy8RwDwFGxFXx964Yz_zaH7Uqt9iSPLuPxWafZeWJkJ21JQDx1Fnp5om1g0ppGWvwjxFtaOcMbpc42xAWTScAHAMJI","expires_in":7200})
+2018/09/12 11:22:11 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_H0YONvl0O6RxeMajJpx7FaGHTMbuGAJ0c3XHxFQdxnQLy8RwDwFGxFXx964Yz_zaH7Uqt9iSPLuPxWafZeWJkJ21JQDx1Fnp5om1g0ppGWvwjxFtaOcMbpc42xAWTScAHAMJI expires_in:7200])
+2018/09/12 11:22:45 [E] 用户没有设置默认案场
+2018/09/12 11:23:02 [E] 用户没有设置默认案场
+2018/09/12 11:23:04 [E] 用户没有设置默认案场
+2018/09/12 11:23:07 [E] 用户没有设置默认案场
+2018/09/12 11:23:07 [E] 用户没有设置默认案场
+2018/09/12 11:23:21 [E] 用户没有设置默认案场
+2018/09/12 11:23:27 [E] 用户没有设置默认案场
+2018/09/12 11:23:56 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 11:23:56 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_D-cFwx0SKVT1vffkUp52tm86n8YYduWiX_1B5tZploz1PI4R9XeeR_lmwlkvswM-vvpinpqpRqTeurMb51supETRj3k776PkxH63ewEwUdVWtgsJqAQrBadFjp5PpLNE8o16vTh0bu60hVKjJREiAGAZHU","expires_in":7200})
+2018/09/12 11:23:56 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_D-cFwx0SKVT1vffkUp52tm86n8YYduWiX_1B5tZploz1PI4R9XeeR_lmwlkvswM-vvpinpqpRqTeurMb51supETRj3k776PkxH63ewEwUdVWtgsJqAQrBadFjp5PpLNE8o16vTh0bu60hVKjJREiAGAZHU expires_in:7200])
+2018/09/12 11:24:37 [E] 用户没有设置默认案场
+2018/09/12 11:24:38 [E] 用户没有设置默认案场
+2018/09/12 11:24:39 [E] 用户没有设置默认案场
+2018/09/12 11:24:41 [E] 用户没有设置默认案场
+2018/09/12 11:24:42 [E] 用户没有设置默认案场
+2018/09/12 11:25:45 [E] 用户没有设置默认案场
+2018/09/12 11:25:45 [E] 用户没有设置默认案场
+2018/09/12 11:25:45 [E] 用户没有设置默认案场
+2018/09/12 11:25:46 [E] 用户没有设置默认案场
+2018/09/12 11:25:47 [E] 用户没有设置默认案场
+2018/09/12 11:27:31 [E] 用户没有设置默认案场
+2018/09/12 11:32:09 [E] 用户没有设置默认案场
+2018/09/12 11:32:10 [E] 用户没有设置默认案场
+2018/09/12 11:32:37 [E] 用户没有设置默认案场
+2018/09/12 11:32:37 [E] 用户没有设置默认案场
+2018/09/12 11:32:44 [E] 用户没有设置默认案场
+2018/09/12 11:32:45 [E] 用户没有设置默认案场
+2018/09/12 11:32:50 [E] 用户没有设置默认案场
+2018/09/12 11:32:50 [E] 用户没有设置默认案场
+2018/09/12 11:33:34 [E] 用户没有设置默认案场
+2018/09/12 11:33:36 [E] 用户没有设置默认案场
+2018/09/12 11:33:38 [E] 用户没有设置默认案场
+2018/09/12 11:33:39 [E] 用户没有设置默认案场
+2018/09/12 11:33:47 [E] 用户没有设置默认案场
+2018/09/12 11:33:47 [E] 用户没有设置默认案场
+2018/09/12 11:33:47 [E] 用户没有设置默认案场
+2018/09/12 11:34:12 [E] 用户没有设置默认案场
+2018/09/12 11:34:12 [E] 用户没有设置默认案场
+2018/09/12 11:34:15 [E] 用户没有设置默认案场
+2018/09/12 11:34:15 [E] 用户没有设置默认案场
+2018/09/12 11:34:17 [E] 用户没有设置默认案场
+2018/09/12 11:34:18 [E] 用户没有设置默认案场
+2018/09/12 11:34:19 [E] 用户没有设置默认案场
+2018/09/12 11:34:21 [E] 用户没有设置默认案场
+2018/09/12 11:35:30 [E] 用户没有设置默认案场
+2018/09/12 11:35:38 [E] 用户没有设置默认案场
+2018/09/12 11:37:37 [E] 用户没有设置默认案场
+2018/09/12 11:37:37 [E] 用户没有设置默认案场
+2018/09/12 11:37:54 [E] 用户没有设置默认案场
+2018/09/12 11:37:54 [E] 用户没有设置默认案场
+2018/09/12 11:37:54 [E] 用户没有设置默认案场
+2018/09/12 11:37:56 [E] 用户没有设置默认案场
+2018/09/12 11:37:56 [E] 用户没有设置默认案场
+2018/09/12 11:37:58 [E] 用户没有设置默认案场
+2018/09/12 11:38:00 [E] 用户没有设置默认案场
+2018/09/12 11:38:00 [E] 用户没有设置默认案场
+2018/09/12 11:38:02 [E] 用户没有设置默认案场
+2018/09/12 11:38:02 [E] 用户没有设置默认案场
+2018/09/12 11:38:04 [E] 用户没有设置默认案场
+2018/09/12 11:38:05 [E] 用户没有设置默认案场
+2018/09/12 11:38:55 [E] 用户没有设置默认案场
+2018/09/12 11:39:14 [E] 用户没有设置默认案场
+2018/09/12 11:39:22 [E] 用户没有设置默认案场
+2018/09/12 11:39:53 [E] 用户没有设置默认案场
+2018/09/12 11:39:58 [E] 用户没有设置默认案场
+2018/09/12 11:39:58 [E] 用户没有设置默认案场
+2018/09/12 11:40:06 [E] 用户没有设置默认案场
+2018/09/12 11:42:30 [E] 用户没有设置默认案场
+2018/09/12 11:42:30 [E] 用户没有设置默认案场
+2018/09/12 11:44:00 [E] 用户没有设置默认案场
+2018/09/12 11:44:04 [E] 用户没有设置默认案场
+2018/09/12 11:45:28 [E] 用户没有设置默认案场
+2018/09/12 11:45:28 [E] 用户没有设置默认案场
+2018/09/12 11:45:35 [E] 用户没有设置默认案场
+2018/09/12 11:46:15 [E] 用户没有设置默认案场
+2018/09/12 11:46:20 [E] 用户没有设置默认案场
+2018/09/12 11:47:29 [E] 用户没有设置默认案场
+2018/09/12 11:50:48 [E] 用户没有设置默认案场
+2018/09/12 11:50:48 [E] 用户没有设置默认案场
+2018/09/12 11:54:38 [E] 用户没有设置默认案场
+2018/09/12 11:54:41 [E] 用户没有设置默认案场
+2018/09/12 11:54:45 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 11:54:45 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_L00IPNlls6l1dGNP0yd2aut_EFTLarqBafPHq_E_tM25DjU6NPQo7qzIrMgL24pVA3yWhi6Au_PdiWdf70rGaGmGX_g-frOVC47uY4Wz_9PHlg0LLQ-EFYvLB8lxgqommPSv-FGWpiNYp-f5BVMcACASMD","expires_in":7200})
+2018/09/12 11:54:45 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_L00IPNlls6l1dGNP0yd2aut_EFTLarqBafPHq_E_tM25DjU6NPQo7qzIrMgL24pVA3yWhi6Au_PdiWdf70rGaGmGX_g-frOVC47uY4Wz_9PHlg0LLQ-EFYvLB8lxgqommPSv-FGWpiNYp-f5BVMcACASMD])
+2018/09/12 11:54:46 [E] 用户没有设置默认案场
+2018/09/12 11:54:49 [E] 用户没有设置默认案场
+2018/09/12 11:56:28 [E] 用户没有设置默认案场
+2018/09/12 11:56:39 [E] 用户没有设置默认案场
+2018/09/12 11:56:41 [E] 用户没有设置默认案场
+2018/09/12 11:56:41 [E] 用户没有设置默认案场
+2018/09/12 11:56:44 [E] 用户没有设置默认案场
+2018/09/12 11:56:46 [E] 用户没有设置默认案场
+2018/09/12 11:56:52 [E] 用户没有设置默认案场
+2018/09/12 11:56:52 [E] 用户没有设置默认案场
+2018/09/12 11:56:52 [E] 用户没有设置默认案场
+2018/09/12 11:56:54 [E] 用户没有设置默认案场
+2018/09/12 11:56:54 [E] 用户没有设置默认案场
+2018/09/12 13:02:58 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 13:03:03 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_ri9FogXsOZzllRzEg982DKn7EJUbs4o04CLUqDK1qfEUbjFLxsIcaQIBQtx1fjEJsFeuj3esg2DWinMH02tEEC1a2DcKSjOLvXfm-KruzxGLwdx5Nxs5eL425K0xsiAVl7j61HWb2YeYO7KgCXUaAJAUPM","expires_in":7200})
+2018/09/12 13:03:03 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_ri9FogXsOZzllRzEg982DKn7EJUbs4o04CLUqDK1qfEUbjFLxsIcaQIBQtx1fjEJsFeuj3esg2DWinMH02tEEC1a2DcKSjOLvXfm-KruzxGLwdx5Nxs5eL425K0xsiAVl7j61HWb2YeYO7KgCXUaAJAUPM])
+2018/09/12 13:33:59 [E] 用户没有设置默认案场
+2018/09/12 13:34:06 [E] 用户没有设置默认案场
+2018/09/12 13:34:07 [E] 用户没有设置默认案场
+2018/09/12 13:35:01 [E] 用户没有设置默认案场
+2018/09/12 13:35:33 [E] 用户没有设置默认案场
+2018/09/12 13:35:35 [E] 用户没有设置默认案场
+2018/09/12 13:35:35 [E] 用户没有设置默认案场
+2018/09/12 13:36:17 [E] 用户没有设置默认案场
+2018/09/12 13:36:17 [E] 用户没有设置默认案场
+2018/09/12 13:36:20 [E] 用户没有设置默认案场
+2018/09/12 13:36:20 [E] 用户没有设置默认案场
+2018/09/12 13:36:24 [E] 用户没有设置默认案场
+2018/09/12 13:36:25 [E] 用户没有设置默认案场
+2018/09/12 13:36:27 [E] 用户没有设置默认案场
+2018/09/12 13:36:27 [E] 用户没有设置默认案场
+2018/09/12 13:36:29 [E] 用户没有设置默认案场
+2018/09/12 13:36:32 [E] 用户没有设置默认案场
+2018/09/12 13:36:32 [E] 用户没有设置默认案场
+2018/09/12 13:36:36 [E] 用户没有设置默认案场
+2018/09/12 13:36:37 [E] 用户没有设置默认案场
+2018/09/12 13:36:42 [E] 用户没有设置默认案场
+2018/09/12 13:36:42 [E] 用户没有设置默认案场
+2018/09/12 13:36:45 [E] 用户没有设置默认案场
+2018/09/12 13:36:46 [E] 用户没有设置默认案场
+2018/09/12 13:41:03 [E] 用户没有设置默认案场
+2018/09/12 13:41:06 [E] 用户没有设置默认案场
+2018/09/12 13:42:34 [E] 用户没有设置默认案场
+2018/09/12 13:42:34 [E] 用户没有设置默认案场
+2018/09/12 13:42:41 [E] 用户没有设置默认案场
+2018/09/12 13:42:41 [E] 用户没有设置默认案场
+2018/09/12 13:42:43 [E] 用户没有设置默认案场
+2018/09/12 13:42:43 [E] 用户没有设置默认案场
+2018/09/12 13:42:43 [E] 用户没有设置默认案场
+2018/09/12 13:42:44 [E] 用户没有设置默认案场
+2018/09/12 13:42:46 [E] 用户没有设置默认案场
+2018/09/12 13:42:46 [E] 用户没有设置默认案场
+2018/09/12 13:42:46 [E] 用户没有设置默认案场
+2018/09/12 13:42:48 [E] 用户没有设置默认案场
+2018/09/12 13:42:48 [E] 用户没有设置默认案场
+2018/09/12 13:42:48 [E] 用户没有设置默认案场
+2018/09/12 13:42:51 [E] 用户没有设置默认案场
+2018/09/12 13:42:51 [E] 用户没有设置默认案场
+2018/09/12 13:42:51 [E] 用户没有设置默认案场
+2018/09/12 13:42:52 [E] 用户没有设置默认案场
+2018/09/12 13:42:52 [E] 用户没有设置默认案场
+2018/09/12 13:42:52 [E] 用户没有设置默认案场
+2018/09/12 13:42:55 [E] 用户没有设置默认案场
+2018/09/12 13:42:55 [E] 用户没有设置默认案场
+2018/09/12 13:42:55 [E] 用户没有设置默认案场
+2018/09/12 13:42:56 [E] 用户没有设置默认案场
+2018/09/12 13:42:56 [E] 用户没有设置默认案场
+2018/09/12 13:42:56 [E] 用户没有设置默认案场
+2018/09/12 13:42:59 [E] 用户没有设置默认案场
+2018/09/12 13:42:59 [E] 用户没有设置默认案场
+2018/09/12 13:42:59 [E] 用户没有设置默认案场
+2018/09/12 13:43:00 [E] 用户没有设置默认案场
+2018/09/12 13:43:00 [E] 用户没有设置默认案场
+2018/09/12 13:43:00 [E] 用户没有设置默认案场
+2018/09/12 13:43:02 [E] 用户没有设置默认案场
+2018/09/12 13:43:02 [E] 用户没有设置默认案场
+2018/09/12 13:43:02 [E] 用户没有设置默认案场
+2018/09/12 13:43:04 [E] 用户没有设置默认案场
+2018/09/12 13:43:05 [E] 用户没有设置默认案场
+2018/09/12 13:43:06 [E] 用户没有设置默认案场
+2018/09/12 13:43:07 [E] 用户没有设置默认案场
+2018/09/12 13:43:09 [E] 用户没有设置默认案场
+2018/09/12 13:43:09 [E] 用户没有设置默认案场
+2018/09/12 13:43:10 [E] 用户没有设置默认案场
+2018/09/12 13:43:10 [E] 用户没有设置默认案场
+2018/09/12 13:43:11 [E] 用户没有设置默认案场
+2018/09/12 13:43:12 [E] 用户没有设置默认案场
+2018/09/12 13:43:13 [E] 用户没有设置默认案场
+2018/09/12 13:43:13 [E] 用户没有设置默认案场
+2018/09/12 13:43:15 [E] 用户没有设置默认案场
+2018/09/12 13:43:15 [E] 用户没有设置默认案场
+2018/09/12 13:43:15 [E] 用户没有设置默认案场
+2018/09/12 13:43:15 [E] 用户没有设置默认案场
+2018/09/12 13:43:16 [E] 用户没有设置默认案场
+2018/09/12 13:43:16 [E] 用户没有设置默认案场
+2018/09/12 13:43:18 [E] 用户没有设置默认案场
+2018/09/12 13:43:18 [E] 用户没有设置默认案场
+2018/09/12 13:43:19 [E] 用户没有设置默认案场
+2018/09/12 13:43:19 [E] 用户没有设置默认案场
+2018/09/12 13:43:23 [E] 用户没有设置默认案场
+2018/09/12 13:43:23 [E] 用户没有设置默认案场
+2018/09/12 13:43:25 [E] 用户没有设置默认案场
+2018/09/12 13:43:25 [E] 用户没有设置默认案场
+2018/09/12 13:43:30 [E] 用户没有设置默认案场
+2018/09/12 13:44:39 [E] 用户没有设置默认案场
+2018/09/12 13:44:39 [E] 用户没有设置默认案场
+2018/09/12 13:44:39 [E] 用户没有设置默认案场
+2018/09/12 13:45:11 [E] 用户没有设置默认案场
+2018/09/12 13:45:11 [E] 用户没有设置默认案场
+2018/09/12 13:45:11 [E] 用户没有设置默认案场
+2018/09/12 13:50:49 [E] 用户没有设置默认案场
+2018/09/12 13:52:44 [E] 用户没有设置默认案场
+2018/09/12 13:52:44 [E] 用户没有设置默认案场
+2018/09/12 13:52:47 [E] 用户没有设置默认案场
+2018/09/12 13:52:47 [E] 用户没有设置默认案场
+2018/09/12 13:52:47 [E] 用户没有设置默认案场
+2018/09/12 13:53:07 [E] 用户没有设置默认案场
+2018/09/12 13:53:07 [E] 用户没有设置默认案场
+2018/09/12 13:53:09 [E] 用户没有设置默认案场
+2018/09/12 13:53:10 [E] 用户没有设置默认案场
+2018/09/12 13:53:10 [E] 用户没有设置默认案场
+2018/09/12 13:53:14 [E] 用户没有设置默认案场
+2018/09/12 13:53:14 [E] 用户没有设置默认案场
+2018/09/12 13:53:14 [E] 用户没有设置默认案场
+2018/09/12 13:53:19 [E] 用户没有设置默认案场
+2018/09/12 13:53:19 [E] 用户没有设置默认案场
+2018/09/12 13:54:03 [E] 用户没有设置默认案场
+2018/09/12 13:54:03 [E] 用户没有设置默认案场
+2018/09/12 13:54:03 [E] 用户没有设置默认案场
+2018/09/12 13:54:06 [E] 用户没有设置默认案场
+2018/09/12 13:54:06 [E] 用户没有设置默认案场
+2018/09/12 13:54:06 [E] 用户没有设置默认案场
+2018/09/12 13:54:06 [E] 用户没有设置默认案场
+2018/09/12 13:54:08 [E] 用户没有设置默认案场
+2018/09/12 13:54:08 [E] 用户没有设置默认案场
+2018/09/12 13:54:13 [E] 用户没有设置默认案场
+2018/09/12 13:54:14 [E] 用户没有设置默认案场
+2018/09/12 13:54:14 [E] 用户没有设置默认案场
+2018/09/12 13:54:16 [E] 用户没有设置默认案场
+2018/09/12 13:54:18 [E] 用户没有设置默认案场
+2018/09/12 13:54:18 [E] 用户没有设置默认案场
+2018/09/12 13:54:18 [E] 用户没有设置默认案场
+2018/09/12 13:54:22 [E] 用户没有设置默认案场
+2018/09/12 13:54:22 [E] 用户没有设置默认案场
+2018/09/12 13:54:27 [E] 用户没有设置默认案场
+2018/09/12 13:54:27 [E] 用户没有设置默认案场
+2018/09/12 13:54:29 [E] 用户没有设置默认案场
+2018/09/12 13:54:30 [E] 用户没有设置默认案场
+2018/09/12 13:54:30 [E] 用户没有设置默认案场
+2018/09/12 13:54:32 [E] 用户没有设置默认案场
+2018/09/12 13:54:33 [E] 用户没有设置默认案场
+2018/09/12 13:54:33 [E] 用户没有设置默认案场
+2018/09/12 13:54:33 [E] 用户没有设置默认案场
+2018/09/12 13:54:37 [E] 用户没有设置默认案场
+2018/09/12 13:54:37 [E] 用户没有设置默认案场
+2018/09/12 13:57:54 [E] 用户没有设置默认案场
+2018/09/12 13:57:54 [E] 用户没有设置默认案场
+2018/09/12 13:57:56 [E] 用户没有设置默认案场
+2018/09/12 13:57:56 [E] 用户没有设置默认案场
+2018/09/12 13:57:57 [E] 用户没有设置默认案场
+2018/09/12 13:59:36 [E] 用户没有设置默认案场
+2018/09/12 13:59:36 [E] 用户没有设置默认案场
+2018/09/12 13:59:43 [E] 用户没有设置默认案场
+2018/09/12 13:59:49 [E] 用户没有设置默认案场
+2018/09/12 13:59:49 [E] 用户没有设置默认案场
+2018/09/12 13:59:51 [E] 用户没有设置默认案场
+2018/09/12 13:59:52 [E] 用户没有设置默认案场
+2018/09/12 13:59:55 [E] 用户没有设置默认案场
+2018/09/12 13:59:55 [E] 用户没有设置默认案场
+2018/09/12 13:59:55 [E] 用户没有设置默认案场
+2018/09/12 13:59:58 [E] 用户没有设置默认案场
+2018/09/12 13:59:58 [E] 用户没有设置默认案场
+2018/09/12 13:59:59 [E] 用户没有设置默认案场
+2018/09/12 14:00:07 [E] 用户没有设置默认案场
+2018/09/12 14:00:07 [E] 用户没有设置默认案场
+2018/09/12 14:00:10 [E] 用户没有设置默认案场
+2018/09/12 14:00:10 [E] 用户没有设置默认案场
+2018/09/12 14:00:10 [E] 用户没有设置默认案场
+2018/09/12 14:00:10 [E] 用户没有设置默认案场
+2018/09/12 14:03:11 [E] 用户没有设置默认案场
+2018/09/12 14:03:15 [E] 用户没有设置默认案场
+2018/09/12 14:04:13 [E] 用户没有设置默认案场
+2018/09/12 14:04:17 [E] 用户没有设置默认案场
+2018/09/12 14:04:17 [E] 用户没有设置默认案场
+2018/09/12 14:04:19 [E] 用户没有设置默认案场
+2018/09/12 14:04:19 [E] 用户没有设置默认案场
+2018/09/12 14:04:19 [E] 用户没有设置默认案场
+2018/09/12 14:04:21 [E] 用户没有设置默认案场
+2018/09/12 14:04:21 [E] 用户没有设置默认案场
+2018/09/12 14:04:27 [E] 用户没有设置默认案场
+2018/09/12 14:04:27 [E] 用户没有设置默认案场
+2018/09/12 14:04:27 [E] 用户没有设置默认案场
+2018/09/12 14:04:31 [E] 用户没有设置默认案场
+2018/09/12 14:04:31 [E] 用户没有设置默认案场
+2018/09/12 14:04:31 [E] 用户没有设置默认案场
+2018/09/12 14:05:05 [E] 用户没有设置默认案场
+2018/09/12 14:05:05 [E] 用户没有设置默认案场
+2018/09/12 14:05:05 [E] 用户没有设置默认案场
+2018/09/12 14:05:07 [E] 用户没有设置默认案场
+2018/09/12 14:05:07 [E] 用户没有设置默认案场
+2018/09/12 14:05:08 [E] 用户没有设置默认案场
+2018/09/12 14:05:08 [E] 用户没有设置默认案场
+2018/09/12 14:05:08 [E] 用户没有设置默认案场
+2018/09/12 14:05:08 [E] 用户没有设置默认案场
+2018/09/12 14:05:09 [E] 用户没有设置默认案场
+2018/09/12 14:05:10 [E] 用户没有设置默认案场
+2018/09/12 14:05:10 [E] 用户没有设置默认案场
+2018/09/12 14:05:11 [E] 用户没有设置默认案场
+2018/09/12 14:05:12 [E] 用户没有设置默认案场
+2018/09/12 14:05:12 [E] 用户没有设置默认案场
+2018/09/12 14:05:12 [E] 用户没有设置默认案场
+2018/09/12 14:05:13 [E] 用户没有设置默认案场
+2018/09/12 14:05:13 [E] 用户没有设置默认案场
+2018/09/12 14:06:44 [E] 用户没有设置默认案场
+2018/09/12 14:06:44 [E] 用户没有设置默认案场
+2018/09/12 14:06:45 [E] 用户没有设置默认案场
+2018/09/12 14:06:48 [E] 用户没有设置默认案场
+2018/09/12 14:06:48 [E] 用户没有设置默认案场
+2018/09/12 14:06:50 [E] 用户没有设置默认案场
+2018/09/12 14:06:50 [E] 用户没有设置默认案场
+2018/09/12 14:06:51 [E] 用户没有设置默认案场
+2018/09/12 14:06:52 [E] 用户没有设置默认案场
+2018/09/12 14:06:52 [E] 用户没有设置默认案场
+2018/09/12 14:06:52 [E] 用户没有设置默认案场
+2018/09/12 14:06:55 [E] 用户没有设置默认案场
+2018/09/12 14:06:55 [E] 用户没有设置默认案场
+2018/09/12 14:06:55 [E] 用户没有设置默认案场
+2018/09/12 14:06:56 [E] 用户没有设置默认案场
+2018/09/12 14:06:56 [E] 用户没有设置默认案场
+2018/09/12 14:06:57 [E] 用户没有设置默认案场
+2018/09/12 14:06:59 [E] 用户没有设置默认案场
+2018/09/12 14:06:59 [E] 用户没有设置默认案场
+2018/09/12 14:07:00 [E] 用户没有设置默认案场
+2018/09/12 14:07:00 [E] 用户没有设置默认案场
+2018/09/12 14:07:00 [E] 用户没有设置默认案场
+2018/09/12 14:07:34 [E] 用户没有设置默认案场
+2018/09/12 14:07:34 [E] 用户没有设置默认案场
+2018/09/12 14:07:34 [E] 用户没有设置默认案场
+2018/09/12 14:07:48 [E] 用户没有设置默认案场
+2018/09/12 14:07:48 [E] 用户没有设置默认案场
+2018/09/12 14:07:50 [E] 用户没有设置默认案场
+2018/09/12 14:07:50 [E] 用户没有设置默认案场
+2018/09/12 14:07:50 [E] 用户没有设置默认案场
+2018/09/12 14:07:52 [E] 用户没有设置默认案场
+2018/09/12 14:07:52 [E] 用户没有设置默认案场
+2018/09/12 14:07:52 [E] 用户没有设置默认案场
+2018/09/12 14:07:54 [E] 用户没有设置默认案场
+2018/09/12 14:07:54 [E] 用户没有设置默认案场
+2018/09/12 14:07:54 [E] 用户没有设置默认案场
+2018/09/12 14:07:55 [E] 用户没有设置默认案场
+2018/09/12 14:07:55 [E] 用户没有设置默认案场
+2018/09/12 14:07:55 [E] 用户没有设置默认案场
+2018/09/12 14:08:02 [E] 用户没有设置默认案场
+2018/09/12 14:08:03 [E] 用户没有设置默认案场
+2018/09/12 14:08:03 [E] 用户没有设置默认案场
+2018/09/12 14:08:03 [E] 用户没有设置默认案场
+2018/09/12 14:08:03 [E] 用户没有设置默认案场
+2018/09/12 14:08:04 [E] 用户没有设置默认案场
+2018/09/12 14:08:04 [E] 用户没有设置默认案场
+2018/09/12 14:08:04 [E] 用户没有设置默认案场
+2018/09/12 14:08:05 [E] 用户没有设置默认案场
+2018/09/12 14:08:06 [E] 用户没有设置默认案场
+2018/09/12 14:08:06 [E] 用户没有设置默认案场
+2018/09/12 14:08:06 [E] 用户没有设置默认案场
+2018/09/12 14:08:07 [E] 用户没有设置默认案场
+2018/09/12 14:08:07 [E] 用户没有设置默认案场
+2018/09/12 14:08:17 [E] 用户没有设置默认案场
+2018/09/12 14:08:17 [E] 用户没有设置默认案场
+2018/09/12 14:08:18 [E] 用户没有设置默认案场
+2018/09/12 14:08:18 [E] 用户没有设置默认案场
+2018/09/12 14:08:18 [E] 用户没有设置默认案场
+2018/09/12 14:08:20 [E] 用户没有设置默认案场
+2018/09/12 14:08:20 [E] 用户没有设置默认案场
+2018/09/12 14:08:20 [E] 用户没有设置默认案场
+2018/09/12 14:08:21 [E] 用户没有设置默认案场
+2018/09/12 14:08:21 [E] 用户没有设置默认案场
+2018/09/12 14:08:22 [E] 用户没有设置默认案场
+2018/09/12 14:08:22 [E] 用户没有设置默认案场
+2018/09/12 14:08:23 [E] 用户没有设置默认案场
+2018/09/12 14:08:23 [E] 用户没有设置默认案场
+2018/09/12 14:08:24 [E] 用户没有设置默认案场
+2018/09/12 14:08:24 [E] 用户没有设置默认案场
+2018/09/12 14:08:24 [E] 用户没有设置默认案场
+2018/09/12 14:08:25 [E] 用户没有设置默认案场
+2018/09/12 14:08:26 [E] 用户没有设置默认案场
+2018/09/12 14:08:26 [E] 用户没有设置默认案场
+2018/09/12 14:08:27 [E] 用户没有设置默认案场
+2018/09/12 14:08:27 [E] 用户没有设置默认案场
+2018/09/12 14:08:27 [E] 用户没有设置默认案场
+2018/09/12 14:08:28 [E] 用户没有设置默认案场
+2018/09/12 14:08:29 [E] 用户没有设置默认案场
+2018/09/12 14:08:29 [E] 用户没有设置默认案场
+2018/09/12 14:10:17 [E] 用户没有设置默认案场
+2018/09/12 14:10:17 [E] 用户没有设置默认案场
+2018/09/12 14:10:24 [E] 用户没有设置默认案场
+2018/09/12 14:11:23 [E] 用户没有设置默认案场
+2018/09/12 14:11:23 [E] 用户没有设置默认案场
+2018/09/12 14:11:42 [E] 用户没有设置默认案场
+2018/09/12 14:12:16 [E] 用户没有设置默认案场
+2018/09/12 14:12:16 [E] 用户没有设置默认案场
+2018/09/12 14:12:16 [E] 用户没有设置默认案场
+2018/09/12 14:12:18 [E] 解密 Base64 字串失败: illegal base64 data at input byte 0
+2018/09/12 14:12:18 [E] 获取组织信息失败: 没有查询到机构信息
+2018/09/12 14:12:18 [E] 用户没有设置默认案场
+2018/09/12 14:12:32 [E] 用户没有设置默认案场
+2018/09/12 14:12:32 [E] 用户没有设置默认案场
+2018/09/12 14:12:32 [E] 用户没有设置默认案场
+2018/09/12 14:16:09 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 14:16:09 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_TP-2l8mlyotE0zKpHpk6tfyd7LoANq3_KSx7OrxhRYCFjvfATXngEhYHQzWdiptJerGUayCPQGaKjKaVY80PrQCGW2fQdKBHAoi_UbYUrlOBNn8ej5bItPIW55tfRbmJbRWOcPkcNMarsVXWEBIaAIAROV","expires_in":7200})
+2018/09/12 14:16:09 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_TP-2l8mlyotE0zKpHpk6tfyd7LoANq3_KSx7OrxhRYCFjvfATXngEhYHQzWdiptJerGUayCPQGaKjKaVY80PrQCGW2fQdKBHAoi_UbYUrlOBNn8ej5bItPIW55tfRbmJbRWOcPkcNMarsVXWEBIaAIAROV expires_in:7200])
+2018/09/12 14:16:18 [E] 用户没有设置默认案场
+2018/09/12 14:16:18 [E] 用户没有设置默认案场
+2018/09/12 14:20:28 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 14:20:28 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_6cXJhV-7Luh4-xqkbRxCsoQiUV0j-zAfNmXR33XYtjRHNnK7Qk-ZiWmlbkXmpz5wyu1r7F782SIFCQhK6NoN02MCIAzsdiufgUQFUJV8ZE0L2NFC06jsJRDR0hNBai3XQM3WUFhT9KZnj26qLBTdAFAHXP","expires_in":7200})
+2018/09/12 14:20:28 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_6cXJhV-7Luh4-xqkbRxCsoQiUV0j-zAfNmXR33XYtjRHNnK7Qk-ZiWmlbkXmpz5wyu1r7F782SIFCQhK6NoN02MCIAzsdiufgUQFUJV8ZE0L2NFC06jsJRDR0hNBai3XQM3WUFhT9KZnj26qLBTdAFAHXP])
+2018/09/12 14:22:35 [E] 用户没有设置默认案场
+2018/09/12 14:22:39 [E] 用户没有设置默认案场
+2018/09/12 14:22:42 [E] 用户没有设置默认案场
+2018/09/12 14:23:11 [E] 用户没有设置默认案场
+2018/09/12 14:23:22 [E] 用户没有设置默认案场
+2018/09/12 14:23:29 [E] 用户没有设置默认案场
+2018/09/12 14:23:30 [E] 用户没有设置默认案场
+2018/09/12 14:23:30 [E] 用户没有设置默认案场
+2018/09/12 14:23:30 [E] 用户没有设置默认案场
+2018/09/12 14:23:32 [E] 用户没有设置默认案场
+2018/09/12 14:23:34 [E] 用户没有设置默认案场
+2018/09/12 14:23:37 [E] 用户没有设置默认案场
+2018/09/12 14:23:38 [E] 用户没有设置默认案场
+2018/09/12 14:23:38 [E] 用户没有设置默认案场
+2018/09/12 14:23:39 [E] 用户没有设置默认案场
+2018/09/12 14:23:41 [E] 用户没有设置默认案场
+2018/09/12 14:23:41 [E] 用户没有设置默认案场
+2018/09/12 14:23:43 [E] 用户没有设置默认案场
+2018/09/12 14:23:45 [E] 用户没有设置默认案场
+2018/09/12 14:23:48 [E] 用户没有设置默认案场
+2018/09/12 14:23:48 [E] 用户没有设置默认案场
+2018/09/12 14:23:50 [E] 用户没有设置默认案场
+2018/09/12 14:23:51 [E] 用户没有设置默认案场
+2018/09/12 14:23:52 [E] 用户没有设置默认案场
+2018/09/12 14:23:54 [E] 用户没有设置默认案场
+2018/09/12 14:23:54 [E] 用户没有设置默认案场
+2018/09/12 14:23:55 [E] 用户没有设置默认案场
+2018/09/12 14:23:58 [E] 用户没有设置默认案场
+2018/09/12 14:23:58 [E] 删除商品规格失败: Error 1064: You have an error in your SQL syntax; check the manual that corresponds to your MySQL server version for the right syntax to use near 'b.spec_id='24d205e9-cd33-4602-976d-7bf69fa6d7b8'' at line 1
+2018/09/12 14:25:04 [E] 用户没有设置默认案场
+2018/09/12 14:25:07 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 14:25:08 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_cGWgMW0Dy_6gDn4WgmLL3CeQvPN3Pqi8eznKe8TpmKWOfDMgGKh2ITAr7GLFk16mX2KyeyGy4Hvrxot2h3zJqmV9JiDAi7gwmoRHI35xjYf6jYA9GkuK6tKjnojPMMzTQP2Seaq_xt1_Inn3JPTiAFACIM","expires_in":7200})
+2018/09/12 14:25:08 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_cGWgMW0Dy_6gDn4WgmLL3CeQvPN3Pqi8eznKe8TpmKWOfDMgGKh2ITAr7GLFk16mX2KyeyGy4Hvrxot2h3zJqmV9JiDAi7gwmoRHI35xjYf6jYA9GkuK6tKjnojPMMzTQP2Seaq_xt1_Inn3JPTiAFACIM expires_in:7200])
+2018/09/12 14:25:09 [E] 用户没有设置默认案场
+2018/09/12 14:25:12 [E] 用户没有设置默认案场
+2018/09/12 14:25:18 [E] 用户没有设置默认案场
+2018/09/12 14:25:18 [E] 用户没有设置默认案场
+2018/09/12 14:25:22 [E] 用户没有设置默认案场
+2018/09/12 14:25:22 [E] 用户没有设置默认案场
+2018/09/12 14:25:23 [E] 用户没有设置默认案场
+2018/09/12 14:25:27 [E] 用户没有设置默认案场
+2018/09/12 14:25:36 [E] 用户没有设置默认案场
+2018/09/12 14:25:39 [E] 用户没有设置默认案场
+2018/09/12 14:26:48 [E] 用户没有设置默认案场
+2018/09/12 14:26:51 [E] 用户没有设置默认案场
+2018/09/12 14:26:51 [E] 获取商品规格失败: Error 1054: Unknown column 'create_date' in 'order clause'
+2018/09/12 14:27:38 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/09/12 14:27:38 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_0QjgwowdSGInKdwbrmtbkXrv6GoHX0tx6D0z56rH8acNnHqeB0NgY4tzJ4KFVi7YxnIBH9ZMnePZVbpKUMJBJ0uZp3RPnjz3ughGkbP_weau5lL_3Mbs3Xrrsi6_sXkPUesmk1P9eN767-oSFIQcAJAMPX","expires_in":7200})
+2018/09/12 14:27:38 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_0QjgwowdSGInKdwbrmtbkXrv6GoHX0tx6D0z56rH8acNnHqeB0NgY4tzJ4KFVi7YxnIBH9ZMnePZVbpKUMJBJ0uZp3RPnjz3ughGkbP_weau5lL_3Mbs3Xrrsi6_sXkPUesmk1P9eN767-oSFIQcAJAMPX expires_in:7200])

models/cases/cases.go

@@ -154,3 +154,10 @@ func (m *CaseDAO) GetCaseUserByType(csIDs []string, typeID string) ([]UserCase,
 
 	return users, nil
 }
+
+// GetCaseByIDs 获取案场信息
+func (m *CaseDAO) GetCaseByIDs(caseids string) ([]model.SysCase, error) {
+	var cases []model.SysCase
+	err := m.db.Where("status>" + strconv.Itoa(models.STATUS_DEL)).And("case_id in ('" + strings.Replace(caseids, ",", "','", -1) + "')").Find(&cases)
+	return cases, err
+}

models/constant.go

@@ -124,3 +124,10 @@ const (
 	GYM_CARD_QUARTER = "quarter"
 	GYM_CARD_YEAR    = "year"
 )
+
+// 系统资源
+// 可用于卡券关联内容选择
+const (
+	SYS_RESOURCE_COURSE = "course"
+	SYS_RESOURCE_GOODS  = "goods"
+)

models/coupon/coupon.go

@@ -96,6 +96,7 @@ func (m *CouponDAO) GetCouponList(filters []string, limit []int) ([]model.TaCoup
 	filterString := ""
 	if len(filters) > 0 {
 		filterString = strings.Join(filters, " and ")
+		filterString += " and "
 	}
 
 	sql := `select * from ta_coupon where %s status = 1 order by create_date desc`

models/coupon/target.go

@@ -1,6 +1,7 @@
 package coupon
 
 import (
+	"errors"
 	"spaceofcheng/services/models/model"
 )
 
@@ -11,6 +12,13 @@ func (m *CouponDAO) UpdateTarget(targets []model.TaCouponTarget, couponID string
 	}
 
 	for i := range targets {
+		if targets[i].TargetId == "" {
+			return errors.New("关联内容不能为空")
+		}
+
+		// TODO
+		// 校验关联内容是否有效
+
 		targets[i].CouponId = couponID
 	}
 

models/goods/goods.go

@@ -250,6 +250,8 @@ func (m *GoodsDAO) UpdateGoods(goods *model.TaGoods, images []string, specs []Sp
 		"goods_name",
 		"type_id",
 		"status",
+		"price",
+		"case_id",
 	}
 
 	// 商品图片
@@ -320,3 +322,18 @@ func (m *GoodsDAO) GetGoodsImgByGoodsID(goodsid string) ([]model.TaGoodsImg, err
 	err := m.db.Where("goods_id=?", goodsid).Find(&goodsimg)
 	return goodsimg, err
 }
+
+// GetGoodsBySpec 根据商品规格获取商品信息
+func (m *GoodsDAO) GetGoodsBySpec(specid string) ([]model.TaGoods, error) {
+	var goods []model.TaGoods
+	sql := `select a.* from ta_goods a inner join ta_goods_spec b on a.goods_id=b.goods_id where a.status>` + strconv.Itoa(models.STATUS_DEL) + ` and b.spec_id='` + specid + `'`
+	err := m.db.Sql(sql).Find(&goods)
+	return goods, err
+}
+
+// GetGoodsByType 根据商品类型获取商品信息
+func (m *GoodsDAO) GetGoodsByType(typeid string) ([]model.TaGoods, error) {
+	var goods []model.TaGoods
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("type_id=?", typeid).Find(&goods)
+	return goods, err
+}

models/goods/spec.go

@@ -6,6 +6,7 @@ import (
 	"spaceofcheng/services/utils"
 	"strconv"
 	"strings"
+	"time"
 )
 
 // GetGoodsSpecCount 获取商品规格总数
@@ -18,7 +19,7 @@ func (m *GoodsDAO) GetGoodsSpecCount(caseids string) (int, error) {
 // GetGoodsSpec 根据案场获取商品规格
 func (m *GoodsDAO) GetGoodsSpec(caseids string, page int, pageSize int) ([]model.TdSpec, error) {
 	var goodsSpec []model.TdSpec
-	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Limit(pageSize, (page-1)*pageSize).Find(&goodsSpec)
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Desc("create_date").Limit(pageSize, (page-1)*pageSize).Find(&goodsSpec)
 	return goodsSpec, err
 }
 
@@ -39,6 +40,7 @@ func (m *GoodsDAO) GetGoodsSpecByID(specid string) (*model.TdSpec, error) {
 func (m *GoodsDAO) AddGoodsSpec(goodsSpec *model.TdSpec) (*model.TdSpec, error) {
 	goodsSpec.SpecId = utils.GetGUID()
 	goodsSpec.Status = models.STATUS_NORMAL
+	goodsSpec.CreateDate = time.Now()
 	_, err := m.db.Insert(goodsSpec)
 	return goodsSpec, err
 }
@@ -47,6 +49,7 @@ func (m *GoodsDAO) AddGoodsSpec(goodsSpec *model.TdSpec) (*model.TdSpec, error)
 func (m *GoodsDAO) UpdateGoodsSpec(goodsSpec model.TdSpec) error {
 	var cols = []string{
 		"spec_name",
+		"case_id",
 	}
 	_, err := m.db.Cols(cols...).Where("spec_id=?", goodsSpec.SpecId).Update(goodsSpec)
 	return err

models/goods/type.go

@@ -25,7 +25,7 @@ func (m *GoodsDAO) GetGoodsTypeByCase(caseid string) ([]model.TdGoodsType, error
 // GetGoodsType 根据案场获取商品类型
 func (m *GoodsDAO) GetGoodsType(caseids string, page int, pageSize int) ([]model.TdGoodsType, error) {
 	var goodstype []model.TdGoodsType
-	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Limit(pageSize, (page-1)*pageSize).Desc("create_date").Find(&goodstype)
+	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("case_id in ('"+strings.Replace(caseids, ",", "','", -1)+"')").Desc("create_date").Limit(pageSize, (page-1)*pageSize).Desc("create_date").Find(&goodstype)
 	return goodstype, err
 }
 

models/model/ta_coupon.go

@@ -8,7 +8,7 @@ type TaCoupon struct {
 	CouponId     string    `xorm:"not null pk VARCHAR(64)"`
 	CouponName   string    `xorm:"VARCHAR(255)"`
 	CouponTypeId string    `xorm:"VARCHAR(64)"`
-	SendType     int       `xorm:"comment('0案场 1渠道') SMALLINT(6)"`
+	SendType     string    `xorm:"VARCHAR(20)"`
 	VideoUrl     string    `xorm:"TEXT"`
 	CoverUrl     string    `xorm:"TEXT"`
 	Price        string    `xorm:"DECIMAL(64)"`

models/model/ta_coupon_target.go

@@ -1,6 +1,7 @@
 package model
 
 type TaCouponTarget struct {
+	TargetType string `xorm:"not null pk VARCHAR(20)"`
 	TargetId   string `xorm:"not null pk VARCHAR(64)"`
 	CouponId   string `xorm:"VARCHAR(64)"`
 	TargetName string `xorm:"VARCHAR(255)"`

models/model/td_spec.go

@@ -1,9 +1,12 @@
 package model
 
+import "time"
+
 type TdSpec struct {
-	SpecId   string `xorm:"not null pk VARCHAR(64)"`
-	SpecName string `xorm:"VARCHAR(50)"`
-	Status   int    `xorm:"SMALLINT(6)"`
-	OrgId    string `xorm:"VARCHAR(64)"`
-	CaseId   string `xorm:"VARCHAR(64)"`
+	SpecId     string    `xorm:"not null pk VARCHAR(64)"`
+	SpecName   string    `xorm:"VARCHAR(50)"`
+	Status     int       `xorm:"SMALLINT(6)"`
+	OrgId      string    `xorm:"VARCHAR(64)"`
+	CaseId     string    `xorm:"VARCHAR(64)"`
+	CreateDate time.Time `xorm:"DATETIME"`
 }

models/system/user.go

@@ -421,3 +421,37 @@ func (m *UserDAO) GetForbidUserByUserID(userID string) ([]model.TaForbidUser, er
 
 	return fbUsers, nil
 }
+
+// CheckUserPhone 用户电话重复校验
+func (m *UserDAO) CheckUserPhone(userid, phone, orgid string) (bool, error) {
+	var users []model.SysUser
+	dao := m.db.Where("phone=?", phone).And("org_id=?", orgid)
+	if userid != "" {
+		dao.And("user_id <> '" + userid + "'")
+	}
+	err := dao.Find(&users)
+	if err != nil {
+		return false, err
+	}
+	if len(users) > 0 {
+		return false, nil
+	}
+	return true, nil
+}
+
+// CheckUserName 用户账户名重复校验
+func (m *UserDAO) CheckUserName(userid, username, orgid string) (bool, error) {
+	var users []model.SysUser
+	dao := m.db.Where("user_name=?", username).And("org_id=?", orgid)
+	if userid != "" {
+		dao.And("user_id <> '" + userid + "'")
+	}
+	err := dao.Find(&users)
+	if err != nil {
+		return false, err
+	}
+	if len(users) > 0 {
+		return false, nil
+	}
+	return true, nil
+}

routers/common.go

@@ -4,6 +4,7 @@ import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/cases"
 	"spaceofcheng/services/controllers/channel"
+	"spaceofcheng/services/controllers/coupon"
 	"spaceofcheng/services/controllers/course"
 	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/goods"
@@ -222,6 +223,12 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/order/goods/finish/:id", &goods.GoodsController{}, "put:FinishMake"),
 		beego.NSRouter("/order/goods/cancel/:id", &goods.GoodsController{}, "put:CancelMake"),
 
+		// 优惠券
+		beego.NSRouter("/coupon", &coupon.CouponController{}, "get:ListByCase"),
+		beego.NSRouter("/coupon", &coupon.CouponController{}, "post:SaveCoupon"),
+		beego.NSRouter("/coupon/:id", &coupon.CouponController{}, "put:UpdateCoupon"),
+		beego.NSRouter("/coupon/:id/to/:users", &coupon.CouponController{}, "post:GiveCoupon"),
+
 		// 文件
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
 

service/coupon/coupon.go

@@ -7,6 +7,7 @@ import (
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
+	"strings"
 	"time"
 
 	"github.com/yl10/kit/guid"
@@ -30,19 +31,34 @@ func NewCouponServ(ctx *utils.Context) *CouponServ {
 
 // GetCouponList 获取优惠券列表
 func (s *CouponServ) GetCouponList(caseID string, pagenavi ...int) ([]model.TaCoupon, int64, error) {
-	if caseID == "" {
-		return nil, 0, errors.New("未指定案场")
-	}
+	filters := []string{}
 
-	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
-		return nil, 0, err
-	}
+	if caseID != "" {
+		if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
+			return nil, 0, err
+		}
 
-	limit := utils.GetPageNaviLimit(pagenavi...)
-	filters := []string{
-		"case_id='" + caseID + "'",
+		filters = []string{
+			"case_id='" + caseID + "'",
+		}
+	} else {
+		casesRaw := s.ctx.Get("cases")
+		if casesRaw == nil {
+			return nil, 0, errors.New("请设置过滤案场")
+		}
+
+		cases := casesRaw.([]model.SysUserCase)
+		caseIDs := []string{}
+		for _, cs := range cases {
+			caseIDs = append(caseIDs, cs.CaseId)
+		}
+
+		filters = []string{
+			"case_id in ('" + strings.Join(caseIDs, "','") + "')",
+		}
 	}
 
+	limit := utils.GetPageNaviLimit(pagenavi...)
 	res, total, err := s.dao.GetCouponList(filters, limit)
 	if err != nil {
 		utils.LogError("查询优惠券列表失败: " + err.Error())
@@ -176,17 +192,6 @@ func (s *CouponServ) GiveCoupon(couponID string, uids []string) error {
 		}
 	}
 
-	// 计算卡券有效期
-	startDate := cp.StartDate
-	endDate := cp.EndDate
-	if cp.ValidDays > 0 {
-		startDate = now
-		hs := int64(cp.ValidDays * 24)
-		endDate = now.Add(time.Hour * time.Duration(hs))
-	}
-
-	cps := make([]model.TaCustomerCoupon, 0)
-	recs := make([]model.TaCouponGiveRecord, 0)
 	for _, uid := range uids {
 		// 获取客户信息
 		cust, err := s.custDao.GetCustomerByID(uid)
@@ -195,56 +200,121 @@ func (s *CouponServ) GiveCoupon(couponID string, uids []string) error {
 			return errors.New("校验客户信息失败")
 		}
 
-		// 检查用户是否已经有了该券
-		custCPS, err := s.dao.CheckCustCoupon(uid, cp.CouponId, startDate, endDate)
-		if err != nil {
-			utils.LogError("校验客户优惠券失败: " + err.Error())
-			return errors.New("校验客户优惠券失败")
+		if err := s.GiveCouponTo(&user, cust, cp); err != nil {
+			return err
 		}
+	}
 
-		if custCPS != nil && len(custCPS) > 0 {
-			return errors.New("客户 " + cust.CustomerName + " 已经拥有该券")
-		}
+	return nil
+}
 
-		// 放入我的卡券
-		custCP := model.TaCustomerCoupon{
-			CouponId:           cp.CouponId,
-			CustomerCouponName: cp.CouponName,
-			CustomerId:         uid,
-			StartDate:          startDate,
-			EndDate:            endDate,
-			ReceiveDate:        now,
-			CaseId:             cp.CaseId,
-			OrgId:              cp.OrgId,
-		}
+// GiveCouponTo 赠送优惠券
+// 本方法会被多出调用, 方法内使用 Context 将是不安全的
+func (s *CouponServ) GiveCouponTo(from *model.SysUser, to *model.TaCustomer, cp *model.TaCoupon) error {
+	if from.UserId == "" {
+		return errors.New("必须指定赠送人")
+	}
+
+	if to.CustomerId == "" {
+		return errors.New("必须指定接收人")
+	}
 
-		cps = append(cps, custCP)
-
-		// 放入赠送记录
-		rec := model.TaCouponGiveRecord{
-			GiftType:   models.GIVE_GIFT_COUPON,
-			GiftId:     cp.CouponId,
-			GiftName:   cp.CouponName,
-			FromId:     user.UserId,
-			FromName:   user.UserName,
-			ToId:       cust.CustomerId,
-			ToName:     cust.CustomerName,
-			CreateDate: now,
+	// 优惠券必须状态正常
+	if cp.CouponId == "" || cp.Status != models.STATUS_NORMAL {
+		return errors.New("优惠券已失效或者不存在")
+	}
+
+	now := time.Now().Local()
+	if cp.ValidDays <= 0 {
+		if cp.EndDate.Before(now) {
+			return errors.New("优惠券已失效")
 		}
+	}
+
+	// 计算卡券有效期
+	startDate := cp.StartDate
+	endDate := cp.EndDate
+	if cp.ValidDays > 0 {
+		startDate = now
+		hs := int64(cp.ValidDays * 24)
+		endDate = now.Add(time.Hour * time.Duration(hs))
+	}
 
-		recs = append(recs, rec)
+	// 检查用户是否已经有了该券
+	custCPS, err := s.dao.CheckCustCoupon(to.CustomerId, cp.CouponId, startDate, endDate)
+	if err != nil {
+		utils.LogError("校验客户优惠券失败: " + err.Error())
+		return errors.New("校验客户优惠券失败")
+	}
+
+	if custCPS != nil && len(custCPS) > 0 {
+		return errors.New("客户 " + to.CustomerName + " 已经拥有该券")
+	}
+
+	// 放入我的卡券
+	custCP := model.TaCustomerCoupon{
+		CouponId:           cp.CouponId,
+		CustomerCouponName: cp.CouponName,
+		CustomerId:         to.CustomerId,
+		StartDate:          startDate,
+		EndDate:            endDate,
+		ReceiveDate:        now,
+		CaseId:             cp.CaseId,
+		OrgId:              cp.OrgId,
+	}
+
+	// 放入赠送记录
+	rec := model.TaCouponGiveRecord{
+		GiftType:   models.GIVE_GIFT_COUPON,
+		GiftId:     cp.CouponId,
+		GiftName:   cp.CouponName,
+		FromId:     from.UserId,
+		FromName:   from.UserName,
+		ToId:       to.CustomerId,
+		ToName:     to.CustomerName,
+		CreateDate: now,
 	}
 
 	// 入库
-	if err := s.dao.SaveCustomerCoupons(cps); err != nil {
+	if err := s.dao.SaveCustomerCoupons([]model.TaCustomerCoupon{custCP}); err != nil {
 		utils.LogError("保存客户优惠券失败: " + err.Error())
 		return errors.New("保存客户优惠券失败")
 	}
 
-	if err := s.dao.SaveCouponRecoreds(recs); err != nil {
+	if err := s.dao.SaveCouponRecoreds([]model.TaCouponGiveRecord{rec}); err != nil {
 		utils.LogError("保存优惠券赠送记录失败: " + err.Error())
 		return errors.New("保存优惠券赠送记录失败")
 	}
 
+	// TODO
+	// 券库存处理
+
 	return nil
 }
+
+// GetCouponByID 获取优惠券
+// 未进行权限校验, 非安全的
+func (s *CouponServ) GetCouponByID(cpID string) (*model.TaCoupon, error) {
+	cp, err := s.dao.GetCouponByID(cpID)
+	if err != nil {
+		utils.LogError("获取优惠券失败: " + err.Error())
+		return nil, errors.New("校验优惠券失败")
+	}
+
+	return cp, nil
+}
+
+// GetCouponByIDWithCheck 获取优惠券
+func (s *CouponServ) GetCouponByIDWithCheck(cpID string) (*model.TaCoupon, error) {
+	cp, err := s.dao.GetCouponByID(cpID)
+	if err != nil {
+		utils.LogError("获取优惠券失败: " + err.Error())
+		return nil, errors.New("校验优惠券失败")
+	}
+
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(cp.CaseId); err != nil {
+		return nil, err
+	}
+
+	return cp, nil
+}

service/customer/customer.go

@@ -141,7 +141,8 @@ func (s *CustomerServ) BindWechatUser(userMap *model.TaUserMapping, phone string
 	}
 
 	// triggerRegiteEvent 触发注册事件
-	utils.EmitEvent(events.EvtRegiste, *cust)
+	evtEngID := utils.EngineIDBy(cust.OrgId, cust.RecommendCase)
+	utils.EventEngineBus(evtEngID).EmitEvent(events.EvtRegiste, *cust)
 
 	// if cust.CustomerId == userMap.UserId {
 	// 	return cust, nil
@@ -246,7 +247,8 @@ func (s *CustomerServ) BindWechatCust(userMap *model.TaUserMapping, phone, caseI
 	}
 
 	// triggerRegiteEvent 触发注册事件
-	utils.EmitEvent(events.EvtRegiste, *cust)
+	evtEngID := utils.EngineIDBy(cust.OrgId, cust.RecommendCase)
+	utils.EventEngineBus(evtEngID).EmitEvent(events.EvtRegiste, *cust)
 
 	// 更新用户映射信息
 	userMap.UserId = cust.CustomerId

service/events/events.go

@@ -2,6 +2,9 @@ package events
 
 import (
 	"fmt"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
 	"sync"
 
 	"github.com/zjxpcyc/tinyevent"
@@ -19,45 +22,61 @@ var EvtActions = map[string]tinyevent.Action{
 }
 
 // ListenAllEvent 监听所有事件
-func ListenAllEvent() {
+func ListenAllEvent(orgID, caseID string) {
 	mtx.Lock()
 	defer mtx.Unlock()
 
-	// // 所有需要执行的事件
-	// allEvts, err := getAllEvents()
-	// if err != nil {
-	// 	utils.LogError(err)
-	// }
-
-	// // 刷新中控中心
-	// utils.ResetEvtBus()
-
-	// for evt, acts := range allEvts {
-	// 	for _, actKey := range acts {
-	// 		act, ok := EvtActions[actKey]
-	// 		if ok {
-	// 			utils.ListenEvent(evt, act)
-	// 		}
-	// 	}
-	// }
+	evtEngID := utils.EngineIDBy(orgID, caseID)
+	evtEngine := utils.ResetEventEngineBus(evtEngID)
+
+	// 所有需要执行的事件
+	allEvts, err := getAllEvents(orgID, caseID)
+	if err != nil {
+		utils.LogError(err)
+	}
+
+	// 刷新中控中心
+	for evt, acts := range allEvts {
+		for _, actKey := range acts {
+			act, ok := EvtActions[actKey]
+			if ok {
+				evtEngine.ListenEvent(evt, act)
+			}
+		}
+	}
 }
 
 // getAllEvents 获取数据库配置
-func getAllEvents() (map[string][]string, error) {
-	// db := models.DBEngine
-
-	// var evts []model.SysActivity
-	// if err := db.Where("status=?", models.STATUS_NORMAL).Find(&evts); err != nil {
-	// 	return nil, err
-	// }
-
-	// TODO
-	return map[string][]string{
-		EvtRegiste: []string{
-			ActTest,
-			ActGiveCoupon,
-		},
-	}, nil
+func getAllEvents(orgID, caseID string) (map[string][]string, error) {
+	db := models.DBEngine
+
+	var evts []model.SysActivity
+	var acts []model.SysActivityAction
+
+	if err := db.Where("org_id=?", orgID).
+		And("case_id=?", caseID).
+		And("status=?", models.STATUS_NORMAL).
+		Find(&evts); err != nil {
+		utils.LogError("查询营销活动配置表失败: " + err.Error())
+		return nil, err
+	}
+
+	res := make(map[string][]string)
+	for _, evtSetting := range evts {
+		res[evtSetting.ActivityType] = make([]string, 0)
+		acts = make([]model.SysActivityAction, 0)
+
+		if err := db.Where("activity_id=?", evtSetting.ActivityId).Find(&acts); err != nil {
+			utils.LogError("查询营销活动配置明细失败: " + err.Error())
+			return nil, err
+		}
+
+		for _, act := range acts {
+			res[evtSetting.ActivityType] = append(res[evtSetting.ActivityType], act.ActiveType)
+		}
+	}
+
+	return res, nil
 }
 
 var tsAction = func(e tinyevent.Event) error {

service/events/giveCoupon.go

@@ -1,22 +1,80 @@
 package events
 
 import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/coupon"
+	"spaceofcheng/services/utils"
+
 	"github.com/zjxpcyc/tinyevent"
 )
 
 // giveCoupon 赠送卡券
 // Event.Payload.customer  = model.TaCustomer
-// Event.Payload.caseId  = 案场ID
 var giveCoupon = func(e tinyevent.Event) error {
-	// db := models.DBEngine
+	hasDBError := false
+	ctx := NewContext()
+	defer DestroyContext(ctx, hasDBError)
+
+	if e.Payload == nil {
+		hasDBError = true
+		utils.LogError("注册送券失败, 没有用户信息")
+		return errors.New("注册送券失败, 没有用户信息")
+	}
+	dtRaw := e.Payload.(map[string]interface{})
+
+	cust := dtRaw["customer"].(model.TaCustomer)
+	caseID := cust.RecommendCase
+	orgID := cust.OrgId
+
+	query := `
+		SELECT
+			t.*
+		FROM
+			sys_activity_action t
+		JOIN sys_activity s ON t.activity_id = s.activity_id
+		WHERE
+			s.org_id = ?
+		AND s.case_id = ?
+		AND s.status = ?
+		AND t.active_type = ?
+	`
+
+	var gifts []model.SysActivityAction
+	if err := models.DBEngine.SQL(query, orgID, caseID, models.STATUS_NORMAL, e.Name).Find(&gifts); err != nil {
+		hasDBError = true
+		utils.LogError("检查营销活动失败: " + err.Error())
+		return errors.New("检查营销活动失败")
+	}
+
+	fromUser := model.SysUser{
+		UserId:   "SYSTEM",
+		UserName: "system",
+	}
+
+	cpServ := coupon.NewCouponServ(ctx)
 
-	// if e.Payload == nil {
-	// 	utils.LogError("注册送券失败, 没有用户信息")
-	// }
-	// dtRaw := e.Payload.(map[string]interface{})
+	for _, gift := range gifts {
+		switch gift.ResourceType {
+		case models.GIVE_GIFT_COUPON:
+			cpID := gift.ResourceDesc
+			cp, err := cpServ.GetCouponByID(cpID)
+			if err != nil {
+				utils.LogError("获取优惠券失败: " + err.Error())
+				hasDBError = true
+				return errors.New("校验优惠券失败")
+			}
 
-	// cust := dtRaw["customer"].(model.TaCustomer)
-	// caseID := dtRaw["caseId"].(string)
+			if err := cpServ.GiveCouponTo(&fromUser, &cust, cp); err != nil {
+				hasDBError = true
+				return err
+			}
+		case models.GIVE_GIFT_EXPERIENCECARD:
+		case models.GIVE_GIFT_GYM:
+		default:
+		}
+	}
 
 	return nil
 }

service/events/utils.go

@@ -0,0 +1,25 @@
+package events
+
+import (
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/utils"
+)
+
+// NewContext 初始化 ctx 实例
+func NewContext() *utils.Context {
+	ctx := utils.NewContext(models.DBEngine, nil)
+	ctx.Ready()
+
+	return ctx
+}
+
+// DestroyContext 注销 ctx
+func DestroyContext(ctx *utils.Context, hasError bool) {
+	if !hasError {
+		ctx.DB.Commit()
+	} else {
+		ctx.DB.Rollback()
+	}
+
+	ctx.Destroy()
+}

service/goods/spec.go

@@ -68,7 +68,15 @@ func (s *GoodsServ) SaveGoodsSpec(goodsSpec model.TdSpec) (*model.TdSpec, error)
 
 // DelGoodsSpec 删除商品类型
 func (s *GoodsServ) DelGoodsSpec(specid string) error {
-	err := s.dao.DelGoodsSpec(specid)
+	goods, err := s.dao.GetGoodsBySpec(specid)
+	if err != nil {
+		utils.LogError("删除商品规格失败: " + err.Error())
+		return errors.New("删除商品规格失败")
+	}
+	if len(goods) > 0 {
+		return errors.New("已关联商品。不允许删除")
+	}
+	err = s.dao.DelGoodsSpec(specid)
 	if err != nil {
 		utils.LogError("删除商品规格失败: " + err.Error())
 		return errors.New("删除商品规格失败")

service/goods/type.go

@@ -82,7 +82,15 @@ func (s *GoodsServ) SaveGoodsType(goodsType model.TdGoodsType) (*model.TdGoodsTy
 
 // DelGoodsType 删除商品类型
 func (s *GoodsServ) DelGoodsType(typeid string) error {
-	err := s.dao.DelGoodsType(typeid)
+	goods, err := s.dao.GetGoodsByType(typeid)
+	if err != nil {
+		utils.LogError("删除商品类型失败: " + err.Error())
+		return errors.New("删除商品类型失败")
+	}
+	if len(goods) > 0 {
+		return errors.New("已关联商品。不允许删除")
+	}
+	err = s.dao.DelGoodsType(typeid)
 	if err != nil {
 		utils.LogError("删除商品类型失败: " + err.Error())
 		return errors.New("删除商品类型失败")

service/sys.go

@@ -75,7 +75,7 @@ func (s *SysServ) SetCustomer(id string) error {
 func (s *SysServ) SaveNewCustomer(wxInfo map[string]interface{}, userMap *model.TaUserMapping) (*model.TaCustomer, error) {
 	// 微信相关字段
 	nickyName := wxInfo["nickname"].(string)
-	sex := wxInfo["sex"].(int)
+	sex := wxInfo["sex"].(float64)
 	headimgurl := wxInfo["headimgurl"].(string)
 
 	org := s.ctx.Get("org").(model.SysOrg)
@@ -83,7 +83,7 @@ func (s *SysServ) SaveNewCustomer(wxInfo map[string]interface{}, userMap *model.
 	cust := model.TaCustomer{
 		CustomerName: nickyName,
 		Name:         nickyName,
-		Sex:          sex,
+		Sex:          int(sex),
 		Headimgurl:   headimgurl,
 		OrgId:        org.OrgId,
 	}

service/user.go

@@ -64,7 +64,19 @@ func (s *UserServ) GetCurrentEnvVars() (map[string]interface{}, error) {
 	user := s.ctx.Get("user").(model.SysUser)
 	user.Pwd = ""
 	// 当前用户案场
-	cases := s.ctx.Get("cases").([]model.SysUserCase)
+	sessionCase := s.ctx.Get("cases").([]model.SysUserCase)
+	caseIDs := ""
+	for _, value := range sessionCase {
+		if caseIDs != "" {
+			caseIDs = caseIDs + ","
+		}
+		caseIDs = caseIDs + value.CaseId
+	}
+	cases, err := s.casedao.GetCaseByIDs(caseIDs)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
 	// 当前用户角色
 	roles, err := s.dao.GetUserRole(user.UserId)
 	if err != nil {
@@ -150,6 +162,25 @@ func (s *UserServ) SaveUser(user system.SysUserForm) (*model.SysUser, error) {
 
 	var err error
 	var newUSer *model.SysUser
+
+	// 手机号码与用户名校验
+	var isok bool
+	isok, err = s.dao.CheckUserName(user.UserId, user.UserName, user.OrgId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	if !isok {
+		return nil, errors.New("用户名重复！")
+	}
+	isok, err = s.dao.CheckUserPhone(user.UserId, user.Phone, user.OrgId)
+	if err != nil {
+		beego.Error(err)
+		return nil, err
+	}
+	if !isok {
+		return nil, errors.New("手机号码重复！")
+	}
 	if user.UserId != "" {
 		err = s.dao.UpdateUser(userInfo)
 		if err != nil {

service/verify/verify.go

@@ -77,13 +77,16 @@ func (s *VerifyServ) GetCustomerCourseDetailByTel(tel, caseids string, page, pag
 		utils.LogError("获取列表失败: " + err.Error())
 		return nil, errors.New("获取列表失败")
 	}
-	customerId := customerDetail[0].CustomerId
+	if len(customerDetail) == 0 {
+		return nil, errors.New("获取列表失败")
+	}
+	customerID := customerDetail[0].CustomerId
 	total, err := s.dao.GetCustomerCourseListByTelCount(tel, caseids)
 	if err != nil {
 		utils.LogError("获取列表失败: " + err.Error())
 		return nil, errors.New("获取列表失败")
 	}
-	customer, err := s.cdao.GetCustomerByID(customerId)
+	customer, err := s.cdao.GetCustomerByID(customerID)
 	if err != nil {
 		utils.LogError("获取列表失败: " + err.Error())
 		return nil, errors.New("获取列表失败")

utils/event.go

@@ -1,49 +1,73 @@
 package utils
 
-// type EventEngine struct {
-// 	ID     string
-// 	engine *tinyevent.DefaultBus
-// }
+import "github.com/zjxpcyc/tinyevent"
 
-// var evtBus map[string]*EventEngine
+// EventEngine Event Engine
+type EventEngine struct {
+	ID     string
+	engine *tinyevent.DefaultBus
+}
 
-// func NewEventEngineBus(id string) *EventEngine {
-// 	if evtBus == nil {
-// 		evtBus = make(map[string]*EventEngine)
-// 	}
+var evtBus map[string]*EventEngine
 
-// 	if id == "" {
-// 		return nil
-// 	}
+// EventEngineBus 初始化实例
+func EventEngineBus(id string) *EventEngine {
+	if evtBus == nil {
+		evtBus = make(map[string]*EventEngine)
+	}
 
-// 	evtEngine := &EventEngine{
-// 		ID:     id,
-// 		engine: new(tinyevent.DefaultBus),
-// 	}
+	if id == "" {
+		return nil
+	}
 
-// 	evtBus[id] = evtEngine
+	if evtBus[id] == nil {
+		evtEngine := &EventEngine{
+			ID:     id,
+			engine: new(tinyevent.DefaultBus),
+		}
 
-// 	return evtEngine
-// }
+		evtBus[id] = evtEngine
+	}
 
-// // EmitEvent 执行事件
-// func (t EventEngine) EmitEvent(evt string, payload interface{}) {
-// 	e := tinyevent.Event{
-// 		Name:    evt,
-// 		Payload: payload,
-// 	}
+	return evtBus[id]
+}
 
-// 	t.engine.Emit(e)
-// }
+// ResetEventEngineBus 重设事件管理引擎
+func ResetEventEngineBus(id string) *EventEngine {
+	if id == "" || evtBus[id] == nil {
+		return nil
+	}
 
-// // ListenEvent 注册监听
-// func (t EventEngine) ListenEvent(evt string, act tinyevent.Action) string {
-// 	return t.engine.On(evt, act)
-// }
+	evtEngine := &EventEngine{
+		ID:     id,
+		engine: new(tinyevent.DefaultBus),
+	}
 
-// // UnListenEvt 取消监听
-// func (t EventEngine) UnListenEvt(id string) {
-// 	t.engine.Off(id)
-// }
+	evtBus[id] = evtEngine
+	return evtEngine
+}
 
-func EmitEvent(evt string, payload interface{}) {}
+// EmitEvent 执行事件
+func (t EventEngine) EmitEvent(evt string, payload interface{}) {
+	e := tinyevent.Event{
+		Name:    evt,
+		Payload: payload,
+	}
+
+	t.engine.Emit(e)
+}
+
+// ListenEvent 注册监听
+func (t EventEngine) ListenEvent(evt string, act tinyevent.Action) string {
+	return t.engine.On(evt, act)
+}
+
+// UnListenEvt 取消监听
+func (t EventEngine) UnListenEvt(id string) {
+	t.engine.Off(id)
+}
+
+// EngineIDBy 获取 Engine Id
+func EngineIDBy(orgID, caseID string) string {
+	return orgID + caseID
+}