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; namespace MySystem.Areas.Api.Controllers.v1.pos { [Area("Api")] [Route("Api/v1/pos/[controller]/[action]")] public class MerchantInfoController : BaseController { public MerchantInfoController(IHttpContextAccessor accessor, ILogger logger, IOptions setting) : base(accessor, logger, setting) { } #region 首页-客小爽产品-我的业绩-个人业绩-激活商户-商户搜索 [Authorize] public JsonResult ActMerchantSearch(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ActMerchantSearchDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ActMerchantSearchDo(string value) { JsonData data = JsonMapper.ToObject(value); string SearchKey = data["SearchKey"].ToString(); //搜索关键词 int UserId = int.Parse(function.CheckInt(data["UserId"].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 = RedisDbconn.Instance.GetList("MerchantList:" + UserId, 1, 1000000); // TODO:要同步数据到本key if (!string.IsNullOrEmpty(SearchKey)) { query = query.Where(m => m.MerchantName.Contains(SearchKey) || m.MerchantNo.Contains(SearchKey) || m.KqSnNo.Contains(SearchKey) || m.MerchantMobile.Contains(SearchKey)).ToList(); } if (PageNum == 1) { query = query.Take(PageSize).ToList(); } else { int skipNum = PageSize * (PageNum - 1); query = query.Skip(skipNum).Take(PageSize).ToList(); } foreach (var sub in query) { PosMerchantInfo subdata = maindb.PosMerchantInfo.FirstOrDefault(m => m.Id == sub.Id) ?? new PosMerchantInfo(); Dictionary curData = new Dictionary(); curData.Add("MerchantName", subdata.MerchantName); //商户姓名 curData.Add("ActiveStatus", subdata.ActiveStatus == 1 ? "已激活" : "未激活"); //商户激活状态 curData.Add("MerStandardDate", subdata.MerStandardDate == null ? "" : subdata.MerStandardDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //商户激活时间 curData.Add("ActType", RelationClass.GetMerchantActTypeInfo(subdata.ActType)); //激活类型 curData.Add("BrandId", RelationClass.GetKqProductBrandInfo(subdata.BrandId)); //品牌 curData.Add("Id", subdata.Id); //Id dataList.Add(curData); } return dataList; } #endregion #region 首页-客小爽产品-我的业绩-个人业绩-激活商户-商户明细 [Authorize] public JsonResult ActMerchants(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); Dictionary Obj = new Dictionary(); List> dataList = ActMerchantsDo(value, out Obj); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList, Other = Obj }); } public List> ActMerchantsDo(string value, out Dictionary Other) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客 int ProductType = int.Parse(function.CheckInt(data["ProductType"].ToString())); //产品类型 string IsHelp = data["IsHelp"].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 = RedisDbconn.Instance.GetList("MerchantList:" + UserId, 1, 1000000); // TODO:要同步数据到本key DateTime check = DateTime.Now.AddMonths(-3); int Total = query.Count; int HelpCount = query.Count(m => m.RegDate >= check); int NotHelpCount = query.Count(m => m.RegDate < check); if (ProductType > 0) { query = query.Where(m => m.BrandId == ProductType).ToList(); } if (!string.IsNullOrEmpty(IsHelp)) { if (IsHelp == "1") { query = query.Where(m => m.RegDate >= check).ToList(); } else { query = query.Where(m => m.RegDate < check).ToList(); } } if (PageNum == 1) { query = query.Take(PageSize).ToList(); } else { int skipNum = PageSize * (PageNum - 1); query = query.Skip(skipNum).Take(PageSize).ToList(); } foreach (MerchantItem merchant in query) { PosMerchantInfo subdata = maindb.PosMerchantInfo.FirstOrDefault(m => m.Id == merchant.Id) ?? new PosMerchantInfo(); Dictionary curData = new Dictionary(); curData.Add("MerchantName", subdata.MerchantName); //商户姓名 curData.Add("ActiveStatus", subdata.ActiveStatus == 1 ? "已激活" : "未激活"); //商户激活状态 curData.Add("MerStandardDate", subdata.MerStandardDate == null ? "" : subdata.MerStandardDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //商户激活时间 curData.Add("ActType", RelationClass.GetMerchantActTypeInfo(subdata.ActType)); //激活类型 curData.Add("BrandId", RelationClass.GetKqProductBrandInfo(subdata.BrandId)); //品牌 curData.Add("Id", subdata.Id); //Id dataList.Add(curData); } Dictionary Obj = new Dictionary(); Obj.Add("Total", Total); //全部商户 Obj.Add("HelpCount", HelpCount); //扶持期商户 Obj.Add("NotHelpCount", NotHelpCount); //稳定期商户 Other = Obj; return dataList; } #endregion #region 首页-客小爽产品-我的业绩-团队业绩-商户列表 [Authorize] public JsonResult TeamPerformanceMerchants(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = TeamPerformanceMerchantsDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> TeamPerformanceMerchantsDo(string value) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].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 = RedisDbconn.Instance.GetList("MerchantList:" + UserId, 1, 1000000).Where(m => m.ActiveStatus == 1).ToList(); if (PageNum == 1) { query = query.Take(PageSize).ToList(); } else { int skipNum = PageSize * (PageNum - 1); query = query.Skip(skipNum).Take(PageSize).ToList(); } foreach (MerchantItem Merchant in query) { PosMerchantInfo subdata = maindb.PosMerchantInfo.FirstOrDefault(m => m.Id == Merchant.Id) ?? new PosMerchantInfo(); Dictionary curData = new Dictionary(); curData.Add("MerchantName", subdata.MerchantName); //商户姓名 curData.Add("Id", subdata.Id); //Id dataList.Add(curData); } return dataList; } #endregion #region 首页-我的商户-商户列表 [Authorize] public JsonResult MyMerchant(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); Dictionary Other = new Dictionary(); List> dataList = MyMerchantDo(value, out Other); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList, Other = Other }); } public List> MyMerchantDo(string value, out Dictionary Other) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //创客 int ProductType = int.Parse(function.CheckInt(data["ProductType"].ToString())); //产品类型 ulong ActiveStatus = ulong.Parse(function.CheckInt(data["ActiveStatus"].ToString())); //商户激活状态 decimal MinTrade = decimal.Parse(function.CheckNum(data["MinTrade"].ToString())); //本月交易额最低值 decimal MaxTrade = decimal.Parse(function.CheckNum(data["MaxTrade"].ToString())); //本月交易额最高值 string ActTime = data["ActTime"].ToString(); //激活时间 string Sort = data["Sort"].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 = PosMerchantInfoDbconn.Instance.GetList(UserId, 1, 1000000); string today = DateTime.Now.ToString("yyyyMMdd"); DateTime date = DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd") + " 00:00:00"); int TotalCount = query.Count; int ActCount = query.Count(m => m.MerStandardDate >= date); int ProductCount = query.Count(m => m.BrandId == ProductType); int ProductActCount = query.Count(m => m.ActiveStatus > 0 && m.BrandId == ProductType); int ProductUnActCount = ProductCount - ProductActCount; if (ProductType > 0) { query = query.Where(m => m.BrandId == ProductType).ToList(); } if (ActiveStatus > 0) { int ActStatus = 1; if (ActiveStatus == 2) ActStatus = 0; query = query.Where(m => m.ActiveStatus == ActStatus).ToList(); } // if (MinTrade > 0) // { // query = query.Where(m => m.TradeAmount >= MinTrade).ToList(); // } // if (MaxTrade > 0) // { // query = query.Where(m => m.TradeAmount <= MaxTrade).ToList(); // } // if (!string.IsNullOrEmpty(ActTime)) // { // query = query.Where(m => m.ActTime == ActTime).ToList(); // } // if (Sort == "trade") // { // query = query.OrderByDescending(m => m.TradeAmount).ToList(); // } if (Sort == "regdate") { query = query.OrderByDescending(m => m.CreateDate).ToList(); } else { query = query.OrderByDescending(m => m.Status).ThenByDescending(m => m.SeoKeyword).ToList(); } if (PageNum == 1) { query = query.Take(PageSize).ToList(); } else { int skipNum = PageSize * (PageNum - 1); query = query.Skip(skipNum).Take(PageSize).ToList(); } foreach (var item in query) { Dictionary curData = new Dictionary(); PosMerchantInfo subdata = PosMerchantInfoDbconn.Instance.Get(item.Id) ?? new PosMerchantInfo(); var posId = maindb.MachineForSnNo.FirstOrDefault(m => m.SnNo == item.KqSnNo) ?? new MachineForSnNo(); var pos = maindb.PosMachinesTwo.FirstOrDefault(m => m.Id == posId.SnId) ?? new PosMachinesTwo(); if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0) { curData.Add("IsOk", 1);//未调整 } else if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 1) { curData.Add("IsOk", 2);//已经调低 } else { curData.Add("IsOk", 0);//初始 } string Name = subdata.MerchantName; if (subdata.BrandId == 2) { if (Name.Contains("-")) { Name = Name.Split('-')[1]; } else if (Name.Contains("_")) { Name = Name.Split('_')[1]; } } curData.Add("MerchantName", Name); //商户姓名 curData.Add("KqRegTime", subdata.CreateDate == null ? "" : subdata.CreateDate.Value.ToString("yyyy-MM-dd")); //渠道注册时间 curData.Add("Id", item.Id); //Id curData.Add("ThisMonthTrade", PosMerchantTradeSummaryDbconn.Instance.GetDateTimeTrade(subdata.Id, DateTime.Now.ToString("yyyyMM"))); //当月交易额 // TODO:记得统计 dataList.Add(curData); } Other = new Dictionary(); Other.Add("TotalCount", TotalCount); //商户数 Other.Add("ActCount", ActCount); //商户激活数 Other.Add("ProductCount", ProductCount); //当前产品商户总数 Other.Add("ProductActCount", ProductActCount); //当前产品已激活数 Other.Add("ProductUnActCount", ProductUnActCount); //当前产品未激活数 return dataList; } #endregion #region 首页-我的商户-商户搜索 [Authorize] public JsonResult MerchantSearch(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = MerchantSearchDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> MerchantSearchDo(string value) { JsonData data = JsonMapper.ToObject(value); string SearchKey = data["SearchKey"].ToString(); //搜索关键词 int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); int ProductType = int.Parse(function.CheckInt(data["ProductType"].ToString())); int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); IQueryable query = maindb.PosMerchantInfo.Where(m => m.UserId == UserId && m.BrandId == ProductType); if (!string.IsNullOrEmpty(SearchKey)) { query = query.Where(m => (m.MerchantName == SearchKey || m.KqSnNo == SearchKey)); } if (PageNum == 1) { query = query.Take(PageSize); } else { int skipNum = PageSize * (PageNum - 1); query = query.Skip(skipNum).Take(PageSize); } foreach (var item in query.ToList()) { PosMerchantInfo subdata = maindb.PosMerchantInfo.FirstOrDefault(m => m.Id == item.Id) ?? new PosMerchantInfo(); Dictionary curData = new Dictionary(); string Name = subdata.MerchantName; if (subdata.BrandId == 2) { if (Name.Contains("-")) { Name = Name.Split('-')[1]; } else if (Name.Contains("_")) { Name = Name.Split('_')[1]; } } curData.Add("MerchantName", Name); //商户姓名 curData.Add("KqRegTime", subdata.KqRegTime == null ? "" : subdata.KqRegTime.Value.ToString("yyyy-MM-dd HH:mm:ss")); //渠道注册时间 curData.Add("Id", item.Id); //Id curData.Add("ThisMonthTrade", PosMerchantTradeSummaryDbconn.Instance.GetDateTimeTrade(subdata.Id, DateTime.Now.ToString("yyyyMM"))); //当月交易额 dataList.Add(curData); } return dataList; } #endregion #region 首页-我的商户-商户详情 [Authorize] public JsonResult Detail(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); Dictionary Obj = DetailDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj }); } public Dictionary DetailDo(string value) { JsonData data = JsonMapper.ToObject(value); Dictionary Obj = new Dictionary(); int Id = int.Parse(function.CheckInt(data["Id"].ToString())); PosMerchantInfo query = PosMerchantInfoDbconn.Instance.Get(Id) ?? new PosMerchantInfo(); string Name = query.MerchantName; if (query.BrandId == 2) { if (Name.Contains("-")) { Name = Name.Split('-')[1]; } else if (Name.Contains("_")) { Name = Name.Split('_')[1]; } } MachineForMerNo forMerNo = maindb.MachineForMerNo.FirstOrDefault(m => m.MerNo == query.KqMerNo) ?? new MachineForMerNo(); Obj.Add("MerchantName", Name); //商户姓名 Obj.Add("MerchantMobile", query.MerchantMobile); //商户手机号 Obj.Add("MerRealName", query.MerRealName); //商户真实姓名 Obj.Add("MerIdcardNo", query.MerIdcardNo); //商户身份证号 Obj.Add("KqMerNo", query.KqMerNo); //商户编号 Obj.Add("KqSnNo", query.KqSnNo); //渠道SN号 Obj.Add("KqSnId", forMerNo.SnId); //机具Id Obj.Add("MerStatus", query.MerStatus); //商户状态 Obj.Add("ActiveStatus", query.ActiveStatus == 1 ? "已激活" : "未激活"); //商户激活状态 Obj.Add("MerStandardDate", query.MerStandardDate == null ? "" : query.MerStandardDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //商户激活时间 Obj.Add("Remark", query.Remark); //备注 Obj.Add("MerUserType", query.MerUserType == 1 ? "商户型创客" : "非商户型创客"); //商户创客类型 Obj.Add("ProductType", RelationClass.GetKqProductBrandInfo(query.BrandId)); //来源产品 Obj.Add("TradeTotal", PosMerchantTradeSummaryDbconn.Instance.GetTrade(query.Id)); //总交易额 Obj.Add("CreateDate", query.CreateDate == null ? "" : query.CreateDate.Value.ToString("yyyy-MM-dd HH:mm:ss")); //创建时间 PosMachinesTwo pos = maindb.PosMachinesTwo.FirstOrDefault(m => m.Status > -1 && m.Id == forMerNo.SnId) ?? new PosMachinesTwo(); var poschange = maindb.PosMachinesFeeChangeRecord.FirstOrDefault(m => m.PosId == pos.Id) ?? new PosMachinesFeeChangeRecord(); if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0 && poschange.Id == 0) { Obj.Add("IsOk", 1);//未调整 } else if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 1 && pos.SeoDescription == "设置成功") { Obj.Add("IsOk", 3);//成功 } else if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0 && poschange.Id > 0) { Obj.Add("IsOk", 2);//处理中 } else if (pos.UpFeeFlag == 1 && pos.DownFeeFlag == 0 && poschange.Status == -1) { Obj.Add("IsOk", -1);//失败 } else { Obj.Add("IsOk", 0);//初始 } decimal Deposit = 0; if (pos.BrandId == 2) { Deposit = 299; if (!string.IsNullOrEmpty(pos.PrizeParams)) { Deposit = decimal.Parse(function.CheckNum(pos.PrizeParams)); } } else if (pos.BrandId == 6) { Deposit = 249; if (!string.IsNullOrEmpty(pos.PrizeParams)) { Deposit = decimal.Parse(function.CheckNum(pos.PrizeParams)); } } Obj.Add("Deposit", Deposit); if (pos.IsFirst == 1) { decimal DepositAmt = decimal.Parse(function.CheckNum(pos.SeoKeyword)); if (DepositAmt > 0) { int Days = int.Parse(RedisDbconn.Instance.Get("pobjrule:" + pos.BrandId + ":HelpPolicy:Days")); //天数 if (pos.BindingTime == null) { Obj.Add("ActStatus", ""); } else { if (pos.BindingTime.Value.AddDays(Days) > DateTime.Now) { Obj.Add("ActStatus", "扶持期"); } else if (pos.DownFeeFlag == 1) { Obj.Add("ActStatus", "盈利期"); } else { Obj.Add("ActStatus", "稳定期"); } } } else if (pos.DownFeeFlag == 1) { Obj.Add("ActStatus", "盈利期"); } else { Obj.Add("ActStatus", "稳定期"); } } else if (pos.DownFeeFlag == 1) { Obj.Add("ActStatus", "盈利期"); } else { Obj.Add("ActStatus", "稳定期"); } return Obj; } #endregion #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 } }