Explorar o código

策略平台自动同步报告的时候,多关联产业的bug处理

xingzai %!s(int64=2) %!d(string=hai) anos
pai
achega
3a3e2e88c8
Modificáronse 1 ficheiros con 7 adicións e 3 borrados
  1. 7 3
      services/article.go

+ 7 - 3
services/article.go

@@ -672,8 +672,7 @@ func GetArticleListByApi(cont context.Context) (err error) {
 }
 
 //func init() {
-//
-//	HandleArticleListByApi(7214)
+//	HandleArticleListByApi(7164)
 //}
 
 //处理同步过来的文章
@@ -989,6 +988,7 @@ func HandleArticleListByApi(artcleId int) (err error) {
 				var keyword4 string
 				sliceSubjects := strings.Split(v.Stock, "/")
 				mapManagementForSubject := make(map[string]string)
+				mapIndustrialId := make(map[int]int)
 				if len(sliceSubjects) > 0 {
 					for _, vSubject := range sliceSubjects {
 						sliceKuohao := strings.Split(vSubject, "(")           //过滤括号
@@ -1014,10 +1014,14 @@ func HandleArticleListByApi(artcleId int) (err error) {
 						subjectStr = "【" + subjectStr + "】"
 						if len(listIndustrial) > 0 {
 							for _, vIndustrial := range listIndustrial {
-								industrialManagementIdStr += strconv.Itoa(vIndustrial.IndustrialManagementId) + ","
+								if _, ok := mapIndustrialId[vIndustrial.IndustrialManagementId]; !ok {
+									industrialManagementIdStr += strconv.Itoa(vIndustrial.IndustrialManagementId) + ","
+								}
+								mapIndustrialId[vIndustrial.IndustrialManagementId] = vIndustrial.IndustrialManagementId
 								industrialSubjectIdStr += strconv.Itoa(vIndustrial.IndustrialSubjectId) + ","
 								mapManagementForSubject[vIndustrial.IndustryName] += vIndustrial.SubjectName + "/"
 							}
+
 							industrialManagementIdStr = strings.TrimRight(industrialManagementIdStr, ",")
 							industrialSubjectIdStr = strings.TrimRight(industrialSubjectIdStr, ",")
 							if industrialManagementIdStr != "" {