diff --git a/admin/src/api/self_input_stats.ts b/admin/src/api/self_input_stats.ts new file mode 100644 index 00000000..bea4cf1a --- /dev/null +++ b/admin/src/api/self_input_stats.ts @@ -0,0 +1,50 @@ +import request from '@/utils/request' + +export function getSelfInputOverview(params: any) { + return request.get({ url: '/stats.self_input/overview', params }) +} + +/** 自媒体来源下拉（业绩+账户消耗已录入值去重） */ +export function getSelfInputMediaSourceOptions() { + return request.get({ url: '/stats.self_input/mediaSourceOptions' }) +} + +export function personalYejiLists(params: any) { + return request.get({ url: '/stats.personal_yeji/lists', params }) +} + +export function personalYejiAdd(data: any) { + return request.post({ url: '/stats.personal_yeji/add', data }) +} + +export function personalYejiEdit(data: any) { + return request.post({ url: '/stats.personal_yeji/edit', data }) +} + +export function personalYejiDetail(params: any) { + return request.get({ url: '/stats.personal_yeji/detail', params }) +} + +export function personalYejiDelete(params: any) { + return request.post({ url: '/stats.personal_yeji/delete', params }) +} + +export function personalAccountCostLists(params: any) { + return request.get({ url: '/stats.personal_account_cost/lists', params }) +} + +export function personalAccountCostAdd(data: any) { + return request.post({ url: '/stats.personal_account_cost/add', data }) +} + +export function personalAccountCostEdit(data: any) { + return request.post({ url: '/stats.personal_account_cost/edit', data }) +} + +export function personalAccountCostDetail(params: any) { + return request.get({ url: '/stats.personal_account_cost/detail', params }) +} + +export function personalAccountCostDelete(params: any) { + return request.post({ url: '/stats.personal_account_cost/delete', params }) +} diff --git a/admin/src/views/stats/self_input/MediaSourceSelect.vue b/admin/src/views/stats/self_input/MediaSourceSelect.vue new file mode 100644 index 00000000..bf47d47d --- /dev/null +++ b/admin/src/views/stats/self_input/MediaSourceSelect.vue @@ -0,0 +1,82 @@ + + + diff --git a/admin/src/views/stats/self_input/account_cost.vue b/admin/src/views/stats/self_input/account_cost.vue new file mode 100644 index 00000000..edbbd26a --- /dev/null +++ b/admin/src/views/stats/self_input/account_cost.vue @@ -0,0 +1,254 @@ + + + + + diff --git a/admin/src/views/stats/self_input/cost-edit.vue b/admin/src/views/stats/self_input/cost-edit.vue new file mode 100644 index 00000000..4a113a5a --- /dev/null +++ b/admin/src/views/stats/self_input/cost-edit.vue @@ -0,0 +1,142 @@ + + + diff --git a/admin/src/views/stats/self_input/index.vue b/admin/src/views/stats/self_input/index.vue new file mode 100644 index 00000000..349a4acc --- /dev/null +++ b/admin/src/views/stats/self_input/index.vue @@ -0,0 +1,499 @@ + + + + + diff --git a/admin/src/views/stats/self_input/useMediaSourceOptions.ts b/admin/src/views/stats/self_input/useMediaSourceOptions.ts new file mode 100644 index 00000000..681c775a --- /dev/null +++ b/admin/src/views/stats/self_input/useMediaSourceOptions.ts @@ -0,0 +1,63 @@ +import { getSelfInputMediaSourceOptions } from '@/api/self_input_stats' + +/** + * 自录转化统计：自媒体来源选项（来自字典「推广渠道」channels）。 + * 业绩页与账户消耗页共用同一接口，下拉打开时刷新，保证两侧字典变更同步。 + */ +export interface MediaSourceOption { + name: string + value: string +} + +export function useMediaSourceOptions() { + const mediaSourceOptions = ref([]) + const mediaSourceLoading = ref(false) + + const normalize = (raw: any): MediaSourceOption[] => { + if (!Array.isArray(raw)) return [] + const list: MediaSourceOption[] = [] + const seen = new Set() + for (const item of raw) { + if (typeof item === 'string') { + const name = item.trim() + if (name && !seen.has(name)) { + seen.add(name) + list.push({ name, value: '' }) + } + continue + } + if (item && typeof item === 'object') { + const name = String(item.name ?? '').trim() + if (name && !seen.has(name)) { + seen.add(name) + list.push({ name, value: String(item.value ?? '') }) + } + } + } + return list + } + + const loadMediaSourceOptions = async (force = false) => { + if (!force && mediaSourceOptions.value.length > 0) { + return + } + mediaSourceLoading.value = true + try { + const res = await getSelfInputMediaSourceOptions() + mediaSourceOptions.value = normalize(res) + } catch { + mediaSourceOptions.value = [] + } finally { + mediaSourceLoading.value = false + } + } + + const refreshMediaSourceOptions = () => loadMediaSourceOptions(true) + + return { + mediaSourceOptions, + mediaSourceLoading, + loadMediaSourceOptions, + refreshMediaSourceOptions, + } +} diff --git a/admin/src/views/stats/self_input/yeji-edit.vue b/admin/src/views/stats/self_input/yeji-edit.vue new file mode 100644 index 00000000..abb45c37 --- /dev/null +++ b/admin/src/views/stats/self_input/yeji-edit.vue @@ -0,0 +1,234 @@ + + + diff --git a/server/app/adminapi/controller/stats/PersonalAccountCostController.php b/server/app/adminapi/controller/stats/PersonalAccountCostController.php new file mode 100644 index 00000000..43ff292a --- /dev/null +++ b/server/app/adminapi/controller/stats/PersonalAccountCostController.php @@ -0,0 +1,62 @@ +dataLists(new PersonalAccountCostLists()); + } + + public function add() + { + $params = (new PersonalAccountCostValidate())->post()->goCheck('add'); + $result = PersonalAccountCostLogic::add($params, $this->adminId, (string) ($this->adminInfo['name'] ?? '')); + if ($result === false) { + return $this->fail(PersonalAccountCostLogic::getError()); + } + + return $this->success('添加成功', [], 1, 1); + } + + public function edit() + { + $params = (new PersonalAccountCostValidate())->post()->goCheck('edit'); + $result = PersonalAccountCostLogic::edit($params, $this->adminId, (string) ($this->adminInfo['name'] ?? ''), $this->adminInfo); + if ($result === false) { + return $this->fail(PersonalAccountCostLogic::getError()); + } + + return $this->success('编辑成功', [], 1, 1); + } + + public function detail() + { + $params = (new PersonalAccountCostValidate())->goCheck('detail'); + $detail = PersonalAccountCostLogic::detail((int) $params['id'], $this->adminId, $this->adminInfo); + if ($detail === []) { + return $this->fail('记录不存在或无权查看'); + } + + return $this->data($detail); + } + + public function delete() + { + $params = (new PersonalAccountCostValidate())->post()->goCheck('delete'); + $result = PersonalAccountCostLogic::delete((int) $params['id'], $this->adminId, $this->adminInfo); + if ($result === false) { + return $this->fail(PersonalAccountCostLogic::getError()); + } + + return $this->success('删除成功', [], 1, 1); + } +} diff --git a/server/app/adminapi/controller/stats/PersonalYejiController.php b/server/app/adminapi/controller/stats/PersonalYejiController.php new file mode 100644 index 00000000..6b7768f8 --- /dev/null +++ b/server/app/adminapi/controller/stats/PersonalYejiController.php @@ -0,0 +1,62 @@ +dataLists(new PersonalYejiLists()); + } + + public function add() + { + $params = (new PersonalYejiValidate())->post()->goCheck('add'); + $result = PersonalYejiLogic::add($params, $this->adminId, (string) ($this->adminInfo['name'] ?? '')); + if ($result === false) { + return $this->fail(PersonalYejiLogic::getError()); + } + + return $this->success('添加成功', [], 1, 1); + } + + public function edit() + { + $params = (new PersonalYejiValidate())->post()->goCheck('edit'); + $result = PersonalYejiLogic::edit($params, $this->adminId, (string) ($this->adminInfo['name'] ?? ''), $this->adminInfo); + if ($result === false) { + return $this->fail(PersonalYejiLogic::getError()); + } + + return $this->success('编辑成功', [], 1, 1); + } + + public function detail() + { + $params = (new PersonalYejiValidate())->goCheck('detail'); + $detail = PersonalYejiLogic::detail((int) $params['id'], $this->adminId, $this->adminInfo); + if ($detail === []) { + return $this->fail('记录不存在或无权查看'); + } + + return $this->data($detail); + } + + public function delete() + { + $params = (new PersonalYejiValidate())->post()->goCheck('delete'); + $result = PersonalYejiLogic::delete((int) $params['id'], $this->adminId, $this->adminInfo); + if ($result === false) { + return $this->fail(PersonalYejiLogic::getError()); + } + + return $this->success('删除成功', [], 1, 1); + } +} diff --git a/server/app/adminapi/controller/stats/SelfInputController.php b/server/app/adminapi/controller/stats/SelfInputController.php new file mode 100644 index 00000000..ad47411d --- /dev/null +++ b/server/app/adminapi/controller/stats/SelfInputController.php @@ -0,0 +1,28 @@ +request->get(), $this->adminId, $this->adminInfo); + + return $this->data($result); + } + + /** + * 自媒体来源下拉：从已录入业绩/账户消耗去重提取（随录入动态变化） + */ + public function mediaSourceOptions() + { + $list = SelfInputLogic::mediaSourceOptions($this->adminId, $this->adminInfo); + + return $this->data($list); + } +} diff --git a/server/app/adminapi/http/middleware/AuthMiddleware.php b/server/app/adminapi/http/middleware/AuthMiddleware.php index 8d726638..c45af2ac 100755 --- a/server/app/adminapi/http/middleware/AuthMiddleware.php +++ b/server/app/adminapi/http/middleware/AuthMiddleware.php @@ -132,6 +132,19 @@ class AuthMiddleware return true; } + // 自录转化统计：自媒体来源下拉，复用总览或账户消耗列表权限 + if ($accessUri === 'stats.selfinput/mediasourceoptions') { + $selfInputAliases = [ + 'stats.selfinput/overview', + 'stats.self_input/overview', + 'stats.personalaccountcost/lists', + 'stats.personal_account_cost/lists', + ]; + if (count(array_intersect($selfInputAliases, $AdminUris)) > 0) { + return true; + } + } + // 处方库列表：消费者开方页/处方库页导入共用，复用开方或处方库菜单权限 if ($accessUri === 'tcm.prescriptionlibrary/lists' && $this->matchPrescriptionLibraryListsPermission($adminUris)) { diff --git a/server/app/adminapi/lists/stats/PersonalAccountCostLists.php b/server/app/adminapi/lists/stats/PersonalAccountCostLists.php new file mode 100644 index 00000000..bda46740 --- /dev/null +++ b/server/app/adminapi/lists/stats/PersonalAccountCostLists.php @@ -0,0 +1,77 @@ + ['media_source', 'creator_name', 'remark'], + ]; + } + + private function baseQuery() + { + $query = PersonalAccountCost::where($this->searchWhere); + $visibleIds = $this->getDataScopeVisibleAdminIds(); + $deptId = (int) ($this->params['dept_id'] ?? 0); + + $finalIds = self::intersectVisibleByDept($visibleIds, $deptId); + if ($finalIds === []) { + $query->whereRaw('0 = 1'); + } elseif ($finalIds !== null) { + $query->whereIn('creator_id', $finalIds); + } + + if (!empty($this->params['start_date']) && !empty($this->params['end_date'])) { + $query->whereBetween('cost_date', [$this->params['start_date'], $this->params['end_date']]); + } elseif (!empty($this->params['start_date'])) { + $query->where('cost_date', '>=', $this->params['start_date']); + } elseif (!empty($this->params['end_date'])) { + $query->where('cost_date', '<=', $this->params['end_date']); + } + + if (!empty($this->params['media_source'])) { + $query->where('media_source', trim((string) $this->params['media_source'])); + } + + return $query; + } + + public function lists(): array + { + $rows = $this->baseQuery() + ->order(['cost_date' => 'desc', 'id' => 'desc']) + ->limit($this->limitOffset, $this->limitLength) + ->select() + ->toArray(); + + return self::attachDeptInfoToRows($rows); + } + + public function count(): int + { + return (int) $this->baseQuery()->count(); + } + + public function extend(): array + { + return [ + 'total_amount' => round((float) $this->baseQuery()->sum('amount'), 2), + 'days_count' => (int) $this->baseQuery()->distinct(true)->count('cost_date'), + ]; + } +} diff --git a/server/app/adminapi/lists/stats/PersonalYejiLists.php b/server/app/adminapi/lists/stats/PersonalYejiLists.php new file mode 100644 index 00000000..2a131080 --- /dev/null +++ b/server/app/adminapi/lists/stats/PersonalYejiLists.php @@ -0,0 +1,72 @@ + ['media_source', 'creator_name', 'remark'], + ]; + } + + private function baseQuery() + { + $query = PersonalYeji::where($this->searchWhere); + $visibleIds = $this->getDataScopeVisibleAdminIds(); + $deptId = (int) ($this->params['dept_id'] ?? 0); + + $finalIds = self::intersectVisibleByDept($visibleIds, $deptId); + if ($finalIds === []) { + $query->whereRaw('0 = 1'); + } elseif ($finalIds !== null) { + $query->whereIn('creator_id', $finalIds); + } + + if (!empty($this->params['start_date']) && !empty($this->params['end_date'])) { + $query->whereBetween('yeji_date', [$this->params['start_date'], $this->params['end_date']]); + } elseif (!empty($this->params['start_date'])) { + $query->where('yeji_date', '>=', $this->params['start_date']); + } elseif (!empty($this->params['end_date'])) { + $query->where('yeji_date', '<=', $this->params['end_date']); + } + + if (!empty($this->params['media_source'])) { + $query->where('media_source', trim((string) $this->params['media_source'])); + } + + if (!empty($this->params['creator_id'])) { + $query->where('creator_id', (int) $this->params['creator_id']); + } + + return $query; + } + + public function lists(): array + { + $rows = $this->baseQuery() + ->order(['yeji_date' => 'desc', 'id' => 'desc']) + ->limit($this->limitOffset, $this->limitLength) + ->select() + ->toArray(); + + return self::attachDeptInfoToRows($rows); + } + + public function count(): int + { + return (int) $this->baseQuery()->count(); + } +} diff --git a/server/app/adminapi/logic/stats/PersonalAccountCostLogic.php b/server/app/adminapi/logic/stats/PersonalAccountCostLogic.php new file mode 100644 index 00000000..c6528f89 --- /dev/null +++ b/server/app/adminapi/logic/stats/PersonalAccountCostLogic.php @@ -0,0 +1,122 @@ + $costDate, + 'media_source' => $mediaSource, + 'amount' => round((float) ($params['amount'] ?? 0), 2), + 'remark' => (string) ($params['remark'] ?? ''), + 'creator_id' => $adminId, + 'creator_name' => $adminName, + 'updater_id' => $adminId, + 'updater_name' => $adminName, + 'dept_id' => self::resolvePrimaryDeptId($adminId), + ]); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function edit(array $params, int $adminId, string $adminName, array $adminInfo): bool + { + try { + $model = PersonalAccountCost::find($params['id']); + if (!$model) { + self::setError('记录不存在'); + + return false; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + self::setError('无权操作该记录'); + + return false; + } + + $model->amount = round((float) ($params['amount'] ?? 0), 2); + $model->remark = (string) ($params['remark'] ?? ''); + $model->updater_id = $adminId; + $model->updater_name = $adminName; + $model->save(); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function delete(int $id, int $adminId, array $adminInfo): bool + { + try { + $model = PersonalAccountCost::find($id); + if (!$model) { + self::setError('记录不存在'); + + return false; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + self::setError('无权操作该记录'); + + return false; + } + + $model->delete(); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function detail(int $id, int $adminId, array $adminInfo): array + { + $model = PersonalAccountCost::find($id); + if (!$model) { + return []; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + return []; + } + + return $model->toArray(); + } +} diff --git a/server/app/adminapi/logic/stats/PersonalStatsScopeTrait.php b/server/app/adminapi/logic/stats/PersonalStatsScopeTrait.php new file mode 100644 index 00000000..79fe8154 --- /dev/null +++ b/server/app/adminapi/logic/stats/PersonalStatsScopeTrait.php @@ -0,0 +1,242 @@ +value('dept_id'); + + return (int) ($deptId ?: 0); + } + + /** + * @param array $creatorIds + * @return array{0: array, 1: array, 2: array} + * [adminId => deptId, deptId => name, deptId => "祖/父/当前"] + */ + protected static function loadAdminDeptMap(array $creatorIds): array + { + $creatorIds = array_values(array_unique(array_filter(array_map('intval', $creatorIds)))); + if ($creatorIds === []) { + return [[], [], []]; + } + $rows = AdminDept::whereIn('admin_id', $creatorIds) + ->field('admin_id, dept_id') + ->select() + ->toArray(); + + $adminToDeptId = []; + foreach ($rows as $row) { + $adminId = (int) ($row['admin_id'] ?? 0); + $deptId = (int) ($row['dept_id'] ?? 0); + if ($adminId <= 0 || $deptId <= 0) { + continue; + } + if (!isset($adminToDeptId[$adminId])) { + $adminToDeptId[$adminId] = $deptId; + } + } + + if ($adminToDeptId === []) { + return [[], [], []]; + } + + $allDeptRows = Dept::field('id, pid, name')->select()->toArray(); + $deptIndex = []; + foreach ($allDeptRows as $row) { + $id = (int) ($row['id'] ?? 0); + if ($id <= 0) { + continue; + } + $deptIndex[$id] = [ + 'pid' => (int) ($row['pid'] ?? 0), + 'name' => (string) ($row['name'] ?? ''), + ]; + } + + $deptNameMap = []; + $deptPathMap = []; + foreach (array_unique(array_values($adminToDeptId)) as $deptId) { + $deptId = (int) $deptId; + if ($deptId <= 0 || !isset($deptIndex[$deptId])) { + continue; + } + $deptNameMap[$deptId] = $deptIndex[$deptId]['name']; + $deptPathMap[$deptId] = self::resolveDeptPath($deptId, $deptIndex); + } + + return [$adminToDeptId, $deptNameMap, $deptPathMap]; + } + + /** + * 从根节点到当前部门的完整链路（用 / 分隔）。 + * + * @param array $deptIndex + */ + private static function resolveDeptPath(int $deptId, array $deptIndex): string + { + $names = []; + $guard = 0; + $cursor = $deptId; + while ($cursor > 0 && isset($deptIndex[$cursor]) && $guard++ < 32) { + $node = $deptIndex[$cursor]; + $name = trim($node['name']); + if ($name !== '') { + array_unshift($names, $name); + } + $cursor = $node['pid']; + } + + return implode(' / ', $names); + } + + /** + * @param array> $rows + * @return array> + */ + protected static function attachDeptInfoToRows(array $rows): array + { + if ($rows === []) { + return $rows; + } + $creatorIds = array_map(static fn (array $row): int => (int) ($row['creator_id'] ?? 0), $rows); + [$adminToDeptId, $deptNameMap, $deptPathMap] = self::loadAdminDeptMap($creatorIds); + foreach ($rows as &$row) { + $creatorId = (int) ($row['creator_id'] ?? 0); + $deptId = $adminToDeptId[$creatorId] ?? 0; + $row['dept_id'] = $deptId; + $row['dept_name'] = $deptId > 0 ? (string) ($deptNameMap[$deptId] ?? '') : ''; + $row['dept_path'] = $deptId > 0 ? (string) ($deptPathMap[$deptId] ?? '') : ''; + } + unset($row); + + return $rows; + } + + /** + * 根据 dept_id（包含其子部门）收窄可见 admin id 集合。 + * 与 visibleAdminIds 取交集。 + * + * @param array|null $visibleAdminIds null 表示不限 + * @return array|null 返回 null 表示外部条件无需附加；返回 [] 表示无可见 admin + */ + protected static function intersectVisibleByDept(?array $visibleAdminIds, int $deptId): ?array + { + if ($deptId <= 0) { + return $visibleAdminIds; + } + $deptIds = DeptLogic::getSelfAndDescendantIds($deptId); + if ($deptIds === []) { + $deptIds = [$deptId]; + } + $adminIds = AdminDept::whereIn('dept_id', $deptIds)->column('admin_id'); + $adminIds = array_values(array_unique(array_filter(array_map('intval', $adminIds), static fn (int $v): bool => $v > 0))); + + if ($visibleAdminIds === null) { + return $adminIds; + } + + return array_values(array_intersect($visibleAdminIds, $adminIds)); + } + + protected static function normalizeMediaSource(string $mediaSource): string + { + return trim($mediaSource); + } + + /** + * 与 project.self_input_stats_view_all_roles 一致：超管或白名单角色可见全部录入人数据。 + */ + protected static function canViewAllSelfInputStats(array $adminInfo): bool + { + if ((int) ($adminInfo['root'] ?? 0) === 1) { + return true; + } + $allow = Config::get('project.self_input_stats_view_all_roles', []); + $allow = array_map('intval', is_array($allow) ? $allow : []); + if ($allow === []) { + return false; + } + $myRoles = array_map('intval', $adminInfo['role_id'] ?? []); + + return count(array_intersect($myRoles, $allow)) > 0; + } + + /** + * @return array|null null=全部录入人；[]=无可见；int[]=可见 creator_id 集合 + */ + protected static function getVisibleCreatorIds(int $adminId, array $adminInfo): ?array + { + if (self::canViewAllSelfInputStats($adminInfo)) { + return null; + } + + return DataScopeService::getVisibleAdminIds($adminId, $adminInfo); + } + + protected static function assertRecordVisible(int $adminId, array $adminInfo, int $creatorId): bool + { + $visibleIds = self::getVisibleCreatorIds($adminId, $adminInfo); + if ($visibleIds === null) { + return true; + } + + return in_array($creatorId, $visibleIds, true); + } + + /** + * 同一天 + 同一渠道全局唯一（不分录入人）：避免重复汇总。 + * 命中时返回首个已存在记录的录入人姓名，便于前端提示。 + * + * @return array{conflict: bool, creator_name: string} + */ + protected static function findYejiConflict(string $yejiDate, string $mediaSource, int $excludeId = 0): array + { + $query = PersonalYeji::where('yeji_date', $yejiDate) + ->where('media_source', $mediaSource); + if ($excludeId > 0) { + $query->where('id', '<>', $excludeId); + } + $row = $query->field('id, creator_name')->find(); + if (!$row) { + return ['conflict' => false, 'creator_name' => '']; + } + + return ['conflict' => true, 'creator_name' => (string) ($row['creator_name'] ?? '')]; + } + + /** + * 同一天 + 同一渠道全局唯一（不分录入人）：避免重复汇总。 + * + * @return array{conflict: bool, creator_name: string} + */ + protected static function findCostConflict(string $costDate, string $mediaSource, int $excludeId = 0): array + { + $query = PersonalAccountCost::where('cost_date', $costDate) + ->where('media_source', $mediaSource); + if ($excludeId > 0) { + $query->where('id', '<>', $excludeId); + } + $row = $query->field('id, creator_name')->find(); + if (!$row) { + return ['conflict' => false, 'creator_name' => '']; + } + + return ['conflict' => true, 'creator_name' => (string) ($row['creator_name'] ?? '')]; + } +} diff --git a/server/app/adminapi/logic/stats/PersonalYejiLogic.php b/server/app/adminapi/logic/stats/PersonalYejiLogic.php new file mode 100644 index 00000000..2fd4fe50 --- /dev/null +++ b/server/app/adminapi/logic/stats/PersonalYejiLogic.php @@ -0,0 +1,136 @@ + $yejiDate, + 'media_source' => $mediaSource, + 'add_fans_count' => (int) ($params['add_fans_count'] ?? 0), + 'total_open_count' => (int) ($params['total_open_count'] ?? 0), + 'unreplied_count' => (int) ($params['unreplied_count'] ?? 0), + 'paid_appointment_count' => (int) ($params['paid_appointment_count'] ?? 0), + 'free_appointment_count' => (int) ($params['free_appointment_count'] ?? 0), + 'interview_count' => (int) ($params['interview_count'] ?? 0), + 'order_amount' => round((float) ($params['order_amount'] ?? 0), 2), + 'completed_order_count' => (int) ($params['completed_order_count'] ?? 0), + 'remark' => (string) ($params['remark'] ?? ''), + 'creator_id' => $adminId, + 'creator_name' => $adminName, + 'updater_id' => $adminId, + 'updater_name' => $adminName, + 'dept_id' => self::resolvePrimaryDeptId($adminId), + ]); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function edit(array $params, int $adminId, string $adminName, array $adminInfo): bool + { + try { + $model = PersonalYeji::find($params['id']); + if (!$model) { + self::setError('记录不存在'); + + return false; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + self::setError('无权操作该记录'); + + return false; + } + + $model->add_fans_count = (int) ($params['add_fans_count'] ?? 0); + $model->total_open_count = (int) ($params['total_open_count'] ?? 0); + $model->unreplied_count = (int) ($params['unreplied_count'] ?? 0); + $model->paid_appointment_count = (int) ($params['paid_appointment_count'] ?? 0); + $model->free_appointment_count = (int) ($params['free_appointment_count'] ?? 0); + $model->interview_count = (int) ($params['interview_count'] ?? 0); + $model->order_amount = round((float) ($params['order_amount'] ?? 0), 2); + $model->completed_order_count = (int) ($params['completed_order_count'] ?? 0); + $model->remark = (string) ($params['remark'] ?? ''); + $model->updater_id = $adminId; + $model->updater_name = $adminName; + $model->save(); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function delete(int $id, int $adminId, array $adminInfo): bool + { + try { + $model = PersonalYeji::find($id); + if (!$model) { + self::setError('记录不存在'); + + return false; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + self::setError('无权操作该记录'); + + return false; + } + + $model->delete(); + + return true; + } catch (\Throwable $e) { + self::setError($e->getMessage()); + + return false; + } + } + + public static function detail(int $id, int $adminId, array $adminInfo): array + { + $model = PersonalYeji::find($id); + if (!$model) { + return []; + } + + if (!self::assertRecordVisible($adminId, $adminInfo, (int) $model->creator_id)) { + return []; + } + + return $model->toArray(); + } +} diff --git a/server/app/adminapi/logic/stats/SelfInputLogic.php b/server/app/adminapi/logic/stats/SelfInputLogic.php new file mode 100644 index 00000000..22fd11a3 --- /dev/null +++ b/server/app/adminapi/logic/stats/SelfInputLogic.php @@ -0,0 +1,384 @@ +where('media_source', $mediaSource); + } + + $count = (int) (clone $yejiQuery)->count(); + $rows = (clone $yejiQuery) + ->order(['yeji_date' => 'desc', 'id' => 'desc']) + ->page($pageNo, $pageSize) + ->select() + ->toArray(); + + $costMap = self::loadAccountCostMap($startDate, $endDate, $effectiveAdminIds, $mediaSource); + + $lists = []; + foreach ($rows as $row) { + $entity = self::normalizeYejiRow($row); + $costKey = self::buildCostKey( + (int) $entity['creator_id'], + (string) $entity['yeji_date'], + (string) $entity['media_source'] + ); + $entity['account_cost'] = round((float) ($costMap[$costKey] ?? 0), 2); + $lists[] = self::finalizeMetrics($entity); + } + $lists = self::attachDeptInfoToRows($lists); + + $allYejiRows = self::buildYejiQuery($startDate, $endDate, $effectiveAdminIds); + if ($mediaSource !== '') { + $allYejiRows->where('media_source', $mediaSource); + } + $allYeji = $allYejiRows->select()->toArray(); + + $summaryCostMap = $costMap; + $summaryBase = self::emptyMetrics(); + foreach ($allYeji as $row) { + $entity = self::normalizeYejiRow($row); + $costKey = self::buildCostKey( + (int) $entity['creator_id'], + (string) $entity['yeji_date'], + (string) $entity['media_source'] + ); + $entity['account_cost'] = round((float) ($summaryCostMap[$costKey] ?? 0), 2); + unset($summaryCostMap[$costKey]); + $entity = self::finalizeMetrics($entity); + $summaryBase = self::accumulateMetrics($summaryBase, $entity); + } + + foreach ($summaryCostMap as $amount) { + $summaryBase['account_cost'] += round((float) $amount, 2); + } + + $summary = self::finalizeMetrics($summaryBase); + $canViewFinance = self::canViewAllSelfInputStats($adminInfo); + + if (!$canViewFinance) { + $summary = self::maskFinanceFields($summary); + foreach ($lists as &$item) { + $item = self::maskFinanceFields($item); + } + unset($item); + } + + return [ + 'summary' => $summary, + 'lists' => $lists, + 'count' => $count, + 'page_no' => $pageNo, + 'page_size' => $pageSize, + 'extend' => [ + 'summary' => $summary, + 'date_range' => [$startDate, $endDate], + 'can_view_finance' => $canViewFinance, + ], + ]; + } + + /** + * 财务相关字段（账户消耗 / 现金成本 / ROI）：非豁免角色不可见，剔除字段避免被嗅探。 + * + * @param array $entity + * @return array + */ + private static function maskFinanceFields(array $entity): array + { + foreach (['account_cost', 'cash_cost', 'roi'] as $key) { + unset($entity[$key]); + } + + return $entity; + } + + /** + * 自媒体来源选项：来自字典「推广渠道」（type_value=channels），按 sort/id 排序。 + * 用 dict_data.name 作为存储值（与历史录入兼容；保留 value 仅作展示标识）。 + * + * @return array + */ + public static function mediaSourceOptions(int $adminId, array $adminInfo): array + { + unset($adminId, $adminInfo); + + $rows = DictData::where('type_value', 'channels') + ->where('status', 1) + ->order(['sort' => 'desc', 'id' => 'asc']) + ->field('name, value') + ->select() + ->toArray(); + + $list = []; + $seen = []; + foreach ($rows as $row) { + $name = self::normalizeMediaSource((string) ($row['name'] ?? '')); + if ($name === '' || isset($seen[$name])) { + continue; + } + $seen[$name] = true; + $list[] = [ + 'name' => $name, + 'value' => (string) ($row['value'] ?? ''), + ]; + } + + return $list; + } + + /** + * @return array|null null = 不限；[] = 无可见 + */ + private static function resolveEffectiveAdminIds(int $adminId, array $adminInfo, int $deptId): ?array + { + $visibleIds = self::getVisibleCreatorIds($adminId, $adminInfo); + + return self::intersectVisibleByDept($visibleIds, $deptId); + } + + /** + * @param array|null $effectiveAdminIds + */ + private static function buildYejiQuery(string $startDate, string $endDate, ?array $effectiveAdminIds) + { + $query = PersonalYeji::whereBetween('yeji_date', [$startDate, $endDate]); + if ($effectiveAdminIds === []) { + $query->whereRaw('0 = 1'); + } elseif ($effectiveAdminIds !== null) { + $query->whereIn('creator_id', $effectiveAdminIds); + } + + return $query; + } + + /** + * @param array|null $effectiveAdminIds + * @return array + */ + private static function loadAccountCostMap( + string $startDate, + string $endDate, + ?array $effectiveAdminIds, + string $mediaSource + ): array { + $query = PersonalAccountCost::whereBetween('cost_date', [$startDate, $endDate]); + if ($effectiveAdminIds === []) { + return []; + } + if ($effectiveAdminIds !== null) { + $query->whereIn('creator_id', $effectiveAdminIds); + } + if ($mediaSource !== '') { + $query->where('media_source', $mediaSource); + } + + $rows = $query + ->fieldRaw('creator_id, cost_date, media_source, SUM(amount) AS total_amount') + ->group('creator_id, cost_date, media_source') + ->select() + ->toArray(); + + $map = []; + foreach ($rows as $row) { + $key = self::buildCostKey( + (int) $row['creator_id'], + (string) $row['cost_date'], + (string) $row['media_source'] + ); + $map[$key] = round((float) ($row['total_amount'] ?? 0), 2); + } + + return $map; + } + + private static function buildCostKey(int $creatorId, string $date, string $mediaSource): string + { + return $creatorId . '|' . $date . '|' . self::normalizeMediaSource($mediaSource); + } + + /** + * @param array $row + * @return array + */ + private static function normalizeYejiRow(array $row): array + { + return [ + 'id' => (int) ($row['id'] ?? 0), + 'yeji_date' => (string) ($row['yeji_date'] ?? ''), + 'media_source' => (string) ($row['media_source'] ?? ''), + 'creator_id' => (int) ($row['creator_id'] ?? 0), + 'creator_name' => (string) ($row['creator_name'] ?? ''), + 'remark' => (string) ($row['remark'] ?? ''), + 'add_fans_count' => (int) ($row['add_fans_count'] ?? 0), + 'total_open_count' => (int) ($row['total_open_count'] ?? 0), + 'unreplied_count' => (int) ($row['unreplied_count'] ?? 0), + 'paid_appointment_count' => (int) ($row['paid_appointment_count'] ?? 0), + 'free_appointment_count' => (int) ($row['free_appointment_count'] ?? 0), + 'interview_count' => (int) ($row['interview_count'] ?? 0), + 'order_amount' => round((float) ($row['order_amount'] ?? 0), 2), + 'completed_order_count' => (int) ($row['completed_order_count'] ?? 0), + 'account_cost' => 0.0, + ]; + } + + /** + * @return array + */ + private static function emptyMetrics(): array + { + return [ + 'add_fans_count' => 0, + 'total_open_count' => 0, + 'unreplied_count' => 0, + 'paid_appointment_count' => 0, + 'free_appointment_count' => 0, + 'appointment_total_count' => 0, + 'interview_count' => 0, + 'order_amount' => 0.0, + 'completed_order_count' => 0, + 'account_cost' => 0.0, + ]; + } + + /** + * @param array $base + * @param array $row + * @return array + */ + private static function accumulateMetrics(array $base, array $row): array + { + $base['add_fans_count'] += (int) ($row['add_fans_count'] ?? 0); + $base['total_open_count'] += (int) ($row['total_open_count'] ?? 0); + $base['unreplied_count'] += (int) ($row['unreplied_count'] ?? 0); + $base['paid_appointment_count'] += (int) ($row['paid_appointment_count'] ?? 0); + $base['free_appointment_count'] += (int) ($row['free_appointment_count'] ?? 0); + $base['interview_count'] += (int) ($row['interview_count'] ?? 0); + $base['order_amount'] = round((float) $base['order_amount'] + (float) ($row['order_amount'] ?? 0), 2); + $base['completed_order_count'] += (int) ($row['completed_order_count'] ?? 0); + $base['account_cost'] = round((float) $base['account_cost'] + (float) ($row['account_cost'] ?? 0), 2); + + return $base; + } + + /** + * @param array $entity + * @return array + */ + private static function finalizeMetrics(array $entity): array + { + $paidAppointmentCount = (int) ($entity['paid_appointment_count'] ?? 0); + $freeAppointmentCount = (int) ($entity['free_appointment_count'] ?? 0); + $appointmentTotalCount = $paidAppointmentCount + $freeAppointmentCount; + $interviewCount = (int) ($entity['interview_count'] ?? 0); + $addFansCount = (int) ($entity['add_fans_count'] ?? 0); + $totalOpenCount = (int) ($entity['total_open_count'] ?? 0); + $completedOrderCount = (int) ($entity['completed_order_count'] ?? 0); + $orderAmount = round((float) ($entity['order_amount'] ?? 0), 2); + $accountCost = round((float) ($entity['account_cost'] ?? 0), 2); + + $entity['appointment_total_count'] = $appointmentTotalCount; + $entity['order_amount'] = $orderAmount; + $entity['account_cost'] = $accountCost; + $entity['paid_appointment_rate'] = self::percent($paidAppointmentCount, $addFansCount); + $entity['open_appointment_rate'] = self::percent($paidAppointmentCount, $totalOpenCount); + $entity['interview_rate'] = self::percent($interviewCount, $appointmentTotalCount); + $entity['receive_rate'] = self::percent($completedOrderCount, $addFansCount); + $entity['interview_receive_rate'] = self::percent($completedOrderCount, $interviewCount); + $entity['open_receive_rate'] = self::percent($completedOrderCount, $totalOpenCount); + $entity['avg_unit_price'] = self::safeDivideMoney($orderAmount, $completedOrderCount); + $entity['cash_cost'] = self::safeDivideMoney($accountCost, $addFansCount); + $entity['roi'] = self::safeDivideRatio($orderAmount, $accountCost); + + return $entity; + } + + /** + * @return array{0: string, 1: string} + */ + private static function resolveTimeRange(array $params): array + { + $today = date('Y-m-d'); + $timeType = (string) ($params['time_type'] ?? 'today'); + + switch ($timeType) { + case 'yesterday': + $startDate = date('Y-m-d', strtotime('-1 day')); + $endDate = $startDate; + break; + case 'week': + $startDate = date('Y-m-d', strtotime('-6 days')); + $endDate = $today; + break; + case 'month': + $startDate = date('Y-m-d', strtotime('-29 days')); + $endDate = $today; + break; + case 'custom': + $startDate = trim((string) ($params['start_date'] ?? '')); + $endDate = trim((string) ($params['end_date'] ?? '')); + if ($startDate === '' || $endDate === '') { + $startDate = $today; + $endDate = $today; + } elseif ($startDate > $endDate) { + [$startDate, $endDate] = [$endDate, $startDate]; + } + break; + case 'today': + default: + $startDate = $today; + $endDate = $today; + } + + return [$startDate, $endDate]; + } + + private static function percent(int $numerator, int $denominator): float + { + if ($denominator <= 0) { + return 0.0; + } + + return round(($numerator / $denominator) * 100, 2); + } + + private static function safeDivideMoney(float $numerator, int $denominator): float + { + if ($denominator <= 0) { + return 0.0; + } + + return round($numerator / $denominator, 2); + } + + private static function safeDivideRatio(float $numerator, float $denominator): float + { + if ($denominator <= 0) { + return 0.0; + } + + return round($numerator / $denominator, 2); + } +} diff --git a/server/app/adminapi/validate/stats/PersonalAccountCostValidate.php b/server/app/adminapi/validate/stats/PersonalAccountCostValidate.php new file mode 100644 index 00000000..01bc382a --- /dev/null +++ b/server/app/adminapi/validate/stats/PersonalAccountCostValidate.php @@ -0,0 +1,61 @@ + 'require|checkExists', + 'cost_date' => 'require|dateFormat:Y-m-d', + 'media_source' => 'require|max:120', + 'amount' => 'require|float|egt:0', + 'remark' => 'max:255', + ]; + + protected $message = [ + 'id.require' => '参数缺失', + 'cost_date.require' => '请选择日期', + 'cost_date.dateFormat' => '日期格式错误', + 'media_source.require' => '请填写自媒体来源', + 'media_source.max' => '自媒体来源不能超过120个字符', + 'amount.require' => '请输入账户消耗金额', + 'amount.float' => '账户消耗金额格式错误', + 'amount.egt' => '账户消耗金额不能小于0', + 'remark.max' => '备注不能超过255个字符', + ]; + + public function sceneAdd() + { + return $this->remove('id', true); + } + + public function sceneEdit() + { + return $this->remove('cost_date', true)->remove('media_source', true); + } + + public function sceneDetail() + { + return $this->only(['id']); + } + + public function sceneDelete() + { + return $this->only(['id']); + } + + public function checkExists($value) + { + $model = PersonalAccountCost::find($value); + if (!$model) { + return '记录不存在'; + } + + return true; + } +} diff --git a/server/app/adminapi/validate/stats/PersonalYejiValidate.php b/server/app/adminapi/validate/stats/PersonalYejiValidate.php new file mode 100644 index 00000000..63f7c774 --- /dev/null +++ b/server/app/adminapi/validate/stats/PersonalYejiValidate.php @@ -0,0 +1,68 @@ + 'require|checkExists', + 'yeji_date' => 'require|dateFormat:Y-m-d', + 'media_source' => 'require|max:120', + 'add_fans_count' => 'require|integer|egt:0', + 'total_open_count' => 'integer|egt:0', + 'unreplied_count' => 'integer|egt:0', + 'paid_appointment_count' => 'integer|egt:0', + 'free_appointment_count' => 'integer|egt:0', + 'interview_count' => 'integer|egt:0', + 'order_amount' => 'float|egt:0', + 'completed_order_count' => 'integer|egt:0', + 'remark' => 'max:255', + ]; + + protected $message = [ + 'id.require' => '参数缺失', + 'yeji_date.require' => '请选择业绩日期', + 'yeji_date.dateFormat' => '业绩日期格式错误', + 'media_source.require' => '请填写自媒体来源', + 'media_source.max' => '自媒体来源不能超过120个字符', + 'add_fans_count.require' => '请填写加粉数', + 'add_fans_count.integer' => '加粉数格式错误', + 'add_fans_count.egt' => '加粉数不能小于0', + 'remark.max' => '备注不能超过255个字符', + ]; + + public function sceneAdd() + { + return $this->remove('id', true); + } + + public function sceneEdit() + { + return $this->remove('yeji_date', true)->remove('media_source', true); + } + + public function sceneDetail() + { + return $this->only(['id']); + } + + public function sceneDelete() + { + return $this->only(['id']); + } + + public function checkExists($value) + { + $model = PersonalYeji::find($value); + if (!$model) { + return '记录不存在'; + } + + return true; + } +} diff --git a/server/app/common/model/stats/PersonalAccountCost.php b/server/app/common/model/stats/PersonalAccountCost.php new file mode 100644 index 00000000..2bb80c3d --- /dev/null +++ b/server/app/common/model/stats/PersonalAccountCost.php @@ -0,0 +1,23 @@ + [0, 3, 4, 9, 6], + // 自录转化统计（stats.self_input / personal_yeji / personal_account_cost）： + // 以下角色 ID + root 在列表与总览中可见全部录入人的业绩/账户消耗（不受角色 data_scope 收窄）。 + // 编辑/删除由菜单按钮权限（stats.personal_yeji/edit 等）控制，不在此配置。 + 'self_input_stats_view_all_roles' => [0, 3, 4, 9, 6], + // 业务订单列表金额统计：医助角色 ID；非支付审核白名单的医助仅统计其诊单 assistant_id=本人 的业绩 'prescription_order_stats_assistant_role_id' => 2, diff --git a/server/sql/1.9.20260521/add_self_input_stats_menu.sql b/server/sql/1.9.20260521/add_self_input_stats_menu.sql new file mode 100644 index 00000000..7c1dcce2 --- /dev/null +++ b/server/sql/1.9.20260521/add_self_input_stats_menu.sql @@ -0,0 +1,145 @@ +-- 自录数据统计菜单（挂在「数据统计」目录下） +-- 目录: /stats/self_input（自录数据统计） +-- 子菜单: +-- 自录转化统计 -> /stats/self_input +-- 账户消耗录入 -> /stats/self_input/account_cost +-- 子菜单 paths 为相对父级目录的路径片段。 + +-- ========== 已执行旧版 SQL 的环境：迁移到「自录数据统计」目录 ========== +SET @stats_root_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `paths` = '/stats' AND `type` = 'M' + ORDER BY `id` ASC + LIMIT 1 +); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT + @stats_root_id, 'M', '自录数据统计', '', 5, '', 'self_input', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL +WHERE @stats_root_id IS NOT NULL + AND NOT EXISTS ( + SELECT 1 FROM `zyt_system_menu` + WHERE `pid` = @stats_root_id AND `type` = 'M' AND `name` = '自录数据统计' + ); + +SET @self_input_group_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `pid` = @stats_root_id AND `type` = 'M' AND `name` = '自录数据统计' + ORDER BY `id` ASC + LIMIT 1 +); + +UPDATE `zyt_system_menu` +SET `pid` = @self_input_group_id, + `paths` = '', + `component` = 'stats/self_input/index', + `sort` = 1 +WHERE `perms` = 'stats.self_input/overview' + AND @self_input_group_id IS NOT NULL; + +UPDATE `zyt_system_menu` +SET `pid` = @self_input_group_id, + `paths` = 'account_cost', + `component` = 'stats/self_input/account_cost', + `sort` = 2 +WHERE `perms` = 'stats.personal_account_cost/lists' + AND @self_input_group_id IS NOT NULL; + +-- ========== 全新安装：目录 + 子菜单 + 按钮权限 ========== +SET @stats_root_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `paths` = '/stats' AND `type` = 'M' + ORDER BY `id` ASC + LIMIT 1 +); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT + @stats_root_id, 'M', '自录数据统计', '', 5, '', 'self_input', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL +WHERE @stats_root_id IS NOT NULL + AND NOT EXISTS ( + SELECT 1 FROM `zyt_system_menu` + WHERE `pid` = @stats_root_id AND `type` = 'M' AND `name` = '自录数据统计' + ); + +SET @self_input_group_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `pid` = @stats_root_id AND `type` = 'M' AND `name` = '自录数据统计' + ORDER BY `id` ASC + LIMIT 1 +); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT + @self_input_group_id, 'C', '自录转化统计', '', 1, 'stats.self_input/overview', '', 'stats/self_input/index', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL +WHERE @self_input_group_id IS NOT NULL + AND NOT EXISTS ( + SELECT 1 FROM `zyt_system_menu` + WHERE `perms` = 'stats.self_input/overview' + ); + +SET @self_input_menu_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `perms` = 'stats.self_input/overview' + LIMIT 1 +); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @self_input_menu_id, 'A', '查看业绩', '', 1, 'stats.personal_yeji/lists', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @self_input_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_yeji/lists'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @self_input_menu_id, 'A', '新增业绩', '', 2, 'stats.personal_yeji/add', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @self_input_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_yeji/add'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @self_input_menu_id, 'A', '编辑业绩', '', 3, 'stats.personal_yeji/edit', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @self_input_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_yeji/edit'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @self_input_menu_id, 'A', '删除业绩', '', 4, 'stats.personal_yeji/delete', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @self_input_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_yeji/delete'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT + @self_input_group_id, 'C', '账户消耗录入', '', 2, 'stats.personal_account_cost/lists', 'account_cost', 'stats/self_input/account_cost', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL +WHERE @self_input_group_id IS NOT NULL + AND NOT EXISTS ( + SELECT 1 FROM `zyt_system_menu` + WHERE `perms` = 'stats.personal_account_cost/lists' + ); + +SET @personal_cost_menu_id = ( + SELECT `id` FROM `zyt_system_menu` + WHERE `perms` = 'stats.personal_account_cost/lists' + LIMIT 1 +); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @personal_cost_menu_id, 'A', '新增消耗', '', 1, 'stats.personal_account_cost/add', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @personal_cost_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_account_cost/add'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @personal_cost_menu_id, 'A', '编辑消耗', '', 2, 'stats.personal_account_cost/edit', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @personal_cost_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_account_cost/edit'); + +INSERT INTO `zyt_system_menu` + (`pid`, `type`, `name`, `icon`, `sort`, `perms`, `paths`, `component`, `selected`, `params`, `is_show`, `is_disable`, `create_time`, `update_time`) +SELECT @personal_cost_menu_id, 'A', '删除消耗', '', 3, 'stats.personal_account_cost/delete', '', '', '', '', 1, 0, UNIX_TIMESTAMP(), UNIX_TIMESTAMP() +FROM DUAL WHERE @personal_cost_menu_id IS NOT NULL AND NOT EXISTS (SELECT 1 FROM `zyt_system_menu` WHERE `perms` = 'stats.personal_account_cost/delete'); + +-- 角色需勾选新目录「自录数据统计」后，子菜单权限才会一并生效（与 likeadmin 菜单树授权一致） diff --git a/server/sql/1.9.20260521/alter_personal_unique_key.sql b/server/sql/1.9.20260521/alter_personal_unique_key.sql new file mode 100644 index 00000000..34443ccf --- /dev/null +++ b/server/sql/1.9.20260521/alter_personal_unique_key.sql @@ -0,0 +1,10 @@ +-- 业绩 & 账户消耗：将「同录入人+同日+同渠道」唯一改为「同日+同渠道」全局唯一，避免重复汇总。 +-- 注意：执行前请先清理同一天同一渠道下多录入人重复的数据，否则索引创建会失败。 + +-- zyt_personal_yeji +ALTER TABLE `zyt_personal_yeji` DROP INDEX `uk_creator_date_media`; +ALTER TABLE `zyt_personal_yeji` ADD UNIQUE KEY `uk_date_media` (`yeji_date`, `media_source`); + +-- zyt_personal_account_cost +ALTER TABLE `zyt_personal_account_cost` DROP INDEX `uk_creator_date_media`; +ALTER TABLE `zyt_personal_account_cost` ADD UNIQUE KEY `uk_date_media` (`cost_date`, `media_source`); diff --git a/server/sql/1.9.20260521/create_personal_account_cost_table.sql b/server/sql/1.9.20260521/create_personal_account_cost_table.sql new file mode 100644 index 00000000..a01e0797 --- /dev/null +++ b/server/sql/1.9.20260521/create_personal_account_cost_table.sql @@ -0,0 +1,20 @@ +CREATE TABLE IF NOT EXISTS `zyt_personal_account_cost` ( + `id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID', + `cost_date` date NOT NULL COMMENT '消耗日期', + `media_source` varchar(120) NOT NULL DEFAULT '' COMMENT '自媒体来源', + `amount` decimal(10,2) NOT NULL DEFAULT '0.00' COMMENT '账户消耗金额', + `remark` varchar(255) NOT NULL DEFAULT '' COMMENT '备注', + `creator_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '录入人ID', + `creator_name` varchar(64) NOT NULL DEFAULT '' COMMENT '录入人姓名', + `updater_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '最后修改人ID', + `updater_name` varchar(64) NOT NULL DEFAULT '' COMMENT '最后修改人姓名', + `dept_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '录入时部门ID快照', + `create_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间', + `update_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '更新时间', + `delete_time` int(11) unsigned DEFAULT NULL COMMENT '删除时间', + PRIMARY KEY (`id`), + UNIQUE KEY `uk_date_media` (`cost_date`, `media_source`), + KEY `idx_cost_date` (`cost_date`), + KEY `idx_creator_id` (`creator_id`), + KEY `idx_dept_id` (`dept_id`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='个人账户消耗录入表'; diff --git a/server/sql/1.9.20260521/create_personal_yeji_table.sql b/server/sql/1.9.20260521/create_personal_yeji_table.sql new file mode 100644 index 00000000..f1194121 --- /dev/null +++ b/server/sql/1.9.20260521/create_personal_yeji_table.sql @@ -0,0 +1,27 @@ +CREATE TABLE IF NOT EXISTS `zyt_personal_yeji` ( + `id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '主键ID', + `yeji_date` date NOT NULL COMMENT '业绩日期', + `media_source` varchar(120) NOT NULL DEFAULT '' COMMENT '自媒体来源', + `add_fans_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '加粉数', + `total_open_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '总开口', + `unreplied_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '未回复', + `paid_appointment_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '付费挂号', + `free_appointment_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '免费挂号', + `interview_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '面诊', + `order_amount` decimal(10,2) NOT NULL DEFAULT '0.00' COMMENT '订单金额', + `completed_order_count` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '接诊诊单', + `remark` varchar(255) NOT NULL DEFAULT '' COMMENT '备注', + `creator_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '录入人ID', + `creator_name` varchar(64) NOT NULL DEFAULT '' COMMENT '录入人姓名', + `updater_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '最后修改人ID', + `updater_name` varchar(64) NOT NULL DEFAULT '' COMMENT '最后修改人姓名', + `dept_id` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '录入时部门ID快照', + `create_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '创建时间', + `update_time` int(11) unsigned NOT NULL DEFAULT '0' COMMENT '更新时间', + `delete_time` int(11) unsigned DEFAULT NULL COMMENT '删除时间', + PRIMARY KEY (`id`), + UNIQUE KEY `uk_date_media` (`yeji_date`, `media_source`), + KEY `idx_yeji_date` (`yeji_date`), + KEY `idx_creator_id` (`creator_id`), + KEY `idx_dept_id` (`dept_id`) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='个人业绩录入表';