暂停聚集模型

zhaoqingang

2025-02-19 fca319958029fa924308e50cb61202d7d6ff5008

 models/accessRegularity.go

@@ -106,11 +106,14 @@
   // 查找指定时间范围内出行过的档案编号
   now := time.Now()
   startDate := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location()).AddDate(0, 0, -m.Duration)
   endDate := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, now.Location())

   err := db.GetDB().Raw(`
      SELECT
         document_number,
         frequent_address,
         community_id
         community_id,
         org_id
      FROM
         snapshot_count_summary
      WHERE
@@ -125,10 +128,11 @@

   logger.Debugf("task %s base filter result %d", m.Task.Name, len(baseFilter))
   esCli := db.GetEsClient()
   // 调用es分析此人的出行规律是否符合条件， 返回符合条件的次数和最后一次符合条件的时间
   sTime := startDate.Format(time.DateTime)
   eTime := endDate.Format(time.DateTime)

   for _, p := range baseFilter {
      // 调用es分析此人的出行规律是否符合条件， 返回符合条件的次数和最后一次符合条件的时间
      sTime := startDate.Format(time.DateTime)
      eTime := time.Now().Format(time.DateTime)
      captures, err := service.QueryEsRecord(esCli, sTime, eTime, nil, []interface{}{p.CommunityId}, []string{p.DocumentNumber})
      //logger.Debugf("task %s person %s captures %d", m.Task.Name, p.DocumentNumber, len(captures))

@@ -144,7 +148,7 @@
         // 写数据库
         result := &db.ModelTaskResults{
            Title:         m.Task.Name,
            Event:         fmt.Sprintf("%s %d次", m.Task.Name, hitCount),
            Event:         fmt.Sprintf("%s - %s 时间段内, %s %d次", sTime, eTime, m.Task.Name, hitCount),
            ModelID:       m.Task.ModelID,
            ModelTaskID:   m.Task.ID,
            CommunityId:   p.CommunityId,
@@ -170,7 +174,7 @@

func (m *RegularityModel) Shutdown() error {
   // 清理资源
   fmt.Println("Shutting down LocationModel Model")
   fmt.Println("Shutting down accessRegularityS Model")
   return nil
}

@@ -192,7 +196,7 @@

   for _, record := range records {
      // 解析时间
      t, err := time.Parse(layout, record.PicDate)
      t, err := time.ParseInLocation(layout, record.PicDate, time.Local)
      if err != nil {
         fmt.Println("解析时间失败:", err)
         continue