更新 'resourceChannel/resourceChannel.go'

json文件上传至0ss

resourceChannel/resourceChannel.go

@@ -324,26 +324,37 @@ func getCurrentPath() string {
 }
 
 func getCategory(OriginalCategory int) int {
-	// 打开JSON文件
-	//jsonFile, err := os.Open(getCurrentPath() + "/category_mapper.json")
-	jsonFile, err := os.Open("category_mapper.json")
+	endpoint := "oss-cn-beijing.aliyuncs.com" // 例如 "oss-cn-hangzhou.aliyuncs.com"
+	accessKeyID := "LTAI5t7iAtrYaUgGgK8ws54e"
+	accessKeySecret := "j4A6llCRqZBMzXLQ7ms84LdKl9l0IS"
+	bucketName := "jjl-prod-bucket"
+	objectName := "channel/category_mapper.json"
+
+	client, err := oss.New(endpoint, accessKeyID, accessKeySecret)
 	if err != nil {
-		fmt.Println(err)
-		return -1
+		log.Fatalf("创建OSS客户端失败: %v", err)
 	}
-	defer jsonFile.Close()
-	// 读取文件内容
-	byteValue, err := ioutil.ReadAll(jsonFile)
+
+	// 获取存储空间
+	bucket, err := client.Bucket(bucketName)
 	if err != nil {
-		fmt.Println(err)
-		return -1
+		log.Fatalf("获取Bucket失败: %v", err)
 	}
-	// 解析JSON数据
+
+	// 获取对象
+	body, err := bucket.GetObject(objectName)
+	if err != nil {
+		log.Fatalf("获取对象失败: %v", err)
+	}
+	defer body.Close()
+
+	// 读取对象内容
 	var channel []SysChannel
-	if err := json.Unmarshal(byteValue, &channel); err != nil {
-		fmt.Println(err)
-		return -1
+	decoder := json.NewDecoder(body)
+	if err := decoder.Decode(&channel); err != nil {
+		log.Fatalf("解析JSON失败: %v", err)
 	}
+
 	for i := range channel {
 		ori, _ := strconv.Atoi(channel[i].OriginalCategory)
 		if ori == OriginalCategory {