// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
|
//
|
// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
|
//
|
// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
|
|
using Admin.NET.Core;
|
using Admin.NET.Core.Service;
|
using Aop.Api.Domain;
|
using Dm.util;
|
using Furion;
|
using Furion.DependencyInjection;
|
using Furion.DynamicApiController;
|
using Furion.FriendlyException;
|
using FZCTB.NET.API.Application.Auth;
|
using FZCTB.NET.API.Application.Auth.DTO;
|
using FZCTB.NET.API.Application.User.DTO;
|
using FZCZTB.Net.CustomerSYSTem;
|
using FZCZTB.NET.MD.ConfigMd;
|
using FZCZTB.NET.MD.CutomerMd;
|
using FZCZTB.NET.MD.CutomerMd.Extend;
|
using FZCZTB.NET.SYSService.CustomerSYS;
|
using Lazy.Captcha.Core.Generator.Image.Gif;
|
using Mapster;
|
using MapsterMapper;
|
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Mvc;
|
using Microsoft.AspNetCore.Mvc.ViewComponents;
|
using NewLife;
|
using OfficeOpenXml.FormulaParsing.ExpressionGraph.FunctionCompilers;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using static QRCoder.PayloadGenerator;
|
|
namespace FZCTB.NET.API.Application.User;
|
/// <summary>
|
/// 客户控制
|
/// </summary>
|
[ApiDescriptionSettings("FZCAPISYS", Order = 149)]
|
public class CustomerService: IDynamicApiController,IScoped
|
{
|
private readonly CustomerManagerS _customerManager;
|
|
private readonly SysCacheService _sysCacheService;
|
private readonly SqlSugarRepository<FBS_ExRole> _fBS_ExRoleRep;
|
private readonly SqlSugarRepository<FBS_CoutomerExRole> _fBS_CustomerExRoleRep;
|
private readonly SqlSugarRepository<FBS_EnterpriseType> _fBS_EnterpriseTypeRep;
|
private readonly SqlSugarRepository<FBS_Customer> _fBS_CustomerRep;
|
private readonly SqlSugarRepository<FBS_CustormerUsers> _fBS_CustormerUsersRep;
|
|
/// <summary>
|
/// 用户扩展
|
/// </summary>
|
private readonly SqlSugarRepository<FBS_CusExtend> _fBS_CusExtendRep;
|
|
private IMapper _mapper;
|
/// <summary>
|
///
|
/// </summary>
|
public CustomerService(SysCacheService cacheService, CustomerManagerS managerS,SqlSugarRepository<FBS_Customer> repository
|
, SqlSugarRepository<FBS_EnterpriseType> fbsenrep,IMapper mapper,
|
SqlSugarRepository<FBS_ExRole> exroles ,
|
SqlSugarRepository<FBS_CusExtend> cusrep,
|
SqlSugarRepository<FBS_CoutomerExRole> cexrrep
|
, SqlSugarRepository<FBS_CustormerUsers> cusUser
|
)
|
{
|
_sysCacheService= cacheService;
|
_customerManager = managerS;
|
_fBS_CustomerRep = repository;
|
_fBS_EnterpriseTypeRep = fbsenrep;
|
_fBS_ExRoleRep = exroles;
|
_fBS_CusExtendRep = cusrep;
|
_mapper = mapper;
|
_fBS_CustomerExRoleRep = cexrrep;
|
_fBS_CustormerUsersRep = cusUser;
|
|
}
|
|
/// <summary>
|
/// 用户注册
|
/// </summary>
|
/// <returns></returns>
|
[AllowAnonymous]
|
[HttpPost]
|
public async Task<string> CustomerRegistration(FBS_CusExtendVm param )
|
{
|
//_customerManager.
|
var ExRole= (await _customerManager.GetExRole()).Where(x => x.Code == param.ExRoleCode).FirstOrDefault();
|
|
if(ExRole==null)
|
{
|
throw Oops.Oh("请选择一个有效的角色进行注册");
|
}
|
|
// //已选角色，请选择一个注册角色
|
//var data= await _fBS_CustomerRep.AsQueryable().Includes(X => X.CoutomerExRols,y=>y.ExRole).Where(x => x.Account == param.Account).FirstAsync();
|
// if (data != null)
|
// {
|
// if (data.CoutomerExRols.Any(x => x.ExRole.Code == param.ExRoleCode))
|
// {
|
// throw Oops.Oh("已经注册了该角色请勿重复注册");
|
// }
|
|
// else
|
// {
|
// throw Oops.Oh("该用户名重复，如果需要对该用户添加相应角色，请登录任意角色后添加");
|
// }
|
|
// }
|
|
|
var vcode= _sysCacheService.Get<string>($"{CacheConst.KeyPhoneVerCode}{param.OperatorPhone}");
|
if(param.PhoneVCode!="TEST")
|
if(vcode!=param.PhoneVCode)
|
{
|
//手机验证码错误
|
throw Oops.Oh("手机验证码错误，请输入正确的手机验证码");
|
}
|
|
|
//使用后立即删除
|
_sysCacheService.Remove($"{CacheConst.KeyPhoneVerCode}{param.OperatorPhone}");
|
|
|
var cusex = await _fBS_CusExtendRep.GetFirstAsync(x => x.UnifiedSocialCreditCode == param.UnifiedSocialCreditCode);
|
if(cusex!=null)
|
{
|
throw Oops.Oh("该企业已经注册");
|
}
|
var dd = param.Adapt<FBS_CusExtend>();
|
|
dd.TransactionCode = param.ExRoleCode;
|
|
dd.CreateTime = DateTime.Now;
|
dd.CreateUserId = 0;
|
dd.CreateUserName = "用户注册";
|
await _fBS_CusExtendRep.AsTenant().BeginTranAsync();
|
try
|
{
|
dd = await _fBS_CusExtendRep.InsertReturnEntityAsync(dd);
|
|
FBS_CoutomerExRole rulse = new FBS_CoutomerExRole
|
{
|
CusExtendId = dd.Id,
|
ExRoleId = ExRole.Id ?? 0,
|
steps = CusExtendStep.UNExamine
|
|
|
};
|
await _fBS_CustomerExRoleRep.InsertAsync(rulse);
|
|
FBS_CustormerUsers user = new FBS_CustormerUsers
|
{
|
CusExtendId = dd.Id,
|
PhoneNumber = dd.OperatorPhone,
|
IsEn = true,
|
IsManager = true,
|
JobTitle = param.JobTitle,
|
Name = dd.OperatorName,
|
Nickname = param.Nickname,
|
CreateTime = dd.CreateTime,
|
CreateUserId = 0,
|
CreateUserName = "用户注册",
|
|
};
|
await _fBS_CustormerUsersRep.InsertAsync(user);
|
|
await _fBS_CusExtendRep.AsTenant().CommitTranAsync();
|
|
return "注册成功";
|
}
|
catch (Exception)
|
{
|
await _fBS_CusExtendRep.AsTenant().RollbackTranAsync();
|
throw;
|
};
|
|
|
|
|
|
|
|
|
|
|
}
|
/// <summary>
|
/// 注册登录可选角色
|
/// </summary>
|
/// <returns></returns>
|
[AllowAnonymous]
|
public async Task<List< ExRoleVM>> GetExRole()
|
{
|
return await _customerManager.GetExRole();
|
}
|
/// <summary>
|
/// 获取企业类型
|
/// </summary>
|
/// <returns></returns>
|
[AllowAnonymous]
|
public async Task<List<EnterpriseTypeVM>> EnterpriseTypes()
|
{
|
return await _fBS_EnterpriseTypeRep.AsQueryable().Select<EnterpriseTypeVM>().ToTreeAsync(x=>x.Child,x=>x.ParentId,0,x=>x.Id);
|
}
|
|
/// <summary>
|
/// 注册角色用户资料
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet]
|
public async Task<bool> CreaterExRolsInformation(string RuleCode)
|
{
|
|
var id = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
var user=await _customerManager.GetCustomer(id);
|
if(user==null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
var data = await _fBS_ExRoleRep.AsQueryable().ToListAsync();
|
var rols= await _fBS_ExRoleRep.GetFirstAsync(x => x.Code == RuleCode && x.Status == StatusEnum.Enable);
|
if(rols==null)
|
{
|
throw Oops.Oh("交易主体不存在");
|
}
|
var ExRoles = await _fBS_CustomerExRoleRep.GetListAsync(x => x.CusExtendId == user.CusExtendId);
|
if (ExRoles != null)
|
{
|
if (ExRoles?.Any(x => x.ExRoleId == rols.Id ) == true)
|
{
|
throw Oops.Oh("用户已经注册了该主体");
|
}
|
|
}
|
|
//增加用户角色
|
await _fBS_CustomerExRoleRep.InsertAsync(new FBS_CoutomerExRole
|
{
|
ExRoleId = rols.Id,
|
CusExtendId = user.CusExtendId,
|
steps= CusExtendStep.UNExamine,
|
});
|
|
|
|
|
return true;
|
|
|
|
|
}
|
/// <summary>
|
/// 获取 个人中心数据？
|
/// </summary>
|
[HttpPost]
|
public async Task<CusExtendDto> GetCusExtendInfo()
|
{
|
var id = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
//
|
var typeCode = App.User.FindFirst(ClaimConst.CustomerLogoinType)?.Value ;
|
if (typeCode == null)
|
{
|
throw Oops.Oh("登录交易主体错误");
|
|
}
|
var user = await _customerManager.GetCustomer(id);
|
if (user == null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
var rols = await _fBS_ExRoleRep.GetFirstAsync(x => x.Code == typeCode && x.Status == StatusEnum.Enable);
|
if (rols == null)
|
{
|
throw Oops.Oh("登录交易主体无效");
|
}
|
|
|
return await _fBS_CusExtendRep.AsQueryable().Where(x => x.Id == user.CusExtendId).Includes(x => x.ExRoles, y => y.ExRole).Select(x => new CusExtendDto
|
{
|
ExRoles = x.ExRoles.Adapt<List<FBS_CoutomerExRoleOutput>>()
|
}, true).FirstAsync();
|
|
|
}
|
|
/// <summary>
|
/// 修改个人中心数据
|
/// </summary>
|
[HttpPost]
|
public async Task<bool> ChangeCusExtend(CusExtendDto InParam)
|
{
|
var id = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
//
|
var typeCode = App.User.FindFirst(ClaimConst.CustomerLogoinType)?.Value;
|
if (typeCode == null)
|
{
|
throw Oops.Oh("登录交易主体错误");
|
|
}
|
var user = await _customerManager.GetCustomer(id);
|
if (user == null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
var rols = await _fBS_ExRoleRep.GetFirstAsync(x => x.Code == typeCode && x.Status == StatusEnum.Enable);
|
if (rols == null)
|
{
|
throw Oops.Oh("登录交易主体无效");
|
}
|
var tab = await _fBS_CusExtendRep.GetFirstAsync(x => x.Id == user.CusExtendId );
|
if (tab == null)
|
{
|
throw Oops.Oh("没有完成信息录入");
|
}
|
|
bool isChangeData = false;
|
|
|
|
//法人
|
if (tab.LegalRepresentativeIdCard != InParam.LegalRepresentativeIdCard)
|
{
|
tab.LegalRepresentativeIdCard = InParam.LegalRepresentativeIdCard;
|
tab.LegalRepresentativeIdNumber = InParam.LegalRepresentativeIdNumber;
|
tab.LegalRepresentativeName = InParam.LegalRepresentativeName;
|
tab.LegalRepresentativePhone = InParam.LegalRepresentativePhone;
|
//重新审核?
|
isChangeData=true;
|
}
|
|
|
//企业信息
|
if (tab.BusinessLicense != InParam.BusinessLicense)
|
{
|
tab.EstablishmentTime = tab.EstablishmentTime;
|
tab.RegisteredCapital = tab.RegisteredCapital;
|
tab.Residence = tab.Residence;
|
tab.MainBusiness = InParam.MainBusiness;
|
|
tab.EnterpriseName = InParam.EnterpriseName;
|
tab.BusinessLicense = InParam.BusinessLicense;
|
//重新审核?
|
isChangeData = true;
|
}
|
if (tab.EnterpriseType != InParam.EnterpriseType)
|
{
|
tab.EnterpriseType = InParam.EnterpriseType;
|
|
}
|
|
//联系电话
|
tab.EnterprisePhone = InParam.EnterprisePhone;
|
tab.EnterpriseEmail = InParam.EnterpriseEmail;
|
|
if (tab.BankAccount != InParam.BankAccount)
|
{
|
|
tab.BankAccount = InParam.BankAccount;
|
isChangeData = true;
|
|
}
|
if (tab.BankName != InParam.BankName)
|
{
|
tab.BankName = InParam.BankName;
|
isChangeData = true;
|
}
|
//银行是否需要修改
|
//tab.BankAccount = InParam.BankAccount;
|
//tab.BankName = InParam.BankName;
|
|
// 经办人
|
if (tab.OperatorIdCard != InParam.OperatorIdCard)
|
{
|
tab.OperatorIdCard = InParam.OperatorIdCard;
|
|
tab.OperatorIdNumber = InParam.OperatorIdNumber;
|
tab.OperatorName = InParam.OperatorName;
|
tab.OperatorPhone = InParam.OperatorPhone;
|
isChangeData = true;
|
}
|
|
|
await _fBS_CusExtendRep.AsTenant().BeginTranAsync();
|
try
|
{
|
if(!isChangeData)
|
{
|
//是更改，需要更该所有roles的值
|
var exrolerep= await _fBS_CustomerExRoleRep.GetListAsync(x=>x.CusExtendId==user.CusExtendId);
|
foreach (var item in exrolerep)
|
{
|
|
item.steps = CusExtendStep.Change;
|
|
|
}
|
await _fBS_CustomerExRoleRep.UpdateRangeAsync(exrolerep);
|
}
|
|
await _fBS_CusExtendRep.UpdateAsync(tab);
|
await _fBS_CusExtendRep.AsTenant().CommitTranAsync();
|
|
}
|
catch (Exception)
|
{
|
await _fBS_CusExtendRep.AsTenant().RollbackTranAsync();
|
throw;
|
}
|
|
return true;
|
|
}
|
|
|
/// <summary>
|
/// 获取账户列表
|
/// </summary>
|
/// <returns></returns>
|
[HttpGet]
|
public async Task<List<FBS_CustormerUsersOutput> > GetCustormerUsersList()
|
{
|
var id = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
if (!await isManger())
|
throw Oops.Oh("用户没有权限");
|
return (await _fBS_CustormerUsersRep.GetListAsync(x => x.CusExtendId == id)).Adapt<List<FBS_CustormerUsersOutput>>();
|
}
|
public FBS_CustormerUsers? ThisUser { get; set; }
|
/// <summary>
|
/// 新建员工数据
|
/// </summary>
|
/// <returns></returns>
|
[HttpPost]
|
public async Task<bool> CreatCustormerUsers(FBS_CustormerUsersVM param)
|
{
|
if (!await isManger())
|
throw Oops.Oh("用户没有权限");
|
var cid = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (cid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
var count = await _fBS_CustormerUsersRep.CountAsync(x=>x.CusExtendId== cid);
|
if(count>10)
|
{
|
throw Oops.Oh("同一组织机构最多可以建立10个用户");
|
}
|
|
var User = await _fBS_CustormerUsersRep.GetFirstAsync(x => x.CusExtendId == cid && x.PhoneNumber == param.PhoneNumber);
|
if(User!=null)
|
{
|
throw Oops.Oh("同一家公司账户不能同时出现相同的电话号码");
|
}
|
|
User = param.Adapt<FBS_CustormerUsers>();
|
User.CusExtendId = cid;
|
User.IsManager = false;
|
User.CreateTime = DateTime.Now;
|
User.CreateUserName ="企业用户:"+ ThisUser?.Name;
|
User.CreateUserId = ThisUser?.Id;
|
return await _fBS_CustormerUsersRep.InsertAsync(User);
|
|
|
|
|
}
|
/// <summary>
|
/// 更改管理员
|
/// </summary>
|
/// <param name="CustormerUserId"> UserList 的ID</param>
|
/// <returns></returns>
|
[HttpGet]
|
public async Task<bool> ChangeManager(long CustormerUserId )
|
{
|
if (!await isManger())
|
throw Oops.Oh("用户没有权限");
|
var cid = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (cid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
var uid = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (uid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
if(CustormerUserId== uid)
|
return true;
|
if (ThisUser==null)
|
{
|
|
ThisUser = await _fBS_CustormerUsersRep.GetFirstAsync(x => x.Id == uid && x.CusExtendId == cid && x.IsEn == true);
|
|
}
|
var User = await _fBS_CustormerUsersRep.GetFirstAsync(x =>x.CusExtendId==ThisUser.CusExtendId &&x.Id== CustormerUserId);
|
if (User == null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
if(User.IsEn==false)
|
throw Oops.Oh("无效用户不可设置为管理员");
|
|
User.IsManager = !User.IsManager;
|
User.UpdateTime = DateTime.Now;
|
User.UpdateUserName= "企业用户:" + ThisUser?.Name;
|
User.UpdateUserId = ThisUser.Id;
|
|
//ThisUser.IsManager = false;
|
//ThisUser.UpdateTime = DateTime.Now;
|
//ThisUser.UpdateUserName = "企业用户:" + ThisUser?.Name; //不互斥
|
//ThisUser.UpdateUserId = ThisUser.Id;
|
await _fBS_CustormerUsersRep.AsTenant().BeginTranAsync();
|
try
|
{
|
await _fBS_CustormerUsersRep.UpdateAsync(User);
|
//await _fBS_CustormerUsersRep.UpdateAsync(ThisUser); //不互斥
|
await _fBS_CustormerUsersRep.AsTenant().CommitTranAsync();
|
return false;
|
|
}
|
catch (Exception)
|
{
|
await _fBS_CustormerUsersRep.AsTenant().RollbackTranAsync();
|
throw;
|
}
|
|
|
}
|
|
/// <summary>
|
/// 更改员工信息
|
/// </summary>
|
/// <param name="CustormerUserId"> UserList 的ID</param>
|
/// <returns></returns>
|
[HttpPost]
|
public async Task<bool> UpdataCustormerUsers( FBS_CustormerUsersVM Param)
|
{
|
if (!await isManger())
|
throw Oops.Oh("用户没有权限");
|
var cid = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (cid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
var uid = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (uid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
if(Param.Id==null)
|
{
|
throw Oops.Oh("Id错误");
|
}
|
if(Param.CusExtendId!= cid)
|
{
|
throw Oops.Oh("组织机构不同不可修改");
|
}
|
|
var User = await _fBS_CustormerUsersRep.GetFirstAsync(x => x.CusExtendId == Param.CusExtendId && x.Id == Param.Id);
|
if (User == null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
User = _mapper.Map(Param, User);
|
|
User.CreateTime = DateTime.Now;
|
User.CreateUserName = "企业用户:" + ThisUser?.Name;
|
User.CreateUserId = ThisUser?.Id;
|
|
return await _fBS_CustormerUsersRep.UpdateAsync(User);
|
|
|
|
}
|
|
/// <summary>
|
/// 删除员工
|
/// </summary>
|
/// <param name="CustormerUserId"> UserList 的ID</param>
|
/// <returns></returns>
|
[HttpDelete]
|
public async Task<bool> DelCustormerUsers(long CustormerUserId)
|
{
|
if (!await isManger())
|
throw Oops.Oh("用户没有权限");
|
var cid = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (cid == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
var uid = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (uid == 0)
|
{
|
|
|
}
|
if (CustormerUserId == uid)
|
throw Oops.Oh("自己不可删除自己");
|
if (ThisUser == null)
|
{
|
|
ThisUser = await _fBS_CustormerUsersRep.GetFirstAsync(x => x.Id == uid && x.CusExtendId == cid && x.IsEn == true);
|
|
}
|
var User = await _fBS_CustormerUsersRep.GetFirstAsync(x => x.CusExtendId == ThisUser.CusExtendId && x.Id == CustormerUserId);
|
if (User == null)
|
{
|
throw Oops.Oh("用户不存在");
|
}
|
return await _fBS_CustormerUsersRep.DeleteByIdAsync(CustormerUserId);
|
|
|
|
}
|
|
/// <summary>
|
/// 权限验证是否是管理员
|
/// </summary>
|
/// <returns></returns>
|
[NonAction]
|
public async Task< bool> isManger()
|
{
|
|
if (ThisUser != null)
|
return ThisUser.IsManager;
|
//用户ID
|
|
var id = App.User.FindFirst(ClaimConst.UserId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("用户凭证错误");
|
|
}
|
//企业ID
|
var CExid = App.User.FindFirst(ClaimConst.CustomerExId)?.Value.ToLong() ?? 0;
|
if (id == 0)
|
{
|
throw Oops.Oh("企业资料不匹配");
|
|
}
|
|
|
var user= await _fBS_CustormerUsersRep.GetFirstAsync(x => x.Id == id && x.CusExtendId == CExid && x.IsEn == true);
|
if(user==null)
|
{
|
throw Oops.Oh("用户不匹配");
|
}
|
ThisUser = user;
|
if (user.IsManager)
|
|
return true;
|
|
else return false;
|
|
|
|
}
|
}
|
