src/Biz/Distributor/Job/DistributorSyncJob.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Biz\Distributor\Job;

use Codeages\Biz\Framework\Scheduler\AbstractJob;
use Biz\Distributor\Util\DistributorJobStatus;

class DistributorSyncJob extends AbstractJob
{
    private $distributorServices = array();
    private $mockedSendTypes = null;

    public function execute()
    {
        $drpService = $this->getDrpService();
        if (!empty($drpService)) {
            $distributorServices = $this->getDistributorServiceList();

            foreach ($distributorServices as $service) {
                $this->sendData($drpService, $service);
            }
        }
    }

    protected function getDrpService()
    {
        $distributorServices = $this->getDistributorServiceList();

        return $distributorServices[0]->getDrpService();
    }

    private function sendData($drpService, $service)
    {
        $jobData = $service->findJobData();
        $status = DistributorJobStatus::ERROR;
        $resultJson = null;
        if (!empty($jobData)) {
            try {
                $typeOrders = array();

                $sendedData = array();
                foreach ($jobData as $data) {
                    $sendType = $service->getSendType($data['data']);
                    if (empty($typeOrders[$sendType])) {
                        $typeOrders[$sendType] = array();
                    }
                    $typeOrders[$sendType][] = $data['data'];
                }

                foreach ($typeOrders as $sendType => $sendedData) {
                    $resultJson = $drpService->postData($sendType, $sendedData);

                    if ($resultJson['success']) {
                        $status = DistributorJobStatus::FINISHED;
                    }
                    $this->biz['logger']->info(
                        'distributor send job DistributorSyncJob::execute ',
                        array('jobData' => $jobData, 'result' => $resultJson)
                    );
                }