Merge branch 'master' of http://118.31.7.2:3000/chenyuan1/digital-rmb-backend

src/main/java/com/yau/digitalrmb/walletopening/application/WalletOpeningService.java

@@ -16,6 +16,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 
@@ -79,10 +80,13 @@ public class WalletOpeningService {
             throw new BusinessException(ErrorCode.VALIDATION_ERROR, "请选择数字钱包类型");
         }
 
-        // 输出申请报文时才存储身份证号、银行卡号等敏感信息
+        BigDecimal accountBalance = request.getAccountBalance();
+        if (accountBalance == null || accountBalance.compareTo(BigDecimal.ZERO) <= 0) {
+            accountBalance = new BigDecimal("50000.00");
+        }
         app.fillForm(request.getSelectedBank(), request.getWalletType(), request.getInputPhone(),
                 request.getInputIdNumber(), request.getInputBankCardNumber(), request.getSignaturePhotoPath(),
-                request.getIdNumber(), request.getAccountBank(), request.getBankCardNumber(), request.getAccountBalance());
+                request.getIdNumber(), request.getAccountBank(), request.getBankCardNumber(), accountBalance);
 
         String applyTime = LocalDateTime.now().format(TIMESTAMP_FORMAT);
         String applicationId = "APP_" + applyTime;

src/main/java/com/yau/digitalrmb/walletopening/application/WalletOpeningTrainingResetResult.java

@@ -0,0 +1,24 @@
+package com.yau.digitalrmb.walletopening.application;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+@ApiModel(description = "开通数字货币钱包实验重新实训结果")
+public class WalletOpeningTrainingResetResult {
+    @ApiModelProperty(value = "是否重置成功", example = "true")
+    private final boolean reset;
+    @ApiModelProperty(value = "逻辑删除的记录总数", example = "12")
+    private final int deletedRecordCount;
+    @ApiModelProperty(value = "处理说明")
+    private final String message;
+
+    public WalletOpeningTrainingResetResult(int deletedRecordCount) {
+        this.reset = true;
+        this.deletedRecordCount = deletedRecordCount;
+        this.message = "钱包开通实验步骤数据已逻辑删除，可从步骤一重新开始";
+    }
+
+    public boolean isReset() { return reset; }
+    public int getDeletedRecordCount() { return deletedRecordCount; }
+    public String getMessage() { return message; }
+}

src/main/java/com/yau/digitalrmb/walletopening/application/WalletOpeningTrainingResetService.java

@@ -0,0 +1,126 @@
+package com.yau.digitalrmb.walletopening.application;
+
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.yau.digitalrmb.institutionidentity.application.InstitutionKeySubject;
+import com.yau.digitalrmb.institutionidentity.infrastructure.StuModuleScoreDetailsEntity;
+import com.yau.digitalrmb.institutionidentity.infrastructure.StuModuleScoreDetailsMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.BankReceivedApplicationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.BankReceivedApplicationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.CentralWalletActivationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.CentralWalletActivationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.CentralWalletRegistrationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.CentralWalletRegistrationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.SmartContractGenerationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.SmartContractGenerationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletApplicationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletApplicationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletIdentifierGenerationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletIdentifierGenerationMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletRegistrationRequestEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletRegistrationRequestMapper;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletVerificationEntity;
+import com.yau.digitalrmb.walletopening.infrastructure.WalletVerificationMapper;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import javax.annotation.Resource;
+
+@Service
+public class WalletOpeningTrainingResetService {
+
+    @Resource private WalletApplicationMapper walletApplicationMapper;
+    @Resource private BankReceivedApplicationMapper bankReceivedApplicationMapper;
+    @Resource private WalletIdentifierGenerationMapper walletIdentifierGenerationMapper;
+    @Resource private SmartContractGenerationMapper smartContractGenerationMapper;
+    @Resource private WalletRegistrationRequestMapper walletRegistrationRequestMapper;
+    @Resource private WalletVerificationMapper walletVerificationMapper;
+    @Resource private CentralWalletRegistrationMapper centralWalletRegistrationMapper;
+    @Resource private CentralWalletActivationMapper centralWalletActivationMapper;
+    @Resource private StuModuleScoreDetailsMapper scoreDetailsMapper;
+
+    @Transactional
+    public WalletOpeningTrainingResetResult reset(InstitutionKeySubject subject) {
+        int count = 0;
+        count += logicalDeleteWalletApplications(subject);
+        count += logicalDeleteBankReceivedApplications(subject);
+        count += logicalDeleteWalletIdentifierGenerations(subject);
+        count += logicalDeleteSmartContracts(subject);
+        count += logicalDeleteWalletRegistrationRequests(subject);
+        count += logicalDeleteWalletVerifications(subject);
+        count += logicalDeleteCentralWalletRegistrations(subject);
+        count += logicalDeleteCentralWalletActivations(subject);
+        count += logicalDeleteScore(subject.getUserId());
+        return new WalletOpeningTrainingResetResult(count);
+    }
+
+    private int logicalDeleteWalletApplications(InstitutionKeySubject s) {
+        return walletApplicationMapper.update(null, new LambdaUpdateWrapper<WalletApplicationEntity>()
+                .eq(WalletApplicationEntity::getUserId, s.getUserId())
+                .eq(WalletApplicationEntity::getSchoolId, s.getSchoolId())
+                .eq(WalletApplicationEntity::getClassId, s.getClassId())
+                .set(WalletApplicationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteBankReceivedApplications(InstitutionKeySubject s) {
+        return bankReceivedApplicationMapper.update(null, new LambdaUpdateWrapper<BankReceivedApplicationEntity>()
+                .eq(BankReceivedApplicationEntity::getUserId, s.getUserId())
+                .eq(BankReceivedApplicationEntity::getSchoolId, s.getSchoolId())
+                .eq(BankReceivedApplicationEntity::getClassId, s.getClassId())
+                .set(BankReceivedApplicationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteWalletIdentifierGenerations(InstitutionKeySubject s) {
+        return walletIdentifierGenerationMapper.update(null, new LambdaUpdateWrapper<WalletIdentifierGenerationEntity>()
+                .eq(WalletIdentifierGenerationEntity::getUserId, s.getUserId())
+                .eq(WalletIdentifierGenerationEntity::getSchoolId, s.getSchoolId())
+                .eq(WalletIdentifierGenerationEntity::getClassId, s.getClassId())
+                .set(WalletIdentifierGenerationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteSmartContracts(InstitutionKeySubject s) {
+        return smartContractGenerationMapper.update(null, new LambdaUpdateWrapper<SmartContractGenerationEntity>()
+                .eq(SmartContractGenerationEntity::getUserId, s.getUserId())
+                .eq(SmartContractGenerationEntity::getSchoolId, s.getSchoolId())
+                .eq(SmartContractGenerationEntity::getClassId, s.getClassId())
+                .set(SmartContractGenerationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteWalletRegistrationRequests(InstitutionKeySubject s) {
+        return walletRegistrationRequestMapper.update(null, new LambdaUpdateWrapper<WalletRegistrationRequestEntity>()
+                .eq(WalletRegistrationRequestEntity::getUserId, s.getUserId())
+                .eq(WalletRegistrationRequestEntity::getSchoolId, s.getSchoolId())
+                .eq(WalletRegistrationRequestEntity::getClassId, s.getClassId())
+                .set(WalletRegistrationRequestEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteWalletVerifications(InstitutionKeySubject s) {
+        return walletVerificationMapper.update(null, new LambdaUpdateWrapper<WalletVerificationEntity>()
+                .eq(WalletVerificationEntity::getUserId, s.getUserId())
+                .eq(WalletVerificationEntity::getSchoolId, s.getSchoolId())
+                .eq(WalletVerificationEntity::getClassId, s.getClassId())
+                .set(WalletVerificationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteCentralWalletRegistrations(InstitutionKeySubject s) {
+        return centralWalletRegistrationMapper.update(null, new LambdaUpdateWrapper<CentralWalletRegistrationEntity>()
+                .eq(CentralWalletRegistrationEntity::getUserId, s.getUserId())
+                .eq(CentralWalletRegistrationEntity::getSchoolId, s.getSchoolId())
+                .eq(CentralWalletRegistrationEntity::getClassId, s.getClassId())
+                .set(CentralWalletRegistrationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteCentralWalletActivations(InstitutionKeySubject s) {
+        return centralWalletActivationMapper.update(null, new LambdaUpdateWrapper<CentralWalletActivationEntity>()
+                .eq(CentralWalletActivationEntity::getUserId, s.getUserId())
+                .eq(CentralWalletActivationEntity::getSchoolId, s.getSchoolId())
+                .eq(CentralWalletActivationEntity::getClassId, s.getClassId())
+                .set(CentralWalletActivationEntity::getDeleted, true));
+    }
+
+    private int logicalDeleteScore(String userId) {
+        return scoreDetailsMapper.update(null, new LambdaUpdateWrapper<StuModuleScoreDetailsEntity>()
+                .eq(StuModuleScoreDetailsEntity::getUserId, userId)
+                .eq(StuModuleScoreDetailsEntity::getMoudule, WalletOpeningScoreService.MODULE_NAME)
+                .set(StuModuleScoreDetailsEntity::getDeleted, true));
+    }
+}

src/main/java/com/yau/digitalrmb/walletopening/interfaces/rest/WalletOpeningTrainingResetController.java

@@ -0,0 +1,38 @@
+package com.yau.digitalrmb.walletopening.interfaces.rest;
+
+import com.yau.digitalrmb.institutionidentity.application.InstitutionKeySubject;
+import com.yau.digitalrmb.security.context.AuthContextHolder;
+import com.yau.digitalrmb.security.context.JwtUser;
+import com.yau.digitalrmb.shared.api.ApiResponse;
+import com.yau.digitalrmb.shared.web.TraceIdFilter;
+import com.yau.digitalrmb.walletopening.application.WalletOpeningTrainingResetResult;
+import com.yau.digitalrmb.walletopening.application.WalletOpeningTrainingResetService;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import org.slf4j.MDC;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+
+@RestController
+@RequestMapping("/api/v1/wallet-opening/training")
+@Tag(name = "开通数字货币钱包-实验管理", description = "钱包开通实验重新实训")
+public class WalletOpeningTrainingResetController {
+
+    @Resource
+    private WalletOpeningTrainingResetService resetService;
+
+    @PostMapping("/reset")
+    @Operation(summary = "重新开始钱包开通实验",
+            description = "逻辑删除当前用户在钱包开通模块的全部步骤数据（申请记录、钱包标识、智能合约、注册登记、验证记录、央行注册与激活、成绩明细），可从步骤一重新开始。")
+    public ApiResponse<WalletOpeningTrainingResetResult> reset() {
+        JwtUser jwtUser = AuthContextHolder.get();
+        return ApiResponse.success(resetService.reset(InstitutionKeySubject.from(jwtUser)), traceId());
+    }
+
+    private String traceId() {
+        return MDC.get(TraceIdFilter.MDC_KEY);
+    }
+}