DelegationInfoRepository.cs 33 KB

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