From 34f4368bc7a60362342960bf2751955637509072 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Mon, 28 Jun 2021 14:39:38 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=95=E7=9D=80=E5=A4=84=E7=90=86connmap?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 business/jxstore/event/event_tcp.go | 13 +++++++------
 globals/beegodb/beegodb.go          |  2 +-
 2 files changed, 8 insertions(+), 7 deletions(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index 0e902dfd1..5c4f4795a 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/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
+
 	}
 }
 
diff --git a/globals/beegodb/beegodb.go b/globals/beegodb/beegodb.go
index 165f00f72..bb063fc78 100644
--- a/globals/beegodb/beegodb.go
+++ b/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{})