no message

services/resource_data.go

@@ -850,3 +850,51 @@ func UpdateYanxuanSpecialResourceData(sourceId int) {
 	}
 	return
 }
+
+func initsql12_17() {
+	listIndustrialResourceIds, e := models.GetSearchResourceList(0, " AND article_type_id > 0 ", 0, 9999)
+	if e != nil {
+		fmt.Println(e)
+		return
+	}
+	var industrialResourceIdsHz []int
+	for _, v := range listIndustrialResourceIds {
+		industrialResourceIdsHz = append(industrialResourceIdsHz, v.IndustrialManagementId)
+	}
+	//date_format( MAX( a.publish_date ), '%Y-%m-%d' ) AS publish_date,
+
+	//合并产业关联的标的
+	listSubjcet, e := models.GetIndustrialSubjectAllByIndustrialId(industrialResourceIdsHz)
+	if e != nil {
+		fmt.Println(e)
+		return
+	}
+	mapIndustrial := make(map[string]int)
+	for _, v := range listSubjcet {
+		for k2, v2 := range listIndustrialResourceIds {
+			if v2.IndustrialManagementId == v.IndustrialManagementId && mapIndustrial[fmt.Sprint(v2.IndustrialManagementId, "Hz", v.SubjectName)] == 0 {
+				listIndustrialResourceIds[k2].IndustrialSubjectList = append(listIndustrialResourceIds[k2].IndustrialSubjectList, v)
+			}
+		}
+	}
+	//industrialsource := "industrialsourceHz"
+	industrialsource := "industrialsourceYx"
+	for _, v := range listIndustrialResourceIds {
+
+		item := new(ElasticComprehensiveDetail)
+		item.SourceId = v.IndustrialManagementId
+		item.Source = industrialsource
+		item.IndustryName = v.IndustryName
+
+		var SubjectName []string
+
+		for _, vN := range v.IndustrialSubjectList {
+			SubjectName = append(SubjectName, vN.SubjectName)
+		}
+		item.SubjectNames = strings.Join(SubjectName, ",")
+		item.PublishDate = v.PublishDate
+		fmt.Println(item)
+		UpdateComprehensiveIndustrialResourceData(item)
+	}
+	return
+}