代理商生成数据异常修改

master
dulingling 4 years ago
parent b63c5088d6
commit e9db5f8737

@ -349,8 +349,8 @@ public class CityPartnerPrizeServiceImpl implements CityPartnerPrizeService {
throw new ServerErrorException("请不要重复生成合伙人记录"); throw new ServerErrorException("请不要重复生成合伙人记录");
} }
// financialPartnerCommissionDetailMapper.clearData(year, month, 1); financialPartnerCommissionDetailMapper.clearData(year, month, 1);
// financialPartnerCommissionMapper.clearData(year, month, 1); financialPartnerCommissionMapper.clearData(year, month, 1);
JSONObject sysConfig = sysConfigManager.getSysConfig(); JSONObject sysConfig = sysConfigManager.getSysConfig();
BigDecimal alipayChargeRate = new BigDecimal("0.6"); BigDecimal alipayChargeRate = new BigDecimal("0.6");
@ -396,7 +396,7 @@ public class CityPartnerPrizeServiceImpl implements CityPartnerPrizeService {
channel.put("month", month); channel.put("month", month);
channel.put("year", year); channel.put("year", year);
channel.put("org_id", orgId); channel.put("org_id", orgId);
// financialPartnerCommissionMapper.save(channel); financialPartnerCommissionMapper.save(channel);
} }
} }
Map<Integer, List<JSONObject>> groupByClientMap = transactionDetail.stream().collect(Collectors.groupingBy(e -> e.getInteger("client_id"))); Map<Integer, List<JSONObject>> groupByClientMap = transactionDetail.stream().collect(Collectors.groupingBy(e -> e.getInteger("client_id")));
@ -405,7 +405,7 @@ public class CityPartnerPrizeServiceImpl implements CityPartnerPrizeService {
Map<String, List<JSONObject>> groupByChannel = oneClient.getValue().stream().collect(Collectors.groupingBy(e -> e.getString("channel"))); Map<String, List<JSONObject>> groupByChannel = oneClient.getValue().stream().collect(Collectors.groupingBy(e -> e.getString("channel")));
List<JSONObject> clientChannelAmount = clientChannelAmount(oneClient.getKey(), org, groupByChannel, channelCharge, year, month, 1); List<JSONObject> clientChannelAmount = clientChannelAmount(oneClient.getKey(), org, groupByChannel, channelCharge, year, month, 1);
for (JSONObject channel : clientChannelAmount) { for (JSONObject channel : clientChannelAmount) {
// financialPartnerCommissionDetailMapper.save(channel); financialPartnerCommissionDetailMapper.save(channel);
} }
} }
Runnable task = () -> { Runnable task = () -> {

Loading…
Cancel
Save