Golang 入門系列（十三）用Beego開發web應用

時間 2019-11-06

標籤 golang 入門系列十三 beego 開發 web 應用欄目 Go 简体版

原文原文鏈接

接着以前的內容，前面已經講過不少Golang的基礎語法，mysql的使用，redis的使用，也講了orm框架，如何建立一個webapi 服務等等，感興趣的能夠看看之前的文章，https://www.cnblogs.com/zhangweizhong/category/1275863.html，css

今天要來講一說，如何用beego開發web應用。html

介紹

beego 是一個快速開發 Go 應用的 HTTP 框架，他能夠用來快速開發 API、Web 及後端服務等各類應用，是一個 RESTful 的框架，同時也是一個關注度和使用量都比價高的開源項目。我認爲它是go初學者比較容易上手的一門MVC Web框架。mysql

它是由國內團隊開發的開源框架，文檔基本都是中文，簡單易懂。git

安裝

　　須要安裝 Beego 和 Bee 的開發工具:github

$ go get github.com/astaxie/beego
$ go get github.com/beego/bee

　　注意：web

beege和bee是兩個概念。beego是框架，bee是工具，是命令。
在安裝Beego前，先確認是否將$GOPATH/bin寫入GO環境中。

建立應用

　　建立一個名爲webDemo的應用redis

$ bee new webDemo     //建立一個web應用
$ bee api webDemo     //建立一個api應用

編譯運行

　　進入webDemo目錄中，執行bee run，就會完成編譯、運行：sql

$ bee run

　　成功後，打開瀏覽器訪問：http://localhost:8080,能夠看到如圖：數據庫

開發

　　以上就beego 的安裝和運行簡單的介紹完了，下面咱們就經過訂單查詢和新增的例子來學習學習如何用beego開發web應用。後端

　　通常的 beego 項目的目錄以下所示：

├── conf           //配置文件
│   └── app.conf
├── controllers    //控制器
│   └── default.go
├── main.go   
├── models         //模型   
│   └── models.go
├── routers       //路由
│   └──router.go
├── static         //靜態文件
│   ├── css
│   ├── ico
│   ├── img
│   └── js
└── views          //界面
    └── index.tpl

conf

　　在app.conf 中增長數據庫鏈接配置

appname = webDemo
httpport = 8080 runmode = dev DBConn="root:root@tcp(localhost:3306)/zwz_test?charset=utf8"

controller

　　在controller目錄下，增長pay.go

package controllers

import (
        "webDemo/models"
)

func (c *MainController) PayQuery() {
    AccountID, _ := c.GetInt64("AccountID1")
    payment, _ := models.GetPaymenRec(AccountID)
    c.Data["AccountID"] = payment.AccountID
    c.Data["PartnerID"] = payment.PartnerID
    c.Data["UserID"] = payment.UserID
    c.Data["CreateTime"] = payment.CreateTime
    c.Data["Amount"] = payment.Amount
    c.Data["OuterTradeNo"] = payment.OuterTradeNo
    c.Data["Remark"] = payment.Remark
    c.Data["Status"] = payment.Status
    c.Data["Msg"] = payment.Msg
    c.TplName = "query.html"
}
func (c *MainController) PayAdd() {
    var payment models.PaymentRecordStr
    c.ParseForm(&payment)
    pay, _ := models.AddPaymenRec(payment)
    c.Data["AccountID"] = pay.AccountID
    c.Data["PartnerID"] = pay.PartnerID
    c.Data["UserID"] = pay.UserID
    c.Data["CreateTime"] = pay.CreateTime
    c.Data["Amount"] = pay.Amount
    c.Data["OuterTradeNo"] = pay.OuterTradeNo
    c.Data["Remark"] = pay.Remark
    c.TplName = "query.html"
}

models

　　1. 在models目錄下，增長pay.go

package models

import (
    "database/sql"
    "errors"

    "strconv"
    "time"

    "github.com/astaxie/beego" _ "github.com/go-sql-driver/mysql" ) var Db *sql.DB type PaymentRecord struct { Id int64 AccountID int64 PartnerID string UserID string CreateTime string Amount float64 OuterTradeNo string Remark string Status int Msg string } type PaymentRecordStr struct { AccountID string PartnerID string UserID string CreateTime string Amount string OuterTradeNo string Remark string } func init() { dbconn := beego.AppConfig.String("DBConn") db, err := sql.Open("mysql", dbconn) if err != nil { return } db.SetMaxOpenConns(2000) db.SetMaxIdleConns(0) db.Ping() Db = db } func Close() { if Db != nil { Db.Close() } } func AddPaymenRec(rec PaymentRecordStr) (PaymentRecord, error) { var isql = "INSERT pay_demo SET account_id=?,partner_id=?,user_id=?,amount=?,outer_tradeno=?,remark=?" AccountID, _ := strconv.ParseInt(rec.AccountID, 10, 64) Amount, _ := strconv.ParseFloat(rec.Amount, 64) response := PaymentRecord{0, AccountID, rec.PartnerID, rec.UserID, rec.CreateTime, Amount, rec.OuterTradeNo, rec.Remark, 0, ""} if Db == nil { return response, errors.New("AddPaymenRec connect mysql failed") } stmt, _ := Db.Prepare(isql) defer stmt.Close() beego.Informational("AddPaymenRec rec=%#v", rec) res, err := stmt.Exec(AccountID, rec.PartnerID, rec.UserID, Amount, rec.OuterTradeNo, rec.Remark) if err == nil { response.Id, _ = res.LastInsertId() response.Status = 1 response.Msg = "已生效" return response, nil } return response, nil } func GetPaymenRec(AccountID int64) (PaymentRecord, error) { var qsql = "SELECT * FROM pay_demo WHERE account_id=?" var response PaymentRecord response.Msg = "失敗" if AccountID != 0 { if Db == nil { return response, errors.New("GetPaymenRec connect mysql failed") } stmt, _ := Db.Prepare(qsql) rows, err := stmt.Query(AccountID) defer rows.Close() if err != nil { return response, err } var timedate string for rows.Next() { err = rows.Scan(&response.Id, &response.AccountID, &response.PartnerID, &response.UserID, &timedate, &response.Amount, &response.OuterTradeNo, &response.Remark) if err != nil { return response, err } DefaultTimeLoc := time.Local loginTime, err := time.ParseInLocation("2006-01-02 15:04:05", timedate, DefaultTimeLoc) if err == nil { unix_time := loginTime.Unix() //time to int64 response.CreateTime = time.Unix(unix_time, 0).Format("2006-01-02 15:04:05") response.Status = 2 response.Msg = "成功" return response, err } else { return response, err } } return response, nil } return response, errors.New("GetPaymenRec Requset is non porinter") }

　　 2. 在數據庫中，增長pay_demo表

CREATE TABLE `pay_demo` (
  `id` int(64) NOT NULL AUTO_INCREMENT,
  `account_id` int(64) NOT NULL,
  `partner_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL,
  `user_id` varchar(50) CHARACTER SET utf8 DEFAULT NULL,
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP,
  `amount` double DEFAULT '0',
  `outer_tradeno` varchar(50) CHARACTER SET utf8 DEFAULT NULL,
  `remark` varchar(255) CHARACTER SET utf8 DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=5024 DEFAULT CHARSET=utf8 COLLATE=utf8_bin;

views

　　將原有的index.tpl 刪除，增長新的index.html 和query.html

index.html

<!DOCTYPE html>

<html>
<head>
    <title>webDemo</title>
    <meta http-equiv="Content-Type" content="text/html; charset=utf-8">
</head>

<body>
<div>
    <form action="/query" method="Post">
        <div>
            GetPaymentBy AccountID:<input  type="text" name="AccountID1" />
        </div>

        <div>
            <input type= "submit" name="n" />
        </div>
    </form>
    <br/>
    <br/>
    <form action="/add" method="Post">
        <div>
            AccountID:<input  type="text" name="AccountID" />
        </div>
        <div>
            PartnerID:<input  type="text" name="PartnerID" />
        </div>
        <div>
            UserID   :<input  type="text" name="UserID" />
        </div>
        <div>
            CreateTime:<input  type="text" name="CreateTime" />
        </div>
        <div>
            Amount:<input  type="text" name="Amount" />
        </div>
        <div>
            OuterTradeNo:<input  type="text" name="OuterTradeNo" />
        </div>
        <div>
            Remark:<input  type="text" name="Remark" />
        </div>

        <div>
            <input type= "submit" name="add" value="添加"/>
        </div>
    </form>

</div>
</body>
</html>

query.html

<!DOCTYPE html>

<html>
<head>
  <title>BeegoDemo</title>
  <meta http-equiv="Content-Type" content="text/html; charset=utf-8">  
</head>

<body>
  <div>        
        <div>
            Payment:
        </div>
        <div>
        AccountID:{{.AccountID}}
        </div>
        <div>
        PartnerID:{{.PartnerID}}
        </div>
        <div>
        UserID:{{.UserID}}
        </div>
        <div>
        CreateTime:{{.CreateTime}}
        </div>
        <div>
        Amount:{{.Amount}}
        </div>
        <div>        
        OuterTradeNo:{{.OuterTradeNo}}
        </div>
            <div>
        Remark:{{.Remark}}
        </div>
            

  </div>
</body>
</html>

routers

　　在router.go 中增長以上新增的2個路由

package routers

import (
    "webDemo/controllers"
    "github.com/astaxie/beego"
)

func init() {
    beego.Router("/query", &controllers.MainController{}, "Post:PayQuery")        // 新增PayQuery路由
    beego.Router("/add", &controllers.MainController{}, "Post:PayAdd")　　　　　　　// 新增PayAdd路由
    beego.Router("/", &controllers.MainController{})
}