Kaynağa Gözat

[集团版][修改]:集团版预处理

release_toaliyun_real
Stormeye Wu 6 yıl önce
ebeveyn
işleme
0b72d1a849
2 değiştirilmiş dosya ile 17 ekleme ve 10 silme
  1. +5
    -4
      mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java
  2. +12
    -6
      mallinkService/src/main/java/com/iformall/service/impl/WxCuserFloatingLayerServiceImpl.java

+ 5
- 4
mallinkService/src/main/java/com/iformall/service/impl/WxCouponServiceImpl.java Dosyayı Görüntüle

@@ -12,6 +12,7 @@ import com.iformall.common.ResultData;
import com.iformall.domain.dto.WxCouponMerchantDto;
import com.iformall.domain.po.*;
import com.iformall.domain.po.base.BaseEntity;
import com.iformall.domain.po.base.TenantEntity;
import com.iformall.domain.vo.WxCouponCVo;
import com.iformall.domain.vo.WxCouponChannelVo;
import com.iformall.domain.vo.WxCouponStatisVo;
@@ -438,18 +439,18 @@ import java.util.stream.Collectors;
}

//清空缓存
clearCache(record.getTenantId());
clearCache(record);
return new ResultData(record.getId());
}


/**
* 清除c端首页券列表缓存
* @param tenantId
* @param tenantEntity
*/
public void clearCache(String tenantId){
public void clearCache(TenantEntity tenantEntity){
for (int i = 1; i <=5 ; i++) {
String key = EnumCacheKey.C_INDEX_PAGE_LIST.getMessage() +tenantId+"_" + i + ":";
String key = EnumCacheKey.C_INDEX_PAGE_LIST.getMessage() +tenantEntity.getTenantId()+"_" + i + ":";
cdRedisTemplate.delete(key);
}
}


+ 12
- 6
mallinkService/src/main/java/com/iformall/service/impl/WxCuserFloatingLayerServiceImpl.java Dosyayı Görüntüle

@@ -2,10 +2,13 @@ package com.iformall.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.iformall.common.IdWorker;
import com.iformall.domain.po.WxAppinfo;
import com.iformall.domain.po.WxCUser;
import com.iformall.domain.po.WxCuserFloatingLayer;
import com.iformall.domain.po.WxFloatingLayer;
import com.iformall.domain.po.base.TenantEntity;
import com.iformall.enums.EnumFloatingLayerStatus;
import com.iformall.mapper.WxAppinfoMapper;
import com.iformall.mapper.WxCUserMapper;
import com.iformall.mapper.WxCuserFloatingLayerMapper;
import com.iformall.mapper.WxFloatingLayerMapper;
@@ -24,6 +27,9 @@ import java.util.Date;
public class WxCuserFloatingLayerServiceImpl implements WxCuserFloatingLayerService {
private final Logger logger = LoggerFactory.getLogger(this.getClass());

@Autowired
WxAppinfoMapper appinfoMapper;

@Autowired
WxCuserFloatingLayerMapper wxCuserFloatingLayerMapper;

@@ -41,9 +47,9 @@ public class WxCuserFloatingLayerServiceImpl implements WxCuserFloatingLayerServ
user.setOpenId(openId);
user.setAppId(appId);
WxCUser byOpenId = wxCUserMapper.findByOpenId(user);
String tenantId = byOpenId.getTenantId();
if (byOpenId == null) {
return getWxFloatingLayer(tenantId);
WxAppinfo appinfo = appinfoMapper.findByAppId(appId);
return getWxFloatingLayer(appinfo.getTenantInfo());
}
//2 用户存在 查看是否已有弹出记录 没有 保存记录后返回浮层信息
WxCuserFloatingLayer wxCuserFloatingLayerQuery = new WxCuserFloatingLayer();
@@ -51,7 +57,7 @@ public class WxCuserFloatingLayerServiceImpl implements WxCuserFloatingLayerServ
WxCuserFloatingLayer wxCuserFloatingLayer = wxCuserFloatingLayerMapper.selectOne(new QueryWrapper<>(wxCuserFloatingLayerQuery));
if (wxCuserFloatingLayer == null) {
saveCuserFloatingLayer(byOpenId);
return getWxFloatingLayer(tenantId);
return getWxFloatingLayer(byOpenId);
}
return null;
}
@@ -62,14 +68,14 @@ public class WxCuserFloatingLayerServiceImpl implements WxCuserFloatingLayerServ
final IdWorker idWorker = IdWorker.get();
wxCuserFloatingLayer.setId(idWorker.nextId());
wxCuserFloatingLayer.setUserId(wxCUser.getId());
wxCuserFloatingLayer.setTenantId(wxCUser.getTenantId());
wxCuserFloatingLayer.updateTenantInfo(wxCUser);
wxCuserFloatingLayer.setCreateTime(new Date());
wxCuserFloatingLayerMapper.insert(wxCuserFloatingLayer);
}

public WxFloatingLayer getWxFloatingLayer(String tenantId) {
public WxFloatingLayer getWxFloatingLayer(TenantEntity tenantEntity) {
WxFloatingLayer wxFloatingLayer = new WxFloatingLayer();
wxFloatingLayer.setTenantId(tenantId);
wxFloatingLayer.updateTenantInfo(tenantEntity);
wxFloatingLayer.setStatus(EnumFloatingLayerStatus.STATUS_THROW_IN.getCode());
return wxFloatingLayerMapper.selectOne(new QueryWrapper<>(wxFloatingLayer));
}


Yükleniyor…
İptal
Kaydet