hongze_cygx/services/tag.go

package services

import (
	"errors"
	"fmt"
	"hongze/hongze_cygx/models"
	"hongze/hongze_cygx/utils"
	"strconv"
	"strings"
	"time"
)

func AddCygxTagHistory(user *models.WxUserItem, tagId int) (err error) {
	if user.UserId == 0 {
		return
	}
	defer func() {
		if err != nil {
			go utils.SendAlarmMsg("tag点击信息记录失败"+err.Error()+"tagId"+strconv.Itoa(tagId)+"userId："+strconv.Itoa(user.UserId), 2)
		}
	}()
	historyRecord := new(models.CygxTagHistory)
	historyRecord.UserId = user.UserId
	historyRecord.TagId = tagId
	historyRecord.CreateTime = time.Now()
	historyRecord.Mobile = user.Mobile
	historyRecord.Email = user.Email
	historyRecord.CompanyId = user.CompanyId
	historyRecord.CompanyName = user.CompanyName
	historyRecord.RegisterPlatform = utils.REGISTER_PLATFORM
	sellerItem, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
	if err != nil && err.Error() != utils.ErrNoRow() {
		return
	}
	historyRecord.RealName = user.RealName
	if sellerItem != nil {
		historyRecord.SellerName = sellerItem.RealName
	}
	_, err = models.AddCygxTagHistory(historyRecord)
	return
}

//func init() {
//	conditionInit, err := GetConditionInitByTagIds("20,21,26")
//	fmt.Println(err)
//	fmt.Println()
//	fmt.Println(conditionInit)
//}

func GetConditionInitByTagIds(tagIds string) (conditionInit string, err error) {
	if tagIds == "" {
		return
	}
	var condition string
	var pars []interface{}
	var searchTag, industries, subjectNames []string
	tagslice := strings.Split(tagIds, ",")
	condition = ` AND tag_id IN (` + utils.GetOrmInReplace(len(tagslice)) + `)`
	pars = append(pars, tagslice)
	listTag, e := models.GetCygxTagListCondition(condition, pars, 0, 0)
	if e != nil {
		err = errors.New("GetActivityListByCondition, Err: " + e.Error())
		return
	}

	for _, tagInfo := range listTag {
		//ActivityTypes 与 ArticleTypes 进行合并
		if tagInfo.ActivityTypes != "" {
			searchTag = append(searchTag, tagInfo.ActivityTypes)
		}
		if tagInfo.ArticleTypes != "" {
			searchTag = append(searchTag, tagInfo.ArticleTypes)
		}
		if tagInfo.Industries != "" {
			industries = append(industries, tagInfo.Industries)
		}
		if tagInfo.SubjectNames != "" {
			subjectNames = append(subjectNames, tagInfo.SubjectNames)
		}
	}

	//拼接search_tag 搜索内容
	if len(searchTag) > 0 {
		conditionInit += " AND search_tag IN  ('" + strings.Join(searchTag, "','") + "')"
	}

	var resourceDataIds []int //cygx_resource_data 主键ID
	//如果产业有组合，那么就去捞产业相关的内容
	if len(industries) > 0 {
		// 获取近一个月产业报告阅读次数最多的产业
		var conditionIndustry string
		var parsIndustry []interface{}
		conditionIndustry += " AND industry_name IN  ('" + strings.Join(industries, "','") + "')"
		listIndustry, e := models.GetTopOneMonthArtReadNumIndustryAll(conditionIndustry, parsIndustry)
		if e != nil {
			err = errors.New("GetTopOneMonthArtReadNumIndustryAll, Err: " + e.Error())
			return
		}
		var industrialManagementIds []int // 产业ID合集
		for _, v := range listIndustry {
			industrialManagementIds = append(industrialManagementIds, v.IndustrialManagementId)
		}

		var conditionIndustryResource string
		var parsIndustryResource []interface{}
		lenArrindustrial := len(industrialManagementIds)
		conditionIndustryResource = ` AND industrial_management_id IN (` + utils.GetOrmInReplace(lenArrindustrial) + `)`
		parsIndustryResource = append(parsIndustryResource, industrialManagementIds)

		if lenArrindustrial > 0 {
			listResourceDataIndustrial, e := models.GetCygxResourceDataIndustrialGroupManagementList(conditionIndustryResource, parsIndustryResource, 0, 0)
			//return
			if e != nil {
				err = errors.New("GetCygxResourceDataIndustrialGroupManagementList, Err: " + e.Error())
				return
			}
			for _, v := range listResourceDataIndustrial {
				resourceDataIds = append(resourceDataIds, v.ResourceDataId)
			}
		}
	}
	//return
	//如果标的有组合，那么就去捞标的相关的内容
	if len(subjectNames) > 0 {
		// 获取近一个月产业报告阅读次数最多的产业
		var conditionsubject string
		var parssubject []interface{}
		conditionsubject += " AND subject_name IN  ('" + strings.Join(subjectNames, "','") + "')"
		listsubject, e := models.GetCygxIndustrialSubjectListCondition(conditionsubject, parssubject)
		if e != nil {
			err = errors.New("GetTopOneMonthArtReadNumIndustry, Err: " + e.Error())
			return
		}
		var industrialsubjectIds []int // 标的ID集合
		for _, v := range listsubject {
			industrialsubjectIds = append(industrialsubjectIds, v.IndustrialSubjectId)
		}
		var conditionsubjectResource string
		var parssubjectResource []interface{}
		lenArrsubject := len(industrialsubjectIds)
		conditionsubjectResource = ` AND industrial_subject_id IN (` + utils.GetOrmInReplace(lenArrsubject) + `)`
		parssubjectResource = append(parssubjectResource, industrialsubjectIds)
		if lenArrsubject > 0 {
			listResourceDatasubject, e := models.GetCygxResourceDataIndustrialGroupSubjectList(conditionsubjectResource, parssubjectResource, 0, 0)
			if e != nil {
				err = errors.New("GetCygxResourceDataIndustrialGroupSubjectList, Err: " + e.Error())
				return
			}
			for _, v := range listResourceDatasubject {
				resourceDataIds = append(resourceDataIds, v.ResourceDataId)
			}
		}
	}

	//拼接 cygx_resource_data 表主键查询ID
	if len(resourceDataIds) > 0 {
		var resourceDataIdStrs []string
		resourceDataIdMap := make(map[int]bool)
		for _, v := range resourceDataIds {
			if resourceDataIdMap[v] {
				continue
			}
			resourceDataIdStrs = append(resourceDataIdStrs, strconv.Itoa(v))
			resourceDataIdMap[v] = true
		}
		conditionInit += " AND id IN  (" + strings.Join(resourceDataIdStrs, ",") + ") "
	}
	return
}