IC/service/sh_service.go

package service

import (
	"IC/models"
	"IC/utils"
	"fmt"
	"regexp"
	"strconv"
	"strings"
	"time"
	"unicode"
)

type KMResult struct {
	FRequestCode           string `gorm:"column:F_RequestCode" json:"F_RequestCode" form:"F_RequestCode"`
	FHospSampleID          string `gorm:"column:F_HospSampleID" json:"F_HospSampleID" form:"F_HospSampleID"`
	FHospSampleNumber      string `gorm:"column:F_HospSampleNumber" json:"F_HospSampleNumber" form:"F_HospSampleNumber"`
	FInputDate             string `gorm:"column:F_InputDate" json:"F_InputDate" form:"F_InputDate"`
	FSamplingDate          string `gorm:"column:F_SamplingDate" json:"F_SamplingDate" form:"F_SamplingDate"`
	FName                  string `gorm:"column:F_Name" json:"F_Name" form:"F_Name"`
	FSex                   string `gorm:"column:F_Sex" json:"F_Sex" form:"F_Sex"`
	FAge                   string `gorm:"column:F_Age" json:"F_Age" form:"F_Age"`
	FAgeUnit               string `gorm:"column:F_AgeUnit" json:"F_AgeUnit" form:"F_AgeUnit"`
	FPatientNumber         string `gorm:"column:F_PatientNumber" json:"F_PatientNumber" form:"F_PatientNumber"`
	FItemType              string `gorm:"column:F_ItemType" json:"F_ItemType" form:"F_ItemType"`
	FCompoundItem          string `gorm:"column:F_CompoundItem" json:"F_CompoundItem" form:"F_CompoundItem"`
	FCompoundItemName      string `gorm:"column:F_CompoundItemName" json:"F_CompoundItemName" form:"F_CompoundItemName"`
	FNaturalItem           string `gorm:"column:F_NaturalItem" json:"F_NaturalItem" form:"F_NaturalItem"`
	FNaturalItemName       string `gorm:"column:F_NaturalItemName" json:"F_NaturalItemName" form:"F_NaturalItemName"`
	FSingleItem            string `gorm:"column:F_SingleItem" json:"F_SingleItem" form:"F_SingleItem"`
	FSingleItemName        string `gorm:"column:F_SingleItemName" json:"F_SingleItemName" form:"F_SingleItemName"`
	FHospNaturalItem       string `gorm:"column:F_HospNaturalItem" json:"F_HospNaturalItem" form:"F_HospNaturalItem"`
	FHospNaturalItemName   string `gorm:"column:F_HospNaturalItemName" json:"F_HospNaturalItemName" form:"F_HospNaturalItemName"`
	FHospItem              string `gorm:"column:F_HospItem" json:"F_HospItem" form:"F_HospItem"`
	FHospItemName          string `gorm:"column:F_HospItemName" json:"F_HospItemName" form:"F_HospItemName"`
	FTestNO                string `gorm:"column:F_TestNO" json:"F_TestNO" form:"F_TestNO"`
	FResult                string `gorm:"column:F_Result" json:"F_Result" form:"F_Result"`
	FUnit                  string `gorm:"column:F_Unit" json:"F_Unit" form:"F_Unit"`
	FHint                  string `gorm:"column:F_Hint" json:"F_Hint" form:"F_Hint"`
	FSuggestion            string `gorm:"column:F_Suggestion" json:"F_Suggestion" form:"F_Suggestion"`
	FReference             string `gorm:"column:F_Reference" json:"F_Reference" form:"F_Reference"`
	FReference2            string `gorm:"column:F_Reference2" json:"F_Reference2" form:"F_Reference2"`
	FDepartmentName        string `gorm:"column:F_DepartmentName" json:"F_DepartmentName" form:"F_DepartmentName"`
	FRecorderName          string `gorm:"column: F_RecorderName" json:"F_RecorderName" form:"F_RecorderName"`
	FRecordTime            string `gorm:"column:F_RecordTime" json:"F_RecordTime" form:"F_RecordTime"`
	FCheckerName           string `gorm:"column:F_CheckerName" json:"F_CheckerName" form:"F_CheckerName"`
	FCheckTime             string `gorm:"column:F_CheckTime" json:"F_CheckTime" form:"F_CheckTime"`
	FAuthorizeName         string `gorm:"column:F_AuthorizeName" json:"F_AuthorizeName" form:"F_AuthorizeName"`
	FAuthorizeTime         string `gorm:"column:F_AuthorizeTime" json:"F_AuthorizeTime" form:"F_AuthorizeTime"`
	FSubResults            string `gorm:"column:F_SubResults" json:"F_SubResults" form:"F_SubResults"`
	FPathologyGrossingDesc string `gorm:"column:F_PathologyGrossingDesc" json:"F_PathologyGrossingDesc" form:"F_PathologyGrossingDesc"`
	FReportBarCode         string `gorm:"column:F_ReportBarCode" json:"F_ReportBarCode" form:"F_ReportBarCode"`
	FReceiveTime           string `gorm:"column:F_ReceiveTime" json:"F_ReceiveTime" form:"F_ReceiveTime"`
	FStatus                string `gorm:"column:F_Status" json:"F_Status" form:"F_Status"`
	FRemark                string `gorm:"column:F_Remark" json:"F_Remark" form:"F_Remark"`
	FTestMethodName        string `gorm:"column:F_TestMethodName" json:"F_TestMethodName" form:"F_TestMethodName"`
	FMachineName           string `gorm:"column:F_MachineName" json:"F_MachineName" form:"F_MachineName"`
	FItemDesc              string `gorm:"column:F_ItemDesc" json:"F_ItemDesc" form:"F_ItemDesc"`
	FIsDelayed             string `gorm:"column:F_IsDelayed" json:"F_IsDelayed" form:"F_IsDelayed"`
	FDelayeddesc           string `gorm:"column:F_Delayeddesc" json:"F_Delayeddesc" form:"F_Delayeddesc"`
	FIsReimbu              string `gorm:"column:F_IsReimbu" json:"F_IsReimbu" form:"F_IsReimbu"`
	FReimbuDesc            string `gorm:"column:F_ReimbuDesc" json:"F_ReimbuDesc" form:"F_ReimbuDesc"`
	FDetailItemID          string `gorm:"column:F_DetailItemID" json:"F_DetailItemID" form:"F_DetailItemID"`
	FIDCardNo              string `gorm:"column:F_IDCardNo" json:"F_IDCardNo" form:"F_IDCardNo"`
}

func (KMResult) TableName() string {
	return "v_km_lis_result"
}

//获取lis返回检验检查结果数据
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.LastId != 0 {
	//		list, err := GetResultRecordByID(record.LastId)
	//		fmt.Println(list)
	//		//插入中间库中
	//		//插入一条插入中间库记录数据
	//		if err == nil {
	//
	//			//插入到系统检验检查数据
	//			for _, item := range list {
	//				project_id := int64(0)
	//				if len(item.Barcode) > 0 {
	//					project_id, _ = GetBljhProjectID(org_id, item.Groupname)
	//				} else {
	//					continue
	//				}
	//				printInfo, _ := GetHisLabelPrintInfoById(item.Barcode)
	//				item_id, _ := GetBlItemID(org_id, item.Groupname, item.Itemname, project_id)
	//
	//				tx := writeMiddleDb.Begin()
	//				var inspection models.MiddleInspection
	//				var inspection_reference models.MiddleInspectionReference
	//
	//				recordDateStr := ""
	//				inspect_date := item.Repdate.Format("2006-01-02 15:04")
	//				if item.Repdate.Unix() == 0 {
	//					recordDateStr = time.Now().Format("2006-01-02 15:04")
	//				} else {
	//
	//					recordDateStr = inspect_date
	//				}
	//
	//				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 strings.Contains(item.Refrange, "-") {
	//					ItemType = 1
	//
	//				} else {
	//					ItemType = 2
	//
	//				}
	//
	//				if ItemType == 1 {
	//					Range := strings.Split(item.Refrange, "-")
	//					RangeMin = Range[0]
	//					RangeMax = Range[1]
	//				} else {
	//					RangeOptions = item.Refrange
	//				}
	//
	//				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.Groupname
	//					inspection_reference.Project = item.Groupname
	//					inspection_reference.ProjectId = project_id
	//					inspection_reference.ItemName = item.Itemname
	//					inspection_reference.ItemNameAddition = item.Barcode
	//					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.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.Unix(), printInfo.PatientId).Find(&inspection).Count(&itotal).Error
	//				if itotal <= 0 {
	//					inspection.PatientId = printInfo.PatientId
	//					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.Result
	//					inspection.InspectDate = inspect_date
	//					inspection.RecordDate = record_date.Unix()
	//					inspection.Status = 1
	//					inspection.CreatedTime = time.Now().Unix()
	//					inspection.UpdatedTime = time.Now().Unix()
	//					inspection.UTime = inspect_date
	//					inspection.HisUserId = strconv.FormatInt(printInfo.PatientId, 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
	//			code, _ := strconv.ParseInt(list[0].Barcode, 10, 64)
	//			info.LastId = code
	//			info.ResultDate = time.Now().Unix()
	//			writeMiddleDb.Save(&info)
	//
	//		}
	//
	//	}
	//
	//}
	//
	// 第一步：跟进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

}

func GetSHResultRecord() (record []*KMResult, err error) {
	err = dataBase.Model(&KMResult{}).Order("barcode asc").Find(&record).Error
	return
}

//判断是否包含中文
func IsChineseChar(str string) bool {
	for _, r := range str {
		if unicode.Is(unicode.Scripts["Han"], r) || (regexp.MustCompile("[\u3002\uff1b\uff0c\uff1a\u201c\u201d\uff08\uff09\u3001\uff1f\u300a\u300b]").MatchString(string(r))) {
			return true
		}
	}
	return false
}

func GetResultRecordByTime(id int64) (record []*KMResult, err error) {
	err = readDb.Model(&KMResult{}).Where("barcode > ? AND repdate >= 2021-08-12 00:00:00", id).Order("barcode asc").Find(&record).Error
	return
}