| | |
| | | if !ok { |
| | | return |
| | | } |
| | | clientName := "" |
| | | if params.ClientId > 0 { |
| | | first, err := model.NewClientSearch(nil).SetId(params.ClientId).First() |
| | | if err != nil { |
| | | ctx.FailWithMsg(ecode.UnknownErr, "客户信息查询失败") |
| | | return |
| | | } |
| | | clientName = first.Name |
| | | } |
| | | //clientName := "" |
| | | //if params.ClientId > 0 { |
| | | // first, err := model.NewClientSearch(nil).SetId(params.ClientId).First() |
| | | // if err != nil { |
| | | // ctx.FailWithMsg(ecode.UnknownErr, "客户信息查询失败") |
| | | // return |
| | | // } |
| | | // clientName = first.Name |
| | | //} |
| | | m := make(map[string]interface{}) |
| | | m["status"] = params.Status |
| | | m["project_id"] = params.ProjectId |
| | |
| | | } |
| | | |
| | | //推送到wms |
| | | wmsProducts := make([]*product_inventory.InventoryProduct, 0) |
| | | for _, product := range params.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.GetCtx(), &product_inventory.CreateOperationRequest{ |
| | | Number: params.Number, |
| | | Addressee: params.Addressee, |
| | | Address: params.Address, |
| | | Phone: params.Phone, |
| | | DeliverType: int32(params.DeliverType), |
| | | Source: "CRM", |
| | | ClientId: int64(params.ClientId), |
| | | ClientName: clientName, |
| | | ProductList: wmsProducts, |
| | | }) |
| | | if err != nil { |
| | | logx.Errorf("grpc CreateOperation err: %v", err.Error()) |
| | | } |
| | | //wmsProducts := make([]*product_inventory.InventoryProduct, 0) |
| | | //for _, product := range params.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.GetCtx(), &product_inventory.CreateOperationRequest{ |
| | | // Number: params.Number, |
| | | // Addressee: params.Addressee, |
| | | // Address: params.Address, |
| | | // Phone: params.Phone, |
| | | // DeliverType: int32(params.DeliverType), |
| | | // Source: "CRM", |
| | | // ClientId: int64(params.ClientId), |
| | | // ClientName: clientName, |
| | | // ProductList: wmsProducts, |
| | | //}) |
| | | //if err != nil { |
| | | // logx.Errorf("grpc CreateOperation err: %v", err.Error()) |
| | | //} |
| | | |
| | | //推送到aps |
| | | ApsProducts := make([]*crm_aps.SalesDetailsProduct, 0) |