vaultody-back/crm-manager/src/main/java/com/crm/manager/controller/VaultodyController.java

package com.crm.manager.controller;

import com.crm.manager.service.VaultodyService;
import com.crm.manager.util.BlockchainUtils;
import com.crm.manager.util.DateUtils;
import com.crm.rely.backend.core.dto.base.BaseResultDto;
import com.crm.rely.backend.model.dto.export.TransactionItemExport;
import com.crm.rely.backend.model.entity.vaultody.vaults.VaultTransactionsSearchEntity;
import com.crm.rely.backend.model.pojo.table.TransactionItemTable;
import com.crm.rely.backend.util.ExportUtil;
import com.crm.rely.backend.util.FileProcessUtil;
import com.google.common.collect.Lists;
import jakarta.servlet.http.HttpServletResponse;
import org.apache.commons.lang3.StringUtils;
import org.hibernate.service.spi.ServiceException;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;


@RestController
@RequestMapping("/vaultody")
public class VaultodyController {

    @Autowired
    private VaultodyService vaultodyService;


    /**
     * 保险箱列表
     *
     */
    @PostMapping("/vaults/list")
    public BaseResultDto vaultsList() throws Exception {
        return vaultodyService.vaultsList();
    }

    /**
     * 保险箱交易详情分页查询
     * @param entity
     * @return
     * @throws Exception
     */
    @PostMapping("/transaction/search/list")
    public BaseResultDto searchList(@RequestBody VaultTransactionsSearchEntity entity) throws Exception {
        if (StringUtils.isBlank(entity.getVaultId())) {
            throw new ServiceException("vault_id_not_null_error");
        }
        return vaultodyService.searchList(entity);
    }

    /**
     * 导出保险箱交易记录
     * @param entity
     * @param response
     * @throws Exception
     */
    @PostMapping("/export")
    public void export(@RequestBody VaultTransactionsSearchEntity entity, HttpServletResponse response) throws Exception {
        List<TransactionItemTable> items = (List<TransactionItemTable>)searchList(entity).getData();
        List<TransactionItemExport> exportDtos = Lists.newArrayList();
        for (TransactionItemTable item : items) {
            TransactionItemExport exportDto = new TransactionItemExport();
            BeanUtils.copyProperties(item, exportDto);
            if(StringUtils.isNotBlank(item.getBlockchain()) && StringUtils.isNotBlank(item.getTransactionId())){
                exportDto.setTransactionId(BlockchainUtils.getTransactionUrl(item.getBlockchain(), item.getTransactionId()));
            }
            exportDto.setCreatedTimestamp(DateUtils.secondToDateTimeStr(item.getCreatedTimestamp()));
            exportDtos.add(exportDto);
        }
        ExportUtil.transferToResponse(FileProcessUtil.genExportFileName("VAULTODY_VAULT_TRANSACTIONS"), exportDtos,
                TransactionItemExport.class, response);
    }

}