| | |
| | | if operation.BaseOperationType == constvar.BaseOperationTypeIncoming { |
| | | if operation.Source != "" { |
| | | go UpdatePurchaseStatus(operation.Source, operation.SourceNumber) |
| | | go UpdateOutsourceOrder(operation.Source, operation.SourceNumber, operation.Id, listDetails) |
| | | } |
| | | } else if operation.BaseOperationType == constvar.BaseOperationTypeOutgoing { |
| | | if operation.Source != "" { |
| | |
| | | } |
| | | } |
| | | |
| | | func UpdateOutsourceOrder(source, number string, operationId int, details []*models.OperationDetails) { |
| | | if source == "APS_OUTSOURCING_RECEIVE" { |
| | | products := make([]*inventory_order.OperationProduct, 0) |
| | | for _, detail := range details { |
| | | if operationId == detail.OperationID { |
| | | var op inventory_order.OperationProduct |
| | | op.ProductNumber = detail.ProductId |
| | | op.Amount = detail.Amount.IntPart() |
| | | products = append(products, &op) |
| | | } |
| | | } |
| | | cl := inventory_order.NewInventoryOrderServiceClient(init_client.ApsConn) |
| | | _, err := cl.UpdateOutsourceOrder(context.Background(), &inventory_order.UpdateOutsourceOrderRequest{ |
| | | OutsourceNumber: number, |
| | | Products: products, |
| | | }) |
| | | if err != nil { |
| | | logx.Errorf("grpc dial UpdateOutsourceOrder service error: %v", err) |
| | | } |
| | | } |
| | | } |
| | | |
| | | // ListTransfer |
| | | // @Tags 入库/出库 |
| | | // @Summary 库存调拨列表 |