Merge branch 'v1.0.1_ws' of moapp/jy_docs into feature/v1.0.1

rpc/partnerlib/crontab/handle/ticker.go

@@ -42,7 +42,7 @@ func CrontabByTicker(ctx context.Context, cron config.Cron, f func(cron config.C
 		g.Log().Info(ctx, "----------------------end-------------当前时间：", time.Now().Format(date.Date_Full_Layout))
 	}, cron.Name)
 	if err != nil {
-		g.Log().Info(ctx, fmt.Sprintf("%s定时任务异常", "----"))
+		g.Log().Info(ctx, fmt.Sprintf("%s定时任务异常,err:%s", "----", err.Error()))
 	}
 	//首次运行
 	if cron.First {

rpc/partnerlib/etc/crontab.yaml

@@ -1,7 +1,7 @@
 IsRun: false
 NewDocsList:
   Name: syncDocs
-  First: false
+  First: true
   Time: "0 0 0/4 * * ?"
   StartId: 0
   StartIdKey: docin_sync_start_id

services/partner/elastic.go

@@ -9,7 +9,7 @@ import (
 func SyncDocsToES(docs []map[string]interface{}) {
 	//jyDocsRpcUtil.GetESV7DB().Save(entity.ElasticJYDoc, entity.ElasticJYDoc, docs[0])
 	if len(docs) > 0 {
-		jyDocsRpcUtil.GetESV7DB().BulkSave(entity.ElasticJYDoc, entity.ElasticJYDoc, &docs, false)
+		jyDocsRpcUtil.GetESV7DB().BulkSave(entity.ElasticJYDoc, entity.ElasticJYDoc, &docs, true)
 	}
 	return
 }