using CommonUtil;
using CommonUtil.RabbitMQ;
using DbAccess;
using Microsoft.AspNetCore.Http;
using Operater.DTO.TopMessage;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Api.MessageReceive.Service
{
    public class YzMessageService
    {
        public static ISysSqlHelper dbMain = SysSqlHelper.CreateSqlHelper("db_main");
        public async static Task<bool> ServiceExecute(IHttpContextAccessor _accessor, YouZanMsgModel youZanMsgModel)
        {
            //防伪签名 
            string eventSign = _accessor.HttpContext.Request.Headers["Event-Sign"].ToString();
            string eventType = _accessor.HttpContext.Request.Headers["Event-Type"].ToString();
            string clientId = _accessor.HttpContext.Request.Headers["Client-Id"].ToString();
            string msg = JSONUtil.ObjectToJson(youZanMsgModel);
            //string clentSecret = "63763d1e16db3ed134fc017663b22469";
            ////判断消息是否合法
            //string sign = SecurityUtil.MD5Encrypt(clientId + JSONUtil.ObjectToJson(youZanMsgModel) + clentSecret, false);
            //if (!sign.Equals(eventSign))
            //{//消息不合法
            //    LogUtil.Info($"官方eventSign：{eventSign},计算sign:{sign}", "不合法");
            //    return false;
            //}
            string decryptMsg = youZanMsgModel.msg.ToUrlDecode();
            //消息入库
            string inserSql = $"insert into yz_msg_history(id,event_type,msg_body,create_time,msg_sign,msg_decrypt)values('{youZanMsgModel.msg_id}','{eventType}','{msg}',now(),'{youZanMsgModel.id}','{decryptMsg}')";
            dbMain.ExecuteNonQuery(inserSql);
            TradeMqMessage tradeMqMessage = new TradeMqMessage()
            {
                MsgType = "yz_trade",
                MsgBody = msg
            };


            string ret = MQClientFullChannel.SendMessageStatic(0, "trade_interflow", JSONUtil.ObjectToJson(tradeMqMessage));
            if (ret != "ok")
            {
                LogUtil.Info($"发MQ失败：{youZanMsgModel.msg_id}", "处理失败");
            }

            return true;
        }
    }
}