forked from rongchao/epmet-cloud-rizhao
258 changed files with 7442 additions and 631 deletions
@ -0,0 +1,21 @@ |
|||
<?xml version="1.0" encoding="UTF-8"?> |
|||
<project xmlns="http://maven.apache.org/POM/4.0.0" |
|||
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" |
|||
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> |
|||
<parent> |
|||
<artifactId>epmet-commons</artifactId> |
|||
<groupId>com.epmet</groupId> |
|||
<version>2.0.0</version> |
|||
</parent> |
|||
<modelVersion>4.0.0</modelVersion> |
|||
|
|||
<artifactId>epmet-commons-rocketmq</artifactId> |
|||
|
|||
<dependencies> |
|||
<dependency> |
|||
<groupId>org.apache.rocketmq</groupId> |
|||
<artifactId>rocketmq-spring-boot-starter</artifactId> |
|||
<version>2.1.1</version> |
|||
</dependency> |
|||
</dependencies> |
|||
</project> |
@ -0,0 +1,21 @@ |
|||
package com.epmet.commons.rocketmq.constants; |
|||
|
|||
/** |
|||
* 消费者组常量 |
|||
*/ |
|||
public interface ConsomerGroupConstants { |
|||
|
|||
/** |
|||
* 初始化客户角色消费者组 |
|||
*/ |
|||
String INIT_CUSTOMER_ROLES_GROUP = "init_customer_roles_group"; |
|||
/** |
|||
* 初始化客户自定义消费者组 |
|||
*/ |
|||
String INIT_CUSTOMER_CUSTOMIZE_GROUP = "init_customer_customize_group"; |
|||
/** |
|||
* 初始化客户组织机构信息分组 |
|||
*/ |
|||
String INIT_CUSTOMER_ORG_GROUP = "init_customer_org_group"; |
|||
|
|||
} |
@ -0,0 +1,5 @@ |
|||
package com.epmet.commons.rocketmq.constants; |
|||
|
|||
public interface TopicConstants { |
|||
String INIT_CUSTOMER = "init_customer_topic"; |
|||
} |
@ -0,0 +1,148 @@ |
|||
package com.epmet.commons.rocketmq.messages; |
|||
|
|||
public class InitCustomerMQMsg { |
|||
|
|||
private String customerId; |
|||
|
|||
private InitCustomerAgency agency; |
|||
|
|||
private InitCustomerStaff staff; |
|||
|
|||
public static class InitCustomerStaff { |
|||
private String agencyId; |
|||
private Integer gender; |
|||
private String mobile; |
|||
private String name; |
|||
private String workType; |
|||
|
|||
public String getAgencyId() { |
|||
return agencyId; |
|||
} |
|||
|
|||
public void setAgencyId(String agencyId) { |
|||
this.agencyId = agencyId; |
|||
} |
|||
|
|||
public Integer getGender() { |
|||
return gender; |
|||
} |
|||
|
|||
public void setGender(Integer gender) { |
|||
this.gender = gender; |
|||
} |
|||
|
|||
public String getMobile() { |
|||
return mobile; |
|||
} |
|||
|
|||
public void setMobile(String mobile) { |
|||
this.mobile = mobile; |
|||
} |
|||
|
|||
public String getName() { |
|||
return name; |
|||
} |
|||
|
|||
public void setName(String name) { |
|||
this.name = name; |
|||
} |
|||
|
|||
public String getWorkType() { |
|||
return workType; |
|||
} |
|||
|
|||
public void setWorkType(String workType) { |
|||
this.workType = workType; |
|||
} |
|||
} |
|||
|
|||
public static class InitCustomerAgency { |
|||
private String agencyId; |
|||
private String organizationName; |
|||
private String level; |
|||
private String areaCode; |
|||
private String province; |
|||
private String city; |
|||
private String district; |
|||
|
|||
public String getAgencyId() { |
|||
return agencyId; |
|||
} |
|||
|
|||
public void setAgencyId(String agencyId) { |
|||
this.agencyId = agencyId; |
|||
} |
|||
|
|||
public String getOrganizationName() { |
|||
return organizationName; |
|||
} |
|||
|
|||
public void setOrganizationName(String organizationName) { |
|||
this.organizationName = organizationName; |
|||
} |
|||
|
|||
public String getLevel() { |
|||
return level; |
|||
} |
|||
|
|||
public void setLevel(String level) { |
|||
this.level = level; |
|||
} |
|||
|
|||
public String getAreaCode() { |
|||
return areaCode; |
|||
} |
|||
|
|||
public void setAreaCode(String areaCode) { |
|||
this.areaCode = areaCode; |
|||
} |
|||
|
|||
public String getProvince() { |
|||
return province; |
|||
} |
|||
|
|||
public void setProvince(String province) { |
|||
this.province = province; |
|||
} |
|||
|
|||
public String getCity() { |
|||
return city; |
|||
} |
|||
|
|||
public void setCity(String city) { |
|||
this.city = city; |
|||
} |
|||
|
|||
public String getDistrict() { |
|||
return district; |
|||
} |
|||
|
|||
public void setDistrict(String district) { |
|||
this.district = district; |
|||
} |
|||
} |
|||
|
|||
public String getCustomerId() { |
|||
return customerId; |
|||
} |
|||
|
|||
public void setCustomerId(String customerId) { |
|||
this.customerId = customerId; |
|||
} |
|||
|
|||
public InitCustomerAgency getAgency() { |
|||
return agency; |
|||
} |
|||
|
|||
public void setAgency(InitCustomerAgency agency) { |
|||
this.agency = agency; |
|||
} |
|||
|
|||
public InitCustomerStaff getStaff() { |
|||
return staff; |
|||
} |
|||
|
|||
public void setStaff(InitCustomerStaff staff) { |
|||
this.staff = staff; |
|||
} |
|||
} |
@ -0,0 +1,35 @@ |
|||
package com.epmet.commons.tools.scan.param; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.Valid; |
|||
import javax.validation.constraints.NotEmpty; |
|||
import javax.validation.constraints.NotNull; |
|||
import java.io.Serializable; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* (异步检测)请求参数 |
|||
* |
|||
* @author yinzuomei@elink-cn.com |
|||
* @date 2021/1/10 21:05 |
|||
*/ |
|||
@Data |
|||
public class VideoScanParamDTO implements Serializable { |
|||
private static final long serialVersionUID = -7261993744367287072L; |
|||
/** |
|||
* 是否开启回调 |
|||
*/ |
|||
@NotNull(message = "openCallBack必填,true开启;false不开启") |
|||
private Boolean openCallBack; |
|||
|
|||
/** |
|||
* 异步检测结果回调地址,执行异步审查内容时 必填 |
|||
* openCallBack=true时,callback必填 |
|||
*/ |
|||
private String callback; |
|||
|
|||
@Valid |
|||
@NotEmpty(message = "任务列表不能为空") |
|||
private List<VideoTaskDTO> tasks; |
|||
} |
@ -0,0 +1,32 @@ |
|||
package com.epmet.commons.tools.scan.param; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* (异步检测)请求参数 |
|||
* |
|||
* @author yinzuomei@elink-cn.com |
|||
* @date 2021/1/10 21:06 |
|||
*/ |
|||
@Data |
|||
public class VideoTaskDTO implements Serializable { |
|||
private static final long serialVersionUID = -5268462578193403270L; |
|||
/** |
|||
* 不必填 |
|||
* 要检测的数据id 非必填 |
|||
* 检测对象对应的数据ID。 |
|||
* 由大小写英文字母、数字、下划线(_)、短划线(-)、英文句号(.)组成,不超过128个字符,可以用于唯一标识您的业务数据。 |
|||
* */ |
|||
@NotBlank(message = "dataId不能为空") |
|||
private String dataId; |
|||
|
|||
/** |
|||
* 必填 |
|||
* 待检测视频的URL。该字段不能和frames同时为空,也不能和frames同时有值。 |
|||
*/ |
|||
@NotBlank(message = "音频URL不能为空") |
|||
private String url; |
|||
} |
@ -0,0 +1,47 @@ |
|||
package com.epmet.commons.tools.scan.result; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.ArrayList; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 视频异步检测结果查询接口返参 |
|||
* 正在检测中的不返回,调用方继续轮询查询结果 |
|||
* @author yinzuomei@elink-cn.com |
|||
* @date 2020/12/29 15:37 |
|||
*/ |
|||
@Data |
|||
public class VideoAsyncScanResultDTO implements Serializable { |
|||
private static final long serialVersionUID = -7302168989456734818L; |
|||
/** |
|||
* 执行成功的任务Id集合 |
|||
* code=200,且所有语音+视频所有场景返回结果都为pass时则为成功 |
|||
*/ |
|||
private List<String> passDataIds = new ArrayList<>(); |
|||
/** |
|||
* 执行失败的任务Id集合 |
|||
*/ |
|||
private List<String> noPassDataIds = new ArrayList<>(); |
|||
|
|||
private List<String> passTaskIds = new ArrayList<>(); |
|||
private List<String> noPassTaskIds = new ArrayList<>(); |
|||
|
|||
/** |
|||
* desc:阿里内容审核API返回结果详情 |
|||
*/ |
|||
private List<VideoScanDetailDTO> details = new ArrayList<>(); |
|||
|
|||
/** |
|||
* 本地是否全部通过 |
|||
*/ |
|||
private Boolean isAllPass; |
|||
|
|||
public boolean isAllPass() { |
|||
if (noPassTaskIds.isEmpty() && !passTaskIds.isEmpty()) { |
|||
return true; |
|||
} |
|||
return isAllPass; |
|||
} |
|||
} |
@ -0,0 +1,56 @@ |
|||
package com.epmet.commons.tools.scan.result; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* |
|||
* @author yinzuomei@elink-cn.com |
|||
* @date 2021/1/10 21:24 |
|||
*/ |
|||
@Data |
|||
public class VideoScanDetailDTO implements Serializable { |
|||
/** |
|||
* 错误码,和HTTP状态码一致。 |
|||
* 更多信息,请参见公共错误码。 |
|||
*/ |
|||
private Integer code; |
|||
|
|||
private String codeDesc; |
|||
|
|||
/** |
|||
* 错误描述信息。 |
|||
*/ |
|||
private String msg; |
|||
/** |
|||
* 检测对象对应的数据ID。 |
|||
*/ |
|||
private String dataId; |
|||
|
|||
/** |
|||
* 检测任务的ID |
|||
*/ |
|||
private String taskId; |
|||
|
|||
/** |
|||
* 返回结果,调用成功时(code=200),返回结果中包含一个或多个元素。每个元素是个结构体,具体结构描述,请参见result。 |
|||
* 说明 视频流检测场景中,code返回280表示在检测中,返回200表示检测完成。在检测中状态时,检测结果中包含从开始检测到当前时间的检测到结果。 |
|||
*/ |
|||
private List<ResultDetail> results; |
|||
|
|||
/** |
|||
* 视频语音检测结果。具体结构描述,请参见audioScanResult。 |
|||
*/ |
|||
private List<ResultDetail> audioScanResults; |
|||
|
|||
|
|||
@Data |
|||
public static class ResultDetail { |
|||
private String scene; |
|||
private String label; |
|||
private String suggestion; |
|||
private Float rate; |
|||
} |
|||
} |
@ -0,0 +1,12 @@ |
|||
package com.epmet.service; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/12/29 17:45 |
|||
*/ |
|||
public interface TopicAutoAuditService { |
|||
Result autoAudit(); |
|||
} |
@ -0,0 +1,24 @@ |
|||
package com.epmet.service.impl; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.resi.group.feign.ResiGroupOpenFeignClient; |
|||
import com.epmet.service.TopicAutoAuditService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/12/29 17:46 |
|||
*/ |
|||
@Service |
|||
public class TopicAutoAuditServiceImpl implements TopicAutoAuditService { |
|||
|
|||
@Autowired |
|||
private ResiGroupOpenFeignClient resiGroupOpenFeignClient; |
|||
|
|||
@Override |
|||
public Result autoAudit() { |
|||
return resiGroupOpenFeignClient.autoAudit(); |
|||
} |
|||
} |
@ -0,0 +1,31 @@ |
|||
package com.epmet.task; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.service.TopicAutoAuditService; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/12/29 17:43 |
|||
*/ |
|||
@Slf4j |
|||
@Component("topicAutoAuditTask") |
|||
public class TopicAutoAuditTask implements ITask { |
|||
|
|||
@Autowired |
|||
private TopicAutoAuditService topicAutoAuditService; |
|||
|
|||
@Override |
|||
public void run(String params) { |
|||
log.info("TopicAutoAuditTask定时任务正在执行,参数为:{}", params); |
|||
Result result = topicAutoAuditService.autoAudit(); |
|||
if (result.success()) { |
|||
log.info("TopicAutoAuditTask定时任务执行成功"); |
|||
} else { |
|||
log.error("TopicAutoAuditTask定时任务执行失败:" + result.getMsg()); |
|||
} |
|||
} |
|||
} |
@ -0,0 +1,19 @@ |
|||
package com.epmet.constant; |
|||
|
|||
/** |
|||
* @Author zxc |
|||
* @DateTime 2021/1/4 下午1:42 |
|||
*/ |
|||
public interface SysSmsConstant { |
|||
|
|||
String IS_NULL_PARAM_LIST = "项目流转或滞留推送短信提醒入参集合为空......"; |
|||
|
|||
String SELECT_PARAMETER_INFO_FAILURE = "查询客户配置参数失败......"; |
|||
|
|||
String PARAMETER_INFO_IS_ZERO = "未查到客户配置参数......"; |
|||
|
|||
String NOT_ENOUGH_BALANCE = "客户:%s ,当前余额为:%s"; |
|||
|
|||
String NOT_ON_SWITCH = "客户:%s ,【%s】开关未开启"; |
|||
|
|||
} |
@ -0,0 +1,7 @@ |
|||
package com.epmet.constant; |
|||
|
|||
public interface SystemMessageSendApproach { |
|||
|
|||
String MQ = "mq"; |
|||
|
|||
} |
@ -0,0 +1,13 @@ |
|||
package com.epmet.constant; |
|||
|
|||
/** |
|||
* 系统消息类型 |
|||
*/ |
|||
public interface SystemMessageType { |
|||
|
|||
/** |
|||
* 初始化客户 |
|||
*/ |
|||
String INIT_CUSTOMER = "init_customer"; |
|||
|
|||
} |
@ -0,0 +1,88 @@ |
|||
package com.epmet.constant; |
|||
|
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
|
|||
/** |
|||
* @description: 微信订阅消息常量 |
|||
* @author: liushaowen |
|||
* @date: 2020/10/21 17:45 |
|||
*/ |
|||
|
|||
public interface WxmpMessageConstant { |
|||
String SEND_MESSAGE = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token="; |
|||
|
|||
String ERR_CODE = "errcode"; |
|||
|
|||
String ERR_MSG = "errmsg"; |
|||
|
|||
int USER_REFUSED = 43101; |
|||
|
|||
String AUTHORIZER_ACCESS_TOKEN = "authorizerAccessToken"; |
|||
|
|||
String RESI = "resi"; |
|||
|
|||
String GOV_REDIS = "work"; |
|||
|
|||
String GOV_DB = "gov"; |
|||
|
|||
String ACCESS_TOKEN = "access_token"; |
|||
|
|||
String TOUSER = "touser"; |
|||
|
|||
String TEMPLATE_ID = "template_id"; |
|||
/*站内信模板start*/ |
|||
String MESSAGE_TEMPLATE_TYPE = "1832"; |
|||
String MESSAGE_TITLE = "thing5"; |
|||
String MESSAGE_CONTENT = "thing4"; |
|||
String MESSAGE_TIME = "date2"; |
|||
/*站内信模板end*/ |
|||
|
|||
/**关注更新提醒模板start**/ |
|||
String CONCERN_UPDATE_TEMPLATE_TYPE = "8171"; |
|||
String CONCERN_UPDATE_TITLE = "thing5"; |
|||
String CONCERN_UPDATE_TITLE_TEXT = "话题状态提醒"; |
|||
String CONCERN_UPDATE_CONTENT = "thing7"; |
|||
String CONCERN_UPDATE_CONTENT_TEXT = "你关注的话题已被转为议题,请点击查看。"; |
|||
String CONCERN_UPDATE_TIME = "time6"; |
|||
/**关注更新提醒模板end**/ |
|||
|
|||
/**内容更新消息通知模板start**/ |
|||
String CONTENT_UPDATE_TEMPLATE_TYPE = "2092"; |
|||
String CONTENT_UPDATE_TITLE = "name4"; |
|||
String CONTENT_UPDATE_TITLE_TEXT = "新评论提醒"; |
|||
String CONTENT_UPDATE_CONTENT = "thing9"; |
|||
String CONTENT_UPDATE_CONTENT_TEXT = "你关注的话题收到新评论,请点击查看。"; |
|||
String CONTENT_UPDATE_TIME = "date3"; |
|||
/**内容更新消息通知模板end**/ |
|||
|
|||
/** 消息来源start**/ |
|||
//话题
|
|||
String SOURCE_TYPE_TOPIC = "topic"; |
|||
//议题
|
|||
String SOURCE_TYPE_ISSUE = "issue"; |
|||
/** 消息来源end**/ |
|||
|
|||
String PAGE = "page"; |
|||
|
|||
String MESSAGE_PAGE_URL = "/subpages/mine/pages/message/skip"; |
|||
|
|||
String UPDATE_PAGE_URL = "/pages/index/subscribe?id="; |
|||
|
|||
int TITLE_LIMIT = 20; |
|||
|
|||
int MESSAGE_CONTENT_LIMIT = 20; |
|||
|
|||
String DATA = "data"; |
|||
|
|||
String MINIPROGRAM_STATE = "miniprogram_state"; |
|||
|
|||
String SUCCESS = "success"; |
|||
|
|||
String ERROR = "error"; |
|||
|
|||
String STATE_DEV = "developer"; |
|||
|
|||
String STATE_TEST = "trial"; |
|||
|
|||
} |
@ -0,0 +1,111 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.dto; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.Date; |
|||
import lombok.Data; |
|||
|
|||
|
|||
/** |
|||
* 订阅消息发送数据表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2021-01-04 |
|||
*/ |
|||
@Data |
|||
public class WxmpUpdateSendDataDTO implements Serializable { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 主键 |
|||
*/ |
|||
private String id; |
|||
|
|||
/** |
|||
* 来源类型 (话题:topic 议题:issue 项目project 爱心互助heart 党建声音voice) |
|||
*/ |
|||
private String sourceType; |
|||
|
|||
/** |
|||
* 来源对应ID |
|||
*/ |
|||
private String sourceId; |
|||
|
|||
/** |
|||
* 客户ID |
|||
*/ |
|||
private String customerId; |
|||
|
|||
/** |
|||
* 组织ID agencyId |
|||
*/ |
|||
private String agencyId; |
|||
|
|||
/** |
|||
* 网格ID |
|||
*/ |
|||
private String gridId; |
|||
|
|||
/** |
|||
* 小组Id |
|||
*/ |
|||
private String groupId; |
|||
|
|||
/** |
|||
* 工作人员Id |
|||
*/ |
|||
private String staffId; |
|||
|
|||
/** |
|||
* 消息接收者 |
|||
*/ |
|||
private String msgUserId; |
|||
|
|||
/** |
|||
* 删除标识 0未删除、1已删除 |
|||
*/ |
|||
private String delFlag; |
|||
|
|||
/** |
|||
* 乐观锁 |
|||
*/ |
|||
private Integer revision; |
|||
|
|||
/** |
|||
* 创建人 |
|||
*/ |
|||
private String createdBy; |
|||
|
|||
/** |
|||
* 创建时间 |
|||
*/ |
|||
private Date createdTime; |
|||
|
|||
/** |
|||
* 更新人 |
|||
*/ |
|||
private String updatedBy; |
|||
|
|||
/** |
|||
* 更新时间 |
|||
*/ |
|||
private Date updatedTime; |
|||
|
|||
} |
@ -0,0 +1,131 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.dto; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.Date; |
|||
import lombok.Data; |
|||
|
|||
|
|||
/** |
|||
* 订阅消息发送记录表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2020-12-30 |
|||
*/ |
|||
@Data |
|||
public class WxmpUpdateSendRecordDTO implements Serializable { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 主键 |
|||
*/ |
|||
private String id; |
|||
|
|||
/** |
|||
* 客户Id |
|||
*/ |
|||
private String customerId; |
|||
|
|||
/** |
|||
* 网格Id (居民端跟网格有关的则有值,工作端以及一些居民端和网格没关的存*) |
|||
*/ |
|||
private String gridId; |
|||
|
|||
/** |
|||
* 所属端类型 居民端:resi 工作端:gov |
|||
*/ |
|||
private String clientType; |
|||
|
|||
/** |
|||
* 消息模板Id |
|||
*/ |
|||
private String templateId; |
|||
|
|||
/** |
|||
* 用户Id |
|||
*/ |
|||
private String userId; |
|||
|
|||
/** |
|||
* openId |
|||
*/ |
|||
private String wxOpenId; |
|||
|
|||
/** |
|||
* 行为类型: 关注更新提醒、内容更新消息通知 |
|||
*/ |
|||
private String behaviorType; |
|||
|
|||
/** |
|||
* 消息标题 |
|||
*/ |
|||
private String title; |
|||
|
|||
/** |
|||
* 消息内容 |
|||
*/ |
|||
private String content; |
|||
|
|||
/** |
|||
* 消息时间 |
|||
*/ |
|||
private Date time; |
|||
|
|||
/** |
|||
* 发送结果(成功:success 失败:error) |
|||
*/ |
|||
private String result; |
|||
|
|||
/** |
|||
* 发送失败的原因,成功可以不记录 |
|||
*/ |
|||
private String reason; |
|||
|
|||
/** |
|||
* 删除标识 |
|||
*/ |
|||
private String delFlag; |
|||
|
|||
/** |
|||
* 乐观锁 |
|||
*/ |
|||
private Integer revision; |
|||
|
|||
/** |
|||
* 创建人 |
|||
*/ |
|||
private String createdBy; |
|||
|
|||
/** |
|||
* 创建时间 |
|||
*/ |
|||
private Date createdTime; |
|||
|
|||
/** |
|||
* 更新人 |
|||
*/ |
|||
private String updatedBy; |
|||
|
|||
/** |
|||
* 更新时间 |
|||
*/ |
|||
private Date updatedTime; |
|||
|
|||
} |
@ -0,0 +1,43 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import com.epmet.commons.tools.validator.group.CustomerClientShowGroup; |
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* 项目提醒--根据手机号、短信模板编码,发送短信 验证码 |
|||
* |
|||
* @author sun |
|||
*/ |
|||
@Data |
|||
public class ProjectSendMsgFormDTO implements Serializable { |
|||
private static final long serialVersionUID = 8894395590639206399L; |
|||
/** |
|||
* 手机号 |
|||
*/ |
|||
@NotBlank(message = "手机号不能为空", groups = {AddUserInternalGroup.class, AddUserShowGroup.class}) |
|||
private String mobile; |
|||
/** |
|||
* 场景: |
|||
*/ |
|||
@NotBlank(message = "短信模板编码不能为空", groups = {AddUserInternalGroup.class}) |
|||
private String aliyunTemplateCode; |
|||
|
|||
/** |
|||
* 客户ID |
|||
*/ |
|||
@NotBlank(message = "客户ID不能为空", groups = {AddUserInternalGroup.class}) |
|||
private String customerId; |
|||
|
|||
/** |
|||
* 参数KEY(发短信:send_msg;) |
|||
*/ |
|||
@NotBlank(message = "参数KEY不能为空", groups = {AddUserInternalGroup.class}) |
|||
private String parameterKey; |
|||
|
|||
public interface AddUserInternalGroup {} |
|||
|
|||
public interface AddUserShowGroup extends CustomerClientShowGroup {} |
|||
} |
@ -0,0 +1,15 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotNull; |
|||
|
|||
@Data |
|||
public class SystemMsgFormDTO { |
|||
|
|||
@NotNull(message = "消息类型不能为空") |
|||
private String messageType; |
|||
|
|||
@NotNull(message = "消息内容不能为空") |
|||
private Object content; |
|||
} |
@ -0,0 +1,86 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
import javax.validation.constraints.NotNull; |
|||
import java.io.Serializable; |
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* @description: 微信订阅消息FormDTO |
|||
* @author: liushaowen |
|||
* @date: 2020/10/21 14:29 |
|||
*/ |
|||
@Data |
|||
public class WxSubscribeUpdateFormDTO implements Serializable { |
|||
private static final long serialVersionUID = 1L; |
|||
/** |
|||
* 客户id |
|||
*/ |
|||
@NotBlank(message = "客户id不能为空") |
|||
private String customerId; |
|||
/** |
|||
* 客户端类型 居民端:resi 工作端:work |
|||
*/ |
|||
@NotBlank(message = "客户端类型不能为空") |
|||
private String clientType; |
|||
|
|||
/** |
|||
* 接收者(用户)的 userId |
|||
*/ |
|||
@NotBlank(message = "接收用户id不能为空") |
|||
private String userId; |
|||
|
|||
/** |
|||
* 来源类型 (话题:topic 议题:issue 项目project 爱心互助heart 党建声音voice)等 |
|||
*/ |
|||
@NotBlank(message = "来源类型不能为空") |
|||
private String sourceType; |
|||
/** |
|||
* 来源对应id |
|||
*/ |
|||
@NotBlank(message = "来源id不能为空") |
|||
private String sourceId; |
|||
|
|||
/** |
|||
* 行为类型 传模板的tid |
|||
*/ |
|||
@NotBlank(message = "行为类型不能为空") |
|||
private String behaviorType; |
|||
|
|||
@NotBlank(message = "消息标题不能为空") |
|||
private String messageTitle; |
|||
|
|||
/** |
|||
* 消息内容 |
|||
*/ |
|||
@NotBlank(message = "消息内容不能为空") |
|||
private String messageContent; |
|||
|
|||
/** |
|||
* 消息时间 |
|||
*/ |
|||
@NotNull(message = "消息时间不能为空") |
|||
private Date messageTime; |
|||
|
|||
/** |
|||
* 网格id |
|||
*/ |
|||
private String gridId; |
|||
/** |
|||
* 工作人员id |
|||
*/ |
|||
private String staffId; |
|||
|
|||
/** |
|||
* 群id |
|||
*/ |
|||
private String groupId; |
|||
/** |
|||
* 组织id |
|||
*/ |
|||
private String agencyId; |
|||
|
|||
|
|||
} |
@ -1,63 +0,0 @@ |
|||
package com.epmet.constant; |
|||
|
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
|
|||
/** |
|||
* @description: 微信订阅消息常量 |
|||
* @author: liushaowen |
|||
* @date: 2020/10/21 17:45 |
|||
*/ |
|||
|
|||
public interface WxmpMessageConstant { |
|||
String SEND_MESSAGE = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token="; |
|||
|
|||
String ERR_CODE = "errcode"; |
|||
|
|||
String ERR_MSG = "errmsg"; |
|||
|
|||
int USER_REFUSED = 43101; |
|||
|
|||
String AUTHORIZER_ACCESS_TOKEN = "authorizerAccessToken"; |
|||
|
|||
String RESI = "resi"; |
|||
|
|||
String GOV_REDIS = "work"; |
|||
|
|||
String GOV_DB = "gov"; |
|||
|
|||
String ACCESS_TOKEN = "access_token"; |
|||
|
|||
String TOUSER = "touser"; |
|||
|
|||
String TEMPLATE_ID = "template_id"; |
|||
|
|||
String TEMPLATE_TYPE = "1832"; |
|||
|
|||
String PAGE = "page"; |
|||
|
|||
String PAGE_URL = "/subpages/mine/pages/message/skip"; |
|||
|
|||
String TITLE = "thing5"; |
|||
|
|||
int TITLE_LIMIT = 20; |
|||
|
|||
String MESSAGE_CONTENT = "thing4"; |
|||
|
|||
int MESSAGE_CONTENT_LIMIT = 20; |
|||
|
|||
String MESSAGE_TIME = "date2"; |
|||
|
|||
String DATA = "data"; |
|||
|
|||
String MINIPROGRAM_STATE = "miniprogram_state"; |
|||
|
|||
String SUCCESS = "success"; |
|||
|
|||
String ERROR = "error"; |
|||
|
|||
String STATE_DEV = "developer"; |
|||
|
|||
String STATE_TEST = "trial"; |
|||
|
|||
} |
@ -0,0 +1,27 @@ |
|||
package com.epmet.controller; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.commons.tools.validator.ValidatorUtils; |
|||
import com.epmet.dto.form.SystemMsgFormDTO; |
|||
import com.epmet.service.SystemMessageService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestBody; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
@RestController |
|||
@RequestMapping("system") |
|||
public class SystemMessageController { |
|||
|
|||
@Autowired |
|||
private SystemMessageService systemMessageService; |
|||
|
|||
@PostMapping("send-by-mq") |
|||
public Result sendSystemMsgByMQ(@RequestBody SystemMsgFormDTO form) { |
|||
ValidatorUtils.validateEntity(form); |
|||
systemMessageService.sendMQMessage(form.getMessageType(), form.getContent()); |
|||
return new Result(); |
|||
} |
|||
|
|||
} |
@ -0,0 +1,98 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.controller; |
|||
|
|||
import com.epmet.commons.tools.page.PageData; |
|||
import com.epmet.commons.tools.utils.ExcelUtils; |
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.commons.tools.validator.AssertUtils; |
|||
import com.epmet.commons.tools.validator.ValidatorUtils; |
|||
import com.epmet.commons.tools.validator.group.AddGroup; |
|||
import com.epmet.commons.tools.validator.group.UpdateGroup; |
|||
import com.epmet.commons.tools.validator.group.DefaultGroup; |
|||
import com.epmet.dto.WxmpUpdateSendDataDTO; |
|||
import com.epmet.excel.WxmpUpdateSendDataExcel; |
|||
import com.epmet.service.WxmpUpdateSendDataService; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.*; |
|||
|
|||
import javax.servlet.http.HttpServletResponse; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
|
|||
/** |
|||
* 订阅消息发送数据表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2021-01-04 |
|||
*/ |
|||
@RestController |
|||
@RequestMapping("wxmpupdatesenddata") |
|||
public class WxmpUpdateSendDataController { |
|||
|
|||
@Autowired |
|||
private WxmpUpdateSendDataService wxmpUpdateSendDataService; |
|||
|
|||
@GetMapping("page") |
|||
public Result<PageData<WxmpUpdateSendDataDTO>> page(@RequestParam Map<String, Object> params){ |
|||
PageData<WxmpUpdateSendDataDTO> page = wxmpUpdateSendDataService.page(params); |
|||
return new Result<PageData<WxmpUpdateSendDataDTO>>().ok(page); |
|||
} |
|||
|
|||
@GetMapping("{id}") |
|||
public Result<WxmpUpdateSendDataDTO> get(@PathVariable("id") String id){ |
|||
if (StringUtils.isBlank(id) || "undefined".equals(id)){ |
|||
return new Result().error(8000,"id不能为空"); |
|||
} |
|||
WxmpUpdateSendDataDTO data = wxmpUpdateSendDataService.get(id); |
|||
return new Result<WxmpUpdateSendDataDTO>().ok(data); |
|||
} |
|||
|
|||
@PostMapping |
|||
public Result save(@RequestBody WxmpUpdateSendDataDTO dto){ |
|||
//效验数据
|
|||
ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class); |
|||
wxmpUpdateSendDataService.save(dto); |
|||
return new Result(); |
|||
} |
|||
|
|||
@PutMapping |
|||
public Result update(@RequestBody WxmpUpdateSendDataDTO dto){ |
|||
//效验数据
|
|||
ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class); |
|||
wxmpUpdateSendDataService.update(dto); |
|||
return new Result(); |
|||
} |
|||
|
|||
@DeleteMapping |
|||
public Result delete(@RequestBody String[] ids){ |
|||
//效验数据
|
|||
AssertUtils.isArrayEmpty(ids, "id"); |
|||
wxmpUpdateSendDataService.delete(ids); |
|||
return new Result(); |
|||
} |
|||
|
|||
@GetMapping("export") |
|||
public void export(@RequestParam Map<String, Object> params, HttpServletResponse response) throws Exception { |
|||
List<WxmpUpdateSendDataDTO> list = wxmpUpdateSendDataService.list(params); |
|||
ExcelUtils.exportExcelToTarget(response, null, list, WxmpUpdateSendDataExcel.class); |
|||
} |
|||
|
|||
} |
@ -0,0 +1,94 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.controller; |
|||
|
|||
import com.epmet.commons.tools.page.PageData; |
|||
import com.epmet.commons.tools.utils.ExcelUtils; |
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.commons.tools.validator.AssertUtils; |
|||
import com.epmet.commons.tools.validator.ValidatorUtils; |
|||
import com.epmet.commons.tools.validator.group.AddGroup; |
|||
import com.epmet.commons.tools.validator.group.UpdateGroup; |
|||
import com.epmet.commons.tools.validator.group.DefaultGroup; |
|||
import com.epmet.dto.WxmpUpdateSendRecordDTO; |
|||
import com.epmet.excel.WxmpUpdateSendRecordExcel; |
|||
import com.epmet.service.WxmpUpdateSendRecordService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.*; |
|||
|
|||
import javax.servlet.http.HttpServletResponse; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
|
|||
/** |
|||
* 订阅消息发送记录表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2020-12-30 |
|||
*/ |
|||
@RestController |
|||
@RequestMapping("wxmpupdatesendrecord") |
|||
public class WxmpUpdateSendRecordController { |
|||
|
|||
@Autowired |
|||
private WxmpUpdateSendRecordService wxmpUpdateSendRecordService; |
|||
|
|||
@GetMapping("page") |
|||
public Result<PageData<WxmpUpdateSendRecordDTO>> page(@RequestParam Map<String, Object> params){ |
|||
PageData<WxmpUpdateSendRecordDTO> page = wxmpUpdateSendRecordService.page(params); |
|||
return new Result<PageData<WxmpUpdateSendRecordDTO>>().ok(page); |
|||
} |
|||
|
|||
@GetMapping("{id}") |
|||
public Result<WxmpUpdateSendRecordDTO> get(@PathVariable("id") String id){ |
|||
WxmpUpdateSendRecordDTO data = wxmpUpdateSendRecordService.get(id); |
|||
return new Result<WxmpUpdateSendRecordDTO>().ok(data); |
|||
} |
|||
|
|||
@PostMapping |
|||
public Result save(@RequestBody WxmpUpdateSendRecordDTO dto){ |
|||
//效验数据
|
|||
ValidatorUtils.validateEntity(dto, AddGroup.class, DefaultGroup.class); |
|||
wxmpUpdateSendRecordService.save(dto); |
|||
return new Result(); |
|||
} |
|||
|
|||
@PutMapping |
|||
public Result update(@RequestBody WxmpUpdateSendRecordDTO dto){ |
|||
//效验数据
|
|||
ValidatorUtils.validateEntity(dto, UpdateGroup.class, DefaultGroup.class); |
|||
wxmpUpdateSendRecordService.update(dto); |
|||
return new Result(); |
|||
} |
|||
|
|||
@DeleteMapping |
|||
public Result delete(@RequestBody String[] ids){ |
|||
//效验数据
|
|||
AssertUtils.isArrayEmpty(ids, "id"); |
|||
wxmpUpdateSendRecordService.delete(ids); |
|||
return new Result(); |
|||
} |
|||
|
|||
@GetMapping("export") |
|||
public void export(@RequestParam Map<String, Object> params, HttpServletResponse response) throws Exception { |
|||
List<WxmpUpdateSendRecordDTO> list = wxmpUpdateSendRecordService.list(params); |
|||
ExcelUtils.exportExcelToTarget(response, null, list, WxmpUpdateSendRecordExcel.class); |
|||
} |
|||
|
|||
} |
@ -0,0 +1,33 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.dao; |
|||
|
|||
import com.epmet.commons.mybatis.dao.BaseDao; |
|||
import com.epmet.entity.SystemMessageEntity; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
|
|||
/** |
|||
* 系统消息表 |
|||
* |
|||
* @author generator generator@elink-cn.com |
|||
* @since v1.0.0 2021-01-06 |
|||
*/ |
|||
@Mapper |
|||
public interface SystemMessageDao extends BaseDao<SystemMessageEntity> { |
|||
|
|||
} |
@ -0,0 +1,33 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.dao; |
|||
|
|||
import com.epmet.commons.mybatis.dao.BaseDao; |
|||
import com.epmet.entity.WxmpUpdateSendDataEntity; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
|
|||
/** |
|||
* 订阅消息发送数据表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2021-01-04 |
|||
*/ |
|||
@Mapper |
|||
public interface WxmpUpdateSendDataDao extends BaseDao<WxmpUpdateSendDataEntity> { |
|||
|
|||
} |
@ -0,0 +1,33 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.dao; |
|||
|
|||
import com.epmet.commons.mybatis.dao.BaseDao; |
|||
import com.epmet.entity.WxmpUpdateSendRecordEntity; |
|||
import org.apache.ibatis.annotations.Mapper; |
|||
|
|||
/** |
|||
* 订阅消息发送记录表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2020-12-30 |
|||
*/ |
|||
@Mapper |
|||
public interface WxmpUpdateSendRecordDao extends BaseDao<WxmpUpdateSendRecordEntity> { |
|||
|
|||
} |
@ -0,0 +1,57 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
|
|||
import com.epmet.commons.mybatis.entity.BaseEpmetEntity; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
import org.omg.CORBA.StringHolder; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 系统消息表 |
|||
* |
|||
* @author generator generator@elink-cn.com |
|||
* @since v1.0.0 2021-01-06 |
|||
*/ |
|||
@Data |
|||
@EqualsAndHashCode(callSuper=false) |
|||
@TableName("system_message") |
|||
public class SystemMessageEntity extends BaseEpmetEntity { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 消息类型 |
|||
*/ |
|||
private String msgType; |
|||
|
|||
/** |
|||
* 发送途径 |
|||
*/ |
|||
private String sendApproach; |
|||
|
|||
/** |
|||
* 消息内容 |
|||
*/ |
|||
private String content; |
|||
|
|||
} |
@ -0,0 +1,81 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
|
|||
import com.epmet.commons.mybatis.entity.BaseEpmetEntity; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 订阅消息发送数据表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2021-01-04 |
|||
*/ |
|||
@Data |
|||
@EqualsAndHashCode(callSuper=false) |
|||
@TableName("wxmp_update_send_data") |
|||
public class WxmpUpdateSendDataEntity extends BaseEpmetEntity { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 来源类型 (话题:topic 议题:issue 项目project 爱心互助heart 党建声音voice) |
|||
*/ |
|||
private String sourceType; |
|||
|
|||
/** |
|||
* 来源对应ID |
|||
*/ |
|||
private String sourceId; |
|||
|
|||
/** |
|||
* 客户ID |
|||
*/ |
|||
private String customerId; |
|||
|
|||
/** |
|||
* 组织ID agencyId |
|||
*/ |
|||
private String agencyId; |
|||
|
|||
/** |
|||
* 网格ID |
|||
*/ |
|||
private String gridId; |
|||
|
|||
/** |
|||
* 小组Id |
|||
*/ |
|||
private String groupId; |
|||
|
|||
/** |
|||
* 工作人员Id |
|||
*/ |
|||
private String staffId; |
|||
|
|||
/** |
|||
* 消息接收者 |
|||
*/ |
|||
private String msgUserId; |
|||
|
|||
} |
@ -0,0 +1,101 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.entity; |
|||
|
|||
import com.baomidou.mybatisplus.annotation.TableName; |
|||
|
|||
import com.epmet.commons.mybatis.entity.BaseEpmetEntity; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 订阅消息发送记录表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2020-12-30 |
|||
*/ |
|||
@Data |
|||
@EqualsAndHashCode(callSuper=false) |
|||
@TableName("wxmp_update_send_record") |
|||
public class WxmpUpdateSendRecordEntity extends BaseEpmetEntity { |
|||
|
|||
private static final long serialVersionUID = 1L; |
|||
|
|||
/** |
|||
* 客户Id |
|||
*/ |
|||
private String customerId; |
|||
|
|||
/** |
|||
* 网格Id (居民端跟网格有关的则有值,工作端以及一些居民端和网格没关的存*) |
|||
*/ |
|||
private String gridId; |
|||
|
|||
/** |
|||
* 所属端类型 居民端:resi 工作端:gov |
|||
*/ |
|||
private String clientType; |
|||
|
|||
/** |
|||
* 消息模板Id |
|||
*/ |
|||
private String templateId; |
|||
|
|||
/** |
|||
* 用户Id |
|||
*/ |
|||
private String userId; |
|||
|
|||
/** |
|||
* openId |
|||
*/ |
|||
private String wxOpenId; |
|||
|
|||
/** |
|||
* 行为类型: 关注更新提醒、内容更新消息通知 |
|||
*/ |
|||
private String behaviorType; |
|||
|
|||
/** |
|||
* 消息标题 |
|||
*/ |
|||
private String title; |
|||
|
|||
/** |
|||
* 消息内容 |
|||
*/ |
|||
private String content; |
|||
|
|||
/** |
|||
* 消息时间 |
|||
*/ |
|||
private Date time; |
|||
|
|||
/** |
|||
* 发送结果(成功:success 失败:error) |
|||
*/ |
|||
private String result; |
|||
|
|||
/** |
|||
* 发送失败的原因,成功可以不记录 |
|||
*/ |
|||
private String reason; |
|||
|
|||
} |
@ -0,0 +1,80 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.excel; |
|||
|
|||
import cn.afterturn.easypoi.excel.annotation.Excel; |
|||
import lombok.Data; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 订阅消息发送数据表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2021-01-04 |
|||
*/ |
|||
@Data |
|||
public class WxmpUpdateSendDataExcel { |
|||
|
|||
@Excel(name = "主键") |
|||
private String id; |
|||
|
|||
@Excel(name = "来源类型 (话题:topic 议题:issue 项目project 爱心互助heart 党建声音voice)") |
|||
private String sourceType; |
|||
|
|||
@Excel(name = "来源对应ID") |
|||
private String sourceId; |
|||
|
|||
@Excel(name = "客户ID") |
|||
private String customerId; |
|||
|
|||
@Excel(name = "组织ID agencyId") |
|||
private String agencyId; |
|||
|
|||
@Excel(name = "网格ID ") |
|||
private String gridId; |
|||
|
|||
@Excel(name = "小组Id") |
|||
private String groupId; |
|||
|
|||
@Excel(name = "工作人员Id") |
|||
private String staffId; |
|||
|
|||
@Excel(name = "消息接收者") |
|||
private String msgUserId; |
|||
|
|||
@Excel(name = "删除标识 0未删除、1已删除") |
|||
private String delFlag; |
|||
|
|||
@Excel(name = "乐观锁") |
|||
private Integer revision; |
|||
|
|||
@Excel(name = "创建人") |
|||
private String createdBy; |
|||
|
|||
@Excel(name = "创建时间") |
|||
private Date createdTime; |
|||
|
|||
@Excel(name = "更新人") |
|||
private String updatedBy; |
|||
|
|||
@Excel(name = "更新时间") |
|||
private Date updatedTime; |
|||
|
|||
|
|||
} |
@ -0,0 +1,92 @@ |
|||
/** |
|||
* Copyright 2018 人人开源 https://www.renren.io
|
|||
* <p> |
|||
* This program is free software: you can redistribute it and/or modify |
|||
* it under the terms of the GNU General Public License as published by |
|||
* the Free Software Foundation, either version 3 of the License, or |
|||
* (at your option) any later version. |
|||
* <p> |
|||
* This program is distributed in the hope that it will be useful, |
|||
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
|||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
|||
* GNU General Public License for more details. |
|||
* <p> |
|||
* You should have received a copy of the GNU General Public License |
|||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|||
*/ |
|||
|
|||
package com.epmet.excel; |
|||
|
|||
import cn.afterturn.easypoi.excel.annotation.Excel; |
|||
import lombok.Data; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 订阅消息发送记录表(内容更新消息提醒、关注更新提醒) |
|||
* |
|||
* @author qu qu@elink-cn.com |
|||
* @since v1.0.0 2020-12-30 |
|||
*/ |
|||
@Data |
|||
public class WxmpUpdateSendRecordExcel { |
|||
|
|||
@Excel(name = "主键") |
|||
private String id; |
|||
|
|||
@Excel(name = "客户Id ") |
|||
private String customerId; |
|||
|
|||
@Excel(name = "网格Id (居民端跟网格有关的则有值,工作端以及一些居民端和网格没关的存*)") |
|||
private String gridId; |
|||
|
|||
@Excel(name = "所属端类型 居民端:resi 工作端:gov") |
|||
private String clientType; |
|||
|
|||
@Excel(name = "消息模板Id ") |
|||
private String templateId; |
|||
|
|||
@Excel(name = "用户Id") |
|||
private String userId; |
|||
|
|||
@Excel(name = "openId ") |
|||
private String wxOpenId; |
|||
|
|||
@Excel(name = "行为类型: 关注更新提醒、内容更新消息通知") |
|||
private String behaviorType; |
|||
|
|||
@Excel(name = "消息标题 ") |
|||
private String title; |
|||
|
|||
@Excel(name = "消息内容 ") |
|||
private String content; |
|||
|
|||
@Excel(name = "消息时间 ") |
|||
private Date time; |
|||
|
|||
@Excel(name = "发送结果(成功:success 失败:error)") |
|||
private String result; |
|||
|
|||
@Excel(name = "发送失败的原因,成功可以不记录") |
|||
private String reason; |
|||
|
|||
@Excel(name = "删除标识") |
|||
private String delFlag; |
|||
|
|||
@Excel(name = "乐观锁") |
|||
private Integer revision; |
|||
|
|||
@Excel(name = "创建人") |
|||
private String createdBy; |
|||
|
|||
@Excel(name = "创建时间") |
|||
private Date createdTime; |
|||
|
|||
@Excel(name = "更新人") |
|||
private String updatedBy; |
|||
|
|||
@Excel(name = "更新时间") |
|||
private Date updatedTime; |
|||
|
|||
|
|||
} |
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue