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"
|
"wms/service"
|
"wms/task"
|
)
|
|
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
|
err := c.BindJSON(¶ms)
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
locationIds := make([]int, 0)
|
productIds := make([]string, 0)
|
productAmounts := make([]*models.LocationProductAmount, 0)
|
if params.WarehouseCode != "" {
|
locations, err := models.NewLocationSearch().SetJointName(params.WarehouseCode).FindNotTotal()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询仓库位置失败")
|
return
|
}
|
|
for _, location := range locations {
|
locationIds = append(locationIds, location.Id)
|
}
|
productAmounts, err = models.NewLocationProductAmountSearch().SetLocationIds(locationIds).SetQuery("amount > 0").Find()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询在库数量失败")
|
return
|
}
|
for _, amount := range productAmounts {
|
productIds = append(productIds, amount.ProductId)
|
}
|
|
}
|
//查询产品
|
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+"%")
|
}
|
if len(productIds) > 0 {
|
search.Orm.Where("material.id in (?)", productIds)
|
}
|
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
|
}
|
|
//查询在库数量
|
if len(productIds) == 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_details.to_location_id in (?)", locationIds)
|
dbOut.Where("wms_operation_details.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) {
|
slf.GetHistoryNew(c)
|
return
|
//var params request.GetInventoryHistory
|
//if err := c.BindJSON(¶ms); err != nil {
|
// util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
// return
|
//}
|
////获取操作详情
|
//detailsSearch := models.NewOperationDetailsSearch()
|
//var (
|
// result []*response.InventoryHistory
|
// total int64
|
// ids []int
|
// err error
|
//)
|
//if params.KeyWord != "" {
|
// ids, err = service.SearchHistoryReport(params.KeyWord, params.BaseOperationType)
|
//
|
// if err != nil {
|
// util.ResponseFormat(c, code.InternalError, err.Error())
|
// return
|
// }
|
// if len(ids) == 0 {
|
// util.ResponseFormatList(c, code.Success, result, 0)
|
// }
|
//}
|
//
|
//detailsSearch.Orm = detailsSearch.Orm.Model(&models.OperationDetails{}).
|
// Select("wms_operation.number, wms_operation.updated_at as date, material.name as product_name, wms_operation.from_location_id,"+
|
// "wms_operation.to_location_id, wms_operation_details.amount, material.unit, wms_operation.contacter_name as contacted_name,"+
|
// "wms_operation.base_operation_type, material.weight, wms_operation_details.product_id").
|
// Joins("left join wms_operation on wms_operation_details.operation_id = wms_operation.id").
|
// Joins("left join material on wms_operation_details.product_id = material.id").
|
// Where("wms_operation.status = ?", constvar.OperationStatus_Finish).Order("wms_operation.created_at desc")
|
//if len(ids) > 0 {
|
// detailsSearch.Orm = detailsSearch.Orm.Where("wms_operation_details.id in ?", ids)
|
//}
|
//if params.ProduceId != "" {
|
// detailsSearch.Orm = detailsSearch.Orm.Where("wms_operation_details.product_id = ?", params.ProduceId)
|
//}
|
//if params.BaseOperationType != 0 {
|
// detailsSearch.Orm = detailsSearch.Orm.Where("wms_operation.base_operation_type = ?", params.BaseOperationType)
|
//}
|
//
|
//err = detailsSearch.Orm.Count(&total).Error
|
//if err != nil {
|
// util.ResponseFormat(c, code.RequestParamError, "查询total失败")
|
// return
|
//}
|
//if params.Page*params.PageSize > 0 {
|
// detailsSearch.Orm = detailsSearch.Orm.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize)
|
//}
|
//
|
//err = detailsSearch.Orm.Find(&result).Error
|
//if err != nil {
|
// util.ResponseFormat(c, code.RequestParamError, fmt.Errorf("查询操作明细失败: %v", err))
|
// return
|
//}
|
//var locationIds []int
|
//for _, history := range result {
|
// locationIds = append(locationIds, history.FromLocationId, history.ToLocationId)
|
//}
|
//locations, err := models.NewLocationSearch().SetIds(locationIds).FindNotTotal()
|
//if err != nil {
|
// util.ResponseFormat(c, code.RequestParamError, fmt.Errorf("查询位置失败: %v", err))
|
// return
|
//}
|
//for _, history := range result {
|
// history.Status = "完成"
|
// for _, location := range locations {
|
// if history.ToLocationId == location.Id {
|
// history.ToLocation = location.Name
|
// }
|
// if history.FromLocationId == location.Id {
|
// history.FromLocation = location.Name
|
// }
|
// }
|
//}
|
//util.ResponseFormatList(c, code.Success, result, int(total))
|
}
|
|
func (slf ReportFormsController) GetHistoryNew(c *gin.Context) {
|
var params request.GetInventoryHistory
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
//获取操作详情
|
detailsSearch := models.NewMoveHistorySearch()
|
var (
|
result []*response.InventoryHistory
|
total uint64
|
ids []int
|
err error
|
)
|
if params.KeyWord != "" {
|
ids, total, err = service.SearchHistoryReport(params.KeyWord, params.BaseOperationType, params.Page, params.PageSize)
|
if err != nil {
|
util.ResponseFormat(c, code.InternalError, err.Error())
|
return
|
}
|
if len(ids) == 0 {
|
util.ResponseFormatList(c, code.Success, result, 0)
|
return
|
}
|
}
|
|
detailsSearch.Orm = detailsSearch.Orm.Model(&models.MoveHistory{}).
|
Select("number, updated_at as date, product_name as product_name, from_location_id, operation_id,to_location_id, amount, " +
|
"unit, operator as contacted_name, base_operation_type, weight, product_id, from_location, to_location, operation_type_name, weight").Order("id desc")
|
if len(ids) > 0 {
|
detailsSearch.Orm = detailsSearch.Orm.Where("id in ?", ids)
|
}
|
if params.BaseOperationType != 0 {
|
detailsSearch.Orm = detailsSearch.Orm.Where("base_operation_type = ?", params.BaseOperationType)
|
}
|
var t int64
|
err = detailsSearch.Orm.Count(&t).Error
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, fmt.Errorf("查询总条数失败: %v", err))
|
return
|
}
|
total = uint64(t)
|
if params.Page*params.PageSize > 0 {
|
detailsSearch.Orm = detailsSearch.Orm.Offset((params.Page - 1) * params.PageSize).Limit(params.PageSize)
|
}
|
err = detailsSearch.Orm.Find(&result).Error
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, fmt.Errorf("查询操作明细失败: %v", err))
|
return
|
}
|
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
|
}
|
ids := make([]int, 0)
|
if params.LocationId != 0 {
|
ids = append(ids, params.LocationId)
|
} else {
|
//查询位置
|
locations, err := models.NewLocationSearch().SetJointName(params.WareHouseCode).SetType(3).FindAll()
|
if err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "查询位置失败")
|
return
|
}
|
for _, location := range locations {
|
ids = append(ids, location.Id)
|
}
|
}
|
var (
|
amounts []*models.LocationProductAmount
|
total uint64
|
totalInt64 int64
|
err error
|
)
|
if params.KeyWord != "" {
|
amounts, total, err = service.SearchLocationReport(params.KeyWord, params.Page, params.PageSize)
|
} else {
|
amounts, totalInt64, 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
|
}
|
total = uint64(totalInt64)
|
}
|
|
var result []response.LocationForms
|
for _, amount := range amounts {
|
var resp response.LocationForms
|
resp.Amount = amount.Amount
|
resp.LocationId = amount.LocationId
|
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))
|
}
|
|
// MonthStats
|
// @Tags 报表
|
// @Summary 月度统计库存报表
|
// @Produce application/json
|
// @Param object body request.GetMonthStats true "查询参数"
|
// @Param Authorization header string true "token"
|
// @Success 200 {object} util.ResponseList{data=[]models.MonthStats} "成功"
|
// @Router /api-wms/v1/forms/monthStats [post]
|
func (slf ReportFormsController) MonthStats(c *gin.Context) {
|
var params request.GetMonthStats
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
|
list, total, err := models.NewMonthStatsSearch().SetPage(params.Page, params.PageSize).SetKeyword(params.Keyword).SetDate(params.Date).Find()
|
if err != nil {
|
util.ResponseFormat(c, code.InternalError, "查询失败")
|
return
|
}
|
|
util.ResponseFormatList(c, code.Success, list, int(total))
|
}
|
|
// DoMonthStats
|
// @Tags 报表
|
// @Summary 手动跑月度统计库存报表
|
// @Produce application/json
|
// @Param object body request.DoMonthStats true "查询参数"
|
// @Param Authorization header string true "token"
|
// @Success 200 {object} util.ResponseList{data=[]models.MonthStats} "成功"
|
// @Router /api-wms/v1/forms/doMonthStats [post]
|
func (slf ReportFormsController) DoMonthStats(c *gin.Context) {
|
var params request.DoMonthStats
|
if err := c.BindJSON(¶ms); err != nil {
|
util.ResponseFormat(c, code.RequestParamError, "参数解析失败，数据类型错误")
|
return
|
}
|
|
if params.Token != constvar.DoMonthStatsToken {
|
return
|
}
|
|
task.MonthStats()
|
util.ResponseFormat(c, code.Success, nil)
|
}
|
