package v1
|
|
import (
|
"aps_crm/constvar"
|
"aps_crm/model"
|
"aps_crm/model/grpc_init"
|
"aps_crm/model/request"
|
"aps_crm/model/response"
|
"aps_crm/pkg/contextx"
|
"aps_crm/pkg/ecode"
|
"aps_crm/pkg/logx"
|
"aps_crm/pkg/structx"
|
"aps_crm/proto/crm_aps"
|
"aps_crm/proto/crm_srm"
|
"aps_crm/proto/product_inventory"
|
"aps_crm/utils"
|
"github.com/gin-gonic/gin"
|
"github.com/shopspring/decimal"
|
"strconv"
|
"strings"
|
)
|
|
type SalesDetailsApi struct{}
|
|
// Add
|
//
|
// @Tags SalesDetails
|
// @Summary 添加销售明细
|
// @Produce application/json
|
// @Param object body request.AddSalesDetails true "查询参数"
|
// @Success 200 {object} contextx.Response{data=request.AddSalesDetails}
|
// @Router /api/salesDetails/add [post]
|
func (s *SalesDetailsApi) Add(c *gin.Context) {
|
var params request.AddSalesDetails
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode, salesDetails := checkSalesDetailsParams(params.SalesDetails)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
count, err := model.NewSalesDetailsSearch().SetNumber(params.Number).Count()
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码验证失败")
|
return
|
}
|
if count > 0 {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码已存在")
|
return
|
}
|
|
if salesDetails.MemberId == 0 {
|
userInfo := utils.GetUserInfo(c)
|
if userInfo.UserType == constvar.UserTypeSub {
|
salesDetails.MemberId = userInfo.CrmUserId
|
}
|
}
|
|
errCode = salesDetailsService.AddSalesDetails(&salesDetails)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.OkWithDetailed(salesDetails)
|
}
|
|
// Delete
|
//
|
// @Tags SalesDetails
|
// @Summary 删除销售明细
|
// @Produce application/json
|
// @Param id path int true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesDetails/delete/{id} [delete]
|
func (s *SalesDetailsApi) Delete(c *gin.Context) {
|
ctx, ok := contextx.NewContext(c, nil)
|
if !ok {
|
return
|
}
|
|
id, _ := strconv.Atoi(c.Param("id"))
|
errCode := salesDetailsService.DeleteSalesDetails(id)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// BatchDelete
|
// @Tags SalesDetails 销售明细
|
// @Summary 批量删除销售明细
|
// @Produce application/json
|
// @Param object body request.CommonIds true "参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesDetails/delete [delete]
|
func (s *SalesDetailsApi) BatchDelete(c *gin.Context) {
|
var params request.CommonIds
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode := salesDetailsService.BatchDeleteSalesDetails(params.Ids)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// Update
|
//
|
// @Tags SalesDetails
|
// @Summary 更新销售明细
|
// @Produce application/json
|
// @Param object body request.UpdateSalesDetails true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesDetails/update [put]
|
func (s *SalesDetailsApi) Update(c *gin.Context) {
|
var params request.UpdateSalesDetails
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode, salesDetails := checkSalesDetailsParams(params.SalesDetails)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
salesDetails.Id = params.Id
|
errCode = salesDetailsService.UpdateSalesDetails(&salesDetails)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
func checkSalesDetailsParams(salesDetails request.SalesDetails) (errCode int, salesDetailsModel model.SalesDetails) {
|
salesDetailsModel.ClientId = salesDetails.ClientId
|
salesDetailsModel.Number = salesDetails.Number
|
salesDetailsModel.SaleChanceId = salesDetails.SaleChanceId
|
salesDetailsModel.SaleType = salesDetails.SaleType
|
salesDetailsModel.SignTime = salesDetails.SignTime
|
salesDetailsModel.MemberId = salesDetails.MemberId
|
salesDetailsModel.DeliveryDate = salesDetails.DeliveryDate
|
salesDetailsModel.WechatOrderStatusId = salesDetails.WechatOrderStatusId
|
salesDetailsModel.Address = salesDetails.Address
|
salesDetailsModel.Phone = salesDetails.Phone
|
salesDetailsModel.Remark = salesDetails.Remark
|
salesDetailsModel.Addressee = salesDetails.Addressee
|
salesDetailsModel.Conditions = salesDetails.Conditions
|
salesDetailsModel.Products = salesDetails.Products
|
salesDetailsModel.LogisticCompany = salesDetails.LogisticCompany
|
salesDetailsModel.LogisticNumber = salesDetails.LogisticNumber
|
salesDetailsModel.LogisticCost = salesDetails.LogisticCost
|
salesDetailsModel.CodeStandID = salesDetails.CodeStandID
|
salesDetailsModel.DeliverType = salesDetails.DeliverType
|
salesDetailsModel.QuotationId = salesDetails.QuotationId
|
salesDetailsModel.Status = salesDetails.Status
|
if salesDetails.Source == "" {
|
salesDetailsModel.Source = "CRM自建"
|
} else {
|
salesDetailsModel.Source = salesDetails.Source
|
}
|
salesDetailsModel.ProjectId = salesDetails.ProjectId
|
|
return ecode.OK, salesDetailsModel
|
}
|
|
// List
|
//
|
// @Tags SalesDetails
|
// @Summary 销售明细单列表
|
// @Produce application/json
|
// @Param object body request.GetSalesDetailsList true "参数"
|
// @Success 200 {object} contextx.Response{data=response.SalesDetailsResponse}
|
// @Router /api/salesDetails/list [post]
|
func (con *SalesDetailsApi) List(c *gin.Context) {
|
var params request.GetSalesDetailsList
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
var memberIds []int
|
userInfo := utils.GetUserInfo(c)
|
if userInfo.UserType == constvar.UserTypeSub {
|
memberIds = userInfo.SubUserIds
|
}
|
|
salesDetailss, total, errCode := salesDetailsService.GetSalesDetailsList(params, memberIds)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.OkWithDetailed(response.SalesDetailsResponse{
|
List: salesDetailss,
|
Count: int(total),
|
})
|
}
|
|
// UpdateStatus
|
//
|
// @Tags SalesDetails
|
// @Summary 更新销售明细状态
|
// @Produce application/json
|
// @Param object body request.UpdateSalesDetailsStatus true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesDetails/updateStatus [post]
|
func (s *SalesDetailsApi) UpdateStatus(c *gin.Context) {
|
var params request.UpdateSalesDetailsStatus
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
m := make(map[string]interface{})
|
m["status"] = params.Status
|
err := model.NewSalesDetailsSearch().SetId(params.Id).UpdateByMap(m)
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "更新失败")
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// GetProductInventoryInfo
|
//
|
// @Tags SalesDetails
|
// @Summary 获取产品库存信息
|
// @Produce application/json
|
// @Param number path string true "明细编码"
|
// @Success 200 {object} response.ListResponse
|
//
|
// @Router /api/salesDetails/getProductInventoryInfo/{number} [get]
|
func (s *SalesDetailsApi) GetProductInventoryInfo(c *gin.Context) {
|
ctx, ok := contextx.NewContext(c, nil)
|
if !ok {
|
return
|
}
|
number := c.Param("number")
|
client := product_inventory.NewProductInventoryServiceClient(grpc_init.ProductInventoryServiceConn)
|
info, err := client.GetInventoryProductInfo(ctx.GetCtx(), &product_inventory.GetInventoryProductInfoRequest{Number: number})
|
if err != nil {
|
if strings.Contains(err.Error(), "record not found") {
|
ctx.Ok()
|
return
|
}
|
logx.Errorf("GetProductInfo err: %v", err.Error())
|
ctx.FailWithMsg(ecode.UnknownErr, "grpc调用错误")
|
return
|
}
|
var list []response.ProductInfo
|
err = structx.AssignTo(info.ProductList, &list)
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "转换错误")
|
return
|
}
|
ctx.OkWithDetailed(list)
|
}
|
|
// GetApsProjectList
|
//
|
// @Tags SalesDetails
|
// @Summary 获取aps项目列表
|
// @Produce application/json
|
// @Success 200 {object} response.Response
|
//
|
// @Router /api/salesDetails/getApsProjectList [get]
|
func (s *SalesDetailsApi) GetApsProjectList(c *gin.Context) {
|
ctx, ok := contextx.NewContext(c, nil)
|
if !ok {
|
return
|
}
|
client := crm_aps.NewCrmAndApsGrpcServiceClient(grpc_init.CrmApsGrpcServiceConn)
|
projectList, err := client.GetApsProjectList(c, &crm_aps.GetApsProjectListRequest{})
|
if err != nil {
|
logx.Errorf("grpc GetApsProjectList err: %v", err.Error())
|
ctx.FailWithMsg(ecode.UnknownErr, "获取aps项目列表失败")
|
return
|
}
|
ctx.OkWithDetailed(projectList.List)
|
}
|
|
// SendSalesDetailsToOtherSystem
|
//
|
// @Tags SalesDetails
|
// @Summary 推送销售明细信息到其他系统
|
// @Produce application/json
|
// @Param object body request.SalesDetails true "查询参数"
|
// @Success 200 {object} response.ListResponse
|
//
|
// @Router /api/salesDetails/sendSalesDetailsToOtherSystem [post]
|
func (s *SalesDetailsApi) SendSalesDetailsToOtherSystem(c *gin.Context) {
|
var params request.SalesDetails
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
//clientName := ""
|
//if params.ClientId > 0 {
|
// first, err := model.NewClientSearch(nil).SetId(params.ClientId).First()
|
// if err != nil {
|
// ctx.FailWithMsg(ecode.UnknownErr, "客户信息查询失败")
|
// return
|
// }
|
// clientName = first.Name
|
//}
|
m := make(map[string]interface{})
|
m["status"] = params.Status
|
m["project_id"] = params.ProjectId
|
err := model.NewSalesDetailsSearch().SetNumber(params.Number).UpdateByMap(m)
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "状态更新失败")
|
return
|
}
|
|
//推送到wms
|
//wmsProducts := make([]*product_inventory.InventoryProduct, 0)
|
//for _, product := range params.Products {
|
// var p product_inventory.InventoryProduct
|
// p.Id = product.Number
|
// p.Amount = product.Amount.String()
|
// wmsProducts = append(wmsProducts, &p)
|
//}
|
//clientWms := product_inventory.NewProductInventoryServiceClient(grpc_init.ProductInventoryServiceConn)
|
//_, err = clientWms.CreateOperation(ctx.GetCtx(), &product_inventory.CreateOperationRequest{
|
// Number: params.Number,
|
// Addressee: params.Addressee,
|
// Address: params.Address,
|
// Phone: params.Phone,
|
// DeliverType: int32(params.DeliverType),
|
// Source: "CRM",
|
// ClientId: int64(params.ClientId),
|
// ClientName: clientName,
|
// ProductList: wmsProducts,
|
//})
|
//if err != nil {
|
// logx.Errorf("grpc CreateOperation err: %v", err.Error())
|
//}
|
|
//推送到aps
|
ApsProducts := make([]*crm_aps.SalesDetailsProduct, 0)
|
var total decimal.Decimal
|
for _, product := range params.Products {
|
var sp crm_aps.SalesDetailsProduct
|
sp.ProductId = product.Number
|
sp.Amount = product.Amount.IntPart()
|
ApsProducts = append(ApsProducts, &sp)
|
total = total.Add(product.Amount)
|
}
|
|
clientAps := crm_aps.NewCrmAndApsGrpcServiceClient(grpc_init.CrmApsGrpcServiceConn)
|
_, err = clientAps.SendSalesDetailsToApsProject(c, &crm_aps.SendSalesDetailsToApsProjectRequest{
|
Number: params.Number,
|
ClientName: params.Client.Name,
|
MemberName: params.Member.Username,
|
SignTime: params.SignTime,
|
DeliveryDate: params.DeliveryDate,
|
Source: params.Source,
|
ProductTotal: total.IntPart(),
|
ProjectId: params.ProjectId,
|
Products: ApsProducts,
|
})
|
if err != nil {
|
//状态还原
|
m["status"] = constvar.WaitConfirmed
|
_ = model.NewSalesDetailsSearch().SetNumber(params.Number).UpdateByMap(m)
|
logx.Errorf("grpc SendSalesDetailsToApsProject err: %v", err.Error())
|
ctx.FailWithMsg(ecode.UnknownErr, "推送失败,请检查参数是否正确")
|
return
|
}
|
ctx.Ok()
|
}
|
|
// GetSalesDetailsProductInfo
|
//
|
// @Tags SalesDetails
|
// @Summary 获取销售明细产品信息
|
// @Produce application/json
|
// @Param number path string true "明细编码"
|
// @Success 200 {object} response.ListResponse
|
//
|
// @Router /api/salesDetails/getSalesDetailsProductInfo/{number} [get]
|
func (s *SalesDetailsApi) GetSalesDetailsProductInfo(c *gin.Context) {
|
ctx, ok := contextx.NewContext(c, nil)
|
if !ok {
|
return
|
}
|
number := c.Param("number")
|
first, err := model.NewSalesDetailsSearch().SetPreload(true).SetNumber(number).First()
|
if err != nil {
|
ctx.FailWithMsg(ecode.DBErr, "查询销售明细出错")
|
return
|
}
|
resp := make([]response.SalesDetailsProductInfo, 0)
|
amountMap := make(map[string]int64)
|
overMap := make(map[string]int64)
|
for _, product := range first.Products {
|
amountMap[product.Number] = 0
|
overMap[product.Number] = 0
|
var sdpi response.SalesDetailsProductInfo
|
sdpi.ProductId = product.Number
|
sdpi.ProductName = product.Name
|
sdpi.Specs = product.Specs
|
sdpi.Unit = product.Unit
|
sdpi.Amount = product.Amount
|
sdpi.Cost = product.Cost
|
sdpi.Price = product.Price
|
sdpi.Total = product.Total
|
sdpi.Profit = product.Profit
|
sdpi.Margin = product.Margin
|
resp = append(resp, sdpi)
|
}
|
srmClient := crm_srm.NewCrmAndSrmServiceClient(grpc_init.CrmSrmGrpcServiceConn)
|
info, err := srmClient.CrmGetPurchaseInfo(c, &crm_srm.CrmGetPurchaseInfoRequest{SalesDetailsNumber: number})
|
if err != nil {
|
logx.Errorf("grpc CrmGetPurchaseInfo err: %v", err.Error())
|
ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
|
return
|
}
|
//采购数量
|
for _, purchaseInfo := range info.Info {
|
amount := amountMap[purchaseInfo.ProductId]
|
amount += purchaseInfo.Amount
|
amountMap[purchaseInfo.ProductId] = amount
|
over := overMap[purchaseInfo.ProductId]
|
over += purchaseInfo.FinishAmount
|
overMap[purchaseInfo.ProductId] = over
|
}
|
for i := 0; i < len(resp); i++ {
|
resp[i].PurchaseAmount = amountMap[resp[i].ProductId]
|
amountMap[resp[i].ProductId] = 0
|
resp[i].PurchaseFinishAmount = overMap[resp[i].ProductId]
|
resp[i].FinishAmount = resp[i].FinishAmount + overMap[resp[i].ProductId]
|
overMap[resp[i].ProductId] = 0
|
}
|
|
apsClient := crm_aps.NewCrmAndApsGrpcServiceClient(grpc_init.CrmApsGrpcServiceConn)
|
productInfo, err := apsClient.CrmGetMakeAndOutsourcingProductInfo(c, &crm_aps.CrmGetMakeAndOutsourcingProductInfoRequest{SalesDetailsNumber: number})
|
if err != nil {
|
logx.Errorf("grpc CrmGetMakeAndOutsourcingProductInfo err: %v", err.Error())
|
ctx.FailWithMsg(ecode.UnknownErr, "内部错误")
|
return
|
}
|
//制造数量
|
for _, makeInfo := range productInfo.Info {
|
if makeInfo.Type == 2 {
|
amount := amountMap[makeInfo.ProductId]
|
amount += makeInfo.Amount
|
amountMap[makeInfo.ProductId] = amount
|
over := overMap[makeInfo.ProductId]
|
over += makeInfo.FinishAmount
|
overMap[makeInfo.ProductId] = over
|
}
|
}
|
for i := 0; i < len(resp); i++ {
|
resp[i].MakeAmount = amountMap[resp[i].ProductId]
|
amountMap[resp[i].ProductId] = 0
|
resp[i].MakeFinishAmount = overMap[resp[i].ProductId]
|
resp[i].FinishAmount = resp[i].FinishAmount + overMap[resp[i].ProductId]
|
overMap[resp[i].ProductId] = 0
|
}
|
//委外数量
|
for _, outsourcingInfo := range productInfo.Info {
|
if outsourcingInfo.Type == 3 {
|
amount := amountMap[outsourcingInfo.ProductId]
|
amount += outsourcingInfo.Amount
|
amountMap[outsourcingInfo.ProductId] = amount
|
over := overMap[outsourcingInfo.ProductId]
|
over += outsourcingInfo.FinishAmount
|
overMap[outsourcingInfo.ProductId] = over
|
}
|
}
|
for i := 0; i < len(resp); i++ {
|
resp[i].OutsourcingAmount = amountMap[resp[i].ProductId]
|
amountMap[resp[i].ProductId] = 0
|
resp[i].OutsourcingFinishAmount = overMap[resp[i].ProductId]
|
resp[i].FinishAmount = resp[i].FinishAmount + overMap[resp[i].ProductId]
|
overMap[resp[i].ProductId] = 0
|
}
|
ctx.OkWithDetailed(resp)
|
}
|
