用户管理更新
wei.peng
6 years ago
parent
13118c8ef5
commit
f7998ab767
@ -0,0 +1,105 @@
|
||||
package cn.estsh.i3plus.core.api.iservice.busi;
|
||||
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.model.platform.UserDetailModel;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.*;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description :人员业务服务接口
|
||||
* @Reference :
|
||||
* @Author : Adair Peng
|
||||
* @CreateDate : 2018-12-22 16:15
|
||||
* @Modify:
|
||||
**/
|
||||
public interface IPersonnelService {
|
||||
|
||||
@ApiOperation(value = "保存账号")
|
||||
SysUser saveSysUser(SysUser user);
|
||||
|
||||
@ApiOperation(value = "保存用户")
|
||||
SysUserInfo saveSysUserInfo(SysUserInfo info);
|
||||
|
||||
@ApiOperation(value = "更新用户状态")
|
||||
void updateSysUserInfoStatus(Long userInfoId,Integer status);
|
||||
|
||||
@ApiOperation(value = "删除账号信息")
|
||||
void deleteSysUser(Long[] userIdList,String userName);
|
||||
|
||||
@ApiOperation(value = "删除用户信息")
|
||||
void deleteSysUserInfo(Long[] infoIdList,String userName);
|
||||
|
||||
@ApiOperation(value = "获取账号信息")
|
||||
SysUser getSysUserById(Long id);
|
||||
|
||||
@ApiOperation(value = "获取用户信息")
|
||||
SysUserInfo getSysUserInfoById(Long id);
|
||||
|
||||
@ApiOperation(value = "获取部门")
|
||||
SysDepartment getSysDepartmentById(Long id);
|
||||
|
||||
@ApiOperation(value = "获取岗位")
|
||||
SysPosition getSysPositionById(Long id);
|
||||
|
||||
@ApiOperation(value = "获取组织")
|
||||
SysOrganize getSysOrganizeById(Long id);
|
||||
|
||||
@ApiOperation(value = "用户登录")
|
||||
SessionUser queryUserLogin(String userName, String password, String languageCode);
|
||||
|
||||
@ApiOperation(value = "查询用户信息")
|
||||
ListPager<SysUserInfo> querySysUserInfo(UserDetailModel model, Pager pager);
|
||||
|
||||
@ApiOperation(value = "查询用户信息")
|
||||
List<SysUserInfo> findSysUserInfoByIds(Long[] ids);
|
||||
|
||||
@ApiOperation(value = "查询账号角色关系")
|
||||
List<SysRefUserRole> findSysRefUserRoleById(Long userId);
|
||||
|
||||
@ApiOperation(value = "查询账号部门关系")
|
||||
List<SysRefUserDepartment> findSysRefUserDepartmentById(Long userId);
|
||||
|
||||
@ApiOperation(value = "查询用户部门关系")
|
||||
List<SysRefUserInfoDepartment> findSysRefUserInfoDepartmentById(Long infoId);
|
||||
|
||||
@ApiOperation(value = "查询用户部门关系")
|
||||
List<SysOrganize> findSysUserInfoOrganize(Long infoId);
|
||||
|
||||
@ApiOperation(value = "查询账户组织关系")
|
||||
List<SysOrganize> findSysUserOrganize(Long infoId);
|
||||
|
||||
@ApiOperation(value = "查询用户岗位关系")
|
||||
List<SysRefUserPosition> findSysRefUserPositionById(Long infoId);
|
||||
|
||||
@ApiOperation(value = "封装用户信息",notes = "封装登录完成后的用户信息(角色、权限、部门、操作部门、组织、岗位)")
|
||||
SessionUser packSessionUser(SessionUser sessionUser, SysUser user, Integer userType, String languageCode);
|
||||
|
||||
@ApiOperation(value = "账号唯一检查")
|
||||
void checkSysUserOnly(SysUser user);
|
||||
|
||||
@ApiOperation(value = "刷新组织冗余")
|
||||
void refreshRefSysUserOrganizeRdd(Long organizeIds);
|
||||
|
||||
@ApiOperation(value = "刷新账号部门")
|
||||
void refreshRefSysUserDepartment(Long userId, Long[] departmentIds);
|
||||
|
||||
@ApiOperation(value = "刷新账号角色")
|
||||
void refreshRefSysUserRole(Long userId, Long[] roleIds);
|
||||
|
||||
@ApiOperation(value = "刷新账号部门")
|
||||
void refreshRefSysUserDepartmentRdd(Long departmentId);
|
||||
|
||||
@ApiOperation(value = "刷新用户部门")
|
||||
void refreshRefSysUserInfoDepartment(Long userInfoId, Long[] departmentIds);
|
||||
@ApiOperation(value = "刷新用户部门")
|
||||
void refreshRefSysUserInfoDepartmentRdd(Long departmentId);
|
||||
|
||||
@ApiOperation(value = "刷新用户岗位")
|
||||
void refreshRefSysUserInfoPosition(Long userInfoId, Long[] positionIds);
|
||||
@ApiOperation(value = "刷新用户岗位")
|
||||
void refreshRefSysUserInfoPositionRdd(Long positionId);
|
||||
|
||||
}
|
||||
@ -0,0 +1,530 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.IPersonnelService;
|
||||
import cn.estsh.i3plus.platform.common.tool.TimeTool;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.base.shirotoken.UserToken;
|
||||
import cn.estsh.i3plus.pojo.base.tool.HqlPack;
|
||||
import cn.estsh.i3plus.pojo.model.platform.UserDetailModel;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.*;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.*;
|
||||
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
|
||||
import cn.estsh.impp.framework.boot.auth.AuthUtil;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
|
||||
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
|
||||
import io.swagger.annotations.ApiOperation;
|
||||
import org.apache.commons.lang3.StringUtils;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Service;
|
||||
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : Adair Peng
|
||||
* @CreateDate : 2018-12-24 13:10
|
||||
* @Modify:
|
||||
**/
|
||||
@Service
|
||||
public class PersonnelServiceService implements IPersonnelService {
|
||||
|
||||
public static final Logger LOGGER = LoggerFactory.getLogger(SysConfigService.class);
|
||||
|
||||
@Autowired
|
||||
private SysUserRepository userRDao;
|
||||
|
||||
@Autowired
|
||||
private SysUserInfoRepository userInfoRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRoleRepository roleRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRefUserDepartmentRepository refUserDepartmentRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRefUserInfoDepartmentRepository refUserInfoDepartmentRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRefUserPositionRepository refUserPositionRDao;
|
||||
|
||||
@Autowired
|
||||
private SysRefUserRoleRepository refUserRoleRDao;
|
||||
|
||||
@Autowired
|
||||
private SysOrganizeRepository organizeRDao;
|
||||
|
||||
@Autowired
|
||||
private SysDepartmentRepository departmentRDao;
|
||||
|
||||
@Autowired
|
||||
private SysPositionRepository positionRDao;
|
||||
|
||||
|
||||
@Override
|
||||
public SysUser saveSysUser(SysUser user) {
|
||||
LOGGER.debug("平台账号 SysUser user:{}", user);
|
||||
return userRDao.save(user);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysUserInfo saveSysUserInfo(SysUserInfo info) {
|
||||
LOGGER.debug("平台用户 SysUserInfo info:{}", info);
|
||||
return userInfoRDao.save(info);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void updateSysUserInfoStatus(Long userInfoId, Integer status) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除账号信息")
|
||||
public void deleteSysUser(Long[] userIdList,String userName) {
|
||||
LOGGER.debug("平台账号 SysUser userIdList:{}", userIdList);
|
||||
// 删除账号信息
|
||||
userRDao.updateValidStatusByPropertyIn("id", userIdList,CommonEnumUtil.IS_VAILD.INVAILD.getValue(), userName);
|
||||
|
||||
// 删除账号关系
|
||||
refUserDepartmentRDao.deleteByPropertyIn("userId",userIdList);
|
||||
refUserRoleRDao.deleteByPropertyIn("userId", userIdList);
|
||||
}
|
||||
|
||||
@Override
|
||||
@ApiOperation(value = "删除用户信息")
|
||||
public void deleteSysUserInfo(Long[] infoIdList,String userName) {
|
||||
LOGGER.debug("平台用户 SysUserInfo infoIdList:{}", infoIdList);
|
||||
// 删除用户信息
|
||||
userInfoRDao.updateValidStatusByPropertyIn("id", infoIdList,CommonEnumUtil.IS_VAILD.INVAILD.getValue(), userName);
|
||||
|
||||
// 删除用户关系
|
||||
refUserInfoDepartmentRDao.deleteByPropertyIn("userId",infoIdList);
|
||||
refUserPositionRDao.deleteByPropertyIn("userId",infoIdList);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysUser getSysUserById(Long id) {
|
||||
return userRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysUserInfo getSysUserInfoById(Long id) {
|
||||
return userInfoRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysDepartment getSysDepartmentById(Long id) {
|
||||
return departmentRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysPosition getSysPositionById(Long id) {
|
||||
return positionRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SysOrganize getSysOrganizeById(Long id) {
|
||||
return organizeRDao.getById(id);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SessionUser queryUserLogin(String userName, String password, String languageCode) {
|
||||
LOGGER.debug("平台用户 SYS_USER loginName:{} \t password:{} \t languageCode:{}", userName, password, languageCode);
|
||||
UserToken token = new UserToken(userName,password,languageCode);
|
||||
SessionUser sessionUser = AuthUtil.login(token);
|
||||
AuthUtil.setSessionUser(sessionUser);
|
||||
return sessionUser;
|
||||
}
|
||||
|
||||
@Override
|
||||
public ListPager<SysUserInfo> querySysUserInfo(UserDetailModel model, Pager pager) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysUserInfo> findSysUserInfoByIds(Long[] ids) {
|
||||
LOGGER.debug("平台用户 SysUserInfo ids:{}", ids);
|
||||
|
||||
String infoWhere = CoreHqlPack.packHqlIds("id", ids);
|
||||
return userInfoRDao.findByHqlWhere(infoWhere);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysRefUserRole> findSysRefUserRoleById(Long userId) {
|
||||
LOGGER.debug("平台账号角色 SysRefUserRole userId:{}", userId);
|
||||
return refUserRoleRDao.findByProperty("userId",userId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysRefUserDepartment> findSysRefUserDepartmentById(Long userId) {
|
||||
LOGGER.debug("平台账号部门 SysRefUserDepartment userId:{}", userId);
|
||||
return refUserDepartmentRDao.findByProperty("userId",userId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysRefUserInfoDepartment> findSysRefUserInfoDepartmentById(Long infoId) {
|
||||
LOGGER.debug("平台用户部门 SysRefUserInfoDepartment infoId:{}", infoId);
|
||||
return refUserInfoDepartmentRDao.findByProperty("userId",infoId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysOrganize> findSysUserInfoOrganize(Long infoId) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysOrganize> findSysUserOrganize(Long infoId) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<SysRefUserPosition> findSysRefUserPositionById(Long infoId) {
|
||||
LOGGER.debug("平台用户岗位 SysRefUserPosition infoId:{}", infoId);
|
||||
return refUserPositionRDao.findByProperty("userId",infoId);
|
||||
}
|
||||
|
||||
@Override
|
||||
public SessionUser packSessionUser(SessionUser sessionUser, SysUser user, Integer userType, String languageCode) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void checkSysUserOnly(SysUser user) {
|
||||
if(user != null){
|
||||
// 登录名唯一教研
|
||||
if(!checkSysUserLoginName(user.getUserLoginName(), user.getId() == null ? 0 : user.getId())){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
|
||||
.setErrorDetail("用户名已存在")
|
||||
.setErrorSolution("请重新输入用户名")
|
||||
.build();
|
||||
}
|
||||
|
||||
// 邮箱唯一教研
|
||||
if(!checkSysUserEmail(user.getUserEmail(),user.getUserInfoId() == null ? 0 : user.getUserInfoId())){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
|
||||
.setErrorDetail("邮箱已存在")
|
||||
.setErrorSolution("请重新输入邮箱")
|
||||
.build();
|
||||
}
|
||||
|
||||
// 手机号唯一教研
|
||||
if(!checkSysUserPhone(user.getUserPhone(),user.getUserInfoId() == null ? 0 : user.getUserInfoId())){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
|
||||
.setErrorDetail("手机号已存在")
|
||||
.setErrorSolution("请重新输入手机号")
|
||||
.build();
|
||||
}
|
||||
|
||||
// 工号唯一教研
|
||||
if(!checkSysUserEmpNo(user.getUserEmpNo(),user.getUserInfoId() == null ? 0 : user.getUserInfoId())){
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
|
||||
.setErrorDetail("工号号已存在")
|
||||
.setErrorSolution("请重新输入工号")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/************************************ 用户唯一检查 ****************************************/
|
||||
|
||||
/**
|
||||
* 登录名 唯一检查
|
||||
* @param userLoginName
|
||||
* @param userId
|
||||
* @return
|
||||
*/
|
||||
private boolean checkSysUserLoginName(String userLoginName, long userId) {
|
||||
int count = 0;
|
||||
if(userId > 0){
|
||||
StringBuffer sw = new StringBuffer();
|
||||
HqlPack.getStringEqualPack(userLoginName,"userLoginName",sw);
|
||||
HqlPack.getNumNOEqualPack(userId,"id",sw);
|
||||
count = userRDao.findByHqlWhereCount(sw.toString());
|
||||
|
||||
}else{
|
||||
count = userRDao.findByPropertyCount("userLoginName",userLoginName);
|
||||
}
|
||||
return count <= 0 ;
|
||||
}
|
||||
|
||||
/**
|
||||
* 用户邮箱唯一检查
|
||||
* @param email
|
||||
* @param infoId
|
||||
* @return
|
||||
*/
|
||||
private boolean checkSysUserEmail(String email, long infoId) {
|
||||
int count;
|
||||
if(infoId > 0){
|
||||
StringBuffer sw = new StringBuffer();
|
||||
HqlPack.getStringEqualPack(email,"userEmail",sw);
|
||||
HqlPack.getNumNOEqualPack(infoId,"userInfoId",sw);
|
||||
count = userRDao.findByHqlWhereCount(sw.toString());
|
||||
|
||||
}else{
|
||||
count = userRDao.findByPropertyCount("userEmail",email);
|
||||
}
|
||||
return count <= 0 ;
|
||||
}
|
||||
|
||||
/**
|
||||
* 手机号码 唯一校验
|
||||
* @param phone
|
||||
* @param infoId
|
||||
* @return
|
||||
*/
|
||||
private boolean checkSysUserPhone(String phone, long infoId) {
|
||||
int count;
|
||||
if(infoId > 0){
|
||||
StringBuffer sw = new StringBuffer();
|
||||
HqlPack.getStringEqualPack(phone,"userPhone",sw);
|
||||
HqlPack.getNumNOEqualPack(infoId,"userInfoId",sw);
|
||||
count = userRDao.findByHqlWhereCount(sw.toString());
|
||||
|
||||
}else{
|
||||
count = userRDao.findByPropertyCount("userPhone",phone);
|
||||
}
|
||||
return count <= 0 ;
|
||||
}
|
||||
|
||||
/**
|
||||
* 工号唯一检查
|
||||
* @param phone
|
||||
* @param infoId
|
||||
* @return
|
||||
*/
|
||||
private boolean checkSysUserEmpNo(String phone, long infoId) {
|
||||
int count;
|
||||
if(infoId > 0){
|
||||
StringBuffer sw = new StringBuffer();
|
||||
HqlPack.getStringEqualPack(phone,"userEmpNo",sw);
|
||||
HqlPack.getNumNOEqualPack(infoId,"userInfoId",sw);
|
||||
count = userRDao.findByHqlWhereCount(sw.toString());
|
||||
|
||||
}else{
|
||||
count = userRDao.findByPropertyCount("userEmpNo",phone);
|
||||
}
|
||||
return count <= 0 ;
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserOrganizeRdd(Long organizeIds) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserDepartment(Long userId, Long[] departmentIds) {
|
||||
LOGGER.info("账号部门信息 SysUser userInfoId:{} departmentIds:{}",userId,departmentIds);
|
||||
|
||||
SysUser user = userRDao.getById(userId);
|
||||
if(user != null ){
|
||||
// 删除用户部门关系
|
||||
refUserDepartmentRDao.deleteByProperty("userId",user.getId());
|
||||
|
||||
if(departmentIds.length > 0){
|
||||
// 查询部门信息
|
||||
StringBuffer where = new StringBuffer();
|
||||
HqlPack.getInPack(StringUtils.join(departmentIds,","),"id",where);
|
||||
List<SysDepartment> departmentList = departmentRDao.findByHqlWhere(where.toString());
|
||||
|
||||
if(departmentList != null && departmentList.size() >0){
|
||||
List<SysRefUserDepartment> list = new ArrayList<>();
|
||||
List<String> nameList = new ArrayList<>();
|
||||
SysRefUserDepartment ref = null;
|
||||
for (SysDepartment department : departmentList) {
|
||||
ref = new SysRefUserDepartment();
|
||||
ref.setOrganizeId(department.getOrganizeId());
|
||||
ref.setOrganizeNameRdd(department.getOrganizeNameRdd());
|
||||
ref.setDepartmentId(department.getId());
|
||||
ref.setDepartmentNameRdd(department.getName());
|
||||
ref.setUserId(user.getId());
|
||||
ref.setUserNameRdd(user.getUserName());
|
||||
list.add(ref);
|
||||
|
||||
nameList.add(department.getName());
|
||||
}
|
||||
|
||||
user.setDepartmentNamesRdd(String.join(",",nameList));
|
||||
|
||||
refUserDepartmentRDao.saveAll(list);
|
||||
userRDao.save(user);
|
||||
|
||||
LOGGER.info("账号部门信息 SysUserInfo RefUserDepartmentRDao Insert Size :{}",list.size());
|
||||
}
|
||||
}
|
||||
}else {
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
|
||||
.setErrorDetail("用户信息不存在")
|
||||
.setErrorSolution("请重新操作")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserRole(Long userId, Long[] roleIds) {
|
||||
LOGGER.debug("账号角色关系信息 RefSysUserRole userId:{} roleIds:{} ", userId,roleIds);
|
||||
SysUser user = userRDao.getById(userId);
|
||||
if(user != null){
|
||||
// 根据IDS 查询所有的角色信息
|
||||
String where = CoreHqlPack.packHqlIds("id", roleIds);
|
||||
List<SysRole> list = roleRDao.findByHqlWhere(where);
|
||||
|
||||
// 删除角色关系信息
|
||||
refUserRoleRDao.deleteByProperty("userId", user.getId()); // 删除用户角色关系
|
||||
|
||||
if(null != list && list.size() > 0){
|
||||
// 新增用户角色关系
|
||||
List<SysRefUserRole> refUserRoles = new ArrayList<>();
|
||||
List<String> roleNameList = new ArrayList<>();
|
||||
List<String> roleIdList = new ArrayList<>();
|
||||
SysRefUserRole refUserRole = null;
|
||||
for (SysRole role : list) {
|
||||
roleNameList.add(role.getName());
|
||||
roleIdList.add(role.getId().toString());
|
||||
// 用户角色关系创建
|
||||
refUserRole = new SysRefUserRole();
|
||||
refUserRole.setRoleId(role.getId());
|
||||
refUserRole.setRoleNameRdd(role.getName());
|
||||
refUserRole.setUserId(user.getId());
|
||||
refUserRole.setUserNameRdd(user.getUserName());
|
||||
refUserRoles.add(refUserRole);
|
||||
}
|
||||
refUserRoleRDao.saveAll(refUserRoles);
|
||||
|
||||
// 角色名称冗余
|
||||
user.setRoleNamesRdd(String.join(",", roleNameList));
|
||||
user.setRoleIds(String.join(",", roleIdList));
|
||||
|
||||
userRDao.save(user);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserDepartmentRdd(Long departmentId) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserInfoDepartment(Long userInfoId, Long[] departmentIds) {
|
||||
LOGGER.info("用户部门关系信息 SysUser userInfoId:{} departmentIds:{}",userInfoId,departmentIds);
|
||||
|
||||
SysUserInfo info = userInfoRDao.getById(userInfoId);
|
||||
if(info != null ){
|
||||
// 删除用户部门关系
|
||||
refUserInfoDepartmentRDao.deleteByProperty("userId",info.getId());
|
||||
|
||||
if(departmentIds.length > 0){
|
||||
// 查询部门信息
|
||||
StringBuffer where = new StringBuffer();
|
||||
HqlPack.getInPack(StringUtils.join(departmentIds,","),"id",where);
|
||||
List<SysDepartment> departmentList = departmentRDao.findByHqlWhere(where.toString());
|
||||
|
||||
if(departmentList != null && departmentList.size() >0){
|
||||
List<SysRefUserInfoDepartment> list = new ArrayList<>();
|
||||
List<String> nameList = new ArrayList<>();
|
||||
SysRefUserInfoDepartment ref = null;
|
||||
for (SysDepartment department : departmentList) {
|
||||
ref = new SysRefUserInfoDepartment();
|
||||
ref.setOrganizeId(department.getOrganizeId());
|
||||
ref.setOrganizeNameRdd(department.getOrganizeNameRdd());
|
||||
ref.setDepartmentId(department.getId());
|
||||
ref.setDepartmentNameRdd(department.getName());
|
||||
ref.setUserId(info.getId());
|
||||
ref.setUserNameRdd(info.getName());
|
||||
list.add(ref);
|
||||
|
||||
nameList.add(department.getName());
|
||||
}
|
||||
|
||||
info.setDepartmentNamesRdd(String.join(",",nameList));
|
||||
|
||||
refUserInfoDepartmentRDao.saveAll(list);
|
||||
userInfoRDao.save(info);
|
||||
|
||||
LOGGER.info("用户部门关系信息 SysUserInfo RefUserDepartmentRDao Insert Size :{}",list.size());
|
||||
}
|
||||
}
|
||||
}else {
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
|
||||
.setErrorDetail("用户信息不存在")
|
||||
.setErrorSolution("请重新操作")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserInfoDepartmentRdd(Long departmentId) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserInfoPosition(Long userInfoId, Long[] positionIds) {
|
||||
LOGGER.info("用户岗位关系信息 RefSysUserInfoPosition userInfoId:{} positionIds:{} userName:{}",userInfoId,positionIds);
|
||||
|
||||
SysUserInfo userInfo = userInfoRDao.getById(userInfoId);
|
||||
if(userInfo != null ){
|
||||
// 删除用户岗位关系
|
||||
refUserPositionRDao.deleteByProperty("userId",userInfo.getId());
|
||||
|
||||
if(positionIds.length > 0){
|
||||
StringBuffer where = new StringBuffer();
|
||||
HqlPack.getInPack(StringUtils.join(positionIds,","),"id",where); // 查询部门信息
|
||||
List<SysPosition> positionList = positionRDao.findByHqlWhere(where.toString());
|
||||
|
||||
if(positionList != null && positionList.size() >0){
|
||||
List<SysRefUserPosition> list = new ArrayList<>();
|
||||
List<String> nameList = new ArrayList<>();
|
||||
SysRefUserPosition ref = null;
|
||||
for (SysPosition position : positionList) {
|
||||
ref = new SysRefUserPosition();
|
||||
ref.setUserId(userInfo.getId());
|
||||
ref.setUserNameRdd(userInfo.getName());
|
||||
ref.setPositionId(position.getId());
|
||||
ref.setPositionNameRdd(position.getName());
|
||||
list.add(ref);
|
||||
|
||||
nameList.add(position.getName());
|
||||
}
|
||||
|
||||
userInfo.setPositionNamesRdd(String.join(",",nameList));
|
||||
|
||||
refUserPositionRDao.saveAll(list);
|
||||
userInfoRDao.save(userInfo);
|
||||
|
||||
LOGGER.info("用户岗位关系信息 SysUserInfo RefUserPositionRDao Insert Size :{}",list.size());
|
||||
}
|
||||
}
|
||||
}else {
|
||||
throw ImppExceptionBuilder.newInstance()
|
||||
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
|
||||
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
|
||||
.setErrorDetail("用户信息不存在")
|
||||
.setErrorSolution("请重新操作")
|
||||
.build();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void refreshRefSysUserInfoPositionRdd(Long positionId) {
|
||||
|
||||
}
|
||||
}
|
||||
@ -1,50 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.mq;
|
||||
|
||||
import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase;
|
||||
import cn.estsh.i3plus.core.apiservice.util.MailUtil;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
|
||||
import org.junit.Test;
|
||||
import org.springframework.amqp.rabbit.core.RabbitTemplate;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-11-15 13:22
|
||||
* @Modify:
|
||||
**/
|
||||
public class TestMQ extends TestBase {
|
||||
|
||||
/**
|
||||
* rabbitMQ队列
|
||||
*/
|
||||
@Autowired
|
||||
private RabbitTemplate rabbitTemplate;
|
||||
|
||||
@Autowired
|
||||
private MailUtil mailUtil;
|
||||
|
||||
@Test
|
||||
public void sendMail() throws InterruptedException {
|
||||
|
||||
SysMessage sysMessage = new SysMessage();
|
||||
sysMessage.setMessageTitle("test-系统通知");
|
||||
sysMessage.setMessageSenderNameRdd("system");
|
||||
sysMessage.setMessageSenderId(-1L);
|
||||
sysMessage.setMessageType(ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue());
|
||||
sysMessage.setMessageSendTime("2018-11-01 16:58:00");
|
||||
|
||||
for (int i = 0; i < 50; i++) {
|
||||
sysMessage = new SysMessage();
|
||||
sysMessage.setId(null);
|
||||
sysMessage.setMessageTitle( i + "mail测试");
|
||||
sysMessage.setMessageSenderNameRdd(i+"");
|
||||
rabbitTemplate.convertAndSend("WYH_MESSAGE_QUEUE", new SysMessage());
|
||||
System.out.println("第" + i + "次");
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,34 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : alwaysfrin
|
||||
* @CreateDate : 2018-11-09 10:00
|
||||
* @Modify:
|
||||
**/
|
||||
public class ArraySort implements Runnable {
|
||||
|
||||
private String num;
|
||||
|
||||
public ArraySort(int num){
|
||||
this.num = num + "";
|
||||
}
|
||||
|
||||
public static void main(String[] args){
|
||||
int[] num = {11,3,9,5,1,4,15};
|
||||
for(int i=0;i<num.length;i++){
|
||||
new Thread(new ArraySort(num[i])).start();
|
||||
}
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
try {
|
||||
Thread.sleep(Integer.parseInt(num));
|
||||
System.out.println(num);
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
File diff suppressed because one or more lines are too long
@ -1,118 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IDepartmentService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Department;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Organize;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 岗位信息测试
|
||||
// * @Reference :
|
||||
// * @Author : wei.peng
|
||||
// * @Date : 2018-10-29 19:02
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestDepartmentService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// private IDepartmentService departmentService;
|
||||
//
|
||||
// /**
|
||||
// * 新增数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testInsertDepartment(){
|
||||
// for(int i = 0 ; i < 50 ; i++ ){
|
||||
// Department obj = new Department();
|
||||
// obj.setName("Junit Test " + i);
|
||||
// obj.setDepartmentCode("DEV_JUNIT " + i);
|
||||
// obj.setParentId(1057165194242953216L);
|
||||
// obj.setOrganizeId(1057163974900060160L);
|
||||
// obj = departmentService.insertDepartment(obj);
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 数据
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetDepartmentById(){
|
||||
// Department obj = departmentService.getDepartmentById("1057163974900060160");
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 查询所有数据
|
||||
// *
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListDepartment(){
|
||||
// List list = departmentService.listDepartment();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据岗位信息进行查找
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testFindDepartmentByPager(){
|
||||
// Organize obj = new Organize();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(1);
|
||||
//
|
||||
// ListPager list = departmentService.queryDepartment(null, pager);
|
||||
//
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 修改数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateDepartment(){
|
||||
// Department obj = departmentService.getDepartmentById("1057108586410414080");
|
||||
// obj.setName("Junit update Name ");
|
||||
// departmentService.updateDepartment(obj);
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 删除数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteDepartmentById(){
|
||||
//// departmentService.deleteOrganizeById("");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据id批量删除岗位
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void deleteDepartmentByIds(){
|
||||
//// departmentService.deleteOrganizeByIds(new String[]{"1057108585445724160","1057108585760296960"});
|
||||
// }
|
||||
//
|
||||
//
|
||||
//}
|
||||
@ -1,59 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysConfig;
|
||||
import cn.estsh.i3plus.pojo.platform.repository.SysConfigRepository;
|
||||
import org.junit.Test;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-12-20 17:02
|
||||
* @Modify:
|
||||
**/
|
||||
public class TestMathOper extends TestBase {
|
||||
|
||||
@Test
|
||||
public void test(){
|
||||
System.out.println("Hello World !~");
|
||||
}
|
||||
|
||||
@Autowired
|
||||
private SysConfigRepository sysConfigRDao;
|
||||
|
||||
String propertyName = "configType";
|
||||
String groupByName = "configType";
|
||||
String[] param = new String[]{"configType"};
|
||||
Object[] paramValue = new Object[]{1};
|
||||
|
||||
|
||||
@Test
|
||||
public void testMax(){
|
||||
SysConfig sysConfig = new SysConfig();
|
||||
// max
|
||||
System.out.println(sysConfigRDao.findMaxByProperties(propertyName,groupByName,param,paramValue));
|
||||
System.out.println(sysConfigRDao.findMaxByProperty(propertyName,groupByName,param[0],paramValue[0]));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testMin(){
|
||||
// min
|
||||
System.out.println(sysConfigRDao.findMinByProperties(propertyName,groupByName,param,paramValue));
|
||||
System.out.println(sysConfigRDao.findMinByProperty(propertyName,groupByName,param[0],paramValue[0]));
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testSum(){
|
||||
//sum
|
||||
System.out.println(sysConfigRDao.findSumByProperties(propertyName,groupByName,param,paramValue));
|
||||
System.out.println(sysConfigRDao.findSumByProperty(propertyName,groupByName,param[0],paramValue[0]));
|
||||
}
|
||||
@Test
|
||||
public void testAvg(){
|
||||
//avg
|
||||
System.out.println(sysConfigRDao.findAvgByProperties(propertyName,groupByName,param,paramValue));
|
||||
System.out.println(sysConfigRDao.findAvgByProperty(propertyName,groupByName,param[0],paramValue[0]));
|
||||
}
|
||||
|
||||
}
|
||||
@ -1,110 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.slf4j.Logger;
|
||||
//import org.slf4j.LoggerFactory;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试 消息服务接口
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-31 15:30
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestMessageService extends TestBase {
|
||||
//
|
||||
// public static final Logger LOGGER = LoggerFactory.getLogger(TestMessageService.class);
|
||||
// @Autowired
|
||||
// private ISysMessageService sysMessageService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有消息
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListSysMessage() {
|
||||
// List list = sysMessageService.listSysMessage();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询消息
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetSysMessageById() {
|
||||
// SysMessage sysMessage = sysMessageService.getSysMessageById(1L);
|
||||
// System.out.println(JSON.toJSONString(sysMessage));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加消息
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertSysMessage() {
|
||||
// SysMessage sysMessage = new SysMessage();
|
||||
// sysMessage.setMessageTitle("test-系统通知");
|
||||
// sysMessage.setMessageSenderNameRdd("system");
|
||||
// sysMessage.setMessageSenderId(-1L);
|
||||
// sysMessage.setMessageType(ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue());
|
||||
// sysMessage.setMessageSendTime("2018-11-01 16:58:00");
|
||||
//
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// sysMessage.setId(null);
|
||||
// sysMessage.setMessageTitle("test-系统通知" + i);
|
||||
// sysMessageService.insertSysMessage(sysMessage);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(sysMessage));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改消息
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateSysMessage(){
|
||||
// SysMessage sysMessage = sysMessageService.getSysMessageById(1L);
|
||||
// sysMessage.setMessageTitle("测试修改");
|
||||
//
|
||||
// sysMessageService.updateSysMessage(sysMessage);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除消息
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteSysMessageById(){
|
||||
// sysMessageService.deleteSysMessageById(1L);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQuerySysMessageByPager(){
|
||||
// SysMessage sysMessage = new SysMessage();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = sysMessageService.querySysMessageByPager(sysMessage,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//
|
||||
//}
|
||||
@ -1,118 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IOrganizeService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Organize;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Organize;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 岗位信息测试
|
||||
// * @Reference :
|
||||
// * @Author : wei.peng
|
||||
// * @Date : 2018-10-29 19:02
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestOrganizeService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// private IOrganizeService organizeService;
|
||||
//
|
||||
// /**
|
||||
// * 新增数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertOrganize(){
|
||||
// for(int i = 0 ; i < 50 ; i++ ){
|
||||
// Organize obj = new Organize();
|
||||
// obj.setName("Junit Test " + i);
|
||||
// obj.setOrganizeCode("DEV_JUNIT " + i);
|
||||
// obj.setParentId(-1L);
|
||||
// obj = organizeService.insertOrganize(obj);
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 数据
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetOrganizeById(){
|
||||
// Organize obj = organizeService.getOrganizeById("1057163974900060160");
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 查询所有数据
|
||||
// *
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListOrganize(){
|
||||
// List list = organizeService.listOrganize();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据岗位信息进行查找
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testFindOrganizeByPager(){
|
||||
// Organize obj = new Organize();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(1);
|
||||
//
|
||||
// ListPager list = organizeService.queryOrganize(null, pager);
|
||||
//
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 修改数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateOrganize(){
|
||||
// Organize obj = organizeService.getOrganizeById("1057108586410414080");
|
||||
// obj.setName("Junit update Name ");
|
||||
// organizeService.updateOrganize(obj);
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 删除数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteOrganizeById(){
|
||||
//// organizeService.deleteOrganizeById("");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据id批量删除岗位
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void deleteOrganizeByIds(){
|
||||
//// organizeService.deleteOrganizeByIds(new String[]{"1057108585445724160","1057108585760296960"});
|
||||
// }
|
||||
//
|
||||
//
|
||||
//}
|
||||
@ -1,117 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IPositionService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Position;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.core.annotation.Order;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 岗位信息测试
|
||||
// * @Reference :
|
||||
// * @Author : wei.peng
|
||||
// * @Date : 2018-10-29 19:02
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestPositionService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// private IPositionService positionService;
|
||||
//
|
||||
// /**
|
||||
// * 新增数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertPosition(){
|
||||
// for(int i = 0 ; i < 50 ; i++ ){
|
||||
// Position position = new Position();
|
||||
// position.setName("Junit Test " + i);
|
||||
// position.setPositionCode("DEV_JUNIT " + i);
|
||||
// position = positionService.insertPosition(position);
|
||||
// System.out.println(JSON.toJSONString(position));
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 数据
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetPositionById(){
|
||||
// Position pos = positionService.getPositionById("1057108589715525632");
|
||||
// System.out.println(JSON.toJSONString(pos));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 查询所有数据
|
||||
// *
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListPosition(){
|
||||
// List list = positionService.listPosition();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据岗位信息进行查找
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testFindPositionByPager(){
|
||||
// Position position = new Position();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(1);
|
||||
//
|
||||
// ListPager list = positionService.findPositionByPager(null, pager);
|
||||
//
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 修改数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdatePosition(){
|
||||
// Position position = positionService.getPositionById("1057108586410414080");
|
||||
// position.setName("Junit update Name ");
|
||||
// positionService.updatePosition(position);
|
||||
// System.out.println(JSON.toJSONString(position));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 删除数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeletePositionById(){
|
||||
// positionService.deletePositionById("1057108585240203264");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据id批量删除岗位
|
||||
// * @return
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void deletePositionByIds(){
|
||||
// positionService.deletePositionByIds(new String[]{"1057108585445724160","1057108585760296960"});
|
||||
// }
|
||||
//
|
||||
//
|
||||
//}
|
||||
@ -1,102 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
|
||||
import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService;
|
||||
import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysConfig;
|
||||
import com.alibaba.fastjson.JSON;
|
||||
import org.junit.Test;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.test.annotation.Rollback;
|
||||
|
||||
import javax.transaction.Transactional;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : 系统参数服务测试
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @Date : 2018-10-30 10:49
|
||||
* @Modify :
|
||||
**/
|
||||
public class TestSysConfigService extends TestBase {
|
||||
|
||||
@Autowired
|
||||
private ISysConfigService sysConfigService;
|
||||
|
||||
/**
|
||||
* 测试 查询所有系统参数
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
public void testListSysConfig() {
|
||||
List list = sysConfigService.ListSysConfig();
|
||||
System.out.println(JSON.toJSONString(list));
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试 根据id查询系统参数
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
public void testGetSysConfigById() {
|
||||
SysConfig sysConfig = sysConfigService.getSysConfigById(1057110061127700480L);
|
||||
System.out.println(JSON.toJSONString(sysConfig));
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试 添加系统参数
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
@Rollback(false)
|
||||
public void testInsertSysConfig() {
|
||||
SysConfig sysConfig = new SysConfig();
|
||||
sysConfig.setName("系统名称");
|
||||
sysConfig.setConfigCode("sys_name");
|
||||
sysConfig.setConfigType(1);
|
||||
sysConfig.setConfigValue("IMPP");
|
||||
sysConfig.setConfigDescription("系统名称");
|
||||
|
||||
sysConfigService.insertSysConfig(sysConfig);
|
||||
System.out.println(JSON.toJSONString(sysConfig));
|
||||
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试 修改系统参数
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
public void testUpdateSysConfig(){
|
||||
SysConfig sysConfig = sysConfigService.getSysConfigById(1057110613261684736L);
|
||||
sysConfig.setConfigDescription("测试修改");
|
||||
|
||||
sysConfigService.updateSysConfig(sysConfig);
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试 根据id删除系统参数
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
public void testDeleteSysConfigById(){
|
||||
sysConfigService.deleteSysConfigById(1057111616417566720L);
|
||||
}
|
||||
|
||||
/**
|
||||
* 测试 复制查询
|
||||
*/
|
||||
@Test
|
||||
@Transactional
|
||||
public void testQuerySysConfigByPager(){
|
||||
SysConfig sysConfig = new SysConfig();
|
||||
|
||||
Pager pager = new Pager();
|
||||
pager.setPageSize(10);
|
||||
pager.setCurrentPage(1);
|
||||
|
||||
ListPager list = sysConfigService.querySysConfigByPager(sysConfig,pager);
|
||||
System.out.println(list);
|
||||
}
|
||||
}
|
||||
@ -1,99 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ISysDictionaryService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.SysDictionary;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试字典服务接口
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-30 18:52
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestSysDictionaryService extends TestBase {
|
||||
// @Autowired
|
||||
// private ISysDictionaryService sysDictionaryService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有字典
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListSysDictionary() {
|
||||
// List list = sysDictionaryService.listSysDictionary();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询字典
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetSysDictionaryById() {
|
||||
// SysDictionary sysDictionary = sysDictionaryService.getSysDictionaryById("1057110061127700480");
|
||||
// System.out.println(JSON.toJSONString(sysDictionary));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加字典
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertSysDictionary() {
|
||||
// SysDictionary sysDictionary = new SysDictionary();
|
||||
// sysDictionary.setName("字典测试");
|
||||
// sysDictionary.setDictionaryCode("dic_test");
|
||||
// sysDictionary.setDictionaryValue("DEV");
|
||||
// sysDictionary.setDictionaryDescription("字典测试");
|
||||
//
|
||||
// sysDictionaryService.insertSysDictionary(sysDictionary);
|
||||
// System.out.println(JSON.toJSONString(sysDictionary));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改字典
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateSysDictionary(){
|
||||
// SysDictionary sysDictionary = sysDictionaryService.getSysDictionaryById("1057110613261684736");
|
||||
// sysDictionary.setName("测试修改");
|
||||
//
|
||||
// sysDictionaryService.updateSysDictionary(sysDictionary);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除字典
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteSysDictionaryById(){
|
||||
// sysDictionaryService.deleteSysDictionaryById("1057111616417566720");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQuerySysDictionaryByPager(){
|
||||
// SysDictionary sysDictionary = new SysDictionary();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = sysDictionaryService.querySysDictionaryByPager(sysDictionary,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,107 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ISysFileService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.SysFile;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试 文件资源服务接口
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-31 15:30
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestSysFileService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// public ISysFileService sysFileService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有文件资源
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListSysFile() {
|
||||
// List list = sysFileService.listSysFile();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询文件资源
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetSysFileById() {
|
||||
// SysFile sysFile = sysFileService.getSysFileById(1057110061127700480L);
|
||||
// System.out.println(JSON.toJSONString(sysFile));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加文件资源
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertSysFile() {
|
||||
// SysFile sysFile = new SysFile();
|
||||
// sysFile.setName("文件doc");
|
||||
// sysFile.setFileTypeId(1058251784058966016L);
|
||||
// sysFile.setFileTypeName("doc");
|
||||
// sysFile.setDownloads(999);
|
||||
// sysFile.setFileSize(1024);
|
||||
// sysFile.setCreateUser("中国移动");
|
||||
// sysFile.setCreateDatetime("2018-01-01 00:00:00");
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// sysFile.setId(null);
|
||||
// sysFile.setName("文件"+ i +".doc");
|
||||
// sysFile.setCreateDatetime("2018-01-01 " + (i % 10) + "0:00:00");
|
||||
// sysFileService.insertSysFile(sysFile);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(sysFile));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改文件资源
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateSysFile(){
|
||||
// SysFile sysFile = sysFileService.getSysFileById(1057110613261684736L);
|
||||
// sysFile.setName("测试修改");
|
||||
//
|
||||
// sysFileService.updateSysFile(sysFile);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除文件资源
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteSysFileById(){
|
||||
// sysFileService.deleteSysFileById("1057111616417566720");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQuerySysFileByPager(){
|
||||
// SysFile sysFile = new SysFile();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = sysFileService.querySysFileByPager(sysFile,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,104 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ISysMenuService;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Organize;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.SysMenu;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description :
|
||||
// * @Reference :
|
||||
// * @Author : wei.peng
|
||||
// * @Date : 2018-11-01 11:58
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestSysMenuService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// private ISysMenuService sysMenuService;
|
||||
//
|
||||
//
|
||||
//
|
||||
//
|
||||
// /**
|
||||
// * 修改数据
|
||||
// */
|
||||
// @Test
|
||||
// public void testUpdateSysMenu() {
|
||||
//
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 修改权限状态
|
||||
// */
|
||||
// @Test
|
||||
// public void testUpdateSysMenuStatus() {
|
||||
//
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 批量修改状态
|
||||
// */
|
||||
// @Test
|
||||
// public void testUpdateSysMenuStatusByIds() {
|
||||
//
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据Key 删除数据
|
||||
// */
|
||||
// @Test
|
||||
// public void testDeleteSysMenuById() {
|
||||
//
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 新增数据
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertSysMenu() {
|
||||
// for(int i = 0 ; i < 50 ; i++ ){
|
||||
// SysMenu obj = new SysMenu();
|
||||
// obj.setName("Junit Test " + i);
|
||||
// obj.setMenuCode("DEV_JUNIT " + i);
|
||||
// obj.setParentId(-1L);
|
||||
// obj = sysMenuService.insertSysMenu(obj);
|
||||
// System.out.println(JSON.toJSONString(obj));
|
||||
// }
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 查询所有数据
|
||||
// */
|
||||
// @Test
|
||||
// public void testFindSysMenuAll() {
|
||||
// List<SysMenu> list = sysMenuService.findSysMenuAll();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 根据id 数据
|
||||
// */
|
||||
// @Test
|
||||
// public void testGetSysMenuById() {
|
||||
// SysMenu menu = sysMenuService.getSysMenuById("1057844135052054528");
|
||||
// System.out.println(JSON.toJSONString(menu));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// public void testQuerySysMenu() {
|
||||
//
|
||||
// }
|
||||
//
|
||||
//}
|
||||
@ -1,104 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeExpressionService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.TaskTimeExpression;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试 时间表达式
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-31 15:30
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestTaskTimeExpressionService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// ITaskTimeExpressionService taskTimeExpressionService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有时间表达式
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListTaskTimeExpression() {
|
||||
// List list = taskTimeExpressionService.listTaskTimeExpression();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询时间表达式
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetTaskTimeExpressionById() {
|
||||
// TaskTimeExpression taskTimeExpression = taskTimeExpressionService.getTaskTimeExpressionById("1057110061127700480");
|
||||
// System.out.println(JSON.toJSONString(taskTimeExpression));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加时间表达式
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertTaskTimeExpression() {
|
||||
// TaskTimeExpression taskTimeExpression = new TaskTimeExpression();
|
||||
// taskTimeExpression.setName("表达式");
|
||||
// taskTimeExpression.setExpressionContent("0000000");
|
||||
// taskTimeExpression.setExpressionDescription("描述");
|
||||
//
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// taskTimeExpression.setId(null);
|
||||
// taskTimeExpression.setName("表达式"+i);
|
||||
// taskTimeExpressionService.insertTaskTimeExpression(taskTimeExpression);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(taskTimeExpression));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改时间表达式
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateTaskTimeExpression(){
|
||||
// TaskTimeExpression taskTimeExpression = taskTimeExpressionService.getTaskTimeExpressionById("1057110613261684736");
|
||||
// taskTimeExpression.setName("测试修改");
|
||||
//
|
||||
// taskTimeExpressionService.updateTaskTimeExpression(taskTimeExpression);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除时间表达式
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteTaskTimeExpressionById(){
|
||||
// taskTimeExpressionService.deleteTaskTimeExpressionById("1057111616417566720");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQueryTaskTimeExpressionByPager(){
|
||||
// TaskTimeExpression taskTimeExpression = new TaskTimeExpression();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = taskTimeExpressionService.queryTaskTimeExpressionByPager(taskTimeExpression,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,109 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeService;
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.ITaskTimeService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.TaskTime;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description :
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-11-03 00:09
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestTaskTimeService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// ITaskTimeService taskTimeService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListTaskTime() {
|
||||
// List list = taskTimeService.listTaskTime();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetTaskTimeById() {
|
||||
// TaskTime taskTime = taskTimeService.getTaskTimeById("1057110061127700480");
|
||||
// System.out.println(JSON.toJSONString(taskTime));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertTaskTime() {
|
||||
// TaskTime taskTime = new TaskTime();
|
||||
// taskTime.setName("时间表达式");
|
||||
// taskTime.setTimeExpressionId(1L);
|
||||
// taskTime.setTaskStartDateTimeRdd("2018-01-01 00:00:00");
|
||||
// taskTime.setTaskEndDateTimeRdd("2018-12-31 00:00:00");
|
||||
// taskTime.setTaskTypeId(ImppEnumUtil.TASK_METHOD_TYPE.TYPE_GROUP.getValue());
|
||||
// taskTime.setTaskStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
|
||||
//
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// taskTime.setId(null);
|
||||
// taskTime.setName("时间表达式"+i);
|
||||
// taskTimeService.insertTaskTime(taskTime,null);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(taskTime));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateTaskTime(){
|
||||
// TaskTime taskTime = taskTimeService.getTaskTimeById("1057110613261684736");
|
||||
// taskTime.setName("测试修改");
|
||||
//
|
||||
// taskTimeService.updateTaskTime(taskTime,null);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteTaskTimeById(){
|
||||
// taskTimeService.deleteTaskTimeById("1058406771644829696");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQueryTaskTimeByPager(){
|
||||
// TaskTime taskTime = new TaskTime();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = taskTimeService.queryTaskTimeByPager(taskTime,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,109 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IToolService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.Tool;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.apache.commons.lang3.EnumUtils;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试 硬件服务接口
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-31 15:30
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestToolService extends TestBase {
|
||||
//
|
||||
// @Autowired
|
||||
// IToolService toolService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListTool() {
|
||||
// List list = toolService.listTool();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetToolById() {
|
||||
// Tool tool = toolService.getToolById("1057110061127700480");
|
||||
// System.out.println(JSON.toJSONString(tool));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertTool() {
|
||||
// Tool tool = new Tool();
|
||||
// tool.setName("扫描枪");
|
||||
// tool.setToolTypeId(1057261374348070912L);
|
||||
// tool.setRedToolTypeName("扫描枪22");
|
||||
// tool.setToolConnTypeId(1);
|
||||
// tool.setToolDataTypeId(1);
|
||||
// tool.setToolStatusId(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
|
||||
//
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// tool.setId(null);
|
||||
// tool.setName("扫描枪"+i);
|
||||
// toolService.insertTool(tool);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(tool));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateTool(){
|
||||
// Tool tool = toolService.getToolById("1057110613261684736");
|
||||
// tool.setName("测试修改");
|
||||
//
|
||||
// toolService.updateTool(tool);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除硬件
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteToolById(){
|
||||
// toolService.deleteToolById("1057111616417566720");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQueryToolByPager(){
|
||||
// Tool tool = new Tool();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = toolService.queryToolByPager(tool,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,101 +0,0 @@
|
||||
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
|
||||
//
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IToolTypeService;
|
||||
//import cn.estsh.i3plus.core.api.iservice.busi.IToolTypeService;
|
||||
//import cn.estsh.i3plus.pojo.base.bean.ListPager;
|
||||
//import cn.estsh.i3plus.pojo.base.common.Pager;
|
||||
//import cn.estsh.i3plus.pojo.platform.bean.ToolType;
|
||||
//import com.alibaba.fastjson.JSON;
|
||||
//import org.junit.Test;
|
||||
//import org.springframework.beans.factory.annotation.Autowired;
|
||||
//import org.springframework.test.annotation.Rollback;
|
||||
//
|
||||
//import javax.transaction.Transactional;
|
||||
//import java.util.List;
|
||||
//
|
||||
///**
|
||||
// * @Description : 测试 硬件类型服务接口
|
||||
// * @Reference :
|
||||
// * @Author : yunhao
|
||||
// * @Date : 2018-10-30 20:36
|
||||
// * @Modify :
|
||||
// **/
|
||||
//public class TestToolTypeService extends TestBase {
|
||||
// @Autowired
|
||||
// private IToolTypeService toolTypeService;
|
||||
//
|
||||
// /**
|
||||
// * 测试 查询所有硬件类型
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testListToolType() {
|
||||
// List list = toolTypeService.listToolType();
|
||||
// System.out.println(JSON.toJSONString(list));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id查询硬件类型
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testGetToolTypeById() {
|
||||
// ToolType toolType = toolTypeService.getToolTypeById("1057110061127700480");
|
||||
// System.out.println(JSON.toJSONString(toolType));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 添加硬件类型
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// @Rollback(false)
|
||||
// public void testInsertToolType() {
|
||||
// ToolType toolType = new ToolType();
|
||||
// toolType.setName("扫描枪");
|
||||
//
|
||||
// for (int i = 0; i < 50; i++) {
|
||||
// toolType.setId(null);
|
||||
// toolType.setName("扫描枪"+i);
|
||||
// toolTypeService.insertToolType(toolType);
|
||||
// }
|
||||
// System.out.println(JSON.toJSONString(toolType));
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 修改硬件类型
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testUpdateToolType(){
|
||||
// ToolType toolType = toolTypeService.getToolTypeById("1057110613261684736");
|
||||
// toolType.setName("测试修改");
|
||||
//
|
||||
// toolTypeService.updateToolType(toolType);
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 根据id删除硬件类型
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testDeleteToolTypeById(){
|
||||
// toolTypeService.deleteToolTypeById("1057111616417566720");
|
||||
// }
|
||||
//
|
||||
// /**
|
||||
// * 测试 复杂查询
|
||||
// */
|
||||
// @Test
|
||||
// @Transactional
|
||||
// public void testQueryToolTypeByPager(){
|
||||
// ToolType toolType = new ToolType();
|
||||
//
|
||||
// Pager pager = new Pager();
|
||||
// pager.setPageSize(10);
|
||||
// pager.setCurrentPage(5);
|
||||
//
|
||||
// ListPager list = toolTypeService.queryToolTypeByPager(toolType,pager);
|
||||
// System.out.println(list);
|
||||
// }
|
||||
//}
|
||||
@ -1,41 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.util;
|
||||
|
||||
import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysTool;
|
||||
import org.junit.Test;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
import javax.annotation.PostConstruct;
|
||||
import java.io.FileInputStream;
|
||||
import java.io.FileNotFoundException;
|
||||
import java.io.FileOutputStream;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* @Description : excel导入导出测试
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-11-21 19:44
|
||||
* @Modify:
|
||||
**/
|
||||
public class TestExcelUtil extends TestBase {
|
||||
|
||||
|
||||
@Test
|
||||
public void TestExportData(){
|
||||
|
||||
}
|
||||
|
||||
@Test
|
||||
public void importData(){
|
||||
try {
|
||||
List sy = ExcelUtil.importData("testOut.xls", new FileInputStream("E://testOut.xls"), SysTool.class);
|
||||
System.out.println(sy);
|
||||
} catch (FileNotFoundException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
}
|
||||
@ -1,29 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.util;
|
||||
|
||||
import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase;
|
||||
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
|
||||
import org.junit.Test;
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-11-21 19:44
|
||||
* @Modify:
|
||||
**/
|
||||
public class TestMailUtil extends TestBase {
|
||||
|
||||
@Autowired
|
||||
MailUtil mailUtil;
|
||||
|
||||
@Test
|
||||
public void TestSendMail(){
|
||||
mailUtil.setTo("yunhao.wang@estsh.com");
|
||||
mailUtil.setSubject("中文");
|
||||
mailUtil.setContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getDescription());
|
||||
mailUtil.setBody("内容");
|
||||
mailUtil.send();
|
||||
|
||||
}
|
||||
}
|
||||
@ -1,33 +0,0 @@
|
||||
package cn.estsh.i3plus.core.apiservice.util;
|
||||
|
||||
import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase;
|
||||
import cn.estsh.i3plus.pojo.platform.bean.SysOrderNoRule;
|
||||
import org.junit.Test;
|
||||
|
||||
/**
|
||||
* @Description :
|
||||
* @Reference :
|
||||
* @Author : yunhao
|
||||
* @CreateDate : 2018-11-21 19:45
|
||||
* @Modify:
|
||||
**/
|
||||
public class TestOrderNoMakeUtil extends TestBase {
|
||||
|
||||
@Test
|
||||
public void TestMakeOrderNo() {
|
||||
SysOrderNoRule sysOrderNoRule = new SysOrderNoRule();
|
||||
sysOrderNoRule.setName("一号单据");
|
||||
sysOrderNoRule.setOrderNoRule("GG-{yyyy}{MM}{dd}{serialNo}");
|
||||
sysOrderNoRule.setSerialNoSeed(1L);
|
||||
sysOrderNoRule.setSerialNoIncrement(1L);
|
||||
sysOrderNoRule.setSerialNoLength(4L);
|
||||
sysOrderNoRule.setSerialNo(9999L);
|
||||
sysOrderNoRule.setIsCycle(1);
|
||||
|
||||
System.out.println(OrderNoMakeUtil.next(sysOrderNoRule));
|
||||
|
||||
// String d= MessageFormat.format("%0{0}d", 3);
|
||||
// System.out.println(d);
|
||||
}
|
||||
|
||||
}
|
||||
Loading…
Reference in New Issue