SystemController.go 102 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016301730183019302030213022302330243025302630273028302930303031303230333034303530363037303830393040304130423043304430453046304730483049305030513052305330543055305630573058305930603061306230633064306530663067306830693070307130723073307430753076307730783079308030813082308330843085308630873088308930903091309230933094309530963097309830993100310131023103310431053106310731083109311031113112311331143115311631173118311931203121312231233124312531263127312831293130313131323133313431353136313731383139314031413142314331443145314631473148314931503151315231533154315531563157315831593160316131623163316431653166316731683169317031713172317331743175317631773178317931803181318231833184318531863187318831893190319131923193319431953196319731983199320032013202320332043205320632073208320932103211321232133214321532163217321832193220322132223223322432253226322732283229323032313232323332343235323632373238323932403241324232433244324532463247324832493250325132523253325432553256325732583259326032613262326332643265326632673268326932703271327232733274327532763277327832793280328132823283328432853286328732883289329032913292329332943295329632973298329933003301330233033304330533063307330833093310331133123313331433153316331733183319332033213322332333243325332633273328332933303331333233333334333533363337333833393340334133423343334433453346334733483349335033513352335333543355335633573358335933603361336233633364336533663367336833693370337133723373337433753376337733783379338033813382338333843385338633873388338933903391339233933394339533963397339833993400340134023403340434053406340734083409341034113412341334143415341634173418341934203421342234233424342534263427342834293430343134323433343434353436343734383439344034413442344334443445344634473448344934503451345234533454345534563457
  1. package partial
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "html/template"
  7. "git.qianqiusoft.com/qianqiusoft/light-apiengine/entitys"
  8. "git.qianqiusoft.com/qianqiusoft/light-apiengine/logs"
  9. "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
  10. sysmodel "git.qianqiusoft.com/qianqiusoft/light-apiengine/models"
  11. sysutils "git.qianqiusoft.com/qianqiusoft/light-apiengine/utils"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. // _Sidebar
  17. // @Title _Sidebar
  18. // @Description 获取导航菜单
  19. // @Param user string false "用户id"
  20. // @Success 200 {object} Account
  21. // @Failure 403 :id is empty
  22. func System_Sidebar(c *entitys.CtrlContext) {
  23. //System_GetMenuTree(c)
  24. _type := c.Ctx.DefaultQuery("type", "")
  25. type_op := c.Ctx.DefaultQuery("type_op", "")
  26. hidden := c.Ctx.DefaultQuery("hidden", "")
  27. name := c.Ctx.DefaultQuery("name", "")
  28. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  29. tk, _ := c.Ctx.Get("token")
  30. user := tk.(*entitys.Token)
  31. op := template.HTML(type_op)
  32. // exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user.UserId, "5c38ee66-c5e6-40a7-b190-86d115bae3e5").Exist()
  33. // 管理员角色Code LAadmin
  34. exist, _ := c.Db.SQL(`SELECT sys_user_role.id FROM sys_user_role,sys_role
  35. WHERE sys_user_role.role_id=sys_role.id
  36. AND sys_user_role.del_flag=0
  37. AND sys_role.del_flag=0
  38. AND sys_role.code=?
  39. AND sys_user_role.user_id=?`, "LAadmin", user.UserId).Exist()
  40. //如果是管理员
  41. var paramMap_i_t map[string]interface{}
  42. if exist {
  43. paramMap_i_t = map[string]interface{}{"user_id": "", "name": name, "cn_id": cn_id, "sort": "name", "type": _type, "type_op": op, "hidden": hidden}
  44. } else {
  45. paramMap_i_t = map[string]interface{}{"user_id": user.UserId, "name": name, "cn_id": cn_id, "sort": "name", "type": _type, "type_op": op, "hidden": hidden}
  46. }
  47. result, err := sysutils.TreeSearch(c.Db, "system", "get_menu_tree", "sys_menu", paramMap_i_t)
  48. if err == nil {
  49. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  50. } else {
  51. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  52. }
  53. }
  54. // _GetMenuTree
  55. // @Title _GetMenuTree
  56. // @Description 获取系统菜单
  57. // @Param user string false "用户id"
  58. // @Success 200 {object} Account
  59. // @Failure 403 :id is empty
  60. func System_GetMenuTree(c *entitys.CtrlContext) {
  61. _type := c.Ctx.DefaultQuery("type", "")
  62. type_op := c.Ctx.DefaultQuery("type_op", "")
  63. hidden := c.Ctx.DefaultQuery("hidden", "")
  64. name := c.Ctx.DefaultQuery("name", "")
  65. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  66. op := template.HTML(type_op)
  67. paramMap_i_t := map[string]interface{}{"user_id": "", "name": name, "cn_id": cn_id, "sort": "name", "type": _type, "type_op": op, "hidden": hidden}
  68. result, err := sysutils.TreeSearch(c.Db, "system", "get_menu_tree", "sys_menu", paramMap_i_t)
  69. if err == nil {
  70. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  71. } else {
  72. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  73. }
  74. }
  75. // _GetDomainTree
  76. // @Title _GetDomainTree
  77. // @Description 获取域树
  78. // @Success 200 {object} Account
  79. // @Failure 403 :id is empty
  80. func System_GetDomainTree(c *entitys.CtrlContext) {
  81. del_flag := c.Ctx.DefaultQuery("del_flag", "")
  82. paramMap_i_t := map[string]interface{}{"sort": "name", "del_flag": del_flag}
  83. result, err := sysutils.TreeSearch(c.Db, "system", "get_domain_tree", "sys_domain", paramMap_i_t)
  84. if err == nil {
  85. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  86. } else {
  87. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  88. }
  89. }
  90. // _FindUserPage
  91. // @Title _FindUserPage
  92. // @Description 获取用户分页数
  93. // @Success 200 {object} Account
  94. // @Failure 403 :id is empty
  95. func System_FindUserPage(c *entitys.CtrlContext) {
  96. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  97. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  98. name := c.Ctx.DefaultQuery("name", "")
  99. login_id := c.Ctx.DefaultQuery("login_id", "")
  100. org_id := c.Ctx.DefaultQuery("org_id", "")
  101. cn_org_id := c.Ctx.DefaultQuery("cn_org_id", "")
  102. role_name := c.Ctx.DefaultQuery("role_name", "")
  103. var roleRule interface{}
  104. rule_code := "org_tree"
  105. user_id := c.Ctx.GetString("user_id")
  106. exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user_id, "5c38ee66-c5e6-40a7-b190-86d115bae3e5").Exist()
  107. //如果是管理员
  108. if exist {
  109. user_id = ""
  110. roleRule = ""
  111. } else if rule_code != "" {
  112. var roleRules []models.SysDataPermissionDetail
  113. // 根据rule_code获取角色对应的接口规则
  114. err := c.Db.SqlMapClient("get_user_rule_by_code", rule_code, user_id).Find(&roleRules)
  115. if err != nil {
  116. roleRule = ""
  117. } else {
  118. roleRule = sysutils.ParseRule(roleRules)
  119. }
  120. }
  121. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "login_id": login_id, "org_id": org_id, "cn_org_id": cn_org_id, "user_id": user_id, "role_name": role_name, "role_rule": roleRule}
  122. result, err := sysutils.PageSearch(c.Db, "system", "find_user_page", "sys_user", paramMap_i_t)
  123. if err != nil {
  124. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), ""})
  125. return
  126. }
  127. //type Role struct {
  128. // RoleName string `json:"role_name"`
  129. // UserRole string `json:"user_role"`
  130. //}
  131. ////获取用户角色
  132. //users := result.Content.([]map[string]interface{})
  133. //for i, user := range users {
  134. // roles := []Role{}
  135. // err := c.Db.SqlMapClient("get_roles_by_user_id", user["id"]).Find(&roles)
  136. // if err != nil {
  137. // fmt.Println("----", err.Error())
  138. // continue
  139. // }
  140. // users[i]["user_role"] = roles[0].UserRole
  141. // users[i]["role_name"] = roles[0].RoleName
  142. //}
  143. //
  144. //result.Content = users
  145. if err == nil {
  146. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  147. } else {
  148. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  149. }
  150. }
  151. // _GetOrgTree
  152. // @Title _GetOrgTree
  153. // @Description 获取组织架构树
  154. // @Success 200 {object} Account
  155. // @Failure 403 :id is empty
  156. func System_GetOrgTree(c *entitys.CtrlContext) {
  157. var roleRule interface{} = ""
  158. rule_code := "org_tree"
  159. var user sysmodel.SysUser
  160. user_id := c.Ctx.GetString("user_id")
  161. // exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user_id, "5c38ee66-c5e6-40a7-b190-86d115bae3e5").Exist()
  162. // 管理员角色Code LAadmin
  163. exist, _ := c.Db.SQL(`SELECT sys_user_role.id FROM sys_user_role,sys_role
  164. WHERE sys_user_role.role_id=sys_role.id
  165. AND sys_user_role.del_flag=0
  166. AND sys_role.del_flag=0
  167. AND sys_role.code=?
  168. AND sys_user_role.user_id=?`, "LAadmin", user_id).Exist()
  169. //如果是管理员
  170. if exist {
  171. user_id = ""
  172. paramMap_i_t := map[string]interface{}{"sort": "name", "role_rule": roleRule}
  173. result, err := sysutils.TreeSearch(c.Db, "system", "get_org_tree", "sys_org", paramMap_i_t)
  174. if err == nil {
  175. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  176. } else {
  177. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  178. }
  179. } else if rule_code != "" {
  180. var roleRules []models.SysDataPermissionDetail
  181. // 根据rule_code获取角色对应的接口规则
  182. err := c.Db.SqlMapClient("get_user_rule_by_code", rule_code, user_id).Find(&roleRules)
  183. if err != nil {
  184. roleRule = ""
  185. } else {
  186. roleRule = sysutils.ParseRule(roleRules)
  187. }
  188. // 查找用户组织ID
  189. _, err = c.Db.ID(user_id).Get(&user)
  190. if err != nil {
  191. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  192. return
  193. }
  194. stplkey := fmt.Sprintf("%s_%s.tpl", "system", "get_org_tree")
  195. paramMap_i_t := map[string]interface{}{"sort": "name", "org_id": user.OrgId, "role_rule": roleRule}
  196. result, err := c.Db.SqlTemplateClient(stplkey, &paramMap_i_t).Query().List()
  197. if err != nil {
  198. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  199. return
  200. }
  201. var org_id = ""
  202. if roleRule.(template.HTML) == "" {
  203. org_id = ""
  204. } else {
  205. org_id = user.OrgId
  206. }
  207. tree, err := sysutils.BuildTree(org_id, result)
  208. if err == nil {
  209. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", tree})
  210. } else {
  211. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  212. }
  213. }
  214. }
  215. // _FindOrgPage
  216. // @Title _FindOrgPage
  217. // @Description 获取组织架构分页数
  218. // @Success 200 {object} Account
  219. // @Failure 403 :id is empty
  220. func System_FindOrgPage(c *entitys.CtrlContext) {
  221. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  222. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  223. name := c.Ctx.DefaultQuery("name", "")
  224. code := c.Ctx.DefaultQuery("code", "")
  225. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  226. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code, "cn_id": cn_id}
  227. result, err := sysutils.PageSearch(c.Db, "system", "find_org_page", "sys_org", paramMap_i_t)
  228. if err == nil {
  229. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  230. } else {
  231. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  232. }
  233. }
  234. // _AddUser
  235. // @Title _AddUser
  236. // @Description 添加用户
  237. // @Param login_id string false "登录ID"
  238. // @Param password string false "密码"
  239. // @Param org_id string false "组织ID"
  240. // @Param email string false "邮箱"
  241. // @Success 200 {object} Account
  242. // @Failure 403 :id is empty
  243. func System_AddUser(c *entitys.CtrlContext) {
  244. tk, _ := c.Ctx.Get("token")
  245. opUser := tk.(*entitys.Token)
  246. var user sysmodel.SysUser
  247. err := c.Ctx.BindJSON(&user)
  248. if err != nil {
  249. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  250. }
  251. fmt.Println(user.LoginId, "-----add user-----", user.Password, " --- ", user.OrgId)
  252. //查找login_id是否存在
  253. exit, _ := c.PlatformDbEngine.Table(new(sysmodel.SysUser)).Where("login_id = ? and del_flag = ?", user.LoginId, 0).Exist()
  254. if exit {
  255. c.Ctx.JSON(200, sysmodel.SysReturn{500, "login_id exit", nil})
  256. return
  257. }
  258. user_id := c.Ctx.GetString("user_id")
  259. user.Id = sysutils.NewUUID()
  260. user.Name = user.Name
  261. user.CreateTime = models.NowLocal()
  262. user.LastUpdateTime = time.Now().UnixNano()
  263. user.CreateBy = user_id
  264. user.LastUpdateBy = user_id
  265. user.DelFlag = 0
  266. user.Domain = opUser.Domain
  267. user.Password = sysutils.HashPassword(user.Password, "")
  268. _, err = c.PlatformDbEngine.Insert(&user)
  269. if err != nil {
  270. c.Ctx.JSON(200, sysmodel.SysReturn{500, "平台插入用户错误:" + err.Error(), nil})
  271. }
  272. _, err = c.Db.Insert(&user)
  273. ret := __none_func_system__(user.LoginId, user.Password, user.OrgId, user.Email)
  274. if ret && err == nil {
  275. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  276. } else {
  277. c.Ctx.JSON(200, sysmodel.SysReturn{500, "域数据库插入用户错误:" + err.Error(), nil})
  278. }
  279. }
  280. // _DelUser
  281. // @Title _DelUser
  282. // @Description 删除用户
  283. // @Param id string false "用户ID"
  284. // @Success 200 {object} Account
  285. // @Failure 403 :id is empty
  286. func System_DelUser(c *entitys.CtrlContext) {
  287. type Param struct {
  288. Id string `json:"id"`
  289. }
  290. var params []Param
  291. c.Ctx.BindJSON(&params)
  292. ids := []string{}
  293. for _, param := range params {
  294. ids = append(ids, param.Id)
  295. }
  296. session := c.Db.NewSession()
  297. defer session.Close()
  298. session.Begin()
  299. _, err := c.Db.Table(new(models.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  300. if err != nil {
  301. session.Rollback()
  302. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  303. return
  304. }
  305. _, err = c.Db.Table(new(models.SysUserRole)).In("user_id", ids).Update(map[string]interface{}{"del_flag": 1})
  306. if err != nil {
  307. session.Rollback()
  308. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  309. return
  310. }
  311. session.Commit()
  312. _, err = c.PlatformDbEngine.Table(new(models.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  313. if err == nil {
  314. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  315. } else {
  316. c.Ctx.JSON(200, sysmodel.SysReturn{500, "平台删除用户失败:" + err.Error(), nil})
  317. }
  318. }
  319. // _UpdateUser
  320. // @Title _UpdateUser
  321. // @Description 修改用户
  322. // @Param login_id string false "登录ID"
  323. // @Param password string false "密码"
  324. // @Param org_id string false "组织ID"
  325. // @Param email string false "邮箱"
  326. // @Success 200 {object} Account
  327. // @Failure 403 :id is empty
  328. func System_UpdateUser(c *entitys.CtrlContext) {
  329. tk, _ := c.Ctx.Get("token")
  330. user := tk.(*entitys.Token)
  331. var postData struct {
  332. sysmodel.SysUser
  333. UserRole []string `json:"user_role"`
  334. }
  335. //var user sysmodel.SysUser
  336. err := c.Ctx.BindJSON(&postData)
  337. if err != nil {
  338. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  339. return
  340. }
  341. //postData.LastUpdateTime = time.Now().UnixNano()
  342. //postData.LastUpdateBy = user.UserId
  343. session := c.Db.NewSession()
  344. defer session.Close()
  345. session.Begin()
  346. //paramMap, _ := sysutils.BeanToMap(&postData)
  347. paramMap := map[string]interface{}{
  348. "id": postData.Id,
  349. "temp_id": postData.TempId,
  350. "temp_value": postData.TempValue,
  351. "name": postData.Name,
  352. "email": postData.Email,
  353. "mobile": postData.Mobile,
  354. "org_id": postData.OrgId,
  355. "address": postData.Address,
  356. "last_update_time": time.Now().UnixNano(),
  357. "last_update_by": user.UserId,
  358. }
  359. _, err = session.SqlMapClient("update_user", &paramMap).Execute()
  360. if err != nil {
  361. session.Rollback()
  362. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  363. return
  364. }
  365. _, err = c.PlatformDbEngine.SqlMapClient("update_user", &paramMap).Execute()
  366. if err != nil {
  367. session.Rollback()
  368. c.Ctx.JSON(500, sysmodel.SysReturn{500, "平台更新用户失败:" + err.Error(), nil})
  369. return
  370. }
  371. userRoles := []sysmodel.SysUserRole{}
  372. for _, roleId := range postData.UserRole {
  373. userRole := sysmodel.SysUserRole{}
  374. userRole.Id = sysutils.NewUUID()
  375. userRole.UserId = postData.Id
  376. userRole.RoleId = roleId
  377. userRole.DelFlag = 0
  378. userRole.CreateTime = sysmodel.NowLocal()
  379. userRole.CreateBy = user.UserId
  380. userRole.LastUpdateBy = user.UserId
  381. userRole.LastUpdateTime = time.Now().UnixNano()
  382. userRoles = append(userRoles, userRole)
  383. }
  384. _, err = session.SqlMapClient("delete_user_role", &map[string]interface{}{"user_id": postData.Id}).Execute()
  385. if err != nil {
  386. session.Rollback()
  387. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  388. return
  389. }
  390. _, err = session.InsertMulti(&userRoles)
  391. if err == nil {
  392. session.Commit()
  393. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  394. } else {
  395. session.Rollback()
  396. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  397. }
  398. }
  399. // _UpdatePassword
  400. // @Title _UpdatePassword
  401. // @Description 修改用户密码
  402. // @Param string false "用户ID"
  403. // @Param password string false "密码"
  404. // @Success 200 {object} Account
  405. // @Failure 403 :id is empty
  406. func System_UpdatePassword(c *entitys.CtrlContext) {
  407. var user sysmodel.SysUser
  408. err := c.Ctx.BindJSON(&user)
  409. operatorId := c.Ctx.GetString("user_id")
  410. if err != nil {
  411. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  412. return
  413. }
  414. user.Password = sysutils.HashPassword(user.Password, "")
  415. paramMap := map[string]interface{}{"id": user.Id, "password": user.Password, "last_update_time": time.Now().UnixNano(), "last_update_by": operatorId}
  416. _, err = c.PlatformDbEngine.SqlMapClient("update_user_password", &paramMap).Execute()
  417. if err == nil {
  418. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  419. } else {
  420. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  421. }
  422. }
  423. // _GetUser
  424. // @Title _GetUser
  425. // @Description 更加用户ID获取用户信息
  426. // @Param user_id string false "用户ID"
  427. // @Success 200 {object} Account
  428. // @Failure 403 :id is empty
  429. func System_GetUser(c *entitys.CtrlContext) {
  430. user_id := c.Ctx.Query("user_id")
  431. var user sysmodel.SysUser
  432. _, err := c.Db.SqlMapClient("selectone_sys_user", &map[string]interface{}{"id": user_id}).Get(&user)
  433. if err == nil {
  434. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", user})
  435. } else {
  436. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  437. }
  438. }
  439. // _AddRole
  440. // @Title _AddRole
  441. // @Description 添加角色
  442. // @Param name string false "角色名称"
  443. // @Param remark string false "备注"
  444. // @Success 200 {object} Account
  445. // @Failure 403 :id is empty
  446. func System_AddRole(c *entitys.CtrlContext) {
  447. var paramObj0 struct {
  448. models.SysRole
  449. RoleMenus []string `json:"role_menus"`
  450. RoleAppFuns []string `json:"role_app_funs"`
  451. }
  452. c.Ctx.BindJSON(&paramObj0)
  453. userId := c.Ctx.GetString("user_id")
  454. session := c.Db.NewSession()
  455. session.Begin()
  456. defer session.Close()
  457. bs, err := json.Marshal(&paramObj0)
  458. if err != nil {
  459. session.Rollback()
  460. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  461. return
  462. }
  463. var role sysmodel.SysRole
  464. if err := json.Unmarshal(bs, &role); err != nil {
  465. session.Rollback()
  466. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  467. return
  468. }
  469. role.Id = sysutils.NewUUID()
  470. role.CreateBy = userId
  471. role.LastUpdateBy = userId
  472. role.CreateTime = models.NowLocal()
  473. role.LastUpdateTime = time.Now().UnixNano()
  474. role.DelFlag = 0
  475. if _, err = c.Db.Insert(&role); err != nil {
  476. session.Rollback()
  477. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  478. return
  479. }
  480. if len(paramObj0.RoleMenus) > 0 {
  481. roleMenus := []sysmodel.SysRoleMenu{}
  482. for _, menuId := range paramObj0.RoleMenus {
  483. roleMenu := sysmodel.SysRoleMenu{}
  484. roleMenu.Id = sysutils.NewUUID()
  485. roleMenu.MenuId = menuId
  486. roleMenu.RoleId = role.Id
  487. roleMenu.CreateBy = userId
  488. roleMenu.LastUpdateBy = userId
  489. roleMenu.CreateTime = models.NowLocal()
  490. roleMenu.LastUpdateTime = time.Now().UnixNano()
  491. roleMenu.DelFlag = 0
  492. roleMenus = append(roleMenus, roleMenu)
  493. }
  494. if _, err := c.Db.Insert(&roleMenus); err != nil {
  495. session.Rollback()
  496. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  497. return
  498. }
  499. }
  500. if len(paramObj0.RoleAppFuns) > 0 {
  501. roleAppFuns := []sysmodel.SysRoleAppFun{}
  502. for _, appFunId := range paramObj0.RoleAppFuns {
  503. roleAppFun := sysmodel.SysRoleAppFun{}
  504. roleAppFun.Id = sysutils.NewUUID()
  505. roleAppFun.AppFunId = appFunId
  506. roleAppFun.RoleId = role.Id
  507. roleAppFun.CreateBy = userId
  508. roleAppFun.LastUpdateBy = userId
  509. roleAppFun.CreateTime = models.NowLocal()
  510. roleAppFun.LastUpdateTime = time.Now().UnixNano()
  511. roleAppFun.DelFlag = 0
  512. roleAppFuns = append(roleAppFuns, roleAppFun)
  513. }
  514. if _, err := c.Db.Insert(&roleAppFuns); err != nil {
  515. session.Rollback()
  516. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  517. return
  518. }
  519. }
  520. session.Commit()
  521. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  522. }
  523. // _DelRole
  524. // @Title _DelRole
  525. // @Description 添加角色
  526. // @Param id string false "角色ID"
  527. // @Success 200 {object} Account
  528. // @Failure 403 :id is empty
  529. func System_DelRole(c *entitys.CtrlContext) {
  530. type Param struct {
  531. Id string `json:"id"`
  532. }
  533. var params []Param
  534. c.Ctx.BindJSON(&params)
  535. ids := []string{}
  536. for _, param := range params {
  537. ids = append(ids, param.Id)
  538. }
  539. _, err := c.Db.Table(new(models.SysRole)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  540. if err == nil {
  541. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  542. } else {
  543. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  544. }
  545. }
  546. // _UpdateRole
  547. // @Title _UpdateRole
  548. // @Description 修改角色
  549. // @Param id string false "角色ID"
  550. // @Param name string false "角色名称"
  551. // @Param remark string false "备注"
  552. // @Success 200 {object} Account
  553. // @Failure 403 :id is empty
  554. func System_UpdateRole(c *entitys.CtrlContext) {
  555. var paramObj0 struct {
  556. models.SysRole
  557. RoleMenus []string `json:"role_menus"`
  558. RoleAppFuns []string `json:"role_app_funs"`
  559. }
  560. if err := c.Ctx.BindJSON(&paramObj0); err != nil {
  561. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  562. return
  563. }
  564. userId := c.Ctx.GetString("user_id")
  565. session := c.Db.NewSession()
  566. session.Begin()
  567. defer session.Close()
  568. bs, err := json.Marshal(&paramObj0)
  569. if err != nil {
  570. session.Rollback()
  571. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  572. return
  573. }
  574. var role sysmodel.SysRole
  575. if err := json.Unmarshal(bs, &role); err != nil {
  576. session.Rollback()
  577. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  578. return
  579. }
  580. role.LastUpdateBy = userId
  581. role.LastUpdateTime = time.Now().UnixNano()
  582. if _, err := session.ID(role.Id).Update(&role); err != nil {
  583. session.Rollback()
  584. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  585. return
  586. }
  587. if len(paramObj0.RoleMenus) > 0 {
  588. // 删除原来的角色菜单数据
  589. if _, err := c.Db.SQL("delete from sys_role_menu where role_id = ?", role.Id).Execute(); err != nil {
  590. session.Rollback()
  591. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  592. return
  593. }
  594. roleMenus := []sysmodel.SysRoleMenu{}
  595. for _, menuId := range paramObj0.RoleMenus {
  596. roleMenu := sysmodel.SysRoleMenu{}
  597. roleMenu.Id = sysutils.NewUUID()
  598. roleMenu.MenuId = menuId
  599. roleMenu.RoleId = role.Id
  600. roleMenu.CreateBy = userId
  601. roleMenu.LastUpdateBy = userId
  602. roleMenu.CreateTime = models.NowLocal()
  603. roleMenu.LastUpdateTime = time.Now().UnixNano()
  604. roleMenu.DelFlag = 0
  605. roleMenus = append(roleMenus, roleMenu)
  606. }
  607. if _, err := c.Db.Insert(&roleMenus); err != nil {
  608. session.Rollback()
  609. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  610. return
  611. }
  612. }
  613. if len(paramObj0.RoleAppFuns) > 0 {
  614. // 删除原来的角色APP功能数据
  615. if _, err := c.Db.SQL("delete from sys_role_app_fun where role_id = ?", role.Id).Execute(); err != nil {
  616. session.Rollback()
  617. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  618. return
  619. }
  620. roleAppFuns := []sysmodel.SysRoleAppFun{}
  621. for _, appFunId := range paramObj0.RoleAppFuns {
  622. roleAppFun := sysmodel.SysRoleAppFun{}
  623. roleAppFun.Id = sysutils.NewUUID()
  624. roleAppFun.AppFunId = appFunId
  625. roleAppFun.RoleId = role.Id
  626. roleAppFun.CreateBy = userId
  627. roleAppFun.LastUpdateBy = userId
  628. roleAppFun.CreateTime = models.NowLocal()
  629. roleAppFun.LastUpdateTime = time.Now().UnixNano()
  630. roleAppFun.DelFlag = 0
  631. roleAppFuns = append(roleAppFuns, roleAppFun)
  632. }
  633. if _, err := c.Db.Insert(&roleAppFuns); err != nil {
  634. session.Rollback()
  635. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  636. return
  637. }
  638. }
  639. session.Commit()
  640. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  641. }
  642. // _GetUserRoles
  643. // @Title _GetUserRoles
  644. // @Description 根据用户id获取用户角色
  645. // @Param user_id string false "用户ID"
  646. // @Success 200 {object} Account
  647. // @Failure 403 :id is empty
  648. func System_GetUserRoles(c *entitys.CtrlContext) {
  649. user_id := c.Ctx.Query("user_id")
  650. var roles []sysmodel.SysRole
  651. err := c.Db.SQL("select sys_role.* from sys_user_role, sys_role where sys_user_role.role_id = sys_role.id and sys_role.del_flag = 0 and sys_user_role.user_id = ? order by sys_role.priority asc", user_id).Find(&roles)
  652. if err == nil {
  653. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", roles})
  654. } else {
  655. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  656. }
  657. }
  658. // _FindRolePage
  659. // @Title _FindRolePage
  660. // @Description 角色分页
  661. // @Param page false "分页参数"
  662. // @Success 200 {object} Account
  663. // @Failure 403 :id is empty
  664. func System_FindRolePage(c *entitys.CtrlContext) {
  665. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  666. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  667. name := c.Ctx.DefaultQuery("name", "")
  668. code := c.Ctx.DefaultQuery("code", "")
  669. paramMap_i_t := map[string]interface{}{"name": name, "code": code, "page": page, "rows": rows}
  670. result, err := sysutils.PageSearch(c.Db, "system", "find_role_page", "sys_role", paramMap_i_t)
  671. if err == nil {
  672. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  673. } else {
  674. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  675. }
  676. }
  677. // _FindMenuPage
  678. // @Title _FindMenuPage
  679. // @Description 获取角色分页数
  680. // @Success 200 {object} Account
  681. // @Failure 403 :id is empty
  682. func System_FindMenuPage(c *entitys.CtrlContext) {
  683. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  684. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  685. user_id := c.Ctx.DefaultQuery("user_id", "")
  686. name := c.Ctx.DefaultQuery("name", "")
  687. code := c.Ctx.DefaultQuery("code", "")
  688. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  689. _type := c.Ctx.DefaultQuery("type", "")
  690. type_op := c.Ctx.DefaultQuery("type_op", "")
  691. hidden := c.Ctx.DefaultQuery("hidden", "")
  692. op := template.HTML(type_op)
  693. // exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user_id, "fc3560f6-e728-490f-aeea-613ed44668fa").Exist()
  694. // 管理员角色Code LAadmin
  695. exist, _ := c.Db.SQL(`SELECT sys_user_role.id FROM sys_user_role,sys_role
  696. WHERE sys_user_role.role_id=sys_role.id
  697. AND sys_user_role.del_flag=0
  698. AND sys_role.del_flag=0
  699. AND sys_role.code=?
  700. AND sys_user_role.user_id=?`, "LAadmin", user_id).Exist()
  701. //如果是管理员
  702. if exist {
  703. user_id = ""
  704. }
  705. paramMap_i_t := map[string]interface{}{"user_id": user_id, "hidden": hidden, "page": page, "rows": rows, "type": _type, "type_op": op, "name": name, "code": code, "cn_id": cn_id}
  706. result, err := sysutils.PageSearch(c.Db, "system", "find_menu_page", "sys_menu", paramMap_i_t)
  707. if err == nil {
  708. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  709. } else {
  710. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  711. }
  712. }
  713. // _FindDomainPage
  714. // @Title _FindDomainPage
  715. // @Description 获取域分页数
  716. // @Success 200 {object} Account
  717. // @Failure 403 :id is empty
  718. func System_FindDomainPage(c *entitys.CtrlContext) {
  719. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  720. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  721. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows}
  722. result, err := sysutils.PageSearch(c.Db, "system", "find_domain_page", "sys_domain", paramMap_i_t)
  723. if err == nil {
  724. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  725. } else {
  726. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  727. }
  728. }
  729. // _FindRoleMenu
  730. // @Title _FindRoleMenu
  731. // @Description 查找角色权限
  732. // @Param role_id string false "角色id"
  733. // @Success 200 {object} Account
  734. // @Failure 403 :id is empty
  735. func System_FindRoleMenuPage(c *entitys.CtrlContext) {
  736. role_id := c.Ctx.Query("role_id")
  737. // sql := `SELECT
  738. // sys_menu.id,
  739. // sys_menu.name,
  740. // user_menu.inheritance
  741. //FROM
  742. // sys_role_menu
  743. // LEFT JOIN sys_menu user_menu
  744. // ON sys_role_menu.menu_id = user_menu.id
  745. // LEFT JOIN sys_menu
  746. // ON FIND_IN_SET(sys_menu.id, REPLACE(user_menu.inheritance, '|', ','))
  747. //WHERE role_id = ?
  748. //GROUP BY sys_menu.id`
  749. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  750. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  751. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "role_id": role_id}
  752. result, err := sysutils.PageSearch(c.Db, "system", "find_role_menu_page", "sys_role_menu", paramMap_i_t)
  753. if err == nil {
  754. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  755. } else {
  756. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  757. }
  758. }
  759. // _SaveRoleMenu
  760. // @Title _SaveRoleMenu
  761. // @Description 保存角色权限
  762. // @Param role_menu string false "角色权限"
  763. // @Success 200 {object} Account
  764. // @Failure 403 :id is empty
  765. func System_SaveRoleMenu(c *entitys.CtrlContext) {
  766. var paramObj0 []models.SaveRoleMenu
  767. c.Ctx.BindJSON(&paramObj0)
  768. ret := __none_func_system__(paramObj0)
  769. if ret {
  770. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  771. } else {
  772. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  773. }
  774. }
  775. // _RoleAll
  776. // @Title _RoleAll
  777. // @Description 查找所有角色
  778. // @Success 200 {object} Account
  779. // @Failure 403 :id is empty
  780. func System_RoleAll(c *entitys.CtrlContext) {
  781. ret := __none_func_system__()
  782. if ret {
  783. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  784. } else {
  785. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  786. }
  787. }
  788. // _FindPermissions
  789. // @Title _FindPermissions
  790. // @Description 查找用户权限
  791. // @Success 200 {object} Account
  792. // @Failure 403 :id is empty
  793. func System_FindPermissions(c *entitys.CtrlContext) {
  794. ret := __none_func_system__()
  795. if ret {
  796. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  797. } else {
  798. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  799. }
  800. }
  801. // _AddMenu
  802. // @Title _AddMenu
  803. // @Description 添加菜单
  804. // @Param string false "菜单"
  805. // @Success 200 {object} Account
  806. // @Failure 403 :id is empty
  807. func System_AddMenu(c *entitys.CtrlContext) {
  808. var paramObj0 models.SysMenu
  809. if err := c.Ctx.BindJSON(&paramObj0); err != nil {
  810. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  811. return
  812. }
  813. tk, _ := c.Ctx.Get("token")
  814. user := tk.(*entitys.Token)
  815. paramObj0.Id = sysutils.NewUUID()
  816. paramObj0.CreateBy = user.UserId
  817. paramObj0.LastUpdateBy = user.UserId
  818. paramObj0.CreateTime = models.NowLocal()
  819. paramObj0.LastUpdateTime = time.Now().UnixNano()
  820. paramObj0.DelFlag = 0
  821. if paramObj0.Parent != "" {
  822. parentNodes := []sysmodel.SysMenu{}
  823. err := c.Db.SqlMapClient("select_parent_menu", paramObj0.Parent).Find(&parentNodes)
  824. if err != nil {
  825. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  826. return
  827. }
  828. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  829. } else {
  830. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  831. }
  832. //_, err := c.LocalSqlMapClient("insert_sys_menu", &paramObj0).Execute()
  833. paramMap, err := sysutils.BeanToMap(&paramObj0)
  834. _, err = c.Db.SqlMapClient("insert_sys_menu", paramMap).Execute()
  835. if err == nil {
  836. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  837. } else {
  838. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  839. }
  840. }
  841. // _DelMenu
  842. // @Title _DelMenu
  843. // @Description 删除菜单
  844. // @Param id string false "菜单ID"
  845. // @Success 200 {object} Account
  846. // @Failure 403 :id is empty
  847. func System_DelMenu(c *entitys.CtrlContext) {
  848. type Param struct {
  849. Id string `json:"id"`
  850. }
  851. var params []Param
  852. c.Ctx.BindJSON(&params)
  853. ids := []string{}
  854. for _, param := range params {
  855. ids = append(ids, param.Id)
  856. }
  857. _, err := c.Db.Table(new(models.SysMenu)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  858. if err == nil {
  859. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  860. } else {
  861. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  862. }
  863. }
  864. // _UpdateMenu
  865. // @Title _UpdateMenu
  866. // @Description 更新菜单
  867. // @Param string false "菜单"
  868. // @Success 200 {object} Account
  869. // @Failure 403 :id is empty
  870. func System_UpdateMenu(c *entitys.CtrlContext) {
  871. var paramObj0 models.SysMenu
  872. err := c.Ctx.BindJSON(&paramObj0)
  873. tk, _ := c.Ctx.Get("token")
  874. user := tk.(*entitys.Token)
  875. if paramObj0.Parent != "" {
  876. parentNode := sysmodel.SysMenu{}
  877. bool, err := c.Db.SqlMapClient("select_parent_menu", paramObj0.Parent).Get(&parentNode)
  878. if !bool || err != nil {
  879. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  880. return
  881. }
  882. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNode.Inheritance)
  883. } else {
  884. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  885. }
  886. paramObj0.LastUpdateBy = user.UserId
  887. paramObj0.LastUpdateTime = time.Now().UnixNano()
  888. sess := c.Db.NewSession()
  889. sess.Begin()
  890. paramMap, err := sysutils.BeanToMap(&paramObj0)
  891. _, err = sess.SqlMapClient("update_sys_menu", paramMap).Execute()
  892. if err != nil {
  893. sess.Rollback()
  894. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  895. }
  896. // 查找目录,修改Inheritance值
  897. //childrenNodes := []sysmodel.SysMenu{}
  898. childrenNode := new(sysmodel.SysMenu)
  899. rows, err := sess.SqlMapClient("select_children_menu", paramObj0.Id).Rows(childrenNode)
  900. if err != nil {
  901. sess.Rollback()
  902. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  903. return
  904. }
  905. defer rows.Close()
  906. for rows.Next() {
  907. err = rows.Scan(childrenNode)
  908. if err != nil {
  909. sess.Rollback()
  910. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  911. return
  912. }
  913. childrenNode.Inheritance = fmt.Sprintf("%s%s|", paramObj0.Inheritance, childrenNode.Id)
  914. childrenNode.LastUpdateBy = user.UserId
  915. childrenNode.LastUpdateTime = time.Now().UnixNano()
  916. paramMap, _ := sysutils.BeanToMap(childrenNode)
  917. _, err = c.Db.SqlMapClient("update_sys_menu", paramMap).Execute()
  918. if err != nil {
  919. break
  920. }
  921. }
  922. if err == nil {
  923. sess.Commit()
  924. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  925. } else {
  926. sess.Rollback()
  927. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  928. }
  929. }
  930. // _AddOrg
  931. // @Title _AddOrg
  932. // @Description 添加组织
  933. // @Param name string false "组织名称"
  934. // @Param domain string false "域"
  935. // @Param parent string false "父ID"
  936. // @Success 200 {object} Account
  937. // @Failure 403 :id is empty
  938. func System_AddOrg(c *entitys.CtrlContext) {
  939. var paramObj0 models.SysOrg
  940. c.Ctx.BindJSON(&paramObj0)
  941. tk, _ := c.Ctx.Get("token")
  942. user := tk.(*entitys.Token)
  943. paramObj0.Id = sysutils.NewUUID()
  944. paramObj0.CreateBy = user.UserId
  945. paramObj0.LastUpdateBy = user.UserId
  946. paramObj0.CreateTime = models.NowLocal()
  947. paramObj0.LastUpdateTime = time.Now().UnixNano()
  948. paramObj0.DelFlag = 0
  949. if paramObj0.Parent != "" {
  950. parentNodes := []sysmodel.SysOrg{}
  951. err := c.Db.SqlMapClient("selectone_sys_org", &map[string]interface{}{"id": paramObj0.Parent}).Find(&parentNodes)
  952. if err != nil {
  953. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  954. return
  955. }
  956. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  957. } else {
  958. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  959. }
  960. //_, err := c.LocalSqlMapClient("insert_sys_org", &paramObj0).Execute()
  961. paramMap, err := sysutils.BeanToMap(&paramObj0)
  962. _, err = c.Db.SqlMapClient("insert_sys_org", paramMap).Execute()
  963. if err == nil {
  964. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  965. } else {
  966. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  967. }
  968. }
  969. // _DelOrg
  970. // @Title _DelOrg
  971. // @Description 删除组织
  972. // @Param id string array false "用户ID"
  973. // @Success 200 {object} Account
  974. // @Failure 403 :id is empty
  975. func System_DelOrg(c *entitys.CtrlContext) {
  976. type Param struct {
  977. Id string `json:"id"`
  978. }
  979. var params []Param
  980. c.Ctx.BindJSON(&params)
  981. ids := []string{}
  982. for _, param := range params {
  983. ids = append(ids, param.Id)
  984. }
  985. _, err := c.Db.Table(new(models.SysOrg)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  986. if err == nil {
  987. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  988. } else {
  989. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  990. }
  991. }
  992. // _UpdateOrg
  993. // @Title _UpdateOrg
  994. // @Description 修改组织
  995. // @Param name string false "组织名称"
  996. // @Param domain string false "域"
  997. // @Param parent string false "父ID"
  998. // @Success 200 {object} Account
  999. // @Failure 403 :id is empty
  1000. func System_UpdateOrg(c *entitys.CtrlContext) {
  1001. //name := c.Ctx.Query("name")
  1002. //domain := c.Ctx.Query("domain")
  1003. //parent := c.Ctx.Query("parent")
  1004. var paramObj0 models.SysOrg
  1005. err := c.Ctx.BindJSON(&paramObj0)
  1006. tk, _ := c.Ctx.Get("token")
  1007. user := tk.(*entitys.Token)
  1008. if paramObj0.Parent != "" {
  1009. parentNodes := []sysmodel.SysOrg{}
  1010. err := c.Db.SqlMapClient("one_sys_org", paramObj0.Parent).Find(&parentNodes)
  1011. if err != nil {
  1012. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1013. return
  1014. }
  1015. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  1016. } else {
  1017. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  1018. }
  1019. paramObj0.LastUpdateBy = user.UserId
  1020. paramObj0.LastUpdateTime = time.Now().UnixNano()
  1021. paramMap, err := sysutils.BeanToMap(&paramObj0)
  1022. _, err = c.Db.SqlMapClient("update_sys_org", paramMap).Execute()
  1023. if err == nil {
  1024. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1025. } else {
  1026. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1027. }
  1028. }
  1029. // _GetOrgByUserid
  1030. // @Title _GetOrgByUserid
  1031. // @Description 根据组织
  1032. // @Param user_id string false "用户id"
  1033. // @Success 200 {object} Account
  1034. // @Failure 403 :id is empty
  1035. func System_GetOrgUsers(c *entitys.CtrlContext) {
  1036. user_id := c.Ctx.Query("user_id")
  1037. role_id := c.Ctx.Query("role_id")
  1038. fmt.Println(user_id, "---------", role_id)
  1039. var err error
  1040. //users := []sysmodel.SysUser{}
  1041. var users []sysmodel.SysUser
  1042. if role_id == "" {
  1043. err = c.Db.SqlMapClient("get_org_users", user_id).Find(&users)
  1044. } else {
  1045. err = c.Db.SqlMapClient("get_org_role_users", user_id, role_id).Find(&users)
  1046. if err != nil || users == nil {
  1047. c.Ctx.JSON(500, sysmodel.SysReturn{500, "无法找到部门审批人!", nil})
  1048. return
  1049. }
  1050. }
  1051. if err == nil {
  1052. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", users})
  1053. } else {
  1054. c.Ctx.JSON(500, sysmodel.SysReturn{500, "错误", nil})
  1055. }
  1056. }
  1057. // _AddDomain
  1058. // @Title _AddDomain
  1059. // @Description 添加域
  1060. // @Param false "域"
  1061. // @Success 200 {object} Account
  1062. // @Failure 403 :id is empty
  1063. func System_AddDomain(c *entitys.CtrlContext) {
  1064. var paramObj0 models.SysDomain
  1065. c.Ctx.BindJSON(&paramObj0)
  1066. ////1、测试连接串
  1067. //db, err := xorm.NewEngine("mysql", paramObj0.DataSource)
  1068. //if err == nil {
  1069. // //engine.initOrmEngine(db, "mysql")
  1070. // //c.BusinessOrmEngine[v.Domain] = db
  1071. //}
  1072. tk, _ := c.Ctx.Get("token")
  1073. user := tk.(*entitys.Token)
  1074. paramObj0.Id = sysutils.NewUUID()
  1075. paramObj0.CreateBy = user.UserId
  1076. paramObj0.LastUpdateBy = user.UserId
  1077. paramObj0.CreateTime = sysmodel.NowLocal()
  1078. paramObj0.LastUpdateTime = time.Now().UnixNano()
  1079. paramObj0.Theme = "default"
  1080. paramObj0.DelFlag = 0
  1081. paramMap, err := sysutils.BeanToMap(&paramObj0)
  1082. if err != nil {
  1083. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1084. return
  1085. }
  1086. _, err = c.Db.SqlMapClient("insert_sys_domain", paramMap).Execute()
  1087. if err == nil {
  1088. //添加数据库基本用户权限数据
  1089. ret := c.App.AddBusinessDb(paramObj0.Id, "admin@"+paramObj0.Domain, paramObj0.Domain, paramObj0.DataSource, true)
  1090. if ret {
  1091. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", paramObj0.Id})
  1092. } else {
  1093. c.Ctx.JSON(500, sysmodel.SysReturn{500, "数据库初始化错误。", nil})
  1094. }
  1095. } else {
  1096. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1097. }
  1098. }
  1099. // _DelDomain
  1100. // @Title _DelDomain
  1101. // @Description 删除域
  1102. // @Param id string false "域ID"
  1103. // @Success 200 {object} Account
  1104. // @Failure 403 :id is empty
  1105. func System_DelDomain(c *entitys.CtrlContext) {
  1106. type Param struct {
  1107. Id string `json:"id"`
  1108. }
  1109. var params []Param
  1110. c.Ctx.BindJSON(&params)
  1111. ids := []string{}
  1112. for _, param := range params {
  1113. ids = append(ids, param.Id)
  1114. }
  1115. _, err := c.Db.Table(new(models.SysDomain)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1116. if err != nil {
  1117. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1118. return
  1119. }
  1120. ret := __none_func_system__()
  1121. if ret {
  1122. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1123. } else {
  1124. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  1125. }
  1126. }
  1127. // _UpdateDomain
  1128. // @Title _UpdateDomain
  1129. // @Description 修改域
  1130. // @Param false "域"
  1131. // @Success 200 {object} Account
  1132. // @Failure 403 :id is empty
  1133. func System_UpdateDomain(c *entitys.CtrlContext) {
  1134. var paramObj0 models.SysDomain
  1135. c.Ctx.BindJSON(&paramObj0)
  1136. tk, _ := c.Ctx.Get("token")
  1137. user := tk.(*entitys.Token)
  1138. paramObj0.LastUpdateTime = time.Now().UnixNano()
  1139. paramObj0.LastUpdateBy = user.UserId
  1140. paramMap, err := sysutils.BeanToMap(&paramObj0)
  1141. if err != nil {
  1142. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1143. return
  1144. }
  1145. _, err = c.Db.SqlMapClient("update_sys_domain", paramMap).Execute()
  1146. if err == nil {
  1147. //添加数据库基本用户权限数据
  1148. ret := c.App.AddBusinessDb(paramObj0.Id, "admin@"+paramObj0.Domain, paramObj0.Domain, paramObj0.DataSource, true)
  1149. if ret {
  1150. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", paramObj0.Id})
  1151. } else {
  1152. c.Ctx.JSON(500, sysmodel.SysReturn{500, "数据库初始化错误。", nil})
  1153. }
  1154. } else {
  1155. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1156. }
  1157. }
  1158. // _GetDomain
  1159. // @Title _GetDomain
  1160. // @Description 根据domain获取域
  1161. // @Param domain string false "域"
  1162. // @Success 200 {object} Account
  1163. // @Failure 403 :id is empty
  1164. func System_GetDomain(c *entitys.CtrlContext) {
  1165. domain := c.Ctx.Query("domain")
  1166. var domainObj sysmodel.SysDomain
  1167. _, err := c.PlatformDbEngine.Where("domain = ?", domain).Get(&domainObj)
  1168. if err == nil {
  1169. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", domainObj})
  1170. } else {
  1171. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1172. }
  1173. }
  1174. // _AddDomainMenu
  1175. // @Title _AddDomainMenu
  1176. // @Description 域添加菜单
  1177. // @Param false "添加域菜单bean"
  1178. // @Success 200 {object} Account
  1179. // @Failure 403 :id is empty
  1180. func System_AddDomainMenu(c *entitys.CtrlContext) {
  1181. var paramObj0 struct {
  1182. //域名ID
  1183. DomainId string `json:"domain_id"`
  1184. //菜单
  1185. Menus []sysmodel.SysMenu `json:"menus"`
  1186. // type
  1187. Type int `json:"type"`
  1188. }
  1189. err := c.Ctx.BindJSON(&paramObj0)
  1190. if err != nil {
  1191. c.Ctx.JSON(500, sysmodel.SysReturn{500, "BindJSON error: " + err.Error(), nil})
  1192. return
  1193. }
  1194. var domain sysmodel.SysDomain
  1195. param := map[string]interface{}{"id": paramObj0.DomainId}
  1196. _, err = c.Db.SqlMapClient("selectone_sys_domain", &param).Get(&domain)
  1197. if err != nil {
  1198. c.Ctx.JSON(500, sysmodel.SysReturn{500, "not find domain error: " + err.Error(), nil})
  1199. return
  1200. }
  1201. var menuIds = make([]string, len(paramObj0.Menus))
  1202. for i := range paramObj0.Menus {
  1203. menuIds[i] = paramObj0.Menus[i].Id
  1204. }
  1205. var menus []sysmodel.SysMenu
  1206. err = c.Db.In("id", menuIds).Find(&menus)
  1207. if err != nil {
  1208. c.Ctx.JSON(500, sysmodel.SysReturn{500, "find menu error: " + err.Error(), nil})
  1209. return
  1210. }
  1211. for i := range menus {
  1212. for j := range paramObj0.Menus {
  1213. if menus[i].Id == paramObj0.Menus[j].Id {
  1214. menus[i].Name = paramObj0.Menus[j].Name
  1215. break
  1216. }
  1217. }
  1218. }
  1219. session := c.App.GetBusinessDb(domain.Domain).NewSession()
  1220. defer session.Close()
  1221. session.Begin()
  1222. deleteSqlMapKey := ""
  1223. if paramObj0.Type >= 0 {
  1224. deleteSqlMapKey = "delete_backend_sys_menu"
  1225. } else {
  1226. deleteSqlMapKey = "delete_app_sys_menu"
  1227. }
  1228. _, err = c.App.GetBusinessDb(domain.Domain).SqlMapClient(deleteSqlMapKey).Execute()
  1229. if err != nil {
  1230. session.Rollback()
  1231. c.Ctx.JSON(500, sysmodel.SysReturn{500, "Insert menu error: " + err.Error(), nil})
  1232. return
  1233. }
  1234. if len(paramObj0.Menus) <= 0 {
  1235. session.Commit()
  1236. c.Ctx.JSON(200, sysmodel.SysReturn{200, "the menus is empty", nil})
  1237. return
  1238. }
  1239. _, err = c.App.GetBusinessDb(domain.Domain).Insert(&paramObj0.Menus)
  1240. if err != nil {
  1241. session.Rollback()
  1242. c.Ctx.JSON(500, sysmodel.SysReturn{500, "Insert menu error: " + err.Error(), nil})
  1243. return
  1244. }
  1245. session.Commit()
  1246. ret := __none_func_system__(paramObj0)
  1247. if ret {
  1248. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1249. } else {
  1250. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1251. }
  1252. }
  1253. // _GetDomainMenuTree
  1254. // @Title _GetDomainMenuTree
  1255. // @Description 域添加菜单
  1256. // @Param domain_id string false "域id"
  1257. // @Success 200 {object} Account
  1258. // @Failure 403 :id is empty
  1259. func System_GetDomainMenuTree(c *entitys.CtrlContext) {
  1260. domain_id := c.Ctx.Query("domain_id")
  1261. _type := c.Ctx.DefaultQuery("type", "")
  1262. type_op := c.Ctx.DefaultQuery("type_op", "")
  1263. op := template.HTML(type_op)
  1264. var domain sysmodel.SysDomain
  1265. param := map[string]interface{}{"id": domain_id, "type": _type, "type_op": op}
  1266. _, err := c.Db.SqlMapClient("selectone_sys_domain", &param).Get(&domain)
  1267. if err != nil {
  1268. c.Ctx.JSON(500, sysmodel.SysReturn{500, "not find domain error: " + err.Error(), nil})
  1269. return
  1270. }
  1271. paramMap := map[string]interface{}{"user_id": "", "type": _type, "type_op": op, "name": "", "hidden": ""}
  1272. domainMenus, err := c.App.GetBusinessDb(domain.Domain).SqlTemplateClient("system_get_menu_tree.tpl", &paramMap).Query().List()
  1273. if err != nil {
  1274. c.Ctx.JSON(500, sysmodel.SysReturn{500, "get domain_menu tree: " + err.Error(), nil})
  1275. return
  1276. }
  1277. domainTree, err := sysutils.BuildTree("", domainMenus)
  1278. sysMenus, err := c.Db.SqlTemplateClient("system_get_menu_tree.tpl", &paramMap).Query().List()
  1279. if err != nil {
  1280. c.Ctx.JSON(500, sysmodel.SysReturn{500, "get sys_menu tree: " + err.Error(), nil})
  1281. return
  1282. }
  1283. var sysMenusMap map[string]map[string]interface{}
  1284. sysMenusMap = make(map[string]map[string]interface{}, 0)
  1285. for _, menu := range sysMenus {
  1286. sysMenusMap[menu["id"].(string)] = menu
  1287. }
  1288. //剔除域已存在的菜单
  1289. //for _, domainMenu := range domainMenus {
  1290. // delete(sysMenusMap, domainMenu["id"].(string))
  1291. //}
  1292. var sysMenuRest []map[string]interface{}
  1293. for _, menu := range sysMenusMap {
  1294. sysMenuRest = append(sysMenuRest, menu)
  1295. }
  1296. sysTree, err := sysutils.BuildTree("", sysMenuRest)
  1297. ret := __none_func_system__(domain_id)
  1298. if ret {
  1299. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", map[string]interface{}{"sys_tree": sysTree, "domain_tree": domainTree}})
  1300. } else {
  1301. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1302. }
  1303. }
  1304. // _GetUserMenuTree
  1305. // @Title _GetUserMenuTree
  1306. // @Description 获取用户权限菜单
  1307. // @Param user_id string false "用户id"
  1308. // @Success 200 {object} Account
  1309. // @Failure 403 :id is empty
  1310. func System_GetRoleMenuTree(c *entitys.CtrlContext) {
  1311. role_id := c.Ctx.Query("role_id")
  1312. //paramMap := map[string]interface{}{"role_id": role_id}
  1313. //sysMenu, err := c.Db.SqlMapClient("get_role_no_have_menu_tree", &paramMap).Query().List()
  1314. //if err != nil {
  1315. // c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1316. // return
  1317. //}
  1318. //sysTree, err := sysutils.BuildTree("", sysMenu)
  1319. menuType := c.Ctx.DefaultQuery("type", "2")
  1320. op := template.HTML("<=")
  1321. paramMap := map[string]interface{}{"user_id": "", "name": "", "sort": "name", "type": menuType, "type_op": op, "hidden": 0}
  1322. sysTree, err := sysutils.TreeSearch(c.Db, "system", "get_menu_tree", "sys_menu", paramMap)
  1323. if err != nil {
  1324. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1325. return
  1326. }
  1327. paramMap2 := map[string]interface{}{"role_id": role_id}
  1328. //roleTree, err := sysutils.TreeSearch(c.Db, "system", "get_role_menu_tree", "sys_menu", paramMap2)
  1329. roleMenu, err := c.Db.SqlMapClient("get_role_menu_tree", &paramMap2).Query().List()
  1330. if err != nil {
  1331. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1332. return
  1333. }
  1334. roleTree, err := sysutils.BuildTree("", roleMenu)
  1335. ret := __none_func_system__(role_id)
  1336. if ret {
  1337. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", map[string]interface{}{"sys_tree": sysTree, "role_tree": roleTree}})
  1338. } else {
  1339. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1340. }
  1341. }
  1342. // _AddRoleMenu
  1343. // @Title _AddRoleMenu
  1344. // @Description 添加角色菜单
  1345. // @Param menu_id false "菜单id"
  1346. // @Param role_id string false "角色id"
  1347. // @Success 200 {object} Account
  1348. // @Failure 403 :id is empty
  1349. func System_AddRoleMenu(c *entitys.CtrlContext) {
  1350. tk, _ := c.Ctx.Get("token")
  1351. user := tk.(*entitys.Token)
  1352. var paramObj0 struct {
  1353. MenuIds []string `json:"menu_ids"`
  1354. RoleId string `json:"role_id"`
  1355. }
  1356. c.Ctx.BindJSON(&paramObj0)
  1357. session := c.Db.NewSession()
  1358. defer session.Close()
  1359. session.Begin()
  1360. _, err := session.SqlMapClient("del_role_menu", paramObj0.RoleId).Execute()
  1361. if err != nil {
  1362. session.Rollback()
  1363. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1364. return
  1365. }
  1366. var roleMenus []*sysmodel.SysRoleMenu
  1367. for _, menu := range paramObj0.MenuIds {
  1368. roleMenu := &sysmodel.SysRoleMenu{}
  1369. roleMenu.Id = sysutils.NewUUID()
  1370. roleMenu.MenuId = menu
  1371. roleMenu.RoleId = paramObj0.RoleId
  1372. roleMenu.CreateBy = user.UserId
  1373. roleMenu.CreateTime = sysmodel.NowLocal()
  1374. roleMenus = append(roleMenus, roleMenu)
  1375. }
  1376. _, err = session.InsertMulti(&roleMenus)
  1377. if err != nil {
  1378. session.Rollback()
  1379. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1380. return
  1381. }
  1382. session.Commit()
  1383. ret := __none_func_system__(paramObj0)
  1384. if ret {
  1385. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1386. } else {
  1387. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1388. }
  1389. }
  1390. // _FindAreaPage
  1391. // @Title _FindAreaPage
  1392. // @Description 获取区域管理分页数
  1393. // @Success 200 {object} Account
  1394. // @Failure 403 :id is empty
  1395. func System_FindAreaPage(c *entitys.CtrlContext) {
  1396. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1397. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1398. var paramMap = make(map[string]interface{})
  1399. paramMap["page"] = page
  1400. paramMap["rows"] = rows
  1401. paramMap["del_flag"] = c.Ctx.Query("del_flag")
  1402. paramMap["id"] = c.Ctx.Query("id")
  1403. paramMap["name"] = c.Ctx.Query("name")
  1404. paramMap["parent"] = c.Ctx.Query("parent")
  1405. paramMap["inheritance"] = c.Ctx.Query("inheritance")
  1406. paramMap["temp_id"] = c.Ctx.Query("temp_id")
  1407. paramMap["manager"] = c.Ctx.Query("manager")
  1408. paramMap["org_id"] = c.Ctx.Query("org_id")
  1409. paramMap["org_name"] = c.Ctx.Query("org_name")
  1410. paramMap["org_inheritance"] = c.Ctx.Query("org_inheritance")
  1411. paramMap["manager_name"] = c.Ctx.Query("manager_name")
  1412. result, err := sysutils.PageSearch(c.Db, "system", "find_area_page", "sys_user", paramMap)
  1413. if err == nil {
  1414. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1415. } else {
  1416. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1417. }
  1418. }
  1419. // _AddArea
  1420. // @Title _AddArea
  1421. // @Description 添加区域
  1422. // @Param name string false "区域名称"
  1423. // @Param parent string false "父节点"
  1424. // @Param inheritance string false "继承关系"
  1425. // @Param org_id string false "组织ID"
  1426. // @Param temp_id string false "模板ID"
  1427. // @Param temp_value string false "模板内容"
  1428. // @Param manager string false "负责人"
  1429. // @Success 200 {object} Account
  1430. // @Failure 403 :id is empty
  1431. func System_AddArea(c *entitys.CtrlContext) {
  1432. var err error
  1433. var bean sysmodel.SysArea
  1434. if err = c.Ctx.BindJSON(&bean); err != nil {
  1435. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1436. return
  1437. }
  1438. user_id := c.Ctx.GetString("user_id")
  1439. bean.Id = sysutils.NewUUID()
  1440. bean.DelFlag = 0
  1441. bean.CreateBy = user_id
  1442. bean.LastUpdateBy = user_id
  1443. bean.CreateTime = sysmodel.NowLocal()
  1444. bean.LastUpdateTime = time.Now().UnixNano()
  1445. if bean.Parent != "" {
  1446. parentNodes := sysmodel.SysArea{}
  1447. _, err := c.Db.SqlMapClient("selectone_sys_area", &map[string]interface{}{"id": bean.Parent}).Get(&parentNodes)
  1448. if err != nil {
  1449. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1450. return
  1451. }
  1452. bean.Inheritance = fmt.Sprintf("|%s%s", bean.Id, parentNodes.Inheritance)
  1453. } else {
  1454. bean.Inheritance = fmt.Sprintf("|%s|", bean.Id)
  1455. }
  1456. _, err = c.Db.InsertOne(&bean)
  1457. if err == nil {
  1458. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1459. } else {
  1460. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1461. }
  1462. }
  1463. // _DelArea
  1464. // @Title _DelArea
  1465. // @Description 删除区域
  1466. // @Param ids string false "用户ID"
  1467. // @Success 200 {object} Account
  1468. // @Failure 403 :id is empty
  1469. func System_DelArea(c *entitys.CtrlContext) {
  1470. var err error
  1471. var bean = &models.SysArea{}
  1472. type Param struct {
  1473. Id string `json:"id"`
  1474. }
  1475. var params []Param
  1476. c.Ctx.BindJSON(&params)
  1477. ids := []string{}
  1478. for _, param := range params {
  1479. ids = append(ids, param.Id)
  1480. }
  1481. session := c.Db.NewSession()
  1482. defer session.Close()
  1483. if err := session.Begin(); err != nil {
  1484. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1485. return
  1486. }
  1487. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1488. if err == nil {
  1489. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1490. }
  1491. if err == nil {
  1492. err = session.Commit()
  1493. }
  1494. if err == nil {
  1495. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1496. } else {
  1497. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1498. }
  1499. }
  1500. // _RecoverArea
  1501. // @Title _RecoverArea
  1502. // @Description 恢复区域
  1503. // @Param ids string false "区域ID"
  1504. // @Success 200 {object} Account
  1505. // @Failure 403 :id is empty
  1506. func System_RecoverArea(c *entitys.CtrlContext) {
  1507. var err error
  1508. var bean = &models.SysArea{}
  1509. idArr := make([]string, 0)
  1510. if ids := c.Ctx.Query("ids"); ids == "" {
  1511. err = c.Ctx.BindJSON(&idArr)
  1512. if err != nil || len(idArr) <= 0 {
  1513. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1514. return
  1515. }
  1516. } else {
  1517. idArr = strings.Split(ids, ",")
  1518. }
  1519. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  1520. if err == nil {
  1521. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1522. } else {
  1523. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1524. }
  1525. }
  1526. // _UpdateArea
  1527. // @Title _UpdateArea
  1528. // @Description 修改区域
  1529. // @Param name string false "区域名称"
  1530. // @Param parent string false "父节点"
  1531. // @Param inheritance string false "继承关系"
  1532. // @Param org_id string false "组织ID"
  1533. // @Param temp_id string false "模板ID"
  1534. // @Param temp_value string false "模板内容"
  1535. // @Param manager string false "负责人"
  1536. // @Success 200 {object} Account
  1537. // @Failure 403 :id is empty
  1538. func System_UpdateArea(c *entitys.CtrlContext) {
  1539. var err error
  1540. var bean sysmodel.SysArea
  1541. if err = c.Ctx.BindJSON(&bean); err != nil {
  1542. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1543. return
  1544. }
  1545. user_id := c.Ctx.GetString("user_id")
  1546. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1547. if !exist && err == nil {
  1548. err = errors.New("record does not exist")
  1549. }
  1550. if err != nil {
  1551. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1552. return
  1553. }
  1554. bean.LastUpdateBy = user_id
  1555. bean.LastUpdateTime = time.Now().UnixNano()
  1556. if bean.Parent != "" {
  1557. parentNodes := sysmodel.SysArea{}
  1558. _, err := c.Db.SqlMapClient("selectone_sys_area", &map[string]interface{}{"id": bean.Parent}).Get(&parentNodes)
  1559. if err != nil {
  1560. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1561. return
  1562. }
  1563. if parentNodes.Inheritance == "" {
  1564. parentNodes.Inheritance = "|"
  1565. }
  1566. bean.Inheritance = fmt.Sprintf("|%s%s", bean.Id, parentNodes.Inheritance)
  1567. } else {
  1568. bean.Inheritance = fmt.Sprintf("|%s|", bean.Id)
  1569. }
  1570. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1571. if err == nil {
  1572. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1573. } else {
  1574. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1575. }
  1576. }
  1577. // _GetArea
  1578. // @Title _GetArea
  1579. // @Description 根据区域ID获取区域信息
  1580. // @Param id string false "区域ID"
  1581. // @Success 200 {object} Account
  1582. // @Failure 403 :id is empty
  1583. func System_GetArea(c *entitys.CtrlContext) {
  1584. id := c.Ctx.Query("id")
  1585. //var area sysmodel.SysArea
  1586. //exist, err := c.Db.SqlMapClient("get_area", &map[string]interface{}{"id": id}).Get(&area)
  1587. result := c.Db.SqlMapClient("get_area", &map[string]interface{}{"id": id}).Query()
  1588. if result.Result != nil && len(result.Result) > 0 {
  1589. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result.Result[0]})
  1590. } else {
  1591. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1592. }
  1593. }
  1594. // _GetAreaTree
  1595. // @Title _GetAreaTree
  1596. // @Description 获取区域管理树
  1597. // @Success 200 {object} Account
  1598. // @Failure 403 :id is empty
  1599. func System_GetAreaTree(c *entitys.CtrlContext) {
  1600. paramMap_i_t := map[string]interface{}{"sort": "name"}
  1601. result, err := sysutils.TreeSearch(c.Db, "system", "get_area_tree", "sys_area", paramMap_i_t)
  1602. if err == nil {
  1603. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1604. } else {
  1605. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1606. }
  1607. }
  1608. // _FindAreaTemplatePage
  1609. // @Title _FindAreaTemplatePage
  1610. // @Description 获取区域模板分页数
  1611. // @Success 200 {object} Account
  1612. // @Failure 403 :id is empty
  1613. func System_FindAreaTemplatePage(c *entitys.CtrlContext) {
  1614. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1615. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1616. del_flag := c.Ctx.Query("del_flag")
  1617. name := c.Ctx.Query("name")
  1618. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name}
  1619. result, err := sysutils.PageSearch(c.Db, "system", "find_area_template_page", "sys_area", paramMap_i_t)
  1620. if err == nil {
  1621. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1622. } else {
  1623. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1624. }
  1625. }
  1626. // _AddAreaTemplate
  1627. // @Title _AddAreaTemplate
  1628. // @Description 添加区域模板
  1629. // @Param name string false "名称"
  1630. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1631. // @Param default int64 false "是否默认 1:是 0:否"
  1632. // @Success 200 {object} Account
  1633. // @Failure 403 :id is empty
  1634. func System_AddAreaTemplate(c *entitys.CtrlContext) {
  1635. var err error
  1636. var bean sysmodel.SysAreaTemplate
  1637. if err = c.Ctx.BindJSON(&bean); err != nil {
  1638. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1639. return
  1640. }
  1641. user_id := c.Ctx.GetString("user_id")
  1642. bean.Id = sysutils.NewUUID()
  1643. bean.DelFlag = 0
  1644. bean.CreateBy = user_id
  1645. bean.LastUpdateBy = user_id
  1646. bean.CreateTime = sysmodel.NowLocal()
  1647. bean.LastUpdateTime = time.Now().UnixNano()
  1648. _, err = c.Db.InsertOne(&bean)
  1649. if err == nil {
  1650. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1651. } else {
  1652. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1653. }
  1654. }
  1655. // _UpdateAreaTemplate
  1656. // @Title _UpdateAreaTemplate
  1657. // @Description 修改区域模板
  1658. // @Param name string false "名称"
  1659. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1660. // @Param default int64 false "是否默认 1:是 0:否"
  1661. // @Success 200 {object} Account
  1662. // @Failure 403 :id is empty
  1663. func System_UpdateAreaTemplate(c *entitys.CtrlContext) {
  1664. var err error
  1665. var bean sysmodel.SysAreaTemplate
  1666. if err = c.Ctx.BindJSON(&bean); err != nil {
  1667. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1668. return
  1669. }
  1670. user_id := c.Ctx.GetString("user_id")
  1671. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1672. if !exist && err == nil {
  1673. err = errors.New("record does not exist")
  1674. }
  1675. if err != nil {
  1676. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1677. return
  1678. }
  1679. bean.LastUpdateBy = user_id
  1680. bean.LastUpdateTime = time.Now().UnixNano()
  1681. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1682. if err == nil {
  1683. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1684. } else {
  1685. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1686. }
  1687. }
  1688. // _DelAreaTemplate
  1689. // @Title _DelAreaTemplate
  1690. // @Description 删除区域模板
  1691. // @Param ids string false "区域模板ID 多个之间(,)隔开"
  1692. // @Success 200 {object} Account
  1693. // @Failure 403 :id is empty
  1694. func System_DelAreaTemplate(c *entitys.CtrlContext) {
  1695. var err error
  1696. var bean = &models.SysAreaTemplate{}
  1697. type Param struct {
  1698. Id string `json:"id"`
  1699. }
  1700. var params []Param
  1701. c.Ctx.BindJSON(&params)
  1702. ids := []string{}
  1703. for _, param := range params {
  1704. ids = append(ids, param.Id)
  1705. }
  1706. session := c.Db.NewSession()
  1707. defer session.Close()
  1708. if err := session.Begin(); err != nil {
  1709. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1710. return
  1711. }
  1712. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1713. if err == nil {
  1714. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1715. }
  1716. if err == nil {
  1717. err = session.Commit()
  1718. }
  1719. if err == nil {
  1720. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1721. } else {
  1722. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1723. }
  1724. }
  1725. // _RecoverAreaTemplate
  1726. // @Title _RecoverAreaTemplate
  1727. // @Description 恢复区域模板
  1728. // @Param ids string false "区域模板ID 多个之间(,)隔开"
  1729. // @Success 200 {object} Account
  1730. // @Failure 403 :id is empty
  1731. func System_RecoverAreaTemplate(c *entitys.CtrlContext) {
  1732. var err error
  1733. var bean = &models.SysAreaTemplate{}
  1734. idArr := make([]string, 0)
  1735. if ids := c.Ctx.Query("ids"); ids == "" {
  1736. err = c.Ctx.BindJSON(&idArr)
  1737. if err != nil || len(idArr) <= 0 {
  1738. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1739. return
  1740. }
  1741. } else {
  1742. idArr = strings.Split(ids, ",")
  1743. }
  1744. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  1745. if err == nil {
  1746. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1747. } else {
  1748. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1749. }
  1750. }
  1751. // _GetAreaTemplate
  1752. // @Title _GetAreaTemplate
  1753. // @Description 根据区域模板ID获取区域模板信息
  1754. // @Param id string false "区域模板ID"
  1755. // @Success 200 {object} Account
  1756. // @Failure 403 :id is empty
  1757. func System_GetAreaTemplate(c *entitys.CtrlContext) {
  1758. id := c.Ctx.Query("id")
  1759. var area sysmodel.SysAreaTemplate
  1760. exist, err := c.Db.SqlMapClient("selectone_sys_area_template", &map[string]interface{}{"id": id}).Get(&area)
  1761. if !exist && err == nil {
  1762. err = errors.New("record does not exist")
  1763. }
  1764. if err == nil {
  1765. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  1766. } else {
  1767. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1768. }
  1769. }
  1770. // _FindAreaTemplateDetailPage
  1771. // @Title _FindAreaTemplateDetailPage
  1772. // @Description 获取区域模板明细分页数
  1773. // @Success 200 {object} Account
  1774. // @Failure 403 :id is empty
  1775. func System_FindAreaTemplateDetailPage(c *entitys.CtrlContext) {
  1776. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1777. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1778. del_flag := c.Ctx.Query("del_flag")
  1779. __sort__ := c.Ctx.Query("__sort__")
  1780. name := c.Ctx.Query("name")
  1781. temp_id := c.Ctx.Query("temp_id")
  1782. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name, "temp_id": temp_id, "__sort__": __sort__}
  1783. result, err := sysutils.PageSearch(c.Db, "system", "find_area_template_detail_page", "sys_area", paramMap_i_t)
  1784. if err == nil {
  1785. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1786. } else {
  1787. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1788. }
  1789. }
  1790. // _AddAreaTemplateDetail
  1791. // @Title _AddAreaTemplateDetail
  1792. // @Description 添加区域模板明细
  1793. // @Param temp_id string false "模板id"
  1794. // @Param name string false "名称"
  1795. // @Param value string false "值"
  1796. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1797. // @Param priority int64 false "优先级"
  1798. // @Param content string false "内容"
  1799. // @Success 200 {object} Account
  1800. // @Failure 403 :id is empty
  1801. func System_AddAreaTemplateDetail(c *entitys.CtrlContext) {
  1802. var err error
  1803. var bean sysmodel.SysAreaTemplateDetail
  1804. if err = c.Ctx.BindJSON(&bean); err != nil {
  1805. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1806. return
  1807. }
  1808. user_id := c.Ctx.GetString("user_id")
  1809. bean.Id = sysutils.NewUUID()
  1810. bean.DelFlag = 0
  1811. bean.CreateBy = user_id
  1812. bean.LastUpdateBy = user_id
  1813. bean.CreateTime = sysmodel.NowLocal()
  1814. bean.LastUpdateTime = time.Now().UnixNano()
  1815. _, err = c.Db.InsertOne(&bean)
  1816. if err == nil {
  1817. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1818. } else {
  1819. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1820. }
  1821. }
  1822. // _UpdateAreaTemplateDetail
  1823. // @Title _UpdateAreaTemplateDetail
  1824. // @Description 修改区域模板明细
  1825. // @Param temp_id string false "模板id"
  1826. // @Param name string false "名称"
  1827. // @Param value string false "值"
  1828. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1829. // @Param priority int64 false "优先级"
  1830. // @Param content string false "内容"
  1831. // @Success 200 {object} Account
  1832. // @Failure 403 :id is empty
  1833. func System_UpdateAreaTemplateDetail(c *entitys.CtrlContext) {
  1834. var err error
  1835. var bean sysmodel.SysAreaTemplateDetail
  1836. if err = c.Ctx.BindJSON(&bean); err != nil {
  1837. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1838. return
  1839. }
  1840. user_id := c.Ctx.GetString("user_id")
  1841. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1842. if !exist && err == nil {
  1843. err = errors.New("record does not exist")
  1844. }
  1845. if err != nil {
  1846. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1847. return
  1848. }
  1849. bean.LastUpdateBy = user_id
  1850. bean.LastUpdateTime = time.Now().UnixNano()
  1851. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1852. if err == nil {
  1853. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1854. } else {
  1855. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1856. }
  1857. }
  1858. // _DelAreaTemplateDetail
  1859. // @Title _DelAreaTemplateDetail
  1860. // @Description 删除区域模板明细
  1861. // @Param ids string false "区域模板明细ID 多个之间(,)隔开"
  1862. // @Success 200 {object} Account
  1863. // @Failure 403 :id is empty
  1864. func System_DelAreaTemplateDetail(c *entitys.CtrlContext) {
  1865. var err error
  1866. var bean = &models.SysAreaTemplateDetail{}
  1867. type Param struct {
  1868. Id string `json:"id"`
  1869. }
  1870. var params []Param
  1871. c.Ctx.BindJSON(&params)
  1872. ids := []string{}
  1873. for _, param := range params {
  1874. ids = append(ids, param.Id)
  1875. }
  1876. session := c.Db.NewSession()
  1877. defer session.Close()
  1878. if err := session.Begin(); err != nil {
  1879. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1880. return
  1881. }
  1882. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1883. if err == nil {
  1884. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1885. }
  1886. if err == nil {
  1887. err = session.Commit()
  1888. }
  1889. if err == nil {
  1890. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1891. } else {
  1892. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1893. }
  1894. }
  1895. // _RecoverAreaTemplateDetail
  1896. // @Title _RecoverAreaTemplateDetail
  1897. // @Description 恢复区域模板明细
  1898. // @Param ids string false "区域模板明细ID 多个之间(,)隔开"
  1899. // @Success 200 {object} Account
  1900. // @Failure 403 :id is empty
  1901. func System_RecoverAreaTemplateDetail(c *entitys.CtrlContext) {
  1902. var err error
  1903. var bean = &models.SysAreaTemplateDetail{}
  1904. idArr := make([]string, 0)
  1905. if ids := c.Ctx.Query("ids"); ids == "" {
  1906. err = c.Ctx.BindJSON(&idArr)
  1907. if err != nil || len(idArr) <= 0 {
  1908. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1909. return
  1910. }
  1911. } else {
  1912. idArr = strings.Split(ids, ",")
  1913. }
  1914. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  1915. if err == nil {
  1916. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1917. } else {
  1918. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1919. }
  1920. }
  1921. // _GetAreaTemplateDetail
  1922. // @Title _GetAreaTemplateDetail
  1923. // @Description 根据区域模板明细ID获取区域模板明细信息
  1924. // @Param id string false "区域模板明细ID"
  1925. // @Success 200 {object} Account
  1926. // @Failure 403 :id is empty
  1927. func System_GetAreaTemplateDetail(c *entitys.CtrlContext) {
  1928. id := c.Ctx.Query("id")
  1929. var area sysmodel.SysAreaTemplateDetail
  1930. exist, err := c.Db.SqlMapClient("selectone_sys_area_template_detail", &map[string]interface{}{"id": id}).Get(&area)
  1931. if !exist && err == nil {
  1932. err = errors.New("record does not exist")
  1933. }
  1934. if err == nil {
  1935. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  1936. } else {
  1937. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1938. }
  1939. }
  1940. // _FindUserTemplatePage
  1941. // @Title _FindUserTemplatePage
  1942. // @Description 获取用户信息模板分页数
  1943. // @Success 200 {object} Account
  1944. // @Failure 403 :id is empty
  1945. func System_FindUserTemplatePage(c *entitys.CtrlContext) {
  1946. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1947. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1948. del_flag := c.Ctx.Query("del_flag")
  1949. name := c.Ctx.Query("name")
  1950. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name}
  1951. result, err := sysutils.PageSearch(c.Db, "system", "find_user_template_page", "sys_area", paramMap_i_t)
  1952. if err == nil {
  1953. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1954. } else {
  1955. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1956. }
  1957. }
  1958. // _AddUserTemplate
  1959. // @Title _AddUserTemplate
  1960. // @Description 添加用户信息模板
  1961. // @Param name string false "名称"
  1962. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1963. // @Param default int64 false "是否默认 1:是 0:否"
  1964. // @Success 200 {object} Account
  1965. // @Failure 403 :id is empty
  1966. func System_AddUserTemplate(c *entitys.CtrlContext) {
  1967. var err error
  1968. var bean sysmodel.SysUserTemplate
  1969. if err = c.Ctx.BindJSON(&bean); err != nil {
  1970. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1971. return
  1972. }
  1973. user_id := c.Ctx.GetString("user_id")
  1974. bean.Id = sysutils.NewUUID()
  1975. bean.DelFlag = 0
  1976. bean.CreateBy = user_id
  1977. bean.LastUpdateBy = user_id
  1978. bean.CreateTime = sysmodel.NowLocal()
  1979. bean.LastUpdateTime = time.Now().UnixNano()
  1980. _, err = c.Db.InsertOne(&bean)
  1981. if err == nil {
  1982. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1983. } else {
  1984. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1985. }
  1986. }
  1987. // _UpdateUserTemplate
  1988. // @Title _UpdateUserTemplate
  1989. // @Description 修改用户信息模板
  1990. // @Param name string false "名称"
  1991. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1992. // @Param default int64 false "是否默认 1:是 0:否"
  1993. // @Success 200 {object} Account
  1994. // @Failure 403 :id is empty
  1995. func System_UpdateUserTemplate(c *entitys.CtrlContext) {
  1996. var err error
  1997. var bean sysmodel.SysUserTemplate
  1998. if err = c.Ctx.BindJSON(&bean); err != nil {
  1999. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2000. return
  2001. }
  2002. user_id := c.Ctx.GetString("user_id")
  2003. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  2004. if !exist && err == nil {
  2005. err = errors.New("record does not exist")
  2006. }
  2007. if err != nil {
  2008. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2009. return
  2010. }
  2011. bean.LastUpdateBy = user_id
  2012. bean.LastUpdateTime = time.Now().UnixNano()
  2013. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  2014. if err == nil {
  2015. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  2016. } else {
  2017. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2018. }
  2019. }
  2020. // _DelUserTemplate
  2021. // @Title _DelUserTemplate
  2022. // @Description 删除用户信息模板
  2023. // @Param ids string false "用户信息模板ID 多个之间(,)隔开"
  2024. // @Success 200 {object} Account
  2025. // @Failure 403 :id is empty
  2026. func System_DelUserTemplate(c *entitys.CtrlContext) {
  2027. var err error
  2028. var bean = &models.SysUserTemplate{}
  2029. type Param struct {
  2030. Id string `json:"id"`
  2031. }
  2032. var params []Param
  2033. c.Ctx.BindJSON(&params)
  2034. ids := []string{}
  2035. for _, param := range params {
  2036. ids = append(ids, param.Id)
  2037. }
  2038. session := c.Db.NewSession()
  2039. defer session.Close()
  2040. if err := session.Begin(); err != nil {
  2041. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2042. return
  2043. }
  2044. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  2045. if err == nil {
  2046. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  2047. }
  2048. if err == nil {
  2049. err = session.Commit()
  2050. }
  2051. if err == nil {
  2052. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2053. } else {
  2054. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2055. }
  2056. }
  2057. // _RecoverUserTemplate
  2058. // @Title _RecoverUserTemplate
  2059. // @Description 恢复用户信息模板
  2060. // @Param ids string false "用户信息模板ID 多个之间(,)隔开"
  2061. // @Success 200 {object} Account
  2062. // @Failure 403 :id is empty
  2063. func System_RecoverUserTemplate(c *entitys.CtrlContext) {
  2064. var err error
  2065. var bean = &models.SysUserTemplate{}
  2066. idArr := make([]string, 0)
  2067. if ids := c.Ctx.Query("ids"); ids == "" {
  2068. err = c.Ctx.BindJSON(&idArr)
  2069. if err != nil || len(idArr) <= 0 {
  2070. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  2071. return
  2072. }
  2073. } else {
  2074. idArr = strings.Split(ids, ",")
  2075. }
  2076. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  2077. if err == nil {
  2078. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2079. } else {
  2080. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2081. }
  2082. }
  2083. // _GetUserTemplate
  2084. // @Title _GetUserTemplate
  2085. // @Description 根据用户信息模板ID获取用户信息模板信息
  2086. // @Param id string false "用户信息模板ID"
  2087. // @Success 200 {object} Account
  2088. // @Failure 403 :id is empty
  2089. func System_GetUserTemplate(c *entitys.CtrlContext) {
  2090. id := c.Ctx.Query("id")
  2091. var area sysmodel.SysUserTemplate
  2092. exist, err := c.Db.SqlMapClient("selectone_sys_user_template", &map[string]interface{}{"id": id}).Get(&area)
  2093. if !exist && err == nil {
  2094. err = errors.New("record does not exist")
  2095. }
  2096. if err == nil {
  2097. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  2098. } else {
  2099. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2100. }
  2101. }
  2102. // _FindUserTemplateDetailPage
  2103. // @Title _FindUserTemplateDetailPage
  2104. // @Description 获取用户信息模板明细分页数
  2105. // @Success 200 {object} Account
  2106. // @Failure 403 :id is empty
  2107. func System_FindUserTemplateDetailPage(c *entitys.CtrlContext) {
  2108. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2109. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2110. del_flag := c.Ctx.Query("del_flag")
  2111. __sort__ := c.Ctx.Query("__sort__")
  2112. name := c.Ctx.Query("name")
  2113. temp_id := c.Ctx.Query("temp_id")
  2114. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name, "temp_id": temp_id, "__sort__": __sort__}
  2115. result, err := sysutils.PageSearch(c.Db, "system", "find_user_template_detail_page", "sys_area", paramMap_i_t)
  2116. if err == nil {
  2117. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2118. } else {
  2119. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2120. }
  2121. }
  2122. // _AddUserTemplateDetail
  2123. // @Title _AddUserTemplateDetail
  2124. // @Description 添加用户信息模板明细
  2125. // @Param temp_id string false "模板id"
  2126. // @Param name string false "名称"
  2127. // @Param value string false "值"
  2128. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  2129. // @Param priority int64 false "优先级"
  2130. // @Param content string false "内容"
  2131. // @Success 200 {object} Account
  2132. // @Failure 403 :id is empty
  2133. func System_AddUserTemplateDetail(c *entitys.CtrlContext) {
  2134. var err error
  2135. var bean sysmodel.SysUserTemplateDetail
  2136. if err = c.Ctx.BindJSON(&bean); err != nil {
  2137. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2138. return
  2139. }
  2140. user_id := c.Ctx.GetString("user_id")
  2141. bean.Id = sysutils.NewUUID()
  2142. bean.DelFlag = 0
  2143. bean.CreateBy = user_id
  2144. bean.LastUpdateBy = user_id
  2145. bean.CreateTime = sysmodel.NowLocal()
  2146. bean.LastUpdateTime = time.Now().UnixNano()
  2147. _, err = c.Db.InsertOne(&bean)
  2148. if err == nil {
  2149. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  2150. } else {
  2151. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2152. }
  2153. }
  2154. // _UpdateUserTemplateDetail
  2155. // @Title _UpdateUserTemplateDetail
  2156. // @Description 修改用户信息模板明细
  2157. // @Param temp_id string false "模板id"
  2158. // @Param name string false "名称"
  2159. // @Param value string false "值"
  2160. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  2161. // @Param priority int64 false "优先级"
  2162. // @Param content string false "内容"
  2163. // @Success 200 {object} Account
  2164. // @Failure 403 :id is empty
  2165. func System_UpdateUserTemplateDetail(c *entitys.CtrlContext) {
  2166. var err error
  2167. var bean sysmodel.SysUserTemplateDetail
  2168. if err = c.Ctx.BindJSON(&bean); err != nil {
  2169. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2170. return
  2171. }
  2172. user_id := c.Ctx.GetString("user_id")
  2173. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  2174. if !exist && err == nil {
  2175. err = errors.New("record does not exist")
  2176. }
  2177. if err != nil {
  2178. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2179. return
  2180. }
  2181. bean.LastUpdateBy = user_id
  2182. bean.LastUpdateTime = time.Now().UnixNano()
  2183. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  2184. if err == nil {
  2185. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  2186. } else {
  2187. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  2188. }
  2189. }
  2190. // _DelUserTemplateDetail
  2191. // @Title _DelUserTemplateDetail
  2192. // @Description 删除用户信息模板明细
  2193. // @Param ids string false "用户信息模板明细ID 多个之间(,)隔开"
  2194. // @Success 200 {object} Account
  2195. // @Failure 403 :id is empty
  2196. func System_DelUserTemplateDetail(c *entitys.CtrlContext) {
  2197. var err error
  2198. var bean = &models.SysUserTemplateDetail{}
  2199. type Param struct {
  2200. Id string `json:"id"`
  2201. }
  2202. var params []Param
  2203. c.Ctx.BindJSON(&params)
  2204. ids := []string{}
  2205. for _, param := range params {
  2206. ids = append(ids, param.Id)
  2207. }
  2208. session := c.Db.NewSession()
  2209. defer session.Close()
  2210. if err := session.Begin(); err != nil {
  2211. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2212. return
  2213. }
  2214. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  2215. if err == nil {
  2216. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  2217. }
  2218. if err == nil {
  2219. err = session.Commit()
  2220. }
  2221. if err == nil {
  2222. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2223. } else {
  2224. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2225. }
  2226. }
  2227. // _RecoverUserTemplateDetail
  2228. // @Title _RecoverUserTemplateDetail
  2229. // @Description 恢复用户信息模板明细
  2230. // @Param ids string false "用户信息模板明细ID 多个之间(,)隔开"
  2231. // @Success 200 {object} Account
  2232. // @Failure 403 :id is empty
  2233. func System_RecoverUserTemplateDetail(c *entitys.CtrlContext) {
  2234. var err error
  2235. var bean = &models.SysUserTemplateDetail{}
  2236. idArr := make([]string, 0)
  2237. if ids := c.Ctx.Query("ids"); ids == "" {
  2238. err = c.Ctx.BindJSON(&idArr)
  2239. if err != nil || len(idArr) <= 0 {
  2240. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  2241. return
  2242. }
  2243. } else {
  2244. idArr = strings.Split(ids, ",")
  2245. }
  2246. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  2247. if err == nil {
  2248. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2249. } else {
  2250. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2251. }
  2252. }
  2253. // _GetUserTemplateDetail
  2254. // @Title _GetUserTemplateDetail
  2255. // @Description 根据用户信息模板明细ID获取用户信息模板明细信息
  2256. // @Param id string false "用户信息模板明细ID"
  2257. // @Success 200 {object} Account
  2258. // @Failure 403 :id is empty
  2259. func System_GetUserTemplateDetail(c *entitys.CtrlContext) {
  2260. id := c.Ctx.Query("id")
  2261. var area sysmodel.SysUserTemplateDetail
  2262. exist, err := c.Db.SqlMapClient("selectone_sys_user_template_detail", &map[string]interface{}{"id": id}).Get(&area)
  2263. if !exist && err == nil {
  2264. err = errors.New("record does not exist")
  2265. }
  2266. if err == nil {
  2267. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  2268. } else {
  2269. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2270. }
  2271. }
  2272. // _AddOptionset
  2273. // @Title _AddOptionset
  2274. // @Description 添加字典
  2275. // @Param false "字典"
  2276. // @Success 200 {object} Account
  2277. // @Failure 403 :id is empty
  2278. func System_AddOptionset(c *entitys.CtrlContext) {
  2279. var paramObj0 models.SysOptionset
  2280. c.Ctx.BindJSON(&paramObj0)
  2281. user_id := c.Ctx.GetString("user_id")
  2282. paramObj0.Id = sysutils.NewUUID()
  2283. paramObj0.CreateBy = user_id
  2284. paramObj0.CreateTime = sysmodel.NowLocal()
  2285. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2286. paramObj0.LastUpdateBy = user_id
  2287. paramObj0.DelFlag = 0
  2288. paramMap, _ := sysutils.BeanToMap(&paramObj0)
  2289. _, err := c.Db.SqlMapClient("insert_sys_optionset", paramMap).Execute()
  2290. if err == nil {
  2291. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2292. } else {
  2293. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2294. }
  2295. }
  2296. // _DelOptionset
  2297. // @Title _DelOptionset
  2298. // @Description 删除字典
  2299. // @Param id string false "字典ID"
  2300. // @Success 200 {object} Account
  2301. // @Failure 403 :id is empty
  2302. func System_DelOptionset(c *entitys.CtrlContext) {
  2303. type Param struct {
  2304. Id string `json:"id"`
  2305. }
  2306. var params []Param
  2307. c.Ctx.BindJSON(&params)
  2308. ids := []string{}
  2309. for _, param := range params {
  2310. ids = append(ids, param.Id)
  2311. }
  2312. _, err := c.Db.Table(new(models.SysOptionset)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2313. if err == nil {
  2314. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2315. } else {
  2316. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2317. }
  2318. }
  2319. // _UpdateOptionset
  2320. // @Title _UpdateOptionset
  2321. // @Description 修改字典
  2322. // @Param false "字典"
  2323. // @Success 200 {object} Account
  2324. // @Failure 403 :id is empty
  2325. func System_UpdateOptionset(c *entitys.CtrlContext) {
  2326. var paramObj0 models.SysOptionset
  2327. c.Ctx.BindJSON(&paramObj0)
  2328. user_id := c.Ctx.GetString("user_id")
  2329. paramObj0.LastUpdateBy = user_id
  2330. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2331. paramMap, _ := sysutils.BeanToMap(&paramObj0)
  2332. _, err := c.Db.SqlMapClient("update_sys_optionset", paramMap).Execute()
  2333. if err == nil {
  2334. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2335. } else {
  2336. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2337. }
  2338. }
  2339. // _FindOptionsetPage
  2340. // @Title _FindOptionsetPage
  2341. // @Description 获取字典分页数
  2342. // @Success 200 {object} Account
  2343. // @Failure 403 :id is empty
  2344. func System_FindOptionsetPage(c *entitys.CtrlContext) {
  2345. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2346. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2347. name := c.Ctx.DefaultQuery("name", "")
  2348. code := c.Ctx.DefaultQuery("code", "")
  2349. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code}
  2350. result, err := sysutils.PageSearch(c.Db, "system", "find_optionset_page", "sys_optionset", paramMap_i_t)
  2351. if err == nil {
  2352. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2353. } else {
  2354. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2355. }
  2356. }
  2357. // _GetOptionsetByCode
  2358. // @Title _GetOptionsetByCode
  2359. // @Description 根据编码查找字典
  2360. // @Param code string false "字典编码"
  2361. // @Success 200 {object} Account
  2362. // @Failure 403 :id is empty
  2363. func System_GetOptionsetByCode(c *entitys.CtrlContext) {
  2364. code := c.Ctx.Query("code")
  2365. var option sysmodel.SysOptionset
  2366. exit, err := c.Db.Table(new(sysmodel.SysOptionset)).Where("code=? and del_flag=0", code).Get(&option)
  2367. if exit && err == nil {
  2368. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", option})
  2369. } else {
  2370. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2371. }
  2372. }
  2373. // _AddTableColUser
  2374. // @Title _AddTableColUser
  2375. // @Description 添加用户可见列
  2376. // @Param false "用户可见列"
  2377. // @Success 200 {object} Account
  2378. // @Failure 403 :id is empty
  2379. func System_AddTableColUser(c *entitys.CtrlContext) {
  2380. var paramObj0 models.SysTableColUser
  2381. c.Ctx.BindJSON(&paramObj0)
  2382. user_id := c.Ctx.GetString("user_id")
  2383. // 查询用户是否有此可见列数据
  2384. var tabelColUser sysmodel.SysTableColUser
  2385. exit, err := c.Db.Where("user_id = ? and code = ?", user_id, paramObj0.Code).Get(&tabelColUser)
  2386. if err != nil {
  2387. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2388. return
  2389. }
  2390. // 如果存在,更新,不存在插入
  2391. if exit {
  2392. tabelColUser.Value = paramObj0.Value
  2393. _, err = c.Db.ID(tabelColUser.Id).Cols("value").Update(&tabelColUser)
  2394. if err == nil {
  2395. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2396. } else {
  2397. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2398. }
  2399. return
  2400. }
  2401. paramObj0.Id = sysutils.NewUUID()
  2402. paramObj0.UserId = user_id
  2403. paramObj0.DelFlag = 0
  2404. paramObj0.CreateTime = sysmodel.NowLocal()
  2405. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2406. paramObj0.CreateBy = user_id
  2407. paramObj0.LastUpdateBy = user_id
  2408. _, err = c.Db.Insert(&paramObj0)
  2409. if err == nil {
  2410. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2411. } else {
  2412. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2413. }
  2414. }
  2415. // _UpdateTableColUser
  2416. // @Title _UpdateTableColUser
  2417. // @Description 修改用户可见列
  2418. // @Param false "用户可见列"
  2419. // @Success 200 {object} Account
  2420. // @Failure 403 :id is empty
  2421. func System_UpdateTableColUser(c *entitys.CtrlContext) {
  2422. var paramObj0 models.SysTableColUser
  2423. c.Ctx.BindJSON(&paramObj0)
  2424. ret := __none_func_system__(paramObj0)
  2425. if ret {
  2426. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2427. } else {
  2428. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2429. }
  2430. }
  2431. // _FindTableColUserpage
  2432. // @Title _FindTableColUserpage
  2433. // @Description 分页获取用户可见列
  2434. // @Success 200 {object} Account
  2435. // @Failure 403 :id is empty
  2436. func System_FindTableColUserpage(c *entitys.CtrlContext) {
  2437. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2438. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2439. code := c.Ctx.DefaultQuery("code", "")
  2440. user_id := c.Ctx.DefaultQuery("user_id", "")
  2441. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "code": code, "user_id": user_id}
  2442. result, err := sysutils.PageSearch(c.Db, "system", "find_table_col_userpage", "sys_table_col_user", paramMap_i_t)
  2443. if err == nil {
  2444. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2445. } else {
  2446. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2447. }
  2448. }
  2449. // _AddDataPermission
  2450. // @Title _AddDataPermission
  2451. // @Description 添加数据权限
  2452. // @Param string false "数据权限"
  2453. // @Success 200 {object} Account
  2454. // @Failure 403 :id is empty
  2455. func System_AddDataPermission(c *entitys.CtrlContext) {
  2456. var paramObj0 struct {
  2457. Permission models.SysDataPermission `json:"permission"`
  2458. Details []models.SysDataPermissionDetail `json:"details"`
  2459. }
  2460. if err := c.Ctx.BindJSON(&paramObj0); err != nil {
  2461. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2462. return
  2463. }
  2464. user_id := c.Ctx.GetString("user_id")
  2465. paramObj0.Permission.Id = sysutils.NewUUID()
  2466. paramObj0.Permission.CreateBy = user_id
  2467. paramObj0.Permission.LastUpdateBy = user_id
  2468. paramObj0.Permission.CreateTime = sysmodel.NowLocal()
  2469. paramObj0.Permission.LastUpdateTime = time.Now().UnixNano()
  2470. paramObj0.Permission.DelFlag = 0
  2471. if _, err := c.Db.Insert(&paramObj0.Permission); err != nil {
  2472. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2473. return
  2474. }
  2475. for i, _ := range paramObj0.Details {
  2476. paramObj0.Details[i].Id = sysutils.NewUUID()
  2477. paramObj0.Details[i].DataPermissionId = paramObj0.Permission.Id
  2478. paramObj0.Details[i].CreateBy = user_id
  2479. paramObj0.Details[i].LastUpdateBy = user_id
  2480. paramObj0.Details[i].CreateTime = sysmodel.NowLocal()
  2481. paramObj0.Details[i].LastUpdateTime = time.Now().UnixNano()
  2482. paramObj0.Details[i].DelFlag = 0
  2483. }
  2484. _, err := c.Db.Insert(&paramObj0.Details)
  2485. if err == nil {
  2486. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2487. } else {
  2488. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2489. }
  2490. }
  2491. // _DelDataPermission
  2492. // @Title _DelDataPermission
  2493. // @Description 删除数据权限
  2494. // @Param id string false "数据权限ID"
  2495. // @Success 200 {object} Account
  2496. // @Failure 403 :id is empty
  2497. func System_DelDataPermission(c *entitys.CtrlContext) {
  2498. type Param struct {
  2499. Id string `json:"id"`
  2500. }
  2501. var params []Param
  2502. c.Ctx.BindJSON(&params)
  2503. ids := []string{}
  2504. for _, param := range params {
  2505. ids = append(ids, param.Id)
  2506. }
  2507. _, err := c.Db.Table(new(models.SysDataPermission)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2508. if err == nil {
  2509. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2510. } else {
  2511. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2512. }
  2513. }
  2514. // _UpdateDataPermission
  2515. // @Title _UpdateDataPermission
  2516. // @Description 更新数据权限
  2517. // @Param string false "数据权限"
  2518. // @Success 200 {object} Account
  2519. // @Failure 403 :id is empty
  2520. func System_UpdateDataPermission(c *entitys.CtrlContext) {
  2521. var paramObj0 struct {
  2522. Permission models.SysDataPermission `json:"permission"`
  2523. Details []models.SysDataPermissionDetail `json:"details"`
  2524. }
  2525. if err := c.Ctx.BindJSON(&paramObj0); err != nil {
  2526. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2527. return
  2528. }
  2529. user_id := c.Ctx.GetString("user_id")
  2530. paramObj0.Permission.LastUpdateBy = user_id
  2531. paramObj0.Permission.LastUpdateTime = time.Now().UnixNano()
  2532. if _, err := c.Db.ID(paramObj0.Permission.Id).Update(&paramObj0.Permission); err != nil {
  2533. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2534. return
  2535. }
  2536. for _, detail := range paramObj0.Details {
  2537. if detail.Id != "" {
  2538. detail.LastUpdateBy = user_id
  2539. detail.LastUpdateTime = time.Now().UnixNano()
  2540. if _, err := c.Db.ID(detail.Id).Update(&detail); err != nil {
  2541. logs.Error(err.Error())
  2542. }
  2543. } else {
  2544. detail.Id = sysutils.NewUUID()
  2545. detail.DataPermissionId = paramObj0.Permission.Id
  2546. detail.CreateBy = user_id
  2547. detail.LastUpdateBy = user_id
  2548. detail.CreateTime = sysmodel.NowLocal()
  2549. detail.LastUpdateTime = time.Now().UnixNano()
  2550. detail.DelFlag = 0
  2551. if _, err := c.Db.Insert(&detail); err != nil {
  2552. logs.Error(err.Error())
  2553. }
  2554. }
  2555. }
  2556. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2557. }
  2558. // _FindDataPermissionPage
  2559. // @Title _FindDataPermissionPage
  2560. // @Description 分页获取数据权限
  2561. // @Success 200 {object} Account
  2562. // @Failure 403 :id is empty
  2563. func System_FindDataPermissionPage(c *entitys.CtrlContext) {
  2564. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2565. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2566. name := c.Ctx.Query("name")
  2567. code := c.Ctx.Query("code")
  2568. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code}
  2569. result, err := sysutils.PageSearch(c.Db, "system", "find_data_permission_page", "sys_data_permission", paramMap_i_t)
  2570. if err == nil {
  2571. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2572. } else {
  2573. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2574. }
  2575. }
  2576. // _AddDataPermissionDetail
  2577. // @Title _AddDataPermissionDetail
  2578. // @Description 添加数据权限规则
  2579. // @Param string false "数据权限"
  2580. // @Success 200 {object} Account
  2581. // @Failure 403 :id is empty
  2582. func System_AddDataPermissionDetail(c *entitys.CtrlContext) {
  2583. var paramObj0 models.SysDataPermission
  2584. c.Ctx.BindJSON(&paramObj0)
  2585. user_id := c.Ctx.GetString("user_id")
  2586. paramObj0.CreateBy = user_id
  2587. paramObj0.CreateTime = models.NowLocal()
  2588. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2589. paramObj0.LastUpdateBy = user_id
  2590. paramObj0.DelFlag = 0
  2591. _, err := c.Db.Insert(&paramObj0)
  2592. if err == nil {
  2593. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2594. } else {
  2595. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2596. }
  2597. }
  2598. // _DelDataPermissionDetail
  2599. // @Title _DelDataPermissionDetail
  2600. // @Description 删除数据权限规则
  2601. // @Param id string false "数据权限ID"
  2602. // @Success 200 {object} Account
  2603. // @Failure 403 :id is empty
  2604. func System_DelDataPermissionDetail(c *entitys.CtrlContext) {
  2605. type Param struct {
  2606. Id string `json:"id"`
  2607. }
  2608. var params []Param
  2609. c.Ctx.BindJSON(&params)
  2610. ids := []string{}
  2611. for _, param := range params {
  2612. ids = append(ids, param.Id)
  2613. }
  2614. _, err := c.Db.Table(new(models.SysDataPermissionDetail)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2615. if err == nil {
  2616. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2617. } else {
  2618. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2619. }
  2620. }
  2621. // _UpdateDataPermissionDetail
  2622. // @Title _UpdateDataPermissionDetail
  2623. // @Description 更新数据权限规则
  2624. // @Param string false "数据权限"
  2625. // @Success 200 {object} Account
  2626. // @Failure 403 :id is empty
  2627. func System_UpdateDataPermissionDetail(c *entitys.CtrlContext) {
  2628. var paramObj0 models.SysDataPermissionDetail
  2629. if err := c.Ctx.BindJSON(&paramObj0); err != nil {
  2630. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2631. return
  2632. }
  2633. user_id := c.Ctx.GetString("user_id")
  2634. paramObj0.LastUpdateBy = user_id
  2635. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2636. _, err := c.Db.ID(paramObj0.Id).Update(&paramObj0)
  2637. if err != nil {
  2638. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2639. } else {
  2640. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2641. }
  2642. }
  2643. // _FindDataPermissionDetailPage
  2644. // @Title _FindDataPermissionDetailPage
  2645. // @Description 分页获取数据权限规则
  2646. // @Success 200 {object} Account
  2647. // @Failure 403 :id is empty
  2648. func System_FindDataPermissionDetailPage(c *entitys.CtrlContext) {
  2649. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2650. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2651. data_permission_id := c.Ctx.DefaultQuery("data_permission_id", "")
  2652. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "data_permission_id": data_permission_id}
  2653. result, err := sysutils.PageSearch(c.Db, "system", "find_data_permission_detail_page", "sys_data_permission_detail", paramMap_i_t)
  2654. if err == nil {
  2655. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2656. } else {
  2657. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2658. }
  2659. }
  2660. // _ModifyPassword
  2661. // @Title _ModifyPassword
  2662. // @Description 修改密码
  2663. // @Param body models.ModifyPassword true ""
  2664. // @Success 200 {object} Account
  2665. // @Failure 403 :id is empty
  2666. func System_ModifyPassword(c *entitys.CtrlContext) {
  2667. var err error
  2668. var param models.ModifyPassword
  2669. if err = c.Ctx.BindJSON(&param); err != nil {
  2670. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2671. return
  2672. }
  2673. var errmsg string
  2674. switch {
  2675. case param.Origin == "":
  2676. errmsg = "原密码不能为空"
  2677. case param.New == "":
  2678. errmsg = "新密码不能为空"
  2679. case param.Confirm == "":
  2680. errmsg = "确认密码不能为空"
  2681. case param.Confirm != param.New:
  2682. errmsg = "两次密码不一致"
  2683. }
  2684. if errmsg != "" {
  2685. c.Ctx.JSON(500, sysmodel.SysReturn{500, errmsg, nil})
  2686. return
  2687. }
  2688. engine := c.PlatformDbEngine
  2689. var userId = c.Ctx.GetString("user_id")
  2690. if param.UserId == "" {
  2691. param.UserId = userId
  2692. }
  2693. var user sysmodel.SysUser
  2694. _, err = engine.ID(param.UserId).Get(&user)
  2695. if err != nil {
  2696. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2697. return
  2698. }
  2699. password := sysutils.HashPassword(param.Origin, "")
  2700. if !strings.EqualFold(password, user.Password) {
  2701. c.Ctx.JSON(500, sysmodel.SysReturn{500, "原密码错误", nil})
  2702. return
  2703. }
  2704. _, err = engine.Table(user).ID(user.Id).
  2705. Update(map[string]interface{}{
  2706. "password": sysutils.HashPassword(param.New, ""),
  2707. "last_update_by": userId,
  2708. "last_update_time": time.Now().UnixNano(),
  2709. })
  2710. if err == nil {
  2711. c.Ctx.JSON(200, sysmodel.SysReturn{200, "modify successfully", nil})
  2712. } else {
  2713. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2714. }
  2715. }
  2716. // _AddTagGroup
  2717. // @Title _AddTagGroup
  2718. // @Description 添加标签分组
  2719. // @Param name string false "分组名称"
  2720. // @Param code string false "编码"
  2721. // @Success 200 {object} Account
  2722. // @Failure 403 :id is empty
  2723. func System_AddTagGroup(c *entitys.CtrlContext) {
  2724. userId := c.Ctx.GetString("user_id")
  2725. var obj struct {
  2726. Name string `json:"name"`
  2727. Code string `json:"code"`
  2728. Tags []sysmodel.SysTag `json:"tags"`
  2729. }
  2730. if err := c.Ctx.BindJSON(&obj); err != nil {
  2731. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2732. return
  2733. }
  2734. tagGroup := sysmodel.SysTagGroup{}
  2735. tagGroup.Id = sysutils.NewUUID()
  2736. tagGroup.Name = obj.Name
  2737. tagGroup.Code = obj.Code
  2738. tagGroup.LastUpdateBy = userId
  2739. tagGroup.CreateBy = userId
  2740. tagGroup.CreateTime = sysmodel.NowLocal()
  2741. tagGroup.LastUpdateTime = time.Now().UnixNano()
  2742. tagGroup.DelFlag = 0
  2743. tags := []sysmodel.SysTag{}
  2744. for _, t := range obj.Tags {
  2745. tag := sysmodel.SysTag{}
  2746. tag.GroupId = tagGroup.Id
  2747. tag.Name = t.Name
  2748. tag.Id = sysutils.NewUUID()
  2749. tag.LastUpdateBy = userId
  2750. tag.CreateBy = userId
  2751. tag.CreateTime = sysmodel.NowLocal()
  2752. tag.LastUpdateTime = time.Now().UnixNano()
  2753. tag.DelFlag = 0
  2754. tags = append(tags, tag)
  2755. }
  2756. session := c.Db.NewSession()
  2757. session.Begin()
  2758. _, err := session.Insert(&tagGroup)
  2759. if err != nil {
  2760. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2761. session.Rollback()
  2762. return
  2763. }
  2764. _, err = session.Insert(&tags)
  2765. if err == nil {
  2766. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2767. session.Commit()
  2768. } else {
  2769. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2770. session.Rollback()
  2771. }
  2772. }
  2773. // _DelTagGroup
  2774. // @Title _DelTagGroup
  2775. // @Description 删除分组
  2776. // @Param id string false "角色ID"
  2777. // @Success 200 {object} Account
  2778. // @Failure 403 :id is empty
  2779. func System_DelTagGroup(c *entitys.CtrlContext) {
  2780. type Param struct {
  2781. Id string `json:"id"`
  2782. }
  2783. var params []Param
  2784. if err := c.Ctx.BindJSON(&params); err != nil {
  2785. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2786. return
  2787. }
  2788. ids := []string{}
  2789. for _, param := range params {
  2790. ids = append(ids, param.Id)
  2791. }
  2792. _, err := c.Db.Table(new(models.SysTagGroup)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2793. if err == nil {
  2794. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2795. } else {
  2796. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2797. }
  2798. }
  2799. // _UpdateTagGroup
  2800. // @Title _UpdateTagGroup
  2801. // @Description 修改分组
  2802. // @Param name string false "分组名称"
  2803. // @Param code string false "编码"
  2804. // @Success 200 {object} Account
  2805. // @Failure 403 :id is empty
  2806. func System_UpdateTagGroup(c *entitys.CtrlContext) {
  2807. userId := c.Ctx.GetString("user_id")
  2808. var obj struct {
  2809. sysmodel.SysTagGroup
  2810. Tags []sysmodel.SysTag `json:"tags"`
  2811. }
  2812. if err := c.Ctx.BindJSON(&obj); err != nil {
  2813. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2814. return
  2815. }
  2816. session := c.Db.NewSession()
  2817. session.Begin()
  2818. if _, err := c.Db.Table(new(sysmodel.SysTagGroup)).ID(obj.Id).Update(map[string]interface{}{"name": obj.Name, "code": obj.Code, "last_update_time": time.Now().UnixNano(), "last_update_by": userId}); err != nil {
  2819. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2820. session.Rollback()
  2821. return
  2822. }
  2823. for _, t := range obj.Tags {
  2824. if t.Id == "" {
  2825. tag := sysmodel.SysTag{}
  2826. tag.GroupId = obj.Id
  2827. tag.Name = t.Name
  2828. tag.Id = sysutils.NewUUID()
  2829. tag.LastUpdateBy = userId
  2830. tag.CreateBy = userId
  2831. tag.CreateTime = sysmodel.NowLocal()
  2832. tag.LastUpdateTime = time.Now().UnixNano()
  2833. tag.DelFlag = 0
  2834. if _, err := c.Db.Insert(&tag); err != nil {
  2835. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2836. session.Rollback()
  2837. return
  2838. }
  2839. } else {
  2840. if _, err := c.Db.Table(new(sysmodel.SysTag)).ID(t.Id).Update(map[string]interface{}{"name": t.Name, "last_update_time": time.Now().UnixNano(), "last_update_by": userId}); err != nil {
  2841. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2842. session.Rollback()
  2843. return
  2844. }
  2845. }
  2846. }
  2847. session.Commit()
  2848. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2849. }
  2850. // _GetTagGroup
  2851. // @Title _GetTagGroup
  2852. // @Description 根据标签ID获取标签分组
  2853. // @Param id string false "分组ID"
  2854. // @Success 200 {object} Account
  2855. // @Failure 403 :id is empty
  2856. func System_GetTagGroup(c *entitys.CtrlContext) {
  2857. //type Param struct {
  2858. // Id string `json:"id"`
  2859. //}
  2860. //var params []Param
  2861. //if err := c.Ctx.BindJSON(&params); err != nil {
  2862. // c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2863. // return
  2864. //}
  2865. //ids := []string{}
  2866. //for _, param := range params {
  2867. // ids = append(ids, param.Id)
  2868. //}
  2869. //
  2870. //_, err := c.Db.Table(new(models.SysTagGroup)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2871. //
  2872. //if err == nil {
  2873. // c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2874. //} else {
  2875. // c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2876. //}
  2877. }
  2878. // _TagGroupPage
  2879. // @Title _TagGroupPage
  2880. // @Description 获取标签分组分页数
  2881. // @Success 200 {object} Account
  2882. // @Failure 403 :id is empty
  2883. func System_TagGroupPage(c *entitys.CtrlContext) {
  2884. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2885. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2886. name := c.Ctx.DefaultQuery("name", "")
  2887. code := c.Ctx.DefaultQuery("code", "")
  2888. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code}
  2889. result, err := sysutils.PageSearch(c.Db, "system", "tag_group_page", "sys_tag_group", paramMap_i_t)
  2890. if err == nil {
  2891. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2892. } else {
  2893. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2894. }
  2895. }
  2896. // _TagPage
  2897. // @Title _TagPage
  2898. // @Description 获取标签分页数
  2899. // @Success 200 {object} Account
  2900. // @Failure 403 :id is empty
  2901. func System_TagPage(c *entitys.CtrlContext) {
  2902. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2903. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2904. group_id := c.Ctx.DefaultQuery("group_id", "")
  2905. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "group_id": group_id}
  2906. result, err := sysutils.PageSearch(c.Db, "system", "tag_page", "sys_tag", paramMap_i_t)
  2907. if err == nil {
  2908. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2909. } else {
  2910. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2911. }
  2912. }
  2913. // _UserTagPage
  2914. // @Title _UserTagPage
  2915. // @Description 分页获取用户标签
  2916. // @Success 200 {object} Account
  2917. // @Failure 403 :id is empty
  2918. func System_UserTagPage(c *entitys.CtrlContext) {
  2919. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2920. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2921. user_id := c.Ctx.DefaultQuery("user_id", "")
  2922. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "user_id": user_id}
  2923. result, err := sysutils.PageSearch(c.Db, "system", "user_tag_page", "sys_user_tag", paramMap_i_t)
  2924. if err == nil {
  2925. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2926. } else {
  2927. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2928. }
  2929. }
  2930. // _AddTag
  2931. // @Title _AddTag
  2932. // @Description 添加标签
  2933. // @Param name string false "分组名称"
  2934. // @Param group_id string false "分组ID"
  2935. // @Success 200 {object} Account
  2936. // @Failure 403 :id is empty
  2937. func System_AddTag(c *entitys.CtrlContext) {
  2938. name := c.Ctx.Query("name")
  2939. group_id := c.Ctx.Query("group_id")
  2940. ret := __none_func_system__(name, group_id)
  2941. if ret {
  2942. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2943. } else {
  2944. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2945. }
  2946. }
  2947. // _DelTag
  2948. // @Title _DelTag
  2949. // @Description 删除标签
  2950. // @Param id string false "标签ID"
  2951. // @Success 200 {object} Account
  2952. // @Failure 403 :id is empty
  2953. func System_DelTag(c *entitys.CtrlContext) {
  2954. type Param struct {
  2955. Id string `json:"id"`
  2956. }
  2957. var params []Param
  2958. if err := c.Ctx.BindJSON(&params); err != nil {
  2959. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2960. return
  2961. }
  2962. ids := []string{}
  2963. for _, param := range params {
  2964. ids = append(ids, param.Id)
  2965. }
  2966. _, err := c.Db.Table(new(models.SysTag)).In("id", ids).Update(map[string]interface{}{"del_flag": 1, "last_update_time": time.Now().UnixNano(), "last_update_by": c.Ctx.GetString("user_id")})
  2967. if err == nil {
  2968. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2969. } else {
  2970. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2971. }
  2972. }
  2973. // _UpdateTagGroup
  2974. // @Title _UpdateTagGroup
  2975. // @Description 修改标签
  2976. // @Param name string false "分组名称"
  2977. // @Param group_id string false "分组ID"
  2978. // @Success 200 {object} Account
  2979. // @Failure 403 :id is empty
  2980. func System_UpdateTag(c *entitys.CtrlContext) {
  2981. name := c.Ctx.Query("name")
  2982. group_id := c.Ctx.Query("group_id")
  2983. ret := __none_func_system__(name, group_id)
  2984. if ret {
  2985. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2986. } else {
  2987. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2988. }
  2989. }
  2990. // _GetTag
  2991. // @Title _GetTag
  2992. // @Description 根据标签ID获取标签
  2993. // @Param id string false "标签ID"
  2994. // @Success 200 {object} Account
  2995. // @Failure 403 :id is empty
  2996. func System_GetTag(c *entitys.CtrlContext) {
  2997. id := c.Ctx.Query("id")
  2998. ret := __none_func_system__(id)
  2999. if ret {
  3000. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  3001. } else {
  3002. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  3003. }
  3004. }
  3005. // _AddUserTag
  3006. // @Title _AddUserTag
  3007. // @Description 添加用户标签
  3008. // @Param user_id string false "用户ID"
  3009. // @Param tag_id string false "标签ID"
  3010. // @Success 200 {object} Account
  3011. // @Failure 403 :id is empty
  3012. func System_AddUserTag(c *entitys.CtrlContext) {
  3013. //user_id := c.Ctx.Query("user_id")
  3014. // //tag_id := c.Ctx.Query("tag_id")
  3015. var userTags []models.SysUserTag
  3016. if err := c.Ctx.BindJSON(&userTags); err != nil {
  3017. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  3018. return
  3019. }
  3020. userId := c.Ctx.GetString("user_id")
  3021. for i, _ := range userTags {
  3022. userTags[i].Id = sysutils.NewUUID()
  3023. //userTag.UserId = user_id
  3024. //userTag.TagId = tag_id
  3025. userTags[i].CreateTime = sysmodel.NowLocal()
  3026. userTags[i].CreateBy = userId
  3027. userTags[i].LastUpdateTime = time.Now().UnixNano()
  3028. userTags[i].LastUpdateBy = userId
  3029. userTags[i].DelFlag = 0
  3030. }
  3031. if _, err := c.Db.Insert(&userTags); err == nil {
  3032. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  3033. } else {
  3034. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  3035. }
  3036. }
  3037. // _DelUserTag
  3038. // @Title _DelUserTag
  3039. // @Description 删除标签
  3040. // @Param id string false "标签ID"
  3041. // @Success 200 {object} Account
  3042. // @Failure 403 :id is empty
  3043. func System_DelUserTag(c *entitys.CtrlContext) {
  3044. type Param struct {
  3045. Id string `json:"id"`
  3046. }
  3047. var params []Param
  3048. if err := c.Ctx.BindJSON(&params); err != nil {
  3049. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  3050. return
  3051. }
  3052. ids := []string{}
  3053. for _, param := range params {
  3054. ids = append(ids, param.Id)
  3055. }
  3056. var usertag sysmodel.SysUserTag
  3057. _, err := c.Db.In("id", ids).Delete(&usertag)
  3058. if err == nil {
  3059. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  3060. } else {
  3061. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  3062. }
  3063. }
  3064. func __none_func_system__(params ...interface{}) bool {
  3065. return true
  3066. }