删除同步完的记录

zhangqian

2023-10-17 f3a09ce0a6411d49303122d1d123863363e04acf

 crontask/cron_task.go

@@ -103,6 +103,7 @@
   if err != nil {
      logx.Errorf("SyncTaskStatus get records err:%v", err)
   }
   syncOkIds := make([]uint, 0, len(records))
   for _, record := range records {
      msg := &common.MsgTaskStatusUpdate{
         WorkOrderId:  record.WorkOrderId,
@@ -116,6 +117,13 @@
      if err != nil {
         logx.Errorf("sync task status send msg error:%v", err.Error())
      }
      syncOkIds = append(syncOkIds, record.ID)
   }
   if len(syncOkIds) > 0 {
      err = service.NewTaskService().RemoveTaskStatusSync(syncOkIds)
      if err != nil {
         logx.Errorf("sync task status delete sync ok records error:%v", err)
      }
   }
}