|
@@ -1,14 +1,15 @@
|
|
|
package main
|
|
|
|
|
|
import (
|
|
|
+ "log"
|
|
|
+ "strings"
|
|
|
+ "time"
|
|
|
+
|
|
|
"github.com/robfig/cron/v3"
|
|
|
"github.com/spf13/viper"
|
|
|
util "jygit.jydev.jianyu360.cn/data_processing/common_utils"
|
|
|
es "jygit.jydev.jianyu360.cn/data_processing/common_utils/elastic"
|
|
|
"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
|
|
|
- "log"
|
|
|
- "strings"
|
|
|
- "time"
|
|
|
)
|
|
|
|
|
|
var (
|
|
@@ -81,7 +82,7 @@ func Init() {
|
|
|
|
|
|
func main() {
|
|
|
Init()
|
|
|
- //dealAll() //存量数据
|
|
|
+ // dealAll() //存量数据
|
|
|
|
|
|
local, _ := time.LoadLocation("Asia/Shanghai")
|
|
|
c := cron.New(cron.WithLocation(local), cron.WithSeconds())
|
|
@@ -92,7 +93,7 @@ func main() {
|
|
|
|
|
|
c.Start()
|
|
|
defer c.Stop()
|
|
|
- //
|
|
|
+
|
|
|
select {}
|
|
|
}
|
|
|
|
|
@@ -115,8 +116,8 @@ func dealInc() {
|
|
|
func dealAll() {
|
|
|
where := map[string]interface{}{
|
|
|
"comeintime": map[string]interface{}{
|
|
|
- "$gte": 1718812800, //2021-06-20
|
|
|
- "$lt": 1721664000, //2021-07-23
|
|
|
+ "$gte": 1726070400,
|
|
|
+ "$lt": 1726156800,
|
|
|
},
|
|
|
}
|
|
|
|