修改

liujiandao

2024-03-30 aeed976c2999e2cea097cdee38d8baeefe323f3d

 controllers/operation.go

@@ -538,9 +538,6 @@
               return err
            }
         }
         if operation.Source != "" {
            go UpdatePurchaseStatus(operation.Source, operation.SourceNumber)
         }

      }

@@ -582,9 +579,6 @@
               return errors.New("当前仓库没有该产品,请先入库")
            }
         }
         if operation.Source != "" {
            go UpdateOutStatus(operation.Source, operation.SourceNumber, 4)
         }
      }

      if operation.BaseOperationType == constvar.BaseOperationTypeInternal {
@@ -624,6 +618,17 @@
   if err != nil {
      util.ResponseFormat(c, code.RequestError, err.Error())
      return
   }
   //修改其他系统订单状态
   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 != "" {
         go UpdateOutStatus(operation.Source, operation.SourceNumber, 4)
      }
   }

   util.ResponseFormat(c, code.Success, "操作成功")
@@ -728,6 +733,28 @@
   }
}

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   库存调拨列表