From 541a61e9535d56ddeacbe40c012d3c5e2b7a7e73 Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 1 Nov 2018 09:22:08 +0800 Subject: [PATCH] - retry 3 times in SendFilesToStores. --- business/jxstore/financial/financial.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/business/jxstore/financial/financial.go b/business/jxstore/financial/financial.go index e8ed85628..db30cdd30 100644 --- a/business/jxstore/financial/financial.go +++ b/business/jxstore/financial/financial.go @@ -62,9 +62,12 @@ func SendFilesToStores(ctx *jxcontext.Context, files []*multipart.FileHeader, is ret := storage.PutRet{} key := "storeBill_" + utils.Int2Str(storeID) + "_" + strings.ToLower(utils.GetUUID()) + path.Ext(fileHeader.Filename) formUploader := storage.NewFormUploader(cfg) - err = formUploader.Put(context.Background(), &ret, upToken, key, file, fileHeader.Size, nil) + for i := 0; i < 3; i++ { + if err = formUploader.Put(context.Background(), &ret, upToken, key, file, fileHeader.Size, nil); err == nil { + break + } + } file.Close() - globals.SugarLogger.Debugf("SendFilesToStores upload file:%s error:%v", fileHeader.Filename, err) if err == nil { db := dao.GetDB() billRec := &legacymodel.StoreBill{ @@ -75,8 +78,11 @@ func SendFilesToStores(ctx *jxcontext.Context, files []*multipart.FileHeader, is } if err = dao.CreateEntity(db, billRec); err == nil { err = weixinmsg.NotifySaleBill(storeID, "http://www2.jxc4.com/jx/public/index.php/jd/excel/index?path="+billRec.Url) - globals.SugarLogger.Debugf("SendFilesToStores NotifySaleBill file:%s error:%v", fileHeader.Filename, err) + } else { + globals.SugarLogger.Warnf("SendFilesToStores CreateEntity file:%s error:%v", fileHeader.Filename, err) } + } else { + globals.SugarLogger.Warnf("SendFilesToStores file:%s failed with error:%v", fileHeader.Filename, err) } } else { globals.SugarLogger.Warnf("SendFilesToStores open file:%s failed with error:%v", fileHeader.Filename, err)