|
|
<?php
|
|
|
|
|
|
namespace Tests\Feature;
|
|
|
|
|
|
use App\Services\Admin\YeWu\PlanListService;
|
|
|
use Illuminate\Support\Facades\DB;
|
|
|
use Illuminate\Support\Facades\Log;
|
|
|
use Tests\TestCase;
|
|
|
|
|
|
class PlanListServiceTest extends TestCase
|
|
|
{
|
|
|
protected function setUp(): void
|
|
|
{
|
|
|
parent::setUp();
|
|
|
$this->initTestData();
|
|
|
}
|
|
|
|
|
|
protected function tearDown(): void
|
|
|
{
|
|
|
$this->cleanupTestData();
|
|
|
parent::tearDown();
|
|
|
}
|
|
|
|
|
|
private function initTestData()
|
|
|
{
|
|
|
$this->cleanupTestData();
|
|
|
|
|
|
DB::table('s_department')->insert([
|
|
|
'id' => 9999,
|
|
|
'department_name' => '测试科室',
|
|
|
'department_number' => 'TEST001',
|
|
|
'department_status' => 1,
|
|
|
'is_del' => 0,
|
|
|
]);
|
|
|
|
|
|
DB::table('s_appointment_type')->insert([
|
|
|
'id' => 9999,
|
|
|
'name' => '测试渠道',
|
|
|
'jiancheng' => '测试',
|
|
|
'status' => 1,
|
|
|
'is_del' => 0,
|
|
|
]);
|
|
|
|
|
|
DB::table('s_period')->insert([
|
|
|
'id' => 9999,
|
|
|
'period_name' => '测试时段',
|
|
|
'period_begin_time' => '08:00:00',
|
|
|
'period_end_time' => '10:00:00',
|
|
|
'department_id' => 9999,
|
|
|
'date_type' => 1,
|
|
|
'period_status' => 1,
|
|
|
]);
|
|
|
|
|
|
DB::table('s_department_resources')->insert([
|
|
|
'id' => 9999,
|
|
|
'department_id' => 9999,
|
|
|
'department_resources_name' => '测试资源',
|
|
|
'is_del' => 0,
|
|
|
]);
|
|
|
|
|
|
DB::table('s_source_roster_detail')->insert([
|
|
|
'id' => 9999,
|
|
|
'department_id' => 9999,
|
|
|
'resources_id' => 9999,
|
|
|
'period_id' => 9999,
|
|
|
'device_id' => '1',
|
|
|
'date' => date('Y-m-d', strtotime('+1 day')),
|
|
|
'begin_time' => '08:00:00',
|
|
|
'end_time' => '10:00:00',
|
|
|
'end_reservation_time' => '23:59:59',
|
|
|
'patient_type' => '0,1,2,3',
|
|
|
'weekname' => '1',
|
|
|
'status' => 1,
|
|
|
'is_del' => 0,
|
|
|
]);
|
|
|
|
|
|
DB::table('s_source_roster_detail_count')->insert([
|
|
|
'id' => 9999,
|
|
|
'roster_detail_id' => 9999,
|
|
|
'appointment_type_id' => 9999,
|
|
|
'count' => 10,
|
|
|
'used_count' => 3,
|
|
|
'locked_count' => 0,
|
|
|
'version' => 1,
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
private function cleanupTestData()
|
|
|
{
|
|
|
DB::table('s_list')->where('reg_num', 'like', 'TEST_REG_%')->delete();
|
|
|
DB::table('s_list_log')->where('reg_num', 'like', 'TEST_REG_%')->delete();
|
|
|
|
|
|
$tables = [
|
|
|
's_source_roster_detail_count',
|
|
|
's_source_roster_detail', 's_department_resources',
|
|
|
's_period', 's_appointment_type', 's_department'
|
|
|
];
|
|
|
foreach ($tables as $table) {
|
|
|
DB::table($table)->where('id', '>=', 9999)->delete();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
private function createTestList($status = 1, $detail = 'default')
|
|
|
{
|
|
|
if ($detail === 'default') {
|
|
|
$detail = json_encode([['roster_detail_count_id' => 9999, 'count' => 2]]);
|
|
|
}
|
|
|
|
|
|
return DB::table('s_list')->insertGetId([
|
|
|
'list_status' => $status,
|
|
|
'reg_num' => 'TEST_REG_' . time() . '_' . rand(1000, 9999),
|
|
|
'user_name' => '测试患者',
|
|
|
'entrust' => '测试检查项目',
|
|
|
'entrust_code' => 'TEST001',
|
|
|
'patient_type' => 1,
|
|
|
'roster_id' => 9999,
|
|
|
'appointment_type_id' => 9999,
|
|
|
'appointment_use_plan_detail' => $detail,
|
|
|
'reservation_date' => date('Y-m-d', strtotime('+1 day')),
|
|
|
'reservation_time' => 9999,
|
|
|
'is_del' => 0,
|
|
|
'is_nullify' => 0,
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
public function test_release_source_from_detail()
|
|
|
{
|
|
|
$countBefore = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(3, $countBefore->used_count);
|
|
|
|
|
|
$detail = json_encode([['roster_detail_count_id' => 9999, 'count' => 2]]);
|
|
|
$listId = $this->createTestList(1, $detail);
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->releaseSourceFromDetail($listId);
|
|
|
|
|
|
$this->assertTrue($result);
|
|
|
|
|
|
$countAfter = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(1, $countAfter->used_count);
|
|
|
$this->assertEquals(2, $countAfter->version);
|
|
|
|
|
|
echo "\n✅ 测试1通过: releaseSourceFromDetail 精确释放号源成功\n";
|
|
|
echo " 释放前 used_count=3, 释放后 used_count=1, version从1变为2\n";
|
|
|
}
|
|
|
|
|
|
public function test_release_source_with_version_check()
|
|
|
{
|
|
|
DB::table('s_source_roster_detail_count')->where('id', 9999)->update(['version' => 5]);
|
|
|
|
|
|
$detail = json_encode([['roster_detail_count_id' => 9999, 'count' => 1]]);
|
|
|
$listId = $this->createTestList(1, $detail);
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->releaseSourceFromDetail($listId);
|
|
|
|
|
|
$this->assertTrue($result);
|
|
|
|
|
|
$countAfter = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(6, $countAfter->version);
|
|
|
|
|
|
echo "\n✅ 测试2通过: 乐观锁version正确递增\n";
|
|
|
echo " 释放前 version=5, 释放后 version=6\n";
|
|
|
}
|
|
|
|
|
|
public function test_release_source_fallback_when_no_detail()
|
|
|
{
|
|
|
DB::table('s_source_roster_detail_count')->where('id', 9999)->update(['used_count' => 3, 'version' => 1]);
|
|
|
DB::table('s_list')->where('reg_num', 'like', 'TEST_REG_%')->delete();
|
|
|
|
|
|
$listId = $this->createTestList(1, null);
|
|
|
$mainInfo = DB::table('s_list')->where('id', $listId)->first();
|
|
|
|
|
|
$countBefore = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(3, $countBefore->used_count, '初始used_count应为3');
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->releaseSourceFromDetail($listId, $mainInfo);
|
|
|
|
|
|
$this->assertTrue($result, 'releaseSourceFromDetail应返回true');
|
|
|
|
|
|
$countAfter = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(2, $countAfter->used_count, '释放后used_count应为2');
|
|
|
|
|
|
echo "\n✅ 测试3通过: 无明细时fallback降级释放成功\n";
|
|
|
echo " 无appointment_use_plan_detail时，按roster_id+appointment_type_id释放1个名额\n";
|
|
|
}
|
|
|
|
|
|
public function test_release_source_multiple_channels()
|
|
|
{
|
|
|
DB::table('s_source_roster_detail_count')->insert([
|
|
|
'id' => 10000,
|
|
|
'roster_detail_id' => 9999,
|
|
|
'appointment_type_id' => 10000,
|
|
|
'count' => 5,
|
|
|
'used_count' => 3,
|
|
|
'locked_count' => 0,
|
|
|
'version' => 1,
|
|
|
]);
|
|
|
|
|
|
$detail = json_encode([
|
|
|
['roster_detail_count_id' => 9999, 'count' => 2],
|
|
|
['roster_detail_count_id' => 10000, 'count' => 1],
|
|
|
]);
|
|
|
$listId = $this->createTestList(1, $detail);
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->releaseSourceFromDetail($listId);
|
|
|
|
|
|
$this->assertTrue($result);
|
|
|
|
|
|
$count1 = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$count2 = DB::table('s_source_roster_detail_count')->where('id', 10000)->first();
|
|
|
|
|
|
$this->assertEquals(1, $count1->used_count);
|
|
|
$this->assertEquals(2, $count2->used_count);
|
|
|
|
|
|
DB::table('s_source_roster_detail_count')->where('id', 10000)->delete();
|
|
|
|
|
|
echo "\n✅ 测试4通过: 多渠道合并号源精确释放成功\n";
|
|
|
echo " 渠道9999: used_count从3变为1\n";
|
|
|
echo " 渠道10000: used_count从3变为2\n";
|
|
|
}
|
|
|
|
|
|
public function test_release_source_with_insufficient_used_count()
|
|
|
{
|
|
|
DB::table('s_source_roster_detail_count')->where('id', 9999)->update(['used_count' => 1]);
|
|
|
|
|
|
$detail = json_encode([['roster_detail_count_id' => 9999, 'count' => 5]]);
|
|
|
$listId = $this->createTestList(1, $detail);
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->releaseSourceFromDetail($listId);
|
|
|
|
|
|
$this->assertTrue($result);
|
|
|
|
|
|
$countAfter = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(0, $countAfter->used_count);
|
|
|
|
|
|
echo "\n✅ 测试5通过: 释放数量大于used_count时，置零并记录警告日志\n";
|
|
|
echo " 尝试释放5个，实际只有1个，已置零并记录日志\n";
|
|
|
}
|
|
|
|
|
|
public function test_cancel_yu_yue_clears_detail()
|
|
|
{
|
|
|
$detail = json_encode([['roster_detail_count_id' => 9999, 'count' => 2]]);
|
|
|
$listId = $this->createTestList(1, $detail);
|
|
|
$listInfo = DB::table('s_list')->where('id', $listId)->first();
|
|
|
|
|
|
$service = new PlanListService();
|
|
|
$result = $service->CancelYuYue($listId, $listInfo->reg_num);
|
|
|
|
|
|
$this->assertTrue($result['status']);
|
|
|
|
|
|
$listAfter = DB::table('s_list')->where('id', $listId)->first();
|
|
|
$this->assertEquals(0, $listAfter->list_status);
|
|
|
$this->assertNull($listAfter->appointment_use_plan_detail);
|
|
|
|
|
|
$countAfter = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$this->assertEquals(1, $countAfter->used_count);
|
|
|
|
|
|
echo "\n✅ 测试6通过: CancelYuYue正确释放号源并清空明细\n";
|
|
|
echo " list_status变为0, appointment_use_plan_detail被清空\n";
|
|
|
echo " used_count从3变为1\n";
|
|
|
}
|
|
|
|
|
|
public function test_optimistic_lock_conflict_detection()
|
|
|
{
|
|
|
$countRecord = DB::table('s_source_roster_detail_count')->where('id', 9999)->first();
|
|
|
$oldVersion = $countRecord->version;
|
|
|
|
|
|
$affected = DB::table('s_source_roster_detail_count')
|
|
|
->where(['id' => 9999, 'version' => $oldVersion])
|
|
|
->update([
|
|
|
'used_count' => DB::raw('used_count + 1'),
|
|
|
'version' => DB::raw('version + 1'),
|
|
|
]);
|
|
|
|
|
|
$this->assertEquals(1, $affected);
|
|
|
|
|
|
$conflictAffected = DB::table('s_source_roster_detail_count')
|
|
|
->where(['id' => 9999, 'version' => $oldVersion])
|
|
|
->update([
|
|
|
'used_count' => DB::raw('used_count + 1'),
|
|
|
'version' => DB::raw('version + 1'),
|
|
|
]);
|
|
|
|
|
|
$this->assertEquals(0, $conflictAffected);
|
|
|
|
|
|
echo "\n✅ 测试7通过: 乐观锁冲突检测生效\n";
|
|
|
echo " 第一次更新成功(affected=1)\n";
|
|
|
echo " 第二次使用旧version更新失败(affected=0)\n";
|
|
|
}
|
|
|
} |