mirror of
https://gitee.com/ShopeX/ECShopX
synced 2026-06-28 19:15:36 +08:00
320 lines
12 KiB
PHP
320 lines
12 KiB
PHP
<?php
|
||
|
||
declare(strict_types=1);
|
||
|
||
namespace Tests\PointBundle;
|
||
|
||
use Dingo\Api\Exception\ResourceException;
|
||
use GuzzleHttp\Client;
|
||
use GuzzleHttp\Handler\MockHandler;
|
||
use GuzzleHttp\HandlerStack;
|
||
use GuzzleHttp\Psr7\Response;
|
||
use MembersBundle\Services\MemberService;
|
||
use PointBundle\Services\PointMemberShuyunOpenPlatformPointListService;
|
||
use DistributionBundle\Repositories\DistributorRepository;
|
||
use ShuyunOpenPlatformBundle\Entities\CompanyShuyunOpenPlatformConfig;
|
||
use ShuyunOpenPlatformBundle\Repositories\CompanyShuyunOpenPlatformConfigRepository;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformGatewayClientFactory;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformGatewayShopIdResolver;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformLoyaltyPointChangelogSearchService;
|
||
use ShuyunOpenPlatformBundle\Services\ShuyunOpenPlatformShopSyncService;
|
||
|
||
/**
|
||
* 计划 T-POINT-06～10：PointBundle 积分流水数云分支（列表服务 + Admin 辅助判定）。
|
||
*/
|
||
class PointMemberShuyunOpenPlatformPointListServiceTest extends \TestCase
|
||
{
|
||
/** T-POINT-06 */
|
||
public function testBuildListFromChangelogMapsRowsAndTotals(): void
|
||
{
|
||
$body = [
|
||
'code' => 10000,
|
||
'data' => [
|
||
'pageSize' => 10,
|
||
'totals' => 2,
|
||
'pageNum' => 1,
|
||
'list' => [
|
||
[
|
||
'changePoint' => 10,
|
||
'created' => '2022-06-15 09:33:13',
|
||
'source' => 'OTHER',
|
||
'desc' => '调试',
|
||
'partnerSequence' => 'O-1',
|
||
'recordId' => 386331442,
|
||
'point' => 160,
|
||
],
|
||
[
|
||
'changePoint' => -5,
|
||
'created' => '2022-06-16 10:00:00',
|
||
'source' => 'CONSUME',
|
||
'desc' => '扣减',
|
||
'partnerSequence' => '',
|
||
'recordId' => 386331443,
|
||
'point' => 155,
|
||
],
|
||
],
|
||
],
|
||
'msg' => '',
|
||
];
|
||
|
||
$changelog = $this->changelogSearchWithJsonBody($body);
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$changelog,
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->createMock(MemberService::class),
|
||
);
|
||
|
||
$out = $svc->buildListFromChangelog(1, 999, 9301, 1, 10, null);
|
||
|
||
$this->assertSame(2, $out['total_count']);
|
||
$this->assertCount(2, $out['list']);
|
||
$this->assertSame('999', $out['list'][0]['user_id']);
|
||
$this->assertSame(10, $out['list'][0]['income']);
|
||
$this->assertSame(0, $out['list'][0]['outcome']);
|
||
$this->assertSame('income', $out['list'][0]['outin_type']);
|
||
$this->assertSame(160, $out['list'][0]['s_point']);
|
||
$this->assertSame(5, $out['list'][1]['outcome']);
|
||
$this->assertSame('outcome', $out['list'][1]['outin_type']);
|
||
}
|
||
|
||
/** T-POINT-06 — outin_type 过滤 */
|
||
public function testBuildListFromChangelogFiltersByOutinType(): void
|
||
{
|
||
$body = [
|
||
'code' => 10000,
|
||
'data' => [
|
||
'totals' => 2,
|
||
'pageNum' => 1,
|
||
'pageSize' => 10,
|
||
'list' => [
|
||
['changePoint' => 10, 'created' => '2022-01-01 00:00:00', 'source' => 'X', 'desc' => '', 'point' => 10],
|
||
['changePoint' => -3, 'created' => '2022-01-02 00:00:00', 'source' => 'Y', 'desc' => '', 'point' => 7],
|
||
],
|
||
],
|
||
'msg' => '',
|
||
];
|
||
|
||
$changelog = $this->changelogSearchWithJsonBody($body);
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$changelog,
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->createMock(MemberService::class),
|
||
);
|
||
|
||
$out = $svc->buildListFromChangelog(1, 1, 1, 1, 10, 'outcome');
|
||
$this->assertCount(1, $out['list']);
|
||
$this->assertSame(3, $out['list'][0]['outcome']);
|
||
}
|
||
|
||
/** T-POINT-07 */
|
||
public function testAssertEligibleThrowsWhenNotEligible(): void
|
||
{
|
||
$repo = $this->createMock(CompanyShuyunOpenPlatformConfigRepository::class);
|
||
$cfg = $this->eligibleConfigEntity();
|
||
$repo->method('findOneByCompanyId')->with(7)->willReturn($cfg);
|
||
|
||
$sync = $this->createMock(ShuyunOpenPlatformShopSyncService::class);
|
||
$sync->method('isEligible')->with($cfg)->willReturn(false);
|
||
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$this->deadChangelogSearch(),
|
||
$repo,
|
||
$sync,
|
||
$this->createMock(MemberService::class),
|
||
);
|
||
|
||
$this->expectException(ResourceException::class);
|
||
$svc->assertEligibleOrThrow(7);
|
||
}
|
||
|
||
/** T-POINT-07 — 无配置行 */
|
||
public function testAssertEligibleThrowsWhenConfigMissing(): void
|
||
{
|
||
$repo = $this->createMock(CompanyShuyunOpenPlatformConfigRepository::class);
|
||
$repo->method('findOneByCompanyId')->willReturn(null);
|
||
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$this->deadChangelogSearch(),
|
||
$repo,
|
||
$this->createMock(ShuyunOpenPlatformShopSyncService::class),
|
||
$this->createMock(MemberService::class),
|
||
);
|
||
|
||
$this->expectException(ResourceException::class);
|
||
$svc->assertEligibleOrThrow(1);
|
||
}
|
||
|
||
/** T-POINT-08：数云会员能力关闭时，门面返回 false（与 Front 先判此开关再达摩/本地一致）。 */
|
||
public function testTPoint08WhenMemberServiceSaysShuyunOffGateIsFalse(): void
|
||
{
|
||
$member = $this->createMock(MemberService::class);
|
||
$member->method('isShuyunOpenPlatformMemberEnabled')->willReturn(false);
|
||
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$this->deadChangelogSearch(),
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$member,
|
||
);
|
||
|
||
$this->assertFalse($svc->isShuyunOpenPlatformMemberEnabled(100));
|
||
}
|
||
|
||
/** T-POINT-09 */
|
||
public function testTPoint09WhenShuyunOnIsTrue(): void
|
||
{
|
||
$member = $this->createMock(MemberService::class);
|
||
$member->method('isShuyunOpenPlatformMemberEnabled')->willReturn(true);
|
||
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$this->deadChangelogSearch(),
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$member,
|
||
);
|
||
|
||
$this->assertTrue($svc->isShuyunOpenPlatformMemberEnabled(1));
|
||
}
|
||
|
||
/** T-POINT-10：后管唯一定位单会员 */
|
||
public function testExtractSingleUserIdScalarAndArray(): void
|
||
{
|
||
$this->assertSame(5, PointMemberShuyunOpenPlatformPointListService::extractSingleUserId(['user_id' => 5]));
|
||
$this->assertSame(5, PointMemberShuyunOpenPlatformPointListService::extractSingleUserId(['user_id' => [5]]));
|
||
$this->assertNull(PointMemberShuyunOpenPlatformPointListService::extractSingleUserId(['user_id' => [5, 6]]));
|
||
$this->assertNull(PointMemberShuyunOpenPlatformPointListService::extractSingleUserId([]));
|
||
}
|
||
|
||
/** T-POINT-10：日期筛选时走后管本地流水，不调数云分页 */
|
||
public function testHasPointLogDateRangeFilter(): void
|
||
{
|
||
$this->assertTrue(PointMemberShuyunOpenPlatformPointListService::hasPointLogDateRangeFilter(['created|gte' => 1]));
|
||
$this->assertFalse(PointMemberShuyunOpenPlatformPointListService::hasPointLogDateRangeFilter(['company_id' => 1]));
|
||
}
|
||
|
||
public function testSearchFailureWrapsResourceException(): void
|
||
{
|
||
$stack = HandlerStack::create(new MockHandler([
|
||
new Response(200, [], '{"code":11008,"data":null,"msg":"accessToken invalid"}'),
|
||
]));
|
||
$client = new Client(['handler' => $stack, 'base_uri' => 'http://open-api.test/']);
|
||
config(['shuyun_open_platform.base_uri' => 'http://open-api.test']);
|
||
config(['shuyun_open_platform.default_plat_code' => 'OFFLINE']);
|
||
|
||
$changelog = new ShuyunOpenPlatformLoyaltyPointChangelogSearchService(
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->mockDistributorRepoForPointList(1),
|
||
new ShuyunOpenPlatformGatewayShopIdResolver(),
|
||
$client,
|
||
new ShuyunOpenPlatformGatewayClientFactory(null),
|
||
);
|
||
|
||
$svc = new PointMemberShuyunOpenPlatformPointListService(
|
||
$changelog,
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->createMock(MemberService::class),
|
||
);
|
||
|
||
$this->expectException(ResourceException::class);
|
||
$svc->buildListFromChangelog(1, 1, 1, 1, 10, null);
|
||
}
|
||
|
||
/**
|
||
* @param array<string, mixed> $body
|
||
*/
|
||
private function changelogSearchWithJsonBody(array $body): ShuyunOpenPlatformLoyaltyPointChangelogSearchService
|
||
{
|
||
config(['shuyun_open_platform.base_uri' => 'http://open-api.test']);
|
||
config(['shuyun_open_platform.default_plat_code' => 'OFFLINE']);
|
||
|
||
$stack = HandlerStack::create(new MockHandler([
|
||
new Response(200, [], json_encode($body, JSON_THROW_ON_ERROR)),
|
||
]));
|
||
$client = new Client(['handler' => $stack, 'base_uri' => 'http://open-api.test/']);
|
||
|
||
return new ShuyunOpenPlatformLoyaltyPointChangelogSearchService(
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->mockDistributorRepoForPointList(1),
|
||
new ShuyunOpenPlatformGatewayShopIdResolver(),
|
||
$client,
|
||
new ShuyunOpenPlatformGatewayClientFactory(null),
|
||
);
|
||
}
|
||
|
||
private function deadChangelogSearch(): ShuyunOpenPlatformLoyaltyPointChangelogSearchService
|
||
{
|
||
config(['shuyun_open_platform.base_uri' => 'http://open-api.test']);
|
||
config(['shuyun_open_platform.default_plat_code' => 'OFFLINE']);
|
||
$client = new Client([
|
||
'handler' => HandlerStack::create(new MockHandler([])),
|
||
'base_uri' => 'http://open-api.test/',
|
||
]);
|
||
|
||
return new ShuyunOpenPlatformLoyaltyPointChangelogSearchService(
|
||
$this->mockConfigRepoEligible(),
|
||
$this->mockShopEligibility(true),
|
||
$this->mockDistributorRepoForPointList(1),
|
||
new ShuyunOpenPlatformGatewayShopIdResolver(),
|
||
$client,
|
||
new ShuyunOpenPlatformGatewayClientFactory(null),
|
||
);
|
||
}
|
||
|
||
/**
|
||
* 任意正整数 distributor_id 返回非虚拟店，便于列表单测覆盖多种 reg_distributor。
|
||
*/
|
||
private function mockDistributorRepoForPointList(int $companyId): DistributorRepository
|
||
{
|
||
$repo = $this->createMock(DistributorRepository::class);
|
||
$repo->method('getInfo')->willReturnCallback(static function (array $filter) use ($companyId): array {
|
||
$cid = (int) ($filter['company_id'] ?? 0);
|
||
$did = (int) ($filter['distributor_id'] ?? 0);
|
||
if ($cid !== $companyId || $did <= 0) {
|
||
return [];
|
||
}
|
||
|
||
return [
|
||
'company_id' => $companyId,
|
||
'distributor_id' => $did,
|
||
'distributor_self' => 0,
|
||
];
|
||
});
|
||
|
||
return $repo;
|
||
}
|
||
|
||
private function mockConfigRepoEligible(): CompanyShuyunOpenPlatformConfigRepository
|
||
{
|
||
$cfgRepo = $this->createMock(CompanyShuyunOpenPlatformConfigRepository::class);
|
||
$cfgRepo->method('findOneByCompanyId')->willReturn($this->eligibleConfigEntity());
|
||
|
||
return $cfgRepo;
|
||
}
|
||
|
||
private function mockShopEligibility(bool $ok): ShuyunOpenPlatformShopSyncService
|
||
{
|
||
$shopEligibility = $this->createMock(ShuyunOpenPlatformShopSyncService::class);
|
||
$shopEligibility->method('isEligible')->willReturn($ok);
|
||
|
||
return $shopEligibility;
|
||
}
|
||
|
||
private function eligibleConfigEntity(): CompanyShuyunOpenPlatformConfig
|
||
{
|
||
$e = new CompanyShuyunOpenPlatformConfig();
|
||
$e->setCompanyId(1);
|
||
$e->setAuthValue('av');
|
||
$e->setAppId('aid');
|
||
$e->setAppSecret('sec');
|
||
$e->setAccessToken('tok');
|
||
$e->setIsEnabled(1);
|
||
|
||
return $e;
|
||
}
|
||
}
|