添加数据流水编号

FworkSpider/items/base_item.py

@@ -1,14 +1,14 @@
 # -*- coding: utf-8 -*-
-
 import feapder.utils.tools as tools
 from feapder import Item
 
 
-class SwordFishProjectItem(Item):
+class BaseItem(Item):
 
     def __init__(self):
-        super(SwordFishProjectItem, self).__init__(
-            save=True  # 是否入库,默认入库=True,不入库=False
+        super(BaseItem, self).__init__(
+            save=True,
+            business_id=str(tools.uuid.uuid4()).replace('-', '')  # 数据流水编号
         )
 
     @property
@@ -16,8 +16,13 @@ class SwordFishProjectItem(Item):
         return self.__dict__["save"]
 
     @save.setter
-    def save(self, enable: bool):
-        self.__dict__["save"] = enable
+    def save(self, state: bool):
+        """
+            入库标识[入库(save=True);不入库(save=False)]
+
+        @param state: 入库状态
+        """
+        self.__dict__["save"] = state
 
     @property
     def fingerprint(self):

FworkSpider/items/njpc_item.py

@@ -1,11 +1,13 @@
+# -*- coding: utf-8 -*-
+
 import feapder.utils.tools as tools
 from feapder.utils.log import log
-from items.base_item import SwordFishProjectItem
+from items.base_item import BaseItem
 from untils.check_data import CheckData
 from untils.tools import int2long, substitute, text_search
 
 
-class DataNjpcItem(SwordFishProjectItem):
+class DataNjpcItem(BaseItem):
     """拟建类"""
     def __init__(self):
         super(DataNjpcItem, self).__init__()
@@ -132,7 +134,7 @@ class DataNjpcItem(SwordFishProjectItem):
             del self.projectinfo
 
 
-class NjpcListItem(SwordFishProjectItem):
+class NjpcListItem(BaseItem):
 
     def __init__(self):
         super(NjpcListItem, self).__init__()

FworkSpider/items/spider_item.py

@@ -1,6 +1,8 @@
+# -*- coding: utf-8 -*-
+
 import feapder.utils.tools as tools
 from feapder.utils.log import log
-from items.base_item import SwordFishProjectItem
+from items.base_item import BaseItem
 from untils.check_data import CheckData
 from untils.tools import (
     int2long,
@@ -9,7 +11,7 @@ from untils.tools import (
 )
 
 
-class DataBakItem(SwordFishProjectItem):
+class DataBakItem(BaseItem):
     """招标(标讯)类"""
     def __init__(self):
         super(DataBakItem, self).__init__()
@@ -108,7 +110,7 @@ class PropertyRightItem(DataBakItem):
         self.infoformat = 3
 
 
-class MgpListItem(SwordFishProjectItem):
+class MgpListItem(BaseItem):
 
     def __init__(self):
         super(MgpListItem, self).__init__()