1

conf/app.conf

@@ -0,0 +1,186 @@
+appname = IC
+httpport = 9818
+runmode = prod
+
+copyrequestbody = true
+sessionon = true
+sessiongcmaxlifetime = 64800
+
+tokencookiemaxlifetime = 7200
+
+enablexsrf = false
+xsrfkey = 61oETzKXQAGaYdkL5gEmGeJJFuYh7EQnp2XdTP1o
+xsrfexpire = 3600
+
+sms_appId = dcabb3aa7afd402794046ebbbf652bce
+sms_sid = a26cb0ceb3a811ca82143972f4ef38a4
+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
+
+appid = "wx43ad410d9eef426e"
+mchid = "1509573721"
+key = "e4SHrkiZu0pQEwVoGBapDBTf9N1Q6MxV"
+appsecret="61ee2e6268497d5aa9de0b0187c39aea"
+
+[prod]
+httpdomain = https://api.xt.kuyicloud.com
+sso_domain = https://sso.kuyicloud.com
+front_end_domain = "https://xt.kuyicloud.com/#"
+
+readmysqlhost = shengws1.mysql.rds.aliyuncs.com
+readmysqlport = 3306
+readmysqluser = syh
+readmysqlpass = xhPECP2nFObR8aUK
+readmysqlname = sgj_xt
+
+writemysqlhost = shengws1.mysql.rds.aliyuncs.com
+writemysqlport = 3306
+writemysqluser = syh
+writemysqlpass = xhPECP2nFObR8aUK
+writemysqlname = sgj_xt
+
+readremotehost = 219.135.207.166
+readremoteport = 1433
+readremoteuser = lis_xt
+readremotepass = xt2020
+readremotename = digitlab
+
+
+readuserhost = shengws1.mysql.rds.aliyuncs.com
+readuserport = 3306
+readuseruser = syh
+readuserpass = xhPECP2nFObR8aUK
+readusername = sgj_users
+
+writeuserhost = shengws1.mysql.rds.aliyuncs.com
+writeuserport = 3306
+writeuseruser = syh
+writeuserpass = xhPECP2nFObR8aUK
+writeusername = sgj_users
+
+readmiddlehost = shengws1.mysql.rds.aliyuncs.com
+readmiddleport = 3306
+readmiddleuser = syh
+readmiddlepass = xhPECP2nFObR8aUK
+readmiddlename = ky_xt_middle
+
+writemiddlehost = shengws1.mysql.rds.aliyuncs.com
+writemiddleport = 3306
+writemiddleuser = syh
+writemiddlepass = xhPECP2nFObR8aUK
+writemiddlename = ky_xt_middle
+
+backuphost = 120.76.159.131
+backupport = 3306
+backupuser = syh
+backuppass = xhPECP2nFObR8aUK
+backupname = sgj_xt
+
+
+redishost = kuyi6666.redis.rds.aliyuncs.com
+redisport = 6379
+redispasswrod = TZtBW098WId3i27clkpj3q8dnUaVFP
+redisdb = 2
+
+
+
+
+niprocart =  63
+jms = 58
+fistula_needle_set = 65
+fistula_needle_set_16 = 64
+hemoperfusion = 55
+dialyser_sterilised = 12
+filtryzer = 53
+dialyzers = 8
+injector = 81
+bloodlines = 42
+tubingHemodialysis = 30
+package = 82
+aliquid = 83
+
+
+
+[dev]
+httpdomain = http://api.xt.test.sgjyun.com
+sso_domain = https://testsso.sgjyun.com
+front_end_domain = "http://xt.test.sgjyun.com/#"
+
+readmysqlhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+readmysqlport = 3306
+readmysqluser = root
+readmysqlpass = 1Q2W3e4r!@#$
+readmysqlname = sgj_xt
+
+writemysqlhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+writemysqlport = 3306
+writemysqluser = root
+writemysqlpass = 1Q2W3e4r!@#$
+writemysqlname = sgj_xt
+
+readremotehost = 219.135.207.166
+readremoteport = 1433
+readremoteuser = lis_xt
+readremotepass = xt2020
+readremotename = digitlab
+
+
+readuserhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+readuserport = 3306
+readuseruser = root
+readuserpass = 1Q2W3e4r!@#$
+readusername = sgj_users
+
+writeuserhost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+writeuserport = 3306
+writeuseruser = root
+writeuserpass = 1Q2W3e4r!@#$
+writeusername = sgj_users
+
+
+readmiddlehost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+readmiddleport = 3306
+readmiddleuser = root
+readmiddlepass = 1Q2W3e4r!@#$
+readmiddlename = ky_xt_middle
+
+writemiddlehost = rm-wz9rg531npf61q03tro.mysql.rds.aliyuncs.com
+writemiddleport = 3306
+writemiddleuser = root
+writemiddlepass = 1Q2W3e4r!@#$
+writemiddlename = ky_xt_middle
+
+# backuphost = 120.76.159.131
+# backupport = 3306
+# backupuser = syh
+# backuppass = xhPECP2nFObR8aUK
+# backupname = sgj_xt
+
+
+
+
+#redishost = 120.77.235.13
+# redishost = 112.74.16.180
+redishost = 112.74.16.180
+redisport = 6379
+redispasswrod = syh@#$%123456!
+redisdb = 0
+
+
+
+niprocart =  83
+jms = 80
+fistula_needle_set = 81
+fistula_needle_set_16 = 82
+hemoperfusion = 85
+dialyser_sterilised = 84
+filtryzer = 79
+dialyzers = 10000
+injector = 10001
+bloodlines = 10002
+tubingHemodialysis = 10003
+package = 10004
+aliquid = 10005

controllers/base_api_controller.go

@@ -0,0 +1,56 @@
+package controllers
+
+import (
+	_"IC/service"
+	"IC/enums"
+	"github.com/astaxie/beego"
+)
+
+type BaseAPIController struct {
+	beego.Controller
+}
+
+// func (this *BaseAPIController) Prepare() {
+// 	this.BaseController.Prepare()
+// 	beego.Trace("============================================================")
+// 	beego.Trace("session ID: %v", this.Ctx.Input.Cookie("beegosessionID"))
+// 	beego.Trace("session : %v", this.GetSession("info"))
+// 	this.SetSession("info", time.Now().Format("2006/01/02 15:04:05"))
+// 	beego.Trace("============================================================")
+// }
+
+// 输出数据格式化
+/*
+	success json:
+	{
+		"state": 1,
+		"code": 0,
+		"data": json,
+	}
+
+	fail json:
+	{
+		"state": 0,
+		"code": int,
+		"msg": string,
+	}
+*/
+func (this *BaseAPIController) ServeSuccessJSON(data map[string]interface{}) {
+	this.Data["json"] = enums.MakeSuccessResponseJSON(data)
+	this.ServeJSON()
+}
+
+func (this *BaseAPIController) ServeFailJSONWithSGJErrorCode(code int) {
+	this.Data["json"] = enums.MakeFailResponseJSONWithSGJErrorCode(code)
+	this.ServeJSON()
+}
+
+func (this *BaseAPIController) ServeFailJSONWithSGJError(err *enums.SGJError) {
+	this.Data["json"] = enums.MakeFailResponseJSONWithSGJError(err)
+	this.ServeJSON()
+}
+
+func (this *BaseAPIController) ServeFailJsonSend(code int, msg string) {
+	this.Data["json"] = enums.MakeFailResponseJSON(msg, code)
+	this.ServeJSON()
+}

controllers/default.go

@@ -0,0 +1,15 @@
+package controllers
+
+import (
+	"github.com/astaxie/beego"
+)
+
+type MainController struct {
+	beego.Controller
+}
+
+func (c *MainController) Get() {
+	c.Data["Website"] = "beego.me"
+	c.Data["Email"] = "astaxie@gmail.com"
+	c.TplName = "index.tpl"
+}

controllers/lis.go

@@ -0,0 +1,398 @@
+package controllers
+
+import (
+	"IC/service"
+	"IC/enums"
+	_"strconv"
+	"encoding/json"
+	"IC/models"
+	"IC/utils"
+	"time"
+	_"fmt"
+	_"github.com/jinzhu/gorm"
+	_"github.com/astaxie/beego"
+)
+
+// LisController operations for Lis
+type LisController struct {
+	BaseAPIController
+}
+
+func (c *LisController) SyncAdvice(){
+	// 获取备份库里所有的医嘱信息
+	advices,_ := service.GetAllAdvice()
+	for _,advice := range advices {
+		// if index > 50 {
+		// 	break
+		// }
+		tempAdvice := models.DoctorAdvice{
+			ID			: advice.ID,
+			Checker		: advice.Checker,
+			CheckTime	: advice.CheckTime,
+			CheckState	: advice.CheckState,
+		}
+		service.SyncAdvice(&tempAdvice)
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+
+}
+
+func (c *LisController) FiledConfigSys(){
+	orgs,_ := service.GetfiledConfigOrg()
+	sysFiledConfig,_ := service.GetfiledConfigSys()
+
+	if len(orgs) > 0 {
+		for _,org := range orgs {
+			for _,filed := range sysFiledConfig {
+				filedConfig,_ := service.GetfiledConfigByOrgId(org.OrgId,filed.Module,filed.FiledName)	
+				if filedConfig.ID > 0 {
+					continue
+				} else {
+					tempfiled := models.FiledConfig {
+						OrgId       : org.OrgId,
+						Module      : filed.Module,
+						FiledName   : filed.FiledName,
+						FiledNameCn : filed.FiledNameCn,
+						IsShow      : 2,
+					}
+					service.CreatefiledConfig(&tempfiled)
+				}
+			}
+		}
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncToBase() {
+	org_id, _:= c.GetInt64("org_id",0) 
+	if org_id <= 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+	
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references,_ := service.GetSyncInspectionReferenceByOrgId(org_id)
+	inspections,_ := service.GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _,inspection_reference := range inspection_references {
+			service.SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _,inspection := range inspections {
+			service.SyncInspection(&inspection)
+		}
+	}
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) GetList() {
+	org_id, _ := c.GetInt64("org_id", 0)
+	if org_id <= 0 {
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeParamWrong)
+		return
+	}
+
+	// 第一步：根据机构id获取对应机构所有病人的his_user_id
+	patients,patientError := service.GetHisUserIdByOrgID(org_id)
+	if patientError != nil {
+		utils.ErrorLog("获取用户His_user_id信息失败:%v", patientError)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return
+	}
+
+	patientStr:= make([]interface{},0)
+	if len(patients) > 0 {
+	// 第二步：根据病人的his_user_id来查询上次同步时间	
+		for _ , patient := range patients {
+			if len(patient.HisUserId) <= 0 {
+				continue
+			}
+			// if patient.SelectType != 1 {
+			// 	continue
+			// }
+
+			syncLastInfo,_ := service.GetSyncTimeByOrgID(org_id,patient.HisUserId)
+			var sync_time int64
+			if syncLastInfo.ID > 0 {
+				sync_time = syncLastInfo.SyncTime
+			} else {
+				inspectionLastInfo,_ := service.GetInspectionLastInfoByOrgID(org_id,patient.HisUserId)
+				if inspectionLastInfo.ID > 0 {
+					sync_time = inspectionLastInfo.CreatedTime
+				} else {
+					sync_time = 1609430400
+				}
+			}
+
+			syncTimes := time.Unix(sync_time,0).Format("2006-01-02 15:04")
+			utils.InfoLog("syncTimes:%v",syncTimes)
+
+			// 第三步：跟进上次同步时间和指定的his_user_id，获取上次同步到现在指定人的检验检查记录
+			resultList, _ := service.GetListByHisUserID(patient.HisUserId,syncTimes,patient.SelectType)
+			var syncInfo models.MiddleSyncInfo
+	
+			if len(resultList) > 0 {
+				// 如果有数据，则把同步过来的详情插入一条数据到同步详情表中
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.HisUserId
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "同步成功"
+				syncInfo.SyncTotalNum = int64(len(resultList))
+				syncInfo.SyncSuccessNum = 0
+				SyncInfos,_ := json.Marshal(resultList)
+				syncInfo.SyncInfo = string(SyncInfos)
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				err := service.CreateSyncInfo(&syncInfo)
+				if err != nil {
+					utils.ErrorLog("创建同步信息失败:%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+			} else {
+				// 如果没有数据，则插入一条数据到同步详情表中
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.HisUserId
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "该患者这个时间段没有任何检验检查数据"
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				err := service.CreateSyncInfo(&syncInfo)
+				if err != nil {
+					utils.ErrorLog("创建同步信息失败:%v", err)
+					c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+					return
+				}
+				// utils.InfoLog("同步信息详情:%v",syncInfo)
+				c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+				continue 
+			}
+
+			// 第四部：将同步过来的数据插入到中间库对应的表
+			syncSuccessNum := 0
+			for _, result := range resultList {
+				utils.ErrorLog("result:%v", result)
+				if (result.HisUserId == patient.HisUserId) || (result.PatientName ==  patient.HisUserId) {
+					patientId := patient.XtPatientId
+					if patientId > 0 {
+						inspection_reference,inspection,_ := service.Sync(result,org_id,patientId)
+						if (inspection_reference.ID > 0 || inspection.ID > 0 ) {
+							syncSuccessNum++
+						}
+					}
+				}
+			}
+			syncInfo.SyncSuccessNum = int64(syncSuccessNum)
+			service.UpdateSyncInfo(&syncInfo)
+
+			// patientStr = append(patientStr,patient.HisUserId)
+			// utils.InfoLog("patientStr:%v",patientStr)	
+		}
+	} else {
+		var syncInfo models.MiddleSyncInfo
+		// 如果没有数据，则插入一条数据到同步详情表中
+		syncInfo.OrgId = org_id
+		syncInfo.SyncTime = time.Now().Unix()
+		syncInfo.SyncResultType = 0
+		syncInfo.SyncRsultRemark = "该机构没有对应的his_user_id"
+		syncInfo.CreateTime = time.Now().Unix()
+		syncInfo.UpdateTime = time.Now().Unix()
+
+		err := service.CreateSyncInfo(&syncInfo)
+		if err != nil {
+			utils.ErrorLog("创建同步信息失败:%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		utils.InfoLog("同步信息详情:%v",syncInfo)
+		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+		return 
+	}
+
+	utils.InfoLog("patientStr:%v",patientStr) 
+
+
+	// // 第一步：根据机构id获取上次同步时间
+	// syncLastInfo,_ := service.GetSyncTimeByOrgID(org_id)
+	// var sync_time int64
+	// if syncLastInfo.ID > 0 {
+	// 	sync_time = syncLastInfo.SyncTime
+	// } else {
+	// 	sync_time = 0
+	// }
+
+	// syncTimes := time.Unix(sync_time,0).Format("2006-01-02 15:04")
+	// utils.InfoLog("syncTimes:%v",syncTimes)
+
+	// // 第二步：根据机构id获取对应机构所有病人的his_user_id
+	// patients,patientError := service.GetHisUserIdByOrgID(org_id)
+	// if patientError != nil {
+	// 	utils.ErrorLog("获取用户His_user_id信息失败:%v", patientError)
+	// 	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 	return
+	// }
+
+	// patientStr:= make([]interface{},0)
+	// if len(patients) > 0 {
+	// 	for _ , patient := range patients {
+	// 		patientStr = append(patientStr,patient.HisUserId)
+	// 		utils.InfoLog("patientStr:%v",patientStr)	
+	// 	}
+	// } else {
+	// 	// 如果没有数据，则插入一条数据到同步详情表中
+	// 	syncInfo.OrgId = org_id
+	// 	syncInfo.SyncTime = time.Now().Unix()
+	// 	syncInfo.SyncResultType = 0
+	// 	syncInfo.SyncRsultRemark = "该机构没有对应的his_user_id"
+	// 	syncInfo.CreateTime = time.Now().Unix()
+	// 	syncInfo.UpdateTime = time.Now().Unix()
+
+	// 	err := service.CreateSyncInfo(&syncInfo)
+	// 	if err != nil {
+	// 		utils.ErrorLog("创建同步信息失败:%v", err)
+	// 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 		return
+	// 	}
+	// 	utils.InfoLog("同步信息详情:%v",syncInfo)
+	// 	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 	return 
+	// }
+
+	// utils.InfoLog("patientStr:%v",patientStr) 
+
+	// // 第三步：跟进上次同步时间和指定的his_user_id，获取上次同步到现在指定人的检验检查记录
+	// resultList, _ := service.GetList(patientStr,syncTimes)
+	
+	// if len(resultList) > 0 {
+	// 	// 如果有数据，则把同步过来的详情插入一条数据到同步详情表中
+	// 	syncInfo.OrgId = org_id
+	// 	syncInfo.SyncTime = time.Now().Unix()
+	// 	syncInfo.SyncResultType = 1
+	// 	syncInfo.SyncRsultRemark = "同步成功"
+	// 	syncInfo.SyncTotalNum = int64(len(resultList))
+	// 	syncInfo.SyncSuccessNum = 0
+	// 	SyncInfos,_ := json.Marshal(resultList)
+	// 	syncInfo.SyncInfo = string(SyncInfos)
+	// 	syncInfo.CreateTime = time.Now().Unix()
+	// 	syncInfo.UpdateTime = time.Now().Unix()
+
+	// 	err := service.CreateSyncInfo(&syncInfo)
+	// 	if err != nil {
+	// 		utils.ErrorLog("创建同步信息失败:%v", err)
+	// 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 		return
+	// 	}
+	// } else {
+	// 	// 如果没有数据，则插入一条数据到同步详情表中
+	// 	syncInfo.OrgId = org_id
+	// 	syncInfo.SyncTime = time.Now().Unix()
+	// 	syncInfo.SyncResultType = 1
+	// 	syncInfo.SyncRsultRemark = "该机构这个时间段没有任何检验检查数据"
+	// 	syncInfo.CreateTime = time.Now().Unix()
+	// 	syncInfo.UpdateTime = time.Now().Unix()
+
+	// 	err := service.CreateSyncInfo(&syncInfo)
+	// 	if err != nil {
+	// 		utils.ErrorLog("创建同步信息失败:%v", err)
+	// 		c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 		return
+	// 	}
+	// 	// utils.InfoLog("同步信息详情:%v",syncInfo)
+	// 	c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+	// 	return 
+	// }
+
+	// // 第四部：将同步过来的数据插入到中间库对应的表
+	// syncSuccessNum := 0
+	// for _, result := range resultList {
+	// 	patientId := int64(0)
+	// 	for _ , patientInfo := range patients {
+	// 		if result.HisUserId == patientInfo.HisUserId {
+	// 			patientId = patientInfo.XtPatientId
+	// 			break
+	// 		}
+	// 	}
+	// 	if patientId > 0 {
+	// 		inspection_reference,inspection,_ := service.Sync(result,org_id,patientId)
+	// 		if (inspection_reference.ID > 0 || inspection.ID > 0 ) {
+	// 			syncSuccessNum++
+	// 		}
+	// 	}
+	// }
+	// syncInfo.SyncSuccessNum = int64(syncSuccessNum)
+	// service.UpdateSyncInfo(&syncInfo)
+
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": patients,
+	})
+	return
+
+}
+
+func (c *LisController) SyncLgth(){
+	service.SyncLisLgty()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncYstx(){
+	service.SyncLisYstx()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncGzjhyz(){
+	service.SyncGzjhyz()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncGzjhLis(){
+	service.SyncGzjhLis()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncHbJldyyz(){
+	service.SyncHbJldyyz()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *LisController) SyncHbJldyLis(){
+	service.SyncHbdyLis()
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}

enums/error_code.go

@@ -0,0 +1,401 @@
+package enums
+
+import "IC/utils"
+
+const ( // ErrorCode
+	// 登录注册错误 6000+
+	ErrorCodeLoginTimeout                   = 6001
+	ErrorCodeNotLogin                       = 6002
+	ErrorCodePermissionDenied               = 6003
+	ErrorCodeMobileRegistered               = 6004
+	ErrorCodePasswordEmpty                  = 6005
+	ErrorCodeVerificationCodeWrong          = 6006
+	ErrorCodeRegisterFail                   = 6007
+	ErrorCodeInvalidToken                   = 6008
+	ErrorCodeAccountOrPasswordWrong         = 6009
+	ErrorCodeMissingOrg                     = 6010
+	ErrorCodeMissingOrgApp                  = 6011
+	ErrorCodeAccountOrVerCodeWrong          = 6012
+	ErrorCodeMobileNotExit                  = 6013
+	ErrorCodeUserNotExist                   = 6014
+	ErrorCodeUserWasForbidden               = 6015
+	ErrorCodeNeverCreateTypeApp             = 6016
+	ErrorCodeContactSuperAdminCreateTypeApp = 6017
+
+	// 数据验证错误 7000+
+	ErrorCodeMobileFormat     = 7001
+	ErrorCodeTelphoneFormat   = 7002
+	ErrorCodeParamWrong       = 7003
+	ErrorCodeParamFormatWrong = 7004
+
+	// 数据库操作错误 8000+
+	ErrorCodeDBCreate         = 8001
+	ErrorCodeDBUpdate         = 8002
+	ErrorCodeDBDelete         = 8003
+	ErrorCodeDBSelectNoResult = 8004
+	ErrorCodeDataException    = 8005
+
+	// 业务逻辑操作错误 9000+
+	ErrorCodeRoleNotExist           = 9001
+	ErrorCodeAdminUserNotExist      = 9002
+	ErrorCodeMobileDidUsedInApp     = 9003
+	ErrorCodeMissingUserName        = 9004
+	ErrorCodeOldPasswordWrong       = 9005
+	ErrorCodeCannotRemoveRole       = 9006
+	ErrorCodeRoleMobileIsSuperAdmin = 9007
+
+	ErrorCodeGetQiniuUpToken                = 1001
+	ErrorCodeCreatePatient                  = 1002
+	ErrorCodeDialysisNoExist                = 1003
+	ErrorCodeIdCardNoExist                  = 1004
+	ErrorCodePatientNoExist                 = 1005
+	ErrorCodeUpdatePatient                  = 1006
+	ErrorCodeDialysisSolutionExist          = 1007
+	ErrorCodeDialysisSolutionCreate         = 1008
+	ErrorCodeDialysisSolutionUpdate         = 1009
+	ErrorCodeDialysisSolutionNotExist       = 1010
+	ErrorCodeParentDialysisSolutionNotExist = 1011
+	ErrorCodeAlReadyHadChildSolution        = 1012
+	ErrorCodeCanntCreateChildChildSolution  = 1013
+	ErrorCodeDialysisSolutionUsed           = 1014
+	ErrorCodeCreateDryWeightFail            = 1015
+	ErrorCodeCreateDoctorAdviceFail         = 1016
+	ErrorCodeDoctorAdviceNotExist           = 1017
+	ErrorCodeUpdateDoctorAdviceFail         = 1018
+	ErrorCodeLongTimeAdviceNotCanntEdit     = 1019
+	ErrorCodeAdviceStoped                   = 1020
+	ErrorCodeParentAdviceNotExist           = 1021
+	ErrorCodeStopAdviceFail                 = 1022
+	ErrorCodeDeleteAdviceFail               = 1023
+	ErrorCodeDialysisSolutionDelete         = 1024
+	ErrorCodeDeviceNumberNotTheZone         = 1025
+	ErrorCodeCreateScheduleFail             = 1026
+	ErrorCodeCantSetScheduleAgainOneDay     = 1027
+	ErrorCodeCantSetScheduleBeforeNow       = 1028
+	ErrorCodeScheduleNotExist               = 1029
+	ErrorCodeDeleteScheduleFail             = 1030
+	ErrorCodeChangeScheduleFail             = 1031
+	ErrorCodePatientPhoneUsed               = 1032
+	ErrorCodeAdviceExced                    = 1033
+	ErrorCodeAdviceChecked                  = 1034
+	ErrorCodePointScheduleExist             = 1035
+	ErrorCodeExceAndCheckNotOneUser         = 1036
+	ErrorCodeCanotEditOtherAdvice           = 1037
+	ErrorCodeEditLapsetoFail                = 1038
+	ErrorCodeAdviceCheckBeforeExce          = 1039
+	ErrorCodeAdviceExceBeforeStart          = 1040
+	ErrorCodeDelScheduleFailByDialysis      = 1041
+	ErrorCodeNotSelectLapsetoType           = 1042
+	ErrorCodeNotSelectLapsetoTime           = 1043
+
+	ErrorCodeInspectionDateExit    = 1201
+	ErrorCodeInspectionAddFail     = 1202
+	ErrorCodeInspectionEditFail    = 1204
+	ErrorCodeInspectionDateNotExit = 1203
+	ErrorCodeInspectionDeleteFail  = 1205
+
+	ErrorCodeMonitorCreate                  = 1128
+	ErrorCodeMonitorNotExist                = 1129
+	ErrorCodeMonitorUpdate                  = 1130
+	ErrorDialysisOrderNoStart               = 1132
+	ErrorDialysisOrderNoEND                 = 1133
+	ErrorDialysisOrderRepeatStart           = 1134
+	ErrorDialysisOrderRepeatBed             = 1136
+	ErrorCodeDialysisPermissionDeniedModify = 1135
+
+	ErrorCodeNotSubscibe       = 4003
+	ErrorCodeServeNotExist     = 4004
+	ErrorCodeInvoiceExist      = 4005
+	ErrorCodeApplyInvoiceFail  = 4006
+	ErrorCodeHetongHad         = 4007
+	ErrorCodeCreateHetongFail  = 4008
+	ErrorCodePatientReachLimit = 4009
+
+	ErrorCodeDeviceZoneNotExist                      = 9021
+	ErrorCodeDeviceZoneNameRepeat                    = 9022
+	ErrorCodeDeviceGroupNotExist                     = 9023
+	ErrorCodeDeviceGroupNameRepeat                   = 9024
+	ErrorCodeDeviceNumberNotExist                    = 9025
+	ErrorCodeDeviceNumberRepeat                      = 9026
+	ErrorCodeDeviceNotExist                          = 9027
+	ErrorCodeDeviceZoneCannotDisable                 = 9028
+	ErrorCodeDeviceNumberCannotDisableCuzDevice      = 9029
+	ErrorCodeDeviceNumberCannotDisableCuzSchedule    = 9030
+	ErrorCodeDeviceNumberCannotDisableCuzSchTemplate = 9031
+
+	ErrorCommitFail = 90000
+
+	ErrorCodeCreateStockInFail = 20001
+
+	ErrorCodeScheduleTemplateNotExist = 10001
+
+	ErrorCodeSystemError  = 6666
+	ErrorCodeProductError = 6667
+	ErrorCodeFieldExist   = 100001
+	ErrorCodeCreateConfig = 100002
+	ErrorCodeUpdateConfig = 100003
+
+	ErrorCodeDoubleCheckWrong     = 200003
+	ErrorCodeDoubleCheckUserWrong = 200004
+	ErrorCodeGoodNoStockInError   = 200005
+	ErrorCodeCancelStockFail      = 200006
+	ErrorCodeDeleteGoodTypeFail   = 200007
+	ErrorCodeDeleteGoodInfoFail   = 200008
+	ErrorCodeDeleteFail           = 200009
+
+	ErrorCodeKeyFail                 = 200010
+	ErrorCodeDeleteStockInRecordFail = 200011
+	ErrorCodeNameWrong               = 200012
+
+	ErrorCodeParamEmptyWrong       = 200013
+	ErrorCodeParamAdviceEmptyWrong = 200014
+
+	ErrorCodeParamTemplateNOEXISTWrong = 200015
+
+	ErrorCodeDeleteDealerWrong       = 200016
+	ErrorCodeDeleteManufacturerWrong = 200017
+	ErrorCodeGoodTypeNameExistError  = 200018
+	ErrorCodeGoodInfoNameExistError  = 200019
+
+	ErrorCodePrescriptionPermissionDeniedModify = 200020
+
+	ErrorCodeAdvicePermissionDeniedModify = 200021
+	ErrorCodePrescriptionException        = 200022
+
+	ErrorCodeNotDocking = 200023
+
+	ErrorCodeAdviceTypeWrong = 200024
+
+	ErrorCodeCreateAdvice = 200025
+
+	ErrorCodePatientDialysisOrder = 20026
+	ErrorSchedualcRepeatBed       = 20027
+
+	ErrorCodeChangeMode         = 20028
+	ErrorCodeChangeDeviceNumber = 20029
+
+	ErrorCodeHisIdExist = 20030
+
+	ErrorCodePreExist = 20031
+)
+
+var ErrCodeMsgs = map[int]string{
+	// 登录注册错误
+	ErrorCodeLoginTimeout:                   "登录超时",
+	ErrorCodeNotLogin:                       "未登录",
+	ErrorCodePermissionDenied:               "权限不足",
+	ErrorCodeMobileRegistered:               "手机号已被注册",
+	ErrorCodePasswordEmpty:                  "密码为空",
+	ErrorCodeVerificationCodeWrong:          "验证码错误",
+	ErrorCodeRegisterFail:                   "注册失败",
+	ErrorCodeInvalidToken:                   "令牌无效",
+	ErrorCodeAccountOrPasswordWrong:         "账号或密码错误",
+	ErrorCodeMissingOrg:                     "未创建机构",
+	ErrorCodeMissingOrgApp:                  "未创建任何应用",
+	ErrorCodeAccountOrVerCodeWrong:          "账号或验证码错误",
+	ErrorCodeMobileNotExit:                  "手机号不存在",
+	ErrorCodeUserNotExist:                   "用户不存在",
+	ErrorCodeUserWasForbidden:               "该用户被禁用",
+	ErrorCodeNeverCreateTypeApp:             "未创建此种应用",
+	ErrorCodeContactSuperAdminCreateTypeApp: "请联系超级管理员开通此种应用",
+
+	// 数据验证错误
+	ErrorCodeMobileFormat:     "手机号格式错误",
+	ErrorCodeTelphoneFormat:   "电话格式错误",
+	ErrorCodeParamWrong:       "参数错误",
+	ErrorCodeParamFormatWrong: "参数格式错误",
+
+	// 数据库操作错误
+	ErrorCodeDBCreate:         "数据库创建出错",
+	ErrorCodeDBUpdate:         "数据库更新出错",
+	ErrorCodeDBDelete:         "数据库删除出错",
+	ErrorCodeDBSelectNoResult: "查询无结果",
+	ErrorCodeDataException:    "数据异常",
+
+	// 业务逻辑操作错误
+	ErrorCodeRoleNotExist:           "角色不存在",
+	ErrorCodeAdminUserNotExist:      "管理员不存在",
+	ErrorCodeMobileDidUsedInApp:     "该手机号已在该应用中被注册为管理员",
+	ErrorCodeMissingUserName:        "缺少用户名",
+	ErrorCodeOldPasswordWrong:       "原密码不正确",
+	ErrorCodeCannotRemoveRole:       "该角色下存在用户，不能删除该角色",
+	ErrorCodeRoleMobileIsSuperAdmin: "该手机号已注册为超级管理员",
+
+	ErrorCodeGetQiniuUpToken: "获取七牛uptoken失败",
+	ErrorCodeCreatePatient:   "创建患者失败",
+	ErrorCodeDialysisNoExist: "患者透析号重复！",
+	ErrorCodeIdCardNoExist:   "身份证号重复！",
+	ErrorCodePatientNoExist:  "患者信息不存在！",
+	ErrorCodeUpdatePatient:   "修改患者信息失败",
+
+	ErrorCodeDialysisSolutionExist:          "该处方已经存在",
+	ErrorCodeDialysisSolutionCreate:         "创建处方失败",
+	ErrorCodeDialysisSolutionUpdate:         "修改处方失败",
+	ErrorCodeDialysisSolutionNotExist:       "该处方不存在",
+	ErrorCodeParentDialysisSolutionNotExist: "上级处方不存在",
+	ErrorCodeAlReadyHadChildSolution:        "所选处方已经存在子方案",
+	ErrorCodeCanntCreateChildChildSolution:  "子方案不能添加子方案",
+	ErrorCodeDialysisSolutionUsed:           "处方已被使用，不能删除",
+	ErrorCodeCreateDryWeightFail:            "添加干体重失败",
+	ErrorCodeCreateDoctorAdviceFail:         "添加医嘱失败",
+	ErrorCodeUpdateDoctorAdviceFail:         "修改医嘱信息失败",
+	ErrorCodeDoctorAdviceNotExist:           "医嘱不存在",
+	ErrorCodeLongTimeAdviceNotCanntEdit:     "长期医嘱不能修改！",
+	ErrorCodeAdviceStoped:                   "所选医嘱已停止",
+	ErrorCodeParentAdviceNotExist:           "上级医嘱不存在",
+	ErrorCodeDeleteAdviceFail:               "删除医嘱失败",
+	ErrorCodeStopAdviceFail:                 "停止医嘱失败",
+	ErrorCodeDialysisSolutionDelete:         "删除方案失败",
+	ErrorCodeDeviceNumberNotTheZone:         "所选机号不在选择分区中",
+	ErrorCodeCreateScheduleFail:             "添加排班失败",
+	ErrorCodeCantSetScheduleAgainOneDay:     "同一天不可有两次排班",
+	ErrorCodeCantSetScheduleBeforeNow:       "不能给今天之前的日期排班",
+	ErrorCodeScheduleNotExist:               "排班不存在",
+	ErrorCodePointScheduleExist:             "所先位置排班已经存在",
+	ErrorCodeDeleteScheduleFail:             "取消排班失败",
+	ErrorCodeChangeScheduleFail:             "修改排班失败",
+	ErrorCodePatientPhoneUsed:               "手机号已经存在",
+	ErrorCodeAdviceExced:                    "医嘱已经执行",
+	ErrorCodeAdviceCheckBeforeExce:          "核对医嘱不能在执行医嘱之前",
+	ErrorCodeAdviceExceBeforeStart:          "执行医嘱不能在开始之前",
+	ErrorCodeAdviceChecked:                  "医嘱已经核对",
+	ErrorCodeExceAndCheckNotOneUser:         "核对与执行不能是同一人",
+	ErrorCodeCanotEditOtherAdvice:           "不能修改非本人添加的医嘱",
+	ErrorCodeEditLapsetoFail:                "转归失败",
+	ErrorCodeDelScheduleFailByDialysis:      "已经上机透析，不能取消排班",
+	ErrorCodeNotSelectLapsetoType:           "请选择转归状态",
+	ErrorCodeNotSelectLapsetoTime:           "请选择转归时间",
+
+	ErrorCodeInspectionDateExit:    "当天已经存在检验检查记录",
+	ErrorCodeInspectionAddFail:     "添加记录失败",
+	ErrorCodeInspectionDateNotExit: "当天不存在检验检查记录",
+	ErrorCodeInspectionEditFail:    "修改记录失败",
+	ErrorCodeInspectionDeleteFail:  "删除记录失败",
+
+	ErrorCodeDeviceZoneNotExist:                      "设备分区不存在",
+	ErrorCodeDeviceZoneNameRepeat:                    "该分区名已存在",
+	ErrorCodeDeviceGroupNotExist:                     "设备分组不存在",
+	ErrorCodeDeviceGroupNameRepeat:                   "该分组名已存在",
+	ErrorCodeDeviceNumberNotExist:                    "机号不存在",
+	ErrorCodeDeviceNumberRepeat:                      "该机号已存在",
+	ErrorCodeDeviceNotExist:                          "该设备不存在",
+	ErrorCodeDeviceZoneCannotDisable:                 "该分区存在床位号，不能删除",
+	ErrorCodeDeviceNumberCannotDisableCuzDevice:      "该床位存在设备，不能删除",
+	ErrorCodeDeviceNumberCannotDisableCuzSchedule:    "该床位尚有排班安排，不能删除",
+	ErrorCodeDeviceNumberCannotDisableCuzSchTemplate: "排班模板在该床位尚有排班安排，不能删除",
+
+	ErrorCodeNotSubscibe:       "没有订阅服务或服务已过期，请先购买服务！",
+	ErrorCodeServeNotExist:     "服务订单不存在！",
+	ErrorCodeInvoiceExist:      "已经申请了发票！",
+	ErrorCodeApplyInvoiceFail:  "申请发票失败！",
+	ErrorCodeHetongHad:         "合同已经存在！",
+	ErrorCodeCreateHetongFail:  "合同创建失败",
+	ErrorCodePatientReachLimit: "患者数已达到当前服务版本病人数，需要升级到更高的版本",
+
+	ErrorCodeMonitorCreate:                  "创建监测失败",
+	ErrorCodeMonitorNotExist:                "监测记录不存在",
+	ErrorCodeMonitorUpdate:                  "修改监测失败",
+	ErrorCodeDialysisPermissionDeniedModify: "您没有权限修改其他医护的数据！",
+
+	ErrorDialysisOrderNoStart:     "尚未上机，无法执行下机操作",
+	ErrorDialysisOrderNoEND:       "已处于下机状态",
+	ErrorDialysisOrderRepeatStart: "已上机",
+	ErrorDialysisOrderRepeatBed:   "该床位已有患者上机,请选择其他床位",
+	//ErrorCodeScheduleTemplateNotExist: "排班模板不存在",
+
+	ErrorCodeSystemError:              "系统异常",
+	ErrorCodeProductError:             "该服务商品已丢失",
+	ErrorCodeScheduleTemplateNotExist: "排班模板不存在",
+
+	ErrorCodeCreateStockInFail: "入库失败",
+	//ErrorCodeSystemError:  "系统异常",
+	//ErrorCodeProductError: "该服务商品已丢失",
+	ErrorCodeFieldExist:   "配置字段已存在",
+	ErrorCodeCreateConfig: "创建配置失败",
+	ErrorCodeUpdateConfig: "修改配置失败",
+
+	ErrorCommitFail:               "提交失败",
+	ErrorCodeDoubleCheckWrong:     "核对已完成, 无法再次提交",
+	ErrorCodeDoubleCheckUserWrong: "你已完成核对，不能重复核对",
+	ErrorCodeGoodNoStockInError:   "该商品尚未入库",
+
+	ErrorCodeCancelStockFail:    "出库退库失败",
+	ErrorCodeDeleteGoodTypeFail: "该类型存在商品信息,无法删除",
+	ErrorCodeDeleteGoodInfoFail: "该商品已经入库无法删除",
+
+	ErrorCodeDeleteFail: "删除失败",
+
+	ErrorCodeKeyFail:                 "关键字不能为空",
+	ErrorCodeDeleteStockInRecordFail: "该记录已经有出库或退货操作,无法删除",
+	ErrorCodeNameWrong:               "该模版名字已存在",
+	ErrorCodeParamEmptyWrong:         "模版名称不能为空",
+	ErrorCodeParamAdviceEmptyWrong:   "医嘱名称不能为空",
+
+	ErrorCodeDeleteDealerWrong:       "该经销商所属商品已入库无法删除",
+	ErrorCodeDeleteManufacturerWrong: "该厂商所属商品已入库无法删除",
+	ErrorCodeGoodTypeNameExistError:  "该商品类型名字已存在",
+	ErrorCodeGoodInfoNameExistError:  "该规格名称名字已存在",
+
+	ErrorCodePrescriptionPermissionDeniedModify: "您没有权限修改透析处方数据",
+	ErrorCodeAdvicePermissionDeniedModify:       "您没有权限添加医嘱",
+	ErrorCodePrescriptionException:              "上机失败,请先开处方",
+	ErrorCodeNotDocking:                         "该地区尚未对接",
+
+	ErrorCodeAdviceTypeWrong:      "请选择医嘱模版类型",
+	ErrorCodeCreateAdvice:         "你没有权限开医嘱",
+	ErrorCodePatientDialysisOrder: "该病人已经上机,无法临时排班",
+	ErrorSchedualcRepeatBed:       "该床位已经有人排班,无法临时排班",
+
+	ErrorCodeChangeMode:         "该患者今天已上机治疗，请在透析记录中进行调整透析模式",
+	ErrorCodeChangeDeviceNumber: "该患者今天已上机治疗，请在透析记录中进行调整机号",
+
+	ErrorCodeHisIdExist: "该his_id已被占用,请重新输入",
+
+	ErrorCodePreExist: "没有该权限",
+}
+
+type SGJError struct {
+	Code int
+}
+
+func (e *SGJError) Error() string {
+	value, ok := ErrCodeMsgs[e.Code]
+	if ok {
+		return value
+	} else {
+		return "未知错误"
+	}
+}
+
+func MakeSuccessResponseJSON(data map[string]interface{}) map[string]interface{} {
+	json := make(map[string]interface{})
+	if data != nil {
+		json["data"] = data
+	} else {
+		json["data"] = make(map[string]interface{})
+	}
+	json["state"] = 1
+	json["code"] = 0
+	return json
+}
+
+func MakeFailResponseJSON(errMsg string, errCode int) map[string]interface{} {
+	json := make(map[string]interface{})
+	json["msg"] = errMsg
+	json["code"] = errCode
+	json["state"] = 0
+	return json
+}
+
+func MakeFailResponseJSONWithSGJError(err *SGJError) map[string]interface{} {
+	if err == nil {
+		utils.WarningLog("MakeFailResponseJSONWithSGJError 参数err 不能为空")
+		return nil
+	}
+	return MakeFailResponseJSON(err.Error(), err.Code)
+}
+
+func MakeFailResponseJSONWithSGJErrorCode(code int) map[string]interface{} {
+	err := &SGJError{Code: code}
+	return MakeFailResponseJSON(err.Error(), err.Code)
+}

main.go

@@ -0,0 +1,17 @@
+package main
+
+import (
+	_ "IC/routers"
+	"IC/service"
+	"github.com/astaxie/beego"
+)
+
+func init() {
+	service.ConnectDB()
+}
+
+func main() {
+	service.BeginAutoSyncLis()
+	beego.Run()
+}
+

models/lis_model.go

@@ -0,0 +1,367 @@
+package models
+
+type DoctorAdvice struct {
+	ID                    int64           `gorm:"column:id" json:"id" form:"id"`
+	GroupNo               int64           `gorm:"column:groupno" json:"groupno" form:"groupno"`
+	UserOrgId             int64           `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId             int64           `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	AdviceType            int64           `gorm:"column:advice_type" json:"advice_type" form:"advice_type"`
+	AdviceDate            int64           `gorm:"column:advice_date" json:"advice_date" form:"advice_date"`
+	StartTime             int64           `gorm:"column:start_time" json:"start_time" form:"start_time"`
+	AdviceName            string          `gorm:"column:advice_name" json:"advice_name" form:"advice_name"`
+	AdviceDesc            string          `gorm:"column:advice_desc" json:"advice_desc" form:"advice_desc"`
+	ReminderDate          int64           `gorm:"column:reminder_date" json:"reminder_date" form:"reminder_date"`
+	SingleDose            float64         `gorm:"column:single_dose" json:"single_dose" form:"single_dose"`
+	SingleDoseUnit        string          `gorm:"column:single_dose_unit" json:"single_dose_unit" form:"single_dose_unit"`
+	DrugSpec              float64         `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
+	DrugSpecUnit          string          `gorm:"column:drug_spec_unit" json:"drug_spec_unit" form:"drug_spec_unit"`
+	PrescribingNumber     float64         `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
+	PrescribingNumberUnit string          `gorm:"column:prescribing_number_unit" json:"prescribing_number_unit" form:"prescribing_number_unit"`
+	DeliveryWay           string          `gorm:"column:delivery_way" json:"delivery_way" form:"delivery_way"`
+	ExecutionFrequency    string          `gorm:"column:execution_frequency" json:"execution_frequency" form:"execution_frequency"`
+	AdviceDoctor          int64           `gorm:"column:advice_doctor" json:"advice_doctor" form:"advice_doctor"`
+	Status                int64           `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime           int64           `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime           int64           `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	AdviceAffirm          string          `gorm:"column:advice_affirm" json:"advice_affirm" form:"advice_affirm"`
+	Remark                string          `gorm:"column:remark" json:"remark" form:"remark"`
+	StopTime              int64           `gorm:"column:stop_time" json:"stop_time" form:"stop_time"`
+	StopReason            string          `gorm:"column:stop_reason" json:"stop_reason" form:"stop_reason"`
+	StopDoctor            int64           `gorm:"column:stop_doctor" json:"stop_doctor" form:"stop_doctor"`
+	StopState             int64           `gorm:"column:stop_state" json:"stop_state" form:"stop_state"`
+	ParentId              int64           `gorm:"column:parent_id" json:"parent_id" form:"parent_id"`
+	ExecutionTime         int64           `gorm:"column:execution_time" json:"execution_time" form:"execution_time"`
+	ExecutionStaff        int64           `gorm:"column:execution_staff" json:"execution_staff" form:"execution_staff"`
+	ExecutionState        int64           `gorm:"column:execution_state" json:"execution_state" form:"execution_state"`
+	Checker               int64           `gorm:"column:checker" json:"checker" form:"checker"`
+	RecordDate            int64           `gorm:"column:record_date" json:"record_date"`
+	DialysisOrderId       int64           `gorm:"column:dialysis_order_id" json:"dialysis_order_id"`
+	CheckTime             int64           `gorm:"column:check_time" json:"check_time" form:"check_time"`
+	CheckState            int64           `gorm:"column:check_state" json:"check_state" form:"check_state"`
+	AdviceId              int64           `gorm:"-"`
+	RemindType            int64           `gorm:"column:remind_type" json:"remind_type"`
+	FrequencyType         int64           `gorm:"column:frequency_type" json:"frequency_type"`
+	DayCount              int64           `gorm:"column:day_count" json:"day_count"`
+	WeekDay               string          `gorm:"column:week_day" json:"week_day"`
+	ChildDoctorAdvice     []*DoctorAdvice `gorm:"ForeignKey:ParentId;AssociationForeignKey:ID" json:"child"`
+	TemplateId            string          `gorm:"column:template_id" json:"template_id"`
+	Modifier              int64           `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	IsCheck               int64           `gorm:"-" json:"is_check" form:"is_check"`
+}
+
+func (DoctorAdvice) TableName() string {
+	return "xt_doctor_advice"
+}
+
+type FiledConfig struct {
+	ID          int64  `gorm:"column:id" json:"id"`
+	OrgId       int64  `gorm:"column:org_id" json:"org_id"`
+	Module      int64  `gorm:"column:module" json:"module"`
+	FiledName   string `gorm:"column:filed_name" json:"filed_name"`
+	FiledNameCn string `gorm:"column:filed_name_cn" json:"filed_name_cn"`
+	IsShow      int64  `gorm:"column:is_show" json:"is_show"`
+	CreateTime  int64  `gorm:"column:create_time" json:"create_time"`
+	UpdateTime  int64  `gorm:"column:update_time" json:"update_time"`
+	SysModule   int64  `gorm:"column:sys_module" json:"sys_module" form:"sys_module"`
+}
+
+func (FiledConfig) TableName() string {
+	return "xt_filed_config"
+}
+
+type MiddlePatients struct {
+	ID             	int64 `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId		int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId       	int64 `gorm:"column:user_id" json:"user_id" form:"user_id"`
+	HisUserId  		string `gorm:"column:his_user_id" json:"his_user_id" form:"his_user_id"`
+	XtPatientId  	int64 `gorm:"column:xt_patient_id" json:"xt_patient_id" form:"xt_patient_id"`
+	SelectType  	int64 `gorm:"column:select_type" json:"select_type" form:"select_type"`
+	Status 			int	  `gorm:"column:status" json:"status" form:"status"`
+
+}
+
+func (MiddlePatients) TableName() string {
+	return "xt_middle_patients"
+}
+
+type Patients struct {
+	ID				int64	`gorm:"column:id" json:"id" form:"id"`
+	UserOrgId		int64	`gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	UserId			int64	`gorm:"column:user_id" json:"user_id" form:"user_id"`
+	AdmissionNumber	string	`gorm:"column:admission_number" json:"admission_number" form:"admission_number"`
+	DialysisNo		string	`gorm:"column:dialysis_no" json:"dialysis_no" form:"dialysis_no"`
+	IdCardNo		string	`gorm:"column:id_card_no" json:"id_card_no" form:"id_card_no"`
+	Name			string	`gorm:"column:name" json:"name" form:"name"`
+	ContactName		string	`gorm:"column:contact_name" json:"contact_name" form:"contact_name"`
+}
+
+func (Patients) TableName() string {
+	return "xt_patients"
+}
+
+type DialysisSchedule struct {
+	ID           int64 `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId    int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PartitionId  int64 `gorm:"column:partition_id" json:"partition_id" form:"partition_id"`
+	BedId        int64 `gorm:"column:bed_id" json:"bed_id" form:"bed_id"`
+	PatientId    int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	ScheduleDate int64 `gorm:"column:schedule_date" json:"schedule_date" form:"schedule_date"`
+	ScheduleType int64 `gorm:"column:schedule_type" json:"schedule_type" form:"schedule_type"`
+	ScheduleWeek int64 `gorm:"column:schedule_week" json:"schedule_week" form:"schedule_week"`
+	ModeId       int64 `gorm:"column:mode_id" json:"mode_id" form:"mode_id"`
+	Status       int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime  int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime  int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	Patients Patients `gorm:"ForeignKey:PatientId" json:"patient"`
+}
+
+func (DialysisSchedule) TableName() string {
+	return "xt_schedule"
+}
+
+
+type MiddleSyncInfo struct {
+	ID             	int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId       	int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	HisUserId       string `gorm:"column:his_user_id" json:"his_user_id" form:"his_user_id"`
+	SyncTime       	int64 `gorm:"column:sync_time" json:"sync_time" form:"sync_time"`
+	SyncResultType  int	  `gorm:"column:sync_result_type" json:"sync_result_type" form:"sync_result_type"`
+	SyncRsultRemark string `gorm:"column:sync_result_remark" json:"sync_result_remark" form:"sync_result_remark"`
+	SyncTotalNum    int64 `gorm:"column:sync_total_num" json:"sync_total_num" form:"sync_total_num"`
+	SyncSuccessNum  int64 `gorm:"column:sync_success_num" json:"sync_success_num" form:"sync_success_num"`
+	SyncInfo      	string `gorm:"column:sync_info" json:"sync_info" form:"sync_info"`
+	CreateTime      int64 `gorm:"column:create_time" json:"create_time" form:"create_time"`
+	UpdateTime    	int64 `gorm:"column:update_time" json:"update_time" form:"update_time"`
+}
+
+func (MiddleSyncInfo) TableName() string {
+	return "xt_middle_sync_info"
+}
+
+type TBLISItem struct {
+	HisUserId             	string  `gorm:"column:his_user_id" json:"his_user_id" form:"his_user_id"`
+	ProjectId       		int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ProjectName         	string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	PatientName         	string `gorm:"column:patient_name" json:"patient_name" form:"patient_name"`
+	InspectDate          	string  `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	ItemId           		int64 `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemName      			string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ItemType          		int    `gorm:"column:item_type" json:"item_type" form:"item_type"`
+	ItemValue    			string `gorm:"column:item_value" json:"item_value" form:"item_value"`
+	RangeMin    			string `gorm:"column:range_min" json:"range_min" form:"range_min"`
+	RangeMax    			string `gorm:"column:range_max" json:"range_max" form:"range_max"`
+	RangeValue   			string  `gorm:"column:range_value" json:"range_value" form:"range_value"`
+	RangeOptions         	string  `gorm:"column:range_options" json:"range_options" form:"range_options"`
+	Unit         			string `gorm:"column:unit" json:"unit" form:"unit"`
+	UTime 					string  `gorm:"column:u_time" json:"u_time" form:"u_time"`
+}
+
+func (TBLISItem) TableName() string {
+	return "TB_LIS_Item"
+}
+
+type Inspection struct {
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	PatientId int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	OrgId int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectId int64 `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemId int64 `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemName string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ProjectName string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	InspectType int64 `gorm:"column:inspect_type" json:"inspect_type" form:"inspect_type"`
+	InspectValue string `gorm:"column:inspect_value" json:"inspect_value" form:"inspect_value"`
+	InspectTips string `gorm:"column:inspect_tips" json:"inspect_tips" form:"inspect_tips"`
+	InspectDate int64 `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+
+func (Inspection) TableName() string {
+	return "xt_inspection"
+}
+
+type InspectionReference struct {
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectName string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	Project string `gorm:"column:project" json:"project" form:"project"`
+	ProjectId int64 `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemName string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ItemNameAddition string `gorm:"column:item_name_addition" json:"item_name_addition" form:"item_name_addition"`
+	Item string `gorm:"column:item" json:"item" form:"item"`
+	ItemId int64 `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	RangeType int `gorm:"column:range_type" json:"range_type" form:"range_type"`
+	RangeMin string `gorm:"column:range_min" json:"range_min" form:"range_min"`
+	RangeMax string `gorm:"column:range_max" json:"range_max" form:"range_max"`
+	RangeValue string `gorm:"column:range_value" json:"range_value" form:"range_value"`
+	RangeOptions string `gorm:"column:range_options" json:"range_options" form:"range_options"`
+	Unit string `gorm:"column:unit" json:"unit" form:"unit"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+func (InspectionReference) TableName() string {
+	return "xt_inspection_reference"
+}
+
+type MiddleReportHandle struct {
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	HisUserId string `gorm:"column:his_user_id" json:"his_user_id" form:"his_user_id"`
+	ApplyNo string `gorm:"column:apply_no" json:"apply_no" form:"apply_no"`
+	ReportId string `gorm:"column:report_id" json:"report_id" form:"report_id"`
+	Name string `gorm:"column:name" json:"name" form:"name"`
+	Sex string `gorm:"column:sex" json:"sex" form:"sex"`
+	Age string `gorm:"column:age" json:"age" form:"age"`
+	Dept string `gorm:"column:dept" json:"dept" form:"dept"`
+	PatientId string `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	RequestTime string `gorm:"column:request_time" json:"request_time" form:"request_time"`
+	ExecuteTime string `gorm:"column:execute_time" json:"execute_time" form:"execute_time"`
+	ReceiveTime string `gorm:"column:receive_time" json:"receive_time" form:"receive_time"`
+	Item string `gorm:"column:item" json:"item" form:"item"`
+	CheckTime string `gorm:"column:check_time" json:"check_time" form:"check_time"`
+	PatientType string `gorm:"column:patient_type" json:"patient_type" form:"patient_type"`
+	ReportInfo string `gorm:"column:report_info" json:"report_info" form:"report_info"`
+	ReportInfoItemNum int64 `gorm:"column:report_info_item_num" json:"report_info_item_num" form:"report_info_item_num"`
+	ReportInfoItemHandleNum int64 `gorm:"column:report_info_item_handle_num" json:"report_info_item_handle_num" form:"report_info_item_handle_num"`
+	HandleType int64 `gorm:"column:handle_type" json:"handle_type" form:"handle_type"`
+	CreatedTime int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+}
+
+
+func (MiddleReportHandle) TableName() string {
+	return "xt_middle_report_handle"
+}
+
+type MiddleInspection struct {
+	ID int64 `gorm:"column:id" json:"id" form:"id"`
+	PatientId int64 `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	OrgId int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectId int64 `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemId int64 `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemName string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ProjectName string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	InspectType int `gorm:"column:inspect_type" json:"inspect_type" form:"inspect_type"`
+	InspectValue string `gorm:"column:inspect_value" json:"inspect_value" form:"inspect_value"`
+	InspectTips string `gorm:"column:inspect_tips" json:"inspect_tips" form:"inspect_tips"`
+	RecordDate int64 `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	InspectDate string `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	Status int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	UTime string `gorm:"column:u_time" json:"u_time" form:"u_time"`
+	IsSync int `gorm:"column:is_sync" json:"is_sync" form:"is_sync"`
+	// SyncItemId int64 `gorm:"column:sync_item_id" json:"sync_item_id" form:"sync_item_id"`
+	HisUserId string `gorm:"column:his_user_id" json:"his_user_id" form:"his_user_id"`
+	SyncId			int64 `gorm:"column:sync_id" json:"sync_id" form:"sync_id"`
+}
+
+
+func (MiddleInspection) TableName() string {
+	return "xt_middle_inspection"
+}
+
+type MiddleInspectionReference struct {
+	ID 					int64 `gorm:"column:id" json:"id" form:"id"`
+	OrgId 				int64 `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectName 		string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	Project 			string `gorm:"column:project" json:"project" form:"project"`
+	ProjectId 			int64 `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemName 			string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ItemId 				int64 `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemNameAddition 	string `gorm:"column:item_name_addition" json:"item_name_addition" form:"item_name_addition"`
+	Item 				string `gorm:"column:item" json:"item" form:"item"`
+	RangeType 			int `gorm:"column:range_type" json:"range_type" form:"range_type"`
+	RangeMin 			string `gorm:"column:range_min" json:"range_min" form:"range_min"`
+	RangeMax 			string `gorm:"column:range_max" json:"range_max" form:"range_max"`
+	RangeValue 			string `gorm:"column:range_value" json:"range_value" form:"range_value"`
+	RangeOptions 		string `gorm:"column:range_options" json:"range_options" form:"range_options"`
+	Unit 				string `gorm:"column:unit" json:"unit" form:"unit"`
+	Status 				int64 `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime 		int64 `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime 		int64 `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	InspectDate 		string `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	IsSync 				int `gorm:"column:is_sync" json:"is_sync" form:"is_sync"`
+	UTime 				string `gorm:"column:u_time" json:"u_time" form:"u_time"`
+	SyncId				int64 `gorm:"column:sync_id" json:"sync_id" form:"sync_id"`
+}
+
+func (MiddleInspectionReference) TableName() string {
+	return "xt_middle_inspection_reference"
+}
+
+type XtDoctorAdvice struct {
+	ID                    int64   `gorm:"column:id" json:"id" form:"id"`
+	UserOrgId             int64   `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
+	PatientId             int64   `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	AdviceType            int64   `gorm:"column:advice_type" json:"advice_type" form:"advice_type"`
+	AdviceDate            int64   `gorm:"column:advice_date" json:"advice_date" form:"advice_date"`
+	StartTime             int64   `gorm:"column:start_time" json:"start_time" form:"start_time"`
+	AdviceName            string  `gorm:"column:advice_name" json:"advice_name" form:"advice_name"`
+	AdviceDesc            string  `gorm:"column:advice_desc" json:"advice_desc" form:"advice_desc"`
+	ReminderDate          int64   `gorm:"column:reminder_date" json:"reminder_date" form:"reminder_date"`
+	SingleDose            float64 `gorm:"column:single_dose" json:"single_dose" form:"single_dose"`
+	SingleDoseUnit        string  `gorm:"column:single_dose_unit" json:"single_dose_unit" form:"single_dose_unit"`
+	PrescribingNumber     float64 `gorm:"column:prescribing_number" json:"prescribing_number" form:"prescribing_number"`
+	PrescribingNumberUnit string  `gorm:"column:prescribing_number_unit" json:"prescribing_number_unit" form:"prescribing_number_unit"`
+	DeliveryWay           string  `gorm:"column:delivery_way" json:"delivery_way" form:"delivery_way"`
+	ExecutionFrequency    string  `gorm:"column:execution_frequency" json:"execution_frequency" form:"execution_frequency"`
+	AdviceDoctor          int64   `gorm:"column:advice_doctor" json:"advice_doctor" form:"advice_doctor"`
+	Status                int64   `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime           int64   `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime           int64   `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
+	AdviceAffirm          string  `gorm:"column:advice_affirm" json:"advice_affirm" form:"advice_affirm"`
+	Remark                string  `gorm:"column:remark" json:"remark" form:"remark"`
+	StopTime              int64   `gorm:"column:stop_time" json:"stop_time" form:"stop_time"`
+	StopReason            string  `gorm:"column:stop_reason" json:"stop_reason" form:"stop_reason"`
+	StopDoctor            int64   `gorm:"column:stop_doctor" json:"stop_doctor" form:"stop_doctor"`
+	StopState             int64   `gorm:"column:stop_state" json:"stop_state" form:"stop_state"`
+	ParentId              int64   `gorm:"column:parent_id" json:"parent_id" form:"parent_id"`
+	ExecutionTime         int64   `gorm:"column:execution_time" json:"execution_time" form:"execution_time"`
+	ExecutionStaff        int64   `gorm:"column:execution_staff" json:"execution_staff" form:"execution_staff"`
+	ExecutionState        int64   `gorm:"column:execution_state" json:"execution_state" form:"execution_state"`
+	Checker               int64   `gorm:"column:checker" json:"checker" form:"checker"`
+	RecordDate            int64   `gorm:"column:record_date" json:"record_date" form:"record_date"`
+	DialysisOrderId       int64   `gorm:"column:dialysis_order_id" json:"dialysis_order_id" form:"dialysis_order_id"`
+	CheckTime             int64   `gorm:"column:check_time" json:"check_time" form:"check_time"`
+	CheckState            int64   `gorm:"column:check_state" json:"check_state" form:"check_state"`
+	DrugSpec              float64 `gorm:"column:drug_spec" json:"drug_spec" form:"drug_spec"`
+	DrugSpecUnit          string  `gorm:"column:drug_spec_unit" json:"drug_spec_unit" form:"drug_spec_unit"`
+	Groupno               int64   `gorm:"column:groupno" json:"groupno" form:"groupno"`
+	RemindType            int64   `gorm:"column:remind_type" json:"remind_type" form:"remind_type"`
+	FrequencyType         int64   `gorm:"column:frequency_type" json:"frequency_type" form:"frequency_type"`
+	DayCount              int64   `gorm:"column:day_count" json:"day_count" form:"day_count"`
+	WeekDay               string  `gorm:"column:week_day" json:"week_day" form:"week_day"`
+	TemplateId            string  `gorm:"column:template_id" json:"template_id" form:"template_id"`
+	Modifier              int64   `gorm:"column:modifier" json:"modifier" form:"modifier"`
+	SyncAdviceId          int64   `gorm:"column:sync_advice_id" json:"sync_advice_id" form:"sync_advice_id"`
+	IsSync          	  int64   `gorm:"column:is_sync" json:"is_sync" form:"is_sync"`
+}
+
+func (XtDoctorAdvice) TableName() string {
+	return "xt_doctor_advice"
+}
+
+type UserAdminRole struct {
+	ID              int64           `gorm:"column:id" json:"id"`
+	AdminUserId     int64           `gorm:"column:admin_user_id" json:"admin_user_id"`
+	OrgId           int64           `gorm:"column:org_id" json:"org_id"`
+	AppId           int64           `gorm:"column:app_id" json:"app_id"`
+	RoleId          int64           `gorm:"column:role_id" json:"role_id"`
+	UserName        string          `gorm:"column:user_name" json:"user_name"`
+	Avatar          string          `gorm:"column:avatar" json:"avatar"`
+	UserType        int64           `gorm:"column:user_type" json:"user_type"`
+	UserTitle       int64           `gorm:"column:user_title" json:"user_title"`
+	Intro           string          `gorm:"column:intro" json:"intro"`
+	Status          int64           `gorm:"column:status" json:"status"`
+	Ctime           int64           `gorm:"column:ctime" json:"ctime"`
+	Mtime           int64           `gorm:"column:mtime" json:"mtime"`
+}
+
+func (UserAdminRole) TableName() string {
+	return "sgj_user_admin_role"
+}

routers/router.go

@@ -0,0 +1,20 @@
+package routers
+
+import (
+	"IC/controllers"
+	"github.com/astaxie/beego"
+)
+
+func init() {
+	beego.Router("/", &controllers.MainController{})
+	beego.Router("/api/lis/getlist", &controllers.LisController{}, "get:GetList")
+	beego.Router("/api/lis/synctobase", &controllers.LisController{}, "get:SyncToBase")
+	beego.Router("/api/lis/synfiled", &controllers.LisController{}, "get:FiledConfigSys")
+	beego.Router("/api/lis/syncadvice", &controllers.LisController{}, "get:SyncAdvice")
+	beego.Router("/api/lis/lgeysync", &controllers.LisController{}, "get:SyncLgth")
+	beego.Router("/api/lis/ystxsync", &controllers.LisController{}, "get:SyncYstx")
+	beego.Router("/api/lis/gzjhyzsync", &controllers.LisController{}, "get:SyncGzjhyz")
+	beego.Router("/api/lis/gzjhlissync", &controllers.LisController{}, "get:SyncGzjhLis")
+	beego.Router("/api/lis/hbdyyzsync", &controllers.LisController{}, "get:SyncHbJldyyz")
+	beego.Router("/api/lis/hbdylissync", &controllers.LisController{}, "get:SyncHbJldyLis")
+}

service/cron.go

@@ -0,0 +1,190 @@
+package service
+
+import (
+	_"fmt"
+	_"strings"
+	"time"
+	"IC/models"
+	"IC/utils"
+	"encoding/json"
+	_"github.com/jinzhu/gorm"
+	"github.com/robfig/cron"
+)
+
+// cron表达式 https://www.cnblogs.com/zuxingyu/p/6023919.html
+var createLisSyncCronJob *cron.Cron
+
+func init() {
+	utils.InfoLog("开启自动检验检查同步定时任务")
+	createLisSyncCronJob = cron.New()
+	spec := "0 0 1 * * ?" // 每天凌晨1点同步
+	createLisSyncCronJob.AddFunc(spec, func() {
+		AutoSyncLis()
+	})
+
+	speclg := "0 0 2 * * ?" // 每天凌晨2点同步 龙岗二院
+	createLisSyncCronJob.AddFunc(speclg, func() {
+		SyncLisLgty()
+	})
+
+	specys := "0 0 3 * * ?" // 每天凌晨3点同步 沅胜血透
+	createLisSyncCronJob.AddFunc(specys, func() {
+		SyncHbdyLis()
+	})
+
+	// specgzjh := "0 */1 7-20 * *  " // 每2分钟同步 广州暨华HIS医嘱
+	// createLisSyncCronJob.AddFunc(specgzjh, func() {
+	// 	SyncGzjhyz()
+	// })
+
+	specgzjhlis := "0 30 3 * * ?" // 每天凌晨3点30同步 广州暨华
+	createLisSyncCronJob.AddFunc(specgzjhlis, func() {
+		SyncGzjhLis()
+	})
+}
+
+func BeginAutoSyncLis() {
+	createLisSyncCronJob.Start()
+}
+
+func AutoSyncLis() {
+	utils.TraceLog("检验检查任务开始执行")
+	org_id := int64(9538)
+
+	// 第一步：根据机构id获取对应机构所有病人的his_user_id
+	patients,patientError := GetHisUserIdByOrgID(org_id)
+	if patientError != nil {
+		utils.ErrorLog("获取用户His_user_id信息失败:%v", patientError)
+		return
+	}
+
+	// patientStr:= make([]interface{},0)
+	if len(patients) > 0 {
+	// 第二步：根据病人的his_user_id来查询上次同步时间	
+		for _ , patient := range patients {
+			if len(patient.HisUserId) <= 0 {
+				continue
+			}
+			syncLastInfo,_ := GetSyncTimeByOrgID(org_id,patient.HisUserId)
+			var sync_time int64
+			if syncLastInfo.ID > 0 {
+				sync_time = syncLastInfo.SyncTime
+			} else {
+				inspectionLastInfo,_ := GetInspectionLastInfoByOrgID(org_id,patient.HisUserId)
+				if inspectionLastInfo.ID > 0 {
+					sync_time = inspectionLastInfo.CreatedTime
+				} else {
+					sync_time = 0
+				}
+			}
+
+			syncTimes := time.Unix(sync_time,0).Format("2006-01-02 15:04")
+			utils.InfoLog("syncTimes:%v",syncTimes)
+
+			// 第三步：跟进上次同步时间和指定的his_user_id，获取上次同步到现在指定人的检验检查记录
+			resultList, _ := GetListByHisUserID(patient.HisUserId,syncTimes,patient.SelectType)
+			var syncInfo models.MiddleSyncInfo
+	
+			if len(resultList) > 0 {
+				// 如果有数据，则把同步过来的详情插入一条数据到同步详情表中
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.HisUserId
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "同步成功"
+				syncInfo.SyncTotalNum = int64(len(resultList))
+				syncInfo.SyncSuccessNum = 0
+				SyncInfos,_ := json.Marshal(resultList)
+				syncInfo.SyncInfo = string(SyncInfos)
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				err := CreateSyncInfo(&syncInfo)
+				if err != nil {
+					utils.ErrorLog("创建同步信息失败:%v", err)
+					return
+				}
+			} else {
+				// 如果没有数据，则插入一条数据到同步详情表中
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.HisUserId
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "该患者这个时间段没有任何检验检查数据"
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				err := CreateSyncInfo(&syncInfo)
+				if err != nil {
+					utils.ErrorLog("创建同步信息失败:%v", err)
+					return
+				}
+				// utils.InfoLog("同步信息详情:%v",syncInfo)
+				continue 
+			}
+
+			// 第四部：将同步过来的数据插入到中间库对应的表
+			syncSuccessNum := 0
+			for _, result := range resultList {
+				if (result.HisUserId == patient.HisUserId) || (result.PatientName ==  patient.HisUserId) {
+					patientId := patient.XtPatientId
+					if patientId > 0 {
+						inspection_reference,inspection,_ := Sync(result,org_id,patientId)
+						if (inspection_reference.ID > 0 || inspection.ID > 0 ) {
+							syncSuccessNum++
+						}
+					}
+				}
+			}
+			syncInfo.SyncSuccessNum = int64(syncSuccessNum)
+			UpdateSyncInfo(&syncInfo)
+
+			// patientStr = append(patientStr,patient.HisUserId)
+			// utils.InfoLog("patientStr:%v",patientStr)	
+		}
+	} else {
+		var syncInfo models.MiddleSyncInfo
+		// 如果没有数据，则插入一条数据到同步详情表中
+		syncInfo.OrgId = org_id
+		syncInfo.SyncTime = time.Now().Unix()
+		syncInfo.SyncResultType = 0
+		syncInfo.SyncRsultRemark = "该机构没有对应的his_user_id"
+		syncInfo.CreateTime = time.Now().Unix()
+		syncInfo.UpdateTime = time.Now().Unix()
+
+		err := CreateSyncInfo(&syncInfo)
+		if err != nil {
+			utils.ErrorLog("创建同步信息失败:%v", err)
+			return
+		}
+		utils.InfoLog("同步信息详情:%v",syncInfo)
+		return 
+	}
+
+	SyncToBase()
+	utils.SuccessLog("检验检查任务完成")
+}
+
+
+func  SyncToBase() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(9538)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references,_ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections,_ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _,inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _,inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}

service/db.go

@@ -0,0 +1,176 @@
+// Pipe - A small and beautiful blogging platform written in golang.
+// Copyright (C) 2017-2018, b3log.org
+//
+// This program is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+//
+// This program is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+//
+// You should have received a copy of the GNU General Public License
+// along with this program.  If not, see <http://www.gnu.org/licenses/>.
+
+package service
+
+import (
+	"fmt"
+
+	"github.com/astaxie/beego"
+	"github.com/jinzhu/gorm"
+	_ "github.com/jinzhu/gorm/dialects/mysql" // mysql
+	_ "github.com/jinzhu/gorm/dialects/mssql" // mssql
+)
+
+var readDb *gorm.DB
+var writeDb *gorm.DB
+var readRemoteDb *gorm.DB
+var writeUserDb *gorm.DB
+
+var readMiddleDb *gorm.DB
+var writeMiddleDb *gorm.DB
+var backupDb *gorm.DB
+var err error
+
+func ConnectDB() {
+	readHost := beego.AppConfig.String("readmysqlhost")
+	readPort := beego.AppConfig.String("readmysqlport")
+	readUser := beego.AppConfig.String("readmysqluser")
+	readPass := beego.AppConfig.String("readmysqlpass")
+	readName := beego.AppConfig.String("readmysqlname")
+
+	writeHost := beego.AppConfig.String("writemysqlhost")
+	writePort := beego.AppConfig.String("writemysqlport")
+	writeUser := beego.AppConfig.String("writemysqluser")
+	writePass := beego.AppConfig.String("writemysqlpass")
+	writeName := beego.AppConfig.String("writemysqlname")
+
+	// readRemoteHost := beego.AppConfig.String("readremotehost")
+	// readRemotePort := beego.AppConfig.String("readremoteport")
+	// readRemoteUser := beego.AppConfig.String("readremoteuser")
+	// readRemotePass := beego.AppConfig.String("readremotepass")
+	// readRemoteName := beego.AppConfig.String("readremotename")
+
+	writeUserHost := beego.AppConfig.String("writeuserhost")
+	writeUserPort := beego.AppConfig.String("writeuserport")
+	writeUserUser := beego.AppConfig.String("writeuseruser")
+	writeUserPass := beego.AppConfig.String("writeuserpass")
+	writeUserName := beego.AppConfig.String("writeusername")
+
+	readMiddleHost := beego.AppConfig.String("readmiddlehost")
+	readMiddlePort := beego.AppConfig.String("readmiddleport")
+	readMiddleUser := beego.AppConfig.String("readmiddleuser")
+	readMiddlePass := beego.AppConfig.String("readmiddlepass")
+	readMiddleName := beego.AppConfig.String("readmiddlename")
+
+	writeMiddleHost := beego.AppConfig.String("writemiddlehost")
+	writeMiddlePort := beego.AppConfig.String("writemiddleport")
+	writeMiddleUser := beego.AppConfig.String("writemiddleuser")
+	writeMiddlePass := beego.AppConfig.String("writemiddlepass")
+	writeMiddleName := beego.AppConfig.String("writemiddlename")
+
+	// backupHost := beego.AppConfig.String("backuphost")
+	// backupPort := beego.AppConfig.String("backupport")
+	// backupUser := beego.AppConfig.String("backupuser")
+	// backupPass := beego.AppConfig.String("backuppass")
+	// backupName := beego.AppConfig.String("backupname")
+
+	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)
+
+	// rudsn := fmt.Sprintf("server=%s;port=%s;database=%s;user id=%s;password=%s", readRemoteHost, readRemotePort, readRemoteName, readRemoteUser, readRemotePass)
+	wudsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeUserUser, writeUserPass, writeUserHost, writeUserPort, writeUserName)
+
+	rmdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readMiddleUser, readMiddlePass, readMiddleHost, readMiddlePort, readMiddleName)
+	wmdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeMiddleUser, writeMiddlePass, writeMiddleHost, writeMiddlePort, writeMiddleName)
+
+	// bdsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", backupUser, backupPass, backupHost, backupPort, backupName)
+
+	readDb, err = gorm.Open("mysql", rdsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	readDb.DB().SetMaxIdleConns(10)
+	readDb.DB().SetMaxOpenConns(100)
+	readDb.LogMode(true)
+
+	// backupDb, err = gorm.Open("mysql", bdsn)
+	// if err != nil {
+	// 	//beego.Error(err)
+	// }
+	// backupDb.DB().SetMaxIdleConns(10)
+	// backupDb.DB().SetMaxOpenConns(100)
+	// backupDb.LogMode(true)
+
+	writeDb, err = gorm.Open("mysql", wdsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	writeDb.DB().SetMaxIdleConns(10)
+	writeDb.DB().SetMaxOpenConns(100)
+	writeDb.LogMode(true)
+
+	// fmt.Println(rudsn)
+
+	// readRemoteDb, err = gorm.Open("mssql", rudsn)
+	// if err != nil {
+	// 	panic(err)
+	// }
+	// readRemoteDb.DB().SetMaxIdleConns(10)
+	// readRemoteDb.DB().SetMaxOpenConns(100)
+	// readRemoteDb.LogMode(true)
+
+	writeUserDb, err = gorm.Open("mysql", wudsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	writeUserDb.DB().SetMaxIdleConns(10)
+	writeUserDb.DB().SetMaxOpenConns(100)
+	writeUserDb.LogMode(true)
+
+	readMiddleDb, err = gorm.Open("mysql", rmdsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	readMiddleDb.DB().SetMaxIdleConns(10)
+	readMiddleDb.DB().SetMaxOpenConns(100)
+	readMiddleDb.LogMode(true)
+
+	writeMiddleDb, err = gorm.Open("mysql", wmdsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	writeMiddleDb.DB().SetMaxIdleConns(10)
+	writeMiddleDb.DB().SetMaxOpenConns(100)
+	writeMiddleDb.LogMode(true)
+
+}
+
+//func DisconnectDB() {
+//	if err := readDb.Close(); nil != err {
+//		beego.Error("Disconnect from database failed: " + err.Error())
+//	}
+//}
+
+func XTReadDB() *gorm.DB {
+	return readDb
+}
+func XTWriteDB() *gorm.DB {
+	return writeDb
+}
+// func RemoteReadDB() *gorm.DB {
+// 	return readRemoteDb
+// }
+func UserWriteDB() *gorm.DB {
+	return writeUserDb
+}
+
+func MiddleReadDB() *gorm.DB {
+	return readMiddleDb
+}
+func MiddleWriteDB() *gorm.DB {
+	return writeMiddleDb
+}

service/lgty_service.go

@@ -0,0 +1,439 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	_"strconv"
+	"strings"
+	"encoding/json"
+	"time"
+	"net/url"
+	_"IC/utils"
+	_"fmt"
+	_"encoding/json"
+	_"github.com/jinzhu/gorm"
+	"github.com/astaxie/beego/httplib"
+)
+
+
+// 龙岗二院Lis同步
+func SyncLisLgty() (err error) {
+	// 第一步：获取龙岗二院所有病人
+	org_id := int64(9598)
+	patientlist,patientError := GetUserInfoByOrgID(org_id)
+	if patientError != nil {
+		utils.ErrorLog("获取龙岗二院患者信息失败:%v", patientError)
+		return
+	}
+
+	if len(patientlist) > 0 {
+		// 第二步：根据病人的住院号来查询上次同步时间	
+		for _ , patient := range patientlist {
+			if len(patient.AdmissionNumber) <= 0 {
+				continue
+			}
+			syncLastInfo,_ := GetSyncTimeByOrgID(org_id,patient.AdmissionNumber)
+			var sync_time int64
+			if syncLastInfo.ID > 0 {
+				sync_time = syncLastInfo.SyncTime
+			} else {
+				inspectionLastInfo,_ := GetInspectionLastInfoByOrgID(org_id,patient.AdmissionNumber)
+				if inspectionLastInfo.ID > 0 {
+					sync_time = inspectionLastInfo.CreatedTime
+				} else {
+					sync_time = 0
+				}
+			}
+
+			syncTimes := time.Unix(sync_time,0).Format("2006-01-02 15:04")
+			utils.InfoLog("syncTimes:%v",syncTimes)
+			nowTimes := time.Now().Format("2006-01-02 15:04")
+			// 第三步：跟进上次同步时间和指定的门诊号，获取上次同步到现在指定人的检验检查记录
+			lisHead,HeadString := GetHead(patient.AdmissionNumber,syncTimes,nowTimes)
+			var resultCount int64
+			// 第四步，将同步过来的头部信息存到中间库的检验检查操作表中
+			if len(lisHead) > 0 {
+				resultCount = 0
+				for _ , head := range lisHead {
+					// if len(head.Item) <= 0  {
+					// 	continue
+					// }
+					if len(head.ReportId) > 1 {
+						if len(head.Item) == 0 {
+							head.Item = "肾功三项"
+						}
+						middleReportHandle := models.MiddleReportHandle{
+							OrgId:			org_id,
+							HisUserId:		patient.AdmissionNumber,
+							ApplyNo:		head.ApplyNo,
+							ReportId:		head.ReportId,	
+							Name:			head.Name,	
+							Sex:			head.Sex,
+							Age:			head.Age,
+							Dept:			head.Dept,
+							PatientId:		head.PatientId,
+							RequestTime:	head.RequestTime,
+							ExecuteTime:	head.ExecuteTime,
+							ReceiveTime:	head.ReceiveTime,
+							Item:			head.Item,
+							CheckTime:		head.CheckTime,
+							PatientType:	head.PatientType,
+							CreatedTime:	time.Now().Unix(),
+							UpdatedTime:	time.Now().Unix(),
+						}
+						handleerr := CreateReportHandle(&middleReportHandle)
+						if handleerr != nil {
+							utils.ErrorLog("创建检验检查操作数据失败:%v", handleerr)
+							return
+						} 
+						// // reportInfos,ReportString := GetReport(head.ReportId)
+						// HeadString = HeadString + " " + ReportString
+						// // 获取该项的检验检查project_id,如果没有，则创建一个
+						// project_id,_ := GetProjectID(org_id,head.Item)
+						// if len(reportInfos) > 2 {
+						// 	// 将同步过来的检验检查数据存到中间库
+						// 	for _,reportInfo := range reportInfos{
+						// 		if len(reportInfo.ItemName) <= 0 {
+						// 			continue
+						// 		}
+						// 		// 获取该小项的检验检查item_id,如果没有，则创建一个
+						// 		item_id,_ := GetItemID(org_id,head.Item,reportInfo.ItemName,project_id)
+						// 		_,_,syerr := LgthSync(head,reportInfo,project_id,item_id,org_id,patient.ID,patient.AdmissionNumber)
+						// 		if syerr == nil {
+						// 			resultCount = resultCount + 1
+						// 		}
+						// 	}
+						// }
+					}
+				}
+				var syncInfo models.MiddleSyncInfo
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.AdmissionNumber
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "同步成功"
+				syncInfo.SyncTotalNum = resultCount
+				syncInfo.SyncSuccessNum = 0
+				syncInfo.SyncInfo = HeadString
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				cwderr := CreateSyncInfo(&syncInfo)
+				if cwderr != nil {
+					utils.ErrorLog("创建同步信息失败:%v", cwderr)
+					return
+				}	
+			} else {
+				// 未同步到检验检查头部信息
+				var syncInfo models.MiddleSyncInfo
+				syncInfo.OrgId = org_id
+				syncInfo.HisUserId = patient.AdmissionNumber
+				syncInfo.SyncTime = time.Now().Unix()
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "该患者这个时间段没有任何检验检查数据"
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				serr := CreateSyncInfo(&syncInfo)
+				if serr != nil {
+					utils.ErrorLog("创建同步信息失败:%v", serr)
+					return
+				}
+				continue 
+			}
+			
+		}
+	}
+	// 第五步，查询检验检查操作表里状态为0的数据，并将该对应报告的检验检查详情数据请求回来并存入该条数据里的report_info字段
+	ReportInfoHandle(org_id)
+	return 
+}
+
+func ReportInfoHandle (org_id int64) {
+	// 1.从检验检查表中查询操作状态为0的数据 
+	report_handle_list,_ := GetReportHandleListyOrgID(org_id)
+	if len(report_handle_list) > 0 {
+		for _,report_handle := range report_handle_list {
+			// 2. 根据report_id获取报告详情并进行相关处理
+			reportInfos,ReportString := GetReport(report_handle.ReportId)
+			if len(reportInfos) > 0 {
+				report_info_item_num := len(reportInfos)
+				// 将检验检查详情，检验检查小项条数更新到操作表数据中
+				middleReportHandle := models.MiddleReportHandle{
+					ID:					report_handle.ID,
+					ReportInfo:			ReportString,
+					ReportInfoItemNum: 	int64(report_info_item_num),
+					UpdatedTime:		time.Now().Unix(),
+				}
+				err := UpdateReportHandleListyOrgID(&middleReportHandle)
+				if err != nil {
+					utils.ErrorLog("创建同步信息失败:%v", err)
+					return
+				}
+				report_handle.ReportInfoItemNum = int64(report_info_item_num)
+				project_id,_ := GetProjectID(org_id,report_handle.Item)
+				patient,perr := GetUserInfoByAdmission(report_handle.HisUserId,org_id)
+				if perr != nil {
+					utils.ErrorLog("查询病人信息失败:%v", perr)
+					return
+				}
+				if len(reportInfos) > 0 {
+				// 将同步过来的检验检查数据存到中间库
+					for _,reportInfo := range reportInfos{
+						if len(reportInfo.ItemName) <= 0 {
+							continue
+						}
+						// 获取该小项的检验检查item_id,如果没有，则创建一个
+						item_id,_ := GetItemID(org_id,report_handle.Item,reportInfo.ItemName,project_id)
+						_,_,syerr := LgthSync(&report_handle,reportInfo,project_id,item_id,org_id,patient.ID,patient.AdmissionNumber)
+						if syerr != nil {
+							utils.ErrorLog("创建同步信息失败:%v", syerr)
+							return
+						}
+					}
+				}
+			} 
+		}
+	}
+	SyncToLgey()
+}
+
+func  SyncToLgey() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(9598)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references,_ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections,_ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _,inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _,inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}
+
+// 从机构将数据同步到中间库
+func LgthSync(Head *models.MiddleReportHandle,report ReportInfo,project_id int64,item_id int64,org_id int64,patient_id int64,his_user_id string)(*models.MiddleInspectionReference,*models.MiddleInspection,error) {
+	tx := writeMiddleDb.Begin()
+	var inspection models.MiddleInspection
+	var inspection_reference models.MiddleInspectionReference
+	recordDateStr := Head.CheckTime
+
+	if len(Head.CheckTime) == 0 { 
+		recordDateStr = time.Now().Format("2006-01-02 15:04")
+	} else {
+		dateTempArrOne := strings.Split(recordDateStr,"T")
+		dateTempArrTwo := strings.Split(dateTempArrOne[1],".")
+		recordDateStr = dateTempArrOne[0] + " " + dateTempArrTwo[0]
+	}
+
+	record_date_str, _ := utils.ParseTimeStringToTime("2006-01-02 15:04:05", recordDateStr)
+	record_date := record_date_str.Unix()
+	inspect_date := time.Unix(record_date,0).Format("2006-01-02 15:04")
+	// date, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", recordDateStr)
+	// record_date,_ := utils.ParseTimeStringToTime("2006-01-02", date.Format("2006-01-02"))
+	var total int
+	var itotal int
+	var RangeOptions string 
+	var RangeMin string
+	var RangeMax string
+
+	// // 判断检查类型
+	ItemType := 1
+	Range := strings.Split(report.Reference,"～")
+	if len(Range) > 1   {
+		RangeMin = Range[0]
+		RangeMax = Range[1] 
+		ItemType = 1
+	} else {
+		ItemType = 2
+		RangeOptions = report.Reference
+	}
+
+
+
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and project_id = ? and item_id = ? and status = 1", org_id, project_id,item_id).Find(&inspection_reference).Count(&total).Error
+	if inspection_reference.ID > 0 {
+		ItemType = inspection_reference.RangeType
+	}
+	if total <= 0 && len(Head.Item) > 0 {
+		inspection_reference.OrgId = org_id
+		inspection_reference.ProjectName = Head.Item
+		inspection_reference.Project = Head.Item
+		inspection_reference.ProjectId = project_id
+		inspection_reference.ItemName = report.ItemName
+		inspection_reference.ItemId = item_id
+		inspection_reference.RangeType = ItemType
+		inspection_reference.RangeMin = RangeMin
+		inspection_reference.RangeMax = RangeMax
+		// inspection_reference.RangeValue = RangeValue
+		inspection_reference.RangeOptions = RangeOptions
+		inspection_reference.Unit = report.Unit
+		inspection_reference.Status = 1
+		inspection_reference.CreatedTime = time.Now().Unix()
+		inspection_reference.UpdatedTime = time.Now().Unix()
+		inspection_reference.InspectDate = inspect_date
+		inspection_reference.UTime = inspect_date
+		err = tx.Model(&models.MiddleInspectionReference{}).Create(&inspection_reference).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+
+	err = readMiddleDb.Model(&models.MiddleInspection{}).Where("org_id = ? and project_id = ? and item_id = ? and record_date = ? and patient_id = ?  and status = 1", org_id, project_id,item_id,record_date,patient_id).Find(&inspection).Count(&itotal).Error
+	if itotal <= 0 {
+		inspection.PatientId = patient_id
+		inspection.OrgId = org_id
+		inspection.ProjectId = project_id
+		inspection.ItemName = report.ItemName
+		inspection.ProjectName = Head.Item
+		inspection.InspectType = ItemType
+		inspection.ItemId = item_id
+		inspection.InspectValue = report.Result
+		inspection.InspectDate = inspect_date
+		inspection.RecordDate = record_date
+		inspection.Status = 1
+		inspection.CreatedTime = time.Now().Unix()
+		inspection.UpdatedTime = time.Now().Unix()
+		inspection.UTime = inspect_date
+		inspection.HisUserId = his_user_id
+		err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+		if err != nil {
+			tx.Rollback()
+		}
+
+		//处理检验检查操作表里同步条数和状态
+		cur_num := Head.ReportInfoItemHandleNum + 1
+		Head.ReportInfoItemHandleNum = cur_num
+		handleType := 2 
+		if cur_num == Head.ReportInfoItemNum {
+			handleType = 1
+		}
+		middleReportHandle := models.MiddleReportHandle{
+			ID:							Head.ID,
+			ReportInfoItemHandleNum:	cur_num,
+			HandleType:					int64(handleType),
+			UpdatedTime:				time.Now().Unix(),
+		}
+		err = UpdateReportHandleListyOrgID(&middleReportHandle)
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+
+	tx.Commit()
+	return nil,nil,err
+}
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetItemID(org_id int64,project_name string,item_name string,project_id int64) (item_id int64 ,err error) {
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ? and item_name = ?", org_id,project_name,item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ItemId,err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id,project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+		utils.InfoLog("inspection_reference: %v",inspection_reference)
+		if inspection_reference.ItemId > 0 {
+			return inspection_reference.ItemId + 1,err
+		} else {
+			return project_id * 1000 + 1 ,err
+		}
+	}
+}
+
+// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+func GetProjectID(org_id int64,project_name string) (project_id int64 ,err error) {
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ?", org_id,project_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId,err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+		utils.InfoLog("inspection_reference: %v",inspection_reference)
+		if inspection_reference.ProjectId > 0 {
+			return inspection_reference.ProjectId + 1,err
+		} else {
+			return 18001,err
+		}
+	}
+}
+
+// 根据机构ID获取该机构所有病人的admission_number （住院号）
+func GetUserInfoByOrgID(org_id int64) (patients []models.Patients ,err error) {
+	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? and status = 1", org_id).Find(&patients).Error
+	return
+}
+
+// 根据机构ID获取该机构所有病人的admission_number （住院号）
+func GetUserInfoByAdmission(admission_number string,org_id int64) (patients models.Patients ,err error) {
+	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? and admission_number = ?  and status = 1", org_id,admission_number).First(&patients).Error
+	return
+}
+
+type HeadInfo struct {
+	ApplyNo        	string  `json:"applyNo"`
+	ReportId        string	`json:"reportId"`
+	Name       		string	`json:"name"`
+	Sex       		string	`json:"sex"`
+	Age 			string	`json:"age"`
+	Dept 			string	`json:"dept"`
+	BedNo 			string	`json:"bedNo"`
+	PatientId 		string	`json:"patientId"`
+	PatientPid 		string	`json:"patientPid"`
+	SampleNo 		float64	`json:"sampleNo"`
+	RequestTime 	string	`json:"requestTime"`
+	ExecuteTime 	string	`json:"executeTime"`
+	ReceiveTime 	string	`json:"receiveTime"`
+	Item 			string	`json:"item"`
+	CheckTime 		string	`json:"checkTime"`
+	PatientType 	string	`json:"patientType"`
+	RequestTimes 	string	`json:"request_time"`
+}
+
+type ReportInfo struct {
+	ReportId    string  `json:"reportId"`
+	ItemCode    string	`json:"itemCode"`
+	ItemName    string	`json:"itemName"`
+	StdCode     string	`json:"stdCode"`
+	Result 		string	`json:"result"`
+	Unit 		string	`json:"unit"`
+	SampleNo 	float64	`json:"sampleNo"`
+	Reference 	string	`json:"reference"`
+	Prompt 		string	`json:"prompt"`
+}
+
+func GetHead(patient_id string,start_time string,end_time string)(head []HeadInfo,str string){
+	Domain := "http://www.szlg2h.cn:9991/xuetoushi/head/getHead?"
+	apiurl := "patient_id=" + patient_id + "&check_time_start=" + start_time + "&check_time_end=" + end_time
+	apiurl = url.PathEscape(apiurl)
+	apiurl = Domain + apiurl
+	utils.InfoLog("url: %v",apiurl)
+	var respJSON []HeadInfo
+	httplib.Get(apiurl).ToJSON(&respJSON)
+	jsonStr, _ := json.Marshal(respJSON)
+	utils.InfoLog("请求患者检查头部数据接口返回数据: %v",string(jsonStr))
+	return respJSON,string(jsonStr)
+}
+
+func GetReport(report_id string)(head  []ReportInfo,str string){
+	Domain := "http://www.szlg2h.cn:9991/xuetoushi/detail/getDetail?"
+	apiurl := "report_id=" + report_id 
+	apiurl = url.PathEscape(apiurl)
+	apiurl = Domain + apiurl
+	
+	var respJSON []ReportInfo
+	httplib.Get(apiurl).ToJSON(&respJSON)
+	jsonStr, _ := json.Marshal(respJSON)
+	utils.InfoLog("请求患者检查详情数据接口返回数据: %v",string(jsonStr))
+	return respJSON,string(jsonStr)
+}

service/lis_service.go

@@ -0,0 +1,296 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	_"strconv"
+	"strings"
+	"time"
+	_"IC/utils"
+	_"fmt"
+	_"github.com/jinzhu/gorm"
+)
+
+// 获取备份库所有的医嘱信息
+func GetAllAdvice() (Advice []models.DoctorAdvice,err error) {
+	err = backupDb.Model(&models.DoctorAdvice{}).Offset(100000).Limit(10000).Find(&Advice).Error
+	return
+}
+
+// 修改医嘱信息
+func SyncAdvice(Advice *models.DoctorAdvice) error {
+	err := writeDb.Model(&models.DoctorAdvice{}).Updates(&Advice).Error
+	return err
+}
+
+// 查找有字段的机构 
+func GetfiledConfigOrg() (FiledConfig []models.FiledConfig,err error) {
+	db := readDb.Begin()
+	err = db.Table("xt_filed_config").Group("org_id").Select("org_id,module,filed_name").Where("org_id > 0").Scan(&FiledConfig).Error
+	return
+}
+
+// 查询系统字段 
+func GetfiledConfigSys() (FiledConfig []models.FiledConfig,err error) {
+	err = readDb.Model(&models.FiledConfig{}).Where("org_id = 0").Find(&FiledConfig).Error
+	return 
+}
+
+// 跟进查询条件查询结果
+func GetfiledConfigByOrgId(org_id int64,module int64,filed_name string)(FiledConfig models.FiledConfig,err error) {
+	err = readDb.Model(&models.FiledConfig{}).Where("org_id = ? and module = ? and filed_name = ?",org_id,module,filed_name).First(&FiledConfig).Error
+	return 
+}
+
+// 创建一条字段数据详情
+func CreatefiledConfig(FiledConfig *models.FiledConfig) error {
+	err := writeDb.Create(&FiledConfig).Error
+	return err
+}
+
+// 从机构将数据同步到中间库
+func SyncInspectionReference(data *models.MiddleInspectionReference) error {
+	tx := writeDb.Begin()
+	var inspection_reference models.InspectionReference
+	var total int
+	err = readDb.Model(&models.InspectionReference{}).Where("org_id = ? and project_id = ? and item_id = ?  and status = 1", data.OrgId, data.ProjectId,data.ItemId).Find(&inspection_reference).Count(&total).Error
+	if total <= 0 {
+		inspection_reference.OrgId = data.OrgId
+		inspection_reference.ProjectName = data.ProjectName
+		inspection_reference.Project = data.ProjectName
+		inspection_reference.ProjectId = data.ProjectId
+		inspection_reference.ItemName = data.ItemName
+		inspection_reference.ItemId = data.ItemId
+		inspection_reference.RangeType = data.RangeType
+		inspection_reference.RangeMin = data.RangeMin
+		inspection_reference.RangeMax = data.RangeMax
+		inspection_reference.RangeValue = data.RangeValue
+		inspection_reference.RangeOptions = data.RangeOptions
+		inspection_reference.Unit = data.Unit
+		inspection_reference.Status = 1
+		inspection_reference.CreatedTime = time.Now().Unix()
+		inspection_reference.UpdatedTime = time.Now().Unix()
+
+		err := tx.Model(&models.InspectionReference{}).Create(&inspection_reference).Error
+		if err != nil {
+			tx.Rollback()
+		}
+
+		data.IsSync = 1
+		data.SyncId = inspection_reference.ID
+		data.UpdatedTime = time.Now().Unix()
+		ierr := writeMiddleDb.Save(&data).Error
+		if ierr != nil {
+			tx.Rollback()
+		}
+	}
+	tx.Commit()
+	return err
+}
+
+// 从机构将数据同步到中间库
+func SyncInspection(data *models.MiddleInspection) error {
+	tx := writeDb.Begin()
+	var inspection models.Inspection
+	var total int
+	err = readDb.Model(&models.Inspection{}).Where("org_id = ? and project_id = ? and item_id = ? and patient_id =? and inspect_date=?  and status = 1", data.OrgId, data.ProjectId,data.ItemId,data.PatientId,data.InspectDate).Find(&inspection).Count(&total).Error
+	if total <= 0 {
+		inspection.OrgId = data.OrgId
+		inspection.PatientId = data.PatientId
+		inspection.ProjectName = data.ProjectName
+		// inspection.Project = data.ProjectName
+		inspection.ProjectId = data.ProjectId
+		inspection.ItemName = data.ItemName
+		inspection.ItemId = data.ItemId
+		inspection.InspectType = int64(data.InspectType)
+		inspection.InspectValue = data.InspectValue
+		inspection.InspectTips = data.InspectTips
+		inspection.InspectDate = data.RecordDate
+		inspection.Status = 1
+		inspection.CreatedTime = time.Now().Unix()
+		inspection.UpdatedTime = time.Now().Unix()
+
+		err := tx.Model(&models.Inspection{}).Create(&inspection).Error
+		if err != nil {
+			tx.Rollback()
+		}
+
+		data.IsSync = 1
+		data.SyncId = inspection.ID
+		data.UpdatedTime = time.Now().Unix()
+		ierr := writeMiddleDb.Save(&data).Error
+		if ierr != nil {
+			tx.Rollback()
+		}
+	}
+	tx.Commit()
+	return err
+}
+
+// 跟进org_id获取未同步的检验检查选项信息
+func GetSyncInspectionReferenceByOrgId(org_id int64) (InspectionReferences []models.MiddleInspectionReference,err error) {
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and is_sync = 0", org_id).Find(&InspectionReferences).Error
+	return
+}
+
+// 跟进org_id获取未同步的检验检查信息
+func GetSyncInspectionByOrgId(org_id int64) (Inspection []models.MiddleInspection,err error) {
+	err = readMiddleDb.Model(&models.MiddleInspection{}).Where("org_id = ? and status = 1 and is_sync = 0", org_id).Find(&Inspection).Error
+	return
+}
+
+// 修改一条同步数据详情
+func UpdateSyncInfo(syncInfo *models.MiddleSyncInfo) error {
+	err := writeMiddleDb.Save(&syncInfo).Error
+	return err
+}
+
+// 创建一条同步数据详情
+func CreateSyncInfo(syncInfo *models.MiddleSyncInfo) error {
+	err := writeMiddleDb.Create(&syncInfo).Error
+	return err
+}
+
+// 创建一条检验检查操作表数据
+func CreateReportHandle(report *models.MiddleReportHandle) error {
+	err := writeMiddleDb.Create(&report).Error
+	return err
+}
+
+// 根据机构ID获取该机构检验检查操作表里状态为0的数据
+func GetReportHandleListyOrgID(org_id int64) (report_handle_list []models.MiddleReportHandle ,err error){
+	err = readMiddleDb.Model(&models.MiddleReportHandle{}).Where("org_id = ?  and  handle_type = 0 ",  org_id).Find(&report_handle_list).Error
+	return
+}
+
+// 根据机构ID修改检验检查操作表里的数据
+func UpdateReportHandleListyOrgID(report_handle *models.MiddleReportHandle)  error{
+	err := writeMiddleDb.Model(&models.MiddleReportHandle{}).Updates(&report_handle).Error
+	return err
+}
+
+// 跟进机构ID获取该机构所有病人的his_user_id
+func GetHisUserIdByOrgID(org_id int64) (patients []models.MiddlePatients ,err error) {
+	err = readMiddleDb.Model(&models.MiddlePatients{}).Where("user_org_id = ? and status = 1", org_id).Find(&patients).Error
+	return
+}
+
+// 根据机构ID获取该机构上次同步信息
+func GetSyncTimeByOrgID(org_id int64,his_user_id string) (sync_info models.MiddleSyncInfo ,err error){
+	err = readMiddleDb.Model(&models.MiddleSyncInfo{}).Where("org_id = ?  and  his_user_id =? ",  org_id,his_user_id).Last(&sync_info).Error
+	return
+}
+
+// 根据机构ID获取该机构上次同步信息
+func GetSyncTimeByOrgIDForYs(org_id int64) (sync_info models.MiddleSyncInfo ,err error){
+	err = readMiddleDb.Model(&models.MiddleSyncInfo{}).Where("org_id = ? ",  org_id).Last(&sync_info).Error
+	return
+}
+
+// 根据机构ID和His_useer_id获取该患者最后一条同步检查数据
+func GetInspectionLastInfoByOrgID(org_id int64,his_user_id string) (inspectionLastInfo models.MiddleInspection ,err error){
+	err = readMiddleDb.Model(&models.MiddleInspection{}).Where("org_id = ?  and  his_user_id =? ",  org_id,his_user_id).Order("created_time desc").First(&inspectionLastInfo).Error
+	return
+}
+
+// 从机构将数据同步到中间库
+func Sync(data *models.TBLISItem,org_id int64,patient_id int64)(*models.MiddleInspectionReference,*models.MiddleInspection,error) {
+	tx := writeMiddleDb.Begin()
+	var inspection models.MiddleInspection
+	var inspection_reference models.MiddleInspectionReference
+	recordDateStr := data.UTime
+	if len(data.UTime) == 0 { 
+		recordDateStr = time.Now().Format("2006-01-02 15:04")
+	}
+	record_date, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", recordDateStr)
+	// date, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", recordDateStr)
+	// record_date,_ := utils.ParseTimeStringToTime("2006-01-02", date.Format("2006-01-02"))
+	var total int
+	var itotal int
+	if len(data.RangeOptions) > 0 {
+		data.ItemType = 2
+	} else {
+		data.ItemType = 1
+		if len(data.RangeMax) > 0 {
+			Range := strings.Split(data.RangeMax,"-")
+			if len(Range) > 1 {
+				data.RangeMin = Range[0]
+				data.RangeMax = Range[1] 
+			} else {
+				data.RangeMin = Range[0]
+			}
+		}
+	}
+
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and project_id = ? and item_id = ? and status = 1", org_id, data.ProjectId,data.ItemId).Find(&inspection_reference).Count(&total).Error
+	if total <= 0 && len(data.ProjectName) > 0 {
+		inspection_reference.OrgId = org_id
+		inspection_reference.ProjectName = data.ProjectName
+		inspection_reference.Project = data.ProjectName
+		inspection_reference.ProjectId = data.ProjectId
+		inspection_reference.ItemName = data.ItemName
+		inspection_reference.ItemId = data.ItemId
+		inspection_reference.RangeType = data.ItemType
+		inspection_reference.RangeMin = data.RangeMin
+		inspection_reference.RangeMax = data.RangeMax
+		inspection_reference.RangeValue = data.RangeValue
+		inspection_reference.RangeOptions = data.RangeMax
+		inspection_reference.Unit = data.Unit
+		inspection_reference.Status = 1
+		inspection_reference.CreatedTime = time.Now().Unix()
+		inspection_reference.UpdatedTime = time.Now().Unix()
+		inspection_reference.InspectDate = data.InspectDate
+		inspection_reference.UTime = data.UTime
+		err := tx.Model(&models.MiddleInspectionReference{}).Create(&inspection_reference).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+
+	err = readMiddleDb.Model(&models.MiddleInspection{}).Where("org_id = ? and project_id = ? and item_id = ? and record_date = ? and patient_id = ?  and status = 1", org_id, data.ProjectId,data.ItemId,record_date.Unix(),patient_id).Find(&inspection).Count(&itotal).Error
+	if itotal <= 0 {
+		inspection.PatientId = patient_id
+		inspection.OrgId = org_id
+		inspection.ProjectId = data.ProjectId
+		inspection.ItemName = data.ItemName
+		inspection.ProjectName = data.ProjectName
+		inspection.InspectType = data.ItemType
+		inspection.ItemId = data.ItemId
+		if data.ItemType == 1 {
+			inspection.InspectValue = data.ItemValue
+		} else {
+			inspection.InspectValue = data.RangeValue
+		}
+		inspection.InspectDate = data.InspectDate
+		inspection.RecordDate = record_date.Unix()
+		inspection.Status = 1
+		inspection.CreatedTime = time.Now().Unix()
+		inspection.UpdatedTime = time.Now().Unix()
+		inspection.UTime = data.UTime
+		inspection.HisUserId = data.HisUserId
+		err := tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+
+	tx.Commit()
+	return &inspection_reference,&inspection,err
+}
+
+//GetPatientList 返回患者的列表
+func GetList(his_user_id []interface{},syncTimes string) (lis []*models.TBLISItem,  err error) {
+	err = readRemoteDb.Model(&models.TBLISItem{}).Where("u_time > ? AND his_user_id in (?)  ",syncTimes,his_user_id).Find(&lis).Error
+	return
+}
+
+//GetPatientList 返回患者的列表
+func GetListByHisUserID(his_user_id string,syncTimes string,selectType int64) (lis []*models.TBLISItem,err error) {
+	if selectType == 1 {
+	 	err = readRemoteDb.Model(&models.TBLISItem{}).Where("u_time > ? AND patient_name = ?  ",syncTimes,his_user_id).Find(&lis).Error
+	 } else {
+		err = readRemoteDb.Model(&models.TBLISItem{}).Where("u_time > ? AND his_user_id = ? ",syncTimes,his_user_id).Find(&lis).Error
+	 }
+	return
+}
+

service/redis.go

@@ -0,0 +1,20 @@
+package service
+
+import (
+	"fmt"
+
+	"github.com/astaxie/beego"
+	"github.com/go-redis/redis"
+)
+
+func RedisClient() *redis.Client {
+	address := fmt.Sprintf("%s:%s", beego.AppConfig.String("redishost"), beego.AppConfig.String("redisport"))
+	client := redis.NewClient(&redis.Options{
+		Addr:     address,
+		Password: beego.AppConfig.String("redispasswrod"), // no password set
+		DB:       0,                                       // use default DB
+	})
+	pong, err := client.Ping().Result()
+	fmt.Println(pong, err)
+	return client
+}

static/js/reload.min.js

@@ -0,0 +1 @@
+function b(a){var c=new WebSocket(a);c.onclose=function(){setTimeout(function(){b(a)},2E3)};c.onmessage=function(){location.reload()}}try{if(window.WebSocket)try{b("ws://localhost:12450/reload")}catch(a){console.error(a)}else console.log("Your browser does not support WebSockets.")}catch(a){console.error("Exception during connecting to Reload:",a)};

tests/default_test.go

@@ -0,0 +1,39 @@
+package test
+
+import (
+	"net/http"
+	"net/http/httptest"
+	"testing"
+	"runtime"
+	"path/filepath"
+	_ "IC/routers"
+
+	"github.com/astaxie/beego"
+	. "github.com/smartystreets/goconvey/convey"
+)
+
+func init() {
+	_, file, _, _ := runtime.Caller(1)
+	apppath, _ := filepath.Abs(filepath.Dir(filepath.Join(file, ".." + string(filepath.Separator))))
+	beego.TestBeegoInit(apppath)
+}
+
+
+// TestBeego is a sample to run an endpoint test
+func TestBeego(t *testing.T) {
+	r, _ := http.NewRequest("GET", "/", nil)
+	w := httptest.NewRecorder()
+	beego.BeeApp.Handlers.ServeHTTP(w, r)
+
+	beego.Trace("testing", "TestBeego", "Code[%d]\n%s", w.Code, w.Body.String())
+
+	Convey("Subject: Test Station Endpoint\n", t, func() {
+	        Convey("Status Code Should Be 200", func() {
+	                So(w.Code, ShouldEqual, 200)
+	        })
+	        Convey("The Result Should Not Be Empty", func() {
+	                So(w.Body.Len(), ShouldBeGreaterThan, 0)
+	        })
+	})
+}
+

utils/ip_helper.go

@@ -0,0 +1,13 @@
+package utils
+
+import (
+	"net/http"
+)
+
+func GetIP(r *http.Request) string {
+	ip := r.Header.Get("X-Forwarded-For")
+	if ip == "" {
+		ip = r.RemoteAddr
+	}
+	return ip
+}

utils/log.go

@@ -0,0 +1,66 @@
+package utils
+
+import (
+	"fmt"
+	"time"
+)
+
+const (
+	color_red = uint8(iota + 91)
+	color_green
+	color_yellow
+	color_blue
+	color_magenta //洋红
+
+	// info = "[INFO]"
+	// trac = "[TRAC]"
+	// erro = "[ERRO]"
+	// warn = "[WARN]"
+	// succ = "[SUCC]"
+)
+
+// 根据 https://github.com/liyu4/chill 修改的
+// see complete color rules in document in https://en.wikipedia.org/wiki/ANSI_escape_code#cite_note-ecma48-13
+func TraceLog(format string, a ...interface{}) {
+	fmt.Println(formatLog(yellow(fmt.Sprintf(format, a...))))
+}
+
+func InfoLog(format string, a ...interface{}) {
+	fmt.Println(formatLog(blue(fmt.Sprintf(format, a...))))
+}
+
+func SuccessLog(format string, a ...interface{}) {
+	fmt.Println(formatLog(green(fmt.Sprintf(format, a...))))
+}
+
+func WarningLog(format string, a ...interface{}) {
+	fmt.Println(formatLog(magenta(fmt.Sprintf(format, a...))))
+}
+
+func ErrorLog(format string, a ...interface{}) {
+	fmt.Println(formatLog(red(fmt.Sprintf(format, a...))))
+}
+
+func red(s string) string {
+	return fmt.Sprintf("\x1b[%dm%s\x1b[0m", color_red, s)
+}
+
+func green(s string) string {
+	return fmt.Sprintf("\x1b[%dm%s\x1b[0m", color_green, s)
+}
+
+func yellow(s string) string {
+	return fmt.Sprintf("\x1b[%dm%s\x1b[0m", color_yellow, s)
+}
+
+func blue(s string) string {
+	return fmt.Sprintf("\x1b[%dm%s\x1b[0m", color_blue, s)
+}
+
+func magenta(s string) string {
+	return fmt.Sprintf("\x1b[%dm%s\x1b[0m", color_magenta, s)
+}
+
+func formatLog(prefix string) string {
+	return time.Now().Format("[2006/01/02 15:04:05]") + " " + prefix + " "
+}

utils/paginator.go

@@ -0,0 +1,191 @@
+// Copyright 2013 wetalk authors
+//
+// Licensed under the Apache License, Version 2.0 (the "License"): you may
+// not use this file except in compliance with the License. You may obtain
+// a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+// WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+// License for the specific language governing permissions and limitations
+// under the License.
+
+package utils
+
+import (
+	"math"
+	"net/http"
+	"net/url"
+	"strconv"
+)
+
+type Paginator struct {
+	Request     *http.Request
+	PerPageNums int
+	MaxPages    int
+
+	nums      int64
+	pageRange []int
+	pageNums  int
+	page      int
+}
+
+func (p *Paginator) PageNums() int {
+	if p.pageNums != 0 {
+		return p.pageNums
+	}
+	pageNums := math.Ceil(float64(p.nums) / float64(p.PerPageNums))
+	if p.MaxPages > 0 {
+		pageNums = math.Min(pageNums, float64(p.MaxPages))
+	}
+	p.pageNums = int(pageNums)
+	return p.pageNums
+}
+
+func (p *Paginator) Nums() int64 {
+	return p.nums
+}
+
+func (p *Paginator) SetNums(nums int64) {
+	p.nums = nums
+}
+
+func (p *Paginator) Page() int {
+	if p.page != 0 {
+		return p.page
+	}
+	if p.Request.Form == nil {
+		p.Request.ParseForm()
+	}
+	p.page, _ = strconv.Atoi(p.Request.Form.Get("page"))
+	if p.page > p.PageNums() {
+		p.page = p.PageNums()
+	}
+	if p.page <= 0 {
+		p.page = 1
+	}
+	return p.page
+}
+
+func (p *Paginator) Pages() []int {
+	if p.pageRange == nil && p.nums > 0 {
+		var pages []int
+		pageNums := p.PageNums()
+		page := p.Page()
+		switch {
+		case page >= pageNums-4 && pageNums > 9:
+			start := pageNums - 9 + 1
+			pages = make([]int, 9)
+			for i, _ := range pages {
+				pages[i] = start + i
+			}
+		case page >= 5 && pageNums > 9:
+			start := page - 5 + 1
+			pages = make([]int, int(math.Min(9, float64(page+4+1))))
+			for i, _ := range pages {
+				pages[i] = start + i
+			}
+		default:
+			pages = make([]int, int(math.Min(9, float64(pageNums))))
+			for i, _ := range pages {
+				pages[i] = i + 1
+			}
+		}
+		p.pageRange = pages
+	}
+	return p.pageRange
+}
+
+func (p *Paginator) PageLink(page int) string {
+	link, _ := url.ParseRequestURI(p.Request.RequestURI)
+	values := link.Query()
+	if page == 1 {
+		values.Del("page")
+	} else {
+		values.Set("page", strconv.Itoa(page))
+	}
+	link.RawQuery = values.Encode()
+	return link.String()
+}
+
+func (p *Paginator) PageParams() url.Values {
+	link, _ := url.ParseRequestURI(p.Request.RequestURI)
+	values := link.Query()
+	values.Del("page")
+	return values
+}
+
+func (p *Paginator) BasePageLink() string {
+	link, _ := url.ParseRequestURI(p.Request.RequestURI)
+	values := link.Query()
+	values.Del("page")
+	link.RawQuery = values.Encode()
+	return link.String()
+}
+
+func (p *Paginator) PageLinkPrev() (link string) {
+	if p.HasPrev() {
+		link = p.PageLink(p.Page() - 1)
+	}
+	return
+}
+
+func (p *Paginator) PageLinkNext() (link string) {
+	if p.HasNext() {
+		link = p.PageLink(p.Page() + 1)
+	}
+	return
+}
+
+func (p *Paginator) PageLinkFirst() (link string) {
+	return p.PageLink(1)
+}
+
+func (p *Paginator) PageLinkLast() (link string) {
+	return p.PageLink(p.PageNums())
+}
+
+func (p *Paginator) HasPrev() bool {
+	return p.Page() > 1
+}
+
+func (p *Paginator) HasNext() bool {
+	return p.Page() < p.PageNums()
+}
+
+func (p *Paginator) IsActive(page int) bool {
+	return p.Page() == page
+}
+
+func (p *Paginator) Offset() int {
+	return (p.Page() - 1) * p.PerPageNums
+}
+
+func (p *Paginator) HasPages() bool {
+	return p.PageNums() > 1
+}
+
+func (p *Paginator) Total() int {
+	return p.PageNums()
+}
+func (p *Paginator) TotalSubOne() int {
+	return p.PageNums() - 1
+}
+
+func NewPaginator(req *http.Request, per int, nums int64) *Paginator {
+	p := Paginator{}
+	p.Request = req
+	if per <= 0 {
+		per = 10
+	}
+	p.PerPageNums = per
+	p.SetNums(nums)
+	return &p
+}
+
+func FakePaginator(currentPage int, per int, nums int64) *Paginator {
+	fakeReq, _ := http.NewRequest("GET", "/?page="+strconv.Itoa(currentPage), nil)
+	return NewPaginator(fakeReq, per, nums)
+}

utils/regex_helper.go

@@ -0,0 +1,75 @@
+package utils
+
+import (
+	"fmt"
+	"regexp"
+)
+
+// 正整数正则
+func PositiveIntegerRegexp() *regexp.Regexp {
+	reg, _ := regexp.Compile("^[1-9][0-9]*$")
+	return reg
+}
+
+// 手机号正则 不那么严谨的
+func CellPhoneRegexp() *regexp.Regexp {
+	reg, _ := regexp.Compile("^1\\d{10}$")
+	return reg
+}
+
+// 固话正则
+func TelPhoneRegexp() *regexp.Regexp {
+	// reg, _ := regexp.Compile("^0\\d{2,3}-?\\d{7,8}$")
+	reg, _ := regexp.Compile("^0\\d{2,3}-?\\d{7,8}$")
+	return reg
+}
+
+// 手机号或固话正则
+func PhoneRegexp() *regexp.Regexp {
+	reg, _ := regexp.Compile("^(0\\d{2,3}-?\\d{7,8}$)|(1\\d{10}$)")
+	return reg
+}
+
+// tests
+func PositiveIntegerRegexpTest() {
+	reg := PositiveIntegerRegexp()
+	fmt.Println("12 是否匹配：", reg.MatchString("12"))
+	fmt.Println("1 是否匹配：", reg.MatchString("1"))
+	fmt.Println("980030 是否匹配：", reg.MatchString("980030"))
+	fmt.Println("01 是否匹配：", reg.MatchString("01"))
+	fmt.Println("asd1asd 是否匹配：", reg.MatchString("asd1asd"))
+	fmt.Println("a12 是否匹配：", reg.MatchString("a12"))
+	fmt.Println("12a 是否匹配：", reg.MatchString("12a"))
+	fmt.Println("-12 是否匹配：", reg.MatchString("-12"))
+	fmt.Println("12.1 是否匹配：", reg.MatchString("12.1"))
+	fmt.Println("14j2a 是否匹配：", reg.MatchString("14j2a"))
+}
+
+func CellPhoneRegexpTest() {
+	reg := CellPhoneRegexp()
+	fmt.Println("13632250447 是否匹配：", reg.MatchString("13632250447"))
+	fmt.Println("12000000000 是否匹配：", reg.MatchString("12000000000"))
+	fmt.Println("30001212325 是否匹配：", reg.MatchString("30001212325"))
+	fmt.Println("1233123 是否匹配：", reg.MatchString("1233123"))
+	fmt.Println("123312312344 是否匹配：", reg.MatchString("123312312344"))
+	fmt.Println("13345678a12 是否匹配：", reg.MatchString("13345678a12"))
+	fmt.Println("a13345678a1 是否匹配：", reg.MatchString("a13345678a1"))
+	fmt.Println("1334a678a12 是否匹配：", reg.MatchString("1334a678a12"))
+	fmt.Println("1345678a12a 是否匹配：", reg.MatchString("1345678a12a"))
+	fmt.Println("aqwertyuioo 是否匹配：", reg.MatchString("aqwertyuioo"))
+}
+
+func TelPhoneRegexpTest() {
+	reg := TelPhoneRegexp()
+	fmt.Println("020-39006917 是否匹配：", reg.MatchString("020-39006917"))
+	fmt.Println("02039006917 是否匹配：", reg.MatchString("02039006917"))
+	fmt.Println("0754-5916612 是否匹配：", reg.MatchString("0754-5916612"))
+	fmt.Println("07545916612 是否匹配：", reg.MatchString("07545916612"))
+	fmt.Println("123-39006917 是否匹配：", reg.MatchString("123-39006917"))
+	fmt.Println("1754-5916612 是否匹配：", reg.MatchString("1754-5916612"))
+	fmt.Println("0a0-39006917 是否匹配：", reg.MatchString("0a0-39006917"))
+	fmt.Println("0a039006917 是否匹配：", reg.MatchString("0a039006917"))
+	fmt.Println("010-39s06917 是否匹配：", reg.MatchString("010-39s06917"))
+	fmt.Println("020-390069171 是否匹配：", reg.MatchString("020-390069171"))
+	fmt.Println("020-3900691 是否匹配：", reg.MatchString("020-3900691"))
+}

utils/stringtool.go

@@ -0,0 +1,115 @@
+package utils
+
+import (
+	"bytes"
+	"crypto/aes"
+	"crypto/cipher"
+	"crypto/md5"
+	"encoding/base64"
+	"fmt"
+	"math/rand"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+)
+
+// 将字符串加密成 md5
+func String2md5(str string) string {
+	data := []byte(str)
+	has := md5.Sum(data)
+	return fmt.Sprintf("%x", has) //将[]byte转成16进制
+}
+
+// RandomString 在数字、大写字母、小写字母范围内生成num位的随机字符串
+func RandomString(length int) string {
+	// 48 ~ 57 数字
+	// 65 ~ 90 A ~ Z
+	// 97 ~ 122 a ~ z
+	// 一共62个字符，在0~61进行随机，小于10时，在数字范围随机，
+	// 小于36在大写范围内随机，其他在小写范围随机
+	rand.Seed(time.Now().UnixNano())
+	result := make([]string, 0, length)
+	for i := 0; i < length; i++ {
+		t := rand.Intn(62)
+		if t < 10 {
+			result = append(result, strconv.Itoa(rand.Intn(10)))
+		} else if t < 36 {
+			result = append(result, string(rand.Intn(26)+65))
+		} else {
+			result = append(result, string(rand.Intn(26)+97))
+		}
+	}
+	return strings.Join(result, "")
+}
+
+func RandomNumberString(length int) string {
+	var str string
+	for i := 0; i < length; i++ {
+		rand.Seed(time.Now().UnixNano())
+		str += strconv.Itoa(rand.Intn(10))
+	}
+	return str
+}
+
+// AES加密
+func AESEncrypt(origin string) string {
+	aes_key := beego.AppConfig.String("aes_key")
+	fmt.Println(aes_key)
+	xpass, _ := _aesEncrypt([]byte(origin), []byte(aes_key))
+	fmt.Println(_aesEncrypt([]byte(origin), []byte(aes_key)))
+	fmt.Println(xpass)
+	pass64 := base64.StdEncoding.EncodeToString(xpass)
+	fmt.Println(pass64)
+	return pass64
+}
+
+func AESDecrypt(crypted []byte) string {
+	aes_key := beego.AppConfig.String("aes_key")
+	origData, err := _aesDecrypt(crypted, []byte(aes_key))
+	if err != nil {
+		return ""
+	}
+	return string(origData)
+}
+
+func _PKCS5Padding(ciphertext []byte, blockSize int) []byte {
+	padding := blockSize - len(ciphertext)%blockSize
+	padtext := bytes.Repeat([]byte{byte(padding)}, padding)
+	return append(ciphertext, padtext...)
+}
+
+func _PKCS5UnPadding(origData []byte) []byte {
+	length := len(origData)
+	unpadding := int(origData[length-1])
+	return origData[:(length - unpadding)]
+}
+
+func _aesEncrypt(origData, key []byte) ([]byte, error) {
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		return nil, err
+	}
+
+	blockSize := block.BlockSize()
+	origData = _PKCS5Padding(origData, blockSize)
+	blockMode := cipher.NewCBCEncrypter(block, key[:blockSize])
+	crypted := make([]byte, len(origData))
+	blockMode.CryptBlocks(crypted, origData)
+	return crypted, nil
+}
+
+func _aesDecrypt(crypted, key []byte) ([]byte, error) {
+	block, err := aes.NewCipher(key)
+	if err != nil {
+		return nil, err
+	}
+
+	blockSize := block.BlockSize()
+	blockMode := cipher.NewCBCDecrypter(block, key[:blockSize])
+	origData := make([]byte, len(crypted))
+	blockMode.CryptBlocks(origData, crypted)
+	origData = _PKCS5UnPadding(origData)
+	return origData, nil
+}

utils/time_helper.go

@@ -0,0 +1,27 @@
+package utils
+
+import (
+	"time"
+)
+
+// day 当天凌晨0点
+func ZeroHourTimeOfDay(day time.Time) time.Time {
+	dayStr := day.Format("2006-01-02")
+	zeroHourTime, _ := ParseTimeStringToTime("2006-01-02", dayStr)
+	return *zeroHourTime
+}
+
+// day 当月一号凌晨0点
+func BeginningOfMonth(day time.Time) time.Time {
+	dayStr := day.Format("2006-01")
+	monthTime, _ := ParseTimeStringToTime("2006-01", dayStr)
+	return *monthTime
+}
+
+// 指定年月的月份的月初凌晨0点和月末23点59分59秒
+func MonthBeginningToEnd(year int, month int) (time.Time, time.Time) {
+	beginningOfMonth := time.Date(year, time.Month(month), 1, 0, 0, 0, 0, time.Local)
+	beginningOfNextMonth := beginningOfMonth.AddDate(0, 1, 0)
+	endOfMonth := beginningOfNextMonth.Add(time.Duration(-1))
+	return beginningOfMonth, endOfMonth
+}

utils/tools.go

@@ -0,0 +1,231 @@
+package utils
+
+import (
+	"crypto/sha1"
+	"encoding/base64"
+	"errors"
+	"fmt"
+	"io"
+	"math/rand"
+	"regexp"
+	"sort"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/astaxie/beego"
+)
+
+func TimeSub(t1, t2 time.Time) int {
+	t1 = time.Date(t1.Year(), t1.Month(), t1.Day(), 0, 0, 0, 0, time.Local)
+	t2 = time.Date(t2.Year(), t2.Month(), t2.Day(), 0, 0, 0, 0, time.Local)
+
+	return int(t1.Sub(t2).Hours() / 24)
+}
+
+func MarkBackUrl(backUrl, defaultUrl string) string {
+	if len(backUrl) == 0 {
+		backUrl = defaultUrl
+	} else {
+		backURLByte, err := base64.URLEncoding.DecodeString(backUrl)
+		if err != nil {
+			backUrl = backUrl
+		} else {
+			backUrl = string(backURLByte)
+		}
+	}
+	return backUrl
+}
+
+func CheckMobile(mobile string) (match bool) {
+
+	//过滤手机
+	match, _ = regexp.MatchString("^1([358][0-9]|4[579]|66|7[0135678]|9[89])[0-9]{8}$", mobile)
+	return
+}
+
+func RandCode(min, max int64) string {
+	if min >= max || min == 0 || max == 0 {
+		return strconv.FormatInt(max, 10)
+	}
+	rand.Seed(time.Now().UnixNano())
+	randNum := rand.Int63n(max-min) + min
+	return strconv.FormatInt(randNum, 10)
+}
+
+func TimeAgo(timeUnix int64) string {
+	timeUnixS := time.Unix(timeUnix, 0)
+	timeNow := time.Now()
+	timeSub := timeNow.Sub(timeUnixS)
+
+	if timeSub < time.Minute*1 {
+		return "刚刚"
+	} else if timeSub < time.Hour*1 {
+		return strconv.Itoa(int(timeSub.Minutes())) + "分钟前"
+	} else if timeSub < time.Hour*24 {
+		return strconv.Itoa(int(timeSub.Hours())) + "小时前"
+	} else if timeSub < time.Hour*24*7 {
+		return strconv.Itoa(int(timeSub.Hours()/24)) + "天前"
+	} else {
+		return timeUnixS.Format("2006-01-02 15:04")
+	}
+	return ""
+}
+
+//Signature sha1签名
+func Signature(params ...string) string {
+	sort.Strings(params)
+	h := sha1.New()
+	for _, s := range params {
+		io.WriteString(h, s)
+	}
+	return fmt.Sprintf("%x", h.Sum(nil))
+}
+
+//RandomStr 随机生成字符串
+func RandomStr(length int) string {
+	str := "0123456789abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
+	bytes := []byte(str)
+	result := []byte{}
+	r := rand.New(rand.NewSource(time.Now().UnixNano()))
+	for i := 0; i < length; i++ {
+		result = append(result, bytes[r.Intn(len(bytes))])
+	}
+	return string(result)
+}
+
+//GetCurrTs return current timestamps
+func GetCurrTs() int64 {
+	return time.Now().Unix()
+}
+
+func SetThisRequestURI(uri string) string {
+	return fmt.Sprintf("%v%v", beego.AppConfig.String("httpdomain"), uri)
+}
+
+func SetThisBasr64RequestURI(uri string) string {
+	backUrl := fmt.Sprintf("%v%v", beego.AppConfig.String("httpdomain"), uri)
+	backUrl = base64.URLEncoding.EncodeToString([]byte(backUrl))
+
+	return backUrl
+}
+
+func TransNum2Str(read int64) (transRead string) {
+	if read < 0 {
+		transRead = "0"
+	} else if read < 10000 {
+		transRead = fmt.Sprintf("%v", read)
+	} else {
+		var c float64 = 10000
+		var rc float64 = float64(read)
+		transRead = fmt.Sprintf("%.2f万", rc/c)
+	}
+
+	return
+}
+
+func GenMobileToken(mobile string) (token string) {
+	st := strings.Split(mobile, "")
+
+	s := fmt.Sprintf("%s%v%v%v%v%v%v", mobile, st[0], st[1], st[3], st[7], st[6], st[9])
+
+	h := sha1.New()
+	h.Write([]byte(s))
+	bs := h.Sum(nil)
+
+	token = fmt.Sprintf("%x", bs)
+
+	return
+}
+
+func CheckMobileToken(mobile, token string) bool {
+	o := GenMobileToken(mobile)
+	if token == o {
+		return true
+	}
+
+	return false
+}
+
+type jSapiConfig struct {
+	AppID     string `json:"app_id"`
+	Timestamp int64  `json:"timestamp"`
+	NonceStr  string `json:"nonce_str"`
+	Signature string `json:"signature"`
+}
+
+//GetAJTConfig jsapi_ticket config
+func GetAJTConfig(jsapiTicket, uri string) (jSapiConfig, error) {
+	var config jSapiConfig
+	nonceStr := RandomStr(16)
+	timestamp := GetCurrTs()
+	str := fmt.Sprintf("jsapi_ticket=%s&noncestr=%s&timestamp=%d&url=%s", jsapiTicket, nonceStr, timestamp, uri)
+	sigStr := Signature(str)
+
+	config.AppID = beego.AppConfig.String("wxappId")
+	config.NonceStr = nonceStr
+	config.Timestamp = timestamp
+	config.Signature = sigStr
+	return config, nil
+}
+
+func TrimHtml(src string) string {
+	//将HTML标签全转换成小写
+	re, _ := regexp.Compile("\\<[\\S\\s]+?\\>")
+	src = re.ReplaceAllStringFunc(src, strings.ToLower)
+	//去除STYLE
+	re, _ = regexp.Compile("\\<style[\\S\\s]+?\\</style\\>")
+	src = re.ReplaceAllString(src, "")
+	//去除SCRIPT
+	re, _ = regexp.Compile("\\<script[\\S\\s]+?\\</script\\>")
+	src = re.ReplaceAllString(src, "")
+	//去除所有尖括号内的HTML代码，并换成换行符
+	re, _ = regexp.Compile("\\<[\\S\\s]+?\\>")
+	src = re.ReplaceAllString(src, "\n")
+	//去除连续的换行符
+	re, _ = regexp.Compile("\\s{2,}")
+	src = re.ReplaceAllString(src, "\n")
+	return strings.TrimSpace(src)
+}
+
+func SubString(str string, begin, length int) string {
+	rs := []rune(str)
+	lth := len(rs)
+	if begin < 0 {
+		begin = 0
+	}
+	if begin >= lth {
+		begin = lth
+	}
+	end := begin + length
+
+	if end > lth {
+		end = lth
+	}
+	return string(rs[begin:end])
+}
+
+func ParseTimeStringToTime(layout string, timeStr string) (*time.Time, error) {
+	if len(layout) == 0 || len(timeStr) == 0 {
+		return nil, errors.New("layout 或 日期字符串 为空，无法解析")
+	}
+	loc, _ := time.LoadLocation("Local")
+	date, parseDateErr := time.ParseInLocation(layout, timeStr, loc)
+	return &date, parseDateErr
+}
+
+// 获取 date 所在周的周一和周日，以周一0点为一周的开始，周日24点为一周的结束
+func GetMondayAndSundayOfWeekDate(date *time.Time) (time.Time, time.Time) {
+	if date == nil {
+		now := time.Now()
+		date = &now
+	}
+	weekday := int(date.Weekday())
+	if weekday == 0 {
+		weekday = 7
+	}
+	loc, _ := time.LoadLocation("Local")
+	monday, _ := time.ParseInLocation("2006-01-02 15:04:05", date.AddDate(0, 0, 1-weekday).Format("2006-01-02")+" 00:00:00", loc)
+	sunday, _ := time.ParseInLocation("2006-01-02 15:04:05", date.AddDate(0, 0, 7-weekday).Format("2006-01-02")+" 23:59:59", loc)
+	return monday, sunday
+}