调整上架时es所存字段

services/stdlib/docChangeService.go

@@ -26,6 +26,23 @@ func ChangeDocumentOn(id string, reason int32) bool {
 			return false
 		}
 	}
+	statisticsData := map[string]interface{}{}
+	var downTimes int64
+	var viewTimes int64
+	result := jyDocsRpcUtil.GetJyDocsDB().Table("doc_statistics").Where("docId=?", id).Find(&statisticsData)
+	if result.Error != nil {
+		log.Println("上架文档 查询浏览次数下载量出错 error:"+id, result.Error)
+		return false
+	} else {
+		if statisticsData["id"] != nil {
+			if statisticsData["downTimes"] != nil {
+				downTimes = statisticsData["downTimes"].(int64)
+			}
+			if statisticsData["viewTimes"] != nil {
+				viewTimes = statisticsData["viewTimes"].(int64)
+			}
+		}
+	}
 	// 上架
 	err := jyDocsRpcUtil.GetJyDocsDB().Transaction(func(tx *gorm.DB) error {
 		// 更新大库状态为上架 1-上架
@@ -38,8 +55,19 @@ func ChangeDocumentOn(id string, reason int32) bool {
 			return err
 		}
 		docData["_id"] = docData["id"]
-		// todo es加数据 索引待替换 测试
-		if rs := elastic.Save("jydoc", "doc", docData); rs != true {
+		saveData := map[string]interface{}{
+			"_id":              docData["id"],
+			"docName":          docData["docName"],
+			"docTags":          docData["docTags"],
+			"docClassLevelOne": docData["docClassLevelOne"],
+			"docClassLevelTwo": docData["docClassLevelTwo"],
+			"price":            docData["price"],
+			"downTimes":        downTimes,
+			"viewTimes":        viewTimes,
+			"docSummary":       docData["docSummary"],
+			"create_at":        docData["uploadDate"].(time.Time).Format("2006-01-02 15:04:05"),
+		}
+		if rs := elastic.Save("jydoc", "_doc", saveData); rs != true {
 			return errors.New("发布到检索库失败")
 		}
 		return nil