Merge remote-tracking branch 'origin/dev1.0.0' into dev1.0.0

rpc/common/test/oss_test.go

@@ -1,25 +1,69 @@
 package test
 
-// import (
-// 	"bytes"
-// 	"io/ioutil"
-// 	"app.yhyue.com/moapp/jyInfo/rpc/model/oss"
-// 	"log"
-// 	"testing"
-// )
-
-// //es保存
-// var filename = "app.yhyue.com/moapp/jyInfo.docx"
-// var filecont = "信息发布，不同意公开联系方式，则采购联系人、采购联系电话不展示。"
-// var filepath = "E:/oss/我的测试文档.docx"
-
-// func Test_ossUp(t *testing.T) {
-// 	model.InitOss()
-// 	bt, _ := ioutil.ReadFile(filepath)
-// 	log.Println("size:", len(bt), len(bt)/1024)
-// 	// bt := []byte(filecont)
-// 	key := model.GetHashKey(bt) + model.TypeByExt(filename)
-// 	log.Println("keys:", key)
-// 	b, err := model.OssPutObject(key, bytes.NewReader(bt))
-// 	log.Println("b:", b, "---err:", err)
-// }
+import (
+	"bytes"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"os"
+	"testing"
+
+	"app.yhyue.com/moapp/jyInfo/rpc/model/oss"
+	"github.com/aliyun/aliyun-oss-go-sdk/oss"
+)
+
+//https://jytest2022.oss-cn-beijing.aliyuncs.com/
+//https://jy-datafile.oss-cn-beijing.aliyuncs.com/
+
+//es保存
+var filename = "4671650439467_.pic_hd.jpg"
+var filecont = "信息发布，不同意公开联系方式，则采购联系人、采购联系电话不展示。"
+var filepath = "E:/oss/4671650439467_.pic_hd.jpg"
+
+//b06c25cc82579e5e600239dec065a71a527e9b701c3315307782c66c01089aa8.docx
+//20fede85e42bbeefd194a3180160b03d1141a0de3f5f6221e2531a9660c017d8.jpg
+var objectName = "jytest2022"
+var objectKey = "20fede85e42bbeefd194a3180160b03d1141a0de3f5f6221e2531a9660c017d8.jpg"
+
+//
+
+func Test_ossUp(t *testing.T) {
+	bt, _ := ioutil.ReadFile(filepath)
+	log.Println("size:", len(bt), len(bt)/1024)
+	// bt := []byte(filecont)
+	key := model.GetHashKey(bt) + model.TypeByExt(filename)
+	log.Println("keys:", key)
+
+	client, err := oss.New("oss-cn-beijing.aliyuncs.com", "LTAI4G5x9aoZx8dDamQ7vfZi", "Bk98FsbPYXcJe72n1bG3Ssf73acuNh")
+	if err != nil {
+		fmt.Println("Error:", err)
+		os.Exit(-1)
+	}
+	// 获取存储空间。
+	bucket, err := client.Bucket(objectName)
+	if err != nil {
+		fmt.Println("Error:", err)
+	}
+	err = bucket.PutObject(key, bytes.NewReader(bt))
+	if err != nil {
+		fmt.Println("file upload false:", err)
+	}
+	log.Println("----------")
+}
+
+//
+func Test_ossIsExist(t *testing.T) {
+	client, err := oss.New("oss-cn-beijing.aliyuncs.com", "LTAI4G5x9aoZx8dDamQ7vfZi", "Bk98FsbPYXcJe72n1bG3Ssf73acuNh")
+	if err != nil {
+		fmt.Println("Error:", err)
+		os.Exit(-1)
+	}
+	// 获取存储信息
+	bucket, err := client.Bucket(objectName)
+	if err != nil {
+		fmt.Println("Error:", err)
+	}
+	//附件是否存在
+	ok, err := bucket.IsObjectExist(objectKey)
+	log.Println("ok:", ok, "--err:", err)
+}