From 37631ca51f853a9b3030085e86bf07ca201a58d8 Mon Sep 17 00:00:00 2001 From: dimengzhe Date: Mon, 11 Sep 2023 00:24:06 +0800 Subject: [PATCH] =?UTF-8?q?=E5=82=AC=E5=8A=9E=E9=83=A8=E5=88=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../api/messageurgeList/MessageListDto.java | 22 ++++++++ .../api/messageurgeList/MessageUrgeList.java | 26 +++++++++ .../messageurgeList/MessageUrgeListFeign.java | 17 ++++++ .../MessageUrgeListFeignFallback.java | 9 +++ .../MessageCenterApplication.java | 4 +- .../MessageUrgeListMapper.java | 15 +++++ .../messageurgeList/MessageUrgeListMapper.xml | 4 ++ .../messageurgeList/MessageUrgeListRest.java | 9 +++ .../MessageUrgeListService.java | 28 ++++++++++ .../ScheduledMessageService.java | 55 +++++++++++++++++++ 10 files changed, 187 insertions(+), 2 deletions(-) create mode 100644 message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageListDto.java create mode 100644 message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeList.java create mode 100644 message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeign.java create mode 100644 message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeignFallback.java create mode 100644 message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.java create mode 100644 message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.xml create mode 100644 message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListRest.java create mode 100644 message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListService.java create mode 100644 message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/ScheduledMessageService.java diff --git a/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageListDto.java b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageListDto.java new file mode 100644 index 0000000..9425030 --- /dev/null +++ b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageListDto.java @@ -0,0 +1,22 @@ +package com.yxt.messagecenter.api.messageurgeList; + +import com.yxt.common.core.dto.Dto; +import lombok.Data; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/10 + **/ +@Data +public class MessageListDto implements Dto { + private static final long serialVersionUID = -1667937381274036191L; + + private String proInstId; + + private int type; + + private String urgeName; + + private String nodeName; +} diff --git a/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeList.java b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeList.java new file mode 100644 index 0000000..c049184 --- /dev/null +++ b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeList.java @@ -0,0 +1,26 @@ +package com.yxt.messagecenter.api.messageurgeList; + +import com.baomidou.mybatisplus.annotation.TableField; +import com.baomidou.mybatisplus.annotation.TableName; +import com.yxt.common.core.domain.BaseEntity; +import io.swagger.annotations.ApiModelProperty; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +@TableName("message_urgeList") +public class MessageUrgeList extends BaseEntity { + private static final long serialVersionUID = 7667726702154027285L; + @ApiModelProperty("消息sid") + private String msgSid; + @ApiModelProperty("流程实例id") + private String proInstId; + @ApiModelProperty("催办类别：1系统，2人工") + private String urgeType; + @ApiModelProperty("被催办人") + private String urgeName; + @ApiModelProperty("审批环节") + private String nodeName; +} diff --git a/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeign.java b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeign.java new file mode 100644 index 0000000..296ed81 --- /dev/null +++ b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeign.java @@ -0,0 +1,17 @@ +package com.yxt.messagecenter.api.messageurgeList; + +import com.yxt.messagecenter.api.message.MessageFeignFallback; +import org.springframework.cloud.openfeign.FeignClient; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +@FeignClient( + contextId = "message-center-MessageUrgeList", + name = "message-center", + path = "v1/MessageUrgeList", + fallback = MessageUrgeListFeignFallback.class) +public interface MessageUrgeListFeign { +} diff --git a/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeignFallback.java b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeignFallback.java new file mode 100644 index 0000000..6ff594b --- /dev/null +++ b/message-center-api/src/main/java/com/yxt/messagecenter/api/messageurgeList/MessageUrgeListFeignFallback.java @@ -0,0 +1,9 @@ +package com.yxt.messagecenter.api.messageurgeList; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +public class MessageUrgeListFeignFallback { +} diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/MessageCenterApplication.java b/message-center-biz/src/main/java/com/yxt/messagecenter/MessageCenterApplication.java index 3b33c55..c9d017e 100644 --- a/message-center-biz/src/main/java/com/yxt/messagecenter/MessageCenterApplication.java +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/MessageCenterApplication.java @@ -4,7 +4,7 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.cloud.openfeign.EnableFeignClients; - +import org.springframework.scheduling.annotation.EnableScheduling; @EnableDiscoveryClient @@ -12,7 +12,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients; "com.yxt.common.base.config", "com.yxt.messagecenter" }) - +@EnableScheduling @EnableFeignClients(basePackages = {"com.yxt.anrui.portal", "com.yxt.anrui.crm","com.yxt.anrui.flowable"}) public class MessageCenterApplication { diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.java b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.java new file mode 100644 index 0000000..fe30ca7 --- /dev/null +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.java @@ -0,0 +1,15 @@ +package com.yxt.messagecenter.biz.messageurgeList; + +import com.baomidou.mybatisplus.core.mapper.BaseMapper; +import com.yxt.messagecenter.api.messagetype.MessageType; +import com.yxt.messagecenter.api.messageurgeList.MessageUrgeList; +import org.apache.ibatis.annotations.Mapper; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/11 + **/ +@Mapper +public interface MessageUrgeListMapper extends BaseMapper { +} diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.xml b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.xml new file mode 100644 index 0000000..3b7f66b --- /dev/null +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListMapper.xml @@ -0,0 +1,4 @@ + + + + \ No newline at end of file diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListRest.java b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListRest.java new file mode 100644 index 0000000..5bfbbfb --- /dev/null +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListRest.java @@ -0,0 +1,9 @@ +package com.yxt.messagecenter.biz.messageurgeList; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +public class MessageUrgeListRest { +} diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListService.java b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListService.java new file mode 100644 index 0000000..96977d1 --- /dev/null +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/MessageUrgeListService.java @@ -0,0 +1,28 @@ +package com.yxt.messagecenter.biz.messageurgeList; + +import cn.hutool.core.bean.BeanUtil; +import com.yxt.common.base.service.MybatisBaseService; +import com.yxt.common.core.result.ResultBean; +import com.yxt.messagecenter.api.messagetype.MessageType; +import com.yxt.messagecenter.api.messageurgeList.MessageListDto; +import com.yxt.messagecenter.api.messageurgeList.MessageUrgeList; +import com.yxt.messagecenter.biz.messagetype.MessageTypeMapper; +import org.springframework.stereotype.Service; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +@Service +public class MessageUrgeListService extends MybatisBaseService { + + + ResultBean saveMessage(MessageListDto dto) { + ResultBean rb = ResultBean.fireFail(); + MessageUrgeList messageUrgeList = new MessageUrgeList(); + BeanUtil.copyProperties(dto, messageUrgeList); + baseMapper.insert(messageUrgeList); + return rb.success(); + } +} diff --git a/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/ScheduledMessageService.java b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/ScheduledMessageService.java new file mode 100644 index 0000000..cf42113 --- /dev/null +++ b/message-center-biz/src/main/java/com/yxt/messagecenter/biz/messageurgeList/ScheduledMessageService.java @@ -0,0 +1,55 @@ +package com.yxt.messagecenter.biz.messageurgeList; + +import cn.hutool.core.bean.BeanUtil; +import com.yxt.anrui.flowable.api.flow2.FlowFeign; +import com.yxt.anrui.flowable.api.flow2.FlowableMessageVo; +import com.yxt.common.core.result.ResultBean; +import com.yxt.messagecenter.api.message.OrderListMessageDto; +import com.yxt.messagecenter.api.message.OrderMesageDto; +import com.yxt.messagecenter.api.messageurgeList.MessageListDto; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; + +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.stream.Collectors; + +/** + * @description: + * @author: dimengzhe + * @date: 2023/9/9 + **/ +@Component +public class ScheduledMessageService { + + @Autowired + private FlowFeign flowFeign; + @Autowired + private MessageUrgeListService messageUrgeListService; + + +// @Scheduled(cron = "0 0 0 * * ?") +// @Scheduled(cron = "0 0/5 16 * * ?") + public void remindVehicle() { + Date now = new Date(); + //获取当前时间 + SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); + //查询规则 + int minutes = 5; + //查询所有的待办工作时间超过5分钟的 + ResultBean> resultBean = flowFeign.getMessageList(minutes); + List list = resultBean.getData(); + list.removeAll(Collections.singleton(null)); + if (!list.isEmpty()) { + for (int i = 0; i < list.size(); i++) { + FlowableMessageVo flowableMessageVo = list.get(i); + MessageListDto messageListDto = new MessageListDto(); + BeanUtil.copyProperties(flowableMessageVo, messageListDto); + messageUrgeListService.saveMessage(messageListDto); + } + } + } + + +}