mirror of
https://gitee.com/ShopeX/ECShopX
synced 2026-06-28 19:15:36 +08:00
275 lines
11 KiB
PHP
275 lines
11 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace Tests\ShuyunOpenPlatform;
|
||
|
||
use GuzzleHttp\Client;
|
||
use GuzzleHttp\Handler\MockHandler;
|
||
use GuzzleHttp\HandlerStack;
|
||
use GuzzleHttp\Middleware;
|
||
use GuzzleHttp\Psr7\Response;
|
||
use ShuyunOpenPlatformBundle\Entities\CompanyShuyunOpenPlatformConfig;
|
||
use ShuyunOpenPlatformBundle\Repositories\CompanyShuyunOpenPlatformConfigRepository;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformGatewayClientFactory;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformOrderGatewayActions;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformRefundSyncService;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformShopSyncService;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformTradeSyncService;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformTrafficAuditWriter;
|
||
|
||
/**
|
||
* 计划 **Acceptance & Test Cases** 中与网关 HTTP 相关的条目 — Guzzle MockHandler 录制请求，不连外网。
|
||
*
|
||
* @see `.tasks/plans/shuyun-open-platform-order.md` A-ORD-FWD-02Z、FWD-03、REV-04、REV-05、GATE-02、PLAT（body 无 platform）
|
||
*/
|
||
class ShuyunOpenPlatformOrderAcceptanceMockTest extends \TestCase
|
||
{
|
||
/** A-ORD-FWD-02Z：零元单仍 POST trade.sync，金额字段允许为 0（D-ZERO-01） */
|
||
public function testAcceptanceFwd02ZeroYuanTradeSyncPayload(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->tradeServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":{},"msg":""}'),
|
||
]);
|
||
|
||
$order = $this->minimalTradeOrder();
|
||
$order['payment'] = 0.0;
|
||
$order['post_fee'] = 0.0;
|
||
$order['trade_discount_fee'] = 0.0;
|
||
|
||
$this->assertTrue($svc->syncValidatedTradeOrders(1, 'myplat', [$order]));
|
||
|
||
$body = (string) $container[0]['request']->getBody();
|
||
$decoded = json_decode($body, true);
|
||
$this->assertIsArray($decoded);
|
||
$this->assertArrayHasKey(0, $decoded);
|
||
$this->assertSame(0.0, (float) ($decoded[0]['payment'] ?? -1));
|
||
}
|
||
|
||
/** A-ORD-FWD-03：51 条 → 2 次 POST（50+1） */
|
||
public function testAcceptanceFwd03FiftyOneTradeOrdersTwoPosts(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->tradeServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":{},"msg":""}'),
|
||
new Response(200, [], '{"code":10000,"data":{},"msg":""}'),
|
||
]);
|
||
|
||
$base = $this->minimalTradeOrder();
|
||
$orders = [];
|
||
for ($i = 0; $i < 51; ++$i) {
|
||
$row = $base;
|
||
$row['order_id'] = (string) (900000 + $i);
|
||
$orders[] = $row;
|
||
}
|
||
|
||
$this->assertTrue($svc->syncValidatedTradeOrders(1, 'wxplat', $orders));
|
||
$this->assertCount(2, $container);
|
||
$this->assertSame(ShuyunOpenPlatformOrderGatewayActions::GATEWAY_ACTION_TRADE_SYNC, $container[0]['request']->getHeaderLine('Gateway-Action-Method'));
|
||
$this->assertSame(ShuyunOpenPlatformOrderGatewayActions::GATEWAY_ACTION_TRADE_SYNC, $container[1]['request']->getHeaderLine('Gateway-Action-Method'));
|
||
}
|
||
|
||
/** 正向 body 根为订单数组，元素内不传 `platform`（仅 Header） */
|
||
public function testAcceptanceTradeBodyJsonRootIsArrayWithoutPlatformKey(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->tradeServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":{},"msg":""}'),
|
||
]);
|
||
|
||
$this->assertTrue($svc->syncValidatedTradeOrders(1, 'offline', [$this->minimalTradeOrder()]));
|
||
|
||
$decoded = json_decode((string) $container[0]['request']->getBody(), true);
|
||
$this->assertIsArray($decoded);
|
||
$this->assertArrayHasKey(0, $decoded);
|
||
$this->assertArrayNotHasKey('platform', $decoded[0]);
|
||
}
|
||
|
||
/** A-ORD-GATE-02：网关业务码非 10000 → sync 返回 false（ERROR 由 Service 内记录） */
|
||
public function testAcceptanceGate02BusinessNonSuccessReturnsFalse(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->tradeServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":11008,"msg":"access invalid","data":null}'),
|
||
]);
|
||
|
||
$this->assertFalse($svc->syncValidatedTradeOrders(1, 'offline', [$this->minimalTradeOrder()]));
|
||
$this->assertCount(1, $container);
|
||
}
|
||
|
||
/** A-ORD-REV-04：同一 refund_id 先审核中再成功，两次 sync，末次 body 含 SY_REFUND_SUCC */
|
||
public function testAcceptanceRev04RefundResyncSecondPayloadSuccess(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->refundServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":"success","msg":""}'),
|
||
new Response(200, [], '{"code":10000,"data":"success","msg":""}'),
|
||
]);
|
||
|
||
$base = $this->minimalRefundPayload();
|
||
$checking = $base;
|
||
$checking['refund_status'] = 'SY_CHECKING';
|
||
$success = $base;
|
||
$success['refund_status'] = 'SY_REFUND_SUCC';
|
||
|
||
$this->assertTrue($svc->syncValidatedRefunds(1, 'offline', [$checking]));
|
||
$this->assertTrue($svc->syncValidatedRefunds(1, 'offline', [$success]));
|
||
|
||
$this->assertCount(2, $container);
|
||
$body1 = (string) $container[0]['request']->getBody();
|
||
$body2 = (string) $container[1]['request']->getBody();
|
||
$this->assertStringContainsString('SY_CHECKING', $body1);
|
||
$this->assertStringContainsString('SY_REFUND_SUCC', $body2);
|
||
$this->assertStringContainsString('"refund_id":"acc-mock-1"', $body2);
|
||
}
|
||
|
||
/** A-ORD-REV-05：51 条退款 → 2 次 POST */
|
||
public function testAcceptanceRev05FiftyOneRefundsTwoPosts(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->refundServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":"success","msg":""}'),
|
||
new Response(200, [], '{"code":10000,"data":"success","msg":""}'),
|
||
]);
|
||
|
||
$base = $this->minimalRefundPayload();
|
||
$refunds = [];
|
||
for ($i = 0; $i < 51; ++$i) {
|
||
$r = $base;
|
||
$r['refund_id'] = 'r'.(700000 + $i);
|
||
$refunds[] = $r;
|
||
}
|
||
|
||
$this->assertTrue($svc->syncValidatedRefunds(1, 'offline', $refunds));
|
||
$this->assertCount(2, $container);
|
||
$this->assertSame(ShuyunOpenPlatformOrderGatewayActions::GATEWAY_ACTION_REFUND_SYNC, $container[0]['request']->getHeaderLine('Gateway-Action-Method'));
|
||
}
|
||
|
||
/** 逆向 refund body 数组元素内不传 `platform` */
|
||
public function testAcceptanceRefundBodyElementWithoutPlatformKey(): void
|
||
{
|
||
$container = [];
|
||
$svc = $this->refundServiceWithHistory($container, [
|
||
new Response(200, [], '{"code":10000,"data":"success","msg":""}'),
|
||
]);
|
||
|
||
$this->assertTrue($svc->syncValidatedRefunds(1, 'offline', [$this->minimalRefundPayload()]));
|
||
|
||
$decoded = json_decode((string) $container[0]['request']->getBody(), true);
|
||
$this->assertIsArray($decoded);
|
||
$this->assertArrayNotHasKey('platform', $decoded[0]);
|
||
}
|
||
|
||
/**
|
||
* @param list<Response> $responses
|
||
*/
|
||
private function tradeServiceWithHistory(array &$container, array $responses): ShuyunOpenPlatformTradeSyncService
|
||
{
|
||
config(['shuyun_open_platform.base_uri' => 'http://open-api.test']);
|
||
config(['shuyun_open_platform.timeout' => 5.0]);
|
||
|
||
$cfgRepo = $this->createMock(CompanyShuyunOpenPlatformConfigRepository::class);
|
||
$cfgRepo->method('findOneByCompanyId')->willReturn($this->eligibleConfig());
|
||
$shopEligibility = $this->createMock(ShuyunOpenPlatformShopSyncService::class);
|
||
$shopEligibility->method('isEligible')->willReturn(true);
|
||
|
||
$stack = HandlerStack::create(new MockHandler($responses));
|
||
$stack->push(Middleware::history($container));
|
||
$client = new Client(['handler' => $stack, 'base_uri' => 'http://open-api.test/']);
|
||
|
||
return new ShuyunOpenPlatformTradeSyncService($cfgRepo, $shopEligibility, $client, new ShuyunOpenPlatformGatewayClientFactory(null));
|
||
}
|
||
|
||
/**
|
||
* @param list<Response> $responses
|
||
*/
|
||
private function refundServiceWithHistory(array &$container, array $responses): ShuyunOpenPlatformRefundSyncService
|
||
{
|
||
config(['shuyun_open_platform.base_uri' => 'http://open-api.test']);
|
||
config(['shuyun_open_platform.timeout' => 5.0]);
|
||
|
||
$cfgRepo = $this->createMock(CompanyShuyunOpenPlatformConfigRepository::class);
|
||
$cfgRepo->method('findOneByCompanyId')->willReturn($this->eligibleConfig());
|
||
$shopEligibility = $this->createMock(ShuyunOpenPlatformShopSyncService::class);
|
||
$shopEligibility->method('isEligible')->willReturn(true);
|
||
|
||
$stack = HandlerStack::create(new MockHandler($responses));
|
||
$stack->push(Middleware::history($container));
|
||
$client = new Client(['handler' => $stack, 'base_uri' => 'http://open-api.test/']);
|
||
|
||
return new ShuyunOpenPlatformRefundSyncService($cfgRepo, $shopEligibility, $client, new ShuyunOpenPlatformGatewayClientFactory(null));
|
||
}
|
||
|
||
/**
|
||
* @return array<string, mixed>
|
||
*/
|
||
private function minimalTradeOrder(): array
|
||
{
|
||
return [
|
||
'shop_id' => '2202520',
|
||
'plat_account' => '10001',
|
||
'order_id' => '9081283821',
|
||
'order_status' => 'WAIT_SELLER_SEND_GOODS',
|
||
'trade_type' => 'FIXED',
|
||
'is_presale' => '0',
|
||
'trade_source' => '11',
|
||
'payment' => 121.0,
|
||
'post_fee' => 10.0,
|
||
'adjust_fee' => 0.7,
|
||
'product_num' => 1,
|
||
'created' => '2017-12-08 21:33:03',
|
||
'modified' => '2017-12-08 21:33:03',
|
||
'delivery_type' => 'SY_EXPRESS',
|
||
'orders' => [
|
||
[
|
||
'order_item_id' => '1223',
|
||
'product_id' => '908872367645891',
|
||
'sku_id' => '231562388901',
|
||
'product_name' => '新款T恤',
|
||
'price' => 12.22,
|
||
'product_num' => 1,
|
||
'discount_fee' => 0.0,
|
||
'adjust_fee' => 0.0,
|
||
'pay_time' => '2018-10-08 09:00:00',
|
||
],
|
||
],
|
||
];
|
||
}
|
||
|
||
/**
|
||
* @return array<string, mixed>
|
||
*/
|
||
private function minimalRefundPayload(): array
|
||
{
|
||
return [
|
||
'refund_id' => 'acc-mock-1',
|
||
'order_id' => '22112333',
|
||
'order_item_id' => '231433221223',
|
||
'shop_id' => '2202520',
|
||
'product_id' => '234221111',
|
||
'sku_id' => '324443333',
|
||
'refund_fee' => 0.9,
|
||
'refund_status' => 'SY_CHECKING',
|
||
'good_return' => 'SY_ONLY_FEE',
|
||
'refund_reason' => 'acceptance-mock',
|
||
'created' => '2018-06-08 12:00:34',
|
||
'modified' => '2018-06-09 12:00:34',
|
||
'refund_phase' => 2,
|
||
];
|
||
}
|
||
|
||
private function eligibleConfig(): CompanyShuyunOpenPlatformConfig
|
||
{
|
||
$e = new CompanyShuyunOpenPlatformConfig();
|
||
$e->setCompanyId(1);
|
||
$e->setAuthValue('av');
|
||
$e->setAppId('aid');
|
||
$e->setAppSecret('sec');
|
||
$e->setAccessToken('tok');
|
||
$e->setIsEnabled(1);
|
||
|
||
return $e;
|
||
}
|
||
}
|