using System; using System.Collections.Generic; using System.Linq; using System.Data; 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 { [Area("Api")] [Route("Api/v1/pos/[controller]/[action]")] public class StoreHouseAmountPromissController : BaseController { public StoreHouseAmountPromissController(IHttpContextAccessor accessor, ILogger logger, IOptions setting) : base(accessor, logger, setting) { OtherMySqlConn.connstr = Library.ConfigurationManager.AppSettings["SqlConnStr"].ToString(); } #region 创客-首页-仓库管理-已担保金额 [Authorize] public JsonResult PromissMoney(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); Dictionary Obj = PromissMoneyDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = Obj }); } public Dictionary PromissMoneyDo(string value) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //用户Id Dictionary Obj = new Dictionary(); var check = maindb.StoreHouseAmountPromiss.Any(m => m.FromUserId == UserId); decimal amount = 0; if (check) { amount = maindb.StoreHouseAmountPromiss.Where(m => m.Status == 1 && m.FromUserId == UserId).Sum(m => m.PromissAmount); } Obj.Add("PromissAmount", amount); //担保金额 return Obj; } #endregion #region 创客-首页-仓库管理-担保反馈 [Authorize] public JsonResult CallBack(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); AppResultJson result = CallBackDo(value); return Json(new AppResultJson() { Status = result.Status, Info = result.Info, Data = result.Data }); } public AppResultJson CallBackDo(string value) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //用户Id int Id = int.Parse(function.CheckInt(data["Id"].ToString())); //记录Id int Status = int.Parse(function.CheckInt(data["Status"].ToString())); //状态 Dictionary Obj = new Dictionary(); var query = maindb.StoreHouseAmountPromiss.FirstOrDefault(m => m.Id == Id && m.Status == 0); var userInfo = maindb.Users.FirstOrDefault(m => m.Id == query.ToUserId); if (query != null) { if (Status == 1)//同意 { query.UpdateDate = DateTime.Now; //修改时间 query.Status = 1; var user = maindb.UserAccount.FirstOrDefault(m => m.Id == query.ToUserId) ?? new UserAccount(); user.ValidAmount += query.PromissAmount; maindb.SaveChanges(); RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal() { UserId = UserId, //接收创客 Title = "仓库担保确认通知", //标题 Content = "
已经确认为创客
" + userInfo.RealName + ' ' + userInfo.MakerCode + "进行分仓额度担保
担保金额:" + query.PromissAmount + "
", //内容 Summary = "已经确认为创客" + userInfo.RealName + ' ' + userInfo.MakerCode + "进行分仓额度担保,担保金额:" + query.PromissAmount, CreateDate = DateTime.Now, })); } if (Status == 2)//拒绝 { query.UpdateDate = DateTime.Now; //修改时间 query.Status = 2; maindb.SaveChanges(); } } else { return new AppResultJson() { Status = "-1", Info = "该用户数据不存在", Data = Obj }; } return new AppResultJson() { Status = "1", Info = "", Data = Obj }; } #endregion #region 创客-首页-仓库管理-担保明细 [Authorize] public JsonResult List(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); Dictionary Other = new Dictionary(); List> dataList = ListDo(value, out Other); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList, Other = Other }); } public List> ListDo(string value, out Dictionary Other) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //用户Id int PageSize = int.Parse(function.CheckInt(data["PageSize"].ToString())); int PageNum = int.Parse(function.CheckInt(data["PageNum"].ToString())); List> dataList = new List>(); List toUserIds = new List(); DataTable dt = OtherMySqlConn.dtable("SELECT ToUserId FROM StoreHouseAmountPromiss WHERE FromUserId='" + UserId + "' AND `Status`=1 GROUP BY ToUserId ORDER BY ToUserId"); foreach (DataRow item in dt.Rows) { toUserIds.Add(int.Parse(item["ToUserId"].ToString())); } foreach (var item in toUserIds) { Dictionary curData = new Dictionary(); var userInfo = maindb.Users.FirstOrDefault(m => m.Id == item); var time = ""; DataTable dts = OtherMySqlConn.dtable("SELECT UpDateDate FROM StoreHouseAmountPromiss WHERE FromUserId='" + UserId + "' AND ToUserId='" + item + "' AND `Status`=1 ORDER BY UpDateDate DESC LIMIT 1"); foreach (DataRow items in dts.Rows) { time = Convert.ToDateTime(items["UpDateDate"]).ToString("yyyy-MM-dd HH:mm:ss"); } var amount = maindb.StoreHouseAmountPromiss.Where(m => m.FromUserId == UserId && m.ToUserId == item && m.Status == 1).Sum(m => m.PromissAmount); curData.Add("userInfo", userInfo.RealName + ' ' + userInfo.MakerCode);//被担保人信息 curData.Add("time", time);//担保时间 curData.Add("amount", amount);//担保金额 dataList.Add(curData); } dataList = dataList.Skip((PageNum - 1) * PageSize).Take(PageSize).ToList();//分页的重点 Other = new Dictionary(); var TotalAmount = maindb.StoreHouseAmountPromiss.Where(m => m.FromUserId == UserId && m.Status == 1).Sum(m => m.PromissAmount); Other.Add("TotalAmount", TotalAmount); return dataList; } #endregion #region 创客-首页-仓库管理-担保确认提示信息 [Authorize] public JsonResult ConfirmInfo(string value) { value = DesDecrypt(value); JsonData data = JsonMapper.ToObject(value); List> dataList = ConfirmInfoDo(value); return Json(new AppResultJson() { Status = "1", Info = "", Data = dataList }); } public List> ConfirmInfoDo(string value) { JsonData data = JsonMapper.ToObject(value); int UserId = int.Parse(function.CheckInt(data["UserId"].ToString())); //担保人 List> dataList = new List>(); var info = maindb.StoreHouseAmountPromiss.Select(m => new { m.Id, m.ToUserId, m.FromUserId, m.Status }).Where(m => m.FromUserId == UserId && m.Status == 0).ToList(); foreach (var item in info) { Dictionary Obj = new Dictionary(); var query = maindb.StoreHouseAmountPromiss.FirstOrDefault(m => m.Id == item.Id); Users UsersData = maindb.Users.FirstOrDefault(m => m.Id == query.ToUserId); Obj.Add("Id", item.Id); //记录Id Obj.Add("RealName", UsersData.RealName); //真实姓名 Obj.Add("MakerCode", UsersData.MakerCode); //创客编号 Obj.Add("PromissAmount", query.PromissAmount); //担保金额 dataList.Add(Obj); } return dataList; } #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 } }