[發(fā)明專利]一種多客戶積分快速過期的處理方法及裝置

有效

• 申請?zhí)枺?/td>: 201810389937.0
• 申請日: 2018-04-27
• 公開（公告）號: CN108510333B
• 公開（公告）日: 2022-11-15
• 發(fā)明（設計）人: 陳碧勇;方敏;呂曄
• 申請（專利權）人: 廈門南訊股份有限公司
• 主分類號: G06Q30/02
• 分類號: G06Q30/02
• 代理公司: 廣州市紅荔專利代理有限公司 44214
• 代理人: 吳偉文

1.一種多客戶積分快速過期的處理方法，其特征在于，主線程包括以下步驟，S1：對店鋪記錄表進行查詢，判斷是否存在需要進行過期積分處理的店鋪；

S2：將需要進行過期積分處理的店鋪加入緩存，形成待處理店鋪隊列；將沒有過期積分的店鋪置為處理完成狀態(tài)；

S3：提取緩存中的一條待處理店鋪記錄，獲取該店鋪的積分記錄表，創(chuàng)建相應的一個子線程處理店鋪過期積分數(shù)據(jù)，線程數(shù)+1，同時處理的店鋪數(shù)量不超過預設的子線程的最大線程數(shù)，超出的店鋪進入等待狀態(tài)；

S4：店鋪過期積分數(shù)據(jù)處理完畢后，線程數(shù)-1，釋放子線程，提取處于等待狀態(tài)中的店鋪，創(chuàng)建相應的一個子線程處理該店鋪過期積分數(shù)據(jù)；

S5：判斷各個店鋪是否還存在未過期積分，如果是，重復步驟S3和S4，如果否，在緩存中加入處理完成標志，退出流程，結束任務；

在步驟S1中，所述的店鋪記錄表用于記錄多個店鋪的過期積分信息匯總，內容包括店鋪編號和積分過期時間；

在步驟S3中，所述的積分記錄表用于記錄每個店鋪下所有的存在待過期積分的用戶積分信息，內容包括店鋪編號、積分過期時間、用戶編號和待過期積分值，所述的用戶編號進行遞增排序；

在步驟S3中，所述的子線程包括如下步驟，S3-1：創(chuàng)建緩存鎖；

S3-2：設置分頁長度為a，從起始用戶編號的下一條開始依序提取b條客戶積分信息記錄作為一組積分記錄，并將該組積分記錄中的最大用戶編號賦值給緩存中的新的起始用戶編號；

S3-3：釋放緩存鎖；

S3-4：判斷步驟S3-2中可提取的客戶積分信息記錄的數(shù)量x是否小于分頁長度a，如果是，將該店鋪記錄從緩存中的店鋪隊列中移除；S3-5：將步驟S3-2提取的一組積分記錄逐條進行積分處理，將處理后的積分記錄根據(jù)用戶編號逐條更新積分表中的積分值，并刪除積分記錄表中相應用戶編號的數(shù)據(jù)，批量插入積分日志表。

2.如權利要求1所述的一種多客戶積分快速過期的處理方法，其特征在于，在步驟S3-2中，首次查詢時，以0作為該店鋪的起始用戶編號。

3.如權利要求2所述的一種多客戶積分快速過期的處理方法，其特征在于，在步驟S3-2中，當可提取的客戶積分信息記錄的數(shù)量x大于a時，b＝a；當可提取的客戶積分信息記錄的數(shù)量x小于a時，b＝x。

4.如權利要求3所述的一種多客戶積分快速過期的處理方法，其特征在于，在步驟S3-5中，所述的積分表用于記錄每個店鋪下所有的用戶積分信息，內容包括店鋪編號、積分過期時間、用戶編號和積分值。

5.一種多客戶積分快速過期的處理裝置，其特征在于，包括查詢單元、分類單元、子線程單元，其中，所述的查詢單元用于對店鋪記錄表進行查詢，判斷是否存在需要進行過期積分處理的店鋪；

所述的分類單元用于將需要進行過期積分處理的店鋪加入緩存，形成待處理店鋪隊列；將沒有過期積分的店鋪置為處理完成狀態(tài)；

所述的子線程單元用于處理店鋪過期積分數(shù)據(jù)；

所述的子線程單元包括緩存鎖創(chuàng)建單元、數(shù)據(jù)提取單元、緩存鎖釋放單元、狀態(tài)判斷單元和數(shù)據(jù)處理單元，其中，所述的緩存鎖創(chuàng)建單元用于創(chuàng)建緩存鎖；

所述的數(shù)據(jù)提取單元用于從起始用戶編號的下一條開始依序提取b條客戶積分信息記錄作為一組積分記錄，并將該組積分記錄中的最大用戶編號賦值給緩存中的新的起始用戶編號；

所述的緩存鎖釋放單元用于釋放緩存鎖；

所述的狀態(tài)判斷單元用于判斷數(shù)據(jù)提取單元中可提取的客戶積分信息記錄的數(shù)量x是否小于分頁長度a；

所述的數(shù)據(jù)處理單元用于將數(shù)據(jù)提取單元提取的一組積分記錄逐條進行積分處理，將處理后的積分記錄根據(jù)用戶編號逐條更新積分表中的積分值，并刪除積分記錄表中相應用戶編號的數(shù)據(jù)，批量插入積分日志表。