PosMachinesTwoChangeController.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809
  1. /*
  2. * 机具库
  3. */
  4. using System;
  5. using System.Web;
  6. using System.Collections.Generic;
  7. using System.Diagnostics;
  8. using System.Linq;
  9. using System.Data;
  10. using System.Threading.Tasks;
  11. using Microsoft.AspNetCore.Mvc;
  12. using Microsoft.AspNetCore.Http;
  13. using Microsoft.Extensions.Logging;
  14. using Microsoft.Extensions.Options;
  15. using MySystem.Models;
  16. using Library;
  17. using LitJson;
  18. using MySystemLib;
  19. namespace MySystem.Areas.Admin.Controllers
  20. {
  21. [Area("Admin")]
  22. [Route("Admin/[controller]/[action]")]
  23. public class PosMachinesTwoChangeController : BaseController
  24. {
  25. public PosMachinesTwoChangeController(IHttpContextAccessor accessor, ILogger<BaseController> logger, IOptions<Setting> setting) : base(accessor, logger, setting)
  26. {
  27. OtherMySqlConn.connstr = ConfigurationManager.AppSettings["SqlConnStr"].ToString();
  28. }
  29. #region 机具库列表
  30. /// <summary>
  31. /// 根据条件查询机具库列表
  32. /// </summary>
  33. /// <returns></returns>
  34. public IActionResult Index(PosMachinesTwo data, string right)
  35. {
  36. ViewBag.RightInfo = RightInfo;
  37. ViewBag.right = right;
  38. return View();
  39. }
  40. #endregion
  41. #region 根据条件查询机具库列表
  42. /// <summary>
  43. /// 机具库列表
  44. /// </summary>
  45. /// <returns></returns>
  46. public JsonResult IndexData(PosMachinesTwo data, string BindingStateSelect, string ActivationStateSelect, string UserIdMakerCode, string UserIdRealName, string StoreIdCode, string StoreIdName, string ActivationDateData, string BindingDateData, string BrandSelect = "1", int page = 1, int limit = 30)
  47. {
  48. Dictionary<string, string> Fields = new Dictionary<string, string>();
  49. Fields.Add("PosSn", "1"); //SN编号
  50. Fields.Add("BrandId", "0"); //品牌
  51. string condition = " and Status>-1 AND BindingState = 1 AND DATE_SUB(CURDATE(), INTERVAL 90 DAY) >= date(BindingTime) and UpFeeFlag=1 and DownFeeFlag=0 and BrandId!=6 and (SeoDescription!='设置成功' or SeoDescription is null or SeoDescription='')";
  52. //绑定状态
  53. if (!string.IsNullOrEmpty(BindingStateSelect))
  54. {
  55. condition += " and BindingState=" + BindingStateSelect;
  56. }
  57. //激活状态
  58. if (!string.IsNullOrEmpty(ActivationStateSelect))
  59. {
  60. condition += " and ActivationState=" + ActivationStateSelect;
  61. }
  62. //所属创客编号
  63. if (!string.IsNullOrEmpty(UserIdMakerCode))
  64. {
  65. condition += " and BuyUserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  66. }
  67. //所属创客真实姓名
  68. if (!string.IsNullOrEmpty(UserIdRealName))
  69. {
  70. condition += " and BuyUserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  71. }
  72. //所属仓库编号
  73. if (!string.IsNullOrEmpty(StoreIdCode))
  74. {
  75. condition += " and StoreId in (select StoreId from StoreForCode where Code='" + StoreIdCode + "')";
  76. }
  77. //所属仓库名称
  78. if (!string.IsNullOrEmpty(StoreIdName))
  79. {
  80. condition += " and StoreId in (select StoreId from StoreForName where Name='" + StoreIdName + "')";
  81. }
  82. //品牌
  83. if (!string.IsNullOrEmpty(BrandSelect))
  84. {
  85. condition += " and BrandId = " + Convert.ToInt32(BrandSelect);
  86. }
  87. if (!string.IsNullOrEmpty(ActivationDateData))
  88. {
  89. string[] datelist = ActivationDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  90. string start = datelist[0];
  91. string end = datelist[1];
  92. condition += " and ActivationTime>='" + start + " 00:00:00' and ActivationTime<='" + end + " 23:59:59'";
  93. }
  94. if (!string.IsNullOrEmpty(BindingDateData))
  95. {
  96. string[] datelist = BindingDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  97. string start = datelist[0];
  98. string end = datelist[1];
  99. condition += " and BindingTime>='" + start + " 00:00:00' and BindingTime<='" + end + " 23:59:59'";
  100. }
  101. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("PosMachinesTwo", Fields, "Id desc", "0", page, limit, condition);
  102. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  103. foreach (Dictionary<string, object> dic in diclist)
  104. {
  105. //是否真实调升/降
  106. if (!string.IsNullOrEmpty(dic["ActivityList"].ToString()))
  107. {
  108. string ActivityList = dic["ActivityList"].ToString();
  109. if (ActivityList == "1") dic["ActivityList"] = "已真实调升";
  110. if (ActivityList == "2") dic["ActivityList"] = "已真实调降";
  111. }
  112. if (string.IsNullOrEmpty(dic["ActivityList"].ToString()))
  113. {
  114. dic["ActivityList"] = "";
  115. }
  116. //绑定状态
  117. int BindingState = int.Parse(dic["BindingState"].ToString());
  118. if (BindingState == 0) dic["BindingState"] = "未绑定";
  119. if (BindingState == 1) dic["BindingState"] = "已绑定";
  120. //激活状态
  121. int ActivationState = int.Parse(dic["ActivationState"].ToString());
  122. if (ActivationState == 0) dic["ActivationState"] = "未激活";
  123. if (ActivationState == 1) dic["ActivationState"] = "已激活";
  124. //所属创客
  125. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  126. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  127. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  128. dic["UserIdRealName"] = userid_Users.RealName;
  129. dic.Remove("UserId");
  130. //所属仓库
  131. int StoreId = int.Parse(function.CheckInt(dic["StoreId"].ToString()));
  132. StoreHouse storeid_StoreHouse = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId) ?? new StoreHouse();
  133. dic["StoreIdCode"] = storeid_StoreHouse.StoreNo;
  134. dic["StoreIdName"] = storeid_StoreHouse.StoreName;
  135. dic.Remove("StoreId");
  136. //产品类型
  137. dic["BrandId"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  138. //绑定商户
  139. int BindMerchantId = int.Parse(function.CheckInt(dic["BindMerchantId"].ToString()));
  140. PosMerchantInfo bindmerchantid_MerchantInfo = db.PosMerchantInfo.FirstOrDefault(m => m.Id == BindMerchantId) ?? new PosMerchantInfo();
  141. dic["BindMerchantIdMerchantNo"] = bindmerchantid_MerchantInfo.MerchantNo;
  142. dic["BindMerchantIdMerchantName"] = bindmerchantid_MerchantInfo.MerchantName;
  143. dic.Remove("BindMerchantId");
  144. //机具类型
  145. int PosSnType = int.Parse(dic["PosSnType"].ToString());
  146. if (PosSnType == 0) dic["PosSnType"] = "兑换机具";
  147. if (PosSnType == 1) dic["PosSnType"] = "循环机具";
  148. //设备类型
  149. string DeviceType = dic["DeviceType"].ToString();
  150. if (DeviceType == "KysSignPos") dic["DeviceType"] = "快益刷电签POS";
  151. if (DeviceType == "KssSignPos") dic["DeviceType"] = "快闪刷电签POS";
  152. if (DeviceType == "") dic["DeviceType"] = "";
  153. //盟主信息
  154. int LeaderUserId = int.Parse(function.CheckInt(dic["LeaderUserId"].ToString()));
  155. if (LeaderUserId != 0)
  156. {
  157. Users users = db.Users.FirstOrDefault(m => m.Id == LeaderUserId) ?? new Users();
  158. dic["UserInfo"] = users.MakerCode + "_" + users.RealName;
  159. }
  160. //是否为第一台机具
  161. // int IsFirst = int.Parse(dic["FirstFlag"].ToString());
  162. // if (IsFirst == 0) dic["IsFirst"] = "否";
  163. // if (IsFirst == 1) dic["IsFirst"] = "是";
  164. dic["IsFirst"] = int.Parse(dic["FirstFlag"].ToString()) == 1 ? "首台" : "非首台"; //是否首台(机具奖励发放)
  165. dic["PosIsFirst"] = int.Parse(dic["FirstFlag"].ToString()) == 1 ? "首台" : "非首台"; //是否首台(服务费领取)
  166. //循环开始时间
  167. if (!string.IsNullOrEmpty(dic["RecycEndDate"].ToString()))
  168. {
  169. var RecycStartDate = Convert.ToDateTime(dic["RecycEndDate"].ToString()).AddMonths(-3).ToString("yyyy-MM-dd HH:mm:ss");
  170. dic["RecycStartDate"] = RecycStartDate;
  171. }
  172. //是否调升
  173. int UpFeeFlag = int.Parse(dic["UpFeeFlag"].ToString());
  174. if (UpFeeFlag == 0) dic["UpFeeFlag"] = "否";
  175. if (UpFeeFlag == 1) dic["UpFeeFlag"] = "是";
  176. //是否调降
  177. int DownFeeFlag = int.Parse(dic["DownFeeFlag"].ToString());
  178. if (DownFeeFlag == 0) dic["DownFeeFlag"] = "否";
  179. if (DownFeeFlag == 1) dic["DownFeeFlag"] = "是";
  180. //调升时间
  181. if (!string.IsNullOrEmpty(dic["UpFeeDate"].ToString()))
  182. {
  183. var UpFeeDate = Convert.ToDateTime(dic["UpFeeDate"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
  184. dic["UpFeeDate"] = UpFeeDate;
  185. }
  186. //调降时间
  187. if (!string.IsNullOrEmpty(dic["DownFeeDate"].ToString()))
  188. {
  189. var DownFeeDate = Convert.ToDateTime(dic["DownFeeDate"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
  190. dic["DownFeeDate"] = DownFeeDate;
  191. }
  192. }
  193. Dictionary<string, object> other = new Dictionary<string, object>();
  194. int TotalCount = 0;//总机具数
  195. DataTable dt = OtherMySqlConn.dtable("select count(0) from PosMachinesTwo where 1=1" + condition);
  196. if (dt.Rows.Count > 0)
  197. {
  198. TotalCount = int.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
  199. }
  200. other.Add("TotalCount", TotalCount);
  201. other.Add("KysCount99", 0);
  202. other.Add("KssCount99", 0);
  203. other.Add("KssCoun198", 0);
  204. other.Add("KssCount298", 0);
  205. obj.Add("other", other);
  206. return Json(obj);
  207. }
  208. #endregion
  209. #region 增加机具库
  210. /// <summary>
  211. /// 增加或修改机具库信息
  212. /// </summary>
  213. /// <returns></returns>
  214. public IActionResult Add(string right)
  215. {
  216. ViewBag.RightInfo = RightInfo;
  217. ViewBag.right = right;
  218. return View();
  219. }
  220. #endregion
  221. #region 增加机具库
  222. /// <summary>
  223. /// 增加或修改机具库信息
  224. /// </summary>
  225. /// <returns></returns>
  226. [HttpPost]
  227. public string Add(PosMachinesTwo data)
  228. {
  229. Dictionary<string, object> Fields = new Dictionary<string, object>();
  230. Fields.Add("SeoTitle", data.SeoTitle);
  231. Fields.Add("SeoKeyword", data.SeoKeyword);
  232. Fields.Add("SeoDescription", data.SeoDescription);
  233. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("PosMachinesTwo", Fields, 0);
  234. AddSysLog(data.Id.ToString(), "PosMachinesTwo", "add");
  235. db.SaveChanges();
  236. return "success";
  237. }
  238. #endregion
  239. #region 修改机具库
  240. /// <summary>
  241. /// 增加或修改机具库信息
  242. /// </summary>
  243. /// <returns></returns>
  244. public IActionResult Edit(string right, int Id = 0)
  245. {
  246. ViewBag.RightInfo = RightInfo;
  247. ViewBag.right = right;
  248. PosMachinesTwo editData = db.PosMachinesTwo.FirstOrDefault(m => m.Id == Id) ?? new PosMachinesTwo();
  249. ViewBag.data = editData;
  250. return View();
  251. }
  252. #endregion
  253. #region 修改机具库
  254. /// <summary>
  255. /// 增加或修改机具库信息
  256. /// </summary>
  257. /// <returns></returns>
  258. [HttpPost]
  259. public string Edit(PosMachinesTwo data)
  260. {
  261. Dictionary<string, object> Fields = new Dictionary<string, object>();
  262. Fields.Add("PosSnType", data.PosSnType);
  263. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, data.Id);
  264. AddSysLog(data.Id.ToString(), "PosMachinesTwo", "update");
  265. db.SaveChanges();
  266. return "success";
  267. }
  268. #endregion
  269. #region 未使用机具归位总仓
  270. /// <summary>
  271. /// 未使用机具归位总仓
  272. /// </summary>
  273. /// <returns></returns>
  274. public IActionResult Home(string right, int Id = 0)
  275. {
  276. ViewBag.RightInfo = RightInfo;
  277. ViewBag.right = right;
  278. PosMachinesTwo editData = db.PosMachinesTwo.FirstOrDefault(m => m.Id == Id) ?? new PosMachinesTwo();
  279. ViewBag.data = editData;
  280. return View();
  281. }
  282. #endregion
  283. #region 未使用机具归位总仓
  284. /// <summary>
  285. /// 未使用机具归位总仓
  286. /// </summary>
  287. /// <returns></returns>
  288. [HttpPost]
  289. public string Home(PosMachinesTwo data)
  290. {
  291. Dictionary<string, object> Fields = new Dictionary<string, object>();
  292. Fields.Add("SeoTitle", "");
  293. Fields.Add("SeoKeyword", "");
  294. Fields.Add("PosSnType", 0);
  295. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, data.Id);
  296. AddSysLog(data.Id.ToString(), "PosMachinesTwo", "home");
  297. db.SaveChanges();
  298. return "success";
  299. }
  300. #endregion
  301. #region 删除机具库信息
  302. /// <summary>
  303. /// 删除机具库信息
  304. /// </summary>
  305. /// <returns></returns>
  306. public string Delete(string Id)
  307. {
  308. string[] idlist = Id.Split(new char[] { ',' });
  309. AddSysLog(Id, "PosMachinesTwo", "del");
  310. foreach (string subid in idlist)
  311. {
  312. int id = int.Parse(subid);
  313. Dictionary<string, object> Fields = new Dictionary<string, object>();
  314. Fields.Add("Status", -1);
  315. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  316. }
  317. db.SaveChanges();
  318. return "success";
  319. }
  320. #endregion
  321. #region 开启
  322. /// <summary>
  323. /// 开启
  324. /// </summary>
  325. /// <returns></returns>
  326. public string Open(string Id)
  327. {
  328. string[] idlist = Id.Split(new char[] { ',' });
  329. AddSysLog(Id, "PosMachinesTwo", "open");
  330. foreach (string subid in idlist)
  331. {
  332. int id = int.Parse(subid);
  333. Dictionary<string, object> Fields = new Dictionary<string, object>();
  334. Fields.Add("Status", 1);
  335. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  336. }
  337. db.SaveChanges();
  338. return "success";
  339. }
  340. #endregion
  341. #region 关闭
  342. /// <summary>
  343. /// 关闭
  344. /// </summary>
  345. /// <returns></returns>
  346. public string Close(string Id)
  347. {
  348. string[] idlist = Id.Split(new char[] { ',' });
  349. AddSysLog(Id, "PosMachinesTwo", "close");
  350. foreach (string subid in idlist)
  351. {
  352. int id = int.Parse(subid);
  353. Dictionary<string, object> Fields = new Dictionary<string, object>();
  354. Fields.Add("Status", 0);
  355. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  356. }
  357. db.SaveChanges();
  358. return "success";
  359. }
  360. #endregion
  361. #region 排序
  362. /// <summary>
  363. /// 排序
  364. /// </summary>
  365. /// <param name="Id"></param>
  366. public string Sort(int Id, int Sort)
  367. {
  368. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("PosMachinesTwo", Sort, Id);
  369. AddSysLog(Id.ToString(), "PosMachinesTwo", "sort");
  370. return "success";
  371. }
  372. #endregion
  373. #region 批量调升费率
  374. /// <summary>
  375. /// 批量调升费率
  376. /// </summary>
  377. /// <returns></returns>
  378. public string BatchSetting(string Id)
  379. {
  380. string opdate = function.ReadInstance("/PublicParams/UpFeeDate/" + DateTime.Now.ToString("yyyyMMdd") + ".txt");
  381. if (!string.IsNullOrEmpty(opdate))
  382. {
  383. return "已提交,请勿重复操作";
  384. }
  385. function.WritePage("/PublicParams/UpFeeDate/", DateTime.Now.ToString("yyyyMMdd") + ".txt", DateTime.Now.ToString("HH:mm:ss"));
  386. AddSysLog(Id, "PosMachinesTwo", "UpFeePosMachinesTwo");
  387. List<int> posIds = new List<int>();
  388. List<int> upposIds = new List<int>();
  389. string userIds = "";
  390. DateTime check = DateTime.Now.AddDays(-90);
  391. List<PosMachinesTwo> poslist = db.PosMachinesTwo.Where(m => m.Status > -1 && m.BindingState == 1 && m.UpFeeFlag == 1 && m.DownFeeFlag == 0 && m.BindingTime <= check && m.SeoDescription != "设置成功" && m.BrandId != 6).ToList();//非盒子
  392. foreach (PosMachinesTwo pos in poslist)
  393. {
  394. Dictionary<string, object> Fields = new Dictionary<string, object>();
  395. Fields.Add("UpFeeFlag", 1);
  396. Fields.Add("UpFeeMan", SysUserName);
  397. Fields.Add("UpFeeDate", DateTime.Now);
  398. if (!userIds.Contains(pos.BuyUserId.ToString()))
  399. {
  400. userIds += pos.BuyUserId + ",";
  401. }
  402. string info = "{\"RecordId\":\"\",\"PosId\":\"" + pos.Id + "\",\"Fee\": \"" + 0.63 + "\",\"Kind\": \"" + 1 + "\",\"OpMan\": \"" + SysUserName + "\"}";
  403. RedisDbconn.Instance.AddList("SetDepositPostQueue", info);
  404. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, pos.Id);
  405. }
  406. db.SaveChanges();
  407. return "success";
  408. }
  409. #endregion
  410. #region 导入费率调整结果
  411. /// <summary>
  412. /// 导入费率调整结果
  413. /// </summary>
  414. /// <param name="ExcelData"></param>
  415. public string ImportEnd(string ExcelData)
  416. {
  417. ExcelData = HttpUtility.UrlDecode(ExcelData);
  418. JsonData list = JsonMapper.ToObject(ExcelData);
  419. List<int> dnposIds = new List<int>();
  420. string userIds = "";
  421. string warning = "";
  422. for (int i = 1; i < list.Count; i++)
  423. {
  424. JsonData dr = list[i];
  425. string PosNo = dr[0].ToString(); // 机具Sn
  426. var Amount = double.Parse(dr[1].ToString()); // 调整费率
  427. int Kind = int.Parse(dr[2].ToString()); // 1 调升 2 调低
  428. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosNo) ?? new PosMachinesTwo();
  429. if (pos.UpFeeFlag == 1)
  430. {
  431. if (Kind != 2 || Amount != 0.6)
  432. {
  433. warning += PosNo + ",该机具调低费率数值或类型不正确,请检查好后全部重新导入";
  434. }
  435. else
  436. {
  437. if (Kind == 2 && Amount == 0.6)
  438. {
  439. pos.DownFeeFlag = 1;
  440. pos.DownFeeDate = DateTime.Now;
  441. pos.DownFeeMan = SysUserName + "_" + SysRealName;
  442. var poschange = db.PosMachinesFeeChangeRecord.FirstOrDefault(m => m.PosId == pos.Id);
  443. poschange.Status = 1;
  444. db.SaveChanges();
  445. dnposIds.Add(pos.Id);
  446. }
  447. if (!userIds.Contains(pos.BuyUserId.ToString()))
  448. {
  449. userIds += pos.BuyUserId + ",";
  450. }
  451. }
  452. }
  453. else
  454. {
  455. warning += PosNo + ",该机具不符合调低条件,请检查好后全部重新导入";
  456. }
  457. }
  458. if (!string.IsNullOrEmpty(warning))
  459. {
  460. return "waning |" + warning;
  461. }
  462. string[] lists = userIds.TrimEnd(',').Split(new char[] { ',' });
  463. int times = lists.ToList().Count;
  464. if (dnposIds.Count > 0)
  465. {
  466. //调降
  467. for (int i = 0; i < times; i++)
  468. {
  469. var UserId = lists[i];
  470. var posInfo = db.PosMachinesTwo.Where(m => dnposIds.Contains(m.Id) && m.BuyUserId == Convert.ToInt32(UserId)).ToList();
  471. string snhtml = "<div style='margin-bottom: .48rem;'>";
  472. foreach (var items in posInfo)
  473. {
  474. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == items.BindMerchantId);
  475. string Name = mer.MerchantName;
  476. if (mer.BrandId == 2)
  477. {
  478. if (Name.Contains("-"))
  479. {
  480. Name = Name.Split('-')[1];
  481. }
  482. else if (Name.Contains("_"))
  483. {
  484. Name = Name.Split('_')[1];
  485. }
  486. }
  487. var brand = db.KqProducts.FirstOrDefault(m => m.Id == items.BrandId);
  488. snhtml += "<div style='margin-bottom: .48rem;'><div class='f16'>商户姓名:" + Name + "</div>";
  489. snhtml += "<div class='f16'>机具品牌:" + brand.Name + "</div>";
  490. snhtml += "<div class='f16'>SN:" + items.PosSn + "</div>";
  491. snhtml += "<div class='f16'>当前费率:0.6%</div>";
  492. snhtml += "<div class='f16'>费率调整时间:" + items.DownFeeDate + "</div></div>";
  493. }
  494. snhtml += "</div>";
  495. RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
  496. {
  497. UserId = Convert.ToInt32(UserId), //创客
  498. Title = "商户费率变更通知", //标题
  499. Content = "<div class='f16' style='margin-bottom: .72rem'>您的商户刷卡交易费率已变更成功!</div>" + snhtml, //内容
  500. Summary = "您的商户刷卡交易费率已变更成功!",
  501. CreateDate = DateTime.Now,
  502. }));
  503. }
  504. }
  505. AddSysLog("0", "PosMachinesTwoChange", "ImportEnd");
  506. return "success";
  507. }
  508. #endregion
  509. #region 导入数据
  510. public IActionResult Import(string right)
  511. {
  512. ViewBag.RightInfo = RightInfo;
  513. ViewBag.right = right;
  514. return View();
  515. }
  516. /// <summary>
  517. /// 导入数据
  518. /// </summary>
  519. /// <param name="ExcelData"></param>
  520. [HttpPost]
  521. public string ImportPost(string ExcelPath)
  522. {
  523. string key = function.MD5_16(Guid.NewGuid().ToString());
  524. RedisDbconn.Instance.AddList("ExcelImport10", ExcelPath + "#cut#ChangeFee#cut#" + key + "#cut#" + SysUserName);
  525. return "success|" + key;
  526. }
  527. public string CheckImport(string key)
  528. {
  529. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  530. if (!string.IsNullOrEmpty(result))
  531. {
  532. string[] datalist = result.Split('|');
  533. if (datalist[0] == "success")
  534. {
  535. return result;
  536. }
  537. return datalist[0];
  538. }
  539. return "0";
  540. }
  541. public Dictionary<string, object> CheckImportV2(string key)
  542. {
  543. Dictionary<string, object> Obj = new Dictionary<string, object>();
  544. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  545. if (!string.IsNullOrEmpty(result))
  546. {
  547. string[] datalist = result.Split('|');
  548. if (datalist[0] == "success")
  549. {
  550. List<string> errList = RedisDbconn.Instance.GetList<string>("ErrList" + key);
  551. if (errList.Count > 0)
  552. {
  553. Obj.Add("status", 2);
  554. Obj.Add("errList", errList);
  555. }
  556. else
  557. {
  558. Obj.Add("status", 1);
  559. Obj.Add("data", result);
  560. }
  561. return Obj;
  562. }
  563. Obj.Add("status", 0);
  564. Obj.Add("data", datalist[0]);
  565. return Obj;
  566. }
  567. Obj.Add("status", -1);
  568. Obj.Add("data", "执行中...");
  569. return Obj;
  570. }
  571. #endregion
  572. #region 导出Excel
  573. /// <summary>
  574. /// 导出Excel
  575. /// </summary>
  576. /// <returns></returns>
  577. public JsonResult ExportExcel(PosMachinesTwo data, string BindingStateSelect, string ActivationStateSelect, string UserIdMakerCode, string UserIdRealName, string StoreIdCode, string StoreIdName, string UpFeeFlagSelect)
  578. {
  579. Dictionary<string, string> Fields = new Dictionary<string, string>();
  580. Fields.Add("PosSn", "1"); //SN编号
  581. Fields.Add("BrandId", "0"); //品牌
  582. string condition = " and Status>-1 and BrandId = " + data.BrandId + " ";
  583. //绑定状态
  584. if (!string.IsNullOrEmpty(BindingStateSelect))
  585. {
  586. condition += " and BindingState=" + BindingStateSelect;
  587. }
  588. //激活状态
  589. if (!string.IsNullOrEmpty(ActivationStateSelect))
  590. {
  591. condition += " and ActivationState=" + ActivationStateSelect;
  592. }
  593. //所属创客编号
  594. if (!string.IsNullOrEmpty(UserIdMakerCode))
  595. {
  596. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  597. }
  598. //所属创客真实姓名
  599. if (!string.IsNullOrEmpty(UserIdRealName))
  600. {
  601. condition += " and UserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  602. }
  603. //所属仓库编号
  604. if (!string.IsNullOrEmpty(StoreIdCode))
  605. {
  606. condition += " and StoreId in (select StoreId from StoreForCode where Code='" + StoreIdCode + "')";
  607. }
  608. //所属仓库名称
  609. if (!string.IsNullOrEmpty(StoreIdName))
  610. {
  611. condition += " and StoreId in (select StoreId from StoreForName where Name='" + StoreIdName + "')";
  612. }
  613. //是否调整
  614. if (!string.IsNullOrEmpty(UpFeeFlagSelect))
  615. {
  616. condition += " and UpFeeFlag = " + UpFeeFlagSelect;
  617. }
  618. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("PosMachinesTwo", Fields, "Id desc", "0", 1, 20000, condition, "BindingState,ActivationState,UserId,StoreId,PosSn,BrandId,ActivityList,BindMerchantId,PosSnType,DeviceType,BindingTime,UpFeeDate,DownFeeDate,ActivationTime,TransferTime", false);
  619. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  620. foreach (Dictionary<string, object> dic in diclist)
  621. {
  622. //绑定状态
  623. int BindingState = int.Parse(dic["BindingState"].ToString());
  624. if (BindingState == 0) dic["BindingState"] = "未绑定";
  625. if (BindingState == 1) dic["BindingState"] = "已绑定";
  626. //绑定时间
  627. if (!string.IsNullOrEmpty(dic["BindingTime"].ToString()))
  628. {
  629. DateTime BindingTime = Convert.ToDateTime(dic["BindingTime"].ToString());
  630. }
  631. //激活状态
  632. int ActivationState = int.Parse(dic["ActivationState"].ToString());
  633. if (ActivationState == 0) dic["ActivationState"] = "未激活";
  634. if (ActivationState == 1) dic["ActivationState"] = "已激活";
  635. //激活时间
  636. if (!string.IsNullOrEmpty(dic["ActivationTime"].ToString()))
  637. {
  638. DateTime ActivationTime = Convert.ToDateTime(dic["ActivationTime"].ToString());
  639. }
  640. //划拨时间
  641. if (!string.IsNullOrEmpty(dic["TransferTime"].ToString()))
  642. {
  643. DateTime TransferTime = Convert.ToDateTime(dic["TransferTime"].ToString());
  644. }
  645. //调升时间
  646. if (!string.IsNullOrEmpty(dic["UpFeeDate"].ToString()))
  647. {
  648. DateTime UpFeeDate = Convert.ToDateTime(dic["UpFeeDate"].ToString());
  649. }
  650. //调降时间
  651. if (!string.IsNullOrEmpty(dic["DownFeeDate"].ToString()))
  652. {
  653. DateTime DownFeeDate = Convert.ToDateTime(dic["DownFeeDate"].ToString());
  654. }
  655. //所属创客
  656. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  657. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  658. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  659. dic["UserIdRealName"] = userid_Users.RealName;
  660. dic.Remove("UserId");
  661. //所属仓库
  662. int StoreId = int.Parse(function.CheckInt(dic["StoreId"].ToString()));
  663. StoreHouse storeid_StoreHouse = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId) ?? new StoreHouse();
  664. dic["StoreIdCode"] = storeid_StoreHouse.StoreNo;
  665. dic["StoreIdName"] = storeid_StoreHouse.StoreName;
  666. dic.Remove("StoreId");
  667. //产品类型
  668. dic["BrandId"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  669. //绑定商户
  670. int BindMerchantId = int.Parse(function.CheckInt(dic["BindMerchantId"].ToString()));
  671. PosMerchantInfo bindmerchantid_MerchantInfo = db.PosMerchantInfo.FirstOrDefault(m => m.Id == BindMerchantId) ?? new PosMerchantInfo();
  672. dic["BindMerchantIdMerchantNo"] = bindmerchantid_MerchantInfo.MerchantNo;
  673. dic["BindMerchantIdMerchantName"] = bindmerchantid_MerchantInfo.MerchantName;
  674. dic.Remove("BindMerchantId");
  675. //机具类型
  676. int PosSnType = int.Parse(dic["PosSnType"].ToString());
  677. if (PosSnType == 0) dic["PosSnType"] = "兑换机具";
  678. if (PosSnType == 1) dic["PosSnType"] = "循环机具";
  679. }
  680. Dictionary<string, object> result = new Dictionary<string, object>();
  681. result.Add("Status", "1");
  682. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  683. result.Add("Obj", diclist);
  684. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  685. ReturnFields.Add("UserIdMakerCode", "创客编号");
  686. ReturnFields.Add("UserIdRealName", "创客姓名");
  687. ReturnFields.Add("StoreIdCode", "仓库编号");
  688. ReturnFields.Add("StoreIdName", "仓库名称");
  689. ReturnFields.Add("BrandId", "产品类型");
  690. ReturnFields.Add("PosSn", "SN编号");
  691. ReturnFields.Add("PosSnType", "SN类型");
  692. ReturnFields.Add("BindMerchantIdMerchantNo", "绑定商户编号");
  693. ReturnFields.Add("BindMerchantIdMerchantName", "绑定商户姓名");
  694. ReturnFields.Add("DeviceType", "设备类型");
  695. ReturnFields.Add("BindingState", "绑定状态");
  696. ReturnFields.Add("BindingTime", "绑定时间");
  697. ReturnFields.Add("ActivationState", "激活状态");
  698. ReturnFields.Add("ActivationTime", "激活时间");
  699. ReturnFields.Add("TransferTime", "划拨时间");
  700. ReturnFields.Add("UpFeeFlag", "调升标记");
  701. ReturnFields.Add("UpFeeDate", "调升时间");
  702. ReturnFields.Add("UpFeeMan", "调升人");
  703. ReturnFields.Add("DownFeeFlag", "调降标记");
  704. ReturnFields.Add("DownFeeDate", "调降时间");
  705. ReturnFields.Add("DownFeeMan", "调降人");
  706. result.Add("Fields", ReturnFields);
  707. AddSysLog("0", "PosMachinesTwo", "ExportExcel");
  708. return Json(result);
  709. }
  710. #endregion
  711. }
  712. }