SystemController.go 90 KB

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