business_conf.go 6.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212
  1. package models
  2. import (
  3. "fmt"
  4. "github.com/beego/beego/v2/client/orm"
  5. "html"
  6. "strings"
  7. "time"
  8. )
  9. const (
  10. BusinessConfUseXf = "UseXf"
  11. BusinessConfXfAppid = "XfAppid"
  12. BusinessConfXfApiKey = "XfApiKey"
  13. BusinessConfXfApiSecret = "XfApiSecret"
  14. BusinessConfXfVcn = "XfVcn"
  15. BusinessConfEnPptCoverImgs = "EnPptCoverImgs"
  16. BusinessConfIsReportApprove = "IsReportApprove"
  17. BusinessConfReportApproveType = "ReportApproveType"
  18. BusinessConfCompanyName = "CompanyName"
  19. BusinessConfCompanyWatermark = "CompanyWatermark"
  20. BusinessConfWatermarkChart = "WatermarkChart"
  21. BusinessConfLoginSmsTpId = "LoginSmsTpId"
  22. BusinessConfLoginSmsGjTpId = "LoginSmsGjTpId"
  23. BusinessConfSmsJhgnAppKey = "SmsJhgnAppKey"
  24. BusinessConfSmsJhgjAppKey = "SmsJhgjAppKey"
  25. BusinessConfLdapHost = "LdapHost"
  26. BusinessConfLdapBase = "LdapBase"
  27. BusinessConfLdapPort = "LdapPort"
  28. BusinessConfEmailClient = "EmailClient"
  29. BusinessConfEmailServerHost = "EmailServerHost"
  30. BusinessConfEmailServerPort = "EmailServerPort"
  31. BusinessConfEmailSender = "EmailSender"
  32. BusinessConfEmailSenderUserName = "EmailSenderUserName"
  33. BusinessConfEmailSenderPassword = "EmailSenderPassword"
  34. BusinessConfSmsClient = "SmsClient"
  35. BusinessConfNanHuaSmsAppKey = "NanHuaSmsAppKey"
  36. BusinessConfNanHuaSmsAppSecret = "NanHuaSmsAppSecret"
  37. BusinessConfNanHuaSmsApiHost = "NanHuaSmsApiHost"
  38. BusinessConfLoginSmsTplContent = "LoginSmsTplContent"
  39. BusinessConfLoginEmailTemplateSubject = "LoginEmailTemplateSubject"
  40. BusinessConfLoginEmailTemplateContent = "LoginEmailTemplateContent"
  41. BusinessConfLdapBindUserSuffix = "LdapBindUserSuffix"
  42. BusinessConfLdapUserFilter = "LdapUserFilter"
  43. BusinessConfSmsJhgjVariable = "SmsJhgjVariable" // 聚合国际短信变量
  44. BusinessConfTencentApiSecretId = "TencentApiSecretId" // 腾讯云API-密钥对
  45. BusinessConfTencentApiSecretKey = "TencentApiSecretKey" // 腾讯云API-密钥对
  46. BusinessConfTencentApiRecTaskCallbackUrl = "TencentApiRecTaskCallbackUrl" // 腾讯云API-语音识别回调地址
  47. )
  48. const (
  49. BusinessConfReportApproveTypeEta = "eta"
  50. BusinessConfReportApproveTypeOther = "other"
  51. BusinessConfClientFlagNanHua = "nhqh" // 南华标记
  52. BusinessConfEmailClientSmtp = "smtp" // 普通邮箱标记
  53. )
  54. // BusinessConf 商户配置表
  55. type BusinessConf struct {
  56. Id int `orm:"column(id);pk"`
  57. ConfKey string `description:"配置Key"`
  58. ConfVal string `description:"配置值"`
  59. ValType int `description:"1-字符串;2-数值;3-字符串数组;4-富文本;"`
  60. Necessary int `description:"是否必填:0-否;1-是"`
  61. Remark string `description:"备注"`
  62. CreateTime time.Time
  63. }
  64. func (m *BusinessConf) TableName() string {
  65. return "business_conf"
  66. }
  67. func (m *BusinessConf) PrimaryId() string {
  68. return "id"
  69. }
  70. func (m *BusinessConf) Create() (err error) {
  71. o := orm.NewOrm()
  72. id, err := o.Insert(m)
  73. if err != nil {
  74. return
  75. }
  76. m.Id = int(id)
  77. return
  78. }
  79. func (m *BusinessConf) CreateMulti(items []*BusinessConf) (err error) {
  80. if len(items) == 0 {
  81. return
  82. }
  83. o := orm.NewOrm()
  84. _, err = o.InsertMulti(len(items), items)
  85. return
  86. }
  87. func (m *BusinessConf) Update(cols []string) (err error) {
  88. o := orm.NewOrm()
  89. _, err = o.Update(m, cols...)
  90. return
  91. }
  92. func (m *BusinessConf) Del() (err error) {
  93. o := orm.NewOrm()
  94. sql := fmt.Sprintf(`DELETE FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  95. _, err = o.Raw(sql, m.Id).Exec()
  96. return
  97. }
  98. func (m *BusinessConf) GetItemById(id int) (item *BusinessConf, err error) {
  99. o := orm.NewOrm()
  100. sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
  101. err = o.Raw(sql, id).QueryRow(&item)
  102. return
  103. }
  104. func (m *BusinessConf) GetItemByCondition(condition string, pars []interface{}) (item *BusinessConf, err error) {
  105. o := orm.NewOrm()
  106. sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s LIMIT 1`, m.TableName(), condition)
  107. err = o.Raw(sql, pars).QueryRow(&item)
  108. return
  109. }
  110. func (m *BusinessConf) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
  111. o := orm.NewOrm()
  112. sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
  113. err = o.Raw(sql, pars).QueryRow(&count)
  114. return
  115. }
  116. func (m *BusinessConf) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BusinessConf, err error) {
  117. o := orm.NewOrm()
  118. fields := strings.Join(fieldArr, ",")
  119. if len(fieldArr) == 0 {
  120. fields = `*`
  121. }
  122. order := `ORDER BY create_time DESC`
  123. if orderRule != "" {
  124. order = ` ORDER BY ` + orderRule
  125. }
  126. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
  127. _, err = o.Raw(sql, pars).QueryRows(&items)
  128. return
  129. }
  130. func (m *BusinessConf) GetPageItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, startSize, pageSize int) (items []*BusinessConf, err error) {
  131. o := orm.NewOrm()
  132. fields := strings.Join(fieldArr, ",")
  133. if len(fieldArr) == 0 {
  134. fields = `*`
  135. }
  136. order := `ORDER BY create_time DESC`
  137. if orderRule != "" {
  138. order = ` ORDER BY ` + orderRule
  139. }
  140. sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
  141. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
  142. return
  143. }
  144. // GetBusinessConf 获取商家配置
  145. func GetBusinessConf() (list map[string]string, err error) {
  146. list = make(map[string]string)
  147. var items []*BusinessConf
  148. o := orm.NewOrm()
  149. sql := `SELECT * FROM business_conf`
  150. _, err = o.Raw(sql).QueryRows(&items)
  151. if err != nil {
  152. return
  153. }
  154. for _, v := range items {
  155. if v.ValType == 4 {
  156. list[v.ConfKey] = html.UnescapeString(v.ConfVal)
  157. continue
  158. }
  159. list[v.ConfKey] = v.ConfVal
  160. }
  161. return
  162. }
  163. // BusinessConfUpdate 更新配置
  164. type BusinessConfUpdate struct {
  165. ConfKey string
  166. ConfVal string
  167. }
  168. // UpdateBusinessConfMulti 批量修改配置
  169. func UpdateBusinessConfMulti(items []BusinessConfUpdate) (err error) {
  170. o := orm.NewOrm()
  171. p, err := o.Raw("UPDATE business_conf SET conf_val = ? WHERE conf_key = ?").Prepare()
  172. if err != nil {
  173. return
  174. }
  175. defer func() {
  176. _ = p.Close()
  177. }()
  178. for _, v := range items {
  179. _, err = p.Exec(v.ConfVal, v.ConfKey)
  180. if err != nil {
  181. return
  182. }
  183. }
  184. return
  185. }
  186. func GetBusinessConfByKey(key string) (item *BusinessConf, err error) {
  187. o := orm.NewOrm()
  188. sql := fmt.Sprintf(`SELECT * FROM business_conf WHERE conf_key = ? LIMIT 1`)
  189. err = o.Raw(sql, key).QueryRow(&item)
  190. return
  191. }