|
|
|
@ -0,0 +1,208 @@
|
|
|
|
|
using OpenAuth.App.BaseApp.Base;
|
|
|
|
|
using OpenAuth.Repository.Domain;
|
|
|
|
|
using OpenAuth.Repository;
|
|
|
|
|
using System;
|
|
|
|
|
using System.Collections.Generic;
|
|
|
|
|
using System.Linq;
|
|
|
|
|
using System.Text;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
using OpenAuth.App.Interface;
|
|
|
|
|
using SqlSugar;
|
|
|
|
|
using Infrastructure;
|
|
|
|
|
using OpenAuth.App.Request;
|
|
|
|
|
using OpenAuth.App.Response;
|
|
|
|
|
using OpenAuth.App.ServiceApp.CompanyManage.Request;
|
|
|
|
|
using Infrastructure.Extensions;
|
|
|
|
|
using Infrastructure.Helpers;
|
|
|
|
|
using Infrastructure.Utilities;
|
|
|
|
|
|
|
|
|
|
namespace OpenAuth.App.ServiceApp.CompanyManage
|
|
|
|
|
{
|
|
|
|
|
public class TaxCompanyApp : SqlSugarBaseApp<TaxCompany, SugarDbContext>
|
|
|
|
|
{
|
|
|
|
|
private ISqlSugarClient client;
|
|
|
|
|
|
|
|
|
|
#region 构造函数
|
|
|
|
|
public TaxCompanyApp(
|
|
|
|
|
ISugarUnitOfWork<SugarDbContext> unitWork,
|
|
|
|
|
ISimpleClient<TaxCompany> repository,
|
|
|
|
|
IAuth auth,
|
|
|
|
|
ISqlSugarClient sqlSugarClient
|
|
|
|
|
) : base(unitWork, repository, auth)
|
|
|
|
|
{
|
|
|
|
|
this.client = sqlSugarClient;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 获取分页数据列表
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 获取分页列表
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="request"></param>
|
|
|
|
|
/// <returns></returns>
|
|
|
|
|
public async Task<Response<PageInfo<List<dynamic>>>> LoadCompanyPageList(TaxCompanyReq req)
|
|
|
|
|
{
|
|
|
|
|
RefAsync<int> totalCount = 0;
|
|
|
|
|
|
|
|
|
|
var query = client.Queryable<TaxCompany>()
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.shxydm),r=>r.shxydm==req.shxydm)
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.syrmc),r=>r.syrmc.Contains(req.syrmc))
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.djqdm),r=>r.djqdm==req.djqdm)
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.djzqdm),r=>r.djzqdm == req.djzqdm)
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.frdb),r=>r.frdb == req.frdb)
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.hy),r=>r.hy == req.hy)
|
|
|
|
|
.WhereIF(!string.IsNullOrEmpty(req.jyzt),r=>r.jyzt == req.jyzt)
|
|
|
|
|
.WhereIF(req.xmgxccmax!=null, r=>r.xmgxcc< req.xmgxccmax)
|
|
|
|
|
.WhereIF(req.xmgxccmin!=null, r=>r.xmgxcc> req.xmgxccmin)
|
|
|
|
|
.WhereIF(req.gdzcmax != null, r=>r.gdzc< req.gdzcmax)
|
|
|
|
|
.WhereIF(req.gdzcmin != null, r=>r.gdzc> req.gdzcmin)
|
|
|
|
|
.WhereIF(req.cscymax != null, r=>r.cscy < req.cscymax)
|
|
|
|
|
.WhereIF(req.cscymin != null, r=>r.cscy > req.cscymin)
|
|
|
|
|
.Select<dynamic>(r => new
|
|
|
|
|
{
|
|
|
|
|
RowNumber = SqlFunc.RowNumber(r.Id),
|
|
|
|
|
r.Id,
|
|
|
|
|
r.shxydm,
|
|
|
|
|
r.syrmc,
|
|
|
|
|
r.hy,
|
|
|
|
|
r.djqmc,
|
|
|
|
|
r.djzqmc,
|
|
|
|
|
//syrlx= SqlFunc.Subqueryable<TaxZongdi>().Where(a => a.shxydm == r.shxydm).Select(a => a.syrlx).FirstOrDefault(),
|
|
|
|
|
r.frdb,
|
|
|
|
|
r.lxfs,
|
|
|
|
|
r.xmgxcc,
|
|
|
|
|
r.cscy
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
var result = await query.ToPageListAsync(req.page, req.limit, totalCount);
|
|
|
|
|
|
|
|
|
|
return new Response<PageInfo<List<dynamic>>>
|
|
|
|
|
{
|
|
|
|
|
Code = 200,
|
|
|
|
|
Message = "success",
|
|
|
|
|
Result = new PageInfo<List<dynamic>>
|
|
|
|
|
{
|
|
|
|
|
Items = result,
|
|
|
|
|
Total = totalCount
|
|
|
|
|
}
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 根据id获取单个企业信息
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="id">企业id</param>
|
|
|
|
|
/// <returns></returns>
|
|
|
|
|
public async Task<TaxCompany> GetConpanyInfoById(string id)
|
|
|
|
|
{
|
|
|
|
|
var list = await client.Queryable<TaxCompany>().Where(r=>r.Id==id).FirstAsync();
|
|
|
|
|
return list;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 编辑企业信息
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 添加企业信息
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="req"></param>
|
|
|
|
|
/// <returns></returns>
|
|
|
|
|
/// <exception cref="Exception"></exception>
|
|
|
|
|
public async Task<Response<bool>> AddCompany(TaxCompany req)
|
|
|
|
|
{
|
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
|
|
|
{
|
|
|
|
|
if (uow.TaxCompany.IsAny(u => u.shxydm == req.shxydm))
|
|
|
|
|
{
|
|
|
|
|
throw new Exception("社会信用代码已存在");
|
|
|
|
|
}
|
|
|
|
|
req.Id = Guid.NewGuid().ToString();
|
|
|
|
|
|
|
|
|
|
bool insert=await uow.TaxCompany.InsertAsync(req);
|
|
|
|
|
bool flag = uow.Commit();
|
|
|
|
|
|
|
|
|
|
return new Response<bool>
|
|
|
|
|
{
|
|
|
|
|
Result = flag && insert,
|
|
|
|
|
Message = (flag && insert) == true ? "success" : "error"
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 修改企业信息
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="req"></param>
|
|
|
|
|
/// <returns></returns>
|
|
|
|
|
/// <exception cref="Exception"></exception>
|
|
|
|
|
public async Task<Response<bool>> UpdateCompany(TaxCompany req)
|
|
|
|
|
{
|
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
|
|
|
{
|
|
|
|
|
if (uow.TaxCompany.AsQueryable().Where(u => u.shxydm == req.shxydm&&u.Id==req.Id).Count()>1)
|
|
|
|
|
{
|
|
|
|
|
throw new Exception("社会信用代码已存在");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
bool update =await uow.TaxCompany.UpdateAsync(req);
|
|
|
|
|
bool flag = uow.Commit();
|
|
|
|
|
|
|
|
|
|
return new Response<bool>
|
|
|
|
|
{
|
|
|
|
|
Result = flag && update,
|
|
|
|
|
Message = (flag && update) == true ? "success" : "error"
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 删除企业
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <param name="ids"></param>
|
|
|
|
|
public async Task<Response<bool>> DeleteCompany(string[] ids)
|
|
|
|
|
{
|
|
|
|
|
using (var uow = base.UnitWork.CreateContext())
|
|
|
|
|
{
|
|
|
|
|
var delete=await uow.TaxCompany.DeleteAsync(a => ids.Contains(a.Id));
|
|
|
|
|
var flag = uow.Commit();
|
|
|
|
|
return new Response<bool>
|
|
|
|
|
{
|
|
|
|
|
Result = flag&& delete,
|
|
|
|
|
Message = flag && delete == true ? "success" : "error"
|
|
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
#region 查询乡镇
|
|
|
|
|
/// <summary>
|
|
|
|
|
/// 查询乡镇
|
|
|
|
|
/// </summary>
|
|
|
|
|
/// <returns></returns>
|
|
|
|
|
public async Task<List<dynamic>> GetStreetInfo()
|
|
|
|
|
{
|
|
|
|
|
var list = await client.Queryable<TaxXzqh>()
|
|
|
|
|
.OrderBy(r=>r.djqdm)
|
|
|
|
|
.GroupBy(r => new {r.djqdm,r.djqmc})
|
|
|
|
|
.Select<dynamic>(r => new
|
|
|
|
|
{
|
|
|
|
|
r.djqdm,
|
|
|
|
|
r.djqmc,
|
|
|
|
|
}).ToListAsync();
|
|
|
|
|
return list;
|
|
|
|
|
}
|
|
|
|
|
public async Task<List<dynamic>> GetCommunityInfo(string djqdm)
|
|
|
|
|
{
|
|
|
|
|
var list = await client.Queryable<TaxXzqh>()
|
|
|
|
|
.Where(r=>r.djqdm== djqdm)
|
|
|
|
|
.OrderBy(r=>r.xzqdm)
|
|
|
|
|
.Select<dynamic>(r => new
|
|
|
|
|
{
|
|
|
|
|
r.xzqdm,
|
|
|
|
|
r.xzqmc,
|
|
|
|
|
}).ToListAsync();
|
|
|
|
|
return list;
|
|
|
|
|
}
|
|
|
|
|
#endregion
|
|
|
|
|
}
|
|
|
|
|
}
|