|
@@ -7,54 +7,54 @@ import (
|
|
|
)
|
|
|
|
|
|
// 用户互动总数统计
|
|
|
-func GetUserInteractionTableCountByCompany(companyId int) (item *GetUserInteractionTableCountResp, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- sql := `SELECT
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_article_history_record_all AS h INNER JOIN cygx_article as art ON art.article_id = h.article_id WHERE h.company_id = u.company_id AND h.is_del = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS history_num,
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_article_collect AS h WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS count_num,
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_chart_collect AS h INNER JOIN cygx_chart AS a ON h.chart_id = a.chart_id WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS chart_num,
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_industry_fllow AS h WHERE h.company_id = u.company_id AND h.type = 1 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS industry_fllow_num,
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_article_department_follow AS h WHERE h.company_id = u.company_id AND h.type = 1 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS department_follow_num,
|
|
|
- ( SELECT COUNT( 1 ) FROM cygx_search_key_word AS h WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS key_word_num,
|
|
|
- ( SELECT COUNT(1 ) as count FROM cygx_activity_signup AS h INNER JOIN cygx_activity as a ON a.activity_id = h.activity_id INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id INNER JOIN wx_user as wu ON wu.user_id = h.user_id WHERE h.company_id = u.company_id
|
|
|
- AND t.activity_type=1 AND h.do_fail_type = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS on_line_num,
|
|
|
- ( SELECT COUNT( 1 ) as count FROM cygx_activity_signup AS h INNER JOIN cygx_activity as a ON a.activity_id = h.activity_id INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id INNER JOIN wx_user as wu ON wu.user_id = h.user_id WHERE h.company_id = u.company_id
|
|
|
- AND t.activity_type = 0 AND h.do_fail_type = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS office_num
|
|
|
- FROM
|
|
|
- company as u
|
|
|
- WHERE
|
|
|
- u.company_id = ?`
|
|
|
- err = o.Raw(sql, companyId).QueryRow(&item)
|
|
|
- return
|
|
|
-}
|
|
|
+//func GetUserInteractionTableCountByCompany(companyId int) (item *GetUserInteractionTableCountResp, err error) {
|
|
|
+// o := orm.NewOrm()
|
|
|
+// sql := `SELECT
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_article_history_record_all AS h INNER JOIN cygx_article as art ON art.article_id = h.article_id WHERE h.company_id = u.company_id AND h.is_del = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS history_num,
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_article_collect AS h WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS count_num,
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_chart_collect AS h INNER JOIN cygx_chart AS a ON h.chart_id = a.chart_id WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS chart_num,
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_industry_fllow AS h WHERE h.company_id = u.company_id AND h.type = 1 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS industry_fllow_num,
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_article_department_follow AS h WHERE h.company_id = u.company_id AND h.type = 1 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS department_follow_num,
|
|
|
+// ( SELECT COUNT( 1 ) FROM cygx_search_key_word AS h WHERE h.company_id = u.company_id AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS key_word_num,
|
|
|
+// ( SELECT COUNT(1 ) as count FROM cygx_activity_signup AS h INNER JOIN cygx_activity as a ON a.activity_id = h.activity_id INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id INNER JOIN wx_user as wu ON wu.user_id = h.user_id WHERE h.company_id = u.company_id
|
|
|
+// AND t.activity_type=1 AND h.do_fail_type = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS on_line_num,
|
|
|
+// ( SELECT COUNT( 1 ) as count FROM cygx_activity_signup AS h INNER JOIN cygx_activity as a ON a.activity_id = h.activity_id INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id INNER JOIN wx_user as wu ON wu.user_id = h.user_id WHERE h.company_id = u.company_id
|
|
|
+// AND t.activity_type = 0 AND h.do_fail_type = 0 AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS office_num
|
|
|
+// FROM
|
|
|
+// company as u
|
|
|
+// WHERE
|
|
|
+// u.company_id = ?`
|
|
|
+// err = o.Raw(sql, companyId).QueryRow(&item)
|
|
|
+// return
|
|
|
+//}
|
|
|
|
|
|
// 获取阅读记录数量
|
|
|
-func GetCygxArticleHistoryCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
- sqlCount := ` SELECT COUNT( 1 ) AS count
|
|
|
-FROM
|
|
|
- (
|
|
|
- SELECT
|
|
|
- COUNT( 1 )
|
|
|
- FROM
|
|
|
- cygx_article_history_record_all AS r
|
|
|
- INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN company_product AS cp ON cp.company_id = r.company_id
|
|
|
- AND cp.product_id = 2
|
|
|
- INNER JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
- INNER JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
- LEFT JOIN cygx_report_mapping AS re ON re.category_id = art.category_id_two WHERE r.is_del = 0`
|
|
|
- if condition != "" {
|
|
|
- sqlCount += condition
|
|
|
- }
|
|
|
- sqlCount += ` GROUP BY r.id ) AS count `
|
|
|
- err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
- return
|
|
|
-}
|
|
|
+//func GetCygxArticleHistoryCountByCompany(condition string) (count int, err error) {
|
|
|
+// o := orm.NewOrm()
|
|
|
+// sqlCount := ` SELECT COUNT( 1 ) AS count
|
|
|
+//FROM
|
|
|
+// (
|
|
|
+// SELECT
|
|
|
+// COUNT( 1 )
|
|
|
+// FROM
|
|
|
+// cygx_article_history_record_all AS r
|
|
|
+// INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
+// INNER JOIN company_product AS cp ON cp.company_id = r.company_id
|
|
|
+// AND cp.product_id = 2
|
|
|
+// INNER JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
+// INNER JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
+// LEFT JOIN cygx_report_mapping AS re ON re.category_id = art.category_id_two WHERE r.is_del = 0`
|
|
|
+// if condition != "" {
|
|
|
+// sqlCount += condition
|
|
|
+// }
|
|
|
+// sqlCount += ` GROUP BY r.id ) AS count `
|
|
|
+// err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
+// return
|
|
|
+//}
|
|
|
|
|
|
// 阅读记录列表
|
|
|
func GetCygxArticleHistoryRecordByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := ` SELECT
|
|
|
art.title,
|
|
|
art.article_id,
|
|
@@ -86,14 +86,13 @@ func GetCygxArticleHistoryRecordByCompany(condition string, startSize, pageSize
|
|
|
|
|
|
// 获取用户参会记录数量
|
|
|
func GetActivityMeetByCompanyCount(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := `SELECT
|
|
|
COUNT(*) AS count
|
|
|
FROM
|
|
|
cygx_activity_signup_detail AS r
|
|
|
INNER JOIN cygx_activity AS a ON a.activity_id = r.activity_id
|
|
|
INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id
|
|
|
- INNER JOIN wx_user AS u ON u.mobile = r.mobile
|
|
|
WHERE
|
|
|
1 = 1
|
|
|
AND r.do_fail_type = 0`
|
|
@@ -106,13 +105,13 @@ func GetActivityMeetByCompanyCount(condition string) (count int, err error) {
|
|
|
|
|
|
// 获取用户参会记录
|
|
|
func GetActivityMeetByCompany(condition string, startSize, pageSize int) (item []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
t.activity_type,
|
|
|
r.signup_type,
|
|
|
r.is_meeting,
|
|
|
- u.mobile,
|
|
|
- u.real_name,
|
|
|
+ r.mobile,
|
|
|
+ r.real_name,
|
|
|
a.activity_name,
|
|
|
a.chart_permission_name,
|
|
|
a.activity_type_name,
|
|
@@ -128,7 +127,6 @@ func GetActivityMeetByCompany(condition string, startSize, pageSize int) (item [
|
|
|
cygx_activity_signup_detail AS r
|
|
|
INNER JOIN cygx_activity AS a ON a.activity_id = r.activity_id
|
|
|
INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id
|
|
|
- INNER JOIN wx_user as u ON u.mobile = r.mobile
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE
|
|
|
1 = 1
|
|
@@ -148,16 +146,16 @@ func GetActivityMeetByCompany(condition string, startSize, pageSize int) (item [
|
|
|
|
|
|
// 收藏列表数量
|
|
|
func GetCygxArticleCollectCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT COUNT(1) AS count FROM cygx_article_collect as r INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id WHERE 1=1 ` + condition
|
|
|
+ WHERE 1=1 ` + condition
|
|
|
err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 收藏列表
|
|
|
func GetCygxArticleCollectByCompany(startSize, pageSize int, condition string) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := ` SELECT
|
|
|
art.title,
|
|
|
art.article_id,
|
|
@@ -188,7 +186,6 @@ func GetCygxArticleCollectByCompany(startSize, pageSize int, condition string) (
|
|
|
FROM
|
|
|
cygx_article_collect AS r
|
|
|
INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
LEFT JOIN cygx_report_mapping AS re ON re.category_id = art.category_id_two
|
|
|
LEFT JOIN cygx_industrial_article_group_management AS man ON man.article_id = art.article_id
|
|
@@ -204,27 +201,25 @@ func GetCygxArticleCollectByCompany(startSize, pageSize int, condition string) (
|
|
|
|
|
|
// 关注产业数量
|
|
|
func GetCygxIndustryFllowCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT COUNT(1) AS count FROM cygx_industry_fllow AS r
|
|
|
- INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id WHERE type = 1 ` + condition
|
|
|
+ INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id WHERE type = 1 ` + condition
|
|
|
err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 关注产业列表
|
|
|
func GetCygxIndustryFllowByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
m.industry_name,
|
|
|
- u.mobile,
|
|
|
- u.real_name,
|
|
|
+ r.mobile,
|
|
|
+ r.real_name,
|
|
|
r.modify_time as create_time,
|
|
|
( SELECT GROUP_CONCAT( DISTINCT s.subject_name SEPARATOR '/' ) FROM cygx_industrial_subject AS s WHERE s.industrial_management_id = m.industrial_management_id ) AS subject_name_str
|
|
|
FROM
|
|
|
cygx_industry_fllow AS r
|
|
|
- LEFT JOIN wx_user as u ON u.mobile = r.mobile
|
|
|
- LEFT JOIN cygx_user_interaction_num as ui ON ui.user_id = u.user_id
|
|
|
+ LEFT JOIN cygx_user_interaction_num as ui ON ui.user_id = r.user_id
|
|
|
INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id
|
|
|
WHERE type = 1 ` + condition + ` ORDER BY ui.industry_fllow_num DESC, r.create_time DESC LIMIT ?,? `
|
|
|
_, err = o.Raw(sql, startSize, pageSize).QueryRows(&items)
|
|
@@ -233,17 +228,16 @@ func GetCygxIndustryFllowByCompany(condition string, startSize, pageSize int) (i
|
|
|
|
|
|
// 关注作者数量
|
|
|
func GetCygArticleDepartmentFollowCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT COUNT(1) AS count FROM cygx_article_department_follow AS r
|
|
|
- INNER JOIN cygx_article_department AS m ON m.department_id = r.department_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id WHERE type = 1 ` + condition
|
|
|
+ INNER JOIN cygx_article_department AS m ON m.department_id = r.department_id WHERE type = 1 ` + condition
|
|
|
err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
return
|
|
|
}
|
|
|
|
|
|
// 关注作者列表
|
|
|
func GetCygArticleDepartmentFollowByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
m.department_id,
|
|
|
m.nick_name,
|
|
@@ -261,7 +255,6 @@ func GetCygArticleDepartmentFollowByCompany(condition string, startSize, pageSiz
|
|
|
cygx_article_department_follow AS r
|
|
|
INNER JOIN cygx_article_department AS m ON m.department_id = r.department_id
|
|
|
INNER JOIN cygx_article AS a ON a.department_id = m.department_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
|
|
|
LEFT JOIN cygx_industrial_management AS i ON i.industrial_management_id = mg.industrial_management_id
|
|
@@ -273,7 +266,7 @@ func GetCygArticleDepartmentFollowByCompany(condition string, startSize, pageSiz
|
|
|
|
|
|
// 用户搜索关键词统计
|
|
|
func GetCygxSearchKeyWordCountBuCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT COUNT(1) AS count FROM cygx_search_key_word as r WHERE 1= 1 ` + condition
|
|
|
err = o.Raw(sqlCount).QueryRow(&count)
|
|
|
return
|
|
@@ -281,7 +274,7 @@ func GetCygxSearchKeyWordCountBuCompany(condition string) (count int, err error)
|
|
|
|
|
|
// 用户搜索关键词列表
|
|
|
func GetCygxSearchKeyWordByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
r.key_word,
|
|
|
r.create_time,
|
|
@@ -298,7 +291,7 @@ func GetCygxSearchKeyWordByCompany(condition string, startSize, pageSize int) (i
|
|
|
|
|
|
// 用户专项产业调研统计
|
|
|
func GetCygxActivitySpecialTripCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
COUNT( 1 )
|
|
|
FROM
|
|
@@ -313,7 +306,7 @@ func GetCygxActivitySpecialTripCountByCompany(condition string) (count int, err
|
|
|
|
|
|
// 用户专项产业调研列表
|
|
|
func CygxActivitySpecialTripByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
a.research_theme AS activity_name,
|
|
|
a.chart_permission_name,
|
|
@@ -336,7 +329,7 @@ func CygxActivitySpecialTripByCompany(condition string, startSize, pageSize int)
|
|
|
|
|
|
// 用户音视频浏览统计
|
|
|
func GetCygxRoadshowCountByCompany(condition string) (count int, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := `SELECT
|
|
|
COUNT( 1 ) total
|
|
|
FROM
|
|
@@ -365,7 +358,7 @@ FROM
|
|
|
|
|
|
// 用户音视频浏览列表
|
|
|
func GetCygxRoadshowByCompany(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
v.video_name AS media_title,
|
|
|
r.create_time,
|
|
@@ -409,7 +402,7 @@ func GetCygxRoadshowByCompany(condition string, startSize, pageSize int) (items
|
|
|
|
|
|
// 用户音视频浏览列表
|
|
|
func GetCygxRoadshowByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
v.video_name AS media_title,
|
|
|
r.create_time,
|
|
@@ -423,7 +416,6 @@ func GetCygxRoadshowByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
FROM
|
|
|
cygx_micro_roadshow_video_history AS r
|
|
|
INNER JOIN cygx_micro_roadshow_video AS v ON r.video_id = v.video_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE 1=1 ` + condition + ` UNION ALL
|
|
@@ -440,7 +432,6 @@ func GetCygxRoadshowByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
FROM
|
|
|
cygx_activity_video_history AS r
|
|
|
INNER JOIN cygx_activity_video AS v ON r.video_id = v.video_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE 1=1 ` + condition + ` UNION ALL
|
|
@@ -457,7 +448,6 @@ func GetCygxRoadshowByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
FROM
|
|
|
cygx_activity_voice_history AS r
|
|
|
INNER JOIN cygx_activity_voice AS v ON r.activity_id = v.activity_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE 1=1 ` + condition + `
|
|
@@ -468,6 +458,7 @@ func GetCygxRoadshowByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
|
|
|
// 根据时间获取机构互动总数统计
|
|
|
func GetCompanyInteractionTableCountBytime(companyId int, startDate, endDate string) (item *GetUserInteractionTableCountResp, err error) {
|
|
|
+ return
|
|
|
o := orm.NewOrm()
|
|
|
sql := `SELECT
|
|
|
( SELECT COUNT( 1 ) FROM cygx_article_history_record_all AS h INNER JOIN cygx_article as art ON art.article_id = h.article_id WHERE h.company_id = u.company_id AND h.is_del = 0 AND create_time BETWEEN '` + startDate + `'AND '` + endDate + `' AND h.create_time < date_format(now(),'%Y-%m-%d') ) AS history_num,
|
|
@@ -490,7 +481,7 @@ func GetCompanyInteractionTableCountBytime(companyId int, startDate, endDate str
|
|
|
|
|
|
// 机构阅读记录列表
|
|
|
func GetCygxArticleHistoryRecordByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := ` SELECT
|
|
|
art.title,
|
|
|
art.article_id,
|
|
@@ -511,7 +502,6 @@ func GetCygxArticleHistoryRecordByCompanyList(condition string, startSize, pageS
|
|
|
FROM
|
|
|
cygx_article_history_record_all AS r
|
|
|
INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
INNER JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
INNER JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
LEFT JOIN cygx_report_mapping AS re ON re.category_id = art.category_id_two
|
|
@@ -526,13 +516,13 @@ func GetCygxArticleHistoryRecordByCompanyList(condition string, startSize, pageS
|
|
|
|
|
|
// 获取机构参会记录
|
|
|
func GetActivityMeetByCompanyList(condition string, startSize, pageSize int) (item []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
t.activity_type,
|
|
|
r.signup_type,
|
|
|
r.is_meeting,
|
|
|
- u.mobile,
|
|
|
- u.real_name,
|
|
|
+ r.mobile,
|
|
|
+ r.real_name,
|
|
|
a.activity_name,
|
|
|
a.chart_permission_name,
|
|
|
a.activity_type_name,
|
|
@@ -551,8 +541,6 @@ func GetActivityMeetByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
cygx_activity_signup_detail AS r
|
|
|
INNER JOIN cygx_activity AS a ON a.activity_id = r.activity_id
|
|
|
INNER JOIN cygx_activity_type as t ON t.activity_type_id = a.activity_type_id
|
|
|
- INNER JOIN wx_user as u ON u.mobile = r.mobile
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE
|
|
@@ -574,7 +562,7 @@ func GetActivityMeetByCompanyList(condition string, startSize, pageSize int) (it
|
|
|
|
|
|
// 机构收藏列表
|
|
|
func GetCygxArticleCollectByCompanyList(startSize, pageSize int, condition string) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := ` SELECT
|
|
|
art.title,
|
|
|
art.article_id,
|
|
@@ -607,8 +595,6 @@ func GetCygxArticleCollectByCompanyList(startSize, pageSize int, condition strin
|
|
|
FROM
|
|
|
cygx_article_collect AS r
|
|
|
INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
LEFT JOIN cygx_report_mapping AS re ON re.category_id = art.category_id_two
|
|
@@ -625,20 +611,18 @@ func GetCygxArticleCollectByCompanyList(startSize, pageSize int, condition strin
|
|
|
|
|
|
// 关注产业列表
|
|
|
func GetCygxIndustryFllowByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
m.industry_name,
|
|
|
- u.mobile,
|
|
|
- u.real_name,
|
|
|
+ r.mobile,
|
|
|
+ r.real_name,
|
|
|
r.modify_time as create_time,
|
|
|
cp.company_name,
|
|
|
cp.seller_name,
|
|
|
( SELECT GROUP_CONCAT( DISTINCT s.subject_name SEPARATOR '/' ) FROM cygx_industrial_subject AS s WHERE s.industrial_management_id = m.industrial_management_id ) AS subject_name_str
|
|
|
FROM
|
|
|
cygx_industry_fllow AS r
|
|
|
- INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
+ INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num as ui ON ui.user_id = u.user_id
|
|
|
|
|
@@ -649,7 +633,7 @@ func GetCygxIndustryFllowByCompanyList(condition string, startSize, pageSize int
|
|
|
|
|
|
// 关注作者机构列表
|
|
|
func GetCygArticleDepartmentFollowByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
m.department_id,
|
|
|
m.nick_name,
|
|
@@ -669,9 +653,7 @@ func GetCygArticleDepartmentFollowByCompanyList(condition string, startSize, pag
|
|
|
cygx_article_department_follow AS r
|
|
|
INNER JOIN cygx_article_department AS m ON m.department_id = r.department_id
|
|
|
INNER JOIN cygx_article AS a ON a.department_id = m.department_id
|
|
|
- INNER JOIN wx_user as u ON u.user_id = r.user_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_industrial_article_group_management AS mg ON mg.article_id = a.article_id
|
|
|
LEFT JOIN cygx_industrial_management AS i ON i.industrial_management_id = mg.industrial_management_id
|
|
@@ -683,17 +665,15 @@ func GetCygArticleDepartmentFollowByCompanyList(condition string, startSize, pag
|
|
|
|
|
|
// 用户搜索关键词列表
|
|
|
func GetCygxSearchKeyWordByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
r.key_word,r.create_time,
|
|
|
r.mobile,
|
|
|
r.source,
|
|
|
- cp.company_name,
|
|
|
- cp.seller_name,
|
|
|
+ r.company_name,
|
|
|
r.real_name
|
|
|
FROM
|
|
|
cygx_search_key_word as r
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE 1= 1 ` + condition + `
|
|
@@ -704,7 +684,7 @@ func GetCygxSearchKeyWordByCompanyList(condition string, startSize, pageSize int
|
|
|
|
|
|
// 用户搜索关键词列表
|
|
|
func GetCygxActivitySpecialTripByCompanyList(condition string, startSize, pageSize int) (items []*UserInteraction, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
a.research_theme AS activity_name,
|
|
|
a.chart_permission_name,
|
|
@@ -715,13 +695,12 @@ func GetCygxActivitySpecialTripByCompanyList(condition string, startSize, pageSi
|
|
|
r.real_name,
|
|
|
r.is_meeting,
|
|
|
r.activity_id,
|
|
|
- cp.company_name,
|
|
|
- cp.seller_name,
|
|
|
+ r.company_name,
|
|
|
+ r.seller_name,
|
|
|
r.real_name
|
|
|
FROM
|
|
|
cygx_activity_special_trip as r
|
|
|
INNER JOIN cygx_activity_special AS a ON a.activity_id = r.activity_id
|
|
|
- LEFT JOIN company_product AS cp ON cp.company_id = r.company_id AND cp.product_id = 2
|
|
|
LEFT JOIN cygx_company_interaction_num AS ci ON ci.company_id = r.company_id
|
|
|
LEFT JOIN cygx_user_interaction_num AS ui ON ui.user_id = r.user_id
|
|
|
WHERE 1= 1 ` + condition + `
|
|
@@ -732,7 +711,7 @@ func GetCygxActivitySpecialTripByCompanyList(condition string, startSize, pageSi
|
|
|
|
|
|
// 通过纪要ID获取活动详情
|
|
|
func GetTableCompanyList() (item *GetUserInteractionTableCountResp, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sql := `SELECT
|
|
|
SUM( article_history_num ) AS history_num,
|
|
|
SUM( article_count_num ) AS count_num,
|
|
@@ -750,6 +729,7 @@ FROM
|
|
|
|
|
|
// 获取用户参会记录根据销售分组
|
|
|
func GetActivityMeetBySeller(condition string) (list []*company.CompanyReportRecordGroup, err error) {
|
|
|
+ return
|
|
|
o := orm.NewOrm()
|
|
|
sqlCount := ` SELECT
|
|
|
p.seller_id as admin_id,count(DISTINCT(r.company_id)) num,GROUP_CONCAT(DISTINCT r.company_id SEPARATOR ',') AS company_ids
|
|
@@ -774,6 +754,7 @@ func GetActivityMeetBySeller(condition string) (list []*company.CompanyReportRec
|
|
|
|
|
|
// 收藏列表数量根据销售分组
|
|
|
func GetCygxArticleCollectCountBySeller(condition string) (list []*company.CompanyReportRecordGroup, err error) {
|
|
|
+ return // 没有使用了
|
|
|
o := orm.NewOrm()
|
|
|
sqlCount := ` SELECT
|
|
|
p.seller_id as admin_id,count(DISTINCT(r.company_id)) num,GROUP_CONCAT(DISTINCT r.company_id SEPARATOR ',') AS company_ids
|
|
@@ -816,6 +797,7 @@ WHERE
|
|
|
|
|
|
// 关注作者数量根据销售分组
|
|
|
func GetCygArticleDepartmentFollowCountBySeller(condition string) (list []*company.CompanyReportRecordGroup, err error) {
|
|
|
+ return // 没有使用了
|
|
|
o := orm.NewOrm()
|
|
|
sqlCount := ` SELECT
|
|
|
p.seller_id AS admin_id,
|
|
@@ -862,14 +844,13 @@ type CompanyAndCount struct {
|
|
|
|
|
|
// 获取用户参会记录数量根据公司分组
|
|
|
func GetActivityMeetGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,COUNT(*) AS count
|
|
|
FROM
|
|
|
cygx_activity_signup AS r
|
|
|
INNER JOIN cygx_activity AS a ON a.activity_id = r.activity_id
|
|
|
INNER JOIN cygx_activity_type AS t ON t.activity_type_id = a.activity_type_id
|
|
|
- INNER JOIN wx_user AS u ON u.user_id = r.user_id
|
|
|
WHERE
|
|
|
1 = 1
|
|
|
AND r.do_fail_type = 0 `
|
|
@@ -883,14 +864,13 @@ WHERE
|
|
|
|
|
|
// 收藏列表数量根据公司分组
|
|
|
func GetCygxArticleCollectCountGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,
|
|
|
COUNT(*) AS count
|
|
|
FROM
|
|
|
cygx_article_collect AS r
|
|
|
INNER JOIN cygx_article AS art ON art.article_id = r.article_id
|
|
|
- INNER JOIN wx_user AS u ON u.user_id = r.user_id
|
|
|
WHERE
|
|
|
1 = 1 `
|
|
|
if condition != "" {
|
|
@@ -903,14 +883,13 @@ WHERE
|
|
|
|
|
|
// 关注产业数量根据公司分组
|
|
|
func GetCygxIndustryFllowCountGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,
|
|
|
COUNT(*) AS count
|
|
|
FROM
|
|
|
cygx_industry_fllow AS r
|
|
|
INNER JOIN cygx_industrial_management AS m ON m.industrial_management_id = r.industrial_management_id
|
|
|
- INNER JOIN wx_user AS u ON u.user_id = r.user_id
|
|
|
WHERE
|
|
|
type = 1 `
|
|
|
if condition != "" {
|
|
@@ -923,14 +902,13 @@ WHERE
|
|
|
|
|
|
// 关注作者数量根据公司分组
|
|
|
func GetCygArticleDepartmentFollowCountGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,
|
|
|
COUNT(*) AS count
|
|
|
FROM
|
|
|
cygx_article_department_follow AS r
|
|
|
INNER JOIN cygx_article_department AS m ON m.department_id = r.department_id
|
|
|
- INNER JOIN wx_user AS u ON u.user_id = r.user_id
|
|
|
WHERE
|
|
|
type = 1 `
|
|
|
if condition != "" {
|
|
@@ -943,7 +921,7 @@ WHERE
|
|
|
|
|
|
// 用户搜索关键词统计
|
|
|
func GetCygxSearchKeyWordCountGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,
|
|
|
COUNT(*) AS count
|
|
@@ -960,7 +938,7 @@ WHERE
|
|
|
}
|
|
|
|
|
|
func GetChartCountGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,
|
|
|
COUNT(*) AS count
|
|
@@ -996,7 +974,7 @@ func GetCompanyCountGroupBySeller(condition string) (list []*company.CompanyRepo
|
|
|
|
|
|
// 获取文章阅读记录根据公司分组
|
|
|
func GetArticleHistoryGroupByCompany(condition string) (list []*CompanyAndCount, err error) {
|
|
|
- o := orm.NewOrm()
|
|
|
+ o := orm.NewOrmUsingDB("hz_cygx")
|
|
|
sqlCount := ` SELECT
|
|
|
r.company_id,COUNT(*) AS count
|
|
|
FROM
|