|
|
@@ -1460,12 +1460,13 @@ public class CompanyServiceImpl implements ICompanyService
|
|
|
List<Company> companyList = companyMapper.selectCompanyList(query);
|
|
|
Optional.ofNullable(companyList).ifPresent(list -> list.forEach(company -> {
|
|
|
transactionTemplate.execute(status -> {
|
|
|
+ String time=DateUtils.getTime();
|
|
|
String moneyStr = redisCache.getCacheObject(FsConstants.COMPANY_MONEY_KEY + company.getCompanyId());
|
|
|
if (StringUtils.isNotEmpty(moneyStr)) {
|
|
|
// 存到缓存中,有效期25小时
|
|
|
redisCache.setCacheObject(FsConstants.COMPANY_MONEY_DATE_KEY + company.getCompanyId()+":"+DateUtils.getDate(), moneyStr, 25, TimeUnit.HOURS);
|
|
|
// 实际不发生交易只是从缓存获取当天余额报错25小时 交易金额登记为0,备注清楚同步的金额
|
|
|
- String remark = "同步公司余额,金额: " + moneyStr;
|
|
|
+ String remark = "时间:" + time +",当前公司余额,金额: " + moneyStr;
|
|
|
BigDecimal money = new BigDecimal(moneyStr);
|
|
|
asyncRecordBalanceLog(company.getCompanyId(),new BigDecimal(0),18,money,remark);
|
|
|
}
|