Создаем 'нормальную' бд персонажей сервера вместе

123new · 4 марта 2019

Собственно, в шапке темы написано все. Давайте в этой теме обсуждать вопрос создания 'нормальной' (привычной для всех, в том числе и для редактирования) базы данных персонажей сервера. Возможно, даже с возможностью мультисерверной работы (что крайне лишним не было бы).

Alex39 · 5 марта 2019

Даже взять файл missionGameplay.c какой функционал там прописан, но уверен не все используется

Alex39 · 5 марта 2019

Ну хорошо, если пойти другим путем, в экзешнике вместо HIVE прописать mysql, а в конфиге сервера конект к базе данных типа так:

Host = localhost

Driver = com.mysql.jdbc.Driver
URL = jdbc:mysql://localhost/dayzsa
Login = dayzsa
Password = 1234567890

А так как сервер основан на Java то подключим jdbc Java

Структуру и таблицы можно из экзешника вытянуть, осталось по экзешнику прописать мисиию, думаю как вариант

Изменено 5 марта 2019 пользователем Alex39 (история изменений)

Alex39 · 6 марта 2019

Ну вроде движуха не стоит на месте, общими силами продвигаемся, и вот подошел кульминационный момент, составить базу данных,

Кто еще заинтересован, ваши варианты, какая структура базы должна быть, файл какой и так далее?

Пожалуйста, Войдите или Зарегистрируйтесь, чтобы увидеть это: Вложение.

Alex39 · 9 марта 2019

По поводу базы данных Hive, я один не потяну с редактированием, но возникла другая идея, онлайн базу перевести в офлайн, так как в офлайне много отключенных фишек, хочу попробовать подключить, что получется не знаю, но у меня не хватает знаний по базе написать миссию , сам функционал

Изменено 9 марта 2019 пользователем Alex39 (история изменений)

Alex39 · 9 марта 2019

Не могу понять что за ошибка прет, у кого какие мысли?

Пожалуйста, Войдите или Зарегистрируйтесь, чтобы увидеть это: Вложение.

Alex39 · 9 марта 2019

Возможно что в базе прописано init а в экзешнике storage

Alex39 · 9 марта 2019

самое интересное что конект в базу уже есть, это уже хорошо

Пожалуйста, Войдите или Зарегистрируйтесь, чтобы увидеть это: Вложение.

Alex39 · 9 марта 2019

Ну с этим разобрался, сервер запущен, и по скрину видно что ошибка в Джава скрипте

123new · 9 марта 2019

1 час назад, Alex39 сказал:

Не могу понять что за ошибка прет, у кого какие мысли?

Пожалуйста, Войдите или Зарегистрируйтесь, чтобы увидеть это: Вложение.

сервер посылает запрос и ожидает получить ответ в каком-то определенном виде. Учитывая, что ответа не поступило, либо он поступил в каком-то некорректном виде, который сервер не смог разобрать, он крашнулся.

Alex39 · 9 марта 2019

2 часа назад, 123new сказал:

сервер посылает запрос и ожидает получить ответ в каком-то определенном виде. Учитывая, что ответа не поступило, либо он поступил в каком-то некорректном виде, который сервер не смог разобрать, он крашнулся.

Конечно некоректное, надо переписать со старой базы на новую, все запросы

app.use(bodyParser());

var getRawBody = require('raw-body');

app.use(function (req, res, next) {
	if (req.headers['content-type'] === 'application/octet-stream') {
		getRawBody(req, {
			length: req.headers['content-length'],
			encoding: this.charset
		}, function (err, string) {
			if (err)
				return next(err)

			req.body = string
			next()
		})
	}
	else {
		next()
	}
});

exports.start = function () {
	app.listen(8080);
	console.log('Server running on port 8080');
}

function responseFile(filePath, response) {
  fs.exists(filePath, function(exists){
      if (exists) {
		console.log('responseFile...');
		response.setHeader('Expect', '100-continue');
		response.setHeader('Content-Type', 'application/octet-stream');
        fs.createReadStream(filePath).pipe(response);
		console.log('responseFile...Complete?');
      } else {
        response.writeHead(400, {"Content-Type": "text/plain"});
        response.end("ERROR File does NOT Exists");
      }
    });
}


function countOcurrences(find,str){
   return (str.split(find).length - 1)
}

function IsJsonString(str) {
	if ((countOcurrences("(",str) == countOcurrences(")",str)) && 
	    (countOcurrences("[",str) == countOcurrences("]",str)) &&
	    (countOcurrences("{",str) == countOcurrences("}",str))
	   ){
        return true;
    } else {
        return false;
    }
}

app.get('/HOME', function (req, res) {
		pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {
			connection.query('SELECT uid FROM objects', function (err, rows, fields) {
				if (err) {
					console.log("数据库连接失败")
					res.send('[]');
					return;
				} 
				connection.release();
	
				if (rows.length == 0) {
					console.log('没有家园数据');
					res.send('[]');
					return;
				}
				var ids = '[';
				rows.forEach(function(element){
					ids += '"' + element.uid+ '",';
				});
				ids = ids.substring(0,ids.length-1) + "]";
				res.send(ids);
				console.log('获取家园数据[' + rows.length +']')
				return;
			});
		}
	});
	
});

app.post('/DayZServlet/lud0/findobj', function (req, res) {
	console.log('找到物品 ' + req.query.uid);

	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {

			connection.query('SELECT model,x,y,z FROM objects WHERE uid = ?', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
				connection.release();
		
				if (rows.length == 0) {
					console.log('No data found');
					res.send('{}');
					return;
				}
				
				if ((rows[0].x == '0') && (rows[0].y == '0') && (rows[0].z == '0'))
				{
					console.log('Corrupt data');
					res.send('{}');
					return;
				}
				// Edit result for sending
				rows[0].pos = [rows[0].x, rows[0].y, rows[0].z];
				delete rows[0].x;
				delete rows[0].y;
				delete rows[0].z;
		
				// Calculate queue
				res.send(JSON.stringify(rows[0]));
				
			});
		}
	});
});

app.get('/DayZServlet/lud0/loadobj', function (req, res) {
	console.log('加载物品 ' + req.query.uid);
	
	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {
			connection.query('SELECT * FROM objects WHERE uid = ?', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
				connection.release();
	
				if (rows.length == 0) {
					console.log('No data found');
					res.send('{}');
					return;
				}
				
				//console.log(rows[0].items);
				//Check if data is corrupt
				if (
				(IsJsonString(rows[0].items) == false) || ((rows[0].items).length < 1)
				)
				{
					console.log('Corrupt data');
					res.send('{}');
					return;
				}
		
				//console.log('Sent character data: ' + JSON.stringify(rows[0]));
				//res.send(JSON.stringify(rows[0]));
				var loadData = '{"model":"'+rows[0].model+'","pos":['+rows[0].x+','+rows[0].z+','+rows[0].y+'],"items":'+rows[0].items+',"dir":['+rows[0].dir_x+','+rows[0].dir_y+','+rows[0].dir_z+'],"up":['+rows[0].up_0+','+rows[0].up_1+','+rows[0].up_2+']'+',"guid":"'+rows[0].guid+'"}';
				console.log(loadData);
				if (IsJsonString(loadData) == true) {
					res.send(loadData);
				}else{
					console.log("Resonce not json!");
					res.send("{}");
				}
			});
		}
	});
});

app.post('/DayZServlet/lud0/saveobj', function (req, res) {

	var guid = req.body.guid.replace(/\"/g,"");
	var uid = req.query.uid.replace(/\"/g,"");
	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
			return;
		}
						connection.query('SELECT * FROM objects WHERE uid = ?', [uid], function (err, rows, fields) {
						if (err) {
							console.log(err)
							res.send('{}');
							return;
						} 

						if (rows.length == 0) {
							console.log(getNowFormatDate1()+" 创建物品 "+req.query.uid);
							connection.query(
								'INSERT INTO objects(uid,model,items,guid,x,y,z,dir_x,dir_y,dir_z,up_0,up_1,up_2,time_created) VALUES(?,?,"[]",?,?,?,?,?,?,?,?,?,?,NOW())',
								[uid,req.body.model,guid,req.body.pos[0], req.body.pos[2], req.body.pos[1], req.body.dir[0], req.body.dir[1], req.body.dir[2], req.body.up[0], req.body.up[1], req.body.up[2]],
								function (err, rows, fields) {
									if (err) console.log(err);
								}
							);
						} else {
							console.log(getNowFormatDate1()+" 更新物品 "+req.query.uid);
							if(typeof (req.body.items) == 'undefined') {
								req.body.items = [];
							}
							connection.query('UPDATE objects SET model = ?, items = ?, guid = ?, x = ?, z = ?, y = ?, dir_x = ?, dir_y = ?, dir_z = ?, up_0 = ?, up_1 = ?, up_2 = ? WHERE uid = ?', [req.body.model, JSON.stringify(req.body.items), guid, req.body.pos[0], req.body.pos[1], req.body.pos[2], req.body.dir[0], req.body.dir[1], req.body.dir[2], req.body.up[0], req.body.up[1], req.body.up[2], uid], function (err, rows, fields) {	
									if (err) console.log(err);
								}
							);
						}
						connection.release();
						res.send('{}');
					});
	});
});

app.post('/DayZServlet/lud0/killobj', function (req, res) {
	if (countOcurrences("?", req.query.uid) == 1){
		var uid = (req.query.uid).replace('?uid=', '');
	}else{
		var uid = req.query.uid;
	}
	console.log('删除物品 ' + uid);

	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {	
			connection.query('DELETE FROM objects WHERE uid = ?', [uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				}	
				connection.release();			
			});			
		}
	});
	res.send('{}');
});



app.post('/DayZServlet/lud0/find', function (req, res) {
	console.log('Got find: ' + req.query.uid);

	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {

			connection.query('SELECT model,x,y,z,queue FROM player WHERE uid = ?', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
				connection.release();
		
				if (rows.length == 0) {
					console.log('No data found');
					res.send('{}');
					return;
				}
				
				if ((rows[0].x == '0') && (rows[0].y == '0') && (rows[0].z == '0'))
				{
					console.log('Corrupt data');
					res.send('{}');
					return;
				}
				// Edit result for sending
				rows[0].pos = [rows[0].x, rows[0].y, rows[0].z];
				delete rows[0].x;
				delete rows[0].y;
				delete rows[0].z;
		
				// Calculate queue
				var queueEnd = moment(rows[0].queue);
				rows[0].queue = -queueEnd.diff(moment(), 'seconds');
		
				res.send(JSON.stringify(rows[0]));
				
			});
		}
	});
});

app.get('/DayZServlet/lud0/load', function (req, res) {
		console.log('Got load: ' + req.query.uid);
	
	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {
			connection.query('SELECT * FROM player WHERE uid = ?', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
				connection.release();
	
				if (rows.length == 0) {
					console.log('No data found');
					res.send('{}');
					return;
				}
				
				console.log(rows[0].items);
				//Check if data is corrupt
				if (
				((IsJsonString(rows[0].items) == false) && 
				(IsJsonString(rows[0].state) == false)) ||
				(((rows[0].items).length < 1) ||
				((rows[0].state).length < 1))
				)
				{
					console.log('Corrupt data');
					res.send('{}');
					return;
				}
	

				// Calculate queue
				var queueEnd = moment(rows[0].queue);
				rows[0].queue = -queueEnd.diff(moment(), 'seconds');
		
		
		
		
				//console.log('Sent character data: ' + JSON.stringify(rows[0]));
				//res.send(JSON.stringify(rows[0]));
				var loadData = '{"model":"'+rows[0].model+'","alive":'+rows[0].alive+',"queue":'+rows[0].queue+',"pos":['+rows[0].x+','+rows[0].z+','+rows[0].y+'],"items":'+rows[0].items+',"state":'+rows[0].state+',"dir":['+rows[0].dir_x+','+rows[0].dir_y+','+rows[0].dir_z+'],"up":['+rows[0].up_0+','+rows[0].up_1+','+rows[0].up_2+']}';
				//console.log(loadData);
				if (IsJsonString(loadData) == true) {
					res.send(loadData);
				}else{
					console.log("Resonce not json!");
					res.send("{}");
				}
			});
		}
	});
});

app.post('/DayZServlet/lud0/create', function (req, res) {
	console.log('Got create: ' + req.query.uid);
	
	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {
			
			connection.query('INSERT IGNORE INTO player(uid) VALUES(?)', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
				
				connection.query('UPDATE record SET RespawnCount=RespawnCount+1', function (err, result) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				}		
				connection.release();
				res.send('{}');
				});				
			});
		}
	});
});

app.post('/DayZServlet/lud0/save', function (req, res) {

	console.log('Got save: ' + req.query.uid);
	
	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
			return;
		}
				
		//console.log(JSON.stringify(req.body.items));
		connection.query('UPDATE player SET model = ?, alive = ?, items = ?, state = ?, x = ?, z = ?, y = ?, dir_x = ?, dir_y = ?, dir_z = ?, up_0 = ?, up_1 = ?, up_2 = ? WHERE uid = ?', [req.body.model, req.body.alive, JSON.stringify(req.body.items), JSON.stringify(req.body.state), req.body.pos[0], req.body.pos[1], req.body.pos[2], req.body.dir[0], req.body.dir[1], req.body.dir[2], req.body.up[0], req.body.up[1], req.body.up[2], req.query.uid], function (err, rows, fields) {
			if (err) {
				console.log(err)
				res.send('{}');
				return;
			} 
			connection.release();
			res.send('{}');
		});
	});
});

app.post('/DayZServlet/lud0/queue', function (req, res) {

	console.log('Got queue: ' + req.query.uid + ' (' + req.body.queue + 's)');
	
	pool.getConnection(function (err, connection) {
		if (err) {
				console.log(err)
				res.send('{}');
		} else {
			connection.query('SELECT queue FROM player WHERE uid = ?', [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
					var query = 'UPDATE player SET queue = DATE_ADD(CURRENT_TIMESTAMP,INTERVAL ' + mysql.escape(JSON.stringify(req.body.queue)) + ' SECOND) WHERE uid = ?';
				connection.query(query, [req.query.uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				} 
					connection.release();
					res.send('{}');
				});
			});
		}
	});

});

app.post('/DayZServlet/lud0/kill', function (req, res) {
	if (countOcurrences("?", req.query.uid) == 1){
		var uid = (req.query.uid).replace('?uid=', '');
	}else{
		var uid = req.query.uid;
	}
	console.log('Got kill: ' + uid);

	pool.getConnection(function (err, connection) {
		if (err) {
			console.log(err)
			res.send('{}');
		} else {	
			connection.query('DELETE FROM player WHERE uid = ?', [uid], function (err, rows, fields) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				}		
				connection.query('UPDATE record SET DeadCount=DeadCount+1', function (err, result) {
				if (err) {
					console.log(err)
					res.send('{}');
					return;
				}		
				connection.release();
			});
				
			});			
		}
	});
	res.send('{}');
});

app.post('/0061/rest/init/enviroment', function (req, res) {
	res.send('{"primary":"http://127.0.0.1:8080/Mikejones420Gaming","envsec":"http://127.0.0.1:8080/Mikejones420Gaming"}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/rest/init/ping', function (req, res) {
	res.send('{"ping":100}');
	console.log('Env POST: ' + req.url);
});

app.get('/0061/rest/u3sT1/status', function (req, res) {
	//res.send('{"status":"ok","message":"ok","timeout":30}');
	res.send('{"status":"ok","message":"ok","timeout":30}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/rest/init/startup', function (req, res) {//res.send('{"s_flags":0,"s_log":1,"s_synctime":18000,"s_statstime":0,"s_deathtime":90,"s_queuetime":30}');
	res.send('{"success": 1,"message": "ok","timeout": 30,"type": 1,"key": "12312132414564564fdsaaezdxqs45","version_required": "0.60:133913","version_allowed": "0.60:133913","check": 0,"categorycount": 12,"s_flags":1,"s_log":0,"s_synctime":18000,"s_statstime":30,"s_deathtime":90,"s_queuetime":30}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/rest/init/confirm', function (req, res) {
	res.send('{"success": 1,"message": "ok","timeout": 30,"type": 1,"key": "12312132414564564fdsaaezdxqs45","version_required": "0.60:133913","version_allowed": "0.60:133913","check": 0,"categorycount": 12,"s_flags":1,"s_log":0,"s_synctime":18000,"s_statstime":30,"s_deathtime":90,"s_queuetime":30}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/rest/init/sync', function (req, res) {
	res.send('{"success": 1,"message": "ok","timeout": 30,"type": 1,"key": "12312132414564564fdsaaezdxqs45","version_required": "0.60:133913","version_allowed": "0.60:133913","check": 0,"categorycount": 12,"s_flags":1,"s_log":0,"s_synctime":18000,"s_statstime":30,"s_deathtime":90,"s_queuetime":30}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/u3sT1/global/record/get', function (req, res) {
	//res.send('[["1","Animals killed","hunt"],["1","Infected killed","kill"]]');
	//res.send('[["hunt","1","Animals killed"],["kill","1","Infected killed"]]');
	//res.send('{"record":{"type":"hunt","localization":"Animals killed","flags":"1"}}');
	//res.send('[{"record":{"type":"hunt","localization":"Animals killed","flags":"1"}},{"record":{"type":"kill","localization":"Infected killed","flags":"1"}}]');
	//res.send('{"record":[{"type":"hunt","localization":"Animals killed","flags":"1"},{"type":"kill","localization":"Infected killed","flags":"1"}]}');
	//res.send('{"record":[{"type":"hunt","localization":"Animals killed","flags":"1","record":1},{"type":"kill","localization":"Infected killed","flags":"1","record":2}]}');
res.send('{"record":[{"type":"hunt","localization":"Animals killed","flags":"1","record":"true"},{"type":"kill","localization":"Infected killed","flags":"1","record":"true"}]}');
	console.log('Env POST: ' + req.url);
});

/*
app.post('/0061/u3sT1/global/record/get', function (req, res) {
	res.send('{"records":{"record":[{"flags":"1","localization":"Animals killed","type":"hunt"},{"flags":"1","localization":"Infected killed","type":"kill"},{"flags":"1","localization":"Survivors killed","type":"murder"},{"flags":"1","localization":"Distance traveled","type":"dist"},{"flags":"1","localization":"Survivors aided","type":"aid"},{"flags":"1","localization":"Water consumed","type":"water"},{"flags":"1","localization":"Calories burned","type":"calories"},{"flags":"3","localization":"Hours survived","type":"playtime"}]}}');
	console.log('Env POST: ' + req.url);
});
*/

app.post('/0061/u3sT1/global/actions/get', function (req, res) {
	res.send('{"message": "test ok"}');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/w_0ld/global/category/get', function (req, res) {
	res.send('<?xml version="1.0" encoding="UTF-8"?><categories><category id="1" type="dynamic"/><category id="2" type="static"/><category id="3" type="animal"/><category id="4" type="zombie"/><category id="5" type="vehicle"/><category id="6" type="wreck"/><category id="7" type="container"/><category id="8" type="random"/><category id="9" type="custom"/><category id="10" type="building"/><category id="11" type="door"/><category id="12" type="player"/></categories>');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/w_0ld/global/type/getbin', function (req, res) {
	res.sendfile('type.bin');
	console.log('Env POST: ' + req.url);
});

app.post('/0061/w_0ld/global/type/setbin', function (req, res) {
	//res.send('{}');
	var noneExistFileName = ['type', '', '.bin'].join('');
	fs.writeFile(noneExistFileName, req.body, function(err){
		if(err) throw err;
		console.log(noneExistFileName+' is written！');
	});
	res.status(200);
	console.log('SET BIN: '+req.url);
});

app.post('/0061/a_0fg/find', function (req, res) {
	res.send('{"model":"SurvivorPartsMaleMatt", "queue": 0, "alive": true, "pos":[1000,1000,0]}');
	//res.send('{}');
	console.log('CHAR: ' + req.url);
});

app.get('/0061/a_0fg/loadbin', function (req, res) {
	//res.sendfile(req.query.uid + '.bin');
	//res.send('');
	res.sendfile('123.bin');
	console.log('LOAD: ' + req.url + ' UID' + req.query.uid);
});

app.post('/0061/a_0fg/create', function (req, res) {
	//res.send('{}');
	console.log('Got create: ' + req.query.uid);
});

app.post('/0061/a_0fg/process', function (req, res) {
	var noneExistFileName = [req.query.uid, '', '.bin'].join('');
	fs.writeFile(noneExistFileName, req.body, function(err){
		if(err) throw err;
		console.log(noneExistFileName+' is written！');
	});
	res.status(200);
	console.log('Got process: ' + req.url + ' UID' + req.query.uid);
	
});

app.post('/mpmissions/dayzOffline.chernarusplus/storage_1/data/events.bin', function (req, res) {
	/*
	res.setHeader('Content-Type', 'application/octet-stream');
	res.sendfile('events.bin');
	*/
	//res.send('');
	console.log('Env POST: ' + req.url);
});



/*
app.post('/0061/w_0ld/global/category/get', function (req, res) {
	res.send('{"categories":{"category":{{"id":"1","type":"dynamic"},{"id":"2","type":"static"},{"id":"3","type":"animal"},{"id":"4","type":"zombie"},{"id":"5","type":"vehicle"},{"id":"6","type":"wreck"},{"id":"7","type":"container"},{"id":"8","type":"random"},{"id":"9","type":"custom"},{"id":"10","type":"building"},{"id":"11","type":"door"}}}}');
	console.log('Env POST: ' + req.url);
});
*/


app.post(/.*/, function (req, res) {
	console.log('Got unhandled POST: ' + req.url);
	res.send('{}');
});

app.get(/.*/, function (req, res) {
	console.log('Got unhandled GET: ' + req.url);
	res.send('{}');
});




var net = require('net');
var HOST = '127.0.0.1';
var PORT = 9433;

net.createServer(function(sock) {
	
	// We have a connection - a socket object is assigned to the connection automatically
	//console.log('CONNECTED: ' + sock.remoteAddress +':'+ sock.remotePort);
	
	// Add a 'data' event handler to this instance of socket
	sock.on('data', function(data) {
	
		var response = data.toString().trim();

		if(response.search("Ping") > -1) {
			console.log('Recived Ping');
			sock.write('Pong');
		}


		if(response.search("ObjectIDS") > -1) {
			console.log('Getting Objects IDS');

			pool.getConnection(function (err, connection) {
				if (err) {
					console.log(err)
					sock.write('Empty');
				} else{

					connection.query('SELECT uid FROM objects', function (err, rows, fields) {
						if (err) {
							console.log(err)
							sock.write('Empty');
							return;
						} 
	
						connection.release();
	
						if (rows.length == 0) {
							sock.write('Empty');
						} else {
	
							var ids = '';
							rows.forEach(function(element){
								ids += element.uid+',';
							});
	
							ids = ids.substring(0, ids.length - 1);
							sock.write(ids);

						}
					});
				}
			});
		}

		if(response.search("ObjectSave: ") > -1) {
			//console.log(JSON.parse(response.match(/\[\[.{3,}\]\]/g)[0]));
			//var match = /*JSON.parse*/(response.match(/\[\[.{3,}\]\]/g));
			var match = /\[\["(\d+)","([\w\d_-]+)",(\[[\d,\.\[]+\]\])\],(.*\])\]/g.exec(response);
			if (match) {
				pool.getConnection(function (err, connection) {


				if (err) {
				console.log(err)
				sock.write('Empty');
				} else{

					connection.query('SELECT * FROM objects WHERE ObjectID = ?', [match[1]], function (err, rows, fields) {
						if (err) {
							console.log(err)
							sock.write('Empty');
							return;
						} 

						if (rows.length == 0) {
							console.log("CREATE "+match[1]+" "+match[2]);
							connection.query(
								'INSERT INTO objects(ObjectID,model,position,items,time_created,time_updated) VALUES(?,?,?,?,NOW(),NOW())',
								[match[1],match[2],match[3],match[4]],
								function (err, rows, fields) {
									if (err) console.log(err);
								}
							);
						} else {
							console.log("UPDATE "+match[1]+" "+match[2]);
							connection.query(
								'UPDATE objects SET position=?, items=?, time_updated=NOW() WHERE ObjectID=?',
								[match[3],match[4],match[1]],
								function (err, rows, fields) {
									if (err) console.log(err);
								}
							);
						}
						connection.release();
					});
					}
				});
			}
			sock.write('Ok');
			sleep.sleep(0.01);
		}




		if(response.search("ObjectLoad: ") > -1) {
			var match = JSON.parse(response.match(/\d+/g));
			if (match) {
				var oid = match;
				console.log("LOAD "+oid);
				pool.getConnection(function (err, connection) {


				if (err) {
				console.log(err)
				sock.write('Empty');
				} else{
					connection.query('SELECT * FROM objects WHERE ObjectID = ?', [oid], function (err, rows, fields) {
						if (err) {
							console.log(err)
							sock.write('Empty');
							return;
						} 
						connection.release();

						if (rows.length == 0) {
							console.log("Could not find object.");
								sock.write('Empty');
						} else {
							var ret = '[["'+rows[0].ObjectID+'","'+rows[0].model+'",'+rows[0].position+'],'+rows[0].items+']';
							console.log(ret);
							sock.write(ret);
						}
					});
					}
				});
			} else {
				sock.write('Empty');
		}
		}




		if(response.search("ObjectDelete: ") > -1) {
			var match = JSON.parse(response.match(/\d+/g));
			if (match) {
				var oid = match;
				console.log("Deleting object "+oid);

				pool.getConnection(function (err, connection) {
									if (err) {
				console.log(err)
				sock.write('Empty');
				} else{
					connection.query('DELETE FROM objects WHERE ObjectID = ?', [oid], function (err, rows, fields) {
						if (err) {
							console.log(err)
							sock.write('Empty');
							return;
						} 
						connection.release();
					});
					}
				});
			}
			sock.write('Ok');
		}
		
	});
	
	// Add a 'close' event handler to this instance of socket
	sock.on('close', function(data) {
		//console.log('SOCKET CONNECTION CLOSED');
	});
	sock.on('error', function(data) {
		console.log("Tried to send to a closed socket.");
	});
}).listen(PORT, HOST);

console.log(getNowFormatDate1()+' Socket listening on ' + HOST +':'+ PORT);

BorizzK · 10 марта 2019

Alex39 имхо, структуру бд брать с оффлайновой

Где блок с парпаметрами перса забинарен

Alex39 · 10 марта 2019

38 минут назад, BorizzK сказал:

Alex39 имхо, структуру бд брать с оффлайновой

Где блок с парпаметрами перса забинарен

Цитата

надо переписать со старой базы на новую, все запросы

BorizzK · 10 марта 2019

Alex39

Для начала нужно понять

Куда и как коннектится серв при InitDbOnline

Указать ip-порт

И скажем WireShark'ом посмотреть

И поднять скажем тот же апач и смотреть что серв от него хочет в логах апача

Я бы занялся, да времени небыло

Завтра попробую вайршарком изучить

Alex39 · 11 марта 2019

21 час назад, BorizzK сказал:

Alex39

Для начала нужно понять

Куда и как коннектится серв при InitDbOnline

Указать ip-порт

И скажем WireShark'ом посмотреть

И поднять скажем тот же апач и смотреть что серв от него хочет в логах апача

Я бы занялся, да времени небыло

Завтра попробую вайршарком изучить

Ну попробуй, я и так знаю что он хочет, только мозги надо иметь что бы сделать, это не просто

BorizzK · 11 марта 2019

Alex39 Рассказывай тогда

123new · 11 марта 2019

2 часа назад, Alex39 сказал:

Ну попробуй, я и так знаю что он хочет, только мозги надо иметь что бы сделать, это не просто

рассказвай, может хоть вместе кто-то чего поможет сделать. Я бы помог, но в этой области уже увы, знаю мало.

Alex39 · 11 марта 2019

1 минуту назад, 123new сказал:

рассказвай, может хоть вместе кто-то чего поможет сделать. Я бы помог, но в этой области уже увы, знаю мало.

Вот и я знаю мало, надо открывать уроки по MySQL и изучать

BorizzK · 11 марта 2019

Alex39 ты хочешь сказать, что там всежтаки mysql?

Alex39 · 11 марта 2019

3 минуты назад, BorizzK сказал:

Alex39 ты хочешь сказать, что там всежтаки mysql?

На сколько я понял что Hive использует компоненты MySQL, это же база данных

BorizzK · 11 марта 2019

Сервер дейз использует запросы mysql?

Alex39 · 11 марта 2019

6 минут назад, BorizzK сказал:

Сервер дейз использует запросы mysql?

Не сервер, Hive

Alex39 · 11 марта 2019

И не сам MySQL, а компоненты, на котором и построена система, надо только правильно подключить это все и полностью использовать сам MySQL

Alex39 · 11 марта 2019

Самое главное произвести конект в саму базу MySQL, а потом уже составлять таблицы, вот и пытаюсь, что бы хотя бы сервер видел хост Mysql, но пока что не получается, я для примера взял @extDB3, но видать не все понимаю или делаю

123new · 11 марта 2019

5 минут назад, Alex39 сказал:

Самое главное произвести конект в саму базу MySQL, а потом уже составлять таблицы, вот и пытаюсь, что бы хотя бы сервер видел хост Mysql, но пока что не получается, я для примера взял @extDB3, но видать не все понимаю или делаю

научитесь перехватывать запросы с hive этого и давать ответы - все получится, а в mysql отправлять уже дело десятое.
там как я понял получается связка php-java-mysql

Alex39 · 11 марта 2019

1 минуту назад, 123new сказал:

научитесь перехватывать запросы с hive этого и давать ответы - все получится, а в mysql отправлять уже дело десятое.
там как я понял получается связка php-java-mysql

Верно, они совместили php-java-mysql, вот и пытаюсь, но пока не выходит, мало знаний

Войти

Создаем 'нормальную' бд персонажей сервера вместе

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

163 ответа на этот вопрос

Рекомендованные сообщения

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением

Ссылка на сообщение

Поделиться на других сайтах

Поделиться сообщением