Эх сурвалжийг харах

添加环境变量配置,根据配置 动态执行定时任务

wcc 2 жил өмнө
parent
commit
13e91646eb

+ 3 - 0
createEsIndex/common.toml

@@ -77,6 +77,9 @@ send = false
 to = "wangjianghan@topnet.net.cn"
 api = "http://172.17.145.179:19281/_send/_mail"
 
+[env]
+    stype = 1 ## 默认0 正式环境;1测试环境。测试环境不会执行定时任务更新采购单位、中标单位、数据检测
+
 # 日志
 [log]
 # 日志路径,为空将输出控制台

+ 6 - 0
createEsIndex/config/conf.go

@@ -28,6 +28,7 @@ type conf struct {
 	Udp  udp
 	Mail mail
 	Log  log
+	Env  env
 }
 
 type udp struct {
@@ -93,6 +94,11 @@ type mgo struct {
 	Password string
 }
 
+//env 全局的相关配置
+type env struct {
+	Stype int //默认0,正式环境;1是测试环境,不会执行定时任务更新采购单位、中标单位、数据检测
+}
+
 type es struct {
 	Addr         string
 	AddrP        string

+ 6 - 4
createEsIndex/main.go

@@ -77,9 +77,12 @@ func init() {
 }
 
 func main() {
-
-	go checkMapJob() //udp 发送邮件
-	go task_index()  //定时同步更新winner_enterprise、buyer_enterprise ES索引;这个功能很少变动,几乎不需要维护
+	//正式环境才执行定时任务
+	if config.Conf.Env.Stype == 0 {
+		go LastUdpJob()  //监听半小时内有无数据
+		go checkMapJob() //udp 发送邮件
+		go task_index()  //定时同步更新winner_enterprise、buyer_enterprise ES索引;这个功能很少变动,几乎不需要维护
+	}
 
 	go UpdateBidding() //更新bidding表数据
 	go SaveEsMethod()
@@ -87,7 +90,6 @@ func main() {
 	go SaveProjectEs()
 
 	go SaveBidErr()
-	go LastUdpJob() //监听半小时内有无数据
 
 	UdpClient = udp.UdpClient{Local: config.Conf.Udp.LocPort, BufSize: 1024}
 	UdpClient.Listen(processUdpMsg)