orginfo_service.go 5.9KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. package service
  2. import (
  3. "XT_New/models"
  4. "github.com/jinzhu/gorm"
  5. "time"
  6. )
  7. func GetOrgTypes() (ots []*models.OrgType, err error) {
  8. err = readUserDb.Model(&models.OrgType{}).Where("status=1").Order("sort_no").Find(&ots).Error
  9. return
  10. }
  11. func UpdateOrgInfo(org *models.Org) (err error) {
  12. err = writeUserDb.Model(&models.Org{}).Where("id=?", org.Id).Update(org).Error
  13. return
  14. }
  15. func GetIllnessList() (ills []*models.Illness, err error) {
  16. err = readUserDb.Where("status=1").Find(&ills).Error
  17. return
  18. }
  19. func CreateOrgGalleryItem(item *models.OrgGallery) (err error) {
  20. err = writeUserDb.Create(item).Error
  21. return
  22. }
  23. func DeleteOrgGalleryItem(id int64) (err error) {
  24. err = writeUserDb.Model(&models.OrgGallery{}).Where("id=?", id).Update(map[string]interface{}{"Status": 0, "Mtime": time.Now().Unix()}).Error
  25. return
  26. }
  27. func CreateOrg(org *models.Org, name string, openXT bool, openCDM bool, openSCRM bool, openMall bool) error {
  28. now := time.Now()
  29. tx_admin := writeUserDb.Begin()
  30. if err := tx_admin.Create(org).Error; err != nil {
  31. tx_admin.Rollback()
  32. return err
  33. }
  34. role := models.Role{
  35. RoleName: "超级管理员",
  36. RoleIntro: "",
  37. Creator: org.Creator,
  38. OrgId: org.Id,
  39. AppId: 0,
  40. IsSuperAdmin: true,
  41. Status: 1,
  42. CreateTime: now.Unix(),
  43. ModifyTime: now.Unix(),
  44. }
  45. if err := tx_admin.Create(&role).Error; err != nil {
  46. tx_admin.Rollback()
  47. return err
  48. }
  49. // app 的创建顺序也决定了登录后前往 app 的优先级
  50. if err := createOrgApp(tx_admin, &role, name, 3, openXT); err != nil {
  51. tx_admin.Rollback()
  52. return err
  53. }
  54. nextMonthDate := now.AddDate(0, 0, 30)
  55. subscibe := models.ServeSubscibe{
  56. OrgId: int64(org.Id),
  57. PeriodStart: now.Unix(),
  58. PeriodEnd: nextMonthDate.Unix(),
  59. Status: 1,
  60. CreatedTime: now.Unix(),
  61. UpdatedTime: now.Unix(),
  62. State: 9,
  63. }
  64. if err := tx_admin.Create(&subscibe).Error; err != nil {
  65. tx_admin.Rollback()
  66. return err
  67. }
  68. tx_patient := writeSgjPatientDb.Begin()
  69. if err := tx_patient.Exec("INSERT INTO sgj_patient_articles_menu (name, status, type, user_org_id, ctime, mtime) VALUES(?, ?, ?, ?, ?, ?);", "科普教育", 1, 1, org.Id, now.Unix(), now.Unix()).Error; err != nil {
  70. tx_patient.Rollback()
  71. tx_admin.Rollback()
  72. return err
  73. }
  74. if err := tx_patient.Exec("INSERT INTO sgj_patient_good_category (user_org_id, category_name, status, created_time, updated_time) VALUES(?, ?, ?, ?, ?);", org.Id, "普通商品", 1, now.Unix(), now.Unix()).Error; err != nil {
  75. tx_patient.Rollback()
  76. tx_admin.Rollback()
  77. return err
  78. }
  79. if err := tx_admin.Exec("INSERT INTO sgj_user_membership_card (user_org_id, card_name, card_level, upgrade_integral, card_right, use_notice, background_type, background, service_phone, status, created_time, updated_time) VALUES(?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?);", org.Id, "普通会员", 0, 0, "", "", 1, "#CACA41", "", 1, now.Unix(), now.Unix()).Error; err != nil {
  80. tx_admin.Rollback()
  81. tx_patient.Rollback()
  82. return err
  83. }
  84. tx_admin.Commit()
  85. tx_patient.Commit()
  86. return nil
  87. }
  88. func createOrgApp(tx *gorm.DB, superAdminRole *models.Role, userName string, appType int, open bool) error {
  89. //创建应用
  90. now := time.Now().Unix()
  91. var app_id int64
  92. apps, _ := FindSystemOrgApp()
  93. for _, item := range apps {
  94. app := &VMOrgApp{
  95. AppType: item.AppType,
  96. Creator: int(superAdminRole.Creator),
  97. OrgId: int(superAdminRole.OrgId),
  98. OpenStatus: item.OpenStatus,
  99. Status: 1,
  100. CreateTime: now,
  101. ModifyTime: now,
  102. Name: item.Name,
  103. Url: item.Url,
  104. Number: item.Number,
  105. Pid: 0,
  106. }
  107. writeUserDb.Create(&app)
  108. if app.AppType == 3 {
  109. app_id = app.ID
  110. }
  111. for _, subItem := range item.VMOrgApp {
  112. app := &VMOrgApp{
  113. AppType: subItem.AppType,
  114. Creator: int(superAdminRole.Creator),
  115. OrgId: int(superAdminRole.OrgId),
  116. OpenStatus: subItem.OpenStatus,
  117. Status: 1,
  118. CreateTime: now,
  119. ModifyTime: now,
  120. Name: subItem.Name,
  121. Url: subItem.Url,
  122. Number: subItem.Number,
  123. Pid: app.ID,
  124. }
  125. writeUserDb.Create(&app)
  126. }
  127. }
  128. app_role := models.App_Role{
  129. AdminUserId: superAdminRole.Creator,
  130. OrgId: superAdminRole.OrgId,
  131. AppId: app_id,
  132. RoleId: superAdminRole.Id,
  133. Avatar: "",
  134. UserName: userName,
  135. Intro: "",
  136. UserType: 1,
  137. UserTitle: 1,
  138. Status: 1,
  139. CreateTime: now,
  140. ModifyTime: now,
  141. }
  142. if createApp_RoleErr := tx.Create(&app_role).Error; createApp_RoleErr != nil {
  143. return createApp_RoleErr
  144. }
  145. return nil
  146. }
  147. func GetOrgTypeByName(org_type_name string) (org_type models.OrgType) {
  148. readUserDb.Model(&models.OrgType{}).Where("status = 1 AND name = ?", org_type_name).First(&org_type)
  149. return
  150. }
  151. type VMOrgApp struct {
  152. ID int64 `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // ID
  153. AppType int `gorm:"column:app_type" json:"app_type"`
  154. Creator int `json:"creator"` // 创建者,即管理员用户的 id
  155. OrgId int `gorm:"column:org_id" json:"org_id"`
  156. OpenStatus int `gorm:"column:open_status" json:"open_status"`
  157. Status int8 `json:"status"` // 状态 0.无效 1.有效 2.禁用
  158. CreateTime int64 `gorm:"column:ctime" json:"ctime"` // 创建时间
  159. ModifyTime int64 `gorm:"column:mtime" json:"mtime"` // 修改时间
  160. Name string `gorm:"column:name" json:"name" form:"name"`
  161. Url string `gorm:"column:url" json:"url" form:"url"`
  162. Pid int64 `gorm:"column:pid" json:"pid" form:"pid"`
  163. Number int64 `gorm:"column:number" json:"order" form:"number"`
  164. VMOrgApp []*VMOrgApp `gorm:"ForeignKey:Pid;AssociationForeignKey:Id" `
  165. }
  166. func (VMOrgApp) TableName() string {
  167. return "sgj_user_org_app"
  168. }
  169. func FindSystemOrgApp() (app []*VMOrgApp, err error) {
  170. err = readUserDb.Model(&VMOrgApp{}).Preload("VMOrgApp", "org_id = 0 AND status =1 AND pid > 0").Where("status = 1 AND org_id = 0 AND pid = 0").Find(&app).Error
  171. return
  172. }
  173. func GetAllOrgByAdminUserId() {
  174. }