EnterExitCostRepository.cs 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390
  1. 
  2. using AutoMapper;
  3. using OASystem.Domain;
  4. using OASystem.Domain.Dtos.Groups;
  5. using OASystem.Domain.Entities.Groups;
  6. using OASystem.Domain.ViewModels.Groups;
  7. using OASystem.Infrastructure.Repositories.System;
  8. using OASystem.Infrastructure.Tools;
  9. using System;
  10. using System.Collections.Generic;
  11. using System.Linq;
  12. using System.Text;
  13. using System.Threading.Tasks;
  14. namespace OASystem.Infrastructure.Repositories.Groups
  15. {
  16. /// <summary>
  17. /// 出入境费用 仓库
  18. /// </summary>
  19. public class EnterExitCostRepository:BaseRepository<Grp_EnterExitCost, EnterExitCostView>
  20. {
  21. private readonly IMapper _mapper;
  22. private readonly SetDataRepository _setDataRep;
  23. public EnterExitCostRepository(SqlSugarClient sqlSugar, IMapper mapper, SetDataRepository setDataRep)
  24. :base(sqlSugar)
  25. {
  26. _setDataRep = setDataRep;
  27. _mapper = mapper;
  28. }
  29. /// <summary>
  30. /// 更新出入境费用汇率信息
  31. /// </summary>
  32. /// <returns></returns>
  33. public async Task<Result> SetEnterExitCostCurrencyChange()
  34. {
  35. Result result = new Result { Code = -1, Msg = "未知错误" };
  36. var enterExitList = await _sqlSugar.Queryable<Grp_EnterExitCost>().ToListAsync();
  37. foreach (var item in enterExitList)
  38. {
  39. string rateStr = string.Format(@"美元(USD):{0}|日元(JPY):{1}|欧元(EUR):{2}|英镑(GBP):{3}|港币(HKD):{4}", item.RateUSD,item.RateJPY,item.RateEUR,item.RateGBP,item.RateHKD);
  40. item.CurrencyRemark = rateStr;
  41. }
  42. var res = await _sqlSugar.Updateable(enterExitList)
  43. .WhereColumns(it => new { it.Id })
  44. .UpdateColumns(it => new { it.CurrencyRemark })
  45. .ExecuteCommandAsync();
  46. if (res > 0)
  47. {
  48. result.Code = 0;
  49. result.Msg = res.ToString();
  50. return result;
  51. }
  52. return result;
  53. }
  54. /// <summary>
  55. /// 查询 根据 Diid 查询
  56. /// </summary>
  57. /// <returns></returns>
  58. public async Task<Result> GetEnterExitCostInfoByDiId(EnterExitCostInfobyDiIdDto dto)
  59. {
  60. Result result = new Result();
  61. var enterExitCostData = await _sqlSugar.Queryable<Grp_EnterExitCost>().FirstAsync(it => it.DiId == dto.DiId && it.IsDel == 0);
  62. //Sys_PageFunctionPermission Function = _mapper.Map<Sys_PageFunctionPermission>(dto);
  63. EnterExitCostInfoView enterExitCostInfoView = new EnterExitCostInfoView();
  64. if (dto.PortType == 1) // Web
  65. {
  66. if (enterExitCostData != null)
  67. {
  68. enterExitCostInfoView = _mapper.Map<EnterExitCostInfoView>(enterExitCostData);
  69. var dayAndCostSql = string.Format(@"Select ntf.Country,ntf.City,ssd.Name CurremcyCode,ssd.Remark CurrencyName,gdac.* From Grp_DayAndCost gdac
  70. Left Join Grp_NationalTravelFee ntf On ntf.Id = gdac.NationalTravelFeeId
  71. Left Join Sys_SetData ssd On ssd.STid = 66 And gdac.Currency = ssd.Id
  72. Where gdac.Isdel = 0 And ntf.IsDel = 0 And gdac.DiId = {0} Order By [Type] ASC,[Days] ASC", dto.DiId);
  73. var dayAndCostData = await _sqlSugar.SqlQueryable<DayAndCostInfoView>(dayAndCostSql).ToListAsync();
  74. enterExitCostInfoView.QuarterageData = dayAndCostData.Where(it => it.Type == 1).ToList(); //住宿费 1
  75. enterExitCostInfoView.BoardWagesData = dayAndCostData.Where(it => it.Type == 2).ToList(); //伙食费 2
  76. enterExitCostInfoView.MiscellaneousFeeData = dayAndCostData.Where(it => it.Type == 3).ToList(); //公杂费 3
  77. enterExitCostInfoView.TrainingExpenseData = dayAndCostData.Where(it => it.Type == 4).ToList(); //培训费 4
  78. enterExitCostInfoView.Currencys = (List<CurrencyInfo>?)CommonFun.GetCurrencyChinaToList(enterExitCostData.CurrencyRemark);
  79. result.Msg = "查询成功";
  80. result.Code = 0;
  81. }
  82. else
  83. {
  84. // List<DayAndCostInfoView> views = new List<DayAndCostInfoView>()
  85. // {
  86. // new DayAndCostInfoView {Days=1},
  87. // new DayAndCostInfoView {Days=2},
  88. // new DayAndCostInfoView {Days=3},
  89. // new DayAndCostInfoView {Days=4},
  90. // new DayAndCostInfoView {Days=5},
  91. // new DayAndCostInfoView {Days=6},
  92. // new DayAndCostInfoView {Days=7},
  93. // new DayAndCostInfoView {Days=8},
  94. // };
  95. // enterExitCostInfoView.QuarterageData = views;
  96. // enterExitCostInfoView.BoardWagesData = views;
  97. // enterExitCostInfoView.MiscellaneousFeeData = views;
  98. // enterExitCostInfoView.TrainingExpenseData = views;
  99. // result.Code = 0;
  100. result.Msg = "未查询出数据!!!";
  101. }
  102. result.Data = enterExitCostInfoView;
  103. }
  104. else result.Msg = ErrorMsg.Error_Port_Msg;
  105. return result;
  106. }
  107. /// <summary>
  108. /// Add Or Update
  109. /// </summary>
  110. /// <param name="dto"></param>
  111. /// <returns></returns>
  112. public async Task<Result> PostEnterExitCostOperate(EnterExitCostOperateDto dto)
  113. {
  114. Result result = new Result() { Code =-1,Msg="操作失败!" };
  115. #region MyRegion
  116. //var enterExitCost = _mapper.Map<Grp_EnterExitCost>(dto);
  117. ////enterExitCost.InsidePay = enterExitCost.Visa + enterExitCost.YiMiao + enterExitCost.HeSuan + enterExitCost.Service + enterExitCost.Safe + enterExitCost.Ticket;
  118. //var quarterageData = _mapper.Map<List<Grp_DayAndCost>>(dto.QuarterageData); //住宿费 1
  119. //quarterageData = quarterageData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  120. //var boardWagesData = _mapper.Map<List<Grp_DayAndCost>>(dto.BoardWagesData); //伙食费 2
  121. //boardWagesData = boardWagesData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  122. //var miscellaneousFeeData = _mapper.Map<List<Grp_DayAndCost>>(dto.MiscellaneousFeeData); //公杂费 3
  123. //miscellaneousFeeData = miscellaneousFeeData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  124. //var trainingExpenseData = _mapper.Map<List<Grp_DayAndCost>>(dto.TrainingExpenseData); //培训费 4
  125. //trainingExpenseData = trainingExpenseData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  126. ////处理币种string
  127. //enterExitCost.CurrencyRemark = CommonFun.GetCurrencyChinaToString(dto.Currencys);
  128. //enterExitCost.CreateUserId = dto.UserId;
  129. //_sqlSugar.BeginTran();
  130. //if (dto.PortType == 1)
  131. //{
  132. // try
  133. // {
  134. // var enterExit = _sqlSugar.Storageable<Grp_EnterExitCost>(enterExitCost).ToStorage();
  135. // var enterExitadd = enterExit.AsInsertable.ExecuteCommand(); //不存在插入
  136. // var enterExitedit = enterExit.AsUpdateable.IgnoreColumns(it => new { it.DiId, it.CreateUserId, it.CreateTime, it.IsDel }).ExecuteCommand(); //存在更新
  137. // var quarterage = _sqlSugar.Storageable<Grp_DayAndCost>(quarterageData).ToStorage(); //住宿费 1
  138. // var quarterageadd = quarterage.AsInsertable.ExecuteCommand(); //不存在插入
  139. // var quarterageedit = quarterage.AsUpdateable.IgnoreColumns(it => new { it.DiId, it.Type, it.CreateUserId, it.CreateTime, it.IsDel }).ExecuteCommand(); //存在更新
  140. // var boardWages = _sqlSugar.Storageable<Grp_DayAndCost>(boardWagesData).ToStorage(); //伙食费 2
  141. // var boardWagesadd = boardWages.AsInsertable.ExecuteCommand(); //不存在插入
  142. // var boardWagesedit = boardWages.AsUpdateable.IgnoreColumns(it => new { it.DiId, it.Type, it.CreateUserId, it.CreateTime, it.IsDel }).ExecuteCommand(); //存在更新
  143. // var miscellaneousFee = _sqlSugar.Storageable<Grp_DayAndCost>(miscellaneousFeeData).ToStorage(); //公杂费 3
  144. // var miscellaneousFeeedd = miscellaneousFee.AsInsertable.ExecuteCommand(); //不存在插入
  145. // var miscellaneousFeeedit = miscellaneousFee.AsUpdateable.IgnoreColumns(it => new { it.DiId, it.Type, it.CreateUserId, it.CreateTime, it.IsDel }).ExecuteCommand(); //存在更新
  146. // var trainingExpense = _sqlSugar.Storageable<Grp_DayAndCost>(trainingExpenseData).ToStorage(); //培训费 4
  147. // var trainingExpenseadd = trainingExpense.AsInsertable.ExecuteCommand(); //不存在插入
  148. // var trainingExpenseedit = trainingExpense.AsUpdateable.IgnoreColumns(it => new { it.DiId, it.Type, it.CreateUserId, it.CreateTime, it.IsDel }).ExecuteCommand(); //存在更新
  149. // _sqlSugar.CommitTran();
  150. // result.Code = 0;
  151. // result.Msg = "操作成功!";
  152. // }
  153. // catch (Exception ex)
  154. // {
  155. // _sqlSugar.RollbackTran();
  156. // result.Msg = ex.Message;
  157. // }
  158. //}
  159. //else result.Msg = ErrorMsg.Error_Port_Msg;
  160. #endregion
  161. var enterExitCost = _mapper.Map<Grp_EnterExitCost>(dto);
  162. //enterExitCost.InsidePay = enterExitCost.Visa + enterExitCost.YiMiao + enterExitCost.HeSuan + enterExitCost.Service + enterExitCost.Safe + enterExitCost.Ticket;
  163. List<Grp_DayAndCost> subData = new List<Grp_DayAndCost>();
  164. var quarterageData = _mapper.Map<List<Grp_DayAndCost>>(dto.QuarterageData); //住宿费 1
  165. quarterageData = quarterageData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  166. if (quarterageData.Count > 0) subData.AddRange(quarterageData);
  167. var boardWagesData = _mapper.Map<List<Grp_DayAndCost>>(dto.BoardWagesData); //伙食费 2
  168. boardWagesData = boardWagesData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  169. if (boardWagesData.Count > 0) subData.AddRange(boardWagesData);
  170. var miscellaneousFeeData = _mapper.Map<List<Grp_DayAndCost>>(dto.MiscellaneousFeeData); //公杂费 3
  171. miscellaneousFeeData = miscellaneousFeeData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  172. if (miscellaneousFeeData.Count > 0) subData.AddRange(miscellaneousFeeData);
  173. var trainingExpenseData = _mapper.Map<List<Grp_DayAndCost>>(dto.TrainingExpenseData); //培训费 4
  174. trainingExpenseData = trainingExpenseData.Select(it => { it.CreateUserId = dto.UserId; return it; }).ToList();
  175. if (trainingExpenseData.Count > 0) subData.AddRange(trainingExpenseData);
  176. //处理币种string
  177. enterExitCost.CurrencyRemark = CommonFun.GetCurrencyChinaToString(dto.Currencys);
  178. enterExitCost.CreateUserId = dto.UserId;
  179. _sqlSugar.BeginTran();
  180. if (dto.PortType == 1)
  181. {
  182. try
  183. {
  184. int enterExitId = 0;
  185. if (enterExitCost.Id > 0) //修改
  186. {
  187. var updateId = _sqlSugar.Updateable<Grp_EnterExitCost>(enterExitCost)
  188. .IgnoreColumns(it => new { it.DeleteUserId, it.DeleteTime, it.CreateUserId, it.CreateTime, it.IsDel })
  189. .ExecuteCommand();
  190. if (updateId > 0)
  191. {
  192. enterExitId = enterExitCost.Id;
  193. }
  194. else
  195. {
  196. _sqlSugar.RollbackTran();
  197. result.Msg = "修改操作失败!";
  198. return result;
  199. }
  200. }
  201. else
  202. { //添加
  203. enterExitId = _sqlSugar.Insertable<Grp_EnterExitCost>(enterExitCost).ExecuteReturnIdentity();
  204. if (enterExitId < 1)
  205. {
  206. result.Msg = "添加操作失败!";
  207. return result;
  208. }
  209. }
  210. if (enterExitId > 0)
  211. {
  212. foreach (var item in subData)
  213. {
  214. if (item.Id > 0) //修改
  215. {
  216. var updateId = _sqlSugar.Updateable<Grp_DayAndCost>(item)
  217. .IgnoreColumns(it => new { it.DiId, it.Type, it.CreateUserId, it.CreateTime, it.IsDel })
  218. .ExecuteCommand();
  219. if (updateId < 1)
  220. {
  221. _sqlSugar.RollbackTran();
  222. result.Msg = "修改操作失败!";
  223. return result;
  224. }
  225. }
  226. else
  227. { //添加
  228. var updateId = _sqlSugar.Insertable<Grp_DayAndCost>(item).ExecuteCommand();
  229. if (updateId < 1)
  230. {
  231. _sqlSugar.RollbackTran();
  232. result.Msg = "添加操作失败!";
  233. return result;
  234. }
  235. }
  236. }
  237. }
  238. _sqlSugar.CommitTran();
  239. result.Code = 0;
  240. result.Msg = "操作成功!";
  241. }
  242. catch (Exception ex)
  243. {
  244. _sqlSugar.RollbackTran();
  245. result.Msg = ex.Message;
  246. }
  247. }
  248. else result.Msg = ErrorMsg.Error_Port_Msg;
  249. return result;
  250. }
  251. /// <summary>
  252. /// Del
  253. /// </summary>
  254. /// <param name="dto"></param>
  255. /// <returns></returns>
  256. public async Task<Result> PostEnterExitCostSubItemDel(EnterExitCostSubItemDelDto dto)
  257. {
  258. Result result = new Result();
  259. var data = new Grp_DayAndCost()
  260. {
  261. Id = dto.Id,
  262. IsDel = 1,
  263. DeleteUserId = dto.DeleteUserId,
  264. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")
  265. };
  266. var del = _sqlSugar.Updateable(data).UpdateColumns(it => new { it.IsDel, it.DeleteUserId,it.DeleteTime }).ExecuteCommand();
  267. if (del > 0) result.Code = 0;
  268. else result.Msg = string.Format("删除失败!");
  269. return result;
  270. }
  271. /// <summary>
  272. /// 团组模块 - 出入境国家费用标准 - Add Or Update
  273. /// </summary>
  274. /// <param name="dto"></param>
  275. /// <returns></returns>
  276. public async Task<Result> PostNationalTravelFeeOperate(NationalTravelFeeOperateDto dto)
  277. {
  278. Result result = new Result();
  279. Grp_NationalTravelFee nationalTravelFee = _mapper.Map<Grp_NationalTravelFee>(dto);
  280. nationalTravelFee.LastUpdateUserId = dto.UserId;
  281. nationalTravelFee.CreateUserId = dto.UserId;
  282. if (dto.PortType == 1) //web
  283. {
  284. var _nationalTravelFee = _sqlSugar.Storageable<Grp_NationalTravelFee>(nationalTravelFee).ToStorage();
  285. if (dto.Id == 0) //新增
  286. {
  287. string selectSql = string.Format(@"Select * From Grp_NationalTravelFee
  288. Where IsDel = 0
  289. And Continent = '{0}'
  290. And Country = '{1}'
  291. And City = '{2}'", dto.Continent, dto.Country, dto.City);
  292. Grp_NationalTravelFee nationalTravelFee1 = new Grp_NationalTravelFee();
  293. nationalTravelFee1 = await _sqlSugar.SqlQueryable<Grp_NationalTravelFee>(selectSql).FirstAsync();
  294. if (nationalTravelFee1 != null)
  295. {
  296. result.Msg = "该国家 城市已存在,请勿重复添加!";
  297. return result;
  298. }
  299. _nationalTravelFee.AsInsertable.ExecuteCommand(); //不存在插入
  300. }
  301. else
  302. {
  303. _nationalTravelFee.AsUpdateable
  304. .IgnoreColumns(it => new { it.CreateUserId, it.CreateTime, it.IsDel })
  305. .WhereColumns(it => it.Id)
  306. .ExecuteCommand(); //存在更新
  307. }
  308. result.Code = 0;
  309. }
  310. else if (dto.PortType == 2) //Android
  311. {
  312. }
  313. else if (dto.PortType == 3) //Ios
  314. {
  315. }
  316. else result.Msg = ErrorMsg.Error_Port_Msg;
  317. return result;
  318. }
  319. }
  320. }