index.ts 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173
  1. import { OpenAPIHono } from '@hono/zod-openapi'
  2. import { swaggerUI } from '@hono/swagger-ui'
  3. import { errorHandler, initializeDataSource } from '@d8d/shared-utils'
  4. import { userRoutes as userModuleRoutes, roleRoutes as roleModuleRoutes } from '@d8d/core-module/user-module'
  5. import { authRoutes as authModuleRoutes, enterpriseAuthRoutes as enterpriseAuthModuleRoutes } from '@d8d/core-module/auth-module'
  6. import { fileRoutes as fileModuleRoutes } from '@d8d/core-module/file-module'
  7. import { AuthContext } from '@d8d/shared-types'
  8. import { AppDataSource } from '@d8d/shared-utils'
  9. import { Hono } from 'hono'
  10. import { databaseBackup } from './utils/backup'
  11. import { UserEntity, Role } from '@d8d/core-module/user-module'
  12. import { File } from '@d8d/core-module/file-module'
  13. import { SystemConfig } from '@d8d/core-module/system-config-module'
  14. import { areasRoutes, adminAreasRoutes, AreaEntity } from '@d8d/geo-areas'
  15. import { channelRoutes } from '@d8d/allin-channel-module'
  16. import { Channel } from '@d8d/allin-channel-module/entities'
  17. import { companyRoutes, companyStatisticsRoutes } from '@d8d/allin-company-module'
  18. import { Company } from '@d8d/allin-company-module/entities'
  19. import { disabledPersonRoutes, personExtensionRoutes } from '@d8d/allin-disability-module'
  20. import { DisabledPerson, DisabledBankCard, DisabledPhoto, DisabledRemark, DisabledVisit } from '@d8d/allin-disability-module/entities'
  21. import { orderRoutes } from '@d8d/allin-order-module'
  22. import { EmploymentOrder, OrderPerson, OrderPersonAsset } from '@d8d/allin-order-module/entities'
  23. import { platformRoutes } from '@d8d/allin-platform-module'
  24. import { Platform } from '@d8d/allin-platform-module/entities'
  25. import { salaryRoutes } from '@d8d/allin-salary-module'
  26. import { SalaryLevel } from '@d8d/allin-salary-module/entities'
  27. import { bankNameRoutes } from '@d8d/bank-names-module'
  28. import { BankName } from '@d8d/bank-names-module'
  29. initializeDataSource([
  30. UserEntity, Role, File, SystemConfig, AreaEntity,
  31. Channel,
  32. Company,
  33. DisabledPerson, DisabledBankCard, DisabledPhoto, DisabledRemark, DisabledVisit,
  34. EmploymentOrder, OrderPerson, OrderPersonAsset,
  35. Platform,
  36. SalaryLevel,
  37. BankName
  38. ])
  39. if(!AppDataSource || !AppDataSource.isInitialized) {
  40. await AppDataSource.initialize();
  41. console.log('数据库初始化完成')
  42. // 启动数据库备份调度
  43. databaseBackup.startScheduledBackups();
  44. console.log('数据库备份调度已启动');
  45. }
  46. const app = new Hono();
  47. const api = new OpenAPIHono<AuthContext>()
  48. api.onError(errorHandler)
  49. // Rate limiting
  50. api.use('/api/v1/*', async (_, next) => {
  51. // 实现速率限制逻辑
  52. await next()
  53. })
  54. // // 数据库初始化中间件
  55. // api.use('/api/v1/*', async (c, next) => {
  56. // await next();
  57. // })
  58. // 注册Bearer认证方案
  59. api.openAPIRegistry.registerComponent('securitySchemes','bearerAuth',{
  60. type:'http',
  61. scheme:'bearer',
  62. bearerFormat:'JWT',
  63. description:'使用JWT进行认证'
  64. })
  65. // OpenAPI documentation endpoint
  66. // !import.meta.env.PROD
  67. if(1){
  68. // api.doc31('/doc', {
  69. // openapi: '3.1.0',
  70. // info: {
  71. // title: 'API Documentation',
  72. // version: '1.0.0'
  73. // },
  74. // security: [{
  75. // bearerAuth: []
  76. // }]
  77. // // servers: [{ url: '/api/v1' }]
  78. // })
  79. api.get('/doc', (c) => {
  80. const config = {
  81. openapi: '3.1.0',
  82. info: {
  83. title: 'API Documentation',
  84. version: '1.0.0'
  85. },
  86. security: [{
  87. bearerAuth: []
  88. }]
  89. // servers: [{ url: '/api/v1' }]
  90. };
  91. try {
  92. const document = api.getOpenAPI31Document(config);
  93. return c.json(document);
  94. } catch (e: any) {
  95. return c.json({
  96. error: 'OpenAPI document generation failed',
  97. message: e.message || 'Unknown error',
  98. stack: e.stack
  99. }, 500)
  100. }
  101. })
  102. app.get('/ui', swaggerUI({
  103. url: '/doc',
  104. persistAuthorization: true,
  105. manuallySwaggerUIHtml: () => `
  106. <div>
  107. <div id="swagger-ui"></div>
  108. <link rel="stylesheet" href="https://ai-oss.d8d.fun/swagger-ui-dist/swagger-ui.css" />
  109. <script src="https://ai-oss.d8d.fun/swagger-ui-dist/swagger-ui-bundle.js" crossorigin="anonymous"></script>
  110. <script>
  111. window.onload = () => {
  112. window.ui = SwaggerUIBundle({
  113. dom_id: '#swagger-ui',
  114. url: '/doc',
  115. persistAuthorization: true
  116. })
  117. }
  118. </script>
  119. </div>
  120. `
  121. }))
  122. }
  123. export const userRoutes = api.route('/api/v1/users', userModuleRoutes)
  124. export const authRoutes = api.route('/api/v1/auth', authModuleRoutes)
  125. export const fileApiRoutes = api.route('/api/v1/files', fileModuleRoutes)
  126. export const roleRoutes = api.route('/api/v1/roles', roleModuleRoutes)
  127. export const areaApiRoutes = api.route('/api/v1/areas', areasRoutes)
  128. export const adminAreaApiRoutes = api.route('/api/v1/admin/areas', adminAreasRoutes)
  129. export const channelApiRoutes = api.route('/api/v1/channel', channelRoutes)
  130. export const companyApiRoutes = api.route('/api/v1/company', companyRoutes)
  131. export const disabilityApiRoutes = api.route('/api/v1/disability', disabledPersonRoutes)
  132. export const orderApiRoutes = api.route('/api/v1/order', orderRoutes)
  133. export const platformApiRoutes = api.route('/api/v1/platform', platformRoutes)
  134. export const salaryApiRoutes = api.route('/api/v1/salary', salaryRoutes)
  135. export const bankNameApiRoutes = api.route('/api/v1/bank-names', bankNameRoutes)
  136. // 企业用户专用路由(用人方小程序)
  137. export const enterpriseAuthApiRoutes = api.route('/api/v1/yongren/auth', enterpriseAuthModuleRoutes)
  138. export const enterpriseCompanyApiRoutes = api.route('/api/v1/yongren/company', companyStatisticsRoutes)
  139. export const enterpriseDisabilityApiRoutes = api.route('/api/v1/yongren/disability-person', personExtensionRoutes)
  140. export type AuthRoutes = typeof authRoutes
  141. export type UserRoutes = typeof userRoutes
  142. export type FileRoutes = typeof fileApiRoutes
  143. export type RoleRoutes = typeof roleRoutes
  144. export type AreaRoutes = typeof areaApiRoutes
  145. export type AdminAreaRoutes = typeof adminAreaApiRoutes
  146. export type ChannelRoutes = typeof channelApiRoutes
  147. export type CompanyRoutes = typeof companyApiRoutes
  148. export type DisabilityRoutes = typeof disabilityApiRoutes
  149. export type OrderRoutes = typeof orderApiRoutes
  150. export type PlatformRoutes = typeof platformApiRoutes
  151. export type SalaryRoutes = typeof salaryApiRoutes
  152. export type BankNameRoutes = typeof bankNameApiRoutes
  153. export type EnterpriseAuthRoutes = typeof enterpriseAuthApiRoutes
  154. export type EnterpriseCompanyRoutes = typeof enterpriseCompanyApiRoutes
  155. export type EnterpriseDisabilityRoutes = typeof enterpriseDisabilityApiRoutes
  156. app.route('/', api)
  157. export default app