足力健后端,使用.netcore版本,合并1个项目使用

KFOrderController.cs 62KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426
  1. /* =============================================
  2. -- Author: <Author,,zhangkun>
  3. -- Create date: <Create Date,,20200618>
  4. -- Description: <Description,,订单相关操作)>
  5. -- ============================================*/
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Common;
  9. using System.Common.Helpers;
  10. using System.Data;
  11. using System.IRepositories;
  12. using System.IRepositories.Bus;
  13. using System.Linq;
  14. using System.Linq.Expressions;
  15. using System.Model;
  16. using System.Model.Bus;
  17. using System.Repositories;
  18. using System.Security.Claims;
  19. using System.Threading.Tasks;
  20. using System.Utility.Http;
  21. using Microsoft.AspNetCore.Mvc;
  22. using Microsoft.AspNetCore.Mvc.RazorPages.Infrastructure;
  23. using Microsoft.Extensions.Configuration;
  24. using SqlSugar;
  25. using TVShoppingCallCenter_ZLJ.Models.Inputs;
  26. namespace TVShoppingCallCenter_ZLJ.Controllers.Order
  27. {
  28. [Route("api/[controller]")]
  29. public class KFOrderController : BaseController
  30. {
  31. private readonly IBus_OrderDetailRepository bus_OrderDetailRepository;
  32. private readonly IBus_OrderRepository bus_OrderRepository;
  33. private readonly ISys_MarketingRepository bus_MarketingRepository;
  34. private readonly IBus_ProductRepository bus_productRepository;
  35. private readonly ICus_VipInfoRepository cus_vip_infoRepository;
  36. private readonly IBus_StockLogRepository bus_StockLogRepository;
  37. private readonly ICus_ScoreSetRepository cus_score_setRepository;
  38. private readonly IBus_OrderMoneyRepository busOrderMoneyRepository;
  39. private readonly IConfiguration config;
  40. private readonly OrderFunctionController busOrderFunctionController;
  41. private readonly IBus_OrderlogsRepository busOrderlogsRepository;
  42. private readonly IBus_AfterSaleRepository busAfterSaleRepository;
  43. private readonly ISys_DictionaryValueRepository _sys_dictionaryRepository;
  44. public KFOrderController(IBus_AfterSaleRepository _busAfterSaleRepository, IBus_OrderMoneyRepository _busOrderMoneyRepository, OrderFunctionController _OrderFunctionController, ICus_ScoreSetRepository _cus_score_setRepository, IBus_StockLogRepository _bus_StockLogRepository, IBus_OrderRepository _bus_OrderRepository, IBus_OrderDetailRepository _bus_OrderDetailRepository, ISys_MarketingRepository _bus_MarketingRepository, IBus_ProductRepository _productRepository, ICus_VipInfoRepository _cus_vip_infoRepository, IConfiguration _configuration, IBus_OrderlogsRepository _busOrderlogsRepository
  45. ,ISys_DictionaryValueRepository sys_dictionaryRepository)
  46. {
  47. busAfterSaleRepository = _busAfterSaleRepository;
  48. bus_OrderDetailRepository = _bus_OrderDetailRepository;
  49. bus_OrderRepository = _bus_OrderRepository;
  50. bus_MarketingRepository = _bus_MarketingRepository;
  51. bus_productRepository = _productRepository;
  52. cus_vip_infoRepository = _cus_vip_infoRepository;
  53. bus_StockLogRepository = _bus_StockLogRepository;
  54. cus_score_setRepository = _cus_score_setRepository;
  55. busOrderMoneyRepository = _busOrderMoneyRepository;
  56. config = _configuration;
  57. busOrderFunctionController = _OrderFunctionController;
  58. busOrderlogsRepository = _busOrderlogsRepository;
  59. _sys_dictionaryRepository = _sys_dictionaryRepository;
  60. }
  61. /// <summary>
  62. /// 导入订单跟踪
  63. /// </summary>
  64. /// <param name="input"></param>
  65. /// <returns></returns>
  66. [HttpPost("importordertrack")]
  67. public async Task<IActionResult> ImportOrderTrack( )
  68. {
  69. Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
  70. if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
  71. return Error($"请正确上传Excel文件:file.ContentType={_upfile.ContentType}");
  72. //将数据导入数据库
  73. int headrow = 0;
  74. NPOIHelper npoi = new NPOIHelper();
  75. DataTable dtExcel = npoi.ExcelToTable1(_upfile, headrow);
  76. if (dtExcel.Rows.Count > 0)
  77. {
  78. Dictionary<string, string> dirList = new Dictionary<string, string>();
  79. string[] arrykey = config["Import:ordertrackkey"].ToString().ToLower().Split(',');
  80. string[] arryvalue = config["Import:ordertracktvalue"].ToString().Split(',');
  81. for (int i = 0; i < arrykey.Length; i++)
  82. {
  83. dirList.Add(arrykey[i], arryvalue[i]);
  84. }
  85. IList<T_Bus_Order> IModels = ModelConvertHelper<T_Bus_Order>.ConvertToModelByColumns(dtExcel, dirList);
  86. List<T_Bus_Order> models = ModelConvertHelper<T_Bus_Order>.ConvertIListToList(IModels);
  87. if (models != null && models.Count > 0)
  88. {
  89. int num = models.Count;
  90. //foreach (T_Bus_Order model in models)
  91. //{
  92. //状态如果需要更新 下面加F_State 如果需要验证之前状态,这里要循环查询
  93. //}
  94. if (await bus_OrderRepository.UpdateListToColumns(models, s => new { s.F_TrackingNo, s.F_Status }))
  95. {
  96. return Success("成功");
  97. }
  98. }
  99. else
  100. {
  101. return Success("内容为空");
  102. }
  103. }
  104. return Success("请选择要导入的文件");
  105. }
  106. /// <summary>
  107. /// 上传文件并导入数据库批量退回
  108. /// </summary>
  109. /// <returns></returns>
  110. [HttpPost("importorderbackexcel")]
  111. public async Task<IActionResult> ImportorderbackExcel(int state=0,int headrow = 0)
  112. {
  113. Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
  114. if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
  115. return Error($"请正确上传Excel文件:file.ContentType={_upfile.ContentType}");
  116. NPOIHelper npoi = new NPOIHelper();
  117. var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
  118. int num = dtExcel.Rows.Count;
  119. var cols = dtExcel.Columns;
  120. int colnu5m = cols.Count;
  121. string errmsg = string.Empty;
  122. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  123. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  124. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  125. if (num > 0)
  126. {
  127. int index = 1;
  128. foreach (DataRow dr in dtExcel.Rows)
  129. {
  130. T_Bus_Order modelOrder = new T_Bus_Order();
  131. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  132. if (dr.Table.Columns.Contains("订单号"))
  133. {
  134. if (!string.IsNullOrEmpty(dr["订单号"].ToString()))
  135. {
  136. modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == dr["订单号"].ToString());
  137. if (modelOrder==null )
  138. {
  139. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  140. continue;
  141. }
  142. }
  143. else
  144. {
  145. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  146. continue;
  147. }
  148. }
  149. else
  150. {
  151. return Error("模板错误,请选择正确的模板");
  152. }
  153. if (state ==0)
  154. {
  155. if (dr.Table.Columns.Contains("退回说明"))
  156. {
  157. modelOrder.F_CheckRemark = dr["退回说明"].ToString();
  158. modelOrder.F_State = 2;
  159. }
  160. else
  161. {
  162. return Error("模板错误,请选择正确的模板");
  163. }
  164. }
  165. else if (state == 1)
  166. {
  167. modelOrder.F_State = 1;
  168. }
  169. else
  170. {
  171. if (dr.Table.Columns.Contains("退回说明"))
  172. {
  173. modelOrder.F_CheckRemark = dr["退回说明"].ToString();
  174. }
  175. else
  176. {
  177. return Error("模板错误,请选择正确的模板");
  178. }
  179. modelOrder.F_State = 9;
  180. }
  181. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  182. modelOrder.F_CheckUserName = UserLogin.UserName;
  183. modelOrder.F_CheckTime = DateTime.Now;
  184. orderLIst.Add(modelOrder);
  185. t_Bus_Orderlogs.F_WoID = modelOrder.F_Id;
  186. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "退回订单";
  187. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  188. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  189. t_Bus_Orderlogs.F_WoState = modelOrder.F_State;
  190. logs.Add(t_Bus_Orderlogs);
  191. index++;
  192. }
  193. if (!await bus_OrderRepository.UpdateList (orderLIst))
  194. {
  195. await busOrderlogsRepository.AddAndUpdateList(logs);
  196. if (!string.IsNullOrEmpty(errmsg))
  197. {
  198. errmsg = errmsg + "导入失败!";
  199. }
  200. else
  201. {
  202. errmsg ="导入失败!";
  203. }
  204. }
  205. }
  206. else
  207. {
  208. return Error("文件中无数据");
  209. }
  210. if (!string.IsNullOrEmpty(errmsg))
  211. {
  212. return Error(errmsg);
  213. }
  214. return Success("导入成功");
  215. }
  216. /// <summary>
  217. /// 批量退回
  218. /// </summary>
  219. /// <param name="orderids"></param>
  220. /// <param name="stock"></param>
  221. /// <returns></returns>
  222. [HttpPost("orderback")]
  223. public async Task<IActionResult> OrderBack(string orderids,string remark, int state=0)
  224. {
  225. if (string.IsNullOrEmpty(orderids))
  226. return Error("请选择订单号");
  227. string msg = "";
  228. string[] ids = orderids.Split(',');
  229. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  230. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  231. foreach (var it in ids)
  232. {
  233. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == it);
  234. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  235. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  236. modelOrder.F_CheckUserName = UserLogin.UserName;
  237. modelOrder.F_CheckTime = DateTime.Now;
  238. if (state==0)
  239. {
  240. modelOrder.F_CheckRemark = remark;
  241. modelOrder.F_State = 2;
  242. }
  243. else if (state == 1)
  244. {
  245. modelOrder.F_State = 1;
  246. }
  247. else
  248. {
  249. modelOrder.F_CheckRemark = remark;
  250. modelOrder.F_State = 9;
  251. }
  252. t_Bus_Orderlogs.F_WoID = modelOrder.F_Id;
  253. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "退回订单";
  254. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  255. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  256. t_Bus_Orderlogs.F_WoState = modelOrder.F_State;
  257. logs.Add(t_Bus_Orderlogs);
  258. orderLIst.Add(modelOrder);
  259. }
  260. if (await bus_OrderRepository.UpdateList(orderLIst))
  261. {
  262. await busOrderlogsRepository.AddAndUpdateList(logs);
  263. return Success("退回成功");
  264. }
  265. else
  266. return Error("退回失败");
  267. }
  268. /// <summary>
  269. /// 订单二审 审完 走发货
  270. /// </summary>
  271. /// <param name="orderid">订单号</param>
  272. /// <param name="state">订单状态 -1无效 0暂存 1提交 2KF退回 3通过 4KG退回 5已分拣 6已发货7,8分仓</param>
  273. /// <param name="remark">客服备注</param>
  274. /// <returns></returns>
  275. [HttpPost("/api/order/checkorderbykf")]
  276. public async Task<IActionResult> CheckOrderKF(string orderid, int state, string remark)
  277. {
  278. try
  279. {
  280. //状态变化 积分变化 处理时间人变化 库存变化 备注
  281. T_Cus_VipInfo modelvip = new T_Cus_VipInfo();
  282. #region 验证参数 必填项
  283. if (string.IsNullOrEmpty(orderid))
  284. return Error("请输入订单号");
  285. if (state <= 0)
  286. return Error("请选择操作类型");
  287. #endregion
  288. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == orderid && q.F_State == 1);
  289. if (modelOrder == null)
  290. {
  291. return Error("只有提交订单才可以审核");
  292. }
  293. if (state == 3)
  294. {
  295. if (string.IsNullOrEmpty(modelOrder.F_Stock))
  296. {
  297. return Error("出货仓不能为空");
  298. }
  299. if (string.IsNullOrEmpty(modelOrder.F_Express))
  300. {
  301. return Error("快递不能为空");
  302. }
  303. if (string.IsNullOrEmpty(modelOrder.F_AddPhone))
  304. {
  305. return Error("收件人电话不能为空");
  306. }
  307. if (string.IsNullOrEmpty(modelOrder.F_AddTown))
  308. {
  309. return Error("收件人地址不能为空");
  310. }
  311. if (string.IsNullOrEmpty(modelOrder.F_Address))
  312. {
  313. return Error("收件人详细地址不能为空");
  314. }
  315. }
  316. modelOrder.F_CheckTime = DateTime.Now;
  317. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  318. modelOrder.F_CheckUserName = UserLogin.UserName;
  319. if (!string.IsNullOrEmpty(remark))
  320. modelOrder.F_CheckRemark = remark;
  321. if (state == 2)
  322. {
  323. string strStock = await busOrderFunctionController.ChangeStockOne(modelOrder, 2, null);
  324. modelOrder.F_State = 2;
  325. modelOrder.F_Score = 0.00M;
  326. }
  327. else if (state == 3)
  328. {
  329. #region 判断积分
  330. bool blScore = false;
  331. if (modelOrder.F_UseScore > 0)
  332. {
  333. //退回积分 查询批次号核算积分是否已经解冻
  334. modelvip = await cus_vip_infoRepository.GetSingle(q => q.F_ID == modelOrder.F_VipId);
  335. modelvip.F_Score = modelvip.F_Score + modelOrder.F_UseScore;
  336. if (await cus_vip_infoRepository.Update(modelvip))
  337. {
  338. //log 或者解冻积分
  339. blScore = true;
  340. }
  341. }
  342. else
  343. {
  344. blScore = true;
  345. }
  346. if (!blScore)
  347. {
  348. return Error("积分处理失败");
  349. }
  350. #endregion
  351. //库存不做处理
  352. modelOrder.F_State = 3;
  353. }
  354. if (await bus_OrderRepository.Update(modelOrder))
  355. return Success("订单成功审核!");
  356. return Error("订单审核失败,请汇报技术支持!");
  357. }
  358. catch (Exception ex)
  359. { return Error(ex.Message); }
  360. }
  361. /// <summary>
  362. /// 获取订单分页列表
  363. /// </summary>
  364. /// <param name="input"></param>
  365. /// <returns></returns>
  366. [HttpPost("/api/order/getorderlistbykfpage")]
  367. public async Task<IActionResult> GetOrderListByKFPage(OrderInput input,string Product, decimal minprice=-1, decimal maxprice=-1,int PayState =0,int state=-1,int isdc=0)
  368. {
  369. List<IConditionalModel> conModels = new List<IConditionalModel>();
  370. #region 条件筛选
  371. // conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.GreaterThan, FieldValue = "0" });
  372. //状态
  373. if (input.F_State > -2)
  374. {
  375. if (input.F_State==14)
  376. conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.In , FieldValue = "1,4" });
  377. else
  378. conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = input.F_State.ToString() });
  379. }
  380. else
  381. {
  382. if (state > -1)
  383. {
  384. conModels.Add(new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.GreaterThanOrEqual , FieldValue ="1" });
  385. }
  386. }
  387. //根据角色展示列表
  388. if (UserLogin.RoleCode == "XS")
  389. {
  390. conModels.Add(new ConditionalModel() { FieldName = "F_AddUser", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId });
  391. }
  392. else if (UserLogin.RoleCode == "KF")
  393. {
  394. conModels.Add(new ConditionalCollections()
  395. {
  396. ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
  397. {
  398. new KeyValuePair<WhereType, ConditionalModel>( WhereType.And , new ConditionalModel() { FieldName = "F_CheckUser", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId }),
  399. new KeyValuePair<WhereType, ConditionalModel>( WhereType.Or, new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = "1" })
  400. }
  401. });
  402. // conModels.Add(new ConditionalModel() { FieldName = "", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId });
  403. }
  404. else if (UserLogin.RoleCode == "KG")
  405. {
  406. //conModels.Add(new ConditionalModel() { FieldName = "F_StockUser", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId });
  407. conModels.Add(new ConditionalCollections()
  408. {
  409. ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
  410. {
  411. new KeyValuePair<WhereType, ConditionalModel>( WhereType.And , new ConditionalModel() { FieldName = "F_StockUser", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId }),
  412. new KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_SendUser", ConditionalType = ConditionalType.Equal, FieldValue = UserLogin.UserId }),
  413. new KeyValuePair<WhereType, ConditionalModel>( WhereType.Or, new ConditionalModel() { FieldName = "F_State", ConditionalType = ConditionalType.Equal, FieldValue = "3" })
  414. }
  415. });
  416. }
  417. if (minprice > -1)
  418. {
  419. conModels.Add(new ConditionalModel() { FieldName = "F_TotlePrice", ConditionalType = ConditionalType.GreaterThanOrEqual, FieldValue = minprice.ToString() });
  420. }
  421. if (maxprice > -1)
  422. {
  423. conModels.Add(new ConditionalModel() { FieldName = "F_TotlePrice", ConditionalType = ConditionalType.LessThanOrEqual, FieldValue = maxprice.ToString() });
  424. }
  425. if (!string.IsNullOrEmpty(input.F_ADFrom))
  426. {
  427. conModels.Add(new ConditionalModel() { FieldName = "F_ADFrom", ConditionalType = ConditionalType.Equal, FieldValue = input.F_ADFrom });
  428. }
  429. if (!string.IsNullOrEmpty(input.F_Type))
  430. {
  431. conModels.Add(new ConditionalModel() { FieldName = "F_Type", ConditionalType = ConditionalType.Equal, FieldValue = input.F_Type });
  432. }
  433. if (!string.IsNullOrEmpty(input.F_Id))
  434. {
  435. conModels.Add(new ConditionalModel() { FieldName = "F_Id", ConditionalType = ConditionalType.Equal, FieldValue = input.F_Id });
  436. }
  437. if (!string.IsNullOrEmpty(input.F_Customer))
  438. {
  439. conModels.Add(new ConditionalModel() { FieldName = "F_Customer", ConditionalType = ConditionalType.Equal, FieldValue = input.F_Customer });
  440. }
  441. if (!string.IsNullOrEmpty(input.F_CustomerPhone))
  442. {
  443. conModels.Add(new ConditionalModel() { FieldName = "F_CustomerPhone", ConditionalType = ConditionalType.Equal, FieldValue = input.F_CustomerPhone });
  444. }
  445. if (!string.IsNullOrEmpty(input.F_TrackingNo))
  446. {
  447. conModels.Add(new ConditionalModel() { FieldName = "F_TrackingNo", ConditionalType = ConditionalType.Equal, FieldValue = input.F_TrackingNo });
  448. }
  449. if (!string.IsNullOrEmpty(input.F_AddProvince))
  450. {
  451. conModels.Add(new ConditionalModel() { FieldName = "F_AddProvince", ConditionalType = ConditionalType.Equal, FieldValue = input.F_AddProvince });
  452. }
  453. if (!string.IsNullOrEmpty(input.F_AddCity))
  454. {
  455. conModels.Add(new ConditionalModel() { FieldName = "F_AddCity", ConditionalType = ConditionalType.Equal, FieldValue = input.F_AddCity });
  456. }
  457. if (!string.IsNullOrEmpty(input.F_AddArea))
  458. {
  459. conModels.Add(new ConditionalModel() { FieldName = "F_AddArea", ConditionalType = ConditionalType.Equal, FieldValue = input.F_AddArea });
  460. }
  461. if (!string.IsNullOrEmpty(input.F_AddTown))
  462. {
  463. conModels.Add(new ConditionalModel() { FieldName = "F_AddTown", ConditionalType = ConditionalType.Equal, FieldValue = input.F_AddTown });
  464. }
  465. if (!string.IsNullOrEmpty(input.F_Express))
  466. {
  467. conModels.Add(new ConditionalModel() { FieldName = "F_Express", ConditionalType = ConditionalType.Equal, FieldValue = input.F_Express });
  468. }
  469. if (!string.IsNullOrEmpty(input.F_PayType))
  470. {
  471. conModels.Add(new ConditionalModel() { FieldName = "F_PayType", ConditionalType = ConditionalType.Equal, FieldValue = input.F_PayType });
  472. }
  473. if (!string.IsNullOrEmpty(input.F_Stock))
  474. {
  475. conModels.Add(new ConditionalModel() { FieldName = "F_Stock", ConditionalType = ConditionalType.Equal, FieldValue = input.F_Stock });
  476. }
  477. if (input.F_IsExpress>-1)
  478. {
  479. conModels.Add(new ConditionalModel() { FieldName = "F_IsExpress", ConditionalType = ConditionalType.Equal, FieldValue = input.F_IsExpress.ToString () });
  480. }
  481. if (input.F_PayState > -1)
  482. {
  483. if (PayState>0)
  484. {
  485. conModels.Add(new ConditionalModel() { FieldName = "F_PayState", ConditionalType = ConditionalType.Equal, FieldValue = input.F_PayState.ToString() });
  486. }
  487. else
  488. {
  489. if (input.F_PayState == 1 || input.F_PayState == 3)
  490. {
  491. conModels.Add(new ConditionalCollections()
  492. {
  493. ConditionalList = new List<KeyValuePair<WhereType, ConditionalModel>>()
  494. {
  495. new KeyValuePair<WhereType, ConditionalModel>( WhereType.And , new ConditionalModel() { FieldName = "F_PayState", ConditionalType = ConditionalType.Equal, FieldValue = "1" }),
  496. new KeyValuePair<WhereType, ConditionalModel>( WhereType.Or , new ConditionalModel() { FieldName = "F_PayState", ConditionalType = ConditionalType.Equal, FieldValue ="3" })
  497. }
  498. });
  499. }
  500. else
  501. {
  502. conModels.Add(new ConditionalModel() { FieldName = "F_PayState", ConditionalType = ConditionalType.Equal, FieldValue = input.F_PayState.ToString() });
  503. }
  504. }
  505. }
  506. if (input.SearchEndTime != null)
  507. {
  508. conModels.Add(new ConditionalModel() { FieldName = "F_AddTime", ConditionalType = ConditionalType.LessThan, FieldValue = input.SearchEndTime.GetValueOrDefault().ToString("yyyy-MM-dd 23:59:59") });
  509. }
  510. if (input.SearchStartTime != null)
  511. {
  512. conModels.Add(new ConditionalModel() { FieldName = "F_AddTime", ConditionalType = ConditionalType.GreaterThan, FieldValue = input.SearchStartTime.GetValueOrDefault().ToString("yyyy-MM-dd 00:00:01") });
  513. }
  514. if (input.F_IsExpress > -1)
  515. {
  516. conModels.Add(new ConditionalModel() { FieldName = "F_IsExpress", ConditionalType = ConditionalType.Equal, FieldValue = input.F_IsExpress.ToString() });
  517. }
  518. #endregion
  519. RefAsync<int> recordCount = 0;
  520. PageData<T_Bus_Order> list = await bus_OrderRepository.GetListByPage(conModels, new MyPageModel() { PageIndex = input.pageindex, PageSize = input.pagesize, PageCount = recordCount }, " F_AddTime ASC");
  521. PageData<OrderInput> returnobj = new PageData<OrderInput>() { Totals = list.Totals };
  522. List<OrderInput> returnlist = new List<OrderInput>();
  523. foreach (T_Bus_Order t in list.Rows)
  524. {
  525. OrderInput m = new OrderInput();
  526. ModelConvertHelper<OrderInput, T_Bus_Order>.ModeToModel(m, t);
  527. List<OrderDetailInput> orderDetailInputs = new List<OrderDetailInput>();
  528. #region 遍历订单商品
  529. List<T_Bus_OrderDetail> orderDetails = await bus_OrderDetailRepository.GetListALL(q => q.F_OrderId == t.F_Id);
  530. if (orderDetails != null)
  531. {
  532. foreach (T_Bus_OrderDetail t1 in orderDetails)
  533. {
  534. OrderDetailInput m1 = new OrderDetailInput();
  535. ModelConvertHelper<OrderDetailInput, T_Bus_OrderDetail>.ModeToModel(m1, t1);
  536. orderDetailInputs.Add(m1);
  537. }
  538. }
  539. #endregion
  540. m.OrderDetailList = orderDetailInputs;
  541. if (!string.IsNullOrEmpty(Product))
  542. {
  543. if (orderDetailInputs.Select (x=>x.F_ProductId ==Product ).Count ()>0 )
  544. returnlist.Add(m);
  545. }
  546. else
  547. returnlist.Add(m);
  548. }
  549. returnobj.Rows = returnlist;
  550. return Success("成功", returnobj);
  551. }
  552. /// <summary>
  553. /// 修改订单
  554. /// </summary>
  555. /// <param name="input"></param>
  556. /// <returns></returns>
  557. [HttpPost("/api/order/editorderkf")]
  558. public async Task<IActionResult> EditOrderKF([FromBody]OrderInput input)
  559. {
  560. T_Cus_VipInfo modelvip = new T_Cus_VipInfo();
  561. #region 验证参数 必填项
  562. if (string.IsNullOrEmpty(input.F_ADFrom))
  563. return Error("请输入选择广告来源");
  564. if (string.IsNullOrEmpty(input.F_Type))
  565. return Error("请输入选择订单类型");
  566. if (string.IsNullOrEmpty(input.F_Id))
  567. return Error("请输入订单编号");
  568. if (string.IsNullOrEmpty(input.F_Customer))
  569. return Error("请输入客户姓名");
  570. if (string.IsNullOrEmpty(input.F_CustomerPhone))
  571. return Error("请输入客户电话");
  572. #endregion
  573. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == input.F_Id);
  574. if (modelOrder == null)
  575. {
  576. return Error("此订单号不存在");
  577. }
  578. //保存 审退回 仓退回
  579. if (!(new int[] { 1, 3 ,4}.Contains(modelOrder.F_State)))
  580. {
  581. return Error("此状态订单不允许修改,先撤回订单");
  582. }
  583. #region 数据绑定
  584. //必填
  585. modelOrder.F_ADFrom = input.F_ADFrom;
  586. modelOrder.F_Type = input.F_Type;
  587. modelOrder.F_Id = input.F_Id;
  588. if (input.F_CustomerType > 0)
  589. { modelOrder.F_CustomerType = input.F_CustomerType; }
  590. if (!string.IsNullOrEmpty(input.F_CustomerTel))
  591. { modelOrder.F_CustomerTel = input.F_CustomerTel; }
  592. //选填 快递属性
  593. if (!string.IsNullOrEmpty(input.F_TrackingNo))
  594. { modelOrder.F_TrackingNo = input.F_TrackingNo; }
  595. if (!string.IsNullOrEmpty(input.F_Addressee))
  596. { modelOrder.F_Addressee = input.F_Addressee; }
  597. if (!string.IsNullOrEmpty(input.F_AddPhone))
  598. { modelOrder.F_AddPhone = input.F_AddPhone; }
  599. if (!string.IsNullOrEmpty(input.F_AddProvince))
  600. { modelOrder.F_AddProvince = input.F_AddProvince; }
  601. if (!string.IsNullOrEmpty(input.F_AddCity))
  602. { modelOrder.F_AddCity = input.F_AddCity; }
  603. if (!string.IsNullOrEmpty(input.F_AddArea))
  604. { modelOrder.F_AddArea = input.F_AddArea; }
  605. if (!string.IsNullOrEmpty(input.F_AddTown))
  606. { modelOrder.F_AddTown = input.F_AddTown; }
  607. if (!string.IsNullOrEmpty(input.F_AddDes))
  608. { modelOrder.F_AddDes = input.F_AddDes; }
  609. if (!string.IsNullOrEmpty(input.F_Address))
  610. { modelOrder.F_Address = input.F_Address; }
  611. if (!string.IsNullOrEmpty(input.F_PostalCode))
  612. { modelOrder.F_PostalCode = input.F_PostalCode; }
  613. if (!string.IsNullOrEmpty(input.F_Express))
  614. { modelOrder.F_Express = input.F_Express; }
  615. if (!string.IsNullOrEmpty(input.F_Remark))
  616. { modelOrder.F_Remark = input.F_Remark; }
  617. if (!string.IsNullOrEmpty(input.F_PayType))
  618. { modelOrder.F_PayType = input.F_PayType; }
  619. if (input.F_VipId > 0)
  620. { modelOrder.F_VipId = input.F_VipId; }
  621. if (!string.IsNullOrEmpty(modelOrder.F_Express))
  622. modelOrder.F_IsExpress = 1;
  623. //选填 关联属性
  624. modelOrder.F_ExpressFee = input.F_ExpressFee;
  625. modelOrder.F_State = input.F_State;
  626. modelOrder.F_Status = 0;
  627. //必须属性 系统生成
  628. modelOrder.F_CheckTime = DateTime.Now;
  629. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  630. modelOrder.F_CheckUserName = UserLogin.UserName;
  631. if (string.IsNullOrEmpty(modelOrder.F_Express))
  632. {
  633. return Error("快递不能为空");
  634. }
  635. if (string.IsNullOrEmpty(modelOrder.F_AddPhone))
  636. {
  637. return Error("收件人电话不能为空");
  638. }
  639. if (string.IsNullOrEmpty(modelOrder.F_AddTown))
  640. {
  641. return Error("收件人地址不能为空");
  642. }
  643. if (string.IsNullOrEmpty(modelOrder.F_Address))
  644. {
  645. return Error("收件人详细地址不能为空");
  646. }
  647. #endregion
  648. modelOrder.F_ShouldPrice = modelOrder.F_TotlePrice - modelOrder.F_ActivityMoney + modelOrder.F_ExpressFee + modelOrder.F_MergeMoney;
  649. if (await bus_OrderRepository.Update(modelOrder))
  650. {
  651. return Success("成功");
  652. }
  653. return Error("订单添加失败,请重试!");
  654. }
  655. /// <summary>
  656. /// 订单打标签
  657. /// </summary>
  658. /// <param name="orderids"></param>
  659. /// <param name="tags"></param>
  660. /// <returns></returns>
  661. [HttpPost("addordertag")]
  662. public async Task<IActionResult> AddOrderTag(string orderids, string tags)
  663. {
  664. #region 验证参数 必填项
  665. if (string.IsNullOrEmpty(orderids))
  666. return Error("请选择订单号");
  667. if (string.IsNullOrEmpty(tags))
  668. return Error("请选择标签");
  669. #endregion
  670. string[] ids = orderids.Split(',');
  671. if (await bus_OrderRepository.Update(s => new T_Bus_Order() { F_Tag = tags }, q => ids.Contains(q.F_Id)))
  672. {
  673. return Success("成功");
  674. }
  675. return Error("失败,请重试!");
  676. }
  677. /// <summary>
  678. /// 上传文件并导入数据库批量导入快递信息
  679. /// </summary>
  680. /// <returns></returns>
  681. [HttpPost("importorderbackexcel")]
  682. public async Task<IActionResult> ImportorderlogisticsExcel( int headrow = 0)
  683. {
  684. Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
  685. if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
  686. return Error($"请正确上传Excel文件:file.ContentType={_upfile.ContentType}");
  687. NPOIHelper npoi = new NPOIHelper();
  688. var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
  689. int num = dtExcel.Rows.Count;
  690. var cols = dtExcel.Columns;
  691. int colnum = cols.Count;
  692. string errmsg = string.Empty;
  693. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  694. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  695. if (num > 0)
  696. {
  697. int index = 1;
  698. foreach (DataRow dr in dtExcel.Rows)
  699. {
  700. T_Bus_Order modelOrder = new T_Bus_Order();
  701. if (dr.Table.Columns.Contains("订单号"))
  702. {
  703. if (!string.IsNullOrEmpty(dr["订单号"].ToString()))
  704. {
  705. modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == dr["订单号"].ToString());
  706. if (modelOrder == null)
  707. {
  708. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  709. continue;
  710. }
  711. }
  712. else
  713. {
  714. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  715. continue;
  716. }
  717. }
  718. else
  719. {
  720. return Error("模板错误,请选择正确的模板");
  721. }
  722. if (dr.Table.Columns.Contains("运单号"))
  723. {
  724. modelOrder.F_TrackingNo = dr["运单号"].ToString();
  725. }
  726. else
  727. {
  728. return Error("模板错误,请选择正确的模板");
  729. }
  730. if (dr.Table.Columns.Contains("快递状态"))
  731. {
  732. if (!string .IsNullOrEmpty (dr["快递状态"].ToString()))
  733. try
  734. {
  735. var model = _sys_dictionaryRepository.GetListALL (x => x.F_Remark == dr["快递状态"].ToString() && x.F_State == 1&&x.F_ValueCode == "OrderF_State").Result ;
  736. if (model!=null &&model .Count >0)
  737. {
  738. modelOrder.F_Status =int .Parse ( model[0].F_Value) ;
  739. }
  740. else
  741. {
  742. errmsg = errmsg + "\r\n第" + index + "行导入失败!快递状态错误";
  743. continue;
  744. }
  745. }
  746. catch
  747. {
  748. errmsg = errmsg + "\r\n第" + index + "行导入失败!快递状态错误";
  749. continue;
  750. }
  751. }
  752. else
  753. {
  754. return Error("模板错误,请选择正确的模板");
  755. }
  756. orderLIst.Add(modelOrder);
  757. index++;
  758. }
  759. if (!await bus_OrderRepository.UpdateList(orderLIst))
  760. {
  761. if (!string.IsNullOrEmpty(errmsg))
  762. {
  763. errmsg = errmsg + "导入失败!";
  764. }
  765. else
  766. {
  767. errmsg = "导入失败!";
  768. }
  769. }
  770. }
  771. else
  772. {
  773. return Error("文件中无数据");
  774. }
  775. if (!string.IsNullOrEmpty(errmsg))
  776. {
  777. return Error(errmsg);
  778. }
  779. return Success("导入成功");
  780. }
  781. /// <summary>
  782. /// 更新物流状态
  783. /// </summary>
  784. /// <param name="orderids"></param>
  785. /// <param name="status">0 未发出 1未签收2签收3改代收4拒收</param>
  786. /// <returns></returns>
  787. [HttpPost("updatestatus")]
  788. public async Task<IActionResult> UpdateStatus(string orderids, int status)
  789. {
  790. #region 验证参数 必填项
  791. if (string.IsNullOrEmpty(orderids))
  792. return Error("请选择订单号");
  793. if (status == 0)
  794. return Error("请选择状态");
  795. #endregion
  796. string[] ids = orderids.Split(',');
  797. if (await bus_OrderRepository.Update(s => new T_Bus_Order() { F_Status = status }, q => ids.Contains(q.F_Id)))
  798. {
  799. return Success("成功");
  800. }
  801. return Error("失败,请重试!");
  802. }
  803. [HttpPost("updateexpress")]
  804. public async Task<IActionResult> UpdateExpress(string orderids, string express)
  805. {
  806. #region 验证参数 必填项
  807. if (string.IsNullOrEmpty(orderids))
  808. return Error("请选择订单号");
  809. if (string.IsNullOrEmpty(express))
  810. return Error("请选择快递");
  811. #endregion
  812. //更新所选订单的快递,并标记为客服已分配快递
  813. string[] ids = orderids.Split(',');
  814. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  815. foreach (var it in ids)
  816. {
  817. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  818. t_Bus_Orderlogs.F_WoID = it;
  819. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "分快递,"+ express;
  820. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  821. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  822. t_Bus_Orderlogs.F_WoState = 3;
  823. logs.Add(t_Bus_Orderlogs);
  824. }
  825. if (await bus_OrderRepository.Update(s => new T_Bus_Order() { F_Express = express, F_IsExpress = 1 }, q => ids.Contains(q.F_Id)))
  826. {
  827. await busOrderlogsRepository.AddAndUpdateList(logs);
  828. return Success("成功");
  829. }
  830. return Error("失败,请重试!");
  831. }
  832. /// <summary>
  833. /// 分仓
  834. /// </summary>
  835. /// <param name="orderids"></param>
  836. /// <param name="stock"></param>
  837. /// <returns></returns>
  838. [HttpPost("updatestock")]
  839. public async Task<IActionResult> UpdateStock(string orderids, string stock)
  840. {
  841. if (string.IsNullOrEmpty(orderids))
  842. return Error("请选择订单号");
  843. if (string.IsNullOrEmpty(stock))
  844. return Error("请选择出货仓");
  845. T_Cus_ScoreSet modelscore = await cus_score_setRepository.GetSingle(x => x.F_State == 1);
  846. if (modelscore == null)
  847. {
  848. modelscore = new T_Cus_ScoreSet();
  849. modelscore.F_Start = 0;
  850. modelscore.F_StartDebit = 1;
  851. modelscore.F_DebitPercent = 1000;
  852. }
  853. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  854. string msg="";
  855. string[] ids = orderids.Split(',');
  856. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  857. if (stock =="无货")
  858. {
  859. foreach (var it in ids)
  860. {
  861. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  862. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == it);
  863. modelOrder.F_CheckUserName = UserLogin.UserName;
  864. modelOrder.F_CheckTime = DateTime.Now;
  865. modelOrder.F_Stock = stock;
  866. modelOrder.F_State = 4;
  867. orderLIst.Add(modelOrder);
  868. t_Bus_Orderlogs.F_WoID = it;
  869. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "分仓,无货";
  870. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  871. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  872. t_Bus_Orderlogs.F_WoState = 4;
  873. logs.Add(t_Bus_Orderlogs);
  874. }
  875. }
  876. else
  877. {
  878. foreach (var it in ids)
  879. {
  880. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  881. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == it);
  882. if (modelscore.F_Start == 1)
  883. {
  884. //订单完成后计算积分
  885. modelOrder.F_Score = -0.01M;
  886. }
  887. else
  888. { //订单完成后也不计算积分
  889. modelOrder.F_Score = 0.00M;
  890. }
  891. if (modelscore.F_StartDebit == 0 || modelOrder.F_VipId == 0)
  892. {
  893. modelOrder.F_UseScore = 0;
  894. }
  895. modelOrder.F_Stock = stock;
  896. List<T_Bus_OrderDetail> detaillist = await bus_OrderDetailRepository.GetListALL(q => q.F_OrderId == modelOrder.F_Id, o => o.F_Sort, OrderByType.Asc);
  897. string strStock = await busOrderFunctionController.ChangeStockOne(modelOrder, 1, detaillist);
  898. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  899. modelOrder.F_CheckUserName = UserLogin.UserName;
  900. modelOrder.F_CheckTime = DateTime.Now;
  901. modelOrder.F_Stock = stock;
  902. if (strStock != "1")
  903. {
  904. msg += "订单" + modelOrder.F_Id + strStock;
  905. modelOrder.F_State = 4;
  906. t_Bus_Orderlogs.F_WoState = 4;
  907. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "分仓,无货";
  908. // { return Error(strStock); }
  909. }
  910. else
  911. {
  912. modelOrder.F_State = 8;
  913. t_Bus_Orderlogs.F_WoState = 8;
  914. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "分仓,"+ stock;
  915. }
  916. t_Bus_Orderlogs.F_WoID = it;
  917. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  918. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  919. logs.Add(t_Bus_Orderlogs);
  920. orderLIst.Add(modelOrder);
  921. }
  922. }
  923. if (await bus_OrderRepository.UpdateList(orderLIst))
  924. {
  925. if (msg =="")
  926. return Success("分仓成功");
  927. else
  928. return Success(msg);
  929. }
  930. else
  931. return Error("分仓失败"+ msg);
  932. }
  933. [HttpPost("checkordermoney")]
  934. public async Task<IActionResult> CheckOrderMoney(OrderMoneyInput input)
  935. {
  936. try
  937. {
  938. #region 验证参数 必填项
  939. if (string.IsNullOrEmpty(input.F_Id))
  940. return Error("请选择条目");
  941. if (string.IsNullOrEmpty(input.F_RemarkKF))
  942. input.F_RemarkKF = "";
  943. if (string.IsNullOrEmpty(input.F_RemarkXS))
  944. input.F_RemarkXS = "";
  945. if (input.F_Money <= 0)
  946. return Error("请输入金额");
  947. #endregion
  948. T_Bus_OrderMoney modelOrderMoeny = await busOrderMoneyRepository.GetSingle(q => q.F_Id == input.F_Id);
  949. modelOrderMoeny.F_CheckUserId = UserLogin.UserId.ObjToInt();
  950. modelOrderMoeny.F_CheckUserName = UserLogin.UserName;
  951. modelOrderMoeny.F_Money = modelOrderMoeny.F_Money;
  952. modelOrderMoeny.F_State = input.F_State;
  953. modelOrderMoeny.F_RemarkKF = input.F_RemarkKF;
  954. if (modelOrderMoeny.F_State == 1)
  955. {
  956. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == modelOrderMoeny.F_OrderId);
  957. if (modelOrder.F_PayState == 1 || modelOrder.F_PayState == 3)
  958. {
  959. return Error("此单已结算!");
  960. }
  961. modelOrder.F_RealPrice = modelOrder.F_RealPrice + modelOrderMoeny.F_Money;
  962. if (modelOrder.F_PayState == 0)
  963. {
  964. if (modelOrder.F_ShouldPrice <= modelOrder.F_RealPrice)
  965. {
  966. //0待回款1已支付 2待退款3已退款
  967. modelOrder.F_PayState = 1;
  968. }
  969. }
  970. else if (modelOrder.F_PayState == 2)
  971. {
  972. if (modelOrder.F_ShouldPrice <= modelOrder.F_RealPrice)
  973. {
  974. //0待回款1已支付 2待退款3已退款
  975. modelOrder.F_PayState = 3;
  976. }
  977. }
  978. await bus_OrderRepository.UpdateListToColumns(new List<T_Bus_Order>() { modelOrder }, s => new { s.F_PayState, s.F_RealPrice });
  979. }
  980. if (await busOrderMoneyRepository.Update(modelOrderMoeny))
  981. return Success("成功!");
  982. return Error("失败!");
  983. }
  984. catch (Exception ex)
  985. { return Error(ex.Message); }
  986. }
  987. [HttpPost("ordermoney")]
  988. public async Task<IActionResult> OrderMoney(OrderMoneyInput input)
  989. {
  990. try
  991. {
  992. #region 验证参数 必填项
  993. if (string.IsNullOrEmpty(input.F_OrderId))
  994. return Error("请输入订单号");
  995. if (string.IsNullOrEmpty(input.F_PayUser))
  996. return Error("请输入打款人");
  997. if (string.IsNullOrEmpty(input.F_PayType))
  998. return Error("请输入打款方式");
  999. if (string.IsNullOrEmpty(input.F_RemarkKF))
  1000. input.F_RemarkKF = "";
  1001. if (string.IsNullOrEmpty(input.F_RemarkXS))
  1002. input.F_RemarkXS = "";
  1003. if (input.F_PayTime == null)
  1004. return Error("请输入打款时间");
  1005. if (input.F_Money >= 0)
  1006. return Error("退款金额只能为负数");
  1007. #endregion
  1008. T_Bus_OrderMoney modelOrderMoeny = new T_Bus_OrderMoney();
  1009. ModelConvertHelper<T_Bus_OrderMoney, OrderMoneyInput>.ModeToModelDefault(modelOrderMoeny, input);
  1010. modelOrderMoeny.F_AddUserId = UserLogin.UserId.ObjToInt();
  1011. modelOrderMoeny.F_UserName = UserLogin.UserName;
  1012. modelOrderMoeny.F_Money = input.F_Money;
  1013. modelOrderMoeny.F_MoneyBak = modelOrderMoeny.F_Money;
  1014. modelOrderMoeny.F_State = 1;
  1015. modelOrderMoeny.F_Id = Guid.NewGuid().ToString().Replace("-", "");
  1016. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == modelOrderMoeny.F_OrderId);
  1017. if (modelOrder.F_PayState == 1 || modelOrder.F_PayState == 3)
  1018. {
  1019. return Error("此单已结算!");
  1020. }
  1021. modelOrder.F_RealPrice = modelOrder.F_RealPrice + modelOrderMoeny.F_Money;
  1022. if (modelOrder.F_PayState == 2)
  1023. {
  1024. if (modelOrder.F_ShouldPrice >= modelOrder.F_RealPrice)
  1025. {
  1026. //0待回款1已支付 2待退款3已退款
  1027. modelOrder.F_PayState = 3;
  1028. }
  1029. }
  1030. await bus_OrderRepository.UpdateListToColumns(new List<T_Bus_Order>() { modelOrder }, s => new { s.F_PayState, s.F_RealPrice });
  1031. if (await busOrderMoneyRepository.AddReturnCount(modelOrderMoeny))
  1032. return Success("成功!");
  1033. return Error("失败!");
  1034. }
  1035. catch (Exception ex)
  1036. { return Error(ex.Message); }
  1037. }
  1038. /// <summary>
  1039. /// 客服提交订单
  1040. /// </summary>
  1041. /// <param name="orderids"></param>
  1042. /// <param name="stock"></param>
  1043. /// <returns></returns>
  1044. [HttpPost("Submit")]
  1045. public async Task<IActionResult> Submit(string orderids)
  1046. {
  1047. if (string.IsNullOrEmpty(orderids))
  1048. return Error("请选择订单号");
  1049. string msg = "";int res = 0;
  1050. string[] ids = orderids.Split(',');
  1051. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  1052. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  1053. foreach (var it in ids)
  1054. {
  1055. T_Bus_Order modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == it);
  1056. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  1057. if (modelOrder.F_IsExpress<=0|| modelOrder.F_State !=3)
  1058. {
  1059. msg += "订单" + modelOrder.F_Id + "未分物流";
  1060. continue;
  1061. }
  1062. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  1063. modelOrder.F_CheckUserName = UserLogin.UserName;
  1064. modelOrder.F_CheckTime = DateTime.Now;
  1065. modelOrder.F_State = 5;
  1066. orderLIst.Add(modelOrder);
  1067. t_Bus_Orderlogs.F_WoID = modelOrder.F_Id;
  1068. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "提交订单";
  1069. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  1070. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  1071. t_Bus_Orderlogs.F_WoState = 5;
  1072. logs.Add(t_Bus_Orderlogs);
  1073. }
  1074. if (await bus_OrderRepository.UpdateList(orderLIst))
  1075. {
  1076. await busOrderlogsRepository.AddAndUpdateList(logs);
  1077. if (msg == "")
  1078. return Success("分仓成功");
  1079. else
  1080. return Success(msg);
  1081. }
  1082. else
  1083. return Error("订单分仓失败" + msg);
  1084. }
  1085. /// <summary>
  1086. /// 上传文件并导入数据库批量导入快递信息
  1087. /// </summary>
  1088. /// <returns></returns>
  1089. [HttpPost("importordersubmitexcel")]
  1090. public async Task<IActionResult> importordersubmitexcel(int headrow = 0)
  1091. {
  1092. Microsoft.AspNetCore.Http.IFormFile _upfile = Request.Form.Files[0];
  1093. if (!_upfile.ContentType.Equals("application/vnd.ms-excel") && !_upfile.ContentType.Equals("application/x-xls") && !_upfile.ContentType.Equals("application/x-xlsx") && !_upfile.ContentType.Equals("application/vnd.openxmlformats-officedocument.spreadsheetml.sheet") && !_upfile.ContentType.Equals("application/octet-stream"))
  1094. return Error($"请正确上传Excel文件:file.ContentType={_upfile.ContentType}");
  1095. NPOIHelper npoi = new NPOIHelper();
  1096. var dtExcel = npoi.ExcelToTable1(_upfile, headrow);
  1097. int num = dtExcel.Rows.Count;
  1098. var cols = dtExcel.Columns;
  1099. int colnum = cols.Count;
  1100. string errmsg = string.Empty;
  1101. string user = User.Claims.FirstOrDefault(c => c.Type == ClaimTypes.Sid).Value;
  1102. List<T_Bus_Order> orderLIst = new List<T_Bus_Order>();
  1103. List<T_Bus_Orderlogs> logs = new List<T_Bus_Orderlogs>();
  1104. if (num > 0)
  1105. {
  1106. int index = 1;
  1107. foreach (DataRow dr in dtExcel.Rows)
  1108. {
  1109. T_Bus_Order modelOrder = new T_Bus_Order();
  1110. T_Bus_Orderlogs t_Bus_Orderlogs = new T_Bus_Orderlogs();
  1111. if (dr.Table.Columns.Contains("订单号"))
  1112. {
  1113. if (!string.IsNullOrEmpty(dr["订单号"].ToString()))
  1114. {
  1115. modelOrder = await bus_OrderRepository.GetSingle(q => q.F_Id == dr["订单号"].ToString());
  1116. if (modelOrder == null)
  1117. {
  1118. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  1119. continue;
  1120. }
  1121. }
  1122. else
  1123. {
  1124. errmsg = errmsg + "\r\n第" + index + "行导入失败!订单不存在";
  1125. continue;
  1126. }
  1127. }
  1128. else
  1129. {
  1130. return Error("模板错误,请选择正确的模板");
  1131. }
  1132. if (modelOrder.F_IsExpress <= 0 || modelOrder.F_State != 3)
  1133. {
  1134. errmsg = errmsg + "\r\n第" + index + "行导入失败!该订单未分物流";
  1135. continue;
  1136. }
  1137. modelOrder.F_CheckUser = UserLogin.UserId.ObjToInt();
  1138. modelOrder.F_CheckUserName = UserLogin.UserName;
  1139. modelOrder.F_CheckTime = DateTime.Now;
  1140. modelOrder.F_State = 5;
  1141. orderLIst.Add(modelOrder);
  1142. t_Bus_Orderlogs.F_WoID = modelOrder.F_Id;
  1143. t_Bus_Orderlogs.F_OptContent = UserLogin.UserName + "提交订单";
  1144. t_Bus_Orderlogs.F_CreateUser = UserLogin.UserCode;
  1145. t_Bus_Orderlogs.F_CreateTime = DateTime.Now;
  1146. t_Bus_Orderlogs.F_WoState = 5;
  1147. logs.Add(t_Bus_Orderlogs);
  1148. index++;
  1149. }
  1150. if (!await bus_OrderRepository.UpdateList(orderLIst))
  1151. {
  1152. await busOrderlogsRepository.AddAndUpdateList(logs);
  1153. if (!string.IsNullOrEmpty(errmsg))
  1154. {
  1155. errmsg = errmsg + "导入失败!";
  1156. }
  1157. else
  1158. {
  1159. errmsg = "导入失败!";
  1160. }
  1161. }
  1162. }
  1163. else
  1164. {
  1165. return Error("文件中无数据");
  1166. }
  1167. if (!string.IsNullOrEmpty(errmsg))
  1168. {
  1169. return Error(errmsg);
  1170. }
  1171. return Success("导入成功");
  1172. }
  1173. /// <summary>
  1174. /// 根据分页获取售后列表 待退款 退货 仓库确认收到货 补差额 不需要仓库确认
  1175. /// </summary>
  1176. /// <param name="input"></param>
  1177. /// <returns></returns>
  1178. [HttpPost("getaftersalebypage")]
  1179. public async Task<IActionResult> GetAfterSaleByPage(AfterSaleInput input)
  1180. {
  1181. #region 拼接条件
  1182. Expression<Func<T_Bus_AfterSale, bool>> eq = a => a.F_Money < 0 && a.F_CheckStateSH == 1 && ((a.F_CheckStateKG == 1 && (a.F_Type == 2 || a.F_Type == 3)) || a.F_Type == 6);
  1183. if (!string.IsNullOrEmpty(input.F_Id))
  1184. {
  1185. eq = eq.And(a => a.F_Id == input.F_Id);
  1186. }
  1187. if (input.F_State > 0)
  1188. {
  1189. eq = eq.And(a => a.F_State == input.F_State);
  1190. }
  1191. if (input.F_Type > 0)
  1192. {
  1193. eq = eq.And(a => a.F_Type == input.F_Type);
  1194. }
  1195. if (!string.IsNullOrEmpty(input.F_ReturnType))
  1196. {
  1197. eq = eq.And(a => a.F_ReturnType == input.F_ReturnType);
  1198. }
  1199. #endregion
  1200. RefAsync<int> count = 0;
  1201. PageData<T_Bus_AfterSale> list = await busAfterSaleRepository.GetListByPage(eq, new MyPageModel() { PageIndex = input.pageindex, PageSize = input.pagesize, PageCount = count }, " F_AddTime DESC");
  1202. return Success("成功", list);
  1203. }
  1204. /// <summary>
  1205. /// 更新售后退款状态
  1206. /// </summary>
  1207. /// <param name="input"></param>
  1208. /// <returns></returns>
  1209. [HttpPost("updatestate")]
  1210. public async Task<IActionResult> UpdateState(AfterSaleInput input)
  1211. {
  1212. try
  1213. {
  1214. #region 验证参数 必填项
  1215. if (string.IsNullOrEmpty(input.F_Id))
  1216. return Error("请选择售后单");
  1217. if (input.F_CheckTimeXS == null)
  1218. return Error("请选择退款时间");
  1219. if (input.F_State == 0)
  1220. return Error("更新状态不正确");
  1221. #endregion
  1222. T_Bus_AfterSale modelAfterSale = await busAfterSaleRepository.GetSingle(q => q.F_Id == input.F_Id);
  1223. if (modelAfterSale.F_State != 0)
  1224. { return Error("此售后状态不支持退款"); }
  1225. if (modelAfterSale.F_Type != 2 && modelAfterSale.F_Type != 3 && modelAfterSale.F_Type != 6)
  1226. {
  1227. return Error("售后类型不支持退款");
  1228. }
  1229. //1收到货(根据状态自动创建订单)2货物不符3未收到货
  1230. if ((modelAfterSale.F_Type == 2 || modelAfterSale.F_Type == 3) && modelAfterSale.F_CheckStateKG != 1)
  1231. {
  1232. return Error("仓库暂未确认收到退货");
  1233. }
  1234. if (modelAfterSale.F_Money >= 0)
  1235. {
  1236. return Error("此金额不需要退款");
  1237. }
  1238. modelAfterSale.F_CheckTimeXS = input.F_CheckTimeXS;
  1239. modelAfterSale.F_State = 1;
  1240. if (await busAfterSaleRepository.Update(modelAfterSale))
  1241. {
  1242. return Success("成功");
  1243. }
  1244. return Error("失败,请重试!");
  1245. }
  1246. catch (Exception ex)
  1247. { return Error(ex.Message); }
  1248. }
  1249. /// <summary>
  1250. /// 根据订单获取相应支付记录
  1251. /// </summary>
  1252. /// <param name="input"></param>
  1253. /// <returns></returns>
  1254. [HttpPost("getordermoney")]
  1255. public async Task<IActionResult> GetOrderMoneyList(OrderMoneyInput input)
  1256. {
  1257. if (string.IsNullOrEmpty(input.F_OrderId))
  1258. {
  1259. return Error("请输入订单号");
  1260. }
  1261. #region 拼接条件
  1262. Expression<Func<T_Bus_OrderMoney, bool>> eq = a => a.F_OrderId== input.F_OrderId;
  1263. #endregion
  1264. List<T_Bus_OrderMoney> list = await busOrderMoneyRepository.GetListALL(eq,o=>o.F_AddTime,OrderByType.Asc);
  1265. return Success("成功", list);
  1266. }
  1267. private async Task<int> AddLog(string WoID, string count, string user, int state)
  1268. {
  1269. T_Bus_Orderlogs logs = new T_Bus_Orderlogs();
  1270. logs.F_WoID = WoID;
  1271. logs.F_WoState = state;
  1272. logs.F_OptContent = count;
  1273. logs.F_CreateUser = user;
  1274. logs.F_CreateTime = DateTime.Now;
  1275. var res = await busOrderlogsRepository.Add(logs);
  1276. return res;
  1277. }
  1278. }
  1279. }