1

.gitignore

@@ -2,7 +2,6 @@
 
 jx-callback
 *.tmp
-swagger/
 debug
 .DS_Store
 *.log

business/jxstore/cms/api_print.go

@@ -268,6 +268,10 @@ func DelPrinter(appID int, printNos []string, storeId string) (err error) {
 	return err
 }
 
+func QueryPrintList(printNo, printKey string, status, isOnline int64, page, size int64) ([]*model.Printer, int, error) {
+	prints, count, err := dao.QueryPrintList(dao.GetDB(), printNo, printKey, status, isOnline, page, size)
+	return prints, count, err
+}
 func UpdatePrinter(appID int, printNo string, name, sim, sound *string, volume *int) (err error) {
 	var (
 		db     = dao.GetDB()

business/jxstore/event/event_tcp.go

@@ -83,27 +83,12 @@ func handleConn(c net.Conn) error {
 				for ip, pn := range PrintAddrAndIp.PrintObject {
 					if ip == printRemoteAddr {
 						PrintAddrAndIp.DelPrintAddrAndIp(printRemoteAddr)
-					} else if pn != "" {
-						printStatusOff[pn] = 1
-					}
-				}
-
-				for pn, ip := range PrintIpAndAddr.PrintObject {
-					if ip == printRemoteAddr {
 						PrintIpAndAddr.DelPrintIpAndAddr(pn)
+						PrintObject.DelPrintObj(printNo)
 					} else if pn != "" {
 						printStatusOff[pn] = 1
 					}
 				}
-
-				globals.SugarLogger.Debugf("----可能存活打印机打印机:%s", utils.Format4Output(printStatusOff, false))
-				for pn, _ := range PrintObject.PrintObject {
-					if printStatusOff[pn] != 1 {
-						globals.SugarLogger.Debugf("----已经不存在但是未删除打印机:%s", pn)
-						PrintObject.DelPrintObj(pn)
-					}
-				}
-
 			}
 			return err
 		}
@@ -370,11 +355,11 @@ func HandleCheckTcpHeart(t *TcpClient, key string) {
 			}
 		}
 	} else {
-		globals.SugarLogger.Debugf("-------close1 := %s", key)
 		t.getClients(key).C.Close()
 		close(t.MsgMap[key])
 		close(t.CallBackMap[key])
-		t.delConn(key)
+		//t.delConn(key)
+		t.clear(key)
 
 		// 链接出错,彻底删除换成
 		if printRemoteAddrIP, have := PrintIpAndAddr.GetPrintIpAndAddr(key); have {

business/jxstore/event/event_tcp_utils.go

@@ -159,7 +159,6 @@ func (t *TcpClient) clear(key string) {
 	t.Lock()
 	defer t.Unlock()
 	t.Clients[key].C.Close()
-	globals.SugarLogger.Debugf("-------close3 := %s", key)
 	delete(t.Clients, key)
 	close(t.MsgMap[key])
 	delete(t.MsgMap, key)

business/jxstore/event/timing_task.go

@@ -47,9 +47,11 @@ func (w *Worker) Start() {
 }
 
 func (w *Worker) Stop() {
-	go func() {
-		w.quit <- true
-	}()
+	w.quit <- true
+	close(w.quit)
+	//go func() {
+	//	w.quit <- true
+	//}()
 }
 
 func NewPool(numWorkers int) *Pool {
@@ -79,14 +81,24 @@ func (p *Pool) Stop() {
 	}
 }
 
+//
+//func (p *Pool) AddJob(job Job) {
+//	p.wg.Add(1)
+//	p.jobChannel <- func() {
+//		job()
+//		p.wg.Done()
+//	}
+//}
+
 func (p *Pool) AddJob(job Job) {
 	p.wg.Add(1)
-	p.jobChannel <- func() {
-		job()
-		p.wg.Done()
-	}
+	go func() {
+		p.jobChannel <- func() {
+			defer p.wg.Done()
+			job()
+		}
+	}()
 }
-
 func (p *Pool) Wait() {
 	p.wg.Wait()
 }

business/model/dao/dao_print.go

@@ -124,3 +124,39 @@ func DeletePrintMsg() {
 	globals.SugarLogger.Debugf("定时删除超过一个月的打印信息:%d 条", num)
 	return
 }
+
+func QueryPrintList(db *DaoDB, printNo, printKey string, status, isOnline int64, page, size int64) (print []*model.Printer, count int, err error) {
+	sql := `
+		SELECT SQL_CALC_FOUND_ROWS * FROM printer WHERE 1=1 
+	`
+	sqlParams := []interface{}{}
+	if printNo != "" {
+		sql += ` AND print_no = ?`
+		sqlParams = append(sqlParams, printNo)
+	}
+	if printKey != "" {
+		sql += ` AND print_key = ?`
+		sqlParams = append(sqlParams, printKey)
+	}
+	if status != model.PrintMsgAll {
+		sql += ` AND status = ?`
+		sqlParams = append(sqlParams, status)
+	}
+	if isOnline != model.PrintMsgAll {
+		sql += ` AND is_online = ?`
+		sqlParams = append(sqlParams, isOnline)
+	}
+	sql += ` AND deleted_at = ?`
+	sqlParams = append(sqlParams, utils.DefaultTimeValue)
+	sql += ` ORDER BY status desc,is_online desc LIMIT ? OFFSET ? `
+	sqlParams = append(sqlParams, size, page)
+	tx, _ := Begin(db)
+	if err = GetRowsTx(tx, &print, sql, sqlParams...); err != nil {
+		Rollback(db, tx)
+		return nil, 0, err
+	}
+	count = GetLastTotalRowCountTx(tx)
+	defer Commit(db, tx)
+
+	return print, count, err
+}

business/q_bida/express_test.go

@@ -21,7 +21,7 @@ func TestQueryExpressPrice(t *testing.T) {
 		SendPhone:       "18981810340",
 		ChannelType:     2,
 	}
-	data,err := QueryExpressPrice(param)
+	data, err := QueryExpressPrice(param)
 	fmt.Println(err)
 	fmt.Println(data)
 }

controllers/api_controller.go

@@ -218,6 +218,43 @@ func (c *ApiController) AddPrinter(dataMap map[string]interface{}) (data, errCod
 	return "", errCode, err
 }
 
+type QueryPrintList struct {
+}
+
+func (c *ApiController) QueryPrintList(dataMap map[string]interface{}) (data map[string]interface{}, errCode string, err error) {
+	var (
+		printNo  string
+		printKey string
+		status   int64
+		isOnline int64
+		page     int64
+		size     int64
+	)
+
+	if printNoParam, ok := dataMap["print_no"].(string); !ok {
+		printNo = ""
+	} else {
+		printNo = printNoParam
+	}
+	if key, ok := dataMap["print_key"].(string); !ok {
+		printKey = ""
+	} else {
+		printKey = key
+	}
+
+	status = utils.Interface2Int64WithDefault(dataMap["status"], -9)
+	isOnline = utils.Interface2Int64WithDefault(dataMap["is_online"], -9)
+	page = utils.Interface2Int64WithDefault(dataMap["page"], 0)
+	size = utils.Interface2Int64WithDefault(dataMap["size"], 15)
+
+	list, count, err := cms.QueryPrintList(printNo, printKey, status, isOnline, page, size)
+	data = map[string]interface{}{
+		"printList": list,
+		"count":     count,
+	}
+	return
+}
+
 //删除打印机绑定
 func (c *ApiController) DelPrinter(dataMap map[string]interface{}) (data, errCode string, err error) {
 	var (

main.go

@@ -29,10 +29,10 @@ import (
 	_ "git.rosy.net.cn/jx-callback/business/auth2/authprovider/mobile"
 	_ "git.rosy.net.cn/jx-callback/business/auth2/authprovider/password"
 	_ "git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
-	_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/jds"
-	_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/mt"
-	_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/pdd"
-	_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/taobao"
+	//_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/jds"
+	//_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/mt"
+	//_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/pdd"
+	//_ "git.rosy.net.cn/jx-callback/business/jxstore/partner/taobao"
 	_ "git.rosy.net.cn/jx-callback/globals/api"
 
 	_ "git.rosy.net.cn/jx-callback/routers"

tests/default_test.go

@@ -10,7 +10,6 @@ import (
 	_ "git.rosy.net.cn/jx-callback/routers"
 
 	"github.com/astaxie/beego"
-	. "github.com/smartystreets/goconvey/convey"
 )
 
 func init() {