From c308c5e9ef94da0761357da1909f9a6a6ae080d1 Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Thu, 16 Jul 2026 16:31:19 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=AE=9E=E7=8E=B0=E8=BD=AC=E8=B4=A6?=
 =?UTF-8?q?=E9=82=AE=E4=BB=B6=E8=BD=AE=E8=AF=A2=E5=90=8E=E5=8F=B0=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=EF=BC=8C=E8=87=AA=E5=8A=A8=E5=8C=B9=E9=85=8D=E8=BD=AC?=
 =?UTF-8?q?=E8=B4=A6=E7=A0=81=E5=B9=B6=E5=AE=8C=E6=88=90=E5=85=A5=E8=B4=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 models/.transfercode.json.swp | Bin 0 -> 12288 bytes
 unipay/init.py                |   4 ++
 unipay/providers/transfer.py  |  84 +++++++++++++++++++++++++++++-----
 3 files changed, 76 insertions(+), 12 deletions(-)
 create mode 100644 models/.transfercode.json.swp

diff --git a/models/.transfercode.json.swp b/models/.transfercode.json.swp
new file mode 100644
index 0000000000000000000000000000000000000000..8e43a4983df2e3cc56a87682b257a24d1a178b1c
GIT binary patch
literal 12288
zcmeI2Pe>F|9LJy8rA!OWx&&?0DM(jWD2<@55k-gU5>n&tTN{}_+svDE6SE}f&m}zV
zB`JkEgam=<rHG;kI&|t1U4n4cgV0Svh`w)jW_EUBSMikad+^zr**EX^`_1RQw;)bm
z$Hh};65Z`7hPI2b)1!L^a?Shdzir*k^2Rm!?V3$99if_O-lpl<Y`#a;s*JdafJvL@
zEGOxjT29R;4J*TSCn;>zbh6w|<Fb9gvCJv~=xZ`S1~z8E71_4#M%I<;?2rKtDhCoR
z%@;Nni$;+FGC&5%02v?yWPl8i0Wz>D4TxMF8%5<?{OV8m$GX_jzoY{hAOmE843Ggb
zKnBPF86X2>fDDiUGO!5^s2RqdZ)5EJb`+2Q{|A5n|JljdGWZGJf(dX3Sl|jc366jy
z*biF4Y7=8Wz(+6*CP4wX;5_I73D61}z;YvFU%*RH0ApYf7~mXe2Q6TA2V=iL5qttu
zU<?cb1DpkiKoh73zZ)3)4qk&va373<A)tZF;5gU|R`A?k!DsLRNDuD-H8Ma3$N(82
z17v^<kb(czzz9pA^?IN3taL5UWK#qm5?PJw8Rb|)vFv_RHMqjOKL10xuIeri@6j^K
z;mUrY_UYUouA15nRcMwOzbPD_b{%0E+^&c->_t@M3$6|#UGgq_%Xwl&>)h-YS8-!!
ztde}rE5s3YJipLHsmO%~v&CDt<K5n4!vNmY6|NKMEmf948!49~FBRb@%cvr5EKD~4
zaD4IAT(R)9_~>yYs5d@HnRab2L^=H0IfZ6$lxpN+Q}s{c*`>lvjl?oeq`P|J(D+d%
ziw{~Tp_cK*H`9wV&la9kl`iDGud9p<Ph-|oEXXg9N?2Q}qwLV@38pBkTdIg8D0K!a
zV(ISq($qw}JD48Tuv{}bcpZ|uVig8;)Uq`HVybv=u3}esWd?QB*f;XN`05O$Y^0Xz
zRaEqpOeo&gUeC5oW2fj=zx=7-CYEZxa`i^`yL=+q6y#&xng5~WY|T*ZeE1^~bSmM}
VUwgSlUZ;=Dy8kqeYlI1g*<Ys}ee3`L

literal 0
HcmV?d00001

diff --git a/unipay/init.py b/unipay/init.py
index f615147..4a97283 100644
--- a/unipay/init.py
+++ b/unipay/init.py
@@ -1,5 +1,6 @@
 # init.py
 import os
+import asyncio
 import traceback
 from appPublic.log import debug,exception
 from ahserver.configuredServer import add_startup
@@ -245,6 +246,9 @@ def load_unipay():
 			PROVIDERS[name] = get_provider(name, conf)
 			if PROVIDERS[name] is not None:
 				print(f"[unipay] {name} 初始化成功")
+				if name == 'transfer':
+					asyncio.ensure_future(PROVIDERS[name].run())
+					print(f"[unipay] transfer 邮件轮询已启动")
 			else:
 				print(f"[unipay] {name} 初始化返回 None（渠道 disabled）")
 		except Exception as e:
diff --git a/unipay/providers/transfer.py b/unipay/providers/transfer.py
index 777d2e6..8165f2b 100644
--- a/unipay/providers/transfer.py
+++ b/unipay/providers/transfer.py
@@ -1,9 +1,10 @@
+import asyncio
 import re
 from random import randint
 from typing import Any, Dict, Optional
 import urllib
 import poplib
-from appPublic.log import debug
+from appPublic.log import debug, exception
 from appPublic.dictObject import DictObject
 from appPublic.timeUtils import curDateString, timestampstr
 from email.parser import Parser
@@ -116,19 +117,21 @@ class TransferGateway(Gateway):
 		return None
 
 	def get_transfer_data(self, mail):
-		assert mail.mailfrom == '95555@message.cmbchina.com'
-		assert mail.mailto == self.email
-		assert mail.body.startswith('动账业务通知')
+		if mail.mailfrom != '95555@message.cmbchina.com':
+			return None
+		if mail.mailto != self.email:
+			return None
+		if not mail.body.startswith('动账业务通知'):
+			return None
 		ns = DictObject()
 		match = re.search(r'交易金额\s*[:：]?\s*(\d+(?:\.\d+)?)', mail.body)
 		if match:
 			ns.amount = float(match.group(1))
-		p =  r'摘要[:：]\s*(\d{7})(?!\d)'
 		match = re.search(r'摘要[:：]\s*(\d{7})(?!\d)', mail.body)
 		if match:
 			ns.code = match.group(1)
-		assert ns.amount
-		assert ns.code
+		if not hasattr(ns, 'amount') or not hasattr(ns, 'code'):
+			return None
 		return ns
 	
 	def gen_mailcode(self):
@@ -136,13 +139,70 @@ class TransferGateway(Gateway):
 		for i in range(6):
 			c += str(randint(0,9))
 		return c
-		
-	def run(self):
+
+	async def run(self):
+		"""后台轮询邮箱，匹配转账码并完成充值入账"""
+		from ahserver.serverenv import ServerEnv
 		self.running = True
 		while self.running:
-			ec = EmailClient(self.pop3server, self.email, self.password)
-			mail = ec.get_mail(1)
-			
+			try:
+				ec = EmailClient(self.pop3server, self.email, self.password)
+				count, _ = ec.stat()
+				if count == 0:
+					await asyncio.sleep(30)
+					continue
+				for i in range(count, 0, -1):
+					try:
+						mail = ec.get_mail(i)
+						if mail.mailfrom != '95555@message.cmbchina.com':
+							continue
+						if not mail.body.startswith('动账业务通知'):
+							continue
+						data = self.get_transfer_data(mail)
+						if data is None:
+							continue
+						debug(f'transfer mail matched: code={data.code}, amount={data.amount}')
+
+						env = ServerEnv()
+						db = DBPools()
+						dbname = env.get_module_dbname('unipay')
+						async with db.sqlorContext(dbname) as sor:
+							recs = await sor.R('transfercode', {'tcode': data.code, 'status': '0'})
+							if len(recs) < 1:
+								debug(f'tcode {data.code} not found or already processed')
+								continue
+							tc = recs[0]
+							if abs(float(tc.amount) - data.amount) > 0.01:
+								debug(f'amount mismatch: tc={tc.amount}, mail={data.amount}')
+								continue
+
+							biz_date = await env.get_business_date(sor)
+							await sor.U('transfercode', {'id': tc.id, 'status': '1'})
+
+							recs2 = await sor.R('payment_log', {'id': tc.id, 'payment_status': '0'})
+							if len(recs2) > 0:
+								plog = recs2[0]
+								await env.recharge_accounting(sor,
+									plog.customerid,
+									'RECHARGE',
+									plog.id,
+									biz_date,
+									plog.amount_total,
+									plog.pay_feerate)
+								await sor.U('payment_log', {
+									'id': plog.id,
+									'payment_status': '1',
+									'payed_timestamp': timestampstr()
+								})
+								debug(f'transfer recharge done: {tc.id}, amount={data.amount}')
+						ec.client.dele(i)
+					except Exception as e2:
+						exception(f'transfer mail[{i}] error: {e2}')
+				ec.client.quit()
+			except Exception as e:
+				exception(f'transfer poll error: {e}')
+			await asyncio.sleep(30)
+
 	async def query(self, out_trade_no: str) -> Dict[str, Any]:
 		pass