msb-public-java
/
xxl-job
mirror of https://gitee.com/xuxueli0323/xxl-job.git
4
2
Code Issues Projects Releases Wiki Activity

分配完成

Browse Source
pull/5/head
infin_caishuxiao 8 years ago
parent b3644291e3
commit ee64870a53
5 changed files with 75 additions and 53 deletions
Show Stats Download Patch File Download Diff File

33
infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/CronCollectionServiceImpl.java
Unescape View File

@ -4,8 +4,10 @@ import static com.infincash.util.Jdk8DateUtils.dateSubstract;
import static com.infincash.util.Jdk8DateUtils.getDateAfter;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import org.springframework.beans.factory.annotation.Autowired;
@ -20,7 +22,7 @@ import com.xxl.job.core.log.XxlJobLogger;
public class CronCollectionServiceImpl implements CronCollectionService
{
@Autowired
TBizCollectionMapper recordMapper;
TBizCollectionMapper collectionMapper;
@Autowired
TBizCollectionOverdueBucketMapper bucketMapper;
@ -30,7 +32,7 @@ public class CronCollectionServiceImpl implements CronCollectionService
{
//90天以上的是坏账
String badDebtDay = getDateAfter(-90);
List<TBizCollection> rList = recordMapper.queryAll(badDebtDay);
List<TBizCollection> rList = collectionMapper.queryAll(badDebtDay);
if (rList == null || rList.size() == 0)
{
throw new InfintechException("recordMapper.queryAll(badDebtDay) empty! badDebtDay: " + badDebtDay);
@ -40,7 +42,32 @@ public class CronCollectionServiceImpl implements CronCollectionService
{
throw new InfintechException("bucketMapper.queryAll() empty!");
}
getWhichBucket(bList, rList);
Map<String, List<TBizCollection>> map = getWhichBucket(bList, rList);
List<TBizCollection> resultList = Lists.newLinkedList();
for (Entry<String, List<TBizCollection>> entry : map.entrySet())
{
String key = entry.getKey();
List<Map<String, Object>> userList = collectionMapper.queryUserByRoleId(key);
if (userList == null || userList.size()==0 ) {
throw new InfintechException("collectionMapper.queryUserByRoleId(key) empty! key:" + key);
}
int cycle = userList.size();
//FIXME 存量怎么办
List<TBizCollection> list = entry.getValue();
int a = 0;
for (TBizCollection s : list) {
Map<String, Object> tmpMap = userList.get(a%cycle);
String userId = (String) tmpMap.get("user_id");
String userRealName = (String) tmpMap.get("real_name");
s.setFkSystemUser(userId);
s.setCollectorLoginName(userRealName);
a++;
}
//拼接List
resultList.addAll(list);
}
collectionMapper.insertBatch(resultList);
}
private Map<String, List<TBizCollection>> getWhichBucket(List<TBizCollectionOverdueBucket> bList, List<TBizCollection> rList)

11
infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionRecordMapper.java → infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionMapper.java
Unescape View File

@ -1,19 +1,16 @@
package com.infincash.cron.collection.mapper;
import java.util.List;
import java.util.Map;
import com.infincash.cron.collection.table.TBizCollection;
public interface TBizCollectionMapper {
List<TBizCollection> queryAll(String badDebtDay);
int deleteByPrimaryKey(Long id);
int insert(TBizCollection record);
int insertSelective(TBizCollection record);
TBizCollection selectByPrimaryKey(Long id);
List<Map<String, Object>> queryUserByRoleId(String roleId);
int insertBatch(List<TBizCollection> record);
int updateByPrimaryKeySelective(TBizCollection record);

4
infintech-executors/executor-collection-dispatcher/src/main/resources/application.properties
Unescape View File

@ -1,9 +1,9 @@
spring.datasource.prd.url=jdbc:mysql://172.16.16.98:3306/microfinance?autoReconnect=true&useUnicode=true&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&rewriteBatchedStatements=true&useSSL=false
spring.datasource.prd.url=jdbc:mysql://47.74.188.197:3306/microfinance?autoReconnect=true&useUnicode=true&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&rewriteBatchedStatements=true&useSSL=false
spring.datasource.prd.username=jobopr
spring.datasource.prd.password=jobopr666
spring.datasource.prd.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.stats.url=jdbc:mysql://172.16.16.99:3306/microfinance1?autoReconnect=true&useUnicode=true&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&rewriteBatchedStatements=true&useSSL=false
spring.datasource.stats.url=jdbc:mysql://47.74.188.197:3306/microfinance1?autoReconnect=true&useUnicode=true&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&rewriteBatchedStatements=true&useSSL=false
spring.datasource.stats.username=jobopr
spring.datasource.stats.password=jobopr666
spring.datasource.stats.driver-class-name=com.mysql.jdbc.Driver

13
infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/CronCollectionMapper.xml
Unescape View File

@ -1,13 +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.CronCollectionMapper">
<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>

67
infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/TBizCollectionRecordMapper.xml
Unescape View File

@ -1,6 +1,6 @@
<?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.cron.collection.mapper.TBizCollectionRecordMapper">
<mapper namespace="com.infincash.cron.collection.mapper.TBizCollectionMapper">
<resultMap id="BaseResultMap" type="com.infincash.cron.collection.table.TBizCollection">
<id column="id" jdbcType="BIGINT" property="id" />
<result column="fk_t_project" jdbcType="VARCHAR" property="fkTProject" />
@ -49,7 +49,8 @@
t1.unit,
t1.first_price_loan,
t2.repayment_date
from t_project t1 inner join t_project_refund t2 on t1.id=t2.project_id and t1.status in ('7') where t1.loan_time > #{_parameter}
from t_project t1 inner join t_project_refund t2 on t1.id=t2.project_id and t1.status in ('7')
where t1.loan_time > #{_parameter}
) t_biz
inner join
t_user t_u ON t_u.user_id = t_biz.user_id
@ -57,7 +58,14 @@
t_user_basis t_ub on t_ub.user_id=t_u.user_id;
</select>
<insert id="insertSelective" parameterType="com.infincash.cron.collection.table.TBizCollection">
<select id="queryUserByRoleId" parameterType="java.lang.String" resultType="java.util.HashMap">
select t1.user_id, t2.real_name from t_system_user_role t1
inner join
t_system_user t2 on t1.user_id = t2.user_id
where t1.role_id = #{_parameter};
</select>
<insert id="insertBatch" parameterType="com.infincash.cron.collection.table.TBizCollection">
insert into t_biz_collection_record
<trim prefix="(" suffix=")" suffixOverrides=",">
<if test="id != null">
@ -130,77 +138,80 @@
histry_collection_count,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides=",">
VALUES
<foreach collection ="list" item="oneItem" index= "index" separator =",">
(
<if test="id != null">
#{id,jdbcType=BIGINT},
#{oneItem.id,jdbcType=BIGINT},
</if>
<if test="fkTProject != null">
#{fkTProject,jdbcType=VARCHAR},
#{oneItem.fkTProject,jdbcType=VARCHAR},
</if>
<if test="fkTUser != null">
#{fkTUser,jdbcType=VARCHAR},
#{oneItem.fkTUser,jdbcType=VARCHAR},
</if>
<if test="fkSystemUser != null">
#{fkSystemUser,jdbcType=VARCHAR},
#{oneItem.fkSystemUser,jdbcType=VARCHAR},
</if>
<if test="waitOrRecord != null">
#{waitOrRecord,jdbcType=TINYINT},
#{oneItem.waitOrRecord,jdbcType=TINYINT},
</if>
<if test="projectNumber != null">
#{projectNumber,jdbcType=VARCHAR},
#{oneItem.projectNumber,jdbcType=VARCHAR},
</if>
<if test="userLoginName != null">
#{userLoginName,jdbcType=VARCHAR},
#{oneItem.userLoginName,jdbcType=VARCHAR},
</if>
<if test="userRealName != null">
#{userRealName,jdbcType=VARCHAR},
#{oneItem.userRealName,jdbcType=VARCHAR},
</if>
<if test="userPhone != null">
#{userPhone,jdbcType=VARCHAR},
#{oneItem.userPhone,jdbcType=VARCHAR},
</if>
<if test="loanTime != null">
#{loanTime,jdbcType=TIMESTAMP},
#{oneItem.loanTime,jdbcType=TIMESTAMP},
</if>
<if test="projectPeriod != null">
#{projectPeriod,jdbcType=VARCHAR},
#{oneItem.projectPeriod,jdbcType=VARCHAR},
</if>
<if test="firstPriceLoan != null">
#{firstPriceLoan,jdbcType=DECIMAL},
#{oneItem.firstPriceLoan,jdbcType=DECIMAL},
</if>
<if test="repaymentDate != null">
#{repaymentDate,jdbcType=TIMESTAMP},
#{oneItem.repaymentDate,jdbcType=TIMESTAMP},
</if>
<if test="overdueDayCount != null">
#{overdueDayCount,jdbcType=SMALLINT},
#{oneItem.overdueDayCount,jdbcType=SMALLINT},
</if>
<if test="fkTBizCollectionOverdueBucketIntervalId != null">
#{fkTBizCollectionOverdueBucketIntervalId,jdbcType=SMALLINT},
#{oneItem.fkTBizCollectionOverdueBucketIntervalId,jdbcType=SMALLINT},
</if>
<if test="collectorLoginName != null">
#{collectorLoginName,jdbcType=VARCHAR},
#{oneItem.collectorLoginName,jdbcType=VARCHAR},
</if>
<if test="updateTime != null">
#{updateTime,jdbcType=TIMESTAMP},
#{oneItem.updateTime,jdbcType=TIMESTAMP},
</if>
<if test="updateBy != null">
#{updateBy,jdbcType=VARCHAR},
#{oneItem.updateBy,jdbcType=VARCHAR},
</if>
<if test="state != null">
#{state,jdbcType=TINYINT},
#{oneItem.state,jdbcType=TINYINT},
</if>
<if test="fullRepayDate != null">
#{fullRepayDate,jdbcType=TIMESTAMP},
#{oneItem.fullRepayDate,jdbcType=TIMESTAMP},
</if>
<if test="lastCollectionTime != null">
#{lastCollectionTime,jdbcType=TIMESTAMP},
#{oneItem.lastCollectionTime,jdbcType=TIMESTAMP},
</if>
<if test="nextCollectionTime != null">
#{nextCollectionTime,jdbcType=TIMESTAMP},
#{oneItem.nextCollectionTime,jdbcType=TIMESTAMP},
</if>
<if test="histryCollectionCount != null">
#{histryCollectionCount,jdbcType=SMALLINT},
#{oneItem.histryCollectionCount,jdbcType=SMALLINT},
</if>
</trim>
)
</foreach >
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.infincash.cron.collection.table.TBizCollectionRecord">

Write Preview
Loading…
Cancel
Save