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"
|
)
|
|
type SalesLeadsApi struct{}
|
|
// Add
|
//
|
// @Tags SalesLeads
|
// @Summary 添加销售线索
|
// @Produce application/json
|
// @Param object body request.AddSalesLeads true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesLeads/add [post]
|
func (s *SalesLeadsApi) Add(c *gin.Context) {
|
var params request.AddSalesLeads
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
if params.MemberId == 0 {
|
userInfo := utils.GetUserInfo(c)
|
if userInfo.UserType == constvar.UserTypeSub {
|
params.MemberId = userInfo.CrmUserId
|
}
|
}
|
|
errCode, salesLeads := checkSalesLeadsParams(params.SalesLeads)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
count, err := model.NewSalesLeadsSearch(nil).SetNumber(params.Number).Count()
|
if err != nil {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码验证失败")
|
return
|
}
|
if count > 0 {
|
ctx.FailWithMsg(ecode.UnknownErr, "编码已存在")
|
return
|
}
|
|
errCode = salesLeadsService.AddSalesLeads(&salesLeads)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// Delete
|
//
|
// @Tags SalesLeads
|
// @Summary 删除销售线索
|
// @Produce application/json
|
// @Param object body request.DeleteSalesLeads true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesLeads/delete [delete]
|
func (s *SalesLeadsApi) Delete(c *gin.Context) {
|
var params request.DeleteSalesLeads
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode := salesLeadsService.DeleteSalesLeads(params.Ids)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
// Update
|
//
|
// @Tags SalesLeads
|
// @Summary 更新销售线索
|
// @Produce application/json
|
// @Param object body request.UpdateSalesLeads true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesLeads/update [put]
|
func (s *SalesLeadsApi) Update(c *gin.Context) {
|
var params request.UpdateSalesLeads
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
errCode, salesLeads := checkSalesLeadsParams(params.SalesLeads)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
salesLeads.Id = params.Id
|
|
errCode = salesLeadsService.UpdateSalesLeads(&salesLeads)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.Ok()
|
}
|
|
func checkSalesLeadsParams(params request.SalesLeads) (errCode int, salesLeads model.SalesLeads) {
|
//if params.Name == "" {
|
// return ecode.InvalidParams, salesLeads
|
//}
|
//
|
//if params.Number == "" {
|
// return ecode.InvalidParams, salesLeads
|
//}
|
//
|
//if params.SalesSourcesId == 0 {
|
// return ecode.InvalidParams, salesLeads
|
//}
|
//
|
//if params.MemberId == 0 {
|
// return ecode.InvalidParams, salesLeads
|
//}
|
|
salesLeads = model.SalesLeads{
|
Name: params.Name,
|
Number: params.Number,
|
ContactName: params.ContactName,
|
ContactPhone: params.ContactPhone,
|
ContactPosition: params.ContactPosition,
|
SalesStatus: constvar.SalesStatusNew,
|
SalesSourcesId: params.SalesSourcesId,
|
MemberId: params.MemberId,
|
Desc: params.Desc,
|
CodeStandID: params.CodeStandID,
|
Address: model.Address{
|
ProvinceId: params.ProvinceId,
|
CityId: params.CityId,
|
RegionId: params.RegionId,
|
CountryId: params.CountryId,
|
},
|
DetailAddress: params.DetailAddress,
|
}
|
|
return ecode.OK, salesLeads
|
}
|
|
// List
|
//
|
// @Tags SalesLeads
|
// @Summary 销售线索列表
|
// @Produce application/json
|
// @Param object body request.GetSalesLeadsList true "参数"
|
// @Success 200 {object} contextx.Response{data=response.SalesLeadsResponse}
|
// @Router /api/salesLeads/list [post]
|
func (s *SalesLeadsApi) List(c *gin.Context) {
|
var params request.GetSalesLeadsList
|
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
|
}
|
|
salesLeadss, total, errCode := salesLeadsService.GetSalesLeadsList(params.Page, params.PageSize, params.SearchMap)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
|
ctx.OkWithDetailed(response.SalesLeadsResponse{
|
List: salesLeadss,
|
Count: int(total),
|
})
|
}
|
|
// Push
|
//
|
// @Tags SalesLeads
|
// @Summary 推进销售线索
|
// @Produce application/json
|
// @Param object body request.PushSalesLeads true "查询参数"
|
// @Success 200 {object} contextx.Response{}
|
// @Router /api/salesLeads/push [post]
|
func (s *SalesLeadsApi) Push(c *gin.Context) {
|
var params request.PushSalesLeads
|
ctx, ok := contextx.NewContext(c, ¶ms)
|
if !ok {
|
return
|
}
|
|
if params.Step == constvar.SalesStatusFail {
|
errCode := salesLeadsService.DeleteSalesLeads([]int{params.Id})
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
} else {
|
errCode := salesLeadsService.PushSalesLeads(params.Id, params.Step, params.Reason)
|
if errCode != ecode.OK {
|
ctx.Fail(errCode)
|
return
|
}
|
}
|
|
ctx.Ok()
|
}
|
