- retry 3 times in SendFilesToStores.

This commit is contained in:
gazebo
2018-11-01 09:22:08 +08:00
parent 3b1256876c
commit 541a61e953

View File

@@ -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)