From bb386b5032505dce071247a99dce6cab77d849b3 Mon Sep 17 00:00:00 2001 From: crish <570360737@qq.com> Date: Fri, 23 Aug 2019 09:58:11 +0800 Subject: [PATCH 01/11] =?UTF-8?q?=E6=9D=83=E9=99=90=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: crish <570360737@qq.com> --- .../java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java index 91b32b0..94a6841 100644 --- a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java +++ b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java @@ -3,7 +3,7 @@ package cn.estsh.i3plus.core.api.iservice.base; /** * @Description : service服务，根据方法名自动添加事务 * @Reference : - * @Author : alwaysfrin + * @Author : alwaysfrin看看就 * @CreateDate : 2018-09-04 16:57 * @Modify: **/ From 910cd25d8f352cd95944c83356b68f3367cc44ac Mon Sep 17 00:00:00 2001 From: "wei.peng" <123456> Date: Fri, 23 Aug 2019 20:11:49 +0800 Subject: [PATCH 02/11] =?UTF-8?q?=E5=BC=82=E5=B8=B8=E5=9B=BD=E9=99=85?= =?UTF-8?q?=E5=8C=96=E5=8A=9F=E8=83=BD=E5=BC=80=E5=8F=91=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/api/iservice/base/IDataSimpleService.java | 42 --- .../iservice/busi/ISysLocaleResourceService.java | 8 + .../controller/DemoRedisMqController.java | 372 --------------------- .../core/apiservice/dao/IMachineFactoryDao.java | 36 -- .../core/apiservice/mq/I3CoreQueueConfig.java | 118 ++----- .../core/apiservice/mq/I3CoreQueueReceiver.java | 109 +----- .../apiservice/mq/MessageLetterQueueReceiver.java | 22 +- .../apiservice/mq/MessageMailQueueReceiver.java | 8 +- .../mq/MessageSWebNoticeQueueReceiver.java | 7 +- .../apiservice/mq/MessageTestQueueReceiver.java | 43 +++ .../core/apiservice/mq/ScheduleQueueReceiver.java | 10 +- .../core/apiservice/mq/SysLocalResourceQueue.java | 115 +++++++ .../serviceimpl/base/DataSimpleService.java | 55 --- .../serviceimpl/busi/SysLocaleResourceService.java | 13 + .../serviceimpl/busi/SysMessageService.java | 7 +- 15 files changed, 230 insertions(+), 735 deletions(-) delete mode 100644 modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java delete mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java delete mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/IMachineFactoryDao.java create mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageTestQueueReceiver.java create mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/SysLocalResourceQueue.java delete mode 100644 modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/DataSimpleService.java diff --git a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java deleted file mode 100644 index 94a6841..0000000 --- a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/base/IDataSimpleService.java +++ /dev/null @@ -1,42 +0,0 @@ -package cn.estsh.i3plus.core.api.iservice.base; - -/** - * @Description : service服务，根据方法名自动添加事务 - * @Reference : - * @Author : alwaysfrin看看就 - * @CreateDate : 2018-09-04 16:57 - * @Modify: - **/ -public interface IDataSimpleService { - - //void saveMachineFactory(MachineFactory machineFactory); - - /*@Transactional - void updateMachineFactoryNameById(long id, String factoryName); - - @Transactional - void deleteMachineFactoryById(long id); - - *//** - * 根据工厂名称查询 - * @param factoryName - * @return - *//* - @Transactional(readOnly = true) - List findMachineFactoryByFactoryName(String factoryName); - - *//** - * 根据code查询 - * @param factoryCode - * @return - *//* - @Transactional(readOnly = true) - List findMachineFactoryByFactoryCode(String factoryCode); - - *//** - * 特殊查询 - * @return - *//* - @Transactional(readOnly = true) - List findMachineFactorySpecial();*/ -} diff --git a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLocaleResourceService.java b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLocaleResourceService.java index a778186..77293da 100644 --- a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLocaleResourceService.java +++ b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLocaleResourceService.java @@ -19,6 +19,9 @@ public interface ISysLocaleResourceService { @ApiOperation(value = "新增系统资源",notes = "新增系统资源") SysLocaleResource insertSysLocaleResource(SysLocaleResource sysLocaleResource); + @ApiOperation(value = "保存系统资源",notes = "保存系统资源") + List saveSysLocaleResource(List list); + @ApiOperation(value = "修改系统资源",notes = "修改系统资源") void updateSysLocaleResource(SysLocaleResource sysLocaleResource); @@ -40,6 +43,11 @@ public interface ISysLocaleResourceService { @ApiOperation(value = "根据语言code和资源key查询资源") SysLocaleResource getSysLocaleResourceByLanguageCodeAndResKey(String languageCode,String resKey); + @ApiOperation(value = "根据资源key查询资源") + List findSysLocaleResourceByResKey(String resKey); + @ApiOperation(value = "根据id查询资源") SysLocaleResource getSysLocaleResourceById(Long id); + + } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java deleted file mode 100644 index 28ce40d..0000000 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/DemoRedisMqController.java +++ /dev/null @@ -1,372 +0,0 @@ -package cn.estsh.i3plus.core.apiservice.controller; - -import cn.estsh.i3plus.core.api.iservice.busi.ISysRoleService; -import cn.estsh.i3plus.core.apiservice.mq.I3CoreQueueConfig; -import cn.estsh.i3plus.core.apiservice.thread.CoreDemoThread; -import cn.estsh.i3plus.platform.common.util.CommonConstWords; -import cn.estsh.i3plus.platform.common.util.PlatformConstWords; -import cn.estsh.i3plus.platform.common.util.QueueConstWords; -import cn.estsh.i3plus.pojo.base.common.Pager; -import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; -import cn.estsh.i3plus.pojo.model.test.TestConstructModel; -import cn.estsh.i3plus.pojo.platform.bean.SessionUser; -import cn.estsh.i3plus.pojo.platform.bean.SysRole; -import cn.estsh.i3plus.pojo.platform.bean.TestTransUser; -import cn.estsh.impp.framework.base.controller.CoreBaseController; -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 cn.estsh.impp.framework.boot.thread.ImppThreadPool; -import cn.estsh.impp.framework.boot.util.ImppRedis; -import cn.estsh.impp.framework.boot.util.ResultBean; -import com.rabbitmq.client.Channel; -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiOperation; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.amqp.core.Message; -import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; -import org.springframework.amqp.rabbit.connection.ConnectionFactory; -import org.springframework.amqp.rabbit.core.RabbitTemplate; -import org.springframework.amqp.rabbit.listener.RabbitListenerEndpointRegistry; -import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.context.i18n.LocaleContextHolder; -import org.springframework.web.bind.annotation.GetMapping; -import org.springframework.web.bind.annotation.RequestMapping; -import org.springframework.web.bind.annotation.RestController; - -import javax.annotation.Resource; -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; -import java.util.Locale; -import java.util.Set; -import java.util.concurrent.TimeoutException; - -/** - * @Description : - * @Reference : - * @Author : alwaysfrin - * @CreateDate : 2018-09-26 10:34 - * @Modify: - **/ -@RestController -@Api(description="复杂对象服务demo") -@RequestMapping("/demo-redis-mq") -public class DemoRedisMqController extends CoreBaseController{ - private static final Logger LOGGER = LoggerFactory.getLogger(DemoRedisMqController.class); - - /** - * 缓存 - */ - @Resource(name = CommonConstWords.IMPP_REDIS_CORE) - private ImppRedis redisCore; - - /** - * rabbitMQ队列 - */ - //@Autowired - //private AmqpTemplate rabbitTemplate; - @Autowired - private RabbitTemplate rabbitTemplate; - - @Autowired - private ISysRoleService sysRoleService; - - @Autowired - private RabbitListenerEndpointRegistry rabbitRegistry; - - @Autowired - private ConnectionFactory connectionFactory; - - /** - * mq工厂，用于生产ack消息 - */ - @Autowired - private CachingConnectionFactory mqFactory; - - @GetMapping(value="/get-mq-info") - @ApiOperation(value="获取队列信息") - public ResultBean getMqInfo(){ - System.out.println(rabbitRegistry.isAutoStartup() + " " + rabbitRegistry.isRunning()); - System.out.println(mqFactory.isPublisherConfirms() + " " + mqFactory.isPublisherReturns()); - System.out.println(connectionFactory); - - Set ids = rabbitRegistry.getListenerContainerIds(); - for(String id : ids){ - System.out.println("id = "+id); - } - - return new ResultBean(true); - } - - @GetMapping(value="/put-cache") - @ApiOperation(value="缓存",notes="放入数据") - public ResultBean putCache(){ - //放入缓存 - //redisCore.putObject("machineFactory",new MachineFactory("111","nnnn")); - redisCore.putObject("wms","123123123"); - - return new ResultBean(true,"已放入缓存"); - } - - @GetMapping(value="/get-cache") - @ApiOperation(value="缓存",notes="获取数据") - public ResultBean getCache(String name){ - System.out.println("===== " + redisCore.getObject(name)); - - return new ResultBean(true,redisCore.getObject(name)); - } - - @GetMapping(value="/exception-demo") - @ApiOperation(value="异常demo",notes="异常demo") - public ResultBean exceptionDemp() throws IOException, TimeoutException { - String data = "true"; - - if("true".equals(data)) { - throw ImppExceptionBuilder.newInstance() - .setSystemID(CommonEnumUtil.SOFT_TYPE.WMS.getCode()) - .setErrorCode(ImppExceptionEnum.BUSINESS_EXCEPTION_DATA_ERROR.getCode()) - .setErrorDetail("aaa操作数据出错") - .setErrorSolution("检查数据完整性") - .build(); - } - return new ResultBean(true,"操作成功"); - } - - @GetMapping(value="/international") - @ApiOperation(value="国际化处理",notes="资源配置文件及国际化") - public ResultBean international() { - Locale locale = LocaleContextHolder.getLocale(); - System.out.println(locale.getLanguage() + " " + locale.getCountry()); - - return new ResultBean(true,"操作成功 ： " + locale.getLanguage() + " " + locale.getCountry()); - } - - @Resource(name= CommonConstWords.IMPP_REDIS_SESSION) - private ImppRedis redisSession; - - @GetMapping(value="/set-redis") - @ApiOperation(value="setredis") - public ResultBean setRedis(String key,String value) { - //redisSession.putObject(key,value); - //redisCore.putObject(key,value); - - - ResultBean rs = new ResultBean(true,"yes"); - rs.setPager(new Pager(100)); - redisSession.putObject("rs",rs); - redisCore.putObject("rs",rs); - - return new ResultBean(true,"操作成功 ： " + key + " : " + value); - } - - @GetMapping(value="/get-redis") - @ApiOperation(value="getredis") - public ResultBean getRedis(String key) { - Object d1 = redisSession.getObject(key); - System.out.println("redisSession-d1==" + d1); - Object d2 = redisCore.getObject(key); - - if(d1 != null) { - SessionUser sessionUser = AuthUtil.getSessionUser(); - System.out.println(sessionUser.toString()); - } - - System.out.println("redisCore-d2==" + d2); - System.out.println(d1 == null?"null":d1.toString()); - System.out.println(d2 == null?"null":d2.toString()); - return new ResultBean(true,"操作成功 ： " + d1 + " : " + d2); - } - - @GetMapping(value="/test-thread") - @ApiOperation(value="testThread") - public ResultBean testThread(String param) { - ImppThreadPool.getThreadExcutorService().execute(new CoreDemoThread(param)); - - return new ResultBean(true,"操作成功"); - } - - - - @GetMapping(value="/send-mq") - @ApiOperation(value="队列",notes="发送") - public ResultBean sendMQ(String data){ - String context = "hello : " + data; - - System.out.println("发送DEMO_STR_QUEUE数据 : " + context); - this.rabbitTemplate.convertAndSend(I3CoreQueueConfig.DEMO_STR_QUEUE, context); - - System.out.println("发送DEMO_HANDLE_QUEUE数据 : " + context); - this.rabbitTemplate.convertAndSend(I3CoreQueueConfig.DEMO_HANDLE_QUEUE, context); - - System.out.println("发送Object数据 : " + context); - //this.rabbitTemplate.convertAndSend(I3CoreQueueConfig.DEMO_OBJ_QUEUE, new MachineFactory("111mq","rabbit")); - - return new ResultBean(true,"操作成功"); - } - - @GetMapping(value="/get-mq-handle") - @ApiOperation(value="手动获取队列",notes="接收队列") - public ResultBean getHandleMQ(){ - Object data = this.rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_HANDLE_QUEUE); - if(data != null) { - LOGGER.info("获取队列数据：" + data); - } - - Object message = this.rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_STR_QUEUE); - if(message != null){ - LOGGER.info("获取str数据：" + data); - } - - message = this.rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_OBJ_QUEUE); - if(message != null){ - LOGGER.info("获取obj数据：" + data); - } - - return new ResultBean(true,""); - } - - /** - * 有确认或返回的队列 - * @param type - * @param data - * @return - * @throws IOException - * @throws TimeoutException - */ - @GetMapping(value="/send-returnmsg") - @ApiOperation(value="队列返回信息",notes="发送") - public ResultBean sendReturnMQ(int type,String data) throws IOException, TimeoutException { - if(type == 1) { - System.out.println("===== in confirm ========"); - rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> { - System.out.println("===ReturnSenderDemo ack==="+ack); - if (ack) { - System.out.println("ReturnSenderDemo:消息发送成功 "); - } else { - System.out.println("ReturnSenderDemo:" + cause + correlationData.toString()); - } - }); - }else{ - System.out.println("===== in return ========"); - rabbitTemplate.setReturnCallback((Message message, int i, String s, String s1, String s2) -> { - System.out.println("===ConfirmSenderDemo ack==="+message); - System.out.println("i=" + i + ",s=" + s + ",s1=" + s1 + ",s2=" + s2); - }); - } - String returnMsg = (String) rabbitTemplate.convertSendAndReceive(I3CoreQueueConfig.DEMO_RETURN_QUEUE, data); - System.out.println("===返回数据==="+returnMsg); - return new ResultBean(true,"操作成功"); - } - - /** - * 如果需要进行ack操作，需要添加RabbitListener方法 - * @return - * @throws IOException - * @throws TimeoutException - */ - @GetMapping(value="/send-ackmsg") - @ApiOperation(value="ack队列",notes="发送") - public ResultBean sendAckMQ(String data) throws IOException, TimeoutException { - System.out.println("发送ack数据 : " + data); - this.rabbitTemplate.convertAndSend(I3CoreQueueConfig.DEMO_ACK_QUEUE, data); - - return new ResultBean(true,"操作成功"); - } - - @GetMapping(value="/get-ackmsg") - @ApiOperation(value="getack队列",notes="接收") - public ResultBean getAckMQ() throws IOException, TimeoutException { - Channel channel = this.rabbitTemplate.getConnectionFactory().createConnection().createChannel(false); - LOGGER.info("channel = {}",channel); - String str = (String) rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_ACK_QUEUE); - LOGGER.info("str = {}",str); - - Message message = rabbitTemplate.receive(I3CoreQueueConfig.DEMO_ACK_QUEUE); - LOGGER.info("message = {}",message); - try { - /*String data = (String) this.rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_ACK_QUEUE); - System.out.println("【client】数据接收成功：" + data); - - if("ack".equals(data)){ - System.out.println("【client】数据抛出异常"); - throw new RuntimeException("【队列抛出异常】" + data); - }*/ - - String data = (String) this.rabbitTemplate.receiveAndConvert(I3CoreQueueConfig.DEMO_ACK_QUEUE); - System.out.println("【client】数据接收成功：" + data); - - if("ackack".equals(data)){ - System.out.println("【client】数据抛出异常"); - throw new RuntimeException("【队列抛出异常】" + data); - } - - //在队列删掉 不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发 - channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); - } catch (IOException e) { - e.printStackTrace(); - //丢弃这条消息 - // channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,false); - // System.out.println("receiver fail"); - try { - channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true); - } catch (IOException e1) { - e1.printStackTrace(); - } - } - return new ResultBean(true,"操作成功"); - } - - /** - * 发送角色至mq交换机 - * @return - * @throws IOException - * @throws TimeoutException - */ - @GetMapping(value="/send-mq-role") - @ApiOperation(value="发送角色信息队列",notes="发送") - public ResultBean sendRoleMQ(int sendCount) throws IOException, TimeoutException { - List roleList = sysRoleService.findSysRoleAll(); - LOGGER.info("共有角色数：{}",roleList.size()); - - //发送信息至通用交换机-》扇形交换 - SysRole sysRole; - for(int i=0;i()); - redisCore.putObject("model",model,100); - - return new ResultBean(true,"已放入缓存"); - } -} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/IMachineFactoryDao.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/IMachineFactoryDao.java deleted file mode 100644 index 9fe06fc..0000000 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/dao/IMachineFactoryDao.java +++ /dev/null @@ -1,36 +0,0 @@ -package cn.estsh.i3plus.core.apiservice.dao; - -/** - * @Description : hql申明查询demo - * 继承了crudrepository，包含了常用hql方法 - * @Reference : 如果需要执行原生sql，则添加 @Query(sql,nativeQuery=true) - * @Author : alwaysfrin - * @CreateDate : 2018-09-05 16:41 - * @Modify: - **/ -//@Repository -//public interface IMachineFactoryDao extends CrudRepository { - - //此处findBy开头，会自动根据属性名进行查询 - /*List findByFactoryName(String factoryName); - - @Modifying - @Query("update MachineFactory mf set mf.factoryName = :factoryName where mf.id = :id") - void updateMachineFactoryNameById(long id, String factoryName); - - @Modifying - @Query("delete from MachineFactory mf where id = :id") - void deleteMachineFactoryById(@Param("id") long id); - - //按位查询 - @Query("select mf from MachineFactory mf where factoryName = ?1") - List findMachineFactoryByFactoryName(String factoryName); - - //参数匹配 - @Query("from MachineFactory mf where mf.factoryCode = :factoryCode") - List findMachineFactoryByFactoryCode(@Param("factoryCode") String factoryCode); - - //自定义Hql - @Query("from MachineFactory mf where mf.createDatetime like '2018-01-01%'") - List findMachineFactorySpecial();*/ -//} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java index 78ca618..d3cd269 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueConfig.java @@ -7,6 +7,8 @@ import org.springframework.amqp.core.Queue; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import static cn.estsh.i3plus.platform.common.util.PlatformConstWords.QUEUE_IMPP_MESSAGE; + /** * @Description : wms队列 * @Reference : @@ -18,8 +20,6 @@ import org.springframework.context.annotation.Configuration; public class I3CoreQueueConfig { private static final Logger LOGGER = LoggerFactory.getLogger(I3CoreQueueConfig.class); - public static final String IMPP_MESSAGE_QUEUE = "IMPP_MESSAGE_QUEUE"; - /** * 开启平台消息队列 * @return 队列 @@ -27,136 +27,56 @@ public class I3CoreQueueConfig { @Bean public Queue getImppMessageQueue() { LOGGER.info("【开启平台消息队列】"); - return new Queue(IMPP_MESSAGE_QUEUE); - } - - /*********** 队列demo ***********/ - - public static final String DEMO_STR_QUEUE = "demo_str_queue"; - - /** - * DEMO字符串对象队列 - * @return 队列 - */ - @Bean - public Queue getStrQueue() { - //LOGGER.info("【DEMO_STR_QUEUE队列】"); - return new Queue(DEMO_STR_QUEUE); - } - - public static final String DEMO_OBJ_QUEUE = "demo_obj_queue"; - - /** - * DEMO对象队列 - * @return 队列 - * @throws Exception - */ - @Bean - public Queue getObjQueue() throws Exception { - //LOGGER.info("【DEMO_OBJ_QUEUE队列】"); - return new Queue(DEMO_OBJ_QUEUE); - } - - public static final String DEMO_HANDLE_QUEUE = "demo_handle_queue"; - - /** - * DEMO_HANDLE_QUEUE - * @return 队列 - * @throws Exception - */ - @Bean - public Queue getHandleQueue() throws Exception { - //LOGGER.info("【DEMO_HANDLE_QUEUE队列】"); - return new Queue(DEMO_HANDLE_QUEUE); + return new Queue(QUEUE_IMPP_MESSAGE); } - public static final String DEMO_ACK_QUEUE = "ack_queue"; - /** - * DEMO_ACK_QUEUE 队列 - * @return 处理结果 - * @throws Exception - */ - @Bean - public Queue getAckQueue() throws Exception { - //LOGGER.info("【DEMO_ACK_QUEUE队列】"); - return new Queue(DEMO_ACK_QUEUE); - } - - public static final String DEMO_RETURN_QUEUE = "return_queue"; - - /** - * DEMO_RETURN_QUEUE 队列 + * QUEUE_IMPP_MESSAGE_LETTER 队列 * @return 队列 * @throws Exception */ @Bean - public Queue getReturnQueue() throws Exception { - //LOGGER.info("【DEMO_RETURN_QUEUE队列】"); - return new Queue(DEMO_RETURN_QUEUE); + public Queue getQueueImppMessageLetterQueue(){ + return new Queue(PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER); } - //测试wms微服队列 - public static final String DEMO_CLOUD_WMS = "DEMO_CLOUD_WMS"; - /** - * DEMO_CLOUD_WMS + * QUEUE_IMPP_MESSAGE_MAIL 队列 * @return 队列 * @throws Exception */ @Bean - public Queue getDemoCloudWmsQueue() throws Exception { - //LOGGER.info("【DEMO_CLOUD_WMS】"); - return new Queue(DEMO_CLOUD_WMS); + public Queue getQueueImppMessageMailQueue(){ + return new Queue(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL); } /** - * IMPP_MESSAGE_LETTER_QUEUE 队列 + * QUEUE_SWEB_NOTICE 队列 * @return 队列 * @throws Exception */ @Bean - public Queue getQueueIMPP_MESSAGE_LETTER_QUEUE() throws Exception { - return new Queue(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE); + public Queue getQueueSwebNoticeQueue(){ + return new Queue(PlatformConstWords.QUEUE_SWEB_NOTICE); } /** - * IMPP_MESSAGE_LETTER_QUEUE_BAK 队列 + * QUEUE_IMPP_SCHEDULE * @return 队列 * @throws Exception */ @Bean - public Queue getQueueIMPP_MESSAGE_LETTER_QUEUE_BAK() throws Exception { - return new Queue(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK); + public Queue getQueueImppScheduleQueue(){ + return new Queue(PlatformConstWords.QUEUE_IMPP_SCHEDULE); } /** - * IMPP_MESSAGE_MAIL_QUEUE 队列 - * @return 队列 - * @throws Exception + * 资源国际化队列 + * @return */ @Bean - public Queue getQueueIMPP_MESSAGE_MAIL_QUEUE() throws Exception { - return new Queue(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE); + public Queue getQueueImppResource(){ + return new Queue(PlatformConstWords.QUEUE_IMPP_RESOURCE); } - /** - * SWEB_NOTICE_QUEUE 队列 - * @return 队列 - * @throws Exception - */ - @Bean - public Queue getQueueSWEB_NOTICE_QUEUE() throws Exception { - return new Queue(PlatformConstWords.SWEB_NOTICE_QUEUE); - } - - /** - * IMPP_SCHEDULE_QUEUE - * @return 队列 - * @throws Exception - */ - @Bean - public Queue getQueueIMPP_SCHEDULE_QUEUE() throws Exception { - return new Queue(PlatformConstWords.IMPP_SCHEDULE_QUEUE); - } } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueReceiver.java index b8eb338..e0438f7 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/I3CoreQueueReceiver.java @@ -1,6 +1,6 @@ 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; @@ -12,6 +12,8 @@ import org.springframework.stereotype.Component; import java.io.IOException; +import static cn.estsh.i3plus.platform.common.util.PlatformConstWords.QUEUE_IMPP_MESSAGE; + /** * @Description : 获取队列信息后处理 * @Reference : @@ -31,17 +33,17 @@ public class I3CoreQueueReceiver { * @param msg 消息 * @param channel 通道 * @param message 消息 - * 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....)); + * 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.QUEUE_IMPP_MESSAGE, new SysMessage(....)); */ - @RabbitListener(queues = I3CoreQueueConfig.IMPP_MESSAGE_QUEUE) + @RabbitListener(queues = QUEUE_IMPP_MESSAGE) public void processImppMessage(SysMessage msg, Channel channel, Message message) { try { - LOGGER.info("【MQ-IMPP_MESSAGE_QUEUE】数据接收成功：{}",msg); + LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE】数据接收成功：{}",msg); //信息已处理 channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); } catch (IOException e) { - LOGGER.error("【MQ-IMPP_MESSAGE_QUEUE】处理出错：{}",e.getMessage(),e); + LOGGER.error("【MQ-QUEUE_IMPP_MESSAGE】处理出错：{}",e.getMessage(),e); //丢弃这条消息 try { // 未成功处理，重新发送 @@ -52,101 +54,4 @@ 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 *******************/ - - /*@RabbitListener(queues = I3CoreQueueConfig.DEMO_STR_QUEUE) - public void getObjQueue(String data) { - System.out.println("接收数据 : " + data.toString()); - } - - @RabbitListener(queues = I3CoreQueueConfig.DEMO_OBJ_QUEUE) - public void getStrQueue(MachineFactory data) { - System.out.println("强转对象：" + data); - }*/ - - /*@RabbitListener(queues = I3CoreQueueConfig.DEMO_RETURN_QUEUE) - public Message processReturn(String data, Channel channel, Message message) { - try { - System.out.println("【client】数据接收成功：" + data); - Thread.sleep(1000); - - //告诉服务器收到这条消息 已经被我消费了 可以在队列删掉 这样以后就不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发 - //消息的标识，false只确认当前一个消息收到，true确认所有consumer获得的消息 - - channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); - } catch (Exception e) { - System.out.println("出现异常：" + e.getMessage()); - // 错误反馈 - // val1 = 是否批量.true:将一次性拒绝所有小于deliveryTag的消息。 - // val2 = 被拒绝的是否重新列入队列 - try { - channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,true); - } catch (IOException e1) { - e1.printStackTrace(); - } - //拒绝，同basicNack，只是没有批量这个属性 - //channel.basicReject(message.getMessageProperties().getDeliveryTag(),true); - } - Message returnMsg = null; - try { - returnMsg = new Message("---返回数据---".getBytes("UTF-8"), message.getMessageProperties()); - }catch(Exception e){ - e.printStackTrace(); - } - return message; - } - - @RabbitListener(queues = I3CoreQueueConfig.DEMO_ACK_QUEUE) - public void processAck(String data, Channel channel, Message message) { - try { - System.out.println("【client】数据接收成功：" + data); - - *//*if(data.startsWith("ack")){ - System.out.println("【client】数据抛出异常"); - throw new RuntimeException("【队列抛出异常】" + data); - }*//* - //在队列删掉 不会再发了 否则消息服务器以为这条消息没处理掉 后续还会在发 - channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); - } catch (IOException e) { - e.printStackTrace(); - //丢弃这条消息 - // channel.basicNack(message.getMessageProperties().getDeliveryTag(), false,false); - // System.out.println("receiver fail"); - try { - // - channel.basicNack(message.getMessageProperties().getDeliveryTag(),false,true); - } catch (IOException e1) { - e1.printStackTrace(); - } - } - }*/ } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageLetterQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageLetterQueueReceiver.java index 6a8720d..38a48dd 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageLetterQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageLetterQueueReceiver.java @@ -62,11 +62,11 @@ public class MessageLetterQueueReceiver { * @param data 消息主体 * @param channel 通道 * @param message 消息 - * 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....)); + * 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.QUEUE_IMPP_MESSAGE, new SysMessage(....)); */ - @RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE) + @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER) public void processImppMessage(String data, Channel channel, Message message) { - LOGGER.info("【MQ-{}】 数据接收成功：{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, data); + LOGGER.info("【MQ-{}】 数据接收成功：{}", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, data); SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); try { ConvertBean.serviceModelInitialize(msg, "system"); @@ -112,7 +112,7 @@ public class MessageLetterQueueReceiver { } // 消息处理完成 - LOGGER.info("【MQ-{}】站内信{} DeliveryTag:{} 处理成功", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, + LOGGER.info("【MQ-{}】站内信{} DeliveryTag:{} 处理成功", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, msg, message.getMessageProperties().getDeliveryTag()); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (IOException e) { @@ -131,7 +131,7 @@ public class MessageLetterQueueReceiver { private void printErrorMessage(Exception e, Class zlass, String msg) { Long time = System.currentTimeMillis(); - LOGGER.error("【MQ-{}】{} 异常代码:{} 消息内容{},处理出错：{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, time, zlass, msg, e.getMessage()); + LOGGER.error("【MQ-{}】{} 异常代码:{} 消息内容{},处理出错：{}", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, time, zlass, msg, e.getMessage()); e.printStackTrace(); //TODO 此处需要配置 @@ -144,7 +144,7 @@ public class MessageLetterQueueReceiver { 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, JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL, JSON.toJSONString(sysMessage)); } @@ -153,16 +153,16 @@ public class MessageLetterQueueReceiver { // * // * @param msg // * @param channel -// * @param message 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.IMPP_MESSAGE_QUEUE, new SysMessage(....)); +// * @param message 发送：rabbitTemplate.convertAndSend(I3CoreQueueConfig.QUEUE_IMPP_MESSAGE, new SysMessage(....)); // */ -// @RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE) +// @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER) // public void processImppMessage(SysMessage msg, Channel channel, Message message) { // try { -// LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功：{}", msg); +// LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE_LETTER】数据接收成功：{}", msg); // // msg = sysMessageService.insertSysMessage(msg); // -// LOGGER.info("【MQ-IMPP_MESSAGE_LETTER_QUEUE】数据接收成功：{}", msg); +// LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE_LETTER】数据接收成功：{}", msg); // // // 收件人信息 // String[] messageReceiver = new String[0]; @@ -209,7 +209,7 @@ public class MessageLetterQueueReceiver { // //信息已处理 // channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); // } catch (IOException e) { -// LOGGER.error("【MQ-IMPP_MESSAGE_LETTER_QUEUE】处理出错：{}", e.getMessage(), e); +// LOGGER.error("【MQ-QUEUE_IMPP_MESSAGE_LETTER】处理出错：{}", e.getMessage(), e); // //丢弃这条消息 // try { // // 未成功处理，重新发送 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java index bc3812a..8266d5c 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageMailQueueReceiver.java @@ -7,7 +7,6 @@ import cn.estsh.i3plus.core.apiservice.util.MailUtil; import cn.estsh.i3plus.platform.common.tool.JsonUtilTool; 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; @@ -15,7 +14,6 @@ import cn.estsh.i3plus.pojo.platform.bean.SysUser; import com.alibaba.fastjson.JSON; import com.rabbitmq.client.Channel; import org.apache.commons.lang3.StringUtils; -import org.apache.logging.log4j.core.util.JsonUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.amqp.core.Message; @@ -54,12 +52,12 @@ public class MessageMailQueueReceiver { * @param channel 通道 * @param message 消息 */ - @RabbitListener(queues = PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE) + @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL) public void processImppMail(String data, Channel channel, Message message) { SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); Long startTime = System.currentTimeMillis(); try { - LOGGER.info("【MQ-IMPP_MESSAGE_MAIL_QUEUE】数据接收成功：{}", msg); + LOGGER.info("【MQ-QUEUE_IMPP_MESSAGE_MAIL】数据接收成功：{}", msg); if (msg.getMessageSendTime() == null) { msg.setMessageSendTime(TimeTool.getNowTime(true)); } @@ -117,7 +115,7 @@ public class MessageMailQueueReceiver { //信息已处理 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (Exception e) { - LOGGER.error("【MQ-IMPP_MESSAGE_MAIL_QUEUE】处理出错：{}", e.getMessage(), e); + LOGGER.error("【MQ-QUEUE_IMPP_MESSAGE_MAIL】处理出错：{}", e.getMessage(), e); //丢弃这条消息 try { if(msg.getId() != null) { diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageSWebNoticeQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageSWebNoticeQueueReceiver.java index 3bb61ba..9c3b8a9 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageSWebNoticeQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageSWebNoticeQueueReceiver.java @@ -7,7 +7,6 @@ import cn.estsh.i3plus.platform.common.convert.ConvertBean; import cn.estsh.i3plus.platform.common.tool.JsonUtilTool; 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.SysFile; import cn.estsh.i3plus.pojo.platform.bean.SysFileAttach; @@ -59,9 +58,9 @@ public class MessageSWebNoticeQueueReceiver { * @param channel 通道 * @param message 消息 */ - @RabbitListener(queues = PlatformConstWords.SWEB_NOTICE_QUEUE) + @RabbitListener(queues = PlatformConstWords.QUEUE_SWEB_NOTICE) public void processImppMail(String data, Channel channel, Message message) { - LOGGER.info("【MQ-{}】 数据接收成功：{}", PlatformConstWords.SWEB_NOTICE_QUEUE, data); + LOGGER.info("【MQ-{}】 数据接收成功：{}", PlatformConstWords.QUEUE_SWEB_NOTICE, data); // 添加消息 SysMessage msg = JsonUtilTool.decode(data, SysMessage.class); try { @@ -132,7 +131,7 @@ public class MessageSWebNoticeQueueReceiver { } // 消息处理完成 - LOGGER.info("【MQ-{}】站内信{} DeliveryTag:{} 处理成功", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, + LOGGER.info("【MQ-{}】站内信{} DeliveryTag:{} 处理成功", PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, msg, message.getMessageProperties().getDeliveryTag()); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (Exception e) { diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageTestQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageTestQueueReceiver.java new file mode 100644 index 0000000..b842643 --- /dev/null +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/MessageTestQueueReceiver.java @@ -0,0 +1,43 @@ +//package cn.estsh.i3plus.core.apiservice.mq; +// +//import cn.estsh.i3plus.platform.common.util.PlatformConstWords; +//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.stereotype.Component; +// +//import java.util.Random; +// +///** +// * @Description : 邮件队列处理 +// * @Reference : +// * @Author : yunhao +// * @CreateDate : 2018-11-15 22:15 +// * @Modify: +// **/ +//@Component +//public class MessageTestQueueReceiver { +// private static final Logger LOGGER = LoggerFactory.getLogger(MessageTestQueueReceiver.class); +// Random random = new Random();//默认构造方法 +// +// /** +// * 系统邮件处理队列 +// * +// * @param data 系统消息信息 +// * @param channel 通道 +// * @param message 消息 +// */ +// @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER_BAK,exclusive = true,concurrency = "1") +// public void processImppMail(String data, Channel channel, Message message) { +// try { +// +// LOGGER.info("====>> {}" ,data); +// Thread.sleep(random.nextInt(100)); +// channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); +// }catch (Exception e){ +// e.printStackTrace(); +// } +// } +//} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java index cd8ec35..2bbe766 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java @@ -55,11 +55,11 @@ public class ScheduleQueueReceiver { * @param channel 通道 * @param message 消息 */ - @RabbitListener(queues = PlatformConstWords.IMPP_SCHEDULE_QUEUE) + @RabbitListener(queues = PlatformConstWords.QUEUE_IMPP_SCHEDULE) public void processSchedule(String data, Channel channel, Message message) { try { SysLogTaskTime logTaskTime = JsonUtilTool.decode(data, SysLogTaskTime.class); - LOGGER.info("【MQ-IMPP_SCHEDULE_QUEUE】数据接收成功：{}", logTaskTime); + LOGGER.info("【MQ-QUEUE_IMPP_SCHEDULE】数据接收成功：{}", logTaskTime); // 跟新最后执行时间 及 任务状态 SysTaskPlan taskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(logTaskTime.getName(), logTaskTime.getGroupName()); if (taskPlan != null) { @@ -112,9 +112,9 @@ public class ScheduleQueueReceiver { // 发送到对应处理队列 if (taskPlan.getNoticeMethod() != null && ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue() == taskPlan.getNoticeMethod().intValue()) { - rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE, JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL, JSON.toJSONString(sysMessage)); } else { - rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, JSON.toJSONString(sysMessage)); } } } @@ -122,7 +122,7 @@ public class ScheduleQueueReceiver { //信息已处理 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (IOException e) { - LOGGER.error("【MQ-IMPP_MESSAGE_MAIL_QUEUE】处理出错：{}", e.getMessage(), e); + LOGGER.error("【MQ-QUEUE_IMPP_MESSAGE_MAIL】处理出错：{}", e.getMessage(), e); //丢弃这条消息 try { // 未成功处理，重新发送 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/SysLocalResourceQueue.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/SysLocalResourceQueue.java new file mode 100644 index 0000000..212d064 --- /dev/null +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/SysLocalResourceQueue.java @@ -0,0 +1,115 @@ +package cn.estsh.i3plus.core.apiservice.mq; + +import cn.estsh.i3plus.core.api.iservice.base.ISystemInitService; +import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleLanguageService; +import cn.estsh.i3plus.core.api.iservice.busi.ISysLocaleResourceService; +import cn.estsh.i3plus.platform.common.tool.TimeTool; +import cn.estsh.i3plus.pojo.base.enumutil.BlockFormEnumUtil; +import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; +import cn.estsh.i3plus.pojo.platform.bean.SysLocaleLanguage; +import cn.estsh.i3plus.pojo.platform.bean.SysLocaleResource; +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.RabbitListener; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Component; + +import java.io.IOException; +import java.util.ArrayList; +import java.util.List; + +import static cn.estsh.i3plus.platform.common.util.PlatformConstWords.QUEUE_IMPP_RESOURCE; + + +/** + * @Description : + * @Reference : + * @Author : wei.peng + * @CreateDate : 19-8-23 下午3:12 + * @Modify: + **/ +@Component +public class SysLocalResourceQueue { + + private static final Logger LOGGER = LoggerFactory.getLogger(SysLocalResourceQueue.class); + + @Autowired + private ISysLocaleResourceService localeResourceService; + + @Autowired + private ISysLocaleLanguageService localeLanguageService; + + @Autowired + private ISystemInitService systemInitService; + + /** + * 语言反向国际化实现 + * + *
根据信息创建不同语言的国际化信息。 + *
当存在的时候不做任何操作，不存的时候创建全部语言的资源信息 + * + * @param resourceKey + * @param channel + * @param message + */ + @RabbitListener(queues = QUEUE_IMPP_RESOURCE) + public void processImppMessage(String resourceKey, Channel channel, Message message) { + try { + if(StringUtils.isNotBlank(resourceKey)){ + List list = localeLanguageService.listSysLocaleLanguage(); + if(list != null && list.size() > 0){ + List resourceList = localeResourceService.findSysLocaleResourceByResKey(resourceKey); + + List saveResource = new ArrayList<>(list.size()); + SysLocaleResource resource = null; + for (SysLocaleLanguage language : list) { + resource = null; + if(resourceList != null && resourceList.size() > 0){ + for (SysLocaleResource localeResource : resourceList) { + if(language.getLanguageCode() != null && language.getLanguageCode().equals(localeResource.getLanguageCode())){ + resource = localeResource; + } + } + }else { + resource = new SysLocaleResource(); + resource.setLanguageCode(language.getLanguageCode()); + resource.setLanguageNameRdd(language.getLanguageName()); + resource.setIsSystem(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()); + resource.setResourceType(CommonEnumUtil.SYS_LOCALE_RESOURCE_TYPE.EXCEPTION.getValue()); + resource.setResourceValue(resourceKey); + resource.setResourceKey(resourceKey); + + resource.setCreateDatetime(TimeTool.getNowTime(true)); + resource.setModifyDatetime(TimeTool.getNowTime(true)); + resource.setIsValid(CommonEnumUtil.IS_VAILD.VAILD.getValue()); //有效 + resource.setIsDeleted(CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue()); //未删除 + } + + if(resource != null){ + saveResource.add(resource); + } + } + + if(saveResource != null && saveResource.size() > 0){ + localeResourceService.saveSysLocaleResource(saveResource); + systemInitService.putAndLoadSysLocaleLanguage(); + } + } + } + }catch (Exception e){ + e.printStackTrace(); + }finally { + try { + channel.basicAck(message.getMessageProperties().getDeliveryTag(),false); + LOGGER.info("[MQ ACK] Tag :{} Completed successfully",message.getMessageProperties().getDeliveryTag()); + } catch (IOException e) { + LOGGER.error("[MQ ERROR] MQ Ack Error Message:{}",e.getMessage()); + e.printStackTrace(); + } + } + } + +} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/DataSimpleService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/DataSimpleService.java deleted file mode 100644 index 5ec3c4a..0000000 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/DataSimpleService.java +++ /dev/null @@ -1,55 +0,0 @@ -package cn.estsh.i3plus.core.apiservice.serviceimpl.base; - -import cn.estsh.i3plus.core.api.iservice.base.IDataSimpleService; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; -import org.springframework.stereotype.Service; - -/** - * @Description : - * @Reference : - * @Author : alwaysfrin - * @CreateDate : 2018-09-04 17:03 - * @Modify: - **/ -@Service -public class DataSimpleService implements IDataSimpleService { - private Logger LOGGER = LoggerFactory.getLogger(this.getClass()); - - /*@Autowired - private IMachineFactoryDao machineFactoryDao; - - @Override - public void saveMachineFactory(MachineFactory machineFactory) { - //生成主键 - machineFactoryDao.save(machineFactory); - }*/ -/* - @Override - public void updateMachineFactoryNameById(long id, String factoryName) { - machineFactoryDao.updateMachineFactoryNameById(id,factoryName); - } - - @Override - public void deleteMachineFactoryById(long id) { - machineFactoryDao.deleteMachineFactoryById(id); - } - - @Autowired - private DataSource ds; - - @Override - public List findMachineFactoryByFactoryName(String factoryName) { - return machineFactoryDao.findMachineFactoryByFactoryName(factoryName); - } - - @Override - public List findMachineFactoryByFactoryCode(String factoryCode) { - return machineFactoryDao.findMachineFactoryByFactoryCode(factoryCode); - } - - @Override - public List findMachineFactorySpecial() { - return machineFactoryDao.findMachineFactorySpecial(); - }*/ -} diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLocaleResourceService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLocaleResourceService.java index f1276eb..0a7c48c 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLocaleResourceService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLocaleResourceService.java @@ -62,6 +62,13 @@ public class SysLocaleResourceService implements ISysLocaleResourceService { return sysLocaleResourceRDao.insert(sysLocaleResource); } + + @Override + public List saveSysLocaleResource(List list) { + LOGGER.info("系统资源 SYS_LOCALE_RESOURCE list：{}",list); + return sysLocaleResourceRDao.saveAll(list); + } + @Override @ApiOperation(value = "修改系统资源",notes = "修改系统资源") public void updateSysLocaleResource(SysLocaleResource sysLocaleResource) { @@ -153,6 +160,12 @@ public class SysLocaleResourceService implements ISysLocaleResourceService { return sysLocaleResourceRDao.getByProperty(new String[]{"languageCode","resourceKey"},new String[]{languageCode,resKey}); } + + @Override + public List findSysLocaleResourceByResKey(String resKey) { + return sysLocaleResourceRDao.findByProperty(new String[]{"resourceKey"},new String[]{resKey}); + } + @Override public SysLocaleResource getSysLocaleResourceById(Long id) { return sysLocaleResourceRDao.getById(id); diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysMessageService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysMessageService.java index 640e42b..4fe3265 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysMessageService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysMessageService.java @@ -157,15 +157,14 @@ public class SysMessageService implements ISysMessageService { // 判断消息类型推送到对应的队列 // 邮件 if(ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue() == sysMessage.getMessageTypeValue()){ - rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_MAIL_QUEUE, JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL, JSON.toJSONString(sysMessage)); // 站内信 }else if(ImppEnumUtil.MESSAGE_TYPE.LETTER.getValue() == sysMessage.getMessageTypeValue()){ - rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE,JSON.toJSONString(sysMessage)); - rabbitTemplate.convertAndSend(PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE_BAK,JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER,JSON.toJSONString(sysMessage)); // SWEB通知及公告 } else if(ImppEnumUtil.MESSAGE_TYPE.SWEB_PUBLIC_NOTICE.getValue() == sysMessage.getMessageTypeValue() || ImppEnumUtil.MESSAGE_TYPE.SWEB_NOTICE.getValue() == sysMessage.getMessageTypeValue()){ - rabbitTemplate.convertAndSend(PlatformConstWords.SWEB_NOTICE_QUEUE,JSON.toJSONString(sysMessage)); + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_SWEB_NOTICE,JSON.toJSONString(sysMessage)); } else { throw ImppExceptionBuilder.newInstance() .setSystemID(CommonEnumUtil.SOFT_TYPE.CORE.getCode()) From 4461f9298efc938c42a999151869272d21419630 Mon Sep 17 00:00:00 2001 From: "wei.peng" <123456> Date: Mon, 26 Aug 2019 11:12:56 +0800 Subject: [PATCH 03/11] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E6=A8=A1=E6=9D=BF?= =?UTF-8?q?=E8=AF=A6=E6=83=85=E5=88=97=E8=A1=A8=E5=8A=9F=E8=83=BD=E6=8E=A5?= =?UTF-8?q?=E5=8F=A3=E5=BC=80=E5=8F=91=E5=AE=8C=E6=88=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../iservice/busi/ISysLabelTemplateService.java | 5 +++- .../busi/SysLabelTemplateController.java | 21 +++++++++++++- .../serviceimpl/busi/SysLabelTemplateService.java | 32 +++++++++++++++++++++- 3 files changed, 55 insertions(+), 3 deletions(-) diff --git a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLabelTemplateService.java b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLabelTemplateService.java index 698c362..d9b7cb6 100644 --- a/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLabelTemplateService.java +++ b/modules/i3plus-core-api/src/main/java/cn/estsh/i3plus/core/api/iservice/busi/ISysLabelTemplateService.java @@ -44,7 +44,10 @@ public interface ISysLabelTemplateService { * 查询全部打印模板 */ @ApiOperation(value = "查询全部打印模板") - List ListSysLabelTemplate(SysLabelTemplate template); + List listSysLabelTemplate(SysLabelTemplate template); + + @ApiOperation(value = "查询全部打印模板详情") + List listSysLabelTemplateDetail(SysLabelTemplate template); /** * 根据id查询打印模板 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysLabelTemplateController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysLabelTemplateController.java index f25f9b7..e682e41 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysLabelTemplateController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysLabelTemplateController.java @@ -142,7 +142,7 @@ public class SysLabelTemplateController extends CoreBaseController { @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") public ResultBean findSysConfigAll(@RequestBody SysLabelTemplate template){ try { - List sysLabelTemplateList = sysLabelTemplateService.ListSysLabelTemplate(template); + List sysLabelTemplateList = sysLabelTemplateService.listSysLabelTemplate(template); return ResultBean.success("操作成功") .setResultList(sysLabelTemplateList) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); @@ -154,6 +154,25 @@ public class SysLabelTemplateController extends CoreBaseController { } /** + * 查询全部打印模板 + * @return 处理结果 + */ + @GetMapping(value = "/list-detail") + @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") + public ResultBean findListDetail(@RequestBody SysLabelTemplate template){ + try { + List sysLabelTemplateList = sysLabelTemplateService.listSysLabelTemplateDetail(template); + 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); + } + } + + /** * 根据id查询打印模板 * @param id 打印模板id * @return 处理结果 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java index a765757..0dc27ea 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java @@ -27,6 +27,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.text.SimpleDateFormat; +import java.util.ArrayList; import java.util.Date; import java.util.List; @@ -141,11 +142,40 @@ public class SysLabelTemplateService implements ISysLabelTemplateService { @Override @ApiOperation(value = "查询打印模板", notes = "查询打印模板") - public List ListSysLabelTemplate(SysLabelTemplate template) { + public List listSysLabelTemplate(SysLabelTemplate template) { return sysLabelTemplateRDao.findByHqlWhere(CoreHqlPack.packBeanSysLabelTemplate(template)); } @Override + public List listSysLabelTemplateDetail(SysLabelTemplate template) { + List list = sysLabelTemplateRDao.findByHqlWhere(CoreHqlPack.packBeanSysLabelTemplate(template)); + if(list != null && list.size() > 0){ + List ids = new ArrayList<>(list.size()); + list.forEach(tmp -> ids.add(tmp.getId())); + + DdlPackBean packBean = DdlPackBean.getDdlPackBean(); + DdlPreparedPack.getInPackList(ids,"templateId",packBean); + List paramList = sysLabelTemplateParamRDao.findByHqlWhere(packBean); + + if(paramList != null && paramList.size() > 0){ + for (SysLabelTemplateParam param : paramList) { + for (SysLabelTemplate temp : list) { + if(temp.getId().equals(param.getId())){ + List params = temp.getLabelTemplateParamList(); + if(params == null){ + params = new ArrayList<>(); + } + params.add(param); + temp.setLabelTemplateParamList(params); + } + } + } + } + } + return list; + } + + @Override @ApiOperation(value = "根据编号打印模板", notes = "根据编号打印模板") public SysLabelTemplate getSysLabelTemplateById(Long id) { return sysLabelTemplateRDao.getById(id); From 6f31a8849a74fe6aad4dd097309c4381810f0d43 Mon Sep 17 00:00:00 2001 From: "wei.peng" <123456> Date: Mon, 26 Aug 2019 13:06:20 +0800 Subject: [PATCH 04/11] =?UTF-8?q?=E5=90=88=E5=B9=B6=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/apiservice/mq/ScheduleQueueReceiver.java | 106 +++++++++++---------- .../serviceimpl/busi/SysRoleService.java | 22 ++--- 2 files changed, 62 insertions(+), 66 deletions(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java index 2bbe766..8e955c1 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java @@ -61,66 +61,68 @@ public class ScheduleQueueReceiver { SysLogTaskTime logTaskTime = JsonUtilTool.decode(data, SysLogTaskTime.class); LOGGER.info("【MQ-QUEUE_IMPP_SCHEDULE】数据接收成功：{}", logTaskTime); // 跟新最后执行时间 及 任务状态 - SysTaskPlan taskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(logTaskTime.getName(), logTaskTime.getGroupName()); - if (taskPlan != null) { - taskPlan.setLastRunDateTime(logTaskTime.getCreateDatetime()); - taskPlan.setTaskPlanExecNum(taskPlan.getTaskPlanExecNumValue() + 1); - taskPlan.setTaskPlanStatus(logTaskTime.getTaskStatus()); - // 更新任务状态以及最后执行时间 - sysTaskPlanService.updateSysTaskPlan(taskPlan); + if(logTaskTime != null){ + SysTaskPlan taskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(logTaskTime.getName(), logTaskTime.getGroupName()); + if (taskPlan != null) { + taskPlan.setLastRunDateTime(logTaskTime.getCreateDatetime()); + taskPlan.setTaskPlanExecNum(taskPlan.getTaskPlanExecNumValue() + 1); + taskPlan.setTaskPlanStatus(logTaskTime.getTaskStatus()); + // 更新任务状态以及最后执行时间 + sysTaskPlanService.updateSysTaskPlan(taskPlan); - // 添加定时任务日志 - logTaskTime.setTaskPlanId(taskPlan.getId()); - logTaskTime.setTaskSoftTypeRdd(taskPlan.getTaskSoftTypeRdd()); - logTaskTime.setTaskCycleNameRdd(taskPlan.getTaskCycleNameRdd()); - logTaskTime.setTaskCycleExpsRdd(taskPlan.getTaskCycleExpsRdd()); - ConvertBean.serviceModelInitialize(logTaskTime, "system"); - sysTaskPlanService.logInsertSysLogTaskTime(logTaskTime); + // 添加定时任务日志 + logTaskTime.setTaskPlanId(taskPlan.getId()); + logTaskTime.setTaskSoftTypeRdd(taskPlan.getTaskSoftTypeRdd()); + logTaskTime.setTaskCycleNameRdd(taskPlan.getTaskCycleNameRdd()); + logTaskTime.setTaskCycleExpsRdd(taskPlan.getTaskCycleExpsRdd()); + ConvertBean.serviceModelInitialize(logTaskTime, "system"); + sysTaskPlanService.logInsertSysLogTaskTime(logTaskTime); - // 定时任务失败通知 - if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == logTaskTime.getTaskStatus() - && CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() == taskPlan.getIsNotice()) { - // 设置通知邮件内容 - SysMessage sysMessage = new SysMessage(); - sysMessage.setMessageSoftType(logTaskTime.getTaskSoftTypeRdd()); - sysMessage.setMessageType(taskPlan.getNoticeMethod()); - sysMessage.setMessageSenderNameRdd("系统管理员"); - sysMessage.setMessageTitle("任务计划失败通知"); - sysMessage.setMessageContent( - String.format("

管理员 您好：

任务计划(Name: %s,GroupName: %s）执行失败,详细信息请查看定时任务日志(ID: %s).
", - taskPlan.getName(), taskPlan.getGroupName(), logTaskTime.getId()) - ); - sysMessage.setMessageContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getValue()); - sysMessage.setMessageSendTime(TimeTool.getNowTime(true)); - sysMessage.setIsSystem(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()); - // 初始数据 - ConvertBean.serviceModelInitialize(sysMessage, "system"); + // 定时任务失败通知 + if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == logTaskTime.getTaskStatus() + && CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() == taskPlan.getIsNotice()) { + // 设置通知邮件内容 + SysMessage sysMessage = new SysMessage(); + sysMessage.setMessageSoftType(logTaskTime.getTaskSoftTypeRdd()); + sysMessage.setMessageType(taskPlan.getNoticeMethod()); + sysMessage.setMessageSenderNameRdd("系统管理员"); + sysMessage.setMessageTitle("任务计划失败通知"); + sysMessage.setMessageContent( + String.format("

管理员 您好：

任务计划(Name: %s,GroupName: %s）执行失败,详细信息请查看定时任务日志(ID: %s).
", + taskPlan.getName(), taskPlan.getGroupName(), logTaskTime.getId()) + ); + sysMessage.setMessageContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getValue()); + sysMessage.setMessageSendTime(TimeTool.getNowTime(true)); + sysMessage.setIsSystem(CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()); + // 初始数据 + ConvertBean.serviceModelInitialize(sysMessage, "system"); - // 是否内部成员 - if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == taskPlan.getIsInternalUser()) { - sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.EXTERNAL.getValue()); - sysMessage.setMessageReceiversNameRdd(taskPlan.getNoticeChannel()); - } else { - sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.INTERNAL.getValue()); - // 设置收件人名称 - String[] messageReceiver = taskPlan.getNoticeChannel().split(","); - String receiversName = sysUserService.findSysUserByIds(StringTool.getArrayLong(messageReceiver)) - .stream().map(e -> e.getUserName()).collect(Collectors.joining(",")); + // 是否内部成员 + if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == taskPlan.getIsInternalUser()) { + sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.EXTERNAL.getValue()); + sysMessage.setMessageReceiversNameRdd(taskPlan.getNoticeChannel()); + } else { + sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.INTERNAL.getValue()); + // 设置收件人名称 + String[] messageReceiver = taskPlan.getNoticeChannel().split(","); + String receiversName = sysUserService.findSysUserByIds(StringTool.getArrayLong(messageReceiver)) + .stream().map(e -> e.getUserName()).collect(Collectors.joining(",")); - sysMessage.setMessageReceiversNameRdd(receiversName); - } + sysMessage.setMessageReceiversNameRdd(receiversName); + } - // 发送到对应处理队列 - if (taskPlan.getNoticeMethod() != null && ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue() == taskPlan.getNoticeMethod().intValue()) { - rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL, JSON.toJSONString(sysMessage)); - } else { - rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, JSON.toJSONString(sysMessage)); + // 发送到对应处理队列 + if (taskPlan.getNoticeMethod() != null && ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue() == taskPlan.getNoticeMethod().intValue()) { + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_MAIL, JSON.toJSONString(sysMessage)); + } else { + rabbitTemplate.convertAndSend(PlatformConstWords.QUEUE_IMPP_MESSAGE_LETTER, JSON.toJSONString(sysMessage)); + } } } - } - //信息已处理 - channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); + //信息已处理 + channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); + } } catch (IOException e) { LOGGER.error("【MQ-QUEUE_IMPP_MESSAGE_MAIL】处理出错：{}", e.getMessage(), e); //丢弃这条消息 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysRoleService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysRoleService.java index e90fc48..7bd075e 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysRoleService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysRoleService.java @@ -3,6 +3,7 @@ package cn.estsh.i3plus.core.apiservice.serviceimpl.busi; import cn.estsh.i3plus.core.api.iservice.busi.IPersonnelService; import cn.estsh.i3plus.core.api.iservice.busi.ISysRoleService; import cn.estsh.i3plus.core.apiservice.dao.IUserPermissionDao; +import cn.estsh.i3plus.platform.common.convert.ConvertBean; import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.common.Pager; @@ -15,8 +16,10 @@ import cn.estsh.i3plus.pojo.platform.repository.SysRefRoleMenuRepository; import cn.estsh.i3plus.pojo.platform.repository.SysRefUserRoleRepository; import cn.estsh.i3plus.pojo.platform.repository.SysRoleRepository; 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 cn.estsh.impp.framework.boot.util.ValidatorBean; import io.swagger.annotations.ApiOperation; import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; @@ -24,6 +27,7 @@ import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.ArrayList; +import java.util.Arrays; import java.util.List; /** @@ -137,19 +141,11 @@ public class SysRoleService implements ISysRoleService { List featuresListRdd = new ArrayList<>(); // 冗余 List refs = new ArrayList<>(); // 角色权限关系 - // 封装需要删除的IDS - Long[] rids = new Long[roleList.size()]; - for (int i = 0; i < roleList.size(); i++) { - rids[i] = roleList.get(i).getId(); - } // 删除角色权限关系 - String deleteWhere = CoreHqlPack.packHqlIds("roleId", roleIds); - List refRoleMenuList = refRoleMenuRDao.findByHqlWhere(deleteWhere); - refRoleMenuRDao.deleteAll(refRoleMenuList); + refRoleMenuRDao.deleteByPropertyIn("roleId",roleIds); if(ids != null && ids.length > 0){ - String menuWhere = CoreHqlPack.packHqlIds("id", ids); - List list = sysMenuRDao.findByHqlWhere(menuWhere); + List list = sysMenuRDao.findAllById(Arrays.asList(ids)); SysRefRoleMenu ref = null; // 插入角色权限关系 @@ -161,11 +157,10 @@ public class SysRoleService implements ISysRoleService { ref.setRoleNameRdd(role.getName()); ref.setMenuNameRdd(menu.getName()); ref.setMenuId(menu.getId()); - ref.setIsValid(CommonEnumUtil.IS_VAILD.VAILD.getValue()); - ref.setIsDeleted(CommonEnumUtil.IS_DEAL.NO.getValue()); ref.setMenuTypeRdd(menu.getMenuType()); + ConvertBean.serviceModelInitialize(ref, AuthUtil.getSessionUser()); - refs.add(ref); + refRoleMenuRDao.insert(ref); } // 冗余信息封装 @@ -185,7 +180,6 @@ public class SysRoleService implements ISysRoleService { role.setMenuNumber(featuresListRdd.size()); } - refRoleMenuRDao.saveAll(refs); roleRDao.saveAll(roleList); }else { throw ImppExceptionBuilder.newInstance() From 7ca830ae71df7a2fbbeb5e6f9fe52693e829169f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= Date: Mon, 26 Aug 2019 16:25:07 +0800 Subject: [PATCH 05/11] =?UTF-8?q?=E6=A8=A1=E6=9D=BF=E6=89=93=E5=8D=B0?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=8A=A0=E5=85=A5=E7=99=BD=E5=90=8D?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/base/WhiteController.java | 22 ++++++++++++++++++++++ .../core/apiservice/mq/ScheduleQueueReceiver.java | 2 +- .../serviceimpl/base/SystemInitService.java | 8 ++++++-- 3 files changed, 29 insertions(+), 3 deletions(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java index 03d3ba8..ccee317 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java @@ -79,6 +79,9 @@ public class WhiteController extends CoreBaseController { @Autowired private ISysOrganizeService sysOrganizeService; + @Autowired + private ISysLabelTemplateService sysLabelTemplateService; + @Resource(name="redisRes") private ImppRedis redisRes; @@ -371,4 +374,23 @@ public class WhiteController extends CoreBaseController { return ImppExceptionBuilder.newInstance().buildExceptionResult(e); } } + + /** + * 查询全部打印模板 + * @return 处理结果 + */ + @GetMapping(value = "/sys-label-template/list") + @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") + public ResultBean findSysConfigAll(){ + try { + List 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); + } + } } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java index cd8ec35..4ce777e 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/mq/ScheduleQueueReceiver.java @@ -122,7 +122,7 @@ public class ScheduleQueueReceiver { //信息已处理 channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); } catch (IOException e) { - LOGGER.error("【MQ-IMPP_MESSAGE_MAIL_QUEUE】处理出错：{}", e.getMessage(), e); + LOGGER.error("【MQ-IMPP_SCHEDULE_QUEUE】处理出错：{}", e.getMessage(), e); //丢弃这条消息 try { // 未成功处理，重新发送 diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java index 8f822ee..da20711 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/base/SystemInitService.java @@ -140,12 +140,16 @@ public class SystemInitService implements ISystemInitService { for (String key : resMap.keySet()) { //放入缓存 - redisRes.putHashMap(CommonConstWords.REDIS_PREFIX_CACHE_LANGUAGE + ":"+ key,resMap.get(key),0); + if(webLangMap.get(key) != null) { + redisRes.putHashMap(CommonConstWords.REDIS_PREFIX_CACHE_LANGUAGE + ":" + key, resMap.get(key), 0); + } } for(String key : webLangMap.keySet()){ //放入缓存 - redisRes.putHashMap(CommonConstWords.REDIS_PREFIX_CACHE_LANGUAGE + ":" + key,webLangMap.get(key),0); + if(webLangMap.get(key) != null){ + redisRes.putHashMap(CommonConstWords.REDIS_PREFIX_CACHE_LANGUAGE + ":" + key,webLangMap.get(key),0); + } } } From dc45feb6d7b9706f1c87006d7f2f7f37b6049da6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= Date: Mon, 26 Aug 2019 16:47:18 +0800 Subject: [PATCH 06/11] =?UTF-8?q?=E6=A8=A1=E6=9D=BF=E6=89=93=E5=8D=B0?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=8A=A0=E5=85=A5=E7=99=BD=E5=90=8D?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../estsh/i3plus/core/apiservice/controller/base/WhiteController.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java index ccee317..02b94d3 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java @@ -381,9 +381,9 @@ public class WhiteController extends CoreBaseController { */ @GetMapping(value = "/sys-label-template/list") @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") - public ResultBean findSysConfigAll(){ + public ResultBean findSysConfigAll(@RequestBody SysLabelTemplate template){ try { - List sysLabelTemplateList = sysLabelTemplateService.ListSysLabelTemplate(); + List sysLabelTemplateList = sysLabelTemplateService.listSysLabelTemplateDetail(template);; return ResultBean.success("操作成功") .setResultList(sysLabelTemplateList) .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); From 221eaa3e89618d91839c4b9970679b73fe524ced Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= Date: Mon, 26 Aug 2019 18:02:44 +0800 Subject: [PATCH 07/11] =?UTF-8?q?=E6=A8=A1=E6=9D=BF=E6=89=93=E5=8D=B0?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=8A=A0=E5=85=A5=E7=99=BD=E5=90=8D?= =?UTF-8?q?=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../estsh/i3plus/core/apiservice/controller/base/WhiteController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java index 02b94d3..1793f1f 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java @@ -379,7 +379,7 @@ public class WhiteController extends CoreBaseController { * 查询全部打印模板 * @return 处理结果 */ - @GetMapping(value = "/sys-label-template/list") + @PostMapping(value = "/sys-label-template/list") @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") public ResultBean findSysConfigAll(@RequestBody SysLabelTemplate template){ try { From 570bf2ec145967d798168a0ff12b2edf3034189f Mon Sep 17 00:00:00 2001 From: crish <570360737@qq.com> Date: Tue, 27 Aug 2019 09:17:19 +0800 Subject: [PATCH 08/11] =?UTF-8?q?=E6=9D=A1=E7=A0=81=E6=89=93=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: crish <570360737@qq.com> --- .../core/apiservice/serviceimpl/busi/SysLabelTemplateService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java index 0dc27ea..501fc25 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/serviceimpl/busi/SysLabelTemplateService.java @@ -160,7 +160,7 @@ public class SysLabelTemplateService implements ISysLabelTemplateService { if(paramList != null && paramList.size() > 0){ for (SysLabelTemplateParam param : paramList) { for (SysLabelTemplate temp : list) { - if(temp.getId().equals(param.getId())){ + if(temp.getId().equals(param.getTemplateId())){ List params = temp.getLabelTemplateParamList(); if(params == null){ params = new ArrayList<>(); From ce896c80d078e9f0b6c23386f5d32ccddc716875 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= Date: Tue, 27 Aug 2019 11:36:25 +0800 Subject: [PATCH 09/11] =?UTF-8?q?oracle=20ojdbc=E7=89=88=E6=9C=AC=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- modules/i3plus-core-apiservice/pom.xml | 2 +- pom.xml | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/modules/i3plus-core-apiservice/pom.xml b/modules/i3plus-core-apiservice/pom.xml index 754e96a..ec75d52 100644 --- a/modules/i3plus-core-apiservice/pom.xml +++ b/modules/i3plus-core-apiservice/pom.xml @@ -83,7 +83,7 @@ com.oracle - ojdbc6 + ojdbc8 diff --git a/pom.xml b/pom.xml index c661a7f..22eb50d 100644 --- a/pom.xml +++ b/pom.xml @@ -157,8 +157,8 @@ com.oracle - ojdbc6 - 12.1.0.1.0 + ojdbc8 + 12.2.0.1 From ba470d5ea2d436856b7c4c12f758822e0ee68b39 Mon Sep 17 00:00:00 2001 From: crish <570360737@qq.com> Date: Tue, 27 Aug 2019 12:08:42 +0800 Subject: [PATCH 10/11] =?UTF-8?q?=E8=8E=B7=E5=8F=96core=E6=9C=8D=E5=8A=A1?= =?UTF-8?q?=E6=89=93=E5=8D=B0=E6=A8=A1=E6=9D=BF=E4=BF=A1=E6=81=AF=EF=BC=8C?= =?UTF-8?q?=20=E8=BF=94=E5=9B=9E=E5=80=BC=E6=B7=BB=E5=8A=A0=E5=85=B7?= =?UTF-8?q?=E4=BD=93=E6=B3=9B=E5=9E=8B=E7=B1=BB=E5=9E=8B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: crish <570360737@qq.com> --- .../estsh/i3plus/core/apiservice/controller/base/WhiteController.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java index 1793f1f..8b39770 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/base/WhiteController.java @@ -381,7 +381,7 @@ public class WhiteController extends CoreBaseController { */ @PostMapping(value = "/sys-label-template/list") @ApiOperation(value = "查询全部打印模板",notes = "查询全部打印模板") - public ResultBean findSysConfigAll(@RequestBody SysLabelTemplate template){ + public ResultBean findSysConfigAll(@RequestBody SysLabelTemplate template){ try { List sysLabelTemplateList = sysLabelTemplateService.listSysLabelTemplateDetail(template);; return ResultBean.success("操作成功") From 13403a35cc01f7fab7eea9451649862003afedad Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=B1=AA=E4=BA=91=E6=98=8A?= Date: Tue, 27 Aug 2019 14:00:25 +0800 Subject: [PATCH 11/11] =?UTF-8?q?=E5=91=A8=E6=9C=9F=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=E5=85=B3=E8=81=94=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/busi/SysTaskCycleController.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysTaskCycleController.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysTaskCycleController.java index e524a81..57239e0 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysTaskCycleController.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/controller/busi/SysTaskCycleController.java @@ -10,6 +10,7 @@ import cn.estsh.i3plus.icloud.wms.sdk.IWmsScheduleJobCloud; import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; import cn.estsh.i3plus.platform.common.tool.StringTool; import cn.estsh.i3plus.platform.common.util.PlatformConstWords; +import cn.estsh.i3plus.pojo.base.bean.BaseResultBean; import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; @@ -168,8 +169,11 @@ public class SysTaskCycleController extends CoreBaseController { sysTaskPlan = sysTaskPlanService.getSysTaskPlanByNameAndGroup(item.getTaskPlanName(), item.getTaskPlanGroupName()); // 查找任务 sysTask = sysTaskService.getSysTaskById(sysTaskPlan.getTaskId()); - - if(sysTaskPlan == null || sysTask == null){ + // 查询调度库中数据是否存在 + BaseResultBean baseResultBean = + getJobService(sysTaskPlan.getTaskSoftTypeRdd()).checkJobExists(sysTask.getTaskPackage(), + sysTask.getTaskClass()); + if(sysTaskPlan == null || sysTask == null || (baseResultBean.isSuccess() && (boolean)baseResultBean.getResultObject())){ continue; } @@ -181,6 +185,13 @@ public class SysTaskCycleController extends CoreBaseController { // 更新关联模块的定时任务 getJobService(sysTaskPlan.getTaskSoftTypeRdd()).editTask(sysTask.getTaskPackage(), sysTask.getTaskClass(), sysTaskPlan.getName() , sysTaskPlan.getGroupName(), sysTaskCycle.getTaskCycleExps(), sysTaskPlan.getTaskPlanDescription()); + + // 停止或启用对应模块中的定时任务 + if (CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() == sysTaskPlan.getTaskPlanStatusVal()) { + getJobService(sysTaskPlan.getTaskSoftTypeRdd()).resumeJob(sysTaskPlan.getName(), sysTaskPlan.getGroupName()); + } else if (CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue() == sysTaskPlan.getTaskPlanStatusVal()) { + getJobService(sysTaskPlan.getTaskSoftTypeRdd()).pauseJob(sysTaskPlan.getName(), sysTaskPlan.getGroupName()); + } } return ResultBean.success("操作成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); } catch (ImppBusiException busExcep) {