package controllers
|
|
import (
|
"fmt"
|
"github.com/gin-gonic/gin"
|
"github.com/shopspring/decimal"
|
"wms/constvar"
|
"wms/extend/code"
|
"wms/extend/util"
|
"wms/models"
|
"wms/request"
|
"wms/response"
|
)
|
|
type ReportFormsController struct {
|
}
|
|
type Detail struct {
|
ProductId string `json:"productId"`
|
Amount decimal.Decimal `json:"amount"`
|
Status constvar.OperationStatus `json:"status"`
|
//ProductName string `json:"productName"`
|
}
|
|
// GetInventoryForms
|
// @Tags 报表
|
// @Summary 获取库存报表
|
// @Produce application/json
|
// @Param object body request.GetInventoryForms true "查询参数"
|
// @Success 200 {object} util.ResponseList{data=[]response.InventoryForms} "成功"
|
// @Router /api-wms/v1/forms/getInventoryForms [post]
|
func (slf ReportFormsController) GetInventoryForms(c *gin.Context) {
|
var params request.GetInventoryForms
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
//查询产品
|
search := models.NewMaterialSearch()
|
search.Orm = search.Orm.Model(&models.Material{}).
|
Select(`material.id, material.name, material.cost, material.amount, material.unit, wms_product_category.name as category_name `).
|
Joins("left join wms_product_category on material.category_id = wms_product_category.id")
|
if len(params.CategoryIds) > 0 {
|
search.Orm.Where("material.category_id in (?)", params.CategoryIds)
|
}
|
if params.KeyWord != "" {
|
search.Orm.Where("material.name like ?", "%"+params.KeyWord+"%").Or("wms_product_category.name like ?", "%"+params.KeyWord+"%")
|
}
|
var (
|
materials = make([]*models.Material, 0)
|
total int64
|
)
|
if err := search.Orm.Count(&total).Error; err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询total失败")
|
return
|
}
|
if params.Page*params.PageSize > 0 {
|
search.Orm = search.Orm.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize)
|
}
|
if err := search.Orm.Find(&materials).Error; err != nil {
|
util.ResponseFormat(c, code.RequestParamError, fmt.Errorf("查询产品失败: %v", err))
|
return
|
}
|
|
locations, err := models.NewLocationSearch().SetJointName(params.WarehouseCode).FindNotTotal()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询仓库位置失败")
|
return
|
}
|
locationIds := make([]int, 0)
|
for _, location := range locations {
|
locationIds = append(locationIds, location.Id)
|
}
|
//查询在库数量
|
productIds := make([]string, 0)
|
for _, material := range materials {
|
productIds = append(productIds, material.ID)
|
}
|
productAmounts, err := models.NewLocationProductAmountSearch().SetProductIds(productIds).SetLocationIds(locationIds).Find()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询在库数量失败")
|
return
|
}
|
|
//查询出入库就绪数量
|
var inHouse []Detail
|
var outHouse []Detail
|
dbIn := models.NewOperationDetailsSearch().Orm.Model(&models.OperationDetails{}).
|
Select("wms_operation_details.product_id,wms_operation_details.amount,wms_operation.status as status").
|
Joins("left join wms_operation ON wms_operation_details.operation_id=wms_operation.id").
|
Where("wms_operation.base_operation_type in (?)", []constvar.BaseOperationType{constvar.BaseOperationTypeIncoming, constvar.BaseOperationTypeInternal}).
|
Where("wms_operation.status in (?)", []constvar.OperationStatus{constvar.OperationStatus_Finish})
|
dbOut := models.NewOperationDetailsSearch().Orm.Model(&models.OperationDetails{}).
|
Select("wms_operation_details.product_id,wms_operation_details.amount,wms_operation.status as status").
|
Joins("left join wms_operation ON wms_operation_details.operation_id=wms_operation.id").
|
Where("wms_operation.base_operation_type in (?)", []constvar.BaseOperationType{constvar.BaseOperationTypeOutgoing, constvar.BaseOperationTypeInternal, constvar.BaseOperationTypeDisuse}).
|
Where("wms_operation.status in (?)", []constvar.OperationStatus{constvar.OperationStatus_Ready, constvar.OperationStatus_Finish})
|
if len(locationIds) > 0 {
|
dbIn.Where("wms_operation.to_location_id in (?)", locationIds)
|
dbOut.Where("wms_operation.from_location_id in (?)", locationIds)
|
}
|
if len(productIds) > 0 {
|
dbIn.Where("wms_operation_details.product_id in (?)", productIds)
|
dbOut.Where("wms_operation_details.product_id in (?)", productIds)
|
}
|
err = dbIn.Find(&inHouse).Error
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询入库数量失败")
|
return
|
}
|
err = dbOut.Find(&outHouse).Error
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询出库数量失败")
|
return
|
}
|
var result []response.InventoryForms
|
for _, material := range materials {
|
var resp response.InventoryForms
|
resp.ProduceId = material.ID
|
resp.ProductName = material.Name
|
resp.Cost = material.Cost
|
resp.Unit = material.Unit
|
resp.Value = material.Amount.Mul(material.Cost)
|
resp.ProductType = material.CategoryName
|
for _, amount := range productAmounts {
|
if material.ID == amount.ProductId {
|
resp.Amount = resp.Amount.Add(amount.Amount)
|
}
|
}
|
for _, details := range inHouse {
|
if material.ID == details.ProductId {
|
resp.In = resp.In.Add(details.Amount)
|
}
|
}
|
available := decimal.NewFromInt(0)
|
for _, details := range outHouse {
|
if material.ID == details.ProductId {
|
if details.Status == constvar.OperationStatus_Ready {
|
available = available.Add(details.Amount)
|
} else {
|
resp.Out = resp.Out.Add(details.Amount)
|
}
|
}
|
}
|
resp.AvailableNumber = resp.Amount.Sub(available)
|
result = append(result, resp)
|
}
|
util.ResponseFormatList(c, code.Success, result, int(total))
|
}
|
|
// GetHistory
|
// @Tags 报表
|
// @Summary 获取历史信息
|
// @Produce application/json
|
// @Param object body request.GetInventoryHistory true "查询参数"
|
// @Success 200 {object} util.ResponseList{data=[]response.InventoryHistory} "成功"
|
// @Router /api-wms/v1/forms/getHistory [post]
|
func (slf ReportFormsController) GetHistory(c *gin.Context) {
|
var params request.GetInventoryHistory
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
//获取操作详情
|
detailsSearch := models.NewOperationDetailsSearch()
|
if params.PageInfo.Check() {
|
detailsSearch.SetPage(params.Page, params.PageSize)
|
}
|
details, total, err := detailsSearch.SetProductId(params.ProduceId).Find()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询操作详情失败")
|
return
|
}
|
var operationIds []int
|
for _, detail := range details {
|
operationIds = append(operationIds, detail.OperationID)
|
}
|
//获取已完成的操作记录
|
operations, err := models.NewOperationSearch().SetIds(operationIds).SetBaseOperationType(params.BaseOperationType).
|
SetStatus(constvar.OperationStatus_Finish).FindNotTotal()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询操作记录失败")
|
return
|
}
|
var result []response.InventoryHistory
|
for _, detail := range details {
|
var resp response.InventoryHistory
|
resp.Amount = detail.Amount
|
resp.Unit = detail.Product.Unit
|
resp.ProductName = detail.Product.Name
|
for _, operation := range operations {
|
if detail.OperationID == operation.Id {
|
resp.Number = operation.Number
|
resp.Date = operation.UpdateTime
|
resp.Status = "完成"
|
resp.ContactedName = operation.ContacterName
|
resp.FromLocation = operation.FromLocation.Name
|
resp.ToLocation = operation.ToLocation.Name
|
resp.BaseOperationType = operation.BaseOperationType
|
result = append(result, resp)
|
break
|
}
|
}
|
}
|
util.ResponseFormatList(c, code.Success, result, int(total))
|
}
|
|
// GetLocationForms
|
// @Tags 报表
|
// @Summary 获取位置报表
|
// @Produce application/json
|
// @Param object body request.GetLocationForms true "查询参数"
|
// @Success 200 {object} util.ResponseList{data=[]response.LocationForms} "成功"
|
// @Router /api-wms/v1/forms/getLocationForms [post]
|
func (slf ReportFormsController) GetLocationForms(c *gin.Context) {
|
var params request.GetLocationForms
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
|
//查询位置
|
locations, err := models.NewLocationSearch().SetJointName(params.WareHouseCode).FindAll()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询位置失败")
|
return
|
}
|
ids := make([]int, 0)
|
for _, location := range locations {
|
ids = append(ids, location.Id)
|
}
|
|
amounts, total, err := models.NewLocationProductAmountSearch().SetPage(params.Page, params.PageSize).SetPreload(true).SetKeyword(params.KeyWord).SetProductId(params.ProductId).SetLocationIds(ids).FindByPage()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询数量失败")
|
return
|
}
|
|
var result []response.LocationForms
|
for _, amount := range amounts {
|
var resp response.LocationForms
|
resp.Amount = amount.Amount
|
resp.LocationName = amount.Location.Name
|
resp.ProduceId = amount.Product.ID
|
resp.ProductName = amount.Product.Name
|
resp.ProductTypeName = amount.ProductCategory.Name
|
resp.Unit = amount.Product.Unit
|
resp.Value = resp.Amount.Mul(amount.Product.Cost)
|
result = append(result, resp)
|
}
|
|
util.ResponseFormatList(c, code.Success, result, int(total))
|
}
|
