package com.vci.ubcs.code.controller;
|
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.alibaba.nacos.common.utils.StringUtils;
|
import com.vci.ubcs.code.dto.CodeOrderDTO;
|
import com.vci.ubcs.code.dto.CodeOrderSecDTO;
|
import com.vci.ubcs.code.dto.datapush.BaseModelDTO;
|
import com.vci.ubcs.code.service.MdmEngineService;
|
import com.vci.ubcs.code.service.MdmIOService;
|
import com.vci.ubcs.code.vo.pagemodel.CodeImProtRusultVO;
|
import com.vci.ubcs.starter.annotation.VciBusinessLog;
|
import com.vci.ubcs.starter.util.LocalFileUtil;
|
import com.vci.ubcs.starter.web.util.ControllerUtil;
|
import com.vci.ubcs.starter.web.util.LangBaseUtil;
|
import io.swagger.annotations.Api;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springblade.core.tool.api.R;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
import org.springframework.web.multipart.MultipartFile;
|
|
import javax.servlet.http.HttpServletResponse;
|
import java.io.File;
|
import java.io.IOException;
|
import java.nio.charset.StandardCharsets;
|
import java.util.List;
|
|
@RestController
|
//@AllArgsConstructor
|
@RequestMapping("/mdmEngineController")
|
@Api(value = "编码数据管理", tags = "编码数据管理")
|
public class MdmEngineController {
|
|
// /**
|
// * 日志
|
// */
|
private Logger logger = LoggerFactory.getLogger(getClass());
|
/**
|
* 主数据引擎服务
|
*/
|
@Autowired
|
private MdmEngineService engineService;
|
/**
|
* 主数据导入导出服务
|
*/
|
@Autowired
|
private MdmIOService mdmIOService;
|
|
/**
|
* 下载批量申请的导入模板
|
* @param codeClassifyOid 分类的主键
|
* @param response 响应对象
|
* @throws IOException 抛出异常
|
*/
|
@GetMapping("/downloadImportExcel")
|
@VciBusinessLog(operateName = "下载批量申请编码的导入模板")
|
public void downloadImportExcel(String codeClassifyOid, HttpServletResponse response) throws IOException{
|
String excelName = mdmIOService.createImportExcel(codeClassifyOid,false);
|
try {
|
ControllerUtil.writeFileToResponse(response,excelName);
|
} catch (Throwable e) {
|
//如果出错,把错误信息写到text
|
String msg = LangBaseUtil.getErrorMsg(e);
|
if(StringUtils.isBlank(msg)){
|
msg = "未知错误";
|
}
|
ControllerUtil.writeDataToResponse(response,msg.getBytes(StandardCharsets.UTF_8),null);
|
}
|
}
|
|
|
/**
|
* 批量申请编码的信息
|
* @param secDTOList 申请编码的信息，必须包含码段和分类主键的信息
|
* @param file 文件的内容
|
*/
|
@VciBusinessLog(operateName = "批量申请编码的信息")
|
@PostMapping("/batchImportCode")
|
public R batchImportCode(String secDTOList, String codeClassifyOid, MultipartFile file, HttpServletResponse response) throws Throwable {
|
CodeOrderDTO orderDTO = new CodeOrderDTO();
|
orderDTO.setCodeClassifyOid(codeClassifyOid);
|
if(StringUtils.isNotBlank(secDTOList)){
|
List<CodeOrderSecDTO> secDTOS = JSONObject.parseArray(secDTOList, CodeOrderSecDTO.class);
|
orderDTO.setSecDTOList(secDTOS);
|
}
|
String excelFileName = LocalFileUtil.getDefaultTempFolder() + File.separator + LocalFileUtil.getFileNameForIE(file.getOriginalFilename());
|
File file1 = new File(excelFileName);
|
try {
|
file.transferTo(new File(excelFileName));
|
CodeImProtRusultVO codeImProtRusultVO = mdmIOService.batchImportCode(orderDTO,file1);
|
if(StringUtils.isNotBlank(codeImProtRusultVO.getFilePath())||StringUtils.isNotBlank(codeImProtRusultVO.getRedisUuid())){
|
//放到map里
|
R result = R.fail("导入失败");
|
if(StringUtils.isNotBlank(codeImProtRusultVO.getFilePath())) {
|
String filedUUid = ControllerUtil.putErrorFile(codeImProtRusultVO.getFilePath());
|
codeImProtRusultVO.setFileOid(filedUUid);
|
}
|
result.setData(codeImProtRusultVO);
|
return result;
|
}else {
|
return R.success("操作成功！");
|
}
|
}catch (Throwable e) {
|
logger.error("导入错误",e);
|
String errorFile = LocalFileUtil.getDefaultTempFolder() + File.separator + "错误.txt";
|
LocalFileUtil.writeContentToFile( LangBaseUtil.getErrorMsg(e),errorFile);
|
String uuid=ControllerUtil.putErrorFile(errorFile);
|
CodeImProtRusultVO codeImProtRusultVO =new CodeImProtRusultVO();
|
codeImProtRusultVO.setRedisUuid("");
|
codeImProtRusultVO.setFileOid(uuid);
|
codeImProtRusultVO.setFilePath(errorFile);
|
R result = R.fail("导入失败");
|
result.setData(codeImProtRusultVO);
|
// result.setObj(codeImProtRusultVO);
|
return result;
|
}finally {
|
file1.delete();
|
}
|
}
|
|
|
/**
|
* 修改状态
|
* @param baseModelDTO 数据传输对象
|
* @return 执行结果
|
*/
|
@PostMapping("changeStatus")
|
public R changeStatus(BaseModelDTO baseModelDTO) {
|
engineService.changeStatus(baseModelDTO);
|
return R.success("操作成功！");
|
}
|
|
|
/**
|
* 申请编码保存
|
* @param orderDTO 编码申请相关的信息，需要有属性和码段相关的信息
|
* @return 执行结果
|
*/
|
@PostMapping("/addSaveCode")
|
@VciBusinessLog(operateName = "申请单个编码")
|
public R addSaveCode(@RequestBody CodeOrderDTO orderDTO){
|
return R.success(engineService.addSaveCode(orderDTO));
|
}
|
}
|
