背景

由于公司数据上传到阿里云，采用到音频格式是amr，在h5播放amr格式到时候，如果长度比较长，那么会出现播放不了到问题。具体可以看下原理。html插件播放音频。

处理方案

将amr转mp3。插件天然支持mp3的播放。具体原因，大家自己去了解下，这里不是重点阐述这个玩意儿的。

处理过程

不得不了解的一些常识

ffmpeg

https://www.ffmpeg.org/
A complete, cross-platform solution to record, convert and stream audio and video.

环境需要安装ffmpeg。不安装，那么程序无法执行命令。
go的日期格式化，很奇葩：
fmt.Println(time.Now().Format("2006-01-02 15:04:05")) # 这是个奇葩,必须是这个时间点, 据说是go诞生之日, 记忆方法:6-1-2-3-4-5

步骤

创建目录:每天从阿里云oss download下来昨天的，放在一个目录里

//创建当天的目录
func mkTodayDir() {
    today := time.Now().Format("20060102")
    _,err2 := os.Stat(myfolder+today)
    if os.IsNotExist(err2) {
        err3 := os.Mkdir(myfolder+today,os.ModePerm)
        if err3 == nil {
            println("mkdir"+myfolder+today+" success..")
        }else {
            println("mkdir"+myfolder+today+" fail..")
        }

    }else {
        println("dir "+myfolder+today+" exists.")
    }
    todayFolder = myfolder+today +"/"

}

初始化阿里云oss实例

func bucketo() *oss.Bucket  {
    // 创建OSSClient实例。
    client, err := oss.New("oss-cn-shanghai.aliyuncs.com", "xxx", "xxx")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    // 获取存储空间。
    bucket, err := client.Bucket("paifenle-tars")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    return bucket
}

开始下载

func getAndDownload() {
    d, _ := time.ParseDuration("-24h")
    // 分页列举包含指定前缀的文件。每页列举80个。
    prefix := oss.Prefix("audio/")
    //prefix := oss.Prefix("audio/00271621-ec5c-485c-a425-d31fffa62a77.amr")
    marker := oss.Marker("")
    for {
        lsRes, err := bucket.ListObjects(oss.MaxKeys(80), marker, prefix)
        if err != nil {
            fmt.Println("Error:", err)
            os.Exit(-1)
        }
        prefix = oss.Prefix(lsRes.Prefix)
        marker = oss.Marker(lsRes.NextMarker)
        // 打印结果。
        for _, object := range lsRes.Objects {
            //列举所有aac文件：audio/00005d64-783c-40da-8f90-05b534a2b353.aac
            objectName := object.Key
            if objectName != "audio/" && strings.Contains(objectName,".amr") {
                if object.LastModified.Format("20060102") != time.Now().Add(d).Format("20060102") {
                    println("跳过...")
                    continue
                }

                //fmt.Println("-Object:", objectName)
                objectNameSuffix := strings.Split(objectName,"/")[1]

                //判断是否有mp3文件，有点话就不下载了
                exists,err2 := bucket.IsObjectExist(strings.Replace(objectName,"amr","mp3",1))
                if err2 != nil {
                    fmt.Println("Error:", err)
                    os.Exit(-1)
                }
                if exists {
                    println(strings.Replace(objectName,"amr","mp3",1)+"在oss存在，不下载到本地.")
                }else{
                    // 下载文件到本地文件。
                    err = bucket.GetObjectToFile(objectName, todayFolder+objectNameSuffix,oss.Progress(&OssProgressListener{}))
                    if err != nil {
                        fmt.Println("Error:", err)
                        os.Exit(-1)
                    }
                    fmt.Println("Transfer Completed.")
                }



            }

        }

        if !lsRes.IsTruncated {
            break
        }
    }

}

转换处理

func convertToMp3(filenames ...string) error {
    var tofilename string
    fromfilename := filenames[0]

    switch len(filenames) {
    case 1:
        tofilename = filenames[0]
        break
    case 2:
        tofilename = filenames[1]
        break
    default:
        tofilename = filenames[0]
    }
    comm := exec.Command("ffmpeg", "-i", fromfilename+".amr", "-ar", AudioSamplingRateMP3, tofilename+".mp3")
    //判断mp3文件是否存在
    fileInfo,err1 := os.Stat(tofilename+".mp3")
    if fileInfo != nil && err1 == nil {
        println(tofilename+".mp3"+"文件存在，不转换...")
        return nil
    }else {
        println(fromfilename+".amr"+"转换....")
        if err := comm.Run(); err != nil {
            return err
        }
        println("=>"+tofilename+".mp3"+"转换成功。")
    }

    println("=>"+tofilename+".mp3"+"开始上传...")
    //上传本地文件。
    arr := strings.Split(tofilename,"/")
    fileName := arr[len(arr)-1]

    // 判断文件是否存在。
    isExist, err := bucket.IsObjectExist("audio/"+fileName+".mp3")
    if err != nil {
        fmt.Println("Error:", err)
        os.Exit(-1)
    }
    if isExist {
        println("audio/"+fileName+".mp3 文件存在,不上传.")
    }else {
        err1 = bucket.PutObjectFromFile("audio/"+fileName+".mp3", tofilename+".mp3",oss.Progress(&OssProgressListener{}))
        if err1 != nil {
            fmt.Println("Error:", err1)
            os.Exit(-1)
        }
        fmt.Println("upload Completed.")
    }



    return nil
}