|
...
|
...
|
@@ -81,6 +81,10 @@ public class InBoxFacade { |
|
|
|
InBoxResponse resp = inBoxSDK.addInbox(req);
|
|
|
|
logger.info("record buyerOrderNotPayed inbox msg, buyerUid {}, orderCode {}, resp {}",
|
|
|
|
buyerUid, orderCode, resp);
|
|
|
|
|
|
|
|
//push
|
|
|
|
SendMessageRspBo bo = ufoSendService.buyerNotPay(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
|
logger.info("record buyerOrderNotPayed push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
});
|
|
|
|
} catch (Exception e) {
|
|
|
|
logger.warn("InBoxFacade buyerOrderNotPayed error inbox msg, buyerUid {}, orderCode {} ",
|
|
...
|
...
|
@@ -132,6 +136,10 @@ public class InBoxFacade { |
|
|
|
Product product = productMapper.selectByPrimaryKey(psog.getProductId());
|
|
|
|
String productCode = product.getProductCode();
|
|
|
|
|
|
|
|
//发push
|
|
|
|
SendMessageRspBo bo = ufoSendService.sellerDeliverNotice(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
|
logger.info("record sellerDeliver2Depot push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
//sms
|
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
|
if (StringUtils.isBlank(phone)){
|
|
...
|
...
|
@@ -176,6 +184,11 @@ public class InBoxFacade { |
|
|
|
logger.info("record noticeBuyerWhenDeliveryGoodsToBuyer inbox msg, buyerUid {}, orderCode {}, prdName {},SellerOrderGoods {} resp {}",
|
|
|
|
buyerUid, orderCode, prdName, JSON.toJSONString(psog), resp);
|
|
|
|
|
|
|
|
//发push
|
|
|
|
SendMessageRspBo bo = ufoSendService.platformDeliverBuyer(String.valueOf(buyerUid),String.valueOf(orderCode));
|
|
|
|
logger.info("record noticeBuyerWhenDeliveryGoodsToBuyer push buyer uid is {}, orderCode is {}, result is {}", buyerUid, orderCode, JSON.toJSONString(bo));
|
|
|
|
|
|
|
|
|
|
|
|
//seller notice
|
|
|
|
|
|
|
|
|
|
...
|
...
|
@@ -519,6 +532,13 @@ public class InBoxFacade { |
|
|
|
logger.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));
|
|
|
|
}
|
|
|
|
|
|
|
|
//短信
|
|
|
|
String phone = userProxyService.getMobile(buyerUid);
|
|
|
|
if (StringUtils.isBlank(phone)){
|
|
...
|
...
|
@@ -1162,11 +1182,11 @@ public class InBoxFacade { |
|
|
|
/**
|
|
|
|
* 鉴定中心把 买家取消（卖家已发货给中心）的物品，顺丰到付寄给卖家
|
|
|
|
*/
|
|
|
|
public void sendCancelledProductToSellerByCenter(int sellerUid,String wayBillCode){
|
|
|
|
public void sendCancelledProductToSellerByCenter(int sellerUid,Long orderCode,SellerOrderGoods sog,String wayBillCode){
|
|
|
|
try {
|
|
|
|
executorService.execute(() -> {
|
|
|
|
logger.info("record sendCancelledProductToSeller inbox sms msg,sellerUid {}, wayBillCode {}",
|
|
|
|
sellerUid, wayBillCode);
|
|
|
|
logger.info("record sendCancelledProductToSeller inbox sms msg,sellerUid {},orderCode {},sellerOrderGoods {}, wayBillCode {}",
|
|
|
|
sellerUid, orderCode,sog,wayBillCode);
|
|
|
|
|
|
|
|
String phone = userProxyService.getMobile(sellerUid);
|
|
|
|
logger.info("sendCancelledProductToSeller wayBillCode sms send get phone {},sellerUid {}, wayBillCode {}",
|
|
...
|
...
|
@@ -1176,8 +1196,12 @@ public class InBoxFacade { |
|
|
|
sellerUid,wayBillCode);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
String prdName = sog.getProductName();
|
|
|
|
String sizeName = sog.getSizeName();
|
|
|
|
Product product = productMapper.selectByPrimaryKey(sog.getProductId());
|
|
|
|
String productCode = product.getProductCode();
|
|
|
|
List<String> mobileList = Arrays.asList(phone);
|
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_CANCELED_BY_BUYER_AFTER_RECEIVED.getContent(),wayBillCode);
|
|
|
|
String content = getReplacedContent(InboxBusinessTypeEnum.SMS_CANCELED_BY_BUYER_AFTER_RECEIVED.getContent(),prdName,sizeName,productCode,orderCode,wayBillCode);
|
|
|
|
|
|
|
|
sendSmsService.smsSendByMobile(content, mobileList);
|
|
|
|
logger.info("record sendCancelledProductToSeller inbox sms msg end,sellerUid {}, wayBillCode {}, phone {},",
|
|
...
|
...
|
@@ -1274,6 +1298,11 @@ public class InBoxFacade { |
|
|
|
executorService.execute(() -> {
|
|
|
|
InBoxResponse inBoxResponse = inBoxSDK.addInbox(inboxMessage);
|
|
|
|
logger.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));
|
|
|
|
|
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
|
logger.warn("noticeBuyerOfSellerShamSendOut sms send fail,uid {} can not find phone", uid);
|
|
...
|
...
|
@@ -1300,6 +1329,11 @@ public class InBoxFacade { |
|
|
|
executorService.execute(() -> {
|
|
|
|
InBoxResponse inBoxResponse = inBoxSDK.addInbox(inboxMessage);
|
|
|
|
logger.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));
|
|
|
|
|
|
|
|
String phone = userProxyService.getMobile(uid);
|
|
|
|
if (StringUtils.isBlank(phone)) {
|
|
|
|
logger.warn("noticeBuyerOfSellerSendOutTimeout sms send fail,uid {} can not find phone", uid);
|
...
|
...
|
|
