域驱动设计和批处理

具有以下结构：

1. 演示级别：

   Web 界面、REST API 和命令提示符 - 全部仅调用 OrderService。

2. 应用层：

   class OrderService
   {
     private $em;
     private $repository;
     private $calculator;
     public function __construct(
         'Doctrine'ORM'EntityManagerInterface $em;
         ClientRepositoryInterface $repository,
         cumulativeDiscountCalculator $calculator
     } {
         $this->em = $em;
         $this->repository = $repository;
         $this->calculator = $calculator;
     }
     public function calculateCumulativeDiscount($id)
     {
         $this->em->beginTransaction();
         try {
             $client = $this->repository->findClient();
             $this->calculator->calculate($client);
             $this->em->flush();
             $this->em->commit();
         } catch ('Exception $e) {
             $this->em->rollback();
             throw $e;
         }
     }
   }
   

3. 模型层：

   interface ClientInterface
   {
       public function setDiscount($discount);
   }
   interface ClientRepositoryInterface
   {
       public function findClient($id);
       public function findClientsByDataRange($from, $to);
   }
   class cumulativeDiscountCalculator
   {
       public function calculate(ClientInterface $client)
       {
           $client->setDiscount(mt_rand(1, 50));
       }
   }
   

4. 基础架构层：

   PHP 原则 2 - 实现 ClientRepositoryInterface。

我的任务 - 为一组客户端执行计算折扣。（方法 ClientRepositoryInterface：：findClientsByDataRange 返回集合以供处理）

问题是我需要处理多达 100,000 条记录。我知道如何在技术上做到这一点，但如何在 DDD 方面做到这一点？出现以下问题：

• 使用哪个层进行批处理？
• 如何收集操作的结果：错误、计算成功的客户端等？
• 在哪里设置事务边界（每 N 个客户端 - 提交并开始一个新事务）？
• 我有大约 10-20 个批处理操作，开发任何结构可能有意义？