liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-06-28 18:51:29 +08:00
parent 274b9c7cba
commit fabdf33a3a
4 changed files with 7 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
business/jxstore/event/event_tcp.go
View File

@@ -7,7 +7,6 @@ import (
"git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model"
"git.rosy.net.cn/jx-callback/business/model/dao" "git.rosy.net.cn/jx-callback/business/model/dao"
"git.rosy.net.cn/jx-callback/globals" "git.rosy.net.cn/jx-callback/globals"
"github.com/astaxie/beego/client/orm"
"io" "io"
"net" "net"
"strconv" "strconv"
@@ -48,12 +47,7 @@ type TcpClient struct {
s *sync.RWMutex s *sync.RWMutex
} }
func Init() { func ListenTcp() {
listenTcp()
go handleTcpMessages()
}
func listenTcp() {
tcpClient.Clients = make(map[string]net.Conn) tcpClient.Clients = make(map[string]net.Conn)
l, err := net.Listen("tcp", ":8000") l, err := net.Listen("tcp", ":8000")
if err != nil { if err != nil {
@@ -76,7 +70,6 @@ func handleConn(c net.Conn) {
printNo string //打印机编号 printNo string //打印机编号
db = dao.GetDB() db = dao.GetDB()
) )
db.Db = orm.NewOrmUsingDB("api") //读写这个库
if c == nil { if c == nil {
globals.SugarLogger.Debugf("conn is nil") globals.SugarLogger.Debugf("conn is nil")
return return
@@ -145,14 +138,13 @@ func changePrintMsg(db *dao.DaoDB, data string) (err error) {
return err return err
} }
func handleTcpMessages() { func HandleTcpMessages() {
var ( var (
db = dao.GetDB() db = dao.GetDB()
offset, pageSize = 0, 10 offset, pageSize = 0, 10
c net.Conn c net.Conn
data []byte data []byte
) )
db.Db = orm.NewOrmUsingDB("api") //读写这个库
for { for {
//一直读？ //一直读？
var err error var err error

2
conf/app.conf
View File

@@ -275,7 +275,7 @@ pddAppSecret = "fa40c1fe356eebc1376ace1d2380ed44e553c602"
httpport = 8088 httpport = 8088
EnableDocs = false EnableDocs = false
dbConnectStr = "root:WebServer@1@tcp(127.0.0.1:3306)/jxd_dev_0?charset=utf8mb4&loc=Local&parseTime=true" dbConnectStr = "root:WebServer@1@tcp(gold1.jxc4.com:3306)/api?charset=utf8mb4&loc=Local&parseTime=true"
enableStoreWrite = true enableStoreWrite = true
enableJdStoreWrite = true enableJdStoreWrite = true

2
globals/beegodb/beegodb.go
View File

@@ -10,7 +10,7 @@ import (
func Init() { func Init() {
// set default database // set default database
orm.RegisterDataBase("default", "mysql", beego.AppConfig.String("dbConnectStr")) orm.RegisterDataBase("default", "mysql", beego.AppConfig.String("dbConnectStr"))
orm.RegisterDataBase("api", "mysql", "root:WebServer@1@tcp(gold1.jxc4.com:3306)/api?charset=utf8mb4&loc=Local&parseTime=true") //orm.RegisterDataBase("api", "mysql", "root:WebServer@1@tcp(gold1.jxc4.com:3306)/api?charset=utf8mb4&loc=Local&parseTime=true")
//用户 //用户
orm.RegisterModel(&model.AuthBind{}, &model.User{}) orm.RegisterModel(&model.AuthBind{}, &model.User{})

5
main.go
View File

@@ -115,8 +115,8 @@ func main() {
} }
} }
}) })
cms.ResetJobTimers()
} }
cms.ResetJobTimers()
if beego.BConfig.RunMode != "prod" { if beego.BConfig.RunMode != "prod" {
beego.BConfig.WebConfig.DirectoryIndex = true beego.BConfig.WebConfig.DirectoryIndex = true
beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger" beego.BConfig.WebConfig.StaticDir["/swagger"] = "swagger"
@@ -129,7 +129,8 @@ func main() {
} }
}() }()
if globals.IsPrintEnv() { if globals.IsPrintEnv() {
event.Init() event.ListenTcp()
go event.HandleTcpMessages()
} }
beego.Run() beego.Run()
} }