484 lines
34 KiB
C#
484 lines
34 KiB
C#
using Api.Framework;
|
|
using Api.Framework.Enums;
|
|
using Api.Framework.Model;
|
|
using Api.Framework.SDK;
|
|
using Api.Framework.Tools;
|
|
using Chat.Framework.WXSdk;
|
|
using Chat.Framework.WXSdk.Implement;
|
|
using CsharpHttpHelper;
|
|
using CsharpHttpHelper.Enum;
|
|
using System;
|
|
using System.Collections;
|
|
using System.Collections.Generic;
|
|
using System.Drawing;
|
|
using System.Drawing.Imaging;
|
|
using System.IO;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Text.RegularExpressions;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Weixin.AccurateCircle.Entitys;
|
|
using Weixin.AccurateCircle.Properties;
|
|
|
|
namespace Weixin.AccurateCircle
|
|
{
|
|
public class MonitorThread : TimerTask
|
|
{
|
|
|
|
private string cache_key = "weixin_accurateCircle_cache_key";
|
|
|
|
public override void Run(object state, bool timedOut)
|
|
{
|
|
|
|
#region 定时清空采集的数据
|
|
if (!string.IsNullOrWhiteSpace(Class1.Config.AutoClearTaskTimes))
|
|
{
|
|
if (Class1.Config.Auto_IsClear == SwitchType.开启)
|
|
{
|
|
try
|
|
{
|
|
if (DateTime.Now.AddSeconds(-3).ToString("HHmm") == DateTime.Parse(Class1.Config.AutoClearTaskTimes).ToString("HHmm"))
|
|
{
|
|
var session = ApiClient.GetSession();
|
|
session.Deleteable<fl_plugin_accuratecircle_dataInfos>().ExecuteCommand();
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, "定时清理异常" + ex.Message + "-" + ex.StackTrace);
|
|
}
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
#region
|
|
try
|
|
{
|
|
#region 采集
|
|
if (Class1.Config.DownTime.AddMinutes(Class1.Config.DownInterval) < DateTime.Now)
|
|
{
|
|
Task.Run(() =>
|
|
{
|
|
try
|
|
{
|
|
var url = string.IsNullOrWhiteSpace(Class1.Config.DownUrl) ? string.Empty : System.IO.Path.Combine(Class1.Config.DownUrl, "api", "circle", "gettask").Replace(@"\", "/");
|
|
if (string.IsNullOrWhiteSpace(url)) return;
|
|
var html = string.Empty;
|
|
HttpHelper http = new HttpHelper();
|
|
HttpItem item = new HttpItem()
|
|
{
|
|
URL = url,
|
|
Method = "post",
|
|
Postdata = $"taskid={Class1.Config.DownID}",
|
|
Timeout = 100000,
|
|
ReadWriteTimeout = 30000,
|
|
UserAgent = "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)",
|
|
ContentType = "application/x-www-form-urlencoded",
|
|
Allowautoredirect = false
|
|
};
|
|
var result = http.GetHtml(item);
|
|
html = result.Html;
|
|
|
|
if (!string.IsNullOrWhiteSpace(html))
|
|
{
|
|
var dic = HttpExtend.JsonToDictionary(html);
|
|
if (dic == null) throw new Exception($"请求采集失败! {html}");
|
|
|
|
if (dic.ContainsKey("Data"))
|
|
{
|
|
var data = dic["Data"] as Dictionary<string, object>;
|
|
if (data.ContainsKey("data"))
|
|
{
|
|
long maxId = 0;//获取最大的id
|
|
var list = new List<fl_plugin_accuratecircle_dataInfos>();
|
|
var _data = data["data"] as ArrayList;
|
|
foreach (Dictionary<string, object> temp in _data)
|
|
{
|
|
var datainfo = temp.ConvertToObj<fl_plugin_accuratecircle_dataInfos>();
|
|
if (datainfo != null)
|
|
{
|
|
datainfo.state = StateType.未推广;
|
|
datainfo.cur_time = DateTime.Now;
|
|
list.Add(datainfo);
|
|
if (maxId < datainfo.id) maxId = datainfo.id;
|
|
}
|
|
}
|
|
var _session = ApiClient.GetSession();
|
|
_session.Saveable(list).ExecuteCommand();
|
|
Class1.Config.DownID = maxId;
|
|
Class1.Config.DownTime = DateTime.Now;
|
|
Util.Save(Class1.Config);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"精准朋友圈采集异常：{ex.Message} - {ex.StackTrace}");
|
|
}
|
|
});
|
|
}
|
|
#endregion
|
|
|
|
#region 发送
|
|
var session = ApiClient.GetSession();
|
|
var datainfos = session.Queryable<fl_plugin_accuratecircle_dataInfos>().OrderBy(f => f.Sendtime, SqlSugar.OrderByType.Asc).Where(f => f.state == StateType.未推广).ToList();
|
|
|
|
datainfos = datainfos.Where(f => f.Sendtime.ToString("HHmm") == DateTime.Now.ToString("HHmm")).ToList();
|
|
|
|
foreach (var datainfo1 in datainfos)
|
|
{
|
|
if (datainfo1 != null)
|
|
{
|
|
var result = ApiClient.Cache.Get<List<long>>(cache_key);
|
|
if (result != null && result.Contains(datainfo1.id)) return;
|
|
var task_time = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + datainfo1.Sendtime.ToString(" HH:mm:ss"));
|
|
var now = DateTime.Now;
|
|
var dValue = (now - task_time).TotalMinutes;
|
|
if (0 < dValue && dValue < 5)
|
|
{
|
|
if (result == null) result = new List<long>();
|
|
result.Add(datainfo1.id);
|
|
ApiClient.Cache.Set(cache_key, result, 5);
|
|
var clients = Chat.Framework.ChatClient.WXClient;
|
|
|
|
var tbAnalysis = new TBHelper.TbAnalysis();
|
|
|
|
var jsonData = "{\"data\":" + datainfo1.AdditionalPic + "}";
|
|
|
|
#region 用户设置的附加图片
|
|
StringBuilder strbImage = new StringBuilder();
|
|
var dicData = HttpExtend.JsonToDictionary(jsonData);
|
|
if (dicData != null && dicData.ContainsKey("data"))
|
|
{
|
|
var arrFileName = dicData["data"] as ArrayList;
|
|
HttpHelper http = new HttpHelper();
|
|
foreach (string fileName in arrFileName)
|
|
{
|
|
try
|
|
{
|
|
var image = Util.MapFile(fileName, @"Cache\image");
|
|
var url = string.IsNullOrWhiteSpace(Class1.Config.DownUrl) ? string.Empty : Path.Combine(Class1.Config.DownUrl, fileName).Replace(@"\", "/");
|
|
if (!string.IsNullOrWhiteSpace(url))
|
|
{
|
|
HttpItem item = new HttpItem()
|
|
{
|
|
URL = url,
|
|
Method = "get",
|
|
IsToLower = false,
|
|
Timeout = 100000,
|
|
ReadWriteTimeout = 30000,
|
|
UserAgent = "Mozilla/5.0 (compatible; MSIE 9.0; Windows NT 6.1; Trident/5.0)",
|
|
ContentType = "text/html",
|
|
Allowautoredirect = false,
|
|
ResultType = ResultType.Byte
|
|
};
|
|
var resule_ = http.GetHtml(item);
|
|
var bytes = resule_.ResultByte;
|
|
var flag = byteArrayToImage(bytes, image);
|
|
strbImage.Append($"[图片={image}]");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{ }
|
|
}
|
|
}
|
|
#endregion
|
|
|
|
foreach (var client in clients.Values)
|
|
{
|
|
try
|
|
{
|
|
if (client.WeixinType == WeixinType.Grpc微信 && client.Status == WxStatus.在线)
|
|
{
|
|
if (!string.IsNullOrWhiteSpace(datainfo1.Data))
|
|
{
|
|
StringBuilder strb = new StringBuilder();
|
|
strb.Append(datainfo1.Content);
|
|
|
|
jsonData = "{\"data\":" + datainfo1.Data + "}";
|
|
dicData = HttpExtend.JsonToDictionary(jsonData);
|
|
if (dicData != null && dicData.ContainsKey("data"))
|
|
{
|
|
var arr = dicData["data"] as ArrayList;
|
|
foreach (Dictionary<string, object> item in arr)
|
|
{
|
|
var baseInfo = new BaseInfo();
|
|
if (item.ContainsKey("Cps")) baseInfo.Cps = item["Cps"].ToString();
|
|
if (item.ContainsKey("ItemId")) baseInfo.ItemId = item["ItemId"].ToString();
|
|
if (item.ContainsKey("Price")) baseInfo.Price = double.Parse(item["Price"].ToString());
|
|
if (item.ContainsKey("ItemTitle")) baseInfo.ItemTitle = item["ItemTitle"].ToString();
|
|
if (item.ContainsKey("conupon_url")) baseInfo.conupon_url = item["conupon_url"].ToString();
|
|
if (item.ContainsKey("Notice")) baseInfo.Notice = item["Notice"].ToString();
|
|
if (item.ContainsKey("conupon_price")) baseInfo.conupon_price = double.Parse(item["conupon_price"].ToString());
|
|
if (item.ContainsKey("Images"))
|
|
{
|
|
var _images = new List<string>();
|
|
var images = item["Images"] as ArrayList;
|
|
foreach (string image in images)
|
|
{
|
|
_images.Add(image);
|
|
}
|
|
baseInfo.Images = _images;
|
|
}
|
|
|
|
if (baseInfo != null)
|
|
{
|
|
var robot = session.FindRobots().FirstOrDefault(f => f.name == client.WeixinHao && f.type == ChatType.微信);
|
|
if (robot == null) continue;
|
|
var adzones = session.FindAdzoneInfos().Where(f => !f.onoff && f.custom_type == Resources.SoftwareType && f.robot_id == robot.id);
|
|
if (baseInfo.Cps == "淘宝")
|
|
{
|
|
#region 淘宝
|
|
try
|
|
{
|
|
var adzone = adzones.FirstOrDefault(f => f.alliance_id == (int)CpsType.阿里妈妈);
|
|
if (adzone == null) continue;
|
|
var member = CpsClient.Members.FirstOrDefault(f => f.cpstype == CpsType.阿里妈妈 && f.username == adzone.adzone_pid_cps_name);
|
|
if (member != null)
|
|
{
|
|
var api = CpsClient.CreateAlimamaRequest(member);
|
|
if (api == null) continue;
|
|
|
|
var pict_url = (baseInfo.Images != null && baseInfo.Images.Count != 0) ? baseInfo.Images[0] : string.Empty;
|
|
#region 获取淘口令 tkl
|
|
var tkl = string.Empty;
|
|
try
|
|
{
|
|
var _title = baseInfo.ItemTitle;
|
|
var _pict_url = pict_url;
|
|
tkl = tbAnalysis.FindTKL(baseInfo.conupon_url, _title, _pict_url, api);
|
|
if (string.IsNullOrEmpty(tkl))
|
|
{
|
|
for (int i = 0; i <= 3; i++)
|
|
{
|
|
tkl = tbAnalysis.FindTKL(baseInfo.conupon_url, _title, _pict_url, api);
|
|
if (!string.IsNullOrEmpty(tkl)) break;
|
|
Thread.Sleep(200);
|
|
}
|
|
}
|
|
if (string.IsNullOrEmpty(tkl))
|
|
continue;
|
|
}
|
|
catch (Exception ex)
|
|
{ }
|
|
#endregion
|
|
var short_url = api.ComposeTbClick(baseInfo.ItemId, pict_url, tkl, baseInfo.conupon_url, true, (int)DwzType.官方短网址);//短连接
|
|
|
|
var image = ApiClient.GetQRImage(baseInfo.ItemTitle, baseInfo.Price.ToString(), baseInfo.conupon_price.ToString(), ((decimal)baseInfo.Price - (decimal)baseInfo.conupon_price).ToString(), pict_url, short_url, ApiClient.QrImageType.模板A, CpsType.阿里妈妈, baseInfo.Notice); //合成附带二维码等信息的宝贝图片
|
|
strb.Append($"[图片={image}]");
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"精确朋友圈淘宝商品解析失败：{ex.Message} - {ex.StackTrace}");
|
|
}
|
|
#endregion
|
|
}
|
|
else if (baseInfo.Cps == "京东")
|
|
{
|
|
#region 京东
|
|
try
|
|
{
|
|
var adzone = session.FindAdzoneInfos().FirstOrDefault(f => f.alliance_id == (int)CpsType.京东联盟 && f.custom_type == Resources.SoftwareType && f.robot_id == robot.id);
|
|
if (adzone != null)
|
|
{
|
|
var member = CpsClient.Members.FirstOrDefault(f => f.cpstype == CpsType.京东联盟 && f.username == adzone.adzone_pid_cps_name);
|
|
if (member != null)
|
|
{
|
|
var api = CpsClient.CreateJingdongRequest(member);
|
|
if (api == null) { return; }
|
|
|
|
var buyshorturl = string.Empty; //转连后的地址
|
|
Dictionary<string, object> conversionlinkresult = null; //查询到的转换链接对象
|
|
var positionId = adzone.adzone_pid.Substring(adzone.adzone_pid.LastIndexOf("_") + 1);
|
|
if (string.IsNullOrWhiteSpace(baseInfo.conupon_url))
|
|
{
|
|
conversionlinkresult = api.SendJingdong("jd.union.open.promotion.byunionid.get", new { promotionCodeReq = new { materialId = $@"https://item.m.jd.com/product/{baseInfo.ItemId}.html", positionId = positionId, unionId = member.usernick } });//宝贝id 和 用户的目标推客的联盟id
|
|
}
|
|
else
|
|
{
|
|
try
|
|
{
|
|
conversionlinkresult = api.SendJingdong("jd.union.open.promotion.byunionid.get", new { promotionCodeReq = new { materialId = $@"https://item.m.jd.com/product/{baseInfo.ItemId}.html", positionId = positionId, unionId = member.usernick, couponUrl = baseInfo.conupon_url } });
|
|
}
|
|
catch (Exception)
|
|
{
|
|
conversionlinkresult = api.SendJingdong("jd.union.open.promotion.byunionid.get", new { promotionCodeReq = new { materialId = $@"https://item.m.jd.com/product/{baseInfo.ItemId}.html", positionId = positionId, unionId = member.usernick } });//宝贝id 和 用户的目标推客的联盟id
|
|
}
|
|
}
|
|
if (conversionlinkresult != null)
|
|
{
|
|
if (conversionlinkresult["code"].ToString() != "200") throw new Exception($"京东查询接口调用失败:{conversionlinkresult["message"].ToString()}");//抛出错误信息
|
|
if (conversionlinkresult.ContainsKey("data"))
|
|
{
|
|
var data = conversionlinkresult["data"] as Dictionary<string, object>;
|
|
if (data.ContainsKey("shortURL"))
|
|
buyshorturl = data["shortURL"].ToString();//购买短连接
|
|
}
|
|
if (string.IsNullOrWhiteSpace(buyshorturl)) continue;//京东转链失败,请稍后重试
|
|
}
|
|
|
|
var goods_desc = string.IsNullOrWhiteSpace(baseInfo.Notice) ? string.Empty : baseInfo.Notice;
|
|
|
|
var image = ApiClient.GetQRImage(baseInfo.ItemTitle, baseInfo.Price.ToString(), baseInfo.conupon_price.ToString(), ((decimal)baseInfo.Price - (decimal)baseInfo.conupon_price).ToString(), baseInfo.Images[0], buyshorturl, ApiClient.QrImageType.模板A, CpsType.京东联盟, baseInfo.Notice); //合成附带二维码等信息的宝贝图片
|
|
strb.Append($"[图片={image}]");
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"精确朋友圈京东商品解析失败：{ex.Message} - {ex.StackTrace}");
|
|
}
|
|
#endregion
|
|
}
|
|
else if (baseInfo.Cps == "拼多多")
|
|
{
|
|
#region 拼多多
|
|
try
|
|
{
|
|
var adzone = session.FindAdzoneInfos().FirstOrDefault(f => f.alliance_id == (int)CpsType.多多进宝 && f.custom_type == Resources.SoftwareType && f.robot_id == robot.id);
|
|
if (adzone != null)
|
|
{
|
|
var member = CpsClient.Members.FirstOrDefault(f => f.cpstype == CpsType.多多进宝 && f.username == adzone.adzone_pid_cps_name);
|
|
if (member != null)
|
|
{
|
|
string param = $"fl_{robot.name}_{(int)ChatType.微信}_精准朋友圈推广";
|
|
var api = CpsClient.CreatePinduoduoRequest(member);
|
|
if (api == null) { return; }
|
|
try
|
|
{
|
|
var data = new { goods_id_list = $"[{baseInfo.ItemId}]" };
|
|
var obj = api.SendPinduoduo("pdd.ddk.goods.detail", data);
|
|
if (obj == null) throw new Exception("创建拼多多API请求失败");
|
|
//解析商品,获取商品的信息
|
|
var goods_detail_response = obj["goods_detail_response"] as Dictionary<string, object>;
|
|
var goods_details = goods_detail_response["goods_details"] as ArrayList;
|
|
//有查到返利提示
|
|
if (goods_details.Count != 0)
|
|
{
|
|
foreach (var _details in goods_details)
|
|
{
|
|
var details = _details as Dictionary<string, object>;
|
|
var _coupon_discount = double.Parse((details["coupon_discount"] ?? 0).ToString());
|
|
var coupon_discount = _coupon_discount == 0 ? 0 : Math.Round(_coupon_discount / 100.00, 2); //优惠券面额，单位为分
|
|
var pddHelper = new PDDHelper();
|
|
string _temp_param = $"fl_{robot.name}_{(int)ChatType.微信}_精准朋友圈推广";
|
|
//搜索成功有券的情况下
|
|
//if (_coupon_discount != 0)
|
|
//{
|
|
var manyShoppingUrl = pddHelper.GetShoppingUrl(api, new { p_id = adzone.adzone_pid, custom_parameters = _temp_param, goods_id_list = $"[{baseInfo.ItemId}]", multi_group = true, generate_short_url = true, generate_weapp_webview = true, force_duo_id = true });
|
|
|
|
strb.Append($"[图片={ApiClient.GetQRImage(baseInfo.ItemTitle, baseInfo.Price.ToString(), coupon_discount.ToString(), ((decimal)baseInfo.Price - (decimal)coupon_discount).ToString(), baseInfo.Images[0], manyShoppingUrl, ApiClient.QrImageType.模板A, CpsType.多多进宝, baseInfo.Notice)}]");
|
|
//}
|
|
}
|
|
}
|
|
}
|
|
catch
|
|
{ }
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"精确朋友圈拼多多商品解析失败：{ex.Message} - {ex.StackTrace}");
|
|
}
|
|
#endregion
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
strb.Append(strbImage.ToString());
|
|
EventClient.OnEvent(this, "定时任务：" + client.WeixinHao + "：准备发了");
|
|
var json = client.SendCircle(strb.ToString());//发送朋友圈的主内容
|
|
if (string.IsNullOrWhiteSpace(json))
|
|
EventClient.OnEvent(this, "定时任务：" + client.WeixinHao + "：发送失败");
|
|
else
|
|
EventClient.OnEvent(this, "定时任务：" + client.WeixinHao + "：已经发了");
|
|
var reg = Regex.Match(json.Replace("<![CDATA[", "").Replace("]]>", ""), @"<id>(?<id>\d{15,})</id>");//获取返回的朋友圈id
|
|
if (reg.Success)
|
|
{
|
|
var id = reg.Groups["id"].Value;
|
|
if (!string.IsNullOrWhiteSpace(datainfo1.Comment))
|
|
client.SendCircleComment(client.User.Username, id, datainfo1.Comment);
|
|
}
|
|
datainfo1.state = StateType.已推广;
|
|
session.Saveable(datainfo1).ExecuteCommand();
|
|
}
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"朋友圈工具 - 定时发送任务：{ex.Message},{ex.StackTrace}");
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
#endregion
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
EventClient.OnEvent(this, $"{ex.Message} - {ex.StackTrace}");
|
|
}
|
|
#endregion
|
|
|
|
}
|
|
|
|
/// <summary>
|
|
/// 字节数组生成图片
|
|
/// </summary>
|
|
/// <param name="Bytes">字节数组</param>
|
|
/// <returns>图片</returns>
|
|
private bool byteArrayToImage(byte[] Bytes, string fileName)
|
|
{
|
|
Stream ms = null;
|
|
try
|
|
{
|
|
ms = new MemoryStream(Bytes);
|
|
return StreamToFile(ms, fileName);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
return false;
|
|
}
|
|
finally
|
|
{
|
|
if (ms != null)
|
|
{
|
|
ms.Close();
|
|
ms.Dispose();
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 将Stream写入文件
|
|
/// </summary>
|
|
/// <param name="stream"></param>
|
|
/// <param name="path"></param>
|
|
public bool StreamToFile(Stream stream, string path)
|
|
{
|
|
try
|
|
{
|
|
byte[] bytes = new byte[stream.Length]; // 把Stream转换成byte[]
|
|
stream.Read(bytes, 0, bytes.Length);
|
|
stream.Seek(0, SeekOrigin.Begin); // 设置当前流的位置为流的开始
|
|
FileStream fs = new FileStream(path, FileMode.Create); // 把byte[]写入文件
|
|
BinaryWriter bw = new BinaryWriter(fs);
|
|
bw.Write(bytes);
|
|
bw.Close();
|
|
fs.Close();
|
|
}
|
|
catch (Exception)
|
|
{
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
|
|
}
|
|
}
|