no message

services/cygx_yanxuan_special.go

@@ -225,23 +225,6 @@ func SendWxMsgSpecialAuthor(specialId, status int) (err error) {
 	return
 }
 
-//func init() {
-//
-//	var condition string
-//	var pars []interface{}
-//
-//	condition = " AND   a.user_id = 103354  "
-//	list, tmpErr := models.GetYanxuanSpecialList(0, condition, pars)
-//
-//	fmt.Println(len(list))
-//	fmt.Println(tmpErr)
-//
-//	for _, v := range list {
-//		fmt.Println(v.Id)
-//		EsAddYanxuanSpecial(v.Id)
-//	}
-//}
-
 // 更新研选专栏  写入首页最新  cygx_resource_data 表
 func UpdateYanxuanSpecialResourceData(sourceId int) {
 	var err error

services/es_comprehensive.go

@@ -611,6 +611,9 @@ func EsAddYanxuanSpecial(sourceId int) {
 	item.Title = detail.Title
 	item.PublishDate = detail.PublishTime
 	item.BodyText = bodyText
+	item.Abstract = bodyText
+	item.IndustryName = detail.IndustryTags
+	item.SubjectNames = detail.SpecialName
 	if detail.Status == 3 {
 		EsAddOrEditComprehensiveData(item) //如果发布了就新增
 	} else {

services/init12.8.go

@@ -20,6 +20,20 @@ func init11() {
 	}
 }
 
+func init8882228() {
+	var condition string
+	var pars []interface{}
+	list, tmpErr := models.GetYanxuanSpecialList(0, condition, pars, 0, 99999)
+
+	fmt.Println(len(list))
+	fmt.Println(tmpErr)
+
+	for _, v := range list {
+		fmt.Println(v.Id)
+		EsAddYanxuanSpecial(v.Id)
+	}
+}
+
 func init77() {
 	var condition string
 	var pars []interface{}