zoujiajian преди 3 години
родител
ревизия
765a625c84
променени са 1 файла, в които са добавени 2 реда и са изтрити 0 реда
  1. 2 0
      netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpMsgBulkTaskServiceImpl.java

+ 2 - 0
netflix-service/src/main/java/com/cyksj/service/corp/impl/CorpMsgBulkTaskServiceImpl.java

@@ -397,6 +397,7 @@ public class CorpMsgBulkTaskServiceImpl extends ServiceImpl<CorpMsgBulkTaskMappe
 			List<List<String>> split = CollectionUtil.split(corpUserIdList, LIMIT / 4);
 			for (List<String> strings : split) {
 				List<CorpUserSendRecord> corpUserSendRecords = corpMsgBulkTaskMapper.getsSuccessCorpUser(strings);
+				log.info("保存群发记录大小:{}", corpUserSendRecords.size());
 				corpUserSendRecords.forEach(corpUserSendRecord -> {
 					corpUserSendRecord.setCorpMsgRecordId(corpMsgBulkTaskRecord.getId());
 				});
@@ -408,6 +409,7 @@ public class CorpMsgBulkTaskServiceImpl extends ServiceImpl<CorpMsgBulkTaskMappe
 			List<CorpUserSendRecord> corpUserSendRecords = corpMsgBulkTaskMapper.getsSuccessCorpUser(failList);
 			if (CollectionUtil.isNotEmpty(corpUserSendRecords)) {
 				corpUserSendRecords.forEach(corpUserSendRecord -> {
+					log.info("失败群发记录大小:{}", corpUserSendRecords.size());
 					corpUserSendRecord.setCorpMsgRecordId(corpMsgBulkTaskRecord.getId());
 					corpMsgBulkTaskRecord.setTaskId(corpMsgBulkTaskRecord.getTaskId());
 					corpUserSendRecordService.saveBatch(corpUserSendRecords);