ds8-solution-pro/ds-wms-service/DS.WMS.MainApi/Controllers/ClientInfoController.cs

using System.Text;
using DS.Module.Core;
using DS.Module.Core.Data;
using DS.Module.Core.Enums;
using DS.Module.Core.Extensions;
using DS.WMS.Core.Fee.Dtos;
using DS.WMS.Core.Flow.Dtos;
using DS.WMS.Core.Info.Dtos;
using DS.WMS.Core.Info.Interface;
using Masuit.Tools.Systems;
using Microsoft.AspNetCore.Mvc;
using MiniExcelLibs;

namespace DS.WMS.MainApi.Controllers;

/// <summary>
/// 客户基本信息-模块
/// </summary>
public class ClientInfoController : ApiController
{
    private readonly IClientInfoService _invokeService;

    /// <summary>
    /// 构造函数
    /// </summary>
    /// <param name="invokeService"></param>
    public ClientInfoController(IClientInfoService invokeService)
    {
        _invokeService = invokeService;
    }

    /// <summary>
    /// 提交审核
    /// </summary>
    /// <param name="idModel"></param>
    /// <returns></returns>
    [HttpPost, Route("SubmitAudit")]
    public async Task<DataResult> SubmitAuditAsync([FromBody] IdModel idModel)
    {
        if (!ModelState.IsValid)
            return DataResult.Failed(ModelState.GetErrorMessage());

        return await _invokeService.SubmitAuditAsync(idModel);
    }

    /// <summary>
    /// 执行审核
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    [HttpPost, Route("Audit")]
    public async Task<DataResult> AuditAsync([FromBody] AuditRequest request)
    {
        if (!ModelState.IsValid)
            return DataResult.Failed(ModelState.GetErrorMessage());

        return await _invokeService.AuditAsync(request);
    }

    /// <summary>
    /// 撤销审核
    /// </summary>
    /// <param name="idModel"></param>
    /// <returns></returns>
    [HttpPost, Route("Withdraw")]
    public async Task<DataResult> WithdrawAsync([FromBody] IdModel idModel)
    {
        if (!ModelState.IsValid)
            return DataResult.Failed(ModelState.GetErrorMessage());

        return await _invokeService.WithdrawAsync(idModel);
    }

    /// <summary>
    /// 审核完成回调
    /// </summary>
    /// <param name="callback">回调信息</param>
    /// <returns></returns>
    [HttpPost, Route("AuditCallback")]
    public async Task<DataResult> AuditCallbackAsync(FlowCallback callback)
    {
        return await _invokeService.AuditCallbackAsync(callback);
    }

    /// <summary>
    /// 列表
    /// </summary>
    /// <param name="request"></param>
    /// <returns></returns>
    [HttpPost]
    [Route("GetClientInfoList")]
    public async Task<DataResult<List<ClientInfoRes>>> GetListAsync([FromBody] PageRequest<ClientQuery> request)
    {
        return await _invokeService.GetListAsync(request);
    }

    /// <summary>
    /// 确定往来单位是否已使用
    /// </summary>
    /// <param name="idModel"></param>
    /// <returns></returns>
    [HttpPost, Route("GetUsage")]
    public async Task<DataResult<List<ClientUsage>>> GetUsageAsync([FromBody] IdModel idModel)
    {
        return await _invokeService.GetUsageAsync(idModel.Ids);
    }

    /// <summary>
    /// 编辑
    /// </summary>
    /// <param name="req"></param>
    /// <returns></returns>
    [HttpPost, Route("EditClientInfo")]
    public async Task<DataResult> EditClientInfoAsync([FromBody] ClientInfoReq req)
    {
        var res = await _invokeService.EditAsync(req);
        return res;
    }

    /// <summary>
    /// 详情
    /// </summary>
    /// <param name="id"></param>
    /// <returns></returns>
    [HttpGet]
    [Route("GetClientInfo")]
    public async Task<DataResult<ClientInfoRes>> GetClientInfoAsync([FromQuery] string id)
    {
        return await _invokeService.GetAsync(id);
    }

    /// <summary>
    /// 根据ID删除发票明细
    /// </summary>
    /// <param name="idModel"></param>
    /// <returns></returns>
    [HttpPost, Route("DeleteInvoiceHeader")]
    public async Task<DataResult> DeleteInvoiceHeaderAsync(IdModel idModel)
    {
        if (!ModelState.IsValid)
            return DataResult.Failed(ModelState.GetErrorMessage(), MultiLanguageConst.IllegalRequest);

        return await _invokeService.DeleteInvoiceHeaderAsync(idModel);
    }

    /// <summary>
    /// 根据ID删除往来单位
    /// </summary>
    /// <param name="model"></param>
    /// <returns></returns>
    [HttpPost, Route("Delete")]
    public async Task<DataResult> DeleteAsync([FromBody] IdModel model)
    {
        if (!ModelState.IsValid)
            return DataResult.Failed(ModelState.GetErrorMessage(), MultiLanguageConst.IllegalRequest);

        return await _invokeService.DeleteAsync(model);
    }

    /// <summary>
    /// 获取往来单位详情（含有联系人列表）
    /// </summary>
    /// <param name="query">查询往来单位</param>
    /// <returns>返回往来单位详情</returns>
    [HttpPost]
    [Route("GetClientInfoWithContact")]
    public async Task<DataResult<ClientInfoRes>> GetClientInfoWithContact([FromBody] QueryClientInfo query)
    {
        return await _invokeService.GetClientInfoWithContact(query);
    }

    /// <summary>
    /// 获取推送通知可选项列表
    /// </summary>
    /// <returns></returns>
    [HttpGet, Route("GetNotifications")]
    public DataResult<List<NotificationItem>> GetNotifications()
    {
        var list = typeof(PushNotification).GetDescriptionAndValue().Where(x => x.Value > 0)
            .Select(x => new NotificationItem { Value = x.Value, Name = x.Key }).ToList();

        return DataResult<List<NotificationItem>>.Success(list);
    }

    /// <summary>
    /// 检查客户信息是否重复
    /// </summary>
    /// <param name="req"></param>
    /// <returns></returns>
    [HttpPost, Route("IsAvailable")]
    public async Task<DataResult> IsAvailableAsync([FromBody] ClientInfoReq req)
    {
        return await _invokeService.IsAvailableAsync(req);
    }

    #region 导入

    /// <summary>
    /// 导入客户
    /// </summary>
    /// <param name="file"></param>
    /// <returns></returns>
    [HttpPost, Route("ImportClient")]
    public async Task<DataResult> ImportClientAsync(IFormFile file)
    {
        if (file == null)
            return DataResult.Failed("请求未包含文件流");

        var stream = file.OpenReadStream();
        var rows = (await MiniExcel.QueryAsync(stream, excelType: ExcelType.XLSX, startCell: "A2")).ToList();

        StringBuilder sb = new StringBuilder();
        List<InfoClientModel> list = [];
        try
        {
            foreach (IDictionary<string, object> item in rows)
            {
                var model = new InfoClientModel
                {
                    DeptName = item["A"]?.ToString(),
                    ContactTel = item["C"]?.ToString(),
                    Contact = item["D"]?.ToString(),
                    AgreementTerm = item["E"] == null ? null : DateTime.Parse(item["E"].ToString()),
                    StatusText = item["F"]?.ToString(),
                    Address = item["G"]?.ToString(),
                    CNName = item["H"]?.ToString()?.Trim(),
                    ENName = item["I"]?.ToString()?.Trim(),
                    ShortName = item["J"]?.ToString()?.Trim(),
                    TaxID = item["K"]?.ToString(),
                    Code = item["L"]?.ToString(),
                    StlType = item["M"]?.ToString(),
                    Class = item["N"]?.ToString(),
                    Attribute = item["O"]?.ToString(),
                    Business = item["P"]?.ToString(),
                    OP = item["Q"]?.ToString(),
                    Sale = item["R"]?.ToString(),
                    CustomerService = item["S"]?.ToString(),
                    Authenticator = item["T"]?.ToString(),
                    PrepaidRMB = item["U"] == null ? 0 : decimal.Parse(item["U"].ToString()),
                    PrepaidUSD = item["V"] == null ? 0 : decimal.Parse(item["V"].ToString()),
                    Quota = item["W"] == null ? 0 : decimal.Parse(item["W"].ToString()),
                    RestQuota = item["X"] == null ? 0 : decimal.Parse(item["X"].ToString()),
                    Phone = item["AB"]?.ToString(),
                    Tel = item["AC"]?.ToString(),
                    QQ = item["AD"]?.ToString(),
                    Wechat = item["AE"]?.ToString(),
                    Email = item["AF"]?.ToString(),
                    ContactName = item["AG"]?.ToString(),
                    NFDS = item["AP"] == null ? null : int.Parse(item["AP"].ToString()),
                    IsCustomer = true
                };

                //if (string.IsNullOrEmpty(model.DeptName))
                //    sb.Append($"行号：{rows.IndexOf(item) + 2} 未填写【所属部门】");

                list.Add(model);
            }

            if (sb.Length > 0)
                return DataResult.Failed("导入失败：" + sb.ToString());
        }
        catch (Exception ex)
        {
            return DataResult.Failed("读取文件失败：" + ex.Message);
        }


        return await _invokeService.ImportAsync(list);
    }

    /// <summary>
    /// 导入供应商
    /// </summary>
    /// <param name="file"></param>
    /// <returns></returns>
    [HttpPost, Route("ImportSupplier")]
    public async Task<DataResult> ImportSupplierAsync(IFormFile file)
    {
        if (file == null)
            return DataResult.Failed("请求未包含文件流");

        var stream = file.OpenReadStream();
        var rows = (await MiniExcel.QueryAsync(stream, excelType: ExcelType.XLSX, startCell: "A2")).ToList();

        StringBuilder sb = new StringBuilder();
        List<InfoClientModel> list = [];
        try
        {
            foreach (IDictionary<string, object> item in rows)
            {
                var model = new InfoClientModel
                {
                    ContactTel = item["A"]?.ToString(),
                    Contact = item["B"]?.ToString(),
                    AgreementTerm = item["C"] == null ? null : DateTime.Parse(item["C"].ToString()),
                    StatusText = item["D"]?.ToString(),
                    Address = item["E"]?.ToString(),
                    CNName = item["F"]?.ToString()?.Trim(),
                    ENName = item["G"]?.ToString()?.Trim(),
                    ShortName = item["H"]?.ToString()?.Trim(),
                    TaxID = item["I"]?.ToString(),
                    Code = item["J"]?.ToString(),
                    StlType = item["K"]?.ToString(),
                    Attribute = item["V"]?.ToString(),
                    Business = item["L"]?.ToString(),
                    OP = item["M"]?.ToString(),
                    Sale = item["N"]?.ToString(),
                    CustomerService = item["P"]?.ToString(),
                    Authenticator = item["Q"]?.ToString(),
                    PrepaidRMB = item["R"] == null ? 0 : decimal.Parse(item["R"].ToString()),
                    PrepaidUSD = item["S"] == null ? 0 : decimal.Parse(item["S"].ToString()),
                    Quota = item["T"] == null ? 0 : decimal.Parse(item["T"].ToString()),
                    RestQuota = item["U"] == null ? 0 : decimal.Parse(item["U"].ToString()),
                    ContactName = item["B"]?.ToString(),
                    IsSupplier = true
                };

                //if (string.IsNullOrEmpty(model.DeptName))
                //    sb.Append($"行号：{rows.IndexOf(item) + 2} 未填写【所属部门】");

                list.Add(model);
            }

            if (sb.Length > 0)
                return DataResult.Failed("导入失败：" + sb.ToString());
        }
        catch (Exception ex)
        {
            return DataResult.Failed("读取文件失败：" + ex.Message);
        }


        return await _invokeService.ImportAsync(list);
    }

    /// <summary>
    /// 导入银行与发票
    /// </summary>
    /// <param name="service"></param>
    /// <param name="file"></param>
    /// <returns></returns>
    [HttpPost, Route("ImportBank")]
    public async Task<DataResult> ImportBankAsync([FromServices] IClientBankService service, IFormFile file)
    {
        if (file == null)
            return DataResult.Failed("请求未包含文件流");

        var stream = file.OpenReadStream();
        var rows = (await MiniExcel.QueryAsync(stream, excelType: ExcelType.XLSX, startCell: "A2")).ToList();

        StringBuilder sb = new StringBuilder();
        List<InfoClientBankModel> list = [];

        try
        {
            foreach (IDictionary<string, object> item in rows)
            {
                var model = new InfoClientBankModel
                {
                    CompanyName = item["A"]?.ToString()?.Trim(),
                    Currency = item["B"]?.ToString(),
                    BankName = item["C"]?.ToString(),
                    BankAccount = item["E"]?.ToString(),
                    BankAddress = item["F"]?.ToString(),
                    InvoiceAddress = item["G"]?.ToString(),
                    InvoiceRecevier = item["H"]?.ToString(),
                    Tel = item["I"]?.ToString(),
                    TaxId = item["J"]?.ToString(),
                    InvoiceTel = item["K"]?.ToString(),
                    Remark = item["L"]?.ToString(),
                    InvoiceHeader = item["M"]?.ToString(),
                    IsDefaultP = int.TryParse(item["N"]?.ToString(), out int value1) && value1 == 1,
                    IsDefaultR = int.TryParse(item["O"]?.ToString(), out int value2) && value2 == 1,
                    IsDefault = int.TryParse(item["P"]?.ToString(), out int value3) && value3 == 1,
                };

                if (string.IsNullOrEmpty(model.CompanyName))
                    model.CompanyName = model.InvoiceHeader;

                if (string.IsNullOrEmpty(model.CompanyName))
                    sb.Append($"行号：{rows.IndexOf(item) + 2} 未填写【公司名称】");

                list.Add(model);
            }

            if (sb.Length > 0)
                return DataResult.Failed("导入失败：" + sb.ToString());
        }
        catch (Exception ex)
        {
            return DataResult.Failed("读取文件失败：" + ex.Message);
        }

        return await service.ImportAsync(list);
    }

    /// <summary>
    /// 导入联系人
    /// </summary>
    /// <param name="service"></param>
    /// <param name="file"></param>
    /// <returns></returns>
    [HttpPost, Route("ImportContact")]
    public async Task<DataResult> ImportContactAsync([FromServices] IClientContactService service, IFormFile file)
    {
        if (file == null)
            return DataResult.Failed("请求未包含文件流");

        var stream = file.OpenReadStream();
        var rows = (await MiniExcel.QueryAsync(stream, excelType: ExcelType.XLSX, startCell: "A2")).ToList();

        StringBuilder sb = new StringBuilder();
        List<InfoClientContactModel> list = [];

        try
        {
            foreach (IDictionary<string, object> item in rows)
            {
                var model = new InfoClientContactModel
                {
                    CompanyName = item["A"]?.ToString()?.Trim(),
                    ContactName = item["B"]?.ToString(),
                    ContactEnName = item["C"]?.ToString(),
                    Tel = item["D"]?.ToString(),
                    Mobile = item["E"]?.ToString(),
                    Email = item["F"]?.ToString(),
                    QQ = item["G"]?.ToString(),
                    IsDefault = item["H"]?.ToString() == "是",
                    Job = item["I"]?.ToString()
                };

                if (string.IsNullOrEmpty(model.CompanyName))
                    sb.Append($"行号：{rows.IndexOf(item) + 2} 未填写【公司名称】");

                list.Add(model);
            }

            if (sb.Length > 0)
                return DataResult.Failed("导入失败：" + sb.ToString());
        }
        catch (Exception ex)
        {
            return DataResult.Failed("读取文件失败：" + ex.Message);
        }

        return await service.ImportAsync(list);
    }

    #endregion
}