Ws数据推送

_capBus.PublishAsync<PFGlobalMapper>("pushpull.data.services.detail", new PFGlobalMapper
                {
                    PushMapperFieldIdx = sqlConfig.PushMapperFieldIdx,
                    OwnerId = pf.OwnerId,
                    SysId = pf.SysId,
                    UserId = pf.UserId ?? (dictionaryUrl.ContainsKey(SystemParamConst.CURRENT_USER_ID) ? dictionaryUrl[SystemParamConst.CURRENT_USER_ID].ToString() : _authProvider.GetCurrentUserId()?.ToString()),
                    AppId = pf.AppId,
                    TenantId = pf.TenantId,
                    ChannelReceiver = pf.ChannelReceiver,
                    ChannelRule = pf.ChannelRule,
                    ModuleKey = mkey,
                    ReponseField = resField,
                    MapperField = mkey,
                    RequestModuleType = RequestModuleType.BatSave,
                    Primarys = lstPrimarys,
                    Ids = lstIds.Where(temp => !string.IsNullOrEmpty(temp)).Distinct(),
                    FromTraceId = "BatSaveService.cs"
                });