public_api_controller.go 15KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560
  1. package controllers
  2. import (
  3. "XT_New/enums"
  4. "XT_New/models"
  5. "XT_New/service"
  6. "encoding/json"
  7. "fmt"
  8. "os"
  9. "path"
  10. "runtime"
  11. "strings"
  12. "time"
  13. "github.com/astaxie/beego"
  14. )
  15. type PublicApiController struct {
  16. BaseAPIController
  17. }
  18. func PublicApiRegistRouters() {
  19. beego.Router("/api/public/getadviceconfig", &PublicApiController{}, "Get:GetDoctorAdviceConfig")
  20. beego.Router("/api/public/servertime", &PublicApiController{}, "Get:GetServerTime")
  21. beego.Router("/api/app/release", &PublicApiController{}, "Get:AppRelease")
  22. beego.Router("/api/get", &PublicApiController{}, "Get:GetJson")
  23. beego.Router("/api/public/handledata", &PublicApiController{}, "Post:HandleData")
  24. }
  25. func (c *PublicApiController) GetDoctorAdviceConfig() {
  26. drugs, _, _ := service.GetPublicDrugDics()
  27. drugways, _, _ := service.GetPublicDrugWayDics()
  28. efs, _, _ := service.GetPublicExecutionFrequencyDics()
  29. c.ServeSuccessJSON(map[string]interface{}{
  30. "drugs": drugs,
  31. "drugways": drugways,
  32. "efs": efs,
  33. })
  34. }
  35. func (c *PublicApiController) GetServerTime() {
  36. timeNow := time.Now()
  37. timeNowStamp := timeNow.Unix()
  38. timeNowStr := timeNow.Format("2006-01-02 15:04:05")
  39. c.ServeSuccessJSON(map[string]interface{}{
  40. "time": timeNowStr,
  41. "timestamp": timeNowStamp,
  42. })
  43. }
  44. func (c *PublicApiController) AppRelease() {
  45. // appId := c.GetString("appid")
  46. version := c.GetString("version")
  47. appType, _ := c.GetInt64("app_type", 0)
  48. appVersion, err := service.GetAppVersionByAppType(appType)
  49. if err != nil {
  50. c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  51. return
  52. }
  53. if appVersion == nil {
  54. c.ServeSuccessJSON(map[string]interface{}{
  55. "version": nil,
  56. "state": 2,
  57. })
  58. return
  59. }
  60. state := strings.Compare(version, appVersion.Version)
  61. // state := 1
  62. if state < 0 {
  63. c.ServeSuccessJSON(map[string]interface{}{
  64. "version": appVersion,
  65. "state": appVersion.Status,
  66. })
  67. return
  68. }
  69. c.ServeSuccessJSON(map[string]interface{}{
  70. "version": nil,
  71. "state": 2,
  72. })
  73. return
  74. }
  75. func (this *PublicApiController) GetJson() {
  76. type Global struct {
  77. DeviceSN string
  78. Version string
  79. Timestamp string
  80. InterfaceSource string
  81. }
  82. type RBPResultModel struct {
  83. Sys string
  84. Dia string
  85. HR string
  86. MeasureTime string
  87. }
  88. type ScannerResultModel struct {
  89. Code string
  90. }
  91. type IDCardResultModel struct {
  92. IDCardNo string
  93. UserName string
  94. Age string
  95. Female string
  96. Male string
  97. SocialSecurityNo string
  98. }
  99. type JsonTemp struct {
  100. Global Global
  101. RBPResultModel RBPResultModel
  102. ScannerResultModel ScannerResultModel
  103. IDCardResultModel IDCardResultModel
  104. }
  105. var person JsonTemp
  106. err3 := json.Unmarshal([]byte(this.GetString("params")), &person)
  107. fmt.Println(err3)
  108. fmt.Println(person.Global)
  109. //temp := JsonTemp{
  110. // Global:Global{
  111. // DeviceSN:"1122",
  112. // Version:"1122",
  113. // Timestamp:"1222",
  114. // InterfaceSource:"1233",
  115. // },
  116. // RBPResultModel: RBPResultModel{
  117. // Sys:"12",
  118. // Dia:"22",
  119. // HR:"23",
  120. // MeasureTime:"123",
  121. // },
  122. // ScannerResultModel:ScannerResultModel{
  123. // Code:"1233",
  124. // },
  125. // IDCardResultModel:IDCardResultModel{
  126. // IDCardNo:"123",
  127. // UserName:"123",
  128. // Age:"123",
  129. // Female:"123",
  130. // Male:"123",
  131. // SocialSecurityNo:"123",
  132. // },
  133. //}
  134. //
  135. //jsonBytes, err := json.Marshal(temp)
  136. //if err != nil {
  137. // fmt.Println(err)
  138. //}
  139. //fmt.Println(string(jsonBytes))
  140. }
  141. func (c *PublicApiController) HandleData() {
  142. org_app, _ := service.GetAllAppOrg()
  143. org_role, _ := service.GetAllRole()
  144. var org_ids []int64
  145. for _, apps := range org_app {
  146. xt_org_app, _ := service.GetAppByType(int64(apps.OrgId), 3)
  147. scrm_org_app, _ := service.GetAppByType(int64(apps.OrgId), 1)
  148. cdm_org_app, _ := service.GetAppByType(int64(apps.OrgId), 4)
  149. mall_org_app, _ := service.GetAppByType(int64(apps.OrgId), 5)
  150. org_app_6, _ := service.GetAppByType(int64(apps.OrgId), 6)
  151. org_app_7, _ := service.GetAppByType(int64(apps.OrgId), 7)
  152. org_app_8, _ := service.GetAppByType(int64(apps.OrgId), 8)
  153. org_app_9, _ := service.GetAppByType(int64(apps.OrgId), 9)
  154. org_app_10, _ := service.GetAppByType(int64(apps.OrgId), 10)
  155. org_app_11, _ := service.GetAppByType(int64(apps.OrgId), 11)
  156. org_app_12, _ := service.GetAppByType(int64(apps.OrgId), 12)
  157. org_app_13, _ := service.GetAppByType(int64(apps.OrgId), 13)
  158. org_app_14, _ := service.GetAppByType(int64(apps.OrgId), 14)
  159. org_app_15, _ := service.GetAppByType(int64(apps.OrgId), 15)
  160. var xt_temp_org_app *models.OrgApp
  161. var mall_temp_org_app *models.OrgApp
  162. if xt_org_app == nil || xt_org_app.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  163. app, _ := service.GetOrgApp(0, 3)
  164. org, _ := service.GetOrgById(int64(apps.OrgId))
  165. app.Id = 0
  166. app.OrgId = apps.OrgId
  167. app.Creator = int(org.Creator)
  168. app.Number = 0
  169. app.Status = 1
  170. app.ModifyTime = time.Now().Unix()
  171. app.CreateTime = time.Now().Unix()
  172. service.CreateOrgApp(app)
  173. xt_temp_org_app = app
  174. } else {
  175. xt_temp_org_app = xt_org_app
  176. }
  177. if scrm_org_app == nil || scrm_org_app.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  178. app, _ := service.GetOrgApp(0, 1)
  179. //org, _ := service.GetOrgById(int64(12))
  180. org, _ := service.GetOrgById(int64(apps.OrgId))
  181. app.OrgId = apps.OrgId
  182. app.Id = 0
  183. app.Creator = int(org.Creator)
  184. app.Number = 0
  185. app.Status = 1
  186. app.ModifyTime = time.Now().Unix()
  187. app.CreateTime = time.Now().Unix()
  188. service.CreateOrgApp(app)
  189. }
  190. if cdm_org_app == nil || cdm_org_app.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  191. app, _ := service.GetOrgApp(0, 4)
  192. //org, _ := service.GetOrgById(int64(12))
  193. org, _ := service.GetOrgById(int64(apps.OrgId))
  194. app.OrgId = apps.OrgId
  195. app.Creator = int(org.Creator)
  196. app.Number = 0
  197. app.Id = 0
  198. app.Status = 1
  199. app.ModifyTime = time.Now().Unix()
  200. app.CreateTime = time.Now().Unix()
  201. service.CreateOrgApp(app)
  202. }
  203. if mall_org_app == nil || mall_org_app.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  204. app, _ := service.GetOrgApp(0, 5)
  205. //org, _ := service.GetOrgById(int64(12))
  206. org, _ := service.GetOrgById(int64(apps.OrgId))
  207. app.OrgId = apps.OrgId
  208. app.Creator = int(org.Creator)
  209. app.Number = 0
  210. app.Id = 0
  211. app.Status = 1
  212. app.ModifyTime = time.Now().Unix()
  213. app.CreateTime = time.Now().Unix()
  214. service.CreateOrgApp(app)
  215. mall_temp_org_app = app
  216. } else {
  217. mall_temp_org_app = mall_org_app
  218. }
  219. if org_app_6 == nil || org_app_6.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  220. app, _ := service.GetOrgApp(0, 6)
  221. //org, _ := service.GetOrgById(int64(12))
  222. org, _ := service.GetOrgById(int64(apps.OrgId))
  223. app.OrgId = apps.OrgId
  224. app.Creator = int(org.Creator)
  225. app.Number = 1
  226. app.Id = 0
  227. app.Status = 1
  228. app.ModifyTime = time.Now().Unix()
  229. app.CreateTime = time.Now().Unix()
  230. app.Pid = xt_temp_org_app.Id
  231. service.CreateOrgApp(app)
  232. }
  233. if org_app_7 == nil || org_app_7.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  234. app, _ := service.GetOrgApp(0, 7)
  235. //org, _ := service.GetOrgById(int64(12))
  236. org, _ := service.GetOrgById(int64(apps.OrgId))
  237. app.OrgId = apps.OrgId
  238. app.Creator = int(org.Creator)
  239. app.Number = 0
  240. app.Status = 2
  241. app.Id = 0
  242. app.ModifyTime = time.Now().Unix()
  243. app.CreateTime = time.Now().Unix()
  244. app.Pid = xt_temp_org_app.Id
  245. service.CreateOrgApp(app)
  246. }
  247. if org_app_8 == nil || org_app_8.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  248. app, _ := service.GetOrgApp(0, 8)
  249. //org, _ := service.GetOrgById(int64(12))
  250. org, _ := service.GetOrgById(int64(apps.OrgId))
  251. app.OrgId = apps.OrgId
  252. app.Creator = int(org.Creator)
  253. app.Number = 3
  254. app.Id = 0
  255. app.Pid = mall_temp_org_app.Id
  256. app.Status = 1
  257. app.ModifyTime = time.Now().Unix()
  258. app.CreateTime = time.Now().Unix()
  259. service.CreateOrgApp(app)
  260. }
  261. if org_app_9 == nil || org_app_9.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  262. app, _ := service.GetOrgApp(0, 9)
  263. //org, _ := service.GetOrgById(int64(12))
  264. org, _ := service.GetOrgById(int64(apps.OrgId))
  265. app.OrgId = apps.OrgId
  266. app.Pid = xt_temp_org_app.Id
  267. app.Creator = int(org.Creator)
  268. app.Number = 4
  269. app.Id = 0
  270. app.Status = 1
  271. app.ModifyTime = time.Now().Unix()
  272. app.CreateTime = time.Now().Unix()
  273. service.CreateOrgApp(app)
  274. }
  275. if org_app_10 == nil || org_app_10.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  276. app, _ := service.GetOrgApp(0, 10)
  277. //org, _ := service.GetOrgById(int64(12))
  278. org, _ := service.GetOrgById(int64(apps.OrgId))
  279. app.OrgId = apps.OrgId
  280. app.Creator = int(org.Creator)
  281. app.Pid = xt_temp_org_app.Id
  282. app.Number = 5
  283. app.Id = 0
  284. app.Status = 1
  285. app.ModifyTime = time.Now().Unix()
  286. app.CreateTime = time.Now().Unix()
  287. service.CreateOrgApp(app)
  288. }
  289. if org_app_11 == nil || org_app_11.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  290. app, _ := service.GetOrgApp(0, 11)
  291. //org, _ := service.GetOrgById(int64(12))
  292. org, _ := service.GetOrgById(int64(apps.OrgId))
  293. app.OrgId = app.OrgId
  294. app.Creator = int(org.Creator)
  295. app.Pid = xt_temp_org_app.Id
  296. app.Id = 0
  297. app.Number = 6
  298. app.Status = 1
  299. app.ModifyTime = time.Now().Unix()
  300. app.CreateTime = time.Now().Unix()
  301. service.CreateOrgApp(app)
  302. }
  303. if org_app_12 == nil || org_app_12.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  304. app, _ := service.GetOrgApp(0, 12)
  305. //org, _ := service.GetOrgById(int64(12))
  306. org, _ := service.GetOrgById(int64(apps.OrgId))
  307. app.OrgId = apps.OrgId
  308. app.Creator = int(org.Creator)
  309. app.Pid = xt_temp_org_app.Id
  310. app.Number = 7
  311. app.Status = 1
  312. app.Id = 0
  313. app.ModifyTime = time.Now().Unix()
  314. app.CreateTime = time.Now().Unix()
  315. service.CreateOrgApp(app)
  316. }
  317. if org_app_13 == nil || org_app_13.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  318. app, _ := service.GetOrgApp(0, 13)
  319. //org, _ := service.GetOrgById(int64(12))
  320. org, _ := service.GetOrgById(int64(apps.OrgId))
  321. app.OrgId = apps.OrgId
  322. app.Creator = int(org.Creator)
  323. app.Pid = xt_temp_org_app.Id
  324. app.Number = 8
  325. app.Id = 0
  326. app.Status = 1
  327. app.ModifyTime = time.Now().Unix()
  328. app.CreateTime = time.Now().Unix()
  329. service.CreateOrgApp(app)
  330. }
  331. if org_app_14 == nil || org_app_14.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  332. app, _ := service.GetOrgApp(0, 14)
  333. //org, _ := service.GetOrgById(int64(12))
  334. org, _ := service.GetOrgById(int64(apps.OrgId))
  335. app.OrgId = apps.OrgId
  336. app.Creator = int(org.Creator)
  337. app.Pid = xt_temp_org_app.Id
  338. app.Id = 0
  339. app.Number = 9
  340. app.Status = 1
  341. app.ModifyTime = time.Now().Unix()
  342. app.CreateTime = time.Now().Unix()
  343. service.CreateOrgApp(app)
  344. }
  345. if org_app_15 == nil || org_app_15.Id == 0 { //判断之前是否有创建该app类型,如果没有则插入数据
  346. app, _ := service.GetOrgApp(0, 15)
  347. //org, _ := service.GetOrgById(int64(12))
  348. org, _ := service.GetOrgById(int64(apps.OrgId))
  349. app.OrgId = apps.OrgId
  350. app.Creator = int(org.Creator)
  351. app.Pid = xt_temp_org_app.Id
  352. app.Number = 10
  353. app.Status = 1
  354. app.Id = 0
  355. app.ModifyTime = time.Now().Unix()
  356. app.CreateTime = time.Now().Unix()
  357. service.CreateOrgApp(app)
  358. }
  359. }
  360. for _, role := range org_role {
  361. org_ids = append(org_ids, role.OrgId)
  362. }
  363. //
  364. //
  365. ////创建内置角色
  366. InitRoleAndPurviews(org_ids)
  367. //var org_id int = 0
  368. ////管理员
  369. //app_roles := service.GetAllUserRoleByUserTypeOne(org_id)
  370. //for _, item := range app_roles{
  371. // var ids string
  372. // if len(item.RoleIds) == 0{
  373. // ids = strconv.FormatInt( item.RoleId,10)
  374. // }else{
  375. //
  376. // ids = item.RoleIds + ","+strconv.FormatInt( item.RoleId,10)
  377. // }
  378. //
  379. // service.UpdateRoleIds(item.Id, ids)
  380. //}
  381. ////护士医生
  382. //app_roles2 := service.GetAllUserRoleByUserTypeOther(org_id)
  383. //for _, item := range app_roles2{
  384. // var ids string
  385. // if len(item.RoleIds) == 0{
  386. // ids = strconv.FormatInt( item.RoleId,10)
  387. // }else{
  388. // ids = item.RoleIds + ","+strconv.FormatInt( item.RoleId,10)
  389. // }
  390. // if item.UserType == 2{
  391. // role := service.FindRoleByUserTypeOne(item.OrgId)
  392. // ids = ids +"," + strconv.FormatInt(role.Id,10)
  393. //
  394. // } else if item.UserType == 3{
  395. // role := service.FindRoleByUserTypeTwo(item.OrgId)
  396. // ids = ids +"," + strconv.FormatInt(role.Id,10)
  397. // }
  398. // service.UpdateRoleIds(item.Id, ids)
  399. //}
  400. c.ServeSuccessJSON(map[string]interface{}{
  401. "msg": "ok",
  402. })
  403. }
  404. func InitRoleAndPurviews(org_ids []int64) {
  405. roles := LoadRoleConfig("./role.json").Roles
  406. for _, org_id := range org_ids {
  407. app, _ := service.GetOrgApp(org_id, 3)
  408. if app == nil || app.Id == 0 {
  409. continue
  410. }
  411. for _, item := range roles {
  412. role := &models.Role{
  413. RoleName: item.RoleName,
  414. RoleIntro: item.RoleIntroduction,
  415. Creator: 0,
  416. OrgId: org_id,
  417. AppId: app.Id,
  418. IsSuperAdmin: false,
  419. Status: 1,
  420. CreateTime: time.Now().Unix(),
  421. ModifyTime: time.Now().Unix(),
  422. Number: item.Number,
  423. IsSystem: item.IsSystem,
  424. }
  425. err := service.CreateOrgRole(role)
  426. if err == nil {
  427. purview := &models.RolePurview{
  428. RoleId: role.Id,
  429. OrgId: org_id,
  430. AppId: role.AppId,
  431. PurviewIds: item.PurviewIds,
  432. Status: 1,
  433. CreateTime: time.Now().Unix(),
  434. ModifyTime: time.Now().Unix(),
  435. }
  436. func_purview := &models.SgjUserRoleFuncPurview{
  437. RoleId: role.Id,
  438. OrgId: org_id,
  439. AppId: role.AppId,
  440. PurviewIds: item.FuncIds,
  441. Status: 1,
  442. Ctime: time.Now().Unix(),
  443. Mtime: time.Now().Unix(),
  444. }
  445. service.CreateRolePurview(purview)
  446. service.CreateFuncRolePurview(func_purview)
  447. }
  448. }
  449. }
  450. }
  451. type RoleConfig struct {
  452. Roles []*models.VMUserRoleAndPurview "json:roles"
  453. }
  454. func LoadRoleConfig(dataFile string) *RoleConfig {
  455. var config RoleConfig
  456. _, filename, _, _ := runtime.Caller(1)
  457. datapath := path.Join(path.Dir(filename), dataFile)
  458. config_file, err := os.Open(datapath)
  459. if err != nil {
  460. emit("Failed to open config file '%s': %s\n", datapath, err)
  461. return &config
  462. }
  463. fi, _ := config_file.Stat()
  464. buffer := make([]byte, fi.Size())
  465. _, err = config_file.Read(buffer)
  466. buffer, err = StripComments(buffer) //去掉注释
  467. if err != nil {
  468. emit("Failed to strip comments from json: %s\n", err)
  469. return &config
  470. }
  471. buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
  472. err = json.Unmarshal(buffer, &config) //解析json格式数据
  473. if err != nil {
  474. emit("Failed unmarshalling json: %s\n", err)
  475. return &config
  476. }
  477. return &config
  478. }