using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Authentication.Cookies;
using Microsoft.AspNetCore.Mvc.TagHelpers;
using Microsoft.AspNetCore.SignalR;
using Microsoft.International.Converters.PinYinConverter;
using NPOI.SS.Formula.PTG;
using OASystem.API.OAMethodLib.Hub.HubClients;
using OASystem.API.OAMethodLib.Hub.Hubs;
using OASystem.API.OAMethodLib.JuHeAPI;
using OASystem.API.OAMethodLib.SignalR.Hubs;
using OASystem.Domain;
using OASystem.Domain.Dtos.Financial;
using OASystem.Domain.Entities.Customer;
using OASystem.Domain.Entities.District;
using OASystem.Domain.Entities.Financial;
using OASystem.Domain.Entities.Groups;
using OASystem.Domain.Entities.PersonnelModule;
using OASystem.Domain.Entities.System;
using OASystem.Domain.ViewModels.Financial;
using OASystem.Domain.ViewModels.JuHeExchangeRate;
using OASystem.Domain.ViewModels.PersonnelModule;
using OASystem.Infrastructure.Repositories.CRM;
using OASystem.Infrastructure.Repositories.Groups;
using System.Collections;
using System.Collections.Generic;
using System.IdentityModel.Tokens.Jwt;
using System.Security.Claims;
using static OpenAI.GPT3.ObjectModels.SharedModels.IOpenAiModels;
namespace OASystem.API.OAMethodLib
{
public static class GeneralMethod
{
//团组信息
private readonly static DelegationInfoRepository _dirRep = AutofacIocManager.Instance.GetService<DelegationInfoRepository>();
private readonly static TeamRateRepository _teamRateRep = AutofacIocManager.Instance.GetService<TeamRateRepository>();
private readonly static IJuHeApiService _juHeApiService = AutofacIocManager.Instance.GetService<IJuHeApiService>();
private readonly static SetDataRepository _setDataRep = AutofacIocManager.Instance.GetService<SetDataRepository>();
private readonly static TableOperationRecordRepository _tableOperationRecordRep = AutofacIocManager.Instance.GetService<TableOperationRecordRepository>();
private readonly static MessageRepository _messageRep = AutofacIocManager.Instance.GetService<MessageRepository>();
private readonly static IHubContext<ChatHub, IChatClient> _hubContext = AutofacIocManager.Instance.GetService<IHubContext<ChatHub, IChatClient>>();
#region 消息
/// <summary>
/// 消息 发布And 通知
/// </summary>
/// <param name="msgTypeEnum">
/// 消息类型
/// 1 公告通知
/// 2 团组流程管控通知
/// 3 团组业务操作通知
/// 4 团组费用审核消息
/// 5 团组签证进度通知
/// 6 团组任务进度通知
/// </param>
/// <param name="title">消息标题</param>
/// <param name="content">消息内容</param>
/// <param name="userIds"></param>
/// <param name="diId">团组id</param>
/// <returns></returns>
public static async Task<bool> MessageIssueAndNotification(MessageTypeEnum msgTypeEnum,string title,string content, List<int> userIds,int diId = 0)
{
MessageDto messageDto = new()
{
Type = msgTypeEnum,
IssuerId = 4,//管理员
DiId = diId,
Title = title,
Content = content,
ReleaseTime = DateTime.Now,
UIdList = userIds
};
var status = await _messageRep.AddMsg(messageDto);//添加消息
if (status)
{
//给在线在用户发送消息
List<string> connIds = UserStore.OnlineUser.Where(it => userIds.Contains(it.UserId)).Select(it => it.ConnectionId).ToList();
string notificationTypeStr1 = GetMsgNotificationType(msgTypeEnum);
string notificationTypeStr = JsonConvert.SerializeObject(
new
{
UserIds = userIds,
Msg = $"您有一条{notificationTypeStr1}相关的消息!"
}
);
await _hubContext.Clients.Clients(connIds).ReceiveMessage($"您有一条{notificationTypeStr1}相关的消息!");
return true;
}
return false;
}
/// <summary>
/// 根据消息类型 获取 消息通知类型
/// </summary>
/// <returns></returns>
public static string GetMsgNotificationType(MessageTypeEnum msgTypeEnum)
{
int notificationType = 0;
string notificationStr = "";
List<NotificationTypeView> notificationTypeViews = AppSettingsHelper.Get<NotificationTypeView>("MessageNotificationType");
notificationType = notificationTypeViews.Where(it => it.MsgTypeIds.Contains((int)msgTypeEnum)).Select(it => it.TypeId).FirstOrDefault();
if (notificationType == 1) notificationStr = "操作";
else if (notificationType == 2) notificationStr = "任务";
return notificationStr;
}
public class NotificationTypeView
{
/// <summary>
/// 通知类型
/// 1 操作通知
/// 2 任务通知
/// </summary>
public int TypeId { get; set; }
/// <summary>
/// 消息类型id
/// </summary>
public List<int> MsgTypeIds { get; set; }
}
#endregion
#region md5 加密
/// <summary>
/// MD5加密,和动网上的16/32位MD5加密结果相同,
/// 使用的UTF8编码
/// </summary>
/// <param name="source">待加密字串</param>
/// <param name="length">16或32值之一,其它则采用.net默认MD5加密算法</param>
/// <returns>加密后的字串</returns>
public static string Encrypt(string source, int length = 32)
{
if (string.IsNullOrWhiteSpace(source))
return string.Empty;
HashAlgorithm hashAlgorithm = CryptoConfig.CreateFromName("MD5") as HashAlgorithm;
byte[] bytes = Encoding.UTF8.GetBytes(source);
byte[] hashValue = hashAlgorithm.ComputeHash(bytes);
StringBuilder sb = new StringBuilder();
switch (length)
{
case 16://16位密文是32位密文的9到24位字符
for (int i = 4; i < 12; i++)
{
sb.Append(hashValue[i].ToString("x2"));
}
break;
case 32:
for (int i = 0; i < 16; i++)
{
sb.Append(hashValue[i].ToString("x2"));
}
break;
default:
for (int i = 0; i < hashValue.Length; i++)
{
sb.Append(hashValue[i].ToString("x2"));
}
break;
}
return sb.ToString();
}
#endregion
#region jwt
/// <summary>
/// 获取token
/// </summary>
/// <param name="_config"></param>
/// <param name="Number"></param>
/// <param name="exp"></param>
/// <returns></returns>
public static async Task<string> GetToken(IConfiguration _config, string Number, int uId, string uName, DateTime exp)
{
string userId = Guid.NewGuid().ToString().Replace("-", "");
var claims = new[] {
new Claim(ClaimTypes.NameIdentifier, uName),
new Claim(ClaimTypes.NameIdentifier, uId.ToString()),
new Claim(ClaimTypes.NameIdentifier, userId),
new Claim("Number",Number)
};
var key = new SymmetricSecurityKey(Encoding.UTF8.GetBytes(_config["JwtSecurityKey"]));
var creds = new SigningCredentials(key, SecurityAlgorithms.HmacSha256);
var token = new JwtSecurityToken(
issuer: "OASystem.com",
audience: "OASystem.com",
claims: claims,
expires: exp,
signingCredentials: creds);
var indentity = new ClaimsIdentity(claims, "formlogin");
var principal = new ClaimsPrincipal(indentity);
// await _httpContext.SignInAsync (CookieAuthenticationDefaults.AuthenticationScheme, principal);
return new JwtSecurityTokenHandler().WriteToken(token);
}
#endregion
#region 数据类型转换
/// <summary>
/// object 转 Int
/// </summary>
/// <param name="obj"></param>
/// <returns></returns>
public static int GetInt(this object obj)
{
if (obj == null)
return 0;
int _number = 0;
bool reslut = Int32.TryParse(obj.ToString(), out _number);
return _number;
}
private static DateTime dateStart = new DateTime(1970, 1, 1, 8, 0, 0);
private static long longTime = 621355968000000000;
private static int samllTime = 10000000;
/// <summary>
/// 时间戳 转 datetime
/// </summary>
/// <param name="timeStamp"></param>
/// <returns></returns>
public static DateTime GetTimeSpmpToDate(this object timeStamp)
{
if (timeStamp == null) return dateStart;
DateTime dateTime = new DateTime(longTime + Convert.ToInt64(timeStamp) * samllTime, DateTimeKind.Utc).ToLocalTime();
return dateTime;
}
#endregion
#region 用户页面操作功能 权限
/// <summary>
/// 用户页面操作功能(可使用)
/// </summary>
/// <param name="userId">用户Id</param>
/// <param name="PageId">页面Id</param>
/// <returns></returns>
public static async Task<PageFunAuthViewBase> PostUserPageFuncDatas(int userId,int PageId)
{
PageFunAuthViewBase pageFunAuth = new PageFunAuthViewBase();
List<UserPageFuncView> userPageFuncDatas = new List<UserPageFuncView>();
string sql = string.Format(@"Select ua.UId As UserId, u.CnName As UserName, pa.ModuleId,pa.ModuleName,pa.PageId,pa.PageName,pa.PageIsEnable,
pa.PagePhoneIsEnable,pa.FuncId,pa.FuncName,pa.FuncIsEnable
From Sys_UserAuthority ua
Left Join Sys_Users u On ua.UId = u.Id
Left Join (
Select sd.Id As ModuleId,sd.Name As ModuleName, smp.Id As PageId,smp.Name As PageName,smp.IsEnable As PageIsEnable,
smp.phoneIsEnable As PagePhoneIsEnable,pfp.Id As FuncId,pfp.FunctionName As FuncName,pfp.IsEnable As FuncIsEnable
From Sys_SystemMenuAndFunction smaf
Left Join Sys_SystemMenuPermission smp On smaf.SmId = smp.Id
Left Join Sys_SetData sd On sd.STid = 5 And smp.Mid = sd.Id
Left Join Sys_PageFunctionPermission pfp On smaf.FId = pfp.Id
Where smaf.IsDel = 0 And smp.IsDel = 0 And pfp.IsDel = 0 And sd.IsDel = 0 And smp.IsEnable = 1
) As pa On ua.SmId = pa.PageId And ua.FId = pa.FuncId
Where ua.IsDel = 0 And ua.UId = {0} And pa.PageId = {1}
Order By ModuleId,PageId,FuncId Asc", userId, PageId);
userPageFuncDatas = await _dirRep._sqlSugar.SqlQueryable<UserPageFuncView>(sql).ToListAsync();
if (userPageFuncDatas.Count <= 0)
{
return pageFunAuth;
}
UserPageFuncView userPageFunc = new UserPageFuncView();
//查询 1
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 1).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.CheckAuth = 1;
//删除 2
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 2).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.DeleteAuth = 1;
//编辑 3
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 3).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.EditAuth = 1;
//下载 4
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 4).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.FilesDownloadAuth = 1;
//上传 5
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 5).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.FilesUploadAuth = 1;
//添加 11
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 11).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.AddAuth = 1;
//审核 12
userPageFunc = userPageFuncDatas.Where(it => it.FuncId == 12).FirstOrDefault();
if (userPageFunc != null) pageFunAuth.AuditAuth = 1;
return pageFunAuth;
}
#endregion
#region 业务模块 团组权限
/// <summary>
/// 业务模块 团组操作权限
/// 验证
/// </summary>
/// <param name="diId">团组Id</param>
/// <param name="userId">用户Id</param>
/// <param name="CTable">业务模块Id</param>
/// <returns></returns>
public static async Task<Result> PostGroupOperationAuth(int diId, int userId, int CTable )
{
Result _result = new Result { Code = -1,Msg = "No Operation Authorty!" };
if (CTable < 1)
{
_result.Msg = "请填写正确的用户Id!";
return _result;
}
var data = await _dirRep._sqlSugar.Queryable<Grp_GroupsTaskAssignment>().Where(it => it.DIId == diId && it.UId == userId && it.CTId == CTable && it.IsDel == 0).FirstAsync();
if (data == null)
{
_result.Msg = "你没有本团下的该业务模块操作,请联系主管分配操作权限!";
}
else
{
_result.Code = 0;
}
return _result;
}
#endregion
#region 团组相关
#region 建团按国家默认添加汇率 / 默认权限分配
/// <summary>
/// 团组汇率
/// 建团时 添加基础汇率 CNY
/// 按国家 添加 默认币种
/// </summary>
/// <param name="userId"></param>
/// <param name="diId"></param>
/// <returns></returns>
public static async Task<Result> PostGroupRateAddInit(int userId, int diId)
{
Result result = new() { Code = -2 };
if (userId < 0)
{
result.Msg = string.Format(@"请传入正确的userId");
return result;
}
if (diId < 0)
{
result.Msg = string.Format(@"请传入正确的DiId");
return result;
}
//美元(USD):1.0000|欧元(EUR):1.0000|墨西哥比索(MXN):1.0000
string CNYInit = string.Format(@"人名币(CNY):1.0000");
var gropInfo = await _dirRep._sqlSugar.Queryable<Grp_DelegationInfo>().Where( it => it.IsDel == 0 && it.Id == diId).FirstAsync();
if (gropInfo != null)
{
if (!string.IsNullOrEmpty(gropInfo.VisitCountry))
{
var countryCueencyCodes = await _setDataRep.GetSetDataBySTId(_setDataRep, 66);
string countrys = gropInfo.VisitCountry;
string[] countryItems = new string[] { };
if (countrys.Contains("|"))
{
countryItems = countrys.Split('|');
}
else
{
countryItems = new string[] { countrys };
}
var countryInfos = await _dirRep._sqlSugar.Queryable<Dis_Country>().Where(it => it.IsDel == 0).ToListAsync();
List<string> currencyCodes = new List<string>();
if (countryItems.Length > 0)
{
foreach (var item in countryItems)
{
Dis_Country country = new Dis_Country();
country = countryInfos.Where(it => it.CnShortName.Equals(item)).FirstOrDefault();
if (country != null)
{
if (!item.Equals("中国"))
{
currencyCodes.Add(country.CurrencyCode);
}
}
}
}
if (currencyCodes.Count > 0)
{
List<ExchangeRateModel> exchangeRateModels = await _juHeApiService.PostItemRateAsync(currencyCodes.ToArray());
if (exchangeRateModels.Count > 0)
{
var codes = await _dirRep._sqlSugar.Queryable<Sys_SetData>().Where(it => it.IsDel == 0 && it.IsDel == 0).ToListAsync();
for (int i = 0; i < exchangeRateModels.Count; i++)
{
string currencyName = exchangeRateModels[i].Name;
string code = "";
var currencyData = codes.Where(it => it.IsDel == 0 && it.Remark == currencyName).FirstOrDefault();
if (currencyData != null) {
code = currencyData.Name;
CNYInit += string.Format(@"|{0}({1}):{2}", exchangeRateModels[i].Name, code, exchangeRateModels[i].MSellPri);
}
}
}
}
}
}
List<Grp_TeamRate> grp_TeamRates = new List<Grp_TeamRate>()
{
new Grp_TeamRate(){ DiId = diId,CTable = 76,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //76 酒店预订
new Grp_TeamRate(){ DiId = diId,CTable = 77,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //77 行程
new Grp_TeamRate(){ DiId = diId,CTable = 79,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //79 车/导游地接
new Grp_TeamRate(){ DiId = diId,CTable = 80,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //80 签证
new Grp_TeamRate(){ DiId = diId,CTable = 82,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //82 团组客户保险
new Grp_TeamRate(){ DiId = diId,CTable = 85,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //85 机票预订
new Grp_TeamRate(){ DiId = diId,CTable = 98,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //98 其他款项
new Grp_TeamRate(){ DiId = diId,CTable = 285,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //285 收款退还
new Grp_TeamRate(){ DiId = diId,CTable = 751,Remark = CNYInit,CreateUserId = userId, IsDel = 0 }, //751 酒店早餐
};
var res = _teamRateRep._sqlSugar.Insertable(grp_TeamRates).ExecuteCommand();
if (res < 0)
{
result.Msg = string.Format(@"添加失败!");
return result;
}
result.Code = 0;
result.Msg = string.Format(@"操作成功!");
return result;
}
/// <summary>
/// 团组汇率
/// 建团时 默认按照岗位分配权限
/// </summary>
/// <param name="userId"></param>
/// <param name="diId"></param>
/// <param name="companyId"></param>
/// <returns></returns>
public static async Task<Result> PostGroupAuthAddInit(int userId, int diId, int companyId = 2)
{
Result result = new() { Code = -2 };
if (userId < 0)
{
result.Msg = string.Format(@"请传入正确的userId");
return result;
}
if (companyId < 0)
{
result.Msg = string.Format(@"请传入正确的companyId");
return result;
}
if (diId < 0)
{
result.Msg = string.Format(@"请传入正确的DiId");
return result;
}
//var depData = await _teamRateRep._sqlSugar.Queryable<Sys_Department>().Where(it => it.IsDel == 0 && it.CompanyId == companyId && it.DepName.Equals("国交部")).FirstAsync();
//if (depData != null)
//{
// var userData = await _teamRateRep._sqlSugar.Queryable<Sys_Users>().Where(it => it.IsDel == 0 && it.CompanyId == companyId && it.DepId == depData.Id).ToListAsync();
//}
result.Code = 0;
result.Msg = string.Format(@"操作成功!");
return result;
}
#endregion
#endregion
#region 团组汇率
/// <summary>
/// 团组汇率
/// 获取板块 币种 及 汇率
/// 76 酒店预订 77 行程 79 车/导游地接
/// 80 签证 82 团组客户保险 85 机票预订
/// 98 其他款项 285 收款退还
/// </summary>
/// <param name="teamRateModels"></param>
/// <param name="cTable"></param>
/// <param name="currencyCode"></param>
/// <returns>
/// string
/// eg: CNY 1.0000
/// </returns>
public static async Task<string> PostGroupRateByCTableAndCurrency(List<TeamRateModelView> teamRateModels,int cTable,List<string> currencyCodes)
{
string str = "";
List<string> currencyRates = new List<string>();
TeamRateModelView hotelRateData = teamRateModels.Where(it => it.CTableId == cTable).FirstOrDefault();
if (hotelRateData != null)
{
var hotelRates = hotelRateData.TeamRates;
foreach (var item in currencyCodes)
{
if (!string.IsNullOrEmpty(item))
{
var hotelRateInfo = hotelRates.Where(it => it.CurrencyCode.Equals(item)).FirstOrDefault();
if (hotelRateInfo != null)
{
string str1 = string.Format("{0} {1}\r\n", hotelRateInfo.CurrencyCode, hotelRateInfo.Rate);
currencyRates.Add(str1);
}
}
}
if (currencyRates != null || currencyRates.Count > 0)
{
currencyRates = currencyRates.Distinct().ToList();
foreach (var item in currencyRates)
{
str += item;
}
}
}
return str;
}
#endregion
#region 汉字转换拼音
private static Dictionary<int, List<string>> GetTotalPingYinDictionary(string text)
{
var chs = text.ToCharArray();
//记录每个汉字的全拼
Dictionary<int, List<string>> totalPingYinList = new Dictionary<int, List<string>>();
for (int i = 0; i < chs.Length; i++)
{
var pinyinList = new List<string>();
//是否是有效的汉字
if (ChineseChar.IsValidChar(chs[i]))
{
ChineseChar cc = new ChineseChar(chs[i]);
pinyinList = cc.Pinyins.Where(p => !string.IsNullOrWhiteSpace(p)).ToList();
}
else
{
pinyinList.Add(chs[i].ToString());
}
//去除声调，转小写
pinyinList = pinyinList.ConvertAll(p => Regex.Replace(p, @"\d", "").ToLower());
//去重
pinyinList = pinyinList.Where(p => !string.IsNullOrWhiteSpace(p)).Distinct().ToList();
if (pinyinList.Any())
{
totalPingYinList[i] = pinyinList;
}
}
return totalPingYinList;
}
/// <summary>
/// 获取汉语拼音全拼
/// </summary>
/// <param name="text">The string.</param>
/// <returns></returns>
public static List<string> GetTotalPingYin(this string text)
{
var result = new List<string>();
foreach (var pys in GetTotalPingYinDictionary(text))
{
var items = pys.Value;
if (result.Count <= 0)
{
result = items;
}
else
{
//全拼循环匹配
var newTotalPingYinList = new List<string>();
foreach (var totalPingYin in result)
{
newTotalPingYinList.AddRange(items.Select(item => totalPingYin + item));
}
newTotalPingYinList = newTotalPingYinList.Distinct().ToList();
result = newTotalPingYinList;
}
}
return result;
}
/// <summary>
/// 获取汉语拼音首字母
/// </summary>
/// <param name="text"></param>
/// <returns></returns>
public static List<string> GetFirstPingYin(this string text)
{
var result = new List<string>();
foreach (var pys in GetTotalPingYinDictionary(text))
{
var items = pys.Value;
if (result.Count <= 0)
{
result = items.ConvertAll(p => p.Substring(0, 1)).Distinct().ToList();
}
else
{
//首字母循环匹配
var newFirstPingYinList = new List<string>();
foreach (var firstPingYin in result)
{
newFirstPingYinList.AddRange(items.Select(item => firstPingYin + item.Substring(0, 1)));
}
newFirstPingYinList = newFirstPingYinList.Distinct().ToList();
result = newFirstPingYinList;
}
}
return result;
}
#endregion
#region 新客户资料表 操作记录
/// <summary>
/// 新客户资料表
/// 操作记录添加
/// </summary>
/// <param name="portType"></param>
/// <param name="operationEnum"></param>
/// <param name="userId"></param>
/// <param name="dataId"></param>
/// <param name="remark"></param>
/// <returns></returns>
public static async Task<bool> NewClientOperationRecord(int portType, OperationEnum operationEnum,int userId,int dataId,string remark )
{
Crm_TableOperationRecord _TableOperationRecord = new Crm_TableOperationRecord()
{
TableName = "Crm_NewClientData",
PortType = portType,
OperationItem = operationEnum,
DataId = dataId,
CreateUserId = userId,
CreateTime = DateTime.Now,
Remark = remark
};
bool add = await _tableOperationRecordRep._Add(_TableOperationRecord);
if (add) return false;
return false;
}
#endregion
}
}