using System; using System.Collections.Generic; using System.Linq; using Microsoft.AspNetCore.Mvc; using Microsoft.AspNetCore.Http; using Microsoft.Extensions.Logging; using Microsoft.Extensions.Options; using Microsoft.AspNetCore.Authorization; using System.Web; using MySystem.MainModels; using LitJson; using Library; using System.Data; namespace MySystem.Areas.Api.Controllers.v1 { [Area("Api")] [Route("Api/v1/[controller]/[action]")] public class ConsumerOrdersController : BaseController { public ConsumerOrdersController(IHttpContextAccessor accessor, ILogger logger, IOptions setting) : base(accessor, logger, setting) { } #region 商户-经营数据(日) [Authorize] public JsonResult ByDate(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ByDateDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ByDateDo(string value) { JsonData data = JsonMapper.ToObject(value); int MerchantId = int.Parse(function.CheckInt(data["MerchantId"].ToString())); //商户 string Month = data["Month"].ToString(); //月份 int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); DataTable dt = MerchantAmountSummary.Instance.GetTradeListByDate(MerchantId, Month, PageNum, PageSize); foreach (DataRow dr in dt.Rows) { string TradeDate = dr["TradeDate"].ToString(); Dictionary curData = new Dictionary(); curData.Add("Date", TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2)); //日期 curData.Add("TotalAmount", dr[5].ToString()); //营收金额 curData.Add("TotalActual", dr[3].ToString()); //实收金额 curData.Add("WeChatAmount", dr[2].ToString()); //微信实收 curData.Add("AlipayAmount", dr[1].ToString()); //支付宝实收 curData.Add("OrderCount", dr[4].ToString()); //订单数 curData.Add("AddCount", 0); //新增会员 dataList.Add(curData); } return dataList; } #endregion #region 商户-经营数据(月) [Authorize] public JsonResult ByMonth(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ByMonthDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ByMonthDo(string value) { JsonData data = JsonMapper.ToObject(value); int MerchantId = int.Parse(function.CheckInt(data["MerchantId"].ToString())); //商户 int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); DataTable dt = MerchantAmountSummary.Instance.GetTradeListByMonth(MerchantId, PageNum, PageSize); foreach (DataRow dr in dt.Rows) { string TradeDate = dr["TradeMonth"].ToString(); Dictionary curData = new Dictionary(); curData.Add("Date", TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2)); //日期 curData.Add("TotalAmount", dr[5].ToString()); //营收金额 curData.Add("TotalActual", dr[3].ToString()); //实收金额 curData.Add("WeChatAmount", dr[2].ToString()); //微信实收 curData.Add("AlipayAmount", dr[1].ToString()); //支付宝实收 curData.Add("OrderCount", dr[4].ToString()); //订单数 curData.Add("AddCount", 0); //新增会员 dataList.Add(curData); } return dataList; } #endregion #region 商户-经营数据-按月 [Authorize] public JsonResult BussinessRecordForMonth(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = BussinessRecordForMonthDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> BussinessRecordForMonthDo(string value) { JsonData data = JsonMapper.ToObject(value); int MerchantId = int.Parse(function.CheckInt(data["MerchantId"].ToString())); //商户 string Month = data["Month"].ToString(); //月份 int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); DataTable dt = MerchantAmountSummary.Instance.GetTradeListByDate(MerchantId, Month, PageNum, PageSize); foreach (DataRow dr in dt.Rows) { string TradeDate = dr["TradeDate"].ToString(); Dictionary curData = new Dictionary(); curData.Add("Date", TradeDate.Substring(0, 4) + "-" + TradeDate.Substring(4, 2) + "-" + TradeDate.Substring(6, 2)); //日期 curData.Add("TotalAmount", dr[5].ToString()); //营收金额 curData.Add("TotalActual", dr[3].ToString()); //实收金额 curData.Add("WeChatAmount", dr[2].ToString()); //微信实收 curData.Add("AlipayAmount", dr[1].ToString()); //支付宝实收 curData.Add("OrderCount", dr[4].ToString()); //订单数 curData.Add("AddCount", 0); //新增会员 dataList.Add(curData); } return dataList; } #endregion #region 商户-订单列表 [Authorize] public JsonResult ForMer(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ForMerDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ForMerDo(string value) { JsonData data = JsonMapper.ToObject(value); int MerchantId = int.Parse(function.CheckInt(data["MerchantId"].ToString())); //商户 string OrderNo = data["OrderNo"].ToString(); //订单号 string Date = data["Date"].ToString(); //日期 int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); string condition = ""; if (!string.IsNullOrEmpty(data["MerchantId"].ToString())) { condition += " and MerchantId=" + MerchantId; } if (!string.IsNullOrEmpty(data["OrderNo"].ToString())) { condition += " and OrderNo='" + OrderNo + "'"; } List> query = new ConsumerOrdersService().List(new List(), condition, PageNum, PageSize); foreach (var subdata in query) { Dictionary curData = new Dictionary(); curData.Add("OrderNo", subdata["OrderNo"].ToString()); //订单号 curData.Add("PayMode", subdata["PayMode"].ToString()); //支付方式 curData.Add("PayMoney", subdata["PayMoney"].ToString()); //支付金额 curData.Add("ReturnMoney", subdata["ReturnMoney"].ToString()); //已返金额 curData.Add("SnNo", subdata["SnNo"].ToString()); //SN号 curData.Add("Id", subdata["Id"].ToString()); //Id curData.Add("Status", subdata["Status"].ToString()); //Status curData.Add("CreateDate", subdata["CreateDate"].ToString()); //CreateDate curData.Add("MerchantName", ""); //门店信息 dataList.Add(curData); } return dataList; } #endregion #region 消费者-我的订单 [Authorize] public JsonResult List(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ListDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ListDo(string value) { JsonData data = JsonMapper.ToObject(value); int ConsumerId = int.Parse(function.CheckInt(data["ConsumerId"].ToString())); //消费者 int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); List> query = new ConsumerOrdersService().List(new List(), " and ConsumerId=" + ConsumerId + " and Status>0", PageNum, PageSize); foreach (Dictionary subdata in query) { MerchantInfo merchant = MerchantInfoDbconn.Instance.Get(int.Parse(subdata["MerchantId"].ToString())) ?? new MerchantInfo(); Dictionary curData = new Dictionary(); curData.Add("OrderNo", subdata["OrderNo"].ToString()); //订单号 curData.Add("PayMoney", subdata["PayMoney"].ToString()); //支付金额 curData.Add("ReturnMoney", subdata["ReturnMoney"].ToString()); //已返金额 curData.Add("Id", subdata["Id"].ToString()); //Id curData.Add("Status", subdata["Status"].ToString()); //Status curData.Add("CreateDate", subdata["CreateDate"].ToString()); //CreateDate curData.Add("MerchantName", merchant.Name); //商户名称 dataList.Add(curData); } return dataList; } #endregion #region 消费者-支付接口 [Authorize] public JsonResult Pay(string value) { function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-1", "支付时间监控"); if (string.IsNullOrEmpty(value)) { System.IO.StreamReader sr = new System.IO.StreamReader(Request.Body); value = sr.ReadToEnd(); value = value.Split('=')[1]; } function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-2", "支付时间监控"); // value = "BplaaoWS0BIaiDoBUavO7+V+TuwfZwqMyMceCjNxKX8WAdNPI4nbsWRweXeisqtFeVwrmUBHvii5+aPGmATw35XnmHbnPfOGcFGStB89zjssftNRosanfYpr1rdYgcaxNuBw2fpAL4HNV9eTFyRdWsJADF+tD4dTSkfh/VK2od4Ze4coidlUyA=="; value = DesDecrypt(value); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-3", "支付时间监控"); JsonData data = JsonMapper.ToObject(value); AppResultJson result = PayDo(value); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-end", "支付时间监控"); return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data }); } public AppResultJson PayDo(string value) { JsonData data = JsonMapper.ToObject(value); string SnNo = data["Sn"].ToString(); //码牌SN // string Machine = data["Machine"].ToString(); if(SnNo.Length > 20) { SnNo = System.Web.HttpUtility.UrlDecode(SnNo); if(!SnNo.EndsWith("=")) { SnNo += "="; } SnNo = dbconn.Decrypt3DES(SnNo, "l2k0b2#3"); SnNo = SnNo.TrimEnd('\0'); SnNo = SnNo.Substring(0, 20); } function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-4", "支付时间监控"); int PayMode = int.Parse(function.CheckInt(data["PayMode"].ToString())); //支付方式 decimal PayMoney = decimal.Parse(function.CheckNum(data["PayMoney"].ToString())); //支付金额 string Code = data["Code"].ToString(); if (string.IsNullOrEmpty(data["PayMode"].ToString())) { return new AppResultJson() { Status = "-1", Info = "请填写支付方式" }; } if (string.IsNullOrEmpty(data["PayMoney"].ToString())) { return new AppResultJson() { Status = "-1", Info = "请填写支付金额" }; } if (!function.IsNum(data["PayMoney"].ToString())) { return new AppResultJson() { Status = "-1", Info = "请填写正确的支付金额" }; } Dictionary Obj = new Dictionary(); MerchantQrCode qrcode = MerchantQrCodeDbconn.Instance.Get(SnNo) ?? new MerchantQrCode(); PosMachinesTwo pos = PosMachinesTwoDbconn.Instance.Get(SnNo) ?? new PosMachinesTwo(); PosMachines machine = PosMachinesDbconn.Instance.Get(SnNo) ?? new PosMachines(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-5", "支付时间监控"); int MerchantId = pos.BindMerchantId; if(machine.DeviceKind == "1") { MerchantId = machine.BindMerchantId; } if(pos.OpId == 1 || machine.DeviceKind == "1") { MerchantInfo merchant = MerchantInfoDbconn.Instance.Get(MerchantId) ?? new MerchantInfo(); MerchantAddInfo merchantAdd = MerchantAddInfoDbconn.Instance.Get(MerchantId) ?? new MerchantAddInfo(); MerchantParamSet merchantset = MerchantParamSetDbconn.Instance.Get(MerchantId) ?? new MerchantParamSet(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-6", "支付时间监控"); string openid = ""; if (PayMode == 1) { openid = new AlipayFunction(_accessor.HttpContext).GetAlipayUserId(Code); if (openid.Contains("|")) { openid = openid.Split('|')[0]; } } else { string result = function.GetWebRequest("https://api.weixin.qq.com/sns/jscode2session?appid=" + new WeChatFunction().AppId + "&secret=" + new WeChatFunction().AppSecret + "&js_code=" + Code + "&grant_type=authorization_code"); function.WriteLog(DateTime.Now.ToString() + "\n" + result, "微信小程序获取openid"); JsonData jsonObj = JsonMapper.ToObject(result); openid = jsonObj["openid"].ToString(); } function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-7", "支付时间监控"); int ConsumerId = 0; ConsumerOpenIds check = maindb.ConsumerOpenIds.FirstOrDefault(m => m.OpenId == openid); if (check == null) { // ConsumerId = PublicFunction.MakeConsumerId(); Consumers consumer = maindb.Consumers.Add(new Consumers() { Id = ConsumerId, CreateDate = DateTime.Now, WechatOpenId = openid, }).Entity; maindb.SaveChanges(); ConsumerId = consumer.Id; check = maindb.ConsumerOpenIds.Add(new ConsumerOpenIds() { OpenId = openid, ConsumerId = ConsumerId, }).Entity; } else { ConsumerId = check.ConsumerId; } maindb.SaveChanges(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-8", "支付时间监控"); string OrderNo = DateTime.Now.ToString("yyyyMMddHHmmssfff") + function.get_Random(8); bool ActFlag = merchantset.IsAll == 1 ? false : true; if(PayMoney < merchantset.MinPayMoney) //支付金额小于活动最小金额,则不分账 { ActFlag = false; } ConsumerOrders order = maindb.ConsumerOrders.Add(new ConsumerOrders() { // Id = PublicFunction.MakeConsumerOrderId(), CreateDate = DateTime.Now, //创建时间 MerchantId = MerchantId, //商户 ConsumerId = ConsumerId, //消费者 UserId = merchant.UserId, //创客 PayMode = PayMode, //支付方式 PayMoney = PayMoney, //支付金额 SnNo = SnNo, //SN号 OrderNo = OrderNo, MaxDivi = ActFlag ? PayMoney * merchantset.DiviPercent / 100 : 0, IsAct = ActFlag ? 1u : 0u, MerchantActualAmount = ActFlag ? PayMoney * merchantset.GetPercent / 100 : PayMoney, SeoDescription = Newtonsoft.Json.JsonConvert.SerializeObject(merchantset), }).Entity; maindb.SaveChanges(); function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "-9", "支付时间监控"); maindb.ConsumerOrderForNo.Add(new ConsumerOrderForNo() { OrderNo = OrderNo, OrderIds = order.Id, }); maindb.SaveChanges(); if (PayMode == 1) { string backString = new AlipayFunction(_accessor.HttpContext).CreateTrade(OrderNo, merchant.Name, PayMoney, openid, merchantAdd.AlipayAuthToken, SpHost + "/api/alipay/notice"); JsonData obj = JsonMapper.ToObject(backString); if (obj["alipay_trade_create_response"]["code"].ToString() == "10000") { string tradeNo = obj["alipay_trade_create_response"]["trade_no"].ToString(); Obj.Add("respCode", obj["alipay_trade_create_response"]["code"].ToString()); Obj.Add("tradeNo", tradeNo); } else { Obj.Add("respCode", obj["alipay_trade_create_response"]["code"].ToString()); Obj.Add("tradeNo", ""); return new AppResultJson() { Status = "-1", Info = obj["alipay_trade_create_response"]["sub_msg"].ToString(), Data = Obj }; } } else if (PayMode == 2) { string SubMchId = merchantAdd.SubMchid; string Description = merchant.Name; string OpenId = openid; string Key = AppConfig.WeChatParam.AesGemKey; string NotifyUrl = SpHost + "/api/wechat/notice"; Dictionary dic = new WeChatFunction(_accessor.HttpContext).Pay(SubMchId, PayMoney, OrderNo, Description, OpenId, Key, NotifyUrl, ActFlag); Obj.Add("appId", dic["appId"]); //微信小程序appid Obj.Add("timeStamp", dic["timeStamp"]); //时间戳 Obj.Add("nonceStr", dic["nonceStr"]); //随机字符串 Obj.Add("package", dic["package"]); //统一支付接口返回的prepayid参数值 Obj.Add("paySign", dic["paySign"]); //支付签名 Obj.Add("ConsumerId", ConsumerId); } function.WriteLog(DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff") + "10", "支付时间监控"); } else { string result = function.PostWebRequest(AppConfig.Base.Host2 + "api/v1/consumerorders/pay", "value=" + value); return Newtonsoft.Json.JsonConvert.DeserializeObject(result); } return new AppResultJson() { Status = "1", Info = "", Data = Obj }; } #endregion public string test() { return new WeChatFunction(_accessor.HttpContext).GetPlatCert(); } public string test2() { return new WeChatFunction(_accessor.HttpContext).GetPublicKey(); } #region 检查签名是否合法,合法返回1,不合法返回提示信息 /// /// 检查签名是否合法,合法返回1,不合法返回提示信息 /// /// 请求的参数(json字符串) /// 要签名的字段 /// private string CheckSign(string value, string[] signField) { JsonData json = JsonMapper.ToObject(value); Dictionary dic = new Dictionary(); for (int i = 0; i < signField.Length; i++) { dic.Add(signField[i], json[signField[i]].ToString()); } string sign = json["sign"].ToString(); //客户端签名字符串 return new Sign().sign(dic, sign); } #endregion } }