tj

center-order/app/base/api/impl/action/order.js

@@ -34,6 +34,9 @@ class OrderAPI extends APIBase {
             case "getOrderDeliveryInfo"://获取订单交付信息
                 opResult = await this.orderinfoSve.getOrderDeliveryInfo(pobj, pobj.actionBody);
                 break;
+            case "getOrderDeliveryFlowInfo"://获取订单交付流程信息
+                opResult = await this.orderinfoSve.getOrderDeliveryFlowInfo(pobj, pobj.actionBody);
+                break;
             //--------------------------------支付相关接口------------开始
             case "getPayOrderInfo"://获取付款订单信息
                 opResult = await this.orderinfoSve.getPayOrderInfo(pobj, pobj.actionBody);
@@ -49,7 +52,7 @@ class OrderAPI extends APIBase {
         return opResult;
     }
 
-    
+
     async addOrder(pobj, actionBody) {
         if (!actionBody.product_info) {
             return system.getResult(null, "产品信息有误，20010");

center-order/app/base/service/impl/dbcorder/orderinfoSve.js

@@ -354,6 +354,17 @@ class OrderInfoService extends ServiceBase {
     }
     return system.getResultSuccess();
   }
+
+  async getOrderDeliveryFlowInfo(pobj, actionBody) {//获取订单交付流程信息
+    var sql = "select * from c_delivery_official_flow where sourceOrderNo='" + pobj.actionBody.sourceOrderNo + "'";
+    var list = await this.customQuery(sql);
+    if (list && list.length > 0) {
+      if (list[0].officialFlow) {
+        return system.getResultSuccess(list[0].officialFlow);
+      }
+    }
+    return system.getResultSuccess();
+  }
   //-------------------------------服务商通知订单流程-------------start----------------
 
   async icOrderStatusNotify(pobj, actionBody) {//峰擎通知工商办理状态
@@ -397,11 +408,11 @@ class OrderInfoService extends ServiceBase {
     }
     var sql = null;
     if (addi > 0) {
-      sql = "INSERT INTO  `c_order_delivery` (`sourceOrderNo`,`deliveryContent`) VALUE('" +
+      sql = "INSERT INTO  `c_delivery_official_flow` (`sourceOrderNo`,`officialFlow`) VALUE('" +
         actionBody.orderNo + "','" + JSON.stringify(updateDeliveryInfo) + "')";
     }
     else {
-      sql = "UPDATE `c_order_delivery`  SET deliveryContent ='" + JSON.stringify(updateDeliveryInfo) + "' where sourceOrderNo='" + actionBody.orderNo + "'";
+      sql = "UPDATE `c_delivery_official_flow`  SET officialFlow ='" + JSON.stringify(updateDeliveryInfo) + "' where sourceOrderNo='" + actionBody.orderNo + "'";
     }
     this.customQuery(sql);
     return system.getResultSuccess();