体积小

conf/app.conf

@@ -0,0 +1,119 @@
+appname = 小程序
+httpport = 9666
+runmode = dev
+
+copyrequestbody = true
+sessionon = true
+sessiongcmaxlifetime = 64800
+
+tokencookiemaxlifetime = 7200
+
+enablexsrf = false
+xsrfkey = 61oETzKXQAGaYdkL5gEmGeJJFuYh7EQnp2XdTP1o
+xsrfexpire = 3600
+
+qiniu_accesskey = -l_Pcc1YJs0gh3w0YwN2uoaZO_5fY5J9SIYnSjg0
+qiniu_secretkey = DmZSp_Bmnp-9aUB7xUvoyViZpzmx1Rs2RL69GvlW
+qiniu_domain = https://images.shengws.com/
+qiniu_bucket = syhclub-storage
+
+aes_key = "xuetou-201807319"
+
+wxtoken = gh_ac6cd0cdde3d
+wxoriId = gh_ac6cd0cdde3d
+wxappId = wxbb9223f20bc11612
+# wxappsecret = a78c793c377268db25dde2eb971a2ebb
+# wxEncodingAESKey = 1vRDzqltXYOc9iMqhsQT7AkIRRpUaGl8MZlUcP7x4UK
+
+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"
+
+
+sz_province = 19
+sz_city = 291
+
+
+
+[prod]
+httpdomain = http://api.szjkhd.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
+
+
+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
+
+redishost = 349e580b2a524290.redis.rds.aliyuncs.com
+redisport = 6379
+redispasswrod = TZtBW098WId3i27clkpj3q8dnUaVFP
+redisdb = 0
+
+
+
+
+
+[dev]
+httpdomain = http://api.szjkhd.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
+
+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
+
+redishost = 112.74.16.180
+redisport = 6379
+redispasswrod = syh@#$%123456!
+redisdb = 0
+
+

controllers/admin_api_controllers/admin_api_base_controller.go

@@ -0,0 +1,29 @@
+package admin_api_controllers
+
+import (
+	"Xcx_New/controllers"
+)
+
+type AdminBaseAPIController struct {
+	controllers.BaseAPIController
+}
+
+func (this *AdminBaseAPIController) ErrorLog(format string, a ...interface{}) {
+	//beego.Error(fmt.Sprintf("[管理员后台] %v", fmt.Sprintf(format, a...)))
+}
+
+func (this *AdminBaseAPIController) WarnLog(format string, a ...interface{}) {
+	//beego.Warn(fmt.Sprintf("[管理员后台] %v", fmt.Sprintf(format, a...)))
+}
+
+func (this *AdminBaseAPIController) InfoLog(format string, a ...interface{}) {
+	//beego.Info(fmt.Sprintf("[管理员后台] %v", fmt.Sprintf(format, a...)))
+}
+
+func (this *AdminBaseAPIController) DebugLog(format string, a ...interface{}) {
+	//beego.Debug(fmt.Sprintf("[管理员后台] %v", fmt.Sprintf(format, a...)))
+}
+
+func (this *AdminBaseAPIController) TraceLog(format string, a ...interface{}) {
+	//beego.Trace(fmt.Sprintf("[管理员后台] %v", fmt.Sprintf(format, a...)))
+}

controllers/admin_api_controllers/api_router_register.go

@@ -0,0 +1,9 @@
+package admin_api_controllers
+
+import "github.com/astaxie/beego"
+
+// 管理员后台路由，以 /admin/api 为前缀
+func AdminAPIControllersRegisterRouters() {
+	beego.Router("/data/upload/api/city", &CityDataUploadAPIController{}, "post:UploadCityData")
+
+}

controllers/admin_api_controllers/city_data_upload_api_controller.go

@@ -0,0 +1,11 @@
+package admin_api_controllers
+
+import "Data_Upload_Api/controllers"
+
+type CityDataUploadAPIController struct {
+	controllers.BaseAPIController
+}
+
+func (this *CityDataUploadAPIController) UploadCityData() {
+
+}

controllers/base_api_controller.go

@@ -0,0 +1,72 @@
+package controllers
+
+import (
+	"Data_Upload_Api/enums"
+)
+
+type BaseAPIController struct {
+	BaseController
+}
+
+// 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()
+}
+
+type BaseAuthAPIController struct {
+	BaseAPIController
+}
+
+func (this *BaseAuthAPIController) Prepare() {
+	this.BaseAPIController.Prepare()
+
+}
+
+type BaseServeAPIController struct {
+	BaseAPIController
+}
+
+func (this *BaseServeAPIController) Prepare() {
+	this.BaseAPIController.Prepare()
+
+}

controllers/base_controller.go

@@ -0,0 +1,29 @@
+package controllers
+
+import (
+	"github.com/astaxie/beego"
+)
+
+type BaseController struct {
+	beego.Controller
+}
+
+func (this *BaseController) ErrorLog(format string, a ...interface{}) {
+	//beego.Error(fmt.Sprintf(format, a...))
+}
+
+func (this *BaseController) WarnLog(format string, a ...interface{}) {
+	//beego.Warn(fmt.Sprintf(format, a...))
+}
+
+func (this *BaseController) InfoLog(format string, a ...interface{}) {
+	//beego.Info(fmt.Sprintf(format, a...))
+}
+
+func (this *BaseController) DebugLog(format string, a ...interface{}) {
+	//beego.Debug(fmt.Sprintf(format, a...))
+}
+
+func (this *BaseController) TraceLog(format string, a ...interface{}) {
+	//beego.Trace(fmt.Sprintf(format, a...))
+}

controllers/base_view_controller.go

@@ -0,0 +1,58 @@
+package controllers
+
+type BaseViewController struct {
+	BaseController
+}
+
+// 设置模板
+// 第一个参数模板，第二个参数为layout
+func (this *BaseViewController) SetTpl(template ...string) {
+	var tplName string
+	layout := ""
+	switch {
+	case len(template) == 1:
+		tplName = template[0]
+	case len(template) == 2:
+		tplName = template[0]
+		layout = template[1]
+	default:
+		tplName = "index.tpl"
+	}
+	this.Layout = layout
+	this.TplName = tplName
+}
+
+// 重定向
+func (this *BaseViewController) Redirect302(url string) {
+	this.Redirect(url, 302)
+	this.StopRun()
+}
+
+// 错误页面
+func (this *BaseViewController) Abort404() {
+	this.Abort("404")
+}
+
+// // 微信错误页面
+// func (this *BaseViewController) WxAbort404(title, desc string) {
+// 	this.Data["Title"] = title
+// 	this.Data["Desc"] = desc
+// 	this.SetTpl("view_wx/error/404.html")
+// }
+
+// type BaseAuthViewController struct {
+// 	BaseViewController
+// }
+
+// func (this *BaseAuthViewController) Prepare() {
+// 	this.BaseController.Prepare()
+// 	backUrl := utils.SetThisRequestURI(this.Ctx.Request.RequestURI)
+// 	backUrl = base64.URLEncoding.EncodeToString([]byte(backUrl))
+// 	if this.GetUserInfo() == nil {
+// 		if strings.HasPrefix(this.Ctx.Request.RequestURI, "/web/") {
+// 			this.Redirect302(beego.URLFor("WebLoginViewController.Login") + "?backUrl=" + backUrl)
+// 		} else {
+// 			this.Redirect302(beego.URLFor("WxLoginViewController.Login") + "?backUrl=" + backUrl)
+// 		}
+// 	}
+// }

controllers/mobile_api_controller.go

@@ -0,0 +1,20 @@
+package controllers
+
+import (
+	"fmt"
+	"github.com/astaxie/beego"
+)
+
+type MobileController struct {
+	BaseAPIController
+}
+
+func MobileRegisterRouters() {
+
+	beego.Router("/api/mobile/login", &MobileController{}, "Get:GetMobileLogin")
+}
+
+func (this *MobileController) GetMobileLogin() {
+
+	fmt.Println("出发多舒服的方式大发阿凡达")
+}

controllers/sync.go

@@ -0,0 +1,325 @@
+package controllers
+
+import (
+	"Data_Upload_Api/enums"
+	"Data_Upload_Api/models/sz"
+	"Data_Upload_Api/service"
+	"Data_Upload_Api/service/city"
+	"Data_Upload_Api/utils"
+	"fmt"
+	_ "fmt"
+	"github.com/astaxie/beego"
+	_ "github.com/jinzhu/gorm"
+	_ "math"
+	_ "strconv"
+	_ "strings"
+	_ "time"
+)
+
+type SyncController struct {
+	BaseAPIController
+}
+
+func SyncAPIRegisterRouters() {
+	beego.Router("/sync/upload/hqyy", &SyncController{}, "get:SyncToHqyy")
+	beego.Router("/sync/upload/lg2h", &SyncController{}, "get:SyncToLg2h")
+	beego.Router("/sync/upload/smzy", &SyncController{}, "get:SyncToSmzy")
+	beego.Router("/sync/upload/smyy", &SyncController{}, "get:SyncToTesgt")
+
+}
+
+func (c *SyncController) SyncToLg2h() {
+	// 第一步：到上报配置表中找到深圳需要上报的机构
+	// sz_province, _ := beego.AppConfig.Int64("sz_province")
+	// sz_city, _ := beego.AppConfig.Int64("sz_city")
+	// configs, _ := service.FindAllDataUploadConfigOrgInfo(sz_province, sz_city, 3)
+
+	org := &sz.DataUploadConfig{
+		OrgId:          9598,
+		ProvinceId:     19,
+		CityId:         291,
+		DepartmentName: "深圳市龙岗区第二人民医院",
+		HospitalId:     "455835506",
+		InstType:       1,
+		DbHost:         "183.62.158.36",
+		DbPort:         "61433",
+		DbPass:         "LG2H+9897",
+		DbUser:         "sa",
+		DbName:         "xtzk",
+	}
+
+	// for _, org := range configs {
+	// 第二步：跟进配置，创建数据库连接
+	if len(org.DbHost) > 0 && len(org.DbUser) > 0 && len(org.DbPort) > 0 && len(org.DbPass) > 0 && len(org.DbName) > 0 {
+		orgDb, err := service.CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+		if err != nil {
+			utils.ErrorLog("创建数据库连接失败:%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		fmt.Println("触发了没有22222222")
+		// 第三步：开始同步数据
+		// 同步医院信息  t_hd_hospital
+		// city.SyncHospital(orgDb, org.OrgId, org.HospitalId, org.InstType, org.DepartmentName)
+		// // 同步水处理器  t_hd_wm
+		// city.SyncWMS(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步员工 t_hd_staff
+		// city.SyncStaff(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步病人 t_hd_patient
+		// city.SyncPatient(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步排班  t_hd_shift
+		// city.SyncShift(orgDb, org.OrgId, org.HospitalId)
+		// // 同步处方 t_hd_ps
+		// city.SyncPs(orgDb, org.OrgId, org.HospitalId)
+		// // 同步处方药品 t_hd_ps
+		// city.SyncPsMedicine(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步转院信息 t_hd_patient_out
+		// city.SyncPatientOut(orgDb, org.OrgId, org.HospitalId)
+		// // 同步处方信息 t_hd_doctors_advice
+		// city.SyncDoctorAdvice(orgDb, org.OrgId, org.HospitalId)
+		// // 同步透中信息 t_hd_middle
+		// city.SyncMiddle(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步设备 t_hd_other_machine
+		// city.SyncOtherMachine(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步维修 t_hd_maintain
+		// city.SyncMachineRepair(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步设备 t_hd_dm
+		// city.SyncDM(orgDb, org.OrgId, org.HospitalId)
+		// // // 同步患者透析记录 t_hd_dialysis
+		// city.SyncDialysis(orgDb, org.OrgId, org.HospitalId)
+		// // 同步透析床位分区 t_hd_division
+		// city.SyncDivision(orgDb, org.OrgId, org.HospitalId)
+		// // 患者通路信息表（T_HD_ACCESS）
+		// city.SyncAccess(orgDb, org.OrgId, org.HospitalId)
+		// // 透析床位表（T_HD_SICKBED）
+		// city.SyncSickbed(orgDb, org.OrgId, org.HospitalId)
+		// // 患者诊断信息表（T_HD_DIAGNOSIS）
+		// city.SyncDiagnosis(orgDb, org.OrgId, org.HospitalId)
+		//  患者传染病检查记录表（T_HD_INFECTION
+		//city.SyncInfection(orgDb, org.OrgId, org.HospitalId)
+		// //  透析并发症记录表（T_HD_COMPLICATION）
+		// city.SyncComplication(orgDb, org.OrgId, org.HospitalId)
+		// //  血透患者检测结果表（T_HD_LIS_REPORT）
+		// city.SyncLisReport(orgDb, org.OrgId, org.HospitalId)
+		// //  血透患者检验结果指标表（T_HD_LIS_INDICATORS）
+		// city.SyncLisIndicators(orgDb, org.OrgId, org.HospitalId)
+
+		// 透析机透析液细菌培养检测记录表(t_hd_dm_dialysate_bc)
+		// city.SyncLisCulture(orgDb,org.OrgId,org.HospitalId)
+		//透析机透析液内毒素检测记录表(T_HD_DM_DIALYSATE_BC)
+		// city.SyncDialysate(orgDb,org.OrgId,org.HospitalId)
+
+		//物表消毒记录表(T_HD_SURFACE_DISINFECT)
+		// city.SyncLisBodyDetection(orgDb,org.OrgId,org.HospitalId)
+		// 第四步：关闭数据库连接
+
+		//透析用水游离氯检测表(T_HD_WATER_FC)
+		// city.SyncLisWaterFc(orgDb,org.OrgId,org.HospitalId)
+
+		//透析用水有毒化学物检测表(T_HD_WATER_NC)
+		// city.SynLisWaterNc(orgDb,org.OrgId,org.HospitalId)
+
+		//透析用水PH值检测表(T_HD_WATER_PH)
+		// city.SynLisWaterPh(orgDb,org.OrgId,org.HospitalId)
+
+		//透析用水水硬度检测表(T_HD_WATER_WH)
+		// city.SynListHadWater(orgDb,org.OrgId,org.HospitalId)
+
+		//导管感染记录表(T_HD_CI)
+		// city.SynListHdCi(orgDb,org.OrgId,org.HospitalId)
+
+		//导管感染转归记录表(T_HD_CI_OUTCOME)
+		// city.SynLisHdCiOutCome(orgDb,org.OrgId,org.HospitalId)
+
+		//透析室空气消毒记录表(T_HD_AIR_DISINFECT)
+		// city.SyncLisAirDetection(orgDb,org.OrgId,org.HospitalId)
+
+		//透析用水细菌培养检测表(T_HD_WATER_BC)
+		// city.SyncLisWaterBc(orgDb,org.OrgId,org.HospitalId)
+
+		//透析用水内毒素检测表(T_HD_WATER_EN)
+		// city.SyncLisWaterEn(orgDb,org.OrgId,org.HospitalId)
+		// 第四步：关闭数据库连接
+		service.CloseDB(orgDb)
+	}
+	// }
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *SyncController) SyncToHqyy() {
+	// 第一步：到上报配置表中找到深圳需要上报的机构
+	// sz_province, _ := beego.AppConfig.Int64("sz_province")
+	// sz_city, _ := beego.AppConfig.Int64("sz_city")
+	// configs, _ := service.FindAllDataUploadConfigOrgInfo(sz_province, sz_city, 3)
+
+	org := &sz.DataUploadConfig{
+		OrgId:          9442,
+		ProvinceId:     19,
+		CityId:         291,
+		DepartmentName: "暨南大学附属深圳华侨医院",
+		HospitalId:     "73307826X",
+		InstType:       1,
+		DbHost:         "183.11.232.26",
+		DbPort:         "3306",
+		DbPass:         "1Q2W3e4r!@#$",
+		DbUser:         "sa",
+		DbName:         "xtzk",
+	}
+
+	// for _, org := range configs {
+	// 第二步：跟进配置，创建数据库连接
+	if len(org.DbHost) > 0 && len(org.DbUser) > 0 && len(org.DbPort) > 0 && len(org.DbPass) > 0 && len(org.DbName) > 0 {
+		orgDb, err := service.CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+		if err != nil {
+			utils.ErrorLog("创建数据库连接失败:%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		// 第三步：开始同步数据
+		// 同步医院信息  t_hd_hospital
+		city.SyncHospital(orgDb, org.OrgId, org.HospitalId, org.InstType, org.DepartmentName)
+		// 同步水处理器  t_hd_wm
+		city.SyncWMS(orgDb, org.OrgId, org.HospitalId)
+		// // 同步员工 t_hd_staff
+		city.SyncStaff(orgDb, org.OrgId, org.HospitalId)
+		// // 同步病人 t_hd_patient
+		city.SyncPatient(orgDb, org.OrgId, org.HospitalId)
+		// // 同步排班  t_hd_shift
+		city.SyncShift(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方 t_hd_ps
+		city.SyncPs(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方药品 t_hd_ps
+		city.SyncPsMedicine(orgDb, org.OrgId, org.HospitalId)
+		// // 同步转院信息 t_hd_patient_out
+		city.SyncPatientOut(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方信息 t_hd_doctors_advice
+		city.SyncDoctorAdvice(orgDb, org.OrgId, org.HospitalId)
+		// 同步透中信息 t_hd_middle
+		city.SyncMiddle(orgDb, org.OrgId, org.HospitalId)
+		// // 同步设备 t_hd_other_machine
+		city.SyncOtherMachine(orgDb, org.OrgId, org.HospitalId)
+		// // 同步维修 t_hd_maintain
+		city.SyncMachineRepair(orgDb, org.OrgId, org.HospitalId)
+		// // 同步设备 t_hd_dm
+		city.SyncDM(orgDb, org.OrgId, org.HospitalId)
+		// // 同步患者透析记录 t_hd_dialysis
+		city.SyncDialysis(orgDb, org.OrgId, org.HospitalId)
+		// 同步透析床位分区 t_hd_division
+		city.SyncDivision(orgDb, org.OrgId, org.HospitalId)
+		// 患者通路信息表（T_HD_ACCESS）
+		city.SyncAccess(orgDb, org.OrgId, org.HospitalId)
+		// 透析床位表（T_HD_SICKBED）
+		city.SyncSickbed(orgDb, org.OrgId, org.HospitalId)
+		// 患者诊断信息表（T_HD_DIAGNOSIS）
+		city.SyncDiagnosis(orgDb, org.OrgId, org.HospitalId)
+		//  患者传染病检查记录表（T_HD_INFECTION
+		city.SyncInfection(orgDb, org.OrgId, org.HospitalId)
+		//  透析并发症记录表（T_HD_COMPLICATION）
+		city.SyncComplication(orgDb, org.OrgId, org.HospitalId)
+		//  血透患者检测结果表（T_HD_LIS_REPORT）
+		city.SyncLisReport(orgDb, org.OrgId, org.HospitalId)
+		//  血透患者检验结果指标表（T_HD_LIS_INDICATORS）
+		city.SyncLisIndicators(orgDb, org.OrgId, org.HospitalId)
+
+		// 第四步：关闭数据库连接
+		service.CloseDB(orgDb)
+	}
+	// }
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *SyncController) SyncToSmzy() {
+	// 第一步：到上报配置表中找到深圳需要上报的机构
+	// sz_province, _ := beego.AppConfig.Int64("sz_province")
+	// sz_city, _ := beego.AppConfig.Int64("sz_city")
+	// configs, _ := service.FindAllDataUploadConfigOrgInfo(sz_province, sz_city, 3)
+
+	org := &sz.DataUploadConfig{
+		OrgId:          9504,
+		ProvinceId:     19,
+		CityId:         291,
+		DepartmentName: "深圳生命之源血液透析中心",
+		HospitalId:     "MA5EU4PC0",
+		InstType:       1,
+		DbHost:         "localhost",
+		DbPort:         "1433",
+		DbPass:         "1Q2W3e4r!@#$",
+		DbUser:         "sa",
+		DbName:         "xtzk",
+	}
+
+	// for _, org := range configs {
+	// 第二步：跟进配置，创建数据库连接
+	if len(org.DbHost) > 0 && len(org.DbUser) > 0 && len(org.DbPort) > 0 && len(org.DbPass) > 0 && len(org.DbName) > 0 {
+		orgDb, err := service.CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+		if err != nil {
+			utils.ErrorLog("创建数据库连接失败:%v", err)
+			c.ServeFailJSONWithSGJErrorCode(enums.ErrorCodeDataException)
+			return
+		}
+		// 第三步：开始同步数据
+		// 同步医院信息  t_hd_hospital
+		city.SyncHospital(orgDb, org.OrgId, org.HospitalId, org.InstType, org.DepartmentName)
+		// 同步水处理器  t_hd_wm
+		city.SyncWMS(orgDb, org.OrgId, org.HospitalId)
+		// // 同步员工 t_hd_staff
+		city.SyncStaff(orgDb, org.OrgId, org.HospitalId)
+		// // 同步病人 t_hd_patient
+		city.SyncPatient(orgDb, org.OrgId, org.HospitalId)
+		// // 同步排班  t_hd_shift
+		city.SyncShift(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方 t_hd_ps
+		city.SyncPs(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方药品 t_hd_ps
+		city.SyncPsMedicine(orgDb, org.OrgId, org.HospitalId)
+		// // 同步转院信息 t_hd_patient_out
+		city.SyncPatientOut(orgDb, org.OrgId, org.HospitalId)
+		// 同步处方信息 t_hd_doctors_advice
+		city.SyncDoctorAdvice(orgDb, org.OrgId, org.HospitalId)
+		// 同步透中信息 t_hd_middle
+		city.SyncMiddle(orgDb, org.OrgId, org.HospitalId)
+		// // 同步设备 t_hd_other_machine
+		city.SyncOtherMachine(orgDb, org.OrgId, org.HospitalId)
+		// // 同步维修 t_hd_maintain
+		city.SyncMachineRepair(orgDb, org.OrgId, org.HospitalId)
+		// // 同步设备 t_hd_dm
+		city.SyncDM(orgDb, org.OrgId, org.HospitalId)
+		// // 同步患者透析记录 t_hd_dialysis
+		city.SyncDialysis(orgDb, org.OrgId, org.HospitalId)
+		// 同步透析床位分区 t_hd_division
+		city.SyncDivision(orgDb, org.OrgId, org.HospitalId)
+		// 患者通路信息表（T_HD_ACCESS）
+		city.SyncAccess(orgDb, org.OrgId, org.HospitalId)
+		// 透析床位表（T_HD_SICKBED）
+		city.SyncSickbed(orgDb, org.OrgId, org.HospitalId)
+		// 患者诊断信息表（T_HD_DIAGNOSIS）
+		city.SyncDiagnosis(orgDb, org.OrgId, org.HospitalId)
+		//  患者传染病检查记录表（T_HD_INFECTION
+		city.SyncInfection(orgDb, org.OrgId, org.HospitalId)
+		//  透析并发症记录表（T_HD_COMPLICATION）
+		city.SyncComplication(orgDb, org.OrgId, org.HospitalId)
+		//  血透患者检测结果表（T_HD_LIS_REPORT）
+		city.SyncLisReport(orgDb, org.OrgId, org.HospitalId)
+		//  血透患者检验结果指标表（T_HD_LIS_INDICATORS）
+		city.SyncLisIndicators(orgDb, org.OrgId, org.HospitalId)
+
+		// 第四步：关闭数据库连接
+		service.CloseDB(orgDb)
+	}
+	// }
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+func (c *SyncController) SyncToTesgt() {
+	fmt.Println("c出发飞阿道夫阿道夫阿方阿方")
+	//city.GetInspectionData(10028)
+}

db/xt_drugway_dic

@@ -0,0 +1,21 @@
+INSERT INTO xt_drugway_dic (code, name, status, created_time, updated_time) VALUES 
+("DGCX","导管冲洗",1,1536290447,1536290447),
+("PO","口服",1,1536290447,1536290447),
+("LNZS","瘤内注射",1,1536290447,1536290447),
+("IVPUMP","微泵注射",1,1536290447,1536290447),
+("WBZS","微泵注射",1,1536290447,1536290447),
+("SXHF","舌下含服",1,1536290447,1536290447),
+("JMFG","静脉封管",1,1536290447,1536290447),
+("DGNWBZS","导管内微泵注射",1,1536290447,1536290447),
+("GLCX","管路冲洗",1,1536290447,1536290447),
+("PS","皮试 ",1,1536290447,1536290447),
+("JMCX","静脉采血",1,1536290447,1536290447),
+("YLGCX","引流管冲洗",1,1536290447,1536290447),
+("ID","皮内注射",1,1536290447,1536290447),
+("IH","皮下注射",1,1536290447,1536290447),
+("IM","肌肉注射",1,1536290447,1536290447),
+("IV","静脉注射",1,1536290447,1536290447),
+("IVGTT","静脉输液（普通）",1,1536290447,1536290447),
+("IVGTT","静脉输液（特殊）",1,1536290447,1536290447),
+("JBMZ","局部麻醉",1,1536290447,1536290447),
+("DGRS","导管溶栓",1,1536290447,1536290447);

db/xt_ef_dic

@@ -0,0 +1,35 @@
+INSERT INTO xt_execution_frequency_dic (code,name,status,created_time,updated_time) VALUES
+("AM","上午",1,1536290447,1536290447),
+("QW","每周一次",1,1536290447,1536290447),
+("SAS","需要时",1,1536290447,1536290447),
+("SQ30FZ","术前30分钟",1,1536290447,1536290447),
+("ST","立即",1,1536290447,1536290447),
+("TID","每日三次",1,1536290447,1536290447),
+("QID","每日四次",1,1536290447,1536290447),
+("QIW","每周四次",1,1536290447,1536290447),
+("TIW","每周三次",1,1536290447,1536290447),
+("TXHLJ","透析后立即",1,1536290447,1536290447),
+("XJQ","下机前",1,1536290447,1536290447),
+("ONCE","临时一次",1,1536290447,1536290447),
+("LZYC","两周一次",1,1536290447,1536290447),
+("LZSC","两周三次",1,1536290447,1536290447),
+("AA","各",1,1536290447,1536290447),
+("SZYC","四周一次",1,1536290447,1536290447),
+("QOD","隔日一次",1,1536290447,1536290447),
+("QN","每晚一次",1,1536290447,1536290447),
+("BID","每日二次",1,1536290447,1536290447),
+("BIW","每周二次",1,1536290447,1536290447),
+("CF","长方",1,1536290447,1536290447),
+("CITO!","急速地",1,1536290447,1536290447),
+("CXSY","持续使用",1,1536290447,1536290447),
+("F","份",1,1536290447,1536290447),
+("HS","临睡前",1,1536290447,1536290447),
+("LSKY","临时开药",1,1536290447,1536290447),
+("MCYC","每晨一次",1,1536290447,1536290447),
+("MFZYC","每分钟一次",1,1536290447,1536290447),
+("QD","每日一次",1,1536290447,1536290447),
+("QEH","每小时",1,1536290447,1536290447),
+("QH","每1小时一次",1,1536290447,1536290447),
+("QM","每晨一次",1,1536290447,1536290447),
+("QN","每晚",1,1536290447,1536290447),
+("SJQ","上机前",1,1536290447,1536290447);

enums/error_code.go

@@ -0,0 +1,374 @@
+package enums
+
+import "Data_Upload_Api/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
+	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
+
+	ErrorCodeNameException = 200023
+)
+
+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: "已上机",
+	//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:              "上机失败,请先开处方",
+
+	ErrorCodeNameException: "账号已经存在",
+}
+
+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,20 @@
+package main
+
+import (
+	_ "Data_Upload_Api/routers"
+	"Data_Upload_Api/service"
+	"Data_Upload_Api/service/city"
+	_ "Data_Upload_Api/service/city"
+	"github.com/astaxie/beego"
+)
+
+func init() {
+	service.ConnectDB()
+}
+
+func main() {
+
+	city.BeginAutoJob()
+	beego.Run()
+
+}

routers/router.go

@@ -0,0 +1,22 @@
+package routers
+
+import (
+	"Xcx_New/controllers"
+	"fmt"
+	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/plugins/cors"
+)
+
+func init() {
+	beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
+		// AllowAllOrigins:  true,
+		AllowOrigins:     []string{"http://api.szjkhd.com", "http://admin.xt.test.szjkhd.com", "http://admin.xt.szjkhd.com", "http://localhost:9527"},
+		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
+		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},
+		ExposeHeaders:    []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},
+		AllowCredentials: true,
+	}))
+	fmt.Println(" chufffdsdfsdfsdfasdf adf afd s fadsf ")
+	//controllers.SyncAPIRegisterRouters()
+	controllers.MobileRegisterRouters()
+}

service/db.go

@@ -0,0 +1,150 @@
+// 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/mssql"
+	_ "github.com/jinzhu/gorm/dialects/mysql" // mysql
+)
+
+var readDb *gorm.DB
+var writeDb *gorm.DB
+var readUserDb *gorm.DB
+var writeUserDb *gorm.DB
+
+var err error
+
+func CreateDB(Host string, Port string, User string, Pass string, Name string) (rsdDb *gorm.DB, err error) {
+	rdb := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", User, Pass, Host, Port, Name)
+	rsdDb, err = gorm.Open("mysql", rdb)
+	if err != nil {
+		//beego.Error(err)
+	}
+	rsdDb.DB().SetMaxIdleConns(5)
+	rsdDb.DB().SetMaxOpenConns(20)
+	rsdDb.LogMode(true)
+	return
+}
+
+func CreateSqlServiceDB(Host string, Port string, User string, Pass string, Name string) (mssqlDb *gorm.DB, err error) {
+	//rdb := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", User, Pass, Host, Port, Name)
+	mssqlstring := fmt.Sprintf("server=%s;port=%s;database=%s;user id=%s;password=%s", Host, Port, Name, User, Pass)
+	fmt.Println(mssqlstring)
+	mssqlDb, err = gorm.Open("mssql", mssqlstring)
+	if err != nil {
+		panic(err)
+	}
+	mssqlDb.DB().SetMaxIdleConns(5)
+	mssqlDb.DB().SetMaxOpenConns(20)
+	mssqlDb.LogMode(true)
+	return
+}
+
+func CloseDB(DB *gorm.DB) {
+	DB.Close()
+}
+
+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")
+
+	readUserHost := beego.AppConfig.String("readuserhost")
+	readUserPort := beego.AppConfig.String("readuserport")
+	readUserUser := beego.AppConfig.String("readuseruser")
+	readUserPass := beego.AppConfig.String("readuserpass")
+	readUserName := beego.AppConfig.String("readusername")
+
+	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")
+
+	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("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", readUserUser, readUserPass, readUserHost, readUserPort, readUserName)
+	wudsn := fmt.Sprintf("%s:%s@tcp(%s:%s)/%s?charset=utf8mb4&parseTime=true", writeUserUser, writeUserPass, writeUserHost, writeUserPort, writeUserName)
+
+	readDb, err = gorm.Open("mysql", rdsn)
+
+	//defer readDb.Close()
+	if err != nil {
+		//beego.Error(err)
+	}
+	readDb.DB().SetMaxIdleConns(5)
+	readDb.DB().SetMaxOpenConns(20)
+	readDb.LogMode(true)
+
+	writeDb, err = gorm.Open("mysql", wdsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+
+	//defer writeDb.Close()
+
+	writeDb.DB().SetMaxIdleConns(5)
+	writeDb.DB().SetMaxOpenConns(20)
+	writeDb.LogMode(true)
+
+	readUserDb, err = gorm.Open("mysql", rudsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+
+	//defer readUserDb.Close()
+
+	readUserDb.DB().SetMaxIdleConns(5)
+	readUserDb.DB().SetMaxOpenConns(20)
+	readUserDb.LogMode(true)
+
+	writeUserDb, err = gorm.Open("mysql", wudsn)
+	if err != nil {
+		//beego.Error(err)
+	}
+	//defer writeUserDb.Close()
+
+	writeUserDb.DB().SetMaxIdleConns(5)
+	writeUserDb.DB().SetMaxOpenConns(20)
+	writeUserDb.LogMode(true)
+
+}
+
+func XTReadDB() *gorm.DB {
+	return readDb
+}
+func XTWriteDB() *gorm.DB {
+	return writeDb
+}
+func UserReadDB() *gorm.DB {
+	return readUserDb
+}
+func UserWriteDB() *gorm.DB {
+	return writeUserDb
+}

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,37 @@
+package test
+
+import (
+	_ "XT/routers"
+	"net/http"
+	"net/http/httptest"
+	"path/filepath"
+	"runtime"
+	"testing"
+
+	"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
+}