95 lines
2.7 KiB
Swift
95 lines
2.7 KiB
Swift
//
|
||
// CommissionRateLogViewModel.swift
|
||
// suixinkan
|
||
//
|
||
|
||
import Foundation
|
||
|
||
/// 获客员分成比例修改记录 ViewModel，负责刷新、分页与重复项合并。
|
||
final class CommissionRateLogViewModel {
|
||
private enum Constants {
|
||
static let pageSize = 10
|
||
}
|
||
|
||
private(set) var items: [CommissionRateLogEntity] = []
|
||
private(set) var isRefreshing = false
|
||
private(set) var isLoadingMore = false
|
||
private(set) var initialLoading = true
|
||
private(set) var canLoadMore = false
|
||
|
||
var onStateChange: (() -> Void)?
|
||
var onShowMessage: ((String) -> Void)?
|
||
|
||
private let saleUserId: Int
|
||
private var total = 0
|
||
private var lastLoadedPage = 0
|
||
private var isLoading = false
|
||
|
||
init(saleUserId: Int) {
|
||
self.saleUserId = saleUserId
|
||
}
|
||
|
||
/// 重新加载第一页修改记录。
|
||
func refresh(api: OrderAPI) async {
|
||
await load(api: api, page: 1, append: false)
|
||
}
|
||
|
||
/// 在存在下一页时加载更多修改记录。
|
||
func loadMore(api: OrderAPI) async {
|
||
guard canLoadMore, !isRefreshing, !isLoadingMore else { return }
|
||
await load(api: api, page: lastLoadedPage + 1, append: true)
|
||
}
|
||
|
||
private func load(api: OrderAPI, page: Int, append: Bool) async {
|
||
guard saleUserId > 0 else {
|
||
initialLoading = false
|
||
onShowMessage?("获客员信息无效")
|
||
notifyStateChange()
|
||
return
|
||
}
|
||
guard !isLoading else { return }
|
||
isLoading = true
|
||
if append {
|
||
isLoadingMore = true
|
||
} else {
|
||
isRefreshing = true
|
||
}
|
||
notifyStateChange()
|
||
|
||
defer {
|
||
isLoading = false
|
||
initialLoading = false
|
||
if append {
|
||
isLoadingMore = false
|
||
} else {
|
||
isRefreshing = false
|
||
}
|
||
notifyStateChange()
|
||
}
|
||
|
||
do {
|
||
let response = try await api.saleUserCommissionRateLogs(
|
||
saleUserId: saleUserId,
|
||
page: page,
|
||
pageSize: Constants.pageSize
|
||
)
|
||
if append {
|
||
let existingIDs = Set(items.map(\.id))
|
||
items.append(contentsOf: response.list.filter { !existingIDs.contains($0.id) })
|
||
} else {
|
||
var seenIDs = Set<Int>()
|
||
items = response.list.filter { seenIDs.insert($0.id).inserted }
|
||
}
|
||
total = max(0, response.total)
|
||
lastLoadedPage = page
|
||
canLoadMore = items.count < total && !response.list.isEmpty
|
||
} catch {
|
||
onShowMessage?(error.localizedDescription)
|
||
}
|
||
}
|
||
|
||
private func notifyStateChange() {
|
||
onStateChange?()
|
||
}
|
||
}
|