aa

business/jxstore/event/event_tcp.go

@@ -373,10 +373,10 @@ func HandleTcpMessages() {
 		prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
 		for _, printMsg := range prints {
 			printMsgChan <- printMsg
-			select {
-			case data, _ := <-printMsgCallbackChan:
-				changePrintMsg(data)
-			}
+			//select {
+			//case data, _ := <-printMsgCallbackChan:
+			//	changePrintMsg(data)
+			//}
 		}
 	}
 }
@@ -385,6 +385,11 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
 	var (
 		db = dao.GetDB()
 	)
+	for {
+		select {
+		case data, _ := <-printMsgCallbackChan:
+			changePrintMsg(data)
+		default:
 			select {
 			case printMsg, _ := <-printMsgChan:
 				var (
@@ -433,6 +438,8 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
 					}
 				}
 			}
+		}
+	}
 	return err
 }