SystemController.go 74 KB

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