241 lines
9.3 KiB
C#
241 lines
9.3 KiB
C#
using Api.Framework.SDK;
|
||
using Chat.Framework.WXSdk;
|
||
using Chat.Framework.WXSdk.Implement;
|
||
using CsharpHttpHelper;
|
||
using FissionSend.Properties;
|
||
using System;
|
||
using System.Collections.Concurrent;
|
||
using System.Collections.Generic;
|
||
using System.Linq;
|
||
using System.Text;
|
||
using System.Threading;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace FissionSend
|
||
{
|
||
public class Class1 : Plugin
|
||
{
|
||
public Class1()
|
||
{
|
||
this.Name = "裂变-辅助发送";
|
||
this.Note = "随便啦";
|
||
this.Logo = Resources.bbbbbbbb;
|
||
}
|
||
|
||
#region 自定义变量
|
||
public static Config Config;
|
||
private Form1 mainForm = null;
|
||
#endregion
|
||
|
||
#region 默认
|
||
public override void Start()
|
||
{
|
||
Config = this.ReadConfig<Config>();
|
||
|
||
SDK.WebRequestEvent += SDK_WebRequestEvent;
|
||
SDK.ReciveIMEvent += SDK_ReciveIMEvent;
|
||
}
|
||
|
||
public override void ShowForm()
|
||
{
|
||
try
|
||
{
|
||
if (mainForm == null || mainForm.IsDisposed)
|
||
{
|
||
mainForm = new Form1();
|
||
mainForm.Show();
|
||
}
|
||
mainForm.TopMost = true;
|
||
mainForm.TopMost = false;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
this.OnLog(ex.Message);
|
||
}
|
||
}
|
||
|
||
public override void Stop()
|
||
{
|
||
try
|
||
{
|
||
if (mainForm != null)
|
||
{
|
||
mainForm.CloseForm();
|
||
mainForm = null;
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
this.OnLog(ex.Message);
|
||
}
|
||
}
|
||
#endregion
|
||
|
||
private ConcurrentDictionary<string, string> groupDic = new ConcurrentDictionary<string, string>();
|
||
|
||
private void SDK_ReciveIMEvent(object sender, ReciveIMEvent e)
|
||
{
|
||
//try
|
||
//{
|
||
// if (!string.IsNullOrWhiteSpace(e.Groupid))
|
||
// {
|
||
// if (!groupDic.ContainsKey(e.Groupid))
|
||
// {
|
||
// groupDic.TryAdd(e.Groupid, e.Groupid);
|
||
// if (sender.GetType() == typeof(WXClientImpl_HOOK))
|
||
// {
|
||
// var hook = sender as WXClientImpl_HOOK;
|
||
// if (hook == null) return;
|
||
// var group = hook.GetContact(e.Groupid);
|
||
// this.OnLog($"添加群缓存 {e.Groupid} - {(group == null ? string.Empty : group.NickName)} ,当前群数量:{groupDic.Count}");
|
||
// }
|
||
// else this.OnLog($"添加群缓存 {e.Groupid},当前群数量:{groupDic.Count}");
|
||
// }
|
||
// }
|
||
//}
|
||
//catch (Exception ex)
|
||
//{
|
||
// this.OnLog(ex.Message);
|
||
//}
|
||
}
|
||
|
||
private void SDK_WebRequestEvent(object sender, Api.Framework.Events.WebRequestEvents e)
|
||
{
|
||
var method = e.Param.ContainsKey("method") ? e.Param["method"] : string.Empty;
|
||
if (string.IsNullOrWhiteSpace(method)) return;
|
||
if (method.ToLower() != "fission") return;
|
||
|
||
var text = string.Empty;
|
||
var min = 0;
|
||
var max = 0;
|
||
var sleepmin = 5000;
|
||
var sleepmax = 40000;
|
||
var groups = string.Empty;
|
||
try
|
||
{
|
||
if (e.Param.ContainsKey("text"))//方法名称
|
||
{
|
||
text = e.Param["text"].Trim();
|
||
text = HttpHelper.URLEncode(text);
|
||
text = HttpHelper.URLDecode(text, Encoding.UTF8);
|
||
}
|
||
if (e.Param.ContainsKey("min"))//方法名称
|
||
min = getInt(e.Param["min"]);
|
||
if (e.Param.ContainsKey("max"))//方法名称
|
||
max = getInt(e.Param["max"]);
|
||
if (e.Param.ContainsKey("sleepmin"))
|
||
sleepmin = getInt(e.Param["sleepmin"]) * 1000;
|
||
if (e.Param.ContainsKey("sleepmax"))
|
||
sleepmax = getInt(e.Param["sleepmax"]) * 1000;
|
||
if (e.Param.ContainsKey("groups"))
|
||
groups = e.Param["groups"];
|
||
|
||
if (string.IsNullOrWhiteSpace(text)) throw new Exception("发送的内容不能为空");
|
||
if (min <= 0) throw new Exception("min不能小于不能零");
|
||
if (max <= 0) throw new Exception("max不能小于等于零");
|
||
if (min > max) throw new Exception("min的值不能比max大");
|
||
if (sleepmin > sleepmax) throw new Exception("sleepmin的值不能比sleepmax大");
|
||
//e.Send("OK");
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
this.OnLog(ex.Message);
|
||
e.Send("异常:" + ex.Message, -1);
|
||
return;
|
||
}
|
||
|
||
try
|
||
{
|
||
var wxs = Chat.Framework.ChatClient.WXClient.Values.Where(f => f.WeixinType == WeixinType.Hook微信 && f.Status == WxStatus.在线);
|
||
if (wxs == null || wxs.Count() == 0) throw new Exception("没有可执行的机器人");
|
||
var count = wxs.Count();
|
||
|
||
//if (groupDic.Count == 0)
|
||
//{
|
||
// var groupInfos = (wxs.ToArray()[0] as WXClientImpl_HOOK).GetGroupsNotInMember();
|
||
// if (groupInfos == null || groupInfos.Count == 0)
|
||
// throw new Exception("群缓存列表为空");
|
||
// foreach (var item in groupInfos)
|
||
// {
|
||
// if (!groupDic.ContainsKey(item.UserName))
|
||
// {
|
||
// groupDic.TryAdd(item.UserName, item.UserName);
|
||
// this.OnLog($"添加群缓存 {item.UserName} - {item.NickName} ,当前群数量:{groupDic.Count}");
|
||
// }
|
||
// }
|
||
//}
|
||
|
||
var _list = new List<string>();
|
||
if (string.IsNullOrWhiteSpace(groups))
|
||
//_list = groupDic.Keys.ToList();
|
||
_list = Config.SendGroups.Replace("，", ",").Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries).Select(f => f.Trim()).Where(f => f.EndsWith("@chatroom")).ToList();
|
||
else
|
||
_list = groups.Replace("，", ",").Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries).Select(f => f.Trim()).Where(f => f.EndsWith("@chatroom")).ToList();
|
||
|
||
//if (string.IsNullOrWhiteSpace(Config.SendGroups)) throw new Exception("没有设置要发送群id");
|
||
|
||
//var _list = Config.SendGroups.Replace("，", ",").Split(new string[] { "," }, StringSplitOptions.RemoveEmptyEntries).Select(f => f.Trim()).Where(f => f.EndsWith("@chatroom")).ToList();
|
||
|
||
e.Send(_list.Count);
|
||
|
||
foreach (var group in _list)
|
||
{
|
||
//if (notSendGroups.Contains(group)) continue;
|
||
var textMsg = text;
|
||
var groupTemp = group;
|
||
Task.Run(() =>
|
||
{
|
||
try
|
||
{
|
||
var num = getnum(count, min, max);
|
||
var _wxs = wxs.ToList().Select(a => new { a, newID = Guid.NewGuid() }).OrderBy(b => b.newID).Select(c => c.a).Distinct().ToList();//打乱顺序
|
||
_wxs = _wxs.GetRange(0, num);
|
||
var sendUCache = new List<string>();//缓存已经发送的账号
|
||
foreach (var wx in _wxs)
|
||
{
|
||
if (sendUCache.Contains(wx.WeixinHao)) continue;
|
||
sendUCache.Add(wx.WeixinHao);
|
||
wx.SendMessage(groupTemp, textMsg);
|
||
this.OnLog($"群:{groupTemp},微信数量:{_wxs.Count}, 机器人:{wx.User.Username}({wx.User.Nick})({wx.User.Uin})，发送内容:text={textMsg} 已经发送");
|
||
Thread.Sleep(new Random(Guid.NewGuid().GetHashCode()).Next(sleepmin, sleepmax));
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
this.OnLog("!!" + ex.Message);
|
||
}
|
||
});
|
||
Thread.Sleep(10);
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
this.OnLog(ex.Message);
|
||
e.Send(ex, -1);
|
||
}
|
||
}
|
||
|
||
private int getnum(int count, int min, int max)
|
||
{
|
||
var num = 0;//执行的数量
|
||
var random = new Random(Guid.NewGuid().GetHashCode());
|
||
if (count >= max)//随机获取min max的区间值
|
||
num = random.Next(min, max);
|
||
else if (count <= min)//执行count数量
|
||
num = count;
|
||
else//随机获取min count的区间值
|
||
num = random.Next(min, count);
|
||
return num;
|
||
}
|
||
|
||
private int getInt(string intStr)
|
||
{
|
||
int result = 0;
|
||
int.TryParse(intStr, out result);
|
||
return result;
|
||
}
|
||
|
||
|
||
}
|
||
}
|