crm/protected/controllers/CompanyRelationController.php

<?php

class CompanyRelationController extends Controller
{
    public string $table = 'company_contact';

    public function actionInfo()
    {
        $id = Helper::getPostInt('id');
        if ($id <= 0) {
            Helper::error('参数错误');
        }
        $data = DB::getInfoById($this->table, $id);
        if (!$data) {
            Helper::error('数据不存在');
        }
        Helper::ok($data);
    }

    public function actionList()
    {
        $filter = [
            'r.is_del'    => 0,
            'r.phone'     => Helper::getPostString('phone'),
            'r.company_id' => Helper::getPostInt('company_id') ?: null,
        ];
        if ($name = Helper::getPostString('name')) {
            $filter['r.name'] = '%'.$name;
        }
        $cri = DbCriteria::simpleCompareWithPage($filter)
            ->setAlias('r')
            ->setSelect('r.*, s.name as company_name')
            ->setJoin('LEFT JOIN wx_company s ON s.id=r.company_id')
            ->setOrder('r.id desc');
        if ($date = Helper::getPostDate('date')) {
            $cri->addBetweenCondition('r.create_date', $date, $date . ' 23:59:59');
        }
        $data = DB::getListWithCriteria($this->table, $cri);
        if (!empty($data['records'])) {
            $users = Helper::arrayColumn(
                DB::getListWithCriteria('useradmin', DbCriteria::simpleCompare([])->setSelect('id, username')),
                'username',
                'id'
            );
            $data['records'] = array_map(function ($item) use ($users) {
                $item['last_user_name'] = $users[$item['last_user_id']] ?? '-';
                return $item;
            }, $data['records']);
        }
        Helper::ok($data);
    }

    /**
     * 下拉列表获取
     * @return void
     */
    public function actionGetSelectList()
    {
        $cri = DbCriteria::simpleCompare(['is_del' => 0])->setSelect('id, name');
        $companys = Helper::arrayColumn(DB::getListWithCriteria('company', $cri), null, 'id');
        if (empty($companys)) {
            Helper::ok();
        }
        $cri1 = DbCriteria::simpleCompare(['is_del' => 0])->setSelect('id, name, company_id');
        $relations = DB::getListWithCriteria($this->table, $cri1);
        foreach ($relations['records'] as $relation) {
            $sid = $relation['company_id'];
            if (!isset($companys[$sid])) {
                continue;
            }
            if (!isset($companys[$sid]['children'])) {
                $companys[$sid]['children'] = [];
            }
            $companys[$sid]['children'][] = [
                'id'   => $relation['id'],
                'name' => $relation['name'],
            ];
        }
        Helper::ok(array_values($companys));
    }

    public function actionDelete()
    {
        $id = Helper::getPostInt('id');
        if ($id < 1) {
            Helper::error('参数错误');
        }
        Db::updateById($this->table, ['is_del' => 1], $id);
        Helper::ok();
    }

    public function actionAdd()
    {
        $this->_save();
    }

    public function actionEdit()
    {
        $id = Helper::getPostInt('id');
        if (!$id) {
            Helper::error('参数错误');
        }
        $this->_save($id);
    }

    private function _save($id = 0)
    {
        $data = [
            'name'      => Helper::getPostString('name'),
            'company_id' => Helper::getPostInt('company_id'),
            'phone'     => Helper::getPostString('phone'),
            'weixin'    => Helper::getPostString('weixin'),
            'position'  => Helper::getPostString('position'),
            'memo'      => Helper::getPostString('memo'),
        ];

        $notNullField = ["name", "company_id", "phone", "weixin", "position"];
        $allowEmptyField = [];

        // 空字段检测
        if (!Helper::checkEmptyKey($data, $notNullField, $allowEmptyField)) {
            Helper::error('参数错误');
        }

        if ($id) {
            DB::updateById($this->table, $data, $id);
        } else {
            DB::addData($this->table, $data);
        }
        Helper::ok();
    }

    public function actionUpdateAttr()
    {
        $id = Helper::getPostInt('id');
        $attr = Helper::getPostString('attr');
        $value = Helper::getPostString('value');
        if ($id <= 0 || !$attr) {
            Helper::error('参数错误');
        }
        if (!in_array($attr, [])) {
            Helper::error('参数错误2');
        }
        if (DB::updateById($this->table, [$attr => $value], $id) === false) {
            Helper::error('更新失败');
        }
        Helper::ok();
    }
}