|
@@ -6,12 +6,15 @@ import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
import com.fasterxml.jackson.databind.node.ObjectNode;
|
|
|
import com.miaxis.common.config.WxpayConfig;
|
|
|
import com.miaxis.common.exception.CustomException;
|
|
|
+import com.miaxis.order.domain.OrderInfo;
|
|
|
+import com.miaxis.order.service.IOrderInfoService;
|
|
|
import com.miaxis.wx.domain.RefundRecord;
|
|
|
import com.miaxis.wx.domain.WxJsOrder;
|
|
|
import com.miaxis.wx.dto.WxNotifyReturnDTO;
|
|
|
import com.miaxis.wx.mapper.RefundRecordMapper;
|
|
|
import com.miaxis.wx.mapper.WxJsOrderMapper;
|
|
|
import com.miaxis.wx.service.IRefundRecordService;
|
|
|
+import lombok.extern.slf4j.Slf4j;
|
|
|
import org.apache.http.HttpResponse;
|
|
|
import org.apache.http.HttpStatus;
|
|
|
import org.apache.http.client.HttpClient;
|
|
@@ -32,6 +35,7 @@ import java.util.List;
|
|
|
* @date 2021-05-18
|
|
|
*/
|
|
|
@Service
|
|
|
+@Slf4j
|
|
|
public class RefundRecordServiceImpl extends ServiceImpl<RefundRecordMapper, RefundRecord> implements IRefundRecordService {
|
|
|
@Resource
|
|
|
private RefundRecordMapper refundRecordMapper;
|
|
@@ -39,6 +43,9 @@ public class RefundRecordServiceImpl extends ServiceImpl<RefundRecordMapper, Ref
|
|
|
@Resource
|
|
|
private WxJsOrderMapper wxJsOrderMapper;
|
|
|
|
|
|
+ @Autowired
|
|
|
+ private IOrderInfoService orderInfoService;
|
|
|
+
|
|
|
@Autowired
|
|
|
private HttpClient httpClient;
|
|
|
|
|
@@ -81,10 +88,17 @@ public class RefundRecordServiceImpl extends ServiceImpl<RefundRecordMapper, Ref
|
|
|
// 返回数据:
|
|
|
String bodyAsString = EntityUtils.toString(response.getEntity());
|
|
|
if(response.getStatusLine().getStatusCode() == HttpStatus.SC_OK){
|
|
|
+ log.info("退款成功,订单号:"+wxJsOrder);
|
|
|
//更新这个字段
|
|
|
wxJsOrder.setOutRefundNo(refundCode);
|
|
|
wxJsOrder.setRefundReason(failCause);
|
|
|
+ wxJsOrder.setTradeType("3");
|
|
|
wxJsOrderMapper.updateById(wxJsOrder);
|
|
|
+ OrderInfo orderInfo = orderInfoService.getByOutTradeNo(wxJsOrder.getOutTradeNo());
|
|
|
+ orderInfo.setOutRefundNo(refundCode);
|
|
|
+ orderInfo.setTradeType(3);
|
|
|
+ orderInfoService.updateById(orderInfo);
|
|
|
+
|
|
|
|
|
|
// 保存退款数据到数据库
|
|
|
RefundRecord refundRecord = new RefundRecord();
|