diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java index a7231ca8a..054080e02 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxBillAllServiceImpl.java @@ -23,6 +23,7 @@ import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.stereotype.Service; import javax.servlet.http.HttpServletRequest; @@ -30,6 +31,7 @@ import javax.servlet.http.HttpServletResponse; import java.math.BigDecimal; import java.math.RoundingMode; import java.util.*; +import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** @@ -111,6 +113,9 @@ public class WxBillAllServiceImpl implements WxBillAllService { @Autowired WxMerchantShopMapper wxMerchantShopMapper; + @Autowired + StringRedisTemplate stringRedisTemplate; + @Override public Map listAsPage(WxBillAll record, Integer pageIndex, Integer pageSize) { //更新各账单状态 @@ -1154,7 +1159,9 @@ public class WxBillAllServiceImpl implements WxBillAllService { } else { logger.error("账单导入失败"); } - + //记数 + stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.expire(importKey, 10, TimeUnit.SECONDS); } public void addActionImport(Long billId, String payWay, MallUserInfo user) {