8402134
/
old_flsystem
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Merge branch 'master' of https://gitea.api.52cmg.cn/8402134/old_flsystem

This commit is contained in:
老道 2022-10-25 09:11:42 +08:00
parent bfd2b3e95c 0e85ee16d9
commit 0501164b48
11 changed files with 1240 additions and 56 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

207
FLSystem/Forms/main.cs
View File

@ -35,6 +35,7 @@ using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using DevExpress.Data.Helpers;
using Microsoft.Win32;
using UI.Framework.Controls;
using UI.Framework.Forms;
@ -100,6 +101,8 @@ namespace FLSystem.Forms
{
try
{
//var ss = ApiClient.ShortURL("https://detail.tmall.com/item.htm?spm=a230r.1.14.16.11f547a36SIAOY&id=526234772827&ns=1&abbucket=1", DwzType.官方短网址).Result;
DevExpress.UserSkins.BonusSkins.Register();
DevExpress.Skins.SkinManager.EnableFormSkins();
@ -394,7 +397,6 @@ namespace FLSystem.Forms
timerLok.Interval = 5 * 60000;//测试1分钟锁屏
timerLok.Start();
#region 激活抖音xxx
//TODO 禁用抖音禁用
//if (StartDy == "1")
@ -573,8 +575,8 @@ namespace FLSystem.Forms
System.Timers.Timer timer = new System.Timers.Timer();
timer.Elapsed += Timer_Elapsed;
timer.Interval = 40 * 60 * 1000;
//timer.Interval = 1000;
timer.Interval = 60 * 60 * 1000;
//timer.Interval = 1000 * 10;
timer.Start();
//下载黑名单
@ -961,7 +963,27 @@ namespace FLSystem.Forms
bool isinsert = user.id == 0 ? true : false;
session.SaveOrUpdate(user);
if (isinsert) EventClient.OnEvent(this, MethodType.刷新机器人);
if (isinsert)
{
try
{
var result = UserRobotUpLoad.CustomerLink_UpLoadRobot(new List<UserRobotUpLoad.CustomerRobotInput>()
{
new UserRobotUpLoad.CustomerRobotInput()
{
HeadUrl = string.Empty,
NickName = user.nick,
Remark = user.remark,
RobotType = UserRobotUpLoad.ConvertRobotType(user.type),
UserName = user.name
}
});
}
catch (Exception e)
{ }
EventClient.OnEvent(this, MethodType.刷新机器人);
}
}
}
catch { }
@ -1098,7 +1120,26 @@ namespace FLSystem.Forms
bool isinsert = user.id == 0 ? true : false;
session.SaveOrUpdate(user);
if (isinsert) EventClient.OnEvent(this, MethodType.刷新机器人);
if (isinsert)
{
try
{
var result = UserRobotUpLoad.CustomerLink_UpLoadRobot(new List<UserRobotUpLoad.CustomerRobotInput>()
{
new UserRobotUpLoad.CustomerRobotInput()
{
HeadUrl = string.Empty,
NickName = user.nick,
Remark = user.remark,
RobotType = UserRobotUpLoad.ConvertRobotType(user.type),
UserName = user.name
}
});
}
catch (Exception e)
{ }
EventClient.OnEvent(this, MethodType.刷新机器人);
}
}
}
catch { }
@ -2372,51 +2413,149 @@ namespace FLSystem.Forms
isrun = true;
try
{
var h = DateTime.Now.Hour; if (!(1 <= h && h < 3))
return;
try
{
var robots = ChatClient.WXClient.Values.Where(f => f.Status == WxStatus.在线).ToList();
foreach (var robot in robots)
var h = DateTime.Now.Hour; if (!(1 <= h && h < 3))
return;
Console.WriteLine();
//没赋值的头像赋值
try
{
try
var robots = ChatClient.WXClient.Values.Where(f => f.Status == WxStatus.在线).ToList();
foreach (var robot in robots)
{
var db = ApiClient.GetSession();
var members = db.Find<fl_member_info>("select * from fl_member_info where robot_name = @robotname and headurl = @headurl", new { robotname = robot.WeixinHao, headurl = "" });
var friends = robot.Friends;
foreach (var member in members)
try
{
if (friends != null && friends.ContainsKey(member.username))
var db = ApiClient.GetSession();
var members = db.Find<fl_member_info>("select * from fl_member_info where robot_name = @robotname and headurl = @headurl", new { robotname = robot.WeixinHao, headurl = "" });
var friends = robot.Friends;
foreach (var member in members)
{
var headurl = friends[member.username].BigHeadImgUrl;
if (!string.IsNullOrWhiteSpace(headurl))
if (friends != null && friends.ContainsKey(member.username))
{
member.headurl = friends[member.username].BigHeadImgUrl;
db.SaveOrUpdate(member);
}
}
else
{
var f = robot.GetContact(member.username);
if (f != null)
{
if (!string.IsNullOrWhiteSpace(f.BigHeadImgUrl))
var headurl = friends[member.username].BigHeadImgUrl;
if (!string.IsNullOrWhiteSpace(headurl))
{
member.headurl = f.BigHeadImgUrl;
member.headurl = friends[member.username].BigHeadImgUrl;
db.SaveOrUpdate(member);
}
}
else
{
var f = robot.GetContact(member.username);
if (f != null)
{
if (!string.IsNullOrWhiteSpace(f.BigHeadImgUrl))
{
member.headurl = f.BigHeadImgUrl;
db.SaveOrUpdate(member);
}
}
}
}
}
catch (Exception ex)
{ }
}
}
catch (Exception exception)
{ }
//上传用户/机器人信息
try
{
var db = ApiClient.GetSession();
var upload = db.FindSingle<fl_upload_record>("select * from fl_upload_record");
if (upload == null)
{
upload = new fl_upload_record();
var userNumber = db.Queryable<fl_member_info>().Count();
upload.usernumber = userNumber;
db.Saveable(upload).ExecuteCommand();
}
if (!upload.usersuccess)
{
var pageSize = 100;
while (upload.userindex * pageSize < upload.usernumber)
{
var members = db.Queryable<fl_member_info>().OrderBy(f => f.id).ToPageList(upload.userindex, pageSize);
List<UserRobotUpLoad.CustomerLinkInput> list = new List<UserRobotUpLoad.CustomerLinkInput>();
foreach (var item in members)
{
list.Add(new UserRobotUpLoad.CustomerLinkInput()
{
CreateTime = item.crt_time,
HeadUrl = item.headurl,
NickName = item.usernick,
Remark = item.remark,
RobotName = item.robot_name,
RobotType = UserRobotUpLoad.ConvertRobotType(item.robot_type),
UserName = item.username
});
}
if (list.Count > 0)
{
var result = UserRobotUpLoad.CustomerLink_UpLoadLink(list);
if (result.Ok)
{
db.Saveable(upload).ExecuteCommand();
}
}
upload.userindex++;
Thread.Sleep(1000);
}
if (upload.userindex * pageSize >= upload.usernumber)
{
upload.usersuccess = true;
db.Saveable(upload).ExecuteCommand();
}
}
catch (Exception ex)
{ }
if (!upload.robotsuccess)
{
try
{
var robots = db.Find<fl_robot_info>("select * from fl_robot_info");
List<UserRobotUpLoad.CustomerRobotInput> list = new List<UserRobotUpLoad.CustomerRobotInput>();
foreach (var item in robots)
{
list.Add(new UserRobotUpLoad.CustomerRobotInput()
{
HeadUrl = string.Empty,
NickName = item.nick,
Remark = item.remark,
RobotType = UserRobotUpLoad.ConvertRobotType(item.type),
UserName = item.name
});
}
if (list.Count > 0)
{
var result = UserRobotUpLoad.CustomerLink_UpLoadRobot(list);
if (result.Ok)
{
upload.robotsuccess = true;
}
}
}
catch (Exception ex)
{
upload.robotsuccess = false;
}
db.Saveable(upload).ExecuteCommand();
}
}
catch (Exception ex)
{
}
}
catch (Exception exception)
{ }
}
catch (Exception ex)
{ }

1
PCRobot/PCRobot.csproj
View File

@ -211,6 +211,7 @@
<Compile Include="Utils\ProtoBufExtension.cs" />
<Compile Include="Utils\RegistryHelper.cs" />
<Compile Include="Utils\UpdateClient.cs" />
<Compile Include="Utils\WeChatActivateHelper.cs" />
<Compile Include="Utils\WechatExtend.cs" />
<Compile Include="Utils\ZipArchive.cs" />
<Compile Include="Utils\ZIP\BZip2\BZip2.cs" />

45
PCRobot/PCRobotForm.cs
View File

@ -14,6 +14,7 @@ using System.Threading.Tasks;
using System.Windows.Forms;
using PCRobot.PCWechat.Enterprise;
using PCRobot.PCWechat.Routine;
using WechatHelper;
namespace PCRobot
{
@ -38,6 +39,14 @@ namespace PCRobot
private void PCRobotForm_Load(object sender, EventArgs e)
{
try
{
WeChatActivateHelper.Init(TimeSpan.FromMinutes(20));
}
catch (Exception exception)
{ }
try
{
//Common.MainExeHandle = this.Handle;
@ -84,7 +93,6 @@ namespace PCRobot
IniData();
this.label5.Text = "版本：" + Common.CurVersion;
//MessageBox.Show("版本：" + Common.CurVersion);
if (string.IsNullOrWhiteSpace(Config.GetValue("设置", "静态")))
{
@ -148,25 +156,26 @@ namespace PCRobot
MessageBox.Show("异常 = " + ex.Message + " --- " + ex.StackTrace);
}
try
{
//自动切换聊天对象
var th = new Thread(OnHandle);
th.IsBackground = true;
th.Start();
//切换窗口
var th1 = new Thread(OnActivationHandle);
th1.IsBackground = true;
th1.Start();
//try
//{
// //自动切换聊天对象
// var th = new Thread(OnHandle);
// th.IsBackground = true;
// th.Start();
//发送消息
var th2 = new Thread(OnSendHandle);
th2.IsBackground = true;
th2.Start();
}
catch
{ }
// //切换窗口
// var th1 = new Thread(OnActivationHandle);
// th1.IsBackground = true;
// th1.Start();
// //发送消息
// var th2 = new Thread(OnSendHandle);
// th2.IsBackground = true;
// th2.Start();
//}
//catch
//{ }
}
List<string> userNameList = new List<string>() { "gh_3dfda90e39d6"/*, "gh_7aac992b0363"*/ };

443
PCRobot/Utils/WeChatActivateHelper.cs Normal file
View File

@ -0,0 +1,443 @@
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Forms;
using PCRobot;
namespace WechatHelper
{
/// <summary>
/// 微信激活帮助类
/// </summary>
internal class WeChatActivateHelper
{
#region WIN32 API函数
[DllImport("User32.dll", EntryPoint = "SendMessage")]
private static extern int SendMessage(IntPtr hWnd, int msg, int wParam, int lParam);
/// <summary>
/// 聚焦
/// </summary>
/// <param name="hWnd"></param>
/// <returns></returns>
[DllImport("user32.dll", EntryPoint = "SetFocus")]
private static extern IntPtr SetFocus(IntPtr hWnd);
/// <summary>
/// 判断是否最小化
/// </summary>
/// <param name="hWnd"></param>
/// <returns></returns>
[DllImport("user32.dll")]
private static extern bool IsIconic(IntPtr hWnd);
/// <summary>
/// 判断是否可见
/// </summary>
/// <param name="hWnd"></param>
/// <returns></returns>
[DllImport("user32.dll")]
[return: MarshalAs(UnmanagedType.Bool)]
private static extern bool IsWindowVisible(IntPtr hWnd);
[DllImport("user32.dll", EntryPoint = "ShowWindow", CharSet = CharSet.Auto)]
public static extern int ShowWindow(IntPtr hwnd, int nCmdShow);
/// <summary>
/// 附加线程输入
/// </summary>
/// <param name="idAttach">当前线程</param>
/// <param name="idAttachTo">目标线程</param>
/// <param name="fAttach"></param>
/// <returns></returns>
[DllImport("user32.dll", CharSet = CharSet.Unicode, EntryPoint = "AttachThreadInput", ExactSpelling = true, SetLastError = true)]
private static extern bool AttachThreadInput(IntPtr idAttach, IntPtr idAttachTo, bool fAttach);
//通过句柄获取线程ID
[DllImport("User32.dll", CharSet = CharSet.Auto)]
private static extern IntPtr GetWindowThreadProcessId(IntPtr hwnd, IntPtr id);
[System.Runtime.InteropServices.DllImport("user32.dll")]
private static extern IntPtr FindWindowExA(IntPtr parentHandle, IntPtr childAfter, string lpClassName, string lpWindowName);
[System.Runtime.InteropServices.DllImport("USER32.DLL")]
private static extern bool SetForegroundWindow(IntPtr hWnd);
[System.Runtime.InteropServices.DllImport("user32.dll")]
private static extern bool SetActiveWindow(IntPtr hWnd);
#endregion
/// <summary>
/// 激活窗口
/// </summary>
private static void ActivateWindow(string lpClassName, string lpWindowName)
{
try
{
//主窗口句柄
var handle = IntPtr.Zero;
var handleList = new List<IntPtr>();
do
{
//优先休眠，防止continue未休眠
Thread.Sleep(1000);
//查找窗口句柄并筛选
handle = FindWindowExA(IntPtr.Zero, handle, lpClassName, lpWindowName);
if (handle == IntPtr.Zero)
{
break;
}
if (handleList.Contains(handle))
{
continue;
}
handleList.Add(handle);
var isIconic = IsIconic(handle);
//窗体不可见，视为最小化了
var isWindowVisible = IsWindowVisible(handle);
if (!isWindowVisible)
{
isIconic = true;
}
//窗体不可见，或者最小化了
if (isIconic)
{
ShowWindow(handle, 1);
Thread.Sleep(1000);
}
var thisHandel = Process.GetCurrentProcess().MainWindowHandle;
//获取自己的线程ID
var thisThreadId = GetWindowThreadProcessId(thisHandel, IntPtr.Zero);
var targetThreadId = GetWindowThreadProcessId(handle, IntPtr.Zero);
//如果这里报错，请添加引用PresentationFramework
var cur = _mSynchronizationContext;
if (cur == null)
{
Console.WriteLine("当前线程信息获取失败");
continue;
}
var handle1 = handle;
cur.Send((e) =>
{
try
{
//附加线程
AttachThreadInput(targetThreadId, thisThreadId, true);
SetFocus(handle1);
var setForegroundWindowResult = SetForegroundWindow(handle1);
var setActiveWindow = SetActiveWindow(handle1);
AttachThreadInput(targetThreadId, thisThreadId, false);
LogHelper.GetSingleObj().Debug("激活", $"this={thisThreadId} target={targetThreadId} fore={setForegroundWindowResult} active={setActiveWindow} ");
}
catch (Exception exception)
{
Console.WriteLine(exception);
}
}, null);
//如果微信最小化了，重新让他最小化
if (!isIconic) continue;
Thread.Sleep(1000);
ShowWindow(handle, 2);
} while (true);
}
catch (Exception e)
{
Console.WriteLine($"ActivateWindow Error：{e.Message}\r\nParams：lpClassName={lpClassName} lpWindowName={lpWindowName}");
}
}
/// <summary>
/// 关闭窗口
/// </summary>
private static void CloseWindow(string className, string windowName)
{
int index = 1;
//主窗口句柄
var handle = IntPtr.Zero;
var handleList = new List<IntPtr>();
do
{
try
{
Thread.Sleep(1000);
var rstHandlePtr = FindWindowExA(IntPtr.Zero, handle, className, windowName);
if (handle == IntPtr.Zero) break;
if (handleList.Contains(handle)) break;
handleList.Add(handle);
//找到了，就自动关闭
SendMessage(rstHandlePtr, 0x0010, 0, 0);
}
catch (Exception e)
{
Console.WriteLine($"关闭窗口失败：{e.Message}");
break;
}
index++;
} while (index < 10);
}
/// <summary>
/// 激活微信
/// </summary>
private static void ActivateWeChat()
{
CloseWindow("UpdateWnd", "升级");
ActivateWindow("WeChatMainWndForPC", "微信");
}
private static Thread _thread;
private static SynchronizationContext _mSynchronizationContext;
private static MouseHook _mouse;
private static DateTime _lastActiveTime = DateTime.Now;
/// <summary>
/// 初始化激活器
/// 注：请务必在主线程调用，不要再子线程
/// </summary>
/// <param name="time">多久激活一次</param>
/// <param name="forcedRunHours">强制运行小时</param>
/// <param name="maxCount">总激活次数（0表示无限制）</param>
/// <exception cref="Exception"></exception>
public static bool Init(TimeSpan time, int forcedRunHours = 2, int maxCount = 0)
{
if (_thread != null && _thread.IsAlive)
{
throw new Exception("当前线程尚未结束，请勿重复初始化");
}
if (_mouse == null)
{
_mouse = new MouseHook();
_mouse.OnMouseActivity += _mouse_OnMouseActivity;
_mouse.Start();
}
_mSynchronizationContext = SynchronizationContext.Current;
if (_mSynchronizationContext == null)
{
throw new Exception("获取主线程失败，请不要再子线程执行");
}
_thread = new Thread(() =>
{
int index = 0;
while (true)
{
try
{
//操作鼠标键盘时间较短
var curTime = DateTime.Now;
var interval = curTime - _mouseHeartbeatTime;
var isNext = false;
//超过12小时没有激活过，强制激活一次
if ((curTime - _lastActiveTime).TotalHours > forcedRunHours)
{
isNext = true;
}
//超过了一定时间，没有操作鼠标
else if (interval > time)
{
isNext = true;
}
if (!isNext) continue;
index++;
_lastActiveTime = DateTime.Now;
ActivateWeChat();
if (maxCount != 0 && index >= maxCount)
{
break;
}
}
catch (Exception e)
{
Console.WriteLine($"激活窗口发生异常：{e.Message}");
}
finally
{
Thread.Sleep(time);
}
}
})
{
IsBackground = true
};
_thread.Start();
return true;
}
private static DateTime _mouseHeartbeatTime = DateTime.Now;
private static void _mouse_OnMouseActivity(object sender, MouseEventArgs e)
{
_mouseHeartbeatTime = DateTime.Now;
}
}
internal class MouseHook
{
private const int WM_MOUSEMOVE = 0x200;
private const int WM_LBUTTONDOWN = 0x201;
private const int WM_RBUTTONDOWN = 0x204;
private const int WM_MBUTTONDOWN = 0x207;
private const int WM_LBUTTONUP = 0x202;
private const int WM_RBUTTONUP = 0x205;
private const int WM_MBUTTONUP = 0x208;
private const int WM_LBUTTONDBLCLK = 0x203;
private const int WM_RBUTTONDBLCLK = 0x206;
private const int WM_MBUTTONDBLCLK = 0x209;
//全局的事件
public event MouseEventHandler OnMouseActivity;
static int hMouseHook = 0; //鼠标钩子句柄
//鼠标常量
public const int WH_MOUSE_LL = 14; //mouse hook constant
HookProc MouseHookProcedure; //声明鼠标钩子事件类型.
//声明一个Point的封送类型
[StructLayout(LayoutKind.Sequential)]
public class POINT
{
public int x;
public int y;
}
//声明鼠标钩子的封送结构类型
[StructLayout(LayoutKind.Sequential)]
public class MouseHookStruct
{
public POINT pt;
public int hWnd;
public int wHitTestCode;
public int dwExtraInfo;
}
//装置钩子的函数
[DllImport("user32.dll", CharSet = CharSet.Auto, CallingConvention = CallingConvention.StdCall)]
public static extern int SetWindowsHookEx(int idHook, HookProc lpfn, IntPtr hInstance, int threadId);
//卸下钩子的函数
[DllImport("user32.dll", CharSet = CharSet.Auto, CallingConvention = CallingConvention.StdCall)]
public static extern bool UnhookWindowsHookEx(int idHook);
//下一个钩挂的函数
[DllImport("user32.dll", CharSet = CharSet.Auto, CallingConvention = CallingConvention.StdCall)]
public static extern int CallNextHookEx(int idHook, int nCode, Int32 wParam, IntPtr lParam);
public delegate int HookProc(int nCode, Int32 wParam, IntPtr lParam);
/// <summary>
/// 墨认的构造函数构造当前类的实例.
/// </summary>
public MouseHook()
{
}
//析构函数.
~MouseHook()
{
Stop();
}
public void Start()
{
//安装鼠标钩子
if (hMouseHook == 0)
{
//生成一个HookProc的实例.
MouseHookProcedure = new HookProc(MouseHookProc);
hMouseHook = SetWindowsHookEx(WH_MOUSE_LL, MouseHookProcedure, Marshal.GetHINSTANCE(System.Reflection.Assembly.GetExecutingAssembly().GetModules()[0]), 0);
//如果装置失败停止钩子
if (hMouseHook == 0)
{
Stop();
throw new Exception("SetWindowsHookEx failed.");
}
}
}
public void Stop()
{
bool retMouse = true;
if (hMouseHook != 0)
{
retMouse = UnhookWindowsHookEx(hMouseHook);
hMouseHook = 0;
}
//如果卸下钩子失败
if (!(retMouse)) throw new Exception("UnhookWindowsHookEx failed.");
}
private int MouseHookProc(int nCode, Int32 wParam, IntPtr lParam)
{
//如果正常运行并且用户要监听鼠标的消息
if ((nCode >= 0) && (OnMouseActivity != null))
{
MouseButtons button = MouseButtons.None;
int clickCount = 0;
switch (wParam)
{
case WM_LBUTTONDOWN:
button = MouseButtons.Left;
clickCount = 1;
break;
case WM_LBUTTONUP:
button = MouseButtons.Left;
clickCount = 1;
break;
case WM_LBUTTONDBLCLK:
button = MouseButtons.Left;
clickCount = 2;
break;
case WM_RBUTTONDOWN:
button = MouseButtons.Right;
clickCount = 1;
break;
case WM_RBUTTONUP:
button = MouseButtons.Right;
clickCount = 1;
break;
case WM_RBUTTONDBLCLK:
button = MouseButtons.Right;
clickCount = 2;
break;
}
//从回调函数中得到鼠标的信息
MouseHookStruct MyMouseHookStruct = (MouseHookStruct)Marshal.PtrToStructure(lParam, typeof(MouseHookStruct));
MouseEventArgs e = new MouseEventArgs(button, clickCount, MyMouseHookStruct.pt.x, MyMouseHookStruct.pt.y, 0);
//if(e.X>700)return 1;//如果想要限制鼠标在屏幕中的移动区域可以在此处设置
OnMouseActivity(this, e);
}
return CallNextHookEx(hMouseHook, nCode, wParam, lParam);
}
}
}

2
应用/AutoAnswer/Class1.cs
View File

@ -196,7 +196,7 @@ namespace AutoAnswer
}
#region 呼叫客服
if (Class1.Config.CellCustomerServiceSwitch == Api.Framework.Enums.SwitchType.开启)
if (Class1.Config.CellCustomerServiceSwitch == Api.Framework.Enums.SwitchType.开启 && !issend)
{
if (string.IsNullOrEmpty(e.Groupid)) //私聊信息
{

2
类库/Api.Framework/Api.Framework.csproj
View File

@ -516,6 +516,7 @@
<Compile Include="Model\fl_ratio_info.cs" />
<Compile Include="Model\fl_suning_tgw.cs" />
<Compile Include="Model\fl_tb_relation.cs" />
<Compile Include="Model\fl_upload_record.cs" />
<Compile Include="Model\fl_uservariate_info.cs" />
<Compile Include="Model\fl_wechat_contacts.cs" />
<Compile Include="Model\fl_wechat_device.cs" />
@ -581,6 +582,7 @@
<Compile Include="Tools\HTTPClass.cs" />
<Compile Include="Tools\TBHelper.cs" />
<Compile Include="Tools\UpdateClient.cs" />
<Compile Include="Tools\UserRobotUpLoad.cs" />
<Compile Include="Tools\Util.cs" />
<Compile Include="Properties\AssemblyInfo.cs" />
<Compile Include="Tools\VariateReplace.cs" />

32
类库/Api.Framework/ApiClient.cs
View File

@ -964,7 +964,25 @@ namespace Api.Framework
token = device,
remark = "PCWechat HOOK"
};
s.Insertable<fl_robot_info>(robot).ExecuteCommandIdentityIntoEntity();
robot = s.Insertable<fl_robot_info>(robot).ExecuteReturnEntity();
try
{
var result = UserRobotUpLoad.CustomerLink_UpLoadRobot(new List<UserRobotUpLoad.CustomerRobotInput>()
{
new UserRobotUpLoad.CustomerRobotInput()
{
HeadUrl = string.Empty,
NickName = robot.nick,
Remark = robot.remark,
RobotType = UserRobotUpLoad.ConvertRobotType(robot.type),
UserName = robot.name
}
});
}
catch (Exception e)
{ }
s.FindRobots(true);
}
else
@ -2406,6 +2424,12 @@ namespace Api.Framework
session.AddIndex<fl_suning_tgw>("username", "toolpid");
}
if (!session.TableExist<fl_upload_record>())
{
strb.AppendLine("fl_upload_record");
session.CreateTable<fl_upload_record>();
}
if (!session.TableExist<fl_bind_cache>())
{
strb.AppendLine("fl_bind_cache");
@ -3606,6 +3630,12 @@ namespace Api.Framework
//}
case DwzType.快站短网址:
{
if (CacheTool.GetSingleObj().Exist("KZShortUrl"))
{
type = DwzType.官方短网址;
goto Next;
}
var urlTmp = KuaiZhanShort.GetShort(url);
if (urlTmp == url)
{

35
类库/Api.Framework/Model/ModelExtend.cs
View File

@ -433,13 +433,44 @@ namespace Api.Framework.Model
var m = session.FindSingle<fl_member_info>("select * from fl_member_info where robot_type = @robot_type and username = @username", new { username = e.Username, robot_type = e.ChatType });
if (m == null)
{
m = new fl_member_info() { crt_time = DateTime.Now, usernick = e.NickName, realnick = e.RealNick, robot_name = e.RobotName, robot_type = e.ChatType, username = e.Username, upd_time = DateTime.Now, alipay_name = string.Empty, alipay_num = string.Empty, remark = string.Empty };
m = new fl_member_info()
{
crt_time = DateTime.Now,
usernick = e.NickName,
realnick = e.RealNick,
robot_name = e.RobotName,
robot_type = e.ChatType,
username = e.Username,
upd_time = DateTime.Now,
alipay_name = string.Empty,
alipay_num = string.Empty,
remark = string.Empty
};
var groups = session.FindGroups();
if (groups.Count == 0) throw new Exception("会员组未设置,请先设置会员组!");
if (!string.IsNullOrEmpty(e.RealNick)) m.realnick = e.RealNick;
if (!string.IsNullOrEmpty(e.Wechatid)) m.wechatid = e.Wechatid;
m.group_id = groups[0].id;
session.Insertable(m).ExecuteReturnEntity();
m = session.Insertable(m).ExecuteReturnEntity();
try
{
var result = UserRobotUpLoad.CustomerLink_UpLoadLink(new List<UserRobotUpLoad.CustomerLinkInput>()
{
new UserRobotUpLoad.CustomerLinkInput()
{
CreateTime = m.crt_time,
HeadUrl = m.headurl,
NickName = m.usernick,
Remark = m.remark,
RobotName = m.robot_name,
RobotType = UserRobotUpLoad.ConvertRobotType(m.robot_type),
UserName = m.username
}
});
}
catch (Exception ex)
{ }
}
else
{

31
类库/Api.Framework/Model/fl_upload_record.cs Normal file
View File

@ -0,0 +1,31 @@
using Api.Framework.Tools;
namespace Api.Framework.Model
{
/// <summary>
/// 数据是否上报成功
/// </summary>
public class fl_upload_record : base_model
{
/// <summary>
/// 用户当前的坐标
/// </summary>
public int userindex { get; set; }
/// <summary>
/// 用户数量
/// </summary>
public int usernumber { get; set; }
/// <summary>
/// 用户是否导入完成
/// </summary>
public bool usersuccess { get; set; } = false;
/// <summary>
/// 机器人是否完成
/// </summary>
public bool robotsuccess { get; set; } = false;
}
}

1
类库/Api.Framework/Tools/KuaiZhanShort.cs
View File

@ -63,6 +63,7 @@ namespace Api.Framework.Tools
}
else if ((int)jobj["code"] == 1001)
{
CacheTool.GetSingleObj().Set("KZShortUrl", "", (int)(DateTime.Now.AddDays(1).AddMinutes(5) - DateTime.Now).TotalMinutes);
EventClient.OnEvent("短连接", "由于快站短连接接口请求的额度超限制,正在切换其他短连接");
}
}

497
类库/Api.Framework/Tools/UserRobotUpLoad.cs Normal file
View File

@ -0,0 +1,497 @@
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.ComponentModel.DataAnnotations;
using System.Linq;
using System.Net;
using System.Security.Cryptography;
using System.Text;
using Api.Framework.SDK;
using CsharpHttpHelper;
namespace Api.Framework.Tools
{
/// <summary>
/// 用户/机器人上传
/// </summary>
public class UserRobotUpLoad
{
/// <summary>
/// host
/// </summary>
public static readonly string host = "http://yzinterface.api.52cmg.cn/api/";
public static readonly int appkey = 334391396;
public static readonly string appsecret = "b924f8b944694cb8891bcfc7834dedb533436a3776de472cbde99577337902b2";
public static readonly string appAes = "EDC19B73FEB447929E187243777477913977AB2694394E5B9BC56CD05302C46B";
public static string UserToken { get; set; }
/// <summary>
/// 上传客户信息
/// </summary>
/// <param name="inputs"></param>
/// <returns></returns>
public static ServiceResult CustomerLink_UpLoadLink(List<CustomerLinkInput> inputs)
{
if (inputs == null || inputs.Count <= 0)
{
return new ServiceResult()
{
Ok = true
};
}
return HttpAes("CustomerLink/UpLoadLink", "post", inputs);
}
/// <summary>
/// 上传客户机器人信息
/// </summary>
/// <param name="inputs"></param>
/// <returns></returns>
public static ServiceResult CustomerLink_UpLoadRobot(List<CustomerRobotInput> inputs)
{
if (inputs == null || inputs.Count <= 0)
{
return new ServiceResult()
{
Ok = true
};
}
return HttpAes("CustomerLink/UpLoadRobot", "post", inputs);
}
/// <summary>
/// AES
/// </summary>
/// <typeparam name="T"></typeparam>
/// <param name="api"></param>
/// <param name="method"></param>
/// <param name="postdata"></param>
/// <returns></returns>
private static ServiceResult<T> HttpAes<T>(string api, string method, object postdata = null)
{
try
{
var result = HttpResultAes(api, method, postdata);
if (result.StatusCode == HttpStatusCode.OK)
{
return Newtonsoft.Json.JsonConvert.DeserializeObject<ServiceResult<T>>(result.Html);
}
return new ServiceResult<T>(default(T))
{
Ok = false,
Message = result.Html,
};
}
catch (Exception e)
{
return new ServiceResult<T>(default(T))
{
Ok = false,
Message = e.ToString(),
};
}
}
/// <summary>
/// aes
/// </summary>
/// <param name="api"></param>
/// <param name="method"></param>
/// <param name="postdata"></param>
/// <returns></returns>
private static ServiceResult HttpAes(string api, string method, object postdata = null)
{
try
{
var result = HttpResultAes(api, method, postdata);
if (result.StatusCode == HttpStatusCode.OK)
{
return Newtonsoft.Json.JsonConvert.DeserializeObject<ServiceResult>(result.Html);
}
return new ServiceResult()
{
Ok = false,
Data = result.Html,
};
}
catch (Exception e)
{
return new ServiceResult()
{
Ok = false,
Data = e.ToString(),
};
}
}
/// <summary>
/// http aes
/// </summary>
/// <param name="api"></param>
/// <param name="method"></param>
/// <param name="postdata"></param>
/// <returns></returns>
private static HttpResult HttpResultAes(string api, string method, object postdata = null)
{
var data = Newtonsoft.Json.JsonConvert.SerializeObject(postdata);
var http = new HttpHelper();
HttpItem item = new HttpItem()
{
URL = host + api,
Method = method,
Timeout = 100000,
ReadWriteTimeout = 30000,
IsToLower = false,
Cookie = "",
UserAgent = "Server",
Accept = "text/html, application/xhtml+xml, */*",
ContentType = "application/json",
Referer = "",
Allowautoredirect = false,
AutoRedirectCookie = false,
Postdata = data,
PostEncoding = Encoding.UTF8,
//WebProxy = new WebProxy("127.0.0.1:8888")
};
var timespan = GetTimespan(DateTime.Now);/*DateTimeHelper.DateTimeToTimeStamp(DateTime.Now)*/;
item.Postdata = SecurityHelper.AesEncrypt(item.Postdata, appAes);
var sign = MD5ToString(Encrypt(item.Postdata + appkey + timespan, appsecret, false));
item.Header.Add("sign", sign);
item.Header.Add("timestamp", timespan + "");
item.Header.Add("appkey", appkey + "");
item.Header.Add("UserToken", UserToken);
var result = http.GetHtml(item);
return result;
}
/// <summary>
/// AES加密
/// </summary>
/// <param name="encryptStr">明文</param>
/// <param name="key">密钥</param>
/// <param name="isBase64">是否转为base64（否的情况将采用16进制字符串）</param>
/// <returns></returns>
public static string Encrypt(string encryptStr, string key, bool isBase64 = true, bool is32 = true)
{
byte[] keyArray = Encoding.UTF8.GetBytes(key.Substring(0, is32 ? 32 : 16));
byte[] toEncryptArray = Encoding.UTF8.GetBytes(encryptStr);
RijndaelManaged rDel = new RijndaelManaged();
rDel.Key = keyArray;
rDel.Mode = CipherMode.ECB;
rDel.Padding = PaddingMode.PKCS7;
ICryptoTransform cTransform = rDel.CreateEncryptor();
byte[] resultArray = cTransform.TransformFinalBlock(toEncryptArray, 0, toEncryptArray.Length);
return isBase64
? Convert.ToBase64String(resultArray, 0, resultArray.Length)
: ByteArrayToHexString(resultArray);
}
/// <summary>
/// 将一个byte数组转换成16进制字符串
/// </summary>
/// <param name="data"></param>
/// <returns></returns>
private static string ByteArrayToHexString(byte[] data)
{
StringBuilder sb = new StringBuilder(data.Length * 3);
foreach (byte b in data)
{
sb.Append(Convert.ToString(b, 16).PadLeft(2, '0'));
}
return sb.ToString().ToUpper();
}
public static string MD5ToString(string text)
{
var retVal = new MD5CryptoServiceProvider().ComputeHash(Encoding.Default.GetBytes(text));
return string.Join("", retVal.Select(s => s.ToString("x2")));
}
/// <summary>
/// 时间戳（秒）
/// </summary>
/// <param name="dateTime"></param>
/// <returns></returns>
public static Int64 GetTimespan(DateTime dateTime)
{
TimeSpan ts = dateTime - new DateTime(1970, 1, 1, 0, 0, 0, 0);
return Convert.ToInt64(ts.TotalSeconds);
}
/// <summary>
/// 加密解密帮助类
/// </summary>
public class SecurityHelper
{
#region AES加密解密
/// <summary>
/// 128位处理key
/// </summary>
/// <param name="keyArray">原字节</param>
/// <param name="key">处理key</param>
/// <returns></returns>
private static byte[] GetAesKey(byte[] keyArray, string key)
{
byte[] newArray = new byte[16];
if (keyArray.Length < 16)
{
for (int i = 0; i < newArray.Length; i++)
{
if (i >= keyArray.Length)
{
newArray[i] = 0;
}
else
{
newArray[i] = keyArray[i];
}
}
}
return newArray;
}
/// <summary>
/// 使用AES加密字符串,按128位处理key
/// </summary>
/// <param name="content">加密内容</param>
/// <param name="key">秘钥，需要128位、256位.....</param>
/// <param name="autoHandle">秘钥，需要128位、256位.....</param>
/// <returns>Base64字符串结果</returns>
public static string AesEncrypt(string content, string key, bool autoHandle = true)
{
try
{
byte[] keyArray = Encoding.UTF8.GetBytes(key);
if (autoHandle)
{
keyArray = GetAesKey(keyArray, key);
}
byte[] toEncryptArray = Encoding.UTF8.GetBytes(content);
SymmetricAlgorithm des = Aes.Create();
des.Key = keyArray;
des.Mode = CipherMode.ECB;
des.Padding = PaddingMode.PKCS7;
ICryptoTransform cTransform = des.CreateEncryptor();
byte[] resultArray = cTransform.TransformFinalBlock(toEncryptArray, 0, toEncryptArray.Length);
return Convert.ToBase64String(resultArray);
}
catch
{
return "";
}
}
/// <summary>
/// 使用AES解密字符串,按128位处理key
/// </summary>
/// <param name="content">内容</param>
/// <param name="key">秘钥，需要128位、256位.....</param>
/// <param name="autoHandle">秘钥，需要128位、256位.....</param>
/// <returns>UTF8解密结果</returns>
public static string AesDecrypt(string content, string key, bool autoHandle = true)
{
try
{
byte[] keyArray = Encoding.UTF8.GetBytes(key);
if (autoHandle)
{
keyArray = GetAesKey(keyArray, key);
}
byte[] toEncryptArray = Convert.FromBase64String(content);
SymmetricAlgorithm des = Aes.Create();
des.Key = keyArray;
des.Mode = CipherMode.ECB;
des.Padding = PaddingMode.PKCS7;
ICryptoTransform cTransform = des.CreateDecryptor();
byte[] resultArray = cTransform.TransformFinalBlock(toEncryptArray, 0, toEncryptArray.Length);
return Encoding.UTF8.GetString(resultArray);
}
catch
{
return "";
}
}
/// <summary>
/// 使用AES解密字符串,按128位处理key
/// </summary>
/// <param name="content">内容</param>
/// <param name="key">秘钥，需要128位、256位.....</param>
/// <param name="autoHandle">秘钥，需要128位、256位.....</param>
/// <returns>UTF8解密结果</returns>
public static byte[] AesDecryptByte(string content, string key, bool autoHandle = true)
{
try
{
byte[] keyArray = Encoding.UTF8.GetBytes(key);
if (autoHandle)
{
keyArray = GetAesKey(keyArray, key);
}
byte[] toEncryptArray = Convert.FromBase64String(content);
SymmetricAlgorithm des = Aes.Create();
des.Key = keyArray;
des.Mode = CipherMode.ECB;
des.Padding = PaddingMode.PKCS7;
ICryptoTransform cTransform = des.CreateDecryptor();
byte[] resultArray = cTransform.TransformFinalBlock(toEncryptArray, 0, toEncryptArray.Length);
return resultArray;
}
catch
{
return null;
}
}
#endregion
}
/// <summary>
/// 上传机器人客户信息
/// </summary>
public class CustomerLinkInput
{
/// <summary>
/// 用户名
/// </summary>
[Required]
[DisplayName("用户名")]
public string UserName { get; set; }
/// <summary>
/// 机器人类型0个人微信 1企业微信 2QQ
/// </summary>
[Required]
[DisplayName("机器人类型0个人微信 1企业微信 2QQ")]
public int RobotType { get; set; }
/// <summary>
/// 头像地址
/// </summary>
public string HeadUrl { get; set; }
/// <summary>
/// 昵称
/// </summary>
public string NickName { get; set; }
/// <summary>
/// 备注
/// </summary>
public string Remark { get; set; }
/// <summary>
/// 机器人账号
/// </summary>
[Required]
[DisplayName("机器人账号")]
public string RobotName { get; set; }
/// <summary>
/// 添加时间
/// </summary>
[Required]
public DateTime CreateTime { get; set; }
}
/// <summary>
/// 转换机器人类型
/// </summary>
/// <param name="chatType"></param>
/// <returns></returns>
public static int ConvertRobotType(ChatType chatType)
{
/*
未知来源 = 0,
QQ = 1,
微信 = 2,
微信公众号 = 3,
企业微信 = 4
*/
switch (chatType)
{
case ChatType.QQ:
return 2;
case ChatType.企业微信:
return 1;
case ChatType.微信:
return 0;
case ChatType.微信公众号:
return -1;
case ChatType.未知来源:
return -1;
}
return -1;
}
/// <summary>
/// 上传机器人信息
/// </summary>
public class CustomerRobotInput
{
/// <summary>
/// 用户名
/// </summary>
[Required]
[DisplayName("用户名")]
public string UserName { get; set; }
/// <summary>
/// 机器人类型0个人微信 1企业微信 2QQ
/// </summary>
[Required]
[DisplayName("机器人类型0个人微信 1企业微信 2QQ")]
public int RobotType { get; set; }
/// <summary>
/// 头像地址
/// </summary>
public string HeadUrl { get; set; }
/// <summary>
/// 昵称
/// </summary>
public string NickName { get; set; }
/// <summary>
/// 备注
/// </summary>
public string Remark { get; set; }
}
/// <summary>
/// 统一服务返回结果
/// </summary>
public class ServiceResult
{
/// <summary>
/// 请求是否成功
/// </summary>
public bool Ok { get; set; }
/// <summary>
/// 数据
/// </summary>
public object Data { get; set; }
/// <summary>
/// 错误信息
/// </summary>
public string Message { get; set; }
}
/// <summary>
/// 统一返回结果
/// </summary>
/// <typeparam name="T"></typeparam>
public class ServiceResult<T> : ServiceResult
{
/// <summary>
/// 初始化
/// </summary>
/// <param name="data"></param>
public ServiceResult(T data)
{
this.Data = data;
}
/// <summary>
/// 返回数据
/// </summary>
public new T Data { get; set; }
}
}
}