This commit is contained in:
Adam 2024-05-28 15:12:18 +02:00
commit fc754a077a
1 changed files with 8 additions and 9 deletions

View File

@ -67,9 +67,8 @@ public class DevAdminSignalRHub(AdminDal adminDal, ServiceProviderAPIController
case SignalRTags.GetPropertiesByOwnerIdAsync: case SignalRTags.GetPropertiesByOwnerIdAsync:
var ownerId = message!.MessagePackTo<SignalRequestByIdMessage>().Id; var ownerId = message!.MessagePackTo<SignalRequestByIdMessage>().Id;
var json = (await serviceProviderAPIController.GetServiceProvidersByOwnerId(ownerId)).ToJson();
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, json), requestId); await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, await serviceProviderAPIController.GetServiceProvidersByOwnerId(ownerId)), requestId);
return; return;
@ -77,7 +76,7 @@ public class DevAdminSignalRHub(AdminDal adminDal, ServiceProviderAPIController
var transfer = message!.MessagePackTo<SignalPostJsonDataMessage<Transfer>>().PostData; var transfer = message!.MessagePackTo<SignalPostJsonDataMessage<Transfer>>().PostData;
await transferDataAPIController.UpdateTransfer(transfer); await transferDataAPIController.UpdateTransfer(transfer);
await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, transfer.ToJson()), requestId); await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, transfer), requestId);
return; return;
@ -86,19 +85,19 @@ public class DevAdminSignalRHub(AdminDal adminDal, ServiceProviderAPIController
return; return;
case SignalRTags.UpdateCompanyAsync: case SignalRTags.UpdateCompanyAsync:
var company = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData; var updaCompany = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData;
await serviceProviderAPIController.UpdateServiceProvider(company); await serviceProviderAPIController.UpdateServiceProvider(updaCompany);
await ResponseToCaller(messageTag, new SignalResponseMessage<string>(SignalResponseStatus.Success, company.ToJson()), requestId); await ResponseToCaller(messageTag, new SignalResponseJsonMessage(SignalResponseStatus.Success, updaCompany), requestId);
return; return;
case SignalRTags.CreateCompanyAsync: case SignalRTags.CreateCompanyAsync:
//var company = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData; //var createCompany = message!.MessagePackTo<SignalPostJsonDataMessage<Company>>().PostData;
//await serviceProviderAPIController.CreateServiceProvider(company); //await serviceProviderAPIController.CreateServiceProvider(createCompany);
//await ResponseToCaller(messageTag, new SignalResponseMessage<string>(SignalResponseStatus.Success, company.ToJson()), requestId); //await ResponseToCaller(messageTag, new SignalResponseMessage<string>(SignalResponseStatus.Success, createCompany), requestId);
return; return;
default: default: