\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