Explorar o código

将所有事件监听器改为同步执行,移除 ShouldQueue 接口实现

notfff hai 7 meses
pai
achega
b2b22a0ab5

+ 4 - 4
app/Module/Farm/Listeners/AddLandAfterHouseUpgradeListener.php

@@ -7,14 +7,14 @@ use App\Module\Farm\Logics\HouseLogic;
 use App\Module\Farm\Logics\LandLogic;
 use App\Module\Farm\Models\FarmLand;
 use App\Module\Farm\Enums\LAND_TYPE;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Log;
 
-class AddLandAfterHouseUpgradeListener implements ShouldQueue
+class AddLandAfterHouseUpgradeListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 房屋逻辑类

+ 4 - 4
app/Module/Farm/Listeners/CalculateHarvestOutputListener.php

@@ -4,8 +4,8 @@ namespace App\Module\Farm\Listeners;
 
 use App\Module\Farm\Enums\BUFF_TYPE;
 use App\Module\Farm\Events\CropHarvestedEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -13,9 +13,9 @@ use Illuminate\Support\Facades\Log;
  * 
  * 监听作物收获事件,计算最终产出数量
  */
-class CalculateHarvestOutputListener implements ShouldQueue
+class CalculateHarvestOutputListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 处理事件

+ 4 - 4
app/Module/Farm/Listeners/CheckHouseDowngradeListener.php

@@ -7,8 +7,8 @@ use App\Module\Farm\Events\HouseUpgradedEvent;
 use App\Module\Farm\Models\FarmHouseConfig;
 use App\Module\Farm\Models\FarmUpgradeLog;
 use App\Module\Farm\Models\FarmUser;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  * 
  * 定期检查用户房屋是否需要降级
  */
-class CheckHouseDowngradeListener implements ShouldQueue
+class CheckHouseDowngradeListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 处理房屋降级检查

+ 4 - 4
app/Module/Farm/Listeners/DistributeTeamProfitListener.php

@@ -7,8 +7,8 @@ use App\Module\Farm\Events\TeamProfitCreatedEvent;
 use App\Module\Farm\Models\FarmTeamProfit;
 use App\Module\Farm\Models\FarmUserReferral;
 use App\Module\Team\Services\TalentService;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  *
  * 监听作物收获事件,计算并分配团队收益
  */
-class DistributeTeamProfitListener implements ShouldQueue
+class DistributeTeamProfitListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 处理事件

+ 4 - 4
app/Module/Farm/Listeners/GenerateDisasterListener.php

@@ -7,8 +7,8 @@ use App\Module\Farm\Enums\GROWTH_STAGE;
 use App\Module\Farm\Enums\LAND_STATUS;
 use App\Module\Farm\Events\CropGrowthStageChangedEvent;
 use App\Module\Farm\Events\DisasterGeneratedEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  *
  * 监听作物生长阶段变更事件,随机生成灾害
  */
-class GenerateDisasterListener implements ShouldQueue
+class GenerateDisasterListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 处理事件

+ 4 - 4
app/Module/Farm/Listeners/UpdateCropStatusListener.php

@@ -5,8 +5,8 @@ namespace App\Module\Farm\Listeners;
 use App\Module\Farm\Enums\GROWTH_STAGE;
 use App\Module\Farm\Enums\LAND_STATUS;
 use App\Module\Farm\Events\CropGrowthStageChangedEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -14,9 +14,9 @@ use Illuminate\Support\Facades\Log;
  *
  * 监听作物生长阶段变更事件,更新土地状态
  */
-class UpdateCropStatusListener implements ShouldQueue
+class UpdateCropStatusListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 处理事件

+ 2 - 2
app/Module/Game/Listeners/HouseDowngradedListener.php

@@ -4,14 +4,14 @@ namespace App\Module\Game\Listeners;
 
 use App\Module\Farm\Events\HouseDowngradedEvent;
 use App\Module\Game\Logics\HouseTemp;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 房屋降级事件监听器
  *
  * 监听房屋降级事件,并调用逻辑层处理临时数据
  */
-class HouseDowngradedListener implements ShouldQueue
+class HouseDowngradedListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Game/Listeners/HouseUpgradedListener.php

@@ -4,7 +4,7 @@ namespace App\Module\Game\Listeners;
 
 use App\Module\Farm\Events\HouseUpgradedEvent;
 use App\Module\Game\Logics\HouseTemp;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 use UCore\Helper\Logger;
 
 /**
@@ -12,7 +12,7 @@ use UCore\Helper\Logger;
  *
  * 监听房屋升级事件,并调用逻辑层处理临时数据
  */
-class HouseUpgradedListener implements ShouldQueue
+class HouseUpgradedListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Game/Listeners/LandCreatedListener.php

@@ -4,14 +4,14 @@ namespace App\Module\Game\Listeners;
 
 use App\Module\Farm\Events\LandCreatedEvent;
 use App\Module\Game\Logics\LandTemp;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 土地创建事件监听器
  *
  * 监听土地创建事件,并调用逻辑层处理临时数据
  */
-class LandCreatedListener implements ShouldQueue
+class LandCreatedListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Game/Listeners/LandStatusChangedListener.php

@@ -4,14 +4,14 @@ namespace App\Module\Game\Listeners;
 
 use App\Module\Farm\Events\LandStatusChangedEvent;
 use App\Module\Game\Logics\LandTemp;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 土地状态变更事件监听器
  *
  * 监听土地状态变更事件,并调用逻辑层处理临时数据
  */
-class LandStatusChangedListener implements ShouldQueue
+class LandStatusChangedListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Game/Listeners/LandUpgradedListener.php

@@ -4,14 +4,14 @@ namespace App\Module\Game\Listeners;
 
 use App\Module\Farm\Events\LandUpgradedEvent;
 use App\Module\Game\Logics\LandTemp;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 土地升级事件监听器
  *
  * 监听土地升级事件,并调用逻辑层处理临时数据
  */
-class LandUpgradedListener implements ShouldQueue
+class LandUpgradedListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/GameItems/Listeners/TestEventListener.php

@@ -3,7 +3,7 @@
 namespace App\Module\GameItems\Listeners;
 
 use App\Module\Test\Events\TestEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 测试事件监听器类
@@ -12,7 +12,7 @@ use Illuminate\Contracts\Queue\ShouldQueue;
  * 此类主要在开发阶段使用,用于测试事件系统的功能。
  * 监听器实现了ShouldQueue接口,表示它将在队列中异步处理事件。
  */
-class TestEventListener implements ShouldQueue
+class TestEventListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/GameItems/Listeners/TestListener.php

@@ -3,9 +3,9 @@
 namespace App\Module\GameItems\Listeners;
 
 use App\Module\Test\Events\TestEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
 
-class TestListener implements ShouldQueue
+
+class TestListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Task/Listeners/TaskCompletedListener.php

@@ -3,14 +3,14 @@
 namespace App\Module\Task\Listeners;
 
 use App\Module\Task\Events\TaskCompletedEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 任务完成事件监听器
  *
  * 监听任务完成事件,执行相关操作
  */
-class TaskCompletedListener extends BaseTaskEventListener implements ShouldQueue
+class TaskCompletedListener extends BaseTaskEventListener
 {
     /**
      * 创建监听器实例

+ 2 - 2
app/Module/Task/Listeners/TaskRewardClaimedListener.php

@@ -3,14 +3,14 @@
 namespace App\Module\Task\Listeners;
 
 use App\Module\Task\Events\TaskRewardClaimedEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
+
 
 /**
  * 任务奖励领取事件监听器
  * 
  * 监听任务奖励领取事件,执行相关操作
  */
-class TaskRewardClaimedListener extends BaseTaskEventListener implements ShouldQueue
+class TaskRewardClaimedListener extends BaseTaskEventListener
 {
     /**
      * 创建监听器实例

+ 4 - 4
app/Module/Team/Listeners/DistributeTeamProfitListener.php

@@ -6,8 +6,8 @@ use App\Module\Team\Events\TeamProfitCreatedEvent;
 use App\Module\Team\Logics\ReferralLogic;
 use App\Module\Team\Logics\TalentLogic;
 use App\Module\Team\Logics\TeamProfitLogic;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  * 监听团队收益创建事件,分配团队收益。
  * 根据用户的推荐关系和达人等级,计算并分配团队收益。
  */
-class DistributeTeamProfitListener implements ShouldQueue
+class DistributeTeamProfitListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 推荐关系逻辑类

+ 4 - 4
app/Module/Team/Listeners/UpdateTalentLevelListener.php

@@ -6,8 +6,8 @@ use App\Module\Team\Events\ReferralCreatedEvent;
 use App\Module\Team\Events\ReferralUpdatedEvent;
 use App\Module\Team\Logics\ReferralLogic;
 use App\Module\Team\Logics\TalentLogic;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  * 监听推荐关系创建和更新事件,更新用户的达人等级。
  * 根据用户的直推人数和团队总人数,计算用户的达人等级。
  */
-class UpdateTalentLevelListener implements ShouldQueue
+class UpdateTalentLevelListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 推荐关系逻辑类

+ 4 - 4
app/Module/Team/Listeners/UpdateTeamCountsListener.php

@@ -6,8 +6,8 @@ use App\Module\Team\Events\ReferralCreatedEvent;
 use App\Module\Team\Events\ReferralUpdatedEvent;
 use App\Module\Team\Logics\ReferralLogic;
 use App\Module\Team\Logics\RelationCacheLogic;
-use Illuminate\Contracts\Queue\ShouldQueue;
-use Illuminate\Queue\InteractsWithQueue;
+
+
 use Illuminate\Support\Facades\Log;
 
 /**
@@ -16,9 +16,9 @@ use Illuminate\Support\Facades\Log;
  * 监听推荐关系创建和更新事件,更新团队统计数据。
  * 包括更新直推人数和团队总人数。
  */
-class UpdateTeamCountsListener implements ShouldQueue
+class UpdateTeamCountsListener
 {
-    use InteractsWithQueue;
+    
 
     /**
      * 推荐关系逻辑类

+ 2 - 2
app/Module/Test/Listeners/TestEventListener.php

@@ -3,9 +3,9 @@
 namespace App\Module\Test\Listeners;
 
 use App\Module\Test\Events\TestEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
 
-class TestEventListener implements ShouldQueue
+
+class TestEventListener
 {
     /**
      * 处理事件

+ 2 - 2
app/Module/Test/Listeners/TestListener.php

@@ -3,9 +3,9 @@
 namespace App\Module\Test\Listeners;
 
 use App\Module\Test\Events\TestEvent;
-use Illuminate\Contracts\Queue\ShouldQueue;
 
-class TestListener implements ShouldQueue
+
+class TestListener
 {
     /**
      * 处理事件