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

REQ-3540: 续费

Browse Source
This commit is contained in:
yanglin 2025-03-17 17:53:20 +08:00
parent 02730d3213
commit 147944bf77
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
doc/doc-server/src/main/java/cn/axzo/nanopart/doc/file/filedb/FileDatabaseService.java
View File

@ -36,6 +36,7 @@ import cn.axzo.nanopart.doc.api.filedb.request.FileDatabaseSearchRequest;
import cn.axzo.nanopart.doc.api.filedb.response.FileDatabaseInfoResponse;
import cn.axzo.nanopart.doc.api.util.BizAssertions;
import cn.axzo.nanopart.doc.api.util.UUIDUtil;
import cn.axzo.nanopart.doc.dao.DocLogDao;
import cn.axzo.nanopart.doc.dao.FileDatabaseDao;
import cn.axzo.nanopart.doc.entity.FileDatabase;
import cn.axzo.nanopart.doc.entity.IndexNode;
@ -66,9 +67,11 @@ public class FileDatabaseService {
private final IndexManager indexManager;
private final TransactionTemplate transaction;
private final AsyncUtils asyncUtils;
private final DocLogDao docLogDao;
@BizTransactional
public void addWorkspace(FileDatabaseAddWorkspaceRequest request) {
docLogDao.logRequest("addWorkspace", request.getWorkspaceId(), request);
String scopeUniqueCode = String.valueOf(request.getWorkspaceId());
TemplateDatabase templateDatabase = templateDatabaseManager.getOrThrow(request.getTemplateDatabaseCode());
FileDatabase savedDb = fileDatabaseDao.findForUpdateOrNull(templateDatabase.getScope(), scopeUniqueCode);
@ -91,6 +94,7 @@ public class FileDatabaseService {
public void active(FileDatabaseActiveRequest request) {
request.checkExpiredDate();
docLogDao.logRequest("active", request.getCode(), request);
FileDatabase db = fileDatabaseDao.getOrThrow(request.getCode());
if (db.isActivated())
return;
@ -126,6 +130,7 @@ public class FileDatabaseService {
@BizTransactional
public void renew(FileDatabaseRenewRequest request) {
request.checkExpiredDate();
docLogDao.logRequest("renew", request.getCode(), request);
FileDatabase db = fileDatabaseDao.getForUpdateOrThrow(request.getCode());
updateCapacity(request) //
.set(FileDatabase::getState,
@ -136,6 +141,7 @@ public class FileDatabaseService {
@BizTransactional
public void expandCapacity(FileDatabaseExpandCapacityRequest request) {
request.checkExpiredDate();
docLogDao.logRequest("expandCapacity", request.getCode(), request);
FileDatabase db = fileDatabaseDao.getForUpdateOrThrow(request.getCode());
BizAssertions.assertTrue(db.isActivated(), "只有激活状态的资料库才能扩容");
updateCapacity(request).update();
@ -149,6 +155,7 @@ public class FileDatabaseService {
}
public void remove(FileDatabaseRemoveRequest request) {
docLogDao.logRequest("remove", request.getCode(), request);
fileDatabaseDao.deleteByCode(request.getCode());
}