From b45152599e02fdc393a6b8b19dfb2cb11e353d9f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=BF=97=E5=BC=BA?= <357099073@qq.com> Date: Tue, 21 Jul 2026 14:04:49 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E8=AF=95frontend?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- backend/src/api/frontMenu.js | 11 +- backend/src/components/CommonAside.vue | 41 +- backend/src/router/index.js | 15 + .../src/views/apps/cms/articles/category.vue | 5 + .../cms/articles/components/CategoryNode.vue | 11 +- frontend/src/api/index.ts | 6 +- frontend/src/router/index.ts | 67 +- frontend/src/router/routes.ts | 203 +- frontend/src/utils/request.ts | 10 +- frontend/src/views/components/header.vue | 96 +- frontend/src/views/newsCenter/news/index.vue | 2 +- frontend/vite.config.ts | 6 +- go/controllers/backend_article.go | 2124 +++++++++-------- go/controllers/backend_menu_front.go | 154 ++ go/controllers/index_portal.go | 75 +- go/models/backend_menu_front.go | 33 + go/models/cms_article.go | 359 +-- go/routers/backend/backend.go | 4 +- 18 files changed, 1840 insertions(+), 1382 deletions(-) create mode 100644 go/controllers/backend_menu_front.go create mode 100644 go/models/backend_menu_front.go diff --git a/backend/src/api/frontMenu.js b/backend/src/api/frontMenu.js index f3f4dac..4124551 100644 --- a/backend/src/api/frontMenu.js +++ b/backend/src/api/frontMenu.js @@ -16,14 +16,11 @@ export function getFrontMenus() { * @param {Object} frontMenuData 前端导航数据 * @returns {Promise} */ -export function createFrontMenu(formData, options = {}) { +export function createFrontMenu(formData) { return request({ - url: "/backend/createfrontmenu", + url: "/backend/frontmenus", method: "post", data: formData, - headers: { - "Content-Type": "multipart/form-data" - } }); } @@ -35,7 +32,7 @@ export function createFrontMenu(formData, options = {}) { */ export function editFrontMenu(id, frontMenuData) { return request({ - url: `/backend/editfrontmenu/${id}`, + url: `/backend/frontmenus/${id}`, method: "post", data: frontMenuData, }); @@ -48,7 +45,7 @@ export function editFrontMenu(id, frontMenuData) { */ export function deleteFrontMenu(id) { return request({ - url: `/backend/deletefrontmenu/${id}`, + url: `/backend/frontmenus/${id}`, method: "delete", }); } diff --git a/backend/src/components/CommonAside.vue b/backend/src/components/CommonAside.vue index 5b55ba0..4335495 100644 --- a/backend/src/components/CommonAside.vue +++ b/backend/src/components/CommonAside.vue @@ -6,7 +6,7 @@ -
+
{{ errorMsg }}
重新加载 @@ -289,13 +289,40 @@ const processMenus = (menus) => { })); }; -const list = computed(() => { - const menuData = menuStore.menus; - if (!menuData || menuData.length === 0) { - return []; - } +const fixedCmsMenu = { + id: -200, + path: "/apps/cms", + title: "文章中心", + icon: "Document", + order: -200, + children: [ + { + id: -201, + path: "/apps/cms/articles", + title: "文章管理", + icon: "Document", + order: 1, + children: [] + }, + { + id: -202, + path: "/apps/cms/articles/category", + title: "文章分类", + icon: "Folder", + order: 2, + children: [] + } + ] +}; - const allMenus = processMenus(menuData); +const mergeFixedCmsMenu = (menus) => { + const hasCmsMenu = menus.some((menu) => menu.path === fixedCmsMenu.path); + return hasCmsMenu ? menus : [fixedCmsMenu, ...menus]; +}; + +const list = computed(() => { + const menuData = menuStore.menus || []; + const allMenus = processMenus(mergeFixedCmsMenu(menuData)); const sortMenusRecursively = (menus) => { menus.forEach((menu) => { diff --git a/backend/src/router/index.js b/backend/src/router/index.js index 8798c45..2eec62b 100644 --- a/backend/src/router/index.js +++ b/backend/src/router/index.js @@ -3,6 +3,19 @@ import { convertMenusToRoutes } from "./dynamicRoutes"; // 静态子路由：需要在 Main 框架内显示的页面 const staticMainChildren = [ + // CMS 文章中心是系统内置功能，不依赖数据库菜单配置。 + { + path: "/apps/cms/articles", + name: "CmsArticles", + component: () => import("@/views/apps/cms/articles/index.vue"), + meta: { requiresAuth: true, title: "文章管理", modulePath: "/apps/cms" } + }, + { + path: "/apps/cms/articles/category", + name: "CmsArticleCategories", + component: () => import("@/views/apps/cms/articles/category.vue"), + meta: { requiresAuth: true, title: "文章分类", modulePath: "/apps/cms" } + }, { path: "/user/userProfile", name: "userProfile", @@ -90,6 +103,8 @@ export async function loadAndAddDynamicRoutes() { routesLoadingPromise = null; return Promise.resolve(); } else { + // 即使权限菜单为空，也要注册内置文章中心路由。 + addDynamicRoutes([]); dynamicRoutesAdded = true; routesLoadingPromise = null; return Promise.resolve(); diff --git a/backend/src/views/apps/cms/articles/category.vue b/backend/src/views/apps/cms/articles/category.vue index b654ab0..70ba02d 100644 --- a/backend/src/views/apps/cms/articles/category.vue +++ b/backend/src/views/apps/cms/articles/category.vue @@ -156,6 +156,11 @@ function toggleExpand(category) { } function handleDelete(category) { + if (Number(category.tid) === 0 || category.is_global === true) { + ElMessage.warning("全局分类不可删除"); + return; + } + ElMessageBox.confirm(`确定要删除分类\"${category.label}\"吗？`, "提示", { confirmButtonText: "确定", cancelButtonText: "取消", diff --git a/backend/src/views/apps/cms/articles/components/CategoryNode.vue b/backend/src/views/apps/cms/articles/components/CategoryNode.vue index b08db73..0f8b4cb 100644 --- a/backend/src/views/apps/cms/articles/components/CategoryNode.vue +++ b/backend/src/views/apps/cms/articles/components/CategoryNode.vue @@ -53,9 +53,18 @@ - + + + 全局 +
diff --git a/frontend/src/api/index.ts b/frontend/src/api/index.ts index 524e80c..6591aef 100644 --- a/frontend/src/api/index.ts +++ b/frontend/src/api/index.ts @@ -2,18 +2,18 @@ import service from '@/utils/request' // 获取前端导航 export const getHeadMenu = async () => { - const response = await service.get('index/headmenu') + const response = await service.get('/api/index/headmenu') return response.data } // 根据路径获取单页内容 export const getOnePageByPath = async (path: string) => { - const response = await service.get(`index/onepage/${encodeURIComponent(path)}`) + const response = await service.get(`/api/index/onepage/${encodeURIComponent(path)}`) return response.data } // 获取前端底部数据 export const getFooterData = async () => { - const response = await service.get('index/footerdata') + const response = await service.get('/api/index/footerdata') return response.data } \ No newline at end of file diff --git a/frontend/src/router/index.ts b/frontend/src/router/index.ts index 4dceab5..462b5fd 100644 --- a/frontend/src/router/index.ts +++ b/frontend/src/router/index.ts @@ -1,52 +1,41 @@ -import { createRouter, createWebHistory } from 'vue-router'; -import { constantRoute, registerDynamicRoutes } from './routes'; +import { createRouter, createWebHistory } from 'vue-router' +import { getHeadMenu } from '@/api/index' +import { constantRoute, registerDynamicRoutes } from './routes' -// 先创建路由，但不立即匹配 const router = createRouter({ history: createWebHistory(), routes: constantRoute, - // 延迟路由匹配，等待动态路由注册完成 strict: false, -}); +}) -// 在应用启动时加载菜单并注册路由 -let routesLoaded = false; -let routesLoadingPromise: Promise | null = null; +let routesLoaded = false +let routesLoadingPromise: Promise | null = null +// 固定路由先可用，再尝试加载后台菜单补充自定义页面。 export async function loadAndRegisterRoutes() { - // 如果已经加载过，直接返回 - if (routesLoaded) { - return; - } + if (routesLoaded) return + if (routesLoadingPromise) return routesLoadingPromise - // 如果正在加载，等待加载完成 - if (routesLoadingPromise) { - return routesLoadingPromise; - } + routesLoadingPromise = getHeadMenu() + .then((response) => { + if (response?.code === 200 && Array.isArray(response.data)) { + registerDynamicRoutes(router, response.data) + } + }) + .catch((error) => { + // 后台菜单不可用时不影响固定文章路由和官网页面。 + console.error('加载前端菜单失败:', error) + }) + .finally(() => { + routesLoaded = true + }) - return routesLoadingPromise; + return routesLoadingPromise } -// 路由守卫：确保路由已加载 -router.beforeEach(async (to, _from, next) => { - // 如果路由还未加载，先加载路由 - if (!routesLoaded) { - - // 等待路由加载完成 - await routesLoadingPromise; - - // 路由加载完成后，如果当前路径不匹配，尝试重新匹配 - const matched = router.resolve(to.path).matched; - if (matched.length === 0 && to.path !== '/404') { - // 路由已加载但当前路径不匹配，可能是通配符路由 - // 继续导航，让通配符路由处理 - next(); - return; - } - } +router.beforeEach(async (_to, _from, next) => { + await loadAndRegisterRoutes() + next() +}) - // 路由已加载，继续导航 - next(); -}); - -export default router; \ No newline at end of file +export default router diff --git a/frontend/src/router/routes.ts b/frontend/src/router/routes.ts index 6efa39a..7199ded 100644 --- a/frontend/src/router/routes.ts +++ b/frontend/src/router/routes.ts @@ -1,124 +1,119 @@ import { createComponentLoader } from '@/utils/pathResolver' -// 对外暴漏配置路由，常量路由 +// 对外暴露配置路由。核心业务路由必须固定存在，不依赖后台菜单配置。 export const constantRoute = [ - { - path: '/', - component: () => import('@/views/home/index.vue'), - name: '首页', - meta: { - title: '首页', - hidden: false, - }, - }, - { - path: '/404', - component: () => import('@/views/404/index.vue'), - name: '404', - meta: { - title: '404', - hidden: true, - icon: 'DocumentDelete', - }, - }, - ] + { + path: '/', + component: () => import('@/views/home/index.vue'), + name: '首页', + meta: { title: '首页', hidden: false }, + }, + { + path: '/solution', + component: () => import('@/views/solution/index.vue'), + name: '解决方案', + meta: { title: '解决方案', hidden: false }, + }, + { + path: '/solution/solution', + component: () => import('@/views/solutions/solution/index.vue'), + name: '行业解决方案', + meta: { title: '行业解决方案', hidden: true }, + }, + { + path: '/solution/successCases', + component: () => import('@/views/solutions/successCases/index.vue'), + name: '成功案例', + meta: { title: '成功案例', hidden: true }, + }, + { + path: '/newsCenter', + component: () => import('@/views/newsCenter/news/index.vue'), + name: '新闻中心', + meta: { title: '新闻中心', hidden: false }, + }, + { + path: '/newsCenter/news', + component: () => import('@/views/newsCenter/news/index.vue'), + name: '站点新闻', + meta: { title: '站点新闻', hidden: true }, + }, + { + path: '/newsCenter/announcement', + component: () => import('@/views/newsCenter/announcement/index.vue'), + name: '站点公告', + meta: { title: '站点公告', hidden: true }, + }, + { + path: '/newsCenter/technologyCenter', + component: () => import('@/views/newsCenter/technologyCenter/index.vue'), + name: '技术中心', + meta: { title: '技术中心', hidden: true }, + }, + // 文章详情路由固定注册，文章发布后无需先在前台菜单中配置路由。 + { + path: '/newsCenter/companyNews/detail/:id', + component: () => import('@/views/components/articleDetail.vue'), + name: '公司新闻详情', + meta: { title: '公司新闻详情', hidden: true }, + }, + { + path: '/newsCenter/kingdeeNews/detail/:id', + component: () => import('@/views/components/articleDetail.vue'), + name: '金蝶新闻详情', + meta: { title: '金蝶新闻详情', hidden: true }, + }, + { + path: '/404', + component: () => import('@/views/404/index.vue'), + name: '404', + meta: { title: '404', hidden: true, icon: 'DocumentDelete' }, + }, + { + path: '/:pathMatch(.*)*', + component: () => import('@/views/onepage/index.vue'), + name: 'OnePage', + meta: { title: '单页', hidden: true }, + }, +] -// 动态路由注册函数 +// 动态路由注册函数：后台菜单只负责补充自定义页面，不覆盖固定业务路由。 export function registerDynamicRoutes(router: any, menus: any[]) { if (!menus || menus.length === 0) return - // 统一处理菜单路径大小写 - const normalizeMenuPaths = (menus: any[]) => { - return menus.map(menu => { - const normalizedMenu = { ...menu } - // 将路径中的 /newscenter/ 替换为 /newsCenter/ - if (normalizedMenu.path) { - normalizedMenu.path = normalizedMenu.path.replace(/\/newscenter\//g, '/newsCenter/') - } - // 递归处理子菜单 - if (normalizedMenu.children && normalizedMenu.children.length > 0) { - normalizedMenu.children = normalizeMenuPaths(normalizedMenu.children) - } - return normalizedMenu - }) - } + const normalizeMenuPaths = (items: any[]): any[] => items.map((menu) => ({ + ...menu, + path: menu.path?.replace(/\/newscenter\//g, '/newsCenter/'), + children: menu.children?.length ? normalizeMenuPaths(menu.children) : menu.children, + })) - // 先规范化菜单路径 - const normalizedMenus = normalizeMenuPaths(menus) - - // 收集所有需要注册的路由 const routesToAdd: any[] = [] - - // 递归处理菜单，收集路由 const processMenu = (menu: any) => { - // type 2: 页面 - 根据 component_path 加载组件 if (menu.type === 2 && menu.path && menu.component_path) { const path = menu.path - // 检查路由是否已存在 - const existingRoute = router.getRoutes().find((r: any) => r.path === path) - if (!existingRoute) { - try { - // 使用 pathResolver 来解析 component_path - // component_path 可能的格式： - // 1. /views/newsCenter/companyNews/index.vue - // 2. views/newsCenter/companyNews/index.vue - // 3. newsCenter/companyNews/index.vue - const componentLoader = createComponentLoader(menu.component_path) - - if (!componentLoader) { - console.error(`Failed to create component loader for: ${menu.component_path}`) - return - } - - routesToAdd.push({ - path: path, - name: `menu_${menu.id}`, - component: componentLoader, - meta: { - title: menu.title, - menuId: menu.id, - menuType: menu.type, - }, - }) - } catch (error) { - console.error(`Failed to prepare route for path ${path}, component_path: ${menu.component_path}`, error) - } + if (!router.getRoutes().some((route: any) => route.path === path)) { + routesToAdd.push({ + path, + name: `menu_${menu.id}`, + component: createComponentLoader(menu.component_path), + meta: { title: menu.title, menuId: menu.id, menuType: menu.type }, + }) } } - // type 4: 单页 - 使用通配符路由处理，不需要单独注册 - - // 递归处理子菜单 - if (menu.children && menu.children.length > 0) { - menu.children.forEach((child: any) => processMenu(child)) - } + menu.children?.forEach(processMenu) } - // 处理所有菜单 - normalizedMenus.forEach((menu) => processMenu(menu)) + normalizeMenuPaths(menus).forEach(processMenu) - // 先移除通配符路由（如果存在），以便重新添加 - const catchAllRoute = router.getRoutes().find((r: any) => r.path === '/:pathMatch(.*)*') - if (catchAllRoute) { - router.removeRoute('OnePage') - } + // 通配符路由必须最后注册，否则会抢先匹配后台新增的自定义页面。 + const catchAll = router.getRoutes().find((route: any) => route.name === 'OnePage') + if (catchAll) router.removeRoute('OnePage') - // 注册 type 2 的路由（必须在通配符路由之前） - routesToAdd.forEach((route) => { - router.addRoute(route) + routesToAdd.forEach((route) => router.addRoute(route)) + router.addRoute({ + path: '/:pathMatch(.*)*', + component: () => import('@/views/onepage/index.vue'), + name: 'OnePage', + meta: { title: '单页', hidden: true }, }) - - // 最后添加通配符路由（用于单页和其他未匹配的路径） - const catchAllExists = router.getRoutes().find((r: any) => r.path === '/:pathMatch(.*)*') - if (!catchAllExists) { - router.addRoute({ - path: '/:pathMatch(.*)*', - component: () => import('@/views/onepage/index.vue'), - name: 'OnePage', - meta: { - title: '单页', - hidden: true, - }, - }) - } } - \ No newline at end of file diff --git a/frontend/src/utils/request.ts b/frontend/src/utils/request.ts index c362bf5..b612182 100644 --- a/frontend/src/utils/request.ts +++ b/frontend/src/utils/request.ts @@ -2,13 +2,17 @@ import axios from 'axios' // 创建axios实例 const service = axios.create({ - baseURL: import.meta.env.VITE_API_BASE_URL, + baseURL: '/', timeout: 10000, }) // 请求拦截器 service.interceptors.request.use( (config) => { + const devTenantId = sessionStorage.getItem('dev_tenant_id') + if (devTenantId) { + config.headers['X-Tenant-ID'] = encodeURIComponent(devTenantId) + } return config }, (error) => { @@ -16,10 +20,10 @@ service.interceptors.request.use( } ) -// 响应拦截器 - 返回 response.data +// 响应拦截器 - 保留完整 axios 响应，由 api 层统一取 response.data（即 {code, data, msg}） service.interceptors.response.use( (response) => { - return response.data + return response }, (error) => { console.error('API请求错误:', error) diff --git a/frontend/src/views/components/header.vue b/frontend/src/views/components/header.vue index 3c1afd3..35e591a 100644 --- a/frontend/src/views/components/header.vue +++ b/frontend/src/views/components/header.vue @@ -301,12 +301,36 @@
+ +
+ +
中文
+ +
+
+

切换测试租户

+
+ + +
+ +
+
+
([]) -// 统一处理菜单路径大小写 +// 统一处理菜单路径大小写，并递归处理子菜单。 const normalizeMenuPaths = (menus: MenuItem[]): MenuItem[] => { - return menus.map((menu: MenuItem) => { - const normalizedMenu = { ...menu } - // 将路径中的 /newscenter/ 替换为 /newsCenter/ - if (normalizedMenu.path) { - normalizedMenu.path = normalizedMenu.path.replace(/\/newscenter\//g, '/newsCenter/') - } - // 递归处理子菜单 - if (normalizedMenu.children && normalizedMenu.children.length > 0) { - normalizedMenu.children = normalizeMenuPaths(normalizedMenu.children) - } - return normalizedMenu - }) + return menus.map((menu) => ({ + ...menu, + path: menu.path?.replace(/\/newscenter\//g, '/newsCenter/'), + children: menu.children?.length ? normalizeMenuPaths(menu.children) : menu.children, + })) +} + +// 后台菜单可配置，但文章中心是官网核心功能，必须始终存在。 +const fixedNewsMenu: MenuChild = { + id: -101, + title: '新闻中心', + path: '/newsCenter/news', + type: 2, +} + +const fixedArticleMenu: MenuItem = { + id: -100, + title: '文章中心', + path: '/newsCenter', + type: 1, + children: [fixedNewsMenu], +} + +const mergeMenuItems = (menus: MenuItem[]): MenuItem[] => { + const normalizedMenus = normalizeMenuPaths(menus) + const articleMenu = normalizedMenus.find( + (menu) => menu.path === fixedArticleMenu.path || menu.title === fixedArticleMenu.title, + ) + if (!articleMenu) return [fixedArticleMenu, ...normalizedMenus] + + const hasNewsCenter = articleMenu.children?.some( + (child) => child.path === '/newsCenter/news' || child.title === '新闻中心', + ) + if (!hasNewsCenter) { + articleMenu.children = [ + ...(articleMenu.children || []), + fixedNewsMenu, + ] + } + return normalizedMenus } // 加载菜单数据 const loadMenu = async () => { try { const response = await getHeadMenu() - if (response.code === 200) { - menuItems.value = normalizeMenuPaths(response.data) + if (response.code === 200 && Array.isArray(response.data)) { + menuItems.value = mergeMenuItems(response.data) + return } } catch (error) { console.error('加载菜单失败:', error) - menuItems.value = [] } + menuItems.value = [fixedArticleMenu] } // 拼接接口地址（用于 logo 等静态资源） @@ -436,9 +489,18 @@ const activeMenu = ref(null) const activeCategory = ref(0) const showSearch = ref(false) const showLanguage = ref(false) +const showTenantModal = ref(false) +const devTenantId = ref(sessionStorage.getItem('dev_tenant_id') || '') +const isDev = import.meta.env.DEV const searchQuery = ref('') const currentLanguage = ref('zh') const isScrolled = ref(false) + +const saveTenant = () => { + sessionStorage.setItem('dev_tenant_id', devTenantId.value) + showTenantModal.value = false + window.location.reload() +} const footerData = ref(null) let closeTimer: ReturnType | null = null @@ -834,6 +896,8 @@ onUnmounted(() => { border: 1px solid #ddd; border-radius: 4px; font-size: 16px; + color: #333; /* 显式设置字体颜色为深色 */ + background-color: #fff; /* 显式设置背景为白色 */ transition: border-color 0.3s ease; &:focus { diff --git a/frontend/src/views/newsCenter/news/index.vue b/frontend/src/views/newsCenter/news/index.vue index 1d922e0..96dd514 100644 --- a/frontend/src/views/newsCenter/news/index.vue +++ b/frontend/src/views/newsCenter/news/index.vue @@ -188,7 +188,7 @@ const formatDate = (date: string) => { } const goToDetail = (id: number) => { - router.push(`/newscenter/companyNews/detail/${id}`) + router.push(`/newsCenter/companyNews/detail/${id}`) } // 加载更多数据 diff --git a/frontend/vite.config.ts b/frontend/vite.config.ts index 73f45fa..d84ff01 100644 --- a/frontend/vite.config.ts +++ b/frontend/vite.config.ts @@ -61,6 +61,10 @@ export default defineConfig(({ mode }: ConfigEnv): UserConfig => { target: env.VITE_API_BASE_URL, // 后端 API 服务器地址 changeOrigin: true, rewrite: (path) => path.replace(/^\/api/, '') + }, + '/index': { + target: env.VITE_API_BASE_URL, + changeOrigin: true } }, // 配置静态资源服务 @@ -91,4 +95,4 @@ export default defineConfig(({ mode }: ConfigEnv): UserConfig => { exclude: [] } } -}) +}) \ No newline at end of file diff --git a/go/controllers/backend_article.go b/go/controllers/backend_article.go index e50b448..ee89cb4 100644 --- a/go/controllers/backend_article.go +++ b/go/controllers/backend_article.go @@ -1,1037 +1,1087 @@ -package controllers - -import ( - "encoding/json" - "fmt" - "io" - "sort" - "strconv" - "strings" - "time" - - "server/models" - "server/pkg/jwtutil" - - "github.com/beego/beego/v2/client/orm" - beego "github.com/beego/beego/v2/server/web" -) - -// BackendArticleController CMS 文章管理 -type BackendArticleController struct { - beego.Controller -} - -// BackendArticleCategoryController CMS 文章分类管理 -type BackendArticleCategoryController struct { - beego.Controller -} - -func (c *BackendArticleController) cmsClaims() (*jwtutil.Claims, error) { - return cmsBackendClaims(&c.Controller) -} - -func (c *BackendArticleCategoryController) cmsClaims() (*jwtutil.Claims, error) { - return cmsBackendClaims(&c.Controller) -} - -func cmsBackendClaims(c *beego.Controller) (*jwtutil.Claims, error) { - auth := c.Ctx.Request.Header.Get("Authorization") - if auth == "" { - return nil, fmt.Errorf("未登录") - } - parts := strings.SplitN(auth, " ", 2) - if len(parts) != 2 || parts[0] != "Bearer" { - return nil, fmt.Errorf("认证信息格式错误") - } - claims, err := jwtutil.ParseToken(parts[1]) - if err != nil { - return nil, fmt.Errorf("无效的token") - } - if claims.UserType != "backend" { - return nil, fmt.Errorf("无权访问") - } - return claims, nil -} - -func cmsEffectiveTid(c *beego.Controller, claims *jwtutil.Claims) uint64 { - _ = c.ParseForm(1 << 20) - if tid, err := c.GetUint64("tid"); err == nil && tid > 0 { - return tid - } - if h := strings.TrimSpace(c.Ctx.Request.Header.Get("X-Tenant-Id")); h != "" { - if v, e := strconv.ParseUint(h, 10, 64); e == nil { - return v - } - } - if claims != nil && claims.TenantId > 0 { - return uint64(claims.TenantId) - } - return 0 -} - -func (c *BackendArticleController) cmsJSONErr(httpStatus, bizCode int, msg string) { - c.Ctx.Output.SetStatus(httpStatus) - c.Data["json"] = map[string]interface{}{"code": bizCode, "msg": msg} - _ = c.ServeJSON() -} - -func (c *BackendArticleCategoryController) cmsJSONErr(httpStatus, bizCode int, msg string) { - c.Ctx.Output.SetStatus(httpStatus) - c.Data["json"] = map[string]interface{}{"code": bizCode, "msg": msg} - _ = c.ServeJSON() -} - -func cmsEnsureTables(c *beego.Controller) bool { - if err := models.EnsureCmsArticleTables(); err != nil { - c.Ctx.Output.SetStatus(500) - c.Data["json"] = map[string]interface{}{"code": 500, "msg": "初始化文章表失败: " + err.Error()} - _ = c.ServeJSON() - return false - } - return true -} - -func cmsParseUintArg(v interface{}) uint64 { - switch x := v.(type) { - case float64: - if x > 0 { - return uint64(x) - } - case string: - if n, err := strconv.ParseUint(strings.TrimSpace(x), 10, 64); err == nil { - return n - } - } - return 0 -} - -func cmsArticleToListItem(row models.CmsArticle, cateName string) map[string]interface{} { - return map[string]interface{}{ - "id": row.ID, - "title": row.Title, - "author": row.Author, - "cate": cateName, - "cate_id": row.CateID, - "status": row.Status, - "views": row.Views, - "likes": row.Likes, - "top": row.Top, - "recommend": row.Recommend, - "publish_date": models.CmsFormatTime(row.PublishTime), - "update_time": models.CmsFormatTime(row.UpdateTime), - } -} - -func cmsArticleToDetail(row models.CmsArticle, cateName string) map[string]interface{} { - pub := models.CmsFormatTime(row.PublishTime) - return map[string]interface{}{ - "id": row.ID, - "title": row.Title, - "author": row.Author, - "cate": cateName, - "cate_id": row.CateID, - "content": row.Content, - "desc": row.Desc, - "image": row.Image, - "is_trans": row.IsTrans, - "transurl": row.TransURL, - "status": row.Status, - "views": row.Views, - "view_count": row.Views, - "likes": row.Likes, - "top": row.Top, - "recommend": row.Recommend, - "publish_time": pub, - "publish_date": pub, - "create_time": row.CreateTime.Format("2006-01-02 15:04:05"), - "update_time": models.CmsFormatTime(row.UpdateTime), - } -} - -func cmsCategoryToMap(row models.CmsArticleCategory) map[string]interface{} { - return map[string]interface{}{ - "id": row.ID, - "name": row.Name, - "label": row.Name, - "cid": row.Cid, - "parentId": row.Cid, - "image": row.Image, - "desc": row.Desc, - "remark": row.Desc, - "sort": row.Sort, - "status": row.Status, - } -} - - // ContentStats GET /backend/contentstats -func (c *BackendArticleController) ContentStats() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - // 统计已发布且未删除的文章，避免把草稿、下架文章计入内容数据。 - var rows []models.CmsArticle - _, err = models.Orm.QueryTable(new(models.CmsArticle)). - Filter("tid", tid). - Filter("status", 2). - Filter("delete_time__isnull", true). - All(&rows) - if err != nil && err != orm.ErrNoRows { - c.cmsJSONErr(500, 500, "获取内容统计失败") - return - } - - totalArticles := len(rows) - now := time.Now() - year, month, _ := now.Date() - totalLikes := 0 - totalViews := 0 - monthArticles := 0 - for _, row := range rows { - totalLikes += row.Likes - totalViews += row.Views - if row.PublishTime != nil { - publishYear, publishMonth, _ := row.PublishTime.Date() - if publishYear == year && publishMonth == month { - monthArticles++ - } - } - } - - // 按阅读量倒序返回热门文章。 - sort.SliceStable(rows, func(i, j int) bool { - if rows[i].Views == rows[j].Views { - return rows[i].ID > rows[j].ID - } - return rows[i].Views > rows[j].Views - }) - if len(rows) > 5 { - rows = rows[:5] - } - - cateIDs := make([]uint64, 0, len(rows)) - for _, row := range rows { - if row.CateID > 0 { - cateIDs = append(cateIDs, row.CateID) - } - } - cateNames := models.CmsCategoryNameMap(tid, cateIDs) - hotArticles := make([]map[string]interface{}, 0, len(rows)) - for _, row := range rows { - hotArticles = append(hotArticles, cmsArticleToListItem(row, cateNames[row.CateID])) - } - - c.Data["json"] = map[string]interface{}{ - "code": 200, - "msg": "success", - "data": map[string]interface{}{ - "total_articles": totalArticles, - "month_articles": monthArticles, - "total_likes": totalLikes, - "total_views": totalViews, - "hot_articles": hotArticles, - }, - } - _ = c.ServeJSON() -} - -// List GET /backend/articlesList -func (c *BackendArticleController) List() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - page, _ := c.GetInt("page", 1) - pageSize, _ := c.GetInt("pageSize", 10) - if page < 1 { - page = 1 - } - if pageSize < 1 { - pageSize = 10 - } - if pageSize > 200 { - pageSize = 200 - } - - keyword := strings.TrimSpace(c.GetString("keyword")) - cateFilter := strings.TrimSpace(c.GetString("cate")) - - qs := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("tid", tid). - Filter("delete_time__isnull", true) - if keyword != "" { - qs = qs.Filter("title__icontains", keyword) - } - if cateFilter != "" { - if cid, err := strconv.ParseUint(cateFilter, 10, 64); err == nil && cid > 0 { - qs = qs.Filter("cate_id", cid) - } - } - - total, _ := qs.Count() - var rows []models.CmsArticle - offset := (page - 1) * pageSize - _, err = qs.OrderBy("-top", "-id").Limit(pageSize, offset).All(&rows) - if err != nil && err != orm.ErrNoRows { - c.cmsJSONErr(500, 500, "获取文章列表失败") - return - } - - cateIDs := make([]uint64, 0, len(rows)) - for _, r := range rows { - if r.CateID > 0 { - cateIDs = append(cateIDs, r.CateID) - } - } - cateNames := models.CmsCategoryNameMap(tid, cateIDs) - - list := make([]map[string]interface{}, 0, len(rows)) - for _, r := range rows { - list = append(list, cmsArticleToListItem(r, cateNames[r.CateID])) - } - - c.Data["json"] = map[string]interface{}{ - "code": 200, - "msg": "success", - "data": map[string]interface{}{"list": list, "total": total}, - } - _ = c.ServeJSON() -} - -// ListAll GET /backend/allarticles -func (c *BackendArticleController) ListAll() { - c.List() -} - -// Detail GET /backend/articles/:id -func (c *BackendArticleController) Detail() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - var row models.CmsArticle - err = models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - One(&row) - if err == orm.ErrNoRows { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - if err != nil { - c.cmsJSONErr(500, 500, "查询失败") - return - } - - cateName := "" - if row.CateID > 0 { - names := models.CmsCategoryNameMap(tid, []uint64{row.CateID}) - cateName = names[row.CateID] - } - - c.Data["json"] = map[string]interface{}{ - "code": 200, - "msg": "success", - "data": cmsArticleToDetail(row, cateName), - } - _ = c.ServeJSON() -} - -type cmsArticlePayload struct { - Title string `json:"title"` - Author string `json:"author"` - Cate interface{} `json:"cate"` - Content string `json:"content"` - Desc string `json:"desc"` - Image string `json:"image"` - IsTrans int8 `json:"is_trans"` - TransURL *string `json:"transurl"` - Status int8 `json:"status"` - IgnoreSimilarity int `json:"ignore_similarity"` -} - -// Create POST /backend/createarticle -func (c *BackendArticleController) Create() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - raw, err := io.ReadAll(c.Ctx.Request.Body) - if err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - var p cmsArticlePayload - if err := json.Unmarshal(raw, &p); err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - title := strings.TrimSpace(p.Title) - if title == "" { - c.cmsJSONErr(400, 400, "标题不能为空") - return - } - - if p.IgnoreSimilarity != 1 { - similar, serr := models.CmsSimilarArticles(tid, title, 5) - if serr == nil && len(similar) > 0 { - c.Ctx.Output.SetStatus(409) - c.Data["json"] = map[string]interface{}{ - "code": 409, - "msg": "检测到相似标题", - "data": map[string]interface{}{"similar_articles": similar}, - } - _ = c.ServeJSON() - return - } - } - - now := time.Now() - cateID := cmsParseUintArg(p.Cate) - row := models.CmsArticle{ - Tid: tid, - Title: title, - Author: strings.TrimSpace(p.Author), - CateID: cateID, - Content: p.Content, - Desc: strings.TrimSpace(p.Desc), - Image: strings.TrimSpace(p.Image), - IsTrans: p.IsTrans, - TransURL: p.TransURL, - Status: p.Status, - CreateTime: now, - UpdateTime: &now, - } - id, err := models.Orm.Insert(&row) - if err != nil { - c.cmsJSONErr(500, 500, "创建失败") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "创建成功", "data": map[string]interface{}{"id": id}} - _ = c.ServeJSON() -} - -// Update POST /backend/editarticle/:id -func (c *BackendArticleController) Update() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - raw, err := io.ReadAll(c.Ctx.Request.Body) - if err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - var p cmsArticlePayload - if err := json.Unmarshal(raw, &p); err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - - now := time.Now() - fields := map[string]interface{}{ - "title": strings.TrimSpace(p.Title), - "author": strings.TrimSpace(p.Author), - "cate_id": cmsParseUintArg(p.Cate), - "content": p.Content, - "desc": strings.TrimSpace(p.Desc), - "image": strings.TrimSpace(p.Image), - "is_trans": p.IsTrans, - "transurl": p.TransURL, - "status": p.Status, - "update_time": now, - } - n, err := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(fields) - if err != nil { - c.cmsJSONErr(500, 500, "更新失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} - _ = c.ServeJSON() -} - -// Delete DELETE /backend/deletearticle/:id -func (c *BackendArticleController) Delete() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - now := time.Now() - n, err := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(map[string]interface{}{"delete_time": now, "update_time": now}) - if err != nil { - c.cmsJSONErr(500, 500, "删除失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "删除成功"} - _ = c.ServeJSON() -} - -func (c *BackendArticleController) setArticleFlag(field string, value int8) { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - now := time.Now() - fields := map[string]interface{}{field: value, "update_time": now} - n, err := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(fields) - if err != nil { - c.cmsJSONErr(500, 500, "操作失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success"} - _ = c.ServeJSON() -} - -func (c *BackendArticleController) Publish() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - var uid uint64 - raw, _ := io.ReadAll(c.Ctx.Request.Body) - if len(raw) > 0 { - var body struct { - UID uint64 `json:"uid"` - } - _ = json.Unmarshal(raw, &body) - uid = body.UID - } - if uid == 0 && claims != nil { - uid = uint64(claims.UserID) - } - - now := time.Now() - fields := map[string]interface{}{ - "status": int8(2), - "publish_time": now, - "publisher_id": uid, - "update_time": now, - } - n, err := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(fields) - if err != nil { - c.cmsJSONErr(500, 500, "发布失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "发布成功"} - _ = c.ServeJSON() -} - -func (c *BackendArticleController) Unpublish() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - now := time.Now() - n, err := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(map[string]interface{}{"status": int8(3), "update_time": now}) - if err != nil { - c.cmsJSONErr(500, 500, "下架失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "文章不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "下架成功"} - _ = c.ServeJSON() -} - -func (c *BackendArticleController) Recommend() { c.setArticleFlag("recommend", 1) } -func (c *BackendArticleController) Unrecommend() { c.setArticleFlag("recommend", 0) } -func (c *BackendArticleController) Top() { c.setArticleFlag("top", 1) } -func (c *BackendArticleController) Untop() { c.setArticleFlag("top", 0) } - -// List GET /backend/categories -func (c *BackendArticleCategoryController) List() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - page, _ := c.GetInt("page", 1) - pageSize, _ := c.GetInt("pageSize", 0) - if pageSize == 0 { - pageSize, _ = c.GetInt("limit", 1000) - } - if page < 1 { - page = 1 - } - if pageSize < 1 { - pageSize = 1000 - } - - keyword := strings.TrimSpace(c.GetString("keyword")) - qs := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("tid", tid). - Filter("delete_time__isnull", true) - if keyword != "" { - qs = qs.Filter("name__icontains", keyword) - } - - total, _ := qs.Count() - var rows []models.CmsArticleCategory - offset := (page - 1) * pageSize - _, err = qs.OrderBy("sort", "id").Limit(pageSize, offset).All(&rows) - if err != nil && err != orm.ErrNoRows { - c.cmsJSONErr(500, 500, "获取分类失败") - return - } - - list := make([]map[string]interface{}, 0, len(rows)) - for _, r := range rows { - list = append(list, cmsCategoryToMap(r)) - } - - c.Data["json"] = map[string]interface{}{ - "code": 200, - "msg": "success", - "data": map[string]interface{}{"list": list, "total": total, "records": list}, - } - _ = c.ServeJSON() -} - -// ListAll GET /backend/allcategories -func (c *BackendArticleCategoryController) ListAll() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - keyword := strings.TrimSpace(c.GetString("keyword")) - qs := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("tid", tid). - Filter("delete_time__isnull", true) - if keyword != "" { - qs = qs.Filter("name__icontains", keyword) - } - - var rows []models.CmsArticleCategory - _, err = qs.OrderBy("sort", "id").All(&rows) - if err != nil && err != orm.ErrNoRows { - c.cmsJSONErr(500, 500, "获取分类失败") - return - } - - list := make([]map[string]interface{}, 0, len(rows)) - for _, r := range rows { - list = append(list, cmsCategoryToMap(r)) - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": list} - _ = c.ServeJSON() -} - -// Detail GET /backend/categories/:id -func (c *BackendArticleCategoryController) Detail() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - var row models.CmsArticleCategory - err = models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - One(&row) - if err == orm.ErrNoRows { - c.cmsJSONErr(404, 404, "分类不存在") - return - } - if err != nil { - c.cmsJSONErr(500, 500, "查询失败") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": cmsCategoryToMap(row)} - _ = c.ServeJSON() -} - -type cmsCategoryPayload struct { - Name string `json:"name"` - Image string `json:"image"` - Desc string `json:"desc"` - Sort int `json:"sort"` - Status int8 `json:"status"` - Cid uint64 `json:"cid"` -} - -// Create POST /backend/createCategory -func (c *BackendArticleCategoryController) Create() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - if tid == 0 { - c.cmsJSONErr(400, 400, "tid不能为空") - return - } - - raw, err := io.ReadAll(c.Ctx.Request.Body) - if err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - var p cmsCategoryPayload - if err := json.Unmarshal(raw, &p); err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - name := strings.TrimSpace(p.Name) - if name == "" { - c.cmsJSONErr(400, 400, "分类名称不能为空") - return - } - - now := time.Now() - row := models.CmsArticleCategory{ - Tid: tid, - Cid: p.Cid, - Name: name, - Image: strings.TrimSpace(p.Image), - Desc: strings.TrimSpace(p.Desc), - Sort: p.Sort, - Status: p.Status, - CreateTime: now, - UpdateTime: &now, - } - id, err := models.Orm.Insert(&row) - if err != nil { - c.cmsJSONErr(500, 500, "创建失败") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "创建成功", "data": map[string]interface{}{"id": id}} - _ = c.ServeJSON() -} - -// Update POST /backend/editCategory/:id -func (c *BackendArticleCategoryController) Update() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - raw, err := io.ReadAll(c.Ctx.Request.Body) - if err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - var p cmsCategoryPayload - if err := json.Unmarshal(raw, &p); err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - - now := time.Now() - n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(map[string]interface{}{ - "name": strings.TrimSpace(p.Name), - "image": strings.TrimSpace(p.Image), - "desc": strings.TrimSpace(p.Desc), - "sort": p.Sort, - "status": p.Status, - "cid": p.Cid, - "update_time": now, - }) - if err != nil { - c.cmsJSONErr(500, 500, "更新失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "分类不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} - _ = c.ServeJSON() -} - -// Delete DELETE /backend/categories/:id -func (c *BackendArticleCategoryController) Delete() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - childCnt, _ := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("tid", tid). - Filter("cid", id). - Filter("delete_time__isnull", true). - Count() - if childCnt > 0 { - c.cmsJSONErr(400, 400, "请先删除子分类") - return - } - - articleCnt, _ := models.Orm.QueryTable(new(models.CmsArticle)). - Filter("tid", tid). - Filter("cate_id", id). - Filter("delete_time__isnull", true). - Count() - if articleCnt > 0 { - c.cmsJSONErr(400, 400, "该分类下还有文章，无法删除") - return - } - - now := time.Now() - n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(map[string]interface{}{"delete_time": now, "update_time": now}) - if err != nil { - c.cmsJSONErr(500, 500, "删除失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "分类不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "删除成功"} - _ = c.ServeJSON() -} - -// UpdateStatus PATCH /backend/categories/:id/status -func (c *BackendArticleCategoryController) UpdateStatus() { - if !cmsEnsureTables(&c.Controller) { - return - } - claims, err := c.cmsClaims() - if err != nil { - c.cmsJSONErr(401, 401, err.Error()) - return - } - tid := cmsEffectiveTid(&c.Controller, claims) - id, _ := c.GetUint64(":id") - if id == 0 { - c.cmsJSONErr(400, 400, "无效ID") - return - } - - raw, err := io.ReadAll(c.Ctx.Request.Body) - if err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - var p struct { - Status int8 `json:"status"` - } - if err := json.Unmarshal(raw, &p); err != nil { - c.cmsJSONErr(400, 400, "参数错误") - return - } - - now := time.Now() - n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). - Filter("id", id). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Update(map[string]interface{}{"status": p.Status, "update_time": now}) - if err != nil { - c.cmsJSONErr(500, 500, "更新失败") - return - } - if n == 0 { - c.cmsJSONErr(404, 404, "分类不存在") - return - } - - c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} - _ = c.ServeJSON() -} +package controllers + +import ( + "encoding/json" + "fmt" + "io" + "sort" + "strconv" + "strings" + "time" + + "server/models" + "server/pkg/jwtutil" + + "github.com/beego/beego/v2/client/orm" + beego "github.com/beego/beego/v2/server/web" +) + +// BackendArticleController CMS 文章管理 +type BackendArticleController struct { + beego.Controller +} + +// BackendArticleCategoryController CMS 文章分类管理 +type BackendArticleCategoryController struct { + beego.Controller +} + +func (c *BackendArticleController) cmsClaims() (*jwtutil.Claims, error) { + return cmsBackendClaims(&c.Controller) +} + +func (c *BackendArticleCategoryController) cmsClaims() (*jwtutil.Claims, error) { + return cmsBackendClaims(&c.Controller) +} + +func cmsBackendClaims(c *beego.Controller) (*jwtutil.Claims, error) { + auth := c.Ctx.Request.Header.Get("Authorization") + if auth == "" { + return nil, fmt.Errorf("未登录") + } + parts := strings.SplitN(auth, " ", 2) + if len(parts) != 2 || parts[0] != "Bearer" { + return nil, fmt.Errorf("认证信息格式错误") + } + claims, err := jwtutil.ParseToken(parts[1]) + if err != nil { + return nil, fmt.Errorf("无效的token") + } + if claims.UserType != "backend" { + return nil, fmt.Errorf("无权访问") + } + return claims, nil +} + +func cmsEffectiveTid(c *beego.Controller, claims *jwtutil.Claims) uint64 { + _ = c.ParseForm(1 << 20) + if tid, err := c.GetUint64("tid"); err == nil && tid > 0 { + return tid + } + if h := strings.TrimSpace(c.Ctx.Request.Header.Get("X-Tenant-Id")); h != "" { + if v, e := strconv.ParseUint(h, 10, 64); e == nil { + return v + } + } + if claims != nil && claims.TenantId > 0 { + return uint64(claims.TenantId) + } + return 0 +} + +func (c *BackendArticleController) cmsJSONErr(httpStatus, bizCode int, msg string) { + c.Ctx.Output.SetStatus(httpStatus) + c.Data["json"] = map[string]interface{}{"code": bizCode, "msg": msg} + _ = c.ServeJSON() +} + +func (c *BackendArticleCategoryController) cmsJSONErr(httpStatus, bizCode int, msg string) { + c.Ctx.Output.SetStatus(httpStatus) + c.Data["json"] = map[string]interface{}{"code": bizCode, "msg": msg} + _ = c.ServeJSON() +} + +func cmsEnsureTables(c *beego.Controller) bool { + if err := models.EnsureCmsArticleTables(); err != nil { + c.Ctx.Output.SetStatus(500) + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "初始化文章表失败: " + err.Error()} + _ = c.ServeJSON() + return false + } + if err := models.EnsureCmsArticleDefaultCategories(); err != nil { + c.Ctx.Output.SetStatus(500) + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "初始化文章分类失败: " + err.Error()} + _ = c.ServeJSON() + return false + } + return true +} + +func cmsPortalTid(c *beego.Controller) uint64 { + if tid, err := c.GetUint64("tid"); err == nil && tid > 0 { + return tid + } + if h := strings.TrimSpace(c.Ctx.Request.Header.Get("X-Tenant-Id")); h != "" { + if tid, err := strconv.ParseUint(h, 10, 64); err == nil { + return tid + } + } + return 1 +} + +func cmsParseUintArg(v interface{}) uint64 { + switch x := v.(type) { + case float64: + if x > 0 { + return uint64(x) + } + case string: + if n, err := strconv.ParseUint(strings.TrimSpace(x), 10, 64); err == nil { + return n + } + } + return 0 +} + +func cmsArticleToListItem(row models.CmsArticle, cateName string) map[string]interface{} { + return map[string]interface{}{ + "id": row.ID, + "title": row.Title, + "author": row.Author, + "cate": cateName, + "cate_id": row.CateID, + "status": row.Status, + "views": row.Views, + "likes": row.Likes, + "top": row.Top, + "recommend": row.Recommend, + "publish_date": models.CmsFormatTime(row.PublishTime), + "update_time": models.CmsFormatTime(row.UpdateTime), + } +} + +func cmsArticleToDetail(row models.CmsArticle, cateName string) map[string]interface{} { + pub := models.CmsFormatTime(row.PublishTime) + return map[string]interface{}{ + "id": row.ID, + "title": row.Title, + "author": row.Author, + "cate": cateName, + "cate_id": row.CateID, + "content": row.Content, + "desc": row.Desc, + "image": row.Image, + "is_trans": row.IsTrans, + "transurl": row.TransURL, + "status": row.Status, + "views": row.Views, + "view_count": row.Views, + "likes": row.Likes, + "top": row.Top, + "recommend": row.Recommend, + "publish_time": pub, + "publish_date": pub, + "create_time": row.CreateTime.Format("2006-01-02 15:04:05"), + "update_time": models.CmsFormatTime(row.UpdateTime), + } +} + +func cmsCategoryToMap(row models.CmsArticleCategory) map[string]interface{} { + return map[string]interface{}{ + "id": row.ID, + "name": row.Name, + "label": row.Name, + "cid": row.Cid, + "parentId": row.Cid, + "tid": row.Tid, + "is_global": row.Tid == 0, + "image": row.Image, + "desc": row.Desc, + "remark": row.Desc, + "sort": row.Sort, + "status": row.Status, + } +} + +// ContentStats GET /backend/contentstats +func (c *BackendArticleController) ContentStats() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + // 统计已发布且未删除的文章，避免把草稿、下架文章计入内容数据。 + var rows []models.CmsArticle + _, err = models.Orm.QueryTable(new(models.CmsArticle)). + Filter("tid", tid). + Filter("status", 2). + Filter("delete_time__isnull", true). + All(&rows) + if err != nil && err != orm.ErrNoRows { + c.cmsJSONErr(500, 500, "获取内容统计失败") + return + } + + totalArticles := len(rows) + now := time.Now() + year, month, _ := now.Date() + totalLikes := 0 + totalViews := 0 + monthArticles := 0 + for _, row := range rows { + totalLikes += row.Likes + totalViews += row.Views + if row.PublishTime != nil { + publishYear, publishMonth, _ := row.PublishTime.Date() + if publishYear == year && publishMonth == month { + monthArticles++ + } + } + } + + // 按阅读量倒序返回热门文章。 + sort.SliceStable(rows, func(i, j int) bool { + if rows[i].Views == rows[j].Views { + return rows[i].ID > rows[j].ID + } + return rows[i].Views > rows[j].Views + }) + if len(rows) > 5 { + rows = rows[:5] + } + + cateIDs := make([]uint64, 0, len(rows)) + for _, row := range rows { + if row.CateID > 0 { + cateIDs = append(cateIDs, row.CateID) + } + } + cateNames := models.CmsCategoryNameMap(tid, cateIDs) + hotArticles := make([]map[string]interface{}, 0, len(rows)) + for _, row := range rows { + hotArticles = append(hotArticles, cmsArticleToListItem(row, cateNames[row.CateID])) + } + + c.Data["json"] = map[string]interface{}{ + "code": 200, + "msg": "success", + "data": map[string]interface{}{ + "total_articles": totalArticles, + "month_articles": monthArticles, + "total_likes": totalLikes, + "total_views": totalViews, + "hot_articles": hotArticles, + }, + } + _ = c.ServeJSON() +} + +// List GET /backend/articlesList +func (c *BackendArticleController) List() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + page, _ := c.GetInt("page", 1) + pageSize, _ := c.GetInt("pageSize", 10) + if page < 1 { + page = 1 + } + if pageSize < 1 { + pageSize = 10 + } + if pageSize > 200 { + pageSize = 200 + } + + keyword := strings.TrimSpace(c.GetString("keyword")) + cateFilter := strings.TrimSpace(c.GetString("cate")) + + qs := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("tid", tid). + Filter("delete_time__isnull", true) + if keyword != "" { + qs = qs.Filter("title__icontains", keyword) + } + if cateFilter != "" { + if cid, err := strconv.ParseUint(cateFilter, 10, 64); err == nil && cid > 0 { + qs = qs.Filter("cate_id", cid) + } + } + + total, _ := qs.Count() + var rows []models.CmsArticle + offset := (page - 1) * pageSize + _, err = qs.OrderBy("-top", "-id").Limit(pageSize, offset).All(&rows) + if err != nil && err != orm.ErrNoRows { + c.cmsJSONErr(500, 500, "获取文章列表失败") + return + } + + cateIDs := make([]uint64, 0, len(rows)) + for _, r := range rows { + if r.CateID > 0 { + cateIDs = append(cateIDs, r.CateID) + } + } + cateNames := models.CmsCategoryNameMap(tid, cateIDs) + + list := make([]map[string]interface{}, 0, len(rows)) + for _, r := range rows { + list = append(list, cmsArticleToListItem(r, cateNames[r.CateID])) + } + + c.Data["json"] = map[string]interface{}{ + "code": 200, + "msg": "success", + "data": map[string]interface{}{"list": list, "total": total}, + } + _ = c.ServeJSON() +} + +// ListAll GET /backend/allarticles +func (c *BackendArticleController) ListAll() { + c.List() +} + +// Detail GET /backend/articles/:id +func (c *BackendArticleController) Detail() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + var row models.CmsArticle + err = models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + One(&row) + if err == orm.ErrNoRows { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + if err != nil { + c.cmsJSONErr(500, 500, "查询失败") + return + } + + cateName := "" + if row.CateID > 0 { + names := models.CmsCategoryNameMap(tid, []uint64{row.CateID}) + cateName = names[row.CateID] + } + + c.Data["json"] = map[string]interface{}{ + "code": 200, + "msg": "success", + "data": cmsArticleToDetail(row, cateName), + } + _ = c.ServeJSON() +} + +type cmsArticlePayload struct { + Title string `json:"title"` + Author string `json:"author"` + Cate interface{} `json:"cate"` + Content string `json:"content"` + Desc string `json:"desc"` + Image string `json:"image"` + IsTrans int8 `json:"is_trans"` + TransURL *string `json:"transurl"` + Status int8 `json:"status"` + IgnoreSimilarity int `json:"ignore_similarity"` +} + +// Create POST /backend/createarticle +func (c *BackendArticleController) Create() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + raw, err := io.ReadAll(c.Ctx.Request.Body) + if err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + var p cmsArticlePayload + if err := json.Unmarshal(raw, &p); err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + title := strings.TrimSpace(p.Title) + if title == "" { + c.cmsJSONErr(400, 400, "标题不能为空") + return + } + + if p.IgnoreSimilarity != 1 { + similar, serr := models.CmsSimilarArticles(tid, title, 5) + if serr == nil && len(similar) > 0 { + c.Ctx.Output.SetStatus(409) + c.Data["json"] = map[string]interface{}{ + "code": 409, + "msg": "检测到相似标题", + "data": map[string]interface{}{"similar_articles": similar}, + } + _ = c.ServeJSON() + return + } + } + + now := time.Now() + cateID := cmsParseUintArg(p.Cate) + row := models.CmsArticle{ + Tid: tid, + Title: title, + Author: strings.TrimSpace(p.Author), + CateID: cateID, + Content: p.Content, + Desc: strings.TrimSpace(p.Desc), + Image: strings.TrimSpace(p.Image), + IsTrans: p.IsTrans, + TransURL: p.TransURL, + Status: p.Status, + CreateTime: now, + UpdateTime: &now, + } + id, err := models.Orm.Insert(&row) + if err != nil { + c.cmsJSONErr(500, 500, "创建失败") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "创建成功", "data": map[string]interface{}{"id": id}} + _ = c.ServeJSON() +} + +// Update POST /backend/editarticle/:id +func (c *BackendArticleController) Update() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + raw, err := io.ReadAll(c.Ctx.Request.Body) + if err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + var p cmsArticlePayload + if err := json.Unmarshal(raw, &p); err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + + now := time.Now() + fields := map[string]interface{}{ + "title": strings.TrimSpace(p.Title), + "author": strings.TrimSpace(p.Author), + "cate_id": cmsParseUintArg(p.Cate), + "content": p.Content, + "desc": strings.TrimSpace(p.Desc), + "image": strings.TrimSpace(p.Image), + "is_trans": p.IsTrans, + "transurl": p.TransURL, + "status": p.Status, + "update_time": now, + } + n, err := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(fields) + if err != nil { + c.cmsJSONErr(500, 500, "更新失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} + _ = c.ServeJSON() +} + +// Delete DELETE /backend/deletearticle/:id +func (c *BackendArticleController) Delete() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + now := time.Now() + n, err := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(map[string]interface{}{"delete_time": now, "update_time": now}) + if err != nil { + c.cmsJSONErr(500, 500, "删除失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "删除成功"} + _ = c.ServeJSON() +} + +func (c *BackendArticleController) setArticleFlag(field string, value int8) { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + now := time.Now() + fields := map[string]interface{}{field: value, "update_time": now} + n, err := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(fields) + if err != nil { + c.cmsJSONErr(500, 500, "操作失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success"} + _ = c.ServeJSON() +} + +func (c *BackendArticleController) Publish() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + var uid uint64 + raw, _ := io.ReadAll(c.Ctx.Request.Body) + if len(raw) > 0 { + var body struct { + UID uint64 `json:"uid"` + } + _ = json.Unmarshal(raw, &body) + uid = body.UID + } + if uid == 0 && claims != nil { + uid = uint64(claims.UserID) + } + + now := time.Now() + fields := map[string]interface{}{ + "status": int8(2), + "publish_time": now, + "publisher_id": uid, + "update_time": now, + } + n, err := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(fields) + if err != nil { + c.cmsJSONErr(500, 500, "发布失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "发布成功"} + _ = c.ServeJSON() +} + +func (c *BackendArticleController) Unpublish() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + now := time.Now() + n, err := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(map[string]interface{}{"status": int8(3), "update_time": now}) + if err != nil { + c.cmsJSONErr(500, 500, "下架失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "文章不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "下架成功"} + _ = c.ServeJSON() +} + +func (c *BackendArticleController) Recommend() { c.setArticleFlag("recommend", 1) } +func (c *BackendArticleController) Unrecommend() { c.setArticleFlag("recommend", 0) } +func (c *BackendArticleController) Top() { c.setArticleFlag("top", 1) } +func (c *BackendArticleController) Untop() { c.setArticleFlag("top", 0) } + +// List GET /backend/categories +func (c *BackendArticleCategoryController) List() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + page, _ := c.GetInt("page", 1) + pageSize, _ := c.GetInt("pageSize", 0) + if pageSize == 0 { + pageSize, _ = c.GetInt("limit", 1000) + } + if page < 1 { + page = 1 + } + if pageSize < 1 { + pageSize = 1000 + } + + keyword := strings.TrimSpace(c.GetString("keyword")) + cond := orm.NewCondition().Or("tid", 0).Or("tid", tid) + qs := models.Orm.QueryTable(new(models.CmsArticleCategory)). + SetCond(cond). + Filter("delete_time__isnull", true) + if keyword != "" { + qs = qs.Filter("name__icontains", keyword) + } + + total, _ := qs.Count() + var rows []models.CmsArticleCategory + offset := (page - 1) * pageSize + _, err = qs.OrderBy("sort", "id").Limit(pageSize, offset).All(&rows) + if err != nil && err != orm.ErrNoRows { + c.cmsJSONErr(500, 500, "获取分类失败") + return + } + + list := make([]map[string]interface{}, 0, len(rows)) + for _, r := range rows { + list = append(list, cmsCategoryToMap(r)) + } + + c.Data["json"] = map[string]interface{}{ + "code": 200, + "msg": "success", + "data": map[string]interface{}{"list": list, "total": total, "records": list}, + } + _ = c.ServeJSON() +} + +// ListAll GET /backend/allcategories +func (c *BackendArticleCategoryController) ListAll() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + keyword := strings.TrimSpace(c.GetString("keyword")) + cond := orm.NewCondition().Or("tid", 0).Or("tid", tid) + qs := models.Orm.QueryTable(new(models.CmsArticleCategory)). + SetCond(cond). + Filter("delete_time__isnull", true) + if keyword != "" { + qs = qs.Filter("name__icontains", keyword) + } + + var rows []models.CmsArticleCategory + _, err = qs.OrderBy("sort", "id").All(&rows) + if err != nil && err != orm.ErrNoRows { + c.cmsJSONErr(500, 500, "获取分类失败") + return + } + + list := make([]map[string]interface{}, 0, len(rows)) + for _, r := range rows { + list = append(list, cmsCategoryToMap(r)) + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": list} + _ = c.ServeJSON() +} + +// Detail GET /backend/categories/:id +func (c *BackendArticleCategoryController) Detail() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + var row models.CmsArticleCategory + cond := orm.NewCondition().Or("tid", 0).Or("tid", tid) + err = models.Orm.QueryTable(new(models.CmsArticleCategory)). + SetCond(cond). + Filter("id", id). + Filter("delete_time__isnull", true). + One(&row) + if err == orm.ErrNoRows { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + if err != nil { + c.cmsJSONErr(500, 500, "查询失败") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": cmsCategoryToMap(row)} + _ = c.ServeJSON() +} + +type cmsCategoryPayload struct { + Name string `json:"name"` + Image string `json:"image"` + Desc string `json:"desc"` + Sort int `json:"sort"` + Status int8 `json:"status"` + Cid uint64 `json:"cid"` +} + +// Create POST /backend/createCategory +func (c *BackendArticleCategoryController) Create() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + if tid == 0 { + c.cmsJSONErr(400, 400, "tid不能为空") + return + } + + raw, err := io.ReadAll(c.Ctx.Request.Body) + if err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + var p cmsCategoryPayload + if err := json.Unmarshal(raw, &p); err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + name := strings.TrimSpace(p.Name) + if name == "" { + c.cmsJSONErr(400, 400, "分类名称不能为空") + return + } + + now := time.Now() + row := models.CmsArticleCategory{ + Tid: tid, + Cid: p.Cid, + Name: name, + Image: strings.TrimSpace(p.Image), + Desc: strings.TrimSpace(p.Desc), + Sort: p.Sort, + Status: p.Status, + CreateTime: now, + UpdateTime: &now, + } + id, err := models.Orm.Insert(&row) + if err != nil { + c.cmsJSONErr(500, 500, "创建失败") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "创建成功", "data": map[string]interface{}{"id": id}} + _ = c.ServeJSON() +} + +// Update POST /backend/editCategory/:id +func (c *BackendArticleCategoryController) Update() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + raw, err := io.ReadAll(c.Ctx.Request.Body) + if err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + var p cmsCategoryPayload + if err := json.Unmarshal(raw, &p); err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + + var row models.CmsArticleCategory + err = models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("id", id). + Filter("delete_time__isnull", true). + One(&row) + if err != nil { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + if row.Tid == 0 { + c.cmsJSONErr(403, 403, "全局分类不可修改") + return + } + + now := time.Now() + n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(map[string]interface{}{ + "name": strings.TrimSpace(p.Name), + "image": strings.TrimSpace(p.Image), + "desc": strings.TrimSpace(p.Desc), + "sort": p.Sort, + "status": p.Status, + "cid": p.Cid, + "update_time": now, + }) + if err != nil { + c.cmsJSONErr(500, 500, "更新失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} + _ = c.ServeJSON() +} + +// Delete DELETE /backend/categories/:id +func (c *BackendArticleCategoryController) Delete() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + var category models.CmsArticleCategory + if err := models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("id", id). + Filter("delete_time__isnull", true). + One(&category); err != nil { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + if category.Tid == 0 { + c.cmsJSONErr(403, 403, "全局分类不可删除") + return + } + + childCnt, _ := models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("tid", tid). + Filter("cid", id). + Filter("delete_time__isnull", true). + Count() + if childCnt > 0 { + c.cmsJSONErr(400, 400, "请先删除子分类") + return + } + + articleCnt, _ := models.Orm.QueryTable(new(models.CmsArticle)). + Filter("tid", tid). + Filter("cate_id", id). + Filter("delete_time__isnull", true). + Count() + if articleCnt > 0 { + c.cmsJSONErr(400, 400, "该分类下还有文章，无法删除") + return + } + + now := time.Now() + n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(map[string]interface{}{"delete_time": now, "update_time": now}) + if err != nil { + c.cmsJSONErr(500, 500, "删除失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "删除成功"} + _ = c.ServeJSON() +} + +// UpdateStatus PATCH /backend/categories/:id/status +func (c *BackendArticleCategoryController) UpdateStatus() { + if !cmsEnsureTables(&c.Controller) { + return + } + claims, err := c.cmsClaims() + if err != nil { + c.cmsJSONErr(401, 401, err.Error()) + return + } + tid := cmsEffectiveTid(&c.Controller, claims) + id, _ := c.GetUint64(":id") + if id == 0 { + c.cmsJSONErr(400, 400, "无效ID") + return + } + + raw, err := io.ReadAll(c.Ctx.Request.Body) + if err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + var p struct { + Status int8 `json:"status"` + } + if err := json.Unmarshal(raw, &p); err != nil { + c.cmsJSONErr(400, 400, "参数错误") + return + } + + now := time.Now() + n, err := models.Orm.QueryTable(new(models.CmsArticleCategory)). + Filter("id", id). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Update(map[string]interface{}{"status": p.Status, "update_time": now}) + if err != nil { + c.cmsJSONErr(500, 500, "更新失败") + return + } + if n == 0 { + c.cmsJSONErr(404, 404, "分类不存在") + return + } + + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} + _ = c.ServeJSON() +} diff --git a/go/controllers/backend_menu_front.go b/go/controllers/backend_menu_front.go new file mode 100644 index 0000000..9d41e02 --- /dev/null +++ b/go/controllers/backend_menu_front.go @@ -0,0 +1,154 @@ +package controllers + +import ( + "encoding/json" + "server/models" + "server/pkg/jwtutil" + "strconv" + "strings" + "time" + + beego "github.com/beego/beego/v2/server/web" +) + +type BackendMenuFrontController struct { + beego.Controller +} + +func (c *BackendMenuFrontController) checkAuth() (uint64, bool) { + authHeader := c.Ctx.Request.Header.Get("Authorization") + if authHeader == "" { + c.Data["json"] = map[string]interface{}{"code": 401, "msg": "未提供认证信息"} + _ = c.ServeJSON() + return 0, false + } + authParts := strings.SplitN(authHeader, " ", 2) + if len(authParts) != 2 || authParts[0] != "Bearer" { + c.Data["json"] = map[string]interface{}{"code": 401, "msg": "认证信息格式错误"} + _ = c.ServeJSON() + return 0, false + } + claims, err := jwtutil.ParseToken(authParts[1]) + if err != nil { + c.Data["json"] = map[string]interface{}{"code": 401, "msg": "token无效"} + _ = c.ServeJSON() + return 0, false + } + return uint64(claims.TenantId), true +} + +func (c *BackendMenuFrontController) List() { + tid, ok := c.checkAuth() + if !ok { + return + } + + var menus []models.BackendMenuFront + _, err := models.Orm.QueryTable("yz_backend_menu_front"). + Filter("tenant_id", tid). + Filter("delete_time__isnull", true). + OrderBy("sort"). + All(&menus) + + if err != nil { + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "查询失败"} + } else { + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": menus} + } + _ = c.ServeJSON() +} + +func (c *BackendMenuFrontController) Create() { + tid, ok := c.checkAuth() + if !ok { + return + } + + var menu models.BackendMenuFront + if err := json.Unmarshal(c.Ctx.Input.RequestBody, &menu); err != nil { + c.Data["json"] = map[string]interface{}{"code": 400, "msg": "参数错误"} + _ = c.ServeJSON() + return + } + + menu.TenantID = tid + menu.CreateTime = nil // 由orm自动处理 + _, err := models.Orm.Insert(&menu) + if err != nil { + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "创建失败"} + } else { + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "创建成功"} + } + _ = c.ServeJSON() +} + +func (c *BackendMenuFrontController) Update() { + id, err := strconv.ParseUint(c.Ctx.Input.Param(":id"), 10, 64) + if err != nil { + c.Data["json"] = map[string]interface{}{"code": 400, "msg": "参数错误"} + _ = c.ServeJSON() + return + } + + tid, ok := c.checkAuth() + if !ok { + return + } + + var menu models.BackendMenuFront + if err := json.Unmarshal(c.Ctx.Input.RequestBody, &menu); err != nil { + c.Data["json"] = map[string]interface{}{"code": 400, "msg": "参数错误"} + _ = c.ServeJSON() + return + } + + num, err := models.Orm.QueryTable("yz_backend_menu_front"). + Filter("id", id). + Filter("tenant_id", tid). + Update(map[string]interface{}{ + "pid": menu.Pid, + "title": menu.Title, + "path": menu.Path, + "component_path": menu.ComponentPath, + "icon": menu.Icon, + "sort": menu.Sort, + "status": menu.Status, + "is_visible": menu.IsVisible, + "type": menu.Type, + "permission": menu.Permission, + "update_time": time.Now(), + }) + + if err != nil || num == 0 { + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "更新失败"} + } else { + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "更新成功"} + } + _ = c.ServeJSON() +} + +func (c *BackendMenuFrontController) Delete() { + id, err := strconv.ParseUint(c.Ctx.Input.Param(":id"), 10, 64) + if err != nil { + c.Data["json"] = map[string]interface{}{"code": 400, "msg": "参数错误"} + _ = c.ServeJSON() + return + } + + tid, ok := c.checkAuth() + if !ok { + return + } + + num, err := models.Orm.QueryTable("yz_backend_menu_front"). + Filter("id", id). + Filter("tenant_id", tid). + Update(map[string]interface{}{"delete_time": time.Now()}) + + if err != nil || num == 0 { + c.Data["json"] = map[string]interface{}{"code": 500, "msg": "删除失败"} + } else { + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "删除成功"} + } + _ = c.ServeJSON() +} \ No newline at end of file diff --git a/go/controllers/index_portal.go b/go/controllers/index_portal.go index 3b78796..1fe42a9 100644 --- a/go/controllers/index_portal.go +++ b/go/controllers/index_portal.go @@ -1,6 +1,8 @@ package controllers import ( + "fmt" + "net/url" "strconv" "strings" @@ -37,8 +39,54 @@ func (c *IndexPortalController) getTidByHost() uint64 { return 1 // 默认租户 } -// GetHeadMenu GET /index/headmenu +// 获取后端菜单数据（支持开发环境租户切换） func (c *IndexPortalController) GetHeadMenu() { + // DEV 环境下支持通过 X-Tenant-ID 切换租户 + runmode, _ := beego.AppConfig.String("runmode") + tenantName := c.Ctx.Request.Header.Get("X-Tenant-ID") + + // 解码 + if decoded, err := url.QueryUnescape(tenantName); err == nil { + tenantName = decoded + } + + // 强制打印，确保你能从终端看到真实值 + fmt.Printf("[DEBUG] runmode: %s, Decoded TenantName: %s\n", runmode, tenantName) + + if runmode == "dev" && tenantName != "" { + // 查找租户 ID - 支持 name 或 short_name + var tenant models.SystemTenant + // 使用 OR 逻辑查询 name 或 short_name + cond := orm.NewCondition() + cond = cond.Or("tenant_name", tenantName).Or("tenant_short_name", tenantName) + + err := models.Orm.QueryTable(new(models.SystemTenant)). + SetCond(cond). + One(&tenant) + + if err != nil { + fmt.Printf("[DEBUG] QueryTenant Error: %v, Looking for: %s\n", err, tenantName) + } else { + fmt.Printf("[DEBUG] Found Tenant ID: %d\n", tenant.ID) + // 查询该租户的自定义菜单 + var menus []models.BackendMenuFront + _, err = models.Orm.QueryTable("yz_backend_menu_front"). + Filter("tenant_id", tenant.ID). + Filter("delete_time__isnull", true). + OrderBy("sort"). + All(&menus) + if err == nil && len(menus) > 0 { + // 转换数据格式供前端使用 + menuData := buildFrontMenuTree(menus, 0) + c.Data["json"] = map[string]interface{}{"code": 200, "msg": "success", "data": menuData} + _ = c.ServeJSON() + return + } else { + fmt.Printf("[DEBUG] No menus found for tenant: %d\n", tenant.ID) + } + } + } + // 前台的静态导航菜单结构 menuData := []map[string]interface{}{ { @@ -103,6 +151,27 @@ func (c *IndexPortalController) GetHeadMenu() { _ = c.ServeJSON() } +// 辅助构建树结构 +func buildFrontMenuTree(menus []models.BackendMenuFront, pid int64) []map[string]interface{} { + var tree []map[string]interface{} + for _, m := range menus { + if int64(m.Pid) == pid { + node := map[string]interface{}{ + "id": m.ID, + "title": m.Title, + "path": m.Path, + "type": m.Type, + } + children := buildFrontMenuTree(menus, int64(m.ID)) + if len(children) > 0 { + node["children"] = children + } + tree = append(tree, node) + } + } + return tree +} + // GetFooterData GET /index/footerdata func (c *IndexPortalController) GetFooterData() { tid := c.getTidByHost() @@ -296,7 +365,7 @@ func (c *IndexPortalController) GetCompanyNewsDetail() { c.getArticleDetail() } -// GetKingdeeNewsDetail GET /index/kingdeenews/detail/:id +// GetKingdeeNewsDetail GET /index/kingdeeNews/detail/:id func (c *IndexPortalController) GetKingdeeNewsDetail() { c.getArticleDetail() } @@ -393,4 +462,4 @@ func (c *IndexPortalController) GetOnePageByPath() { "data": nil, } _ = c.ServeJSON() -} +} \ No newline at end of file diff --git a/go/models/backend_menu_front.go b/go/models/backend_menu_front.go new file mode 100644 index 0000000..8de1077 --- /dev/null +++ b/go/models/backend_menu_front.go @@ -0,0 +1,33 @@ +package models + +import ( + "time" + + "github.com/beego/beego/v2/client/orm" +) + +type BackendMenuFront struct { + ID uint64 `orm:"column(id);pk;auto" json:"id"` + TenantID uint64 `orm:"column(tenant_id)" json:"tenant_id"` + Pid int64 `orm:"column(pid)" json:"pid"` + Title string `orm:"column(title)" json:"title"` + Path string `orm:"column(path)" json:"path"` + ComponentPath string `orm:"column(component_path)" json:"component_path"` + Icon string `orm:"column(icon)" json:"icon"` + Sort int `orm:"column(sort)" json:"sort"` + Status int8 `orm:"column(status)" json:"status"` + IsVisible int8 `orm:"column(is_visible)" json:"is_visible"` + Type int8 `orm:"column(type)" json:"type"` + Permission string `orm:"column(permission)" json:"permission"` + CreateTime *time.Time `orm:"column(create_time);auto_now_add;type(datetime)" json:"create_time"` + UpdateTime *time.Time `orm:"column(update_time);auto_now;type(datetime)" json:"update_time"` + DeleteTime *time.Time `orm:"column(delete_time);null;type(datetime)" json:"delete_time"` +} + +func (m *BackendMenuFront) TableName() string { + return "yz_backend_menu_front" +} + +func init() { + orm.RegisterModel(new(BackendMenuFront)) +} \ No newline at end of file diff --git a/go/models/cms_article.go b/go/models/cms_article.go index dec5c3b..ab85384 100644 --- a/go/models/cms_article.go +++ b/go/models/cms_article.go @@ -1,159 +1,200 @@ -package models - -import ( - "sync" - "time" - - "github.com/beego/beego/v2/client/orm" -) - -// CmsArticleCategory CMS 文章分类 yz_cms_article_category -type CmsArticleCategory struct { - ID uint64 `orm:"column(id);pk;auto" json:"id"` - Tid uint64 `orm:"column(tid);default(0)" json:"tid"` - Cid uint64 `orm:"column(cid);default(0)" json:"cid"` - Name string `orm:"column(name);size(100)" json:"name"` - Image string `orm:"column(image);size(500);default()" json:"image"` - Desc string `orm:"column(desc);size(500);default()" json:"desc"` - Sort int `orm:"column(sort);default(0)" json:"sort"` - Status int8 `orm:"column(status);default(1)" json:"status"` - CreateTime time.Time `orm:"column(create_time);auto_now_add;type(datetime)" json:"create_time"` - UpdateTime *time.Time `orm:"column(update_time);type(datetime);null" json:"update_time"` - DeleteTime *time.Time `orm:"column(delete_time);type(datetime);null" json:"delete_time"` -} - -func (m *CmsArticleCategory) TableName() string { - return "yz_cms_article_category" -} - -// CmsArticle CMS 文章 yz_cms_article -type CmsArticle struct { - ID uint64 `orm:"column(id);pk;auto" json:"id"` - Tid uint64 `orm:"column(tid);default(0)" json:"tid"` - Title string `orm:"column(title);size(255)" json:"title"` - Author string `orm:"column(author);size(100);default()" json:"author"` - CateID uint64 `orm:"column(cate_id);default(0)" json:"cate_id"` - Content string `orm:"column(content);type(mediumtext);null" json:"content"` - Desc string `orm:"column(desc);size(500);default()" json:"desc"` - Image string `orm:"column(image);size(500);default()" json:"image"` - IsTrans int8 `orm:"column(is_trans);default(0)" json:"is_trans"` - TransURL *string `orm:"column(transurl);size(500);null" json:"transurl"` - Status int8 `orm:"column(status);default(0)" json:"status"` - Top int8 `orm:"column(top);default(0)" json:"top"` - Recommend int8 `orm:"column(recommend);default(0)" json:"recommend"` - Views int `orm:"column(views);default(0)" json:"views"` - Likes int `orm:"column(likes);default(0)" json:"likes"` - PublisherID *uint64 `orm:"column(publisher_id);null" json:"publisher_id"` - PublishTime *time.Time `orm:"column(publish_time);type(datetime);null" json:"publish_time"` - CreateTime time.Time `orm:"column(create_time);auto_now_add;type(datetime)" json:"create_time"` - UpdateTime *time.Time `orm:"column(update_time);type(datetime);null" json:"update_time"` - DeleteTime *time.Time `orm:"column(delete_time);type(datetime);null" json:"delete_time"` -} - -func (m *CmsArticle) TableName() string { - return "yz_cms_article" -} - -var cmsArticleTablesOnce sync.Once - -// EnsureCmsArticleTables 首次使用时自动建表（若不存在）。 -func EnsureCmsArticleTables() error { - var err error - cmsArticleTablesOnce.Do(func() { - _, err = Orm.Raw(` -CREATE TABLE IF NOT EXISTS yz_cms_article_category ( - id bigint unsigned NOT NULL AUTO_INCREMENT, - tid bigint unsigned NOT NULL DEFAULT 0, - cid bigint unsigned NOT NULL DEFAULT 0, - name varchar(100) NOT NULL DEFAULT '', - image varchar(500) NOT NULL DEFAULT '', - ` + "`desc`" + ` varchar(500) NOT NULL DEFAULT '', - sort int NOT NULL DEFAULT 0, - status tinyint NOT NULL DEFAULT 1, - create_time datetime NOT NULL, - update_time datetime DEFAULT NULL, - delete_time datetime DEFAULT NULL, - PRIMARY KEY (id), - KEY idx_tid_cid (tid, cid) -) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4`).Exec() - if err != nil { - return - } - _, err = Orm.Raw(` -CREATE TABLE IF NOT EXISTS yz_cms_article ( - id bigint unsigned NOT NULL AUTO_INCREMENT, - tid bigint unsigned NOT NULL DEFAULT 0, - title varchar(255) NOT NULL DEFAULT '', - author varchar(100) NOT NULL DEFAULT '', - cate_id bigint unsigned NOT NULL DEFAULT 0, - content mediumtext, - ` + "`desc`" + ` varchar(500) NOT NULL DEFAULT '', - image varchar(500) NOT NULL DEFAULT '', - is_trans tinyint NOT NULL DEFAULT 0, - transurl varchar(500) DEFAULT NULL, - status tinyint NOT NULL DEFAULT 0, - top tinyint NOT NULL DEFAULT 0, - recommend tinyint NOT NULL DEFAULT 0, - views int NOT NULL DEFAULT 0, - likes int NOT NULL DEFAULT 0, - publisher_id bigint unsigned DEFAULT NULL, - publish_time datetime DEFAULT NULL, - create_time datetime NOT NULL, - update_time datetime DEFAULT NULL, - delete_time datetime DEFAULT NULL, - PRIMARY KEY (id), - KEY idx_tid_status (tid, status), - KEY idx_cate_id (cate_id) -) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4`).Exec() - }) - return err -} - -func CmsCategoryNameMap(tid uint64, ids []uint64) map[uint64]string { - out := make(map[uint64]string) - if len(ids) == 0 { - return out - } - var rows []CmsArticleCategory - _, _ = Orm.QueryTable(new(CmsArticleCategory)). - Filter("tid", tid). - Filter("id__in", ids). - Filter("delete_time__isnull", true). - All(&rows, "ID", "Name") - for _, r := range rows { - out[r.ID] = r.Name - } - return out -} - -func CmsFormatTime(t *time.Time) string { - if t == nil { - return "" - } - return t.Format("2006-01-02 15:04:05") -} - -func CmsSimilarArticles(tid uint64, title string, limit int) ([]orm.Params, error) { - if limit <= 0 { - limit = 5 - } - var rows []CmsArticle - _, err := Orm.QueryTable(new(CmsArticle)). - Filter("tid", tid). - Filter("delete_time__isnull", true). - Filter("title__icontains", title). - Limit(limit). - All(&rows, "ID", "Title") - if err != nil { - return nil, err - } - out := make([]orm.Params, 0, len(rows)) - for _, r := range rows { - out = append(out, orm.Params{ - "id": r.ID, - "title": r.Title, - "similarity": 80, - }) - } - return out, nil -} +package models + +import ( + "sync" + "time" + + "github.com/beego/beego/v2/client/orm" +) + +// CmsArticleCategory CMS 文章分类 yz_cms_article_category +type CmsArticleCategory struct { + ID uint64 `orm:"column(id);pk;auto" json:"id"` + Tid uint64 `orm:"column(tid);default(0)" json:"tid"` + Cid uint64 `orm:"column(cid);default(0)" json:"cid"` + Name string `orm:"column(name);size(100)" json:"name"` + Image string `orm:"column(image);size(500);default()" json:"image"` + Desc string `orm:"column(desc);size(500);default()" json:"desc"` + Sort int `orm:"column(sort);default(0)" json:"sort"` + Status int8 `orm:"column(status);default(1)" json:"status"` + CreateTime time.Time `orm:"column(create_time);auto_now_add;type(datetime)" json:"create_time"` + UpdateTime *time.Time `orm:"column(update_time);type(datetime);null" json:"update_time"` + DeleteTime *time.Time `orm:"column(delete_time);type(datetime);null" json:"delete_time"` +} + +func (m *CmsArticleCategory) TableName() string { + return "yz_cms_article_category" +} + +// CmsArticle CMS 文章 yz_cms_article +type CmsArticle struct { + ID uint64 `orm:"column(id);pk;auto" json:"id"` + Tid uint64 `orm:"column(tid);default(0)" json:"tid"` + Title string `orm:"column(title);size(255)" json:"title"` + Author string `orm:"column(author);size(100);default()" json:"author"` + CateID uint64 `orm:"column(cate_id);default(0)" json:"cate_id"` + Content string `orm:"column(content);type(mediumtext);null" json:"content"` + Desc string `orm:"column(desc);size(500);default()" json:"desc"` + Image string `orm:"column(image);size(500);default()" json:"image"` + IsTrans int8 `orm:"column(is_trans);default(0)" json:"is_trans"` + TransURL *string `orm:"column(transurl);size(500);null" json:"transurl"` + Status int8 `orm:"column(status);default(0)" json:"status"` + Top int8 `orm:"column(top);default(0)" json:"top"` + Recommend int8 `orm:"column(recommend);default(0)" json:"recommend"` + Views int `orm:"column(views);default(0)" json:"views"` + Likes int `orm:"column(likes);default(0)" json:"likes"` + PublisherID *uint64 `orm:"column(publisher_id);null" json:"publisher_id"` + PublishTime *time.Time `orm:"column(publish_time);type(datetime);null" json:"publish_time"` + CreateTime time.Time `orm:"column(create_time);auto_now_add;type(datetime)" json:"create_time"` + UpdateTime *time.Time `orm:"column(update_time);type(datetime);null" json:"update_time"` + DeleteTime *time.Time `orm:"column(delete_time);type(datetime);null" json:"delete_time"` +} + +func (m *CmsArticle) TableName() string { + return "yz_cms_article" +} + +var cmsArticleTablesOnce sync.Once + +// EnsureCmsArticleTables 首次使用时自动建表（若不存在）。 +func EnsureCmsArticleTables() error { + var err error + cmsArticleTablesOnce.Do(func() { + _, err = Orm.Raw(` +CREATE TABLE IF NOT EXISTS yz_cms_article_category ( + id bigint unsigned NOT NULL AUTO_INCREMENT, + tid bigint unsigned NOT NULL DEFAULT 0, + cid bigint unsigned NOT NULL DEFAULT 0, + name varchar(100) NOT NULL DEFAULT '', + image varchar(500) NOT NULL DEFAULT '', + ` + "`desc`" + ` varchar(500) NOT NULL DEFAULT '', + sort int NOT NULL DEFAULT 0, + status tinyint NOT NULL DEFAULT 1, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + delete_time datetime DEFAULT NULL, + PRIMARY KEY (id), + KEY idx_tid_cid (tid, cid) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4`).Exec() + if err != nil { + return + } + _, err = Orm.Raw(` +CREATE TABLE IF NOT EXISTS yz_cms_article ( + id bigint unsigned NOT NULL AUTO_INCREMENT, + tid bigint unsigned NOT NULL DEFAULT 0, + title varchar(255) NOT NULL DEFAULT '', + author varchar(100) NOT NULL DEFAULT '', + cate_id bigint unsigned NOT NULL DEFAULT 0, + content mediumtext, + ` + "`desc`" + ` varchar(500) NOT NULL DEFAULT '', + image varchar(500) NOT NULL DEFAULT '', + is_trans tinyint NOT NULL DEFAULT 0, + transurl varchar(500) DEFAULT NULL, + status tinyint NOT NULL DEFAULT 0, + top tinyint NOT NULL DEFAULT 0, + recommend tinyint NOT NULL DEFAULT 0, + views int NOT NULL DEFAULT 0, + likes int NOT NULL DEFAULT 0, + publisher_id bigint unsigned DEFAULT NULL, + publish_time datetime DEFAULT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + delete_time datetime DEFAULT NULL, + PRIMARY KEY (id), + KEY idx_tid_status (tid, status), + KEY idx_cate_id (cate_id) +) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4`).Exec() + }) + return err +} + +func EnsureCmsArticleDefaultCategories() error { + // 只初始化两级全局分类：文章中心（顶级）和新闻中心（文章中心的子分类）。 + // 不在启动时创建其它业务分类，后续分类由管理员按需新增。 + defaults := []struct { + name string + cid uint64 + sort int + }{ + {name: "文章中心", cid: 0, sort: 1}, + {name: "新闻中心", cid: 1, sort: 2}, + } + + for _, item := range defaults { + count, err := Orm.QueryTable(new(CmsArticleCategory)). + Filter("tid", 0). + Filter("name", item.name). + Filter("cid", item.cid). + Filter("delete_time__isnull", true). + Count() + if err != nil { + return err + } + if count > 0 { + continue + } + now := time.Now() + _, err = Orm.Insert(&CmsArticleCategory{ + Tid: 0, + Cid: item.cid, + Name: item.name, + Sort: item.sort, + Status: 1, + CreateTime: now, + }) + if err != nil { + return err + } + } + return nil +} + +func CmsCategoryNameMap(tid uint64, ids []uint64) map[uint64]string { + out := make(map[uint64]string) + if len(ids) == 0 { + return out + } + var rows []CmsArticleCategory + qs := Orm.QueryTable(new(CmsArticleCategory)). + Filter("id__in", ids). + Filter("delete_time__isnull", true) + cond := orm.NewCondition().Or("tid", 0).Or("tid", tid) + _, _ = qs.SetCond(cond).All(&rows, "ID", "Name") + for _, r := range rows { + out[r.ID] = r.Name + } + return out +} + +func CmsFormatTime(t *time.Time) string { + if t == nil { + return "" + } + return t.Format("2006-01-02 15:04:05") +} + +func CmsSimilarArticles(tid uint64, title string, limit int) ([]orm.Params, error) { + if limit <= 0 { + limit = 5 + } + var rows []CmsArticle + _, err := Orm.QueryTable(new(CmsArticle)). + Filter("tid", tid). + Filter("delete_time__isnull", true). + Filter("title__icontains", title). + Limit(limit). + All(&rows, "ID", "Title") + if err != nil { + return nil, err + } + out := make([]orm.Params, 0, len(rows)) + for _, r := range rows { + out = append(out, orm.Params{ + "id": r.ID, + "title": r.Title, + "similarity": 80, + }) + } + return out, nil +} diff --git a/go/routers/backend/backend.go b/go/routers/backend/backend.go index efa2c79..24a8fc5 100644 --- a/go/routers/backend/backend.go +++ b/go/routers/backend/backend.go @@ -31,7 +31,9 @@ func RegisterAuthRoutes() { // 菜单接口 beego.Router("/backend/menu/:id", &controllers.BackendMenuController{}, "get:GetBackendMenu") - beego.Router("/backend/allmenu", &controllers.BackendMenuController{}, "get:GetAllBackendMenus") + // 前端菜单接口 + beego.Router("/backend/frontmenus", &controllers.BackendMenuFrontController{}, "get:List;post:Create") + beego.Router("/backend/frontmenus/:id", &controllers.BackendMenuFrontController{}, "post:Update;delete:Delete") // 操作日志（yz_system_operation_log） beego.Router("/backend/operationLogs", &controllers.BackendOperationLogController{}, "get:List")