试着处理connmap

business/jxstore/event/event_tcp.go

@@ -3,7 +3,9 @@ package event
 import (
 	"encoding/hex"
 	"fmt"
+	"git.rosy.net.cn/jx-callback/business/model/dao"
 	"git.rosy.net.cn/jx-callback/globals"
+	"github.com/astaxie/beego/client/orm"
 	"io"
 	"net"
 	"strconv"
@@ -18,8 +20,6 @@ const (
 )
 
 var (
-	//广播频道(通道)
-	msgChan   = make(chan string)
 	tcpClient = &TcpClient{}
 )
 
@@ -54,7 +54,9 @@ func listenTcp() {
 func handleConn(c net.Conn) {
 	var (
 		printNo string //打印机编号
+		db      = dao.GetDB()
 	)
+	db.Db = orm.NewOrmUsingDB("api") //读写这个库
 	if c == nil {
 		globals.SugarLogger.Debugf("conn is nil")
 		return
@@ -84,9 +86,9 @@ func handleConn(c net.Conn) {
 		} else if strings.Contains(data, printText) {
 			//证明是打印成功
 			if strings.Contains(data, printSuccessText) {
-
+				//打印成功改变打印表的状态
 			} else {
-
+				//打印失败也改变状态并更新失败原因
 			}
 		}
 	}
@@ -94,8 +96,7 @@ func handleConn(c net.Conn) {
 
 func handleTcpMessages() {
 	for {
-		//读取通道中的消息
-		//msg := <-msgChan
+
 	}
 }
 

globals/beegodb/beegodb.go

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