node采集代码
function submitDataInput(data){
log('提交从前台录入第'+data.number+'数据:'+data.data);
try{
var client=mysql.createClient(config.dbinfo);
}catch(err){
throw('连接数据库失败');
}
data.time=Math.floor((new Date(data.time)).getTime()/1000);
client.query("insert into blast_data(type, time, number, data) values(?,?,?,?)", [data.type, data.time, data.number, data.data], function(err, result){
if(err){
//console.log(err);
// 普通出错
if(err.number==1062){
// 数据已经存在
log('第'+data.number+'期数据已经存在数据');
}else{
log('运行出错:'+err.message);
}
}else if(result){
// 正常
log('写入第'+data.number+'期数据成功');
// 计算奖品
//setTimeout(requestKj, 500, data.type, data.number);
setTimeout(calcJ, 500, data);
}else{
global.log('未知运行出错');
}
});
client.end();
}
后台自己修改的代码
//添加开奖号
public final function added(){
$para=$_POST;
$para['type']=intval($para['type']);
$para['key']=$this->encrypt_key;
$sql ="insert into {$this->prename}data(type, time, number, data)values({$para['type']}','{$para['time,']}','{$para['number']}','{$para['data']}')";
$return =$this->getRow($sql);
}
public final function updatedataed(){
$id=intval($_POST['id']);
$para['data']=$_POST['data'];
$sql="update {$this->prename}data set data='{$para['data']}' where id={$id}";
if($this->update($sql)){
echo '修改成功';
正常的和非正常的对比图
数据库里面TIME的显示