百霖

main.go

 
 func init() {
 	service.ConnectDB()
-	service.ConnectSHMSDB()
+	service.ConnectMSDB2()
 	service.ConnectMSDB()
 }
 

service/sh_service.go

 package service
 
 import (
+	"IC/models"
+	"IC/utils"
 	"fmt"
 	"regexp"
+	"strconv"
+	"strings"
+	"time"
 	"unicode"
 )
 
 func GetSHResultDataInsertDB(org_id int64) (result []*KMResult) {
 	record, _ := GetLastSyncResultRecord(org_id)
 	fmt.Println(record)
-	//if record.ID == 0 {
-	//	list, err := GetSHResultRecord()
-	//	if err == nil {
-	//		fmt.Println(list)
-	//
-	//		//插入到系统检验检查数据
-	//		for _, item := range list {
-	//			project_id := int64(0)
-	//			if len(item.FIDCardNo) > 0 {
-	//				project_id, _ = GetShjhProjectID(org_id, item.FCompoundItemName)
-	//			} else {
-	//				continue
-	//			}
-	//			printInfo, _ := GetPatientsInfoByIDCardNo(item.FIDCardNo, 10215)
-	//
-	//			if printInfo.ID == 0 {
-	//				fmt.Println(item)
-	//				fmt.Println(printInfo)
-	//				fmt.Println("暂无该患者")
-	//				continue
-	//			}
-	//
-	//			item_id, _ := GetShItemID(org_id, item.FCompoundItemName, item.FSingleItemName, project_id)
-	//
-	//			tx := writeMiddleDb.Begin()
-	//			var inspection models.MiddleInspection
-	//			var inspection_reference models.MiddleInspectionReference
-	//
-	//			recordDateStr := ""
-	//			//inspect_date := item.FRecordTime.Format("2006-01-02 15:04")
-	//
-	//			recordDateStr = item.FRecordTime
-	//			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
-	//			// 判断检查类型
-	//			var ItemType int
-	//			if IsChineseChar(item.FReference) || strings.Contains(item.FReference, "|") || strings.Contains(item.FReference, "≤") {
-	//				ItemType = 2
-	//			} else {
-	//				if strings.Contains(item.FReference, "-") {
-	//					ItemType = 1
-	//				} else {
-	//					ItemType = 2
-	//				}
-	//			}
-	//
-	//			if ItemType == 1 {
-	//				Range := strings.Split(item.FReference, "-")
-	//				RangeMin = Range[0]
-	//				RangeMax = Range[1]
-	//			} else {
-	//				RangeOptions = item.FReference
-	//			}
-	//
-	//			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 = item.FCompoundItemName
-	//				inspection_reference.Project = item.FCompoundItemName
-	//				inspection_reference.ProjectId = project_id
-	//				inspection_reference.ItemName = item.FSingleItemName
-	//				inspection_reference.ItemNameAddition = ""
-	//				inspection_reference.ItemId = item_id
-	//				inspection_reference.RangeType = ItemType
-	//				inspection_reference.RangeMin = RangeMin
-	//				inspection_reference.RangeMax = RangeMax
-	//				inspection_reference.RangeOptions = RangeOptions
-	//				inspection_reference.Unit = item.FUnit
-	//				inspection_reference.Status = 1
-	//				inspection_reference.CreatedTime = time.Now().Unix()
-	//				inspection_reference.UpdatedTime = time.Now().Unix()
-	//				inspection_reference.InspectDate = item.FCheckTime
-	//				inspection_reference.UTime = item.FCheckTime
-	//				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.Unix(), printInfo.ID).Find(&inspection).Count(&itotal).Error
-	//			if itotal <= 0 {
-	//				inspection.PatientId = printInfo.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 = item.FResult
-	//				inspection.InspectDate = item.FCheckTime
-	//				inspection.RecordDate = record_date.Unix()
-	//				inspection.Status = 1
-	//				inspection.CreatedTime = time.Now().Unix()
-	//				inspection.UpdatedTime = time.Now().Unix()
-	//				inspection.UTime = item.FCheckTime
-	//				inspection.HisUserId = strconv.FormatInt(printInfo.ID, 10)
-	//				err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
-	//				if err != nil {
-	//					tx.Rollback()
-	//				}
-	//			}
-	//
-	//			tx.Commit()
-	//
-	//		}
-	//		//插入一条查询检验检查结果记录状态数据
-	//		var info LisSyncResultStatusInfo
-	//		info.Ctime = time.Now().Unix()
-	//		info.Status = 1
-	//		info.Mtime = time.Now().Unix()
-	//		info.OrgId = org_id
-	//		info.IsResult = 1
-	//		info.LastId = int64(len(list))
-	//		info.ResultDate = time.Now().Unix()
-	//		writeMiddleDb.Save(&info)
-	//	}
-	//
-	//} else
+	if record.ID == 0 {
+		list, err := GetSHResultRecord()
+		if err == nil {
+			fmt.Println(list)
+
+			//插入到系统检验检查数据
+			for _, item := range list {
+				project_id := int64(0)
+				if len(item.FIDCardNo) > 0 {
+					project_id, _ = GetShjhProjectID(org_id, item.FCompoundItemName)
+				} else {
+					continue
+				}
+				printInfo, _ := GetPatientsInfoByIDCardNo(item.FIDCardNo, 10215)
+
+				if printInfo.ID == 0 {
+					fmt.Println(item)
+					fmt.Println(printInfo)
+					fmt.Println("暂无该患者")
+					continue
+				}
+
+				item_id, _ := GetShItemID(org_id, item.FCompoundItemName, item.FSingleItemName, project_id)
+
+				tx := writeMiddleDb.Begin()
+				var inspection models.MiddleInspection
+				var inspection_reference models.MiddleInspectionReference
+
+				recordDateStr := ""
+				//inspect_date := item.FRecordTime.Format("2006-01-02 15:04")
+
+				recordDateStr = item.FRecordTime
+				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
+				// 判断检查类型
+				var ItemType int
+				if IsChineseChar(item.FReference) || strings.Contains(item.FReference, "|") || strings.Contains(item.FReference, "≤") {
+					ItemType = 2
+				} else {
+					if strings.Contains(item.FReference, "-") {
+						ItemType = 1
+					} else {
+						ItemType = 2
+					}
+				}
+
+				if ItemType == 1 {
+					Range := strings.Split(item.FReference, "-")
+					RangeMin = Range[0]
+					RangeMax = Range[1]
+				} else {
+					RangeOptions = item.FReference
+				}
+
+				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 = item.FCompoundItemName
+					inspection_reference.Project = item.FCompoundItemName
+					inspection_reference.ProjectId = project_id
+					inspection_reference.ItemName = item.FSingleItemName
+					inspection_reference.ItemNameAddition = ""
+					inspection_reference.ItemId = item_id
+					inspection_reference.RangeType = ItemType
+					inspection_reference.RangeMin = RangeMin
+					inspection_reference.RangeMax = RangeMax
+					inspection_reference.RangeOptions = RangeOptions
+					inspection_reference.Unit = item.FUnit
+					inspection_reference.Status = 1
+					inspection_reference.CreatedTime = time.Now().Unix()
+					inspection_reference.UpdatedTime = time.Now().Unix()
+					inspection_reference.InspectDate = item.FCheckTime
+					inspection_reference.UTime = item.FCheckTime
+					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.Unix(), printInfo.ID).Find(&inspection).Count(&itotal).Error
+				if itotal <= 0 {
+					inspection.PatientId = printInfo.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 = item.FResult
+					inspection.InspectDate = item.FCheckTime
+					inspection.RecordDate = record_date.Unix()
+					inspection.Status = 1
+					inspection.CreatedTime = time.Now().Unix()
+					inspection.UpdatedTime = time.Now().Unix()
+					inspection.UTime = item.FCheckTime
+					inspection.HisUserId = strconv.FormatInt(printInfo.ID, 10)
+					err = tx.Model(&models.MiddleInspection{}).Create(&inspection).Error
+					if err != nil {
+						tx.Rollback()
+					}
+				}
+
+				tx.Commit()
+
+			}
+			//插入一条查询检验检查结果记录状态数据
+			var info LisSyncResultStatusInfo
+			info.Ctime = time.Now().Unix()
+			info.Status = 1
+			info.Mtime = time.Now().Unix()
+			info.OrgId = org_id
+			info.IsResult = 1
+			info.LastId = int64(len(list))
+			info.ResultDate = time.Now().Unix()
+			writeMiddleDb.Save(&info)
+		}
+
+	}
+	//else
 	//{
 	//	if record.LastId != 0 {
 	//		list, err := GetResultRecordByID(record.LastId)
 	//
 	//}
 	//
-	//// 第一步：跟进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)
-	//	}
-	//}
+	// 第一步：跟进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)
+		}
+	}
 	return
 
 }