From 9fe5db1e4c131a9fd8b2605b362c1a285d20809e Mon Sep 17 00:00:00 2001 From: Burce Date: Tue, 17 Sep 2019 22:35:36 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BF=AE=E5=A4=8D][=E6=95=B0=E6=8D=AE]?= =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A7=AF=E5=88=86=E6=8E=A5=E5=8F=A3=E5=BC=82?= =?UTF-8?q?=E5=B8=B8=E6=95=B0=E6=8D=AE=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/sys/DataInitController.java | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/mallinkSysAdmin/src/main/java/com/iformall/controller/sys/DataInitController.java b/mallinkSysAdmin/src/main/java/com/iformall/controller/sys/DataInitController.java index efa07062e..5d86ab63b 100644 --- a/mallinkSysAdmin/src/main/java/com/iformall/controller/sys/DataInitController.java +++ b/mallinkSysAdmin/src/main/java/com/iformall/controller/sys/DataInitController.java @@ -8,6 +8,7 @@ import com.iformall.domain.po.*; import com.iformall.enums.EnumMsgModel; import com.iformall.enums.EnumScoreType; import com.iformall.enums.EnumUserType; +import com.iformall.exception.MallinkException; import com.iformall.mapper.*; import com.iformall.service.WxCreditHistoryService; import com.iformall.utils.DateUtils; @@ -56,6 +57,9 @@ public class DataInitController extends BaseController { @Resource private WxMerchantBUserMapper merchantBUserMapper; + @Resource + private WxMerchantMapper wxMerchantMapper; + @GetMapping("/init") public ResultData init() { @@ -130,7 +134,18 @@ public class DataInitController extends BaseController { return; } - Map result = creditHistoryService.findByMerchantIdAndSpend(wxCreditHistory.getMerchantId(), String.valueOf(wxCreditHistory.getSpend()), wxCreditHistory.getCUserId(), wxCreditHistory.getTenantId()); + WxMerchant wxMerchant = new WxMerchant(); + wxMerchant.setStatus(1); + wxMerchant.setId(wxCreditHistory.getMerchantId()); + List wxMerchantList = wxMerchantMapper.findList(wxMerchant); + if (wxMerchantList == null || wxMerchantList.size() == 0) { + log.debug(ErrorCode.MERCHANT_INFO_NOT_FOUND.getMessage()); + return; + } + //根据商户id和花费金额计算需要新增的积分 + Map result = creditHistoryService.findByMerchantIdAndSpend(wxCreditHistory.getMerchantId(), String.valueOf(wxCreditHistory.getSpend()), wxCreditHistory.getCUserId(),wxCreditHistory.getTenantId()); + + //Map result = creditHistoryService.findByMerchantIdAndSpend(wxCreditHistory.getMerchantId(), String.valueOf(wxCreditHistory.getSpend()), wxCreditHistory.getCUserId(), wxCreditHistory.getTenantId()); Integer creditDB = wxCreditHistory.getCreditNum(); Integer credit = result.get("credit"); if (Objects.equals(credit, creditDB)) { @@ -187,7 +202,7 @@ public class DataInitController extends BaseController { } if (ret != null) { - log.debug("用户已有积分历史id: {}", ret.getId()); + log.debug(" : {}", ret.getId()); return; } WxCUser cuUser = cUserMapper.selectByPrimaryKey(co.getcUserId());