diff --git a/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/CronCollectionServiceImpl.java b/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/CronCollectionServiceImpl.java
index 32c1c4d7..c92c11ad 100644
--- a/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/CronCollectionServiceImpl.java
+++ b/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/CronCollectionServiceImpl.java
@@ -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)
diff --git a/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionRecordMapper.java b/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionMapper.java
similarity index 65%
rename from infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionRecordMapper.java
rename to infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionMapper.java
index ac2e805c..6894c9fd 100644
--- a/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionRecordMapper.java
+++ b/infintech-executors/executor-collection-dispatcher/src/main/java/com/infincash/cron/collection/mapper/TBizCollectionMapper.java
@@ -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);
 
diff --git a/infintech-executors/executor-collection-dispatcher/src/main/resources/application.properties b/infintech-executors/executor-collection-dispatcher/src/main/resources/application.properties
index 7f47a2c6..cbeb5538 100644
--- a/infintech-executors/executor-collection-dispatcher/src/main/resources/application.properties
+++ b/infintech-executors/executor-collection-dispatcher/src/main/resources/application.properties
@@ -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
diff --git a/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/CronCollectionMapper.xml b/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/CronCollectionMapper.xml
deleted file mode 100644
index 94a813d1..00000000
--- a/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/CronCollectionMapper.xml
+++ /dev/null
@@ -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>
\ No newline at end of file
diff --git a/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/TBizCollectionRecordMapper.xml b/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/TBizCollectionRecordMapper.xml
index cff12a83..470c3a97 100644
--- a/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/TBizCollectionRecordMapper.xml
+++ b/infintech-executors/executor-collection-dispatcher/src/main/resources/mapping/prd/TBizCollectionRecordMapper.xml
@@ -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">