diff --git a/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java b/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java index 2afbe3f39..39b093453 100644 --- a/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java +++ b/mallinkService/src/main/java/com/iformall/service/impl/WxCreditHistoryServiceImpl.java @@ -63,6 +63,9 @@ public class WxCreditHistoryServiceImpl implements WxCreditHistoryService { @Autowired RedisLock redisLock; + @Autowired + WxMerchantMapper wxMerchantMapper; + @Override public void clearCreditByYear() { WxScoreRules wxScoreRules = new WxScoreRules(); @@ -333,6 +336,13 @@ public class WxCreditHistoryServiceImpl implements WxCreditHistoryService { } private int spendCredit(WxCreditHistory record) { + WxMerchant wxMerchant = new WxMerchant(); + wxMerchant.setStatus(1); + wxMerchant.setId(record.getMerchantId()); + List wxMerchantList = wxMerchantMapper.findList(wxMerchant); + if (wxMerchantList == null || wxMerchantList.size() == 0) { + throw new MallinkException(ErrorCode.MERCHANT_INFO_NOT_FOUND); + } //根据商户id和花费金额计算需要新增的积分 Map map = findByMerchantIdAndSpend(record.getMerchantId(), record.getSpendStr(), record.getTenantId()); return map.get("credit");