TestRefill.php 45 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318
  1. <?php
  2. use PHPUnit\Framework\TestCase;
  3. define('APP_ID', 'test');
  4. define('BASE_ROOT_PATH', str_replace('/test', '', dirname(__FILE__)));
  5. require_once(BASE_ROOT_PATH . '/global.php');
  6. require_once(BASE_CORE_PATH . '/lrlz.php');
  7. require_once(BASE_ROOT_PATH . '/fooder.php');
  8. require_once(BASE_CORE_PATH . '/framework/function/http.php');
  9. require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');
  10. require_once(BASE_HELPER_PATH . '/mtopcard/mtopcard.php');
  11. const LocalTest = 1;
  12. const NetTest = 2;
  13. const CurrentTest = LocalTest;
  14. class TestRefill extends TestCase
  15. {
  16. private $mReqHost;
  17. private $mKey;
  18. private $mMchid;
  19. public function __construct(?string $name = null, array $data = [], $dataName = '')
  20. {
  21. parent::__construct($name, $data, $dataName);
  22. if (CurrentTest == LocalTest) {
  23. $this->mReqHost = BASE_SITE_URL;
  24. $this->mMchid = 1;
  25. $this->mKey = '1ff02223b771c0414468c8892151c602';
  26. } else {
  27. // $this->mReqHost = 'https://www.xyzshops.cn';
  28. $this->mReqHost = 'http://121.89.196.45';
  29. $this->mMchid = 1092;
  30. $this->mKey = '210fe406954220f56085997d6a4c5b80';
  31. }
  32. }
  33. public static function setUpBeforeClass(): void
  34. {
  35. Base::run_util();
  36. refill\RefillFactory::instance();
  37. }
  38. public function testMerchantPrice()
  39. {
  40. $price = new refill\merchant_price();
  41. }
  42. public function testCallBack()
  43. {
  44. }
  45. public function testFactory()
  46. {
  47. $providers = refill\RefillFactory::instance();
  48. }
  49. private function make_sn()
  50. {
  51. return mt_rand(1000, 9999)
  52. . sprintf('%010d', time())
  53. . sprintf('%06d', (float)microtime() * 1000000);
  54. }
  55. public function testRandomMobile()
  56. {
  57. $no = "1" . mt_rand(1, 9999999999);
  58. Log::record("phone no={$no}", Log::DEBUG);
  59. }
  60. public function testBJBAddPhone()
  61. {
  62. $providers = new refill\bjb\RefillPhone([]);
  63. for ($i = 3; $i > 0; --$i) {
  64. $resp = $providers->add(13911129867, 4, 10, ['order_sn' => $this->make_sn()]);
  65. $resp = $providers->add(18500608333, 4, 10, ['order_sn' => $this->make_sn()]);
  66. $resp = $providers->add(18510683168, 4, 10, ['order_sn' => $this->make_sn()]);
  67. $resp = $providers->add(18513846008, 4, 10, ['order_sn' => $this->make_sn()]);
  68. $resp = $providers->add(18518237398, 4, 10, ['order_sn' => $this->make_sn()]);
  69. }
  70. }
  71. public function testOilticket()
  72. {
  73. $providers = new refill\bjb\RefillPhone([]);
  74. }
  75. public function testBjbRet()
  76. {
  77. $resp = '0|提交成功|14936.8600';
  78. $resp = explode('|', $resp);
  79. }
  80. public function testIpWhiteList()
  81. {
  82. $x = serialize(['47.99.57.105']);
  83. $ips = unserialize('a:1:{i:0;s:12:"47.99.57.105";}');
  84. if (!empty($ips)) {
  85. $addr = '47.99.57.105';
  86. Log::record("request ip:{$addr}", Log::DEBUG);
  87. if (!in_array($addr, $ips)) {
  88. throw new Exception("请求地址不在白名单中");
  89. }
  90. }
  91. }
  92. public function testBaizePhone()
  93. {
  94. $providers = new refill\baizeyd\RefillPhone([]);
  95. // $resp = $providers->add(17801048874, 5, 10, ['order_sn' => $this->make_sn()]);
  96. $resp = $providers->query(['order_sn' => '930668700375312006']);
  97. // $str = 'amount=10.00&orderId=720668384771999671&phone=13911129867&payTime=2021-03-06+22%3A26%3A12&sign=94dfe83221f7768650e70cce08879b60&appKey=uECmTOFAY6RPCTtI&payUrl=&statusDes=%E6%94%AF%E4%BB%98%E5%A4%B1%E8%B4%A5&status=7';
  98. // $input = $this->parse_request($str);
  99. // $input['amount'] = 10.00;
  100. // $input['orderId'] = '92391614943913061206';
  101. // $input['phone'] = 17801048874;
  102. // $input['payTime'] = '2021-03-05 19:31:55';
  103. // $input['sign'] = 'bef6ae50319fb1e8cb3f21302f0abef8';
  104. // $input['appKey'] = 'uECmTOFAY6RPCTtI';
  105. // $input['payUrl'] = '';
  106. // $input['statusDes'] = '支付失败';
  107. // $input['status'] = 7;
  108. // refill\RefillFactory::instance()->notify('baizeyd',$input);
  109. }
  110. private function parse_request($squery)
  111. {
  112. if (empty($squery)) return [];
  113. $result = [];
  114. $params = preg_split('/&/', $squery);
  115. foreach ($params as $pair) {
  116. if (empty($pair)) continue;
  117. $kv = explode('=', $pair);
  118. $count = count($kv);
  119. if ($count === 1) {
  120. $key = $kv[0];
  121. $val = "";
  122. } elseif ($count === 2) {
  123. $key = $kv[0];
  124. $val = urldecode($kv[1]);
  125. } else {
  126. continue;
  127. }
  128. if (!empty($key)) {
  129. $result[$key] = $val;
  130. }
  131. }
  132. return $result;
  133. }
  134. public function testAmPhone()
  135. {
  136. // $providers = new refill\aming\RefillPhone([]);
  137. // $resp = $providers->add(18500608333, 5, 10, ['order_sn' => $this->make_sn()]);
  138. $input['result'] = 'fail';
  139. $input['msg'] = 0;
  140. $input['order'] = 'null';
  141. $input['phone_no'] = 18500608333;
  142. $input['sign'] = 'c925ad19c63c3eb36ffc52d938e24604';
  143. $input['amount'] = '10.00';
  144. $input['op_no'] = '42601615096072517841';
  145. refill\RefillFactory::instance()->notify('aming', $input);
  146. }
  147. public function testBhcPhone()
  148. {
  149. $providers = new refill\binghc\RefillPhone([]);
  150. $resp = $providers->query(['order_sn' => 250668618955902006]);
  151. // $input['result'] = 'fail';
  152. // $input['msg'] = 0;
  153. // $input['order'] = 'null';
  154. // $input['phone_no'] = 18500608333;
  155. // $input['sign'] = 'c3aa38ee07cd1b69bfd5ead56f6da8d6';
  156. // $input['amount'] = '10.00';
  157. // $input['op_no'] = '24061615096361999002';
  158. // refill\RefillFactory::instance()->notify('binghc',$input);
  159. }
  160. public function testRuishunPhone()
  161. {
  162. // $providers = new refill\ruishun\RefillPhone([]);
  163. // $resp = $providers->add(18500608333, 5, 10, ['order_sn' => $this->make_sn()]);
  164. $input['result'] = 'fail';
  165. $input['msg'] = 0;
  166. $input['order'] = null;
  167. $input['phone_no'] = 18500608333;
  168. $input['sign'] = 'e234f7d1c0458ca236f53a0008436b46';
  169. $input['amount'] = "10.00";
  170. $input['op_no'] = '76361615095403188513';
  171. refill\RefillFactory::instance()->notify('ruishun', $input);
  172. }
  173. public function testWuchenPhone()
  174. {
  175. $providers = new refill\wuchen\RefillPhone([]);
  176. // $resp = $providers->add('13699279618', 5, 30, ['order_sn' => $this->make_sn()]);
  177. $resp = $providers->query(['order_sn' => '790668630498425006']);
  178. // $input['app_id'] = '70016';
  179. // $input['message'] = 'fail';
  180. // $input['order_sn'] = '43101615277293035501';
  181. // $input['platform_order_id'] = '';
  182. // $input['sign'] = '5ea59f8ac51a518f2c622824d7db2a04';
  183. // $input['state'] = "fail";
  184. // $input['sys_sn'] = '202103091608231836913889';
  185. // $input['timestamp'] = '1615277361';
  186. // refill\RefillFactory::instance()->notify('wuchen',$input);
  187. }
  188. public function testYibaoPhone()
  189. {
  190. $providers = new refill\yibao\RefillPhone([]);
  191. // $resp = $providers->add('13699279618', 5, 30, ['order_sn' => $this->make_sn()]);
  192. $resp = $providers->query(['ch_trade_no' => '31215002972142736']);
  193. // $str = '{"amount":"30","carrierOrderNo":null,"mobile":"13699279618","orderNo":"27961615532426088043","orderStatus":3,"sign":"012BA0B093A0473D7DD1634A8356DCB1","tradeNo":"31215002972142736"}';
  194. // $data = json_decode($str,true);
  195. // refill\RefillFactory::instance()->notify('yibao',$data);
  196. }
  197. public function testAmingydPhone()
  198. {
  199. $providers = new refill\amingyd\RefillPhone([]);
  200. // $resp = $providers->add('13699279618', 5, 30, ['order_sn' => $this->make_sn()]);
  201. $resp = $providers->query(['order_sn' => '15421615627436792938']);
  202. // $str = '{"orderId":"15421615627436792938","amount":3000,"appKey":"40695059","timestamp":1615627503,"status":3,"operatorId":"508353854027968617","sign":"2A0562319ED4845AB9E3812A58F0B425"}';
  203. // $data = json_decode($str,true);
  204. // refill\RefillFactory::instance()->notify('amingyd',$data);
  205. }
  206. public function testChukaPhone()
  207. {
  208. $providers = new refill\chuka\RefillPhone([]);
  209. // $resp = $providers->add('18500608333', 5, 20, ['order_sn' => $this->make_sn()]);
  210. // $resp = $providers->query(['order_sn' => '92161616314884175179']);
  211. $params['customerId'] = '101787';
  212. $params['orderno'] = 'C1616314888506705492';
  213. $params['tmporder'] = '92161616314884175179';
  214. $params['code'] = '1';
  215. $params['number'] = '18500608333';
  216. $params['money'] = '20';
  217. $params['amount'] = '0';
  218. refill\RefillFactory::instance()->notify('chuka', $params);
  219. }
  220. public function testLegouPhone()
  221. {
  222. $providers = new refill\legou\RefillPhone([]);
  223. // $resp = $providers->add('18500608333', 5, 30, ['order_sn' => '200649600557718881' , 'order_id' => 247 , 'buyer_id' => 52667]);
  224. $resp = $providers->query(['order_sn' => '200649600557718881', 'order_id' => 247]);
  225. $params['username'] = 'lzdc';
  226. $params['orderNumber'] = '690653407667699667';
  227. $params['cardNumber'] = '18500608333';
  228. $params['orderMoney'] = '30.0';
  229. $params['orderPay'] = '1.0';
  230. $params['resultCode'] = '2';
  231. $params['rechargeDesc'] = '{"rechargeStatus":600200,"rechargeDesc":"充值成功"}';
  232. $params['rechargeVoucher'] = '100407307092103291444050244599';
  233. $params['sign'] = 'c054884422a8c3749cbfda0e82b9af70';
  234. // refill\RefillFactory::instance()->notify('legou',$params);
  235. }
  236. public function testFeiniaoPhone()
  237. {
  238. $providers = new refill\feiniao\RefillPhone([]);
  239. // $order_sn = $this->make_sn();
  240. // Log::record($order_sn, Log::DEBUG);
  241. // $resp = $providers->add('13699279618', 4, 50, ['order_sn' => $order_sn]);
  242. $resp = $providers->query(['order_sn' => '28641617178590981824']);
  243. $params['result'] = 'fail';
  244. $params['msg'] = '0';
  245. $params['order'] = 'null';
  246. $params['phone_no'] = '18500608333';
  247. $params['amount'] = '100.00';
  248. $params['op_no'] = '64591617090761169983';
  249. $params['settle'] = '0';
  250. $params['sign'] = '907d2640f96e8d78d59202d090ddb470';
  251. // refill\RefillFactory::instance()->notify('feiniao',$params);
  252. }
  253. public function testTongyPhone()
  254. {
  255. $providers = new refill\tongy\RefillPhone([]);
  256. $resp = $providers->add('18500608333', 5, 30, ['order_sn' => '690653407667699667', 'order_id' => 248, 'buyer_id' => 52667]);
  257. }
  258. public function testWeiyiPhone()
  259. {
  260. $providers = new refill\weiyi\RefillPhone([]);
  261. // $resp = $providers->add(18500608333, 5, 100, ['order_sn' => $this->make_sn()]);
  262. // $resp = $providers->query(['order_sn' => '59031616396534854303']);
  263. // $body = '{"userid":"8177b4b1d0254c0699bc","ordernum":"59031616396534854303","mobile":"18500608333","timestamp":"20210322150437","state":"3","desc":"%E5%A4%B1%E8%B4%A5%3A%E5%A4%B1%E8%B4%A5","sign":"1d412f956c041bf4454357b209c93df6"}';
  264. // $params = json_decode($body , true);
  265. // refill\RefillFactory::instance()->notify('weiyi',$params);
  266. }
  267. public function testTongluPhone()
  268. {
  269. $providers = new refill\tonglu\RefillPhone([]);
  270. // $resp = $providers->add(18500608333, 5, 50, ['order_sn' => $this->make_sn()]);
  271. $resp = $providers->query(['order_sn' => '22961616468561936356']);
  272. // $body = '{"order_no":"22961616468561936356","order_status":"5","phone_no":"18500608333","amount":5000,"time_paid":1616468856287,"order_cert_no":"","paid":false,"order_id":"20210323966497008"}';
  273. // $sign = '9E41F52F612D60EBB654B3A5D1E2F1E5';
  274. // $params = json_decode($body , true);
  275. // $params['sign'] = $sign;
  276. // refill\RefillFactory::instance()->notify('tonglu',$params);
  277. }
  278. public function testAmingjd()
  279. {
  280. // $providers = new refill\amingjd\RefillPhone([]);
  281. // $resp = $providers->add(13699279618, 5, 30, ['order_sn' => $this->make_sn()]);
  282. // $resp = $providers->query(['order_sn' => '42301616475989518588']);
  283. $body = '{"order_id":"83321616478215494884","mchid":"10003","tel":"13699279618","price":"30.00","sign":"01c49620c155a80bc43cecc2b1651868","status":"0","out_order_id":"0"}';
  284. $params = json_decode($body, true);
  285. refill\RefillFactory::instance()->notify('amingjd', $params);
  286. }
  287. public function testPrice()
  288. {
  289. $amounts = [10, 20, 30, 50, 100, 200, 300, 500];
  290. $rate = 0.935;
  291. foreach ($amounts as $amount) {
  292. $price[] = $amount * $rate;
  293. }
  294. }
  295. public function testWeisPhone()
  296. {
  297. $providers = new refill\weisyd\RefillPhone([]);
  298. $resp = $providers->add(17801048874, 4, 10, ['order_sn' => $this->make_sn()]);
  299. }
  300. public function testXcPhone()
  301. {
  302. $providers = new refill\xc\RefillPhone([]);
  303. $resp = $providers->add(13699279618, 5, 100, ['order_sn' => $this->make_sn()]);
  304. // $resp = $providers->query(['order_sn' => '87961616926444043617']);
  305. $params['pay_orderid'] = '87961616926444043617';
  306. $params['pay_iphone'] = '18500608333';
  307. $params['pay_money'] = '100';
  308. $params['wt_orderid'] = '202103281816121070';
  309. $params['status'] = '1';
  310. $params['sign'] = 'f7be2e859a5a6dc7b1a8273361617752';
  311. // refill\RefillFactory::instance()->notify('xc',$params);
  312. }
  313. public function testAfandPhone()
  314. {
  315. $providers = new refill\afand\RefillPhone([]);
  316. // for ($i = 3; $i > 0; --$i) {
  317. $resp = $providers->query(['order_sn' => '540668612768904780']);
  318. // }
  319. }
  320. public function testAfandengPhone()
  321. {
  322. $providers = new refill\afandeng\RefillPhone([]);
  323. // for ($i = 5; $i > 0; --$i) {
  324. $resp = $providers->add(13699279618, 4, 50, ['order_sn' => $this->make_sn()]);
  325. // }
  326. // $resp = $providers->query(['order_sn' => '20941616115610023539']);
  327. // $params['usr'] = 'afandeng';
  328. // $params['ord'] = '20941616115610023539';
  329. // $params['state'] = '2';
  330. // $params['bz'] = '';
  331. // $params['sgn'] = 'BA2C9D379C3EB648A0B7AAB3A21A3F6A';
  332. // refill\RefillFactory::instance()->notify('afandeng',$params);
  333. }
  334. public function testWantongPhone()
  335. {
  336. $providers = new refill\wantong\RefillPhone([]);
  337. $resp = $providers->add(13699279618, 4, 30, ['order_sn' => $this->make_sn()]);
  338. // $resp = $providers->query(['order_sn' => '50261617199864602428']);
  339. }
  340. public function testXunyinPhone()
  341. {
  342. $providers = new refill\xunyin\RefillPhone([]);
  343. // $resp = $providers->add(17703711950, 6, 30, ['order_sn' => $this->make_sn()]);
  344. // $resp = $providers->query(['order_sn' => '76831617176125893158']);
  345. $params['ext'] = '';
  346. $params['code'] = '8888';
  347. $params['sign'] = '428ac223cf3a1f6f3d382aac754e8e17';
  348. $params['statemes'] = '成功';
  349. $params['id'] = '76831617176125893158';
  350. $params['userid'] = '8417';
  351. $params['operatorid'] = '1000000083421033115583773201';
  352. $params['status'] = 'SUCCESS';
  353. refill\RefillFactory::instance()->notify('xunyin',$params);
  354. }
  355. public function testLingzhPhone()
  356. {
  357. $providers = new refill\lingzh\RefillPhone([]);
  358. // $resp = $providers->add(18500608333, 5, 10, ['order_sn' => $this->make_sn()]);
  359. // $resp = $providers->query(['order_sn' => '59911615124025101286']);
  360. $resp = $providers->balance();
  361. // $input['usr'] = 1;
  362. // $input['ord'] = '52741615119546453690';
  363. // $input['bz'] = '';
  364. // $input['state'] = 2;
  365. // $input['sgn'] = 'FFCBB75C307154DD306F4EC75BB69A6D';
  366. // refill\RefillFactory::instance()->notify('lingzh',$input);
  367. }
  368. public function testAfandnewPhone()
  369. {
  370. $providers = new refill\afandnew\RefillPhone([]);
  371. // $resp = $providers->add(18500608333, 5, 100, ['order_sn' => $this->make_sn()]);
  372. // $resp = $providers->query(['order_sn' => '45371617101073876975', 'ch_trade_no' => '33018443659736309']);
  373. $params = '{"amount":"100","carrierOrderNo":null,"mobile":"18500608333","orderNo":"45371617101073876975","orderStatus":3,"sign":"8DE392AD6B4730AD9EE0FC2B95BBDF17","tradeNo":"33018443659736309"}';
  374. $input = json_decode($params, true);
  375. refill\RefillFactory::instance()->notify('afandnew', $input);
  376. }
  377. public function testYifaPhone()
  378. {
  379. $providers = new refill\yifa\RefillPhone([]);
  380. $resp = $providers->add(15120035568, 5, 50, ['order_sn' => $this->make_sn()]);
  381. }
  382. public function testTianjtOil()
  383. {
  384. $cardno = 1000111100021211884;
  385. $providers = new refill\tianjt\RefillOil([]);
  386. $resp = $providers->add($cardno, 2, 500, ['order_sn' => $this->make_sn()]);
  387. }
  388. public function testWeitPhone()
  389. {
  390. $providers = new refill\weit\RefillPhone([]);
  391. for ($i = 0; $i <= 10; $i++) {
  392. $resp = $providers->add(18500608333, 5, 10, ['order_sn' => $this->make_sn()]);
  393. }
  394. }
  395. public function testWeitCB()
  396. {
  397. $params['sign'] = 'af820c33472f4b571fa0c48483dfb975';
  398. $params['status'] = 0;
  399. $params['price'] = 30;
  400. $params['op_order_id'] = '';
  401. $params['mch_order_id'] = '900664281823957221';
  402. $params['pt_order_id'] = '2021011802434412825405218901';
  403. $params['pay_type'] = '';
  404. $params['tel'] = 18500608333;
  405. $params['mchid'] = 10014;
  406. $resp = http_request($this->mReqHost . "/mobile/refill_weit.php", $params, 'POST');
  407. }
  408. public function testYifaCB()
  409. {
  410. $body = '{"app_id":"e4a61b2acf1119c72c1ed9b61781494e","nonce_str":"OQMEBRQWJGPKOWYUXDVPTNMLEQJHXFWG","timestamp":1610275083,"order_sn":"161027325773032634","coder_order_sn":"60641610273255214687","isp_order_sn":null,"phone":"15120035568","amount":"94.000","discount":"0.9400","create_time":"2021-01-10 18:07:42","recharge_time":"","status":"fail","channel_id":3,"sign":"47278AD74EFA7F5FC8DE3A6D362C409B"}';
  411. $input = json_decode($body, true);
  412. refill\RefillFactory::instance()->notify('yifa', $input);
  413. }
  414. public function testBjbQuery()
  415. {
  416. $providers = new refill\bjb\RefillPhone([]);
  417. $refill_info = ['order_sn' => 110667993758599771, 'ch_trade_no' => 499, 'card_no' => 1000111200005252927];
  418. $resp = $providers->query($refill_info);
  419. }
  420. public function testXcQuery()
  421. {
  422. $providers = new refill\xc\RefillPhone([]);
  423. $refill_info = ['order_sn' => 950663423236726632, 'ch_trade_no' => 499, 'card_no' => 1000111200005252927];
  424. $resp = $providers->query($refill_info);
  425. }
  426. public function testTianjtQuery()
  427. {
  428. $providers = new refill\tianjt\RefillOil([]);
  429. $refill_info = ['order_sn' => 680665862267622221, 'ch_trade_no' => 499, 'card_no' => 1000111200005252927];
  430. $resp = $providers->query($refill_info);
  431. }
  432. public function testSaihuOil()
  433. {
  434. $providers = new refill\saihu\RefillOil([]);
  435. $resp = $providers->add(1000111100021211884, 2, 100, ['order_sn' => $this->make_sn()]);
  436. }
  437. public function testBdtOil()
  438. {
  439. $providers = new refill\bdt\RefillOil([]);
  440. $resp = $providers->add(1000111100021211884, 2, 100, ['order_sn' => '200229600556618886']);
  441. }
  442. public function testGFTDOil()
  443. {
  444. $providers = new refill\gftd\RefillOil([]);
  445. $resp = $providers->add(1000111100020445281, mtopcard\SinopecCard, 100, ['order_sn' => $this->make_sn()]);
  446. }
  447. public function testGFTDCB()
  448. {
  449. $data = '{"channelOrderNumber":"79091610959059372019","orderNumber":"GYFL1610959060397001","message":"充值成功","signature":"881036222bd8f067ff47d248c75f4c8d","voucher":"","status":101}';
  450. $url = "http://192.168.1.220/mobile/refill_gftd.php?" . $data;
  451. $resp = http_post_data($url, $data, ['Content-Type: application/json;charset=UTF-8;', 'Accept:application/json;charset=UTF-8;']);
  452. }
  453. public function testJiecPhone()
  454. {
  455. $providers = new refill\jiec\RefillPhone([]);
  456. $resp = $providers->add('18500608333', 5, 30, ['order_sn' => $this->make_sn()]);
  457. }
  458. public function testBxtwtCB()
  459. {
  460. $data = '{"order_number":18219726,"shipping_status":4,"shipping_status_desc":"发货失败","shipping_status_message":"","sign":"863b4d972f2a4d39a9af7396879116c4","voucher":"","vouchertype":"","voucherurl":"","tradeNo":"100662475851197741"}';
  461. }
  462. public function testTianjtJDVerify()
  463. {
  464. $data = 'onlystr=920661883198026632&sign=533151e3f0dff5f507786aabc37b18f7&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_tianjt.php&jdno&cardtype=Sinoepc&batchid=26106&cardno=1000111100020654226&orgid=1590993600&status=3';
  465. $url = "http://192.168.1.220/mobile/refill_tianjt.php?" . $data;
  466. $resp = http_request($url);
  467. }
  468. public function testSuhcPDD()
  469. {
  470. $data = 'onlystr=820663525320005221&pddno&sign=4b1e8645f7541ced34855779448d9d52&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhcpdd.php&cardtype=Sinoepc&batchid=3&cardno=1000111100020445281&orgid=1590993600&status=2';
  471. $url = "https://www.xyzshops.cn/mobile/refill_suhcpdd.php?" . $data;
  472. $resp = http_request($url);
  473. }
  474. public function testSuhcTMVerify()
  475. {
  476. $data = 'onlystr=180662473867058221&sign=5ff5f95d54a89e78dbb49923f6b20c08&amt=100&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhctm.php&cardtype=Sinoepc&batchid=3&cardno=1000111100020445281&orgid=1590993600&status=3';
  477. $url = "https://www.xyzshops.cn/mobile/refill_suhctm.php?" . $data;
  478. $resp = http_request($url);
  479. }
  480. public function testBeixtVerify()
  481. {
  482. $data = '{"order_number":18219726,"shipping_status":4,"shipping_status_desc":"发货失败","shipping_status_message":"","sign":"863b4d972f2a4d39a9af7396879116c4","voucher":"","vouchertype":"","voucherurl":"","tradeNo":"100662475851197741"}';
  483. $url = "https://www.xyzshops.cn/mobile/refill_bxtwt.php";
  484. $headers = ['Content-Type: application/json'];
  485. $resp = http_post_data($url, $data, $headers);
  486. }
  487. public function testInput()
  488. {
  489. $input = fopen("php://input", "rw");
  490. file_put_contents($input, 'xxxx');
  491. $content = file_get_contents('php://input');
  492. }
  493. public function testUrl()
  494. {
  495. $data = 'onlystr=190661874318128632&sign=9eb60765c356341fd41c9bec6526f46a&amt=1000&notifyurl=https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_suhc.php&jdno&cardtype=Sinoepc&batchid=25940&cardno=1000111100012304048&orgid=1590993600&status=2';
  496. $params = preg_split('/&/', $data);
  497. foreach ($params as $pair) {
  498. $kv = explode('=', $pair);
  499. $count = count($kv);
  500. if ($count === 1) {
  501. $key = $kv[0];
  502. $val = "";
  503. } elseif ($count === 2) {
  504. $key = $kv[0];
  505. $val = $kv[1];
  506. } else {
  507. continue;
  508. }
  509. Log::record("{$key}:{$val}", Log::DEBUG);
  510. }
  511. }
  512. public function testAddoil()
  513. {
  514. $url = $this->mReqHost . "/mobile/index.php";
  515. $notifyurl = 'http://121.89.196.45/mobile/signature.php';
  516. $params = ['mchid' => $this->mMchid,
  517. 'cardno' => '1000111100020445281',
  518. 'amount' => "100",
  519. "act" => "refill",
  520. "op" => "add",
  521. 'order_sn' => $this->make_sn(),
  522. 'notifyurl' => $notifyurl];
  523. $resp = $this->send_md5($url, $params);
  524. Log::record($resp, Log::DEBUG);
  525. }
  526. public function testBalance()
  527. {
  528. $url = $this->mReqHost . "/mobile/index.php";
  529. $params = ['mchid' => 1092,
  530. "act" => "refill",
  531. "op" => "balance"];
  532. $resp = $this->send_md5($url, $params);
  533. Log::record($resp, Log::DEBUG);
  534. }
  535. public function testAddPhoe()
  536. {
  537. $phones = [//13911129867,
  538. 18500608333,
  539. 18510683168,
  540. 18513846008,
  541. 18518237398];
  542. $amount = 10;
  543. for ($i = 0; $i < 3; $i++) {
  544. foreach ($phones as $phone) {
  545. $url = $this->mReqHost . "/mobile/index.php";
  546. $params = ['mchid' => 1092,
  547. 'cardno' => $phone,
  548. 'amount' => $amount,
  549. "act" => "refill",
  550. "op" => "add",
  551. 'order_sn' => $this->make_sn(),
  552. 'notifyurl' => $this->mReqHost . "/mobile/refill_xyz.php"];
  553. $resp = $this->send_md5($url, $params);
  554. Log::record($resp, Log::DEBUG);
  555. }
  556. }
  557. }
  558. public function testProxyHelper()
  559. {
  560. $phone = '13911129867';
  561. $amount = 100;
  562. $url = $this->mReqHost . "/mobile/index.php";
  563. $params = ['mchid' => 1090,
  564. 'cardno' => $phone,
  565. 'amount' => $amount,
  566. "act" => "refill",
  567. "op" => "add",
  568. 'order_sn' => $this->make_sn(),
  569. 'notifyurl' => "https://xxx"];
  570. $proxy = new refill_proxy("xxx");
  571. $resp = $proxy->send($url, $params);
  572. }
  573. public function testGoods()
  574. {
  575. $req_url = $this->mReqHost . '/mobile/index.php';
  576. $params = ['mchid' => $this->mMchid,
  577. "act" => "refill",
  578. "op" => "goods"];
  579. $resp = $this->send_md5($req_url, $params);
  580. }
  581. public function testQueryFactory()
  582. {
  583. refill\RefillFactory::instance()->query(295);
  584. }
  585. public function testQuery()
  586. {
  587. //$req_url = 'https://www.xyzshops.cn/mobile/index.php';
  588. // $notifyurl = 'https://www.xyzshops.cn/mobile/signature.php';
  589. $req_url = BASE_SITE_URL . '/mobile/index.php';
  590. $notifyurl = 'https://www.xyzshops.cn/mobile/signature.php';
  591. $params = ['mchid' => 1,
  592. "act" => "refill",
  593. "op" => "query",
  594. 'order_sn' => "13281476"];
  595. $resp = $this->send_md5($req_url, $params);
  596. }
  597. public function testRemoveSession()
  598. {
  599. $resp = http_request(BASE_SITE_URL . "/mobile/signature.php", [], 'POST');
  600. }
  601. public function testTianjtCB()
  602. {
  603. // $notifyurl = BASE_SITE_URL . "/mobile/refill_tianjt.php";
  604. $notifyurl = "https://www.xyzshops.cn/mobile/refill_tianjt.php";
  605. // $notifyurl = "https%3A%2F%2Fwww.xyzshops.cn%2Fmobile%2Frefill_tianjt.php";
  606. $params = ['onlystr' => '690665858589475818',
  607. 'amt' => 1000,
  608. 'jdno' => '',
  609. 'notifyurl' => $notifyurl,
  610. 'cardtype' => 'Sinoepc',
  611. 'batchid' => 30589,
  612. 'cardno' => '1000113300007993287',
  613. 'orgid' => '1590993600',
  614. 'status' => 3];
  615. $sign = $this->md5_sign($params);
  616. $params['sign'] = $sign;
  617. $resp = http_request($notifyurl, $params, 'POST');
  618. Log::record($resp, Log::DEBUG);
  619. }
  620. public function testBJBCB()
  621. {
  622. $params = [
  623. 'usr' => '13699279618',
  624. 'ord' => '710662733975412771',
  625. 'state' => '2',
  626. 'bz' => '',
  627. 'sgn' => 'AC9AFD254DE682D8440A97CA68B992DA'
  628. ];
  629. $resp = http_request("https://www.xyzshops.cn/mobile/refill_bjb.php", $params, 'POST');
  630. }
  631. public function testJiecCB()
  632. {
  633. $params['result'] = 'fail';
  634. $params['msg'] = '0';
  635. $params['order'] = 'null';
  636. $params['phone_no'] = '18500608333';
  637. $params['amount'] = '30.00';
  638. $params['op_no'] = '800663597981819221';
  639. $params['sign'] = '2510046895e8e12322c8a32547905ee9';
  640. $resp = http_request($this->mReqHost . "/mobile/refill_jiec.php", $params, 'POST');
  641. }
  642. public function testZFKJ()
  643. {
  644. //带签名参数:mchid=1090&act=refill&op=add&cardno=100112121212212133
  645. //&amount=10&order_sn=PH2012261356569433&
  646. //notifyurl=https%3A%2F%2Fqzcz.edusahoo.com.cn%2Findex%2Findex%2Fcallback
  647. //&sign=4a3ac5f9706e64aa70c6cab0fc5839d3
  648. $params = ['mchid' => 1090,
  649. 'cardno' => '100112121212212133',
  650. 'amount' => '10',
  651. "act" => "refill",
  652. "op" => "add",
  653. 'order_sn' => 'PH2012261356569433',
  654. 'notifyurl' => 'https://qzcz.edusahoo.com.cn/index/index/callback'];
  655. $resp = $this->send_md5(BASE_SITE_URL . '/mobile/index.php', $params);
  656. }
  657. protected function check_empty($value)
  658. {
  659. if (!isset($value))
  660. return true;
  661. if ($value === null)
  662. return true;
  663. if (trim($value) === "")
  664. return true;
  665. return false;
  666. }
  667. public function testcreateSign()
  668. {
  669. $params['act'] = 'refill';
  670. $params['amount'] = '100';
  671. $params['cardno'] = '1000111200006005872';
  672. $params['mchid'] = '1092';
  673. $params['notifyurl'] = 'http://202.85.213.156:8080//YeZiYKCallBackOrderServlet';
  674. $params['op'] = 'balance';
  675. $params['order_sn'] = 'jftest0000123';
  676. $sign = $this->md5_sign($params);
  677. }
  678. public function testCheckphone()
  679. {
  680. $check = function ($phone) {
  681. $url = 'https://mobileempty.shumaidata.com/mobileempty';
  682. $params['mobile'] = $phone;
  683. $headers = array();
  684. array_push($headers, "Authorization:APPCODE " . '8f92d951293f4d2ea48ff86d5a70c537');
  685. $resp = http_request($url, $params, 'GET', false, $headers);
  686. $resp = json_decode($resp, true);
  687. if ($resp['success'] == true && $resp['code'] == 200) {
  688. Log::record("data phone:{$phone} , status : {$resp['data']['status']}", Log::DEBUG);
  689. if (in_array($resp['data']['status'], [0, 3, 4, 5])) {
  690. return false;
  691. }
  692. } else {
  693. Log::record("data phone:{$phone} , 不支持的号段", Log::DEBUG);
  694. }
  695. };
  696. $check(17801048874);
  697. }
  698. public function testCtSign()
  699. {
  700. $params['act'] = 'refill';
  701. $params['mchid'] = 12345;
  702. $params['op'] = 'goods';
  703. $sign = $this->md5_sign($params);
  704. }
  705. private function md5_sign($params)
  706. {
  707. ksort($params);
  708. $body = "";
  709. $i = 0;
  710. foreach ($params as $k => $v) {
  711. if (false === $this->check_empty($v) && "@" != substr($v, 0, 1)) {
  712. if ($i == 0) {
  713. $body .= "{$k}" . "=" . urlencode($v);
  714. } else {
  715. $body .= "&" . "{$k}" . "=" . urlencode($v);
  716. }
  717. $i++;
  718. }
  719. }
  720. $body .= "&key=12345";
  721. return md5($body);
  722. }
  723. public function testCallMech()
  724. {
  725. $logic = Logic('queue');
  726. $logic->NotifyMerchantComplete(['order_id' => 18171, 'manual' => true]);
  727. }
  728. //docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestRefill::testCallMech)( .*)?$/" --test-suffix TestRefill.php /var/www/html/test
  729. private function send($url, $params)
  730. {
  731. $mchid = $params['mchid'];
  732. $pri_key = BASE_DATA_PATH . "/api/merchant/key/{$mchid}_pri.pem";
  733. $key = file_get_contents($pri_key);
  734. $pri = openssl_get_privatekey($key);
  735. $body = $this->body($params);
  736. openssl_sign($body, $signed, $pri);
  737. $sign = base64_encode($signed);
  738. $params['sign'] = $sign;
  739. $resp = http_request($url, $params, 'POST');
  740. Log::record("resp:{$resp}", Log::DEBUG);
  741. }
  742. private function send_md5($url, $params)
  743. {
  744. $body = $this->body($params);
  745. $body .= "&key={$this->mKey}";
  746. $params['sign'] = md5($body);
  747. $resp = http_request($url, $params, 'POST');
  748. Log::record("resp:{$resp}", Log::DEBUG);
  749. return $resp;
  750. }
  751. public function testCardType()
  752. {
  753. $cardno = '1000111100021211884';
  754. $ret = preg_match('/^1[0-9]{18}$/', $cardno, $matches);
  755. }
  756. public function testMtrand()
  757. {
  758. }
  759. public function testHttpRefill()
  760. {
  761. $mchid = '000001';
  762. $pri_key = BASE_DATA_PATH . "/api/merchant/key/{$mchid}_pri.pem";
  763. $key = file_get_contents($pri_key);
  764. $pri = openssl_get_privatekey($key);
  765. $params = ['MCHID' => $mchid, 'cardno' => '1000111100021211884', 'amt' => "100", "act" => "refill", "op" => "addoil"];
  766. $body = $this->body($params);
  767. openssl_sign($body, $signed, $pri);
  768. $sign = base64_encode($signed);
  769. $params['sign'] = $sign;
  770. $resp = http_request(BASE_SITE_URL . "/mobile/index.php", $params, 'POST');
  771. }
  772. private function body($params)
  773. {
  774. ksort($params);
  775. $body = "";
  776. $i = 0;
  777. foreach ($params as $k => $v) {
  778. if (false === $this->checkEmpty($v) && "@" != substr($v, 0, 1)) {
  779. if ($i == 0) {
  780. $body .= "{$k}" . "=" . urlencode($v);
  781. } else {
  782. $body .= "&" . "{$k}" . "=" . urlencode($v);
  783. }
  784. $i++;
  785. }
  786. }
  787. return $body;
  788. }
  789. private function checkEmpty($value)
  790. {
  791. if (!isset($value))
  792. return true;
  793. if ($value === null)
  794. return true;
  795. if (trim($value) === "")
  796. return true;
  797. return false;
  798. }
  799. public function testKsort()
  800. {
  801. $age = ["Peter" => "35", "Ben" => "37", "Joe" => "43"];
  802. ksort($age);
  803. foreach ($age as $x => $x_value) {
  804. echo "Key=" . $x . ", Value=" . $x_value;
  805. echo "<br>";
  806. }
  807. }
  808. public function testip()
  809. {
  810. $model_merchant = Model('merchant');
  811. $merchant_info = $model_merchant->getMerchantInfo(['mchid' => 1]);
  812. $ipwhitelist = unserialize($merchant_info['ip_white_list']);
  813. $res = json_encode($ipwhitelist);
  814. }
  815. //测试向内部店提交订单,可先屏蔽其它充值通道
  816. public function testAddoilToInnerStore()
  817. {
  818. $url = $this->mReqHost . "/mobile/index.php";
  819. $notifyurl = BASE_SITE_URL . '/mobile/signature.php';
  820. $params = ['mchid' => 1,
  821. 'cardno' => '1000111100020445281',
  822. 'amount' => "1000",
  823. "act" => "refill",
  824. "op" => "add",
  825. 'order_sn' => $this->make_sn(),
  826. 'notifyurl' => $notifyurl];
  827. $resp = $this->send_md5($url, $params);
  828. Log::record($resp, Log::DEBUG);
  829. }
  830. public function testRefillInnerCB()
  831. {
  832. $params = ['state_type' => 'order_cancel', 'order_id' => 311, 'channel_name' => 'lx'];
  833. $resp = http_request(BASE_SITE_URL . '/mobile/refill_inner.php', $params, 'POST');
  834. }
  835. public function testArgs()
  836. {
  837. Log::record($_SERVER['argv'], Log::DEBUG);
  838. }
  839. public function testCall()
  840. {
  841. $order_id = 14974;
  842. QueueClient::async_push("NotifyMerchantComplete", ['order_id' => $order_id, 'manual' => true], 10);
  843. }
  844. public function testSyncconfig()
  845. {
  846. $name_val_cfg = function ($items) {
  847. $result = [];
  848. foreach ($items as $item) {
  849. $name = $item->name();
  850. $result[$name] = $item;
  851. }
  852. return $result;
  853. };
  854. $name_val_row = function ($items) {
  855. $result = [];
  856. foreach ($items as $item) {
  857. $name = $item['name'];
  858. $result[$name] = $item;
  859. }
  860. return $result;
  861. };
  862. $match = function ($all, $cur) {
  863. $insert = [];
  864. foreach ($all as $key => $value) {
  865. if (!array_key_exists($key, $cur)) {
  866. $insert[] = $key;
  867. }
  868. }
  869. return $insert;
  870. };
  871. $inserter = function ($mod, $type, $names) {
  872. foreach ($names as $name) {
  873. $data = ['name' => $name, 'type' => $type];
  874. $mod->insert($data);
  875. }
  876. };
  877. $providers = refill\RefillFactory::instance()->providers();
  878. $oils = $name_val_cfg($providers['oil']);
  879. $phones = $name_val_cfg($providers['phone']);
  880. $mod_prov = Model('refill_provider');
  881. $oil_items = $mod_prov->getProviderList(['type' => 1]);
  882. $oil_items = $name_val_row($oil_items);
  883. $oil_inserts = $match($oils, $oil_items);
  884. $phone_items = $mod_prov->getProviderList(['type' => 2]);
  885. $phone_items = $name_val_row($phone_items);
  886. $phone_inserts = $match($phones, $phone_items);
  887. $inserter($mod_prov, 1, $oil_inserts);
  888. $inserter($mod_prov, 2, $phone_inserts);
  889. }
  890. public function testStat()
  891. {
  892. $model_refill_order = Model('refill_order');
  893. $stat = Model('')->table('refill_order,vr_order')->join('inner')
  894. ->on('refill_order.order_id=vr_order.order_id')
  895. ->field('sum(refill_amount) as refill_amounts , sum(channel_amount) as channel_amounts , sum(mch_amount) as mch_amounts')
  896. ->where([])->select();
  897. }
  898. public function testRefillGoods()
  899. {
  900. $goods = refill\RefillFactory::instance()->goods();
  901. }
  902. private function make_mobile()
  903. {
  904. $no = "1" . mt_rand(3000000000, 3999999999);
  905. return $no;
  906. }
  907. private function refill_info($card_no, $card_type)
  908. {
  909. $data = rcache($card_no, 'cardrefill-');
  910. if (empty($data)) {
  911. $mod_topcard = Model('topcard');
  912. $ret = $mod_topcard->get_card($card_no);
  913. if (empty($ret)) {
  914. $bind_phone = $this->make_mobile();
  915. $mod_topcard->add($card_no, $card_type, time(), $bind_phone);
  916. $data['bind_phone'] = $bind_phone;
  917. $data['refill_time'] = time();
  918. $data['times'] = 0;
  919. wcache($card_no, $data, 'cardrefill-');
  920. } else {
  921. $val = $ret[0];
  922. $data['bind_phone'] = $val['bind_phone'];
  923. $data['refill_time'] = time();
  924. $data['times'] = 0;
  925. }
  926. }
  927. return $data;
  928. }
  929. public function testGetMobile()
  930. {
  931. $card_no = '1000119000001679247';
  932. $card_type = 1;
  933. $info = $this->refill_info($card_no, $card_type);
  934. }
  935. private function check_mchorder($mchid, $mch_order)
  936. {
  937. if (empty($mch_order)) {
  938. return true;
  939. } else {
  940. $refill_order = Model('refill_order');
  941. $ret = $refill_order->getOrderInfo(['mchid' => $mchid, 'mch_order' => $mch_order]);
  942. return empty($ret);
  943. }
  944. }
  945. public function testCheckMchorder()
  946. {
  947. $ret = $this->check_mchorder(1, '13281475');
  948. }
  949. public function testMakemobile()
  950. {
  951. $mobile = refill\util::make_mobile();
  952. $ret = refill\util::set_black('1000111100020445281');
  953. }
  954. public function testLoadBlack()
  955. {
  956. $path = BASE_DATA_PATH . "/log";
  957. $names = ['20210119-mobile.log',
  958. '20210120-mobile.log', '20210121-mobile.log', '20210122-mobile.log', '20210123-mobile.log',
  959. '20210124-mobile.log', '20210125-mobile.log'];
  960. foreach ($names as $name) {
  961. $file_name = $path . "/" . $name;
  962. refill\util::black_from_log($file_name);
  963. }
  964. }
  965. public function testStats()
  966. {
  967. $date = date('Y-m-d', time());
  968. $today = strtotime("{$date}");
  969. $times_begin = function ($start) {
  970. $times = [];
  971. $begin = $start;
  972. for ($i = 0; $i < 7; $i++) {
  973. $times[] = $begin;
  974. $begin -= 86400;
  975. }
  976. return $times;
  977. };
  978. $reader = function ($mchid, $time) {
  979. $cond['mchid'] = $mchid;
  980. $cond['inner_status'] = 0;
  981. $cond['refill_order.order_time'] = ['between', [$time, $time + 86400 - 1]];
  982. $items = Model('')->table('refill_order,vr_order')->join('inner')
  983. ->on('refill_order.order_id=vr_order.order_id')
  984. ->field('count(*) as order_count, vr_order.order_state, sum(mch_amount) as mch_amounts')
  985. ->group('vr_order.order_state')
  986. ->where($cond)->select();
  987. return $items;
  988. };
  989. $begins = $times_begin($today);
  990. $mchid = 10096;
  991. // $states = rcache($this->mchid() , 'refillstat-');
  992. $states = unserialize($states ?? "");
  993. if (empty($states)) $states = [];
  994. $result = [];
  995. $cache = [];
  996. foreach ($begins as $begin) {
  997. if (array_key_exists($begin, $states)) {
  998. $item = $states[$begin];
  999. } else {
  1000. $item = $reader($mchid, $begin);
  1001. }
  1002. $result[$begin] = $item;
  1003. //判断item 中充值中的状态是否为0,为0的情况下放进cache
  1004. $cache = $item;
  1005. }
  1006. wcache($this->mchid(), $cache, 'refillstat-');
  1007. return $result;
  1008. }
  1009. public function testNotifyx()
  1010. {
  1011. $mch_cache = rcache("merchant-notify", 'refill-');
  1012. $caches = empty($mch_cache['data']) ? [] : unserialize($mch_cache['data']);
  1013. $new_caches = [];
  1014. $merchants = Model('merchant')->getMerchantList([], '', '', 'merchant.*,member.available_predeposit', "0,1000");
  1015. foreach ($merchants as $merchant) {
  1016. $mchid = $merchant['mchid'];
  1017. $phone = $merchant['contact_phone'] ?? "";
  1018. $available_pd = intval($merchant['available_predeposit']);
  1019. $alarm_pd = intval($merchant['alarm_amount']) < 10000 ? 10000 : intval($merchant['alarm_amount']);
  1020. if (array_key_exists($mchid, $caches)) {
  1021. $mch_cache = $caches[$mchid];
  1022. } else {
  1023. $mch_cache = ['last_time' => 0, 'send_count' => 0];
  1024. }
  1025. if (!empty($phone) && ($available_pd < $alarm_pd)) {
  1026. $counts = $mch_cache['send_count'];
  1027. if (($mch_cache['last_time'] + 300 < time()) && $counts < 5) {
  1028. $mch_cache = ['last_time' => time(), 'send_count' => $counts + 1];
  1029. QueueClient::push('sendSMS', ['mobile' => $merchant['contact_phone'],
  1030. 'type' => 'balance_warning', 'datas' => [date("m月d日H时"), $merchant['available_predeposit']]]);
  1031. }
  1032. } else {
  1033. $mch_cache = ['last_time' => 0, 'send_count' => 0];
  1034. }
  1035. $new_caches[$mchid] = $mch_cache;
  1036. }
  1037. wcache("merchant-notify", ['data' => serialize($new_caches)], 'refill-');
  1038. }
  1039. public function testReadChannel()
  1040. {
  1041. refill\RefillFactory::instance()->read_channel();
  1042. }
  1043. public function testAllow()
  1044. {
  1045. $allow = refill\RefillFactory::instance()->allow(10096, 1, 100);
  1046. }
  1047. public function testCheckData()
  1048. {
  1049. $str = '|2|110667993758599771-充值失败|';
  1050. // $str = '0|提交成功|-36557.7400';
  1051. // if(preg_match( '/^-*[0-9]{1,3}\|[\x{4e00}-\x{9fa5}]+\|-*[0-9]+\.*[0-9]+$/u',$str,$matches)) {
  1052. // return true;
  1053. // }
  1054. // if(preg_match('/^[0-3]\|[0-9]+-*[\x{4e00}-\x{9fa5}]+\|[0-9]*$/u',$str,$matches)){
  1055. // return true;
  1056. // }
  1057. // return false;
  1058. $resp = ltrim($str, '|');
  1059. $resp = explode('|', $resp);
  1060. if (count($resp) != 3) {
  1061. return [false, '返回值错误'];
  1062. }
  1063. }
  1064. public function testErrre()
  1065. {
  1066. $line = '[13 2021-01-24 16:07:03] DEBUG: type = application/json;charset=utf-8, content={"channelOrderNumber":"610664819621371793","orderNumber":"GYFL1611475621525437","message":"充值失败","signature":"6c28c15b9ce2b2243742ecebbd929ac5","status":109}';
  1067. $ret = preg_match('/[\w\W]+"channelOrderNumber":"(?P<order_sn>[^"]+)"[\w\W]+"message":"(?P<message>[\x{4e00}-\x{9fa5}]+)"[\w\W]+"status":109/u', $line, $matches);
  1068. }
  1069. public function testLog()
  1070. {
  1071. // $line = './LOG/20210203-mobile.log:[15 2021-02-03 10:41:17] SQL: UPDATE `lrlz_member` SET available_predeposit=available_predeposit+975 WHERE ( member_id = \'65818\' ) [ RunTime:0.000297s ]';
  1072. $fn = fopen(BASE_ROOT_PATH . "/10096.log", "r");
  1073. $mod = Model();
  1074. $mod->table('tfloat')->where(['member_id' => 65818])->update(['pdamount' => 0]);
  1075. $total_amount = ncPriceFormat(0.00);
  1076. $i = 0;
  1077. while (!feof($fn)) {
  1078. $i++;
  1079. $line = trim(fgets($fn));
  1080. $ret = preg_match('/[\w\W]+UPDATE[\w\W]+available_predeposit=available_predeposit(?P<oper>[-+]+)(?P<amount>[.\d]+)/i', $line, $matches);
  1081. if ($ret) {
  1082. $oper = $matches['oper'];
  1083. $amount = $matches['amount'];
  1084. if ($oper == '-') {
  1085. $total_amount = ncPriceFormat($total_amount) - ncPriceFormat($amount);
  1086. // $mod->table('tfloat')->where(['member_id' => 65818])->update( ['pdamount'=>['exp','pdamount-'.$amount]]);
  1087. } else {
  1088. $total_amount = ncPriceFormat($total_amount) + ncPriceFormat($amount);
  1089. // $mod->table('tfloat')->where(['member_id' => 65818])->update( ['pdamount'=>['exp','pdamount+'.$amount]]);
  1090. }
  1091. Log::record("index = {$i} {$total_amount} = {$total_amount} {$oper} {$amount}", Log::DEBUG);
  1092. }
  1093. }
  1094. Log::record("total_amount:{$total_amount}", Log::DEBUG);
  1095. fclose($fn);
  1096. }
  1097. public function testMchctl()
  1098. {
  1099. $ctl = new refill\mchctl();
  1100. }
  1101. }
  1102. //docker-compose run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestRefill::testLoadBlack)( .*)?$/" --test-suffix TestRefill.php /var/www/html/test
  1103. //docker-compose -f ./docker-compose-dev.yml run phpcli php /var/www/html/phpunit-9.2.5.phar --filter "/(TestRefill::testCall)( .*)?$/" --test-suffix TestRefill.php /var/www/html/test