医保对接

controllers/base_api_controller.go

@@ -2,10 +2,15 @@ package controllers
 
 import (
 	"XT_New/enums"
+	"XT_New/models"
 	"XT_New/service"
-	"fmt"
+	"encoding/json"
+	"os"
+	"path"
+	"runtime"
 	"strconv"
 	"strings"
+	"time"
 )
 
 type BaseAPIController struct {
@@ -69,56 +74,72 @@ type BaseAuthAPIController struct {
 func (this *BaseAuthAPIController) Prepare() {
 	this.BaseAPIController.Prepare()
 	if this.GetAdminUserInfo() == nil {
-		//var userAdmin models.AdminUser
-		//userAdmin.Id = 1448
-		//userAdmin.Mobile = "13318599895"
-		//
-		//userAdmin.Id = 597
-		//userAdmin.Mobile = "19874122664"
-		//userAdmin.IsSuperAdmin = false
-		//userAdmin.Status = 1
-		//userAdmin.CreateTime = 1530786071
-		//userAdmin.ModifyTime = 1530786071
-		//var subscibe models.ServeSubscibe
-		//subscibe.ID = 1
-		//subscibe.OrgId = 3877
-		//subscibe.PeriodStart = 1538035409
-		//subscibe.PeriodEnd = 1569571409
-		//subscibe.State = 1
-		//subscibe.Status = 1
-		//subscibe.CreatedTime = 1538035409
-		//subscibe.UpdatedTime = 1538035409
-		//subscibes := make(map[int64]*models.ServeSubscibe, 0)
-		//subscibes[4] = &subscibe
-		//var adminUserInfo service.AdminUserInfo
-		//adminUserInfo.CurrentOrgId = 3877
-		//adminUserInfo.CurrentAppId = 4
-		//adminUserInfo.AdminUser = &userAdmin
-		//adminUserInfo.Subscibes = subscibes
-		//this.SetSession("admin_user_info", &adminUserInfo)
-
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
-		this.StopRun()
+		var userAdmin models.AdminUser
+		userAdmin.Id = 1448
+		userAdmin.Mobile = "13318599895"
+
+		userAdmin.Id = 597
+		userAdmin.Mobile = "19874122664"
+		userAdmin.IsSuperAdmin = false
+		userAdmin.Status = 1
+		userAdmin.CreateTime = 1530786071
+		userAdmin.ModifyTime = 1530786071
+		var subscibe models.ServeSubscibe
+		subscibe.ID = 1
+		subscibe.OrgId = 10215
+		subscibe.PeriodStart = 1538035409
+		subscibe.PeriodEnd = 1569571409
+		subscibe.State = 1
+		subscibe.Status = 1
+		subscibe.CreatedTime = 1538035409
+		subscibe.UpdatedTime = 1538035409
+		subscibes := make(map[int64]*models.ServeSubscibe, 0)
+		subscibes[4] = &subscibe
+		var adminUserInfo service.AdminUserInfo
+		adminUserInfo.CurrentOrgId = 10215
+		adminUserInfo.CurrentAppId = 4
+		adminUserInfo.AdminUser = &userAdmin
+		adminUserInfo.Subscibes = subscibes
+		this.SetSession("admin_user_info", &adminUserInfo)
+
+		//this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
+		//this.StopRun()
 
 	}
 
 	adminUserInfo := this.GetAdminUserInfo()
 
 	if this.Ctx.Request.Header.Get("Permission") == "2" {
+		err_msgs := LoadErrMsgConfig("./err_msg.json").Msgs
+
 		org, _ := service.GetOrgById(adminUserInfo.CurrentOrgId)
 		if adminUserInfo.AdminUser.Id != org.Creator { //超级管理员不受此限制
 
 			isPermission := false
 			adminUserInfo := this.GetAdminUserInfo()
-			//该机构下该用户有多少个
-			role, _ := service.GetUserAllRole(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id)
-			var roles []string
-			if len(role.RoleIds) <= 0 { //该用户没有设置角色
 
+			redisClient := service.RedisClient()
+			defer redisClient.Close()
+			key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 64) + "_" + strconv.FormatInt(adminUserInfo.AdminUser.Id, 64) + "_role_ids"
+			result, _ := redisClient.Get(key).Result()
+			var role models.App_Role
+			var roles []string
+			if len(result) == 0 {
+				//该机构下该用户有多少个
+				role, _ = service.GetUserAllRole(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id)
+				redisClient.Set(key, role, time.Second*60*60*18)
+				if len(role.RoleIds) > 0 { //该用户没有设置角色
+					roles = strings.Split(role.RoleIds, ",")
+				}
 			} else {
-				roles = strings.Split(role.RoleIds, ",")
+				json.Unmarshal([]byte(result), &role)
+				if len(role.RoleIds) > 0 { //该用户没有设置角色
+					roles = strings.Split(role.RoleIds, ",")
+				}
 			}
-			fmt.Println(roles)
+
+			//key := strconv.FormatInt(role_id, 64) + "_" + strconv.FormatInt(adminUserInfo.AdminUser.Id, 64) + "_role_ids"
+			//result, _ := redisClient.Get(key).Result()
 
 			//获取该用户下所有角色的权限总集
 			var userRolePurviews string
@@ -134,7 +155,7 @@ func (this *BaseAuthAPIController) Prepare() {
 			}
 			//该用户所拥有角色的权限的总集
 			userRolePurviewsArr = RemoveRepeatedPurviewElement2(strings.Split(userRolePurviews, ","))
-			fmt.Println("userRolePurviewsArr", userRolePurviewsArr)
+
 			//系统所记录的权限列表
 			allPermission, _ := service.GetAllFunctionPurview()
 
@@ -155,7 +176,13 @@ func (this *BaseAuthAPIController) Prepare() {
 						}
 					}
 					if !isPermission {
-						msg, _ := service.FindErrorMsgByStr(strings.Split(this.Ctx.Request.RequestURI, "?")[0] + "?" + "mode=" + this.GetString("mode"))
+						var msg string
+						for _, item := range err_msgs {
+							if strings.Index(item.Url, strings.Split(this.Ctx.Request.RequestURI, "?")[0]+"?"+"mode="+this.GetString("mode")) != -1 {
+								msg = item.ErrMsg
+							}
+						}
+						//msg, _ := service.FindErrorMsgByStr(strings.Split(this.Ctx.Request.RequestURI, "?")[0] + "?" + "mode=" + this.GetString("mode"))
 						json := make(map[string]interface{})
 						json["msg"] = msg
 						json["code"] = 0
@@ -171,20 +198,33 @@ func (this *BaseAuthAPIController) Prepare() {
 	}
 
 	if this.Ctx.Request.Header.Get("Permission") == "3" {
+		err_msgs := LoadErrMsgConfig("./err_msg.json").Msgs
+
 		org, _ := service.GetOrgById(adminUserInfo.CurrentOrgId)
 		if adminUserInfo.AdminUser.Id != org.Creator { //超级管理员不受此限制
 
 			isPermission := false
 			adminUserInfo := this.GetAdminUserInfo()
 			//该机构下该用户有多少个
-			role, _ := service.GetUserAllRole(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id)
+			redisClient := service.RedisClient()
+			defer redisClient.Close()
+			key := strconv.FormatInt(adminUserInfo.CurrentOrgId, 64) + "_" + strconv.FormatInt(adminUserInfo.AdminUser.Id, 64) + "_role_ids"
+			result, _ := redisClient.Get(key).Result()
+			var role models.App_Role
 			var roles []string
-			if len(role.RoleIds) <= 0 { //该用户没有设置角色
-
+			if len(result) == 0 {
+				//该机构下该用户有多少个
+				role, _ = service.GetUserAllRole(adminUserInfo.CurrentOrgId, adminUserInfo.AdminUser.Id)
+				redisClient.Set(key, role, time.Second*60*60*18)
+				if len(role.RoleIds) > 0 { //该用户没有设置角色
+					roles = strings.Split(role.RoleIds, ",")
+				}
 			} else {
-				roles = strings.Split(role.RoleIds, ",")
+				json.Unmarshal([]byte(result), &role)
+				if len(role.RoleIds) > 0 { //该用户没有设置角色
+					roles = strings.Split(role.RoleIds, ",")
+				}
 			}
-			fmt.Println(roles)
 
 			//获取该用户下所有角色的权限总集
 			var userRolePurviews string
@@ -200,7 +240,6 @@ func (this *BaseAuthAPIController) Prepare() {
 			}
 			//该用户所拥有角色的权限的总集
 			userRolePurviewsArr = RemoveRepeatedPurviewElement2(strings.Split(userRolePurviews, ","))
-			fmt.Println(userRolePurviewsArr)
 			//系统所记录的权限列表
 			allPermission, _ := service.GetAllFunctionPurview()
 
@@ -219,7 +258,13 @@ func (this *BaseAuthAPIController) Prepare() {
 						}
 					}
 					if !isPermission {
-						msg, _ := service.FindErrorMsgByStr(strings.Split(this.Ctx.Request.RequestURI, "?")[0] + "?" + "mode=" + this.GetString("mode"))
+						var msg string
+						for _, item := range err_msgs {
+							if strings.Index(item.Url, strings.Split(this.Ctx.Request.RequestURI, "?")[0]+"?"+"mode="+this.GetString("mode")) != -1 {
+								msg = item.ErrMsg
+							}
+						}
+						//msg, _ := service.FindErrorMsgByStr(strings.Split(this.Ctx.Request.RequestURI, "?")[0] + "?" + "mode=" + this.GetString("mode"))
 						json := make(map[string]interface{})
 						json["msg"] = msg
 						json["code"] = 0
@@ -316,35 +361,35 @@ type BaseServeAPIController struct {
 func (this *BaseServeAPIController) Prepare() {
 	this.BaseAPIController.Prepare()
 	if this.GetAdminUserInfo() == nil {
-		//var userAdmin models.AdminUser
-		//userAdmin.Id = 1448
-		//userAdmin.Mobile = "13318599895"
-		//
-		//userAdmin.Id = 597
-		//userAdmin.Mobile = "19874122664"
-		//userAdmin.IsSuperAdmin = false
-		//userAdmin.Status = 1
-		//userAdmin.CreateTime = 1530786071
-		//userAdmin.ModifyTime = 1530786071
-		//var subscibe models.ServeSubscibe
-		//subscibe.ID = 1
-		//subscibe.OrgId = 3877
-		//subscibe.PeriodStart = 1538035409
-		//subscibe.PeriodEnd = 1569571409
-		//subscibe.State = 1
-		//subscibe.Status = 1
-		//subscibe.CreatedTime = 1538035409
-		//subscibe.UpdatedTime = 1538035409
-		//subscibes := make(map[int64]*models.ServeSubscibe, 0)
-		//subscibes[4] = &subscibe
-		//var adminUserInfo service.AdminUserInfo
-		//adminUserInfo.CurrentOrgId = 3877
-		//adminUserInfo.CurrentAppId = 4
-		//adminUserInfo.AdminUser = &userAdmin
-		//adminUserInfo.Subscibes = subscibes
-		//this.SetSession("admin_user_info", &adminUserInfo)
-		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
-		this.StopRun()
+		var userAdmin models.AdminUser
+		userAdmin.Id = 1448
+		userAdmin.Mobile = "13318599895"
+
+		userAdmin.Id = 597
+		userAdmin.Mobile = "19874122664"
+		userAdmin.IsSuperAdmin = false
+		userAdmin.Status = 1
+		userAdmin.CreateTime = 1530786071
+		userAdmin.ModifyTime = 1530786071
+		var subscibe models.ServeSubscibe
+		subscibe.ID = 1
+		subscibe.OrgId = 10215
+		subscibe.PeriodStart = 1538035409
+		subscibe.PeriodEnd = 1569571409
+		subscibe.State = 1
+		subscibe.Status = 1
+		subscibe.CreatedTime = 1538035409
+		subscibe.UpdatedTime = 1538035409
+		subscibes := make(map[int64]*models.ServeSubscibe, 0)
+		subscibes[4] = &subscibe
+		var adminUserInfo service.AdminUserInfo
+		adminUserInfo.CurrentOrgId = 10215
+		adminUserInfo.CurrentAppId = 4
+		adminUserInfo.AdminUser = &userAdmin
+		adminUserInfo.Subscibes = subscibes
+		this.SetSession("admin_user_info", &adminUserInfo)
+		//this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotLogin)
+		//this.StopRun()
 	}
 
 	//if adminUserInfo.AppRole != nil {
@@ -381,3 +426,33 @@ func RemoveRepeatedPurviewElement2(arr []string) (newArr []string) {
 	}
 	return
 }
+
+type ErrMsgConfig struct {
+	Msgs []*models.ErrMsg "json:msg"
+}
+
+func LoadErrMsgConfig(dataFile string) *ErrMsgConfig {
+	var config ErrMsgConfig
+	_, filename, _, _ := runtime.Caller(1)
+	datapath := path.Join(path.Dir(filename), dataFile)
+	config_file, err := os.Open(datapath)
+	if err != nil {
+		emit("Failed to open config file '%s': %s\n", datapath, err)
+		return &config
+	}
+	fi, _ := config_file.Stat()
+	buffer := make([]byte, fi.Size())
+	_, err = config_file.Read(buffer)
+	buffer, err = StripComments(buffer) //去掉注释
+	if err != nil {
+		emit("Failed to strip comments from json: %s\n", err)
+		return &config
+	}
+	buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
+	err = json.Unmarshal(buffer, &config)         //解析json格式数据
+	if err != nil {
+		emit("Failed unmarshalling json: %s\n", err)
+		return &config
+	}
+	return &config
+}

controllers/mobile_api_controllers/err_msg.json

@@ -0,0 +1,158 @@
+{
+  "msg": [
+    {
+      "url": "/m/api/solution?mode=1,/api/dialysis/soulution?mode=1,/api/patients/dialysissolution/create?mode=1",
+      "err_msg": "没有权限新增长期处方"
+    },{
+      "url": ",,/api/patients/dialysissolution/edit?mode=2",
+      "err_msg": "没有权限修改长期处方"
+    },{
+      "url": ",,/api/patients/dialysissolution/edit?mode=3",
+      "err_msg": "没有权限修改别人的长期处方"
+    },{
+      "url": "/m/api/dialysis/dialysisPrescription?mode=1,/api/dialysis/prescription?mode=1,",
+      "err_msg": "没有权限新增临时处方"
+    },{
+      "url": "/m/api/dialysis/dialysisPrescription?mode=3,/api/dialysis/prescription?mode=3,",
+      "err_msg": "没有权限修改他人的临时处方"
+    },{
+      "url": "/m/api/dialysis/acceptsAssessment?mode=1,/api/dialysis/accepts?mode=1,",
+      "err_msg": "没有权限新增接诊评估"
+    },{
+      "url": "/m/api/dialysis/acceptsAssessment?mode=2,/api/dialysis/accepts?mode=2,",
+      "err_msg": "没有权限修改接诊评估"
+    },{
+      "url": "/m/api/dialysis/acceptsAssessment?mode=3,/api/dialysis/accepts?mode=3,",
+      "err_msg": "没有权限修改别人接诊评估"
+    },{
+      "url": "/m/api/assessmentbefore/commit?mode=1,/api/dialysis/assessmentbeforedislysis?mode=1,",
+      "err_msg": "没有权限新增透前评估"
+    },{
+      "url": "/m/api/assessmentbefore/commit?mode=2,/api/dialysis/assessmentbeforedislysis?mode=2,",
+      "err_msg": "没有权限修改透前评估"
+    },{
+      "url": "/m/api/assessmentbefore/commit?mode=3,/api/dialysis/assessmentbeforedislysis?mode=3,",
+      "err_msg": "没有权限修改别人透前评估"
+    },{
+      "url": "/m/api/dialysis/start?mode=1,/api/dialysis/start_record?mode=1,",
+      "err_msg": "没有权限执行上机"
+    },{
+      "url": "/m/api/startOrder/edit?mode=2,/api/start_dialysis/modify?mode=2,",
+      "err_msg": "没有权限修改执行上机"
+    },{
+      "url": "/m/api/startOrder/edit?mode=3,/api/start_dialysis/modify?mode=3,",
+      "err_msg": "没有权限修改他人执行上机"
+    },{
+      "url": "/m/api/monitor/add?mode=1,/api/dislysis/monitor/edit?mode=1,",
+      "err_msg": "没有权限新增透析监测"
+    },{
+      "url": "/m/api/monitor/edit?mode=2,/api/dislysis/monitor/edit?mode=2,",
+      "err_msg": "没有权限修改透析监测"
+    },{
+      "url": "/m/api/monitor/edit?mode=3,/api/dislysis/monitor/edit?mode=3,",
+      "err_msg": "没有权限修改他人透析监测"
+    },{
+      "url": "/m/api/monitor/delete?mode=4,/api/dialysis/monitor/del?mode=4,",
+      "err_msg": "没有权限删除透析监测"
+    },{
+      "url": "/m/api/monitor/delete?mode=5,/api/dialysis/monitor/del?mode=5,",
+      "err_msg": "没有权限删除他人透析监测"
+    },{
+      "url": "/m/api/dialysis/finish?mode=1,/api/dialysis/finish?mode=1,",
+      "err_msg": "没有权限执行下机"
+    },{
+      "url": "/m/api/finishOrder/edit?mode=2,/api/finish_dialysis/modify?mode=2,",
+      "err_msg": "没有权限修改执行下机"
+    },{
+      "url": "/m/api/finishOrder/edit?mode=3,/api/finish_dialysis/modify?mode=3,",
+      "err_msg": "没有权限修改他人执行下机"
+    },{
+      "url": "/m/api/dialysis/assessmentAfterDislysis?mode=1,/api/dialysis/assessmentafterdislysis?mode=1,",
+      "err_msg": "没有权限新增透后评估"
+    },{
+      "url": "/m/api/dialysis/assessmentAfterDislysis?mode=2,/api/dialysis/assessmentafterdislysis?mode=2,",
+      "err_msg": "没有权限修改透后评估"
+    },{
+      "url": "/m/api/dialysis/assessmentAfterDislysis?mode=3,/api/dialysis/assessmentafterdislysis?mode=3,",
+      "err_msg": "没有权限修改他人透后评估"
+    },{
+      "url": "/m/api/dialysis/treatmentSummary?mode=1,/api/dialysis/treatmentsummary?mode=1,",
+      "err_msg": "没有权限新增治疗小结"
+    },{
+      "url": "/m/api/dialysis/treatmentSummary?mode=2,/api/dialysis/treatmentsummary?mode=2,",
+      "err_msg": "没有权限修改治疗小结"
+    },{
+      "url": "/m/api/dialysis/treatmentSummary?mode=3,/api/dialysis/treatmentsummary?mode=3,",
+      "err_msg": "没有权限修改他人治疗小结"
+    },{
+      "url": "/m/api/dryweight/commit?mode=1,/api/dryweight/commit?mode=1,/api/patient/updatedryweightdata?mode=1",
+      "err_msg": "没有权限新增干体重"
+    },{
+      "url": ",/api/patients/advice/create?mode=1-1,/api/patients/advice/creategroup?mode=1-1",
+      "err_msg": "没有权限新增临时医嘱"
+    },{
+      "url": ",/api/patients/advice/edit?mode=2-1,",
+      "err_msg": "没有权限修改临时医嘱"
+    },{
+      "url": ",/api/patients/advice/edit?mode=3-1,",
+      "err_msg": "没有权限修改他人临时医嘱"
+    },{
+      "url": ",/api/patients/advice/delete?mode=4-1,/api/patients/advice/deletegroup?mode=4-1",
+      "err_msg": "没有权限删除临时医嘱"
+    },{
+      "url": ",/api/patients/advice/delete?mode=5-1,/api/patients/advice/deletegroup?mode=5-1",
+      "err_msg": "没有权限删除他人开的临时医嘱"
+    },{
+      "url": ",/api/patients/advice/create?mode=1-2,/api/patients/advice/creategroup?mode=1-2",
+      "err_msg": "没有权限新增长期医嘱"
+    },{
+      "url": ",/api/patients/advice/edit?mode=1-3,",
+      "err_msg": "没有权限修改长期医嘱"
+    },{
+      "url": ",/api/patients/advice/edit?mode=1-4,",
+      "err_msg": "没有权限修改他人长期医嘱"
+    },{
+      "url": ",/api/patients/advice/stop?mode=1-5,",
+      "err_msg": "没有权限停止长期医嘱"
+    },{
+      "url": ",/api/patients/advice/delete?mode=1-6,/api/patients/advice/deletegroup?mode=1-6",
+      "err_msg": "没有权限删除长期医嘱"
+    },{
+      "url": ",/api/patients/advice/delete?mode=1-7,/api/patients/advice/deletegroup?mode=1-7",
+      "err_msg": "没有权限删除他人长期医嘱"
+    },{
+      "url": "/m/api/advice/creategroup?mode=1,/api/patients/advice/creategroup?mode=1,/api/patients/advice/create?mode=1",
+      "err_msg": "没有权限新增透析临时医嘱"
+    },{
+      "url": "/m/api/advice/edit?mode=2,/api/patients/advice/edit?mode=2,",
+      "err_msg": "没有权限修改透析临时医嘱"
+    },{
+      "url": "/m/api/advice/edit?mode=3,/api/patients/advice/edit?mode=3,",
+      "err_msg": "没有权限修改他人透析临时医嘱"
+    },{
+      "url": "/m/api/newadvice/delete?mode=4,/api/patients/advice/delete?mode=4,/api/patients/advice/deletegroup?mode=4",
+      "err_msg": "没有权限删除透析临时医嘱"
+    },{
+      "url": "/m/api/newadvice/delete?mode=5,/api/patients/advice/delete?mode=5,/api/patients/advice/deletegroup?mode=5",
+      "err_msg": "没有权限删除他人透析临时医嘱"
+    },{
+      "url": "/m/api/advice/exec?mode=6,/api/patients/advice/exec?mode=6,",
+      "err_msg": "没有权限执行透析临时医嘱"
+    },{
+      "url": "/m/api/advice/exec/modify?mode=8,,",
+      "err_msg": "没有权限修改已执行医嘱"
+    },{
+      "url": "/m/api/advice/check?mode=7,/api/patients/advice/check?mode=7,",
+      "err_msg": "没有权限核对透析临时医嘱"
+    },{
+      "url": ",/api/patients/advice/stop?mode=1-8,",
+      "err_msg": "没有权限停止他人长期医嘱"
+    },{
+      "url": ",/api/patients/advice/execgroup?mode=6-1,",
+      "err_msg": "没有权限执行医嘱"
+    },{
+      "url": ",/api/patients/advice/checkgroup?mode=7-1,",
+      "err_msg": "没有权限核对医嘱"
+    }
+  ]
+}

models/err_msg.go

@@ -0,0 +1,6 @@
+package models
+
+type ErrMsg struct {
+	Url    string `gorm:"column:url" json:"url"`
+	ErrMsg string `gorm:"column:err_msg" json:"err_msg"`
+}