151 lines
3.8 KiB
PHP
151 lines
3.8 KiB
PHP
<?php
|
|
|
|
namespace App\Service\Common\Pay\Wx;
|
|
|
|
use App\Constants\Common\OrderCode;
|
|
use App\Service\ServiceTrait\Api\CateringTrait;
|
|
use App\Service\ServiceTrait\Api\CheckOrderCallBackTrait;
|
|
use App\Service\ServiceTrait\Api\CouponTrait;
|
|
use App\Service\ServiceTrait\Api\GoodOrderTrait;
|
|
use App\Service\ServiceTrait\Api\OrderTrait;
|
|
use App\Service\ServiceTrait\Api\PayFinishTrait;
|
|
use App\Service\ServiceTrait\Api\RefundOrderTrait;
|
|
use App\Service\ServiceTrait\Common\OrderChangeStatusTrait;
|
|
use Hyperf\DbConnection\Db;
|
|
use Psr\Container\ContainerExceptionInterface;
|
|
use Psr\Container\NotFoundExceptionInterface;
|
|
use Psr\Http\Message\ResponseInterface;
|
|
use Yansongda\Artful\Exception\InvalidParamsException;
|
|
use function Hyperf\Config\config;
|
|
|
|
class WxJsRechargeOrderService extends WxJsRechargeBaseService
|
|
{
|
|
use CheckOrderCallBackTrait,
|
|
GoodOrderTrait,
|
|
PayFinishTrait,
|
|
RefundOrderTrait,
|
|
OrderTrait,
|
|
OrderChangeStatusTrait,
|
|
CateringTrait,
|
|
CouponTrait;
|
|
|
|
/**
|
|
*
|
|
*/
|
|
const int OrderType = OrderCode::ORDER_TYPE_GOOD;
|
|
|
|
/**
|
|
* 订单 id
|
|
* @var int
|
|
*/
|
|
protected int $orderId;
|
|
|
|
/**
|
|
* @var string
|
|
*/
|
|
protected string $orderNo;
|
|
|
|
/**
|
|
* @var mixed
|
|
*/
|
|
protected mixed $orderInfo;
|
|
|
|
/**
|
|
* @var mixed
|
|
*/
|
|
protected mixed $payInfo;
|
|
|
|
/**
|
|
* @var mixed
|
|
*/
|
|
protected mixed $refundInfo;
|
|
|
|
/**
|
|
* @var bool 是否加入配餐数据
|
|
*/
|
|
protected bool $isCatering = true;
|
|
|
|
/**
|
|
* @return ResponseInterface
|
|
* @throws ContainerExceptionInterface
|
|
* @throws NotFoundExceptionInterface
|
|
* @throws InvalidParamsException
|
|
*/
|
|
public function callBackHandle(): ResponseInterface
|
|
{
|
|
$this->getWechatData();
|
|
|
|
$this->checkWxCallBackOrder();
|
|
|
|
$this->checkOrder();
|
|
|
|
Db::transaction(function (){
|
|
$this->manageOrder();
|
|
|
|
$this->manageWxOrder();
|
|
//
|
|
$this->isCatering = $this->manageAddCateringLog();
|
|
});
|
|
|
|
//已经截单 自动退款
|
|
if (!$this->isCatering) $this->joinRefundQueue($this->orderId,OrderCode::ORDER_TYPE_GOOD,$this->orderInfo->actual_price,'已截单,系统自动退款');
|
|
|
|
//todo 发送订阅通知
|
|
// $this->sendGainCoinMsg();
|
|
|
|
//发送mq通知报表结算
|
|
// $this->sendShareExMq($this->orderInfo->mid,ShareExCode::RECHARGE_COIN, [
|
|
// 'order_id' => $this->orderInfo->id,
|
|
// 'count' => $this->rechargeCoin,
|
|
// ]);
|
|
|
|
return $this->returnSuccess();
|
|
}
|
|
|
|
/**
|
|
* @return ResponseInterface
|
|
* @throws ContainerExceptionInterface
|
|
* @throws InvalidParamsException
|
|
* @throws NotFoundExceptionInterface
|
|
*/
|
|
public function refundCallBackHandle(): ResponseInterface
|
|
{
|
|
$this->getWechatData();
|
|
|
|
$this->checkWxRefundCallBackOrder();
|
|
|
|
$this->checkRefundOrder();
|
|
|
|
Db::transaction(function (){
|
|
$this->manageRefundOrder();
|
|
|
|
$this->manageOrderByRefund();
|
|
|
|
$this->manageSubCateringLog();
|
|
|
|
if ($this->orderInfo->coupin_id > 0) $this->rollbackCoupon(OrderCode::ORDER_TYPE_GOOD,$this->orderInfo);
|
|
});
|
|
|
|
$this->sendStockMq($this->orderInfo->id,$this->orderInfo->status);
|
|
|
|
return $this->returnSuccess();
|
|
}
|
|
|
|
/**
|
|
* @return void
|
|
*/
|
|
public function setNotify(): void
|
|
{
|
|
//返回的回调地址
|
|
$this->config['wechat']['default']['notify_url'] = config('system.api_url').'/common/wxPay/order/js/callBack';
|
|
}
|
|
|
|
/**
|
|
* @return void
|
|
*/
|
|
public function setRefundNotify(): void
|
|
{
|
|
//返回的退款回调地址
|
|
$this->config['wechat']['default']['notify_url'] = config('system.api_url').'/common/wxPay/order/js/refund/callBack';
|
|
}
|
|
} |