| | |
|---|
| | | response.FailWithMessage(err.Error(), c) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | warehouse := "" |
|---|
| | | if params.Status == purchase.OrderStatusReceived { |
|---|
| | | data, err := service.NewPurchaseService().GetPurchase(uint(params.Id)) |
|---|
| | | if err != nil { |
|---|
| | |
|---|
| | | product = append(product, &p) |
|---|
| | | } |
|---|
| | | client := purchase_wms.NewPurchaseServiceClient(purchase_wms.PurchaseConn) |
|---|
| | | _, err = client.PurchaseToWms(context.Background(), &purchase_wms.PurchaseToWmsRequest{ |
|---|
| | | resp, err := client.PurchaseToWms(context.Background(), &purchase_wms.PurchaseToWmsRequest{ |
|---|
| | | Number: data.Number, |
|---|
| | | SupplierName: data.Supplier.Name, |
|---|
| | | Product: product, |
|---|
| | |
|---|
| | | response.FailWithMessage("grpc调用失败", c) |
|---|
| | | return |
|---|
| | | } |
|---|
| | | warehouse = resp.Warehouse |
|---|
| | | } |
|---|
| | | |
|---|
| | | err = service.NewPurchaseService().Submit(params.Id, params.Status) |
|---|
| | | err = service.NewPurchaseService().Submit(params.Id, params.Status, warehouse) |
|---|
| | | if err != nil { |
|---|
| | | global.GVA_LOG.Error("更新失败!", zap.Error(err)) |
|---|
| | | response.FailWithMessage("更新失败", c) |
|---|
