db_init.go 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144
  1. package models
  2. import (
  3. "github.com/beego/beego/v2/client/orm"
  4. _ "github.com/go-sql-driver/mysql"
  5. "hongze/hongze_mobile_admin/models/roadshow"
  6. "hongze/hongze_mobile_admin/models/tables/admin"
  7. "hongze/hongze_mobile_admin/models/tables/admin_record"
  8. "hongze/hongze_mobile_admin/models/tables/approval_flow"
  9. "hongze/hongze_mobile_admin/models/tables/approval_flow_node"
  10. "hongze/hongze_mobile_admin/models/tables/company"
  11. "hongze/hongze_mobile_admin/models/tables/company_approval"
  12. "hongze/hongze_mobile_admin/models/tables/company_approval_message"
  13. "hongze/hongze_mobile_admin/models/tables/company_contract"
  14. "hongze/hongze_mobile_admin/models/tables/company_delay_permission"
  15. "hongze/hongze_mobile_admin/models/tables/company_log"
  16. "hongze/hongze_mobile_admin/models/tables/company_operation_record"
  17. "hongze/hongze_mobile_admin/models/tables/company_permission_log"
  18. "hongze/hongze_mobile_admin/models/tables/company_product"
  19. "hongze/hongze_mobile_admin/models/tables/company_product_log"
  20. "hongze/hongze_mobile_admin/models/tables/company_product_update_log"
  21. "hongze/hongze_mobile_admin/models/tables/company_report_permission"
  22. "hongze/hongze_mobile_admin/models/tables/contract"
  23. "hongze/hongze_mobile_admin/models/tables/contract_approval"
  24. "hongze/hongze_mobile_admin/models/tables/contract_approval_record"
  25. "hongze/hongze_mobile_admin/models/tables/contract_operation_record"
  26. "hongze/hongze_mobile_admin/models/tables/contract_service_detail"
  27. "hongze/hongze_mobile_admin/models/tables/contract_service_template"
  28. "hongze/hongze_mobile_admin/models/tables/contract_template"
  29. "hongze/hongze_mobile_admin/models/tables/h5_admin_session"
  30. "hongze/hongze_mobile_admin/models/tables/report"
  31. "hongze/hongze_mobile_admin/models/tables/research_variety_tag_relation"
  32. "hongze/hongze_mobile_admin/models/tables/resource"
  33. "hongze/hongze_mobile_admin/models/tables/seal"
  34. "hongze/hongze_mobile_admin/models/tables/sys_role"
  35. "hongze/hongze_mobile_admin/models/tables/sys_role_admin"
  36. "hongze/hongze_mobile_admin/models/tables/user_template_record"
  37. "hongze/hongze_mobile_admin/models/tables/variety_classify"
  38. "hongze/hongze_mobile_admin/models/tables/variety_tag"
  39. "hongze/hongze_mobile_admin/models/tables/wx_token"
  40. "hongze/hongze_mobile_admin/models/tables/wx_user"
  41. "hongze/hongze_mobile_admin/models/tables/yb_community_question"
  42. "hongze/hongze_mobile_admin/models/tables/yb_community_question_comment"
  43. "hongze/hongze_mobile_admin/models/tables/yb_price_driven_tag"
  44. "hongze/hongze_mobile_admin/utils"
  45. "time"
  46. )
  47. func init() {
  48. _ = orm.RegisterDataBase("default", "mysql", utils.MYSQL_URL)
  49. orm.SetMaxIdleConns("default", 50)
  50. orm.SetMaxOpenConns("default", 100)
  51. db, _ := orm.GetDB("default")
  52. db.SetConnMaxLifetime(10 * time.Minute)
  53. //rddp数据库
  54. _ = orm.RegisterDataBase("rddp", "mysql", utils.MYSQL_URL_RDDP)
  55. orm.SetMaxIdleConns("rddp", 50)
  56. orm.SetMaxOpenConns("rddp", 100)
  57. report_db, _ := orm.GetDB("rddp")
  58. report_db.SetConnMaxLifetime(10 * time.Minute)
  59. orm.Debug = true
  60. orm.DebugLog = orm.NewLog(utils.Binlog)
  61. //注册对象
  62. orm.RegisterModel(
  63. new(admin.Admin),
  64. new(admin_record.AdminRecord),
  65. new(sys_role.SysRole),
  66. new(sys_role_admin.SysRoleAdmin),
  67. new(approval_flow.ApprovalFlow),
  68. new(approval_flow_node.ApprovalFlowNode),
  69. new(company.Company),
  70. new(company_approval.CompanyApproval),
  71. new(company_approval_message.CompanyApprovalMessage),
  72. new(company_contract.CompanyContract),
  73. new(company_delay_permission.CompanyDelayPermission),
  74. new(company_log.CompanyLog),
  75. new(company_operation_record.CompanyOperationRecord),
  76. new(company_permission_log.CompanyPermissionLog),
  77. new(company_product.CompanyProduct),
  78. new(company_product_log.CompanyProductLog),
  79. new(company_report_permission.CompanyReportPermission),
  80. new(contract.Contract),
  81. new(contract_approval.ContractApproval),
  82. new(contract_approval_record.ContractApprovalRecord),
  83. new(contract_operation_record.ContractOperationRecord),
  84. new(contract_service_detail.ContractServiceDetail),
  85. new(contract_service_template.ContractServiceTemplate),
  86. new(contract_template.ContractTemplate),
  87. new(h5_admin_session.H5AdminSession),
  88. new(report.Report),
  89. new(resource.Resource),
  90. new(wx_token.WxToken),
  91. new(wx_user.WxUser),
  92. new(seal.Seal), //用印表
  93. new(seal.SealOperationRecord), // 用印操作记录表
  94. new(seal.Attachment), //用印附件
  95. new(roadshow.RsCalendar),
  96. new(roadshow.RsCalendarResearcher),
  97. new(roadshow.RsMatters),
  98. new(roadshow.RsCalendarRelation),
  99. new(company_product_update_log.CompanyProductUpdateLog), //客户产品状态变更记录表
  100. new(user_template_record.UserTemplateRecord), //模版消息记录表
  101. )
  102. // 社区问答相关
  103. initCommunity()
  104. // 品种标签相关
  105. initVariety()
  106. // 价格驱动相关
  107. initPriceDriven()
  108. }
  109. // initCommunity 社区问答相关
  110. func initCommunity() {
  111. orm.RegisterModel(
  112. new(yb_community_question.CommunityQuestion), //社区问答
  113. new(yb_community_question_comment.YbCommunityQuestionComment), //社区问答评论
  114. )
  115. }
  116. // initVariety 品种标签相关
  117. func initVariety() {
  118. orm.RegisterModel(
  119. new(variety_classify.VarietyClassify), //品种标签分类
  120. new(variety_tag.VarietyTag), //品种标签
  121. new(research_variety_tag_relation.ResearchVarietyTagRelation), //品种标签关系
  122. )
  123. }
  124. // initPriceDriven 价格驱动相关
  125. func initPriceDriven() {
  126. orm.RegisterModel(
  127. new(yb_price_driven_tag.PriceDrivenTag), //价格驱动标签
  128. )
  129. }
  130. func InitDb() {}