sandbox.go 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404
  1. package sandbox
  2. import (
  3. "eta/eta_api/models/system"
  4. "eta/eta_api/utils"
  5. "fmt"
  6. "github.com/beego/beego/v2/client/orm"
  7. "github.com/rdlucklib/rdluck_tools/paging"
  8. "time"
  9. )
  10. // Sandbox 沙盘推演主表
  11. //type Sandbox struct {
  12. // SandboxId int `orm:"column(sandbox_id);pk" description:"沙盘id"`
  13. // Name string `description:"沙盘名称"`
  14. // ChartPermissionId int `description:"品种id"`
  15. // ChartPermissionName string `description:"品种名称"`
  16. // CurrVersion int `description:"当前版本"`
  17. // Code string `description:"沙盘code"`
  18. // Content string `description:"沙盘数据"`
  19. // PicUrl string `description:"沙盘图片地址"`
  20. // OpUserId int `description:"最近一次编辑操作的用户id"`
  21. // OpUserName string `description:"最近一次编辑的用户名称(冗余字段,避免查表)"`
  22. // IsDelete int8 `description:"是否删除,0:未删除,1:已删除"`
  23. // ModifyTime time.Time `description:"修改时间"`
  24. // CreateTime time.Time `description:"创建时间"`
  25. // SandboxClassifyId int `description:"分类id"`
  26. // Sort int `description:"排序"`
  27. //}
  28. type Sandbox struct {
  29. SandboxId int `orm:"column(sandbox_id);pk" description:"沙盘id"`
  30. Name string `description:"沙盘名称"`
  31. Code string `description:"沙盘code"`
  32. Content string `description:"沙盘数据"`
  33. PicUrl string `description:"沙盘图片地址"`
  34. SysUserId int `description:"作者id"`
  35. SysUserName string `description:"作者名称"`
  36. IsDelete int8 `description:"是否删除,0:未删除,1:已删除"`
  37. ModifyTime time.Time `description:"修改时间"`
  38. CreateTime time.Time `description:"创建时间"`
  39. SandboxClassifyId int `description:"分类id"`
  40. Sort int `description:"排序"`
  41. }
  42. // Update 沙盘字段变更
  43. func (sandbox *Sandbox) Update(cols []string) (err error) {
  44. o := orm.NewOrmUsingDB("data")
  45. _, err = o.Update(sandbox, cols...)
  46. return
  47. }
  48. // GetSandboxById 根据沙盘id获取沙盘详情
  49. func GetSandboxById(sandboxId int) (sandboxInfo *Sandbox, err error) {
  50. o := orm.NewOrmUsingDB("data")
  51. sql := `select * from sandbox where sandbox_id = ? and is_delete = 0`
  52. err = o.Raw(sql, sandboxId).QueryRow(&sandboxInfo)
  53. return
  54. }
  55. // AddNewSandbox 添加一个新的沙盘
  56. func AddNewSandbox(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft) (err error) {
  57. o := orm.NewOrmUsingDB("data")
  58. to, err := o.Begin()
  59. if err != nil {
  60. return
  61. }
  62. defer func() {
  63. if err != nil {
  64. _ = to.Rollback()
  65. } else {
  66. _ = to.Commit()
  67. }
  68. }()
  69. id, err := to.Insert(sandboxInfo)
  70. if err != nil {
  71. return
  72. }
  73. sandboxInfo.SandboxId = int(id)
  74. // 新增版本
  75. sandboxVersion.SandboxId = sandboxInfo.SandboxId
  76. id, err = to.Insert(sandboxVersion)
  77. if err != nil {
  78. return
  79. }
  80. sandboxVersion.SandboxVersionId = int(id)
  81. // 新增草稿
  82. sandboxDraft.SandboxId = sandboxInfo.SandboxId
  83. id, err = to.Insert(sandboxDraft)
  84. if err != nil {
  85. return
  86. }
  87. sandboxDraft.SandboxDraftId = int(id)
  88. return
  89. }
  90. // UpdateSandbox 更新沙盘
  91. func UpdateSandbox(sandboxInfo *Sandbox, updateSandboxColumn []string, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft) (err error) {
  92. o := orm.NewOrmUsingDB("data")
  93. to, err := o.Begin()
  94. if err != nil {
  95. return
  96. }
  97. defer func() {
  98. if err != nil {
  99. _ = to.Rollback()
  100. } else {
  101. _ = to.Commit()
  102. }
  103. }()
  104. _, err = to.Update(sandboxInfo, updateSandboxColumn...)
  105. if err != nil {
  106. return
  107. }
  108. // 新增版本
  109. sandboxVersion.SandboxId = sandboxInfo.SandboxId
  110. id, err := to.Insert(sandboxVersion)
  111. if err != nil {
  112. return
  113. }
  114. sandboxVersion.SandboxVersionId = int(id)
  115. // 新增草稿
  116. sandboxDraft.SandboxId = sandboxInfo.SandboxId
  117. id, err = to.Insert(sandboxDraft)
  118. if err != nil {
  119. return
  120. }
  121. sandboxDraft.SandboxDraftId = int(id)
  122. return
  123. }
  124. // UpdateSandboxName 更新沙盘(仅仅更新名称)
  125. func UpdateSandboxName(sandboxInfo *Sandbox, sandboxVersion *SandboxVersion, sandboxDraft *SandboxDraft, updateSandboxColumn, updateSandboxVersionColumn []string) (err error) {
  126. o := orm.NewOrmUsingDB("data")
  127. to, err := o.Begin()
  128. if err != nil {
  129. return
  130. }
  131. defer func() {
  132. if err != nil {
  133. _ = to.Rollback()
  134. } else {
  135. _ = to.Commit()
  136. }
  137. }()
  138. _, err = to.Update(sandboxInfo, updateSandboxColumn...)
  139. if err != nil {
  140. return
  141. }
  142. // 更新版本
  143. _, err = to.Update(sandboxVersion, updateSandboxVersionColumn...)
  144. if err != nil {
  145. return
  146. }
  147. // 新增草稿
  148. sandboxDraft.SandboxId = sandboxInfo.SandboxId
  149. id, err := to.Insert(sandboxDraft)
  150. if err != nil {
  151. return
  152. }
  153. sandboxDraft.SandboxDraftId = int(id)
  154. return
  155. }
  156. // SandboxListItem 沙盘推演列表数据
  157. type SandboxListItem struct {
  158. SandboxId int `description:"沙盘id"`
  159. Name string `description:"沙盘名称"`
  160. ChartPermissionId int `description:"品种id"`
  161. ChartPermissionName string `description:"品种名称"`
  162. CurrVersion int `description:"当前版本"`
  163. Code string `description:"沙盘code"`
  164. VersionCode string `description:"沙盘版本code"`
  165. //Content string `description:"沙盘数据"`
  166. PicUrl string `description:"沙盘图片地址"`
  167. OpUserId int `description:"最近一次编辑操作的用户id"`
  168. OpUserName string `description:"最近一次编辑的用户名称(冗余字段,避免查表)"`
  169. IsDelete int8 `description:"是否删除,0:未删除,1:已删除" json:"is_delete"`
  170. CanEdit bool `description:"是否可编辑"`
  171. Editor string `description:"编辑人"`
  172. VersionTotal int `description:"历史版本数量"`
  173. ModifyTime time.Time `description:"修改时间"`
  174. CreateTime time.Time `description:"创建时间"`
  175. }
  176. // GetList 获取沙盘列表页
  177. // todo 测试服兼容
  178. func GetList(condition string, pars []interface{}, startSize, pageSize int) (total int, list []*SandboxListItem, err error) {
  179. o := orm.NewOrmUsingDB("data")
  180. sql := "select a.sandbox_id,a.name,a.chart_permission_id,a.chart_permission_name,a.curr_version,a.code,a.pic_url,a.op_user_id,a.op_user_name,a.modify_time,a.create_time,b.version_code from sandbox_bak_20231018 as a join sandbox_version b on a.sandbox_id=b.sandbox_id and a.curr_version=b.curr_version where 1=1 AND a.is_delete = 0 "
  181. sql += condition
  182. sql += ` order by a.modify_time desc,a.sandbox_id desc`
  183. totalSql := `select count(1) total from (` + sql + `) z `
  184. err = o.Raw(totalSql, pars).QueryRow(&total)
  185. if err != nil {
  186. return
  187. }
  188. sql += ` LIMIT ?,? `
  189. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&list)
  190. return
  191. }
  192. // SandboxSaveResp 保存沙盘响应体
  193. type SandboxSaveResp struct {
  194. *Sandbox
  195. VersionCode string `description:"版本号"`
  196. }
  197. func GetSandboxAll() (list []*SandboxClassifyItems, err error) {
  198. o := orm.NewOrmUsingDB("data")
  199. sql := `SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name, sort
  200. FROM sandbox `
  201. _, err = o.Raw(sql).QueryRows(&list)
  202. return
  203. }
  204. // CheckOpSandboxPermission 判断沙盘操作权限
  205. func CheckOpSandboxPermission(sysUser *system.Admin, createUserId int) (ok bool) {
  206. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN {
  207. ok = true
  208. }
  209. // 如果图表创建人与当前操作人相同的话,那么就是允许操作
  210. if ok == false && createUserId == sysUser.AdminId {
  211. ok = true
  212. }
  213. // 如果图表权限id 是 1 ,那么允许编辑
  214. if ok == false && sysUser.ChartPermission == 1 {
  215. ok = true
  216. }
  217. return
  218. }
  219. // GetSandboxInfoByAdminId 获取所有我创建的沙盘,用于分类展示
  220. func GetSandboxInfoByAdminId(adminId int) (items []*SandboxClassifyItems, err error) {
  221. o := orm.NewOrmUsingDB("data")
  222. sql := ` SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name,code,
  223. sys_user_id,sys_user_name
  224. FROM sandbox where sys_user_id = ? ORDER BY sort asc,create_time ASC `
  225. _, err = o.Raw(sql, adminId).QueryRows(&items)
  226. return
  227. }
  228. func GetSandboxClassify(sandboxClassifyId int) (sandbox_classify_id string, err error) {
  229. o := orm.NewOrmUsingDB("data")
  230. sql := `SELECT GROUP_CONCAT(t.sandbox_classify_id) AS sandbox_classify_id FROM (
  231. SELECT a.sandbox_classify_id FROM sandbox_classify AS a
  232. WHERE a.sandbox_classify_id=?
  233. UNION ALL
  234. SELECT a.sandbox_classify_id FROM sandbox_classify AS a
  235. WHERE a.parent_id=? UNION ALL
  236. SELECT
  237. sandbox_classify_id
  238. FROM
  239. sandbox_classify
  240. WHERE
  241. parent_id IN ( SELECT sandbox_classify_id FROM sandbox_classify WHERE parent_id = ? )
  242. )AS t`
  243. err = o.Raw(sql, sandboxClassifyId, sandboxClassifyId, sandboxClassifyId).QueryRow(&sandbox_classify_id)
  244. return
  245. }
  246. type SandboxListItems struct {
  247. Sandbox
  248. ParentIds string
  249. }
  250. func GetSandboxListByCondition(condition string, pars []interface{}, startSize, pageSize int) (item []*SandboxListItems, err error) {
  251. o := orm.NewOrmUsingDB("data")
  252. sql := ` SELECT * FROM sandbox WHERE 1=1 `
  253. if condition != "" {
  254. sql += condition
  255. }
  256. sql += " ORDER BY create_time DESC LIMIT ?,? "
  257. _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&item)
  258. return
  259. }
  260. func GetSandboxListCountByCondition(condition string, pars []interface{}) (count int, err error) {
  261. o := orm.NewOrmUsingDB("data")
  262. sql := ` SELECT COUNT(1) AS count FROM sandbox WHERE 1=1 `
  263. if condition != "" {
  264. sql += condition
  265. }
  266. err = o.Raw(sql, pars).QueryRow(&count)
  267. return
  268. }
  269. type SandboxListResp struct {
  270. Paging *paging.PagingItem
  271. List []*SandboxListItems
  272. }
  273. func AddSandbox(item *Sandbox) (lastId int64, err error) {
  274. o := orm.NewOrmUsingDB("data")
  275. lastId, err = o.Insert(item)
  276. return
  277. }
  278. func GetSandboxItemsByClassifyId(sandboxClassifyId int) (list []*SandboxClassifyItems, err error) {
  279. o := orm.NewOrmUsingDB("data")
  280. sql := `SELECT sandbox_id,sandbox_classify_id,name AS sandbox_classify_name, sort
  281. FROM sandbox WHERE sandbox_classify_id = ? AND is_delete = 0 ORDER BY sort `
  282. _, err = o.Raw(sql, sandboxClassifyId).QueryRows(&list)
  283. return
  284. }
  285. func GetSandboxAllParentByClassifyId(sandboxClassifyId int) (ids string, err error) {
  286. o := orm.NewOrmUsingDB("data")
  287. sql := `SELECT
  288. GROUP_CONCAT(DISTINCT m.sandbox_classify_id ORDER BY m.level) AS ids
  289. FROM
  290. (
  291. SELECT
  292. @id AS _id,(
  293. SELECT
  294. @id := parent_id
  295. FROM
  296. sandbox_classify
  297. WHERE
  298. sandbox_classify_id = _id
  299. )
  300. FROM
  301. (
  302. SELECT
  303. @id :=(
  304. SELECT
  305. parent_id
  306. FROM
  307. sandbox_classify
  308. WHERE
  309. sandbox_classify_id = ?
  310. )) vm,
  311. sandbox_classify m
  312. WHERE
  313. @id IS NOT NULL
  314. ) vm
  315. INNER JOIN sandbox_classify m
  316. WHERE
  317. sandbox_classify_id = vm._id `
  318. err = o.Raw(sql, sandboxClassifyId).QueryRow(&ids)
  319. return
  320. }
  321. type MoveSandboxReq struct {
  322. SandboxId int `description:"沙盘ID"`
  323. PrevSandboxId int `description:"上一个沙盘ID"`
  324. NextSandboxId int `description:"下一个沙盘ID"`
  325. SandboxClassifyId int `description:"分类id"`
  326. }
  327. func GetSandboxClassifyCountById(classifyId int) (count int, err error) {
  328. o := orm.NewOrmUsingDB("data")
  329. sql := `SELECT count(1) AS count FROM sandbox_classify WHERE sandbox_classify_id=? `
  330. err = o.Raw(sql, classifyId).QueryRow(&count)
  331. return
  332. }
  333. // GetSandboxByClassifyIdAndName 根据分类id和沙盘名获取图表信息
  334. func GetSandboxByClassifyIdAndName(classifyId int, name string) (item *Sandbox, err error) {
  335. o := orm.NewOrmUsingDB("data")
  336. sql := ` SELECT * FROM sandbox WHERE sandbox_classify_id = ? and name=? `
  337. err = o.Raw(sql, classifyId, name).QueryRow(&item)
  338. return
  339. }
  340. func MoveSandbox(sandboxId, classifyId int) (err error) {
  341. o := orm.NewOrmUsingDB("data")
  342. sql := ` UPDATE sandbox
  343. SET
  344. sandbox_classify_id = ?
  345. WHERE sandbox_id = ?`
  346. _, err = o.Raw(sql, classifyId, sandboxId).Exec()
  347. return
  348. }
  349. // UpdateSandboxSortByClassifyId 根据沙盘id更新排序
  350. func UpdateSandboxSortByClassifyId(classifyId, nowSort, prevSandboxId int, updateSort string) (err error) {
  351. o := orm.NewOrmUsingDB("data")
  352. sql := ` update sandbox set sort = ` + updateSort + ` WHERE sandbox_classify_id=? AND `
  353. if prevSandboxId > 0 {
  354. sql += ` (sort > ? or (sandbox_id > ` + fmt.Sprint(prevSandboxId) + ` and sort = ` + fmt.Sprint(nowSort) + `))`
  355. }
  356. _, err = o.Raw(sql, classifyId, nowSort).Exec()
  357. return
  358. }
  359. // GetFirstSandboxByClassifyId 获取当前分类下,且排序数相同 的排序第一条的数据
  360. func GetFirstSandboxByClassifyId(classifyId int) (item *Sandbox, err error) {
  361. o := orm.NewOrmUsingDB("data")
  362. sql := ` SELECT * FROM sandbox WHERE sandbox_classify_id=? order by sort asc,sandbox_id asc limit 1`
  363. err = o.Raw(sql, classifyId).QueryRow(&item)
  364. return
  365. }