no message

models/cygx/questionnaire.go

@@ -68,7 +68,7 @@ type GetCygxQuestionnaireResp struct {
 
 // 添加
 func AddCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionnaireThemeReq) (err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	to, err := o.Begin()
 	if err != nil {
 		return
@@ -101,7 +101,7 @@ func AddCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionn
 
 // 编辑
 func EditCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionnaireThemeReq) (err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	to, err := o.Begin()
 	if err != nil {
 		return
@@ -180,14 +180,14 @@ func GetCygxQuestionnaireCount(condition string, pars []interface{}) (count int,
 	if condition != "" {
 		sqlCount += condition
 	}
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	err = o.Raw(sqlCount, pars).QueryRow(&count)
 	return
 }
 
 // 列表
 func GetCygxQuestionnaireList(condition string, pars []interface{}, startSize, pageSize int) (items []*CygxQuestionnaireResp, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire as art WHERE 1= 1 `
 	if condition != "" {
 		sql += condition
@@ -203,7 +203,7 @@ type GetCygxQuestionnaireDetailResp struct {
 
 // 通过ID获取详情
 func GetCygxQuestionnaireDetail(questionnaireId int) (item *CygxQuestionnaireResp, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire  WHERE questionnaire_id=? `
 	err = o.Raw(sql, questionnaireId).QueryRow(&item)
 	return
@@ -211,7 +211,7 @@ func GetCygxQuestionnaireDetail(questionnaireId int) (item *CygxQuestionnaireRes
 
 // 列表
 func GetCygxQuestionnaireThemeListByQuestionnaireId(questionnaireId int) (items []*AddCygxQuestionnaireThemeReq, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire_theme as art WHERE questionnaire_id = ? `
 	_, err = o.Raw(sql, questionnaireId).QueryRows(&items)
 	return

models/cygx/questionnaire_vote.go

@@ -48,7 +48,7 @@ type CygxQuestionnaireVoteListResp struct {
 
 // 列表
 func GetCygxCygxQuestionnaireVoteListByQuestionnaireId(questionnaireId int) (items []*CygxQuestionnaireVoteResp, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire_vote as art WHERE questionnaire_id = ? `
 	_, err = o.Raw(sql, questionnaireId).QueryRows(&items)
 	return
@@ -60,7 +60,7 @@ type CygxCygxQuestionnaireVoteListResp struct {
 
 // 列表
 func GetCygxQuestionnaireVoteListByQuestionnaireThemeId(questionnaireThemeId int) (items []*CygxQuestionnaireVoteResp, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire_vote as art WHERE questionnaire_theme_id = ? `
 	_, err = o.Raw(sql, questionnaireThemeId).QueryRows(&items)
 	return
@@ -72,7 +72,7 @@ type CygxQuestionnaireVoteOtherThemeListResp struct {
 
 // 列表
 func GetCygxQuestionnaireVoteOtherThemeListByQuestionnaireId(questionnaireId int) (items []*CygxQuestionnaireVoteOtherThemeResp, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("hz_cygx")
 	sql := `SELECT * FROM cygx_questionnaire_vote_other_theme as art WHERE questionnaire_id = ? `
 	_, err = o.Raw(sql, questionnaireId).QueryRows(&items)
 	return