first commit

.gitignore

@@ -0,0 +1,5 @@
+*.exe
+*.exe~
+*.zip
+*.tmp
+annual-lottery

conf/app.conf

@@ -0,0 +1,7 @@
+appname = annual-lottery
+httpport = 8080
+runmode = dev
+autorender = false
+copyrequestbody = true
+EnableDocs = true
+sessionon = true

conf/db.conf

@@ -0,0 +1,29 @@
+; 数据库类型，目前只支持mysql
+db_type      = mysql
+
+; 连接协议
+con_protocol = tcp
+
+; 数据库地址，可以使用IP
+db_addr      = 47.101.36.130
+
+; 端口
+db_port      = 3306
+
+; 用户名
+username     = annual_lottery
+
+; 密码
+password     = annual_lottery
+
+; 数据库名或者schema
+database     = annual_lottery
+
+; 前缀，目前尚未使用
+dbprefix     = 
+
+; 模式，目前尚未使用
+db_debug     = false
+
+; 字符集
+char_set     = utf8

controllers/base.go

@@ -0,0 +1,94 @@
+package controllers
+
+import (
+	"annual-lottery/utils"
+	"bytes"
+	"errors"
+	"reflect"
+	"time"
+
+	"github.com/astaxie/beego"
+
+	"net/http"
+	"net/url"
+)
+
+//Message api统一的返回消息格式
+type Message struct {
+	Code    int         `json:"code"`
+	Message interface{} `json:"message"`
+}
+
+//BaseController 基础controller
+type BaseController struct {
+	beego.Controller
+}
+
+const (
+	SESSION_USER = "h5.user"
+	PAGENUM      = 10
+	LISTPAGENUM  = 20
+)
+
+// BaseControllerInterface 项目约定的 Controller 须满足的接口
+type BaseControllerInterface interface {
+	Constructor()
+}
+
+//Prepare 继承beego的
+func (c *BaseController) Prepare() {
+	// 路由对应的实际 Controller 初始化
+	c.initController()
+}
+
+// ResponseJson 自定义的JSON返回
+func (c *BaseController) ResponseJson(msg interface{}, code ...int) {
+	status := http.StatusOK
+	if len(code) > 0 {
+		status = code[0]
+	}
+
+	if reflect.ValueOf(msg).Type().String() == "*errors.errorString" {
+		err := msg.(error)
+		if status == http.StatusOK {
+			status = http.StatusInternalServerError
+		}
+
+		c.Data["json"] = Message{status, err.Error()}
+	} else {
+		c.Data["json"] = Message{status, msg}
+	}
+
+	c.ServeJSON()
+	c.StopRun()
+}
+
+// initAppController 执行当前路由请求对应的 Controller 初始化
+func (c *BaseController) initController() {
+	if ctrl, ok := c.AppController.(BaseControllerInterface); ok {
+		ctrl.Constructor()
+	}
+}
+
+// SaveToExcel 保存文件到 excel
+// 文件不落地, 对内存开销比较大, 如果文件过大, 服务可能会崩掉
+func (c *BaseController) SaveToExcel(fn string, excel *utils.TinyXLSXEngine) {
+	var buf bytes.Buffer
+	if err := excel.Write(&buf); err != nil {
+		beego.Error("写 xlsx buffer 失败: " + err.Error())
+		c.ResponseJson(errors.New("生成 excel 异常, 请重试"))
+	}
+
+	c.Ctx.Output.Header("Content-Disposition", "attachment; filename="+url.QueryEscape(fn))
+	c.Ctx.Output.Header("Content-Description", "File Transfer")
+	c.Ctx.Output.ContentType(".xlsx")
+	c.Ctx.Output.Header("Content-Transfer-Encoding", "binary")
+	c.Ctx.Output.Header("Expires", "0")
+	c.Ctx.Output.Header("Cache-Control", "must-revalidate")
+	c.Ctx.Output.Header("Pragma", "public")
+
+	r := bytes.NewReader(buf.Bytes())
+	http.ServeContent(c.Ctx.ResponseWriter, c.Ctx.Request, fn, time.Now().Local(), r)
+
+	c.StopRun()
+}

controllers/lottery.go

@@ -0,0 +1,272 @@
+package controllers
+
+import (
+	"annual-lottery/models"
+	"annual-lottery/models/model"
+	"annual-lottery/utils"
+	"encoding/json"
+	"errors"
+	"net/http"
+	"strconv"
+
+	"github.com/astaxie/beego"
+)
+
+// LotteryController 基础controller
+type LotteryController struct {
+	dao *models.LotteryModel
+	BaseController
+}
+
+// Constructor 初始化
+func (c *LotteryController) Constructor() {
+	c.dao = new(models.LotteryModel)
+}
+
+// UserList 获取人员名单
+// @router /user [get]
+func (c *LotteryController) UserList() {
+	users, err := c.dao.UserList()
+	if err != nil {
+		beego.Error("获取人员名单失败,", err)
+		c.ResponseJson(errors.New("获取人员名单失败"))
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"users": users,
+	})
+}
+
+// PrizeSettingList 获取抽奖设置列表
+// @router /setting/prize [get]
+func (c *LotteryController) PrizeSettingList() {
+	ps, err := c.dao.PrizeSettingList()
+	if err != nil {
+		beego.Error("获取抽奖设置列表失败,", err)
+		c.ResponseJson(errors.New("获取抽奖设置列表失败"))
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"settings": ps,
+	})
+}
+
+// PrizeSetting 抽奖设置
+// @router /setting/prize/?:id [post,put,delete]
+func (c *LotteryController) PrizeSetting() {
+	id := c.GetString(":id")
+	bt := []byte(c.GetString("data"))
+
+	ps := model.TaPrizeSetting{}
+	mp := make(map[string]interface{})
+	if err := json.Unmarshal(bt, &mp); err != nil {
+		beego.Error("转换抽奖设置数据失败,", err)
+		c.ResponseJson(errors.New("接收抽奖配置失败"))
+	}
+
+	utils.Map2Struct(mp, &ps)
+
+	switch c.Ctx.Input.Method() {
+	case http.MethodPost:
+		ps.SettingId = 0
+		if err := c.dao.PrizeSetting(&ps, models.DATA_ADD); err != nil {
+			beego.Error("新增抽奖设置失败,", err)
+			c.ResponseJson(errors.New("新增抽奖设置失败"))
+		}
+	case http.MethodPut:
+		if id == "" {
+			c.ResponseJson(errors.New("抽奖设置ID不能为空"), http.StatusBadRequest)
+		}
+
+		ps.SettingId, _ = strconv.Atoi(id)
+		if err := c.dao.PrizeSetting(&ps, models.DATA_UPDATE); err != nil {
+			beego.Error("更新抽奖设置失败,", err)
+			c.ResponseJson(errors.New("更新抽奖设置失败"))
+		}
+	case http.MethodDelete:
+		if id == "" {
+			c.ResponseJson(errors.New("抽奖设置ID不能为空"), http.StatusBadRequest)
+		}
+
+		ps.PrizeId, _ = strconv.Atoi(id)
+		if err := c.dao.PrizeSetting(&ps, models.DATA_DELETE); err != nil {
+			beego.Error("删除抽奖设置失败,", err)
+			c.ResponseJson(errors.New("删除抽奖设置失败"))
+		}
+	default:
+		c.ResponseJson(errors.New("404"), http.StatusNotFound)
+	}
+
+	// 返回最新结果
+	c.PrizeSettingList()
+}
+
+// Draw 抽奖
+// @router /draw [post]
+func (c *LotteryController) Draw() {
+	pw, err := c.dao.Draw()
+	if err != nil {
+		beego.Error("抽奖失败,", err)
+		c.ResponseJson(errors.New("抽奖失败, 请重试"))
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"winner": pw,
+	})
+}
+
+// PrizeList 奖品列表
+// @router /prize [get]
+func (c *LotteryController) PrizeList() {
+	pl, err := c.dao.PrizeList()
+	if err != nil {
+		beego.Error("获取奖品列表失败,", err)
+		c.ResponseJson(errors.New("获取奖品列表失败"))
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"prizes": pl,
+	})
+}
+
+// PrizeEdit 奖品维护
+// @router /prize/?:id [post,put,delete]
+func (c *LotteryController) PrizeEdit() {
+	id := c.GetString(":id")
+	bt := []byte(c.GetString("data"))
+
+	ps := model.TaPrize{}
+	mp := make(map[string]interface{})
+	if err := json.Unmarshal(bt, &mp); err != nil {
+		beego.Error("转换奖品数据失败,", err)
+		c.ResponseJson(errors.New("接收奖品数据失败"))
+	}
+
+	utils.Map2Struct(mp, &ps)
+
+	switch c.Ctx.Input.Method() {
+	case http.MethodPost:
+		ps.PrizeId = 0
+		if err := c.dao.PrizeEdit(&ps, models.DATA_ADD); err != nil {
+			beego.Error("新增奖品数据失败,", err)
+			c.ResponseJson(errors.New("新增奖品数据失败"))
+		}
+	case http.MethodPut:
+		if id == "" {
+			c.ResponseJson(errors.New("奖品数据ID不能为空"), http.StatusBadRequest)
+		}
+
+		ps.PrizeId, _ = strconv.Atoi(id)
+		if err := c.dao.PrizeEdit(&ps, models.DATA_UPDATE); err != nil {
+			beego.Error("更新奖品数据失败,", err)
+			c.ResponseJson(errors.New("更新奖品数据失败"))
+		}
+	case http.MethodDelete:
+		if id == "" {
+			c.ResponseJson(errors.New("奖品数据ID不能为空"), http.StatusBadRequest)
+		}
+
+		ps.PrizeId, _ = strconv.Atoi(id)
+		if err := c.dao.PrizeEdit(&ps, models.DATA_DELETE); err != nil {
+			beego.Error("删除奖品数据失败,", err)
+			c.ResponseJson(errors.New("删除奖品数据失败"))
+		}
+	default:
+		c.ResponseJson(errors.New("404"), http.StatusNotFound)
+	}
+
+	// 返回最新结果
+	c.PrizeList()
+}
+
+// WinnerList 中奖人员名单
+// @router /winner [get]
+func (c *LotteryController) WinnerList() {
+	typ := c.GetString("type")
+	name := c.GetString("name")
+	delStr := c.GetString("del")
+	del, _ := strconv.Atoi(delStr)
+
+	var wl []model.TaPrizeWinner
+	var err error
+
+	if delStr == "" {
+		wl, err = c.dao.WinnerList(typ, name)
+		if err != nil {
+			beego.Error("获取中奖人员名单失败,", err)
+			c.ResponseJson(errors.New("获取中奖人员名单失败"))
+		}
+	} else {
+		wl, err = c.dao.WinnerList(typ, name, del)
+		if err != nil {
+			beego.Error("获取中奖人员名单失败,", err)
+			c.ResponseJson(errors.New("获取中奖人员名单失败"))
+		}
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"winners": wl,
+	})
+}
+
+// CancelWinner 作废中奖人员
+// @router /winner/:uid [delete]
+func (c *LotteryController) CancelWinner() {
+	pid, _ := c.GetInt("pid")
+	uid, _ := c.GetInt(":uid")
+
+	if err := c.dao.CancelWinner(pid, uid); err != nil {
+		beego.Error("作废中奖人员失败,", err)
+		c.ResponseJson(errors.New("作废中奖人员失败"))
+	}
+
+	c.ResponseJson(map[string]interface{}{
+		"result": "success",
+	})
+}
+
+// ExportWinners 导出中奖名单
+// @router /excel/winner [get]
+func (c *LotteryController) ExportWinners() {
+	typ := c.GetString("type")
+	del := models.STATUS_NORMAL
+
+	wl, err := c.dao.WinnerList(typ, "", del)
+	if err != nil {
+		beego.Error("获取中奖人员名单失败,", err)
+		c.ResponseJson(errors.New("获取中奖人员名单失败"))
+	}
+
+	excel, err := utils.NewTinyXLSXEngine()
+	if err != nil {
+		beego.Error("导出中奖人员名单失败,", err)
+		c.ResponseJson(errors.New("导出中奖人员名单失败"))
+	}
+
+	excel.SetCell(
+		excel.InsertRow(),
+		[]string{
+			"序号",
+			"中奖人",
+			"公司",
+			"部门",
+			"分类",
+			"奖品",
+		},
+	)
+
+	for k, w := range wl {
+		row := excel.InsertRow()
+
+		excel.SetCell(row, []string{
+			strconv.Itoa(k + 1),
+			w.UserName,
+			w.UserOrg,
+			w.UserDept,
+			w.PrizeType,
+			w.PrizeName,
+		})
+	}
+
+	c.SaveToExcel("中奖名单.xlsx", excel)
+}

main.go

@@ -0,0 +1,15 @@
+package main
+
+import (
+	_ "annual-lottery/routers"
+
+	"github.com/astaxie/beego"
+)
+
+func main() {
+	if beego.BConfig.RunMode == "dev" {
+		beego.BConfig.WebConfig.DirectoryIndex = true
+		beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
+	}
+	beego.Run()
+}

models/lottery.go

@@ -0,0 +1,188 @@
+package models
+
+import (
+	"annual-lottery/models/model"
+	"annual-lottery/utils"
+	"time"
+)
+
+const (
+	STATUS_DELETE = iota - 1
+	STATUS_READY
+	STATUS_NORMAL
+)
+
+const (
+	DATA_DELETE = iota - 1
+	DATA_ADD
+	DATA_UPDATE
+)
+
+// LotteryModel model
+type LotteryModel struct{}
+
+// UserList 用户列表
+func (m *LotteryModel) UserList() ([]model.TaUser, error) {
+	users := make([]model.TaUser, 0)
+	err := Dao.Asc("user_id").Find(&users)
+	return users, err
+}
+
+// PrizeSettingList 奖品设置列表
+func (m *LotteryModel) PrizeSettingList() ([]model.TaPrizeSetting, error) {
+	ps := make([]model.TaPrizeSetting, 0)
+
+	err := Dao.Desc("create_date").Find(&ps)
+	return ps, err
+}
+
+// PrizeSetting 抽奖设置维护
+func (m *LotteryModel) PrizeSetting(s *model.TaPrizeSetting, typ int) error {
+	switch typ {
+	case DATA_ADD:
+		s.SettingId = 0
+		s.Status = STATUS_NORMAL
+		s.CreateDate = time.Now().Local()
+		_, err := Dao.Insert(s)
+		return err
+	case DATA_UPDATE:
+		cols := []string{"prize_id", "is_repeat", "prize_num", "status"}
+		_, err := Dao.Cols(cols...).Where("setting_id=?", s.SettingId).Update(s)
+		return err
+	default:
+		return nil
+	}
+}
+
+// Draw 抽奖
+// 因为没有库存的概念，因此奖品中奖后, 不会把奖品表中的数量减一
+func (m *LotteryModel) Draw() ([]model.TaPrizeWinner, error) {
+	// 获取当前可用抽奖设置
+	setting := model.TaPrizeSetting{}
+	if _, err := Dao.Where("status=?", STATUS_NORMAL).Get(&setting); err != nil {
+		return nil, err
+	}
+
+	// 获取奖品
+	prize := model.TaPrize{}
+	if _, err := Dao.Where("prize_id=?", setting.PrizeId).Get(&prize); err != nil {
+		return nil, err
+	}
+
+	// 获取参与抽奖人员
+	users := make([]model.TaUser, 0)
+	query := `select * from ta_user t`
+	if setting.IsRepeat == 0 {
+		// 如果不允许多次中奖
+		query += ` where not exists (
+			select * from ta_prize_winner s where t.user_id = s.user_id
+		)`
+	}
+	if err := Dao.SQL(query).Find(&users); err != nil {
+		return nil, err
+	}
+
+	pws := make([]model.TaPrizeWinner, 0)
+	randIDs := make([]int, 0)
+	randID := -1
+	for i := 0; i < setting.PrizeNum; i++ {
+		// 获取中奖人员
+		for {
+			randID = utils.RandNum(len(users))
+			if utils.IntSliceIndex(randIDs, randID) > -1 {
+				randIDs = append(randIDs, randID)
+				break
+			}
+		}
+
+		winner := users[randID]
+
+		// 组合中奖信息
+		pw := model.TaPrizeWinner{
+			UserId:     winner.UserId,
+			UserName:   winner.UserName,
+			UserOrg:    winner.UserOrg,
+			UserDept:   winner.UserDept,
+			PrizeId:    prize.PrizeId,
+			PrizeName:  prize.PrizeName,
+			PrizeType:  prize.PrizeType,
+			SettingId:  setting.SettingId,
+			Status:     STATUS_NORMAL,
+			CreateDate: time.Now().Local(),
+		}
+
+		pws = append(pws, pw)
+	}
+
+	// 更新抽奖配置
+	if _, err := Dao.Cols("status").
+		Update(&model.TaPrizeSetting{SettingId: setting.SettingId, Status: STATUS_NORMAL}); err != nil {
+		return nil, err
+	}
+
+	// 保存记录
+	if _, err := Dao.Insert(&pws); err != nil {
+		return nil, err
+	}
+
+	return pws, nil
+}
+
+// PrizeEdit 奖品维护
+func (m *LotteryModel) PrizeEdit(p *model.TaPrize, typ int) error {
+	switch typ {
+	case DATA_ADD:
+		p.CreateDate = time.Now().Local()
+		_, err := Dao.Insert(p)
+		return err
+	case DATA_UPDATE:
+		cols := []string{"prize_type", "prize_name", "picture", "stock"}
+		_, err := Dao.Cols(cols...).Where("prize_id=?", p.PrizeId).Update(p)
+		return err
+	default:
+		return nil
+	}
+}
+
+// PrizeList 奖品列表
+func (m *LotteryModel) PrizeList() ([]model.TaPrize, error) {
+	ps := make([]model.TaPrize, 0)
+	err := Dao.Desc("create_date").Find(&ps)
+	return ps, err
+}
+
+// WinnerList 中奖人员名单
+// typ 奖品类型
+// name 用户名称
+// del 是否有效记录
+func (m *LotteryModel) WinnerList(typ, name string, del ...int) ([]model.TaPrizeWinner, error) {
+	ws := make([]model.TaPrizeWinner, 0)
+	query := Dao.Where("1=1")
+
+	if typ != "" {
+		query = query.And("prize_type like '%" + typ + "%'")
+	}
+
+	if name != "" {
+		query = query.And("user_name like '%" + name + "%'")
+	}
+
+	if len(del) > 0 {
+		query = query.And("status=?", del[0])
+	}
+
+	err := query.Asc("prize_type").Desc("create_date").Find(&ws)
+	return ws, err
+}
+
+// CancelWinner 作废中奖人员
+func (m *LotteryModel) CancelWinner(prizeID, userID int) error {
+	// 作废记录
+	pw := model.TaPrizeWinner{Status: STATUS_DELETE}
+	if _, err := Dao.Cols("status").Where("prize_id=?", prizeID).
+		And("user_id=?", userID).Update(&pw); err != nil {
+		return err
+	}
+
+	return nil
+}

models/model/ta_prize.go

@@ -0,0 +1,12 @@
+package model
+
+import "time"
+
+type TaPrize struct {
+	PrizeId    int       `xorm:"not null pk autoincr INT(11)"`
+	PrizeType  string    `xorm:"VARCHAR(100)"`
+	PrizeName  string    `xorm:"VARCHAR(300)"`
+	Picture    string    `xorm:"TEXT"`
+	Stock      int       `xorm:"INT(11)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+}

models/model/ta_prize_setting.go

@@ -0,0 +1,12 @@
+package model
+
+import "time"
+
+type TaPrizeSetting struct {
+	SettingId  int       `xorm:"not null pk autoincr INT(11)"`
+	PrizeId    int       `xorm:"INT(11)"`
+	IsRepeat   int       `xorm:"SMALLINT(6)"`
+	PrizeNum   int       `xorm:"INT(11)"`
+	Status     int       `xorm:"SMALLINT(6)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+}

models/model/ta_prize_winner.go

@@ -0,0 +1,17 @@
+package model
+
+import "time"
+
+type TaPrizeWinner struct {
+	RecId      int       `xorm:"not null pk autoincr INT(11)"`
+	UserId     int       `xorm:"INT(11)"`
+	UserName   string    `xorm:"VARCHAR(200)"`
+	UserOrg    string    `xorm:"VARCHAR(300)"`
+	UserDept   string    `xorm:"VARCHAR(300)"`
+	PrizeId    int       `xorm:"INT(11)"`
+	PrizeName  string    `xorm:"VARCHAR(200)"`
+	PrizeType  string    `xorm:"VARCHAR(100)"`
+	SettingId  int       `xorm:"INT(11)"`
+	Status     int       `xorm:"INT(11)"`
+	CreateDate time.Time `xorm:"DATETIME"`
+}

models/model/ta_user.go

@@ -0,0 +1,8 @@
+package model
+
+type TaUser struct {
+	UserId   int    `xorm:"not null pk INT(11)"`
+	UserName string `xorm:"VARCHAR(100)"`
+	UserOrg  string `xorm:"VARCHAR(300)"`
+	UserDept string `xorm:"VARCHAR(300)"`
+}

models/models.go

@@ -0,0 +1,57 @@
+package models
+
+import (
+	"github.com/astaxie/beego/config"
+	_ "github.com/go-sql-driver/mysql"
+	"github.com/go-xorm/xorm"
+)
+
+var (
+	Dao *xorm.Engine
+)
+
+func init() {
+	Dao = NewDAO()
+}
+
+// NewDAO 初始化数据库连接
+func NewDAO() *xorm.Engine {
+	dbType := "mysql"
+	dns := getMysqlDns()
+
+	dao, err := xorm.NewEngine(dbType, dns)
+	// dao.ShowSQL()
+
+	if err != nil {
+		panic(err)
+		return nil
+	}
+
+	Dao = dao
+	return dao
+}
+
+func getMysqlDns() string {
+	dbconf, _ := config.NewConfig("ini", "conf/db.conf")
+
+	// db_type  := dbconf.DefaultString("db_type", "mysql")
+	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")
+	// dbprefix := dbconf.String("dbprefix")
+	// db_debug := dbconf.DefaultBool("db_debug", false)
+	charSet := dbconf.DefaultString("char_set", "utf8")
+
+	dns := userName
+
+	if len(password) > 0 {
+		dns += ":" + password
+	}
+
+	dns += "@" + conProt + "(" + dbAddr + ":" + dbPort + ")" + "/" + database + "?charset=" + charSet
+
+	return dns
+}

routers/commentsRouter_controllers.go

@@ -0,0 +1,82 @@
+package routers
+
+import (
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/context/param"
+)
+
+func init() {
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "Draw",
+			Router: `/draw`,
+			AllowHTTPMethods: []string{"post"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "ExportWinners",
+			Router: `/excel/winner`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "PrizeList",
+			Router: `/prize`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "PrizeEdit",
+			Router: `/prize/?:id`,
+			AllowHTTPMethods: []string{"post","put","delete"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "PrizeSettingList",
+			Router: `/setting/prize`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "PrizeSetting",
+			Router: `/setting/prize/?:id`,
+			AllowHTTPMethods: []string{"post","put","delete"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "UserList",
+			Router: `/user`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "WinnerList",
+			Router: `/winner`,
+			AllowHTTPMethods: []string{"get"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+	beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"] = append(beego.GlobalControllerRouter["annual-lottery/controllers:LotteryController"],
+		beego.ControllerComments{
+			Method: "CancelWinner",
+			Router: `/winner/:uid`,
+			AllowHTTPMethods: []string{"delete"},
+			MethodParams: param.Make(),
+			Params: nil})
+
+}

routers/router.go

@@ -0,0 +1,23 @@
+// @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 (
+	"annual-lottery/controllers"
+
+	"github.com/astaxie/beego"
+)
+
+func init() {
+	ns := beego.NewNamespace("/api",
+		beego.NSInclude(&controllers.LotteryController{}),
+	)
+	beego.AddNamespace(ns)
+
+	// beego.Router("/", &controllers.BaseController{}, "*:Index")
+}

tests/default_test.go

@@ -0,0 +1,37 @@
+package test
+
+import (
+	_ "annual-lottery/routers"
+	"net/http"
+	"net/http/httptest"
+	"path/filepath"
+	"runtime"
+	"testing"
+
+	"github.com/astaxie/beego"
+	. "github.com/smartystreets/goconvey/convey"
+)
+
+func init() {
+	_, file, _, _ := runtime.Caller(1)
+	apppath, _ := filepath.Abs(filepath.Dir(filepath.Join(file, ".."+string(filepath.Separator))))
+	beego.TestBeegoInit(apppath)
+}
+
+// TestGet is a sample to run an endpoint test
+func TestGet(t *testing.T) {
+	r, _ := http.NewRequest("GET", "/v1/object", nil)
+	w := httptest.NewRecorder()
+	beego.BeeApp.Handlers.ServeHTTP(w, r)
+
+	beego.Trace("testing", "TestGet", "Code[%d]\n%s", w.Code, w.Body.String())
+
+	Convey("Subject: Test Station Endpoint\n", t, func() {
+		Convey("Status Code Should Be 200", func() {
+			So(w.Code, ShouldEqual, 200)
+		})
+		Convey("The Result Should Not Be Empty", func() {
+			So(w.Body.Len(), ShouldBeGreaterThan, 0)
+		})
+	})
+}

utils/excel.go

@@ -0,0 +1,55 @@
+package utils
+
+import (
+	"errors"
+	"io"
+	"reflect"
+
+	"github.com/astaxie/beego"
+
+	"github.com/tealeg/xlsx"
+)
+
+// TinyXLSXEngine 简版 xlsx 处理器
+type TinyXLSXEngine struct {
+	xlsxFile *xlsx.File
+	sheet    *xlsx.Sheet
+}
+
+// NewTinyXLSXEngine init
+func NewTinyXLSXEngine() (*TinyXLSXEngine, error) {
+	file := xlsx.NewFile()
+
+	sheet, err := file.AddSheet("sheet1")
+	if err != nil {
+		beego.Error("创建 xlsx sheet 失败: " + err.Error())
+		return nil, errors.New("创建 xlsx sheet 失败")
+	}
+
+	return &TinyXLSXEngine{
+		xlsxFile: file,
+		sheet:    sheet,
+	}, nil
+}
+
+// InsertRow 新增行
+func (t *TinyXLSXEngine) InsertRow() *xlsx.Row {
+	return t.sheet.AddRow()
+}
+
+// SetCell 新增数据
+func (t *TinyXLSXEngine) SetCell(row *xlsx.Row, v interface{}) {
+	rv := reflect.ValueOf(v)
+	if rv.Kind() == reflect.Slice {
+		for i := 0; i < rv.Len(); i++ {
+			row.AddCell().SetValue(rv.Index(i).Interface())
+		}
+	} else {
+		row.AddCell().SetValue(v)
+	}
+}
+
+// Write 写数据
+func (t *TinyXLSXEngine) Write(w io.Writer) error {
+	return t.xlsxFile.Write(w)
+}

utils/map2struct.go

@@ -0,0 +1,28 @@
+package utils
+
+import (
+	"reflect"
+)
+
+// Map2Struct map 转 struct
+// 必须保证 s 为 stuct 指针
+func Map2Struct(m map[string]interface{}, s interface{}) {
+	sv := reflect.ValueOf(s).Elem()
+
+	for k, t := range m {
+		f := sv.FieldByName(k)
+
+		if !f.IsValid() {
+			continue
+		}
+
+		switch v := t.(type) {
+		case string:
+			f.SetString(v)
+		case float64:
+			f.SetInt(int64(v))
+		default:
+			continue
+		}
+	}
+}

utils/random.go

@@ -0,0 +1,12 @@
+package utils
+
+import (
+	"math/rand"
+	"time"
+)
+
+// RandNum 生成一个 [0, max) 的随机数
+func RandNum(max int) int {
+	src := rand.NewSource(time.Now().UnixNano())
+	return rand.New(src).Intn(max)
+}

utils/slice.go

@@ -0,0 +1,12 @@
+package utils
+
+// IntSliceIndex 返回值 -1 未找到, 正数为 index
+func IntSliceIndex(is []int, s int) int {
+	for k, v := range is {
+		if v == s {
+			return k
+		}
+	}
+
+	return -1
+}