百霖

controllers/lis.go

@@ -398,11 +398,15 @@ func (c *LisController) SyncHbJldyLis() {
 
 func (c *LisController) SyncBlLis() {
 	service.GetDataInsertDB(10138)
-
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "同步成功",
+	})
 }
 
 func (c *LisController) SyncBlResultLis() {
 
 	service.GetResultDataInsertDB(10138)
-
+	c.ServeSuccessJSON(map[string]interface{}{
+		"resultList": "同步成功",
+	})
 }

routers/router.go

@@ -18,6 +18,7 @@ func init() {
 	beego.Router("/api/lis/hbdyyzsync", &controllers.LisController{}, "get:SyncHbJldyyz")
 	beego.Router("/api/lis/hbdylissync", &controllers.LisController{}, "get:SyncHbJldyLis")
 
+	//百霖lis
 	beego.Router("/api/lis/bltest", &controllers.LisController{}, "get:SyncBlLis")
 	beego.Router("/api/lis/blresulttest", &controllers.LisController{}, "get:SyncBlResultLis")
 

service/bl_service.go

@@ -239,7 +239,7 @@ func GetLastSyncResultRecord(org_id int64) (record LisSyncResultStatusInfo, err
 }
 
 func GetResultRecord() (record []CmResult, err error) {
-	err = dataBase.Model(&CmResult{}).Order("barcode asc").Limit(1).Find(&record).Error
+	err = dataBase.Model(&CmResult{}).Order("barcode asc").Find(&record).Error
 	return
 }
 
@@ -264,7 +264,7 @@ func GetLisDataById(org_id int64, last_id int64) (list []*HisLabelPrintInfo, err
 				}).Where("status = 1")
 			}).Where("status = 1")
 		}).Where("status = 1")
-	}).Where("id > ? AND user_org_id = ? AND status = 1", last_id, org_id).Limit(100).Find(&list).Error
+	}).Where("id > ? AND user_org_id = ? AND status = 1", last_id, org_id).Find(&list).Error
 	return
 }
 
@@ -277,7 +277,7 @@ func GetAllLisData(org_id int64) (list []*HisLabelPrintInfo, err error) {
 				}).Where("status = 1")
 			}).Where("status = 1")
 		}).Where("status = 1")
-	}).Where("user_org_id = ? AND status = 1", org_id).Limit(100).Find(&list).Error
+	}).Where("user_org_id = ? AND status = 1", org_id).Find(&list).Error
 	return
 }
 
@@ -657,9 +657,7 @@ func GetResultDataInsertDB(org_id int64) (result []*CmResult) {
 
 	} else {
 		if record.LastId != 0 {
-			fmt.Println("~~~~~~~~")
-
-			list, err := GetResultRecord()
+			list, err := GetResultRecordByID(record.LastId)
 			fmt.Println(list)
 			//插入中间库中
 			//插入一条插入中间库记录数据
@@ -667,15 +665,13 @@ func GetResultDataInsertDB(org_id int64) (result []*CmResult) {
 
 				//插入到系统检验检查数据
 				for _, item := range list {
-
 					project_id := int64(0)
-					if len("180") > 0 {
+					if len(item.Barcode) > 0 {
 						project_id, _ = GetBljhProjectID(org_id, item.Groupname)
 					} else {
 						continue
 					}
-					printInfo, _ := GetHisLabelPrintInfoById("180")
-
+					printInfo, _ := GetHisLabelPrintInfoById(item.Barcode)
 					item_id, _ := GetBlItemID(org_id, item.Groupname, item.Itemname, project_id)
 
 					tx := writeMiddleDb.Begin()

service/cron.go

@@ -22,32 +22,32 @@ func init() {
 		AutoSyncLis()
 	})
 
-	speclg := "0 0 2 * * ?" // 每天凌晨2点同步 龙岗二院
-	createLisSyncCronJob.AddFunc(speclg, func() {
-		SyncLisLgty()
-	})
-
-	specys := "0 0 3 * * ?" // 每天凌晨3点同步 沅胜血透
-	createLisSyncCronJob.AddFunc(specys, func() {
-		SyncHbdyLis()
-	})
+	//speclg := "0 0 2 * * ?" // 每天凌晨2点同步 龙岗二院
+	//createLisSyncCronJob.AddFunc(speclg, func() {
+	//	SyncLisLgty()
+	//})
+	//
+	//specys := "0 0 3 * * ?" // 每天凌晨3点同步 沅胜血透
+	//createLisSyncCronJob.AddFunc(specys, func() {
+	//	SyncHbdyLis()
+	//})
 
 	// specgzjh := "0 */1 7-20 * *  " // 每2分钟同步 广州暨华HIS医嘱
 	// createLisSyncCronJob.AddFunc(specgzjh, func() {
 	// 	SyncGzjhyz()
 	// })
 
-	specgzjhlis := "0 30 3 * * ?" // 每天凌晨3点30同步 广州暨华
-	createLisSyncCronJob.AddFunc(specgzjhlis, func() {
-		SyncGzjhLis()
-	})
-
-	specszbllis := "0 30 4 * * ?" // 每天凌晨4点30同步 广州暨华
+	//specgzjhlis := "0 30 3 * * ?" // 每天凌晨3点30同步 广州暨华
+	//createLisSyncCronJob.AddFunc(specgzjhlis, func() {
+	//	SyncGzjhLis()
+	//})
+	//
+	specszbllis := "0 0 4 * * ?" // 每天凌晨4点00同步 深圳百霖
 	createLisSyncCronJob.AddFunc(specszbllis, func() {
 		SyncSZblLis()
 	})
 
-	specszbllisResult := "0 0 2 * * ?" // 每天凌晨3点00同步 广州暨华
+	specszbllisResult := "0 30 4 * * ?" // 每天凌晨4点30同步 深圳百霖
 	createLisSyncCronJob.AddFunc(specszbllisResult, func() {
 		SyncSZblLisResult()
 	})