fix bugs

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<RiskStatsDTO> countRecentRisk();
+	
+	int writeRecentRisk(List<RiskStatsDTO> list);
 }

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<RiskStatsDTO> countRecentRisk() {
-		return mapper.countRiskRule();
+		return readMapper.countRiskRule();
+	}
+
+	@Override
+	public int writeRecentRisk(List<RiskStatsDTO> list) {
+		return writeMapper.insertBatch(list);
 	}
 }

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<TStatsRiskDetail> record);
+    int insertBatch(List<RiskStatsDTO> list);
 }

xxl-job-executor-samples/xxl-job-executor-db/src/main/java/com/infincash/statistics/risk/table/stats/TStatsRiskDetail.java

@@ -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();
-    }
-}

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<String> execute(String param) throws Exception {
-		List<RiskStatsDTO> aa = service.countRecentRisk();
+		List<RiskStatsDTO> list = service.countRecentRisk();
-		for (RiskStatsDTO a:aa) {
+		int res = service.writeRecentRisk(list);
-			XxlJobLogger.log(a.getRiskRuleId() +", "+ a.getCount()+", "+ a.getTime());			
+		XxlJobLogger.log("res: " + res);
+		if(res < list.size()){			
+		    return FAIL;
 		}
 		return SUCCESS;
 	}

xxl-job-executor-samples/xxl-job-executor-db/src/main/resources/mapping/stats/TStatsRiskDetailMapper.xml

@@ -1,52 +1,20 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.infincash.statistics.risk.mapper.stats.TStatsRiskDetailMapper">
-  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.stats.TStatsRiskDetail">
+  <resultMap id="BaseResultMap" type="com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO">
-    <id column="id" jdbcType="BIGINT" property="id" />
+        <result property="riskRuleId" column="risk_rule_id" />  
-    <result column="stats_time" jdbcType="TIMESTAMP" property="statsTime" />
+        <result property="count" column="count1" />  
-    <result column="a_hour_count" jdbcType="INTEGER" property="aHourCount" />
+        <result property="time" column="time" />  
-    <result column="risk_rule_id" jdbcType="VARCHAR" property="riskRuleId" />
   </resultMap>
-  <sql id="Base_Column_List">
+
-    id, stats_time, a_hour_count, risk_rule_id
+  <insert id="insertBatch" parameterType="java.util.List">
-  </sql>
-  <select id="selectByPrimaryKey" parameterType="java.lang.Long" resultMap="BaseResultMap">
-    select 
-    <include refid="Base_Column_List" />
-    from t_stats_risk_detail
-    where id = #{id,jdbcType=BIGINT}
-  </select>
-  
-  <insert id="insert" parameterType="com.infincash.statistics.risk.table.stats.TStatsRiskDetail">
-    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>
-  
-  <insert id="insertBatch" parameterType="com.infincash.statistics.risk.table.stats.TStatsRiskDetail">
     insert into t_stats_risk_detail
-    <trim prefix="(" suffix=")" suffixOverrides=",">
+    (stats_time, a_hour_count, risk_rule_id)
-      <if test="statsTime != null">
+    VALUES
-        stats_time,
+    <foreach collection ="list" item="oneItem" index= "index" separator =",">
-      </if>
+    (
-      <if test="aHourCount != null">
+      #{oneItem.time}, #{oneItem.count},#{oneItem.riskRuleId}
-        a_hour_count,
+    )
-      </if>
+    </foreach >
-      <if test="riskRuleId != null">
-        risk_rule_id,
-      </if>
-    </trim>
-    <trim prefix="values (" suffix=")" suffixOverrides=",">
-      <if test="statsTime != null">
-        #{statsTime,jdbcType=TIMESTAMP},
-      </if>
-      <if test="aHourCount != null">
-        #{aHourCount,jdbcType=INTEGER},
-      </if>
-      <if test="riskRuleId != null">
-        #{riskRuleId,jdbcType=VARCHAR},
-      </if>
-    </trim>
   </insert>
 </mapper>