Merge branch 'master' of http://git.shengws.com/csx/XT_New

conf/app.conf

@@ -34,7 +34,7 @@ sms_token = ea475ed8d3de6c54c2b3f9d78db76d1e
 sms_baseUrl = https://open.ucpaas.com/ol/sms/
 ip_max_send_count = 20
 moblie_max_send_count = 5
-sms_verification_code_templateid = 329532
+sms_verification_code_templateid = 358429
 
 
 appid = "wx43ad410d9eef426e"
@@ -86,6 +86,21 @@ writemiddleuser = syh
 writemiddlepass = xhPECP2nFObR8aUK
 writemiddlename = ky_xt_middle
 
+
+readsgjpatientmysqlhost = shengws1.mysql.rds.aliyuncs.com
+readsgjpatientmysqlport = 3306
+readsgjpatientmysqluser = syh
+readsgjpatientmysqlpass = xhPECP2nFObR8aUK
+readsgjpatientmysqlname = sgj_patient
+
+writesgjpatientmysqlhost = shengws1.mysql.rds.aliyuncs.com
+writesgjpatientmysqlport = 3306
+writesgjpatientmysqluser = syh
+writesgjpatientmysqlpass = xhPECP2nFObR8aUK
+writesgjpatientmysqlname = sgj_patient
+
+
+
 redishost = 349e580b2a524290.redis.rds.aliyuncs.com
 redisport = 6379
 redispasswrod = TZtBW098WId3i27clkpj3q8dnUaVFP
@@ -94,6 +109,8 @@ redisdb = 0
 
 
 
+
+
 niprocart =  63
 jms = 58
 fistula_needle_set = 65
@@ -166,6 +183,19 @@ writepatientuser = root
 writepatientpass = 1Q2W3e4r!@#$
 writepatientname = sgj_cdm
 
+readsgjpatientmysqlhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+readsgjpatientmysqlport = 3306
+readsgjpatientmysqluser = root
+readsgjpatientmysqlpass = 1Q2W3e4r!@#$
+readsgjpatientmysqlname = sgj_patient
+
+writesgjpatientmysqlhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+writesgjpatientmysqlport = 3306
+writesgjpatientmysqluser = root
+writesgjpatientmysqlpass = 1Q2W3e4r!@#$
+writesgjpatientmysqlname = sgj_patient
+
+
 #redishost = 120.77.235.13
 #redishost = 112.74.16.180
 redishost = localhost

controllers/base_api_controller.go

@@ -95,15 +95,15 @@ func (this *BaseAuthAPIController) Prepare() {
 		//this.StopRun()
 	}
 
-	if this.Ctx.Request.Method != "GET" {
-		adminUserInfo := this.GetAdminUserInfo()
-
-		err := service.GetOrgSubscibeState(adminUserInfo.Subscibes[adminUserInfo.CurrentOrgId])
-		if err != nil || adminUserInfo.Subscibes[adminUserInfo.CurrentOrgId].State == 3 {
-			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotSubscibe)
-			this.StopRun()
-		}
-	}
+	//if this.Ctx.Request.Method != "GET" {
+	//	adminUserInfo := this.GetAdminUserInfo()
+	//
+	//	err := service.GetOrgSubscibeState(adminUserInfo.Subscibes[adminUserInfo.CurrentOrgId])
+	//	if err != nil || adminUserInfo.Subscibes[adminUserInfo.CurrentOrgId].State == 3 {
+	//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotSubscibe)
+	//		this.StopRun()
+	//	}
+	//}
 
 	//if this.Ctx.Request.Header.Get("Permission") == "1" {
 	//

controllers/mobile_api_controllers/mobile_api_base_controller.go

@@ -4,7 +4,6 @@ import (
 	"XT_New/controllers"
 	"XT_New/enums"
 	"XT_New/models"
-	"XT_New/service"
 	"fmt"
 )
 
@@ -54,11 +53,11 @@ func (this *MobileBaseAPIAuthController) Prepare() {
 		this.StopRun()
 	}
 
-	if this.Ctx.Request.Method != "GET" {
-		err := service.GetOrgSubscibeState(adminUserInfo.Subscibe)
-		if err != nil || adminUserInfo.Subscibe.State == 3 {
-			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotSubscibe)
-			this.StopRun()
-		}
-	}
+	//if this.Ctx.Request.Method != "GET" {
+	//	err := service.GetOrgSubscibeState(adminUserInfo.Subscibe)
+	//	if err != nil || adminUserInfo.Subscibe.State == 3 {
+	//		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeNotSubscibe)
+	//		this.StopRun()
+	//	}
+	//}
 }

controllers/new_mobile_api_controllers/home_api_controller.go

@@ -0,0 +1,331 @@
+package new_mobile_api_controllers
+
+import (
+	"XT_New/controllers/mobile_api_controllers"
+	"XT_New/enums"
+	"XT_New/models"
+	"XT_New/service"
+	"XT_New/utils"
+	"github.com/astaxie/beego"
+	"strconv"
+	"time"
+)
+
+type HomeController struct {
+	NewMobileBaseAPIAuthController
+}
+
+func (this *HomeController) GetHomeData() {
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	if adminUserInfo.Org != nil {
+		//获取该管理员所有机构列表
+		var orgs []*models.Org
+		adminUser, err := service.GetHomeData(adminUserInfo.AdminUser.Id)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+		for _, item := range adminUser.Org {
+			orgs = append(orgs, item)
+		}
+		for _, item := range adminUser.VMApp_Role {
+			for _, subItem := range item.Org {
+				orgs = append(orgs, subItem)
+			}
+		}
+		orgs = RemoveRepeatedOrgElement(orgs)
+
+		apps, err := service.GetAllApp(adminUserInfo.Org.Id)
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+
+		banners, err := service.GetSystemBanner()
+		if err != nil {
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+			return
+		}
+
+		this.ServeSuccessJSON(map[string]interface{}{
+			"orgs":        orgs,
+			"apps":        apps,
+			"banners":     banners,
+			"isCreateOrg": true,
+		})
+	} else {
+		this.ServeSuccessJSON(map[string]interface{}{
+			"isCreateOrg": false,
+		})
+	}
+
+}
+
+func RemoveRepeatedOrgElement(orgs []*models.Org) (newOrgs []*models.Org) {
+	newOrgs = make([]*models.Org, 0)
+	for i := 0; i < len(orgs); i++ {
+		repeat := false
+		for j := i + 1; j < len(orgs); j++ {
+			if orgs[i].Id == orgs[j].Id {
+				repeat = true
+				break
+			}
+		}
+		if !repeat {
+			newOrgs = append(newOrgs, orgs[i])
+		}
+	}
+	return
+}
+
+func (this *HomeController) ChangeOrg() {
+	org_id, _ := this.GetInt64("org_id")
+	adminUserInfo := this.GetMobileAdminUserInfo()
+
+	tempOrg, err := service.GetOrgById(org_id)
+	if err != nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
+		return
+	}
+
+	if tempOrg == nil {
+		this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeOrgNoExist)
+		return
+	}
+
+	mobile := adminUserInfo.AdminUser.Mobile
+	// 只取最近被创建的 admin_role
+	adminUser, getAdminErr := service.GetValidAdminUserByMobileReturnErr(mobile) //账号信息唯一值
+	if getAdminErr != nil {
+		utils.ErrorLog("获取管理员失败：%v", getAdminErr)
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		this.ServeJSON()
+		return
+	} else if adminUser == nil {
+		utils.ErrorLog("查找不到 mobile = %v 的用户", mobile)
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeAccountOrPasswordWrong)
+		this.ServeJSON()
+		return
+	} else {
+
+		var appRole *models.App_Role
+		var org *models.Org
+		var subscibe *models.ServeSubscibe
+		var app *models.OrgApp
+
+		//根据登录信息的机构和用户id，去获取对应用户信息和机构信息
+		tempApp, _ := service.GetOrgApp(tempOrg.Id, 3)
+		tempRole, _ := service.GetAppRole(tempOrg.Id, tempApp.Id, adminUser.Id)
+
+		tempSubscibe, getSubscibeErr := service.GetOrgServeSubscibe(tempOrg.Id)
+		if getSubscibeErr != nil {
+			utils.ErrorLog("获取机构订阅信息失败：%v", getSubscibeErr)
+			this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			this.ServeJSON()
+			return
+		}
+
+		subscibe = tempSubscibe
+		org = tempOrg
+		appRole = tempRole
+		app = tempApp
+
+		if org != nil && appRole != nil {
+			// 插入一条登录记录
+			ip := this.GetString("ip")
+			loginLog := &models.AdminUserLoginLog{
+				AdminUserId: adminUser.Id,
+				OrgId:       org.Id,
+				AppId:       appRole.AppId,
+				IP:          ip,
+				OperateType: 3,
+				AppType:     int8(3),
+				CreateTime:  time.Now().Unix(),
+			}
+			if insertErr := service.InsertLoginLog(loginLog); insertErr != nil {
+				utils.ErrorLog("为手机号为%v的用户插入一条登录记录失败：%v", mobile, insertErr)
+			}
+		}
+
+		templateInfo, _ := service.GetOrgInfoTemplate(org.Id)
+
+		mobileAdminUserInfo := &mobile_api_controllers.MobileAdminUserInfo{
+			AdminUser:    adminUser,
+			Org:          org,
+			App:          app,
+			AppRole:      appRole,
+			Subscibe:     subscibe,
+			TemplateInfo: &templateInfo,
+		}
+
+		//删除session和cookie
+		this.DelSession("mobile_admin_user_info")
+		this.Ctx.SetCookie("token_cookie", "")
+
+		//设置new seesion
+		this.SetSession("mobile_admin_user_info", mobileAdminUserInfo)
+		//设置new cookie
+		mobile := adminUser.Mobile + "-" + strconv.FormatInt(org.Id, 10) + "-" + strconv.FormatInt(appRole.Id, 10)
+		token := utils.GenerateLoginToken(mobile)
+		expiration, _ := beego.AppConfig.Int64("mobile_token_expiration_second")
+		this.Ctx.SetCookie("token_cookie", token, expiration, "/")
+
+		var configList interface{}
+		var FiledList []*models.FiledConfig
+
+		if org.Id > 0 {
+			configList, _ = service.GetConfigList(org.Id)
+			FiledList, _ = service.FindFiledByOrgId(org.Id)
+		}
+		if len(FiledList) == 0 {
+			var err error
+			if org.Id > 0 {
+				err = service.BatchInsertFiledConfig(org.Id)
+				if err == nil {
+					FiledList, _ = service.FindFiledByOrgId(org.Id)
+				} else {
+					utils.ErrorLog("字段批量插入失败：%v", err)
+				}
+			} else {
+				FiledList = make([]*models.FiledConfig, 0)
+			}
+		}
+		this.ServeSuccessJSON(map[string]interface{}{
+			"admin": adminUser,
+			"user":  appRole,
+			"org":   org,
+			"template_info": map[string]interface{}{
+				"id":          templateInfo.ID,
+				"org_id":      templateInfo.OrgId,
+				"template_id": templateInfo.TemplateId,
+			},
+			"config_list": configList,
+			"filed_list":  FiledList,
+		})
+	}
+
+}
+
+func (this *HomeController) CreateOrg() {
+
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	adminUser := adminUserInfo.AdminUser
+
+	if didCreateOrg, checkCreateOrgErr := service.DidAdminUserCreateOrg(adminUser.Id); checkCreateOrgErr != nil {
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		this.ServeJSON()
+		return
+	} else if didCreateOrg {
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeRepeatCreateOrg)
+		this.ServeJSON()
+		return
+	}
+
+	name := this.GetString("org_name")
+	shortName := name
+	provinceName := this.GetString("provinces_name")
+	cityName := this.GetString("city_name")
+	districtName := this.GetString("district_name")
+	address := this.GetString("address")
+	org_type := this.GetString("org_type")
+	contactName := this.GetString("contact_name")
+
+	openXT := true
+	openCDM := false
+	openSCRM := false
+	openMall := false
+
+	if len(name) == 0 || len(shortName) == 0 || len(contactName) == 0 || len(address) == 0 || len(provinceName) <= 0 || len(cityName) <= 0 || len(districtName) <= 0 || len(org_type) <= 0 {
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		this.ServeJSON()
+		return
+	}
+	orgPhone := this.GetString("telephone")
+
+	if len(orgPhone) > 0 {
+		if utils.PhoneRegexp().MatchString(orgPhone) == false {
+			this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+			this.ServeJSON()
+			return
+		}
+	}
+
+	provinceID := 0
+	cityID := 0
+	districtID := 0
+
+	province, getProvinceErr := service.GetProvinceWithName(provinceName)
+	if getProvinceErr != nil {
+		utils.ErrorLog("查询省名失败：%v", getProvinceErr)
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		this.ServeJSON()
+		return
+	} else if province != nil {
+		provinceID = int(province.ID)
+		city, getCityErr := service.GetCityWithName(province.ID, cityName)
+		if getCityErr != nil {
+			utils.ErrorLog("查询城市名失败：%v", getCityErr)
+			this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			this.ServeJSON()
+			return
+		} else if city != nil {
+			cityID = int(city.ID)
+			district, getDistrictErr := service.GetDistrictWithName(city.ID, districtName)
+			if getDistrictErr != nil {
+				utils.ErrorLog("查询区县名失败：%v", getDistrictErr)
+				this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				this.ServeJSON()
+				return
+			} else if district != nil {
+				districtID = int(district.ID)
+			}
+		}
+	}
+
+	orgType := service.GetOrgTypeByName(org_type)
+
+	org := &models.Org{
+		Creator:      adminUser.Id,
+		OrgName:      name,
+		OrgShortName: shortName,
+		Province:     int64(provinceID),
+		City:         int64(cityID),
+		District:     int64(districtID),
+		Address:      address,
+		OrgType:      orgType.ID,
+		Telephone:    orgPhone,
+		ContactName:  contactName,
+		Claim:        1,
+		Evaluate:     5,
+		Status:       1,
+		CreateTime:   time.Now().Unix(),
+		ModifyTime:   time.Now().Unix(),
+	}
+
+	createErr := service.CreateOrg(org, adminUser.Mobile, openXT, openCDM, openSCRM, openMall) // 创建机构以及所有类型的 app，如果有新类型的平台，则需要在这个方法里面把创建这一新类型的 app 的代码加上
+
+	if createErr != nil {
+		utils.ErrorLog("mobile=%v的超级管理员创建机构失败：%v", adminUser.Mobile, createErr)
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+		this.ServeJSON()
+	} else {
+
+		//初始化病人和排班相关数据
+		InitPatientAndSchedule(org)
+		//初始化透析方案
+		InitSystemPrescrption(org)
+		//初始化医嘱模版
+		InitAdviceTemplate(org)
+		//初始化角色和权限
+
+		//初始化设备管理
+
+		//初始化显示配置
+
+		this.ServeSuccessJSON(map[string]interface{}{
+			"org": org,
+		})
+
+	}
+
+}

controllers/new_mobile_api_controllers/mobile_regist_controller.go

@@ -8,12 +8,17 @@ import (
 	"XT_New/utils"
 	"bytes"
 	"encoding/json"
+	"fmt"
 	"github.com/astaxie/beego"
+	"io/ioutil"
 	"log"
+	"net/http"
+	"net/url"
 	"os"
 	"path"
 	"regexp"
 	"runtime"
+	"strconv"
 	"time"
 )
 
@@ -198,7 +203,7 @@ func (this *MobileRegistController) CreateOrg() {
 
 	orgType := service.GetOrgTypeByName(org_type)
 
-	org := models.Org{
+	org := &models.Org{
 		Creator:      adminUser.Id,
 		OrgName:      name,
 		OrgShortName: shortName,
@@ -216,17 +221,294 @@ func (this *MobileRegistController) CreateOrg() {
 		ModifyTime:   time.Now().Unix(),
 	}
 
-	createErr := service.CreateOrg(&org, adminUser.Mobile, openXT, openCDM, openSCRM, openMall) // 创建机构以及所有类型的 app，如果有新类型的平台，则需要在这个方法里面把创建这一新类型的 app 的代码加上
-	var ids []int64
+	createErr := service.CreateOrg(org, adminUser.Mobile, openXT, openCDM, openSCRM, openMall) // 创建机构以及所有类型的 app，如果有新类型的平台，则需要在这个方法里面把创建这一新类型的 app 的代码加上
+
+	if createErr != nil {
+		utils.ErrorLog("mobile=%v的超级管理员创建机构失败：%v", adminUser.Mobile, createErr)
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
+		this.ServeJSON()
+	} else {
 
+		//初始化病人和排班相关数据
+		InitPatientAndSchedule(org)
+		//初始化透析方案
+		InitSystemPrescrption(org)
+		//初始化医嘱模版
+		InitAdviceTemplate(org)
+		//初始化角色和权限
+
+		//初始化设备管理
+
+		//初始化显示配置
+
+		//创建完机构后进行登录验证操作
+		ip := utils.GetIP(this.Ctx.Request)
+		ssoDomain := beego.AppConfig.String("sso_domain")
+		api := ssoDomain + "/m/login/pwd"
+		values := make(url.Values)
+		values.Set("mobile", adminUser.Mobile)
+		values.Set("password", adminUser.Password)
+		values.Set("app_type", "3")
+		values.Set("ip", ip)
+		resp, requestErr := http.PostForm(api, values)
+
+		if requestErr != nil {
+			utils.ErrorLog("请求SSO登录接口失败: %v", requestErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		defer resp.Body.Close()
+		body, ioErr := ioutil.ReadAll(resp.Body)
+		if ioErr != nil {
+			utils.ErrorLog("SSO登录接口返回数据读取失败: %v", ioErr)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		var respJSON map[string]interface{}
+		utils.InfoLog(string(body))
+		if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
+			utils.ErrorLog("SSO登录接口返回数据解析JSON失败: %v", err)
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+
+		if respJSON["state"].(float64) != 1 {
+			msg := respJSON["msg"].(string)
+			utils.ErrorLog("SSO登录接口请求失败: %v", msg)
+			if int(respJSON["code"].(float64)) == 609 {
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAccountOrPasswordWrong)
+				return
+			}
+			this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		} else {
+			utils.SuccessLog("SSO登录成功")
+			// 下面这几段 Map=>JSON=>Struct 的流程可能会造成速度很慢
+			userJSON := respJSON["data"].(map[string]interface{})["admin"].(map[string]interface{})
+			userJSONBytes, _ := json.Marshal(userJSON)
+			var adminUser models.AdminUser
+			if err := json.Unmarshal(userJSONBytes, &adminUser); err != nil {
+				utils.ErrorLog("解析管理员失败：%v", err)
+				this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				return
+			}
+
+			var org models.Org
+			if respJSON["data"].(map[string]interface{})["org"] != nil {
+				orgJSON := respJSON["data"].(map[string]interface{})["org"].(map[string]interface{})
+				orgJSONBytes, _ := json.Marshal(orgJSON)
+				if err := json.Unmarshal(orgJSONBytes, &org); err != nil {
+					utils.ErrorLog("解析机构失败：%v", err)
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			}
+
+			var app models.OrgApp
+
+			if respJSON["data"].(map[string]interface{})["app"] != nil {
+				appJSON := respJSON["data"].(map[string]interface{})["app"].(map[string]interface{})
+				appJSONBytes, _ := json.Marshal(appJSON)
+				if err := json.Unmarshal(appJSONBytes, &app); err != nil {
+					utils.ErrorLog("解析应用失败：%v", err)
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			}
+
+			var appRole models.App_Role
+
+			if respJSON["data"].(map[string]interface{})["app_role"] != nil {
+				appRoleJSON := respJSON["data"].(map[string]interface{})["app_role"].(map[string]interface{})
+				appRoleJSONBytes, _ := json.Marshal(appRoleJSON)
+				if err := json.Unmarshal(appRoleJSONBytes, &appRole); err != nil {
+					utils.ErrorLog("解析AppRole失败：%v", err)
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			}
+
+			var subscibe models.ServeSubscibe
+			if respJSON["data"].(map[string]interface{})["subscibe"] != nil {
+				subscibeJSON := respJSON["data"].(map[string]interface{})["subscibe"].(map[string]interface{})
+				subscibeJSONBytes, _ := json.Marshal(subscibeJSON)
+				if err := json.Unmarshal(subscibeJSONBytes, &subscibe); err != nil {
+					utils.ErrorLog("解析Subscibe失败：%v", err)
+					this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+
+			}
+
+			//service.GetOrgSubscibeState(&subscibe)
+			templateInfo, _ := service.GetOrgInfoTemplate(org.Id)
+
+			mobileAdminUserInfo := &mobile_api_controllers.MobileAdminUserInfo{
+				AdminUser:    &adminUser,
+				Org:          &org,
+				App:          &app,
+				AppRole:      &appRole,
+				Subscibe:     &subscibe,
+				TemplateInfo: &templateInfo,
+			}
+			//设置seesion
+			this.SetSession("mobile_admin_user_info", mobileAdminUserInfo)
+
+			//设置cookie
+			mobile := adminUser.Mobile + "-" + strconv.FormatInt(org.Id, 10) + "-" + strconv.FormatInt(appRole.Id, 10)
+			token := utils.GenerateLoginToken(mobile)
+			expiration, _ := beego.AppConfig.Int64("mobile_token_expiration_second")
+			this.Ctx.SetCookie("token_cookie", token, expiration, "/")
+
+			var configList interface{}
+			var FiledList []*models.FiledConfig
+
+			if org.Id > 0 {
+				configList, _ = service.GetConfigList(org.Id)
+				FiledList, _ = service.FindFiledByOrgId(org.Id)
+			}
+			if len(FiledList) == 0 {
+				var err error
+				if org.Id > 0 {
+					err = service.BatchInsertFiledConfig(org.Id)
+					if err == nil {
+						FiledList, _ = service.FindFiledByOrgId(org.Id)
+					} else {
+						utils.ErrorLog("字段批量插入失败：%v", err)
+					}
+				} else {
+					FiledList = make([]*models.FiledConfig, 0)
+				}
+			}
+
+			this.ServeSuccessJSON(map[string]interface{}{
+				"admin": adminUser,
+				"user":  appRole,
+				"org":   org,
+				"template_info": map[string]interface{}{
+					"id":          templateInfo.ID,
+					"org_id":      templateInfo.OrgId,
+					"template_id": templateInfo.TemplateId,
+				},
+				"config_list": configList,
+				"filed_list":  FiledList,
+			})
+		}
+
+	}
+
+}
+
+func InitAdviceTemplate(org *models.Org) {
+
+	//初始化医嘱模版
+	adviceInit := &models.AdviceInit{
+		UserOrgId:  org.Id,
+		CreateTime: time.Now().Unix(),
+		UpdateTime: time.Now().Unix(),
+		Status:     1,
+		IsInit:     1,
+	}
+
+	adviceParentTemplate := LoadConfig("./advice_template.json").Parent_template
+	for _, item := range adviceParentTemplate {
+		parentTemplate := &models.DoctorAdviceParentTemplate{
+			OrgId:       org.Id,
+			Name:        item.Name,
+			Status:      1,
+			CreatedTime: time.Now().Unix(),
+			UpdatedTime: time.Now().Unix(),
+			AdviceType:  item.AdviceType,
+		}
+
+		createErr := service.CreateDoctorParentTemplate(parentTemplate)
+		fmt.Println(parentTemplate.ID)
+		if createErr == nil {
+			for _, adviceTemplateItem := range item.DoctorAdviceTemplate {
+				adviceTeplate := &models.DoctorAdviceTemplate{
+					OrgId:                 org.Id,
+					AdviceName:            adviceTemplateItem.AdviceName,
+					AdviceDesc:            adviceTemplateItem.AdviceDesc,
+					SingleDose:            adviceTemplateItem.SingleDose,
+					SingleDoseUnit:        adviceTemplateItem.SingleDoseUnit,
+					PrescribingNumber:     adviceTemplateItem.PrescribingNumber,
+					PrescribingNumberUnit: adviceTemplateItem.PrescribingNumberUnit,
+					DeliveryWay:           adviceTemplateItem.DeliveryWay,
+					ExecutionFrequency:    adviceTemplateItem.ExecutionFrequency,
+					AdviceDoctor:          adviceTemplateItem.AdviceDoctor,
+					Status:                1,
+					CreatedTime:           time.Now().Unix(),
+					UpdatedTime:           time.Now().Unix(),
+					TemplateId:            parentTemplate.ID,
+					DrugSpec:              adviceTemplateItem.DrugSpec,
+					DrugSpecUnit:          adviceTemplateItem.DrugSpecUnit,
+					ParentId:              adviceTemplateItem.ParentId,
+					AdviceType:            adviceTemplateItem.AdviceType,
+					DayCount:              adviceTemplateItem.DayCount,
+					WeekDays:              adviceTemplateItem.WeekDays,
+					FrequencyType:         adviceTemplateItem.FrequencyType,
+				}
+				createErr := service.CreateDoctorTemplate(adviceTeplate)
+
+				if createErr == nil {
+					for _, childItem := range adviceTemplateItem.SubDoctorAdviceTemplate {
+						adviceTeplate := &models.DoctorAdviceTemplate{
+							OrgId:                 org.Id,
+							AdviceName:            childItem.AdviceName,
+							AdviceDesc:            childItem.AdviceDesc,
+							SingleDose:            childItem.SingleDose,
+							SingleDoseUnit:        childItem.SingleDoseUnit,
+							PrescribingNumber:     childItem.PrescribingNumber,
+							PrescribingNumberUnit: childItem.PrescribingNumberUnit,
+							DeliveryWay:           childItem.DeliveryWay,
+							ExecutionFrequency:    childItem.ExecutionFrequency,
+							AdviceDoctor:          childItem.AdviceDoctor,
+							Status:                1,
+							CreatedTime:           time.Now().Unix(),
+							UpdatedTime:           time.Now().Unix(),
+							TemplateId:            parentTemplate.ID,
+							DrugSpec:              childItem.DrugSpec,
+							DrugSpecUnit:          childItem.DrugSpecUnit,
+							ParentId:              adviceTeplate.ID,
+							AdviceType:            childItem.AdviceType,
+							DayCount:              childItem.DayCount,
+							WeekDays:              childItem.WeekDays,
+							FrequencyType:         childItem.FrequencyType,
+						}
+						service.CreateDoctorTemplate(adviceTeplate)
+					}
+				}
+			}
+		}
+	}
+	service.CreateAdviceInitConfig(adviceInit)
+
+}
+
+func InitSystemPrescrption(org *models.Org) {
+	//初始化透析方案
+	prescriptions := LoadPrescriptionConfig("./system_dialysis_prescription.json").Prescription
+	for _, item := range prescriptions {
+		item.UserOrgId = org.Id
+		item.CreatedTime = time.Now().Unix()
+		item.UpdatedTime = time.Now().Unix()
+		service.CreateVMPrescription(item)
+	}
+
+}
+
+func InitPatientAndSchedule(org *models.Org) {
+	var ids []int64
 	//数据初始化
+
 	//创建两个虚拟病人
-	patients := LoadConfig("./patient.json").patients
+	patients := LoadPatientConfig("./patient.json").Patients
 	for _, item := range patients {
 		item.UserOrgId = org.Id
 		item.CreatedTime = time.Now().Unix()
 		item.UpdatedTime = time.Now().Unix()
 		item.Status = 1
+
 		service.CreateVMOrgPatient(item)
 		ids = append(ids, item.ID)
 	}
@@ -234,7 +516,7 @@ func (this *MobileRegistController) CreateOrg() {
 	//创建1个分组
 	vmGroup := &models.VMDeviceGroup{
 		OrgId:  org.Id,
-		Name:   "测试分组1",
+		Name:   "护理一组",
 		Status: 1,
 		Ctime:  time.Now().Unix(),
 		Mtime:  time.Now().Unix(),
@@ -245,7 +527,7 @@ func (this *MobileRegistController) CreateOrg() {
 	//创建两个虚拟分区
 	vmZone1 := &models.VMDeviceZone{
 		OrgId:  org.Id,
-		Name:   "分区1",
+		Name:   "A区",
 		Type:   1,
 		Status: 1,
 		Ctime:  time.Now().Unix(),
@@ -255,7 +537,7 @@ func (this *MobileRegistController) CreateOrg() {
 
 	vmZone2 := &models.VMDeviceZone{
 		OrgId:  org.Id,
-		Name:   "分区2",
+		Name:   "B区",
 		Type:   2,
 		Status: 1,
 		Ctime:  time.Now().Unix(),
@@ -263,10 +545,10 @@ func (this *MobileRegistController) CreateOrg() {
 	}
 	service.CreateVMZone(vmZone2)
 
-	//创建4个虚拟床位
+	//创建2个虚拟床位
 	vmDeviceNumber1 := &models.VMDeviceNumber{
 		OrgId:   org.Id,
-		Number:  "1",
+		Number:  "1号床",
 		GroupId: vmGroup.ID,
 		ZoneId:  vmZone1.ID,
 		Status:  1,
@@ -277,7 +559,7 @@ func (this *MobileRegistController) CreateOrg() {
 
 	vmDeviceNumber2 := &models.VMDeviceNumber{
 		OrgId:   org.Id,
-		Number:  "2",
+		Number:  "2号床",
 		GroupId: vmGroup.ID,
 		ZoneId:  vmZone2.ID,
 		Status:  1,
@@ -286,53 +568,111 @@ func (this *MobileRegistController) CreateOrg() {
 	}
 	service.CreateVMDeviceNumber(vmDeviceNumber2)
 
-	//创建两个虚拟病人排班
-	stime, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
-	for index, id := range ids {
-		if index == 0 {
-			sch := &models.VMSchedule{
-				UserOrgId:    org.Id,
-				PartitionId:  vmZone1.ID,
-				BedId:        vmDeviceNumber1.ID,
-				PatientId:    id,
-				ScheduleDate: stime.Unix(),
-				ScheduleType: 1,
-				ScheduleWeek: int64(time.Now().Weekday()),
-				ModeId:       1,
-				Status:       1,
-				CreatedTime:  time.Now().Unix(),
-				UpdatedTime:  time.Now().Unix(),
+	var dates []int64
+
+	mondayDate := GetDateOfWeek(1)
+	tuesdayDate := GetDateOfWeek(2)
+	wednesdayDate := GetDateOfWeek(3)
+	thursdayDate := GetDateOfWeek(4)
+	fridayDate := GetDateOfWeek(5)
+	saturdayDate := GetDateOfWeek(6)
+	sundayDate := GetDateOfWeek(7)
+
+	dates = append(dates, mondayDate)
+	dates = append(dates, tuesdayDate)
+	dates = append(dates, wednesdayDate)
+	dates = append(dates, thursdayDate)
+	dates = append(dates, fridayDate)
+	dates = append(dates, saturdayDate)
+	dates = append(dates, sundayDate)
+
+	//创建两个虚拟病人本周的排班
+	//stime, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
+	for _, date := range dates {
+		for index, id := range ids {
+			if index == 0 {
+				sch := &models.VMSchedule{
+					UserOrgId:    org.Id,
+					PartitionId:  vmZone1.ID,
+					BedId:        vmDeviceNumber1.ID,
+					PatientId:    id,
+					ScheduleDate: date,
+					ScheduleType: 1,
+					ScheduleWeek: int64(time.Now().Weekday()),
+					ModeId:       1,
+					Status:       1,
+					CreatedTime:  time.Now().Unix(),
+					UpdatedTime:  time.Now().Unix(),
+				}
+				service.CreateVMSch(sch)
 			}
-			service.CreateVMSch(sch)
-		}
 
-		if index == 1 {
-
-			sch := &models.VMSchedule{
-				UserOrgId:    org.Id,
-				PartitionId:  vmZone2.ID,
-				BedId:        vmDeviceNumber2.ID,
-				PatientId:    id,
-				ScheduleDate: stime.Unix(),
-				ScheduleType: 1,
-				ScheduleWeek: int64(time.Now().Weekday()),
-				ModeId:       1,
-				Status:       1,
-				CreatedTime:  time.Now().Unix(),
-				UpdatedTime:  time.Now().Unix(),
+			if index == 1 {
+
+				sch := &models.VMSchedule{
+					UserOrgId:    org.Id,
+					PartitionId:  vmZone2.ID,
+					BedId:        vmDeviceNumber2.ID,
+					PatientId:    id,
+					ScheduleDate: date,
+					ScheduleType: 2,
+					ScheduleWeek: int64(time.Now().Weekday()),
+					ModeId:       1,
+					Status:       1,
+					CreatedTime:  time.Now().Unix(),
+					UpdatedTime:  time.Now().Unix(),
+				}
+				service.CreateVMSch(sch)
 			}
-			service.CreateVMSch(sch)
 		}
+
 	}
 
-	if createErr != nil {
-		utils.ErrorLog("mobile=%v的超级管理员创建机构失败：%v", adminUser.Mobile, createErr)
-		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
-		this.ServeJSON()
-	} else {
-		this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{})
-		this.ServeJSON()
+	//创建单周模版
+	//1.创建模版模式
+	mode := &models.VMPatientScheduleTemplateMode{
+		OrgId:        org.Id,
+		Mode:         1,
+		ExecuteTimes: 0,
+		Status:       1,
+		Ctime:        time.Now().Unix(),
+		Mtime:        time.Now().Unix(),
+	}
+	service.CreateVMSchMode(mode)
+	//2.创建模版id
+	templaeIdOne := &models.VMPatientScheduleTemplateId{
+		OrgId:  org.Id,
+		Status: 1,
+		Ctime:  time.Now().Unix(),
+		Mtime:  time.Now().Unix(),
+	}
+	service.CreateVMSchTemplateId(templaeIdOne)
+	templaeIdTwo := &models.VMPatientScheduleTemplateId{
+		OrgId:  org.Id,
+		Status: 1,
+		Ctime:  time.Now().Unix(),
+		Mtime:  time.Now().Unix(),
+	}
+	service.CreateVMSchTemplateId(templaeIdTwo)
+	//3.创建单周排班模版
+	items := LoadSchTemplateConfig("./schedule_template.json").ScheduleTemplateItem
+	for _, item := range items {
+		if item.TimeType == 1 {
+			item.OrgId = org.Id
+			item.TemplateId = templaeIdOne.ID
+			item.DeviceNumberId = vmDeviceNumber1.ID
+			item.PatientId = ids[0]
+
+		} else if item.TimeType == 2 {
+			item.OrgId = org.Id
+			item.TemplateId = templaeIdOne.ID
+			item.DeviceNumberId = vmDeviceNumber2.ID
+			item.PatientId = ids[1]
+		}
+
+		service.CreateVMSchTemplate(item)
 	}
+
 }
 
 func (this *MobileRegistController) ModifyName() {
@@ -394,12 +734,80 @@ func (this *MobileRegistController) Login() {
 
 }
 
-type Config struct {
-	patients []*models.VMOrgPatients "json:patients"
+type PatientConfig struct {
+	Patients []*models.VMOrgPatients "json:patients"
 }
 
-func LoadConfig(dataFile string) *Config {
-	var config Config
+type SchTemplateConfig struct {
+	ScheduleTemplateItem []*models.VMPatientScheduleTemplateItem "json:item"
+}
+
+type PrescriptionConfig struct {
+	Prescription []*models.SystemPrescription "json:prescription"
+}
+
+func LoadPatientConfig(dataFile string) *PatientConfig {
+	var config PatientConfig
+	_, 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 LoadSchTemplateConfig(dataFile string) *SchTemplateConfig {
+	var config SchTemplateConfig
+	_, 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 LoadPrescriptionConfig(dataFile string) *PrescriptionConfig {
+	var config PrescriptionConfig
 	_, filename, _, _ := runtime.Caller(1)
 	datapath := path.Join(path.Dir(filename), dataFile)
 	config_file, err := os.Open(datapath)
@@ -449,3 +857,89 @@ func StripComments(data []byte) ([]byte, error) {
 
 	return bytes.Join(filtered, []byte("\n")), nil
 }
+
+func GetDateOfWeek(week_type int) (weekMonday int64) {
+	thisTime := time.Now()
+	weekDay := int(thisTime.Weekday())
+	if weekDay == 0 {
+		weekDay = 7
+	}
+	weekEnd := 7 - weekDay
+	weekStart := weekEnd - 6
+	weekTitle := make([]string, 0)
+	days := make([]string, 0)
+	for index := weekStart; index <= weekEnd; index++ {
+		theDay := thisTime.AddDate(0, 0, index)
+		indexYear, indexMonthTime, indexDay := theDay.Date()
+		indexMonth := int(indexMonthTime)
+		indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
+		weekTitle = append(weekTitle, indexWeek)
+		days = append(days, theDay.Format("2006-01-02"))
+	}
+	var targetDayStr string
+	switch week_type {
+	case 1:
+		targetDayStr = days[0]
+		break
+	case 2:
+		targetDayStr = days[1]
+
+		break
+	case 3:
+		targetDayStr = days[2]
+
+		break
+	case 4:
+		targetDayStr = days[3]
+
+		break
+	case 5:
+		targetDayStr = days[4]
+
+		break
+	case 6:
+		targetDayStr = days[5]
+
+		break
+	case 7:
+		targetDayStr = days[6]
+
+		break
+	}
+	targetDay, _ := utils.ParseTimeStringToTime("2006-01-02", targetDayStr)
+	return targetDay.Unix()
+}
+
+type Config struct {
+	Parent_template []*models.VMDoctorAdviceParentTemplate "json:parent_template"
+}
+
+func LoadConfig(dataFile string) *Config {
+	var config Config
+	_, 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/new_mobile_api_controllers/new_login_api_controller.go

@@ -22,6 +22,7 @@ type NewLoginApiController struct {
 }
 
 func (this *NewLoginApiController) GetLogin() {
+
 	token_cookie := this.Ctx.GetCookie("token_cookie")
 	if len(token_cookie) == 0 {
 		this.ServeSuccessJSON(map[string]interface{}{
@@ -517,6 +518,12 @@ func (this *NewLoginApiController) GetCode() {
 		return
 	}
 
+	adminUser, _ := service.GetValidAdminUserByMobileReturnErr(mobile)
+	if adminUser != nil {
+		this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeRegisterExist)
+		this.ServeJSON()
+		return
+	}
 	//this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{
 	//	"msg": "短信发送成功,有效期为10分钟",
 	//})

controllers/new_mobile_api_controllers/new_mobile_api_router_register.go

@@ -1,6 +1,8 @@
 package new_mobile_api_controllers
 
-import "github.com/astaxie/beego"
+import (
+	"github.com/astaxie/beego"
+)
 
 // 平板端路由，以 /m/api 为前缀
 func NewMobileAPIControllersRegisterRouters() {
@@ -29,6 +31,10 @@ func NewMobileAPIControllersRegisterRouters() {
 
 	beego.Router("/m/api/org/create", &MobileRegistController{}, "post:CreateOrg")
 
+	beego.Router("/m/api/home", &HomeController{}, "get:GetHomeData")
+	beego.Router("/m/api/changeorg", &HomeController{}, "post:ChangeOrg")
+	beego.Router("/m/api/createOrg", &HomeController{}, "post:CreateOrg")
+
 	beego.Router("/m/api/patient/getbloodpatientinfo", &NewDialysisApiController{}, "Get:GetBloodPatientInfo")
 	beego.Router("/m/api/patient/getslowpatientinfo", &NewDialysisApiController{}, "Get:GetSlowPatientInfo")
 	beego.Router("/m/api/patient/getmemberpatientinfo", &NewDialysisApiController{}, "Get:GetMemberpatientInfo")
@@ -50,4 +56,5 @@ func NewMobileAPIControllersRegisterRouters() {
 	beego.Router("/m/api/patient/getrescuerecord", &NewDialysisApiController{}, "Get:GetRescuerecord")
 	beego.Router("/m/api/patient/getscheduling", &NewDialysisApiController{}, "Get:GetScheduling")
 	beego.Router("/m/api/patient/geteducation", &NewDialysisApiController{}, "Get:GetEducation")
+
 }

controllers/new_mobile_api_controllers/new_role_api_controller.go

@@ -0,0 +1,30 @@
+package new_mobile_api_controllers
+
+import (
+	"XT_New/service"
+)
+
+type NewRoleApiController struct {
+	NewMobileBaseAPIAuthController
+}
+
+func (this *NewRoleApiController) GetAllOrgUser() {
+	adminUserInfo := this.GetMobileAdminUserInfo()
+	viewModels, _, _ := service.GetAdminUsersAndLoginInfo(adminUserInfo.Org.Id, adminUserInfo.App.Id, 1, 10)
+	this.ServeSuccessJSON(map[string]interface{}{
+		"admins": viewModels,
+	})
+
+}
+func (this *NewRoleApiController) CreateOrgUser() {
+
+}
+func (this *NewRoleApiController) ModifyOrgUser() {
+
+}
+func (this *NewRoleApiController) GetOrgRole() {
+
+}
+func (this *NewRoleApiController) CreateOrgRole() {
+
+}

controllers/new_mobile_api_controllers/patient.json

@@ -3,19 +3,19 @@
     {
       "avatar": "https://images.shengws.com/201809182128111.png",
       "patient_type": 1,
-      "dialysis_no": "01",
+      "dialysis_no": "001",
       "admission_number": "",
       "source": 1,
       "lapseto": 2,
       "partition_id": 0,
       "bed_id": 0,
-      "name": "测试病人",
+      "name": "演示患者一",
       "alias": "",
-      "gender": 2,
+      "gender": 1,
       "nation": "汉",
       "native_place": "广东深圳",
       "marital_status": 1,
-      "id_card_no": "430503196002063010",
+      "id_card_no": "431230199808081111",
       "birthday": -312537600,
       "reimbursement_way_id": 7,
       "health_care_type": 0,
@@ -27,10 +27,10 @@
       "health_care_due_alert_date": 0,
       "education_level": 5,
       "profession": 10,
-      "phone": "13535547901",
-      "home_telephone": "12221903097",
-      "relative_phone": "18123074302",
-      "relative_relations": "哥哥",
+      "phone": "13800000001",
+      "home_telephone": "",
+      "relative_phone": "",
+      "relative_relations": "",
       "home_address": "深圳市罗湖区鸿翔花园",
       "work_unit": "无",
       "unit_address": "无",
@@ -82,19 +82,19 @@
     {
       "avatar": "https://images.shengws.com/201809182128111.png",
       "patient_type": 1,
-      "dialysis_no": "01",
+      "dialysis_no": "002",
       "admission_number": "",
       "source": 1,
       "lapseto": 2,
       "partition_id": 0,
       "bed_id": 0,
-      "name": "测试病人2",
+      "name": "演示患者二",
       "alias": "",
       "gender": 2,
       "nation": "汉",
       "native_place": "广东深圳",
       "marital_status": 1,
-      "id_card_no": "430503196002063010",
+      "id_card_no": "4312301999090952222",
       "birthday": -312537600,
       "reimbursement_way_id": 7,
       "health_care_type": 0,
@@ -106,9 +106,9 @@
       "health_care_due_alert_date": 0,
       "education_level": 5,
       "profession": 10,
-      "phone": "13535547901",
-      "home_telephone": "12221903097",
-      "relative_phone": "18123074302",
+      "phone": "13800000001",
+      "home_telephone": "",
+      "relative_phone": "",
       "relative_relations": "哥哥",
       "home_address": "深圳市罗湖区鸿翔花园",
       "work_unit": "无",

controllers/new_mobile_api_controllers/schedule_template.json

@@ -0,0 +1,86 @@
+{
+  "item": [
+    {
+      "treat_mode": 1,
+      "weekday": 1,
+      "time_type": 1
+    },
+    {
+      "treat_mode": 1,
+      "weekday": 1,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 2,
+      "time_type": 1
+    },
+
+    {
+
+      "treat_mode": 1,
+      "weekday": 2,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 3,
+      "time_type": 1
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 3,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 4,
+      "time_type": 1
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 4,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 5,
+      "time_type": 1
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 5,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 6,
+      "time_type": 1
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 6,
+      "time_type": 2
+    },
+    {
+
+      "treat_mode": 1,
+      "weekday": 7,
+      "time_type": 1
+    },
+    {
+      "treat_mode": 1,
+      "weekday": 7,
+      "time_type": 2
+    }
+  ]
+}

controllers/new_mobile_api_controllers/system_dialysis_prescription.json

@@ -0,0 +1,44 @@
+{
+  "prescription": [
+    {
+      "anticoagulant": 3,
+      "anticoagulant_shouji": 4000,
+      "anticoagulant_weichi": 0,
+      "anticoagulant_zongliang": 4000,
+      "mode_id": 1,
+      "blood_flow_volume": 250,
+      "kalium": 2,
+      "sodium": 135,
+      "calcium": 1.5,
+      "status": 1,
+      "dialysis_duration_hour": 4,
+      "dialysis_duration_minute": 0
+    },{
+      "anticoagulant": 3,
+      "anticoagulant_shouji": 4000,
+      "anticoagulant_weichi": 0,
+      "anticoagulant_zongliang": 4000,
+      "mode_id": 2,
+      "blood_flow_volume": 250,
+      "kalium": 2,
+      "sodium": 135,
+      "calcium": 1.5,
+      "status": 1,
+      "dialysis_duration_hour": 4,
+      "dialysis_duration_minute": 0
+    },{
+      "anticoagulant": 3,
+      "anticoagulant_shouji": 4000,
+      "anticoagulant_weichi": 0,
+      "anticoagulant_zongliang": 4000,
+      "mode_id": 3,
+      "blood_flow_volume": 200,
+      "kalium": 2,
+      "sodium": 135,
+      "calcium": 1.5,
+      "status": 1,
+      "dialysis_duration_hour": 4,
+      "dialysis_duration_minute": 0
+    }
+  ]
+}

enums/error_code.go

@@ -178,7 +178,10 @@ const ( // ErrorCode
 
 	ErrorCodeHisIdExist = 20030
 
-	ErrorCodePreExist = 20031
+	ErrorCodePreExist   = 20031
+	ErrorCodeOrgNoExist = 20032
+
+	ErrorCodeRegisterExist = 20033
 )
 
 var ErrCodeMsgs = map[int]string{
@@ -356,6 +359,10 @@ var ErrCodeMsgs = map[int]string{
 	ErrorCodePreExist: "没有该权限",
 
 	ErrorCodeRepeatCreateOrg: "该账号已创建过机构了",
+
+	ErrorCodeOrgNoExist: "该机构不存在",
+
+	ErrorCodeRegisterExist: "该账号已经注册，请登录",
 }
 
 type SGJError struct {

models/org_models.go

@@ -49,14 +49,18 @@ func (OrgGallery) TableName() string {
 }
 
 type OrgApp struct {
-	Id         int64 `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // ID
-	AppType    int   `gorm:"column:app_type" json:"app_type"`      // 应用类型 1.病友经营；2.科普号；3.血透经营；4.慢病管理
-	Creator    int   `json:"creator"`                              // 创建者，即管理员用户的 id
-	OrgId      int   `gorm:"column:org_id" json:"org_id"`
-	OpenStatus int   `gorm:"column:open_status" json:"open_status"`
-	Status     int8  `json:"status"`                    // 状态 0.无效 1.有效 2.禁用
-	CreateTime int64 `gorm:"column:ctime" json:"ctime"` // 创建时间
-	ModifyTime int64 `gorm:"column:mtime" json:"mtime"` // 修改时间
+	Id         int64  `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // ID
+	AppType    int    `gorm:"column:app_type" json:"app_type"`      // 应用类型 1.病友经营；2.科普号；3.血透经营；4.慢病管理
+	Creator    int    `json:"creator"`                              // 创建者，即管理员用户的 id
+	OrgId      int    `gorm:"column:org_id" json:"org_id"`
+	OpenStatus int    `gorm:"column:open_status" json:"open_status"`
+	Status     int8   `json:"status"`                    // 状态 0.无效 1.有效 2.禁用
+	CreateTime int64  `gorm:"column:ctime" json:"ctime"` // 创建时间
+	ModifyTime int64  `gorm:"column:mtime" json:"mtime"` // 修改时间
+	Name       string `gorm:"column:name" json:"name" form:"name"`
+	Url        string `gorm:"column:url" json:"url" form:"url"`
+	Pid        int64  `gorm:"column:pid" json:"pid" form:"pid"`
+	Number     int64  `gorm:"column:number" json:"number" form:"number"`
 }
 
 func (OrgApp) TableName() string {

models/vm_models.go

@@ -151,3 +151,83 @@ type VMSchedule struct {
 func (VMSchedule) TableName() string {
 	return "xt_schedule"
 }
+
+type VMApp_Role struct {
+	Id          int64  `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"`
+	AdminUserId int64  `gorm:"column:admin_user_id" json:"admin_user_id"`
+	OrgId       int64  `gorm:"column:org_id" json:"org_id"`
+	Org         []*Org `gorm:"ForeignKey:ID;AssociationForeignKey:OrgId" json:"orgs"`
+}
+
+func (VMApp_Role) TableName() string {
+	return "sgj_user_admin_role"
+}
+
+type VMAdminUser struct {
+	ID         int64         `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // 管理员用户 ID
+	Org        []*Org        `gorm:"ForeignKey:Creator;AssociationForeignKey:ID" json:"orgs"`
+	VMApp_Role []*VMApp_Role `gorm:"ForeignKey:AdminUserId;AssociationForeignKey:ID" json:"roles"`
+}
+
+func (VMAdminUser) TableName() string {
+	return "sgj_user_admin"
+}
+
+type VMAdminBanner struct {
+	ID     int64  `gorm:"column:id" json:"id" form:"id"`
+	Thumb  string `gorm:"column:thumb" json:"thumb" form:"thumb"`
+	Url    string `gorm:"column:url" json:"url" form:"url"`
+	Status int64  `gorm:"column:status" json:"status" form:"status"`
+	Ctime  int64  `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime  int64  `gorm:"column:mtime" json:"mtime" form:"mtime"`
+	Title  string `gorm:"column:title" json:"title" form:"title"`
+	Desc   string `gorm:"column:desc" json:"desc" form:"desc"`
+}
+
+func (VMAdminBanner) TableName() string {
+	return "sgj_admin_banner"
+}
+
+type VMPatientScheduleTemplateId struct {
+	ID     int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId  int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	Ctime  int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime  int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (VMPatientScheduleTemplateId) TableName() string {
+	return "xt_patient_schedule_template_id"
+}
+
+type VMPatientScheduleTemplateItem struct {
+	ID             int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId          int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	TemplateId     int64 `gorm:"column:template_id" json:"template_id" form:"template_id"`
+	DeviceNumberId int64 `gorm:"column:device_number_id" json:"device_number_id" form:"device_number_id"`
+	PatientId      int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	TreatMode      int64 `gorm:"column:treat_mode" json:"treat_mode" form:"treat_mode"`
+	Weekday        int64 `gorm:"column:weekday" json:"weekday" form:"weekday"`
+	TimeType       int64 `gorm:"column:time_type" json:"time_type" form:"time_type"`
+	Status         int64 `gorm:"column:status" json:"status" form:"status"`
+	Ctime          int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime          int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (VMPatientScheduleTemplateItem) TableName() string {
+	return "xt_patient_schedule_template_id"
+}
+
+type VMPatientScheduleTemplateMode struct {
+	ID           int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId        int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	Mode         int64 `gorm:"column:mode" json:"mode" form:"mode"`
+	ExecuteTimes int64 `gorm:"column:execute_times" json:"execute_times" form:"execute_times"`
+	Status       int64 `gorm:"column:status" json:"status" form:"status"`
+	Ctime        int64 `gorm:"column:ctime" json:"ctime" form:"ctime"`
+	Mtime        int64 `gorm:"column:mtime" json:"mtime" form:"mtime"`
+}
+
+func (VMPatientScheduleTemplateMode) TableName() string {
+	return "xt_patient_schedule_template_id"
+}

service/db.go

@@ -34,6 +34,9 @@ var writeMiddleDb *gorm.DB
 
 var readPatientDb *gorm.DB
 var writePatientDb *gorm.DB
+
+var readSgjPatientDb *gorm.DB
+var writeSgjPatientDb *gorm.DB
 var err error
 
 func ConnectDB() {
@@ -85,6 +88,18 @@ func ConnectDB() {
 	writePatientPass := beego.AppConfig.String("writepatientpass")
 	writePatientName := beego.AppConfig.String("writepatientname")
 
+	readSgjPatientHost := beego.AppConfig.String("readsgjpatientmysqlhost")
+	readSgjPatientPort := beego.AppConfig.String("readsgjpatientmysqlport")
+	readSgjPatientUser := beego.AppConfig.String("readsgjpatientmysqluser")
+	readSgjPatientPass := beego.AppConfig.String("readsgjpatientmysqlpass")
+	readSgjPatientName := beego.AppConfig.String("readsgjpatientmysqlname")
+
+	writeSgjPatientHost := beego.AppConfig.String("writesgjpatientmysqlhost")
+	writeSgjPatientPort := beego.AppConfig.String("writesgjpatientmysqlport")
+	writeSgjPatientUser := beego.AppConfig.String("writesgjpatientmysqluser")
+	writeSgjPatientPass := beego.AppConfig.String("writesgjpatientmysqlpass")
+	writeSgjPatientName := beego.AppConfig.String("writesgjpatientmysqlname")
+
 	rdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUser, readPass, readHost, readPort, readName)
 	wdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeUser, writePass, writeHost, writePort, writeName)
 
@@ -97,6 +112,9 @@ func ConnectDB() {
 	rpdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readPatientUser, readPatientPass, readPatientHost, readPatientPort, readPatientName)
 	wpdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writePatientUser, writePatientPass, writePatientHost, writePatientPort, writePatientName)
 
+	rspdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readSgjPatientUser, readSgjPatientPass, readSgjPatientHost, readSgjPatientPort, readSgjPatientName)
+	wspdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeSgjPatientUser, writeSgjPatientPass, writeSgjPatientHost, writeSgjPatientPort, writeSgjPatientName)
+
 	readDb, err = gorm.Open("mysql", rdsn)
 	if err != nil {
 		//beego.Error(err)
@@ -160,6 +178,22 @@ func ConnectDB() {
 	writePatientDb.DB().SetMaxIdleConns(10)
 	writePatientDb.DB().SetMaxOpenConns(100)
 	writePatientDb.LogMode(true)
+
+	readSgjPatientDb, err = gorm.Open("mysql", rspdsn)
+	if err != nil {
+		beego.Error(err)
+	}
+	readSgjPatientDb.DB().SetMaxIdleConns(10)
+	readSgjPatientDb.DB().SetMaxOpenConns(100)
+	readSgjPatientDb.LogMode(true)
+
+	writeSgjPatientDb, err = gorm.Open("mysql", wspdsn)
+	if err != nil {
+		beego.Error(err)
+	}
+	writeSgjPatientDb.DB().SetMaxIdleConns(10)
+	writeSgjPatientDb.DB().SetMaxOpenConns(100)
+	writeSgjPatientDb.LogMode(true)
 }
 
 //func DisconnectDB() {
@@ -195,3 +229,11 @@ func PatientReadDB() *gorm.DB {
 func PatientWriteDB() *gorm.DB {
 	return writePatientDb
 }
+
+func SgjPatientReadDB() *gorm.DB {
+	return readSgjPatientDb
+}
+
+func SgjPatientWriteDB() *gorm.DB {
+	return writeSgjPatientDb
+}

service/home_service.go

@@ -0,0 +1,25 @@
+package service
+
+import (
+	"XT_New/models"
+	"github.com/jinzhu/gorm"
+)
+
+func GetHomeData(adminUserId int64) (adminUser models.VMAdminUser, err error) {
+	err = readUserDb.Model(&models.VMAdminUser{}).Where("status = 1 AND id = ?", adminUserId).
+		Preload("Org", "status = 1").
+		Preload("VMApp_Role", func(db *gorm.DB) *gorm.DB {
+			return db.Preload("Org", "status = 1").Where("status = 1")
+		}).Find(&adminUser).Error
+	return
+}
+
+func GetAllApp(org_id int64) (apps []*models.OrgApp, err error) {
+	err = readUserDb.Model(&models.OrgApp{}).Where("status = 1 AND pid > 0 AND org_id = ?", org_id).Order("number asc").Find(&apps).Error
+	return
+}
+
+func GetSystemBanner() (banners []*models.VMAdminBanner, err error) {
+	err = readUserDb.Model(&models.VMAdminBanner{}).Where("status = 1 ").Find(&banners).Error
+	return
+}

service/orginfo_service.go

@@ -75,7 +75,7 @@ func CreateOrg(org *models.Org, mobile string, openXT bool, openCDM bool, openSC
 		return err
 	}
 
-	tx_patient := writeDb.Begin()
+	tx_patient := writeSgjPatientDb.Begin()
 	if err := tx_patient.Exec("INSERT INTO sgj_patient_articles_menu (name, status, type, user_org_id, ctime, mtime) VALUES(?, ?, ?, ?, ?, ?);", "科普教育", 1, 1, org.Id, now.Unix(), now.Unix()).Error; err != nil {
 		tx_patient.Rollback()
 		tx_admin.Rollback()
@@ -99,27 +99,53 @@ func CreateOrg(org *models.Org, mobile string, openXT bool, openCDM bool, openSC
 }
 
 func createOrgApp(tx *gorm.DB, superAdminRole *models.Role, userName string, appType int, open bool) error {
-	openStatus := 0
-	if open {
-		openStatus = 1
-	}
+
+	//创建应用
 	now := time.Now().Unix()
-	app := models.OrgApp{
-		Creator:    int(superAdminRole.Creator),
-		OrgId:      int(superAdminRole.OrgId),
-		AppType:    appType,
-		OpenStatus: openStatus,
-		Status:     1,
-		CreateTime: now,
-		ModifyTime: now,
-	}
-	if createAppErr := tx.Create(&app).Error; createAppErr != nil {
-		return createAppErr
+	var app_id int64
+	apps, _ := FindSystemOrgApp()
+	for _, item := range apps {
+		app := &VMOrgApp{
+			AppType:    item.AppType,
+			Creator:    int(superAdminRole.Creator),
+			OrgId:      int(superAdminRole.OrgId),
+			OpenStatus: item.OpenStatus,
+			Status:     1,
+			CreateTime: now,
+			ModifyTime: now,
+			Name:       item.Name,
+			Url:        item.Url,
+			Order:      item.Order,
+			Pid:        0,
+		}
+		writeUserDb.Create(&app)
+		if app.AppType == 3 {
+			app_id = app.ID
+
+		}
+
+		for _, subItem := range item.VMOrgApp {
+			app := &VMOrgApp{
+				AppType:    subItem.AppType,
+				Creator:    int(superAdminRole.Creator),
+				OrgId:      int(superAdminRole.OrgId),
+				OpenStatus: subItem.OpenStatus,
+				Status:     1,
+				CreateTime: now,
+				ModifyTime: now,
+				Name:       subItem.Name,
+				Url:        subItem.Url,
+				Order:      subItem.Order,
+				Pid:        app.ID,
+			}
+			writeUserDb.Create(&app)
+		}
 	}
+
 	app_role := models.App_Role{
 		AdminUserId: superAdminRole.Creator,
 		OrgId:       superAdminRole.OrgId,
-		AppId:       app.Id,
+		AppId:       app_id,
 		RoleId:      superAdminRole.Id,
 		Avatar:      "",
 		UserName:    userName,
@@ -140,3 +166,32 @@ func GetOrgTypeByName(org_type_name string) (org_type models.OrgType) {
 	readUserDb.Model(&models.OrgType{}).Where("status = 1 AND name = ?", org_type_name).First(&org_type)
 	return
 }
+
+type VMOrgApp struct {
+	ID         int64       `gorm:"PRIMARY_KEY;AUTO_INCREMENT" json:"id"` // ID
+	AppType    int         `gorm:"column:app_type" json:"app_type"`
+	Creator    int         `json:"creator"` // 创建者，即管理员用户的 id
+	OrgId      int         `gorm:"column:org_id" json:"org_id"`
+	OpenStatus int         `gorm:"column:open_status" json:"open_status"`
+	Status     int8        `json:"status"`                    // 状态 0.无效 1.有效 2.禁用
+	CreateTime int64       `gorm:"column:ctime" json:"ctime"` // 创建时间
+	ModifyTime int64       `gorm:"column:mtime" json:"mtime"` // 修改时间
+	Name       string      `gorm:"column:name" json:"name" form:"name"`
+	Url        string      `gorm:"column:url" json:"url" form:"url"`
+	Pid        int64       `gorm:"column:pid" json:"pid" form:"pid"`
+	Order      int64       `gorm:"column:order" json:"order" form:"order"`
+	VMOrgApp   []*VMOrgApp `gorm:"ForeignKey:Pid;AssociationForeignKey:Id" `
+}
+
+func (VMOrgApp) TableName() string {
+	return "sgj_user_org_app"
+}
+
+func FindSystemOrgApp() (app []*VMOrgApp, err error) {
+	err = readUserDb.Model(&VMOrgApp{}).Preload("VMOrgApp", "org_id = 0 AND status =1 AND pid > 0").Where("status = 1 AND org_id = 0 AND pid = 0").Find(&app).Error
+	return
+}
+
+func GetAllOrgByAdminUserId() {
+
+}

service/role_service.go

@@ -106,6 +106,7 @@ type AdminUserManageViewModel struct {
 	Ip          string `gorm:"ip" json:"ip"`
 	Ctime       int64  `gorm:"ctime" json:"last_login_time"`
 	Status      int    `gorm:"status" json:"status"`
+	Avatar      string `gorm:"avatar" json:"avatar"`
 
 	// LastLoginTimeStr string `gorm:"-" json:"last_login_time_formatted"`
 	TitleName string `gorm:"-" json:"title_name"`
@@ -119,7 +120,7 @@ func GetAdminUsersAndLoginInfo(orgID int64, appID int64, page int, count int) ([
 		page = 1
 	}
 	var viewModels []*AdminUserManageViewModel = make([]*AdminUserManageViewModel, 0)
-	rows, err := readUserDb.Raw("SELECT u_a_r.admin_user_id, u_a_r.user_name, u_r.role_name, u_a_r.user_title, u_l.ip, u_l.ctime, u_a_r.status FROM sgj_user_admin_role AS u_a_r INNER JOIN sgj_user_role AS u_r ON u_a_r.org_id = u_r.org_id AND u_a_r.app_id = u_r.app_id AND u_r.id = u_a_r.role_id LEFT JOIN (SELECT * FROM (SELECT admin_user_id, org_id, app_id, ip, ctime FROM sgj_user_admin_login_log WHERE org_id = ? AND app_id = ? ORDER BY ctime DESC) AS t GROUP BY admin_user_id) AS u_l ON u_a_r.org_id = u_l.org_id AND u_a_r.app_id = u_l.app_id AND u_a_r.admin_user_id = u_l.admin_user_id WHERE u_a_r.org_id = ? AND u_a_r.app_id = ? GROUP BY u_a_r.admin_user_id LIMIT ? OFFSET ?;", orgID, appID, orgID, appID, count, (page-1)*count).Rows()
+	rows, err := readUserDb.Raw("SELECT u_a_r.admin_user_id, u_a_r.user_name, u_r.role_name, u_a_r.user_title, u_l.ip, u_l.ctime, u_a_r.status,u_a_r.avatar FROM sgj_user_admin_role AS u_a_r INNER JOIN sgj_user_role AS u_r ON u_a_r.org_id = u_r.org_id AND u_a_r.app_id = u_r.app_id AND u_r.id = u_a_r.role_id LEFT JOIN (SELECT * FROM (SELECT admin_user_id, org_id, app_id, ip, ctime FROM sgj_user_admin_login_log WHERE org_id = ? AND app_id = ? ORDER BY ctime DESC) AS t GROUP BY admin_user_id) AS u_l ON u_a_r.org_id = u_l.org_id AND u_a_r.app_id = u_l.app_id AND u_a_r.admin_user_id = u_l.admin_user_id WHERE u_a_r.org_id = ? AND u_a_r.app_id = ? GROUP BY u_a_r.admin_user_id LIMIT ? OFFSET ?;", orgID, appID, orgID, appID, count, (page-1)*count).Rows()
 	defer rows.Close()
 	if err != nil {
 		if err == gorm.ErrRecordNotFound {
@@ -403,3 +404,12 @@ func ModifyAdminUserInfo(adminUserID int64, orgID int64, appID int64, name strin
 	tx.Commit()
 	return nil
 }
+
+func GetOrgApp(orgID int64, app_type int) (*models.OrgApp, error) {
+	var apps models.OrgApp
+	err := readUserDb.Where("app_type = ? AND org_id = ? AND status = 1", app_type, orgID).First(&apps).Error
+	if err != nil {
+		return nil, err
+	}
+	return &apps, nil
+}

service/vm_service.go

@@ -1,6 +1,8 @@
 package service
 
-import "XT_New/models"
+import (
+	"XT_New/models"
+)
 
 func CreateVMOrgPatient(patients *models.VMOrgPatients) {
 	writeDb.Model(&models.VMOrgPatients{}).Create(&patients)
@@ -21,3 +23,19 @@ func CreateVMDeviceNumber(number *models.VMDeviceNumber) {
 func CreateVMSch(sch *models.VMSchedule) {
 	writeDb.Model(&models.VMSchedule{}).Create(&sch)
 }
+
+func CreateVMSchMode(schMode *models.VMPatientScheduleTemplateMode) {
+	writeDb.Model(&models.VMPatientScheduleTemplateMode{}).Create(&schMode)
+}
+
+func CreateVMSchTemplateId(schTemplateId *models.VMPatientScheduleTemplateId) {
+	writeDb.Model(&models.VMPatientScheduleTemplateId{}).Create(&schTemplateId)
+}
+
+func CreateVMSchTemplate(schTemplate *models.VMPatientScheduleTemplateItem) {
+	writeDb.Model(&models.VMPatientScheduleTemplateItem{}).Create(&schTemplate)
+}
+
+func CreateVMPrescription(sys *models.SystemPrescription) {
+	writeDb.Model(&models.SystemPrescription{}).Create(&sys)
+}