暂存0822

chengf

2025-08-25 4fafe2304ab5e3df321808f5120b29baf27c7eab

 service-job/src/main/java/com/java110/job/cmd/export/ExportDataCmd.java

@@ -16,9 +16,11 @@
import com.java110.utils.exception.CmdException;
import com.java110.utils.util.Assert;
import com.java110.utils.util.DateUtil;
import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;

import java.util.Arrays;
import java.util.List;

/**
@@ -60,12 +62,33 @@

        reqJson.put("userId",userId);
        reqJson.put("storeId",storeId);
        if ("dataFeeManualCollection".equals(reqJson.getString("pagePath"))) {
            // 物业费催缴单
            List<String> configIds = Arrays.asList(reqJson.getString("configIds").split(","));
            List<String> roomIds = Arrays.asList(reqJson.getString("roomIds").split(","));
            for (String configId : configIds) {
                reqJson.put("configId", configId);
                for (String roomId : roomIds) {
                    reqJson.put("roomId", roomId);
                    this.create(userId, userDtos, reqJson);
                }
            }
        } else {
            this.create(userId, userDtos, reqJson);
        }
        context.setResponseEntity(ResultVo.createResponseEntity(ResultVo.CODE_OK,"文件正在生成，请到文件下载页面下载"));
    }

    private void create(String userId, List<UserDto> userDtos, JSONObject reqJson) {
        ExportDataDto exportDataDto = new ExportDataDto();
        exportDataDto.setBusinessAdapt(reqJson.getString("pagePath"));
        exportDataDto.setReqJson(reqJson);
        String fileName = GenerateCodeFactory.getUUID()
                + ".xlsx";
        String fileName = "";
        if ("dataFeeManualCollection".equals(reqJson.getString("pagePath"))) {
            fileName = GenerateCodeFactory.getUUID() + ".docx";
        } else {
            fileName = GenerateCodeFactory.getUUID() + ".xlsx";
        }
        exportDataDto.setFileName(EXPORT_DATA_PRE
                + reqJson.getString("pagePath")
                + "/"
@@ -86,12 +109,7 @@
        if (flag < 1) {
            throw new CmdException("下载文件失败");
        }

        exportDataDto.setDownloadId(userDownloadFilePo.getDownloadId());

        ExportDataQueue.addMsg(exportDataDto);


        context.setResponseEntity(ResultVo.createResponseEntity(ResultVo.CODE_OK,"文件正在生成，请到文件下载页面下载"));
    }
}