|
@@ -1876,7 +1876,7 @@ func RefreshDataFromComTrade(wg *sync.WaitGroup) (err error) {
|
|
|
//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromGl ErrMsg:"+err.Error(), utils.EmailSendToUsers)
|
|
|
go alarm_msg.SendAlarmMsg("RefreshDataFromComTrade ErrMsg:"+err.Error(), 3)
|
|
|
}
|
|
|
- //wg.Done()
|
|
|
+ wg.Done()
|
|
|
}()
|
|
|
var condition string
|
|
|
var pars []interface{}
|
|
@@ -1922,7 +1922,7 @@ func RefreshDataFromSci(wg *sync.WaitGroup) (err error) {
|
|
|
//go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromGl ErrMsg:"+err.Error(), utils.EmailSendToUsers)
|
|
|
go alarm_msg.SendAlarmMsg("RefreshDataFromSci ErrMsg:"+err.Error(), 3)
|
|
|
}
|
|
|
- //wg.Done()
|
|
|
+ wg.Done()
|
|
|
}()
|
|
|
var condition string
|
|
|
var pars []interface{}
|