410 lines
16 KiB
C#
410 lines
16 KiB
C#
|
using Furion.DependencyInjection;
|
|||
|
|
using Nirvana.Common;
|
|||
|
|
using SqlSugar;
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
using Waste.Domain;
|
|||
|
|
|
|||
|
|
namespace Waste.Application
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 苏州设备接入平台管理
|
|||
|
|
/// </summary>
|
|||
|
|
public class SZPltService : ISZPltService, ITransient
|
|||
|
|
{
|
|||
|
|
private readonly ISqlSugarRepository<W_SZAddress> repository;
|
|||
|
|
private readonly SqlSugarClient dbClient;
|
|||
|
|
private readonly ISuZhouService _suZhouService;
|
|||
|
|
public SZPltService(ISqlSugarRepository<W_SZAddress> sqlSugarRepository, ISuZhouService suZhouService)
|
|||
|
|
{
|
|||
|
|
repository = sqlSugarRepository;
|
|||
|
|
dbClient = repository.Context;
|
|||
|
|
_suZhouService = suZhouService;
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除地产区域
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<ResultInfo> DeleteAddressAsync(Guid id)
|
|||
|
|
{
|
|||
|
|
var data = await dbClient.Queryable<W_SZAddress>().FirstAsync(x => x.Id == id);
|
|||
|
|
if (data == null)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "记录未找到");
|
|||
|
|
}
|
|||
|
|
var result = await _suZhouService.DeleteEstates(data.AdId);
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
//删除数据中的
|
|||
|
|
await dbClient.Deleteable<W_SZAddress>().Where(x => x.Id == id).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "删除成功");
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除采集点
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<ResultInfo> DeleteCollectAsync(Guid id)
|
|||
|
|
{
|
|||
|
|
var tdbClient = repository.Change<W_SZCollect>().Context;
|
|||
|
|
var data = await tdbClient.Queryable<W_SZCollect>().FirstAsync(x => x.Id == id);
|
|||
|
|
if (data == null)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "记录未找到");
|
|||
|
|
}
|
|||
|
|
var result = await _suZhouService.DeleteCollect(data.CoId);
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
//删除数据中的
|
|||
|
|
await dbClient.Deleteable<W_SZCollect>().Where(x => x.Id == id).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "删除成功");
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 地产区域详情
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<W_SZAddress> DetailAddressAsync(Guid id)
|
|||
|
|
{
|
|||
|
|
return await dbClient.Queryable<W_SZAddress>().FirstAsync(x => x.Id == id);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 采集点详情
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="id"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<W_SZCollect> DetailCollectAsync(Guid id)
|
|||
|
|
{
|
|||
|
|
var tdbClient = repository.Change<W_SZCollect>().Context;
|
|||
|
|
return await tdbClient.Queryable<W_SZCollect>().FirstAsync(x => x.Id == id);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取地产区域所有列表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<List<W_SZAddress>> GetAddressAllListAsync()
|
|||
|
|
{
|
|||
|
|
return await dbClient.Queryable<W_SZAddress>().ToListAsync();
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取地产区域列表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="param"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<PageParms<W_SZAddress>> GetAddressListAsync(QueryParams param)
|
|||
|
|
{
|
|||
|
|
RefAsync<int> totalnum = 0;
|
|||
|
|
var temquery = dbClient.Queryable<W_SZAddress>();
|
|||
|
|
if (param.queryParam != null && param.queryParam.Count > 0)
|
|||
|
|
{
|
|||
|
|
List<IConditionalModel> conModels = new List<IConditionalModel>();
|
|||
|
|
param.queryParam.ForEach(x =>
|
|||
|
|
{
|
|||
|
|
if (!string.IsNullOrEmpty(x.Value))
|
|||
|
|
{
|
|||
|
|
conModels.Add(new ConditionalModel()
|
|||
|
|
{
|
|||
|
|
FieldName = x.Name,
|
|||
|
|
ConditionalType = (ConditionalType)x.Type,
|
|||
|
|
FieldValue = x.Value.Trim()
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
if (conModels.Count > 0)
|
|||
|
|
{
|
|||
|
|
temquery = temquery.Where(conModels);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
string sorts = string.Format("{0} {1}", param.sort, param.order);
|
|||
|
|
var query = await temquery.OrderBy(sorts)
|
|||
|
|
.ToPageListAsync(param.offset, param.limit, totalnum);
|
|||
|
|
return new PageParms<W_SZAddress>
|
|||
|
|
{
|
|||
|
|
page = param.offset,
|
|||
|
|
Items = query,
|
|||
|
|
totalnum = totalnum,
|
|||
|
|
limit = param.limit
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取采集点列表
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="param"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<PageParms<SZCollectList>> GetCollectListAsync(QueryParams param)
|
|||
|
|
{
|
|||
|
|
var tdbClient = repository.Change<W_SZCollect>().Context;
|
|||
|
|
RefAsync<int> totalnum = 0;
|
|||
|
|
var temquery = tdbClient.Queryable<W_SZCollect>();
|
|||
|
|
if (param.queryParam != null && param.queryParam.Count > 0)
|
|||
|
|
{
|
|||
|
|
List<IConditionalModel> conModels = new List<IConditionalModel>();
|
|||
|
|
param.queryParam.ForEach(x =>
|
|||
|
|
{
|
|||
|
|
if (!string.IsNullOrEmpty(x.Value))
|
|||
|
|
{
|
|||
|
|
conModels.Add(new ConditionalModel()
|
|||
|
|
{
|
|||
|
|
FieldName = x.Name,
|
|||
|
|
ConditionalType = (ConditionalType)x.Type,
|
|||
|
|
FieldValue = x.Value.Trim()
|
|||
|
|
});
|
|||
|
|
}
|
|||
|
|
});
|
|||
|
|
if (conModels.Count > 0)
|
|||
|
|
{
|
|||
|
|
temquery = temquery.Where(conModels);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
string sorts = string.Format("{0} {1}", param.sort, param.order);
|
|||
|
|
var query = await temquery.OrderBy(sorts)
|
|||
|
|
.Select(x => new SZCollectList
|
|||
|
|
{
|
|||
|
|
Id = x.Id,
|
|||
|
|
Addr = x.Addr,
|
|||
|
|
Code = x.Code,
|
|||
|
|
CreateTime = x.CreateTime,
|
|||
|
|
EstateId = x.EstateId,
|
|||
|
|
Name = x.Name
|
|||
|
|
})
|
|||
|
|
.Mapper((it, cache) =>
|
|||
|
|
{
|
|||
|
|
var allestate = cache.Get(list =>
|
|||
|
|
{
|
|||
|
|
var ids = list.Select(x => Guid.Parse(x.EstateId)).ToList();
|
|||
|
|
return dbClient.Queryable<W_SZAddress>().Where(e => ids.Contains(e.Id)).ToList();
|
|||
|
|
});
|
|||
|
|
it.AddressName = allestate.FirstOrDefault(x => x.Id ==Guid.Parse(it.EstateId))?.Name;
|
|||
|
|
})
|
|||
|
|
.ToPageListAsync(param.offset, param.limit, totalnum);
|
|||
|
|
return new PageParms<SZCollectList>
|
|||
|
|
{
|
|||
|
|
page = param.offset,
|
|||
|
|
Items = query,
|
|||
|
|
totalnum = totalnum,
|
|||
|
|
limit = param.limit
|
|||
|
|
};
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 地产区域信息提交
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="data"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<ResultInfo> SubmitAddressFormAsync(W_SZAddress data)
|
|||
|
|
{
|
|||
|
|
data.Code = data.Code.ToStr();
|
|||
|
|
data.Name = data.Name.ToStr();
|
|||
|
|
data.Addr = data.Addr.ToStr();
|
|||
|
|
data.City = data.City.ToStr();
|
|||
|
|
data.Area = data.Area.ToStr();
|
|||
|
|
data.Street = data.Street.ToStr();
|
|||
|
|
if (string.IsNullOrEmpty(data.Code))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "编号不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Code.Length < 2 || data.Code.Length > 32)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "编号长度范围在2-32位");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Addr))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "所在地址不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Addr.Length < 4 || data.Addr.Length > 128)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "编号长度范围在4-128位");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.City))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "城市编码不可为空");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Name))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "名称不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Name.Length < 2 || data.Name.Length > 32)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "名称长度范围在2-32位");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Area))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "区域编码不可为空");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Street))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "街道编码不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Id != Guid.Empty)
|
|||
|
|
{
|
|||
|
|
if (await dbClient.Queryable<W_SZAddress>().AnyAsync(x => x.Code == data.Code && x.Id != data.Id))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "此编号已存在");
|
|||
|
|
}
|
|||
|
|
var addata = await dbClient.Queryable<W_SZAddress>().FirstAsync(x => x.Id == data.Id);
|
|||
|
|
//先删除,再增加
|
|||
|
|
var result = await _suZhouService.DeleteEstates(addata.AdId);
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
result = await _suZhouService.PostEstatesAsync(new EstatesC2SDto
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Street = data.Street,
|
|||
|
|
Area = data.Area,
|
|||
|
|
City = data.City,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Name = data.Name
|
|||
|
|
});
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
string adid = result.data.ToString();
|
|||
|
|
await dbClient.Updateable<W_SZAddress>().SetColumns(x => new W_SZAddress
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Street = data.Street,
|
|||
|
|
AdId = adid,
|
|||
|
|
Area = data.Area,
|
|||
|
|
City = data.City,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Name = data.Name
|
|||
|
|
}).Where(x => x.Id == data.Id).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "修改成功");
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (await dbClient.Queryable<W_SZAddress>().AnyAsync(x => x.Code == data.Code))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "此编号已存在");
|
|||
|
|
}
|
|||
|
|
var result = await _suZhouService.PostEstatesAsync(new EstatesC2SDto
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Street = data.Street,
|
|||
|
|
Area = data.Area,
|
|||
|
|
City = data.City,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Name = data.Name
|
|||
|
|
});
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
data.AdId = result.data.ToString();
|
|||
|
|
data.CreateTime = DateTime.Now;
|
|||
|
|
await dbClient.Insertable<W_SZAddress>(data).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "添加成功");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 采集点信息提交
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="data"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public async Task<ResultInfo> SubmitCollectFormAsync(W_SZCollect data)
|
|||
|
|
{
|
|||
|
|
data.Code = data.Code.ToStr();
|
|||
|
|
data.Name = data.Name.ToStr();
|
|||
|
|
data.Addr = data.Addr.ToStr();
|
|||
|
|
var tdbClient = repository.Change<W_SZCollect>().Context;
|
|||
|
|
if (string.IsNullOrEmpty(data.Code))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "编号不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Code.Length < 2 || data.Code.Length > 32)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "编号长度范围在2-32位");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Addr))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "所在地址不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Addr.Length < 4 || data.Addr.Length > 128)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "地址长度范围在4-128位");
|
|||
|
|
}
|
|||
|
|
if (string.IsNullOrEmpty(data.Name))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "名称不可为空");
|
|||
|
|
}
|
|||
|
|
if (data.Name.Length < 2 || data.Name.Length > 32)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "名称长度范围在2-32位");
|
|||
|
|
}
|
|||
|
|
Guid eid = Guid.Parse(data.EstateId);
|
|||
|
|
var address = await dbClient.Queryable<W_SZAddress>().FirstAsync(x => x.Id == eid);
|
|||
|
|
if (address == null)
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "地产区域未找到");
|
|||
|
|
}
|
|||
|
|
if (data.Id != Guid.Empty)
|
|||
|
|
{
|
|||
|
|
if (await tdbClient.Queryable<W_SZCollect>().AnyAsync(x => x.Code == data.Code && x.Id != data.Id))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "此编号已存在");
|
|||
|
|
}
|
|||
|
|
var addata = await tdbClient.Queryable<W_SZCollect>().FirstAsync(x => x.Id == data.Id);
|
|||
|
|
//先删除,再增加
|
|||
|
|
var result = await _suZhouService.DeleteCollect(addata.CoId);
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
result = await _suZhouService.PostCollectAsync(new CollectC2SDto
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Estate = address.AdId,
|
|||
|
|
Name = data.Name
|
|||
|
|
});
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
string adid = result.data.ToString();
|
|||
|
|
await tdbClient.Updateable<W_SZCollect>().SetColumns(x => new W_SZCollect
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Name = data.Name,
|
|||
|
|
CoId = adid,
|
|||
|
|
EstateId = data.EstateId
|
|||
|
|
}).Where(x => x.Id == data.Id).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "修改成功");
|
|||
|
|
}
|
|||
|
|
else
|
|||
|
|
{
|
|||
|
|
if (await tdbClient.Queryable<W_SZCollect>().AnyAsync(x => x.Code == data.Code))
|
|||
|
|
{
|
|||
|
|
return new ResultInfo(ResultState.FAIL, "此编号已存在");
|
|||
|
|
}
|
|||
|
|
var result = await _suZhouService.PostCollectAsync(new CollectC2SDto
|
|||
|
|
{
|
|||
|
|
Addr = data.Addr,
|
|||
|
|
Code = data.Code,
|
|||
|
|
Estate = address.AdId,
|
|||
|
|
Name = data.Name
|
|||
|
|
});
|
|||
|
|
if (result.code != ResultState.SUCCESS)
|
|||
|
|
{
|
|||
|
|
return result;
|
|||
|
|
}
|
|||
|
|
data.CoId = result.data.ToString();
|
|||
|
|
data.CreateTime = DateTime.Now;
|
|||
|
|
await tdbClient.Insertable<W_SZCollect>(data).ExecuteCommandAsync();
|
|||
|
|
return new ResultInfo(ResultState.SUCCESS, "添加成功");
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|