1

business/jxstore/event/event_tcp.go

@@ -181,6 +181,11 @@ func (t *TcpClient) HandleTcpMessages(printNo string) {
 		}
 	}()
 }
+func (t *TcpClient) readTimeoutMap(key string) bool {
+	t.Lock()
+	defer t.Unlock()
+	return <-t.TimeoutMap[key]
+}
 
 func (t *TcpClient) doPrint(key string) (err error) {
 	var (
@@ -191,11 +196,10 @@ func (t *TcpClient) doPrint(key string) (err error) {
 	}
 	go func() {
 		for {
-			select {
-			case <-t.TimeoutMap[key]:
+			if t.readTimeoutMap(key) {
 				globals.SugarLogger.Debugf("doPrint timeout")
 				return
-			default:
+			} else {
 				select {
 				case printMsg, ok := <-t.MsgMap[key]:
 					if !ok {
@@ -286,6 +290,101 @@ func (t *TcpClient) doPrint(key string) (err error) {
 					}
 				}
 			}
+			//select {
+			//case <-t.TimeoutMap[key]:
+			//	globals.SugarLogger.Debugf("doPrint timeout")
+			//	return
+			//default:
+			//	select {
+			//	case printMsg, ok := <-t.MsgMap[key]:
+			//		if !ok {
+			//			globals.SugarLogger.Debugf("doPrint err !ok ...")
+			//			return
+			//		}
+			//		var (
+			//			data []byte
+			//			c    net.Conn
+			//		)
+			//		if printMsg != nil {
+			//			if err = checkPrintMsg(db, printMsg); err == nil {
+			//				status := t.getPrintStatus(printMsg.PrintNo)
+			//				switch status {
+			//				//只有在线才打印内容
+			//				case printerStatusOnline:
+			//					if c = t.getPrintConn(printMsg.PrintNo); c != nil {
+			//						data, err = buildMsg(printMsg)
+			//					}
+			//				case printerStatusOffline:
+			//					err = fmt.Errorf("打印机离线！")
+			//				case printerStatusOnlineWithoutPaper:
+			//					err = fmt.Errorf("打印机缺纸！")
+			//				default:
+			//					err = fmt.Errorf("打印机状态未知！")
+			//				}
+			//			}
+			//			if err != nil {
+			//				//t.delConn(printMsg.PrintNo)
+			//				printMsg.Status = printMsgErr
+			//				printMsg.Comment = err.Error()
+			//				dao.UpdateEntity(db, printMsg, "Status", "Comment")
+			//				close(t.TimeoutMap[key])
+			//			} else {
+			//				if c != nil {
+			//					encryption := ""
+			//					for _, v := range data {
+			//						encryption += fmt.Sprintf("%d", v)
+			//					}
+			//					printMsg.ContentEncryption = encryption
+			//
+			//					dao.UpdateEntity(db, printMsg, "ContentEncryption")
+			//					if _, err = c.Write(data); err != nil {
+			//						globals.SugarLogger.Debugf("handleTcpMessages err [%v]", err)
+			//						//t.delConn(printMsg.PrintNo)
+			//						close(t.TimeoutMap[key])
+			//					} else {
+			//						//等待回调
+			//						dataStr := <-t.CallBackMap[printMsg.PrintNo]
+			//						if dataStr != "" {
+			//							a, b := getCallbackMsgInfo(dataStr)
+			//							t.changePrintMsg(dataStr, a, b)
+			//							// 查询打印机是否扣费,未扣费就扣费,已经扣费不做处理
+			//							have, err := dao.QueryOrderDeductionRecord(db, b, utils.Int64ToStr(a))
+			//							if err != nil && !have {
+			//								// 扣除打印机账号金额
+			//								if err = dao.DeductionPrintBalance(db, b); err != nil {
+			//									globals.SugarLogger.Debugf("扣除用户打印机金额错误 %s", err)
+			//								} else {
+			//									// 添加打印记录(支出记录)
+			//									if err = dao.AddPrintRecord(db, &model.PrintBillRecord{
+			//										CreatedAt: time.Now(),
+			//										UpdatedAt: time.Now(),
+			//										PrintNo:   b,
+			//										PayType:   2,
+			//										PayMoney:  1, // 固定支出一分钱
+			//										OrderId:   utils.Int64ToStr(a),
+			//										UserId:    "",
+			//									}); err != nil {
+			//										globals.SugarLogger.Debugf("添加打印机订单支付记录错误 %s", err)
+			//									}
+			//								}
+			//							} else {
+			//								globals.SugarLogger.Debugf("查询打印机扣费记录错误 %s", err)
+			//							}
+			//							//判断音频暂停？
+			//							//收到打印成功回调后，如果消息中有音频，需要等待一下,等上一个音频播完
+			//							//暂停时间就暂时取的sound标签内内容长度/2
+			//							if sounds := regexpSoundSpan.FindStringSubmatch(printMsg.Content); len(sounds) > 0 {
+			//								sound := sounds[1]
+			//								lenTime := time.Duration(utf8.RuneCountInString(sound)) * time.Second
+			//								time.Sleep(lenTime / 2)
+			//							}
+			//						}
+			//					}
+			//				}
+			//			}
+			//		}
+			//	}
+			//}
 		}
 	}()
 	return err