wangli/nanopart
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

REQ-3581: 备份

Browse Source
This commit is contained in:
yanglin 2025-02-21 17:00:38 +08:00
parent d01c5e4314
commit dfa62ebfdf
2 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/EssService.java
View File

@ -32,6 +32,7 @@ import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionTemplate;
import java.util.function.Function;
@ -56,6 +57,7 @@ public class EssService {
private final EssSupport essSupport;
private final TransactionTemplate transactionTemplate;
@Transactional
public String createConsoleLoginUrl(CreateConsoleLoginUrlRequest request) {
String subject = IdBuilder.builder()
.append(request.getOuId())
@ -84,6 +86,7 @@ public class EssService {
contextPerson, request.getEmbedType(), request.getBusinessId());
}
@Transactional
public void essAddSealAuthorization(AddSealAuthorizationRequest request) {
String subject = IdBuilder.builder()
.append(request.getEssSealId())
@ -102,6 +105,7 @@ public class EssService {
orgManager.addSealAuthorization(request.getEssSealId(), request.getPersonId(), request.getOperatorPersonId());
}
@Transactional
public void essRemoveSealAuthorization(RemoveSealAuthorizationRequest request) {
String subject = IdBuilder.builder()
.append(request.getEssSealId())
@ -193,8 +197,10 @@ public class EssService {
String pdfUrl = getContractPDFUrlFromEss(c);
String fileName = String.format("%s.pdf", c.getContractName());
String fileKey = ossService.uploadToOss(pdfUrl, fileName);
essContractDao.setOssFileKey(c, fileKey);
essLogDao.log("uploadContractToOss", c.getEssContractId());
transactionTemplate.executeWithoutResult(unused -> {
essContractDao.setOssFileKey(c, fileKey);
essLogDao.log("uploadContractToOss", c.getEssContractId(), "ossFileKey", fileKey);
});
log.info("上传合同到OSS成功, essContractId={}", c.getEssContractId());
} catch (Exception e) {
log.warn("上传合同到OSS失败", e);

4
ess/ess-server/src/main/java/cn/axzo/nanopart/ess/server/ess/PersonResignListener.java
View File

@ -20,6 +20,7 @@ import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.stereotype.Component;
import org.springframework.transaction.support.TransactionTemplate;
import java.util.Collections;
@ -45,6 +46,7 @@ public class PersonResignListener extends BaseListener
private final EssOrgDao essOrgDao;
private final EssPersonDao essPersonDao;
private final EssLogDao essLogDao;
private final TransactionTemplate transactionTemplate;
@Override
public void onMessage(MessageExt message) {
@ -57,7 +59,7 @@ public class PersonResignListener extends BaseListener
OrgUserStatusChangedEvent userEvent = event.normalizedData(OrgUserStatusChangedEvent.class);
log.info("receive user event: {}", JSON.toJSONString(userEvent));
if (userEvent.getStatusCode() == 6)
trySetPersonResigned(userEvent);
transactionTemplate.executeWithoutResult(unused -> trySetPersonResigned(userEvent));
else
log.info("ignore user event: {}", JSON.toJSONString(userEvent));
}