...
|
...
|
@@ -17,6 +17,7 @@ import com.yohoufo.inboxclient.sdk.InBoxSDK; |
|
|
import com.yohoufo.order.service.impl.function.BuyerNoticeSender;
|
|
|
import com.yohoufo.order.utils.PaymentHelper;
|
|
|
import lombok.NonNull;
|
|
|
import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.commons.lang3.StringUtils;
|
|
|
import org.slf4j.Logger;
|
|
|
import org.slf4j.LoggerFactory;
|
...
|
...
|
@@ -37,10 +38,9 @@ import java.util.concurrent.TimeUnit; |
|
|
* Created by chenchao on 2018/10/8.
|
|
|
*/
|
|
|
@Service
|
|
|
@Slf4j(topic = "notice")
|
|
|
public class InBoxFacade extends BaseNoticeFacade{
|
|
|
|
|
|
private final Logger logger = LoggerFactory.getLogger(getClass());
|
|
|
|
|
|
private ExecutorService executorService = new ThreadPoolExecutor(5, 10, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(1000), new InBoxThreadFactory());
|
|
|
|
|
|
@Autowired
|
...
|
...
|
@@ -71,7 +71,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
* @param buyerUid
|
|
|
*/
|
|
|
public void buyerOrderNotPayed(int buyerUid, long orderCode) {
|
|
|
logger.info("notice buyer not paid, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
log.info("notice buyer not paid, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
newNotice(buyerUid)
|
|
|
.withLogPrefix("notice buyer not paid")
|
|
|
.withInBox(InboxBusinessTypeEnum.PURCHASE_UNPAID, orderCode)
|
...
|
...
|
@@ -86,7 +86,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
* @param orderCode
|
|
|
*/
|
|
|
public void buyerFinishPaid(int buyerUid, long orderCode, int deliveryHours, String unit) {
|
|
|
logger.info("notice buyer finish paid, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
log.info("notice buyer finish paid, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
String timelimitDesc = new StringBuilder().append(deliveryHours).append(unit).toString();
|
|
|
newNotice(buyerUid)
|
|
|
.withLogPrefix("notice buyer finish paid")
|
...
|
...
|
@@ -103,7 +103,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
*/
|
|
|
public void sellerDeliver2Depot(int buyerUid, long orderCode, SellerOrderGoods psog) {
|
|
|
try {
|
|
|
logger.info("notice buyer seller deliver 2 depot, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
log.info("notice buyer seller deliver 2 depot, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
newNotice(buyerUid)
|
|
|
.withLogPrefix("notice buyer seller deliver 2 depot")
|
|
|
.withInBox(InboxBusinessTypeEnum.NOTICE_BUYER_WHEN_SELLER_DELIVER, orderCode)
|
...
|
...
|
@@ -118,7 +118,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
})
|
|
|
.send();
|
|
|
} catch (Exception ex) {
|
|
|
logger.warn("notice buyer seller deliver 2 depot fail, buyerUid {}, orderCode {}", buyerUid, orderCode, ex);
|
|
|
log.warn("notice buyer seller deliver 2 depot fail, buyerUid {}, orderCode {}", buyerUid, orderCode, ex);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -129,7 +129,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
*/
|
|
|
public void appraisePassAndDeliveryGoodsToBuyerNoticeBuyer(int buyerUid, long orderCode, SellerOrderGoods psog) {
|
|
|
try {
|
|
|
logger.info("notice buyer appraise pass, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
log.info("notice buyer appraise pass, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
newNotice(buyerUid)
|
|
|
.withLogPrefix("notice buyer appraise pass")
|
|
|
.withInBox(InboxBusinessTypeEnum.PURCHASE_SENDED, orderCode)
|
...
|
...
|
@@ -143,13 +143,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
})
|
|
|
.send();
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("notice buyer appraise pass fail, buyerUid {}, orderCode {}", buyerUid, orderCode, e);
|
|
|
log.warn("notice buyer appraise pass fail, buyerUid {}, orderCode {}", buyerUid, orderCode, e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public void appraisePassNoticeSeller(int buyerUid, long orderCode, SellerOrderGoods psog) {
|
|
|
try {
|
|
|
logger.info("notice seller appraise pass, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
log.info("notice seller appraise pass, buyerUid {}, orderCode {}", buyerUid, orderCode);
|
|
|
newNotice(psog.getUid())
|
|
|
.withLogPrefix("notice seller appraise pass")
|
|
|
.withInBox(() -> {
|
...
|
...
|
@@ -167,7 +167,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
.send();
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("notice seller appraise pass fail, buyerUid {}, orderCode {}", buyerUid, orderCode, e);
|
|
|
log.warn("notice seller appraise pass fail, buyerUid {}, orderCode {}", buyerUid, orderCode, e);
|
|
|
}
|
|
|
|
|
|
}
|
...
|
...
|
@@ -192,17 +192,17 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeBuyerWhenSellerCancelAfterPaid inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeBuyerWhenSellerCancelAfterPaid inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode, prdName,resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.sellerCancelTrade(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
logger.info("record noticeBuyerWhenSellerCancelAfterPaid push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record noticeBuyerWhenSellerCancelAfterPaid push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeBuyerWhenSellerCancelAfterPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in noticeBuyerWhenSellerCancelAfterPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -210,11 +210,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
String content=getReplacedContent(InboxBusinessTypeEnum.SMS_CLOSED_SELLER.getContent(),skupTypeText,prdName,productCode,sizeName,orderCode);
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeBuyerWhenSellerCancelAfterPaid inbox sms msg, buyerUid {}, orderCode {},prdName {}",
|
|
|
log.info("record noticeBuyerWhenSellerCancelAfterPaid inbox sms msg, buyerUid {}, orderCode {},prdName {}",
|
|
|
buyerUid, orderCode,prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeBuyerWhenSellerCancelAfterPaid error inbox msg, buyerUid {}, orderCode {} prdName {}",
|
|
|
log.warn("InBoxFacade noticeBuyerWhenSellerCancelAfterPaid error inbox msg, buyerUid {}, orderCode {} prdName {}",
|
|
|
buyerUid, orderCode,psog, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -230,11 +230,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerCancelOrder inbox msg, buyerUid {}, orderCode {}, resp {}",
|
|
|
log.info("record buyerCancelOrder inbox msg, buyerUid {}, orderCode {}, resp {}",
|
|
|
buyerUid, orderCode, resp);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerCancelOrder error inbox msg, buyerUid {}, orderCode {} ",
|
|
|
log.warn("InBoxFacade buyerCancelOrder error inbox msg, buyerUid {}, orderCode {} ",
|
|
|
buyerUid, orderCode, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -256,7 +256,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerGetEarnestMoneyWhenAppraiseFail inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record buyerGetEarnestMoneyWhenAppraiseFail inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
|
|
|
Product product = productMapper.selectByPrimaryKey(sellerOrderGoods.getProductId());
|
...
|
...
|
@@ -265,18 +265,18 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in buyerGetEarnestMoneyWhenAppraiseFail sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in buyerGetEarnestMoneyWhenAppraiseFail sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
|
|
|
String content=getReplacedContent(InboxBusinessTypeEnum.SMS_CLOSED_PLATFORM.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record buyerGetEarnestMoneyWhenAppraiseFail inbox sms msg, buyerUid {}, orderCode {},prdName {}",
|
|
|
log.info("record buyerGetEarnestMoneyWhenAppraiseFail inbox sms msg, buyerUid {}, orderCode {},prdName {}",
|
|
|
buyerUid, orderCode,prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerGetEarnestMoneyWhenAppraiseFail error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("InBoxFacade buyerGetEarnestMoneyWhenAppraiseFail error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
buyerUid, orderCode,sellerOrderGoods, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -293,11 +293,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeBuyerWhenPlatformReceiveGoods inbox msg, buyerUid {}, orderCode {}, resp {}",
|
|
|
log.info("record noticeBuyerWhenPlatformReceiveGoods inbox msg, buyerUid {}, orderCode {}, resp {}",
|
|
|
buyerUid, orderCode, resp);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerCancelOrder error inbox msg, buyerUid {}, orderCode {} ",
|
|
|
log.warn("InBoxFacade buyerCancelOrder error inbox msg, buyerUid {}, orderCode {} ",
|
|
|
buyerUid, orderCode, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -316,18 +316,18 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeBuyerWhenQualityCheckNotPass inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeBuyerWhenQualityCheckNotPass inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.platformNotPass(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
logger.info("record noticeBuyerWhenQualityCheckNotPass push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record noticeBuyerWhenQualityCheckNotPass push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeBuyerWhenQualityCheckNotPass sms fail, buyerUid {} orderCode {} ,prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in noticeBuyerWhenQualityCheckNotPass sms fail, buyerUid {} orderCode {} ,prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
Product product = productMapper.selectByPrimaryKey(sellerOrderGoods.getProductId());
|
...
|
...
|
@@ -337,11 +337,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
String content=getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_BUYER_WHEN_QUALITY_NOT_PASS.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeBuyerWhenQualityCheckNotPass inbox sms msg, buyerUid {}, orderCode {}, prdName {}",
|
|
|
log.info("record noticeBuyerWhenQualityCheckNotPass inbox sms msg, buyerUid {}, orderCode {}, prdName {}",
|
|
|
buyerUid, orderCode,prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeBuyerWhenQualityCheckNotPass error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("InBoxFacade noticeBuyerWhenQualityCheckNotPass error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
buyerUid, orderCode,sellerOrderGoods, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -352,7 +352,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
public void buyerMiniFaultCreate(int buyerUid, long orderCode,SellerOrderGoods psog,Product product) {
|
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
logger.info("record buyerMiniFaultCreate inbox enter, buyerUid {} ,orderCode {} ,psog {},product {}",
|
|
|
log.info("record buyerMiniFaultCreate inbox enter, buyerUid {} ,orderCode {} ,psog {},product {}",
|
|
|
buyerUid, orderCode ,psog, JSON.toJSONString(product));
|
|
|
String skupTypeText=SkupType.getSkupType(psog.getAttributes()).attrName();
|
|
|
String prdName = psog.getProductName();
|
...
|
...
|
@@ -364,29 +364,29 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerMiniFaultCreate inbox msg, buyerUid {} ,orderCode {} ,psog {},product {},resp {}",
|
|
|
log.info("record buyerMiniFaultCreate inbox msg, buyerUid {} ,orderCode {} ,psog {},product {},resp {}",
|
|
|
buyerUid, orderCode ,psog,JSON.toJSONString(product),resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.buyerFlawConfirm(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
logger.info("record buyerMiniFaultCreate push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record buyerMiniFaultCreate push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("buyerMiniFaultCreate sms send fail,buyerUid {} ,orderCode {},psog {},product {}", buyerUid, orderCode,psog,JSON.toJSONString(product));
|
|
|
log.warn("buyerMiniFaultCreate sms send fail,buyerUid {} ,orderCode {},psog {},product {}", buyerUid, orderCode,psog,JSON.toJSONString(product));
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_CHECK_ORDER_PROBLEM.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record buyerMiniFaultCreate inbox sms msg,buyerUid {}, orderCode {},prdName {}",
|
|
|
log.info("record buyerMiniFaultCreate inbox sms msg,buyerUid {}, orderCode {},prdName {}",
|
|
|
buyerUid ,orderCode,prdName);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerMiniFaultCreate error inbox msg, buyerUid {},orderCode {},psog {},product {} ",
|
|
|
log.warn("InBoxFacade buyerMiniFaultCreate error inbox msg, buyerUid {},orderCode {},psog {},product {} ",
|
|
|
buyerUid, orderCode,psog ,JSON.toJSONString(product), e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -408,20 +408,20 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerQualityCheckNotPass inbox msg, buyerUid {} ,orderCode {},prdName {} ,resp {}",
|
|
|
log.info("record buyerQualityCheckNotPass inbox msg, buyerUid {} ,orderCode {},prdName {} ,resp {}",
|
|
|
buyerUid, orderCode, prdName ,resp);
|
|
|
|
|
|
//瑕疵确认超时,发push
|
|
|
if(outTimeFlag){
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.buyerConfirmFlawExceed(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
logger.info("record buyerQualityCheckNotPass push buyer uid is {}, orderCode is {},outTimeFlag {}, result is {}", buyerUid, orderCode,outTimeFlag, JSON.toJSONString(bo));
|
|
|
log.info("record buyerQualityCheckNotPass push buyer uid is {}, orderCode is {},outTimeFlag {}, result is {}", buyerUid, orderCode,outTimeFlag, JSON.toJSONString(bo));
|
|
|
}
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("buyerQualityCheckNotPass sms send fail,buyerUid {} ,orderCode {}", buyerUid, orderCode);
|
|
|
log.warn("buyerQualityCheckNotPass sms send fail,buyerUid {} ,orderCode {}", buyerUid, orderCode);
|
|
|
return;
|
|
|
}
|
|
|
Product product = productMapper.selectByPrimaryKey(sellerOrderGoods.getProductId());
|
...
|
...
|
@@ -434,12 +434,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content = getReplacedContent(sms.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record buyerQualityCheckNotPass inbox sms msg,buyerUid {}, prdName {},orderCode {}",
|
|
|
log.info("record buyerQualityCheckNotPass inbox sms msg,buyerUid {}, prdName {},orderCode {}",
|
|
|
buyerUid , prdName,orderCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerSkupPaidByBuyer error inbox msg, buyerUid {},orderCode {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerSkupPaidByBuyer error inbox msg, buyerUid {},orderCode {}, prdName {} ",
|
|
|
buyerUid, orderCode ,sellerOrderGoods, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -456,11 +456,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
*/
|
|
|
public void sellerOrderNotPaid(int sellerUid, String prdName) {
|
|
|
try {
|
|
|
logger.info("record in sellerOrderNotPaid inbox msg, sellerUid {}, prdName {}",
|
|
|
log.info("record in sellerOrderNotPaid inbox msg, sellerUid {}, prdName {}",
|
|
|
sellerUid, prdName);
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerOrderNotPaid error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerOrderNotPaid error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -475,7 +475,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
public void sellerPaidEarnestMoney(int sellerUid, String prdName,String sizeName,Integer productId,Integer prdAttr) {
|
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
logger.info("record sellerPaidEarnestMoney inbox in , sellerUid {}, prdName {}, sizeName {} ,productId {},prdAttr {}",
|
|
|
log.info("record sellerPaidEarnestMoney inbox in , sellerUid {}, prdName {}, sizeName {} ,productId {},prdAttr {}",
|
|
|
sellerUid, prdName, sizeName,productId,prdAttr);
|
|
|
Product product = productMapper.selectByPrimaryKey(productId);
|
|
|
String productCode = product.getProductCode();
|
...
|
...
|
@@ -486,11 +486,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerPaidEarnestMoney inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
log.info("record sellerPaidEarnestMoney inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
sellerUid, prdName, resp);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerPaidEarnestMoney error inbox msg, sellerUid {}, prdName {} ,productId {} ",
|
|
|
log.warn("InBoxFacade sellerPaidEarnestMoney error inbox msg, sellerUid {}, prdName {} ,productId {} ",
|
|
|
sellerUid, prdName,productId, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -514,12 +514,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerPlaySelf inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
log.info("record sellerPlaySelf inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
sellerUid, prdName, resp);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerPlaySelf error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerPlaySelf error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, sellerOrderGoods, e);
|
|
|
}
|
|
|
|
...
|
...
|
@@ -545,12 +545,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerSkupCreateOrderByBuyer inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
log.info("record sellerSkupCreateOrderByBuyer inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
sellerUid, prdName, resp);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerSkupCreateOrderByBuyer error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerSkupCreateOrderByBuyer error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, psog, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -575,13 +575,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerMiniFaultUnAccept inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},resp {}",
|
|
|
log.info("record sellerMiniFaultUnAccept inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},resp {}",
|
|
|
JSON.toJSONString(sog),sellerUid, prdName, sizeName, resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sellerMiniFaultUnAccept sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("sellerMiniFaultUnAccept sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -591,12 +591,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content = getReplacedContent(sms.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerMiniFaultUnAccept inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
log.info("record sellerMiniFaultUnAccept inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
sellerUid, prdName,orderCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerMiniFaultUnAccept error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerMiniFaultUnAccept error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -618,24 +618,24 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerQualityCheckNotPass inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},resp {}",
|
|
|
log.info("record sellerQualityCheckNotPass inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},resp {}",
|
|
|
JSON.toJSONString(sog),sellerUid, prdName, sizeName, resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sellerQualityCheckNotPass sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("sellerQualityCheckNotPass sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_SELLER_WHEN_QUALITY_CHECK_REJECT.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerQualityCheckNotPass inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
log.info("record sellerQualityCheckNotPass inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
sellerUid, prdName,orderCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerQualityCheckNotPass error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerQualityCheckNotPass error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -656,13 +656,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerQualityCheckNotPass_send_back inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},type {}, resp {}",
|
|
|
log.info("record sellerQualityCheckNotPass_send_back inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {},type {}, resp {}",
|
|
|
JSON.toJSONString(sog),sellerUid, prdName, sizeName,type , resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sellerQualityCheckNotPass_send_back sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("sellerQualityCheckNotPass_send_back sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -676,12 +676,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content = getReplacedContent(sms.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode,wayBillCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerQualityCheckNotPass_send_back inbox sms msg,sellerUid {}, prdName {},type {},orderCode {}",
|
|
|
log.info("record sellerQualityCheckNotPass_send_back inbox sms msg,sellerUid {}, prdName {},type {},orderCode {}",
|
|
|
sellerUid, prdName,type,orderCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerQualityCheckNotPass_send_back error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerQualityCheckNotPass_send_back error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -707,29 +707,29 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerSkupPaidByBuyer inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {} timelimitDesc {}, resp {}",
|
|
|
log.info("record sellerSkupPaidByBuyer inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {} timelimitDesc {}, resp {}",
|
|
|
JSON.toJSONString(sog),sellerUid, prdName, sizeName, timelimitDesc, resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.sellerGoodsSend(String.valueOf(sellerUid),String.valueOf(orderCode),prdName,sizeName,productCode,timelimitDesc);
|
|
|
logger.info("record sellerSkupPaidByBuyer push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record sellerSkupPaidByBuyer push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sellerSkupPaidByBuyer sms send fail,sellerUid {}, prdName {} timelimitDesc {}",
|
|
|
log.warn("sellerSkupPaidByBuyer sms send fail,sellerUid {}, prdName {} timelimitDesc {}",
|
|
|
sellerUid, prdName, timelimitDesc);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTIFIED_SEND.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode,timelimitDesc);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerSkupPaidByBuyer inbox sms msg,sellerUid {}, prdName {},orderCode {} timelimitDesc {}",
|
|
|
log.info("record sellerSkupPaidByBuyer inbox sms msg,sellerUid {}, prdName {},orderCode {} timelimitDesc {}",
|
|
|
sellerUid, prdName,orderCode, timelimitDesc);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerSkupPaidByBuyer error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerSkupPaidByBuyer error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -753,12 +753,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerCancelAfterBuyerPaid inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
log.info("record sellerCancelAfterBuyerPaid inbox msg, sellerUid {}, prdName {}, resp {}",
|
|
|
sellerUid, prdName, resp);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerCancelAfterBuyerPaid error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerCancelAfterBuyerPaid error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -781,7 +781,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticSellerWhenBuyerCancel inbox msg, sellerUid {}, sog {}, resp {}",
|
|
|
log.info("record noticSellerWhenBuyerCancel inbox msg, sellerUid {}, sog {}, resp {}",
|
|
|
sellerUid, sog, resp);
|
|
|
|
|
|
//短信
|
...
|
...
|
@@ -801,7 +801,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticSellerWhenBuyerCancel error inbox msg, sellerUid {}, sog {} ",
|
|
|
log.warn("InBoxFacade noticSellerWhenBuyerCancel error inbox msg, sellerUid {}, sog {} ",
|
|
|
sellerUid, sog, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -825,25 +825,25 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeSellerWhenAppraiseFail inbox msg, SellerOrderGoods {} sellerUid {}, prdName {} orderCode {},wayBillCode {} resp {}",
|
|
|
log.info("record noticeSellerWhenAppraiseFail inbox msg, SellerOrderGoods {} sellerUid {}, prdName {} orderCode {},wayBillCode {} resp {}",
|
|
|
JSON.toJSONString(sog), sellerUid, prdName,orderCode ,wayBillCode, resp);
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("record noticeSellerWhenAppraiseFail sms send fail cause of empty phone number,sellerUid {}, prdName {} ,wayBillCode {}", sellerUid, prdName,wayBillCode);
|
|
|
log.warn("record noticeSellerWhenAppraiseFail sms send fail cause of empty phone number,sellerUid {}, prdName {} ,wayBillCode {}", sellerUid, prdName,wayBillCode);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_SELLER_WHEN_CLOSED_PLATFORM.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode,wayBillCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record noticeSellerWhenAppraiseFail sms send,sellerUid {}, prdName {},orderCode {},wayBillCode {} ",
|
|
|
log.info("record noticeSellerWhenAppraiseFail sms send,sellerUid {}, prdName {},orderCode {},wayBillCode {} ",
|
|
|
sellerUid, prdName,orderCode,wayBillCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSellerWhenAppraiseFail error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade noticeSellerWhenAppraiseFail error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -868,29 +868,29 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record notifyUnshelfCauseBySpecialReason inbox msg, sellerUid {}, prdName {},psog {}, resp {}",
|
|
|
log.info("record notifyUnshelfCauseBySpecialReason inbox msg, sellerUid {}, prdName {},psog {}, resp {}",
|
|
|
sellerUid, prdName, psog,resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.skuClosedNotice(String.valueOf(sellerUid),prdName,sizeName,productCode);
|
|
|
logger.info("record notifyUnshelfCauseBySpecialReason push seller uid is {}, prdName is {}, result is {}", sellerUid, prdName, JSON.toJSONString(bo));
|
|
|
log.info("record notifyUnshelfCauseBySpecialReason push seller uid is {}, prdName is {}, result is {}", sellerUid, prdName, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("notifyUnshelfCauseBySpecialReason sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("notifyUnshelfCauseBySpecialReason sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTIFIED_UNSHELF.getContent(),skupTypeText,prdName,sizeName,productCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record notifyUnshelfCauseBySpecialReason inbox sms msg,sellerUid {}, prdName {}, resp {}",
|
|
|
log.info("record notifyUnshelfCauseBySpecialReason inbox sms msg,sellerUid {}, prdName {}, resp {}",
|
|
|
sellerUid, prdName);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade notifyUnshelfCauseBySpecialReason error inbox msg, sellerUid {}, psog {} ",
|
|
|
log.warn("InBoxFacade notifyUnshelfCauseBySpecialReason error inbox msg, sellerUid {}, psog {} ",
|
|
|
sellerUid, psog, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -905,7 +905,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
// 发站内信
|
|
|
logger.info("record noticeSellerWhenOtherChangePriceLower for seller,noticeSellerMap {}, sog {}", noticeSellerMap, sog);
|
|
|
log.info("record noticeSellerWhenOtherChangePriceLower for seller,noticeSellerMap {}, sog {}", noticeSellerMap, sog);
|
|
|
|
|
|
Product product = productMapper.selectByPrimaryKey(sog.getProductId());
|
|
|
String productCode = product.getProductCode();
|
...
|
...
|
@@ -916,28 +916,28 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
//发消息
|
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, InboxBusinessTypeEnum.NOTICE_SELLER_WHEN_OTHER_LOWER_PRICE);
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeSellerWhenOtherChangePriceLower for seller send msg ,seller uid {} resp {} noticeSellerMap {}, sog {}", sellerUid,resp,noticeSellerMap, sog);
|
|
|
log.info("record noticeSellerWhenOtherChangePriceLower for seller send msg ,seller uid {} resp {} noticeSellerMap {}, sog {}", sellerUid,resp,noticeSellerMap, sog);
|
|
|
//发push
|
|
|
SellerOrder currSellerOrder = sellerOrderMapper.selectBySkup(currSog.getId());
|
|
|
if(currSellerOrder==null){
|
|
|
logger.warn("InBoxFacade noticeSellerWhenOtherChangePriceLower error sellerOrder is null,skup {}, noticeSellerMap {}, sog {} ",noticeSellerMap.get(sellerUid).getId(), noticeSellerMap, sog);
|
|
|
log.warn("InBoxFacade noticeSellerWhenOtherChangePriceLower error sellerOrder is null,skup {}, noticeSellerMap {}, sog {} ",noticeSellerMap.get(sellerUid).getId(), noticeSellerMap, sog);
|
|
|
return ;
|
|
|
}
|
|
|
SendMessageRspBo bo=null;
|
|
|
if(PaymentHelper.isWallet(currSellerOrder.getPayment())){
|
|
|
//入驻
|
|
|
bo = ufoSendService.sendLessPriceEnter(String.valueOf(sellerUid), prdName,sizeName,productCode,noticePrice, String.valueOf(currSog.getProductId()));
|
|
|
logger.info("record noticeSellerWhenOtherChangePriceLower push enter seller uid is {}, product id is {}, result is {}", sellerUid, currSog.getProductId(), JSON.toJSONString(bo));
|
|
|
log.info("record noticeSellerWhenOtherChangePriceLower push enter seller uid is {}, product id is {}, result is {}", sellerUid, currSog.getProductId(), JSON.toJSONString(bo));
|
|
|
}else{
|
|
|
bo = ufoSendService.sendLessPrice(String.valueOf(sellerUid), prdName,sizeName,productCode,noticePrice, String.valueOf(currSellerOrder.getOrderCode()));
|
|
|
logger.info("record noticeSellerWhenOtherChangePriceLower push non enter seller uid is {}, seller order code is {}, result is {}", sellerUid, currSellerOrder.getOrderCode(), JSON.toJSONString(bo));
|
|
|
log.info("record noticeSellerWhenOtherChangePriceLower push non enter seller uid is {}, seller order code is {}, result is {}", sellerUid, currSellerOrder.getOrderCode(), JSON.toJSONString(bo));
|
|
|
}
|
|
|
}
|
|
|
logger.info("record noticeSellerWhenOtherChangePriceLower for seller end,noticeSellerMap {}, sog {}", noticeSellerMap, sog);
|
|
|
log.info("record noticeSellerWhenOtherChangePriceLower for seller end,noticeSellerMap {}, sog {}", noticeSellerMap, sog);
|
|
|
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSellerWhenOtherChangePriceLower error inbox msg, noticeSellerMap {}, sog {} ", noticeSellerMap, sog, e);
|
|
|
log.warn("InBoxFacade noticeSellerWhenOtherChangePriceLower error inbox msg, noticeSellerMap {}, sog {} ", noticeSellerMap, sog, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -965,7 +965,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
// 发站内信
|
|
|
logger.info("record noticeSellerWhenSecondHandProductApplyAudit pass {} for seller,SellerOrderGoods {}, rejectReason {}", passFlag, sog,rejectReason);
|
|
|
log.info("record noticeSellerWhenSecondHandProductApplyAudit pass {} for seller,SellerOrderGoods {}, rejectReason {}", passFlag, sog,rejectReason);
|
|
|
Product product = productMapper.selectByPrimaryKey(sog.getProductId());
|
|
|
String productCode = product.getProductCode();
|
|
|
|
...
|
...
|
@@ -981,12 +981,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params,msgBizType );
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeSellerWhenSecondHandProductApplyAudit pass {} for seller msg end,SellerOrderGoods {}, resp {}", passFlag, sog,resp);
|
|
|
log.info("record noticeSellerWhenSecondHandProductApplyAudit pass {} for seller msg end,SellerOrderGoods {}, resp {}", passFlag, sog,resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("record noticeSellerWhenSecondHandProductApplyAudit sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("record noticeSellerWhenSecondHandProductApplyAudit sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -998,7 +998,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content = getReplacedContent(smsBizType.getContent(),skupTypeText,prdName,sizeName,productCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record noticeSellerWhenSecondHandProductApplyAudit inbox sms msg pass {} for seller,SellerOrderGoods {}, resp {}", passFlag, sog,resp);
|
|
|
log.info("record noticeSellerWhenSecondHandProductApplyAudit inbox sms msg pass {} for seller,SellerOrderGoods {}, resp {}", passFlag, sog,resp);
|
|
|
|
|
|
//发push
|
|
|
/*
|
...
|
...
|
@@ -1007,7 +1007,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
*/
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSellerWhenSecondHandProductApplyAudit error inbox msg, pass {}, sog {} ", passFlag, sog, e);
|
|
|
log.warn("InBoxFacade noticeSellerWhenSecondHandProductApplyAudit error inbox msg, pass {}, sog {} ", passFlag, sog, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1016,7 +1016,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
********************************************************************/
|
|
|
|
|
|
public void sendMsg4EntySeller(Integer uid){
|
|
|
logger.info("InBoxFacade sendMsg4EntySeller inbox msg, uid {}",uid);
|
|
|
log.info("InBoxFacade sendMsg4EntySeller inbox msg, uid {}",uid);
|
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
// 发送消息
|
...
|
...
|
@@ -1025,18 +1025,18 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO inBoxReq = buildInboxReqVO(uid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(inBoxReq);
|
|
|
logger.info("InBoxFacade sendMsg4enty inbox msg, uid {}, resp {}",
|
|
|
log.info("InBoxFacade sendMsg4enty inbox msg, uid {}, resp {}",
|
|
|
uid, resp);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sendMsg4EntySeller error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sendMsg4EntySeller error inbox msg, sellerUid {}, prdName {} ",
|
|
|
uid, e);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
public void sendMsg4QuitEntrySeller(Integer uid){
|
|
|
logger.info("InBoxFacade sendMsg4QuitEntrySeller inbox msg, uid {}",uid);
|
|
|
log.info("InBoxFacade sendMsg4QuitEntrySeller inbox msg, uid {}",uid);
|
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
// 发送消息
|
...
|
...
|
@@ -1045,26 +1045,26 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO inBoxReq = buildInboxReqVO(uid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(inBoxReq);
|
|
|
logger.info("InBoxFacade sendMsg4quit inbox msg, uid {}, resp {}",
|
|
|
log.info("InBoxFacade sendMsg4quit inbox msg, uid {}, resp {}",
|
|
|
uid, resp);
|
|
|
|
|
|
// 发送短信
|
|
|
String content=InboxBusinessTypeEnum.SMS_EXIT_SETTLED.getContent();
|
|
|
String phone=userProxyService.getMobile(uid);
|
|
|
logger.info("sendMsg4quit inbox sms, uid {}, phone {}",
|
|
|
log.info("sendMsg4quit inbox sms, uid {}, phone {}",
|
|
|
uid, phone);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("endMsg4quit inbox sms fail cause of phone is empty, uid {} ", uid);
|
|
|
log.warn("endMsg4quit inbox sms fail cause of phone is empty, uid {} ", uid);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("sendMsg4quit inbox sms send end, uid {}, phone {}",
|
|
|
log.info("sendMsg4quit inbox sms send end, uid {}, phone {}",
|
|
|
uid, phone);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sendMsg4QuitEntrySeller error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sendMsg4QuitEntrySeller error inbox msg, sellerUid {}, prdName {} ",
|
|
|
uid, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1077,7 +1077,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
public void sendCancelledProductToSellerByCenter(int sellerUid,Long orderCode,SellerOrderGoods sog,String wayBillCode){
|
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
logger.info("record sendCancelledProductToSeller inbox sms msg,sellerUid {},orderCode {},sellerOrderGoods {}, wayBillCode {}",
|
|
|
log.info("record sendCancelledProductToSeller inbox sms msg,sellerUid {},orderCode {},sellerOrderGoods {}, wayBillCode {}",
|
|
|
sellerUid, orderCode,sog,wayBillCode);
|
|
|
String skupTypeText=SkupType.getSkupType(sog.getAttributes()).attrName();
|
|
|
String prdName = sog.getProductName();
|
...
|
...
|
@@ -1090,15 +1090,15 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO inBoxReq = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(inBoxReq);
|
|
|
logger.info("InBoxFacade sendCancelledProductToSeller inbox msg, sellerUid {},orderCode {},sellerOrderGoods {}, wayBillCode {},resp {}",
|
|
|
log.info("InBoxFacade sendCancelledProductToSeller inbox msg, sellerUid {},orderCode {},sellerOrderGoods {}, wayBillCode {},resp {}",
|
|
|
sellerUid, orderCode,sog,wayBillCode,resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
logger.info("sendCancelledProductToSeller wayBillCode sms send get phone {},sellerUid {}, wayBillCode {}",
|
|
|
log.info("sendCancelledProductToSeller wayBillCode sms send get phone {},sellerUid {}, wayBillCode {}",
|
|
|
phone,sellerUid,wayBillCode);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sendCancelledProductToSeller wayBillCode sms send fail cause of phone blank,sellerUid {}, wayBillCode {}",
|
|
|
log.warn("sendCancelledProductToSeller wayBillCode sms send fail cause of phone blank,sellerUid {}, wayBillCode {}",
|
|
|
sellerUid,wayBillCode);
|
|
|
return;
|
|
|
}
|
...
|
...
|
@@ -1107,11 +1107,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_CANCELED_BY_BUYER_AFTER_RECEIVED.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode,wayBillCode);
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sendCancelledProductToSeller inbox sms msg end,sellerUid {}, wayBillCode {}, phone {},",
|
|
|
log.info("record sendCancelledProductToSeller inbox sms msg end,sellerUid {}, wayBillCode {}, phone {},",
|
|
|
sellerUid, wayBillCode, phone);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sendCancelledProductToSeller error inbox msg, sellerUid {}, wayBillCode {} ",
|
|
|
log.warn("InBoxFacade sendCancelledProductToSeller error inbox msg, sellerUid {}, wayBillCode {} ",
|
|
|
sellerUid, wayBillCode, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1134,13 +1134,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerAppraiseUnsure_send_back inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {}, resp {}",
|
|
|
log.info("record sellerAppraiseUnsure_send_back inbox msg, SellerOrderGoods {} ,sellerUid {}, prdName {}, sizeName {}, resp {}",
|
|
|
JSON.toJSONString(sog),sellerUid, prdName, sizeName , resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("sellerAppraiseUnsure_send_back sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("sellerAppraiseUnsure_send_back sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1148,12 +1148,12 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String content = getReplacedContent(sms.getContent(),skupTypeText,prdName,sizeName,productCode,orderCode,wayBillCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerAppraiseUnsure_send_back inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
log.info("record sellerAppraiseUnsure_send_back inbox sms msg,sellerUid {}, prdName {},orderCode {}",
|
|
|
sellerUid, prdName,orderCode);
|
|
|
});
|
|
|
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerAppraiseUnsure_send_back error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("InBoxFacade sellerAppraiseUnsure_send_back error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1166,27 +1166,27 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
try {
|
|
|
executorService.execute(() -> {
|
|
|
// 发站内信
|
|
|
logger.info("record seller sham send out inbox sms msg for seller,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.info("record seller sham send out inbox sms msg for seller,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
Product product = productMapper.selectByPrimaryKey(sog.getProductId());
|
|
|
String productCode = product.getProductCode();
|
|
|
String params = buildParams(skupTypeText,prdName, sizeName,productCode);
|
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, InboxBusinessTypeEnum.NOTICE_SELLER_SELLER_SHAM_SEND_OUT);
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record seller sham send out inbox msg,sellerUid {}, prdName {},sizeName {} resp {}",
|
|
|
log.info("record seller sham send out inbox msg,sellerUid {}, prdName {},sizeName {} resp {}",
|
|
|
sellerUid, prdName, sizeName, resp);
|
|
|
// 发短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("seller sham send out sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("seller sham send out sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_SELLER_SELLER_SHAM_SEND_OUT.getContent(),skupTypeText,prdName,sizeName,productCode);
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("seller sham send out msg,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.info("seller sham send out msg,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSellerOfSellerShamSendOut error inbox msg, sellerUid {}, prdName {} ", sellerUid, prdName, e);
|
|
|
log.warn("InBoxFacade noticeSellerOfSellerShamSendOut error inbox msg, sellerUid {}, prdName {} ", sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1199,25 +1199,25 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String smsContent = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_BUYER_SELLER_SHAM_SEND_OUT.getContent(), orderCode);
|
|
|
try {
|
|
|
logger.info("noticeBuyerOfSellerShamSendOut,uid {} request is {}", uid, request);
|
|
|
log.info("noticeBuyerOfSellerShamSendOut,uid {} request is {}", uid, request);
|
|
|
executorService.execute(() -> {
|
|
|
InBoxResponse inBoxResponse = inBoxSDK.addInbox(inboxMessage);
|
|
|
logger.info("noticeBuyerOfSellerShamSendOut inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
log.info("noticeBuyerOfSellerShamSendOut inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.sellerFalseDeliver(String.valueOf(uid),String.valueOf(orderCode));
|
|
|
logger.info("record noticeBuyerOfSellerShamSendOut push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record noticeBuyerOfSellerShamSendOut push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
logger.warn("noticeBuyerOfSellerShamSendOut sms send fail,uid {} can not find phone", uid);
|
|
|
log.warn("noticeBuyerOfSellerShamSendOut sms send fail,uid {} can not find phone", uid);
|
|
|
return;
|
|
|
}
|
|
|
sendSmsService.smsSendByMobile(smsContent, Arrays.asList(phone));
|
|
|
logger.info("noticeBuyerOfSellerShamSendOut sms send success,uid {}", uid);
|
|
|
log.info("noticeBuyerOfSellerShamSendOut sms send success,uid {}", uid);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("noticeBuyerOfSellerShamSendOut fail,uid {}", uid, e);
|
|
|
log.warn("noticeBuyerOfSellerShamSendOut fail,uid {}", uid, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1230,25 +1230,25 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String smsContent = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_BUYER_SELLER_SEND_OUT_TIMEOUT.getContent(), orderCode);
|
|
|
try {
|
|
|
logger.info("noticeBuyerOfSellerSendOutTimeout,uid {} request is {}", uid, request);
|
|
|
log.info("noticeBuyerOfSellerSendOutTimeout,uid {} request is {}", uid, request);
|
|
|
executorService.execute(() -> {
|
|
|
InBoxResponse inBoxResponse = inBoxSDK.addInbox(inboxMessage);
|
|
|
logger.info("noticeBuyerOfSellerSendOutTimeout inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
log.info("noticeBuyerOfSellerSendOutTimeout inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.sellerDeliverHours(String.valueOf(uid),String.valueOf(orderCode));
|
|
|
logger.info("record noticeBuyerOfSellerSendOutTimeout push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record noticeBuyerOfSellerSendOutTimeout push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
logger.warn("noticeBuyerOfSellerSendOutTimeout sms send fail,uid {} can not find phone", uid);
|
|
|
log.warn("noticeBuyerOfSellerSendOutTimeout sms send fail,uid {} can not find phone", uid);
|
|
|
return;
|
|
|
}
|
|
|
sendSmsService.smsSendByMobile(smsContent, Arrays.asList(phone));
|
|
|
logger.info("noticeBuyerOfSellerSendOutTimeout sms send success,uid {}", uid);
|
|
|
log.info("noticeBuyerOfSellerSendOutTimeout sms send success,uid {}", uid);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("noticeBuyerOfSellerSendOutTimeout fail,uid {}", uid, e);
|
|
|
log.warn("noticeBuyerOfSellerSendOutTimeout fail,uid {}", uid, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1263,26 +1263,26 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO inboxMessage = buildInboxReqVO(uid, params, InboxBusinessTypeEnum.NOTICE_BUYER_WHEN_APPRAISE_UNSURE);
|
|
|
String smsContent = getReplacedContent(InboxBusinessTypeEnum.SMS_NOTICE_BUYER_WHEN_APPRAISE_UNSURE.getContent(), orderCode);
|
|
|
try {
|
|
|
logger.info("noticeBuyerAppraiseUnsure,uid {} request is {}", uid, request);
|
|
|
log.info("noticeBuyerAppraiseUnsure,uid {} request is {}", uid, request);
|
|
|
executorService.execute(() -> {
|
|
|
InBoxResponse inBoxResponse = inBoxSDK.addInbox(inboxMessage);
|
|
|
logger.info("noticeBuyerAppraiseUnsure inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
log.info("noticeBuyerAppraiseUnsure inbox send success, message is {} res is {}", inboxMessage, inBoxResponse);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.identifyFail(String.valueOf(uid),String.valueOf(orderCode));
|
|
|
logger.info("noticeBuyerAppraiseUnsure push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("noticeBuyerAppraiseUnsure push buyer uid is {}, orderCode is {}, result is {}", uid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
//sms
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
logger.warn("noticeBuyerAppraiseUnsure sms send fail,uid {} can not find phone", uid);
|
|
|
log.warn("noticeBuyerAppraiseUnsure sms send fail,uid {} can not find phone", uid);
|
|
|
return;
|
|
|
}
|
|
|
sendSmsService.smsSendByMobile(smsContent, Arrays.asList(phone));
|
|
|
logger.info("noticeBuyerAppraiseUnsure sms send success,uid {}", uid);
|
|
|
log.info("noticeBuyerAppraiseUnsure sms send success,uid {}", uid);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("noticeBuyerAppraiseUnsure fail,uid {}", uid, e);
|
|
|
log.warn("noticeBuyerAppraiseUnsure fail,uid {}", uid, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1312,27 +1312,27 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
return;
|
|
|
}
|
|
|
executorService.execute(() -> {
|
|
|
logger.info("record sellerDeliverNotice inbox sms msg,sellerUid {},orderCode {}, prdName {}, times {}",
|
|
|
log.info("record sellerDeliverNotice inbox sms msg,sellerUid {},orderCode {}, prdName {}, times {}",
|
|
|
sellerUid,orderCode, prdName, times);
|
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record sellerDeliverNotice inbox msg,sellerUid {}, orderCode {} ,prdName {},sizeName {} times {},resp {}",
|
|
|
log.info("record sellerDeliverNotice inbox msg,sellerUid {}, orderCode {} ,prdName {},sizeName {} times {},resp {}",
|
|
|
sellerUid,orderCode, prdName, sizeName, times, resp);
|
|
|
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("times {},sellerDeliverNotice sms send fail,sellerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("times {},sellerDeliverNotice sms send fail,sellerUid {}, orderCode {} ,prdName {}",
|
|
|
times, sellerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("record sellerDeliverNotice inbox sms msg,sellerUid {},orderCode, prdName {}, times {},resp {}",
|
|
|
log.info("record sellerDeliverNotice inbox sms msg,sellerUid {},orderCode, prdName {}, times {},resp {}",
|
|
|
sellerUid, orderCode,prdName, times);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade sellerDeliverNotice error inbox msg, sellerUid {}, orderCode,prdName {} ",
|
|
|
log.warn("InBoxFacade sellerDeliverNotice error inbox msg, sellerUid {}, orderCode,prdName {} ",
|
|
|
sellerUid,orderCode, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1358,25 +1358,25 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
|
|
|
|
|
|
logger.info("noticeSellerAppraiseUnsure inbox sms msg,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.info("noticeSellerAppraiseUnsure inbox sms msg,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("noticeSellerAppraiseUnsure inbox msg,sellerUid {}, prdName {},sizeName {},resp {}",
|
|
|
log.info("noticeSellerAppraiseUnsure inbox msg,sellerUid {}, prdName {},sizeName {},resp {}",
|
|
|
sellerUid, prdName, sizeName, resp);
|
|
|
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
logger.warn("noticeSellerAppraiseUnsure sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
log.warn("noticeSellerAppraiseUnsure sms send fail,sellerUid {}, prdName {}", sellerUid, prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
logger.info("noticeSellerAppraiseUnsure inbox sms msg,sellerUid {}, prdName {},resp {}",
|
|
|
log.info("noticeSellerAppraiseUnsure inbox sms msg,sellerUid {}, prdName {},resp {}",
|
|
|
sellerUid, prdName, resp);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("noticeSellerAppraiseUnsure error inbox msg, sellerUid {}, prdName {} ",
|
|
|
log.warn("noticeSellerAppraiseUnsure error inbox msg, sellerUid {}, prdName {} ",
|
|
|
sellerUid, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1397,36 +1397,36 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerCancelBeforeDepotReceive to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record buyerCancelBeforeDepotReceive to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
//seller
|
|
|
InboxBusinessTypeEnum ibtOfSeller = InboxBusinessTypeEnum.SALE_CLOSED_BY_BUYER_AFTER_DELIVERY;
|
|
|
String paramsOfSeller = buildParams(skupTypeText,prdName, sizeName,productCode);
|
|
|
InboxReqVO reqOfSeller = buildInboxReqVO(sellerUid, paramsOfSeller, ibtOfSeller);
|
|
|
InBoxResponse respOfSeller = inBoxSDK.addInbox(reqOfSeller);
|
|
|
logger.info("record buyerCancelBeforeDepotReceive to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record buyerCancelBeforeDepotReceive to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
sellerUid, orderCode, prdName, respOfSeller);
|
|
|
|
|
|
//发push,通知卖家
|
|
|
SendMessageRspBo bo = ufoSendService.buyerCancelSend(String.valueOf(sellerUid),String.valueOf(orderCode),prdName, sizeName,productCode);
|
|
|
logger.info("record buyerCancelBeforeDepotReceive push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record buyerCancelBeforeDepotReceive push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in buyerCancelBeforeDepotReceive sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in buyerCancelBeforeDepotReceive sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
|
|
|
String content= getReplacedContent(InboxBusinessTypeEnum.SMS_CANCELED_BY_BUYER_AFTER_DELIVERY.getContent(),skupTypeText,prdName, sizeName,productCode,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record buyerCancelBeforeDepotReceive inbox sms msg, sellerUid {}, orderCode {},prdName {}",
|
|
|
log.info("record buyerCancelBeforeDepotReceive inbox sms msg, sellerUid {}, orderCode {},prdName {}",
|
|
|
sellerUid, orderCode, prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerCancelBeforeDepotReceive error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("InBoxFacade buyerCancelBeforeDepotReceive error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
buyerUid, orderCode, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1455,18 +1455,18 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(sellerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeSellerWhenBuyerCancelNoResponsibility to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeSellerWhenBuyerCancelNoResponsibility to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
sellerUid, orderCode,prdName, resp);
|
|
|
|
|
|
//发push
|
|
|
SendMessageRspBo bo = ufoSendService.buyerCancelBooking(String.valueOf(sellerUid),String.valueOf(orderCode),prdName, sizeName,productCode);
|
|
|
logger.info("record noticeSellerWhenBuyerCancelNoResponsibility push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record noticeSellerWhenBuyerCancelNoResponsibility push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeSellerWhenBuyerCancelNoResponsibility sms fail, sellerUid {} orderCode {} prdName {}", sellerUid, orderCode,prdName);
|
|
|
log.warn("in noticeSellerWhenBuyerCancelNoResponsibility sms fail, sellerUid {} orderCode {} prdName {}", sellerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1477,11 +1477,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content = buildSmsContent(sms, orderCode,skupTypeText, prdName,sizeName,productCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeSellerWhenBuyerCancelNoResponsibility inbox sms msg, sellerUid {}, orderCode {},prdName {}",
|
|
|
log.info("record noticeSellerWhenBuyerCancelNoResponsibility inbox sms msg, sellerUid {}, orderCode {},prdName {}",
|
|
|
sellerUid, orderCode, prdName);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSellerWhenBuyerCancelNoResponsibility error inbox msg, sellerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("InBoxFacade noticeSellerWhenBuyerCancelNoResponsibility error inbox msg, sellerUid {}, orderCode {} ,prdName {}",
|
|
|
sellerUid, orderCode, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1498,7 +1498,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record buyerCancelBeforeSellerDeliver to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record buyerCancelBeforeSellerDeliver to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
//seller
|
|
|
Product product = productMapper.selectByPrimaryKey(sog.getProductId());
|
...
|
...
|
@@ -1510,18 +1510,18 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
String paramsOfSeller = buildParams(skupTypeText,prdName, sizeName,productCode);
|
|
|
InboxReqVO reqOfSeller = buildInboxReqVO(sellerUid, paramsOfSeller, ibtOfSeller);
|
|
|
InBoxResponse respOfSeller = inBoxSDK.addInbox(reqOfSeller);
|
|
|
logger.info("record buyerCancelBeforeSellerDeliver to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record buyerCancelBeforeSellerDeliver to seller inbox msg, sellerUid {}, orderCode {},prdName {} resp {}",
|
|
|
sellerUid, orderCode, prdName, respOfSeller);
|
|
|
|
|
|
//发push ,给卖家
|
|
|
SendMessageRspBo bo = ufoSendService.buyerCancel(String.valueOf(sellerUid),String.valueOf(orderCode),prdName, sizeName,productCode);
|
|
|
logger.info("record buyerCancelBeforeSellerDeliver push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
log.info("record buyerCancelBeforeSellerDeliver push seller uid is {}, orderCode is {}, result is {}", sellerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in buyerCancelBeforeSellerDeliver sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in buyerCancelBeforeSellerDeliver sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1532,11 +1532,11 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
}
|
|
|
String content= getReplacedContent(sms.getContent(),orderCode,skupTypeText,prdName,sizeName,productCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record buyerCancelBeforeSellerDeliver inbox sms msg, sellerUid {}, orderCode {},prdName {} ,sizeName {} ,productCode {}",
|
|
|
log.info("record buyerCancelBeforeSellerDeliver inbox sms msg, sellerUid {}, orderCode {},prdName {} ,sizeName {} ,productCode {}",
|
|
|
sellerUid, orderCode, prdName,sizeName,productCode);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade buyerCancelBeforeSellerDeliver error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
log.warn("InBoxFacade buyerCancelBeforeSellerDeliver error inbox msg, buyerUid {}, orderCode {} ,prdName {}",
|
|
|
buyerUid, orderCode, prdName, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1557,7 +1557,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
break;
|
|
|
}
|
|
|
if (smsIBT == null || inboxIBT == null ){
|
|
|
logger.warn("in noticeSuperSellerDegrade not match send condition, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
log.warn("in noticeSuperSellerDegrade not match send condition, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
uid, sesl, leftInWallet);
|
|
|
return;
|
|
|
}
|
...
|
...
|
@@ -1565,23 +1565,23 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(uid, params, inboxIBT);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeSuperSellerDegrade to super seller inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {} resp {}",
|
|
|
log.info("record noticeSuperSellerDegrade to super seller inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {} resp {}",
|
|
|
uid, sesl, leftInWallet, resp);
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeSuperSellerDegrade sms fail, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
log.warn("in noticeSuperSellerDegrade sms fail, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
uid, sesl, leftInWallet);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(smsIBT.getContent(), leftInWallet);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeSuperSellerDegrade inbox sms msg, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
log.info("record noticeSuperSellerDegrade inbox sms msg, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
uid, sesl, leftInWallet);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeSuperSellerDegrade error inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
log.warn("InBoxFacade noticeSuperSellerDegrade error inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {}",
|
|
|
uid, sesl, leftInWallet, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1602,25 +1602,25 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
break;
|
|
|
}
|
|
|
if (smsIBT == null){
|
|
|
logger.warn("in noticeLargeSettlementSuperDegrade not match send condition, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
log.warn("in noticeLargeSettlementSuperDegrade not match send condition, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
uid, sesl, leftInWallet, threshold);
|
|
|
return;
|
|
|
}
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeLargeSettlementSuperDegrade sms fail, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold{}",
|
|
|
log.warn("in noticeLargeSettlementSuperDegrade sms fail, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold{}",
|
|
|
uid, sesl, leftInWallet, threshold);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content = getReplacedContent(smsIBT.getContent(), threshold);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeLargeSettlementSuperDegrade inbox sms msg, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
log.info("record noticeLargeSettlementSuperDegrade inbox sms msg, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
uid, sesl, leftInWallet, threshold);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade noticeLargeSettlementSuperDegrade error inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
log.warn("InBoxFacade noticeLargeSettlementSuperDegrade error inbox msg, uid {}, SuperEnterStageLevel {},leftInWallet {} threshold {}",
|
|
|
uid, sesl, leftInWallet,threshold, e);
|
|
|
}
|
|
|
}
|
...
|
...
|
@@ -1630,7 +1630,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
executorService.execute(task);
|
|
|
}catch (Exception ex){
|
|
|
|
|
|
logger.warn(logModule, logParms, ex);
|
|
|
log.warn(logModule, logParms, ex);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
@@ -1644,13 +1644,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeWhenBuyerBlownCustomsClearance to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeWhenBuyerBlownCustomsClearance to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeWhenBuyerBlownCustomsClearance sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in noticeWhenBuyerBlownCustomsClearance sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1659,7 +1659,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String content= getReplacedContent(sms.getContent(),prdName,sizeName,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeWhenBuyerBlownCustomsClearance inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
log.info("record noticeWhenBuyerBlownCustomsClearance inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
buyerUid, orderCode, prdName,sizeName);
|
|
|
};
|
|
|
String logModule = "InBoxFacade noticeWhenBuyerBlownCustomsClearance error inbox msg, buyerUid {}, orderCode {} ,prdName {}";
|
...
|
...
|
@@ -1678,13 +1678,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeWhenQuickDeliverOrderPaid to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeWhenQuickDeliverOrderPaid to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeWhenQuickDeliverOrderPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in noticeWhenQuickDeliverOrderPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1693,7 +1693,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String content= getReplacedContent(sms.getContent(),prdName,sizeName,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeWhenQuickDeliverOrderPaid inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
log.info("record noticeWhenQuickDeliverOrderPaid inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
buyerUid, orderCode, prdName,sizeName);
|
|
|
};
|
|
|
String logModule = "InBoxFacade noticeWhenQuickDeliverOrderPaid error inbox msg, buyerUid {}, orderCode {} ,prdName {}";
|
...
|
...
|
@@ -1713,13 +1713,13 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
InboxReqVO req = buildInboxReqVO(buyerUid, params, ibt);
|
|
|
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
logger.info("record noticeWhenDepositOrderOfPaid to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
log.info("record noticeWhenDepositOrderOfPaid to buyer inbox msg, buyerUid {}, orderCode {},prdName {} resp {}",
|
|
|
buyerUid, orderCode,prdName, resp);
|
|
|
|
|
|
//短信
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in noticeWhenDepositOrderOfPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
log.warn("in noticeWhenDepositOrderOfPaid sms fail, buyerUid {} orderCode {} prdName {}", buyerUid, orderCode,prdName);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
...
|
...
|
@@ -1728,7 +1728,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
|
|
|
String content= getReplacedContent(sms.getContent(),prdName,sizeName,orderCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record noticeWhenDepositOrderOfPaid inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
log.info("record noticeWhenDepositOrderOfPaid inbox sms msg, buyer Uid {}, orderCode {},prdName {} ,sizeName {} ",
|
|
|
buyerUid, orderCode, prdName,sizeName);
|
|
|
};
|
|
|
String logModule = "InBoxFacade noticeWhenDepositOrderOfPaid error inbox msg, buyerUid {}, orderCode {} ,prdName {}";
|
...
|
...
|
@@ -1741,7 +1741,7 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
// 召回的
|
|
|
public void recallDepositnotify(int uid, SellerOrderGoods sog) {
|
|
|
if (null == sog) {
|
|
|
logger.warn("InBoxFacade recallDepositnotify error SellerOrderGoods is null, uid {}", uid);
|
|
|
log.warn("InBoxFacade recallDepositnotify error SellerOrderGoods is null, uid {}", uid);
|
|
|
return;
|
|
|
}
|
|
|
String prdName = sog.getProductName();
|
...
|
...
|
@@ -1755,21 +1755,21 @@ public class InBoxFacade extends BaseNoticeFacade{ |
|
|
String paramsOfSeller = buildParams(prdName, sizeName,productCode);
|
|
|
InboxReqVO reqOfSeller = buildInboxReqVO(uid, paramsOfSeller, ibtOfSeller);
|
|
|
InBoxResponse respOfSeller = inBoxSDK.addInbox(reqOfSeller);
|
|
|
logger.info("record recallDepositnotify to seller inbox msg, uid {}, sog {} resp {}",
|
|
|
log.info("record recallDepositnotify to seller inbox msg, uid {}, sog {} resp {}",
|
|
|
uid, sog, respOfSeller);
|
|
|
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
if (StringUtils.isBlank(phone)){
|
|
|
logger.warn("in recallDepositnotify sms fail, uid {} sog {}", uid, sog);
|
|
|
log.warn("in recallDepositnotify sms fail, uid {} sog {}", uid, sog);
|
|
|
return;
|
|
|
}
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
String content= getReplacedContent(InboxBusinessTypeEnum.SMS_NOTIFY_SELLER_DEPOSIT_RECALL.getContent(),prdName, sizeName, productCode);
|
|
|
sendSmsService.smsSendByMobile(content,mobileList);
|
|
|
logger.info("record recallDepositnotify inbox sms msg, uid {}, sog {}", uid, sog);
|
|
|
log.info("record recallDepositnotify inbox sms msg, uid {}, sog {}", uid, sog);
|
|
|
});
|
|
|
} catch (Exception e) {
|
|
|
logger.warn("InBoxFacade recallDepositnotify error inbox msg, uid {}, sog {}", uid, sog, e);
|
|
|
log.warn("InBoxFacade recallDepositnotify error inbox msg, uid {}, sog {}", uid, sog, e);
|
|
|
}
|
|
|
}
|
|
|
|
...
|
...
|
|