迁移修改

@@ -96,6 +96,10 @@ func CreateUploadImage(client *vod.Client, r *CreateUploadImageRequest) (respons
 	filePath := getFileName(FileImage, r.FileName)
 	filePath := getFileName(FileImage, r.FileName)
 	request.ImageType = "default"
 	request.ImageType = "default"
 	request.Title = filePath
 	request.Title = filePath
+	if filepath.Ext(r.FileName) == "" {
+		err = fmt.Errorf("filename:%v invalid", r.FileName)
+		return
+	}
 	request.ImageExt = filepath.Ext(r.FileName)[1:]
 	request.ImageExt = filepath.Ext(r.FileName)[1:]
 	request.AcceptFormat = "JSON"
 	request.AcceptFormat = "JSON"
 	//request.StorageLocation = filepath.Base(request.Title)
 	//request.StorageLocation = filepath.Base(request.Title)

@@ -12,7 +12,7 @@ import (
 	"opp/protocol"
 	"opp/protocol"
 )
 )
 
 
-const LoopSize = 1
+const LoopSize = 20
 
 
 const (
 const (
 	Uploaded      = "已上传,跳过"
 	Uploaded      = "已上传,跳过"
@@ -31,12 +31,13 @@ func MigrateChanceDataToAliYun() {
 	log.Info("【迁移机会媒体数据】开始迁移")
 	log.Info("【迁移机会媒体数据】开始迁移")
 	defer log.Info("【迁移机会媒体数据】结束迁移")
 	defer log.Info("【迁移机会媒体数据】结束迁移")
 	var (
 	var (
-		datas    []*models.ChanceData
 		query    = `select * from chance_data order by id limit ?,?`
 		query    = `select * from chance_data order by id limit ?,?`
 		pageInfo = protocol.PageInfo{PageSize: LoopSize}
 		pageInfo = protocol.PageInfo{PageSize: LoopSize}
 	)
 	)
 	o := orm.NewOrm()
 	o := orm.NewOrm()
 	for {
 	for {
+		var datas []*models.ChanceData
+		log.Info("当前页:", pageInfo.PageIndex, "起始:", pageInfo.Offset())
 		if _, e := o.Raw(query, pageInfo.Offset(), pageInfo.PageSize).QueryRows(&datas); e != nil {
 		if _, e := o.Raw(query, pageInfo.Offset(), pageInfo.PageSize).QueryRows(&datas); e != nil {
 			if e == orm.ErrNoRows {
 			if e == orm.ErrNoRows {
 				break
 				break
@@ -44,6 +45,9 @@ func MigrateChanceDataToAliYun() {
 			log.Error(e)
 			log.Error(e)
 			break
 			break
 		}
 		}
+		if len(datas) == 0 {
+			break
+		}
 
 
 		for i := range datas {
 		for i := range datas {
 			data := datas[i]
 			data := datas[i]
@@ -53,12 +57,12 @@ func MigrateChanceDataToAliYun() {
 			//上传视频
 			//上传视频
 			data.Videos = utils.JsonMarsh(uploadVideos(data, data.Videos))
 			data.Videos = utils.JsonMarsh(uploadVideos(data, data.Videos))
 			//上传音频
 			//上传音频
-			data.Speechs = utils.JsonMarsh(uploadVoice(data, data.Speechs))
+			//data.Speechs = utils.JsonMarsh(uploadVoice(data, data.Speechs))
 			//更新数据
 			//更新数据
 			o.Update(data)
 			o.Update(data)
 		}
 		}
 		pageInfo.PageIndex += 1
 		pageInfo.PageIndex += 1
-		break
+		//break
 	}
 	}
 }
 }