controllers/lis.go

@@ -9,7 +9,9 @@ import (
 	"fmt"
 	_ "github.com/astaxie/beego"
 	_ "github.com/jinzhu/gorm"
+	"net"
 	_ "strconv"
+	"strings"
 	"time"
 )
 
@@ -26,13 +28,45 @@ func (c *LisController) SyncChydLis() {
 	return
 }
 
-//func (c *LisController) Test() {
-//	service.SyncJhhjyyLis()
-//	c.ServeSuccessJSON(map[string]interface{}{
-//		"resultList": "12345",
-//	})
-//	return
-//}
+func (c *LisController) Test() {
+	var ipWhitelist = []string{"192.168.2.6", "192.168.1.1"}
+	ip := c.Ctx.Request.Header.Get("X-Forwarded-For")
+	if ip == "" {
+		// 如果没有 X-Forwarded-For，则使用 RemoteAddr
+		// 注意：RemoteAddr 可能包含端口号，需要进行处理
+		ip, _, _ = net.SplitHostPort(c.Ctx.Request.RemoteAddr)
+	}
+
+	// 如果 X-Forwarded-For 包含多个 IP 地址（逗号分隔），则通常取第一个
+	// 这通常是因为请求经过了多个代理
+	ips := strings.Split(ip, ",")
+	if len(ips) > 0 {
+		ip = strings.TrimSpace(ips[0])
+	}
+
+	utils.InfoLog("IP:%v", ip)
+
+	ipFlag := false
+	for _, allowedIP := range ipWhitelist {
+		if ip == allowedIP {
+			ipFlag = true
+		}
+	}
+
+	if ipFlag {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"flag": "1",
+			"msg":  "认证通过",
+		})
+	} else {
+		c.ServeSuccessJSON(map[string]interface{}{
+			"flag": "0",
+			"msg":  "IP认证通过未通过",
+		})
+	}
+
+	return
+}
 
 func (c *LisController) Schedule() {
 	for i := 762429; i > 0; i-- {

main.go

@@ -15,7 +15,7 @@ func init() {
 }
 
 func main() {
-	service.BeginAutoSyncLis()
+	//service.BeginAutoSyncLis()
 	//service.SyncStsyLis() //  汕头三优  打开程序马上运行LIS同步
 	//service.SyncLisSgyhs() //  韶关源和盛  打开程序马上运行LIS同步
 	//service.SyncLisPljx(10597) //  揭阳景熹透析中心  打开程序马上运行LIS同步
@@ -25,5 +25,8 @@ func main() {
 	//service.SyncSclsyyyyyz() // 石狮盛誉血液透析中心  打开程序马上运行LIS同步
 	//service.SyncSccdkfyyLis() // 成都城东康复医院  打开程序马上运行LIS同步
 	//service.SyncSclsyyyyyz(orgDb) // 深圳五洲医院  打开程序马上运行LIS同步
+	//service.SyncGzkyLis() // 广州康允 打开程序马上运行LIS同步
+	//service.SyncLisZqshtx() // 肇庆三鹤 打开程序马上运行LIS同步
+	//service.SyncBjncHis()
 	beego.Run()
 }

routers/router.go

@@ -3,9 +3,19 @@ package routers
 import (
 	"IC/controllers"
 	"github.com/astaxie/beego"
+	"github.com/astaxie/beego/plugins/cors"
 )
 
 func init() {
+	beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
+		//AllowAllOrigins:  true,
+		AllowOrigins: []string{"https://xt.kuyicloud.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com", "https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com", "http://mobile.sgjyun.com", "http://mobile.kuyicloud.com", "https://mobile.kuyicloud.com"},
+		//AllowOrigins:     []string{"https://xt.kuyicloud.com", "http://localhost:9528", "http://xt.test.shengws.com","https://xt.test.shengws.com", "http://xt.test.sgjyun.com","https://xt.test.sgjyun.com", "http://localhost:8081", "http://localhost:8082", "https://pad.kuyicloud.com", "http://pad.kuyicloud.com", "http://pad.test.sgjyun.com","https://pad.test.sgjyun.com", "http://admin.xt.test.sgjyun.com", "http://admin.xt.kuyicloud.com","http://mobile.sgjyun.com","http://mobile.kuyicloud.com"},
+		AllowMethods:     []string{"GET", "POST", "PUT", "DELETE", "OPTIONS"},
+		AllowHeaders:     []string{"Origin", "Authorization", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type", "X-XSRF-TOKEN", "Permission", "KyToken"},
+		ExposeHeaders:    []string{"Content-Length", "Access-Control-Allow-Origin", "Access-Control-Allow-Headers", "Content-Type"},
+		AllowCredentials: true,
+	}))
 	beego.Router("/", &controllers.MainController{})
 	//beego.Router("/api/lis/getlist", &controllers.LisController{}, "get:GetList")
 	//beego.Router("/api/lis/synctobase", &controllers.LisController{}, "get:SyncToBase")
@@ -40,5 +50,5 @@ func init() {
 	//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")
+	beego.Router("/test", &controllers.LisController{}, "get:Test")
 }

service/bjnc_service.go

@@ -0,0 +1,773 @@
+package service
+
+import (
+	"IC/models"
+	_ "IC/models"
+	"IC/utils"
+	"bytes"
+	"encoding/json"
+	_ "encoding/json"
+	_ "encoding/xml"
+	"fmt"
+	_ "github.com/jinzhu/gorm"
+	"io/ioutil"
+	"net/http"
+	"strconv"
+	"strings"
+	"time"
+)
+
+func GetbjncProjectID(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 = ?", org_id, project_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId, err
+	} else {
+		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 {
+			err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+			if inspection_reference.ProjectId > 0 {
+				return inspection_reference.ProjectId + 1, err
+			} else {
+				return 1060601, err
+			}
+		}
+	}
+}
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetbjncItemID(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 = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ItemId, err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id, project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+		if inspection_reference.ItemId > 0 {
+			return inspection_reference.ItemId + 1, err
+		} else {
+			return project_id*100 + 1, err
+		}
+	}
+}
+
+// 北京南诚中西医结合医院Lis同步
+func SyncBjncLis() (err error) {
+	org_id := int64(10606)
+
+	// 第一步：获取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime - 60*60*6
+	} else {
+		sync_time = 1714492800
+	}
+
+	loc, _ := time.LoadLocation("Local") //重要：获取时区
+	sync_time_temp := time.Unix(sync_time, 0)
+	startTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+	end_time := time.Now().Unix()
+	end_time_temp := time.Unix(end_time, 0)
+	endTimeStr := end_time_temp.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
+				utils.InfoLog("startTimeStr:%v", startTimeStr)
+				// utils.InfoLog("VipStr:%v", VipStr)
+				// 跟进身份证获取patientID
+				patientList, _ := BjncGetPatientInfo(patient.IdCardNo, endTimeStr)
+
+				var bjncPatient BjncPatientInfo
+				if err := json.Unmarshal([]byte(patientList), &bjncPatient); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+				}
+
+				utils.InfoLog("patientId:%v", bjncPatient.Result[0].Patientid)
+
+				reportList, _ := BjncGetLisReport(bjncPatient.Result[0].Patientid, startTimeStr, endTimeStr)
+				var lisReport BjncLisReport
+				if err := json.Unmarshal([]byte(reportList), &lisReport); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+				}
+				utils.InfoLog("reportList:%v", lisReport)
+
+				if len(lisReport.Result) > 0 {
+					for _, linfo := range lisReport.Result {
+						infoReprot, _ := BjncGetReportInfo(linfo.Reportno, startTimeStr, endTimeStr)
+						var reportInfo ReportDetail
+						if err := json.Unmarshal([]byte(infoReprot), &reportInfo); err != nil {
+							utils.ErrorLog("解析失败：%v", err)
+						}
+
+						for _, ivalue := range reportInfo.Result {
+							theTime, _ := time.ParseInLocation("2006-01-02 15:04:05", ivalue.Testtime, loc) //使用模板在对应时区转化为time.time类型
+							start_temp_Time := theTime.Format("2006-01-02 15:04")
+							SxTime, _ := time.ParseInLocation("2006-01-02 15:04", start_temp_Time, loc)
+							start_time := SxTime.Unix()
+
+							project_id, _ := GetbjncProjectID(org_id, ivalue.Combinationname)
+							item_id, _ := GetbjncItemID(org_id, ivalue.Combinationname, ivalue.Itemname, project_id)
+							tx := writeMiddleDb.Begin()
+							var inspection models.MiddleInspection
+							var inspection_reference models.MiddleInspectionReference
+
+							var total int
+							var RangeOptions string
+							var RangeMin string
+							var RangeMax string
+							var ItemType int
+							Range := strings.Split(ivalue.Referscope, "-")
+							if len(Range) > 1 {
+								RangeMin = Range[0]
+								RangeMax = Range[1]
+								ItemType = 1
+							} else {
+								ItemType = 2
+								RangeOptions = ivalue.Referscope
+							}
+
+							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 total <= 0 {
+								inspection_reference.OrgId = org_id
+								inspection_reference.ProjectName = ivalue.Combinationname
+								inspection_reference.Project = ivalue.Combinationname
+								inspection_reference.ProjectId = project_id
+								inspection_reference.ItemName = ivalue.Itemname
+								// inspection_reference.ItemNameAddition = strconv.FormatInt(info.ItemId, 10)
+								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 = ivalue.Unit
+								inspection_reference.Status = 1
+								inspection_reference.CreatedTime = time.Now().Unix()
+								inspection_reference.UpdatedTime = time.Now().Unix()
+								inspection_reference.InspectDate = ivalue.Testtime
+								inspection_reference.UTime = ivalue.Testtime
+								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, start_time, patient.ID).Find(&inspection).Count(&itotal).Error
+							if itotal <= 0 {
+								// inspection.InspectValue = strings.Replace(LisInfo.Testresult, "&gt;", ">", -1)
+								// inspection.InspectValue = strings.Replace(LiLisInfo.Testresult, "&lt;", "<", -1)
+								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 = ivalue.Itemreportresult
+								inspection.InspectDate = start_temp_Time
+								inspection.RecordDate = start_time
+								// inspection.InspectTips = report.Resultstate
+								inspection.Status = 1
+								inspection.CreatedTime = time.Now().Unix()
+								inspection.UpdatedTime = time.Now().Unix()
+								// inspection.UTime = record_date.Format(timeLayout)
+								// inspection.HisUserId = strconv.FormatInt(patient_id, 10)
+								err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+								if err != nil {
+									tx.Rollback()
+								}
+							}
+							tx.Commit()
+						}
+					}
+				}
+
+			} else {
+				continue
+			}
+		}
+	}
+	var syncInfo models.MiddleSyncInfo
+	syncInfo.OrgId = org_id
+	syncInfo.SyncTime = time.Now().Unix()
+	syncInfo.SyncResultType = 1
+	syncInfo.SyncRsultRemark = "同步成功"
+	syncInfo.SyncTotalNum = 0
+	syncInfo.SyncSuccessNum = 0
+	syncInfo.SyncInfo = ""
+	syncInfo.CreateTime = time.Now().Unix()
+	syncInfo.UpdateTime = time.Now().Unix()
+
+	cwderr := CreateSyncInfo(&syncInfo)
+	if cwderr != nil {
+		utils.ErrorLog("创建同步信息失败:%v", cwderr)
+		return
+	}
+	SyncToFjtftx()
+	return
+}
+
+type BjncPatientInfo struct {
+	Msg    string `json:"msg"`
+	Code   string `json:"code"`
+	Result []struct {
+		Patientid    int64  `json:"patientId"`
+		Visitid      int64  `json:"visitId"`
+		Outpatientno string `json:"outPatientNo"`
+		Patientname  string `json:"patientName"`
+		Idcardno     string `json:"idCardNo"`
+	} `json:"result"`
+}
+
+func BjncGetPatientInfo(id_card_no string, endTime string) (string, string) {
+	// 1.生成签名sign
+	var sync_time int64
+	sync_time = 1690819200 // 2023-08-01 00:00:00
+	sync_time_temp := time.Unix(sync_time, 0)
+	startTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+	signData := make(map[string]interface{})
+	//signData["dateType"] = "07"
+	signData["startTime"] = startTimeStr
+	signData["idCardNo"] = id_card_no
+	signData["endTime"] = endTime
+	bytesData, _ := json.Marshal(signData)
+	inputLog := string(bytesData)
+	signStr := "body=" + inputLog + "&operUserCode=100&serv=getRegisterInfo&key=A3195B3D179B01F66C86703E0890A95F"
+	signTemp := utils.String2md5(signStr)
+	sign := strings.ToUpper(signTemp)
+
+	// 2.请求参数
+	inputData := make(map[string]interface{})
+	inputData["body"] = signData
+	inputData["serv"] = "getRegisterInfo"
+	inputData["operUserCode"] = "100"
+	inputData["sign"] = sign
+
+	postData, err := json.Marshal(inputData)
+	postStr := string(postData)
+	utils.InfoLog("1111111111:%v", postStr)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	reader := bytes.NewReader(postData)
+	url := "http://123.127.8.35:18090/esb/listener/openapi/StandardInterface"
+
+	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", "XTXT")
+
+	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)
+	utils.InfoLog("22222222:%v", str)
+	return str, inputLog
+}
+
+type BjncLisReport struct {
+	Code   string `json:"code"`
+	Msg    string `json:"msg"`
+	Result []struct {
+		Patientid     string `json:"patientId"`
+		Patientname   string `json:"patientName"`
+		Reportno      int64  `json:"reportNo"`
+		Visitid       string `json:"visitId"`
+		Applydeptname string `json:"applyDeptName"`
+		Reportname    string `json:"reportName"`
+	} `json:"result"`
+}
+
+func BjncGetLisReport(id_card_no int64, startTime string, endTime string) (string, string) {
+	// 1.生成签名sign
+	signData := make(map[string]interface{})
+	signData["patientId"] = strconv.FormatInt(id_card_no, 10)
+	signData["dateType"] = "16"
+	signData["startTime"] = startTime
+	signData["endTime"] = endTime
+	bytesData, _ := json.Marshal(signData)
+	inputLog := string(bytesData)
+	signStr := "body=" + inputLog + "&operUserCode=100&serv=getLisReport&key=A3195B3D179B01F66C86703E0890A95F"
+	signTemp := utils.String2md5(signStr)
+	sign := strings.ToUpper(signTemp)
+
+	// 2.请求参数
+	inputData := make(map[string]interface{})
+	inputData["body"] = signData
+	inputData["serv"] = "getLisReport"
+	inputData["operUserCode"] = "100"
+	inputData["sign"] = sign
+
+	postData, err := json.Marshal(inputData)
+	postStr := string(postData)
+	utils.InfoLog("1111111111:%v", postStr)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	reader := bytes.NewReader(postData)
+	url := "http://123.127.8.35:18090/esb/listener/openapi/StandardInterface"
+
+	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", "XTXT")
+
+	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)
+	utils.InfoLog("22222222:%v", str)
+	return str, inputLog
+}
+
+type ReportDetail struct {
+	Msg    string `json:"msg"`
+	Code   string `json:"code"`
+	Result []struct {
+		Detailid         string `json:"detailId"`
+		Reportno         string `json:"reportNo"`
+		Testtime         string `json:"testTime"`
+		Combinationcode  string `json:"combinationCode"`
+		Combinationname  string `json:"combinationName"`
+		Itemcode         string `json:"itemCode"`
+		Itemname         string `json:"itemName"`
+		Abbreviation     string `json:"abbreviation"`
+		Itemreportresult string `json:"itemReportResult"`
+		Unit             string `json:"unit"`
+		Resultpoint      string `json:"resultPoint"`
+		Rownr            string `json:"rownr"`
+		Referlow         string `json:"referLow"`
+		Referhigh        string `json:"referHigh"`
+		Referscope       string `json:"referScope"`
+		Low              string `json:"low"`
+		High             string `json:"high"`
+	} `json:"result"`
+}
+
+func BjncGetReportInfo(report_no int64, startTime string, endTime string) (string, string) {
+	// 1.生成签名sign
+	signData := make(map[string]interface{})
+	signData["reportNo"] = strconv.FormatInt(report_no, 10)
+	signData["dateType"] = "16"
+	signData["startTime"] = startTime
+	signData["endTime"] = endTime
+	bytesData, _ := json.Marshal(signData)
+	inputLog := string(bytesData)
+	signStr := "body=" + inputLog + "&operUserCode=100&serv=getLisReportDetail&key=A3195B3D179B01F66C86703E0890A95F"
+	signTemp := utils.String2md5(signStr)
+	sign := strings.ToUpper(signTemp)
+
+	// 2.请求参数
+	inputData := make(map[string]interface{})
+	inputData["body"] = signData
+	inputData["serv"] = "getLisReportDetail"
+	inputData["operUserCode"] = "100"
+	inputData["sign"] = sign
+
+	postData, err := json.Marshal(inputData)
+	postStr := string(postData)
+	utils.InfoLog("1111111111:%v", postStr)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	reader := bytes.NewReader(postData)
+	url := "http://123.127.8.35:18090/esb/listener/openapi/StandardInterface"
+
+	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", "XTXT")
+
+	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)
+	utils.InfoLog("22222222:%v", str)
+	return str, inputLog
+}
+
+func SyncBjncHis() (err error) {
+	org_id := int64(10606)
+	redisClient := RedisClient()
+	defer redisClient.Close()
+
+	// 第一步：获取上一次同步的时间点
+	sync_time_tt, _ := redisClient.Get("bjncyyyy_sync_time").Result()
+
+	sync_time, _ := strconv.ParseInt(sync_time_tt, 10, 64)
+
+	if sync_time == 0 {
+		sync_time = time.Now().Unix() - 60*60*10
+		//sync_time = 1719763200
+	}
+
+	loc, _ := time.LoadLocation("Local") //重要：获取时区
+	sync_time_temp := time.Unix(sync_time, 0)
+	startTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+	end_time := time.Now().Unix()
+	end_time_temp := time.Unix(end_time, 0)
+	endTimeStr := end_time_temp.Format("2006-01-02 15:04:05")
+
+	new_sync_time := time.Now().Unix() - 60*60
+	redisClient.Set("bjncyyyy_sync_time", new_sync_time, time.Minute*60*24)
+	// 第二步：获取所有患者的病历号
+
+	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
+				utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
+				// utils.InfoLog("VipStr:%v", VipStr)
+
+				result, _ := BjncGetHis(patient.IdCardNo, startTimeStr, endTimeStr)
+				var bjncHis BjncHis
+				if err := json.Unmarshal([]byte(result), &bjncHis); err != nil {
+					utils.ErrorLog("解析失败：%v", err)
+				}
+				fmt.Println(bjncHis)
+				for _, cinfo := range bjncHis.Result {
+					fmt.Println(cinfo.Patientid)
+					// 查询该患者当天是否有排班信息
+
+					STime, _ := time.ParseInLocation("2006-01-02 15:04:05", cinfo.Itemeffectivetimelow, loc) //使用模板在对应时区转化为time.time类型
+					formattedTime := STime.Format("2006-01-02")
+					StTime, _ := time.ParseInLocation("2006-01-02", formattedTime, loc)
+					schedulesTime := StTime.Unix()
+
+					theTime, _ := time.ParseInLocation("2006-01-02 15:04:05", cinfo.Itemeffectivetimelow, loc) //使用模板在对应时区转化为time.time类型
+					start_temp_Time := theTime.Format("2006-01-02 15:04")
+					SxTime, _ := time.ParseInLocation("2006-01-02 15:04", start_temp_Time, loc)
+					start_time := SxTime.Unix()
+					utils.InfoLog("start_time:%v", start_time)
+
+					schedulesInfo, _ := GetSchedulesByPatientID(org_id, schedulesTime, patient.ID)
+					if schedulesInfo.ID > 0 {
+						start_time = theTime.Unix()
+					} else {
+						continue
+					}
+
+					// 根据同步来的 advice_id 来查询库里是否已经存在
+					advice_info, _ := GetAdviceBySyncAdviceIdForScyyyy(org_id, cinfo.Medicaladviceid, schedulesTime, patient.ID)
+					utils.InfoLog("Orderstatuscode:%v", cinfo.Orderstatuscode)
+					utils.InfoLog("AdviceName:%v", cinfo.Diagproname)
+					if advice_info.ID > 0 {
+						if cinfo.Orderstatuscode == 4 || cinfo.Orderstatuscode == 5 {
+							advice_info.Status = 0
+							SaveDoctorAdviceHandle(&advice_info)
+						} else {
+							continue
+						}
+					} else {
+						if cinfo.Orderstatuscode == 1 || cinfo.Orderstatuscode == 8 {
+							// 根据姓名获取医生ID
+							var doctor_id int64
+							temp_doctor_id, _ := redisClient.Get("bjncyyyy_doctor_id_" + cinfo.Orderdoctorcode).Result()
+							if len(temp_doctor_id) == 0 {
+								doctor, _ := GetAdminUserId(org_id, cinfo.Orderdoctorname)
+								doctor_id = doctor.AdminUserId
+								if doctor_id > 0 {
+									redisClient.Set("bjncyyyy_doctor_id_"+cinfo.Orderdoctorcode, doctor_id, time.Minute*60*2)
+								} else {
+									continue
+								}
+							} else {
+								doctor_id, _ = strconv.ParseInt(temp_doctor_id, 10, 64)
+							}
+							//
+							//	// 根据排班班次，固定医嘱时间
+
+							advice := models.XtDoctorAdvice{
+								UserOrgId:             org_id,
+								PatientId:             patient.ID,
+								AdviceType:            2,
+								AdviceDate:            schedulesTime,
+								StartTime:             start_time,
+								AdviceName:            cinfo.Diagproname,
+								RecordDate:            schedulesTime,
+								SingleDose:            cinfo.Dosequantity,
+								SingleDoseUnit:        cinfo.Dosequantityunit,
+								PrescribingNumber:     cinfo.Amount,
+								PrescribingNumberUnit: cinfo.Unit,
+								DeliveryWay:           cinfo.Routename,
+								ExecutionFrequency:    cinfo.Executefrequencyname,
+								AdviceDoctor:          doctor_id,
+								CreatedTime:           time.Now().Unix(),
+								UpdatedTime:           time.Now().Unix(),
+								SyncAdviceId:          cinfo.Medicaladviceid,
+								ExecutionState:        2,
+								Status:                1,
+								IsSync:                1,
+							}
+							utils.InfoLog("advice:%v", advice)
+
+							if len(cinfo.Diagproname) > 0 {
+								handleerr := CreateDoctorAdviceHandle(&advice)
+								if handleerr != nil {
+									utils.ErrorLog("添加医嘱信息失败:%v", handleerr)
+									continue
+								}
+							} else {
+								continue
+							}
+						} else {
+							continue
+						}
+					}
+				}
+			}
+		}
+	}
+
+	//var syncInfo models.MiddleSyncInfo
+	//syncInfo.OrgId = org_id
+	//syncInfo.SyncTime = time.Now().Unix()
+	//syncInfo.SyncResultType = 1
+	//syncInfo.SyncRsultRemark = "同步成功"
+	//syncInfo.SyncTotalNum = 0
+	//syncInfo.SyncSuccessNum = 0
+	//syncInfo.SyncInfo = ""
+	//syncInfo.CreateTime = time.Now().Unix()
+	//syncInfo.UpdateTime = time.Now().Unix()
+	//
+	//cwderr := CreateSyncInfo(&syncInfo)
+	//if cwderr != nil {
+	//	utils.ErrorLog("创建同步信息失败:%v", cwderr)
+	//	return
+	//}
+	//SyncToFjtftx()
+	return
+}
+
+type BjncHis struct {
+	Msg    string `json:"msg"`
+	Code   string `json:"code"`
+	Result []struct {
+		Patientid             string  `json:"patientId"`
+		Visitid               string  `json:"visitId"`
+		Outpatientno          string  `json:"outPatientNo"`
+		Patientname           string  `json:"patientName"`
+		Idcardno              string  `json:"idCardNo"`
+		Orderstatuscode       int64   `json:"orderStatusCode"`
+		Ordercreatetime       string  `json:"orderCreateTime"`
+		Orderdoctorcode       string  `json:"orderDoctorCode"`
+		Orderdoctorname       string  `json:"orderDoctorName"`
+		Medicaladviceid       int64   `json:"medicalAdviceId"`
+		Medicalordername      string  `json:"medicalOrderName"`
+		Itemname              string  `json:"itemName"`
+		Itemeffectivetimelow  string  `json:"itemEffectiveTimeLow"`
+		Executefrequencyname  string  `json:"executeFrequencyName"`
+		Routename             string  `json:"routeName"`
+		Dosequantity          float64 `json:"doseQuantity"`
+		Dosequantityunit      string  `json:"doseQuantityUnit"`
+		Totaldosequantity     float64 `json:"totalDoseQuantity"`
+		Totaldosequantityunit string  `json:"totalDoseQuantityUnit"`
+		Diagproname           string  `json:"diagProName"`
+		Amount                float64 `json:"amount"`
+		Unit                  string  `json:"unit"`
+	} `json:"result"`
+}
+
+func BjncGetHis(id_card_no string, startTime string, endTime string) (string, string) {
+	// 1.生成签名sign
+	signData := make(map[string]interface{})
+	signData["dateType"] = "07"
+	signData["medicalOrderType"] = "1,2,3,A,B,D,E,L,N,O"
+	signData["idCardNo"] = id_card_no
+	signData["startTime"] = startTime
+	signData["endTime"] = endTime
+	bytesData, _ := json.Marshal(signData)
+	inputLog := string(bytesData)
+	signStr := "body=" + inputLog + "&operUserCode=100&serv=getMedicalAdvice&key=A3195B3D179B01F66C86703E0890A95F"
+	signTemp := utils.String2md5(signStr)
+	sign := strings.ToUpper(signTemp)
+
+	// 2.请求参数
+	inputData := make(map[string]interface{})
+	inputData["body"] = signData
+	inputData["serv"] = "getMedicalAdvice"
+	inputData["operUserCode"] = "100"
+	inputData["sign"] = sign
+
+	postData, err := json.Marshal(inputData)
+	postStr := string(postData)
+	utils.InfoLog("1111111111:%v", postStr)
+	if err != nil {
+		fmt.Println(err.Error())
+		return err.Error(), ""
+	}
+
+	reader := bytes.NewReader(postData)
+	url := "http://123.127.8.35:18090/esb/listener/openapi/StandardInterface"
+
+	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", "XTXT")
+
+	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)
+	utils.InfoLog("22222222:%v", str)
+	return str, inputLog
+}
+
+//
+//func FjtjGetLac(lab01 int64) (string, string) {
+//	inputData := make(map[string]interface{})
+//
+//	inputData["lab01"] = lab01
+//
+//	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://hip.zptfyy.com/esb/listener/getLac1"
+//
+//	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", "xt")
+//
+//	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
+//}
+//
+//// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+//func GetfjtfProjectID(org_id int64, project_name string) (project_id int64, err error) {
+//	var inspection_reference models.MiddleInspectionReference
+//	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ?", org_id, project_name).First(&inspection_reference).Error
+//	if inspection_reference.ID > 0 {
+//		return inspection_reference.ProjectId, err
+//	} else {
+//		err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+//		if inspection_reference.ProjectId > 0 {
+//			return inspection_reference.ProjectId + 1, err
+//		} else {
+//			return 330001, err
+//		}
+//	}
+//}
+//
+//// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+//func GetFjtfItemID(org_id int64, project_name string, item_name string, project_id int64) (item_id int64, err error) {
+//	var inspection_reference models.MiddleInspectionReference
+//	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
+//	if inspection_reference.ID > 0 {
+//		return inspection_reference.ItemId, err
+//	} else {
+//		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id, project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+//		utils.InfoLog("inspection_reference: %v", inspection_reference)
+//		if inspection_reference.ItemId > 0 {
+//			return inspection_reference.ItemId + 1, err
+//		} else {
+//			return project_id*100 + 1, err
+//		}
+//	}
+//}
+//
+//func SyncToFjtftx() {
+//	utils.TraceLog("检验检查同步任务开始执行")
+//	org_id := int64(10330)
+//
+//	// 第一步：跟进org_id 去中间库查出需要同步的数据
+//	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+//	inspections, _ := GetSyncInspectionByOrgId(org_id)
+//
+//	// 第二步：将数据同步到业务库
+//	if len(inspection_references) > 0 {
+//		for _, inspection_reference := range inspection_references {
+//			SyncInspectionReference(&inspection_reference)
+//		}
+//	}
+//
+//	if len(inspections) > 0 {
+//		for _, inspection := range inspections {
+//			SyncInspection(&inspection)
+//		}
+//	}
+//	utils.SuccessLog("检验检查同步任务完成")
+//}

service/chyd_service.go

@@ -0,0 +1,359 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	_ "IC/utils"
+	"encoding/json"
+	_ "encoding/json"
+	"encoding/xml"
+	_ "fmt"
+	"github.com/astaxie/beego/httplib"
+	_ "github.com/jinzhu/gorm"
+	"net/url"
+	"strconv"
+	"strings"
+	"time"
+)
+
+type XmlKeyChyd struct {
+	XMLName    xml.Name `xml:"string"`
+	StringName string   `xml:"name,attr"`
+	InnerText  string   `xml:",innerxml"`
+}
+
+// 获取艾迪康的key
+func GetAdKeyChyd(logid string, password string) (key string) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/Login?"
+	apiurl := "logid=" + logid + "&password=" + password
+	apiurl = url.PathEscape(apiurl)
+	apiurl = Domain + apiurl
+	XmlKeyChyd := XmlKeyChyd{}
+	httplib.Get(apiurl).ToXML(&XmlKeyChyd)
+	return XmlKeyChyd.InnerText
+}
+
+type ADStringChyd struct {
+	XMLName        xml.Name         `xml:"string" json:"string"`
+	NewDataSetChyd rpnewDataSetChyd `xml:"NewDataSet" json:"NewDataSet"`
+}
+
+type rpnewDataSetChyd struct {
+	ListTableChyd []rplisttableChyd `xml:"listtable" json:"listtable"`
+}
+
+type rplisttableChyd struct {
+	Id              string `xml:"Id" json:"Id"`
+	ReportType      string `xml:"ReportType" json:"ReportType"`
+	AdiconBarcode   string `xml:"AdiconBarcode" json:"AdiconBarcode"`
+	PatientName     string `xml:"PatientName" json:"PatientName"`
+	Bgrq            string `xml:"Bgrq" json:"Bgrq"`
+	Instrument      string `xml:"Instrument" json:"Instrument"`
+	LisDate         string `xml:"LisDate" json:"LisDate"`
+	Sampleid        string `xml:"Sampleid" json:"Sampleid"`
+	CustomerBarcode string `xml:"CustomerBarcode" json:"CustomerBarcode"`
+	Repno           string `xml:"Repno" json:"Repno"`
+	// PdfFileName		string `xml:"PdfFileName" json:"PdfFileName"`
+	// DownFlag		string `xml:"DownFlag" json:"DownFlag"`
+	// DownDate		string `xml:"DownDate" json:"DownDate"`
+	Sjrq string `xml:"Sjrq" json:"Sjrq"`
+	// Sjys		string `xml:"Sjys" json:"Sjys"`
+	// Brnl		string `xml:"Brnl" json:"Brnl"`
+	// Brxb		string `xml:"Brxb" json:"Brxb"`
+	Bbzl string `xml:"bbzl" json:"bbzl"`
+	// Bzlbid		string `xml:"Bzlbid" json:"Bzlbid"`
+	// PDFFileType		string `xml:"PDFFileType" json:"PDFFileType"`
+	// PageType		string `xml:"PageType" json:"PageType"`
+	PatientNo string `xml:"PatientNo" json:"PatientNo"`
+	// SfzId		string `xml:"SfzId" json:"SfzId"`
+	// CertificatesType		string `xml:"CertificatesType" json:"CertificatesType"`
+	// Nationality		string `xml:"Nationality" json:"Nationality"`
+	// SerialNumber		string `xml:"SerialNumber" json:"SerialNumber"`
+	// Str1		string `xml:"Str1" json:"Str1"`
+	// Str2		string `xml:"Str2" json:"Str2"`
+	// Str3		string `xml:"Str3" json:"Str3"`
+	// Str4		string `xml:"Str4" json:"Str4"`
+	// Str5		string `xml:"Str5" json:"Str5"`
+	// TWBG		string `xml:"TWBG" json:"TWBG"`
+}
+
+// 获取机构一段时间内检验检查列表
+func GetAdGetReportListChyd(Key string, BeginDateTime string, EndDateTime string, TypeDateTime string, AgainFlag string) (key ADStringChyd) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/GetReportList"
+	//apiurl := "Key=" + Key + "&BeginDateTime=" + BeginDateTime + "&EndDateTime=" + EndDateTime + "&TypeDateTime=" + TypeDateTime + "&AgainFlag=" + AgainFlag
+	//apiurl = url.PathEscape(apiurl)
+	//apiurl = Domain + apiurl
+	//utils.InfoLog("url0: %v", apiurl)
+	var xmlKey ADStringChyd
+	req := httplib.Post(Domain)
+	req.Param("Key", Key)
+	req.Param("BeginDateTime", BeginDateTime)
+	req.Param("EndDateTime", EndDateTime)
+	req.Param("TypeDateTime", TypeDateTime)
+	req.Param("AgainFlag", AgainFlag)
+	xmlString, _ := req.String()
+	xmlString = strings.Replace(xmlString, "&lt;", "<", -1)
+	xmlString = strings.Replace(xmlString, "&gt;", ">", -1)
+	xml.Unmarshal([]byte(xmlString), &xmlKey)
+	return xmlKey
+}
+
+type AdkCheckChyd struct {
+	Cgbg AdkSResult `json:"常规报告"`
+}
+
+type AdkSResult struct {
+	Item []AdkItem `json:"item"`
+}
+
+type AdkItem struct {
+	Adiconbarcode   string `json:"AdiconBarcode"`
+	Patientname     string `json:"PatientName"`
+	Sex             string `json:"Sex"`
+	Age             string `json:"Age"`
+	Reportdate      string `json:"ReportDate"`
+	Itemcode        string `json:"ItemCode"`
+	ItemnameCn      string `json:"ItemName_CN"`
+	ItemnameEn      string `json:"ItemName_EN"`
+	Result          string `json:"Result"`
+	Resulthint      string `json:"ResultHint"`
+	Resultreference string `json:"ResultReference"`
+	Resultunit      string `json:"ResultUnit"`
+	Zhmc            string `json:"zhmc"`
+}
+
+func GetAdkInfoChyd(key string, id string) (str AdkCheckChyd, checkStr string) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/GetJSONReportItemListByAdiconBarocde?"
+	//apiurl := "key=" + key + "&AdiconBarocde=" + id
+	//apiurl = url.PathEscape(apiurl)
+	//apiurl = Domain + apiurl
+	//utils.InfoLog("url1: %v", apiurl)
+	xmlKey := XmlKeyChyd{}
+	rep := httplib.Post(Domain)
+	rep.Param("Key", key)
+	rep.Param("AdiconBarcode", id)
+	rep.ToXML(&xmlKey)
+	utils.InfoLog("InnerText: %v", xmlKey.InnerText)
+	var checkJSON AdkCheckChyd
+	json.Unmarshal([]byte(xmlKey.InnerText), &checkJSON)
+
+	return checkJSON, xmlKey.InnerText
+}
+
+// 从化意达透析中心Lis同步
+func SyncLisChyd(flag int64) (err error) {
+	// 第一步：获取艾迪康下发的Key
+	org_id := int64(10318)
+	login := "RH0222"
+	password := "Abc123123"
+	key := GetAdKeyChyd(login, password)
+	utils.InfoLog("key:%v", key)
+	// 第二步：获取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime
+	} else {
+		sync_time = 1704038400
+	}
+
+	if flag > 0 {
+		sync_time = 1704038400
+	}
+
+	nowTimes := time.Now().Unix()
+	// syncTimes := time.Unix(sync_time,0).Format("2006-01-02")
+	if sync_time < nowTimes {
+		for i := sync_time; i < nowTimes; i = i + 86400 {
+			tempsyncTimes := time.Unix(i, 0).Format("2006-01-02")
+			adString := GetAdGetReportListChyd(key, tempsyncTimes, tempsyncTimes, "2", "1")
+			listtable := adString.NewDataSetChyd.ListTableChyd
+			if len(listtable) >= 1 {
+				// 第三步：根据检查列表获取的ID来获取检验检查详情
+				for _, list := range listtable {
+					listId := list.AdiconBarcode
+					checkInfo, _ := GetAdkInfoChyd(key, listId)
+					//utils.InfoLog("checkStr: %v", checkStr)
+					for _, info := range checkInfo.Cgbg.Item {
+						// 根据姓名 去查询对应的patient_id
+						patient, _ := GetPatientID(org_id, info.Patientname)
+						utils.InfoLog("patient: %v", patient)
+						if patient.ID > 0 {
+							ChydReportInfoHandle(info, org_id, patient.ID)
+						}
+					}
+				}
+				var syncInfo models.MiddleSyncInfo
+				syncInfo.OrgId = org_id
+
+				syncInfo.SyncTime = i
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "同步成功"
+				syncInfo.SyncTotalNum = 0
+				syncInfo.SyncSuccessNum = 0
+				syncInfo.SyncInfo = ""
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				cwderr := CreateSyncInfo(&syncInfo)
+				if cwderr != nil {
+					utils.ErrorLog("创建同步信息失败:%v", cwderr)
+					return
+				}
+			}
+		}
+
+	}
+	SyncToChyd()
+	return
+}
+
+func SyncToChyd() {
+
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10318)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetChydItemID(org_id int64, project_name string, item_name string, project_id int64) (item_id int64, err error) {
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ItemId, err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id, project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+		utils.InfoLog("inspection_reference: %v", inspection_reference)
+		if inspection_reference.ItemId > 0 {
+			return inspection_reference.ItemId + 1, err
+		} else {
+			return project_id*100 + 1, err
+		}
+	}
+}
+
+// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+func GetChydProjectID(org_id int64, project_name string) (project_id int64, err error) {
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ?", org_id, project_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId, err
+	} else {
+		err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+		if inspection_reference.ProjectId > 0 {
+			return inspection_reference.ProjectId + 1, err
+		} else {
+			return 1031801, err
+		}
+	}
+}
+
+func ChydReportInfoHandle(CheckInfo AdkItem, org_id int64, patientId int64) {
+	tx := writeMiddleDb.Begin()
+	var total int
+	var RangeMin string
+	var RangeMax string
+
+	timstr := strings.Split(CheckInfo.Reportdate, ".")
+	recordDateStr := timstr[0]
+
+	if len(recordDateStr) == 0 {
+		recordDateStr = time.Now().Format("2006-01-02 15:04")
+	}
+
+	record_date_str, _ := utils.ParseTimeStringToTime("2006-01-02 15:04:05", recordDateStr)
+	record_date := record_date_str.Unix()
+	inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
+
+	// // 判断检查类型
+	ItemType := 1
+	Range := strings.Split(CheckInfo.Resultreference, "-")
+	if len(Range) > 1 {
+		RangeMin = Range[0]
+		RangeMax = Range[1]
+		ItemType = 1
+	} else {
+		ItemType = 2
+	}
+
+	var inspection models.MiddleInspection
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and project = ? and item_code = ? and status = 1", org_id, CheckInfo.Zhmc, CheckInfo.Itemcode).Find(&inspection_reference).Count(&total).Error
+	if inspection_reference.ID > 0 {
+		ItemType = inspection_reference.RangeType
+	}
+	if total <= 0 {
+		//  如果配置表里没有相关配置，则创建project_id,item_id和相关配置信息
+		project_id, _ := GetChydProjectID(org_id, CheckInfo.Zhmc)
+		item_id, _ := GetChydItemID(org_id, CheckInfo.Zhmc, CheckInfo.ItemnameCn, project_id)
+
+		inspection_reference.OrgId = org_id
+		inspection_reference.ProjectName = CheckInfo.Zhmc
+		inspection_reference.Project = CheckInfo.Zhmc
+		inspection_reference.ProjectId = project_id
+		inspection_reference.ItemName = CheckInfo.ItemnameCn
+		inspection_reference.ItemNameAddition = CheckInfo.ItemnameEn
+		inspection_reference.ItemId = item_id
+		inspection_reference.ItemCode = CheckInfo.Itemcode
+		inspection_reference.RangeType = ItemType
+		inspection_reference.RangeMin = RangeMin
+		inspection_reference.RangeMax = RangeMax
+		// inspection_reference.RangeValue = RangeValue
+		//inspection_reference.RangeOptions = RangeOptions
+		inspection_reference.Unit = CheckInfo.Resultunit
+		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
+		inspection_reference.Adiconbarcode = CheckInfo.Adiconbarcode
+		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, inspection_reference.ProjectId, inspection_reference.ItemId, record_date, patientId).Find(&inspection).Count(&itotal).Error
+	if itotal <= 0 {
+		inspection.PatientId = patientId
+		inspection.OrgId = org_id
+		inspection.ProjectId = inspection_reference.ProjectId
+		inspection.ItemName = inspection_reference.ItemName
+		inspection.ProjectName = inspection_reference.ProjectName
+		inspection.InspectType = ItemType
+		inspection.ItemId = inspection_reference.ItemId
+		inspection.InspectValue = CheckInfo.Result
+		inspection.InspectDate = inspect_date
+		inspection.RecordDate = record_date
+		//inspection.InspectTips = result.AntiCode
+		inspection.Status = 1
+		inspection.CreatedTime = time.Now().Unix()
+		inspection.UpdatedTime = time.Now().Unix()
+		inspection.UTime = inspect_date
+		inspection.HisUserId = strconv.FormatInt(patientId, 10)
+		inspection.Adiconbarcode = CheckInfo.Adiconbarcode
+		err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+	tx.Commit()
+}

service/cron.go

@@ -5,10 +5,8 @@ import (
 	"IC/utils"
 	"encoding/json"
 	_ "fmt"
-	oracle "github.com/dzwvip/gorm-oracle"
 	_ "github.com/jinzhu/gorm"
 	"github.com/robfig/cron/v3"
-	"gorm.io/gorm"
 	_ "strings"
 	"time"
 )
@@ -31,11 +29,11 @@ func BeginAutoSyncLis() {
 	utils.InfoLog("开启自动检验检查同步定时任务")
 	createLisSyncCronJob := newWithSeconds()
 
-	orgDb, err := gorm.Open(oracle.Open("oracle://zjybase:zjybase@10.0.0.248:1521/orcl"), &gorm.Config{})
-
-	if err != nil {
-		utils.InfoLog("创建数据库连接失败:%v", err)
-	}
+	//orgDb, err := gorm.Open(oracle.Open("oracle://zjybase:zjybase@10.0.0.248:1521/orcl"), &gorm.Config{})
+	//
+	//if err != nil {
+	//	utils.InfoLog("创建数据库连接失败:%v", err)
+	//}
 
 	//specys := "0 0 */1 * * ?" // 每天凌晨3点同步 唐山朝阳医院
 	//createLisSyncCronJob.AddFunc(specys, func() {
@@ -82,10 +80,10 @@ func BeginAutoSyncLis() {
 	//	SyncLisSzwz()
 	//})
 
-	//spec8 := "0 25 */2 * * ?" // 每个小时同步一次 汕头三优透析中心LIS对接，本地部署的
-	//createLisSyncCronJob.AddFunc(spec8, func() {
-	//	SyncStsyLis()
-	//})
+	spec8 := "0 25 */3 * * ?" // 每个小时同步一次 汕头三优透析中心LIS对接，本地部署的
+	createLisSyncCronJob.AddFunc(spec8, func() {
+		SyncStsyLis()
+	})
 
 	//spec9 := "0 57 * * * ?" // 每个小时同步一次 遵化仁爱医院LIS对接，本地部署的
 	//createLisSyncCronJob.AddFunc(spec9, func() {
@@ -132,15 +130,25 @@ func BeginAutoSyncLis() {
 	//	SyncJhhjyyLis()
 	//})
 
-	spec18 := "1 * * * * ?" // 每个30秒同步一次 四川乐山友谊医院医嘱对接，本地部署的
-	createLisSyncCronJob.AddFunc(spec18, func() {
-		SyncSclsyyyyyz(orgDb)
-	})
+	//spec18 := "1 * * * * ?" // 每个30秒同步一次 四川乐山友谊医院医嘱对接，本地部署的
+	//createLisSyncCronJob.AddFunc(spec18, func() {
+	//	SyncSclsyyyyyz(orgDb)
+	//})
 
-	spec19 := "* 35 */4 * * ?" // 每个2个小时同步一次 四川乐山友谊医院LIS对接，本地部署的
-	createLisSyncCronJob.AddFunc(spec19, func() {
-		SyncScyyyyLis()
-	})
+	//spec19 := "* 35 */4 * * ?" // 每个2个小时同步一次 四川乐山友谊医院LIS对接，本地部署的
+	//createLisSyncCronJob.AddFunc(spec19, func() {
+	//	SyncScyyyyLis()
+	//})
+
+	//spec20 := "* 15 */2 * * ?" // 每个2个小时同步一次 四川乐山友谊医院LIS对接，本地部署的
+	//createLisSyncCronJob.AddFunc(spec20, func() {
+	//	SyncGzkyLis()
+	//})
+
+	//spec21 := "1 * * * * ?" // 每个30秒同步一次 四川乐山友谊医院医嘱对接，本地部署的
+	//createLisSyncCronJob.AddFunc(spec21, func() {
+	//	SyncBjncHis()
+	//})
 
 	createLisSyncCronJob.Start()
 }

service/jhhjyy_service.go

@@ -0,0 +1,260 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	_ "encoding/json"
+	_ "fmt"
+	"github.com/jinzhu/gorm"
+	"strings"
+	"time"
+)
+
+type jhhjyyLis struct {
+	HisUserId    string `json:"his_user_id"`
+	PatientName  string `json:"patient_name"`
+	ProjectId    string `json:"project_id"`
+	ProjectName  string `json:"project_name"`
+	InspectDate  string `json:"inspect_date"`
+	ItemId       string `json:"item_id"`
+	ItemName     string `json:"item_name"`
+	ItemType     string `json:"item_type"`
+	ItemValue    string `json:"item_value"`
+	RangeMin     string `json:"range_min"`
+	RangeMax     string `json:"range_max"`
+	RangeValue   string `json:"range_value"`
+	RangeOptions string `json:"range_options"`
+	Unit         string `json:"unit"`
+	State        string `json:"state"`
+	CTime        string `json:"c_time"`
+	UTime        string `json:"u_time"`
+}
+
+func (jhhjyyLis) TableName() string {
+	return "GetJianYanXX"
+}
+
+func GetJhhjyyLis(rdb *gorm.DB, synctime string, his_user_id string, patient_name string) (record []*jhhjyyLis, err error) {
+	err = rdb.Model(&jhhjyyLis{}).Where("c_time >= ? and (his_user_id = ? or patient_name = ?)", synctime, his_user_id, patient_name).Find(&record).Error
+	return
+}
+
+//// 根据机构ID和患者身份证号码获取患者信息
+//func GetUserInIdcardNoByOrg(org_id int64) (patients []*models.Patients, err error) {
+//	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? and status = 1 ", org_id).Find(&patients).Error
+//	return
+//}
+
+// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+func GetJhhjyyProjectID(org_id int64, project_name string, item_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 = ? and item_name = ? ", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId, err
+	} else {
+		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 {
+			err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+			if inspection_reference.ProjectId > 0 {
+				return inspection_reference.ProjectId + 1, err
+			} else {
+				return 1062901, err
+			}
+		}
+	}
+}
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetJhhjyyItemID(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 = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ItemId, err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id, project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+		if inspection_reference.ItemId > 0 {
+			return inspection_reference.ItemId + 1, err
+		} else {
+			return project_id*100 + 1, err
+		}
+	}
+}
+
+// 湖南郴州嘉禾恒佳医院Lis同步
+func SyncJhhjyyLis() (err error) {
+	org_id := int64(10629)
+
+	org := &models.DataUploadConfig{
+		OrgId:  org_id,
+		DbHost: "192.168.5.253",
+		DbPort: "1433",
+		DbPass: "XtUser",
+		DbUser: "XtUser",
+		DbName: "HealthOne",
+	}
+
+	orgDb, err := CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+	if err != nil {
+		utils.ErrorLog("创建数据库连接失败:%v", err)
+		return
+	}
+
+	// 第一步：获取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime
+	} else {
+		sync_time = 1704038400 // 2023-01-01
+	}
+	// 第二步：获取时间内所有检验结果
+	sync_time_temp := time.Unix(sync_time, 0)
+	startTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+
+	patients, _ := GetUserInIdcardNoByOrg(org_id)
+
+	if len(patients) > 0 {
+		for _, patient := range patients {
+			userCardId := patient.IdCardNo
+			// 根据姓名获取患者ID
+			jhhyyyLis, _ := GetJhhjyyLis(orgDb, startTimeStr, userCardId, patient.Name)
+			if len(jhhyyyLis) > 0 {
+				for _, LisInfo := range jhhyyyLis {
+					project_id, _ := GetJhhjyyProjectID(org_id, LisInfo.ProjectName, LisInfo.ItemName)
+					item_id, _ := GetJhhjyyItemID(org_id, LisInfo.ProjectName, LisInfo.ItemName, project_id)
+					tx := writeMiddleDb.Begin()
+					var inspection models.MiddleInspection
+					var inspection_reference models.MiddleInspectionReference
+
+					timeLayout := "2006-01-02 15:04"
+					loc, _ := time.LoadLocation("Local")
+
+					utils.InfoLog("1111111---%v", LisInfo.InspectDate)
+					timstr := strings.Split(LisInfo.InspectDate, "T")
+					timstem := strings.Split(timstr[1], "Z")
+					tempRecord := timstr[0] + " " + timstem[0]
+					utils.InfoLog("2222222---%v", tempRecord)
+
+					recordTime, _ := time.ParseInLocation("2006-01-02 15:04:05", tempRecord, loc)
+					recordTimeInt := recordTime.Unix()
+					recordTimeStr := time.Unix(recordTimeInt, 0).Format(timeLayout)
+
+					var total int
+					var RangeOptions string
+					var RangeMin string
+					var RangeMax string
+					var ItemType int
+					Range := strings.Split(LisInfo.RangeValue, "-")
+					if len(Range) > 1 {
+						RangeMin = Range[0]
+						RangeMax = Range[1]
+						ItemType = 1
+					} else {
+						ItemType = 2
+						RangeOptions = LisInfo.RangeValue
+					}
+
+					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 total <= 0 {
+						inspection_reference.OrgId = org_id
+						inspection_reference.ProjectName = LisInfo.ProjectName
+						inspection_reference.Project = LisInfo.ProjectName
+						inspection_reference.ProjectId = project_id
+						inspection_reference.ItemName = LisInfo.ItemName
+						// inspection_reference.ItemNameAddition = strconv.FormatInt(info.ItemId, 10)
+						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 = LisInfo.Unit
+						inspection_reference.Status = 1
+						inspection_reference.CreatedTime = time.Now().Unix()
+						inspection_reference.UpdatedTime = time.Now().Unix()
+						inspection_reference.InspectDate = recordTimeStr
+						inspection_reference.UTime = recordTimeStr
+						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, recordTimeStr, patient.ID).Find(&inspection).Count(&itotal).Error
+					if itotal <= 0 {
+						// inspection.InspectValue = strings.Replace(LisInfo.Testresult, "&gt;", ">", -1)
+						// inspection.InspectValue = strings.Replace(LiLisInfo.Testresult, "&lt;", "<", -1)
+						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 = LisInfo.ItemValue
+						inspection.InspectDate = recordTimeStr
+						inspection.RecordDate = recordTimeInt
+						// inspection.InspectTips = report.Resultstate
+						inspection.Status = 1
+						inspection.CreatedTime = time.Now().Unix()
+						inspection.UpdatedTime = time.Now().Unix()
+						// inspection.UTime = record_date.Format(timeLayout)
+						// inspection.HisUserId = strconv.FormatInt(patient_id, 10)
+						err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+						if err != nil {
+							tx.Rollback()
+						}
+					}
+					tx.Commit()
+				}
+			} else {
+				continue
+			}
+		}
+
+		var syncInfo models.MiddleSyncInfo
+		syncInfo.OrgId = org_id
+		syncInfo.SyncTime = time.Now().Unix()
+		syncInfo.SyncResultType = 1
+		syncInfo.SyncRsultRemark = "同步成功"
+		syncInfo.SyncTotalNum = 0
+		syncInfo.SyncSuccessNum = 0
+		syncInfo.SyncInfo = ""
+		syncInfo.CreateTime = time.Now().Unix()
+		syncInfo.UpdateTime = time.Now().Unix()
+
+		cwderr := CreateSyncInfo(&syncInfo)
+		if cwderr != nil {
+			utils.ErrorLog("创建同步信息失败:%v", cwderr)
+			return
+		}
+	}
+	SyncToJhhjyy()
+	return
+}
+
+func SyncToJhhjyy() {
+
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10629)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}

service/sclsyyyy_service.go

@@ -0,0 +1,465 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	_ "encoding/json"
+	_ "fmt"
+	oracle "github.com/dzwvip/gorm-oracle"
+	"gorm.io/gorm"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// 四川乐山友谊医院 HIS医嘱同步+LIS检验结果同步
+
+type scyyyylis struct {
+	HisUserId    string `gorm:"column:HIS_USER_ID" json:"HIS_USER_ID"`
+	PatientName  string `gorm:"column:PATIENT_NAME" json:"PATIENT_NAME"`
+	ProjectId    string `gorm:"column:PROJECT_ID" json:"PROJECT_ID"`
+	ProjectName  string `gorm:"column:PROJECT_NAME" json:"PROJECT_NAME"`
+	InspectDate  string `gorm:"column:INSPECT_DATE" json:"INSPECT_DATE"`
+	ItemId       string `gorm:"column:ITEM_ID" json:"ITEM_ID"`
+	ItemName     string `gorm:"column:ITEM_NAME" json:"ITEM_NAME"`
+	ItemType     int64  `gorm:"column:ITEM_TYPE" json:"ITEM_TYPE"`
+	ItemValue    string `gorm:"column:ITEM_VALUE" json:"ITEM_VALUE"`
+	RangeMin     string `gorm:"column:RANGE_MIN" json:"RANGE_MIN"`
+	RangeMax     string `gorm:"column:RANGE_MAX" json:"RANGE_MAX"`
+	RangeValue   string `gorm:"column:RANGE_VALUE" json:"RANGE_VALUE"`
+	RangeOptions string `gorm:"column:RANGE_OPTIONS" json:"RANGE_OPTIONS"`
+	Unit         string `gorm:"column:UNIT" json:"UNIT"`
+	State        int64  `gorm:"column:STATE" json:"STATE"`
+	CTime        string `gorm:"column:C_TIME" json:"C_TIME"`
+	UTime        string `gorm:"column:U_TIME" json:"U_TIME"`
+}
+
+func (scyyyylis) TableName() string {
+	return "yyyyxthy"
+}
+
+func GetSclsyyyyLis(rdb *gorm.DB, c_time string) (record []*scyyyylis, err error) {
+	err = rdb.Model(&scyyyylis{}).Where("C_TIME >= TO_DATE(?, 'YYYY-MM-DD HH24:MI:SS')", c_time).Find(&record).Error
+	return
+}
+
+// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+func GetScyyyyProjectID(org_id int64, project_name string, item_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 = ? and item_name = ? ", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId, err
+	} else {
+		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 {
+			err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+			if inspection_reference.ProjectId > 0 {
+				return inspection_reference.ProjectId + 1, err
+			} else {
+				return 1067701, err
+			}
+		}
+	}
+}
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetScyyyyItemID(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 = ? and item_name = ?", org_id, project_name, item_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ItemId, err
+	} else {
+		err := readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id = ? and project_id = ? ", org_id, project_id).Select("max(item_id) as item_id").First(&inspection_reference).Error
+		if inspection_reference.ItemId > 0 {
+			return inspection_reference.ItemId + 1, err
+		} else {
+			return project_id*100 + 1, err
+		}
+	}
+}
+
+// 四川乐山友谊医院Lis同步
+func SyncScyyyyLis() (err error) {
+	org_id := int64(10677)
+	orgDb, err := gorm.Open(oracle.Open("oracle://zjybase:zjybase@10.0.0.248:1521/orcl"), &gorm.Config{})
+
+	if err != nil {
+		utils.InfoLog("创建数据库连接失败:%v", err)
+	}
+
+	// 第一步：获取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime
+	} else {
+		sync_time = 1704038400 // 2024-01-01
+	}
+
+	// 第二步：获取时间内所有检验结果
+	sync_time_temp := time.Unix(sync_time, 0)
+	startTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+
+	yyyyLis, _ := GetSclsyyyyLis(orgDb, startTimeStr)
+	if len(yyyyLis) > 0 {
+		for _, LisInfo := range yyyyLis {
+			var patientInfo models.Patients
+			// 根据身份证号获取患者信息
+			if len(LisInfo.HisUserId) > 0 {
+				patientInfo, _ = GetPatientsInfoByIDCardNo(LisInfo.HisUserId, org_id)
+				if patientInfo.ID <= 0 {
+					continue
+				}
+			} else {
+				patientInfo, _ = GetPatientsInfoByName(LisInfo.PatientName, org_id)
+				if patientInfo.ID <= 0 {
+					continue
+				}
+			}
+
+			timeLayout := "2006-01-02 15:04"
+			loc, _ := time.LoadLocation("Local")
+
+			timstr := strings.Split(LisInfo.InspectDate, "T")
+			timstem := strings.Split(timstr[1], "+")
+			tempRecord := timstr[0] + " " + timstem[0]
+			recordTime, _ := time.ParseInLocation("2006-01-02 15:04:05", tempRecord, loc)
+			recordTimeInt := recordTime.Unix()
+			recordTimeStr := time.Unix(recordTimeInt, 0).Format(timeLayout)
+
+			project_id, _ := GetScyyyyProjectID(org_id, LisInfo.ProjectName, LisInfo.ItemName)
+			item_id, _ := GetScyyyyItemID(org_id, LisInfo.ProjectName, LisInfo.ItemName, project_id)
+			tx := writeMiddleDb.Begin()
+			var inspection models.MiddleInspection
+			var inspection_reference models.MiddleInspectionReference
+
+			var total int
+			var RangeOptions string
+			var RangeMin string
+			var RangeMax string
+			var ItemType int
+			Range := strings.Split(LisInfo.RangeValue, "--")
+			if len(Range) > 1 {
+				RangeMin = Range[0]
+				RangeMax = Range[1]
+				ItemType = 1
+			} else {
+				ItemType = 2
+				RangeOptions = LisInfo.RangeValue
+			}
+
+			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 total <= 0 {
+				inspection_reference.OrgId = org_id
+				inspection_reference.ProjectName = LisInfo.ProjectName
+				inspection_reference.Project = LisInfo.ProjectName
+				inspection_reference.ProjectId = project_id
+				inspection_reference.ItemName = LisInfo.ItemName
+				// inspection_reference.ItemNameAddition = strconv.FormatInt(info.ItemId, 10)
+				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 = LisInfo.Unit
+				inspection_reference.Status = 1
+				inspection_reference.CreatedTime = time.Now().Unix()
+				inspection_reference.UpdatedTime = time.Now().Unix()
+				inspection_reference.InspectDate = recordTimeStr
+				inspection_reference.UTime = recordTimeStr
+				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, recordTimeStr, patientInfo.ID).Find(&inspection).Count(&itotal).Error
+			if itotal <= 0 {
+				// inspection.InspectValue = strings.Replace(LisInfo.Testresult, "&gt;", ">", -1)
+				// inspection.InspectValue = strings.Replace(LiLisInfo.Testresult, "&lt;", "<", -1)
+				inspection.PatientId = patientInfo.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 = LisInfo.ItemValue
+				inspection.InspectDate = recordTimeStr
+				inspection.RecordDate = recordTimeInt
+				// inspection.InspectTips = report.Resultstate
+				inspection.Status = 1
+				inspection.CreatedTime = time.Now().Unix()
+				inspection.UpdatedTime = time.Now().Unix()
+				// inspection.UTime = record_date.Format(timeLayout)
+				// inspection.HisUserId = strconv.FormatInt(patient_id, 10)
+				err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+				if err != nil {
+					tx.Rollback()
+				}
+			}
+			tx.Commit()
+		}
+		var syncInfo models.MiddleSyncInfo
+		syncInfo.OrgId = org_id
+		syncInfo.SyncTime = time.Now().Unix()
+		syncInfo.SyncResultType = 1
+		syncInfo.SyncRsultRemark = "同步成功"
+		syncInfo.SyncTotalNum = 0
+		syncInfo.SyncSuccessNum = 0
+		syncInfo.SyncInfo = ""
+		syncInfo.CreateTime = time.Now().Unix()
+		syncInfo.UpdateTime = time.Now().Unix()
+
+		cwderr := CreateSyncInfo(&syncInfo)
+		if cwderr != nil {
+			utils.ErrorLog("创建同步信息失败:%v", cwderr)
+			return
+		}
+	}
+
+	SyncToSclsyyyy()
+	return
+}
+
+func SyncToSclsyyyy() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10677)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}
+
+type yyyyxtyz struct {
+	HisUserId             string `gorm:"column:HIS_USER_ID" json:"HIS_USER_ID" form:"HIS_USER_ID"`
+	UserName              string `gorm:"column:USER_NAME" json:"USER_NAME" form:"USER_NAME"`
+	DoctorId              string `gorm:"column:DOCTOR_ID" json:"DOCTOR_ID" form:"DOCTOR_ID"`
+	DoctorName            string `gorm:"column:DOCTOR_NAME" json:"DOCTOR_NAME" form:"DOCTOR_NAME"`
+	AdviceId              int64  `gorm:"column:ADVICE_ID" json:"ADVICE_ID" form:"ADVICE_ID"`
+	MedListCodg           string `gorm:"column:MED_LIST_CODG" json:"MED_LIST_CODG" form:"MED_LIST_CODG"`
+	StartTime             string `gorm:"column:START_TIME" json:"START_TIME" form:"START_TIME"`
+	AdviceName            string `gorm:"column:ADVICE_NAME" json:"ADVICE_NAME" form:"ADVICE_NAME"`
+	AdviceDesc            string `gorm:"column:ADVICE_DESC" json:"ADVICE_DESC" form:"ADVICE_DESC"`
+	SingleDose            string `gorm:"column:SINGLE_DOSE" json:"SINGLE_DOSE" form:"SINGLE_DOSE"`
+	SingleDoseUnit        string `gorm:"column:SINGLE_DOSE_UNIT" json:"SINGLE_DOSE_UNIT" form:"SINGLE_DOSE_UNIT"`
+	PrescribingNumber     string `gorm:"column:PRESCRIBING_NUMBER" json:"PRESCRIBING_NUMBER" form:"PRESCRIBING_NUMBER"`
+	PrescribingNumberUnit string `gorm:"column:PRESCRIBING_NUMBER_UNIT" json:"PRESCRIBING_NUMBER_UNIT" form:"PRESCRIBING_NUMBER_UNIT"`
+	DeliveryWay           string `gorm:"column:DELIVERY_WAY" json:"DELIVERY_WAY" form:"DELIVERY_WAY"`
+	ExecutionFrequency    string `gorm:"column:EXECUTION_FREQUENCY" json:"EXECUTION_FREQUENCY" form:"EXECUTION_FREQUENCY"`
+	State                 int64  `gorm:"column:STATE" json:"STATE" form:"STATE"`
+	CTime                 string `gorm:"column:CREATE_TIME" json:"CREATE_TIME" form:"CREATE_TIME"`
+	UTime                 string `gorm:"column:UPDATE_TIME" json:"UPDATE_TIME" form:"UPDATE_TIME"`
+}
+
+func (yyyyxtyz) TableName() string {
+	return "yyyyxtyz"
+}
+
+func GetSclsyyyyyz(rdb *gorm.DB, update_time string) (record []*yyyyxtyz, err error) {
+	err = rdb.Model(&yyyyxtyz{}).Where("update_time >= ?", update_time).Find(&record).Error
+	return
+}
+
+func GetAdviceBySyncAdviceIdForScyyyy(orgId int64, sync_advice_id int64, advice_date int64, patient_id int64) (advice models.XtDoctorAdvice, err error) {
+	err = readDb.Model(&models.XtDoctorAdvice{}).Where(" user_org_id = ? AND advice_date = ? and patient_id = ? AND sync_advice_id = ? AND status = 1 ", orgId, advice_date, patient_id, sync_advice_id).First(&advice).Error
+	return
+}
+
+// 根据姓名获取patient_id
+func GetSchedulesByPatientID(org_id int64, schedulesTime int64, patient_id int64) (schedules models.DialysisSchedule, err error) {
+	err = readDb.Model(&models.DialysisSchedule{}).Where("user_org_id = ? and  schedule_date = ? and patient_id = ? and status = 1", org_id, schedulesTime, patient_id).First(&schedules).Error
+	return
+}
+
+// 四川乐山友谊医院医嘱同步
+func SyncSclsyyyyyz(orgDb *gorm.DB) (err error) {
+	// 第一步：获取上次同步时间
+	org_id := int64(10677)
+
+	redisClient := RedisClient()
+	defer redisClient.Close()
+	sync_time_tt, _ := redisClient.Get("sclsyyyy_sync_time").Result()
+
+	sync_time, _ := strconv.ParseInt(sync_time_tt, 10, 64)
+	if sync_time == 0 {
+		sync_time = time.Now().Unix() - 60*60*10
+	}
+	// 需要把时间戳转换为日期格式
+	syncTimeStr := time.Unix(sync_time, 0).Format("2006-01-02 15:04:05")
+	new_sync_time := time.Now().Unix() - 60*3
+	schedulesDateStr := time.Now().Format("2006-01-02")
+	schedulesDate, _ := utils.ParseTimeStringToTime("2006-01-02", schedulesDateStr)
+	schedulesTime := schedulesDate.Unix()
+	utils.InfoLog("syncTimeStr:%v", syncTimeStr)
+	utils.InfoLog("schedulesTime:%v", schedulesTime)
+
+	// 切换为当前时间
+	redisClient.Set("sclsyyyy_sync_time", new_sync_time, time.Minute*60*24)
+	// 第二步： 获取该时间段内有更新的医嘱
+	yzList, _ := GetSclsyyyyyz(orgDb, syncTimeStr)
+	if len(yzList) > 0 {
+		loc, _ := time.LoadLocation("Local") //重要：获取时区
+		for _, yz := range yzList {
+			if yz.DeliveryWay == "口服" {
+				continue
+			}
+			var dflag int64
+			dflag = 0
+			utils.InfoLog("AdviceName:%v", yz.AdviceName)
+			if strings.Contains(yz.AdviceName, "注射") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "血液") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "低分子肝素") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "左卡") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "促红素") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "奈莫司他") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "葡萄糖") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "吸氧") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "抢救") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "电脑血糖") {
+				dflag = 1
+			}
+
+			if strings.Contains(yz.AdviceName, "血液透析") {
+				yz.SingleDose = ""
+				yz.SingleDoseUnit = ""
+				yz.PrescribingNumber = "1"
+				yz.PrescribingNumberUnit = "次"
+			}
+
+			utils.InfoLog("dflag:%v", dflag)
+
+			if dflag == 0 {
+				continue
+			}
+
+			var patientInfo models.Patients
+			// 根据身份证号获取患者信息
+			if len(yz.HisUserId) > 0 {
+				patientInfo, _ = GetPatientsInfoByIDCardNo(yz.HisUserId, org_id)
+				if patientInfo.ID <= 0 {
+					continue
+				}
+			} else {
+				patientInfo, _ = GetPatientsInfoByName(yz.UserName, org_id)
+				if patientInfo.ID <= 0 {
+					continue
+				}
+			}
+			// 查询该患者当天是否有排班信息
+			theTime, _ := time.ParseInLocation("2006-01-02 15:04", yz.StartTime, loc) //使用模板在对应时区转化为time.time类型
+			start_time := theTime.Unix()
+
+			schedulesInfo, _ := GetSchedulesByPatientID(org_id, schedulesTime, patientInfo.ID)
+			if schedulesInfo.ID > 0 {
+				start_time = theTime.Unix()
+			} else {
+				continue
+			}
+
+			// 根据同步来的 advice_id 来查询库里是否已经存在
+			advice_info, _ := GetAdviceBySyncAdviceIdForScyyyy(org_id, yz.AdviceId, schedulesTime, patientInfo.ID)
+			if advice_info.ID > 0 {
+				continue
+			} else {
+				// 根据姓名获取医生ID
+				var doctor_id int64
+				temp_doctor_id, _ := redisClient.Get("sclsyyyy_doctor_id_" + yz.DoctorId).Result()
+				if len(temp_doctor_id) == 0 {
+					doctor, _ := GetAdminUserId(org_id, yz.DoctorName)
+					doctor_id = doctor.AdminUserId
+					if doctor_id > 0 {
+						redisClient.Set("sclsyyyy_doctor_id_"+yz.DoctorId, doctor_id, time.Minute*60*2)
+					} else {
+						continue
+					}
+				} else {
+					doctor_id, _ = strconv.ParseInt(temp_doctor_id, 10, 64)
+				}
+
+				// 根据排班班次，固定医嘱时间
+				SingleDose, _ := strconv.ParseFloat(yz.SingleDose, 64)
+				PrescribingNumber, _ := strconv.ParseFloat(yz.PrescribingNumber, 64)
+				advice := models.XtDoctorAdvice{
+					UserOrgId:             org_id,
+					PatientId:             patientInfo.ID,
+					AdviceType:            2,
+					AdviceDate:            schedulesTime,
+					StartTime:             start_time,
+					AdviceName:            yz.AdviceName,
+					AdviceDesc:            yz.AdviceDesc,
+					RecordDate:            schedulesTime,
+					SingleDose:            SingleDose,
+					SingleDoseUnit:        yz.SingleDoseUnit,
+					PrescribingNumber:     PrescribingNumber,
+					PrescribingNumberUnit: yz.PrescribingNumberUnit,
+					DeliveryWay:           yz.DeliveryWay,
+					ExecutionFrequency:    yz.ExecutionFrequency,
+					AdviceDoctor:          doctor_id,
+					CreatedTime:           time.Now().Unix(),
+					UpdatedTime:           time.Now().Unix(),
+					SyncAdviceId:          yz.AdviceId,
+					ExecutionState:        2,
+					Status:                1,
+					IsSync:                1,
+				}
+				utils.InfoLog("advice:%v", advice)
+
+				if len(yz.AdviceName) > 0 {
+					handleerr := CreateDoctorAdviceHandle(&advice)
+					if handleerr != nil {
+						utils.ErrorLog("添加医嘱信息失败:%v", handleerr)
+						continue
+					}
+				} else {
+					continue
+				}
+			}
+		}
+	}
+	return
+}

service/sssy_service.go

@@ -666,7 +666,7 @@ func UploadSYData(org_id int64) {
 
 func SyncSYData2() {
 	org_id := int64(10191)
-	start_time := "2024-04-20"
+	start_time := "2022-01-10"
 	end_time := "2024-04-26"
 	record, _ := GetLastSyncResultRecord(org_id)
 	if record.ID > 0 {
@@ -675,7 +675,7 @@ func SyncSYData2() {
 	}
 	loc, _ := time.LoadLocation("Local")
 	theTime, _ := time.ParseInLocation("2006-01-02", start_time, loc)
-	newtheTime := theTime.Unix() - 60*60*24*3
+	newtheTime := theTime.Unix() - 60*60*24
 
 	SyncTime := time.Unix(newtheTime, 0)
 	syncTimeStr := SyncTime.Format("2006-01-02")
@@ -821,7 +821,7 @@ func SyncSYData2() {
 	}
 
 	SyncToSssytx()
-	UpdateJg()
+	//UpdateJg()
 }
 
 func SyncToSssytx() {
@@ -830,21 +830,19 @@ func SyncToSssytx() {
 	org_id := int64(10191)
 
 	// 第一步：跟进org_id 去中间库查出需要同步的数据
-	//inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
 	inspections, _ := GetSyncInspectionByOrgId(org_id)
 
 	// 第二步：将数据同步到业务库
-	//if len(inspection_references) > 0 {
-	//	for _, inspection_reference := range inspection_references {
-	//		SyncInspectionReference(&inspection_reference)
-	//	}
-	//}
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
 
 	if len(inspections) > 0 {
 		for _, inspection := range inspections {
-			if inspection.SysProjectId > 0 && inspection.SysItemId > 0 {
-				SyncSssyInspection(&inspection)
-			}
+			SyncSssyInspection(&inspection)
 		}
 	}
 	utils.SuccessLog("检验检查同步任务完成")
@@ -890,9 +888,9 @@ func SyncSssyInspection(data *models.MiddleInspection) error {
 		inspection.PatientId = data.PatientId
 		inspection.ProjectName = data.ProjectName
 		// inspection.Project = data.ProjectName
-		inspection.ProjectId = data.SysProjectId
+		inspection.ProjectId = data.ProjectId
 		inspection.ItemName = data.ItemName
-		inspection.ItemId = data.SysItemId
+		inspection.ItemId = data.ItemId
 		inspection.InspectType = int64(data.InspectType)
 		inspection.InspectValue = data.InspectValue
 		inspection.InspectTips = data.InspectTips

service/sy_service.go

@@ -192,7 +192,7 @@ func SyncStsyLis() (err error) {
 					}
 				}
 				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, recordTimeStr, patient.ID).Find(&inspection).Count(&itotal).Error
+				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, recordTimeInt, patient.ID).Find(&inspection).Count(&itotal).Error
 				if itotal <= 0 {
 					// inspection.InspectValue = strings.Replace(LisInfo.Testresult, "&gt;", ">", -1)
 					// inspection.InspectValue = strings.Replace(LiLisInfo.Testresult, "&lt;", "<", -1)

service/xml_service.go

@@ -38,7 +38,7 @@ func GetGPReportListData(start_date string, end_date string, key string) (result
 	}
 
 	// 创建POST请求
-	url := "http://gpis.cnhiqc.com:9799/InstituteLISService.asmx"
+	url := "https://gpis.cnhiqc.com/api/InstituteLISService.asmx"
 	req, err := http.NewRequest("POST", url, bytes.NewBuffer(requestBody))
 	if err != nil {
 		fmt.Println("Request creation error:", err)
@@ -192,7 +192,7 @@ func GetGPResultDataTwo(item models.GPReportListResultData, key string) (results
 		}
 
 		// 创建POST请求
-		url := "http://gpis.cnhiqc.com:9799/InstituteLISService.asmx"
+		url := "https://gpis.cnhiqc.com/api/InstituteLISService.asmx"
 		req, err := http.NewRequest("POST", url, bytes.NewBuffer(requestBody))
 		if err != nil {
 			fmt.Println("Request creation error:", err)
@@ -273,7 +273,7 @@ func GetGPResultDataTwo(item models.GPReportListResultData, key string) (results
 			}
 
 			// 创建POST请求
-			url := "http://gpis.cnhiqc.com:9799/InstituteLISService.asmx"
+			url := "https://gpis.cnhiqc.com/api/InstituteLISService.asmx"
 			req, err := http.NewRequest("POST", url, bytes.NewBuffer(requestBody))
 			if err != nil {
 				fmt.Println("Request creation error:", err)
@@ -358,7 +358,7 @@ func PostInspectApply(key string, apply models.JYApply, list []models.CustomerAp
 	fmt.Println(string(requestBody))
 
 	// 创建POST请求
-	url := "http://gpis.cnhiqc.com:9799/InstituteLISService.asmx"
+	url := "https://gpis.cnhiqc.com/api/InstituteLISService.asmx"
 	req, err := http.NewRequest("POST", url, bytes.NewBuffer(requestBody))
 	if err != nil {
 		fmt.Println("Request creation error:", err)

service/zqsh_service.go

@@ -0,0 +1,527 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	"encoding/json"
+	"encoding/xml"
+	"github.com/astaxie/beego/httplib"
+	"net/url"
+	"strconv"
+	"strings"
+	"time"
+)
+
+type RequestResultZqsh struct {
+	Msg        string `json:"msg"`
+	ResultGzjh []struct {
+		AdviceId               int64   `json:"医嘱ID"`
+		OtherId                int64   `json:"相关ID"`
+		Source                 int     `json:"病人来源"`
+		PatientId              int64   `json:"病人ID"`
+		JzId                   int64   `json:"就诊ID"`
+		BabyId                 int     `json:"婴儿ID"`
+		PatientDepartmentId    int     `json:"病人科室ID"`
+		OrderId                int     `json:"次序"`
+		AdviceStatus           int     `json:"医嘱状态"`
+		AdviceType             int     `json:"医嘱类型"`
+		DiagnosisType          string  `json:"诊疗类型"`
+		DiagnosisItemId        int     `json:"诊疗项目ID"`
+		CheckMethd             string  `json:"检查方法"`
+		ChargeItemId           int     `json:"收费项目ID"`
+		Day                    int     `json:"天数"`
+		JiLiang                float64 `json:"剂量"`
+		YongLiang              string  `json:"用量"`
+		DanLiang               float64 `json:"单量"`
+		Shuliang               float64 `json:"数量"`
+		Advice                 string  `json:"医嘱"`
+		GeiYaoTuJing           string  `json:"给药途径"`
+		ShuoMing               string  `json:"说明"`
+		ZhiXingKeShiId         int     `json:"执行科室ID"`
+		ZhiXingKeShi           string  `json:"执行科室"`
+		PN                     string  `json:"P(+)或N(-)表示阳性或阴性"`
+		ZhiXingPinCi           string  `json:"执行频次"`
+		PinLvCiShu             int     `json:"频率次数"`
+		PinLvJianGe            int     `json:"频率间隔"`
+		JianGeDanWei           string  `json:"间隔单位"`
+		ZhiXingShiJianFangAn   string  `json:"执行时间方案"`
+		JiJiaTeXing            int     `json:"计价特性"`
+		ZhiXingXingZhi         int     `json:"执行性质"`
+		ZhiXingBiaoZhi         int     `json:"执行标记"`
+		KeFouFenLing           int     `json:"可否分零"`
+		JinJiBiaoZhi           int     `json:"紧急标志"`
+		KaiShiZhiXingShiJian   int64   `json:"开始执行时间"`
+		ZhiXingZhongZhiShiJian int64   `json:"执行终止时间"`
+		ShangCiZhiXingShiJian  int64   `json:"上次执行时间"`
+		KaiZhuKeShiId          int     `json:"开嘱科室ID"`
+		DoctorCode             string  `json:"医师编码"`
+		Doctor                 string  `json:"开嘱医师"`
+		AdviceTime             int64   `json:"开嘱时间"`
+		StopTime               int64   `json:"停嘱时间"`
+		ApplyId                int     `json:"申请ID"`
+		UploadLable            int     `json:"上传标志"`
+		CheckResult            int     `json:"审查结果"`
+		NoPrint                int     `json:"忽略打印"`
+		Summary                string  `json:"摘要"`
+		AdviceOrderId          int64   `json:"医嘱单id"`
+		GeiYaoKeShi            int     `json:"给药科室"`
+		GeiYaoXingZhi          int     `json:"给药性质"`
+		GroupNo                int     `json:"组号"`
+		Speed                  string  `json:"滴速"`
+		ShouRiCiShu            float64 `json:"首日次数"`
+		MoRiCiShu              float64 `json:"末日次数"`
+		AdviceDoctorId         int     `json:"开嘱医师ID"`
+		AdviceNurseId          int     `json:"开嘱护士ID"`
+		OperaId                int     `json:"操作员ID"`
+		Opera                  string  `json:"操作员"`
+		CheckTime              int64   `json:"审核时间"`
+		ReplyAdviceTime        int64   `json:"重整医嘱时间"`
+	} `json:"result"`
+	Code string `json:"code"`
+}
+
+type XmlKeyZqsh struct {
+	XMLName    xml.Name `xml:"string"`
+	StringName string   `xml:"name,attr"`
+	InnerText  string   `xml:",innerxml"`
+}
+
+// 获取艾迪康的key
+func GetZqshAdKey(logid string, password string) (key string) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/Login?"
+	apiurl := "logid=" + logid + "&password=" + password
+	apiurl = url.PathEscape(apiurl)
+	utils.InfoLog("apiUrl: %v", apiurl)
+	apiurl = Domain + apiurl
+	xmlKey := XmlKeyZqsh{}
+	httplib.Get(apiurl).ToXML(&xmlKey)
+	utils.InfoLog("xmlKey: %v", xmlKey)
+	return xmlKey.InnerText
+}
+
+type ADStringZqsh struct {
+	XMLName    xml.Name         `xml:"string" json:"string"`
+	NewDataSet rpnewDataSetZqsh `xml:"NewDataSet" json:"NewDataSetZqsh"`
+}
+
+type rpnewDataSetZqsh struct {
+	ListTable []rplisttableZqsh `xml:"listtable" json:"listtableZqsh"`
+}
+
+type rplisttableZqsh struct {
+	Id          string `xml:"Id" json:"Id"`
+	PatientName string `xml:"PatientName" json:"PatientName"`
+	Bgrq        string `xml:"Bgrq" json:"Bgrq"`
+	Instrument  string `xml:"Instrument" json:"Instrument"`
+	LisDate     string `xml:"LisDate" json:"LisDate"`
+	Sampleid    string `xml:"Sampleid" json:"Sampleid"`
+}
+
+type ReportListZqshXml struct {
+	XMLName       xml.Name `xml:"GetReportList"`
+	Key           string   `xml:"Key"`
+	BeginDateTime string   `xml:"BeginDateTime"`
+	EndDateTime   string   `xml:"EndDateTime"`
+	TypeDateTime  string   `xml:"TypeDateTime"`
+	AgainFlag     string   `xml:"AgainFlag"`
+}
+
+// 获取机构一段时间内检验检查列表
+func GetAdGetReportListZqsh(Key string, BeginDateTime string, EndDateTime string, TypeDateTime string, AgainFlag string) (key ADStringZqsh) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/GetReportList"
+	var xmlKey ADStringZqsh
+	reportPost := httplib.Post(Domain)
+	reportPost.Param("Key", Key)
+	reportPost.Param("BeginDateTime", BeginDateTime)
+	reportPost.Param("EndDateTime", EndDateTime)
+	reportPost.Param("TypeDateTime", TypeDateTime)
+	reportPost.Param("AgainFlag", AgainFlag)
+	reportPost.Header("Content-Type", "application/xml")
+
+	xmlString, _ := reportPost.String()
+	xmlString = strings.Replace(xmlString, "&lt;", "<", -1)
+	xmlString = strings.Replace(xmlString, "&gt;", ">", -1)
+	xml.Unmarshal([]byte(xmlString), &xmlKey)
+	return xmlKey
+}
+
+type adkCheckZqsh struct {
+	ApplyId     string          `json:"applyid"`
+	ReportNo    string          `json:"reportno"`
+	PatName     string          `json:"patname"`
+	Sex         string          `json:"sex"`
+	Age         string          `json:"age"`
+	DptName     string          `json:"dptname"`
+	Testtype    string          `json:"testtype"`
+	Testcode    string          `json:"testcode"`
+	ExecuteTime string          `json:"receivetime"`
+	Checktime   string          `json:"checktime"`
+	Checkcode   string          `json:"checkcode"`
+	Result      []adkResultZqsh `json:"result"`
+}
+
+func GetAdkInfoZqsh(key string, id string) (str []adkCheckZqsh, checkStr string) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/GetJSONReportItemListById"
+
+	reportPost := httplib.Post(Domain)
+	reportPost.Param("Key", key)
+	reportPost.Param("id", id)
+	reportPost.Header("Content-Type", "application/xml")
+	xmlKey := XmlKey{}
+	reportPost.ToXML(&xmlKey)
+	var checkJSON []adkCheckZqsh
+	json.Unmarshal([]byte(xmlKey.InnerText), &checkJSON)
+	return checkJSON, xmlKey.InnerText
+}
+
+// 广州暨华血液透析中心Lis同步
+func SyncLisZqshtx() (err error) {
+	// 第一步：获取艾迪康下发的Key
+	org_id := int64(10215)
+	login := "RH0647"
+	password := "abc123456"
+	key := GetZqshAdKey(login, password)
+	utils.InfoLog("key: %v", key)
+	// 第二步：获e取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime + 86400
+	} else {
+		sync_time = 1711900800
+	}
+	nowTimes := time.Now().Unix()
+	// syncTimes := time.Unix(sync_time,0).Format("2006-01-02")
+	if sync_time < nowTimes {
+		for i := sync_time; i < nowTimes; i = i + 86400 {
+			tempsyncTimes := time.Unix(i, 0).Format("2006-01-02")
+			utils.InfoLog("tempsyncTimes:%v", tempsyncTimes)
+			adString := GetAdGetReportListZqsh(key, tempsyncTimes, tempsyncTimes, "2", "2")
+			listtable := adString.NewDataSet.ListTable
+			utils.InfoLog("listtable: %v", listtable)
+			if len(listtable) > 3 {
+				// 第三步：根据检查列表获取的ID来获取检验检查详情
+				for _, list := range listtable {
+					listId := list.Id
+					utils.InfoLog("listId: %v", listId)
+					checkInfo, checkStr := GetAdkInfoZqsh(key, listId)
+					utils.InfoLog("checkInfo: %v", checkInfo)
+					for _, info := range checkInfo {
+						// 根据姓名 去查询对应的patient_id
+						patient, _ := GetPatientIDZqsh(org_id, info.PatName)
+						utils.InfoLog("patient: %v", patient)
+						if patient.ID > 0 {
+							middleReportHandle := models.MiddleReportHandle{
+								OrgId:       org_id,
+								HisUserId:   strconv.FormatInt(patient.ID, 10),
+								ApplyNo:     info.ApplyId,
+								ReportId:    info.ReportNo,
+								Name:        info.PatName,
+								Sex:         info.Sex,
+								Age:         info.Age,
+								Dept:        info.DptName,
+								PatientId:   strconv.FormatInt(patient.ID, 10),
+								RequestTime: info.ExecuteTime,
+								ExecuteTime: info.ExecuteTime,
+								ReceiveTime: info.ExecuteTime,
+								CheckTime:   info.ExecuteTime,
+								ReportInfo:  checkStr,
+								CreatedTime: time.Now().Unix(),
+								UpdatedTime: time.Now().Unix(),
+							}
+							handleerr := CreateReportHandle(&middleReportHandle)
+							if handleerr != nil {
+								utils.ErrorLog("创建检验检查操作数据失败:%v", handleerr)
+								return
+							}
+
+							ZqshReportInfoHandle(info, org_id, patient.ID)
+						}
+					}
+				}
+				var syncInfo models.MiddleSyncInfo
+				syncInfo.OrgId = org_id
+
+				syncInfo.SyncTime = i
+				syncInfo.SyncResultType = 1
+				syncInfo.SyncRsultRemark = "同步成功"
+				syncInfo.SyncTotalNum = 0
+				syncInfo.SyncSuccessNum = 0
+				syncInfo.SyncInfo = ""
+				syncInfo.CreateTime = time.Now().Unix()
+				syncInfo.UpdateTime = time.Now().Unix()
+
+				cwderr := CreateSyncInfo(&syncInfo)
+				if cwderr != nil {
+					utils.ErrorLog("创建同步信息失败:%v", cwderr)
+					return
+				}
+			}
+		}
+
+	}
+	SyncToZqshtx()
+
+	return
+}
+
+// 根据姓名获取patient_id
+func GetPatientIDZqsh(org_id int64, patient_name string) (patient models.Patients, err error) {
+	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? and status = 1 and name = ? ", org_id, patient_name).First(&patient).Error
+	return
+}
+
+func GetProjectInfoZqsh(item_id int64, org_id int64) (project_info models.MiddleInspectionReference, err error) {
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and item_id = ?", org_id, item_id).First(&project_info).Error
+	return
+}
+
+// 修改配置信息
+// func UpdateInspectionReference(InspectionReference *models.MiddleInspectionReference) error {
+// 	err := readMiddleDb.Model(&models.MiddleInspectionReference{}).Updates(&InspectionReference).Error
+// 	return err
+// }
+
+// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+func GetZqshProjectID(org_id int64, project_name string) (project_id int64, err error) {
+	var inspection_reference models.MiddleInspectionReference
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ?", org_id, project_name).First(&inspection_reference).Error
+	if inspection_reference.ID > 0 {
+		return inspection_reference.ProjectId, err
+	} else {
+		err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+		utils.InfoLog("inspection_reference: %v", inspection_reference)
+		if inspection_reference.ProjectId > 0 {
+			return inspection_reference.ProjectId + 1, err
+		} else {
+			return 1021501, err
+		}
+	}
+}
+
+// // 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
+// func GetGzjhProjectID(org_id int64, project_name string) (project_id int64, err error) {
+// 	var inspection_reference models.MiddleInspectionReference
+// 	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and status = 1 and project_name = ?", org_id, project_name).First(&inspection_reference).Error
+// 	if inspection_reference.ID > 0 {
+// 		return inspection_reference.ProjectId, err
+// 	} else {
+// 		err = readMiddleDb.Table("xt_middle_inspection_reference").Where("org_id=? ", org_id).Select("max(project_id) as project_id").Scan(&inspection_reference).Error
+// 		if inspection_reference.ProjectId > 0 {
+// 			return inspection_reference.ProjectId + 1, err
+// 		} else {
+// 			return 116001, err
+// 		}
+// 	}
+// }
+
+func ZqshReportInfoHandle(CheckInfo adkCheckZqsh, org_id int64, patientId int64) {
+	// 1.先把所有的检查项弄出来
+	for _, info := range CheckInfo.Result {
+		// 根据project_id和item_id 判断该项是否存在
+		curitemcode, _ := strconv.ParseInt(info.Itemcode, 10, 64)
+		reference, _ := GetProjectInfoZqsh(curitemcode, org_id)
+		utils.InfoLog("info: %v", info)
+		utils.InfoLog("reference: %v", info)
+		if reference.ID > 0 {
+			if reference.ProjectId > 0 {
+				LgthYsSyncZqsh(info, reference.ProjectId, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+			} else {
+				project_id := int64(0)
+				if len(info.Groupitemcode) > 0 {
+					// 对没有project信息的项目进行修改
+					project_id, _ = GetZqshProjectID(org_id, info.Groupitemname)
+					reference.ProjectId = project_id
+					reference.ProjectName = info.Groupitemcode
+					reference.Project = info.Groupitemcode
+					// 修改配置信息
+					UpdateInspectionReference(&reference)
+				}
+				LgthYsSyncZqsh(info, project_id, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+			}
+		} else {
+			project_id := int64(0)
+			if len(info.Groupitemcode) > 0 {
+				project_id, _ = GetZqshProjectID(org_id, info.Groupitemname)
+			}
+			LgthYsSyncZqsh(info, project_id, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+		}
+	}
+
+	//SyncLisZqshtx()
+}
+
+type adkResultZqsh struct {
+	Testno        string `json:"testno"`
+	Reportno      string `json:"reportno"`
+	Itemord       string `json:"itemord"`
+	Itemcode      string `json:"itemcode"`
+	Itemname      string `json:"itemname"`
+	ItemEname     string `json:"itemename"`
+	Result        string `json:"result"`
+	Units         string `json:"units"`
+	Testdate      string `json:"testdate"`
+	Eqpname       string `json:"eqpname"`
+	Groupitemcode string `json:"groupitemcode"`
+	Groupitemname string `json:"groupitemname"`
+	Limit         string `json:"limit"`
+	Resultstate   string `json:"resultstate"`
+	Criticalflag  string `json:"criticalflag"`
+	Itemename     string `json:"itemename"`
+}
+
+// 从机构将数据同步到中间库
+func LgthYsSyncZqsh(report adkResultZqsh, project_id int64, item_id int64, org_id int64, patient_id int64, receivetime string) (*models.MiddleInspectionReference, error) {
+	tx := writeMiddleDb.Begin()
+	var inspection models.MiddleInspection
+	var inspection_reference models.MiddleInspectionReference
+	recordDateStr := receivetime
+
+	if len(receivetime) == 0 {
+		recordDateStr = time.Now().Format("2006-01-02 15:04")
+	}
+
+	record_date_str, _ := utils.ParseTimeStringToTime("2006-01-02 15:04:05", recordDateStr)
+	record_date := record_date_str.Unix()
+	inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
+	// date, _ := utils.ParseTimeStringToTime("2006-01-02 15:04", recordDateStr)
+	// record_date,_ := utils.ParseTimeStringToTime("2006-01-02", date.Format("2006-01-02"))
+	var total int
+	var RangeOptions string
+	var RangeMin string
+	var RangeMax string
+
+	// // 判断检查类型
+	ItemType := 1
+	Range := strings.Split(report.Limit, "-")
+	if len(Range) > 1 {
+		RangeMin = Range[0]
+		RangeMax = Range[1]
+		ItemType = 1
+	} else {
+		ItemType = 2
+		RangeOptions = report.Limit
+	}
+
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and project_id = ? and item_id = ? and status = 1", org_id, project_id, item_id).Find(&inspection_reference).Count(&total).Error
+	if inspection_reference.ID > 0 {
+		ItemType = inspection_reference.RangeType
+	}
+	if total <= 0 {
+		inspection_reference.OrgId = org_id
+		inspection_reference.ProjectName = report.Groupitemname
+		inspection_reference.Project = report.Groupitemcode
+		inspection_reference.ProjectId = project_id
+		inspection_reference.ItemName = report.Itemname
+		inspection_reference.ItemNameAddition = report.ItemEname
+		inspection_reference.ItemId = item_id
+		inspection_reference.RangeType = ItemType
+		inspection_reference.RangeMin = RangeMin
+		inspection_reference.RangeMax = RangeMax
+		// inspection_reference.RangeValue = RangeValue
+		inspection_reference.RangeOptions = RangeOptions
+		inspection_reference.Unit = report.Units
+		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 {
+		report.Result = strings.Replace(report.Result, "&gt;", ">", -1)
+		report.Result = strings.Replace(report.Result, "&lt;", "<", -1)
+		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 = report.Result
+		inspection.InspectDate = inspect_date
+		inspection.RecordDate = record_date
+		inspection.InspectTips = report.Resultstate
+		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()
+		}
+	}
+
+	// 	//处理检验检查操作表里同步条数和状态
+	// 	cur_num := Head.ReportInfoItemHandleNum + 1
+	// 	Head.ReportInfoItemHandleNum = cur_num
+	// 	handleType := 2
+	// 	if cur_num == Head.ReportInfoItemNum {
+	// 		handleType = 1
+	// 	}
+	// 	middleReportHandle := models.MiddleReportHandle{
+	// 		ID:							Head.ID,
+	// 		ReportInfoItemHandleNum:	cur_num,
+	// 		HandleType:					int64(handleType),
+	// 		UpdatedTime:				time.Now().Unix(),
+	// 	}
+	// 	err = UpdateReportHandleListyOrgID(&middleReportHandle)
+	// 	if err != nil {
+	// 		tx.Rollback()
+	// 	}
+	// }
+
+	tx.Commit()
+	return nil, err
+}
+
+// 根据姓名获取patient_id
+func GetPatientGzjhListZqsh(org_id int64, schedulesTime int64) (schedules []*models.DialysisSchedule, err error) {
+	err = readDb.Model(&models.DialysisSchedule{}).Where("user_org_id = ? and status = 1 and  schedule_date = ?", org_id, schedulesTime).Preload("Patients", "status = 1").Find(&schedules).Error
+	return
+}
+
+// 根据姓名获取admin_user_id
+func GetAdminUserIdZqsh(org_id int64, doctor_name string) (doctor models.UserAdminRole, err error) {
+	err = writeUserDb.Model(&models.UserAdminRole{}).Where("org_id = ? and status = 1 and  user_name = ?", org_id, doctor_name).First(&doctor).Error
+	return
+}
+
+func GetPatientGzjhByOrgIdZqsh(org_id int64) (patientList []*models.Patients, err error) {
+	err = readDb.Model(&models.Patients{}).Where("user_org_id = ? and status = 1", org_id).Find(&patientList).Error
+	return
+}
+
+func SyncToZqshtx() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10215)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			if inspection_reference.ProjectId > 0 && inspection_reference.ItemId > 0 {
+				SyncInspectionReference(&inspection_reference)
+			}
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			if inspection.ProjectId > 0 && inspection.ItemId > 0 {
+				SyncInspection(&inspection)
+			}
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}