kpt_xdmy/apiserver/service/job.go

package service

import (
	"fmt"
	"github.com/robfig/cron"
	"kpt.xdmy/apiserver/model"
	"kpt.xdmy/apiserver/service/cownum_sqlserver"
	"time"
)

var s *Service

func SapJobInit() {

	duetimecst, _ := time.ParseInLocation("15:04:05", "00:01:00", time.Local)
	duetimecst1, _ := time.ParseInLocation("15:04:05", "00:00:00", time.Local)
	spec := fmt.Sprintf("@every %v", duetimecst.Sub(duetimecst1))
	c := cron.New()
	c.AddFunc(spec, func() {
		AutoSapOrderJob()
		AutoSrmOrderJob()
		AutoSapReturnOrderJob()
		AutoSrmReturnOrderJob()
	})
	c.Start()
	/*
		var t time.Time
		t = time.Now()
		var code string
		pastureList := make([]*model.Pasture, 0)
		err := s.d.DB.Table("pasture").Where("id in(367)").Find(&pastureList)
		fmt.Println(err)
		i := -120
		for {
			fmt.Println(i, t.AddDate(0, 0, i))
			for _, pasture := range pastureList {
				s.SapSupplier(t, pasture.CompanyCode, pasture.ID)
				s.SapAsset(t.AddDate(0, 0, i), code, pasture.CompanyCode)
			}

			if t.AddDate(0, 0, i).Format("2006-01-02") == "2023-04-26" {
				break
			}
			i++
		}
	*/
	c1 := cron.New()
	c1.AddFunc("0 50 23 * * ?", func() {
		fmt.Println(time.Now())
		var t time.Time
		t = time.Now()
		var code string
		pastureList := make([]*model.Pasture, 0)
		err := s.d.DB.Table("pasture").Find(&pastureList)
		fmt.Println(err)
		for _, pasture := range pastureList {
			s.SapSupplier(t, pasture.CompanyCode, pasture.ID)
			s.SapAsset(t, code, pasture.CompanyCode)
		}
		s.SapMaterial(t, code)
		s.d.DB.Exec(`call createEqstatus()`)
	})

	//保养计划
	duetimecst, _ = time.ParseInLocation("15:04:05", "01:00:00", time.Local)
	duetimecst1, _ = time.ParseInLocation("15:04:05", "00:00:00", time.Local)
	spec1 := fmt.Sprintf("@every %v", duetimecst.Sub(duetimecst1))
	c1.AddFunc(spec1, func() {
		s.d.DB.Exec(`call createRUcode()`)
	})

	duetimecst, _ = time.ParseInLocation("15:04:05", "00:05:00", time.Local)
	duetimecst1, _ = time.ParseInLocation("15:04:05", "00:00:00", time.Local)
	spec2 := fmt.Sprintf("@every %v", duetimecst.Sub(duetimecst1))
	c1.AddFunc(spec2, func() {
		s.d.DB.Exec(`call wxmsg()`)
	})

	//i := -10
	//for {
	//	now := time.Now().AddDate(0, 0, i).Format("2006-01-02")
	//	fmt.Println(now)
	//	cownum_sqlserver.SyncCownum(s.sqlserver, s.d, now)
	//	if now == "2023-05-09" {
	//		break
	//	}
	//	i++
	//}
	//pastureList := make([]*model.Pasture, 0)
	//s.d.DB.Table("pasture").Where("vendor = 1 ").Where("factory_code  != '' ").Where("factory_code  is not null ").Find(&pastureList)
	//for _, item := range pastureList {
	//	//fmt.Println(item.FactoryCode, "a")
	//	AutoFeeQuery(item.FactoryCode, item.ID)
	//}

	c1.AddFunc("0 10 16 * * ?", func() {
		cownum_sqlserver.SyncCownum(s.sqlserver, s.d, time.Now().AddDate(0, 0, -1).Format("2006-01-02"))

		//pastureList := make([]*model.Pasture, 0)
		//s.d.DB.Table("pasture").Where("vendor = 1 ").Where("factory_code  != '' ").Where("factory_code  is not null ").Find(&pastureList)
		//for _, item := range pastureList {
		//	//fmt.Println(item.FactoryCode, "a")
		//	AutoFeeQuery(item.FactoryCode, item.ID)
		//}

	})
	c1.Start()
}

func jobMaterial() {
	t := time.Now()
	var code string
	s.SapMaterial(t, code)
}
func jobTransfer() {
	autoTransfer()
}