From d74cd8ed4ce995294c7f65b02742d07d7a420474 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 20 十月 2023 16:13:56 +0800 Subject: [PATCH] add log --- nsq/msg_handler.go | 8 +++++++- 1 files changed, 7 insertions(+), 1 deletions(-) diff --git a/nsq/msg_handler.go b/nsq/msg_handler.go index 423b7ac..dd90080 100644 --- a/nsq/msg_handler.go +++ b/nsq/msg_handler.go @@ -82,19 +82,25 @@ var err error if oldWorkOrder != nil && oldWorkOrder.WorkOrderID != "" { if err = model.NewOrderSearch(db).SetId(oldWorkOrder.ID).Updates(&orderRecord); err != nil { + logx.Errorf(" save task message error err1: %v", err) return err } for _, procedure := range procedureRecords { err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Upsert(procedure) if err != nil { + logx.Errorf(" save task message error err2: %v", err) return err } } } else { if err = model.NewOrderSearch(db).Create(&orderRecord); err != nil { + logx.Errorf(" save task message error err3: %v", err) return err } - return model.NewProceduresSearch(db).CreateBatch(procedureRecords) + if err = model.NewProceduresSearch(db).CreateBatch(procedureRecords); err != nil { + logx.Errorf(" save task message error err4: %v", err) + return err + } } return nil }) -- Gitblit v1.8.0