13
13
import fr .dossierfacile .common .repository .TenantUserApiRepository ;
14
14
import fr .dossierfacile .common .service .interfaces .PartnerCallBackService ;
15
15
import fr .dossierfacile .common .service .interfaces .RequestService ;
16
- import fr .dossierfacile .common .utils .TransactionalUtil ;
17
16
import jakarta .validation .constraints .NotNull ;
18
17
import lombok .RequiredArgsConstructor ;
19
18
import lombok .SneakyThrows ;
20
19
import lombok .extern .slf4j .Slf4j ;
21
20
import org .apache .commons .lang3 .StringUtils ;
22
- import org .springframework .beans .factory .annotation .Value ;
23
21
import org .springframework .stereotype .Service ;
24
22
import org .springframework .transaction .annotation .Transactional ;
25
23
@@ -43,7 +41,8 @@ public class PartnerCallBackServiceImpl implements PartnerCallBackService {
43
41
private final ObjectMapper objectMapper ;
44
42
45
43
public void registerTenant (String internalPartnerId , Tenant tenant , UserApi userApi ) {
46
- Optional <TenantUserApi > optionalTenantUserApi = tenantUserApiRepository .findFirstByTenantAndUserApi (tenant , userApi );
44
+ Optional <TenantUserApi > optionalTenantUserApi = tenantUserApiRepository .findFirstByTenantAndUserApi (tenant ,
45
+ userApi );
47
46
if (optionalTenantUserApi .isEmpty ()) {
48
47
TenantUserApi tenantUserApi = TenantUserApi .builder ()
49
48
.id (new TenantUserApiKey (tenant .getId (), userApi .getId ()))
@@ -61,21 +60,21 @@ public void registerTenant(String internalPartnerId, Tenant tenant, UserApi user
61
60
}
62
61
tenantUserApiRepository .save (tenantUserApi );
63
62
64
- if (userApi .getVersion () != null && userApi .getUrlCallback () != null && (
65
- tenant .getStatus () == TenantFileStatus .VALIDATED
63
+ if (userApi .getVersion () != null && userApi .getUrlCallback () != null
64
+ && ( tenant .getStatus () == TenantFileStatus .VALIDATED
66
65
|| tenant .getStatus () == TenantFileStatus .TO_PROCESS )) {
67
- PartnerCallBackType partnerCallBackType = tenant .getStatus () == TenantFileStatus .VALIDATED ?
68
- PartnerCallBackType .VERIFIED_ACCOUNT :
69
- PartnerCallBackType .CREATED_ACCOUNT ;
66
+ PartnerCallBackType partnerCallBackType = tenant .getStatus () == TenantFileStatus .VALIDATED
67
+ ? PartnerCallBackType .VERIFIED_ACCOUNT
68
+ : PartnerCallBackType .CREATED_ACCOUNT ;
70
69
ApplicationModel webhookDTO = getWebhookDTO (tenant , userApi , partnerCallBackType );
71
70
sendCallBack (tenant , userApi , webhookDTO );
72
71
}
73
72
}
74
73
}
75
74
76
75
private List <UserApi > findAllUserApi (ApartmentSharing as ) {
77
- return as .getTenants () == null ? Collections .emptyList () :
78
- as .getTenants ().stream ()
76
+ return as .getTenants () == null ? Collections .emptyList ()
77
+ : as .getTenants ().stream ()
79
78
.flatMap (t -> t .getTenantsUserApi () == null ? Stream .empty () : t .getTenantsUserApi ().stream ())
80
79
.map (TenantUserApi ::getUserApi )
81
80
.distinct ()
@@ -110,7 +109,8 @@ public void sendCallBack(List<Tenant> tenantList, PartnerCallBackType partnerCal
110
109
}
111
110
112
111
@ SneakyThrows
113
- private void createCallbackLogForPartnerModel (Long tenantId , Long partnerId , TenantFileStatus tenantFileStatus , ApplicationModel applicationModel ) {
112
+ private void createCallbackLogForPartnerModel (Long tenantId , Long partnerId , TenantFileStatus tenantFileStatus ,
113
+ ApplicationModel applicationModel ) {
114
114
String jsonContent = objectMapper .writeValueAsString (applicationModel );
115
115
callbackLogRepository .save (new CallbackLog (tenantId , partnerId , tenantFileStatus , jsonContent ));
116
116
}
@@ -149,11 +149,13 @@ public ApplicationModel getWebhookDTO(Tenant tenant, UserApi userApi, PartnerCal
149
149
for (Tenant t : tenantList ) {
150
150
tenantUserApiRepository .findFirstByTenantAndUserApi (t , userApi ).ifPresent (tenantUserApi -> {
151
151
if (ApiVersion .V3 .is (userApi .getVersion ())) {
152
- if (tenantUserApi .getAllInternalPartnerId () != null && !tenantUserApi .getAllInternalPartnerId ().isEmpty ()) {
152
+ if (tenantUserApi .getAllInternalPartnerId () != null
153
+ && !tenantUserApi .getAllInternalPartnerId ().isEmpty ()) {
153
154
applicationModel .getTenants ().stream ()
154
155
.filter (tenantObject -> Objects .equals (tenantObject .getId (), t .getId ()))
155
156
.findFirst ()
156
- .ifPresent (tenantModel -> tenantModel .setAllInternalPartnerId (tenantUserApi .getAllInternalPartnerId ()));
157
+ .ifPresent (tenantModel -> tenantModel
158
+ .setAllInternalPartnerId (tenantUserApi .getAllInternalPartnerId ()));
157
159
}
158
160
}
159
161
});
0 commit comments