PosMachinesTwoChangeController.cs 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866
  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 UpFeeFlagSelect, string UserIdMakerCode, string UserIdRealName, string StoreIdCode, string StoreIdName, string ActivationDateData, string BindingDateData, 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 180 DAY) >= date(BindingTime)";
  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. condition += " and BrandId = " + data.BrandId;
  84. if (!string.IsNullOrEmpty(UpFeeFlagSelect))
  85. {
  86. condition += " and UpFeeFlag = " + UpFeeFlagSelect;
  87. }
  88. if (!string.IsNullOrEmpty(ActivationDateData))
  89. {
  90. string[] datelist = ActivationDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  91. string start = datelist[0];
  92. string end = datelist[1];
  93. condition += " and ActivationTime>='" + start + " 00:00:00' and ActivationTime<='" + end + " 23:59:59'";
  94. }
  95. if (!string.IsNullOrEmpty(BindingDateData))
  96. {
  97. string[] datelist = BindingDateData.Split(new string[] { " - " }, StringSplitOptions.None);
  98. string start = datelist[0];
  99. string end = datelist[1];
  100. condition += " and BindingTime>='" + start + " 00:00:00' and BindingTime<='" + end + " 23:59:59'";
  101. }
  102. Dictionary<string, object> obj = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).IndexData("PosMachinesTwo", Fields, "Id desc", "0", page, limit, condition);
  103. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  104. foreach (Dictionary<string, object> dic in diclist)
  105. {
  106. //绑定状态
  107. int BindingState = int.Parse(dic["BindingState"].ToString());
  108. if (BindingState == 0) dic["BindingState"] = "未绑定";
  109. if (BindingState == 1) dic["BindingState"] = "已绑定";
  110. //激活状态
  111. int ActivationState = int.Parse(dic["ActivationState"].ToString());
  112. if (ActivationState == 0) dic["ActivationState"] = "未激活";
  113. if (ActivationState == 1) dic["ActivationState"] = "已激活";
  114. //所属创客
  115. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  116. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  117. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  118. dic["UserIdRealName"] = userid_Users.RealName;
  119. dic.Remove("UserId");
  120. //所属仓库
  121. int StoreId = int.Parse(function.CheckInt(dic["StoreId"].ToString()));
  122. StoreHouse storeid_StoreHouse = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId) ?? new StoreHouse();
  123. dic["StoreIdCode"] = storeid_StoreHouse.StoreNo;
  124. dic["StoreIdName"] = storeid_StoreHouse.StoreName;
  125. dic.Remove("StoreId");
  126. //产品类型
  127. dic["BrandId"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  128. //参加活动
  129. dic["ActivityList"] = RelationClass.GetProfitObjectsActivesList(dic["ActivityList"].ToString());
  130. //绑定商户
  131. int BindMerchantId = int.Parse(function.CheckInt(dic["BindMerchantId"].ToString()));
  132. PosMerchantInfo bindmerchantid_MerchantInfo = db.PosMerchantInfo.FirstOrDefault(m => m.Id == BindMerchantId) ?? new PosMerchantInfo();
  133. dic["BindMerchantIdMerchantNo"] = bindmerchantid_MerchantInfo.MerchantNo;
  134. dic["BindMerchantIdMerchantName"] = bindmerchantid_MerchantInfo.MerchantName;
  135. dic.Remove("BindMerchantId");
  136. //机具类型
  137. int PosSnType = int.Parse(dic["PosSnType"].ToString());
  138. if (PosSnType == 0) dic["PosSnType"] = "购买机具";
  139. if (PosSnType == 1) dic["PosSnType"] = "赠送机具";
  140. //设备类型
  141. string DeviceType = dic["DeviceType"].ToString();
  142. if (DeviceType == "KysSignPos") dic["DeviceType"] = "快益刷电签POS";
  143. if (DeviceType == "KssSignPos") dic["DeviceType"] = "快闪刷电签POS";
  144. if (DeviceType == "") dic["DeviceType"] = "";
  145. //盟主信息
  146. int LeaderUserId = int.Parse(function.CheckInt(dic["LeaderUserId"].ToString()));
  147. if (LeaderUserId != 0)
  148. {
  149. Users users = db.Users.FirstOrDefault(m => m.Id == LeaderUserId) ?? new Users();
  150. dic["UserInfo"] = users.MakerCode + "_" + users.RealName;
  151. }
  152. //是否为第一台机具
  153. int IsFirst = int.Parse(dic["IsFirst"].ToString());
  154. if (IsFirst == 0) dic["IsFirst"] = "否";
  155. if (IsFirst == 1) dic["IsFirst"] = "是";
  156. //循环开始时间
  157. if (!string.IsNullOrEmpty(dic["RecycEndDate"].ToString()))
  158. {
  159. var RecycStartDate = Convert.ToDateTime(dic["RecycEndDate"].ToString()).AddMonths(-3).ToString("yyyy-MM-dd HH:mm:ss");
  160. dic["RecycStartDate"] = RecycStartDate;
  161. }
  162. //是否调升
  163. int UpFeeFlag = int.Parse(dic["UpFeeFlag"].ToString());
  164. if (UpFeeFlag == 0) dic["UpFeeFlag"] = "否";
  165. if (UpFeeFlag == 1) dic["UpFeeFlag"] = "是";
  166. //是否调降
  167. int DownFeeFlag = int.Parse(dic["DownFeeFlag"].ToString());
  168. if (DownFeeFlag == 0) dic["DownFeeFlag"] = "否";
  169. if (DownFeeFlag == 1) dic["DownFeeFlag"] = "是";
  170. //调升时间
  171. if (!string.IsNullOrEmpty(dic["UpFeeDate"].ToString()))
  172. {
  173. var UpFeeDate = Convert.ToDateTime(dic["UpFeeDate"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
  174. dic["UpFeeDate"] = UpFeeDate;
  175. }
  176. //调降时间
  177. if (!string.IsNullOrEmpty(dic["DownFeeDate"].ToString()))
  178. {
  179. var DownFeeDate = Convert.ToDateTime(dic["DownFeeDate"].ToString()).ToString("yyyy-MM-dd HH:mm:ss");
  180. dic["DownFeeDate"] = DownFeeDate;
  181. }
  182. }
  183. Dictionary<string, object> other = new Dictionary<string, object>();
  184. int TotalCount = 0;//总机具数
  185. string KysCount99 = "0.00";
  186. string KssCount99 = "0.00";
  187. string KssCoun198 = "0.00";
  188. string KssCount298 = "0.00";
  189. DataTable dt = OtherMySqlConn.dtable("select count(0) from PosMachinesTwo where 1=1" + condition);
  190. if (dt.Rows.Count > 0)
  191. {
  192. TotalCount = int.Parse(function.CheckNum(dt.Rows[0][0].ToString()));
  193. }
  194. // dt = OtherMySqlConn.dtable("select sum(TotalPrice) from Orders where PayStatus=1" + condition);
  195. // if (dt.Rows.Count > 0)
  196. // {
  197. // FailAmount = decimal.Parse(function.CheckNum(dt.Rows[0][0].ToString())).ToString("f2");
  198. // }
  199. other.Add("TotalCount", TotalCount);
  200. other.Add("KysCount99", 0);
  201. other.Add("KssCount99", 0);
  202. other.Add("KssCoun198", 0);
  203. other.Add("KssCount298", 0);
  204. obj.Add("other", other);
  205. return Json(obj);
  206. }
  207. #endregion
  208. #region 增加机具库
  209. /// <summary>
  210. /// 增加或修改机具库信息
  211. /// </summary>
  212. /// <returns></returns>
  213. public IActionResult Add(string right)
  214. {
  215. ViewBag.RightInfo = RightInfo;
  216. ViewBag.right = right;
  217. return View();
  218. }
  219. #endregion
  220. #region 增加机具库
  221. /// <summary>
  222. /// 增加或修改机具库信息
  223. /// </summary>
  224. /// <returns></returns>
  225. [HttpPost]
  226. public string Add(PosMachinesTwo data)
  227. {
  228. Dictionary<string, object> Fields = new Dictionary<string, object>();
  229. Fields.Add("SeoTitle", data.SeoTitle);
  230. Fields.Add("SeoKeyword", data.SeoKeyword);
  231. Fields.Add("SeoDescription", data.SeoDescription);
  232. int Id = new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Add("PosMachinesTwo", Fields, 0);
  233. AddSysLog(data.Id.ToString(), "PosMachinesTwo", "add");
  234. db.SaveChanges();
  235. return "success";
  236. }
  237. #endregion
  238. #region 修改机具库
  239. /// <summary>
  240. /// 增加或修改机具库信息
  241. /// </summary>
  242. /// <returns></returns>
  243. public IActionResult Edit(string right, int Id = 0)
  244. {
  245. ViewBag.RightInfo = RightInfo;
  246. ViewBag.right = right;
  247. PosMachinesTwo editData = db.PosMachinesTwo.FirstOrDefault(m => m.Id == Id) ?? new PosMachinesTwo();
  248. ViewBag.data = editData;
  249. return View();
  250. }
  251. #endregion
  252. #region 修改机具库
  253. /// <summary>
  254. /// 增加或修改机具库信息
  255. /// </summary>
  256. /// <returns></returns>
  257. [HttpPost]
  258. public string Edit(PosMachinesTwo data)
  259. {
  260. Dictionary<string, object> Fields = new Dictionary<string, object>();
  261. Fields.Add("PosSnType", data.PosSnType);
  262. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, data.Id);
  263. AddSysLog(data.Id.ToString(), "PosMachinesTwo", "update");
  264. db.SaveChanges();
  265. RedisDbconn.Instance.Clear("PosMachinesTwo:" + data.Id);
  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. RedisDbconn.Instance.Clear("PosMachinesTwo:" + data.Id);
  299. return "success";
  300. }
  301. #endregion
  302. #region 删除机具库信息
  303. /// <summary>
  304. /// 删除机具库信息
  305. /// </summary>
  306. /// <returns></returns>
  307. public string Delete(string Id)
  308. {
  309. string[] idlist = Id.Split(new char[] { ',' });
  310. AddSysLog(Id, "PosMachinesTwo", "del");
  311. foreach (string subid in idlist)
  312. {
  313. int id = int.Parse(subid);
  314. Dictionary<string, object> Fields = new Dictionary<string, object>();
  315. Fields.Add("Status", -1);
  316. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  317. }
  318. db.SaveChanges();
  319. return "success";
  320. }
  321. #endregion
  322. #region 开启
  323. /// <summary>
  324. /// 开启
  325. /// </summary>
  326. /// <returns></returns>
  327. public string Open(string Id)
  328. {
  329. string[] idlist = Id.Split(new char[] { ',' });
  330. AddSysLog(Id, "PosMachinesTwo", "open");
  331. foreach (string subid in idlist)
  332. {
  333. int id = int.Parse(subid);
  334. Dictionary<string, object> Fields = new Dictionary<string, object>();
  335. Fields.Add("Status", 1);
  336. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  337. }
  338. db.SaveChanges();
  339. return "success";
  340. }
  341. #endregion
  342. #region 关闭
  343. /// <summary>
  344. /// 关闭
  345. /// </summary>
  346. /// <returns></returns>
  347. public string Close(string Id)
  348. {
  349. string[] idlist = Id.Split(new char[] { ',' });
  350. AddSysLog(Id, "PosMachinesTwo", "close");
  351. foreach (string subid in idlist)
  352. {
  353. int id = int.Parse(subid);
  354. Dictionary<string, object> Fields = new Dictionary<string, object>();
  355. Fields.Add("Status", 0);
  356. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  357. }
  358. db.SaveChanges();
  359. return "success";
  360. }
  361. #endregion
  362. #region 排序
  363. /// <summary>
  364. /// 排序
  365. /// </summary>
  366. /// <param name="Id"></param>
  367. public string Sort(int Id, int Sort)
  368. {
  369. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Sort("PosMachinesTwo", Sort, Id);
  370. AddSysLog(Id.ToString(), "PosMachinesTwo", "sort");
  371. return "success";
  372. }
  373. #endregion
  374. #region 批量调升费率
  375. /// <summary>
  376. /// 批量调升费率
  377. /// </summary>
  378. /// <returns></returns>
  379. public string BatchSetting(string Id)
  380. {
  381. string[] idlist = Id.Split(new char[] { ',' });
  382. AddSysLog(Id, "PosMachinesTwo", "UpFeePosMachinesTwo");
  383. List<int> posIds = new List<int>();
  384. string userIds = "";
  385. string warning = "";
  386. if (!string.IsNullOrEmpty(warning))
  387. {
  388. return "Warning |" + warning;
  389. }
  390. foreach (string subids in idlist)
  391. {
  392. int id = int.Parse(subids);
  393. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.Id == id) ?? new PosMachinesTwo();
  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 (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 6)
  399. {
  400. if (!userIds.Contains(pos.BuyUserId.ToString()))
  401. {
  402. userIds += pos.BuyUserId + ",";
  403. }
  404. posIds.Add(id);
  405. // PosId:机具Id
  406. // Kind:1或2,1为费率0.63,2为费率0.6
  407. // OpMan:操作人,app传创客编号,后台传SysUserName
  408. string info = "{\"PosId\":" + id + "\"\",\"Fee\": " + 0.63 + "\"\",\"Kind\": " + 1 + "\"\",\"OpMan\": " + SysUserName + "\"\"}";
  409. RedisDbconn.Instance.AddList("SetDepositQueue", info);
  410. }
  411. else
  412. {
  413. warning += "以下机具调升失败 :" + pos.PosSn + '\n' + "目前只支持金控、立刷";
  414. }
  415. new AdminContentOther(_accessor.HttpContext, PublicFunction.MainTables).Edit("PosMachinesTwo", Fields, id);
  416. }
  417. db.SaveChanges();
  418. db.Dispose();
  419. return "success";
  420. }
  421. #endregion
  422. #region 导入费率调整结果
  423. /// <summary>
  424. /// 导入费率调整结果
  425. /// </summary>
  426. /// <param name="ExcelData"></param>
  427. public string ImportEnd(string ExcelData)
  428. {
  429. ExcelData = HttpUtility.UrlDecode(ExcelData);
  430. JsonData list = JsonMapper.ToObject(ExcelData);
  431. List<int> upposIds = new List<int>();
  432. List<int> dnposIds = new List<int>();
  433. string userIds = "";
  434. string warning = "";
  435. for (int i = 1; i < list.Count; i++)
  436. {
  437. JsonData dr = list[i];
  438. string PosNo = dr[0].ToString(); // 机具Sn
  439. decimal Amount = decimal.Parse(dr[1].ToString()); // 调整费率
  440. int Kind = int.Parse(dr[2].ToString()); // 1 调升 2 调低
  441. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosNo) ?? new PosMachinesTwo();
  442. if (pos.BrandId == 1 || pos.BrandId == 3 || pos.BrandId == 6)
  443. {
  444. warning += PosNo + ",该机具应直接设置,请全部重新导入";
  445. }
  446. if (!string.IsNullOrEmpty(warning))
  447. {
  448. return "waning |" + warning;
  449. }
  450. }
  451. for (int i = 1; i < list.Count; i++)
  452. {
  453. JsonData dr = list[i];
  454. string PosNo = dr[0].ToString(); // 机具Sn
  455. decimal Amount = decimal.Parse(dr[1].ToString()); // 调整费率
  456. int Kind = int.Parse(dr[2].ToString()); // 1 调升 2 调低
  457. var pos = db.PosMachinesTwo.FirstOrDefault(m => m.PosSn == PosNo) ?? new PosMachinesTwo();
  458. if (Kind == 1)
  459. {
  460. pos.UpFeeFlag = 1;
  461. pos.UpFeeDate = DateTime.Now;
  462. pos.UpFeeMan = SysUserName + "_" + SysRealName;
  463. db.SaveChanges();
  464. upposIds.Add(pos.Id);
  465. }
  466. if (Kind == 2)
  467. {
  468. pos.DownFeeFlag = 1;
  469. pos.DownFeeDate = DateTime.Now;
  470. pos.DownFeeMan = SysUserName + "_" + SysRealName;
  471. db.SaveChanges();
  472. dnposIds.Add(pos.Id);
  473. }
  474. if (!userIds.Contains(pos.BuyUserId.ToString()))
  475. {
  476. userIds += pos.BuyUserId + ",";
  477. }
  478. }
  479. string[] lists = userIds.TrimEnd(',').Split(new char[] { ',' });
  480. int times = lists.ToList().Count;
  481. if (upposIds.Count > 0)
  482. {
  483. //调升
  484. for (int i = 0; i < times; i++)
  485. {
  486. var UserId = lists[i];
  487. var posInfo = db.PosMachinesTwo.Where(m => upposIds.Contains(m.Id) && m.BuyUserId == Convert.ToInt32(UserId)).ToList();
  488. string snhtml = "<div style='margin-bottom: .48rem;'>";
  489. foreach (var items in posInfo)
  490. {
  491. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == items.BindMerchantId);
  492. string Name = mer.MerchantName;
  493. if (mer.BrandId == 2)
  494. {
  495. if (Name.Contains("-"))
  496. {
  497. Name = Name.Split('-')[1];
  498. }
  499. else if (Name.Contains("_"))
  500. {
  501. Name = Name.Split('_')[1];
  502. }
  503. }
  504. var brand = db.KqProducts.FirstOrDefault(m => m.Id == items.BrandId);
  505. snhtml += "<div style='margin-bottom: .48rem;'><div class='f16'>商户姓名:" + Name + "</div>";
  506. snhtml += "<div class='f16'>机具品牌:" + brand.Name + "</div>";
  507. snhtml += "<div class='f16'>SN:" + items.PosSn + "</div></div>";
  508. }
  509. snhtml += "</div>";
  510. RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
  511. {
  512. UserId = Convert.ToInt32(UserId), //创客
  513. Title = "商户费率变更通知", //标题
  514. Content = "<div class='f16' style='margin-bottom: .72rem'>您的部分机具已绑定超过180天,刷卡费率已自动变更为0.63%,如需调整费率,请前往我的商户-商户详情中调整费率</div>" + snhtml, //内容
  515. Summary = "您的部分机具已绑定超过180天,刷卡费率已自动变更为0.63%,如需调整费率,请前往我的商户-商户详情中调整费率",
  516. CreateDate = DateTime.Now,
  517. }));
  518. }
  519. }
  520. if (dnposIds.Count > 0)
  521. {
  522. //调降
  523. for (int i = 0; i < times; i++)
  524. {
  525. var UserId = lists[i];
  526. var posInfo = db.PosMachinesTwo.Where(m => dnposIds.Contains(m.Id) && m.BuyUserId == Convert.ToInt32(UserId)).ToList();
  527. string snhtml = "<div style='margin-bottom: .48rem;'>";
  528. foreach (var items in posInfo)
  529. {
  530. var mer = db.PosMerchantInfo.FirstOrDefault(m => m.Id == items.BindMerchantId);
  531. string Name = mer.MerchantName;
  532. if (mer.BrandId == 2)
  533. {
  534. if (Name.Contains("-"))
  535. {
  536. Name = Name.Split('-')[1];
  537. }
  538. else if (Name.Contains("_"))
  539. {
  540. Name = Name.Split('_')[1];
  541. }
  542. }
  543. var brand = db.KqProducts.FirstOrDefault(m => m.Id == items.BrandId);
  544. snhtml += "<div style='margin-bottom: .48rem;'><div class='f16'>商户姓名:" + Name + "</div>";
  545. snhtml += "<div class='f16'>机具品牌:" + brand.Name + "</div>";
  546. snhtml += "<div class='f16'>SN:" + items.PosSn + "</div>";
  547. snhtml += "<div class='f16'>当前费率:0.6%</div>";
  548. snhtml += "<div class='f16'>费率调整时间:" + items.DownFeeDate + "</div></div>";
  549. }
  550. snhtml += "</div>";
  551. RedisDbconn.Instance.AddList("MsgPersonalQueue", Newtonsoft.Json.JsonConvert.SerializeObject(new MsgPersonal()
  552. {
  553. UserId = Convert.ToInt32(UserId), //创客
  554. Title = "商户费率变更通知", //标题
  555. Content = "<div class='f16' style='margin-bottom: .72rem'>您的商户刷卡交易费率已变更成功!</div>" + snhtml, //内容
  556. Summary = "您的商户刷卡交易费率已变更成功!",
  557. CreateDate = DateTime.Now,
  558. }));
  559. }
  560. }
  561. AddSysLog("0", "PosMachinesTwoChange", "ImportEnd");
  562. return "success";
  563. }
  564. #endregion
  565. #region 导入数据
  566. public IActionResult Import(string right)
  567. {
  568. ViewBag.RightInfo = RightInfo;
  569. ViewBag.right = right;
  570. return View();
  571. }
  572. /// <summary>
  573. /// 导入数据
  574. /// </summary>
  575. /// <param name="ExcelData"></param>
  576. [HttpPost]
  577. public string ImportPost(string ExcelPath)
  578. {
  579. string key = function.MD5_16(Guid.NewGuid().ToString());
  580. RedisDbconn.Instance.AddList("ExcelImportV2", ExcelPath + "#cut#ChangeFee#cut#" + key + "#cut#" + SysUserName);
  581. return "success|" + key;
  582. }
  583. public string CheckImport(string key)
  584. {
  585. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  586. if (!string.IsNullOrEmpty(result))
  587. {
  588. string[] datalist = result.Split('|');
  589. if (datalist[0] == "success")
  590. {
  591. return result;
  592. }
  593. return datalist[0];
  594. }
  595. return "0";
  596. }
  597. public Dictionary<string, object> CheckImportV2(string key)
  598. {
  599. Dictionary<string, object> Obj = new Dictionary<string, object>();
  600. string result = RedisDbconn.Instance.Get<string>("CheckImport:" + key);
  601. if (!string.IsNullOrEmpty(result))
  602. {
  603. string[] datalist = result.Split('|');
  604. if (datalist[0] == "success")
  605. {
  606. List<string> errList = RedisDbconn.Instance.GetList<string>("ErrList" + key);
  607. if (errList.Count > 0)
  608. {
  609. Obj.Add("status", 2);
  610. Obj.Add("errList", errList);
  611. }
  612. else
  613. {
  614. Obj.Add("status", 1);
  615. Obj.Add("data", result);
  616. }
  617. return Obj;
  618. }
  619. Obj.Add("status", 0);
  620. Obj.Add("data", datalist[0]);
  621. return Obj;
  622. }
  623. Obj.Add("status", -1);
  624. Obj.Add("data", "执行中...");
  625. return Obj;
  626. }
  627. #endregion
  628. #region 导出Excel
  629. /// <summary>
  630. /// 导出Excel
  631. /// </summary>
  632. /// <returns></returns>
  633. public JsonResult ExportExcel(PosMachinesTwo data, string BindingStateSelect, string ActivationStateSelect, string UserIdMakerCode, string UserIdRealName, string StoreIdCode, string StoreIdName)
  634. {
  635. Dictionary<string, string> Fields = new Dictionary<string, string>();
  636. Fields.Add("PosSn", "1"); //SN编号
  637. Fields.Add("BrandId", "0"); //品牌
  638. string condition = " and Status>-1";
  639. //绑定状态
  640. if (!string.IsNullOrEmpty(BindingStateSelect))
  641. {
  642. condition += " and BindingState=" + BindingStateSelect;
  643. }
  644. //激活状态
  645. if (!string.IsNullOrEmpty(ActivationStateSelect))
  646. {
  647. condition += " and ActivationState=" + ActivationStateSelect;
  648. }
  649. //所属创客创客编号
  650. if (!string.IsNullOrEmpty(UserIdMakerCode))
  651. {
  652. condition += " and UserId in (select UserId from UserForMakerCode where MakerCode='" + UserIdMakerCode + "')";
  653. }
  654. //所属创客真实姓名
  655. if (!string.IsNullOrEmpty(UserIdRealName))
  656. {
  657. condition += " and UserId in (select UserId from UserForRealName where RealName='" + UserIdRealName + "')";
  658. }
  659. //所属仓库编号
  660. if (!string.IsNullOrEmpty(StoreIdCode))
  661. {
  662. condition += " and StoreId in (select StoreId from StoreForCode where Code='" + StoreIdCode + "')";
  663. }
  664. //所属仓库名称
  665. if (!string.IsNullOrEmpty(StoreIdName))
  666. {
  667. condition += " and StoreId in (select StoreId from StoreForName where Name='" + StoreIdName + "')";
  668. }
  669. 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,ActivationTime,TransferTime", false);
  670. List<Dictionary<string, object>> diclist = obj["data"] as List<Dictionary<string, object>>;
  671. foreach (Dictionary<string, object> dic in diclist)
  672. {
  673. //绑定状态
  674. int BindingState = int.Parse(dic["BindingState"].ToString());
  675. if (BindingState == 0) dic["BindingState"] = "未绑定";
  676. if (BindingState == 1) dic["BindingState"] = "已绑定";
  677. //绑定时间
  678. if (!string.IsNullOrEmpty(dic["BindingTime"].ToString()))
  679. {
  680. DateTime BindingTime = Convert.ToDateTime(dic["BindingTime"].ToString());
  681. }
  682. //激活状态
  683. int ActivationState = int.Parse(dic["ActivationState"].ToString());
  684. if (ActivationState == 0) dic["ActivationState"] = "未激活";
  685. if (ActivationState == 1) dic["ActivationState"] = "已激活";
  686. //激活时间
  687. if (!string.IsNullOrEmpty(dic["ActivationTime"].ToString()))
  688. {
  689. DateTime ActivationTime = Convert.ToDateTime(dic["ActivationTime"].ToString());
  690. }
  691. //划拨时间
  692. if (!string.IsNullOrEmpty(dic["TransferTime"].ToString()))
  693. {
  694. DateTime TransferTime = Convert.ToDateTime(dic["TransferTime"].ToString());
  695. }
  696. //调升时间
  697. if (!string.IsNullOrEmpty(dic["UpFeeDate"].ToString()))
  698. {
  699. DateTime UpFeeDate = Convert.ToDateTime(dic["UpFeeDate"].ToString());
  700. }
  701. //调降时间
  702. if (!string.IsNullOrEmpty(dic["DownFeeDate"].ToString()))
  703. {
  704. DateTime DownFeeDate = Convert.ToDateTime(dic["DownFeeDate"].ToString());
  705. }
  706. //所属创客
  707. int UserId = int.Parse(function.CheckInt(dic["UserId"].ToString()));
  708. Users userid_Users = db.Users.FirstOrDefault(m => m.Id == UserId) ?? new Users();
  709. dic["UserIdMakerCode"] = userid_Users.MakerCode;
  710. dic["UserIdRealName"] = userid_Users.RealName;
  711. dic.Remove("UserId");
  712. //所属仓库
  713. int StoreId = int.Parse(function.CheckInt(dic["StoreId"].ToString()));
  714. StoreHouse storeid_StoreHouse = db.StoreHouse.FirstOrDefault(m => m.Id == StoreId) ?? new StoreHouse();
  715. dic["StoreIdCode"] = storeid_StoreHouse.StoreNo;
  716. dic["StoreIdName"] = storeid_StoreHouse.StoreName;
  717. dic.Remove("StoreId");
  718. //产品类型
  719. dic["BrandId"] = RelationClass.GetKqProductBrandInfo(int.Parse(dic["BrandId"].ToString()));
  720. //参加活动
  721. // dic["ActivityList"] = RelationClass.GetProfitObjectsActivesList(dic["ActivityList"].ToString());
  722. //绑定商户
  723. int BindMerchantId = int.Parse(function.CheckInt(dic["BindMerchantId"].ToString()));
  724. PosMerchantInfo bindmerchantid_MerchantInfo = db.PosMerchantInfo.FirstOrDefault(m => m.Id == BindMerchantId) ?? new PosMerchantInfo();
  725. dic["BindMerchantIdMerchantNo"] = bindmerchantid_MerchantInfo.MerchantNo;
  726. dic["BindMerchantIdMerchantName"] = bindmerchantid_MerchantInfo.MerchantName;
  727. dic.Remove("BindMerchantId");
  728. //机具类型
  729. int PosSnType = int.Parse(dic["PosSnType"].ToString());
  730. if (PosSnType == 0) dic["PosSnType"] = "购买机具";
  731. if (PosSnType == 1) dic["PosSnType"] = "赠送机具";
  732. // //设备类型
  733. // string DeviceType = dic["DeviceType"].ToString();
  734. // if (DeviceType == "KysSignPos") dic["DeviceType"] = "快益刷电签POS";
  735. // if (DeviceType == "KssSignPos") dic["DeviceType"] = "快闪刷电签POS";
  736. // if (DeviceType == "") dic["DeviceType"] = "";
  737. }
  738. Dictionary<string, object> result = new Dictionary<string, object>();
  739. result.Add("Status", "1");
  740. result.Add("Info", "Excel报表-" + DateTime.Now.ToString("yyyy-MM-ddTHH:mm:ss") + ".xlsx");
  741. result.Add("Obj", diclist);
  742. Dictionary<string, object> ReturnFields = new Dictionary<string, object>();
  743. ReturnFields.Add("UserIdMakerCode", "创客编号");
  744. ReturnFields.Add("UserIdRealName", "创客姓名");
  745. ReturnFields.Add("StoreIdCode", "仓库编号");
  746. ReturnFields.Add("StoreIdName", "仓库名称");
  747. ReturnFields.Add("BrandId", "产品类型");
  748. ReturnFields.Add("PosSn", "SN编号");
  749. ReturnFields.Add("PosSnType", "SN类型");
  750. // ReturnFields.Add("ActivityList", "参加活动");
  751. ReturnFields.Add("BindMerchantIdMerchantNo", "绑定商户编号");
  752. ReturnFields.Add("BindMerchantIdMerchantName", "绑定商户姓名");
  753. ReturnFields.Add("DeviceType", "设备类型");
  754. ReturnFields.Add("BindingState", "绑定状态");
  755. ReturnFields.Add("BindingTime", "绑定时间");
  756. ReturnFields.Add("ActivationState", "激活状态");
  757. ReturnFields.Add("ActivationTime", "激活时间");
  758. ReturnFields.Add("TransferTime", "划拨时间");
  759. ReturnFields.Add("UpFeeFlag", "调升标记");
  760. ReturnFields.Add("UpFeeDate", "调升时间");
  761. ReturnFields.Add("UpFeeMan", "调升人");
  762. ReturnFields.Add("DownFeeFlag", "调降标记");
  763. ReturnFields.Add("DownFeeDate", "调降时间");
  764. ReturnFields.Add("DownFeeMan", "调降人");
  765. result.Add("Fields", ReturnFields);
  766. AddSysLog("0", "PosMachinesTwo", "ExportExcel");
  767. return Json(result);
  768. }
  769. #endregion
  770. }
  771. }