Merge remote-tracking branch 'origin/master'

# Conflicts:
#	modules/i3plus-core-apiservice/src/main/resources/application-dev.properties
yun-zuoyi
frin.fei 7 years ago
commit fbc33e3d0c

@ -21,6 +21,10 @@
<groupId>i3plus.pojo</groupId> <groupId>i3plus.pojo</groupId>
<artifactId>i3plus-pojo-mes</artifactId> <artifactId>i3plus-pojo-mes</artifactId>
</dependency> </dependency>
<dependency>
<groupId>i3plus.pojo</groupId>
<artifactId>i3plus-pojo-model</artifactId>
</dependency>
<!-- shiro --> <!-- shiro -->
<dependency> <dependency>

@ -1,5 +1,7 @@
package cn.estsh.i3plus.core.api.iservice.busi; package cn.estsh.i3plus.core.api.iservice.busi;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.model.platform.CommonTreeModel;
import cn.estsh.i3plus.pojo.platform.bean.SysDepartment; import cn.estsh.i3plus.pojo.platform.bean.SysDepartment;
import cn.estsh.i3plus.pojo.platform.bean.SysMenu; import cn.estsh.i3plus.pojo.platform.bean.SysMenu;
import cn.estsh.i3plus.pojo.platform.bean.SysOrganize; import cn.estsh.i3plus.pojo.platform.bean.SysOrganize;
@ -28,7 +30,7 @@ public interface ICoreTreeService {
* @param id * @param id
* @return * @return
*/ */
SysPosition getSysPositionTreeByParentId(long id); SysPosition getSysPositionTreeById(long id);
/** /**
* *
@ -55,7 +57,7 @@ public interface ICoreTreeService {
* @param id * @param id
* @return * @return
*/ */
SysDepartment getSysDepartmentTreeByParentId(long id); SysDepartment getSysDepartmentTreeById(long id);
/** /**
* *
@ -82,7 +84,7 @@ public interface ICoreTreeService {
* @param id * @param id
* @return * @return
*/ */
SysOrganize getSysOrganizeTreeByParentId(long id); SysOrganize getSysOrganizeTreeById(long id);
/** /**
* *
@ -109,7 +111,7 @@ public interface ICoreTreeService {
* @param id * @param id
* @return * @return
*/ */
SysMenu getSysMenuTreeByParentId(long id); SysMenu getSysMenuTreeById(long id);
/** /**
* *
@ -124,4 +126,25 @@ public interface ICoreTreeService {
*/ */
void doValidatorSysMenuParentId(SysMenu menu) ; void doValidatorSysMenuParentId(SysMenu menu) ;
/**
*
* @param parentId
* @return
*/
List<CommonTreeModel> findOrganizeDepartment(long parentId);
/**
*
* @param id
* @return
*/
CommonTreeModel getOrganizeById(long id);
/**
*
* @param parent
* @param step
*/
void findOrganizeTreePack(CommonTreeModel parent, int step);
} }

@ -51,4 +51,17 @@ public interface ISysConfigService {
* @return * @return
*/ */
ListPager querySysConfigByPager(SysConfig sysConfig, Pager pager); ListPager querySysConfigByPager(SysConfig sysConfig, Pager pager);
/**
* code
* @param code
* @return
*/
SysConfig getSysConfigByCode(String code);
/**
*
* @return
*/
List findMailConfig();
} }

@ -39,4 +39,9 @@ public interface ISysLocaleLanguageService {
@ApiOperation(value = "根据code查询语言") @ApiOperation(value = "根据code查询语言")
SysLocaleLanguage getSysLocaleLanguageByCode(String code); SysLocaleLanguage getSysLocaleLanguageByCode(String code);
@ApiOperation(value = "根据语言id修改语言状态")
void updateSysLocaleLanguageStatusById(Long id,Integer status);
void updateSysLocaleLanguageStatusByIds(Long[] ids,Integer status);
} }

@ -33,4 +33,7 @@ public interface ISysLocaleResourceService {
@ApiOperation(value = "根据id批量删除",notes = "根据id批量删除") @ApiOperation(value = "根据id批量删除",notes = "根据id批量删除")
void deleteSysLocaleResourceByIds(Long[] ids); void deleteSysLocaleResourceByIds(Long[] ids);
@ApiOperation(value = "批量添加")
void insertSysLocaleResourceList(List<SysLocaleResource> sysLocaleResources);
} }

@ -0,0 +1,25 @@
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.platform.bean.SysLogException;
import io.swagger.annotations.ApiOperation;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-19 17:28
* @Modify:
**/
public interface ISysLogExceptionService {
/**
*
* @param sysLogException
* @param pager
* @return
*/
@ApiOperation(value = "系统异常日志复杂查询,分页,排序")
ListPager<SysLogException> querySysLogExceptionByPager(SysLogException sysLogException, Pager pager);
}

@ -62,6 +62,7 @@ public interface ISysLogOperateService {
List<SysLogOperate> listSysLogOperateByOperateUserName(String operateUserName); List<SysLogOperate> listSysLogOperateByOperateUserName(String operateUserName);
//查询所有日志数量 //查询所有日志数量
@ApiOperation(value = "查询所有日志数量")
long countAllSysLogOperate(); long countAllSysLogOperate();
/** /**

@ -0,0 +1,34 @@
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.platform.bean.SysOrderNoRule;
import io.swagger.annotations.ApiOperation;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-21 19:57
* @Modify:
**/
public interface ISysOrderNoRuleService {
@ApiOperation(value = "添加单号规则")
SysOrderNoRule insertSysOrderNoRule(SysOrderNoRule sysOrderNoRule);
@ApiOperation(value = "修改单号规则")
void updateSysOrderNoRule(SysOrderNoRule sysOrderNoRule);
@ApiOperation(value = "根据id删除单号规则")
void deleteSysOrderNoRuleById(Long id);
@ApiOperation(value = "根据id查询单号规则")
SysOrderNoRule getSysOrderNoRuleById(Long id);
@ApiOperation(value = "单号规则复杂查询,分页,排序")
ListPager querySysOrderNoRuleByPager(SysOrderNoRule sysOrderNoRule, Pager pager);
@ApiOperation(value = "根据code查询单号规则")
SysOrderNoRule getSysOrderNoRuleCode(String code);
}

@ -128,6 +128,27 @@
<groupId>javax.mail</groupId> <groupId>javax.mail</groupId>
<artifactId>mail</artifactId> <artifactId>mail</artifactId>
</dependency> </dependency>
<dependency>
<groupId>org.jdom</groupId>
<artifactId>jdom2</artifactId>
<version>2.0.6</version>
</dependency>
<dependency>
<groupId>jaxen</groupId>
<artifactId>jaxen</artifactId>
<version>1.1.6</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
</dependency>
</dependencies> </dependencies>
<build> <build>
@ -164,8 +185,19 @@
<resource> <resource>
<directory>src/main/resources</directory> <directory>src/main/resources</directory>
<filtering>true</filtering> <filtering>true</filtering>
<excludes>
<exclude>**/*.xlsx</exclude>
</excludes>
</resource>
<resource>
<directory>src/main/resources</directory>
<filtering>false</filtering>
<includes>
<include>**/*.xlsx</include>
</includes>
</resource> </resource>
</resources> </resources>
</build> </build>
</project> </project>

@ -43,7 +43,7 @@ public class DemoTreeAndExceptionController extends CoreBaseController{
@ApiOperation(value="查询部门树",notes="通过部门主键获取部门树,-1为根节点") @ApiOperation(value="查询部门树",notes="通过部门主键获取部门树,-1为根节点")
public ResultBean listDepartmentTree(long depParentId) { public ResultBean listDepartmentTree(long depParentId) {
try { try {
SysDepartment department = coreTreeService.getSysDepartmentTreeByParentId(depParentId); SysDepartment department = coreTreeService.getSysDepartmentTreeById(depParentId);
return ResultBean.success("查询部门树成功") return ResultBean.success("查询部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())

@ -103,7 +103,24 @@ public class AuthController extends CoreBaseController {
try { try {
SessionUser sUser = AuthUtil.getSessionUser(); SessionUser sUser = AuthUtil.getSessionUser();
LOGGER.info("用户:{}",sUser); LOGGER.info("用户:{}",sUser);
return new ResultBean(true,"",sUser); return new ResultBean(true,"",sUser.getUserInfo());
} catch (ImppBusiException e) {
return new ResultBean(false,e.getErrorDetail() + ",so:" + e.getErrorSolution());
}
}
/**
*
* @return
*/
@GetMapping(value="/get-user")
@ApiOperation(value="获取登录用户信息",notes="获取当前登录用户账号详细信息")
public ResultBean getUser(){
LOGGER.info("获取用户信息...lang:{}",AuthUtil.getSessionAttribute("languageCode"));
try {
SessionUser sUser = AuthUtil.getSessionUser();
LOGGER.info("用户:{}",sUser);
return new ResultBean(true,"",sUser.getUser());
} catch (ImppBusiException e) { } catch (ImppBusiException e) {
return new ResultBean(false,e.getErrorDetail() + ",so:" + e.getErrorSolution()); return new ResultBean(false,e.getErrorDetail() + ",so:" + e.getErrorSolution());
} }

@ -1,7 +1,6 @@
package cn.estsh.i3plus.core.apiservice.controller.busi; package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleLanguageService; import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleLanguageService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.platform.common.tool.StringTool; import cn.estsh.i3plus.platform.common.tool.StringTool;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
@ -49,8 +48,8 @@ public class SysLocaleLanguageController extends CoreBaseController {
.notNull("languageCode", sysLocaleLanguage.getLanguageCode()); .notNull("languageCode", sysLocaleLanguage.getLanguageCode());
//新增初始化 //新增初始化
// ConvertBean.modelInitialize(sysLocaleLanguage, sessionUser);
sysLocaleLanguage.setIsDefault(CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue()); sysLocaleLanguage.setIsDefault(CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue());
sysLocaleLanguage.setLanguageStatus(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue());
sysLocaleLanguageService.insertSysLocaleLanguage(sysLocaleLanguage); sysLocaleLanguageService.insertSysLocaleLanguage(sysLocaleLanguage);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
@ -71,9 +70,6 @@ public class SysLocaleLanguageController extends CoreBaseController {
.notNull("languageName", sysLocaleLanguage.getLanguageName()) .notNull("languageName", sysLocaleLanguage.getLanguageName())
.notNull("languageCode", sysLocaleLanguage.getLanguageCode()); .notNull("languageCode", sysLocaleLanguage.getLanguageCode());
//修改初始化
// ConvertBean.modelUpdate(sysLocaleLanguage, sessionUser);
sysLocaleLanguageService.updateSysLocaleLanguage(sysLocaleLanguage); sysLocaleLanguageService.updateSysLocaleLanguage(sysLocaleLanguage);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
@ -161,4 +157,43 @@ public class SysLocaleLanguageController extends CoreBaseController {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
} }
} }
@PostMapping(value = "/status/{id}/{status}")
@ApiOperation(value = "根据id修改语言状态")
public ResultBean updateSysLocaleLanguageStatusById(@PathVariable("id") String idStr,@PathVariable("status") Integer status){
try {
//条件校验
ValidatorBean.checkNotNull(idStr,"id不能为空");
ValidatorBean.checkIsNumber(status,"状态不能为空");
sysLocaleLanguageService.updateSysLocaleLanguageStatusById(Long.parseLong(idStr),status);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@PostMapping(value = "/batch-status")
@ApiOperation(value = "根据批量修改语言状态")
public ResultBean updateSysLocaleLanguageStatusByIds(String[] idsStr,Integer status){
try {
if(idsStr.length == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
ValidatorBean.checkNotZero(status,"状态不能为0");
sysLocaleLanguageService.updateSysLocaleLanguageStatusByIds(StringTool.getArrayLong(idsStr),status);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
} }

@ -1,7 +1,6 @@
package cn.estsh.i3plus.core.apiservice.controller.busi; package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleResourceService; import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleResourceService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.platform.common.tool.StringTool; import cn.estsh.i3plus.platform.common.tool.StringTool;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
@ -165,4 +164,25 @@ public class SysLocaleResourceController extends CoreBaseController {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
} }
} }
@PutMapping(value = "batch-insert")
@ApiOperation(value = "批量添加系统资源")
public ResultBean insertSysLocaleResourceList(@RequestBody List<SysLocaleResource> sysLocaleResourcesList){
try {
if(sysLocaleResourcesList.size() == 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("请选择需要删除的资源。")
.build();
}
sysLocaleResourceService.insertSysLocaleResourceList(sysLocaleResourcesList);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
} }

@ -0,0 +1,49 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogExceptionService;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysLogException;
import cn.estsh.impp.framework.base.controller.CoreBaseController;
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ResultBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-19 18:42
* @Modify:
**/
@RestController
@Api(description = "系统异常日志服务")
@RequestMapping(CoreBaseController.BASE_URL + "/sys-log-exception")
public class SysLogExceptionController {
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogExceptionController.class);
@Autowired
private ISysLogExceptionService sysLogExceptionService;
@GetMapping(value = "/query")
@ApiOperation(value = "异常日志复杂查询,分页,排序",notes = "异常日志复杂查询,分页,排序")
public ResultBean querySysLogOperateByPager(SysLogException sysLogException, Pager pager){
try {
ListPager logExceptionList = sysLogExceptionService.querySysLogExceptionByPager(sysLogException, pager);
return ResultBean.success("查询成功").setListPager(logExceptionList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
}

@ -1,16 +1,13 @@
package cn.estsh.i3plus.core.apiservice.controller.busi; package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogOperateService; import cn.estsh.i3plus.core.api.iservice.busi.ISysLogOperateService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.SysLogOperate; import cn.estsh.i3plus.pojo.platform.bean.SysLogOperate;
import cn.estsh.impp.framework.base.controller.CoreBaseController; import cn.estsh.impp.framework.base.controller.CoreBaseController;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppBusiException; import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ResultBean; import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean; import cn.estsh.impp.framework.boot.util.ValidatorBean;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
@ -24,7 +21,7 @@ import javax.websocket.server.PathParam;
import java.util.List; import java.util.List;
/** /**
* @Description : * @Description :
* @Reference : * @Reference :
* @Author : yunhao * @Author : yunhao
* @Date : 2018-10-25 14:08 * @Date : 2018-10-25 14:08
@ -32,7 +29,7 @@ import java.util.List;
**/ **/
@RestController @RestController
@Api(description = "操作日志") @Api(description = "操作日志")
@RequestMapping(CoreBaseController.BASE_URL + "/log-operate") @RequestMapping(CoreBaseController.BASE_URL + "/sys-log-operate")
public class SysLogOperateController extends CoreBaseController { public class SysLogOperateController extends CoreBaseController {
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogOperateController.class); public static final Logger LOGGER = LoggerFactory.getLogger(SysLogOperateController.class);
@ -43,20 +40,12 @@ public class SysLogOperateController extends CoreBaseController {
@ApiOperation(value = "添加操作日志",notes = "添加操作日志") @ApiOperation(value = "添加操作日志",notes = "添加操作日志")
public ResultBean insertSysLogOperateController(SysLogOperate logOperate){ public ResultBean insertSysLogOperateController(SysLogOperate logOperate){
try { try {
// 登录用户
SessionUser user = AuthUtil.getSessionUser();
// 新增初始化
ConvertBean.modelInitialize(logOperate,user);
logOperateService.insertSysLogOperate(logOperate); logOperateService.insertSysLogOperate(logOperate);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -70,11 +59,9 @@ public class SysLogOperateController extends CoreBaseController {
logOperateService.deleteSysLogOperateById(Long.parseLong(id)); logOperateService.deleteSysLogOperateById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -85,11 +72,9 @@ public class SysLogOperateController extends CoreBaseController {
List logOperateList = logOperateService.listSysLogOperate(); List logOperateList = logOperateService.listSysLogOperate();
return ResultBean.success("查询成功").setResultList(logOperateList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("查询成功").setResultList(logOperateList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -108,11 +93,9 @@ public class SysLogOperateController extends CoreBaseController {
.setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode()); .setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
} }
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -123,11 +106,9 @@ public class SysLogOperateController extends CoreBaseController {
ListPager logSystemList = logOperateService.querySysLogOperateByPager(logOperate, pager); ListPager logSystemList = logOperateService.querySysLogOperateByPager(logOperate, pager);
return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
} }

@ -1,16 +1,13 @@
package cn.estsh.i3plus.core.apiservice.controller.busi; package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogSystemService; import cn.estsh.i3plus.core.api.iservice.busi.ISysLogSystemService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysLogSystem; import cn.estsh.i3plus.pojo.platform.bean.SysLogSystem;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.impp.framework.base.controller.CoreBaseController; import cn.estsh.impp.framework.base.controller.CoreBaseController;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppBusiException; import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ResultBean; import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean; import cn.estsh.impp.framework.boot.util.ValidatorBean;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
@ -31,7 +28,7 @@ import java.util.List;
**/ **/
@RestController @RestController
@Api(description = "系统日志服务") @Api(description = "系统日志服务")
@RequestMapping(CoreBaseController.BASE_URL +"/log-system") @RequestMapping(CoreBaseController.BASE_URL +"/sys-log-system")
public class SysLogSystemController extends CoreBaseController{ public class SysLogSystemController extends CoreBaseController{
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogSystemController.class); public static final Logger LOGGER = LoggerFactory.getLogger(SysLogSystemController.class);
@ -43,20 +40,12 @@ public class SysLogSystemController extends CoreBaseController{
@ApiOperation(value="新增系统日志",notes = "新增系统日志") @ApiOperation(value="新增系统日志",notes = "新增系统日志")
public ResultBean insertSysLogSystem(SysLogSystem logSystem) { public ResultBean insertSysLogSystem(SysLogSystem logSystem) {
try { try {
// 登录用户
SessionUser user = AuthUtil.getSessionUser();
// 新增初始化
ConvertBean.modelInitialize(logSystem,user);
logSystemService.insertSysLogSystem(logSystem); logSystemService.insertSysLogSystem(logSystem);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -70,11 +59,9 @@ public class SysLogSystemController extends CoreBaseController{
logSystemService.deleteSysLogSystemById(Long.parseLong(id)); logSystemService.deleteSysLogSystemById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -83,15 +70,11 @@ public class SysLogSystemController extends CoreBaseController{
public ResultBean findSysLogSystemAll(){ public ResultBean findSysLogSystemAll(){
try { try {
List<SysLogSystem> logSystemList = logSystemService.listSysLogSystem(); List<SysLogSystem> logSystemList = logSystemService.listSysLogSystem();
return ResultBean.success("查询成功") return ResultBean.success("查询成功").setResultList(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
.setResultList(logSystemList)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -102,11 +85,9 @@ public class SysLogSystemController extends CoreBaseController{
SysLogSystem logSystem = logSystemService.getSysLogSystemById(Long.parseLong(id)); SysLogSystem logSystem = logSystemService.getSysLogSystemById(Long.parseLong(id));
return ResultBean.success("查询成功").setResultObject(logSystem).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("查询成功").setResultObject(logSystem).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
@ -123,11 +104,9 @@ public class SysLogSystemController extends CoreBaseController{
ListPager logSystemList = logSystemService.querySysLogSystemByPager(logSystem, pager); ListPager logSystemList = logSystemService.querySysLogSystemByPager(logSystem, pager);
return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){ }catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow()); return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){ }catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e); return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
} }
} }
} }

@ -0,0 +1,132 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysOrderNoRuleService;
import cn.estsh.i3plus.core.apiservice.util.OrderNoMakeUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysOrderNoRule;
import cn.estsh.impp.framework.base.controller.CoreBaseController;
import cn.estsh.impp.framework.boot.exception.ImppBusiException;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.util.ValidatorBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-21 18:20
* @Modify:
**/
@RestController
@Api(description = "系统单号规则管理服务")
@RequestMapping(CoreBaseController.BASE_URL + "/sys-order-no-rule")
public class SysOrderNoRuleController {
@Autowired
ISysOrderNoRuleService sysOrderNoRuleService;
@PostMapping(value = "/insert")
@ApiOperation(value = "新增单号规则")
public ResultBean insertSysOrderNoRule(SysOrderNoRule sysOrderNoRule){
try {
ValidatorBean.beginValid(sysOrderNoRule)
.notNull("name",sysOrderNoRule.getName())
.notNull("orderNoRuleCode",sysOrderNoRule.getOrderNoRuleCode())
.notNull("orderNoRule",sysOrderNoRule.getOrderNoRule())
.checkNotZero("serialNoSeed",sysOrderNoRule.getSerialNoSeed())
.checkNotZero("serialNoIncrement",sysOrderNoRule.getSerialNoIncrement())
.checkNotZero("serialNoLength",sysOrderNoRule.getSerialNoLength())
.checkNotZero("isCycle",sysOrderNoRule.getIsCycle());
sysOrderNoRuleService.insertSysOrderNoRule(sysOrderNoRule);
return ResultBean.success("操作成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@PutMapping(value = "/update")
@ApiOperation(value = "修改单号规则")
public ResultBean updateSysOrderNoRule(SysOrderNoRule sysOrderNoRule){
try {
ValidatorBean.beginValid(sysOrderNoRule)
.notNull("id",sysOrderNoRule.getId())
.notNull("name",sysOrderNoRule.getName())
.notNull("orderNoRuleCode",sysOrderNoRule.getOrderNoRuleCode())
.notNull("orderNoRule",sysOrderNoRule.getOrderNoRule())
.checkNotZero("serialNoSeed",sysOrderNoRule.getSerialNoSeed())
.checkNotZero("serialNoIncrement",sysOrderNoRule.getSerialNoIncrement())
.checkNotZero("serialNoLength",sysOrderNoRule.getSerialNoLength())
.checkNotZero("isCycle",sysOrderNoRule.getIsCycle());
sysOrderNoRuleService.updateSysOrderNoRule(sysOrderNoRule);
return ResultBean.success("操作成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping(value = "/get/{id}")
@ApiOperation(value = "根据id获取编号规则")
public ResultBean getSysOrderNoRuleById(@PathVariable("id") String idStr){
try {
ValidatorBean.checkNotNull(idStr,"id不能为空");
SysOrderNoRule sysOrderNoRule = sysOrderNoRuleService.getSysOrderNoRuleById(Long.parseLong(idStr));
if (sysOrderNoRule != null) {
return ResultBean.success("查询成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@DeleteMapping(value = "/delete/{id}")
@ApiOperation(value = "根据id删除单号规则")
public ResultBean deleteSysOrderNoRuleById(@PathVariable("id") String idStr){
try {
ValidatorBean.checkNotNull(idStr,"id不能为空");
sysOrderNoRuleService.deleteSysOrderNoRuleById(Long.parseLong(idStr));
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping(value = "/get-order-no/{code}")
@ApiOperation(value = "根据单号规则代码,获取单号")
public ResultBean getOrderNo(@PathVariable("code") String code){
try {
ValidatorBean.checkNotNull(code,"code不能为空");
SysOrderNoRule sysOrderNoRule = sysOrderNoRuleService.getSysOrderNoRuleCode(code);
if (sysOrderNoRule == null) {
return ResultBean.fail("单号规则不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}else {
sysOrderNoRule = OrderNoMakeUtil.next(sysOrderNoRule);
sysOrderNoRuleService.updateSysOrderNoRule(sysOrderNoRule);
}
return ResultBean.success("查询成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
}

@ -3,6 +3,7 @@ package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ICoreTreeService; import cn.estsh.i3plus.core.api.iservice.busi.ICoreTreeService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysOrganizeService; import cn.estsh.i3plus.core.api.iservice.busi.ISysOrganizeService;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.model.platform.CommonTreeModel;
import cn.estsh.i3plus.pojo.platform.bean.SysDepartment; import cn.estsh.i3plus.pojo.platform.bean.SysDepartment;
import cn.estsh.i3plus.pojo.platform.bean.SysMenu; import cn.estsh.i3plus.pojo.platform.bean.SysMenu;
import cn.estsh.i3plus.pojo.platform.bean.SysOrganize; import cn.estsh.i3plus.pojo.platform.bean.SysOrganize;
@ -47,7 +48,7 @@ public class SysTreeController extends CoreBaseController {
@ApiOperation(value="查询岗位树",notes="通过部门主键获取岗位树,-1为根节点") @ApiOperation(value="查询岗位树",notes="通过部门主键获取岗位树,-1为根节点")
public ResultBean listSysPositionTree(@PathVariable("id") long id) { public ResultBean listSysPositionTree(@PathVariable("id") long id) {
try { try {
SysPosition position = coreTreeService.getSysPositionTreeByParentId(id); SysPosition position = coreTreeService.getSysPositionTreeById(id);
return ResultBean.success("查询部门树成功") return ResultBean.success("查询部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
@ -84,7 +85,7 @@ public class SysTreeController extends CoreBaseController {
@ApiOperation(value="查询组织树",notes="通过部门主键获取组织树,-1为根节点") @ApiOperation(value="查询组织树",notes="通过部门主键获取组织树,-1为根节点")
public ResultBean listOrganizeTree(@PathVariable("id") long id) { public ResultBean listOrganizeTree(@PathVariable("id") long id) {
try { try {
SysOrganize obj = coreTreeService.getSysOrganizeTreeByParentId(id); SysOrganize obj = coreTreeService.getSysOrganizeTreeById(id);
return ResultBean.success("查询部门树成功") return ResultBean.success("查询部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
@ -120,7 +121,7 @@ public class SysTreeController extends CoreBaseController {
@ApiOperation(value="部门树",notes="通过部门主键获取部门树,-1为根节点") @ApiOperation(value="部门树",notes="通过部门主键获取部门树,-1为根节点")
public ResultBean listDepartmentTree(@PathVariable("id") long id) { public ResultBean listDepartmentTree(@PathVariable("id") long id) {
try { try {
SysDepartment obj = coreTreeService.getSysDepartmentTreeByParentId(id); SysDepartment obj = coreTreeService.getSysDepartmentTreeById(id);
return ResultBean.success("查询部门树成功") return ResultBean.success("查询部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
@ -157,7 +158,7 @@ public class SysTreeController extends CoreBaseController {
@ApiOperation(value="部门树",notes="通过部门主键获取部门树,-1为根节点") @ApiOperation(value="部门树",notes="通过部门主键获取部门树,-1为根节点")
public ResultBean listSysMenuTree(@PathVariable("id") long id) { public ResultBean listSysMenuTree(@PathVariable("id") long id) {
try { try {
SysMenu obj = coreTreeService.getSysMenuTreeByParentId(id); SysMenu obj = coreTreeService.getSysMenuTreeById(id);
return ResultBean.success("查询部门树成功") return ResultBean.success("查询部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
@ -189,4 +190,21 @@ public class SysTreeController extends CoreBaseController {
} }
} }
@GetMapping(value="/organize-department/list/{parentId}")
@ApiOperation(value="查询组织-部门树",notes="通过部门主键获取组组织-部门,-1为根节点")
public ResultBean listOrganizeDepartmentListTree(@PathVariable("parentId") long parentId) {
try {
List<CommonTreeModel> resultList = coreTreeService.findOrganizeDepartment(parentId);
return ResultBean.success("查询组织-部门树成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultList(resultList);
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep.getErrorShow());
}catch(Exception e){
LOGGER.error(ImppExceptionEnum.SYSTEM_EXCEPTION.getDescription() + "{}",e.getMessage(),e);
return ResultBean.fail().setCode(ImppExceptionEnum.SYSTEM_EXCEPTION.getCode());
}
}
} }

@ -2,8 +2,6 @@ package cn.estsh.i3plus.core.apiservice.mq;
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService; import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService; import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
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 cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysRefUserMessage; import cn.estsh.i3plus.pojo.platform.bean.SysRefUserMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysUser; import cn.estsh.i3plus.pojo.platform.bean.SysUser;
@ -51,12 +49,12 @@ public class MailQueueReceiver {
SysMessage sysMessage = sysMessageService.getSysMessageById(msg.getMessageId()); SysMessage sysMessage = sysMessageService.getSysMessageById(msg.getMessageId());
SysUser sysUser = sysUserService.getSysUserById(msg.getReceiverId()); SysUser sysUser = sysUserService.getSysUserById(msg.getReceiverId());
MailUtil mailUtil = new MailUtil(); // MailUtil mailUtil = new MailUtil();
mailUtil.setSubject(sysMessage.getMessageTitle()); // mailUtil.setSubject(sysMessage.getMessageTitle());
mailUtil.setContentType(ImppEnumUtil.MESSAGE_CONTENT_TYPE.valueOfDescription(sysMessage.getMessageContentType())); // mailUtil.setContentType(ImppEnumUtil.MESSAGE_CONTENT_TYPE.valueOfDescription(sysMessage.getMessageContentType()));
mailUtil.setBody(sysMessage.getMessageContent()); // mailUtil.setBody(sysMessage.getMessageContent());
mailUtil.setTo(sysUser.getUserEmail()); // mailUtil.setTo(sysUser.getUserEmail());
mailUtil.send(); // mailUtil.send();
//信息已处理 //信息已处理
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);

@ -1,7 +1,10 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi; package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ICoreTreeService; import cn.estsh.i3plus.core.api.iservice.busi.ICoreTreeService;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ModelEnumUtil;
import cn.estsh.i3plus.pojo.model.platform.CommonTreeModel;
import cn.estsh.i3plus.pojo.platform.bean.SysDepartment; import cn.estsh.i3plus.pojo.platform.bean.SysDepartment;
import cn.estsh.i3plus.pojo.platform.bean.SysMenu; import cn.estsh.i3plus.pojo.platform.bean.SysMenu;
import cn.estsh.i3plus.pojo.platform.bean.SysOrganize; import cn.estsh.i3plus.pojo.platform.bean.SysOrganize;
@ -18,6 +21,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List; import java.util.List;
/** /**
@ -59,7 +63,7 @@ public class CoreTreeService implements ICoreTreeService {
} }
@Override @Override
public SysPosition getSysPositionTreeByParentId(long id) { public SysPosition getSysPositionTreeById(long id) {
// 查找数据 // 查找数据
SysPosition position = positionRDao.getById(id); SysPosition position = positionRDao.getById(id);
// 数据是否真实存在 // 数据是否真实存在
@ -107,7 +111,7 @@ public class CoreTreeService implements ICoreTreeService {
} }
@Override @Override
public SysDepartment getSysDepartmentTreeByParentId(long id) { public SysDepartment getSysDepartmentTreeById(long id) {
// 查找数据 // 查找数据
SysDepartment department = departmentRDao.getById(id); SysDepartment department = departmentRDao.getById(id);
// 数据是否真实存在 // 数据是否真实存在
@ -155,7 +159,7 @@ public class CoreTreeService implements ICoreTreeService {
} }
@Override @Override
public SysOrganize getSysOrganizeTreeByParentId(long id) { public SysOrganize getSysOrganizeTreeById(long id) {
// 查找数据 // 查找数据
SysOrganize organize = organizeRDao.getById(id); SysOrganize organize = organizeRDao.getById(id);
// 数据是否真实存在 // 数据是否真实存在
@ -202,7 +206,7 @@ public class CoreTreeService implements ICoreTreeService {
} }
@Override @Override
public SysMenu getSysMenuTreeByParentId(long id) { public SysMenu getSysMenuTreeById(long id) {
// 查找数据 // 查找数据
SysMenu menu = menuRDao.getById(id); SysMenu menu = menuRDao.getById(id);
// 数据是否真实存在 // 数据是否真实存在
@ -305,4 +309,98 @@ public class CoreTreeService implements ICoreTreeService {
} }
} }
} }
@Override
public List<CommonTreeModel> findOrganizeDepartment(long parentId) {
List<CommonTreeModel> result = new ArrayList<>();
List<SysOrganize> list = organizeRDao.findByProperty("parentId", parentId);
// 循环设置子集
if(list != null && list.size() > 0){
for (SysOrganize organize : list) {
CommonTreeModel treeModel = new CommonTreeModel();
treeModel.setBean(organize);
treeModel.setBeanType(ModelEnumUtil.COMMON_TREE_TYPE.TYPE_ORGANIZE.getValue());
findOrganizeTreePack(treeModel,0);
result.add(treeModel);
}
}
return result;
}
@Override
public CommonTreeModel getOrganizeById(long id) {
// 查找数据
SysOrganize organize = organizeRDao.getById(id);
// 数据是否真实存在
ValidatorBean.checkNotNull(organize,"不存在的组织信息");
CommonTreeModel treeModel = new CommonTreeModel();
treeModel.setBean(organize);
treeModel.setBeanType(ModelEnumUtil.COMMON_TREE_TYPE.TYPE_ORGANIZE.getValue());
// 递归查询子集
findOrganizeTreePack(treeModel, 0);
return treeModel;
}
@Override
public void findOrganizeTreePack(CommonTreeModel parent, int step) {
if(null != parent){
BaseBean bean = parent.getBean();
List<CommonTreeModel> childList = new ArrayList<>();
CommonTreeModel treeModel = null;
if(bean instanceof SysOrganize){
SysOrganize organize = (SysOrganize) bean;
List<SysOrganize> organizeList = organizeRDao.findByProperty("parentId", organize.getId());
if(organizeList != null && organizeList.size() > 0){
for (SysOrganize org : organizeList) {
treeModel = new CommonTreeModel();
treeModel.setBean(org);
treeModel.setBeanType(ModelEnumUtil.COMMON_TREE_TYPE.TYPE_ORGANIZE.getValue());
findOrganizeTreePack(treeModel,step);
childList.add(treeModel);
}
}
List<SysDepartment> departmentList = departmentRDao.findByProperty("organizeId", organize.getId());
if(departmentList != null && departmentList.size() > 0){
for (SysDepartment department : departmentList) {
if(department.getParentId() != null && department.getParentId() < 0){
treeModel = new CommonTreeModel();
treeModel.setBean(department);
treeModel.setBeanType(ModelEnumUtil.COMMON_TREE_TYPE.TYPE_DEPARTMENT.getValue());
findOrganizeTreePack(treeModel,step);
childList.add(treeModel);
}
}
}
LOGGER.info("【{}】包含子集:{},步长:{}", parent.getBean().getClass().getName(), parent.getChildList().size(), step);
}else if(bean instanceof SysDepartment){
SysDepartment department = (SysDepartment) bean;
List<SysDepartment> departmentList = departmentRDao.findByProperty("parentId", department.getId());
if(departmentList != null && departmentList.size() > 0){
for (SysDepartment dep : departmentList) {
treeModel = new CommonTreeModel();
treeModel.setBean(dep);
treeModel.setBeanType(ModelEnumUtil.COMMON_TREE_TYPE.TYPE_DEPARTMENT.getValue());
findOrganizeTreePack(treeModel,step);
childList.add(treeModel);
}
}
}
parent.setChildList(childList);
}
}
} }

@ -12,6 +12,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List; import java.util.List;
/** /**
@ -71,4 +72,21 @@ public class SysConfigService implements ISysConfigService {
} }
} }
@Override
public SysConfig getSysConfigByCode(String code) {
return SysConfigRDao.getByProperty("configCode",code);
}
@Override
public List findMailConfig() {
List mailConfig = new ArrayList();
// mailConfig.add(SysConfigRDao.getByProperty("configCode", PlatformConstWords.MAIL_HOST));
// mailConfig.add(SysConfigRDao.getByProperty("configCode", PlatformConstWords.MAIL_PORT));
// mailConfig.add(SysConfigRDao.getByProperty("configCode", PlatformConstWords.MAIL_USER));
// mailConfig.add(SysConfigRDao.getByProperty("configCode", PlatformConstWords.MAIL_PASSWORD));
// mailConfig.add(SysConfigRDao.getByProperty("configCode", PlatformConstWords.MAIL_NICK));
return mailConfig;
}
} }

@ -117,7 +117,6 @@ public class SysDictionaryService implements ISysDictionaryService {
@Override @Override
public ListPager querySysDictionaryByPager(SysDictionary sysDictionary, Pager pager) { public ListPager querySysDictionaryByPager(SysDictionary sysDictionary, Pager pager) {
LOGGER.info("字典 SYS_DICTIONARY SysDictionary:{}Pager:{}",sysDictionary,pager);
sysDictionary = sysDictionary == null ? new SysDictionary():sysDictionary; sysDictionary = sysDictionary == null ? new SysDictionary():sysDictionary;
String hqlPack = CoreHqlPack.packHqlSysDictionary(sysDictionary); String hqlPack = CoreHqlPack.packHqlSysDictionary(sysDictionary);

@ -9,7 +9,6 @@ import cn.estsh.i3plus.pojo.platform.bean.SysLocaleLanguage;
import cn.estsh.i3plus.pojo.platform.repository.SysLocaleLanguageRepository; import cn.estsh.i3plus.pojo.platform.repository.SysLocaleLanguageRepository;
import cn.estsh.i3plus.pojo.platform.repository.SysLocaleResourceRepository; import cn.estsh.i3plus.pojo.platform.repository.SysLocaleResourceRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack; import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.base.service.IBaseService;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum; import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import cn.estsh.impp.framework.boot.util.ValidatorBean; import cn.estsh.impp.framework.boot.util.ValidatorBean;
@ -103,7 +102,6 @@ public class SysLocaleLanguageService implements ISysLocaleLanguageService {
@Override @Override
public ListPager querySysLocaleLanguageByPager(SysLocaleLanguage sysLocaleLanguage, Pager pager) { public ListPager querySysLocaleLanguageByPager(SysLocaleLanguage sysLocaleLanguage, Pager pager) {
LOGGER.info("系统语言 SYS_LOCALE_LANGUAGE sysLocaleLanguage:{},Pager:{}",sysLocaleLanguage,pager);
if(sysLocaleLanguage == null) { if(sysLocaleLanguage == null) {
pager = PagerHelper.getPager(pager, sysLocaleLanguageRDao.listCount()); pager = PagerHelper.getPager(pager, sysLocaleLanguageRDao.listCount());
return new ListPager(sysLocaleLanguageRDao.listPager(pager),pager); return new ListPager(sysLocaleLanguageRDao.listPager(pager),pager);
@ -116,13 +114,19 @@ public class SysLocaleLanguageService implements ISysLocaleLanguageService {
@Override @Override
public void deleteSysLocaleLanguageByIds(Long[] ids) { public void deleteSysLocaleLanguageByIds(Long[] ids) {
LOGGER.info("系统语言 SYS_LOCALE_LANGUAGE ids:{}",ids); if(sysLocaleResourceRDao.findByHqlWhereCount(CoreHqlPack.packHqlIds("id",ids)) > 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("存在关联资源无法删除")
.build();
}
sysLocaleLanguageRDao.deleteByIds(ids); sysLocaleLanguageRDao.deleteByIds(ids);
} }
@Override @Override
public void updateSysLocaleLanguageDefaultById(Long ids) { public void updateSysLocaleLanguageDefaultById(Long ids) {
LOGGER.info("系统语言 SYS_LOCALE_LANGUAGE ids:{}",ids);
sysLocaleLanguageRDao.updateByHqlWhere("and 1=1","isDefault",CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue()); sysLocaleLanguageRDao.updateByHqlWhere("and 1=1","isDefault",CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue());
sysLocaleLanguageRDao.updateByProperties("id",ids, sysLocaleLanguageRDao.updateByProperties("id",ids,
@ -133,4 +137,14 @@ public class SysLocaleLanguageService implements ISysLocaleLanguageService {
public SysLocaleLanguage getSysLocaleLanguageByCode(String code) { public SysLocaleLanguage getSysLocaleLanguageByCode(String code) {
return sysLocaleLanguageRDao.getByProperty("languageCode",code); return sysLocaleLanguageRDao.getByProperty("languageCode",code);
} }
@Override
public void updateSysLocaleLanguageStatusById(Long id, Integer status) {
sysLocaleLanguageRDao.updateByProperties("id",id,"languageStatus",status);
}
@Override
public void updateSysLocaleLanguageStatusByIds(Long[] ids, Integer status) {
sysLocaleLanguageRDao.updateByHqlWhere(CoreHqlPack.packHqlIds("id",ids),"languageStatus",status);
}
} }

@ -115,4 +115,9 @@ public class SysLocaleResourceService implements ISysLocaleResourceService {
LOGGER.info("系统资源 SYS_LOCALE_RESOURCE ids{}",ids); LOGGER.info("系统资源 SYS_LOCALE_RESOURCE ids{}",ids);
sysLocaleResourceRDao.deleteByIds(ids); sysLocaleResourceRDao.deleteByIds(ids);
} }
@Override
public void insertSysLocaleResourceList(List<SysLocaleResource> sysLocaleResourcesList) {
sysLocaleResourceRDao.saveAll(sysLocaleResourcesList);
}
} }

@ -0,0 +1,45 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLogExceptionService;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.platform.bean.SysLogException;
import cn.estsh.i3plus.pojo.platform.repositorymongo.SysLogExceptionRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack;
import io.swagger.annotations.ApiOperation;
import org.bson.conversions.Bson;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-19 17:30
* @Modify:
**/
@Service
public class SysLogExceptionService implements ISysLogExceptionService {
public static final Logger LOGGER = LoggerFactory.getLogger(SysLogExceptionService.class);
@Autowired
private SysLogExceptionRepository sysLogExceptionRDao;
@Override
@ApiOperation(value = "系统异常日志复杂查询,分页,排序")
public ListPager<SysLogException> querySysLogExceptionByPager(SysLogException sysLogException, Pager pager) {
if(sysLogException == null) {
pager = PagerHelper.getPager(pager, (int) sysLogExceptionRDao.count());
return new ListPager(sysLogExceptionRDao.findAll(),pager);
}else{
Bson bson = CoreBsonPack.packBsonBySysLogException(sysLogException);
pager = PagerHelper.getPager(pager,sysLogExceptionRDao.findByBsonCount(bson));
//分页,排序
return new ListPager(sysLogExceptionRDao.findByBsonPager(bson,pager,sysLogException.getOrderByParam()
,sysLogException.getAscOrDesc()),pager);
}
}
}

@ -7,6 +7,7 @@ import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.platform.bean.SysLogOperate; import cn.estsh.i3plus.pojo.platform.bean.SysLogOperate;
import cn.estsh.i3plus.pojo.platform.repositorymongo.SysLogOperateRepository; import cn.estsh.i3plus.pojo.platform.repositorymongo.SysLogOperateRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack; import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack;
import io.swagger.annotations.ApiOperation;
import org.bson.conversions.Bson; import org.bson.conversions.Bson;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -31,16 +32,19 @@ public class SysLogOperateService implements ISysLogOperateService {
public SysLogOperateRepository logOperateRDao; public SysLogOperateRepository logOperateRDao;
@Override @Override
@ApiOperation(value = "添加操作日志",notes = "添加操作日志")
public SysLogOperate insertSysLogOperate(SysLogOperate logOperate) { public SysLogOperate insertSysLogOperate(SysLogOperate logOperate) {
return logOperateRDao.insert(logOperate); return logOperateRDao.insert(logOperate);
} }
@Override @Override
@ApiOperation(value = "根据id删除日志",notes = "根据id删除日志")
public void deleteSysLogOperateById(Long id) { public void deleteSysLogOperateById(Long id) {
logOperateRDao.deleteById(id); logOperateRDao.deleteById(id);
} }
@Override @Override
@ApiOperation(value = "查询全部操作日志",notes = "查询全部操作日志")
public List listSysLogOperate() { public List listSysLogOperate() {
return logOperateRDao.listPager(null); return logOperateRDao.listPager(null);
} }
@ -53,28 +57,32 @@ public class SysLogOperateService implements ISysLogOperateService {
} }
@Override @Override
@ApiOperation(value = "根据id查询操作日志",notes = "根据id查询操作日志")
public SysLogOperate getSysLogOperateById(Long id) { public SysLogOperate getSysLogOperateById(Long id) {
return logOperateRDao.getById(id); return logOperateRDao.getById(id);
} }
@Override @Override
@ApiOperation(value = "根据操作人姓名模糊查询日志",notes = "根据操作人姓名模糊查询日志")
public List<SysLogOperate> listSysLogOperateByOperateUserName(String operateUserName) { public List<SysLogOperate> listSysLogOperateByOperateUserName(String operateUserName) {
return logOperateRDao.findByProperty("operateUserName",operateUserName); return logOperateRDao.findByProperty("operateUserName",operateUserName);
} }
@Override @Override
@ApiOperation(value = "查询所有日志数量")
public long countAllSysLogOperate() { public long countAllSysLogOperate() {
return logOperateRDao.listCount(); return logOperateRDao.listCount();
} }
@Override @Override
@ApiOperation(value = "操作日志复杂查询,分页,排序",notes = "操作日志复杂查询,分页,排序")
public ListPager<SysLogOperate> querySysLogOperateByPager(SysLogOperate logOperate, Pager pager) { public ListPager<SysLogOperate> querySysLogOperateByPager(SysLogOperate logOperate, Pager pager) {
if(logOperate == null) { if(logOperate == null) {
pager = PagerHelper.getPager(pager, (int) logOperateRDao.count()); pager = PagerHelper.getPager(pager, (int) logOperateRDao.count());
return new ListPager(logOperateRDao.findAll(),pager); return new ListPager(logOperateRDao.findAll(),pager);
}else{ }else{
Bson bson = CoreBsonPack.packBsonByLogOperate(logOperate); Bson bson = CoreBsonPack.packBsonByLogOperate(logOperate);
pager = PagerHelper.getPager(pager,(int)logOperateRDao.findByBsonCount(bson)); pager = PagerHelper.getPager(pager,logOperateRDao.findByBsonCount(bson));
//分页,排序 //分页,排序
return new ListPager(logOperateRDao.findByBsonPager(bson,pager,logOperate.getOrderByParam(),logOperate.getAscOrDesc()),pager); return new ListPager(logOperateRDao.findByBsonPager(bson,pager,logOperate.getOrderByParam(),logOperate.getAscOrDesc()),pager);
} }

@ -8,6 +8,7 @@ import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.platform.bean.SysLogSystem; import cn.estsh.i3plus.pojo.platform.bean.SysLogSystem;
import cn.estsh.i3plus.pojo.platform.repositorymongo.SysLogSystemRepository; import cn.estsh.i3plus.pojo.platform.repositorymongo.SysLogSystemRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack; import cn.estsh.i3plus.pojo.platform.sqlpack.CoreBsonPack;
import io.swagger.annotations.ApiOperation;
import org.bson.conversions.Bson; import org.bson.conversions.Bson;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -32,38 +33,38 @@ public class SysLogSystemService implements ISysLogSystemService {
private SysLogSystemRepository logSystemRDao; private SysLogSystemRepository logSystemRDao;
@Override @Override
@ApiOperation(value = "添加系统日志",notes = "添加系统日志")
public void insertSysLogSystem(SysLogSystem logSystem) { public void insertSysLogSystem(SysLogSystem logSystem) {
LOGGER.info("系统日志 SYS_SYSTEM {}",logSystem);
logSystemRDao.insert(logSystem); logSystemRDao.insert(logSystem);
} }
@Override @Override
@ApiOperation(value = "删除日志",notes = "删除日志")
public void deleteSysLogSystemById(Long id) { public void deleteSysLogSystemById(Long id) {
LOGGER.info("系统日志 SYS_SYSTEM id:{}",id);
logSystemRDao.deleteById(id); logSystemRDao.deleteById(id);
} }
@Override @Override
@ApiOperation(value = "查询全部日志",notes = "查询全部日志")
public List<SysLogSystem> listSysLogSystem() { public List<SysLogSystem> listSysLogSystem() {
LOGGER.info("系统日志 LOG_SYSTEM list");
return logSystemRDao.findAll(); return logSystemRDao.findAll();
} }
@Override @Override
@ApiOperation(value = "根据id查询系统日志",notes = "根据id查询系统日志")
public SysLogSystem getSysLogSystemById(long id) { public SysLogSystem getSysLogSystemById(long id) {
LOGGER.info("系统日志 LOG_SYSTEM id:{}",id);
return logSystemRDao.getById(id); return logSystemRDao.getById(id);
} }
@Override @Override
@ApiOperation(value = "系统日志分页复杂查询",notes = "系统日志分页复杂查询")
public ListPager querySysLogSystemByPager(SysLogSystem logSystem, Pager pager) { public ListPager querySysLogSystemByPager(SysLogSystem logSystem, Pager pager) {
LOGGER.info("系统日志 LOG_SYSTEM logSystem:{}Pager:{}",logSystem,pager);
if (logSystem == null) { if (logSystem == null) {
pager = PagerHelper.getPager(pager,(int) logSystemRDao.listCount()); pager = PagerHelper.getPager(pager,logSystemRDao.listCount());
return new ListPager(logSystemRDao.listPager(pager),pager); return new ListPager(logSystemRDao.listPager(pager),pager);
} else { } else {
Bson bson = CoreBsonPack.packBsonByLogSystem(logSystem); Bson bson = CoreBsonPack.packBsonByLogSystem(logSystem);
pager = PagerHelper.getPager(pager, (int) logSystemRDao.findByBsonCount(bson)); pager = PagerHelper.getPager(pager,logSystemRDao.findByBsonCount(bson));
return new ListPager(logSystemRDao.findByBsonPager(bson,pager,logSystem.getOrderByParam() return new ListPager(logSystemRDao.findByBsonPager(bson,pager,logSystem.getOrderByParam()
,logSystem.getAscOrDesc()),pager); ,logSystem.getAscOrDesc()),pager);
} }

@ -0,0 +1,90 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysOrderNoRuleService;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysOrderNoRule;
import cn.estsh.i3plus.pojo.platform.repository.SysOrderNoRuleRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-21 20:04
* @Modify:
**/
@Service
public class SysOrderNoRuleService implements ISysOrderNoRuleService {
public static final Logger LOGGER = LoggerFactory.getLogger(SysOrderNoRuleService.class);
@Autowired
private SysOrderNoRuleRepository sysOrderNoRuleRDao;
@Override
public SysOrderNoRule insertSysOrderNoRule(SysOrderNoRule sysOrderNoRule) {
if(sysOrderNoRuleRDao.isExitByProperty("orderNoRuleCode",sysOrderNoRule.getOrderNoRuleCode())){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("规则代码已存在")
.setErrorSolution("请重新输入规则代码")
.build();
}
return sysOrderNoRuleRDao.insert(sysOrderNoRule);
}
@Override
public void updateSysOrderNoRule(SysOrderNoRule sysOrderNoRule) {
// 校验唯一
String hqlPack = CoreHqlPack.packHqlSysOrderNoRuleCode(sysOrderNoRule);
long repeatCount = sysOrderNoRuleRDao.findByHqlWhereCount(hqlPack);
if (repeatCount > 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("规则代码已存在")
.setErrorSolution("请重新输入规则代码")
.build();
}
sysOrderNoRuleRDao.update(sysOrderNoRule);
}
@Override
public void deleteSysOrderNoRuleById(Long id) {
sysOrderNoRuleRDao.deleteById(id);
}
@Override
public SysOrderNoRule getSysOrderNoRuleById(Long id) {
return sysOrderNoRuleRDao.getById(id);
}
@Override
public ListPager querySysOrderNoRuleByPager(SysOrderNoRule sysOrderNoRule, Pager pager) {
if(sysOrderNoRule == null) {
pager = PagerHelper.getPager(pager, sysOrderNoRuleRDao.listCount());
return new ListPager(sysOrderNoRuleRDao.listPager(pager),pager);
}else {
String hqlPack = CoreHqlPack.packHqlSysOrderNoRule(sysOrderNoRule);
pager = PagerHelper.getPager(pager, sysOrderNoRuleRDao.findByHqlWhereCount(hqlPack));
return new ListPager(sysOrderNoRuleRDao.findByHqlWherePage(hqlPack + sysOrderNoRule.orderBy(),pager),pager);
}
}
@Override
public SysOrderNoRule getSysOrderNoRuleCode(String code) {
return sysOrderNoRuleRDao.getByProperty("code",code);
}
}

@ -35,10 +35,10 @@ public class SysUserInfoService implements ISysUserInfoService {
public static final Logger LOGGER = LoggerFactory.getLogger(SysUserInfoService.class); public static final Logger LOGGER = LoggerFactory.getLogger(SysUserInfoService.class);
@Autowired @Autowired
private SysUserInfoRepository userInfoRDao; private SysUserInfoRepository sysUserInfoRDao;
@Autowired @Autowired
private SysUserRepository userRDao; private SysUserRepository sysUserRepository;
@Autowired @Autowired
private SysDepartmentRepository departmentRDao; private SysDepartmentRepository departmentRDao;
@ -63,20 +63,20 @@ public class SysUserInfoService implements ISysUserInfoService {
public SysUserInfo insertSysUserInfo(SysUserInfo userInfo) { public SysUserInfo insertSysUserInfo(SysUserInfo userInfo) {
LOGGER.info("用户信息 SysUserInfo userInfo:{}",userInfo); LOGGER.info("用户信息 SysUserInfo userInfo:{}",userInfo);
return userInfoRDao.insert(userInfo); return sysUserInfoRDao.insert(userInfo);
} }
@Override @Override
public void updateSysUserInfo(SysUserInfo userInfo) { public void updateSysUserInfo(SysUserInfo userInfo) {
LOGGER.info("用户信息 SysUserInfo userInfo:{}",userInfo); LOGGER.info("用户信息 SysUserInfo userInfo:{}",userInfo);
userInfoRDao.update(userInfo); sysUserInfoRDao.update(userInfo);
} }
@Override @Override
public void refreshRefUserDepartment(Long userInfoId, Long[] departmentIds, String userName) { public void refreshRefUserDepartment(Long userInfoId, Long[] departmentIds, String userName) {
LOGGER.info("用户信息 SysUserInfo userInfoId:{} departmentIds:{} userName:{}",userInfoId,departmentIds,userName); LOGGER.info("用户信息 SysUserInfo userInfoId:{} departmentIds:{} userName:{}",userInfoId,departmentIds,userName);
SysUserInfo userInfo = userInfoRDao.getById(userInfoId); SysUserInfo userInfo = sysUserInfoRDao.getById(userInfoId);
if(userInfo != null ){ if(userInfo != null ){
// 查询部门信息 // 查询部门信息
StringBuffer where = new StringBuffer(); StringBuffer where = new StringBuffer();
@ -106,7 +106,7 @@ public class SysUserInfoService implements ISysUserInfoService {
userInfo.setDepartmentNameRdd(String.join(",",nameList)); userInfo.setDepartmentNameRdd(String.join(",",nameList));
refUserDepartmentRDao.saveAll(list); refUserDepartmentRDao.saveAll(list);
userInfoRDao.save(userInfo); sysUserInfoRDao.save(userInfo);
LOGGER.info("用户信息 SysUserInfo RefUserDepartmentRDao Insert Size :{}",list.size()); LOGGER.info("用户信息 SysUserInfo RefUserDepartmentRDao Insert Size :{}",list.size());
} }
@ -124,7 +124,7 @@ public class SysUserInfoService implements ISysUserInfoService {
public void refreshRefUserPosition(Long userInfoId, Long[] positionIds , String userName) { public void refreshRefUserPosition(Long userInfoId, Long[] positionIds , String userName) {
LOGGER.info("用户信息 SysUserInfo userInfoId:{} positionIds:{} userName:{}",userInfoId,positionIds,userName); LOGGER.info("用户信息 SysUserInfo userInfoId:{} positionIds:{} userName:{}",userInfoId,positionIds,userName);
SysUserInfo userInfo = userInfoRDao.getById(userInfoId); SysUserInfo userInfo = sysUserInfoRDao.getById(userInfoId);
if(userInfo != null ){ if(userInfo != null ){
// 查询部门信息 // 查询部门信息
StringBuffer where = new StringBuffer(); StringBuffer where = new StringBuffer();
@ -154,7 +154,7 @@ public class SysUserInfoService implements ISysUserInfoService {
userInfo.setPositionNameRdd(String.join(",",nameList)); userInfo.setPositionNameRdd(String.join(",",nameList));
refUserPositionRDao.saveAll(list); refUserPositionRDao.saveAll(list);
userInfoRDao.save(userInfo); sysUserInfoRDao.save(userInfo);
LOGGER.info("用户信息 SysUserInfo RefUserPositionRDao Insert Size :{}",list.size()); LOGGER.info("用户信息 SysUserInfo RefUserPositionRDao Insert Size :{}",list.size());
} }
@ -171,7 +171,7 @@ public class SysUserInfoService implements ISysUserInfoService {
@Override @Override
public void refreshRefUserOrganize(Long userInfoId, Long organizeId, String userName) { public void refreshRefUserOrganize(Long userInfoId, Long organizeId, String userName) {
LOGGER.info("用户信息 SysUserInfo userInfoId:{} organizeId:{} userName:{}",userInfoId,organizeId,userName); LOGGER.info("用户信息 SysUserInfo userInfoId:{} organizeId:{} userName:{}",userInfoId,organizeId,userName);
SysUserInfo userInfo = userInfoRDao.getById(userInfoId); SysUserInfo userInfo = sysUserInfoRDao.getById(userInfoId);
if(userInfo != null ){ if(userInfo != null ){
SysOrganize organize = organizeRDao.getById(organizeId); SysOrganize organize = organizeRDao.getById(organizeId);
if(organize != null ){ if(organize != null ){
@ -181,7 +181,7 @@ public class SysUserInfoService implements ISysUserInfoService {
userInfo.setModifyUser(userName); userInfo.setModifyUser(userName);
userInfo.setModifyDatetime(TimeTool.getNowTime(true)); userInfo.setModifyDatetime(TimeTool.getNowTime(true));
userInfoRDao.update(organize); sysUserInfoRDao.update(organize);
} }
}else { }else {
throw ImppExceptionBuilder.newInstance() throw ImppExceptionBuilder.newInstance()
@ -196,35 +196,35 @@ public class SysUserInfoService implements ISysUserInfoService {
@Override @Override
public void deleteSysUserInfoById(Long id) { public void deleteSysUserInfoById(Long id) {
LOGGER.info("用户信息 SysUserInfo id:{}",id); LOGGER.info("用户信息 SysUserInfo id:{}",id);
userInfoRDao.deleteById(id); sysUserInfoRDao.deleteById(id);
} }
@Override @Override
public void deleteSysUserInfoByIds(Long[] ids) { public void deleteSysUserInfoByIds(Long[] ids) {
LOGGER.info("用户信息 SysUserInfo ids:{}",ids); LOGGER.info("用户信息 SysUserInfo ids:{}",ids);
userInfoRDao.deleteByIds(ids); sysUserInfoRDao.deleteByIds(ids);
} }
@Override @Override
public SysUserInfo getSysUserInfoById(Long id) { public SysUserInfo getSysUserInfoById(Long id) {
return userInfoRDao.getById(id); return sysUserInfoRDao.getById(id);
} }
@Override @Override
public List listSysUserInfo() { public List listSysUserInfo() {
return userInfoRDao.findAll(); return sysUserInfoRDao.findAll();
} }
@Override @Override
public ListPager<SysUserInfo> querySysUserInfo(SysUserInfo userInfo, Pager pager) { public ListPager<SysUserInfo> querySysUserInfo(SysUserInfo userInfo, Pager pager) {
LOGGER.info("定时任务 TASK_TIME TaskTime:{}Pager:{}",userInfo,pager); LOGGER.info("定时任务 TASK_TIME TaskTime:{}Pager:{}",userInfo,pager);
if(userInfo == null) { if(userInfo == null) {
pager = PagerHelper.getPager(pager, userInfoRDao.listCount()); pager = PagerHelper.getPager(pager, sysUserInfoRDao.listCount());
return new ListPager(userInfoRDao.listPager(pager),pager); return new ListPager(sysUserInfoRDao.listPager(pager),pager);
}else { }else {
String hqlPack = CoreHqlPack.packHqlSysUserInfo(userInfo); String hqlPack = CoreHqlPack.packHqlSysUserInfo(userInfo);
pager = PagerHelper.getPager(pager, userInfoRDao.findByHqlWhereCount(hqlPack)); pager = PagerHelper.getPager(pager, sysUserInfoRDao.findByHqlWhereCount(hqlPack));
return new ListPager(userInfoRDao.findByHqlWherePage(hqlPack + userInfo.orderBy(),pager),pager); return new ListPager(sysUserInfoRDao.findByHqlWherePage(hqlPack + userInfo.orderBy(),pager),pager);
} }
} }
} }

@ -24,6 +24,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashSet;
import java.util.List; import java.util.List;
/** /**
@ -65,6 +66,12 @@ public class SysUserService implements ISysUserService {
@Autowired @Autowired
private SysFileRepository sysFileRDao; private SysFileRepository sysFileRDao;
@Autowired
private SysDepartmentRepository sysDepartmentRDao;
@Autowired
private SysPositionRepository sysPositionRDao;
@Override @Override
public SessionUser queryUserLogin(String loginName, String password, String languageCode) throws AuthenticationException { public SessionUser queryUserLogin(String loginName, String password, String languageCode) throws AuthenticationException {
LOGGER.debug("平台用户 SYS_USER loginName:{} \t password:{} \t languageCode:{}", loginName, password, languageCode); LOGGER.debug("平台用户 SYS_USER loginName:{} \t password:{} \t languageCode:{}", loginName, password, languageCode);
@ -388,17 +395,14 @@ public class SysUserService implements ISysUserService {
* @return * @return
*/ */
public void packSysUserDepartment(SessionUser sessionUser, SysUserInfo userInfo){ public void packSysUserDepartment(SessionUser sessionUser, SysUserInfo userInfo){
List<SysDepartment> list = null;
try { try {
LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId()); LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId());
userInfo.setDepartmentList(userPermissionDao.findDepartmentByUser(userInfo));
list = userPermissionDao.findDepartmentByUser(userInfo); userInfo.setDepartment(sysDepartmentRDao.getById(userInfo.getDepartmentId()));
}catch (Exception e){ }catch (Exception e){
LOGGER.error(" SysUser Peck Department information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage()); LOGGER.error(" SysUser Peck Department information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
userInfo.setDepartmentList(list);
sessionUser.setUserInfo(userInfo);
} }
/** /**
@ -408,17 +412,14 @@ public class SysUserService implements ISysUserService {
* @return * @return
*/ */
public void packSysUserPosition(SessionUser sessionUser, SysUserInfo userInfo){ public void packSysUserPosition(SessionUser sessionUser, SysUserInfo userInfo){
List<SysPosition> list = null;
try { try {
LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId()); LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId());
userInfo.setPositionList(userPermissionDao.findPositionByUser(userInfo));
list = userPermissionDao.findPositionByUser(userInfo); userInfo.setPosition(sysPositionRDao.getById(userInfo.getPositionId()));
}catch (Exception e){ }catch (Exception e){
LOGGER.error(" SysUser Peck Position information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage()); LOGGER.error(" SysUser Peck Position information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage());
e.printStackTrace(); e.printStackTrace();
} }
userInfo.setPositionList(list);
sessionUser.setUserInfo(userInfo);
} }
/** /**
@ -428,17 +429,25 @@ public class SysUserService implements ISysUserService {
* @return * @return
*/ */
public void packSysUserOrganize(SessionUser sessionUser, SysUserInfo userInfo){ public void packSysUserOrganize(SessionUser sessionUser, SysUserInfo userInfo){
SysOrganize organize = null;
try { try {
LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId()); LOGGER.debug("平台用户 SYS_USER user id :{}", userInfo.getId());
userInfo.setOrganize(organizeRDao.getById(userInfo.getOrganizeId()));
List<SysDepartment> departmentList = userInfo.getDepartmentList();
if(departmentList != null && departmentList.size() > 0){
Long[] ids = new Long[departmentList.size()];
for (int i = 0; i < departmentList.size(); i++) {
ids[i] = departmentList.get(i).getOrganizeId();
}
String hqlWhere = CoreHqlPack.packHqlIds("id", ids);
List<SysOrganize> organizeList = organizeRDao.findByHqlWhere(hqlWhere);
organize = organizeRDao.getById(userInfo.getOrganizeId()); userInfo.setOrganizeList(organizeList);
}
}catch (Exception e){ }catch (Exception e){
LOGGER.error(" SysUser Peck Organize information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage()); LOGGER.error(" SysUser Peck Organize information Error userId : {} Exception Message : {} " ,userInfo.getId(),e.getMessage());
e.printStackTrace();
} }
userInfo.setOrganize(organize);
sessionUser.setUserInfo(userInfo);
} }

@ -1,16 +1,18 @@
package cn.estsh.i3plus.core.apiservice.util; package cn.estsh.i3plus.core.apiservice.util;
import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil; import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.core.io.support.PropertiesLoaderUtils; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.mail.*; import javax.mail.*;
import javax.mail.internet.AddressException; import javax.mail.internet.AddressException;
import javax.mail.internet.InternetAddress; import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage; import javax.mail.internet.MimeMessage;
import javax.mail.internet.MimeUtility; import javax.mail.internet.MimeUtility;
import java.io.IOException;
import java.io.UnsupportedEncodingException; import java.io.UnsupportedEncodingException;
import java.util.Properties; import java.util.Properties;
@ -21,6 +23,7 @@ import java.util.Properties;
* @CreateDate : 2018-11-14 19:24 * @CreateDate : 2018-11-14 19:24
* @Modify: * @Modify:
**/ **/
@Component
public class MailUtil { public class MailUtil {
public static final Logger LOGGER = LoggerFactory.getLogger(MailUtil.class); public static final Logger LOGGER = LoggerFactory.getLogger(MailUtil.class);
@ -39,21 +42,20 @@ public class MailUtil {
private String smtpPassword = ""; private String smtpPassword = "";
private boolean isAuthenticationSMTP = false; private boolean isAuthenticationSMTP = false;
@Autowired
private ISysConfigService sysConfigService;
//初始化服务器邮箱参数 //初始化服务器邮箱参数
public MailUtil() { public MailUtil init() {
try { this.smtpHost = sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_HOST).getConfigValue();
Properties mailInfo = PropertiesLoaderUtils.loadAllProperties("mail.properties"); this.smtpPort = Integer.parseInt(sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_PORT).getConfigValue());
this.smtpHost = mailInfo.get("mail.host").toString(); this.from = sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_USER).getConfigValue();
this.smtpPort = Integer.parseInt(mailInfo.get("mail.port").toString()); this.nick = sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_NICK).getConfigValue();
this.from = mailInfo.get("mail.user") + ""; this.smtpUser = sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_USER).getConfigValue();
this.nick = mailInfo.get("mail.nick") + ""; this.smtpPassword = sysConfigService.getSysConfigByCode(PlatformConstWords.MAIL_PASSWORD).getConfigValue();
this.smtpUser = mailInfo.get("mail.user") + ""; this.isAuthenticationSMTP = true;
this.smtpPassword = mailInfo.get("mail.password") + "";
this.isAuthenticationSMTP = true; return this;
} catch (IOException e) {
e.printStackTrace();
}
} }
/** /**

@ -0,0 +1,59 @@
package cn.estsh.i3plus.core.apiservice.util;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysOrderNoRule;
import java.text.MessageFormat;
import java.text.SimpleDateFormat;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-21 13:26
* @Modify:
**/
public class OrderNoMakeUtil {
public static SysOrderNoRule next(SysOrderNoRule orderNoRule) {
StringBuilder orderNo = new StringBuilder(orderNoRule.getOrderNoRule());
String[] dateTime = new SimpleDateFormat("yyyy-MM-dd-HH-mm-ss").format(System.currentTimeMillis()).split("-");
replace(orderNo, PlatformConstWords.YEAR, dateTime[0]);
replace(orderNo, PlatformConstWords.MONTH, dateTime[1]);
replace(orderNo, PlatformConstWords.DAY, dateTime[2]);
replace(orderNo, PlatformConstWords.HOUR, dateTime[3]);
replace(orderNo, PlatformConstWords.MINUTE, dateTime[4]);
replace(orderNo, PlatformConstWords.SECOND, dateTime[5]);
// 流水号长度补全
String serialNumberFormatStr = MessageFormat.format(PlatformConstWords.SERIAL_NO_FORMAT, orderNoRule.getSerialNoLength());
if (orderNoRule.getLastMakeSerialNo() > 0) {
int serialNo = orderNoRule.getLastMakeSerialNo() + orderNoRule.getSerialNoIncrement();
// 达到最大值后循环或继续
if(orderNoRule.getSerialNoLength().intValue() < String.valueOf(serialNo).length()
&& orderNoRule.getIsCycle() == CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()){
orderNoRule.setLastMakeSerialNo(orderNoRule.getSerialNoSeed());
} else {
orderNoRule.setLastMakeSerialNo(orderNoRule.getLastMakeSerialNo() + orderNoRule.getSerialNoIncrement());
}
} else {
orderNoRule.setLastMakeSerialNo(orderNoRule.getSerialNoSeed());
}
replace(orderNo, PlatformConstWords.SERIAL_NO, String.format(serialNumberFormatStr, orderNoRule.getLastMakeSerialNo()));
orderNoRule.setLastMakeOrderNo(orderNo.toString());
return orderNoRule;
}
private static StringBuilder replace(StringBuilder no, String constant, String param) {
int day = no.indexOf(constant);
if (day != -1) {
no.replace(day, day + constant.length(), param);
}
return no;
}
}

@ -1,6 +1,7 @@
package cn.estsh.i3plus.core.apiservice.mq; package cn.estsh.i3plus.core.apiservice.mq;
import cn.estsh.i3plus.core.apiservice.serviceimpl.busi.TestBase; 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.base.enumutil.ImppEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysMessage; import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import org.junit.Test; import org.junit.Test;
@ -14,7 +15,7 @@ import org.springframework.beans.factory.annotation.Autowired;
* @CreateDate : 2018-11-15 13:22 * @CreateDate : 2018-11-15 13:22
* @Modify: * @Modify:
**/ **/
public class MailUtil extends TestBase { public class TestMQ extends TestBase {
/** /**
* rabbitMQ * rabbitMQ
@ -22,6 +23,9 @@ public class MailUtil extends TestBase {
@Autowired @Autowired
private RabbitTemplate rabbitTemplate; private RabbitTemplate rabbitTemplate;
@Autowired
private MailUtil mailUtil;
@Test @Test
public void sendMail() throws InterruptedException { public void sendMail() throws InterruptedException {
@ -42,4 +46,5 @@ public class MailUtil extends TestBase {
} }
} }
} }

@ -1,5 +1,6 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi; package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService;
import cn.estsh.impp.framework.boot.init.ApplicationProperties; import cn.estsh.impp.framework.boot.init.ApplicationProperties;
import org.junit.After; import org.junit.After;
import org.junit.Before; import org.junit.Before;
@ -27,6 +28,9 @@ public class TestBase {
@Autowired @Autowired
private ApplicationProperties app; private ApplicationProperties app;
@Autowired
private ISysConfigService sysConfigService;
@Before @Before
public void init() { public void init() {
System.out.println("-----------------开始测试-----------------"); System.out.println("-----------------开始测试-----------------");

@ -0,0 +1,261 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.platform.common.tool.EncryptTool;
import cn.estsh.i3plus.pojo.platform.bean.*;
import cn.estsh.i3plus.pojo.platform.repository.*;
import com.alibaba.fastjson.JSON;
import io.swagger.models.auth.In;
import org.apache.poi.ss.usermodel.Row;
import org.apache.poi.ss.usermodel.Workbook;
import org.apache.poi.ss.usermodel.WorkbookFactory;
import org.apache.poi.xssf.usermodel.XSSFSheet;
import org.apache.poi.xssf.usermodel.XSSFWorkbook;
import org.jdom2.Document;
import org.jdom2.JDOMException;
import org.jdom2.input.SAXBuilder;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
/**
*
*/
public class TestExcelPermission extends TestBase {
//public class TestExcelPermission {
public static final Logger LOGGER = LoggerFactory.getLogger(TestExcelPermission.class);
// 文件路径
public static final String PATH_NAME = "init/permission.xlsx";
// 权限Sheet 名称
public static final String SHEET_NAME_MENU = "menu";
public static final String SHEET_NAME_ROLE = "role";
public static final String SHEET_NAME_USER_INFO = "user-info";
public static final String SHEET_NAME_USER = "user";
@Autowired
private SysUserRepository sysUserRdao;
@Autowired
private SysUserInfoRepository userInfoRDao;
@Autowired
private SysMenuRepository menuRdao;
@Autowired
private SysRoleRepository roleRDao;
@Autowired
private SysRefRoleMenuRepository refRoleMenuRDao;
@Test
public void testInit() throws Exception {
XSSFWorkbook workbook = getWorkbook(PATH_NAME);
if(workbook != null){
XSSFSheet sheetMenu = workbook.getSheet(SHEET_NAME_MENU);
XSSFSheet sheetRole = workbook.getSheet(SHEET_NAME_ROLE);
XSSFSheet sheetUserInfo = workbook.getSheet(SHEET_NAME_USER_INFO);
XSSFSheet sheetUser = workbook.getSheet(SHEET_NAME_USER);
List<SysMenu> menus = getSysMenu(sheetMenu);
List<SysRole> roles = getSysRole(sheetRole);
List<SysUserInfo> userInfos = getSysUserInfo(sheetUserInfo);
List<SysUser> users = getSysUser(sheetUser);
List<SysRefRoleMenu> refRoleMenu = getRefRoleMenu(menus, roles);
LOGGER.info("System Init SysMenu Size:{}",menus.size());
LOGGER.info("System Init SysRole Size:{}",roles.size());
LOGGER.info("System Init SysUserInfo Size:{}",userInfos.size());
LOGGER.info("System Init SysUser Size:{}",users.size());
LOGGER.info("System Init SysRefRoleMenu Size:{}",refRoleMenu.size());
sysUserRdao.saveAll(users);
userInfoRDao.saveAll(userInfos);
menuRdao.saveAll(menus);
roleRDao.saveAll(roles);
refRoleMenuRDao.saveAll(refRoleMenu);
}
}
public List<SysRefUserRole> getRefUserRole(List<SysUser> users,List<SysRole> roles){
List<SysRefUserRole> result = new ArrayList<>();
if(users != null && roles != null){
SysRefUserRole ref = null;
for (SysUser user : users) {
for (SysRole role : roles) {
ref = new SysRefUserRole();
ref.setRoleId(role.getId());
ref.setRoleNameRdd(role.getName());
ref.setUserId(user.getId());
ref.setUserNameRdd(user.getUserName());
result.add(ref);
}
}
}
return result;
}
public List<SysRefRoleMenu> getRefRoleMenu(List<SysMenu> menus,List<SysRole> roles){
List<SysRefRoleMenu> result = new ArrayList<>();
if(menus != null && roles != null){
SysRefRoleMenu ref = null;
for (SysMenu menu : menus) {
for (SysRole role : roles) {
ref = new SysRefRoleMenu();
ref.setRoleId(role.getId());
ref.setRoleNameRdd(role.getName());
ref.setMenuId(menu.getId());
ref.setMenuNameRdd(menu.getName());
ref.setMenuTypeRdd(menu.getMenuType());
result.add(ref);
}
}
}
return result;
}
public List<SysUser> getSysUser(XSSFSheet sheet){
List<SysUser> result = new ArrayList<>();
if(sheet != null){
if(sheet.getLastRowNum() >= 1){
SysUser obj = null;
for (int i = 1; i <= sheet.getLastRowNum(); i++) {
try {
Row row = sheet.getRow(i);//获取索引为i的行以0开始
if(row.getCell(0).toString().trim().length() > 0){
obj = new SysUser();
String md5 = EncryptTool.hexMD5(row.getCell(2).toString());
obj.setId(Long.parseLong(row.getCell(0).getStringCellValue()));
obj.setUserLoginName(row.getCell(1).getStringCellValue());
obj.setUserLoginPassword(md5);
obj.setUserEmail(row.getCell(3).getStringCellValue());
obj.setUserPhone(row.getCell(4).getStringCellValue());
obj.setUserInfoId(Long.parseLong(row.getCell(5).getStringCellValue()));
obj.setUserName(row.getCell(6).getStringCellValue());
obj.setIsValid(1);
obj.setUserType(1);
obj.setUserLoginNum(0);
result.add(obj);
}
}catch (Exception e){
LOGGER.error("Excel Sheet Name :{} Index:{} DataType Error", sheet.getSheetName(), i);
}
}
}
}
return result;
}
public List<SysUserInfo> getSysUserInfo(XSSFSheet sheet){
List<SysUserInfo> result = new ArrayList<>();
if(sheet != null){
if(sheet.getLastRowNum() >= 1){
SysUserInfo obj = null;
for (int i = 1; i <= sheet.getLastRowNum(); i++) {
try {
Row row = sheet.getRow(i);//获取索引为i的行以0开始
if(row.getCell(0).toString().trim().length() > 0){
obj = new SysUserInfo();
obj.setId(Long.parseLong(row.getCell(0).getStringCellValue()));
obj.setName(row.getCell(1).getStringCellValue());
obj.setUserEmpNo(row.getCell(2).getStringCellValue());
obj.setUserLoginNum(0);
obj.setIsValid(1);
result.add(obj);
}
}catch (Exception e){
LOGGER.error("Excel Sheet Name :{} Index:{} DataType Error", sheet.getSheetName(), i);
}
}
}
}
return result;
}
public List<SysRole> getSysRole(XSSFSheet sheet){
List<SysRole> result = new ArrayList<>();
if(sheet != null){
if(sheet.getLastRowNum() >= 1){
SysRole role = null;
for (int i = 1; i <= sheet.getLastRowNum(); i++) {
try {
Row row = sheet.getRow(i);//获取索引为i的行以0开始
if(row.getCell(0).toString().trim().length() > 0){
role = new SysRole();
role.setId(Long.parseLong(row.getCell(0).getStringCellValue()));
role.setName(row.getCell(1).getStringCellValue());
role.setRoleDescription(row.getCell(2).getStringCellValue());
result.add(role);
}
}catch (Exception e){
LOGGER.error("Excel Sheet Name :{} Index:{} DataType Error", sheet.getSheetName(), i);
}
}
}
}
return result;
}
public List<SysMenu> getSysMenu(XSSFSheet sheet){
List<SysMenu> result = new ArrayList<>();
if(sheet != null){
if(sheet.getLastRowNum() >= 1){
SysMenu menu = null;
for (int i = 1; i <= sheet.getLastRowNum(); i++) {
try {
Row row = sheet.getRow(i);//获取索引为i的行以0开始
if(row.getCell(0).toString().trim().length() > 0){
menu = new SysMenu();
menu.setId(Long.parseLong(row.getCell(0).getStringCellValue()));
menu.setMenuType(Integer.parseInt(row.getCell(1).getStringCellValue()));
menu.setMenuCode(row.getCell(2).getStringCellValue());
menu.setName(row.getCell(3).getStringCellValue());
menu.setParentId(Long.parseLong(row.getCell(4).getStringCellValue()));
menu.setParentNameRdd(row.getCell(5).getStringCellValue());
menu.setMenuDescription(row.getCell(6).getStringCellValue());
menu.setMenuStatus(Integer.parseInt(row.getCell(7).getStringCellValue()));
menu.setCreateUser("System Init");
menu.setMenuUrl(row.getCell(9).getStringCellValue());
menu.setMenuCss(row.getCell(10).getStringCellValue());
menu.setMenuIcon(row.getCell(11).getStringCellValue());
result.add(menu);
}
}catch (Exception e){
LOGGER.error("Excel Sheet Name :{} Index:{} DataType Error", sheet.getSheetName(), i);
}
}
}
}
return result;
}
public XSSFWorkbook getWorkbook(String pathName){
try {
InputStream in = TestExcelPermission.class.getClassLoader().getResourceAsStream(pathName);
XSSFWorkbook workbook = new XSSFWorkbook(in);
return workbook;
}catch (Exception e){
LOGGER.error(" System Init Sys Data Excel Error file path {} error message :{}",pathName,e.getMessage());
e.getMessage();
return null;
}
}
}

@ -1,111 +0,0 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.*;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.*;
import com.alibaba.fastjson.JSON;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import javax.transaction.Transactional;
/**
*
*/
public class TestInitData extends TestBase {
@Autowired
private IOrganizeService organizeService;
@Autowired
private IPositionService positionService;
@Autowired
private IDepartmentService departmentService;
@Autowired
private ISysMenuService sysMenuService;
@Autowired
private ISysRoleService sysRoleService;
@Autowired
private ISysUserService sysUserService;
@Autowired
private ISysUserInfoService sysUserInfoService;
@Test
@Transactional
public void testInitPosition(){
}
@Test
@Transactional
public void testInitOrganize(){
}
@Test
@Transactional
public void testInitDepartment(){
}
@Test
@Transactional
public void testInitSysRole(){
}
@Test
@Transactional
public void testInitSysUser()throws Exception{
Organize organize = new Organize();
organize.setName("Junit 组织");
organize.setOrganizeTypeId(ImppEnumUtil.ORGANIZE_YTPE.TYPE_COMPANY.getValue());
organize.setOrganizeCode("junit 001");
Organize insertOrganize = organizeService.insertOrganize(organize);
System.out.println(JSON.toJSON(insertOrganize));
Department department = new Department();
department.setName("Junit 部门");
department.setDepartmentCode("junit 001");
department.setOrganizeId(insertOrganize.getId());
Department insertDepartment = departmentService.insertDepartment(department);
System.out.println(JSON.toJSON(insertDepartment));
Position position = new Position();
position.setName("Junit 岗位");
position.setPositionCode("junit 001");
Position insertPosition = positionService.insertPosition(position);
System.out.println(JSON.toJSON(insertPosition));
SysUserInfo info = new SysUserInfo();
info.setName("Junit 用户");
info.setOrganizeId(insertOrganize.getId());
info.setDepartmentId(insertDepartment.getId());
info.setPositionId(insertPosition.getId());
SysUserInfo insertSysUserInfo = sysUserInfoService.insertSysUserInfo(info);
SysRole role = new SysRole();
role.setName("Junit 角色");
SysRole insertSysRole = sysRoleService.insertSysRole(role);
System.out.println(JSON.toJSON(insertSysRole));
SysUser user = new SysUser();
user.setUserLoginName("root");
user.setUserLoginPassword("root");
user.setUserInfoId(insertSysUserInfo.getId());
user.setRoleId(insertSysRole.getId());
SysUser sysUser = sysUserService.insertSysUser(user);
System.out.println(JSON.toJSON(sysUser));
}
}

@ -1,102 +1,102 @@
//package cn.estsh.i3plus.core.apiservice.serviceimpl.busi; package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
//
//import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService; import cn.estsh.i3plus.core.api.iservice.busi.ISysConfigService;
//import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.bean.ListPager;
//import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.common.Pager;
//import cn.estsh.i3plus.pojo.platform.bean.SysConfig; import cn.estsh.i3plus.pojo.platform.bean.SysConfig;
//import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSON;
//import org.junit.Test; import org.junit.Test;
//import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.test.annotation.Rollback; import org.springframework.test.annotation.Rollback;
//
//import javax.transaction.Transactional; import javax.transaction.Transactional;
//import java.util.List; import java.util.List;
//
///** /**
// * @Description : 系统参数服务测试 * @Description :
// * @Reference : * @Reference :
// * @Author : yunhao * @Author : yunhao
// * @Date : 2018-10-30 10:49 * @Date : 2018-10-30 10:49
// * @Modify : * @Modify :
// **/ **/
//public class TestSysConfigService extends TestBase { public class TestSysConfigService extends TestBase {
//
// @Autowired @Autowired
// private ISysConfigService sysConfigService; private ISysConfigService sysConfigService;
//
// /** /**
// * 测试 查询所有系统参数 *
// */ */
// @Test @Test
// @Transactional @Transactional
// public void testListSysConfig() { public void testListSysConfig() {
// List list = sysConfigService.ListSysConfig(); List list = sysConfigService.ListSysConfig();
// System.out.println(JSON.toJSONString(list)); System.out.println(JSON.toJSONString(list));
// } }
//
// /** /**
// * 测试 根据id查询系统参数 * id
// */ */
// @Test @Test
// @Transactional @Transactional
// public void testGetSysConfigById() { public void testGetSysConfigById() {
// SysConfig sysConfig = sysConfigService.getSysConfigById("1057110061127700480"); SysConfig sysConfig = sysConfigService.getSysConfigById(1057110061127700480L);
// System.out.println(JSON.toJSONString(sysConfig)); System.out.println(JSON.toJSONString(sysConfig));
// } }
//
// /** /**
// * 测试 添加系统参数 *
// */ */
// @Test @Test
// @Transactional @Transactional
// @Rollback(false) @Rollback(false)
// public void testInsertSysConfig() { public void testInsertSysConfig() {
// SysConfig sysConfig = new SysConfig(); SysConfig sysConfig = new SysConfig();
// sysConfig.setName("系统名称"); sysConfig.setName("系统名称");
// sysConfig.setConfigCode("sys_name"); sysConfig.setConfigCode("sys_name");
// sysConfig.setConfigTypeId(1); sysConfig.setConfigType(1);
// sysConfig.setConfigValue("IMPP"); sysConfig.setConfigValue("IMPP");
// sysConfig.setConfigDescription("系统名称"); sysConfig.setConfigDescription("系统名称");
//
// sysConfigService.insertSysConfig(sysConfig); sysConfigService.insertSysConfig(sysConfig);
// System.out.println(JSON.toJSONString(sysConfig)); System.out.println(JSON.toJSONString(sysConfig));
//
// } }
//
// /** /**
// * 测试 修改系统参数 *
// */ */
// @Test @Test
// @Transactional @Transactional
// public void testUpdateSysConfig(){ public void testUpdateSysConfig(){
// SysConfig sysConfig = sysConfigService.getSysConfigById("1057110613261684736"); SysConfig sysConfig = sysConfigService.getSysConfigById(1057110613261684736L);
// sysConfig.setConfigDescription("测试修改"); sysConfig.setConfigDescription("测试修改");
//
// sysConfigService.updateSysConfig(sysConfig); sysConfigService.updateSysConfig(sysConfig);
// } }
//
// /** /**
// * 测试 根据id删除系统参数 * id
// */ */
// @Test @Test
// @Transactional @Transactional
// public void testDeleteSysConfigById(){ public void testDeleteSysConfigById(){
// sysConfigService.deleteSysConfigById("1057111616417566720"); sysConfigService.deleteSysConfigById(1057111616417566720L);
// } }
//
// /** /**
// * 测试 复制查询 *
// */ */
// @Test @Test
// @Transactional @Transactional
// public void testQuerySysConfigByPager(){ public void testQuerySysConfigByPager(){
// SysConfig sysConfig = new SysConfig(); SysConfig sysConfig = new SysConfig();
//
// Pager pager = new Pager(); Pager pager = new Pager();
// pager.setPageSize(10); pager.setPageSize(10);
// pager.setCurrentPage(1); pager.setCurrentPage(1);
//
// ListPager list = sysConfigService.querySysConfigByPager(sysConfig,pager); ListPager list = sysConfigService.querySysConfigByPager(sysConfig,pager);
// System.out.println(list); System.out.println(list);
// } }
//} }

@ -0,0 +1,29 @@
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_CONTENT_TYPE.HTML.getDescription());
mailUtil.setBody("内容");
mailUtil.send();
}
}

@ -0,0 +1,33 @@
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(1);
sysOrderNoRule.setSerialNoIncrement(1);
sysOrderNoRule.setSerialNoLength(4);
sysOrderNoRule.setLastMakeSerialNo(9999);
sysOrderNoRule.setIsCycle(1);
System.out.println(OrderNoMakeUtil.next(sysOrderNoRule));
// String d= MessageFormat.format("%0{0}d", 3);
// System.out.println(d);
}
}

@ -182,6 +182,17 @@
<artifactId>mail</artifactId> <artifactId>mail</artifactId>
<version>1.4.7</version> <version>1.4.7</version>
</dependency> </dependency>
<!-- Java Excel -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>RELEASE</version>
</dependency>
</dependencies> </dependencies>
</dependencyManagement> </dependencyManagement>

Loading…
Cancel
Save