日志脚本

app/Console/Commands/CleaningData.php

@@ -3,6 +3,7 @@
 use Illuminate\Console\Command;
 use DB;
 use App\Order;
+use App\OrderScript;
 use App\GoodsSkus;
 use App\OrderGoodsSkus;
 
@@ -80,7 +81,7 @@ class CleaningData extends Command {
             $outerCode = Order::where('id', $id)->pluck('outerCode');
         }
         $order['outerCode'] = $outerCode;
-        $mjOrder = Order::mjOrderGet($order);
+        $mjOrder = OrderScript::mjOrderGet($order);
         if(!isset($mjOrder['order']['code'])){
             return false;
         }

app/Console/Commands/SyncMjOrderStatus.php

@@ -4,6 +4,7 @@ namespace App\Console\Commands;
 use Illuminate\Console\Command;
 use DB;
 use App\Order;
+use App\OrderScript;
 use App\FxOrder;
 use App\GoodsSkus;
 use App\OrderGoodsSkus;
@@ -132,7 +133,7 @@ class SyncMjOrderStatus extends Command {
             $outerCode = Order::where('id', $id)->pluck('outerCode');
         }
         $order['outerCode'] = $outerCode;
-        $mjOrder = Order::mjOrderGet($order);
+        $mjOrder = OrderScript::mjOrderGet($order);
         if(!isset($mjOrder['order']['code'])){
             return false;
         }
@@ -149,7 +150,7 @@ class SyncMjOrderStatus extends Command {
             $outerCode = FxOrder::where('id', $id)->pluck('outerCode');
         }
         $order['outerCode'] = $outerCode;
-        $mjOrder = Order::mjOrderGet($order);
+        $mjOrder = OrderScript::mjOrderGet($order);
         if(!isset($mjOrder['order']['code'])){
             return false;
         }

app/Console/Commands/SyncMjWarehouse.php

@@ -4,6 +4,7 @@ namespace App\Console\Commands;
 use Illuminate\Console\Command;
 use DB;
 use App\Order;
+use App\OrderScript;
 class SyncMjWarehouse extends Command {
 
     protected $signature = 'SyncMjWarehouse';
@@ -27,7 +28,7 @@ class SyncMjWarehouse extends Command {
         $params['warehouseCode'] = config('constants.WAREHOUSE_CODE'); //仓库编码
         $params['pageIndex'] = '1';
         $params['pageSize'] = $this->limit;
-        $mjRes = Order::mjWarehouseSkuGet($params);
+        $mjRes = OrderScript::mjWarehouseSkuGet($params);
         if($mjRes == false){
             exit('获取卖家云数据出错');
         }
@@ -41,7 +42,7 @@ class SyncMjWarehouse extends Command {
         //插入其他页面
         for($i=2; $i<=$pages; $i++){
             $params['pageIndex'] = $i;
-            $mjRes = Order::mjWarehouseSkuGet($params);
+            $mjRes = OrderScript::mjWarehouseSkuGet($params);
             $this->insertData( $mjRes['resultSet']['skuList'] );
         }
 

app/Console/Commands/SyncOrderToMj.php

@@ -4,6 +4,7 @@ namespace App\Console\Commands;
 use Illuminate\Console\Command;
 use DB;
 use App\Order;
+use App\OrderScript;
 use App\FxOrder;
 use App\GoodsSkus;
 use App\Goods;
@@ -115,7 +116,7 @@ class SyncOrderToMj extends Command {
             }
         }
         //卖家云添加订单 ->改为审核通过再同步卖家云
-        $mj_add = Order::mjOrderAdd($order);
+        $mj_add = OrderScript::mjOrderAdd($order);
         //同步卖家云订单数据到本系统
         if( isset($mj_add['order']['code']) ){
             $mjorder = array();
@@ -135,7 +136,7 @@ class SyncOrderToMj extends Command {
             $outerCode = Order::where('id', $id)->pluck('outerCode');
         }
         $order['outerCode'] = $outerCode;
-        $mjOrder = Order::mjOrderGet($order);
+        $mjOrder = OrderScript::mjOrderGet($order);
         if(!isset($mjOrder['order']['code'])){
             return false;
         }
@@ -152,7 +153,7 @@ class SyncOrderToMj extends Command {
             $order = json_decode(json_encode($order), true);
         }
 
-        $mj_add = Order::mjOrderUpdate($order);
+        $mj_add = OrderScript::mjOrderUpdate($order);
 
         return $mj_add;
     }
@@ -188,7 +189,7 @@ class SyncOrderToMj extends Command {
             }
         }
         //卖家云添加订单 ->改为审核通过再同步卖家云
-        $mj_add = Order::mjOrderAdd($order);
+        $mj_add = OrderScript::mjOrderAdd($order);
         //同步卖家云订单数据到本系统
         if( isset($mj_add['order']['code']) ){
             $mjorder = array();
@@ -208,7 +209,7 @@ class SyncOrderToMj extends Command {
             $outerCode = FxOrder::where('id', $id)->pluck('outerCode');
         }
         $order['outerCode'] = $outerCode;
-        $mjOrder = Order::mjOrderGet($order);
+        $mjOrder = OrderScript::mjOrderGet($order);
         if(!isset($mjOrder['order']['code'])){
             return false;
         }
@@ -225,7 +226,7 @@ class SyncOrderToMj extends Command {
             $order = json_decode(json_encode($order), true);
         }
 
-        $mj_add = Order::mjOrderUpdate($order);
+        $mj_add = OrderScript::mjOrderUpdate($order);
 
         return $mj_add;
     }

app/Log.php

@@ -21,4 +21,21 @@ class Log extends Model
         $name=date("Y-m-d",time()).".txt";
         error_log(json_encode($data)."\n",3,"/log/seafood_log/".$tmpDir.$name);
     }
+
+    public static function scriptLog($params,$returnValue,$interfaceName,$flag,$headers=[],$responseTime=NULL){
+        $data['time']=date("Y-m-d H:i:s",time());
+        $data["interfaceName"]=$interfaceName;
+        $data['responseTime'] = $responseTime;
+        $data["params"]=$params;
+        $data["headers"]=$headers;
+        $data["returnValue"]=$returnValue;
+       
+        if($flag){
+            $tmpDir="script_success/";
+        }else{
+            $tmpDir="script_error/";
+        }
+        $name=date("Y-m-d",time()).".txt";
+        error_log(json_encode($data)."\n",3,"/log/seafood_log/".$tmpDir.$name);
+    }
 }

app/OrderScript.php

@@ -0,0 +1,199 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: Administrator
+ * Date: 2017/12/5
+ * Time: 15:07
+ */
+
+namespace App;
+use Illuminate\Database\Eloquent\Model;
+use PHPExcel;
+use PHPExcel_Writer_Excel2007;
+
+class OrderScript extends Model
+{
+    public $timestamps = false;
+    /**
+     * 添加订单
+     */
+   	public static function mjOrderAdd($orderList){
+   		$orderList["method"] = "maijiayun.order.add";
+      //status格式
+      $staus_arr = array(
+        0 => '待付款',
+        1 => '已付款待审核',
+        2 => '已审核待发货',
+        3 => '已发货',
+      );
+      $orderList['status'] = $staus_arr[$orderList['status']];
+   		$result = self::mjApi($orderList);
+   		return $result;
+   	}
+
+    /**
+     * 更新订单
+     */
+    public static function mjOrderUpdate($orderList){
+      $orderList["method"] = "maijiayun.order.update";
+      $staus_arr = array(
+        0 => '待付款',
+        1 => '已付款待审核',
+        2 => '已审核待发货',
+        3 => '已发货',
+        4 => '已取消',
+      );
+      $orderList['status'] = $staus_arr[$orderList['status']];
+      $result = self::mjApi($orderList);
+      return $result;
+    }
+
+    /**
+     * 取消订单
+     */
+    public static function mjOrderDel($orderList){
+      $orderList["method"] = "maijiayun.order.update"; 
+      $orderList['status'] = '已取消';
+      $result = self::mjApi($orderList);
+      return $result;
+    }
+    
+
+    /**
+     * 获取订单
+     */
+    public static function mjOrderGet($order){
+      $order["method"] = "maijiayun.order.get";
+      $result = self::mjApi($order);
+      return $result;
+    }
+
+    /**
+     * 添加Erp商品
+     */
+    public static function mjErpGoodsAdd($goods){
+      $goods["method"] = "maijiayun.goods.sku.add";
+      $result = self::mjApi($goods);
+      return $result;
+    }
+
+    /**
+     * 添加商品
+     */
+    public static function mjGoodsAdd($goods){
+      $goods["method"] = "maijiayun.eshop.goods.add";
+      $result = self::mjApi($goods);
+      return $result;
+    }
+  
+    /**
+     * 更新商品
+     */
+    public static function mjGoodsUpdate($goods){
+      $goods["method"] = "maijiayun.eshop.goods.update";
+      $result = self::mjApi($goods);
+      return $result;
+    }
+    
+    /**
+     * 更新erp商品
+     */
+    public static function mjErpGoodsUpdate($goods){
+      $goods["method"] = "maijiayun.goods.update";
+      $result = self::mjApi($goods);
+      return $result;
+    }
+
+    /**
+     * 批量添加sku
+     */
+    public static function mjBatchSkuAdd($sku){
+      $sku["method"] = "maijiayun.eshop.sku.batchAdd"; //批量添加
+      //$sku["method"] = "maijiayun.eshop.sku.add";
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
+    /**
+     * 添加单个sku
+     */
+    public static function mjSkuAdd($sku){
+      $sku["method"] = "maijiayun.eshop.sku.add";
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
+    /**
+     * 修改Erp sku
+     */
+    public static function mjErpSkuUpdate($sku){
+      $sku["method"] = "maijiayun.goods.sku.update"; 
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
+    /**
+     * 修改shop sku
+     */
+    public static function mjSkuUpdate($sku){
+      $sku["method"] = "maijiayun.eshop.sku.update"; 
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
+    /**
+     * 获取 sku 库存
+     */
+    public static function mjWarehouseSkuGet($sku){
+      $sku["method"] = "maijiayun.warehouse.sku.list"; 
+      $result = self::mjApi($sku);
+      return $result;
+    }
+
+   	public static function mjApi($params = array()){  		
+      $accessKey = "B1E69297B5DA44DAB35099A5F28F41D9"; //erp 生成的 accessKey
+      $accessSecret = "4sN2LbylhOglelMP";
+   		//$accessKey = "F82A757089D84F89B1782EDC3A4DA82A"; //erp 生成的 accessKey     
+		  //$accessSecret = "wB2ueW8eQOHXNWcN";
+	    $params["timestamp"] = time()."000";
+	    $params["version"] = "v1";
+	    $reqparams = $params;
+	    ksort($reqparams);
+	    $sign = "";
+	    foreach($reqparams as $k=>$val){
+	    if(is_array($val)){
+	    $val = json_encode($val,320);
+	    }
+	    $sign.=$k.$val;
+	    }
+	    $params["accessKey"] = $accessKey;
+	    $params["token"] = strtoupper(sha1($accessKey.$sign.$accessSecret));
+	    $param = json_encode($params);
+
+	    $ch = curl_init();
+	    $headers = array("Content-type:application/json;charset='utf-8'","Accept:application/json", "Cache-Control: no-cache", "Pragma: no-cache");
+	    curl_setopt($ch, CURLOPT_URL, "https://api.erp.maijiayun.cn"); //api 地址
+	    curl_setopt($ch, CURLOPT_POST, 1); 
+	    curl_setopt($ch, CURLOPT_TIMEOUT, 5); 
+	    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); 
+	    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers); 
+	    curl_setopt($ch, CURLOPT_POSTFIELDS, $param); 
+	    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
+	    $response = curl_exec($ch); 
+	    curl_close($ch);
+	    $response = json_decode($response, true);
+      Log::scriptLog($params,['mjApi_response'=>$response],"order/mjApi",1,'');
+	    if (!$response || !is_array($response)) { 
+	        return false;
+	    }
+	    if (!array_key_exists("isOk", $response)) { 
+	        return false;
+	    } elseif( $response['isOk'] == false){
+          Log::scriptLog($params,['mjApi_response'=>$response],"order/mjApi",0,'');
+          return false;
+      } else {
+	        return $response;
+	    }
+	 }
+
+}