csx 3 yıl önce
ebeveyn
işleme
793d2e180f
3 değiştirilmiş dosya ile 11 ekleme ve 1 silme
  1. 6 0
      controllers/lis.go
  2. 1 0
      routers/router.go
  3. 4 1
      service/bl_service.go

+ 6 - 0
controllers/lis.go Dosyayı Görüntüle

@@ -400,3 +400,9 @@ func (c *LisController) SyncBlLis() {
400 400
 	service.GetDataInsertDB(10138)
401 401
 
402 402
 }
403
+
404
+func (c *LisController) SyncBlResultLis() {
405
+
406
+	service.GetResultDataInsertDB(10138)
407
+
408
+}

+ 1 - 0
routers/router.go Dosyayı Görüntüle

@@ -19,5 +19,6 @@ func init() {
19 19
 	beego.Router("/api/lis/hbdylissync", &controllers.LisController{}, "get:SyncHbJldyLis")
20 20
 
21 21
 	beego.Router("/api/lis/bltest", &controllers.LisController{}, "get:SyncBlLis")
22
+	beego.Router("/api/lis/blresulttest", &controllers.LisController{}, "get:SyncBlResultLis")
22 23
 
23 24
 }

+ 4 - 1
service/bl_service.go Dosyayı Görüntüle

@@ -237,7 +237,7 @@ func GetLastSyncResultRecord(org_id int64) (record LisSyncResultStatusInfo, err
237 237
 }
238 238
 
239 239
 func GetResultRecord() (record []*CmResult, err error) {
240
-	err = dataBase.Model(&CmResult{}).Order("barcode desc").Find(&record).Error
240
+	err = dataBase.Model(&CmResult{}).Order("barcode desc").Limit(100).Find(&record).Error
241 241
 	return
242 242
 }
243 243
 
@@ -529,6 +529,7 @@ func GetResultDataInsertDB(org_id int64) (result []*CmResult) {
529 529
 	if record.ID == 0 {
530 530
 		list, err := GetResultRecord()
531 531
 		if err == nil {
532
+			fmt.Println(list)
532 533
 			//插入一条查询检验检查结果记录状态数据
533 534
 			var info LisSyncResultStatusInfo
534 535
 			info.Ctime = time.Now().Unix()
@@ -653,7 +654,9 @@ func GetResultDataInsertDB(org_id int64) (result []*CmResult) {
653 654
 
654 655
 	} else {
655 656
 		if record.LastId != 0 {
657
+
656 658
 			list, err := GetResultRecordByID(record.LastId)
659
+			fmt.Println(list)
657 660
 			//插入中间库中
658 661
 			//插入一条插入中间库记录数据
659 662
 			if err == nil {