first commit

.gitignore

@@ -0,0 +1,5 @@
+*.exe
+*.exe~
+*.test
+*.log
+log

bootstrap/bootstrap.go

@@ -0,0 +1,25 @@
+package bootstrap
+
+import (
+	"support-game/models"
+	"support-game/routers"
+	"support-game/utils"
+)
+
+// SystemInit 系统初始化
+func SystemInit() {
+	// 数据库连接
+	models.InitDB()
+
+	// 系统日志
+	utils.LogInit()
+
+	// 微信
+	utils.InitWechat()
+
+	// 阿里云
+	utils.OssInit()
+
+	// 路由系统
+	routers.RouteInit()
+}

conf/app.conf

@@ -0,0 +1,23 @@
+appname = support-game
+httpport = 8080
+runmode = prod
+
+[cros]
+allowMode = dev
+allowCredentials = true
+allowOrigin = http://localhost:9528
+
+# GET, POST etc
+allowMethods = *
+
+[game]
+beginDate = 2018/12/07
+endDate = 2018/12/16
+gameNum = 10
+
+
+[alioss]
+Endpoint=oss-cn-shanghai.aliyuncs.com
+AccessKeyId=LTAIkc75dpkJw8Lb
+AccessKeySecret=v4bvXCaix6vSDTCFfwSAdqV53iFEQw
+Bucket=jingcheng-h5temp

conf/db.conf

@@ -0,0 +1,33 @@
+; 数据库类型，目前只支持mysql
+db_type      = mysql
+
+; 连接协议
+con_protocol = tcp
+
+; 数据库地址，可以使用IP
+# db_addr      = 47.101.36.130
+# db_addr        = 192.168.0.122
+db_addr = localhost
+# db_addr      = rm-uf6z3z6jq11x653d77o.mysql.rds.aliyuncs.com
+
+; 端口
+db_port      = 3306
+
+; 用户名
+username     = spaceofcheng
+
+; 密码
+password     = spaceofcheng
+# password     = c;a|vK)Xv/=L@c[6Fx,v[ITD5;WpR}+Y
+
+; 数据库名或者schema
+database     = support-game
+
+; 前缀，目前尚未使用
+dbprefix     = 
+
+; 模式，目前尚未使用
+db_debug     = false
+
+; 字符集
+char_set     = utf8mb4

conf/log.conf

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

conf/wechat.conf

@@ -0,0 +1,4 @@
+appid = wx776f26b70b03902b
+secret = 36ad3e2017a77cb4005770bfa405d7b1
+wxid = gh_1ec36e12f0a9
+token = yansenisashit

controllers/base.go

@@ -0,0 +1,86 @@
+package controllers
+
+import (
+	"net/http"
+	"support-game/utils"
+
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/config"
+)
+
+//BaseController 基础controller
+type BaseController struct {
+	beego.Controller
+	Context  *utils.Context
+	Configer map[string]config.Configer
+	RunMode  string
+}
+
+//Prepare 继承beego的
+func (c *BaseController) Prepare() {
+	// 读取配置文件
+	c.initConfig()
+
+	// 初始化上下文
+	c.initContext()
+
+	// 路由对应的实际 Controller 初始化
+	c.initController()
+}
+
+// ResponseJSON 返回JSON数据
+func (c *BaseController) ResponseJSON(data interface{}) {
+	c.ResponseData(data, "", http.StatusOK)
+}
+
+// ResponseError 返回错误
+func (c *BaseController) ResponseError(err error, code ...int) {
+	if len(code) > 0 {
+		c.ResponseData(nil, err, code[0])
+	}
+
+	c.ResponseData(nil, err, http.StatusBadRequest)
+}
+
+// ResponseRaw 返回
+func (c *BaseController) ResponseRaw(msg []byte, stop ...bool) {
+	c.Ctx.ResponseWriter.Write(msg)
+
+	if stop != nil && len(stop) > 0 {
+		if !stop[0] {
+			return
+		}
+	}
+
+	c.destroyContext(true)
+	c.StopRun()
+}
+
+// ResponseData 自定义的JSON返回
+func (c *BaseController) ResponseData(data interface{}, msg interface{}, code int) {
+	status := code
+
+	sendMessage := ""
+	switch msgVal := msg.(type) {
+	case error:
+		sendMessage = msgVal.Error()
+	case string:
+		sendMessage = msgVal
+	default:
+		sendMessage = ""
+	}
+
+	c.Data["json"] = JSONMessage{status, sendMessage, data}
+
+	c.destroyContext(status < http.StatusMultipleChoices)
+	c.crosPolicy()
+	c.ServeJSON()
+	c.StopRun()
+}
+
+// initAppController 执行当前路由请求对应的 Controller 初始化
+func (c *BaseController) initController() {
+	if ctrl, ok := c.AppController.(ControllerInterface); ok {
+		ctrl.Constructor()
+	}
+}

controllers/config.go

@@ -0,0 +1,37 @@
+package controllers
+
+import (
+	"support-game/utils"
+
+	"github.com/astaxie/beego/config"
+)
+
+// 配置文件列表
+const (
+	AppConf    = "app"
+	AliYunConf = "aliyun"
+	WeChatConf = "wechat"
+	SMSConf    = "sms"
+)
+
+func (c *BaseController) initConfig() {
+	// c.RunMode = beego.AppConfig.String("runmode")
+
+	if c.Configer == nil {
+		c.Configer = make(map[string]config.Configer)
+	}
+
+	// 系统
+	appConf, _ := utils.GetConfiger("conf/app.conf")
+	if appConf != nil {
+		c.Configer[AppConf] = appConf
+	}
+
+	c.RunMode = appConf.String("runmode")
+
+	// 微信
+	wechatConf, _ := utils.GetConfiger("conf/wechat.conf")
+	if wechatConf != nil {
+		c.Configer[WeChatConf] = wechatConf
+	}
+}

controllers/context.go

@@ -0,0 +1,33 @@
+package controllers
+
+import (
+	"support-game/models"
+	"support-game/utils"
+)
+
+/**
+* Context 说明
+* - 所有 stuct 类型均不是指针
+* - 包含内容如下
+**/
+
+// initContext 初始化 Context
+func (c *BaseController) initContext() {
+	c.Context = utils.NewContext(models.DBEngine, nil)
+	c.Context.Ready()
+}
+
+// initContext 销毁 Context
+func (c *BaseController) destroyContext(ok ...bool) {
+	if len(ok) == 0 || ok[0] {
+		c.Context.DB.Commit()
+	} else {
+		c.Context.DB.Rollback()
+	}
+
+	c.Context.Destroy()
+}
+
+func (c *BaseController) DestroyContext() {
+	c.destroyContext()
+}

controllers/cros.go

@@ -0,0 +1,25 @@
+package controllers
+
+// Options 解决跨域先发送 options
+func (c *BaseController) Options() {
+	c.ResponseJSON("")
+}
+
+// crosPolicy 跨域策略
+func (c *BaseController) crosPolicy() {
+	appConf, ok := c.Configer[AppConf]
+	if ok {
+		runMode := appConf.String("runmode")
+		allowMode := appConf.String("cros::allowMode")
+		allowMethods := appConf.String("cros::allowMethods")
+		allowOrigin := appConf.String("cros::allowOrigin")
+		allowCredentials := appConf.String("cros::allowCredentials")
+
+		if runMode == allowMode {
+			c.Ctx.Output.Header("Access-Control-Allow-Origin", allowOrigin)
+			c.Ctx.Output.Header("Access-Control-Allow-Methods", allowMethods)
+			c.Ctx.Output.Header("Access-Control-Allow-Credentials", allowCredentials)
+			c.Ctx.Output.Header("Access-Control-Allow-Headers", "X-Token,Authorization")
+		}
+	}
+}

controllers/file.go

@@ -0,0 +1,25 @@
+package controllers
+
+import (
+	"strconv"
+	"support-game/utils"
+	"time"
+)
+
+type ObjectController struct {
+	BaseController
+}
+
+// Post 上传图片
+func (c *ObjectController) Post() {
+	fNameExtra := strconv.FormatInt(time.Now().Unix(), 10)
+
+	fileURL, err := utils.UploadFileToBucket(c.Ctx.Request, "file", fNameExtra)
+	if err != nil {
+		c.ResponseError(err)
+	}
+
+	c.ResponseJSON(map[string]interface{}{
+		"url": fileURL,
+	})
+}

controllers/game/support.go

@@ -0,0 +1,101 @@
+package game
+
+import (
+	"net/url"
+	"support-game/controllers"
+	"support-game/service/game"
+	"support-game/utils"
+)
+
+// SupportController 活动
+type SupportController struct {
+	serv *game.SupportServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *SupportController) Constructor() {
+	c.serv = game.NewSupportServ(c.Context)
+}
+
+// GetCustomer 获取用户信息
+func (c *SupportController) GetCustomer() {
+	code := c.GetString(":code")
+	customer, err := c.serv.GetCustomerByCode(code)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customer)
+}
+
+// SignUp 注册
+func (c *SupportController) SignUp() {
+	customerid := c.GetString(":customerid")
+	name := c.GetString("name")
+	phone := c.GetString("phone")
+	address := c.GetString("address")
+	customer, err := c.serv.SignUp(customerid, name, phone, address)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(customer)
+}
+
+// GetGame 获取主信息
+func (c *SupportController) GetGame() {
+	gameid := c.GetString(":gameid")
+	customerid := c.GetString(":customerid")
+	info, err := c.serv.GetGameInfo(gameid, customerid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// GetRecord 获取报名信息
+func (c *SupportController) GetRecord() {
+	recordid := c.GetString(":recordid")
+	info, err := c.serv.GetRecordInfo(recordid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// AddRecord 参加活动
+func (c *SupportController) AddRecord() {
+	customerid := c.GetString(":customerid")
+	gameid := c.GetString(":gameid")
+	record, err := c.serv.AddRecord(customerid, gameid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(record)
+}
+
+// AddSupport 助力
+func (c *SupportController) AddSupport() {
+	customerid := c.GetString(":customerid")
+	recordid := c.GetString(":recordid")
+	info, err := c.serv.AddSupport(recordid, customerid)
+	if err != nil {
+		c.ResponseError(err)
+	}
+	c.ResponseJSON(info)
+}
+
+// WechatInfo 微信接入
+func (c *SupportController) WechatInfo() {
+	echostr := c.GetString("echostr")
+	c.ResponseRaw([]byte(echostr))
+}
+
+// GetWxJsSDKSignature 获取 微信 jssdk 签名
+func (c *SupportController) GetWxJsSDKSignature() {
+	url, _ := url.QueryUnescape(c.GetString("url"))
+
+	res := utils.WxClient().GetJsTicketSignature(url)
+	c.ResponseJSON(res)
+}

controllers/game/voting.go

@@ -0,0 +1,106 @@
+package game
+
+import (
+	"errors"
+	"support-game/controllers"
+	gamemodel "support-game/models/game"
+	"support-game/models/model"
+	"support-game/service/game"
+)
+
+// VotingController 活动
+type VotingController struct {
+	serv *game.VotingServ
+	controllers.BaseController
+}
+
+// Constructor 初始化 Controller
+// @Title Constructor
+// @Description 初始化 Controller, 系统自动调用
+func (c *VotingController) Constructor() {
+	c.serv = game.NewVotingServ(c.Context)
+}
+
+// List 获取列表
+func (c *VotingController) List() {
+	// 活动
+	actID, _ := c.GetInt("actid")
+
+	// 分页
+	page, _ := c.GetInt("page")
+	if page < 1 {
+		page = 1
+	}
+	page -= 1
+
+	// tab 类型
+	tab, _ := c.GetInt("tab")
+
+	// 搜索条件
+	search := c.GetString("q")
+	list, err := c.serv.GetList(actID, search, tab, page)
+	if err != nil {
+		c.ResponseError(errors.New("查询列表失败, 请重试"))
+	}
+
+	c.ResponseJSON(list)
+}
+
+// Activities 活动详情
+func (c *VotingController) Activities() {
+	// 活动
+	actID, _ := c.GetInt(":actid")
+	activitie, err := c.serv.GetActivitiesInfo(actID)
+	if err != nil {
+		c.ResponseError(errors.New("查询活动失败，请重试"))
+	}
+
+	c.ResponseJSON(activitie)
+}
+
+// Detail 报名详情
+func (c *VotingController) Detail() {
+	// 活动
+	actID, _ := c.GetInt(":actid")
+	memberid, _ := c.GetInt(":memberid")
+	activitie, err := c.serv.GetMemberInfo(actID, memberid)
+	if err != nil {
+		c.ResponseError(errors.New("查询活动详情失败，请重试"))
+	}
+
+	c.ResponseJSON(activitie)
+}
+
+// Registe 报名
+func (c *VotingController) Registe() {
+	// 活动
+	actID, _ := c.GetInt(":actid")
+	member := gamemodel.MemInfo{}
+	if err := c.ParseForm(&member); err != nil {
+		c.ResponseError(errors.New("参数错误！"))
+	}
+	member.ActivityId = actID
+	err := c.serv.Registe(&member)
+	if err != nil {
+		c.ResponseError(errors.New("查询活动详情失败，请重试"))
+	}
+	c.ResponseJSON(member)
+}
+
+// Vote 投票
+func (c *VotingController) Vote() {
+	actID, _ := c.GetInt(":actid")
+	memberid, _ := c.GetInt(":memberid")
+	openid := c.GetString("openid")
+	record := model.TaVotingRecords{
+		ActivityId: actID,
+		MemberId:   memberid,
+		Openid:     openid,
+	}
+
+	err := c.serv.Vote(&record)
+	if err != nil {
+		c.ResponseError(errors.New("投票失败，请重试"))
+	}
+	c.ResponseJSON(record)
+}

controllers/types.go

@@ -0,0 +1,13 @@
+package controllers
+
+// JSONMessage 主要用于 Response 返回
+type JSONMessage struct {
+	Code    int         `json:"code"`
+	Message string      `json:"message"`
+	Result  interface{} `json:"result"`
+}
+
+// ControllerInterface 项目约定的 Controller 须满足的接口
+type ControllerInterface interface {
+	Constructor()
+}

main.go

@@ -0,0 +1,18 @@
+package main
+
+import (
+	"support-game/bootstrap"
+
+	"github.com/astaxie/beego"
+)
+
+func main() {
+	if beego.BConfig.RunMode == "dev" {
+		beego.BConfig.WebConfig.DirectoryIndex = true
+		beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
+	}
+
+	bootstrap.SystemInit()
+
+	beego.Run()
+}

models/constant.go

@@ -0,0 +1,16 @@
+package models
+
+// 状态列表
+const (
+	// 删除
+	STATUS_DEL = iota - 1
+
+	// 进行中
+	STATUS_READY
+
+	// 已成功
+	STATUS_NORMAL
+
+	// 已失效
+	STATUS_INVALID
+)

models/game/support.go

@@ -0,0 +1,154 @@
+package game
+
+import (
+	"support-game/models"
+	"support-game/models/model"
+	"support-game/utils"
+	"time"
+
+	"github.com/go-xorm/xorm"
+)
+
+// SupportDao 当前数据库操作对象
+type SupportDao struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewSupportDao 初始化DAO
+func NewSupportDao(ctx *utils.Context) *SupportDao {
+	return &SupportDao{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+// GetCustomerByOpenID 根据openid获取用户信息
+func (m *SupportDao) GetCustomerByOpenID(openid string) (*model.TaCustomer, error) {
+	var customer = model.TaCustomer{}
+	_, err := m.db.Where("openid=?", openid).Get(&customer)
+	return &customer, err
+}
+
+// SaveCustomer 保存用户信息
+func (m *SupportDao) SaveCustomer(customer model.TaCustomer) (*model.TaCustomer, error) {
+	customer.CustomerId = utils.GetGUID()
+	customer.CreateDate = time.Now()
+	_, err := m.db.Insert(customer)
+	return &customer, err
+}
+
+// UpdateCustomer 修改用户信息
+func (m *SupportDao) UpdateCustomer(customer *model.TaCustomer, cols []string) error {
+	_, err := m.db.Cols(cols...).Where("customer_id=?", customer.CustomerId).Update(customer)
+	return err
+}
+
+// UpdateRecord 修改活动信息
+func (m *SupportDao) UpdateRecord(record *model.TaGameRecord, cols []string) error {
+	_, err := m.db.Cols(cols...).Where("record_id=?", record.RecordId).Update(record)
+	return err
+}
+
+// GetCustomerByID 根据id获取用户信息
+func (m *SupportDao) GetCustomerByID(id string) (*model.TaCustomer, error) {
+	var customer = model.TaCustomer{}
+	_, err := m.db.Where("customer_id=?", id).Get(&customer)
+	return &customer, err
+}
+
+// GetRecordByID 根据id获取记录
+func (m *SupportDao) GetRecordByID(recordid string) (*model.TaGameRecord, error) {
+	var record model.TaGameRecord
+	_, err := m.db.Where("record_id=?", recordid).Get(&record)
+	return &record, err
+}
+
+// RecordSupport 助力记录
+type RecordSupport struct {
+	model.TaRecordSuppot `xorm:"extends"`
+	CustomerName         string
+	Name                 string
+	HeadImg              string
+}
+
+// GetSupportsByRecord 获取助力信息
+func (m *SupportDao) GetSupportsByRecord(recordid string) ([]RecordSupport, error) {
+	var supports []RecordSupport
+	sql := `select a.*,b.customer_name,b.name,b.head_img from ta_record_suppot a inner join ta_customer b on a.customer_id=b.customer_id where record_id=?`
+	err := m.db.Sql(sql, recordid).Find(&supports)
+	return supports, err
+}
+
+// GetTodayQuota 获取今天成功的活动
+func (m *SupportDao) GetTodayQuota(gameid string) ([]model.TaGameRecord, error) {
+	var records []model.TaGameRecord
+	sql := `select * from ta_game_record where date_format(create_date,'%Y-%m-%d') = date_format(now(),'%Y-%m-%d') and status = ? and game_id=?`
+	err := m.db.Sql(sql, models.STATUS_NORMAL, gameid).Find(&records)
+	return records, err
+}
+
+// GetTodayCustomerRecord 获取客户今天参与的活动
+func (m *SupportDao) GetTodayCustomerRecord(customerid, gameid string) ([]model.TaGameRecord, error) {
+	var records []model.TaGameRecord
+	sql := `select * from ta_game_record where date_format(create_date,'%Y-%m-%d') = date_format(now(),'%Y-%m-%d') and customer_id=? and game_id=?`
+	err := m.db.Sql(sql, customerid, gameid).Find(&records)
+	return records, err
+}
+
+// GetCustomerQuota 获取用户成功的活动
+func (m *SupportDao) GetCustomerQuota(customerid, gameid string) ([]model.TaGameRecord, error) {
+	var records []model.TaGameRecord
+	sql := `select * from ta_game_record where customer_id=? and status = ? and game_id=?`
+	err := m.db.Sql(sql, customerid, models.STATUS_NORMAL, gameid).Find(&records)
+	return records, err
+}
+
+// AddRecord 新增活动
+func (m *SupportDao) AddRecord(record model.TaGameRecord) (*model.TaGameRecord, error) {
+	record.RecordId = utils.GetGUID()
+	record.CreateDate = time.Now()
+	record.Status = models.STATUS_READY
+	_, err := m.db.Insert(record)
+	return &record, err
+}
+
+// AddSupport 新增助力
+func (m *SupportDao) AddSupport(support model.TaRecordSuppot) (*model.TaRecordSuppot, error) {
+	support.CreateDate = time.Now()
+	support.SupportId = utils.GetGUID()
+	_, err := m.db.Insert(support)
+	return &support, err
+}
+
+// GetCustomerSupport 获取用户当前活动的助力信息
+func (m *SupportDao) GetCustomerSupport(recordid, customerid string) ([]model.TaRecordSuppot, error) {
+	var supports []model.TaRecordSuppot
+	err := m.db.Where("record_id=?", recordid).And("customer_id=?", customerid).Find(&supports)
+	return supports, err
+}
+
+// GetGameByID 获取主活动信息
+func (m *SupportDao) GetGameByID(gameid string) (*model.TaGame, error) {
+	var game model.TaGame
+	_, err := m.db.Where("game_id=?", gameid).Get(&game)
+	return &game, err
+}
+
+// GetGameNote 获取活动今日信息
+func (m *SupportDao) GetGameNote(gameid string) (*model.TaGameNotes, error) {
+	var note model.TaGameNotes
+	_, err := m.db.Where("game_id=?", gameid).And("date_format(game_date,'%Y-%m-%d') = date_format(now(),'%Y-%m-%d')").Get(&note)
+	return &note, err
+}
+
+// UpdateLeftNum 更新活动剩余次数
+func (m *SupportDao) UpdateLeftNum(gameid string) (int64, error) {
+	sql := `update ta_game_notes set left_num = left_num-1 where date_format(game_date,'%Y-%m-%d') = date_format(now(),'%Y-%m-%d') and game_id=? and left_num>0`
+	s, err := m.db.Exec(sql, gameid)
+	if err != nil {
+		return 0, err
+	}
+	row, _ := s.RowsAffected()
+	return row, nil
+}

models/game/voting.go

@@ -0,0 +1,339 @@
+package game
+
+import (
+	"encoding/json"
+	"errors"
+	"strconv"
+	"support-game/models"
+	"support-game/models/model"
+	"support-game/utils"
+	"time"
+
+	"github.com/go-xorm/xorm"
+)
+
+const (
+	// 默认图片类型
+	DefaultPhotoType = "main"
+
+	// 列表排序类型
+	OrderByDate = 1
+	OrderByVote = 2
+
+	// 活动限制规则
+	RuleOfLimitEveryday = "limiteveryday"
+
+	PageNum = 10
+)
+
+var (
+	ErrVoteLimit        = errors.New("votelimit")
+	ErrActivityNotStart = errors.New("Activity not start")
+	ErrActivityIsOver   = errors.New("Activity is over")
+)
+
+// VotingModel 当前数据库操作对象
+type VotingModel struct {
+	ctx *utils.Context
+	db  *xorm.Session
+}
+
+// NewVotingModel 初始化DAO
+func NewVotingModel(ctx *utils.Context) *VotingModel {
+	return &VotingModel{
+		ctx: ctx,
+		db:  ctx.DB,
+	}
+}
+
+type MemInfo struct {
+	model.TaVotingMember `xorm:"extends"`
+	Photo                string `xorm:"TEXT"`
+	Rank                 int
+}
+
+// List 报名列表
+func (m *VotingModel) List(actID int, search string, orderby, page int) (list []MemInfo, err error) {
+	query := `
+		SELECT t.*, s.photo
+		FROM
+			ta_voting_member t
+		JOIN ta_voting_member_photos s ON t.member_id = s.member_id
+			AND t.activity_id = s.activity_id
+			AND s.type = '` + DefaultPhotoType + `'
+			AND s.status = ` + strconv.Itoa(models.STATUS_NORMAL) + `
+		Where t.activity_id = '` + strconv.Itoa(actID) + `' AND 
+	`
+
+	// 依据 ID 或者 名称查询
+	// 全部列表的时候, 名称为空即可
+	if search != "" {
+		query += `(t.member_id like '%` + search + `%' or t.name like '%` + search + `%') AND`
+	}
+	query += " t.status = " + strconv.Itoa(models.STATUS_NORMAL)
+
+	// 排序
+	if orderby == OrderByVote {
+		query += " order by t.vote desc"
+		if page > 5 {
+			page = 5
+		}
+	} else {
+		query += " order by t.create_date desc"
+	}
+
+	// 分页
+	offset := (page - 1) * PageNum
+	if offset < 0 {
+		offset = 0
+	}
+
+	query += " limit " + strconv.Itoa(PageNum) + " offset " + strconv.Itoa(offset)
+
+	if err = m.db.Sql(query).Find(&list); err != nil {
+		return
+	}
+
+	return
+}
+
+// GetActivityInfo 查询活动
+func (m *VotingModel) GetActivityInfo(actID int) (act *model.TaVotingActivities, err error) {
+	_, err = m.db.Table("ta_voting_activities").Where("activity_id=?", actID).Get(act)
+	if err != nil {
+		return
+	}
+	return
+}
+
+// GetMemInfo 获取报名人员信息
+func (m *VotingModel) GetMemInfo(actID, memID int) (mem *MemInfo, err error) {
+	query := `
+		SELECT t.*, s.photo
+		FROM
+			ta_voting_member t
+		JOIN ta_voting_member_photos s ON t.member_id = s.member_id
+			AND t.activity_id = s.activity_id
+			AND s.type = '` + DefaultPhotoType + `'
+			AND s.status = ` + strconv.Itoa(models.STATUS_NORMAL) + `
+		Where t.activity_id = ? AND t.member_id = ?
+	`
+
+	if _, err = m.db.SQL(query, actID, memID).Get(mem); err != nil {
+		return
+	}
+
+	// 获取排名
+	cnt, e := m.db.Where("activity_id=?", actID).
+		And("status=?", models.STATUS_NORMAL).
+		And("vote>?", mem.Vote).
+		Count()
+	if e != nil {
+		// -1 代表发生错误
+		mem.Rank = -1
+		return
+	}
+
+	mem.Rank = int(cnt)
+	return
+}
+
+// Registe 报名保存
+func (m *VotingModel) Registe(memInfo *MemInfo) error {
+	if memInfo.ActivityId == 0 {
+		return errors.New("活动报名失败, 没有指定活动内容")
+	}
+	// 校验活动
+	if err := m.checkActivity(memInfo.ActivityId); err != nil {
+		return err
+	}
+
+	now := time.Now().Local()
+
+	mem := memInfo.TaVotingMember
+	photo := model.TaVotingMemberPhotos{
+		ActivityId: mem.ActivityId,
+		Photo:      memInfo.Photo,
+		Type:       DefaultPhotoType,
+		CreateDate: now,
+		Status:     models.STATUS_NORMAL,
+	}
+
+	// 检查已有最大值
+	maxID, err := m.getMaxMemID(mem.ActivityId)
+	if err != nil {
+		return err
+	}
+
+	mem.MemberId = int(maxID + 1)
+	mem.Vote = 0
+	photo.MemberId = mem.MemberId
+	memInfo.MemberId = mem.MemberId
+
+	if _, err := m.db.Insert(&photo); err != nil {
+		return err
+	}
+
+	if _, err := m.db.Insert(&mem); err != nil {
+		return err
+	}
+
+	// 反更新报名人数
+	// TODO
+
+	return nil
+}
+
+func (m *VotingModel) getMaxMemID(actID int) (maxID int64, err error) {
+	query := `
+		SELECT
+			max(start_id) as max_id
+		FROM
+			(
+				SELECT
+					max(t.member_id) AS start_id
+				FROM
+					ta_voting_member t
+				UNION
+					SELECT
+						s.start_id
+					FROM
+						ta_voting_activities s
+					WHERE
+						s.activity_id = ?
+			) a
+	`
+
+	if _, err = m.db.SQL(query, actID).Get(&maxID); err != nil {
+		return
+	}
+
+	return
+}
+
+// Vote 投票
+func (m *VotingModel) Vote(rec *model.TaVotingRecords) error {
+	// 校验活动
+	if err := m.checkActivity(rec.ActivityId); err != nil {
+		return err
+	}
+
+	rule, err := m.getActivityRule(rec.ActivityId)
+	if err != nil {
+		return err
+	}
+
+	var ruleParam map[string]interface{}
+	if err := json.Unmarshal([]byte(rule.RuleValue), &ruleParam); err != nil {
+		return err
+	}
+
+	// 如果有每天最大投票限制
+	if v, ok := ruleParam[RuleOfLimitEveryday]; ok {
+		limitEveryday := int64(v.(float64))
+
+		voteNum, err := m.getVoteNumOfMember(rec)
+		if err != nil {
+			return err
+		}
+
+		if voteNum >= limitEveryday {
+			return ErrVoteLimit
+		}
+	}
+
+	// 每天投票
+	rec.VoteDate = time.Now().Local()
+	if _, err := m.db.Insert(rec); err != nil {
+		return err
+	}
+
+	// 反更新次数
+	if err := m.updateVoteOfMember(rec.ActivityId, rec.MemberId); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// 获取投票规则
+func (m *VotingModel) getActivityRule(actID int) (rule *model.TaVotingRules, err error) {
+	query := `
+		SELECT
+			t.*
+		FROM
+			ta_voting_rules t
+		JOIN ta_voting_activities s ON t.rule_id = s.rule_id
+		AND s.activity_id = ?
+	`
+
+	if _, err = m.db.SQL(query, actID).Get(rule); err != nil {
+		return
+	}
+
+	if rule.RuleValue == "" {
+		rule.RuleValue = "{}"
+	}
+
+	return
+}
+
+// 获取当前人员投票数
+func (m *VotingModel) getVoteNumOfMember(rec *model.TaVotingRecords) (num int64, err error) {
+	query := `
+		SELECT
+			*
+		FROM
+			ta_voting_records t
+		WHERE
+			t.activity_id = ?
+		AND t.member_id = ?
+		AND t.openid = ?
+		AND date_format(t.vote_date, "%Y-%m-%d") = date_format(now(), "%Y-%m-%d")
+	`
+
+	num, err = m.db.SQL(query, rec.ActivityId, rec.MemberId, rec.Openid).Count()
+	if err != nil {
+		return
+	}
+
+	return
+}
+
+// 反更新投票次数
+func (m *VotingModel) updateVoteOfMember(actID, memID int) error {
+	query := `
+	UPDATE ta_voting_member t
+		SET t.vote = t.vote + 1
+		WHERE
+			t.activity_id = ?
+		AND t.member_id = ?
+	`
+
+	if _, err := m.db.Exec(query, actID, memID); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// 校验活动
+// 只校验活动时间
+func (m *VotingModel) checkActivity(actID int) error {
+	act := model.TaVotingActivities{}
+
+	if _, err := m.db.Where("activity_id=?", actID).Get(&act); err != nil {
+		return err
+	}
+
+	now := time.Now().Local()
+	if act.StartTime.After(now) {
+		return ErrActivityNotStart
+	}
+
+	if act.EndTime.Before(now) {
+		return ErrActivityIsOver
+	}
+
+	return nil
+}

models/model/ta_customer.go

@@ -0,0 +1,17 @@
+package model
+
+import (
+	"time"
+)
+
+type TaCustomer struct {
+	CustomerId   string    `xorm:"VARCHAR(64)"`
+	Openid       string    `xorm:"VARCHAR(200)"`
+	CreateDate   time.Time `xorm:"DATETIME"`
+	HeadImg      string    `xorm:"TEXT"`
+	CustomerName string    `xorm:"VARCHAR(50)"`
+	Name         string    `xorm:"VARCHAR(50)"`
+	Phone        string    `xorm:"VARCHAR(50)"`
+	Address      string    `xorm:"VARCHAR(500)"`
+	Sex          int       `xorm:"SMALLINT(6)"`
+}

models/model/ta_game.go

@@ -0,0 +1,15 @@
+package model
+
+import (
+	"time"
+)
+
+type TaGame struct {
+	GameId    string    `xorm:"VARCHAR(64)"`
+	GameName  string    `xorm:"VARCHAR(50)"`
+	BeginDate time.Time `xorm:"DATETIME"`
+	EndDate   time.Time `xorm:"DATETIME"`
+	DayNum    int       `xorm:"INT(11)"`
+	Status    int       `xorm:"SMALLINT(6)"`
+	UserNum   int       `xorm:"INT(11)"`
+}

models/model/ta_game_notes.go

@@ -0,0 +1,13 @@
+package model
+
+import (
+	"time"
+)
+
+type TaGameNotes struct {
+	NotesId  string    `xorm:"VARCHAR(64)"`
+	GameId   string    `xorm:"VARCHAR(64)"`
+	GameDate time.Time `xorm:"DATETIME"`
+	Num      int       `xorm:"INT(11)"`
+	LeftNum  int       `xorm:"INT(11)"`
+}

models/model/ta_game_record.go

@@ -0,0 +1,14 @@
+package model
+
+import (
+	"time"
+)
+
+type TaGameRecord struct {
+	RecordId   string    `xorm:"VARCHAR(64)"`
+	GameId     string    `xorm:"VARCHAR(64)"`
+	GameName   string    `xorm:"VARCHAR(50)"`
+	CustomerId string    `xorm:"VARCHAR(64)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+	Status     int       `xorm:"SMALLINT(6)"`
+}

models/model/ta_record_suppot.go

@@ -0,0 +1,12 @@
+package model
+
+import (
+	"time"
+)
+
+type TaRecordSuppot struct {
+	SupportId  string    `xorm:"VARCHAR(64)"`
+	RecordId   string    `xorm:"VARCHAR(64)"`
+	CustomerId string    `xorm:"VARCHAR(64)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+}

models/model/ta_voting_activities.go

@@ -0,0 +1,27 @@
+package model
+
+import (
+	"time"
+)
+
+type TaVotingActivities struct {
+	ActivityId int       `xorm:"not null pk autoincr SMALLINT(6)"`
+	RuleId     int       `xorm:"SMALLINT(6)"`
+	Music      string    `xorm:"TEXT"`
+	Name       string    `xorm:"VARCHAR(300)"`
+	Thumb      string    `xorm:"TEXT"`
+	Banner     string    `xorm:"TEXT"`
+	Desc       string    `xorm:"TEXT"`
+	Rules      string    `xorm:"TEXT"`
+	StartTime  time.Time `xorm:"DATETIME"`
+	EndTime    time.Time `xorm:"DATETIME"`
+	Remark     string    `xorm:"VARCHAR(500)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+	Status     int       `xorm:"SMALLINT(6)"`
+	Members    int       `xorm:"INT(11)"`
+	StartId    int       `xorm:"INT(11)"`
+	AfterVote  string    `xorm:"TEXT"`
+	ShareTitle string    `xorm:"VARCHAR(100)"`
+	ShareIcon  string    `xorm:"TEXT"`
+	ShareDesc  string    `xorm:"VARCHAR(200)"`
+}

models/model/ta_voting_member.go

@@ -0,0 +1,19 @@
+package model
+
+import (
+	"time"
+)
+
+type TaVotingMember struct {
+	MemberId   int       `xorm:"not null pk INT(11)"`
+	ActivityId int       `xorm:"not null pk SMALLINT(6)"`
+	Name       string    `xorm:"VARCHAR(200)"`
+	Phone      string    `xorm:"VARCHAR(20)"`
+	Addr       string    `xorm:"TEXT"`
+	Message    string    `xorm:"TEXT"`
+	Remark     string    `xorm:"VARCHAR(500)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+	Status     int       `xorm:"SMALLINT(6)"`
+	Vote       int       `xorm:"INT(11)"`
+	Openid     string    `xorm:"VARCHAR(64)"`
+}

models/model/ta_voting_member_photos.go

@@ -0,0 +1,16 @@
+package model
+
+import (
+	"time"
+)
+
+type TaVotingMemberPhotos struct {
+	PhotoId    int       `xorm:"not null pk autoincr INT(11)"`
+	MemberId   int       `xorm:"INT(11)"`
+	ActivityId int       `xorm:"SMALLINT(6)"`
+	Photo      string    `xorm:"TEXT"`
+	Type       string    `xorm:"VARCHAR(20)"`
+	Desc       string    `xorm:"VARCHAR(300)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+	Status     int       `xorm:"SMALLINT(6)"`
+}

models/model/ta_voting_records.go

@@ -0,0 +1,15 @@
+package model
+
+import (
+	"time"
+)
+
+type TaVotingRecords struct {
+	VoteId     int       `xorm:"not null pk autoincr INT(11)"`
+	MemberId   int       `xorm:"INT(11)"`
+	ActivityId int       `xorm:"SMALLINT(6)"`
+	VoteDate   time.Time `xorm:"DATETIME"`
+	NickName   string    `xorm:"VARCHAR(200)"`
+	Avatar     string    `xorm:"TEXT"`
+	Openid     string    `xorm:"VARCHAR(64)"`
+}

models/model/ta_voting_rules.go

@@ -0,0 +1,8 @@
+package model
+
+type TaVotingRules struct {
+	RuleId    int    `xorm:"not null pk autoincr SMALLINT(6)"`
+	RuleValue string `xorm:"TEXT"`
+	Desc      string `xorm:"TEXT"`
+	Status    int    `xorm:"SMALLINT(6)"`
+}

models/models.go

@@ -0,0 +1,55 @@
+package models
+
+import (
+	"support-game/utils"
+
+	"github.com/astaxie/beego/config"
+	_ "github.com/go-sql-driver/mysql"
+	"github.com/go-xorm/xorm"
+)
+
+var (
+	DBEngine *xorm.Engine
+)
+
+func InitDB() {
+	DBEngine = NewDBEngine()
+}
+
+// NewDBEngine 初始化数据库连接
+func NewDBEngine() *xorm.Engine {
+	dbType := "mysql"
+	dns := getMySQLDNS()
+
+	engine, err := xorm.NewEngine(dbType, dns)
+	engine.ShowSQL()
+
+	if err != nil {
+		panic(err)
+	}
+
+	return engine
+}
+
+func getMySQLDNS() (dns string) {
+	appRoot := utils.GetAppRoot()
+	dbconf, _ := config.NewConfig("ini", appRoot+"/conf/db.conf")
+
+	conProt := dbconf.DefaultString("con_protocol", "tcp")
+	dbAddr := dbconf.DefaultString("db_addr", "localhost")
+	dbPort := dbconf.DefaultString("db_port", "3306")
+	userName := dbconf.DefaultString("username", "root")
+	password := dbconf.String("password")
+	database := dbconf.String("database")
+	charSet := dbconf.DefaultString("char_set", "utf8")
+
+	dns = userName
+
+	if len(password) > 0 {
+		dns += ":" + password
+	}
+
+	dns += "@" + conProt + "(" + dbAddr + ":" + dbPort + ")" + "/" + database + "?charset=" + charSet
+
+	return
+}

routers/router.go

@@ -0,0 +1,38 @@
+// @APIVersion 1.0.0
+// @Title beego Test API
+// @Description beego has a very cool tools to autogenerate documents for your API
+// @Contact astaxie@gmail.com
+// @TermsOfServiceUrl http://beego.me/
+// @License Apache 2.0
+// @LicenseUrl http://www.apache.org/licenses/LICENSE-2.0.html
+package routers
+
+import (
+	"support-game/controllers"
+	"support-game/controllers/game"
+
+	"github.com/astaxie/beego"
+)
+
+func RouteInit() {
+	ns := beego.NewNamespace("api",
+		// 解决跨域时 先发送 options 问题
+		beego.NSRouter("*", &controllers.BaseController{}, "options:Options"),
+		beego.NSRouter("/wechat", &game.SupportController{}, "get:WechatInfo"),
+		beego.NSRouter("/game/:gameid/:customerid", &game.SupportController{}, "get:GetGame"),
+		beego.NSRouter("/customer/:code", &game.SupportController{}, "get:GetCustomer"),
+		beego.NSRouter("/signup/:customerid", &game.SupportController{}, "post:SignUp"),
+		beego.NSRouter("/record/:recordid", &game.SupportController{}, "get:GetRecord"),
+		beego.NSRouter("/record/:customerid/:gameid", &game.SupportController{}, "post:AddRecord"),
+		beego.NSRouter("/support/:customerid/:recordid", &game.SupportController{}, "post:AddSupport"),
+		beego.NSRouter("/wechat/jssdk/signature", &game.SupportController{}, "get:GetWxJsSDKSignature"),
+
+		beego.NSRouter("/voting", &game.VotingController{}, "get:List"),
+		beego.NSRouter("/voting/:actid", &game.VotingController{}, "get:Activities"),
+		beego.NSRouter("/voting/:actid/:memberid", &game.VotingController{}, "get:Detail"),
+		beego.NSRouter("/voting/:actid", &game.VotingController{}, "post:Registe"),
+		beego.NSRouter("/voting/:actid/:memberid", &game.VotingController{}, "post:Vote"),
+	)
+
+	beego.AddNamespace(ns)
+}

service/game/support.go

@@ -0,0 +1,317 @@
+package game
+
+import (
+	"errors"
+	"support-game/models"
+	"support-game/models/game"
+	"support-game/models/model"
+	"support-game/utils"
+	"time"
+)
+
+// SupportServ 活动serv
+type SupportServ struct {
+	ctx *utils.Context
+	dao *game.SupportDao
+}
+
+// NewSupportServ 初始化
+func NewSupportServ(ctx *utils.Context) *SupportServ {
+	return &SupportServ{
+		ctx: ctx,
+		dao: game.NewSupportDao(ctx),
+	}
+}
+
+// GetCustomerByCode 获取用户信息
+func (s *SupportServ) GetCustomerByCode(code string) (*model.TaCustomer, error) {
+	if code == "" {
+		return nil, errors.New("code为空")
+	}
+	data, err := utils.WxClient().GetUserInfo(code)
+	if err != nil {
+		utils.LogError("获取微信用户信息失败：", err)
+		return nil, err
+	}
+
+	openid := data["openid"].(string)
+	customer, err := s.dao.GetCustomerByOpenID(openid)
+	if err != nil {
+		utils.LogError("获取用户信息失败：", err)
+		return nil, err
+	}
+
+	if customer != nil && customer.CustomerId != "" && customer.CustomerName != "" {
+		return customer, nil
+	}
+
+	user := model.TaCustomer{}
+	user.Openid = openid
+
+	if data["sex"] != nil {
+		user.Sex = int(data["sex"].(float64))
+	}
+
+	if data["nickname"] != nil {
+		user.CustomerName = data["nickname"].(string)
+	}
+
+	if data["headimgurl"] != nil {
+		user.HeadImg = data["headimgurl"].(string)
+	}
+
+	if customer != nil && customer.CustomerId != "" {
+		user.CustomerId = customer.CustomerId
+		err = s.dao.UpdateCustomer(&user, []string{
+			"sex",
+			"customer_name",
+			"head_img",
+		})
+
+		if err != nil {
+			utils.LogError("修改用户信息失败", err)
+			return nil, err
+		}
+		return &user, nil
+	}
+
+	saveUser, err := s.dao.SaveCustomer(user)
+	if err != nil {
+		utils.LogError("保存用户信息失败", err)
+		return nil, err
+	}
+	return saveUser, nil
+}
+
+// SignUp 报名
+func (s *SupportServ) SignUp(customerid, name, phone, address string) (*model.TaCustomer, error) {
+	if customerid == "" {
+		return nil, errors.New("没有需要报名的用户信息")
+	}
+	customer, err := s.dao.GetCustomerByID(customerid)
+	if err != nil {
+		utils.LogError("获取用户信息失败", err)
+		return nil, err
+	}
+	customer.Phone = phone
+	customer.Name = name
+	customer.Address = address
+	err = s.dao.UpdateCustomer(customer, []string{
+		"name",
+		"phone",
+		"address",
+	})
+	if err != nil {
+		utils.LogError("报名失败：", err)
+		return nil, err
+	}
+	return customer, nil
+}
+
+// AddRecord 新增活动
+func (s *SupportServ) AddRecord(customerid, gameid string) (*model.TaGameRecord, error) {
+	game, err := s.dao.GetGameByID(gameid)
+	if err != nil {
+		utils.LogError("获取主信息信息失败", err)
+		return nil, err
+	}
+	if game.Status == models.STATUS_INVALID {
+		return nil, errors.New("活动已结束")
+	}
+	// 时间判断
+	if time.Now().Before(game.BeginDate) {
+		return nil, errors.New("活动未开始")
+	}
+	if time.Now().After(game.EndDate) {
+		return nil, errors.New("活动已结束")
+	}
+	todayNote, err := s.dao.GetGameNote(gameid)
+	if err != nil {
+		utils.LogError("获取活动设置信息失败：", err)
+		return nil, err
+	}
+	if todayNote == nil || todayNote.NotesId == "" {
+		utils.LogError("获取当天所有成功数据失败：", err)
+		return nil, errors.New("获取活动信息失败")
+	}
+	if todayNote.LeftNum <= 0 {
+		return nil, errors.New("今日活动已结束！请明日再来！")
+	}
+	// 判断当天是否已参与过活动
+	records, err := s.dao.GetTodayCustomerRecord(customerid, gameid)
+	if err != nil {
+		utils.LogError("判断当天是否参与过活动失败：", err)
+		return nil, err
+	}
+	if len(records) > 0 {
+		return nil, errors.New("您今天已参与过活动了，请明天再来吧！")
+	}
+	// 判断用户是否已成功
+	records, err = s.dao.GetCustomerQuota(customerid, gameid)
+	if err != nil {
+		utils.LogError("判断当天是否参与过活动失败：", err)
+		return nil, err
+	}
+	if len(records) > 0 {
+		return nil, errors.New("您已参加此次活动，请勿重复参加！")
+	}
+
+	var record = model.TaGameRecord{
+		CustomerId: customerid,
+		GameId:     gameid,
+		GameName:   game.GameName,
+	}
+
+	info, err := s.dao.AddRecord(record)
+	if err != nil {
+		utils.LogError("新增报名信息失败：", err)
+		return nil, err
+	}
+
+	return info, nil
+}
+
+// AddSupport 助力
+func (s *SupportServ) AddSupport(recordid, customerid string) (map[string]interface{}, error) {
+	// 判断活动是否已结束
+	record, err := s.dao.GetRecordByID(recordid)
+	if record.Status == models.STATUS_INVALID {
+		return nil, errors.New("当前活动已结束")
+	}
+	if record.Status == models.STATUS_NORMAL {
+		return nil, errors.New("当前活动已助力成功")
+	}
+	game, err := s.dao.GetGameByID(record.GameId)
+	if err != nil {
+		utils.LogError("获取活动信息失败：", err)
+		return nil, err
+	}
+	// 时间判断
+	if time.Now().Before(game.BeginDate) {
+		return nil, errors.New("活动未开始")
+	}
+	if time.Now().After(game.EndDate) {
+		return nil, errors.New("活动已结束")
+	}
+	// 判断用户信息
+	cust, err := s.dao.GetCustomerByID(customerid)
+	if err != nil {
+		utils.LogError("获取活动信息失败：", err)
+		return nil, err
+	}
+	if cust == nil || cust.CustomerId == "" {
+		return nil, errors.New("当前用户状态不正确！")
+	}
+	if cust.CustomerId == record.CustomerId {
+		return nil, errors.New("您不能给自己助力！")
+	}
+	// 判断是否助力过
+	support, err := s.dao.GetCustomerSupport(recordid, customerid)
+	if err != nil {
+		utils.LogError("获取用户助力信息失败：", err)
+		return nil, err
+	}
+	if len(support) > 0 {
+		return nil, errors.New("您已助力过此活动！")
+	}
+	// 助力
+	var addinfo = model.TaRecordSuppot{
+		RecordId:   recordid,
+		CustomerId: customerid,
+	}
+	info, err := s.dao.AddSupport(addinfo)
+	if err != nil {
+		utils.LogError("新增助力信息失败：", err)
+		return nil, err
+	}
+
+	supports, err := s.dao.GetSupportsByRecord(recordid)
+	if err != nil {
+		utils.LogError("获取助力信息失败：", err)
+		return nil, err
+	}
+	if len(supports) >= game.UserNum {
+		// 助力成功
+		record.Status = models.STATUS_NORMAL
+		err := s.dao.UpdateRecord(record, []string{
+			"status",
+		})
+		if err != nil {
+			utils.LogError("更新助力信息失败：", err)
+			return nil, err
+		}
+		// 更新当天的剩余次数
+		row, err := s.dao.UpdateLeftNum(record.GameId)
+		if err != nil {
+			utils.LogError("更新剩余天数失败：", err)
+			return nil, err
+		}
+		if row <= 0 {
+			return nil, errors.New("活动已结束")
+		}
+	}
+	return map[string]interface{}{
+		"record":  record,
+		"support": info,
+	}, nil
+}
+
+// GetRecordInfo 获取活动信息
+func (s *SupportServ) GetRecordInfo(recordid string) (map[string]interface{}, error) {
+	record, err := s.dao.GetRecordByID(recordid)
+	if err != nil {
+		utils.LogError("获取活动信息失败：", err)
+		return nil, err
+	}
+	supports, err := s.dao.GetSupportsByRecord(recordid)
+	if err != nil {
+		utils.LogError("获取助力信息失败：", err)
+		return nil, err
+	}
+	customer, err := s.dao.GetCustomerByID(record.CustomerId)
+	return map[string]interface{}{
+		"record":   record,
+		"supports": supports,
+		"customer": customer,
+	}, nil
+}
+
+// GetGameInfo 获取活动主信息
+func (s *SupportServ) GetGameInfo(gameid, customerid string) (map[string]interface{}, error) {
+	game, err := s.dao.GetGameByID(gameid)
+	if err != nil {
+		utils.LogError("获取主信息失败：", err)
+		return nil, err
+	}
+	note, err := s.dao.GetGameNote(gameid)
+	if err != nil {
+		utils.LogError("获取进入抽奖信息失败：", err)
+		return nil, err
+	}
+	// 获取用户的抽奖信息
+	records, err := s.dao.GetCustomerQuota(customerid, gameid)
+	if err != nil {
+		utils.LogError("获取用户抽奖信息失败：", err)
+		return nil, err
+	}
+	var nowRecord model.TaGameRecord
+	if len(records) > 0 {
+		nowRecord = records[0]
+	} else {
+		// 获取用户当天的抽奖信息
+		records, err = s.dao.GetTodayCustomerRecord(customerid, gameid)
+		if err != nil {
+			utils.LogError("获取用户当天抽奖信息失败：", err)
+			return nil, err
+		}
+		if len(records) > 0 {
+			nowRecord = records[0]
+		}
+	}
+
+	return map[string]interface{}{
+		"game":   game,
+		"note":   note,
+		"record": nowRecord,
+	}, nil
+}

service/game/voting.go

@@ -0,0 +1,72 @@
+package game
+
+import (
+	"errors"
+	"support-game/models/game"
+	"support-game/models/model"
+	"support-game/utils"
+)
+
+// VotingServ 活动serv
+type VotingServ struct {
+	ctx *utils.Context
+	dao *game.VotingModel
+}
+
+// NewVotingServ 初始化
+func NewVotingServ(ctx *utils.Context) *VotingServ {
+	return &VotingServ{
+		ctx: ctx,
+		dao: game.NewVotingModel(ctx),
+	}
+}
+
+// GetList 投票列表信息
+func (s *VotingServ) GetList(actID int, search string, orderby, page int) ([]game.MemInfo, error) {
+	list, err := s.dao.List(actID, search, orderby, page)
+	if err != nil {
+		utils.LogError("获取投票列表失败：", err)
+		return nil, errors.New("获取投票列表失败，请重试")
+	}
+	return list, nil
+}
+
+// GetActivitiesInfo 获取活动详情
+func (s *VotingServ) GetActivitiesInfo(actid int) (*model.TaVotingActivities, error) {
+	info, err := s.dao.GetActivityInfo(actid)
+	if err != nil {
+		utils.LogError("获取投票详情失败：", err)
+		return nil, errors.New("获取投票详情失败，请重试")
+	}
+	return info, nil
+}
+
+// GetMemberIndo 获取报名详情
+func (s *VotingServ) GetMemberInfo(actid, memberid int) (*game.MemInfo, error) {
+	info, err := s.dao.GetMemInfo(actid, memberid)
+	if err != nil {
+		utils.LogError("获取报名详情失败：", err)
+		return nil, errors.New("获取报名详情失败，请重试")
+	}
+	return info, nil
+}
+
+// Registe 报名
+func (s *VotingServ) Registe(memInfo *game.MemInfo) error {
+	err := s.dao.Registe(memInfo)
+	if err != nil {
+		utils.LogError("报名失败：", err)
+		return errors.New("操作失败，请重试")
+	}
+	return nil
+}
+
+// Vote 投票
+func (s *VotingServ) Vote(rec *model.TaVotingRecords) error {
+	err := s.dao.Vote(rec)
+	if err != nil {
+		utils.LogError("投票失败：", err)
+		return errors.New("操作失败，请重试")
+	}
+	return nil
+}

service/service.go

@@ -0,0 +1 @@
+package service

utils/aliyun.go

@@ -0,0 +1,81 @@
+package utils
+
+import (
+	"errors"
+	"net/http"
+	"strings"
+
+	"github.com/aliyun/aliyun-oss-go-sdk/oss"
+	"github.com/astaxie/beego"
+)
+
+var ossCli *oss.Client
+
+func OssInit() {
+	cert, err := beego.AppConfig.GetSection("alioss")
+	if err != nil {
+		LogError("读取阿里 OSS 配置失败: ", err)
+		return
+	}
+
+	OssClientSingleton(cert["Endpoint"], cert["AccessKeyId"], cert["AccessKeySecret"])
+}
+
+func OssClientSingleton(endpoint, accessKeyID, accessKeySecret string) {
+	if ossCli == nil {
+		var err error
+		ossCli, err = oss.New(endpoint, accessKeyID, accessKeySecret)
+		if err != nil {
+			LogError("初始化阿里 OSS 失败: ", err)
+		}
+	}
+}
+
+// GetOssClient 获取 OSS 客户端
+func GetOssClient() *oss.Client {
+	return ossCli
+}
+
+// UploadFileToBucket 简单上传文件
+func UploadFileToBucket(req *http.Request, fromFront string, nameSuffix ...string) (string, error) {
+	bucket := beego.AppConfig.String("alioss::Bucket")
+	endpoint := beego.AppConfig.String("alioss::Endpoint")
+
+	if ossCli == nil {
+		LogError("未成功初始化OSS 客户端")
+		return "", errors.New("未成功初始化OSS 客户端")
+	}
+
+	bkt, err := ossCli.Bucket(bucket)
+	if err != nil {
+		LogError("初始化OSS Bucket 失败: ", err)
+		return "", errors.New("初始化OSS Bucket 失败")
+	}
+
+	file, fh, err := req.FormFile(fromFront)
+	if err != nil {
+		LogError("读取文件失败: ", err)
+		return "", errors.New("未读取到文件或读取失败")
+	}
+	defer file.Close()
+
+	fname := fh.Filename
+	if len(nameSuffix) > 0 && nameSuffix[0] != "" {
+		fArr := strings.Split(fname, ".")
+		fArr[0] = fArr[0] + nameSuffix[0]
+		fname = strings.Join(fArr, ".")
+	}
+
+	err = bkt.PutObject(fname, file)
+	if err != nil {
+		LogError("上传文件到 OSS 失败: ", err)
+		return "", errors.New("上传文件到 OSS 失败")
+	}
+
+	return strings.Join([]string{
+		"http://",
+		bucket + ".",
+		endpoint + "/",
+		fname,
+	}, ""), nil
+}

utils/configer.go

@@ -0,0 +1,15 @@
+package utils
+
+import (
+	"github.com/astaxie/beego/config"
+)
+
+// GetConfiger 获取配置
+func GetConfiger(file string) (config.Configer, error) {
+	conf, err := config.NewConfig("ini", file)
+	if err != nil {
+		return nil, LogError("读取配置文件失败", err.Error())
+	}
+
+	return conf, nil
+}

utils/context.go

@@ -0,0 +1,59 @@
+package utils
+
+import (
+	"github.com/go-xorm/xorm"
+)
+
+// Context 上下文
+// 只限制在每次 Request 内
+type Context struct {
+	DB  *xorm.Session
+	box map[string]interface{}
+}
+
+// NewContext 初始化上下文
+func NewContext(engine *xorm.Engine, opt map[string]interface{}) *Context {
+	return &Context{
+		DB:  engine.NewSession(),
+		box: opt,
+	}
+}
+
+// Get 获取
+func (c *Context) Get(key string, def ...interface{}) interface{} {
+	if c.box != nil {
+		if opt, has := c.box[key]; has {
+			return opt
+		}
+	}
+
+	if len(def) > 0 {
+		return def[0]
+	}
+
+	return nil
+}
+
+// Set 设置
+func (c *Context) Set(key string, val interface{}) {
+	if c.box == nil {
+		c.box = make(map[string]interface{})
+	}
+
+	c.box[key] = val
+}
+
+// Ready Request 级别初始化
+func (c *Context) Ready() error {
+	// 开启事务
+	if err := c.DB.Begin(); err != nil {
+		return err
+	}
+
+	return nil
+}
+
+// Destroy 析构函数
+func (c *Context) Destroy() {
+	c.DB.Close()
+}

utils/guid.go

@@ -0,0 +1,10 @@
+package utils
+
+import (
+	"github.com/pborman/uuid"
+)
+
+// GetGUID 获取GUID
+func GetGUID() string {
+	return uuid.New()
+}

utils/log.go

@@ -0,0 +1,105 @@
+package utils
+
+import (
+	"errors"
+	"fmt"
+	"runtime"
+
+	"github.com/astaxie/beego/config"
+	"github.com/astaxie/beego/logs"
+)
+
+var instances = make(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", GetAppRoot()+"/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 {
+	log := instances["common"]
+
+	preMsg := ""
+	_, file, line, ok := runtime.Caller(1)
+	if ok {
+		preMsg = fmt.Sprintf("file: %s    line=%d : ", file, line)
+	}
+
+	log.Error(preMsg, v...)
+
+	if len(v) > 0 {
+		firstV := v[0]
+
+		switch err := firstV.(type) {
+		case string:
+			return errors.New(err)
+		case error:
+			return err
+		default:
+			msg := "Unknown error type"
+			return errors.New(msg)
+		}
+	}
+
+	return nil
+}
+
+// LogInfo Info 日志
+func LogInfo(v ...interface{}) {
+	log := instances["common"]
+
+	preMsg := ""
+	_, file, line, ok := runtime.Caller(1)
+	if ok {
+		preMsg = fmt.Sprintf("file: %s    line=%d : ", file, line)
+	}
+
+	log.Info(preMsg, v...)
+}
+
+// GetDefaultLogger 获取默认 logger
+func GetDefaultLogger() *logs.BeeLogger {
+	log := instances["common"]
+	log.SetLogFuncCallDepth(4)
+	return log
+}
+
+func LogInit() {
+	NewLog()
+}

utils/utils.go

@@ -0,0 +1,194 @@
+package utils
+
+import (
+	"encoding/base64"
+	"math/rand"
+	"net/http"
+	"os"
+	"path/filepath"
+	"runtime"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// 客户端类型
+const (
+	ClientAdmin  = "client-admin"
+	ClientWechat = "client-wechat"
+	ClientMini   = "client-mini"
+)
+
+// 一些 UA 列表
+const (
+	UAWechat      = "micromessenger"
+	UAMiniProgram = "miniprogram"
+)
+
+// GetClientType 获取客户端类型
+// 默认返回是 管理端
+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
+}
+
+// StrSliceIndexOf slice indexof
+func StrSliceIndexOf(s []string, t string) int64 {
+	if s == nil || len(s) == 0 {
+		return -1
+	}
+
+	for k, v := range s {
+		if v == t {
+			return int64(k)
+		}
+	}
+
+	return -1
+}
+
+// GUIID2IntString guid 转 int 字符串
+func GUIID2IntString(id string) []string {
+	if id == "" {
+		return nil
+	}
+
+	res := make([]string, 0)
+	for _, part := range strings.Split(id, "-") {
+		sum := 0
+		for _, r := range []rune(part) {
+			sum += int(r)
+		}
+
+		res = append(res, strconv.Itoa(sum))
+	}
+
+	return res
+}
+
+// EncodeBase64TrimTail base64 加密, 去除末尾 =
+func EncodeBase64TrimTail(src string) string {
+	if src == "" {
+		return ""
+	}
+
+	enStr := base64.StdEncoding.EncodeToString([]byte(src))
+
+	return strings.TrimRight(enStr, "=")
+}
+
+// DecodeBase64NoTail base64解密, 位数不够的, 自动补全
+func DecodeBase64NoTail(src string) string {
+	if src == "" {
+		return ""
+	}
+
+	pd := 4 - len(src)%4
+	if pd > 0 && pd != 4 {
+		src += strings.Repeat("=", pd)
+	}
+
+	res, err := base64.StdEncoding.DecodeString(src)
+	if err != nil {
+		LogError("解密 Base64 字串失败: " + err.Error())
+		return ""
+	}
+
+	return string(res)
+}
+
+// GetPageNaviLimit 获取 mysql limit 限定
+func GetPageNaviLimit(params ...int) []int {
+	page := 1
+	pagesize := 10
+
+	if params != nil {
+		pl := len(params)
+
+		if pl > 0 {
+			page = params[0]
+			if page < 1 {
+				page = 1
+			}
+		}
+
+		if pl > 1 {
+			pagesize = params[1]
+		}
+	}
+
+	return []int{
+		pagesize,
+		(page - 1) * pagesize,
+	}
+}
+
+// GenerateQRCode 生成二维码数字
+func GenerateQRCode() string {
+	var temp1 int = rand.Intn(9)*87 + 11
+	var temp2 int = rand.Intn(9)*89 + 13
+	nano := time.Now().UnixNano()
+	var nanostr string = strconv.FormatInt(nano, 10)
+	var temp3 string = nanostr[11:]
+	var temp4 string = "6"
+	var temp5 int = rand.Intn(9)*7 + 17
+	var code string = "66" + strconv.Itoa(temp1) + temp4 + strconv.Itoa(temp2) + temp3 + strconv.Itoa(temp5)
+	return code
+}
+
+// GetFiveSeconds 获取 5 秒钟的时间
+func GetFiveSeconds(t time.Time) string {
+	str := t.Format("20060102150405")
+	strLen := len(str)
+
+	lastNum, _ := strconv.Atoi(str[strLen-1:])
+	if lastNum < 5 {
+		lastNum = 0
+	} else {
+		lastNum = 5
+	}
+
+	return str[:strLen-1] + strconv.Itoa(lastNum)
+}
+
+// 当前运行环境
+var processEnv string
+var appRoot string
+
+// GetAppRoot 获取系统根目录
+func GetAppRoot() string {
+	if appRoot != "" {
+		return appRoot
+	}
+
+	if processEnv == "" {
+		for _, arg := range os.Args {
+			if strings.Index(arg, "-test.run") > -1 {
+				processEnv = "test"
+				break
+			}
+		}
+
+		if processEnv == "" {
+			processEnv = "production"
+		}
+	}
+
+	if processEnv == "test" {
+		_, file, _, _ := runtime.Caller(1)
+		appRoot, _ = filepath.Abs(filepath.Dir(filepath.Join(file, ".."+string(filepath.Separator))))
+	} else {
+		appRoot, _ = filepath.Abs(filepath.Dir(os.Args[0]))
+	}
+
+	return appRoot
+}

utils/wechat.go

@@ -0,0 +1,37 @@
+package utils
+
+import (
+	"github.com/astaxie/beego"
+	"github.com/zjxpcyc/wechat/wx"
+)
+
+var client *wx.Client
+
+// WxClientSingleton 初始化
+func WxClientSingleton(cert map[string]string) {
+	client = wx.NewClient(cert)
+}
+
+// WxClient 微信实例
+func WxClient() *wx.Client {
+	return client
+}
+
+// 初始化微信
+func InitWechat() {
+	appRoot := GetAppRoot()
+
+	wechatConf, _ := GetConfiger(appRoot + "/conf/wechat.conf")
+	if wechatConf == nil {
+		return
+	}
+	cert := map[string]string{
+		"appid":  wechatConf.String("appid"),
+		"secret": wechatConf.String("secret"),
+		"token":  wechatConf.String("token"),
+		"aeskey": "",
+		"wxid":   wechatConf.String("wxid"),
+	}
+	beego.Error(cert)
+	WxClientSingleton(cert)
+}