TestController.php 42 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010
  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' => '8224910599200NB', 'wx' => [624877731, 624877902], 'zfb' => '2088830970964611'],
  181. ['name' => '昆明期待鲜花', 'merchantNo' => '8227310599200J6', 'wx' => [615582300, 615582180], 'zfb' => '2088530113958388'],
  182. ['name' => '厦门遇见你', 'merchantNo' => '82239305992008D', 'wx' => [614782373, 614783346], 'zfb' => '2088430828233036'],
  183. //['name' => '淄博花超鲜花批发', 'merchantNo' => '82245305992001R', 'wx' => [614685779, 614682986], 'zfb' => '2088430805221810'],
  184. //['name' => '广州国恋', 'merchantNo' => '8225810599200Q7', 'wx' => [612321716, 612320978], 'zfb' => '2088330479975012'],
  185. //['name' => '欣研鲜花', 'merchantNo' => '82260305992001Y', 'wx' => [612181234, 612181615], 'zfb' => '2088330365608286'],
  186. //['name' => '村长冷链', 'merchantNo' => '82260205992008G', 'wx' => [612168406, 612168000], 'zfb' => '2088330360870932'],
  187. //['name' => '惠州惠雅鲜花批发', 'merchantNo' => '82259505992003S', 'wx' => [611676975, 611677314], 'zfb' => '2088330136601427'],
  188. //['name' => '杭州斗南鲜花', 'merchantNo' => '8223310599200AR', 'wx' => [608955814, 608955082], 'zfb' => '2088130449323603'],
  189. //['name' => '营口简约花卉', 'merchantNo' => '8227310599200HJ', 'wx' => [608439898, 608440994], 'zfb' => '2088130112725929'],
  190. //['name' => '惠雅鲜花惠州店', 'merchantNo' => '82260205992007Z', 'wx' => [608406948, 608403207], 'zfb' => '2088130098167302'],
  191. //['name' => '云南珑松花卉珠海店', 'merchantNo' => '82258505992002U', 'wx' => [608062727, 608056474], 'zfb' => '2088030873238576'],
  192. //['name' => '买手很忙', 'merchantNo' => '8227310599200GJ', 'wx' => [601597167, 601595526], 'zfb' => '2088820818930267'],
  193. //['name' => '七彩花都', 'merchantNo' => '8227310599200GF', 'wx' => [601176481, 601148503], 'zfb' => '2088820748594478'],
  194. //['name' => '十年', 'merchantNo' => '82252305992001U', 'wx' => [601285154, 601261795], 'zfb' => '2088820782171763'],
  195. //['name' => '都市花季OK', 'merchantNo' => '82239305992006U', 'wx' => [601174342, 601147649], 'zfb' => '2088820748507346'],
  196. //['name' => '花样年华OK', 'merchantNo' => '82260205992007Q', 'wx' => [601134352, 601091710], 'zfb' => '2088820735043444'],
  197. //['name' => '精茂城OK', 'merchantNo' => '8225840599200TF', 'wx' => [601173752, 601143352], 'zfb' => '2088820746800005'],
  198. //['name' => '莱漫OK', 'merchantNo' => '82239305992007A', 'wx' => [601288494, 601288166], 'zfb' => '2088820783686611'],
  199. //['name' => '莱漫(没用)', 'merchantNo' => '82239305992006T', 'wx' => [601134065, 601125595], 'zfb' => '2088820743859918'],
  200. //['name' => '福州我要花OK', 'merchantNo' => '82239105992007J', 'wx' => [601134030, 601128111], 'zfb' => '2088820745276973'],
  201. //['name' => '泉城OK', 'merchantNo' => '82239705992004F', 'wx' => [601273270, 601272854], 'zfb' => '2088820784658561'],
  202. //['name' => '泉城(没用)', 'merchantNo' => '82239705992004E', 'wx' => [601133056, 601133821], 'zfb' => '2088820746111323'],
  203. //['name' => '美丽花行OK', 'merchantNo' => '82239305992006V', 'wx' => [601155249, 601149712], 'zfb' => '2088820747673312'],
  204. //['name' => '三叶OK', 'merchantNo' => '82236805992001Y', 'wx' => [601152233, 601151024], 'zfb' => '2088820747556725'],
  205. //['name' => '花大苪OK', 'merchantNo' => '8227310599200GG', 'wx' => [601174221, 601165136], 'zfb' => '2088820751181377'],
  206. //['name' => '十堰天天鲜花OK', 'merchantNo' => '82252305992001S', 'wx' => [601171131, 601170642], 'zfb' => '2088820750844626'],
  207. //['name' => '珑松花卉OK', 'merchantNo' => '82260205992007S', 'wx' => [601176093, 601174262], 'zfb' => '2088820754742492'],
  208. //['name' => '惠雅鲜花OK', 'merchantNo' => '82260205992007R', 'wx' => [601173390, 601174002], 'zfb' => '2088820753174540'],
  209. //['name' => '锦绣花卉OK', 'merchantNo' => '82252305992001T', 'wx' => [601176719, 601176660], 'zfb' => '2088820754751663'],
  210. //['name' => '祥瑞鲜花同安店OK', 'merchantNo' => '82239305992006W', 'wx' => [601178350, 601177795], 'zfb' => '2088820755715024'],
  211. //['name' => '祥瑞鲜花翔安店OK', 'merchantNo' => '82239305992006X', 'wx' => [601178260, 601178199], 'zfb' => '2088820754481553'],
  212. //['name' => '初见花季OK', 'merchantNo' => '82239305992006Y', 'wx' => [601178998, 601179605], 'zfb' => '2088820757223312'],
  213. //['name' => '荣发鲜花OK', 'merchantNo' => '82242705992000D', 'wx' => [601179681, 601179180], 'zfb' => '2088820756926593'],
  214. //['name' => '花千朵(多多)OK', 'merchantNo' => '82239305992006Z', 'wx' => [601223474, 601208096], 'zfb' => '2088820766783276'],
  215. //['name' => '花悠星OK', 'merchantNo' => '8225810599200NH', 'wx' => [601228194, 601227691], 'zfb' => '2088820774587446'],
  216. //['name' => '花悠星(没用)', 'merchantNo' => '8225810599200NG', 'wx' => [601223630, 601210952], 'zfb' => '2088820767072874'],
  217. //['name' => '源花汇OK', 'merchantNo' => '82222105992004A', 'wx' => [601221944, 601214269], 'zfb' => '2088820770594246'],
  218. //['name' => '源花汇2(没用)', 'merchantNo' => '8227310599200GD', 'wx' => [601136305, 601067016], 'zfb' => '2088820729832744'],
  219. ];
  220. $new = [];
  221. foreach ($arr as $item) {
  222. $wx = $item['wx'];
  223. $zfb = $item['zfb'];
  224. $merchantNo = $item['merchantNo'];
  225. $name = $item['name'] . ' ' . $merchantNo;
  226. $group = [];
  227. foreach ($wx as $oneWx) {
  228. $params = [
  229. 'appid' => 'OP00002119',
  230. 'serial_no' => '018b08cfddbd',
  231. 'merchant_no' => $merchantNo,
  232. 'term_no' => 'C6337694',
  233. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  234. 'lklCertificatePath' => $lklCertificatePath,
  235. ];
  236. $data = [
  237. 'subMerchantId' => $oneWx,
  238. 'tradeMode' => 'WECHAT',
  239. ];
  240. $laResource = new Lakala($params);
  241. $response = $laResource->openStateQuery($data);
  242. $statusName = '出错了';
  243. if ($response['retCode'] == '000000') {
  244. $checkResult = $response['respData']['checkResult'] ?? '';
  245. $statusName = '未认证';
  246. if ($checkResult == 'AUTHORIZE_STATE_AUTHORIZED') {
  247. $statusName = '已认证';
  248. }
  249. }
  250. $group[] = '微信 ' . $oneWx . ' ' . $statusName;
  251. }
  252. $params = [
  253. 'appid' => 'OP00002119',
  254. 'serial_no' => '018b08cfddbd',
  255. 'merchant_no' => $merchantNo,
  256. 'term_no' => 'C6337694',
  257. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  258. 'lklCertificatePath' => $lklCertificatePath,
  259. ];
  260. $data = [
  261. 'subMerchantId' => $zfb,
  262. 'tradeMode' => 'ALIPAY',
  263. ];
  264. $laResource = new Lakala($params);
  265. $response = $laResource->openStateQuery($data);
  266. $statusName = '出错了';
  267. if ($response['retCode'] == '000000') {
  268. $checkResult = $response['respData']['checkResult'] ?? '';
  269. $statusName = '未认证';
  270. if ($checkResult == 'AUTHORIZED') {
  271. $statusName = '已认证';
  272. }
  273. }
  274. $group[] = '支付宝 ' . $zfb . ' ' . $statusName;
  275. $new[] = ['name' => $name, 'status' => $group];
  276. }
  277. echo '<pre>';
  278. print_r($new);
  279. die;
  280. }
  281. public function actionRefundQuery()
  282. {
  283. $shopId = 520;
  284. $shop = ShopClass::getById($shopId, true);
  285. if (empty($shop)) {
  286. util::stop('没有找到门店');
  287. }
  288. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  289. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  290. $params = [
  291. 'appid' => 'OP00002119',
  292. 'serial_no' => '018b08cfddbd',
  293. 'merchant_no' => $shop->lklSjNo,
  294. 'term_no' => $shop->lklScanTermNo,
  295. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  296. 'lklCertificatePath' => $lklCertificatePath,
  297. ];
  298. $laResource = new Lakala($params);
  299. $orderSn = '20231201110113131266165492618754';
  300. $data = [
  301. 'orderSn' => $orderSn,
  302. ];
  303. $response = $laResource->refundQuery($data);
  304. echo "<pre>";
  305. print_r($response);
  306. }
  307. public function actionBalanceQuery()
  308. {
  309. $shopId = 1212;
  310. $shop = ShopClass::getById($shopId, true);
  311. if (empty($shop)) {
  312. util::stop('没有找到门店');
  313. }
  314. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  315. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  316. $params = [
  317. 'appid' => 'OP00002119',
  318. 'serial_no' => '018b08cfddbd',
  319. 'merchant_no' => $shop->lklSjNo,
  320. 'term_no' => $shop->lklScanTermNo,
  321. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  322. 'lklCertificatePath' => $lklCertificatePath,
  323. ];
  324. $laResource = new Lakala($params);
  325. $response = $laResource->accountBalanceQuery();
  326. echo "<pre>";
  327. print_r($response);
  328. }
  329. //测试环境查线上数据 ssh 20231230
  330. public function actionCsQuery()
  331. {
  332. // $shopId = 1527;
  333. // $shop = ShopClass::getById($shopId, true);
  334. // if (empty($shop)) {
  335. // util::stop('没有找到门店');
  336. // }
  337. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  338. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  339. $params = [
  340. 'appid' => 'OP00002119',
  341. 'serial_no' => '018b08cfddbd',
  342. //'merchant_no' => $shop->lklSjNo,
  343. 'merchant_no' => '82222105992004A',
  344. //'term_no' => $shop->lklScanTermNo,
  345. 'term_no' => 'H3656802',
  346. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  347. 'lklCertificatePath' => $lklCertificatePath,
  348. ];
  349. $laResource = new Lakala($params);
  350. $queryParams = [
  351. //'orderSn' => 'KD26452235',
  352. 'tradeNo' => '20231230110113130266215700775011',
  353. ];
  354. $response = $laResource->query($queryParams, 1);
  355. echo "<pre>";
  356. print_r($response);
  357. }
  358. public function actionQuery()
  359. {
  360. $shopId = 726;
  361. $shop = ShopClass::getById($shopId, true);
  362. if (empty($shop)) {
  363. util::stop('没有找到门店');
  364. }
  365. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  366. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  367. $params = [
  368. 'appid' => 'OP00002119',
  369. 'serial_no' => '018b08cfddbd',
  370. 'merchant_no' => $shop->lklSjNo,
  371. 'term_no' => $shop->lklScanTermNo,
  372. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  373. 'lklCertificatePath' => $lklCertificatePath,
  374. ];
  375. $laResource = new Lakala($params);
  376. $queryParams = [
  377. 'orderSn' => 'KD26481486',
  378. //'tradeNo' => '20231230110113130266215700775011',
  379. ];
  380. $response = $laResource->query($queryParams, 0);
  381. echo "<pre>";
  382. print_r($response);
  383. }
  384. public function actionClearQuery()
  385. {
  386. $shopId = 8249;
  387. $shop = ShopClass::getById($shopId, true);
  388. if (empty($shop)) {
  389. util::stop('没有找到门店');
  390. }
  391. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  392. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  393. $params = [
  394. 'appid' => 'OP00002119',
  395. 'serial_no' => '018b08cfddbd',
  396. 'merchant_no' => $shop->lklSjNo,
  397. 'term_no' => $shop->lklScanTermNo,
  398. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  399. 'lklCertificatePath' => $lklCertificatePath,
  400. ];
  401. $laResource = new Lakala($params);
  402. $queryParams = [
  403. //'orderSn' => 'CL28693295',
  404. 'tradeNo' => '66215417437878',
  405. ];
  406. $response = $laResource->query($queryParams, 1);
  407. echo "<pre>";
  408. print_r($response);
  409. }
  410. //零售订单查询 ssh 20231031
  411. public function actionLsTradeQuery()
  412. {
  413. $shopId = 520;
  414. $shop = ShopClass::getById($shopId, true);
  415. if (empty($shop)) {
  416. util::stop('没有找到门店');
  417. }
  418. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  419. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  420. $params = [
  421. 'appid' => 'OP00002119',
  422. 'serial_no' => '018b08cfddbd',
  423. 'merchant_no' => $shop->lklSjNo,
  424. 'term_no' => $shop->lklScanTermNo,
  425. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  426. 'lklCertificatePath' => $lklCertificatePath,
  427. ];
  428. $laResource = new Lakala($params);
  429. $queryParams = [
  430. 'orderSn' => 'KD26487879',
  431. //'tradeNo' => '20231029110113130266215259252887',
  432. ];
  433. $response = $laResource->query($queryParams, 0);
  434. print_r($response);
  435. util::stop();
  436. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  437. $connection = Yii::$app->db;
  438. $transaction = $connection->beginTransaction();
  439. try {
  440. $postData = $response['resp_data'] ?? [];
  441. $orderSn = $postData['out_trade_no'] ?? '';
  442. $total_amount = $postData['total_amount'] ?? 0;
  443. $account_type = $postData['account_type'] ?? '';
  444. if (empty($account_type)) {
  445. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意,orderSn:' . $orderSn, '15280215347');
  446. util::end();
  447. }
  448. $totalFee = $total_amount / 100;
  449. $transactionId = $postData['trade_no'] ?? 0;
  450. $capitalType = dict::getDict('capitalType', 'xhOrder', 'id');
  451. $currentPayWay = null;
  452. if ($account_type == 'WECHAT') {
  453. $currentPayWay = dict::getDict('payWay', 'wxPay');
  454. } elseif ($account_type == 'ALIPAY') {
  455. $currentPayWay = dict::getDict('payWay', 'alipay');
  456. } else {
  457. noticeUtil::push('支付回调失败了,没有找到支付类型,orderSn:' . $orderSn, '15280215347');
  458. util::end();
  459. }
  460. $attach = '';
  461. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  462. $transaction->commit();
  463. echo 'OK';
  464. } catch (\Exception $e) {
  465. $transaction->rollBack();
  466. Yii::error("失败原因:" . $e->getMessage());
  467. }
  468. }
  469. }
  470. //零售订单查询 ssh 20231031
  471. public function actionClear()
  472. {
  473. $shopId = 10649;
  474. $shop = ShopClass::getById($shopId, true);
  475. if (empty($shop)) {
  476. util::stop('没有找到门店');
  477. }
  478. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  479. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  480. $params = [
  481. 'appid' => 'OP00002119',
  482. 'serial_no' => '018b08cfddbd',
  483. 'merchant_no' => $shop->lklSjNo,
  484. 'term_no' => $shop->lklScanTermNo,
  485. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  486. 'lklCertificatePath' => $lklCertificatePath,
  487. ];
  488. $laResource = new Lakala($params);
  489. $queryParams = [
  490. //'orderSn' => 'KD26461864',
  491. 'tradeNo' => '20231230110113130266215700775011',
  492. ];
  493. $response = $laResource->query($queryParams, 1);
  494. print_r($response);
  495. util::stop();
  496. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  497. $connection = Yii::$app->db;
  498. $transaction = $connection->beginTransaction();
  499. try {
  500. $postData = $response['resp_data'] ?? [];
  501. $orderSn = $postData['out_trade_no'] ?? '';
  502. $total_amount = $postData['total_amount'] ?? 0;
  503. $account_type = $postData['account_type'] ?? '';
  504. if (empty($account_type)) {
  505. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意,orderSn:' . $orderSn, '15280215347');
  506. util::end();
  507. }
  508. $totalFee = $total_amount / 100;
  509. $transactionId = $postData['trade_no'] ?? 0;
  510. $capitalType = dict::getDict('capitalType', 'hdPurchaseClear', 'id');
  511. $currentPayWay = null;
  512. if ($account_type == 'WECHAT') {
  513. $currentPayWay = dict::getDict('payWay', 'wxPay');
  514. } elseif ($account_type == 'ALIPAY') {
  515. $currentPayWay = dict::getDict('payWay', 'alipay');
  516. } else {
  517. noticeUtil::push('支付回调失败了,没有找到支付类型,orderSn:' . $orderSn, '15280215347');
  518. util::end();
  519. }
  520. $attach = '';
  521. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  522. $transaction->commit();
  523. echo 'OK';
  524. } catch (\Exception $e) {
  525. $transaction->rollBack();
  526. Yii::error("失败原因:" . $e->getMessage());
  527. }
  528. }
  529. }
  530. //交易查询 ssh 20231021
  531. public function actionTradeQuery()
  532. {
  533. $shopId = 7855;
  534. $shop = ShopClass::getById($shopId, true);
  535. if (empty($shop)) {
  536. util::stop('没有找到门店');
  537. }
  538. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  539. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  540. $params = [
  541. 'appid' => 'OP00002119',
  542. 'serial_no' => '018b08cfddbd',
  543. 'merchant_no' => $shop->lklSjNo,
  544. 'term_no' => $shop->lklScanTermNo,
  545. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  546. 'lklCertificatePath' => $lklCertificatePath,
  547. ];
  548. $laResource = new Lakala($params);
  549. $queryParams = [
  550. //'orderSn' => 'CG26890919',
  551. 'tradeNo' => '66215960152739',
  552. ];
  553. $response = $laResource->query($queryParams, 1);
  554. print_r($response);
  555. util::stop();
  556. if (isset($response['code']) && $response['code'] == 'BBS00000') {
  557. $capitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  558. $connection = Yii::$app->db;
  559. $transaction = $connection->beginTransaction();
  560. try {
  561. $account_type = $response['resp_data']['account_type'] ?? 0;
  562. if (empty($account_type)) {
  563. noticeUtil::push('支付回调失败了,没有找到钱包类型,请注意', '15280215347');
  564. util::end();
  565. }
  566. $currentPayWay = null;
  567. if ($account_type == 'WECHAT') {
  568. $currentPayWay = dict::getDict('payWay', 'wxPay');
  569. } elseif ($account_type == 'ALIPAY') {
  570. $currentPayWay = dict::getDict('payWay', 'alipay');
  571. } else {
  572. noticeUtil::push('支付回调失败了,没有找到支付类型', '15280215347');
  573. util::end();
  574. }
  575. $attach = '';
  576. $total_amount = $response['resp_data']['total_amount'] ?? 0;
  577. $orderSn = $response['resp_data']['out_trade_no'] ?? 0;
  578. $totalFee = $total_amount / 100;
  579. $transactionId = $response['resp_data']['trade_no'] ?? 0;
  580. payUtil::thirdPay($currentPayWay, $capitalType, $orderSn, $totalFee, $attach, $transactionId);
  581. $transaction->commit();
  582. echo 'OK';
  583. } catch (\Exception $e) {
  584. $transaction->rollBack();
  585. Yii::error("失败原因:" . $e->getMessage());
  586. }
  587. }
  588. }
  589. public function actionAliRun2()
  590. {
  591. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  592. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  593. $params = [
  594. 'appid' => 'OP00002119',
  595. 'serial_no' => '018b08cfddbd',
  596. 'merchant_no' => '82240505992000N',
  597. 'term_no' => 'C6337694',
  598. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  599. 'lklCertificatePath' => $lklCertificatePath,
  600. ];
  601. $outTradeNo = orderSn::getPurchaseSn();
  602. $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
  603. $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  604. $aliParams = [
  605. 'orderSn' => $outTradeNo,
  606. 'amount' => 0.16,
  607. 'capitalType' => $currentCapitalType,
  608. 'notifyUrl' => $notifyUrl,
  609. ];
  610. $laResource = new Lakala($params);
  611. $response = $laResource->driveAliPay($aliParams);
  612. if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
  613. echo '<pre>';
  614. echo "下单成功<br/>";
  615. print_r($response);
  616. } else {
  617. echo '<pre>';
  618. echo "下单失败<br/>";
  619. print_r($response);
  620. }
  621. }
  622. public function actionAliRun3()
  623. {
  624. $merchantPrivateKeyPath = Yii::getAlias("@vendor/lakala") . '/production/api_private_key.pem';
  625. $lklCertificatePath = Yii::getAlias("@vendor/lakala") . '/production/lkl-apigw-v1.cer';
  626. $params = [
  627. 'appid' => 'OP00002119',
  628. 'serial_no' => '018b08cfddbd',
  629. 'merchant_no' => '82240505992000N',
  630. 'term_no' => 'C6337694',
  631. 'merchantPrivateKeyPath' => $merchantPrivateKeyPath,
  632. 'lklCertificatePath' => $lklCertificatePath,
  633. ];
  634. $laResource = new Lakala($params);
  635. $outTradeNo = orderSn::getPurchaseSn();
  636. $notifyUrl = Yii::$app->params['hdHost'] . "/notice/pay-callback";
  637. $currentCapitalType = dict::getDict('capitalType', 'xhPurchase', 'id');
  638. $wxParams = [
  639. 'orderSn' => $outTradeNo,
  640. 'amount' => 0.16,
  641. 'capitalType' => $currentCapitalType,
  642. 'notifyUrl' => $notifyUrl,
  643. ];
  644. $response = $laResource->driveWxPay($wxParams);
  645. if ($response && isset($response['cmdRetCode']) && $response['cmdRetCode'] == 'GLOBAL_SUCCESS') {
  646. echo '<pre>';
  647. echo "下单成功<br/>";
  648. print_r($response);
  649. } else {
  650. echo '<pre>';
  651. echo "下单失败<br/>";
  652. print_r($response);
  653. }
  654. }
  655. //dada 城市code
  656. public function actionDadaCityCode()
  657. {
  658. $res = dada::getCityCode(0);
  659. util::success($res);
  660. }
  661. //理由
  662. public function actionDadaReasons()
  663. {
  664. $res = dada::getCancelReason(0);
  665. util::success($res);
  666. }
  667. //达达 :下单
  668. public function actionDadaAddOrder()
  669. {
  670. $orderSn = 'XSD_CS26316851';
  671. $orderInfo = OrderClass::getByOrderSn($orderSn);
  672. $res = DadaExpressServices::addOrder($orderInfo);
  673. util::success($res);
  674. }
  675. //重发快递
  676. public function actionDadaReAdd()
  677. {
  678. $orderSn = 'XSD_CS26316851';
  679. $orderInfo = OrderClass::getByOrderSn($orderSn);
  680. $res = DadaExpressServices::reAddOrder($orderInfo);
  681. util::success($res);
  682. }
  683. //达达状态查询
  684. public function actionDadaOrderStatus()
  685. {
  686. $orderSn = 'XSD_CS26316851';
  687. $res = DadaExpressServices::statusOrder($orderSn);
  688. util::success($res);
  689. }
  690. //达达取消下单
  691. public function actionDadaCancelOrder()
  692. {
  693. $orderSn = 'XSD_CS26316851';
  694. $res = DadaExpressServices::cancelOrder($orderSn, 1);
  695. util::success($res);
  696. }
  697. //获取已支持的配送公司列表接口
  698. public function actionGetAllDelivery()
  699. {
  700. $data = MiniExpressService::getAllImmeDelivery();
  701. util::success($data);
  702. }
  703. //即时配送
  704. /*
  705. * Array
  706. (
  707. [resultcode] => 0
  708. [resultmsg] => OK
  709. [shop_list] => Array
  710. (
  711. [0] => Array
  712. (
  713. [shopid] => 1588714266
  714. [delivery_id] => SFTC
  715. [audit_result] => 0
  716. [create_time] => 1612172838
  717. [remark] =>
  718. [delivery_name] => 顺丰同城急送
  719. )
  720. )
  721. )
  722. */
  723. public function actionGetBindAccount()
  724. {
  725. $merchant = WxOpenClass::getGhsWxInfo();
  726. $isOpen = 2;
  727. $r = miniUtil::getBindAccount($merchant, $isOpen);
  728. dd($r);
  729. }
  730. //下单 (沙箱)
  731. /**
  732. * Array
  733. * (
  734. * [resultcode] => 0
  735. * [resultmsg] => ok
  736. * [fee] => 10
  737. * [waybill_id] => test_shop_id1612365974_waybillid
  738. * [order_status] => 101
  739. * [dispatch_duration] => 300
  740. * )
  741. */
  742. public function actionCreateWaybill()
  743. {
  744. $merchant = WxOpenClass::getGhsWxInfo();
  745. $isOpen = 2;
  746. $shopId = 'test_shop_id';
  747. $shopOrderId = 'test_shop_id' . time();
  748. $appSecret = 'test_app_secrect';
  749. $data = [
  750. 'shopid' => $shopId,
  751. 'shop_order_id' => $shopOrderId,
  752. 'shop_no' => '1',
  753. 'delivery_sign' => miniUtil::getDeliverySign($shopId, $shopOrderId, $appSecret), //,则delivery_sign=SHA1(shopid + shop_order_id + AppSecret)
  754. 'delivery_id' => "TEST",
  755. 'openid' => 'oGKMp45YLxewOTWEbpMFzWoVqdW0',
  756. 'sender' => [
  757. 'name' => 'test',
  758. 'city' => '厦门市',
  759. 'address' => '思明区',
  760. 'address_detail' => '软件园二期',
  761. 'phone' => '19959271111',
  762. 'lng' => 118.134343,
  763. 'lat' => 24.483566,
  764. 'coordinate_type' => 0,
  765. ],
  766. 'receiver' => [
  767. 'name' => 'test',
  768. 'city' => '厦门市',
  769. 'address' => '思明区',
  770. 'address_detail' => '软件园二期',
  771. 'phone' => '19959271111',
  772. 'lng' => 118.134343,
  773. 'lat' => 24.493566,
  774. 'coordinate_type' => 0,
  775. ],
  776. 'cargo' => [
  777. 'goods_value' => 1,
  778. 'goods_weight' => 0.1,
  779. 'cargo_first_class' => '鲜花',
  780. 'cargo_second_class' => '鲜花',
  781. ],
  782. 'order_info' => [
  783. 'order_type' => 0,
  784. ],
  785. 'shop' => [
  786. 'wxa_path' => '/shop',
  787. 'img_url' => 'http://www.baidu.com/test.png',
  788. 'goods_name' => 'test',
  789. 'goods_count' => 1,
  790. ],
  791. ];
  792. $r = miniUtil::addOrder($data, $merchant, $isOpen);
  793. dd($r);
  794. }
  795. //获取运单数据
  796. /**
  797. * Array
  798. * (
  799. * [resultcode] => 0
  800. * [resultmsg] => ok
  801. * [order_status] => 101
  802. * [agent_info] => Array
  803. * (
  804. * )
  805. *
  806. * [waybill_id] => test_shop_id1612365974_waybillid
  807. * [rider_name] =>
  808. * [rider_phone] =>
  809. * [order_token] => NsXweKCKhSyAEIhAdnX3TYZsVDES0-t-tymHDONG0MpRsF31dQvVxiP_JJvLFaKS-kwXuOG3D0hzKkl7o-gzew
  810. * )
  811. */
  812. public function actionGetOrder()
  813. {
  814. $shopId = 'test_shop_id';
  815. $shopOrderId = 'test_shop_id1612365974';
  816. $appSecret = 'test_app_secrect';
  817. $merchant = WxOpenClass::getGhsWxInfo();
  818. $isOpen = 2;
  819. $data = [
  820. 'shopid' => $shopId,
  821. 'shop_order_id' => $shopOrderId,
  822. 'shop_no' => '1',
  823. 'delivery_sign' => MiniExpressService::getDeliverySign($shopId, $shopOrderId, $appSecret),
  824. ];
  825. $r = miniUtil::getOrder($data, $merchant, $isOpen);
  826. dd($r);
  827. }
  828. //沙盒 更新快递状态
  829. public function actionMockUpdateOrder()
  830. {
  831. $merchant = WxOpenClass::getGhsWxInfo();
  832. $isOpen = 2;
  833. /**
  834. * {
  835. * "shopid": "test_shop_id",
  836. * "shop_order_id": "xxxxxxxxxxx",
  837. * "waybill_id": "xxxxxxxxxxxxx",
  838. * "action_time": 12345678,
  839. * "order_status": 101,
  840. * "action_msg": "",
  841. * }
  842. */
  843. $shopId = 'test_shop_id';
  844. $shopOrderId = 'test_shop_id1612365974';
  845. $data = [
  846. 'shop_order_id' => $shopOrderId,
  847. "shopid" => $shopId,
  848. "action_time" => time(),
  849. "order_status" => 302,
  850. 'action_msg' => '状态变更',
  851. ];
  852. $r = miniUtil::mockUpdateOrder($data, $merchant, $isOpen);
  853. dd($r);
  854. }
  855. public function actionTest()
  856. {
  857. }
  858. //新增订单
  859. public function actionAddOrder()
  860. {
  861. $dada = Yii::getAlias("@vendor/dada/");
  862. require_once $dada . 'api/addOrderApi.php';
  863. require_once $dada . 'client/dadaRequestClient.php';
  864. require_once $dada . 'client/dadaResponse.php';
  865. require_once $dada . 'config/config.php';
  866. require_once $dada . 'model/orderModel.php';
  867. // isOnline 判断是否是测试环境,会有不同的域名等
  868. $isOnline = false;
  869. $sourceId = 1000000;
  870. // 初始化一个config
  871. $config = new \Config($sourceId, $isOnline);
  872. $orderModel = new \OrderModel();
  873. $orderModel->setShopNo('11047059');
  874. $orderModel->setOriginId('2018091100000002');
  875. $orderModel->setCityCode('021');
  876. $orderModel->setCargoPrice(10);
  877. $orderModel->setIsPrepay(0);
  878. $orderModel->setReceiverName('测试达达');
  879. $orderModel->setReceiverAddress('上海市崇明岛');
  880. $orderModel->setReceiverLat(31.63);
  881. $orderModel->setReceiverLng(121.41);
  882. $orderModel->setReceiverPhone('18588888888');
  883. $orderModel->setCallback('http://api.b.huaml.com/data/request');
  884. // api主要有2个参数,一个是url, 一个是业务参数
  885. $addOrderApi = new \AddOrderApi(json_encode($orderModel));
  886. $dada_client = new \DadaRequestClient($config, $addOrderApi);
  887. $resp = $dada_client->makeRequest();
  888. echo json_encode($resp);
  889. }
  890. //订单详情查询
  891. public function actionOrderQuery()
  892. {
  893. $dada = Yii::getAlias("@vendor/dada/");
  894. require_once $dada . 'api/OrderQueryApi.php';
  895. require_once $dada . 'client/dadaRequestClient.php';
  896. require_once $dada . 'client/dadaResponse.php';
  897. require_once $dada . 'config/config.php';
  898. require_once $dada . 'model/orderModel.php';
  899. // isOnline 判断是否是测试环境,会有不同的域名等
  900. $isOnline = false;
  901. $sourceId = 1000000;
  902. // 初始化一个config
  903. $config = new \Config($sourceId, $isOnline);
  904. $orderModel = new \OrderModel();
  905. $orderModel->setOrderId('2018091100000002');
  906. // api主要有2个参数,一个是url, 一个是业务参数
  907. $addOrderApi = new \OrderQueryApi(json_encode($orderModel));
  908. $dada_client = new \DadaRequestClient($config, $addOrderApi);
  909. $resp = $dada_client->makeRequest();
  910. echo json_encode($resp);
  911. }
  912. public function actionFocus()
  913. {
  914. $name = '花卉宝';
  915. if (getenv('YII_ENV') == 'dev') {
  916. $name = '花美灵';
  917. }
  918. $merchant = MerchantService::getByCondition(['name' => $name]);
  919. $list = wxUtil::getSubscribeUserList($merchant);
  920. dd($list);
  921. }
  922. //宝贝售出提醒 ssh 2020.1.30
  923. public function actionInform()
  924. {
  925. $merchant = MerchantService::getMerchantById(12362);
  926. $order = OrderService::getById(214810);
  927. InformAdminClass::sendComplete($order);
  928. }
  929. public function actionNotice()
  930. {
  931. $data = ['messageType' => 'inform', 'informWay' => 'wx', 'userType' => 'admin', 'id' => 6, 'mobile' => '15280215347'];
  932. $producer = Yii::$app->rabbitmq->getProducer('informProducer');
  933. echo '<pre>';
  934. print_r($data);
  935. $msg = serialize($data);
  936. $r = $producer->publish($msg, 'informExchange', 'informRoute');
  937. }
  938. }