提交第三方接口订单同步功能

bms-back/ruoyi-admin/src/main/java/com/ruoyi/web/controller/api/TmsPriceController.java

@@ -2,10 +2,13 @@ package com.ruoyi.web.controller.api;
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestHeader;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 import com.ruoyi.common.annotation.Anonymous;
 import com.ruoyi.common.core.controller.BaseController;
@@ -13,8 +16,10 @@ import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.exception.ServiceException;
 import com.ruoyi.common.utils.StringUtils;
 import com.ruoyi.framework.config.properties.TmsApiProperties;
+import com.ruoyi.price.domain.vo.TmsPriceBillRequest;
 import com.ruoyi.price.domain.vo.TmsPriceQuoteRequest;
 import com.ruoyi.price.domain.vo.TmsPriceQuoteResult;
+import com.ruoyi.price.service.IPrcBillService;
 import com.ruoyi.price.service.ITmsPriceQuoteService;
 
 /**
@@ -35,6 +40,9 @@ public class TmsPriceController extends BaseController
     @Autowired
     private ITmsPriceQuoteService tmsPriceQuoteService;
 
+    @Autowired
+    private IPrcBillService prcBillService;
+
     @Autowired
     private TmsApiProperties tmsApiProperties;
 
@@ -52,6 +60,33 @@ public class TmsPriceController extends BaseController
         return success(result);
     }
 
+    /**
+     * Sync order and persist receivable bill (prc_bill / prc_bill_fee).
+     * Same price match as quote. Same orderNo upserts.
+     */
+    @PostMapping("/bill")
+    public AjaxResult bill(
+        @RequestHeader(value = HEADER_API_CODE, required = false) String headerApiCode,
+        @Validated @RequestBody TmsPriceBillRequest request)
+    {
+        assertApiCode(headerApiCode, request == null ? null : request.getApiCode());
+        TmsPriceQuoteResult result = prcBillService.bill(request);
+        return success(result);
+    }
+
+    /**
+     * Query receivable bill by orderNo after sync.
+     */
+    @GetMapping("/bill/by-order/{orderNo}")
+    public AjaxResult getBillByOrder(
+        @RequestHeader(value = HEADER_API_CODE, required = false) String headerApiCode,
+        @PathVariable("orderNo") String orderNo,
+        @RequestParam(value = "apiCode", required = false) String apiCode)
+    {
+        assertApiCode(headerApiCode, apiCode);
+        return success(prcBillService.getBillByOrderNo(orderNo));
+    }
+
     private void assertApiCode(String headerApiCode, String bodyApiCode)
     {
         String expected = tmsApiProperties.getApiCode();

bms-back/ruoyi-admin/src/main/java/com/ruoyi/web/controller/price/BillingController.java

@@ -13,9 +13,12 @@ import org.springframework.web.bind.annotation.RestController;
 import com.ruoyi.common.core.controller.BaseController;
 import com.ruoyi.common.core.domain.AjaxResult;
 import com.ruoyi.common.core.page.TableDataInfo;
+import com.ruoyi.price.domain.PrcBill;
 import com.ruoyi.price.domain.PrcQuote;
+import com.ruoyi.price.domain.vo.TmsPriceBillRequest;
 import com.ruoyi.price.domain.vo.TmsPriceQuoteRequest;
 import com.ruoyi.price.domain.vo.TmsPriceQuoteResult;
+import com.ruoyi.price.service.IPrcBillService;
 import com.ruoyi.price.service.ITmsPriceQuoteService;
 
 /**
@@ -30,6 +33,9 @@ public class BillingController extends BaseController
     @Autowired
     private ITmsPriceQuoteService tmsPriceQuoteService;
 
+    @Autowired
+    private IPrcBillService prcBillService;
+
     /**
      * Historical quote list.
      */
@@ -62,4 +68,28 @@ public class BillingController extends BaseController
         TmsPriceQuoteResult result = tmsPriceQuoteService.quote(request);
         return success(result);
     }
+
+    @PreAuthorize("@ss.hasPermi('price:billing:bill')")
+    @GetMapping("/bill/list")
+    public TableDataInfo billList(PrcBill query)
+    {
+        startPage();
+        List<PrcBill> list = prcBillService.selectBillList(query);
+        return getDataTable(list);
+    }
+
+    @PreAuthorize("@ss.hasPermi('price:billing:bill')")
+    @GetMapping("/bill/{billId}")
+    public AjaxResult getBill(@PathVariable String billId)
+    {
+        return success(prcBillService.getBill(billId));
+    }
+
+    @PreAuthorize("@ss.hasPermi('price:billing:bill')")
+    @PostMapping("/bill")
+    public AjaxResult bill(@Validated @RequestBody TmsPriceBillRequest request)
+    {
+        TmsPriceQuoteResult result = prcBillService.bill(request);
+        return success(result);
+    }
 }