|
|
@@ -24,11 +24,10 @@ func InitTriggerConfig() {
|
|
|
// 3 对比触发器列表，本地没有的则下载
|
|
|
for _, trigger := range *cloudTriggers {
|
|
|
id := util.ToString(trigger.TriggerId)
|
|
|
- var triggerLocalPath string
|
|
|
- triggerLocalDir := config.CloudConfig.TriggersDir + id + "/"
|
|
|
- _ = util.CreateParentDir(triggerLocalPath)
|
|
|
hasIdDir, _ := util.ContainsElement(localTriggerIds, id)
|
|
|
+ triggerLocalDir := config.CloudConfig.TriggersDir + id + "/"
|
|
|
hasLabelSo, soPaths := util.CheckSoFilesInDirectory(triggerLocalDir)
|
|
|
+ var triggerLocalPath string
|
|
|
if hasIdDir && hasLabelSo { // 已存在的触发器不需要再次下载
|
|
|
triggerLocalPath = soPaths[0]
|
|
|
c_log.GlobalLogger.Info("触发器插件从 ", triggerLocalPath, " 存在。")
|
|
|
@@ -39,6 +38,7 @@ func InitTriggerConfig() {
|
|
|
triggerLocalPath = config.CloudConfig.TriggersDir + id + "/" + label + ".so"
|
|
|
c_log.GlobalLogger.Info("下载触发器插件从 ", trigger.TriggerScriptPath, " 到 ", triggerLocalPath)
|
|
|
config.OssMutex.Lock()
|
|
|
+ _ = util.CreateParentDir(triggerLocalPath)
|
|
|
err := config.OssBucket.GetObjectToFile(trigger.TriggerScriptPath, triggerLocalPath)
|
|
|
config.OssMutex.Unlock()
|
|
|
if err != nil {
|
