添加上链内容

3 years ago · fcc13af999
41 changed files with 3827 additions and 6 deletions
--- a/conflux-admin/pom.xml
+++ b/conflux-admin/pom.xml
@ -60,7 +60,51 @@
            <groupId>com.conflux</groupId>
            <artifactId>conflux-generator</artifactId>
        </dependency>
-
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.web3j</groupId>
+            <artifactId>core</artifactId>
+            <version>4.5.11</version>
+        </dependency>
+        <dependency>
+            <groupId>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.57</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.4</version>
+        </dependency>
+        <dependency>
+            <groupId>cn.hutool</groupId>
+            <artifactId>hutool-all</artifactId>
+            <version>5.0.6</version>
+        </dependency>
+        <dependency>
+            <groupId>commons-codec</groupId>
+            <artifactId>commons-codec</artifactId>
+            <version>1.10</version>
+        </dependency>
+        <dependency>
+            <groupId>org.bitcoinj</groupId>
+            <artifactId>bitcoinj-core</artifactId>
+            <version>0.15.3</version>
+            <scope>compile</scope>
+        </dependency>
+        <dependency>
+            <groupId>io.github.conflux-chain</groupId>
+            <artifactId>conflux.web3j</artifactId>
+            <version>1.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>com.google.code.gson</groupId>
+            <artifactId>gson</artifactId>
+            <version>2.8.2</version>
+        </dependency>
    </dependencies>

    <build>
--- a/conflux-admin/src/main/java/com/conflux/web/controller/api/ConfluxAip.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/api/ConfluxAip.java
@ -0,0 +1,26 @@
+package com.conflux.web.controller.api;
+
+import com.conflux.common.core.domain.AjaxResult;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+@RestController
+@RequestMapping("/api/conflux")
+public class ConfluxAip {
+    @PostMapping("/push")
+    public AjaxResult confluxPush(){
+
+        return null;
+    }
+    @GetMapping("/getToken")
+    public AjaxResult getToken(){
+
+        return null;
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/collect/controller/CollectConfigController.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/collect/controller/CollectConfigController.java
@ -0,0 +1,103 @@
+package com.conflux.web.controller.collect.controller;
+
+
+import com.conflux.common.annotation.Log;
+import com.conflux.common.core.controller.BaseController;
+import com.conflux.common.core.domain.AjaxResult;
+import com.conflux.common.core.page.TableDataInfo;
+import com.conflux.common.enums.BusinessType;
+import com.conflux.common.utils.poi.ExcelUtil;
+import com.conflux.web.controller.collect.domain.CollectConfig;
+import com.conflux.web.controller.collect.service.ICollectConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+/**
+ * confluxController
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+@RestController
+@RequestMapping("/conflux/collect")
+public class CollectConfigController extends BaseController
+{
+    @Autowired
+    private ICollectConfigService collectConfigService;
+
+    /**
+     * 查询conflux列表
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(CollectConfig collectConfig)
+    {
+        startPage();
+        List<CollectConfig> list = collectConfigService.selectCollectConfigList(collectConfig);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出conflux列表
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:export')")
+    @Log(title = "conflux", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, CollectConfig collectConfig)
+    {
+        List<CollectConfig> list = collectConfigService.selectCollectConfigList(collectConfig);
+        ExcelUtil<CollectConfig> util = new ExcelUtil<CollectConfig>(CollectConfig.class);
+        util.exportExcel(response, list, "conflux数据");
+    }
+
+    /**
+     * 获取conflux详细信息
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:query')")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id)
+    {
+        return AjaxResult.success(collectConfigService.selectCollectConfigById(id));
+    }
+
+    /**
+     * 新增conflux
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:add')")
+    @Log(title = "conflux", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody CollectConfig collectConfig)
+    {
+        return toAjax(collectConfigService.insertCollectConfig(collectConfig));
+    }
+
+    /**
+     * 修改conflux
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:edit')")
+    @Log(title = "conflux", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody CollectConfig collectConfig)
+    {
+        return toAjax(collectConfigService.updateCollectConfig(collectConfig));
+    }
+
+    /**
+     * 删除conflux
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:collect:remove')")
+    @Log(title = "conflux", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids)
+    {
+        return toAjax(collectConfigService.deleteCollectConfigByIds(ids));
+    }
+    @PutMapping("/changeStatus")
+    public AjaxResult changeStatus(@RequestBody CollectConfig collectConfig){
+        return toAjax(collectConfigService.changeStatus(collectConfig));
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/collect/domain/CollectConfig.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/collect/domain/CollectConfig.java
@ -0,0 +1,77 @@
+package com.conflux.web.controller.collect.domain;
+
+import com.conflux.common.annotation.Excel;
+import com.conflux.common.core.domain.BaseEntity;
+import lombok.Data;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+import java.io.Serializable;
+
+/**
+ * conflux对象 collect_config
+ *
+ * @author conflux
+ * @date 2022-05-31
+ */
+@Data
+public class CollectConfig implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Integer id;
+
+    /**
+     * node
+     */
+    @Excel(name = "node")
+    private String node;
+
+    /**
+     * limit_count
+     */
+    @Excel(name = "limit_count")
+    private Integer limitCount;
+
+    /**
+     * chain_id
+     */
+    @Excel(name = "chain_id")
+    private Integer chainId;
+
+    /**
+     * epoch_number
+     */
+    @Excel(name = "epoch_number")
+    private Long epochNumber;
+
+    /**
+     * on_pause
+     */
+    @Excel(name = "on_pause")
+    private Boolean onPause;
+
+    /**
+     * mint_pause
+     */
+    @Excel(name = "mint_pause")
+    private Boolean mintPause;
+
+    /**
+     * createTime
+     */
+    @Excel(name = "createTime")
+    private Long createTime;
+
+    /**
+     * updateTime
+     */
+    @Excel(name = "updateTime")
+    private Long updateTime;
+
+    @Excel(name = "帐号状态", readConverterExp = "0=正常,1=停用")
+    private String status;
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/collect/mapper/CollectConfigMapper.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/collect/mapper/CollectConfigMapper.java
@ -0,0 +1,66 @@
+package com.conflux.web.controller.collect.mapper;
+
+
+import com.conflux.web.controller.collect.domain.CollectConfig;
+
+import java.util.List;
+
+/**
+ * confluxMapper接口
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+public interface CollectConfigMapper 
+{
+    /**
+     * 查询conflux
+     * 
+     * @param id conflux主键
+     * @return conflux
+     */
+    public CollectConfig selectCollectConfigById(Long id);
+
+    /**
+     * 查询conflux列表
+     * 
+     * @param collectConfig conflux
+     * @return conflux集合
+     */
+    public List<CollectConfig> selectCollectConfigList(CollectConfig collectConfig);
+
+    /**
+     * 新增conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    public int insertCollectConfig(CollectConfig collectConfig);
+
+    /**
+     * 修改conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    public int updateCollectConfig(CollectConfig collectConfig);
+
+    /**
+     * 删除conflux
+     * 
+     * @param id conflux主键
+     * @return 结果
+     */
+    public int deleteCollectConfigById(Long id);
+
+    /**
+     * 批量删除conflux
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteCollectConfigByIds(Long[] ids);
+
+
+    public int updateStatus(Integer id);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/collect/service/ICollectConfigService.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/collect/service/ICollectConfigService.java
@ -0,0 +1,71 @@
+package com.conflux.web.controller.collect.service;
+
+
+import com.conflux.web.controller.collect.domain.CollectConfig;
+
+import java.util.List;
+
+/**
+ * confluxService接口
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+public interface ICollectConfigService 
+{
+    /**
+     * 查询conflux
+     * 
+     * @param id conflux主键
+     * @return conflux
+     */
+    public CollectConfig selectCollectConfigById(Long id);
+
+    /**
+     * 查询conflux列表
+     * 
+     * @param collectConfig conflux
+     * @return conflux集合
+     */
+    public List<CollectConfig> selectCollectConfigList(CollectConfig collectConfig);
+
+    /**
+     * 新增conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    public int insertCollectConfig(CollectConfig collectConfig);
+
+    /**
+     * 修改conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    public int updateCollectConfig(CollectConfig collectConfig);
+
+    /**
+     * 批量删除conflux
+     * 
+     * @param ids 需要删除的conflux主键集合
+     * @return 结果
+     */
+    public int deleteCollectConfigByIds(Long[] ids);
+
+    /**
+     * 删除conflux信息
+     * 
+     * @param id conflux主键
+     * @return 结果
+     */
+    public int deleteCollectConfigById(Long id);
+
+    /**
+     * 修改状态
+     * @param id
+     * @param status
+     * @return
+     */
+    public int changeStatus(CollectConfig collectConfig);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/collect/service/impl/CollectConfigServiceImpl.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/collect/service/impl/CollectConfigServiceImpl.java
@ -0,0 +1,106 @@
+package com.conflux.web.controller.collect.service.impl;
+
+
+import com.conflux.common.utils.DateUtils;
+import com.conflux.web.controller.collect.domain.CollectConfig;
+import com.conflux.web.controller.collect.mapper.CollectConfigMapper;
+import com.conflux.web.controller.collect.service.ICollectConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+/**
+ * confluxService业务层处理
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+@Service
+public class CollectConfigServiceImpl implements ICollectConfigService
+{
+    @Autowired
+    private CollectConfigMapper collectConfigMapper;
+
+    /**
+     * 查询conflux
+     * 
+     * @param id conflux主键
+     * @return conflux
+     */
+    @Override
+    public CollectConfig selectCollectConfigById(Long id)
+    {
+        return collectConfigMapper.selectCollectConfigById(id);
+    }
+
+    /**
+     * 查询conflux列表
+     * 
+     * @param collectConfig conflux
+     * @return conflux
+     */
+    @Override
+    public List<CollectConfig> selectCollectConfigList(CollectConfig collectConfig)
+    {
+        return collectConfigMapper.selectCollectConfigList(collectConfig);
+    }
+
+    /**
+     * 新增conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    @Override
+    public int insertCollectConfig(CollectConfig collectConfig)
+    {
+        collectConfig.setCreateTime(System.currentTimeMillis());
+        return collectConfigMapper.insertCollectConfig(collectConfig);
+    }
+
+    /**
+     * 修改conflux
+     * 
+     * @param collectConfig conflux
+     * @return 结果
+     */
+    @Override
+    public int updateCollectConfig(CollectConfig collectConfig)
+    {
+        collectConfig.setUpdateTime(System.currentTimeMillis());
+        return collectConfigMapper.updateCollectConfig(collectConfig);
+    }
+
+    /**
+     * 批量删除conflux
+     * 
+     * @param ids 需要删除的conflux主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCollectConfigByIds(Long[] ids)
+    {
+        return collectConfigMapper.deleteCollectConfigByIds(ids);
+    }
+
+    /**
+     * 删除conflux信息
+     * 
+     * @param id conflux主键
+     * @return 结果
+     */
+    @Override
+    public int deleteCollectConfigById(Long id)
+    {
+        return collectConfigMapper.deleteCollectConfigById(id);
+    }
+
+    @Override
+    @Transactional
+    public int changeStatus(CollectConfig collectConfig) {
+        collectConfigMapper.updateCollectConfig(collectConfig);
+        return collectConfigMapper.updateStatus(collectConfig.getId());//其他禁用
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/contract/controller/ContractConfigController.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/contract/controller/ContractConfigController.java
@ -0,0 +1,99 @@
+package com.conflux.web.controller.contract.controller;
+
+
+import com.conflux.common.annotation.Log;
+import com.conflux.common.core.controller.BaseController;
+import com.conflux.common.core.domain.AjaxResult;
+import com.conflux.common.core.page.TableDataInfo;
+import com.conflux.common.enums.BusinessType;
+import com.conflux.common.utils.poi.ExcelUtil;
+import com.conflux.web.controller.contract.domain.ContractConfig;
+import com.conflux.web.controller.contract.service.IContractConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.web.bind.annotation.*;
+
+import javax.servlet.http.HttpServletResponse;
+import java.util.List;
+
+/**
+ * 合约私钥配置Controller
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+@RestController
+@RequestMapping("/conflux/contract")
+public class ContractConfigController extends BaseController
+{
+    @Autowired
+    private IContractConfigService contractConfigService;
+
+    /**
+     * 查询合约私钥配置列表
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:list')")
+    @GetMapping("/list")
+    public TableDataInfo list(ContractConfig contractConfig)
+    {
+        startPage();
+        List<ContractConfig> list = contractConfigService.selectContractConfigList(contractConfig);
+        return getDataTable(list);
+    }
+
+    /**
+     * 导出合约私钥配置列表
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:export')")
+    @Log(title = "合约私钥配置", businessType = BusinessType.EXPORT)
+    @PostMapping("/export")
+    public void export(HttpServletResponse response, ContractConfig contractConfig)
+    {
+        List<ContractConfig> list = contractConfigService.selectContractConfigList(contractConfig);
+        ExcelUtil<ContractConfig> util = new ExcelUtil<ContractConfig>(ContractConfig.class);
+        util.exportExcel(response, list, "合约私钥配置数据");
+    }
+
+    /**
+     * 获取合约私钥配置详细信息
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:query')")
+    @GetMapping(value = "/{id}")
+    public AjaxResult getInfo(@PathVariable("id") Long id)
+    {
+        return AjaxResult.success(contractConfigService.selectContractConfigById(id));
+    }
+
+    /**
+     * 新增合约私钥配置
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:add')")
+    @Log(title = "合约私钥配置", businessType = BusinessType.INSERT)
+    @PostMapping
+    public AjaxResult add(@RequestBody ContractConfig contractConfig)
+    {
+        return toAjax(contractConfigService.insertContractConfig(contractConfig));
+    }
+
+    /**
+     * 修改合约私钥配置
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:edit')")
+    @Log(title = "合约私钥配置", businessType = BusinessType.UPDATE)
+    @PutMapping
+    public AjaxResult edit(@RequestBody ContractConfig contractConfig)
+    {
+        return toAjax(contractConfigService.updateContractConfig(contractConfig));
+    }
+
+    /**
+     * 删除合约私钥配置
+     */
+    @PreAuthorize("@ss.hasPermi('conflux:contract:remove')")
+    @Log(title = "合约私钥配置", businessType = BusinessType.DELETE)
+	@DeleteMapping("/{ids}")
+    public AjaxResult remove(@PathVariable Long[] ids)
+    {
+        return toAjax(contractConfigService.deleteContractConfigByIds(ids));
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/contract/domain/ContractConfig.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/contract/domain/ContractConfig.java
@ -0,0 +1,81 @@
+package com.conflux.web.controller.contract.domain;
+
+import com.conflux.common.annotation.Excel;
+import com.conflux.common.core.domain.BaseEntity;
+import org.apache.commons.lang3.builder.ToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+/**
+ * 合约私钥配置对象 contract_config
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+public class ContractConfig extends BaseEntity
+{
+    private static final long serialVersionUID = 1L;
+
+    /** $column.columnComment */
+    private Long id;
+
+    /** 合约地址 */
+    @Excel(name = "合约地址")
+    private String contract;
+
+    /** 拥有者 */
+    @Excel(name = "拥有者")
+    private String owner;
+
+    /** 私钥 */
+    @Excel(name = "私钥")
+    private String privateKey;
+
+    public void setId(Long id) 
+    {
+        this.id = id;
+    }
+
+    public Long getId() 
+    {
+        return id;
+    }
+    public void setContract(String contract) 
+    {
+        this.contract = contract;
+    }
+
+    public String getContract() 
+    {
+        return contract;
+    }
+    public void setOwner(String owner) 
+    {
+        this.owner = owner;
+    }
+
+    public String getOwner() 
+    {
+        return owner;
+    }
+    public void setPrivateKey(String privateKey) 
+    {
+        this.privateKey = privateKey;
+    }
+
+    public String getPrivateKey() 
+    {
+        return privateKey;
+    }
+
+    @Override
+    public String toString() {
+        return new ToStringBuilder(this, ToStringStyle.MULTI_LINE_STYLE)
+            .append("id", getId())
+            .append("contract", getContract())
+            .append("owner", getOwner())
+            .append("privateKey", getPrivateKey())
+            .append("createTime", getCreateTime())
+            .append("updateTime", getUpdateTime())
+            .toString();
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/contract/mapper/ContractConfigMapper.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/contract/mapper/ContractConfigMapper.java
@ -0,0 +1,63 @@
+package com.conflux.web.controller.contract.mapper;
+
+
+import com.conflux.web.controller.contract.domain.ContractConfig;
+
+import java.util.List;
+
+/**
+ * 合约私钥配置Mapper接口
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+public interface ContractConfigMapper 
+{
+    /**
+     * 查询合约私钥配置
+     * 
+     * @param id 合约私钥配置主键
+     * @return 合约私钥配置
+     */
+    public ContractConfig selectContractConfigById(Long id);
+
+    /**
+     * 查询合约私钥配置列表
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 合约私钥配置集合
+     */
+    public List<ContractConfig> selectContractConfigList(ContractConfig contractConfig);
+
+    /**
+     * 新增合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    public int insertContractConfig(ContractConfig contractConfig);
+
+    /**
+     * 修改合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    public int updateContractConfig(ContractConfig contractConfig);
+
+    /**
+     * 删除合约私钥配置
+     * 
+     * @param id 合约私钥配置主键
+     * @return 结果
+     */
+    public int deleteContractConfigById(Long id);
+
+    /**
+     * 批量删除合约私钥配置
+     * 
+     * @param ids 需要删除的数据主键集合
+     * @return 结果
+     */
+    public int deleteContractConfigByIds(Long[] ids);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/contract/service/IContractConfigService.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/contract/service/IContractConfigService.java
@ -0,0 +1,63 @@
+package com.conflux.web.controller.contract.service;
+
+
+import com.conflux.web.controller.contract.domain.ContractConfig;
+
+import java.util.List;
+
+/**
+ * 合约私钥配置Service接口
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+public interface IContractConfigService 
+{
+    /**
+     * 查询合约私钥配置
+     * 
+     * @param id 合约私钥配置主键
+     * @return 合约私钥配置
+     */
+    public ContractConfig selectContractConfigById(Long id);
+
+    /**
+     * 查询合约私钥配置列表
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 合约私钥配置集合
+     */
+    public List<ContractConfig> selectContractConfigList(ContractConfig contractConfig);
+
+    /**
+     * 新增合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    public int insertContractConfig(ContractConfig contractConfig);
+
+    /**
+     * 修改合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    public int updateContractConfig(ContractConfig contractConfig);
+
+    /**
+     * 批量删除合约私钥配置
+     * 
+     * @param ids 需要删除的合约私钥配置主键集合
+     * @return 结果
+     */
+    public int deleteContractConfigByIds(Long[] ids);
+
+    /**
+     * 删除合约私钥配置信息
+     * 
+     * @param id 合约私钥配置主键
+     * @return 结果
+     */
+    public int deleteContractConfigById(Long id);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/contract/service/impl/ContractConfigServiceImpl.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/contract/service/impl/ContractConfigServiceImpl.java
@ -0,0 +1,98 @@
+package com.conflux.web.controller.contract.service.impl;
+
+
+import com.conflux.common.utils.DateUtils;
+import com.conflux.web.controller.contract.domain.ContractConfig;
+import com.conflux.web.controller.contract.mapper.ContractConfigMapper;
+import com.conflux.web.controller.contract.service.IContractConfigService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * 合约私钥配置Service业务层处理
+ * 
+ * @author conflux
+ * @date 2022-05-31
+ */
+@Service
+public class ContractConfigServiceImpl implements IContractConfigService
+{
+    @Autowired
+    private ContractConfigMapper contractConfigMapper;
+
+    /**
+     * 查询合约私钥配置
+     * 
+     * @param id 合约私钥配置主键
+     * @return 合约私钥配置
+     */
+    @Override
+    public ContractConfig selectContractConfigById(Long id)
+    {
+        return contractConfigMapper.selectContractConfigById(id);
+    }
+
+    /**
+     * 查询合约私钥配置列表
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 合约私钥配置
+     */
+    @Override
+    public List<ContractConfig> selectContractConfigList(ContractConfig contractConfig)
+    {
+        return contractConfigMapper.selectContractConfigList(contractConfig);
+    }
+
+    /**
+     * 新增合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    @Override
+    public int insertContractConfig(ContractConfig contractConfig)
+    {
+        contractConfig.setCreateTime(DateUtils.getNowDate());
+        return contractConfigMapper.insertContractConfig(contractConfig);
+    }
+
+    /**
+     * 修改合约私钥配置
+     * 
+     * @param contractConfig 合约私钥配置
+     * @return 结果
+     */
+    @Override
+    public int updateContractConfig(ContractConfig contractConfig)
+    {
+        contractConfig.setUpdateTime(DateUtils.getNowDate());
+        return contractConfigMapper.updateContractConfig(contractConfig);
+    }
+
+    /**
+     * 批量删除合约私钥配置
+     * 
+     * @param ids 需要删除的合约私钥配置主键
+     * @return 结果
+     */
+    @Override
+    public int deleteContractConfigByIds(Long[] ids)
+    {
+        return contractConfigMapper.deleteContractConfigByIds(ids);
+    }
+
+    /**
+     * 删除合约私钥配置信息
+     * 
+     * @param id 合约私钥配置主键
+     * @return 结果
+     */
+    @Override
+    public int deleteContractConfigById(Long id)
+    {
+        return contractConfigMapper.deleteContractConfigById(id);
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/CheckArgs.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/CheckArgs.java
@ -0,0 +1,15 @@
+package com.conflux.web.controller.nft.domain;
+
+import lombok.Data;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+@Data
+public class CheckArgs {
+    private String token;
+    private String timesTamp;
+    private String sign;
+    private String[] ids;
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/ConfluxArt.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/ConfluxArt.java
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/ConfluxExecutor.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/ConfluxExecutor.java
@ -0,0 +1,74 @@
+package com.conflux.web.controller.nft.domain;
+
+import com.google.gson.Gson;
+import conflux.web3j.Account;
+import conflux.web3j.Cfx;
+import conflux.web3j.RpcException;
+import conflux.web3j.request.Call;
+import conflux.web3j.response.UsedGasAndCollateral;
+import org.web3j.abi.FunctionEncoder;
+import org.web3j.abi.TypeReference;
+import org.web3j.abi.datatypes.Address;
+import org.web3j.abi.datatypes.Type;
+import org.web3j.abi.datatypes.generated.Uint256;
+
+import java.math.BigInteger;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+public class ConfluxExecutor {
+    private Account account;
+    private String contract;
+
+    public ConfluxExecutor(Account account, String contractAddress) throws RpcException {
+        this.account = account;
+        this.contract = contractAddress;
+    }
+
+    public String mulMint(Account.Option option, String address, List<BigInteger> _tokenIds) throws Exception {
+        //String call(Account.Option option, Address contract, String method, Type<?>... inputs)
+        return this.account.call(option,
+                new conflux.web3j.types.Address(this.contract),
+                "mulMint",
+                new Address(address),
+                new org.web3j.abi.datatypes.DynamicArray<>(
+                        Uint256.class,
+                        org.web3j.abi.Utils.typeMap(_tokenIds, Uint256.class)));
+    }
+
+    /**
+     * 估算gas limit storage 出来
+     *
+     * @param cfx             cfx
+     * @param account         account
+     * @param contractAddress contractAddress
+     * @return re
+     */
+    public UsedGasAndCollateral getEstimate(Cfx cfx, conflux.web3j.types.Address account,
+                                            conflux.web3j.types.Address contractAddress,
+                                            String address,
+                                            List<BigInteger> _tokenIds) {
+        Call call = new Call();
+        call.setFrom(account);
+        call.setTo(contractAddress);
+        org.web3j.abi.datatypes.Function function = new org.web3j.abi.datatypes.Function(
+                "mulMint",
+                Arrays.<Type>asList(new Address(160, address),
+                        new org.web3j.abi.datatypes.DynamicArray<Uint256>(
+                                Uint256.class,
+                                org.web3j.abi.Utils.typeMap(_tokenIds, Uint256.class))),
+                Collections.<TypeReference<?>>emptyList());
+        String data = FunctionEncoder.encode(function);
+        System.out.println("============");
+        System.out.println(data);
+        call.setData(data);
+        System.out.println(new Gson().toJson(call));
+        return cfx.estimateGasAndCollateral(call).sendAndGet();
+    }
+
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/NftNormal.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/NftNormal.java
@ -0,0 +1,43 @@
+package com.conflux.web.controller.nft.domain;
+
+import lombok.Data;
+
+import java.util.List;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+public class NftNormal {
+    /**
+     * name : Herbie Starbelly
+     * description : Friendly OpenSea Creature that enjoys long swims in the ocean.
+     * image : https://storage.googleapis.com/opensea-prod.appspot.com/creature/50.png
+     */
+
+    private String name;
+    private String description;
+    private String image;
+    private List<Attributes> attributes;
+    /**
+     * properties : {"preview_file":{"type":"string","description":"https://metadata.boxnft.io/sh/20.jpg"},"preview_file2":{"type":"string","description":"https://metadata.boxnft.io/sh/20.mp4"},"preview_file2_type":{"type":"mimeType","description":"video/mp4"}}
+     */
+    private String animation_url;
+
+    @Override
+    public String toString() {
+        return "Nft{" +
+                "name='" + name + '\'' +
+                ", description='" + description + '\'' +
+                ", image='" + image + '\'' +
+                ", attributes=" + attributes +
+                '}';
+    }
+
+    @Data
+    public static class Attributes {
+        private String trait_type;
+        private String value;
+        private String display_type;
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/dto/NftDTO.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/dto/NftDTO.java
@ -0,0 +1,14 @@
+package com.conflux.web.controller.nft.domain.dto;
+
+import lombok.Data;
+
+import java.math.BigInteger;
+
+@Data
+public class NftDTO {
+    private String owner;
+    private BigInteger tokenId;
+    private Long updateTime;
+    private Long epochNumber;
+
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/dto/PageDTO.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/dto/PageDTO.java
@ -0,0 +1,9 @@
+package com.conflux.web.controller.nft.domain.dto;
+
+import lombok.Data;
+
+@Data
+public class PageDTO {
+    private long from;
+    private long to;
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/vo/FilterMapVO.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/domain/vo/FilterMapVO.java
@ -0,0 +1,15 @@
+package com.conflux.web.controller.nft.domain.vo;
+
+import conflux.web3j.request.LogFilter;
+import lombok.Data;
+
+import java.util.Map;
+
+/**
+ * @author yzbbanban
+ */
+@Data
+public class FilterMapVO {
+    private LogFilter logFilter;
+    private Map<String, Integer> map;
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/IRedisLimitService.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/IRedisLimitService.java
@ -0,0 +1,8 @@
+package com.conflux.web.controller.nft.redis;
+
+import com.google.common.collect.ImmutableList;
+import org.springframework.data.redis.core.script.RedisScript;
+
+public interface IRedisLimitService {
+    Number execute(RedisScript<Number> redisScript, ImmutableList<Object> keys, int limitCount, int limitPeriod);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/IRedisNft.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/IRedisNft.java
@ -0,0 +1,9 @@
+package com.conflux.web.controller.nft.redis;
+
+import java.util.List;
+
+public interface IRedisNft {
+    boolean pushNft(List<String> tokenIds);
+
+    Object popNft();
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/impl/RedisLimitServiceImpl.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/impl/RedisLimitServiceImpl.java
@ -0,0 +1,20 @@
+package com.conflux.web.controller.nft.redis.impl;
+
+import com.google.common.collect.ImmutableList;
+import com.yzb.jing.cache.redis.RedisUtils;
+import com.yzb.jing.service.redis.IRedisLimitService;
+import org.springframework.data.redis.core.script.RedisScript;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Service
+public class RedisLimitServiceImpl implements IRedisLimitService {
+    @Resource
+    private RedisUtils redisUtils;
+
+    @Override
+    public Number execute(RedisScript<Number> redisScript, ImmutableList<Object> keys, int limitCount, int limitPeriod) {
+        return redisUtils.execute(redisScript, keys, limitCount, limitPeriod);
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/impl/RedisNftImpl.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/redis/impl/RedisNftImpl.java
@ -0,0 +1,27 @@
+package com.conflux.web.controller.nft.redis.impl;
+
+
+import com.conflux.web.controller.nft.redis.IRedisNft;
+import com.conflux.web.controller.util.common.RedisConstant;
+import com.conflux.web.controller.util.redis.RedisUtils;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+@Service
+public class RedisNftImpl implements IRedisNft {
+
+    @Resource
+    private RedisUtils redisUtils;
+
+    @Override
+    public boolean pushNft(List<String> tokenIds) {
+        return redisUtils.lLeftPush(RedisConstant.NFTConstant.NFT_MINT, tokenIds) > 0;
+    }
+
+    @Override
+    public Object popNft() {
+        return redisUtils.lGetRightPop(RedisConstant.NFTConstant.NFT_MINT);
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/ConfluxService.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/ConfluxService.java
@ -0,0 +1,11 @@
+package com.conflux.web.controller.nft.service;
+
+import com.conflux.common.core.domain.AjaxResult;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+public interface ConfluxService {
+    AjaxResult getToken();
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/IHandlerStrategy.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/IHandlerStrategy.java
@ -0,0 +1,8 @@
+package com.conflux.web.controller.nft.service;
+
+
+import conflux.web3j.Cfx;
+
+public interface IHandlerStrategy {
+    boolean relayHandler(Cfx cfx, String json, int type);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/INftInfoV2Handler.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/INftInfoV2Handler.java
@ -0,0 +1,9 @@
+package com.conflux.web.controller.nft.service;
+
+
+import conflux.web3j.Cfx;
+
+public interface INftInfoV2Handler {
+
+    void send721NftTransfer(Cfx cfx, String json);
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/BaseHandler.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/BaseHandler.java
@ -0,0 +1,21 @@
+package com.conflux.web.controller.nft.service.impl;
+
+import com.google.gson.Gson;
+import conflux.web3j.response.Log;
+
+import java.util.List;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+public class BaseHandler {
+    protected Log getLogInfo(String json) {
+        return new Gson().fromJson(json, Log.class);
+    }
+
+    protected List<String> getLogTopics(String json) {
+        Log log = new Gson().fromJson(json, Log.class);
+        return log.getTopics();
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/ConfluxServiceImpl.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/ConfluxServiceImpl.java
@ -0,0 +1,45 @@
+package com.conflux.web.controller.nft.service.impl;
+
+import com.conflux.common.core.domain.AjaxResult;
+import com.conflux.common.utils.uuid.IdUtils;
+import com.conflux.web.controller.nft.domain.ConfluxArt;
+import com.conflux.web.controller.nft.service.ConfluxService;
+import com.conflux.web.controller.util.AESUtil;
+import com.conflux.web.controller.util.redis.RedisUtils;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+@Service
+@Slf4j
+public class ConfluxServiceImpl implements ConfluxService {
+    @Resource
+    private RedisUtils redisUtils;
+    @Override
+    public AjaxResult getToken() {
+        Map<String,Object> map=new HashMap<>();
+        String token = IdUtils.fastUUID();
+        long time =System.currentTimeMillis();
+
+        String decrypt=null;
+        try {
+            decrypt= AESUtil.decrypt(ConfluxArt.SIGN, ConfluxArt.AESKEY);
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.error("sign签名加密出错：{}",e.getMessage());
+        }
+        map.put("token",token);
+        map.put("timesTamp",time);
+        map.put("sign", decrypt);
+        redisUtils.set(token,token);
+        redisUtils.set("timestamp",token);
+        return AjaxResult.success(map);
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/HandlerStrategy.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/HandlerStrategy.java
@ -0,0 +1,28 @@
+package com.conflux.web.controller.nft.service.impl;
+
+import com.conflux.web.controller.nft.service.IHandlerStrategy;
+import com.conflux.web.controller.nft.service.INftInfoV2Handler;
+import conflux.web3j.Cfx;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+@Slf4j
+@Service
+public class HandlerStrategy implements IHandlerStrategy {
+
+    @Resource
+    private INftInfoV2Handler iNftInfoV2ImplHandler;
+
+    @Override
+    public boolean relayHandler(Cfx cfx, String json, int type) {
+        if (type == 20000) {
+            //nft 1155 采集
+            log.info("transfer: {}", json);
+            iNftInfoV2ImplHandler.send721NftTransfer(cfx, json);
+            return true;
+        }
+        return false;
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/NftInfoV2ImplHandler.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/nft/service/impl/NftInfoV2ImplHandler.java
@ -0,0 +1,71 @@
+package com.conflux.web.controller.nft.service.impl;
+
+import cn.hutool.core.date.DateUtil;
+import com.conflux.web.controller.nft.domain.dto.NftDTO;
+import com.conflux.web.controller.nft.service.INftInfoV2Handler;
+import com.conflux.web.controller.util.CfxUtils;
+import conflux.web3j.Cfx;
+import conflux.web3j.response.Log;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+import org.web3j.abi.FunctionReturnDecoder;
+import org.web3j.abi.TypeReference;
+import org.web3j.abi.datatypes.Address;
+
+import javax.annotation.Resource;
+import java.util.Arrays;
+import java.util.List;
+
+/**
+ * @Author _007long
+ * @Date 2022 05 31
+ **/
+@Slf4j
+@Service
+public class NftInfoV2ImplHandler extends BaseHandler implements INftInfoV2Handler {
+
+//    @Resource
+//    private WjMyCollectionService wjMyCollectionService;
+
+    /**
+     * {
+     * "address":"0x8b432262c89b58b1c808beb9df879a6134045c01",
+     * "topics":[
+     * "0xc3d58168c5ae7397731d063d5bbf3d657854427343f4c083240f7aacaa2d0f62",  topic pair   0
+     * "0x000000000000000000000000186dbddd61814ad28665afce757ae97ccf077a9b",  operator     1
+     * "0x0000000000000000000000000000000000000000000000000000000000000000",  from         2
+     * "0x000000000000000000000000186dbddd61814ad28665afce757ae97ccf077a9b"   to           3
+     * ],
+     * "data":"0x00000000000000000000000000000000000000000000000000000000000000050000000000000000000000000000000000000000000000000000000000000001",
+     * "blockHash":"0x4df4cf81f99b9f8668e615fe5f4b4e5cd56ed8ce9fd4c415231d8cfba700bc63",
+     * "epochNumber":"0x666916",
+     * "transactionHash":"0xf54026a68b55de515465bc9de30b2f9a5822db627db56014d88fc144f71bb352",
+     * "transactionIndex":"0x0",
+     * "logIndex":"0x0",
+     * "transactionLogIndex":"0x0"
+     * }
+     * 0000000000000000000000000000000000000000000000000000000000000005  id
+     * 0000000000000000000000000000000000000000000000000000000000000001  value
+     * <p>
+     * event Transfer(address indexed operator, address indexed from, address indexed to);
+     *
+     * @param json json
+     */
+    @Override
+    public void send721NftTransfer(Cfx cfx, String json) {
+        Log logInfo = getLogInfo(json);
+        NftDTO nftDTO = new NftDTO();
+        nftDTO.setOwner(decode(logInfo.getTopics().get(2)).getValue());
+        nftDTO.setTokenId(CfxUtils.getNumber(logInfo.getTopics().get(3)));
+        nftDTO.setEpochNumber(logInfo.getEpochNumber().get().longValue());
+        nftDTO.setUpdateTime(DateUtil.currentSeconds());
+        //
+        //wjMyCollectionService.updateCollect(nftDTO);
+    }
+
+    public static Address decode(String encodedResult) {
+        TypeReference returnTypeRef = TypeReference.create(Address.class);
+        List<Address> decoded = FunctionReturnDecoder.decode(encodedResult, Arrays.asList(returnTypeRef));
+        return decoded != null && !decoded.isEmpty() ? decoded.get(0) : null;
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/AESUtil.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/AESUtil.java
@ -0,0 +1,184 @@
+package com.conflux.web.controller.util;
+
+import lombok.extern.slf4j.Slf4j;
+
+import javax.crypto.Cipher;
+import javax.crypto.KeyGenerator;
+import javax.crypto.SecretKey;
+import javax.crypto.spec.SecretKeySpec;
+import java.security.SecureRandom;
+
+/**
+ * AES加密解密工具类（提供对称加密）
+ */
+@Slf4j
+public final class AESUtil {
+    // 加密密钥
+    private static String KEY = "zyxXV3mYqgEuXk02IJQnLwQ7cb2LkOSv";
+    // 默认字符集
+    private static final String DEFAULT_CHARSET = "UTF-8";
+    // 加密方式
+    private static final String KEY_AES = "AES";
+    // 加密模式
+    private static final int EN_CODE = Cipher.ENCRYPT_MODE;
+    // 解密模式
+    private static final int DE_CODE = Cipher.DECRYPT_MODE;
+
+    /**
+     * k
+     * 加密
+     *
+     * @param data 需要加密的数据
+     * @return 返回加密后的结果
+     */
+    public static String encrypt(String data) throws Exception {
+        return doAES(data, KEY, EN_CODE);
+    }
+
+    /**
+     * 解密
+     *
+     * @param data 需要解密的数据
+     * @return 返回解密后的结果
+     */
+    public static String decrypt(String data) throws Exception {
+        return doAES(data, KEY, DE_CODE);
+    }
+
+    /**
+     * 加密
+     *
+     * @param data 需要加密的数据
+     * @param key  需要加密的密钥
+     * @return 返回解密后的结果
+     */
+    public static String encrypt(String data, String key) throws Exception {
+        return doAES(data, key, EN_CODE);
+    }
+
+    /**
+     * 解密
+     *
+     * @param data 需要解密的数据
+     * @param key  需要解密的密钥
+     * @return 返回解密后的结果
+     */
+    public static String decrypt(String data, String key) throws Exception {
+        return doAES(data, key, DE_CODE);
+    }
+
+    /**
+     * 加密或解密方法
+     *
+     * @param data  需要加密或解密的内容
+     * @param key   加密或解密的密钥
+     * @param model 处理模式
+     * @return 返回处理结果
+     */
+    private static String doAES(String data, String key, final int model) throws Exception {
+        try {
+            data = data == null ? "" : data;
+            key = key == null ? "" : key;
+
+            if ("".equalsIgnoreCase(data) || "".equalsIgnoreCase(key)) {
+                return null;
+            }
+
+            // 构造密钥生成器，指定为AES方式，不区分大小写
+            KeyGenerator kgen = KeyGenerator.getInstance(KEY_AES);
+
+            // 根据EcnodeRules规则初始化密钥生成器
+            // 根据传入的字节数组，生成一个128位的随机源
+            SecureRandom random = SecureRandom.getInstance("SHA1PRNG");
+            random.setSeed(key.getBytes("UTF-8"));
+
+//            kgen.init(128, new SecureRandom(key.getBytes(DEFAULT_CHARSET)));
+
+            kgen.init(128, random);
+
+            // 产生原始对称密钥
+            SecretKey secretKey = kgen.generateKey();
+
+            // 获得原始对称密钥的字节数组
+            byte[] enCodeFormat = secretKey.getEncoded();
+
+            // 根据字节数组生成AES密钥
+            SecretKeySpec keySpec = new SecretKeySpec(enCodeFormat, KEY_AES);
+
+            // 根据指定的AES算法创建密码器
+            Cipher cipher = Cipher.getInstance(KEY_AES);
+
+            // 初始化密码器，第一个参数为加密(Encrypt_mode)或者解密解密(Decrypt_mode)操作，第二个参数为使用的KEY
+            cipher.init(model, keySpec);
+
+            byte[] content; // 用于存储加密内容
+            byte[] result;
+            switch (model) {
+                case EN_CODE:
+                    content = data.getBytes(DEFAULT_CHARSET);
+                    result = cipher.doFinal(content);
+
+                    // 将二进制转换成16进制
+                    return parseByte2HexStr(result);
+                case DE_CODE:
+                    content = parseHexStr2Byte(data);
+                    result = cipher.doFinal(content);
+
+                    // 将二进制转为字符串
+                    return new String(result, DEFAULT_CHARSET);
+                default:
+                    throw new RuntimeException("The Encrypt Model Is Wrong!");
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            log.info("====error" + org.apache.commons.lang.exception.ExceptionUtils.getFullStackTrace(e));
+            return null;
+        }
+    }
+
+    /**
+     * 将二进制转换成16进制
+     *
+     * @param buf 二进制数据
+     * @return 返回16进制结果
+     */
+    public static String parseByte2HexStr(byte[] buf) {
+        StringBuilder sb = new StringBuilder();
+        for (int i = 0; i < buf.length; i++) {
+            String hex = Integer.toHexString(buf[i] & 0xFF);
+            if (hex.length() == 1) {
+                hex = '0' + hex;
+            }
+            sb.append(hex.toUpperCase());
+        }
+        return sb.toString();
+    }
+
+    /**
+     * 将16进制转换为二进制
+     *
+     * @param hexStr 16进制字符串
+     * @return 返回二进制数据
+     */
+    public static byte[] parseHexStr2Byte(String hexStr) {
+        if (hexStr.length() < 1) {
+            return null;
+        }
+        byte[] result = new byte[hexStr.length() / 2];
+        for (int i = 0; i < hexStr.length() / 2; i++) {
+            int high = Integer.parseInt(hexStr.substring(i * 2, i * 2 + 1), 16);
+            int low = Integer.parseInt(hexStr.substring(i * 2 + 1, i * 2 + 2), 16);
+            result[i] = (byte) (high * 16 + low);
+        }
+        return result;
+    }
+
+    public static void main(String[] args) {
+        try {
+            String encrypt = encrypt("0xb9061981f2580bf01afe108e01cbd182b4c0493768698ecf0e078f329902d3cd");
+            System.err.println(encrypt);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/AddressUtil.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/AddressUtil.java
@ -0,0 +1,27 @@
+package com.conflux.web.controller.util;
+
+public class AddressUtil {
+
+
+    public static String getNewTypeAddress(String old, int chainId) {
+        conflux.web3j.types.Address a = new conflux.web3j.types.Address(old, chainId);
+        return a.getVerboseAddress();
+    }
+
+    public static String getNewAddress(String old, int chainId) {
+        conflux.web3j.types.Address a = new conflux.web3j.types.Address(old, chainId);
+        return a.getAddress();
+    }
+
+    public static String getNewAddress(String typeAddress) {
+        conflux.web3j.types.Address a = new conflux.web3j.types.Address(typeAddress);
+        return a.getAddress();
+    }
+
+
+    public static String getHexAddress(String typeAddress) {
+        conflux.web3j.types.Address a = new conflux.web3j.types.Address(typeAddress);
+        return a.getHexAddress();
+    }
+
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/CfxUtils.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/CfxUtils.java
@ -0,0 +1,149 @@
+package com.conflux.web.controller.util;
+
+import org.apache.commons.lang3.StringUtils;
+import org.web3j.abi.EventEncoder;
+import org.web3j.abi.TypeReference;
+import org.web3j.abi.datatypes.*;
+import org.web3j.abi.datatypes.generated.Bytes32;
+import org.web3j.abi.datatypes.generated.Uint256;
+import org.web3j.abi.datatypes.generated.Uint32;
+import org.web3j.utils.Numeric;
+
+import java.math.BigInteger;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @author wangban
+ */
+public class CfxUtils {
+
+    public static final String ADDRESS = "address";
+    public static final String UINT256 = "uint256";
+    public static final String UINT32 = "uint32";
+    public static final String Utf8String = "string";
+    public static final String BOOL = "bool";
+    public static final String BYTES = "bytes";
+    public static final String BYTES32 = "bytes32";
+    public static final String ARRAY = "array";
+    public static final String UINT256_ARRAY = "uint256Array";
+    public static final String ADDRESS_ARRAY = "addressArray";
+
+    public static String getEventKeccak(String method, List<String> inputParams) {
+        Event event = new Event(method, getTypes(inputParams));
+        return EventEncoder.encode(event);
+    }
+
+    public static String getUtf8String(String data) {
+        return new String(Numeric.hexStringToByteArray(data)).trim();
+    }
+
+    public static List<String> getEventParams(String data) {
+        if (data.startsWith("0x")) {
+            data = data.substring(2);
+        }
+        List<String> result = new ArrayList<>();
+        result.add(data);
+        int length = data.length() / 64;
+        for (int i = 0; i < length; i++) {
+            String param = data.substring(i * 64, (i + 1) * 64);
+            BigInteger b = new BigInteger(param, 16);
+            result.add(b.toString(16));
+        }
+//        System.out.println(result);
+        return result;
+    }
+
+    public static String getAddress(String address) {
+        if (address.length() > 42) {
+            address = address.substring(26);
+        }
+        if (address.startsWith("0x")) {
+            return address;
+        }
+        if (StringUtils.isEmpty(address) || "0".equals(address)) {
+            return "0x0000000000000000000000000000000000000000";
+        }
+        return "0x" + address;
+    }
+
+    public static void main(String[] args) {
+        System.out.println(getAddress("0x0000000000000000000000001cba0557e0b38e595588b0f8a3d7c89de992e4e3"));
+    }
+
+    public static BigInteger getChainId(BigInteger chainId){
+        if(chainId.compareTo(BigInteger.ONE)==0){
+            return new BigInteger("10001");
+        }else {
+            return new BigInteger("11029");
+        }
+    }
+
+    public static BigInteger getNumber(String num) {
+        if (num.contains("0x")) {
+            num = num.substring(2);
+        }
+        return new BigInteger(num, 16);
+    }
+
+    public static Integer getIntNumber(String num) {
+        if (num.contains("0x")) {
+            num = num.substring(2);
+        }
+        return new BigInteger(num, 16).intValue();
+    }
+
+
+    private static List<TypeReference<?>> getTypes(List<String> inputParams) {
+        List<TypeReference<?>> parameters = new ArrayList<>();
+        for (int i = 0; i < inputParams.size(); i++) {
+            String in = inputParams.get(i);
+            switch (in) {
+                case ADDRESS:
+                    parameters.add(new TypeReference<Address>() {
+                    });
+                    break;
+                case UINT256:
+                    parameters.add(new TypeReference<Uint256>() {
+                    });
+                    break;
+                case UINT32:
+                    parameters.add(new TypeReference<Uint32>() {
+                    });
+                    break;
+                case Utf8String:
+                    parameters.add(new TypeReference<org.web3j.abi.datatypes.Utf8String>() {
+                    });
+                    break;
+                case BOOL:
+                    parameters.add(new TypeReference<Bool>() {
+                    });
+                    break;
+                case BYTES:
+                    parameters.add(new TypeReference<Bytes>() {
+                    });
+                    break;
+                case BYTES32:
+                    parameters.add(new TypeReference<Bytes32>() {
+                    });
+                    break;
+                case ARRAY:
+                    parameters.add(new TypeReference<Array>() {
+                    });
+                    break;
+                case UINT256_ARRAY:
+                    parameters.add(new TypeReference<DynamicArray<Uint256>>() {
+                    });
+                    break;
+                case ADDRESS_ARRAY:
+                    parameters.add(new TypeReference<DynamicArray<Address>>() {
+                    });
+                    break;
+                default:
+                    break;
+            }
+        }
+        return parameters;
+    }
+
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/OkHttpsUtils.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/OkHttpsUtils.java
@ -0,0 +1,375 @@
+package com.conflux.web.controller.util;
+
+import com.alibaba.fastjson.JSONObject;
+import okhttp3.*;
+import org.apache.commons.lang3.StringUtils;
+
+import javax.net.ssl.*;
+import java.io.File;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.security.cert.X509Certificate;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * 网路访问
+ *
+ * @author wangban
+ * @date 11:59 2018/9/10
+ */
+public class OkHttpsUtils {
+
+    private static OkHttpClient mOkHttpClient;
+
+    /**
+     * 网络访问连接池
+     */
+    private static ConnectionPool pool;
+
+    /**
+     * get 请求
+     *
+     * @param url 请求地址
+     * @return 返回结果
+     */
+    public static String getRequest(String url, String appKey) {
+        try {
+
+            Request.Builder builder = new Request.Builder();
+            if (!StringUtils.isEmpty(appKey)) {
+                builder.addHeader("Authorization", "APPCODE" + appKey);
+            }
+            builder.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.71 Safari/537.36");
+            builder.url(url);
+            final Request request = builder.build();
+            //new call
+            Call call = getOkHttpInstance().newCall(request);
+            //请求加入调度
+            Response response = call.execute();
+            return response.body().string();
+        } catch (IOException e) {
+            e.printStackTrace();
+            return "";
+        }
+    }
+
+    /**
+     * get 请求 InputStream
+     *
+     * @param url 请求地址
+     * @return 返回结果
+     */
+    public static InputStream getInputStreamRequest(String url) {
+        try {
+
+            Request.Builder builder = new Request.Builder();
+            builder.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.71 Safari/537.36");
+            builder.url(url);
+            final Request request = builder.build();
+            //new call
+            Call call = getOkHttpInstance().newCall(request);
+            //请求加入调度
+            Response response = call.execute();
+            return response.body().byteStream();
+        } catch (IOException e) {
+            System.err.println(e.getMessage());
+            return null;
+        }
+    }
+
+    private static OkHttpClient getOkHttpInstance() {
+        if (mOkHttpClient == null) {
+            synchronized (OkHttpsUtils.class) {
+                //创建okHttpClient对象
+                mOkHttpClient = getUnsafeOkHttpClient();
+            }
+        }
+        return mOkHttpClient;
+    }
+
+
+    //okHttp3添加信任所有证书
+
+    public static OkHttpClient getUnsafeOkHttpClient() {
+
+        X509TrustManager x509 = new X509TrustManager() {
+            @Override
+            public void checkClientTrusted(X509Certificate[] chain, String authType) {
+            }
+
+            @Override
+            public void checkServerTrusted(X509Certificate[] chain, String authType) {
+            }
+
+            @Override
+            public X509Certificate[] getAcceptedIssuers() {
+                return new X509Certificate[]{};
+            }
+        };
+
+        try {
+            final TrustManager[] trustAllCerts = new TrustManager[]{x509};
+
+            final SSLContext sslContext = SSLContext.getInstance("SSL");
+            sslContext.init(null, trustAllCerts, new java.security.SecureRandom());
+            final SSLSocketFactory sslSocketFactory = sslContext.getSocketFactory();
+            OkHttpClient.Builder builder = new OkHttpClient.Builder()
+                    .connectTimeout(3, TimeUnit.MINUTES)
+                    .writeTimeout(3, TimeUnit.MINUTES)
+                    .readTimeout(3, TimeUnit.MINUTES);
+            builder.sslSocketFactory(sslSocketFactory, x509);
+
+            builder.hostnameVerifier(new HostnameVerifier() {
+                @Override
+                public boolean verify(String hostname, SSLSession session) {
+                    return true;
+                }
+            });
+
+            return builder.build();
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+
+    }
+
+    /**
+     * 获取网络访问连接池
+     *
+     * @return
+     */
+    private static ConnectionPool getConnectionPool() {
+        if (pool == null) {
+            synchronized (OkHttpsUtils.class) {
+                pool = new ConnectionPool(5, 10, TimeUnit.MINUTES);
+            }
+        }
+        return pool;
+    }
+
+
+    /**
+     * get 请求 含代理
+     *
+     * @param url 请求地址
+     * @return 返回结果
+     */
+    public static String getRequestByProxy(String url, String host, int port) {
+        try {
+            //创建okHttpClient对象
+            OkHttpClient.Builder b = new OkHttpClient.Builder();
+            Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress(host, port));
+            b.proxy(proxy);
+            //创建一个Request
+            Request.Builder builder = new Request.Builder();
+            builder.addHeader("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/39.0.2171.71 Safari/537.36");
+            builder.url(url);
+            final Request request = builder.build();
+            //new call
+            Call call = getOkHttpInstance().newCall(request);
+            //请求加入调度
+            Response response = call.execute();
+            return response.body().string();
+        } catch (IOException e) {
+            System.err.println(e.getMessage());
+            return "";
+        }
+    }
+
+
+    public static String uploadObject(String url, File file, String token) throws IOException {
+        MediaType mediaType = MediaType.parse("image/*");
+        RequestBody requestBody = RequestBody.create(mediaType, file);
+
+        Request request = new Request.Builder()
+                .url(url)
+                .post(requestBody)
+                .addHeader("Authorization", token)
+                .build();
+
+        Call call = getOkHttpInstance().newCall(request);
+        Response response = call.execute();
+        return response.body().string();
+    }
+
+    /**
+     * 一般post请求
+     *
+     * @param url    请求路径
+     * @param params 请求参数
+     * @param token  消息头
+     * @return 返回结果
+     */
+    public static String postRequest(String url, Map<String, String> params, String token) {
+        try {
+
+            FormBody.Builder formBodyBuilder = new FormBody.Builder();
+            Set<String> keySet = params.keySet();
+            for (String key : keySet) {
+                String value = params.get(key);
+                formBodyBuilder.add(key, value);
+            }
+            FormBody formBody = formBodyBuilder.build();
+
+            Request.Builder builder = new Request.Builder();
+            if (!StringUtils.isEmpty(token)) {
+                builder.addHeader("Authorization", token);
+            }
+            Request request = builder.url(url)
+                    .post(formBody).build();
+
+            Call call = getOkHttpInstance().newCall(request);
+
+            Response response = call.execute();
+            return response.body().string();
+        } catch (IOException e) {
+            e.printStackTrace();
+            return "";
+        }
+    }
+
+    /**
+     * 一般post请求
+     *
+     * @param url    请求路径
+     * @param params 请求参数
+     * @param token  消息头
+     * @return 返回结果
+     */
+    public static JSONObject postRequestObj(String url, Map<String, String> params, String token) {
+        try {
+
+            FormBody.Builder formBodyBuilder = new FormBody.Builder();
+            Set<String> keySet = params.keySet();
+            for (String key : keySet) {
+                String value = params.get(key);
+                formBodyBuilder.add(key, value);
+            }
+            FormBody formBody = formBodyBuilder.build();
+
+            Request.Builder builder = new Request.Builder();
+            if (!StringUtils.isEmpty(token)) {
+                builder.addHeader("Authorization", token);
+            }
+            Request request = builder.url(url)
+                    .post(formBody).build();
+
+            Call call = getOkHttpInstance().newCall(request);
+
+            Response response = call.execute();
+            String s = response.body().string();
+
+            return JSONObject.parseObject(s);
+        } catch (IOException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * post传json参数
+     *
+     * @param url  请求路径
+     * @param json 请求的json数据
+     * @return 返回结果
+     */
+    public static String postJsonAuth(String url, String json, String token) {
+        try {
+
+            //MediaType  设置Content-Type 标头中包含的媒体类型值
+            RequestBody requestBody = FormBody.create(MediaType.parse("application/json; charset=utf-8")
+                    , json);
+
+            Request.Builder builder = new Request.Builder();
+            if (!StringUtils.isEmpty(token)) {
+                builder.addHeader("Authorization", token);
+            }
+            Request request = builder
+                    //请求的url
+                    .url(url)
+                    .post(requestBody)
+                    .build();
+
+            //创建/Call
+            Call call = getOkHttpInstance().newCall(request);
+            Response response = call.execute();
+            return response.body().string();
+        } catch (IOException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+
+    /**
+     * post传json参数
+     *
+     * @param url  请求路径
+     * @param json 请求的json数据
+     * @return 返回结果
+     */
+    public static String postJsonResponse(String url, String json) {
+        try {
+
+            //MediaType  设置Content-Type 标头中包含的媒体类型值
+            RequestBody requestBody = FormBody.create(MediaType.parse("application/json; charset=utf-8")
+                    , json);
+
+            Request request = new Request.Builder()
+                    //请求的url
+                    .url(url)
+                    .post(requestBody)
+                    .build();
+
+            //创建/Call
+            Call call = getOkHttpInstance().newCall(request);
+            Response response = call.execute();
+            return response.body().string();
+        } catch (IOException e) {
+            e.printStackTrace();
+            return "";
+        }
+    }
+
+    /**
+     * 一般post请求
+     *
+     * @param url    请求路径
+     * @param params 请求参数
+     * @return 返回结果
+     */
+    public static String postRequest(String url, Map<String, String> params) {
+        try {
+
+            FormBody.Builder formBodyBuilder = new FormBody.Builder();
+            Set<String> keySet = params.keySet();
+            Request.Builder builder = new Request.Builder();
+            for (String key : keySet) {
+                String value = params.get(key);
+                if (!StringUtils.isEmpty(value)) {
+                    builder.addHeader(key, value);
+                }
+            }
+            FormBody formBody = formBodyBuilder.build();
+
+            Request request = builder.url(url)
+                    .post(formBody).build();
+
+            Call call = getOkHttpInstance().newCall(request);
+
+            Response response = call.execute();
+            String s = response.body().string();
+
+            return s;
+        } catch (IOException e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+}
+
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/common/RedisConstant.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/common/RedisConstant.java
@ -0,0 +1,7 @@
+package com.conflux.web.controller.util.common;
+
+public interface RedisConstant {
+    interface NFTConstant {
+        String NFT_MINT = "nft:mint";
+    }
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/redis/RedisConfig.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/redis/RedisConfig.java
@ -0,0 +1,197 @@
+package com.conflux.web.controller.util.redis;
+
+import cn.hutool.core.lang.Assert;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.parser.ParserConfig;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.codec.digest.DigestUtils;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
+import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.cache.Cache;
+import org.springframework.cache.annotation.CachingConfigurerSupport;
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.cache.interceptor.CacheErrorHandler;
+import org.springframework.cache.interceptor.KeyGenerator;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.cache.RedisCacheConfiguration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.RedisOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.serializer.RedisSerializationContext;
+import org.springframework.data.redis.serializer.RedisSerializer;
+
+import java.nio.charset.Charset;
+import java.nio.charset.StandardCharsets;
+import java.time.Duration;
+import java.util.HashMap;
+import java.util.Map;
+
+@Slf4j
+@Configuration
+@EnableCaching
+@ConditionalOnClass(RedisOperations.class)
+@EnableConfigurationProperties(RedisProperties.class)
+public class RedisConfig extends CachingConfigurerSupport {
+
+    /**
+     * 设置 redis 数据默认过期时间，默认2小时
+     * 设置@cacheable 序列化方式
+     */
+    @Bean
+    public RedisCacheConfiguration redisCacheConfiguration() {
+        FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
+        RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig();
+        configuration = configuration.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(fastJsonRedisSerializer)).entryTtl(Duration.ofHours(2));
+        return configuration;
+    }
+
+    @SuppressWarnings("all")
+    @Bean(name = "redisTemplate")
+    @ConditionalOnMissingBean(name = "redisTemplate")
+    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
+        RedisTemplate<Object, Object> template = new RedisTemplate<>();
+        //序列化
+        FastJsonRedisSerializer<Object> fastJsonRedisSerializer = new FastJsonRedisSerializer<>(Object.class);
+        // value值的序列化采用fastJsonRedisSerializer
+        template.setValueSerializer(fastJsonRedisSerializer);
+        template.setHashValueSerializer(fastJsonRedisSerializer);
+        // 全局开启AutoType，这里方便开发，使用全局的方式
+        ParserConfig.getGlobalInstance().setAutoTypeSupport(true);
+        // 建议使用这种方式，小范围指定白名单
+//        ParserConfig.getGlobalInstance().addAccept("com.yzb.dokit.entity");
+        // key的序列化采用StringRedisSerializer
+        template.setKeySerializer(new StringRedisSerializer());
+        template.setHashKeySerializer(new StringRedisSerializer());
+        template.setConnectionFactory(redisConnectionFactory);
+        return template;
+    }
+
+    /**
+     * 自定义缓存key生成策略，默认将使用该策略
+     */
+    @Bean
+    @Override
+    public KeyGenerator keyGenerator() {
+        return (target, method, params) -> {
+            Map<String, Object> container = new HashMap<>(3);
+            Class<?> targetClassClass = target.getClass();
+            // 类地址
+            container.put("class", targetClassClass.toGenericString());
+            // 方法名称
+            container.put("methodName", method.getName());
+            // 包名称
+            container.put("package", targetClassClass.getPackage());
+            // 参数列表
+            for (int i = 0; i < params.length; i++) {
+                container.put(String.valueOf(i), params[i]);
+            }
+            // 转为JSON字符串
+            String jsonString = JSON.toJSONString(container);
+            // 做SHA256 Hash计算，得到一个SHA256摘要作为Key
+            return DigestUtils.sha256Hex(jsonString);
+        };
+    }
+
+    @Bean
+    @Override
+    public CacheErrorHandler errorHandler() {
+        // 异常处理，当Redis发生异常时，打印日志，但是程序正常走
+        log.info("初始化 -> [{}]", "Redis CacheErrorHandler");
+        return new CacheErrorHandler() {
+            @Override
+            public void handleCacheGetError(RuntimeException e, Cache cache, Object key) {
+                log.error("Redis occur handleCacheGetError：key -> [{}]", key, e);
+            }
+
+            @Override
+            public void handleCachePutError(RuntimeException e, Cache cache, Object key, Object value) {
+                log.error("Redis occur handleCachePutError：key -> [{}]；value -> [{}]", key, value, e);
+            }
+
+            @Override
+            public void handleCacheEvictError(RuntimeException e, Cache cache, Object key) {
+                log.error("Redis occur handleCacheEvictError：key -> [{}]", key, e);
+            }
+
+            @Override
+            public void handleCacheClearError(RuntimeException e, Cache cache) {
+                log.error("Redis occur handleCacheClearError：", e);
+            }
+        };
+    }
+
+}
+
+/**
+ * Value 序列化
+ *
+ * @param <T>
+ * @author /
+ */
+class FastJsonRedisSerializer<T> implements RedisSerializer<T> {
+
+    private Class<T> clazz;
+
+    FastJsonRedisSerializer(Class<T> clazz) {
+        super();
+        this.clazz = clazz;
+    }
+
+    @Override
+    public byte[] serialize(T t) {
+        if (t == null) {
+            return new byte[0];
+        }
+        return JSON.toJSONString(t, SerializerFeature.WriteClassName).getBytes(StandardCharsets.UTF_8);
+    }
+
+    @Override
+    public T deserialize(byte[] bytes) {
+        if (bytes == null || bytes.length <= 0) {
+            return null;
+        }
+        String str = new String(bytes, StandardCharsets.UTF_8);
+        return JSON.parseObject(str, clazz);
+    }
+
+}
+
+/**
+ * 重写序列化器
+ *
+ * @author /
+ */
+class StringRedisSerializer implements RedisSerializer<Object> {
+
+    private final Charset charset;
+
+    StringRedisSerializer() {
+        this(StandardCharsets.UTF_8);
+    }
+
+    private StringRedisSerializer(Charset charset) {
+        Assert.notNull(charset, "Charset must not be null!");
+        this.charset = charset;
+    }
+
+    @Override
+    public String deserialize(byte[] bytes) {
+        return (bytes == null ? null : new String(bytes, charset));
+    }
+
+    @Override
+    public byte[] serialize(Object object) {
+        String string = JSON.toJSONString(object);
+        if (StringUtils.isBlank(string)) {
+            return null;
+        }
+        string = string.replace("\"", "");
+        return string.getBytes(charset);
+    }
+
+}
--- a/conflux-admin/src/main/java/com/conflux/web/controller/util/redis/RedisUtils.java
+++ b/conflux-admin/src/main/java/com/conflux/web/controller/util/redis/RedisUtils.java
@ -0,0 +1,751 @@
+package com.conflux.web.controller.util.redis;
+
+import org.springframework.cache.annotation.EnableCaching;
+import org.springframework.data.redis.connection.RedisConnection;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.Cursor;
+import org.springframework.data.redis.core.RedisConnectionUtils;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ScanOptions;
+import org.springframework.data.redis.core.script.RedisScript;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import java.util.*;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author yzb
+ * @email yzbbanban@gmail.com
+ * @date 2019/12/13
+ */
+@Component
+@SuppressWarnings({"unchecked", "all"})
+@EnableCaching
+public class RedisUtils {
+
+    private RedisTemplate<Object, Object> redisTemplate;
+
+    public RedisUtils(RedisTemplate<Object, Object> redisTemplate) {
+        this.redisTemplate = redisTemplate;
+    }
+
+    // =============================common============================
+
+    /**
+     * 指定缓存失效时间
+     *
+     * @param key  键
+     * @param time 时间(秒)
+     */
+    public boolean expire(String key, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.expire(key, time, TimeUnit.SECONDS);
+            }
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+        return true;
+    }
+
+    /**
+     * 根据 key 获取过期时间
+     *
+     * @param key 键 不能为null
+     * @return 时间(秒) 返回0代表为永久有效
+     */
+    public long getExpire(Object key) {
+        return redisTemplate.getExpire(key, TimeUnit.SECONDS);
+    }
+
+    /**
+     * 查找匹配key
+     *
+     * @param pattern key
+     * @return /
+     */
+    public List<String> scan(String pattern) {
+        ScanOptions options = ScanOptions.scanOptions().match(pattern).build();
+        RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
+        RedisConnection rc = Objects.requireNonNull(factory).getConnection();
+        Cursor<byte[]> cursor = rc.scan(options);
+        List<String> result = new ArrayList<>();
+        while (cursor.hasNext()) {
+            result.add(new String(cursor.next()));
+        }
+        try {
+            RedisConnectionUtils.releaseConnection(rc, factory);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    /**
+     * 分页查询 key
+     *
+     * @param patternKey key
+     * @param page       页码
+     * @param size       每页数目
+     * @return /
+     */
+    public List<String> findKeysForPage(String patternKey, int page, int size) {
+        ScanOptions options = ScanOptions.scanOptions().match(patternKey).build();
+        RedisConnectionFactory factory = redisTemplate.getConnectionFactory();
+        RedisConnection rc = Objects.requireNonNull(factory).getConnection();
+        Cursor<byte[]> cursor = rc.scan(options);
+        List<String> result = new ArrayList<>(size);
+        int tmpIndex = 0;
+        int fromIndex = page * size;
+        int toIndex = page * size + size;
+        while (cursor.hasNext()) {
+            if (tmpIndex >= fromIndex && tmpIndex < toIndex) {
+                result.add(new String(cursor.next()));
+                tmpIndex++;
+                continue;
+            }
+            // 获取到满足条件的数据后,就可以退出了
+            if (tmpIndex >= toIndex) {
+                break;
+            }
+            tmpIndex++;
+            cursor.next();
+        }
+        try {
+            RedisConnectionUtils.releaseConnection(rc, factory);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return result;
+    }
+
+    /**
+     * 判断key是否存在
+     *
+     * @param key 键
+     * @return true 存在 false不存在
+     */
+    public boolean hasKey(String key) {
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除缓存
+     *
+     * @param key 可以传一个值 或多个
+     */
+    public boolean del(String... key) {
+        if (key != null && key.length > 0) {
+            if (key.length == 1) {
+                return redisTemplate.delete(key[0]);
+            } else {
+                return redisTemplate.delete(CollectionUtils.arrayToList(key)) > 0;
+            }
+        }
+        return false;
+    }
+
+    // ============================String=============================
+
+    /**
+     * 普通缓存获取
+     *
+     * @param key 键
+     * @return 值
+     */
+    public Object get(String key) {
+        return key == null ? null : redisTemplate.opsForValue().get(key);
+    }
+
+    /**
+     * 批量获取
+     *
+     * @param keys
+     * @return
+     */
+    public List<Object> multiGet(List<String> keys) {
+        Object obj = redisTemplate.opsForValue().multiGet(Collections.singleton(keys));
+        return null;
+    }
+
+    /**
+     * 普通缓存放入
+     *
+     * @param key   键
+     * @param value 值
+     * @return true成功 false失败
+     */
+    public boolean set(String key, Object value) {
+        try {
+            redisTemplate.opsForValue().set(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 普通缓存放入并设置时间
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期
+     * @return true成功 false 失败
+     */
+    public boolean set(String key, Object value, long time) {
+        try {
+            if (time > 0) {
+                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
+            } else {
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 普通缓存增加并设
+     *
+     * @param key   键
+     * @param value 值
+     * @return true成功 false 失败
+     */
+    public long setIncr(String key, long value) {
+        try {
+            return redisTemplate.opsForValue().increment(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 普通缓存放入并设置时间
+     *
+     * @param key      键
+     * @param value    值
+     * @param time     时间
+     * @param timeUnit 类型
+     * @return true成功 false 失败
+     */
+    public boolean set(String key, Object value, long time, TimeUnit timeUnit) {
+        try {
+            if (time > 0) {
+                redisTemplate.opsForValue().set(key, value, time, timeUnit);
+            } else {
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    // ================================Map=================================
+
+    /**
+     * HashGet
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return 值
+     */
+    public Object hget(String key, String item) {
+        return redisTemplate.opsForHash().get(key, item);
+    }
+
+    /**
+     * 获取hashKey对应的所有键值
+     *
+     * @param key 键
+     * @return 对应的多个键值
+     */
+    public Map<Object, Object> hmget(String key) {
+        return redisTemplate.opsForHash().entries(key);
+
+    }
+
+    /**
+     * HashSet
+     *
+     * @param key 键
+     * @param map 对应多个键值
+     * @return true 成功 false 失败
+     */
+    public boolean hmset(String key, Map<String, Object> map) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * HashSet 并设置时间
+     *
+     * @param key  键
+     * @param map  对应多个键值
+     * @param time 时间(秒)
+     * @return true成功 false失败
+     */
+    public boolean hmset(String key, Map<String, Object> map, long time) {
+        try {
+            redisTemplate.opsForHash().putAll(key, map);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key, String item, Object value) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     *
+     * @param key   键
+     * @param item  项
+     * @param value 值
+     * @param time  时间(秒) 注意:如果已存在的hash表有时间,这里将会替换原有的时间
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key, String item, Object value, long time) {
+        try {
+            redisTemplate.opsForHash().put(key, item, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除hash表中的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 可以使多个 不能为null
+     */
+    public void hdel(String key, Object... item) {
+        redisTemplate.opsForHash().delete(key, item);
+    }
+
+    /**
+     * 判断hash表中是否有该项的值
+     *
+     * @param key  键 不能为null
+     * @param item 项 不能为null
+     * @return true 存在 false不存在
+     */
+    public boolean hHasKey(String key, String item) {
+        return redisTemplate.opsForHash().hasKey(key, item);
+    }
+
+    /**
+     * hash递增 如果不存在,就会创建一个 并把新增后的值返回
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要增加几(大于0)
+     * @return
+     */
+    public double hincr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, by);
+    }
+
+    /**
+     * hash递减
+     *
+     * @param key  键
+     * @param item 项
+     * @param by   要减少记(小于0)
+     * @return
+     */
+    public double hdecr(String key, String item, double by) {
+        return redisTemplate.opsForHash().increment(key, item, -by);
+    }
+
+    // ============================set=============================
+
+    /**
+     * 根据key获取Set中的所有值
+     *
+     * @param key 键
+     * @return
+     */
+    public Set<Object> sGet(String key) {
+        try {
+            return redisTemplate.opsForSet().members(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 根据value从一个set中查询,是否存在
+     *
+     * @param key   键
+     * @param value 值
+     * @return true 存在 false不存在
+     */
+    public boolean sHasKey(String key, Object value) {
+        try {
+            return redisTemplate.opsForSet().isMember(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将数据放入set缓存
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSet(String key, Object... values) {
+        try {
+            return redisTemplate.opsForSet().add(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 将set数据放入缓存
+     *
+     * @param key    键
+     * @param time   时间(秒)
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSetAndTime(String key, long time, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().add(key, values);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 获取set缓存的长度
+     *
+     * @param key 键
+     * @return
+     */
+    public long sGetSetSize(String key) {
+        try {
+            return redisTemplate.opsForSet().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 移除值为value的
+     *
+     * @param key    键
+     * @param values 值 可以是多个
+     * @return 移除的个数
+     */
+    public long setRemove(String key, Object... values) {
+        try {
+            Long count = redisTemplate.opsForSet().remove(key, values);
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    // ===============================list=================================
+
+    /**
+     * 获取list缓存的内容
+     *
+     * @param key   键
+     * @param start 开始
+     * @param end   结束 0 到 -1代表所有值
+     * @return
+     */
+    public List<Object> lGet(String key, long start, long end) {
+        try {
+            return redisTemplate.opsForList().range(key, start, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list 左边加入
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    public Long lLeftPush(String key, Object value) {
+        try {
+            return redisTemplate.opsForList().leftPush(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list 左边加入
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    public Long lRightPush(String key, Object value) {
+        try {
+            return redisTemplate.opsForList().rightPush(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+
+    /**
+     * 获取list 左边弹出
+     *
+     * @param key 键
+     * @return
+     */
+    public Object lGetLeftPop(String key) {
+        try {
+            return redisTemplate.opsForList().leftPop(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+
+    /**
+     * 获取list 右边弹出
+     *
+     * @param key 键
+     * @return
+     */
+    public Object lGetRightPop(String key) {
+        try {
+            return redisTemplate.opsForList().rightPop(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list缓存的长度
+     *
+     * @param key 键
+     * @return
+     */
+    public long lGetListSize(String key) {
+        try {
+            return redisTemplate.opsForList().size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 通过索引 获取list中的值
+     *
+     * @param key   键
+     * @param index 索引 index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
+     * @return
+     */
+    public Object lGetIndex(String key, long index) {
+        try {
+            return redisTemplate.opsForList().index(key, index);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    public boolean lSet(String key, Object value) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, Object value, long time) {
+        try {
+            redisTemplate.opsForList().rightPush(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    public boolean lSet(String key, List<Object> value) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     *
+     * @param key   键
+     * @param value 值
+     * @param time  时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, List<Object> value, long time) {
+        try {
+            redisTemplate.opsForList().rightPushAll(key, value);
+            if (time > 0) {
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据索引修改list中的某条数据
+     *
+     * @param key   键
+     * @param index 索引
+     * @param value 值
+     * @return /
+     */
+    public boolean lUpdateIndex(String key, long index, Object value) {
+        try {
+            redisTemplate.opsForList().set(key, index, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 移除N个值为value
+     *
+     * @param key   键
+     * @param count 移除多少个
+     * @param value 值
+     * @return 移除的个数
+     */
+    public long lRemove(String key, long count, Object value) {
+        try {
+            return redisTemplate.opsForList().remove(key, count, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+
+    /**
+     * 将list放入缓存 zset
+     *
+     * @param key   键
+     * @param value 值
+     * @return
+     */
+    public boolean zSet(String key, Object value, double time) {
+        try {
+            redisTemplate.opsForZSet().add(key, value, time);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    public Number execute(RedisScript<Number> redisScript, List<Object> keys, int limitCount, int limitPeriod) {
+        return redisTemplate.execute(redisScript, keys, limitCount, limitPeriod);
+    }
+}
--- a/conflux-common/pom.xml
+++ b/conflux-common/pom.xml
@ -124,7 +124,6 @@
            <groupId>javax.servlet</groupId>
            <artifactId>javax.servlet-api</artifactId>
        </dependency>
-
    </dependencies>

 </project>
--- a/conflux-system/src/main/resources/mapper/system/CollectConfigMapper.xml
+++ b/conflux-system/src/main/resources/mapper/system/CollectConfigMapper.xml
@ -0,0 +1,95 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.conflux.web.controller.collect.mapper.CollectConfigMapper">
+    
+    <resultMap type="CollectConfig" id="CollectConfigResult">
+        <result property="id"    column="id"    />
+        <result property="node"    column="node"    />
+        <result property="limitCount"    column="limit_count"    />
+        <result property="chainId"    column="chain_id"    />
+        <result property="epochNumber"    column="epoch_number"    />
+        <result property="onPause"    column="on_pause"    />
+        <result property="mintPause"    column="mint_pause"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+    </resultMap>
+
+    <sql id="selectCollectConfigVo">
+        select id, node, limit_count, chain_id, epoch_number, on_pause, mint_pause, create_time, update_time from collect_config
+    </sql>
+
+    <select id="selectCollectConfigList" parameterType="CollectConfig" resultMap="CollectConfigResult">
+        <include refid="selectCollectConfigVo"/>
+        <where>  
+            <if test="node != null  and node != ''"> and node = #{node}</if>
+            <if test="limitCount != null "> and limit_count = #{limitCount}</if>
+            <if test="chainId != null "> and chain_id = #{chainId}</if>
+            <if test="epochNumber != null "> and epoch_number = #{epochNumber}</if>
+            <if test="onPause != null "> and on_pause = #{onPause}</if>
+            <if test="mintPause != null "> and mint_pause = #{mintPause}</if>
+        </where>
+    </select>
+    
+    <select id="selectCollectConfigById" parameterType="Long" resultMap="CollectConfigResult">
+        <include refid="selectCollectConfigVo"/>
+        where id = #{id}
+    </select>
+        
+    <insert id="insertCollectConfig" parameterType="CollectConfig" useGeneratedKeys="true" keyProperty="id">
+        insert into collect_config
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="node != null">node,</if>
+            <if test="limitCount != null">limit_count,</if>
+            <if test="chainId != null">chain_id,</if>
+            <if test="epochNumber != null">epoch_number,</if>
+            <if test="onPause != null">on_pause,</if>
+            <if test="mintPause != null">mint_pause,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateTime != null">update_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="node != null">#{node},</if>
+            <if test="limitCount != null">#{limitCount},</if>
+            <if test="chainId != null">#{chainId},</if>
+            <if test="epochNumber != null">#{epochNumber},</if>
+            <if test="onPause != null">#{onPause},</if>
+            <if test="mintPause != null">#{mintPause},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateCollectConfig" parameterType="CollectConfig">
+        update collect_config
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="node != null">node = #{node},</if>
+            <if test="limitCount != null">limit_count = #{limitCount},</if>
+            <if test="chainId != null">chain_id = #{chainId},</if>
+            <if test="epochNumber != null">epoch_number = #{epochNumber},</if>
+            <if test="onPause != null">on_pause = #{onPause},</if>
+            <if test="mintPause != null">mint_pause = #{mintPause},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+            <if test="status != null">status = #{status},</if>
+        </trim>
+        where id = #{id}
+    </update>
+    <update id="updateStatus">
+        update collect_config
+           set status =1
+        where id != #{id}
+    </update>
+
+    <delete id="deleteCollectConfigById" parameterType="Long">
+        delete from collect_config where id = #{id}
+    </delete>
+
+    <delete id="deleteCollectConfigByIds" parameterType="String">
+        delete from collect_config where id in 
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
--- a/conflux-system/src/main/resources/mapper/system/ContractConfigMapper.xml
+++ b/conflux-system/src/main/resources/mapper/system/ContractConfigMapper.xml
@ -0,0 +1,74 @@
+<?xml version="1.0" encoding="UTF-8" ?>
+<!DOCTYPE mapper
+PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.conflux.web.controller.contract.mapper.ContractConfigMapper">
+    
+    <resultMap type="ContractConfig" id="ContractConfigResult">
+        <result property="id"    column="id"    />
+        <result property="contract"    column="contract"    />
+        <result property="owner"    column="owner"    />
+        <result property="privateKey"    column="private_key"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateTime"    column="update_time"    />
+    </resultMap>
+
+    <sql id="selectContractConfigVo">
+        select id, contract, owner, private_key, create_time, update_time from contract_config
+    </sql>
+
+    <select id="selectContractConfigList" parameterType="ContractConfig" resultMap="ContractConfigResult">
+        <include refid="selectContractConfigVo"/>
+        <where>  
+            <if test="contract != null  and contract != ''"> and contract = #{contract}</if>
+            <if test="owner != null  and owner != ''"> and owner = #{owner}</if>
+            <if test="privateKey != null  and privateKey != ''"> and private_key = #{privateKey}</if>
+        </where>
+    </select>
+    
+    <select id="selectContractConfigById" parameterType="Long" resultMap="ContractConfigResult">
+        <include refid="selectContractConfigVo"/>
+        where id = #{id}
+    </select>
+        
+    <insert id="insertContractConfig" parameterType="ContractConfig" useGeneratedKeys="true" keyProperty="id">
+        insert into contract_config
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="contract != null">contract,</if>
+            <if test="owner != null">owner,</if>
+            <if test="privateKey != null">private_key,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateTime != null">update_time,</if>
+         </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="contract != null">#{contract},</if>
+            <if test="owner != null">#{owner},</if>
+            <if test="privateKey != null">#{privateKey},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+         </trim>
+    </insert>
+
+    <update id="updateContractConfig" parameterType="ContractConfig">
+        update contract_config
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="contract != null">contract = #{contract},</if>
+            <if test="owner != null">owner = #{owner},</if>
+            <if test="privateKey != null">private_key = #{privateKey},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteContractConfigById" parameterType="Long">
+        delete from contract_config where id = #{id}
+    </delete>
+
+    <delete id="deleteContractConfigByIds" parameterType="String">
+        delete from contract_config where id in 
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
+</mapper>
--- a/pom.xml
+++ b/pom.xml
@ -32,6 +32,7 @@
        <poi.version>4.1.2</poi.version>
        <velocity.version>2.3</velocity.version>
        <jwt.version>0.9.1</jwt.version>
+        <mybatis-plus.version>3.4.3.1</mybatis-plus.version>
    </properties>
 	
    <!-- 依赖声明 -->
@ -62,12 +63,17 @@
            </dependency>

            <!-- SpringBoot集成mybatis框架 -->
+<!--            <dependency>-->
+<!--                <groupId>org.mybatis.spring.boot</groupId>-->
+<!--                <artifactId>mybatis-spring-boot-starter</artifactId>-->
+<!--                <version>${mybatis-spring-boot.version}</version>-->
+<!--            </dependency>-->
+            <!-- mybatis-plus -->
            <dependency>
-                <groupId>org.mybatis.spring.boot</groupId>
-                <artifactId>mybatis-spring-boot-starter</artifactId>
-                <version>${mybatis-spring-boot.version}</version>
+                <groupId>com.baomidou</groupId>
+                <artifactId>mybatis-plus-boot-starter</artifactId>
+                <version>${mybatis-plus.version}</version>
            </dependency>
-
            <!-- pagehelper 分页插件 -->
            <dependency>
                <groupId>com.github.pagehelper</groupId>