DelegationInfoRepository.cs 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807
  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<TourClientListInfo>();
  240. foreach (var item in _DeleClients)
  241. {
  242. var param = new TourClientListInfo();
  243. var clientInfo = DeleClientArr.FirstOrDefault(x => x.Id == item.ClientId);
  244. if (clientInfo == null) clientInfo = new Crm_DeleClient();
  245. var clientIDInfo = _CustomerCerts.FirstOrDefault(x=>x.DcId == item.ClientId); //身份证信息
  246. if (clientIDInfo == null) clientIDInfo = new Crm_CustomerCert();
  247. var Company = CompanyArr.FirstOrDefault(x => x.Id == clientInfo.CrmCompanyId);
  248. if(Company == null) Company = new Crm_CustomerCompany();
  249. param.IDCardNo = clientIDInfo.CertNo;
  250. param.Remark = item.Remark;
  251. param.BirthDay = clientInfo.BirthDay;
  252. param.FirstName = clientInfo.FirstName;
  253. param.LastName = clientInfo.LastName;
  254. param.CompanyFullName = Company.CompanyFullName;
  255. param.Job = clientInfo.Job;
  256. param.Sex = clientInfo.Sex;
  257. param.Phone = clientInfo.Phone;
  258. param.Pinyin = clientInfo.Pinyin;
  259. param.HotelSpecialNeeds = item.HotelSpecialNeeds;
  260. param.MealSpecialNeeds = item.MealSpecialNeeds;
  261. param.ShippingSpaceSpecialNeeds = item.ShippingSpaceSpecialNeeds;
  262. param.ShippingSpaceTypeId = item.ShippingSpaceTypeId;
  263. TourClientListInfoArr.Add(param);
  264. }
  265. GroupProcessOperationDtoParam.PortType = dto.PortType;
  266. GroupProcessOperationDtoParam.TourClientListInfos = TourClientListInfoArr;
  267. GroupProcessOperationDtoParam.VisitDate = GroupProcessOperationDtoParam.VisitDate.Length > 10 ? GroupProcessOperationDtoParam.VisitDate.Substring(0, 10) : "";
  268. GroupProcessOperationDtoParam.TontractTime = GroupProcessOperationDtoParam.TontractTime.Length > 10 ? GroupProcessOperationDtoParam.TontractTime.Substring(0, 10) : "";
  269. result.Data = GroupProcessOperationDtoParam;
  270. }
  271. }
  272. else result.Msg = "暂无该团组信息";
  273. }
  274. return result;
  275. }
  276. /// <summary>
  277. /// 获取接团信息 编辑
  278. /// 基础 数据源
  279. /// </summary>
  280. /// <param name="dto"></param>
  281. /// <returns></returns>
  282. public async Task<Result> GroupEditBasicSource(GroupListDto dto)
  283. {
  284. Result result = new Result() { Code = -2, Msg = "未知错误" };
  285. try
  286. {
  287. if (dto.PortType == 1 || dto.PortType == 2) //web
  288. {
  289. dynamic? teamTypeData1 = null;
  290. string teamTypeSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = {0} And IsDel = {1}", 10, 0);
  291. var teamTypeData = await _sqlSugar.SqlQueryable<SetDataInfoView>(teamTypeSql).ToListAsync(); ; //团组分类 10
  292. if (teamTypeData.Count > 0)
  293. {
  294. teamTypeData1 = teamTypeData;
  295. }
  296. dynamic? teamLevData1 = null;
  297. string teamLevSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = {0} And IsDel = {1}", 56, 0);
  298. var teamLevData = await _sqlSugar.SqlQueryable<SetDataInfoView>(teamLevSql).ToListAsync(); ; //团组等级 56
  299. if (teamLevData.Count > 0)
  300. {
  301. teamLevData1 = teamLevData;
  302. }
  303. dynamic? userData1 = null;
  304. string userSql = string.Format(@"Select Id,CnName From Sys_Users Where IsDel = {0}", 0);
  305. var userData = await _sqlSugar.SqlQueryable<UserNameView>(userSql).ToListAsync(); ;
  306. if (userData.Count > 0)
  307. {
  308. userData1 = userData;
  309. }
  310. result.Code = 0;
  311. result.Msg = "成功!";
  312. result.Data = new
  313. {
  314. teamTypeData = teamTypeData1,
  315. teamLevData = teamLevData1,
  316. userData = userData1
  317. };
  318. }
  319. }
  320. catch (Exception)
  321. {
  322. throw;
  323. }
  324. return result;
  325. }
  326. /// <summary>
  327. /// 团组信息操作
  328. /// </summary>
  329. /// <param name="dto"></param>
  330. /// <returns></returns>
  331. public async Task<Result> GroupOperation(GroupOperationDto dto)
  332. {
  333. Result result = new Result() { Code = -2, Msg = "未知错误" };
  334. if (dto.PortType == 1 || dto.PortType == 2) //web
  335. {
  336. if (dto.Status == 1) //添加
  337. {
  338. string selectSql = string.Format(@"Select * From Grp_DelegationInfo
  339. Where IsDel = 0
  340. And TeamName = '{0}'
  341. And ClientName = '{1}'
  342. And ClientUnit ='{2}'
  343. And VisitDate ='{3}'",dto.TeamName, dto.ClientName, dto.ClientUnit, dto.VisitDate);
  344. var selectGroupInfo = await _sqlSugar.SqlQueryable<Grp_DelegationInfo>(selectSql).FirstAsync();
  345. if (selectGroupInfo != null)
  346. {
  347. result.Msg = "数据已存在,请勿重复添加!";
  348. return result;
  349. }
  350. //string teamCodeSql = string.Format("Select SalesQuoteNo From Grp_DelegationInfo");
  351. //var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  352. //string SalesQuoteNo = "";
  353. //while (true)
  354. //{
  355. // SalesQuoteNo = Tools.CommonFun.GetRandomStr(6);
  356. // if (!teamCodeItem.Equals(SalesQuoteNo))
  357. // {
  358. // break;
  359. // }
  360. //}
  361. string countrys = string.Empty;
  362. string countryReq = dto.VisitCountry;
  363. if (!string.IsNullOrEmpty(countryReq))
  364. {
  365. if (countryReq.Contains(",")) countrys = countryReq.Replace(',','|');
  366. else if (countryReq.Contains(",")) countrys = countryReq.Replace(',', '|');
  367. else if (countryReq.Contains(" ")) countrys = countryReq.Replace(' ', '|');
  368. else if (countryReq.Contains("、")) countrys = countryReq.Replace('、', '|');
  369. else if (countryReq.Contains(".")) countrys = countryReq.Replace('.', '|');
  370. else countrys = countryReq;
  371. }
  372. Grp_DelegationInfo delegationInfo = new Grp_DelegationInfo()
  373. {
  374. SalesQuoteNo = dto.SalesQuoteNo,
  375. TeamLevSId = dto.TeamLevSId,
  376. ClientName = dto.ClientName,
  377. ClientUnit = dto.ClientUnit,
  378. TeamName = dto.TeamName,
  379. TeamDid = dto.TeamDid,
  380. VisitDate = Convert.ToDateTime(dto.VisitDate),
  381. VisitCountry = countrys,
  382. VisitPurpose = dto.VisitPurpose,
  383. VisitDays = dto.VisitDays,
  384. VisitPNumber = dto.VisitPNumber,
  385. SpecialNeeds = dto.SpecialNeeds,
  386. OtherNeeds = dto.OtherNeeds,
  387. Remark = dto.Remark,
  388. JietuanOperator = dto.UserId,
  389. TellPhone = dto.TellPhone,
  390. CGRWSPBMMC = dto.CGRWSPBMMC,
  391. CGRWSPWH = dto.CGRWSPWH,
  392. ZZSCBMMC = dto.ZZSCBMMC,
  393. ZZSCSPWH = dto.ZZSCSPWH,
  394. TontractTime = Convert.ToDateTime(dto.TontractTime),
  395. PaymentMoney = dto.PaymentMoney,
  396. PayDay = dto.PayDay,
  397. TourCode = "",
  398. SalesDate = DateTime.Now,
  399. IsState = 0, //默认团组未完成 0
  400. JietuanTime = DateTime.Now,
  401. IsDel = 0,
  402. BudgetCost = 0.00M,
  403. HotelComplain = 0,
  404. OPComplain = 0,
  405. OAComplain = 0,
  406. AirComplain = 0,
  407. VisaComplain = 0,
  408. CreateUserId = dto.UserId,
  409. CreateTime = DateTime.Now,
  410. DeleteUserId = null,
  411. DeleteTime = new DateTime(1990, 1, 1).ToString("yyyy-MM-dd HH:mm:ss"),
  412. OpRoyaltyLv = dto.OpRoyaltyLv,
  413. OpRoyaltyRemark=dto.opRoyaltyRemark,
  414. Officialneeds = dto.Officialneeds
  415. };
  416. var addId = await _sqlSugar.Insertable(delegationInfo).ExecuteReturnIdentityAsync();
  417. if (addId > 0)
  418. {
  419. result.Code = 0;
  420. result.Msg = "添加成功!";
  421. result.Data = addId;
  422. }
  423. else
  424. {
  425. result.Msg = "添加失败!";
  426. }
  427. }
  428. else if (dto.Status == 2) //修改
  429. {
  430. var updateStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  431. {
  432. SalesQuoteNo = dto.SalesQuoteNo,
  433. TeamLevSId = dto.TeamLevSId,
  434. ClientName = dto.ClientName,
  435. ClientUnit = dto.ClientUnit,
  436. TeamName = dto.TeamName,
  437. TeamDid = dto.TeamDid,
  438. VisitDate = Convert.ToDateTime(dto.VisitDate),
  439. VisitCountry = dto.VisitCountry,
  440. VisitPurpose = dto.VisitPurpose,
  441. VisitDays = dto.VisitDays,
  442. VisitPNumber = dto.VisitPNumber,
  443. SpecialNeeds = dto.SpecialNeeds,
  444. OtherNeeds = dto.OtherNeeds,
  445. Remark = dto.Remark,
  446. JietuanOperator = dto.UserId,
  447. TellPhone = dto.TellPhone,
  448. CGRWSPBMMC = dto.CGRWSPBMMC,
  449. CGRWSPWH = dto.CGRWSPWH,
  450. ZZSCBMMC = dto.ZZSCBMMC,
  451. ZZSCSPWH = dto.ZZSCSPWH,
  452. TontractTime = Convert.ToDateTime(dto.TontractTime),
  453. PaymentMoney = dto.PaymentMoney,
  454. PayDay = dto.PayDay,
  455. OpRoyaltyLv = dto.OpRoyaltyLv,
  456. OpRoyaltyRemark = dto.opRoyaltyRemark,
  457. Officialneeds = dto.Officialneeds
  458. });
  459. if (updateStatus)
  460. {
  461. result.Code = 0;
  462. result.Msg = "修改成功!";
  463. }
  464. else
  465. {
  466. result.Msg = "修改失败!";
  467. }
  468. }
  469. else if (dto.Status == 3) //删除
  470. {
  471. var deleteStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  472. {
  473. DeleteUserId = dto.UserId,
  474. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  475. IsDel = 1
  476. });
  477. if (deleteStatus)
  478. {
  479. result.Code = 0;
  480. result.Msg = "删除成功!";
  481. }
  482. else
  483. {
  484. result.Msg = "删除失败!";
  485. }
  486. }
  487. }
  488. return result;
  489. }
  490. /// <summary>
  491. /// 团组信息操作 - 删除
  492. /// </summary>
  493. /// <param name="dto"></param>
  494. /// <returns></returns>
  495. public async Task<Result> GroupDel(GroupDelDto dto)
  496. {
  497. Result result = new Result() { Code = -2, Msg = "未知错误" };
  498. if (dto.PortType == 1 || dto.PortType == 2) //web
  499. {
  500. var deleteStatus = await UpdateAsync(a => a.Id == dto.Id, a => new Grp_DelegationInfo
  501. {
  502. DeleteUserId = dto.UserId,
  503. DeleteTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"),
  504. IsDel = 1
  505. });
  506. if (deleteStatus)
  507. {
  508. result.Code = 0;
  509. result.Msg = "删除成功!";
  510. }
  511. else
  512. {
  513. result.Msg = "删除失败!";
  514. }
  515. }
  516. return result;
  517. }
  518. /// <summary>
  519. /// 获取销售报价号
  520. /// </summary>
  521. /// <returns></returns>
  522. public async Task<Result> GetGroupSalesQuoteNo()
  523. {
  524. Result result = new Result() { Code = -2, Msg = "未知错误" };
  525. string teamCodeSql = string.Format("Select SalesQuoteNo From Grp_DelegationInfo");
  526. var teamCodeItem = await _sqlSugar.SqlQueryable<SalesQuoteNoView>(teamCodeSql).ToListAsync();
  527. string teamCode = "";
  528. while (true)
  529. {
  530. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  531. if (!teamCodeItem.Equals(teamCode))
  532. {
  533. break;
  534. }
  535. }
  536. result.Code = 0;
  537. result.Msg = "成功!";
  538. result.Data = teamCode;
  539. return result;
  540. }
  541. /// <summary>
  542. /// 团组删除
  543. /// </summary>
  544. /// <returns></returns>
  545. public async Task<Result> GroupDeleteById()
  546. {
  547. Result result = new Result() { Code = -2, Msg = "未知错误" };
  548. string teamCodeSql = string.Format("Select TourCode From Grp_DelegationInfo");
  549. var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  550. string teamCode = "";
  551. while (true)
  552. {
  553. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  554. if (!teamCodeItem.Equals(teamCode))
  555. {
  556. break;
  557. }
  558. }
  559. result.Code = 0;
  560. result.Msg = "成功!";
  561. result.Data = teamCode;
  562. return result;
  563. }
  564. /// <summary>
  565. /// 团组确认出团
  566. /// </summary>
  567. /// <returns></returns>
  568. public async Task<Result> ConfirmationGroup(ConfirmationGroupDto dto)
  569. {
  570. Result result = new Result() { Code = -2, Msg = "未知错误" };
  571. string teamCode = "";
  572. if (dto.PortType == 1 || dto.PortType == 2) //web
  573. {
  574. string teamCodeSql = string.Format("Select TourCode From Grp_DelegationInfo");
  575. var teamCodeItem = await _sqlSugar.SqlQueryable<TeamCodeView>(teamCodeSql).ToListAsync();
  576. while (true)
  577. {
  578. teamCode = Tools.CommonFun.GetRandomAllStr(6);
  579. if (!teamCodeItem.Equals(teamCode))
  580. {
  581. break;
  582. }
  583. }
  584. var deleteStatus = await UpdateAsync(a => a.Id == dto.GroupId, a => new Grp_DelegationInfo
  585. {
  586. TourCode = teamCode,
  587. GroupsOperator = dto.GroupsOperator,
  588. GroupsTime = DateTime.Now
  589. });
  590. if (deleteStatus)
  591. {
  592. result.Code = 0;
  593. result.Msg = "确认出团设置成功!";
  594. }
  595. else
  596. {
  597. result.Msg = "确认出团设置失败!";
  598. }
  599. }
  600. result.Code = 0;
  601. result.Msg = "成功!";
  602. result.Data = teamCode;
  603. return result;
  604. }
  605. /// <summary>
  606. /// 获取接团名称List
  607. /// </summary>
  608. /// <param name="dto"></param>
  609. /// <returns></returns>
  610. public async Task<Result> GetGroupNameList(GroupNameDto dto)
  611. {
  612. Result result = new Result() { Code = -2, Msg = "未知错误" };
  613. if (dto.PortType == 1 || dto.PortType == 2) //web
  614. {
  615. string sql = string.Format(@"Select Id,TeamName GroupName From Grp_DelegationInfo
  616. Where TeamName != '' And IsDel = 0
  617. Order By Id Desc");
  618. var _groupNameList = await _sqlSugar.SqlQueryable<GroupNameView>(sql).ToListAsync();
  619. if (_groupNameList.Count > 0)
  620. {
  621. result.Code = 0;
  622. result.Msg = "成功!";
  623. result.Data = _groupNameList;
  624. }
  625. else
  626. {
  627. result.Msg = "暂无团组信息";
  628. }
  629. }
  630. return result;
  631. }
  632. /// <summary>
  633. /// 获取接团名称List And 签证国别
  634. /// </summary>
  635. /// <param name="dto"></param>
  636. /// <returns></returns>
  637. public async Task<Result> GetGroupNameAndVisaNationality(GroupNameDto dto)
  638. {
  639. Result result = new Result() { Code = -2, Msg = "未知错误" };
  640. if (dto.PortType == 1 || dto.PortType == 2) //web
  641. {
  642. string sql = string.Format(@"Select Id,TeamName GroupName From Grp_DelegationInfo
  643. Where TeamName != '' And IsDel = 0
  644. Order By Id Desc");
  645. var _groupNameList = await _sqlSugar.SqlQueryable<GroupNameView>(sql).ToListAsync();
  646. string visaSql = string.Format(@"Select Id,Name From Sys_SetData Where STid = 41 And IsDel = 0");
  647. var _setDataList = await _sqlSugar.SqlQueryable<SetDataInfoView>(visaSql).ToListAsync();
  648. var data = new {
  649. groupNameData = _groupNameList,
  650. visaNationalityData = _setDataList
  651. };
  652. result.Data = data;
  653. result.Code = 0;
  654. }
  655. return result;
  656. }
  657. #endregion
  658. #region 团组&签证
  659. /// <summary>
  660. /// 根据团组Id查询客户
  661. /// </summary>
  662. /// <param name="dto"></param>
  663. /// <returns></returns>
  664. public async Task<Result> GetCrmByGroupId(ClientByGroupIdDto dto)
  665. {
  666. Result result = new Result() { Code = -2 };
  667. if (dto.PortType == 1 || dto.PortType == 2)
  668. {
  669. string sql = string.Format(@"Select gdjc.GrpDCId grpId,cdc.Id,cdc.LastName+cdc.FirstName clientName,cdc.Tel,ccc.CertNo CerdNo
  670. From Grp_DelegationJoinCustomer gdjc
  671. Inner join Crm_DeleClient cdc On gdjc.CrmDCId = cdc.Id
  672. Left Join Crm_CustomerCert ccc On ccc.SdId = 773 And cdc.Id = ccc.DcId
  673. Where gdjc.GrpDCId = {0}", dto.GroupId);
  674. var clientList = await _sqlSugar.SqlQueryable<CrmByGroupIdView>(sql).ToListAsync();
  675. if (clientList.Count > 0)
  676. {
  677. result.Code = 0;
  678. result.Msg = "成功!";
  679. result.Data = clientList;
  680. }
  681. else
  682. {
  683. result.Msg = "暂无数据!";
  684. }
  685. }
  686. return result;
  687. }
  688. #endregion
  689. }
  690. }