zhangqian
2023-11-29 d1cb09e7a23e7221b6c090ad33e4481a5b79f615
controllers/operation.go
@@ -24,10 +24,12 @@
   "wms/opa"
   "wms/pkg/logx"
   "wms/pkg/structx"
   "wms/proto/client"
   "wms/proto/product_inventory"
   "wms/proto/purchase_wms"
   "wms/proto/supplier"
   "wms/request"
   "wms/service"
   "wms/utils/http"
   "wms/utils/upload"
)
@@ -168,6 +170,30 @@
   }
   return nil
}
// GetOperationInfo
// @Tags      入库/出库
// @Summary   入库/出库列表
// @Produce   application/json
//
//   @Param      id   path      string         true   "id"
//
// @Success   200 {object} util.Response   "成功"
// @Router    /api-wms/v1/operation/getOperationInfo/{id} [get]
func (slf OperationController) GetOperationInfo(c *gin.Context) {
   number := c.Param("id")
   if number == "" {
      util.ResponseFormat(c, code.RequestParamError, "参数解析失败,参数不能为空")
      return
   }
   id, _ := strconv.Atoi(number)
   operation, err := models.NewOperationSearch().SetID(id).SetPreload(true).First()
   if err != nil {
      util.ResponseFormat(c, code.RequestParamError, err.Error())
      return
   }
   util.ResponseFormat(c, code.Success, operation)
}
// List
@@ -707,6 +733,7 @@
func AddMoveHistory(operationList []*models.Operation, db *gorm.DB) error {
   var histories []*models.MoveHistory
   operationMap := make(map[string]*models.Operation, len(operationList))
   for _, operation := range operationList {
      for _, v := range operation.Details {
         history := &models.MoveHistory{
@@ -715,6 +742,7 @@
            OperationTypeId:   operation.OperationTypeId,
            OperationTypeName: operation.OperationTypeName,
            OperationId:       operation.Id,
            ProductId:         v.ProductId,
            ProductName:       v.Product.Name,
            Amount:            v.Amount,
            Unit:              v.Product.Unit,
@@ -726,9 +754,13 @@
         }
         histories = append(histories, history)
      }
      operationMap[operation.Number] = operation
   }
   if err := db.Model(&models.MoveHistory{}).Create(&histories).Error; err != nil {
      return err
   }
   for _, history := range histories {
      service.AddNewHistoryReportRecord(history, operationMap[history.Number])
   }
   return nil
}
@@ -1084,3 +1116,21 @@
   }
   util.ResponseFormat(c, code.Success, resp.List)
}
// GetClientList
// @Tags      入库/出库
// @Summary   获取物流公司列表
// @Produce   application/json
//
//   @Success   200   {object}   util.Response   "成功"
//
// @Router    /api-wms/v1/operation/getClientList [get]
func (slf OperationController) GetClientList(c *gin.Context) {
   cli := client.NewClientServiceClient(client.ClientConn)
   resp, err := cli.GetClientList(c, &client.ClientListRequest{})
   if err != nil {
      util.ResponseFormat(c, code.RequestParamError, "grpc调用失败:"+err.Error())
      return
   }
   util.ResponseFormat(c, code.Success, resp.List)
}