package v1
|
|
import (
|
"aps_crm/constvar"
|
"aps_crm/model"
|
"aps_crm/model/request"
|
"aps_crm/model/response"
|
"aps_crm/pkg/contextx"
|
"aps_crm/pkg/ecode"
|
"aps_crm/utils"
|
"github.com/gin-gonic/gin"
|
"github.com/shopspring/decimal"
|
)
|
|
type QuotationApi struct{}
|
|
// Add
|
//
|
// @Tags Quotation
|
// @Summary 添加报价单
|
// @Produce application/json
|
// @Param object body request.AddQuotation true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/quotation/add [post]
|
func (s *QuotationApi) Add(c *gin.Context) {
|
var params request.AddQuotation
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode, quotation := checkQuotationParams(params.Quotation)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
count, err := model.NewQuotationSearch(nil).SetNumber(params.Number).Count()
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码验证失败")
|
return
|
}
|
if count > 0 {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码已存在")
|
return
|
}
|
|
if quotation.MemberId == 0 {
|
userInfo := utils.GetUserInfo(c)
|
if userInfo.UserType == constvar.UserTypeSub {
|
quotation.MemberId = userInfo.CrmUserId
|
}
|
}
|
|
errCode = quotationService.AddQuotation("ation)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// Delete
|
//
|
// @Tags Quotation
|
// @Summary 删除报价单
|
// @Produce application/json
|
// @Param object body request.DeleteQuotation true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/quotation/delete [delete]
|
func (s *QuotationApi) Delete(c *gin.Context) {
|
var params request.DeleteQuotation
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode := quotationService.DeleteQuotation(params.Ids)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// Update
|
//
|
// @Tags Quotation
|
// @Summary 更新报价单
|
// @Produce application/json
|
// @Param object body request.UpdateQuotation true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/quotation/update [put]
|
func (s *QuotationApi) Update(c *gin.Context) {
|
var params request.UpdateQuotation
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode, quotation := checkQuotationParams(params.Quotation)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
quotation.Id = params.Id
|
|
errCode = quotationService.UpdateQuotation("ation)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// checkQuotationParams
|
func checkQuotationParams(quotation request.Quotation) (int, model.Quotation) {
|
var errCode int
|
var quotationModel model.Quotation
|
|
//if quotation.ClientId == 0 {
|
// errCode = ecode.InvalidParams
|
// return errCode, quotationModel
|
//}
|
//
|
//if quotation.QuotationStatusId == 0 {
|
// errCode = ecode.InvalidParams
|
// return errCode, quotationModel
|
//}
|
//
|
//if quotation.Number == "" {
|
// errCode = ecode.InvalidParams
|
// return errCode, quotationModel
|
//}
|
//
|
//if quotation.MemberId == 0 {
|
// errCode = ecode.InvalidParams
|
// return errCode, quotationModel
|
//}
|
|
t, err := checkTimeFormat(quotation.ValidityDate)
|
if err != nil {
|
errCode = ecode.InvalidParams
|
return errCode, quotationModel
|
}
|
|
// 将时间字符转换为时间类型
|
|
quotationModel.ValidityDate = t
|
quotationModel.ClientId = quotation.ClientId
|
quotationModel.QuotationStatusId = quotation.QuotationStatusId
|
quotationModel.Number = quotation.Number
|
quotationModel.MemberId = quotation.MemberId
|
quotationModel.SaleChanceId = quotation.SaleChanceId
|
quotationModel.ContactId = quotation.ContactId
|
quotationModel.Conditions = quotation.Conditions
|
quotationModel.File = quotation.File
|
quotationModel.Products = quotation.Products
|
quotationModel.CodeStandID = quotation.CodeStandID
|
quotationModel.QuotationName = quotation.QuotationName
|
|
return ecode.OK, quotationModel
|
|
}
|
|
// List
|
//
|
// @Tags Quotation
|
// @Summary 报价单列表
|
// @Produce application/json
|
// @Param object body request.GetQuotationList true "参数"
|
// @Success 200 {object} contextx.Response{data=response.QuotationResponse}
|
// @Router /api/quotation/list [post]
|
func (con *QuotationApi) List(c *gin.Context) {
|
var params request.GetQuotationList
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
userInfo := utils.GetUserInfo(c)
|
if userInfo.UserType == constvar.UserTypeSub {
|
if params.SearchMap == nil {
|
params.SearchMap = make(map[string]interface{}, 0)
|
}
|
params.SearchMap["member_ids"] = userInfo.SubUserIds
|
}
|
|
quotations, total, errCode := quotationService.GetQuotationList(params.Page, params.PageSize, params.SearchMap)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
for _, quotation := range quotations {
|
amount := decimal.NewFromInt(0)
|
for _, product := range quotation.Products {
|
amount = amount.Add(product.Total)
|
}
|
quotation.AmountTotal = amount
|
}
|
|
ctx.OkWithDetailed(response.QuotationResponse{
|
List: quotations,
|
Count: int(total),
|
})
|
}
|
|
// Statistics
|
//
|
// @Tags Quotation
|
// @Summary 报价单统计
|
// @Produce application/json
|
// @Success 200 {object} contextx.Response{data=map[string]int64}
|
// @Router /api/quotation/statistics [get]
|
func (con *QuotationApi) Statistics(c *gin.Context) {
|
ctx, ok := contextx.NewContext(c, nil)
|
if !ok {
|
return
|
}
|
m := make(map[string]int64)
|
total, _ := model.NewQuotationSearch(nil).Count()
|
m["total"] = total
|
//已创建
|
created, _ := model.NewQuotationSearch(nil).SetQuotationStatusId(1).Count()
|
m["created"] = created
|
//已审批
|
approved, _ := model.NewQuotationSearch(nil).SetQuotationStatusId(3).Count()
|
m["approved"] = approved
|
//已接受
|
accepted, _ := model.NewQuotationSearch(nil).SetQuotationStatusId(5).Count()
|
m["accepted"] = accepted
|
ctx.OkWithDetailed(m)
|
}
|
