zhangqian
2023-10-20 663a2c112e4d907478a13d3201329630f61ed5e1
nsq/msg_handler.go
@@ -85,6 +85,7 @@
               logx.Errorf(" save task message error err1: %v", err)
               return err
            }
            logx.Errorf(" save task message error no err1: %v", err)
            for _, procedure := range procedureRecords {
               err = model.NewProceduresSearch(db).SetWorkOrderId(procedure.WorkOrderID).SetProcedureId(procedure.ProcedureID).Upsert(procedure)
               if err != nil {
@@ -92,16 +93,20 @@
                  return err
               }
            }
            logx.Errorf(" save task message error no err2: %v", err)
         } else {
            if err = model.NewOrderSearch(db).Create(&orderRecord); err != nil {
               logx.Errorf(" save task message error err3: %v", err)
               return err
            }
            logx.Errorf(" save task message error no err3: %v", err)
            if err = model.NewProceduresSearch(db).CreateBatch(procedureRecords); err != nil {
               logx.Errorf(" save task message error err4: %v", err)
               return err
            }
            logx.Errorf(" save task message error no err4: %v", err)
         }
         logx.Errorf(" save task message error no err5: %v", err)
         return nil
      })
      if err != nil {