新增商户号

services/task.go

@@ -23,9 +23,10 @@ func Task() {
 // 生产环境需要走的任务
 func releaseTask() {
 	//同步指标
-	syncHzDataIndex := task.NewTask("syncHzDataIndex", "0 30 0,18,21 * * *", SyncHzDataIndex)
-	task.AddTask("syncHzDataIndex", syncHzDataIndex)
-
+	if utils.BusinessCode != "E2023080900" {
+		syncHzDataIndex := task.NewTask("syncHzDataIndex", "0 30 0,18,21 * * *", SyncHzDataIndex)
+		task.AddTask("syncHzDataIndex", syncHzDataIndex)
+	}
 	// 定时统计交易所的持仓分析数据
 	initPositionTask := task.NewTask("initPositionTask", "0 0 1,19,22 * * *", data.InitPositionTask)
 	task.AddTask("initPositionTask", initPositionTask)

utils/config.go

@@ -34,6 +34,9 @@ var (
 	SECRET string
 )
 
+// BusinessCode 商家编码
+var BusinessCode string
+
 func init() {
 	tmpRunMode, err := web.AppConfig.String("run_mode")
 	if err != nil {
@@ -62,7 +65,8 @@ func init() {
 	}
 	beego.Info(RunMode + " 模式")
 	MYSQL_URL = config["mysql_url"]
-
+	// 商家编码
+	BusinessCode = config["business_code"]
 	// 系统类型
 	systemType, err := web.AppConfig.String("system_type")
 	if err != nil {