no message

controllers/activity_special.go

@@ -238,34 +238,35 @@ func (this *ActivitySpecialCoAntroller) SpecialTripAdd() {
 				br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
 				return
 			}
+			go services.SpecialActivityPointsBillSignupAddSpecial(activityId, uid) // 用户报名专项调研活动扣点处理
 			//流水记录表
-			itemBill := new(models.CygxActivitySpecialTripBill)
-			itemBill.UserId = user.UserId
-			itemBill.ActivityId = activityInfo.ActivityId
-			itemBill.CreateTime = time.Now()
-			itemBill.Mobile = user.Mobile
-			itemBill.Email = user.Email
-			itemBill.CompanyId = user.CompanyId
-			itemBill.CompanyName = user.CompanyName
-			itemBill.RealName = user.RealName
-			itemBill.Source = 1
-			itemBill.DoType = 1
-			itemBill.BillDetailed = -1 // 流水减一
-			itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
-			itemBill.ChartPermissionId = activityInfo.ChartPermissionId
-			itemBill.ChartPermissionName = activityInfo.ChartPermissionName
-
-			if utils.InArrayByStr(utils.ACTIVITY_SPECIAL_TRIP_PERMISSION_NAME_OTHER, activityInfo.ChartPermissionName) {
-				//如果是策略、固收、周期行业，把代扣行业信息放入流水表，取消报名的时候，返点使用
-				maxChartPermissionId, maxChartPermissionName, err := services.GetSpecialBillMaxChartPermissionId(user)
-				if err != nil {
-					br.Msg = "操作失败"
-					br.ErrMsg = "获取销售信息失败,GetSpecialBillMaxChartPermissionId Err:" + err.Error()
-					return
-				}
-				itemBill.ChartPermissionId = maxChartPermissionId
-				itemBill.ChartPermissionName = maxChartPermissionName
-			}
+			//itemBill := new(models.CygxActivitySpecialTripBill)
+			//itemBill.UserId = user.UserId
+			//itemBill.ActivityId = activityInfo.ActivityId
+			//itemBill.CreateTime = time.Now()
+			//itemBill.Mobile = user.Mobile
+			//itemBill.Email = user.Email
+			//itemBill.CompanyId = user.CompanyId
+			//itemBill.CompanyName = user.CompanyName
+			//itemBill.RealName = user.RealName
+			//itemBill.Source = 1
+			//itemBill.DoType = 1
+			//itemBill.BillDetailed = -1 // 流水减一
+			//itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
+			//itemBill.ChartPermissionId = activityInfo.ChartPermissionId
+			//itemBill.ChartPermissionName = activityInfo.ChartPermissionName
+			//
+			//if utils.InArrayByStr(utils.ACTIVITY_SPECIAL_TRIP_PERMISSION_NAME_OTHER, activityInfo.ChartPermissionName) {
+			//	//如果是策略、固收、周期行业，把代扣行业信息放入流水表，取消报名的时候，返点使用
+			//	maxChartPermissionId, maxChartPermissionName, err := services.GetSpecialBillMaxChartPermissionId(user)
+			//	if err != nil {
+			//		br.Msg = "操作失败"
+			//		br.ErrMsg = "获取销售信息失败,GetSpecialBillMaxChartPermissionId Err:" + err.Error()
+			//		return
+			//	}
+			//	itemBill.ChartPermissionId = maxChartPermissionId
+			//	itemBill.ChartPermissionName = maxChartPermissionName
+			//}
 
 			var itemMeeting = new(models.CygxActivitySpecialMeetingDetail)
 			itemMeeting.UserId = user.UserId
@@ -343,18 +344,18 @@ func (this *ActivitySpecialCoAntroller) SpecialTripAdd() {
 					br.ErrMsg = "二次报名，更改报名是否有效状态失败，Err:" + err.Error()
 					return
 				}
-				resultTime := utils.StrTimeToTime(activityInfo.ActivityTime)
-				//48小时之内的取消也扣除一次参会记录
-				if time.Now().Add(+time.Hour * 48).After(resultTime) {
-					itemBill.BillDetailed = 0 //48小时之内，取消报名之后二次报名，不扣除流水记录
-				} else {
-					err = services.DeductTripRemainingtimesByUser(user, activityInfo) //扣除用户专项调研剩余次数
-					if err != nil {
-						br.Msg = "操作失败"
-						br.ErrMsg = "操作失败,Err:" + err.Error()
-						return
-					}
-				}
+				//resultTime := utils.StrTimeToTime(activityInfo.ActivityTime)
+				////48小时之内的取消也扣除一次参会记录
+				//if time.Now().Add(+time.Hour * 48).After(resultTime) {
+				//	itemBill.BillDetailed = 0 //48小时之内，取消报名之后二次报名，不扣除流水记录
+				//} else {
+				//	err = services.DeductTripRemainingtimesByUser(user, activityInfo) //扣除用户专项调研剩余次数
+				//	if err != nil {
+				//		br.Msg = "操作失败"
+				//		br.ErrMsg = "操作失败,Err:" + err.Error()
+				//		return
+				//	}
+				//}
 			}
 			//userType, tripRemaining, mapChartName, err := services.GetChartPermissionSpecialSurplusByCompany(user.CompanyId)
 			//if err != nil {
@@ -375,21 +376,21 @@ func (this *ActivitySpecialCoAntroller) SpecialTripAdd() {
 			//	itemBill.Total = strings.TrimRight(itemBill.Total, "+")
 			//}
 
-			totalText, err := services.HandleActivitySpecialTripBillTotalText(user.CompanyId)
-			if err != nil {
-				br.Msg = "报名失败，"
-				br.ErrMsg = "二次报名，更改报名是否有效状态失败，Err:" + err.Error()
-				return
-			}
-			itemBill.Total = totalText
+			//totalText, err := services.HandleActivitySpecialTripBillTotalText(user.CompanyId)
+			//if err != nil {
+			//	br.Msg = "报名失败，"
+			//	br.ErrMsg = "二次报名，更改报名是否有效状态失败，Err:" + err.Error()
+			//	return
+			//}
+			//itemBill.Total = totalText
 
 			//添加流水记录
-			err = models.AddCygxActivitySpecialTripBill(itemBill)
-			if err != nil {
-				br.Msg = "报名失败，"
-				br.ErrMsg = "AddCygxActivitySpecialTripBill，Err:" + err.Error()
-				return
-			}
+			//err = models.AddCygxActivitySpecialTripBill(itemBill)
+			//if err != nil {
+			//	br.Msg = "报名失败，"
+			//	br.ErrMsg = "AddCygxActivitySpecialTripBill，Err:" + err.Error()
+			//	return
+			//}
 			//添加数据到会信息
 			err = models.AddCygxActivitySpecialMeetingDetail(itemMeeting)
 			if err != nil {
@@ -465,48 +466,49 @@ func (this *ActivitySpecialCoAntroller) Tripcancel() {
 		br.ErrMsg = "操作失败,Err:" + errInfo.Error()
 		return
 	}
-	//流水记录表
-	itemBill := new(models.CygxActivitySpecialTripBill)
-	itemBill.UserId = user.UserId
-	itemBill.ActivityId = activityInfo.ActivityId
-	itemBill.CreateTime = time.Now()
-	itemBill.Mobile = user.Mobile
-	itemBill.Email = user.Email
-	itemBill.CompanyId = user.CompanyId
-	itemBill.CompanyName = user.CompanyName
-	itemBill.RealName = user.RealName
-	itemBill.Source = 1
-	itemBill.DoType = 2
-	itemBill.BillDetailed = 1 // 流水加一
-	itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
-	itemBill.ChartPermissionId = activityInfo.ChartPermissionId
-	itemBill.ChartPermissionName = activityInfo.ChartPermissionName
+	////流水记录表
+	//itemBill := new(models.CygxActivitySpecialTripBill)
+	//itemBill.UserId = user.UserId
+	//itemBill.ActivityId = activityInfo.ActivityId
+	//itemBill.CreateTime = time.Now()
+	//itemBill.Mobile = user.Mobile
+	//itemBill.Email = user.Email
+	//itemBill.CompanyId = user.CompanyId
+	//itemBill.CompanyName = user.CompanyName
+	//itemBill.RealName = user.RealName
+	//itemBill.Source = 1
+	//itemBill.DoType = 2
+	//itemBill.BillDetailed = 1 // 流水加一
+	//itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
+	//itemBill.ChartPermissionId = activityInfo.ChartPermissionId
+	//itemBill.ChartPermissionName = activityInfo.ChartPermissionName
 	resultTime := utils.StrTimeToTime(activityInfo.ActivityTime)
 
-	if utils.InArrayByStr(utils.ACTIVITY_SPECIAL_TRIP_PERMISSION_NAME_OTHER, activityInfo.ChartPermissionName) {
-		//如果是策略、固收、周期行业，把代扣行业信息放入流水表，取消报名的时候，返点使用
-		lastTripBill, err := models.GetCygxActivitySpecialTripBillLastDetialByActivityId(activityInfo.ActivityId, user.UserId)
-		if err != nil {
-			br.Msg = "操作失败"
-			br.ErrMsg = "获取销售信息失败,GetSpecialBillMaxChartPermissionId Err:" + err.Error()
-			return
-		}
-		itemBill.ChartPermissionId = lastTripBill.ChartPermissionId
-		itemBill.ChartPermissionName = lastTripBill.ChartPermissionName
-	}
+	//if utils.InArrayByStr(utils.ACTIVITY_SPECIAL_TRIP_PERMISSION_NAME_OTHER, activityInfo.ChartPermissionName) {
+	//	//如果是策略、固收、周期行业，把代扣行业信息放入流水表，取消报名的时候，返点使用
+	//	lastTripBill, err := models.GetCygxActivitySpecialTripBillLastDetialByActivityId(activityInfo.ActivityId, user.UserId)
+	//	if err != nil {
+	//		br.Msg = "操作失败"
+	//		br.ErrMsg = "获取销售信息失败,GetSpecialBillMaxChartPermissionId Err:" + err.Error()
+	//		return
+	//	}
+	//	itemBill.ChartPermissionId = lastTripBill.ChartPermissionId
+	//	itemBill.ChartPermissionName = lastTripBill.ChartPermissionName
+	//}
 	//48小时之内的取消也扣除一次参会记录
 	var isValid int
 	if time.Now().Add(+time.Hour * 48).After(resultTime) {
 		isValid = 1
-		itemBill.BillDetailed = 0 //48小时之内取消的活动扣点不返回
-	} else {
-		err = services.RebateTripRemainingtimesByUser(user, activityInfo) // 返点
-		if err != nil {
-			br.Msg = "操作失败"
-			br.ErrMsg = "操作失败,RebateTripRemainingtimesByUserErr:" + err.Error()
-			return
-		}
+		//itemBill.BillDetailed = 0 //48小时之内取消的活动扣点不返回
 	}
+	//else {
+	//	err = services.RebateTripRemainingtimesByUser(user, activityInfo) // 返点
+	//	if err != nil {
+	//		br.Msg = "操作失败"
+	//		br.ErrMsg = "操作失败,RebateTripRemainingtimesByUserErr:" + err.Error()
+	//		return
+	//	}
+	//}
 	//userType, tripRemaining, mapChartName, err := services.GetChartPermissionSpecialSurplusByCompany(user.CompanyId)
 	//if err != nil {
 	//	br.Msg = "获取专项调研剩余次数失败"
@@ -526,13 +528,13 @@ func (this *ActivitySpecialCoAntroller) Tripcancel() {
 	//	itemBill.Total = strings.TrimRight(itemBill.Total, "+")
 	//}
 
-	totalText, err := services.HandleActivitySpecialTripBillTotalText(user.CompanyId)
-	if err != nil {
-		br.Msg = "操作失败，"
-		br.ErrMsg = "HandleActivitySpecialTripBillTotalText，Err:" + err.Error()
-		return
-	}
-	itemBill.Total = totalText
+	//totalText, err := services.HandleActivitySpecialTripBillTotalText(user.CompanyId)
+	//if err != nil {
+	//	br.Msg = "操作失败，"
+	//	br.ErrMsg = "HandleActivitySpecialTripBillTotalText，Err:" + err.Error()
+	//	return
+	//}
+	//itemBill.Total = totalText
 	err = models.CancelActivitySpecialTripIsValid(isValid, activityInfo.ActivityId, uid)
 	if err != nil {
 		br.Msg = "操作失败"
@@ -546,7 +548,8 @@ func (this *ActivitySpecialCoAntroller) Tripcancel() {
 		br.ErrMsg = "CancelCygxActivitySpecialMeetingDetail,Err:" + err.Error()
 		return
 	}
-	go models.AddCygxActivitySpecialTripBill(itemBill)
+	go services.ActivityPointsBillSignupCancelSpecial(activityId, uid) // 用户取消报名专项调研活动扣点处理
+	//go models.AddCygxActivitySpecialTripBill(itemBill)
 
 	br.Ret = 200
 	br.Success = true

services/activity_points.go

@@ -136,6 +136,46 @@ func YanXuanActivityPointsBillSubmitMeeting(activityId, adminId int) (err error)
 	return
 }
 
+// 用户报名专项调研活动扣点处理
+func SpecialActivityPointsBillSignupAddSpecial(activityId, uid int) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			msg := fmt.Sprint("activityId:", activityId, "userId:", uid)
+			go utils.SendAlarmMsg("用户报名专项调研活动扣点处理，写入Redis队列消息失败 SpecialActivityPointsBillSignupAddSpecial ："+err.Error()+msg, 2)
+		}
+	}()
+	//SourceType int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会。"`
+	log := &models.YanXuanActivityPointsRedis{UserId: uid, ActivityId: activityId, SourceType: 1, RegisterPlatform: utils.REGISTER_PLATFORM, Source: 9, 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 ActivityPointsBillSignupCancelSpecial(activityId, uid int) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			msg := fmt.Sprint("activityId:", activityId, "userId:", uid)
+			go utils.SendAlarmMsg("用户取消报名专项调研活动扣点处理，写入Redis队列消息失败 ActivityPointsBillSignupCancelSpecial ："+err.Error()+msg, 2)
+		}
+	}()
+	//SourceType int       `description:"1：报名、 2：取消报名、3：活动编辑、4：活动发布，取消发布、5：活动到会。"`
+	log := &models.YanXuanActivityPointsRedis{UserId: uid, ActivityId: activityId, SourceType: 1, RegisterPlatform: utils.REGISTER_PLATFORM, Source: 10, 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
+}
+
 // YanXuanActivityPointsBillReduce 处理研选活动扣点
 func YanXuanActivityPointsBillReduce() (err error) {
 	for {
@@ -178,6 +218,14 @@ func YanXuanActivityPointsBillReduce() (err error) {
 				//go YanXuanActivityVivoPointsBillSignupReduce(log)
 				fmt.Println("8：播放研选扣点音视频。")
 				break
+			case 9:
+				go YanXuanActivityPointsBillSignupAddReduceSpecial(log)
+				fmt.Println("9：报名专项调研活动。")
+				break
+			case 10:
+				go SpecialActivityPointsBillSignupCancelReduce(log)
+				fmt.Println(" 2：取消报名")
+				break
 			default:
 				fmt.Println(string(b))
 				go utils.SendAlarmMsg("处理研选活动扣点处理Redis队列消息失败："+string(b), 2)
@@ -1248,3 +1296,162 @@ func YanXuanActivityVivoPointsBillSignupReduce(log models.YanXuanActivityPointsR
 	err = models.AddCygxActivityPointsBillMulti(items, itemCompanys)
 	return
 }
+
+// 9:用户报名（专项调研活动）
+func YanXuanActivityPointsBillSignupAddReduceSpecial(log models.YanXuanActivityPointsRedis) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go utils.SendAlarmMsg("用户报名活动扣点，处理Redis队列消息失败："+err.Error()+fmt.Sprint("ActivityId", log.ActivityId, "userId", log.UserId), 2)
+		}
+	}()
+	//加2000毫秒的延迟
+	time.Sleep(2 * time.Second)
+	activityId := log.ActivityId
+	userId := log.UserId
+	activityInfo, e := models.GetCygxActivitySpecialDetail(activityId)
+	if e != nil {
+		err = errors.New("GetCygxActivitySpecialDetail" + e.Error())
+		return
+	}
+	user, e := models.GetWxUserItemByUserId(userId)
+	if e != nil {
+		err = errors.New("GetWxUserItemByUserId" + e.Error())
+		return
+	}
+	companyId := user.CompanyId
+	//判断公司是不是满足扣点情况，如果是后台超管手动给试用客户报名，就写入一条点数初始化数据
+	total, e := models.GetCygxActivitySpecialPermissionPointsCountByCompanyId(companyId)
+	if e != nil {
+		err = errors.New("GetCygxActivityPointsCompanyCountByCompanyId, Err: " + e.Error())
+		return
+	}
+	var companyPointsNum float64
+	if total == 0 {
+		companyPointsNum = 0
+		itemPointsCompany := new(models.CygxActivitySpecialPermissionPoints)
+		itemPointsCompany.CompanyId = companyId
+		itemPointsCompany.CompanyName = user.CompanyName
+		itemPointsCompany.CreateTime = time.Now()
+		itemPointsCompany.ModifyTime = time.Now()
+		e = models.AddCygxActivitySpecialPermissionPoints(itemPointsCompany)
+		if e != nil {
+			err = errors.New("AddCygxActivitySpecialPermissionPoints, Err: " + e.Error())
+			return
+		}
+	} else {
+		// 获取用户所在公司剩余的点
+		companyPointsNum, e = models.GetCygxActivitySpecialPermissionPoints(user.CompanyId)
+		if e != nil && e.Error() != utils.ErrNoRow() {
+			err = errors.New("GetCygxActivitySpecialPermissionPoints, Err: " + e.Error())
+			return
+		}
+	}
+
+	//获取需要添加的流水信息
+	var items []*models.CygxActivitySpecialTripBill
+	itemBill := new(models.CygxActivitySpecialTripBill)
+	itemBill.UserId = user.UserId
+	itemBill.ActivityId = activityInfo.ActivityId
+	itemBill.CreateTime = time.Now()
+	itemBill.Mobile = user.Mobile
+	itemBill.Email = user.Email
+	itemBill.CompanyId = user.CompanyId
+	itemBill.CompanyName = user.CompanyName
+	itemBill.RealName = user.RealName
+	itemBill.Source = 1
+	itemBill.DoType = 1
+	itemBill.BillDetailed = -1 // 流水减一
+	itemBill.RegisterPlatform = utils.REGISTER_PLATFORM
+	itemBill.ChartPermissionId = activityInfo.ChartPermissionId
+	itemBill.ChartPermissionName = activityInfo.ChartPermissionName
+	itemBill.Content = activityInfo.ResearchTheme + "--报名"
+	resultTime := utils.StrTimeToTime(activityInfo.ActivityTime)
+	//48小时之内的取消也扣除一次参会记录
+	if time.Now().Add(+time.Hour * 48).After(resultTime) {
+		itemBill.BillDetailed = 0 //48小时之内，取消报名之后二次报名，不扣除流水记录
+	}
+	itemBill.Total = fmt.Sprint(companyPointsNum+itemBill.BillDetailed, "次")
+	itemBill.TableSource = utils.CYGX_OBJ_ACTIVITYSPECIAL
+	items = append(items, itemBill)
+	//更新对应机构的剩余点数
+	var itemCompanys []*models.CygxActivitySpecialPermissionPoints
+	itemCompany := new(models.CygxActivitySpecialPermissionPoints)
+	itemCompany.CompanyId = user.CompanyId
+	itemCompany.Points = companyPointsNum - itemBill.BillDetailed
+	itemCompany.ModifyTime = time.Now()
+	itemCompanys = append(itemCompanys, itemCompany)
+
+	err = models.AddCygxActivitySpecialTripBillMulti(items, itemCompanys)
+	return
+}
+
+// 10:用户取消报名（专项调研活动）
+func SpecialActivityPointsBillSignupCancelReduce(log models.YanXuanActivityPointsRedis) (err error) {
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go utils.SendAlarmMsg("用户取消报名扣点，处理Redis队列消息失败 SpecialActivityPointsBillSignupCancelReduce："+err.Error()+fmt.Sprint("ActivityId", log.ActivityId, "userId", log.UserId), 2)
+		}
+	}()
+
+	activityId := log.ActivityId
+	userId := log.UserId
+
+	activityInfo, e := models.GetCygxActivitySpecialDetail(activityId)
+	if e != nil {
+		err = errors.New("GetAddActivityInfoById" + e.Error())
+		return
+	}
+	user, e := models.GetWxUserItemByUserId(userId)
+	if e != nil {
+		err = errors.New("GetWxUserItemByUserId" + e.Error())
+		return
+	}
+
+	// 获取用户所在公司剩余的点
+	companyPointsNum, e := models.GetCygxActivitySpecialPermissionPoints(user.CompanyId)
+	if e != nil && e.Error() != utils.ErrNoRow() {
+		err = errors.New("GetCompanyPoints, Err: " + e.Error())
+		return
+	}
+
+	//获取需要添加的流水信息
+	var items []*models.CygxActivitySpecialTripBill
+	//流水记录表
+	itemBill := new(models.CygxActivitySpecialTripBill)
+	itemBill.UserId = user.UserId
+	itemBill.ActivityId = activityInfo.ActivityId
+	itemBill.CreateTime = time.Now()
+	itemBill.Mobile = user.Mobile
+	itemBill.Email = user.Email
+	itemBill.CompanyId = user.CompanyId
+	itemBill.CompanyName = user.CompanyName
+	itemBill.RealName = user.RealName
+	itemBill.Source = 1
+	itemBill.DoType = 2
+	itemBill.BillDetailed = 1 // 流水加一
+	itemBill.RegisterPlatform = log.RegisterPlatform
+	itemBill.ChartPermissionId = activityInfo.ChartPermissionId
+	itemBill.ChartPermissionName = activityInfo.ChartPermissionName
+	resultTime := utils.StrTimeToTime(activityInfo.ActivityTime)
+	//48小时之内的取消也扣除一次参会记录
+	if time.Now().Add(+time.Hour * 48).After(resultTime) {
+		itemBill.BillDetailed = 0 //48小时之内取消的活动扣点不返回
+	}
+	itemBill.Total = fmt.Sprint(companyPointsNum+itemBill.BillDetailed, "次")
+	itemBill.Content = activityInfo.ResearchTheme + "--取消报名"
+	itemBill.TableSource = utils.CYGX_OBJ_ACTIVITYSPECIAL
+	items = append(items, itemBill)
+
+	//更新对应机构的剩余点数
+	var itemCompanys []*models.CygxActivitySpecialPermissionPoints
+	itemCompany := new(models.CygxActivitySpecialPermissionPoints)
+	itemCompany.CompanyId = user.CompanyId
+	itemCompany.Points = companyPointsNum + itemBill.BillDetailed
+	itemCompany.ModifyTime = time.Now()
+	itemCompanys = append(itemCompanys, itemCompany)
+
+	err = models.AddCygxActivitySpecialTripBillMulti(items, itemCompanys)
+	return
+}

services/activity_special_trip.go

@@ -53,111 +53,6 @@ func SpecialTripPopupMsg(activityInfo *models.CygxActivitySpecialDetail, user *m
 	return
 }
 
-// 获取用户剩余报名次数
-//func GetTripRemainingtimesBycompany(user *models.WxUserItem, activityInfo *models.CygxActivitySpecialDetail) (errMsg string, tripRemaining int, err error) {
-//
-//	//获取 专项调研客户类型   //1、永续客户 //2、大套餐客户（4个行业全开通的正式客户） //3、分行业套餐客户（开通对应行业的正式客户） //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户;6、冻结客户；7、流失客户 8：行业升级套餐客户
-//	msgTemplate := "您的专项调研次数已用完，如仍想参加，请与您的对口销售商议"
-//	//var tripTota int
-//	//var airborneTota int
-//	//userType, _, e := GetActivitySpecialUserType(user.CompanyId)
-//	userType, _, e := GetUserType(user.CompanyId)
-//	if e != nil {
-//		err = errors.New("获取客户身份信息失败 GetActivitySpecialUserType, Err: " + e.Error())
-//		return
-//	}
-//	if userType == 0 {
-//		errMsg = msgTemplate
-//		return
-//	} else if userType == 1 {
-//		tripRemaining = 999
-//		return
-//	} else if userType == 2 {
-//		var condition string
-//		var pars []interface{}
-//
-//		condition += ` AND company_id = ? `
-//		pars = append(pars, user.CompanyId)
-//
-//		//airborneTota, e = models.GetActivitySpecialTripAirborneCountByActivitySpecial(condition, pars)
-//		//if e != nil {
-//		//	err = errors.New("GetActivitySpecialTripAirborneCountByActivitySpecial, Err: " + e.Error())
-//		//	return
-//		//}
-//		//condition += ` AND is_valid = 1 `
-//		//查询当年的数据
-//		condition += ` AND create_time >= ?  `
-//		pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
-//		listTripBill, e := models.GetCygxActivitySpecialTripBill(condition, pars)
-//		if e != nil {
-//			err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
-//			return
-//		}
-//		var TripBillNum int
-//		for _, v := range listTripBill {
-//			TripBillNum += v.BillDetailed
-//		}
-//		var packageType int
-//		//大套餐客户，数据库添加标识，
-//		companyUserTypeDetail, errs := models.GetCygxCompanyUserType(user.CompanyId)
-//		if errs != nil && errs.Error() != utils.ErrNoRow() {
-//			err = errs
-//			return
-//		}
-//		if companyUserTypeDetail != nil {
-//			packageType = companyUserTypeDetail.PackageType
-//			if companyUserTypeDetail.CustomerTypeId != 0 {
-//				userType = companyUserTypeDetail.CustomerTypeId
-//				return
-//			}
-//		}
-//
-//		packageTypeMap := map[int]int{1: 16, 2: 10}
-//		totalTrip := packageTypeMap[packageType]
-//		//tripRemaining = 10 - airborneTota + TripBillNum
-//		tripRemaining = totalTrip + TripBillNum
-//		if tripRemaining <= 0 {
-//			errMsg = msgTemplate
-//			return
-//		}
-//		//tripRemaining = 12 - tripTota
-//	} else {
-//		var condition string
-//		var pars []interface{}
-//
-//		condition += ` AND company_id = ? `
-//		pars = append(pars, user.CompanyId)
-//
-//		condition += ` AND chart_permission_id = ? `
-//		pars = append(pars, activityInfo.ChartPermissionId)
-//
-//		//airborneTota, e = models.GetActivitySpecialTripAirborneCountByActivitySpecial(condition, pars)
-//		//if e != nil {
-//		//	err = errors.New("GetActivitySpecialTripAirborneCountByActivitySpecial, Err: " + e.Error())
-//		//	return
-//		//}
-//		//查询当年的数据
-//		condition += ` AND create_time >= ?  `
-//		pars = append(pars, time.Now().Format(utils.FormatYearDate)+"-01-01")
-//		listTripBill, e := models.GetCygxActivitySpecialTripBill(condition, pars)
-//		if e != nil {
-//			err = errors.New("GetActivitySpecialTripCountByActivitySpecial, Err: " + e.Error())
-//			return
-//		}
-//		var TripBillNum int
-//		for _, v := range listTripBill {
-//			TripBillNum += v.BillDetailed
-//		}
-//		//tripRemaining = 5 - airborneTota + TripBillNum
-//		tripRemaining = 5 + TripBillNum
-//		if tripRemaining <= 0 {
-//			errMsg = msgTemplate
-//			return
-//		}
-//	}
-//	return
-//}
-
 // 校验是否还有剩余次数
 func CheckTripRemainingtimesBycompany(user *models.WxUserItem, activityInfo *models.CygxActivitySpecialDetail) (errMsg string, err error) {
 	msgTemplate := "您的专项调研次数已用完，如仍想参加，请与您的对口销售商议"