diff --git a/FOOT000.go b/FOOT000.go index 4c1f2d4dca3232b771ab835ce8510d836707e81a..7541a8961393102b65bb3ef6db5fc04589e7dcfb 100644 --- a/FOOT000.go +++ b/FOOT000.go @@ -13,6 +13,7 @@ import ( "tesou.io/platform/foot-parent/foot-core/module/leisu/constants" "tesou.io/platform/foot-parent/foot-core/module/leisu/service" "tesou.io/platform/foot-parent/foot-core/module/leisu/utils" + service3 "tesou.io/platform/foot-parent/foot-core/module/match/service" "tesou.io/platform/foot-parent/foot-core/module/wechat/controller" "tesou.io/platform/foot-parent/foot-spider/launch" "time" @@ -111,7 +112,7 @@ func main() { case "auto\n", "auto": go func() { for { - base.Log.Info("--------数据更新开始运行--------") + base.Log.Info("--------全量数据更新开始运行--------") //1.安装数据库 //2.配置好数据库连接,打包程序发布 //3.程序执行流程,周期定制定为一天三次 @@ -122,7 +123,14 @@ func main() { //3.2 FC002AnalyApplication 分析得出推荐列表 launch2.Analy() configService := new(service2.ConfService) - base.Log.Info("--------数据更新周期结束--------") + base.Log.Info("--------全量数据更新周期结束--------") + + base.Log.Info("--------全量比赛发布公众号开始运行--------") + //3.3 FW001PubApplication 执行发布到雷速 + materialController := new(controller.MaterialController) + materialController.ModifyNewsOnly() + base.Log.Info("--------全量临场比赛发布公众号周期结束--------") + time.Sleep(time.Duration(configService.GetSpiderCycleTime()) * time.Minute) } }() @@ -137,18 +145,20 @@ func main() { // } //}() for { - base.Log.Info("--------临场比赛数据更新开始运行--------") - launch.Spider_Near() - launch2.Analy_Near() - base.Log.Info("--------临场比赛数据更新周期结束--------") - - base.Log.Info("--------发布公众号开始运行--------") - //3.3 FW001PubApplication 执行发布到雷速 - materialController := new(controller.MaterialController) - materialController.ModifyNewsOnly() - base.Log.Info("--------发布公众号周期结束--------") - + matchLastService := new(service3.MatchLastService) + matchLasts := matchLastService.FindNear() + if len(matchLasts) > 0 { + base.Log.Info("--------临场比赛数据更新开始运行--------") + launch.Spider_Near() + launch2.Analy_Near() + base.Log.Info("--------临场比赛数据更新周期结束--------") + base.Log.Info("--------临场比赛发布公众号开始运行--------") + //3.3 FW001PubApplication 执行发布到雷速 + materialController := new(controller.MaterialController) + materialController.ModifyNewsOnly() + base.Log.Info("--------临场比赛发布公众号周期结束--------") + } time.Sleep(5 * time.Minute) } diff --git a/FOOT000Cmd.go b/FOOT000Cmd.go index c9c0489d273e3e98b861f4f5819ea8c72611de30..b02cb792e081bf2eae073d707f3bf3f4b9479279 100644 --- a/FOOT000Cmd.go +++ b/FOOT000Cmd.go @@ -13,6 +13,7 @@ import ( "tesou.io/platform/foot-parent/foot-core/module/leisu/constants" "tesou.io/platform/foot-parent/foot-core/module/leisu/service" "tesou.io/platform/foot-parent/foot-core/module/leisu/utils" + service3 "tesou.io/platform/foot-parent/foot-core/module/match/service" "tesou.io/platform/foot-parent/foot-core/module/wechat/controller" "tesou.io/platform/foot-parent/foot-spider/launch" "time" @@ -125,10 +126,9 @@ HEAD: }() goto HEAD case "auto\n", "auto\r\n": - //赔率全量更新 go func() { for { - base.Log.Info("--------数据更新开始运行--------") + base.Log.Info("--------全量数据更新开始运行--------") //1.安装数据库 //2.配置好数据库连接,打包程序发布 //3.程序执行流程,周期定制定为一天三次 @@ -139,35 +139,17 @@ HEAD: //3.2 FC002AnalyApplication 分析得出推荐列表 launch2.Analy() configService := new(service2.ConfService) - base.Log.Info("--------数据更新周期结束--------") + base.Log.Info("--------全量数据更新周期结束--------") - base.Log.Info("--------发布公众号开始运行--------") + base.Log.Info("--------全量比赛发布公众号开始运行--------") //3.3 FW001PubApplication 执行发布到雷速 materialController := new(controller.MaterialController) materialController.ModifyNewsOnly() - base.Log.Info("--------发布公众号周期结束--------") + base.Log.Info("--------全量临场比赛发布公众号周期结束--------") time.Sleep(time.Duration(configService.GetSpiderCycleTime()) * time.Minute) } }() - //对当前即时进行的比赛,或正在进行的比赛进行,赔率更新 - go func() { - for { - base.Log.Info("--------临场比赛数据更新开始运行--------") - launch.Spider_Near() - launch2.Analy_Near() - base.Log.Info("--------临场比赛数据更新周期结束--------") - - base.Log.Info("--------发布公众号开始运行--------") - //3.3 FW001PubApplication 执行发布到雷速 - materialController := new(controller.MaterialController) - materialController.ModifyNewsOnly() - base.Log.Info("--------发布公众号周期结束--------") - - - time.Sleep(5 * time.Minute) - } - }() //go func() { // for { // base.Log.Info("--------发布开始运行--------") @@ -178,6 +160,25 @@ HEAD: // time.Sleep(time.Duration(pubService.CycleTime()) * time.Minute) // } //}() + go func() { + for { + matchLastService := new(service3.MatchLastService) + matchLasts := matchLastService.FindNear() + if len(matchLasts) > 0 { + base.Log.Info("--------临场比赛数据更新开始运行--------") + launch.Spider_Near() + launch2.Analy_Near() + base.Log.Info("--------临场比赛数据更新周期结束--------") + + base.Log.Info("--------临场比赛发布公众号开始运行--------") + //3.3 FW001PubApplication 执行发布到雷速 + materialController := new(controller.MaterialController) + materialController.ModifyNewsOnly() + base.Log.Info("--------临场比赛发布公众号周期结束--------") + } + time.Sleep(5 * time.Minute) + } + }() goto HEAD default: goto HEAD