IC/service/cron.go

package service

import (
	"IC/models"
	"IC/utils"
	"encoding/json"
	_ "fmt"
	oracle "github.com/dzwvip/gorm-oracle"
	_ "github.com/jinzhu/gorm"
	"github.com/robfig/cron/v3"
	"gorm.io/gorm"
	_ "strings"
	"time"
)

// cron表达式 https://www.cnblogs.com/zuxingyu/p/6023919.html
// var createLisSyncCronJob *cron.Cron

func init() {

}

// 返回一个支持至 秒 级别的 cron
func newWithSeconds() *cron.Cron {
	secondParser := cron.NewParser(cron.Second | cron.Minute |
		cron.Hour | cron.Dom | cron.Month | cron.DowOptional | cron.Descriptor)
	return cron.New(cron.WithParser(secondParser), cron.WithChain())
}

func BeginAutoSyncLis() {
	utils.InfoLog("开启自动检验检查同步定时任务")
	createLisSyncCronJob := newWithSeconds()

	orgDb, err := gorm.Open(oracle.Open("oracle://zjybase:zjybase@10.0.0.248:1521/orcl"), &gorm.Config{})

	if err != nil {
		utils.InfoLog("创建数据库连接失败:%v", err)
	}

	//specys := "0 0 */1 * * ?" // 每天凌晨3点同步 唐山朝阳医院
	//createLisSyncCronJob.AddFunc(specys, func() {
	//	SyncTscyLis()
	//})
	//
	//specys1 := "0 10 */2 * * ?" // 每两个小时同步长沙南雅医院
	//createLisSyncCronJob.AddFunc(specys1, func() {
	//SyncCsnyLis()
	//})
	//
	//spec := "0 50 1 * * ?" // 每天凌晨1点同步 监利大院的
	//createLisSyncCronJob.AddFunc(spec, func() {
	//	SyncHbdyLis()
	//})
	//
	//spec2 := "0 50 2 * * ?" // 每天凌晨2点同步 龙岗二院
	//createLisSyncCronJob.AddFunc(spec2, func() {
	//	SyncLisLgty()
	//})
	//
	//spec3 := "0 50 3 * * ?" // 每天凌晨2点同步 广州暨华血液透析中心
	//createLisSyncCronJob.AddFunc(spec3, func() {
	//	SyncLisGzjhtx()
	//})
	//
	//spec4 := "0 20 3 * * ?" // 每天凌晨同步 石狮盛誉血液透析中心
	//createLisSyncCronJob.AddFunc(spec4, func() {
	//	SyncSYData2()
	//})
	//
	//spec5 := "0 20 4 * * ?" // 每天凌晨同步 唐山朝阳医院VIP血液透析中心
	//createLisSyncCronJob.AddFunc(spec5, func() {
	//	SyncTscyVipLis()
	//})

	//spec6 := "0 20 1 * * ?" // 每天凌晨同步 广州康允透析中心LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec6, func() {
	//	SyncGzkyLis()
	//})

	//spec7 := "0 40 1 * * ?" // 每天凌晨同步 广州康允透析中心LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec7, func() {
	//	SyncLisSzwz()
	//})

	//spec8 := "0 25 */2 * * ?" // 每个小时同步一次 汕头三优透析中心LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec8, func() {
	//	SyncStsyLis()
	//})

	//spec9 := "0 57 * * * ?" // 每个小时同步一次 遵化仁爱医院LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec9, func() {
	//	SyncTszhraLis()
	//})

	//spec10 := "0 20 * * * ?" // 每个小时同步一次 韶关始兴源和盛LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec10, func() {
	//	SyncLisSgyhs()
	//})

	//spec11 := "0 20 */2 * * ?" // 每个小时同步一次 揭阳景熹LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec11, func() {
	//	SyncLisPljx(10597)
	//})

	//spec12 := "0 40 */2 * * ?" // 每个小时同步一次 普宁景熹LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec12, func() {
	//	SyncLisPljx(10599)
	//})

	//spec13 := "0 10 * * * ?" // 每个小时同步一次 唐山遵化仁爱医院LIS对接，本地部署的
	//createLisSyncCronJob.AddFunc(spec13, func() {
	//	SyncTszhraLis()
	//})

	//spec14 := "0 10 2 * * ?" // 每天凌晨步一次 从化意达血液透析中心LIS对接，服务器部署
	//createLisSyncCronJob.AddFunc(spec14, func() {
	//	SyncLisChyd(0)
	//})

	//spec15 := "0 20 */2 * * ?" // 每个小时同步一次 成都城东康复医院，本地部署的
	//createLisSyncCronJob.AddFunc(spec15, func() {
	//	SyncSccdkfyyLis()
	//})

	//spec16 := "0 20 */2 * * ?" // 每个小时同步一次 深圳五洲医院，本地部署的
	//createLisSyncCronJob.AddFunc(spec16, func() {
	//	SyncLisSzwz()
	//})

	//spec17 := "0 20 */2 * * ?" // 每个小时同步一次 湖南嘉禾恒佳医院，本地部署的
	//createLisSyncCronJob.AddFunc(spec17, func() {
	//	SyncJhhjyyLis()
	//})

	spec18 := "1 * * * * ?" // 每个30秒同步一次 四川乐山友谊医院医嘱对接，本地部署的
	createLisSyncCronJob.AddFunc(spec18, func() {
		SyncSclsyyyyyz(orgDb)
	})

	spec19 := "* 35 */4 * * ?" // 每个2个小时同步一次 四川乐山友谊医院LIS对接，本地部署的
	createLisSyncCronJob.AddFunc(spec19, func() {
		SyncScyyyyLis()
	})

	createLisSyncCronJob.Start()
}

func AutoSyncLis() {
	utils.TraceLog("检验检查任务开始执行")
	org_id := int64(9538)

	// 第一步：根据机构id获取对应机构所有病人的his_user_id
	patients, patientError := GetHisUserIdByOrgID(org_id)
	if patientError != nil {
		utils.ErrorLog("获取用户His_user_id信息失败:%v", patientError)
		return
	}

	// patientStr:= make([]interface{},0)
	if len(patients) > 0 {
		// 第二步：根据病人的his_user_id来查询上次同步时间
		for _, patient := range patients {
			if len(patient.HisUserId) <= 0 {
				continue
			}
			syncLastInfo, _ := GetSyncTimeByOrgID(org_id, patient.HisUserId)
			var sync_time int64
			if syncLastInfo.ID > 0 {
				sync_time = syncLastInfo.SyncTime
			} else {
				inspectionLastInfo, _ := GetInspectionLastInfoByOrgID(org_id, patient.HisUserId)
				if inspectionLastInfo.ID > 0 {
					sync_time = inspectionLastInfo.CreatedTime
				} else {
					sync_time = 0
				}
			}

			syncTimes := time.Unix(sync_time, 0).Format("2006-01-02 15:04")
			utils.InfoLog("syncTimes:%v", syncTimes)

			// 第三步：跟进上次同步时间和指定的his_user_id，获取上次同步到现在指定人的检验检查记录
			resultList, _ := GetListByHisUserID(patient.HisUserId, syncTimes, patient.SelectType)
			var syncInfo models.MiddleSyncInfo

			if len(resultList) > 0 {
				// 如果有数据，则把同步过来的详情插入一条数据到同步详情表中
				syncInfo.OrgId = org_id
				syncInfo.HisUserId = patient.HisUserId
				syncInfo.SyncTime = time.Now().Unix()
				syncInfo.SyncResultType = 1
				syncInfo.SyncRsultRemark = "同步成功"
				syncInfo.SyncTotalNum = int64(len(resultList))
				syncInfo.SyncSuccessNum = 0
				SyncInfos, _ := json.Marshal(resultList)
				syncInfo.SyncInfo = string(SyncInfos)
				syncInfo.CreateTime = time.Now().Unix()
				syncInfo.UpdateTime = time.Now().Unix()

				err := CreateSyncInfo(&syncInfo)
				if err != nil {
					utils.ErrorLog("创建同步信息失败:%v", err)
					return
				}
			} else {
				// 如果没有数据，则插入一条数据到同步详情表中
				syncInfo.OrgId = org_id
				syncInfo.HisUserId = patient.HisUserId
				syncInfo.SyncTime = time.Now().Unix()
				syncInfo.SyncResultType = 1
				syncInfo.SyncRsultRemark = "该患者这个时间段没有任何检验检查数据"
				syncInfo.CreateTime = time.Now().Unix()
				syncInfo.UpdateTime = time.Now().Unix()

				err := CreateSyncInfo(&syncInfo)
				if err != nil {
					utils.ErrorLog("创建同步信息失败:%v", err)
					return
				}
				// utils.InfoLog("同步信息详情:%v",syncInfo)
				continue
			}

			// 第四部：将同步过来的数据插入到中间库对应的表
			syncSuccessNum := 0
			for _, result := range resultList {
				if (result.HisUserId == patient.HisUserId) || (result.PatientName == patient.HisUserId) {
					patientId := patient.XtPatientId
					if patientId > 0 {
						inspection_reference, inspection, _ := Sync(result, org_id, patientId)
						if inspection_reference.ID > 0 || inspection.ID > 0 {
							syncSuccessNum++
						}
					}
				}
			}
			syncInfo.SyncSuccessNum = int64(syncSuccessNum)
			UpdateSyncInfo(&syncInfo)

			// patientStr = append(patientStr,patient.HisUserId)
			// utils.InfoLog("patientStr:%v",patientStr)
		}
	} else {
		var syncInfo models.MiddleSyncInfo
		// 如果没有数据，则插入一条数据到同步详情表中
		syncInfo.OrgId = org_id
		syncInfo.SyncTime = time.Now().Unix()
		syncInfo.SyncResultType = 0
		syncInfo.SyncRsultRemark = "该机构没有对应的his_user_id"
		syncInfo.CreateTime = time.Now().Unix()
		syncInfo.UpdateTime = time.Now().Unix()

		err := CreateSyncInfo(&syncInfo)
		if err != nil {
			utils.ErrorLog("创建同步信息失败:%v", err)
			return
		}
		utils.InfoLog("同步信息详情:%v", syncInfo)
		return
	}

	SyncToBase()
	utils.SuccessLog("检验检查任务完成")
}

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

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

// func SyncSZblLis() {
// 	utils.TraceLog("检验检查同步任务开始执行")
// 	org_id := int64(10138)
// 	GetDataInsertDB(org_id)
// }

// func SyncSZblLisResult() {
// 	utils.TraceLog("获取检验检查结果任务开始执行")
// 	org_id := int64(10138)
// 	GetResultDataInsertDB(org_id)
// }