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