hz_crm_api/controllers/cygx/interview_apply.go

package cygx

import (
	"encoding/json"
	"github.com/rdlucklib/rdluck_tools/paging"
	"hongze/hz_crm_api/controllers"
	"hongze/hz_crm_api/models"
	"hongze/hz_crm_api/models/cygx"
	cygxService "hongze/hz_crm_api/services/cygx"
	"hongze/hz_crm_api/utils"
	"strings"
)

// 访谈申请
type InterviewApplyController struct {
	controllers.BaseAuthController
}

// @Title 访谈申请列表
// @Description 访谈申请列表接口
// @Param   PageSize   query   int  true       "每页数据条数"
// @Param   CurrentIndex   query   int  true       "当前页页码，从1开始"
// @Param   KeyWord   query   string  true       "搜索关键词"
// @Success 200 {object} cygx.InterviewApplyListResp
// @router /interview/list [get]
func (this *InterviewApplyController) List() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()

	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	pageSize, _ := this.GetInt("PageSize")
	currentIndex, _ := this.GetInt("CurrentIndex")
	keyWord := this.GetString("KeyWord")
	keyWord = strings.Trim(keyWord, " ")
	keyWord = strings.Replace(keyWord, "'", "", -1)

	roleTypeCode := sysUser.RoleTypeCode
	var condition string
	var pars []interface{}
	//{
	//	if roleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
	//		if roleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN {
	//			condition += ` AND c.product_id=? `
	//			pars = append(pars, 1)
	//		} else if roleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
	//			condition += ` AND c.product_id=? `
	//			pars = append(pars, 2)
	//		} else {
	//			if sysUser.Authority <= 0 {
	//				condition += ` AND c.seller_id=?  `
	//				pars = append(pars, sysUser.AdminId)
	//			} else {
	//				if sysUser.Authority == 1 {
	//					condition += ` AND c.department_id=? `
	//					pars = append(pars, sysUser.DepartmentId)
	//				}
	//				if sysUser.Authority == 2 {
	//					condition += ` AND c.group_id=? `
	//					pars = append(pars, sysUser.GroupId)
	//				}
	//			}
	//		}
	//	}
	//}

	{
		if roleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
			//权益申请销售只能看到自己名下的客户的申请
			companyIds, err := cygxService.GetAdminLookUserCompanyIds(sysUser)
			if err != nil {
				br.Msg = "获取失败"
				br.ErrMsg = "获取失败，GetAdminLookUserCompanyIds Err:" + err.Error()
				return
			}

			lencompanyIds := len(companyIds)
			if lencompanyIds > 0 {
				condition += ` AND a.company_id  IN (` + utils.GetOrmInReplace(lencompanyIds) + `)`
				pars = append(pars, companyIds)
			}
		}
	}

	var startSize int
	if pageSize <= 0 {
		pageSize = utils.PageSize20
	}
	if currentIndex <= 0 {
		currentIndex = 1
	}
	startSize = paging.StartIndex(currentIndex, pageSize)

	if keyWord != "" {
		var conditionuiUser string
		var parsUser []interface{}
		conditionuiUser += ` AND (mobile LIKE '%` + keyWord + `%' OR email LIKE '%` + keyWord + `%' OR real_name LIKE '%` + keyWord + `%') `
		listUser, err := models.GetWxUserList(conditionuiUser, parsUser)
		if err != nil {
			br.Msg = "获取失败"
			br.ErrMsg = "，GetWxUserListErr:" + err.Error()
			return
		}
		var userIds []int

		for _, v := range listUser {
			userIds = append(userIds, int(v.UserId))
		}
		lenuserIds := len(userIds)
		if lenuserIds > 0 {
			condition += ` AND a.user_id  IN (` + utils.GetOrmInReplace(lenuserIds) + `)`
			pars = append(pars, userIds)
		}
	}

	total, err := cygx.GetInterviewApplyListCount(condition, pars)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据总数失败，Err:" + err.Error()
		return
	}

	list, err := cygx.GetInterviewApplyList(condition, pars, startSize, pageSize)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	var userIds []int

	for _, v := range list {
		userIds = append(userIds, v.UserId)
	}
	listUser, err := models.GetWxUserRaiSllerListByUserIds(userIds)
	if err != nil {
		br.Msg = "获取失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	//拼接用户相关信息
	mapUser := make(map[int]*models.WxUserSller)
	for _, v := range listUser {
		mapUser[v.UserId] = v
	}
	for _, v := range list {
		if mapUser[v.UserId] != nil {
			v.UserRealName = mapUser[v.UserId].RealName
			v.Mobile = mapUser[v.UserId].Mobile
			v.CompanyName = mapUser[v.UserId].CompanyName
			v.SalesRealName = mapUser[v.UserId].SellerName
		}
	}
	if list == nil {
		list = make([]*cygx.CygxInterviewApply, 0)
	}
	resp := new(cygx.InterviewApplyListResp)
	page := paging.GetPaging(currentIndex, pageSize, total)
	resp.List = list
	resp.Paging = page

	br.Ret = 200
	br.Success = true
	br.Msg = "获取成功"
	br.Data = resp
}

// @Title 访谈申请状态变更接口
// @Description 访谈申请状态变更接口（包含取消和状态更新）
// @Param	request	body cygx.InterviewApplyStatusReq true "type json string"
// @Success Ret=200 访谈申请取消成功
// @router /interview/status/modify [post]
func (this *InterviewApplyController) InterviewApplyCancel() {
	br := new(models.BaseResponse).Init()
	defer func() {
		this.Data["json"] = br
		this.ServeJSON()
	}()
	sysUser := this.SysUser
	if sysUser == nil {
		br.Msg = "请登录"
		br.ErrMsg = "请登录，SysUser Is Empty"
		br.Ret = 408
		return
	}
	var req cygx.InterviewApplyStatusReq
	err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
	if err != nil {
		br.Msg = "参数解析异常！"
		br.ErrMsg = "参数解析失败，Err:" + err.Error()
		return
	}
	if req.InterviewApplyId <= 0 {
		br.Msg = "参数错误"
		br.ErrMsg = "参数错误，访谈申请id小于等于0"
		return
	}
	item, err := cygx.GetCygxInterviewApplyDetail(req.InterviewApplyId)
	if err != nil {
		br.Msg = "获取数据失败"
		br.ErrMsg = "获取数据失败，Err:" + err.Error()
		return
	}
	var status string
	if req.HandleType == 2 {
		if item.Status == "已取消" || item.Status == "已完成" {
			br.Msg = "当前状态为：" + item.Status + "，不可进行取消操作"
			br.ErrMsg = "当前状态为：" + item.Status + "，不可进行取消操作"
			return
		}
		status = "已取消"
	} else {
		if req.InterviewTime != "" {
			status = "待访谈"
		} else {
			status = "已完成"
		}
	}
	err = cygx.InterviewApplyStatusModify(req.InterviewApplyId, status, req.InterviewTime)
	if err != nil {
		br.Msg = "状态更新失败"
		br.ErrMsg = "状态更新失败，Err:" + err.Error()
		return
	}
	br.Ret = 200
	br.Success = true
	br.Msg = "状态更新成功"
}