簡介本資源是一套基于.NET框架與C#語言開發(fā)的積分消費系統(tǒng)完整源碼面向需要構(gòu)建會員積分管理功能的中初級.NET開發(fā)者與課程設(shè)計學(xué)習(xí)者。系統(tǒng)采用ASP.NET MVC分層架構(gòu)配合SQL Server數(shù)據(jù)庫與ADO.NET數(shù)據(jù)訪問技術(shù)涵蓋用戶管理、積分獲取、積分消費、積分查詢、積分規(guī)則配置及操作日志記錄等核心模塊前端以HTML、CSS、JavaScript結(jié)合jQuery實現(xiàn)交互。壓縮包共約2000個文件包含206個cs源碼、181個aspx頁面、145個js腳本、70個css樣式及968個gif、302個png等界面素材另有46個dll依賴庫與數(shù)據(jù)庫文件整體約38.97MB目錄按Model、DBUtility、WebUI等分層組織結(jié)構(gòu)清晰便于二次開發(fā)。目前已有72人學(xué)習(xí)下載適合作為積分系統(tǒng)設(shè)計參考、畢業(yè)設(shè)計原型或企業(yè)積分模塊的起步框架。1. 從一份 .rar 說起.NET 積分消費系統(tǒng)到底在解決什么問題商場會員卡里躺著幾千積分顧客到店消費時收銀臺卻查不到余額運營做了一場雙倍積分活動第二天財務(wù)對賬發(fā)現(xiàn)流水對不上門店斷網(wǎng)了積分核銷直接卡死。這些場景背后幾乎都指向同一類系統(tǒng)——基于 .NET 的積分消費系統(tǒng)。它要干的事很樸素把「積分發(fā)放、積分扣減、消費核銷、流水追溯」這四件事做成一套能扛住并發(fā)、能對賬、能離線兜底的服務(wù)端程序。標(biāo)題里那串net積分消費系統(tǒng).rar_.net_net積分消費系統(tǒng)_積分 系統(tǒng)_系統(tǒng)_系統(tǒng) net c#看著像壓縮包被反復(fù)重命名后的殘留但核心信息很清楚.NET 技術(shù)棧、C# 語言、積分消費業(yè)務(wù)。適合誰看正在用 C# 做會員/營銷中臺的后端或者手里拿到一份積分系統(tǒng)源碼卻不知道怎么跑起來、怎么改、怎么上生產(chǎn)的工程師。下面按「業(yè)務(wù)模型怎么立 → 數(shù)據(jù)庫怎么設(shè)計 → 核心扣減怎么防超賣 → 對賬怎么查 → 坑在哪」這條線走一遍能直接抄的部分我都給代碼。2. 積分消費系統(tǒng)的業(yè)務(wù)模型與數(shù)據(jù)庫落地先想清楚積分不是錢2.1 積分和余額的本質(zhì)區(qū)別決定了表結(jié)構(gòu)很多人第一反應(yīng)是把積分當(dāng)錢存一張User表加個Points字段就開干。這是后面所有對賬災(zāi)難的源頭。積分和現(xiàn)金余額有三個本質(zhì)差異第一積分有有效期過期要清零錢不會第二積分有來源是消費返的還是活動送的來源不同可能退的時候規(guī)則不同第三積分變動必須可追溯任何一筆扣減都要能回答「什么時候、因為哪筆訂單、扣了多少、扣完剩多少」。所以正確的做法是「賬戶表 流水表」雙表結(jié)構(gòu)賬戶表存當(dāng)前可用余額快照流水表存每一筆變動事實。余額永遠(yuǎn)可以由流水重算出來這就是你的后悔藥。-- 積分賬戶表一個用戶一條存快照 CREATE TABLE MemberPointsAccount ( MemberId BIGINT NOT NULL PRIMARY KEY, AvailablePoints INT NOT NULL DEFAULT 0, -- 當(dāng)前可用積分 FrozenPoints INT NOT NULL DEFAULT 0, -- 凍結(jié)積分下單未支付時占用 TotalEarned INT NOT NULL DEFAULT 0, -- 累計獲得用于等級計算 RowVersion ROWVERSION NOT NULL, -- 樂觀鎖版本號 UpdatedAt DATETIME2 NOT NULL DEFAULT SYSUTCDATETIME() ); -- 積分流水表只增不改每一筆變動一條 CREATE TABLE MemberPointsLedger ( LedgerId BIGINT NOT NULL IDENTITY PRIMARY KEY, MemberId BIGINT NOT NULL, ChangeType TINYINT NOT NULL, -- 1消費返 2活動贈 3消費扣 4過期扣 5退款回滾 ChangePoints INT NOT NULL, -- 正數(shù)增加負(fù)數(shù)扣減 BalanceAfter INT NOT NULL, -- 變動后余額對賬關(guān)鍵字段 BizOrderNo VARCHAR(64) NULL, -- 關(guān)聯(lián)業(yè)務(wù)單號冪等鍵 ExpireAt DATETIME2 NULL, -- 該筆積分的過期時間 CreatedAt DATETIME2 NOT NULL DEFAULT SYSUTCDATETIME(), INDEX IX_Member_Created (MemberId, CreatedAt), UNIQUE KEY UK_BizOrder_Type (BizOrderNo, ChangeType) -- 防重復(fù)入賬 );BalanceAfter這個字段是血淚經(jīng)驗換來的。只存變動值對賬時你得把用戶所有流水按時間累加才能算出某時刻余額一旦中間有數(shù)據(jù)修復(fù)或補錄累加結(jié)果和賬戶表對不上排查起來就是黑匣子。存了變動后余額任意一筆流水都能獨立驗證對賬腳本直接比對BalanceAfter和賬戶表AvailablePoints即可。2.2 用 C# 定義領(lǐng)域模型和入賬服務(wù)表建好了落到 C# 代碼。核心是一個入賬方法它必須在一個數(shù)據(jù)庫事務(wù)里完成「寫流水 更新賬戶余額」兩件事并且用樂觀鎖防并發(fā)覆蓋。public class PointsService { private readonly AppDbContext _db; public PointsService(AppDbContext db) _db db; /// summary /// 積分變動統(tǒng)一入口 /// /summary /// param namememberId會員ID/param /// param namechangeType變動類型見枚舉/param /// param namepoints變動值正加負(fù)減/param /// param namebizOrderNo業(yè)務(wù)單號冪等鍵/param public async Task ChangePointsAsync(long memberId, ChangeType changeType, int points, string bizOrderNo) { // 冪等檢查同一業(yè)務(wù)單號同一類型只允許入賬一次 bool exists await _db.Ledgers.AnyAsync(x x.BizOrderNo bizOrderNo x.ChangeType changeType); if (exists) return; await using var tx await _db.Database.BeginTransactionAsync(); var account await _db.Accounts .FromSqlInterpolated($SELECT * FROM MemberPointsAccount WITH (UPDLOCK) WHERE MemberId {memberId}) .FirstOrDefaultAsync(); if (account null) throw new BizException(積分賬戶不存在); int newBalance account.AvailablePoints points; if (newBalance 0) throw new BizException(積分不足); account.AvailablePoints newBalance; if (points 0) account.TotalEarned points; _db.Ledgers.Add(new PointsLedger { MemberId memberId, ChangeType changeType, ChangePoints points, BalanceAfter newBalance, BizOrderNo bizOrderNo, CreatedAt DateTime.UtcNow }); await _db.SaveChangesAsync(); await tx.CommitAsync(); } }邏輯說明先做冪等檢查避免消息重投導(dǎo)致重復(fù)加分UPDLOCK提示讓 SQL Server 在讀取賬戶行時就加更新鎖防止兩個并發(fā)請求同時讀到舊余額余額不足直接拋業(yè)務(wù)異常事務(wù)回滾。參數(shù)上points正負(fù)決定加減bizOrderNo是冪等的關(guān)鍵訂單號、活動ID 都可以但必須全局唯一且和ChangeType組合唯一。這套寫法在單庫單表、日流水百萬級以內(nèi)完全夠用再往上就要考慮分庫或把熱點賬戶拆成子賬戶。3. 積分扣減的并發(fā)控制為什么你的系統(tǒng)會超扣3.1 超扣的三種典型成因積分消費最怕的不是扣錯是超扣——用戶只有 100 分兩筆并發(fā)請求各扣 80結(jié)果都成功了余額變成 -60。成因有三類一是讀改寫之間沒有鎖兩個線程讀到同一個舊值二是用了UPDATE ... SET Points Points - 80這種看似原子的寫法但沒加WHERE Points 80條件扣成負(fù)數(shù)也不報錯三是分布式環(huán)境下多個服務(wù)實例各自持有本地緩存緩存里的余額是臟的。第一種靠數(shù)據(jù)庫鎖或樂觀鎖解決第二種靠條件更新解決第三種只能靠「緩存只讀、寫走數(shù)據(jù)庫」或者用分布式鎖。3.2 樂觀鎖重試適合讀多寫少的積分場景積分消費的寫并發(fā)通常遠(yuǎn)低于查詢樂觀鎖是性價比最高的方案。原理是給賬戶表加RowVersion更新時帶上版本號版本不匹配說明有人改過重試即可。public async Taskbool DeductWithRetryAsync(long memberId, int points, string orderNo, int maxRetry 3) { for (int i 0; i maxRetry; i) { try { var account await _db.Accounts.FindAsync(memberId); if (account null || account.AvailablePoints points) return false; account.AvailablePoints - points; _db.Ledgers.Add(new PointsLedger { MemberId memberId, ChangeType ChangeType.ConsumeDeduct, ChangePoints -points, BalanceAfter account.AvailablePoints, BizOrderNo orderNo }); await _db.SaveChangesAsync(); // RowVersion 不匹配會拋 DbUpdateConcurrencyException return true; } catch (DbUpdateConcurrencyException) { // 版本沖突清掉跟蹤重新讀 foreach (var entry in _db.ChangeTracker.Entries().ToList()) entry.State EntityState.Detached; await Task.Delay(20 * (i 1)); // 退避重試 } } return false; }參數(shù)說明maxRetry一般設(shè) 3超過說明熱點賬戶沖突嚴(yán)重該換悲觀鎖或隊列串行化了Task.Delay的退避系數(shù) 20ms 起步避免重試風(fēng)暴。注意SaveChangesAsync拋的DbUpdateConcurrencyException必須捕獲否則整個請求 500。這套代碼在 EF Core 里依賴實體配置Property(x x.RowVersion).IsRowVersion()SQL Server 會自動維護(hù)版本。3.3 悲觀鎖與隊列串行化的適用邊界如果某個賬戶是超級熱點比如平臺補貼活動幾萬人同時搶同一個活動賬戶樂觀鎖重試次數(shù)會飆升這時候用UPDLOCK悲觀鎖更穩(wěn)代價是吞吐下降。再極端一點把扣減請求丟進(jìn)內(nèi)存隊列Channel或BlockingCollection單線程消費天然串行但要注意進(jìn)程重啟丟消息的問題得配合持久化隊列。我一般會先上樂觀鎖監(jiān)控重試率超過 5% 再考慮升級。4. 積分消費系統(tǒng)的對賬與排查余額對不上時先看這三張表4.1 對賬腳本用流水重算余額對賬的核心邏輯一句話對每個會員把流水表按時間累加看最終結(jié)果是否等于賬戶表余額。不等就是有問題。-- 找出余額不一致的會員 SELECT a.MemberId, a.AvailablePoints AS AccountBalance, ISNULL(SUM(l.ChangePoints), 0) AS LedgerSum FROM MemberPointsAccount a LEFT JOIN MemberPointsLedger l ON a.MemberId l.MemberId GROUP BY a.MemberId, a.AvailablePoints HAVING a.AvailablePoints ISNULL(SUM(l.ChangePoints), 0);跑出來如果有記錄先別急著改數(shù)據(jù)。按下面順序排查第一看這些會員的流水里有沒有BizOrderNo為空的記錄空單號說明是人工補錄或程序 bug 寫入的第二看有沒有同一BizOrderNo ChangeType出現(xiàn)兩次說明冪等失效第三看BalanceAfter字段是否連續(xù)如果某條流水的BalanceAfter和上一條加變動值對不上說明寫入時就有并發(fā)問題。4.2 用 BalanceAfter 做逐筆校驗-- 逐筆校驗當(dāng)前流水的 BalanceAfter 應(yīng)等于上一條 BalanceAfter 當(dāng)前 ChangePoints WITH Ordered AS ( SELECT LedgerId, MemberId, ChangePoints, BalanceAfter, LAG(BalanceAfter) OVER (PARTITION BY MemberId ORDER BY LedgerId) AS PrevBalance FROM MemberPointsLedger ) SELECT * FROM Ordered WHERE PrevBalance IS NOT NULL AND BalanceAfter PrevBalance ChangePoints;這條 SQL 能精確定位到哪一筆流水開始錯亂。常見結(jié)果是某幾筆的BalanceAfter相同說明兩個并發(fā)事務(wù)都基于同一個舊余額計算典型的樂觀鎖沒生效或用了錯誤的隔離級別。4.3 消費核銷的冪等排查積分消費經(jīng)常和訂單系統(tǒng)聯(lián)動訂單支付成功回調(diào)扣積分。如果回調(diào)重復(fù)觸發(fā)就會重復(fù)扣。排查時重點看MemberPointsLedger里同一BizOrderNo是否有多條ChangeType 3的記錄。有的話檢查回調(diào)接口有沒有做冪等以及唯一索引UK_BizOrder_Type是否真的建上了——我見過有人建了索引但字段順序反了導(dǎo)致冪等失效。5. 避坑與常見問題積分系統(tǒng)上線后最容易翻車的五個點現(xiàn)象一活動期間積分扣成負(fù)數(shù)。原因用了UPDATE Account SET Points Points - p但沒加WHERE Points p或者 C# 里先查后改沒加鎖。解決所有扣減必須帶條件更新或樂觀鎖數(shù)據(jù)庫層加CHECK (AvailablePoints 0)約束兜底讓負(fù)數(shù)直接寫不進(jìn)去?，F(xiàn)象二用戶退款后積分沒退回。原因退款流程只處理了錢忘了積分回滾或者回滾時用了新的BizOrderNo導(dǎo)致和原扣減對不上。解決退款回滾必須用原訂單號 新的ChangeType如 5 退款回滾并在流水里記錄關(guān)聯(lián)的原流水 ID。現(xiàn)象三積分過期任務(wù)跑完后余額對不上。原因過期扣減是批量操作直接UPDATE賬戶表但沒寫流水或者寫了流水但BalanceAfter算錯。解決過期也必須走統(tǒng)一的ChangePointsAsync入口一筆一筆寫流水批量任務(wù)只是循環(huán)調(diào)用?，F(xiàn)象四分布式部署后同一用戶并發(fā)扣減仍然超扣。原因每個實例的 EF Core 上下文緩存了賬戶實體FindAsync直接返回緩存沒查庫。解決扣減場景禁用一級緩存用AsNoTracking重新查或直接走FromSqlInterpolated強制查庫?，F(xiàn)象五對賬腳本跑出來一堆差異但業(yè)務(wù)說沒投訴。原因?qū)~ SQL 沒排除測試數(shù)據(jù)或歷史遷移數(shù)據(jù)BizOrderNo為空的補錄流水被算進(jìn)去了。解決對賬前先過濾BizOrderNo IS NOT NULL并把補錄流水單獨標(biāo)記ChangeType對賬時排除。6. 進(jìn)階技巧把積分消費做成可回放的事件流前面講的都是「當(dāng)前狀態(tài)」的維護(hù)但真正讓積分系統(tǒng)好維護(hù)的是把它當(dāng)成事件流來設(shè)計。每一筆積分變動都是一條不可變事件賬戶余額只是事件的物化視圖。這樣做的好處是任何歷史時刻的余額都能重放出來對賬不再依賴BalanceAfter字段出問題可以直接從流水重建賬戶表。具體做法是在現(xiàn)有流水表基礎(chǔ)上加兩個字段EventVersion該會員的事件序號從 1 遞增和SnapshotAt快照時間。每處理 N 筆比如 100 筆寫一個賬戶快照重放時從最近快照開始只回放之后的流水。// 從快照 流水重建賬戶余額 public async Taskint RebuildBalanceAsync(long memberId) { var snapshot await _db.Snapshots .Where(x x.MemberId memberId) .OrderByDescending(x x.EventVersion) .FirstOrDefaultAsync(); int balance snapshot?.Balance ?? 0; int fromVersion snapshot?.EventVersion ?? 0; var events await _db.Ledgers .Where(x x.MemberId memberId x.EventVersion fromVersion) .OrderBy(x x.EventVersion) .ToListAsync(); foreach (var e in events) balance e.ChangePoints; return balance; }驗證方法很簡單對任意會員跑一遍RebuildBalanceAsync結(jié)果應(yīng)該等于賬戶表AvailablePoints。如果不等說明流水有缺失或事件版本號有斷層這時候去查EventVersion是否連續(xù)就能定位。我自己的習(xí)慣是每周跑一次全量重放校驗把差異會員拉出來人工核對比等用戶投訴再查主動得多。這套事件流思路還能平滑遷移到消息隊列積分變動發(fā)到 Kafka下游對賬、風(fēng)控、報表各自消費系統(tǒng)邊界一下就清晰了。積分系統(tǒng)看著簡單真正難的是「每一分都能說清楚從哪來、到哪去」。把流水當(dāng)事實、余額當(dāng)視圖、對賬當(dāng)習(xí)慣這套系統(tǒng)就能睡得著覺。希望幫到你。本文還有配套的精品資源點擊獲取