diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxBillDailyServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxBillDailyServiceImpl.java index 531303ddc..03e7b703b 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxBillDailyServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxBillDailyServiceImpl.java @@ -244,7 +244,7 @@ public class WxBillDailyServiceImpl implements WxBillDailyService { public void insertData(WxBillDailyVo billDaily, String importKey, MallUserInfo user) { String shopNumber = billDaily.getShopNumber(); if (StringUtils.isBlank(shopNumber)) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("商铺号为空", billDaily.toString()); return; } @@ -256,43 +256,43 @@ public class WxBillDailyServiceImpl implements WxBillDailyService { shop.setIsDel(EnumDelStatus.NOT_DEL.getCode()); WxShop wxShop = wxShopMapper.selectOne(shop); if (wxShop == null) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("商铺未找到", billDaily.toString()); return; } Integer type = billDaily.getType(); if (type == null) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("账单类型为空", billDaily.toString()); return; } String receivePayStr = billDaily.getReceivePayStr(); if (StringUtils.isBlank(receivePayStr)) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("实际应收金额为空", billDaily.toString()); return; } double receivePayD = new BigDecimal(receivePayStr).doubleValue(); if (receivePayD <= 0) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("实际应收金额小于等于0", billDaily.toString()); return; } String payStr = billDaily.getPayStr(); if (StringUtils.isBlank(payStr)) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("实收金额为空", billDaily.toString()); return; } double payD = new BigDecimal(payStr).doubleValue(); if (payD < 0) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("实收金额小于0", billDaily.toString()); return; } if (receivePayD < payD) { - stringRedisTemplate.opsForHash().increment(importKey, "processCount", 1); + stringRedisTemplate.opsForHash().increment(importKey, "failCount", 1); logger.error("实际应收金额小于实收金额", billDaily.toString()); return; }