Compare commits

..

No commits in common. "8619126d168ce651d67bc79a0e8491173d5e1824" and "eea01eab93b3e7761d12dbcc38d8c5a7254fa900" have entirely different histories.

43 changed files with 180 additions and 1161 deletions

2
.gitignore vendored
View File

@ -24,5 +24,3 @@ hs_err_pid*
.vs .vs
.idea .idea
*.iml
**/target/

View File

@ -5,12 +5,12 @@ import com.electromagnetic.industry.software.data.manage.request.indicator.EDDat
import electromagnetic.data.framework.share.model.ElectromagneticResult; import electromagnetic.data.framework.share.model.ElectromagneticResult;
import electromagnetic.data.framework.share.model.ElectromagneticResultUtil; import electromagnetic.data.framework.share.model.ElectromagneticResultUtil;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.multipart.MultipartFile; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import java.util.Date;
@RequestMapping("/data/ed/file") @RequestMapping("/data/ed/file")
@RestController @RestController
@ -33,29 +33,16 @@ public class EDDataController {
} }
@ApiOperation(value = "更新文件信息",notes = "") @ApiOperation(value = "更新文件占用状态",notes = "")
@RequestMapping(value = "/updateFileInfo",method = RequestMethod.POST) @RequestMapping(value = "/updateFileStatus",method = RequestMethod.POST)
public ElectromagneticResult<?> updateFileInfo(@RequestBody EDDataRequest request){ public ElectromagneticResult<?> updateFileStatus(@RequestBody EDDataRequest request){
return edDataFacade.updateFileInfo(request); return edDataFacade.updateFileStatus(request);
}
@ApiOperation(value = "获取子文件数量",notes = "")
@RequestMapping(value = "/getChildFileCount",method = RequestMethod.POST)
public ElectromagneticResult<?> getChildFileCount(@RequestBody EDDataRequest request){
return edDataFacade.getChildFileCount(request);
} }
@ApiOperation(value = "上传",notes = "") @ApiOperation(value = "上传",notes = "")
@RequestMapping(value = "/upload", consumes = "multipart/form-data",method = RequestMethod.POST) @RequestMapping(value = "/upload",method = RequestMethod.POST)
public ElectromagneticResult<?> upload(@RequestParam("parentId") String parentId, public ElectromagneticResult<?> upload(@RequestBody EDDataRequest request){
@RequestParam("file") MultipartFile file,
@RequestParam("gmtBatchUpload") Long gmtBatchUpload){
EDDataRequest request = new EDDataRequest();
request.setParentId(parentId);
request.setFileData(file);
request.setGmtBatchUpload(new Date(gmtBatchUpload));
return edDataFacade.upload(request); return edDataFacade.upload(request);
} }
@ -74,4 +61,10 @@ public class EDDataController {
} }
@ApiOperation(value = "重命名",notes = "")
@RequestMapping(value = "/rename",method = RequestMethod.POST)
public ElectromagneticResult<?> rename(@RequestBody EDDataRequest request){
return ElectromagneticResultUtil.success("重命名");
}
} }

View File

@ -50,19 +50,19 @@ public class UserController {
} }
@ApiOperation(value = "查询用户信息", notes = "") @ApiOperation(value = "查询用户信息", notes = "")
@RequestMapping(value = "/list", method = RequestMethod.POST) @RequestMapping(value = "/list", method = RequestMethod.GET)
public ElectromagneticResult<?> searchUser(@RequestBody SearchUserRequest searchUserRequest) { public ElectromagneticResult<?> searchUser(SearchUserRequest searchUserRequest) {
return userFacade.searchUser(searchUserRequest); return userFacade.searchUser(searchUserRequest);
} }
@ApiOperation(value = "校验工号唯一性", notes = "") @ApiOperation(value = "校验工号唯一性", notes = "")
@RequestMapping(value = "/validateWorkNumber", method = RequestMethod.POST) @RequestMapping(value = "/validate", method = RequestMethod.POST)
public ElectromagneticResult<?> validateWorkNum(@RequestBody UserWorkNumRequest userWorkNumRequest) { public ElectromagneticResult<?> validateWorkNum(@RequestBody UserWorkNumRequest userWorkNumRequest) {
return userFacade.validateWorkNum(userWorkNumRequest); return userFacade.validateWorkNum(userWorkNumRequest);
} }
@ApiOperation(value="删除用户信息",notes="") @ApiOperation(value="删除用户信息",notes="")
@PostMapping(value = "/deleteUser") @GetMapping(value = "/deleteUser")
public ElectromagneticResult<?> deleteUser(@RequestBody UserDeleteRequest userDeleteRequest) { public ElectromagneticResult<?> deleteUser(@RequestBody UserDeleteRequest userDeleteRequest) {
return userFacade.deleteUser(userDeleteRequest); return userFacade.deleteUser(userDeleteRequest);
} }

View File

@ -53,22 +53,6 @@ public class EDDataInfo {
* 状态publish:发布occupy:占用 * 状态publish:发布occupy:占用
*/ */
private String dataStatus; private String dataStatus;
/**
* 备注
*/
private String note;
/**
* 编辑人
*/
private String editor;
/**
* 批量上传时间
*/
private Date gmtBatchUpload;
/**
* 保存状态
*/
private String saveStatus;
/** /**
* 创建人 * 创建人
*/ */

View File

@ -1,10 +1,8 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames; package com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames;
import lombok.Data; import lombok.Data;
import org.springframework.web.multipart.MultipartFile;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date;
@Data @Data
public class EDDataParams implements Serializable { public class EDDataParams implements Serializable {
@ -20,49 +18,21 @@ public class EDDataParams implements Serializable {
/** /**
* 上级文件夹数据码,为空是顶级 * 上级文件夹数据码,为空是顶级
*/ */
private String parentId; private Long parentId;
/**
* 文件数据编码
*/
private String dataId;
/** /**
* 文件夹名称 * 文件夹名称
*/ */
private String name; private String name;
/**
* 创建日期排序
*/
private String gmtCreate;
/**
* 文件数据状态
*/
private String dataStatus;
/**
* 备注
*/
private String note;
/**
* 是否有效
*/
private String effectFlag;
/** /**
* 关键词 * 关键词
*/ */
private String keyWord; private String keyWord;
/** /**
* 批量上传时间 * 文件数据编码
*/ */
private Date gmtBatchUpload; private String dataId;
/** /**
* 保存状态 * 文件数据状态
*/ */
private String saveStatus; private String dataStatus;
/**
* 文件数据编码数组
*/
private String[] dataIdArr;
/**
* 文件数据
*/
private MultipartFile fileData;
} }

View File

@ -7,8 +7,6 @@ import com.electromagnetic.industry.software.data.manage.domain.boardservice.ind
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import java.util.List;
/** /**
* @author * @author
* @version $Id: EDDataRepos.java, v 0.1 2024-07-29 19:02 * @version $Id: EDDataRepos.java, v 0.1 2024-07-29 19:02
@ -16,32 +14,32 @@ import java.util.List;
public interface EDDataRepository { public interface EDDataRepository {
/** /**
* 创建文件/文件数据信息 * 创建文件
* @param edDataInfo * @param edDataInfo
* @return * @return
*/ */
Boolean createDataInfo(EDDataInfo edDataInfo); Boolean createFolder(EDDataInfo edDataInfo);
/** /**
* 获取文件信息列表 * 获取文件信息列表
* @param parames * @param parames
* @return * @return
*/ */
List<EDDataInfo> getDataInfoList(EDDataParams parames); PageInfo<EDDataInfo> getDataInfoList(EDDataParams parames);
/** /**
* 获取文件信息 * 更新文件占用状态
* @param parames * @param parames
* @return * @return
*/ */
EDDataInfo getDataInfo(EDDataParams parames); Boolean updateFileStatus(EDDataParams parames);
/** /**
* 更新文件信息 * 上传
* @param parames * @param parames
* @return * @return
*/ */
Boolean updateFileInfo(EDDataParams parames); Boolean upload(EDDataParams parames);
/** /**
* 下载 * 下载

View File

@ -7,11 +7,11 @@ import com.electromagnetic.industry.software.data.manage.domain.boardservice.ind
public interface EDDataService { public interface EDDataService {
/** /**
* 创建文件/文件数据信息 * 创建文件
* @param edDataInfo * @param edDataInfo
* @return * @return
*/ */
Boolean createDataInfo(EDDataInfo edDataInfo); Boolean createFolder(EDDataInfo edDataInfo);
/** /**
* 获取文件信息列表 * 获取文件信息列表
@ -21,25 +21,18 @@ public interface EDDataService {
EDDataPage getDataInfoList(EDDataParams parames); EDDataPage getDataInfoList(EDDataParams parames);
/** /**
* 获取文件信息 * 更新文件占用状态
* @param parames * @param parames
* @return * @return
*/ */
EDDataInfo getDataInfo(EDDataParams parames); Boolean updateFileStatus(EDDataParams parames);
/** /**
* 更新文件信息 * 上传
* @param parames * @param parames
* @return * @return
*/ */
Boolean updateFileInfo(EDDataParams parames); Boolean upload(EDDataParams parames);
/**
* 获取子文件数量
* @param parames
* @return
*/
Integer getChildFileCount(EDDataParams parames);
/** /**
* 下载 * 下载
@ -48,18 +41,4 @@ public interface EDDataService {
*/ */
Boolean download(EDDataParams parames); Boolean download(EDDataParams parames);
/**
* 检查文件夹是否存在
* @param path
* @return
*/
Boolean checkFolderIsExist(String path);
/**
* 创建多级目录
* @param path
* @return
*/
Boolean createMultiLevelDirectory(String path);
} }

View File

@ -3,13 +3,11 @@
*/ */
package com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.impl; package com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.impl;
import cn.hutool.poi.excel.cell.CellSetter;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataPage; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataPage;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.repository.EDDataRepository; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.repository.EDDataRepository;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.EDDataService; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.EDDataService;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo; import com.github.pagehelper.PageInfo;
import electromagnetic.data.framework.share.exception.LoggerConstant; import electromagnetic.data.framework.share.exception.LoggerConstant;
import org.slf4j.Logger; import org.slf4j.Logger;
@ -17,10 +15,6 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.util.List;
/** /**
* @author * @author
@ -36,13 +30,13 @@ public class EDDataServiceImpl implements EDDataService {
/** /**
* 创建文件/文件数据信息 * 创建文件
* @param edDataInfo * @param edDataInfo
* @return * @return
*/ */
public Boolean createDataInfo(EDDataInfo edDataInfo) public Boolean createFolder(EDDataInfo edDataInfo)
{ {
edDataRepository.createDataInfo(edDataInfo); edDataRepository.createFolder(edDataInfo);
return Boolean.TRUE; return Boolean.TRUE;
} }
@ -53,59 +47,33 @@ public class EDDataServiceImpl implements EDDataService {
*/ */
public EDDataPage getDataInfoList(EDDataParams parames) public EDDataPage getDataInfoList(EDDataParams parames)
{ {
PageHelper.startPage(parames.getPageIndex(), parames.getPageSize());
List<EDDataInfo> edDataInfoList = edDataRepository.getDataInfoList(parames);
PageInfo<EDDataInfo> pageInfo = new PageInfo<>(edDataInfoList);
EDDataPage edDataPage=new EDDataPage(); EDDataPage edDataPage=new EDDataPage();
//数据查询
PageInfo<EDDataInfo> pageInfo = edDataRepository.getDataInfoList(parames);
edDataPage.setEdDataInfo(pageInfo); edDataPage.setEdDataInfo(pageInfo);
return edDataPage; return edDataPage;
} }
/** /**
* 获取文件信息 * 更新文件占用状态
* @param parames * @param parames
* @return * @return
*/ */
public EDDataInfo getDataInfo(EDDataParams parames) public Boolean updateFileStatus(EDDataParams parames)
{ {
return edDataRepository.getDataInfo(parames); edDataRepository.updateFileStatus(parames);
}
/**
* 更新文件信息
* @param parames
* @return
*/
public Boolean updateFileInfo(EDDataParams parames)
{
edDataRepository.updateFileInfo(parames);
return Boolean.TRUE; return Boolean.TRUE;
} }
/** /**
* 获取子文件数量 * 上传
* @param parames * @param parames
* @return * @return
*/ */
public Integer getChildFileCount(EDDataParams parames) public Boolean upload(EDDataParams parames)
{ {
Integer childFileCount = 0; edDataRepository.upload(parames);
return Boolean.TRUE;
List<EDDataInfo> edDataInfoList = edDataRepository.getDataInfoList(parames);
for (EDDataInfo edDataInfo : edDataInfoList) {
if(edDataInfo.getDataType().equals("folder"))
{
parames.setParentId(edDataInfo.getDataId());
childFileCount += getChildFileCount(parames);
}
else if(edDataInfo.getDataType().equals("file"))
{
++childFileCount;
}
}
return childFileCount;
} }
/** /**
@ -119,30 +87,6 @@ public class EDDataServiceImpl implements EDDataService {
return Boolean.TRUE; return Boolean.TRUE;
} }
/**
* 检查文件夹是否存在
* @param path
* @return
*/
public Boolean checkFolderIsExist(String path)
{
return Files.exists(Paths.get(path));
}
/**
* 创建多级目录
* @param path
* @return
*/
public Boolean createMultiLevelDirectory(String path)
{
try {
Files.createDirectories(Paths.get(path));
return Boolean.TRUE;
} catch (IOException e) {
return Boolean.FALSE;
}
}
} }

View File

@ -23,7 +23,7 @@ public class LoginInterceptor implements HandlerInterceptor {
response.setStatus(401); response.setStatus(401);
return false; return false;
} else { } else {
//token = token.substring(7); token = token.substring(7);
} }
boolean result = tokenService.isTokenValid(token.substring(7)); boolean result = tokenService.isTokenValid(token.substring(7));
if (!result) { if (!result) {

View File

@ -1,25 +0,0 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params;
import java.util.List;
import lombok.Data;
@Data
public class PublishParam {
private static final long serialVersionUID = 1L;
/**
* 用户编码
*/
private List<String> userIds;
/**
* 编辑者
*/
private String modifier;
/**
* 编辑者姓名
*/
private String modifierName;
}

View File

@ -17,7 +17,7 @@ public class SearchKeyWords {
/** /**
* 用户发布状态 * 用户发布状态
*/ */
private String isPublished; private int isPublished;
/** /**
* 排序方式: "asc" "desc" * 排序方式: "asc" "desc"
@ -33,14 +33,4 @@ public class SearchKeyWords {
* 排序方式: "asc" "desc" * 排序方式: "asc" "desc"
*/ */
private String internEndDate; private String internEndDate;
/**
* 页码
*/
private int pageIndex;
/**
* 单页条目数量
*/
private int pageSize;
} }

View File

@ -1,29 +0,0 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params;
import lombok.Data;
import java.util.Date;
@Data
public class UserDeleteKeyWords {
/**
* 主键ID
*/
private Long id;
/**
* 用户编码
*/
private String userId;
/**
* 更新人
*/
private String modifier;
/**
* 更新人姓名
*/
private String modifierName;
}

View File

@ -15,19 +15,4 @@ public interface CategoryRepository {
* 获取所有节点 * 获取所有节点
*/ */
List<Category> getAllCategories(); List<Category> getAllCategories();
/**
* 获取节点通过编码ID
* @param category
* @return
*/
List<Category> selectCategories(Category category);
/**
* 获取子节点通过父ID
* @param category
* @return
*/
List<Category> selectChildCategories(Category category);
} }

View File

@ -1,10 +1,7 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository; package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import java.util.List; import java.util.List;
public interface UserRepository { public interface UserRepository {
@ -25,10 +22,10 @@ public interface UserRepository {
/** /**
* 用户发布 * 用户发布
* @param publishParam * @param userIds
* @return * @return
*/ */
int publish(PublishParam publishParam); int publish(List<String> userIds);
/** /**
* 通过工号查询用户 * 通过工号查询用户
@ -51,18 +48,11 @@ public interface UserRepository {
*/ */
List<User> search(SearchKeyWords searchKeyWords); List<User> search(SearchKeyWords searchKeyWords);
/**
* 查询数据总条目数
* @param searchKeywords
* @return
*/
int getTotalCount (SearchKeyWords searchKeywords);
/** /**
* 删除用户 * 删除用户
* @param userId * @param userId
* @return * @return
*/ */
int deleteUser(UserDeleteKeyWords userDeleteKeyWords); int deleteUser(String userId);
} }

View File

@ -11,32 +11,4 @@ public interface CategoryService {
*/ */
public List<Category> buildCategoryTree(); public List<Category> buildCategoryTree();
/**
* 获取所有节点
* @return
*/
List<Category> selectAllCategories();
/**
* 获取节点通过编码ID
* @param category
* @return
*/
List<Category> selectCategories(Category category);
/**
* 获取子节点通过父ID
* @param category
* @return
*/
List<Category> selectChildCategories(Category category);
/**
* 获取 指定节点的 父节点 从所有节点数组中
* @param categoryId
* @param categoryList
* @return
*/
Category getParentCategories(String categoryId, List<Category> categoryList);
} }

View File

@ -1,9 +1,7 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service; package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import java.util.List; import java.util.List;
@ -25,10 +23,10 @@ public interface UserService {
/** /**
* 用户发布 * 用户发布
* @param publishParam * @param userIds
* @return * @return
*/ */
Boolean publishUser(PublishParam publishParam); Boolean publishUser(List<String> userIds);
/** /**
* 通过工号查询用户 * 通过工号查询用户
@ -60,17 +58,10 @@ public interface UserService {
*/ */
List<User> searchUser(SearchKeyWords searchKeyWords); List<User> searchUser(SearchKeyWords searchKeyWords);
/**
* 查询数据总条目数
* @param searchKeywords
* @return
*/
int getTotalCount (SearchKeyWords searchKeywords);
/** /**
* 根据userId逻辑删除用户 * 根据userId逻辑删除用户
* @param userId * @param userId
* @return * @return
*/ */
Boolean deleteUser(UserDeleteKeyWords userDeleteKeyWords); Boolean deleteUser(String userId);
} }

View File

@ -80,55 +80,4 @@ public class CategoryServiceImpl implements CategoryService {
private boolean hasChild(List<Category> list, Category category) { private boolean hasChild(List<Category> list, Category category) {
return !getChildList(list, category).isEmpty(); return !getChildList(list, category).isEmpty();
} }
/**
* 获取所有节点
* @return
*/
public List<Category> selectAllCategories() { return categoryRepository.getAllCategories(); }
/**
* 获取节点通过编码ID
* @param category
* @return
*/
public List<Category> selectCategories(Category category) { return categoryRepository.selectCategories(category); }
/**
* 获取子节点通过父ID
* @param category
* @return
*/
public List<Category> selectChildCategories(Category category) { return categoryRepository.selectChildCategories(category); }
/**
* 获取 指定节点的 父节点 从所有节点数组中
* @param categoryId
* @param categoryList
* @return
*/
public Category getParentCategories(String categoryId, List<Category> categoryList)
{
Category category = null;
Category categoryParent = null;
for(Category iter : categoryList)
{
if(category == null && iter.getCategoryId().equals(categoryId))
{
category = iter;
break;
}
}
for(Category iter : categoryList)
{
if(categoryParent == null && iter.getCategoryId().equals(category.getParentId()))
{
categoryParent = iter;
break;
}
}
return categoryParent;
}
} }

View File

@ -1,9 +1,7 @@
package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.impl; package com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.impl;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository.UserRepository; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository.UserRepository;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.UserService; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.UserService;
import electromagnetic.data.framework.share.exception.LoggerConstant; import electromagnetic.data.framework.share.exception.LoggerConstant;
@ -69,11 +67,11 @@ public class UserServiceImpl implements UserService {
/** /**
* 用户发布 * 用户发布
* @param publishParam * @param userIds
* @return * @return
*/ */
@Override @Override
public Boolean publishUser(PublishParam publishParam) { return userRepository.publish(publishParam)>0; } public Boolean publishUser(List<String> userIds) { return userRepository.publish(userIds)>0; }
/** /**
* 获取单条用户信息 * 获取单条用户信息
@ -91,24 +89,14 @@ public class UserServiceImpl implements UserService {
@Override @Override
public List<User> searchUser(SearchKeyWords searchKeyWords) { return userRepository.search(searchKeyWords); } public List<User> searchUser(SearchKeyWords searchKeyWords) { return userRepository.search(searchKeyWords); }
/**
* 查询数据总条目数
* @param searchKeywords
* @return
*/
@Override
public int getTotalCount (SearchKeyWords searchKeywords) {
return userRepository.getTotalCount(searchKeywords);
}
/** /**
* 根据userId逻辑删除用户 * 根据userId逻辑删除用户
* *
* @param userDeleteKeyWords * @param userId
* @return * @return
*/ */
@Override @Override
public Boolean deleteUser(UserDeleteKeyWords userDeleteKeyWords) { public Boolean deleteUser(String userId) {
return userRepository.deleteUser(userDeleteKeyWords)>0; return userRepository.deleteUser(userId)>0;
} }
} }

View File

@ -18,10 +18,6 @@
<groupId>com.electromagnetic.data</groupId> <groupId>com.electromagnetic.data</groupId>
<artifactId>electromagnetic-framework</artifactId> <artifactId>electromagnetic-framework</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
</dependency>
</dependencies> </dependencies>

View File

@ -4,9 +4,6 @@ import com.electromagnetic.industry.software.data.manage.request.indicator.EDDat
import com.electromagnetic.industry.software.data.manage.response.indicator.EDDataPageResponse; import com.electromagnetic.industry.software.data.manage.response.indicator.EDDataPageResponse;
import electromagnetic.data.framework.share.model.ElectromagneticResult; import electromagnetic.data.framework.share.model.ElectromagneticResult;
import java.util.List;
import java.util.Map;
public interface EDDataFacade { public interface EDDataFacade {
/** /**
@ -25,18 +22,11 @@ public interface EDDataFacade {
ElectromagneticResult<EDDataPageResponse> getDataInfoList(EDDataRequest request); ElectromagneticResult<EDDataPageResponse> getDataInfoList(EDDataRequest request);
/** /**
* 更新文件信息 * 更新文件占用状态
* @param request * @param request
* @return * @return
*/ */
ElectromagneticResult<Boolean> updateFileInfo(EDDataRequest request); ElectromagneticResult<Boolean> updateFileStatus(EDDataRequest request);
/**
* 获取子文件数量
* @param request
* @return
*/
ElectromagneticResult<Map<String, Integer>> getChildFileCount(EDDataRequest request);
/** /**
* 上传 * 上传
@ -50,20 +40,6 @@ public interface EDDataFacade {
* @param request * @param request
* @return * @return
*/ */
ElectromagneticResult<Map<String, List<String>>> download(EDDataRequest request); ElectromagneticResult<Boolean> download(EDDataRequest request);
/**
* 导出
* @param request
* @return
*/
ElectromagneticResult<String> batchExport(EDDataRequest request);
/**
* 导入
* @param request
* @return
*/
ElectromagneticResult<String> batchImport(EDDataRequest request);
} }

View File

@ -1,11 +1,8 @@
package com.electromagnetic.industry.software.data.manage.request.indicator; package com.electromagnetic.industry.software.data.manage.request.indicator;
import org.springframework.web.multipart.MultipartFile;
import electromagnetic.data.framework.share.model.BaseRequest; import electromagnetic.data.framework.share.model.BaseRequest;
import lombok.Data; import lombok.Data;
import java.util.Date;
@Data @Data
public class EDDataRequest extends BaseRequest { public class EDDataRequest extends BaseRequest {
@ -20,49 +17,21 @@ public class EDDataRequest extends BaseRequest {
/** /**
* 上级文件夹数据码,为空是顶级 * 上级文件夹数据码,为空是顶级
*/ */
private String parentId; private Long parentId;
/**
* 文件数据编码
*/
private String dataId;
/** /**
* 文件夹名称 * 文件夹名称
*/ */
private String name; private String name;
/**
* 创建日期排序
*/
private String gmtCreate;
/**
* 文件数据状态
*/
private String dataStatus;
/**
* 备注
*/
private String note;
/**
* 是否有效
*/
private String effectFlag;
/** /**
* 关键词 * 关键词
*/ */
private String keyWord; private String keyWord;
/** /**
* 批量上传时间 * 文件数据编码
*/ */
private Date gmtBatchUpload; private String dataId;
/** /**
* 保存状态 * 文件数据状态
*/ */
private String saveStatus; private String dataStatus;
/**
* 文件数据编码数组
*/
private String[] dataIdArr;
/**
* 文件数据
*/
private MultipartFile fileData;
} }

View File

@ -22,10 +22,19 @@ public class SearchUserRequest extends BaseRequest implements Serializable {
private String userStatus; private String userStatus;
/** /**
* 用户发布状态1已发布0未发布 * 用户发布状态
*/ */
private String isPublished; private int isPublished;
// /**
// * 排序字段: "gmtCreate", "joinTime", "internEndDate"
// */
// private String sortBy;
//
// /**
// * 排序方式: "asc" "desc"
// */
// private String sortOrder;
/** /**
* 排序方式: "asc" "desc" * 排序方式: "asc" "desc"
*/ */
@ -40,14 +49,4 @@ public class SearchUserRequest extends BaseRequest implements Serializable {
* 排序方式: "asc" "desc" * 排序方式: "asc" "desc"
*/ */
private String internEndDate; private String internEndDate;
/**
* 页码
*/
private int pageIndex;
/**
* 单页条目数量
*/
private int pageSize;
} }

View File

@ -17,14 +17,4 @@ public class UserDeleteRequest extends BaseRequest implements Serializable {
* 用户编码 * 用户编码
*/ */
private String userId; private String userId;
/**
* 更新人姓名
*/
private String modifier;
/**
* 更新人工号
*/
private String modifierName;
} }

View File

@ -23,6 +23,8 @@ public class UserModiRequest extends BaseRequest implements Serializable {
*/ */
private String userName; private String userName;
/** /**
* 工号 * 工号
*/ */

View File

@ -18,14 +18,4 @@ public class UserPublishRequest extends BaseRequest implements Serializable {
* 用户编码 * 用户编码
*/ */
private List<String> userIds; private List<String> userIds;
/**
* 编辑者
*/
private String modifier;
/**
* 编辑者姓名
*/
private String modifierName;
} }

View File

@ -62,15 +62,4 @@ public class UserRequest extends BaseRequest implements Serializable {
* 创建者姓名 * 创建者姓名
*/ */
private String creatorName; private String creatorName;
/**
* 编辑者userId
*/
private String modifier;
/**
* 编辑者姓名
*/
private String modifierName;
} }

View File

@ -19,9 +19,4 @@ public class UserWorkNumRequest extends BaseRequest implements Serializable {
*/ */
private String workNumber; private String workNumber;
/**
* 用户编号
*/
private String userID;
} }

View File

@ -1,8 +1,13 @@
package com.electromagnetic.industry.software.data.manage.response.user; package com.electromagnetic.industry.software.data.manage.response.user;
import com.electromagnetic.industry.software.data.manage.response.indicator.IndicatorCardResponse;
import com.electromagnetic.industry.software.data.manage.response.indicator.IndicatorResponse;
import lombok.Data; import lombok.Data;
import java.io.Serializable;
import java.util.Date; import java.util.Date;
import java.util.List;
@Data @Data
public class SingleUserResponse { public class SingleUserResponse {

View File

@ -1,13 +0,0 @@
package com.electromagnetic.industry.software.data.manage.response.user;
import lombok.Data;
import java.io.Serializable;
@Data
public class UserLoginResponse implements Serializable {
private String token;
private String userId;
}

View File

@ -22,10 +22,5 @@ public class UserSearchResponse implements Serializable {
* 用户列表 * 用户列表
*/ */
private List<SingleUserResponse> userList; private List<SingleUserResponse> userList;
//private List<User> userList;
/**
* 总数据数
*/
private long totalCount;
} }

View File

@ -19,16 +19,4 @@ public interface CategoryMapper {
* @return * @return
*/ */
List<Category> selectAllCategories(); List<Category> selectAllCategories();
/**
* 获取节点通过编码ID
* @return
*/
List<Category> selectCategories(Category category);
/**
* 获取子节点通过父ID
* @return
*/
List<Category> selectChildCategories(Category category);
} }

View File

@ -2,8 +2,6 @@ package com.electromagnetic.industry.software.data.manage.repository.dao;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams;
import com.electromagnetic.industry.software.data.manage.request.indicator.EDDataRequest;
import electromagnetic.data.framework.share.model.ElectromagneticResult;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import java.util.List; import java.util.List;
@ -26,10 +24,11 @@ public interface EDDataMapper {
List<EDDataInfo> getDataInfoList(EDDataParams parames); List<EDDataInfo> getDataInfoList(EDDataParams parames);
/** /**
* 更新文件信息 * 更新文件占用状态
* @param parames * @param parames
* @return * @return
*/ */
Boolean updateFileInfo(EDDataParams parames); Boolean updateFileStatus(EDDataParams parames);
} }

View File

@ -1,9 +1,7 @@
package com.electromagnetic.industry.software.data.manage.repository.dao; package com.electromagnetic.industry.software.data.manage.repository.dao;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Mapper;
import java.util.List; import java.util.List;
@ -26,10 +24,10 @@ public interface UserMapper {
/** /**
* 发布 * 发布
* @param publishParam * @param userIds
* @return * @return
*/ */
int publish(PublishParam publishParam); int publish(List<String> userIds);
/** /**
* 通过工号查询用户 * 通过工号查询用户
@ -52,17 +50,10 @@ public interface UserMapper {
*/ */
List<User> search(SearchKeyWords searchKeywords); List<User> search(SearchKeyWords searchKeywords);
/**
* 查询数据总条目数
* @param searchKeywords
* @return
*/
int getTotalCount (SearchKeyWords searchKeywords);
/** /**
* 通过用户ID删除用户 * 通过用户ID删除用户
* @param userId * @param userId
* @return * @return
*/ */
int deleteUser(UserDeleteKeyWords userDeleteKeyWords); int deleteUser(String userId);
} }

View File

@ -26,22 +26,8 @@ public class CategoryRepositoryImpl implements CategoryRepository {
* 获取所有节点 * 获取所有节点
*/ */
@Override @Override
public List<Category> getAllCategories() { return categoryMapper.selectAllCategories(); } public List<Category> getAllCategories(){
return categoryMapper.selectAllCategories();
/** }
* 获取节点通过编码ID
* @param category
* @return
*/
@Override
public List<Category> selectCategories(Category category) { return categoryMapper.selectCategories(category); }
/**
* 获取子节点通过父ID
* @param category
* @return
*/
@Override
public List<Category> selectChildCategories(Category category) { return categoryMapper.selectChildCategories(category); }
} }

View File

@ -25,13 +25,13 @@ public class EDDataRepositoryImpl implements EDDataRepository {
private EDDataMapper edDataMapper; private EDDataMapper edDataMapper;
/** /**
* 创建文件/文件数据信息 * 创建文件
* *
* @param edDataInfo * @param edDataInfo
* @return * @return
*/ */
@Override @Override
public Boolean createDataInfo(EDDataInfo edDataInfo) public Boolean createFolder(EDDataInfo edDataInfo)
{ {
return edDataMapper.createDataInfo(edDataInfo); return edDataMapper.createDataInfo(edDataInfo);
} }
@ -42,35 +42,35 @@ public class EDDataRepositoryImpl implements EDDataRepository {
* @return * @return
*/ */
@Override @Override
public List<EDDataInfo> getDataInfoList(EDDataParams parames) public PageInfo<EDDataInfo> getDataInfoList(EDDataParams parames)
{
return edDataMapper.getDataInfoList(parames);
}
/**
* 获取文件信息
* @param parames
* @return
*/
@Override
public EDDataInfo getDataInfo(EDDataParams parames)
{ {
PageHelper.startPage(parames.getPageIndex(), parames.getPageSize());
List<EDDataInfo> edDataInfoList=edDataMapper.getDataInfoList(parames); List<EDDataInfo> edDataInfoList=edDataMapper.getDataInfoList(parames);
if(edDataInfoList.size()>0) return new PageInfo<>(edDataInfoList);
return edDataInfoList.get(0);
else
return null;
} }
/** /**
* 更新文件信息 * 更新文件占用状态
* @param parames * @param parames
* @return * @return
*/ */
@Override @Override
public Boolean updateFileInfo(EDDataParams parames) public Boolean updateFileStatus(EDDataParams parames)
{ {
return edDataMapper.updateFileInfo(parames); return edDataMapper.updateFileStatus(parames);
}
/**
* 上传
* @param parames
* @return
*/
@Override
public Boolean upload(EDDataParams parames)
{
//return edDataMapper.upload(parames);
//edDataMapper.createDataInfo(edDataInfo);
return Boolean.TRUE;
} }
/** /**
@ -86,5 +86,4 @@ public class EDDataRepositoryImpl implements EDDataRepository {
} }
} }

View File

@ -4,10 +4,8 @@
package com.electromagnetic.industry.software.data.manage.repository.impl; package com.electromagnetic.industry.software.data.manage.repository.impl;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository.UserRepository; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.repository.UserRepository;
import com.electromagnetic.industry.software.data.manage.repository.dao.UserMapper; import com.electromagnetic.industry.software.data.manage.repository.dao.UserMapper;
import org.springframework.stereotype.Repository; import org.springframework.stereotype.Repository;
@ -45,12 +43,12 @@ public class UserRepositoryImpl implements UserRepository {
/** /**
* 用户发布 * 用户发布
* *
* @param publishParam * @param userIds
* @return * @return
*/ */
@Override @Override
public int publish(PublishParam publishParam) { public int publish(List<String> userIds) {
return userMapper.publish(publishParam); return userMapper.publish(userIds);
} }
/** /**
@ -83,22 +81,14 @@ public class UserRepositoryImpl implements UserRepository {
return userMapper.search(searchKeywords); return userMapper.search(searchKeywords);
} }
/**
* 查询数据总条目数
* @param searchKeywords
* @return
*/
@Override
public int getTotalCount (SearchKeyWords searchKeywords) {return userMapper.getTotalCount(searchKeywords);}
/** /**
* 删除用户 * 删除用户
* @param userDeleteKeyWords * @param userId
* @return * @return
*/ */
@Override @Override
public int deleteUser(UserDeleteKeyWords userDeleteKeyWords) { public int deleteUser(String userId) {
return userMapper.deleteUser(userDeleteKeyWords); return userMapper.deleteUser(userId);
} }

View File

@ -32,17 +32,4 @@
<include refid="selectUserVo" /> <include refid="selectUserVo" />
where category_status="available" where category_status="available"
</select> </select>
<select id="selectCategories" resultMap="CategoryResultMap"
parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.category.model.Category">
<include refid="selectUserVo" />
where category_id = categoryId and category_status="available"
</select>
<select id="selectChildCategories" resultMap="CategoryResultMap"
parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.category.model.Category">
<include refid="selectUserVo" />
where parent_id = parentId and category_status="available"
</select>
</mapper> </mapper>

View File

@ -14,10 +14,6 @@
<result column="content" jdbcType="VARCHAR" property="content" /> <result column="content" jdbcType="VARCHAR" property="content" />
<result column="implant_json" jdbcType="VARCHAR" property="implantJson" /> <result column="implant_json" jdbcType="VARCHAR" property="implantJson" />
<result column="data_status" jdbcType="VARCHAR" property="dataStatus" /> <result column="data_status" jdbcType="VARCHAR" property="dataStatus" />
<result column="note" jdbcType="VARCHAR" property="note" />
<result column="editor" jdbcType="VARCHAR" property="editor" />
<result column="gmt_batch_upload" jdbcType="TIMESTAMP" property="gmtBatchUpload" />
<result column="save_status" jdbcType="VARCHAR" property="saveStatus" />
<result column="creator" jdbcType="VARCHAR" property="creator" /> <result column="creator" jdbcType="VARCHAR" property="creator" />
<result column="creator_name" jdbcType="VARCHAR" property="creatorName" /> <result column="creator_name" jdbcType="VARCHAR" property="creatorName" />
<result column="gmt_create" jdbcType="TIMESTAMP" property="gmtCreate" /> <result column="gmt_create" jdbcType="TIMESTAMP" property="gmtCreate" />
@ -28,7 +24,7 @@
</resultMap> </resultMap>
<sql id="Base_Column_list"> <sql id="Base_Column_list">
id,category_id,data_id,data_no,data_name,data_type,file_type,version,content, id,category_id,data_id,data_no,data_name,data_type,file_type,version,content,
implant_json,data_status,note,editor,gmt_batch_upload,save_status,creator,creator_name,gmt_create,modifier,modifier_name, implant_json,data_status,creator,creator_name,gmt_create,modifier,modifier_name,
gmt_modified,effect_flag gmt_modified,effect_flag
</sql> </sql>
@ -39,18 +35,16 @@
</selectKey> </selectKey>
insert into ed_data_info (id, category_id, insert into ed_data_info (id, category_id,
data_id, data_no, data_name, data_id, data_no, data_name,
data_type, file_type, version, data_type, file_type,
content, implant_json, data_status, version,content, implant_json, data_status,
note, editor, gmt_batch_upload, save_status,
creator, creator_name, gmt_create, creator, creator_name, gmt_create,
modifier, modifier_name, gmt_modified, modifier, modifier_name, gmt_modified,
effect_flag effect_flag
) )
values (#{id,jdbcType=VARCHAR}, #{categoryId,jdbcType=VARCHAR}, values (#{id,jdbcType=VARCHAR}, #{categoryId,jdbcType=VARCHAR},
#{dataId,jdbcType=VARCHAR}, #{dataNo,jdbcType=VARCHAR}, #{dataName,jdbcType=VARCHAR}, #{dataId,jdbcType=VARCHAR}, #{dataNo,jdbcType=VARCHAR}, #{dataName,jdbcType=VARCHAR},
#{dataType,jdbcType=VARCHAR}, #{fileType,jdbcType=VARCHAR},#{version,jdbcType=VARCHAR}, #{dataType,jdbcType=VARCHAR}, #{fileType,jdbcType=VARCHAR},
#{content,jdbcType=VARCHAR}, #{implantJson,jdbcType=VARCHAR}, #{dataStatus,jdbcType=VARCHAR}, #{version,jdbcType=VARCHAR},#{content,jdbcType=VARCHAR}, #{implantJson,jdbcType=VARCHAR}, #{dataStatus,jdbcType=VARCHAR},
#{note,jdbcType=VARCHAR}, #{editor,jdbcType=VARCHAR}, #{gmtBatchUpload,jdbcType=TIMESTAMP}, #{saveStatus,jdbcType=VARCHAR},
#{creator,jdbcType=VARCHAR}, #{creatorName,jdbcType=VARCHAR}, now(), #{modifier,jdbcType=VARCHAR}, #{creator,jdbcType=VARCHAR}, #{creatorName,jdbcType=VARCHAR}, now(), #{modifier,jdbcType=VARCHAR},
#{modifierName,jdbcType=VARCHAR},now(),1 #{modifierName,jdbcType=VARCHAR},now(),1
) )
@ -67,45 +61,23 @@
<if test="parentId!=null and parentId!=''"> <if test="parentId!=null and parentId!=''">
and category_id='${parentId}' and category_id='${parentId}'
</if> </if>
<if test="dataId!=null and dataId!=''">
and data_id='${dataId}'
</if>
<if test="keyWord!=null and keyWord!=''"> <if test="keyWord!=null and keyWord!=''">
and data_name LIKE '%${keyWord}%' and data_name LIKE '%${keyWord}%'
</if> </if>
<if test="saveStatus!=null and saveStatus!=''">
and save_status='${saveStatus}'
</if>
GROUP BY id GROUP BY id
<if test="gmtCreate == 'asc' or gmtCreate =='desc'"> order by gmt_modified asc
order by gmt_create ${gmtCreate}
</if>
</select> </select>
<update id="updateFileInfo" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams"> <update id="updateFileStatus" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams">
update ed_data_info update ed_data_info
<set> <set>
<if test="name != null and name!=''">
data_name = #{name,jdbcType=VARCHAR},
</if>
<if test="dataStatus != null and dataStatus!=''"> <if test="dataStatus != null and dataStatus!=''">
data_status = #{dataStatus,jdbcType=VARCHAR}, data_status = #{dataStatus,jdbcType=VARCHAR},
</if> </if>
<if test="note != null and note!=''">
note = #{note,jdbcType=VARCHAR},
</if>
<if test="saveStatus != null and note!=''">
save_status = #{saveStatus,jdbcType=VARCHAR},
</if>
<if test="effectFlag != null and effectFlag!=''">
effect_flag = #{effectFlag,jdbcType=VARCHAR},
</if>
gmt_modified = now() gmt_modified = now()
</set> </set>
where data_id = #{dataId,jdbcType=VARCHAR} and effect_flag = 1 where data_id = #{dataId,jdbcType=VARCHAR} and effect_flag = 1
</update> </update>
</mapper> </mapper>

View File

@ -83,16 +83,14 @@
<if test="modifier != null and modifier != ''">modifier = #{modifier},</if> <if test="modifier != null and modifier != ''">modifier = #{modifier},</if>
<if test="modifierName != null and modifierName != ''">modifier_name = #{modifierName},</if> <if test="modifierName != null and modifierName != ''">modifier_name = #{modifierName},</if>
</set> </set>
where user_id= #{userId} where id= #{id}
</update> </update>
<update id="publish" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam"> <update id="publish" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User">
update ed_users update ed_users
<trim prefix="SET" suffixOverrides=","> <trim prefix="SET" suffixOverrides=",">
is_published = 1, is_published = 1
<if test="modifier != null and modifier != ''">modifier = #{modifier},</if>
<if test="modifierName != null and modifierName != ''">modifier_name = #{modifierName},</if>
</trim> </trim>
where user_id IN where user_id IN
<foreach collection="userIds" item="userId" open="(" separator="," close=")"> <foreach collection="userIds" item="userId" open="(" separator="," close=")">
@ -118,50 +116,6 @@
</choose> </choose>
</if> </if>
<!-- 条件 3按发布状态搜索 -->
<if test="isPublished != null and isPublished != ''">
<choose>
<when test="isPublished != 'all'">
AND is_published = CAST(#{isPublished} AS INT)
</when>
</choose>
</if>
and effect_flag=1
</where>
<!-- 动态排序条件 -->
<choose>
<when test="gmtCreate == 'asc' or gmtCreate == 'desc'">
ORDER BY gmt_create ${gmtCreate}
</when>
<when test="joinTime == 'asc' or joinTime == 'desc'">
ORDER BY join_time ${joinTime}
</when>
<when test="internEndDate == 'asc' or internEndDate == 'desc'">
ORDER BY internship_end_date ${internEndDate}
</when>
</choose>
LIMIT #{pageSize} OFFSET #{pageIndex}
</select>
<select id="getTotalCount" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords" resultType="Integer">
SELECT COUNT(*)
FROM ed_users
<where>
<!-- 条件 1按用户名或工号搜索 -->
<if test="keyWord != null and keyWord != ''">
(user_name LIKE CONCAT('%', #{keyWord}, '%') OR work_number LIKE CONCAT('%', #{keyWord}, '%'))
</if>
<!-- 条件 2按用户状态搜索 -->
<if test="userStatus != null and userStatus != ''">
<choose>
<when test="userStatus != 'all'">
AND user_status = #{userStatus}
</when>
</choose>
</if>
<!-- 条件 3按发布状态搜索 --> <!-- 条件 3按发布状态搜索 -->
<if test="isPublished != null and isPublished != ''"> <if test="isPublished != null and isPublished != ''">
<choose> <choose>
@ -170,7 +124,6 @@
</when> </when>
</choose> </choose>
</if> </if>
and effect_flag=1
</where> </where>
<!-- 动态排序条件 --> <!-- 动态排序条件 -->
@ -187,6 +140,7 @@
</choose> </choose>
</select> </select>
<select id="selectUserByWorkNumber" parameterType="String" resultMap="UserResultMap"> <select id="selectUserByWorkNumber" parameterType="String" resultMap="UserResultMap">
<include refid="selectUserVo" /> <include refid="selectUserVo" />
where work_number = #{workNumber} where work_number = #{workNumber}
@ -197,13 +151,9 @@
where user_id = #{userId} where user_id = #{userId}
</select> </select>
<update id="deleteUser" parameterType="com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords"> <update id="deleteUser" parameterType="String">
update ed_users update ed_users
<set> set effect_flag=0
effect_flag=0,
modifier=#{modifier},
modifier_name=#{modifierName}
</set>
where user_id = #{userId} where user_id = #{userId}
</update> </update>
</mapper> </mapper>

View File

@ -1,13 +1,9 @@
package com.electromagnetic.industry.software.data.manage.service.facade; package com.electromagnetic.industry.software.data.manage.service.facade;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.category.model.Category;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataInfo;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataPage; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.model.EDDataPage;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.parames.EDDataParams;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.EDDataService; import com.electromagnetic.industry.software.data.manage.domain.boardservice.indicator.service.EDDataService;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.CategoryService;
import com.electromagnetic.industry.software.data.manage.facade.EDDataFacade; import com.electromagnetic.industry.software.data.manage.facade.EDDataFacade;
import com.electromagnetic.industry.software.data.manage.request.indicator.EDDataRequest; import com.electromagnetic.industry.software.data.manage.request.indicator.EDDataRequest;
import com.electromagnetic.industry.software.data.manage.response.indicator.EDDataPageResponse; import com.electromagnetic.industry.software.data.manage.response.indicator.EDDataPageResponse;
@ -15,23 +11,15 @@ import com.electromagnetic.industry.software.data.manage.service.mappers.EDDataM
import electromagnetic.data.framework.share.id.IdWorker; import electromagnetic.data.framework.share.id.IdWorker;
import electromagnetic.data.framework.share.model.ElectromagneticResult; import electromagnetic.data.framework.share.model.ElectromagneticResult;
import electromagnetic.data.framework.share.model.ElectromagneticResultUtil; import electromagnetic.data.framework.share.model.ElectromagneticResultUtil;
import org.springframework.http.HttpStatus;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.web.multipart.MultipartFile;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.*;
@Service @Service
public class EDDataFacadeImpl implements EDDataFacade { public class EDDataFacadeImpl implements EDDataFacade {
@Resource @Resource
private EDDataService edDataService; private EDDataService edDataService;
private CategoryService categoryService;
/** /**
* 创建文件夹 * 创建文件夹
@ -44,73 +32,21 @@ public class EDDataFacadeImpl implements EDDataFacade {
@Override @Override
public ElectromagneticResult<Boolean> createFolder(EDDataRequest request) { public ElectromagneticResult<Boolean> createFolder(EDDataRequest request) {
EDDataInfo edDataInfo = EDDataMappers.INSTANCE.getEDDataInfo(request); EDDataInfo edDataInfo = EDDataMappers.INSTANCE.getEDDataInfo(request);
// 临时数据设置
if(Boolean.TRUE) {
if (request.getUserId() == null || request.getUserId().isEmpty()) request.setUserId(IdWorker.getSnowFlakeIdString());
if (request.getUserName() == null || request.getUserName().isEmpty()) request.setUserName("user");
if (request.getName() == null || request.getName().isEmpty()) request.setName("testFolder");
//if (request.getParentId() == null || request.getParentId().isEmpty()) request.setParentId(IdWorker.getSnowFlakeIdString());
}
edDataInfo.setCreator(request.getUserId()); edDataInfo.setCreator(request.getUserId());
edDataInfo.setCreatorName(request.getUserName()); edDataInfo.setCreatorName(request.getPersonName());
edDataInfo.setModifier(request.getUserId()); //edDataInfo.setModifier(request.getUserId());
edDataInfo.setModifierName(request.getUserName()); edDataInfo.setModifierName(request.getPersonName());
edDataInfo.setCategoryId(request.getParentId()); edDataInfo.setModifier(IdWorker.getSnowFlakeIdString());
edDataInfo.setDataName(request.getName());
edDataInfo.setNote(request.getNote());
edDataInfo.setCategoryId(IdWorker.getSnowFlakeIdString());
edDataInfo.setDataNo(IdWorker.getSnowFlakeIdString());
edDataInfo.setDataId(IdWorker.getSnowFlakeIdString()); edDataInfo.setDataId(IdWorker.getSnowFlakeIdString());
edDataInfo.setDataNo(edDataInfo.getDataId());
edDataInfo.setDataType("folder"); edDataInfo.setDataType("folder");
edDataInfo.setDataName("testFolder");
edDataInfo.setVersion("1.0.0"); edDataInfo.setVersion("1.0.0");
edDataInfo.setDataStatus("publish"); edDataInfo.setDataStatus("publish");
String parentFolderPath = ""; edDataService.createFolder(edDataInfo);
// 获取上级目录的名称
if(!request.getParentId().isEmpty()) {
EDDataParams parames = new EDDataParams();
parames.setDataId(request.getParentId());
EDDataInfo edDataInfoParent = edDataService.getDataInfo(parames);
if(edDataInfoParent == null) {
ElectromagneticResultUtil.fail(HttpStatus.BAD_REQUEST.toString(),"上级文件夹为空!");
}
String folderNameParent = edDataInfoParent.getDataName();
String folderIdParent = edDataInfoParent.getDataId();
// 记录当前目录的文件夹路径和文件夹id路径
JSONObject implantJsonObject = JSON.parseObject(edDataInfoParent.getImplantJson());
if(implantJsonObject == null) {
implantJsonObject = new JSONObject();
parentFolderPath = folderNameParent;
implantJsonObject.put("folderPath", parentFolderPath);
implantJsonObject.put("folderIdPath", folderIdParent);
}
else
{
String folderPath = implantJsonObject.getString("folderPath");
String folderIdPath = implantJsonObject.getString("folderIdPath");
parentFolderPath = folderPath + "/" + folderNameParent;
implantJsonObject.put("folderPath", parentFolderPath);
implantJsonObject.put("folderIdPath", folderIdPath + "/" + folderIdParent);
}
String newImplantJson = implantJsonObject.toJSONString();
edDataInfo.setImplantJson(newImplantJson);
}
boolean isSuccess = edDataService.createDataInfo(edDataInfo);
if(isSuccess)
{
// 获取文件存储的文件夹路径
String storageDirectory = "D:/fileTemp/" + parentFolderPath + "/" + edDataInfo.getDataName();
if(!edDataService.checkFolderIsExist(storageDirectory)) {
edDataService.createMultiLevelDirectory(storageDirectory);
}
}
return ElectromagneticResultUtil.success(Boolean.TRUE); return ElectromagneticResultUtil.success(Boolean.TRUE);
} }
@ -125,7 +61,6 @@ public class EDDataFacadeImpl implements EDDataFacade {
*/ */
public ElectromagneticResult<EDDataPageResponse> getDataInfoList(EDDataRequest request) public ElectromagneticResult<EDDataPageResponse> getDataInfoList(EDDataRequest request)
{ {
EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request); EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request);
//获取中支指标配置列表 //获取中支指标配置列表
EDDataPage edDataPage = edDataService.getDataInfoList(parames); EDDataPage edDataPage = edDataService.getDataInfoList(parames);
@ -135,35 +70,19 @@ public class EDDataFacadeImpl implements EDDataFacade {
} }
/** /**
* 更新文件信息 * 更新文件占用状态
* WISDOM_UPDATE_FILEINFO * WISDOM_UPDATE_FILESTATUS
* /data/ed/file/updateFileInfo * /data/ed/file/updateFileStatus
* @param request * @param request
* @return * @return
*/ */
public ElectromagneticResult<Boolean> updateFileInfo(EDDataRequest request) public ElectromagneticResult<Boolean> updateFileStatus(EDDataRequest request)
{ {
EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request); EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request);
edDataService.updateFileInfo(parames); edDataService.updateFileStatus(parames);
return ElectromagneticResultUtil.success(Boolean.TRUE); return ElectromagneticResultUtil.success(Boolean.TRUE);
} }
/**
* 获取子文件数量
* WISDOM_GET_CHILDFILECOUNT
* /data/ed/file/getChildFileCount
* @param request
* @return
*/
public ElectromagneticResult<Map<String, Integer>> getChildFileCount(EDDataRequest request)
{
EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request);
Integer fileCount = edDataService.getChildFileCount(parames);
Map<String, Integer> result = new HashMap<>();
result.put("fileCount", fileCount);
return ElectromagneticResultUtil.success(result);
}
/** /**
* 上传 * 上传
* WISDOM_UPLOAD * WISDOM_UPLOAD
@ -174,147 +93,8 @@ public class EDDataFacadeImpl implements EDDataFacade {
public ElectromagneticResult<Boolean> upload(EDDataRequest request) public ElectromagneticResult<Boolean> upload(EDDataRequest request)
{ {
EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request); EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request);
edDataService.upload(parames);
try { return ElectromagneticResultUtil.success(Boolean.TRUE);
// 获取目录编码ID
String categoryId = request.getParentId();
// 获取要上传的文件
MultipartFile fileInput = request.getFileData();
// 检查文件是否为空
if (fileInput == null || fileInput.isEmpty()) {
return ElectromagneticResultUtil.fail(HttpStatus.BAD_REQUEST.toString(),"上传的文件为空");
}
// 获取文件名
String fileFullName = fileInput.getOriginalFilename();
// 获取文件类型
String fileType = "";
// 获取文件名称
String fileName = "";
if (fileFullName.lastIndexOf(".") != -1 && fileFullName.lastIndexOf(".") != 0) {
fileType = fileFullName.substring(fileFullName.lastIndexOf(".") + 1);
fileName = fileFullName.substring(fileFullName.lastIndexOf("."));
}
// 获取文件存储的文件夹路径
String storageDirectory = "D:/fileTemp";
if(!edDataService.checkFolderIsExist(storageDirectory)) {
edDataService.createMultiLevelDirectory(storageDirectory);
}
String parentFolderPath = ""; //上级文件夹路径
String parentFolderIdPath = ""; //上级文件夹ID路径
String parentFolderName = ""; //上级文件夹名称
// 获取上级文件夹路径
{
EDDataParams folderParames = new EDDataParams();
folderParames.setDataId(categoryId);
EDDataInfo edDataInfoParent = edDataService.getDataInfo(folderParames);
if(edDataInfoParent == null) {
ElectromagneticResultUtil.fail(HttpStatus.BAD_REQUEST.toString(),"上级文件夹为空!");
}
JSONObject implantJsonObject = JSON.parseObject(edDataInfoParent.getImplantJson());
parentFolderPath = implantJsonObject.getString("folderPath");
parentFolderIdPath = implantJsonObject.getString("folderIdPath");
if(!parentFolderPath.isEmpty())
parentFolderPath += "/" ;
if(!parentFolderIdPath.isEmpty())
parentFolderIdPath += "/" ;
parentFolderPath += edDataInfoParent.getDataName();
parentFolderIdPath += edDataInfoParent.getDataId();
parentFolderName = edDataInfoParent.getDataName();
}
// 文件保存目录路径
String fileSavePath = storageDirectory + "/" + parentFolderPath;
String treeName = "目录树名称";
//String newFileName = treeName + "," + parentFolderName + "," + fileFullName;
String newFileName = fileFullName;
// 文件数据信息写到数据库
{
// 临时数据设置
if(Boolean.TRUE) {
if (request.getUserId() == null || request.getUserId().isEmpty()) request.setUserId(IdWorker.getSnowFlakeIdString());
if (request.getUserName() == null || request.getUserName().isEmpty()) request.setUserName("user");
//if (request.getName() == null || request.getName().isEmpty()) request.setName("testFolder");
if (request.getParentId() == null || request.getParentId().isEmpty()) request.setParentId(IdWorker.getSnowFlakeIdString());
}
// 创建新文件数据
EDDataInfo edDataInfo = new EDDataInfo();
edDataInfo.setCreator(request.getUserId());
edDataInfo.setCreatorName(request.getUserName());
edDataInfo.setModifier(request.getUserId());
edDataInfo.setModifierName(request.getUserName());
edDataInfo.setCategoryId(request.getParentId());
edDataInfo.setDataName(newFileName);
edDataInfo.setNote(request.getNote());
edDataInfo.setFileType(fileType);
edDataInfo.setGmtBatchUpload(request.getGmtBatchUpload());
edDataInfo.setDataId(IdWorker.getSnowFlakeIdString());
edDataInfo.setDataNo(edDataInfo.getDataId());
edDataInfo.setDataType("file");
edDataInfo.setVersion("1.0.0");
edDataInfo.setDataStatus("publish");
edDataInfo.setSaveStatus("saving");
JSONObject newImplantJsonObject = new JSONObject();
newImplantJsonObject.put("folderPath", parentFolderPath);
newImplantJsonObject.put("folderIdPath", parentFolderIdPath);
edDataInfo.setImplantJson(newImplantJsonObject.toJSONString());
boolean isSuccess = edDataService.createDataInfo(edDataInfo);
String userHome = System.getProperty("user.home");
File cacheDirectory = new File(userHome + "\\AppData\\Local\\Temp\\EDData\\Upload");
if (!cacheDirectory.exists()) {
cacheDirectory.mkdirs();
}
String cacheFolder = cacheDirectory.getAbsolutePath();
String cachePath = cacheFolder + "/" + newFileName;
System.out.println("文件缓存路径为: " + cacheDirectory.getAbsolutePath());
fileSavePath += "/" + newFileName;
// 这里可以添加将文件保存到本地磁盘或其他存储介质的逻辑
File saveFile = new File(cachePath);//fileSavePath
// 将文件保存到硬盘
fileInput.transferTo(saveFile);
EDDataParams fileParames = new EDDataParams();
fileParames.setDataId(edDataInfo.getDataId());
if(fileInput.getSize() == saveFile.length())
{
Path source = Paths.get(cachePath);
Path target = Paths.get(fileSavePath);
Files.move(source, target);
fileParames.setSaveStatus("success");
}
else
{
saveFile.delete();
fileParames.setSaveStatus("failure");
}
isSuccess = edDataService.updateFileInfo(fileParames);
}
// 如果文件上传成功返回成功消息
return ElectromagneticResultUtil.success(Boolean.TRUE);
} catch (Exception e) {
// 如果出现异常返回异常消息
return ElectromagneticResultUtil.fail(HttpStatus.INTERNAL_SERVER_ERROR.toString(),"文件上传失败" + e.getMessage());
}
} }
/** /**
@ -324,127 +104,13 @@ public class EDDataFacadeImpl implements EDDataFacade {
* @param request * @param request
* @return * @return
*/ */
public ElectromagneticResult<Map<String, List<String>>> download(EDDataRequest request) public ElectromagneticResult<Boolean> download(EDDataRequest request)
{ {
//EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request); EDDataParams parames= EDDataMappers.INSTANCE.getEDDataParames(request);
edDataService.download(parames);
// 获取文件存储的文件夹路径 return ElectromagneticResultUtil.success(Boolean.TRUE);
String storageDirectory = "D:/fileTemp";
EDDataParams parames = new EDDataParams();
List<String> dataPathArr = new ArrayList();
for(String dataId : request.getDataIdArr())
{
parames.setDataId(dataId);
EDDataInfo edDataInfo = edDataService.getDataInfo(parames);
if(edDataInfo != null)
{
JSONObject implantJsonObject = JSON.parseObject(edDataInfo.getImplantJson());
String filePath = implantJsonObject.getString("folderPath");
filePath = storageDirectory + "/" + filePath + "/" + edDataInfo.getDataName();
dataPathArr.add(filePath);
}
}
Map<String, List<String>> result = new HashMap<>();
result.put("urlArr", dataPathArr);
return ElectromagneticResultUtil.success(result);
} }
/**
* 导出
* @param request
* @return
*/
@Override
public ElectromagneticResult<String> batchExport(EDDataRequest request) {
//1根据用户选择层级树编码查出所有文件和文件夹list
//2循环list将每个文件复制到新建目录并进行重命名命名规则目录树编码+,+文件夹编码有则填写无则为空+,+文件编码
//3打包新建为zip并根据生产下载地址域名+文件路径+文件
//4返回前端下载的地址
// **********在导出的过程中可能会出现有用户上传文件的情况
// 获取目录编码ID
String categoryId = request.getParentId();
// 获取缓存文件夹的绝对路径
String userHome = System.getProperty("user.home");
File cacheDirectory = new File(userHome + "\\AppData\\Local\\Temp\\EDData\\Export");
if (!cacheDirectory.exists()) {
cacheDirectory.mkdirs();
}
String cacheFolder = cacheDirectory.getAbsolutePath(); // 缓存文件夹的绝对路径
List<Category> categoryList = categoryService.selectAllCategories();
{
// 遍历客户端上传的
EDDataParams folderParames = new EDDataParams();
for (String dataId : request.getDataIdArr()) {
Category category = new Category();
category.setCategoryId(dataId);
categoryService.selectCategories(category);
//folderParames.setDataId(dataId);
//EDDataInfo edDataInfo = edDataService.getDataInfo(folderParames);
//if(edDataInfo != null)
//{
// JSONObject implantJsonObject = JSON.parseObject(edDataInfo.getImplantJson());
// String filePath = implantJsonObject.getString("folderPath");
// filePath = storageDirectory + "/" + filePath + "/" + edDataInfo.getDataName();
// dataPathArr.add(filePath);
//}
}
}
String parentFolderPath = ""; //上级文件夹路径
String parentFolderIdPath = ""; //上级文件夹ID路径
String parentFolderName = ""; //上级文件夹名称
// 获取上级文件夹路径
{
EDDataParams folderParames = new EDDataParams();
folderParames.setDataId(categoryId);
EDDataInfo edDataInfoParent = edDataService.getDataInfo(folderParames);
if(edDataInfoParent == null) {
ElectromagneticResultUtil.fail(HttpStatus.BAD_REQUEST.toString(),"上级文件夹为空!");
}
JSONObject implantJsonObject = JSON.parseObject(edDataInfoParent.getImplantJson());
parentFolderPath = implantJsonObject.getString("folderPath");
parentFolderIdPath = implantJsonObject.getString("folderIdPath");
if(!parentFolderPath.isEmpty())
parentFolderPath += "/" ;
if(!parentFolderIdPath.isEmpty())
parentFolderIdPath += "/" ;
parentFolderPath += edDataInfoParent.getDataName();
parentFolderIdPath += edDataInfoParent.getDataId();
parentFolderName = edDataInfoParent.getDataName();
}
return null;
}
/**
* 导入
* @param request
* @return
*/
@Override
public ElectromagneticResult<String> batchImport(EDDataRequest request) {
//1上传文件到指定目录并重命名
//2接下压缩包
//3扫码解压文件夹的所有文件
//4循环处理文件读取文件名称根据名称规则进行数据库查询匹配层级树文件夹和文件是否跳过
//5如果不存在则新建文件记录
//6并移动文件到上传目录
//7处理完成返回成功
return null;
}
} }

View File

@ -3,9 +3,6 @@ package com.electromagnetic.industry.software.data.manage.service.facade.user;
import com.electromagnetic.industry.software.data.manage.common.ElectromagneticErrorEnum; import com.electromagnetic.industry.software.data.manage.common.ElectromagneticErrorEnum;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.TokenService; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.TokenService;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.UserService; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.service.UserService;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.util.UserConstant; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.util.UserConstant;
@ -16,10 +13,8 @@ import com.electromagnetic.industry.software.data.manage.request.user.UserPublis
import com.electromagnetic.industry.software.data.manage.request.user.UserLoginRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserLoginRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserRequest;
import com.electromagnetic.industry.software.data.manage.response.user.SingleUserResponse; import com.electromagnetic.industry.software.data.manage.response.user.SingleUserResponse;
import com.electromagnetic.industry.software.data.manage.response.user.UserLoginResponse;
import com.electromagnetic.industry.software.data.manage.response.user.UserSearchResponse; import com.electromagnetic.industry.software.data.manage.response.user.UserSearchResponse;
import com.electromagnetic.industry.software.data.manage.service.mappers.UserMappers; import com.electromagnetic.industry.software.data.manage.service.mappers.UserMappers;
import com.github.pagehelper.PageInfo;
import electromagnetic.data.framework.share.id.IdWorker; import electromagnetic.data.framework.share.id.IdWorker;
import electromagnetic.data.framework.share.model.ElectromagneticResult; import electromagnetic.data.framework.share.model.ElectromagneticResult;
import electromagnetic.data.framework.share.model.ElectromagneticResultUtil; import electromagnetic.data.framework.share.model.ElectromagneticResultUtil;
@ -45,17 +40,14 @@ public class UserFacadeImpl implements UserFacade {
* @return * @return
*/ */
@Override @Override
public ElectromagneticResult<UserLoginResponse> login(UserLoginRequest loginRequest) { public ElectromagneticResult<String> login(UserLoginRequest loginRequest) {
UserLoginInfo info = UserMappers.INSTANCE.getUserLoginRequestToModel(loginRequest); UserLoginInfo info = UserMappers.INSTANCE.getUserLoginRequestToModel(loginRequest);
String decodePwd = AESUtils.decrypt(info.getUserPwd(), UserConstant.SECRET_KEY); String decodePwd = AESUtils.decrypt(info.getUserPwd(), UserConstant.SECRET_KEY);
User user = userService.getUserByWorkNumber(info.getWorkNumber()); User user = userService.getUserByWorkNumber(info.getWorkNumber());
if ( user!=null && userService.matchPassword(user, decodePwd)) { if ( user!=null && userService.matchPassword(user, decodePwd)) {
String tokenStr = tokenService.createToken(info); String tokenStr = tokenService.createToken(info);
tokenService.createUserToken(user, tokenStr); tokenService.createUserToken(user, tokenStr);
UserLoginResponse userLoginResponse = new UserLoginResponse(); return ElectromagneticResultUtil.success(tokenStr);
userLoginResponse.setToken(tokenStr);
userLoginResponse.setUserId(user.getUserId());
return ElectromagneticResultUtil.success(userLoginResponse);
} }
return ElectromagneticResultUtil.fail("500","用户不存在/密码错误"); return ElectromagneticResultUtil.fail("500","用户不存在/密码错误");
} }
@ -95,8 +87,7 @@ public class UserFacadeImpl implements UserFacade {
*/ */
@Override @Override
public ElectromagneticResult<Boolean> publishUser(UserPublishRequest userPublishRequest){ public ElectromagneticResult<Boolean> publishUser(UserPublishRequest userPublishRequest){
PublishParam model = UserMappers.INSTANCE.getUserPublishRequestToModel(userPublishRequest); return ElectromagneticResultUtil.success(userService.publishUser(userPublishRequest.getUserIds()));
return ElectromagneticResultUtil.success(userService.publishUser(model));
} }
/** /**
@ -107,41 +98,13 @@ public class UserFacadeImpl implements UserFacade {
*/ */
@Override @Override
public ElectromagneticResult<?> validateWorkNum(UserWorkNumRequest userWorkNumRequest) { public ElectromagneticResult<?> validateWorkNum(UserWorkNumRequest userWorkNumRequest) {
// 前端请求对象转换为模型对象包含userId和userWorkNum // 请求对象转换为模型对象
User user = UserMappers.INSTANCE.getUserWorkNumRequestToModel(userWorkNumRequest); User user = UserMappers.INSTANCE.getUserWorkNumRequestToModel(userWorkNumRequest);
// 尝试根据工号获取用户
//根据请求对象的userId判断当前处于什么状态 User existingUser = userService.getUserByWorkNumber(user.getWorkNumber());
if(user.getUserId()==null){ // 根据是否存在具有相同工号的用户来确定工号的唯一性
//userId为空表示是新增用户阶段 boolean isWorkNumberUnique = (existingUser == null);
//判断数据库中有无该工号对应的用户 return ElectromagneticResultUtil.success(Boolean.valueOf(isWorkNumberUnique));
User existingUser = userService.getUserByWorkNumber(user.getWorkNumber());
//如果有该用户就返回false,如果没有(==null)就返回true
boolean isWorkNumberUnique = (existingUser == null);
return ElectromagneticResultUtil.success(isWorkNumberUnique);
}else{
//userId不为空表示是编辑用户阶段
//请求对象的userWordNum在数据库中对应的user
User existingUser = userService.getUserByWorkNumber(user.getWorkNumber());
//判断请求对象的userId对应的user和请求对象的userWordNum在数据库中对应的user是否为用一个
if(existingUser!=null){
//请求对象的userWordNum在数据库中对应的user与请求对象的userId对应的user是否为同一个
if(user.getUserId().equals(existingUser.getUserId())){
// 如果获取到的用户ID与当前编辑的用户ID相同说明工号未改变直接返回true
return ElectromagneticResultUtil.success(true);
}else{
// 如果获取到的用户ID与当前编辑的用户ID不同说明工号已改变需要判断新工号是否唯一
// 如果根据新工号获取不到用户说明新工号唯一
boolean isWorkNumberUnique = (userService.getUserByWorkNumber(user.getWorkNumber()) == null);
return ElectromagneticResultUtil.success(isWorkNumberUnique);
}
}else{
//请求对象的userWordNum在数据库中不存在对应的user
return ElectromagneticResultUtil.success(true);
}
}
} }
/** /**
@ -163,14 +126,10 @@ public class UserFacadeImpl implements UserFacade {
*/ */
@Override @Override
public ElectromagneticResult<UserSearchResponse> searchUser(SearchUserRequest searchUserRequest){ public ElectromagneticResult<UserSearchResponse> searchUser(SearchUserRequest searchUserRequest){
searchUserRequest.setPageIndex((searchUserRequest.getPageIndex()-1)*searchUserRequest.getPageSize()); List<User> userList = userService.searchUser(UserMappers.INSTANCE.getSearchKeywordsRequestToModel(searchUserRequest));
SearchKeyWords model = UserMappers.INSTANCE.getSearchKeywordsRequestToModel(searchUserRequest);
List<User> userList = userService.searchUser(model);
int totalCount = userService.getTotalCount(model);
List<SingleUserResponse> singleUserResponseList = UserMappers.INSTANCE.userListToResponseList(userList); List<SingleUserResponse> singleUserResponseList = UserMappers.INSTANCE.userListToResponseList(userList);
UserSearchResponse userSearchResponse = new UserSearchResponse(); UserSearchResponse userSearchResponse = new UserSearchResponse();
userSearchResponse.setUserList(singleUserResponseList); userSearchResponse.setUserList(singleUserResponseList);
userSearchResponse.setTotalCount(totalCount);
return ElectromagneticResultUtil.success(userSearchResponse); return ElectromagneticResultUtil.success(userSearchResponse);
} }
@ -182,17 +141,15 @@ public class UserFacadeImpl implements UserFacade {
@Override @Override
public ElectromagneticResult<?> deleteUser(UserDeleteRequest userDeleteRequest) { public ElectromagneticResult<?> deleteUser(UserDeleteRequest userDeleteRequest) {
// 将请求对象转换为模型对象 // 将请求对象转换为模型对象
UserDeleteKeyWords userDeleteKeyWords = UserMappers.INSTANCE.getUserDeleteRequestToModel(userDeleteRequest); User user = UserMappers.INSTANCE.getUserDeleteRequestToModel(userDeleteRequest);
// 检查用户是否已经被逻辑删除 // 检查用户是否已经被逻辑删除
User existingUser = userService.getSingleUser(userDeleteKeyWords.getUserId()); User existingUser = userService.getSingleUser(user.getUserId());
if(existingUser != null && existingUser.getEffectFlag()==0){ if(existingUser != null && existingUser.getEffectFlag()==0){
// 如果用户已经被逻辑删除在这个假设中0 表示已删除则不进行任何操作或返回错误 // 如果用户已经被逻辑删除在这个假设中0 表示已删除则不进行任何操作或返回错误
return ElectromagneticResultUtil.fail(ElectromagneticErrorEnum. FINE_DELETE_USER_ERROR); return ElectromagneticResultUtil.fail(ElectromagneticErrorEnum. FINE_DELETE_USER_ERROR);
} }
if(existingUser!=null && existingUser.getEffectFlag()==1){// 在这个假设中1 表示未删除 if(existingUser!=null && existingUser.getEffectFlag()==1){// 在这个假设中1 表示未删除
return ElectromagneticResultUtil.success(userService.deleteUser(userDeleteKeyWords)); return ElectromagneticResultUtil.success(userService.deleteUser(user.getUserId()));
}else{ }else{
// 如果用户不存在理论上不应该发生除非数据库状态不一致则返回错误 // 如果用户不存在理论上不应该发生除非数据库状态不一致则返回错误
return ElectromagneticResultUtil.fail(ElectromagneticErrorEnum. FINE_DELETE_USER_ERROR); return ElectromagneticResultUtil.fail(ElectromagneticErrorEnum. FINE_DELETE_USER_ERROR);

View File

@ -3,10 +3,8 @@
*/ */
package com.electromagnetic.industry.software.data.manage.service.mappers; package com.electromagnetic.industry.software.data.manage.service.mappers;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import com.electromagnetic.industry.software.data.manage.request.user.UserModiRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserModiRequest;
import com.electromagnetic.industry.software.data.manage.request.user.*; import com.electromagnetic.industry.software.data.manage.request.user.*;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo;
@ -47,14 +45,6 @@ public interface UserMappers {
*/ */
SingleUserResponse getSingleUserToResponse(User user); SingleUserResponse getSingleUserToResponse(User user);
/**
* 用户发布request转用户发布参数模型
* @param userPublishRequest
* @return
*/
PublishParam getUserPublishRequestToModel(UserPublishRequest userPublishRequest);
/** /**
* 获取单条用户信息Request转用户模型 * 获取单条用户信息Request转用户模型
* @param searchUserRequest * @param searchUserRequest
@ -88,7 +78,7 @@ public interface UserMappers {
* @param userDeleteRequest * @param userDeleteRequest
* @return * @return
*/ */
UserDeleteKeyWords getUserDeleteRequestToModel(UserDeleteRequest userDeleteRequest); User getUserDeleteRequestToModel(UserDeleteRequest userDeleteRequest);
} }

View File

@ -2,14 +2,11 @@ package com.electromagnetic.industry.software.data.manage.service.mappers;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.User;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.model.UserLoginInfo;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.PublishParam;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords; import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.SearchKeyWords;
import com.electromagnetic.industry.software.data.manage.domain.boardservice.user.params.UserDeleteKeyWords;
import com.electromagnetic.industry.software.data.manage.request.user.SearchUserRequest; import com.electromagnetic.industry.software.data.manage.request.user.SearchUserRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserDeleteRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserDeleteRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserLoginRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserLoginRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserModiRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserModiRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserPublishRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserRequest;
import com.electromagnetic.industry.software.data.manage.request.user.UserWorkNumRequest; import com.electromagnetic.industry.software.data.manage.request.user.UserWorkNumRequest;
import com.electromagnetic.industry.software.data.manage.response.user.SingleUserResponse; import com.electromagnetic.industry.software.data.manage.response.user.SingleUserResponse;
@ -19,8 +16,8 @@ import javax.annotation.Generated;
@Generated( @Generated(
value = "org.mapstruct.ap.MappingProcessor", value = "org.mapstruct.ap.MappingProcessor",
date = "2024-11-21T15:49:09+0800", date = "2024-11-20T10:52:53+0800",
comments = "version: 1.4.1.Final, compiler: javac, environment: Java 1.8.0_281 (Oracle Corporation)" comments = "version: 1.4.1.Final, compiler: javac, environment: Java 1.8.0_271 (Oracle Corporation)"
) )
public class UserMappersImpl implements UserMappers { public class UserMappersImpl implements UserMappers {
@ -43,8 +40,6 @@ public class UserMappersImpl implements UserMappers {
user.setInternshipEndDate( userRequest.getInternshipEndDate() ); user.setInternshipEndDate( userRequest.getInternshipEndDate() );
user.setCreator( userRequest.getCreator() ); user.setCreator( userRequest.getCreator() );
user.setCreatorName( userRequest.getCreatorName() ); user.setCreatorName( userRequest.getCreatorName() );
user.setModifier( userRequest.getModifier() );
user.setModifierName( userRequest.getModifierName() );
return user; return user;
} }
@ -95,24 +90,6 @@ public class UserMappersImpl implements UserMappers {
return singleUserResponse; return singleUserResponse;
} }
@Override
public PublishParam getUserPublishRequestToModel(UserPublishRequest userPublishRequest) {
if ( userPublishRequest == null ) {
return null;
}
PublishParam publishParam = new PublishParam();
List<String> list = userPublishRequest.getUserIds();
if ( list != null ) {
publishParam.setUserIds( new ArrayList<String>( list ) );
}
publishParam.setModifier( userPublishRequest.getModifier() );
publishParam.setModifierName( userPublishRequest.getModifierName() );
return publishParam;
}
@Override @Override
public SearchKeyWords getSearchKeywordsRequestToModel(SearchUserRequest searchUserRequest) { public SearchKeyWords getSearchKeywordsRequestToModel(SearchUserRequest searchUserRequest) {
if ( searchUserRequest == null ) { if ( searchUserRequest == null ) {
@ -127,8 +104,6 @@ public class UserMappersImpl implements UserMappers {
searchKeyWords.setGmtCreate( searchUserRequest.getGmtCreate() ); searchKeyWords.setGmtCreate( searchUserRequest.getGmtCreate() );
searchKeyWords.setJoinTime( searchUserRequest.getJoinTime() ); searchKeyWords.setJoinTime( searchUserRequest.getJoinTime() );
searchKeyWords.setInternEndDate( searchUserRequest.getInternEndDate() ); searchKeyWords.setInternEndDate( searchUserRequest.getInternEndDate() );
searchKeyWords.setPageIndex( searchUserRequest.getPageIndex() );
searchKeyWords.setPageSize( searchUserRequest.getPageSize() );
return searchKeyWords; return searchKeyWords;
} }
@ -186,17 +161,16 @@ public class UserMappersImpl implements UserMappers {
} }
@Override @Override
public UserDeleteKeyWords getUserDeleteRequestToModel(UserDeleteRequest userDeleteRequest) { public User getUserDeleteRequestToModel(UserDeleteRequest userDeleteRequest) {
if ( userDeleteRequest == null ) { if ( userDeleteRequest == null ) {
return null; return null;
} }
UserDeleteKeyWords userDeleteKeyWords = new UserDeleteKeyWords(); User user = new User();
userDeleteKeyWords.setUserId( userDeleteRequest.getUserId() ); user.setUserId( userDeleteRequest.getUserId() );
userDeleteKeyWords.setModifier( userDeleteRequest.getModifier() ); user.setUserName( userDeleteRequest.getUserName() );
userDeleteKeyWords.setModifierName( userDeleteRequest.getModifierName() );
return userDeleteKeyWords; return user;
} }
} }