\Config\business.json
{
// #region 索引配置文件分层
"pushPullIndexs": {
"basis": [
"bo",
"bs",
"biz"
],
"owner": [
"dev"
]
}
// #索引配置文件分层
}
RG3.BO.BI.Bridge\Providers\PopedomPushPullIndexAbstractProvider.cs
List<string> lstBasisDir = new List<string> { };
_configuration.GetSection("pushPullIndexs:basis").Bind(lstBasisDir);
List<string> lstOwnerDir = new List<string> { };
_configuration.GetSection("pushPullIndexs:owner").Bind(lstOwnerDir);
添加PushMethod,和修改idx.json
/// <summary>
/// 8
/// </summary>
/// <param name="pfMapper"></param>
/// <returns></returns>
[CapSubscribe("pushpull.data.services.detail")]
public async Task BuildDataDetail(PFGlobalMapper pfMapper)
{
PFGlobalParameter pf = new PFGlobalParameter
{
PushMethod= pfMapper.PushMethod,
Cap = pfMapper.Cap,
FromOpRmt = RequestModuleType.Cap,
OwnerId = pfMapper.OwnerId,
UserId = pfMapper.UserId,
SysId = pfMapper.SysId,
ModuleKey = pfMapper.ModuleKey,
ReponseField = pfMapper.ReponseField,
RequestModuleType = pfMapper.RequestModuleType,
PushMapperFieldIdx = pfMapper.PushMapperFieldIdx,
MapperField = pfMapper.MapperField,
Ids = (pfMapper.FromOpRmt == RequestModuleType.Cap ? new List<string>() : pfMapper.Ids),
};
if (EnvPFUtil.IsDev())
{
Console.WriteLine($"【{DateTimeUtil.Now()}】【Data】【{pfMapper.ModuleKey}】【pushpull.data.services.detail】【推送开始】");
}
if (pf.PushMapperFieldIdx != null && pf.PushMapperFieldIdx.Count() > 0)
{
foreach (var item in pf.PushMapperFieldIdx)
{
Console.WriteLine($"【{DateTimeUtil.Now()}】【Data】【{pfMapper.ModuleKey}】【{pf.MapperField}】【pushpull.data.services.detail】【推送开始】");
pf.MapperField = item;
await _popedomPushAbstract.Datas<IEnumerable<string>>(pf, null);
}
await _capBus.PublishAsync("pushpull.ws.data.services.pro", pfMapper);
}
else if (EnvPFUtil.IsDev())
{
Console.WriteLine($"【{DateTimeUtil.Now()}】【Data】【{pfMapper.ModuleKey}】【pushpull.data.services.detail】【推送结束】【PushMapperFieldId未配置】");
}
}
文档更新时间: 2022-05-29 06:59 作者:admin