create:提交订单上游状态sql

yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/controller/admin/orders/OrdersController.java

@@ -76,6 +76,14 @@ public class OrdersController {
         return success(true);
     }
 
+    @PutMapping("/submitUpStreamStatus")
+    @Operation(summary = "强制修改订单提交状态")
+    @PreAuthorize("@ss.hasPermission('haoka:orders:submitUpStreamStatus')")
+    public CommonResult<Boolean> submitUpStreamStatus(@Valid @RequestBody OrdersSaveReqVO updateReqVO) {
+        ordersService.submitUpStreamStatus(updateReqVO);
+        return success(true);
+    }
+
     @DeleteMapping("/delete")
     @Operation(summary = "删除订单")
     @Parameter(name = "id", description = "编号", required = true)

yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/controller/admin/orders/vo/OrdersSaveReqVO.java

@@ -217,4 +217,10 @@ public class OrdersSaveReqVO {
      */
     @Schema(description = "是否加急")
     private Integer isUrgent;
+
+    /**
+     * 上游订单状态（生产异常 -430 开卡失败-460 提交异常 0 开卡中470  待发货500 已发货550 已激活700）
+     */
+    @Schema(description = "上游订单状态")
+    private Integer upstreamOrderStatus;
 }

yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/dal/dataobject/orders/OrdersDO.java

@@ -1,5 +1,6 @@
 package cn.iocoder.yudao.module.haoka.dal.dataobject.orders;
 
+import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.*;
 
 import java.util.*;
@@ -233,6 +234,10 @@ public class OrdersDO extends BaseDO {
      * 上游订单号
      */
     private String upstreamOrderId;
+    /**
+     * 上游订单状态（-430 生产异常 -460 提交异常 0 开卡中470  待发货500 已发货550 已激活700）
+     */
+    private Integer upstreamOrderStatus;
     /**
      * 生产备注
      */

yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orders/OrdersService.java

@@ -69,4 +69,10 @@ public interface OrdersService extends IService<OrdersDO> {
      * @param updateReqVO
      */
     void submitOrders(OrdersSaveReqVO updateReqVO);
+
+    /**
+     * 强制修改订单提交状态
+     * @param updateReqVO
+     */
+    void submitUpStreamStatus(OrdersSaveReqVO updateReqVO);
 }

yudao-module-haoka/yudao-module-haoka-biz/src/main/java/cn/iocoder/yudao/module/haoka/service/orders/OrdersServiceImpl.java

@@ -197,6 +197,11 @@ public class OrdersServiceImpl extends ServiceImpl<OrdersMapper, OrdersDO> imple
         createOrder(updateObj);
     }
 
+    @Override
+    public void submitUpStreamStatus(OrdersSaveReqVO updateReqVO) {
+
+    }
+
     /**
      * 调用运营商产生订单
      *
@@ -211,18 +216,23 @@ public class OrdersServiceImpl extends ServiceImpl<OrdersMapper, OrdersDO> imple
         Boolean isBlack = orderResponse.getIsBlack();
         // 上游是否支持这个接口
         // Boolean isSupport = orderResponse.getIsSupport(); 都支持创建订单的   查询不一定
-        // 成功？
+        // 是否成功？
         Boolean success = orderResponse.getSuccess();
         // 响应信息
         String msg = orderResponse.getMsg();
-        // 订单创结果
-        OrderApiCreateResp orderData = orderResponse.getData();
-        // 上游订单ID
-        String supplierOrderId = orderData.getSupplierOrderId();
-
-        // ordersDO 记录 create param 和 响应信息
-        ordersDO.setOrderCreateResponse(orderData.getOrderCreateResponse());
-        ordersDO.setUpstreamOrderId(supplierOrderId);
+        if(success){
+            // 订单创结果
+            OrderApiCreateResp orderData = orderResponse.getData();
+            // ordersDO 记录 create param 和 响应信息
+            ordersDO.setOrderCreateResponse(orderData.getOrderCreateResponse());
+            // 上游订单ID
+            String supplierOrderId = orderData.getSupplierOrderId();
+            ordersDO.setUpstreamOrderId(supplierOrderId);
+            // 记录成功操作记录 todo
+        }else {
+            // 失败操作记录 todo
+        }
+        // 更新订单
         ordersMapper.updateById(ordersDO);
     }
 

yudao-server/src/main/resources/db/migration/V5.0.15__insert_upstream_order_status_enum_to_dict.sql

@@ -0,0 +1,20 @@
+-- 创建字典类型
+INSERT INTO `system_dict_type` (`name`, `type`, `status`, `remark`, `creator`, `updater`, `deleted`)
+VALUES ('上游订单状态', 'haoka_upstream_order_status', 0, '', '1', '1', b'0');
+
+# 生产异常 -430 开卡失败-460 提交异常 0 开卡中 470  待发货 500 已发货 550 已激活 700
+
+-- 插入字典数据
+INSERT INTO `system_dict_data` (`sort`, `label`, `value`, `dict_type`, `status`, `color_type`, `css_class`, `remark`, `creator`, `updater`, `deleted`)
+VALUES
+    (1, '生产异常', '-430', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (2, '开卡失败', '-460', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (3, '提交异常', '0', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (4, '开卡中', '470', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (5, '待发货', '500', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (6, '已发货', '550', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0'),
+    (7, '已激活', '700', 'haoka_upstream_order_status', 0, '', '', NULL, '1', '1', b'0');
+
+ALTER TABLE `haoka_orders`
+    MODIFY COLUMN `refund_status` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NULL DEFAULT NULL COMMENT '交易状态' AFTER `status_updated_at`,
+    ADD COLUMN `upstream_order_status` varchar(50) NULL COMMENT '上游订单状态' AFTER `upstream_order_id`;