dev

data/model/refill_query_err.model.php

@@ -9,47 +9,9 @@ class refill_query_errModel extends Model
         parent::__construct('refill_query_err');
     }
 
-    public function getThirdProductList($condition, $pagesize = '', $field = '*', $order = '', $limit = '')
-    {
-        $list = $this->table('third_product')->field($field)->where($condition)->page($pagesize)->order($order)->limit($limit)->select();
-        if (empty($list)) return [];
-        return $list;
-    }
-
-    public function addThirdProduct($insert)
-    {
-        return $this->table('third_product')->insert($insert);
-    }
-
-    public function findThirdProduct($system_code)
-    {
-        return $this->table('third_product')->where(['system_code' => $system_code])->find();
-    }
-
-    public function editThirdProduct($system_code, $data){
-        return $this->table('third_product')->where(['system_code' => $system_code])->update($data);
-    }
-
-    public function getProviderProductList($condition, $pagesize = '', $field = '*', $order = '', $limit = '')
-    {
-        $list = $this->table('third_proprice')->field($field)->where($condition)->page($pagesize)->order($order)->limit($limit)->select();
-        if (empty($list)) return [];
-        return $list;
-    }
-
     public function add($insert)
     {
         $insert['query_time'] = time();
         return $this->insert($insert);
     }
-
-    public function edit_provider_product($system_code,$store_id,$goods_id,$data)
-    {
-        return $this->table('third_proprice')->where(['store_id' => $store_id,'goods_id' => $goods_id,'system_code' => $system_code])->update($data);
-    }
-
-    public function del_provider_product($system_code,$store_id,$goods_id)
-    {
-        return $this->table('third_proprice')->where(['store_id' => $store_id,'goods_id' => $goods_id,'system_code' => $system_code])->delete();
-    }
 }

helper/message/publisher.php

@@ -256,7 +256,10 @@ class publisher
     {
         Log::record(__METHOD__,Log::DEBUG);
         if($this->mConnected) {
-            $this->mRedis->publish('refill',json_encode(['type'=>'bridge','value' => 0]));
+            $this->mRedis->publish('refill',json_encode(['type'=>'fulu_bridge','value' => 0]));
+            $this->mRedis->publish('refill',json_encode(['type'=>'fulu_qdw_bridge','value' => 0]));
+            $this->mRedis->publish('refill',json_encode(['type'=>'fulu_ylyw_bridge','value' => 0]));
+            $this->mRedis->publish('refill',json_encode(['type'=>'fulu_youjun_bridge','value' => 0]));
         }
     }
 }

helper/rbridge/fulu/Bridge.php

@@ -13,7 +13,7 @@ class Bridge implements IBridge
 {
     public function add($params)
     {
-        if(StatesHelper::fetch_state('bridge')) {
+        if(StatesHelper::fetch_state('fulu_bridge')) {
             include (BASE_HELPER_PATH . '/rbridge/fulu/product.php');
         }
 

helper/rbridge/fulu_qdw/Bridge.php

@@ -13,7 +13,7 @@ class Bridge implements IBridge
 {
     public function add($params)
     {
-        if(StatesHelper::fetch_state('bridge')) {
+        if(StatesHelper::fetch_state('fulu_qdw_bridge')) {
             include (BASE_HELPER_PATH . '/rbridge/fulu_qdw/product.php');
         }
 

helper/rbridge/fulu_ylyw/Bridge.php

@@ -13,7 +13,7 @@ class Bridge implements IBridge
 {
     public function add($params)
     {
-        if(StatesHelper::fetch_state('bridge')) {
+        if(StatesHelper::fetch_state('fulu_ylyw_bridge')) {
             include (BASE_HELPER_PATH . '/rbridge/fulu_ylyw/product.php');
         }
 

helper/rbridge/fulu_youjun/Bridge.php

@@ -14,7 +14,7 @@ class Bridge implements IBridge
 {
     public function add($params)
     {
-        if(StatesHelper::fetch_state('bridge')) {
+        if(StatesHelper::fetch_state('fulu_youjun_bridge')) {
             include (BASE_HELPER_PATH . '/rbridge/fulu_youjun/product.php');
         }