销售明细不推送wms

liujiandao

2024-02-06 fe675a31074e9ff012d29387336dc35de3ba46f2

 proto/crm_aps/server.go

@@ -5,7 +5,6 @@
   "aps_crm/model"
   "aps_crm/model/grpc_init"
   "aps_crm/pkg/ecode"
   "aps_crm/proto/product_inventory"
   "aps_crm/service"
   "context"
   "errors"
@@ -77,38 +76,38 @@
      }

      //推送到wms
      clientName := ""
      if detail.ClientId > 0 {
         first, err := model.NewClientSearch(nil).SetId(detail.ClientId).First()
         if err == nil {
            clientName = first.Name
         }
      }
      wmsProducts := make([]*product_inventory.InventoryProduct, 0)
      for _, product := range detail.Products {
         var p product_inventory.InventoryProduct
         p.Id = product.Number
         p.Amount = product.Amount.String()
         wmsProducts = append(wmsProducts, &p)
      }
      clientWms := product_inventory.NewProductInventoryServiceClient(grpc_init.ProductInventoryServiceConn)
      _, err = clientWms.CreateOperation(ctx, &product_inventory.CreateOperationRequest{
         Number:      detail.Number,
         Addressee:   detail.Addressee,
         Address:     detail.Address,
         Phone:       detail.Phone,
         DeliverType: int32(detail.DeliverType),
         Source:      "CRM",
         ClientId:    int64(detail.ClientId),
         ClientName:  clientName,
         ProductList: wmsProducts,
      })
      if err != nil {
         //状态还原
         m["status"] = constvar.WaitConfirmed
         _ = model.NewSalesDetailsSearch().SetNumber(detail.Number).UpdateByMap(m)
         return nil, err
      }
      //clientName := ""
      //if detail.ClientId > 0 {
      //   first, err := model.NewClientSearch(nil).SetId(detail.ClientId).First()
      //   if err == nil {
      //      clientName = first.Name
      //   }
      //}
      //wmsProducts := make([]*product_inventory.InventoryProduct, 0)
      //for _, product := range detail.Products {
      //   var p product_inventory.InventoryProduct
      //   p.Id = product.Number
      //   p.Amount = product.Amount.String()
      //   wmsProducts = append(wmsProducts, &p)
      //}
      //clientWms := product_inventory.NewProductInventoryServiceClient(grpc_init.ProductInventoryServiceConn)
      //_, err = clientWms.CreateOperation(ctx, &product_inventory.CreateOperationRequest{
      //   Number:      detail.Number,
      //   Addressee:   detail.Addressee,
      //   Address:     detail.Address,
      //   Phone:       detail.Phone,
      //   DeliverType: int32(detail.DeliverType),
      //   Source:      "CRM",
      //   ClientId:    int64(detail.ClientId),
      //   ClientName:  clientName,
      //   ProductList: wmsProducts,
      //})
      //if err != nil {
      //   //状态还原
      //   m["status"] = constvar.WaitConfirmed
      //   _ = model.NewSalesDetailsSearch().SetNumber(detail.Number).UpdateByMap(m)
      //   return nil, err
      //}

      //推送到aps
      products := make([]*SalesDetailsProduct, 0)