1
// 根据周期过滤
2
if (period === "month") {
3
  const startOfMonth = dayjs().startOf("month").valueOf();
4
  where.createdAt = db.command.gte(startOfMonth);  // ❌ 使用错误的字段
5
}
6

7
const result = await this.paginateQuery<WeekArchive>(
8
  savingsWeekArchivesCollection,
9
  where,
10
  page,
11
  pageSize,
12
  [{ field: "createdAt", order: "desc" }],  // ❌ 普通查询
13
);

1
// 根据周期过滤（使用周结束时间作为过滤条件）
2
if (period === "month") {
3
  const startOfMonth = dayjs().startOf("month").valueOf();
4
  matchCondition.endDateTimestamp = db.command.gte(startOfMonth);  // ✅ 使用正确字段
5
}
6

7
// ✅ 使用聚合查询提升性能
8
const aggregateResult = await savingsWeekArchivesCollection
9
  .aggregate()
10
  .match(matchCondition)
11
  .sort({ endDateTimestamp: -1 })
12
  .skip(skip)
13
  .limit(pageSize)
14
  .project({
15
    _id: 0,
16
    weekId: 1,
17
    startDateTimestamp: 1,
18
    endDateTimestamp: 1,
19
    goalYuan: 1,
20
    actualSpentYuan: 1,
21
    savedYuan: 1,
22
    status: 1,
23
    savingPowerStats: 1,
24
  })
25
  .end();

1
private async addVirtualTransaction(
2
  userId: string,
3
  weekId: string,
4
  type: "deposit" | "withdraw",
5
  amountYuan: number,  // ❌ 不明确应该传正数还是负数
6
  description: string,
7
): Promise<void> {
8
  await savingsVirtualTransactionsCollection.add({
9
    data: {
10
      userId,
11
      weekId,
12
      type,
13
      amountYuan,  // ❌ 直接保存，依赖调用方处理正负
14
      description,
15
      createdAt: Date.now(),
16
    },
17
  });
18
}
19

20
// 调用示例（混乱）
21
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, "..."); // 传正数
22
await this.addVirtualTransaction(userId, weekId, "withdraw", -amount, "..."); // 传负数

1
/**
2
 * 添加虚拟交易
3
 * @param amountYuan 金额（始终传入正数，方法内部会根据type自动处理正负）
4
 */
5
private async addVirtualTransaction(
6
  userId: string,
7
  weekId: string,
8
  type: "deposit" | "withdraw",
9
  amountYuan: number,  // ✅ 明确约定：始终传入正数
10
  description: string,
11
): Promise<void> {
12
  // ✅ 确保金额为正数
13
  const absoluteAmount = Math.abs(amountYuan);
14

15
  // ✅ 根据类型决定存储的金额正负
16
  const storedAmount = type === "deposit" ? absoluteAmount : -absoluteAmount;
17

18
  await savingsVirtualTransactionsCollection.add({
19
    data: {
20
      userId,
21
      weekId,
22
      type,
23
      amountYuan: storedAmount,  // ✅ 统一由方法处理正负
24
      description,
25
      createdAt: Date.now(),
26
    },
27
  });
28
}
29

30
// 调用示例（统一）
31
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, "..."); // ✅ 传正数
32
await this.addVirtualTransaction(userId, weekId, "withdraw", amount, "..."); // ✅ 传正数

1
// ✅ 首次生成虚拟额度
2
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, `周结算储蓄 - ${weekId}`);
3

4
// ✅ 调整虚拟额度（增加或减少）
5
const adjustmentType = difference > 0 ? "deposit" : "withdraw";
6
const adjustmentAmount = Math.abs(difference);
7
await this.addVirtualTransaction(userId, weekId, adjustmentType, adjustmentAmount, description);
8

9
// ✅ 清零虚拟额度
10
await this.addVirtualTransaction(userId, weekId, "withdraw", previousAmount, `周结算储蓄清零 - ${weekId}`);

1
// ✅ 创建提取交易（传入正数，方法内部会转为负数）
2
await this.addVirtualTransaction(userId, weekId, "withdraw", amountYuan, reason);

1
// savingsWeekArchives 集合
2
db.savingsWeekArchives.createIndex({ userId: 1, endDateTimestamp: -1 })

1
// 查询本月的周归档
2
{
3
  "action": "savings.history",
4
  "period": "month",
5
  "page": 1,
6
  "pageSize": 10
7
}
8

9
// 查询本年的周归档
10
{
11
  "action": "savings.history",
12
  "period": "year",
13
  "page": 1,
14
  "pageSize": 20
15
}
16

17
// 查询所有周归档
18
{
19
  "action": "savings.history",
20
  "period": "week",
21
  "page": 1,
22
  "pageSize": 10
23
}

1
{
2
  "action": "savings.withdraw",
3
  "amountYuan": 100,
4
  "reason": "用于实际消费"
5
}