品种同步

models/config/permission.go

@@ -29,9 +29,8 @@ func BatchInsertOrUpdate(list []Permission) (err error) {
 	db := models.Main()
 	OnConflictFunc := clause.OnConflict{
 		Columns:   []clause.Column{{Name: "permission_id"}},
-		DoUpdates: clause.AssignmentColumns([]string{"name", "status", "deleted"}),
+		DoUpdates: clause.AssignmentColumns([]string{"name", "parent_id", "sort"}),
 	}
-
 	// 执行批量插入或更新操作
 	err = db.Clauses(OnConflictFunc).Create(&list).Error
 	return

task/eta/permission/eta_permission_task.go

@@ -11,7 +11,7 @@ import (
 
 var (
 	taskName base.TaskType = "ETAPermissionSyncTask"
-	cron                   = "0/60 * * * * *"
+	cron                   = "0/10 * * * * *"
 )
 
 // Execute Task ETA取研报的数据
@@ -34,11 +34,11 @@ func (pr *PermissionTask) Execute(taskDetail *base.TaskDetail) error {
 		}
 		err = configService.SyncPermission(permissionDTOList)
 		if err != nil {
-			logger.Error("同步ETA研报列表失败：%v", err)
+			logger.Error("同步ETA品种列表失败：%v", err)
 			return err
 		}
 	}
-	logger.Info(contants.TaskFormat, "同步ETA作者结束")
+	logger.Info(contants.TaskFormat, "同步ETA品种结束")
 	return nil
 }
 

task/task_starter.go

@@ -5,6 +5,7 @@ import (
 	"eta/eta_mini_ht_api/common/contants"
 	"eta/eta_mini_ht_api/task/base"
 	_ "eta/eta_mini_ht_api/task/eta/author"
+	_ "eta/eta_mini_ht_api/task/eta/permission"
 	_ "eta/eta_mini_ht_api/task/message"
 	_ "eta/eta_mini_ht_api/task/report"
 	_ "eta/eta_mini_ht_api/task/sms"
@@ -14,7 +15,6 @@ import (
 
 func AddTasksToScheduler() {
 	for _, t := range base.GetTasks() {
-		//if t.RunMode == web.BConfig.RunMode {
 		if needAddTask(t.RunMode, web.BConfig.RunMode) {
 			tk := task.NewTask(string(t.Name), t.Cron, t.Run)
 			task.AddTask(string(t.Name), tk)