aps/crm.git - Gitblit

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, &params)
    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, &params)
    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, &params)
    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, &params)
    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_id"] = userInfo.CrmUserId
    }
 
    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, &params)
    if !ok {
        return
    }
 
    errCode := salesLeadsService.PushSalesLeads(params.Id, params.Step, params.Reason)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }
    ctx.Ok()
}