package com.xiaopeng.order.utils;
|
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpResponse;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson2.JSON;
|
import com.xiaopeng.api.dto.account.UcUserInfo;
|
import com.xiaopeng.api.feignClient.account.UserResourcesClient;
|
import com.xiaopeng.api.feignClient.operation.XpOfficialPartnerClient;
|
import com.xiaopeng.api.model.operation.XpOfficialPartner;
|
import com.xiaopeng.api.model.order.XpOrder;
|
import com.xiaopeng.api.model.order.XpOrderCancel;
|
import com.xiaopeng.api.vo.operation.OfficialPartnerResult;
|
import com.xiaopeng.common.core.domain.R;
|
import com.xiaopeng.common.core.exception.ServiceException;
|
import com.xiaopeng.order.vo.CancelOrderVo;
|
import com.xiaopeng.order.vo.CloseOrderVo;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.time.LocalDateTime;
|
import java.time.format.DateTimeFormatter;
|
|
/**
|
* 合作商工具类
|
*/
|
@Component
|
public class OfficialPartnerUtil {
|
|
@Resource
|
private XpOfficialPartnerClient xpOfficialPartnerClient;
|
|
|
/**
|
* 推送取消订单
|
* @param officialPartnerId
|
* @param orderCancel
|
* @return
|
*/
|
public R<?> pushCancelOrder(Integer officialPartnerId, XpOrderCancel orderCancel, Integer status) {
|
XpOfficialPartner xpOfficialPartner = xpOfficialPartnerClient.getOfficialPartner(officialPartnerId).getData();
|
String cancelOrderUrl = xpOfficialPartner.getCancelOrderUrl();
|
HttpRequest post = HttpUtil.createPost(cancelOrderUrl);
|
CancelOrderVo cancelOrderVo = buildCancelOrder(orderCancel, status);
|
post.body(JSON.toJSONString(cancelOrderVo));
|
HttpResponse execute = post.execute();
|
if(!execute.isOk()){
|
throw new ServiceException("[" + xpOfficialPartner.getName() + "]调用合作商接口失败-取消订单接口");
|
}
|
OfficialPartnerResult officialPartnerResult = JSON.parseObject(execute.body(), OfficialPartnerResult.class);
|
if(0 == officialPartnerResult.getCode()){
|
return R.ok();
|
}
|
throw new ServiceException("[" + xpOfficialPartner.getName() + "]" + officialPartnerResult.getMsg());
|
}
|
|
|
|
private CancelOrderVo buildCancelOrder(XpOrderCancel xpOrder, Integer status){
|
CancelOrderVo vo = new CancelOrderVo();
|
vo.setOrderId(xpOrder.getOrderId());
|
vo.setCancelReason(xpOrder.getCancelReason());
|
vo.setCancelSource(xpOrder.getCancelSource());
|
vo.setCancelTime(xpOrder.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
vo.setStatus(status);
|
return vo;
|
}
|
|
|
/**
|
* 推送结束订单
|
* @param officialPartnerId
|
* @param xpOrder
|
* @param closeReason
|
* @return
|
*/
|
public R<?> pushEndOrder(Integer officialPartnerId, XpOrder xpOrder, String closeReason){
|
XpOfficialPartner xpOfficialPartner = xpOfficialPartnerClient.getOfficialPartner(officialPartnerId).getData();
|
String closeOrderUrl = xpOfficialPartner.getCloseOrderUrl();
|
HttpRequest post = HttpUtil.createPost(closeOrderUrl);
|
CloseOrderVo closeOrderVo = new CloseOrderVo();
|
closeOrderVo.setOrderId(xpOrder.getId());
|
closeOrderVo.setCloseReason("closeReason");
|
closeOrderVo.setCloseTime(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
|
closeOrderVo.setStatus(xpOrder.getStatus());
|
post.body(JSON.toJSONString(closeOrderVo));
|
HttpResponse execute = post.execute();
|
if(!execute.isOk()){
|
throw new ServiceException("[" + xpOfficialPartner.getName() + "]调用合作商接口失败-取消订单接口");
|
}
|
OfficialPartnerResult officialPartnerResult = JSON.parseObject(execute.body(), OfficialPartnerResult.class);
|
if(0 == officialPartnerResult.getCode()){
|
return R.ok();
|
}
|
throw new ServiceException("[" + xpOfficialPartner.getName() + "]" + officialPartnerResult.getMsg());
|
}
|
}
|
