|
|
|
<?php
|
|
|
|
declare (strict_types=1);
|
|
|
|
|
|
|
|
namespace app\api\controller;
|
|
|
|
|
|
|
|
use app\common\model\WxwholesalerAccount;
|
|
|
|
use cores\BaseController;
|
|
|
|
use think\db\exception\DataNotFoundException;
|
|
|
|
use think\db\exception\DbException;
|
|
|
|
use think\db\exception\ModelNotFoundException;
|
|
|
|
|
|
|
|
class Wxwholesaler extends BaseController
|
|
|
|
{
|
|
|
|
|
|
|
|
public function verifyTicket()
|
|
|
|
{
|
|
|
|
$xmlData = file_get_contents("php://input");
|
|
|
|
$obj = new \app\common\library\wxserver\Wholesaler();
|
|
|
|
$obj->getVerifyTicket($xmlData);
|
|
|
|
echo 'success';
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @notes:授权回调
|
|
|
|
* @throws DataNotFoundException
|
|
|
|
* @throws DbException
|
|
|
|
* @throws ModelNotFoundException
|
|
|
|
* @author: wanghousheng
|
|
|
|
*/
|
|
|
|
public function redirect()
|
|
|
|
{
|
|
|
|
$authorization_code = $this->request->get('auth_code');
|
|
|
|
if ($authorization_code) {
|
|
|
|
$obj = new \app\common\library\wxserver\Wholesaler();
|
|
|
|
$obj->authorizationInfo($authorization_code, $this->request->domain(true));
|
|
|
|
}
|
|
|
|
echo 'success';
|
|
|
|
}
|
|
|
|
|
|
|
|
public function callback($appid)
|
|
|
|
{
|
|
|
|
$obj = new \app\common\library\wxserver\Wholesaler();
|
|
|
|
$signature = $this->request->get('signature');
|
|
|
|
$timestamp = $this->request->get('timestamp');
|
|
|
|
$nonce = $this->request->get('nonce');
|
|
|
|
if ($signature && $timestamp && $nonce) {
|
|
|
|
if ($obj->checkSignature($signature, $timestamp, $nonce)) {
|
|
|
|
$xmlData = file_get_contents("php://input");
|
|
|
|
if ($xmlData) {
|
|
|
|
$data = $obj->decryptXml($xmlData);
|
|
|
|
if (!empty($data['MsgType'])) {
|
|
|
|
if ($data['MsgType'] == 'event' && !empty($data['Event'])) {
|
|
|
|
$up = [];
|
|
|
|
if ($data['Event'] == 'weapp_audit_success') {
|
|
|
|
$up['audit_status'] = 2;
|
|
|
|
$obj->release($appid);//审核通过发布版本
|
|
|
|
} elseif ($data['Event'] == 'weapp_audit_fail') {
|
|
|
|
$up['audit_status'] = 3;
|
|
|
|
} elseif ($data['Event'] == 'weapp_audit_delay') {
|
|
|
|
$up['audit_status'] = 4;
|
|
|
|
}
|
|
|
|
if (!empty($data['Reason'])) {
|
|
|
|
$up['audit_reason'] = $data['Reason'];
|
|
|
|
}
|
|
|
|
if ($up && $appid) {
|
|
|
|
$model = new WxwholesalerAccount();
|
|
|
|
$model->update($up, ['appid' => $appid]);
|
|
|
|
}
|
|
|
|
echo 'success';
|
|
|
|
} elseif ($data['MsgType'] == 'text' && !empty($data['Content'])) {
|
|
|
|
if ($data['Content'] == 'TESTCOMPONENT_MSG_TYPE_TEXT') {
|
|
|
|
$data['Content'] = 'TESTCOMPONENT_MSG_TYPE_TEXT_callback';
|
|
|
|
} elseif (strpos($data['Content'], 'QUERY_AUTH_CODE:') !== false) {
|
|
|
|
$query_auth_code = trim(str_replace("QUERY_AUTH_CODE:", "", $data['Content']));
|
|
|
|
$obj->apiText($query_auth_code, $data['FromUserName']);
|
|
|
|
}
|
|
|
|
echo $this->responseText($data);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
private function responseText($data): string
|
|
|
|
{
|
|
|
|
$template = "<xml>
|
|
|
|
<ToUserName><![CDATA[%s]]></ToUserName>
|
|
|
|
<FromUserName><![CDATA[%s]]></FromUserName>
|
|
|
|
<CreateTime>%s</CreateTime>
|
|
|
|
<MsgType><![CDATA[%s]]></MsgType>
|
|
|
|
<Content><![CDATA[%s]]></Content>
|
|
|
|
</xml>";
|
|
|
|
$fromUser = $data['ToUserName'];
|
|
|
|
$toUser = $data['FromUserName'];
|
|
|
|
$content = !empty($data['Content']) ? $data['Content'] : 'success';
|
|
|
|
$time = time();
|
|
|
|
$msgType = 'text';
|
|
|
|
return sprintf($template, $toUser, $fromUser, $time, $msgType, $content);
|
|
|
|
}
|
|
|
|
}
|