YOHOBUY / yohobuy-activity · Commits

Go to a project

Authored by zhaoqing
Commit e572f8fee6205aa0a51d70ce5a9164c01feb0ba5 1 parent b59fba4e

消息推送

Inline Side-by-side
Showing 1 changed file with 13 additions and 10 deletions
@@ -129,19 +129,22 @@ public class ProductLimitUserHelpServiceImpl implements IProductLimitUserHelpSer @@ -129,19 +129,22 @@ public class ProductLimitUserHelpServiceImpl implements IProductLimitUserHelpSer
129 helpUserSize = helpUserSize + 1; 129 helpUserSize = helpUserSize + 1;
130 } 130 }
131 } 131 }
132 - //推送好友助力成功消息  
133 - try {  
134 - logger.info("ProductLimitUserHelpServiceImpl: push helpInfo message param : uid is {}, helpUserNum is {}, productName is {}, limitProductCode is {}",limitProductHelpUserRequestBO.getUserId(),  
135 - limitProductBo.getProductName(), helpUserSize, limitProductHelpUserRequestBO.getLimitProductCode());  
136 - SendMessageRspBo responseMessage = iSendLimitCodeMessage.assitSuccess(String.valueOf(limitProductHelpUserRequestBO.getUserId()),  
137 - limitProductBo.getProductName(), helpUserSize, limitProductHelpUserRequestBO.getLimitProductCode());  
138 - logger.info("ProductLimitUserHelpServiceImpl: push helpInfo message success, code is {}, message is {}",responseMessage.getCode(),responseMessage.getMessage());  
139 - }catch (Exception e){  
140 - logger.error("推送助力成功信息失败！", e);  
141 - } 132 +
142 logger.info("ProductLimitUserHelpServiceImpl :: addHelpUserInfo helpUserSize is: {}", helpUserSize); 133 logger.info("ProductLimitUserHelpServiceImpl :: addHelpUserInfo helpUserSize is: {}", helpUserSize);
143 Integer helpLimit = limitProductBo.getHelpLimit(); 134 Integer helpLimit = limitProductBo.getHelpLimit();
144 logger.info("ProductLimitUserHelpServiceImpl :: addHelpUserInfo helpLimit is: {}", helpLimit); 135 logger.info("ProductLimitUserHelpServiceImpl :: addHelpUserInfo helpLimit is: {}", helpLimit);
  136 + if(helpUserSize < helpLimit){
  137 + //推送好友助力成功消息
  138 + try {
  139 + logger.info("ProductLimitUserHelpServiceImpl: push helpInfo message param : uid is {}, helpUserNum is {}, productName is {}, limitProductCode is {}",limitProductHelpUserRequestBO.getUserId(),
  140 + limitProductBo.getProductName(), helpUserSize, limitProductHelpUserRequestBO.getLimitProductCode());
  141 + SendMessageRspBo responseMessage = iSendLimitCodeMessage.assitSuccess(String.valueOf(limitProductHelpUserRequestBO.getUserId()),
  142 + limitProductBo.getProductName(), helpUserSize, limitProductHelpUserRequestBO.getLimitProductCode());
  143 + logger.info("ProductLimitUserHelpServiceImpl: push helpInfo message success, code is {}, message is {}",responseMessage.getCode(),responseMessage.getMessage());
  144 + }catch (Exception e){
  145 + logger.error("推送助力成功信息失败！", e);
  146 + }
  147 + }
145 if (helpUserSize == helpLimit){ 148 if (helpUserSize == helpLimit){
146 ProductLimitCodeReq limitCodeReq = new ProductLimitCodeReq(); 149 ProductLimitCodeReq limitCodeReq = new ProductLimitCodeReq();
147 limitCodeReq.setLimitProductCode(limitProductHelpUserRequestBO.getLimitProductCode()); 150 limitCodeReq.setLimitProductCode(limitProductHelpUserRequestBO.getLimitProductCode());