1111

conf/app.conf

 # blmysqlname = kuyicloud
 
 
-readmysqlhost = shengws1.mysql.rds.aliyuncs.com
+readmysqlhost = kuyicl.mysql.rds.aliyuncs.com
 readmysqlport = 3306
 readmysqluser = syh
-readmysqlpass = xhPECP2nFObR8aUK
+readmysqlpass = yHXAcb7dTJyv
 readmysqlname = sgj_xt
 
-writemysqlhost = shengws1.mysql.rds.aliyuncs.com
+writemysqlhost = kuyicl.mysql.rds.aliyuncs.com
 writemysqlport = 3306
 writemysqluser = syh
-writemysqlpass = xhPECP2nFObR8aUK
+writemysqlpass = yHXAcb7dTJyv
 writemysqlname = sgj_xt
 
-tempwritemysqlhost = rm-wz930n4u3k76i95tuuo.mysql.rds.aliyuncs.com
+tempwritemysqlhost = kuyicl.mysql.rds.aliyuncs.com
 tempwritemysqlport = 3306
 tempwritemysqluser = syh
-tempwritemysqlpass = xhPECP2nFObR8aUK
+tempwritemysqlpass = yHXAcb7dTJyv
 tempwritemysqlname = sgj_xt
 
 readremotehost = 219.135.207.166
 readremotename = digitlab
 
 
-readuserhost = shengws1.mysql.rds.aliyuncs.com
+readuserhost = kuyicl.mysql.rds.aliyuncs.com
 readuserport = 3306
 readuseruser = syh
-readuserpass = xhPECP2nFObR8aUK
+readuserpass = yHXAcb7dTJyv
 readusername = sgj_users
 
-writeuserhost = shengws1.mysql.rds.aliyuncs.com
+writeuserhost = kuyicl.mysql.rds.aliyuncs.com
 writeuserport = 3306
 writeuseruser = syh
-writeuserpass = xhPECP2nFObR8aUK
+writeuserpass = yHXAcb7dTJyv
 writeusername = sgj_users
 
-readmiddlehost = shengws1.mysql.rds.aliyuncs.com
+readmiddlehost = kuyicl.mysql.rds.aliyuncs.com
 readmiddleport = 3306
 readmiddleuser = syh
-readmiddlepass = xhPECP2nFObR8aUK
+readmiddlepass = yHXAcb7dTJyv
 readmiddlename = ky_xt_middle
 
-writemiddlehost = shengws1.mysql.rds.aliyuncs.com
+writemiddlehost = kuyicl.mysql.rds.aliyuncs.com
 writemiddleport = 3306
 writemiddleuser = syh
-writemiddlepass = xhPECP2nFObR8aUK
+writemiddlepass = yHXAcb7dTJyv
 writemiddlename = ky_xt_middle
 
 backuphost = 120.76.159.131
 backupport = 3306
-backupuser = syh
-backuppass = xhPECP2nFObR8aUK
+backupuser = kuyicloud
+backuppass = yHXAcb7dTJyvMiX3vK2iOvTAHeaowy5P
 backupname = sgj_xt
 
 

controllers/lis.go

 	BaseAPIController
 }
 
+func (c *LisController) SyncChydLis() {
+	service.SyncLisChyd(1)
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "12345",
+	})
+	return
+}
+
+//func (c *LisController) Test() {
+//	service.SyncJhhjyyLis()
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
+
 func (c *LisController) Schedule() {
 	for i := 762429; i > 0; i-- {
 		schedule, err := service.GetScheduless(int64(i))
 
 }
 
-// 普宁锦熹血液透析中心Lis同步
-func (c *LisController) SyncPljx() {
-	service.SyncLisPljx(10599)
-	c.ServeSuccessJSON(map[string]interface{}{
-		"resultList": "12345",
-	})
-	return
-}
+//// 普宁锦熹血液透析中心Lis同步
+//func (c *LisController) SyncPljx() {
+//	service.SyncLisPljx(10599)
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
 
 // 遵化仁爱医院Lis同步
-func (c *LisController) SyncZhraLis() {
-	service.SyncTszhraLis()
-	c.ServeSuccessJSON(map[string]interface{}{
-		"resultList": "12345",
-	})
-	return
-}
+//func (c *LisController) SyncZhraLis() {
+//	service.SyncTszhraLis()
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
 
 // 北京南诚中西医结合医院Lis同步
-func (c *LisController) SyncBjncLis() {
-	service.SyncBjncLis()
-	c.ServeSuccessJSON(map[string]interface{}{
-		"resultList": "12345",
-	})
-	return
-}
+//func (c *LisController) SyncBjncLis() {
+//	service.SyncBjncLis()
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
 
 // 广州康允LIS同步
-func (c *LisController) SyncGzky() {
-	service.SyncGzkyLis()
-	c.ServeSuccessJSON(map[string]interface{}{
-		"resultList": "12345",
-	})
-	return
-}
-
-func (c *LisController) SyncSzwz() {
-	service.SyncLisSzwz()
-	c.ServeSuccessJSON(map[string]interface{}{
-		"resultList": "12345",
-	})
-	return
-}
+//func (c *LisController) SyncGzky() {
+//	service.SyncGzkyLis()
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
+
+//func (c *LisController) SyncSzwz() {
+//	service.SyncLisSzwz()
+//	c.ServeSuccessJSON(map[string]interface{}{
+//		"resultList": "12345",
+//	})
+//	return
+//}
 
 // 石狮盛誉LIS同步
 func (c *LisController) SyncSssy() {

main.go

 	service.BeginAutoSyncLis()
 	//service.SyncStsyLis() //  汕头三优  打开程序马上运行LIS同步
 	//service.SyncLisSgyhs() //  韶关源和盛  打开程序马上运行LIS同步
-	//service.SyncLisPljx(10599) //  揭阳景熹透析中心  打开程序马上运行LIS同步
-	service.SyncTszhraLis() // 遵化仁爱医院  打开程序马上运行LIS同步
+	//service.SyncCsnyLis() //  揭阳景熹透析中心  打开程序马上运行LIS同步
+	//service.SyncTszhraLis() // 遵化仁爱医院  打开程序马上运行LIS同步
+	//service.SyncLisYstxChyd() // 从化意达透析中心  打开程序马上运行LIS同步
+	//service.SyncJhhjyyLis() // 湖南郴州嘉禾恒佳医院  打开程序马上运行LIS同步
+	//service.SyncSYData2() // 石狮盛誉血液透析中心  打开程序马上运行LIS同步
 	beego.Run()
 }

models/lis_model.go

 	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"`
-	SysProjectId int64  `gorm:"column:sys_project_id" json:"sys_project_id" form:"sys_project_id"`
-	SysItemId    int64  `gorm:"column:sys_item_id" json:"sys_item_id" form:"sys_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"`
+	SysProjectId  int64  `gorm:"column:sys_project_id" json:"sys_project_id" form:"sys_project_id"`
+	SysItemId     int64  `gorm:"column:sys_item_id" json:"sys_item_id" form:"sys_item_id"`
+	Adiconbarcode string `gorm:"column:adiconbarcode" json:"adiconbarcode" form:"adiconbarcode"`
 }
 
 func (MiddleInspection) TableName() string {
 	ItemCode         string `gorm:"column:item_code" json:"item_code" form:"item_code"`
 	XtProjectId      int64  `gorm:"column:xt_project_id" json:"xt_project_id" form:"xt_project_id"`
 	XtItemId         int64  `gorm:"column:xt_item_id" json:"xt_item_id" form:"xt_item_id"`
+	Adiconbarcode    string `gorm:"column:adiconbarcode" json:"adiconbarcode" form:"adiconbarcode"`
 }
 
 func (MiddleInspectionReference) TableName() string {

routers/router.go

 
 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")
-	beego.Router("/api/lis/tscylissync", &controllers.LisController{}, "get:SyncTscyLis")
-	beego.Router("/api/lis/fjtflissync", &controllers.LisController{}, "get:SyncFjtfLis")
-	beego.Router("/api/lis/csnylissync", &controllers.LisController{}, "get:SyncCsnyLis")
-
-	//百霖lis
-	beego.Router("/api/lis/bltest", &controllers.LisController{}, "get:SyncBlLis")
-	beego.Router("/api/lis/blresulttest", &controllers.LisController{}, "get:SyncBlResultLis")
-	beego.Router("/api/schedule", &controllers.LisController{}, "get:Schedule")
-
-	beego.Router("/api/syncshLis", &controllers.LisController{}, "get:SyncShLis")
-	beego.Router("/api/syncszblis", &controllers.LisController{}, "get:SyncSzblLis")
-	beego.Router("/api/test", &controllers.LisController{}, "get:SyncTest")
-	//beego.Router("/api/lis/gzjhxytx", &controllers.LisController{}, "get:SyncGzjhxytx")
-	//beego.Router("/api/lis/scdckfyy", &controllers.LisController{}, "get:SyncSccdkfyyLis")
-	//beego.Router("/api/lis/pajm", &controllers.LisController{}, "get:SyncPajmLis")
-	beego.Router("/api/lis/sssy", &controllers.LisController{}, "get:SyncSssy")
-	beego.Router("/api/lis/tscyvip", &controllers.LisController{}, "get:SyncTscyVipLis")
-	beego.Router("/api/lis/syncgzky", &controllers.LisController{}, "get:SyncGzky")
-	beego.Router("/api/lis/syncszwz", &controllers.LisController{}, "get:SyncSzwz")
-	beego.Router("/api/lis/syncpljx", &controllers.LisController{}, "get:SyncPljx")
-	beego.Router("/api/lis/syncbjnc", &controllers.LisController{}, "get:SyncBjncLis")
-	beego.Router("/api/lis/synczhra", &controllers.LisController{}, "get:SyncZhraLis")
+	//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")
+	//beego.Router("/api/lis/tscylissync", &controllers.LisController{}, "get:SyncTscyLis")
+	//beego.Router("/api/lis/fjtflissync", &controllers.LisController{}, "get:SyncFjtfLis")
+	//beego.Router("/api/lis/csnylissync", &controllers.LisController{}, "get:SyncCsnyLis")
+	//
+	////百霖lis
+	//beego.Router("/api/lis/bltest", &controllers.LisController{}, "get:SyncBlLis")
+	//beego.Router("/api/lis/blresulttest", &controllers.LisController{}, "get:SyncBlResultLis")
+	//beego.Router("/api/schedule", &controllers.LisController{}, "get:Schedule")
+	//
+	//beego.Router("/api/syncshLis", &controllers.LisController{}, "get:SyncShLis")
+	//beego.Router("/api/syncszblis", &controllers.LisController{}, "get:SyncSzblLis")
+	//beego.Router("/api/test", &controllers.LisController{}, "get:SyncTest")
+	////beego.Router("/api/lis/gzjhxytx", &controllers.LisController{}, "get:SyncGzjhxytx")
+	////beego.Router("/api/lis/scdckfyy", &controllers.LisController{}, "get:SyncSccdkfyyLis")
+	////beego.Router("/api/lis/pajm", &controllers.LisController{}, "get:SyncPajmLis")
+	//beego.Router("/api/lis/sssy", &controllers.LisController{}, "get:SyncSssy")
+	//beego.Router("/api/lis/tscyvip", &controllers.LisController{}, "get:SyncTscyVipLis")
+	//beego.Router("/api/lis/syncgzky", &controllers.LisController{}, "get:SyncGzky")
+	//beego.Router("/api/lis/syncszwz", &controllers.LisController{}, "get:SyncSzwz")
+	//beego.Router("/api/lis/syncpljx", &controllers.LisController{}, "get:SyncPljx")
+	//beego.Router("/api/lis/syncbjnc", &controllers.LisController{}, "get:SyncBjncLis")
+	//beego.Router("/api/lis/synczhra", &controllers.LisController{}, "get:SyncZhraLis")
+	beego.Router("/api/lis/syncchyd", &controllers.LisController{}, "get:SyncChydLis")
+	//beego.Router("/test", &controllers.LisController{}, "get:Test")
 }

service/cron.go

 	//
 	//specys1 := "0 10 */2 * * ?" // 每两个小时同步长沙南雅医院
 	//createLisSyncCronJob.AddFunc(specys1, func() {
-	//	SyncCsnyLis()
+	//SyncCsnyLis()
 	//})
 	//
 	//spec := "0 50 1 * * ?" // 每天凌晨1点同步 监利大院的
 	//	SyncLisPljx(10599)
 	//})
 
+	//spec13 := "0 10 * * * ?" // 每个小时同步一次 唐山遵化仁爱医院LIS对接，本地部署的
+	//createLisSyncCronJob.AddFunc(spec13, func() {
+	//	SyncTszhraLis()
+	//})
+
+	//spec14 := "0 10 2 * * ?" // 每天凌晨步一次 从化意达血液透析中心LIS对接，服务器部署
+	//createLisSyncCronJob.AddFunc(spec14, func() {
+	//	SyncLisChyd(0)
+	//})
+
 	createLisSyncCronJob.Start()
 }
 

service/csny_service.go

 	_ "github.com/jinzhu/gorm"
 	"io/ioutil"
 	"net/http"
+	"unicode/utf8"
 
 	"strconv"
 	"strings"
 	"time"
 )
 
+func lastThreeChars(s string) string {
+	runeCount := 0
+	for i := len(s); i > 0; {
+		_, size := utf8.DecodeLastRuneInString(s[:i])
+		i -= size
+		runeCount++
+		if runeCount == 3 {
+			return s[i:]
+		}
+	}
+	// 如果字符串长度少于3个字符，则返回整个字符串或空字符串
+	if runeCount == 0 {
+		return ""
+	}
+	return s
+}
+
 // 福建天福医院透析中心Lis同步
 func SyncCsnyLis() (err error) {
 	org_id := int64(10340)
+	//org_id_other := int64(103401)
 
 	// 第一步：获取上一次同步的时间点
 	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
 		sync_time = 1651334400 // 2022-05-01 00:00:00
 	}
 
+	//syncLastInfo1, _ := GetSyncTimeByOrgIDForYs(org_id_other)
+	//var sync_time_other int64
+	//if syncLastInfo1.ID > 0 {
+	//	sync_time_other = syncLastInfo1.SyncTime
+	//} else {
+	//	sync_time_other = 1651334400 // 2022-05-01 00:00:00
+	//}
+
 	sync_time_temp := time.Unix(sync_time, 0)
 	syncTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+
+	//sync_time_temp_1 := time.Unix(sync_time_other, 0)
+	//syncTimeStr_1 := sync_time_temp_1.Format("2006-01-02 15:04:05")
 	// 第二步：获取所有患者的病历号
 
 	patientList, _ := GetPatientGzjhByOrgId(org_id)
 	if len(patientList) > 0 {
+		// 体检的检验数据
+		//for _, patient := range patientList {
+		//	if len(patient.IdCardNo) > 0 || len(patient.DialysisNo) > 0 {
+		//		patient_id := patient.ID
+		//		var patient_name string
+		//		length := len(patient.Name)
+		//		if length >= 3 {
+		//			utils.InfoLog("名字：%v", patient.Name)
+		//			lastThree := lastThreeChars(patient.Name)
+		//			utils.InfoLog("截取后的名字：%v", lastThree)
+		//			re := regexp.MustCompile("[0-9]+")
+		//			patient_name = re.ReplaceAllString(lastThree, "")
+		//		} else {
+		//			patient_name = patient.Name
+		//		}
+		//		result, _ := CsnyGetLabTj(patient_name, syncTimeStr_1)
+		//		utils.InfoLog("result:%v", result)
+		//		var fjtfLab LabCsnyResult
+		//		if err := json.Unmarshal([]byte(result), &fjtfLab); err != nil {
+		//			utils.ErrorLog("解析失败：%v", err)
+		//		}
+		//		fmt.Println(fjtfLab)
+		//
+		//		if len(fjtfLab.Result) > 0 {
+		//			// 根据获取的头部lab01获取检查结果
+		//
+		//			for _, info := range fjtfLab.Result {
+		//				lacResult, _ := CsnyGetLac(info.Lab01)
+		//				utils.InfoLog("lacResult:%v", lacResult)
+		//				var fjtfLac LacCsnyResult
+		//				if err := json.Unmarshal([]byte(lacResult), &fjtfLac); err != nil {
+		//					utils.ErrorLog("解析失败：%v", err)
+		//				}
+		//				fmt.Println(fjtfLac)
+		//				for _, cinfo := range fjtfLac.Result {
+		//					project_id := int64(0)
+		//					item_id := int64(0)
+		//					if len(cinfo.Bbx05a) > 0 {
+		//						project_id, _ = GetCsnyProjectID(org_id, cinfo.Bbx05a)
+		//						item_id, _ = GetCsnyItemID(org_id, cinfo.Bbx05a, cinfo.Bbx05, project_id)
+		//					} else {
+		//						project_id, _ = GetCsnyProjectID(org_id, cinfo.Bbx05)
+		//						item_id, _ = GetCsnyItemID(org_id, cinfo.Bbx05, cinfo.Bbx05, project_id)
+		//					}
+		//
+		//					tx := writeMiddleDb.Begin()
+		//					var inspection models.MiddleInspection
+		//					var inspection_reference models.MiddleInspectionReference
+		//
+		//					loc, _ := time.LoadLocation("Local")
+		//					theTime, _ := time.ParseInLocation("2006-01-02 15:04:05", cinfo.Lac25, loc)
+		//					record_date := theTime.Unix()
+		//
+		//					if record_date == 0 {
+		//						record_date = time.Now().Unix()
+		//					}
+		//
+		//					inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
+		//					var total int
+		//					var RangeOptions string
+		//					var RangeMin string
+		//					var RangeMax string
+		//
+		//					// // 判断检查类型
+		//					ItemType := 1
+		//					Range := strings.Split(cinfo.Lac15, "-")
+		//					if len(Range) > 1 {
+		//						RangeMin = cinfo.Lac13
+		//						RangeMax = cinfo.Lac14
+		//						ItemType = 1
+		//					} else {
+		//						ItemType = 2
+		//						RangeOptions = cinfo.Lac15
+		//					}
+		//
+		//					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 = int64(inspection_reference.RangeType)
+		//					// }
+		//
+		//					if total <= 0 {
+		//						inspection_reference.OrgId = org_id
+		//						if len(cinfo.Bbx05a) > 0 {
+		//							inspection_reference.ProjectName = cinfo.Bbx05a
+		//							inspection_reference.Project = cinfo.Bbx05a
+		//						} else {
+		//							inspection_reference.ProjectName = cinfo.Bbx05
+		//							inspection_reference.Project = cinfo.Bbx05
+		//						}
+		//						inspection_reference.ProjectId = project_id
+		//						inspection_reference.ItemName = cinfo.Bbx05
+		//						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 = cinfo.Bdg02
+		//						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()
+		//						}
+		//					}
+		//
+		//					var itotal int
+		//					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 = inspection_reference.ItemName
+		//						inspection.ProjectName = inspection_reference.ProjectName
+		//						inspection.InspectType = ItemType
+		//						inspection.ItemId = item_id
+		//						inspection.InspectValue = cinfo.Lac10
+		//						inspection.InspectDate = inspect_date
+		//						inspection.RecordDate = record_date
+		//						inspection.InspectTips = cinfo.Lac11
+		//						inspection.Status = 1
+		//						inspection.CreatedTime = time.Now().Unix()
+		//						inspection.UpdatedTime = time.Now().Unix()
+		//						inspection.UTime = inspect_date
+		//						inspection.HisUserId = strconv.FormatInt(patient_id, 10)
+		//						err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+		//						if err != nil {
+		//							tx.Rollback()
+		//						}
+		//					}
+		//
+		//					tx.Commit()
+		//
+		//				}
+		//			}
+		//		}
+		//	} else {
+		//		continue
+		//	}
+		//}
 		for _, patient := range patientList {
 			if len(patient.IdCardNo) > 0 || len(patient.DialysisNo) > 0 {
 				patient_id := patient.ID
 				utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
 				// utils.InfoLog("VipStr:%v", VipStr)
 
-				result, _ := CsnyGetLab(patient.IdCardNo, syncTimeStr)
-				utils.InfoLog("result:%v", result)
+				result1, _ := CsnyGetLab(patient.IdCardNo, syncTimeStr)
+				utils.InfoLog("result:%v", result1)
 				var fjtfLab LabCsnyResult
-				if err := json.Unmarshal([]byte(result), &fjtfLab); err != nil {
+				if err := json.Unmarshal([]byte(result1), &fjtfLab); err != nil {
 					utils.ErrorLog("解析失败：%v", err)
 				}
 				fmt.Println(fjtfLab)
 		utils.ErrorLog("创建同步信息失败:%v", cwderr)
 		return
 	}
+
+	//var syncInfos models.MiddleSyncInfo
+	//syncInfos.OrgId = org_id_other
+	//syncInfos.SyncTime = time.Now().Unix()
+	//syncInfos.SyncResultType = 1
+	//syncInfos.SyncRsultRemark = "同步成功"
+	//syncInfos.SyncTotalNum = 0
+	//syncInfos.SyncSuccessNum = 0
+	//syncInfos.SyncInfo = ""
+	//syncInfos.CreateTime = time.Now().Unix()
+	//syncInfos.UpdateTime = time.Now().Unix()
+	//
+	//cwderrs := CreateSyncInfo(&syncInfos)
+	//if cwderrs != nil {
+	//	utils.ErrorLog("创建同步信息失败:%v", cwderrs)
+	//	return
+	//}
 	SyncToCsnytx()
 	return
 }
 	return str, inputLog
 }
 
+func CsnyGetLabTj(patient_name string, synctime string) (string, string) {
+	inputData := make(map[string]interface{})
+
+	inputData["vaa05"] = patient_name
+	inputData["begintime"] = synctime
+
+	var inputLog string
+	bytesData, err := json.Marshal(inputData)
+	inputLog = string(bytesData)
+	fmt.Println(string(bytesData))
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	reader := bytes.NewReader(bytesData)
+	url := "http://218.104.146.179:9091/esb/listener/getLab1"
+
+	request, err := http.NewRequest("POST", url, reader)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
+	request.Header.Set("code", "Xmrjyy")
+
+	client := http.Client{}
+	resp, err := client.Do(request)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	respBytes, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+	str := string(respBytes)
+	return str, inputLog
+}
+
 type LacCsnyResult struct {
 	Msg    string `json:"msg"`
 	Result []struct {

service/db.go

 	fmt.Println(mssqlstring)
 	mssqlDb, err = gorm.Open("mssql", mssqlstring)
 	if err != nil {
-		panic(err)
+		//panic(err)
 	}
-	mssqlDb.DB().SetMaxIdleConns(5)
-	mssqlDb.DB().SetMaxOpenConns(20)
-	mssqlDb.LogMode(true)
+	//mssqlDb.DB().SetMaxIdleConns(5)
+	//mssqlDb.DB().SetMaxOpenConns(20)
+	//mssqlDb.LogMode(true)
 	return
 }
 
 
 func ConnectDB() {
 
-	readHost := beego.AppConfig.String("readmysqlhost")
+	readHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	readPort := beego.AppConfig.String("readmysqlport")
-	readUser := beego.AppConfig.String("readmysqluser")
-	readPass := beego.AppConfig.String("readmysqlpass")
+	readUser := "syh"
+	readPass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	readName := beego.AppConfig.String("readmysqlname")
 
-	writeHost := beego.AppConfig.String("writemysqlhost")
+	writeHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	writePort := beego.AppConfig.String("writemysqlport")
-	writeUser := beego.AppConfig.String("writemysqluser")
-	writePass := beego.AppConfig.String("writemysqlpass")
+	writeUser := "syh"
+	writePass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	writeName := beego.AppConfig.String("writemysqlname")
 
 	// tempwriteHost := beego.AppConfig.String("tempwritemysqlhost")
 	// tempwritePass := beego.AppConfig.String("tempwritemysqlpass")
 	// tempwriteName := beego.AppConfig.String("tempwritemysqlname")
 
-	readUserHost := beego.AppConfig.String("readuserhost")
+	readUserHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	readUserPort := beego.AppConfig.String("readuserport")
-	readUserUser := beego.AppConfig.String("readuseruser")
-	readUserPass := beego.AppConfig.String("readuserpass")
+	readUserUser := "syh"
+	readUserPass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	readUserName := beego.AppConfig.String("readusername")
 
 	// readRemoteHost := beego.AppConfig.String("readremotehost")
 	// readRemotePass := beego.AppConfig.String("readremotepass")
 	// readRemoteName := beego.AppConfig.String("readremotename")
 
-	writeUserHost := beego.AppConfig.String("writeuserhost")
+	writeUserHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	writeUserPort := beego.AppConfig.String("writeuserport")
-	writeUserUser := beego.AppConfig.String("writeuseruser")
-	writeUserPass := beego.AppConfig.String("writeuserpass")
+	writeUserUser := "syh"
+	writeUserPass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	writeUserName := beego.AppConfig.String("writeusername")
 
-	readMiddleHost := beego.AppConfig.String("readmiddlehost")
+	readMiddleHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	readMiddlePort := beego.AppConfig.String("readmiddleport")
-	readMiddleUser := beego.AppConfig.String("readmiddleuser")
-	readMiddlePass := beego.AppConfig.String("readmiddlepass")
+	readMiddleUser := "syh"
+	readMiddlePass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	readMiddleName := beego.AppConfig.String("readmiddlename")
 
-	writeMiddleHost := beego.AppConfig.String("writemiddlehost")
+	writeMiddleHost := "kuyicloud2024lt.mysql.rds.aliyuncs.com"
 	writeMiddlePort := beego.AppConfig.String("writemiddleport")
-	writeMiddleUser := beego.AppConfig.String("writemiddleuser")
-	writeMiddlePass := beego.AppConfig.String("writemiddlepass")
+	writeMiddleUser := "syh"
+	writeMiddlePass := "Zc8xxwN4jkZswprx8VKHRSd2rBMRWgC4"
 	writeMiddleName := beego.AppConfig.String("writemiddlename")
 
 	// backupHost := beego.AppConfig.String("backuphost")

service/pajm_service.go

 // 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
 func GetScpaProjectID(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
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project = ?", org_id, project_name).First(&inspection_reference).Error
 	if inspection_reference.ID > 0 {
 		return inspection_reference.ProjectId, err
 	} else {
 // 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
 func GetScpaItemID(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
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
 	if inspection_reference.ID > 0 {
 		return inspection_reference.ItemId, err
 	} else {

service/sgyhs_service.go

 			if Result.Name == "陈永中" {
 				Result.Name = "陈永忠"
 			}
+			if Result.Name == "朱小飞" {
+				Result.Name = "朱小妃"
+			}
+
 			patient, _ := GetUserInfoByName(org_id, Result.Name)
 			if patient.ID > 0 {
 				project_id, _ := GetSgyhsProjectID(org_id, Result.DockingapplyitemName)

service/sssy_service.go

 
 func SyncSYData2() {
 	org_id := int64(10191)
-	start_time := "2023-01-01"
-	end_time := "2023-11-22"
+	start_time := "2024-01-01"
+	end_time := "2024-04-15"
 	record, _ := GetLastSyncResultRecord(org_id)
 	if record.ID > 0 {
 		start_time = record.GpSyncEndDate
 		fmt.Println(list)
 		//插入到系统检验检查数据
 		if len(list) > 0 {
+			tx := writeMiddleDb.Begin()
 			for _, item := range list {
 				project_id := int64(0)
 				patient, _ := GetPatientID(org_id, item.ListResult.PatientName)
 				if patient.ID == 0 {
 					continue
 				}
-				tx := writeMiddleDb.Begin()
 				var inspection models.MiddleInspection
 				var inspection_reference models.MiddleInspectionReference
 
 						tx.Rollback()
 					}
 				}
-				tx.Commit()
-
 			}
 			//插入一条查询检验检查结果记录状态数据
 			var info LisSyncResultStatusInfo
 			info.ResultDate = time.Now().Unix()
 			info.GpSyncEndDate = end_time
 			writeMiddleDb.Save(&info)
+
+			tx.Commit()
 		}
 	}
 	SyncToSssytx()
+	UpdateJg()
 }
 
 func SyncToSssytx() {
 	utils.SuccessLog("检验检查同步任务完成")
 }
 
+func UpdateJg() error {
+	var inspections []models.Inspection
+	err = readDb.Model(&models.Inspection{}).Where("org_id = ? and project_id = ? and inspect_date >= ?  and status = 1", 10191, 15, 1704038400).Group("patient_id,inspect_date").Find(&inspections).Error
+	for _, info := range inspections {
+		var inspectionByOne []models.Inspection
+		err = readDb.Model(&models.Inspection{}).Where("org_id = ? and project_id = ? and inspect_date = ? and patient_id = ?  and status = 1", 10191, 15, info.InspectDate, info.PatientId).Find(&inspectionByOne).Error
+		if len(inspectionByOne) == 2 {
+			for _, tinfo := range inspectionByOne {
+				utils.InfoLog("date1: %v", tinfo.ID)
+				if tinfo.ItemId != 115 && tinfo.ItemId != 37 {
+					// 报告单里只有肌酐和尿素这两个项目要上传到“透后肾功能”里
+					continue
+				}
+				if tinfo.ItemId == 115 {
+					tinfo.ProjectId = 8060
+					tinfo.ItemId = 8060
+				}
+				if tinfo.ItemId == 37 {
+					tinfo.ProjectId = 8060
+					tinfo.ItemId = 8061
+				}
+				writeDb.Save(&tinfo)
+			}
+		}
+	}
+	return err
+}
+
 // 从机构将数据同步到中间库
 func SyncSssyInspection(data *models.MiddleInspection) error {
 	tx := writeDb.Begin()

service/sy_service.go

 
 	org := &models.DataUploadConfig{
 		OrgId:  org_id,
-		DbHost: "127.0.0.1",
+		DbHost: "192.168.1.209",
 		DbPort: "1433",
 		DbPass: "Aa123456",
 		DbUser: "kyys",
 		}
 	}
 
+	// 第四步：关闭数据库连接
+	CloseDB(orgDb)
 	SyncToStsytx()
 	return
 }
 // }
 
 func SyncToStsytx() {
-
-	utils.TraceLog("检验检查同步任务开始执行")
 	org_id := int64(10223)
+	utils.TraceLog("检验检查同步任务开始执行")
 
 	// 第一步：跟进org_id 去中间库查出需要同步的数据
 	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
 			SyncInspection(&inspection)
 		}
 	}
+	// 第四步：关闭数据库连接
 	utils.SuccessLog("检验检查同步任务完成")
 }