小程序开发日记④：消息推送与消息中心

1
const messages = ref([])
2
const pageNum = ref(1)
3
const pageSize = 20
4
const total = ref(0)
5
const loading = ref(false)
6
const loadingMore = ref(false)
7
const hasMore = computed(() => messages.value.length < total.value)

1
async function load(reset = false) {
2
  if (loading.value || loadingMore.value) return
3
  if (!reset && !hasMore.value) return
4

5
  const targetPage = reset ? 1 : pageNum.value + 1
6
  reset ? loading.value = true : loadingMore.value = true
7
  // 请求并合并
8
}

1
<scroll-view
2
  scroll-y
3
  refresher-enabled
4
  :refresher-triggered="refreshing"
5
  @refresherrefresh="refreshMessages"
6
  @scrolltolower="loadMore"
7
>

1
const merged = new Map()
2
;(reset ? rows : messages.value.concat(rows)).forEach(item => {
3
  merged.set(String(item.notificationId), item)
4
})
5
messages.value = [...merged.values()].sort(sortBySendTimeDesc)

1
const locallyReadIds = ref(new Set(uni.getStorageSync('readNotificationIds') || []))
2

3
function markMessageRead(id) {
4
  locallyReadIds.value.add(String(id))
5
  uni.setStorageSync('readNotificationIds', [...locallyReadIds.value])
6
}

1
while ((page - 1) * pageSize < total) {
2
  const response = await getNotificationList({ pageNum: page, pageSize: 100 })
3
  const found = response.rows.find(item => String(item.notificationId) === targetId)
4
  if (found) return found
5
  total = Number(response.total)
6
  page += 1
7
}