506 lines
15 KiB
Go
506 lines
15 KiB
Go
|
package req
|
|||
|
|
|
|||
|
|
import (
|
|||
|
|
"encoding/json"
|
|||
|
|
"strings"
|
|||
|
|
"time"
|
|||
|
|
)
|
|||
|
|
|
|||
|
|
// 指令参数
|
|||
|
|
// 自动抢红包 101
|
|||
|
|
type AutoRedRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启领取红包机制
|
|||
|
|
Single int32 `example:"1"` // 是否仅抢单个红包（不同时抢多个）
|
|||
|
|
AutoReply int32 `example:"1"` // 是否自动回复感谢
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟回复的时间，单位为秒
|
|||
|
|
ReplyMessages string // 回复内容（多个消息用逗号隔开）
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealAutoRed(model *AutoRedRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
if model.Single != 1 {
|
|||
|
|
model.Single = 0
|
|||
|
|
}
|
|||
|
|
if model.AutoReply != 1 {
|
|||
|
|
model.AutoReply = 0
|
|||
|
|
}
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
_, model.ReplyMessages = StringToSlice(model.ReplyMessages)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 自动接收转账 106
|
|||
|
|
type AutoTransferRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启接收转账功能
|
|||
|
|
AutoReply int32 `example:"1"` // 是否开启自动回复
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟回复的时间，单位为秒
|
|||
|
|
ReplyMessage string // 回复内容（仅一条）
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealTransfer(model *AutoTransferRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
if model.AutoReply != 1 {
|
|||
|
|
model.AutoReply = 0
|
|||
|
|
}
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
model.ReplyMessage = StringTo1000(model.ReplyMessage)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 延迟领取红包 103
|
|||
|
|
type DelayRedRequestModel struct {
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟领取红包的时间，单位为秒
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealDelayRed(model *DelayRedRequestModel) {
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 延迟接收转账 113
|
|||
|
|
type DelayAutoTransferRequestModel struct {
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟接收转账的时间，单位为秒
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealDelayTransfer(model *DelayAutoTransferRequestModel) {
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 关键字包不抢 118
|
|||
|
|
type KeywordAvoidanceRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启关键字包不抢
|
|||
|
|
Keywords string // 设置关键字（多个用逗号隔开）
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealKeywordAvoidance(model *KeywordAvoidanceRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
_, model.Keywords = StringToSlice(model.Keywords)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 自动点赞 401
|
|||
|
|
type AutoLikeRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启自动点赞
|
|||
|
|
StartTime string // 开始时间 // 点赞时间段
|
|||
|
|
EndTime string // 结束时间// 点赞时间段
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟点赞的时间，单位为秒
|
|||
|
|
Mode int32 `example:"1"` // 模式，1-仅点赞分组，0-不点赞分组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealAutoLike(model *AutoLikeRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
if model.Mode != 1 {
|
|||
|
|
model.Mode = 0
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 朋友圈跟随转发 402
|
|||
|
|
type AutoForwardRequestModel struct {
|
|||
|
|
EnableAutoForward int32 `example:"1"` // 是否开启跟随转发
|
|||
|
|
IsBlockAuthor int32 `example:"1"` // 是否屏蔽作者
|
|||
|
|
IsBlockGroup int32 `example:"1"` // 是否屏蔽组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealAutoForward(model *AutoForwardRequestModel) {
|
|||
|
|
if model.EnableAutoForward != 1 {
|
|||
|
|
model.EnableAutoForward = 0
|
|||
|
|
}
|
|||
|
|
if model.IsBlockAuthor != 1 {
|
|||
|
|
model.IsBlockAuthor = 0
|
|||
|
|
}
|
|||
|
|
if model.IsBlockGroup != 1 {
|
|||
|
|
model.IsBlockGroup = 0
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 朋友圈收藏转发 403
|
|||
|
|
type FavoriteForwardRequestModel struct {
|
|||
|
|
EnableFavoriteForward int32 `example:"1"` // 是否开启收藏转发
|
|||
|
|
IsBlockAuthor int32 `example:"1"` // 是否屏蔽作者
|
|||
|
|
IsBlockGroup int32 `example:"1"` // 是否屏蔽组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealFavoriteForward(model *FavoriteForwardRequestModel) {
|
|||
|
|
if model.EnableFavoriteForward != 1 {
|
|||
|
|
model.EnableFavoriteForward = 0
|
|||
|
|
}
|
|||
|
|
if model.IsBlockAuthor != 1 {
|
|||
|
|
model.IsBlockAuthor = 0
|
|||
|
|
}
|
|||
|
|
if model.IsBlockGroup != 1 {
|
|||
|
|
model.IsBlockGroup = 0
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 朋友圈自动评论 404
|
|||
|
|
type AutoCommentRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启自动评论
|
|||
|
|
CommentMessages string // 评论内容（多条用逗号隔开）
|
|||
|
|
StartTime string // 评论时间段，开始时间
|
|||
|
|
EndTime string // 评论时间段，结束时间
|
|||
|
|
TimeInSeconds int32 `example:"0"` // 延迟评论的时间，单位为秒
|
|||
|
|
Mode int32 `example:"1"` // 模式，1-仅评论分组，0-不评论分组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealAutoComment(model *AutoCommentRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
_, model.CommentMessages = StringToSlice(model.CommentMessages)
|
|||
|
|
// TimeInSeconds 0-60
|
|||
|
|
if model.TimeInSeconds < 0 {
|
|||
|
|
model.TimeInSeconds = 0
|
|||
|
|
} else if model.TimeInSeconds > 60 {
|
|||
|
|
model.TimeInSeconds = 60
|
|||
|
|
}
|
|||
|
|
if model.Mode != 1 {
|
|||
|
|
model.Mode = 0
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 定时发朋友圈 405
|
|||
|
|
type MomentsRequestModel struct {
|
|||
|
|
MomentType int32 `example:"1"` // 发圈类型，1-文字，3-图片
|
|||
|
|
MomentContent string // 朋友圈内容
|
|||
|
|
MomentImages string // 朋友圈图片（最多上传9张，图片路径或链接用逗号隔开）
|
|||
|
|
IsBlock int32 `example:"1"` // 发圈时屏蔽组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
ScheduledTime string // 预约发圈时间
|
|||
|
|
Status int32 `example:"0"` // 状态，0-未发布，1-已发布，-1-发布失败
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealMoments(model *MomentsRequestModel) {
|
|||
|
|
// MomentType must be either 1 or 3
|
|||
|
|
if model.MomentType != 3 {
|
|||
|
|
model.MomentType = 1 // Default to 1 if invalid
|
|||
|
|
}
|
|||
|
|
model.MomentContent = StringTo1000(model.MomentContent)
|
|||
|
|
_, model.MomentImages = StringToSlice(model.MomentImages)
|
|||
|
|
if model.IsBlock != 1 {
|
|||
|
|
model.IsBlock = 0
|
|||
|
|
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
// Status can remain as is since it is already initialized
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 发大视频朋友圈 406
|
|||
|
|
type MomentsPostRequestModel struct {
|
|||
|
|
Content string // 朋友圈内容
|
|||
|
|
VideoURL string // 视频，最大500M（最多上传1个）
|
|||
|
|
IsBlock int32 `example:"1"` // 发圈时屏蔽组
|
|||
|
|
Groups string // 设置分组，多个用逗号隔开
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealMomentsPost(model *MomentsPostRequestModel) {
|
|||
|
|
model.Content = StringTo1000(model.Content)
|
|||
|
|
model.VideoURL = StringTo1000(model.VideoURL)
|
|||
|
|
if model.IsBlock != 1 {
|
|||
|
|
model.IsBlock = 0
|
|||
|
|
}
|
|||
|
|
_, model.Groups = StringToSlice(model.Groups)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 欢迎新人入群 502
|
|||
|
|
type WelcomeNewMemberRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启欢迎新人入群
|
|||
|
|
WelcomeMsg string // 欢迎语内容（仅一条）
|
|||
|
|
Mode int32 `example:"1"` // 模式，1-仅欢迎设置群，0-不欢迎设置群
|
|||
|
|
Rooms string // 设置的群
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealWelcomeNewMember(model *WelcomeNewMemberRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
model.WelcomeMsg = StringTo1000(model.WelcomeMsg)
|
|||
|
|
if model.Mode != 1 {
|
|||
|
|
model.Mode = 0
|
|||
|
|
}
|
|||
|
|
_, model.Rooms = StringToSlice(model.Rooms)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 关键词自动踢人 503
|
|||
|
|
type KeywordKickRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启关键词踢人
|
|||
|
|
Keywords string // 触发的关键词（多条用逗号分隔）
|
|||
|
|
IsLinkKick int32 `example:"1"` // 是否踢发链接的人
|
|||
|
|
IsCardKick int32 `example:"1"` // 是否踢发名片的人
|
|||
|
|
IsMiniProgramKick int32 `example:"1"` // 是否踢发小程序的人
|
|||
|
|
IsImageQRCodeKick int32 `example:"1"` // 是否踢发图片二维码的人
|
|||
|
|
Mode int32 `example:"1"` // 模式，1-仅踢设置群，0-不踢设置群
|
|||
|
|
Rooms string // 设置的群
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealKeywordKick(model *KeywordKickRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
_, model.Keywords = StringToSlice(model.Keywords)
|
|||
|
|
if model.IsLinkKick != 1 {
|
|||
|
|
model.IsLinkKick = 0
|
|||
|
|
}
|
|||
|
|
if model.IsCardKick != 1 {
|
|||
|
|
model.IsCardKick = 0
|
|||
|
|
}
|
|||
|
|
if model.IsMiniProgramKick != 1 {
|
|||
|
|
model.IsMiniProgramKick = 0
|
|||
|
|
}
|
|||
|
|
if model.IsImageQRCodeKick != 1 {
|
|||
|
|
model.IsImageQRCodeKick = 0
|
|||
|
|
}
|
|||
|
|
if model.Mode != 1 {
|
|||
|
|
model.Mode = 0
|
|||
|
|
}
|
|||
|
|
_, model.Rooms = StringToSlice(model.Rooms)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 关键词自动回复 504
|
|||
|
|
type ReplyKeywordsItem struct {
|
|||
|
|
Keyword string // 触发的关键词
|
|||
|
|
Content string // 回复的内容
|
|||
|
|
NewMsgId string // 新消息ID 引用了文件助手某条消息时用这个字段
|
|||
|
|
MsgType int32 // 收到消息时的类型：1-文本 3-图片 24-笔记 33-小程序 42-名片 49-链接
|
|||
|
|
SendType int32 // 回复的类型，发送类型 1-文本 3-图片 49-笔记|链接 2002-小程序 42-名片
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
type KeywordAutoReplyRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启关键词自动回复
|
|||
|
|
PrivateReply int32 `example:"1"` // 是否回复私聊
|
|||
|
|
Mode int32 `example:"1"` // 模式，1-仅回复设置群，0-不回复设置群
|
|||
|
|
Rooms string // 设置的群
|
|||
|
|
Keywords []ReplyKeywordsItem // 关键词设置
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealKeywordAutoReply(model *KeywordAutoReplyRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
if model.PrivateReply != 1 {
|
|||
|
|
model.PrivateReply = 0
|
|||
|
|
}
|
|||
|
|
if model.Mode != 1 {
|
|||
|
|
model.Mode = 0
|
|||
|
|
}
|
|||
|
|
_, model.Rooms = StringToSlice(model.Rooms)
|
|||
|
|
|
|||
|
|
for i := range model.Keywords {
|
|||
|
|
model.Keywords[i].Keyword = StringTo1000(model.Keywords[i].Keyword)
|
|||
|
|
model.Keywords[i].Content = StringTo1000(model.Keywords[i].Content)
|
|||
|
|
// MsgType and SendType are assumed to be validated outside this function
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 万群同步 505
|
|||
|
|
type MessageForwardingRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启消息转发
|
|||
|
|
MainRoom string // 设置的主讲群
|
|||
|
|
Lecturers string // 添加的讲师
|
|||
|
|
ForwardRooms string // 设置的转发群
|
|||
|
|
StartTime string // 转发时间段，开始时间
|
|||
|
|
EndTime string // 转发时间段，结束时间
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealMessageForwarding(model *MessageForwardingRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
model.MainRoom = StringTo1000(model.MainRoom)
|
|||
|
|
model.Lecturers = StringTo1000(model.Lecturers)
|
|||
|
|
_, model.ForwardRooms = StringToSlice(model.ForwardRooms)
|
|||
|
|
// StartTime and EndTime are assumed to be valid formats validated outside this function
|
|||
|
|
startTime, endTime := DealTimeRange(model.StartTime, model.EndTime)
|
|||
|
|
model.StartTime = startTime
|
|||
|
|
model.EndTime = endTime
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 自动通过好友 801
|
|||
|
|
type AutoApproveRequestModel struct {
|
|||
|
|
Enable int32 `example:"1"` // 是否开启自动通过验证
|
|||
|
|
AutoReply int32 `example:"1"` // 是否通过验证后自动回复
|
|||
|
|
ReplyMessage string // 回复内容（仅一条）
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
func DealAutoApprove(model *AutoApproveRequestModel) {
|
|||
|
|
if model.Enable != 1 {
|
|||
|
|
model.Enable = 0
|
|||
|
|
}
|
|||
|
|
if model.AutoReply != 1 {
|
|||
|
|
model.AutoReply = 0
|
|||
|
|
}
|
|||
|
|
model.ReplyMessage = StringTo1000(model.ReplyMessage)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 中文逗号转为英文逗号，清理换行符，过滤空字符串，返回字符串数组和字符串表示
|
|||
|
|
func StringToSlice(str string) ([]string, string) {
|
|||
|
|
// 清理换行符（包括 \n 和 \r）
|
|||
|
|
str = strings.ReplaceAll(str, "\r", "")
|
|||
|
|
|
|||
|
|
// 回车符转成分隔付(逗号)
|
|||
|
|
str = strings.ReplaceAll(str, "\n", ",")
|
|||
|
|
|
|||
|
|
// 将中文逗号替换为英文逗号
|
|||
|
|
str = strings.ReplaceAll(str, "，", ",")
|
|||
|
|
|
|||
|
|
// 按英文逗号分割成字符串数组
|
|||
|
|
strArr := strings.Split(str, ",")
|
|||
|
|
var result []string
|
|||
|
|
var finalString string = ""
|
|||
|
|
|
|||
|
|
// 过滤掉空字符串，清理头尾空格
|
|||
|
|
for _, v := range strArr {
|
|||
|
|
v = strings.TrimSpace(v) // 去掉前后空格
|
|||
|
|
if v != "" {
|
|||
|
|
// 判断不能大于 1000 个字符
|
|||
|
|
if len(finalString+","+v) > 1000 {
|
|||
|
|
continue
|
|||
|
|
}
|
|||
|
|
if finalString != "" {
|
|||
|
|
finalString += ","
|
|||
|
|
}
|
|||
|
|
finalString += v
|
|||
|
|
result = append(result, v)
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 将数组转成字符串格式
|
|||
|
|
// finalString := strings.Join(result, ",")
|
|||
|
|
|
|||
|
|
// 返回字符串数组和字符串
|
|||
|
|
return result, finalString
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 判断字符串不能大于 1000 个字符，大于则截取前 1000 个字符
|
|||
|
|
func StringTo1000(str string) string {
|
|||
|
|
str = strings.TrimSpace(str) // 去掉前后空格
|
|||
|
|
// 只取 前 1000 个字符
|
|||
|
|
if len(str) > 1000 {
|
|||
|
|
str = str[:1000]
|
|||
|
|
}
|
|||
|
|
return str
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 处理开始时间和结束时间，如果输入格式不正确，则使用默认值
|
|||
|
|
func DealTimeRange(startTime string, endTime string) (string, string) {
|
|||
|
|
const timeFormat = "15:04"
|
|||
|
|
// 解析 StartTime
|
|||
|
|
start, errStart := time.Parse(timeFormat, startTime)
|
|||
|
|
if errStart != nil {
|
|||
|
|
start = time.Date(0, 1, 1, 0, 0, 0, 0, time.UTC) // 设置为 00:00
|
|||
|
|
startTime = start.Format(timeFormat)
|
|||
|
|
} else {
|
|||
|
|
startTime = start.Format(timeFormat)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 解析 EndTime
|
|||
|
|
end, errEnd := time.Parse(timeFormat, endTime)
|
|||
|
|
if errEnd != nil {
|
|||
|
|
end = time.Date(0, 1, 1, 23, 59, 0, 0, time.UTC) // 设置为 23:59
|
|||
|
|
endTime = end.Format(timeFormat)
|
|||
|
|
} else {
|
|||
|
|
endTime = end.Format(timeFormat)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 如果 EndTime 小于 StartTime，则将 EndTime 设置为 StartTime
|
|||
|
|
if end.Before(start) {
|
|||
|
|
end = start
|
|||
|
|
endTime = end.Format(timeFormat)
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
return startTime, endTime
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// ToJSON 将任意结构体转换为 JSON 字符串
|
|||
|
|
func ToJSONStr(input interface{}) (string, error) {
|
|||
|
|
// 使用 json.Marshal 将对象转换为 JSON 字节数组
|
|||
|
|
bytes, err := json.Marshal(input)
|
|||
|
|
if err != nil {
|
|||
|
|
// 如果转换失败，返回错误提示
|
|||
|
|
return "", err
|
|||
|
|
}
|
|||
|
|
// 将字节数组转换为字符串并返回
|
|||
|
|
return string(bytes), nil
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// FromJSONS 将 JSON 字符串转换为任意结构体
|
|||
|
|
func FromJSONS(input string, output interface{}) error {
|
|||
|
|
if len(input) == 0 {
|
|||
|
|
// 将空字符串替换为一个空 JSON 对象
|
|||
|
|
input = "{}"
|
|||
|
|
}
|
|||
|
|
err := json.Unmarshal([]byte(input), output)
|
|||
|
|
return err
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 定时任务执行函数 true 可以执行，false 不执行
|
|||
|
|
func IsInTimeRange(StartTime string, EndTime string) bool {
|
|||
|
|
// 获取系统当前时间（HH:mm 格式）
|
|||
|
|
now := time.Now()
|
|||
|
|
layout := "15:04"
|
|||
|
|
currentTime, err := time.Parse(layout, now.Format(layout)) // 将当前时间转换为 HH:mm 格式
|
|||
|
|
if err != nil {
|
|||
|
|
// 如果解析失败，执行任务即可
|
|||
|
|
return true
|
|||
|
|
}
|
|||
|
|
// 解析 StartTime 和 EndTime
|
|||
|
|
startTime, err := time.Parse(layout, StartTime)
|
|||
|
|
if err != nil {
|
|||
|
|
// 如果解析失败，执行任务即可
|
|||
|
|
return true
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
endTime, err := time.Parse(layout, EndTime)
|
|||
|
|
|
|||
|
|
if err != nil {
|
|||
|
|
// 如果解析失败，执行任务即可
|
|||
|
|
return true
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// 判断当前时间是否在范围内
|
|||
|
|
if (currentTime.After(startTime) || currentTime.Equal(startTime)) && (currentTime.Before(endTime) || currentTime.Equal(endTime)) {
|
|||
|
|
// 执行任务
|
|||
|
|
return true
|
|||
|
|
} else {
|
|||
|
|
// 不执行
|
|||
|
|
return false
|
|||
|
|
}
|
|||
|
|
}
|