mirror of
https://github.com/FloatTech/ZeroBot-Plugin.git
synced 2025-12-19 22:00:11 +08:00
286 lines
8.0 KiB
Go
286 lines
8.0 KiB
Go
// Package setutime 来份涩图
|
||
package setutime
|
||
|
||
import (
|
||
"fmt"
|
||
"io"
|
||
"net/http"
|
||
"os"
|
||
"strconv"
|
||
"strings"
|
||
"sync"
|
||
"time"
|
||
|
||
"github.com/FloatTech/AnimeAPI/pixiv"
|
||
"github.com/sirupsen/logrus"
|
||
zero "github.com/wdvxdr1123/ZeroBot"
|
||
"github.com/wdvxdr1123/ZeroBot/extension/rate"
|
||
"github.com/wdvxdr1123/ZeroBot/message"
|
||
|
||
"github.com/FloatTech/ZeroBot-Plugin/control"
|
||
"github.com/FloatTech/ZeroBot-Plugin/data"
|
||
)
|
||
|
||
// Pools 图片缓冲池
|
||
type imgpool struct {
|
||
Lock sync.Mutex
|
||
DB *data.Sqlite
|
||
Path string
|
||
Group int64
|
||
List []string
|
||
Max int
|
||
Pool map[string][]*pixiv.Illust
|
||
Form int64
|
||
}
|
||
|
||
const (
|
||
dburl = "https://codechina.csdn.net/u011570312/ZeroBot-Plugin/-/raw/master/data/SetuTime/SetuTime.db"
|
||
)
|
||
|
||
// NewPoolsCache 返回一个缓冲池对象
|
||
func newPools() *imgpool {
|
||
cache := &imgpool{
|
||
DB: &data.Sqlite{DBPath: "data/SetuTime/SetuTime.db"},
|
||
Path: "data/SetuTime/cache/",
|
||
Group: 0,
|
||
List: []string{"涩图", "二次元", "风景", "车万"}, // 可以自己加类别，得自己加图片进数据库
|
||
Max: 10,
|
||
Pool: map[string][]*pixiv.Illust{},
|
||
Form: 0,
|
||
}
|
||
// 每次启动清理缓存
|
||
os.RemoveAll(cache.Path)
|
||
err := os.MkdirAll(cache.Path, 0755)
|
||
if err != nil {
|
||
panic(err)
|
||
}
|
||
// 如果数据库不存在则下载
|
||
if _, err := os.Stat(cache.DB.DBPath); err != nil || os.IsNotExist(err) {
|
||
f, err := os.Create(cache.DB.DBPath)
|
||
if err == nil {
|
||
resp, err := http.Get(dburl)
|
||
if err == nil {
|
||
defer resp.Body.Close()
|
||
if resp.ContentLength > 0 {
|
||
logrus.Printf("[Setu]从镜像下载数据库%d字节...", resp.ContentLength)
|
||
data, err := io.ReadAll(resp.Body)
|
||
if err == nil && len(data) > 0 {
|
||
_, err = f.Write(data)
|
||
if err != nil {
|
||
logrus.Errorf("[Setu]写入数据库失败: %v", err)
|
||
}
|
||
}
|
||
}
|
||
}
|
||
f.Close()
|
||
}
|
||
}
|
||
for i := range cache.List {
|
||
if err := cache.DB.Create(cache.List[i], &pixiv.Illust{}); err != nil {
|
||
panic(err)
|
||
}
|
||
}
|
||
return cache
|
||
}
|
||
|
||
var (
|
||
pool = newPools()
|
||
limit = rate.NewManager(time.Minute*1, 5)
|
||
)
|
||
|
||
func init() { // 插件主体
|
||
engine := control.Register("setutime", &control.Options{
|
||
DisableOnDefault: false,
|
||
Help: "涩图\n" +
|
||
"- 来份[涩图/二次元/风景/车万]\n" +
|
||
"- 添加[涩图/二次元/风景/车万][P站图片ID]\n" +
|
||
"- 删除[涩图/二次元/风景/车万][P站图片ID]\n" +
|
||
"- >setu status",
|
||
})
|
||
engine.OnRegex(`^来份(.*)$`, firstValueInList(pool.List)).SetBlock(true).SetPriority(20).
|
||
Handle(func(ctx *zero.Ctx) {
|
||
if !limit.Load(ctx.Event.UserID).Acquire() {
|
||
ctx.SendChain(message.Text("请稍后重试0x0..."))
|
||
return
|
||
}
|
||
var imgtype = ctx.State["regex_matched"].([]string)[1]
|
||
// 补充池子
|
||
go func() {
|
||
times := data.Min(pool.Max-pool.size(imgtype), 2)
|
||
for i := 0; i < times; i++ {
|
||
illust := &pixiv.Illust{}
|
||
// 查询出一张图片
|
||
if err := pool.DB.Find(imgtype, illust, "ORDER BY RANDOM() limit 1"); err != nil {
|
||
ctx.SendChain(message.Text("ERROR: ", err))
|
||
continue
|
||
}
|
||
// 下载图片
|
||
if err := download(illust, pool.Path); err != nil {
|
||
ctx.SendChain(message.Text("ERROR: ", err))
|
||
continue
|
||
}
|
||
ctx.SendGroupMessage(pool.Group, []message.MessageSegment{message.Image(file(illust))})
|
||
// 向缓冲池添加一张图片
|
||
pool.push(imgtype, illust)
|
||
time.Sleep(time.Second * 1)
|
||
}
|
||
}()
|
||
// 如果没有缓存，阻塞5秒
|
||
if pool.size(imgtype) == 0 {
|
||
ctx.SendChain(message.Text("INFO: 正在填充弹药......"))
|
||
<-time.After(time.Second * 5)
|
||
if pool.size(imgtype) == 0 {
|
||
ctx.SendChain(message.Text("ERROR: 等待填充，请稍后再试......"))
|
||
return
|
||
}
|
||
}
|
||
// 从缓冲池里抽一张
|
||
if id := ctx.SendChain(message.Image(file(pool.pop(imgtype)))); id == 0 {
|
||
ctx.SendChain(message.Text("ERROR: 可能被风控了"))
|
||
}
|
||
})
|
||
|
||
engine.OnRegex(`^添加(.*?)(\d+)$`, firstValueInList(pool.List), zero.SuperUserPermission).SetBlock(true).SetPriority(21).
|
||
Handle(func(ctx *zero.Ctx) {
|
||
var (
|
||
imgtype = ctx.State["regex_matched"].([]string)[1]
|
||
id, _ = strconv.ParseInt(ctx.State["regex_matched"].([]string)[2], 10, 64)
|
||
)
|
||
ctx.SendChain(message.Text("少女祈祷中......"))
|
||
// 查询P站插图信息
|
||
illust, err := pixiv.Works(id)
|
||
if err != nil {
|
||
ctx.SendChain(message.Text("ERROR: ", err))
|
||
return
|
||
}
|
||
// 下载插画
|
||
if err := download(illust, pool.Path); err != nil {
|
||
ctx.SendChain(message.Text("ERROR: ", err))
|
||
return
|
||
}
|
||
// 发送到发送者
|
||
if id := ctx.SendChain(message.Image(file(illust))); id == 0 {
|
||
ctx.SendChain(message.Text("ERROR: 可能被风控，发送失败"))
|
||
return
|
||
}
|
||
// 添加插画到对应的数据库table
|
||
if err := pool.DB.Insert(imgtype, illust); err != nil {
|
||
ctx.SendChain(message.Text("ERROR: ", err))
|
||
return
|
||
}
|
||
ctx.Send("添加成功")
|
||
})
|
||
|
||
engine.OnRegex(`^删除(.*?)(\d+)$`, firstValueInList(pool.List), zero.SuperUserPermission).SetBlock(true).SetPriority(22).
|
||
Handle(func(ctx *zero.Ctx) {
|
||
var (
|
||
imgtype = ctx.State["regex_matched"].([]string)[1]
|
||
id, _ = strconv.ParseInt(ctx.State["regex_matched"].([]string)[2], 10, 64)
|
||
)
|
||
// 查询数据库
|
||
if err := pool.DB.Del(imgtype, fmt.Sprintf("WHERE pid=%d", id)); err != nil {
|
||
ctx.Send(fmt.Sprintf("ERROR: %v", err))
|
||
return
|
||
}
|
||
ctx.Send("删除成功")
|
||
})
|
||
|
||
// 查询数据库涩图数量
|
||
engine.OnFullMatchGroup([]string{">setu status"}).SetBlock(true).SetPriority(23).
|
||
Handle(func(ctx *zero.Ctx) {
|
||
state := []string{"[SetuTime]"}
|
||
for i := range pool.List {
|
||
num, err := pool.DB.Count(pool.List[i])
|
||
if err != nil {
|
||
num = 0
|
||
}
|
||
state = append(state, "\n")
|
||
state = append(state, pool.List[i])
|
||
state = append(state, ": ")
|
||
state = append(state, fmt.Sprintf("%d", num))
|
||
}
|
||
ctx.Send(strings.Join(state, ""))
|
||
})
|
||
}
|
||
|
||
// firstValueInList 判断正则匹配的第一个参数是否在列表中
|
||
func firstValueInList(list []string) zero.Rule {
|
||
return func(ctx *zero.Ctx) bool {
|
||
first := ctx.State["regex_matched"].([]string)[1]
|
||
for i := range list {
|
||
if first == list[i] {
|
||
return true
|
||
}
|
||
}
|
||
return false
|
||
}
|
||
}
|
||
|
||
// size 返回缓冲池指定类型的现有大小
|
||
func (p *imgpool) size(imgtype string) int {
|
||
return len(p.Pool[imgtype])
|
||
}
|
||
|
||
/*
|
||
// isFull 返回缓冲池指定类型是否已满
|
||
func (p *imgpool) isFull(imgtype string) bool {
|
||
return len(p.Pool[imgtype]) >= p.Max
|
||
}*/
|
||
|
||
// push 向缓冲池插入一张图片
|
||
func (p *imgpool) push(imgtype string, illust *pixiv.Illust) {
|
||
p.Lock.Lock()
|
||
defer p.Lock.Unlock()
|
||
p.Pool[imgtype] = append(p.Pool[imgtype], illust)
|
||
}
|
||
|
||
// Push 在缓冲池拿出一张图片
|
||
func (p *imgpool) pop(imgtype string) (illust *pixiv.Illust) {
|
||
p.Lock.Lock()
|
||
defer p.Lock.Unlock()
|
||
if p.size(imgtype) == 0 {
|
||
return
|
||
}
|
||
illust = p.Pool[imgtype][0]
|
||
p.Pool[imgtype] = p.Pool[imgtype][1:]
|
||
return
|
||
}
|
||
|
||
func file(i *pixiv.Illust) string {
|
||
filename := fmt.Sprint(i.Pid)
|
||
pwd, _ := os.Getwd()
|
||
filepath := pwd + `/` + pool.Path + filename
|
||
if _, err := os.Stat(filepath + ".jpg"); err == nil || os.IsExist(err) {
|
||
return `file:///` + filepath + ".jpg"
|
||
}
|
||
if _, err := os.Stat(filepath + ".png"); err == nil || os.IsExist(err) {
|
||
return `file:///` + filepath + ".png"
|
||
}
|
||
if _, err := os.Stat(filepath + ".gif"); err == nil || os.IsExist(err) {
|
||
return `file:///` + filepath + ".gif"
|
||
}
|
||
return ""
|
||
}
|
||
|
||
func download(i *pixiv.Illust, filedir string) /*(string, */ error /*)*/ {
|
||
filename := fmt.Sprint(i.Pid)
|
||
filepath := filedir + filename
|
||
if _, err := os.Stat(filepath + ".jpg"); err == nil || os.IsExist(err) {
|
||
return /*filepath + ".jpg",*/ nil
|
||
}
|
||
if _, err := os.Stat(filepath + ".png"); err == nil || os.IsExist(err) {
|
||
return /*filepath + ".png",*/ nil
|
||
}
|
||
if _, err := os.Stat(filepath + ".gif"); err == nil || os.IsExist(err) {
|
||
return /*filepath + ".gif",*/ nil
|
||
}
|
||
// 下载最大分辨率为 1200 的图片
|
||
link := i.ImageUrls
|
||
link = strings.ReplaceAll(link, "img-original", "img-master")
|
||
link = strings.ReplaceAll(link, "_p0", "_p0_master1200")
|
||
link = strings.ReplaceAll(link, ".png", ".jpg")
|
||
// 下载
|
||
_, err1 := pixiv.Download(link, filedir, filename)
|
||
return err1
|
||
}
|