From 6565707338944f22dd02859914224af146fad068 Mon Sep 17 00:00:00 2001 From: infin_caishuxiao Date: Fri, 23 Feb 2018 11:58:39 +0800 Subject: [PATCH] fix bugs --- .../statistics/risk/RiskService.java | 2 + .../statistics/risk/RiskServiceImpl.java | 13 ++++- .../mapper/stats/TStatsRiskDetailMapper.java | 5 +- .../risk/table/stats/TStatsRiskDetail.java | 45 -------------- .../RiskCountStatisticsJobHandler.java | 8 ++- .../mapping/stats/TStatsRiskDetailMapper.xml | 58 +++++-------------- 6 files changed, 34 insertions(+), 97 deletions(-) delete mode 100644 xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/stats/TStatsRiskDetail.java diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java index 53fe80b5..68d5f9d0 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskService.java @@ -6,4 +6,6 @@ import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO; public interface RiskService { List countRecentRisk(); + + int writeRecentRisk(List list); } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java index a183a2b3..c4b0661f 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/RiskServiceImpl.java @@ -6,16 +6,25 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.infincash.statistics.risk.mapper.prd.TRiskRuleMapper; +import com.infincash.statistics.risk.mapper.stats.TStatsRiskDetailMapper; import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO; @Service public class RiskServiceImpl implements RiskService { @Autowired - private TRiskRuleMapper mapper;//这里会报错，但是并不会影响 + private TRiskRuleMapper readMapper;//这里会报错，但是并不会影响 + + @Autowired + private TStatsRiskDetailMapper writeMapper; @Override public List countRecentRisk() { - return mapper.countRiskRule(); + return readMapper.countRiskRule(); + } + + @Override + public int writeRecentRisk(List list) { + return writeMapper.insertBatch(list); } } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/stats/TStatsRiskDetailMapper.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/stats/TStatsRiskDetailMapper.java index 5d78d12b..2ed592e0 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/stats/TStatsRiskDetailMapper.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/mapper/stats/TStatsRiskDetailMapper.java @@ -2,8 +2,9 @@ package com.infincash.statistics.risk.mapper.stats; import java.util.List; -import com.infincash.statistics.risk.table.stats.TStatsRiskDetail; +import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO; + public interface TStatsRiskDetailMapper { - int insertBatch(List record); + int insertBatch(List list); } \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/stats/TStatsRiskDetail.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/stats/TStatsRiskDetail.java deleted file mode 100644 index 123b69f8..00000000 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/stats/TStatsRiskDetail.java +++ /dev/null @@ -1,45 +0,0 @@ -package com.infincash.statistics.risk.table.stats; - -import java.util.Date; - -public class TStatsRiskDetail { - private Long id; - - private Date statsTime; - - private Integer aHourCount; - - private String riskRuleId; - - public Long getId() { - return id; - } - - public void setId(Long id) { - this.id = id; - } - - public Date getStatsTime() { - return statsTime; - } - - public void setStatsTime(Date statsTime) { - this.statsTime = statsTime; - } - - public Integer getaHourCount() { - return aHourCount; - } - - public void setaHourCount(Integer aHourCount) { - this.aHourCount = aHourCount; - } - - public String getRiskRuleId() { - return riskRuleId; - } - - public void setRiskRuleId(String riskRuleId) { - this.riskRuleId = riskRuleId == null ? null : riskRuleId.trim(); - } -} \ No newline at end of file diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java index b10f05bc..4928b69b 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/xxl/job/executor/service/jobhandler/RiskCountStatisticsJobHandler.java @@ -30,9 +30,11 @@ public class RiskCountStatisticsJobHandler extends IJobHandler { @Override public ReturnT execute(String param) throws Exception { - List aa = service.countRecentRisk(); - for (RiskStatsDTO a:aa) { - XxlJobLogger.log(a.getRiskRuleId() +", "+ a.getCount()+", "+ a.getTime()); + List list = service.countRecentRisk(); + int res = service.writeRecentRisk(list); + XxlJobLogger.log("res: " + res); + if(res < list.size()){ + return FAIL; } return SUCCESS; } diff --git a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/stats/TStatsRiskDetailMapper.xml b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/stats/TStatsRiskDetailMapper.xml index 774aaf13..97eab6bc 100644 --- a/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/stats/TStatsRiskDetailMapper.xml +++ b/xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/stats/TStatsRiskDetailMapper.xml @@ -1,52 +1,20 @@ - - - - - + + + + - - id, stats_time, a_hour_count, risk_rule_id - - - - - insert into t_stats_risk_detail (id, stats_time, a_hour_count, - risk_rule_id) - values (#{id,jdbcType=BIGINT}, #{statsTime,jdbcType=TIMESTAMP}, #{aHourCount,jdbcType=INTEGER}, - #{riskRuleId,jdbcType=VARCHAR}) - - - + + insert into t_stats_risk_detail - - - stats_time, - - - a_hour_count, - - - risk_rule_id, - - - - - #{statsTime,jdbcType=TIMESTAMP}, - - - #{aHourCount,jdbcType=INTEGER}, - - - #{riskRuleId,jdbcType=VARCHAR}, - - + (stats_time, a_hour_count, risk_rule_id) + VALUES + + ( + #{oneItem.time}, #{oneItem.count},#{oneItem.riskRuleId} + ) + \ No newline at end of file