infin_caishuxiao
8 years ago
parent
3d5e14512c
commit
8ed4a86a42
@ -0,0 +1,23 @@
|
||||
package com.infincash.cron.collection;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
public interface CronCollectionService {
|
||||
/**
|
||||
* 查询全部未分配订单
|
||||
* @return
|
||||
*/
|
||||
List<Collection> readCollection();
|
||||
|
||||
/**
|
||||
* 分配待催收订单
|
||||
* @return
|
||||
*/
|
||||
int assignCollection(List<Collection> list);
|
||||
|
||||
/**
|
||||
* 离职员工催收订单分配
|
||||
* @return
|
||||
*/
|
||||
int assignExemployeeCollection();
|
||||
}
|
||||
@ -0,0 +1,5 @@
|
||||
package com.infincash.cron.collection;
|
||||
|
||||
public class CronCollectionServiceImpl implements CronCollectionService{
|
||||
|
||||
}
|
||||
@ -1,11 +0,0 @@
|
||||
package com.infincash.statistics.risk;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO;
|
||||
|
||||
public interface RiskService {
|
||||
List<RiskStatsDTO> countRecentRisk();
|
||||
|
||||
int writeRecentRisk(List<RiskStatsDTO> list);
|
||||
}
|
||||
@ -1,30 +0,0 @@
|
||||
package com.infincash.statistics.risk;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
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 readMapper;//这里会报错，但是并不会影响
|
||||
|
||||
@Autowired
|
||||
private TStatsRiskDetailMapper writeMapper;
|
||||
|
||||
@Override
|
||||
public List<RiskStatsDTO> countRecentRisk() {
|
||||
return readMapper.countRiskRule();
|
||||
}
|
||||
|
||||
@Override
|
||||
public int writeRecentRisk(List<RiskStatsDTO> list) {
|
||||
return writeMapper.insertBatch(list);
|
||||
}
|
||||
}
|
||||
@ -1,9 +0,0 @@
|
||||
package com.infincash.statistics.risk.mapper.prd;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO;
|
||||
|
||||
public interface TRiskRuleMapper {
|
||||
List<RiskStatsDTO> countRiskRule();
|
||||
}
|
||||
@ -1,10 +0,0 @@
|
||||
package com.infincash.statistics.risk.mapper.stats;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
import com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO;
|
||||
|
||||
|
||||
public interface TStatsRiskDetailMapper {
|
||||
int insertBatch(List<RiskStatsDTO> list);
|
||||
}
|
||||
@ -1,28 +0,0 @@
|
||||
package com.infincash.statistics.risk.table.prd.extend;
|
||||
|
||||
import java.util.Date;
|
||||
|
||||
public class RiskStatsDTO {
|
||||
String riskRuleId;
|
||||
int count;
|
||||
Date time;
|
||||
|
||||
public Date getTime() {
|
||||
return time;
|
||||
}
|
||||
public void setTime(Date time) {
|
||||
this.time = time;
|
||||
}
|
||||
public String getRiskRuleId() {
|
||||
return riskRuleId;
|
||||
}
|
||||
public void setRiskRuleId(String riskRuleId) {
|
||||
this.riskRuleId = riskRuleId;
|
||||
}
|
||||
public int getCount() {
|
||||
return count;
|
||||
}
|
||||
public void setCount(int count) {
|
||||
this.count = count;
|
||||
}
|
||||
}
|
||||
@ -0,0 +1,25 @@
|
||||
<?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.prd.TRiskRuleMapper">
|
||||
<resultMap id="riskStatsDTOMap" type="com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO">
|
||||
<result property="riskRuleId" column="risk_rule_id" />
|
||||
<result property="count" column="count1" />
|
||||
<result property="time" column="time" />
|
||||
</resultMap>
|
||||
<!-- id, risk_rule_id, count(1) as count1, now() as time resultType="com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO" -->
|
||||
<select id="selectCollection" resultType="java.lang.String" >
|
||||
select
|
||||
|
||||
</select>
|
||||
|
||||
<select id="selectTel1Employee" resultType="java.lang.String" >
|
||||
select user_id from t_system_user_role t1 inner join t_system_role t2 on t1.role_id = t2.role_id and t2.role_name='电催_1';
|
||||
</select>
|
||||
<select id="selectTel2Employee" resultType="java.lang.String" >
|
||||
select user_id from t_system_user_role t1 inner join t_system_role t2 on t1.role_id = t2.role_id and t2.role_name='电催_2';
|
||||
</select>
|
||||
<select id="selectDoorEmployee" resultType="java.lang.String" >
|
||||
select user_id from t_system_user_role t1 inner join t_system_role t2 on t1.role_id = t2.role_id and t2.role_name='地催';
|
||||
</select>
|
||||
|
||||
</mapper>
|
||||
@ -1,19 +0,0 @@
|
||||
<?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.prd.TRiskRuleMapper">
|
||||
<resultMap id="riskStatsDTOMap" type="com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO">
|
||||
<result property="riskRuleId" column="risk_rule_id" />
|
||||
<result property="count" column="count1" />
|
||||
<result property="time" column="time" />
|
||||
</resultMap>
|
||||
<!-- id, risk_rule_id, count(1) as count1, now() as time resultType="com.infincash.statistics.risk.table.prd.extend.RiskStatsDTO" -->
|
||||
<select id="countRiskRule" resultMap="riskStatsDTOMap" >
|
||||
<![CDATA[
|
||||
select
|
||||
risk_rule_id, count(1) as count1, now() as time
|
||||
from t_user_risk
|
||||
where user_id in (select user_id from t_user where DATE_SUB(NOW(),INTERVAL 1 HOUR) <= register_time)
|
||||
GROUP by risk_rule_id order by risk_rule_id;
|
||||
]]>
|
||||
</select>
|
||||
</mapper>
|
||||
@ -1,20 +0,0 @@
|
||||
<?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.prd.extend.RiskStatsDTO">
|
||||
<result property="riskRuleId" column="risk_rule_id" />
|
||||
<result property="count" column="count1" />
|
||||
<result property="time" column="time" />
|
||||
</resultMap>
|
||||
|
||||
<insert id="insertBatch" parameterType="java.util.List">
|
||||
insert into t_stats_risk_detail
|
||||
(stats_time, a_hour_count, risk_rule_id)
|
||||
VALUES
|
||||
<foreach collection ="list" item="oneItem" index= "index" separator =",">
|
||||
(
|
||||
#{oneItem.time}, #{oneItem.count},#{oneItem.riskRuleId}
|
||||
)
|
||||
</foreach >
|
||||
</insert>
|
||||
</mapper>
|
||||
Loading…
Reference in new issue