long
3 years ago
25 changed files with 962 additions and 88 deletions
@ -0,0 +1,104 @@ |
|||||||
|
package com.conflux.web.controller.privateKey.controller; |
||||||
|
|
||||||
|
import java.util.List; |
||||||
|
import javax.servlet.http.HttpServletResponse; |
||||||
|
import org.springframework.security.access.prepost.PreAuthorize; |
||||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||||
|
import org.springframework.web.bind.annotation.GetMapping; |
||||||
|
import org.springframework.web.bind.annotation.PostMapping; |
||||||
|
import org.springframework.web.bind.annotation.PutMapping; |
||||||
|
import org.springframework.web.bind.annotation.DeleteMapping; |
||||||
|
import org.springframework.web.bind.annotation.PathVariable; |
||||||
|
import org.springframework.web.bind.annotation.RequestBody; |
||||||
|
import org.springframework.web.bind.annotation.RequestMapping; |
||||||
|
import org.springframework.web.bind.annotation.RestController; |
||||||
|
import com.conflux.common.annotation.Log; |
||||||
|
import com.conflux.common.core.controller.BaseController; |
||||||
|
import com.conflux.common.core.domain.AjaxResult; |
||||||
|
import com.conflux.common.enums.BusinessType; |
||||||
|
import com.conflux.web.controller.privateKey.domain.PrivateKey; |
||||||
|
import com.conflux.web.controller.privateKey.service.IPrivateKeyService; |
||||||
|
import com.conflux.common.utils.poi.ExcelUtil; |
||||||
|
import com.conflux.common.core.page.TableDataInfo; |
||||||
|
|
||||||
|
/** |
||||||
|
* 私钥申请Controller |
||||||
|
* |
||||||
|
* @author conflux |
||||||
|
* @date 2022-06-07 |
||||||
|
*/ |
||||||
|
@RestController |
||||||
|
@RequestMapping("/conflux/key") |
||||||
|
public class PrivateKeyController extends BaseController |
||||||
|
{ |
||||||
|
@Autowired |
||||||
|
private IPrivateKeyService privateKeyService; |
||||||
|
|
||||||
|
/** |
||||||
|
* 查询私钥申请列表 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:list')") |
||||||
|
@GetMapping("/list") |
||||||
|
public TableDataInfo list(PrivateKey privateKey) |
||||||
|
{ |
||||||
|
startPage(); |
||||||
|
List<PrivateKey> list = privateKeyService.selectPrivateKeyList(privateKey); |
||||||
|
return getDataTable(list); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 导出私钥申请列表 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:export')") |
||||||
|
@Log(title = "私钥申请", businessType = BusinessType.EXPORT) |
||||||
|
@PostMapping("/export") |
||||||
|
public void export(HttpServletResponse response, PrivateKey privateKey) |
||||||
|
{ |
||||||
|
List<PrivateKey> list = privateKeyService.selectPrivateKeyList(privateKey); |
||||||
|
ExcelUtil<PrivateKey> util = new ExcelUtil<PrivateKey>(PrivateKey.class); |
||||||
|
util.exportExcel(response, list, "私钥申请数据"); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 获取私钥申请详细信息 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:query')") |
||||||
|
@GetMapping(value = "/{id}") |
||||||
|
public AjaxResult getInfo(@PathVariable("id") Long id) |
||||||
|
{ |
||||||
|
return AjaxResult.success(privateKeyService.selectPrivateKeyById(id)); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 新增私钥申请 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:add')") |
||||||
|
@Log(title = "私钥申请", businessType = BusinessType.INSERT) |
||||||
|
@PostMapping |
||||||
|
public AjaxResult add(@RequestBody PrivateKey privateKey) |
||||||
|
{ |
||||||
|
return toAjax(privateKeyService.insertPrivateKey(privateKey)); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 修改私钥申请 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:edit')") |
||||||
|
@Log(title = "私钥申请", businessType = BusinessType.UPDATE) |
||||||
|
@PutMapping |
||||||
|
public AjaxResult edit(@RequestBody PrivateKey privateKey) |
||||||
|
{ |
||||||
|
return toAjax(privateKeyService.updatePrivateKey(privateKey)); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 删除私钥申请 |
||||||
|
*/ |
||||||
|
@PreAuthorize("@ss.hasPermi('system:key:remove')") |
||||||
|
@Log(title = "私钥申请", businessType = BusinessType.DELETE) |
||||||
|
@DeleteMapping("/{ids}") |
||||||
|
public AjaxResult remove(@PathVariable Long[] ids) |
||||||
|
{ |
||||||
|
return toAjax(privateKeyService.deletePrivateKeyByIds(ids)); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,37 @@ |
|||||||
|
package com.conflux.web.controller.privateKey.domain; |
||||||
|
|
||||||
|
import com.conflux.common.annotation.Excel; |
||||||
|
import com.conflux.common.core.domain.BaseEntity; |
||||||
|
import lombok.Data; |
||||||
|
|
||||||
|
/** |
||||||
|
* 私钥申请对象 private_key |
||||||
|
* |
||||||
|
* @author conflux |
||||||
|
* @date 2022-06-07 |
||||||
|
*/ |
||||||
|
@Data |
||||||
|
public class PrivateKey extends BaseEntity |
||||||
|
{ |
||||||
|
private static final long serialVersionUID = 1L; |
||||||
|
|
||||||
|
/** */ |
||||||
|
private Long id; |
||||||
|
|
||||||
|
/** 项目名称 */ |
||||||
|
@Excel(name = "项目名称") |
||||||
|
private String unitName; |
||||||
|
|
||||||
|
/** appid */ |
||||||
|
@Excel(name = "appid") |
||||||
|
private String appId; |
||||||
|
|
||||||
|
/** 私钥 */ |
||||||
|
@Excel(name = "私钥") |
||||||
|
private String privateKey; |
||||||
|
|
||||||
|
/** 0正常1禁用 */ |
||||||
|
@Excel(name = "0正常1禁用") |
||||||
|
private String stauts; |
||||||
|
|
||||||
|
} |
||||||
@ -0,0 +1,68 @@ |
|||||||
|
package com.conflux.web.controller.privateKey.mapper; |
||||||
|
|
||||||
|
import java.util.List; |
||||||
|
import com.conflux.web.controller.privateKey.domain.PrivateKey; |
||||||
|
|
||||||
|
/** |
||||||
|
* 私钥申请Mapper接口 |
||||||
|
* |
||||||
|
* @author conflux |
||||||
|
* @date 2022-06-07 |
||||||
|
*/ |
||||||
|
public interface PrivateKeyMapper |
||||||
|
{ |
||||||
|
/** |
||||||
|
* 查询私钥申请 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 私钥申请 |
||||||
|
*/ |
||||||
|
public PrivateKey selectPrivateKeyById(Long id); |
||||||
|
|
||||||
|
/** |
||||||
|
* 通过appid查询 |
||||||
|
* @param appId |
||||||
|
* @return |
||||||
|
*/ |
||||||
|
public PrivateKey selectPrivateKeyByAppId(String appId); |
||||||
|
|
||||||
|
/** |
||||||
|
* 查询私钥申请列表 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 私钥申请集合 |
||||||
|
*/ |
||||||
|
public List<PrivateKey> selectPrivateKeyList(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 新增私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int insertPrivateKey(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 修改私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int updatePrivateKey(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 删除私钥申请 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int deletePrivateKeyById(Long id); |
||||||
|
|
||||||
|
/** |
||||||
|
* 批量删除私钥申请 |
||||||
|
* |
||||||
|
* @param ids 需要删除的数据主键集合 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int deletePrivateKeyByIds(Long[] ids); |
||||||
|
} |
||||||
@ -0,0 +1,67 @@ |
|||||||
|
package com.conflux.web.controller.privateKey.service; |
||||||
|
|
||||||
|
import java.util.List; |
||||||
|
import com.conflux.web.controller.privateKey.domain.PrivateKey; |
||||||
|
|
||||||
|
/** |
||||||
|
* 私钥申请Service接口 |
||||||
|
* |
||||||
|
* @author conflux |
||||||
|
* @date 2022-06-07 |
||||||
|
*/ |
||||||
|
public interface IPrivateKeyService |
||||||
|
{ |
||||||
|
/** |
||||||
|
* 查询私钥申请 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 私钥申请 |
||||||
|
*/ |
||||||
|
public PrivateKey selectPrivateKeyById(Long id); |
||||||
|
|
||||||
|
/** |
||||||
|
* 通过appid查询 |
||||||
|
* @param appId |
||||||
|
* @return |
||||||
|
*/ |
||||||
|
public PrivateKey selectPrivateKeyByAppId(String appId); |
||||||
|
/** |
||||||
|
* 查询私钥申请列表 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 私钥申请集合 |
||||||
|
*/ |
||||||
|
public List<PrivateKey> selectPrivateKeyList(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 新增私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int insertPrivateKey(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 修改私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int updatePrivateKey(PrivateKey privateKey); |
||||||
|
|
||||||
|
/** |
||||||
|
* 批量删除私钥申请 |
||||||
|
* |
||||||
|
* @param ids 需要删除的私钥申请主键集合 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int deletePrivateKeyByIds(Long[] ids); |
||||||
|
|
||||||
|
/** |
||||||
|
* 删除私钥申请信息 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
public int deletePrivateKeyById(Long id); |
||||||
|
} |
||||||
@ -0,0 +1,156 @@ |
|||||||
|
package com.conflux.web.controller.privateKey.service.impl; |
||||||
|
|
||||||
|
import java.math.BigInteger; |
||||||
|
import java.text.SimpleDateFormat; |
||||||
|
import java.util.Date; |
||||||
|
import java.util.List; |
||||||
|
import com.conflux.common.utils.DateUtils; |
||||||
|
import com.conflux.common.utils.uuid.IdUtils; |
||||||
|
import com.conflux.web.controller.nft.domain.ConfluxArt; |
||||||
|
import com.conflux.web.controller.util.AESUtil; |
||||||
|
import com.conflux.web.controller.util.redis.RedisUtils; |
||||||
|
import org.springframework.beans.factory.annotation.Autowired; |
||||||
|
import org.springframework.data.redis.core.RedisTemplate; |
||||||
|
import org.springframework.stereotype.Service; |
||||||
|
import com.conflux.web.controller.privateKey.mapper.PrivateKeyMapper; |
||||||
|
import com.conflux.web.controller.privateKey.domain.PrivateKey; |
||||||
|
import com.conflux.web.controller.privateKey.service.IPrivateKeyService; |
||||||
|
|
||||||
|
import javax.annotation.Resource; |
||||||
|
|
||||||
|
/** |
||||||
|
* 私钥申请Service业务层处理 |
||||||
|
* |
||||||
|
* @author conflux |
||||||
|
* @date 2022-06-07 |
||||||
|
*/ |
||||||
|
@Service |
||||||
|
public class PrivateKeyServiceImpl implements IPrivateKeyService |
||||||
|
{ |
||||||
|
@Autowired |
||||||
|
private PrivateKeyMapper privateKeyMapper; |
||||||
|
@Resource |
||||||
|
private RedisUtils redisUtils; |
||||||
|
@Resource |
||||||
|
RedisTemplate redisTemplate; |
||||||
|
/** |
||||||
|
* 查询私钥申请 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 私钥申请 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public PrivateKey selectPrivateKeyById(Long id) |
||||||
|
{ |
||||||
|
return privateKeyMapper.selectPrivateKeyById(id); |
||||||
|
} |
||||||
|
|
||||||
|
@Override |
||||||
|
public PrivateKey selectPrivateKeyByAppId(String appId) { |
||||||
|
return privateKeyMapper.selectPrivateKeyByAppId(appId); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 查询私钥申请列表 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 私钥申请 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public List<PrivateKey> selectPrivateKeyList(PrivateKey privateKey) |
||||||
|
{ |
||||||
|
return privateKeyMapper.selectPrivateKeyList(privateKey); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 新增私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public int insertPrivateKey(PrivateKey privateKey) { |
||||||
|
privateKey.setCreateTime(DateUtils.getNowDate()); |
||||||
|
String fastUUID = IdUtils.fastUUID(); |
||||||
|
String appid = null; |
||||||
|
String key= null; |
||||||
|
try { |
||||||
|
appid =generateOrderSn(); |
||||||
|
key = AESUtil.encrypt(fastUUID, ConfluxArt.AESKEY); |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
} |
||||||
|
privateKey.setAppId(appid); |
||||||
|
privateKey.setPrivateKey(key.toLowerCase()); |
||||||
|
return privateKeyMapper.insertPrivateKey(privateKey); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 修改私钥申请 |
||||||
|
* |
||||||
|
* @param privateKey 私钥申请 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public int updatePrivateKey(PrivateKey privateKey) |
||||||
|
{ |
||||||
|
return privateKeyMapper.updatePrivateKey(privateKey); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 批量删除私钥申请 |
||||||
|
* |
||||||
|
* @param ids 需要删除的私钥申请主键 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public int deletePrivateKeyByIds(Long[] ids) |
||||||
|
{ |
||||||
|
return privateKeyMapper.deletePrivateKeyByIds(ids); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 删除私钥申请信息 |
||||||
|
* |
||||||
|
* @param id 私钥申请主键 |
||||||
|
* @return 结果 |
||||||
|
*/ |
||||||
|
@Override |
||||||
|
public int deletePrivateKeyById(Long id) |
||||||
|
{ |
||||||
|
return privateKeyMapper.deletePrivateKeyById(id); |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 生成appid |
||||||
|
* @return |
||||||
|
*/ |
||||||
|
public String generateOrderSn() { |
||||||
|
StringBuilder sb = new StringBuilder(); |
||||||
|
String date = new SimpleDateFormat("yyyyMMddHHmmss").format(new Date()); |
||||||
|
// 拼接key值
|
||||||
|
String key = "UUID:"+ date; |
||||||
|
int code = (int)(Math.random() * (40000 -10000)) + 10000; |
||||||
|
Long increment = incr(key, code); |
||||||
|
sb.append(date); |
||||||
|
sb.append(String.format("%02d", 2)); |
||||||
|
sb.append(String.format("%02d",2)); |
||||||
|
String incrementStr = increment.toString(); |
||||||
|
if (incrementStr.length() <= 6) { |
||||||
|
sb.append(String.format("%06d", increment)); |
||||||
|
} else { |
||||||
|
sb.append(incrementStr); |
||||||
|
} |
||||||
|
return sb.toString(); |
||||||
|
} |
||||||
|
|
||||||
|
/*** |
||||||
|
* 按delta递增 |
||||||
|
* @param key |
||||||
|
* @param delta |
||||||
|
* @return |
||||||
|
*/ |
||||||
|
public Long incr(String key, long delta) { |
||||||
|
return redisTemplate.opsForValue().increment(key, delta); |
||||||
|
} |
||||||
|
} |
||||||
@ -0,0 +1,194 @@ |
|||||||
|
package com.conflux.web.controller.util; |
||||||
|
|
||||||
|
import cn.hutool.core.date.DateUtil; |
||||||
|
import com.conflux.web.controller.collect.domain.CollectConfig; |
||||||
|
import com.conflux.web.controller.collect.service.ICollectConfigService; |
||||||
|
import com.conflux.web.controller.nft.domain.EventParam; |
||||||
|
import com.conflux.web.controller.nft.domain.vo.FilterMapVO; |
||||||
|
import com.conflux.web.controller.nft.service.IHandlerStrategy; |
||||||
|
import com.google.gson.Gson; |
||||||
|
import conflux.web3j.Cfx; |
||||||
|
import conflux.web3j.Request; |
||||||
|
import conflux.web3j.request.Epoch; |
||||||
|
import conflux.web3j.request.LogFilter; |
||||||
|
import conflux.web3j.response.Log; |
||||||
|
import conflux.web3j.types.Address; |
||||||
|
import lombok.extern.slf4j.Slf4j; |
||||||
|
import org.apache.commons.collections.CollectionUtils; |
||||||
|
import org.springframework.beans.factory.annotation.Value; |
||||||
|
import org.springframework.context.annotation.Configuration; |
||||||
|
import org.springframework.scheduling.annotation.Scheduled; |
||||||
|
|
||||||
|
import javax.annotation.Resource; |
||||||
|
import java.math.BigInteger; |
||||||
|
import java.util.*; |
||||||
|
import java.util.stream.Collectors; |
||||||
|
|
||||||
|
/** |
||||||
|
* @Author _007long |
||||||
|
* @Date 2022 06 07 |
||||||
|
**/ |
||||||
|
@Slf4j |
||||||
|
@Configuration |
||||||
|
public class ScheduledTask { |
||||||
|
@Value("${conflux.contract}") |
||||||
|
private String contract; |
||||||
|
@Resource |
||||||
|
private ICollectConfigService collectConfigService; |
||||||
|
@Resource |
||||||
|
private IHandlerStrategy iHandlerStrategy; |
||||||
|
private Map<String,CollectConfig> map=new HashMap(); |
||||||
|
//@Scheduled(fixedDelay = 5000L)
|
||||||
|
public void executeMakeUp() { |
||||||
|
CollectConfig collect = collectConfigService.selectCollectConfigByStatus(); |
||||||
|
if (collect.getOnPause()) { |
||||||
|
log.info("[dispatchHandler]{}", "暂停中"); |
||||||
|
try { |
||||||
|
Thread.sleep(5000); |
||||||
|
} catch (InterruptedException e) { |
||||||
|
e.printStackTrace(); |
||||||
|
} |
||||||
|
return; |
||||||
|
} |
||||||
|
//=======检查数据=======
|
||||||
|
List<EventParam> eventParams = new ArrayList<>(); |
||||||
|
EventParam eventParam = new EventParam(); |
||||||
|
eventParam.setChainId(collect.getChainId()); |
||||||
|
eventParam.setContract(contract);//合约
|
||||||
|
eventParam.setParam("address,address,uint256"); |
||||||
|
eventParam.setMethod("Transfer"); |
||||||
|
eventParam.setType(20000); |
||||||
|
eventParam.setRemark("Wu jing"); |
||||||
|
eventParams.add(eventParam); |
||||||
|
if (CollectionUtils.isEmpty(eventParams)) { |
||||||
|
log.error("[dispatchHandler]{}", "没有需要监听的数据"); |
||||||
|
return; |
||||||
|
} |
||||||
|
Gson gson = new Gson(); |
||||||
|
//获取event，使用 webService
|
||||||
|
//记录数据
|
||||||
|
Cfx cfx = null; |
||||||
|
try { |
||||||
|
cfx = Cfx.create(collect.getNode(), 3, 1000); |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
return; |
||||||
|
} |
||||||
|
FilterMapVO vo = getFilter(eventParams); |
||||||
|
CollectConfig collectConfig = map.get(contract); |
||||||
|
long from = 0l; |
||||||
|
if (null != collectConfig) { |
||||||
|
from = collectConfig.getEpochNumber(); |
||||||
|
} else { |
||||||
|
from = collect.getEpochNumber(); |
||||||
|
} |
||||||
|
// Invoke cfx method
|
||||||
|
BigInteger epoch = cfx.getEpochNumber().sendAndGet(); |
||||||
|
log.info("[executeMakeUp][Current epoch]:{}", epoch); |
||||||
|
long to = epoch.intValue() - 5; |
||||||
|
if (to - from > collect.getLimitCount()) { |
||||||
|
to = from + collect.getLimitCount(); |
||||||
|
} |
||||||
|
vo.getLogFilter().setFromEpoch(Epoch.numberOf(from)); |
||||||
|
//当前高度
|
||||||
|
vo.getLogFilter().setToEpoch(Epoch.numberOf(to)); |
||||||
|
Request<List<Log>, Log.Response> events = cfx.getLogs(vo.getLogFilter()); |
||||||
|
try { |
||||||
|
events = cfx.getLogs(vo.getLogFilter()); |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
} |
||||||
|
if (events == null) { |
||||||
|
log.info("[executeMakeUp][请重启服务]"); |
||||||
|
return; |
||||||
|
} |
||||||
|
List<Log> logList = events.sendAndGet(); |
||||||
|
boolean isSuccess = false; |
||||||
|
if (CollectionUtils.isEmpty(logList)) { |
||||||
|
log.info("[executeMakeUp][此区间暂无日志]:from:{} to:{}", from, to); |
||||||
|
isSuccess = true; |
||||||
|
} |
||||||
|
for (Log l : logList) { |
||||||
|
//处理高度信息
|
||||||
|
String evAddress = l.getTopics().get(0); |
||||||
|
String tokenAddress = l.getAddress().getAddress(); |
||||||
|
if (tokenAddress.contains("TYPE")) { |
||||||
|
Address a = new Address(tokenAddress); |
||||||
|
tokenAddress = a.getAddress(); |
||||||
|
} |
||||||
|
int type = vo.getMap().get(evAddress + "-" + tokenAddress.toLowerCase()); |
||||||
|
if (type == 0) { |
||||||
|
log.info("[dispatchHandler][暂无符合条件的数据]"); |
||||||
|
return; |
||||||
|
} |
||||||
|
boolean res; |
||||||
|
try { |
||||||
|
res = iHandlerStrategy.relayHandler(cfx, gson.toJson(l), type); |
||||||
|
} catch (Exception e) { |
||||||
|
e.printStackTrace(); |
||||||
|
isSuccess = false; |
||||||
|
log.info("[dispatchHandler][数据错误未分配]{}", l.getData()); |
||||||
|
break; |
||||||
|
} |
||||||
|
if (res) { |
||||||
|
log.info("[dispatchHandler][分配成功]{}", evAddress); |
||||||
|
isSuccess = true; |
||||||
|
} else { |
||||||
|
log.info("[dispatchHandler][数据错误未分配]{}", l.getData()); |
||||||
|
isSuccess = false; |
||||||
|
break; |
||||||
|
} |
||||||
|
} |
||||||
|
//分析数据拉取成功
|
||||||
|
CollectConfig t = new CollectConfig(); |
||||||
|
t.setId(collect.getId()); |
||||||
|
t.setUpdateTime(DateUtil.currentSeconds()); |
||||||
|
if (isSuccess) { |
||||||
|
t.setEpochNumber(to); |
||||||
|
log.info("[dispatchHandler][更新高度]:{}", to); |
||||||
|
map.put(contract,t); |
||||||
|
} |
||||||
|
} |
||||||
|
|
||||||
|
/** |
||||||
|
* 每隔一分钟更新一次数据 |
||||||
|
*/ |
||||||
|
//@Scheduled(fixedDelay = 60000L)
|
||||||
|
public void flushDiskToMysql(){ |
||||||
|
CollectConfig collectConfig = map.get(contract); |
||||||
|
if (null!=collectConfig){ |
||||||
|
//写入数据库
|
||||||
|
collectConfigService.updateCollectConfig(collectConfig); |
||||||
|
System.err.println(map.toString()); |
||||||
|
}else { |
||||||
|
System.err.println("写入数据库失败！"); |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
|
private FilterMapVO getFilter(List<EventParam> eventParams) { |
||||||
|
// PubSub Subscribe to incoming events and process incoming events
|
||||||
|
LogFilter filter = new LogFilter(); |
||||||
|
//添加监听合约：
|
||||||
|
List<Address> moList = eventParams.stream().map( |
||||||
|
eventParam -> new Address(eventParam.getContract())).collect(Collectors.toList()); |
||||||
|
filter.setAddress(moList); |
||||||
|
//添加监听方法
|
||||||
|
List<String> list = new ArrayList<>(); |
||||||
|
//Transfer
|
||||||
|
Map<String, Integer> map = new HashMap<>(eventParams.size()); |
||||||
|
eventParams.forEach(eventParam -> { |
||||||
|
String evAddress = CfxUtils.getEventKeccak(eventParam.getMethod(), Arrays.asList(eventParam.getParam().split(","))); |
||||||
|
// log.info("token:{} method:{} kec:{}", eventParam.getContract(), eventParam.getMethod(), evAddress);
|
||||||
|
map.put(evAddress + "-" + eventParam.getContract().toLowerCase(), eventParam.getType()); |
||||||
|
list.add(evAddress); |
||||||
|
}); |
||||||
|
List<List<String>> lists = new ArrayList<>(); |
||||||
|
lists.add(list); |
||||||
|
filter.setTopics(lists); |
||||||
|
FilterMapVO vo = new FilterMapVO(); |
||||||
|
vo.setLogFilter(filter); |
||||||
|
vo.setMap(map); |
||||||
|
return vo; |
||||||
|
} |
||||||
|
|
||||||
|
} |
||||||
@ -0,0 +1,79 @@ |
|||||||
|
<?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.privateKey.mapper.PrivateKeyMapper"> |
||||||
|
|
||||||
|
<resultMap type="PrivateKey" id="PrivateKeyResult"> |
||||||
|
<result property="id" column="id" /> |
||||||
|
<result property="unitName" column="unit_name" /> |
||||||
|
<result property="appId" column="app_id" /> |
||||||
|
<result property="privateKey" column="private_key" /> |
||||||
|
<result property="stauts" column="stauts" /> |
||||||
|
<result property="createTime" column="create_time" /> |
||||||
|
</resultMap> |
||||||
|
|
||||||
|
<sql id="selectPrivateKeyVo"> |
||||||
|
select id, unit_name, app_id, private_key, stauts, create_time from private_key |
||||||
|
</sql> |
||||||
|
|
||||||
|
<select id="selectPrivateKeyList" parameterType="PrivateKey" resultMap="PrivateKeyResult"> |
||||||
|
<include refid="selectPrivateKeyVo"/> |
||||||
|
<where> |
||||||
|
<if test="unitName != null and unitName != ''"> and unit_name like concat('%', #{unitName}, '%')</if> |
||||||
|
<if test="appId != null and appId != ''"> and app_id = #{appId}</if> |
||||||
|
<if test="privateKey != null and privateKey != ''"> and private_key = #{privateKey}</if> |
||||||
|
<if test="stauts != null and stauts != ''"> and stauts = #{stauts}</if> |
||||||
|
</where> |
||||||
|
</select> |
||||||
|
|
||||||
|
<select id="selectPrivateKeyById" parameterType="Long" resultMap="PrivateKeyResult"> |
||||||
|
<include refid="selectPrivateKeyVo"/> |
||||||
|
where id = #{id} |
||||||
|
</select> |
||||||
|
<select id="selectPrivateKeyByAppId" parameterType="String" resultMap="PrivateKeyResult"> |
||||||
|
<include refid="selectPrivateKeyVo"/> |
||||||
|
where app_id = #{appId} |
||||||
|
</select> |
||||||
|
|
||||||
|
<insert id="insertPrivateKey" parameterType="PrivateKey" useGeneratedKeys="true" keyProperty="id"> |
||||||
|
insert into private_key |
||||||
|
<trim prefix="(" suffix=")" suffixOverrides=","> |
||||||
|
<if test="unitName != null">unit_name,</if> |
||||||
|
<if test="appId != null">app_id,</if> |
||||||
|
<if test="privateKey != null">private_key,</if> |
||||||
|
<if test="stauts != null">stauts,</if> |
||||||
|
<if test="createTime != null">create_time,</if> |
||||||
|
</trim> |
||||||
|
<trim prefix="values (" suffix=")" suffixOverrides=","> |
||||||
|
<if test="unitName != null">#{unitName},</if> |
||||||
|
<if test="appId != null">#{appId},</if> |
||||||
|
<if test="privateKey != null">#{privateKey},</if> |
||||||
|
<if test="stauts != null">#{stauts},</if> |
||||||
|
<if test="createTime != null">#{createTime},</if> |
||||||
|
</trim> |
||||||
|
</insert> |
||||||
|
|
||||||
|
<update id="updatePrivateKey" parameterType="PrivateKey"> |
||||||
|
update private_key |
||||||
|
<trim prefix="SET" suffixOverrides=","> |
||||||
|
<if test="unitName != null">unit_name = #{unitName},</if> |
||||||
|
<if test="appId != null">app_id = #{appId},</if> |
||||||
|
<if test="privateKey != null">private_key = #{privateKey},</if> |
||||||
|
<if test="stauts != null">stauts = #{stauts},</if> |
||||||
|
<if test="createTime != null">create_time = #{createTime},</if> |
||||||
|
</trim> |
||||||
|
where id = #{id} |
||||||
|
</update> |
||||||
|
|
||||||
|
<delete id="deletePrivateKeyById" parameterType="Long"> |
||||||
|
delete from private_key where id = #{id} |
||||||
|
</delete> |
||||||
|
|
||||||
|
<delete id="deletePrivateKeyByIds" parameterType="String"> |
||||||
|
delete from private_key where id in |
||||||
|
<foreach item="id" collection="array" open="(" separator="," close=")"> |
||||||
|
#{id} |
||||||
|
</foreach> |
||||||
|
</delete> |
||||||
|
</mapper> |
||||||
Loading…
Reference in new issue