IC/service/csny_service.go

package service

import (
	"IC/models"
	"IC/utils"
	_ "IC/utils"
	"bytes"
	"encoding/json"
	_ "encoding/json"
	_"encoding/xml"
	"fmt"
	"net/http"
	"io/ioutil"
	_ "github.com/jinzhu/gorm"

	"strconv"
	"strings"
	"time"
)

// 福建天福医院透析中心Lis同步
func SyncCsnyLis() (err error) {
	org_id := int64(10340)

	// 第一步：获取上一次同步的时间点
	syncLastInfo, _ := GetSyncTimeByOrgIDForYs(org_id)
	var sync_time int64
	if syncLastInfo.ID > 0 {
		sync_time = syncLastInfo.SyncTime
	} else {
		sync_time = 1651334400  // 2022-05-01 00:00:00
	}

	sync_time_temp := time.Unix(sync_time,0)
	syncTimeStr := sync_time_temp.Format("2006-01-02 15:04:05")
	// 第二步：获取所有患者的病历号

	patientList, _ := GetPatientGzjhByOrgId(org_id)
	if len(patientList) > 0 {
		for _, patient := range patientList {
			if len(patient.IdCardNo) > 0 || len(patient.DialysisNo) > 0 {
				patient_id := patient.ID
				utils.InfoLog("IdCardNo:%v", patient.IdCardNo)
				// utils.InfoLog("VipStr:%v", VipStr)

				result, _ := CsnyGetLab(patient.IdCardNo,syncTimeStr)
				utils.InfoLog("result:%v", result)
				var fjtfLab LabCsnyResult
				if err := json.Unmarshal([]byte(result), &fjtfLab); err != nil {
					utils.ErrorLog("解析失败：%v", err)
				}
				fmt.Println(fjtfLab)

				if len(fjtfLab.Result) > 0 {
					// 根据获取的头部lab01获取检查结果
	
					for _, info := range fjtfLab.Result {
						lacResult, _ := CsnyGetLac(info.Lab01)
						utils.InfoLog("lacResult:%v", lacResult)
						var fjtfLac LacCsnyResult
						if err := json.Unmarshal([]byte(lacResult), &fjtfLac); err != nil {
							utils.ErrorLog("解析失败：%v", err)
						}
						fmt.Println(fjtfLac)
						for _,cinfo := range fjtfLac.Result{
							project_id := int64(0)
							item_id := int64(0)
							if len(cinfo.Bbx05a) > 0 {
								project_id, _ = GetCsnyProjectID(org_id, cinfo.Bbx05a)
								item_id, _ = GetCsnyItemID(org_id, cinfo.Bbx05a, cinfo.Bbx05, project_id)
							} else {
								project_id, _ = GetCsnyProjectID(org_id, cinfo.Bbx05)
								item_id, _ = GetCsnyItemID(org_id, cinfo.Bbx05, cinfo.Bbx05, project_id)
							}
						

							tx := writeMiddleDb.Begin()
							var inspection models.MiddleInspection
							var inspection_reference models.MiddleInspectionReference


							loc, _ := time.LoadLocation("Local")
							theTime, _ := time.ParseInLocation("2006-01-02 15:04:05", cinfo.Lac25, loc)
							record_date := theTime.Unix()

						if record_date == 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 := 1
						Range := strings.Split(cinfo.Lac15, "-")
						if len(Range) > 1 {
							RangeMin = cinfo.Lac13
							RangeMax = cinfo.Lac14
							ItemType = 1
						} else {
							ItemType = 2
							RangeOptions = cinfo.Lac15
						}

						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 = int64(inspection_reference.RangeType)
						// }
						
						if total <= 0 {
							inspection_reference.OrgId = org_id
							if len(cinfo.Bbx05a) > 0 {
								inspection_reference.ProjectName = cinfo.Bbx05a 
								inspection_reference.Project = cinfo.Bbx05a
							} else {
								inspection_reference.ProjectName = cinfo.Bbx05
								inspection_reference.Project = cinfo.Bbx05
							}
							inspection_reference.ProjectId = project_id
							inspection_reference.ItemName = cinfo.Bbx05
							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 = cinfo.Bdg02
							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 {
							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 = cinfo.Lac10
							inspection.InspectDate = inspect_date
							inspection.RecordDate = record_date
							inspection.InspectTips =  cinfo.Lac11
							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
	}
	SyncToCsnytx()
	return
}

type LabCsnyResult struct {
	Msg    string `json:"msg"`
	Result []struct {
		Lab01	int64		`json:"lab01"`
		Lab58	string   	`json:"lab58"`
	} `json:"result"`
	Code string `json:"code"`
}

func CsnyGetLab(id_card_no string, synctime string) (string, string) {
	inputData := make(map[string]interface{})

	inputData["vaa15"] = id_card_no
	inputData["begintime"] = synctime

	var inputLog string
	bytesData, err := json.Marshal(inputData)
	inputLog = string(bytesData)
	fmt.Println(string(bytesData))
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	reader := bytes.NewReader(bytesData)
	url := "http://218.104.146.179:9091/esb/listener/getLab1"

	request, err := http.NewRequest("POST", url, reader)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}

	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
	request.Header.Set("code", "Xmrjyy")

	client := http.Client{}
	resp, err := client.Do(request)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	respBytes, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	str := string(respBytes)
	return str, inputLog
}

type LacCsnyResult struct {
	Msg    string `json:"msg"`
	Result []struct {
		Lab01	int64		`json:"labo1"`
		Bbx05	string   	`json:"BBX05"`
		Bbx05a	string   	`json:"BBX05A"`
		Bfc03	string   	`json:"BFC03"`
		Bdg02	string   	`json:"BDG02"`
		Lac10	string   	`json:"LAC10"`
		Lac11	string   	`json:"LAC11"`
		Lac13	string   	`json:"LAC13"`
		Lac14	string   	`json:"LAC14"`
		Lac15	string   	`json:"LAC15"`
		Lac25	string   	`json:"LAC25"`
	} `json:"result"`
	Code string `json:"code"`
}

func CsnyGetLac(lab01 int64) (string, string) {
	inputData := make(map[string]interface{})

	inputData["lab01"] = lab01

	var inputLog string
	bytesData, err := json.Marshal(inputData)
	inputLog = string(bytesData)
	fmt.Println(string(bytesData))
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	reader := bytes.NewReader(bytesData)
	url := "http://218.104.146.179:9091/esb/listener/getLac1"

	request, err := http.NewRequest("POST", url, reader)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}

	request.Header.Set("Content-Type", "application/json;charset=UTF-8")
	request.Header.Set("code", "Xmrjyy")

	client := http.Client{}
	resp, err := client.Do(request)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	respBytes, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		fmt.Println(err.Error())
		return err.Error(), ""
	}
	str := string(respBytes)
	return str, inputLog
}

// 根据机构ID和检验检查名称获取该检查的project_id，如没有，则创建一个
func GetCsnyProjectID(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 340001, err
		}
	}
}

// 根据机构ID和检验检查小项名称获取该检查的item_id，如没有，则创建一个
func GetCsnyItemID(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
		}
	}
}


func SyncToCsnytx() {
	utils.TraceLog("检验检查同步任务开始执行")
	org_id := int64(10340)

	// 第一步：跟进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("检验检查同步任务完成")
}