hongze_web_mfyx/services/user_permission.go

package services

import (
	"errors"
	"fmt"
	"hongze/hongze_web_mfyx/models"
	"hongze/hongze_web_mfyx/models/order"
	"hongze/hongze_web_mfyx/utils"
	"strings"
)

var (
	UserPermissionOperationModeApply      = "Apply"
	UserPermissionOperationModeCall       = "Call"
	UserPermissionPopupMsgApplyActivity   = "您暂无权限参加此活动，若想参加可以申请开通对应的试用权限"
	UserPermissionPopupMsgCallActivity    = "您暂无权限参加此活动，若想参加可以联系对口销售"
	UserPermissionPopupMsgApplyMicroVideo = "您暂无权限查看此视频，若想查看可以申请开通对应的试用权限"
	UserPermissionPopupMsgApplyMicroVoice = "您暂无权限查看此音频，若想查看可以申请开通对应的试用权限"
	UserPermissionPopupMsgCallMicroVoice  = "您暂无权限查看此音频，若想参加可以联系对口销售"
	UserPermissionPopupMsgCallMicroVideo  = "您暂无权限查看此视频，若想查看可以联系对口销售"
)

// GetUserRaiPermissionInfo 获取权限类型及信息
// HasPermission int `description:"1:有该行业权限,正常展示，2：无该行业权限，不存在权益客户下（ficc），3:无该品类权限,已提交过申请，4：无该品类权限,未提交过申请，5：潜在客户，未提交过申请，6：潜在客户,已提交过申请"`
func GetUserRaiPermissionInfo1(userId, companyId int) (authInfo models.UserPermissionAuthInfo, permissionArr []string, err error) {
	// 用户申请记录
	applyCount, e := models.GetApplyRecordCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取用户申请信息失败, Err: " + e.Error())
		return
	}

	// 潜在用户
	if companyId <= 1 {
		authInfo.HasPermission = 5
		if applyCount > 0 {
			authInfo.HasPermission = 6
		}
		authInfo.OperationMode = UserPermissionOperationModeApply
		authInfo.PopupMsg = UserPermissionPopupMsgApplyActivity
		return
	}

	// 销售信息
	ficcSeller, e := models.GetSellerByCompanyIdCheckFicc(companyId, utils.COMPANY_PRODUCT_FICC_ID)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取FICC销售信息失败, Err: " + e.Error())
		return
	}
	raiSeller, e := models.GetSellerByCompanyIdCheckFicc(companyId, utils.COMPANY_PRODUCT_RAI_ID)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取权益销售信息失败, Err: " + e.Error())
		return
	}
	if raiSeller != nil {
		authInfo.SellerMobile = raiSeller.Mobile
		authInfo.SellerName = raiSeller.RealName
		authInfo.HasPermission = 4
		if applyCount > 0 {
			authInfo.HasPermission = 3
		}
		authInfo.OperationMode = UserPermissionOperationModeApply
		authInfo.PopupMsg = UserPermissionPopupMsgApplyActivity
		return
	}
	// 仅有FICC权限
	if ficcSeller != nil {
		authInfo.HasPermission = 2
		authInfo.OperationMode = UserPermissionOperationModeApply
		authInfo.PopupMsg = UserPermissionPopupMsgApplyActivity
		return
	}

	// permissions示例: 医药,消费,科技,智造,策略,专家,买方研选
	permissions, e := models.GetCompanyPermissionName(companyId)
	if e != nil {
		err = errors.New("获取客户权限失败, Err: " + e.Error())
		return
	}
	if permissions == "" {
		// 无权益权限

		// 有销售信息
		authInfo.HasPermission = 2
		authInfo.OperationMode = UserPermissionOperationModeCall
		authInfo.PopupMsg = UserPermissionPopupMsgCallActivity
		return

		// 无销售信息, 无申请, 视作潜在用户
		//authInfo.HasPermission = 3
		//authInfo.OperationMode = UserPermissionOperationModeApply
		//return
	}
	// 有基本的权益权限
	authInfo.HasPermission = 1
	permissionArr = strings.Split(permissions, ",")
	return
}

func GetUserRaiPermissionInfo(userId, companyId int) (authInfo models.UserPermissionAuthInfo, permissionArr []string, err error) {
	// 用户申请记录
	applyCount, e := models.GetApplyRecordCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取用户申请信息失败, Err: " + e.Error())
		return
	}

	// 潜在用户
	if companyId <= 1 {
		authInfo.HasPermission = 6
		if applyCount > 0 {
			authInfo.HasPermission = 7
		}
		authInfo.OperationMode = UserPermissionOperationModeApply
		authInfo.PopupMsg = UserPermissionPopupMsgApplyActivity
		return
	}

	// 销售信息
	ficcSeller, e := models.GetSellerByCompanyIdCheckFicc(companyId, utils.COMPANY_PRODUCT_FICC_ID)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取FICC销售信息失败, Err: " + e.Error())
		return
	}
	raiSeller, e := models.GetSellerByCompanyIdCheckFicc(companyId, utils.COMPANY_PRODUCT_RAI_ID)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取权益销售信息失败, Err: " + e.Error())
		return
	}
	if raiSeller != nil {
		authInfo.SellerMobile = raiSeller.Mobile
		authInfo.SellerName = raiSeller.RealName
	}
	// 仅有FICC权限
	if ficcSeller != nil && raiSeller == nil {
		authInfo.HasPermission = 2
		authInfo.OperationMode = UserPermissionOperationModeApply
		authInfo.PopupMsg = UserPermissionPopupMsgApplyActivity
		return
	}

	// permissions示例: 医药,消费,科技,智造,策略,专家,买方研选
	permissions, e := models.GetCompanyPermissionName(companyId)
	if e != nil {
		err = errors.New("获取客户权限失败, Err: " + e.Error())
		return
	}
	if permissions == "" {
		// 无权益权限
		if raiSeller != nil {
			// 有销售信息
			authInfo.HasPermission = 2
			authInfo.OperationMode = UserPermissionOperationModeCall
			authInfo.PopupMsg = UserPermissionPopupMsgCallActivity
			return
		}
		// 无销售信息, 无申请, 视作潜在用户
		authInfo.HasPermission = 3
		authInfo.OperationMode = UserPermissionOperationModeApply
		return
	}
	// 有基本的权益权限
	authInfo.HasPermission = 1
	permissionArr = strings.Split(permissions, ",")

	//判断用户是否开通了个人研选权限，如果有权限后缀拼接权限名称
	mfyxUserPermissionTotal := GetMfyxUserPermissionTotal(userId)
	if mfyxUserPermissionTotal == 1 {
		permissionArr = append(permissionArr, utils.CHART_PERMISSION_NAME_MF_YANXUAN)
	}
	return
}

// 查询研选的权限状态
func GetUserRaiPermissionYanXuanInfo(user *models.WxUserItem) (hasPermission int, err error) {
	//判断用户是否开通了个人研选权限
	mfyxUserPermissionTotal := GetMfyxUserPermissionTotal(user.UserId)
	if mfyxUserPermissionTotal == 1 {
		hasPermission = 1
		return
	}
	var condition string
	var pars []interface{}
	condition = " AND company_id = ?  AND status  IN ('正式','试用')  AND chart_permission_id = ?   ORDER BY company_report_permission_id DESC LIMIT 1  "
	pars = append(pars, user.CompanyId, utils.CHART_PERMISSION_ID_YANXUAN)
	companyReportPermissionDetail, e := models.GetCompanyReportPermissionDetailByCondition(condition, pars)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCompanyReportPermissionDetailByCondition, Err: " + e.Error())
		return
	}
	//如果用户没有研选权限，那么就获取他对应的状态码
	if companyReportPermissionDetail == nil {
		hasPermission, _, _, _, e = GetUserHasPermissionArticle(user)
		if e != nil {
			err = errors.New("GetUserHasPermissionArticle, Err: " + e.Error())
			return
		}
	} else {
		hasPermission = 1
	}
	return
}

func GetUserApplyRecordCount(userId int) (applyCount int, err error) {
	// 用户申请记录
	applyCount, e := models.GetApplyRecordCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取用户申请信息失败, Err: " + e.Error())
		return
	}
	return
}

// 是否需要上传名片
func GetCygxUserBusinessCardCount(userId, companyId int) (isNeedBusinessCard bool) {
	if companyId > 1 {
		return
	}
	var err error
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg(fmt.Sprint("是否需要上传名片失败 GetCygxUserBusinessCardCount, err：", err.Error()), 2)
		}
	}()
	businessCardCount, e := order.GetCygxUserBusinessCardCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCygxUserBusinessCardCount, Err: " + e.Error())
		return
	}
	if businessCardCount > 0 {
		return
	}
	isNeedBusinessCard = true
	return
}

// 获取客户是否有过历史申请记录
func GetUserApplyRecordCountByCompanyIdPay(companyIdPay int) (isCompanyApply bool) {
	var err error
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg(fmt.Sprint("获取客户是否有过历史申请记录失败 GetUserApplyRecordCountByCompanyIdPay, err：", err.Error()), 2)
		}
	}()
	//if companyIdPay >= 1 {
	//	return
	//}
	// 客户申请
	//applyCount, e := models.GetApplyRecordCountByCompanyIdPay(companyIdPay)
	//if e != nil {
	//	err = errors.New("GetApplyRecordCountByCompanyIdPay, Err: " + e.Error())
	//	return
	//}

	//有研选订阅的权限的也不开放申请按钮
	permissionCount, e := models.GetCompanyPermissionCheck(companyIdPay, utils.CHART_PERMISSION_ID_YANXUAN)
	if e != nil {
		err = errors.New("GetCompanyPermissionCheck, Err: " + e.Error())
		return
	}
	//if applyCount > 0 || permissionCount > 0 {
	if permissionCount > 0 {
		isCompanyApply = true
	}
	return
}

// 获取用户权限状态  https://hzstatic.hzinsights.com/static/images/202402/20240205/LpE6dspJCLzfQoCoE8SFMDiLuxXk.png（状态码说明）
func GetUserPermissionCode(userId, companyId int) (permission int, err error) {
	// 用户申请记录
	applyCount, e := models.GetApplyRecordCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取用户申请信息失败, Err: " + e.Error())
		return
	}

	if companyId == 1 {
		// 潜在用户
		if applyCount > 0 {
			permission = 6
		} else {
			permission = 7
		}
	} else {
		//权益客户
		raiCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_RAI_ID)
		if e != nil {
			err = errors.New("获取用户申请信息失败, Err: " + e.Error())
			return
		}
		if raiCount == 1 {
			if applyCount > 0 {
				permission = 2
			} else {
				permission = 3
			}
		} else {
			//ficc 客户
			ficcCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_FICC_ID)
			if e != nil {
				err = errors.New("获取用户申请信息失败, Err: " + e.Error())
				return
			}
			if ficcCount == 1 {
				if applyCount > 0 {
					permission = 4
				} else {
					permission = 5
				}
			}
		}
	}
	return
}

// 用户详情页获取用户权限状态  https://hzstatic.hzinsights.com/static/images/202402/20240205/LpE6dspJCLzfQoCoE8SFMDiLuxXk.png（状态码说明）
func GetUserDetailPermissionCode(userId, companyId int) (permission int, err error) {
	// 用户申请记录
	applyCount, e := models.GetApplyRecordCount(userId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("获取用户申请信息失败, Err: " + e.Error())
		return
	}
	if companyId == 1 {
		// 潜在用户
		if applyCount > 0 {
			permission = 6
		} else {
			permission = 7
		}
	} else {
		//权益客户
		raiCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_RAI_ID)
		if e != nil {
			err = errors.New("获取用户申请信息失败, Err: " + e.Error())
			return
		}

		if raiCount == 1 {
			if applyCount > 0 {
				permission = 2
			} else {
				permission = 3
			}
		} else {
			//ficc 客户
			ficcCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_FICC_ID)
			if e != nil {
				err = errors.New("获取用户申请信息失败, Err: " + e.Error())
				return
			}
			if ficcCount == 1 {
				if applyCount > 0 {
					permission = 4
				} else {
					permission = 5
				}
			}
		}
	}
	return
}

// 获取权益销售姓名
func GetSellerName(user *models.WxUserItem) (sellerName string, sellerId int) {
	var err error
	defer func() {
		if err != nil {
			fmt.Println(err)
			go utils.SendAlarmMsg(fmt.Sprint("获取权益销售姓名失败 GetSellerName, err：", err.Error()), 2)
		}
	}()
	companyId := user.CompanyId
	//潜在客户没有销售
	if user.CompanyId <= 1 {
		return
	}
	//权益客户
	raiCount, e := models.GetCompanyProductCount(companyId, utils.COMPANY_PRODUCT_RAI_ID)
	if e != nil {
		err = errors.New("GetCompanyProductCount, Err: " + e.Error())
		return
	}
	//仅开通FICC的客户不展示销售姓名
	if raiCount == 0 {
		return
	}
	sealldetail, e := models.GetRaiSellerByCompanyId(companyId)
	if e != nil {
		err = errors.New("GetRaiSellerByCompanyId, Err: " + e.Error())
		return
	}
	sellerName = sealldetail.RealName
	sellerId = sealldetail.AdminId
	return

}