etreschenkov 2025-10-17 13:12:52 +03:00
parent e4fc5bbedd
commit ddd500e26f
4 changed files with 29 additions and 5 deletions

View file

@ -160,7 +160,7 @@ public class ClearingMemberCategoryService extends QueueConsumer implements Init
return null;
}
private RequestInfoUpdate clearingMemberCategoryDelete(BaseRequest<CommonDeleteRequest> userRequest) {
public RequestInfoUpdate clearingMemberCategoryDelete(BaseRequest<CommonDeleteRequest> userRequest) {
CommonDeleteRequest req = userRequest.getRequestPayload();
RequestInfoUpdate requestInfoUpdate = userRoleVerification.validateRoleAndGetResult(userRequest);

View file

@ -18,6 +18,7 @@ import ru.spcex.clearing.platform.messaging.domain.ActionType;
import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
import ru.spcex.clearing.platform.messaging.domain.Consts;
import ru.spcex.clearing.platform.messaging.domain.cud.account.ClientCodeNewRequest;
import ru.spcex.clearing.platform.messaging.domain.cud.common.CommonDeleteRequest;
import ru.spcex.clearing.platform.messaging.domain.cud.company.*;
import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.clearing.platform.messaging.service.RequestInfoUpdate;
@ -198,10 +199,16 @@ public class MultiCompanyService
replyI = clearingMemberCategoryService.clearingMemberCategoryNew(wrapRequest(baseRequest, partRequest, ActionType.NEW));
validateReply(companyId, "contactNew", replyI);
} else {
log.trace("For company[{}] do update category[{}]", companyId, existCategory.getId());
ClearingMemberCategoryUpdateRequest partUpdateRequest = createUpdateRequest(existCategory, partRequest);
replyI = clearingMemberCategoryService.clearingMemberCategoryUpdate(wrapRequest(baseRequest, partUpdateRequest, ActionType.UPDATE));
validateReply(companyId, "categoryUpdate", replyI);
if (Arrays.asList("CLOS", "SSPD").contains(partRequest.getWorkflowStatus())) {
log.trace("For company[{}] do delete category[{}]", companyId, existCategory.getId());
CommonDeleteRequest commonDeleteRequest = createDeleteRequest(existCategory);
clearingMemberCategoryService.clearingMemberCategoryDelete(wrapRequest(baseRequest, commonDeleteRequest, ActionType.DELETE));
} else {
log.trace("For company[{}] do update category[{}]", companyId, existCategory.getId());
ClearingMemberCategoryUpdateRequest partUpdateRequest = createUpdateRequest(existCategory, partRequest);
replyI = clearingMemberCategoryService.clearingMemberCategoryUpdate(wrapRequest(baseRequest, partUpdateRequest, ActionType.UPDATE));
validateReply(companyId, "categoryUpdate", replyI);
}
}
}
txOk = true;
@ -335,6 +342,12 @@ public class MultiCompanyService
return r;
}
CommonDeleteRequest createDeleteRequest(ClearingMemberCategory existCategory) {
CommonDeleteRequest commonDeleteRequest = new CommonDeleteRequest();
commonDeleteRequest.setId(existCategory.getId());
return commonDeleteRequest;
}
Long getCompanyIdForCompanySymbols(String uuid, CompanyNewRequest cnr, Collection<CompanySymbolNewRequest> companySymbols) {
CompanySymbols companySymbol = null;
if (StringUtils.isNotEmpty(uuid)) {

View file

@ -131,6 +131,7 @@ public class CompanyRequestAdapter {
public ClearingMemberCategoryNewRequest toCategoryRequest(CompanyClearingCategory companyClearingCategory) {
ClearingMemberCategoryNewRequest categoryNewRequest = new ClearingMemberCategoryNewRequest();
categoryNewRequest.setClearingMemberCategory(companyClearingCategory.getCategory());
categoryNewRequest.setWorkflowStatus(companyClearingCategory.getWorkflowStatus());
return categoryNewRequest;
}
}

View file

@ -7,6 +7,8 @@ public class ClearingMemberCategoryNewRequest {
private String clearingMemberCategory;
@JsonProperty
private Long companyId;
@JsonProperty
private String workflowStatus;
public Long getCompanyId() {
return companyId;
@ -23,4 +25,12 @@ public class ClearingMemberCategoryNewRequest {
public void setClearingMemberCategory(String clearingMemberCategory) {
this.clearingMemberCategory = clearingMemberCategory;
}
public String getWorkflowStatus() {
return workflowStatus;
}
public void setWorkflowStatus(String workflowStatus) {
this.workflowStatus = workflowStatus;
}
}