diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index ee79ba6da..a4582d26e 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -252,7 +252,6 @@ func changePrintMsg(data string) (err error) { printNo, comment string orderNo int64 status int - printMsg = &model.PrintMsg{} ) //1、先找出打印机编号和订单序列号,这两个确定唯一一条消息 orderNo = h8l82int(data[len(data)-6:len(data)-4], data[len(data)-4:len(data)-2]) @@ -270,15 +269,17 @@ func changePrintMsg(data string) (err error) { if tcpClient.Clients[printNo] == nil { return err } - if printMsg, err = dao.GetPrintMsg(db, printNo, orderNo); err != nil { + if printMsgs, err := dao.GetPrintMsgNoPage(db, printNo, orderNo); err != nil { globals.SugarLogger.Debugf("changePrintMsg err :[%v]", err) return - } else if printMsg == nil { + } else if len(printMsgs) == 0 { globals.SugarLogger.Debugf("changePrintMsg err ,not found printMsg printNo:[%v], orderNo :[%v]", printNo, orderNo) - } else if printMsg.Status != status { - printMsg.Comment = comment - printMsg.Status = status - dao.UpdateEntity(db, printMsg, "Comment", "Status") + } else if len(printMsgs) > 0 { + for _, v := range printMsgs { + v.Comment = comment + v.Status = status + dao.UpdateEntity(db, v, "Comment", "Status") + } } return err } diff --git a/business/model/dao/dao_print.go b/business/model/dao/dao_print.go index bb18cdca6..6b9f2a73f 100644 --- a/business/model/dao/dao_print.go +++ b/business/model/dao/dao_print.go @@ -6,7 +6,7 @@ import ( "time" ) -func GetPrintMsg(db *DaoDB, printNo string, orderNo int64) (prints *model.PrintMsg, err error) { +func GetPrintMsgNoPage(db *DaoDB, printNo string, orderNo int64) (prints []*model.PrintMsg, err error) { sql := ` SELECT * FROM print_msg