WxOpenController.php 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559
  1. <?php
  2. namespace www\controllers;
  3. use common\services\xhMerchantExtendService;
  4. use Yii;
  5. use common\services\xhApplyOrderService;
  6. use common\services\xhWxMenuService;
  7. use common\services\xhMerchantService;
  8. use common\services\xhInviteService;
  9. use common\components\util;
  10. use common\components\configDict;
  11. use common\services\xhWxOpenService;
  12. use common\components\stringUtil;
  13. use common\components\wxUtil;
  14. use common\services\xhSetMealService;
  15. use yii\helpers\Json;
  16. use common\models\xhWxOpen;
  17. use linslin\yii2\curl;
  18. /**
  19. * 微信开放平台相关
  20. */
  21. class WxOpenController extends PublicController
  22. {
  23. public $withoutLogin = ['callback-create-first-merchant'];
  24. //开放平台开始授权 shish 2020.1.16
  25. public function actionBeginAuth()
  26. {
  27. $id = 1;
  28. $open = xhWxOpenService::getById($id);
  29. $pre = wxUtil::getPreAuthCode($open);
  30. $appId = $open['appId'];
  31. $oData = [];
  32. $oData['preAuthCodeTime'] = date("Y-m-d H:i:s");
  33. //设置预授码过期,让下个用户可以获取新的预授码
  34. xhWxOpenService::updateById($id, $oData);
  35. $url = Yii::$app->params['wHost'] . '/wx-open/callback';
  36. $merchantId = $open['merchantId'];
  37. //如果平台没有对应的商家,先去创建第一个商家并做关联
  38. if (empty($merchantId)) {
  39. $url = Yii::$app->params['wHost'] . '/wx-open/callback-create-first-merchant';
  40. }
  41. echo "<a href='https://mp.weixin.qq.com/cgi-bin/componentloginpage?component_appid={$appId}&pre_auth_code={$pre}&redirect_uri={$url}'>授权</a>";
  42. }
  43. public function actionCheckMerchantName()
  44. {
  45. $get = Yii::$app->request->get();
  46. $merchantName = isset($get['merchantName']) ? $get['merchantName'] : '';
  47. $m = xhMerchantService::getByMerchantName($merchantName);
  48. if (!empty($m)) {
  49. util::failInfo('公众号名称已经使用');
  50. }
  51. util::successInfo();
  52. }
  53. /**
  54. * 下载微信里的图片到服务器
  55. */
  56. public function actionDownloadWxImg()
  57. {
  58. $get = Yii::$app->request->get();
  59. $mediaId = isset($get['mediaId']) ? $get['mediaId'] : '';
  60. $imgList = wxUtil::downloadmediaIdImg($this->merchant, $mediaId);
  61. if (!empty($imgList)) {
  62. util::successInfo('操作成功', 'A0001', $imgList);
  63. }
  64. util::failInfo();
  65. }
  66. /**
  67. * 创建第一个商家
  68. */
  69. public function actionCallbackCreateFirstMerchant()
  70. {
  71. $get = Yii::$app->request->get();
  72. if (isset($get['auth_code']) == false) {
  73. util::stop('公众号授权回调未成功');
  74. }
  75. $code = $get['auth_code'];
  76. //使用授权码换取公众号的接口调用凭据和授权信息
  77. $authorize = wxUtil::getAuthorizer($code);
  78. if (isset($authorize['authorization_info']) == false) {
  79. util::stop('未换取公众号的接口调用凭据和授权信息');
  80. }
  81. $info = $authorize['authorization_info'];
  82. $authorizeAppId = $info['authorizer_appid'];
  83. $authorize_access_token = $info['authorizer_access_token'];
  84. $expires_in = $info['expires_in'];//7200
  85. $authorize_refresh_token = $info['authorizer_refresh_token'];
  86. //获取授权方的公众号帐号基本信息
  87. $authorizeDetailInfo = wxUtil::getAuthorizerInfo($authorizeAppId);
  88. if (isset($authorizeDetailInfo['authorizer_info']) == false) {
  89. util::stop('没有获取到公众号帐号基本信息');
  90. }
  91. $authorize_info = $authorizeDetailInfo['authorizer_info'];
  92. $nick_name = $authorize_info['nick_name'];
  93. $head_img = $authorize_info['head_img'];
  94. $service_type_info = $authorize_info['service_type_info'];
  95. if ($service_type_info['id'] != 2) {
  96. util::stop('公众号不是服务号');
  97. }
  98. $verify_type_info = $authorize_info['verify_type_info'];
  99. if ($verify_type_info['id'] != 0) {
  100. util::stop('公众号还没有认证哦');
  101. }
  102. $user_name = $authorize_info['user_name'];
  103. $alias = $authorize_info['alias'];
  104. $qrCodeUrl = $authorize_info['qrcode_url'];
  105. $business_info = $authorize_info['business_info'];
  106. $open_pay = $business_info['open_pay'];
  107. $merchant = xhMerchantService::getByAppId($authorizeAppId);
  108. $wxAccessTokenTime = date("Y-m-d H:i:s", (time() + $expires_in - 100));//安全起见,将过期时间设置得比微信里还短100秒
  109. if (!empty($merchant)) {
  110. util::stop('此公众号已经授权过了');
  111. }
  112. //引导生成商家
  113. $date = date("Y-m-d H:i:s");
  114. $trainDemo = configDict::getConfig('trainDemo');
  115. //$logo = xhMerchantService::logoSave($head_img, $authorizeAppId);
  116. $logo = '';
  117. $appData['logo'] = $logo;
  118. //保存公众号二维码
  119. //$wxQrCodeUrl = xhMerchantService::qrCodeSave($qrCodeUrl, $authorizeAppId);
  120. $wxQrCodeUrl = '';
  121. $appData['wxQrcodeUrl'] = $wxQrCodeUrl;
  122. $appData['wxAppId'] = $authorizeAppId;
  123. $appData['wxUserName'] = $user_name;
  124. $appData['wxAliasName'] = $alias;
  125. $appData['wxAccessToken'] = $authorize_access_token;
  126. $appData['wxAccessTokenTime'] = $wxAccessTokenTime;
  127. $appData['wxRefreshToken'] = $authorize_refresh_token;
  128. $appData['accountStyle'] = 0;//认证服务号
  129. $appData['status'] = 0;//待审核
  130. $appData['createTime'] = $date;
  131. $appData['updateTime'] = $date;
  132. $appData['shopLat'] = (string)0;
  133. $appData['shopLong'] = (string)0;
  134. $appData['shopPrecision'] = (string)0;
  135. $appData['account'] = $trainDemo['platform']['account'];
  136. $appData['adminId'] = 0;
  137. $appData['wxToken'] = stringUtil::buildWxToken(0);
  138. $appData['shopPhotoList'] = '';
  139. $appData['merchantName'] = $nick_name;
  140. $appData['shopProvince'] = '福建';
  141. $appData['shopCity'] = '厦门';
  142. $appData['shopDist'] = '思明区';
  143. $appData['alipayAccount'] = 'shishaohua8879@sina.com';
  144. $appData['alipayAccountName'] = '石少华';
  145. $appData['agentLevel'] = 1;//默认设置为代理商
  146. $merchant = xhMerchantService::applyCreateMerchant($appData);
  147. $wxOpenId = configDict::getConfig('openId');
  148. $merchantId = $merchant['id'];
  149. $account = $merchant['id'];
  150. $createTime = date("Y-m-d H:i:s");
  151. $orderId = 'A' . stringUtil::buildOrderNo();
  152. $orderData = ['id' => $orderId, 'userId' => 0, 'applyName' => $nick_name, 'email' => '',
  153. 'createTime' => $createTime, 'accountId' => 0, 'inviteCode' => '', 'merchantId' => $merchantId, 'invitedMerchantId' => $merchantId,
  154. 'prePrice' => 0, 'actPrice' => 0, 'deadline' => time() + 2592000, 'inviteCodeStatus' => 0, 'payStatus' => 1,
  155. ];
  156. xhWxOpenService::updateById($wxOpenId, ['merchantId' => $merchantId]);
  157. //xhApplyOrderService::add($orderData);//保存订单信息
  158. //xhWxMenuService::applyInit($merchant);//初始化微信菜单
  159. //$openMerchant = xhWxOpenService::getMerchant();
  160. //$openMerchantAccount = $openMerchant['id'];
  161. //将新生成的商家account加密传到后台绑定管理员,密钥有效期5分钟
  162. //$newAccount = urlencode(stringUtil::authcode($account, 'ENCODE', 300));
  163. echo 'ok';
  164. }
  165. public function actionCallback()
  166. {
  167. $get = Yii::$app->request->get();
  168. if (isset($get['auth_code']) == false) {
  169. util::stop('公众号授权回调未成功');
  170. }
  171. $code = $get['auth_code'];
  172. //使用授权码换取公众号的接口调用凭据和授权信息
  173. $authorize = wxUtil::getAuthorizer($code);
  174. if (isset($authorize['authorization_info']) == false) {
  175. util::stop('未换取公众号的接口调用凭据和授权信息');
  176. }
  177. $info = $authorize['authorization_info'];
  178. $authorizeAppId = $info['authorizer_appid'];
  179. $authorize_access_token = $info['authorizer_access_token'];
  180. $expires_in = $info['expires_in'];//7200
  181. $authorize_refresh_token = $info['authorizer_refresh_token'];
  182. //获取授权方的基本信息
  183. $authorizeDetailInfo = wxUtil::getAuthorizerInfo($authorizeAppId);
  184. if (isset($authorizeDetailInfo['authorizer_info']) == false) {
  185. util::stop('没有获取到公众号帐号基本信息');
  186. }
  187. $authorize_info = $authorizeDetailInfo['authorizer_info'];
  188. $nick_name = $authorize_info['nick_name'];
  189. $head_img = $authorize_info['head_img'];
  190. $service_type_info = $authorize_info['service_type_info'];
  191. if (isset($authorize_info['MiniProgramInfo']) == false || empty($authorize_info['MiniProgramInfo'])) {
  192. if ($service_type_info['id'] != 2) {
  193. util::stop('公众号不是服务号,appId:' . $authorizeAppId . ' refresh:' . $authorize_refresh_token);
  194. }
  195. }
  196. $verify_type_info = $authorize_info['verify_type_info'];
  197. if ($verify_type_info['id'] != 0) {
  198. util::stop('公众号还没有认证哦');
  199. }
  200. $user_name = $authorize_info['user_name'];
  201. $alias = $authorize_info['alias'];
  202. $qrCodeUrl = $authorize_info['qrcode_url'];
  203. $business_info = $authorize_info['business_info'];
  204. $open_pay = $business_info['open_pay'];
  205. $accessTokenTime = date("Y-m-d H:i:s", (time() + $expires_in - 100));//安全起见,将过期时间设置得比微信里还短100秒
  206. //小程序
  207. if (isset($authorize_info['MiniProgramInfo']) && !empty($authorize_info['MiniProgramInfo'])) {
  208. $merchant = xhMerchantService::getByCondition(['miniAppId' => $authorizeAppId]);
  209. if (empty($merchant)) {
  210. Yii::info('没有小程序信息 appId:' . $authorizeAppId);
  211. util::stop('没有小程序信息 appId:' . $authorizeAppId);
  212. }
  213. $merchantId = $merchant['id'];
  214. xhMerchantExtendService::updateByMerchantId($merchantId, ['miniAccessToken' => $authorize_access_token, 'miniAccessTokenTime' => $accessTokenTime, 'miniRefreshToken' => $authorize_refresh_token]);
  215. Yii::info('小程序信息更新成功:' . json_encode($authorize_info));
  216. util::stop("小程序信息更新成功");
  217. } else {
  218. $merchant = xhMerchantService::getByAppId($authorizeAppId);
  219. Yii::info('appId:' . $authorizeAppId);
  220. $set = xhSetMealService::getRandOne();
  221. if (empty($set)) {
  222. util::stop('没有套餐信息');
  223. }
  224. if (empty($merchant)) {
  225. util::stop('这个商家没有生成过基本信息。appid:' . $authorizeAppId);
  226. }
  227. if (empty($merchant)) {
  228. echo '新建商家能力暂时关闭';
  229. Yii::$app->end();
  230. //没有生成商家,引导进去设置
  231. $session = Yii::$app->session;
  232. $session['wxAppId'] = $authorizeAppId;
  233. $session['wxUserName'] = $user_name;
  234. $session['wxAliasName'] = $alias;
  235. $session['wxAccessToken'] = $authorize_access_token;
  236. $session['wxAccessTokenTime'] = $accessTokenTime;
  237. $session['wxRefreshToken'] = $authorize_refresh_token;
  238. $session['logo'] = $head_img;
  239. $session['wxQrcodeUrl'] = $qrCodeUrl;
  240. $session['allowGenerateMerchant'] = 'ok';//经过授权流程,允许允许生成商家
  241. $trainDemo = configDict::getConfig('trainDemo');
  242. $demoName = $trainDemo['merchant']['name'];//培训演示的公众号
  243. return $this->renderPartial('callback', ['merchantName' => $nick_name, 'set' => $set, 'demoName' => $demoName]);
  244. }
  245. $cData = [];
  246. $cData['wxAccessToken'] = $authorize_access_token;
  247. $cData['wxAccessTokenTime'] = $accessTokenTime;
  248. $cData['wxRefreshToken'] = $authorize_refresh_token;
  249. //审核通过
  250. $cData['status'] = 1;
  251. $merchantId = $merchant['id'];
  252. xhMerchantService::updateById($merchantId, $cData);
  253. }
  254. echo $authorizeAppId . ' ';
  255. exit('ok');
  256. $price = $set['price'];
  257. $now = time();
  258. $apply = xhApplyOrderService::getByMerchantId($merchantId);
  259. if (empty($apply)) {
  260. return $this->renderPartial('hint', ['msg' => '没有申请记录']);
  261. }
  262. $orderId = $apply['id'];
  263. $price = $apply['actPrice'];
  264. $openMerchant = xhWxOpenService::getMerchant();
  265. $openMerchantAccount = $openMerchant['id'];
  266. $account = $merchant['id'];
  267. //将新生成的商家account加密传到后台绑定管理员,密钥有效期5分钟
  268. $newAccount = urlencode(stringUtil::authcode($account, 'ENCODE', 300));
  269. if ($apply['payStatus'] == 1) {
  270. if (empty($merchant['adminId'])) {
  271. $this->redirect(Yii::$app->params['adminUrl'] . '/admin/generate?account=' . $openMerchantAccount . '&newAccount=' . $newAccount);
  272. util::end();
  273. }
  274. return $this->renderPartial('hint', ['msg' => '恭喜!您已申请成功。']);
  275. }
  276. if ($price > 0) {
  277. $this->redirect(Yii::$app->params['openUrl'] . '/pay/apply?orderId=' . $apply['id']);
  278. util::end();
  279. } else {
  280. $inviteCode = $order['inviteCode'];
  281. $now = time();
  282. if (!empty($inviteCode)) {
  283. $invite = xhInviteService::getByCode($inviteCode);
  284. if (empty($invite)) {
  285. return $this->renderPartial('hint', ['msg' => '邀请码不存在']);
  286. }
  287. if ($invite['takeStatus'] == 1) {//邀请码未使用,并且没有过期
  288. return $this->renderPartial('hint', ['msg' => '邀请码已经使用,请联系客服']);
  289. }
  290. $inviteDeadline = $invite['deadline'];
  291. if ($now > $inviteDeadline) {
  292. return $this->renderPartial('hint', ['msg' => '邀请码已经过期,请联系客服']);
  293. }
  294. xhInviteService::updateByCode($inviteCode, ['takeStatus' => 1, 'inviteUseTo' => 0, 'targetId' => $orderId, 'invitedMerchantId' => $merchantId]);
  295. }
  296. $updateData = ['inviteCodeStatus' => 1, 'payStatus' => 1, 'payWay' => 0, 'invitedMerchantId' => $merchantId];
  297. xhApplyOrderService::updateById($orderId, $updateData);
  298. $this->redirect(Yii::$app->params['adminUrl'] . '/admin/generate?account=' . $openMerchantAccount . '&newAccount=' . $newAccount);
  299. util::end();
  300. }
  301. }
  302. public function actionResult()
  303. {
  304. $get = Yii::$app->request->get();
  305. $id = isset($get['id']) ? $get['id'] : 0;
  306. $merchant = xhMerchantService::getById($id);
  307. $status = configDict::getConfig('merchantStatusName');
  308. $orMechantId = configDict::getConfig('merchantId');
  309. $originalMerchant = xhMerchantService::getById($orMechantId);
  310. return $this->renderPartial('result', ['originalMerchant' => $originalMerchant, 'merchant' => $merchant, 'status' => $status]);
  311. }
  312. /**
  313. * 商家申请入驻
  314. */
  315. public function actionAddMerchant()
  316. {
  317. $post = Yii::$app->request->post();
  318. $session = Yii::$app->session;
  319. if (isset($session['allowGenerateMerchant']) == false) {
  320. //util::failInfo('没有经过授权的操作');
  321. }
  322. unset($post['_csrf']);
  323. if (isset($session['wxAppId']) == false || empty($session['wxAppId'])) {
  324. util::failInfo('公众号appId不存在');
  325. }
  326. $wxAppId = $session['wxAppId'];
  327. if (isset($session['logo'])) {
  328. $logo = xhMerchantService::logoSave($session['logo'], $wxAppId);
  329. $post['logo'] = $logo;
  330. }
  331. if (isset($session['wxQrcodeUrl'])) {
  332. $wxQrCodeUrl = xhMerchantService::qrCodeSave($session['wxQrcodeUrl'], $wxAppId);
  333. $post['wxQrcodeUrl'] = $wxQrCodeUrl;
  334. }
  335. $date = date("Y-m-d H:i:s");
  336. $inviteCode = isset($post['inviteCode']) ? $post['inviteCode'] : '';
  337. $accountStyle = configDict::getConfig('accountStyle');
  338. $merchantStatus = configDict::getConfig('merchantStatus');
  339. $serviceAccount = $accountStyle['serviceAccount'];//认证服务号
  340. $checking = $merchantStatus['checking'];//审核中
  341. $merchantName = !empty($post['merchantName']) ? $post['merchantName'] : '';
  342. $exists = xhMerchantService::getByMerchantName($merchantName);
  343. if (!empty($exists)) {
  344. util::failInfo('花店名称已经存在了');
  345. }
  346. $post['wxAppId'] = $wxAppId;
  347. $post['wxUserName'] = $session['wxUserName'];
  348. $post['wxAliasName'] = $session['wxAliasName'];
  349. $post['wxAccessToken'] = $session['wxAccessToken'];
  350. $post['wxAccessTokenTime'] = $session['wxAccessTokenTime'];
  351. $post['wxRefreshToken'] = $session['wxRefreshToken'];
  352. $post['accountStyle'] = $serviceAccount;//认证服务号
  353. $post['status'] = $checking;//待审
  354. $post['createTime'] = $date;
  355. $post['updateTime'] = $date;
  356. $post['shopLat'] = isset($post['shopLat']) ? (string)$post['shopLat'] : (string)0;
  357. $post['shopLong'] = isset($post['shopLong']) ? (string)$post['shopLong'] : (string)0;
  358. $post['shopPrecision'] = isset($post['shopPrecision']) ? (string)$post['shopPrecision'] : (string)0;
  359. $account = stringUtil::buildOrderNo(0);
  360. $trainDemo = configDict::getConfig('trainDemo');
  361. $demoName = $trainDemo['merchant']['name'];//培训演示的公众号
  362. if (isset($post['merchantName']) && $post['merchantName'] == $demoName) {
  363. $account = $trainDemo['merchant']['account'];
  364. }
  365. $post['account'] = $account;
  366. $post['adminId'] = 0;
  367. $post['wxToken'] = stringUtil::buildWxToken(0);
  368. $shopPhotoListString = json_encode(["outdoor" => $post['shopImg'], 'indoor' => $post['shopImg2']]);//将门店照片组合成json
  369. $post['shopPhotoList'] = $shopPhotoListString;
  370. $merchant = xhMerchantService::applyCreateMerchant($post);
  371. $id = $merchant['id'];
  372. $account = $merchant['id'];
  373. unset($session['allowGenerateMerchant']);
  374. xhWxMenuService::applyInit($merchant);
  375. $set = xhSetMealService::getRandOne();
  376. $price = $set['price'];
  377. $actPrice = $price;
  378. $mainMerchantId = 0;
  379. $now = time();
  380. $orderDeadline = 0;
  381. if (!empty($inviteCode)) {
  382. $invite = xhInviteService::getByCode($inviteCode);
  383. if (empty($invite)) {
  384. util::failInfo('邀请码不存在');
  385. }
  386. if ($invite['takeStatus'] == 1) {//邀请码未使用,并且没有过期
  387. util::failInfo('邀请码已经使用');
  388. }
  389. $inviteDeadline = $invite['deadline'];
  390. if ($now > $inviteDeadline) {
  391. util::failInfo('邀请码已经过期');
  392. }
  393. $mainMerchantId = isset($invite['merchantId']) ? $invite['merchantId'] : 0;
  394. $actPrice = stringUtil::calcSub($set['price'], $invite['save']);//扣除邀请码里的钱
  395. }
  396. $toPay = $actPrice <= 0 ? 'no' : 'yes';//是否需要付款
  397. $inviteCodeStatus = $actPrice <= 0 ? 1 : 0;//邀请码是否已使用
  398. $payStatus = $actPrice <= 0 ? 1 : 0;//付款是否成功
  399. $createTime = date("Y-m-d H:i:s");
  400. $orderId = 'A' . stringUtil::buildOrderNo($id);
  401. $orderData = ['id' => $orderId, 'userId' => $this->userId, 'applyName' => $merchantName, 'email' => '',
  402. 'createTime' => $createTime, 'accountId' => 0, 'inviteCode' => $inviteCode, 'merchantId' => $mainMerchantId, 'invitedMerchantId' => $id,
  403. 'prePrice' => $price, 'actPrice' => $actPrice, 'deadline' => $orderDeadline, 'inviteCodeStatus' => (int)$inviteCodeStatus, 'payStatus' => $payStatus,
  404. ];
  405. xhApplyOrderService::add($orderData);//保存订单信息
  406. if ($actPrice <= 0 && !empty($inviteCode)) {
  407. xhInviteService::updateByCode($inviteCode, ['targetId' => $orderId, 'takeStatus' => 1, 'invitedMerchantId' => $id, 'inviteUseTo' => 0]);
  408. }
  409. $openMerchant = xhWxOpenService::getMerchant();
  410. $openMerchantAccount = $openMerchant['id'];
  411. $newAccount = urlencode(stringUtil::authcode($account, 'ENCODE', 300));
  412. util::successInfo('提交成功', 'A0001', ['account' => $openMerchantAccount, 'newAccount' => $newAccount, 'toPay' => $toPay, 'orderId' => $orderId, 'actPrice' => $actPrice]);
  413. }
  414. public function actionCheckInviteCode()
  415. {
  416. $get = Yii::$app->request->get();
  417. $code = isset($get['code']) ? $get['code'] : '';
  418. $invite = xhInviteService::getByCode($code);
  419. if (empty($invite)) {
  420. util::failInfo('邀请码错误');
  421. }
  422. $now = time();
  423. if ($now > $invite['deadline']) {
  424. util::failInfo('邀请码已经失效');
  425. }
  426. if (!empty($invite['takeStatus'])) {
  427. util::failInfo('邀请码已经使用');
  428. }
  429. util::successInfo('操作成功', 'A0001', $invite);
  430. }
  431. public function actionSelect()
  432. {
  433. $isWeixin = util::isWeixin();
  434. if ($isWeixin == false) {
  435. return $this->renderPartial('notWeixin');
  436. }
  437. return $this->renderPartial('select');
  438. }
  439. public function actionApi()
  440. {
  441. $openData = file_get_contents('php://input');
  442. if (isset ($openData) == false || empty($openData)) {
  443. util::stop('has no post data');
  444. }
  445. $weixinSecret = Yii::getAlias("@vendor/weixinSecret");
  446. require_once($weixinSecret . '/wxBizMsgCrypt.php');
  447. $get = Yii::$app->request->get();
  448. $encryptMsg = $openData;
  449. $openId = configDict::getConfig('openId');
  450. $open = xhWxOpenService::getById($openId);
  451. $encodingAesKey = $open['aesKey'];
  452. $token = $open['token'];
  453. $appId = $open['appId'];
  454. $signature = isset($get['signature']) ? $get['signature'] : '';
  455. $timestamp = isset($get['timestamp']) ? $get['timestamp'] : '';
  456. $nonce = isset($get['nonce']) ? $get['nonce'] : '';
  457. $encrypt_type = isset($get['encrypt_type']) ? $get['encrypt_type'] : '';
  458. $msg_signature = isset($get['msg_signature']) ? $get['msg_signature'] : '';
  459. $xml_tree = new \DOMDocument();
  460. $xml_tree->loadXML($encryptMsg);
  461. $array_e = $xml_tree->getElementsByTagName('Encrypt');
  462. $encrypt = $array_e->item(0)->nodeValue;
  463. $format = "<xml><ToUserName><![CDATA[toUser]]></ToUserName><Encrypt><![CDATA[%s]]></Encrypt></xml>";
  464. $from_xml = sprintf($format, $encrypt);
  465. $formString = '1:' . $token . ' 2:' . $encodingAesKey . ' 3:' . $appId . ' 4:' . $msg_signature . ' 5:' . $timestamp . ' 6:' . $nonce . ' 7:' . $from_xml;
  466. Yii::warning("formString:" . $formString);
  467. //第三方收到公众号平台发送的消息
  468. $pc = new \WXBizMsgCrypt($token, $encodingAesKey, $appId);
  469. $msg = '';//解密后的消息
  470. $errCode = $pc->decryptMsg($msg_signature, $timestamp, $nonce, $from_xml, $msg);
  471. if ($errCode != 0) {
  472. Yii::warning("解密未成功,错误代码:" . $errCode);
  473. Yii::$app->end();
  474. }
  475. $postObj = simplexml_load_string($msg, 'SimpleXMLElement', LIBXML_NOCDATA);
  476. $infoType = $postObj->InfoType;
  477. switch ($infoType) {
  478. //推送 componentVerifyTicket
  479. case 'component_verify_ticket':
  480. $componentVerifyTicket = $postObj->ComponentVerifyTicket;
  481. if (!empty($componentVerifyTicket)) {
  482. $oData = [];
  483. $oData['verifyTicket'] = (string)$componentVerifyTicket;
  484. $oData['verifyTicketTime'] = date("Y-m-d H:i:s", $timestamp + 600);//每10分钟(600秒)推一次
  485. xhWxOpenService::updateById($openId, $oData);
  486. Yii::warning("component_verify_ticket:" . (string)$componentVerifyTicket);
  487. util::stop('success');
  488. }
  489. break;
  490. //取消授权通知
  491. case 'unauthorized':
  492. $AppId = $postObj->AppId;
  493. $authorizeAppid = $postObj->AuthorizerAppid;
  494. $merchant = xhMerchantService::getByAppId($authorizeAppid);
  495. if (!empty($merchant)) {
  496. $merchantId = $merchant['id'];
  497. xhMerchantService::updateById($merchantId, ['status' => 5]);//自主冻结
  498. }
  499. break;
  500. //授权成功通知
  501. case 'authorized':
  502. $AppId = $postObj->AppId;//第三方平台appid
  503. $CreateTime = $postObj->CreateTime;//公众号
  504. $authorizeAppid = $postObj->AuthorizerAppid;//授权码,可用于换取公众号的接口调用凭据,详细见上面的说明
  505. $AuthorizationCode = $postObj->AuthorizationCode;
  506. $AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;//授权码过期时间
  507. break;
  508. //授权更新通知
  509. case 'updateauthorized':
  510. $AppId = $postObj->AppId;
  511. $CreateTime = $postObj->CreateTime;
  512. $authorizeAppid = $postObj->AuthorizerAppid;
  513. $AuthorizationCode = $postObj->AuthorizationCode;
  514. $AuthorizationCodeExpiredTime = $postObj->AuthorizationCodeExpiredTime;
  515. $authorize = wxUtil::getAuthorizer($AuthorizationCode);
  516. if (isset($authorize['authorization_info']) == false) {
  517. $msg = '授权回调获取到auth_code,但未换取公众号的接口调用凭据和授权信息!!';
  518. Yii::warning($msg, __METHOD__);
  519. Yii::$app->end();
  520. }
  521. $info = $authorize['authorization_info'];
  522. $authorizeAppId = $info['authorizer_appid'];
  523. $authorize_access_token = $info['authorizer_access_token'];
  524. $expires_in = $info['expires_in'];//7200
  525. $authorize_refresh_token = $info['authorizer_refresh_token'];
  526. $merchant = xhMerchantService::getByAppId($authorizeAppId);
  527. if (empty($merchant)) {
  528. return false;
  529. }
  530. $merchantId = $merchant['id'];
  531. $wxData = [];
  532. $wxData['wxAccessToken'] = $authorize_access_token;
  533. $wxData['wxRefreshToken'] = $authorize_refresh_token;
  534. $wxData['wxAccessTokenTime'] = date("Y-m-d H:i:s", (time() + $expires_in - 100));
  535. $wxData['status'] = 1;
  536. xhMerchantService::updateById($merchantId, $wxData);
  537. break;
  538. default:
  539. }
  540. Yii::warning("---wx open data end--- \n");
  541. }
  542. }