liucaijun
/
voucher
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

timeSliceQueryPush

This commit is contained in:
ziming 2025-06-12 10:31:57 +08:00
parent 4847e4eced
commit 540d873eac
2 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/pkg/script/script.go
View File

@ -25,7 +25,11 @@ func timeSliceQueryPush(startTime, endTime time.Time, duration time.Duration, re
// 每指定间隔时间发送一次请求 // 每指定间隔时间发送一次请求
for t := startTime; t.Before(endTime); t = t.Add(duration) { for t := startTime; t.Before(endTime); t = t.Add(duration) {
end := t.Add(duration) // 计算每次请求的结束时间 end := t.Add(duration) // 计算每次请求的结束时间
if end.After(endTime) {
end = endTime
}
// 创建请求体 // 创建请求体
requestBody := map[string]any{ requestBody := map[string]any{
@ -60,7 +64,11 @@ func pushWechatQuery(startTime, endTime time.Time, duration time.Duration, reque
// 每指定间隔时间发送一次请求 // 每指定间隔时间发送一次请求
for t := startTime; t.Before(endTime); t = t.Add(duration) { for t := startTime; t.Before(endTime); t = t.Add(duration) {
end := t.Add(duration) // 计算每次请求的结束时间 end := t.Add(duration) // 计算每次请求的结束时间
if end.After(endTime) {
end = endTime
}
// 创建请求体 // 创建请求体
requestBody := map[string]any{ requestBody := map[string]any{

2
internal/pkg/script/script_test.go
View File

@ -13,7 +13,7 @@ func Test_script(t *testing.T) {
return return
} }
endTime, err := time.Parse(time.DateTime, "2025-05-01 2:00:03") endTime, err := time.Parse(time.DateTime, "2025-05-01 02:00:03")
if err != nil { if err != nil {
t.Error(err) t.Error(err)
return return