zhangqian
2023-10-20 50fdb4bc0545136c14b7b1b50c55430e5c8d970a
nsq/msg_handler.go
@@ -82,31 +82,22 @@
         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
            }
            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 {
                  logx.Errorf(" save task message error err2: %v", err)
                  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 {