using Aspose.Cells;
using Aspose.Cells.Drawing;
using Aspose.Words;
using Aspose.Words.Tables;
using Azure;
using EyeSoft.Extensions;
using Microsoft.AspNetCore.Http.Features;
using Microsoft.Graph.Models;
using Microsoft.Kiota.Abstractions;
using Newtonsoft.Json.Serialization;
using NodaTime;
using NPOI.SS.Formula.Functions;
using NPOI.SS.UserModel;
using OASystem.API.OAMethodLib;
using OASystem.API.OAMethodLib.Hotmail;
using OASystem.API.OAMethodLib.HunYuanAPI;
using OASystem.API.OAMethodLib.QiYeWeChatAPI;
using OASystem.API.OAMethodLib.QiYeWeChatAPI.AppNotice;
using OASystem.Domain.AesEncryption;
using OASystem.Domain.Dtos.Groups;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.ViewModels.Groups;
using OASystem.Domain.ViewModels.QiYeWeChat;
using OASystem.Domain.ViewModels.Statistics;
using OASystem.Infrastructure.Repositories.Groups;
using Quartz.Logging;
using Quartz.Util;
using System.ComponentModel.DataAnnotations;
using System.Data;
using System.Diagnostics;
using System.Security.AccessControl;
using TencentCloud.Common;
using static NodaTime.TimeZones.TzdbZone1970Location;
using static OASystem.API.OAMethodLib.GeneralMethod;
using static OASystem.API.OAMethodLib.Hotmail.HotmailService;
using static OASystem.API.OAMethodLib.JWTHelper;
using static OpenAI.GPT3.ObjectModels.Models;
using Workbook = Aspose.Cells.Workbook;
namespace OASystem.API.Controllers
{
///
/// 资料相关
///
//[Authorize]
[Route("api/[controller]/[action]")]
public class ResourceController : ControllerBase
{
private readonly IMapper _mapper;
private readonly ILogger _logger;
private readonly IConfiguration _config;
private readonly IHunyuanService _hunyuanService;
private readonly IQiYeWeChatApiService _qiYeWeChatApiService;
private readonly SqlSugarClient _sqlSugar;
private readonly CarDataRepository _carDataRep;
private readonly LocalGuideDataRepository _localGuideDataRep;
private readonly ThreeCodeRepository _ThreeCodeRep;
private readonly HotelDataRepository _hotelDataRep;
private readonly ResItemInfoRepository _resItemInfoRep;
private readonly SetDataRepository _setDataRepository;
private readonly CountryFeeRepository _countryFeeRep;
private readonly SetDataTypeRepository _setDataTypeRep;
private readonly AirTicketAgentRepository _airTicketAgentRep;
private readonly InvitationOfficialActivityDataRepository _InvitationOfficialActivityDataRep;
private readonly OfficialActivitiesRepository _officialActivitiesRep;
private readonly AskDataRepository _askDataRep;
private readonly TicketBlackCodeRepository _ticketBlackCodeRep;
private readonly TourClientListRepository _tourClientListRep;
private readonly DelegationInfoRepository _delegationInfoRep;
private readonly TranslatorLibraryRepository _translatorRep;
private readonly MediaSuppliersRepository _mediaSupplierRep;
private readonly List _portIds;
private readonly BasicInsuranceCostRepository _insuranceCostRep;
private readonly GamesBudgetMasterRepository _gamesBudgetMasterRep;
private readonly OverseaVehicleRepository _overseaVehicleRep;
private readonly MaterialCostRepository _materialCostRep;
private readonly HotmailService _hotmailService;
///
/// 签证费用归属省份静态数据
///
private static readonly List> _provinceData = new()
{
new(122, "四川"),
new(132, "云南"),
new(103, "重庆"),
new(108, "贵州")
};
public ResourceController(
IMapper mapper,
IConfiguration config,
ILogger logger,
IHunyuanService hunyuanService,
IQiYeWeChatApiService qiYeWeChatApiService,
HotmailService hotmailService,
SqlSugarClient sqlSugar,
CarDataRepository carDataRep,
LocalGuideDataRepository localGuideDataRep,
ThreeCodeRepository threeCodeRep,
HotelDataRepository hotelDataRep,
ResItemInfoRepository resItemInfoRep,
SetDataRepository setDataRepository,
CountryFeeRepository countryFeeRep,
SetDataTypeRepository setDataTypeRep,
AirTicketAgentRepository airTicketAgentRep,
InvitationOfficialActivityDataRepository invitationOfficialActivityDataRep,
OfficialActivitiesRepository officialActivitiesRep,
AskDataRepository askDataRep,
TicketBlackCodeRepository ticketBlackCodeRep,
TourClientListRepository tourClientListRep,
DelegationInfoRepository delegationInfoRep,
TranslatorLibraryRepository translatorRep,
MediaSuppliersRepository mediaSupplierRep,
BasicInsuranceCostRepository insuranceCostRep,
GamesBudgetMasterRepository gamesBudgetMasterRep,
OverseaVehicleRepository overseaVehicleRep,
MaterialCostRepository materialCostRep
)
{
_mapper = mapper;
_config = config;
_logger = logger;
_hunyuanService = hunyuanService;
_qiYeWeChatApiService = qiYeWeChatApiService;
_hotmailService = hotmailService;
_sqlSugar = sqlSugar;
_carDataRep = carDataRep;
_localGuideDataRep = localGuideDataRep;
_ThreeCodeRep = threeCodeRep;
_hotelDataRep = hotelDataRep;
_resItemInfoRep = resItemInfoRep;
_setDataRepository = setDataRepository;
_countryFeeRep = countryFeeRep;
_setDataTypeRep = setDataTypeRep;
_airTicketAgentRep = airTicketAgentRep;
_InvitationOfficialActivityDataRep = invitationOfficialActivityDataRep;
_officialActivitiesRep = officialActivitiesRep;
_askDataRep = askDataRep;
_ticketBlackCodeRep = ticketBlackCodeRep;
_tourClientListRep = tourClientListRep;
_delegationInfoRep = delegationInfoRep;
_translatorRep = translatorRep;
_mediaSupplierRep = mediaSupplierRep;
_portIds = new List { 1, 2, 3 };
_insuranceCostRep = insuranceCostRep;
_gamesBudgetMasterRep = gamesBudgetMasterRep;
_overseaVehicleRep = overseaVehicleRep;
_materialCostRep = materialCostRep;
}
#region 车公司资料板块
///
/// 车公司信息查询
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryCarData(QueryCarDataDto dto)
{
Result LocalGuide = await _carDataRep.QueryCarData(dto);
if (LocalGuide.Code == 0)
{
return Ok(JsonView(true, "查询成功", LocalGuide.Data));
}
else
{
return Ok(JsonView(false, LocalGuide.Msg));
}
}
///
/// 车公司资料下拉框数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryCarSelect()
{
var carData = _carDataRep.QueryDto().ToList();
if (carData.Count == 0)
{
return Ok(JsonView(false, "暂无数据!"));
}
foreach (var item in carData) EncryptionProcessor.DecryptProperties(item);
carData.Add(new CarDataSelectView { Id = 0, UnitArea = "全部" });
carData = carData.Where((x, i) => carData.FindIndex(z => z.UnitArea == x.UnitArea) == i).ToList();
carData = carData.OrderBy(x => x.Id).ToList();
var data = new List();
foreach (CarDataSelectView car in carData)
{
if (!string.IsNullOrWhiteSpace(car.UnitArea))
{
data.Add(car);
}
}
return Ok(JsonView(true, "查询成功", data));
}
///
/// 根据Id查询车公司详细数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QuerCarDataDetailById(QueryCarDataDetailDto dto)
{
string sql = string.Format(@" Select * From Res_CarData With(Nolock) Where Id = {0} ", dto.Id);
var info = _resItemInfoRep._sqlSugar.SqlQueryable(sql).First();
if (info == null)
{
return Ok(JsonView(false, "未找到相关数据!"));
}
EncryptionProcessor.DecryptProperties(info);
return Ok(JsonView(true, "查询成功", info));
}
///
/// 车公司信息添加
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task AddCarData(AddCarDataDto dto)
{
if (string.IsNullOrEmpty(dto.UnitArea)) return Ok(JsonView(false, "请检查单位区域是否填写!"));
if (string.IsNullOrEmpty(dto.UnitName)) return Ok(JsonView(false, "请检查单位名称是否填写!"));
if (string.IsNullOrEmpty(dto.Contact)) return Ok(JsonView(false, "请检查单位联系人是否填写!"));
if (string.IsNullOrEmpty(dto.ContactTel)) return Ok(JsonView(false, "请检查联系方式是否填写正确!"));
var carDadaInfo = _carDataRep
.QueryDto(a => a.UnitArea == dto.UnitArea &&
a.UnitName == dto.UnitName &&
a.Contact == dto.Contact &&
a.ContactTel == dto.ContactTel
)
.First();
if (carDadaInfo != null) return Ok(JsonView(false, "该信息已存在,请勿重复添加!"));
var carData = _mapper.Map(dto);
carData.LastUpdateUserId = dto.CreateUserId;
carData.LastUpdateTime = DateTime.Now;
EncryptionProcessor.EncryptProperties(carData);
int id = await _carDataRep.AddAsyncReturnId(carData);
if (id < 1) return Ok(JsonView(false, "添加失败!"));
return Ok(JsonView(true, "添加成功", new { Id = id }));
}
///
/// 车公司信息修改
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task UpCarData(UpCarDataDto dto)
{
if (string.IsNullOrEmpty(dto.UnitArea)) return Ok(JsonView(false, "请检查单位区域是否填写!"));
if (string.IsNullOrEmpty(dto.UnitName)) return Ok(JsonView(false, "请检查单位名称是否填写!"));
if (string.IsNullOrEmpty(dto.Contact)) return Ok(JsonView(false, "请检查单位联系人是否填写!"));
if (string.IsNullOrEmpty(dto.ContactTel)) return Ok(JsonView(false, "请检查联系方式是否填写正确!"));
var carData = _mapper.Map(dto);
carData.LastUpdateTime = DateTime.Now;
EncryptionProcessor.EncryptProperties(carData);
var res = await _sqlSugar.Updateable(carData)
.IgnoreColumns(x => new { x.CreateUserId, x.CreateTime, x.DeleteTime, x.DeleteUserId, x.IsDel })
.ExecuteCommandAsync();
if (res < 1) { return Ok(JsonView(false, "修改失败!")); }
return Ok(JsonView(true, "修改成功"));
}
///
/// 车公司信息删除
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelCarData(DelCarDataDto dto)
{
bool res = await _carDataRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res) { return Ok(JsonView(false, "删除失败!")); }
return Ok(JsonView(true, "删除成功"));
}
#endregion
#region 导游地接资料板块
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task LocalGuideBatchEncryption()
{
var infos = await _sqlSugar.Queryable().ToListAsync();
foreach (var item in infos) EncryptionProcessor.EncryptProperties(item);
await _sqlSugar.Updateable(infos).ExecuteCommandAsync();
return Ok(JsonView(true));
}
///
/// 导游地接资料查询
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryLocalGuide(QueryLocalGuide dto)
{
Stopwatch stopwatch = Stopwatch.StartNew();
Result LocalGuide = await _localGuideDataRep.QueryLocalGuide(dto);
if (LocalGuide.Code == 0)
{
stopwatch.Stop();
return Ok(JsonView(true, $"查询成功!耗时:{stopwatch.ElapsedMilliseconds} 毫秒", LocalGuide.Data));
}
stopwatch.Stop();
return Ok(JsonView(false, LocalGuide.Msg + $" 耗时:{stopwatch.ElapsedMilliseconds} 毫秒"));
}
///
/// 导游地接资料下拉框数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryLocalGuideSelect()
{
var localGuides = _carDataRep.QueryDto().ToList();
if (localGuides.Count == 0)
{
return Ok(JsonView(false, "暂无数据!"));
}
foreach (var item in localGuides) EncryptionProcessor.DecryptProperties(item);
localGuides.Add(new QueryLocalGuideSelectView { Id = 0, UnitArea = "全部" });
localGuides = localGuides.Where((x, i) => localGuides.FindIndex(z => z.UnitArea == x.UnitArea && !string.IsNullOrEmpty(z.UnitArea)) == i).ToList();
localGuides = localGuides.OrderBy(x => x.Id).ToList();
var data = new List();
foreach (QueryLocalGuideSelectView Local in localGuides)
{
if (!string.IsNullOrWhiteSpace(Local.UnitArea))
{
data.Add(Local);
}
}
return Ok(JsonView(true, "查询成功", data));
}
///
/// 根据Id查询地接详细数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryLocalGuideDetailById(QueryLocalGuideDetailDto dto)
{
string sql = string.Format(@" Select * From Res_LocalGuideData With(Nolock) Where Id = {0} ", dto.Id);
var info = _resItemInfoRep._sqlSugar.SqlQueryable(sql).First();
if (info == null)
{
return Ok(JsonView(false, "未找到相关数据!"));
}
EncryptionProcessor.DecryptProperties(info);
return Ok(JsonView(true, "查询成功", info));
}
///
/// 导游地接信息操作(Status:1.新增,2.修改)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OperationLocalGuide(LocalGuideOperationDto dto)
{
if (string.IsNullOrEmpty(dto.UnitArea)) return Ok(JsonView(false, "请检查单位区域是否填写!"));
if (string.IsNullOrEmpty(dto.UnitName)) return Ok(JsonView(false, "请检查单位名称是否填写!"));
if (string.IsNullOrEmpty(dto.Contact)) return Ok(JsonView(false, "请检查单位联系人是否填写!"));
if (string.IsNullOrEmpty(dto.ContactTel)) return Ok(JsonView(false, "请检查联系方式是否填写正确!"));
Result result = await _localGuideDataRep.LocalGuideOperation(dto);
if (result.Code != 0)
{
return Ok(JsonView(false, result.Msg));
}
return Ok(JsonView(true, result.Msg));
}
///
/// 导游地接信息操作(删除)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelLocalGuide(LocalGuideDelDto dto)
{
var res = await _localGuideDataRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res)
{
return Ok(JsonView(false, "删除失败"));
}
return Ok(JsonView(true, "删除成功!"));
}
#endregion
#region 机场三字码信息
///
/// 机场三字码查询
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryThreeCode(QueryThreeCodeDto dto)
{
try
{
Result LocalGuide = await _ThreeCodeRep.QueryThreeCode(dto);
if (LocalGuide.Code == 0)
{
return Ok(JsonView(true, "查询成功", LocalGuide.Data));
}
else
{
return Ok(JsonView(false, LocalGuide.Msg));
}
}
catch (Exception ex)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
///
/// 机场三字码数据城市下拉框数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryThreeCodeSelect()
{
try
{
var ThreeCode = _carDataRep.QueryDto().ToList();
if (ThreeCode.Count == 0)
{
return Ok(JsonView(false, "暂无数据!"));
}
ThreeCode.Add(new ThreeCodeSelectView { Id = 0, City = "全部" });
ThreeCode = ThreeCode.Where((x, i) => ThreeCode.FindIndex(z => z.City == x.City && z.City != "") == i).ToList();
ThreeCode = ThreeCode.OrderBy(x => x.Id).ToList();
List data = new List();
foreach (ThreeCodeSelectView _ThreeCode in ThreeCode)
{
if (!string.IsNullOrWhiteSpace(_ThreeCode.City))
{
data.Add(_ThreeCode);
}
}
return Ok(JsonView(true, "查询成功", data));
}
catch (Exception)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
///
/// 机场三字码资料操作(Status:1.新增,2.修改)
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OperationThreeCode(ThreeCodeOperationDto dto)
{
try
{
if (dto.Three == "")
{
return Ok(JsonView(false, "请检查三字码是否填写!"));
}
if (dto.Country == "")
{
return Ok(JsonView(false, "请检查国家是否填写!"));
}
if (dto.City == "")
{
return Ok(JsonView(false, "请检查城市是否填写正确!"));
}
if (dto.AirPort == "")
{
return Ok(JsonView(false, "请检查机场是否填写正确!"));
}
Result result = await _ThreeCodeRep.ThreeCodeOperation(dto);
if (result.Code != 0)
{
return Ok(JsonView(false, result.Msg));
}
return Ok(JsonView(true, result.Msg));
}
catch (Exception ex)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
///
/// 机场三字码资料操作(删除)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelThreeCode(ThreeCodeDelDto dto)
{
try
{
var res = await _ThreeCodeRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res)
{
return Ok(JsonView(false, "删除失败"));
}
return Ok(JsonView(true, "删除成功!"));
}
catch (Exception ex)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
///
///根据ID查询三字码信息
///
///
[HttpPost]
public IActionResult QuerySingleThreeCode(QuerySingleThreeCode dto)
{
var jw = JsonView(false);
var single = _sqlSugar.Queryable().First(x => x.Id == dto.ID && x.IsDel == 0);
if (single != null)
{
jw = JsonView(true, "获取成功!", new
{
single.Three,
Four = single.Four?.Trim(),
single.AirPort,
single.AirPort_En,
single.City,
single.Country,
single.Remark
});
}
else
{
jw.Msg = "暂无!";
}
return Ok(jw);
}
#endregion
#region 代理出票合作方资料
///
/// 代理出票合作方资料
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryAirTicketAgent(DtoBase dto)
{
var res_AirTicketAgents = _airTicketAgentRep.Query(a => a.IsDel == 0).ToList();
if (res_AirTicketAgents.Count > 1)
{
res_AirTicketAgents = res_AirTicketAgents.OrderByDescending(a => a.CreateTime).ToList();
if (dto.PageSize == 0 && dto.PageIndex == 0)
{
foreach (var item in res_AirTicketAgents) EncryptionProcessor.DecryptProperties(item);
return Ok(JsonView(true, "查询成功!", res_AirTicketAgents));
}
else
{
int count = res_AirTicketAgents.Count;
float totalPage = (float)count / dto.PageSize;//总页数
if (totalPage == 0) totalPage = 1;
else totalPage = (int)Math.Ceiling((double)totalPage);
var _AirTicketAgent = new List();
for (int i = 0; i < dto.PageSize; i++)
{
var RowIndex = i + (dto.PageIndex - 1) * dto.PageSize;
if (RowIndex < res_AirTicketAgents.Count)
{
EncryptionProcessor.DecryptProperties(res_AirTicketAgents[RowIndex]);
_AirTicketAgent.Add(res_AirTicketAgents[RowIndex]);
}
else break;
}
return Ok(JsonView(true, "查询成功!", new { pageCount = count, totalPage = (int)totalPage, pageIndex = dto.PageIndex, pageSize = dto.PageSize, pageSource = _AirTicketAgent }));
}
}
return Ok(JsonView(false, "暂无数据!"));
}
///
/// 代理出票合作方资料操作(Status:1.新增,2.修改)
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OpAirTicketAgent(OpAirTicketAgentDto dto)
{
if (string.IsNullOrEmpty(dto.Account)) return Ok(JsonView(false, "请检查代理商账户是否填写!"));
if (string.IsNullOrEmpty(dto.Bank)) return Ok(JsonView(false, "请检查代理商银行是否填写!"));
if (string.IsNullOrEmpty(dto.Name)) return Ok(JsonView(false, "请检查代理商名称是否填写正确!"));
Result result = await _airTicketAgentRep.OpAirTicketAgent(dto);
if (result.Code != 0) return Ok(JsonView(false, result.Msg));
return Ok(JsonView(true, result.Msg));
}
///
/// 代理出票合作方资料操作(删除)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelAirTicketAgent(DelBaseDto dto)
{
var res = await _airTicketAgentRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res) return Ok(JsonView(false, "删除失败"));
return Ok(JsonView(true, "删除成功!"));
}
#endregion
#region 酒店资料数据
///
/// 酒店信息查询 Page
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryHotelData(QueryHotelDataDto dto)
{
string sqlWhere = string.Empty;
if (!string.IsNullOrWhiteSpace(dto.Name))
{
sqlWhere += string.Format(@" And hd.Name like '%{0}%'", AesEncryptionHelper.Encrypt(dto.Name));
}
if (!string.IsNullOrWhiteSpace(dto.City) && dto.City != "全部")
{
sqlWhere += string.Format(@" And hd.City like '%{0}%'", AesEncryptionHelper.Encrypt(dto.City));
}
if (!string.IsNullOrWhiteSpace(dto.Contact))
{
sqlWhere += string.Format(@" And hd.Contact like '%{0}%'", AesEncryptionHelper.Encrypt(dto.Contact));
}
if (!string.IsNullOrWhiteSpace(dto.ContactPhone))
{
sqlWhere += string.Format(@" And hd.ContactPhone like '%{0}%'", AesEncryptionHelper.Encrypt(dto.ContactPhone));
}
sqlWhere += string.Format(@" And hd.IsDel={0}", 0);
if (!string.IsNullOrEmpty(sqlWhere.Trim()))
{
Regex r = new Regex("And");
sqlWhere = r.Replace(sqlWhere, "Where", 1);
}
string sql = string.Format(@"SELECT
*
FROM
(
SELECT
ROW_NUMBER() OVER (
ORDER BY
hd.CreateTime DESC
) AS Row_Number,
hd.Id,
hd.City,
hd.[Name],
hd.Tel,
hd.Fax,
hd.Contact,
hd.ContactPhone,
u.CnName AS CreateUserName,
hd.CreateTime
FROM
Res_HotelData hd
WITH
(NoLock)
LEFT JOIN Sys_Users u
WITH
(NoLock) ON hd.CreateUserId = u.Id {0}
) Temp
", sqlWhere);
if (dto.PortType == 1)
{
var HotelDataData = await _sqlSugar.SqlQueryable(sql).ToListAsync();
if (HotelDataData.Count == 0)
{
return Ok(JsonView(false, "暂无数据"));
}
foreach (var item in HotelDataData)
{
EncryptionProcessor.DecryptProperties(item);
}
return Ok(JsonView(true, "操作成功", HotelDataData));
}
else if (dto.PortType == 2 || dto.PortType == 3)
{
RefAsync total = 0;//REF和OUT不支持异步,想要真的异步这是最优解
var data = await _sqlSugar.SqlQueryable(sql).ToPageListAsync(dto.PageIndex, dto.PageSize, total); //ToPageAsync
foreach (var item in data) EncryptionProcessor.DecryptProperties(item);
return Ok(JsonView(true, "操作成功", data, total));
}
else return Ok(JsonView(false, "请传入PortType参数!1:Web,2:Android,3:IOS"));
}
///
/// 酒店资料
/// 详情
/// add time:2024-05-14 11:57:10
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryHotelDataInfo(QueryHotelDataInfoDto dto)
{
var _view = await _hotelDataRep._Info(dto.PortType, dto.Id);
if (_view.Code == 0)
{
return Ok(JsonView(true, _view.Msg, _view.Data));
}
return Ok(JsonView(false, _view.Msg));
}
///
/// 酒店资料下拉框数据
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryHotelDataSelect()
{
try
{
var HotelData = _carDataRep.QueryDto().ToList();
if (HotelData.Count == 0)
{
return Ok(JsonView(false, "暂无数据!"));
}
//解密
foreach (var item in HotelData)
{
EncryptionProcessor.DecryptProperties(item);
}
HotelData.Add(new QueryHotelDataSelect { Id = 0, City = "全部" });
HotelData = HotelData.Where((x, i) => HotelData.FindIndex(z => z.City == x.City && z.City != "") == i).ToList();
HotelData = HotelData.OrderBy(x => x.Id).ToList();
var data = new List();
foreach (var Hotel in HotelData)
{
if (!string.IsNullOrWhiteSpace(Hotel.City))
{
data.Add(Hotel);
}
}
return Ok(JsonView(true, "查询成功", data));
}
catch (Exception)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
///
/// 酒店资料操作(Status:1.新增,2.修改)
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OperationHotelData(OperationHotelDto dto)
{
if (string.IsNullOrEmpty(dto.City)) return Ok(JsonView(false, "请检查酒店所在城市是否填写!"));
if (string.IsNullOrEmpty(dto.Name)) return Ok(JsonView(false, "请检查酒店名称是否填写!"));
if (string.IsNullOrEmpty(dto.Address)) return Ok(JsonView(false, "请检查酒店地址是否填写正确!"));
if (string.IsNullOrEmpty(dto.Tel)) return Ok(JsonView(false, "请检查酒店联系方式是否填写正确!"));
Result result = await _hotelDataRep.OperationHotelData(dto);
if (result.Code != 0) return Ok(JsonView(false, result.Msg));
return Ok(JsonView(true, result.Msg));
}
///
/// 酒店资料操作(删除)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelHotelData(DelHotelDataDto dto)
{
try
{
var res = await _hotelDataRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res)
{
return Ok(JsonView(false, "删除失败"));
}
return Ok(JsonView(true, "删除成功!"));
}
catch (Exception ex)
{
return Ok(JsonView(false, "程序错误!"));
throw;
}
}
#endregion
#region 签证费用资料
///
/// 签证费用资料查询
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryCountryFeeCost(DtoBase dto)
{
var portType = dto.PortType;
if (portType != 1 && portType != 2 && portType != 3)
return Ok(JsonView(false, "请传入PortType参数!1:Web,2:Android,3:IOS"));
var countryVisaFees = await _countryFeeRep
.QueryDto()
.OrderByDescending(x => x.CreateTime)
.ToListAsync();
if (countryVisaFees == null || countryVisaFees.Count == 0)
return Ok(JsonView(false, "暂无数据!"));
return Ok(JsonView(true, "查询成功", countryVisaFees));
}
///
/// 签证费用资料查询 Page New
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryVisaCountryFeeCosts(QueryVisaCountryFeeCostsDto dto)
{
// 校验端口类型
if (dto.PortType != 1 && dto.PortType != 2 && dto.PortType != 3)
return Ok(JsonView(false, "请传入PortType参数!1:Web,2:Android,3:IOS"));
var portType = dto.PortType;
RefAsync total = 0;
var query = _countryFeeRep._sqlSugar
.Queryable()
.Where(x => x.IsDel == 0)
.WhereIF(dto.VisaFeeType >= 0, x => x.VisaFeeType == dto.VisaFeeType)
.WhereIF(!string.IsNullOrEmpty(dto.CountryName), x => x.VisaCountry.Contains(dto.CountryName))
.OrderByDescending(x => x.CreateTime);
var countryVisaFees = await query.ToPageListAsync(dto.PageIndex, dto.PageSize, total);
if (!countryVisaFees.Any()) return Ok(JsonView(true, "暂无数据!"));
var view = _mapper.Map>(countryVisaFees);
return Ok(JsonView(true, "查询成功", view, total));
}
///
/// 签证费用资料操作(Status:1.新增,2.修改)
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OperationCountryFeeCost(OperationCountryFeeCostDto dto)
{
if (string.IsNullOrWhiteSpace(dto.VisaContinent) || string.IsNullOrWhiteSpace(dto.VisaCountry))
return Ok(JsonView(false, "请检查州名和国家名是否填写!"));
return Ok(await _countryFeeRep.OperationCountryFeeCost(dto));
}
///
/// 签证费用资料操作(删除)
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelCountryFeeCost(DelCountryFeeCostDto dto)
{
var res = await _countryFeeRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res) return Ok(JsonView(false, "删除失败"));
return Ok(JsonView(true, "删除成功!"));
}
#endregion
#region 签证费用资料 New
///
/// 签证费用标准 Init
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeStandardInit()
{
//签证费用类型数据
var visaFeeTypeData = new List>
{
new(0, "因公"),
new(1, "因私")
};
//签证费用归属省份
var data = new
{
VisaFeeType = visaFeeTypeData.Select(x => new { Id = x.Key, Text = x.Value }),
Province = _provinceData.Select(x => new { Id = x.Key, Text = x.Value })
};
return Ok(JsonView(data));
}
///
/// 签证费用标准 Info
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeStandardInfo(VisaFeeStandardInfoDto dto)
{
var portType = dto.PortType;
if (portType != 1 && portType != 2 && portType != 3)
return Ok(JsonView(false, "请传入PortType参数!1:Web,2:Android,3:IOS"));
return Ok(await _countryFeeRep.InfoAsync(dto.Id));
}
///
/// 签证费用标准 List
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeStandardList(VisaFeeStandardListDto dto)
{
return Ok(await _countryFeeRep.PageListAsync(dto));
}
///
/// 签证费用标准 Save
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeStandardSave(VisaFeeStandardSaveDto dto)
{
return Ok(await _countryFeeRep.SaveAsync(dto));
}
///
/// 签证费用标准 SoftDel
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeStandardSoftDel(VisaFeeStandardSoftDelDto dto)
{
return Ok(await _countryFeeRep.SoftDelAsync(dto.CurrUserId, dto.Id));
}
///
/// 根据省份获取签证费用报价
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task VisaFeeQuoteByProvince(VisaFeesByProvinceDto dto)
{
//省份验证
var provinceIds = _provinceData.Select(x => x.Key).ToList();
if (!provinceIds.Contains(dto.ProvinceId))
{
return Ok(JsonView(false, "请选择有效的省份!"));
}
return Ok(await _countryFeeRep.VisaFeeQuoteAsync(dto.ProvinceId, dto.CountryName));
}
#endregion
#region 物料信息、供应商维护
#region 供应商
///
/// 物料供应商查询
///
/// Json序列化
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostSearchItemVendor(JsonDtoBase _jsonDto)
{
if (string.IsNullOrEmpty(_jsonDto.Paras))
{
return Ok(JsonView(false, "参数为空"));
}
Search_ResItemVendorDto _ItemVendorDto = System.Text.Json.JsonSerializer.Deserialize(_jsonDto.Paras);
if (_ItemVendorDto != null)
{
if (_ItemVendorDto.SearchType == 2) //获取列表
{
Res_ItemVendorListView rstList = _resItemInfoRep.GetVendorList(_ItemVendorDto);
return Ok(rstList);
}
else
{
Res_ItemVendorView rstInfo = _resItemInfoRep.getVendorInfo(_ItemVendorDto);
return Ok(rstInfo);
}
}
else
{
return Ok(JsonView(false, "参数反序列化失败"));
}
//return Ok(JsonView(false));
}
///
/// 创建/编辑/删除供应商信息
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostEditItemVendor(Edit_ResItemVendorDto _dto)
{
bool rst = false;
if (_dto.EditType >= 0)
{
if (string.IsNullOrEmpty(_dto.VendorFullName))
{
return Ok(JsonView(false, "全称未填写"));
}
if (string.IsNullOrEmpty(_dto.VendorLinker))
{
return Ok(JsonView(false, "联系人未填写"));
}
if (string.IsNullOrEmpty(_dto.VendorMobile))
{
return Ok(JsonView(false, "联系人手机号未填写"));
}
if (string.IsNullOrEmpty(_dto.BusRange))
{
return Ok(JsonView(false, "经营范围未选择"));
}
if (_dto.EditType == 0)
{
var checkEmpty = _resItemInfoRep.Query(s => s.FullName == _dto.VendorFullName).First();
if (checkEmpty != null)
{
return Ok(JsonView(false, "已存在同名供应商"));
}
rst = await _resItemInfoRep.addVendorInfo(_dto);
}
else if (_dto.EditType == 1)
{
if (_dto.VendorId > 0)
{
Res_ItemVendor _entity = _mapper.Map(_dto);
rst = await _resItemInfoRep.updVendorInfo(_entity);
}
else
{
return Ok(JsonView(false, "供应商不存在"));
}
}
}
else
{
if (_dto.VendorId < 1 || _dto.SysUserId < 1)
{
return Ok(JsonView(false, "用户Id或供应商Id不存在"));
}
Res_ItemVendor _entity = _mapper.Map(_dto);
rst = await _resItemInfoRep.delVendorInfo(_entity);
}
return Ok(JsonView(rst));
}
#endregion
#region 物料信息
///
/// 物料信息查询
///
/// Json序列化
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostSearchItemInfo(string paras)
{
if (string.IsNullOrEmpty(paras))
{
return Ok(JsonView(false, "参数为空"));
}
Search_ItemInfoDto _ItemInfoDto = System.Text.Json.JsonSerializer.Deserialize(paras);
if (_ItemInfoDto != null)
{
if (_ItemInfoDto.SearchType == 2) //获取列表
{
Res_ItemInfoListView rstList = _resItemInfoRep.GetItemList(_ItemInfoDto);
return Ok(rstList);
}
else
{
Res_ItemInfoView rstInfo = _resItemInfoRep.getItemInfo(_ItemInfoDto);
return Ok(rstInfo);
}
}
else
{
return Ok(JsonView(false, "参数反序列化失败"));
}
//return Ok(JsonView(false));
}
///
/// 创建/编辑/删除物料信息
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostEditItemInfo(Edit_ResItemInfoDto _dto)
{
bool rst = false;
if (_dto.EditType >= 0)
{
if (_dto.VendorId < 1)
{
return Ok(JsonView(false, "未选择供应商"));
}
if (string.IsNullOrEmpty(_dto.ItemName))
{
return Ok(JsonView(false, "物料名称为空"));
}
if (_dto.ItemTypeId < 1)
{
return Ok(JsonView(false, "未选择物料类型"));
}
if (_dto.SysUserId < 1)
{
return Ok(JsonView(false, "当前操作用户Id为空"));
}
if (_dto.CurrRate <= 0)
{
return Ok(JsonView(false, "物料录入价格不能小于等于0"));
}
if (_dto.EditType == 0)
{
//判断物料名称、类型、供应商全部重复
var checkEmpty = _resItemInfoRep.Query(s => s.ItemName == _dto.ItemName && s.ItemTypeId == _dto.ItemTypeId && s.VendorId == _dto.VendorId).First();
if (checkEmpty != null)
{
return Ok(JsonView(false, "已存在重复物料信息"));
}
Res_ItemDetailInfo _entity = _mapper.Map(_dto);
DateTime dtNow = DateTime.Now;
_entity.CreateUserId = _dto.SysUserId;
_entity.IsDel = 0;
_entity.MaxRate = _dto.CurrRate;
_entity.MaxDt = dtNow;
_entity.CurrRate = _dto.CurrRate;
_entity.CurrDt = dtNow;
_entity.MinRate = _dto.CurrRate;
_entity.MinDt = dtNow;
rst = await _resItemInfoRep.AddAsync(_entity) > 0;
}
else if (_dto.EditType == 1)
{
if (_dto.ItemId > 0)
{
Res_ItemDetailInfo _entity = _mapper.Map(_dto);
_entity.Id = _dto.ItemId;
rst = await _resItemInfoRep.updItemInfo(_entity);
}
else
{
return Ok(JsonView(false, "供应商不存在"));
}
}
}
else
{
if (_dto.ItemId < 1 || _dto.SysUserId < 1)
{
return Ok(JsonView(false, "用户Id或物料信息Id不存在"));
}
Res_ItemDetailInfo _entity = _mapper.Map(_dto);
rst = await _resItemInfoRep.delItemInfo(_entity);
}
return Ok(JsonView(rst));
}
#endregion
#region 物料类型获取
#endregion
#endregion
#region 备忘录
///
/// 备忘录查询
///
/// Json序列化
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostSearchMemo(JsonDtoBase _jsonDto)
{
if (string.IsNullOrEmpty(_jsonDto.Paras))
{
return Ok(JsonView(false, "参数为空"));
}
Search_ResMemoDto _memoDto = JsonConvert.DeserializeObject(_jsonDto.Paras);
if (_memoDto != null)
{
if (_memoDto.SearchType == 2)
{
//获取列表
string sqlWhere = string.Format(" Where IsDel=0 ");
#region SqlWhere
if (!string.IsNullOrEmpty(_memoDto.Abstracts))
{
sqlWhere += string.Format(@" And m.Abstracts Like '%{0}%' ", _memoDto.Abstracts);
}
if (!string.IsNullOrEmpty(_memoDto.Title))
{
sqlWhere += string.Format(@" And m.Title Like '%{0}%' ", _memoDto.Title);
}
if (_memoDto.ReadLevel > 0)
{
sqlWhere += string.Format(@" And m.ReadLevel = {0} ", _memoDto.ReadLevel);
}
#endregion
int currPIndex = (((_memoDto.PageIndex > 0) ? (_memoDto.PageIndex - 1) : 0) * _memoDto.PageSize) + 1;
int currPSize = (((_memoDto.PageIndex > 0) ? (_memoDto.PageIndex - 1) : 0) + 1) * _memoDto.PageSize;
string sql = string.Format(@" Select * From(Select ROW_NUMBER() Over(order By m.Id desc) as RowNumber,
m.Id as MemoId,d.DepName as DepartmentName,m.ReadLevel,m.Title,m.Abstracts,
m.LastedEditDt,m.LastedEditorId
From Res_Memo as m With(Nolock) Inner Join Sys_Users as u With(Nolock) On m.CreateUserId=u.Id
Inner Join Sys_Department as d With(Nolock) On u.DepId=d.Id {2}
) as tb Where tb.RowNumber Between {0} And {1} ", currPIndex, currPSize, sqlWhere);
Res_MemoListView rst = new Res_MemoListView();
rst.CurrPageIndex = currPIndex;
rst.CurrPageSize = currPSize;
List dataSource = _carDataRep._sqlSugar.SqlQueryable(sql).ToList();
Dictionary userDic = new Dictionary();
foreach (var item in dataSource)
{
if (userDic.ContainsKey(item.LastedEditorId))
{
item.LastedEditor = userDic[item.LastedEditorId];
}
else
{
var _sysUser = _carDataRep.Query(s => s.Id == item.LastedEditorId).First();
userDic[item.LastedEditorId] = _sysUser.CnName;
item.LastedEditor = _sysUser.CnName;
}
}
rst.DataList = new List(dataSource);
if (rst.DataList.Count > 0)
{
string sqlCount = string.Format(@" Select Id From Res_Memo as m With(Nolock) {0} ", sqlWhere);
int dataCount = _carDataRep._sqlSugar.SqlQueryable(sqlCount).Count();
rst.DataCount = dataCount;
}
return Ok(JsonView(rst));
}
else
{
//获取对象
string sqlSingle = string.Format(@" Select
m.Id as MemoId,d.DepName as DepartmentName,m.ReadLevel,m.Title,m.Abstracts,
m.LastedEditDt,m.LastedEditor,m.MDFilePath
From Res_Memo as m With(Nolock) Inner Join Sys_Users as u With(Nolock) On m.CreateUserId=u.Id
Inner Join Sys_Department as d With(Nolock) On u.DepId=d.Id Where m.Id={0} ", _memoDto.MemoId);
Res_MemoView _result = _carDataRep._sqlSugar.SqlQueryable(sqlSingle).First();
if (_result != null)
{
var _sysUser = _carDataRep.Query(s => s.Id == _result.LastedEditorId).First();
_result.LastedEditor = _sysUser.CnName;
_result.MarkDownContent = new IOOperatorHelper().Read(_result.MDFilePath);
return Ok(JsonView(_result));
}
}
}
else
{
return Ok(JsonView(false, "参数反序列化失败"));
}
return Ok(JsonView(false));
}
///
/// 创建/编辑/删除备忘录信息
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task PostEditMemo(Edit_ResMemoDto _dto)
{
bool rst = false;
if (_dto.SysUserId < 1)
{
return Ok(JsonView(false, "操作人失效"));
}
var _sysUser = _resItemInfoRep.Query(s => s.Id == _dto.SysUserId).First();
if (_sysUser == null)
{
return Ok(JsonView(false, "操作人失效02"));
}
if (_dto.EditType >= 0)
{
if (_dto.ReadLevel < 1)
{
return Ok(JsonView(false, "未知的阅读等级"));
}
if (string.IsNullOrEmpty(_dto.Title.Trim()))
{
return Ok(JsonView(false, "标题不能为空"));
}
if (string.IsNullOrEmpty(_dto.Content.Trim()))
{
return Ok(JsonView(false, "正文内容不能为空"));
}
//新增备忘录
DateTime dtNow = DateTime.Now;
string dir = AppSettingsHelper.Get("MemoCurrPath");
string fileName = dtNow.ToString("yyyyMMddHHmmss") + _dto.Title + ".md";
string content = JsonConvert.SerializeObject(_dto.Content);
if (_dto.EditType == 0)//新增
{
string savePath = new IOOperatorHelper().Write_CoverFile(content, dir, fileName);
if (savePath.Length > 0)
{
Res_MemoInfo _insert = new Res_MemoInfo();
_insert.Abstracts = _dto.Abstracts;
_insert.Title = _dto.Title;
_insert.DepartmentId = _sysUser.DepId;
_insert.CreateUserId = _sysUser.Id;
_insert.LastedEditDt = dtNow;
_insert.LastedEditor = _sysUser.Id;
_insert.MDFilePath = savePath;
_insert.ReadLevel = _dto.ReadLevel;
_insert.Title = _dto.Title;
int result = await _resItemInfoRep.AddAsync(_insert);
return Ok(JsonView(result > 0));
}
else
{
return Ok(JsonView(false, "路径保存失败"));
}
}
else//修改
{
if (_dto.MemoId < 1)
{
return Ok(JsonView(false, "MemoId不存在"));
}
Res_MemoInfo _source = _resItemInfoRep.Query(s => s.Id == _dto.MemoId).First();
if (_source == null)
{
return Ok(JsonView(false, "MemoInfo不存在"));
}
//修改
string sourcePath = _source.MDFilePath;
string recycDir = AppSettingsHelper.Get("MemoRecycleBinPath");
new IOOperatorHelper().MoveFile(sourcePath, recycDir);
string savePath = new IOOperatorHelper().Write_CoverFile(content, dir, fileName);
if (savePath.Length > 0)
{
var result = await _resItemInfoRep._sqlSugar.Updateable()
.SetColumns(it => it.LastedEditDt == DateTime.Now)
.SetColumns(it => it.LastedEditor == _sysUser.Id)
.SetColumns(it => it.Abstracts == _dto.Abstracts)
.SetColumns(it => it.MDFilePath == savePath)
.SetColumns(it => it.ReadLevel == _dto.ReadLevel)
.SetColumns(it => it.Title == _dto.Title)
.Where(s => s.Id == _source.Id)
.ExecuteCommandAsync();
return Ok(JsonView(result > 0));
}
}
}
else
{
//删除
if (_dto.MemoId < 1)
{
return Ok(JsonView(false, "MemoId不存在"));
}
Res_MemoInfo _source = _resItemInfoRep.Query(s => s.Id == _dto.MemoId).First();
if (_source == null)
{
return Ok(JsonView(false, "MemoInfo不存在"));
}
//修改
string sourcePath = _source.MDFilePath;
string recycDir = AppSettingsHelper.Get("MemoRecycleBinPath");
new IOOperatorHelper().MoveFile(sourcePath, recycDir);
var result = await _resItemInfoRep._sqlSugar.Updateable()
.SetColumns(it => it.IsDel == 1)
.SetColumns(it => it.DeleteUserId == _sysUser.Id)
.SetColumns(it => it.DeleteTime == DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"))
.Where(s => s.Id == _source.Id)
.ExecuteCommandAsync();
return Ok(JsonView(result > 0));
}
return Ok(JsonView(rst));
}
#endregion
#region 商邀资料
///
/// 商邀资料 基础数据源
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryIOAInitData(QueryIOAInitDataDto dto)
{
#region 参数验证
if (dto.PortType < 1) return Ok(JsonView(false, "请传入有效的PortType参数!"));
#endregion
var ExcludedKeyStr = new string[] { "快递费" };
var ClientKeyStr = new string[] { "邀请函翻译" };
List _DelegationInfos = _sqlSugar.Queryable().Where(it => it.IsDel == 0).OrderByDescending(it => it.JietuanTime).ToList();
List _ioaDatas = _sqlSugar.Queryable()
.Where(it => it.IsDel == 0)
.Select(x => new Res_InvitationOfficialActivityData
{
Country = x.Country,
UnitName = x.UnitName,
Contact = x.Contact,
Field = x.Field,
})
.ToList();
foreach (var item in _ioaDatas)
{
EncryptionProcessor.DecryptProperties(item);
}
foreach (var item in ExcludedKeyStr)
{
_ioaDatas = _ioaDatas.Where(x => string.IsNullOrWhiteSpace(x.UnitName) || !x.UnitName.Contains(item)).ToList();
}
foreach (var item in ClientKeyStr)
{
_ioaDatas = _ioaDatas.Where(x => string.IsNullOrWhiteSpace(x.Contact) || !x.Contact.Contains(item)).ToList();
}
List _Users = _sqlSugar.Queryable().Where(it => it.IsDel == 0).ToList();
var _countryData = _ioaDatas.Select(it => it.Country).Distinct().ToList(); _countryData.Remove("");
var _inviterData = _ioaDatas.Select(it => it.UnitName).Distinct().ToList(); _inviterData.Remove("");
var _contactData = _ioaDatas.Select(it => it.Contact).Distinct().ToList(); _contactData.Remove("");
var _domainData = _ioaDatas.Select(it => it.Field).Distinct().ToList(); _domainData.Remove("");
var _groupNameData = _DelegationInfos.Select(it => new { it.Id, it.TeamName }).ToList();
var _userNameData = _Users.Select(it => new { it.Id, it.CnName }).ToList();
var _data = new
{
CountryData = _countryData,
InviterData = _inviterData,
DomainData = _domainData,
ContactData = _contactData,
GroupNameData = _groupNameData,
UserNameData = _userNameData,
};
return Ok(JsonView(true, $"查询成功!", _data));
}
///
/// 商邀资料查询
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryInvitationOfficialActivityData(QueryInvitationOfficialActivityDataDto dto)
{
var ExcludedKeyStr = new string[] { "快递费" };
var ClientKeyStr = new string[] { "邀请函翻译" };
var columns = "Id,UnitName,Contact,City";
try
{
#region 参数验证
if (dto.PageIndex < 1) return Ok(JsonView(false, "请传入有效的PageIndex参数!"));
if (dto.PageSize < 1) return Ok(JsonView(false, "请传入有效的PageSize参数!"));
#endregion
//string sqlWhere = string.Empty;
if (!string.IsNullOrWhiteSpace(dto.Country)) { columns += ",Country"; }
//if (!string.IsNullOrWhiteSpace(dto.UnitName)) { columns += ",UnitName"; }
//if (!string.IsNullOrWhiteSpace(dto.Contact)) { columns += ",Contact"; }
if (!string.IsNullOrWhiteSpace(dto.Delegation)) { columns += ",Delegation"; }
if (!string.IsNullOrWhiteSpace(dto.Field)) { columns += ",Field"; }
//if (dto.CreateUserId != 0 && !string.IsNullOrWhiteSpace(dto.CreateUserId.ToString())) { columns += ",CreateUserId"; }
//if (!string.IsNullOrWhiteSpace(dto.StartCreateTime) && !string.IsNullOrWhiteSpace(dto.EndCreateTime))
//{
// columns += ",CreateUserId";
//}
DateTime endTime = new DateTime();
var InvitationOfficialActivityDataList = _sqlSugar.Queryable()
.Where(x => x.IsDel == 0)
.WhereIF(dto.CreateUserId != 0 && !string.IsNullOrWhiteSpace(dto.CreateUserId.ToString()), x => x.CreateUserId == dto.CreateUserId)
.WhereIF(DateTime.TryParse(dto.StartCreateTime, out DateTime startTime) && DateTime.TryParse(dto.EndCreateTime, out endTime), x => x.CreateTime >= startTime && x.CreateTime <= endTime)
.Select(columns)
.ToList();
foreach (var item in InvitationOfficialActivityDataList)
{
EncryptionProcessor.DecryptProperties(item);
}
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList
.WhereIF(!string.IsNullOrWhiteSpace(dto.Country), x => (!string.IsNullOrWhiteSpace(x.Country) && x.Country.Contains(dto.Country)) || (!string.IsNullOrWhiteSpace(x.City) && x.City.Contains(dto.Country)))
.WhereIF(!string.IsNullOrWhiteSpace(dto.UnitName), x => !string.IsNullOrWhiteSpace(x.UnitName) && x.UnitName.Contains(dto.UnitName))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Contact), x => !string.IsNullOrWhiteSpace(x.Contact) && x.Contact.Contains(dto.Contact))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Delegation), x => !string.IsNullOrWhiteSpace(x.Delegation) && x.Delegation.Contains(dto.Delegation))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Field), x => !string.IsNullOrWhiteSpace(x.Field) && x.Field.Contains(dto.Field))
.ToList();
foreach (var item in ExcludedKeyStr)
{
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList.Where(x => string.IsNullOrWhiteSpace(x.UnitName) || !x.UnitName.Contains(item)).ToList();
//sqlWhere += $" And i.UnitName not like '%{item}%' ";
}
foreach (var item in ClientKeyStr)
{
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList.Where(x => string.IsNullOrWhiteSpace(x.Contact) || !x.Contact.Contains(item)).ToList();
//sqlWhere += $" And i.Contact not like '%{item}%' ";
}
var ids = InvitationOfficialActivityDataList.Select(x => x.Id);
RefAsync totalCount = 0;
var _ivitiesViews = await _sqlSugar.Queryable()
.LeftJoin((a, b) => b.IsDel == 0 && a.CreateUserId == b.Id)
.Where((a, b) => ids.Contains(a.Id))
.OrderByDescending((a, b) => a.CreateTime)
.Select((a, b) => new InvitationOfficialActivityDataView
{
FaceBook = a.FaceBook,
Id = a.Id,
CreateUserId = a.CreateUserId,
IsDel = 0,
Address = a.Address,
Background = a.Background,
City = a.City,
Contact = a.Contact,
Country = a.Country,
CreateTime = a.CreateTime,
CreateUserName = b.CnName,
Delegation = a.Delegation,
Email = a.Email,
Fax = a.Fax,
Field = a.Field,
FilePath = a.FilePath,
Ins = a.Ins,
WeChat = a.WeChat,
UnitWeb = a.UnitWeb,
UnitName = a.UnitName,
UnitInfo = a.UnitInfo,
Tel = a.Tel,
SndFilePath = a.SndFilePath,
SndFileName = a.SndFileName,
Remark = a.Remark,
OtherInfo = a.OtherInfo,
Job = a.Job
})
.ToPageListAsync(dto.PageIndex, dto.PageSize, totalCount);
var allGroupIds = new HashSet();
foreach (var item in _ivitiesViews)
{
EncryptionProcessor.DecryptProperties(item);
if (!string.IsNullOrEmpty(item.Delegation))
{
allGroupIds.UnionWith(item.Delegation.Split(',').Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
}).Where(id => id != 0));
}
}
var _DelegationInfos = _sqlSugar.Queryable()
.Where(x => allGroupIds.Contains(x.Id) && x.IsDel == 0)
.ToList()
.GroupBy(x => x.Id)
.ToDictionary(group => group.Key, group => group.Select(g => g.TeamName));
foreach (var item in _ivitiesViews)
{
string groupNameStr = "";
if (!string.IsNullOrEmpty(item.Delegation))
{
var groupIds = item.Delegation.Split(',').Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
})
.Where(id => id != 0)
.ToArray();
foreach (var id in groupIds)
{
if (_DelegationInfos.ContainsKey(id))
{
groupNameStr += string.Join("", _DelegationInfos[id]) + ",";
}
}
if (groupNameStr.Length > 1)
{
groupNameStr = groupNameStr.Substring(0, groupNameStr.Length - 1);
}
}
item.DelegationStr = groupNameStr;
}
return Ok(JsonView(true, $"查询成功!", _ivitiesViews, totalCount));
}
catch (Exception ex)
{
return Ok(JsonView(false, ex.Message));
}
}
///
/// 商邀资料查询-欧洲
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryInvitationOfficialActivityData1()
{
try
{
// 定义欧洲国家数组
string[] europeanCountries = {
// 北欧国家
"瑞典", "芬兰", "挪威", "丹麦", "冰岛",
// 西欧国家
"英国", "爱尔兰", "法国", "荷兰", "比利时", "卢森堡", "摩纳哥",
// 中欧国家
"德国", "瑞士", "奥地利", "波兰", "捷克", "斯洛伐克", "匈牙利", "列支敦士登",
// 南欧国家
"意大利", "西班牙", "葡萄牙", "希腊", "马耳他", "圣马力诺", "梵蒂冈", "安道尔",
"克罗地亚", "斯洛文尼亚", "波斯尼亚和黑塞哥维那", "黑山", "塞尔维亚", "北马其顿", "阿尔巴尼亚", "保加利亚", "罗马尼亚",
// 东欧国家
"俄罗斯", "乌克兰", "白俄罗斯", "摩尔多瓦", "爱沙尼亚", "拉脱维亚", "立陶宛"
};
var InvitationOfficialActivityDataList = _sqlSugar.Queryable()
.Where(x => x.IsDel == 0)
.Select(x => new Res_InvitationOfficialActivityData() { Id = x.Id, Country = x.Country })
.ToList();
foreach (var item in InvitationOfficialActivityDataList)
{
EncryptionProcessor.DecryptProperties(item);
}
var ids = InvitationOfficialActivityDataList
.WhereIF(europeanCountries.Any(), x => !string.IsNullOrWhiteSpace(x.Country) && europeanCountries.Contains(x.Country))
.Select(x => x.Id)
.ToList();
RefAsync totalCount = 0;
var _ivitiesViews = await _sqlSugar.Queryable()
.LeftJoin((a, b) => b.IsDel == 0 && a.CreateUserId == b.Id)
.Where((a, b) => ids.Contains(a.Id))
.OrderByDescending((a, b) => a.CreateTime)
.Select((a, b) => new InvitationOfficialActivityDataView1
{
Country = a.Country,
City = a.City,
UnitName = a.UnitName,
Field = a.Field,
Address = a.Address,
UnitInfo = a.UnitInfo,
Delegation = a.Delegation,
OtherInfo = a.OtherInfo
})
.ToListAsync();
var allGroupIds = new HashSet();
foreach (var item in _ivitiesViews)
{
EncryptionProcessor.DecryptProperties(item);
if (!string.IsNullOrEmpty(item.Delegation))
{
allGroupIds.UnionWith(item.Delegation.Split(',').Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
}).Where(id => id != 0));
}
}
var _DelegationInfos = _sqlSugar.Queryable()
.Where(x => allGroupIds.Contains(x.Id) && x.IsDel == 0)
.ToList()
.GroupBy(x => x.Id)
.ToDictionary(group => group.Key, group => group.Select(g => g.TeamName));
foreach (var item in _ivitiesViews)
{
string groupNameStr = "";
if (!string.IsNullOrEmpty(item.Delegation))
{
var groupIds = item.Delegation.Split(',').Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
})
.Where(id => id != 0)
.ToArray();
foreach (var id in groupIds)
{
if (_DelegationInfos.ContainsKey(id))
{
groupNameStr += string.Join("", _DelegationInfos[id]) + ",";
}
}
if (groupNameStr.Length > 1)
{
groupNameStr = groupNameStr.Substring(0, groupNameStr.Length - 1);
}
}
item.DelegationStr = groupNameStr;
}
//获取模板
string tempPath = (AppSettingsHelper.Get("ExcelBasePath") + "Template/商邀资料模板.xls");
var designer = new WorkbookDesigner();
designer.Workbook = new Workbook(tempPath);
var dt = CommonFun.ToDataTableArray(_ivitiesViews);
dt.TableName = $"OADataView";
designer.SetDataSource(dt);
designer.Process();
//文件名
string fileName = $"商邀资料{DateTime.Now.ToString("yyyyMMddHHmmss")}.xls";
designer.Workbook.Save(AppSettingsHelper.Get("ExcelBasePath") + "InvitationOfficialActivityExport/" + fileName);
string url = AppSettingsHelper.Get("ExcelBaseUrl") + "Office/Excel/InvitationOfficialActivityExport/" + fileName;
return Ok(JsonView(true, "成功", url));
}
catch (Exception ex)
{
return Ok(JsonView(false, ex.Message));
}
}
///
/// 根据商邀资料Id查询信息
///
///
///
[HttpGet("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task QueryInvitationOfficialActivityById(int id)
{
if (id < 1) return Ok(JsonView(false, "Id参数错误!"));
return Ok(await _InvitationOfficialActivityDataRep.Info(id));
}
///
/// 商邀资料操作(Status:1.新增,2.修改)
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task OpInvitationOfficialActivity([FromForm] OpInvitationOfficialActivityDto dto)
{
return Ok(await _InvitationOfficialActivityDataRep.IOA_OP(dto));
}
///
/// 商邀资料 删除文件
///
///
///
///
[HttpDelete("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationOfficialActivityDelFile(int id, string fileName)
{
if (id < 1) return Ok(JsonView(false, "请传入有效的Id"));
if (string.IsNullOrEmpty(fileName)) return Ok(JsonView(false, "文件名称不能为空!"));
var info = await _sqlSugar.Queryable().FirstAsync(x => x.Id == id);
if (info == null) return Ok(JsonView(false, "该条数据不存在!"));
var files = new List();
try
{
files = JsonConvert.DeserializeObject>(info.SndFileName);
}
catch (Exception) { }
if (files != null && files.Count > 0 && files.Contains(fileName))
{
var filePath = $@"{AppSettingsHelper.Get("GrpFileBasePath")}/商邀相关文件/{fileName}";
if (System.IO.File.Exists(filePath))
{
System.IO.File.Delete(filePath);
}
//更改文件值
files.Remove(fileName);
var fileUpd = await _sqlSugar.Updateable()
.SetColumns(x => x.SndFileName == JsonConvert.SerializeObject(files))
.Where(x => x.Id == id)
.ExecuteCommandAsync();
if (fileUpd > 0) return Ok(JsonView(true, "操作成功!"));
}
return Ok(JsonView(false, "操作失败!"));
}
///
/// 删除商邀资料信息
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task DelInvitationOfficialActivity(DelBaseDto dto)
{
var res = await _InvitationOfficialActivityDataRep.SoftDeleteByIdAsync(dto.Id.ToString(), dto.DeleteUserId);
if (!res) return Ok(JsonView(false, "删除失败"));
var info = await _sqlSugar.Queryable().FirstAsync(x => x.Id == dto.Id);
if (info == null) return Ok(JsonView(false, "该条数据不存在!"));
var files = new List();
try
{
files = JsonConvert.DeserializeObject>(info.SndFileName);
}
catch (Exception) { }
if (files != null && files.Count > 0)
{
foreach (var fileName in files)
{
var filePath = $@"{AppSettingsHelper.Get("GrpFileBasePath")}/商邀相关文件/{fileName}";
if (System.IO.File.Exists(filePath))
{
System.IO.File.Delete(filePath);
}
}
}
return Ok(JsonView(true, "删除成功!"));
}
///
/// 商邀资料 ExcelExport
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationOfficialActivityExcelExport(QueryInvitationOfficialActivityDataDto dto)
{
var ExcludedKeyStr = new string[] { "快递费" };
var ClientKeyStr = new string[] { "邀请函翻译" };
var columns = "Id,UnitName,Contact";
#region 参数验证
if (dto.PageIndex < 1) return Ok(JsonView(false, "请传入有效的PageIndex参数!"));
if (dto.PageSize < 1) return Ok(JsonView(false, "请传入有效的PageSize参数!"));
#endregion
if (!string.IsNullOrWhiteSpace(dto.Country)) { columns += ",Country"; }
if (!string.IsNullOrWhiteSpace(dto.Delegation)) { columns += ",Delegation"; }
if (!string.IsNullOrWhiteSpace(dto.Field)) { columns += ",Field"; }
DateTime endTime = new DateTime();
var InvitationOfficialActivityDataList = _sqlSugar.Queryable()
.Where(x => x.IsDel == 0)
.WhereIF(dto.CreateUserId != 0 && !string.IsNullOrWhiteSpace(dto.CreateUserId.ToString()), x => x.CreateUserId == dto.CreateUserId)
.WhereIF(DateTime.TryParse(dto.StartCreateTime, out DateTime startTime) && DateTime.TryParse(dto.EndCreateTime, out endTime), x => x.CreateTime >= startTime && x.CreateTime <= endTime)
.Select(columns)
.ToList();
foreach (var item in InvitationOfficialActivityDataList)
{
EncryptionProcessor.DecryptProperties(item);
}
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList
.WhereIF(!string.IsNullOrWhiteSpace(dto.Country), x => !string.IsNullOrWhiteSpace(x.Country) && x.Country.Contains(dto.Country))
.WhereIF(!string.IsNullOrWhiteSpace(dto.UnitName), x => !string.IsNullOrWhiteSpace(x.UnitName) && x.UnitName.Contains(dto.UnitName))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Contact), x => !string.IsNullOrWhiteSpace(x.Contact) && x.Contact.Contains(dto.Contact))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Delegation), x => !string.IsNullOrWhiteSpace(x.Delegation) && x.Delegation.Contains(dto.Delegation))
.WhereIF(!string.IsNullOrWhiteSpace(dto.Field), x => !string.IsNullOrWhiteSpace(x.Field) && x.Field.Contains(dto.Field))
.ToList();
foreach (var item in ExcludedKeyStr)
{
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList.Where(x => string.IsNullOrWhiteSpace(x.UnitName) || !x.UnitName.Contains(item)).ToList();
//sqlWhere += $" And i.UnitName not like '%{item}%' ";
}
foreach (var item in ClientKeyStr)
{
InvitationOfficialActivityDataList = InvitationOfficialActivityDataList.Where(x => string.IsNullOrWhiteSpace(x.Contact) || !x.Contact.Contains(item)).ToList();
//sqlWhere += $" And i.Contact not like '%{item}%' ";
}
var ids = InvitationOfficialActivityDataList.Select(x => x.Id);
var _ivitiesViews = await _sqlSugar.Queryable()
.LeftJoin((a, b) => b.IsDel == 0 && a.CreateUserId == b.Id)
.Where((a, b) => ids.Contains(a.Id))
.OrderByDescending((a, b) => a.CreateTime)
.Select((a, b) => new IOAInfoView
{
FaceBook = a.FaceBook,
Id = a.Id,
Address = a.Address,
Background = a.Background,
City = a.City,
Contact = a.Contact,
Country = a.Country,
Delegation = a.Delegation,
Email = a.Email,
Fax = a.Fax,
Field = a.Field,
Ins = a.Ins,
WeChat = a.WeChat,
UnitWeb = a.UnitWeb,
UnitName = a.UnitName,
UnitInfo = a.UnitInfo,
Tel = a.Tel,
SndFileName = a.SndFileName,
Remark = a.Remark,
OtherInfo = a.OtherInfo,
Job = a.Job
})
.ToListAsync();
if (!_ivitiesViews.Any()) return Ok(JsonView(false, $"您查询的数据暂无内容,不可导出!"));
var allGroupIds = new HashSet();
foreach (var item in _ivitiesViews)
{
EncryptionProcessor.DecryptProperties(item);
if (!string.IsNullOrEmpty(item.Delegation))
{
allGroupIds.UnionWith(
item.Delegation.Split(',')
.Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
})
.Where(id => id != 0)
);
}
}
var _DelegationInfos = _sqlSugar.Queryable()
.Where(x => allGroupIds.Contains(x.Id) && x.IsDel == 0)
.ToList()
.GroupBy(x => x.Id)
.ToDictionary(group => group.Key, group => group.Select(g => g.TeamName));
foreach (var item in _ivitiesViews)
{
string groupNameStr = "";
if (!string.IsNullOrEmpty(item.Delegation))
{
var groupIds = item.Delegation.Split(',').Select(x =>
{
int id;
if (int.TryParse(x, out id)) return id;
return 0;
})
.Where(id => id != 0)
.ToArray();
foreach (var id in groupIds)
{
if (_DelegationInfos.ContainsKey(id))
{
groupNameStr += string.Join("", _DelegationInfos[id]) + ",";
}
}
if (groupNameStr.Length > 1)
{
groupNameStr = groupNameStr.Substring(0, groupNameStr.Length - 1);
}
}
item.DelegationStr = groupNameStr;
}
//获取模板
string tempPath = (AppSettingsHelper.Get("ExcelBasePath") + "Template/商邀资料模板.xls");
var designer = new WorkbookDesigner();
designer.Workbook = new Workbook(tempPath);
var dt = CommonFun.ToDataTableArray(_ivitiesViews);
dt.TableName = $"OADataView";
designer.SetDataSource(dt);
designer.Process();
//文件名
string fileName = $"商邀资料{DateTime.Now.ToString("yyyyMMddHHmmss")}.xls";
designer.Workbook.Save(AppSettingsHelper.Get("ExcelBasePath") + "InvitationOfficialActivityExport/" + fileName);
string url = AppSettingsHelper.Get("ExcelBaseUrl") + "Office/Excel/InvitationOfficialActivityExport/" + fileName;
return Ok(JsonView(true, "成功", url));
}
///
/// 商邀资料 导入文件(Excel)模板下载
///
///
[HttpGet]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationOfficialActivityExcelTemplateExport()
{
//获取模板
string fileName = $"商邀资料上传文件模板.xls";
string url = AppSettingsHelper.Get("ExcelBaseUrl") + "Office/Excel/Template/" + fileName;
return Ok(JsonView(true, "成功", url));
}
///
/// 商邀资料 上传Excel文件添加
///
///
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationOfficialActivityExcelUpload(IFormFile file, int currUserId)
{
var fileName = file.FileName;
var filePostfix = fileName.Split(".")[1].ToUpper();
if (!filePostfix.Contains("XLS")) return Ok(JsonView(false, $"请传入Excel文件"));
if (file.Length < 1) return Ok(JsonView(false, $"请传入有效的文件"));
if (currUserId < 1) return Ok(JsonView(false, $"请传入有效的UserId"));
//保存文件
string fileDirPath = string.Format(@"{0}InvitationOfficialActivityExcelUpload/", AppSettingsHelper.Get("ExcelBasePath"));
if (!Directory.Exists(fileDirPath))
{
Directory.CreateDirectory(fileDirPath);
}
var filePath = Path.Combine(fileDirPath, fileName);
await using var stream = new FileStream(filePath, FileMode.Create);
await file.CopyToAsync(stream);
//读取保存的文件
Workbook workbook = new Workbook(filePath);
if (workbook == null) return Ok(JsonView(false, $"Excel文件不存在!"));
Worksheet worksheet = workbook.Worksheets[0];
if (worksheet == null) return Ok(JsonView(false, $"Excel文件工作簿不存在!"));
var infos = new List();
var groupNames = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && !string.IsNullOrEmpty(x.TeamName)).Select(x => new { x.Id, x.TeamName }).ToListAsync();
for (int row = 1; row < worksheet.Cells.MaxDataRow + 1; row++)
{
var groupIdsLabel = string.Empty;
var groupNames1 = worksheet.Cells[row, 14].StringValue ?? "-";
if (!string.IsNullOrEmpty(groupNames1))
{
if (groupNames1.Contains(";"))
{
var groupNameArray = groupNames1.Split(";").Where(x => !string.IsNullOrEmpty(x)).ToList();
var groupIds = groupNames.Where(x => groupNameArray.Contains(x.TeamName)).Select(x => x.Id).ToList();
if (groupIds.Any()) groupIdsLabel = string.Join(',', groupIds);
}
else groupIdsLabel = groupNames.Where(x => groupNames1.Equals(x.TeamName)).FirstOrDefault()?.Id.ToString() ?? string.Empty;
}
infos.Add(new Res_InvitationOfficialActivityData()
{
Country = worksheet.Cells[row, 0].StringValue ?? "-",
City = worksheet.Cells[row, 1].StringValue ?? "-",
UnitName = worksheet.Cells[row, 2].StringValue ?? "-",
Field = worksheet.Cells[row, 3].StringValue ?? "-",
Address = worksheet.Cells[row, 4].StringValue ?? "-",
UnitInfo = worksheet.Cells[row, 5].StringValue ?? "-",
Contact = worksheet.Cells[row, 6].StringValue ?? "-",
Job = worksheet.Cells[row, 7].StringValue ?? "-",
Tel = worksheet.Cells[row, 8].StringValue ?? "-",
Email = worksheet.Cells[row, 9].StringValue ?? "-",
WeChat = worksheet.Cells[row, 10].StringValue ?? "-",
FaceBook = worksheet.Cells[row, 11].StringValue ?? "-",
Ins = worksheet.Cells[row, 12].StringValue ?? "-",
Fax = worksheet.Cells[row, 13].StringValue ?? "-",
Delegation = groupIdsLabel,
SndFilePath = worksheet.Cells[row, 15].StringValue ?? "-",
OtherInfo = worksheet.Cells[row, 16].StringValue ?? "-",
Remark = $"[{DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")}] Excel上传文件添加! 文件存储地址[{filePath}]",
CreateUserId = currUserId,
IsDel = 0
});
}
//加密
foreach (var item in infos) EncryptionProcessor.EncryptProperties(item);
var addCount = await _sqlSugar.Insertable(infos).ExecuteCommandAsync();
if (addCount < 1) return Ok(JsonView(false, "文件上传添加失败!"));
return Ok(JsonView(true, $"上传文件添加成功!共添加{addCount}条!"));
}
#endregion
#region 商邀资料 AI
///
/// 商邀资料AI 基础数据源
///
///
[HttpGet]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAIInit()
{
var itemNames = await InvitationAIInvName();
var unitNames = await InvitationAIClientName();
var countries = await InvitationAICountryName();
var industryNodes = IndustryTree.Build().Select(x => x.NameCn).ToList();
var orgScales = OrgScale.BuildInitialData().Select(x => x.Name).ToList();
var orgLevels = new List() {
"全部",
"总部",
"分公司"
};
return Ok(JsonView(true, $"查询成功!", new
{
itemNames,
unitNames,
countries,
industryNodes,
orgScales,
orgLevels
}));
}
///
/// 商邀资料AI 资料列表
///
///
[HttpGet("{name}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAIItemByName(string name)
{
if (string.IsNullOrWhiteSpace(name)) return Ok(JsonView(false, "名称无效"));
// 1. 获取主表记录
var info = await _sqlSugar.Queryable()
.FirstAsync(x => x.IsDel == 0 && x.InvName == name);
var groupInfo = await _sqlSugar.Queryable().FirstAsync(x => x.IsDel == 0 && x.TeamName.Equals(name));
string baseUrl = AppSettingsHelper.Get("OfficeBaseUrl")?.TrimEnd('/');
// 2. 分支处理:若无主表记录,尝试从团组表同步基本信息
if (info == null)
{
return Ok(JsonView(true, "暂无数据", new
{
Id = 0,
GroupId = groupInfo?.Id ?? 0,
InvName = name,
AiCrawledDetails = new List(),
Entry = new
{
Objective = groupInfo?.VisitPurpose ?? "商务会谈",
OriginUnit = groupInfo?.ClientUnit ?? "",
TargetCountry = _delegationInfoRep.GroupSplitCountry(groupInfo?.VisitCountry ?? "")
}
}));
}
// 3. 数据填充(使用 ??= 语法确保 Null 安全)
info.EntryInfo ??= new EntryInfo();
if (string.IsNullOrEmpty(info.EntryInfo.Objective))
info.EntryInfo.Objective = groupInfo?.VisitPurpose ?? "商务会谈";
if (string.IsNullOrEmpty(info.EntryInfo.OriginUnit))
info.EntryInfo.OriginUnit = groupInfo?.ClientUnit ?? "";
if (info.EntryInfo.TargetCountry?.Any() != true)
info.EntryInfo.TargetCountry = _delegationInfoRep.GroupSplitCountry(groupInfo?.VisitCountry ?? "");
// 4. 排序:ThenByDescending 确保多级排序生效
info.AiCrawledDetails = info.AiCrawledDetails
.OrderByDescending(x => x.IsChecked)
.ThenByDescending(x => x.OperatedAt)
.ToList();
var details = info?.AiCrawledDetails ?? new List();
if (details.Any())
{
foreach (var detail in details)
{
// 附件路径处理
if (detail.EmailInfo?.AttachmentPaths?.Any() == true)
{
detail.EmailInfo.AttachmentPaths = detail.EmailInfo.AttachmentPaths
.Select(p => p.StartsWith("http") ? p : $"{baseUrl}/{p.TrimStart('/')}")
.ToList();
}
// 官网地址注入新闻首位 (确保 PostUrl 已实例化)
if (!string.IsNullOrEmpty(detail.SiteUrl))
{
detail.PostUrl ??= new List();
// 避免重复插入
if (!detail.PostUrl.Any(x => x.Description == "官网"))
{
detail.PostUrl.Insert(0, new PostNewsItem
{
Date = "-",
Description = "官网",
Url = detail.SiteUrl
});
}
}
}
}
return Ok(JsonView(true, "查询成功!", new
{
info.Id,
info.GroupId,
info.InvName,
AiCrawledDetails = details,
Entry = info.EntryInfo
}));
}
///
/// 商邀资料AI 设置词条
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAISetPrompt(InvitationAISetPromptDto dto)
{
// 基础校验
if (string.IsNullOrWhiteSpace(dto.InvName) || string.IsNullOrWhiteSpace(dto.Objective) || string.IsNullOrWhiteSpace(dto.OriginUnit) ||
dto.TargetCountry == null || dto.TargetCountry.Count == 0 || dto.Industries == null || dto.Industries.Count == 0 ||
dto.ScaleTypes == null || dto.ScaleTypes.Count == 0
)
return Ok(JsonView(false, "请传入有效的公务名称、单位名称、国家、出访目的、行业和规模类型!"));
var invName = dto.InvName;
var groupInfo = await _sqlSugar.Queryable()
.Where(x => x.IsDel == 0 && x.TeamName.Equals(invName))
.Select(x => new {x.Id,x.TeamName, x.VisitPurpose })
.FirstAsync();
int groupId = groupInfo?.Id ?? 0;
#region 数据库操作
// 数据库信息获取方式
var dataInfo = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.InvName.Equals( invName)).FirstAsync();
#region 词条信息
string operatorName = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.Id == dto.CurrUserId).Select(x => x.CnName).FirstAsync() ?? "-";
var entryInfo = new EntryInfo()
{
OriginUnit = dto.OriginUnit,
TargetCountry = dto.TargetCountry,
Objective = dto.Objective,
Industries = dto.Industries,
ScaleTypes = dto.ScaleTypes,
IsBackground = dto.IsBackground,
OrgLevel = dto.OrgLevel,
OtherConstraints = dto.OtherConstraints,
Operator = operatorName,
OperatedAt = DateTime.Now
};
#endregion
// 3.如果以上两种方式都没有查询到数据,则说明是新数据,需要添加到数据库
if (dataInfo == null)
{
// 3.1 新数据,需要添加到数据库
dataInfo = new Res_InvitationAI()
{
InvName = invName,
GroupId = groupId,
EntryInfo = entryInfo,
CreateUserId = dto.CurrUserId
};
var insert = await _sqlSugar.Insertable(dataInfo).ExecuteReturnIdentityAsync();
if (insert < 1)
{
return Ok(JsonView(false, $"词条信息新增失败!"));
}
dataInfo.Id = insert;
}
else
{
// 3.2 数据存在 则更新数据(覆盖原有的AI爬取详情,保留原有的其他字段不变)
dataInfo.EntryInfo = entryInfo;
var update = await _sqlSugar.Updateable(dataInfo).ExecuteCommandAsync();
if (update < 1)
{
return Ok(JsonView(false, $"词条信息更新失败!"));
}
}
#endregion
return Ok(JsonView(true, $"设置成功!", new
{
dataInfo.Id,
dataInfo.InvName,
dataInfo.GroupId,
Entry = dataInfo.EntryInfo,
}));
}
///
/// 商邀资料AI 设置复选框选中 批量
///
///
///
[HttpPost]
public async Task InvitationAISetChecked([FromBody] InvitationAISetCheckedDto dto)
{
// 1. 基础参数校验 (注意:这里移除了对 Guids.Any() 的强校验,允许空集合)
if (dto.Id < 1 || dto.CurrUserId < 1 || dto.Guids == null)
return Ok(JsonView(false, "请求参数不完整"));
// 2. 获取主记录
var invAiInfo = await _sqlSugar.Queryable()
.FirstAsync(x => x.IsDel == 0 && x.Id == dto.Id);
if (invAiInfo?.AiCrawledDetails == null || !invAiInfo.AiCrawledDetails.Any())
return Ok(JsonView(false, "数据不存在或集合为空"));
// 3. 准备更新所需数据
var guidSet = dto.Guids.ToHashSet();
var now = DateTime.Now;
// 获取操作人姓名
string operatorName = await _sqlSugar.Queryable()
.Where(x => x.Id == dto.CurrUserId)
.Select(x => x.CnName)
.FirstAsync() ?? "-";
// 4. 单次遍历完成 重置 + 更新
// 如果 guidSet 为空,循环会将所有项的 IsChecked 置为 false
foreach (var item in invAiInfo.AiCrawledDetails)
{
if (guidSet.Contains(item.Guid))
{
item.IsChecked = true;
}
else
{
item.IsChecked = false;
}
item.OperatedAt = now;
item.Operator = operatorName;
}
// 5. 排序逻辑
// 即使是全量取消选中,也可以按最后操作时间排序,让最近变动的项在前
invAiInfo.AiCrawledDetails = invAiInfo.AiCrawledDetails
.OrderByDescending(x => x.OperatedAt)
.ToList();
// 6. 提交数据库
// 注意:SqlSugar 的 UpdateColumns 会序列化整个对象列表并覆盖数据库字段
await _sqlSugar.Updateable(invAiInfo)
.UpdateColumns(x => x.AiCrawledDetails)
.ExecuteCommandAsync();
return Ok(JsonView(true, guidSet.Any() ? "设置成功" : "已全部取消选中"));
}
///
/// 商邀资料AI 保存
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAISave(InvitationAISaveDto dto)
{
if (dto.Id < 1) return Ok(JsonView(false, "请先设置AI关键字"));
if (dto.CurrUserId < 1) return Ok(JsonView(false, "请传入用户Id"));
if (dto.AiCrawledDetail == null) return Ok(JsonView(false, "请选择保存的邀请方详情"));
var invAiInfo = await _sqlSugar.Queryable()
.Where(x => x.Id == dto.Id)
.FirstAsync();
if (invAiInfo == null) return Ok(JsonView(false, "数据信息为空"));
var dataList = invAiInfo?.AiCrawledDetails;
if (dataList == null) return Ok(JsonView(false, "邀请方数据信息为空"));
var datas = dataList.Where(x => x.Guid != dto.AiCrawledDetail.Guid).ToList();
var editInfo = dto.AiCrawledDetail;
// 如果 Guid 为空,说明是新增数据,需要生成新的 Guid
if (string.IsNullOrEmpty(editInfo.Guid))
{
editInfo.Guid = Guid.NewGuid().ToString("N");
editInfo.Source = 2; // 标记为手动新增数据
editInfo.OperatedAt = DateTime.Now;
}
var opUserName = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.Id == dto.CurrUserId).Select(x => x.CnName).FirstAsync() ?? "-";
editInfo.Operator = opUserName;
editInfo.OperatedAt = DateTime.Now;
datas.Add(editInfo);
invAiInfo.AiCrawledDetails = datas.OrderByDescending(x => x.OperatedAt).ToList();
var editUpd = await _sqlSugar.Updateable(invAiInfo).UpdateColumns(x => x.AiCrawledDetails).ExecuteCommandAsync();
if (editUpd < 1)
{
return Ok(JsonView(true, "保存失败"));
}
return Ok(JsonView(true, "保存成功"));
}
///
/// 商邀资料AI 单条删除
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAISingleDel(InvitationAISingleDelDto dto)
{
int id = dto.Id;
string guid = dto.Guid;
// 基础校验
if (id < 1 || string.IsNullOrWhiteSpace(guid))
return Ok(JsonView(false, "请传入有效的Id和Guid!"));
var dataInfo = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.Id == id).FirstAsync();
if (dataInfo == null)
return Ok(JsonView(false, "当前数据信息不存在!"));
var newDataInfos = dataInfo.AiCrawledDetails.Where(x => x.Guid != guid).ToList();
dataInfo.AiCrawledDetails = newDataInfos.OrderByDescending(x => x.OperatedAt).ToList();
var update = await _sqlSugar.Updateable(dataInfo).ExecuteCommandAsync();
if (update < 1)
{
return Ok(JsonView(false, $"删除失败!"));
}
return Ok(JsonView(true, $"删除成功!", new
{
dataInfo.Id,
dataInfo.InvName,
dataInfo.GroupId,
dataInfo.AiCrawledDetails
}));
}
///
/// 商邀资料AI AI查询出的数据添加至商邀资料库
///
///
[HttpPost]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAIInsertResource([FromBody] InvitationAIInsertResourceDto dto)
{
// 基础校验
if (dto.Id < 1 || dto.CurrUserId < 1 || dto.Guids == null || !dto.Guids.Any())
return Ok(JsonView(false, "参数不完整,请选择有效的单位数据"));
// 获取主记录
var dataInfo = await _sqlSugar.Queryable()
.FirstAsync(x => x.IsDel == 0 && x.Id == dto.Id);
if (dataInfo?.AiCrawledDetails == null)
return Ok(JsonView(false, "当前数据信息不存在!"));
// 筛选出待转正的 AI 数据 (使用 HashSet 优化匹配)
var guidSet = dto.Guids.ToHashSet();
var targetAiDetails = dataInfo.AiCrawledDetails
.Where(x => x.Source != 0 && guidSet.Contains(x.Guid))
.ToList();
if (!targetAiDetails.Any())
return Ok(JsonView(false, "未找到符合条件的 AI 获取信息,无法重复添加或来源错误!"));
// 准备入库数据(批量构建)
var now = DateTime.Now;
var opUserName = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.Id == dto.CurrUserId).Select(x => x.CnName).FirstAsync() ?? "-";
var rawLocalDatas = targetAiDetails.Select(item => {
// 修改内存中的状态为本地数据
item.Source = 0;
item.OperatedAt = now;
item.Operator = opUserName;
return new Res_InvitationOfficialActivityData()
{
// 批量加密操作
Country = AesEncryptionHelper.Encrypt(item.Region),
UnitName = AesEncryptionHelper.Encrypt(item.NameCn),
Address = AesEncryptionHelper.Encrypt(item.Address),
Field = AesEncryptionHelper.Encrypt(item.Scope),
Contact = AesEncryptionHelper.Encrypt(item.Contact),
Tel = AesEncryptionHelper.Encrypt(item.Phone),
Email = AesEncryptionHelper.Encrypt(item.Email),
UnitWeb = AesEncryptionHelper.Encrypt(item.SiteUrl),
LastUpdateUserId = dto.CurrUserId,
LastUpdateTime = now,
CreateUserId = dto.CurrUserId,
CreateTime = now
};
}).ToList();
// 开启事务执行双表更新
var result = await _sqlSugar.UseTranAsync(async () =>
{
// 插入本地资料库
await _sqlSugar.Insertable(rawLocalDatas).ExecuteCommandAsync();
// 更新 AI 主表的状态(全量覆盖 JSON 列)
await _sqlSugar.Updateable(dataInfo)
.UpdateColumns(x => x.AiCrawledDetails)
.ExecuteCommandAsync();
});
return Ok(result.IsSuccess
? JsonView(true, "成功添加至资料库并更新来源状态")
: JsonView(false, $"操作失败:{result.ErrorMessage}"));
}
///
/// 商邀资料AI 混元AI查询资料(SSE流式推送)
///
[HttpPost]
public async Task InvitationAISearchStreamProgress([FromBody] InvitationAISearchDto dto)
{
HttpContext.InitializeSse();
try
{
await HttpContext.SendSseStepAsync(5, "正在加载配置...");
#region 1. 异步并行化验证 (Performance Boost)
var invAiInfo = await _sqlSugar.Queryable().Where(x => x.IsDel == 0 && x.Id == dto.Id).FirstAsync();
var operatorName = await _sqlSugar.Queryable()
.Where(x => x.IsDel == 0 && x.Id == dto.CurrUserId)
.Select(x => x.CnName).FirstAsync();
if (invAiInfo?.EntryInfo == null)
{
await HttpContext.SendSseStepAsync(-1, "未找到有效的关键字配置。");
return;
}
var entryInfo = invAiInfo.EntryInfo;
var targetCountrySet = new HashSet(entryInfo.TargetCountry);
#endregion
await HttpContext.SendSseStepAsync(20, "正在解析本地典籍 (并行解密)...");
#region 2. 内存计算优化
// 仅查询必要字段,减少 DataReader 压力
var rawLocalDatas = await _sqlSugar.Queryable()
.Where(x => x.IsDel == 0 && !string.IsNullOrEmpty(x.UnitName))
.Select(x => new { x.Country, x.UnitName, x.Address, x.Field, x.Contact, x.Tel, x.Email })
.ToListAsync();
// PLINQ 核心炼金:利用多核并行解密
var allDecrypted = rawLocalDatas.AsParallel().Select(item => new InvitationAIInfo
{
Guid = Guid.NewGuid().ToString("N"),
Source = 0, // 标识来源:本地
Region = AesEncryptionHelper.Decrypt(item.Country),
NameCn = AesEncryptionHelper.Decrypt(item.UnitName),
Address = AesEncryptionHelper.Decrypt(item.Address),
Scope = AesEncryptionHelper.Decrypt(item.Field),
Contact = AesEncryptionHelper.Decrypt(item.Contact),
Phone = AesEncryptionHelper.Decrypt(item.Tel),
Email = AesEncryptionHelper.Decrypt(item.Email),
OperatedAt = DateTime.Now,
Operator = operatorName,
}).ToList();
// 筛选符合国家的本地数据
var matchedCountries = allDecrypted.Where(x => targetCountrySet.Contains(x.Region)).ToList();
//var matchedCountries = new List();
#endregion
#region 3. 混元 AI 协同炼金 (双阶段)
// --- 阶段 A: 行业匹配分析 ---
if (matchedCountries.Any())
{
await HttpContext.SendSseStepAsync(40, $"AI 正在执行 {entryInfo.TargetCountry.Count} 国的行业契合度分析...");
string industryQuestion = BuildIndustryPrompt(entryInfo, matchedCountries);
string industryRaw = await _hunyuanService.ChatCompletionsHunyuan_t1_latestAsync(industryQuestion);
var industryMatches = CleanAndParseJson>(industryRaw) ?? new();
var matchedNames = new HashSet(industryMatches.Select(x => x.TargetUnitName));
// 重新过滤:仅保留 AI 认为匹配的本地数据
matchedCountries = matchedCountries.Where(x => !string.IsNullOrEmpty(x.NameCn) && matchedNames.Contains(x.NameCn)).Distinct().ToList();
}
// --- 阶段 B: 差额补全 (Gap Filling) ---
var localInvDatas = new List();
var aiTasks = new List();
foreach (var country in entryInfo.TargetCountry)
{
var countryData = matchedCountries.Where(x => x.Region == country).Take(entryInfo.NeedCount).ToList();
localInvDatas.AddRange(countryData);
int gap = entryInfo.NeedCount - countryData.Count;
if (gap > 0) aiTasks.Add(new() { Country = country, Count = gap });
}
var hunyuanAIInvDatas = new List();
if (aiTasks.Any())
{
// 强制冷却(应对 QPS 限制)
// 混元免费版或低阶版本通常有 1s/1次 的频率限制
await Task.Delay(1000);
// 任务配置计算
var countryTasks = QuotaScheduler.GenerateTasks(aiTasks, entryInfo.Industries, entryInfo.ScaleTypes);
var countryTasksGroupBy = countryTasks.GroupBy(x => x.Region).Select(g => new
{
Region = g.Key,
Counrt = g.Count()
}).ToList();
await HttpContext.SendSseStepAsync(60, $"AI 正在跨境检索缺失的 {string.Join(", ", countryTasksGroupBy.Select(x => $"{x.Region}({x.Counrt}条)"))} 单位资料...");
string searchQuestion = BuildHunyuanPrompt(aiTasks, countryTasks, entryInfo);
_logger.LogInformation(@"公务名称:{InvName}; 混元AI查询提示词:{searchQuestion}", invAiInfo.InvName, searchQuestion);
string searchRaw = await _hunyuanService.ChatCompletionsHunyuan_t1_latestAsync(searchQuestion);
var aiParsed = CleanAndParseJson>(searchRaw);
if (aiParsed != null)
{
hunyuanAIInvDatas = aiParsed.Select(x => {
x.Guid = Guid.NewGuid().ToString("N");
x.Source = 1;
x.Operator = operatorName;
x.OperatedAt = DateTime.Now;
return x;
}).ToList();
}
}
#endregion
await HttpContext.SendSseStepAsync(90, "正在同步成果至持久化仓库...");
#region 4. 数据融合与更新
var finalResult = localInvDatas.Concat(hunyuanAIInvDatas).ToList();
// 仅更新指定列,性能更优
invAiInfo.AiCrawledDetails = finalResult.OrderByDescending(x => x.OperatedAt).ToList();
bool isOk = await _sqlSugar.Updateable(invAiInfo)
.UpdateColumns(x => x.AiCrawledDetails)
.ExecuteCommandHasChangeAsync();
if (!isOk) await HttpContext.SendSseStepAsync(-1, $"数据持久化失败。");
#endregion
// 5. 终焉推送
await HttpContext.SendSseStepAsync(100, "操作成功!资料已全部就绪。", new
{
invAiInfo.Id,
AiCrawledDetails = finalResult.OrderByDescending(x => x.Source).ThenBy(x => x.Region).ToList()
});
}
catch (Exception ex)
{
_logger.LogError(ex, "SSE 管道熔断");
await HttpContext.SendSseStepAsync(-1, $"SSE 错误:{ex.InnerException.Message}({ex.Message})");
}
finally
{
await HttpContext.FinalizeSseAsync();
}
}
///
/// 清洗并解析 AI 返回的 JSON 块
///
private static T? CleanAndParseJson(string rawResponse)
{
if (string.IsNullOrWhiteSpace(rawResponse)) return default;
string cleanJson = rawResponse.Trim();
// 自动剥离 Markdown 语法糖
if (cleanJson.Contains("```json"))
cleanJson = cleanJson.Split("```json")[1].Split("```")[0];
else if (cleanJson.Contains("```"))
cleanJson = cleanJson.Split("```")[1].Split("```")[0];
return JsonConvert.DeserializeObject(cleanJson.Trim());
}
///
/// 商邀资料AI 混元AI续写(SSE流式推送)
///
///
///
[HttpPost]
public async Task InvitationAICompleteTextStream([FromBody] InvitationAICompleteTextDto dto)
{
HttpContext.InitializeSse();
try
{
// 初始化检查 (Progress: 5%)
var invAiInfo = await _sqlSugar.Queryable().Where(x => x.Id == dto.Id).FirstAsync();
if (invAiInfo?.EntryInfo == null)
{
await HttpContext.SendSseStepAsync(-1, "请先设置关键字信息!");
return;
}
await HttpContext.SendSseStepAsync(10, "任务初始化完成,正在计算补齐缺口...");
// 任务拆解逻辑
var entryInfo = invAiInfo.EntryInfo;
var aiTasks = new List();
int targetPerCountry = entryInfo.NeedCount;
foreach (var countryName in entryInfo.TargetCountry)
{
var countryDataCount = invAiInfo.AiCrawledDetails.Count(x => x.Region == countryName);
int aiNeedCount = targetPerCountry - countryDataCount;
if (aiNeedCount > 0) aiTasks.Add(new() { Country = countryName, Count = aiNeedCount });
}
if (!aiTasks.Any())
{
await HttpContext.SendSseStepAsync(100, "数据已满额,无需续写", invAiInfo.AiCrawledDetails);
return;
}
// 准备 AI Prompt (Progress: 20%)
var existingNames = new HashSet(invAiInfo.AiCrawledDetails.Where(x => x.Source == 1).Select(x => x.NameCn));
string promptOther = $"请基于以下已存在的名称列表进行推荐,避免重复:{string.Join(", ", existingNames)}。{entryInfo.OtherConstraints}";
entryInfo.OtherConstraints = promptOther; // 将去重提示注入 entryInfo,确保 Prompt 构建时包含该信息
// 构建 Question
// 任务配置计算
var countryTasks = QuotaScheduler.GenerateTasks(aiTasks, entryInfo.Industries, entryInfo.ScaleTypes);
string question = BuildHunyuanPrompt(aiTasks, countryTasks, entryInfo);
await HttpContext.SendSseStepAsync(30, "AI 正在深度检索跨境商邀数据,请稍候...");
// 调用 AI (Progress: 30% - 80%)
string aiRawResponse = await _hunyuanService.ChatCompletionsHunyuan_t1_latestAsync(question);
await HttpContext.SendSseStepAsync(85, "数据已捕获,正在进行格式校验与去重...");
// 5. 解析与清洗数据
var hunyuanAIInvDatas = ProcessAIResponse(aiRawResponse);
string operatorName = await _sqlSugar.Queryable().Where(x => x.Id == dto.CurrUserId).Select(x => x.CnName).FirstAsync() ?? "-";
foreach (var x in hunyuanAIInvDatas)
{
x.Guid = Guid.NewGuid().ToString("N");
x.Source = 1;
x.Operator = operatorName;
x.OperatedAt = DateTime.Now;
}
// 6. 数据库操作 (Progress: 95%)
invAiInfo.AiCrawledDetails.AddRange(hunyuanAIInvDatas);
invAiInfo.AiCrawledDetails = invAiInfo.AiCrawledDetails.OrderByDescending(x => x.OperatedAt).ToList();
var update = await _sqlSugar.Updateable(invAiInfo).UpdateColumns(x => x.AiCrawledDetails).ExecuteCommandAsync();
if (update > 0)
{
await HttpContext.SendSseStepAsync(100, $"AI 续写成功!新增 {hunyuanAIInvDatas.Count} 条数据", invAiInfo.AiCrawledDetails);
}
else
{
await HttpContext.SendSseStepAsync(-1, "数据库更新失败");
}
}
catch (Exception ex)
{
_logger.LogError(ex, "SSE 续写异常");
await HttpContext.SendSseStepAsync(-1, $"炼金炸炉:{ex.Message}");
}
finally
{
await HttpContext.FinalizeSseAsync();
}
}
private List ProcessAIResponse(string response)
{
if (string.IsNullOrWhiteSpace(response)) return new List();
string cleanJson = response.Trim();
if (cleanJson.Contains("```json"))
{
cleanJson = Regex.Match(cleanJson, @"```json([\s\S]*?)```").Groups[1].Value.Trim();
}
else if (cleanJson.Contains("```"))
{
cleanJson = Regex.Match(cleanJson, @"```([\s\S]*?)```").Groups[1].Value.Trim();
}
return JsonConvert.DeserializeObject>(cleanJson) ?? new List();
}
///
/// 商邀资料AI 文件生成(基于混元AI已爬取数据进行格式化输出,供用户下载使用)
///
///
[HttpGet("{id}")]
[ProducesResponseType(typeof(JsonView), StatusCodes.Status200OK)]
public async Task InvitationAIFileGenerator(int id)
{
var invAiInfo = await _sqlSugar.Queryable()
.Where(x => x.Id == id)
.FirstAsync();
var dataList = invAiInfo?.AiCrawledDetails;
if (dataList == null)
return Ok(JsonView(false, "数据为空"));
Document doc = new Document();
DocumentBuilder builder = new DocumentBuilder(doc);
// A4页面设置
double usableWidth = 495;
foreach (Aspose.Words.Section sec in doc.Sections)
{
sec.PageSetup.PaperSize = Aspose.Words.PaperSize.A4;
sec.PageSetup.LeftMargin = 50;
sec.PageSetup.RightMargin = 50;
sec.PageSetup.TopMargin = 50;
sec.PageSetup.BottomMargin = 50;
}
// 卡片背景
Color cardBg = Color.FromArgb(252, 252, 252);
string fontName = "微软雅黑";
int count = 1;
foreach (var item in dataList)
{
// 标题
builder.ParagraphFormat.ClearFormatting();
builder.Font.ClearFormatting();
builder.Font.Name = fontName;
builder.Font.Size = 16;
builder.Font.Bold = true;
builder.Font.Color = Color.Black;
builder.Write($"{count++}. {item.NameCn}");
builder.InsertParagraph();
// 英文名
builder.Font.Size = 10;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(120, 120, 120);
builder.Write(item.NameEn ?? "");
builder.InsertParagraph();
builder.InsertParagraph();
// ====== 卡片表格 ======
Aspose.Words.Tables.Table table = builder.StartTable();
builder.CellFormat.Shading.BackgroundPatternColor = cardBg;
builder.CellFormat.VerticalAlignment = CellVerticalAlignment.Center;
builder.CellFormat.WrapText = true;
builder.CellFormat.LeftPadding = 12;
builder.CellFormat.RightPadding = 12;
builder.CellFormat.TopPadding = 8;
builder.CellFormat.BottomPadding = 8;
double labelW = 120;
AddSingleRow(builder, fontName, labelW, usableWidth - labelW, "详细地址", item.Address);
AddSingleRow(builder, fontName, labelW, usableWidth - labelW, "联系人", item.Contact);
AddSingleRow(builder, fontName, labelW, usableWidth - labelW, "联系电话", item.Phone);
AddSingleRow(builder, fontName, labelW, usableWidth - labelW, "电子邮箱", item.Email);
AddSingleLinkRow(builder, fontName, labelW, usableWidth - labelW, "官方网站", item.SiteUrl);
AddSingleLinkRow(builder, fontName, labelW, usableWidth - labelW, "最近三年动态", string.Join(", ", item.PostUrl.Select(p => p.Url)));
AddFullWidthRow(builder, fontName, labelW, usableWidth - labelW, "推荐等级", item.RecLevel);
AddFullWidthRow(builder, fontName, labelW, usableWidth - labelW, "经营范围", item.Scope);
AddFullWidthRow(builder, fontName, labelW, usableWidth - labelW, "对接建议", item.IntgAdvice);
// 表格样式
table.SetBorders(Aspose.Words.LineStyle.Single, 0.5, Color.FromArgb(230, 230, 230));
table.AutoFit(AutoFitBehavior.FixedColumnWidths);
table.AllowAutoFit = false;
table.PreferredWidth = PreferredWidth.FromPoints(usableWidth);
builder.EndTable();
builder.InsertParagraph();
builder.InsertParagraph();
}
// 保存逻辑
string fileName = $"{invAiInfo.InvName}_Professional.docx";
string filePath = Path.Combine(AppSettingsHelper.Get("InvitationAIAssistBasePath"), fileName);
doc.Save(filePath, Aspose.Words.SaveFormat.Docx);
return Ok(JsonView(true, "生成成功", new { Url = $"{AppSettingsHelper.Get("WordBaseUrl")}/{AppSettingsHelper.Get("InvitationAIAssistFtpPath")}/{fileName}" }));
}
#region 15.12 适配助手方法
private void AddSingleRow(DocumentBuilder builder, string font, double labelW, double contentW, string label, string value)
{
// 标签
builder.InsertCell();
builder.CellFormat.Width = labelW;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Right;
builder.Font.Name = font;
builder.Font.Size = 9;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(120, 120, 120);
builder.Write(label);
// 内容
builder.InsertCell();
builder.CellFormat.Width = contentW;
builder.CellFormat.HorizontalMerge = CellMerge.First;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Left;
builder.Font.Size = 10;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(60, 60, 60);
builder.Write(string.IsNullOrEmpty(value) ? "—" : value);
// 合并剩余列
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.EndRow();
builder.CellFormat.HorizontalMerge = CellMerge.None;
}
private void AddSingleLinkRow(DocumentBuilder builder, string font, double labelW, double contentW, string label, string url)
{
builder.InsertCell();
builder.CellFormat.Width = labelW;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Right;
builder.Font.Size = 9;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(120, 120, 120);
builder.Write(label);
builder.InsertCell();
builder.CellFormat.Width = contentW;
builder.CellFormat.HorizontalMerge = CellMerge.First;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Left;
if (!string.IsNullOrEmpty(url) && url.StartsWith("http"))
{
builder.Font.Size = 10;
builder.Font.Color = Color.FromArgb(0, 102, 204);
builder.Font.Underline = Underline.None;
builder.InsertHyperlink(url, url, false);
}
else
{
builder.Font.Color = Color.FromArgb(60, 60, 60);
builder.Write("—");
}
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.EndRow();
builder.CellFormat.HorizontalMerge = CellMerge.None;
}
private void AddFullWidthRow(DocumentBuilder builder, string font, double lw, double cw, string label, string value)
{
// 标签
builder.InsertCell();
builder.CellFormat.Width = lw;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Right;
builder.Font.Size = 9;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(120, 120, 120);
builder.Write(label);
// 内容
builder.InsertCell();
builder.CellFormat.Width = cw;
builder.CellFormat.HorizontalMerge = CellMerge.First;
builder.ParagraphFormat.Alignment = ParagraphAlignment.Left;
builder.Font.Size = 10;
builder.Font.Bold = false;
builder.Font.Color = Color.FromArgb(60, 60, 60);
builder.Write(string.IsNullOrEmpty(value) ? "—" : value);
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.InsertCell();
builder.CellFormat.HorizontalMerge = CellMerge.Previous;
builder.EndRow();
builder.CellFormat.HorizontalMerge = CellMerge.None;
}
#endregion
///
/// 商邀资料AI 生成邮件(SSE流式推送)
///
///
[HttpPost]
public async Task InvitationAIGenerateEmailStream([FromBody] InvitationAIGenerateEmailDto dto)
{
HttpContext.InitializeSse();
try
{
// 1. 基础校验与资源加载 (Progress: 5%)
if (dto.Id < 1 || dto.Guids == null || !dto.Guids.Any())
{
await HttpContext.SendSseStepAsync(-1, "请求参数不完整,请选择单位");
return;
}
var invAiInfo = await _sqlSugar.Queryable().Where(x => x.Id == dto.Id).FirstAsync();
if (invAiInfo?.AiCrawledDetails == null)
{
await HttpContext.SendSseStepAsync(-1, "基础商邀资料不存在");
return;
}
await HttpContext.SendSseStepAsync(10, "AI 正在分析考察团组背景与访问意图...");
// 2. 准备 AI 上下文数据 (Progress: 15%)
var clientInfoSources = invAiInfo.AiCrawledDetails.Where(x => dto.Guids.Contains(x.Guid)).ToList();
var clientInfosForAI = clientInfoSources.Select(x => new AICreateEmailInfo()
{
Guid = x.Guid,
NameCn = x.NameCn,
Scope = x.Scope
}).ToList();
var groupInfo = await _sqlSugar.Queryable()
.Where(x => x.IsDel == 0 && x.Id == invAiInfo.GroupId)
.Select(x => new { x.TeamName, x.VisitPurpose, x.VisitDate })
.FirstAsync();
string operatorName = await _sqlSugar.Queryable()
.Where(x => x.Id == dto.CurrUserId).Select(x => x.CnName).FirstAsync() ?? "-";
// 3. 构建 Prompt 并调用 AI (Progress: 25%)
await HttpContext.SendSseStepAsync(30, $"AI 正在为 {clientInfosForAI.Count} 家单位撰写定制化正式邮件...");
// 构建生成邮件的 Prompt
string pormpt = BuildHunyuanEmailPrompt(
invAiInfo.EntryInfo?.OriginUnit ?? "",
groupInfo?.VisitPurpose ?? "",
groupInfo?.VisitDate.ToString("yyyy-MM-dd") ?? "",
clientInfosForAI
);
// 调用 AI (此处为阻塞式等待 AI 结果,若混元支持 Stream 可进一步拆解)
string aiResponse = await _hunyuanService.ChatCompletionsHunyuan_t1_latestAsync(pormpt);
await HttpContext.SendSseStepAsync(80, "邮件初稿已生成,正在进行 HTML 格式校验与转义处理...");
// 4. 解析结果 (Progress: 85%)
var hunyuanAIEmailDatas = new List();
if (!string.IsNullOrWhiteSpace(aiResponse))
{
// 预处理:过滤 AI 可能返回的 Markdown 标记
string cleanJson = aiResponse.Trim();
if (cleanJson.StartsWith("```json"))
cleanJson = cleanJson.Substring(7, cleanJson.Length - 10).Trim();
else if (cleanJson.StartsWith("```"))
cleanJson = cleanJson.Substring(3, cleanJson.Length - 6).Trim();
try
{
// 解析并注入 Source 标识
hunyuanAIEmailDatas = JsonConvert.DeserializeObject>(cleanJson);
}
catch (JsonException ex)
{
// 记录日志并考虑 fallback 策略
_logger.LogError(ex, "Hunyuan AI 响应解析失败。原始数据:{Response}", aiResponse);
}
}
if (hunyuanAIEmailDatas == null || !hunyuanAIEmailDatas.Any())
{
await HttpContext.SendSseStepAsync(-1, "AI 格式解析失败,请尝试重新生成");
return;
}
// 5. 更新数据模型 (Progress: 90%)
foreach (var client in clientInfoSources)
{
var aiEmail = hunyuanAIEmailDatas.FirstOrDefault(x => x.Guid == client.Guid);
if (aiEmail != null)
{
client.EmailInfo.Status = 2; // 已生成
client.EmailInfo.EmailTitle = aiEmail.Subject;
client.EmailInfo.EmailContent = aiEmail.Content;
client.EmailInfo.Operator = operatorName;
client.EmailInfo.OperatedAt = DateTime.Now;
}
}
// 6. 数据库持久化 (Progress: 95%)
// 采用增量更新策略,避免直接 Where 过滤掉其他未选中的数据
var update = await _sqlSugar.Updateable(invAiInfo).UpdateColumns(x => x.AiCrawledDetails).ExecuteCommandAsync();
if (update > 0)
{
await HttpContext.SendSseStepAsync(100, "邮件全部生成完毕并已存入团组资料库", invAiInfo.AiCrawledDetails);
}
else
{
await HttpContext.SendSseStepAsync(-1, "数据库写入失败,请联系管理员");
}
}
catch (Exception ex)
{
_logger.LogError(ex, "邮件生成异常");
await HttpContext.SendSseStepAsync(-1, $"生成失败:{ex.Message}");
}
finally
{
await HttpContext.FinalizeSseAsync();
}
}
///
/// 混元邮件生成提示词构建
///
/// 出访单位
/// 出访室友/拜访目的
/// 出访时间
/// 需要生成邮件的客户信息列表
/// 最终构建的 System Prompt 字符串
private static string BuildHunyuanEmailPrompt(string originUnit, string objective,string visitDate, List clientInfosForAI)
{
return $@"
# Role
你是一位精通国际政企关系的【首席联络官】。你具备极强的行业分析能力,能通过 [SourceEntity] 的名称自动检索并推导其行政职能与行业地位,并以此撰写具有战略高度、语调优雅的正式商务邮件。
# Intelligence Task: Source Profiling
在生成邮件前,请先执行以下逻辑:
1. **职能推导**:基于 [SourceEntity] 的名称,自动识别其在所属领域的具体行政职能与政策影响力。
2. **战略对齐**:将其职能与全球大趋势(如:Sustainable Urbanization, Digital Transformation, Carbon Neutrality)挂钩,作为邮件第二段的叙事背景。
# [RICH_TEXT_STANDARDS_FOR_QUILL]
- **Prohibited Tags**: 绝对禁止包含 , , , ,
,