business_conf.go 6.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/models"
  5. "eta/eta_api/services"
  6. "eta/eta_api/utils"
  7. "fmt"
  8. "html"
  9. "strconv"
  10. "strings"
  11. "time"
  12. )
  13. // BusinessConfController 商家配置
  14. type BusinessConfController struct {
  15. BaseAuthController
  16. }
  17. type BusinessConfOpenController struct {
  18. BaseCommonController
  19. }
  20. // Save
  21. // @Title 保存配置
  22. // @Description 保存配置
  23. // @Param request body map[string]interface{} true "type json string"
  24. // @Success 200 Ret=200 操作成功
  25. // @router /save [post]
  26. func (this *BusinessConfController) Save() {
  27. br := new(models.BaseResponse).Init()
  28. defer func() {
  29. if br.ErrMsg == "" {
  30. br.IsSendEmail = false
  31. }
  32. this.Data["json"] = br
  33. this.ServeJSON()
  34. }()
  35. sysUser := this.SysUser
  36. if sysUser == nil {
  37. br.Msg = "请登录"
  38. br.ErrMsg = "请登录,SysUser Is Empty"
  39. br.Ret = 408
  40. return
  41. }
  42. var req map[string]interface{}
  43. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  44. br.Msg = "参数解析异常!"
  45. br.ErrMsg = "参数解析失败,Err:" + e.Error()
  46. return
  47. }
  48. // 获取配置信息
  49. confOb := new(models.BusinessConf)
  50. list, e := confOb.GetItemsByCondition("", make([]interface{}, 0), []string{}, "")
  51. if e != nil {
  52. br.Msg = "保存失败"
  53. br.ErrMsg = "获取配置列表失败, Err: " + e.Error()
  54. return
  55. }
  56. confMap := make(map[string]*models.BusinessConf)
  57. for _, c := range list {
  58. confMap[c.ConfKey] = c
  59. }
  60. openApprove := ""
  61. approveType := ""
  62. // 根据配置类型取值
  63. updates := make([]models.BusinessConfUpdate, 0)
  64. for k, v := range req {
  65. // 过滤掉表中没有的key
  66. conf := confMap[k]
  67. if conf == nil {
  68. continue
  69. }
  70. switch conf.ValType {
  71. case 1: // 字符串
  72. str, ok := v.(string)
  73. if !ok {
  74. continue
  75. }
  76. str = strings.TrimSpace(str)
  77. if conf.Necessary == 1 && str == "" {
  78. br.Msg = conf.Remark + "不可为空"
  79. return
  80. }
  81. updates = append(updates, models.BusinessConfUpdate{
  82. ConfKey: k,
  83. ConfVal: str,
  84. })
  85. // 取出审批参数
  86. if k == models.BusinessConfIsReportApprove {
  87. openApprove = str
  88. }
  89. if k == models.BusinessConfReportApproveType {
  90. approveType = str
  91. }
  92. case 2: // 数值
  93. num, ok := v.(float64)
  94. if !ok {
  95. continue
  96. }
  97. if conf.Necessary == 1 && num <= 0 {
  98. br.Msg = conf.Remark + "不可为空"
  99. return
  100. }
  101. val := strconv.FormatFloat(num, 'f', 0, 64)
  102. updates = append(updates, models.BusinessConfUpdate{
  103. ConfKey: k,
  104. ConfVal: val,
  105. })
  106. case 3: // 字符串数组
  107. arr, ok := v.([]interface{})
  108. if !ok {
  109. continue
  110. }
  111. if conf.Necessary == 1 && len(arr) == 0 {
  112. br.Msg = conf.Remark + "不可为空"
  113. return
  114. }
  115. strArr := make([]string, 0)
  116. for _, a := range arr {
  117. if s, ok2 := a.(string); ok2 {
  118. strArr = append(strArr, s)
  119. }
  120. }
  121. val := strings.Join(strArr, ",")
  122. updates = append(updates, models.BusinessConfUpdate{
  123. ConfKey: k,
  124. ConfVal: val,
  125. })
  126. case 4: // 富文本
  127. content, ok := v.(string)
  128. if !ok {
  129. continue
  130. }
  131. content = strings.TrimSpace(content)
  132. if conf.Necessary == 1 && content == "" {
  133. br.Msg = conf.Remark + "不可为空"
  134. return
  135. }
  136. content = html.EscapeString(content)
  137. updates = append(updates, models.BusinessConfUpdate{
  138. ConfKey: k,
  139. ConfVal: content,
  140. })
  141. }
  142. }
  143. // 校验报告审批是否可以切换
  144. confOpenApprove := confMap[models.BusinessConfIsReportApprove]
  145. confApproveType := confMap[models.BusinessConfReportApproveType]
  146. if confOpenApprove != nil && confApproveType != nil {
  147. // 仅校验有审批->无审批, 或是有审批->切换审批方式的情况
  148. if openApprove == "false" && confOpenApprove.ConfVal == "true" || (openApprove == "true" && openApprove == confOpenApprove.ConfVal && confApproveType.ConfVal != approveType) {
  149. ok, e := services.CheckCloseReportApproveConf()
  150. if e != nil {
  151. br.Msg = "保存失败"
  152. br.ErrMsg = "校验是否可以关闭报告审批失败, Err: " + e.Error()
  153. return
  154. }
  155. if !ok {
  156. br.Msg = "当前有未走完流程的报告,请走完流程后再做变更"
  157. return
  158. }
  159. }
  160. // 审批设置切换对未发布/待提交报告状态的重置
  161. needReset := false
  162. changeType := ""
  163. if openApprove == "false" && confOpenApprove.ConfVal == "true" {
  164. needReset = true
  165. }
  166. if openApprove == "true" && openApprove == confOpenApprove.ConfVal && confApproveType.ConfVal != approveType {
  167. needReset = false
  168. changeType = approveType
  169. }
  170. if needReset {
  171. go services.ConfigChangeResetReportState(changeType)
  172. }
  173. }
  174. if len(updates) > 0 {
  175. if e = models.UpdateBusinessConfMulti(updates); e != nil {
  176. br.Msg = "保存失败"
  177. br.ErrMsg = "保存商家配置失败, Err: " + e.Error()
  178. return
  179. }
  180. }
  181. // 操作日志
  182. go func() {
  183. b, e := json.Marshal(req)
  184. if e != nil {
  185. return
  186. }
  187. recordOb := new(models.BusinessConfOperationRecord)
  188. recordOb.SysUserId = sysUser.AdminId
  189. recordOb.SysRealName = sysUser.RealName
  190. recordOb.Content = string(b)
  191. recordOb.CreateTime = time.Now().Local()
  192. _ = recordOb.Create()
  193. }()
  194. br.Ret = 200
  195. br.Success = true
  196. br.Msg = "操作成功"
  197. }
  198. // Fetch
  199. // @Title 获取配置
  200. // @Description 获取配置
  201. // @Success 200 Ret=200 获取成功
  202. // @router /fetch [get]
  203. func (this *BusinessConfController) Fetch() {
  204. br := new(models.BaseResponse).Init()
  205. defer func() {
  206. if br.ErrMsg == "" {
  207. br.IsSendEmail = false
  208. }
  209. this.Data["json"] = br
  210. this.ServeJSON()
  211. }()
  212. sysUser := this.SysUser
  213. if sysUser == nil {
  214. br.Msg = "请登录"
  215. br.ErrMsg = "请登录,SysUser Is Empty"
  216. br.Ret = 408
  217. return
  218. }
  219. list, e := models.GetBusinessConf()
  220. if e != nil {
  221. br.Msg = "获取失败"
  222. br.ErrMsg = "获取商家配置失败, Err: " + e.Error()
  223. return
  224. }
  225. br.Data = list
  226. br.Ret = 200
  227. br.Success = true
  228. br.Msg = "获取成功"
  229. }
  230. // CodeEncrypt
  231. // @Title 商家编码加密
  232. // @Description 商家编码加密
  233. // @Success 200 Ret=200 获取成功
  234. // @router /code_encrypt [get]
  235. func (this *BusinessConfOpenController) CodeEncrypt() {
  236. br := new(models.BaseResponse).Init()
  237. defer func() {
  238. if br.ErrMsg == "" {
  239. br.IsSendEmail = false
  240. }
  241. this.Data["json"] = br
  242. this.ServeJSON()
  243. }()
  244. res := ""
  245. if utils.BusinessCode != "" {
  246. res = utils.MD5(fmt.Sprintf("%s%s", utils.BusinessCode, utils.BusinessCodeSalt))
  247. }
  248. br.Data = res
  249. br.Ret = 200
  250. br.Success = true
  251. br.Msg = "获取成功"
  252. }