using Dapper;
|
using Newtonsoft.Json;
|
using System;
|
using System.Collections.Generic;
|
using System.IO;
|
using System.Linq;
|
using System.Net;
|
using System.Net.Http;
|
using System.Net.Http.Headers;
|
using System.Text;
|
using System.Web.Http;
|
using VueWebApi.Models;
|
using VueWebApi.Tools;
|
using VueWebApi.Util;
|
|
namespace VueWebApi.Controllers
|
{
|
[RoutePrefix(prefix: "api/Message")]
|
[ControllerGroup("T8授权管理", "在线接口")]
|
public class MessageController : ApiController
|
{
|
public static ToMessage mes = new ToMessage(); //定义全局返回信息对象
|
|
[Route(template: "OAuth")]
|
[HttpGet]
|
public string OAuth(string code, string state)
|
{
|
Console.WriteLine($"Code:{code}");
|
LogHelper.WriteLogData("code:" + code);
|
return code;
|
}
|
|
[Route(template: "Receive")]
|
[HttpPost]
|
public dynamic Receive([FromBody] ChanjetEncryptMsg encryptMsg)
|
{
|
string enMsg = encryptMsg.GetEncryptMsg();
|
LogHelper.WriteLogData("解密前的消息enMsg:" + enMsg);
|
Console.WriteLine($"解密前的消息{enMsg}");
|
String decryptMsg = OpenapiHelper.AesDecrypt(enMsg, config.Key_encryptKey);
|
LogHelper.WriteLogData2("解密后消息:" + decryptMsg);
|
Console.WriteLine($"解密前的消息{enMsg}");
|
|
MessageBase message = JsonConvert.DeserializeObject<MessageBase>(decryptMsg);
|
object retObj = null;
|
try
|
{
|
switch (message.msgType)
|
{
|
case "APP_TEST":
|
LogHelper.WriteLogData("消息类型msgType:" + message.msgType);
|
retObj = DealTestMsg(message);
|
break;
|
case "APP_TICKET":
|
LogHelper.WriteLogData("消息类型msgType:" + message.msgType);
|
retObj = DealTicketMsg(message);
|
break;
|
case "TEMP_AUTH_CODE":
|
LogHelper.WriteLogData("消息类型msgType:" + message.msgType);
|
retObj = DealOrgTempAuthMsg(message);
|
break;
|
case "PAY_ORDER_SUCCESS":
|
LogHelper.WriteLogData("消息类型msgType:" + message.msgType);
|
retObj = DealOrderPayMsg(message);
|
break;
|
default:
|
break;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return retObj;
|
}
|
|
private object DealOrderPayMsg(MessageBase message)
|
{
|
//throw new NotImplementedException();
|
Dictionary<string, string> dic = new Dictionary<string, string>
|
{
|
{ "result","success"}
|
};
|
return dic;
|
}
|
|
private object DealOrgTempAuthMsg(MessageBase message)
|
{
|
LogHelper.WriteLogData("开始OrgTempAuthContent");
|
OrgTempAuthContent content = JsonConvert.DeserializeObject<OrgTempAuthContent>(message.bizContent.ToString());
|
Console.WriteLine($"OrgTempAuthCode:{content.tempAuthCode}");
|
LogHelper.WriteLogData("结束OrgTempAuthContent");
|
return $"OrgTempAuthCode:{content.tempAuthCode}";
|
}
|
|
private object DealTicketMsg(MessageBase message)
|
{
|
LogHelper.WriteLogData("开始AppTicket");
|
AppTicketContent content = JsonConvert.DeserializeObject<AppTicketContent>(message.bizContent.ToString());
|
LogHelper.WriteLogData($"AppTicket:{content.appTicket}");
|
LogHelper.WriteLogData("结束AppTicket");
|
|
var dynamicParams = new DynamicParameters();
|
var sql = @"update T_AppTicket set AppTicket=@AppTicket,lm_date=@lm_date";
|
dynamicParams.Add("@AppTicket", content.appTicket);
|
dynamicParams.Add("@lm_date", DateTime.Now.ToString());
|
int cont = DapperHelper.SQL(sql, dynamicParams);
|
if (cont > 0)
|
{
|
Dictionary<string, string> dic = new Dictionary<string, string>
|
{
|
{ "result","success"}
|
};
|
return dic;
|
}
|
else
|
{
|
Dictionary<string, string> dic = new Dictionary<string, string>
|
{
|
{ "result","success"}
|
};
|
return dic;
|
}
|
}
|
|
private object DealTestMsg(MessageBase message)
|
{
|
Dictionary<string, string> dic = new Dictionary<string, string>
|
{
|
{ "result","success"}
|
};
|
LogHelper.WriteLogData1(JsonConvert.SerializeObject(dic));
|
return dic;
|
}
|
|
/// <summary>
|
/// 获取AppTicket
|
/// </summary>
|
/// <returns></returns>
|
[Route(template: "AppTicketSelect")]
|
[HttpGet]
|
public HttpResponseMessage AppTicketSelect()
|
{
|
string sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//获取车间下拉框数据
|
sql = @"select * from T_AppTicket ";
|
var data = DapperHelper.selecttable(sql);
|
if (data.Rows.Count > 0)
|
{
|
mes.code = "200";
|
mes.Message = "查询成功!";
|
mes.data = data;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.Message = "查询失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return TJson.toJson(mes);
|
}
|
|
}
|
}
|
