DelegationInfoRepository.cs 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823
  1. using AutoMapper;
  2. using Newtonsoft.Json;
  3. using NPOI.OpenXmlFormats.Wordprocessing;
  4. using OASystem.Domain;
  5. using OASystem.Domain.Dtos;
  6. using OASystem.Domain.Dtos.Financial;
  7. using OASystem.Domain.Dtos.Groups;
  8. using OASystem.Domain.Dtos.UserDto;
  9. using OASystem.Domain.Entities.Customer;
  10. using OASystem.Domain.Entities.Groups;
  11. using OASystem.Domain.ViewModels.CRM;
  12. using OASystem.Domain.ViewModels.Financial;
  13. using OASystem.Domain.ViewModels.Groups;
  14. using OASystem.Infrastructure.Repositories.System;
  15. using Org.BouncyCastle.Asn1.Cms;
  16. using Org.BouncyCastle.Utilities.Collections;
  17. using Serilog;
  18. using SqlSugar;
  19. using System;
  20. using System.Collections.Generic;
  21. using System.Linq;
  22. using System.Text;
  23. using System.Threading.Tasks;
  24. namespace OASystem.Infrastructure.Repositories.Groups
  25. {
  26. /// <summary>
  27. /// 接团信息
  28. /// </summary>
  29. public class DelegationInfoRepository : BaseRepository<Grp_DelegationInfo, DelegationInfoView>
  30. {
  31. private readonly SetDataRepository _setDataRepository;
  32. private readonly UsersRepository _usersRepository;
  33. private readonly TaskAssignmentRepository _taskAssignmentRep;
  34. private readonly IMapper _mapper;
  35. //private readonly TeamRateRepository _teamRateRep;
  36. //public readonly Logs _logs;
  37. public DelegationInfoRepository(SqlSugarClient sqlSugar, SetDataRepository setDataRepository, UsersRepository usersRepository,
  38. TaskAssignmentRepository taskAssignmentRep, IMapper mapper)
  39. : base(sqlSugar)
  40. {
  41. _setDataRepository = setDataRepository;
  42. _usersRepository = usersRepository;
  43. _taskAssignmentRep = taskAssignmentRep;
  44. _mapper = mapper;
  45. //_teamRateRep = teamRateRep;
  46. }
  47. #region 团组信息 团组详情共享Api
  48. /// <summary>
  49. /// 团组信息 团组预览详情共享Api
  50. /// </summary>
  51. /// <param name="dto"></param>
  52. /// <returns></returns>
  53. public async Task<Result> PostShareGroupInfo(ShareGroupInfoDto dto)
  54. {
  55. Result result = new Result() { Code = -2, Msg = "未知错误" };
  56. string sql = string.Format(@"Select Id,TeamName,TourCode,ClientName,VisitCountry,VisitStartDate,VisitEndDate,VisitDays,VisitPNumber
  57. From Grp_DelegationInfo Where Id = {0} And IsDel = 0", dto.Id);
  58. if (dto.PortType == 1) //Web
  59. {
  60. var _DelegationInfo = await _sqlSugar.SqlQueryable<Web_ShareGroupInfoView>(sql).FirstAsync();
  61. if (_DelegationInfo != null)
  62. {
  63. if (!string.IsNullOrEmpty(_DelegationInfo.VisitCountry))
  64. {
  65. if (_DelegationInfo.VisitCountry.Contains("|"))
  66. {
  67. _DelegationInfo.VisitCountry = _DelegationInfo.VisitCountry.Replace("|", "、");
  68. }
  69. }
  70. else _DelegationInfo.VisitCountry = " - ";
  71. result.Data = _DelegationInfo;
  72. }
  73. else result.Msg = "暂无该团组信息";
  74. }
  75. else if (dto.PortType == 2 || dto.PortType == 3) //IOS Or Android
  76. {
  77. var _DelegationInfo = await _sqlSugar.SqlQueryable<IOSOrAndroid_ShareGroupInfoView>(sql).FirstAsync();
  78. if (_DelegationInfo != null)
  79. {
  80. if (!string.IsNullOrEmpty(_DelegationInfo.VisitCountry))
  81. {
  82. if (_DelegationInfo.VisitCountry.Contains("|"))
  83. {
  84. _DelegationInfo.VisitCountry = _DelegationInfo.VisitCountry.Replace("|", "、");
  85. }
  86. }
  87. else _DelegationInfo.VisitCountry = " - ";
  88. result.Data = _DelegationInfo;
  89. }
  90. else result.Msg = "暂无该团组信息";
  91. }
  92. else result.Msg = "请输入正确的端口号。1 Web 2 Android 3 IOS";
  93. result.Code = 0;
  94. result.Msg = "成功!";
  95. return result;
  96. }
  97. #endregion
  98. /// <summary>
  99. /// 获取接团信息Info
  100. /// </summary>
  101. /// <param name="dto"></param>
  102. /// <returns></returns>
  103. public async Task<Result> PostGroupInfo(GroupInfoDto dto)
  104. {
  105. Result result = new Result() { Code = -2, Msg = "未知错误" };
  106. if (dto.PortType == 1 || dto.PortType == 2) //Web Or Android
  107. {
  108. string sql = string.Format(@"Select Id,SalesQuoteNo,TourCode,JietuanOperator,TeamLevSId,TeamDid,TeamName,ClientName,
  109. ClientUnit,VisitCountry,VisitDate,VisitDays,VisitPNumber,TontractTime,
  110. PayDay,PaymentMoney,VisitPurpose,SpecialNeeds,OtherNeeds,CGRWSPBMMC,CGRWSPWH,
  111. ZZSCBMMC,ZZSCSPWH,Remark,TellPhone,Officialneeds
  112. From Grp_DelegationInfo Where Id = {0} And IsDel = 0", dto.Id);
  113. var _DelegationInfo = await _sqlSugar.SqlQueryable<DelegationInfoWebView>(sql).FirstAsync();
  114. if (_DelegationInfo != null)
  115. {
  116. result.Code = 0;
  117. result.Msg = "成功!";
  118. result.Data = _DelegationInfo;
  119. }
  120. else result.Msg = "暂无该团组信息";
  121. }
  122. return result;
  123. }
  124. #region 团组
  125. /// <summary>
  126. /// 获取接团信息 Page List
  127. /// </summary>
  128. /// <param name="dto"></param>
  129. /// <returns></returns>
  130. public async Task<Result> GetGroupPageList(GroupCommissionDto dto)
  131. {
  132. Result result = new Result() { Code = -2, Msg = "未知错误" };
  133. ListViewBase<DelegationPageListView> groupsInfoPageList = new ListViewBase<DelegationPageListView>()
  134. {
  135. ReceiveDt = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")
  136. };
  137. if (dto.PortType == 1 || dto.PortType == 2) //web
  138. {
  139. int startIndex = (dto.PageIndex - 1) * dto.PageSize + 1;
  140. int endIndex = startIndex + dto.PageSize - 1;
  141. int taskUserId = -1;
  142. string taskGroupIds = string.Empty;
  143. #region 处理用户团组操作权限
  144. if (dto.UserId != -1)
  145. {
  146. }
  147. #endregion
  148. string sql = string.Format(@"Select * From(Select row_number() over (order by gdi.Id Desc) as RowNumber,
  149. gdi.Id,SalesQuoteNo,TourCode,ssd.Id TeamTypeId, ssd.Name TeamType,ssd1.Id TeamLevId,
  150. ssd1.Name TeamLev,TeamName,ClientName,ClientUnit,VisitDate,VisitDays,VisitPNumber,
  151. su.CnName JietuanOperator,IsSure
  152. From Grp_DelegationInfo gdi
  153. Inner Join Sys_SetData ssd On gdi.TeamDid = ssd.Id
  154. Inner Join Sys_SetData ssd1 On gdi.TeamLevSId = ssd1.Id
  155. Left Join Sys_Users su On gdi.JietuanOperator = su.Id
  156. Where gdi.IsDel = 0
  157. )temp Where RowNumber Between {0} and {1}", startIndex, endIndex);
  158. string sqlCount = string.Format(@"Select Count(1) as Count From Grp_DelegationInfo gdi
  159. Inner Join Sys_SetData ssd On gdi.TeamDid = ssd.Id
  160. Inner Join Sys_SetData ssd1 On gdi.TeamLevSId = ssd1.Id
  161. Left Join Sys_Users su On gdi.JietuanOperator = su.Id
  162. Where gdi.IsDel = 0 ");
  163. List<DelegationPageListView> _DeleInfoList = await _sqlSugar.SqlQueryable<DelegationPageListView>(sql).ToListAsync();
  164. DelegationPageCountView _DeleCount = await _sqlSugar.SqlQueryable<DelegationPageCountView>(sqlCount).FirstAsync();
  165. int count = _DeleCount.Count;
  166. groupsInfoPageList = new ListViewBase<DelegationPageListView>
  167. {
  168. CurrPageIndex = dto.PageIndex,
  169. CurrPageSize = dto.PageSize,
  170. DataCount = count,
  171. DataList = _DeleInfoList
  172. };
  173. result.Code = 0;
  174. result.Msg = "成功!";
  175. result.Data = groupsInfoPageList;
  176. }
  177. return result;
  178. }
  179. /// <summary>
  180. /// 获取接团信息List
  181. /// </summary>
  182. /// <param name="dto"></param>
  183. /// <returns></returns>
  184. public async Task<Result> GetGroupList(GroupListDto dto)
  185. {
  186. Result result = new Result() { Code = -2, Msg = "未知错误" };
  187. if (dto.PortType == 1 || dto.PortType == 2) //web
  188. {
  189. string sql = string.Format(@"Select gdi.Id,SalesQuoteNo,TourCode,ssd.Id TeamTypeId, ssd.Name TeamType,ssd1.Id TeamLevId,ssd1.Name TeamLev,TeamName,ClientName,ClientUnit,VisitDate,VisitDays,VisitPNumber,su.CnName JietuanOperator,IsSure
  190. From Grp_DelegationInfo gdi
  191. Inner Join Sys_SetData ssd On gdi.TeamDid = ssd.Id
  192. Inner Join Sys_SetData ssd1 On gdi.TeamLevSId = ssd1.Id
  193. Left Join Sys_Users su On gdi.JietuanOperator = su.Id
  194. Where gdi.IsDel = 0
  195. Order By gdi.CreateTime Desc");
  196. var _DelegationList = await _sqlSugar.SqlQueryable<DelegationListView>(sql).ToListAsync();
  197. if (_DelegationList.Count > 0)
  198. {
  199. result.Code = 0;
  200. result.Msg = "成功!";
  201. result.Data = _DelegationList;
  202. }
  203. else
  204. {
  205. result.Msg = "暂无该团组信息";
  206. }
  207. }
  208. return result;
  209. }
  210. /// <summary>
  211. /// 获取接团信息Info
  212. /// </summary>
  213. /// <param name="dto"></param>
  214. /// <returns></returns>
  215. public async Task<Result> GetGroupInfo(GroupInfoDto dto)
  216. {
  217. Result result = new Result() { Code = -2, Msg = "未知错误" };
  218. if (dto.PortType == 1 || dto.PortType == 2) //Web Or Android
  219. {
  220. string sql = string.Format(@"Select Id,SalesQuoteNo,TourCode,JietuanOperator,TeamLevSId,TeamDid,TeamName,ClientName,
  221. ClientUnit,VisitCountry,VisitDate,VisitDays,VisitPNumber,TontractTime,
  222. PayDay,PaymentMoney,VisitPurpose,SpecialNeeds,OtherNeeds,CGRWSPBMMC,CGRWSPWH,
  223. ZZSCBMMC,ZZSCSPWH,Remark,TellPhone,OpRoyaltyLv,OpRoyaltyRemark,Officialneeds
  224. From Grp_DelegationInfo Where Id = {0} And IsDel = 0", dto.Id);
  225. var _DelegationInfo = await _sqlSugar.SqlQueryable<DelegationInfoWebView>(sql).FirstAsync();
  226. if (_DelegationInfo != null)
  227. {
  228. result.Code = 0;
  229. result.Msg = "成功!";
  230. result.Data = _DelegationInfo;
  231. if (dto.PortType == 2)
  232. {
  233. var GroupProcessOperationDtoParam = new GroupProcessOperationDto();
  234. GroupProcessOperationDtoParam = _mapper.Map<DelegationInfoWebView, GroupProcessOperationDto>(_DelegationInfo);
  235. List<Crm_DeleClient> DeleClientArr = await _sqlSugar.Queryable<Crm_DeleClient>().Where(it => it.IsDel == 0).ToListAsync(); //客户信息
  236. List<Grp_TourClientList> _DeleClients = await _sqlSugar.Queryable<Grp_TourClientList>().Where(it => it.IsDel == 0 && it.DiId == dto.Id).ToListAsync(); // 接团客户名单
  237. List<Crm_CustomerCert> _CustomerCerts = await _sqlSugar.Queryable<Crm_CustomerCert>().Where(it => it.IsDel == 0 && it.SdId == 773).ToListAsync(); // 身份证类型证件信息
  238. List<Crm_CustomerCompany> CompanyArr = await _sqlSugar.Queryable<Crm_CustomerCompany>().Where(it => it.IsDel == 0).ToListAsync();
  239. var TourClientListInfoArr = new List<TourClientListProcessInfo>();
  240. var timeParam = new DateTime();
  241. foreach (var item in _DeleClients)
  242. {
  243. var param = new TourClientListProcessInfo();
  244. var clientInfo = DeleClientArr.FirstOrDefault(x => x.Id == item.ClientId);
  245. if (clientInfo == null) clientInfo = new Crm_DeleClient();
  246. var clientIDInfo = _CustomerCerts.FirstOrDefault(x=>x.DcId == item.ClientId); //身份证信息
  247. if (clientIDInfo == null) clientIDInfo = new Crm_CustomerCert();
  248. var Company = CompanyArr.FirstOrDefault(x => x.Id == clientInfo.CrmCompanyId);
  249. if(Company == null) Company = new Crm_CustomerCompany();
  250. param.IDCardNo = clientIDInfo.CertNo;
  251. param.Remark = item.Remark;
  252. param.BirthDay = DateTime.TryParse(clientInfo.BirthDay, out timeParam) ? timeParam.ToString("yyyy-MM-dd") : "";
  253. param.FirstName = clientInfo.FirstName;
  254. param.LastName = clientInfo.LastName;
  255. param.CompanyFullName = Company.CompanyFullName;
  256. param.Job = clientInfo.Job;
  257. param.Sex = clientInfo.Sex;
  258. param.Phone = clientInfo.Phone;
  259. param.Pinyin = clientInfo.Pinyin;
  260. param.HotelSpecialNeeds = item.HotelSpecialNeeds;
  261. param.MealSpecialNeeds = item.MealSpecialNeeds;
  262. param.ShippingSpaceSpecialNeeds = item.ShippingSpaceSpecialNeeds;
  263. param.ShippingSpaceTypeId = item.ShippingSpaceTypeId;
  264. param.Id = clientInfo.Id;
  265. TourClientListInfoArr.Add(param);
  266. }
  267. GroupProcessOperationDtoParam.PortType = dto.PortType;
  268. GroupProcessOperationDtoParam.TourClientListInfos = TourClientListInfoArr;
  269. GroupProcessOperationDtoParam.VisitDate = DateTime.TryParse(GroupProcessOperationDtoParam.VisitDate, out timeParam) ? timeParam.ToString("yyyy-MM-dd") : "";
  270. GroupProcessOperationDtoParam.TontractTime = DateTime.TryParse(GroupProcessOperationDtoParam.TontractTime, out timeParam) ? timeParam.ToString("yyyy-MM-dd") : "";
  271. result.Data = GroupProcessOperationDtoParam;
  272. }
  273. }
  274. else result.Msg = "暂无该团组信息";
  275. }
  276. return result;
  277. }
  278. /// <summary>
  279. /// 获取接团信息 编辑
  280. /// 基础 数据源
  281. /// </summary>
  282. /// <param name="dto"></param>
  283. /// <returns></returns>
  284. public async Task<Result> GroupEditBasicSource(GroupListDto dto)
  285. {
  286. Result result = new Result() { Code = -2, Msg = "未知错误" };
  287. try
  288. {
  289. if (dto.PortType == 1 || dto.PortType == 2) //web
  290. {
  291. dynamic? teamTypeData1 = null;
  292. string teamTypeSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = {0} And IsDel = {1}", 10, 0);
  293. var teamTypeData = await _sqlSugar.SqlQueryable<SetDataInfoView>(teamTypeSql).ToListAsync(); ; //团组分类 10
  294. if (teamTypeData.Count > 0)
  295. {
  296. teamTypeData1 = teamTypeData;
  297. }
  298. dynamic? teamLevData1 = null;
  299. string teamLevSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = {0} And IsDel = {1}", 56, 0);
  300. var teamLevData = await _sqlSugar.SqlQueryable<SetDataInfoView>(teamLevSql).ToListAsync(); ; //团组等级 56
  301. if (teamLevData.Count > 0)
  302. {
  303. teamLevData1 = teamLevData;
  304. }
  305. dynamic? userData1 = null;
  306. string userSql = string.Format(@"Select Id,CnName From Sys_Users Where IsDel = {0}", 0);
  307. var userData = await _sqlSugar.SqlQueryable<UserNameView>(userSql).ToListAsync(); ;
  308. if (userData.Count > 0)
  309. {
  310. userData1 = userData;
  311. }
  312. result.Code = 0;
  313. result.Msg = "成功!";
  314. result.Data = new
  315. {
  316. teamTypeData = teamTypeData1,
  317. teamLevData = teamLevData1,
  318. userData = userData1
  319. };
  320. }
  321. }
  322. catch (Exception)
  323. {
  324. throw;
  325. }
  326. return result;
  327. }
  328. /// <summary>
  329. /// 团组信息操作
  330. /// </summary>
  331. /// <param name="dto"></param>
  332. /// <returns></returns>
  333. public async Task<Result> GroupOperation(GroupOperationDto dto)
  334. {
  335. Result result = new Result() { Code = -2, Msg = "未知错误" };
  336. if (dto.PortType == 1 || dto.PortType == 2) //web
  337. {
  338. #region 添加出访起止时间
  339. var startTime = new DateTime();
  340. var endTime = new DateTime();
  341. if (DateTime.TryParse(dto.VisitDate, out startTime))
  342. {
  343. endTime = startTime.AddDays(dto.VisitDays);
  344. }
  345. #endregion
  346. if (dto.Status == 1) //添加
  347. {
  348. string selectSql = string.Format(@"Select * From Grp_DelegationInfo
  349. Where IsDel = 0
  350. And TeamName = '{0}'
  351. And ClientName = '{1}'
  352. And ClientUnit ='{2}'
  353. And VisitDate ='{3}'",dto.TeamName, dto.ClientName, dto.ClientUnit, dto.VisitDate);
  354. var selectGroupInfo = await _sqlSugar.SqlQueryable<Grp_DelegationInfo>(selectSql).FirstAsync();
  355. if (selectGroupInfo != null)
  356. {
  357. result.Msg = "数据已存在,请勿重复添加!";
  358. return result;
  359. }
  360. //string teamCodeSql = string.Format("Select SalesQuoteNo From Grp_DelegationInfo");
  361. //var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  362. //string SalesQuoteNo = "";
  363. //while (true)
  364. //{
  365. // SalesQuoteNo = Tools.CommonFun.GetRandomStr(6);
  366. // if (!teamCodeItem.Equals(SalesQuoteNo))
  367. // {
  368. // break;
  369. // }
  370. //}
  371. string countrys = string.Empty;
  372. string countryReq = dto.VisitCountry;
  373. if (!string.IsNullOrEmpty(countryReq))
  374. {
  375. if (countryReq.Contains(",")) countrys = countryReq.Replace(',','|');
  376. else if (countryReq.Contains(",")) countrys = countryReq.Replace(',', '|');
  377. else if (countryReq.Contains(" ")) countrys = countryReq.Replace(' ', '|');
  378. else if (countryReq.Contains("、")) countrys = countryReq.Replace('、', '|');
  379. else if (countryReq.Contains(".")) countrys = countryReq.Replace('.', '|');
  380. else countrys = countryReq;
  381. }
  382. Grp_DelegationInfo delegationInfo = new Grp_DelegationInfo()
  383. {
  384. SalesQuoteNo = dto.SalesQuoteNo,
  385. TeamLevSId = dto.TeamLevSId,
  386. ClientName = dto.ClientName,
  387. ClientUnit = dto.ClientUnit,
  388. TeamName = dto.TeamName,
  389. TeamDid = dto.TeamDid,
  390. VisitDate = Convert.ToDateTime(dto.VisitDate),
  391. VisitCountry = countrys,
  392. VisitPurpose = dto.VisitPurpose,
  393. VisitDays = dto.VisitDays,
  394. VisitPNumber = dto.VisitPNumber,
  395. SpecialNeeds = dto.SpecialNeeds,
  396. OtherNeeds = dto.OtherNeeds,
  397. Remark = dto.Remark,
  398. JietuanOperator = dto.UserId,
  399. TellPhone = dto.TellPhone,
  400. CGRWSPBMMC = dto.CGRWSPBMMC,
  401. CGRWSPWH = dto.CGRWSPWH,
  402. ZZSCBMMC = dto.ZZSCBMMC,
  403. ZZSCSPWH = dto.ZZSCSPWH,
  404. TontractTime = Convert.ToDateTime(dto.TontractTime),
  405. PaymentMoney = dto.PaymentMoney,
  406. PayDay = dto.PayDay,
  407. TourCode = "",
  408. SalesDate = DateTime.Now,
  409. IsState = 0, //默认团组未完成 0
  410. JietuanTime = DateTime.Now,
  411. IsDel = 0,
  412. BudgetCost = 0.00M,
  413. HotelComplain = 0,
  414. OPComplain = 0,
  415. OAComplain = 0,
  416. AirComplain = 0,
  417. VisaComplain = 0,
  418. CreateUserId = dto.UserId,
  419. CreateTime = DateTime.Now,
  420. DeleteUserId = null,
  421. DeleteTime = new DateTime(1990, 1, 1).ToString("yyyy-MM-dd HH:mm:ss"),
  422. OpRoyaltyLv = dto.OpRoyaltyLv,
  423. OpRoyaltyRemark=dto.opRoyaltyRemark,
  424. Officialneeds = dto.Officialneeds,
  425. VisitStartDate = startTime,
  426. VisitEndDate = endTime,
  427. };
  428. var addId = await _sqlSugar.Insertable(delegationInfo).ExecuteReturnIdentityAsync();
  429. if (addId > 0)
  430. {
  431. result.Code = 0;
  432. result.Msg = "添加成功!";
  433. result.Data = addId;
  434. }
  435. else
  436. {
  437. result.Msg = "添加失败!";
  438. }
  439. }
  440. else if (dto.Status == 2) //修改
  441. {
  442. var updateStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  443. {
  444. SalesQuoteNo = dto.SalesQuoteNo,
  445. TeamLevSId = dto.TeamLevSId,
  446. ClientName = dto.ClientName,
  447. ClientUnit = dto.ClientUnit,
  448. TeamName = dto.TeamName,
  449. TeamDid = dto.TeamDid,
  450. VisitDate = Convert.ToDateTime(dto.VisitDate),
  451. VisitCountry = dto.VisitCountry,
  452. VisitPurpose = dto.VisitPurpose,
  453. VisitDays = dto.VisitDays,
  454. VisitPNumber = dto.VisitPNumber,
  455. SpecialNeeds = dto.SpecialNeeds,
  456. OtherNeeds = dto.OtherNeeds,
  457. Remark = dto.Remark,
  458. JietuanOperator = dto.JietuanOperator,
  459. TellPhone = dto.TellPhone,
  460. CGRWSPBMMC = dto.CGRWSPBMMC,
  461. CGRWSPWH = dto.CGRWSPWH,
  462. ZZSCBMMC = dto.ZZSCBMMC,
  463. ZZSCSPWH = dto.ZZSCSPWH,
  464. TontractTime = Convert.ToDateTime(dto.TontractTime),
  465. PaymentMoney = dto.PaymentMoney,
  466. PayDay = dto.PayDay,
  467. OpRoyaltyLv = dto.OpRoyaltyLv,
  468. OpRoyaltyRemark = dto.opRoyaltyRemark,
  469. Officialneeds = dto.Officialneeds,
  470. VisitStartDate = startTime,
  471. VisitEndDate = endTime,
  472. });
  473. if (updateStatus)
  474. {
  475. result.Code = 0;
  476. result.Msg = "修改成功!";
  477. }
  478. else
  479. {
  480. result.Msg = "修改失败!";
  481. }
  482. }
  483. else if (dto.Status == 3) //删除
  484. {
  485. var deleteStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  486. {
  487. DeleteUserId = dto.UserId,
  488. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  489. IsDel = 1
  490. });
  491. if (deleteStatus)
  492. {
  493. result.Code = 0;
  494. result.Msg = "删除成功!";
  495. }
  496. else
  497. {
  498. result.Msg = "删除失败!";
  499. }
  500. }
  501. }
  502. return result;
  503. }
  504. /// <summary>
  505. /// 团组信息操作 - 删除
  506. /// </summary>
  507. /// <param name="dto"></param>
  508. /// <returns></returns>
  509. public async Task<Result> GroupDel(GroupDelDto dto)
  510. {
  511. Result result = new Result() { Code = -2, Msg = "未知错误" };
  512. if (dto.PortType == 1 || dto.PortType == 2) //web
  513. {
  514. var deleteStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  515. {
  516. DeleteUserId = dto.UserId,
  517. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  518. IsDel = 1
  519. });
  520. if (deleteStatus)
  521. {
  522. result.Code = 0;
  523. result.Msg = "删除成功!";
  524. }
  525. else
  526. {
  527. result.Msg = "删除失败!";
  528. }
  529. }
  530. return result;
  531. }
  532. /// <summary>
  533. /// 获取销售报价号
  534. /// </summary>
  535. /// <returns></returns>
  536. public async Task<Result> GetGroupSalesQuoteNo()
  537. {
  538. Result result = new Result() { Code = -2, Msg = "未知错误" };
  539. string teamCodeSql = string.Format("Select SalesQuoteNo From Grp_DelegationInfo");
  540. var teamCodeItem = await _sqlSugar.SqlQueryable<SalesQuoteNoView>(teamCodeSql).ToListAsync();
  541. string teamCode = "";
  542. while (true)
  543. {
  544. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  545. if (!teamCodeItem.Equals(teamCode))
  546. {
  547. break;
  548. }
  549. }
  550. result.Code = 0;
  551. result.Msg = "成功!";
  552. result.Data = teamCode;
  553. return result;
  554. }
  555. /// <summary>
  556. /// 团组删除
  557. /// </summary>
  558. /// <returns></returns>
  559. public async Task<Result> GroupDeleteById()
  560. {
  561. Result result = new Result() { Code = -2, Msg = "未知错误" };
  562. string teamCodeSql = string.Format("Select TourCode From Grp_DelegationInfo");
  563. var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  564. string teamCode = "";
  565. while (true)
  566. {
  567. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  568. if (!teamCodeItem.Equals(teamCode))
  569. {
  570. break;
  571. }
  572. }
  573. result.Code = 0;
  574. result.Msg = "成功!";
  575. result.Data = teamCode;
  576. return result;
  577. }
  578. /// <summary>
  579. /// 团组确认出团
  580. /// </summary>
  581. /// <returns></returns>
  582. public async Task<Result> ConfirmationGroup(ConfirmationGroupDto dto)
  583. {
  584. Result result = new Result() { Code = -2, Msg = "未知错误" };
  585. string teamCode = "";
  586. if (dto.PortType == 1 || dto.PortType == 2 || dto.PortType == 3) //web
  587. {
  588. string teamCodeSql = string.Format("Select TourCode From Grp_DelegationInfo");
  589. var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  590. while (true)
  591. {
  592. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  593. if (!teamCodeItem.Equals(teamCode))
  594. {
  595. break;
  596. }
  597. }
  598. var deleteStatus = await UpdateAsync(a => a.Id == dto.GroupId, a => new Grp_DelegationInfo
  599. {
  600. TourCode = teamCode,
  601. GroupsOperator = dto.GroupsOperator,
  602. GroupsTime = DateTime.Now
  603. });
  604. if (deleteStatus)
  605. {
  606. result.Code = 0;
  607. result.Msg = "确认出团设置成功!";
  608. }
  609. else
  610. {
  611. result.Msg = "确认出团设置失败!";
  612. }
  613. }
  614. result.Code = 0;
  615. result.Msg = "成功!";
  616. result.Data = teamCode;
  617. return result;
  618. }
  619. /// <summary>
  620. /// 获取接团名称List
  621. /// </summary>
  622. /// <param name="dto"></param>
  623. /// <returns></returns>
  624. public async Task<Result> GetGroupNameList(GroupNameDto dto)
  625. {
  626. Result result = new Result() { Code = -2, Msg = "未知错误" };
  627. if (dto.PortType == 1 || dto.PortType == 2) //web
  628. {
  629. string sql = string.Format(@"Select Id,TeamName GroupName From Grp_DelegationInfo
  630. Where TeamName != '' And IsDel = 0
  631. Order By Id Desc");
  632. var _groupNameList = await _sqlSugar.SqlQueryable<GroupNameView>(sql).ToListAsync();
  633. if (_groupNameList.Count > 0)
  634. {
  635. result.Code = 0;
  636. result.Msg = "成功!";
  637. result.Data = _groupNameList;
  638. }
  639. else
  640. {
  641. result.Msg = "暂无团组信息";
  642. }
  643. }
  644. return result;
  645. }
  646. /// <summary>
  647. /// 获取接团名称List And 签证国别
  648. /// </summary>
  649. /// <param name="dto"></param>
  650. /// <returns></returns>
  651. public async Task<Result> GetGroupNameAndVisaNationality(GroupNameDto dto)
  652. {
  653. Result result = new Result() { Code = -2, Msg = "未知错误" };
  654. if (dto.PortType == 1 || dto.PortType == 2) //web
  655. {
  656. string sql = string.Format(@"Select Id,TeamName GroupName From Grp_DelegationInfo
  657. Where TeamName != '' And IsDel = 0
  658. Order By Id Desc");
  659. var _groupNameList = await _sqlSugar.SqlQueryable<GroupNameView>(sql).ToListAsync();
  660. string visaSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = 41 And IsDel = 0");
  661. var _setDataList = await _sqlSugar.SqlQueryable<SetDataInfoView>(visaSql).ToListAsync();
  662. var data = new {
  663. groupNameData = _groupNameList,
  664. visaNationalityData = _setDataList
  665. };
  666. result.Data = data;
  667. result.Code = 0;
  668. }
  669. return result;
  670. }
  671. #endregion
  672. #region 团组&签证
  673. /// <summary>
  674. /// 根据团组Id查询客户
  675. /// </summary>
  676. /// <param name="dto"></param>
  677. /// <returns></returns>
  678. public async Task<Result> GetCrmByGroupId(ClientByGroupIdDto dto)
  679. {
  680. Result result = new Result() { Code = -2 };
  681. if (dto.PortType == 1 || dto.PortType == 2)
  682. {
  683. string sql = string.Format(@"Select gdjc.GrpDCId grpId,cdc.Id,cdc.LastName+cdc.FirstName clientName,cdc.Tel,ccc.CertNo CerdNo
  684. From Grp_DelegationJoinCustomer gdjc
  685. Inner join Crm_DeleClient cdc On gdjc.CrmDCId = cdc.Id
  686. Left Join Crm_CustomerCert ccc On ccc.SdId = 773 And cdc.Id = ccc.DcId
  687. Where gdjc.GrpDCId = {0}", dto.GroupId);
  688. var clientList = await _sqlSugar.SqlQueryable<CrmByGroupIdView>(sql).ToListAsync();
  689. if (clientList.Count > 0)
  690. {
  691. result.Code = 0;
  692. result.Msg = "成功!";
  693. result.Data = clientList;
  694. }
  695. else
  696. {
  697. result.Msg = "暂无数据!";
  698. }
  699. }
  700. return result;
  701. }
  702. #endregion
  703. }
  704. }