db.go 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236
  1. package models
  2. import (
  3. "eta/eta_mobile/models/data_manage"
  4. "eta/eta_mobile/models/ppt_english"
  5. "eta/eta_mobile/models/sandbox"
  6. saModel "eta/eta_mobile/models/semantic_analysis"
  7. "eta/eta_mobile/models/system"
  8. "eta/eta_mobile/utils"
  9. _ "github.com/go-sql-driver/mysql"
  10. "time"
  11. "github.com/beego/beego/v2/client/orm"
  12. )
  13. func init() {
  14. _ = orm.RegisterDataBase("default", "mysql", utils.MYSQL_URL)
  15. orm.SetMaxIdleConns("default", 50)
  16. orm.SetMaxOpenConns("default", 100)
  17. db, _ := orm.GetDB("default")
  18. db.SetConnMaxLifetime(10 * time.Minute)
  19. _ = orm.RegisterDataBase("rddp", "mysql", utils.MYSQL_URL_RDDP)
  20. orm.SetMaxIdleConns("rddp", 50)
  21. orm.SetMaxOpenConns("rddp", 100)
  22. report_db, _ := orm.GetDB("rddp")
  23. report_db.SetConnMaxLifetime(10 * time.Minute)
  24. _ = orm.RegisterDataBase("edb", "mysql", utils.MYSQL_URL_EDB)
  25. orm.SetMaxIdleConns("edb", 50)
  26. orm.SetMaxOpenConns("edb", 100)
  27. edb_db, _ := orm.GetDB("edb")
  28. edb_db.SetConnMaxLifetime(10 * time.Minute)
  29. _ = orm.RegisterDataBase("data", "mysql", utils.MYSQL_URL_DATA)
  30. orm.SetMaxIdleConns("data", 50)
  31. orm.SetMaxOpenConns("data", 100)
  32. data_db, _ := orm.GetDB("data")
  33. data_db.SetConnMaxLifetime(10 * time.Minute)
  34. _ = orm.RegisterDataBase("eta", "mysql", utils.MYSQL_URL_ETA)
  35. orm.SetMaxIdleConns("eta", 50)
  36. orm.SetMaxOpenConns("eta", 100)
  37. etaDb, _ := orm.GetDB("eta")
  38. etaDb.SetConnMaxLifetime(10 * time.Minute)
  39. orm.Debug = true
  40. orm.DebugLog = orm.NewLog(utils.Binlog)
  41. //注册对象
  42. orm.RegisterModel(
  43. new(Classify),
  44. new(Resource),
  45. new(Ppt),
  46. new(PptPages),
  47. new(PptPublishRecord),
  48. new(PptV2),
  49. new(PptV2PublishRecord),
  50. new(PptV2SaveLog),
  51. new(PptV2Group),
  52. new(PptV2GroupMapping),
  53. new(PptV2Grant), //ppt授权操作表
  54. )
  55. // 报告相关 数据表
  56. initReport()
  57. initSystem()
  58. initChart()
  59. // 上海指标服务 数据表
  60. initShEdbData()
  61. // 指标服务 数据表
  62. initEdbData()
  63. // 英文ppt
  64. initPptEnglish()
  65. //多图配置
  66. initMultipleGraphConfig()
  67. // 英文报告
  68. initEnglishReport()
  69. // 沙盘推演
  70. initSandbox()
  71. // 文档对比
  72. initSaCompare()
  73. }
  74. // initSystem 系统表 数据表
  75. func initSystem() {
  76. orm.RegisterModel(
  77. new(system.SysUserLoginRecord),
  78. new(system.SysSession),
  79. new(system.Admin),
  80. new(system.AdminConfig), //系统用户配置表
  81. new(system.AdminVerifyCodeRecord), // 用户短信邮箱验证码记录表
  82. )
  83. }
  84. // initReport 报告相关 数据表
  85. func initReport() {
  86. orm.RegisterModel(
  87. new(Report),
  88. new(ResearchReport), //日报、周报信息
  89. new(ChartPermissionSearchKeyWordMapping), //报告分类权限表
  90. new(ReportChapter), // 报告章节表
  91. new(ReportChapterTicker), // 晨报章节ticker
  92. new(ReportChapterTypePermission), // 晨周报章节类型权限表
  93. new(YbPcSuncode),
  94. new(YbSuncodePars),
  95. new(ReportAuthor), //报告作者
  96. new(ClassifyMenu), // 报告分类-子目录表
  97. new(ClassifyMenuRelation), // 报告分类-子目录关联表
  98. new(ChartPermissionChapterMapping), // 权限mapping表
  99. new(ReportChapterType), // 报告章节类型表
  100. )
  101. }
  102. // initChart 图表 数据表
  103. func initChart() {
  104. orm.RegisterModel(
  105. new(data_manage.ChartClassify),
  106. new(data_manage.ChartInfo),
  107. new(data_manage.ChartEdbMapping),
  108. new(data_manage.MyChartClassify),
  109. new(data_manage.MyChart),
  110. new(data_manage.MyChartLog),
  111. new(data_manage.MyChartClassifyMapping),
  112. new(data_manage.ChartInfoLog),
  113. new(data_manage.ChartInfoCorrelation),
  114. )
  115. }
  116. // initShEdbData 上海服务器指标 数据表
  117. func initShEdbData() {
  118. orm.RegisterModel(
  119. new(Edbdata),
  120. new(EdbdataDeleteRecord),
  121. new(Edbinfo), //edb库的edbinfo表
  122. )
  123. }
  124. // initEdbData 指标服务 数据表
  125. func initEdbData() {
  126. orm.RegisterModel(
  127. new(data_manage.EdbClassify),
  128. new(data_manage.EdbInfo), //hz_data库的edb_info表
  129. new(data_manage.EdbDataThs),
  130. new(data_manage.EdbDataWind),
  131. new(data_manage.EdbDataPb),
  132. new(data_manage.EdbInfoCalculate),
  133. new(data_manage.EdbDataCalculate),
  134. new(data_manage.EdbInfoCalculateTbz),
  135. new(data_manage.SearchKeyword),
  136. new(data_manage.BaseFromSmm),
  137. new(data_manage.BaseFromSmmIndex),
  138. new(data_manage.BaseFromSmmData),
  139. new(data_manage.EdbInfoLog),
  140. new(data_manage.EdbInfoCalculateMapping),
  141. new(data_manage.ExcelClassify), //ETA excel表格分类
  142. new(data_manage.ExcelInfo), //ETA excel表格
  143. new(data_manage.PredictEdbConf), //预测指标配置
  144. new(data_manage.BaseFromMysteelChemicalIndex), //钢联化工
  145. new(data_manage.BaseFromEiaSteoClassify), // Eia steo 报告指标
  146. new(data_manage.BaseFromEiaSteoIndex), // Eia steo 报告指标分类
  147. new(data_manage.PredictEdbRuleData), //预测指标,动态规则的计算数据
  148. new(data_manage.BaseFromSci),
  149. new(data_manage.BaseFromSciIndex),
  150. new(data_manage.BaseFromSciData),
  151. new(data_manage.BaseFromBaiinfo),
  152. new(data_manage.BaseFromBaiinfoIndex),
  153. new(data_manage.BaseFromBaiinfoData),
  154. new(data_manage.EdbDataInsertConfig), // 指标数据插入配置表
  155. new(data_manage.EdbInfoNoPermissionAdmin), //指标不可见用户配置表
  156. )
  157. }
  158. // initPptEnglish ppt英文
  159. func initPptEnglish() {
  160. orm.RegisterModel(
  161. new(ppt_english.PptEnglish),
  162. new(ppt_english.PptEnglishPublishRecord),
  163. new(ppt_english.PptEnglishSaveLog),
  164. new(ppt_english.PptEnglishGroup),
  165. new(ppt_english.PptEnglishGroupMapping),
  166. new(ppt_english.PptEnglishGrant), //ppt授权操作表
  167. new(ppt_english.ReportPptEnglishImg), //Ppt转报告的图片记录表
  168. )
  169. }
  170. // initMultipleGraphConfig 多图配置 数据表
  171. func initMultipleGraphConfig() {
  172. //注册对象
  173. orm.RegisterModel(
  174. new(data_manage.MultipleGraphConfig), //多图配置表
  175. new(data_manage.MultipleGraphConfigChartMapping), //图表与多图配置的关系表
  176. //new(data_manage.MultipleGraphConfigEdbMapping), //指标与多图配置的关系表
  177. )
  178. }
  179. // initEnglishReport 英文报告
  180. func initEnglishReport() {
  181. orm.RegisterModel(
  182. new(EnglishReport),
  183. new(EnglishPolicyReport),
  184. new(EnglishReportEmail),
  185. new(EnglishReportEmailLog),
  186. new(EnglishClassify),
  187. new(EnglishVideo), // 英文研报线上路演
  188. )
  189. }
  190. // initSandbox 注册Edb沙盘 数据表
  191. func initSandbox() {
  192. //注册对象
  193. orm.RegisterModel(
  194. new(sandbox.Sandbox), //沙盘主表
  195. )
  196. }
  197. func initSaCompare() {
  198. orm.RegisterModel(
  199. new(saModel.SaCompare), //文档对比
  200. )
  201. }