订单同步到卖家云之前查询收货人所在城市天气状况并更新到卖家备注当中

app/Console/Commands/SyncOrderToMj.php

@@ -46,6 +46,9 @@ class SyncOrderToMj extends Command {
             if(empty($thisOrder)){
                 continue;
             }
+            #新加逻辑 查询收件人所在城市天气情况并更新
+            Order::updateWeather($id);
+
             $res = $this->syncOrderToMj($id);
             if(!$res){
                 echo "\n订单ID:".$id." 同步失败";

app/Http/Controllers/Admin/FxOrderController.php

@@ -1007,6 +1007,9 @@ class FxOrderController extends Controller
                 if($mjFlag == 1){    
                     //其他仓变C仓           
                     if(empty($mjOrder)){
+                        #新加逻辑 查询收件人所在城市天气情况并更新
+                        Order::updateWeather($id);
+
                         $mj_in = $this->syncOrderToMj($id, $orderSkus);
                         if( $mj_in == false ){
                             throw new Exception("订单同步到卖家云失败");
@@ -1272,6 +1275,9 @@ class FxOrderController extends Controller
                 $today_date = date('Y-m-d');
                 #如果审核通过，c仓, 并且到预发货时间，同步卖家云
                 if($order->status == 2 && $order->warehouse == 3 && $order->delivery_date <= $today_date){
+                    #新加逻辑 查询收件人所在城市天气情况并更新
+                    Order::updateWeather($id);
+
                     $syncMj = $this->syncOrderToMj($id);
                     if( $syncMj == false ){
                         throw new Exception("订单同步到卖家云失败");

app/Http/Controllers/Admin/OrderController.php

@@ -1271,6 +1271,9 @@ class OrderController extends Controller
                 if($mjFlag == 1){    
                     //其他仓变C仓           
                     if(empty($mjOrder)){
+                        #新加逻辑 查询收件人所在城市天气情况并更新
+                        Order::updateWeather($id);
+
                         $mj_in = $this->syncOrderToMj($id, $orderSkus);
                         if( $mj_in == false ){
                             throw new Exception("订单同步到卖家云失败");
@@ -1764,6 +1767,9 @@ class OrderController extends Controller
                 $today_date = date('Y-m-d');
                 #如果审核通过，c仓, 并且到预发货时间，同步卖家云
                 if($order->status == 2 && $order->warehouse == 3 && $order->delivery_date <= $today_date){
+                    #新加逻辑 查询收件人所在城市天气情况并更新
+                    Order::updateWeather($id);
+
                     $syncMj = $this->syncOrderToMj($id);
                     if( $syncMj == false ){
                         throw new Exception("订单同步到卖家云失败");

app/Http/Controllers/Api/OrderController.php

@@ -841,6 +841,9 @@ class OrderController extends Controller {
                 $today_date = date('Y-m-d');
                 #如果审核通过，c仓, 并且到预发货时间，同步卖家云
                 if($order->status == 2 && $order->warehouse == 3 && $order->delivery_date <= $today_date){
+                    #新加逻辑 查询收件人所在城市天气情况并更新
+                    Order::updateWeather($id);
+
                     $syncMj = $this->syncOrderToMj($id);
                     if( $syncMj == false ){
                         throw new Exception("订单同步到卖家云失败");

app/Order.php

@@ -306,4 +306,52 @@ class Order extends Model
         $objWriter->save('php://output');  
         exit();
     }
+
+    /*更新城市天气信息*/
+    public static function updateWeather($order_id) {
+        $redisKey = 'seafood_order_city_weather';
+        $appKey = '32c8f844f8055f70f702fc28ec930e52';
+        //查询订单收件人所在的城市（过滤关键字 市）
+        $city = self::where('id', $order_id)->pluck('receiverCity');
+        $city = str_replace('市','',$city);
+        $specialCity = array('朝阳区','嘉定区','海淀区','昌平区','密云区','大兴区','房山区','通州区','普陀区',);
+        if(in_array($city, $specialCity)) {
+            $city = str_replace('区','',$city);
+        }
+        //查询redis中是否有该键，若没有则查询
+        $weather = RedisModel::get($redisKey.'_'.$city);
+        if($weather) {
+            $sellerMemo = self::where('id', $order_id)->pluck('sellerMemo');
+            $sellerMemo = $sellerMemo.'  '.$city.'天气状况:'.$weather;
+            self::where('id', $order_id)->update(['sellerMemo'=>$sellerMemo]);
+        } else {
+            $url = 'http://apis.juhe.cn/simpleWeather/query?city='.urlencode($city).'&key='.$appKey;
+            $result = file_get_contents($url);
+            $result = json_decode($result, true);
+            if($result['error_code'] == '0') {
+                //将数据缓存到redis里
+                $today = date('Y-m-d',time());
+                $tomorrow = date('Y-m-d',strtotime('+1 days'));
+                $weather = '';
+                foreach ($result['result']['future'] as $value) {
+                    if($value['date'] == $today) {
+                        $weather .= $today.'日气温:'.$value['temperature'].';  ';
+                    }
+                    if($value['date'] == $tomorrow) {
+                        $weather .= $tomorrow.'日气温:'.$value['temperature'];
+                    }
+                }
+
+                RedisModel::set($redisKey.'_'.$city, $weather);
+                $endTime = strtotime(date('Y-m-d 00:00:00',strtotime('+1 days'))) -1;
+                $expire = $endTime - time();
+                RedisModel::expire($redisKey.'_'.$city, $expire);
+                $sellerMemo = self::where('id', $order_id)->pluck('sellerMemo');
+                $sellerMemo = $sellerMemo.'  '.$city.'天气状况:'.$weather;
+                self::where('id', $order_id)->update(['sellerMemo'=>$sellerMemo]);
+            }
+        }
+
+        return true;
+    }
 }