|
@@ -83,7 +83,16 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
|
|
|
//redis获取剩余流量
|
|
|
Object traffic = redisCache.getCacheObject(CompanyTrafficConstants.CACHE_KEY + ":" + companyTrafficRecord.getDeptId() + ":" + companyTrafficRecord.getCompanyId());
|
|
|
if(traffic!=null) {
|
|
|
- Long balance = ((Integer) traffic).longValue();
|
|
|
+ Long balance;
|
|
|
+ if(traffic instanceof Long) {
|
|
|
+ balance = (Long) traffic;
|
|
|
+ }else if(traffic instanceof Integer){
|
|
|
+ balance = ((Integer) traffic).longValue();
|
|
|
+ }else if(traffic instanceof String){
|
|
|
+ balance = Long.parseLong(traffic.toString());
|
|
|
+ }else{
|
|
|
+ throw new IllegalArgumentException("流量转换异常");
|
|
|
+ }
|
|
|
long trafficAmount = companyTrafficRecord.getBalance() - balance;
|
|
|
companyTrafficRecord.setBalance(balance);
|
|
|
if (trafficAmount != 0) {
|
|
@@ -181,7 +190,9 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
|
|
|
private void doRefresh(CompanyTrafficRecordChargeParam record, CompanyTrafficRecord companyTrafficRecord) {
|
|
|
if (record.getCompany() != null && record.getCompany().getDeptId() != null) {
|
|
|
// 更新缓存 key=CACHE_KEY:deptId:companyId value=剩余流量
|
|
|
- redisCache.setCacheObject(CompanyTrafficConstants.CACHE_KEY + ":" + record.getCompany().getDeptId() + ":" + record.getCompanyId(),
|
|
|
+
|
|
|
+ redisCache.deleteObject(CompanyTrafficConstants.CACHE_KEY + ":" + record.getCompany().getDeptId() + ":" + record.getCompanyId());
|
|
|
+ redisCache.incr(CompanyTrafficConstants.CACHE_KEY + ":" + record.getCompany().getDeptId() + ":" + record.getCompanyId(),
|
|
|
companyTrafficRecord.getBalance());
|
|
|
|
|
|
// 计算该部门下所有公司流量总和
|
|
@@ -217,10 +228,7 @@ public class CompanyTrafficRecordServiceImpl extends ServiceImpl<CompanyTrafficR
|
|
|
|
|
|
@Override
|
|
|
public List<CompanyTrafficRecord> selectList(CompanyTrafficRecordQueryParam record) {
|
|
|
- return baseMapper.selectList(new LambdaQueryWrapper<CompanyTrafficRecord>()
|
|
|
- .eq(record.getCompanyId() != null,CompanyTrafficRecord::getCompanyId, record.getCompanyId())
|
|
|
- .in(record.getCompanyIds() != null && !record.getCompanyIds().isEmpty(),CompanyTrafficRecord::getCompanyId, record.getCompanyIds())
|
|
|
- .between(record.getCreateTimeStart() != null && record.getCreateTimeEnd() != null,CompanyTrafficRecord::getCreateTime, record.getCreateTimeStart(),record.getCreateTimeEnd()));
|
|
|
+ return baseMapper.selectListWithUncharged(record);
|
|
|
}
|
|
|
|
|
|
@Override
|