Browse Source
# Conflicts: # epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/extract/FactOriginGroupMainDailyDao.java # epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/dao/evaluationindex/extract/FactOriginProjectMainDailyDao.java # epmet-module/data-statistical/data-statistical-server/src/main/java/com/epmet/service/evaluationindex/extract/FactOriginProjectMainDailyService.java # epmet-module/data-statistical/data-statistical-server/src/main/resources/mapper/evaluationindex/extract/FactOriginGroupMainDailyDao.xmldev_shibei_match
yinzuomei
5 years ago
58 changed files with 1591 additions and 78 deletions
@ -0,0 +1,20 @@ |
|||
package com.epmet.dto.extract.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* @Description |
|||
* @ClassName GridHeartedFormDTO |
|||
* @Auth wangc |
|||
* @Date 2020-09-20 12:42 |
|||
*/ |
|||
@Data |
|||
public class GridHeartedFormDTO implements Serializable { |
|||
private static final long serialVersionUID = 9069263069122734316L; |
|||
|
|||
private String userId; |
|||
|
|||
private String gridId; |
|||
} |
|||
@ -0,0 +1,41 @@ |
|||
package com.epmet.dto.group.result; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* @Description |
|||
* @ClassName ExtractGroupMemberActionRecordResultDTO |
|||
* @Auth wangc |
|||
* @Date 2020-09-18 21:18 |
|||
*/ |
|||
@Data |
|||
public class ExtractGroupMemberActionRecordResultDTO implements Serializable { |
|||
private static final long serialVersionUID = -74883228267461785L; |
|||
private String customerId; |
|||
|
|||
private String groupId; |
|||
|
|||
private String memberId; |
|||
|
|||
private String leaderFlag; |
|||
|
|||
private String dateId; |
|||
|
|||
private String weekId; |
|||
|
|||
private String monthId; |
|||
|
|||
private String quarterId; |
|||
|
|||
private String yearId; |
|||
|
|||
private Date joinDate; |
|||
|
|||
/** |
|||
* 目前只有join leader也是join |
|||
* */ |
|||
private String actionCode; |
|||
} |
|||
@ -0,0 +1,20 @@ |
|||
package com.epmet.dto.project; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/9/20 21:08 |
|||
*/ |
|||
@Data |
|||
public class FinishOrgDTO implements Serializable { |
|||
|
|||
private static final long serialVersionUID = -5684606755705833962L; |
|||
private String projectId; |
|||
private String orgIdPath; |
|||
private String pIdPath; |
|||
|
|||
} |
|||
@ -0,0 +1,36 @@ |
|||
package com.epmet.dto.stats.result; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import java.io.Serializable; |
|||
|
|||
/** |
|||
* @Description |
|||
* @ClassName GridAttributesResultDTO |
|||
* @Auth wangc |
|||
* @Date 2020-09-20 12:50 |
|||
*/ |
|||
@Data |
|||
public class GridAttributesResultDTO implements Serializable { |
|||
private static final long serialVersionUID = 466974582608407121L; |
|||
|
|||
/** |
|||
* 网格ID |
|||
*/ |
|||
private String gridId; |
|||
|
|||
/** |
|||
* 网格所属机关ID |
|||
*/ |
|||
private String agencyId; |
|||
|
|||
/** |
|||
* 机关的上级ID |
|||
*/ |
|||
private String parentId; |
|||
|
|||
/** |
|||
* 所有上级Id |
|||
* */ |
|||
private String pids; |
|||
} |
|||
@ -0,0 +1,30 @@ |
|||
package com.epmet.feign; |
|||
|
|||
import com.epmet.commons.tools.constant.ServiceConstant; |
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.dto.extract.form.ExtractFormDTO; |
|||
import com.epmet.feign.impl.FactExtractOpenFeignClientFallBack; |
|||
import org.springframework.cloud.openfeign.FeignClient; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestBody; |
|||
|
|||
/** |
|||
* desc: 数据抽取 对外feign client |
|||
* |
|||
* @return: |
|||
* @date: 2020/6/22 17:39 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@FeignClient(name = ServiceConstant.DATA_STATISTICAL_SERVER, fallback = FactExtractOpenFeignClientFallBack.class) |
|||
public interface FactExtractOpenFeignClient { |
|||
|
|||
/** |
|||
* desc: 【日】抽取业务数据到统计库 小组 话题 议题 项目 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@PostMapping(value = "data/stats/factorigin/extractall") |
|||
Result extractall(@RequestBody(required = false) ExtractFormDTO formDTO); |
|||
|
|||
} |
|||
@ -0,0 +1,184 @@ |
|||
package com.epmet.feign.impl; |
|||
|
|||
import com.epmet.commons.tools.constant.ServiceConstant; |
|||
import com.epmet.commons.tools.utils.ModuleUtils; |
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.dto.StatsFormDTO; |
|||
import com.epmet.dto.group.form.GroupStatsFormDTO; |
|||
import com.epmet.dto.issue.form.IssueJobFromDTO; |
|||
import com.epmet.dto.stats.form.CustomerIdAndDateIdFormDTO; |
|||
import com.epmet.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 FactExtractOpenFeignClientFallBack implements DataStatisticalOpenFeignClient { |
|||
|
|||
/** |
|||
* desc: 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result articleSummaryDailyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "articleSummaryDailyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 定时任务 【日】统计文章总数及在线文章总数 包含 机关 部门 网格 |
|||
* |
|||
* @return: |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagUsedDailyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedDailyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 【月】 统计发表文章最多的分类 包含 机关 部门 网格 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagUsedMonthlyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedMonthlyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 【季，年】 统计发表文章最多的分类 包含 机关 部门 网格 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagUsedQuarterlyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagUsedQuarterlyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 【日】 统计阅读最多的标签 包含 机关 网格 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagViewedDailyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedDailyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 【月】 统计阅读最多的标签 包含 机关 网格 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagViewedMonthlyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedMonthlyStatsjob", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* desc: 【季，年】 统计阅读最多的标签 包含 机关 网格 |
|||
* |
|||
* @param formDTO |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result tagViewedQuarterlyStatsjob(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "tagViewedQuarterlyStatsjob", formDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result groupGridDaily(GroupStatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupGridDaily", formDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result groupAgencyDaily(GroupStatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupAgencyDaily", formDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result groupAgencyMonthly(GroupStatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "groupAgencyMonthly", formDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result agencyGridIssueStats() { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStats"); |
|||
} |
|||
|
|||
@Override |
|||
public Result agencyGridIssueStatsOfDate(IssueJobFromDTO fromDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyGridIssueStatsOfDate"); |
|||
} |
|||
|
|||
/** |
|||
* @Description 数据统计-项目-机关日月统计 |
|||
* @Author sun |
|||
*/ |
|||
@Override |
|||
public Result agencyProjectStats(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "agencyProjectStats", formDTO); |
|||
} |
|||
|
|||
/** |
|||
* @Description 数据统计-项目-网格日月统计 |
|||
* @Author sun |
|||
*/ |
|||
@Override |
|||
public Result gridProjectStats(StatsFormDTO formDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "gridProjectStats", formDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result initAllDims() { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "initAllDims"); |
|||
} |
|||
|
|||
/** |
|||
* @param |
|||
* @return |
|||
* @Description 执行用户统计 |
|||
* @author wangc |
|||
* @date 2020.06.29 09:26 |
|||
**/ |
|||
@Override |
|||
public Result execUserStatistical(String date) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "execUserStatistical", date); |
|||
} |
|||
|
|||
/** |
|||
* @param |
|||
* @return |
|||
* @Description 执行话题统计 |
|||
* @author wangc |
|||
* @date 2020.06.29 09:27 |
|||
**/ |
|||
@Override |
|||
public Result execTopicStatistical(String date) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "execTopicStatistical", date); |
|||
} |
|||
|
|||
@Override |
|||
public Result getPartyInfo(CustomerIdAndDateIdFormDTO customerIdAndDateIdFormDTO) { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "getPartyInfo", customerIdAndDateIdFormDTO); |
|||
} |
|||
|
|||
@Override |
|||
public Result processPenddingCalculate() { |
|||
return ModuleUtils.feignConError(ServiceConstant.DATA_STATISTICAL_SERVER, "processPenddingCalculate"); |
|||
} |
|||
} |
|||
@ -0,0 +1,22 @@ |
|||
package com.epmet.service.evaluationindex.indexcoll; |
|||
|
|||
import com.epmet.commons.mybatis.service.BaseService; |
|||
import com.epmet.entity.evaluationindex.indexcoll.FactIndexGovrnAblityOrgMonthlyEntity; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/9/20 20:29 |
|||
*/ |
|||
public interface FactIndexGovrnAblityOrgMonthlyService extends BaseService<FactIndexGovrnAblityOrgMonthlyEntity> { |
|||
/** |
|||
* 根据客户清空数据 |
|||
* @author zhaoqifeng |
|||
* @date 2020/9/20 20:33 |
|||
* @param customerId |
|||
* @param monthId |
|||
* @param type |
|||
* @return void |
|||
*/ |
|||
void deleteByCustomer(String customerId, String monthId, String type); |
|||
} |
|||
@ -0,0 +1,23 @@ |
|||
package com.epmet.service.evaluationindex.indexcoll.impl; |
|||
|
|||
import com.epmet.commons.dynamic.datasource.annotation.DataSource; |
|||
import com.epmet.commons.mybatis.service.impl.BaseServiceImpl; |
|||
import com.epmet.constant.DataSourceConstant; |
|||
import com.epmet.dao.evaluationindex.indexcoll.FactIndexGovrnAblityOrgMonthlyDao; |
|||
import com.epmet.entity.evaluationindex.indexcoll.FactIndexGovrnAblityOrgMonthlyEntity; |
|||
import com.epmet.service.evaluationindex.indexcoll.FactIndexGovrnAblityOrgMonthlyService; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
/** |
|||
* @author zhaoqifeng |
|||
* @dscription |
|||
* @date 2020/9/20 20:29 |
|||
*/ |
|||
@Service |
|||
@DataSource(DataSourceConstant.EVALUATION_INDEX) |
|||
public class FactIndexGovrnAblityOrgMonthlyServiceImpl extends BaseServiceImpl<FactIndexGovrnAblityOrgMonthlyDao, FactIndexGovrnAblityOrgMonthlyEntity> implements FactIndexGovrnAblityOrgMonthlyService { |
|||
@Override |
|||
public void deleteByCustomer(String customerId, String monthId, String type) { |
|||
baseDao.deleteByCustomer(customerId, monthId, type); |
|||
} |
|||
} |
|||
@ -0,0 +1,23 @@ |
|||
package com.epmet.service; |
|||
|
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.dto.extract.form.ExtractFormDTO; |
|||
|
|||
/** |
|||
* desc: 业务数据抽取到统计库服务类 |
|||
* |
|||
* @return: |
|||
* @date: 2020/6/22 10:24 |
|||
* @author: jianjun liu |
|||
*/ |
|||
public interface FactOriginExtractTaskService { |
|||
|
|||
/** |
|||
* desc: 【日】抽取 小组 话题 议题 项目数据到统计库 |
|||
* |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
Result factOriginExtractJob(ExtractFormDTO formDTO); |
|||
} |
|||
@ -0,0 +1,30 @@ |
|||
package com.epmet.service.impl; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.dto.extract.form.ExtractFormDTO; |
|||
import com.epmet.feign.FactExtractOpenFeignClient; |
|||
import com.epmet.service.FactOriginExtractTaskService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
/** |
|||
* desc：数据统计 任务服务类 |
|||
*/ |
|||
@Service |
|||
public class FactOriginExtractTaskServiceImpl implements FactOriginExtractTaskService { |
|||
@Autowired |
|||
private FactExtractOpenFeignClient factExtractOpenFeignClient; |
|||
|
|||
|
|||
/** |
|||
* desc: 【日】抽取 小组 话题 议题 项目数据到统计库 |
|||
* |
|||
* @param formDTO |
|||
* @date: 2020/6/22 9:09 |
|||
* @author: jianjun liu |
|||
*/ |
|||
@Override |
|||
public Result factOriginExtractJob(ExtractFormDTO formDTO) { |
|||
return factExtractOpenFeignClient.extractall(formDTO); |
|||
} |
|||
} |
|||
@ -0,0 +1,48 @@ |
|||
package com.epmet.task; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.dto.StatsFormDTO; |
|||
import com.epmet.dto.extract.form.ExtractFormDTO; |
|||
import com.epmet.service.FactOriginExtractTaskService; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.slf4j.Logger; |
|||
import org.slf4j.LoggerFactory; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
/** |
|||
* desc:数据抽取定时任务 定时任务 |
|||
*/ |
|||
@Component("factOriginExtractTask") |
|||
public class FactOriginExtractTask implements ITask { |
|||
private Logger logger = LoggerFactory.getLogger(getClass()); |
|||
|
|||
@Autowired |
|||
private FactOriginExtractTaskService factOriginExtractTaskService; |
|||
|
|||
|
|||
@Override |
|||
public void run(String params) { |
|||
logger.info("FactOriginExtractTask定时任务正在执行，参数为：{}", params); |
|||
ExtractFormDTO formDTO = new ExtractFormDTO(); |
|||
if (StringUtils.isNotBlank(params)) { |
|||
formDTO = JSON.parseObject(params, ExtractFormDTO.class); |
|||
} |
|||
Result result = factOriginExtractTaskService.factOriginExtractJob(formDTO); |
|||
if (result.success()) { |
|||
logger.info("FactOriginExtractTask定时任务执行成功"); |
|||
} else { |
|||
logger.error("FactOriginExtractTask定时任务执行失败:" + result.getMsg()); |
|||
} |
|||
} |
|||
|
|||
public static void main(String[] args) { |
|||
StatsFormDTO formDTO = new StatsFormDTO(); |
|||
String params = "{'date':'\"2020-06-20','customerId':'123'}"; |
|||
if (StringUtils.isNotBlank(params)) { |
|||
formDTO = JSON.parseObject(params, StatsFormDTO.class); |
|||
} |
|||
System.out.println(JSON.toJSONString(formDTO)); |
|||
} |
|||
} |
|||
Loading…
Reference in new issue