1

business/jxstore/event/event_tcp.go

@@ -226,6 +226,8 @@ func (t *TcpClient) doPrint(key string) (err error) {
 						c    net.Conn
 					)
 					if printMsg != nil {
+						time.Sleep(2 * time.Second)
+						globals.SugarLogger.Debugf("printMsg ... %s", utils.Format4Output(printMsg, false))
 						if err = checkPrintMsg(db, printMsg); err == nil {
 							status := t.getPrintStatus(printMsg.PrintNo)
 							switch status {
@@ -304,104 +306,11 @@ func (t *TcpClient) doPrint(key string) (err error) {
 								}
 							}
 						}
+					} else {
+						globals.SugarLogger.Debugf("msgMap is nil")
 					}
 				}
 			}
-			//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