合并代码

yun-zuoyi
Silliter 6 years ago
commit 89b7bf03df

@ -79,6 +79,7 @@
<orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" /> <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" />
<orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.6" level="project" /> <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.6" level="project" />
<orderEntry type="module" module-name="i3plus-pojo-report" /> <orderEntry type="module" module-name="i3plus-pojo-report" />
<orderEntry type="module" module-name="i3plus-pojo-form" />
<orderEntry type="module" module-name="i3plus-pojo-wms" /> <orderEntry type="module" module-name="i3plus-pojo-wms" />
<orderEntry type="library" name="Maven: org.apache.shiro:shiro-core:1.4.0" level="project" /> <orderEntry type="library" name="Maven: org.apache.shiro:shiro-core:1.4.0" level="project" />
<orderEntry type="library" name="Maven: org.apache.shiro:shiro-lang:1.4.0" level="project" /> <orderEntry type="library" name="Maven: org.apache.shiro:shiro-lang:1.4.0" level="project" />

@ -74,4 +74,12 @@ public interface ISysFileService {
*/ */
@ApiOperation(value = "上传文件资源",notes = "上传文件资源") @ApiOperation(value = "上传文件资源",notes = "上传文件资源")
SysFile uploadFile(Object file) throws Exception; SysFile uploadFile(Object file) throws Exception;
/**
*
* @param fileCode
* @return
*/
@ApiOperation(value = "根据文件代码获取文件信息")
SysFile getSysFileByFileCode(String fileCode);
} }

@ -1,5 +1,6 @@
package cn.estsh.i3plus.core.api.iservice.busi; package cn.estsh.i3plus.core.api.iservice.busi;
import cn.estsh.i3plus.pojo.base.bean.DdlPackBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.platform.bean.SysUser; import cn.estsh.i3plus.pojo.platform.bean.SysUser;
@ -21,4 +22,7 @@ public interface ITestService {
@ApiOperation(value = "条件查询") @ApiOperation(value = "条件查询")
public ListPager<SysUser> querySysUserByPager(SysUser user, Pager pager); public ListPager<SysUser> querySysUserByPager(SysUser user, Pager pager);
@ApiOperation(value = "in条件封装查询")
List<SysUser> querySysUserByPack(DdlPackBean packBean);
} }

@ -110,10 +110,11 @@
<orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" /> <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-annotations:2.9.0" level="project" />
<orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.6" level="project" /> <orderEntry type="library" name="Maven: com.fasterxml.jackson.core:jackson-core:2.9.6" level="project" />
<orderEntry type="module" module-name="i3plus-pojo-report" /> <orderEntry type="module" module-name="i3plus-pojo-report" />
<orderEntry type="module" module-name="i3plus-pojo-form" />
<orderEntry type="module" module-name="i3plus-pojo-wms" /> <orderEntry type="module" module-name="i3plus-pojo-wms" />
<orderEntry type="module" module-name="i3plus-pojo-base" /> <orderEntry type="module" module-name="i3plus-pojo-base" />
<orderEntry type="module" module-name="i3plus-core-api" /> <orderEntry type="module" module-name="i3plus-core-api" />
<orderEntry type="module" module-name="impp-framework-boot" /> <orderEntry type="library" name="Maven: impp.framework:impp-framework-boot:1.0-TEST-SNAPSHOT" level="project" />
<orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-web:2.0.3.RELEASE" level="project" /> <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-web:2.0.3.RELEASE" level="project" />
<orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-json:2.0.3.RELEASE" level="project" /> <orderEntry type="library" name="Maven: org.springframework.boot:spring-boot-starter-json:2.0.3.RELEASE" level="project" />
<orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.9.6" level="project" /> <orderEntry type="library" name="Maven: com.fasterxml.jackson.datatype:jackson-datatype-jdk8:2.9.6" level="project" />

@ -2,10 +2,13 @@ package cn.estsh.i3plus.core.apiservice.controller;
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService; import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
import cn.estsh.i3plus.core.api.iservice.busi.ITestService; import cn.estsh.i3plus.core.api.iservice.busi.ITestService;
import cn.estsh.i3plus.pojo.base.bean.BaseResultBean;
import cn.estsh.i3plus.pojo.base.bean.DdlPackBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack;
import cn.estsh.i3plus.pojo.base.tool.HqlPack; import cn.estsh.i3plus.pojo.base.tool.HqlPack;
import cn.estsh.i3plus.pojo.platform.bean.SysUser; import cn.estsh.i3plus.pojo.platform.bean.SysUser;
import cn.estsh.impp.framework.boot.exception.ImppBusiException; import cn.estsh.impp.framework.boot.exception.ImppBusiException;
@ -22,6 +25,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import java.sql.SQLException; import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
@RestController @RestController
@RequestMapping("/impp-ddl") @RequestMapping("/impp-ddl")
@ -44,4 +49,37 @@ public class DemoDdlPackController {
return ResultBean.fail(busExcep); return ResultBean.fail(busExcep);
} }
} }
@GetMapping(value="/testpackin")
@ApiOperation(value="ddl封装in")
public BaseResultBean testDdlPackIn(int testType){
String[] strArr = {"1","2"};
Integer[] intArr = {1,2};
List strList = new ArrayList();
strList.add("1");
strList.add("2");
List intList = new ArrayList();
intList.add(1);
intList.add(2);
DdlPackBean packBean = new DdlPackBean(true);
if(testType == 1) {
DdlPreparedPack.getInPack("aaa", "userName", packBean);
}else if(testType == 2) {
DdlPreparedPack.getInPackArray(strArr, "userName", packBean);
}else if(testType == 3) {
DdlPreparedPack.getInPackArray(intArr, "userStatus", packBean);
}else if(testType == 4) {
DdlPreparedPack.getInPackList(strList, "userName", packBean);
}else if(testType == 5) {
DdlPreparedPack.getInPackList(intList, "userStatus", packBean);
}
List<SysUser> list = testService.querySysUserByPack(packBean);
return ResultBean.success("用户数量:" + list.size())
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultList(list);
}
} }

@ -3,7 +3,6 @@ package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysDictionaryService; import cn.estsh.i3plus.core.api.iservice.busi.ISysDictionaryService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysFileService; import cn.estsh.i3plus.core.api.iservice.busi.ISysFileService;
import cn.estsh.i3plus.platform.common.tool.StringTool; import cn.estsh.i3plus.platform.common.tool.StringTool;
import cn.estsh.i3plus.platform.common.util.CommonConstWords;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords; import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.bean.BaseConstWords; import cn.estsh.i3plus.pojo.base.bean.BaseConstWords;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
@ -26,7 +25,6 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import javax.servlet.http.HttpServletResponse; import javax.servlet.http.HttpServletResponse;
import java.io.BufferedInputStream; import java.io.BufferedInputStream;
import java.io.IOException; import java.io.IOException;
@ -57,13 +55,14 @@ public class SysFileController extends CoreBaseController{
private FastDFSClient dfsClient; private FastDFSClient dfsClient;
@PutMapping(value = "/update") @PutMapping(value = "/update")
@ApiOperation(value = "修改文件资源",notes = "修改文件资源") @ApiOperation(value = "修改文件资源", notes = "修改文件资源")
public ResultBean updateSysFile(SysFile sysFile){ public ResultBean updateSysFile(SysFile sysFile){
try { try {
// 条件验证 // 条件验证
ValidatorBean.beginValid(sysFile) ValidatorBean.beginValid(sysFile)
.notNull("id",sysFile.getId()) .notNull("id", sysFile.getId())
.notNull("name",sysFile.getName()); .notNull("fileSoftType", sysFile.getFileSoftType())
.notNull("name", sysFile.getName());
sysFileService.updateSysFile(sysFile); sysFileService.updateSysFile(sysFile);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
@ -75,10 +74,18 @@ public class SysFileController extends CoreBaseController{
} }
@DeleteMapping(value = "/delete/{id}") @DeleteMapping(value = "/delete/{id}")
@ApiOperation(value = "根据id删除文件资源",notes = "根据id删除文件资源") @ApiOperation(value = "根据id删除文件资源", notes = "根据id删除文件资源")
public ResultBean deleteSysFileById(@PathVariable("id") String id){ public ResultBean deleteSysFileById(@PathVariable("id") String idStr){
try { try {
sysFileService.deleteSysFileById(Long.parseLong(id)); ValidatorBean.checkNotNull(idStr, "id不能为空");
SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(idStr));
ValidatorBean.checkNotNull(sysFile, "文件信息不存在");
LOGGER.info("FastDFS删除文件 == groupName: {}name{}", sysFile.getDfsGroupName(), sysFile.getDfsFileName());
dfsClient.deleteFile(sysFile.getDfsGroupName(), sysFile.getDfsFileName());
sysFileService.deleteSysFileById(Long.parseLong(idStr));
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep); return ResultBean.fail(busExcep);
@ -88,7 +95,7 @@ public class SysFileController extends CoreBaseController{
} }
@GetMapping(value = "/list") @GetMapping(value = "/list")
@ApiOperation(value = "查询全部文件资源",notes = "查询全部文件资源") @ApiOperation(value = "查询全部文件资源", notes = "查询全部文件资源")
public ResultBean findSysFileAll(SysFile sysFile){ public ResultBean findSysFileAll(SysFile sysFile){
try { try {
List<SysFile> sysFileList = sysFileService.listSysFile(); List<SysFile> sysFileList = sysFileService.listSysFile();
@ -103,12 +110,14 @@ public class SysFileController extends CoreBaseController{
} }
@GetMapping(value = "/get/{id}") @GetMapping(value = "/get/{id}")
@ApiOperation(value = "根据id查询文件资源",notes = "根据id查询文件资源") @ApiOperation(value = "根据id查询文件资源", notes = "根据id查询文件资源")
public ResultBean getSysFileById(@PathVariable("id") String id){ public ResultBean getSysFileById(@PathVariable("id") String id){
try { try {
ValidatorBean.checkIsNumber(id,"id必须为数字"); ValidatorBean.checkIsNumber(id, "id必须为数字");
SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(id)); SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(id));
ValidatorBean.checkNotNull(sysFile, "文件信息不存在");
return ResultBean.success("操作成功") return ResultBean.success("操作成功")
.setResultObject(sysFile) .setResultObject(sysFile)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
@ -120,10 +129,10 @@ public class SysFileController extends CoreBaseController{
} }
@GetMapping(value = "/query") @GetMapping(value = "/query")
@ApiOperation(value = "文件资源复杂查询,分页,排序",notes = "文件资源复杂查询,分页,排序") @ApiOperation(value = "文件资源复杂查询,分页,排序", notes = "文件资源复杂查询,分页,排序")
public ResultBean querySysFileByPager(SysFile sysFile, Pager pager){ public ResultBean querySysFileByPager(SysFile sysFile, Pager pager){
try { try {
ListPager sysFileListPager = sysFileService.querySysFileByPager(sysFile,pager); ListPager sysFileListPager = sysFileService.querySysFileByPager(sysFile, pager);
return ResultBean.success("操作成功").setListPager(sysFileListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("操作成功").setListPager(sysFileListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep); return ResultBean.fail(busExcep);
@ -133,7 +142,7 @@ public class SysFileController extends CoreBaseController{
} }
@DeleteMapping(value = "/batch-delete") @DeleteMapping(value = "/batch-delete")
@ApiOperation(value = "批量删除文件资源",notes = "批量删除文件资源") @ApiOperation(value = "批量删除文件资源", notes = "批量删除文件资源")
public ResultBean deleteSysFileByIds(String[] ids){ public ResultBean deleteSysFileByIds(String[] ids){
try{ try{
if(ids.length == 0){ if(ids.length == 0){
@ -154,7 +163,7 @@ public class SysFileController extends CoreBaseController{
} }
@PostMapping("/upload") @PostMapping("/upload")
@ApiOperation(value = "文件上传",notes = "文件上传") @ApiOperation(value = "文件上传", notes = "文件上传")
public ResultBean singleFileUpload(@RequestParam("file") MultipartFile file) { public ResultBean singleFileUpload(@RequestParam("file") MultipartFile file) {
try { try {
if(file.isEmpty()){ if(file.isEmpty()){
@ -186,10 +195,10 @@ public class SysFileController extends CoreBaseController{
} }
@GetMapping("/download/{id}") @GetMapping("/download/{id}")
@ApiOperation(value = "文件下载",notes = "文件下载") @ApiOperation(value = "文件下载", notes = "文件下载")
public ResultBean singleDownload(@PathVariable("id")String id, HttpServletResponse response) { public ResultBean singleDownload(@PathVariable("id")String id, HttpServletResponse response) {
try { try {
ValidatorBean.checkIsNumber(id,"文件ID不能为空"); ValidatorBean.checkIsNumber(id, "文件ID不能为空");
SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(id)); SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(id));
if(sysFile == null){ if(sysFile == null){
@ -210,9 +219,9 @@ public class SysFileController extends CoreBaseController{
.build(); .build();
} }
response.setContentType("application/force-download");// 设置强制下载不打开 response.setContentType("application/force-download"); // 设置强制下载不打开
response.addHeader("Content-Disposition", "attachment;fileName=" + sysFile.getFileOriginalName());// 设置文件名 response.addHeader("Content-Disposition", "attachment;fileName=" + sysFile.getFileOriginalName()); // 设置文件名
response.addHeader("Content-type", "application/octet-stream");// 设置文件名 response.addHeader("Content-type", "application/octet-stream"); // 设置文件名
BufferedInputStream bis = null; BufferedInputStream bis = null;
try { try {
@ -248,18 +257,19 @@ public class SysFileController extends CoreBaseController{
} }
@PostMapping(value = "/insert") @PostMapping(value = "/insert")
@ApiOperation(value = "新增文件资源",notes = "新增文件资源") @ApiOperation(value = "新增文件资源", notes = "新增文件资源")
public ResultBean insertSysFile(@RequestBody SysFile sysFile){ public ResultBean insertSysFile(@RequestBody SysFile sysFile){
try { try {
// 条件验证 // 条件验证
ValidatorBean.beginValid(sysFile) ValidatorBean.beginValid(sysFile)
.notNull("dfsFileName",sysFile.getDfsFileName()) .notNull("dfsFileName", sysFile.getDfsFileName())
.notNull("dfsGroupName",sysFile.getDfsGroupName()) .notNull("dfsGroupName", sysFile.getDfsGroupName())
.notNull("fileOriginalName",sysFile.getFileOriginalName()); .notNull("fileSoftType", sysFile.getFileSoftType())
.notNull("fileOriginalName", sysFile.getFileOriginalName());
// 文件类型验证 // 文件类型验证
SysDictionary dictionary = dictionaryService.getSysDictionaryByParentCodeAndCode(BaseConstWords.DICTIONARY_FILE_TYPE, SysDictionary dictionary = dictionaryService.getSysDictionaryByParentCodeAndCode(BaseConstWords.DICTIONARY_FILE_TYPE,
StringTool.getStringFileSuffix(sysFile.getFileOriginalName(),false)); StringTool.getStringFileSuffix(sysFile.getFileOriginalName(), false));
if(dictionary == null){ if(dictionary == null){
throw ImppExceptionBuilder.newInstance() throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode()) .setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
@ -282,4 +292,25 @@ public class SysFileController extends CoreBaseController{
} }
} }
/**
*
* @param fileCode
* @return
*/
@GetMapping("/get-file-code/{code}")
@ApiOperation(value = "根据文件代码查询文件信息")
public ResultBean getSysFileByFileCode(@PathVariable("code") String fileCode) {
try {
// 条件验证
ValidatorBean.checkNotNull(fileCode, "文件代码不能为空");
SysFile sysFile = sysFileService.getSysFileByFileCode(fileCode);
ValidatorBean.checkNotNull(sysFile, "文件信息不存在");
return ResultBean.success().setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysFile);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
} }

@ -314,6 +314,7 @@ public class SysOrderNoRuleController extends CoreBaseController {
SysFile sysFile = new SysFile(); SysFile sysFile = new SysFile();
sysFile.setDfsGroupName(fileAbsolutePath[0]); sysFile.setDfsGroupName(fileAbsolutePath[0]);
sysFile.setDfsFileName(fileAbsolutePath[1]); sysFile.setDfsFileName(fileAbsolutePath[1]);
sysFile.setFileSoftType(CommonEnumUtil.SOFT_TYPE.CORE.getValue());
sysFile.setFileSize(fastDFSFile.getContent().length); sysFile.setFileSize(fastDFSFile.getContent().length);
sysFile.setFilePath(filePath); sysFile.setFilePath(filePath);
sysFile.setFileOriginalName(fastDFSFile.getName()); sysFile.setFileOriginalName(fastDFSFile.getName());

@ -8,11 +8,14 @@ import cn.estsh.i3plus.pojo.base.bean.BaseConstWords;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper; import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysDictionary; import cn.estsh.i3plus.pojo.platform.bean.SysDictionary;
import cn.estsh.i3plus.pojo.platform.bean.SysFile; import cn.estsh.i3plus.pojo.platform.bean.SysFile;
import cn.estsh.i3plus.pojo.platform.repository.SysDictionaryRepository; import cn.estsh.i3plus.pojo.platform.repository.SysDictionaryRepository;
import cn.estsh.i3plus.pojo.platform.repository.SysFileRepository; import cn.estsh.i3plus.pojo.platform.repository.SysFileRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack; import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import cn.estsh.impp.framework.boot.fastdfs.FastDFSClient; import cn.estsh.impp.framework.boot.fastdfs.FastDFSClient;
import cn.estsh.impp.framework.boot.fastdfs.FastDFSFile; import cn.estsh.impp.framework.boot.fastdfs.FastDFSFile;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
@ -21,7 +24,6 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.multipart.MultipartFile;
import java.io.File; import java.io.File;
import java.util.List; import java.util.List;
@ -48,49 +50,73 @@ public class SysFileServiceImpl implements ISysFileService {
@Override @Override
@ApiOperation(value = "新增资源信息") @ApiOperation(value = "新增资源信息")
public SysFile insertSysFile(SysFile sysFile) { public SysFile insertSysFile(SysFile sysFile) {
LOGGER.info("文件资源 SYS_FILE :{}",sysFile); LOGGER.info("文件资源 SYS_FILE :{}", sysFile);
if (sysFile.getFileCode() != null) {
SysFile fileCode = sysFileRDao.getByProperty("fileCode", sysFile.getFileCode());
if (fileCode != null) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("文件代码已存在。")
.setErrorSolution("请更换文件代码")
.build();
}
}
return sysFileRDao.insert(sysFile); return sysFileRDao.insert(sysFile);
} }
@Override @Override
@ApiOperation(value = "更新资源信息") @ApiOperation(value = "更新资源信息")
public void updateSysFile(SysFile sysFile) { public void updateSysFile(SysFile sysFile) {
LOGGER.info("文件资源 SYS_FILE :{}",sysFile); LOGGER.info("文件资源 SYS_FILE :{}", sysFile);
if (sysFile.getFileCode() != null) {
List list = sysFileRDao.findByHqlWhere(CoreHqlPack.packHqlSysFileCode(sysFile));
if (list != null && list.size() > 0) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("文件代码已存在。")
.setErrorSolution("请更换文件代码")
.build();
}
}
sysFileRDao.update(sysFile); sysFileRDao.update(sysFile);
} }
@Override @Override
@ApiOperation(value = "查询资源信息",notes = "查询所有资源信息") @ApiOperation(value = "查询资源信息", notes = "查询所有资源信息")
public List<SysFile> listSysFile() { public List<SysFile> listSysFile() {
LOGGER.info("文件资源 SYS_FILE list"); LOGGER.info("文件资源 SYS_FILE list");
return sysFileRDao.list(); return sysFileRDao.list();
} }
@Override @Override
@ApiOperation(value = "查询资源信息",notes = "根据 ID查询资源信息") @ApiOperation(value = "查询资源信息", notes = "根据 ID查询资源信息")
public SysFile getSysFileById(Long id) { public SysFile getSysFileById(Long id) {
LOGGER.info("文件资源 SYS_FILE id:{}",id); LOGGER.info("文件资源 SYS_FILE id:{}", id);
return sysFileRDao.getById(id); return sysFileRDao.getById(id);
} }
@Override @Override
@ApiOperation(value = "查询资源信息",notes = "查询资源信息(分页、组合)") @ApiOperation(value = "查询资源信息", notes = "查询资源信息(分页、组合)")
public ListPager querySysFileByPager(SysFile sysFile, Pager pager) { public ListPager querySysFileByPager(SysFile sysFile, Pager pager) {
LOGGER.info("文件资源 SYS_FILE sysFile:{}Pager:{}",sysFile,pager); LOGGER.info("文件资源 SYS_FILE sysFile:{}Pager:{}", sysFile, pager);
if(sysFile == null) { if (sysFile == null) {
pager = PagerHelper.getPager(pager, sysFileRDao.listCount()); pager = PagerHelper.getPager(pager, sysFileRDao.listCount());
return new ListPager(sysFileRDao.listPager(pager),pager); return new ListPager(sysFileRDao.listPager(pager), pager);
}else { } else {
String hqlPack = CoreHqlPack.packHqlSysFile(sysFile); String hqlPack = CoreHqlPack.packHqlSysFile(sysFile);
pager = PagerHelper.getPager(pager, sysFileRDao.findByHqlWhereCount(hqlPack)); pager = PagerHelper.getPager(pager, sysFileRDao.findByHqlWhereCount(hqlPack));
return new ListPager(sysFileRDao.findByHqlWherePage(hqlPack + sysFile.orderBy(),pager),pager); return new ListPager(sysFileRDao.findByHqlWherePage(hqlPack + sysFile.orderBy(), pager), pager);
} }
} }
@Override @Override
@ApiOperation(value = "删除资源信息",notes = "根据ID删除资源信息") @ApiOperation(value = "删除资源信息", notes = "根据ID删除资源信息")
public void deleteSysFileById(Long id) { public void deleteSysFileById(Long id) {
LOGGER.info("文件资源 SYS_FILE id:{}",id); LOGGER.info("文件资源 SYS_FILE id:{}", id);
sysFileRDao.deleteById(id); sysFileRDao.deleteById(id);
} }
@ -101,33 +127,34 @@ public class SysFileServiceImpl implements ISysFileService {
} }
@Override @Override
@ApiOperation(value = "上传文件资源",notes = "上传文件资源") @ApiOperation(value = "上传文件资源", notes = "上传文件资源")
public SysFile uploadFile(Object file) throws Exception{ public SysFile uploadFile(Object file) throws Exception {
FastDFSFile fastDFSFile; FastDFSFile fastDFSFile;
// 判断参数类型 // 判断参数类型
if(file instanceof File){ if (file instanceof File) {
fastDFSFile = new FastDFSFile(((File)file).getName(), FileUtil.file2Byte(((File)file).getPath()), fastDFSFile = new FastDFSFile((( File ) file).getName(), FileUtil.file2Byte((( File ) file).getPath()),
StringTool.getStringFileSuffix(((File)file).getName(),true)); StringTool.getStringFileSuffix((( File ) file).getName(), true));
}else{ } else {
fastDFSFile = dfsClient.saveFile((MultipartFile) file); fastDFSFile = dfsClient.saveFile(( MultipartFile ) file);
} }
String[] fileAbsolutePath = dfsClient.upload(fastDFSFile); String[] fileAbsolutePath = dfsClient.upload(fastDFSFile);
// 保存到系统文件表中 // 保存到系统文件表中
String filePath = dfsClient.getHostUi() + "/" + fileAbsolutePath[0] + "/" + fileAbsolutePath[1]; String filePath = dfsClient.getHostUi() + "/" + fileAbsolutePath[0] + "/" + fileAbsolutePath[1];
SysDictionary dictionary = sysDictionaryRDao.getByProperty(new String[]{"parentCodeRdd","dictionaryValue"}, SysDictionary dictionary = sysDictionaryRDao.getByProperty(new String[]{"parentCodeRdd", "dictionaryValue"},
new Object[]{BaseConstWords.DICTIONARY_FILE_TYPE, fastDFSFile.getExt()}); new Object[]{BaseConstWords.DICTIONARY_FILE_TYPE, fastDFSFile.getExt()});
if(dictionary == null){ if (dictionary == null) {
dictionary = sysDictionaryRDao.getByProperty(new String[]{"parentCodeRdd","dictionaryValue"}, dictionary = sysDictionaryRDao.getByProperty(new String[]{"parentCodeRdd", "dictionaryValue"},
new Object[]{BaseConstWords.DICTIONARY_FILE_TYPE, "."+fastDFSFile.getExt()}); new Object[]{BaseConstWords.DICTIONARY_FILE_TYPE, "." + fastDFSFile.getExt()});
} }
SysFile sysFile = new SysFile(); SysFile sysFile = new SysFile();
sysFile.setDfsGroupName(fileAbsolutePath[0]); sysFile.setDfsGroupName(fileAbsolutePath[0]);
sysFile.setDfsFileName(fileAbsolutePath[1]); sysFile.setDfsFileName(fileAbsolutePath[1]);
sysFile.setFileSoftType(CommonEnumUtil.SOFT_TYPE.CORE.getValue());
sysFile.setFileSize(fastDFSFile.getContent().length); sysFile.setFileSize(fastDFSFile.getContent().length);
sysFile.setFilePath(filePath); sysFile.setFilePath(filePath);
sysFile.setFileOriginalName(fastDFSFile.getName()); sysFile.setFileOriginalName(fastDFSFile.getName());
@ -138,4 +165,9 @@ public class SysFileServiceImpl implements ISysFileService {
return insertSysFile(sysFile); return insertSysFile(sysFile);
} }
@Override
public SysFile getSysFileByFileCode(String fileCode) {
return sysFileRDao.getByProperty("fileCode", fileCode);
}
} }

@ -75,4 +75,9 @@ public class TestService implements ITestService {
return list; return list;
} }
@Override
public List<SysUser> querySysUserByPack(DdlPackBean packBean) {
return sysUserRDao.findByHqlWhere(packBean);
}
} }

Loading…
Cancel
Save