add

wangpengfei

2023-08-11 69ac5c4605f340144144a4b0954c7768697e95e6

add

add the push function to slaeChance

 api/v1/saleChance.go

@@ -1,212 +1,239 @@
package v1



import (

    "aps_crm/model"

    "aps_crm/model/request"

    "aps_crm/model/response"

    "aps_crm/pkg/contextx"

    "aps_crm/pkg/ecode"

    "github.com/gin-gonic/gin"

    "strconv"

)



type SaleChanceApi struct{}



// Add

//

//    @Tags        SaleChance

//    @Summary    添加销售机会

//    @Produce    application/json

//    @Param        object    body        request.AddSaleChance    true    "查询参数"

//    @Success    200        {object}    contextx.Response{}

//    @Router        /api/saleChance/add [post]

func (s *SaleChanceApi) Add(c *gin.Context) {

    var params request.AddSaleChance

    ctx, ok := contextx.NewContext(c, &params)

    if !ok {

        return

    }



    errCode, saleChance := checkSaleChanceParams(params.SaleChance)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    errCode = saleChanceService.AddSaleChance(&saleChance)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    ctx.Ok()

}



// Delete

//

//    @Tags        SaleChance

//    @Summary    删除销售机会

//    @Produce    application/json

//    @Param        id    path        int    true    "查询参数"

//    @Success    200    {object}    contextx.Response{}

//    @Router        /api/saleChance/delete/{id} [delete]

func (s *SaleChanceApi) Delete(c *gin.Context) {

    ctx, ok := contextx.NewContext(c, nil)

    if !ok {

        return

    }



    id, _ := strconv.Atoi(c.Param("id"))

    errCode := saleChanceService.DeleteSaleChance(id)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    ctx.Ok()

}



// Update

//

//    @Tags        SaleChance

//    @Summary    更新销售机会

//    @Produce    application/json

//    @Param        object    body        request.UpdateSaleChance    true    "查询参数"

//    @Success    200        {object}    contextx.Response{}

//    @Router        /api/saleChance/update [put]

func (s *SaleChanceApi) Update(c *gin.Context) {

    var params request.UpdateSaleChance

    ctx, ok := contextx.NewContext(c, &params)

    if !ok {

        return

    }



    // check id

    if params.Id == 0 {

        ctx.Fail(ecode.InvalidParams)

        return

    }



    errCode, saleChance := checkSaleChanceParams(params.SaleChance)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    saleChance.Id = params.Id



    errCode = saleChanceService.UpdateSaleChance(&saleChance)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    ctx.Ok()

}



// checkSaleChanceParams

// 检查销售机会参数

func checkSaleChanceParams(saleChance request.SaleChance) (int, model.SaleChance) {

    var errCode int

    var sc model.SaleChance



    //if saleChance.Name == "" {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}

    //

    //if saleChance.Number == "" {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}

    //

    //if saleChance.MemberId == 0 {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}

    //

    //if saleChance.Currency == 0 {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}

    //

    //if saleChance.ExpectedTime == "" {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}

    //

    //if saleChance.ProjectedAmount == 0 {

    //    errCode = ecode.InvalidParams

    //    return errCode, sc

    //}



    t, err := checkTimeFormat(saleChance.ExpectedTime)

    if err != nil {

        errCode = ecode.InvalidParams

        return errCode, sc

    }



    sc.ExpectedTime = t



    sc.Name = saleChance.Name

    sc.Number = saleChance.Number

    sc.ContactId = saleChance.ContactId

    sc.ClientId = saleChance.ClientId

    sc.SalesSourcesId = saleChance.SalesSourcesId

    sc.SaleTypeId = saleChance.SaleTypeId

    sc.SaleStageId = saleChance.SaleStageId

    sc.MemberId = saleChance.MemberId

    sc.RegularCustomersId = saleChance.RegularCustomersId

    sc.Competitors = saleChance.Competitors

    sc.PossibilitiesId = saleChance.Possibilities

    sc.Budget = saleChance.Budget

    sc.ProjectedAmount = saleChance.ProjectedAmount

    sc.Currency = saleChance.Currency

    sc.StatusId = saleChance.StatusId

    sc.PainPoints = saleChance.PainPoints

    sc.WhetherEstablished = saleChance.WhetherEstablished

    sc.CapitalBudget = saleChance.CapitalBudget

    sc.KeyMaker = saleChance.KeyMaker

    sc.KeyFactors = saleChance.KeyFactors

    sc.Process = saleChance.Process

    sc.Solutions = saleChance.Solutions

    sc.Advantages = saleChance.Advantages

    sc.Disadvantages = saleChance.Disadvantages

    sc.Opportunities = saleChance.Opportunities

    sc.Threats = saleChance.Threats

    sc.Remark = saleChance.Remark

    sc.DetailAddress = saleChance.DetailAddress

    sc.Address.RegionId = saleChance.Address.RegionId

    sc.Address.CityId = saleChance.Address.CityId

    sc.Address.CountryId = saleChance.Address.CountryId

    sc.Address.ProvinceId = saleChance.Address.ProvinceId



    return ecode.OK, sc

}



// List

//

//    @Tags        SaleChance

//    @Summary    销售机会列表

//    @Produce    application/json

//    @Param        object    body        request.GetSaleChanceList    true    "参数"

// @Success    200        {object}    contextx.Response{data=response.SaleChanceResponse}

//    @Router        /api/saleChance/list [post]

func (con *SaleChanceApi) List(c *gin.Context) {

    var params request.GetSaleChanceList

    ctx, ok := contextx.NewContext(c, &params)

    if !ok {

        return

    }



    saleChances, total, errCode := saleChanceService.GetSaleChanceList(params.Page, params.PageSize, params.Keyword)

    if errCode != ecode.OK {

        ctx.Fail(errCode)

        return

    }



    ctx.OkWithDetailed(response.SaleChanceResponse{

        List:  saleChances,

        Count: int(total),

    })

}
package v1

import (
    "aps_crm/model"
    "aps_crm/model/request"
    "aps_crm/model/response"
    "aps_crm/pkg/contextx"
    "aps_crm/pkg/ecode"
    "github.com/gin-gonic/gin"
    "strconv"
)

type SaleChanceApi struct{}

// Add
//
//    @Tags        SaleChance
//    @Summary    添加销售机会
//    @Produce    application/json
//    @Param        object    body        request.AddSaleChance    true    "查询参数"
//    @Success    200        {object}    contextx.Response{}
//    @Router        /api/saleChance/add [post]
func (s *SaleChanceApi) Add(c *gin.Context) {
    var params request.AddSaleChance
    ctx, ok := contextx.NewContext(c, &params)
    if !ok {
        return
    }

    errCode, saleChance := checkSaleChanceParams(params.SaleChance)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    errCode = saleChanceService.AddSaleChance(&saleChance)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    ctx.Ok()
}

// Delete
//
//    @Tags        SaleChance
//    @Summary    删除销售机会
//    @Produce    application/json
//    @Param        id    path        int    true    "查询参数"
//    @Success    200    {object}    contextx.Response{}
//    @Router        /api/saleChance/delete/{id} [delete]
func (s *SaleChanceApi) Delete(c *gin.Context) {
    ctx, ok := contextx.NewContext(c, nil)
    if !ok {
        return
    }

    id, _ := strconv.Atoi(c.Param("id"))
    errCode := saleChanceService.DeleteSaleChance(id)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    ctx.Ok()
}

// Update
//
//    @Tags        SaleChance
//    @Summary    更新销售机会
//    @Produce    application/json
//    @Param        object    body        request.UpdateSaleChance    true    "查询参数"
//    @Success    200        {object}    contextx.Response{}
//    @Router        /api/saleChance/update [put]
func (s *SaleChanceApi) Update(c *gin.Context) {
    var params request.UpdateSaleChance
    ctx, ok := contextx.NewContext(c, &params)
    if !ok {
        return
    }

    // check id
    if params.Id == 0 {
        ctx.Fail(ecode.InvalidParams)
        return
    }

    errCode, saleChance := checkSaleChanceParams(params.SaleChance)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    saleChance.Id = params.Id

    errCode = saleChanceService.UpdateSaleChance(&saleChance)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    ctx.Ok()
}

// checkSaleChanceParams
// 检查销售机会参数
func checkSaleChanceParams(saleChance request.SaleChance) (int, model.SaleChance) {
    var errCode int
    var sc model.SaleChance

    //if saleChance.Name == "" {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}
    //
    //if saleChance.Number == "" {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}
    //
    //if saleChance.MemberId == 0 {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}
    //
    //if saleChance.Currency == 0 {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}
    //
    //if saleChance.ExpectedTime == "" {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}
    //
    //if saleChance.ProjectedAmount == 0 {
    //    errCode = ecode.InvalidParams
    //    return errCode, sc
    //}

    t, err := checkTimeFormat(saleChance.ExpectedTime)
    if err != nil {
        errCode = ecode.InvalidParams
        return errCode, sc
    }

    sc.ExpectedTime = t

    sc.Name = saleChance.Name
    sc.Number = saleChance.Number
    sc.ContactId = saleChance.ContactId
    sc.ClientId = saleChance.ClientId
    sc.SalesSourcesId = saleChance.SalesSourcesId
    sc.SaleTypeId = saleChance.SaleTypeId
    sc.SaleStageId = saleChance.SaleStageId
    sc.MemberId = saleChance.MemberId
    sc.RegularCustomersId = saleChance.RegularCustomersId
    sc.Competitors = saleChance.Competitors
    sc.PossibilitiesId = saleChance.Possibilities
    sc.Budget = saleChance.Budget
    sc.ProjectedAmount = saleChance.ProjectedAmount
    sc.Currency = saleChance.Currency
    sc.StatusId = saleChance.StatusId
    sc.PainPoints = saleChance.PainPoints
    sc.WhetherEstablished = saleChance.WhetherEstablished
    sc.CapitalBudget = saleChance.CapitalBudget
    sc.KeyMaker = saleChance.KeyMaker
    sc.KeyFactors = saleChance.KeyFactors
    sc.Process = saleChance.Process
    sc.Solutions = saleChance.Solutions
    sc.Advantages = saleChance.Advantages
    sc.Disadvantages = saleChance.Disadvantages
    sc.Opportunities = saleChance.Opportunities
    sc.Threats = saleChance.Threats
    sc.Remark = saleChance.Remark
    sc.DetailAddress = saleChance.DetailAddress
    sc.Address.RegionId = saleChance.Address.RegionId
    sc.Address.CityId = saleChance.Address.CityId
    sc.Address.CountryId = saleChance.Address.CountryId
    sc.Address.ProvinceId = saleChance.Address.ProvinceId

    return ecode.OK, sc
}

// List
//
//    @Tags        SaleChance
//    @Summary    销售机会列表
//    @Produce    application/json
//    @Param        object    body        request.GetSaleChanceList    true    "参数"
//
// @Success    200        {object}    contextx.Response{data=response.SaleChanceResponse}
//
//    @Router        /api/saleChance/list [post]
func (con *SaleChanceApi) List(c *gin.Context) {
    var params request.GetSaleChanceList
    ctx, ok := contextx.NewContext(c, &params)
    if !ok {
        return
    }

    saleChances, total, errCode := saleChanceService.GetSaleChanceList(params.Page, params.PageSize, params.Keyword)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    ctx.OkWithDetailed(response.SaleChanceResponse{
        List:  saleChances,
        Count: int(total),
    })
}

// Push
//
//    @Tags        SaleChance
//    @Summary    推进销售机会
//    @Produce    application/json
//    @Param        object    body        request.PushSaleChance  true    "查询参数"
//    @Success    200    {object}    contextx.Response{}
//    @Router        /api/saleChance/push [put]
func (s *SaleChanceApi) Push(c *gin.Context) {
    var params request.PushSaleChance
    ctx, ok := contextx.NewContext(c, &params)
    if !ok {
        ctx.Fail(ecode.InvalidParams)
        return
    }

    errCode := saleChanceService.PushSaleChance(params.Id, params.Step)
    if errCode != ecode.OK {
        ctx.Fail(errCode)
        return
    }

    ctx.Ok()
}

 docs/docs.go

@@ -6388,6 +6388,36 @@
                }
            }
        },
        "/api/saleChance/push": {
            "put": {
                "produces": [
                    "application/json"
                ],
                "tags": [
                    "SaleChance"
                ],
                "summary": "推进销售机会",
                "parameters": [
                    {
                        "description": "查询参数",
                        "name": "object",
                        "in": "body",
                        "required": true,
                        "schema": {
                            "$ref": "#/definitions/request.PushSaleChance"
                        }
                    }
                ],
                "responses": {
                    "200": {
                        "description": "OK",
                        "schema": {
                            "$ref": "#/definitions/contextx.Response"
                        }
                    }
                }
            }
        },
        "/api/saleChance/update": {
            "put": {
                "produces": [
@@ -14863,6 +14893,21 @@
                }
            }
        },
        "request.PushSaleChance": {
            "type": "object",
            "required": [
                "id",
                "step"
            ],
            "properties": {
                "id": {
                    "type": "integer"
                },
                "step": {
                    "type": "integer"
                }
            }
        },
        "request.PushSalesLeads": {
            "type": "object",
            "properties": {

 docs/swagger.json

@@ -6376,6 +6376,36 @@
                }
            }
        },
        "/api/saleChance/push": {
            "put": {
                "produces": [
                    "application/json"
                ],
                "tags": [
                    "SaleChance"
                ],
                "summary": "推进销售机会",
                "parameters": [
                    {
                        "description": "查询参数",
                        "name": "object",
                        "in": "body",
                        "required": true,
                        "schema": {
                            "$ref": "#/definitions/request.PushSaleChance"
                        }
                    }
                ],
                "responses": {
                    "200": {
                        "description": "OK",
                        "schema": {
                            "$ref": "#/definitions/contextx.Response"
                        }
                    }
                }
            }
        },
        "/api/saleChance/update": {
            "put": {
                "produces": [
@@ -14851,6 +14881,21 @@
                }
            }
        },
        "request.PushSaleChance": {
            "type": "object",
            "required": [
                "id",
                "step"
            ],
            "properties": {
                "id": {
                    "type": "integer"
                },
                "step": {
                    "type": "integer"
                }
            }
        },
        "request.PushSalesLeads": {
            "type": "object",
            "properties": {

 docs/swagger.yaml

@@ -3365,6 +3365,16 @@
      subOrderId:
        type: integer
    type: object
  request.PushSaleChance:
    properties:
      id:
        type: integer
      step:
        type: integer
    required:
    - id
    - step
    type: object
  request.PushSalesLeads:
    properties:
      id:
@@ -9528,6 +9538,25 @@
      summary: 销售机会列表
      tags:
      - SaleChance
  /api/saleChance/push:
    put:
      parameters:
      - description: 查询参数
        in: body
        name: object
        required: true
        schema:
          $ref: '#/definitions/request.PushSaleChance'
      produces:
      - application/json
      responses:
        "200":
          description: OK
          schema:
            $ref: '#/definitions/contextx.Response'
      summary: 推进销售机会
      tags:
      - SaleChance
  /api/saleChance/update:
    put:
      parameters:

 model/request/saleChance.go

@@ -46,3 +46,8 @@
    PageInfo
    Keyword string `json:"keyword"`
}

type PushSaleChance struct {
    Id   int `json:"id" binding:"required"`
    Step int `json:"step" binding:"required"`
}

 router/saleChance.go

@@ -14,6 +14,7 @@
        saleChanceRouter.POST("add", saleChanceApi.Add)             // 添加销售机会
        saleChanceRouter.DELETE("delete/:id", saleChanceApi.Delete) // 删除销售机会
        saleChanceRouter.PUT("update", saleChanceApi.Update)        // 更新销售机会
        saleChanceRouter.POST("list", saleChanceApi.List)            // 获取销售机会列表
        saleChanceRouter.POST("list", saleChanceApi.List)           // 获取销售机会列表
        saleChanceRouter.PUT("push", saleChanceApi.Push)            // 推进销售机会
    }
}
}

 service/saleChance.go

@@ -62,3 +62,25 @@
    }
    return contacts, total, ecode.OK
}

// push
func (SaleChanceService) PushSaleChance(id, step int) int {
    // check saleChange exist
    errCode := CheckSaleChangeExist(id)
    if errCode != ecode.OK {
        return errCode
    }
    // check step
    _, err := model.NewSaleStageSearch().SetId(step).Find()
    if err != nil {
        return ecode.SaleStageNotExist
    }

    // push saleChange
    err = model.NewSaleChanceSearch().SetId(id).Update(&model.SaleChance{SaleStageId: step})
    if err != nil {
        return ecode.SaleChanceUpdateErr
    }

    return ecode.OK
}