hongze_task/services/cygx/activity_points_set.go

package cygx

import (
	"errors"
	"fmt"
	"hongze/hongze_task/models"
	"hongze/hongze_task/models/data_manage"
	"hongze/hongze_task/services/alarm_msg"
	"hongze/hongze_task/utils"
	"strconv"
	"strings"
	"time"
)

type YanXuanActivityPointsRedis struct {
	UserId           int       `description:"用户ID"`
	ComapnyId        int       `description:"公司ID"`
	ActivityId       int       `description:"活动ID"`
	PublishStatus    int       `description:"发布状态 1已发布，0未发布"`
	SourceType       int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会、6 研选审批通过的时候研选扣点更新。"`
	AdminId          int       `description:"管理员、销售ID"`
	Source           int       `description:" 来源，1客户端，2后台添加, 3开发人员手动添加、4定时任务"`
	RegisterPlatform int       `description:"来源 1小程序，2：网页"`
	CreateTime       time.Time `description:"创建时间"`
}

//func init(){
//	log := &YanXuanActivityPointsRedis{ComapnyId: 16, SourceType: 7, Source: 4, CreateTime: time.Now()}
//	if utils.Re == nil {
//		err := utils.Rc.LPush(utils.CYGX_YANXUAN_POINTS_KEY, log)
//		if err != nil {
//			fmt.Println("YanXuanActivityPointsRedis LPush Err:" + err.Error())
//		}
//	}
//}

// 6 研选审批通过的时候研选扣点更新
func YanXuanCompanyApproval(comapnyId int) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			msg := fmt.Sprint("comapnyId:", comapnyId)
			go alarm_msg.SendAlarmMsg("研选审批通过的时候研选扣点更新，写入Redis队列消息失败："+err.Error()+msg, 2)
		}
	}()
	//SourceType int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会。6 研选审批通过的时候研选扣点更新。7,正式专试用定时任务更新"`
	log := &YanXuanActivityPointsRedis{ComapnyId: comapnyId, SourceType: 6, Source: 2, CreateTime: time.Now()}
	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CYGX_YANXUAN_POINTS_KEY, log)
		if err != nil {
			fmt.Println("YanXuanActivityPointsRedis LPush Err:" + err.Error())
		}
	}
	return
}


// 7 正式专试用定时任务更新研选扣点
func YanXuanCompanyCompanyTryOut(comapnyId int) (err error) {
	defer func() {
		if err != nil {
			fmt.Println(err)
			msg := fmt.Sprint("comapnyId:", comapnyId)
			go alarm_msg.SendAlarmMsg("正式专试用定时任务更新研选扣点，写入Redis队列消息失败："+err.Error()+msg, 2)
		}
	}()
	//SourceType int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会。6 研选审批通过的时候研选扣点更新。7,正式专试用定时任务更新"`
	log := &YanXuanActivityPointsRedis{ComapnyId: comapnyId, SourceType: 7, Source: 4, CreateTime: time.Now()}
	if utils.Re == nil {
		err := utils.Rc.LPush(utils.CYGX_YANXUAN_POINTS_KEY, log)
		if err != nil {
			fmt.Println("YanXuanActivityPointsRedis LPush Err:" + err.Error())
		}
	}
	return
}

// 审批通过的时候专项调研次数更新
func ActivitySpecialCompanyApproval(companyId int) (err error) {
	comapny, e := models.GetCompanyById(companyId)
	if e != nil {
		err = errors.New("GetCompanyById err:" + e.Error())
		return
	}
	// 获取继承点数
	inheritList, e := data_manage.GetCygxActivitySpecialInheritPointsByCompanyId(companyId)
	if e != nil && e.Error() != utils.ErrNoRow() {
		err = errors.New("GetCygxActivitySpecialInheritPointsByCompanyId, Err: " + e.Error())
	}
	chartNameMap := map[string]int{utils.YI_YAO_NAME: 0, utils.XIAO_FEI_NAME: 0, utils.KE_JI_NAME: 0, utils.ZHI_ZAO_NAME: 0}

	userType, packageType, _, _, _ := GetUserType(companyId)
	itemBill := new(data_manage.CygxActivitySpecialTripBill)
	itemBill.CreateTime = time.Now()
	itemBill.CompanyId = companyId
	itemBill.CompanyName = comapny.CompanyName
	itemBill.Source = 2
	itemBill.DoType = 2
	itemBill.Way = 3
	if userType == 2{
		packageTypeMap := map[int]int{1: 16, 2: 10}
		totalTrip := packageTypeMap[packageType]
		if len(inheritList) > 0 {
			for _, v := range inheritList {
				if v.ChartPermissionId == 0 {
					itemBill.BillDetailed = totalTrip + v.Points
				} else {
					itemBill.BillDetailed = totalTrip
				}
			}
		} else {
			itemBill.BillDetailed = totalTrip
		}

		itemBill.Total = strconv.Itoa(itemBill.BillDetailed) + "次"
		if totalTrip == 10 {
			itemBill.Content = "45w大套餐转正"
		} else {
			itemBill.Content = "70w大套餐转正"
		}
	} else {
		list, e := GetCompanyReportPermissionUpgrade(companyId, 2)
		if e != nil && e.Error() != utils.ErrNoRow() {
			err = errors.New("GetCompanyReportPermissionUpgrade, Err: " + e.Error())
		}
		if len(list) == 0 {
			return
		}
		var chartPermissionIdSlice []string
		mapChartName := make(map[string]int)
		mapInheritChartName := make(map[string]int)
		mapPermissionNameTrip := make(map[string]int)
		//mapPermissionName := make(map[int]string)
		for _, v := range list {
			chartPermissionIdSlice = append(chartPermissionIdSlice, strconv.Itoa(v.ChartPermissionId))
		}
		chartList, e := models.GetChartPermissionByIds(chartPermissionIdSlice)
		if e != nil {
			err = errors.New("获取品种信息失败, Err:" + e.Error())
			return
		}
		// 10.9.1本身升级套餐没有也可能通过继承获得
		//if len(chartList) == 0 {
		//	return
		//}
		for _, v := range chartList {
			mapChartName[v.PermissionName] = 5 + mapPermissionNameTrip[v.ChartPermissionName]
		}
		for _, v := range inheritList {
			mapInheritChartName[v.ChartPermissionName] = v.Points
		}
		for k, _ := range chartNameMap {
			if _, ok := mapChartName[k]; ok {
				if inherit, ok2 := mapInheritChartName[k]; ok2 {
					mapChartName[k] += inherit
				}
			}
		}
		for k, v := range mapChartName {
			if v > 0 {
				itemBill.BillDetailed += v
				itemBill.Total += k + strconv.Itoa(v) + "次+"
			}
		}
		itemBill.Content = "行业升级套餐转正"
		itemBill.Total = strings.TrimRight(itemBill.Total, "+")
	}
	err = data_manage.AddCygxActivitySpecialTripBill(itemBill)
	if err != nil {
		return
	}
	return
}