dd

xggsve-order/app/base/api/impl/op/action.js

@@ -4,7 +4,7 @@ var settings = require("../../../../config/settings");
 class ActionAPI extends APIBase {
     constructor() {
         super();
-        this.iborderSve = system.getObject("service.order.iborderbaseSve");
+        this.iborderbaseSve = system.getObject("service.order.iborderbaseSve");
         this.ibdeliverbaseSve = system.getObject("service.order.ibdeliverbaseSve");
 
         this.iborderSve = system.getObject("service.order.iborderSve");
@@ -40,6 +40,13 @@ class ActionAPI extends APIBase {
         var opResult = null;
         switch (action_type) {
             // 订单
+            case "createOrder":
+                opResult = await this.iborderbaseSve.apiCreateOrder(action_body);
+                break;
+            case "completedOrder":
+                opResult = await this.iborderbaseSve.apiCompletedOrder(action_body);
+                break;
+
             case "addOrder":
                 opResult = await this.iborderSve.apiAdd(action_body);
                 break;

xggsve-order/app/base/service/impl/order/iborderbaseSve.js

@@ -11,6 +11,76 @@ class IborderbaseService extends ServiceBase {
     this.orderSve_3 = system.getObject("service.order.iborderdzSve");
   }
 
+  /**
+   * 创建基类订单
+   * @param {*} params 
+   */
+  apiCreateOrder(params) {
+    // if(!params.productType){
+    //   return system.getResult(null, `参数错误 产品类型错误`);
+    // }
+    // if(!params.productItems instanceof Array){
+    //   return system.getResult(null, `参数错误 产品项目错误`);
+    // }
+    // if(!params.channelNo){
+    //   return system.getResult(null, `参数错误 渠道名称错误`);
+    // }
+    // if(!params.thirdNo){
+    //   return system.getResult(null, `参数错误 订单错误`);
+    // }
+    // if(!Number(params.price)<0){
+    //   return system.getResult(null, `参数错误 订单价格错误`);
+    // }
+    // if(!params.payType){
+    //   return system.getResult(null, `参数错误 支付方式错误`);
+    // }
+    // if(!params.legalName){
+    //   return system.getResult(null, `参数错误 联系人不能为空`);
+    // }
+    // if(!params.legalMobile){
+    //   return system.getResult(null, `参数错误 联系电话不能为空`);
+    // }
+    // if(!params.invoiceType){
+    //   return system.getResult(null, `参数错误 发票类型错误`);
+    // }
+
+    try {
+      params.channelNo = this.trim(params.channelNo);
+      params.thirdNo = this.trim(params.thirdNo);
+      params.notes = this.trim(params.notes);
+      params.legalName = this.trim(params.legalName);
+      params.legalMobile = this.trim(params.legalMobile);
+      params.legalEmail = this.trim(params.legalEmail);
+      params.payType = Number(params.payType || 1);
+      params.productType = Number(params.productType || 1);
+      params.price = Number(params.price || 0);
+      //1 保存基类的信息
+      await this.db.transaction(async t => {
+
+        //创建基类表
+        let _baseOrder = await this.create(params);
+        let childSve = this.getService(params);
+        //将id 赋值
+        params.id = _baseOrder.raw.id;
+        await childSve.createOrder(params);
+      });
+      return system.getResultSuccess();
+    } catch (error) {
+      return system.getResult(null, `系统错误 错误信息 ${error}`);
+    }
+  }
+
+  /**
+   * 完善信息
+   * @param {*} params 
+   */
+  async completedOrder(params){
+    //1 检查个体户是否存在
+
+    //2 如果不存在添加保存个体户  
+    //3 完善信息
+  }
+
   getService(productType) {
     return this["orderSve_" + productType];
   }

xggsve-order/app/base/service/impl/order/iborderdkSve.js

@@ -11,6 +11,41 @@ class IborderdkService extends ServiceBase {
 
   async addOrder(params) {
   }
+
+  /**
+   * 创建订单
+   * @param {*} params 
+   */
+  async createOrder(params){
+    try {
+      if(!params.merchantId){
+        return system.getResult(null, `参数错误 商户ID不能为空`);
+      }
+      if(!params.businessmentId){
+        return system.getResult(null, `参数错误 个体户ID不能为空`);
+      }
+      if(!params.orderpayId){
+        return system.getResult(null, `参数错误 支付ID不能为空`);
+      }
+      if(!Number(params.price)<0){
+        return system.getResult(null, `参数错误 订单金额格式错误`);
+      }
+      for (let key in params) {
+          if(params[key] instanceof String){
+            params[key] =  this.trim(params[key]);
+          }
+      }
+      let _ibOrderDk = null;
+      if(!params.id){
+        _ibOrderDk = await this.create(params);
+      }else{
+        _ibOrderDk = await this.dao.create(params);
+      }
+      return system.getResult(_ibOrderDk);
+    } catch (error) {
+      return system.getResult(null,`系统错误 错误信息 ${error}`);
+    }
+  }
 }
 module.exports = IborderdkService;
 // var task=new UserService();