- update mongo

const.go

@@ -1,6 +1,6 @@
 package gojobs
 
 const (
-	Version       = "1.0.99"
+	Version       = "1.0.100"
 	SpecifyIpNull = "0.0.0.0"
 )

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

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=

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)
 	}