SystemController.go 75 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502
  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. // 管理员角色ID 5c38ee66-c5e6-40a7-b190-86d115bae3e5,如果是管理员,可以看所有,否则只看到本部门
  151. user_id := c.Ctx.GetString("user_id")
  152. exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user_id, "5c38ee66-c5e6-40a7-b190-86d115bae3e5").Exist()
  153. //如果是管理员
  154. if exist {
  155. user_id = ""
  156. } else if rule_code != "" {
  157. var roleRules []models.SysDataPermissionDetail
  158. // 根据rule_code获取角色对应的接口规则
  159. err := c.Db.SqlMapClient("get_user_rule_by_code", rule_code, user_id).Find(&roleRules)
  160. if err != nil {
  161. roleRule = ""
  162. } else {
  163. roleRule = sysutils.ParseRule(roleRules)
  164. }
  165. }
  166. paramMap_i_t := map[string]interface{}{"sort": "name", "user_id": user_id, "role_rule": roleRule}
  167. result, err := sysutils.TreeSearch(c.Db, "system", "get_org_tree", "sys_org", paramMap_i_t)
  168. if err == nil {
  169. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  170. } else {
  171. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  172. }
  173. }
  174. // _FindOrgPage
  175. // @Title _FindOrgPage
  176. // @Description 获取组织架构分页数
  177. // @Success 200 {object} Account
  178. // @Failure 403 :id is empty
  179. func System_FindOrgPage(c *entitys.CtrlContext) {
  180. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  181. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  182. name := c.Ctx.DefaultQuery("name", "")
  183. code := c.Ctx.DefaultQuery("code", "")
  184. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  185. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code, "cn_id": cn_id}
  186. result, err := sysutils.PageSearch(c.Db, "system", "find_org_page", "sys_org", paramMap_i_t)
  187. if err == nil {
  188. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  189. } else {
  190. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  191. }
  192. }
  193. // _AddUser
  194. // @Title _AddUser
  195. // @Description 添加用户
  196. // @Param login_id string false "登录ID"
  197. // @Param password string false "密码"
  198. // @Param org_id string false "组织ID"
  199. // @Param email string false "邮箱"
  200. // @Success 200 {object} Account
  201. // @Failure 403 :id is empty
  202. func System_AddUser(c *entitys.CtrlContext) {
  203. tk, _ := c.Ctx.Get("token")
  204. opUser := tk.(*entitys.Token)
  205. var user sysmodel.SysUser
  206. err := c.Ctx.BindJSON(&user)
  207. if err != nil {
  208. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  209. }
  210. fmt.Println(user.LoginId, "-----add user-----", user.Password, " --- ", user.OrgId)
  211. //查找login_id是否存在
  212. exit, _ := c.PlatformDbEngine.Table(new(sysmodel.SysUser)).Where("login_id = ? and del_flag = ?", user.LoginId, 0).Exist()
  213. if exit {
  214. c.Ctx.JSON(200, sysmodel.SysReturn{500, "login_id exit", nil})
  215. return
  216. }
  217. user_id := c.Ctx.GetString("user_id")
  218. user.Id = sysutils.NewUUID()
  219. user.Name = user.LoginId
  220. user.CreateTime = models.NowLocal()
  221. user.LastUpdateTime = time.Now().UnixNano()
  222. user.CreateBy = user_id
  223. user.LastUpdateBy = user_id
  224. user.DelFlag = 0
  225. user.Domain = opUser.Domain
  226. user.Password = sysutils.HashPassword(user.Password, "")
  227. _, err = c.PlatformDbEngine.Insert(&user)
  228. if err != nil {
  229. c.Ctx.JSON(200, sysmodel.SysReturn{500, "平台插入用户错误:" + err.Error(), nil})
  230. }
  231. _, err = c.Db.Insert(&user)
  232. ret := __none_func_system__(user.LoginId, user.Password, user.OrgId, user.Email)
  233. if ret && err == nil {
  234. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  235. } else {
  236. c.Ctx.JSON(200, sysmodel.SysReturn{500, "域数据库插入用户错误:" + err.Error(), nil})
  237. }
  238. }
  239. // _DelUser
  240. // @Title _DelUser
  241. // @Description 删除用户
  242. // @Param id string false "用户ID"
  243. // @Success 200 {object} Account
  244. // @Failure 403 :id is empty
  245. func System_DelUser(c *entitys.CtrlContext) {
  246. type Param struct {
  247. Id string `json:"id"`
  248. }
  249. var params []Param
  250. c.Ctx.BindJSON(&params)
  251. ids := []string{}
  252. for _, param := range params {
  253. ids = append(ids, param.Id)
  254. }
  255. session := c.Db.NewSession()
  256. defer session.Close()
  257. session.Begin()
  258. _, err := c.Db.Table(new(models.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  259. if err != nil {
  260. session.Rollback()
  261. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  262. return
  263. }
  264. _, err = c.Db.Table(new(models.SysUserRole)).In("user_id", ids).Update(map[string]interface{}{"del_flag": 1})
  265. if err != nil {
  266. session.Rollback()
  267. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  268. return
  269. }
  270. session.Commit()
  271. _, err = c.PlatformDbEngine.Table(new(models.SysUser)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  272. if err == nil {
  273. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  274. } else {
  275. c.Ctx.JSON(200, sysmodel.SysReturn{500, "平台删除用户失败:" + err.Error(), nil})
  276. }
  277. }
  278. // _UpdateUser
  279. // @Title _UpdateUser
  280. // @Description 修改用户
  281. // @Param login_id string false "登录ID"
  282. // @Param password string false "密码"
  283. // @Param org_id string false "组织ID"
  284. // @Param email string false "邮箱"
  285. // @Success 200 {object} Account
  286. // @Failure 403 :id is empty
  287. func System_UpdateUser(c *entitys.CtrlContext) {
  288. tk, _ := c.Ctx.Get("token")
  289. user := tk.(*entitys.Token)
  290. var postData struct {
  291. sysmodel.SysUser
  292. UserRole []string `json:"user_role"`
  293. }
  294. //var user sysmodel.SysUser
  295. err := c.Ctx.BindJSON(&postData)
  296. if err != nil {
  297. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  298. return
  299. }
  300. //postData.LastUpdateTime = time.Now().UnixNano()
  301. //postData.LastUpdateBy = user.UserId
  302. session := c.Db.NewSession()
  303. defer session.Close()
  304. session.Begin()
  305. //paramMap, _ := sysutils.BeanToMap(&postData)
  306. 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}
  307. _, err = session.SqlMapClient("update_user", &paramMap).Execute()
  308. if err != nil {
  309. session.Rollback()
  310. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  311. return
  312. }
  313. _, err = c.PlatformDbEngine.SqlMapClient("update_user", &paramMap).Execute()
  314. if err != nil {
  315. session.Rollback()
  316. c.Ctx.JSON(500, sysmodel.SysReturn{500, "平台更新用户失败:" + err.Error(), nil})
  317. return
  318. }
  319. userRoles := []sysmodel.SysUserRole{}
  320. for _, roleId := range postData.UserRole {
  321. userRole := sysmodel.SysUserRole{}
  322. userRole.Id = sysutils.NewUUID()
  323. userRole.UserId = postData.Id
  324. userRole.RoleId = roleId
  325. userRole.DelFlag = 0
  326. userRole.CreateTime = sysmodel.NowLocal()
  327. userRole.CreateBy = user.UserId
  328. userRole.LastUpdateBy = user.UserId
  329. userRole.LastUpdateTime = time.Now().UnixNano()
  330. userRoles = append(userRoles, userRole)
  331. }
  332. _, err = session.SqlMapClient("delete_user_role", &map[string]interface{}{"user_id": postData.Id}).Execute()
  333. if err != nil {
  334. session.Rollback()
  335. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  336. return
  337. }
  338. _, err = session.InsertMulti(&userRoles)
  339. if err == nil {
  340. session.Commit()
  341. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  342. } else {
  343. session.Rollback()
  344. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  345. }
  346. }
  347. // _UpdatePassword
  348. // @Title _UpdatePassword
  349. // @Description 修改用户密码
  350. // @Param string false "用户ID"
  351. // @Param password string false "密码"
  352. // @Success 200 {object} Account
  353. // @Failure 403 :id is empty
  354. func System_UpdatePassword(c *entitys.CtrlContext) {
  355. var user sysmodel.SysUser
  356. err := c.Ctx.BindJSON(&user)
  357. operatorId := c.Ctx.GetString("user_id")
  358. if err != nil {
  359. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  360. return
  361. }
  362. user.Password = sysutils.HashPassword(user.Password, "")
  363. paramMap := map[string]interface{}{"id": user.Id, "password": user.Password, "last_update_time": time.Now().UnixNano(), "last_update_by": operatorId}
  364. _, err = c.PlatformDbEngine.SqlMapClient("update_user_password", &paramMap).Execute()
  365. if err == nil {
  366. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  367. } else {
  368. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  369. }
  370. }
  371. // _GetUser
  372. // @Title _GetUser
  373. // @Description 更加用户ID获取用户信息
  374. // @Param user_id string false "用户ID"
  375. // @Success 200 {object} Account
  376. // @Failure 403 :id is empty
  377. func System_GetUser(c *entitys.CtrlContext) {
  378. user_id := c.Ctx.Query("user_id")
  379. var user sysmodel.SysUser
  380. _, err := c.Db.SqlMapClient("selectone_sys_user", &map[string]interface{}{"id": user_id}).Get(&user)
  381. if err == nil {
  382. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", user})
  383. } else {
  384. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  385. }
  386. }
  387. // _AddRole
  388. // @Title _AddRole
  389. // @Description 添加角色
  390. // @Param name string false "角色名称"
  391. // @Param remark string false "备注"
  392. // @Success 200 {object} Account
  393. // @Failure 403 :id is empty
  394. func System_AddRole(c *entitys.CtrlContext) {
  395. var paramObj0 models.SysRole
  396. c.Ctx.BindJSON(&paramObj0)
  397. tk, _ := c.Ctx.Get("token")
  398. user := tk.(*entitys.Token)
  399. paramObj0.Id = sysutils.NewUUID()
  400. paramObj0.CreateBy = user.UserId
  401. paramObj0.LastUpdateBy = user.UserId
  402. paramObj0.CreateTime = models.NowLocal()
  403. paramObj0.LastUpdateTime = time.Now().UnixNano()
  404. paramObj0.DelFlag = 0
  405. //_, err := c.LocalSqlMapClient("insert_sys_role", &paramObj0).Execute()
  406. paramMap, err := sysutils.BeanToMap(&paramObj0)
  407. _, err = c.Db.SqlMapClient("insert_sys_role", paramMap).Execute()
  408. if err == nil {
  409. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  410. } else {
  411. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  412. }
  413. }
  414. // _DelRole
  415. // @Title _DelRole
  416. // @Description 添加角色
  417. // @Param id string false "角色ID"
  418. // @Success 200 {object} Account
  419. // @Failure 403 :id is empty
  420. func System_DelRole(c *entitys.CtrlContext) {
  421. type Param struct {
  422. Id string `json:"id"`
  423. }
  424. var params []Param
  425. c.Ctx.BindJSON(&params)
  426. ids := []string{}
  427. for _, param := range params {
  428. ids = append(ids, param.Id)
  429. }
  430. _, err := c.Db.Table(new(models.SysRole)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  431. if err == nil {
  432. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  433. } else {
  434. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  435. }
  436. }
  437. // _UpdateRole
  438. // @Title _UpdateRole
  439. // @Description 修改角色
  440. // @Param id string false "角色ID"
  441. // @Param name string false "角色名称"
  442. // @Param remark string false "备注"
  443. // @Success 200 {object} Account
  444. // @Failure 403 :id is empty
  445. func System_UpdateRole(c *entitys.CtrlContext) {
  446. var role sysmodel.SysRole
  447. err := c.Ctx.BindJSON(&role)
  448. if err != nil {
  449. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  450. return
  451. }
  452. paramMap, _ := sysutils.BeanToMap(&role)
  453. _, err = c.Db.SqlMapClient("update_sys_role", paramMap).Execute()
  454. if err == nil {
  455. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  456. } else {
  457. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  458. }
  459. }
  460. // _GetUserRoles
  461. // @Title _GetUserRoles
  462. // @Description 根据用户id获取用户角色
  463. // @Param user_id string false "用户ID"
  464. // @Success 200 {object} Account
  465. // @Failure 403 :id is empty
  466. func System_GetUserRoles(c *entitys.CtrlContext) {
  467. user_id := c.Ctx.Query("user_id")
  468. var roles []sysmodel.SysRole
  469. 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)
  470. if err == nil {
  471. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", roles})
  472. } else {
  473. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  474. }
  475. }
  476. // _FindRolePage
  477. // @Title _FindRolePage
  478. // @Description 角色分页
  479. // @Param page false "分页参数"
  480. // @Success 200 {object} Account
  481. // @Failure 403 :id is empty
  482. func System_FindRolePage(c *entitys.CtrlContext) {
  483. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  484. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  485. name := c.Ctx.DefaultQuery("name", "")
  486. code := c.Ctx.DefaultQuery("code", "")
  487. paramMap_i_t := map[string]interface{}{"name": name, "code": code, "page": page, "rows": rows}
  488. result, err := sysutils.PageSearch(c.Db, "system", "find_role_page", "sys_role", paramMap_i_t)
  489. if err == nil {
  490. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  491. } else {
  492. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  493. }
  494. }
  495. // _FindMenuPage
  496. // @Title _FindMenuPage
  497. // @Description 获取角色分页数
  498. // @Success 200 {object} Account
  499. // @Failure 403 :id is empty
  500. func System_FindMenuPage(c *entitys.CtrlContext) {
  501. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  502. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  503. user_id := c.Ctx.DefaultQuery("user_id", "")
  504. name := c.Ctx.DefaultQuery("name", "")
  505. code := c.Ctx.DefaultQuery("code", "")
  506. cn_id := c.Ctx.DefaultQuery("cn_id", "")
  507. _type := c.Ctx.DefaultQuery("type", "")
  508. type_op := c.Ctx.DefaultQuery("type_op", "")
  509. hidden := c.Ctx.DefaultQuery("hidden", "")
  510. op := template.HTML(type_op)
  511. // 管理员角色ID 5c38ee66-c5e6-40a7-b190-86d115bae3e5
  512. exist, _ := c.Db.Table("sys_user_role").Where("user_id = ? and role_id = ?", user_id, "5c38ee66-c5e6-40a7-b190-86d115bae3e5").Exist()
  513. //如果是管理员
  514. if exist {
  515. user_id = ""
  516. }
  517. 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}
  518. result, err := sysutils.PageSearch(c.Db, "system", "find_menu_page", "sys_menu", paramMap_i_t)
  519. if err == nil {
  520. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  521. } else {
  522. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  523. }
  524. }
  525. // _FindDomainPage
  526. // @Title _FindDomainPage
  527. // @Description 获取域分页数
  528. // @Success 200 {object} Account
  529. // @Failure 403 :id is empty
  530. func System_FindDomainPage(c *entitys.CtrlContext) {
  531. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  532. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  533. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows}
  534. result, err := sysutils.PageSearch(c.Db, "system", "find_domain_page", "sys_domain", paramMap_i_t)
  535. if err == nil {
  536. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  537. } else {
  538. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  539. }
  540. }
  541. // _FindRoleMenu
  542. // @Title _FindRoleMenu
  543. // @Description 查找角色权限
  544. // @Param role_id string false "角色id"
  545. // @Success 200 {object} Account
  546. // @Failure 403 :id is empty
  547. func System_FindRoleMenu(c *entitys.CtrlContext) {
  548. role_id := c.Ctx.Query("role_id")
  549. ret := __none_func_system__(role_id)
  550. if ret {
  551. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  552. } else {
  553. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  554. }
  555. }
  556. // _SaveRoleMenu
  557. // @Title _SaveRoleMenu
  558. // @Description 保存角色权限
  559. // @Param role_menu string false "角色权限"
  560. // @Success 200 {object} Account
  561. // @Failure 403 :id is empty
  562. func System_SaveRoleMenu(c *entitys.CtrlContext) {
  563. var paramObj0 []models.SaveRoleMenu
  564. c.Ctx.BindJSON(&paramObj0)
  565. ret := __none_func_system__(paramObj0)
  566. if ret {
  567. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  568. } else {
  569. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  570. }
  571. }
  572. // _RoleAll
  573. // @Title _RoleAll
  574. // @Description 查找所有角色
  575. // @Success 200 {object} Account
  576. // @Failure 403 :id is empty
  577. func System_RoleAll(c *entitys.CtrlContext) {
  578. ret := __none_func_system__()
  579. if ret {
  580. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  581. } else {
  582. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  583. }
  584. }
  585. // _FindPermissions
  586. // @Title _FindPermissions
  587. // @Description 查找用户权限
  588. // @Success 200 {object} Account
  589. // @Failure 403 :id is empty
  590. func System_FindPermissions(c *entitys.CtrlContext) {
  591. ret := __none_func_system__()
  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. // _AddMenu
  599. // @Title _AddMenu
  600. // @Description 添加菜单
  601. // @Param string false "菜单"
  602. // @Success 200 {object} Account
  603. // @Failure 403 :id is empty
  604. func System_AddMenu(c *entitys.CtrlContext) {
  605. var paramObj0 models.SysMenu
  606. c.Ctx.BindJSON(&paramObj0)
  607. tk, _ := c.Ctx.Get("token")
  608. user := tk.(*entitys.Token)
  609. paramObj0.Id = sysutils.NewUUID()
  610. paramObj0.CreateBy = user.UserId
  611. paramObj0.LastUpdateBy = user.UserId
  612. paramObj0.CreateTime = models.NowLocal()
  613. paramObj0.LastUpdateTime = time.Now().UnixNano()
  614. paramObj0.DelFlag = 0
  615. if paramObj0.Parent != "" {
  616. parentNodes := []sysmodel.SysMenu{}
  617. err := c.Db.SqlMapClient("select_parent_menu", paramObj0.Parent).Find(&parentNodes)
  618. if err != nil {
  619. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  620. return
  621. }
  622. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  623. } else {
  624. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  625. }
  626. //_, err := c.LocalSqlMapClient("insert_sys_menu", &paramObj0).Execute()
  627. paramMap, err := sysutils.BeanToMap(&paramObj0)
  628. _, err = c.Db.SqlMapClient("insert_sys_menu", paramMap).Execute()
  629. if err == nil {
  630. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  631. } else {
  632. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  633. }
  634. }
  635. // _DelMenu
  636. // @Title _DelMenu
  637. // @Description 删除菜单
  638. // @Param id string false "菜单ID"
  639. // @Success 200 {object} Account
  640. // @Failure 403 :id is empty
  641. func System_DelMenu(c *entitys.CtrlContext) {
  642. type Param struct {
  643. Id string `json:"id"`
  644. }
  645. var params []Param
  646. c.Ctx.BindJSON(&params)
  647. ids := []string{}
  648. for _, param := range params {
  649. ids = append(ids, param.Id)
  650. }
  651. _, err := c.Db.Table(new(models.SysMenu)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  652. if err == nil {
  653. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  654. } else {
  655. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  656. }
  657. }
  658. // _UpdateMenu
  659. // @Title _UpdateMenu
  660. // @Description 更新菜单
  661. // @Param string false "菜单"
  662. // @Success 200 {object} Account
  663. // @Failure 403 :id is empty
  664. func System_UpdateMenu(c *entitys.CtrlContext) {
  665. var paramObj0 models.SysMenu
  666. err := c.Ctx.BindJSON(&paramObj0)
  667. tk, _ := c.Ctx.Get("token")
  668. user := tk.(*entitys.Token)
  669. if paramObj0.Parent != "" {
  670. parentNode := sysmodel.SysMenu{}
  671. bool, err := c.Db.SqlMapClient("select_parent_menu", paramObj0.Parent).Get(&parentNode)
  672. if !bool || err != nil {
  673. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  674. return
  675. }
  676. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNode.Inheritance)
  677. } else {
  678. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  679. }
  680. paramObj0.LastUpdateBy = user.UserId
  681. paramObj0.LastUpdateTime = time.Now().UnixNano()
  682. sess := c.Db.NewSession()
  683. sess.Begin()
  684. paramMap, err := sysutils.BeanToMap(&paramObj0)
  685. _, err = sess.SqlMapClient("update_sys_menu", paramMap).Execute()
  686. if err != nil {
  687. sess.Rollback()
  688. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  689. }
  690. // 查找目录,修改Inheritance值
  691. //childrenNodes := []sysmodel.SysMenu{}
  692. childrenNode := new(sysmodel.SysMenu)
  693. rows, err := sess.SqlMapClient("select_children_menu", paramObj0.Id).Rows(childrenNode)
  694. if err != nil {
  695. sess.Rollback()
  696. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  697. return
  698. }
  699. defer rows.Close()
  700. for rows.Next() {
  701. err = rows.Scan(childrenNode)
  702. if err != nil {
  703. sess.Rollback()
  704. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  705. return
  706. }
  707. childrenNode.Inheritance = fmt.Sprintf("%s%s|", paramObj0.Inheritance, childrenNode.Id)
  708. childrenNode.LastUpdateBy = user.UserId
  709. childrenNode.LastUpdateTime = time.Now().UnixNano()
  710. paramMap, _ := sysutils.BeanToMap(childrenNode)
  711. _, err = c.Db.SqlMapClient("update_sys_menu", paramMap).Execute()
  712. if err != nil {
  713. break
  714. }
  715. }
  716. if err == nil {
  717. sess.Commit()
  718. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  719. } else {
  720. sess.Rollback()
  721. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  722. }
  723. }
  724. // _AddOrg
  725. // @Title _AddOrg
  726. // @Description 添加组织
  727. // @Param name string false "组织名称"
  728. // @Param domain string false "域"
  729. // @Param parent string false "父ID"
  730. // @Success 200 {object} Account
  731. // @Failure 403 :id is empty
  732. func System_AddOrg(c *entitys.CtrlContext) {
  733. var paramObj0 models.SysOrg
  734. c.Ctx.BindJSON(&paramObj0)
  735. tk, _ := c.Ctx.Get("token")
  736. user := tk.(*entitys.Token)
  737. paramObj0.Id = sysutils.NewUUID()
  738. paramObj0.CreateBy = user.UserId
  739. paramObj0.LastUpdateBy = user.UserId
  740. paramObj0.CreateTime = models.NowLocal()
  741. paramObj0.LastUpdateTime = time.Now().UnixNano()
  742. paramObj0.DelFlag = 0
  743. if paramObj0.Parent != "" {
  744. parentNodes := []sysmodel.SysOrg{}
  745. err := c.Db.SqlMapClient("one_sys_org", map[string]interface{}{"id": paramObj0.Parent}).Find(&parentNodes)
  746. if err != nil {
  747. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  748. return
  749. }
  750. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  751. } else {
  752. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  753. }
  754. //_, err := c.LocalSqlMapClient("insert_sys_org", &paramObj0).Execute()
  755. paramMap, err := sysutils.BeanToMap(&paramObj0)
  756. _, err = c.Db.SqlMapClient("insert_sys_org", paramMap).Execute()
  757. if err == nil {
  758. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  759. } else {
  760. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  761. }
  762. }
  763. // _DelOrg
  764. // @Title _DelOrg
  765. // @Description 删除组织
  766. // @Param id string array false "用户ID"
  767. // @Success 200 {object} Account
  768. // @Failure 403 :id is empty
  769. func System_DelOrg(c *entitys.CtrlContext) {
  770. type Param struct {
  771. Id string `json:"id"`
  772. }
  773. var params []Param
  774. c.Ctx.BindJSON(&params)
  775. ids := []string{}
  776. for _, param := range params {
  777. ids = append(ids, param.Id)
  778. }
  779. _, err := c.Db.Table(new(models.SysOrg)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  780. if err == nil {
  781. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  782. } else {
  783. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  784. }
  785. }
  786. // _UpdateOrg
  787. // @Title _UpdateOrg
  788. // @Description 修改组织
  789. // @Param name string false "组织名称"
  790. // @Param domain string false "域"
  791. // @Param parent string false "父ID"
  792. // @Success 200 {object} Account
  793. // @Failure 403 :id is empty
  794. func System_UpdateOrg(c *entitys.CtrlContext) {
  795. //name := c.Ctx.Query("name")
  796. //domain := c.Ctx.Query("domain")
  797. //parent := c.Ctx.Query("parent")
  798. var paramObj0 models.SysOrg
  799. err := c.Ctx.BindJSON(&paramObj0)
  800. tk, _ := c.Ctx.Get("token")
  801. user := tk.(*entitys.Token)
  802. if paramObj0.Parent != "" {
  803. parentNodes := []sysmodel.SysOrg{}
  804. err := c.Db.SqlMapClient("one_sys_org", paramObj0.Parent).Find(&parentNodes)
  805. if err != nil {
  806. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  807. return
  808. }
  809. paramObj0.Inheritance = fmt.Sprintf("|%s%s", paramObj0.Id, parentNodes[0].Inheritance)
  810. } else {
  811. paramObj0.Inheritance = fmt.Sprintf("|%s|", paramObj0.Id)
  812. }
  813. paramObj0.LastUpdateBy = user.UserId
  814. paramObj0.LastUpdateTime = time.Now().UnixNano()
  815. paramMap, err := sysutils.BeanToMap(&paramObj0)
  816. _, err = c.Db.SqlMapClient("update_sys_org", paramMap).Execute()
  817. if err == nil {
  818. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  819. } else {
  820. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  821. }
  822. }
  823. // _GetOrgByUserid
  824. // @Title _GetOrgByUserid
  825. // @Description 根据组织
  826. // @Param user_id string false "用户id"
  827. // @Success 200 {object} Account
  828. // @Failure 403 :id is empty
  829. func System_GetOrgUsers(c *entitys.CtrlContext) {
  830. user_id := c.Ctx.Query("user_id")
  831. role_id := c.Ctx.Query("role_id")
  832. fmt.Println(user_id, "---------", role_id)
  833. var err error
  834. //users := []sysmodel.SysUser{}
  835. var users []sysmodel.SysUser
  836. if role_id == "" {
  837. err = c.Db.SqlMapClient("get_org_users", user_id).Find(&users)
  838. } else {
  839. err = c.Db.SqlMapClient("get_org_role_users", user_id, role_id).Find(&users)
  840. if err != nil || users == nil {
  841. c.Ctx.JSON(500, sysmodel.SysReturn{500, "无法找到部门审批人!", nil})
  842. return
  843. }
  844. }
  845. if err == nil {
  846. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", users})
  847. } else {
  848. c.Ctx.JSON(500, sysmodel.SysReturn{500, "错误", nil})
  849. }
  850. }
  851. // _AddDomain
  852. // @Title _AddDomain
  853. // @Description 添加域
  854. // @Param false "域"
  855. // @Success 200 {object} Account
  856. // @Failure 403 :id is empty
  857. func System_AddDomain(c *entitys.CtrlContext) {
  858. var paramObj0 models.SysDomain
  859. c.Ctx.BindJSON(&paramObj0)
  860. ////1、测试连接串
  861. //db, err := xorm.NewEngine("mysql", paramObj0.DataSource)
  862. //if err == nil {
  863. // //engine.initOrmEngine(db, "mysql")
  864. // //c.BusinessOrmEngine[v.Domain] = db
  865. //}
  866. tk, _ := c.Ctx.Get("token")
  867. user := tk.(*entitys.Token)
  868. paramObj0.Id = sysutils.NewUUID()
  869. paramObj0.CreateBy = user.UserId
  870. paramObj0.LastUpdateBy = user.UserId
  871. paramObj0.CreateTime = sysmodel.NowLocal()
  872. paramObj0.LastUpdateTime = time.Now().UnixNano()
  873. paramObj0.Theme = "default"
  874. paramObj0.DelFlag = 0
  875. paramMap, err := sysutils.BeanToMap(&paramObj0)
  876. if err != nil {
  877. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  878. return
  879. }
  880. _, err = c.Db.SqlMapClient("insert_sys_domain", paramMap).Execute()
  881. if err == nil {
  882. //添加数据库基本用户权限数据
  883. ret := c.App.AddBusinessDb(paramObj0.Id, "admin@"+paramObj0.Domain, paramObj0.Domain, paramObj0.DataSource, true)
  884. if ret {
  885. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", paramObj0.Id})
  886. } else {
  887. c.Ctx.JSON(500, sysmodel.SysReturn{500, "数据库初始化错误。", nil})
  888. }
  889. } else {
  890. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  891. }
  892. }
  893. // _DelDomain
  894. // @Title _DelDomain
  895. // @Description 删除域
  896. // @Param id string false "域ID"
  897. // @Success 200 {object} Account
  898. // @Failure 403 :id is empty
  899. func System_DelDomain(c *entitys.CtrlContext) {
  900. type Param struct {
  901. Id string `json:"id"`
  902. }
  903. var params []Param
  904. c.Ctx.BindJSON(&params)
  905. ids := []string{}
  906. for _, param := range params {
  907. ids = append(ids, param.Id)
  908. }
  909. _, err := c.Db.Table(new(models.SysDomain)).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  910. if err != nil {
  911. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  912. return
  913. }
  914. ret := __none_func_system__()
  915. if ret {
  916. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  917. } else {
  918. c.Ctx.JSON(200, sysmodel.SysReturn{500, "", nil})
  919. }
  920. }
  921. // _UpdateDomain
  922. // @Title _UpdateDomain
  923. // @Description 修改域
  924. // @Param false "域"
  925. // @Success 200 {object} Account
  926. // @Failure 403 :id is empty
  927. func System_UpdateDomain(c *entitys.CtrlContext) {
  928. var paramObj0 models.SysDomain
  929. c.Ctx.BindJSON(&paramObj0)
  930. tk, _ := c.Ctx.Get("token")
  931. user := tk.(*entitys.Token)
  932. paramObj0.LastUpdateTime = time.Now().UnixNano()
  933. paramObj0.LastUpdateBy = user.UserId
  934. paramMap, err := sysutils.BeanToMap(&paramObj0)
  935. if err != nil {
  936. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  937. return
  938. }
  939. _, err = c.Db.SqlMapClient("update_sys_domain", paramMap).Execute()
  940. if err == nil {
  941. //添加数据库基本用户权限数据
  942. ret := c.App.AddBusinessDb(paramObj0.Id, "admin@"+paramObj0.Domain, paramObj0.Domain, paramObj0.DataSource, true)
  943. if ret {
  944. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", paramObj0.Id})
  945. } else {
  946. c.Ctx.JSON(500, sysmodel.SysReturn{500, "数据库初始化错误。", nil})
  947. }
  948. } else {
  949. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  950. }
  951. }
  952. // _GetDomain
  953. // @Title _GetDomain
  954. // @Description 根据domain获取域
  955. // @Param domain string false "域"
  956. // @Success 200 {object} Account
  957. // @Failure 403 :id is empty
  958. func System_GetDomain(c *entitys.CtrlContext) {
  959. domain := c.Ctx.Query("domain")
  960. var domainObj sysmodel.SysDomain
  961. _, err := c.PlatformDbEngine.Where("domain = ?", domain).Get(&domainObj)
  962. if err == nil {
  963. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", domainObj})
  964. } else {
  965. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  966. }
  967. }
  968. // _AddDomainMenu
  969. // @Title _AddDomainMenu
  970. // @Description 域添加菜单
  971. // @Param false "添加域菜单bean"
  972. // @Success 200 {object} Account
  973. // @Failure 403 :id is empty
  974. func System_AddDomainMenu(c *entitys.CtrlContext) {
  975. var paramObj0 struct {
  976. //域名ID
  977. DomainId string `json:"domain_id"`
  978. //菜单
  979. Menus []sysmodel.SysMenu `json:"menus"`
  980. // type
  981. Type int `json:"type"`
  982. }
  983. err := c.Ctx.BindJSON(&paramObj0)
  984. if err != nil {
  985. c.Ctx.JSON(500, sysmodel.SysReturn{500, "BindJSON error: " + err.Error(), nil})
  986. return
  987. }
  988. var domain sysmodel.SysDomain
  989. param := map[string]interface{}{"id": paramObj0.DomainId}
  990. _, err = c.Db.SqlMapClient("selectone_sys_domain", &param).Get(&domain)
  991. if err != nil {
  992. c.Ctx.JSON(500, sysmodel.SysReturn{500, "not find domain error: " + err.Error(), nil})
  993. return
  994. }
  995. var menuIds = make([]string, len(paramObj0.Menus))
  996. for i := range paramObj0.Menus {
  997. menuIds[i] = paramObj0.Menus[i].Id
  998. }
  999. var menus []sysmodel.SysMenu
  1000. err = c.Db.In("id", menuIds).Find(&menus)
  1001. if err != nil {
  1002. c.Ctx.JSON(500, sysmodel.SysReturn{500, "find menu error: " + err.Error(), nil})
  1003. return
  1004. }
  1005. for i := range menus {
  1006. for j := range paramObj0.Menus {
  1007. if menus[i].Id == paramObj0.Menus[j].Id {
  1008. menus[i].Name = paramObj0.Menus[j].Name
  1009. break
  1010. }
  1011. }
  1012. }
  1013. session := c.App.GetBusinessDb(domain.Domain).NewSession()
  1014. defer session.Close()
  1015. session.Begin()
  1016. deleteSqlMapKey := ""
  1017. if paramObj0.Type >= 0 {
  1018. deleteSqlMapKey = "delete_backend_sys_menu"
  1019. } else {
  1020. deleteSqlMapKey = "delete_app_sys_menu"
  1021. }
  1022. _, err = c.App.GetBusinessDb(domain.Domain).SqlMapClient(deleteSqlMapKey).Execute()
  1023. if err != nil {
  1024. session.Rollback()
  1025. c.Ctx.JSON(500, sysmodel.SysReturn{500, "Insert menu error: " + err.Error(), nil})
  1026. return
  1027. }
  1028. if len(paramObj0.Menus) <= 0 {
  1029. session.Commit()
  1030. c.Ctx.JSON(200, sysmodel.SysReturn{200, "the menus is empty", nil})
  1031. return
  1032. }
  1033. _, err = c.App.GetBusinessDb(domain.Domain).Insert(&paramObj0.Menus)
  1034. if err != nil {
  1035. session.Rollback()
  1036. c.Ctx.JSON(500, sysmodel.SysReturn{500, "Insert menu error: " + err.Error(), nil})
  1037. return
  1038. }
  1039. session.Commit()
  1040. ret := __none_func_system__(paramObj0)
  1041. if ret {
  1042. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1043. } else {
  1044. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1045. }
  1046. }
  1047. // _GetDomainMenuTree
  1048. // @Title _GetDomainMenuTree
  1049. // @Description 域添加菜单
  1050. // @Param domain_id string false "域id"
  1051. // @Success 200 {object} Account
  1052. // @Failure 403 :id is empty
  1053. func System_GetDomainMenuTree(c *entitys.CtrlContext) {
  1054. domain_id := c.Ctx.Query("domain_id")
  1055. _type := c.Ctx.DefaultQuery("type", "")
  1056. type_op := c.Ctx.DefaultQuery("type_op", "")
  1057. op := template.HTML(type_op)
  1058. var domain sysmodel.SysDomain
  1059. param := map[string]interface{}{"id": domain_id, "type": _type, "type_op": op}
  1060. _, err := c.Db.SqlMapClient("selectone_sys_domain", &param).Get(&domain)
  1061. if err != nil {
  1062. c.Ctx.JSON(500, sysmodel.SysReturn{500, "not find domain error: " + err.Error(), nil})
  1063. return
  1064. }
  1065. paramMap := map[string]interface{}{"user_id": "", "type": _type, "type_op": op, "name": "", "hidden": ""}
  1066. domainMenus, err := c.App.GetBusinessDb(domain.Domain).SqlTemplateClient("system_get_menu_tree.tpl", &paramMap).Query().List()
  1067. if err != nil {
  1068. c.Ctx.JSON(500, sysmodel.SysReturn{500, "get domain_menu tree: " + err.Error(), nil})
  1069. return
  1070. }
  1071. domainTree, err := sysutils.BuildTree("", domainMenus)
  1072. sysMenus, err := c.Db.SqlTemplateClient("system_get_menu_tree.tpl", &paramMap).Query().List()
  1073. if err != nil {
  1074. c.Ctx.JSON(500, sysmodel.SysReturn{500, "get sys_menu tree: " + err.Error(), nil})
  1075. return
  1076. }
  1077. var sysMenusMap map[string]map[string]interface{}
  1078. sysMenusMap = make(map[string]map[string]interface{}, 0)
  1079. for _, menu := range sysMenus {
  1080. sysMenusMap[menu["id"].(string)] = menu
  1081. }
  1082. //剔除域已存在的菜单
  1083. //for _, domainMenu := range domainMenus {
  1084. // delete(sysMenusMap, domainMenu["id"].(string))
  1085. //}
  1086. var sysMenuRest []map[string]interface{}
  1087. for _, menu := range sysMenusMap {
  1088. sysMenuRest = append(sysMenuRest, menu)
  1089. }
  1090. sysTree, err := sysutils.BuildTree("", sysMenuRest)
  1091. ret := __none_func_system__(domain_id)
  1092. if ret {
  1093. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", map[string]interface{}{"sys_tree": sysTree, "domain_tree": domainTree}})
  1094. } else {
  1095. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1096. }
  1097. }
  1098. // _GetUserMenuTree
  1099. // @Title _GetUserMenuTree
  1100. // @Description 获取用户权限菜单
  1101. // @Param user_id string false "用户id"
  1102. // @Success 200 {object} Account
  1103. // @Failure 403 :id is empty
  1104. func System_GetRoleMenuTree(c *entitys.CtrlContext) {
  1105. role_id := c.Ctx.Query("role_id")
  1106. //paramMap := map[string]interface{}{"role_id": role_id}
  1107. //sysMenu, err := c.Db.SqlMapClient("get_role_no_have_menu_tree", &paramMap).Query().List()
  1108. //if err != nil {
  1109. // c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1110. // return
  1111. //}
  1112. //sysTree, err := sysutils.BuildTree("", sysMenu)
  1113. op := template.HTML(">=")
  1114. paramMap := map[string]interface{}{"user_id": "", "sort": "name", "type": 0, "type_op": op, "hidden": 0}
  1115. sysTree, err := sysutils.TreeSearch(c.Db, "system", "get_menu_tree", "sys_menu", paramMap)
  1116. if err != nil {
  1117. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1118. return
  1119. }
  1120. paramMap2 := map[string]interface{}{"role_id": role_id}
  1121. //roleTree, err := sysutils.TreeSearch(c.Db, "system", "get_role_menu_tree", "sys_menu", paramMap2)
  1122. roleMenu, err := c.Db.SqlMapClient("get_role_menu_tree", &paramMap2).Query().List()
  1123. if err != nil {
  1124. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1125. return
  1126. }
  1127. roleTree, err := sysutils.BuildTree("", roleMenu)
  1128. ret := __none_func_system__(role_id)
  1129. if ret {
  1130. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", map[string]interface{}{"sys_tree": sysTree, "role_tree": roleTree}})
  1131. } else {
  1132. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1133. }
  1134. }
  1135. // _AddRoleMenu
  1136. // @Title _AddRoleMenu
  1137. // @Description 添加角色菜单
  1138. // @Param menu_id false "菜单id"
  1139. // @Param role_id string false "角色id"
  1140. // @Success 200 {object} Account
  1141. // @Failure 403 :id is empty
  1142. func System_AddRoleMenu(c *entitys.CtrlContext) {
  1143. tk, _ := c.Ctx.Get("token")
  1144. user := tk.(*entitys.Token)
  1145. var paramObj0 struct {
  1146. MenuIds []string `json:"menu_ids"`
  1147. RoleId string `json:"role_id"`
  1148. }
  1149. c.Ctx.BindJSON(&paramObj0)
  1150. session := c.Db.NewSession()
  1151. defer session.Close()
  1152. session.Begin()
  1153. _, err := session.SqlMapClient("del_role_menu", paramObj0.RoleId).Execute()
  1154. if err != nil {
  1155. session.Rollback()
  1156. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1157. return
  1158. }
  1159. var roleMenus []*sysmodel.SysRoleMenu
  1160. for _, menu := range paramObj0.MenuIds {
  1161. roleMenu := &sysmodel.SysRoleMenu{}
  1162. roleMenu.Id = sysutils.NewUUID()
  1163. roleMenu.MenuId = menu
  1164. roleMenu.RoleId = paramObj0.RoleId
  1165. roleMenu.CreateBy = user.UserId
  1166. roleMenu.CreateTime = sysmodel.NowLocal()
  1167. roleMenus = append(roleMenus, roleMenu)
  1168. }
  1169. _, err = session.InsertMulti(&roleMenus)
  1170. if err != nil {
  1171. session.Rollback()
  1172. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1173. return
  1174. }
  1175. session.Commit()
  1176. ret := __none_func_system__(paramObj0)
  1177. if ret {
  1178. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1179. } else {
  1180. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1181. }
  1182. }
  1183. // _FindAreaPage
  1184. // @Title _FindAreaPage
  1185. // @Description 获取区域管理分页数
  1186. // @Success 200 {object} Account
  1187. // @Failure 403 :id is empty
  1188. func System_FindAreaPage(c *entitys.CtrlContext) {
  1189. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1190. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1191. var paramMap = make(map[string]interface{})
  1192. paramMap["page"] = page
  1193. paramMap["rows"] = rows
  1194. paramMap["del_flag"] = c.Ctx.Query("del_flag")
  1195. paramMap["id"] = c.Ctx.Query("id")
  1196. paramMap["name"] = c.Ctx.Query("name")
  1197. paramMap["parent"] = c.Ctx.Query("parent")
  1198. paramMap["inheritance"] = c.Ctx.Query("inheritance")
  1199. paramMap["temp_id"] = c.Ctx.Query("temp_id")
  1200. paramMap["manager"] = c.Ctx.Query("manager")
  1201. paramMap["org_id"] = c.Ctx.Query("org_id")
  1202. paramMap["org_name"] = c.Ctx.Query("org_name")
  1203. paramMap["org_inheritance"] = c.Ctx.Query("org_inheritance")
  1204. paramMap["manager_name"] = c.Ctx.Query("manager_name")
  1205. result, err := sysutils.PageSearch(c.Db, "system", "find_area_page", "sys_user", paramMap)
  1206. if err == nil {
  1207. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1208. } else {
  1209. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1210. }
  1211. }
  1212. // _AddArea
  1213. // @Title _AddArea
  1214. // @Description 添加区域
  1215. // @Param name string false "区域名称"
  1216. // @Param parent string false "父节点"
  1217. // @Param inheritance string false "继承关系"
  1218. // @Param org_id string false "组织ID"
  1219. // @Param temp_id string false "模板ID"
  1220. // @Param temp_value string false "模板内容"
  1221. // @Param manager string false "负责人"
  1222. // @Success 200 {object} Account
  1223. // @Failure 403 :id is empty
  1224. func System_AddArea(c *entitys.CtrlContext) {
  1225. var err error
  1226. var bean sysmodel.SysArea
  1227. if err = c.Ctx.BindJSON(&bean); err != nil {
  1228. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1229. return
  1230. }
  1231. user_id := c.Ctx.GetString("user_id")
  1232. bean.Id = sysutils.NewUUID()
  1233. bean.DelFlag = 0
  1234. bean.CreateBy = user_id
  1235. bean.LastUpdateBy = user_id
  1236. bean.CreateTime = sysmodel.NowLocal()
  1237. bean.LastUpdateTime = time.Now().UnixNano()
  1238. if bean.Parent != "" {
  1239. parentNodes := sysmodel.SysArea{}
  1240. _, err := c.Db.SqlMapClient("selectone_sys_area", &map[string]interface{}{"id": bean.Parent}).Get(&parentNodes)
  1241. if err != nil {
  1242. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1243. return
  1244. }
  1245. bean.Inheritance = fmt.Sprintf("|%s%s", bean.Id, parentNodes.Inheritance)
  1246. } else {
  1247. bean.Inheritance = fmt.Sprintf("|%s|", bean.Id)
  1248. }
  1249. _, err = c.Db.InsertOne(&bean)
  1250. if err == nil {
  1251. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1252. } else {
  1253. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1254. }
  1255. }
  1256. // _DelArea
  1257. // @Title _DelArea
  1258. // @Description 删除区域
  1259. // @Param ids string false "用户ID"
  1260. // @Success 200 {object} Account
  1261. // @Failure 403 :id is empty
  1262. func System_DelArea(c *entitys.CtrlContext) {
  1263. var err error
  1264. var bean = &models.SysArea{}
  1265. type Param struct {
  1266. Id string `json:"id"`
  1267. }
  1268. var params []Param
  1269. c.Ctx.BindJSON(&params)
  1270. ids := []string{}
  1271. for _, param := range params {
  1272. ids = append(ids, param.Id)
  1273. }
  1274. session := c.Db.NewSession()
  1275. defer session.Close()
  1276. if err := session.Begin(); err != nil {
  1277. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1278. return
  1279. }
  1280. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1281. if err == nil {
  1282. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1283. }
  1284. if err == nil {
  1285. err = session.Commit()
  1286. }
  1287. if err == nil {
  1288. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1289. } else {
  1290. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1291. }
  1292. }
  1293. // _RecoverArea
  1294. // @Title _RecoverArea
  1295. // @Description 恢复区域
  1296. // @Param ids string false "区域ID"
  1297. // @Success 200 {object} Account
  1298. // @Failure 403 :id is empty
  1299. func System_RecoverArea(c *entitys.CtrlContext) {
  1300. var err error
  1301. var bean = &models.SysArea{}
  1302. idArr := make([]string, 0)
  1303. if ids := c.Ctx.Query("ids"); ids == "" {
  1304. err = c.Ctx.BindJSON(&idArr)
  1305. if err != nil || len(idArr) <= 0 {
  1306. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1307. return
  1308. }
  1309. } else {
  1310. idArr = strings.Split(ids, ",")
  1311. }
  1312. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  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. // _UpdateArea
  1320. // @Title _UpdateArea
  1321. // @Description 修改区域
  1322. // @Param name string false "区域名称"
  1323. // @Param parent string false "父节点"
  1324. // @Param inheritance string false "继承关系"
  1325. // @Param org_id string false "组织ID"
  1326. // @Param temp_id string false "模板ID"
  1327. // @Param temp_value string false "模板内容"
  1328. // @Param manager string false "负责人"
  1329. // @Success 200 {object} Account
  1330. // @Failure 403 :id is empty
  1331. func System_UpdateArea(c *entitys.CtrlContext) {
  1332. var err error
  1333. var bean sysmodel.SysArea
  1334. if err = c.Ctx.BindJSON(&bean); err != nil {
  1335. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1336. return
  1337. }
  1338. user_id := c.Ctx.GetString("user_id")
  1339. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1340. if !exist && err == nil {
  1341. err = errors.New("record does not exist")
  1342. }
  1343. if err != nil {
  1344. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1345. return
  1346. }
  1347. bean.LastUpdateBy = user_id
  1348. bean.LastUpdateTime = time.Now().UnixNano()
  1349. if bean.Parent != "" {
  1350. parentNodes := sysmodel.SysArea{}
  1351. _, err := c.Db.SqlMapClient("selectone_sys_area", &map[string]interface{}{"id": bean.Parent}).Get(&parentNodes)
  1352. if err != nil {
  1353. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1354. return
  1355. }
  1356. if parentNodes.Inheritance == "" {
  1357. parentNodes.Inheritance = "|"
  1358. }
  1359. bean.Inheritance = fmt.Sprintf("|%s%s", bean.Id, parentNodes.Inheritance)
  1360. } else {
  1361. bean.Inheritance = fmt.Sprintf("|%s|", bean.Id)
  1362. }
  1363. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1364. if err == nil {
  1365. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1366. } else {
  1367. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1368. }
  1369. }
  1370. // _GetArea
  1371. // @Title _GetArea
  1372. // @Description 根据区域ID获取区域信息
  1373. // @Param id string false "区域ID"
  1374. // @Success 200 {object} Account
  1375. // @Failure 403 :id is empty
  1376. func System_GetArea(c *entitys.CtrlContext) {
  1377. id := c.Ctx.Query("id")
  1378. //var area sysmodel.SysArea
  1379. //exist, err := c.Db.SqlMapClient("get_area", &map[string]interface{}{"id": id}).Get(&area)
  1380. result := c.Db.SqlMapClient("get_area", &map[string]interface{}{"id": id}).Query()
  1381. if result.Result != nil && len(result.Result) > 0 {
  1382. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result.Result[0]})
  1383. } else {
  1384. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  1385. }
  1386. }
  1387. // _GetAreaTree
  1388. // @Title _GetAreaTree
  1389. // @Description 获取区域管理树
  1390. // @Success 200 {object} Account
  1391. // @Failure 403 :id is empty
  1392. func System_GetAreaTree(c *entitys.CtrlContext) {
  1393. paramMap_i_t := map[string]interface{}{"sort": "name"}
  1394. result, err := sysutils.TreeSearch(c.Db, "system", "get_area_tree", "sys_area", paramMap_i_t)
  1395. if err == nil {
  1396. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1397. } else {
  1398. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1399. }
  1400. }
  1401. // _FindAreaTemplatePage
  1402. // @Title _FindAreaTemplatePage
  1403. // @Description 获取区域模板分页数
  1404. // @Success 200 {object} Account
  1405. // @Failure 403 :id is empty
  1406. func System_FindAreaTemplatePage(c *entitys.CtrlContext) {
  1407. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1408. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1409. del_flag := c.Ctx.Query("del_flag")
  1410. name := c.Ctx.Query("name")
  1411. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name}
  1412. result, err := sysutils.PageSearch(c.Db, "system", "find_area_template_page", "sys_area", paramMap_i_t)
  1413. if err == nil {
  1414. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1415. } else {
  1416. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1417. }
  1418. }
  1419. // _AddAreaTemplate
  1420. // @Title _AddAreaTemplate
  1421. // @Description 添加区域模板
  1422. // @Param name string false "名称"
  1423. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1424. // @Param default int64 false "是否默认 1:是 0:否"
  1425. // @Success 200 {object} Account
  1426. // @Failure 403 :id is empty
  1427. func System_AddAreaTemplate(c *entitys.CtrlContext) {
  1428. var err error
  1429. var bean sysmodel.SysAreaTemplate
  1430. if err = c.Ctx.BindJSON(&bean); err != nil {
  1431. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1432. return
  1433. }
  1434. user_id := c.Ctx.GetString("user_id")
  1435. bean.Id = sysutils.NewUUID()
  1436. bean.DelFlag = 0
  1437. bean.CreateBy = user_id
  1438. bean.LastUpdateBy = user_id
  1439. bean.CreateTime = sysmodel.NowLocal()
  1440. bean.LastUpdateTime = time.Now().UnixNano()
  1441. _, err = c.Db.InsertOne(&bean)
  1442. if err == nil {
  1443. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1444. } else {
  1445. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1446. }
  1447. }
  1448. // _UpdateAreaTemplate
  1449. // @Title _UpdateAreaTemplate
  1450. // @Description 修改区域模板
  1451. // @Param name string false "名称"
  1452. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1453. // @Param default int64 false "是否默认 1:是 0:否"
  1454. // @Success 200 {object} Account
  1455. // @Failure 403 :id is empty
  1456. func System_UpdateAreaTemplate(c *entitys.CtrlContext) {
  1457. var err error
  1458. var bean sysmodel.SysAreaTemplate
  1459. if err = c.Ctx.BindJSON(&bean); err != nil {
  1460. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1461. return
  1462. }
  1463. user_id := c.Ctx.GetString("user_id")
  1464. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1465. if !exist && err == nil {
  1466. err = errors.New("record does not exist")
  1467. }
  1468. if err != nil {
  1469. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1470. return
  1471. }
  1472. bean.LastUpdateBy = user_id
  1473. bean.LastUpdateTime = time.Now().UnixNano()
  1474. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1475. if err == nil {
  1476. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1477. } else {
  1478. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1479. }
  1480. }
  1481. // _DelAreaTemplate
  1482. // @Title _DelAreaTemplate
  1483. // @Description 删除区域模板
  1484. // @Param ids string false "区域模板ID 多个之间(,)隔开"
  1485. // @Success 200 {object} Account
  1486. // @Failure 403 :id is empty
  1487. func System_DelAreaTemplate(c *entitys.CtrlContext) {
  1488. var err error
  1489. var bean = &models.SysAreaTemplate{}
  1490. type Param struct {
  1491. Id string `json:"id"`
  1492. }
  1493. var params []Param
  1494. c.Ctx.BindJSON(&params)
  1495. ids := []string{}
  1496. for _, param := range params {
  1497. ids = append(ids, param.Id)
  1498. }
  1499. session := c.Db.NewSession()
  1500. defer session.Close()
  1501. if err := session.Begin(); err != nil {
  1502. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1503. return
  1504. }
  1505. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1506. if err == nil {
  1507. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1508. }
  1509. if err == nil {
  1510. err = session.Commit()
  1511. }
  1512. if err == nil {
  1513. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1514. } else {
  1515. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1516. }
  1517. }
  1518. // _RecoverAreaTemplate
  1519. // @Title _RecoverAreaTemplate
  1520. // @Description 恢复区域模板
  1521. // @Param ids string false "区域模板ID 多个之间(,)隔开"
  1522. // @Success 200 {object} Account
  1523. // @Failure 403 :id is empty
  1524. func System_RecoverAreaTemplate(c *entitys.CtrlContext) {
  1525. var err error
  1526. var bean = &models.SysAreaTemplate{}
  1527. idArr := make([]string, 0)
  1528. if ids := c.Ctx.Query("ids"); ids == "" {
  1529. err = c.Ctx.BindJSON(&idArr)
  1530. if err != nil || len(idArr) <= 0 {
  1531. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1532. return
  1533. }
  1534. } else {
  1535. idArr = strings.Split(ids, ",")
  1536. }
  1537. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  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. // _GetAreaTemplate
  1545. // @Title _GetAreaTemplate
  1546. // @Description 根据区域模板ID获取区域模板信息
  1547. // @Param id string false "区域模板ID"
  1548. // @Success 200 {object} Account
  1549. // @Failure 403 :id is empty
  1550. func System_GetAreaTemplate(c *entitys.CtrlContext) {
  1551. id := c.Ctx.Query("id")
  1552. var area sysmodel.SysAreaTemplate
  1553. exist, err := c.Db.SqlMapClient("selectone_sys_area_template", &map[string]interface{}{"id": id}).Get(&area)
  1554. if !exist && err == nil {
  1555. err = errors.New("record does not exist")
  1556. }
  1557. if err == nil {
  1558. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  1559. } else {
  1560. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1561. }
  1562. }
  1563. // _FindAreaTemplateDetailPage
  1564. // @Title _FindAreaTemplateDetailPage
  1565. // @Description 获取区域模板明细分页数
  1566. // @Success 200 {object} Account
  1567. // @Failure 403 :id is empty
  1568. func System_FindAreaTemplateDetailPage(c *entitys.CtrlContext) {
  1569. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1570. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1571. del_flag := c.Ctx.Query("del_flag")
  1572. __sort__ := c.Ctx.Query("__sort__")
  1573. name := c.Ctx.Query("name")
  1574. temp_id := c.Ctx.Query("temp_id")
  1575. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name, "temp_id": temp_id, "__sort__": __sort__}
  1576. result, err := sysutils.PageSearch(c.Db, "system", "find_area_template_detail_page", "sys_area", paramMap_i_t)
  1577. if err == nil {
  1578. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1579. } else {
  1580. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1581. }
  1582. }
  1583. // _AddAreaTemplateDetail
  1584. // @Title _AddAreaTemplateDetail
  1585. // @Description 添加区域模板明细
  1586. // @Param temp_id string false "模板id"
  1587. // @Param name string false "名称"
  1588. // @Param value string false "值"
  1589. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1590. // @Param priority int64 false "优先级"
  1591. // @Param content string false "内容"
  1592. // @Success 200 {object} Account
  1593. // @Failure 403 :id is empty
  1594. func System_AddAreaTemplateDetail(c *entitys.CtrlContext) {
  1595. var err error
  1596. var bean sysmodel.SysAreaTemplateDetail
  1597. if err = c.Ctx.BindJSON(&bean); err != nil {
  1598. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1599. return
  1600. }
  1601. user_id := c.Ctx.GetString("user_id")
  1602. bean.Id = sysutils.NewUUID()
  1603. bean.DelFlag = 0
  1604. bean.CreateBy = user_id
  1605. bean.LastUpdateBy = user_id
  1606. bean.CreateTime = sysmodel.NowLocal()
  1607. bean.LastUpdateTime = time.Now().UnixNano()
  1608. _, err = c.Db.InsertOne(&bean)
  1609. if err == nil {
  1610. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1611. } else {
  1612. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1613. }
  1614. }
  1615. // _UpdateAreaTemplateDetail
  1616. // @Title _UpdateAreaTemplateDetail
  1617. // @Description 修改区域模板明细
  1618. // @Param temp_id string false "模板id"
  1619. // @Param name string false "名称"
  1620. // @Param value string false "值"
  1621. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1622. // @Param priority int64 false "优先级"
  1623. // @Param content string false "内容"
  1624. // @Success 200 {object} Account
  1625. // @Failure 403 :id is empty
  1626. func System_UpdateAreaTemplateDetail(c *entitys.CtrlContext) {
  1627. var err error
  1628. var bean sysmodel.SysAreaTemplateDetail
  1629. if err = c.Ctx.BindJSON(&bean); err != nil {
  1630. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1631. return
  1632. }
  1633. user_id := c.Ctx.GetString("user_id")
  1634. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1635. if !exist && err == nil {
  1636. err = errors.New("record does not exist")
  1637. }
  1638. if err != nil {
  1639. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1640. return
  1641. }
  1642. bean.LastUpdateBy = user_id
  1643. bean.LastUpdateTime = time.Now().UnixNano()
  1644. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1645. if err == nil {
  1646. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1647. } else {
  1648. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1649. }
  1650. }
  1651. // _DelAreaTemplateDetail
  1652. // @Title _DelAreaTemplateDetail
  1653. // @Description 删除区域模板明细
  1654. // @Param ids string false "区域模板明细ID 多个之间(,)隔开"
  1655. // @Success 200 {object} Account
  1656. // @Failure 403 :id is empty
  1657. func System_DelAreaTemplateDetail(c *entitys.CtrlContext) {
  1658. var err error
  1659. var bean = &models.SysAreaTemplateDetail{}
  1660. type Param struct {
  1661. Id string `json:"id"`
  1662. }
  1663. var params []Param
  1664. c.Ctx.BindJSON(&params)
  1665. ids := []string{}
  1666. for _, param := range params {
  1667. ids = append(ids, param.Id)
  1668. }
  1669. session := c.Db.NewSession()
  1670. defer session.Close()
  1671. if err := session.Begin(); err != nil {
  1672. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1673. return
  1674. }
  1675. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1676. if err == nil {
  1677. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1678. }
  1679. if err == nil {
  1680. err = session.Commit()
  1681. }
  1682. if err == nil {
  1683. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1684. } else {
  1685. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1686. }
  1687. }
  1688. // _RecoverAreaTemplateDetail
  1689. // @Title _RecoverAreaTemplateDetail
  1690. // @Description 恢复区域模板明细
  1691. // @Param ids string false "区域模板明细ID 多个之间(,)隔开"
  1692. // @Success 200 {object} Account
  1693. // @Failure 403 :id is empty
  1694. func System_RecoverAreaTemplateDetail(c *entitys.CtrlContext) {
  1695. var err error
  1696. var bean = &models.SysAreaTemplateDetail{}
  1697. idArr := make([]string, 0)
  1698. if ids := c.Ctx.Query("ids"); ids == "" {
  1699. err = c.Ctx.BindJSON(&idArr)
  1700. if err != nil || len(idArr) <= 0 {
  1701. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1702. return
  1703. }
  1704. } else {
  1705. idArr = strings.Split(ids, ",")
  1706. }
  1707. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  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. // _GetAreaTemplateDetail
  1715. // @Title _GetAreaTemplateDetail
  1716. // @Description 根据区域模板明细ID获取区域模板明细信息
  1717. // @Param id string false "区域模板明细ID"
  1718. // @Success 200 {object} Account
  1719. // @Failure 403 :id is empty
  1720. func System_GetAreaTemplateDetail(c *entitys.CtrlContext) {
  1721. id := c.Ctx.Query("id")
  1722. var area sysmodel.SysAreaTemplateDetail
  1723. exist, err := c.Db.SqlMapClient("selectone_sys_area_template_detail", &map[string]interface{}{"id": id}).Get(&area)
  1724. if !exist && err == nil {
  1725. err = errors.New("record does not exist")
  1726. }
  1727. if err == nil {
  1728. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  1729. } else {
  1730. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1731. }
  1732. }
  1733. // _FindUserTemplatePage
  1734. // @Title _FindUserTemplatePage
  1735. // @Description 获取用户信息模板分页数
  1736. // @Success 200 {object} Account
  1737. // @Failure 403 :id is empty
  1738. func System_FindUserTemplatePage(c *entitys.CtrlContext) {
  1739. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1740. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1741. del_flag := c.Ctx.Query("del_flag")
  1742. name := c.Ctx.Query("name")
  1743. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name}
  1744. result, err := sysutils.PageSearch(c.Db, "system", "find_user_template_page", "sys_area", paramMap_i_t)
  1745. if err == nil {
  1746. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1747. } else {
  1748. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1749. }
  1750. }
  1751. // _AddUserTemplate
  1752. // @Title _AddUserTemplate
  1753. // @Description 添加用户信息模板
  1754. // @Param name string false "名称"
  1755. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1756. // @Param default int64 false "是否默认 1:是 0:否"
  1757. // @Success 200 {object} Account
  1758. // @Failure 403 :id is empty
  1759. func System_AddUserTemplate(c *entitys.CtrlContext) {
  1760. var err error
  1761. var bean sysmodel.SysUserTemplate
  1762. if err = c.Ctx.BindJSON(&bean); err != nil {
  1763. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1764. return
  1765. }
  1766. user_id := c.Ctx.GetString("user_id")
  1767. bean.Id = sysutils.NewUUID()
  1768. bean.DelFlag = 0
  1769. bean.CreateBy = user_id
  1770. bean.LastUpdateBy = user_id
  1771. bean.CreateTime = sysmodel.NowLocal()
  1772. bean.LastUpdateTime = time.Now().UnixNano()
  1773. _, err = c.Db.InsertOne(&bean)
  1774. if err == nil {
  1775. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1776. } else {
  1777. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1778. }
  1779. }
  1780. // _UpdateUserTemplate
  1781. // @Title _UpdateUserTemplate
  1782. // @Description 修改用户信息模板
  1783. // @Param name string false "名称"
  1784. // @Param type int64 false "模板类型 0:固定模板 1:动态模板 2:自定义模板"
  1785. // @Param default int64 false "是否默认 1:是 0:否"
  1786. // @Success 200 {object} Account
  1787. // @Failure 403 :id is empty
  1788. func System_UpdateUserTemplate(c *entitys.CtrlContext) {
  1789. var err error
  1790. var bean sysmodel.SysUserTemplate
  1791. if err = c.Ctx.BindJSON(&bean); err != nil {
  1792. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1793. return
  1794. }
  1795. user_id := c.Ctx.GetString("user_id")
  1796. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1797. if !exist && err == nil {
  1798. err = errors.New("record does not exist")
  1799. }
  1800. if err != nil {
  1801. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1802. return
  1803. }
  1804. bean.LastUpdateBy = user_id
  1805. bean.LastUpdateTime = time.Now().UnixNano()
  1806. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1807. if err == nil {
  1808. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1809. } else {
  1810. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1811. }
  1812. }
  1813. // _DelUserTemplate
  1814. // @Title _DelUserTemplate
  1815. // @Description 删除用户信息模板
  1816. // @Param ids string false "用户信息模板ID 多个之间(,)隔开"
  1817. // @Success 200 {object} Account
  1818. // @Failure 403 :id is empty
  1819. func System_DelUserTemplate(c *entitys.CtrlContext) {
  1820. var err error
  1821. var bean = &models.SysUserTemplate{}
  1822. type Param struct {
  1823. Id string `json:"id"`
  1824. }
  1825. var params []Param
  1826. c.Ctx.BindJSON(&params)
  1827. ids := []string{}
  1828. for _, param := range params {
  1829. ids = append(ids, param.Id)
  1830. }
  1831. session := c.Db.NewSession()
  1832. defer session.Close()
  1833. if err := session.Begin(); err != nil {
  1834. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1835. return
  1836. }
  1837. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  1838. if err == nil {
  1839. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  1840. }
  1841. if err == nil {
  1842. err = session.Commit()
  1843. }
  1844. if err == nil {
  1845. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  1846. } else {
  1847. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1848. }
  1849. }
  1850. // _RecoverUserTemplate
  1851. // @Title _RecoverUserTemplate
  1852. // @Description 恢复用户信息模板
  1853. // @Param ids string false "用户信息模板ID 多个之间(,)隔开"
  1854. // @Success 200 {object} Account
  1855. // @Failure 403 :id is empty
  1856. func System_RecoverUserTemplate(c *entitys.CtrlContext) {
  1857. var err error
  1858. var bean = &models.SysUserTemplate{}
  1859. idArr := make([]string, 0)
  1860. if ids := c.Ctx.Query("ids"); ids == "" {
  1861. err = c.Ctx.BindJSON(&idArr)
  1862. if err != nil || len(idArr) <= 0 {
  1863. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  1864. return
  1865. }
  1866. } else {
  1867. idArr = strings.Split(ids, ",")
  1868. }
  1869. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  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. // _GetUserTemplate
  1877. // @Title _GetUserTemplate
  1878. // @Description 根据用户信息模板ID获取用户信息模板信息
  1879. // @Param id string false "用户信息模板ID"
  1880. // @Success 200 {object} Account
  1881. // @Failure 403 :id is empty
  1882. func System_GetUserTemplate(c *entitys.CtrlContext) {
  1883. id := c.Ctx.Query("id")
  1884. var area sysmodel.SysUserTemplate
  1885. exist, err := c.Db.SqlMapClient("selectone_sys_user_template", &map[string]interface{}{"id": id}).Get(&area)
  1886. if !exist && err == nil {
  1887. err = errors.New("record does not exist")
  1888. }
  1889. if err == nil {
  1890. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  1891. } else {
  1892. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1893. }
  1894. }
  1895. // _FindUserTemplateDetailPage
  1896. // @Title _FindUserTemplateDetailPage
  1897. // @Description 获取用户信息模板明细分页数
  1898. // @Success 200 {object} Account
  1899. // @Failure 403 :id is empty
  1900. func System_FindUserTemplateDetailPage(c *entitys.CtrlContext) {
  1901. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  1902. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  1903. del_flag := c.Ctx.Query("del_flag")
  1904. __sort__ := c.Ctx.Query("__sort__")
  1905. name := c.Ctx.Query("name")
  1906. temp_id := c.Ctx.Query("temp_id")
  1907. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "del_flag": del_flag, "name": name, "temp_id": temp_id, "__sort__": __sort__}
  1908. result, err := sysutils.PageSearch(c.Db, "system", "find_user_template_detail_page", "sys_area", paramMap_i_t)
  1909. if err == nil {
  1910. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  1911. } else {
  1912. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1913. }
  1914. }
  1915. // _AddUserTemplateDetail
  1916. // @Title _AddUserTemplateDetail
  1917. // @Description 添加用户信息模板明细
  1918. // @Param temp_id string false "模板id"
  1919. // @Param name string false "名称"
  1920. // @Param value string false "值"
  1921. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1922. // @Param priority int64 false "优先级"
  1923. // @Param content string false "内容"
  1924. // @Success 200 {object} Account
  1925. // @Failure 403 :id is empty
  1926. func System_AddUserTemplateDetail(c *entitys.CtrlContext) {
  1927. var err error
  1928. var bean sysmodel.SysUserTemplateDetail
  1929. if err = c.Ctx.BindJSON(&bean); err != nil {
  1930. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1931. return
  1932. }
  1933. user_id := c.Ctx.GetString("user_id")
  1934. bean.Id = sysutils.NewUUID()
  1935. bean.DelFlag = 0
  1936. bean.CreateBy = user_id
  1937. bean.LastUpdateBy = user_id
  1938. bean.CreateTime = sysmodel.NowLocal()
  1939. bean.LastUpdateTime = time.Now().UnixNano()
  1940. _, err = c.Db.InsertOne(&bean)
  1941. if err == nil {
  1942. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1943. } else {
  1944. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1945. }
  1946. }
  1947. // _UpdateUserTemplateDetail
  1948. // @Title _UpdateUserTemplateDetail
  1949. // @Description 修改用户信息模板明细
  1950. // @Param temp_id string false "模板id"
  1951. // @Param name string false "名称"
  1952. // @Param value string false "值"
  1953. // @Param type int64 false "类型 0:数值项 1:单选项 2:文字项 3:列表项"
  1954. // @Param priority int64 false "优先级"
  1955. // @Param content string false "内容"
  1956. // @Success 200 {object} Account
  1957. // @Failure 403 :id is empty
  1958. func System_UpdateUserTemplateDetail(c *entitys.CtrlContext) {
  1959. var err error
  1960. var bean sysmodel.SysUserTemplateDetail
  1961. if err = c.Ctx.BindJSON(&bean); err != nil {
  1962. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1963. return
  1964. }
  1965. user_id := c.Ctx.GetString("user_id")
  1966. exist, err := c.Db.Table(&bean).Where("id = ?", bean.Id).Exist()
  1967. if !exist && err == nil {
  1968. err = errors.New("record does not exist")
  1969. }
  1970. if err != nil {
  1971. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  1972. return
  1973. }
  1974. bean.LastUpdateBy = user_id
  1975. bean.LastUpdateTime = time.Now().UnixNano()
  1976. _, err = c.Db.AllCols().ID(bean.Id).Update(&bean)
  1977. if err == nil {
  1978. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", bean.Id})
  1979. } else {
  1980. c.Ctx.JSON(200, sysmodel.SysReturn{500, err.Error(), nil})
  1981. }
  1982. }
  1983. // _DelUserTemplateDetail
  1984. // @Title _DelUserTemplateDetail
  1985. // @Description 删除用户信息模板明细
  1986. // @Param ids string false "用户信息模板明细ID 多个之间(,)隔开"
  1987. // @Success 200 {object} Account
  1988. // @Failure 403 :id is empty
  1989. func System_DelUserTemplateDetail(c *entitys.CtrlContext) {
  1990. var err error
  1991. var bean = &models.SysUserTemplateDetail{}
  1992. type Param struct {
  1993. Id string `json:"id"`
  1994. }
  1995. var params []Param
  1996. c.Ctx.BindJSON(&params)
  1997. ids := []string{}
  1998. for _, param := range params {
  1999. ids = append(ids, param.Id)
  2000. }
  2001. session := c.Db.NewSession()
  2002. defer session.Close()
  2003. if err := session.Begin(); err != nil {
  2004. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2005. return
  2006. }
  2007. _, err = session.Table(bean).Where("del_flag=1").In("id", ids).Delete(bean)
  2008. if err == nil {
  2009. _, err = session.Table(bean).In("id", ids).Update(map[string]interface{}{"del_flag": 1})
  2010. }
  2011. if err == nil {
  2012. err = session.Commit()
  2013. }
  2014. if err == nil {
  2015. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2016. } else {
  2017. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2018. }
  2019. }
  2020. // _RecoverUserTemplateDetail
  2021. // @Title _RecoverUserTemplateDetail
  2022. // @Description 恢复用户信息模板明细
  2023. // @Param ids string false "用户信息模板明细ID 多个之间(,)隔开"
  2024. // @Success 200 {object} Account
  2025. // @Failure 403 :id is empty
  2026. func System_RecoverUserTemplateDetail(c *entitys.CtrlContext) {
  2027. var err error
  2028. var bean = &models.SysUserTemplateDetail{}
  2029. idArr := make([]string, 0)
  2030. if ids := c.Ctx.Query("ids"); ids == "" {
  2031. err = c.Ctx.BindJSON(&idArr)
  2032. if err != nil || len(idArr) <= 0 {
  2033. c.Ctx.JSON(500, sysmodel.SysReturn{500, "ids is empty", nil})
  2034. return
  2035. }
  2036. } else {
  2037. idArr = strings.Split(ids, ",")
  2038. }
  2039. _, err = c.Db.Table(bean).In("id", idArr).Update(map[string]interface{}{"del_flag": 0})
  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. // _GetUserTemplateDetail
  2047. // @Title _GetUserTemplateDetail
  2048. // @Description 根据用户信息模板明细ID获取用户信息模板明细信息
  2049. // @Param id string false "用户信息模板明细ID"
  2050. // @Success 200 {object} Account
  2051. // @Failure 403 :id is empty
  2052. func System_GetUserTemplateDetail(c *entitys.CtrlContext) {
  2053. id := c.Ctx.Query("id")
  2054. var area sysmodel.SysUserTemplateDetail
  2055. exist, err := c.Db.SqlMapClient("selectone_sys_user_template_detail", &map[string]interface{}{"id": id}).Get(&area)
  2056. if !exist && err == nil {
  2057. err = errors.New("record does not exist")
  2058. }
  2059. if err == nil {
  2060. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", area})
  2061. } else {
  2062. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2063. }
  2064. }
  2065. // _AddOptionset
  2066. // @Title _AddOptionset
  2067. // @Description 添加字典
  2068. // @Param false "字典"
  2069. // @Success 200 {object} Account
  2070. // @Failure 403 :id is empty
  2071. func System_AddOptionset(c *entitys.CtrlContext) {
  2072. var paramObj0 models.SysOptionset
  2073. c.Ctx.BindJSON(&paramObj0)
  2074. user_id := c.Ctx.GetString("user_id")
  2075. paramObj0.Id = sysutils.NewUUID()
  2076. paramObj0.CreateBy = user_id
  2077. paramObj0.CreateTime = sysmodel.NowLocal()
  2078. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2079. paramObj0.LastUpdateBy = user_id
  2080. paramObj0.DelFlag = 0
  2081. paramMap, _ := sysutils.BeanToMap(&paramObj0)
  2082. _, err := c.Db.SqlMapClient("insert_sys_optionset", paramMap).Execute()
  2083. if err == nil {
  2084. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2085. } else {
  2086. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2087. }
  2088. }
  2089. // _DelOptionset
  2090. // @Title _DelOptionset
  2091. // @Description 删除字典
  2092. // @Param id string false "字典ID"
  2093. // @Success 200 {object} Account
  2094. // @Failure 403 :id is empty
  2095. func System_DelOptionset(c *entitys.CtrlContext) {
  2096. type Param struct {
  2097. Id string `json:"id"`
  2098. }
  2099. var params []Param
  2100. c.Ctx.BindJSON(&params)
  2101. ids := []string{}
  2102. for _, param := range params {
  2103. ids = append(ids, param.Id)
  2104. }
  2105. _, 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")})
  2106. if err == nil {
  2107. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2108. } else {
  2109. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2110. }
  2111. }
  2112. // _UpdateOptionset
  2113. // @Title _UpdateOptionset
  2114. // @Description 修改字典
  2115. // @Param false "字典"
  2116. // @Success 200 {object} Account
  2117. // @Failure 403 :id is empty
  2118. func System_UpdateOptionset(c *entitys.CtrlContext) {
  2119. var paramObj0 models.SysOptionset
  2120. c.Ctx.BindJSON(&paramObj0)
  2121. user_id := c.Ctx.GetString("user_id")
  2122. paramObj0.LastUpdateBy = user_id
  2123. paramObj0.LastUpdateTime = time.Now().UnixNano()
  2124. paramMap, _ := sysutils.BeanToMap(&paramObj0)
  2125. _, err := c.Db.SqlMapClient("update_sys_optionset", paramMap).Execute()
  2126. if err == nil {
  2127. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2128. } else {
  2129. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2130. }
  2131. }
  2132. // _FindOptionsetPage
  2133. // @Title _FindOptionsetPage
  2134. // @Description 获取字典分页数
  2135. // @Success 200 {object} Account
  2136. // @Failure 403 :id is empty
  2137. func System_FindOptionsetPage(c *entitys.CtrlContext) {
  2138. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2139. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2140. name := c.Ctx.DefaultQuery("name", "")
  2141. code := c.Ctx.DefaultQuery("code", "")
  2142. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows, "name": name, "code": code}
  2143. result, err := sysutils.PageSearch(c.Db, "system", "find_optionset_page", "sys_optionset", paramMap_i_t)
  2144. if err == nil {
  2145. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2146. } else {
  2147. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2148. }
  2149. }
  2150. // _GetOptionsetByCode
  2151. // @Title _GetOptionsetByCode
  2152. // @Description 根据编码查找字典
  2153. // @Param code string false "字典编码"
  2154. // @Success 200 {object} Account
  2155. // @Failure 403 :id is empty
  2156. func System_GetOptionsetByCode(c *entitys.CtrlContext) {
  2157. code := c.Ctx.Query("code")
  2158. var option sysmodel.SysOptionset
  2159. exit, err := c.Db.Table(new(sysmodel.SysOptionset)).Where("code = ?", code).Get(&option)
  2160. if exit && err == nil {
  2161. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", option})
  2162. } else {
  2163. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2164. }
  2165. }
  2166. // _AddDataPermission
  2167. // @Title _AddDataPermission
  2168. // @Description 添加数据权限
  2169. // @Param string false "数据权限"
  2170. // @Success 200 {object} Account
  2171. // @Failure 403 :id is empty
  2172. func System_AddDataPermission(c *entitys.CtrlContext) {
  2173. var paramObj0 models.SysDataPermission
  2174. c.Ctx.BindJSON(&paramObj0)
  2175. ret := __none_func_system__(paramObj0)
  2176. if ret {
  2177. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2178. } else {
  2179. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2180. }
  2181. }
  2182. // _DelDataPermission
  2183. // @Title _DelDataPermission
  2184. // @Description 删除数据权限
  2185. // @Param id string false "数据权限ID"
  2186. // @Success 200 {object} Account
  2187. // @Failure 403 :id is empty
  2188. func System_DelDataPermission(c *entitys.CtrlContext) {
  2189. id := c.Ctx.Query("id")
  2190. ret := __none_func_system__(id)
  2191. if ret {
  2192. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2193. } else {
  2194. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2195. }
  2196. }
  2197. // _UpdateDataPermission
  2198. // @Title _UpdateDataPermission
  2199. // @Description 更新数据权限
  2200. // @Param string false "数据权限"
  2201. // @Success 200 {object} Account
  2202. // @Failure 403 :id is empty
  2203. func System_UpdateDataPermission(c *entitys.CtrlContext) {
  2204. var paramObj0 models.SysDataPermission
  2205. c.Ctx.BindJSON(&paramObj0)
  2206. ret := __none_func_system__(paramObj0)
  2207. if ret {
  2208. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", nil})
  2209. } else {
  2210. c.Ctx.JSON(500, sysmodel.SysReturn{500, "", nil})
  2211. }
  2212. }
  2213. // _FindDataPermissionPage
  2214. // @Title _FindDataPermissionPage
  2215. // @Description 分页获取数据权限
  2216. // @Success 200 {object} Account
  2217. // @Failure 403 :id is empty
  2218. func System_FindDataPermissionPage(c *entitys.CtrlContext) {
  2219. page, _ := strconv.Atoi(c.Ctx.DefaultQuery("page", "1"))
  2220. rows, _ := strconv.Atoi(c.Ctx.DefaultQuery("rows", "10"))
  2221. paramMap_i_t := map[string]interface{}{"page": page, "rows": rows}
  2222. result, err := sysutils.PageSearch(c.Db, "system", "find_data_permission_page", "data_permission", paramMap_i_t)
  2223. if err == nil {
  2224. c.Ctx.JSON(200, sysmodel.SysReturn{200, "", result})
  2225. } else {
  2226. c.Ctx.JSON(500, sysmodel.SysReturn{500, err.Error(), nil})
  2227. }
  2228. }
  2229. func __none_func_system__(params ...interface{}) bool {
  2230. return true
  2231. }