TestController.php 42 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009
  1. <?php
  2. namespace ghs\controllers;
  3. use biz\ghs\classes\GhsClass;
  4. use biz\shop\classes\ShopClass;
  5. use biz\sj\services\MerchantService;
  6. use biz\wx\classes\WxMessageClass;
  7. use bizGhs\custom\classes\CustomClass;
  8. use bizGhs\custom\classes\CustomDebtChangeClass;
  9. use bizGhs\express\services\DadaExpressServices;
  10. use bizGhs\order\classes\OrderClass;
  11. use bizGhs\order\classes\RefundOrderClass;
  12. use bizHd\message\classes\InformAdminClass;
  13. use bizHd\order\services\OrderService;
  14. use bizHd\purchase\classes\PurchaseClass;
  15. use bizHd\purchase\classes\PurchaseClearClass;
  16. use bizHd\wx\classes\WxOpenClass;
  17. use bizGhs\express\services\MiniExpressService;
  18. use common\components\arrayUtil;
  19. use common\components\dict;
  20. use common\components\lakala\Lakala;
  21. use common\components\miniUtil;
  22. use common\components\noticeUtil;
  23. use common\components\orderSn;
  24. use common\components\wxUtil;
  25. use common\components\payUtil;
  26. use Yii;
  27. use common\components\util;
  28. class TestController extends BaseController
  29. {
  30. public $guestAccess = ['clear-query', 'ip', 'debt', 'apply', 'clear', 'ls-trade-query', 'refund-query', 'inform', 'notice', 'order-query', 'add-order', 'index', 'get', 'trade-query', 'query', 'balance-query', 'refund'];
  31. public function actionIp()
  32. {
  33. $ip = $_SERVER['SERVER_ADDR'] ?? '';
  34. echo $ip;
  35. }
  36. //欠款的查询与跟踪 ssh 20240103
  37. public function actionDebt()
  38. {
  39. $customId = 17081;
  40. $custom = CustomClass::getById($customId, true);
  41. if (empty($custom)) {
  42. echo '没有找到客户';
  43. die;
  44. }
  45. $flag = [];
  46. $changeList = CustomDebtChangeClass::getAllByCondition(['customId' => $customId], null, '*');
  47. if (!empty($changeList)) {
  48. foreach ($changeList as $change) {
  49. $event = $change['evnet'] ?? '';
  50. $relateId = $change['relateId'] ?? 0;
  51. $amount = $change['amount'] ?? 0;
  52. if (strpos($event, '购买花材') >= 0) {
  53. $flag['40-' . $relateId] = $amount;
  54. }
  55. if (strpos($event, '退款') >= 0) {
  56. $flag['33-' . $relateId] = $amount;
  57. }
  58. if (strpos($event, '结账') >= 0) {
  59. $flag['20-' . $relateId] = $amount;
  60. }
  61. }
  62. }
  63. print_r($flag);
  64. $orderList = OrderClass::getAllByCondition(['customId' => $customId, 'debtPrice>' => 0], null, 'id,actPrice,payTime', null);
  65. $arr = [];
  66. if (!empty($orderList)) {
  67. foreach ($orderList as $order) {
  68. $payTime = $order['payTime'] ?? '';
  69. $id = $order['id'] ?? 0;
  70. $arr[$payTime] = $order;
  71. if (isset($flag['40-' . $id]) == false) {
  72. echo '40-' . $id . "订单有问题\n";
  73. }
  74. }
  75. }
  76. //20
  77. $clearList = PurchaseClearClass::getAllByCondition(['customId' => $customId, 'status' => 2], null, 'id,actPrice,payTime', null);
  78. if (!empty($clearList)) {
  79. foreach ($clearList as $clear) {
  80. $payTime = $clear['payTime'] ?? '';
  81. $id = $clear['id'] ?? 0;
  82. $arr[$payTime] = $clear;
  83. if (isset($flag['20-' . $id]) == false) {
  84. echo '20-' . $id . "结账有问题\n";
  85. }
  86. }
  87. }
  88. //33
  89. $refundList = RefundOrderClass::getAllByCondition(['customId' => $customId], null, 'id,refundPrice,updateTime', null);
  90. if (!empty($refundList)) {
  91. foreach ($refundList as $refund) {
  92. $id = $refund['id'] ?? 0;
  93. $updateTime = $refund['updateTime'] ?? '';
  94. $arr[$updateTime] = $refund;
  95. if (isset($flag['33-' . $id]) == false) {
  96. echo '33-' . $id . "退款单有问题\n";
  97. }
  98. }
  99. }
  100. echo "<pre>";
  101. ksort($arr);
  102. print_r($arr);
  103. die;
  104. }
  105. //退款操作 ssh 20231029
  106. public function actionRefund()
  107. {
  108. $shopId = 36524;
  109. $shop = ShopClass::getById($shopId, true);
  110. if (empty($shop)) {
  111. util::fail('没有找到门店');
  112. }
  113. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  114. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  115. $params = [
  116. 'appid' => 'OP00002119',
  117. 'serial_no' => '018b08cfddbd',
  118. 'merchant_no' => $shop->lklSjNo,
  119. 'term_no' => $shop->lklB2BTermNo,
  120. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  121. 'lklCertificatePath' => $lklCertificatePath,
  122. ];
  123. $laResource = new Lakala($params);
  124. $refundReason = '暂无';
  125. $refundOrderSn = orderSn::getCgRefundSn();
  126. $refundPrice = 0.01;
  127. $refundFee = bcmul($refundPrice, 100);
  128. $orderSn = 'KD_CS61235203';
  129. $originTradeNo = '20231030110113230266215266468756';
  130. //$originLogNo = '66215266025626';
  131. $aliParams = [
  132. 'refundSn' => $refundOrderSn,
  133. 'orderSn' => $orderSn,
  134. 'refundAmount' => $refundFee,
  135. 'refundReason' => $refundReason,
  136. 'originTradeNo' => $originTradeNo,
  137. //'originLogNo' => $originLogNo,
  138. ];
  139. $response = $laResource->refund($aliParams);
  140. echo '<pre>';
  141. print_r($response);
  142. }
  143. public function actionApply()
  144. {
  145. $id = 2888;
  146. $shopId = 36524;
  147. $cg = PurchaseClass::getById($id, true);
  148. $shop = ShopClass::getById($shopId, true);
  149. WxMessageClass::hdNewCgOrderInform($shop, $cg);
  150. }
  151. public function actionGet()
  152. {
  153. ini_set('memory_limit', '2045M');
  154. set_time_limit(0);
  155. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  156. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  157. $arr = [
  158. //['name' => '国兰花尚OK', 'merchantNo' => '82239305992006L', 'wx' => [600913569, 600907053], 'zfb' => '2088820709029782'],
  159. //['name' => '花掌柜OK', 'merchantNo' => '82240505992000P', 'wx' => [600466131, 600465187], 'zfb' => '2088820656569304'],
  160. //['name' => '纯彩花艺OK', 'merchantNo' => '82239305992006M', 'wx' => [600922790, 600915407], 'zfb' => '2088820710146836'],
  161. //['name' => '集美天天鲜花OK', 'merchantNo' => '82239305992006P', 'wx' => [601036538, 601036322], 'zfb' => '2088820726763339'],
  162. //['name' => '丰行花行OK', 'merchantNo' => '82260205992007P', 'wx' => [601053759, 601052157], 'zfb' => '2088820725885465'],
  163. //['name' => '独家花行OK', 'merchantNo' => '82239305992006Q', 'wx' => [601049483, 601048223], 'zfb' => '2088820725546555'],
  164. //['name' => '好多花海沧OK', 'merchantNo' => '82239305992006R', 'wx' => [601052177, 601053735], 'zfb' => '2088820725549695'],
  165. //['name' => '美天鲜花OK', 'merchantNo' => '82259505992003F', 'wx' => [601062064, 601138175], 'zfb' => '2088820729400990'],
  166. //['name' => '天天陈江店OK', 'merchantNo' => '82259505992003E', 'wx' => [601060616, 601059382], 'zfb' => '2088820725555368'],
  167. //['name' => '叶上花OK', 'merchantNo' => '82231805992002G', 'wx' => [601062892, 601062589], 'zfb' => '2088820728763546'],
  168. //['name' => '好又多(小明)OK', 'merchantNo' => '82239305992006S', 'wx' => [601135715, 601067347], 'zfb' => '2088820729698012'],
  169. //['name' => '我卖花OK', 'merchantNo' => '82227505992000R', 'wx' => [601177139, 601148755], 'zfb' => '2088820746424032'],
  170. //['name' => '问境OK', 'merchantNo' => '8226900599200KX', 'wx' => [601299388, 601299453], 'zfb' => '2088820787661843'],
  171. //['name' => '昱成OK', 'merchantNo' => '8226900599200KY', 'wx' => [601312993, 601325844], 'zfb' => '2088820788900240'],
  172. //['name' => '杭州斗南', 'merchantNo' => '杭州斗南', 'wx' => [601405963, 601405929], 'zfb' => '2088820793601705'],
  173. //['name' => '杭州斗南(没用)', 'merchantNo' => '8223310599200AD', 'wx' => [601254682, 601250805], 'zfb' => '2088820782666872'],
  174. //['name' => '珑松花卉长安店', 'merchantNo' => '82260205992007U', 'wx' => [602499045, 602497558], 'zfb' => '2088820959620797'],
  175. //['name' => '福州花福(个人)', 'merchantNo' => '82239105992007P', 'wx' => [603301197, 603302321], 'zfb' => '2088920058098261'],
  176. //['name' => '福州花福', 'merchantNo' => '82239105992007N', 'wx' => [602796807, 602774796], 'zfb' => '2088820996010582'],
  177. //['name' => '昆明新宏源', 'merchantNo' => '82239305992007H', 'wx' => [606098318, 606100317], 'zfb' => '2088920878302843'],
  178. //['name' => '昆明纯彩', 'merchantNo' => '82239905992003L', 'wx' => [604923629, 604922175], 'zfb' => '2088920533160795'],
  179. //['name' => '花优田(军兴旺)', 'merchantNo' => '8227310599200GX', 'wx' => [605191281, 605190492], 'zfb' => '2088920588715249'],
  180. ['name' => '昆明期待鲜花', 'merchantNo' => '8227310599200J6', 'wx' => [615582300, 615582180], 'zfb' => '2088530113958388'],
  181. ['name' => '厦门遇见你', 'merchantNo' => '82239305992008D', 'wx' => [614782373, 614783346], 'zfb' => '2088430828233036'],
  182. //['name' => '淄博花超鲜花批发', 'merchantNo' => '82245305992001R', 'wx' => [614685779, 614682986], 'zfb' => '2088430805221810'],
  183. //['name' => '广州国恋', 'merchantNo' => '8225810599200Q7', 'wx' => [612321716, 612320978], 'zfb' => '2088330479975012'],
  184. //['name' => '欣研鲜花', 'merchantNo' => '82260305992001Y', 'wx' => [612181234, 612181615], 'zfb' => '2088330365608286'],
  185. //['name' => '村长冷链', 'merchantNo' => '82260205992008G', 'wx' => [612168406, 612168000], 'zfb' => '2088330360870932'],
  186. //['name' => '惠州惠雅鲜花批发', 'merchantNo' => '82259505992003S', 'wx' => [611676975, 611677314], 'zfb' => '2088330136601427'],
  187. //['name' => '杭州斗南鲜花', 'merchantNo' => '8223310599200AR', 'wx' => [608955814, 608955082], 'zfb' => '2088130449323603'],
  188. //['name' => '营口简约花卉', 'merchantNo' => '8227310599200HJ', 'wx' => [608439898, 608440994], 'zfb' => '2088130112725929'],
  189. //['name' => '惠雅鲜花惠州店', 'merchantNo' => '82260205992007Z', 'wx' => [608406948, 608403207], 'zfb' => '2088130098167302'],
  190. //['name' => '云南珑松花卉珠海店', 'merchantNo' => '82258505992002U', 'wx' => [608062727, 608056474], 'zfb' => '2088030873238576'],
  191. //['name' => '买手很忙', 'merchantNo' => '8227310599200GJ', 'wx' => [601597167, 601595526], 'zfb' => '2088820818930267'],
  192. //['name' => '七彩花都', 'merchantNo' => '8227310599200GF', 'wx' => [601176481, 601148503], 'zfb' => '2088820748594478'],
  193. //['name' => '十年', 'merchantNo' => '82252305992001U', 'wx' => [601285154, 601261795], 'zfb' => '2088820782171763'],
  194. //['name' => '都市花季OK', 'merchantNo' => '82239305992006U', 'wx' => [601174342, 601147649], 'zfb' => '2088820748507346'],
  195. //['name' => '花样年华OK', 'merchantNo' => '82260205992007Q', 'wx' => [601134352, 601091710], 'zfb' => '2088820735043444'],
  196. //['name' => '精茂城OK', 'merchantNo' => '8225840599200TF', 'wx' => [601173752, 601143352], 'zfb' => '2088820746800005'],
  197. //['name' => '莱漫OK', 'merchantNo' => '82239305992007A', 'wx' => [601288494, 601288166], 'zfb' => '2088820783686611'],
  198. //['name' => '莱漫(没用)', 'merchantNo' => '82239305992006T', 'wx' => [601134065, 601125595], 'zfb' => '2088820743859918'],
  199. //['name' => '福州我要花OK', 'merchantNo' => '82239105992007J', 'wx' => [601134030, 601128111], 'zfb' => '2088820745276973'],
  200. //['name' => '泉城OK', 'merchantNo' => '82239705992004F', 'wx' => [601273270, 601272854], 'zfb' => '2088820784658561'],
  201. //['name' => '泉城(没用)', 'merchantNo' => '82239705992004E', 'wx' => [601133056, 601133821], 'zfb' => '2088820746111323'],
  202. //['name' => '美丽花行OK', 'merchantNo' => '82239305992006V', 'wx' => [601155249, 601149712], 'zfb' => '2088820747673312'],
  203. //['name' => '三叶OK', 'merchantNo' => '82236805992001Y', 'wx' => [601152233, 601151024], 'zfb' => '2088820747556725'],
  204. //['name' => '花大苪OK', 'merchantNo' => '8227310599200GG', 'wx' => [601174221, 601165136], 'zfb' => '2088820751181377'],
  205. //['name' => '十堰天天鲜花OK', 'merchantNo' => '82252305992001S', 'wx' => [601171131, 601170642], 'zfb' => '2088820750844626'],
  206. //['name' => '珑松花卉OK', 'merchantNo' => '82260205992007S', 'wx' => [601176093, 601174262], 'zfb' => '2088820754742492'],
  207. //['name' => '惠雅鲜花OK', 'merchantNo' => '82260205992007R', 'wx' => [601173390, 601174002], 'zfb' => '2088820753174540'],
  208. //['name' => '锦绣花卉OK', 'merchantNo' => '82252305992001T', 'wx' => [601176719, 601176660], 'zfb' => '2088820754751663'],
  209. //['name' => '祥瑞鲜花同安店OK', 'merchantNo' => '82239305992006W', 'wx' => [601178350, 601177795], 'zfb' => '2088820755715024'],
  210. //['name' => '祥瑞鲜花翔安店OK', 'merchantNo' => '82239305992006X', 'wx' => [601178260, 601178199], 'zfb' => '2088820754481553'],
  211. //['name' => '初见花季OK', 'merchantNo' => '82239305992006Y', 'wx' => [601178998, 601179605], 'zfb' => '2088820757223312'],
  212. //['name' => '荣发鲜花OK', 'merchantNo' => '82242705992000D', 'wx' => [601179681, 601179180], 'zfb' => '2088820756926593'],
  213. //['name' => '花千朵(多多)OK', 'merchantNo' => '82239305992006Z', 'wx' => [601223474, 601208096], 'zfb' => '2088820766783276'],
  214. //['name' => '花悠星OK', 'merchantNo' => '8225810599200NH', 'wx' => [601228194, 601227691], 'zfb' => '2088820774587446'],
  215. //['name' => '花悠星(没用)', 'merchantNo' => '8225810599200NG', 'wx' => [601223630, 601210952], 'zfb' => '2088820767072874'],
  216. //['name' => '源花汇OK', 'merchantNo' => '82222105992004A', 'wx' => [601221944, 601214269], 'zfb' => '2088820770594246'],
  217. //['name' => '源花汇2(没用)', 'merchantNo' => '8227310599200GD', 'wx' => [601136305, 601067016], 'zfb' => '2088820729832744'],
  218. ];
  219. $new = [];
  220. foreach ($arr as $item) {
  221. $wx = $item['wx'];
  222. $zfb = $item['zfb'];
  223. $merchantNo = $item['merchantNo'];
  224. $name = $item['name'] . ' ' . $merchantNo;
  225. $group = [];
  226. foreach ($wx as $oneWx) {
  227. $params = [
  228. 'appid' => 'OP00002119',
  229. 'serial_no' => '018b08cfddbd',
  230. 'merchant_no' => $merchantNo,
  231. 'term_no' => 'C6337694',
  232. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  233. 'lklCertificatePath' => $lklCertificatePath,
  234. ];
  235. $data = [
  236. 'subMerchantId' => $oneWx,
  237. 'tradeMode' => 'WECHAT',
  238. ];
  239. $laResource = new Lakala($params);
  240. $response = $laResource->openStateQuery($data);
  241. $statusName = '出错了';
  242. if ($response['retCode'] == '000000') {
  243. $checkResult = $response['respData']['checkResult'] ?? '';
  244. $statusName = '未认证';
  245. if ($checkResult == 'AUTHORIZE_STATE_AUTHORIZED') {
  246. $statusName = '已认证';
  247. }
  248. }
  249. $group[] = '微信 ' . $oneWx . ' ' . $statusName;
  250. }
  251. $params = [
  252. 'appid' => 'OP00002119',
  253. 'serial_no' => '018b08cfddbd',
  254. 'merchant_no' => $merchantNo,
  255. 'term_no' => 'C6337694',
  256. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  257. 'lklCertificatePath' => $lklCertificatePath,
  258. ];
  259. $data = [
  260. 'subMerchantId' => $zfb,
  261. 'tradeMode' => 'ALIPAY',
  262. ];
  263. $laResource = new Lakala($params);
  264. $response = $laResource->openStateQuery($data);
  265. $statusName = '出错了';
  266. if ($response['retCode'] == '000000') {
  267. $checkResult = $response['respData']['checkResult'] ?? '';
  268. $statusName = '未认证';
  269. if ($checkResult == 'AUTHORIZED') {
  270. $statusName = '已认证';
  271. }
  272. }
  273. $group[] = '支付宝 ' . $zfb . ' ' . $statusName;
  274. $new[] = ['name' => $name, 'status' => $group];
  275. }
  276. echo '<pre>';
  277. print_r($new);
  278. die;
  279. }
  280. public function actionRefundQuery()
  281. {
  282. $shopId = 520;
  283. $shop = ShopClass::getById($shopId, true);
  284. if (empty($shop)) {
  285. util::stop('没有找到门店');
  286. }
  287. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  288. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  289. $params = [
  290. 'appid' => 'OP00002119',
  291. 'serial_no' => '018b08cfddbd',
  292. 'merchant_no' => $shop->lklSjNo,
  293. 'term_no' => $shop->lklScanTermNo,
  294. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  295. 'lklCertificatePath' => $lklCertificatePath,
  296. ];
  297. $laResource = new Lakala($params);
  298. $orderSn = '20231201110113131266165492618754';
  299. $data = [
  300. 'orderSn' => $orderSn,
  301. ];
  302. $response = $laResource->refundQuery($data);
  303. echo "<pre>";
  304. print_r($response);
  305. }
  306. public function actionBalanceQuery()
  307. {
  308. $shopId = 1212;
  309. $shop = ShopClass::getById($shopId, true);
  310. if (empty($shop)) {
  311. util::stop('没有找到门店');
  312. }
  313. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  314. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  315. $params = [
  316. 'appid' => 'OP00002119',
  317. 'serial_no' => '018b08cfddbd',
  318. 'merchant_no' => $shop->lklSjNo,
  319. 'term_no' => $shop->lklScanTermNo,
  320. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  321. 'lklCertificatePath' => $lklCertificatePath,
  322. ];
  323. $laResource = new Lakala($params);
  324. $response = $laResource->accountBalanceQuery();
  325. echo "<pre>";
  326. print_r($response);
  327. }
  328. //测试环境查线上数据 ssh 20231230
  329. public function actionCsQuery()
  330. {
  331. // $shopId = 1527;
  332. // $shop = ShopClass::getById($shopId, true);
  333. // if (empty($shop)) {
  334. // util::stop('没有找到门店');
  335. // }
  336. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  337. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  338. $params = [
  339. 'appid' => 'OP00002119',
  340. 'serial_no' => '018b08cfddbd',
  341. //'merchant_no' => $shop->lklSjNo,
  342. 'merchant_no' => '82222105992004A',
  343. //'term_no' => $shop->lklScanTermNo,
  344. 'term_no' => 'H3656802',
  345. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  346. 'lklCertificatePath' => $lklCertificatePath,
  347. ];
  348. $laResource = new Lakala($params);
  349. $queryParams = [
  350. //'orderSn' => 'KD26452235',
  351. 'tradeNo' => '20231230110113130266215700775011',
  352. ];
  353. $response = $laResource->query($queryParams, 1);
  354. echo "<pre>";
  355. print_r($response);
  356. }
  357. public function actionQuery()
  358. {
  359. $shopId = 726;
  360. $shop = ShopClass::getById($shopId, true);
  361. if (empty($shop)) {
  362. util::stop('没有找到门店');
  363. }
  364. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  365. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  366. $params = [
  367. 'appid' => 'OP00002119',
  368. 'serial_no' => '018b08cfddbd',
  369. 'merchant_no' => $shop->lklSjNo,
  370. 'term_no' => $shop->lklScanTermNo,
  371. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  372. 'lklCertificatePath' => $lklCertificatePath,
  373. ];
  374. $laResource = new Lakala($params);
  375. $queryParams = [
  376. 'orderSn' => 'KD26481486',
  377. //'tradeNo' => '20231230110113130266215700775011',
  378. ];
  379. $response = $laResource->query($queryParams, 0);
  380. echo "<pre>";
  381. print_r($response);
  382. }
  383. public function actionClearQuery()
  384. {
  385. $shopId = 8249;
  386. $shop = ShopClass::getById($shopId, true);
  387. if (empty($shop)) {
  388. util::stop('没有找到门店');
  389. }
  390. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  391. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  392. $params = [
  393. 'appid' => 'OP00002119',
  394. 'serial_no' => '018b08cfddbd',
  395. 'merchant_no' => $shop->lklSjNo,
  396. 'term_no' => $shop->lklScanTermNo,
  397. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  398. 'lklCertificatePath' => $lklCertificatePath,
  399. ];
  400. $laResource = new Lakala($params);
  401. $queryParams = [
  402. //'orderSn' => 'CL28693295',
  403. 'tradeNo' => '66215417437878',
  404. ];
  405. $response = $laResource->query($queryParams, 1);
  406. echo "<pre>";
  407. print_r($response);
  408. }
  409. //零售订单查询 ssh 20231031
  410. public function actionLsTradeQuery()
  411. {
  412. $shopId = 520;
  413. $shop = ShopClass::getById($shopId, true);
  414. if (empty($shop)) {
  415. util::stop('没有找到门店');
  416. }
  417. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  418. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  419. $params = [
  420. 'appid' => 'OP00002119',
  421. 'serial_no' => '018b08cfddbd',
  422. 'merchant_no' => $shop->lklSjNo,
  423. 'term_no' => $shop->lklScanTermNo,
  424. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  425. 'lklCertificatePath' => $lklCertificatePath,
  426. ];
  427. $laResource = new Lakala($params);
  428. $queryParams = [
  429. 'orderSn' => 'KD26487878',
  430. //'tradeNo' => '20231029110113130266215259252887',
  431. ];
  432. $response = $laResource->query($queryParams, 0);
  433. print_r($response);
  434. //util::stop();
  435. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  436. $connection = Yii::$app->db;
  437. $transaction = $connection->beginTransaction();
  438. try {
  439. $postData = $response['resp_data'] ?? [];
  440. $orderSn = $postData['out_trade_no'] ?? '';
  441. $total_amount = $postData['total_amount'] ?? 0;
  442. $account_type = $postData['account_type'] ?? '';
  443. if (empty($account_type)) {
  444. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意,orderSn:' . $orderSn, '15280215347');
  445. util::end();
  446. }
  447. $totalFee = $total_amount / 100;
  448. $transactionId = $postData['trade_no'] ?? 0;
  449. $capitalType = dict::getDict('capitalType', 'xhOrder', 'id');
  450. $currentPayWay = null;
  451. if ($account_type == 'WECHAT') {
  452. $currentPayWay = dict::getDict('payWay', 'wxPay');
  453. } elseif ($account_type == 'ALIPAY') {
  454. $currentPayWay = dict::getDict('payWay', 'alipay');
  455. } else {
  456. noticeUtil::push('支付回调失败了,没有找到支付类型,orderSn:' . $orderSn, '15280215347');
  457. util::end();
  458. }
  459. $attach = '';
  460. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  461. $transaction->commit();
  462. echo 'OK';
  463. } catch (\Exception $e) {
  464. $transaction->rollBack();
  465. Yii::error("失败原因:" . $e->getMessage());
  466. }
  467. }
  468. }
  469. //零售订单查询 ssh 20231031
  470. public function actionClear()
  471. {
  472. $shopId = 10649;
  473. $shop = ShopClass::getById($shopId, true);
  474. if (empty($shop)) {
  475. util::stop('没有找到门店');
  476. }
  477. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  478. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  479. $params = [
  480. 'appid' => 'OP00002119',
  481. 'serial_no' => '018b08cfddbd',
  482. 'merchant_no' => $shop->lklSjNo,
  483. 'term_no' => $shop->lklScanTermNo,
  484. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  485. 'lklCertificatePath' => $lklCertificatePath,
  486. ];
  487. $laResource = new Lakala($params);
  488. $queryParams = [
  489. //'orderSn' => 'KD26461864',
  490. 'tradeNo' => '20231230110113130266215700775011',
  491. ];
  492. $response = $laResource->query($queryParams, 1);
  493. print_r($response);
  494. util::stop();
  495. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  496. $connection = Yii::$app->db;
  497. $transaction = $connection->beginTransaction();
  498. try {
  499. $postData = $response['resp_data'] ?? [];
  500. $orderSn = $postData['out_trade_no'] ?? '';
  501. $total_amount = $postData['total_amount'] ?? 0;
  502. $account_type = $postData['account_type'] ?? '';
  503. if (empty($account_type)) {
  504. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意,orderSn:' . $orderSn, '15280215347');
  505. util::end();
  506. }
  507. $totalFee = $total_amount / 100;
  508. $transactionId = $postData['trade_no'] ?? 0;
  509. $capitalType = dict::getDict('capitalType', 'hdPurchaseClear', 'id');
  510. $currentPayWay = null;
  511. if ($account_type == 'WECHAT') {
  512. $currentPayWay = dict::getDict('payWay', 'wxPay');
  513. } elseif ($account_type == 'ALIPAY') {
  514. $currentPayWay = dict::getDict('payWay', 'alipay');
  515. } else {
  516. noticeUtil::push('支付回调失败了,没有找到支付类型,orderSn:' . $orderSn, '15280215347');
  517. util::end();
  518. }
  519. $attach = '';
  520. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  521. $transaction->commit();
  522. echo 'OK';
  523. } catch (\Exception $e) {
  524. $transaction->rollBack();
  525. Yii::error("失败原因:" . $e->getMessage());
  526. }
  527. }
  528. }
  529. //交易查询 ssh 20231021
  530. public function actionTradeQuery()
  531. {
  532. $shopId = 7855;
  533. $shop = ShopClass::getById($shopId, true);
  534. if (empty($shop)) {
  535. util::stop('没有找到门店');
  536. }
  537. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  538. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  539. $params = [
  540. 'appid' => 'OP00002119',
  541. 'serial_no' => '018b08cfddbd',
  542. 'merchant_no' => $shop->lklSjNo,
  543. 'term_no' => $shop->lklScanTermNo,
  544. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  545. 'lklCertificatePath' => $lklCertificatePath,
  546. ];
  547. $laResource = new Lakala($params);
  548. $queryParams = [
  549. //'orderSn' => 'CG26895438',
  550. 'tradeNo' => '66215982546403',
  551. ];
  552. $response = $laResource->query($queryParams, 1);
  553. print_r($response);
  554. util::stop();
  555. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  556. $capitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  557. $connection = Yii::$app->db;
  558. $transaction = $connection->beginTransaction();
  559. try {
  560. $account_type = $response['resp_data']['account_type'] ?? 0;
  561. if (empty($account_type)) {
  562. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意', '15280215347');
  563. util::end();
  564. }
  565. $currentPayWay = null;
  566. if ($account_type == 'WECHAT') {
  567. $currentPayWay = dict::getDict('payWay', 'wxPay');
  568. } elseif ($account_type == 'ALIPAY') {
  569. $currentPayWay = dict::getDict('payWay', 'alipay');
  570. } else {
  571. noticeUtil::push('支付回调失败了,没有找到支付类型', '15280215347');
  572. util::end();
  573. }
  574. $attach = '';
  575. $total_amount = $response['resp_data']['total_amount'] ?? 0;
  576. $orderSn = $response['resp_data']['out_trade_no'] ?? 0;
  577. $totalFee = $total_amount / 100;
  578. $transactionId = $response['resp_data']['trade_no'] ?? 0;
  579. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  580. $transaction->commit();
  581. echo 'OK';
  582. } catch (\Exception $e) {
  583. $transaction->rollBack();
  584. Yii::error("失败原因:" . $e->getMessage());
  585. }
  586. }
  587. }
  588. public function actionAliRun2()
  589. {
  590. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  591. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  592. $params = [
  593. 'appid' => 'OP00002119',
  594. 'serial_no' => '018b08cfddbd',
  595. 'merchant_no' => '82240505992000N',
  596. 'term_no' => 'C6337694',
  597. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  598. 'lklCertificatePath' => $lklCertificatePath,
  599. ];
  600. $outTradeNo = orderSn::getPurchaseSn();
  601. $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
  602. $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  603. $aliParams = [
  604. 'orderSn' => $outTradeNo,
  605. 'amount' => 0.16,
  606. 'capitalType' => $currentCapitalType,
  607. 'notifyUrl' => $notifyUrl,
  608. ];
  609. $laResource = new Lakala($params);
  610. $response = $laResource->driveAliPay($aliParams);
  611. if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
  612. echo '<pre>';
  613. echo "下单成功<br/>";
  614. print_r($response);
  615. } else {
  616. echo '<pre>';
  617. echo "下单失败<br/>";
  618. print_r($response);
  619. }
  620. }
  621. public function actionAliRun3()
  622. {
  623. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  624. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  625. $params = [
  626. 'appid' => 'OP00002119',
  627. 'serial_no' => '018b08cfddbd',
  628. 'merchant_no' => '82240505992000N',
  629. 'term_no' => 'C6337694',
  630. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  631. 'lklCertificatePath' => $lklCertificatePath,
  632. ];
  633. $laResource = new Lakala($params);
  634. $outTradeNo = orderSn::getPurchaseSn();
  635. $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
  636. $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  637. $wxParams = [
  638. 'orderSn' => $outTradeNo,
  639. 'amount' => 0.16,
  640. 'capitalType' => $currentCapitalType,
  641. 'notifyUrl' => $notifyUrl,
  642. ];
  643. $response = $laResource->driveWxPay($wxParams);
  644. if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
  645. echo '<pre>';
  646. echo "下单成功<br/>";
  647. print_r($response);
  648. } else {
  649. echo '<pre>';
  650. echo "下单失败<br/>";
  651. print_r($response);
  652. }
  653. }
  654. //dada 城市code
  655. public function actionDadaCityCode()
  656. {
  657. $res = dada::getCityCode(0);
  658. util::success($res);
  659. }
  660. //理由
  661. public function actionDadaReasons()
  662. {
  663. $res = dada::getCancelReason(0);
  664. util::success($res);
  665. }
  666. //达达 :下单
  667. public function actionDadaAddOrder()
  668. {
  669. $orderSn = 'XSD_CS26316851';
  670. $orderInfo = OrderClass::getByOrderSn($orderSn);
  671. $res = DadaExpressServices::addOrder($orderInfo);
  672. util::success($res);
  673. }
  674. //重发快递
  675. public function actionDadaReAdd()
  676. {
  677. $orderSn = 'XSD_CS26316851';
  678. $orderInfo = OrderClass::getByOrderSn($orderSn);
  679. $res = DadaExpressServices::reAddOrder($orderInfo);
  680. util::success($res);
  681. }
  682. //达达状态查询
  683. public function actionDadaOrderStatus()
  684. {
  685. $orderSn = 'XSD_CS26316851';
  686. $res = DadaExpressServices::statusOrder($orderSn);
  687. util::success($res);
  688. }
  689. //达达取消下单
  690. public function actionDadaCancelOrder()
  691. {
  692. $orderSn = 'XSD_CS26316851';
  693. $res = DadaExpressServices::cancelOrder($orderSn, 1);
  694. util::success($res);
  695. }
  696. //获取已支持的配送公司列表接口
  697. public function actionGetAllDelivery()
  698. {
  699. $data = MiniExpressService::getAllImmeDelivery();
  700. util::success($data);
  701. }
  702. //即时配送
  703. /*
  704. * Array
  705. (
  706. [resultcode] => 0
  707. [resultmsg] => OK
  708. [shop_list] => Array
  709. (
  710. [0] => Array
  711. (
  712. [shopid] => 1588714266
  713. [delivery_id] => SFTC
  714. [audit_result] => 0
  715. [create_time] => 1612172838
  716. [remark] =>
  717. [delivery_name] => 顺丰同城急送
  718. )
  719. )
  720. )
  721. */
  722. public function actionGetBindAccount()
  723. {
  724. $merchant = WxOpenClass::getGhsWxInfo();
  725. $isOpen = 2;
  726. $r = miniUtil::getBindAccount($merchant, $isOpen);
  727. dd($r);
  728. }
  729. //下单 (沙箱)
  730. /**
  731. * Array
  732. * (
  733. * [resultcode] => 0
  734. * [resultmsg] => ok
  735. * [fee] => 10
  736. * [waybill_id] => test_shop_id1612365974_waybillid
  737. * [order_status] => 101
  738. * [dispatch_duration] => 300
  739. * )
  740. */
  741. public function actionCreateWaybill()
  742. {
  743. $merchant = WxOpenClass::getGhsWxInfo();
  744. $isOpen = 2;
  745. $shopId = 'test_shop_id';
  746. $shopOrderId = 'test_shop_id' . time();
  747. $appSecret = 'test_app_secrect';
  748. $data = [
  749. 'shopid' => $shopId,
  750. 'shop_order_id' => $shopOrderId,
  751. 'shop_no' => '1',
  752. 'delivery_sign' => miniUtil::getDeliverySign($shopId, $shopOrderId, $appSecret), //,则delivery_sign=SHA1(shopid + shop_order_id + AppSecret)
  753. 'delivery_id' => "TEST",
  754. 'openid' => 'oGKMp45YLxewOTWEbpMFzWoVqdW0',
  755. 'sender' => [
  756. 'name' => 'test',
  757. 'city' => '厦门市',
  758. 'address' => '思明区',
  759. 'address_detail' => '软件园二期',
  760. 'phone' => '19959271111',
  761. 'lng' => 118.134343,
  762. 'lat' => 24.483566,
  763. 'coordinate_type' => 0,
  764. ],
  765. 'receiver' => [
  766. 'name' => 'test',
  767. 'city' => '厦门市',
  768. 'address' => '思明区',
  769. 'address_detail' => '软件园二期',
  770. 'phone' => '19959271111',
  771. 'lng' => 118.134343,
  772. 'lat' => 24.493566,
  773. 'coordinate_type' => 0,
  774. ],
  775. 'cargo' => [
  776. 'goods_value' => 1,
  777. 'goods_weight' => 0.1,
  778. 'cargo_first_class' => '鲜花',
  779. 'cargo_second_class' => '鲜花',
  780. ],
  781. 'order_info' => [
  782. 'order_type' => 0,
  783. ],
  784. 'shop' => [
  785. 'wxa_path' => '/shop',
  786. 'img_url' => 'http://www.baidu.com/test.png',
  787. 'goods_name' => 'test',
  788. 'goods_count' => 1,
  789. ],
  790. ];
  791. $r = miniUtil::addOrder($data, $merchant, $isOpen);
  792. dd($r);
  793. }
  794. //获取运单数据
  795. /**
  796. * Array
  797. * (
  798. * [resultcode] => 0
  799. * [resultmsg] => ok
  800. * [order_status] => 101
  801. * [agent_info] => Array
  802. * (
  803. * )
  804. *
  805. * [waybill_id] => test_shop_id1612365974_waybillid
  806. * [rider_name] =>
  807. * [rider_phone] =>
  808. * [order_token] => NsXweKCKhSyAEIhAdnX3TYZsVDES0-t-tymHDONG0MpRsF31dQvVxiP_JJvLFaKS-kwXuOG3D0hzKkl7o-gzew
  809. * )
  810. */
  811. public function actionGetOrder()
  812. {
  813. $shopId = 'test_shop_id';
  814. $shopOrderId = 'test_shop_id1612365974';
  815. $appSecret = 'test_app_secrect';
  816. $merchant = WxOpenClass::getGhsWxInfo();
  817. $isOpen = 2;
  818. $data = [
  819. 'shopid' => $shopId,
  820. 'shop_order_id' => $shopOrderId,
  821. 'shop_no' => '1',
  822. 'delivery_sign' => MiniExpressService::getDeliverySign($shopId, $shopOrderId, $appSecret),
  823. ];
  824. $r = miniUtil::getOrder($data, $merchant, $isOpen);
  825. dd($r);
  826. }
  827. //沙盒 更新快递状态
  828. public function actionMockUpdateOrder()
  829. {
  830. $merchant = WxOpenClass::getGhsWxInfo();
  831. $isOpen = 2;
  832. /**
  833. * {
  834. * "shopid": "test_shop_id",
  835. * "shop_order_id": "xxxxxxxxxxx",
  836. * "waybill_id": "xxxxxxxxxxxxx",
  837. * "action_time": 12345678,
  838. * "order_status": 101,
  839. * "action_msg": "",
  840. * }
  841. */
  842. $shopId = 'test_shop_id';
  843. $shopOrderId = 'test_shop_id1612365974';
  844. $data = [
  845. 'shop_order_id' => $shopOrderId,
  846. "shopid" => $shopId,
  847. "action_time" => time(),
  848. "order_status" => 302,
  849. 'action_msg' => '状态变更',
  850. ];
  851. $r = miniUtil::mockUpdateOrder($data, $merchant, $isOpen);
  852. dd($r);
  853. }
  854. public function actionTest()
  855. {
  856. }
  857. //新增订单
  858. public function actionAddOrder()
  859. {
  860. $dada = Yii::getAlias("@vendor/dada/");
  861. require_once $dada . 'api/addOrderApi.php';
  862. require_once $dada . 'client/dadaRequestClient.php';
  863. require_once $dada . 'client/dadaResponse.php';
  864. require_once $dada . 'config/config.php';
  865. require_once $dada . 'model/orderModel.php';
  866. // isOnline 判断是否是测试环境,会有不同的域名等
  867. $isOnline = false;
  868. $sourceId = 1000000;
  869. // 初始化一个config
  870. $config = new \Config($sourceId, $isOnline);
  871. $orderModel = new \OrderModel();
  872. $orderModel->setShopNo('11047059');
  873. $orderModel->setOriginId('2018091100000002');
  874. $orderModel->setCityCode('021');
  875. $orderModel->setCargoPrice(10);
  876. $orderModel->setIsPrepay(0);
  877. $orderModel->setReceiverName('测试达达');
  878. $orderModel->setReceiverAddress('上海市崇明岛');
  879. $orderModel->setReceiverLat(31.63);
  880. $orderModel->setReceiverLng(121.41);
  881. $orderModel->setReceiverPhone('18588888888');
  882. $orderModel->setCallback('http://api.b.huaml.com/data/request');
  883. // api主要有2个参数,一个是url, 一个是业务参数
  884. $addOrderApi = new \AddOrderApi(json_encode($orderModel));
  885. $dada_client = new \DadaRequestClient($config, $addOrderApi);
  886. $resp = $dada_client->makeRequest();
  887. echo json_encode($resp);
  888. }
  889. //订单详情查询
  890. public function actionOrderQuery()
  891. {
  892. $dada = Yii::getAlias("@vendor/dada/");
  893. require_once $dada . 'api/OrderQueryApi.php';
  894. require_once $dada . 'client/dadaRequestClient.php';
  895. require_once $dada . 'client/dadaResponse.php';
  896. require_once $dada . 'config/config.php';
  897. require_once $dada . 'model/orderModel.php';
  898. // isOnline 判断是否是测试环境,会有不同的域名等
  899. $isOnline = false;
  900. $sourceId = 1000000;
  901. // 初始化一个config
  902. $config = new \Config($sourceId, $isOnline);
  903. $orderModel = new \OrderModel();
  904. $orderModel->setOrderId('2018091100000002');
  905. // api主要有2个参数,一个是url, 一个是业务参数
  906. $addOrderApi = new \OrderQueryApi(json_encode($orderModel));
  907. $dada_client = new \DadaRequestClient($config, $addOrderApi);
  908. $resp = $dada_client->makeRequest();
  909. echo json_encode($resp);
  910. }
  911. public function actionFocus()
  912. {
  913. $name = '花卉宝';
  914. if (getenv('YII_ENV') == 'dev') {
  915. $name = '花美灵';
  916. }
  917. $merchant = MerchantService::getByCondition(['name' => $name]);
  918. $list = wxUtil::getSubscribeUserList($merchant);
  919. dd($list);
  920. }
  921. //宝贝售出提醒 ssh 2020.1.30
  922. public function actionInform()
  923. {
  924. $merchant = MerchantService::getMerchantById(12362);
  925. $order = OrderService::getById(214810);
  926. InformAdminClass::sendComplete($order);
  927. }
  928. public function actionNotice()
  929. {
  930. $data = ['messageType' => 'inform', 'informWay' => 'wx', 'userType' => 'admin', 'id' => 6, 'mobile' => '15280215347'];
  931. $producer = Yii::$app->rabbitmq->getProducer('informProducer');
  932. echo '<pre>';
  933. print_r($data);
  934. $msg = serialize($data);
  935. $r = $producer->publish($msg, 'informExchange', 'informRoute');
  936. }
  937. }