Commit 6a34055c by Li Feifei

format project

parent 659d3987
Pipeline #15686 passed with stages
in 32 seconds
......@@ -173,6 +173,13 @@ func (f *ObtainFile) uploadPacked() error {
return oss.Upload(f.parser.splitUploadPath()+"packed.json", bytes.NewReader(packedBytes))
}
// 拼接下载zip包地址
func (f *ObtainFile) splitDownloadLink() string {
return fmt.Sprintf("%s?info=1&words=%v&ssl=1&furl=%s/%s",
ParserFileLink, f.pageCount, g.Cfg().GetString("oss.url"),
f.parser.dataPath())
}
// 进行解析上传操作
func (f *ObtainFile) Worker(err error) {
defer func() {
......@@ -192,12 +199,8 @@ func (f *ObtainFile) Worker(err error) {
}
g.Log().Async().Infof("file: %s file info complete", f.parser.name)
downloadZipLink := fmt.Sprintf("%s?info=1&words=%v&ssl=1&furl=%s/%s",
ParserFileLink, f.pageCount, g.Cfg().GetString("oss.url"),
f.parser.dataPath())
// 下载ZIP包
if err = http.Download(downloadZipLink, f.parser.splitTempZipLink()); err != nil {
if err = http.Download(f.splitDownloadLink(), f.parser.splitTempZipLink()); err != nil {
return
}
// 清理ZIP包
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment