package ossClient

import (
	"io/ioutil"
	"log"
	"sync"
	"sync/atomic"
	"testing"
	"time"
)

var (
	//restfulAddress = "http://172.17.162.27:18011"
	restfulAddress = "http://127.0.0.1:8011"
)

// restful方式上传附件
func TestUploadFileByRestful(t *testing.T) {
	b, _ := ioutil.ReadFile("./" + imgFileName)
	t.Log(UpLoadByRestful(restfulAddress, bucketID, imgFileName, b, false))
}

// restful方式上传正文
func TestUploadTextByRestful(t *testing.T) {
	b := []byte(textDetail)
	t.Log(UpLoadByRestful(restfulAddress, bucketID, txtFileName, b, false))
}

// restful方式下载
func TestDownloadTextByRestful(t *testing.T) {
	t.Log(DownloadByRestful(restfulAddress, bucketID, imgFileName))
}

// restful方式删除
func TestDeleteByRestful(t *testing.T) {
	t.Log(DeleteByRestful(restfulAddress, bucketID, txtFileName))
}

// restful方式获取标讯正文
func TestGetBidDetailByRestful(t *testing.T) {
	array := []string{"684b7e4c5f834436f09f980f", "684b7e4c5f834436f09f9812", "684b7e4c5f834436f09f9814", "684b7e4c5f834436f09f9816", "684b7e4c5f834436f09f9818", "684b7e4c5f834436f09f9819", "684b7e4c5f834436f09f981a", "684b7e4c5f834436f09f981b", "684b7e4f5f834436f09f981c", "684b7e4f5f834436f09f981d", "684b7e4f5f834436f09f981e", "684b7e4f5f834436f09f9820", "684b7e4f5f834436f09f9822", "684b7e4f5f834436f09f9823", "684b7e4f5f834436f09f9824", "684b7e4f5f834436f09f9825", "684b7e4f5f834436f09f9826", "684b7e4f5f834436f09f9827", "684b7e4f5f834436f09f9828", "684b7e4f5f834436f09f9829", "684b7e4f5f834436f09f982b", "684b7e4f5f834436f09f982c", "684b7e4f5f834436f09f982e", "684b7e4f5f834436f09f982f", "684b7e4f5f834436f09f9830", "684b7e4f5f834436f09f9831", "684b7e4f5f834436f09f9833", "684b7e4f5f834436f09f9834", "684b7e4f5f834436f09f9835", "684b7e4f5f834436f09f9836", "684b7e4f5f834436f09f9837", "684b7e4f5f834436f09f9838", "684b7e4f5f834436f09f983a", "684b7e4f5f834436f09f983b", "684b7e4f5f834436f09f983d", "684b7e4f5f834436f09f983e", "684b7e4f5f834436f09f9840", "684b7e4f5f834436f09f9842", "684b7e4f5f834436f09f9843", "684b7e4f5f834436f09f9844", "684b7e4f5f834436f09f9845", "684b7e4f5f834436f09f9846", "684b7e4f5f834436f09f9847", "684b7e4f5f834436f09f9848", "684b7e4f5f834436f09f9849", "684b7e4f5f834436f09f984b", "684b7e4f5f834436f09f984d", "684b7e4f5f834436f09f984f", "684b7e4f5f834436f09f9851", "684b7e4f5f834436f09f9852", "684b7e4f5f834436f09f9853", "684b7e4f5f834436f09f9854", "684b7e4f5f834436f09f9856", "684b7e4f5f834436f09f9857", "684b7e4f5f834436f09f9858", "684b7e4f5f834436f09f985b", "684b7e505f834436f09f985c", "684b7e505f834436f09f985e", "684b7e505f834436f09f985f", "684b7e505f834436f09f9860", "684b7e505f834436f09f9861", "684b7e505f834436f09f9862", "684b7e505f834436f09f9865", "684b7e505f834436f09f9866", "684b7e505f834436f09f9868", "684b7e505f834436f09f986a", "684b7e505f834436f09f986b", "684b7e505f834436f09f986c", "684b7e505f834436f09f986d", "684b7e505f834436f09f986f", "684b7e505f834436f09f9870", "684b7e505f834436f09f9871", "684b7e505f834436f09f9872", "684b7e505f834436f09f9873", "684b7e505f834436f09f9875", "684b7e505f834436f09f9876", "684b7e505f834436f09f9877", "684b7e505f834436f09f9878", "684b7e505f834436f09f987a", "684b7e505f834436f09f987c", "684b7e505f834436f09f987d", "684b7e505f834436f09f987e", "684b7e505f834436f09f9880", "684b7e505f834436f09f9881", "684b7e505f834436f09f9882", "684b7e505f834436f09f9883", "684b7e505f834436f09f9885", "684b7e505f834436f09f9886", "684b7e505f834436f09f9887", "684b7e505f834436f09f988a", "684b7e505f834436f09f988b", "684b7e505f834436f09f988c", "684b7e505f834436f09f988d", "684b7e505f834436f09f988e", "684b7e505f834436f09f988f", "684b7e505f834436f09f9890", "684b7e505f834436f09f9893", "684b7e505f834436f09f9894", "684b7e505f834436f09f9895", "684b7e505f834436f09f9896", "684b7e505f834436f09f9897"}
	pool := make(chan bool, 3)
	wait := &sync.WaitGroup{}
	var index int64
	for _, v := range array {
		pool <- true
		wait.Add(1)
		go func(vv string) {
			atomic.AddInt64(&index, 1)
			t.Log(GetBidDetailByRestful("http://172.17.162.27:18011", bucketID, vv))
			<-pool
			wait.Done()
		}(v)
	}
	wait.Wait()
	log.Println(len(array), index)
	time.Sleep(time.Minute)
}