mobile_regist_controller.go 30KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061
  1. package new_mobile_api_controllers
  2. import (
  3. "XT_New/controllers/mobile_api_controllers"
  4. "XT_New/enums"
  5. "XT_New/models"
  6. "XT_New/service"
  7. "XT_New/utils"
  8. "bytes"
  9. "encoding/json"
  10. "fmt"
  11. "github.com/astaxie/beego"
  12. "io/ioutil"
  13. "log"
  14. "net/http"
  15. "net/url"
  16. "os"
  17. "path"
  18. "regexp"
  19. "runtime"
  20. "strconv"
  21. "time"
  22. )
  23. type MobileRegistController struct {
  24. mobile_api_controllers.MobileBaseAPIController
  25. }
  26. // /mobile/regist [get]
  27. // /mobile/regist/submit [post]
  28. // @param mobile:string
  29. // @param password:string
  30. // @param code:string
  31. func (this *MobileRegistController) RegistSubmit() {
  32. mobile := this.GetString("mobile")
  33. pwd := this.GetString("password")
  34. code := this.GetString("code")
  35. // 判断手机号是否存在
  36. if utils.CellPhoneRegexp().MatchString(mobile) == false {
  37. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMobileFormat)
  38. return
  39. }
  40. if len(pwd) == 0 {
  41. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodePasswordEmpty)
  42. return
  43. }
  44. if len(code) == 0 {
  45. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeVerificationCodeWrong)
  46. return
  47. }
  48. if service.IsMobileRegister(mobile) == true {
  49. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeMobileRegistered)
  50. return
  51. }
  52. if code == "13535547901" {
  53. admin, err := service.RegisterSuperAdmin(mobile, pwd)
  54. if err != nil {
  55. this.ServeFailJSONWithSGJErrorCode(err.Code)
  56. return
  57. } else {
  58. this.Ctx.SetCookie("mobile", mobile)
  59. this.SetSession("mobile_admin_user", admin)
  60. this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{
  61. "result": true,
  62. "id": admin.Id,
  63. })
  64. this.ServeJSON()
  65. }
  66. } else {
  67. redisClient := service.RedisClient()
  68. defer redisClient.Close()
  69. cache_code, _ := redisClient.Get("code_msg_" + mobile).Result()
  70. if cache_code != code {
  71. //this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeVerificationCodeWrong)
  72. //this.ServeJSON()
  73. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeVerificationCodeWrong)
  74. return
  75. }
  76. admin, err := service.RegisterSuperAdmin(mobile, pwd)
  77. if err != nil {
  78. this.ServeFailJSONWithSGJErrorCode(err.Code)
  79. return
  80. } else {
  81. this.Ctx.SetCookie("mobile", mobile)
  82. this.SetSession("mobile_admin_user", admin)
  83. // 注册成功后验证码就要使其失效
  84. redisClient.Del("code_msg_" + mobile)
  85. this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{
  86. "result": true,
  87. "id": admin.Id,
  88. })
  89. this.ServeJSON()
  90. }
  91. }
  92. }
  93. // /mobile/org/create/submit [post]
  94. // @param name:string
  95. // @param province:string 省名
  96. // @param city:string 市名
  97. // @param district:string 区县
  98. // @param address:string
  99. // @param category:int
  100. // @param contact_name:string
  101. // @param org_phone?:string
  102. // @param open_xt?:bool 是否开启血透系统
  103. // @param open_cdm?:bool 是否开启慢病系统
  104. // @param open_scrm?:bool 是否开启SCRM
  105. // @param open_mall?:bool 是否开启Mall
  106. func (this *MobileRegistController) CreateOrg() {
  107. adminUserObj := this.GetSession("mobile_admin_user")
  108. if adminUserObj == nil {
  109. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeLoginTimeout)
  110. this.ServeJSON()
  111. return
  112. }
  113. adminUser := adminUserObj.(*models.AdminUser)
  114. //if didCreateOrg, checkCreateOrgErr := service.DidAdminUserCreateOrg(adminUser.Id); checkCreateOrgErr != nil {
  115. // this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  116. // this.ServeJSON()
  117. // return
  118. //} else if didCreateOrg {
  119. // this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeRepeatCreateOrg)
  120. // this.ServeJSON()
  121. // return
  122. //}
  123. name := this.GetString("org_name")
  124. shortName := name
  125. provinceName := this.GetString("provinces_name")
  126. cityName := this.GetString("city_name")
  127. districtName := this.GetString("district_name")
  128. address := this.GetString("address")
  129. org_type := this.GetString("org_type")
  130. contactName := this.GetString("contact_name")
  131. //openXT, _ := this.GetBool("open_xt")
  132. //openCDM, _ := this.GetBool("open_cdm")
  133. //openSCRM, _ := this.GetBool("open_scrm")
  134. //openMall, _ := this.GetBool("open_mall")
  135. openXT := true
  136. openCDM := false
  137. openSCRM := false
  138. openMall := false
  139. 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 {
  140. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  141. this.ServeJSON()
  142. return
  143. }
  144. orgPhone := this.GetString("telephone")
  145. if len(orgPhone) > 0 {
  146. if utils.PhoneRegexp().MatchString(orgPhone) == false {
  147. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
  148. this.ServeJSON()
  149. return
  150. }
  151. }
  152. provinceID := 0
  153. cityID := 0
  154. districtID := 0
  155. province, getProvinceErr := service.GetProvinceWithName(provinceName)
  156. if getProvinceErr != nil {
  157. utils.ErrorLog("查询省名失败:%v", getProvinceErr)
  158. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  159. this.ServeJSON()
  160. return
  161. } else if province != nil {
  162. provinceID = int(province.ID)
  163. city, getCityErr := service.GetCityWithName(province.ID, cityName)
  164. if getCityErr != nil {
  165. utils.ErrorLog("查询城市名失败:%v", getCityErr)
  166. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  167. this.ServeJSON()
  168. return
  169. } else if city != nil {
  170. cityID = int(city.ID)
  171. district, getDistrictErr := service.GetDistrictWithName(city.ID, districtName)
  172. if getDistrictErr != nil {
  173. utils.ErrorLog("查询区县名失败:%v", getDistrictErr)
  174. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  175. this.ServeJSON()
  176. return
  177. } else if district != nil {
  178. districtID = int(district.ID)
  179. }
  180. }
  181. }
  182. orgType := service.GetOrgTypeByName(org_type)
  183. org := &models.Org{
  184. Creator: adminUser.Id,
  185. OrgName: name,
  186. OrgShortName: shortName,
  187. Province: int64(provinceID),
  188. City: int64(cityID),
  189. District: int64(districtID),
  190. Address: address,
  191. OrgType: orgType.ID,
  192. Telephone: orgPhone,
  193. ContactName: contactName,
  194. Claim: 1,
  195. Evaluate: 5,
  196. Status: 1,
  197. CreateTime: time.Now().Unix(),
  198. ModifyTime: time.Now().Unix(),
  199. }
  200. createErr := service.CreateOrg(org, adminUser.Mobile, openXT, openCDM, openSCRM, openMall) // 创建机构以及所有类型的 app,如果有新类型的平台,则需要在这个方法里面把创建这一新类型的 app 的代码加上
  201. if createErr != nil {
  202. utils.ErrorLog("mobile=%v的超级管理员创建机构失败:%v", adminUser.Mobile, createErr)
  203. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeDBCreate)
  204. this.ServeJSON()
  205. } else {
  206. //初始化病人和排班相关数据
  207. InitPatientAndSchedule(org)
  208. //初始化透析方案
  209. InitSystemPrescrption(org)
  210. //初始化医嘱模版
  211. //InitAdviceTemplate(org)
  212. //初始化角色和权限
  213. //初始化设备管理
  214. InitEquitMentInformation(org)
  215. //初始化显示配置
  216. //创建完机构后进行登录验证操作
  217. ip := utils.GetIP(this.Ctx.Request)
  218. ssoDomain := beego.AppConfig.String("sso_domain")
  219. api := ssoDomain + "/m/login/pwd"
  220. values := make(url.Values)
  221. values.Set("mobile", adminUser.Mobile)
  222. values.Set("password", adminUser.Password)
  223. values.Set("app_type", "3")
  224. values.Set("ip", ip)
  225. resp, requestErr := http.PostForm(api, values)
  226. if requestErr != nil {
  227. utils.ErrorLog("请求SSO登录接口失败: %v", requestErr)
  228. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  229. return
  230. }
  231. defer resp.Body.Close()
  232. body, ioErr := ioutil.ReadAll(resp.Body)
  233. if ioErr != nil {
  234. utils.ErrorLog("SSO登录接口返回数据读取失败: %v", ioErr)
  235. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  236. return
  237. }
  238. var respJSON map[string]interface{}
  239. utils.InfoLog(string(body))
  240. if err := json.Unmarshal([]byte(string(body)), &respJSON); err != nil {
  241. utils.ErrorLog("SSO登录接口返回数据解析JSON失败: %v", err)
  242. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  243. return
  244. }
  245. if respJSON["state"].(float64) != 1 {
  246. msg := respJSON["msg"].(string)
  247. utils.ErrorLog("SSO登录接口请求失败: %v", msg)
  248. if int(respJSON["code"].(float64)) == 609 {
  249. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeAccountOrPasswordWrong)
  250. return
  251. }
  252. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  253. return
  254. } else {
  255. utils.SuccessLog("SSO登录成功")
  256. // 下面这几段 Map=>JSON=>Struct 的流程可能会造成速度很慢
  257. userJSON := respJSON["data"].(map[string]interface{})["admin"].(map[string]interface{})
  258. userJSONBytes, _ := json.Marshal(userJSON)
  259. var adminUser models.AdminUser
  260. if err := json.Unmarshal(userJSONBytes, &adminUser); err != nil {
  261. utils.ErrorLog("解析管理员失败:%v", err)
  262. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  263. return
  264. }
  265. var org models.Org
  266. if respJSON["data"].(map[string]interface{})["org"] != nil {
  267. orgJSON := respJSON["data"].(map[string]interface{})["org"].(map[string]interface{})
  268. orgJSONBytes, _ := json.Marshal(orgJSON)
  269. if err := json.Unmarshal(orgJSONBytes, &org); err != nil {
  270. utils.ErrorLog("解析机构失败:%v", err)
  271. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  272. return
  273. }
  274. }
  275. var app models.OrgApp
  276. if respJSON["data"].(map[string]interface{})["app"] != nil {
  277. appJSON := respJSON["data"].(map[string]interface{})["app"].(map[string]interface{})
  278. appJSONBytes, _ := json.Marshal(appJSON)
  279. if err := json.Unmarshal(appJSONBytes, &app); err != nil {
  280. utils.ErrorLog("解析应用失败:%v", err)
  281. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  282. return
  283. }
  284. }
  285. var appRole models.App_Role
  286. if respJSON["data"].(map[string]interface{})["app_role"] != nil {
  287. appRoleJSON := respJSON["data"].(map[string]interface{})["app_role"].(map[string]interface{})
  288. appRoleJSONBytes, _ := json.Marshal(appRoleJSON)
  289. if err := json.Unmarshal(appRoleJSONBytes, &appRole); err != nil {
  290. utils.ErrorLog("解析AppRole失败:%v", err)
  291. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  292. return
  293. }
  294. }
  295. var subscibe models.ServeSubscibe
  296. if respJSON["data"].(map[string]interface{})["subscibe"] != nil {
  297. subscibeJSON := respJSON["data"].(map[string]interface{})["subscibe"].(map[string]interface{})
  298. subscibeJSONBytes, _ := json.Marshal(subscibeJSON)
  299. if err := json.Unmarshal(subscibeJSONBytes, &subscibe); err != nil {
  300. utils.ErrorLog("解析Subscibe失败:%v", err)
  301. this.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
  302. return
  303. }
  304. }
  305. //service.GetOrgSubscibeState(&subscibe)
  306. templateInfo, _ := service.GetOrgInfoTemplate(org.Id)
  307. mobileAdminUserInfo := &mobile_api_controllers.MobileAdminUserInfo{
  308. AdminUser: &adminUser,
  309. Org: &org,
  310. App: &app,
  311. AppRole: &appRole,
  312. Subscibe: &subscibe,
  313. TemplateInfo: &templateInfo,
  314. }
  315. //设置seesion
  316. this.SetSession("mobile_admin_user_info", mobileAdminUserInfo)
  317. //设置cookie
  318. mobile := adminUser.Mobile + "-" + strconv.FormatInt(org.Id, 10) + "-" + strconv.FormatInt(appRole.Id, 10)
  319. token := utils.GenerateLoginToken(mobile)
  320. expiration, _ := beego.AppConfig.Int64("mobile_token_expiration_second")
  321. this.Ctx.SetCookie("token_cookie", token, expiration, "/")
  322. var configList interface{}
  323. var FiledList []*models.FiledConfig
  324. if org.Id > 0 {
  325. configList, _ = service.GetConfigList(org.Id)
  326. FiledList, _ = service.FindFiledByOrgId(org.Id)
  327. }
  328. if len(FiledList) == 0 {
  329. var err error
  330. if org.Id > 0 {
  331. err = service.BatchInsertFiledConfig(org.Id)
  332. if err == nil {
  333. FiledList, _ = service.FindFiledByOrgId(org.Id)
  334. } else {
  335. utils.ErrorLog("字段批量插入失败:%v", err)
  336. }
  337. } else {
  338. FiledList = make([]*models.FiledConfig, 0)
  339. }
  340. }
  341. this.ServeSuccessJSON(map[string]interface{}{
  342. "admin": adminUser,
  343. "user": appRole,
  344. "org": org,
  345. "template_info": map[string]interface{}{
  346. "id": templateInfo.ID,
  347. "org_id": templateInfo.OrgId,
  348. "template_id": templateInfo.TemplateId,
  349. },
  350. "config_list": configList,
  351. "filed_list": FiledList,
  352. })
  353. }
  354. }
  355. }
  356. func InitAdviceTemplate(org *models.Org) {
  357. //初始化医嘱模版
  358. adviceInit := &models.AdviceInit{
  359. UserOrgId: org.Id,
  360. CreateTime: time.Now().Unix(),
  361. UpdateTime: time.Now().Unix(),
  362. Status: 1,
  363. IsInit: 1,
  364. }
  365. adviceParentTemplate := LoadConfig("./advice_template.json").Parent_template
  366. for _, item := range adviceParentTemplate {
  367. parentTemplate := &models.DoctorAdviceParentTemplate{
  368. OrgId: org.Id,
  369. Name: item.Name,
  370. Status: 1,
  371. CreatedTime: time.Now().Unix(),
  372. UpdatedTime: time.Now().Unix(),
  373. AdviceType: item.AdviceType,
  374. }
  375. createErr := service.CreateDoctorParentTemplate(parentTemplate)
  376. fmt.Println(parentTemplate.ID)
  377. if createErr == nil {
  378. for _, adviceTemplateItem := range item.DoctorAdviceTemplate {
  379. adviceTeplate := &models.DoctorAdviceTemplate{
  380. OrgId: org.Id,
  381. AdviceName: adviceTemplateItem.AdviceName,
  382. AdviceDesc: adviceTemplateItem.AdviceDesc,
  383. SingleDose: adviceTemplateItem.SingleDose,
  384. SingleDoseUnit: adviceTemplateItem.SingleDoseUnit,
  385. PrescribingNumber: adviceTemplateItem.PrescribingNumber,
  386. PrescribingNumberUnit: adviceTemplateItem.PrescribingNumberUnit,
  387. DeliveryWay: adviceTemplateItem.DeliveryWay,
  388. ExecutionFrequency: adviceTemplateItem.ExecutionFrequency,
  389. AdviceDoctor: adviceTemplateItem.AdviceDoctor,
  390. Status: 1,
  391. CreatedTime: time.Now().Unix(),
  392. UpdatedTime: time.Now().Unix(),
  393. TemplateId: parentTemplate.ID,
  394. DrugSpec: adviceTemplateItem.DrugSpec,
  395. DrugSpecUnit: adviceTemplateItem.DrugSpecUnit,
  396. ParentId: adviceTemplateItem.ParentId,
  397. AdviceType: adviceTemplateItem.AdviceType,
  398. DayCount: adviceTemplateItem.DayCount,
  399. WeekDays: adviceTemplateItem.WeekDays,
  400. FrequencyType: adviceTemplateItem.FrequencyType,
  401. }
  402. createErr := service.CreateDoctorTemplate(adviceTeplate)
  403. if createErr == nil {
  404. for _, childItem := range adviceTemplateItem.SubDoctorAdviceTemplate {
  405. adviceTeplate := &models.DoctorAdviceTemplate{
  406. OrgId: org.Id,
  407. AdviceName: childItem.AdviceName,
  408. AdviceDesc: childItem.AdviceDesc,
  409. SingleDose: childItem.SingleDose,
  410. SingleDoseUnit: childItem.SingleDoseUnit,
  411. PrescribingNumber: childItem.PrescribingNumber,
  412. PrescribingNumberUnit: childItem.PrescribingNumberUnit,
  413. DeliveryWay: childItem.DeliveryWay,
  414. ExecutionFrequency: childItem.ExecutionFrequency,
  415. AdviceDoctor: childItem.AdviceDoctor,
  416. Status: 1,
  417. CreatedTime: time.Now().Unix(),
  418. UpdatedTime: time.Now().Unix(),
  419. TemplateId: parentTemplate.ID,
  420. DrugSpec: childItem.DrugSpec,
  421. DrugSpecUnit: childItem.DrugSpecUnit,
  422. ParentId: adviceTeplate.ID,
  423. AdviceType: childItem.AdviceType,
  424. DayCount: childItem.DayCount,
  425. WeekDays: childItem.WeekDays,
  426. FrequencyType: childItem.FrequencyType,
  427. }
  428. service.CreateDoctorTemplate(adviceTeplate)
  429. }
  430. }
  431. }
  432. }
  433. }
  434. service.CreateAdviceInitConfig(adviceInit)
  435. }
  436. func InitSystemPrescrption(org *models.Org) {
  437. //初始化透析方案
  438. prescriptions := LoadPrescriptionConfig("./system_dialysis_prescription.json").Prescription
  439. for _, item := range prescriptions {
  440. item.UserOrgId = org.Id
  441. item.CreatedTime = time.Now().Unix()
  442. item.UpdatedTime = time.Now().Unix()
  443. service.CreateVMPrescription(item)
  444. }
  445. }
  446. func InitPatientAndSchedule(org *models.Org) {
  447. var ids []int64
  448. //数据初始化
  449. //创建两个虚拟病人
  450. patients := LoadPatientConfig("./patient.json").Patients
  451. for _, item := range patients {
  452. item.UserOrgId = org.Id
  453. item.CreatedTime = time.Now().Unix()
  454. item.UpdatedTime = time.Now().Unix()
  455. item.Status = 1
  456. service.CreateVMOrgPatient(item)
  457. ids = append(ids, item.ID)
  458. }
  459. //创建两个血透的虚拟病人到新表
  460. fmt.Print("patients", patients)
  461. for _, it := range ids {
  462. patientsNew := models.XtPatientsNew{
  463. UserOrgId: org.Id,
  464. CreatedTime: time.Now().Unix(),
  465. UpdatedTime: time.Now().Unix(),
  466. Status: 1,
  467. BloodId: it,
  468. BloodPatients: 1,
  469. }
  470. service.CreateVMOrgNewPatient(&patientsNew)
  471. }
  472. //创建1个分组
  473. vmGroup := &models.VMDeviceGroup{
  474. OrgId: org.Id,
  475. Name: "护理一组",
  476. Status: 1,
  477. Ctime: time.Now().Unix(),
  478. Mtime: time.Now().Unix(),
  479. }
  480. service.CreateVMGroup(vmGroup)
  481. //创建两个虚拟分区
  482. vmZone1 := &models.VMDeviceZone{
  483. OrgId: org.Id,
  484. Name: "A区",
  485. Type: 1,
  486. Status: 1,
  487. Ctime: time.Now().Unix(),
  488. Mtime: time.Now().Unix(),
  489. }
  490. service.CreateVMZone(vmZone1)
  491. vmZone2 := &models.VMDeviceZone{
  492. OrgId: org.Id,
  493. Name: "B区",
  494. Type: 2,
  495. Status: 1,
  496. Ctime: time.Now().Unix(),
  497. Mtime: time.Now().Unix(),
  498. }
  499. service.CreateVMZone(vmZone2)
  500. //创建2个虚拟床位
  501. vmDeviceNumber1 := &models.VMDeviceNumber{
  502. OrgId: org.Id,
  503. Number: "1号床",
  504. GroupId: vmGroup.ID,
  505. ZoneId: vmZone1.ID,
  506. Status: 1,
  507. Ctime: time.Now().Unix(),
  508. Mtime: time.Now().Unix(),
  509. }
  510. service.CreateVMDeviceNumber(vmDeviceNumber1)
  511. vmDeviceNumber2 := &models.VMDeviceNumber{
  512. OrgId: org.Id,
  513. Number: "2号床",
  514. GroupId: vmGroup.ID,
  515. ZoneId: vmZone2.ID,
  516. Status: 1,
  517. Ctime: time.Now().Unix(),
  518. Mtime: time.Now().Unix(),
  519. }
  520. service.CreateVMDeviceNumber(vmDeviceNumber2)
  521. var dates []int64
  522. mondayDate := GetDateOfWeek(1)
  523. tuesdayDate := GetDateOfWeek(2)
  524. wednesdayDate := GetDateOfWeek(3)
  525. thursdayDate := GetDateOfWeek(4)
  526. fridayDate := GetDateOfWeek(5)
  527. saturdayDate := GetDateOfWeek(6)
  528. sundayDate := GetDateOfWeek(7)
  529. dates = append(dates, mondayDate)
  530. dates = append(dates, tuesdayDate)
  531. dates = append(dates, wednesdayDate)
  532. dates = append(dates, thursdayDate)
  533. dates = append(dates, fridayDate)
  534. dates = append(dates, saturdayDate)
  535. dates = append(dates, sundayDate)
  536. //创建两个虚拟病人本周的排班
  537. //stime, _ := time.Parse("2006-01-02", time.Now().Format("2006-01-02"))
  538. for week_type, date := range dates {
  539. for index, id := range ids {
  540. if index == 0 {
  541. sch := &models.VMSchedule{
  542. UserOrgId: org.Id,
  543. PartitionId: vmZone1.ID,
  544. BedId: vmDeviceNumber1.ID,
  545. PatientId: id,
  546. ScheduleDate: date,
  547. ScheduleType: 1,
  548. ScheduleWeek: int64(week_type + 1),
  549. ModeId: 1,
  550. Status: 1,
  551. CreatedTime: time.Now().Unix(),
  552. UpdatedTime: time.Now().Unix(),
  553. }
  554. service.CreateVMSch(sch)
  555. }
  556. if index == 1 {
  557. sch := &models.VMSchedule{
  558. UserOrgId: org.Id,
  559. PartitionId: vmZone2.ID,
  560. BedId: vmDeviceNumber2.ID,
  561. PatientId: id,
  562. ScheduleDate: date,
  563. ScheduleType: 2,
  564. ScheduleWeek: int64(week_type + 1),
  565. ModeId: 1,
  566. Status: 1,
  567. CreatedTime: time.Now().Unix(),
  568. UpdatedTime: time.Now().Unix(),
  569. }
  570. service.CreateVMSch(sch)
  571. }
  572. }
  573. }
  574. //创建单周模版
  575. //1.创建模版模式
  576. mode := &models.VMPatientScheduleTemplateMode{
  577. OrgId: org.Id,
  578. Mode: 1,
  579. ExecuteTimes: 0,
  580. Status: 1,
  581. Ctime: time.Now().Unix(),
  582. Mtime: time.Now().Unix(),
  583. }
  584. service.CreateVMSchMode(mode)
  585. //2.创建模版id
  586. templaeIdOne := &models.VMPatientScheduleTemplateId{
  587. OrgId: org.Id,
  588. Status: 1,
  589. Ctime: time.Now().Unix(),
  590. Mtime: time.Now().Unix(),
  591. }
  592. service.CreateVMSchTemplateId(templaeIdOne)
  593. templaeIdTwo := &models.VMPatientScheduleTemplateId{
  594. OrgId: org.Id,
  595. Status: 1,
  596. Ctime: time.Now().Unix(),
  597. Mtime: time.Now().Unix(),
  598. }
  599. service.CreateVMSchTemplateId(templaeIdTwo)
  600. //3.创建单周排班模版
  601. items := LoadSchTemplateConfig("./schedule_template.json").Item
  602. for _, item := range items {
  603. if item.TimeType == 1 {
  604. item.OrgId = org.Id
  605. item.TemplateId = templaeIdOne.ID
  606. item.DeviceNumberId = vmDeviceNumber1.ID
  607. item.PatientId = ids[0]
  608. item.Status = 1
  609. item.Ctime = time.Now().Unix()
  610. item.Mtime = time.Now().Unix()
  611. } else if item.TimeType == 2 {
  612. item.OrgId = org.Id
  613. item.TemplateId = templaeIdOne.ID
  614. item.DeviceNumberId = vmDeviceNumber2.ID
  615. item.PatientId = ids[1]
  616. item.Status = 1
  617. item.Ctime = time.Now().Unix()
  618. item.Mtime = time.Now().Unix()
  619. }
  620. service.CreateVMSchTemplate(item)
  621. }
  622. }
  623. func (this *MobileRegistController) ModifyName() {
  624. name := this.GetString("name")
  625. adminUserObj := this.GetSession("mobile_admin_user")
  626. adminUser := adminUserObj.(*models.AdminUser)
  627. err := service.ModifyAdminUserName(name, adminUser.Id)
  628. if err != nil {
  629. utils.ErrorLog("修改管理员名字失败:%v", err)
  630. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
  631. this.ServeJSON()
  632. } else {
  633. this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{})
  634. this.ServeJSON()
  635. }
  636. }
  637. func (this *MobileRegistController) Login() {
  638. mobile := this.Ctx.GetCookie("mobile")
  639. adminUser, err := service.GetValidAdminUserByMobileReturnErr(mobile)
  640. if err != nil {
  641. utils.ErrorLog("获取管理信息失败:%v", err)
  642. this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(enums.ErrorCodeSystemError)
  643. this.ServeJSON()
  644. } else {
  645. mobileAdminUserInfo := &mobile_api_controllers.MobileAdminUserInfo{
  646. AdminUser: adminUser,
  647. Org: nil,
  648. App: nil,
  649. AppRole: nil,
  650. Subscibe: nil,
  651. TemplateInfo: nil,
  652. }
  653. var org models.Org
  654. var user models.App_Role
  655. //设置seesion
  656. this.SetSession("mobile_admin_user_info", mobileAdminUserInfo)
  657. //设置cookie
  658. mobile = mobile + "-" + "0" + "-" + "0"
  659. token := utils.GenerateLoginToken(mobile)
  660. expiration, _ := beego.AppConfig.Int64("mobile_token_expiration_second")
  661. this.Ctx.SetCookie("token_cookie", token, expiration, "/")
  662. this.Data["json"] = enums.MakeSuccessResponseJSON(map[string]interface{}{
  663. "admin": adminUser,
  664. "user": user,
  665. "org": org,
  666. "template_info": map[string]interface{}{
  667. "id": 0,
  668. "org_id": 0,
  669. "template_id": 0,
  670. },
  671. "config_list": nil,
  672. "filed_list": nil,
  673. })
  674. this.ServeJSON()
  675. }
  676. }
  677. type PatientConfig struct {
  678. Patients []*models.VMOrgPatients "json:patients"
  679. }
  680. type SchTemplateConfig struct {
  681. Item []*models.VMPatientScheduleTemplateItem "json:item"
  682. }
  683. type PrescriptionConfig struct {
  684. Prescription []*models.SystemPrescription "json:prescription"
  685. }
  686. func LoadPatientConfig(dataFile string) *PatientConfig {
  687. var config PatientConfig
  688. _, filename, _, _ := runtime.Caller(1)
  689. datapath := path.Join(path.Dir(filename), dataFile)
  690. config_file, err := os.Open(datapath)
  691. if err != nil {
  692. emit("Failed to open config file '%s': %s\n", datapath, err)
  693. return &config
  694. }
  695. fi, _ := config_file.Stat()
  696. buffer := make([]byte, fi.Size())
  697. _, err = config_file.Read(buffer)
  698. buffer, err = StripComments(buffer) //去掉注释
  699. if err != nil {
  700. emit("Failed to strip comments from json: %s\n", err)
  701. return &config
  702. }
  703. buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
  704. err = json.Unmarshal(buffer, &config) //解析json格式数据
  705. if err != nil {
  706. emit("Failed unmarshalling json: %s\n", err)
  707. return &config
  708. }
  709. return &config
  710. }
  711. func LoadSchTemplateConfig(dataFile string) *SchTemplateConfig {
  712. var config SchTemplateConfig
  713. _, filename, _, _ := runtime.Caller(1)
  714. datapath := path.Join(path.Dir(filename), dataFile)
  715. config_file, err := os.Open(datapath)
  716. if err != nil {
  717. emit("Failed to open config file '%s': %s\n", datapath, err)
  718. return &config
  719. }
  720. fi, _ := config_file.Stat()
  721. buffer := make([]byte, fi.Size())
  722. _, err = config_file.Read(buffer)
  723. buffer, err = StripComments(buffer) //去掉注释
  724. if err != nil {
  725. emit("Failed to strip comments from json: %s\n", err)
  726. return &config
  727. }
  728. buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
  729. err = json.Unmarshal(buffer, &config) //解析json格式数据
  730. if err != nil {
  731. emit("Failed unmarshalling json: %s\n", err)
  732. return &config
  733. }
  734. return &config
  735. }
  736. func LoadPrescriptionConfig(dataFile string) *PrescriptionConfig {
  737. var config PrescriptionConfig
  738. _, filename, _, _ := runtime.Caller(1)
  739. datapath := path.Join(path.Dir(filename), dataFile)
  740. config_file, err := os.Open(datapath)
  741. if err != nil {
  742. emit("Failed to open config file '%s': %s\n", datapath, err)
  743. return &config
  744. }
  745. fi, _ := config_file.Stat()
  746. buffer := make([]byte, fi.Size())
  747. _, err = config_file.Read(buffer)
  748. buffer, err = StripComments(buffer) //去掉注释
  749. if err != nil {
  750. emit("Failed to strip comments from json: %s\n", err)
  751. return &config
  752. }
  753. buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
  754. err = json.Unmarshal(buffer, &config) //解析json格式数据
  755. if err != nil {
  756. emit("Failed unmarshalling json: %s\n", err)
  757. return &config
  758. }
  759. return &config
  760. }
  761. func emit(msgfmt string, args ...interface{}) {
  762. log.Printf(msgfmt, args...)
  763. }
  764. func StripComments(data []byte) ([]byte, error) {
  765. data = bytes.Replace(data, []byte("\r"), []byte(""), 0) // Windows
  766. lines := bytes.Split(data, []byte("\n")) //split to muli lines
  767. filtered := make([][]byte, 0)
  768. for _, line := range lines {
  769. match, err := regexp.Match(`^\s*#`, line)
  770. if err != nil {
  771. return nil, err
  772. }
  773. if !match {
  774. filtered = append(filtered, line)
  775. }
  776. }
  777. return bytes.Join(filtered, []byte("\n")), nil
  778. }
  779. func GetDateOfWeek(week_type int) (weekMonday int64) {
  780. thisTime := time.Now()
  781. weekDay := int(thisTime.Weekday())
  782. if weekDay == 0 {
  783. weekDay = 7
  784. }
  785. weekEnd := 7 - weekDay
  786. weekStart := weekEnd - 6
  787. weekTitle := make([]string, 0)
  788. days := make([]string, 0)
  789. for index := weekStart; index <= weekEnd; index++ {
  790. theDay := thisTime.AddDate(0, 0, index)
  791. indexYear, indexMonthTime, indexDay := theDay.Date()
  792. indexMonth := int(indexMonthTime)
  793. indexWeek := strconv.Itoa(indexYear) + "." + strconv.Itoa(indexMonth) + "." + strconv.Itoa(indexDay)
  794. weekTitle = append(weekTitle, indexWeek)
  795. days = append(days, theDay.Format("2006-01-02"))
  796. }
  797. var targetDayStr string
  798. switch week_type {
  799. case 1:
  800. targetDayStr = days[0]
  801. break
  802. case 2:
  803. targetDayStr = days[1]
  804. break
  805. case 3:
  806. targetDayStr = days[2]
  807. break
  808. case 4:
  809. targetDayStr = days[3]
  810. break
  811. case 5:
  812. targetDayStr = days[4]
  813. break
  814. case 6:
  815. targetDayStr = days[5]
  816. break
  817. case 7:
  818. targetDayStr = days[6]
  819. break
  820. }
  821. targetDay, _ := utils.ParseTimeStringToTime("2006-01-02", targetDayStr)
  822. return targetDay.Unix()
  823. }
  824. type Config struct {
  825. Parent_template []*models.VMDoctorAdviceParentTemplate "json:parent_template"
  826. }
  827. func LoadConfig(dataFile string) *Config {
  828. var config Config
  829. _, filename, _, _ := runtime.Caller(1)
  830. datapath := path.Join(path.Dir(filename), dataFile)
  831. config_file, err := os.Open(datapath)
  832. if err != nil {
  833. emit("Failed to open config file '%s': %s\n", datapath, err)
  834. return &config
  835. }
  836. fi, _ := config_file.Stat()
  837. buffer := make([]byte, fi.Size())
  838. _, err = config_file.Read(buffer)
  839. buffer, err = StripComments(buffer) //去掉注释
  840. if err != nil {
  841. emit("Failed to strip comments from json: %s\n", err)
  842. return &config
  843. }
  844. buffer = []byte(os.ExpandEnv(string(buffer))) //特殊
  845. err = json.Unmarshal(buffer, &config) //解析json格式数据
  846. if err != nil {
  847. emit("Failed unmarshalling json: %s\n", err)
  848. return &config
  849. }
  850. return &config
  851. }
  852. func InitEquitMentInformation(org *models.Org) {
  853. //添加设备型号
  854. mode := models.VMDeviceMode{
  855. DeviceMode: "5008S",
  856. Status: 1,
  857. UserOrgId: org.Id,
  858. Ctime: time.Now().Unix(),
  859. Mtime: time.Now().Unix(),
  860. }
  861. service.CreatedDeviceMode(&mode)
  862. deviceMode := models.VMDeviceMode{
  863. DeviceMode: "4008S",
  864. Status: 1,
  865. UserOrgId: org.Id,
  866. Ctime: time.Now().Unix(),
  867. Mtime: time.Now().Unix(),
  868. }
  869. service.CreatedDeviceMode(&deviceMode)
  870. firstDeviceMode, _ := service.GetFirstDeviceMode(org.Id)
  871. //获取机构下对应的第一数据
  872. number, _ := service.GetFirstBedNumber(org.Id)
  873. //添加设备
  874. deviceAddmacher := models.VmDeviceAddmacher{
  875. SerialNumber: "8VSAHE13",
  876. DeviceType: 1,
  877. BedId: number.ID,
  878. DeviceName: "费森尤斯",
  879. UnitType: firstDeviceMode.ID,
  880. MachineStatus: 1,
  881. Status: 1,
  882. UserOrgId: org.Id,
  883. Ctime: time.Now().Unix(),
  884. }
  885. service.CreateDeviceAddMacher(&deviceAddmacher)
  886. macher, _ := service.GetLastMacher(org.Id)
  887. fmt.Print(macher.ID)
  888. treatmentmode := models.VmDeviceTreatmentmode{
  889. MachineId: macher.ID,
  890. Status: 1,
  891. Ctime: time.Now().Unix(),
  892. Mtime: time.Now().Unix(),
  893. UserOrgId: org.Id,
  894. TreateMode: 1,
  895. }
  896. service.CreatedTreateMode(&treatmentmode)
  897. treatmentmodeone := models.VmDeviceTreatmentmode{
  898. MachineId: macher.ID,
  899. Status: 1,
  900. Ctime: time.Now().Unix(),
  901. Mtime: time.Now().Unix(),
  902. UserOrgId: org.Id,
  903. TreateMode: 2,
  904. }
  905. service.CreatedTreateMode(&treatmentmodeone)
  906. treatmentmodetwo := models.VmDeviceTreatmentmode{
  907. MachineId: macher.ID,
  908. Status: 1,
  909. Ctime: time.Now().Unix(),
  910. Mtime: time.Now().Unix(),
  911. UserOrgId: org.Id,
  912. TreateMode: 3,
  913. }
  914. service.CreatedTreateMode(&treatmentmodetwo)
  915. treatmentmodethree := models.VmDeviceTreatmentmode{
  916. MachineId: macher.ID,
  917. Status: 1,
  918. Ctime: time.Now().Unix(),
  919. Mtime: time.Now().Unix(),
  920. UserOrgId: org.Id,
  921. TreateMode: 4,
  922. }
  923. service.CreatedTreateMode(&treatmentmodethree)
  924. treatmentmodefour := models.VmDeviceTreatmentmode{
  925. MachineId: macher.ID,
  926. Status: 1,
  927. Ctime: time.Now().Unix(),
  928. Mtime: time.Now().Unix(),
  929. UserOrgId: org.Id,
  930. TreateMode: 5,
  931. }
  932. service.CreatedTreateMode(&treatmentmodefour)
  933. treatmentmodefive := models.VmDeviceTreatmentmode{
  934. MachineId: macher.ID,
  935. Status: 1,
  936. Ctime: time.Now().Unix(),
  937. Mtime: time.Now().Unix(),
  938. UserOrgId: org.Id,
  939. TreateMode: 12,
  940. }
  941. service.CreatedTreateMode(&treatmentmodefive)
  942. }