125 lines
3.0 KiB
JavaScript
125 lines
3.0 KiB
JavaScript
const app = require('j7/app');
|
|
const utils = require('j7/utils');
|
|
const bcutils = require('j7/bcutils');
|
|
const bcconst = require('common/bcconst');
|
|
const contract = require('common/contract');
|
|
const serviceFactory = require('../services/factory');
|
|
|
|
async function buyPlanet(session) {
|
|
try {
|
|
const account = bcutils.toNormalAddress(session.request('account', ''));
|
|
const netId = session.request('net_id');
|
|
const price = session.request('price');
|
|
const currencyName = session.request('currency_name');
|
|
const ids = utils.jsonDecode(session.request('ids', ''));
|
|
const bc = serviceFactory.create('BlockChain');
|
|
{
|
|
const ret = await bc.init(netId);
|
|
if (!ret) {
|
|
session.rspErr(500, 'net_id error');
|
|
return;
|
|
}
|
|
}
|
|
{
|
|
if (!bc.isValidAddress(account)) {
|
|
session.rspErr(500, 'account error');
|
|
return;
|
|
}
|
|
}
|
|
|
|
const currency = bc.getCurrencyAddressByName(currencyName);
|
|
const userAddress = bc.getUserAddress();
|
|
{
|
|
if (!bc.isValidAddress(currency)) {
|
|
session.rspErr(500, 'ceg error');
|
|
return;
|
|
}
|
|
}
|
|
|
|
const transModel = session.createModel('Transaction');
|
|
const usedTokenIdModel = session.createModel('UsedTokenId');
|
|
|
|
const {err, seqId} = await transModel.add(account, session.requestToJson(), netId);
|
|
if (err) {
|
|
session.rspErr(500, 'server internal error');
|
|
return;
|
|
}
|
|
|
|
const nowTime = utils.getUtcTime();
|
|
const transId = bcutils.genTransId
|
|
(
|
|
bcconst.BC_FUNC_COMMON,
|
|
nowTime,
|
|
seqId,
|
|
[
|
|
]
|
|
);
|
|
await transModel.update
|
|
(
|
|
seqId,
|
|
[
|
|
['trans_id', transId]
|
|
]);
|
|
const nonce = transId;
|
|
const orderId = transId;
|
|
const nftAddresses = [bc.getContractAddressByName('PLANET')];
|
|
const amounts = [1];
|
|
const values = [orderId, price, nowTime, nonce];
|
|
utils.arrayToStrings(ids);
|
|
utils.arrayToStrings(amounts);
|
|
utils.arrayToStrings(values);
|
|
|
|
const signArr = [];
|
|
{
|
|
for (let i = 0; i < ids.length * 2 + 4; ++i) {
|
|
signArr.push('');
|
|
}
|
|
for (let i = 0; i < ids.length; ++i) {
|
|
signArr[i * 2] = ids[i];
|
|
signArr[i * 2 + 1] = amounts[i];
|
|
}
|
|
for (let i = 0; i < values.length; ++i) {
|
|
signArr[ids.length * 2 + i] = values[i];
|
|
}
|
|
}
|
|
console.log([
|
|
currency,
|
|
account,
|
|
...nftAddresses,
|
|
...signArr
|
|
]);
|
|
const signature = await bc.soliditySha3Sign(
|
|
currency,
|
|
account,
|
|
...nftAddresses,
|
|
...signArr
|
|
);
|
|
|
|
const rspParams = [
|
|
currency,
|
|
utils.jsonEncode(nftAddresses),
|
|
utils.jsonEncode(ids),
|
|
utils.jsonEncode(amounts),
|
|
utils.jsonEncode(values),
|
|
signature
|
|
];
|
|
utils.arrayToStrings(rspParams);
|
|
|
|
session.rspData({
|
|
'trans_id' : transId,
|
|
'order_id': orderId,
|
|
'params': rspParams
|
|
});
|
|
} catch (e) {
|
|
session.rspErr(1, 1);
|
|
utils.safeDumpErrStack(e);
|
|
console.log(e);
|
|
}
|
|
}
|
|
|
|
function init() {
|
|
app.registerHandler('BeNftMallTrans', 'buyPlanet', buyPlanet);
|
|
}
|
|
|
|
exports.init = init;
|