Просмотр исходного кода

//sharing

release_toaliyun_real
xhxu 3 лет назад
Родитель
Сommit
864538b558
2 измененных файлов: 12 добавлений и 8 удалений
  1. +8
    -4
      mallinkService/src/main/java/com/iformall/service/impl/WxProfitPaymentReceiverServiceImpl.java
  2. +4
    -4
      mallinkService/src/main/java/com/iformall/service/impl/WxProfitSharingReceiverServiceImpl.java

+ 8
- 4
mallinkService/src/main/java/com/iformall/service/impl/WxProfitPaymentReceiverServiceImpl.java Просмотреть файл

@@ -72,7 +72,7 @@ public class WxProfitPaymentReceiverServiceImpl implements WxProfitPaymentReceiv


@Autowired @Autowired
@Qualifier("objectCommonRedisTemplate") @Qualifier("objectCommonRedisTemplate")
RedisTemplate<String, Object> paymentReceicerRedisTemplate;
RedisTemplate<String, Object> receicerRedisTemplate;


@Override @Override
public PageInfo<WxProfitPaymentReceiver> listAsPage(WxProfitPaymentReceiver record, Integer pageIndex, Integer pageSize) { public PageInfo<WxProfitPaymentReceiver> listAsPage(WxProfitPaymentReceiver record, Integer pageIndex, Integer pageSize) {
@@ -127,6 +127,10 @@ public class WxProfitPaymentReceiverServiceImpl implements WxProfitPaymentReceiv
}else{ }else{
wxProfitSharingReceiverMapper.updateById(sharingReceiver); wxProfitSharingReceiverMapper.updateById(sharingReceiver);
} }
String key = Constant.sharingReceicerPrev + sharingReceiver.getTenantId()
+ ":" + sharingReceiver.getPlat()
+ ":" + sharingReceiver.getMerchantId();
RedisCacheUtils.removeCache(receicerRedisTemplate, key);
} }
} }


@@ -142,7 +146,7 @@ public class WxProfitPaymentReceiverServiceImpl implements WxProfitPaymentReceiv
String key = Constant.paymentReceicerPrev + tenantEntity.getTenantId() String key = Constant.paymentReceicerPrev + tenantEntity.getTenantId()
+ ":" + plat.getCode() + ":" + plat.getCode()
+ ":" + merchantId; + ":" + merchantId;
record = RedisCacheUtils.getCacheObject(paymentReceicerRedisTemplate, key, WxProfitPaymentReceiver.class);
record = RedisCacheUtils.getCacheObject(receicerRedisTemplate, key, WxProfitPaymentReceiver.class);
if(record == null){ if(record == null){
WxProfitPaymentReceiver receiver = new WxProfitPaymentReceiver(); WxProfitPaymentReceiver receiver = new WxProfitPaymentReceiver();
receiver.updateTenantInfo(tenantEntity); receiver.updateTenantInfo(tenantEntity);
@@ -152,7 +156,7 @@ public class WxProfitPaymentReceiverServiceImpl implements WxProfitPaymentReceiv
receiver.setStatus(EnumProfitSharingReceiverStatus.PROFIT_SHARING_RECEIVER_STATUS_VALID.getCode()); receiver.setStatus(EnumProfitSharingReceiverStatus.PROFIT_SHARING_RECEIVER_STATUS_VALID.getCode());
record = wxProfitPaymentReceiverMapper.findOne(receiver); record = wxProfitPaymentReceiverMapper.findOne(receiver);
if(record != null){ if(record != null){
RedisCacheUtils.cache(paymentReceicerRedisTemplate, key, record, 3600*24*7);
RedisCacheUtils.cache(receicerRedisTemplate, key, record, 3600*24*3);
} }
} }
return record; return record;
@@ -350,7 +354,7 @@ public class WxProfitPaymentReceiverServiceImpl implements WxProfitPaymentReceiv
String key = Constant.paymentReceicerPrev + receiver.getTenantId() String key = Constant.paymentReceicerPrev + receiver.getTenantId()
+ ":" + receiver.getPlat() + ":" + receiver.getPlat()
+ ":" + receiver.getMerchantId(); + ":" + receiver.getMerchantId();
RedisCacheUtils.removeCache(paymentReceicerRedisTemplate, key);
RedisCacheUtils.removeCache(receicerRedisTemplate, key);
} }
} }




+ 4
- 4
mallinkService/src/main/java/com/iformall/service/impl/WxProfitSharingReceiverServiceImpl.java Просмотреть файл

@@ -87,7 +87,7 @@ public class WxProfitSharingReceiverServiceImpl implements WxProfitSharingReceiv


@Autowired @Autowired
@Qualifier("objectCommonRedisTemplate") @Qualifier("objectCommonRedisTemplate")
RedisTemplate<String, Object> sharingReceicerRedisTemplate;
RedisTemplate<String, Object> receicerRedisTemplate;


@Override @Override
public PageInfo<WxProfitSharingReceiver> listAsPage(WxProfitSharingReceiver record, Integer pageIndex, Integer pageSize) { public PageInfo<WxProfitSharingReceiver> listAsPage(WxProfitSharingReceiver record, Integer pageIndex, Integer pageSize) {
@@ -129,7 +129,7 @@ public class WxProfitSharingReceiverServiceImpl implements WxProfitSharingReceiv
String key = Constant.sharingReceicerPrev + tenantEntity.getTenantId() String key = Constant.sharingReceicerPrev + tenantEntity.getTenantId()
+ ":" + plat.getCode() + ":" + plat.getCode()
+ ":" + merchantId; + ":" + merchantId;
record = RedisCacheUtils.getCacheObject(sharingReceicerRedisTemplate, key, WxProfitSharingReceiver.class);
record = RedisCacheUtils.getCacheObject(receicerRedisTemplate, key, WxProfitSharingReceiver.class);
if(record == null){ if(record == null){
WxProfitSharingReceiver receiver = new WxProfitSharingReceiver(); WxProfitSharingReceiver receiver = new WxProfitSharingReceiver();
receiver.updateTenantInfo(tenantEntity); receiver.updateTenantInfo(tenantEntity);
@@ -142,7 +142,7 @@ public class WxProfitSharingReceiverServiceImpl implements WxProfitSharingReceiv
record = receivers.get(0); record = receivers.get(0);
} }
if(record != null){ if(record != null){
RedisCacheUtils.cache(sharingReceicerRedisTemplate, key, record, 3600*24*7);
RedisCacheUtils.cache(receicerRedisTemplate, key, record, 3600*24*3);
} }
} }
return record; return record;
@@ -346,7 +346,7 @@ public class WxProfitSharingReceiverServiceImpl implements WxProfitSharingReceiv
String key = Constant.sharingReceicerPrev + receiver.getTenantId() String key = Constant.sharingReceicerPrev + receiver.getTenantId()
+ ":" + receiver.getPlat() + ":" + receiver.getPlat()
+ ":" + receiver.getMerchantId(); + ":" + receiver.getMerchantId();
RedisCacheUtils.removeCache(sharingReceicerRedisTemplate, key);
RedisCacheUtils.removeCache(receicerRedisTemplate, key);
} }
} }
} }

Загрузка…
Отмена
Сохранить