From a2f2689d106a8153002e345a45af5e353d68ba92 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E5=85=89=E6=98=A5?= <gc@dtapp.net>
Date: Tue, 20 Sep 2022 15:13:27 +0800
Subject: [PATCH] - update mongo

---
 const.go |  2 +-
 go.mod   |  2 +-
 go.sum   |  4 ++--
 model.go | 12 +++---------
 4 files changed, 7 insertions(+), 13 deletions(-)

diff --git a/const.go b/const.go
index d3e4fc6..d7bc206 100644
--- a/const.go
+++ b/const.go
@@ -1,6 +1,6 @@
 package gojobs
 
 const (
-	Version       = "1.0.99"
+	Version       = "1.0.100"
 	SpecifyIpNull = "0.0.0.0"
 )
diff --git a/go.mod b/go.mod
index 673869f..44e5633 100644
--- a/go.mod
+++ b/go.mod
@@ -8,7 +8,7 @@ require (
 	github.com/robfig/cron/v3 v3.0.1
 	go.dtapp.net/dorm v1.0.38
 	go.dtapp.net/goip v1.0.36
-	go.dtapp.net/golog v1.0.86
+	go.dtapp.net/golog v1.0.87
 	go.dtapp.net/gostring v1.0.10
 	go.dtapp.net/gotime v1.0.5
 	go.dtapp.net/gotrace_id v1.0.6
diff --git a/go.sum b/go.sum
index 362c547..d5fd554 100644
--- a/go.sum
+++ b/go.sum
@@ -507,8 +507,8 @@ go.dtapp.net/dorm v1.0.38 h1:9OgWY5bnar6D0Xdho62xn7RluXJNe8i7Kz/IeSUObF4=
 go.dtapp.net/dorm v1.0.38/go.mod h1:z9ksZ4Y0HHH0odjEiG57d90/ZUBM51qXEWJC8fS+dEM=
 go.dtapp.net/goip v1.0.36 h1:+wexFCMnP3f+6jPYXjBLMyjnP+DfQrslWvXifndxkdc=
 go.dtapp.net/goip v1.0.36/go.mod h1:9/Oo1HVM4EVUsvAebdV6CaBAK4S6qQMQWT3LcJfH6jM=
-go.dtapp.net/golog v1.0.86 h1:XaWiu+gupSiMic9gA5gzrFMsGGYDMS8+lDlyndpjVNM=
-go.dtapp.net/golog v1.0.86/go.mod h1:SeAB/PPgwh+bVoG2TbDvWJtbPxvKImZCih1Un3SY9fA=
+go.dtapp.net/golog v1.0.87 h1:mueYl2NEf28rt9z0AgI7SvdLaqc88VdQVnjgQKon0ps=
+go.dtapp.net/golog v1.0.87/go.mod h1:SeAB/PPgwh+bVoG2TbDvWJtbPxvKImZCih1Un3SY9fA=
 go.dtapp.net/gorandom v1.0.1 h1:IWfMClh1ECPvyUjlqD7MwLq4mZdUusD1qAwAdsvEJBs=
 go.dtapp.net/gorandom v1.0.1/go.mod h1:ZPdgalKpvFV/ATQqR0k4ns/F/IpITAZpx6WkWirr5Y8=
 go.dtapp.net/gorequest v1.0.31 h1:r/OoU5Y00TbJjkQtpvwjsb/pllqO0UQQjFRY1veZYZc=
diff --git a/model.go b/model.go
index 1a4d800..a094e58 100644
--- a/model.go
+++ b/model.go
@@ -40,7 +40,7 @@ func (c *Client) MongoTaskLogDelete(ctx context.Context, hour int64) (*mongo.Del
 
 // 创建时间序列集合
 func (c *Client) mongoCreateCollectionTaskLog(ctx context.Context) {
-	err := c.mongoClient.Db.Database(c.mongoConfig.databaseName).CreateCollection(ctx, jobs_mongo_model.TaskLog{}.CollectionName(), options.CreateCollection().SetTimeSeriesOptions(options.TimeSeries().SetTimeField("log_time")))
+	err := c.mongoClient.Database(c.mongoConfig.databaseName).CreateCollection(ctx, jobs_mongo_model.TaskLog{}.CollectionName(), options.CreateCollection().SetTimeSeriesOptions(options.TimeSeries().SetTimeField("log_time")))
 	if err != nil {
 		c.zapLog.WithTraceId(ctx).Sugar().Errorf("创建时间序列集合：%s", err)
 	}
@@ -50,16 +50,10 @@ func (c *Client) mongoCreateCollectionTaskLog(ctx context.Context) {
 func (c *Client) mongoCreateIndexesTaskLog(ctx context.Context) {
 	indexes, err := c.mongoClient.Database(c.mongoConfig.databaseName).Collection(jobs_mongo_model.TaskLog{}.CollectionName()).CreateManyIndexes(ctx, []mongo.IndexModel{{
 		Keys: bson.D{{
-			Key:   "task_id",
-			Value: 1,
-		}},
-	}, {
-		Keys: bson.D{{
-			Key:   "task_result_code",
+			Key:   "log_time",
 			Value: -1,
 		}},
-	},
-	})
+	}})
 	if err != nil {
 		c.zapLog.WithTraceId(ctx).Sugar().Errorf("创建索引：%s", err)
 	}