日志添加

jyBXSubscribe/rpc/model/push.go

@@ -388,6 +388,7 @@ func (s *subscribePush) Datas(spqp *SubPushQueryParam) (hasNextPage bool, total
 }
 
 func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, endtime int64, size int, isLimit bool) (result []*bxsubscribe.SubscribeInfo, count int64) {
+	start := time.Now().Unix()
 	querys := []string{}
 	userStr := " 1=1  "
 	var (
@@ -660,6 +661,8 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
 	}
 	logx.Info(spqp.NewUserId, "subscribePush query sql：", findSql)
 	list := spqp.BaseServiceMysql.SelectBySql(findSql)
+	end1 := time.Now().Unix()
+	log.Println("mysql查询用时:", end1-start)
 	if list != nil && len(*list) > 0 {
 		pushCas := s.GetJyPushs(*list)
 		if !spqp.Export {
@@ -670,6 +673,9 @@ func (s *subscribePush) getDatasFromMysql(spqp *SubPushQueryParam, starttime, en
 	} else {
 		result = []*bxsubscribe.SubscribeInfo{}
 	}
+	end2 := time.Now().Unix()
+	log.Println("处理数据用时:", end2-end1)
+	log.Println("总用时用时:", end2-start)
 	return
 }