Merge remote-tracking branch 'remotes/origin/dev' into test

# Conflicts:
#	modules/i3plus-ics-gateway/src/main/resources/application-test.properties
#	modules/i3plus-ics-regist/i3plus-ics-regist.iml
返回提示修改
报表打印修改
yun-zuoyi
wei.peng 6 years ago
commit 9026617500

@ -0,0 +1,72 @@
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.SysBarcodeRule;
import io.swagger.annotations.ApiOperation;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-03-12 16:01
* @Modify:
**/
public interface ISysBarcodeRuleService {
/**
*
* @param barcodeRule
*/
@ApiOperation(value = "新增条码规则信息")
SysBarcodeRule insertSysBarcodeRule(SysBarcodeRule barcodeRule);
/**
*
* @param barcodeRule
*/
@ApiOperation(value = "更新条码规则信息")
void updateSysBarcodeRule(SysBarcodeRule barcodeRule);
/**
*
* @return
*/
@ApiOperation(value = "查询所有条码规则信息",notes = "查询所有条码规则信息")
List<SysBarcodeRule> listSysBarcodeRule();
/**
* id
* @param id
* @return
*/
@ApiOperation(value = "查询条码规则信息",notes = "根据ID查询条码规则信息")
SysBarcodeRule getSysBarcodeRuleById(Long id);
/**
* id
* @param id
* @return
*/
@ApiOperation(value = "根据id删除条码规则",notes = "根据id删除条码规则")
void deleteSysBarcodeRuleById(Long id);
/**
*
* @param code
* @return
*/
@ApiOperation(value = "根据规则代码查询条码规则",notes = "根据规则代码查询条码规则")
SysBarcodeRule getSysBarcodeRuleByCode(String code);
/**
*
* @param barcodeRule
* @param pager
* @return
*/
@ApiOperation(value = "根据规则代码查询条码规则",notes = "根据规则代码查询条码规则")
ListPager<SysBarcodeRule> querySysBarcodeRuleByPager(SysBarcodeRule barcodeRule, Pager pager);
}

@ -53,12 +53,12 @@ public interface ISysDictionaryService {
SysDictionary getSysDictionaryById(Long id);
/**
*
*
* @param parentCode
* @return
*/
@ApiOperation(value = "根据父级代码查询字典项信息")
List<SysDictionary> findSysDictionaryByParentCode(String parentCode);
@ApiOperation(value = "根据微服务与父级代码查询字典项")
List<SysDictionary> findSysDictionaryBySoftTypeAndParentCode(Integer softType,String parentCode);
/**
*

@ -0,0 +1,75 @@
package cn.estsh.i3plus.core.api.iservice.busi;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.model.platform.LabelTemplateModel;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplate;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplateParam;
import io.swagger.annotations.ApiOperation;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : siliter
* @Date : 2019-03-18 9:25
* @Modify :
**/
public interface ISysLabelTemplateService {
/**
*
* @param sysLabelTemplate
*/
@ApiOperation(value = "添加打印模板")
void insertSysLabelTemplate(SysLabelTemplate sysLabelTemplate);
/**
*
* @param id
*/
@ApiOperation(value = "删除打印模板")
void deleteSysLabelTemplateById(Long id);
/**
*
* @param sysLabelTemplate
*/
@ApiOperation(value = "修改打印模板")
void updateSysLabelTemplate(SysLabelTemplate sysLabelTemplate);
/**
*
*/
@ApiOperation(value = "查询全部打印模板")
List<SysLabelTemplate> ListSysLabelTemplate();
/**
* id
* @param id
*/
@ApiOperation(value = "根据id查询打印模板")
SysLabelTemplate getSysLabelTemplateById(Long id);
/**
*
* @param sysLabelTemplate
* @param pager
* @return
*/
@ApiOperation(value = "打印模板复杂查询分页排序")
ListPager querySysLabelTemplateByPager(SysLabelTemplate sysLabelTemplate, Pager pager);
/**
*
*/
@ApiOperation(value = "根据模板编号查询模板参数")
List<SysLabelTemplateParam> listSysLabelTemplateParam(String labelTemplateId);
/**
*
*/
@ApiOperation(value = "根据模板编号查询模板信息")
LabelTemplateModel getLabelTemplateInfoById(String labelTemplateId);
}

@ -24,6 +24,9 @@ public interface ISysMessageService {
@ApiOperation(value = "添加消息")
SysMessage insertSysMessage(SysMessage sysMessage);
@ApiOperation(value = "添加消息")
List<SysMessage> insertSysMessage(List<SysMessage> sysMessage);
/**
*
* @param id
@ -77,6 +80,13 @@ public interface ISysMessageService {
SysRefUserMessage insertSysRefUserMessage(SysRefUserMessage refUserMessage);
/**
*
* @param refList
*/
@ApiOperation(value = "添加用户消息关系")
List<SysRefUserMessage> insertSysRefUserMessage(List<SysRefUserMessage> refList);
/**
*
* @param sysMessage
* @return

@ -46,7 +46,7 @@ public class DemoCloudController {
@GetMapping(value="/test")
@ApiOperation(value="core测试",notes = "core测试")
public BaseResultBean testCore(String test) {
LOGGER.info("{}{}【impp-core接受数据】{}",ipAddress,serverPort,test);
LOGGER.info("iWmsDemoCloud:{},ip:{},port:{}【impp-core接受数据】{}",iWmsDemoCloud,ipAddress,serverPort,test);
//return ResultBean.success("返回:" + test).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return BaseResultBean.buildBaseResultBean(true,"");
}
@ -54,7 +54,7 @@ public class DemoCloudController {
@GetMapping(value="/test-wms")
@ApiOperation(value="wms测试",notes = "wms测试")
public ResultBean testWms(String test) {
LOGGER.info("【{}{}impp-core接受数据 -> wms】{}",ipAddress,serverPort,test);
LOGGER.info("iWmsDemoCloud:{},ip:{},port:{}【impp-core接受数据】{}",iWmsDemoCloud,ipAddress,serverPort,test);
BaseResultBean result = iWmsDemoCloud.testWms(test);
if(result.isSuccess()){

@ -45,7 +45,7 @@ public class DemoExceptionController {
}else if(type == 2){
throw new SQLException("测试数据库异常");
}else {
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);

@ -103,7 +103,7 @@ public class DemoResourceController extends CoreBaseController {
//修改条件
ConvertBean.modelUpdate(lang,user);
systemResourceService.updateSysLocaleLanguage(lang);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep).build();
}catch(Exception e){
@ -173,7 +173,7 @@ public class DemoResourceController extends CoreBaseController {
SysLocaleResource res = systemResourceService.getSysLocaleResourceByLanguage(resourceType, langCode, resKey);
LOGGER.info("获取的资源:" + res);
return ResultBean.success("保存成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultObject(res);
}catch(ImppBusiException busExcep){
@ -221,7 +221,7 @@ public class DemoResourceController extends CoreBaseController {
SysUser user = userService.getSysUserById(key);
System.out.println("1==="+user.toString());
return ResultBean.success("保存成功");
return ResultBean.success("操作成功");
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -240,7 +240,7 @@ public class DemoResourceController extends CoreBaseController {
SysUserInfo userInfo = userInfoServicer.getSysUserInfoById(key);
System.out.println("2==="+userInfo.toString());
return ResultBean.success("保存成功");
return ResultBean.success("操作成功");
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -266,7 +266,7 @@ public class DemoResourceController extends CoreBaseController {
SysUserInfo userInfo = userInfoServicer.getSysUserInfoById(key);
// System.out.println("2==="+userInfo);
return ResultBean.success("保存成功");
return ResultBean.success("操作成功");
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -1,10 +1,13 @@
package cn.estsh.i3plus.core.apiservice.controller;
import cn.estsh.i3plus.icloud.wms.sdk.IWmsScheduleJobCloud;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.impp.framework.base.controller.CoreBaseController;
import cn.estsh.impp.framework.boot.util.ResultBean;
import cn.estsh.impp.framework.boot.quartz.IQuartzJobService;
import cn.estsh.impp.framework.boot.quartz.ScheduleTool;
import cn.estsh.impp.framework.boot.quartz.TaskInfo;
import cn.estsh.impp.framework.boot.util.ResultBean;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
@ -17,7 +20,7 @@ import org.springframework.web.bind.annotation.RestController;
import java.util.List;
/**
* @Description :
* @Description : demo
* @Reference :
* @Author : alwaysfrin
* @CreateDate : 2018-09-26 10:34
@ -33,74 +36,95 @@ public class DemoScheduleController extends CoreBaseController{
@Autowired
private ScheduleTool scheduleTool;
@Autowired
private IWmsScheduleJobCloud wmsScheduleJobCloud;
/**
*
* @param source CommonEnumUtil.SOFT_TYPE
* @return
*/
private IQuartzJobService getJobService(int source){
IQuartzJobService quartzJobService = scheduleTool;
if(source == CommonEnumUtil.SOFT_TYPE.CORE.getValue()){
//平台定时任务
quartzJobService = scheduleTool;
}else if(source == CommonEnumUtil.SOFT_TYPE.WMS.getValue()){
quartzJobService = wmsScheduleJobCloud;
}
return quartzJobService;
}
@GetMapping(value="/list-task")
@ApiOperation(value="查询定时任务",notes="查询所有定时任务")
public ResultBean listTask(){
List<TaskInfo> taskList = scheduleTool.queryJobList();
for(TaskInfo ti : taskList){
System.out.println(ti);
public ResultBean listTask(int sourceType){
List<TaskInfo> taskList = getJobService(sourceType).listTask().getResultList();
if(taskList != null) {
for (TaskInfo ti : taskList) {
LOGGER.info("任务:{}",ti);
}
}else{
LOGGER.info("任务列表为空");
}
return new ResultBean(true,"");
return new ResultBean(true,taskList);
}
@GetMapping(value="/add-task")
@ApiOperation(value="添加定时任务",notes="添加定时任务")
public ResultBean addTask(String packageName,String className,String jobName,String jobGroup,String cronExpression){
//String packageName = "cn.estsh.impp.framework.boot.quartz.job";
//String className = "ImppJob";
scheduleTool.addJob(new TaskInfo(packageName,className,jobName,jobGroup,cronExpression,"测试任务"));
public ResultBean addTask(int sourceType,
String packageName,String className,String jobName,String jobGroup,String cronExpression){
this.getJobService(sourceType).addTask(packageName,className,jobName,jobGroup,cronExpression,"wms新任务");
return new ResultBean(true,"");
}
@GetMapping(value="/delete-task")
@ApiOperation(value="删除定时任务",notes="删除定时任务")
public ResultBean deleteTask(String jobName,String jobGroup){
scheduleTool.deleteJob(jobName,jobGroup);
public ResultBean deleteTask(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).deleteTask(jobName,jobGroup);
return new ResultBean(true,"");
return new ResultBean(true);
}
@GetMapping(value="/pause-task")
@ApiOperation(value="暂停定时任务",notes="暂停定时任务")
public ResultBean pauseJob(String jobName,String jobGroup){
scheduleTool.pauseJob(jobName,jobGroup);
public ResultBean pauseJob(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).pauseJob(jobName,jobGroup);
return new ResultBean(true,"");
return new ResultBean(true);
}
@GetMapping(value="/resume-task")
@ApiOperation(value="继续定时任务",notes="继续定时任务")
public ResultBean resumeJob(String jobName,String jobGroup){
scheduleTool.resumeJob(jobName,jobGroup);
public ResultBean resumeJob(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).resumeJob(jobName,jobGroup);
return new ResultBean(true,"");
return new ResultBean(true);
}
@GetMapping(value="/exceute-task")
@GetMapping(value="/execeute-task")
@ApiOperation(value="立即执行定时任务",notes="立即执行定时任务")
public ResultBean excuteJob(String jobName,String jobGroup){
scheduleTool.executeJob(jobName,jobGroup);
public ResultBean executeJob(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).executeJob(jobName,jobGroup);
return new ResultBean(true,"");
return new ResultBean(true);
}
@GetMapping(value="/stand-by-schedule")
@ApiOperation(value="定时器待机",notes="定时器待机")
public ResultBean restartJob(String jobName,String jobGroup){
scheduleTool.standBySchedule();
public ResultBean restartJob(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).standBySchedule();
return new ResultBean(true,"");
return new ResultBean(true);
}
@GetMapping(value="/start-schedule")
@ApiOperation(value="启动定时器",notes="启动定时器")
public ResultBean startSchedule(String jobName,String jobGroup){
scheduleTool.startSchedule();
public ResultBean startSchedule(int sourceType,String jobName,String jobGroup){
this.getJobService(sourceType).startSchedule();
return new ResultBean(true,"");
return new ResultBean(true);
}
}

@ -1,6 +1,8 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
package cn.estsh.i3plus.core.apiservice.controller;
import cn.estsh.i3plus.core.api.iservice.busi.*;
import cn.estsh.i3plus.core.apiservice.controller.busi.ComputePi;
import cn.estsh.i3plus.core.apiservice.controller.busi.PersonnelController;
import cn.estsh.i3plus.platform.common.tool.TimeTool;
import cn.estsh.i3plus.pojo.base.bean.BaseBean;
import cn.estsh.i3plus.pojo.base.codemaker.SnowflakeIdMaker;
@ -31,10 +33,10 @@ import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import javax.persistence.EntityManager;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Random;
@ -50,8 +52,8 @@ import java.util.UUID;
@RestController
@Api(description = "IMPP性能测试")
@RequestMapping("/impp/white/sys-test")
public class TestController {
public static final Logger LOGGER = LoggerFactory.getLogger(TestController.class);
public class DemoTestingController {
public static final Logger LOGGER = LoggerFactory.getLogger(DemoTestingController.class);
String TEXT = "飓风黑兹尔是1954年大西洋飓风季期间造成死亡人数最多、经济损失最惨重的飓风。这场风暴夺走了海地多达1000人的生命然后又以四级飓风强度从南、北卡罗莱纳州边境附近袭击美国造成95人丧生。之后黑兹尔转变成温带风暴但仍然致使81人遇难其中大部分来自多伦多。由于风暴造成了重大人员伤亡和财产损失其名称“黑兹尔”因此从大西洋风暴命名名单上退役。黑兹尔摧毁了海地40%的咖啡树和50%的可可作物对当地经济的影响持续了数年之久。飓风在南、北卡罗莱纳州登陆冲击点附近的大部分海滨住宅被毁。气旋从北卡罗莱纳州沿大西洋海岸北上先后影响了弗吉尼亚州、西弗吉尼亚州、马里兰州、特拉华州、新泽西州、宾夕法尼亚州和纽约州产生的阵风时速有近160公里造成的经济损失高达3.08亿美元。多伦多市内及周边有许多溪流溢出导致严重的洪涝灾害。加拿大遭受的损失达到1.35亿加拿大元。由于缺少应对热带气旋的经验,加上风暴强度的保持时间异常之长,多伦多所受影响的严重程度是前所未有的";
@ -1053,10 +1055,78 @@ public class TestController {
public void MakeSql(String path,int page,int pageSize){
try {
for (int i = 0; i < page; i++) {
Text.printUsage(path,pageSize, i);
printSql(path,pageSize, i);
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static final String DATA_TEXT = "党的十八大提出倡导富强、民主、文明、和谐倡导自由、平等、公正、法治倡导爱国、敬业、诚信、友善积极培育和践行社会主义核心价值观。富强、民主、文明、和谐是国家层面的价值目标自由、平等、公正、法治是社会层面的价值取向爱国、敬业、诚信、友善是公民个人层面的价值准则这24个字是社会主义核心价值观的基本内容。";
/**
*
* @param path
* @param num
* @param index
* @throws IOException
*/
public static void printSql(String path, int num, int index) throws IOException {
File dir = new File(path+File.separator+"tool"+File.separator+"temp" + (index / 10));
if (!dir.exists()) {
System.out.println(dir.mkdirs());
}
File f = new File(path+File.separator+"tool"+File.separator+"temp" + (index / 10) + File.separator+"insert" + index + ".sql");
FileWriter fw = new FileWriter(f);
BufferedWriter out = new BufferedWriter(fw);
try {
SysTool sysTool;
StringBuffer sb;
SnowflakeIdMaker snf = new SnowflakeIdMaker();
for (int i = 0; i < num; i++) {
sb = new StringBuffer();
sb.append("insert into sys_tool (id,name,tool_type_name_rdd,tool_type_id,tool_ip,tool_port,tool_description) values ");
sysTool = new SysTool();
sysTool.setId(snf.nextId() + System.currentTimeMillis());
sysTool.setName(RandomStringUtils.random(10, DATA_TEXT));
sysTool.setToolTypeNameRdd(RandomStringUtils.random(10, DATA_TEXT));
sysTool.setToolTypeId(System.currentTimeMillis());
sysTool.setToolIp(RandomStringUtils.random(10, DATA_TEXT));
sysTool.setToolPort((int) (Math.random() * i));
sysTool.setToolDescription(RandomStringUtils.random(10, DATA_TEXT));
sysTool.setCreateDatetime(TimeTool.getNowTime(true));
sysTool.setModifyDatetime(TimeTool.getNowTime(true));
sb.append("(" + sysTool.getId() + ",'" + sysTool.getName() + "','" + sysTool.getToolTypeNameRdd() + "'," + sysTool.getToolTypeId() + ",'"
+ sysTool.getToolIp() + "'," + sysTool.getToolPort() + ",'" + sysTool.getToolDescription() + "');");
out.write(sb.toString());
}
} finally {
out.close();
}
}
}
class TestThread implements Runnable {
private Thread t;
private int piLength = 0;
public TestThread (int piLength){
this.piLength = piLength;
}
@Override
public void run() {
ComputePi.computePi(piLength);
}
public void start () {
if (t == null) {
t = new Thread (this);
t.start ();
}
}
}

@ -71,7 +71,7 @@ public class WhiteController extends CoreBaseController {
public ResultBean listSysLocaleLanguage(){
try {
List sysLocaleLanguageList = sysLocaleLanguageService.findSysLocaleLanguageByStatus(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue());
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -117,7 +117,7 @@ public class PersonnelController extends CoreBaseController {
// 关系 刷新
refreshRef(user, info, model);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -197,7 +197,7 @@ public class PersonnelController extends CoreBaseController {
personnelService.saveSysUser(user);
personnelService.saveSysUserInfo(userInfo);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -229,7 +229,7 @@ public class PersonnelController extends CoreBaseController {
// 关系 刷新
refreshRef(user, null, model);
personnelService.saveSysUser(user);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -309,7 +309,7 @@ public class PersonnelController extends CoreBaseController {
personnelService.deleteSysUserInfo(new Long[]{info.getId()},getSessionUser().getUserName());
personnelService.deleteSysUser(new Long[]{info.getUserId()},getSessionUser().getUserName());
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else{
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -347,7 +347,7 @@ public class PersonnelController extends CoreBaseController {
personnelService.deleteSysUserInfo(infoIds,getSessionUser().getUserName());
personnelService.deleteSysUser(userIds,getSessionUser().getUserName());
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else{
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -370,7 +370,7 @@ public class PersonnelController extends CoreBaseController {
personnelService.deleteSysUserInfo(new Long[]{user.getUserInfoId()},getSessionUser().getUserName());
personnelService.deleteSysUser(new Long[]{user.getId()},getSessionUser().getUserName());
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else{
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -408,7 +408,7 @@ public class PersonnelController extends CoreBaseController {
personnelService.deleteSysUserInfo(infoIds,getSessionUser().getUserName());
personnelService.deleteSysUser(userIds,getSessionUser().getUserName());
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else{
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}

@ -0,0 +1,149 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysBarcodeRuleService;
import cn.estsh.i3plus.core.apiservice.util.BarcodeParseUtil;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.SysBarcodeRule;
import cn.estsh.i3plus.pojo.platform.bean.SysConfig;
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.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
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.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.Map;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-03-12 16:00
* @Modify:
**/
@RestController
@Api(description = "条码规则管理服务")
@RequestMapping(PlatformConstWords.BASE_URL +"/sys-barcode-rule")
public class SysBarcodeRuleController extends CoreBaseController {
public static final Logger LOGGER = LoggerFactory.getLogger(SysConfigController.class);
@Autowired
private ISysBarcodeRuleService sysBarcodeRuleService;
@PostMapping("/insert")
@ApiOperation(value = "添加条码规则",notes = "添加条码规则")
public ResultBean insertSysBarcodeRule(SysBarcodeRule sysBarcodeRule) {
try {
// 条件验证
ValidatorBean.beginValid(sysBarcodeRule)
.notNull("name",sysBarcodeRule.getName())
.notNull("barcodeRuleCode",sysBarcodeRule.getBarcodeRuleCode())
.notNull("barcodeRule",sysBarcodeRule.getBarcodeRule());
sysBarcodeRuleService.insertSysBarcodeRule(sysBarcodeRule);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@PutMapping("/update")
@ApiOperation(value = "修改条码规则",notes = "修改条码规则")
public ResultBean updateSysBarcodeRule(SysBarcodeRule sysBarcodeRule) {
try {
// 条件验证
ValidatorBean.beginValid(sysBarcodeRule)
.notNull("name",sysBarcodeRule.getName())
.notNull("barcodeRuleCode",sysBarcodeRule.getBarcodeRuleCode())
.notNull("barcodeRule",sysBarcodeRule.getBarcodeRule());
sysBarcodeRuleService.updateSysBarcodeRule(sysBarcodeRule);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@DeleteMapping("/delete/{id}")
@ApiOperation(value = "删除条码规则",notes = "删除条码规则")
public ResultBean deleteSysBarcodeRuleById(@PathVariable("id") String idStr) {
try {
// 条件验证
ValidatorBean.checkNotNull(idStr,"id不能为空");
SysBarcodeRule sysBarcodeRule = sysBarcodeRuleService.getSysBarcodeRuleById(Long.parseLong(idStr));
if(sysBarcodeRule == null){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("条码规则不存在")
.setErrorSolution("请重新输入条码id")
.build();
}
sysBarcodeRuleService.deleteSysBarcodeRuleById(Long.parseLong(idStr));
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping("/query")
@ApiOperation(value = "条码规则分页复杂查询",notes = "条码规则分页复杂查询")
public ResultBean querySysBarcodeRuleByPager(SysBarcodeRule sysBarcodeRule, Pager pager) {
try {
ListPager listPager = sysBarcodeRuleService.querySysBarcodeRuleByPager(sysBarcodeRule,pager);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(listPager);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@PutMapping("/parser")
@ApiOperation(value = "解析条码规则",notes = "解析条码规则")
public ResultBean querySysBarcodeRuleByPager(String ruleCode, String barcode) {
try {
// 条件验证
ValidatorBean.checkNotNull(ruleCode,"规则代码不能为空");
SysBarcodeRule sysBarcodeRule = sysBarcodeRuleService.getSysBarcodeRuleByCode(ruleCode);
if(sysBarcodeRule == null){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("条码规则不存在")
.setErrorSolution("请重新输入条码id")
.build();
}
// 解析条码规则
Map resultMap = BarcodeParseUtil.parse(sysBarcodeRule,barcode);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultMap(resultMap);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
}

@ -72,7 +72,7 @@ public class SysConfigController extends CoreBaseController {
sysConfigService.insertSysConfig(sysConfig);
systemInitService.loadSysConfig();
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -97,7 +97,7 @@ public class SysConfigController extends CoreBaseController {
sysConfigService.deleteSysConfigById(Long.parseLong(idStr));
systemInitService.loadSysConfig();
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -124,7 +124,7 @@ public class SysConfigController extends CoreBaseController {
sysConfigService.updateSysConfig(sysConfig);
systemInitService.loadSysConfig();
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -137,7 +137,7 @@ public class SysConfigController extends CoreBaseController {
public ResultBean findSysConfigAll(){
try {
List<SysConfig> sysConfigList = sysConfigService.ListSysConfig();
return ResultBean.success("查询成功")
return ResultBean.success("操作成功")
.setResultList(sysConfigList)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
@ -155,7 +155,7 @@ public class SysConfigController extends CoreBaseController {
SysConfig sysConfig = sysConfigService.getSysConfigById(Long.parseLong(id));
if (sysConfig != null) {
return ResultBean.success("查询成功")
return ResultBean.success("操作成功")
.setResultObject(sysConfig).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
@ -172,7 +172,7 @@ public class SysConfigController extends CoreBaseController {
public ResultBean querySysConfigByPager(SysConfig sysConfig,Pager pager) {
try {
ListPager sysConfigListPager = sysConfigService.querySysConfigByPager(sysConfig,pager);
return ResultBean.success("查询成功").setListPager(sysConfigListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysConfigListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -190,7 +190,7 @@ public class SysConfigController extends CoreBaseController {
if(sysConfig == null){
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
} else{
return ResultBean.success("查询成功").setResultObject(sysConfig).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysConfig).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
@ -207,7 +207,7 @@ public class SysConfigController extends CoreBaseController {
if(sysConfig == null){
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
} else{
return ResultBean.success("查询成功").setResultList(sysConfig).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultList(sysConfig).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
@ -225,7 +225,7 @@ public class SysConfigController extends CoreBaseController {
sysConfigService.updateSysConfigByCode(code,value);
systemInitService.loadSysConfig();
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -267,7 +267,7 @@ public class SysConfigController extends CoreBaseController {
try {
ValidatorBean.checkNotNull(group,"参数组不能为空");
List<SysConfig> sysConfigList = sysConfigService.findSysConfigByGroup(group);
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysConfigList);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysConfigList);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -72,7 +72,7 @@ public class SysDashboardController extends CoreBaseController {
redisCore.putHashMap(redisKey, dashboardData, 500);
}
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultMap(dashboardData);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultMap(dashboardData);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -99,7 +99,7 @@ public class SysDashboardController extends CoreBaseController {
redisCore.putHashMap(redisKey, dashboardData, 500);
}
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultMap(dashboardData);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
@ -129,7 +129,7 @@ public class SysDashboardController extends CoreBaseController {
redisCore.putHashMap(redisKey, dashboardData, 500);
}
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultMap(dashboardData);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
@ -159,7 +159,7 @@ public class SysDashboardController extends CoreBaseController {
redisCore.putHashMap(redisKey, dashboardData, 500);
}
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultMap(dashboardData);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
@ -208,7 +208,7 @@ public class SysDashboardController extends CoreBaseController {
redisCore.putHashMap(redisKey, dashboardData, 500);
}
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultMap(dashboardData);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);

@ -72,7 +72,7 @@ public class SysDepartmentController extends CoreBaseController {
}
departmentService.insertSysDepartment(department);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -101,7 +101,7 @@ public class SysDepartmentController extends CoreBaseController {
}
departmentService.updateSysDepartment(department);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -159,7 +159,7 @@ public class SysDepartmentController extends CoreBaseController {
}else{
list = departmentService.findSysDepartmentByPager(department, pager);
}
return ResultBean.success("查询成功").setListPager(list).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(list).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -175,7 +175,7 @@ public class SysDepartmentController extends CoreBaseController {
ValidatorBean.checkNotNull(id, "id为空。");
departmentService.deleteSysDepartmentById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -196,7 +196,7 @@ public class SysDepartmentController extends CoreBaseController {
.build();
}
departmentService.deleteSysDepartmentByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -53,6 +53,7 @@ public class SysDictionaryController extends CoreBaseController{
ValidatorBean.beginValid(sysDictionary)
.notNull("id",sysDictionary.getId())
.notNull("name",sysDictionary.getName())
.notNull("softType",sysDictionary.getSoftType())
.notNull("dictionaryCode",sysDictionary.getDictionaryCode())
.notNull("dictionaryValue",sysDictionary.getDictionaryValue());
@ -60,7 +61,7 @@ public class SysDictionaryController extends CoreBaseController{
sysDictionary.setIsDefault(CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue());
sysDictionaryService.insertSysDictionary(sysDictionary);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -78,6 +79,7 @@ public class SysDictionaryController extends CoreBaseController{
// 条件验证
ValidatorBean.beginValid(sysDictionary)
.notNull("name",sysDictionary.getName())
.notNull("softType",sysDictionary.getSoftType())
.notNull("dictionaryCode",sysDictionary.getDictionaryCode())
.notNull("dictionaryValue",sysDictionary.getDictionaryValue());
@ -85,7 +87,7 @@ public class SysDictionaryController extends CoreBaseController{
ConvertBean.modelUpdate(sysDictionary,user);
sysDictionaryService.updateSysDictionary(sysDictionary);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -117,7 +119,7 @@ public class SysDictionaryController extends CoreBaseController{
}
sysDictionaryService.deleteSysDictionaryById(Long.parseLong(idStr));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -130,7 +132,7 @@ public class SysDictionaryController extends CoreBaseController{
public ResultBean findSysDictionaryAll() {
try {
List<SysDictionary> sysDictionaryList = sysDictionaryService.listSysDictionary();
return ResultBean.success("查询成功").setResultList(sysDictionaryList)
return ResultBean.success("操作成功").setResultList(sysDictionaryList)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
@ -148,7 +150,7 @@ public class SysDictionaryController extends CoreBaseController{
SysDictionary sysDictionary = sysDictionaryService.getSysDictionaryById(Long.parseLong(id));
if (sysDictionary != null) {
return ResultBean.success("查询成功").setResultObject(sysDictionary).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysDictionary).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("字典不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -159,12 +161,12 @@ public class SysDictionaryController extends CoreBaseController{
}
}
@GetMapping(value = "/find/{code}")
@ApiOperation(value = "根据父级code查询字典项", notes = "根据父级code查询字典项")
public ResultBean findSysDictionaryByParentCode(@PathVariable("code") String code) {
@GetMapping(value = "/find/{softType}/{code}")
@ApiOperation(value = "根据微服务与父级code查询字典项", notes = "根据微服务与父级code查询字典项")
public ResultBean findSysDictionaryByParentCode(@PathVariable("softType")Integer softType,@PathVariable("code") String code) {
try {
List<SysDictionary> sysDictionaryList = sysDictionaryService.findSysDictionaryByParentCode(code);
return ResultBean.success("查询成功").setResultList(sysDictionaryList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
List<SysDictionary> sysDictionaryList = sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(softType,code);
return ResultBean.success("操作成功").setResultList(sysDictionaryList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -176,18 +178,27 @@ public class SysDictionaryController extends CoreBaseController{
@ApiOperation(value = "查询跟用户相关所有字典")
public ResultBean findSysDictionaryUserInfo() {
try {
Map<String,Object> resultMap = new HashMap<>();
resultMap.put("1",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_SEX));
resultMap.put("2",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_FILE_TYPE));
resultMap.put("3",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_MARRIAGE));
resultMap.put("4",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_EDUCATION));
resultMap.put("5",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_NATIONALITY));
resultMap.put("6",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_CERTIFICATE_TYPE));
resultMap.put("7",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_EMPLOYEE_GRADE));
resultMap.put("8",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_POLITICAL_STATUS));
resultMap.put("9",sysDictionaryService.findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_EMPLOYEE_TYPE));
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("1", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_SEX));
resultMap.put("2", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_FILE_TYPE));
resultMap.put("3", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_MARRIAGE));
resultMap.put("4", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_EDUCATION));
resultMap.put("5", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_NATIONALITY));
resultMap.put("6", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_CERTIFICATE_TYPE));
resultMap.put("7", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_EMPLOYEE_GRADE));
resultMap.put("8", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_POLITICAL_STATUS));
resultMap.put("9", sysDictionaryService.findSysDictionaryBySoftTypeAndParentCode(
CommonEnumUtil.SOFT_TYPE.CORE.getValue(), BaseConstWords.DICTIONARY_EMPLOYEE_TYPE));
return ResultBean.success("查询成功").setResultMap(resultMap).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultMap(resultMap).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -200,7 +211,7 @@ public class SysDictionaryController extends CoreBaseController{
public ResultBean querySysDictionaryByPager(SysDictionary sysDictionary, Pager pager) {
try {
ListPager sysDictionaryListPager = sysDictionaryService.querySysDictionaryByPager(sysDictionary,pager);
return ResultBean.success("查询成功").setListPager(sysDictionaryListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysDictionaryListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -213,7 +224,7 @@ public class SysDictionaryController extends CoreBaseController{
public ResultBean findSysDictionaryByTop() {
try {
List<SysDictionary> sysDictionaryList = sysDictionaryService.findSysDictionaryByTop();
return ResultBean.success("查询成功").setResultList(sysDictionaryList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultList(sysDictionaryList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -233,7 +244,7 @@ public class SysDictionaryController extends CoreBaseController{
.build();
}
sysDictionaryService.deleteSysDictionaryByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -66,7 +66,7 @@ public class SysFileController extends CoreBaseController{
.notNull("name",sysFile.getName());
sysFileService.updateSysFile(sysFile);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -79,7 +79,7 @@ public class SysFileController extends CoreBaseController{
public ResultBean deleteSysFileById(@PathVariable("id") String id){
try {
sysFileService.deleteSysFileById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -92,7 +92,7 @@ public class SysFileController extends CoreBaseController{
public ResultBean findSysFileAll(SysFile sysFile){
try {
List<SysFile> sysFileList = sysFileService.listSysFile();
return ResultBean.success("查询成功")
return ResultBean.success("操作成功")
.setResultList(sysFileList)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
@ -109,7 +109,7 @@ public class SysFileController extends CoreBaseController{
ValidatorBean.checkIsNumber(id,"id必须为数字");
SysFile sysFile = sysFileService.getSysFileById(Long.parseLong(id));
return ResultBean.success("查询成功")
return ResultBean.success("操作成功")
.setResultObject(sysFile)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
@ -124,7 +124,7 @@ public class SysFileController extends CoreBaseController{
public ResultBean querySysFileByPager(SysFile sysFile, Pager pager){
try {
ListPager sysFileListPager = sysFileService.querySysFileByPager(sysFile,pager);
return ResultBean.success("查询成功").setListPager(sysFileListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysFileListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -145,7 +145,7 @@ public class SysFileController extends CoreBaseController{
}
sysFileService.deleteSysFileByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -274,7 +274,7 @@ public class SysFileController extends CoreBaseController{
sysFile.setFileTypeName(dictionary.getName());
sysFile = sysFileService.insertSysFile(sysFile);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysFile);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(sysFile);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -0,0 +1,214 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLabelTemplateService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.model.platform.LabelTemplateModel;
import cn.estsh.i3plus.pojo.platform.bean.SessionUser;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplate;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplateParam;
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.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
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.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : siliter
* @Date : 2019-03-18 13:15
* @Modify :
**/
@RestController
@Api(description = "打印模板管理服务")
@RequestMapping(PlatformConstWords.BASE_URL +"/sys-label-template")
public class SysLabelTemplateController extends CoreBaseController {
public static final Logger LOGGER = LoggerFactory.getLogger(SysLabelTemplateController.class);
@Autowired
private ISysLabelTemplateService sysLabelTemplateService;
@PostMapping("/insert")
@ApiOperation(value = "添加打印模板",notes = "添加打印模板")
public ResultBean insertSysLabelTemplate(SysLabelTemplate sysLabelTemplate) {
try {
// 登录用户
SessionUser user = AuthUtil.getSessionUser();
// 条件验证
ValidatorBean.beginValid(sysLabelTemplate)
.notNull("templateCode", sysLabelTemplate.getTemplateCode())
.notNull("templateName", sysLabelTemplate.getTemplateName())
.notNull("paramsPack", sysLabelTemplate.getParamsPack())
.notNull("templateContent", sysLabelTemplate.getTemplateContent());
//修改初始化
ConvertBean.modelInitialize(sysLabelTemplate, user);
sysLabelTemplateService.insertSysLabelTemplate(sysLabelTemplate);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@DeleteMapping(value = "/delete/{id}")
@ApiOperation(value = "根据id删除打印模板", notes = "根据id删除打印模板")
public ResultBean deleteSysLabelTemplate(@PathVariable("id") String idStr) {
try {
// 条件验证
ValidatorBean.checkNotNull(idStr,"id不能为空");
if(sysLabelTemplateService.getSysLabelTemplateById(Long.parseLong(idStr)) == null){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("打印模板不存在")
.setErrorSolution("请检查打印模板编号")
.build();
}
sysLabelTemplateService.deleteSysLabelTemplateById(Long.parseLong(idStr));
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@PutMapping(value = "/update")
@ApiOperation(value = "修改打印模板",notes = "修改打印模板")
public ResultBean updateSysLabelTemplate(SysLabelTemplate sysLabelTemplate){
try {
// 登录用户
SessionUser user = AuthUtil.getSessionUser();
// 条件验证
ValidatorBean.beginValid(sysLabelTemplate)
.notNull("templateCode", sysLabelTemplate.getTemplateCode())
.notNull("templateName", sysLabelTemplate.getTemplateName())
.notNull("paramsPack", sysLabelTemplate.getParamsPack())
.notNull("templateContent", sysLabelTemplate.getTemplateContent());
//添加初始化
ConvertBean.modelUpdate(sysLabelTemplate, user);
sysLabelTemplateService.updateSysLabelTemplate(sysLabelTemplate);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping(value = "/list")
@ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板")
public ResultBean findSysConfigAll(){
try {
List<SysLabelTemplate> sysLabelTemplateList = sysLabelTemplateService.ListSysLabelTemplate();
return ResultBean.success("操作成功")
.setResultList(sysLabelTemplateList)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping(value = "/get/{id}")
@ApiOperation(value = "根据id查询打印模板",notes = "根据id查询打印模板")
public ResultBean getSysLabelTemplateById(@PathVariable("id") String id){
try {
ValidatorBean.checkNotNull(id,"id不能为空");
SysLabelTemplate sysLabelTemplate = sysLabelTemplateService.getSysLabelTemplateById(Long.parseLong(id));
if (sysLabelTemplate != null) {
return ResultBean.success("操作成功")
.setResultObject(sysLabelTemplate).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping("/query")
@ApiOperation(value = "打印模板复杂查询,分页,排序",notes = "打印模板复杂查询,分页,排序")
public ResultBean querySysLabelTemplateByPager(SysLabelTemplate sysLabelTemplate,Pager pager) {
try {
ListPager sysConfigListPager = sysLabelTemplateService.querySysLabelTemplateByPager(sysLabelTemplate,pager);
return ResultBean.success("操作成功").setListPager(sysConfigListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping("/find-template-id/{id}")
@ApiOperation(value = "根据打印模板编号查询模板参数",notes = "根据打印模板编号查询模板参数")
public ResultBean getSysLabelTemplateByTemplateId(@PathVariable("id") String id) {
try {
if (StringUtils.isBlank(id)) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("打印模板编号为空")
.setErrorSolution("请检查打印模板编号")
.build();
}
return ResultBean.success("操作成功").setResultList(sysLabelTemplateService.listSysLabelTemplateParam(id))
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
@GetMapping("/get-template-info/{id}")
@ApiOperation(value = "根据打印模板编号查询模板",notes = "根据打印模板编号查询模板")
public ResultBean getSysLabelTemplateInfoById(@PathVariable("id") String id) {
try {
if (StringUtils.isBlank(id)) {
throw ImppExceptionBuilder.newInstance()
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorDetail("打印模板编号为空")
.setErrorSolution("请检查打印模板编号")
.build();
}
return ResultBean.success("操作成功").setResultObject(sysLabelTemplateService.getLabelTemplateInfoById(id))
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
}

@ -124,7 +124,7 @@ public class SysLocaleLanguageController extends CoreBaseController {
public ResultBean listSysLocaleLanguage(){
try {
List sysLocaleLanguageList = sysLocaleLanguageService.listSysLocaleLanguage();
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -137,7 +137,7 @@ public class SysLocaleLanguageController extends CoreBaseController {
public ResultBean querySysLocaleLanguageByPager(SysLocaleLanguage sysLocaleLanguage, Pager pager){
try {
ListPager sysLocaleLanguageListPager = sysLocaleLanguageService.querySysLocaleLanguageByPager(sysLocaleLanguage,pager);
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(sysLocaleLanguageListPager);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(sysLocaleLanguageListPager);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -132,7 +132,7 @@ public class SysLocaleResourceController extends CoreBaseController {
public ResultBean listSysLocaleResource(){
try {
List sysLocaleLanguageList = sysLocaleResourceService.listSysLocaleResource();
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultList(sysLocaleLanguageList);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -145,7 +145,7 @@ public class SysLocaleResourceController extends CoreBaseController {
public ResultBean querySysLocaleResourceByPager(SysLocaleResource sysLocaleResource, Pager pager){
try {
ListPager sysLocaleLanguageListPager = sysLocaleResourceService.querySysLocaleResourceByPager(sysLocaleResource,pager);
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(sysLocaleLanguageListPager);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager(sysLocaleLanguageListPager);
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -63,7 +63,7 @@ public class SysLogOperateController extends CoreBaseController {
public ResultBean insertSysLogOperateController(SysLogOperate logOperate){
try {
logOperateService.insertSysLogOperate(logOperate);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -79,7 +79,7 @@ public class SysLogOperateController extends CoreBaseController {
ValidatorBean.checkNotNull(id,"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){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -92,7 +92,7 @@ public class SysLogOperateController extends CoreBaseController {
public ResultBean findSysLogOperateAll(){
try {
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){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -106,7 +106,7 @@ public class SysLogOperateController extends CoreBaseController {
try{
SysLogOperate logOperate = logOperateService.getSysLogOperateById(Long.parseLong(id));
if (logOperate != null) {
return ResultBean.success("查询成功")
return ResultBean.success("操作成功")
.setResultObject(logOperate)
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
@ -125,7 +125,7 @@ public class SysLogOperateController extends CoreBaseController {
public ResultBean querySysLogOperateByPager(SysLogOperate logOperate, Pager pager){
try {
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){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -59,7 +59,7 @@ public class SysLogSystemController extends CoreBaseController{
public ResultBean insertSysLogSystem(SysLogSystem logSystem) {
try {
logSystemService.insertSysLogSystem(logSystem);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -75,7 +75,7 @@ public class SysLogSystemController extends CoreBaseController{
ValidatorBean.checkNotNull(id,"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){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -88,7 +88,7 @@ public class SysLogSystemController extends CoreBaseController{
public ResultBean findSysLogSystemAll(){
try {
List<SysLogSystem> logSystemList = logSystemService.listSysLogSystem();
return ResultBean.success("查询成功").setResultList(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultList(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -101,7 +101,7 @@ public class SysLogSystemController extends CoreBaseController{
public ResultBean getSysLogSystemById(String id){
try {
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){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -120,7 +120,7 @@ public class SysLogSystemController extends CoreBaseController{
public ResultBean querySysLogSystemByPager(SysLogSystem logSystem, Pager pager){
try {
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){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -39,7 +39,7 @@ public class SysLogTaskTimeController extends CoreBaseController{
public ResultBean insertSyslogTaskTime(SysLogTaskTime sysLogTaskTime) {
try {
logTaskTimeService.insertSysLogTaskTime(sysLogTaskTime);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -55,7 +55,7 @@ public class SysLogTaskTimeController extends CoreBaseController{
ValidatorBean.checkNotNull(id,"id不能为空");
logTaskTimeService.deleteSysLogTaskTimeById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -69,7 +69,7 @@ public class SysLogTaskTimeController extends CoreBaseController{
try {
SysLogTaskTime logTaskTime = logTaskTimeService.getSysLogTaskTimeById(Long.parseLong(id));
if (logTaskTime != null) {
return ResultBean.success("查询成功").setResultObject(logTaskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(logTaskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("日志不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -91,7 +91,7 @@ public class SysLogTaskTimeController extends CoreBaseController{
public ResultBean querySysLogSystemByPager(SysLogTaskTime sysLogTaskTime, Pager pager){
try {
ListPager logSystemList = logTaskTimeService.querySysLogTaskTimeByPager(sysLogTaskTime, pager);
return ResultBean.success("查询成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(logSystemList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -93,7 +93,7 @@ public class SysMenuController extends CoreBaseController {
}
sysMenuService.updateSysMenu(menu);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep).build();
} catch (Exception e) {
@ -215,7 +215,7 @@ public class SysMenuController extends CoreBaseController {
.build();
}
sysMenuService.deleteSysMenuByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);

@ -66,7 +66,7 @@ public class SysMessageController extends CoreBaseController {
sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.INTERNAL.getValue());
sysMessageService.doSendSysMessage(sysMessage);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -82,7 +82,7 @@ public class SysMessageController extends CoreBaseController {
ValidatorBean.checkNotNull(id,"id不能为空");
sysMessageService.deleteSysMessageById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -104,7 +104,7 @@ public class SysMessageController extends CoreBaseController {
.checkNotZero("messageType",sysMessage.getMessageType());
sysMessageService.updateSysMessage(sysMessage);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -117,7 +117,7 @@ public class SysMessageController extends CoreBaseController {
public ResultBean findSysMessageAll(){
try {
List<SysMessage> sysMessageList = sysMessageService.listSysMessage();
return ResultBean.success("查询成功").setResultList(sysMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultList(sysMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -131,7 +131,7 @@ public class SysMessageController extends CoreBaseController {
try {
SysMessage sysMessage = sysMessageService.getSysMessageById(Long.parseLong(idStr));
if (sysMessage != null) {
return ResultBean.success("查询成功").setResultObject(sysMessage).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysMessage).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -147,7 +147,7 @@ public class SysMessageController extends CoreBaseController {
public ResultBean querySysMessageByPager(SysMessage sysMessage, Pager pager){
try {
ListPager sysMessageListPager = sysMessageService.querySysMessageByPager(sysMessage,pager);
return ResultBean.success("查询成功").setListPager(sysMessageListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysMessageListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -169,7 +169,7 @@ public class SysMessageController extends CoreBaseController {
.build();
}
sysMessageService.deleteSysMessageByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -186,7 +186,7 @@ public class SysMessageController extends CoreBaseController {
sysRefUserMessage.setReceiverId(getSessionUser().getUser().getId());
ListPager userMessageList = sysMessageService.querySysRefUserMessageByPager(sysRefUserMessage,pager);
return ResultBean.success("查询成功").setListPager(userMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(userMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -203,7 +203,7 @@ public class SysMessageController extends CoreBaseController {
sysMessage.setMessageSenderId(getSessionUser().getUser().getId());
ListPager sysMessageListPager = sysMessageService.querySysMessageByPager(sysMessage,pager);
return ResultBean.success("查询成功").setListPager(sysMessageListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysMessageListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -217,7 +217,7 @@ public class SysMessageController extends CoreBaseController {
try {
List userMessageList = sysMessageService.findSysRefUserMessageByUserIdAndStatus(getSessionUser().getUser().getId(),
ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
return ResultBean.success("查询成功").setResultList(userMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultList(userMessageList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -313,7 +313,7 @@ public class SysMessageController extends CoreBaseController {
sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.INTERNAL.getValue());
sysMessageService.doSendSysMessage(sysMessage);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -121,7 +121,7 @@ public class SysOrderNoRuleController extends CoreBaseController {
SysOrderNoRule sysOrderNoRule = sysOrderNoRuleService.getSysOrderNoRuleById(Long.parseLong(idStr));
if (sysOrderNoRule != null) {
return ResultBean.success("查询成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -152,7 +152,7 @@ public class SysOrderNoRuleController extends CoreBaseController {
public ResultBean querySysOrderNoRuleByPager(SysOrderNoRule sysOrderNoRule, Pager pager){
try {
ListPager sysOrderNoRuleList = sysOrderNoRuleService.querySysOrderNoRuleByPager(sysOrderNoRule, pager);
return ResultBean.success("查询成功").setListPager(sysOrderNoRuleList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysOrderNoRuleList).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -375,7 +375,7 @@ public class SysOrderNoRuleController extends CoreBaseController {
ValidatorBean.checkNotNull(code,"code不能为空");
SysOrderNoRule sysOrderNoRule = sysOrderNoRuleService.getSysOrderNoRuleCode(code);
return ResultBean.success("查询成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysOrderNoRule).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -86,7 +86,7 @@ public class SysOrganizeController extends CoreBaseController{
}
organizeService.updateSysOrganize(organize);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -184,7 +184,7 @@ public class SysOrganizeController extends CoreBaseController{
}
organizeService.deleteSysOrganizeByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -61,7 +61,7 @@ public class SysPositionController extends CoreBaseController {
}
SysPosition pos = positionService.insertSysPosition(position);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode())
.setResultObject(pos);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
@ -91,7 +91,7 @@ public class SysPositionController extends CoreBaseController {
}
positionService.updateSysPosition(position);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -137,7 +137,7 @@ public class SysPositionController extends CoreBaseController {
ValidatorBean.beginValid(position)
.notNull("id",position.getId());
return ResultBean.success("查询成功").setResultObject(position).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(position).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -153,7 +153,7 @@ public class SysPositionController extends CoreBaseController {
ValidatorBean.checkNotNull(id,"id为空");
positionService.deleteSysPositionById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -174,7 +174,7 @@ public class SysPositionController extends CoreBaseController {
.build();
}
positionService.deleteSysPositionByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);

@ -81,7 +81,7 @@ public class SysRoleController extends CoreBaseController{
ConvertBean.modelUpdate(role, AuthUtil.getSessionUser());
sysRoleService.updateSysRole(role);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -291,7 +291,7 @@ public class SysRoleController extends CoreBaseController{
.build();
}
sysRoleService.deleteSysRoleByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);

@ -145,7 +145,7 @@ public class SysTaskController extends CoreBaseController {
.build();
}
sysTaskService.deleteSysTaskByIds(StringTool.getArrayLong(idsStr));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {

@ -144,7 +144,7 @@ public class SysTaskCycleController extends CoreBaseController{
SysTaskCycle sysTaskCycle = sysTaskCycleService.getSysTaskCycleById(Long.parseLong(id));
if (sysTaskCycle != null) {
return ResultBean.success("查询成功").setResultObject(sysTaskCycle).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(sysTaskCycle).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -160,7 +160,7 @@ public class SysTaskCycleController extends CoreBaseController{
public ResultBean querySysTaskCycleByPager(SysTaskCycle taskTimeExpression, Pager pager){
try {
ListPager listPager = sysTaskCycleService.querySysTaskCycleByPager(taskTimeExpression,pager);
return ResultBean.success("查询成功").setListPager(listPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(listPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -181,7 +181,7 @@ public class SysTaskCycleController extends CoreBaseController{
}
sysTaskCycleService.deleteSysTaskCycleByIds(StringTool.getArrayLong(idsStr));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -165,7 +165,7 @@ public class SysTaskPlanController extends CoreBaseController{
SysTaskPlan taskTime = sysTaskPlanService.getSysTaskPlanById(Long.parseLong(id));
if (taskTime != null) {
return ResultBean.success("查询成功").setResultObject(taskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(taskTime).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("任务计划不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -198,7 +198,7 @@ public class SysTaskPlanController extends CoreBaseController{
public ResultBean querySysTaskTimeByPager(SysTaskPlan taskTime, Pager pager){
try {
ListPager taskTimeListPager = sysTaskPlanService.querySysTaskPlanByPager(taskTime,pager);
return ResultBean.success("查询成功").setListPager(taskTimeListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(taskTimeListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -69,7 +69,7 @@ public class SysToolController extends CoreBaseController{
tool.setToolStatus(CommonEnumUtil.DATA_STATUS.ENABLE.getValue());
toolService.insertSysTool(tool);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -97,7 +97,7 @@ public class SysToolController extends CoreBaseController{
ConvertBean.modelUpdate(tool,user);
toolService.updateSysTool(tool);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -112,7 +112,7 @@ public class SysToolController extends CoreBaseController{
ValidatorBean.checkNotNull(id,"id不能为空");
toolService.deleteSysToolById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -142,7 +142,7 @@ public class SysToolController extends CoreBaseController{
SysTool tool = toolService.getSysToolById(Long.parseLong(id));
if (tool != null) {
return ResultBean.success("查询成功").setResultObject(tool).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(tool).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("硬件不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -158,7 +158,7 @@ public class SysToolController extends CoreBaseController{
public ResultBean querySysToolByPager(SysTool tool, Pager pager){
try {
ListPager sysSysToolListPager = toolService.querySysToolByPager(tool,pager);
return ResultBean.success("查询成功").setListPager(sysSysToolListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysSysToolListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -191,7 +191,7 @@ public class SysToolController extends CoreBaseController{
.build();
}
toolService.deleteSysToolByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -53,7 +53,7 @@ public class SysToolTypeController extends CoreBaseController{
ConvertBean.modelInitialize(toolType, AuthUtil.getSessionUser());
toolTypeService.insertSysToolType(toolType);
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -75,7 +75,7 @@ public class SysToolTypeController extends CoreBaseController{
ConvertBean.modelUpdate(toolType,user);
toolTypeService.updateSysToolType(toolType);
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){
@ -98,7 +98,7 @@ public class SysToolTypeController extends CoreBaseController{
}
toolTypeService.deleteSysToolTypeById(Long.parseLong(idStr));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep);
@ -129,7 +129,7 @@ public class SysToolTypeController extends CoreBaseController{
SysToolType toolType = toolTypeService.getSysToolTypeById(Long.parseLong(id));
if (toolType != null) {
return ResultBean.success("查询成功").setResultObject(toolType).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(toolType).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("硬件不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -145,7 +145,7 @@ public class SysToolTypeController extends CoreBaseController{
public ResultBean querySysToolTypeByPager(SysToolType toolType, Pager pager){
try {
ListPager sysDictionaryListPager = toolTypeService.querySysToolTypeByPager(toolType,pager);
return ResultBean.success("查询成功").setListPager(sysDictionaryListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setListPager(sysDictionaryListPager).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
LOGGER.error(busExcep.getErrorMsg() + "{}",busExcep.getErrorDetail(),busExcep);
return ResultBean.fail(busExcep);
@ -166,7 +166,7 @@ public class SysToolTypeController extends CoreBaseController{
.build();
}
toolTypeService.deleteSysToolTypeByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -293,7 +293,7 @@ public class SysUserController extends CoreBaseController{
}
sysUserService.deleteBatchSysUserById(StringTool.getArrayLong(ids),AuthUtil.getSessionUser());
return ResultBean.success("删除成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);

@ -81,7 +81,7 @@ public class SysUserInfoController extends CoreBaseController{
sysUserInfoService.refreshRefUserOrganize(info.getId(), userInfo.getDepartment().getOrganizeId(),user.getUserName());
return ResultBean.success("添加成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(info);
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultObject(info);
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -106,7 +106,7 @@ public class SysUserInfoController extends CoreBaseController{
sysUserInfoService.refreshRefUserOrganize(userInfo.getId(), userInfo.getDepartment().getOrganizeId(),user.getUserName());
return ResultBean.success("修改成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -122,7 +122,7 @@ public class SysUserInfoController extends CoreBaseController{
ValidatorBean.checkNotNull(id,"id为空");
sysUserInfoService.deleteSysUserInfoById(Long.parseLong(id));
return ResultBean.success("删除成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
} catch (ImppBusiException busExcep) {
return ResultBean.fail(busExcep);
} catch (Exception e) {
@ -168,7 +168,7 @@ public class SysUserInfoController extends CoreBaseController{
.notNull("id",userInfo.getId());
if(userInfo != null){
return ResultBean.success("查询成功").setResultObject(userInfo).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
return ResultBean.success("操作成功").setResultObject(userInfo).setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}else {
return ResultBean.fail("数据不存在").setCode(ResourceEnumUtil.MESSAGE.EMPTY.getCode());
}
@ -192,7 +192,7 @@ public class SysUserInfoController extends CoreBaseController{
.build();
}
sysUserInfoService.deleteSysUserInfoByIds(StringTool.getArrayLong(ids));
return ResultBean.success("删除成功")
return ResultBean.success("操作成功")
.setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode());
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
@ -378,7 +378,7 @@ public class SysUserInfoController extends CoreBaseController{
@ApiOperation(value = "获取用户可导出字段")
public ResultBean getSysUserInfoColName(){
try {
return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultMap(ExcelUtil.getColName(SysUserInfo.class));
return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setResultMap(ExcelUtil.getColName(SysUserInfo.class));
}catch(ImppBusiException busExcep){
return ResultBean.fail(busExcep);
}catch(Exception e){

@ -1,31 +0,0 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-02-19 18:13
* @Modify:
**/
public class TestThread implements Runnable {
private Thread t;
private int piLength = 0;
public TestThread (int piLength){
this.piLength = piLength;
}
@Override
public void run() {
ComputePi.computePi(piLength);
}
public void start () {
if (t == null) {
t = new Thread (this);
t.start ();
}
}
}

@ -1,61 +0,0 @@
package cn.estsh.i3plus.core.apiservice.controller.busi;
import cn.estsh.i3plus.platform.common.tool.TimeTool;
import cn.estsh.i3plus.pojo.base.codemaker.SnowflakeIdMaker;
import cn.estsh.i3plus.pojo.platform.bean.SysTool;
import org.apache.commons.lang3.RandomStringUtils;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-02-19 11:41
* @Modify:
**/
public class Text {
public static final String TEXT = "党的十八大提出倡导富强、民主、文明、和谐倡导自由、平等、公正、法治倡导爱国、敬业、诚信、友善积极培育和践行社会主义核心价值观。富强、民主、文明、和谐是国家层面的价值目标自由、平等、公正、法治是社会层面的价值取向爱国、敬业、诚信、友善是公民个人层面的价值准则这24个字是社会主义核心价值观的基本内容。";
public static void printUsage(String path, int num, int index) throws IOException {
File dir = new File(path+File.separator+"tool"+File.separator+"temp" + (index / 10));
if (!dir.exists()) {
System.out.println(dir.mkdirs());
}
File f = new File(path+File.separator+"tool"+File.separator+"temp" + (index / 10) + File.separator+"insert" + index + ".sql");
FileWriter fw = new FileWriter(f);
BufferedWriter out = new BufferedWriter(fw);
try {
SysTool sysTool;
StringBuffer sb;
SnowflakeIdMaker snf = new SnowflakeIdMaker();
for (int i = 0; i < num; i++) {
sb = new StringBuffer();
sb.append("insert into sys_tool (id,name,tool_type_name_rdd,tool_type_id,tool_ip,tool_port,tool_description) values ");
sysTool = new SysTool();
sysTool.setId(snf.nextId() + System.currentTimeMillis());
sysTool.setName(RandomStringUtils.random(10, TEXT));
sysTool.setToolTypeNameRdd(RandomStringUtils.random(10, TEXT));
sysTool.setToolTypeId(System.currentTimeMillis());
sysTool.setToolIp(RandomStringUtils.random(10, TEXT));
sysTool.setToolPort((int) (Math.random() * i));
sysTool.setToolDescription(RandomStringUtils.random(10, TEXT));
sysTool.setCreateDatetime(TimeTool.getNowTime(true));
sysTool.setModifyDatetime(TimeTool.getNowTime(true));
sb.append("(" + sysTool.getId() + ",'" + sysTool.getName() + "','" + sysTool.getToolTypeNameRdd() + "'," + sysTool.getToolTypeId() + ",'"
+ sysTool.getToolIp() + "'," + sysTool.getToolPort() + ",'" + sysTool.getToolDescription() + "');");
out.write(sb.toString());
}
} finally {
out.close();
}
}
}

@ -63,4 +63,12 @@ public class I3CoreQueueConfig {
//LOGGER.info("【DEMO_RETURN_QUEUE队列】");
return new Queue(DEMO_RETURN_QUEUE);
}
//测试wms微服队列
public static final String DEMO_CLOUD_WMS = "DEMO_CLOUD_WMS";
@Bean
public Queue getDemoCloudWmsQueue() throws Exception {
//LOGGER.info("【DEMO_CLOUD_WMS】");
return new Queue(DEMO_CLOUD_WMS);
}
}

@ -1,10 +1,13 @@
package cn.estsh.i3plus.core.apiservice.mq;
import cn.estsh.i3plus.icloud.wms.sdk.IWmsDemoCloud;
import cn.estsh.i3plus.pojo.base.bean.BaseResultBean;
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import com.rabbitmq.client.Channel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.io.IOException;
@ -20,6 +23,9 @@ import java.io.IOException;
public class I3CoreQueueReceiver {
private static final Logger LOGGER = LoggerFactory.getLogger(I3CoreQueueReceiver.class);
@Autowired
IWmsDemoCloud iWmsDemoCloud;
/**
*
* @param msg
@ -46,6 +52,34 @@ public class I3CoreQueueReceiver {
}
}
/**
*
* @param msg
* @param channel
* @param message
* rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....));
*/
@RabbitListener(queues = I3CoreQueueConfig.DEMO_CLOUD_WMS)
public void processCloud(String msg, Channel channel, Message message) {
try {
LOGGER.info("【MQ-DEMO_CLOUD_WMS】数据接收成功{}",msg);
BaseResultBean result = iWmsDemoCloud.testWms(msg);
LOGGER.info("微服返回结果:{}",result);
//信息已处理
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
} catch (IOException e) {
LOGGER.error("【MQ-DEMO_CLOUD_WMS】处理出错{}",e.getMessage(),e);
//丢弃这条消息
try {
// 未成功处理,重新发送
channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true);
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
/********************* 消息队列处理demo *******************/

@ -1,14 +1,18 @@
package cn.estsh.i3plus.core.apiservice.mq;
import cn.estsh.i3plus.core.api.iservice.busi.IPersonnelService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
import cn.estsh.i3plus.core.apiservice.websocket.MessageWebSocket;
import cn.estsh.i3plus.platform.common.tool.StringTool;
import cn.estsh.i3plus.platform.common.tool.TimeTool;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysRefUserMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysUser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.rabbitmq.client.Channel;
import org.apache.commons.lang3.StringUtils;
@ -16,11 +20,13 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
/**
@ -37,78 +43,180 @@ public class MessageLetterQueueReceiver {
@Autowired
ISysMessageService sysMessageService;
@Autowired
ISysUserService sysUserService;
@Autowired
private IPersonnelService personnelService;
@Autowired
private RabbitTemplate rabbitTemplate;
private static final ObjectMapper MAPPER = new ObjectMapper();
/**
*
*
* @param msg
* @param channel
* @param message rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....));
*/
@RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE)
public void processImppMessage(SysMessage msg, Channel channel, Message message) {
try {
LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功{}", msg);
LOGGER.info("【MQ-{}】 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, msg);
LOGGER.info("【MQ-{}】 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, msg);
LOGGER.info("【MQ-{}】 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, msg);
try {
msg = sysMessageService.insertSysMessage(msg);
LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功{}", msg);
if (!StringUtils.isBlank(msg.getMessageReceiversId())) {
String[] userIds = msg.getMessageReceiversId().split(",");
// 收件人信息
String[] messageReceiver = new String[0];
String[] receiverName = new String[0];
if (msg.getMessageReceiversId() != null) {
messageReceiver = msg.getMessageReceiversId().split(",");
receiverName = new String[messageReceiver.length];
}
if(userIds != null && userIds.length > 0){
List<SysUser> userList = personnelService.findSysUserByIds(StringTool.getArrayLong(userIds));
if(userList != null && userList.size() > 0){
List<String> names = new ArrayList<>(userList.size());
List<SysRefUserMessage> insertList = new ArrayList<>(userList.size());
SysRefUserMessage refUserMessage;
SysUser sysUser;
List<SysRefUserMessage> userMessage;
ObjectMapper mapper = new ObjectMapper();
for (int i = 0; i < messageReceiver.length; i++) {
sysUser = sysUserService.getSysUserById(Long.parseLong(messageReceiver[i]));
if(sysUser != null) {
receiverName[i] = sysUser.getUserName();
for (SysUser user : userList){
refUserMessage = new SysRefUserMessage();
refUserMessage.setMessageId(msg.getId());
refUserMessage.setMessageTitleRdd(msg.getMessageTitle());
refUserMessage.setMessageTypeRdd(msg.getMessageType());
refUserMessage.setMessageSenderNameRdd(msg.getMessageSenderNameRdd());
refUserMessage.setReceiverId(sysUser.getId());
refUserMessage.setReceiverNameRdd(sysUser.getUserName());
refUserMessage.setReceiverId(user.getId());
refUserMessage.setReceiverNameRdd(user.getUserName());
refUserMessage.setMessageStatus(ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
refUserMessage.setReceiverTime(TimeTool.getNowTime(true));
refUserMessage.setIsUrgent(msg.getIsUrgent());
sysMessageService.insertSysRefUserMessage(refUserMessage);
names.add(user.getUserName());
insertList.add(refUserMessage);
}
List<SysRefUserMessage> refList = sysMessageService.insertSysRefUserMessage(insertList);
userMessage = sysMessageService.findSysRefUserMessageByUserIdAndStatus(sysUser.getId(),
ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
MessageWebSocket.sendMessage(sysUser.getUserInfoId(),
mapper.writeValueAsString(userMessage)
);
// 站内信使用 Web Socket 推送
if(refList != null && refList.size() > 0){
for (SysRefUserMessage userMessage : refList) {
MessageWebSocket.sendMessage(userMessage.getReceiverId(), MAPPER.writeValueAsString(userMessage));
}
}
msg.setMessageReceiversNameRdd(StringUtils.join(receiverName, ","));
// 更新冗余信息
msg.setMessageReceiversNameRdd(StringUtils.join(names,","));
sysMessageService.updateSysMessage(msg);
//信息已处理
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
} catch (IOException e) {
LOGGER.error("【MQ-IMPP_MESSAGE_LETTER_QUEUE】处理出错{}", e.getMessage(), e);
//丢弃这条消息
}
}
}
}catch (Exception e){
printErrorMessage(e,Exception.class, msg);
}finally {
try {
// 未成功处理,重新发送
channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
} catch (IOException e1) {
e1.printStackTrace();
// 消息处理完成
LOGGER.info("【MQ-{}】站内信{} DeliveryTag:{} 处理成功", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, msg,message.getMessageProperties().getDeliveryTag());
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}catch (IOException e){
printErrorMessage(e,IOException.class, msg);
}catch (Exception e){
printErrorMessage(e,Exception.class, msg);
}
}
}
private void printErrorMessage(Exception e,Class zlass,SysMessage msg){
Long time = System.currentTimeMillis();
LOGGER.error("【MQ-{}】{} 异常代码:{} 消息内容{},处理出错:{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, time, zlass, msg, e.getMessage());
LOGGER.info("【MQ-{}】{} 异常代码:{} 消息内容{},处理出错:{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, time, zlass, msg, e.getMessage());
e.printStackTrace();
//TODO MQ发生异常邮件通知 。
SysMessage sysMessage = new SysMessage();
sysMessage.setMessageSenderNameRdd("系统管理员");
sysMessage.setMessageTitle("【IMPP-MQ异常】站内信消息推送失败");
sysMessage.setMessageContent("推送站内信["+zlass+"]错误异常代码:"+time);
sysMessage.setMessageContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getValue());
sysMessage.setMessageSendTime(TimeTool.getNowTime(true));
sysMessage.setIsSystem(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue());
sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.EXTERNAL.getValue());
sysMessage.setMessageReceiversNameRdd("yunhao.wang@estsh.com,wei.peng@estsh.com");
rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE,sysMessage);
}
// /**
// * 站内信处理队列
// *
// * @param msg
// * @param channel
// * @param message 发送rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....));
// */
// @RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE)
// public void processImppMessage(SysMessage msg, Channel channel, Message message) {
// try {
// LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功{}", msg);
//
// msg = sysMessageService.insertSysMessage(msg);
//
// LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功{}", msg);
//
// // 收件人信息
// String[] messageReceiver = new String[0];
// String[] receiverName = new String[0];
// if (msg.getMessageReceiversId() != null) {
// messageReceiver = msg.getMessageReceiversId().split(",");
// receiverName = new String[messageReceiver.length];
// }
//
// SysRefUserMessage refUserMessage;
// SysUser sysUser;
// List<SysRefUserMessage> userMessage;
// ObjectMapper mapper = new ObjectMapper();
//
// for (int i = 0; i < messageReceiver.length; i++) {
// sysUser = sysUserService.getSysUserById(Long.parseLong(messageReceiver[i]));
// if(sysUser != null) {
// receiverName[i] = sysUser.getUserName();
//
// refUserMessage = new SysRefUserMessage();
// refUserMessage.setMessageId(msg.getId());
// refUserMessage.setMessageTitleRdd(msg.getMessageTitle());
// refUserMessage.setMessageTypeRdd(msg.getMessageType());
// refUserMessage.setMessageSenderNameRdd(msg.getMessageSenderNameRdd());
// refUserMessage.setReceiverId(sysUser.getId());
// refUserMessage.setReceiverNameRdd(sysUser.getUserName());
// refUserMessage.setMessageStatus(ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
// refUserMessage.setReceiverTime(TimeTool.getNowTime(true));
// refUserMessage.setIsUrgent(msg.getIsUrgent());
//
// sysMessageService.insertSysRefUserMessage(refUserMessage);
//
// userMessage = sysMessageService.findSysRefUserMessageByUserIdAndStatus(sysUser.getId(),
// ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
// MessageWebSocket.sendMessage(sysUser.getUserInfoId(),
// mapper.writeValueAsString(userMessage)
// );
// }
// }
//
// msg.setMessageReceiversNameRdd(StringUtils.join(receiverName, ","));
// sysMessageService.updateSysMessage(msg);
//
// //信息已处理
// channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
// } catch (IOException e) {
// LOGGER.error("【MQ-IMPP_MESSAGE_LETTER_QUEUE】处理出错{}", e.getMessage(), e);
// //丢弃这条消息
// try {
// // 未成功处理,重新发送
// channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
// } catch (IOException e1) {
// e1.printStackTrace();
// }
// }
// }
}

@ -0,0 +1,66 @@
package cn.estsh.i3plus.core.apiservice.mq;
import cn.estsh.i3plus.core.api.iservice.busi.IPersonnelService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
import cn.estsh.i3plus.core.apiservice.websocket.MessageWebSocket;
import cn.estsh.i3plus.platform.common.tool.StringTool;
import cn.estsh.i3plus.platform.common.tool.TimeTool;
import cn.estsh.i3plus.platform.common.util.PlatformConstWords;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysRefUserMessage;
import cn.estsh.i3plus.pojo.platform.bean.SysUser;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.rabbitmq.client.Channel;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnExpression;
import org.springframework.stereotype.Component;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2018-11-15 22:35
* @Modify:
**/
@Component
@RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK)
public class MessageLetterQueueReceiverHandler {
private static final Logger LOGGER = LoggerFactory.getLogger(MessageLetterQueueReceiverHandler.class);
@RabbitHandler
public void handleMessage(byte[] message){
LOGGER.info("【MQ-{}】handleMessage(byte[] message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(byte[] message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(byte[] message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
}
@RabbitHandler
public void handleMessage(String message){
LOGGER.info("【MQ-{}】handleMessage(String message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(String message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(String message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
}
@RabbitHandler
public void handleMessage(SysMessage message){
LOGGER.info("【MQ-{}】handleMessage(SysMessage message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(SysMessage message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
LOGGER.info("【MQ-{}】handleMessage(SysMessage message) 数据接收成功:{}",PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK, message);
}
}

@ -107,6 +107,7 @@ public class MessageMailQueueReceiver {
sysMessageService.updateSysMessage(msg);
}
}
//信息已处理
channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
}catch (NullPointerException e){
@ -116,7 +117,10 @@ public class MessageMailQueueReceiver {
//丢弃这条消息
try {
// 未成功处理,重新发送
channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true);
//channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true);
//todo 此处对邮件持久化,通过参数设置,是否还需要重复重新发送
// 改为接收成功
channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);
} catch (IOException e1) {
e1.printStackTrace();
}

@ -0,0 +1,29 @@
package cn.estsh.i3plus.core.apiservice.schedulejob;
import cn.estsh.impp.framework.base.schedule.BaseImppScheduleJob;
import cn.estsh.impp.framework.boot.init.ApplicationProperties;
import io.swagger.annotations.ApiOperation;
import org.quartz.JobExecutionContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* @Description :
* @Reference :
* @Author : alwaysfrin
* @CreateDate : 2019-03-12 17:51
* @Modify:
**/
@ApiOperation("测试微服定时任务demo")
public class DemoCloudJob extends BaseImppScheduleJob {
public static final Logger LOGGER = LoggerFactory.getLogger(DemoJob.class);
public DemoCloudJob() {
super(DemoJob.class,"测试微服定时任务demo");
}
@Override
public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) {
System.out.println("==============测试微服定时任务demo===========");
}
}

@ -24,13 +24,9 @@ public class WmsDualTransStockJob extends BaseImppScheduleJob {
super(WmsDualTransStockJob.class,"定时处理库存移动单信息");
}
@Autowired
private IWmsScheduleJobCloud scheduleJobCloud;
@Override
public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) {
System.out.println("定时任务被执行");
LOGGER.info("projectName{},port:{}",applicationProperties.getApplicationName(),applicationProperties.getServerPort());
scheduleJobCloud.dualMovementJob();
}
}

@ -0,0 +1,103 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysBarcodeRuleService;
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.SysBarcodeRule;
import cn.estsh.i3plus.pojo.platform.repository.SysBarcodeRuleRepository;
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 io.swagger.annotations.ApiOperation;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-03-12 16:13
* @Modify:
**/
@Service
public class SysBarcodeRuleService implements ISysBarcodeRuleService {
public static final Logger LOGGER = LoggerFactory.getLogger(SysBarcodeRuleService.class);
@Autowired
private SysBarcodeRuleRepository sysBarcodeRuleRDao;
@Override
@ApiOperation(value = "新增条码规则信息")
public SysBarcodeRule insertSysBarcodeRule(SysBarcodeRule barcodeRule) {
// 数据校验
if (sysBarcodeRuleRDao.isExitByProperty("barcodeRuleCode",barcodeRule.getBarcodeRuleCode())) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("规则代码已存在")
.setErrorSolution("请重新输入规则代码")
.build();
}
return sysBarcodeRuleRDao.insert(barcodeRule);
}
@Override
@ApiOperation(value = "更新条码规则信息")
public void updateSysBarcodeRule(SysBarcodeRule barcodeRule) {
List list = sysBarcodeRuleRDao.findByHqlWhere(CoreHqlPack.packHqlSysBarcodeRuleCode(barcodeRule));
if (list.size() > 0) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("规则代码已存在")
.setErrorSolution("请重新输入规则代码")
.build();
}
sysBarcodeRuleRDao.update(barcodeRule);
}
@Override
@ApiOperation(value = "查询所有条码规则信息",notes = "查询所有条码规则信息")
public List<SysBarcodeRule> listSysBarcodeRule() {
return sysBarcodeRuleRDao.list();
}
@Override
@ApiOperation(value = "查询条码规则信息",notes = "根据ID查询条码规则信息")
public SysBarcodeRule getSysBarcodeRuleById(Long id) {
return sysBarcodeRuleRDao.getById(id);
}
@Override
@ApiOperation(value = "根据id删除条码规则",notes = "根据id删除条码规则")
public void deleteSysBarcodeRuleById(Long id) {
sysBarcodeRuleRDao.deleteById(id);
}
@Override
@ApiOperation(value = "根据规则代码查询条码规则",notes = "根据规则代码查询条码规则")
public SysBarcodeRule getSysBarcodeRuleByCode(String code) {
return sysBarcodeRuleRDao.getByProperty("barcodeRuleCode",code);
}
@Override
@ApiOperation(value = "根据规则代码查询条码规则",notes = "根据规则代码查询条码规则")
public ListPager<SysBarcodeRule> querySysBarcodeRuleByPager(SysBarcodeRule barcodeRule, Pager pager) {
if(barcodeRule == null) {
pager = PagerHelper.getPager(pager, sysBarcodeRuleRDao.listCount());
return new ListPager(sysBarcodeRuleRDao.listPager(pager),pager);
}else {
String hqlPack = CoreHqlPack.packHqlSysBarcodeRule(barcodeRule);
pager = PagerHelper.getPager(pager, sysBarcodeRuleRDao.findByHqlWhereCount(hqlPack));
return new ListPager(sysBarcodeRuleRDao.findByHqlWherePage(hqlPack + barcodeRule.orderBy(),pager),pager);
}
}
}

@ -40,9 +40,10 @@ public class SysDictionaryService implements ISysDictionaryService {
@Override
@ApiOperation(value = "添加字典")
public void insertSysDictionary(SysDictionary sysDictionary) {
long repeatCodeCount = sysDictionaryRDao.findByPropertyCount("dictionaryCode",sysDictionary.getDictionaryCode());
long repeatValueCount = sysDictionaryRDao.findByPropertyCount(new String[]{"parentId","dictionaryValue"},
new Object[]{sysDictionary.getParentId(),sysDictionary.getDictionaryValue()});
long repeatCodeCount = sysDictionaryRDao.findByPropertyCount(new String[]{"dictionaryCode", "softType"},
new Object[]{sysDictionary.getDictionaryCode(), sysDictionary.getSoftType()});
long repeatValueCount = sysDictionaryRDao.findByPropertyCount(new String[]{"parentId", "dictionaryValue", "softType"},
new Object[]{sysDictionary.getParentId(), sysDictionary.getDictionaryValue(), sysDictionary.getSoftType()});
if (repeatCodeCount > 0 || repeatValueCount > 0){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
@ -87,8 +88,8 @@ public class SysDictionaryService implements ISysDictionaryService {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_EXIT.getCode())
.setErrorDetail("字典代码已存在")
.setErrorSolution("请重新输入字典代码")
.setErrorDetail("字典代码或字典值已存在")
.setErrorSolution("请重新输入字典代码或字典值")
.build();
}
@ -132,9 +133,9 @@ public class SysDictionaryService implements ISysDictionaryService {
@Override
@ApiOperation(value = "根据父级代码查询字典项信息")
public List<SysDictionary> findSysDictionaryByParentCode(String parentCode) {
public List<SysDictionary> findSysDictionaryBySoftTypeAndParentCode(Integer softType,String parentCode) {
LOGGER.info("字典 SYS_DICTIONARY parentCode:{}",parentCode);
return sysDictionaryRDao.findByProperty("parentCodeRdd",parentCode);
return sysDictionaryRDao.findByProperty(new String[]{"softType", "parentCodeRdd"}, new Object[]{softType, parentCode});
}
@Override
@ -173,7 +174,8 @@ public class SysDictionaryService implements ISysDictionaryService {
@Override
@ApiOperation(value = "检出文件名称是否符合系统规范")
public boolean checkFileName(String fileName) {
List<SysDictionary> list = findSysDictionaryByParentCode(BaseConstWords.DICTIONARY_FILE_TYPE);
List<SysDictionary> list = findSysDictionaryBySoftTypeAndParentCode(CommonEnumUtil.SOFT_TYPE.CORE.getValue(),
BaseConstWords.DICTIONARY_FILE_TYPE);
if(list != null && list.size()> 0){
String suffix = StringTool.getStringFileSuffix(fileName,true);

@ -0,0 +1,173 @@
package cn.estsh.i3plus.core.apiservice.serviceimpl.busi;
import cn.estsh.i3plus.core.api.iservice.busi.ISysLabelTemplateService;
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
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.base.tool.HqlPack;
import cn.estsh.i3plus.pojo.model.platform.LabelTemplateModel;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplate;
import cn.estsh.i3plus.pojo.platform.bean.SysLabelTemplateParam;
import cn.estsh.i3plus.pojo.platform.repository.SysLabelTemplateParamRepository;
import cn.estsh.i3plus.pojo.platform.repository.SysLabelTemplateRepository;
import cn.estsh.i3plus.pojo.platform.sqlpack.CoreHqlPack;
import cn.estsh.impp.framework.boot.auth.AuthUtil;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import io.swagger.annotations.ApiOperation;
import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @Description :
* @Reference :
* @Author : siliter
* @Date : 2019-03-18 9:25
* @Modify :
**/
@Service
public class SysLabelTemplateService implements ISysLabelTemplateService {
public static final Logger LOGGER = LoggerFactory.getLogger(SysLabelTemplateService.class);
@Autowired
private SysLabelTemplateRepository sysLabelTemplateRDao;
@Autowired
private SysLabelTemplateParamRepository sysLabelTemplateParamRDao;
@Override
@ApiOperation(value = "添加打印模板",notes = "添加打印模板")
public void insertSysLabelTemplate(SysLabelTemplate sysLabelTemplate) {
// 根据模板代码进行唯一性校验
int count = sysLabelTemplateRDao.findByHqlWhereCount(CoreHqlPack.packHqlSysLabelTemplate(sysLabelTemplate));
if (count > 0) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("打印模板已存在")
.setErrorSolution("请检查打印模板")
.build();
}
SysLabelTemplate insertResult = sysLabelTemplateRDao.insert(sysLabelTemplate);
// 新增打印模板成功
if (insertResult != null) {
// 判断模板参数是否存在,存在就进行数据操作
String paramPack = sysLabelTemplate.getParamsPack();
if (StringUtils.isNotBlank(paramPack)) {
// 新增打印模板参数
SysLabelTemplateParam templateParam;
String[] paramArr = paramPack.trim().split(",");
for (String paramItem : paramArr) {
templateParam = new SysLabelTemplateParam();
templateParam.setTemplateCode(sysLabelTemplate.getTemplateCode());
templateParam.setTemplateId(insertResult.getId());
templateParam.setTemplateParam(paramItem);
templateParam.setTemplateParamText(paramItem);
ConvertBean.serviceModelInitialize(templateParam, AuthUtil.getSessionUser().getUserName());
sysLabelTemplateParamRDao.insert(templateParam);
}
}
}
}
@Override
@ApiOperation(value = "删除打印模板",notes = "删除打印模板")
public void deleteSysLabelTemplateById(Long id) {
sysLabelTemplateRDao.deleteById(id);
}
@Override
@ApiOperation(value = "修改打印模板",notes = "修改打印模板")
public void updateSysLabelTemplate(SysLabelTemplate sysLabelTemplate) {
SysLabelTemplate updateBefore = sysLabelTemplateRDao.getById(sysLabelTemplate.getId());
if (updateBefore == null) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.WMS.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("打印模板不存在")
.build();
}
//暂时根据id和模板代码作为唯一性校验
StringBuffer where = new StringBuffer();
HqlPack.getNumNOEqualPack(sysLabelTemplate.getId(), "id", where);
HqlPack.getStringEqualPack(sysLabelTemplate.getTemplateCode(), "templateCode", where);
int count = sysLabelTemplateRDao.findByHqlWhereCount(where.toString());
if (count > 0) {
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION_DATA_NOT_EXIT.getCode())
.setErrorDetail("打印模板已存在")
.setErrorSolution("请检查打印模板")
.build();
}
// 更新打印模板
sysLabelTemplateRDao.update(sysLabelTemplate);
// 判断模板参数是否存在,存在就进行数据操作
if (StringUtils.isNotBlank(sysLabelTemplate.getParamsPack())) {
// 更新打印模板参数
SysLabelTemplateParam templateParam;
String[] paramArr = sysLabelTemplate.getParamsPack().trim().split(",");
for (String paramItem : paramArr) {
templateParam = new SysLabelTemplateParam();
templateParam.setTemplateCode(sysLabelTemplate.getTemplateCode());
templateParam.setTemplateParam(paramItem);
templateParam.setTemplateId(sysLabelTemplate.getId());
templateParam.setTemplateParamText(paramItem);
ConvertBean.serviceModelUpdate(templateParam, AuthUtil.getSessionUser().getUserName());
sysLabelTemplateParamRDao.update(templateParam);
}
}
}
@Override
@ApiOperation(value = "查询打印模板",notes = "查询打印模板")
public List<SysLabelTemplate> ListSysLabelTemplate() {
return sysLabelTemplateRDao.list();
}
@Override
@ApiOperation(value = "根据编号打印模板",notes = "根据编号打印模板")
public SysLabelTemplate getSysLabelTemplateById(Long id) {
return sysLabelTemplateRDao.getById(id);
}
@Override
@ApiOperation(value = "复杂分页查询打印模板",notes = "复杂分页查询打印模板")
public ListPager querySysLabelTemplateByPager(SysLabelTemplate sysLabelTemplate, Pager pager) {
if(sysLabelTemplate == null) {
pager = PagerHelper.getPager(pager, sysLabelTemplateRDao.listCount());
return new ListPager(sysLabelTemplateRDao.listPager(pager),pager);
}else {
String hqlPack = CoreHqlPack.packHqlSysLabelTemplate(sysLabelTemplate);
pager = PagerHelper.getPager(pager, sysLabelTemplateRDao.findByHqlWhereCount(hqlPack));
return new ListPager(sysLabelTemplateRDao.findByHqlWherePage(hqlPack + sysLabelTemplate.orderBy(), pager), pager);
}
}
@Override
@ApiOperation(value = "根据模板编号查询模板参数",notes = "根据模板编号查询模板参数")
public List<SysLabelTemplateParam> listSysLabelTemplateParam(String labelTemplateId) {
SysLabelTemplateParam templateParam = new SysLabelTemplateParam();
templateParam.setTemplateId(Long.parseLong(labelTemplateId));
return sysLabelTemplateParamRDao.findByHqlWhere(CoreHqlPack.packHqlSysLabelTemplateParams(templateParam));
}
@Override
public LabelTemplateModel getLabelTemplateInfoById(String labelTemplateId) {
LabelTemplateModel templateModel = new LabelTemplateModel();
templateModel.setLabelTemplate(sysLabelTemplateRDao.getById(Long.parseLong(labelTemplateId)));
templateModel.setTemplateParamList(listSysLabelTemplateParam(labelTemplateId));
return templateModel;
}
}

@ -64,6 +64,13 @@ public class SysMessageService implements ISysMessageService {
}
@Override
@ApiOperation(value = "添加消息")
public List<SysMessage> insertSysMessage(List<SysMessage> list) {
return sysMessageRDao.saveAll(list);
}
@Override
@ApiOperation(value = "删除消息")
public void deleteSysMessageById(Long id) {
LOGGER.info("消息 SYS_MESSAGE id:{}",id);
@ -120,6 +127,12 @@ public class SysMessageService implements ISysMessageService {
}
@Override
@ApiOperation(value = "添加用户消息关系")
public List<SysRefUserMessage> insertSysRefUserMessage(List<SysRefUserMessage> refList) {
return sysRefUserMessageRDao.saveAll(refList);
}
@Override
@ApiOperation(value = "添加消息并发送")
public void doSendSysMessage(SysMessage sysMessage) {
// 判断消息类型推送到对应的队列
@ -127,6 +140,7 @@ public class SysMessageService implements ISysMessageService {
rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE,sysMessage);
}else{
rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE,sysMessage);
rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK,sysMessage);
}
}

@ -0,0 +1,76 @@
package cn.estsh.i3plus.core.apiservice.util;
import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.platform.bean.SysBarcodeRule;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum;
import java.util.HashMap;
import java.util.Map;
/**
* @Description :
* @Reference :
* @Author : yunhao
* @CreateDate : 2019-03-12 14:41
* @Modify:
**/
public class BarcodeParseUtil {
/**
*
* @param barcodeRule
* @param barcode
* @return
*/
public static Map<String,String> parse(SysBarcodeRule barcodeRule,String barcode){
// 数据有效性校验
if(barcodeRule == null || barcode == null){
return null;
}else if(barcodeRule.getBarcodeRule() == null || barcodeRule.getBarcodeSeparator() == null){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("条码规则不完善!")
.build();
}
//特殊分隔符处理
barcodeRule.setBarcodeSeparator(barcodeRule.getBarcodeSeparator().replaceAll("\\\\","\\\\\\\\"));
barcodeRule.setBarcodeSeparator(barcodeRule.getBarcodeSeparator().replaceAll("\\|","\\\\|"));
barcodeRule.setBarcodeSeparator(barcodeRule.getBarcodeSeparator().replaceAll("\\.","\\\\."));
// 分隔条码信息
String[] barcodeKey = barcodeRule.getBarcodeRule().split(barcodeRule.getBarcodeSeparator());
String[] barcodeValue = barcode.split(barcodeRule.getBarcodeSeparator());
if(barcodeKey.length != barcodeValue.length){
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("条码与规则不匹配!")
.build();
}
// 匹配条码数据
HashMap<String,String> barcodeMap = new HashMap<>();
for (int i = 0; i < barcodeKey.length; i++) {
barcodeMap.put(barcodeKey[i],barcodeValue[i]);
}
return barcodeMap;
}
public static void main(String[] args) {
SysBarcodeRule barcodeRule = new SysBarcodeRule();
barcodeRule.setName("测试条码规则");
barcodeRule.setBarcodeRuleCode("Barcode");
barcodeRule.setBarcodeRule("SN\\ORGANIZE_CODE\\PART_NO\\QTY\\UNIT");
barcodeRule.setBarcodeSeparator("\\");
barcodeRule.setBarcodeRuleDescription("描述");
Map barcode= parse(barcodeRule,"99\\99\\99\\99\\99");
System.out.println(barcode);
}
}

@ -1,8 +1,11 @@
package cn.estsh.i3plus.core.apiservice.websocket;
import cn.estsh.i3plus.pojo.base.codemaker.SnowflakeIdMaker;
import org.apache.commons.lang.StringEscapeUtils;
import org.apache.commons.lang3.RandomStringUtils;
import java.util.Random;
/**
* @Description :
* @Reference :
@ -16,5 +19,38 @@ public class TestMain {
System.out.println(RandomStringUtils.random(15, true, false));
// StringEscapeUtils.escapeHtml();
/*long workerIdBits = 5L;
long maxWorkerId = -1L ^ (-1L << workerIdBits);
System.out.println("5 --> "+maxWorkerId);
workerIdBits = 6L;
maxWorkerId = -1L ^ (-1L << workerIdBits);
System.out.println("6 --> "+maxWorkerId);
workerIdBits = 8L;
maxWorkerId = -1L ^ (-1L << workerIdBits);
System.out.println("8 --> " + maxWorkerId);*/
int wId = new Random().nextInt(29) + 1;
System.out.println("random id -> "+wId);
SnowflakeIdMaker m = new SnowflakeIdMaker(wId,3);
m = new SnowflakeIdMaker(wId,3);
int i = 0;
long id;
int c = 0;
long l1 = System.currentTimeMillis();
while(i < 1000){
if(m.nextId() < 0) {
System.out.println("======="+m.nextId());
c++;
}else{
//System.out.println(m.nextId());
}
i++;
}
System.out.println("耗时:" + (System.currentTimeMillis()-l1));
System.out.println("====end====error:" + c);
}
}

Loading…
Cancel
Save