Browse Source
Conflicts: epmet-module/data-statistical/data-statistical-server/deploy/docker-compose-dev.yml epmet-module/data-statistical/data-statistical-server/deploy/docker-compose-test.yml epmet-module/data-statistical/data-statistical-server/pom.xmlmaster
291 changed files with 11983 additions and 1596 deletions
@ -0,0 +1,19 @@ |
|||||
|
package com.epmet.dto.form; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import javax.validation.constraints.NotBlank; |
||||
|
import java.util.List; |
||||
|
|
||||
|
@Data |
||||
|
public class UpdateCachedRolesFormDTO { |
||||
|
|
||||
|
@NotBlank(message = "客户ID不能为空") |
||||
|
private String staffId; |
||||
|
|
||||
|
@NotBlank(message = "机关ID不能为空") |
||||
|
private String orgId; |
||||
|
|
||||
|
private List<String> roleIds; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,103 @@ |
|||||
|
package com.epmet.commons.tools.dto.form; |
||||
|
|
||||
|
import com.alibaba.fastjson.JSON; |
||||
|
import org.springframework.util.CollectionUtils; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.HashMap; |
||||
|
import java.util.List; |
||||
|
import java.util.Map; |
||||
|
|
||||
|
/** |
||||
|
* desc: 钉钉文本消息参数 实体类 |
||||
|
* |
||||
|
* @date: 2020/6/29 9:06 |
||||
|
* @author: jianjun liu |
||||
|
* email:liujianjun@git.elinkit.com.cn |
||||
|
*/ |
||||
|
public class DingTalkTextMsg implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = -3611771312188821915L; |
||||
|
/** |
||||
|
* 消息接收者 |
||||
|
*/ |
||||
|
private String webHook; |
||||
|
|
||||
|
/** |
||||
|
* 密钥 |
||||
|
*/ |
||||
|
private String secret; |
||||
|
/** |
||||
|
* 发送内容 |
||||
|
*/ |
||||
|
private String content; |
||||
|
|
||||
|
/** |
||||
|
* at的群成员手机号 |
||||
|
*/ |
||||
|
private List<String> atMobiles; |
||||
|
|
||||
|
/** |
||||
|
* 是否at所有人 |
||||
|
*/ |
||||
|
private boolean isAtAll; |
||||
|
|
||||
|
public String getWebHook() { |
||||
|
return webHook; |
||||
|
} |
||||
|
|
||||
|
public void setWebHook(String webHook) { |
||||
|
this.webHook = webHook; |
||||
|
} |
||||
|
|
||||
|
public String getContent() { |
||||
|
return content; |
||||
|
} |
||||
|
|
||||
|
public void setContent(String content) { |
||||
|
this.content = content; |
||||
|
} |
||||
|
|
||||
|
public List<String> getAtMobiles() { |
||||
|
return atMobiles; |
||||
|
} |
||||
|
|
||||
|
public void setAtMobiles(List<String> atMobiles) { |
||||
|
this.atMobiles = atMobiles; |
||||
|
} |
||||
|
|
||||
|
public boolean isAtAll() { |
||||
|
return isAtAll; |
||||
|
} |
||||
|
|
||||
|
public void setAtAll(boolean atAll) { |
||||
|
isAtAll = atAll; |
||||
|
} |
||||
|
|
||||
|
public String getSecret() { |
||||
|
return secret; |
||||
|
} |
||||
|
|
||||
|
public void setSecret(String secret) { |
||||
|
this.secret = secret; |
||||
|
} |
||||
|
|
||||
|
public String getMsgContent() { |
||||
|
Map<String, Object> items = new HashMap<>(); |
||||
|
items.put("msgtype", "text"); |
||||
|
|
||||
|
Map<String, String> textContent = new HashMap<>(); |
||||
|
textContent.put("content", getContent()); |
||||
|
items.put("text", textContent); |
||||
|
|
||||
|
Map<String, Object> atItems = new HashMap<>(); |
||||
|
if (!CollectionUtils.isEmpty(atMobiles)) { |
||||
|
atItems.put("atMobiles", atMobiles); |
||||
|
} |
||||
|
if (isAtAll) { |
||||
|
atItems.put("isAtAll", isAtAll); |
||||
|
} |
||||
|
items.put("at", atItems); |
||||
|
return JSON.toJSONString(items); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,116 @@ |
|||||
|
package com.epmet.commons.tools.filter; |
||||
|
|
||||
|
import ch.qos.logback.classic.Level; |
||||
|
import ch.qos.logback.classic.filter.LevelFilter; |
||||
|
import ch.qos.logback.classic.spi.ILoggingEvent; |
||||
|
import ch.qos.logback.classic.spi.IThrowableProxy; |
||||
|
import ch.qos.logback.classic.spi.StackTraceElementProxy; |
||||
|
import ch.qos.logback.core.spi.FilterReply; |
||||
|
import com.epmet.commons.tools.dto.form.DingTalkTextMsg; |
||||
|
import com.epmet.commons.tools.utils.DingdingMsgSender; |
||||
|
import org.apache.commons.lang3.StringUtils; |
||||
|
import org.slf4j.Logger; |
||||
|
import org.slf4j.LoggerFactory; |
||||
|
|
||||
|
import java.text.SimpleDateFormat; |
||||
|
|
||||
|
/** |
||||
|
* desc: 发送日志消息 |
||||
|
* |
||||
|
* @date: 2020/6/24 17:47 |
||||
|
* @author: jianjun liu |
||||
|
*/ |
||||
|
public class LogMsgSendFilter extends LevelFilter { |
||||
|
private static final Logger logger = LoggerFactory.getLogger(LogMsgSendFilter.class); |
||||
|
private DingdingMsgSender msgSender = new DingdingMsgSender(); |
||||
|
private String webHook; |
||||
|
private String secret; |
||||
|
|
||||
|
@Override |
||||
|
public FilterReply decide(ILoggingEvent event) { |
||||
|
//如果日志级别等于设置的日志级别 则发送消息
|
||||
|
if (event.getLevel().isGreaterOrEqual(Level.ERROR)) { |
||||
|
try { |
||||
|
StringBuilder stringBuilder = new StringBuilder(); |
||||
|
stringBuilder.append("【日志告警】\n"); |
||||
|
|
||||
|
stringBuilder.append("\n"); |
||||
|
|
||||
|
stringBuilder.append("告警级别:" + event.getLevel()); |
||||
|
stringBuilder.append("\n"); |
||||
|
stringBuilder.append("故障时间:" + formatLongTime2Str(event.getTimeStamp())); |
||||
|
stringBuilder.append("\n"); |
||||
|
stringBuilder.append("TraceId:" + Thread.currentThread().getName()); |
||||
|
stringBuilder.append("\n"); |
||||
|
stringBuilder.append("告警信息:" + event.getFormattedMessage()); |
||||
|
stringBuilder.append("\n"); |
||||
|
|
||||
|
IThrowableProxy throwableProxy = event.getThrowableProxy(); |
||||
|
//异常信息处理 暂时处理一级的5行数据
|
||||
|
apendStackInfo(stringBuilder, throwableProxy); |
||||
|
DingTalkTextMsg msg = new DingTalkTextMsg(); |
||||
|
msg.setContent(stringBuilder.toString()); |
||||
|
if (StringUtils.isNotBlank(webHook)) { |
||||
|
msg.setWebHook(webHook); |
||||
|
} |
||||
|
if (StringUtils.isNotBlank(secret)) { |
||||
|
msg.setSecret(secret); |
||||
|
} |
||||
|
boolean flag = msgSender.sendMsgAsync(msg); |
||||
|
if (!flag) { |
||||
|
logger.warn("msgSender.sendMsg fail,param:{}", stringBuilder.toString()); |
||||
|
} |
||||
|
} catch (Exception e) { |
||||
|
logger.warn("decide exception", e); |
||||
|
} |
||||
|
} |
||||
|
//交给其他filter继续向下处理
|
||||
|
return super.decide(event); |
||||
|
} |
||||
|
|
||||
|
private void apendStackInfo(StringBuilder stringBuilder, IThrowableProxy throwableProxy) { |
||||
|
int defaultRowLine = 5; |
||||
|
if (throwableProxy != null) { |
||||
|
stringBuilder.append("异常信息:") |
||||
|
.append(throwableProxy.getClassName()) |
||||
|
.append(" : ") |
||||
|
.append(throwableProxy.getMessage()) |
||||
|
.append("\n"); |
||||
|
|
||||
|
StackTraceElementProxy[] stackTraceElementProxyArray = throwableProxy.getStackTraceElementProxyArray(); |
||||
|
StackTraceElementProxy stackTraceElementProxy = null; |
||||
|
|
||||
|
if (stackTraceElementProxyArray.length < defaultRowLine) { |
||||
|
defaultRowLine = stackTraceElementProxyArray.length; |
||||
|
} |
||||
|
for (int i = 0; i < defaultRowLine; i++) { |
||||
|
stackTraceElementProxy = stackTraceElementProxyArray[i]; |
||||
|
StackTraceElement stackTraceElement = stackTraceElementProxy.getStackTraceElement(); |
||||
|
stringBuilder.append("\t\tat "); |
||||
|
stringBuilder.append(stackTraceElement.getClassName()); |
||||
|
stringBuilder.append("."); |
||||
|
stringBuilder.append(stackTraceElement.getMethodName()); |
||||
|
stringBuilder.append("("); |
||||
|
stringBuilder.append(stackTraceElement.getFileName()); |
||||
|
stringBuilder.append(":"); |
||||
|
stringBuilder.append(stackTraceElement.getLineNumber()); |
||||
|
stringBuilder.append(")"); |
||||
|
stringBuilder.append("\n"); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
|
||||
|
private String formatLongTime2Str(long timestamp) { |
||||
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss.SSS"); |
||||
|
return dateFormat.format(timestamp); |
||||
|
} |
||||
|
|
||||
|
public void setWebHook(String webHook) { |
||||
|
this.webHook = webHook; |
||||
|
} |
||||
|
|
||||
|
public void setSecret(String secret) { |
||||
|
this.secret = secret; |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,185 @@ |
|||||
|
package com.epmet.commons.tools.utils; |
||||
|
|
||||
|
import com.alibaba.fastjson.JSON; |
||||
|
import com.epmet.commons.tools.dto.form.DingTalkTextMsg; |
||||
|
import com.google.common.cache.Cache; |
||||
|
import com.google.common.cache.CacheBuilder; |
||||
|
import com.google.common.collect.Lists; |
||||
|
import org.apache.commons.codec.binary.Base64; |
||||
|
import org.apache.commons.lang3.StringUtils; |
||||
|
import org.slf4j.Logger; |
||||
|
import org.slf4j.LoggerFactory; |
||||
|
import org.springframework.stereotype.Component; |
||||
|
|
||||
|
import javax.annotation.PreDestroy; |
||||
|
import javax.crypto.Mac; |
||||
|
import javax.crypto.spec.SecretKeySpec; |
||||
|
import java.io.IOException; |
||||
|
import java.net.URLEncoder; |
||||
|
import java.util.concurrent.ArrayBlockingQueue; |
||||
|
import java.util.concurrent.TimeUnit; |
||||
|
import java.util.concurrent.atomic.AtomicInteger; |
||||
|
|
||||
|
/** |
||||
|
* desc: 发送消息工具类 |
||||
|
* |
||||
|
* @date: 2020/6/29 8:43 |
||||
|
* @author: jianjun liu |
||||
|
*/ |
||||
|
@Component |
||||
|
public class DingdingMsgSender { |
||||
|
|
||||
|
private final Logger logger = LoggerFactory.getLogger(DingdingMsgSender.class); |
||||
|
//如果不设置则为 开发环境机器人地址
|
||||
|
private static final String webHook = "https://oapi.dingtalk.com/robot/send?access_token=90782b119f82a5b6bb8e0f819b6a77bbc2102b53aa2d7d2e24fa10b66d580b1c"; |
||||
|
private static final String secret = "SEC080aac67ff78e79fdaba132aa51e3fb3f6060dec99492feaac82cabf9f8b6a19"; |
||||
|
/** |
||||
|
* 默认10 |
||||
|
*/ |
||||
|
private static Integer maxQueueSize = 10; |
||||
|
|
||||
|
/** |
||||
|
* 有序队列 |
||||
|
*/ |
||||
|
private ArrayBlockingQueue<DingTalkTextMsg> msgQueue = new ArrayBlockingQueue<>(maxQueueSize); |
||||
|
|
||||
|
|
||||
|
private volatile boolean running = false; |
||||
|
|
||||
|
private Cache<String, AtomicInteger> limitCache = CacheBuilder.newBuilder().expireAfterWrite(1, TimeUnit.MINUTES).maximumSize(1000).build(); |
||||
|
|
||||
|
public DingdingMsgSender() { |
||||
|
|
||||
|
} |
||||
|
|
||||
|
|
||||
|
private void handleMsg() { |
||||
|
DingTalkTextMsg msg = null; |
||||
|
try { |
||||
|
//阻塞取元素
|
||||
|
msg = msgQueue.take(); |
||||
|
if (msg != null) { |
||||
|
AtomicInteger limitCount = limitCache.getIfPresent(msg.getWebHook()); |
||||
|
if (limitCount == null) { |
||||
|
limitCount = new AtomicInteger(1); |
||||
|
limitCache.put(msg.getWebHook(), limitCount); |
||||
|
} |
||||
|
if (limitCount.intValue() > maxQueueSize) { |
||||
|
msgQueue.offer(msg); |
||||
|
Thread.sleep(1000); |
||||
|
} else { |
||||
|
sendPostByJSON(msg); |
||||
|
limitCount.addAndGet(1); |
||||
|
} |
||||
|
} else { |
||||
|
Thread.sleep(1000); |
||||
|
} |
||||
|
} catch (Exception e) { |
||||
|
logger.warn("handleMsg exception,serverUrl:" + msg.getWebHook() + ",msg:" + JSON.toJSONString(msg), e); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* desc:异步发送消息 |
||||
|
* |
||||
|
* @param messageParam |
||||
|
* @return |
||||
|
* @throws IOException |
||||
|
*/ |
||||
|
public boolean sendMsgAsync(DingTalkTextMsg messageParam) { |
||||
|
if (!running) { |
||||
|
running = true; |
||||
|
getThread().start(); |
||||
|
} |
||||
|
boolean flag = false; |
||||
|
int currentQueueSize = msgQueue.size(); |
||||
|
//非阻塞 添加/删除元素
|
||||
|
if (currentQueueSize < maxQueueSize) { |
||||
|
flag = msgQueue.offer(messageParam); |
||||
|
} else { |
||||
|
msgQueue.poll(); |
||||
|
|
||||
|
DingTalkTextMsg param = new DingTalkTextMsg(); |
||||
|
param.setContent("待发送消息队列已满,当前队列个数" + msgQueue.size() + "\n" + "最新消息内容:" + JSON.toJSONString(messageParam)); |
||||
|
param.setWebHook(messageParam.getWebHook()); |
||||
|
sendPostByJSON(param); |
||||
|
} |
||||
|
return flag; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* 同步发送报警 |
||||
|
* |
||||
|
* @param messageParam |
||||
|
* @return |
||||
|
* @throws IOException |
||||
|
*/ |
||||
|
public Result<String> sendMsgSync(DingTalkTextMsg messageParam) { |
||||
|
return sendPostByJSON(messageParam); |
||||
|
} |
||||
|
|
||||
|
private Thread getThread() { |
||||
|
Thread sendMsgThread = new Thread("MsgSender-Thread") { |
||||
|
@Override |
||||
|
public void run() { |
||||
|
while (running) { |
||||
|
handleMsg(); |
||||
|
} |
||||
|
} |
||||
|
}; |
||||
|
return sendMsgThread; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
@PreDestroy |
||||
|
public void destroy() { |
||||
|
running = false; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* 发送POST 请求 |
||||
|
* |
||||
|
* @param param 请求参数,JSON格式 |
||||
|
* @return |
||||
|
*/ |
||||
|
private Result<String> sendPostByJSON(DingTalkTextMsg param) { |
||||
|
if (StringUtils.isBlank(param.getWebHook())) { |
||||
|
param.setWebHook(webHook); |
||||
|
} |
||||
|
if (StringUtils.isBlank(param.getSecret())) { |
||||
|
param.setSecret(secret); |
||||
|
} |
||||
|
Result<String> result = new Result<String>().error(); |
||||
|
Long timestamp = System.currentTimeMillis(); |
||||
|
try { |
||||
|
String stringToSign = timestamp + "\n" + param.getSecret(); |
||||
|
Mac mac = Mac.getInstance("HmacSHA256"); |
||||
|
mac.init(new SecretKeySpec(param.getSecret().getBytes("UTF-8"), "HmacSHA256")); |
||||
|
byte[] signData = mac.doFinal(stringToSign.getBytes("UTF-8")); |
||||
|
String sign = URLEncoder.encode(new String(Base64.encodeBase64(signData)), "UTF-8"); |
||||
|
String url = param.getWebHook(); |
||||
|
url = url.concat("×tamp=" + timestamp + "&sign=" + sign); |
||||
|
String jsonStrParam = param.getMsgContent(); |
||||
|
result = HttpClientManager.getInstance().sendPostByJSON(url, jsonStrParam); |
||||
|
} catch (Exception e) { |
||||
|
logger.warn("sendPostByJSON error", e); |
||||
|
} |
||||
|
return result; |
||||
|
} |
||||
|
|
||||
|
|
||||
|
public static void main(String[] args) { |
||||
|
for (int i = 0; i < 50; i++) { |
||||
|
|
||||
|
DingTalkTextMsg dingTalkTextMsg = new DingTalkTextMsg(); |
||||
|
dingTalkTextMsg.setWebHook(""); |
||||
|
dingTalkTextMsg.setContent("测试消息" + i); |
||||
|
dingTalkTextMsg.setAtMobiles(Lists.newArrayList()); |
||||
|
dingTalkTextMsg.setAtAll(false); |
||||
|
dingTalkTextMsg.setSecret(""); |
||||
|
DingdingMsgSender msgSender = new DingdingMsgSender(); |
||||
|
msgSender.sendMsgAsync(dingTalkTextMsg); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,25 @@ |
|||||
|
package com.epmet.dto; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* 部门维度 |
||||
|
* |
||||
|
* @author yinzuomei@elink-cn.com |
||||
|
* @date 2020/6/29 13:59 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class DimDepartmentDTO implements Serializable { |
||||
|
private static final long serialVersionUID = -521155628850201172L; |
||||
|
/** |
||||
|
* DEPARTMENT_ID |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 部门名称 |
||||
|
*/ |
||||
|
private String departmentName; |
||||
|
} |
||||
@ -0,0 +1,29 @@ |
|||||
|
package com.epmet.dto.result.user; |
||||
|
|
||||
|
import com.epmet.dto.DimAgencyDTO; |
||||
|
import com.epmet.dto.DimDepartmentDTO; |
||||
|
import com.epmet.dto.DimGridDTO; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 直属机关、部门、网格列表查询 返参DTO |
||||
|
* |
||||
|
* @author yinzuomei@elink-cn.com |
||||
|
* @date 2020/6/29 13:55 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class UserAgencyInfoResultDTO implements Serializable { |
||||
|
private static final long serialVersionUID = 4471324414446061654L; |
||||
|
private Boolean subGridFlag; |
||||
|
private Boolean subDepartmentFlag; |
||||
|
private Boolean subAgencyFlag; |
||||
|
// @JsonIgnore
|
||||
|
private List<DimAgencyDTO> subAgencyList; |
||||
|
// @JsonIgnore
|
||||
|
private List<DimGridDTO> subGridList; |
||||
|
// @JsonIgnore
|
||||
|
private List<DimDepartmentDTO> subDepartmentList; |
||||
|
} |
||||
@ -0,0 +1,63 @@ |
|||||
|
/** |
||||
|
* 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.publicity.dto.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 文章引用标签阅读数量【机关】统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-19 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTagViewedAgencyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 标签名称 标签名称 |
||||
|
*/ |
||||
|
private String name; |
||||
|
|
||||
|
/** |
||||
|
* 使用改标签的数量 |
||||
|
*/ |
||||
|
private Integer value; |
||||
|
|
||||
|
/** |
||||
|
* 固定值:文章数量 |
||||
|
*/ |
||||
|
private String type="阅读次数"; |
||||
|
|
||||
|
/** |
||||
|
* 机关Id |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 标签Id |
||||
|
*/ |
||||
|
private String tagId; |
||||
|
|
||||
|
|
||||
|
} |
||||
@ -0,0 +1,121 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-机关日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicIssueAgencyDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 父级机关ID |
||||
|
*/ |
||||
|
private String pid; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 日期ID |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题数量 |
||||
|
*/ |
||||
|
private Integer issueTotal; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题当日增量 |
||||
|
*/ |
||||
|
private Integer issueIncr; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-机关月统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicIssueAgencyMonthlyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 父级ID |
||||
|
*/ |
||||
|
private String pid; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题总量 |
||||
|
*/ |
||||
|
private Integer issueTotal; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题增量 |
||||
|
*/ |
||||
|
private Integer issueIncr; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,121 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-网格日统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicIssueGridDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 网格ID |
||||
|
*/ |
||||
|
private String gridId; |
||||
|
|
||||
|
/** |
||||
|
* 日期ID |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 新增转议题数 |
||||
|
*/ |
||||
|
private Integer issueIncr; |
||||
|
|
||||
|
/** |
||||
|
* 转议题总数 |
||||
|
*/ |
||||
|
private Integer issueTotal; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-网格月统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicIssueGridMonthlyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 网格ID |
||||
|
*/ |
||||
|
private String gridId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题增量 |
||||
|
*/ |
||||
|
private Integer issueIncr; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题总量 |
||||
|
*/ |
||||
|
private Integer issueTotal; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,137 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.math.BigDecimal; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-机关日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicStatusAgencyDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机构ID 关联机关dm表 |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 父级机关ID |
||||
|
*/ |
||||
|
private String pid; |
||||
|
|
||||
|
/** |
||||
|
* 统计日期 关联日期dm表 |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态ID 关联dim_topic_status表 |
||||
|
讨论中 discussing |
||||
|
已屏蔽 hidden |
||||
|
已关闭 closed |
||||
|
已转项目 shift_project |
||||
|
*/ |
||||
|
private String topicStatusId; |
||||
|
|
||||
|
/** |
||||
|
* 话题数量 指定状态的话题数量 |
||||
|
*/ |
||||
|
private Integer topicCount; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态百分比 指定状态话题数/话题总数 |
||||
|
总数在topic_total_agency_daily中 |
||||
|
*/ |
||||
|
private BigDecimal topicProportion; |
||||
|
|
||||
|
/** |
||||
|
* 话题增量 单位时间内的状态话题的增加数 |
||||
|
*/ |
||||
|
private Integer topicIncrement; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,127 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.math.BigDecimal; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-机关月统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicStatusAgencyMonthlyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机构ID 关联机关dm表 |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 父级机关ID |
||||
|
*/ |
||||
|
private String pid; |
||||
|
|
||||
|
/** |
||||
|
* 统计月份 关联月度dm表 |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID 关联季度dm表 |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID 关联年度dm表 |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态 讨论中 discussing |
||||
|
已屏蔽 hidden |
||||
|
已关闭 closed |
||||
|
已转项目 shift_project |
||||
|
*/ |
||||
|
private String topicStatusId; |
||||
|
|
||||
|
/** |
||||
|
* 话题数量 |
||||
|
*/ |
||||
|
private Integer topicCount; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态占比 月末一天 |
||||
|
指定状态话题数/话题总数 |
||||
|
总数在topic_total_agency_daily中 |
||||
|
*/ |
||||
|
private BigDecimal topicProportion; |
||||
|
|
||||
|
/** |
||||
|
* 话题增量 单位时间内的话题状态增加数 |
||||
|
*/ |
||||
|
private Integer topicIncr; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,136 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.math.BigDecimal; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-网格日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicStatusGridDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 网格ID 关联网格dm表 |
||||
|
*/ |
||||
|
private String gridId; |
||||
|
|
||||
|
/** |
||||
|
* 日期ID |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态ID 讨论中 discussing |
||||
|
已屏蔽 hidden |
||||
|
已关闭 closed |
||||
|
已转项目 shift_project |
||||
|
*/ |
||||
|
private String topicStatusId; |
||||
|
|
||||
|
/** |
||||
|
* 话题数量 |
||||
|
*/ |
||||
|
private Integer topicCount; |
||||
|
|
||||
|
/** |
||||
|
* 话题状态占比 指定状态话题数/话题总数 |
||||
|
总数在topic_total_grid_daily中 |
||||
|
*/ |
||||
|
private BigDecimal topicProportion; |
||||
|
|
||||
|
/** |
||||
|
* 话题增量 |
||||
|
*/ |
||||
|
private Integer topicIncrement; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 话题总数-机关日统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicTotalAgencyDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 父级机关ID |
||||
|
*/ |
||||
|
private String pid; |
||||
|
|
||||
|
/** |
||||
|
* 统计日期 关联日期dm表 |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 话题总数 |
||||
|
*/ |
||||
|
private Integer topicTotal; |
||||
|
|
||||
|
/** |
||||
|
* 话题增量 |
||||
|
*/ |
||||
|
private Integer topicIncr; |
||||
|
|
||||
|
/** |
||||
|
* 屏蔽话题数 |
||||
|
*/ |
||||
|
private Integer hiddenTotalCount; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题数 |
||||
|
*/ |
||||
|
private Integer issueTotalCount; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
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.stats.topic; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.Date; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
|
||||
|
/** |
||||
|
* 话题总数-网格日统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class FactTopicTotalGridDailyDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = 1L; |
||||
|
|
||||
|
/** |
||||
|
* 唯一标识 |
||||
|
*/ |
||||
|
private String id; |
||||
|
|
||||
|
/** |
||||
|
* 机关ID |
||||
|
*/ |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* 客户Id |
||||
|
* */ |
||||
|
private String customerId; |
||||
|
|
||||
|
/** |
||||
|
* 网格ID |
||||
|
*/ |
||||
|
private String gridId; |
||||
|
|
||||
|
/** |
||||
|
* 统计日期 关联日期dm表 |
||||
|
*/ |
||||
|
private String dateId; |
||||
|
|
||||
|
/** |
||||
|
* 周ID |
||||
|
*/ |
||||
|
private String weekId; |
||||
|
|
||||
|
/** |
||||
|
* 月ID |
||||
|
*/ |
||||
|
private String monthId; |
||||
|
|
||||
|
/** |
||||
|
* 季度ID |
||||
|
*/ |
||||
|
private String quarterId; |
||||
|
|
||||
|
/** |
||||
|
* 年ID |
||||
|
*/ |
||||
|
private String yearId; |
||||
|
|
||||
|
/** |
||||
|
* 话题总量 |
||||
|
*/ |
||||
|
private Integer topicTotal; |
||||
|
|
||||
|
/** |
||||
|
* 话题增量 |
||||
|
*/ |
||||
|
private Integer topicIncr; |
||||
|
|
||||
|
/** |
||||
|
* 屏蔽话题数量 |
||||
|
*/ |
||||
|
private Integer hiddenTotalCount; |
||||
|
|
||||
|
/** |
||||
|
* 已转议题数量 |
||||
|
*/ |
||||
|
private Integer issueTotalCount; |
||||
|
|
||||
|
/** |
||||
|
* 删除标识 |
||||
|
*/ |
||||
|
private String delFlag; |
||||
|
|
||||
|
/** |
||||
|
* 乐观锁 |
||||
|
*/ |
||||
|
private Integer revision; |
||||
|
|
||||
|
/** |
||||
|
* 创建人 |
||||
|
*/ |
||||
|
private String createdBy; |
||||
|
|
||||
|
/** |
||||
|
* 创建时间 |
||||
|
*/ |
||||
|
private Date createdTime; |
||||
|
|
||||
|
/** |
||||
|
* 更新人 |
||||
|
*/ |
||||
|
private String updatedBy; |
||||
|
|
||||
|
/** |
||||
|
* 更新时间 |
||||
|
*/ |
||||
|
private Date updatedTime; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,38 @@ |
|||||
|
package com.epmet.dto.stats.topic.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @Description |
||||
|
* @ClassName GridTopicData |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-22 17:31 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class GridTopicData implements Serializable { |
||||
|
private static final long serialVersionUID = -7427128491727512781L; |
||||
|
|
||||
|
private String gridId; |
||||
|
|
||||
|
private Integer topicIncr = 0; |
||||
|
|
||||
|
private Integer discussingIncr = 0; |
||||
|
|
||||
|
private Integer hiddenIncr = 0; |
||||
|
|
||||
|
private Integer closedIncr = 0; |
||||
|
|
||||
|
private Integer total = 0; |
||||
|
|
||||
|
private Integer discussingTotal = 0; |
||||
|
|
||||
|
private Integer hiddenTotal = 0; |
||||
|
|
||||
|
private Integer closedTotal = 0; |
||||
|
|
||||
|
private Integer issueIncr = 0; |
||||
|
|
||||
|
private Integer issueTotal = 0; |
||||
|
} |
||||
@ -0,0 +1,38 @@ |
|||||
|
package com.epmet.dto.stats.topic.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @Description |
||||
|
* @ClassName GroupTopicData |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-22 15:29 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class GroupTopicData implements Serializable { |
||||
|
private static final long serialVersionUID = -7968684838832002029L; |
||||
|
|
||||
|
private String groupId; |
||||
|
|
||||
|
private Integer topicIncr = 0; |
||||
|
|
||||
|
private Integer discussingIncr = 0; |
||||
|
|
||||
|
private Integer hiddenIncr = 0; |
||||
|
|
||||
|
private Integer closedIncr = 0; |
||||
|
|
||||
|
private Integer total = 0; |
||||
|
|
||||
|
private Integer discussingTotal = 0; |
||||
|
|
||||
|
private Integer hiddenTotal = 0; |
||||
|
|
||||
|
private Integer closedTotal = 0; |
||||
|
|
||||
|
private Integer issueIncr = 0; |
||||
|
|
||||
|
private Integer issueTotal = 0; |
||||
|
} |
||||
@ -0,0 +1,43 @@ |
|||||
|
package com.epmet.dto.stats.topic.result; |
||||
|
|
||||
|
import com.epmet.dto.stats.topic.*; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* @Description 话题统计数据对象 |
||||
|
* @ClassName TopicStatisticalDataResultDTO |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-22 13:16 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class TopicStatisticalData implements Serializable { |
||||
|
private static final long serialVersionUID = 3690257892396607149L; |
||||
|
|
||||
|
private List<FactTopicIssueAgencyDailyDTO> issueAgencyDailyList ; |
||||
|
|
||||
|
private List<FactTopicIssueAgencyMonthlyDTO> issueAgencyMonthlyList ; |
||||
|
|
||||
|
private List<FactTopicIssueGridDailyDTO> issueGridDailyList ; |
||||
|
|
||||
|
private List<FactTopicIssueGridMonthlyDTO> issueGridMonthlyList ; |
||||
|
|
||||
|
private List<FactTopicStatusAgencyDailyDTO> topicAgencyDailyList ; |
||||
|
|
||||
|
private List<FactTopicStatusAgencyMonthlyDTO> topicAgencyMonthlyList ; |
||||
|
|
||||
|
private List<FactTopicStatusGridDailyDTO> topicGridDailyList; |
||||
|
|
||||
|
private List<FactTopicTotalAgencyDailyDTO> totalAgencyDailyList; |
||||
|
|
||||
|
private List<FactTopicTotalGridDailyDTO> totalGridDailyList; |
||||
|
|
||||
|
private String dateId; |
||||
|
|
||||
|
private String monthId; |
||||
|
|
||||
|
private String customerId; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,41 @@ |
|||||
|
package com.epmet.dto.stats.user.result; |
||||
|
|
||||
|
|
||||
|
import com.epmet.dto.stats.user.*; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* @Description 用户统计数据对象 |
||||
|
* @ClassName UserStatisticalData |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-19 15:02 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class UserStatisticalData implements Serializable { |
||||
|
private static final long serialVersionUID = 7423427555123585566L; |
||||
|
|
||||
|
private List<FactParticipationUserAgencyDailyDTO> partiAgencyDailyList; |
||||
|
|
||||
|
private List<FactParticipationUserGridDailyDTO> partiGridDailyList; |
||||
|
|
||||
|
private List<FactParticipationUserAgencyMonthlyDTO> partiAgencyMonthlyList; |
||||
|
|
||||
|
private List<FactParticipationUserGridMonthlyDTO> partiGridMonthlyList; |
||||
|
|
||||
|
private List<FactRegUserAgencyDailyDTO> regAgencyDailyList; |
||||
|
|
||||
|
private List<FactRegUserGridDailyDTO> regGridDailyList; |
||||
|
|
||||
|
private List<FactRegUserAgencyMonthlyDTO> regAgencyMonthlyList; |
||||
|
|
||||
|
private List<FactRegUserGridMonthlyDTO> regGridMonthlyList; |
||||
|
|
||||
|
private String customerId; |
||||
|
|
||||
|
private String dateId; |
||||
|
|
||||
|
private String monthId; |
||||
|
} |
||||
@ -0,0 +1,27 @@ |
|||||
|
package com.epmet.dto.topic.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* @Description 组-话题对象 |
||||
|
* @ClassName ResiGroupTopicResultDTO |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-20 17:23 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ResiGroupTopicResultDTO implements Serializable { |
||||
|
private static final long serialVersionUID = -6243796311184636458L; |
||||
|
|
||||
|
private String gridId; |
||||
|
|
||||
|
private String groupId; |
||||
|
|
||||
|
private String groupName; |
||||
|
|
||||
|
private String customerId; |
||||
|
|
||||
|
private List<ResiTopicResultDTO> topics; |
||||
|
} |
||||
@ -0,0 +1,31 @@ |
|||||
|
package com.epmet.dto.topic.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @Description 话题操作记录DTO |
||||
|
* @ClassName ResiTopicOperationResultDTO |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-22 10:58 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ResiTopicOperationResultDTO implements Serializable { |
||||
|
private static final long serialVersionUID = -7811429974017636134L; |
||||
|
|
||||
|
/** |
||||
|
* 话题Id |
||||
|
* */ |
||||
|
private String topicId; |
||||
|
|
||||
|
/** |
||||
|
* 操作状态 |
||||
|
* */ |
||||
|
private String status; |
||||
|
|
||||
|
/** |
||||
|
* 操作时间 yyyy-MM-dd |
||||
|
* */ |
||||
|
private String createdTime; |
||||
|
} |
||||
@ -0,0 +1,24 @@ |
|||||
|
package com.epmet.dto.topic.result; |
||||
|
|
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @Description 话题对象 |
||||
|
* @ClassName ResiTopicResultDTO |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-20 17:22 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ResiTopicResultDTO implements Serializable { |
||||
|
private static final long serialVersionUID = 6818736495648532514L; |
||||
|
|
||||
|
private String topicId; |
||||
|
|
||||
|
private String status; |
||||
|
|
||||
|
private boolean shiftIssue; |
||||
|
|
||||
|
private String incrFlag; |
||||
|
} |
||||
@ -1,131 +0,0 @@ |
|||||
package feign; |
|
||||
|
|
||||
import com.epmet.commons.tools.constant.ServiceConstant; |
|
||||
import com.epmet.commons.tools.utils.Result; |
|
||||
import feign.impl.DataStatisticalOpenFeignClientFallBack; |
|
||||
import org.springframework.cloud.openfeign.FeignClient; |
|
||||
import org.springframework.web.bind.annotation.PostMapping; |
|
||||
|
|
||||
/** |
|
||||
* desc: 数据统计 对外feign client |
|
||||
* |
|
||||
* @return: |
|
||||
* @date: 2020/6/22 17:39 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@FeignClient(name = ServiceConstant.DATA_STATISTICAL, fallback = DataStatisticalOpenFeignClientFallBack.class) |
|
||||
public interface DataStatisticalOpenFeignClient { |
|
||||
|
|
||||
/** |
|
||||
* desc: 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/articleSummaryDailyStatsjob") |
|
||||
Result articleSummaryDailyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 定时任务 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @return: |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagUsedDailyStatsjob") |
|
||||
Result tagUsedDailyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 【月】 统计发表文章最多的分类 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagUsedMonthlyStatsjob") |
|
||||
Result tagUsedMonthlyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 【季,年】 统计发表文章最多的分类 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagUsedQuarterlyStatsjob") |
|
||||
Result tagUsedQuarterlyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 【日】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagViewedDailyStatsjob") |
|
||||
Result tagViewedDailyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 【月】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagViewedMonthlyStatsjob") |
|
||||
Result tagViewedMonthlyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* desc: 【季,年】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@PostMapping(value = "data/stats/statspublicity/tagViewedQuarterlyStatsjob") |
|
||||
Result tagViewedQuarterlyStatsjob(); |
|
||||
|
|
||||
/** |
|
||||
* @Description 统计 “网格小组”, dim:【网格-日】 |
|
||||
* @param |
|
||||
* @author zxc |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsgroup/groupgriddaily") |
|
||||
Result groupGridDaily(); |
|
||||
|
|
||||
/** |
|
||||
* @Description 统计 “网格小组”, dim:【机关-日】 |
|
||||
* @param |
|
||||
* @author zxc |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsgroup/groupagencydaily") |
|
||||
Result groupAgencyDaily(); |
|
||||
|
|
||||
/** |
|
||||
* @Description 统计 “网格小组”, dim:【机关-月】 |
|
||||
* @param |
|
||||
* @author zxc |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsgroup/groupagencymonthly") |
|
||||
Result groupAgencyMonthly(); |
|
||||
|
|
||||
/** |
|
||||
* 议题统计 |
|
||||
* @author zhaoqifeng |
|
||||
* @date 2020/6/23 14:34 |
|
||||
* @param |
|
||||
* @return com.epmet.commons.tools.utils.Result |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsissue/issuestats") |
|
||||
Result agencyGridIssueStats(); |
|
||||
|
|
||||
/** |
|
||||
* @Description 数据统计-项目-机关日月统计 |
|
||||
* @Author sun |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsproject/agencyprojectstats") |
|
||||
Result agencyProjectStats(); |
|
||||
|
|
||||
/** |
|
||||
* @Description 数据统计-项目-网格日月统计 |
|
||||
* @Author sun |
|
||||
*/ |
|
||||
@PostMapping("/data/stats/statsproject/gridprojectstats") |
|
||||
Result gridProjectStats(); |
|
||||
|
|
||||
} |
|
||||
@ -1,135 +0,0 @@ |
|||||
package feign.impl; |
|
||||
|
|
||||
import com.epmet.commons.tools.constant.ServiceConstant; |
|
||||
import com.epmet.commons.tools.utils.ModuleUtils; |
|
||||
import com.epmet.commons.tools.utils.Result; |
|
||||
import feign.DataStatisticalOpenFeignClient; |
|
||||
import org.springframework.stereotype.Component; |
|
||||
|
|
||||
/** |
|
||||
* desc: |
|
||||
* |
|
||||
* @return: |
|
||||
* @date: 2020/6/22 9:38 |
|
||||
* @author: jianjun liu |
|
||||
* email:liujianjun@git.elinkit.com.cn |
|
||||
*/ |
|
||||
@Component |
|
||||
public class DataStatisticalOpenFeignClientFallBack implements DataStatisticalOpenFeignClient { |
|
||||
|
|
||||
/** |
|
||||
* desc: 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result articleSummaryDailyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "articleSummaryDailyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 定时任务 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @return: |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagUsedDailyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagUsedDailyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 【月】 统计发表文章最多的分类 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagUsedMonthlyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagUsedMonthlyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 【季,年】 统计发表文章最多的分类 包含 机关 部门 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagUsedQuarterlyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagUsedQuarterlyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 【日】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagViewedDailyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagViewedDailyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 【月】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagViewedMonthlyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagViewedMonthlyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* desc: 【季,年】 统计阅读最多的标签 包含 机关 网格 |
|
||||
* |
|
||||
* @date: 2020/6/22 9:09 |
|
||||
* @author: jianjun liu |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result tagViewedQuarterlyStatsjob() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "tagViewedQuarterlyStatsjob"); |
|
||||
} |
|
||||
|
|
||||
@Override |
|
||||
public Result groupGridDaily() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupGridDaily"); |
|
||||
} |
|
||||
|
|
||||
@Override |
|
||||
public Result groupAgencyDaily() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupAgencyDaily"); |
|
||||
} |
|
||||
|
|
||||
@Override |
|
||||
public Result groupAgencyMonthly() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "groupAgencyMonthly"); |
|
||||
} |
|
||||
|
|
||||
@Override |
|
||||
public Result agencyGridIssueStats() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "agencyGridIssueStats"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* @Description 数据统计-项目-机关日月统计 |
|
||||
* @Author sun |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result agencyProjectStats() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "agencyProjectStats"); |
|
||||
} |
|
||||
|
|
||||
/** |
|
||||
* @Description 数据统计-项目-网格日月统计 |
|
||||
* @Author sun |
|
||||
*/ |
|
||||
@Override |
|
||||
public Result gridProjectStats() { |
|
||||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL, "gridProjectStats"); |
|
||||
} |
|
||||
} |
|
||||
@ -0,0 +1,31 @@ |
|||||
|
package com.epmet.controller; |
||||
|
|
||||
|
import com.epmet.commons.tools.utils.Result; |
||||
|
import com.epmet.service.StatsTopicService; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.web.bind.annotation.PostMapping; |
||||
|
import org.springframework.web.bind.annotation.RequestMapping; |
||||
|
import org.springframework.web.bind.annotation.RequestParam; |
||||
|
import org.springframework.web.bind.annotation.RestController; |
||||
|
|
||||
|
import java.util.Date; |
||||
|
|
||||
|
/** |
||||
|
* @Description |
||||
|
* @ClassName StatsTopicController |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-23 15:19 |
||||
|
*/ |
||||
|
@RestController |
||||
|
@RequestMapping("statstopic") |
||||
|
public class StatsTopicController { |
||||
|
|
||||
|
@Autowired |
||||
|
private StatsTopicService statsTopicService; |
||||
|
|
||||
|
@PostMapping("execute") |
||||
|
public Result execute(@RequestParam(value = "date",required = false) Date date){ |
||||
|
statsTopicService.partition(date); |
||||
|
return new Result(); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,31 @@ |
|||||
|
package com.epmet.controller; |
||||
|
|
||||
|
import com.epmet.commons.tools.utils.Result; |
||||
|
import com.epmet.service.StatsUserService; |
||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||
|
import org.springframework.stereotype.Controller; |
||||
|
import org.springframework.web.bind.annotation.RequestMapping; |
||||
|
import org.springframework.web.bind.annotation.RequestParam; |
||||
|
import org.springframework.web.bind.annotation.RestController; |
||||
|
|
||||
|
import java.util.Date; |
||||
|
|
||||
|
/** |
||||
|
* @Description 用户统计 |
||||
|
* @ClassName StatsUserController |
||||
|
* @Auth wangc |
||||
|
* @Date 2020-06-23 15:18 |
||||
|
*/ |
||||
|
@RestController |
||||
|
@RequestMapping("statsuser") |
||||
|
public class StatsUserController { |
||||
|
|
||||
|
@Autowired |
||||
|
private StatsUserService statsUserService; |
||||
|
|
||||
|
@RequestMapping("execute") |
||||
|
public Result execute(@RequestParam(value = "date",required = false) Date date){ |
||||
|
statsUserService.partition(date); |
||||
|
return new Result(); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,40 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicIssueAgencyDailyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicIssueAgencyDailyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-机关日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicIssueAgencyDailyDao extends BaseDao<FactTopicIssueAgencyDailyEntity> { |
||||
|
|
||||
|
void insertBatch(@Param("list") List<FactTopicIssueAgencyDailyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("dateId")String dateId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,40 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicIssueAgencyMonthlyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicIssueAgencyMonthlyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-机关月统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicIssueAgencyMonthlyDao extends BaseDao<FactTopicIssueAgencyMonthlyEntity> { |
||||
|
|
||||
|
void insertBatch(@Param("list") List<FactTopicIssueAgencyMonthlyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("monthId")String monthId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,39 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicIssueGridDailyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicIssueGridDailyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-网格日统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicIssueGridDailyDao extends BaseDao<FactTopicIssueGridDailyEntity> { |
||||
|
void insertBatch(@Param("list") List<FactTopicIssueGridDailyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("dateId")String dateId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,39 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicIssueGridMonthlyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicIssueGridMonthlyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 转议题话题-网格月统计表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicIssueGridMonthlyDao extends BaseDao<FactTopicIssueGridMonthlyEntity> { |
||||
|
void insertBatch(@Param("list") List<FactTopicIssueGridMonthlyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("monthId")String monthId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,39 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicStatusAgencyDailyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicStatusAgencyDailyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-机关日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicStatusAgencyDailyDao extends BaseDao<FactTopicStatusAgencyDailyEntity> { |
||||
|
void insertBatch(@Param("list") List<FactTopicStatusAgencyDailyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("dateId")String dateId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,39 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicStatusAgencyMonthlyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicStatusAgencyMonthlyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-机关月统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicStatusAgencyMonthlyDao extends BaseDao<FactTopicStatusAgencyMonthlyEntity> { |
||||
|
void insertBatch(@Param("list") List<FactTopicStatusAgencyMonthlyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("monthId")String monthId,@Param("customerId")String customerId); |
||||
|
} |
||||
@ -0,0 +1,39 @@ |
|||||
|
/** |
||||
|
* 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.stats.topic; |
||||
|
|
||||
|
import com.epmet.commons.mybatis.dao.BaseDao; |
||||
|
import com.epmet.dto.stats.topic.FactTopicStatusGridDailyDTO; |
||||
|
import com.epmet.entity.stats.topic.FactTopicStatusGridDailyEntity; |
||||
|
import org.apache.ibatis.annotations.Mapper; |
||||
|
import org.apache.ibatis.annotations.Param; |
||||
|
|
||||
|
import java.util.List; |
||||
|
|
||||
|
/** |
||||
|
* 状态话题-网格日统计数据表 |
||||
|
* |
||||
|
* @author generator generator@elink-cn.com |
||||
|
* @since v1.0.0 2020-06-20 |
||||
|
*/ |
||||
|
@Mapper |
||||
|
public interface FactTopicStatusGridDailyDao extends BaseDao<FactTopicStatusGridDailyEntity> { |
||||
|
void insertBatch(@Param("list") List<FactTopicStatusGridDailyDTO> list); |
||||
|
|
||||
|
void deleteByParams(@Param("dateId")String dateId,@Param("customerId")String customerId); |
||||
|
} |
||||
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue