feats

controllers/auth.go

@@ -72,37 +72,48 @@ func (c *BaseController) authWechat(serv *service.SysServ) {
 		custID = custIDRaw.(string)
 	}
 
+	// 机构ID - 后面再思考机构问题
+	var orgID = "1"
+	// 微信配置
+	wxConf, err := serv.GetWeChatConfig(orgID)
+	if err != nil {
+		utils.LogError("查询微信配置失败: " + err.Error())
+		c.ResponseError(
+			errors.New("没有找到微信相关配置"),
+			http.StatusBadRequest,
+		)
+	}
+	utils.WxClientSingleton(orgID, wxConf)
+
 	// 用户微信信息
 	var wxDetail map[string]interface{}
-	detailRaw := c.GetSession("wechat_user")
 
+	detailRaw := c.GetSession("wechat_user")
 	if detailRaw != nil {
 		wxDetail = detailRaw.(map[string]interface{})
-	}
-
-	// DEV MODE
-	if c.RunMode == "dev" {
-		wxDetail = map[string]interface{}{
-			"openid":     " OPENID",
-			"nickname":   "NICKNAME",
-			"sex":        "1",
-			"province":   "PROVINCE",
-			"city":       "CITY",
-			"country":    "COUNTRY",
-			"headimgurl": "http://thirdwx.qlogo.cn/mmopen/g3MonUZtNHkdmzicIlibx6iaFqAc56vxLSUfpb6n5WKSYVY0ChQKkiaJSgQ1dZuTOgvLLrhJbERQQ4eMsv84eavHiaiceqxibJxCfHe/46",
-			"unionid":    "o6_bmasdasdsad6_2sgVt7hMZOPfL",
+	} else {
+		// DEV MODE
+		if c.RunMode == "dev" {
+			wxDetail = map[string]interface{}{
+				"openid":     "OPENID",
+				"nickname":   "NICKNAME",
+				"sex":        "1",
+				"province":   "PROVINCE",
+				"city":       "CITY",
+				"country":    "COUNTRY",
+				"headimgurl": "http://thirdwx.qlogo.cn/mmopen/g3MonUZtNHkdmzicIlibx6iaFqAc56vxLSUfpb6n5WKSYVY0ChQKkiaJSgQ1dZuTOgvLLrhJbERQQ4eMsv84eavHiaiceqxibJxCfHe/46",
+				"unionid":    "o6_bmasdasdsad6_2sgVt7hMZOPfL",
+			}
+		} else {
+			wxDetail = c.getWechatDetail(orgID, serv)
 		}
-	}
-
-	if custID == "" && wxDetail == nil {
-		wxDetail = c.getWechatDetail(serv)
 
 		c.SetSession("wechat_user", wxDetail)
 	}
 
 	c.Context.Set("wxInfo", wxDetail)
 
-	// 普通客户映射检查
+	// 用户映射检查
 	userMap, err := serv.CheckWechatUserMapping(wxDetail)
 	if err != nil {
 		c.ResponseError(
@@ -110,10 +121,7 @@ func (c *BaseController) authWechat(serv *service.SysServ) {
 			http.StatusInternalServerError,
 		)
 	}
-
-	if userMap != nil {
-		c.Context.Set("userMap", *userMap)
-	}
+	c.Context.Set("userMap", *userMap)
 
 	if !c.needAuth() {
 		return
@@ -121,21 +129,13 @@ func (c *BaseController) authWechat(serv *service.SysServ) {
 
 	// 未登录或者绑定, 返回 401
 	if custID == "" && userMap.UserId == "" {
-		wxConf, ok := c.Configer[WeChatConf]
-		if ok {
-			c.ResponseData(
-				map[string]interface{}{
-					"appid": wxConf.String("appid"),
-				},
-				errors.New("用户未登录"),
-				http.StatusUnauthorized,
-			)
-		} else {
-			c.ResponseError(
-				errors.New("用户未登录"),
-				http.StatusUnauthorized,
-			)
-		}
+		c.ResponseData(
+			map[string]interface{}{
+				"appid": wxConf["appid"],
+			},
+			errors.New("用户未登录或绑定"),
+			http.StatusUnauthorized,
+		)
 	}
 
 	if custID == "" {
@@ -168,7 +168,7 @@ func (c *BaseController) needAuth() bool {
 }
 
 // getWechatDetail 获取微信个人信息详情
-func (c *BaseController) getWechatDetail(serv *service.SysServ) map[string]interface{} {
+func (c *BaseController) getWechatDetail(org string, serv *service.SysServ) map[string]interface{} {
 	// 微信 code
 	code := c.GetString("code")
 	if code == "" {
@@ -178,19 +178,7 @@ func (c *BaseController) getWechatDetail(serv *service.SysServ) map[string]inter
 		)
 	}
 
-	// TODO
-	// 机构先默认写死
-	conf, err := serv.GetWeChatConfig("1")
-	if err != nil {
-		utils.LogError("查询微信配置失败: " + err.Error())
-		c.ResponseError(
-			errors.New("没有找到微信相关配置"),
-			http.StatusBadRequest,
-		)
-	}
-
-	utils.InitWeChatClient(conf)
-	usr, err := utils.GetWxUserInfo(code)
+	usr, err := utils.WxClientFor(org).GetUserInfo(code)
 	if err != nil {
 		c.ResponseError(
 			utils.LogError("获取微信个人信息失败: "+err.Error()),

controllers/context.go

@@ -9,13 +9,13 @@ import (
 * Context 说明
 * - 所有 stuct 类型均不是指针
 * - 包含内容如下
-* user					用户基本信息
-* customer			会员基本信息
-* userMap				用户/会员 映射第三方账户
-* wxInfo				微信信息
-* cases					用户所有案场信息
-* currentCase 	当前案场
-* org						用户当前组织
+* user					SysUser 									用户基本信息
+* customer			TaCustomer 								会员基本信息
+* userMap				TaUserMapping 						用户/会员 映射第三方账户
+* wxInfo				map[string]interface{} 		微信信息
+* cases					[]SysUserCase 						用户所有案场信息
+* currentCase		SysUserCase 							当前案场
+* org						SysOrg 										用户当前组织
 **/
 
 // initContext 初始化 Context

controllers/customer/customer.go

@@ -4,7 +4,6 @@ import (
 	"errors"
 	"net/http"
 	"spaceofcheng/services/controllers"
-	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/customer"
 	"spaceofcheng/services/utils"
@@ -55,33 +54,16 @@ func (c *CustomerController) GetCustWXByID() {
 
 	userMap := userMapRaw.(model.TaUserMapping)
 
-	if userMap.UserType == models.USERMAP_USER {
-		// 如果是用户
-		userID := userMap.UserId
-		user, err := c.serv.GetCustUserByID(userID)
-		if err != nil {
-			utils.LogError(err)
-			c.ResponseError(errors.New("获取用户信息失败, 请重试"))
-		}
-
-		c.ResponseJSON(map[string]interface{}{
-			"user":     user,
-			"userType": userMap.UserType,
-		})
-	} else {
-		// 如果是客户
-		custID := userMap.UserId
-		cust, err := c.serv.GetCustWithWXByID(custID)
-		if err != nil {
-			utils.LogError(err)
-			c.ResponseError(errors.New("获取用户信息失败, 请重试"))
-		}
-
-		c.ResponseJSON(map[string]interface{}{
-			"customer": cust,
-			"userType": userMap.UserType,
-		})
+	custID := userMap.UserId
+	cust, err := c.serv.GetCustWithWXByID(custID)
+	if err != nil {
+		utils.LogError(err)
+		c.ResponseError(errors.New("获取用户信息失败, 请重试"))
 	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"customer": cust,
+	})
 }
 
 // SignIn 微信登录

controllers/goods/dicts.go

@@ -0,0 +1,27 @@
+package goods
+
+import (
+	"spaceofcheng/services/models/goods"
+)
+
+// GetMakeStatus 获取制作状态字典
+func (c GoodsController) GetMakeStatus() {
+	data := []map[string]string{
+		map[string]string{
+			"TypeId":   goods.MAKESTATUS_NOTSTARTED,
+			"TypeName": "未开始",
+		},
+		map[string]string{
+			"TypeId":   goods.MAKESTATUS_FINISHED,
+			"TypeName": "已完成",
+		},
+		map[string]string{
+			"TypeId":   goods.MAKESTATUS_CANCEL,
+			"TypeName": "已取消",
+		},
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"list": data,
+	})
+}

controllers/goods/goods.go

@@ -1,13 +1,19 @@
 package goods
 
 import (
+	"encoding/json"
+	"errors"
 	"spaceofcheng/services/controllers"
+	goodsModel "spaceofcheng/services/models/goods"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/service/goods"
+	"spaceofcheng/services/utils"
+	"strings"
 )
 
 // GoodsController 商品
 type GoodsController struct {
-	dao *goods.GoodsServ
+	serv *goods.GoodsServ
 	controllers.BaseController
 }
 
@@ -15,5 +21,93 @@ type GoodsController struct {
 // @Title Constructor
 // @Description 初始化 Controller, 系统自动调用
 func (c *GoodsController) Constructor() {
-	c.dao = goods.NewGoodsServ(c.Context)
+	c.serv = goods.NewGoodsServ(c.Context)
+}
+
+// GetListByCase 获取案场商品列表
+// 管理端
+func (c *GoodsController) GetListByCase() {
+	page, _ := c.GetInt("page")
+	pagesize, _ := c.GetInt("pagesize")
+	caseID := c.GetString("caseid")
+	goodsName := c.GetString("name")
+	goodsType := c.GetString("type")
+
+	goodsList, cnt, err := c.serv.GetGoodsListPageNavi(goodsName, goodsType, caseID, page, pagesize)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"list":     goodsList,
+		"pagesize": pagesize,
+		"pagenum":  cnt,
+		"page":     page,
+	})
+}
+
+// GetListForWechat 获取商品列表
+// 微信端
+func (c *GoodsController) GetListForWechat() {
+	caseID := c.GetString("caseid")
+	if caseID == "" {
+		c.ResponseError(errors.New("请指定案场"))
+	}
+
+	goodsList, err := c.serv.GetListByCase(caseID)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"list": goodsList,
+	})
+}
+
+// UpdateGoods 新增或者更新商品
+func (c *GoodsController) UpdateGoods() {
+	// 商品
+	gds := model.TaGoods{}
+	if err := c.ParseForm(&gds); err != nil {
+		utils.LogError("接收商品参数失败: " + err.Error())
+		c.ResponseError(errors.New("接收商品参数失败"))
+	}
+
+	// 图片
+	images := strings.Split(c.GetString("images"), ",")
+
+	// 规格
+	var specs []goodsModel.SpecWithPrice
+	specsJSON := c.GetString("specs")
+	if err := json.Unmarshal([]byte(specsJSON), &specs); err != nil {
+		utils.LogError("接收商品参数失败: " + err.Error())
+		c.ResponseError(errors.New("接收商品参数失败"))
+	}
+
+	goodsID := c.GetString(":id")
+	gds.GoodsId = goodsID
+
+	if err := c.serv.UpdateGoods(&gds, images, specs); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"goods":  gds,
+		"images": images,
+		"specs":  specs,
+	})
+}
+
+// DeleteGoods 删除商品
+func (c *GoodsController) DeleteGoods() {
+	goodsID := c.GetString(":id")
+	if goodsID == "" {
+		c.ResponseError(errors.New("没有需要删除的商品"))
+	}
+
+	if err := c.serv.DeleteGoods(goodsID); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("ok")
 }

controllers/goods/order.go

@@ -0,0 +1,15 @@
+package goods
+
+// GetOrderList 获取商品订单
+// 管理端 - 统计查询
+func (c *GoodsController) GetOrderList() {
+	// caseID := c.GetString("caseid")
+	// userType := c.GetString("usertype")
+	// status := c.GetString("status")
+	// orderStart := c.GetString("startdate")
+	// orderEnd := c.GetString("enddate")
+
+	// page, _ := c.GetInt("page")
+	// pagesize, _ := c.GetInt("pagesize")
+
+}

controllers/goods/spec.go

@@ -1,6 +1,8 @@
 package goods
 
-import "spaceofcheng/services/models/model"
+import (
+	"spaceofcheng/services/models/model"
+)
 
 // GetGoodsSpec 获取商品规格列表
 func (c *GoodsController) GetGoodsSpec() {
@@ -11,7 +13,7 @@ func (c *GoodsController) GetGoodsSpec() {
 	}
 	page, _ := c.GetInt("page")
 	pageSize, _ := c.GetInt("pagesize")
-	goodsSpec, err := c.dao.GetGoodsSpec(caseids, page, pageSize)
+	goodsSpec, err := c.serv.GetGoodsSpec(caseids, page, pageSize)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -21,7 +23,7 @@ func (c *GoodsController) GetGoodsSpec() {
 // GetGoodsSpecByID 根据ID获取商品分类
 func (c *GoodsController) GetGoodsSpecByID() {
 	specid := c.GetString(":specid")
-	goodsSpec, err := c.dao.GetGoodsSpecByID(specid)
+	goodsSpec, err := c.serv.GetGoodsSpecByID(specid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -34,7 +36,7 @@ func (c *GoodsController) SaveGoodsSpec() {
 	if err := c.ParseForm(&goodsSpec); err != nil {
 		c.ResponseError(err)
 	}
-	newSpec, err := c.dao.SaveGoodsSpec(goodsSpec)
+	newSpec, err := c.serv.SaveGoodsSpec(goodsSpec)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -44,7 +46,7 @@ func (c *GoodsController) SaveGoodsSpec() {
 // DelGoodsSpec 删除商品分类
 func (c *GoodsController) DelGoodsSpec() {
 	specid := c.GetString(":specid")
-	err := c.dao.DelGoodsSpec(specid)
+	err := c.serv.DelGoodsSpec(specid)
 	if err != nil {
 		c.ResponseError(err)
 	}

controllers/goods/type.go

@@ -1,6 +1,8 @@
 package goods
 
-import "spaceofcheng/services/models/model"
+import (
+	"spaceofcheng/services/models/model"
+)
 
 // GetGoodsType 获取商品分类列表
 func (c *GoodsController) GetGoodsType() {
@@ -11,7 +13,7 @@ func (c *GoodsController) GetGoodsType() {
 	}
 	page, _ := c.GetInt("page")
 	pageSize, _ := c.GetInt("pagesize")
-	goodstype, err := c.dao.GetGoodsType(caseids, page, pageSize)
+	goodstype, err := c.serv.GetGoodsType(caseids, page, pageSize)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -21,7 +23,7 @@ func (c *GoodsController) GetGoodsType() {
 // GetGoodsTypeByID 根据ID获取商品分类
 func (c *GoodsController) GetGoodsTypeByID() {
 	typeid := c.GetString(":typeid")
-	goodsType, err := c.dao.GetGoodsTypeByID(typeid)
+	goodsType, err := c.serv.GetGoodsTypeByID(typeid)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -34,7 +36,7 @@ func (c *GoodsController) SaveGoodsType() {
 	if err := c.ParseForm(&goodsType); err != nil {
 		c.ResponseError(err)
 	}
-	newtype, err := c.dao.SaveGoodsType(goodsType)
+	newtype, err := c.serv.SaveGoodsType(goodsType)
 	if err != nil {
 		c.ResponseError(err)
 	}
@@ -44,7 +46,7 @@ func (c *GoodsController) SaveGoodsType() {
 // DelGoodsType 删除商品分类
 func (c *GoodsController) DelGoodsType() {
 	typeid := c.GetString(":typeid")
-	err := c.dao.DelGoodsType(typeid)
+	err := c.serv.DelGoodsType(typeid)
 	if err != nil {
 		c.ResponseError(err)
 	}

log/common.2018-08-17.log

@@ -1,17 +0,0 @@
-2018/08/17 13:45:31 [E] 用户登录失败: 用户密码不正确
-2018/08/17 13:47:02 [E] 用户登录失败: 用户密码不正确
-2018/08/17 17:29:34 [E] 获取用户案场信息失败: Error 1054: Unknown column 's.user_id' in 'where clause'
-2018/08/17 17:29:34 [E] 获取用户案场信息失败: Error 1054: Unknown column 's.user_id' in 'where clause'
-2018/08/17 17:30:02 [E] 获取用户案场信息失败: Error 1054: Unknown column 's.user_id' in 'where clause'
-2018/08/17 17:30:02 [E] 获取用户案场信息失败: Error 1054: Unknown column 's.user_id' in 'where clause'
-2018/08/17 17:35:08 [E] 用户没有设置默认案场
-2018/08/17 17:35:08 [E] 用户没有设置默认案场
-2018/08/17 17:37:03 [E] 用户没有设置默认案场
-2018/08/17 17:37:03 [E] 获取用户组织信息失败: 没有查询到机构信息
-2018/08/17 17:37:03 [E] 获取用户组织信息失败: 没有查询到机构信息
-2018/08/17 17:41:34 [E] 用户没有设置默认案场
-2018/08/17 17:41:34 [E] 获取用户组织信息失败: 没有查询到机构信息
-2018/08/17 17:41:34 [E] 获取用户组织信息失败: 没有查询到机构信息
-2018/08/17 17:42:13 [E] 用户没有设置默认案场
-2018/08/17 17:47:00 [E] 用户没有设置默认案场
-2018/08/17 17:47:48 [E] 用户没有设置默认案场

log/common.2018-08-24.log

@@ -0,0 +1,7 @@
+2018/08/24 09:40:16 [E] 验证码 - 17714208769 : 648633
+2018/08/24 10:53:37 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
+2018/08/24 10:54:58 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
+2018/08/24 10:55:03 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
+2018/08/24 10:55:42 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
+2018/08/24 10:55:46 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
+2018/08/24 11:30:58 [E] 更新用户映射信息失败:Params type error

log/common.log

@@ -1,7 +1,74 @@
-2018/08/24 09:40:16 [E] 验证码 - 17714208769 : 648633
-2018/08/24 10:53:37 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
-2018/08/24 10:54:58 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
-2018/08/24 10:55:03 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
-2018/08/24 10:55:42 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
-2018/08/24 10:55:46 [E] 获取人员映射账户失败: Error 1205: Lock wait timeout exceeded; try restarting transaction
-2018/08/24 11:30:58 [E] 更新用户映射信息失败:Params type error
+2018/08/26 09:37:50 [E] 查询微信配置失败: Error 1054: Unknown column 'rmark' in 'field list'
+2018/08/26 09:38:37 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:38:37 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_-Lg_RS71-apY79btcVmfgOoi47yZER01vtlROS4cXfqgIRfbPkzUPTwvZz6w0DlHMJIk7h-xISGUwZ0Tosff1sEpcfhNiBLw6zvr-l9zpi-tp2N6hJY7QM4uExMIZTSOixTUS9uHKOiK7trvUZWdAIAHMJ","expires_in":7200})
+2018/08/26 09:38:37 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_-Lg_RS71-apY79btcVmfgOoi47yZER01vtlROS4cXfqgIRfbPkzUPTwvZz6w0DlHMJIk7h-xISGUwZ0Tosff1sEpcfhNiBLw6zvr-l9zpi-tp2N6hJY7QM4uExMIZTSOixTUS9uHKOiK7trvUZWdAIAHMJ])
+2018/08/26 09:44:13 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:44:13 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_2REPD5yYQxrGgfgH94odWyxn0xLwS_-9HvVko999_vYdApibljI1UuhMYohVkLz84IMkGEyf9BpSFWbR9oH3qJffwFnjb-f3XVDXjuuGRPpFU5q3acQ1-8Q5PzEXWZdAJAGFI","expires_in":7200})
+2018/08/26 09:44:13 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_2REPD5yYQxrGgfgH94odWyxn0xLwS_-9HvVko999_vYdApibljI1UuhMYohVkLz84IMkGEyf9BpSFWbR9oH3qJffwFnjb-f3XVDXjuuGRPpFU5q3acQ1-8Q5PzEXWZdAJAGFI expires_in:7200])
+2018/08/26 09:45:32 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:45:32 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_xTyy-6CTPuz4gw7CzuHQhZ73GnK1IL_KpzT9EgUTUX4qSgdqH0ZEgNMxhavJY-kMsaHN15owtkQe0dlf9kfE7Cl0PvCmC9OPc5PiJhflZ2NAAiZp84sKHp81FDsTSBeAHAYXG","expires_in":7200})
+2018/08/26 09:45:32 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_xTyy-6CTPuz4gw7CzuHQhZ73GnK1IL_KpzT9EgUTUX4qSgdqH0ZEgNMxhavJY-kMsaHN15owtkQe0dlf9kfE7Cl0PvCmC9OPc5PiJhflZ2NAAiZp84sKHp81FDsTSBeAHAYXG expires_in:7200])
+2018/08/26 09:49:08 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:49:09 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_K6k5JNOBeMpIe_gitC04i233yiyA6yh1smV1feyiUQTk6010b98PU3X67e8KCvaCjTR0HmjrttsTJLrtzg54TwKnGLE-UgV7NDMMhp4u2r2V56ghJDZ5-7xlC9SxvTkIu0nmQAfAif3ktCULIQZeADAVDM","expires_in":7200})
+2018/08/26 09:49:09 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_K6k5JNOBeMpIe_gitC04i233yiyA6yh1smV1feyiUQTk6010b98PU3X67e8KCvaCjTR0HmjrttsTJLrtzg54TwKnGLE-UgV7NDMMhp4u2r2V56ghJDZ5-7xlC9SxvTkIu0nmQAfAif3ktCULIQZeADAVDM expires_in:7200])
+2018/08/26 09:50:11 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:50:11 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_Dm3oaLYTAMFOsaxzn6Sm-liedNbNRUDD0lZuCSUHfVFWry9R7oXyyLDXGOsDR6XO_cAReWZ0KBgituizW20oxfHHq8ezj0iiUveePrL03Cml6x7R0WkzMOiNGcXmyzo3Igh3r8QhGK2WfuwOMVQfAAAHQL","expires_in":7200})
+2018/08/26 09:50:11 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_Dm3oaLYTAMFOsaxzn6Sm-liedNbNRUDD0lZuCSUHfVFWry9R7oXyyLDXGOsDR6XO_cAReWZ0KBgituizW20oxfHHq8ezj0iiUveePrL03Cml6x7R0WkzMOiNGcXmyzo3Igh3r8QhGK2WfuwOMVQfAAAHQL expires_in:7200])
+2018/08/26 09:51:59 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:51:59 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_B0bGSFxdnZK5KT9wzuHQhZ73GnK1IL_KpzT9EvI_ZHhdHbiwSy9FiEfhct77uI_1Brx6kBu3SklukBzw2BnWBk-Q52pYYIb9NpZELzJVR8tzWWbPWD9Tc36StP7FmdpzG1y9UrT4A3idUIDfVRGgAEAZVK","expires_in":7200})
+2018/08/26 09:51:59 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_B0bGSFxdnZK5KT9wzuHQhZ73GnK1IL_KpzT9EvI_ZHhdHbiwSy9FiEfhct77uI_1Brx6kBu3SklukBzw2BnWBk-Q52pYYIb9NpZELzJVR8tzWWbPWD9Tc36StP7FmdpzG1y9UrT4A3idUIDfVRGgAEAZVK expires_in:7200])
+2018/08/26 09:52:26 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:52:26 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_JaO07aaK8Vbt8mVhb88JC_57VjUKFd0UxQUL0TVMKNF0DUrcHPt4tjZjaeF3K1UI0NPOyNqYytzPg5YfIeSfDowMBreC86pigfPIXZrwlqspCOddE5QtTmD8uGQZ7_VhX0aHegYT8Iy-dSupBNQcAFAPBE","expires_in":7200})
+2018/08/26 09:52:26 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_JaO07aaK8Vbt8mVhb88JC_57VjUKFd0UxQUL0TVMKNF0DUrcHPt4tjZjaeF3K1UI0NPOyNqYytzPg5YfIeSfDowMBreC86pigfPIXZrwlqspCOddE5QtTmD8uGQZ7_VhX0aHegYT8Iy-dSupBNQcAFAPBE expires_in:7200])
+2018/08/26 09:52:52 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:52:52 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_W_Xh9756zIW8jFK4bRxCsoQiUV0j-zAfNmXR38hdAk10_MDRh15cOJkDRkROLC6iU7zSqQxcPQQz-NsBHfFaK9Ol1HliVvIg8efKZGrfBwXva0asAn0OnU869MNfv5-EtNzJl_talvZ7N2twBOBfAEAVIV","expires_in":7200})
+2018/08/26 09:52:52 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_W_Xh9756zIW8jFK4bRxCsoQiUV0j-zAfNmXR38hdAk10_MDRh15cOJkDRkROLC6iU7zSqQxcPQQz-NsBHfFaK9Ol1HliVvIg8efKZGrfBwXva0asAn0OnU869MNfv5-EtNzJl_talvZ7N2twBOBfAEAVIV])
+2018/08/26 09:53:06 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:53:06 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_x8W4tYHqT6-xw2KZbRxCsoQiUV0j-zAfNmXR38hdAk10_MDRh15cOJkDRkTiPc6vNMq046pPpyHg_ksa0ELjakenatHGtKfyBPLppB1hTwdcpghc5Z8QmY5upPqR37Epw0HfFweotkLnljJiOEOfAEAXNX","expires_in":7200})
+2018/08/26 09:53:06 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_x8W4tYHqT6-xw2KZbRxCsoQiUV0j-zAfNmXR38hdAk10_MDRh15cOJkDRkTiPc6vNMq046pPpyHg_ksa0ELjakenatHGtKfyBPLppB1hTwdcpghc5Z8QmY5upPqR37Epw0HfFweotkLnljJiOEOfAEAXNX expires_in:7200])
+2018/08/26 09:54:43 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:54:44 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_PK1MfsKJTJBSyulyKvLRHiorDM-9wwzYsyPyvpnEpTQgtpnYsMM6AwA9DcpV5vq0REYd69l3WhYQ1_0AOZcTW7GKQaAxLmxj47IBXdxLScTYi4l-8ZtP6ZmS96kFROeAGAJVS","expires_in":7200})
+2018/08/26 09:54:44 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_PK1MfsKJTJBSyulyKvLRHiorDM-9wwzYsyPyvpnEpTQgtpnYsMM6AwA9DcpV5vq0REYd69l3WhYQ1_0AOZcTW7GKQaAxLmxj47IBXdxLScTYi4l-8ZtP6ZmS96kFROeAGAJVS expires_in:7200])
+2018/08/26 09:56:04 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 09:56:04 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_igGxdtw6AzmfTOu9cIlzH2dMOQRu-NPQ0Pm92NS4Hm9llCRTrFHsaxQb0etiAjOuQBL7_ep7csgPjvyNWEEZGOZ28akNtaDQD1ApoYYeAihI58iUra270dbdmO8MNEfAGAWXO","expires_in":7200})
+2018/08/26 09:56:04 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_igGxdtw6AzmfTOu9cIlzH2dMOQRu-NPQ0Pm92NS4Hm9llCRTrFHsaxQb0etiAjOuQBL7_ep7csgPjvyNWEEZGOZ28akNtaDQD1ApoYYeAihI58iUra270dbdmO8MNEfAGAWXO expires_in:7200])
+2018/08/26 10:01:23 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:01:23 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_ho3BftxaKmrGQie6QrTSheSWuAj8XAN8wpjERCj2FB00PWVCksSlu-X-3yVreKXyMZiE9TKDHdpFRJ4TwWiWKC6Bn7nwuF38emI9H3YKw41aq4OzdCHxSpeswgkiUTmGyyLdUBTGvBg3LrgbQUQaACACGC","expires_in":7200})
+2018/08/26 10:01:23 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[expires_in:7200 access_token:13_ho3BftxaKmrGQie6QrTSheSWuAj8XAN8wpjERCj2FB00PWVCksSlu-X-3yVreKXyMZiE9TKDHdpFRJ4TwWiWKC6Bn7nwuF38emI9H3YKw41aq4OzdCHxSpeswgkiUTmGyyLdUBTGvBg3LrgbQUQaACACGC])
+2018/08/26 10:03:00 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:03:00 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_mPkwKKOyg1_TrG55P9WmMf-uZJq9ElASxwnCi3kwUmH6i2JfpZRszI-vThMJ8p2BZ155si1rJiD9T1OMphQ2LlU4mVJK2VylENa49ZYKq1nman7AQKmmUhQQf1NF61dSpJzwWL1YcmtxdswWPEWcAFAGVN","expires_in":7200})
+2018/08/26 10:03:00 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_mPkwKKOyg1_TrG55P9WmMf-uZJq9ElASxwnCi3kwUmH6i2JfpZRszI-vThMJ8p2BZ155si1rJiD9T1OMphQ2LlU4mVJK2VylENa49ZYKq1nman7AQKmmUhQQf1NF61dSpJzwWL1YcmtxdswWPEWcAFAGVN expires_in:7200])
+2018/08/26 10:03:34 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:03:37 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:03:37 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_pDrce0TWVtCLO-krXhdBpI73YPmDSHDuiZldQlc0KhV3MDE9JEF9fhiCft8VbdEtodGzPVCL0_HE1pGlJ8SPI64yDhihRsrgkw7gh8tUnzSXlax1SqATFixZjSN6ufmekVUwX1lTNaQxz74BDSNaAHAYNI","expires_in":7200})
+2018/08/26 10:03:37 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_pDrce0TWVtCLO-krXhdBpI73YPmDSHDuiZldQlc0KhV3MDE9JEF9fhiCft8VbdEtodGzPVCL0_HE1pGlJ8SPI64yDhihRsrgkw7gh8tUnzSXlax1SqATFixZjSN6ufmekVUwX1lTNaQxz74BDSNaAHAYNI expires_in:7200])
+2018/08/26 10:06:33 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:06:33 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_DZoFCC4yhlTyAkYxNIDuR2xRUAWJHPruJFOqDuEV3D5d1DdqVNkCznwmzs340F7K4wM5CiXND7hySR6ljElUYYPdZq_LrWW-g-Q5SzsRT6RRelYmhu4yRe8J8cBBg_ElkEbervWfr1DBlstvZOHaAIADSL","expires_in":7200})
+2018/08/26 10:06:33 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_DZoFCC4yhlTyAkYxNIDuR2xRUAWJHPruJFOqDuEV3D5d1DdqVNkCznwmzs340F7K4wM5CiXND7hySR6ljElUYYPdZq_LrWW-g-Q5SzsRT6RRelYmhu4yRe8J8cBBg_ElkEbervWfr1DBlstvZOHaAIADSL expires_in:7200])
+2018/08/26 10:08:42 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:08:43 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_96NNB_wLDEFTiOTGTmi9TkQvj1AiAe3lQIQWnbQIohFWbJ5DduY27W7k_Acaf8CUKq-N1Bl9yorRUuG690EDGHwBuA5tpkg3fAvrnn50VNEmTbtaNN3H22dcMu5eqxZIAtptEs_n5SRPXBfXOKIcACABXV","expires_in":7200})
+2018/08/26 10:08:43 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_96NNB_wLDEFTiOTGTmi9TkQvj1AiAe3lQIQWnbQIohFWbJ5DduY27W7k_Acaf8CUKq-N1Bl9yorRUuG690EDGHwBuA5tpkg3fAvrnn50VNEmTbtaNN3H22dcMu5eqxZIAtptEs_n5SRPXBfXOKIcACABXV expires_in:7200])
+2018/08/26 10:28:46 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:28:47 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_tfSozSKyxf6tttaz0yd2aut_EFTLarqBafPHq9AIARgmCTZL471kN1LURN4Fkklongv4QIwKWMKPgiDc0Lz_2UrwBmbDWFsr_CsKoXMewVTLbjcPRMzVwps-bgL865o-ivCgAv_1lk9AZ92BFPFeAFAYIY","expires_in":7200})
+2018/08/26 10:28:47 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_tfSozSKyxf6tttaz0yd2aut_EFTLarqBafPHq9AIARgmCTZL471kN1LURN4Fkklongv4QIwKWMKPgiDc0Lz_2UrwBmbDWFsr_CsKoXMewVTLbjcPRMzVwps-bgL865o-ivCgAv_1lk9AZ92BFPFeAFAYIY expires_in:7200])
+2018/08/26 10:36:16 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:36:16 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_Bgp4G3PY317x9UpbQOS6uPUvYLON3hDKHhqdyhD0TB_S4qUw5Kps-GnjTBABV8fU0Fq5JZkiTeXHHCLXnolcWgx3lMMy736Q_UU2hWVRHoiVTR7WRe08Yg3p2_OxIS43-bhf5ZZ1Pq1vpla5PDDfABACQQ","expires_in":7200})
+2018/08/26 10:36:16 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_Bgp4G3PY317x9UpbQOS6uPUvYLON3hDKHhqdyhD0TB_S4qUw5Kps-GnjTBABV8fU0Fq5JZkiTeXHHCLXnolcWgx3lMMy736Q_UU2hWVRHoiVTR7WRe08Yg3p2_OxIS43-bhf5ZZ1Pq1vpla5PDDfABACQQ expires_in:7200])
+2018/08/26 10:37:08 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:37:08 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_7OsVSwADwqEcwqQKNIDuR2xRUAWJHPruJFOqDlmHgDjknD0fdU94o7ndqas3U5aNtlfiNoovlsA4RLjUmqIMGf0vTlCFBjQ_M8L-N-i1jlcQiugyXFDRWsui1CUIG_9gW7gCdS1LUybkGRE4ZCIcABAEHN","expires_in":7200})
+2018/08/26 10:37:08 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_7OsVSwADwqEcwqQKNIDuR2xRUAWJHPruJFOqDlmHgDjknD0fdU94o7ndqas3U5aNtlfiNoovlsA4RLjUmqIMGf0vTlCFBjQ_M8L-N-i1jlcQiugyXFDRWsui1CUIG_9gW7gCdS1LUybkGRE4ZCIcABAEHN expires_in:7200])
+2018/08/26 10:48:19 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:48:20 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_kgQXjSoiSNu6r7VNYRaB7Jkvc6MyxsgqlfRp0GD3t4U9VVRlLLteA1jq_4IZBAVt3zYLiacrmsTJLR2nD9qb99yUWfPaLFP8NBTDPvu4cFYbNFHmOBMUJwVW9lVEaPm_2kQY1tnqcmFRpa6uKOGeABAFJB","expires_in":7200})
+2018/08/26 10:48:20 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_kgQXjSoiSNu6r7VNYRaB7Jkvc6MyxsgqlfRp0GD3t4U9VVRlLLteA1jq_4IZBAVt3zYLiacrmsTJLR2nD9qb99yUWfPaLFP8NBTDPvu4cFYbNFHmOBMUJwVW9lVEaPm_2kQY1tnqcmFRpa6uKOGeABAFJB expires_in:7200])
+2018/08/26 10:57:38 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:57:38 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_IuDEV53CHWkI4PMqWBMNgMuHx4Y6f7UP5MD90PRncFeGPK9Ri00Zbf6d-IvnUZ3FEhCN7bkwGK9wJPJGXu-RY5J91Cpr_OII7IZhVYPjtdLWuBIPzkcq28gKfxTRlSQTCQXGc3_khJMAJrNIDUThAGAGXW","expires_in":7200})
+2018/08/26 10:57:38 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_IuDEV53CHWkI4PMqWBMNgMuHx4Y6f7UP5MD90PRncFeGPK9Ri00Zbf6d-IvnUZ3FEhCN7bkwGK9wJPJGXu-RY5J91Cpr_OII7IZhVYPjtdLWuBIPzkcq28gKfxTRlSQTCQXGc3_khJMAJrNIDUThAGAGXW expires_in:7200])
+2018/08/26 10:58:56 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 10:58:56 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_j6hv2N3bFx7qKu-zMWqgXQqP5f3C1fi5MKw7aVmOU27p7NHWfiwleuTzzhyuccc9zfejZJV9s615X9pGZo2swrUQa_R4b3jFxn7OLuA3jDgBBUQwvIv578aeNjgLLVfAIAUUE","expires_in":7200})
+2018/08/26 10:58:56 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_j6hv2N3bFx7qKu-zMWqgXQqP5f3C1fi5MKw7aVmOU27p7NHWfiwleuTzzhyuccc9zfejZJV9s615X9pGZo2swrUQa_R4b3jFxn7OLuA3jDgBBUQwvIv578aeNjgLLVfAIAUUE expires_in:7200])
+2018/08/26 15:20:02 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 15:20:03 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_BWujCeV9M2yUp5tsJpx7FaGHTMbuGAJ0c3XHxCrkY7-Ro9tiu-cAJNx45PdkiNe5SfTZrW7ZhHXz36VnZ8HYzN6arFiFgloLHh9qJIb9_sIqFAgi2NPApcOm16BXEF4GY7KDOza67EWofM1jIQIgABAUCU","expires_in":7200})
+2018/08/26 15:20:03 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_BWujCeV9M2yUp5tsJpx7FaGHTMbuGAJ0c3XHxCrkY7-Ro9tiu-cAJNx45PdkiNe5SfTZrW7ZhHXz36VnZ8HYzN6arFiFgloLHh9qJIb9_sIqFAgi2NPApcOm16BXEF4GY7KDOza67EWofM1jIQIgABAUCU expires_in:7200])
+2018/08/26 16:17:50 [I] 请求远程接口: %!(EXTRA string=https://api.weixin.qq.com/cgi-bin/token?appid=wx7320287e057bbeee&grant_type=client_credential&secret=6e844dc2ade439545c47569ba1707673)
+2018/08/26 16:17:50 [I] 远程请求结果:%!(EXTRA string={"access_token":"13_hezlnSFBORaBwf5SdwfaSZEoGO35hkS4XL7D2SKqDSUwryGZpP6lFh9fVUDjFQzwv0oH3wZnP5ANT4rE1nQEeBgZTHIPo5Qzu5KpHhVFQNc_0bb6XGAFm-ugPf9iKI2tVA4SIfILsf6VunDeLZUeAAAVJE","expires_in":7200})
+2018/08/26 16:17:50 [I] 接口返回结果: %!(EXTRA map[string]interface {}=map[access_token:13_hezlnSFBORaBwf5SdwfaSZEoGO35hkS4XL7D2SKqDSUwryGZpP6lFh9fVUDjFQzwv0oH3wZnP5ANT4rE1nQEeBgZTHIPo5Qzu5KpHhVFQNc_0bb6XGAFm-ugPf9iKI2tVA4SIfILsf6VunDeLZUeAAAVJE expires_in:7200])

models/customer/customer.go

@@ -93,7 +93,7 @@ func (m *CustomerDAO) GetCustWithWXByID(custID string) (*CustWithWX, error) {
 
 	cust := CustWithWX{}
 	query := `
-		SELECT *
+		SELECT *, t.user_id as map_user
 		FROM
 			ta_customer t
 		LEFT JOIN ta_user_mapping s ON t.customer_id = s.user_id
@@ -215,14 +215,3 @@ func (m *CustomerDAO) GetCustomerByID(id string) (*model.TaCustomer, error) {
 
 	return cust, nil
 }
-
-// GetForbidUserByUserID 查询禁用人员
-func (m *CustomerDAO) GetForbidUserByUserID(userID string) ([]model.TaForbidUser, error) {
-	var fbUsers []model.TaForbidUser
-
-	if err := m.db.Where("user_id=?", userID).Find(&fbUsers); err != nil {
-		return nil, err
-	}
-
-	return fbUsers, nil
-}

models/goods/goods.go

@@ -26,8 +26,56 @@ func NewGoodsDAO(ctx *utils.Context) *GoodsDAO {
 	}
 }
 
+// GetGoodsListPageNavi 获取商品列表
+// 管理端接口
+func (m *GoodsDAO) GetGoodsListPageNavi(name, typeID, caseID string, limit []int) ([]GoodsWithSpec, int64, error) {
+	sql := `
+		SELECT *
+		FROM
+			ta_goods t
+		WHERE
+			t.case_id = ?
+	`
+
+	if name != "" {
+		sql += `
+			AND LOWER(t.goods_name) LIKE '%` + name + `%'
+		`
+	}
+
+	if typeID != "" {
+		sql += `
+			AND t.type_id = '` + typeID + `'
+		`
+	}
+
+	sql += `		
+		AND t.status > ?
+		ORDER BY
+			t.type_id,
+			t.create_date
+	`
+
+	var goodsList []GoodsWithSpec
+	cnt, err := utils.NewPageNaviEngine(m.ctx).GetPageList(&goodsList, sql, limit, caseID, models.STATUS_DEL)
+	if err != nil {
+		return nil, 0, err
+	}
+
+	for inx, goods := range goodsList {
+		specs, err := m.GetSpecWithPrice(goods.GoodsId)
+		if err != nil {
+			return nil, 0, err
+		}
+
+		goodsList[inx].Specs = specs
+	}
+
+	return goodsList, cnt, nil
+}
+
 // GetGoodsListOfCase 获取案场商品列表
-// 暂时没涉及分页
+// 微信端 暂时没涉及分页
 func (m *GoodsDAO) GetGoodsListOfCase(caseID string) ([]GoodsWithSpec, error) {
 	var goodsList []GoodsWithSpec
 
@@ -37,13 +85,8 @@ func (m *GoodsDAO) GetGoodsListOfCase(caseID string) ([]GoodsWithSpec, error) {
 	}
 
 	for inx, goods := range goodsList {
-		sql = `SELECT * FROM td_spec t
-			JOIN ta_goods_spec s ON t.spec_id = s.spec_id
-			WHERE t.status = ? AND s.goods_id = ?
-		`
-
-		var specs []SpecWithPrice
-		if err := m.db.SQL(sql, models.STATUS_DEL, goods.GoodsId).Find(&specs); err != nil {
+		specs, err := m.GetSpecWithPrice(goods.GoodsId)
+		if err != nil {
 			return nil, err
 		}
 
@@ -53,10 +96,23 @@ func (m *GoodsDAO) GetGoodsListOfCase(caseID string) ([]GoodsWithSpec, error) {
 	return goodsList, nil
 }
 
+// GetSpecWithPrice 获取商品规格 含 金额
+func (m *GoodsDAO) GetSpecWithPrice(goodsID string) ([]SpecWithPrice, error) {
+	sql := `SELECT * FROM td_spec t
+		JOIN ta_goods_spec s ON t.spec_id = s.spec_id
+		WHERE t.status = ? AND s.goods_id = ?
+	`
+
+	var specs []SpecWithPrice
+	err := m.db.SQL(sql, models.STATUS_DEL, goodsID).Find(&specs)
+
+	return specs, err
+}
+
 // GetGoodsByID 依据ID 获取商品
-func (m *GoodsDAO) GetGoodsByID(id, caseID string) (*model.TaGoods, error) {
+func (m *GoodsDAO) GetGoodsByID(id string) (*model.TaGoods, error) {
 	goods := new(model.TaGoods)
-	if _, err := m.db.Where("goods_id=?", id).And("case_id=?", caseID).Get(goods); err != nil {
+	if _, err := m.db.Where("goods_id=?", id).Get(goods); err != nil {
 		return nil, err
 	}
 
@@ -85,17 +141,35 @@ func (m *GoodsDAO) GetGoodsWithPriceByID(id, spec, caseID string) (*GoodsWithPri
 	return goods, nil
 }
 
-// UpdateGoods 更新商品
-func (m *GoodsDAO) UpdateGoods(goods *model.TaGoods, cols []string) error {
-	if _, err := m.db.Where("goods_id=?", goods.GoodsId).Cols(cols...).Update(goods); err != nil {
-		return err
+// GetGoodsWithSpecByID  依据ID 获取商品(含规格)
+func (m *GoodsDAO) GetGoodsWithSpecByID(id string) (*GoodsWithSpec, error) {
+	goods := new(model.TaGoods)
+	if _, err := m.db.Where("goods_id=?", id).Get(goods); err != nil {
+		return nil, err
 	}
 
-	return nil
+	var specs []SpecWithPrice
+	query := `
+		SELECT
+			t.*, s.goods_price
+		FROM
+			td_spec t
+		JOIN ta_goods_spec s ON t.spec_id = s.spec_id
+		WHERE
+			s.goods_id = ?
+	`
+	if err := m.db.SQL(query, id).Find(&specs); err != nil {
+		return nil, err
+	}
+
+	return &GoodsWithSpec{
+		TaGoods: *goods,
+		Specs:   specs,
+	}, nil
 }
 
 // SaveGoods 保存商品
-func (m *GoodsDAO) SaveGoods(goods *model.TaGoods) error {
+func (m *GoodsDAO) SaveGoods(goods *model.TaGoods, images []string, specs []SpecWithPrice) error {
 	userRaw := m.ctx.Get("user")
 	if userRaw == nil {
 		return errors.New("登录异常, 请登出重试")
@@ -108,9 +182,114 @@ func (m *GoodsDAO) SaveGoods(goods *model.TaGoods) error {
 	goods.CreateUser = user.UserId
 	goods.OrgId = user.OrgId
 
+	// 商品图片
+	if images != nil && len(images) > 0 {
+		goodsImages := make([]model.TaGoodsImg, 0)
+
+		for _, img := range images {
+			goodsImages = append(goodsImages, model.TaGoodsImg{
+				ImgId:   guid.NewGUIDString(),
+				GoodsId: goods.GoodsId,
+				ImgUrl:  img,
+				Status:  models.STATUS_NORMAL,
+			})
+		}
+
+		if _, err := m.db.Insert(&goodsImages); err != nil {
+			return err
+		}
+	}
+
+	// 规格
+	if specs != nil && len(specs) > 0 {
+		goodsSpecs := make([]model.TaGoodsSpec, 0)
+
+		for _, spec := range specs {
+			goodsSpecs = append(goodsSpecs, model.TaGoodsSpec{
+				SpecId:     spec.SpecId,
+				GoodsId:    goods.GoodsId,
+				GoodsPrice: spec.GoodsPrice,
+			})
+		}
+
+		if _, err := m.db.Insert(&goodsSpecs); err != nil {
+			return err
+		}
+	}
+
 	if _, err := m.db.Insert(goods); err != nil {
 		return err
 	}
 
 	return nil
 }
+
+// UpdateGoods 更新商品
+func (m *GoodsDAO) UpdateGoods(goods *model.TaGoods, images []string, specs []SpecWithPrice) error {
+	cols := []string{
+		"goods_name",
+		"type_id",
+		"status",
+	}
+
+	// 商品图片
+	if images != nil && len(images) > 0 {
+		// 先清除旧数据
+		if _, err := m.db.Delete(&model.TaGoodsImg{GoodsId: goods.GoodsId}); err != nil {
+			return err
+		}
+
+		goodsImages := make([]model.TaGoodsImg, 0)
+		for _, img := range images {
+			goodsImages = append(goodsImages, model.TaGoodsImg{
+				ImgId:   guid.NewGUIDString(),
+				GoodsId: goods.GoodsId,
+				ImgUrl:  img,
+				Status:  models.STATUS_NORMAL,
+			})
+		}
+
+		if _, err := m.db.Insert(&goodsImages); err != nil {
+			return err
+		}
+	}
+
+	// 规格
+	if specs != nil && len(specs) > 0 {
+		// 先清除旧数据
+		if _, err := m.db.Delete(&model.TaGoodsSpec{GoodsId: goods.GoodsId}); err != nil {
+			return err
+		}
+
+		goodsSpecs := make([]model.TaGoodsSpec, 0)
+		for _, spec := range specs {
+			goodsSpecs = append(goodsSpecs, model.TaGoodsSpec{
+				SpecId:     spec.SpecId,
+				GoodsId:    goods.GoodsId,
+				GoodsPrice: spec.GoodsPrice,
+			})
+		}
+
+		if _, err := m.db.Insert(&goodsSpecs); err != nil {
+			return err
+		}
+	}
+
+	if _, err := m.db.Where("goods_id=?", goods.GoodsId).Cols(cols...).Update(goods); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// DeleteGoods 删除商品
+func (m *GoodsDAO) DeleteGoods(id string) error {
+	goods := new(model.TaGoods)
+	goods.Status = models.STATUS_DEL
+
+	if _, err := m.db.Where("goods_id=?", id).Cols("status").Update(goods); err != nil {
+		return err
+	}
+
+	return nil
+}

models/goods/orders.go

@@ -12,6 +12,11 @@ import (
 	"github.com/yl10/kit/guid"
 )
 
+// GetOrdersByCases 获取案场订单列表
+func (m *GoodsDAO) GetOrdersByCases() error {
+	return nil
+}
+
 // SaveOrders 下单
 func (m *GoodsDAO) SaveOrders(order *model.TaGoodsOrders) error {
 	if order.UserId == "" {
@@ -110,3 +115,55 @@ func (m *GoodsDAO) getCaseByID(caseID string) (*model.SysCase, error) {
 
 	return cs, nil
 }
+
+// GetOrdersByCaseID 获取订单列表
+func (m *GoodsDAO) GetOrdersByCaseID(caseID, userType string, makeStatus []string, orderDate []time.Time, limit []int) ([]OrdersWithGoods, int64, error) {
+	var orderList []OrdersWithGoods
+
+	query := "select * from ta_goods_orders where case_id = ? and status = ?"
+
+	// 制作状态
+	if makeStatus != nil && len(makeStatus) > 0 {
+		query += ` and make_status in ('` + strings.Join(makeStatus, "','") + `')`
+	}
+
+	// 用户类型
+	if userType != "" {
+		query += ` and user_type = '` + userType + `'`
+	}
+
+	// 订单起始时间
+	if orderDate != nil && len(orderDate) > 0 {
+		query += ` and DATE_FORMAT(create_date, '%Y-%m-%d %H:%i') >= '` + orderDate[0].Format("2006-01-02 15:04") + `'`
+
+		if len(orderDate) > 1 {
+			query += ` and DATE_FORMAT(create_date, '%Y-%m-%d %H:%i') <= '` + orderDate[1].Format("2006-01-02 15:04") + `'`
+		}
+	}
+
+	query += " order by create_date asc"
+
+	var cnt int64
+	if limit != nil && len(limit) > 1 {
+		var err error
+		cnt, err = utils.NewPageNaviEngine(m.ctx).GetPageList(&orderList, query, limit, caseID, models.STATUS_NORMAL)
+		if err != nil {
+			return nil, 0, err
+		}
+	} else {
+		if err := m.db.SQL(query, caseID, models.STATUS_NORMAL).Find(&orderList); err != nil {
+			return nil, 0, err
+		}
+	}
+
+	for i, o := range orderList {
+		var details []model.TaGoodsOrdersDetail
+		if err := m.db.Where("orders_id=?", o.OrdersId).Find(&details); err != nil {
+			return nil, 0, err
+		}
+
+		orderList[i].Goods = details
+	}
+
+	return orderList, cnt, nil
+}

models/goods/types.go

@@ -4,10 +4,18 @@ import (
 	"spaceofcheng/services/models/model"
 )
 
+// 商品订单 - 制作状态
+const (
+	MAKESTATUS_NOTSTARTED = "not started"
+	MAKESTATUS_DOING      = "doing"
+	MAKESTATUS_FINISHED   = "finished"
+	MAKESTATUS_CANCEL     = "cancel"
+)
+
 // SpecWithPrice 规格价格
 type SpecWithPrice struct {
 	model.TdSpec
-	GoodsPrice float32 `xorm:"FLOAT(8,2)"`
+	GoodsPrice string `xorm:"DECIMAL(8,2)"`
 }
 
 // GoodsWithSpec 含规格商品
@@ -21,3 +29,9 @@ type GoodsWithPrice struct {
 	model.TaGoods     `xorm."extends"`
 	model.TaGoodsSpec `xorm."extends"`
 }
+
+// OrdersWithGoods 订单列表
+type OrdersWithGoods struct {
+	model.TaGoodsOrders
+	Goods []model.TaGoodsOrdersDetail
+}

models/model/sys_wechat_conf.go

@@ -9,6 +9,6 @@ type SysWechatConf struct {
 	Token  string `xorm:"VARCHAR(50)"`
 	Aeskey string `xorm:"VARCHAR(100)"`
 	Wxid   string `xorm:"VARCHAR(50)"`
-	Rmark  string `xorm:"TEXT"`
+	Remark string `xorm:"TEXT"`
 	Status int    `xorm:"SMALLINT(6)"`
 }

models/model/ta_goods_orders.go

@@ -25,4 +25,5 @@ type TaGoodsOrders struct {
 	IsPay        int       `xorm:"TINYINT(1)"`
 	ActualAmount string    `xorm:"DECIMAL(8,2)"`
 	CouponAmount string    `xorm:"DECIMAL(8,2)"`
+	MakeStatus   string    `xorm:"VARCHAR(20)"`
 }

models/system/user.go

@@ -378,3 +378,45 @@ func (m *UserDAO) UpdateUserMapping(userMap *model.TaUserMapping, cols []string)
 	_, err := m.db.Where("mapping_id=?", userMap.MappingId).Cols(cols...).Update(userMap)
 	return err
 }
+
+type UserWithType struct {
+	model.SysUser
+	TypeId   string
+	TypeName string
+	CaseId   string
+}
+
+// GetUserWithTypeByID 获取用户类型
+func (m *UserDAO) GetUserWithTypeByID(userID string) ([]UserWithType, error) {
+	query := `
+		SELECT
+			t.*, m.type_id,
+			m.type_name,
+			m.case_id
+		FROM
+			sys_user t
+		JOIN sys_user_type s ON t.user_id = s.user_id
+		JOIN td_user_type m ON s.type_id = m.type_id
+		AND m.status = ?
+		WHERE
+			t.user_id = ?
+	`
+
+	var userTypes []UserWithType
+	if err := m.db.SQL(query, models.STATUS_NORMAL, userID).Find(&userTypes); err != nil {
+		return nil, err
+	}
+
+	return userTypes, nil
+}
+
+// GetForbidUserByUserID 查询禁用人员
+func (m *UserDAO) GetForbidUserByUserID(userID string) ([]model.TaForbidUser, error) {
+	var fbUsers []model.TaForbidUser
+
+	if err := m.db.Where("user_id=?", userID).Find(&fbUsers); err != nil {
+		return nil, err
+	}
+
+	return fbUsers, nil
+}

routers/common.go

@@ -175,6 +175,15 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/detail", &course.CourseController{}, "put:SaveDetail"),
 		beego.NSRouter("/detail/:detailid", &course.CourseController{}, "delete:DelCourseDetail"),
 
+		// 商品
+		beego.NSRouter("/goods", &goods.GoodsController{}, "get:GetListByCase"),
+		beego.NSRouter("/goods", &goods.GoodsController{}, "post:UpdateGoods"),
+		beego.NSRouter("/goods/:id", &goods.GoodsController{}, "put:UpdateGoods"),
+		beego.NSRouter("/goods/:id", &goods.GoodsController{}, "delete:UpdateGoods"),
+
+		// 商品订单
+		beego.NSRouter("/order/goods", &goods.GoodsController{}, "get:GetListByCase"),
+
 		// 文件
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
 

routers/guest.go

@@ -4,6 +4,7 @@ import (
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/controllers/cases"
 	"spaceofcheng/services/controllers/customer"
+	"spaceofcheng/services/controllers/goods"
 	"spaceofcheng/services/controllers/message"
 	"spaceofcheng/services/controllers/user"
 
@@ -22,6 +23,12 @@ func getGuestRoutes() beego.LinkNamespace {
 		// 案场
 		beego.NSRouter("/case", &cases.CaseController{}, "get:GetOrgCases"),
 
+		// 商品制作状态
+		beego.NSRouter("/dict/order/makestatus", &goods.GoodsController{}, "get:GetMakeStatus"),
+
+		// 商品
+		beego.NSRouter("/goods", &goods.GoodsController{}, "get:GetListForWechat"),
+
 		// 验证码 获取, 校验
 		beego.NSRouter("/captcha", &controllers.BaseController{}, "get:SendCaptcha"),
 		beego.NSRouter("/captcha", &controllers.BaseController{}, "post:ValidCaptcha"),

service/customer/customer.go

@@ -156,13 +156,14 @@ func (s *CustomerServ) BindWechatCust(userMap *model.TaUserMapping, phone, caseI
 		return nil, errors.New("用户状态不正确")
 	}
 
-	// triggerRegiteEvent 触发注册事件
-	utils.EmitEvent(events.EvtRegiste, *cust)
-
+	// 如果客户ID 与映射表中一致, 说明已经绑定过了
 	if cust.CustomerId == userMap.UserId {
 		return cust, nil
 	}
 
+	// triggerRegiteEvent 触发注册事件
+	utils.EmitEvent(events.EvtRegiste, *cust)
+
 	// 更新用户映射信息
 	userMap.UserId = cust.CustomerId
 	if err := s.dao.UpdateUserMapping(userMap, []string{"user_id"}); err != nil {

service/goods/goods.go

@@ -1,10 +1,15 @@
 package goods
 
 import (
+	"errors"
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/cases"
 	"spaceofcheng/services/models/customer"
 	"spaceofcheng/services/models/goods"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/models/system"
 	"spaceofcheng/services/utils"
+	"strings"
 )
 
 // GoodsServ 系统处理
@@ -13,6 +18,7 @@ type GoodsServ struct {
 	dao     *goods.GoodsDAO
 	caseDAO *cases.CaseDAO
 	custDAO *customer.CustomerDAO
+	userDAO *system.UserDAO
 }
 
 // NewGoodsServ 初始化
@@ -22,5 +28,86 @@ func NewGoodsServ(ctx *utils.Context) *GoodsServ {
 		dao:     goods.NewGoodsDAO(ctx),
 		caseDAO: cases.NewCaseDAO(ctx),
 		custDAO: customer.NewCustomerDAO(ctx),
+		userDAO: system.NewUserDAO(ctx),
 	}
 }
+
+// GetListByCase 获取商品列表
+// 微信端
+func (s *GoodsServ) GetListByCase(id string) ([]goods.GoodsWithSpec, error) {
+	res, err := s.dao.GetGoodsListOfCase(id)
+
+	if err != nil {
+		utils.LogError("获取商品列表失败: " + err.Error())
+		return nil, errors.New("获取列表失败, 请重试")
+	}
+
+	return res, nil
+}
+
+// GetGoodsListPageNavi 获取商品列表
+// 前端 - 非统计部分
+func (s *GoodsServ) GetGoodsListPageNavi(name, typeID, caseID string, page, pagesize int) ([]goods.GoodsWithSpec, int64, error) {
+	if page < 1 {
+		page = 1
+	}
+	if pagesize < 0 {
+		pagesize = 0
+	}
+
+	offset := (page - 1) * pagesize
+
+	res, cnt, err := s.dao.GetGoodsListPageNavi(strings.ToLower(name), typeID, caseID, []int{pagesize, offset})
+	if err != nil {
+		utils.LogError("获取商品列表失败: " + err.Error())
+		return nil, 0, errors.New("获取列表失败, 请重试")
+	}
+
+	return res, cnt, nil
+}
+
+// UpdateGoods 更新商品
+// 如果没有则新增
+func (s *GoodsServ) UpdateGoods(goods *model.TaGoods, images []string, specs []goods.SpecWithPrice) error {
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(goods.CaseId); err != nil {
+		return err
+	}
+
+	if goods.GoodsId == "" {
+		if err := s.dao.SaveGoods(goods, images, specs); err != nil {
+			utils.LogError("保存商品失败: " + err.Error())
+			return errors.New("保存商品失败, 请重试")
+		}
+	} else {
+		if err := s.dao.UpdateGoods(goods, images, specs); err != nil {
+			utils.LogError("更新商品失败: " + err.Error())
+			return errors.New("更新商品失败, 请重试")
+		}
+	}
+
+	return nil
+}
+
+// DeleteGoods 删除商品
+func (s *GoodsServ) DeleteGoods(id string) error {
+	goods, err := s.dao.GetGoodsByID(id)
+	if err != nil {
+		utils.LogError("查询商品失败: " + err.Error())
+		return errors.New("校验商品失败")
+	}
+
+	if goods.Status == models.STATUS_DEL {
+		return nil
+	}
+
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(goods.CaseId); err != nil {
+		return err
+	}
+
+	if err := s.dao.DeleteGoods(id); err != nil {
+		utils.LogError("删除商品失败: " + err.Error())
+		return errors.New("删除商品失败")
+	}
+
+	return nil
+}

service/goods/orders.go

@@ -3,9 +3,11 @@ package goods
 import (
 	"errors"
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/goods"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 	"strconv"
+	"time"
 )
 
 // Orders 下单
@@ -72,6 +74,10 @@ func (s *GoodsServ) Orders(
 		}
 	}
 
+	// TODO
+	// 通知后端有新订单 - websocket
+	// utils.SendMessage()
+
 	return nil
 }
 
@@ -148,7 +154,32 @@ func (s *GoodsServ) validOrdersInfo(info *model.TaGoodsOrders) error {
 
 	// 如果是管理人员
 	if cust.UserId != "" {
-		fibUsers, err := s.custDAO.GetForbidUserByUserID(cust.UserId)
+		// 查找用户类型
+		userWithTypes, err := s.userDAO.GetUserWithTypeByID(cust.UserId)
+		if err != nil {
+			utils.LogError("查询下单人类型出错: " + err.Error())
+			return errors.New("验证下单人出错")
+		}
+		if userWithTypes != nil && len(userWithTypes) > 0 {
+			for _, ut := range userWithTypes {
+				if ut.Status != models.STATUS_NORMAL {
+					return errors.New("下单人状态不正确, 不能下单")
+				}
+
+				if ut.CaseId == caseID {
+					info.UserType = ut.TypeId
+
+					// 下单人姓名 - 姓名不存在则用昵称
+					info.UserName = ut.RealName
+					if info.UserName == "" {
+						info.UserName = cust.CustomerName
+					}
+				}
+			}
+		}
+
+		// 查找禁用名单
+		fibUsers, err := s.userDAO.GetForbidUserByUserID(cust.UserId)
 		if err != nil {
 			utils.LogError("查询下单人是否被禁出错: " + err.Error())
 			return errors.New("验证下单人出错")
@@ -202,3 +233,53 @@ func (s *GoodsServ) validBillCharges(info *model.TaGoodsOrders, details []model.
 
 	return nil
 }
+
+// GetOrderList 获取订单列表
+// 管理端 - 查询统计
+func (s *GoodsServ) GetOrderList(caseID, userType, status string, orderDate []time.Time, page, pagesize int) ([]goods.OrdersWithGoods, int64, error) {
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
+		return nil, 0, err
+	}
+
+	var makeStatus []string
+	if status != "" {
+		makeStatus = []string{status}
+	}
+
+	if page < 1 {
+		page = 1
+	}
+	if pagesize < 0 {
+		pagesize = 0
+	}
+	limit := []int{
+		pagesize,
+		(page - 1) * pagesize,
+	}
+
+	orderList, cnt, err := s.dao.GetOrdersByCaseID(caseID, userType, makeStatus, orderDate, limit)
+	if err != nil {
+		utils.LogError("获取商品订单列表失败： " + err.Error())
+		return nil, 0, errors.New("获取商品订单列表失败")
+	}
+
+	return orderList, cnt, nil
+}
+
+// GetOnLineOrders 获取订单列表
+// 管理端 - 在线订单
+func (s *GoodsServ) GetOnLineOrders(caseID string) ([]goods.OrdersWithGoods, error) {
+	if err := utils.NewAuthEngine(s.ctx).CheckCase(caseID); err != nil {
+		return nil, err
+	}
+
+	makeStatus := []string{goods.MAKESTATUS_NOTSTARTED, goods.MAKESTATUS_DOING}
+
+	orderList, _, err := s.dao.GetOrdersByCaseID(caseID, "", makeStatus, nil, nil)
+	if err != nil {
+		utils.LogError("获取在线订单列表失败： " + err.Error())
+		return nil, errors.New("获取在线订单列表失败")
+	}
+
+	return orderList, nil
+}

service/sys.go

@@ -113,6 +113,7 @@ func (s *SysServ) CheckWechatUserMapping(user map[string]interface{}) (*model.Ta
 			if userMapping.Openid == um.Openid &&
 				userMapping.AccountType == um.AccountType &&
 				userMapping.UserType == um.UserType {
+				userMapping.UserId = um.UserId
 
 				// 存在的用户, 使用 ID 作为检查条件去更新
 				userMapping.MappingId = um.MappingId
@@ -123,7 +124,6 @@ func (s *SysServ) CheckWechatUserMapping(user map[string]interface{}) (*model.Ta
 	// 更新数据库内容, 没有的话则插入
 	err = s.dao.UpdateUserMapping(&userMapping)
 	if err != nil {
-		beego.Error(err)
 		return nil, err
 	}
 

utils/permission.go

@@ -25,6 +25,29 @@ func NewAuthEngine(ctx *Context) *DataAuthEngine {
 	return &DataAuthEngine{ctx: ctx}
 }
 
+// CheckCase 校验案场数据权限
+func (t *DataAuthEngine) CheckCase(caseID string) error {
+	cases := t.ctx.Get("cases")
+	if cases == nil {
+		return errors.New("请授权用户案场权限")
+	}
+
+	found := false
+	userCases := cases.([]model.SysUserCase)
+
+	for _, cs := range userCases {
+		if caseID == cs.CaseId {
+			found = true
+		}
+	}
+
+	if !found {
+		return errors.New("用户无该案场数据权限")
+	}
+
+	return nil
+}
+
 // AuthFilter 按权限过滤
 func (t *DataAuthEngine) AuthFilter(targ interface{}, sql string, params ...interface{}) error {
 	if t.ctx == nil {

utils/wechat.go

@@ -4,20 +4,26 @@ import (
 	"github.com/zjxpcyc/wechat/wx"
 )
 
-var wxCli *wx.Client
+var wxClients map[string]*wx.Client
 
-// InitWeChatClient 初始化
-func InitWeChatClient(cert map[string]string) {
-	wxCli = wx.NewClient(cert)
-	wx.SetLogInst(defaultLogger)
+// WxClientSingleton 初始化
+func WxClientSingleton(org string, cert map[string]string) {
+	if wxClients == nil {
+		wxClients = map[string]*wx.Client{
+			org: wx.NewClient(cert),
+		}
+	} else {
+		if _, ok := wxClients[org]; !ok {
+			wxClients[org] = wx.NewClient(cert)
+		}
+	}
 }
 
-// GetWxUserInfo 微信获取用户信息
-func GetWxUserInfo(code string) (map[string]interface{}, error) {
-	return wxCli.GetUserInfo(code)
+// WxClientFor 微信客户端
+func WxClientFor(org string) *wx.Client {
+	return wxClients[org]
 }
 
-// WechatSignature 启用 Wechat 接口
-func WechatSignature(timestamp, nonce string) string {
-	return wxCli.Signature(timestamp, nonce)
+func init() {
+	wx.SetLogInst(defaultLogger)
 }