chart_permission.go 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343
  1. package services
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/models"
  5. "eta/eta_api/models/company"
  6. "eta/eta_api/utils"
  7. "fmt"
  8. "io/ioutil"
  9. "net/http"
  10. "strings"
  11. )
  12. func GetChartPermissionList() (list []*models.ChartPermission, err error) {
  13. var req GetChartPermissionReq
  14. data, err := getChartPermission(req)
  15. if err != nil {
  16. return
  17. }
  18. list = data.List
  19. return
  20. }
  21. type GetChartPermissionReq struct {
  22. ChartPermissionId int `json:"chart_permission_id"`
  23. ProductId int `json:"product_id"`
  24. }
  25. type GetChartPermissionItem struct {
  26. List []*models.ChartPermission
  27. ParentList []*models.ChartPermission
  28. }
  29. type GetChartPermissionResp struct {
  30. Code int `json:"code" description:"状态码"`
  31. Msg string `json:"msg" description:"提示信息"`
  32. Data GetChartPermissionItem `json:"data" description:"返回数据"`
  33. ErrMsg string `json:"-" description:"错误信息,不用返回给前端,只是做日志记录"`
  34. }
  35. func getChartPermission(pars GetChartPermissionReq) (res GetChartPermissionItem, err error) {
  36. if utils.CrmEtaServerUrl == "" {
  37. return
  38. }
  39. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/list")
  40. if pars.ProductId == 0 {
  41. pars.ProductId = 1 //默认查ficc的品种
  42. }
  43. b, err := crmEtaPost(url, pars)
  44. if err != nil {
  45. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  46. return
  47. }
  48. //result := new(models.ResultData)
  49. result := new(GetChartPermissionResp)
  50. if e := json.Unmarshal(b, &result); e != nil {
  51. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  52. return
  53. }
  54. utils.FileLog.Info("%s", string(b))
  55. if result.Code != 200 {
  56. err = fmt.Errorf("result: %s", string(b))
  57. return
  58. }
  59. res = result.Data
  60. return
  61. }
  62. type ChartPermissionResp struct {
  63. Code int `json:"code" description:"状态码"`
  64. Msg string `json:"msg" description:"提示信息"`
  65. ErrMsg string `json:"-" description:"错误信息,不用返回给前端,只是做日志记录"`
  66. }
  67. type ChartPermissionAddReq struct {
  68. PermissionName string `description:"品种权限名称"`
  69. ParentId int `description:"父级ID"`
  70. Enabled int `description:"是否可用 0禁用, 1启用"` //启用,禁用操作会关联二级品种
  71. IsPublic int `description:"是否是公有权限1:公有权限,0私有权限"`
  72. ProductId int
  73. }
  74. type ChartPermissionEditReq struct {
  75. ChartPermissionId int `description:"品种权限Id"` // 如果ID存在,则是更新操作,否则是新增操作
  76. PermissionName string `description:"品种权限名称"`
  77. Enabled int `description:"是否可用 0禁用, 1启用"` //启用,禁用操作会关联二级品种
  78. IsPublic int `description:"是否是公有权限1:公有权限,0私有权限"`
  79. PublicPermissionIds []int `description:"公有权限的ID列表"` //一级品种没有公有私有属性
  80. }
  81. type ChartPermissionMoveReq struct {
  82. ChartPermissionId int `description:"品种id"`
  83. // ParentChartPermissionId int `description:"父级品种id"`
  84. PrevChartPermissionId int `description:"上一个兄弟节点品种id"`
  85. NextChartPermissionId int `description:"下一个兄弟节点品种id"`
  86. }
  87. func crmEtaPost(url string, pars interface{}) (respBody []byte, err error) {
  88. params, e := json.Marshal(pars)
  89. if e != nil {
  90. err = fmt.Errorf("data json marshal err: %s", e.Error())
  91. return
  92. }
  93. body := ioutil.NopCloser(strings.NewReader(string(params)))
  94. client := &http.Client{}
  95. req, e := http.NewRequest("POST", url, body)
  96. if e != nil {
  97. err = fmt.Errorf("http create request err: %s", e.Error())
  98. return
  99. }
  100. contentType := "application/json;charset=utf-8"
  101. req.Header.Set("Content-Type", contentType)
  102. req.Header.Set("Authorization", utils.CrmEtaAuthorization)
  103. resp, e := client.Do(req)
  104. if e != nil {
  105. err = fmt.Errorf("http client do err: %s", e.Error())
  106. return
  107. }
  108. defer func() {
  109. _ = resp.Body.Close()
  110. }()
  111. b, e := ioutil.ReadAll(resp.Body)
  112. if e != nil {
  113. err = fmt.Errorf("resp body read err: %s", e.Error())
  114. return
  115. }
  116. if len(b) == 0 {
  117. err = fmt.Errorf("resp body is empty")
  118. return
  119. }
  120. // 生产环境解密, 注意有个坑前后的双引号
  121. if utils.RunMode == "release" {
  122. str := string(b)
  123. str = strings.Trim(str, `"`)
  124. b = utils.DesBase64Decrypt([]byte(str), utils.CrmEtaServerDes3Key)
  125. }
  126. respBody = b
  127. return
  128. }
  129. func AddChartPermission(pars *ChartPermissionAddReq) (err error, errMsg string) {
  130. if utils.CrmEtaServerUrl == "" {
  131. return
  132. }
  133. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/add")
  134. if pars.ProductId == 0 {
  135. pars.ProductId = 1 //默认新增ficc的品种
  136. }
  137. b, err := crmEtaPost(url, pars)
  138. if err != nil {
  139. errMsg = "新增品种失败"
  140. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  141. return
  142. }
  143. //result := new(models.ResultData)
  144. result := new(ChartPermissionResp)
  145. if e := json.Unmarshal(b, &result); e != nil {
  146. errMsg = "新增品种失败"
  147. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  148. return
  149. }
  150. utils.FileLog.Info("%s", string(b))
  151. if result.Code != 200 {
  152. err = fmt.Errorf("result: %s, err: %s", string(b), result.ErrMsg)
  153. errMsg = result.Msg
  154. return
  155. }
  156. return
  157. }
  158. func EditChartPermission(pars *ChartPermissionEditReq) (err error, errMsg string) {
  159. if utils.CrmEtaServerUrl == "" {
  160. return
  161. }
  162. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/edit")
  163. b, err := crmEtaPost(url, pars)
  164. if err != nil {
  165. errMsg = "更新品种失败"
  166. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  167. return
  168. }
  169. //result := new(models.ResultData)
  170. result := new(ChartPermissionResp)
  171. if e := json.Unmarshal(b, &result); e != nil {
  172. errMsg = "更新品种失败"
  173. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  174. return
  175. }
  176. utils.FileLog.Info("%s", string(b))
  177. if result.Code != 200 {
  178. err = fmt.Errorf("result: %s, err: %s", string(b), result.ErrMsg)
  179. errMsg = result.Msg
  180. return
  181. }
  182. return
  183. }
  184. func MoveChartPermission(pars *ChartPermissionMoveReq) (err error, errMsg string) {
  185. if utils.CrmEtaServerUrl == "" {
  186. return
  187. }
  188. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/move")
  189. b, err := crmEtaPost(url, pars)
  190. if err != nil {
  191. errMsg = "移动品种失败"
  192. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  193. return
  194. }
  195. //result := new(models.ResultData)
  196. result := new(ChartPermissionResp)
  197. if e := json.Unmarshal(b, &result); e != nil {
  198. errMsg = "移动品种失败"
  199. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  200. return
  201. }
  202. utils.FileLog.Info("%s", string(b))
  203. if result.Code != 200 {
  204. err = fmt.Errorf("result: %s, err: %s", string(b), result.ErrMsg)
  205. errMsg = result.Msg
  206. return
  207. }
  208. return
  209. }
  210. // GetChartPermissionEnabledList 查询已启用的FICC权限列表
  211. func GetChartPermissionEnabledList() (list []*company.PermissionSetList, err error) {
  212. var req GetChartPermissionReq
  213. data, err := getChartPermission(req)
  214. if err != nil {
  215. return
  216. }
  217. dataList := data.List
  218. //enabledList := make([]*models.ChartPermission, 0)
  219. parentList := make([]*models.ChartPermission, 0)
  220. enabledMap := make(map[int][]*company.PermissionSetItem)
  221. listMap := make(map[int]*models.ChartPermission)
  222. for _, v := range dataList {
  223. listMap[v.ChartPermissionId] = v
  224. if v.ParentId == 0 {
  225. parentList = append(parentList, v)
  226. }
  227. if v.Enabled == 1 && v.ParentId > 0 && v.PermissionType == 0 {
  228. //enabledList = append(enabledList, v)
  229. item := &company.PermissionSetItem{
  230. ChartPermissionId: v.ChartPermissionId,
  231. PermissionName: v.PermissionName,
  232. PermissionType: v.PermissionType,
  233. }
  234. enabledMap[v.ParentId] = append(enabledMap[v.ParentId], item)
  235. }
  236. }
  237. for _, v := range parentList {
  238. items, ok := enabledMap[v.ChartPermissionId]
  239. if !ok {
  240. continue
  241. }
  242. checkList := make([]int, 0)
  243. p := new(company.PermissionSetList)
  244. p.PermissionName = v.PermissionName
  245. p.Child = items
  246. if v.PermissionName == "宏观经济" {
  247. checkList = append(checkList, 1)
  248. }
  249. p.CheckList = checkList
  250. list = append(list, p)
  251. }
  252. return
  253. }
  254. type EditClassifyPermissionReq struct {
  255. Keyword string
  256. ChartPermissionIdList []int `description:"权限id数组"`
  257. NewKeyword string
  258. }
  259. // GetClassifyChartPermission 获取报告分类已绑定的权限
  260. func GetClassifyChartPermission(classifyName string) (list []*models.ChartPermissionSearchKeyWordMapping, err error) {
  261. if utils.CrmEtaServerUrl == "" {
  262. return
  263. }
  264. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/classify")
  265. var req ClassifyPermissionReq
  266. req.Keyword = classifyName
  267. b, err := crmEtaPost(url, req)
  268. if err != nil {
  269. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  270. return
  271. }
  272. //result := new(models.ResultData)
  273. result := new(GetClassifyChartPermissionResp)
  274. if e := json.Unmarshal(b, &result); e != nil {
  275. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  276. return
  277. }
  278. utils.FileLog.Info("%s", string(b))
  279. if result.Code != 200 {
  280. err = fmt.Errorf("result: %s", string(b))
  281. return
  282. }
  283. list = result.Data.List
  284. return
  285. }
  286. type ClassifyPermissionReq struct {
  287. Keyword string
  288. }
  289. type ClassifyPermissionList struct {
  290. List []*models.ChartPermissionSearchKeyWordMapping
  291. }
  292. type GetClassifyChartPermissionResp struct {
  293. Code int `json:"code" description:"状态码"`
  294. Msg string `json:"msg" description:"提示信息"`
  295. Data ClassifyPermissionList `json:"data" description:"返回数据"`
  296. ErrMsg string `json:"-" description:"错误信息,不用返回给前端,只是做日志记录"`
  297. }
  298. // EditClassifyChartPermission 设置报告分类权限
  299. func EditClassifyChartPermission(req EditClassifyPermissionReq) (err error) {
  300. if utils.CrmEtaServerUrl == "" {
  301. return
  302. }
  303. url := fmt.Sprint(utils.CrmEtaServerUrl, "/api/crm/chart_permission/classify/edit")
  304. b, err := crmEtaPost(url, req)
  305. if err != nil {
  306. err = fmt.Errorf("url:%s err: %s", url, err.Error())
  307. return
  308. }
  309. //result := new(models.ResultData)
  310. result := new(ChartPermissionResp)
  311. if e := json.Unmarshal(b, &result); e != nil {
  312. err = fmt.Errorf("result unmarshal err: %s\nresult: %s", e.Error(), string(b))
  313. return
  314. }
  315. utils.FileLog.Info("%s", string(b))
  316. if result.Code != 200 {
  317. err = fmt.Errorf("result: %s", string(b))
  318. return
  319. }
  320. return
  321. }