医保对接

controllers/mobile_api_controllers/mobile_api_base_controller.go

@@ -5,8 +5,14 @@ import (
 	"XT_New/enums"
 	"XT_New/models"
 	"XT_New/service"
+	"bytes"
 	"encoding/json"
 	"fmt"
+	"log"
+	"os"
+	"path"
+	"regexp"
+	"runtime"
 	"strconv"
 	"strings"
 	"time"
@@ -106,18 +112,30 @@ func (this *MobileBaseAPIAuthController) Prepare() {
 
 	if this.Ctx.Request.Header.Get("Permission") == "1" {
 		if adminUserInfo.AdminUser.Id != adminUserInfo.Org.Creator { //超级管理员不受此限制
+			err_msgs := LoadErrMsgConfig("./err_msg.json").Msgs
 
 			isPermission := false
 			adminUserInfo := this.GetMobileAdminUserInfo()
 			//该机构下该用户有多少个
-			role, _ := service.GetUserAllRole(adminUserInfo.Org.Id, adminUserInfo.AdminUser.Id)
+			redisClient := service.RedisClient()
+			defer redisClient.Close()
+			key2 := strconv.FormatInt(adminUserInfo.Org.Id, 64) + "_" + strconv.FormatInt(adminUserInfo.AdminUser.Id, 64) + "_role_ids"
+			result, _ := redisClient.Get(key2).Result()
+			var role models.App_Role
 			var roles []string
-			if len(role.RoleIds) <= 0 { //该用户没有设置角色
-
+			if len(result) == 0 {
+				//该机构下该用户有多少个
+				role, _ = service.GetUserAllRole(adminUserInfo.Org.Id, adminUserInfo.AdminUser.Id)
+				redisClient.Set(key2, 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, ",")
+				}
 			}
-
 			//redis相关处理逻辑
 			redis := service.RedisClient()
 			defer redis.Close()
@@ -177,7 +195,14 @@ func (this *MobileBaseAPIAuthController) Prepare() {
 						}
 					}
 					if !isPermission {
-						msg, _ := service.FindErrorMsgByStr(strings.Split(this.Ctx.Request.RequestURI, "?")[0] + "?" + "mode=" + this.GetString("mode"))
+						//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
+							}
+						}
+
 						json := make(map[string]interface{})
 						json["msg"] = msg
 						json["code"] = 0
@@ -224,3 +249,55 @@ type AdminUserInfo struct {
 	AppUrlfors   map[int64][]string                   `json:"app_urlfors"`
 	Subscibes    map[int64]*models.ServeSubscibe      `json:"org_subscibes"`
 }
+
+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
+}
+
+func emit(msgfmt string, args ...interface{}) {
+	log.Printf(msgfmt, args...)
+}
+
+func StripComments(data []byte) ([]byte, error) {
+	data = bytes.Replace(data, []byte("\r"), []byte(""), 0) // Windows
+	lines := bytes.Split(data, []byte("\n"))                //split to muli lines
+	filtered := make([][]byte, 0)
+
+	for _, line := range lines {
+		match, err := regexp.Match(`^\s*#`, line)
+		if err != nil {
+			return nil, err
+		}
+		if !match {
+			filtered = append(filtered, line)
+		}
+	}
+
+	return bytes.Join(filtered, []byte("\n")), nil
+}