|
@@ -362,17 +362,10 @@ void card_location_base::on_message(zloop<task*>* loop, message_ins_locinfo& loc
|
|
|
char sql[1024] = { 0 };
|
|
|
snprintf(sql,
|
|
|
1024,
|
|
|
- "insert into his_raw_data_sb(card_id, x, y, z, speed, site_id1, distance1, site_id2, distance2, site_info, acc, acc_x, acc_y, acc_z, ang, ang_x, ang_y, ang_z, cur_time) values('%s', %.2f, %.2f, %.2f, %.2f, %d, %.2f, %d, %.2f, '%s', %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, '%s')",
|
|
|
+ "insert into his_raw_data_sb(card_id, site_id, distance, acc, acc_x, acc_y, acc_z, ang, ang_x, ang_y, ang_z, cur_time) values('%s', %d, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, '%s')",
|
|
|
sid.c_str(),
|
|
|
- 0.0,
|
|
|
- 0.0,
|
|
|
- 0.0,
|
|
|
- 0.0,
|
|
|
siteId1,
|
|
|
distance1,
|
|
|
- siteId2,
|
|
|
- distance2,
|
|
|
- "",//site_info.c_str(),
|
|
|
loc.m_ins_data.get_acc(),
|
|
|
loc.m_ins_data.get_acc(0),
|
|
|
loc.m_ins_data.get_acc(1),
|
|
@@ -386,6 +379,27 @@ void card_location_base::on_message(zloop<task*>* loop, message_ins_locinfo& loc
|
|
|
db_tool::PushAsync(sql);
|
|
|
log_info("[sql] %s", sql);
|
|
|
|
|
|
+ memset(sql, 0, 1024);
|
|
|
+
|
|
|
+ snprintf(sql,
|
|
|
+ 1024,
|
|
|
+ "insert into his_raw_data_sb(card_id, site_id, distance, acc, acc_x, acc_y, acc_z, ang, ang_x, ang_y, ang_z, cur_time) values('%s', %d, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, %.2f, '%s')",
|
|
|
+ sid.c_str(),
|
|
|
+ siteId2,
|
|
|
+ distance2,
|
|
|
+ loc.m_ins_data.get_acc(),
|
|
|
+ loc.m_ins_data.get_acc(0),
|
|
|
+ loc.m_ins_data.get_acc(1),
|
|
|
+ loc.m_ins_data.get_acc(2),
|
|
|
+ loc.m_ins_data.get_gyro(),
|
|
|
+ loc.m_ins_data.get_gyro(0),
|
|
|
+ loc.m_ins_data.get_gyro(1),
|
|
|
+ loc.m_ins_data.get_gyro(2),
|
|
|
+ now.c_str()
|
|
|
+ );
|
|
|
+ db_tool::PushAsync(sql);
|
|
|
+ log_info("[sql] %s", sql);
|
|
|
+
|
|
|
// 更新数据到发送线程
|
|
|
sys::sb_data sd;
|
|
|
sd.cid = sid;
|