Compare commits
39 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
0452d951a7 | ||
|
|
c0dcffce9d | ||
|
|
b14dbe0d1d | ||
|
|
b024600ef0 | ||
|
|
bc2893fad1 | ||
|
|
a098da39ee | ||
|
|
d8a8bf4efc | ||
|
|
42339e3c51 | ||
|
|
8f6b7cb68d | ||
|
|
20aeeefb3c | ||
|
|
08ffd4de6c | ||
|
|
72a2e694f8 | ||
|
|
2238e23c8d | ||
|
|
a13e39dc0a | ||
|
|
0f506e5afc | ||
|
|
74f19e9d03 | ||
|
|
44c45d11f2 | ||
|
|
50e91680bb | ||
|
|
3554c95edc | ||
|
|
b2598f2406 | ||
|
|
db8c460b42 | ||
|
|
6818b10f4a | ||
|
|
7747a4b634 | ||
|
|
727b06e143 | ||
|
|
2226ec7e63 | ||
|
|
c0c3864a8e | ||
|
|
8c2ab9376c | ||
|
|
b0be537c5d | ||
|
|
9c7e93660d | ||
|
|
9670c0b2fe | ||
|
|
4cc50718e2 | ||
|
|
534f7a0ec8 | ||
|
|
16838ff80f | ||
|
|
ce37a269e1 | ||
|
|
aa78f3940c | ||
|
|
1c55900291 | ||
|
|
386e0dd6d3 | ||
|
|
9bec70319b | ||
|
|
bd33759b80 |
14
app/assistant.go
Normal file
14
app/assistant.go
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
package app
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/gin-gonic/gin"
|
||||||
|
)
|
||||||
|
|
||||||
|
// SaveAssistant
|
||||||
|
// @description: 保存AI助手
|
||||||
|
// @param ctx
|
||||||
|
func SaveAssistant(ctx *gin.Context) {
|
||||||
|
|
||||||
|
//ctx.String(http.StatusOK, "操作成功")
|
||||||
|
ctx.Redirect(302, "/assistant.html")
|
||||||
|
}
|
||||||
@@ -23,6 +23,13 @@ type changeUseAiModelParam struct {
|
|||||||
Model string `json:"model" binding:"required"` // 模型代码
|
Model string `json:"model" binding:"required"` // 模型代码
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// autoClearMembers
|
||||||
|
// @description: 自动清理群成员
|
||||||
|
type autoClearMembers struct {
|
||||||
|
WxId string `json:"wxid" binding:"required"` // 群Id
|
||||||
|
Days int `json:"days"` // 多少天未发言
|
||||||
|
}
|
||||||
|
|
||||||
// ChangeEnableAiStatus
|
// ChangeEnableAiStatus
|
||||||
// @description: 修改是否开启AI
|
// @description: 修改是否开启AI
|
||||||
// @param ctx
|
// @param ctx
|
||||||
@@ -67,6 +74,28 @@ func ChangeUseAiModel(ctx *gin.Context) {
|
|||||||
ctx.String(http.StatusOK, "操作成功")
|
ctx.String(http.StatusOK, "操作成功")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ChangeUseAiAssistant
|
||||||
|
// @description: 修改使用的AI助手
|
||||||
|
// @param ctx
|
||||||
|
func ChangeUseAiAssistant(ctx *gin.Context) {
|
||||||
|
// 此处复用一下结构体
|
||||||
|
var p changeUseAiModelParam
|
||||||
|
if err := ctx.ShouldBind(&p); err != nil {
|
||||||
|
ctx.String(http.StatusBadRequest, "参数错误")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
err := client.MySQL.Model(&entity.Friend{}).
|
||||||
|
Where("wxid = ?", p.WxId).
|
||||||
|
Update("`prompt`", p.Model).Error
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("修改【%s】的AI助手失败:%s", p.WxId, err)
|
||||||
|
ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx.String(http.StatusOK, "操作成功")
|
||||||
|
}
|
||||||
|
|
||||||
// ChangeEnableGroupRankStatus
|
// ChangeEnableGroupRankStatus
|
||||||
// @description: 修改是否开启水群排行榜
|
// @description: 修改是否开启水群排行榜
|
||||||
// @param ctx
|
// @param ctx
|
||||||
@@ -182,3 +211,49 @@ func ChangeSkipGroupRankStatus(ctx *gin.Context) {
|
|||||||
|
|
||||||
ctx.String(http.StatusOK, "操作成功")
|
ctx.String(http.StatusOK, "操作成功")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ChangeEnableNewsStatus
|
||||||
|
// @description: 修改是否开启新闻
|
||||||
|
// @param ctx
|
||||||
|
func ChangeEnableNewsStatus(ctx *gin.Context) {
|
||||||
|
var p changeStatusParam
|
||||||
|
if err := ctx.ShouldBindJSON(&p); err != nil {
|
||||||
|
ctx.String(http.StatusBadRequest, "参数错误")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
log.Printf("待修改的Id:%s", p.WxId)
|
||||||
|
|
||||||
|
err := client.MySQL.Model(&entity.Friend{}).
|
||||||
|
Where("wxid = ?", p.WxId).
|
||||||
|
Update("`enable_news`", gorm.Expr(" !`enable_news`")).Error
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("修改早报启用状态失败:%s", err)
|
||||||
|
ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx.String(http.StatusOK, "操作成功")
|
||||||
|
}
|
||||||
|
|
||||||
|
// AutoClearMembers
|
||||||
|
// @description: 自动清理群成员
|
||||||
|
// @param ctx
|
||||||
|
func AutoClearMembers(ctx *gin.Context) {
|
||||||
|
var p autoClearMembers
|
||||||
|
if err := ctx.ShouldBindJSON(&p); err != nil {
|
||||||
|
ctx.String(http.StatusBadRequest, "参数错误")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
log.Printf("待修改的Id:%s", p.WxId)
|
||||||
|
|
||||||
|
err := client.MySQL.Model(&entity.Friend{}).
|
||||||
|
Where("wxid = ?", p.WxId).
|
||||||
|
Update("`clear_member`", p.Days).Error
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("修改自动清理群成员阈值失败:%s", err)
|
||||||
|
ctx.String(http.StatusInternalServerError, "操作失败: %s", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
ctx.String(http.StatusOK, "操作成功")
|
||||||
|
}
|
||||||
|
|||||||
17
app/pages.go
17
app/pages.go
@@ -66,6 +66,7 @@ func Friend(ctx *gin.Context) {
|
|||||||
result["friends"] = friends
|
result["friends"] = friends
|
||||||
result["vnc"] = config.Conf.Wechat.VncUrl
|
result["vnc"] = config.Conf.Wechat.VncUrl
|
||||||
result["aiModels"] = config.Conf.Ai.Models
|
result["aiModels"] = config.Conf.Ai.Models
|
||||||
|
result["assistant"], _ = service.GetAllAiAssistant()
|
||||||
// 渲染页面
|
// 渲染页面
|
||||||
ctx.HTML(http.StatusOK, "friend.html", result)
|
ctx.HTML(http.StatusOK, "friend.html", result)
|
||||||
}
|
}
|
||||||
@@ -85,11 +86,27 @@ func Group(ctx *gin.Context) {
|
|||||||
result["groups"] = groups
|
result["groups"] = groups
|
||||||
result["vnc"] = config.Conf.Wechat.VncUrl
|
result["vnc"] = config.Conf.Wechat.VncUrl
|
||||||
result["aiModels"] = config.Conf.Ai.Models
|
result["aiModels"] = config.Conf.Ai.Models
|
||||||
|
result["assistant"], _ = service.GetAllAiAssistant()
|
||||||
|
|
||||||
// 渲染页面
|
// 渲染页面
|
||||||
ctx.HTML(http.StatusOK, "group.html", result)
|
ctx.HTML(http.StatusOK, "group.html", result)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Assistant
|
||||||
|
// @description: AI角色
|
||||||
|
// @param ctx
|
||||||
|
func Assistant(ctx *gin.Context) {
|
||||||
|
var result = gin.H{
|
||||||
|
"msg": "success",
|
||||||
|
}
|
||||||
|
|
||||||
|
result["aiModels"] = config.Conf.Ai.Models
|
||||||
|
result["assistant"], _ = service.GetAllAiAssistant()
|
||||||
|
|
||||||
|
// 渲染页面
|
||||||
|
ctx.HTML(http.StatusOK, "assistant.html", result)
|
||||||
|
}
|
||||||
|
|
||||||
// PageNotFound
|
// PageNotFound
|
||||||
// @description: 404页面
|
// @description: 404页面
|
||||||
// @param ctx
|
// @param ctx
|
||||||
|
|||||||
32
config.yaml
32
config.yaml
@@ -1,3 +1,22 @@
|
|||||||
|
system:
|
||||||
|
# 添加新好友或群之后通知给指定的人
|
||||||
|
newFriendNotify:
|
||||||
|
enable: true
|
||||||
|
toUser:
|
||||||
|
- "wxid_xxx"
|
||||||
|
# 默认AI等配置
|
||||||
|
defaultRule:
|
||||||
|
# 默认是否开启AI
|
||||||
|
ai: true
|
||||||
|
# 默认是否开启水群排行榜
|
||||||
|
chatRank: true
|
||||||
|
# 默认是否开启聊天记录总结
|
||||||
|
summary: true
|
||||||
|
# 默认是否开启新成员加群欢迎
|
||||||
|
welcome: true
|
||||||
|
# 每日早报
|
||||||
|
news: true
|
||||||
|
|
||||||
# 微信HOOK配置
|
# 微信HOOK配置
|
||||||
wechat:
|
wechat:
|
||||||
# 微信HOOK接口地址
|
# 微信HOOK接口地址
|
||||||
@@ -24,11 +43,14 @@ mysql:
|
|||||||
|
|
||||||
task:
|
task:
|
||||||
enable: false
|
enable: false
|
||||||
|
news:
|
||||||
|
enable: true
|
||||||
|
cron: '14 11 * * *' # 每天0:30
|
||||||
syncFriends:
|
syncFriends:
|
||||||
enable: false
|
enable: false
|
||||||
cron: '*/5 * * * *' # 五分钟一次
|
cron: '*/5 * * * *' # 五分钟一次
|
||||||
groupSummary:
|
groupSummary:
|
||||||
enable: true
|
enable: false
|
||||||
cron: '30 0 * * *' # 每天0:30
|
cron: '30 0 * * *' # 每天0:30
|
||||||
waterGroup:
|
waterGroup:
|
||||||
enable: false
|
enable: false
|
||||||
@@ -79,6 +101,10 @@ ai:
|
|||||||
model: moonshot-v1-128k
|
model: moonshot-v1-128k
|
||||||
- name: 跃问
|
- name: 跃问
|
||||||
model: StepChat
|
model: StepChat
|
||||||
|
- name: 豆包Lite-4k
|
||||||
|
model: Doubao-lite-4k
|
||||||
|
- name: 豆包Pro-4k
|
||||||
|
model: Doubao-pro-4k
|
||||||
|
|
||||||
# 资源配置
|
# 资源配置
|
||||||
# map[k]v结构,k 会变成全小写,所以这儿不能用大写字母
|
# map[k]v结构,k 会变成全小写,所以这儿不能用大写字母
|
||||||
@@ -87,6 +113,10 @@ resource:
|
|||||||
welcome-new:
|
welcome-new:
|
||||||
type: emotion
|
type: emotion
|
||||||
path: 58e4150be2bba8f7b71974b10391f9e9
|
path: 58e4150be2bba8f7b71974b10391f9e9
|
||||||
|
# 给新好友或者群的自我介绍,不配置就不发送
|
||||||
|
introduce:
|
||||||
|
type: text
|
||||||
|
path: "大家好,我是一个AI机器人,可以直接@我询问你想问的问题。"
|
||||||
# 水群排行榜词云,只能是图片,末尾的`\%s`也是必须的
|
# 水群排行榜词云,只能是图片,末尾的`\%s`也是必须的
|
||||||
wordcloud:
|
wordcloud:
|
||||||
type: image
|
type: image
|
||||||
|
|||||||
@@ -6,6 +6,7 @@ var Conf conf
|
|||||||
// Config
|
// Config
|
||||||
// @description: 配置
|
// @description: 配置
|
||||||
type conf struct {
|
type conf struct {
|
||||||
|
System system `json:"system" yaml:"system"` // 系统配置
|
||||||
Task task `json:"task" yaml:"task"` // 定时任务配置
|
Task task `json:"task" yaml:"task"` // 定时任务配置
|
||||||
MySQL mysql `json:"mysql" yaml:"mysql"` // MySQL 配置
|
MySQL mysql `json:"mysql" yaml:"mysql"` // MySQL 配置
|
||||||
Wechat wechat `json:"wechat" yaml:"wechat"` // 微信助手
|
Wechat wechat `json:"wechat" yaml:"wechat"` // 微信助手
|
||||||
|
|||||||
22
config/system.go
Normal file
22
config/system.go
Normal file
@@ -0,0 +1,22 @@
|
|||||||
|
package config
|
||||||
|
|
||||||
|
// 系统配置
|
||||||
|
type system struct {
|
||||||
|
NewFriendNotify newFriendNotify `json:"newFriendNotify" yaml:"newFriendNotify"` // 新好友通知
|
||||||
|
DefaultRule defaultRule `json:"defaultRule" yaml:"defaultRule"` // 默认规则
|
||||||
|
}
|
||||||
|
|
||||||
|
// 添加新好友或群之后通知给指定的人
|
||||||
|
type newFriendNotify struct {
|
||||||
|
Enable bool `json:"enable" yaml:"enable"` // 是否启用
|
||||||
|
ToUser []string `json:"toUser" yaml:"toUser"` // 通知给谁
|
||||||
|
}
|
||||||
|
|
||||||
|
// 默认规则
|
||||||
|
type defaultRule struct {
|
||||||
|
Ai bool `json:"ai" yaml:"ai"` // 是否启用AI
|
||||||
|
ChatRank bool `json:"chatRank" yaml:"chatRank"` // 是否启用聊天排行榜
|
||||||
|
Summary bool `json:"summary" yaml:"summary"` // 是否启用聊天总结
|
||||||
|
Welcome bool `json:"welcome" yaml:"welcome"` // 是否启用欢迎新成员
|
||||||
|
News bool `json:"news" yaml:"news"` // 是否启用每日早报
|
||||||
|
}
|
||||||
@@ -4,6 +4,7 @@ package config
|
|||||||
// @description: 定时任务
|
// @description: 定时任务
|
||||||
type task struct {
|
type task struct {
|
||||||
Enable bool `json:"enable" yaml:"enable"` // 是否启用
|
Enable bool `json:"enable" yaml:"enable"` // 是否启用
|
||||||
|
News syncFriends `json:"news" yaml:"news"` // 每日早报
|
||||||
SyncFriends syncFriends `json:"syncFriends" yaml:"syncFriends"` // 同步好友
|
SyncFriends syncFriends `json:"syncFriends" yaml:"syncFriends"` // 同步好友
|
||||||
WaterGroup waterGroup `json:"waterGroup" yaml:"waterGroup"` // 水群排行榜
|
WaterGroup waterGroup `json:"waterGroup" yaml:"waterGroup"` // 水群排行榜
|
||||||
GroupSummary syncFriends `json:"groupSummary" yaml:"groupSummary"` // 群聊总结
|
GroupSummary syncFriends `json:"groupSummary" yaml:"groupSummary"` // 群聊总结
|
||||||
|
|||||||
39
entity/aiassistant.go
Normal file
39
entity/aiassistant.go
Normal file
@@ -0,0 +1,39 @@
|
|||||||
|
package entity
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/google/uuid"
|
||||||
|
"go-wechat/common/types"
|
||||||
|
"gorm.io/gorm"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
// AiAssistant
|
||||||
|
// @description: AI助手表
|
||||||
|
type AiAssistant struct {
|
||||||
|
Id string `json:"id" gorm:"type:varchar(32);primarykey"`
|
||||||
|
CreatedAt types.DateTime `json:"createdAt"`
|
||||||
|
Name string `json:"name" gorm:"type:varchar(10);not null;comment:'名称'"`
|
||||||
|
Personality string `json:"personality" gorm:"type:varchar(999);not null;comment:'人设'"`
|
||||||
|
Model string `json:"model" gorm:"type:varchar(50);not null;comment:'使用的模型'"`
|
||||||
|
Enable bool `json:"enable" gorm:"type:tinyint(1);not null;default:1;comment:'是否启用'"`
|
||||||
|
}
|
||||||
|
|
||||||
|
// TableName
|
||||||
|
// @description: 表名
|
||||||
|
// @receiver AiAssistant
|
||||||
|
// @return string
|
||||||
|
func (AiAssistant) TableName() string {
|
||||||
|
return "t_ai_assistant"
|
||||||
|
}
|
||||||
|
|
||||||
|
// BeforeCreate
|
||||||
|
// @description: 创建数据库对象之前生成UUID
|
||||||
|
// @receiver m
|
||||||
|
// @param *gorm.DB
|
||||||
|
// @return err
|
||||||
|
func (m *AiAssistant) BeforeCreate(*gorm.DB) (err error) {
|
||||||
|
if m.Id == "" {
|
||||||
|
m.Id = strings.ReplaceAll(uuid.New().String(), "-", "")
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
@@ -19,6 +19,8 @@ type Friend struct {
|
|||||||
EnableChatRank bool `json:"enableChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否使用聊天排行
|
EnableChatRank bool `json:"enableChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否使用聊天排行
|
||||||
EnableWelcome bool `json:"enableWelcome" gorm:"type:tinyint(1) default 0 not null"` // 是否启用迎新
|
EnableWelcome bool `json:"enableWelcome" gorm:"type:tinyint(1) default 0 not null"` // 是否启用迎新
|
||||||
EnableSummary bool `json:"enableSummary" gorm:"type:tinyint(1) default 0 not null"` // 是否启用总结
|
EnableSummary bool `json:"enableSummary" gorm:"type:tinyint(1) default 0 not null"` // 是否启用总结
|
||||||
|
EnableNews bool `json:"enableNews" gorm:"type:tinyint(1) default 0 not null"` // 是否启用新闻
|
||||||
|
ClearMember int `json:"clearMember"` // 清理成员配置(多少天未活跃的)
|
||||||
IsOk bool `json:"isOk" gorm:"type:tinyint(1) default 0 not null"` // 是否正常
|
IsOk bool `json:"isOk" gorm:"type:tinyint(1) default 0 not null"` // 是否正常
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
2
main.go
2
main.go
@@ -48,6 +48,8 @@ func main() {
|
|||||||
return "群组列表"
|
return "群组列表"
|
||||||
case "index":
|
case "index":
|
||||||
return "首页"
|
return "首页"
|
||||||
|
case "assistant":
|
||||||
|
return "AI角色"
|
||||||
default:
|
default:
|
||||||
return "其他页面"
|
return "其他页面"
|
||||||
}
|
}
|
||||||
|
|||||||
18
model/news.go
Normal file
18
model/news.go
Normal file
@@ -0,0 +1,18 @@
|
|||||||
|
package model
|
||||||
|
|
||||||
|
// MorningPost
|
||||||
|
// @description: 每日早报返回结构体
|
||||||
|
type MorningPost struct {
|
||||||
|
Code int `json:"code"`
|
||||||
|
Msg string `json:"msg"`
|
||||||
|
Data struct {
|
||||||
|
Date string `json:"date"` // 新闻日期
|
||||||
|
News []string `json:"news"` // 新闻标题文字版
|
||||||
|
WeiYu string `json:"weiyu"` // 微语,就是一句屁话
|
||||||
|
Image string `json:"image"` // 早报完整图片
|
||||||
|
HeadImage string `json:"head_image"` // 早报头部图片
|
||||||
|
} `json:"data"`
|
||||||
|
Time int `json:"time"`
|
||||||
|
Usage int `json:"usage"`
|
||||||
|
LogId string `json:"log_id"`
|
||||||
|
}
|
||||||
@@ -54,7 +54,7 @@ func AI(m *plugin.MessageContext) {
|
|||||||
|
|
||||||
// 组装消息体
|
// 组装消息体
|
||||||
messages := make([]openai.ChatCompletionMessage, 0)
|
messages := make([]openai.ChatCompletionMessage, 0)
|
||||||
if config.Conf.Ai.Personality != "" {
|
if prompt != "" {
|
||||||
// 填充人设
|
// 填充人设
|
||||||
messages = append(messages, openai.ChatCompletionMessage{
|
messages = append(messages, openai.ChatCompletionMessage{
|
||||||
Role: openai.ChatMessageRoleSystem,
|
Role: openai.ChatMessageRoleSystem,
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ import (
|
|||||||
"github.com/go-resty/resty/v2"
|
"github.com/go-resty/resty/v2"
|
||||||
"go-wechat/utils"
|
"go-wechat/utils"
|
||||||
"log"
|
"log"
|
||||||
|
"net/http"
|
||||||
)
|
)
|
||||||
|
|
||||||
// KfcCrazyThursdayCmd
|
// KfcCrazyThursdayCmd
|
||||||
@@ -33,8 +34,9 @@ func kfcApi1() string {
|
|||||||
res := resty.New()
|
res := resty.New()
|
||||||
resp, err := res.R().
|
resp, err := res.R().
|
||||||
Post("https://api.jixs.cc/api/wenan-fkxqs/index.php")
|
Post("https://api.jixs.cc/api/wenan-fkxqs/index.php")
|
||||||
if err != nil {
|
if err != nil || resp.StatusCode() != http.StatusOK {
|
||||||
log.Panicf("KFC接口1文案获取失败: %s", err.Error())
|
log.Printf("KFC接口1文案获取失败: %v", err)
|
||||||
|
return ""
|
||||||
}
|
}
|
||||||
log.Printf("KFC接口1文案获取结果: %s", resp.String())
|
log.Printf("KFC接口1文案获取结果: %s", resp.String())
|
||||||
return resp.String()
|
return resp.String()
|
||||||
@@ -58,8 +60,9 @@ func kfcApi2() string {
|
|||||||
resp, err := res.R().
|
resp, err := res.R().
|
||||||
SetResult(&resData).
|
SetResult(&resData).
|
||||||
Post("https://api.jixs.cc/api/wenan-fkxqs/index.php")
|
Post("https://api.jixs.cc/api/wenan-fkxqs/index.php")
|
||||||
if err != nil {
|
if err != nil || resp.StatusCode() != http.StatusOK {
|
||||||
log.Panicf("KFC接口2文案获取失败: %s", err.Error())
|
log.Printf("KFC接口2文案获取失败: %v", err)
|
||||||
|
return ""
|
||||||
}
|
}
|
||||||
log.Printf("KFC接口2文案获取结果: %s", resp.String())
|
log.Printf("KFC接口2文案获取结果: %s", resp.String())
|
||||||
if resData.Data.Msg != "" {
|
if resData.Data.Msg != "" {
|
||||||
@@ -84,8 +87,9 @@ func kfcApi3() string {
|
|||||||
resp, err := res.R().
|
resp, err := res.R().
|
||||||
SetResult(&resData).
|
SetResult(&resData).
|
||||||
Post("https://api.pearktrue.cn/api/kfc")
|
Post("https://api.pearktrue.cn/api/kfc")
|
||||||
if err != nil {
|
if err != nil || resp.StatusCode() != http.StatusOK {
|
||||||
log.Panicf("KFC接口3文案获取失败: %s", err.Error())
|
log.Printf("KFC接口3文案获取失败: %v", err)
|
||||||
|
return ""
|
||||||
}
|
}
|
||||||
log.Printf("KFC接口3文案获取结果: %s", resp.String())
|
log.Printf("KFC接口3文案获取结果: %s", resp.String())
|
||||||
if resData.Text != "" {
|
if resData.Text != "" {
|
||||||
|
|||||||
@@ -14,9 +14,10 @@ func Init(g *gin.Engine) {
|
|||||||
ctx.Redirect(302, "/index.html")
|
ctx.Redirect(302, "/index.html")
|
||||||
})
|
})
|
||||||
|
|
||||||
g.GET("/index.html", app.Index) // 首页
|
g.GET("/index.html", app.Index) // 首页
|
||||||
g.GET("/friend.html", app.Friend) // 好友列表
|
g.GET("/friend.html", app.Friend) // 好友列表
|
||||||
g.GET("/group.html", app.Group) // 群组列表
|
g.GET("/group.html", app.Group) // 群组列表
|
||||||
|
g.GET("/assistant.html", app.Assistant) // AI角色
|
||||||
|
|
||||||
g.GET("/404.html", app.PageNotFound) // 群组列表
|
g.GET("/404.html", app.PageNotFound) // 群组列表
|
||||||
|
|
||||||
@@ -24,10 +25,15 @@ func Init(g *gin.Engine) {
|
|||||||
api := g.Group("/api")
|
api := g.Group("/api")
|
||||||
api.PUT("/ai/status", app.ChangeEnableAiStatus) // 修改是否开启AI状态
|
api.PUT("/ai/status", app.ChangeEnableAiStatus) // 修改是否开启AI状态
|
||||||
api.POST("/ai/model", app.ChangeUseAiModel) // 修改使用的AI模型
|
api.POST("/ai/model", app.ChangeUseAiModel) // 修改使用的AI模型
|
||||||
|
api.POST("/ai/assistant", app.ChangeUseAiAssistant) // 修改使用的AI助手
|
||||||
api.PUT("/welcome/status", app.ChangeEnableWelcomeStatus) // 修改是否开启迎新状态
|
api.PUT("/welcome/status", app.ChangeEnableWelcomeStatus) // 修改是否开启迎新状态
|
||||||
api.PUT("/command/status", app.ChangeEnableCommandStatus) // 修改是否开启指令状态
|
api.PUT("/command/status", app.ChangeEnableCommandStatus) // 修改是否开启指令状态
|
||||||
|
api.PUT("/news/status", app.ChangeEnableNewsStatus) // 修改是否开启早报状态
|
||||||
api.PUT("/grouprank/status", app.ChangeEnableGroupRankStatus) // 修改是否开启水群排行榜状态
|
api.PUT("/grouprank/status", app.ChangeEnableGroupRankStatus) // 修改是否开启水群排行榜状态
|
||||||
api.PUT("/grouprank/skip", app.ChangeSkipGroupRankStatus) // 修改是否跳过水群排行榜状态
|
api.PUT("/grouprank/skip", app.ChangeSkipGroupRankStatus) // 修改是否跳过水群排行榜状态
|
||||||
api.GET("/group/users", app.GetGroupUsers) // 获取群成员列表
|
api.GET("/group/users", app.GetGroupUsers) // 获取群成员列表
|
||||||
api.PUT("/summary/status", app.ChangeEnableSummaryStatus) // 修改是否开启群聊总结状态
|
api.PUT("/summary/status", app.ChangeEnableSummaryStatus) // 修改是否开启群聊总结状态
|
||||||
|
api.PUT("/clearmembers", app.AutoClearMembers) // 自动清理群成员
|
||||||
|
|
||||||
|
api.POST("/assistant", app.SaveAssistant) // 保存AI助手
|
||||||
}
|
}
|
||||||
|
|||||||
14
service/aiassistant.go
Normal file
14
service/aiassistant.go
Normal file
@@ -0,0 +1,14 @@
|
|||||||
|
package service
|
||||||
|
|
||||||
|
import (
|
||||||
|
"go-wechat/client"
|
||||||
|
"go-wechat/entity"
|
||||||
|
)
|
||||||
|
|
||||||
|
// GetAllAiAssistant
|
||||||
|
// @description: 取出所有AI助手
|
||||||
|
// @return records
|
||||||
|
func GetAllAiAssistant() (records []entity.AiAssistant, err error) {
|
||||||
|
err = client.MySQL.Order("created_at DESC").Find(&records).Error
|
||||||
|
return
|
||||||
|
}
|
||||||
@@ -49,7 +49,10 @@ func GetAllEnableAI() (records []entity.Friend, err error) {
|
|||||||
// @return records
|
// @return records
|
||||||
// @return err
|
// @return err
|
||||||
func GetAllEnableChatRank() (records []entity.Friend, err error) {
|
func GetAllEnableChatRank() (records []entity.Friend, err error) {
|
||||||
err = client.MySQL.Where("enable_chat_rank = ?", 1).Where("wxid LIKE '%@chatroom'").Find(&records).Error
|
err = client.MySQL.Where("enable_chat_rank = ?", 1).
|
||||||
|
Where("is_ok IS TRUE").
|
||||||
|
Where("wxid LIKE '%@chatroom'").
|
||||||
|
Find(&records).Error
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -58,7 +61,28 @@ func GetAllEnableChatRank() (records []entity.Friend, err error) {
|
|||||||
// @return records
|
// @return records
|
||||||
// @return err
|
// @return err
|
||||||
func GetAllEnableSummary() (records []entity.Friend, err error) {
|
func GetAllEnableSummary() (records []entity.Friend, err error) {
|
||||||
err = client.MySQL.Where("enable_summary = ?", 1).Where("wxid LIKE '%@chatroom'").Find(&records).Error
|
err = client.MySQL.Where("enable_summary = ?", 1).
|
||||||
|
Where("is_ok IS TRUE").
|
||||||
|
Where("wxid LIKE '%@chatroom'").
|
||||||
|
Find(&records).Error
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetAllEnableNews
|
||||||
|
// @description: 取出所有启用了新闻的好友或群组
|
||||||
|
// @return records
|
||||||
|
// @return err
|
||||||
|
func GetAllEnableNews() (records []entity.Friend, err error) {
|
||||||
|
err = client.MySQL.Where("enable_news = ?", 1).Where("is_ok IS TRUE").Find(&records).Error
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// GetAllEnableClearGroup
|
||||||
|
// @description: 获取所有需要清理成员的群组
|
||||||
|
// @return records
|
||||||
|
// @return err
|
||||||
|
func GetAllEnableClearGroup() (records []entity.Friend, err error) {
|
||||||
|
err = client.MySQL.Where("clear_member > 0").Where("is_ok IS TRUE").Find(&records).Error
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -73,6 +73,8 @@ func GetTextMessagesById(id string) (records []vo.TextMessageItem, err error) {
|
|||||||
Where("tm.`from_user` = ?", id).
|
Where("tm.`from_user` = ?", id).
|
||||||
Where(`(tm.type = 1 OR ( tm.type = 49 AND EXTRACTVALUE ( tm.content, "/msg/appmsg/type" ) IN (?) ))`, appMsgList).
|
Where(`(tm.type = 1 OR ( tm.type = 49 AND EXTRACTVALUE ( tm.content, "/msg/appmsg/type" ) IN (?) ))`, appMsgList).
|
||||||
Where("DATE ( tm.create_at ) = DATE ( CURDATE() - INTERVAL 1 DAY )").
|
Where("DATE ( tm.create_at ) = DATE ( CURDATE() - INTERVAL 1 DAY )").
|
||||||
|
Where("tm.content NOT LIKE '#昨日水群排行榜%'").
|
||||||
|
Where("tm.content NOT LIKE '#昨日消息总结%'").
|
||||||
Order("tm.create_at ASC")
|
Order("tm.create_at ASC")
|
||||||
|
|
||||||
err = tx.Find(&records).Error
|
err = tx.Find(&records).Error
|
||||||
|
|||||||
68
tasks/cleargroupuser/cleargroupuser.go
Normal file
68
tasks/cleargroupuser/cleargroupuser.go
Normal file
@@ -0,0 +1,68 @@
|
|||||||
|
package cleargroupuser
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"go-wechat/client"
|
||||||
|
"go-wechat/entity"
|
||||||
|
"go-wechat/service"
|
||||||
|
"go-wechat/utils"
|
||||||
|
"log"
|
||||||
|
"strings"
|
||||||
|
)
|
||||||
|
|
||||||
|
// ClearGroupUser
|
||||||
|
// @description: 清理群成员
|
||||||
|
func ClearGroupUser() {
|
||||||
|
groups, err := service.GetAllEnableClearGroup()
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("获取启用了聊天排行榜的群组失败, 错误信息: %v", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, group := range groups {
|
||||||
|
// 获取需要清理的群成员Id
|
||||||
|
members := getNeedDeleteMembers(group.Wxid, group.ClearMember)
|
||||||
|
memberCount := len(members)
|
||||||
|
log.Printf("群[%s(%s)]需要清理的成员数量: %d", group.Nickname, group.Wxid, memberCount)
|
||||||
|
if memberCount < 1 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
var memberMap = make(map[string]string)
|
||||||
|
var deleteIds = make([]string, 0)
|
||||||
|
for _, member := range members {
|
||||||
|
deleteIds = append(deleteIds, member.Wxid)
|
||||||
|
// 昵称为空,取id后4位
|
||||||
|
if member.Nickname == "" {
|
||||||
|
member.Nickname = "无名氏_" + member.Wxid[len(member.Wxid)-4:]
|
||||||
|
}
|
||||||
|
memberMap[member.Nickname] = member.LastActive.Format("2006-01-02 15:04:05")
|
||||||
|
}
|
||||||
|
// 调用接口
|
||||||
|
utils.DeleteGroupMember(group.Wxid, strings.Join(deleteIds, ","), 0)
|
||||||
|
// 发送通知到群里
|
||||||
|
ms := make([]string, 0)
|
||||||
|
for k, v := range memberMap {
|
||||||
|
ms = append(ms, fmt.Sprintf("昵称:%s\n最后活跃时间:%s", k, v))
|
||||||
|
}
|
||||||
|
msg := fmt.Sprintf("#清理群成员\n\n很遗憾地通知各位,就在刚刚,有%d名群友因活跃度不够暂时离开了我们,希望还健在的群友引以为戒、保持活跃!\n\n详细信息: \n%s",
|
||||||
|
memberCount, strings.Join(ms, "\n"))
|
||||||
|
utils.SendMessage(group.Wxid, "", msg, 0)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
// getNeedDeleteMembers
|
||||||
|
// @description: 获取需要删除的群成员
|
||||||
|
// @param groupId 群Id
|
||||||
|
// @param days 需要清理的未活跃的天数
|
||||||
|
// @return members
|
||||||
|
func getNeedDeleteMembers(groupId string, days int) (members []entity.GroupUser) {
|
||||||
|
err := client.MySQL.Model(&entity.GroupUser{}).Where("group_id = ?", groupId).
|
||||||
|
Where("is_member IS TRUE").
|
||||||
|
Where("DATEDIFF( NOW(), last_active ) >= ?", days).
|
||||||
|
Order("last_active DESC").
|
||||||
|
Find(&members).Error
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("获取需要清理的群成员失败, 错误信息: %v", err)
|
||||||
|
}
|
||||||
|
return
|
||||||
|
}
|
||||||
@@ -41,6 +41,9 @@ func Sync() {
|
|||||||
|
|
||||||
nowIds := []string{}
|
nowIds := []string{}
|
||||||
|
|
||||||
|
// 新增的成员,用于通知给指定的人
|
||||||
|
var newItmes = make(map[string]string)
|
||||||
|
|
||||||
for _, friend := range base.Data {
|
for _, friend := range base.Data {
|
||||||
if strings.Contains(friend.Wxid, "gh_") || strings.Contains(friend.Wxid, "@openim") {
|
if strings.Contains(friend.Wxid, "gh_") || strings.Contains(friend.Wxid, "@openim") {
|
||||||
continue
|
continue
|
||||||
@@ -61,26 +64,46 @@ func Sync() {
|
|||||||
if count == 0 {
|
if count == 0 {
|
||||||
// 新增
|
// 新增
|
||||||
err = tx.Create(&entity.Friend{
|
err = tx.Create(&entity.Friend{
|
||||||
CustomAccount: friend.CustomAccount,
|
CustomAccount: friend.CustomAccount,
|
||||||
Nickname: friend.Nickname,
|
Nickname: friend.Nickname,
|
||||||
Pinyin: friend.Pinyin,
|
Pinyin: friend.Pinyin,
|
||||||
PinyinAll: friend.PinyinAll,
|
PinyinAll: friend.PinyinAll,
|
||||||
Wxid: friend.Wxid,
|
Wxid: friend.Wxid,
|
||||||
IsOk: true,
|
IsOk: true,
|
||||||
LastActive: time.Now().Local(),
|
EnableAi: config.Conf.System.DefaultRule.Ai,
|
||||||
|
EnableChatRank: config.Conf.System.DefaultRule.ChatRank,
|
||||||
|
EnableSummary: config.Conf.System.DefaultRule.Summary,
|
||||||
|
EnableWelcome: config.Conf.System.DefaultRule.Welcome,
|
||||||
|
EnableNews: config.Conf.System.DefaultRule.News,
|
||||||
|
ClearMember: 0,
|
||||||
|
LastActive: time.Now().Local(),
|
||||||
}).Error
|
}).Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Printf("新增好友失败: %s", err.Error())
|
log.Printf("新增好友失败: %s", err.Error())
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
// 发送一条新消息
|
newItmes[friend.Wxid] = friend.Nickname
|
||||||
utils.SendMessage(friend.Wxid, "", "大家好,我是一个AI机器人,可以直接@我询问你想问的问题。该功能默认未启用,请群主艾特我并发送 /ai enable 指令启用", 0)
|
if conf, ok := config.Conf.Resource["introduce"]; ok {
|
||||||
|
// 发送一条新消息
|
||||||
|
switch conf.Type {
|
||||||
|
case "text":
|
||||||
|
// 文字类型
|
||||||
|
utils.SendMessage(friend.Wxid, "", conf.Path, 0)
|
||||||
|
case "image":
|
||||||
|
// 图片类型
|
||||||
|
utils.SendImage(friend.Wxid, conf.Path, 0)
|
||||||
|
case "emotion":
|
||||||
|
// 表情类型
|
||||||
|
utils.SendEmotion(friend.Wxid, conf.Path, 0)
|
||||||
|
}
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
pm := map[string]any{
|
pm := map[string]any{
|
||||||
"nickname": friend.Nickname,
|
"nickname": friend.Nickname,
|
||||||
"custom_account": friend.CustomAccount,
|
"custom_account": friend.CustomAccount,
|
||||||
"pinyin": friend.Pinyin,
|
"pinyin": friend.Pinyin,
|
||||||
"pinyin_all": friend.PinyinAll,
|
"pinyin_all": friend.PinyinAll,
|
||||||
|
"is_ok": true,
|
||||||
}
|
}
|
||||||
err = tx.Model(&entity.Friend{}).Where("wxid = ?", friend.Wxid).Updates(pm).Error
|
err = tx.Model(&entity.Friend{}).Where("wxid = ?", friend.Wxid).Updates(pm).Error
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -95,8 +118,35 @@ func Sync() {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 通知有新成员
|
||||||
|
if len(newItmes) > 0 && config.Conf.System.NewFriendNotify.Enable {
|
||||||
|
// 组装成一句话
|
||||||
|
msg := []string{"#新好友通知\n"}
|
||||||
|
for wxId, nickname := range newItmes {
|
||||||
|
msg = append(msg, "微信Id: "+wxId+"\n昵称: "+nickname)
|
||||||
|
}
|
||||||
|
for _, user := range config.Conf.System.NewFriendNotify.ToUser {
|
||||||
|
if user != "" {
|
||||||
|
// 发送一条新消息
|
||||||
|
utils.SendMessage(user, "", strings.Join(msg, "\n-------\n"), 0)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// 清理不在列表中的好友
|
// 清理不在列表中的好友
|
||||||
err = tx.Model(&entity.Friend{}).Where("wxid NOT IN (?)", nowIds).Update("is_ok", false).Error
|
clearPm := map[string]any{
|
||||||
|
"is_ok": false,
|
||||||
|
"enable_chat_rank": false,
|
||||||
|
"enable_welcome": false,
|
||||||
|
"enable_summary": false,
|
||||||
|
"enable_news": false,
|
||||||
|
"clear_member": false,
|
||||||
|
"enable_ai": false,
|
||||||
|
}
|
||||||
|
err = tx.Model(&entity.Friend{}).Where("wxid NOT IN (?)", nowIds).Updates(clearPm).Error
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("清理好友失败: %s", err.Error())
|
||||||
|
}
|
||||||
|
|
||||||
log.Println("同步好友列表完成")
|
log.Println("同步好友列表完成")
|
||||||
}
|
}
|
||||||
|
|||||||
36
tasks/news/news.go
Normal file
36
tasks/news/news.go
Normal file
@@ -0,0 +1,36 @@
|
|||||||
|
package news
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"go-wechat/service"
|
||||||
|
"go-wechat/utils"
|
||||||
|
"log"
|
||||||
|
"strings"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
// DailyNews
|
||||||
|
// @description: 每日新闻
|
||||||
|
func DailyNews() {
|
||||||
|
groups, err := service.GetAllEnableNews()
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("获取启用了聊天排行榜的群组失败, 错误信息: %v", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
news := utils.NewsUtil().MorningPost()
|
||||||
|
if len(news) == 0 {
|
||||||
|
log.Println("每日早报获取失败")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
newsStr := fmt.Sprintf("#每日早报\n\n又是新的一天了,让我们康康一觉醒来世界又发生了哪些变化~\n\n%s", strings.Join(news, "\n"))
|
||||||
|
|
||||||
|
// 循环发送新闻
|
||||||
|
for _, group := range groups {
|
||||||
|
// 发送消息
|
||||||
|
utils.SendMessage(group.Wxid, "", newsStr, 0)
|
||||||
|
// 休眠一秒,防止频繁发送
|
||||||
|
time.Sleep(time.Second)
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -42,11 +42,12 @@ func AiSummary() {
|
|||||||
注意,他们可能是多个话题,请仔细甄别。
|
注意,他们可能是多个话题,请仔细甄别。
|
||||||
每一行代表一个人的发言,每一行的的格式为: {"{nickname}": "{content}"}--end--
|
每一行代表一个人的发言,每一行的的格式为: {"{nickname}": "{content}"}--end--
|
||||||
|
|
||||||
|
群名称: %s
|
||||||
聊天记录如下:
|
聊天记录如下:
|
||||||
%s
|
%s
|
||||||
`
|
`
|
||||||
|
|
||||||
msg := fmt.Sprintf(msgTmp, strings.Join(content, "\n"))
|
msg := fmt.Sprintf(msgTmp, group.Nickname, strings.Join(content, "\n"))
|
||||||
|
|
||||||
// AI总结
|
// AI总结
|
||||||
messages := []openai.ChatCompletionMessage{
|
messages := []openai.ChatCompletionMessage{
|
||||||
|
|||||||
@@ -3,7 +3,9 @@ package tasks
|
|||||||
import (
|
import (
|
||||||
"github.com/go-co-op/gocron"
|
"github.com/go-co-op/gocron"
|
||||||
"go-wechat/config"
|
"go-wechat/config"
|
||||||
|
"go-wechat/tasks/cleargroupuser"
|
||||||
"go-wechat/tasks/friends"
|
"go-wechat/tasks/friends"
|
||||||
|
"go-wechat/tasks/news"
|
||||||
"go-wechat/tasks/summary"
|
"go-wechat/tasks/summary"
|
||||||
"go-wechat/tasks/watergroup"
|
"go-wechat/tasks/watergroup"
|
||||||
"log"
|
"log"
|
||||||
@@ -42,7 +44,6 @@ func InitTasks() {
|
|||||||
if config.Conf.Task.GroupSummary.Enable {
|
if config.Conf.Task.GroupSummary.Enable {
|
||||||
log.Printf("群聊总结任务已启用,执行表达式: %s", config.Conf.Task.GroupSummary.Cron)
|
log.Printf("群聊总结任务已启用,执行表达式: %s", config.Conf.Task.GroupSummary.Cron)
|
||||||
_, _ = s.Cron(config.Conf.Task.GroupSummary.Cron).Do(summary.AiSummary)
|
_, _ = s.Cron(config.Conf.Task.GroupSummary.Cron).Do(summary.AiSummary)
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 更新好友列表
|
// 更新好友列表
|
||||||
@@ -51,6 +52,14 @@ func InitTasks() {
|
|||||||
_, _ = s.Cron(config.Conf.Task.SyncFriends.Cron).Do(friends.Sync)
|
_, _ = s.Cron(config.Conf.Task.SyncFriends.Cron).Do(friends.Sync)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 每日早报
|
||||||
|
if config.Conf.Task.News.Enable {
|
||||||
|
_, _ = s.Cron(config.Conf.Task.News.Cron).Do(news.DailyNews)
|
||||||
|
}
|
||||||
|
|
||||||
|
// 每天0点检查一次处理清理群成员
|
||||||
|
_, _ = s.Cron("0 0 * * *").Do(cleargroupuser.ClearGroupUser)
|
||||||
|
|
||||||
// 开启定时任务
|
// 开启定时任务
|
||||||
s.StartAsync()
|
s.StartAsync()
|
||||||
log.Println("定时任务初始化成功")
|
log.Println("定时任务初始化成功")
|
||||||
|
|||||||
@@ -32,7 +32,7 @@ func getRankData(groupId, date string) (rank []rankUser, err error) {
|
|||||||
case "week":
|
case "week":
|
||||||
tx.Where("YEARWEEK(date_format(tm.create_at, '%Y-%m-%d')) = YEARWEEK(now()) - 1")
|
tx.Where("YEARWEEK(date_format(tm.create_at, '%Y-%m-%d')) = YEARWEEK(now()) - 1")
|
||||||
case "month":
|
case "month":
|
||||||
tx.Where("PERIOD_DIFF(date_format(now(), '%Y%m'), date_format(create_at, '%Y%m')) = 1")
|
tx.Where("PERIOD_DIFF(date_format(now(), '%Y%m'), date_format(tm.create_at, '%Y%m')) = 1")
|
||||||
case "year":
|
case "year":
|
||||||
tx.Where("YEAR(tm.create_at) = YEAR(NOW()) - 1")
|
tx.Where("YEAR(tm.create_at) = YEAR(NOW()) - 1")
|
||||||
}
|
}
|
||||||
|
|||||||
46
utils/news.go
Normal file
46
utils/news.go
Normal file
@@ -0,0 +1,46 @@
|
|||||||
|
package utils
|
||||||
|
|
||||||
|
import (
|
||||||
|
"github.com/go-resty/resty/v2"
|
||||||
|
"go-wechat/model"
|
||||||
|
"log"
|
||||||
|
)
|
||||||
|
|
||||||
|
// News
|
||||||
|
// @description: 新闻
|
||||||
|
type News interface {
|
||||||
|
MorningPost() []string // 早报
|
||||||
|
}
|
||||||
|
|
||||||
|
type news struct{}
|
||||||
|
|
||||||
|
// NewsUtil
|
||||||
|
// @description: 新闻工具
|
||||||
|
// @param account
|
||||||
|
// @param password
|
||||||
|
// @return LeiGod
|
||||||
|
func NewsUtil() News {
|
||||||
|
return &news{}
|
||||||
|
}
|
||||||
|
|
||||||
|
// MorningPost
|
||||||
|
// @description: 早报
|
||||||
|
// @receiver news
|
||||||
|
// @return records
|
||||||
|
func (news) MorningPost() (records []string) {
|
||||||
|
var newsResp model.MorningPost
|
||||||
|
|
||||||
|
res := resty.New()
|
||||||
|
resp, err := res.R().
|
||||||
|
SetHeader("Content-Type", "application/json;chartset=utf-8").
|
||||||
|
SetQueryParam("token", "cFoMZNNBxT4jQovS").
|
||||||
|
SetResult(&newsResp).
|
||||||
|
Post("https://v2.alapi.cn/api/zaobao")
|
||||||
|
if err != nil {
|
||||||
|
log.Panicf("每日早报获取失败: %s", err.Error())
|
||||||
|
}
|
||||||
|
log.Printf("每日早报获取结果: %s", unicodeToText(resp.String()))
|
||||||
|
|
||||||
|
records = newsResp.Data.News
|
||||||
|
return
|
||||||
|
}
|
||||||
@@ -121,3 +121,36 @@ func SendEmotion(toId, emotionHash string, retryCount int) {
|
|||||||
}
|
}
|
||||||
log.Printf("发送表情包消息结果: %s", resp.String())
|
log.Printf("发送表情包消息结果: %s", resp.String())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// DeleteGroupMember
|
||||||
|
// @description: 删除群成员
|
||||||
|
// @param chatRoomId 群Id
|
||||||
|
// @param memberIds 成员id,用','分隔
|
||||||
|
func DeleteGroupMember(chatRoomId, memberIds string, retryCount int) {
|
||||||
|
if retryCount > 5 {
|
||||||
|
log.Printf("重试五次失败,停止发送")
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
|
// 组装参数
|
||||||
|
param := map[string]any{
|
||||||
|
"chatRoomId": chatRoomId, // 群Id
|
||||||
|
"memberIds": memberIds, // 成员id
|
||||||
|
}
|
||||||
|
pbs, _ := json.Marshal(param)
|
||||||
|
|
||||||
|
res := resty.New()
|
||||||
|
resp, err := res.R().
|
||||||
|
SetHeader("Content-Type", "application/json;chartset=utf-8").
|
||||||
|
SetBody(string(pbs)).
|
||||||
|
Post(config.Conf.Wechat.GetURL("/api/delMemberFromChatRoom"))
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("删除群成员失败: %s", err.Error())
|
||||||
|
// 休眠五秒后重新发送
|
||||||
|
time.Sleep(5 * time.Second)
|
||||||
|
DeleteGroupMember(chatRoomId, memberIds, retryCount+1)
|
||||||
|
}
|
||||||
|
log.Printf("删除群成员结果: %s", resp.String())
|
||||||
|
// 这个逼接口要调用两次,第一次调用成功,第二次调用才会真正删除
|
||||||
|
DeleteGroupMember(chatRoomId, memberIds, 5)
|
||||||
|
}
|
||||||
|
|||||||
89
views/assistant.html
Normal file
89
views/assistant.html
Normal file
@@ -0,0 +1,89 @@
|
|||||||
|
<!DOCTYPE html>
|
||||||
|
<html lang="en" class="h-full bg-gray-100">
|
||||||
|
|
||||||
|
<head>
|
||||||
|
<meta charset="UTF-8">
|
||||||
|
<title>水群助手</title>
|
||||||
|
|
||||||
|
<link href="assets/css/daisyui-4.4.14-full.min.css" rel="stylesheet" type="text/css"/>
|
||||||
|
<link href="assets/css/index.css" rel="stylesheet" type="text/css"/>
|
||||||
|
|
||||||
|
<script src="https://cdn.tailwindcss.com?plugins=forms,typography,aspect-ratio,line-clamp"></script>
|
||||||
|
<script src="https://cdn.bootcdn.net/ajax/libs/axios/1.5.0/axios.min.js"></script>
|
||||||
|
|
||||||
|
<script src="assets/js/index.js"></script>
|
||||||
|
</head>
|
||||||
|
|
||||||
|
<body class="h-full">
|
||||||
|
<div class="min-h-full">
|
||||||
|
{{ template "head.html" "assistant" }}
|
||||||
|
|
||||||
|
<main class="-mt-32">
|
||||||
|
<div class="mx-auto max-w-7xl px-4 pb-12 sm:px-6 lg:px-8">
|
||||||
|
<div class="rounded-lg bg-white px-5 py-6 shadow sm:px-6 text-2xl">
|
||||||
|
<ul role="list" class="grid grid-cols-1 gap-x-6 gap-y-8 lg:grid-cols-2 xl:gap-x-8">
|
||||||
|
{{ range .assistant }}
|
||||||
|
<li class="overflow-hidden rounded-xl border border-gray-200">
|
||||||
|
<!-- 头 -->
|
||||||
|
<!-- <div class="flex items -center gap-x-4 border-b border-gray-900/5 bg-gray-50 p-6">-->
|
||||||
|
<!-- <div class="text-sm flex-1">-->
|
||||||
|
<!-- <div class="font-medium leading-6 text-gray-900">{{ .Name }}</div>-->
|
||||||
|
<!-- <div class="font-medium text-gray-500">{{ .CreatedAt }}</div>-->
|
||||||
|
<!-- </div>-->
|
||||||
|
<!-- </div>-->
|
||||||
|
|
||||||
|
<!-- body -->
|
||||||
|
<form action="/api/assistant" method="post">
|
||||||
|
<div class="-my-3 divide-y divide-gray-100 px-6 py-4 text-sm leading-6">
|
||||||
|
<div class="border-b border-gray-900/10 pb-12">
|
||||||
|
<div class="mt-10 grid grid-cols-1 gap-x-6 gap-y-8 sm:grid-cols-6">
|
||||||
|
<div class="sm:col-span-4">
|
||||||
|
<label for="name-{{.Id}}" class="block text-sm font-medium leading-6 text-gray-900">角色名称</label>
|
||||||
|
<div class="mt-2">
|
||||||
|
<div class="flex rounded-md shadow-sm ring-1 ring-inset ring-gray-300 focus-within:ring-2 focus-within:ring-inset focus-within:ring-indigo-600 sm:max-w-md">
|
||||||
|
<input type="text" value="{{.Name}}" name="name" id="name-{{.Id}}" class="block flex-1 border-0 bg-transparent py-1.5 pl-1 text-gray-900 placeholder:text-gray-400 focus:ring-0 sm:text-sm sm:leading-6" placeholder="请输入角色名称">
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="col-span-full">
|
||||||
|
<label for="about-{{.Id}}" class="block text-sm font-medium leading-6 text-gray-900">Prompt</label>
|
||||||
|
<div class="mt-2">
|
||||||
|
<textarea id="about-{{.Id}}" name="about" rows="4" class="block w-full rounded-md border-0 py-1.5 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-indigo-600 sm:text-sm sm:leading-6" placeholder="请输入角色Prompt">{{.Personality}}</textarea>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="col-span-full">
|
||||||
|
<label for="model-{{.Id}}" class="block text-sm font-medium leading-6 text-gray-900">AI模型</label>
|
||||||
|
<div class="mt-2">
|
||||||
|
<select id="model-{{.Id}}" class="block w-full rounded-md border-0 py-1.5 pl-3 pr-10 text-gray-900 ring-1 ring-inset ring-gray-300 focus:ring-2 focus:ring-green-600 sm:text-sm sm:leading-6">
|
||||||
|
{{$useModel := .Model}}
|
||||||
|
{{ range $.aiModels }}
|
||||||
|
<option value="{{.Model}}" {{ if eq $useModel .Model}}selected{{ end }}>
|
||||||
|
{{.Name}}
|
||||||
|
</option>
|
||||||
|
{{ end }}
|
||||||
|
</select>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
|
||||||
|
<div class="mt-6 flex items-center justify-end gap-x-6">
|
||||||
|
<button type="submit" class="rounded-md bg-indigo-600 px-3 py-2 text-sm font-semibold text-white shadow-sm hover:bg-indigo-500 focus-visible:outline focus-visible:outline-2 focus-visible:outline-offset-2 focus-visible:outline-indigo-600">Save</button>
|
||||||
|
</div>
|
||||||
|
</form>
|
||||||
|
</li>
|
||||||
|
{{ end }}
|
||||||
|
</ul>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</main>
|
||||||
|
|
||||||
|
{{ template "footer.html" }}
|
||||||
|
|
||||||
|
{{ template "groupuser.html" }}
|
||||||
|
</div>
|
||||||
|
|
||||||
|
</body>
|
||||||
@@ -136,3 +136,70 @@
|
|||||||
</span>
|
</span>
|
||||||
</button>
|
</button>
|
||||||
{{end}}
|
{{end}}
|
||||||
|
|
||||||
|
|
||||||
|
<!-- 水群排行榜 -->
|
||||||
|
{{define "groupRank"}}
|
||||||
|
<button type="button"
|
||||||
|
class="{{ if eq .EnableWelcome true }}bg-green-600{{ else }}bg-gray-200{{ end }} relative inline-flex h-6 w-11 flex-shrink-0 cursor-pointer rounded-full border-2 border-transparent transition-colors duration-200 ease-in-out focus:outline-none focus:ring-2 focus:ring-green-600 focus:ring-offset-2"
|
||||||
|
role="switch" aria-checked="false" onclick="changeUserGroupRankSkipStatus({{.Wxid}})">
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableWelcome true }}translate-x-5{{ else }}translate-x-0{{ end }} pointer-events-none relative inline-block h-5 w-5 transform rounded-full bg-white shadow ring-0 transition duration-200 ease-in-out">
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableWelcome true }}opacity-0 duration-100 ease-out{{ else }}opacity-100 duration-200 ease-in{{ end }} absolute inset-0 flex h-full w-full items-center justify-center transition-opacity"
|
||||||
|
aria-hidden="true">
|
||||||
|
<svg class="h-3 w-3 text-gray-400" fill="none" viewBox="0 0 12 12">
|
||||||
|
<path d="M4 8l2-2m0 0l2-2M6 6L4 4m2 2l2 2" stroke="currentColor" stroke-width="2" stroke-linecap="round"
|
||||||
|
stroke-linejoin="round"/>
|
||||||
|
</svg>
|
||||||
|
</span>
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableWelcome true }}opacity-100 duration-200 ease-in{{ else }}opacity-0 duration-100 ease-out{{ end }} absolute inset-0 flex h-full w-full items-center justify-center transition-opacity"
|
||||||
|
aria-hidden="true">
|
||||||
|
<svg class="h-3 w-3 text-green-600" fill="currentColor" viewBox="0 0 12 12">
|
||||||
|
<path
|
||||||
|
d="M3.707 5.293a1 1 0 00-1.414 1.414l1.414-1.414zM5 8l-.707.707a1 1 0 001.414 0L5 8zm4.707-3.293a1 1 0 00-1.414-1.414l1.414 1.414zm-7.414 2l2 2 1.414-1.414-2-2-1.414 1.414zm3.414 2l4-4-1.414-1.414-4 4 1.414 1.414z"/>
|
||||||
|
</svg>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</button>
|
||||||
|
{{end}}
|
||||||
|
|
||||||
|
<!-- 早报 -->
|
||||||
|
{{define "news"}}
|
||||||
|
<button type="button"
|
||||||
|
class="{{ if eq .EnableNews true }}bg-green-600{{ else }}bg-gray-200{{ end }} relative inline-flex h-6 w-11 flex-shrink-0 cursor-pointer rounded-full border-2 border-transparent transition-colors duration-200 ease-in-out focus:outline-none focus:ring-2 focus:ring-green-600 focus:ring-offset-2"
|
||||||
|
role="switch" aria-checked="false" onclick="changeUserNewsStatus({{.Wxid}})">
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableNews true }}translate-x-5{{ else }}translate-x-0{{ end }} pointer-events-none relative inline-block h-5 w-5 transform rounded-full bg-white shadow ring-0 transition duration-200 ease-in-out">
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableNews true }}opacity-0 duration-100 ease-out{{ else }}opacity-100 duration-200 ease-in{{ end }} absolute inset-0 flex h-full w-full items-center justify-center transition-opacity"
|
||||||
|
aria-hidden="true">
|
||||||
|
<svg class="h-3 w-3 text-gray-400" fill="none" viewBox="0 0 12 12">
|
||||||
|
<path d="M4 8l2-2m0 0l2-2M6 6L4 4m2 2l2 2" stroke="currentColor" stroke-width="2" stroke-linecap="round"
|
||||||
|
stroke-linejoin="round"/>
|
||||||
|
</svg>
|
||||||
|
</span>
|
||||||
|
<span
|
||||||
|
class="{{ if eq .EnableNews true }}opacity-100 duration-200 ease-in{{ else }}opacity-0 duration-100 ease-out{{ end }} absolute inset-0 flex h-full w-full items-center justify-center transition-opacity"
|
||||||
|
aria-hidden="true">
|
||||||
|
<svg class="h-3 w-3 text-green-600" fill="currentColor" viewBox="0 0 12 12">
|
||||||
|
<path
|
||||||
|
d="M3.707 5.293a1 1 0 00-1.414 1.414l1.414-1.414zM5 8l-.707.707a1 1 0 001.414 0L5 8zm4.707-3.293a1 1 0 00-1.414-1.414l1.414 1.414zm-7.414 2l2 2 1.414-1.414-2-2-1.414 1.414zm3.414 2l4-4-1.414-1.414-4 4 1.414 1.414z"/>
|
||||||
|
</svg>
|
||||||
|
</span>
|
||||||
|
</span>
|
||||||
|
</button>
|
||||||
|
{{end}}
|
||||||
|
|
||||||
|
|
||||||
|
<!-- 是否tag -->
|
||||||
|
{{define "flagTag"}}
|
||||||
|
{{ if eq . true }}
|
||||||
|
<span
|
||||||
|
class="inline-flex items-center rounded-md bg-green-50 px-2 py-1 text-xs font-medium text-green-700 ring-1 ring-inset ring-green-600/20">在通讯录</span>
|
||||||
|
{{ else }}
|
||||||
|
<span
|
||||||
|
class="inline-flex items-center rounded-md bg-red-50 px-2 py-1 text-xs font-medium text-red-700 ring-1 ring-inset ring-red-600/20">不在通讯录</span>
|
||||||
|
{{ end }}
|
||||||
|
{{end}}
|
||||||
|
|||||||
@@ -28,11 +28,7 @@
|
|||||||
<img src="assets/img/status-{{ if eq .IsOk true }}ok{{else}}fail{{end}}.png" alt="Tuple" class="h-12 w-12 flex-none rounded-lg bg-white object-cover ring-1 ring-gray-900/10">
|
<img src="assets/img/status-{{ if eq .IsOk true }}ok{{else}}fail{{end}}.png" alt="Tuple" class="h-12 w-12 flex-none rounded-lg bg-white object-cover ring-1 ring-gray-900/10">
|
||||||
<div class="flex-1">
|
<div class="flex-1">
|
||||||
<div class="text-sm font-medium leading-6 text-gray-900">{{ .Nickname }}</div>
|
<div class="text-sm font-medium leading-6 text-gray-900">{{ .Nickname }}</div>
|
||||||
{{ if eq .IsOk true }}
|
{{ template "flagTag" .IsOk }}
|
||||||
<span class="inline-flex items-center rounded-md bg-green-50 px-2 py-1 text-xs font-medium text-green-700 ring-1 ring-inset ring-green-600/20">正常</span>
|
|
||||||
{{ else }}
|
|
||||||
<span class="inline-flex items-center rounded-md bg-red-50 px-2 py-1 text-xs font-medium text-red-700 ring-1 ring-inset ring-red-600/20">已删除</span>
|
|
||||||
{{ end }}
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
<dl class="-my-3 divide-y divide-gray-100 px-6 py-4 text-sm leading-6">
|
<dl class="-my-3 divide-y divide-gray-100 px-6 py-4 text-sm leading-6">
|
||||||
@@ -80,8 +76,33 @@
|
|||||||
</label>
|
</label>
|
||||||
</dd>
|
</dd>
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
|
<div class="flex justify-between gap-x-4 py-3">
|
||||||
|
<dt class="text-gray-500 mt-2">AI角色</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
<label>
|
||||||
|
<select class="block w-full rounded-md border-0 py-1.5 pl-3 pr-10 text-gray-900 ring-1 ring-inset ring-gray-300 focus:ring-2 focus:ring-green-600 sm:text-sm sm:leading-6" onchange="aiAssistantChange(event, {{.Wxid}})">
|
||||||
|
<option value="" {{ if eq .Prompt "" }}selected{{ end }}>默认</option>
|
||||||
|
|
||||||
|
{{$usePrompt := .Prompt}}
|
||||||
|
{{ range $.assistant }}
|
||||||
|
<option value="{{.Id}}" {{ if eq $usePrompt .Id}}selected{{ end }}>
|
||||||
|
{{.Name}}
|
||||||
|
</option>
|
||||||
|
{{ end }}
|
||||||
|
</select>
|
||||||
|
</label>
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
{{ end }}
|
{{ end }}
|
||||||
|
|
||||||
|
<div class="flex justify-between gap-x-4 py-3">
|
||||||
|
<dt class="text-gray-500">早报</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "news" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
|
||||||
<div class="flex justify-between gap-x-4 py-3">
|
<div class="flex justify-between gap-x-4 py-3">
|
||||||
<dt class="text-gray-500">指令</dt>
|
<dt class="text-gray-500">指令</dt>
|
||||||
<dd class="flex items-start gap-x-2">
|
<dd class="flex items-start gap-x-2">
|
||||||
|
|||||||
208
views/group.html
208
views/group.html
@@ -21,98 +21,136 @@
|
|||||||
<main class="-mt-32">
|
<main class="-mt-32">
|
||||||
<div class="mx-auto max-w-7xl px-4 pb-12 sm:px-6 lg:px-8">
|
<div class="mx-auto max-w-7xl px-4 pb-12 sm:px-6 lg:px-8">
|
||||||
<div class="rounded-lg bg-white px-5 py-6 shadow sm:px-6 text-2xl">
|
<div class="rounded-lg bg-white px-5 py-6 shadow sm:px-6 text-2xl">
|
||||||
<table class="min-w-full divide-y divide-gray-300">
|
<ul role="list" class="grid grid-cols-1 gap-x-6 gap-y-8 lg:grid-cols-2 xl:gap-x-8">
|
||||||
<thead class="bg-gray-50">
|
|
||||||
<tr>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">群名称
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
最后活跃时间
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否在通讯录
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否启用AI
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否启用水群排行榜
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否启用聊天记录总结
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否启用迎新
|
|
||||||
</th>
|
|
||||||
<th scope="col" class="px-3 py-3.5 text-left text-sm font-semibold text-gray-900">
|
|
||||||
是否启用指令
|
|
||||||
</th>
|
|
||||||
</tr>
|
|
||||||
</thead>
|
|
||||||
<tbody class="divide-y divide-gray-200 bg-white">
|
|
||||||
{{ range .groups }}
|
{{ range .groups }}
|
||||||
<tr class="even:bg-gray-50">
|
<li class="overflow-hidden rounded-xl border border-gray-200">
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
<div class="flex items -center gap-x-4 border-b border-gray-900/5 bg-gray-50 p-6">
|
||||||
<div class="font-medium text-gray-900">{{ .Nickname }}</div>
|
<img src="assets/img/status-{{ if eq .IsOk true }}ok{{else}}fail{{end}}.png" alt="Tuple"
|
||||||
<div class="mt-1 truncate text-gray-500">{{ .Wxid }}</div>
|
class="h-12 w-12 flex-none rounded-lg bg-white object-cover ring-1 ring-gray-900/10">
|
||||||
</td>
|
<div class="text-sm flex-1">
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
<div class="font-medium leading-6 text-gray-900">{{ .Nickname }}</div>
|
||||||
{{ if eq .LastActive.IsNil true }}
|
<div class="font-medium text-gray-500">{{ .Wxid }}</div>
|
||||||
无数据
|
{{ template "flagTag" .IsOk }}
|
||||||
{{ else }}
|
<button type="button" class="btn-link float-end text-red-600" onclick="getGroupUsers({{.Wxid}}, {{.Nickname}})">群成员</button>
|
||||||
{{ .LastActive }}
|
</div>
|
||||||
{{ end }}
|
</div>
|
||||||
</td>
|
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
|
||||||
{{ if eq .IsOk true }}
|
|
||||||
<span
|
|
||||||
class="inline-flex items-center rounded-md bg-green-50 px-2 py-1 text-xs font-medium text-green-700 ring-1 ring-inset ring-green-600/20">是</span>
|
|
||||||
{{ else }}
|
|
||||||
<span
|
|
||||||
class="inline-flex items-center rounded-md bg-red-50 px-2 py-1 text-xs font-medium text-red-700 ring-1 ring-inset ring-red-600/20">否</span>
|
|
||||||
{{ end }}
|
|
||||||
</td>
|
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
|
||||||
{{ template "ai" . }}
|
|
||||||
<!-- 使用的模型 -->
|
|
||||||
{{ if eq .EnableAi true }}
|
|
||||||
<select id="location" name="location"
|
|
||||||
class="mt-2 block w-full rounded-md border-0 py-1.5 pl-3 pr-10 text-gray-900 ring-1 ring-inset ring-gray-300 focus:ring-2 focus:ring-green-600 sm:text-sm sm:leading-6"
|
|
||||||
onchange="aiModelChange(event, {{.Wxid}})">
|
|
||||||
<option value="" {{ if eq .AiModel
|
|
||||||
"" }}selected{{ end }}>默认(gpt-3.5-turbo-0613)
|
|
||||||
</option>
|
|
||||||
|
|
||||||
{{$useModel := .AiModel}}
|
<dl class="-my-3 divide-y divide-gray-100 px-6 py-4 text-sm leading-6">
|
||||||
{{ range $.aiModels }}
|
<!-- 最后活跃时间 -->
|
||||||
<option value="{{.Model}}" {{ if eq $useModel .Model}}selected{{ end }}>
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
{{.Name}}({{.Model}})
|
<dt class="text-gray-500">最后活跃时间</dt>
|
||||||
</option>
|
<dd class="flex items-start gap-x-2">
|
||||||
{{ end }}
|
{{ if eq .LastActive.IsNil true }}
|
||||||
</select>
|
无活跃数据
|
||||||
{{ end }}
|
{{ else }}
|
||||||
</td>
|
<time datetime="{{ .LastActive }}">{{ .LastActive }}</time>
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
{{ end }}
|
||||||
{{ template "chatRank" . }}
|
</dd>
|
||||||
</td>
|
</div>
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
<!-- AI -->
|
||||||
{{ template "summary" . }}
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
</td>
|
<dt class="text-gray-500">AI(模型可选默认或者指定模型)</dt>
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
<dd class="flex items-start gap-x-2 items-center">
|
||||||
{{ template "welcome" . }}
|
<div>
|
||||||
</td>
|
{{ template "ai" . }}
|
||||||
<td class="whitespace-nowrap px-3 py-4 text-sm text-gray-500">
|
</div>
|
||||||
{{ template "command" . }}
|
{{ if eq .EnableAi true }}
|
||||||
</td>
|
<div class="float-end">
|
||||||
</tr>
|
<div>
|
||||||
{{ end }}
|
<label>
|
||||||
</tbody>
|
<select class="block w-full rounded-md border-0 py-1.5 pl-3 pr-10 text-gray-900 ring-1 ring-inset ring-gray-300 focus:ring-2 focus:ring-green-600 sm:text-sm sm:leading-6" onchange="aiModelChange(event, {{.Wxid}})">
|
||||||
</table>
|
{{$useModel := .AiModel}}
|
||||||
|
{{ range $.aiModels }}
|
||||||
|
<option value="{{.Model}}" {{ if eq $useModel .Model}}selected{{ end }}>
|
||||||
|
{{.Name}}
|
||||||
|
</option>
|
||||||
|
{{ end }}
|
||||||
|
</select>
|
||||||
|
</label>
|
||||||
|
</div>
|
||||||
|
<div class="float-end mt-1">
|
||||||
|
<label>
|
||||||
|
<select
|
||||||
|
class="block w-full rounded-md border-0 py-1.5 pl-3 pr-10 text-gray-900 ring-1 ring-inset ring-gray-300 focus:ring-2 focus:ring-green-600 sm:text-sm sm:leading-6"
|
||||||
|
onchange="aiAssistantChange(event, {{.Wxid}})">
|
||||||
|
<option value="" {{ if eq .Prompt
|
||||||
|
"" }}selected{{ end }}>默认</option>
|
||||||
|
|
||||||
|
{{$usePrompt := .Prompt}}
|
||||||
|
{{ range $.assistant }}
|
||||||
|
<option value="{{.Id}}" {{ if eq $usePrompt .Id}}selected{{ end }}>
|
||||||
|
{{.Name}}
|
||||||
|
</option>
|
||||||
|
{{ end }}
|
||||||
|
</select>
|
||||||
|
</label>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
{{ end }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 水群排行榜 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">水群排行榜</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "chatRank" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 群聊总结 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">群聊总结</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "summary" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 迎新 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">迎新</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "welcome" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 早报 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">早报</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "news" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 指令 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">迎新</dt>
|
||||||
|
<dd class="flex items-start gap-x-2">
|
||||||
|
{{ template "command" . }}
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
<!-- 自动清理不活跃成员 -->
|
||||||
|
<div class="flex justify-between gap-x-4 py-3 items-center">
|
||||||
|
<dt class="text-gray-500">末位淘汰</dt>
|
||||||
|
<dd class="flex items-start gap-x-2 items-center">
|
||||||
|
<div class="relative rounded-md shadow-sm">
|
||||||
|
<label>
|
||||||
|
<input type="number" id="auto-cm-{{ .Wxid }}" min="0" class="block w-1/2 float-end rounded-md border-0 py-1.5 text-gray-900 shadow-sm ring-1 ring-inset ring-gray-300 placeholder:text-gray-400 focus:ring-2 focus:ring-inset focus:ring-indigo-600 sm:text-sm sm:leading-6" placeholder="N天不活跃自动移除"
|
||||||
|
value="{{.ClearMember}}"
|
||||||
|
onblur="changeClearMember({{.Wxid}}, {{.ClearMember}}, this.value)"
|
||||||
|
>
|
||||||
|
</label>
|
||||||
|
<div class="pointer-events-none absolute inset-y-0 right-0 flex items-center pr-3">
|
||||||
|
<span class="text-gray-500 sm:text-sm" id="price-currency">天</span>
|
||||||
|
</div>
|
||||||
|
</div>
|
||||||
|
</dd>
|
||||||
|
</div>
|
||||||
|
</dl>
|
||||||
|
{{ end }}
|
||||||
|
</ul>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</main>
|
</main>
|
||||||
|
|
||||||
{{ template "footer.html" }}
|
{{ template "footer.html" }}
|
||||||
|
|
||||||
|
{{ template "groupuser.html" }}
|
||||||
</div>
|
</div>
|
||||||
|
|
||||||
</body>
|
</body>
|
||||||
|
|||||||
21
views/groupuser.html
Normal file
21
views/groupuser.html
Normal file
@@ -0,0 +1,21 @@
|
|||||||
|
<dialog id="groupUserModal" class="modal">
|
||||||
|
<div class="modal-box w-11/12 max-w-7xl">
|
||||||
|
<h3 class="font-bold text-lg" id="groupUserModalName">我是群名称</h3>
|
||||||
|
<div class="divider divider-warning">成员列表</div>
|
||||||
|
<table class="table table-zebra">
|
||||||
|
<thead>
|
||||||
|
<tr>
|
||||||
|
<th>微信Id</th>
|
||||||
|
<th>昵称</th>
|
||||||
|
<th>是否群成员</th>
|
||||||
|
<th>是否群主</th>
|
||||||
|
<th>加群时间</th>
|
||||||
|
<th>最后活跃时间</th>
|
||||||
|
<th>退群时间</th>
|
||||||
|
<th>是否跳过水群排行榜</th>
|
||||||
|
</tr>
|
||||||
|
</thead>
|
||||||
|
<tbody id="groupUsers"></tbody>
|
||||||
|
</table>
|
||||||
|
</div>
|
||||||
|
</dialog>
|
||||||
@@ -13,6 +13,7 @@
|
|||||||
<a href="/friend.html" class="{{ if eq . "friend" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium" aria-current="page">好友</a>
|
<a href="/friend.html" class="{{ if eq . "friend" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium" aria-current="page">好友</a>
|
||||||
<a href="/group.html" class="{{ if eq . "group" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium">群组</a>
|
<a href="/group.html" class="{{ if eq . "group" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium">群组</a>
|
||||||
<!-- <a href="/index.html" class="{{ if eq . "vnc" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium">VNC</a>-->
|
<!-- <a href="/index.html" class="{{ if eq . "vnc" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium">VNC</a>-->
|
||||||
|
<a href="/assistant.html" class="{{ if eq . "assistant" }}bg-green-700{{ else }}hover:bg-green-500 hover:bg-opacity-75{{ end }} text-white rounded-md py-2 px-3 text-sm font-medium">AI角色</a>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
|||||||
@@ -1,4 +1,14 @@
|
|||||||
/* 隐藏滚动条 */
|
/* 隐藏滚动条 */
|
||||||
::-webkit-scrollbar {
|
::-webkit-scrollbar {
|
||||||
display: none;
|
display: none;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/* 隐藏input输入数字时的箭头 */
|
||||||
|
input[type=number]::-webkit-inner-spin-button,
|
||||||
|
input[type=number]::-webkit-outer-spin-button {
|
||||||
|
-webkit-appearance: none;
|
||||||
|
margin: 0;
|
||||||
|
}
|
||||||
|
input[type=number] {
|
||||||
|
-moz-appearance:textfield;
|
||||||
|
}
|
||||||
|
|||||||
@@ -80,6 +80,25 @@ function changeWelcomeEnableStatus(wxId) {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// 修改用户新闻开启状态
|
||||||
|
function changeUserNewsStatus(wxId) {
|
||||||
|
axios({
|
||||||
|
method: 'put',
|
||||||
|
url: '/api/news/status',
|
||||||
|
data: {
|
||||||
|
wxId: wxId
|
||||||
|
}
|
||||||
|
}).then(function (response) {
|
||||||
|
console.log(`返回结果: ${JSON.stringify(response)}`);
|
||||||
|
alert(`${response.data}`)
|
||||||
|
}).catch(function (error) {
|
||||||
|
console.log(`错误信息: ${error}`);
|
||||||
|
alert("修改失败")
|
||||||
|
}).finally(function () {
|
||||||
|
window.location.reload();
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
// 修改指令权限启用状态
|
// 修改指令权限启用状态
|
||||||
function changeCommandEnableStatus(wxId) {
|
function changeCommandEnableStatus(wxId) {
|
||||||
axios({
|
axios({
|
||||||
@@ -155,12 +174,13 @@ function getGroupUsers(groupId, groupName) {
|
|||||||
// Insert data into cells
|
// Insert data into cells
|
||||||
row.insertCell(0).innerHTML = wxid;
|
row.insertCell(0).innerHTML = wxid;
|
||||||
row.insertCell(1).innerHTML = nickname;
|
row.insertCell(1).innerHTML = nickname;
|
||||||
row.insertCell(2).innerHTML = `<div class="badge badge-${isMember ? 'info' : 'error'} gap-2">${isMember ? '是' : '否'}</div>`;
|
row.insertCell(2).innerHTML = `<span class="inline-flex items-center rounded-md px-2 py-1 text-xs font-medium ring-1 ring-inset ${isMember ? 'bg-green-50 text-green-700 ring-green-600/20' : 'bg-red-50 text-red-700 ring-red-600/20'}">${isMember ? '是' : '否'}</span>`;
|
||||||
row.insertCell(3).innerHTML = `<div class="badge badge-${isAdmin ? 'info' : 'error'} gap-2">${isAdmin ? '是' : '否'}</div>`;
|
row.insertCell(3).innerHTML = `<span class="inline-flex items-center rounded-md px-2 py-1 text-xs font-medium ring-1 ring-inset ${isAdmin ? 'bg-green-50 text-green-700 ring-green-600/20' : 'bg-red-50 text-red-700 ring-red-600/20'}">${isAdmin ? '是' : '否'}</span>`;
|
||||||
row.insertCell(4).innerHTML = joinTime;
|
row.insertCell(4).innerHTML = joinTime;
|
||||||
row.insertCell(5).innerHTML = lastActive;
|
row.insertCell(5).innerHTML = lastActive;
|
||||||
row.insertCell(6).innerHTML = leaveTime;
|
row.insertCell(6).innerHTML = leaveTime;
|
||||||
row.insertCell(7).innerHTML = `<input type="checkbox" class="toggle toggle-error" ${skipChatRank ? 'checked' : ''} onclick="changeUserGroupRankSkipStatus('${groupId}', '${wxid}')" />`;
|
// row.insertCell(7).innerHTML = `<input type="checkbox" class="toggle toggle-error" ${skipChatRank ? 'checked' : ''} onclick="changeUserGroupRankSkipStatus('${groupId}', '${wxid}')" />`;
|
||||||
|
row.insertCell(7).innerHTML = `<span class="inline-flex items-center rounded-md px-2 py-1 text-xs font-medium ring-1 ring-inset ${skipChatRank ? 'bg-green-50 text-green-700 ring-green-600/20' : 'bg-red-50 text-red-700 ring-red-600/20'}">${skipChatRank ? '是' : '否'}</span>`;
|
||||||
});
|
});
|
||||||
}).catch(function (error) {
|
}).catch(function (error) {
|
||||||
console.log(`错误信息: ${error}`);
|
console.log(`错误信息: ${error}`);
|
||||||
@@ -193,3 +213,56 @@ function aiModelChange(event, wxid) {
|
|||||||
window.location.reload();
|
window.location.reload();
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// AI角色变动
|
||||||
|
function aiAssistantChange(event, wxid) {
|
||||||
|
// 取出变动后的值
|
||||||
|
const assistantStr = event.target.value;
|
||||||
|
console.log("AI角色变动: ", wxid, assistantStr)
|
||||||
|
axios({
|
||||||
|
method: 'post',
|
||||||
|
url: '/api/ai/assistant',
|
||||||
|
data: {
|
||||||
|
wxid: wxid,
|
||||||
|
model: assistantStr
|
||||||
|
}
|
||||||
|
}).then(function (response) {
|
||||||
|
console.log(`返回结果: ${JSON.stringify(response)}`);
|
||||||
|
alert(`${response.data}`)
|
||||||
|
}).catch(function (error) {
|
||||||
|
console.log(`错误信息: ${error}`);
|
||||||
|
alert("修改失败")
|
||||||
|
}).finally(function () {
|
||||||
|
window.location.reload();
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
// 修改清理群成员值
|
||||||
|
function changeClearMember(wxid, oldVal, newVal) {
|
||||||
|
oldVal = Number(oldVal)
|
||||||
|
newVal = Number(newVal)
|
||||||
|
|
||||||
|
if (oldVal === newVal) {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
if (newVal < 0) {
|
||||||
|
alert('不活跃天数的值不能小于0')
|
||||||
|
}
|
||||||
|
// 请求接口
|
||||||
|
axios({
|
||||||
|
method: 'put',
|
||||||
|
url: '/api/clearmembers',
|
||||||
|
data: {
|
||||||
|
wxid: wxid,
|
||||||
|
days: Number(newVal)
|
||||||
|
}
|
||||||
|
}).then(function (response) {
|
||||||
|
console.log(`返回结果: ${JSON.stringify(response)}`);
|
||||||
|
alert(`${response.data}`)
|
||||||
|
}).catch(function (error) {
|
||||||
|
console.log(`错误信息: ${error}`);
|
||||||
|
alert("修改失败")
|
||||||
|
}).finally(function () {
|
||||||
|
window.location.reload();
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|||||||
@@ -15,10 +15,13 @@ type FriendItem struct {
|
|||||||
LastActive types.DateTime // 最后活跃时间
|
LastActive types.DateTime // 最后活跃时间
|
||||||
EnableAi bool // 是否使用AI
|
EnableAi bool // 是否使用AI
|
||||||
AiModel string // AI模型
|
AiModel string // AI模型
|
||||||
|
Prompt string // AI助手或者自定义提示词
|
||||||
EnableChatRank bool // 是否使用聊天排行
|
EnableChatRank bool // 是否使用聊天排行
|
||||||
EnableWelcome bool // 是否使用迎新
|
EnableWelcome bool // 是否使用迎新
|
||||||
EnableCommand bool // 是否启用指令
|
EnableCommand bool // 是否启用指令
|
||||||
EnableSummary bool // 是否启用总结
|
EnableSummary bool // 是否启用总结
|
||||||
|
EnableNews bool // 是否启用新闻
|
||||||
|
ClearMember int // 清理成员配置(多少天未活跃的)
|
||||||
IsOk bool // 是否还在通讯库(群聊是要还在群里也算)
|
IsOk bool // 是否还在通讯库(群聊是要还在群里也算)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user