update:set

application/services/goods/GoodsService.php

@@ -252,11 +252,31 @@ class GoodsService
             "inventory_rest" => $skuData["inventory"],
             "original_price" => empty($skuData["original_price"]) ? '' : $skuData["original_price"] * 100,
             "price" => $skuData["price"] * 100,
+            "online_start_time" =>  empty($skuData["online_start_time"]) ? "" : $skuData["online_start_time"],
+            "online_end_time" =>  empty($skuData["online_end_time"]) ? "" : $skuData["online_end_time"],
+            "online_type" => empty($skuData["online_type"]) ? "" : $skuData["online_type"],
         ];
         if (!empty($skuData["setmeal"])) {
             $skuParams["setmeal"] = $skuData["setmeal"];
         }
 
+        $online_type = empty($skuData["online_type"]) ? 0 : $skuData["online_type"];
+
+        switch ($online_type) {
+            case 1:
+                $skuParams['online_status'] = 1;
+                break;
+            case 2:
+                $skuParams['online_status'] = 0;
+                break;
+            case 3:
+                $skuParams['online_status'] = 0;
+                break;
+            default:
+                # code...
+                break;
+        }
+
         GoodsSku::save($skuParams);
         self::addGoodsSkuPicRecord($skuId, $skuData);
         return $skuId;
@@ -405,6 +425,26 @@ class GoodsService
                     ];
                 }
 
+                $online_type = empty($skuData["online_type"]) ? 0 : $skuData["online_type"];
+
+                switch ($online_type) {
+                    case 1:
+                        $statusData['online_status'] = 1;
+                        break;
+                    case 2:
+                        $statusData['online_status'] = 0;
+                        $statusData['online_start_time'] =  empty($skuData["online_start_time"]) ? "" : $skuData["online_start_time"];
+                        $statusData['online_end_time'] =  empty($skuData["online_end_time"]) ? "" : $skuData["online_end_time"];
+                        break;
+                    case 3:
+                        $statusData['online_status'] = 0;
+                        break;
+                    default:
+                        # code...
+                        break;
+                }
+
+
                 GoodsSku::save($statusData, ["goods_sku_id" => $sku["goods_sku_id"]]);
 
                 //商品操作记录

daemon/Goods.php

@@ -31,6 +31,8 @@ class Goods implements DaemonServiceInterface
             GoodsService::updateGoodsInfoToEs($where['goods_sku_id']);
 
         }
+
+        $this->onlineGoods();
     }
 
 
@@ -53,4 +55,32 @@ class Goods implements DaemonServiceInterface
             GoodsService::updateGoodsInfoToEs($where['goods_sku_id']);
         }
     }
+
+    /**
+     *
+     * 自动上线
+     */
+    public function onlineGoods()
+    {
+        sleep(2);
+        $orderData = [
+            'online_type' => 2,
+            'online_status' => 0,
+            'online_start_time[<]' => date("Y-m-d H:i:s",time()),
+            'LIMIT' => 100,
+        ];
+        $goodsList = GoodsSku::getRecords($orderData);
+        DaemonLog::info('DaemonServiceOnline_goods', json_encode($goodsList));
+        foreach ($goodsList as $key => $value) {
+            $where = [];
+            $where['goods_sku_id'] = !empty($value['goods_sku_id']) ? $value['goods_sku_id'] : '';
+            $colums = [
+                'online_status' => 1,
+            ];  
+            GoodsSku::save($colums, $where);
+            //更新es
+            GoodsService::updateGoodsInfoToEs($where['goods_sku_id']);
+
+        }
+    }
 }
\ No newline at end of file