xionggeshop/addons/shopro_huifu/library/onboard/HuifuOnboardAdminService.php

<?php

namespace addons\shopro_huifu\library\onboard;

use addons\shopro_huifu\model\Onboard;
use think\Db;

class HuifuOnboardAdminService
{
    public function saveDraft($userId, $roleType, $roleRefId, array $formData, $onboardId = 0)
    {
        $onboardId = intval($onboardId);
        if ($onboardId > 0) {
            $row = Onboard::get($onboardId);
            if (!$row) {
                throw new \InvalidArgumentException('进件记录不存在');
            }
            $userId = intval($row['user_id']);
            $roleType = (string) $row['role_type'];
            $roleRefId = intval($row['role_ref_id']);
        } else {
            $userId = intval($userId);
            $roleRefId = intval($roleRefId);
            if ($userId <= 0) {
                throw new \InvalidArgumentException('请选择用户');
            }
            if (!in_array($roleType, ['promoter', 'regional_agent'], true)) {
                throw new \InvalidArgumentException('请选择进件角色');
            }
            $this->assertRoleBinding($userId, $roleType, $roleRefId);
        }

        $service = new HuifuOnboardService();
        return $service->saveDraft($userId, $roleType, $roleRefId, $formData, $onboardId);
    }

    protected function assertRoleBinding($userId, $roleType, $roleRefId)
    {
        if ($roleType === 'promoter') {
            if ($roleRefId !== $userId) {
                throw new \InvalidArgumentException('分销商角色参数无效');
            }
            $agent = Db::name('shopro_commission_agent')->where('user_id', $userId)->find();
            if (!$agent) {
                throw new \InvalidArgumentException('该用户不是分销商，无法创建分销商进件');
            }
            return;
        }

        $agent = Db::name('shopro_regional_agent')
            ->where('id', $roleRefId)
            ->where('user_id', $userId)
            ->find();
        if (!$agent) {
            throw new \InvalidArgumentException('区域公司与用户不匹配');
        }
    }
}