Merge branch 'cygx_need_932' of http://8.136.199.33:3000/cxzhang/hongze_mfyx

controllers/home.go

@@ -74,8 +74,8 @@ func (this *HomeController) NewList() {
 		if labelKeyword == "" {
 			//查询近一个月的数据
 			condition += " AND search_order_time  >   '" + time.Now().AddDate(0, 0, -60).Format(utils.FormatDateTime) + "'"
-			yanxuanActivityIds = services.GetYanxuanActivityIds(user) // 获取所有的研选活动ID
-			yanxuanArticleIds = services.GetYanxuanArticleIds()       //获取所有研选文章ID
+			yanxuanActivityIds = services.GetYanxuanActivityIds(user, 1) // 获取所有的研选活动ID
+			yanxuanArticleIds = services.GetYanxuanArticleIds()          //获取所有研选文章ID
 		} else {
 			yanxuanActivityIds, yanxuanArticleIds, err = services.GetConditionInitByTagIds(user, labelKeyword)
 			if err != nil {

services/activity.go

@@ -1320,7 +1320,7 @@ func GetActivityTypeIdMap() (mapResp map[int]int) {
 }
 
 // GetYanxuanActivityIds 获取研选活动ID
-func GetYanxuanActivityIds(user *models.WxUserItem) (activityIds []int) {
+func GetYanxuanActivityIds(user *models.WxUserItem, activeState int) (activityIds []int) {
 	var err error
 	defer func() {
 		if err != nil {
@@ -1331,6 +1331,9 @@ func GetYanxuanActivityIds(user *models.WxUserItem) (activityIds []int) {
 	var condition string
 	var pars []interface{}
 	condition = `  AND  chart_permission_id  = 31  AND yidong_activity_id = '' AND art.publish_status = 1  `
+	if activeState > 0 {
+		condition += ` AND  active_state =` + strconv.Itoa(activeState)
+	}
 	//pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
 	if user.CompanyId > 1 {
 		conditionActivity, e := ActivityConditioninitSql(user, condition, 0)

services/es_comprehensive.go

@@ -649,8 +649,8 @@ func GetResourceDataEsList(list []*SearchComprehensiveItem, user *models.WxUserI
 }
 
 func SqlComprehensiveSearch(user *models.WxUserItem, keyWord string, startSize, pageSize int) (result []*SearchComprehensiveItem, total int, err error) {
-	yanxuanActivityIds := GetYanxuanActivityIds(user) // 获取所有的研选活动ID
-	yanxuanArticleIds := GetYanxuanArticleIds()       //获取所有研选文章ID
+	yanxuanActivityIds := GetYanxuanActivityIds(user, 0) // 获取所有的研选活动ID
+	yanxuanArticleIds := GetYanxuanArticleIds()          //获取所有研选文章ID
 	yanxuanArticleIds = append(yanxuanArticleIds, 0)
 	yanxuanActivityIds = append(yanxuanActivityIds, 0)
 

services/tag.go

@@ -66,9 +66,9 @@ func GetConditionInitByTagIds(user *models.WxUserItem, labelKeyword string) (yan
 	var pars []interface{}
 	switch labelKeyword {
 	case utils.LABEL_L1_1: // 全部活动
-		yanxuanActivityIds = GetYanxuanActivityIds(user) // 获取所有的研选活动ID
+		yanxuanActivityIds = GetYanxuanActivityIds(user, 1) // 获取所有的研选活动ID
 	case "买方交流": // 买方交流 ->买方线下交流
-		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id = 8  `
+		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id = 8  AND  active_state = 1 `
 		pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
 		list, e := models.GetCygxActivityIdList(condition, pars)
 		if e != nil {
@@ -79,7 +79,7 @@ func GetConditionInitByTagIds(user *models.WxUserItem, labelKeyword string) (yan
 			yanxuanActivityIds = append(yanxuanActivityIds, v.ActivityId)
 		}
 	case "专家调研": // 专家调研->专家电话会+专家线下沙龙
-		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id IN  (1,5) `
+		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id IN  (1,5)  AND  active_state = 1 `
 		pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
 		list, e := models.GetCygxActivityIdList(condition, pars)
 		if e != nil {
@@ -91,7 +91,7 @@ func GetConditionInitByTagIds(user *models.WxUserItem, labelKeyword string) (yan
 		}
 
 	case "上市公司小范围": // 上市公司小范围->公司调研电话会
-		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id = 3 `
+		condition = `   AND  chart_permission_id  = ? AND yidong_activity_id = ''  AND activity_type_id = 3  AND  active_state = 1 `
 		pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
 		list, e := models.GetCygxActivityIdList(condition, pars)
 		if e != nil {
@@ -130,7 +130,7 @@ func GetConditionInitByTagIds(user *models.WxUserItem, labelKeyword string) (yan
 		//	}
 	}
 
-	yanxuanActivityIdsPerssion := GetYanxuanActivityIds(user) // 获取所有有权限的研选活动ID
+	yanxuanActivityIdsPerssion := GetYanxuanActivityIds(user, 1) // 获取所有有权限的研选活动ID
 	mapyanxuanActivityIds := make(map[int]bool)
 	for _, v := range yanxuanActivityIdsPerssion {
 		mapyanxuanActivityIds[v] = true