app-uploader/main.go

package main

import (
	"app-uploader/huawei"
	"app-uploader/utils"
	"bufio"
	"encoding/json"
	"fmt"
	"os"
	"path/filepath"
	"runtime"
	"strconv"
	"strings"
	"time"

	"github.com/jessevdk/go-flags"
)

var GAppOption = &AppOption{}
var obsBase = "http://spu3dv1.obs.cn-east-3.myhuaweicloud.com/pkg/"

// short只能是一个字符
type AppOption struct {
	Unzip string `short:"d" long:"unzip" description:"unzip file"`
}

func (o *AppOption) Parse() {
	_, err := flags.NewParser(o, flags.Default|flags.IgnoreUnknown).Parse()
	fmt.Println(err)
}

func main() {
	// 读取package.json版本数据
	// 复制app.json文件和logo文件
	// 读取配置
	// 解压工具 app-uploader.exe -d output/queenter-v1.1.2-amd64-windows.zip
	// !压缩后的文件在windows上用软件打开有问题,但在linux上解压或者unzip正常
	// utils.Unzip(zipPath,filepath.Base(zipFile),nil)
	GAppOption.Parse()
	if len(GAppOption.Unzip) > 0 {
		fileName := filepath.Base(GAppOption.Unzip)
		ext := filepath.Ext(fileName)
		fileDir := strings.TrimSuffix(fileName, ext)
		fmt.Println(GAppOption.Unzip)
		dest := fmt.Sprintf("%s/%s", filepath.Dir(GAppOption.Unzip), fileDir)
		fmt.Println("unzip dir:", dest)
		err := utils.Unzip(GAppOption.Unzip, dest, nil)
		if err != nil {
			fmt.Println("unzip err:", err)
			return
		}
		return
	}
	appConf, err := utils.ReadAppConfig()
	if err != nil {
		fmt.Println("读取配置文件错误")
		return
	}
	uploadConf, err := utils.ReadUpConf()
	if err != nil {
		fmt.Println("读取配置文件错误")
		return
	}

	if _, ok := uploadConf[appConf.Key]; !ok {
		fmt.Println("未找到该配置项")
		return
	}
	// 复制文件到对应目录
	dest := uploadConf[appConf.Key].Dest
	copyFiles := uploadConf[appConf.Key].Files
	modify := uploadConf[appConf.Key].Modify

	fmt.Println(uploadConf[appConf.Key])

	// 复制文件到目标目录中
	if len(copyFiles) > 0 {
		for _, file := range copyFiles {
			err := utils.Copy(file, fmt.Sprintf("%s/%s", dest, file))
			if err != nil {
				fmt.Println(err)
				return
			}
		}
	}

	// 获取版本信息
	version, err := utils.GetVersion()
	if err != nil {
		fmt.Println(err)
		return
	}
	appConf.Version = version
	appConfDest := fmt.Sprintf("%s/%s", dest, modify)
	err = utils.WriteAppConfig(appConf, appConfDest)
	if err != nil {
		fmt.Println(err)
		return
	}
	// 压缩文件
	// remoteswift-v1.0.0-x64-windows.zip
	zipFile := fmt.Sprintf("%s-v%s-%s-%s.zip", appConf.Key, version, runtime.GOARCH, runtime.GOOS)
	zipPath := fmt.Sprintf("output/%s", zipFile)
	fmt.Println("压缩文件中...")
	err = utils.Zip(zipPath, dest)
	if err != nil {
		fmt.Println("压缩文件出错")
		return
	}

	// 检测zip文件是否存在
	checkFile := fmt.Sprintf("%s%s", obsBase, zipFile)
	ok, err := utils.CheckZipExist(checkFile)
	if err != nil {
		fmt.Println(err)
		fmt.Println("检测打包文件失败")
	}
	isCover := true
	if ok {
		inputReader := bufio.NewReader(os.Stdin)
		fmt.Printf("obs已存在该zip文件,是否覆盖【%s】?\n覆盖-默认:【yes】,不覆盖【no】:", zipFile)
		input, err := inputReader.ReadString('\n')
		if err != nil {
			fmt.Println(err)
			return
		}
		switch input {
		case "yes\r\n":
			fmt.Println("上传中...")
		case "no\r\n":
			fmt.Println("取消上传")
			isCover = false
			time.Sleep(3 * time.Second)
			// !这里要不要直接退出,如果不需要上传则,后面的发布流程感觉不需要。所以这里直接退出
			return
		default:
			fmt.Println("上传中...")
		}

	}

	obsUrl := checkFile
	size, _ := strconv.Atoi(strings.Replace(appConf.Size, "MB", "", -1))
	if isCover {
		// 上传文件
		huawei.InitConfig()
		// http://spu3dv1.obs.cn-east-3.myhuaweicloud.com/pkg/lancher1.0.2.windows-amd64.zip
		obsDir := "pkg"
		obs, err := huawei.UploadFile(zipPath, obsDir, zipFile)

		if err != nil {
			fmt.Println(err)
			return
		}
		if len(obs.Url) < 1 {
			fmt.Println("上传zipfile错误")
			return
		}
		fmt.Println("succ uploaded=>", obs.Url)
		fmt.Println(obs.Size)
		size = int(obs.Size / (1024 * 1024))
		obsUrl = fmt.Sprintf("https:%s", obs.Url)

	}

	// 获取最新版本
	// 输出db文件
	outputDb := "output/db.json"
	// sizeM, err := strconv.Atoi(strings.Replace(appConf.Size, "MB", "", -1))
	// if err != nil {
	// 	fmt.Println("转换size string->int 错误:", err)

	// }
	// obsUrl := fmt.Sprintf("https:%s", obs.Url)

	fmt.Println("上传成功")

	// 是否发布
	inputReader := bufio.NewReader(os.Stdin)
	fmt.Printf("是否发布【%s】,version【%s】?\n发布-默认:【yes】,不发布【no】: ", appConf.Key, version)
	input, err := inputReader.ReadString('\n')
	if err != nil {
		fmt.Println(err)
		return
	}
	switch input {
	case "yes\r\nn":
		fmt.Println("发布中...")
	case "no\r\n":
		fmt.Println("取消发布")
		time.Sleep(3 * time.Second)
		return
	default:
		fmt.Println("发布中...")
	}

	// 获取对应应用配置
	// "platform": "windows-amd64",
	platform := fmt.Sprintf("%s-%s", runtime.GOOS, runtime.GOARCH)
	query := fmt.Sprintf("?name=%s&platform=%s", appConf.Key, platform)
	appVersion, err := utils.GetAppVersion(query)
	if err != nil {
		fmt.Println(err)
		fmt.Println("获取版本信息错误")
	}
	fmt.Println(appVersion)
	// 调用接口修改配置
	appVersion.Version = version
	appVersion.SizeM = float32(size)
	appVersion.Url = obsUrl
	data, err := json.Marshal(appVersion)
	if err != nil {
		fmt.Println("数据转换错误:", err)
		return
	}
	res, err := utils.PostJson(data)
	if err != nil {
		fmt.Println("更新version错误:", err)
		return
	}
	if res == "fail" {
		fmt.Println("更新version失败")
		return
	}

	if res == "succ" {
		fmt.Println("更新version成功")
		err = utils.WriteVersionDb(&utils.Version{
			Label:     appVersion.Label,
			Name:      appVersion.Name,
			Icon:      appVersion.Icon,
			Type:      appVersion.Type,
			Version:   appVersion.Version,
			SizeM:     int(appVersion.SizeM),
			Url:       appVersion.Url,
			Platform:  appVersion.Platform,
			Thumbnail: appVersion.Thumbnail,
			Desc:      appVersion.Desc,
			AppType:   appVersion.AppType,
			InstCount: appVersion.InstCount,
		}, outputDb)
		if err != nil {
			fmt.Println("写入output/db.json错误:", err)
			return
		}
		err = utils.WriteAppConfig(&utils.App{
			Name:           appConf.Name,
			Version:        appVersion.Version,
			LastUpdateDate: time.Now().Format("2006-01-02"),
			Icon:           appConf.Icon,
			RevAssets:      appConf.RevAssets,
			Size:           fmt.Sprintf("%fM", appVersion.SizeM),
			Tags:           appConf.Tags,
			Desc:           appVersion.Desc,
			Entry:          appConf.Entry,
			Type:           appVersion.AppType,
			Key:            appVersion.Name,
			InstCount:      appVersion.InstCount,
		}, "app.json")
		if err != nil {
			fmt.Println("更新app.json错误: ", err)
		}

		fmt.Println("输出文件目录=>: output")
		time.Sleep(3 * time.Second)
	}

}