如何帮助商家破局“流量困境”全新泰山众筹
我是微三云门门，本期以核爆泰山众筹模型方案举例：
以投资10000短期合约5天为例:
简单模型:每5天:10000x5x1%=500
每月、年:500x6=3000x12=3.6万
核爆模型:每5天:10000x1.05=10500
每月:10000x1.05^6=1.34万
2.5个月:10000x1.05^15=2.08万
6个月:10000x1.05^36=5.79万12个月:10000x1.05^72=33.55万
举例说明：
假如：您的级别是四级 级差2% 参与短期合约五天一轮(每月六轮出局)
1》直推
举例:100Wx2%=2W/次x6次=12W/月x12月=144W/年 (推多少赚多少)
●2》团队(按0.5%级差)
@举例:100Wx0.5%=5000/次x6次=3W/月x12月=36W
3》自摸(2%+1%)
@举例:10Wx2%=2000/次x6次=1.2W/月x12月=14.4W
10Wx1%x5天=5000/次x6次=3W/月x12月=36W
静态:每天1%
自由合约 24小时 短期合约3-7天 中期合约 8-15天 长期合约 16-30天
单利静态月化 30%
复利年化 3倍--30倍
理论举例:5天合约为例:时间+复利
1个月6次 1Wx1.056 =1.34W
2.5个月15次 1=2.07W
6个月36次 1=5.8W
12个月72次1=33.5W
注:复利理论数据测算，是当前周期未爆仓为前提测算
钱从哪来? 10人x100/人=1000 5天短期合约
本金 650 静态 260 动态 60 平台 20 奖励 10
例:入出 +5
100>105 65 40 =105 x+5
100>105 65 十 40 =105 x+5
100105 65 40 =105 】+5 +120
100> 105 65 + 40=105 +5
100105 65 + 40=105 +5. 赢亏平衡
100 105 65 + 40=105 平台0泡沫
100 > 105 65 + 20=85--15
100>105100 >10565650 =65--350 =65--35 -120止损重生优先赢利
10.100 >105 65 0=65-35
扩展资料：
public void start() {
if (this.connector == null) {
System.out.println("connector不能为空,启动失败");
return;
}
thread = new Thread(this::process);
thread.setUncaughtExceptionHandler(handler);
running = true;
thread.start();
System.out.println("canal client started...");
}
public void stop() {
if (!running) {
return;
}
running = false;
if (thread != null) {
try {
thread.join();
} catch (InterruptedException e) {
// ignore
}
}
System.out.println("canal client stopped...");
}
private void process() {
while (running) {
try {
//打开连接
connector.connect();
//订阅数据库表,全部表
connector.subscribe(".*\\..*");
//回滚到未进行ack的地方，下次fetch的时候，可以从最后一个没有ack的地方开始拿
connector.rollback();
while (running) {
// 获取指定数量的数据
Message message = connector.getWithoutAck(BATCH_SIZE);
//获取批量ID
long batchId = message.getId();
//获取批量的数量
int size = message.getEntries().size();
//如果没有数据
if (batchId == -1 || size == 0) {
try {
//线程休眠2秒
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
} else {
//如果有数据,处理数据
printEntry(message.getEntries());
}
if (batchId != -1) {
// 提交确认
connector.ack(batchId);
}
}
} catch (Throwable e) {
e.printStackTrace();
try {
Thread.sleep(1000L);
} catch (InterruptedException e1) {
// ignore
}
connector.rollback(); // 处理失败, 回滚数据
} finally {
connector.disconnect();
}
}
}
/**
* 打印canal server解析binlog获得的实体类信息
*/
private static void printEntry(List entrys) {
for (CanalEntry.Entry entry : entrys) {
if (entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONBEGIN || entry.getEntryType() == CanalEntry.EntryType.TRANSACTIONEND) {
//开启/关闭事务的实体类型，跳过
continue;
}
//RowChange对象，包含了一行数据变化的所有特征
//比如isDdl 是否是ddl变更操作 sql 具体的ddl sql beforeColumns afterColumns 变更前后的数据字段等等
CanalEntry.RowChange rowChage;
try {
rowChage = CanalEntry.RowChange.parseFrom(entry.getStoreValue());
} catch (Exception e) {
throw new RuntimeException("ERROR ## parser of eromanga-event has an error , data:" + entry.toString(), e);
}
//获取操作类型：insert/update/delete类型
CanalEntry.EventType eventType = rowChage.getEventType();
//打印Header信息
System.out.println(String.format("================》; binlog[%s:%s] , dbName:%s, tableName:%s , eventType : %s",
entry.getHeader().getLogfileName(), entry.getHeader().getLogfileOffset(),
entry.getHeader().getSchemaName(), entry.getHeader().getTableName(),
eventType));
//判断是否是DDL语句
if (rowChage.getIsDdl()) {
System.out.println("================》;isDDL: true,sql:" + rowChage.getSql());
}
//获取RowChange对象里的每一行数据，打印出来
for (CanalEntry.RowData rowData : rowChage.getRowDatasList()) {
//如果是删除语句
if (eventType == CanalEntry.EventType.DELETE) {
printColumn(rowData.getBeforeColumnsList());
//如果是新增语句
} else if (eventType == CanalEntry.EventType.INSERT) {
printColumn(rowData.getAfterColumnsList());
//如果是更新的语句
} else {
//变更前的数据
System.out.println("------->; before");
printColumn(rowData.getBeforeColumnsList());
//变更后的数据
System.out.println("------->; after");
printColumn(rowData.getAfterColumnsList());
}
}
}
}
private static void printColumn(List columns) {
for (CanalEntry.Column column : columns) {
System.out.println(column.getName() + " : " + column.getValue() + " update=" + column.getUpdated());
}
}
}
insert测试
我提前创建了一个表
CREATE TABLE `canal_user` (
`id` bigint(0) UNSIGNED NOT NULL AUTO_INCREMENT,
`name` varchar(100) NULL,
`age` int(0) UNSIGNED NULL,
`create_time` datetime(0) NULL,
`is_deleted` tinyint(1) NULL,
PRIMARY KEY (`id`)
插入一条：
INSERT INTO `canal_user`(`name`, `age`, create_time, is_deleted) VALUES ('hello-canal', 18, '2022-11-15 00:00:00', 0);
1
SimpleCanalClient监听到了：
================》; binlog[mysql-bin.000005:7300] , dbName:my-test, tableName:canal_user , eventType : INSERT
id : 1 update=true
name : hello-canal update=true
age : 18 update=true
create_time : 2022-11-15 00:00:00 update=true
is_deleted : 0 update=true
update测试
update `canal_user` set `name` = 'hello-canal-28', age = 28 where id = 1;
1
SimpleCanalClient监听到了：
================》; binlog[mysql-bin.000005:7601] , dbName:my-test, tableName:canal_user , eventType : UPDATE
------->; before
id : 1 update=false
name : hello-canal update=false
age : 18 update=false
create_time : 2022-11-15 00:00:00 update=false
is_deleted : 0 update=false
------->; after
id : 1 update=false
name : hello-canal-28 update=true
age : 28 update=true
create_time : 2022-11-15 00:00:00 update=false
is_deleted : 0 update=false
delete测试
delete from `canal_user` where id = 1;
1
SimpleCanalClient监听到了：
================》; binlog[mysql-bin.000005:7938] , dbName:my-test, tableName:canal_user , eventType : DELETE
id : 1 update=false
name : hello-canal-28 update=false
age : 28 update=false
create_time : 2022-11-15 00:00:00 update=false
is_deleted : 0 update=false
- 发表于:
- 原文链接：https://kuaibao.qq.com/s/20230208A08ASH00?refer=cp_1026
- 腾讯「腾讯云开发者社区」是腾讯内容开放平台帐号（企鹅号）传播渠道之一，根据《腾讯内容开放平台服务协议》转载发布内容。
- 如有侵权，请联系 cloudcommunity@tencent.com 删除。
相关快讯
扫码
添加站长 进交流群
领取专属 10元无门槛券
私享最新 技术干货
腾讯云开发者
