diff --git a/.gitignore b/.gitignore
index d2918cd9ff10008ea01e8a82406229027f7bb259..c768d1a0e4e7ebe5d6f18b9da55d6a0f8860f327 100644
--- a/.gitignore
+++ b/.gitignore
@@ -38,7 +38,7 @@ jobs/
 
 # 排除build
 build/
-
+**/bin/
 # 排除mac本地文件
 *.DS_Store
 *.properties
diff --git a/board/board-website/src/views/teamwork/visual/component-list/HorzLR/params.vue b/board/board-website/src/views/teamwork/visual/component-list/HorzLR/params.vue
index 7f2dcbe6e35ba9652d80f5a1dcb7cde1750e6a01..a69ee52062700fe19038256bbeb24baf2afc3f41 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/HorzLR/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/HorzLR/params.vue
@@ -291,7 +291,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 // config
diff --git a/board/board-website/src/views/teamwork/visual/component-list/HorzSecureBoost/params.vue b/board/board-website/src/views/teamwork/visual/component-list/HorzSecureBoost/params.vue
index 263731ed745bf616df8d4ac57612f8bcdaa94c19..90f86d9090763fe6f4ef285f74e27a9a290a604b 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/HorzSecureBoost/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/HorzSecureBoost/params.vue
@@ -282,7 +282,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 originForm:  { ...XGBoost },
diff --git a/board/board-website/src/views/teamwork/visual/component-list/MixLR/params.vue b/board/board-website/src/views/teamwork/visual/component-list/MixLR/params.vue
index c9d32e796801d3c5ca53a85465df24be16cc64f0..0e751fa7def54f703d947285c759470f1cd9e372 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/MixLR/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/MixLR/params.vue
@@ -326,7 +326,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 // config
diff --git a/board/board-website/src/views/teamwork/visual/component-list/MixSecureBoost/params.vue b/board/board-website/src/views/teamwork/visual/component-list/MixSecureBoost/params.vue
index b360c2e72952d654ca3ef1825a18130437f5633c..2e126e88a3d7ce6c5c48e43615da933427135863 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/MixSecureBoost/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/MixSecureBoost/params.vue
@@ -322,7 +322,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 originForm:  { ...XGBoost },
diff --git a/board/board-website/src/views/teamwork/visual/component-list/VertLR/params.vue b/board/board-website/src/views/teamwork/visual/component-list/VertLR/params.vue
index f747bb12e7cc93b75a84feb50d969a302d03e35f..6012ee4ec156039799d937748bcf7db9b7c534cf 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/VertLR/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/VertLR/params.vue
@@ -327,7 +327,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 // config
diff --git a/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/help.vue b/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/help.vue
index acc0cc29c91489ce70ed66a5bff7ee2c62da7a5b..40a46fc2c0811a471857638016cec46e57408ab9 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/help.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/help.vue
@@ -5,7 +5,7 @@
         </template>
         <template #params>
             <ol>
-                <li>同态加密算法：paillier、IterativeAffine</li>
+                <li>同态加密算法：paillier</li>
                 <li>最大树数量</li>
                 <li>树的最大深度</li>
                 <li>最大桶（箱）数量：直方图算法中指定每个特征最大分箱数量</li>
diff --git a/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/params.vue b/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/params.vue
index 771a695c8138e030785526e64b2293dfc34ca8d4..c2950448b3764bbfbe1cf0e5db53047b4b39e3b8 100644
--- a/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/params.vue
+++ b/board/board-website/src/views/teamwork/visual/component-list/VertSecureBoost/params.vue
@@ -320,7 +320,6 @@
                 encryptionTypeList: [
                     { value: '', text: '------' },
                     { value: 'Paillier', text: 'Paillier' },
-                    { value: 'IterativeAffine', text: 'IterativeAffine' },
                 ],
 
                 originForm:  { ...XGBoost },
diff --git a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/entity/contract/tool/TransactionResponseDetailInfo.java b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/entity/contract/tool/TransactionResponseDetailInfo.java
new file mode 100644
index 0000000000000000000000000000000000000000..6dfd80d1d972d61f26151b104d11d4e3d31193b1
--- /dev/null
+++ b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/entity/contract/tool/TransactionResponseDetailInfo.java
@@ -0,0 +1,83 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.common.data.mongodb.entity.contract.tool;
+
+import com.alibaba.fastjson.JSONObject;
+import com.welab.wefe.common.data.mongodb.entity.AbstractNormalMongoModel;
+
+import java.math.BigInteger;
+
+/**
+ * @author aaron.li
+ * @date 2022/1/5 15:52
+ **/
+public class TransactionResponseDetailInfo extends AbstractNormalMongoModel {
+    private BigInteger blockNumber;
+    private String transactionHash;
+    private String contractName;
+    private String contractAddress;
+    private String eventName;
+    private JSONObject data;
+
+    public BigInteger getBlockNumber() {
+        return blockNumber;
+    }
+
+    public void setBlockNumber(BigInteger blockNumber) {
+        this.blockNumber = blockNumber;
+    }
+
+    public String getContractName() {
+        return contractName;
+    }
+
+    public void setContractName(String contractName) {
+        this.contractName = contractName;
+    }
+
+    public String getContractAddress() {
+        return contractAddress;
+    }
+
+    public void setContractAddress(String contractAddress) {
+        this.contractAddress = contractAddress;
+    }
+
+    public String getEventName() {
+        return eventName;
+    }
+
+    public void setEventName(String eventName) {
+        this.eventName = eventName;
+    }
+
+    public JSONObject getData() {
+        return data;
+    }
+
+    public void setData(JSONObject data) {
+        this.data = data;
+    }
+
+    public String getTransactionHash() {
+        return transactionHash;
+    }
+
+    public void setTransactionHash(String transactionHash) {
+        this.transactionHash = transactionHash;
+    }
+}
diff --git a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncContractHeightMongoRepo.java b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncContractHeightMongoRepo.java
index 2cfa28984eecd8d8742dff4d06c3f0abdca2ffb7..c1912ba94f69209f3d83269abd7daebcc6de7082 100644
--- a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncContractHeightMongoRepo.java
+++ b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncContractHeightMongoRepo.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -35,6 +35,9 @@ public class BlockSyncContractHeightMongoRepo extends AbstractMongoRepo {
     public void upsertByGroupIdAndContractName(BlockSyncContractHeight blockSyncContractHeight) {
         BlockSyncContractHeight dbRecord = findByGroupIdAndContractName(blockSyncContractHeight.getGroupId(), blockSyncContractHeight.getContractName());
         if (dbRecord != null) {
+            if (dbRecord.getBlockNumber() >= blockSyncContractHeight.getBlockNumber()) {
+                return;
+            }
             blockSyncContractHeight.setId(dbRecord.getId());
             blockSyncContractHeight.setCreateTime(dbRecord.getCreateTime());
         }
diff --git a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncDetailInfoMongoRepo.java b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncDetailInfoMongoRepo.java
index f7aa58bd8ec5b00ec05857c86f01f28650307cfe..bf296d78de9fd6a06d72dc2b8bda88bfe7925025 100644
--- a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncDetailInfoMongoRepo.java
+++ b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncDetailInfoMongoRepo.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -35,6 +35,9 @@ public class BlockSyncDetailInfoMongoRepo extends AbstractMongoRepo {
     public void upsert(BlockSyncDetailInfo blockSyncDetailInfo) {
         BlockSyncDetailInfo dbRecord = findByGroupIdAndBlockNumber(blockSyncDetailInfo.getGroupId(), blockSyncDetailInfo.getBlockNumber());
         if (dbRecord != null) {
+            if (dbRecord.getBlockNumber() >= blockSyncDetailInfo.getBlockNumber()) {
+                return;
+            }
             blockSyncDetailInfo.setId(dbRecord.getId());
             blockSyncDetailInfo.setCreateTime(dbRecord.getCreateTime());
         }
diff --git a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncHeightMongoReop.java b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncHeightMongoReop.java
index 74c7552c8a74b3216914780cff9d05908b39026a..2c777df92cf9dcd693db8e9a6bb4554210d637b6 100644
--- a/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncHeightMongoReop.java
+++ b/common/java/common-data-mongodb/src/main/java/com/welab/wefe/common/data/mongodb/repo/BlockSyncHeightMongoReop.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -35,6 +35,9 @@ public class BlockSyncHeightMongoReop extends AbstractMongoRepo {
     public void upsert(BlockSyncHeight blockSyncHeight) {
         BlockSyncHeight dbRecord = findByGroupId(blockSyncHeight.getGroupId());
         if (dbRecord != null) {
+            if (dbRecord.getBlockNumber() >= blockSyncHeight.getBlockNumber()) {
+                return;
+            }
             blockSyncHeight.setId(dbRecord.getId());
             blockSyncHeight.setCreateTime(dbRecord.getCreateTime());
         }
diff --git a/kernel/base/params/encrypt_param.py b/kernel/base/params/encrypt_param.py
index b621dc0a9bb1db820fb69a9a661ea0a950afc35b..db6a16d554e54d3e3c93091e05e1bce9ed1ebb68 100644
--- a/kernel/base/params/encrypt_param.py
+++ b/kernel/base/params/encrypt_param.py
@@ -70,10 +70,6 @@ class EncryptParam(BaseParam):
             user_input = self.method.lower()
             if user_input == "paillier":
                 self.method = consts.PAILLIER
-            elif user_input == "iterativeaffine":
-                self.method = consts.ITERATIVEAFFINE
-            elif user_input == "randomiterativeaffine":
-                self.method = consts.RANDOM_ITERATIVEAFFINE
             else:
                 raise ValueError(
                     "encrypt_param's method {} not supported".format(user_input))
diff --git a/kernel/components/boosting/mixsecureboost/mix_decision_tree_promoter.py b/kernel/components/boosting/mixsecureboost/mix_decision_tree_promoter.py
index abd37e26be3001397c5752c2f677031ee116aea1..e515f109c8dee75f1bf5ec08e0431ae25652ba3c 100644
--- a/kernel/components/boosting/mixsecureboost/mix_decision_tree_promoter.py
+++ b/kernel/components/boosting/mixsecureboost/mix_decision_tree_promoter.py
@@ -44,7 +44,7 @@ from kernel.components.boosting.core.subsample import goss_sampling
 from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import CriterionMeta
 from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import DecisionTreeModelMeta
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import DecisionTreeModelParam
-from kernel.security.encrypt import PaillierEncrypt, IterativeAffineEncrypt
+from kernel.security.encrypt import PaillierEncrypt
 from kernel.transfer.variables.transfer_class.mix_decision_tree_transfer_variable import MixDecisionTreeTransferVariable
 from kernel.utils import consts
 from kernel.utils.data_util import NoneType
@@ -151,8 +151,6 @@ class MixDecisionTreePromoter(DecisionTree):
 
         if type(self.encrypter) == PaillierEncrypt:
             return consts.PAILLIER
-        elif type(self.encrypter) == IterativeAffineEncrypt:
-            return consts.ITERATIVEAFFINE
         else:
             raise ValueError('unknown encrypter type: {}'.format(type(self.encrypter)))
 
diff --git a/kernel/components/boosting/mixsecureboost/mix_secureboosting_promoter.py b/kernel/components/boosting/mixsecureboost/mix_secureboosting_promoter.py
index 2edd8aed2c96ad753daad0096ed003f4b507bb93..02eb5b72b36388a3fda5b9ced906bfc989970ee4 100644
--- a/kernel/components/boosting/mixsecureboost/mix_secureboosting_promoter.py
+++ b/kernel/components/boosting/mixsecureboost/mix_secureboosting_promoter.py
@@ -63,7 +63,6 @@ from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import QuantileMeta
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import BoostingTreeModelParam
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import DecisionTreeModelParam
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import FeatureImportanceInfo
-from kernel.security import IterativeAffineEncrypt
 from kernel.security import PaillierEncrypt
 from kernel.security.encrypt_mode import EncryptModeCalculator
 from kernel.transfer.framework.weights import DictWeights
@@ -241,14 +240,6 @@ class MixSecureBoostingPromoter(BoostingTree):
         if self.encrypt_param.method.lower() == consts.PAILLIER.lower():
             self.encrypter = PaillierEncrypt()
             self.encrypter.generate_key(self.encrypt_param.key_length)
-        elif self.encrypt_param.method.lower() == consts.ITERATIVEAFFINE.lower():
-            self.encrypter = IterativeAffineEncrypt()
-            self.encrypter.generate_key(key_size=self.encrypt_param.key_length,
-                                        randomized=False)
-        elif self.encrypt_param.method.lower() == consts.RANDOM_ITERATIVEAFFINE.lower():
-            self.encrypter = IterativeAffineEncrypt()
-            self.encrypter.generate_key(key_size=self.encrypt_param.key_length,
-                                        randomized=True)
         else:
             raise NotImplementedError("encrypt method not supported yes!!!")
 
diff --git a/kernel/components/boosting/mixsecureboost/mix_secureboosting_provider.py b/kernel/components/boosting/mixsecureboost/mix_secureboosting_provider.py
index 6a3c7d7596ee47596e09af647896463f78ed5d0d..0281ac8d17a47468330860a5d3ba9c023b2ec73d 100644
--- a/kernel/components/boosting/mixsecureboost/mix_secureboosting_provider.py
+++ b/kernel/components/boosting/mixsecureboost/mix_secureboosting_provider.py
@@ -280,7 +280,7 @@ class MixSecureBoostingProvider(BoostingTree):
 
     def fit_a_booster(self, epoch_idx: int, booster_dim: int):
 
-        self.check_run_sp_opt()
+        # self.check_run_sp_opt()
         tree = MixDecisionTreeProvider(tree_param=self.tree_param)
         tree.init(flowid=self.generate_flowid(epoch_idx, booster_dim),
                   valid_features=self.sample_valid_features(),
diff --git a/kernel/components/boosting/vertfastsecureboost/default_runtime.json b/kernel/components/boosting/vertfastsecureboost/default_runtime.json
index 2aec2d2409e199b0aef5320c6984b0c7bb06c218..db4f77b9f2906bbbbf5524b2a3b9823d13122eec 100644
--- a/kernel/components/boosting/vertfastsecureboost/default_runtime.json
+++ b/kernel/components/boosting/vertfastsecureboost/default_runtime.json
@@ -35,7 +35,7 @@
     ]
   },
   "encrypt_param": {
-    "method": "iterativeAffine"
+    "method": "Paillier"
   },
   "predict_param": {
     "with_proba": true,
diff --git a/kernel/components/boosting/vertfastsecureboost/vert_fast_secureboost_provider.py b/kernel/components/boosting/vertfastsecureboost/vert_fast_secureboost_provider.py
index e96c14eea63b9a520b56c48a6baceb82f4907804..066495ab7e9ebaf7a581192ec9c62d9fce442912 100644
--- a/kernel/components/boosting/vertfastsecureboost/vert_fast_secureboost_provider.py
+++ b/kernel/components/boosting/vertfastsecureboost/vert_fast_secureboost_provider.py
@@ -139,7 +139,7 @@ class VertFastSecureBoostingTreeProvider(VertSecureBoostingProvider):
 
         tree_type, target_provider_id = self.get_tree_plan(epoch_idx)
         self.check_provider_number(tree_type)
-        self.check_run_sp_opt()
+        # self.check_run_sp_opt()
         tree = VertFastDecisionTreeProvider(tree_param=self.tree_param)
         tree.init(flowid=self.generate_flowid(epoch_idx, booster_dim),
                   valid_features=self.sample_valid_features(),
diff --git a/kernel/components/boosting/vertsecureboost/default_runtime.json b/kernel/components/boosting/vertsecureboost/default_runtime.json
index 3a3b03a74f7dd7a1d94fb34a41489791f77e11f2..ea267219c09a325fcf6807b3e92cb218beb79d2b 100644
--- a/kernel/components/boosting/vertsecureboost/default_runtime.json
+++ b/kernel/components/boosting/vertsecureboost/default_runtime.json
@@ -31,7 +31,7 @@
     ]
   },
   "encrypt_param": {
-    "method": "iterativeAffine"
+    "method": "Paillier"
   },
   "predict_param": {
     "with_proba": true,
diff --git a/kernel/components/boosting/vertsecureboost/vert_decision_tree_promoter.py b/kernel/components/boosting/vertsecureboost/vert_decision_tree_promoter.py
index 0fe7ad5ca945d4074bc97c7b21f2281c955a718a..ecbe0e3927ce068c0113886117f5848805d6dfcf 100644
--- a/kernel/components/boosting/vertsecureboost/vert_decision_tree_promoter.py
+++ b/kernel/components/boosting/vertsecureboost/vert_decision_tree_promoter.py
@@ -43,7 +43,7 @@ from kernel.components.boosting.core.subsample import goss_sampling
 from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import CriterionMeta
 from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import DecisionTreeModelMeta
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import DecisionTreeModelParam
-from kernel.security.encrypt import PaillierEncrypt, IterativeAffineEncrypt
+from kernel.security.encrypt import PaillierEncrypt
 from kernel.transfer.variables.transfer_class.vert_decision_tree_transfer_variable import \
     VertDecisionTreeTransferVariable
 from kernel.utils import consts
@@ -165,8 +165,6 @@ class VertDecisionTreePromoter(DecisionTree):
 
         if type(self.encrypter) == PaillierEncrypt:
             return consts.PAILLIER
-        elif type(self.encrypter) == IterativeAffineEncrypt:
-            return consts.ITERATIVEAFFINE
         else:
             raise ValueError('unknown encrypter type: {}'.format(type(self.encrypter)))
 
diff --git a/kernel/components/boosting/vertsecureboost/vert_secureboosting_promoter.py b/kernel/components/boosting/vertsecureboost/vert_secureboosting_promoter.py
index cc039320fd80814d48df2d669c5189f70aef047b..ec0ac10c8a3bcbf9f2e98ee1e06223da0c296f01 100644
--- a/kernel/components/boosting/vertsecureboost/vert_secureboosting_promoter.py
+++ b/kernel/components/boosting/vertsecureboost/vert_secureboosting_promoter.py
@@ -63,7 +63,6 @@ from kernel.protobuf.generated.boosting_tree_model_meta_pb2 import QuantileMeta
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import BoostingTreeModelParam
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import DecisionTreeModelParam
 from kernel.protobuf.generated.boosting_tree_model_param_pb2 import FeatureImportanceInfo
-from kernel.security import IterativeAffineEncrypt
 from kernel.security import PaillierEncrypt
 from kernel.security.encrypt_mode import EncryptModeCalculator
 from kernel.transfer.variables.transfer_class.vert_secure_boost_transfer_variable import \
@@ -217,14 +216,6 @@ class VertSecureBoostingPromoter(BoostingTree):
         if self.encrypt_param.method.lower() == consts.PAILLIER.lower():
             self.encrypter = PaillierEncrypt()
             self.encrypter.generate_key(self.encrypt_param.key_length)
-        elif self.encrypt_param.method.lower() == consts.ITERATIVEAFFINE.lower():
-            self.encrypter = IterativeAffineEncrypt()
-            self.encrypter.generate_key(key_size=self.encrypt_param.key_length,
-                                        randomized=False)
-        elif self.encrypt_param.method.lower() == consts.RANDOM_ITERATIVEAFFINE.lower():
-            self.encrypter = IterativeAffineEncrypt()
-            self.encrypter.generate_key(key_size=self.encrypt_param.key_length,
-                                        randomized=True)
         else:
             raise NotImplementedError("encrypt method not supported yes!!!")
 
diff --git a/kernel/components/boosting/vertsecureboost/vert_secureboosting_provider.py b/kernel/components/boosting/vertsecureboost/vert_secureboosting_provider.py
index 9e080e971937acacd32c13425978dd896b968155..90f6310f3b51d114e9224932def683ff0743aedc 100644
--- a/kernel/components/boosting/vertsecureboost/vert_secureboosting_provider.py
+++ b/kernel/components/boosting/vertsecureboost/vert_secureboosting_provider.py
@@ -252,7 +252,7 @@ class VertSecureBoostingProvider(BoostingTree):
 
     def fit_a_booster(self, epoch_idx: int, booster_dim: int):
 
-        self.check_run_sp_opt()
+        # self.check_run_sp_opt()
         tree = VertDecisionTreeProvider(tree_param=self.tree_param)
         tree.init(flowid=self.generate_flowid(epoch_idx, booster_dim),
                   valid_features=self.sample_valid_features(),
diff --git a/kernel/components/deeplearning/vertnn/backend/tf_keras/interactive/dense_model.py b/kernel/components/deeplearning/vertnn/backend/tf_keras/interactive/dense_model.py
index 009f952ad2b216623d437d47a5c27cfd6903074d..a560346a4aa6fb95570f485d1506b03d43a0e9f0 100644
--- a/kernel/components/deeplearning/vertnn/backend/tf_keras/interactive/dense_model.py
+++ b/kernel/components/deeplearning/vertnn/backend/tf_keras/interactive/dense_model.py
@@ -263,9 +263,9 @@ class PromoterDenseModel(DenseModel):
         self.model_weight -= self.lr * delta.T
 
 
-class HostDenseModel(DenseModel):
+class ProviderDenseModel(DenseModel):
     def __init__(self):
-        super(HostDenseModel, self).__init__()
+        super(ProviderDenseModel, self).__init__()
         self.role = "provider"
 
     def select_backward_sample(self, selective_ids):
diff --git a/kernel/components/deeplearning/vertnn/model/interactive_layer.py b/kernel/components/deeplearning/vertnn/model/interactive_layer.py
index 4715aad217fdec8890195cd035946e90451db07f..a3b9dfa94c3fd0824d641ed72a822bc8ab20228b 100644
--- a/kernel/components/deeplearning/vertnn/model/interactive_layer.py
+++ b/kernel/components/deeplearning/vertnn/model/interactive_layer.py
@@ -36,7 +36,7 @@ import pickle
 import numpy as np
 
 from common.python.utils import log_utils
-from kernel.components.deeplearning.vertnn.backend.tf_keras.interactive.dense_model import HostDenseModel
+from kernel.components.deeplearning.vertnn.backend.tf_keras.interactive.dense_model import ProviderDenseModel
 from kernel.components.deeplearning.vertnn.backend.tf_keras.interactive.dense_model import PromoterDenseModel
 from kernel.components.deeplearning.vertnn.backend.tf_keras.interactive.drop_out import DropOut
 from kernel.protobuf.generated.vert_nn_model_param_pb2 import InteractiveLayerParam
@@ -96,7 +96,7 @@ class InterActivePromoterDenseLayer(object):
         self.partitions = partition
 
     def __build_model(self, restore_stage=False):
-        self.provider_model = HostDenseModel()
+        self.provider_model = ProviderDenseModel()
         self.provider_model.build(self.provider_input_shape, self.layer_config, self.model_builder, restore_stage)
         self.provider_model.set_learning_rate(self.learning_rate)
 
diff --git a/kernel/security/cipher_compressor/compressor.py b/kernel/security/cipher_compressor/compressor.py
index 6f559b046c15470bf2f2ec2c5628f73eb34a68d5..a3c71368e5dd73d6cabff91498daff23f4189bf4 100644
--- a/kernel/security/cipher_compressor/compressor.py
+++ b/kernel/security/cipher_compressor/compressor.py
@@ -142,7 +142,7 @@ class CipherCompressor(object):
         round_decimal: decimal rounding setting
         """
 
-        if cipher_type != consts.PAILLIER and cipher_type != consts.ITERATIVEAFFINE:
+        if cipher_type != consts.PAILLIER:
             raise ValueError('encrypt type {} is not supported by cipher compressing'.format(cipher_type))
 
         self._ciper_type = cipher_type
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/BlockInfoBO.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/BlockInfoBO.java
index adaf0b14fd91cfdd2c91e8b6e8aa33920a76ee19..5d900b290f372b20f5e4cf0635f487547567543f 100644
--- a/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/BlockInfoBO.java
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/BlockInfoBO.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,6 +17,7 @@
 package com.welab.wefe.bo.data;
 
 import java.math.BigInteger;
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -27,6 +28,7 @@ public class BlockInfoBO {
     private BigInteger blockNumber;
 
     private List<EventBO> eventBOList;
+    private List<TransactionResponseBO> transactionResponseBOList = new ArrayList<>();
 
     @Override
     public String toString() {
@@ -60,4 +62,12 @@ public class BlockInfoBO {
     public void setBlockNumber(BigInteger blockNumber) {
         this.blockNumber = blockNumber;
     }
+
+    public List<TransactionResponseBO> getTransactionResponseBOList() {
+        return transactionResponseBOList;
+    }
+
+    public void setTransactionResponseBOList(List<TransactionResponseBO> transactionResponseBOList) {
+        this.transactionResponseBOList = transactionResponseBOList;
+    }
 }
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/TransactionResponseBO.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/TransactionResponseBO.java
new file mode 100644
index 0000000000000000000000000000000000000000..cd2396e428a55580f80d364db9469b9223655ff5
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/bo/data/TransactionResponseBO.java
@@ -0,0 +1,73 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.bo.data;
+
+import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
+
+import java.math.BigInteger;
+
+/**
+ * @author aaron.li
+ * @date 2021/12/30 16:00
+ **/
+public class TransactionResponseBO {
+    private BigInteger blockNumber;
+    private String contractAddress;
+    private String contractName;
+    private String transactionHash;
+    private TransactionResponse transactionResponse;
+
+    public BigInteger getBlockNumber() {
+        return blockNumber;
+    }
+
+    public void setBlockNumber(BigInteger blockNumber) {
+        this.blockNumber = blockNumber;
+    }
+
+    public String getContractAddress() {
+        return contractAddress;
+    }
+
+    public void setContractAddress(String contractAddress) {
+        this.contractAddress = contractAddress;
+    }
+
+    public String getContractName() {
+        return contractName;
+    }
+
+    public void setContractName(String contractName) {
+        this.contractName = contractName;
+    }
+
+    public TransactionResponse getTransactionResponse() {
+        return transactionResponse;
+    }
+
+    public void setTransactionResponse(TransactionResponse transactionResponse) {
+        this.transactionResponse = transactionResponse;
+    }
+
+    public String getTransactionHash() {
+        return transactionHash;
+    }
+
+    public void setTransactionHash(String transactionHash) {
+        this.transactionHash = transactionHash;
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/parser/BlockInfoParser.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/parser/BlockInfoParser.java
index 6fb6a737f52748fde7e88f6d77efebf1cd27509b..2a6520cb68e0de5b0138556fc5589d4682a4421e 100644
--- a/union/blockchain-data-sync/src/main/java/com/welab/wefe/parser/BlockInfoParser.java
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/parser/BlockInfoParser.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -21,6 +21,7 @@ import com.welab.wefe.bo.contract.EventMetaInfo;
 import com.welab.wefe.bo.contract.FieldInfo;
 import com.welab.wefe.bo.data.BlockInfoBO;
 import com.welab.wefe.bo.data.EventBO;
+import com.welab.wefe.bo.data.TransactionResponseBO;
 import com.welab.wefe.common.util.DateUtil;
 import com.welab.wefe.common.util.JObject;
 import com.welab.wefe.common.util.StringUtil;
@@ -33,6 +34,8 @@ import org.fisco.bcos.sdk.client.protocol.model.JsonTransactionResponse;
 import org.fisco.bcos.sdk.client.protocol.response.BcosBlock;
 import org.fisco.bcos.sdk.client.protocol.response.BcosTransactionReceipt;
 import org.fisco.bcos.sdk.model.TransactionReceipt;
+import org.fisco.bcos.sdk.transaction.codec.decode.TransactionDecoderInterface;
+import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
 import org.fisco.bcos.sdk.transaction.model.exception.ContractException;
 import org.fisco.bcos.sdk.utils.Numeric;
 import org.slf4j.Logger;
@@ -130,6 +133,7 @@ public class BlockInfoParser {
             if (!opt.isPresent()) {
                 continue;
             }
+
             TransactionReceipt tr = opt.get();
             ContractInfo contractInfo = TransactionUtil.getContractInfoByTransaction(transaction);
             if (null == contractInfo) {
@@ -143,11 +147,37 @@ public class BlockInfoParser {
 
             // Explain the event
             eventBOList.addAll(parserEvent(tr, contractInfo));
+
+            // Explain transaction response
+            parseTransactionResponse(blockInfoBO, contractInfo, tr);
         }
 
         blockInfoBO.setEventBOList(eventBOList);
         return blockInfoBO;
     }
 
+    /**
+     * Explain transaction response
+     */
+    private void parseTransactionResponse(BlockInfoBO blockInfoBO, ContractInfo contractInfo, TransactionReceipt transactionReceipt) {
+        try {
+            String contractAbi = contractInfo.getAbi();
+            TransactionDecoderInterface decoder = SyncConstant.getCurrentContext().getDecoder();
+            TransactionResponse transactionResponse = decoder.decodeReceiptWithoutValues(contractAbi, transactionReceipt);
+            if (null == transactionResponse) {
+                return;
+            }
+            TransactionResponseBO transactionResponseBO = new TransactionResponseBO();
+            transactionResponseBO.setTransactionHash(transactionReceipt.getTransactionHash());
+            transactionResponseBO.setBlockNumber(blockInfoBO.getBlockNumber());
+            transactionResponseBO.setContractAddress(transactionReceipt.getContractAddress());
+            transactionResponseBO.setContractName(contractInfo.getContractName());
+            transactionResponseBO.setTransactionResponse(transactionResponse);
+            blockInfoBO.getTransactionResponseBOList().add(transactionResponseBO);
+        } catch (Exception e) {
+            LOG.error("Failed to explain transaction receipt: ", e);
+        }
+    }
+
 
 }
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BaseService.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BaseService.java
new file mode 100644
index 0000000000000000000000000000000000000000..29376d17b9bd9ec38cdd065b46a2056a91b3f396
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BaseService.java
@@ -0,0 +1,51 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.service;
+
+import com.welab.wefe.common.util.DateUtil;
+import com.welab.wefe.exception.BusinessException;
+import com.welab.wefe.util.WechatUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+
+import java.util.Date;
+
+/**
+ * @author aaron.li
+ * @date 2021/12/31 11:12
+ **/
+public class BaseService {
+    protected final Logger LOG = LoggerFactory.getLogger(this.getClass());
+
+    @Value("${wechat.bot-url}")
+    private String wechatUrl;
+
+    /**
+     * Send error warning
+     */
+    public void sendErrorMsg(int groupId, long blockNumber, Exception e) {
+        String errorMsg;
+        if (e instanceof BusinessException) {
+            errorMsg = "Warning!!!, Business exception! Business exception! Business exception! Important things are to be repeated for 3 times! Sync group id: " + groupId + ", block number: " + blockNumber + ", data exception: " + e.getMessage();
+        } else {
+            errorMsg = "Sync group id: " + groupId + ", block number " + blockNumber + ", data exception: " + e.getMessage();
+        }
+        errorMsg += "\n\n" + DateUtil.toStringYYYY_MM_DD_HH_MM_SS2(new Date());
+        WechatUtil.send(wechatUrl, errorMsg);
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncContractHeightService.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncContractHeightService.java
new file mode 100644
index 0000000000000000000000000000000000000000..ebc5e90c95acf8d4f0ec0e906eed3bbe151ec100
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncContractHeightService.java
@@ -0,0 +1,68 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.service;
+
+import com.welab.wefe.bo.data.BlockInfoBO;
+import com.welab.wefe.bo.data.EventBO;
+import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncContractHeight;
+import com.welab.wefe.common.data.mongodb.repo.BlockSyncContractHeightMongoRepo;
+import org.apache.commons.collections4.CollectionUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashSet;
+import java.util.List;
+import java.util.Set;
+
+/**
+ * @author aaron.li
+ * @date 2021/12/31 11:09
+ **/
+@Service
+public class BlockSyncContractHeightService extends BaseService {
+
+    @Autowired
+    private BlockSyncContractHeightMongoRepo blockSyncContractHeightMongoRepo;
+
+    /**
+     * Record the block height contract information that has been successfully synchronized
+     */
+    public void save(BlockInfoBO blockInfoBO) {
+        List<EventBO> eventBOList = blockInfoBO.getEventBOList();
+        if (CollectionUtils.isEmpty(eventBOList)) {
+            return;
+        }
+        Set<String> contractNameList = new HashSet<>(16);
+        eventBOList.forEach(x -> contractNameList.add(x.getContractName()));
+        BlockSyncContractHeight blockSyncContractHeight;
+        for (String contractName : contractNameList) {
+            blockSyncContractHeight = new BlockSyncContractHeight();
+            blockSyncContractHeight.setGroupId(blockInfoBO.getGroupId());
+            blockSyncContractHeight.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
+            blockSyncContractHeight.setContractName(contractName);
+            blockSyncContractHeightMongoRepo.upsertByGroupIdAndContractName(blockSyncContractHeight);
+        }
+    }
+
+    public BlockSyncContractHeight findByGroupIdAndContractName(Integer groupId, String contractName) {
+        return blockSyncContractHeightMongoRepo.findByGroupIdAndContractName(groupId, contractName);
+    }
+
+    public void upsertByGroupIdAndContractName(BlockSyncContractHeight blockSyncContractHeight) {
+        blockSyncContractHeightMongoRepo.upsertByGroupIdAndContractName(blockSyncContractHeight);
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncDetailInfoService.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncDetailInfoService.java
new file mode 100644
index 0000000000000000000000000000000000000000..52a57cf254d351ca5267783b334c5fd24cecddc9
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncDetailInfoService.java
@@ -0,0 +1,54 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.service;
+
+import com.welab.wefe.bo.data.BlockInfoBO;
+import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncDetailInfo;
+import com.welab.wefe.common.data.mongodb.repo.BlockSyncDetailInfoMongoRepo;
+import com.welab.wefe.common.util.JObject;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author aaron.li
+ * @date 2021/12/31 11:11
+ **/
+@Service
+public class BlockSyncDetailInfoService extends BaseService{
+    private final Logger LOG = LoggerFactory.getLogger(BlockSyncDetailInfoService.class);
+
+    @Autowired
+    private BlockSyncDetailInfoMongoRepo blockSyncDetailInfoMongoRepo;
+
+    /**
+     * Save block information
+     */
+    public void saveBlockDetailInfo(BlockInfoBO blockInfoBO) {
+        try {
+            BlockSyncDetailInfo blockSyncDetailInfo = new BlockSyncDetailInfo();
+            blockSyncDetailInfo.setGroupId(blockInfoBO.getGroupId());
+            blockSyncDetailInfo.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
+            blockSyncDetailInfo.setData(JObject.create(blockInfoBO));
+            blockSyncDetailInfoMongoRepo.upsert(blockSyncDetailInfo);
+        } catch (Exception e) {
+            LOG.error("Failed to save block detail info with group id:" + blockInfoBO.getGroupId() + ", block: " + blockInfoBO.getBlockNumber() + " , exception info: ", e);
+            sendErrorMsg(blockInfoBO.getGroupId(), blockInfoBO.getBlockNumber().longValue(), e);
+        }
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncHeightService.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncHeightService.java
new file mode 100644
index 0000000000000000000000000000000000000000..7d5e97931fef6ea1e35d24f54a2a68d67f965f70
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/BlockSyncHeightService.java
@@ -0,0 +1,47 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.service;
+
+import com.welab.wefe.bo.data.BlockInfoBO;
+import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncHeight;
+import com.welab.wefe.common.data.mongodb.repo.BlockSyncHeightMongoReop;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * @author aaron.li
+ * @date 2021/12/30 18:01
+ **/
+@Service
+public class BlockSyncHeightService extends BaseService {
+    @Autowired
+    private BlockSyncHeightMongoReop blockSyncHeightMongoReop;
+
+    /**
+     * Record the block height information that has been successfully synchronized
+     */
+    public void save(BlockInfoBO blockInfoBO) {
+        BlockSyncHeight blockSyncHeight = new BlockSyncHeight();
+        blockSyncHeight.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
+        blockSyncHeight.setGroupId(blockInfoBO.getGroupId());
+        blockSyncHeightMongoReop.upsert(blockSyncHeight);
+    }
+
+    public BlockSyncHeight findByGroupId(Integer groupId) {
+        return blockSyncHeightMongoReop.findByGroupId(groupId);
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/TransactionResponseService.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/TransactionResponseService.java
new file mode 100644
index 0000000000000000000000000000000000000000..9c6c8c169d2d92501f3766a817aa45279254ca54
--- /dev/null
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/service/TransactionResponseService.java
@@ -0,0 +1,121 @@
+/**
+ * Copyright 2021 Tianmian Tech. All Rights Reserved.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.welab.wefe.service;
+
+import com.welab.wefe.bo.data.BlockInfoBO;
+import com.welab.wefe.bo.data.TransactionResponseBO;
+import com.welab.wefe.common.data.mongodb.entity.contract.tool.TransactionResponseDetailInfo;
+import com.welab.wefe.common.data.mongodb.util.QueryBuilder;
+import com.welab.wefe.common.util.JObject;
+import com.welab.wefe.common.util.StringUtil;
+import org.apache.commons.collections4.CollectionUtils;
+import org.fisco.bcos.sdk.transaction.model.dto.TransactionResponse;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.query.Query;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Set;
+
+/**
+ * Transaction response service class
+ *
+ * @author aaron.li
+ * @date 2021/12/31 14:07
+ **/
+@Service
+public class TransactionResponseService extends BaseService {
+    private final static String COLLECTION_NAME_PREFIX = "BlockTr_";
+    private final static String EMPTY_CONTRACT_NAME = "empty";
+    private final static String EMPTY_EVENT_NAME = "empty";
+
+    @Autowired
+    protected MongoTemplate mongoTemplate;
+
+    /**
+     * save
+     */
+    public void save(BlockInfoBO blockInfoBO) {
+        try {
+            if (null == blockInfoBO) {
+                return;
+            }
+            List<TransactionResponseBO> transactionResponseBOList = blockInfoBO.getTransactionResponseBOList();
+            if (CollectionUtils.isEmpty(transactionResponseBOList)) {
+                return;
+            }
+
+            for (TransactionResponseBO transactionResponseBO : transactionResponseBOList) {
+                String eventName = getEventName(transactionResponseBO);
+                String contractName = (StringUtil.isEmpty(transactionResponseBO.getContractName()) ? EMPTY_CONTRACT_NAME : transactionResponseBO.getContractName());
+
+                TransactionResponseDetailInfo detailInfo = new TransactionResponseDetailInfo();
+                detailInfo.setTransactionHash(transactionResponseBO.getTransactionHash());
+                detailInfo.setBlockNumber(transactionResponseBO.getBlockNumber());
+                detailInfo.setContractAddress(transactionResponseBO.getContractAddress());
+                detailInfo.setContractName(contractName);
+                detailInfo.setEventName(eventName);
+                detailInfo.setData(JObject.create(JObject.toJSONString(transactionResponseBO.getTransactionResponse())));
+
+                String collectionName = buildCollectionName(contractName, eventName);
+                TransactionResponseDetailInfo historyDetailInfo = getByTransactionHash(collectionName, transactionResponseBO.getTransactionHash());
+                if (null != historyDetailInfo) {
+                    detailInfo.setId(historyDetailInfo.getId());
+                }
+                mongoTemplate.save(detailInfo, collectionName);
+            }
+        } catch (Exception e) {
+            LOG.error("Failed to save transaction response info with group id:" + blockInfoBO.getGroupId() + ", block: " + blockInfoBO.getBlockNumber() + ", exception info: ", e);
+        }
+    }
+
+
+    private TransactionResponseDetailInfo getByTransactionHash(String collectionName, String transactionHash) {
+        if (StringUtil.isEmpty(transactionHash)) {
+            return null;
+        }
+
+        Query query = new QueryBuilder().append("transactionHash", transactionHash).build();
+        return mongoTemplate.findOne(query, TransactionResponseDetailInfo.class, collectionName);
+    }
+
+    private String buildCollectionName(String contractName, String eventName) {
+        return COLLECTION_NAME_PREFIX + contractName + "_" + eventName;
+    }
+
+    /**
+     * Extract event name from transaction
+     */
+    private String getEventName(TransactionResponseBO transactionResponseBO) {
+        JObject dataObj = transactionResponseToJson(transactionResponseBO.getTransactionResponse());
+        JObject eventObj = dataObj.getJObject("event_result_map");
+        if (null == eventObj || eventObj.isEmpty()) {
+            return EMPTY_EVENT_NAME;
+        }
+        Set<String> keySet = eventObj.getInnerMap().keySet();
+        String eventName = keySet.stream().findFirst().get();
+        return StringUtil.isEmpty(eventName) ? EMPTY_EVENT_NAME : eventName;
+    }
+
+    private JObject transactionResponseToJson(TransactionResponse transactionResponse) {
+        if (null == transactionResponse) {
+            return JObject.create();
+        }
+        return JObject.create(JObject.toJSONString(transactionResponse));
+    }
+}
diff --git a/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java b/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java
index 1a0e225ec59a98d3e3655e3052da5eafdd401263..6882a1ee79b5bba251f51bbff74f9b6f82df6d2d 100644
--- a/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java
+++ b/union/blockchain-data-sync/src/main/java/com/welab/wefe/task/DataSyncTask.java
@@ -1,12 +1,12 @@
 /**
  * Copyright 2021 Tianmian Tech. All Rights Reserved.
- * 
+ *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- * 
+ *
  *     http://www.apache.org/licenses/LICENSE-2.0
- * 
+ *
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -19,23 +19,20 @@ package com.welab.wefe.task;
 import com.welab.wefe.bo.data.BlockInfoBO;
 import com.welab.wefe.bo.data.EventBO;
 import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncContractHeight;
-import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncDetailInfo;
 import com.welab.wefe.common.data.mongodb.entity.contract.tool.BlockSyncHeight;
-import com.welab.wefe.common.data.mongodb.repo.BlockSyncContractHeightMongoRepo;
-import com.welab.wefe.common.data.mongodb.repo.BlockSyncDetailInfoMongoRepo;
-import com.welab.wefe.common.data.mongodb.repo.BlockSyncHeightMongoReop;
-import com.welab.wefe.common.util.DateUtil;
-import com.welab.wefe.common.util.JObject;
 import com.welab.wefe.common.util.StringUtil;
 import com.welab.wefe.common.util.ThreadUtil;
 import com.welab.wefe.constant.BlockConstant;
 import com.welab.wefe.constant.SyncConstant;
 import com.welab.wefe.exception.BusinessException;
 import com.welab.wefe.parser.BlockInfoParser;
+import com.welab.wefe.service.BlockSyncContractHeightService;
+import com.welab.wefe.service.BlockSyncDetailInfoService;
+import com.welab.wefe.service.BlockSyncHeightService;
+import com.welab.wefe.service.TransactionResponseService;
 import com.welab.wefe.tool.DataProcessor;
 import com.welab.wefe.tool.DataSyncContext;
 import com.welab.wefe.util.BlockUtil;
-import com.welab.wefe.util.WechatUtil;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang.math.NumberUtils;
 import org.fisco.bcos.sdk.BcosSDK;
@@ -49,7 +46,8 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 import java.math.BigInteger;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * Blockchain data sync
@@ -64,13 +62,16 @@ public class DataSyncTask {
     private BcosSDK bcosSDK;
 
     @Autowired
-    private BlockSyncHeightMongoReop blockSyncHeightMongoReop;
+    private BlockSyncHeightService blockSyncHeightService;
+
+    @Autowired
+    private BlockSyncContractHeightService blockSyncContractHeightService;
 
     @Autowired
-    private BlockSyncDetailInfoMongoRepo blockSyncDetailInfoMongoRepo;
+    private BlockSyncDetailInfoService blockSyncDetailInfoService;
 
     @Autowired
-    private BlockSyncContractHeightMongoRepo blockSyncContractHeightMongoRepo;
+    private TransactionResponseService transactionResponseService;
 
     /**
      * The group ID of the sync data, separated by commas
@@ -78,23 +79,17 @@ public class DataSyncTask {
     @Value("${contract.data-sync-group-id}")
     private String dataSyncGroupId;
 
-    @Value("${wechat.bot-url}")
-    private String wechatUrl;
-
-
     public void startTask() {
         if (StringUtil.isEmpty(dataSyncGroupId) || StringUtil.isEmpty(dataSyncGroupId.trim())) {
             LOG.warn("please config data sync group id.");
             return;
         }
 
-
         String[] groupIds = dataSyncGroupId.trim().split(",");
         for (String groupId : groupIds) {
             if (!NumberUtils.isNumber(groupId)) {
                 continue;
             }
-
             cn.hutool.core.thread.ThreadUtil.execAsync(new CrawlRunner(NumberUtils.toInt(groupId)));
         }
     }
@@ -115,7 +110,7 @@ public class DataSyncTask {
                 DataSyncContext dataSyncContext = DataSyncContext.create(client);
                 SyncConstant.setCurrentContext(dataSyncContext);
                 //Query part of the data that has been synchronized
-                BlockSyncHeight blockSyncHeight = blockSyncHeightMongoReop.findByGroupId(dataSyncContext.getGroupId());
+                BlockSyncHeight blockSyncHeight = blockSyncHeightService.findByGroupId(dataSyncContext.getGroupId());
                 long startBlockNumber = (null == blockSyncHeight ? 0 : blockSyncHeight.getBlockNumber() + 1);
                 while (true) {
                     // The length of the synchronized part is greater than the current maximum length, it proves that the synchronization has been completed
@@ -137,18 +132,18 @@ public class DataSyncTask {
                         } catch (BusinessException e) {
                             LOG.error("Failed to sync data with group id: " + groupId + ", block: " + startBlockNumber + " , exception info: ", e);
                             // Business error proofs need not be repeated, Manual intervention is required
-                            sendErrorMsg(groupId, startBlockNumber, e);
+                            blockSyncHeightService.sendErrorMsg(groupId, startBlockNumber, e);
                             return;
                         } catch (Exception e) {
                             LOG.error("Failed to sync data with group id:" + groupId + ", block: " + startBlockNumber + " , exception info: ", e);
-                            sendErrorMsg(groupId, startBlockNumber, e);
+                            blockSyncHeightService.sendErrorMsg(groupId, startBlockNumber, e);
                             ThreadUtil.sleepSeconds(5);
                         }
                     }
                 }
             } catch (Exception e) {
                 LOG.error("Failed to sync data with group id:" + groupId + " exception info: ", e);
-                sendErrorMsg(groupId, -1, e);
+                blockSyncHeightService.sendErrorMsg(groupId, -1, e);
             }
         }
 
@@ -156,11 +151,11 @@ public class DataSyncTask {
          * Sync block data
          */
         private void startSync(long blockNumber) throws Exception {
+            BlockInfoBO blockInfoBO = null;
             for (int i = 0; i < 6; i++) {
                 // get block by block number
                 BcosBlock.Block block = BlockUtil.getBlock(this.client, new BigInteger(String.valueOf(blockNumber)));
-                BlockInfoBO blockInfoBO = BlockInfoParser.create(block).parse();
-
+                blockInfoBO = BlockInfoParser.create(block).parse();
                 if (CollectionUtils.isEmpty(blockInfoBO.getEventBOList())) {
                     // retry
                     Thread.sleep(500);
@@ -171,43 +166,13 @@ public class DataSyncTask {
 
                 DataProcessor.parseBlockData(filterBlockInfoBO);
 
-                saveBlockSyncHeight(blockInfoBO);
+                blockSyncHeightService.save(blockInfoBO);
 
-                saveBlockSyncContractHeight(filterBlockInfoBO);
+                blockSyncContractHeightService.save(filterBlockInfoBO);
 
-                saveBlockDetailInfo(blockInfoBO);
-            }
-        }
-
-        /**
-         * Record the block height information that has been successfully synchronized
-         */
-        private void saveBlockSyncHeight(BlockInfoBO blockInfoBO) {
-            BlockSyncHeight blockSyncHeight = new BlockSyncHeight();
-            blockSyncHeight.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
-            blockSyncHeight.setGroupId(blockInfoBO.getGroupId());
-            blockSyncHeightMongoReop.upsert(blockSyncHeight);
-        }
-
-
-        /**
-         * Record the block height contract information that has been successfully synchronized
-         */
-        private void saveBlockSyncContractHeight(BlockInfoBO blockInfoBO) {
-            List<EventBO> eventBOList = blockInfoBO.getEventBOList();
-            if (CollectionUtils.isEmpty(eventBOList)) {
-                return;
-            }
-            Set<String> contractNameList = new HashSet<>(16);
-            eventBOList.forEach(x -> contractNameList.add(x.getContractName()));
-            BlockSyncContractHeight blockSyncContractHeight;
-            for (String contractName : contractNameList) {
-                blockSyncContractHeight = new BlockSyncContractHeight();
-                blockSyncContractHeight.setGroupId(blockInfoBO.getGroupId());
-                blockSyncContractHeight.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
-                blockSyncContractHeight.setContractName(contractName);
-                blockSyncContractHeightMongoRepo.upsertByGroupIdAndContractName(blockSyncContractHeight);
+                blockSyncDetailInfoService.saveBlockDetailInfo(blockInfoBO);
             }
+            transactionResponseService.save(blockInfoBO);
         }
 
 
@@ -225,7 +190,7 @@ public class DataSyncTask {
             List<EventBO> filterResultEventBOList = new ArrayList<>();
             BlockSyncContractHeight blockSyncContractHeight;
             for (EventBO eventBO : eventBOList) {
-                blockSyncContractHeight = blockSyncContractHeightMongoRepo.findByGroupIdAndContractName(blockInfoBO.getGroupId(), eventBO.getContractName());
+                blockSyncContractHeight = blockSyncContractHeightService.findByGroupIdAndContractName(blockInfoBO.getGroupId(), eventBO.getContractName());
                 // Prove that the events of the contract have not been synchronized
                 if (null == blockSyncContractHeight || (eventBO.getBlockNumber().longValue() > blockSyncContractHeight.getBlockNumber())) {
                     filterResultEventBOList.add(eventBO);
@@ -236,35 +201,5 @@ public class DataSyncTask {
             copyBlockInfoBO.setEventBOList(filterResultEventBOList);
             return copyBlockInfoBO;
         }
-
-        /**
-         * Save block information
-         */
-        private void saveBlockDetailInfo(BlockInfoBO blockInfoBO) {
-            try {
-                BlockSyncDetailInfo blockSyncDetailInfo = new BlockSyncDetailInfo();
-                blockSyncDetailInfo.setGroupId(blockInfoBO.getGroupId());
-                blockSyncDetailInfo.setBlockNumber(blockInfoBO.getBlockNumber().longValue());
-                blockSyncDetailInfo.setData(JObject.create(blockInfoBO));
-                blockSyncDetailInfoMongoRepo.upsert(blockSyncDetailInfo);
-            } catch (Exception e) {
-                LOG.error("Failed to save block detail info with group id:" + blockInfoBO.getGroupId() + ", block: " + blockInfoBO.getBlockNumber() + " , exception info: ", e);
-                sendErrorMsg(blockInfoBO.getGroupId(), blockInfoBO.getBlockNumber().longValue(), e);
-            }
-        }
-
-        /**
-         * Send error warning
-         */
-        private void sendErrorMsg(int groupId, long blockNumber, Exception e) {
-            String errorMsg;
-            if (e instanceof BusinessException) {
-                errorMsg = "Warning!!!, Business exception! Business exception! Business exception! Important things are to be repeated for 3 times! Sync group id: " + groupId + ", block number: " + blockNumber + ", data exception: " + e.getMessage();
-            } else {
-                errorMsg = "Sync group id: " + groupId + ", block number " + blockNumber + ", data exception: " + e.getMessage();
-            }
-            errorMsg += "\n\n" + DateUtil.toStringYYYY_MM_DD_HH_MM_SS2(new Date());
-            WechatUtil.send(wechatUrl, errorMsg);
-        }
     }
 }
diff --git a/union/union-service/src/main/java/com/welab/wefe/union/service/mapper/DataSetMapper.java b/union/union-service/src/main/java/com/welab/wefe/union/service/mapper/DataSetMapper.java
index ff9608d954683b41bb861829fb5972b9ba1b519b..b7e5c8f63b611976af785d4a7dd8e6a537af1174 100644
--- a/union/union-service/src/main/java/com/welab/wefe/union/service/mapper/DataSetMapper.java
+++ b/union/union-service/src/main/java/com/welab/wefe/union/service/mapper/DataSetMapper.java
@@ -61,6 +61,9 @@ public interface DataSetMapper {
      */
     @Mappings({
             @Mapping(source = "dataSetId", target = "id"),
+            @Mapping(target = "usageCountInJob",expression = "java(com.welab.wefe.common.util.StringUtil.isEmpty(entity.getUsageCountInJob()) ? 0 : Integer.parseInt(entity.getUsageCountInJob()))"),
+            @Mapping(target = "usageCountInFlow",expression = "java(com.welab.wefe.common.util.StringUtil.isEmpty(entity.getUsageCountInFlow()) ? 0 : Integer.parseInt(entity.getUsageCountInFlow()))"),
+            @Mapping(target = "usageCountInProject",expression = "java(com.welab.wefe.common.util.StringUtil.isEmpty(entity.getUsageCountInProject()) ? 0 : Integer.parseInt(entity.getUsageCountInProject()))"),
             @Mapping(source = "createdTime", target = "createdTime", dateFormat = DateUtil.YYYY_MM_DD_HH_MM_SS2),
             @Mapping(source = "updatedTime", target = "updatedTime", dateFormat = DateUtil.YYYY_MM_DD_HH_MM_SS2),
     })