Penny Lens 储蓄功能修复日志

// 根据周期过滤
if (period === "month") {
  const startOfMonth = dayjs().startOf("month").valueOf();
  where.createdAt = db.command.gte(startOfMonth);  // ❌ 使用错误的字段
}
 
const result = await this.paginateQuery<WeekArchive>(
  savingsWeekArchivesCollection,
  where,
  page,
  pageSize,
  [{ field: "createdAt", order: "desc" }],  // ❌ 普通查询
);

// 根据周期过滤（使用周结束时间作为过滤条件）
if (period === "month") {
  const startOfMonth = dayjs().startOf("month").valueOf();
  matchCondition.endDateTimestamp = db.command.gte(startOfMonth);  // ✅ 使用正确字段
}
 
// ✅ 使用聚合查询提升性能
const aggregateResult = await savingsWeekArchivesCollection
  .aggregate()
  .match(matchCondition)
  .sort({ endDateTimestamp: -1 })
  .skip(skip)
  .limit(pageSize)
  .project({
    _id: 0,
    weekId: 1,
    startDateTimestamp: 1,
    endDateTimestamp: 1,
    goalYuan: 1,
    actualSpentYuan: 1,
    savedYuan: 1,
    status: 1,
    savingPowerStats: 1,
  })
  .end();

private async addVirtualTransaction(
  userId: string,
  weekId: string,
  type: "deposit" | "withdraw",
  amountYuan: number,  // ❌ 不明确应该传正数还是负数
  description: string,
): Promise<void> {
  await savingsVirtualTransactionsCollection.add({
    data: {
      userId,
      weekId,
      type,
      amountYuan,  // ❌ 直接保存，依赖调用方处理正负
      description,
      createdAt: Date.now(),
    },
  });
}
 
// 调用示例（混乱）
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, "..."); // 传正数
await this.addVirtualTransaction(userId, weekId, "withdraw", -amount, "..."); // 传负数

/**
 * 添加虚拟交易
 * @param amountYuan 金额（始终传入正数，方法内部会根据type自动处理正负）
 */
private async addVirtualTransaction(
  userId: string,
  weekId: string,
  type: "deposit" | "withdraw",
  amountYuan: number,  // ✅ 明确约定：始终传入正数
  description: string,
): Promise<void> {
  // ✅ 确保金额为正数
  const absoluteAmount = Math.abs(amountYuan);
  
  // ✅ 根据类型决定存储的金额正负
  const storedAmount = type === "deposit" ? absoluteAmount : -absoluteAmount;
 
  await savingsVirtualTransactionsCollection.add({
    data: {
      userId,
      weekId,
      type,
      amountYuan: storedAmount,  // ✅ 统一由方法处理正负
      description,
      createdAt: Date.now(),
    },
  });
}
 
// 调用示例（统一）
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, "..."); // ✅ 传正数
await this.addVirtualTransaction(userId, weekId, "withdraw", amount, "..."); // ✅ 传正数

// ✅ 首次生成虚拟额度
await this.addVirtualTransaction(userId, weekId, "deposit", savedYuan, `周结算储蓄 - ${weekId}`);
 
// ✅ 调整虚拟额度（增加或减少）
const adjustmentType = difference > 0 ? "deposit" : "withdraw";
const adjustmentAmount = Math.abs(difference);
await this.addVirtualTransaction(userId, weekId, adjustmentType, adjustmentAmount, description);
 
// ✅ 清零虚拟额度
await this.addVirtualTransaction(userId, weekId, "withdraw", previousAmount, `周结算储蓄清零 - ${weekId}`);

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