监测商品价格变化逻辑

app/Console/Commands/Monitor.php

@@ -50,7 +50,7 @@ class Monitor extends Command {
             #发送验证码报警
             self::sendMsg('13161864516');
             self::sendMsg('18410900527');
-            error_log(date('Y-m-d H:i:s',time()).' pv:'.$pv." \n ",3,"/log/seafood_log/".date('Y-m-d',time()).'Monitor.log');
+            error_log(date('Y-m-d H:i:s',time()).' pv:'.$pv." \n ",3,"/log/seafood_log/script_success/".date('Y-m-d',time()).'Monitor.log');
         }
 
     }

app/Console/Commands/SyncMjWarehouse.php

@@ -5,6 +5,14 @@ use Illuminate\Console\Command;
 use DB;
 use App\Order;
 use App\OrderScript;
+use App\libs\sms;
+//define("YP_SMS_KEY", "fbdb5f2ddae13c2f4a592348bfe52137");
+//define('YP_SMS_YHQ', '73a74eb72c42b765669acd8e94096b9f');
+//define("YP_SMS_KEY_FAMLI",'995629e02beaaf47118b84ac19c4b5b9');
+//define("YP_VOICE_URL", "http://voice.yunpian.com/v2/voice/send.json");
+//define("YP_TPL_URL", "https://sms.yunpian.com/v2/sms/tpl_single_send.json");
+//define("YP_TPL_ID", "3383382");
+
 class SyncMjWarehouse extends Command {
 
     protected $signature = 'SyncMjWarehouse';
@@ -17,16 +25,22 @@ class SyncMjWarehouse extends Command {
     protected $description = '同步库存';
     protected $limit = 20;
     protected $diffRealPriceSkuListArr = array();
+    protected $YP_TPL_ID = '3383382';
 
 
     public function handle()
     {
         $this->SyncMjWarehouse();
+        if(count($this->diffRealPriceSkuListArr) > 0){
+//            print_r(json_encode($this->diffRealPriceSkuListArr));
+            $this->skuRealPriceMonitor();
+        }
+
     }
     public function SyncMjWarehouse(){
         $params = array();
         $params['eshopCode'] = config('constants.ESHOP_CODE');
-        $params['warehouseCode'] = config('constants.WAREHOUSE_CODE'); //仓库编码
+      //  $params['warehouseCode'] = config('constants.WAREHOUSE_CODE'); //仓库编码
         $params['pageIndex'] = '1';
         $params['pageSize'] = $this->limit;
         $mjRes = OrderScript::mjWarehouseSkuGet($params);
@@ -61,7 +75,7 @@ class SyncMjWarehouse extends Command {
             //2.更新商品库存总成本(有可能为空)
             //3.计算商品真实价格
             //4.计算商品外部价格
-            $cost = DB::table('goods_skus')->where('code', $code)->select('referenceCost', 'is_weigh', 'outPrice' ,'realPrice')->first(); //获取规格成本/是否称重
+            $cost = DB::table('goods_skus')->where('code', $code)->select('code', 'referenceCost', 'is_weigh', 'outPrice' ,'realPrice')->first(); //获取规格成本/是否称重
             if($cost){
                 $quantity = $cost->is_weigh == 1 ? $sku['quantity']/2 : $sku['quantity']; //对应规格数量
                 //实际库存=库存-冻结
@@ -77,8 +91,16 @@ class SyncMjWarehouse extends Command {
                 if($sku['quantity'] != 0 ){
                     $up['realPrice'] = $sku['totalCost'] / $quantity;
 
+                    #监控realPrice变化是否超过10%
                     $newRealPrice = $up['realPrice'];
                     $oldRealPrice = $cost->realPrice;
+                    if($oldRealPrice != 0){
+                        $result = $this->getNumberDiffAbs($newRealPrice,$oldRealPrice);
+                        if($result >= 0.1){
+                            $this->diffRealPriceSkuListArr[] = $code;
+                        }
+                    }
+
                 }
 //                if($cost->outPrice == 0){
 //                    if(isset($up['realPrice']) && $up['realPrice'] != 0){
@@ -94,4 +116,84 @@ class SyncMjWarehouse extends Command {
         return true;
     }
 
+    /**
+     * 发送短信验证码通知
+     */
+    public function skuRealPriceMonitor(){
+        $text = json_encode($this->diffRealPriceSkuListArr);
+        #发送验证码报警
+        $this->sendMsg('13161864516',$text);
+//        self::sendMsg('18410900527');
+        error_log(date('Y-m-d H:i:s',time()).' skuList:'.$text." \n ",3,"/log/seafood_log/script_success/".date('Y-m-d',time()).'MonitorRealPrice.log');
+
+    }
+
+    /**
+     * 计算两个数之间差值的绝对值
+     * @param $newNumber
+     * @param $oldNumber
+     * @return float|int
+     */
+    public function getNumberDiffAbs($newNumber,$oldNumber){
+        $diff = abs(($newNumber-$oldNumber));
+        return $diff/$oldNumber;
+    }
+
+    private function init(){
+        $ch = curl_init();
+        /* 设置验证方式 */
+        curl_setopt($ch, CURLOPT_HTTPHEADER, array('Accept:text/plain;charset=utf-8',
+            'Content-Type:application/x-www-form-urlencoded', 'charset=utf-8'));
+        /* 设置返回结果为流 */
+        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
+
+        /* 设置超时时间*/
+        curl_setopt($ch, CURLOPT_TIMEOUT, 10);
+
+        /* 设置通信方式 */
+        curl_setopt($ch, CURLOPT_POST, 1);
+        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
+        return $ch;
+
+    }
+
+    public function sendMsg($phone,$params){
+
+        $tpl_id = $this->YP_TPL_ID;
+        $ch=$this->init();
+        //$data=array('tpl_id' => $tpl_id,'text'=>$text,'apikey'=>YP_SMS_KEY,'mobile'=>$phone);
+        $data = [
+            'apikey' => YP_SMS_KEY,
+            'mobile' => $phone,
+            'tpl_id' => $tpl_id,
+            'tpl_value' => ('#sku_id#').'='.$params,
+        ];
+        $json_data = $this->tpl_send($ch,$data);
+        //print_r($json_data);    ******************************maybe影响验证码发出
+        $array = json_decode($json_data,true);
+        // echo '<pre>';print_r($array);
+        curl_close($ch);
+        return $array;
+    }
+
+    private function tpl_send($ch,$data){
+        curl_setopt ($ch, CURLOPT_URL, YP_TPL_URL);
+        curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data));
+        $result = curl_exec($ch);
+        $error = curl_error($ch);
+        $this->checkErr($result,$error);
+        return $result;
+    }
+
+    private static function checkErr($result,$error) {
+        if($result === false)
+        {
+            echo 'Curl error: ' . $error;
+        }
+//        else
+//        {
+//            echo '操作完成没有任何错误';
+//        }
+    }
+
 }