eta_task/models/wx_template_msg.go

package models

import (
	"eta_gn/eta_task/global"
)

type SendTemplateResponse struct {
	Errcode int    `json:"errcode"`
	Errmsg  string `json:"errmsg"`
	MsgID   int    `json:"msgid"`
}

type OpenIdList struct {
	OpenId string
}

func DeleteTemplateRecordByDate(date string) (err error) {
	//sql := `DELETE FROM user_template_record WHERE create_time<? `
	//o := orm.NewOrm()
	//_, err = o.Raw(sql, date).Exec()

	sql := `DELETE FROM user_template_record WHERE create_time<? `
	err = global.DEFAULT_DmSQL.Exec(sql, date).Error
	return
}

//// GetOpenIdListV2 2022-08-18从hongze_admin复制过来的最新的代码
//func GetOpenIdListV2() (items []*OpenIdList, err error) {
//	sql := `SELECT DISTINCT
//				ur.open_id,
//				wu.user_id
//			FROM
//				wx_user AS wu
//			INNER JOIN company AS c ON c.company_id = wu.company_id
//			INNER JOIN company_product AS d ON c.company_id = d.company_id
//			INNER JOIN user_record AS ur ON wu.user_id = ur.user_id
//			WHERE
//				ur.open_id != "" AND ur.subscribe = 1 AND ur.create_platform = 1 AND d. STATUS IN ('正式', '试用', '永续') `
//	_, err = orm.NewOrm().Raw(sql).QueryRows(&items)
//	return
//}

func GetOpenIdArr() (items []string, err error) {
	//sql := ` SELECT DISTINCT ur.open_id FROM wx_user AS wu
	//      INNER JOIN company AS c ON c.company_id = wu.company_id
	//      INNER JOIN company_product AS d ON c.company_id=d.company_id
	//	INNER JOIN user_record  AS ur ON wu.user_id=ur.user_id
	//      WHERE ur.open_id != "" AND ur.subscribe=1 AND ur.create_platform=1 AND  d.status IN('正式','试用','永续')
	//     ORDER BY FIELD(c.company_id, 16) desc, ur.user_record_id asc`
	//o := orm.NewOrm()
	//_, err = o.Raw(sql).QueryRows(&items)

	sql := ` SELECT DISTINCT ur.open_id FROM wx_user AS wu
	     INNER JOIN company AS c ON c.company_id = wu.company_id
	     INNER JOIN company_product AS d ON c.company_id=d.company_id
		INNER JOIN user_record  AS ur ON wu.user_id=ur.user_id
	     WHERE ur.open_id != '' AND ur.subscribe=1 AND ur.create_platform=1 AND  d.status IN('正式','试用','永续')
	    ORDER BY FIELD(c.company_id, 16) desc, ur.user_record_id asc`
	err = global.DEFAULT_DmSQL.Raw(sql).Find(&items).Error
	return
}

//func GetOpenIdArrByClassifyNameSecond(classifyNameSecond string) (items []string, err error) {
//	sql := ` SELECT DISTINCT ur.open_id FROM wx_user AS wu
//			INNER JOIN company AS c ON c.company_id = wu.company_id
//			INNER JOIN company_product AS d ON c.company_id=d.company_id
//			INNER JOIN user_record  AS ur ON wu.user_id=ur.user_id
//			INNER JOIN company_report_permission AS e ON d.company_id=e.company_id
//			INNER JOIN chart_permission AS f ON e.chart_permission_id=f.chart_permission_id
//			INNER JOIN chart_permission_search_key_word_mapping AS g ON f.chart_permission_id=g.chart_permission_id
//			WHERE ur.open_id != "" AND ur.subscribe=1 AND ur.create_platform=1 AND  d.status IN('正式','试用','永续') AND  e.status IN('正式','试用','永续')
//			AND g.from='rddp'
//			AND g.key_word=?
//			ORDER BY FIELD(c.company_id, 16) DESC, ur.user_record_id ASC  `
//	o := orm.NewOrm()
//	_, err = o.Raw(sql, classifyNameSecond).QueryRows(&items)
//	return
//}

// GetOpenIdArrByClassifyId
// @Description: 根据分类id获取关联的用户微信openid
// @author: Roc
// @datetime 2024-06-28 14:57:27
// @param classifyId int
// @return items []string
// @return err error
func GetOpenIdArrByClassifyId(classifyId int) (items []string, err error) {
	//sql := ` SELECT DISTINCT ur.open_id FROM wx_user AS wu
	//		INNER JOIN company AS c ON c.company_id = wu.company_id
	//		INNER JOIN company_product AS d ON c.company_id=d.company_id
	//		INNER JOIN user_record  AS ur ON wu.user_id=ur.user_id
	//		INNER JOIN company_report_permission AS e ON d.company_id=e.company_id
	//		INNER JOIN chart_permission AS f ON e.chart_permission_id=f.chart_permission_id
	//		INNER JOIN chart_permission_search_key_word_mapping AS g ON f.chart_permission_id=g.chart_permission_id
	//		WHERE ur.open_id != "" AND ur.subscribe=1 AND ur.create_platform=1 AND  d.status IN('正式','试用','永续') AND  e.status IN('正式','试用','永续')
	//		AND g.from='rddp'
	//		AND g.classify_id=?
	//		ORDER BY FIELD(c.company_id, 16) DESC, ur.user_record_id ASC  `
	//o := orm.NewOrmUsingDB("weekly")
	//_, err = o.Raw(sql, classifyId).QueryRows(&items)
	return
}