no message

controllers/cygx/questionnaire.go

@@ -68,19 +68,24 @@ func (this *QuestionnaireController) PreserveAndPublish() {
 	item.MaxChooseTotal = maxChooseTotal
 
 	if questionnaireId == 0 {
-		err = cygx.AddCygxQuestionnaire(item, listTheme)
+		newId, err := cygx.AddCygxQuestionnaire(item, listTheme)
+		if err != nil {
+			br.Msg = "保存失败"
+			br.ErrMsg = "保存失败,Err:" + err.Error()
+			return
+		}
+		//投票发布时，给所有开通买方研选正式试用的客户，推送模板消息
+		go cygxService.SendWxMsgCygxQuestionnaire(int(newId))
+
 	} else {
 		err = cygx.EditCygxQuestionnaire(item, listTheme)
+		if err != nil {
+			br.Msg = "保存失败"
+			br.ErrMsg = "保存失败,Err:" + err.Error()
+			return
+		}
 	}
-	if err != nil {
-		br.Msg = "保存失败"
-		br.ErrMsg = "保存失败,Err:" + err.Error()
-		return
-	}
-	//投票发布时，给所有开通买方研选正式试用的客户，推送模板消息
-	if questionnaireId == 0 {
-		go cygxService.SendWxMsgCygxQuestionnaire(questionnaireId)
-	}
+
 	br.Ret = 200
 	br.Success = true
 	br.IsAddLog = true

models/cygx/questionnaire.go

@@ -67,7 +67,7 @@ type GetCygxQuestionnaireResp struct {
 }
 
 // 添加
-func AddCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionnaireThemeReq) (err error) {
+func AddCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionnaireThemeReq) (newId int64, err error) {
 	o := orm.NewOrmUsingDB("hz_cygx")
 	to, err := o.Begin()
 	if err != nil {
@@ -80,7 +80,7 @@ func AddCygxQuestionnaire(item *CygxQuestionnaire, listTheme []*AddCygxQuestionn
 			_ = to.Commit()
 		}
 	}()
-	newId, err := to.Insert(item)
+	newId, err = to.Insert(item)
 	if err != nil {
 		return
 	}