1

conf/log.conf

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

conf/sms.conf

@@ -0,0 +1,7 @@
+# 短信接口
+url = http://localhost:8080/sms
+method = POST
+contentType = "application/json;charset=UTF-8"
+
+[captcha]
+code = 0107

controllers/auth.go

@@ -1,6 +1,10 @@
 package controllers
 
 import (
+	"errors"
+	"net/http"
+	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
 	"strings"
 
 	"github.com/astaxie/beego"
@@ -8,23 +12,127 @@ import (
 
 // Authenticate 权限验证
 func (c *BaseController) authenticate() {
+	// 默认 service
+	serv := service.NewSysServ(c.Context)
+
+	// 客户端类型
+	clientType := utils.GetClientType(c.Ctx.Request)
+
+	switch clientType {
+	case utils.ClientAdmin:
+		c.authPCAdmin(serv)
+	case utils.ClientWechat:
+		c.authWechat(serv)
+	default:
+		c.ResponseError(
+			errors.New("暂不支持的 API 场景"),
+			http.StatusBadRequest,
+		)
+	}
+}
+
+// authPCAdmin PC管理端
+func (c *BaseController) authPCAdmin(serv *service.SysServ) {
 	if !c.needAuth() {
 		return
 	}
 
-	userID, _ := c.GetSession(SNUserID).(string)
-	// userType := c.GetSession(SNUserType).(string)
+	// 用户ID
+	userID := ""
+	userIDRaw := c.GetSession(SNUserID)
+	if userIDRaw != nil {
+		userID = userIDRaw.(string)
+	}
 
-	// 未登录状态
 	if userID == "" {
+		c.ResponseError(
+			errors.New("用户未登录"),
+			http.StatusUnauthorized,
+		)
+	}
+
+	if err := serv.SetUserProfile(userID); err != nil {
+		utils.LogError(err.Error())
+
+		c.ResponseError(
+			errors.New("内部错误, 请重试"),
+			http.StatusInternalServerError,
+		)
+	}
+
+	// 设置 Session
+	c.SetSession(SNUserID, userID)
+}
+
+// authWechat 微信端
+func (c *BaseController) authWechat(serv *service.SysServ) {
+	custID := ""
+	custIDRaw := c.GetSession(SNCustID)
+	if custIDRaw != nil {
+		custID = custIDRaw.(string)
+	}
+
+	// 用户微信信息
+	var wxDetail map[string]interface{}
+	detailRaw := c.GetSession("wechat_user")
+	if detailRaw != nil {
+		wxDetail = detailRaw.(map[string]interface{})
+	}
+
+	if custID == "" && wxDetail == nil {
+		wxDetail = c.getWechatDetail()
+		c.SetSession("wechat_user", wxDetail)
+	}
+
+	c.Context.Set("wxInfo", wxDetail)
+
+	// 普通客户映射检查
+	userMap, err := serv.CheckWechatUserMapping(wxDetail)
+	if err != nil {
+		c.ResponseError(
+			utils.LogError("获取人员映射账户失败: "+err.Error()),
+			http.StatusInternalServerError,
+		)
+	}
+
+	if !c.needAuth() {
 		return
 	}
 
-	// clientType := utils.GetClientType()
-	// if clientType == utils.ClientWechat {
+	// 未登录或者绑定, 返回 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,
+			)
+		}
+	}
+
+	if custID == "" {
+		custID = userMap.UserId
+	}
 
-	// }
+	if err := serv.SetCustomer(custID); err != nil {
+		utils.LogError(err.Error())
 
+		c.ResponseError(
+			errors.New("内部错误, 请重试"),
+			http.StatusInternalServerError,
+		)
+	}
+
+	// 设置 Session
+	c.SetSession(SNCustID, custID)
 }
 
 func (c *BaseController) needAuth() bool {
@@ -38,3 +146,25 @@ func (c *BaseController) needAuth() bool {
 
 	return true
 }
+
+// getWechatDetail 获取微信个人信息详情
+func (c *BaseController) getWechatDetail() map[string]interface{} {
+	// 微信 code
+	code := c.GetString("code")
+	if code == "" {
+		c.ResponseError(
+			errors.New("没有接收到微信 code"),
+			http.StatusBadRequest,
+		)
+	}
+
+	usr, err := utils.GetWxUserInfo(code)
+	if err != nil {
+		c.ResponseError(
+			utils.LogError("获取微信个人信息失败: "+err.Error()),
+			http.StatusInternalServerError,
+		)
+	}
+
+	return usr
+}

controllers/base.go

@@ -6,16 +6,21 @@ import (
 	"spaceofcheng/services/utils"
 
 	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/config"
 )
 
 //BaseController 基础controller
 type BaseController struct {
 	beego.Controller
-	Context *utils.Context
+	Context  *utils.Context
+	Configer map[string]config.Configer
 }
 
 //Prepare 继承beego的
 func (c *BaseController) Prepare() {
+	// 读取配置文件
+	c.initConfig()
+
 	// 初始化上下文
 	c.initContext()
 

controllers/config.go

@@ -0,0 +1,52 @@
+package controllers
+
+import (
+	"spaceofcheng/services/utils"
+
+	"github.com/astaxie/beego/config"
+)
+
+// 配置文件列表
+const (
+	AliYunConf = "aliyun"
+	WeChatConf = "wechat"
+	SMSConf    = "sms"
+)
+
+func (c *BaseController) initConfig() {
+	if c.Configer == nil {
+		c.Configer = make(map[string]config.Configer)
+	}
+
+	// 阿里云
+	aliConf := c.getConfig("conf/aliyun.conf")
+	if aliConf != nil {
+		c.Configer[AliYunConf] = aliConf
+	}
+
+	// 微信
+	clientType := utils.GetClientType(c.Ctx.Request)
+	if clientType == utils.ClientWechat {
+		wxConf := c.getConfig("conf/wechat.conf")
+		if wxConf != nil {
+			c.Configer[WeChatConf] = wxConf
+		}
+	}
+
+	// 短信
+	smsConf := c.getConfig("conf/sms.conf")
+	if smsConf != nil {
+		c.Configer[SMSConf] = smsConf
+	}
+	utils.ResetSMSEngine(smsConf)
+}
+
+func (c *BaseController) getConfig(confPath string) config.Configer {
+	aliConf, err := config.NewConfig("ini", confPath)
+	if err != nil {
+		utils.LogError("读取配置文件失败: " + err.Error())
+		return nil
+	}
+
+	return aliConf
+}

controllers/context.go

@@ -11,6 +11,8 @@ import (
 * - 包含内容如下
 * user					用户基本信息
 * customer			会员基本信息
+* userMap				用户/会员 映射第三方账户
+* wxInfo				微信信息
 * cases					用户所有案场信息
 * currentCase 	当前案场
 * org						用户当前组织

controllers/customer/customer.go

@@ -0,0 +1,130 @@
+package customer
+
+import (
+	"errors"
+	"net/http"
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/customer"
+	"spaceofcheng/services/utils"
+)
+
+// CustomerController 用户
+type CustomerController struct {
+	serv *customer.CustomerServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *CustomerController) Constructor() {
+	c.serv = customer.NewCustomerServ(c.Context)
+}
+
+// CustWXList 获取客户列表
+func (c *CustomerController) CustWXList() {
+	phone := c.GetString("phone")
+	page, _ := c.GetInt("page")
+
+	custList, total, err := c.serv.GetCustWithWXList(phone, page)
+	if err != nil {
+		utils.LogError("获取客户列表失败: " + err.Error())
+		c.ResponseError(
+			errors.New("获取客户列表失败"),
+			http.StatusInternalServerError,
+		)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"list":  custList,
+		"total": total,
+	})
+}
+
+// GetCustWXByID 获取用户信息
+func (c *CustomerController) GetCustWXByID() {
+	userMapRaw := c.Context.Get("userMap")
+	if userMapRaw == nil {
+		c.ResponseError(errors.New("获取用户信息失败, 请确认使用微信浏览"))
+	}
+
+	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,
+		})
+	}
+}
+
+// SignIn 微信登录
+func (c *CustomerController) SignIn() {
+	phone := c.GetString("phone")
+	captcha := c.GetString("captcha")
+
+	if err := utils.ValidCaptcha(phone, captcha); err != nil {
+		c.ResponseError(err)
+	}
+
+	userMapping := c.Context.Get("userMap").(model.TaUserMapping)
+
+	cust, err := c.serv.BindWechatUser(&userMapping, phone)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.SetSession(controllers.SNCustID, cust.CustomerId)
+
+	c.ResponseJSON("ok")
+}
+
+// SignUp 注册会员
+func (c *CustomerController) SignUp() {
+	phone := c.GetString("phone")
+	captcha := c.GetString("captcha")
+	csID := c.GetString("case")
+	arID := c.GetString("sales")
+
+	if phone == "" || captcha == "" || csID == "" || arID == "" {
+		c.ResponseError(errors.New("请填写完整注册信息"))
+	}
+
+	if err := utils.ValidCaptcha(phone, captcha); err != nil {
+		c.ResponseError(err)
+	}
+
+	userMapping := c.Context.Get("userMap").(model.TaUserMapping)
+
+	cust, err := c.serv.BindWechatCust(&userMapping, phone, csID, arID)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.SetSession(controllers.SNCustID, cust.CustomerId)
+
+	c.ResponseJSON("ok")
+}

controllers/file.go

@@ -1,13 +1,12 @@
 package controllers
 
 import (
+	"errors"
 	"spaceofcheng/services/utils"
 	"strconv"
 	"time"
 
 	"net/http"
-
-	"github.com/astaxie/beego/config"
 )
 
 // FileUpload 文件上传
@@ -23,9 +22,9 @@ func (c *BaseController) FileUpload() {
 }
 
 func (c *BaseController) uploadFileToOSS(field string) (string, error) {
-	aliConf, err := config.NewConfig("ini", "conf/aliyun.conf")
-	if err != nil {
-		return "", err
+	aliConf, ok := c.Configer[AliYunConf]
+	if !ok {
+		return "", errors.New("没有找到阿里云相关配置")
 	}
 
 	endpoint := aliConf.String("oss::Endpoint")

controllers/message.go

@@ -0,0 +1,42 @@
+package controllers
+
+import (
+	"errors"
+	"spaceofcheng/services/utils"
+)
+
+// SendCaptcha 发送验证码
+func (c *BaseController) SendCaptcha() {
+	phone := c.GetString("phone")
+
+	if phone == "" {
+		c.ResponseError(errors.New("请确定手机号码"))
+	}
+
+	if err := utils.SendCaptcha(phone); err != nil {
+		utils.LogError(err)
+		c.ResponseError(errors.New("验证码发送失败, 请重试"))
+	}
+
+	c.ResponseJSON("ok")
+}
+
+// ValidCaptcha 发送验证码
+func (c *BaseController) ValidCaptcha() {
+	phone := c.GetString("phone")
+
+	if phone == "" {
+		c.ResponseError(errors.New("请确定手机号码"))
+	}
+
+	captcha := c.GetString("captcha")
+	if captcha == "" {
+		c.ResponseError(errors.New("验证码不能为空"))
+	}
+
+	if err := utils.ValidCaptcha(phone, captcha); err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON("ok")
+}

controllers/session.go

@@ -4,6 +4,10 @@ package controllers
 const (
 	// 用户ID
 	SNUserID = "userid"
-	// 用户类型
-	SNUserType = "userType"
+
+	// 客户ID
+	SNCustID = "custid"
+
+	// 内置 wechat_user
+	// 请勿使用 wechat_user 作为 session 的key
 )

controllers/types.go

@@ -1,12 +1,5 @@
 package controllers
 
-// 用户类型列表
-const (
-	UserGuest    = "guest"
-	UserCommon   = "common"
-	UserCustomer = "customer"
-)
-
 // JSONMessage 主要用于 Response 返回
 type JSONMessage struct {
 	Code    int         `json:"code"`

controllers/user/user.go

@@ -1,10 +1,14 @@
 package user
 
 import (
+	"errors"
+	"net/http"
 	"spaceofcheng/services/controllers"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/system"
 	"spaceofcheng/services/service"
+	"spaceofcheng/services/utils"
+	"time"
 )
 
 // UserController 用户
@@ -127,3 +131,61 @@ func (c *UserController) GetUserCustomer() {
 	}
 	c.ResponseJSON(customers)
 }
+
+// SignIn 用户登录
+func (c *UserController) SignIn() {
+	userName := c.GetString("username")
+	userPassword := c.GetString("userpassword")
+	token := c.GetString("token")
+	doRemember, _ := c.GetInt("doremember")
+
+	if token != "" {
+		tokenMap, err := utils.PareseToken(token)
+		if err != nil {
+			utils.LogError("解析用户 token 失败: " + err.Error())
+
+			c.ResponseError(
+				errors.New("登录失败, 用户名或者密码不正确"),
+				http.StatusBadRequest,
+			)
+		}
+
+		userName = tokenMap["user"].(string)
+		userPassword = tokenMap["password"].(string)
+	}
+
+	user, err := c.dao.CheckUserSignIn(userName, userPassword)
+	if err != nil {
+		utils.LogError("用户登录失败: " + err.Error())
+		c.ResponseError(
+			errors.New("登录失败, 用户名或者密码不正确"),
+			http.StatusBadRequest,
+		)
+	}
+
+	// 成功之后, 设置 session
+	c.SetSession(controllers.SNUserID, user.UserId)
+
+	if token == "" && doRemember != 0 {
+		var err error
+		token, err = utils.CreateToken(map[string]interface{}{
+			"user":     userName,
+			"password": userPassword,
+			"exp":      time.Now().Local().Add(7 * 24 * time.Hour), // 有效期是 7 天
+		})
+
+		if err != nil {
+			utils.LogError("生成 用户登录 token 失败: " + err.Error())
+		}
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		token: token,
+	})
+}
+
+// SignOut 用户登出
+func (c *UserController) SignOut() {
+	c.DestroySession()
+	c.ResponseJSON("ok")
+}

models/constant.go

@@ -1,11 +1,30 @@
 package models
 
+// 状态列表
 const (
 	STATUS_NORMAL = 1
 	STATUS_DEL    = -1
 )
 
+// 映射数据库的布尔型
+const (
+	BOOL_FALSE = 0
+	BOOL_TRUE  = 1
+)
+
+// 映射表账户类型
+const (
+	ACCMAP_WECHAT = "wechat"
+	ACCMAP_MINI   = "mini"
+)
+
 const (
 	IMAGETYPE_COVER  = "cover"
 	IMAGETYPE_DETAIL = "detail"
 )
+
+// 映射表用户类型
+const (
+	USERMAP_USER     = "user"
+	USERMAP_CUSTOMER = "customer"
+)

models/customer/customer.go

@@ -0,0 +1,193 @@
+package customer
+
+import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/utils"
+	"time"
+
+	"github.com/yl10/kit/guid"
+
+	"github.com/go-xorm/xorm"
+)
+
+// CustomerDAO 当前数据库操作对象
+type CustomerDAO struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewCustomerDAO New Inst
+func NewCustomerDAO(ctx *utils.Context) *CustomerDAO {
+	return &CustomerDAO{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+// CustWithWXList 客户列表
+func (m *CustomerDAO) CustWithWXList(phone string, page ...int) ([]CustWithWX, int64, error) {
+	if phone == "" {
+		phone = "%"
+	} else {
+		phone = "%" + phone + "%"
+	}
+
+	pageNum := 10
+	if m.ctx.Get("pageNum") != nil {
+		pageNum = m.ctx.Get("pageNum").(int)
+	}
+
+	pg := 1
+	if len(page) > 0 {
+		pg = page[0]
+	}
+	offset := (pg - 1) * pageNum
+	if offset < 0 {
+		offset = 0
+	}
+
+	query := `
+		SELECT *
+		FROM
+			ta_customer t
+		LEFT JOIN ta_user_mapping s ON t.customer_id = s.user_id
+			AND s.user_type = '` + models.USERMAP_CUSTOMER + `'
+			AND s.account_type = '` + models.ACCMAP_WECHAT + `'
+		WHERE
+			t.phone like ?
+		AND t.status > ?
+		ORDER BY
+			t.create_date DESC
+	`
+
+	var cust []CustWithWX
+
+	cnt, err := utils.GetPageList(m.db, &cust, []int{pageNum, offset}, query, phone, models.STATUS_DEL)
+	if err != nil {
+		return nil, 0, err
+	}
+
+	return cust, cnt, nil
+}
+
+// GetCustWithWXByID 获取客户(微信)信息
+func (m *CustomerDAO) GetCustWithWXByID(custID string) (*CustWithWX, error) {
+	if custID == "" {
+		return nil, errors.New("获取客户信息失败")
+	}
+
+	cust := CustWithWX{}
+	query := `
+		SELECT *
+		FROM
+			ta_customer t
+		LEFT JOIN ta_user_mapping s ON t.customer_id = s.user_id
+			AND s.user_type = '` + models.USERMAP_CUSTOMER + `'
+			AND s.account_type = '` + models.ACCMAP_WECHAT + `'
+		WHERE
+			t.customer_id = ?
+	`
+
+	if _, err := m.db.SQL(query, custID).Get(&cust); err != nil {
+		return nil, err
+	}
+
+	return &cust, nil
+}
+
+// GetCustomerByPhone 依据手机号获取客户信息
+func (m *CustomerDAO) GetCustomerByPhone(phone string) (*model.TaCustomer, error) {
+	custs := []model.TaCustomer{}
+
+	if err := m.db.Where("phone=?", phone).Find(&custs); err != nil {
+		return nil, err
+	}
+
+	if len(custs) == 0 {
+		return nil, nil
+	}
+
+	if len(custs) > 0 {
+		return nil, errors.New("数据异常, 一个手机绑定了多个用户")
+	}
+
+	cust := custs[0]
+
+	return &cust, nil
+}
+
+// UpdateUserMapping 更新用户映射
+func (m *CustomerDAO) UpdateUserMapping(userMap *model.TaUserMapping, cols []string) error {
+	if userMap.MappingId == "" {
+		return errors.New("用户映射信息不存在")
+	}
+
+	_, err := m.db.Where("mapping_id=?", userMap.MappingId).Cols(cols...).Update(&userMap)
+	return err
+}
+
+// GetCaseByID 获取案场
+func (m *CustomerDAO) GetCaseByID(caseID string) (*model.SysCase, error) {
+	if caseID == "" {
+		return nil, errors.New("获取案场信息失败")
+	}
+
+	cs := model.SysCase{}
+	has, err := m.db.Where("case_id=?", caseID).Get(&cs)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, nil
+	}
+
+	return &cs, nil
+}
+
+// GetUserByID 获取系统用户
+func (m *CustomerDAO) GetUserByID(userID string) (*model.SysUser, error) {
+	if userID == "" {
+		return nil, errors.New("获取相关人员信息失败")
+	}
+
+	user := model.SysUser{}
+	has, err := m.db.Where("user_id=?", userID).Get(&user)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, nil
+	}
+
+	return &user, nil
+}
+
+// GetUserByPhone 依据手机号获取人员信息
+func (m *CustomerDAO) GetUserByPhone(phone string) (*model.SysUser, error) {
+	user := model.SysUser{}
+
+	has, err := m.db.Where("phone=?", phone).Get(&user)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, nil
+	}
+
+	return &user, nil
+}
+
+// SaveCustomer 新增客户
+func (m *CustomerDAO) SaveCustomer(cust *model.TaCustomer) error {
+	cust.CustomerId = guid.NewGUIDString()
+	cust.CreateDate = time.Now().Local()
+	cust.Status = models.STATUS_NORMAL
+
+	_, err := m.db.Insert(&cust)
+	return err
+}

models/customer/types.go

@@ -0,0 +1,12 @@
+package customer
+
+import (
+	"spaceofcheng/services/models/model"
+)
+
+// CustWithWX 客户及微信相关信息
+type CustWithWX struct {
+	model.TaCustomer    `xorm:"extends"`
+	model.TaUserMapping `xorm:"extends"`
+	Points              int
+}

models/model/sys_case_user.go

@@ -5,14 +5,12 @@ import (
 )
 
 type SysCaseUser struct {
-	CaseUserId string `xorm:"not null pk VARCHAR(64)"`
-	OrgId      string `xorm:"VARCHAR(64)"`
-	CaseId     string `xorm:"VARCHAR(64)"`
-	UserName   string `xorm:"VARCHAR(50)"`
-	Tel        string `xorm:"VARCHAR(50)"`
-	UserType   string `xorm:"comment('案场管理员
-            咖啡师
-            消息收发员') VARCHAR(20)"`
+	CaseUserId string    `xorm:"not null pk VARCHAR(64)"`
+	OrgId      string    `xorm:"VARCHAR(64)"`
+	CaseId     string    `xorm:"VARCHAR(64)"`
+	UserName   string    `xorm:"VARCHAR(50)"`
+	Tel        string    `xorm:"VARCHAR(50)"`
+	UserType   string    `xorm:"comment('案场管理员 咖啡师 消息收发员') VARCHAR(20)"`
 	Status     int       `xorm:"SMALLINT(6)"`
 	CreateDate time.Time `xorm:"DATETIME"`
 }

models/model/sys_wechat_conf.go

@@ -3,8 +3,7 @@ package model
 type SysWechatConf struct {
 	ConfId string `xorm:"VARCHAR(64)"`
 	OrgId  string `xorm:"VARCHAR(64)"`
-	Type   int    `xorm:"comment('wechat 微信公众号
-            mini 小程序') SMALLINT(6)"`
+	Type   int    `xorm:"comment('wechat 微信公众号  mini 小程序') SMALLINT(6)"`
 	Appid  string `xorm:"VARCHAR(50)"`
 	Secret string `xorm:"VARCHAR(50)"`
 	Token  string `xorm:"VARCHAR(50)"`

models/model/ta_account_change.go

@@ -5,25 +5,19 @@ import (
 )
 
 type TaAccountChange struct {
-	DetailId   string `xorm:"not null pk VARCHAR(64)"`
-	AccountId  string `xorm:"VARCHAR(64)"`
-	UserId     string `xorm:"VARCHAR(64)"`
-	UserName   string `xorm:"VARCHAR(50)"`
-	OrgId      string `xorm:"VARCHAR(64)"`
-	CaseId     string `xorm:"VARCHAR(64)"`
-	ChangeType string `xorm:"comment('integral 积分
-            amount 城币') VARCHAR(20)"`
-	ChangeSource string `xorm:"comment('vip vip卡充值
-            orders 订单消费
-            register 注册
-            perfect 完善资料
-            recommend 推荐') VARCHAR(20)"`
-	SourceId   string  `xorm:"VARCHAR(64)"`
-	SourceName string  `xorm:"VARCHAR(255)"`
-	Amount     float32 `xorm:"FLOAT(8,2)"`
-	FloatType  string  `xorm:"comment('+
-            -') VARCHAR(5)"`
-	CreateDate time.Time `xorm:"DATETIME"`
-	CreateUser string    `xorm:"VARCHAR(64)"`
-	Status     int       `xorm:"SMALLINT(6)"`
+	DetailId     string    `xorm:"not null pk VARCHAR(64)"`
+	AccountId    string    `xorm:"VARCHAR(64)"`
+	UserId       string    `xorm:"VARCHAR(64)"`
+	UserName     string    `xorm:"VARCHAR(50)"`
+	OrgId        string    `xorm:"VARCHAR(64)"`
+	CaseId       string    `xorm:"VARCHAR(64)"`
+	ChangeType   string    `xorm:"comment('integral 积分  amount 城币') VARCHAR(20)"`
+	ChangeSource string    `xorm:"comment('vip vip卡充值  orders 订单消费  register 注册  perfect 完善资料  recommend 推荐') VARCHAR(20)"`
+	SourceId     string    `xorm:"VARCHAR(64)"`
+	SourceName   string    `xorm:"VARCHAR(255)"`
+	Amount       float32   `xorm:"FLOAT(8,2)"`
+	FloatType    string    `xorm:"comment('+  -') VARCHAR(5)"`
+	CreateDate   time.Time `xorm:"DATETIME"`
+	CreateUser   string    `xorm:"VARCHAR(64)"`
+	Status       int       `xorm:"SMALLINT(6)"`
 }

models/model/ta_cms_case_image.go

@@ -5,7 +5,6 @@ type TaCmsCaseImage struct {
 	CmsCaseId      string `xorm:"VARCHAR(64)"`
 	CaseImageUrl   string `xorm:"TEXT"`
 	Status         int    `xorm:"SMALLINT(6)"`
-	ImageType      string `xorm:"comment('cover：封面
-            detail：详情') VARCHAR(32)"`
-	Sort int `xorm:"INT(11)"`
+	ImageType      string `xorm:"comment('cover：封面  detail：详情') VARCHAR(32)"`
+	Sort           int    `xorm:"INT(11)"`
 }

models/model/ta_cms_location.go

@@ -1,6 +1,6 @@
 package model
 
 type TaCmsLocation struct {
-	LocationId string `xorm:"VARCHAR(64)"`
-	NewsId     string `xorm:"VARCHAR(64)"`
+	LocationId string `xorm:"not null pk VARCHAR(64)"`
+	NewsId     string `xorm:"not null pk VARCHAR(64)"`
 }

models/model/ta_customer.go

@@ -17,4 +17,5 @@ type TaCustomer struct {
 	RecommendName string    `xorm:"VARCHAR(50)"`
 	CreateDate    time.Time `xorm:"DATETIME"`
 	Status        int       `xorm:"SMALLINT(6)"`
+	UserId        string    `xorm:"VARCHAR(64)"`
 }

models/model/ta_experience_card.go

@@ -1,25 +0,0 @@
-package model
-
-import (
-	"time"
-)
-
-type TaExperienceCard struct {
-	CardId     string    `xorm:"not null pk VARCHAR(64)"`
-	CardTypeId string    `xorm:"VARCHAR(64)"`
-	SendType   string    `xorm:"comment('0案场 1渠道') VARCHAR(32)"`
-	VideoUrl   string    `xorm:"TEXT"`
-	CoverUrl   string    `xorm:"TEXT"`
-	Price      float32   `xorm:"FLOAT(64)"`
-	StartDate  time.Time `xorm:"DATETIME"`
-	EndDate    time.Time `xorm:"DATETIME"`
-	TotalCount int       `xorm:"INT(11)"`
-	SentCount  int       `xorm:"INT(11)"`
-	UsedCount  int       `xorm:"INT(11)"`
-	Status     string    `xorm:"comment('private未发布 public发布 over过期') VARCHAR(32)"`
-	CaseId     string    `xorm:"VARCHAR(64)"`
-	OrgId      string    `xorm:"VARCHAR(64)"`
-	CreateDate time.Time `xorm:"DATETIME"`
-	CreateUser string    `xorm:"VARCHAR(64)"`
-	IsOver     int       `xorm:"TINYINT(1)"`
-}

models/model/ta_goods_orders.go

@@ -5,25 +5,24 @@ import (
 )
 
 type TaGoodsOrders struct {
-	OrdersId   string    `xorm:"not null pk VARCHAR(64)"`
-	OrdersNo   string    `xorm:"VARCHAR(32)"`
-	OrgId      string    `xorm:"VARCHAR(64)"`
-	CaseId     string    `xorm:"VARCHAR(64)"`
-	AreaId     string    `xorm:"VARCHAR(64)"`
-	AreaName   string    `xorm:"VARCHAR(50)"`
-	TableId    string    `xorm:"VARCHAR(64)"`
-	TableName  string    `xorm:"VARCHAR(50)"`
-	Amount     string    `xorm:"DECIMAL(8,2)"`
-	CreateDate time.Time `xorm:"DATETIME"`
-	Status     int       `xorm:"SMALLINT(6)"`
-	PayType    int       `xorm:"comment('vip VIP卡城币抵用
-            coupon 优惠券抵用') SMALLINT(6)"`
-	UserType     int    `xorm:"SMALLINT(6)"`
-	UserId       string `xorm:"VARCHAR(64)"`
-	UserName     string `xorm:"VARCHAR(50)"`
-	OrdersNum    int    `xorm:"INT(11)"`
-	Remark       string `xorm:"TEXT"`
-	IsPay        int    `xorm:"TINYINT(1)"`
-	ActualAmount string `xorm:"DECIMAL(8,2)"`
-	CouponAmount string `xorm:"DECIMAL(8,2)"`
+	OrdersId     string    `xorm:"not null pk VARCHAR(64)"`
+	OrdersNo     string    `xorm:"VARCHAR(32)"`
+	OrgId        string    `xorm:"VARCHAR(64)"`
+	CaseId       string    `xorm:"VARCHAR(64)"`
+	AreaId       string    `xorm:"VARCHAR(64)"`
+	AreaName     string    `xorm:"VARCHAR(50)"`
+	TableId      string    `xorm:"VARCHAR(64)"`
+	TableName    string    `xorm:"VARCHAR(50)"`
+	Amount       string    `xorm:"DECIMAL(8,2)"`
+	CreateDate   time.Time `xorm:"DATETIME"`
+	Status       int       `xorm:"SMALLINT(6)"`
+	PayType      int       `xorm:"comment('vip VIP卡城币抵用 coupon 优惠券抵用') SMALLINT(6)"`
+	UserType     int       `xorm:"SMALLINT(6)"`
+	UserId       string    `xorm:"VARCHAR(64)"`
+	UserName     string    `xorm:"VARCHAR(50)"`
+	OrdersNum    int       `xorm:"INT(11)"`
+	Remark       string    `xorm:"TEXT"`
+	IsPay        int       `xorm:"TINYINT(1)"`
+	ActualAmount string    `xorm:"DECIMAL(8,2)"`
+	CouponAmount string    `xorm:"DECIMAL(8,2)"`
 }

models/model/ta_user_mapping.go

@@ -1,12 +1,10 @@
 package model
 
 type TaUserMapping struct {
-	MappingId string `xorm:"not null pk VARCHAR(64)"`
-	UserId    string `xorm:"VARCHAR(64)"`
-	UserType  string `xorm:"comment('customer 为会员
-            user 为后台用户') VARCHAR(50)"`
-	AccountType string `xorm:"comment('wechat 微信公众号
-            mini 小程序') VARCHAR(50)"`
+	MappingId   string `xorm:"not null pk VARCHAR(64)"`
+	UserId      string `xorm:"VARCHAR(64)"`
+	UserType    string `xorm:"comment('customer 为会员  user 为后台用户') VARCHAR(50)"`
+	AccountType string `xorm:"comment('wechat 微信公众号 mini 小程序') VARCHAR(50)"`
 	Openid      string `xorm:"VARCHAR(200)"`
 	Uuid        string `xorm:"VARCHAR(200)"`
 	AccountInfo string `xorm:"TEXT"`

models/sys.go

@@ -1,8 +1,12 @@
 package models
 
 import (
+	"errors"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 
+	"github.com/yl10/kit/guid"
+
 	"github.com/go-xorm/xorm"
 )
 
@@ -19,3 +23,119 @@ func NewSysDAO(ctx *utils.Context) *SysDAO {
 		db:  ctx.DB,
 	}
 }
+
+// GetPureUserInfo 获取用户基本信息
+func (m *SysDAO) GetPureUserInfo(id string) (*model.SysUser, error) {
+	user := model.SysUser{}
+
+	has, err := m.db.Where("user_id=?", id).Get(&user)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, errors.New("没有查询到 ID (" + id + ") 对应的用户")
+	}
+
+	if user.Status != STATUS_NORMAL {
+		return nil, errors.New("用户状态不正确")
+	}
+
+	return &user, nil
+}
+
+// GetUserMenu 获取用户菜单
+func (m *SysDAO) GetUserMenu(userID string) ([]model.SysMenu, error) {
+	query := `
+		SELECT t.*
+		FROM sys_menu t
+			JOIN sys_user_menu s ON t.menu_id = s.menu_id
+		WHERE s.user_id = ?
+			AND t.status = ?
+		ORDER BY t.order_no ASC
+	`
+
+	var menus []model.SysMenu
+	if err := m.db.SQL(query, userID, STATUS_NORMAL).Find(&menus); err != nil {
+		return nil, err
+	}
+
+	return menus, nil
+}
+
+// GetUserCase 获取用户案场
+func (m *SysDAO) GetUserCase(userID string) ([]model.SysUserCase, error) {
+	query := `
+		SELECT t.*
+		FROM sys_user_case t
+		WHERE s.user_id = ?
+			AND t.status = ?
+	`
+
+	var cases []model.SysUserCase
+	if err := m.db.SQL(query, userID, STATUS_NORMAL).Find(&cases); err != nil {
+		return nil, err
+	}
+
+	return cases, nil
+}
+
+// GetOrg 获取机构信息
+func (m *SysDAO) GetOrg(orgID string) (*model.SysOrg, error) {
+	var org model.SysOrg
+	has, err := m.db.Where("org_id=?", orgID).And("status=?", STATUS_NORMAL).Get(&org)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, errors.New("没有查询到机构信息")
+	}
+
+	return &org, nil
+}
+
+// GetCustomer 获取用户信息
+// 暂时无法解决 一个用户 多组织架构的问题
+func (m *SysDAO) GetCustomer(custID string) (*model.TaCustomer, error) {
+	var cust model.TaCustomer
+
+	has, err := m.db.Where("customer_id=?", custID).And("status=?", STATUS_NORMAL).Get(&cust)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, errors.New("没有查询到客户 (id: " + custID + ") 信息")
+	}
+
+	return &cust, nil
+}
+
+// GetUserMappingByOpenID 获取用户映射信息
+func (m *SysDAO) GetUserMappingByOpenID(openID string) ([]model.TaUserMapping, error) {
+	var users []model.TaUserMapping
+
+	err := m.db.Where("openid=?", openID).Find(&users)
+	return users, err
+}
+
+// UpdateUserMapping 保存用户映射信息
+func (m *SysDAO) UpdateUserMapping(user *model.TaUserMapping) error {
+	// 如果没有映射ID, 则新增记录
+	if user.MappingId == "" {
+		user.MappingId = guid.NewGUIDString()
+		_, err := m.db.Insert(user)
+		return err
+	}
+
+	// 否则更新记录
+	cols := []string{
+		"account_info",
+	}
+	_, err := m.db.Cols(cols...).
+		Where("account_type=?", user.AccountType).
+		And("openid=?", user.Openid).
+		Update(&user)
+	return err
+}

models/system/user.go

@@ -1,6 +1,7 @@
 package system
 
 import (
+	"errors"
 	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
@@ -328,3 +329,45 @@ func (m *UserDAO) GetUserCustomer(userid string, page int, pageSize int) ([]mode
 	err := m.db.Where("status>"+strconv.Itoa(models.STATUS_DEL)).And("recommend_id=?", userid).Limit(pageSize, page*pageSize).Desc("create_date").Find(&customers)
 	return customers, err
 }
+
+// GetUserByName 依据账户获取人员信息
+func (m *UserDAO) GetUserByName(userName string) (*model.SysUser, error) {
+	user := model.SysUser{}
+
+	has, err := m.db.Where("user_name=?", userName).Get(&user)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, nil
+	}
+
+	return &user, nil
+}
+
+// GetUserByPhone 依据手机号获取人员信息
+func (m *UserDAO) GetUserByPhone(phone string) (*model.SysUser, error) {
+	user := model.SysUser{}
+
+	has, err := m.db.Where("phone=?", phone).Get(&user)
+	if err != nil {
+		return nil, err
+	}
+
+	if !has {
+		return nil, nil
+	}
+
+	return &user, nil
+}
+
+// UpdateUserMapping 更新用户映射
+func (m *UserDAO) UpdateUserMapping(userMap *model.TaUserMapping, cols []string) error {
+	if userMap.MappingId == "" {
+		return errors.New("用户映射信息不存在")
+	}
+
+	_, err := m.db.Where("mapping_id=?", userMap.MappingId).Cols(cols...).Update(&userMap)
+	return err
+}

routers/common.go

@@ -2,6 +2,7 @@ package routers
 
 import (
 	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/goods"
 	"spaceofcheng/services/controllers/message"
 	"spaceofcheng/services/controllers/user"
@@ -13,53 +14,61 @@ func getCommonRoutes() beego.LinkNamespace {
 	prefix := beego.AppConfig.String("api::common")
 
 	return beego.NSNamespace(prefix,
-		beego.NSRouter("/goodstype", &goods.GoodsController{}, "get:GetGoodsType"),
-		beego.NSRouter("/goodstype/:typeid", &goods.GoodsController{}, "get:GetGoodsTypeByID"),
-		beego.NSRouter("/goodstype", &goods.GoodsController{}, "post:SaveGoodsType"),
-		beego.NSRouter("/goodstype", &goods.GoodsController{}, "put:SaveGoodsType"),
-		beego.NSRouter("/goodstype/:typeid", &goods.GoodsController{}, "delete:DelGoodsType"),
+		// 商品分类
+		beego.NSRouter("/type/goods", &goods.GoodsController{}, "get:GetGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "get:GetGoodsTypeByID"),
+		beego.NSRouter("/type/goods", &goods.GoodsController{}, "post:SaveGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "put:SaveGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "delete:DelGoodsType"),
 
-		beego.NSRouter("/goodspec", &goods.GoodsController{}, "get:GetGoodsSpec"),
-		beego.NSRouter("/goodspec/:specid", &goods.GoodsController{}, "get:GetGoodsSpecByID"),
-		beego.NSRouter("/goodspec", &goods.GoodsController{}, "post:SaveGoodsSpec"),
-		beego.NSRouter("/goodspec", &goods.GoodsController{}, "put:SaveGoodsSpec"),
-		beego.NSRouter("/goodspec/:specid", &goods.GoodsController{}, "delete:DelGoodsSpec"),
+		// 商品规格
+		beego.NSRouter("/spec/goods", &goods.GoodsController{}, "get:GetGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "get:GetGoodsSpecByID"),
+		beego.NSRouter("/spec/goods", &goods.GoodsController{}, "post:SaveGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "put:SaveGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "delete:DelGoodsSpec"),
 
+		// 系统用户
 		beego.NSRouter("/user", &user.UserController{}, "get:GetUserList"),
 		beego.NSRouter("/user/:userid", &user.UserController{}, "get:GetUserByID"),
+		beego.NSRouter("/user/:userid/password", &user.UserController{}, "put:UpdatePassword"),
+		beego.NSRouter("/user/password/reset", &user.UserController{}, "put:ResetPassword"),
+		beego.NSRouter("/signout", &user.UserController{}, "post:SignOut"),
 
-		beego.NSRouter("/pwd/reset", &user.UserController{}, "put:ResetPassword"),
-		beego.NSRouter("/pwd/update", &user.UserController{}, "put:UpdatePassword"),
+		// cms 位置
+		beego.NSRouter("/cms/location", &message.MessageController{}, "get:GetLocations"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "get:GetLocationById"),
+		beego.NSRouter("/cms/location", &message.MessageController{}, "post:SaveLocation"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "put:SaveLocation"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "delete:DelLocation"),
 
-		beego.NSRouter("/location", &message.MessageController{}, "get:GetLocations"),
-		beego.NSRouter("/location/:locationid", &message.MessageController{}, "get:GetLocationById"),
-		beego.NSRouter("/location", &message.MessageController{}, "post:SaveLocation"),
-		beego.NSRouter("/location", &message.MessageController{}, "put:SaveLocation"),
-		beego.NSRouter("/location/:locationid", &message.MessageController{}, "delete:DelLocation"),
+		// cms
+		beego.NSRouter("/cms/info", &message.MessageController{}, "get:GetCmsInfoList"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "get:GetCmsInfoByID"),
+		beego.NSRouter("/cms/info", &message.MessageController{}, "post:SaveCmsInfo"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "put:SaveCmsInfo"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "delete:DelCmsInfo"),
 
-		beego.NSRouter("/cmsinfo", &message.MessageController{}, "get:GetCmsInfoList"),
-		beego.NSRouter("/cmsinfo/:infoid", &message.MessageController{}, "get:GetCmsInfoByID"),
-		beego.NSRouter("/cmsinfo", &message.MessageController{}, "post:SaveCmsInfo"),
-		beego.NSRouter("/cmsinfo", &message.MessageController{}, "put:SaveCmsInfo"),
-		beego.NSRouter("/cmsinfo/:infoid", &message.MessageController{}, "delete:DelCmsInfo"),
+		// cms 图片
+		beego.NSRouter("/cms/image", &message.MessageController{}, "get:GetImgList"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "get:GetImgByID"),
+		beego.NSRouter("/cms/image", &message.MessageController{}, "post:SaveImage"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "put:SaveImage"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "delete:DelImg"),
 
-		beego.NSRouter("/cmsimg", &message.MessageController{}, "get:GetImgList"),
-		beego.NSRouter("/cmsimg/:imgid", &message.MessageController{}, "get:GetImgByID"),
-		beego.NSRouter("/cmsimg", &message.MessageController{}, "post:SaveImage"),
-		beego.NSRouter("/cmsimg", &message.MessageController{}, "put:SaveImage"),
-		beego.NSRouter("/cmsimg/:imgid", &message.MessageController{}, "delete:DelImg"),
+		// cms 消息
+		beego.NSRouter("/cms/news", &message.MessageController{}, "get:GetNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "get:GetNewsByID"),
+		beego.NSRouter("/cms/news", &message.MessageController{}, "post:SaveNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "put:SaveNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "delete:DelNews"),
 
-		beego.NSRouter("/news", &message.MessageController{}, "get:GetNews"),
-		beego.NSRouter("/news/:newsid", &message.MessageController{}, "get:GetNewsByID"),
-		beego.NSRouter("/news", &message.MessageController{}, "post:SaveNews"),
-		beego.NSRouter("/news", &message.MessageController{}, "put:SaveNews"),
-		beego.NSRouter("/news/:newsid", &message.MessageController{}, "delete:DelNews"),
-
-		beego.NSRouter("/cmscase", &message.MessageController{}, "get:GetCmsCase"),
-		beego.NSRouter("/cmscase/:cmscaseid", &message.MessageController{}, "get:GetCmsCaseByID"),
-		beego.NSRouter("/cmscase", &message.MessageController{}, "post:SaveCmsCase"),
-		beego.NSRouter("/cmscase", &message.MessageController{}, "put:SaveCmsCase"),
-		beego.NSRouter("/cmscase/:cmscaseid", &message.MessageController{}, "delete:DelCmsCase"),
+		// cms 案场
+		beego.NSRouter("/cms/case", &message.MessageController{}, "get:GetCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "get:GetCmsCaseByID"),
+		beego.NSRouter("/cms/case", &message.MessageController{}, "post:SaveCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "put:SaveCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "delete:DelCmsCase"),
 
 		beego.NSRouter("/caseuser", &message.MessageController{}, "get:GetCaseUserByCase"),
 		beego.NSRouter("/caseuserbytype", &message.MessageController{}, "get:GetCaseUserByType"),
@@ -68,6 +77,10 @@ func getCommonRoutes() beego.LinkNamespace {
 		beego.NSRouter("/caseuser", &message.MessageController{}, "put:SaveCaseUser"),
 		beego.NSRouter("/caseuser/:userid", &message.MessageController{}, "delete:DelCaseUser"),
 
+		// 文件
 		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
+
+		// 会员
+		beego.NSRouter("/customer", &customer.CustomerController{}, "get:CustWXList"),
 	)
 }

routers/guest.go

@@ -1,7 +1,10 @@
 package routers
 
 import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/controllers/customer"
 	"spaceofcheng/services/controllers/message"
+	"spaceofcheng/services/controllers/user"
 
 	"github.com/astaxie/beego"
 )
@@ -10,9 +13,21 @@ func getGuestRoutes() beego.LinkNamespace {
 	prefix := beego.AppConfig.String("api::guest")
 
 	return beego.NSNamespace(prefix,
-		beego.NSRouter("/cmsinfo", &message.MessageController{}, "get:GetCmsInfoByLocation"),
-		beego.NSRouter("/cmsimg", &message.MessageController{}, "get:GetImgByLocation"),
-		beego.NSRouter("/cmsnews", &message.MessageController{}, "get:GetNewsByLocation"),
-		beego.NSRouter("/cmscase", &message.MessageController{}, "get:GetCmsCaseList"),
+		// cms
+		beego.NSRouter("/cms/info", &message.MessageController{}, "get:GetCmsInfoByLocation"),
+		beego.NSRouter("/cms/img", &message.MessageController{}, "get:GetImgByLocation"),
+		beego.NSRouter("/cms/news", &message.MessageController{}, "get:GetNewsByLocation"),
+		beego.NSRouter("/cms/case", &message.MessageController{}, "get:GetCmsCaseList"),
+
+		// 验证码 获取, 校验
+		beego.NSRouter("/captcha", &controllers.BaseController{}, "get:SendCaptcha"),
+		beego.NSRouter("/captcha", &controllers.BaseController{}, "post:ValidCaptcha"),
+
+		// 微信 登录, 注册
+		beego.NSRouter("/wxsignin", &customer.CustomerController{}, "post:SignIn"),
+		beego.NSRouter("/wxsignup", &customer.CustomerController{}, "post:SignUp"),
+
+		// 登录
+		beego.NSRouter("/signin", &user.UserController{}, "post:SignIn"),
 	)
 }

routers/router.go

@@ -23,6 +23,9 @@ func init() {
 		// 通用需要鉴权路由
 		getCommonRoutes(),
 
+		// 微信路由
+		getWechatRoutes(),
+
 		// 不需要鉴权的路由
 		getGuestRoutes(),
 	)

routers/wechat.go

@@ -1 +1,79 @@
 package routers
+
+import (
+	"spaceofcheng/services/controllers"
+	"spaceofcheng/services/controllers/customer"
+	"spaceofcheng/services/controllers/goods"
+	"spaceofcheng/services/controllers/message"
+	"spaceofcheng/services/controllers/user"
+
+	"github.com/astaxie/beego"
+)
+
+func getWechatRoutes() beego.LinkNamespace {
+	prefix := beego.AppConfig.String("api::wechat")
+
+	return beego.NSNamespace(prefix,
+		// 商品分类
+		beego.NSRouter("/type/goods", &goods.GoodsController{}, "get:GetGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "get:GetGoodsTypeByID"),
+		beego.NSRouter("/type/goods", &goods.GoodsController{}, "post:SaveGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "put:SaveGoodsType"),
+		beego.NSRouter("/type/goods/:typeid", &goods.GoodsController{}, "delete:DelGoodsType"),
+
+		// 商品规格
+		beego.NSRouter("/spec/goods", &goods.GoodsController{}, "get:GetGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "get:GetGoodsSpecByID"),
+		beego.NSRouter("/spec/goods", &goods.GoodsController{}, "post:SaveGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "put:SaveGoodsSpec"),
+		beego.NSRouter("/spec/goods/:specid", &goods.GoodsController{}, "delete:DelGoodsSpec"),
+
+		// 系统用户
+		beego.NSRouter("/user", &user.UserController{}, "get:GetUserList"),
+		beego.NSRouter("/user/:userid", &user.UserController{}, "get:GetUserByID"),
+		beego.NSRouter("/user/:userid/password", &user.UserController{}, "put:UpdatePassword"),
+		beego.NSRouter("/user/password/reset", &user.UserController{}, "put:ResetPassword"),
+		beego.NSRouter("/signout", &user.UserController{}, "post:SignOut"),
+
+		// cms 位置
+		beego.NSRouter("/cms/location", &message.MessageController{}, "get:GetLocations"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "get:GetLocationById"),
+		beego.NSRouter("/cms/location", &message.MessageController{}, "post:SaveLocation"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "put:SaveLocation"),
+		beego.NSRouter("/cms/location/:locationid", &message.MessageController{}, "delete:DelLocation"),
+
+		// cms
+		beego.NSRouter("/cms/info", &message.MessageController{}, "get:GetCmsInfoList"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "get:GetCmsInfoByID"),
+		beego.NSRouter("/cms/info", &message.MessageController{}, "post:SaveCmsInfo"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "put:SaveCmsInfo"),
+		beego.NSRouter("/cms/info/:infoid", &message.MessageController{}, "delete:DelCmsInfo"),
+
+		// cms 图片
+		beego.NSRouter("/cms/image", &message.MessageController{}, "get:GetImgList"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "get:GetImgByID"),
+		beego.NSRouter("/cms/image", &message.MessageController{}, "post:SaveImage"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "put:SaveImage"),
+		beego.NSRouter("/cms/image/:imgid", &message.MessageController{}, "delete:DelImg"),
+
+		// cms 消息
+		beego.NSRouter("/cms/news", &message.MessageController{}, "get:GetNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "get:GetNewsByID"),
+		beego.NSRouter("/cms/news", &message.MessageController{}, "post:SaveNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "put:SaveNews"),
+		beego.NSRouter("/cms/news/:newsid", &message.MessageController{}, "delete:DelNews"),
+
+		// cms 案场
+		beego.NSRouter("/cms/case", &message.MessageController{}, "get:GetCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "get:GetCmsCaseByID"),
+		beego.NSRouter("/cms/case", &message.MessageController{}, "post:SaveCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "put:SaveCmsCase"),
+		beego.NSRouter("/cms/case/:cmscaseid", &message.MessageController{}, "delete:DelCmsCase"),
+
+		// 文件
+		beego.NSRouter("/file", &controllers.BaseController{}, "post:FileUpload"),
+
+		// 会员
+		beego.NSRouter("/customer", &customer.CustomerController{}, "get:CustWXList"),
+	)
+}

service/customer/customer.go

@@ -0,0 +1,238 @@
+package customer
+
+import (
+	"errors"
+	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/customer"
+	"spaceofcheng/services/models/model"
+	"spaceofcheng/services/service/events"
+	"spaceofcheng/services/utils"
+	"strconv"
+)
+
+// CustomerServ 系统处理
+type CustomerServ struct {
+	ctx *utils.Context
+	dao *customer.CustomerDAO
+}
+
+// NewCustomerServ 初始化
+func NewCustomerServ(ctx *utils.Context) *CustomerServ {
+	return &CustomerServ{
+		ctx: ctx,
+		dao: customer.NewCustomerDAO(ctx),
+	}
+}
+
+// GetCustWithWXList 获取客户列表
+func (s *CustomerServ) GetCustWithWXList(phone string, page ...int) ([]customer.CustWithWX, int64, error) {
+	return s.dao.CustWithWXList(phone, page...)
+}
+
+// GetCustWithWXByID 获取客户列表
+func (s *CustomerServ) GetCustWithWXByID(custID string) (*customer.CustWithWX, error) {
+	cust, err := s.dao.GetCustWithWXByID(custID)
+	if err != nil {
+		return nil, err
+	}
+
+	if cust.Status != models.STATUS_NORMAL {
+		return nil, errors.New("用户状态异常")
+	}
+
+	return cust, nil
+}
+
+// GetCustUserByID 获取用户信息(自定义内容)
+func (s *CustomerServ) GetCustUserByID(userID string) (*UserProfile, error) {
+	user, err := s.dao.GetUserByID(userID)
+	if err != nil {
+		return nil, err
+	}
+
+	if user.Status != models.STATUS_NORMAL {
+		return nil, errors.New("用户状态异常")
+	}
+
+	userProfile := UserProfile{
+		UserId:     user.UserId,
+		UserName:   user.UserName,
+		RealName:   user.RealName,
+		Sex:        user.Sex,
+		WorkNo:     user.WorkNo,
+		Email:      user.Email,
+		Phone:      user.Phone,
+		Headimgurl: user.Headimgurl,
+	}
+
+	return &userProfile, nil
+}
+
+// BindWechatUser 绑定微信用户
+func (s *CustomerServ) BindWechatUser(userMap *model.TaUserMapping, phone string) (*model.TaCustomer, error) {
+	user, err := s.dao.GetUserByPhone(phone)
+	if err != nil {
+		return nil, err
+	}
+
+	if user == nil || user.Status == models.STATUS_DEL {
+		return nil, errors.New("当前手机号未绑定管理员")
+	}
+
+	cust, err := s.dao.GetCustomerByPhone(phone)
+	if err != nil {
+		return nil, err
+	}
+
+	if cust == nil {
+		wxInfoRaw := s.ctx.Get("wxInfo")
+		if wxInfoRaw == nil {
+			return nil, errors.New("请确定使用微信端登录")
+		}
+
+		wxInfo := wxInfoRaw.(map[string]interface{})
+		newCust, err := s.SaveNewCustomer(wxInfo, "", "", user.UserId)
+		if err != nil {
+			return nil, err
+		}
+		cust = newCust
+	}
+
+	if cust.Status != models.STATUS_NORMAL {
+		return nil, errors.New("用户状态不正确")
+	}
+
+	// triggerRegiteEvent 触发注册事件
+	utils.EmitEvent(events.EvtRegiste, *cust)
+
+	if cust.CustomerId == userMap.UserId {
+		return cust, nil
+	}
+
+	// 更新用户映射信息
+	userMap.UserId = cust.CustomerId
+	if err := s.dao.UpdateUserMapping(userMap, []string{"user_id"}); err != nil {
+		utils.LogError("更新用户映射信息失败:" + err.Error())
+		return nil, errors.New("映射用户信息失败")
+	}
+
+	return cust, nil
+}
+
+// BindWechatCust 绑定微信用户
+func (s *CustomerServ) BindWechatCust(userMap *model.TaUserMapping, phone, caseID, userID string) (*model.TaCustomer, error) {
+	cust, err := s.dao.GetCustomerByPhone(phone)
+	if err != nil {
+		return nil, err
+	}
+
+	// 用户不存在, 则新增
+	if cust == nil {
+		wxInfoRaw := s.ctx.Get("wxInfo")
+		if wxInfoRaw == nil {
+			return nil, errors.New("请确定使用微信端登录")
+		}
+
+		wxInfo := wxInfoRaw.(map[string]interface{})
+		newCust, err := s.SaveNewCustomer(wxInfo, caseID, userID, "")
+		if err != nil {
+			return nil, err
+		}
+
+		cust = newCust
+	}
+
+	if cust.Status != models.STATUS_NORMAL {
+		return nil, errors.New("用户状态不正确")
+	}
+
+	// triggerRegiteEvent 触发注册事件
+	utils.EmitEvent(events.EvtRegiste, *cust)
+
+	if cust.CustomerId == userMap.UserId {
+		return cust, nil
+	}
+
+	// 更新用户映射信息
+	userMap.UserId = cust.CustomerId
+	if err := s.dao.UpdateUserMapping(userMap, []string{"user_id"}); err != nil {
+		utils.LogError("更新用户映射信息失败:" + err.Error())
+		return nil, errors.New("映射用户信息失败")
+	}
+
+	return cust, nil
+}
+
+// SaveNewCustomer 新增客户
+func (s *CustomerServ) SaveNewCustomer(wxInfo map[string]interface{}, caseID, arID, userID string) (*model.TaCustomer, error) {
+	if caseID == "" && arID == "" && userID == "" {
+		return nil, errors.New("新增信息失败, 无法确认人员类型")
+	}
+
+	// 微信相关字段
+	nickyName := wxInfo["nickname"].(string)
+	sex := wxInfo["sex"].(string)
+	headimgurl := wxInfo["headimgurl"].(string)
+
+	sexInt, _ := strconv.Atoi(sex)
+	if sexInt == 0 {
+		sexInt = 1 // 默认男性
+	}
+
+	cust := model.TaCustomer{
+		CustomerName: nickyName,
+		Name:         nickyName,
+		Sex:          sexInt,
+		Headimgurl:   headimgurl,
+	}
+
+	// 校验案场信息
+	if caseID != "" {
+		cs, err := s.dao.GetCaseByID(caseID)
+		if err != nil {
+			return nil, err
+		}
+
+		if cs == nil || cs.Status == models.STATUS_DEL {
+			return nil, errors.New("系统无该推荐案场")
+		}
+
+		cust.OrgId = cs.OrgId
+		cust.RecommendCase = cs.CaseId
+	}
+
+	// 校验推荐人
+	if arID != "" {
+		ar, err := s.dao.GetUserByID(arID)
+		if err != nil {
+			return nil, err
+		}
+
+		if ar == nil || ar.Status == models.STATUS_DEL {
+			return nil, errors.New("系统无该推荐人")
+		}
+
+		cust.OrgId = ar.OrgId
+		cust.RecommendId = ar.UserId
+		cust.RecommendName = ar.RealName
+	}
+
+	// 系统用户
+	if userID != "" {
+		user, err := s.dao.GetUserByID(userID)
+		if err != nil {
+			return nil, err
+		}
+
+		if user != nil && user.Status != models.STATUS_DEL {
+			cust.UserId = userID
+		}
+	}
+
+	if err := s.dao.SaveCustomer(&cust); err != nil {
+		utils.LogError("更新客户信息失败: " + err.Error())
+		return nil, errors.New("更新客户信息失败")
+	}
+
+	return &cust, nil
+}

service/customer/types.go

@@ -0,0 +1,16 @@
+package customer
+
+type UserProfile struct {
+	UserId     string
+	UserName   string
+	RealName   string
+	Sex        int
+	WorkNo     string
+	Email      string
+	Phone      string
+	Headimgurl string
+}
+
+func (t *UserProfile) TableName() string {
+	return "sys_user"
+}

service/events/events.go

@@ -54,7 +54,7 @@ func getAllEvents() (map[string][]string, error) {
 }
 
 var tsAction = func(e tinyevent.Event) error {
-	str := string(e.Payload)
+	str := e.Payload.(string)
 	fmt.Println(str)
 	return nil
 }

service/sys.go

@@ -1,7 +1,9 @@
 package service
 
 import (
+	"encoding/json"
 	"spaceofcheng/services/models"
+	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/utils"
 )
 
@@ -23,6 +25,101 @@ func NewSysServ(ctx *utils.Context) *SysServ {
 	}
 }
 
-func (s *SysServ) GetUserByID(id string) error {
+// SetUserProfile 设置用户信息
+func (s *SysServ) SetUserProfile(id string) error {
+	user, err := s.dao.GetPureUserInfo(id)
+	if err != nil {
+		return utils.LogError("获取用户基本信息失败: " + err.Error())
+	}
+	s.ctx.Set("user", *user)
+
+	cases, err := s.dao.GetUserCase(id)
+	if err != nil {
+		return utils.LogError("获取用户案场信息失败: " + err.Error())
+	}
+	s.ctx.Set("cases", cases)
+
+	found := false
+	for _, cs := range cases {
+		if cs.IsBelong == models.BOOL_TRUE {
+			found = true
+			s.ctx.Set("currentCase", cs)
+		}
+	}
+
+	if !found {
+		return utils.LogError("用户没有设置默认案场")
+	}
+
+	org, err := s.dao.GetOrg(user.OrgId)
+	if err != nil {
+		return utils.LogError("获取用户组织信息失败: " + err.Error())
+	}
+	s.ctx.Set("org", *org)
+
+	return nil
+}
+
+// SetCustomer 设置客户信息
+func (s *SysServ) SetCustomer(id string) error {
+	cust, err := s.dao.GetCustomer(id)
+	if err != nil {
+		return utils.LogError("获取客户基本信息失败: " + err.Error())
+	}
+
+	s.ctx.Set("customer", *cust)
 	return nil
 }
+
+// CheckWechatUserMapping 校验并更新客户信息
+// 如果不存在, 则插入新数据
+func (s *SysServ) CheckWechatUserMapping(user map[string]interface{}) (*model.TaUserMapping, error) {
+	openID := user["openid"].(string)
+
+	uuID := ""
+	uuidRaw, ok := user["unionid"]
+	if ok {
+		uuID = uuidRaw.(string)
+	}
+
+	accountRaw, err := json.Marshal(user)
+	if err != nil {
+		return nil, err
+	}
+	account := string(accountRaw)
+
+	userMapping := model.TaUserMapping{
+		UserType:    models.USERMAP_CUSTOMER,
+		AccountType: models.ACCMAP_WECHAT,
+		Openid:      openID,
+		Uuid:        uuID,
+		AccountInfo: account,
+	}
+
+	// 查询数据库是否存在已有映射
+	userMapList, err := s.dao.GetUserMappingByOpenID(openID)
+	if err != nil {
+		return nil, err
+	}
+
+	// 如果存在
+	if len(userMapList) > 0 {
+		for _, um := range userMapList {
+			if userMapping.Openid == um.Openid &&
+				userMapping.AccountType == um.AccountType &&
+				userMapping.UserType == um.UserType {
+
+				// 存在的用户, 使用 ID 作为检查条件去更新
+				userMapping.MappingId = um.MappingId
+			}
+		}
+	}
+
+	// 更新数据库内容, 没有的话则插入
+	err = s.dao.UpdateUserMapping(&userMapping)
+	if err != nil {
+		return nil, err
+	}
+
+	return &userMapping, nil
+}

service/user.go

@@ -2,6 +2,7 @@ package service
 
 import (
 	"errors"
+	"spaceofcheng/services/models"
 	"spaceofcheng/services/models/model"
 	"spaceofcheng/services/models/system"
 	"spaceofcheng/services/utils"
@@ -9,11 +10,6 @@ import (
 	"github.com/yl10/kit/encrypt"
 )
 
-const (
-	USERTYPE_USER     = "user"
-	USERTYPE_CUSTOMER = "customer"
-)
-
 // UserServ 系统处理
 type UserServ struct {
 	ctx     *utils.Context
@@ -244,3 +240,25 @@ func (s *UserServ) GetUserCustomer(userid string, page int, pageSize int) ([]mod
 	customers, err := s.dao.GetUserCustomer(userid, page, pageSize)
 	return customers, err
 }
+
+// CheckUserSignIn 校验用户登录
+func (s *UserServ) CheckUserSignIn(userName, userPassword string) (*model.SysUser, error) {
+	user, err := s.dao.GetUserByName(userName)
+	if err != nil {
+		return nil, err
+	}
+
+	if user == nil {
+		return nil, errors.New("账户不存在")
+	}
+
+	if user.Status != models.STATUS_NORMAL {
+		return nil, errors.New("用户账户异常")
+	}
+
+	if !s.dao.ValidatePassword(user, userPassword) {
+		return nil, errors.New("用户密码不正确")
+	}
+
+	return user, nil
+}

utils/captcha.go

@@ -0,0 +1,99 @@
+package utils
+
+import (
+	"errors"
+	"math/rand"
+	"strconv"
+	"strings"
+	"time"
+)
+
+type cap struct {
+	Phone   string
+	Captcha string
+	Expire  time.Time
+}
+
+// CaptchaEngine 验证码引擎
+type CaptchaEngine struct {
+	capList map[string]cap
+}
+
+var capEngine *CaptchaEngine
+
+// NewCaptchaEngine 创建验证码引擎
+func NewCaptchaEngine() *CaptchaEngine {
+	return &CaptchaEngine{
+		capList: make(map[string]cap),
+	}
+}
+
+// SendCaptcha 发送验证码
+func SendCaptcha(phone string) error {
+	if phone == "" {
+		return errors.New("验证码发送错误: 没有手机号")
+	}
+
+	capEngine.SendCaptcha(phone)
+	return nil
+}
+
+// ValidCaptcha 校验 验证码
+func ValidCaptcha(phone, cap string) error {
+	if phone == "" {
+		return errors.New("验证码校验失败: 没有手机号")
+	}
+
+	return capEngine.ValidCaptcha(phone, cap)
+}
+
+// Random 获取随机数
+// 连续调用会有随机数不随机问题
+func (c *CaptchaEngine) Random(length int, phone string) string {
+	phoneInt, _ := strconv.ParseInt(phone, 10, 64)
+
+	r := rand.New(rand.NewSource(time.Now().UnixNano() + phoneInt))
+	dict := strings.Split("0123456789", "")
+
+	res := ""
+	for i := 0; i < length; i++ {
+		res = res + dict[r.Intn(10)]
+	}
+
+	return res
+}
+
+// SendCaptcha 发送验证码
+func (c *CaptchaEngine) SendCaptcha(phone string) {
+	theCap := cap{
+		Phone:   phone,
+		Captcha: capEngine.Random(6, phone),
+		Expire:  time.Now().Local().Add(1 * time.Minute),
+	}
+
+	c.capList[phone] = theCap
+
+	SendSMS("captcha", theCap.Phone, theCap.Captcha)
+}
+
+// ValidCaptcha 验证 验证码
+func (c *CaptchaEngine) ValidCaptcha(phone, cap string) error {
+	theCap, ok := c.capList[phone]
+	if !ok {
+		return errors.New("未发送过该号码的验证码")
+	}
+
+	if time.Now().Local().Before(theCap.Expire) {
+		return errors.New("验证码已过期")
+	}
+
+	if theCap.Captcha != cap {
+		return errors.New("验证码不正确")
+	}
+
+	return nil
+}
+
+func init() {
+	capEngine = NewCaptchaEngine()
+}

utils/captcha_test.go

@@ -0,0 +1,18 @@
+package utils_test
+
+import (
+	"spaceofcheng/services/utils"
+	"testing"
+	"time"
+)
+
+func TestRandom(t *testing.T) {
+	capEngine := utils.NewCaptchaEngine()
+	r1 := capEngine.Random(6, "13823838438")
+	time.Sleep(1 * time.Microsecond)
+	r2 := capEngine.Random(6, "13823838438")
+
+	if r1 == r2 {
+		t.Fatalf("Test CaptchaEngine Random fail, %s", r2)
+	}
+}

utils/event.go

@@ -7,7 +7,7 @@ import (
 var evtBus = &tinyevent.DefaultBus{}
 
 // EmitEvent 执行事件
-func EmitEvent(evt string, payload []byte) {
+func EmitEvent(evt string, payload interface{}) {
 	e := tinyevent.Event{
 		Name:    evt,
 		Payload: payload,

utils/jwt.go

@@ -0,0 +1,34 @@
+package utils
+
+import (
+	"errors"
+
+	jwt "github.com/dgrijalva/jwt-go"
+)
+
+var tokenSignedKey = []byte(`Yansen is so handsome!`)
+
+// CreateToken 获取token
+func CreateToken(info map[string]interface{}) (string, error) {
+	claims := jwt.MapClaims(info)
+	token := jwt.NewWithClaims(jwt.SigningMethodHS256, claims)
+	return token.SignedString(tokenSignedKey)
+}
+
+// PareseToken 解析 token
+func PareseToken(token string) (map[string]interface{}, error) {
+	tk, err := jwt.Parse(token, func(t *jwt.Token) (interface{}, error) {
+		return tokenSignedKey, nil
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	if claims, ok := tk.Claims.(jwt.MapClaims); ok && tk.Valid {
+		info := map[string]interface{}(claims)
+		return info, nil
+	}
+
+	return nil, errors.New("Token 解析 未知错误")
+}

utils/log.go

@@ -3,23 +3,87 @@ package utils
 import (
 	"errors"
 
-	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/config"
+	"github.com/astaxie/beego/logs"
 )
 
+var defaultLogger *logs.BeeLogger
+var instances map[string]*logs.BeeLogger
+
+// NewLog 构造日志对象
+func NewLog(tp ...string) *logs.BeeLogger {
+	logType := "common"
+	if len(tp) > 0 {
+		if tp[0] != "" {
+			logType = tp[0]
+		}
+	}
+
+	if v, ok := instances[logType]; ok {
+		return v
+	}
+
+	log := logs.NewLogger()
+	instances[logType] = log
+
+	// 读取配置文件
+	conf, err := config.NewConfig("ini", "./conf/log.conf")
+	if err != nil {
+		log.SetLogger(logs.AdapterConsole)
+		return log
+	}
+
+	// 读文件存储位置
+	filename := conf.String(logType + "::filename")
+	// 输出级别
+	level := conf.String(logType + "::level")
+	if level == "" {
+		level = "error"
+	}
+
+	if filename == "" {
+		filename = "./" + logType + ".log"
+	}
+
+	log.Async()
+	log.SetLogger(logs.AdapterFile, `{"filename":"`+filename+`"}`)
+	return log
+}
+
 // LogError 错误日志
 func LogError(v ...interface{}) error {
-	beego.Error(v...)
+	log := instances["common"]
 
 	if len(v) > 0 {
-		switch err := v[0].(type) {
+		firstV := v[0]
+		leftV := v[1:]
+
+		switch err := firstV.(type) {
 		case string:
+			log.Error(err, leftV...)
 			return errors.New(err)
 		case error:
+			log.Error(err.Error(), leftV...)
 			return err
 		default:
-			return errors.New("Unknown error type")
+			msg := "Unknown error type"
+			log.Error(msg, leftV...)
+			return errors.New(msg)
 		}
 	}
 
 	return nil
 }
+
+// GetDefaultLogger 获取默认 logger
+func GetDefaultLogger() *logs.BeeLogger {
+	log := instances["common"]
+	return log
+}
+
+func init() {
+	instances = make(map[string]*logs.BeeLogger)
+	NewLog()
+
+	defaultLogger = GetDefaultLogger()
+}

utils/pagenavi.go

@@ -0,0 +1,61 @@
+package utils
+
+import (
+	"errors"
+	"regexp"
+	"strconv"
+
+	"github.com/go-xorm/xorm"
+)
+
+// GetPageList 获取列表
+func GetPageList(db *xorm.Session, target interface{}, limit []int, sqlorArgs ...interface{}) (int64, error) {
+	if sqlorArgs == nil || len(sqlorArgs) == 0 {
+		return 0, errors.New("SQL 语句不存在")
+	}
+
+	countSQLorArgs := GetCountSQL(sqlorArgs...)
+	cntRes, err := db.Query(countSQLorArgs...)
+	if err != nil {
+		return 0, err
+	}
+
+	cntStr := string(cntRes[0]["cnt"])
+	cnt, _ := strconv.ParseInt(cntStr, 10, 64)
+
+	sql, args := PackLimitToSQL(limit, sqlorArgs...)
+
+	err = db.SQL(sql, args...).Find(target)
+	if err != nil {
+		return 0, err
+	}
+
+	return cnt, nil
+}
+
+// GetCountSQL 获取计算 Count 的相关 SQL 脚本
+func GetCountSQL(sqlorArgs ...interface{}) []interface{} {
+	sql := sqlorArgs[0].(string)
+
+	re := regexp.MustCompile("(?ims)(select .* from)")
+	cntSQL := re.ReplaceAllString(sql, "select count(*) as cnt from")
+
+	newSQLorArgs := []interface{}{cntSQL}
+	newSQLorArgs = append(newSQLorArgs, sqlorArgs[1:])
+	return newSQLorArgs
+}
+
+// PackLimitToSQL 添加 limit 语句到 sql 最后
+func PackLimitToSQL(limit []int, sqlorArgs ...interface{}) (string, []interface{}) {
+	sql := sqlorArgs[0].(string)
+	args := sqlorArgs[1:]
+
+	switch len(limit) {
+	case 1:
+		return sql + " LIMIT " + strconv.Itoa(limit[0]), args
+	case 2:
+		return sql + " LIMIT " + strconv.Itoa(limit[0]) + " OFFSET " + strconv.Itoa(limit[1]), args
+	default:
+		return sql, args
+	}
+}

utils/pagenavi_test.go

@@ -0,0 +1,71 @@
+package utils_test
+
+import (
+	"spaceofcheng/services/utils"
+	"testing"
+)
+
+func TestGetCountSQL(t *testing.T) {
+	testCases := []map[string]string{
+		map[string]string{
+			"sql":      "Select field1, field2 From table",
+			"expected": "select count(*) as cnt from table",
+		},
+		map[string]string{
+			"sql": `Select 
+								field1, field2 From table where status = ?`,
+			"expected": "select count(*) as cnt from table where status = ?",
+		},
+	}
+
+	for inx, cs := range testCases {
+		sql := cs["sql"]
+		expected := cs["expected"]
+
+		var res []interface{}
+		if inx < 1 {
+			res = utils.GetCountSQL(sql)
+		} else {
+			res = utils.GetCountSQL(sql, inx)
+		}
+
+		if res == nil || len(res) == 0 {
+			t.Fatalf("Test GetCountSQL fail --1")
+		}
+
+		newSQL := res[0].(string)
+		if newSQL != expected {
+			t.Fatalf("Test GetCountSQL fail: %s", newSQL)
+		}
+	}
+}
+
+func TestPackLimitToSQL(t *testing.T) {
+	testCases := []map[string]string{
+		map[string]string{
+			"sql":      "Select * From table",
+			"expected": "Select * From table LIMIT 1 OFFSET 0",
+		},
+		map[string]string{
+			"sql":      "Select * From table",
+			"expected": "Select * From table LIMIT 1",
+		},
+	}
+
+	for inx, cs := range testCases {
+		sql := cs["sql"]
+		expected := cs["expected"]
+
+		var sqlRes string
+		if inx < 1 {
+			sqlRes, _ = utils.PackLimitToSQL([]int{inx + 1, inx}, sql)
+		} else {
+			sqlRes, _ = utils.PackLimitToSQL([]int{inx}, sql, inx)
+		}
+
+		if sqlRes != expected {
+			t.Fatalf("\n%v: Test PackLimitToSQL fail: %s", inx+1, sqlRes)
+		}
+	}
+
+}

utils/sms.go

@@ -0,0 +1,79 @@
+package utils
+
+import (
+	"bytes"
+	"fmt"
+	"net/http"
+	"strings"
+	"sync"
+
+	"github.com/astaxie/beego/config"
+)
+
+// SMSEngine 短信
+type SMSEngine struct {
+	url         string
+	method      string
+	contentType string
+	setting     config.Configer
+}
+
+var defaultSMS *SMSEngine
+var mtx *sync.Mutex
+
+// ResetSMSEngine 重置引擎
+func ResetSMSEngine(conf config.Configer) {
+	mtx.Lock()
+	defer mtx.Unlock()
+
+	newAPIURL := conf.String("url")
+
+	if defaultSMS == nil || defaultSMS.url != newAPIURL {
+		defaultSMS = &SMSEngine{
+			url:         conf.String("url"),
+			method:      strings.ToUpper(conf.String("method")),
+			contentType: conf.String("contentType"),
+			setting:     conf,
+		}
+	}
+}
+
+// SendSMS 发送短信
+func SendSMS(smsType, tel string, messages ...string) {
+	go func() {
+		if defaultSMS == nil {
+			LogError("没有成功初始化短信引擎")
+			return
+		}
+
+		// 接口内容
+		paramsTpl := `{"code": "%s", "tel": "%s", "params": "[%s]"}`
+		// 发送消息
+		message := strings.Join(messages, `","`)
+		if message != "" {
+			message = fmt.Sprintf(`"%s"`, message)
+		}
+
+		code := defaultSMS.setting.String(smsType + "::code")
+
+		// 接口 data
+		data := bytes.NewBuffer([]byte(fmt.Sprintf(paramsTpl, code, tel, message)))
+
+		// 暂时只支持 post 发送数据
+		if defaultSMS.method == http.MethodPost {
+			resp, err := http.Post(defaultSMS.url, defaultSMS.contentType, data)
+			if err != nil {
+				LogError("短信发送错误: " + err.Error())
+			}
+
+			if resp.StatusCode != http.StatusOK {
+				LogError("短信发送失败: " + resp.Status)
+			}
+		}
+
+	}()
+}
+
+func init() {
+	mtx = new(sync.Mutex)
+}

utils/utils.go

@@ -1,5 +1,10 @@
 package utils
 
+import (
+	"net/http"
+	"strings"
+)
+
 // 客户端类型
 const (
 	ClientAdmin  = "client-admin"
@@ -7,7 +12,24 @@ const (
 	ClientMini   = "client-mini"
 )
 
+// 一些 UA 列表
+const (
+	UAWechat      = "micromessenger"
+	UAMiniProgram = "miniprogram"
+)
+
 // GetClientType 获取客户端类型
-func GetClientType() string {
-	return ""
+// 默认返回是 管理端
+func GetClientType(r *http.Request) string {
+	ua := strings.ToLower(r.Header.Get("User-Agent"))
+
+	if strings.Index(ua, UAWechat) > -1 {
+		if strings.Index(ua, UAMiniProgram) > -1 {
+			return ClientMini
+		}
+
+		return ClientWechat
+	}
+
+	return ClientAdmin
 }

utils/wechat.go

@@ -0,0 +1,23 @@
+package utils
+
+import (
+	"github.com/zjxpcyc/wechat/wx"
+)
+
+var wxCli *wx.Client
+
+// InitWeChatClient 初始化
+func InitWeChatClient(cert map[string]string) {
+	wxCli = wx.NewClient(cert)
+	wx.SetLogInst(defaultLogger)
+}
+
+// GetWxUserInfo 微信获取用户信息
+func GetWxUserInfo(code string) (map[string]interface{}, error) {
+	return wxCli.GetUserInfo(code)
+}
+
+// WechatSignature 启用 Wechat 接口
+func WechatSignature(timestamp, nonce string) string {
+	return wxCli.Signature(timestamp, nonce)
+}