models/lis_model.go

@@ -79,6 +79,117 @@ func (DataUploadConfig) TableName() string {
 	return "data_upload_config"
 }
 
+type VYunjingPatientLabItems struct {
+	Id             	int64  	`gorm:"column:ID" json:"ID"`
+	Zyid			string  `gorm:"column:ZYID" json:"ZYID"`
+	Mzid     		string  `gorm:"column:MZID" json:"MZID"`
+	PatientId       string  `gorm:"column:PATIENT_ID" json:"PATIENT_ID"`
+	Sfzh 			string 	`gorm:"column:SFZH" json:"SFZH"`
+	PatientName     string 	`gorm:"column:PATIENT_NAME" json:"PATIENT_NAME"`
+	TestOrderNo		string 	`gorm:"column:TEST_ORDER_NO" json:"TEST_ORDER_NO"`
+	ItemType		string  `gorm:"column:ITEM_TYPE" json:"ITEM_TYPE"`
+	ItemTypeName    string  `gorm:"column:ITEM_TYPE_NAME" json:"ITEM_TYPE_NAME"`
+	ItemCode     	string  `gorm:"column:ITEM_CODE" json:"ITEM_CODE"`
+	ItemName    	string  `gorm:"column:ITEM_NAME" json:"ITEM_NAME"`
+	SubmitAt    	string  `gorm:"column:SUBMIT_AT" json:"SUBMIT_AT"`
+	CreateAt    	string  `gorm:"column:CREATE_AT" json:"CREATE_AT"`
+	DeptName    	string  `gorm:"column:DEPT_NAME" json:"DEPT_NAME"`
+}
+
+func (VYunjingPatientLabItems) TableName() string {
+	return "v_yunjing_patient_lab_items"
+}
+
+type VYunjingPatientLabAnti struct {
+	Id             	int64  	`gorm:"column:ID" json:"ID"`
+	Zyid			string  `gorm:"column:ZYID" json:"ZYID"`
+	Mzid     		string  `gorm:"column:MZID" json:"MZID"`
+	PatientId       string  `gorm:"column:PATIENT_ID" json:"PATIENT_ID"`
+	Sfzh 			string 	`gorm:"column:SFZH" json:"SFZH"`
+	PatientName     string 	`gorm:"column:PATIENT_NAME" json:"PATIENT_NAME"`
+	TestOrderNo		string 	`gorm:"column:TEST_ORDER_NO" json:"TEST_ORDER_NO"`
+	ResultDate		string 	`gorm:"column:RESULT_DATE" json:"RESULT_DATE"`
+	TestResult		string 	`gorm:"column:TEST_RESULT" json:"TEST_RESULT"`
+	Unit			string 	`gorm:"column:UNIT" json:"UNIT"`
+	ReferRange		string 	`gorm:"column:REFER_RANGE" json:"REFER_RANGE"`
+	AntiCode		string 	`gorm:"column:ANTI_CODE" json:"ANTI_CODE"`
+	AntiName		string 	`gorm:"column:ANTI_NAME" json:"ANTI_NAME"`
+	CreateAt    	string  `gorm:"column:CREATE_AT" json:"CREATE_AT"`
+
+}
+
+func (VYunjingPatientLabAnti) TableName() string {
+	return "v_yunjing_patient_lab_anti"
+}
+
+type PlugPlugcase struct {
+	Id             	int64  	`gorm:"column:ID" json:"ID"`
+	Oldserialno		string  `gorm:"column:oldSerialNo" json:"oldSerialNo"`
+	Serialno     	string  `gorm:"column:serialNo" json:"serialNo"`
+	Name         	string  `gorm:"column:name" json:"name"`
+	Gender 			string 	`gorm:"column:gender" json:"gender"`
+	Age          	int64 	`gorm:"column:age" json:"age"`
+	RegistrantmanId	int64 	`gorm:"column:registrantMan_id" json:"registrantMan_id"`
+	Mainindex		string  `gorm:"column:mainIndex" json:"mainIndex"`
+	Orddoctor     	string  `gorm:"column:ordDoctor" json:"ordDoctor"`
+	Ordloc     		string  `gorm:"column:ordLoc" json:"ordLoc"`
+	Birthday    	string  `gorm:"column:birthDay" json:"birthDay"`
+}
+
+func (PlugPlugcase) TableName() string {
+	return "plug_plugcase"
+}
+
+type PlugPlugcheckitem struct {
+	Id             	int64  	`gorm:"column:ID" json:"ID"`
+	Serialno		string  `gorm:"column:serialNo" json:"serialNo"`
+	Itemcode     	string  `gorm:"column:itemCode" json:"itemCode"`
+	State         	int64  	`gorm:"column:state" json:"state"`
+	Itemplug 		string 	`gorm:"column:itemPlug" json:"itemPlug"`
+	Checkitemid		string 	`gorm:"column:checkItemId" json:"checkItemId"`
+	Oldserialno		string 	`gorm:"column:oldSerialNo" json:"oldSerialNo"`
+	Applytime		string 	`gorm:"column:applyTime" json:"applyTime"`
+	Specimenname	string  `gorm:"column:specimenName" json:"specimenName"`
+	Checkitemname 	string  `gorm:"column:checkItemName" json:"checkItemName"`
+	Liscollectuser	string  `gorm:"column:LisCollectUser" json:"LisCollectUser"`
+	Liscollecttime	string  `gorm:"column:LisCollectTime" json:"LisCollectTime"`
+	Lissignuser    	string  `gorm:"column:LisSignUser" json:"LisSignUser"`
+	Lissigntime    	string  `gorm:"column:LissignTime" json:"LissignTime"`
+	Lisacceptuser   string  `gorm:"column:LisAcceptUser" json:"LisAcceptUser"`
+	Lisaccepttime   string  `gorm:"column:LisAcceptTime" json:"LisAcceptTime"`
+	Lisregisteruser	string  `gorm:"column:LisRegisterUser" json:"LisRegisterUser"`
+	Lisregistertime	string  `gorm:"column:LisRegisterTime" json:"LisRegisterTime"`
+	Lischeckuser    string  `gorm:"column:LisCheckUser" json:"LisCheckUser"`
+	Lischecktime    string  `gorm:"column:LisCheckTime" json:"LisCheckTime"`
+	Lisrefuseuser   string  `gorm:"column:LisRefuseUser" json:"LisRefuseUser"`
+	Lisrefusetime   string  `gorm:"column:LisRefuseTime" json:"LisRefuseTime"`
+	Lisstatus    	string  `gorm:"column:LisStatus" json:"LisStatus"`
+	Refusereason    string  `gorm:"column:RefuseReason" json:"RefuseReason"`
+}
+
+func (PlugPlugcheckitem) TableName() string {
+	return "plug_plugcheckitem"
+}
+
+type PlugPlugresult struct {
+	Id             		int64  	`gorm:"column:ID" json:"ID"`
+	Serialno			string  `gorm:"column:serialNo" json:"serialNo"`
+	Testitemname		string  `gorm:"column:testItemName" json:"testItemName"`
+	Itemcode			string  `gorm:"column:itemcode" json:"itemcode"`
+	Paritemno			string  `gorm:"column:parItemNo" json:"parItemNo"`
+	Reportvalueall		string  `gorm:"column:reportValueAll" json:"reportValueAll"`
+	Testitemdatetime	string  `gorm:"column:testItemDateTime" json:"testItemDateTime"`
+	Unit				string  `gorm:"column:unit" json:"unit"`
+	Refrange			string  `gorm:"column:refrange" json:"refrange"`
+	Resultstatus		string  `gorm:"column:resultStatus" json:"resultStatus"`
+	Itemorder			int64  	`gorm:"column:itemOrder" json:"itemOrder"`
+	Checker				string  `gorm:"column:checker" json:"checker"`
+}
+
+func (PlugPlugresult) TableName() string {
+	return "plug_plugresult"
+}
+
 type Schedules struct {
 	ID           int64 `gorm:"column:id" json:"id" form:"id"`
 	UserOrgId    int64 `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
@@ -129,6 +240,7 @@ func (MiddlePatients) TableName() string {
 	return "xt_middle_patients"
 }
 
+
 type Patients struct {
 	ID              int64  `gorm:"column:id" json:"id" form:"id"`
 	UserOrgId       int64  `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
@@ -140,8 +252,6 @@ type Patients struct {
 	ContactName     string `gorm:"column:contact_name" json:"contact_name" form:"contact_name"`
 	Gender          int64  `gorm:"column:gender" json:"gender" form:"gender"`
 	Birthday        int64  `gorm:"column:birthday" json:"birthday" form:"birthday"`
-	Phone           string `gorm:"column:phone" json:"phone" form:"phone"`
-	Age             int64  `gorm:"column:age" json:"age"`
 }
 
 func (Patients) TableName() string {
@@ -209,22 +319,20 @@ func (TBLISItem) TableName() string {
 }
 
 type Inspection struct {
-	ID                 int64  `gorm:"column:id" json:"id" form:"id"`
-	PatientId          int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	OrgId              int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
-	ProjectId          int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
-	ItemId             int64  `gorm:"column:item_id" json:"item_id" form:"item_id"`
-	ItemName           string `gorm:"column:item_name" json:"item_name" form:"item_name"`
-	ProjectName        string `gorm:"column:project_name" json:"project_name" form:"project_name"`
-	InspectType        int64  `gorm:"column:inspect_type" json:"inspect_type" form:"inspect_type"`
-	InspectValue       string `gorm:"column:inspect_value" json:"inspect_value" form:"inspect_value"`
-	InspectTips        string `gorm:"column:inspect_tips" json:"inspect_tips" form:"inspect_tips"`
-	InspectDate        int64  `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
-	Status             int64  `gorm:"column:status" json:"status" form:"status"`
-	CreatedTime        int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
-	UpdatedTime        int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
-	ReferenceItemId    int64  `gorm:"column:reference_item_id" json:"reference_item_id" form:"reference_item_id"`
-	ReferenceProjectId int64  `gorm:"column:reference_project_id" json:"reference_project_id" form:"reference_project_id"`
+	ID           int64  `gorm:"column:id" json:"id" form:"id"`
+	PatientId    int64  `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
+	OrgId        int64  `gorm:"column:org_id" json:"org_id" form:"org_id"`
+	ProjectId    int64  `gorm:"column:project_id" json:"project_id" form:"project_id"`
+	ItemId       int64  `gorm:"column:item_id" json:"item_id" form:"item_id"`
+	ItemName     string `gorm:"column:item_name" json:"item_name" form:"item_name"`
+	ProjectName  string `gorm:"column:project_name" json:"project_name" form:"project_name"`
+	InspectType  int64  `gorm:"column:inspect_type" json:"inspect_type" form:"inspect_type"`
+	InspectValue string `gorm:"column:inspect_value" json:"inspect_value" form:"inspect_value"`
+	InspectTips  string `gorm:"column:inspect_tips" json:"inspect_tips" form:"inspect_tips"`
+	InspectDate  int64  `gorm:"column:inspect_date" json:"inspect_date" form:"inspect_date"`
+	Status       int64  `gorm:"column:status" json:"status" form:"status"`
+	CreatedTime  int64  `gorm:"column:created_time" json:"created_time" form:"created_time"`
+	UpdatedTime  int64  `gorm:"column:updated_time" json:"updated_time" form:"updated_time"`
 }
 
 func (Inspection) TableName() string {
@@ -335,9 +443,7 @@ type MiddleInspectionReference struct {
 	IsSync           int    `gorm:"column:is_sync" json:"is_sync" form:"is_sync"`
 	UTime            string `gorm:"column:u_time" json:"u_time" form:"u_time"`
 	SyncId           int64  `gorm:"column:sync_id" json:"sync_id" form:"sync_id"`
-
-	XtProjectId int64 `gorm:"column:xt_project_id" json:"xt_project_id" form:"xt_project_id"`
-	XtItemId    int64 `gorm:"column:xt_item_id" json:"xt_item_id" form:"xt_item_id"`
+	ItemCode         string  `gorm:"column:item_code" json:"item_code" form:"item_code"`
 }
 
 func (MiddleInspectionReference) TableName() string {
@@ -454,26 +560,3 @@ type VMItemProjectList struct {
 func (VMItemProjectList) TableName() string {
 	return "xt_his_project_list"
 }
-
-type HisLabelPrintStatusInfo struct {
-	ID                 int64    `gorm:"column:id" json:"id" form:"id"`
-	PatientId          int64    `gorm:"column:patient_id" json:"patient_id" form:"patient_id"`
-	Ctime              int64    `gorm:"column:ctime" json:"ctime" form:"ctime"`
-	Mtime              int64    `gorm:"column:mtime" json:"mtime" form:"mtime"`
-	Status             int64    `gorm:"column:status" json:"status" form:"status"`
-	IsCombinationPrint int64    `gorm:"column:is_combination_print" json:"is_combination_print" form:"is_combination_print"`
-	RecordDate         string   `gorm:"column:record_date" json:"record_date" form:"record_date"`
-	ItemIds            string   `gorm:"column:item_ids" json:"item_ids" form:"item_ids"`
-	UserOrgId          int64    `gorm:"column:user_org_id" json:"user_org_id" form:"user_org_id"`
-	ProjectIds         string   `gorm:"column:project_ids" json:"project_ids" form:"project_ids"`
-	DoctorId           int64    `gorm:"column:doctor_id" json:"doctor_id" form:"doctor_id"`
-	Ids                string   `gorm:"column:ids" json:"ids" form:"ids"`
-	IsTeam             int64    `gorm:"column:is_team" json:"is_team" form:"is_team"`
-	IsPrint            int64    `gorm:"column:is_print" json:"is_print" form:"is_print"`
-	Patient            Patients `gorm:"ForeignKey:ID;AssociationForeignKey:PatientId" json:"patient"`
-	ApplyCode          string   `gorm:"column:apply_code" json:"apply_code" form:"apply_code"`
-}
-
-func (HisLabelPrintStatusInfo) TableName() string {
-	return "his_label_print_status_info"
-}

routers/router.go

@@ -28,6 +28,8 @@ func init() {
 
 	beego.Router("/api/syncshLis", &controllers.LisController{}, "get:SyncShLis")
 	beego.Router("/api/syncszblis", &controllers.LisController{}, "get:SyncSzblLis")
-	//beego.Router("/api/test", &controllers.LisController{}, "get:SyncScpaLis")
-
+	beego.Router("/api/test", &controllers.LisController{}, "get:SyncTest")
+	beego.Router("/api/lis/gzjhxytx", &controllers.LisController{}, "get:SyncGzjhxytx")
+	beego.Router("/api/lis/scdckfyy", &controllers.LisController{}, "get:SyncSccdkfyyLis")
+	beego.Router("/api/lis/pajm", &controllers.LisController{}, "get:SyncPajmLis")
 }

service/cron.go

@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	_ "fmt"
 	_ "github.com/jinzhu/gorm"
+	"github.com/robfig/cron"
 	_ "strings"
 	"time"
 )
@@ -17,40 +18,84 @@ func init() {
 
 }
 
-//// 返回一个支持至 秒 级别的 cron
-//func newWithSeconds() *cron.Cron {
-//	secondParser := cron.NewParser(cron.Second | cron.Minute |
-//		cron.Hour | cron.Dom | cron.Month | cron.DowOptional | cron.Descriptor)
-//	return cron.New(cron.WithParser(secondParser), cron.WithChain())
-//}
-//
-//func BeginAutoSyncLis() {
-//	utils.InfoLog("开启自动检验检查同步定时任务")
-//	createLisSyncCronJob := newWithSeconds()
-//
-//	// specgzjh := "0 */1 * * * ?" // 每1分钟同步 广州暨华HIS医嘱
-//	// createLisSyncCronJob.AddFunc(specgzjh, func() {
-//	// 	// SyncGzjhyz()
-//	// 	Synctfyz()
-//	// })
-//
-//	specys := "0 0 */1 * * ?" // 每天凌晨3点同步 唐山朝阳医院
-//	createLisSyncCronJob.AddFunc(specys, func() {
-//		SyncScpaLis()
-//	})
-//
-//	specys1 := "0 10 */2 * * ?" // 每两个小时同步长沙南雅医院
-//	createLisSyncCronJob.AddFunc(specys1, func() {
-//		// SyncCsnyLis()
-//	})
-//
-//	spec := "0 50 1 * * ?" // 每天凌晨1点同步 监利大院的
-//	createLisSyncCronJob.AddFunc(spec, func() {
-//		// SyncHbdyLis()
-//	})
-//
-//	createLisSyncCronJob.Start()
-//}
+// 返回一个支持至 秒 级别的 cron
+func newWithSeconds() *cron.Cron {
+	secondParser := cron.NewParser(cron.Second | cron.Minute |
+		cron.Hour | cron.Dom | cron.Month | cron.DowOptional | cron.Descriptor)
+	return cron.New(cron.WithParser(secondParser), cron.WithChain())
+}
+
+// func BeginAutoSyncLis() {
+// 	utils.InfoLog("开启自动检验检查同步定时任务")
+// 	createLisSyncCronJob := newWithSeconds()
+
+// 	// specgzjh := "0 */1 * * * ?" // 每1分钟同步 广州暨华HIS医嘱
+// 	// createLisSyncCronJob.AddFunc(specgzjh, func() {
+// 	// 	// SyncGzjhyz()
+// 	// 	Synctfyz()
+// 	// })
+
+// 	specys := "0 0 */1 * * ?" // 每天凌晨3点同步 唐山朝阳医院
+// 	createLisSyncCronJob.AddFunc(specys, func() {
+// 		// SyncStsyLis()
+// 	})
+
+// 	specys1 := "0 10 */2 * * ?" // 每两个小时同步长沙南雅医院
+// 	createLisSyncCronJob.AddFunc(specys1, func() {
+// 		// SyncCsnyLis()
+// 	})
+
+// 	spec := "0 50 1 * * ?" // 每天凌晨1点同步 监利大院的
+// 	createLisSyncCronJob.AddFunc(spec, func() {
+// 		// SyncHbdyLis()
+// 	})
+
+// 	createLisSyncCronJob.Start()
+// }
+
+func BeginAutoSyncLis() {
+	utils.InfoLog("开启自动检验检查同步定时任务")
+	createLisSyncCronJob := newWithSeconds()
+
+	// specgzjh := "0 */1 * * * ?" // 每1分钟同步 广州暨华HIS医嘱
+	// createLisSyncCronJob.AddFunc(specgzjh, func() {
+	// 	// SyncGzjhyz()
+	// 	Synctfyz()
+	// })
+
+	// specys := "0 0 */1 * * ?" // 每天凌晨3点同步 唐山朝阳医院
+	// createLisSyncCronJob.AddFunc(specys, func() {
+	// 	SyncTscyLis()
+	// })
+
+	// specys1 := "0 10 */2 * * ?" // 每两个小时同步长沙南雅医院
+	// createLisSyncCronJob.AddFunc(specys1, func() {
+	// 	SyncCsnyLis()
+	// })
+
+	// spec := "0 50 1 * * ?" // 每天凌晨1点同步 监利大院的
+	// createLisSyncCronJob.AddFunc(spec, func() {
+	// 	SyncHbdyLis()
+	// })
+	
+	// spec2 := "0 50 2 * * ?" // 每天凌晨2点同步 龙岗二院
+	// createLisSyncCronJob.AddFunc(spec2, func() {
+	// 	SyncLisLgty()
+	// })
+
+	// spec3 := "0 50 3 * * ?" // 每天凌晨2点同步 广州暨华血液透析中心
+	// createLisSyncCronJob.AddFunc(spec3, func() {
+	// 	SyncLisGzjhtx()
+	// })
+
+	specgzjh := "0 0 */2 * * ?" // 每2个小时同步 汕头三优血液透析中心LIS
+	createLisSyncCronJob.AddFunc(specgzjh, func() {
+		SyncScpaLis()
+	})
+
+	createLisSyncCronJob.Start()
+}
+
 
 func AutoSyncLis() {
 	utils.TraceLog("检验检查任务开始执行")
@@ -126,7 +171,7 @@ func AutoSyncLis() {
 				}
 				// utils.InfoLog("同步信息详情:%v",syncInfo)
 				continue
-			}
+			} 
 
 			// 第四部：将同步过来的数据插入到中间库对应的表
 			syncSuccessNum := 0
@@ -193,11 +238,11 @@ func SyncToBase() {
 	utils.SuccessLog("检验检查同步任务完成")
 }
 
-func SyncSZblLis() {
-	utils.TraceLog("检验检查同步任务开始执行")
-	org_id := int64(10138)
-	GetDataInsertDB(org_id)
-}
+// func SyncSZblLis() {
+// 	utils.TraceLog("检验检查同步任务开始执行")
+// 	org_id := int64(10138)
+// 	GetDataInsertDB(org_id)
+// }
 
 // func SyncSZblLisResult() {
 // 	utils.TraceLog("获取检验检查结果任务开始执行")

service/gzjhtxzx_service.go

@@ -0,0 +1,524 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	"encoding/json"
+	"encoding/xml"
+	"github.com/astaxie/beego/httplib"
+	"net/url"
+	"strconv"
+	"strings"
+	"time"
+)
+
+type RequestResultGzjh 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 XmlKeyGzjh struct {
+	XMLName    xml.Name `xml:"string"`
+	StringName string   `xml:"name,attr"`
+	InnerText  string   `xml:",innerxml"`
+}
+
+// 获取艾迪康的key
+func GetGzjhAdKey(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 := XmlKeyGzjh{}
+	httplib.Get(apiurl).ToXML(&xmlKey)
+	utils.InfoLog("xmlKey: %v", xmlKey)
+	return xmlKey.InnerText
+}
+
+type ADStringGzjh struct {
+	XMLName    xml.Name     `xml:"string" json:"string"`
+	NewDataSet rpnewDataSetGzjh `xml:"NewDataSet" json:"NewDataSetGzjh"`
+}
+
+type rpnewDataSetGzjh struct {
+	ListTable []rplisttableGzjh `xml:"listtable" json:"listtableGzjh"`
+}
+
+type rplisttableGzjh 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 ReportListXml 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 GetAdGetReportListGzjh(Key string, BeginDateTime string, EndDateTime string, TypeDateTime string, AgainFlag string) (key ADStringGzjh) {
+	Domain := "http://183.63.151.26:8081/AdWebService_new/ADReportWebService.asmx/GetReportList"
+	var xmlKey ADStringGzjh
+	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 adkCheckGzjh 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      []adkResultGzjh `json:"result"`
+}
+
+func GetAdkInfoGzjh(key string, id string) (str []adkCheckGzjh, 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 []adkCheckGzjh
+	json.Unmarshal([]byte(xmlKey.InnerText), &checkJSON)
+	return checkJSON, xmlKey.InnerText
+}
+
+// 广州暨华血液透析中心Lis同步
+func SyncLisGzjhtx() (err error) {
+	// 第一步：获取艾迪康下发的Key
+	org_id := int64(10015)
+	login := "RH0046"
+	password := "Abc123123"
+	key := GetGzjhAdKey(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 = 1672502400
+	}
+	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 := GetAdGetReportListGzjh(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 := GetAdkInfoGzjh(key, listId)
+					utils.InfoLog("checkInfo: %v", checkInfo)
+					for _, info := range checkInfo {
+						// 根据姓名 去查询对应的patient_id
+						patient, _ := GetPatientIDGzjh(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
+							}
+
+							GzjhReportInfoHandle(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
+				}
+			}
+		}
+
+	}
+	SyncToGzczjhtx()
+
+	return
+}
+
+// 根据姓名获取patient_id
+func GetPatientIDGzjh(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 GetProjectInfoGzjh(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 GetGzzcjhProjectID(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 1001501, 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 GzjhReportInfoHandle(CheckInfo adkCheckGzjh, org_id int64, patientId int64) {
+	// 1.先把所有的检查项弄出来
+	for _, info := range CheckInfo.Result {
+		// 根据project_id和item_id 判断该项是否存在
+		curitemcode, _ := strconv.ParseInt(info.Itemcode, 10, 64)
+		reference, _ := GetProjectInfoGzjh(curitemcode, org_id)
+		utils.InfoLog("info: %v", info)
+		utils.InfoLog("reference: %v", info)
+		if reference.ID > 0 {
+			if reference.ProjectId > 0 {
+				LgthYsSyncGzjh(info, reference.ProjectId, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+			} else {
+				project_id := int64(0)
+				if len(info.Groupitemcode) > 0 {
+					// 对没有project信息的项目进行修改
+					project_id, _ = GetGzzcjhProjectID(org_id, info.Groupitemname)
+					reference.ProjectId = project_id
+					reference.ProjectName = info.Groupitemcode
+					reference.Project = info.Groupitemcode
+					// 修改配置信息
+					UpdateInspectionReference(&reference)
+				}
+				LgthYsSyncGzjh(info, project_id, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+			}
+		} else {
+			project_id := int64(0)
+			if len(info.Groupitemcode) > 0 {
+				project_id, _ = GetGzzcjhProjectID(org_id, info.Groupitemname)
+			}
+			LgthYsSyncGzjh(info, project_id, curitemcode, org_id, patientId, CheckInfo.ExecuteTime)
+		}
+	}
+
+	// SyncLisGzjhtx()
+}
+
+type adkResultGzjh 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 LgthYsSyncGzjh(report adkResultGzjh, 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 GetPatientGzjhListGzjh(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 GetAdminUserIdGzjh(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 GetPatientGzjhByOrgIdGzjh(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 SyncToGzczjhtx() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10015)
+
+	// 第一步：跟进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/lis_service.go

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

service/pajm_service.go

@@ -1,13 +1,15 @@
 package service
 
 import (
-	//"Data_Upload_Api/models/sz"
-	//"Data_Upload_Api/service"
 	"IC/models"
 	"IC/utils"
 	_ "encoding/json"
 	_ "encoding/xml"
+	"github.com/jinzhu/gorm"
 	_ "github.com/jinzhu/gorm"
+	"strconv"
+	"strings"
+	"time"
 )
 
 type scpalis struct {
@@ -25,7 +27,7 @@ type scpalis struct {
 	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"`
+	State        string  `gorm:"column:state" json:"state"`
 	CTime        int64  `gorm:"column:c_time" json:"c_time"`
 	UTime        int64  `gorm:"column:u_time" json:"u_time"`
 }
@@ -34,11 +36,10 @@ func (scpalis) TableName() string {
 	return "检验检查信息"
 }
 
-//
-//func GetScpaLis(rdb *gorm.DB, synctime int64, hisuserid string) (record []*scpalis, err error) {
-//	err = rdb.Model(&scpalis{}).Where("inspect_date >= ? and his_user_id = ?", synctime, hisuserid).Find(&record).Error
-//	return
-//}
+func GetScpaLis(rdb *gorm.DB, synctime int64, hisuserid string) (record []*scpalis, err error) {
+	err = rdb.Model(&scpalis{}).Where("inspect_date >= ? and his_user_id = ?", synctime, hisuserid).Find(&record).Error
+	return
+}
 
 // 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
 func GetScpaProjectID(org_id int64, project_name string) (project_id int64, err error) {
@@ -73,167 +74,172 @@ func GetScpaItemID(org_id int64, project_name string, item_name string, project_
 	}
 }
 
+func GetPatientPajmByOrgId(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
+}
+
 // 四川蓬安济民透析中心Lis同步
-//func SyncScpaLis() (err error) {
-//	org_id := int64(9829)
-//
-//	org := &sz.DataUploadConfig{
-//		OrgId:  org_id,
-//		DbHost: "192.168.0.254",
-//		DbPort: "1433",
-//		DbPass: "999999",
-//		DbUser: "sa",
-//		DbName: "nfjiminhis",
-//	}
-//
-//	orgDb, err := service.CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
-//	if err != nil {
-//		utils.ErrorLog("创建数据库连接失败:%v", err)
-//		return
-//	}
-//
-//	// var sync_time int64
-//	// sync_time = 1627747200
-//
-//	// scpaLis, _ := GetScpaLis(orgDb, sync_time,"512926196302182682")
-//	// utils.InfoLog("IdCardNo:%v",scpaLis)
-//
-//	// 第一步：获取上一次同步的时间点
-//	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
-//	var sync_time int64
-//	if syncLastInfo.ID > 0 {
-//		sync_time = syncLastInfo.SyncTime
-//	} else {
-//		sync_time = 1627747200
-//	}
-//	// 第二步：获取所有患者的病历号
-//
-//	patientList, _ := GetPatientGzjhByOrgId(org_id)
-//	if len(patientList) > 0 {
-//		for _, patient := range patientList {
-//			if len(patient.IdCardNo) > 0 {
-//				// 上次同步时间转换为接口需要的格式
-//				patient_id := patient.ID
-//				utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
-//				scpaLis, _ := GetScpaLis(orgDb, sync_time, patient.IdCardNo)
-//				if len(scpaLis) > 0 {
-//					for _, info := range scpaLis {
-//						utils.InfoLog("Result:%v", info)
-//						// 根据project_id和item_id 判断该项是否存在
-//						project_id := int64(0)
-//						if info.ProjectId > 0 {
-//							project_id, _ = GetScpaProjectID(org_id, info.ProjectName)
-//						} else {
-//							continue
-//						}
-//						item_id, _ := GetScpaItemID(org_id, info.ProjectName, info.ItemName, project_id)
-//						tx := writeMiddleDb.Begin()
-//						var inspection models.MiddleInspection
-//						var inspection_reference models.MiddleInspectionReference
-//						record_date := info.InspectDate
-//						if info.InspectDate == 0 {
-//							record_date = time.Now().Unix()
-//						}
-//						inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
-//						var total int
-//						var RangeOptions string
-//						var RangeMin string
-//						var RangeMax string
-//
-//						// // 判断检查类型
-//						ItemType := info.ItemType
-//						RangeMin = info.RangeMin
-//						RangeMax = info.RangeMax
-//						RangeOptions = info.RangeValue
-//						// Range := strings.Split(info.RangeValue, "-")
-//						// if len(Range) > 1 {
-//						// 	RangeMin = Range[0]
-//						// 	RangeMax = Range[1]
-//						// 	ItemType = 1
-//						// } else {
-//						// 	ItemType = 2
-//						// 	RangeOptions = info.RangeOptions
-//						// }
-//
-//						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 = info.ProjectName
-//							inspection_reference.Project = info.ProjectName
-//							inspection_reference.ProjectId = project_id
-//							inspection_reference.ItemName = info.ItemName
-//							inspection_reference.ItemNameAddition = strconv.FormatInt(info.ItemId, 10)
-//							inspection_reference.ItemId = item_id
-//							inspection_reference.RangeType, _ = strconv.Atoi(strconv.FormatInt(ItemType, 10))
-//							inspection_reference.RangeMin = RangeMin
-//							inspection_reference.RangeMax = RangeMax
-//							// inspection_reference.RangeValue = RangeValue
-//							inspection_reference.RangeOptions = RangeOptions
-//							inspection_reference.Unit = info.Unit
-//							inspection_reference.Status = 1
-//							inspection_reference.CreatedTime = time.Now().Unix()
-//							inspection_reference.UpdatedTime = time.Now().Unix()
-//							inspection_reference.InspectDate = inspect_date
-//							inspection_reference.UTime = inspect_date
-//							err = tx.Model(&models.MiddleInspectionReference{}).Create(&inspection_reference).Error
-//							if err != nil {
-//								tx.Rollback()
-//							}
-//						}
-//
-//						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 {
-//							info.ItemValue = strings.Replace(info.ItemValue, "&gt;", ">", -1)
-//							info.ItemValue = strings.Replace(info.ItemValue, "&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, _ = strconv.Atoi(strconv.FormatInt(ItemType, 10))
-//							inspection.ItemId = item_id
-//							inspection.InspectValue = info.ItemValue
-//							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()
-//							}
-//						}
-//						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
-//	}
-//	SyncToScpatx()
-//	return
-//}
+func SyncScpaLis() (err error) {
+	org_id := int64(9829)
+
+	org := &models.DataUploadConfig{
+		OrgId:  org_id,
+		DbHost: "192.168.0.254",
+		DbPort: "1433",
+		DbPass: "999999",
+		DbUser: "sa",
+		DbName: "nfjiminhis",
+	}
+
+	orgDb, err := CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+	if err != nil {
+		utils.ErrorLog("创建数据库连接失败:%v", err)
+		return
+	}
+
+	// var sync_time int64
+	// sync_time = 1627747200
+
+	// scpaLis, _ := GetScpaLis(orgDb, sync_time,"512926196302182682")
+	// utils.InfoLog("IdCardNo:%v",scpaLis)
+
+	// 第一步：获取上一次同步的时间点
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime
+	} else {
+		sync_time = 1627747200
+	}
+	// 第二步：获取所有患者的病历号
+
+	patientList, _ := GetPatientPajmByOrgId(org_id)
+	if len(patientList) > 0 {
+		for _, patient := range patientList {
+			if len(patient.IdCardNo) > 0 {
+				// 上次同步时间转换为接口需要的格式
+				patient_id := patient.ID
+				utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
+				scpaLis, _ := GetScpaLis(orgDb, sync_time, patient.IdCardNo)
+				if len(scpaLis) > 0 {
+					for _, info := range scpaLis {
+						utils.InfoLog("Result:%v", info)
+						// 根据project_id和item_id 判断该项是否存在
+						project_id := int64(0)
+						if info.ProjectId > 0 {
+							project_id, _ = GetScpaProjectID(org_id, info.ProjectName)
+						} else {
+							continue
+						}
+						item_id, _ := GetScpaItemID(org_id, info.ProjectName, info.ItemName, project_id)
+						tx := writeMiddleDb.Begin()
+						var inspection models.MiddleInspection
+						var inspection_reference models.MiddleInspectionReference
+						record_date := info.InspectDate
+						if info.InspectDate == 0 {
+							record_date = time.Now().Unix()
+						}
+						inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
+						var total int
+						var RangeOptions string
+						var RangeMin string
+						var RangeMax string
+
+						// // 判断检查类型
+						ItemType := info.ItemType
+						RangeMin = info.RangeMin
+						RangeMax = info.RangeMax
+						RangeOptions = info.RangeValue
+						// Range := strings.Split(info.RangeValue, "-")
+						// if len(Range) > 1 {
+						// 	RangeMin = Range[0]
+						// 	RangeMax = Range[1]
+						// 	ItemType = 1
+						// } else {
+						// 	ItemType = 2
+						// 	RangeOptions = info.RangeOptions
+						// }
+
+						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 = info.ProjectName
+							inspection_reference.Project = info.ProjectName
+							inspection_reference.ProjectId = project_id
+							inspection_reference.ItemName = info.ItemName
+							inspection_reference.ItemNameAddition = strconv.FormatInt(info.ItemId, 10)
+							inspection_reference.ItemId = item_id
+							inspection_reference.RangeType, _ = strconv.Atoi(strconv.FormatInt(ItemType, 10))
+							inspection_reference.RangeMin = RangeMin
+							inspection_reference.RangeMax = RangeMax
+							// inspection_reference.RangeValue = RangeValue
+							inspection_reference.RangeOptions = RangeOptions
+							inspection_reference.Unit = info.Unit
+							inspection_reference.Status = 1
+							inspection_reference.CreatedTime = time.Now().Unix()
+							inspection_reference.UpdatedTime = time.Now().Unix()
+							inspection_reference.InspectDate = inspect_date
+							inspection_reference.UTime = inspect_date
+							err = tx.Model(&models.MiddleInspectionReference{}).Create(&inspection_reference).Error
+							if err != nil {
+								tx.Rollback()
+							}
+						}
+
+						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 {
+							info.ItemValue = strings.Replace(info.ItemValue, "&gt;", ">", -1)
+							info.ItemValue = strings.Replace(info.ItemValue, "&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, _ = strconv.Atoi(strconv.FormatInt(ItemType, 10))
+							inspection.ItemId = item_id
+							inspection.InspectValue = info.ItemValue
+							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()
+							}
+						}
+						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
+	}
+	SyncToScpatx()
+	return
+}
 
 func SyncToScpatx() {
 	utils.TraceLog("检验检查同步任务开始执行")

service/sccdkfyy_service.go

@@ -0,0 +1,345 @@
+package service
+
+import (
+	"IC/models"
+	"IC/utils"
+	"github.com/jinzhu/gorm"
+	"strconv"
+	"strings"
+	"time"
+)
+
+// 四川城东康复医院Lis同步
+func SyncSccdkfyyLis() (err error) {
+	org_id := int64(10551)
+
+	org := &models.DataUploadConfig{
+		OrgId:  org_id,
+		DbHost: "192.168.1.5",
+		DbPort: "1433",
+		DbPass: "XTXT_User",
+		DbUser: "XTXT_User",
+		DbName: "ndlmis15",
+	}
+
+	orgDb, err := CreateSqlServiceDB(org.DbHost, org.DbPort, org.DbUser, org.DbPass, org.DbName)
+	if err != nil {
+		utils.ErrorLog("创建数据库连接失败:%v", err)
+		return
+	}
+
+	// var sync_time int64
+	// sync_time = 1627747200
+
+	// scpaLis, _ := GetScpaLis(orgDb, sync_time,"512926196302182682")
+	// utils.InfoLog("IdCardNo:%v",scpaLis)
+
+	// 第一步：获取上一次同步的plug_plugcase的ID
+	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
+	var sync_time int64
+	if syncLastInfo.ID > 0 {
+		sync_time = syncLastInfo.SyncTime
+	} else {
+		sync_time = 0
+	}
+
+	sync_time_temp := time.Unix(sync_time, 0)
+	syncTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
+
+
+	// 第二步：获取时间内所有检验结果
+	sccdLis, _ := GetScdckfyyLis(orgDb, syncTimeStr)
+
+	if len(sccdLis) > 0 {
+		for _, item := range sccdLis {
+			printInfo, _ := GetPatientsInfoBySfzh(item.Sfzh, 10551)
+			if printInfo.ID == 0 {
+				continue
+			}
+			// result 里查询
+			antiRresult,_ := GetScCdkfyyAnti(orgDb,item.TestOrderNo)
+			if len(antiRresult) > 0  {
+				for _,anti := range antiRresult {
+					LgthScdckfyySync(anti,item, org_id, printInfo.ID)
+				}
+			}
+		}
+	}
+
+	// 第二步：获取所有患者的病历号
+
+	// patientList, _ := GetPatientGzjhByOrgId(org_id)
+	// if len(patientList) > 0 {
+	// 	for _, patient := range patientList {
+	// 		if len(patient.IdCardNo) > 0 {
+	// 			patient_id := patient.ID
+	// 			utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
+	// 			scdcCaseList, _ := GetScCdkfyyCase(orgDb, sync_time,lastId, patient.IdCardNo)
+	// 			// 如果存在纪录，再在plug_plugCheckitem里根据信息查询检验信息
+	// 			if len(scdcCaseList) > 0 {
+	// 				for _, info := range scdcCaseList {
+	// 					utils.InfoLog("Result:%v", info)
+	// 					scdcItemList,_ := GetScCdkfyyCheckItem(orgDb,info.Serialno)
+	// 					//根据item里的数据，查询检验结果
+	// 					if len(scdcItemList) > 0 {
+	// 						for _,item := range scdcItemList {
+	// 							resultList,_ := GetScCdkfyyResult(orgDb,item.Serialno,item.Itemcode)
+	// 							if len(resultList) > 0 {
+	// 								for _ ,resultinfo := range resultList{
+	// 									LgthScdckfyySync(resultinfo,item, org_id, patient_id)
+	// 								}
+	// 							}
+	// 						}
+	// 					}
+	// 				}
+	// 			}
+	// 		}
+	// 	}
+	// }
+	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
+	}
+	SyncToSccdkfyy()
+	return
+}
+
+func SyncToSccdkfyy() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10551)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}
+
+func GetScCdkfyyAnti(rdb *gorm.DB, test_order_no string) (record []*models.VYunjingPatientLabAnti, err error) {
+	err = rdb.Model(&models.VYunjingPatientLabAnti{}).Where("TEST_ORDER_NO = ?", test_order_no).Find(&record).Error
+	return
+}
+
+func GetPatientsInfoBySfzh(sfzh string, org_id int64) (info models.Patients, err error) {
+	err = readDb.Model(&models.Patients{}).Where("id_card_no = ? AND user_org_id = ?", sfzh, org_id).First(&info).Error
+	return
+}
+
+func GetScdckfyyLis(rdb *gorm.DB, synctime string) (record []*models.VYunjingPatientLabItems, err error) {
+	err = rdb.Model(&models.VYunjingPatientLabItems{}).Where("CREATE_AT >= ? ", synctime).Find(&record).Error
+	return
+}
+
+
+func SyncToScdckfyytx() {
+	utils.TraceLog("检验检查同步任务开始执行")
+	org_id := int64(10551)
+
+	// 第一步：跟进org_id 去中间库查出需要同步的数据
+	inspection_references, _ := GetSyncInspectionReferenceByOrgId(org_id)
+	inspections, _ := GetSyncInspectionByOrgId(org_id)
+
+	// 第二步：将数据同步到业务库
+	if len(inspection_references) > 0 {
+		for _, inspection_reference := range inspection_references {
+			SyncInspectionReference(&inspection_reference)
+		}
+	}
+
+	if len(inspections) > 0 {
+		for _, inspection := range inspections {
+			SyncInspection(&inspection)
+		}
+	}
+	utils.SuccessLog("检验检查同步任务完成")
+}
+
+
+// 从机构将数据同步到中间库
+func LgthScdckfyySync(result *models.VYunjingPatientLabAnti, checkItem *models.VYunjingPatientLabItems, org_id int64, patient_id int64) (*models.MiddleInspectionReference, error) {
+	tx := writeMiddleDb.Begin()
+	var inspection models.MiddleInspection
+	var inspection_reference models.MiddleInspectionReference
+
+	timstr := strings.Split(checkItem.CreateAt, "T")
+	timstem := strings.Split(timstr[1], "Z")
+	recordDateStr := timstr[0] + " " + timstem[0]
+	utils.InfoLog("recordDateStr: %v", recordDateStr)
+
+	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)
+	utils.InfoLog("record_date_str: %v", record_date_str)
+	record_date := record_date_str.Unix()
+	utils.InfoLog("record_date: %v", record_date)
+	inspect_date := time.Unix(record_date, 0).Format("2006-01-02 15:04")
+	utils.InfoLog("inspect_date: %v", inspect_date)
+
+	var total int
+	var RangeOptions string
+	var RangeMin string
+	var RangeMax string
+
+	// // 判断检查类型
+	ItemType := 1
+	Range := strings.Split(result.ReferRange, "-")
+	if len(Range) > 1 {
+		RangeMin = Range[0]
+		RangeMax = Range[1]
+		ItemType = 1
+	} else {
+		ItemType = 2
+		RangeOptions = result.ReferRange
+	}
+
+	err = readMiddleDb.Model(&models.MiddleInspectionReference{}).Where("org_id = ? and project_name = ? and item_name = ? and status = 1", org_id,checkItem.ItemTypeName,result.AntiName).Find(&inspection_reference).Count(&total).Error
+	if inspection_reference.ID > 0 {
+		ItemType = inspection_reference.RangeType
+	}
+	if total <= 0 {
+		//  如果配置表里没有相关配置，则创建project_id,item_id和相关配置信息
+		project_id, _ := GetSccdkfyyProjectID(org_id,checkItem.ItemTypeName)
+		item_id,_ := GetSccdkfyyItemID(org_id, checkItem.ItemTypeName, result.AntiName, project_id)
+
+		inspection_reference.OrgId = org_id
+		inspection_reference.ProjectName = checkItem.ItemTypeName
+		inspection_reference.Project = checkItem.ItemType
+		inspection_reference.ProjectId = project_id
+		inspection_reference.ItemName = result.AntiName
+		inspection_reference.ItemNameAddition = result.AntiName
+		inspection_reference.ItemId = item_id
+		inspection_reference.ItemCode = result.AntiName
+		inspection_reference.RangeType = ItemType
+		inspection_reference.RangeMin = RangeMin
+		inspection_reference.RangeMax = RangeMax
+		// inspection_reference.RangeValue = RangeValue
+		inspection_reference.RangeOptions = RangeOptions
+		inspection_reference.Unit = result.Unit
+		inspection_reference.Status = 1
+		inspection_reference.CreatedTime = time.Now().Unix()
+		inspection_reference.UpdatedTime = time.Now().Unix()
+		inspection_reference.InspectDate = inspect_date
+		inspection_reference.UTime = inspect_date
+		err = tx.Model(&models.MiddleInspectionReference{}).Create(&inspection_reference).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+
+	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, patient_id).Find(&inspection).Count(&itotal).Error
+	if itotal <= 0 {
+		result.TestResult = strings.Replace(result.TestResult, "&gt;", ">", -1)
+		result.TestResult = strings.Replace(result.TestResult, "&lt;", "<", -1)
+		inspection.PatientId = patient_id
+		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 = result.TestResult
+		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(patient_id, 10)
+		err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+		if err != nil {
+			tx.Rollback()
+		}
+	}
+	tx.Commit()
+	return nil, err
+}
+
+func GetProjectInfoSccdkfyy(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
+}
+
+
+// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
+func GetSccdkfyyItemID(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 GetSccdkfyyProjectID(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 1055101, err
+		}
+	}
+}
+
+func GetScCdkfyyResult(rdb *gorm.DB, serialNo string,parItemNo string) (record []*models.PlugPlugresult, err error) {
+	err = rdb.Model(&models.PlugPlugresult{}).Where("serialNo = ? and parItemNo = ?", serialNo,parItemNo).Find(&record).Error
+	return
+}
+
+func GetScCdkfyyCheckItem(rdb *gorm.DB, serialNo string) (record []*models.PlugPlugcheckitem, err error) {
+	err = rdb.Model(&models.PlugPlugcheckitem{}).Where("serialNo = ? ", serialNo).Find(&record).Error
+	return
+}
+
+func GetScCdkfyyCase(rdb *gorm.DB, startId int64,endId int64, hisuserid string) (record []*models.PlugPlugcase, err error) {
+	err = rdb.Model(&models.PlugPlugcase{}).Where("ID >= ? and ID <= ? and mainIndex = ?", startId,endId, hisuserid).Find(&record).Error
+	return
+}
+
+func GetScCdkfyyCaseMaxID(rdb *gorm.DB) (record models.PlugPlugcase, err error) {
+	err = rdb.Model(&models.PlugPlugcase{}).Select("TOP 1 *").Order("ID desc").Find(&record).Error
+	return
+}

service/wfnfm_service.go

@@ -75,13 +75,6 @@ func FindDoctorAdviceOrderById(orgID int64,patientId int64, recordDate int64) (p
 	return
 }
 
-type DataUploadConfig struct {
-	DbHost         string `gorm:"column:db_host" json:"db_host"`
-	DbPort         string `gorm:"column:db_port" json:"db_port"`
-	DbUser         string `gorm:"column:db_user" json:"db_user"`
-	DbPass         string `gorm:"column:db_pass" json:"db_pass"`
-	DbName         string `gorm:"column:db_name" json:"db_name"`
-}
 
 func BatchCreateRecord(ps *models.EmrBloodDialyRecord, rdb *gorm.DB) (err error) {
 	err = rdb.Create(&ps).Error
@@ -100,7 +93,7 @@ func BatchCreateOrder(ps *models.EmrBloodDialyOrder, rdb *gorm.DB) (err error) {
 
 // 潍坊内分泌医院 同步健康数据上报
 func  EmrBloodDiaylOrder() {
-	org := &DataUploadConfig{
+	org := &models.DataUploadConfig{
 		DbHost:         "127.0.0.1",
 		DbPort:         "1433",
 		DbPass:         "Aa123456",
@@ -205,7 +198,7 @@ func  EmrBloodDiaylOrder() {
 
 // 潍坊内分泌医院 同步健康数据上报
 func  EmrBloodDiaylDetail() {
-	org := &DataUploadConfig{
+	org := &models.DataUploadConfig{
 		DbHost:         "localhost",
 		DbPort:         "1433",
 		DbPass:         "Aa123456",
@@ -303,7 +296,7 @@ func  EmrBloodDiaylDetail() {
 
 // 潍坊内分泌医院 同步健康数据上报
 func  EmrBloodDiaylRecord() {
-	org := &DataUploadConfig{
+	org := &models.DataUploadConfig{
 		DbHost:         "localhost",
 		DbPort:         "1433",
 		DbPass:         "Aa123456",

service/ystx_service.go

@@ -200,7 +200,7 @@ func SyncLisYstx() (err error) {
 	// 第一步：获取艾迪康下发的Key
 	org_id := int64(9919)
 	login := "R26028"
-	password := "abc123"
+	password := "Abc123456@"
 	key := GetAdKey(login, password)
 	// 第二步：获取上一次同步的时间点
 	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
@@ -368,7 +368,7 @@ func YsReportInfoHandle(CheckInfo adkCheck, org_id int64, patientId int64) {
 		}
 	}
 
-	SyncToYstx()
+	SyncToGzczjhtx()
 }
 
 type adkResult struct {
@@ -502,29 +502,6 @@ func LgthYsSync(report adkResult, project_id int64, item_id int64, org_id int64,
 	return nil, err
 }
 
-func SyncToYstx() {
-	utils.TraceLog("检验检查同步任务开始执行")
-	org_id := int64(9919)
-
-	// 第一步：跟进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("检验检查同步任务完成")
-}
-
 // 根据姓名获取patient_id
 func GetPatientGzjhList(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

tf日志/tf_20220808_log.txt

@@ -0,0 +1,37 @@
+记录日志
+
+
+2022-08-08 09:50:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:49:00","病人来源":"1","身份证号":""}
+2022-08-08 09:50:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-08 09:51:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:50:00","病人来源":"1","身份证号":""}
+2022-08-08 09:51:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-08 09:52:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:51:00","病人来源":"1","身份证号":""}
+2022-08-08 09:52:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-08 09:53:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:52:00","病人来源":"1","身份证号":""}
+2022-08-08 09:53:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-08 09:54:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:53:00","病人来源":"1","身份证号":""}
+2022-08-08 09:54:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-08 09:55:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-08 09:54:00","病人来源":"1","身份证号":""}
+2022-08-08 09:55:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}

tf日志/tf_20220809_log.txt

@@ -0,0 +1,43 @@
+记录日志
+
+
+2022-08-09 15:09:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:09:00","病人来源":"1","身份证号":"999999190001018888"}
+2022-08-09 15:09:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:09:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:09:00","病人来源":"1","身份证号":"430581200205182779"}
+2022-08-09 15:09:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:09:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:09:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-09 15:09:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:10:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:10:00","病人来源":"1","身份证号":"999999190001019999"}
+2022-08-09 15:10:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:10:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:10:00","病人来源":"1","身份证号":"999999190001018888"}
+2022-08-09 15:10:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:10:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:10:00","病人来源":"1","身份证号":"430581200205182779"}
+2022-08-09 15:10:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-09 15:10:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-09 15:10:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-09 15:10:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}

tf日志/tf_20220810_log.txt

@@ -0,0 +1,85 @@
+记录日志
+
+
+2022-08-10 20:31:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:31:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-10 20:31:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:31:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:31:00","病人来源":"1","身份证号":"35062319500804667X"}
+2022-08-10 20:31:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:32:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:32:00","病人来源":"1","身份证号":"350623198802116616"}
+2022-08-10 20:32:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:32:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:32:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-10 20:32:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:32:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:32:00","病人来源":"1","身份证号":"35062319500804667X"}
+2022-08-10 20:32:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:33:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:33:00","病人来源":"1","身份证号":"350623198802116616"}
+2022-08-10 20:33:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:33:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:33:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-10 20:33:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:33:01 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:33:00","病人来源":"1","身份证号":"35062319500804667X"}
+2022-08-10 20:33:01 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:37:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:37:00","病人来源":"1","身份证号":"350623198802116616"}
+2022-08-10 20:37:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:37:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:37:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-10 20:37:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:37:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:37:00","病人来源":"1","身份证号":"35062319500804667X"}
+2022-08-10 20:37:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:39:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:39:00","病人来源":"1","身份证号":"350623198802116616"}
+2022-08-10 20:39:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:39:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:39:00","病人来源":"1","身份证号":"350425200411242430"}
+2022-08-10 20:39:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}
+
+
+2022-08-10 20:39:00 【 tftf入参 】：
+{"开嘱时间":"2022-08-10 20:39:00","病人来源":"1","身份证号":"35062319500804667X"}
+2022-08-10 20:39:00 【 tftf出参 】：
+{"msg":"成功","result":[],"code":"10000"}