nanguaboss
80 lines
3.0 KiB
PHP
80 lines
3.0 KiB
PHP
<?php
|
||
/**
|
||
* 人员新增接口 POST /api/person/add.php
|
||
* 必填：full_name；union_id 为空时自动生成。
|
||
* 可选：contacts（JSON 数组，如 [{"platform":"email","account_id":"a@b.com","is_primary":1}]）
|
||
*/
|
||
require_once __DIR__ . '/../common/db.php';
|
||
require_once __DIR__ . '/../common/response.php';
|
||
require_once __DIR__ . '/../common/auth.php';
|
||
require_once __DIR__ . '/../common/logger.php';
|
||
require_once __DIR__ . '/../common/helpers.php';
|
||
require_once __DIR__ . '/../common/completeness.php';
|
||
require_once __DIR__ . '/../common/duplicate_check.php';
|
||
require_once __DIR__ . '/../common/validate.php';
|
||
|
||
checkAjax();
|
||
checkPermission('person');
|
||
|
||
$data = extractFields(PERSON_FIELDS);
|
||
if (empty($data['full_name'])) {
|
||
Response::error('姓名（full_name）为必填项', 400);
|
||
}
|
||
if (empty($data['union_id'])) {
|
||
$data['union_id'] = 'P' . date('YmdHis') . substr(uniqid(), -6);
|
||
}
|
||
|
||
$pdo = DB::getInstance()->getPdo();
|
||
|
||
// union_id 唯一性
|
||
$chk = $pdo->prepare("SELECT COUNT(*) FROM persons WHERE union_id = ?");
|
||
$chk->execute([$data['union_id']]);
|
||
if ((int)$chk->fetchColumn() > 0) {
|
||
Response::error('union_id 已存在，请更换');
|
||
}
|
||
|
||
// 唯一性校验：身份证号码 / 联系方式（手机/邮箱/社媒账号/主页链接），收集全部重复
|
||
$dups = [];
|
||
if (!empty($data['id_number'])) {
|
||
checkFieldFormat('id_number', $data['id_number']);
|
||
$dup = findDuplicate($pdo, 'id_number', $data['id_number']);
|
||
if ($dup) $dups[] = $dup;
|
||
}
|
||
$contacts = json_decode($_POST['contacts'] ?? '[]', true);
|
||
if (!is_array($contacts)) {
|
||
$contacts = [];
|
||
}
|
||
$dups = array_merge($dups, checkAccountsDuplicates($pdo, $contacts));
|
||
if (!empty($dups)) Response::duplicates($dups);
|
||
|
||
[$sql, $params] = buildInsert($data);
|
||
$pdo->prepare("INSERT INTO persons $sql")->execute($params);
|
||
$newId = (int)$pdo->lastInsertId();
|
||
|
||
// 写入联系方式（v1.0.16：支持 is_defult 字段，1常用/0备用）
|
||
if (is_array($contacts) && count($contacts) > 0) {
|
||
$ins = $pdo->prepare(
|
||
"INSERT INTO social_accounts (owner_type, owner_id, platform, account_id, profile_url, remark, is_primary, is_defult)
|
||
VALUES ('person', ?, ?, ?, ?, ?, ?, ?)"
|
||
);
|
||
foreach ($contacts as $c) {
|
||
$platform = trim($c['platform'] ?? '');
|
||
$accountId = trim($c['account_id'] ?? '');
|
||
if ($platform === '' || $accountId === '') continue;
|
||
$ins->execute([$newId, $platform, $accountId, $c['profile_url'] ?? null, $c['remark'] ?? null, !empty($c['is_primary']) ? 1 : 0, !empty($c['is_defult']) ? 1 : 0]);
|
||
}
|
||
}
|
||
|
||
// 工作履历（v1.0.18：整表替换）
|
||
$experiences = json_decode($_POST['experiences'] ?? '[]', true);
|
||
if (is_array($experiences)) {
|
||
savePersonExperiences($pdo, $newId, $experiences);
|
||
}
|
||
|
||
// 完整度检查：人员主表 + 其 social_accounts
|
||
updateIncomplete($pdo, 'persons', $newId);
|
||
updateAccountsIncomplete($pdo, 'person', $newId);
|
||
|
||
logCurrent('add', 'person', 'persons', $newId, ['data' => $data, 'contacts' => $contacts]);
|
||
Response::success(['id' => $newId], '新增成功');
|