kpt-pasture/module/crontab/work_cron.go

package crontab

import (
	"encoding/json"
	"kpt-pasture/model"
	"time"

	"gorm.io/gorm"

	"gitee.com/xuyiping_admin/pkg/xerr"

	"gitee.com/xuyiping_admin/pkg/logger/zaplog"
	"go.uber.org/zap"

	pasturePb "gitee.com/xuyiping_admin/go_proto/proto/go/backend/cow"
)

// GenerateCalendarBySameTimePlan 生成同期计划的牛只
func (e *Entry) GenerateCalendarBySameTimePlan(cowList []*model.Cow, sameTime *model.SameTime) (err error) {
	if len(cowList) <= 0 {
		return nil
	}

	newCowList := make([]*model.Cow, 0)
	for _, cow := range cowList {
		if ok := e.IsExistSameTimeCow(cow, sameTime); ok {
			continue
		}
		newCowList = append(newCowList, cow)
	}

	if len(newCowList) <= 0 || len(sameTime.CollateNodes) <= 0 {
		return nil
	}

	newSameTimeCowDetailList := make([]*model.EventCowSameTime, 0)
	newEventMatingList := make([]*model.EventMating, 0)
	collateNodes := make([]*pasturePb.CollateNode, 0)
	newEventItemList := make([]*model.EventItem, 0)
	var _ = json.Unmarshal([]byte(sameTime.CollateNodes), &collateNodes)
	nowTime := time.Now()
	for i, collateNode := range collateNodes {
		showDay := nowTime
		if i > 0 {
			showDay = nowTime.Add(time.Hour * 24 * time.Duration(collateNode.NextNodeDay))
		}

		calendarType := pasturePb.CalendarType_PG
		histCount := int64(0)
		if collateNode.SameTimeType == pasturePb.SameTimeType_TAI {
			calendarType = pasturePb.CalendarType_Mating
			histCount = e.GetTowardTaiCowSum(sameTime.PastureId)
			newEventMatingList = append(newEventMatingList, model.NewEventMatingList(sameTime.PastureId, newCowList, showDay.Unix(), pasturePb.ExposeEstrusType_Same_Time)...)
			newEventItemList = append(newEventItemList, model.NewEventItemList(newCowList, calendarType)...)
		} else {
			if collateNode.SameTimeType == pasturePb.SameTimeType_RnGH {
				calendarType = pasturePb.CalendarType_RnGH
			}
			histCount = e.GetTowardSameTimeCowSum(sameTime, collateNode.SameTimeType)
			newEventCowSameTimeList := model.NewEventCowSameTimeList(sameTime.PastureId, newCowList, sameTime, showDay.Unix(), collateNode.SameTimeType)
			newSameTimeCowDetailList = append(newSameTimeCowDetailList, newEventCowSameTimeList...)
			newEventItemList = append(newEventItemList, model.NewEventItemList(newCowList, calendarType)...)
		}

		allCount := int32(len(newCowList)) + int32(histCount)
		e.CreatedCalendar(sameTime.PastureId, calendarType, showDay.Format(model.LayoutDate2), allCount)
	}

	if err = e.DB.Transaction(func(tx *gorm.DB) error {
		// 创建牛只同期详情表
		if err = tx.Create(newSameTimeCowDetailList).Error; err != nil {
			return xerr.WithStack(err)
		}
		// 创建牛只配种表
		if err = tx.Create(newEventMatingList).Error; err != nil {
			return xerr.WithStack(err)
		}
		// 创建牛只事件表
		if err = tx.Create(newEventItemList).Error; err != nil {
			return xerr.WithStack(err)
		}
		return nil
	}); err != nil {
		return xerr.WithStack(err)
	}

	return nil
}

// GetTowardSameTimeCowSum 获取历史未打激素牛只总数量
func (e *Entry) GetTowardSameTimeCowSum(sameTime *model.SameTime, sameTimeType pasturePb.SameTimeType_Kind) int64 {
	res := int64(0)
	if err := e.DB.Model(&model.EventCowSameTime{}).
		Where("status = ?", pasturePb.IsShow_No).
		Where("pasture_id = ?", sameTime.PastureId).
		Where("same_time_id = ?", sameTime.Id).
		Where("same_time_type = ?", sameTimeType).
		Count(&res).Error; err != nil {
		zaplog.Error("GetTowardSameTimeCowSum", zap.Any("err", err))
	}
	return res
}

// GetTowardTaiCowSum 获取历史未配种牛只总数量
func (e *Entry) GetTowardTaiCowSum(pastureId int64) int64 {
	res := int64(0)
	if err := e.DB.Model(&model.EventMating{}).
		Where("pasture_id = ?", pastureId).
		Where("status = ?", pasturePb.IsShow_No).
		Count(&res).Error; err != nil {
		zaplog.Error("GetTowardTaiCowSum", zap.Any("err", err))
	}
	return res
}