天津产业标的名称

controllers/jinmencaijing.go

@@ -12,6 +12,7 @@ import (
 	"hongze/hongze_open_api/models/tables/cygx/cygx_three_api_log"
 	"hongze/hongze_open_api/models/tables/wx_user"
 	"hongze/hongze_open_api/services/alarm_msg"
+	cygxSeriesActivity "hongze/hongze_open_api/services/cygx_activity"
 	servicesWxUser "hongze/hongze_open_api/services/wx_user"
 	"hongze/hongze_open_api/utils"
 	"strconv"
@@ -68,6 +69,7 @@ func (c *JinMenCaiJingController) ActivityDetail() {
 	detail.ReportLink = activityInfo.ReportLink
 	detail.Theme = activityInfo.Theme
 	detail.Remarks = activityInfo.Remarks
+	detail.SubjectName = cygxSeriesActivity.GetActivitySubjectNameList(activityId)
 	//添加请求日志记录
 	itemApiLog := new(cygx_three_api_log.CygxThreeApiLog)
 	itemApiLog.CreateTime = time.Now()

models/response/jinmencaijing/jinmencaijing.go

@@ -12,37 +12,38 @@ type CustomerInfo struct {
 
 // CygxActivity 活动表结构体
 type CygxActivityResp struct {
-	ActivityID              int    `json:"activity_id" description:"活动ID"`
-	PublishStatus           int    `json:"publish_status" description:"发布状态，0未发布，1已发布"`
-	ActivityName            string `json:"activity_name" description:"活动名称"`
-	Label                   string `json:"label" description:"标签"`
-	ActivityTime            string `json:"activity_time" description:"活动时间"`
-	ActivityTimeText        string `json:"activity_time_text" description:"活动时间带文字"`
-	ActivityTypeId          int    `json:"activity_type_id" description:"活动类型ID"`
-	ActivityTypeName        string `json:"activity_type_name" description:"活动类型名称"`
-	ChartPermissionName     string `json:"chart_permission_name" description:"行业名称"`
-	IsLimitPeople           int    `json:"is_limit_people" description:"是否限制人数 1是，0否"`
-	LimitPeopleNum          int    `json:"limit_people_num" description:"限制人数数量"`
-	Expert                  string `json:"expert" description:"专家"`
-	Host                    string `json:"host" description:"主持人"`
-	Speaker                 string `json:"speaker" description:"主讲人"`
-	City                    string `json:"city" description:"城市"`
-	Address                 string `json:"address" description:"活动地址"`
-	Highlights              string `json:"highlights" description:"活动亮点"`
-	DistinguishedGuest      string `json:"distinguished_guest" description:"嘉宾"`
-	MainlandTell            string `json:"mainland_tell" description:"大陆拨入"`
-	HongKongTell            string `json:"hong_kong_tell" description:"香港拨入"`
-	TaiwanTell              string `json:"taiwan_tell" description:"台湾拨入"`
-	AmericaTell             string `json:"america_tell" description:"美国拨入"`
-	ParticipationCode       string `json:"participation_code" description:"拨入密码"`
-	OnlineParticipation     string `json:"online_participation" description:"网络参会"`
-	TencentConferenceNumber string `json:"tencent_conference_number" description:"腾讯会议号"`
-	LinkParticipants        string `json:"link_participants" description:"链接参会"`
-	VmpRobotMeetingId       string `json:"vmp_robot_meeting_id" description:"会议ID"`
-	ConferencePassword      string `json:"conference_password" description:"会议密码"`
-	ReportLink              string `json:"report_link" description:"报告链接"`
-	Theme                   string `json:"theme" description:"主题"`
-	Remarks                 string `json:"remarks" description:"备注"`
+	ActivityID              int      `json:"activity_id" description:"活动ID"`
+	PublishStatus           int      `json:"publish_status" description:"发布状态，0未发布，1已发布"`
+	ActivityName            string   `json:"activity_name" description:"活动名称"`
+	Label                   string   `json:"label" description:"标签"`
+	ActivityTime            string   `json:"activity_time" description:"活动时间"`
+	ActivityTimeText        string   `json:"activity_time_text" description:"活动时间带文字"`
+	ActivityTypeId          int      `json:"activity_type_id" description:"活动类型ID"`
+	ActivityTypeName        string   `json:"activity_type_name" description:"活动类型名称"`
+	ChartPermissionName     string   `json:"chart_permission_name" description:"行业名称"`
+	IsLimitPeople           int      `json:"is_limit_people" description:"是否限制人数 1是，0否"`
+	LimitPeopleNum          int      `json:"limit_people_num" description:"限制人数数量"`
+	Expert                  string   `json:"expert" description:"专家"`
+	Host                    string   `json:"host" description:"主持人"`
+	Speaker                 string   `json:"speaker" description:"主讲人"`
+	City                    string   `json:"city" description:"城市"`
+	Address                 string   `json:"address" description:"活动地址"`
+	Highlights              string   `json:"highlights" description:"活动亮点"`
+	DistinguishedGuest      string   `json:"distinguished_guest" description:"嘉宾"`
+	MainlandTell            string   `json:"mainland_tell" description:"大陆拨入"`
+	HongKongTell            string   `json:"hong_kong_tell" description:"香港拨入"`
+	TaiwanTell              string   `json:"taiwan_tell" description:"台湾拨入"`
+	AmericaTell             string   `json:"america_tell" description:"美国拨入"`
+	ParticipationCode       string   `json:"participation_code" description:"拨入密码"`
+	OnlineParticipation     string   `json:"online_participation" description:"网络参会"`
+	TencentConferenceNumber string   `json:"tencent_conference_number" description:"腾讯会议号"`
+	LinkParticipants        string   `json:"link_participants" description:"链接参会"`
+	VmpRobotMeetingId       string   `json:"vmp_robot_meeting_id" description:"会议ID"`
+	ConferencePassword      string   `json:"conference_password" description:"会议密码"`
+	ReportLink              string   `json:"report_link" description:"报告链接"`
+	Theme                   string   `json:"theme" description:"主题"`
+	Remarks                 string   `json:"remarks" description:"备注"`
+	SubjectName             []string `json:"subject_name" description:"标的名称"`
 }
 
 // CygxActivity 活动表结构体

models/tables/cygx/cygx_activity/cygx_activity.go

@@ -405,3 +405,25 @@ func GetActivitySignupSuccessCount(activityId int) (count int, err error) {
 	err = o.Raw(sqlCount, activityId).QueryRow(&count)
 	return
 }
+
+type SubjectlActivityGroupResp struct {
+	ActivityId  int    `description:"活动ID"`
+	SubjectName string `description:"标的名称"`
+}
+
+// 列表
+func GetSubjectActivityGroupListByactivityIds(activityIds string) (items []*SubjectlActivityGroupResp, err error) {
+	o := orm.NewOrmUsingDB("hz_cygx")
+	sql := `SELECT
+			sg.*,
+			s.subject_name,
+			s.industrial_management_id 
+		FROM
+			cygx_industrial_activity_group_subject AS sg
+			INNER JOIN cygx_industrial_subject AS s ON s.industrial_subject_id = sg.industrial_subject_id 
+		WHERE
+			1 = 1 
+			AND sg.activity_id IN (` + activityIds + `)  GROUP BY sg.activity_id,sg.industrial_subject_id`
+	_, err = o.Raw(sql).QueryRows(&items)
+	return
+}

services/cygx_activity/activity.go

@@ -0,0 +1,31 @@
+package cygx_activity
+
+import (
+	"errors"
+	"fmt"
+	cygxActivity "hongze/hongze_open_api/models/tables/cygx/cygx_activity"
+	"hongze/hongze_open_api/services/alarm_msg"
+	"strconv"
+)
+
+func GetActivitySubjectNameList(activity int) (names []string) {
+	var err error
+	defer func() {
+		if err != nil {
+			fmt.Println(err)
+			go alarm_msg.SendAlarmMsg(fmt.Sprint("Kp互动提醒失败,GetActivitySubjectNameList err", err.Error()), 2)
+		}
+	}()
+
+	listName, e := cygxActivity.GetSubjectActivityGroupListByactivityIds(strconv.Itoa(activity))
+	if e != nil {
+		err = errors.New("GetSubjectActivityGroupListByactivityIds" + e.Error())
+		return
+	}
+	names = make([]string, 0)
+	for _, v := range listName {
+		names = append(names, v.SubjectName)
+	}
+
+	return
+}