Crypto / Crypto-auto-trading

Go to a project
Toggle navigation Toggle navigation pinning
June
f4a87939 1 parent 1a663f49

Modify repeat

Inline Side-by-side
Showing 2 changed files with 179 additions and 70 deletions
const fetch = (...args) => import('node-fetch').then(({ default: fetch }) => fetch(...args));
const url1 = 'https://api.upbit.com/v1/market/all';
const options = { method: 'GET', headers: { Accept: 'application/json' } };
const express = require('express');
const app = express();
const { Coin } = require("./models/Coin");
const {User}=require('./models/User');
require("dotenv").config();
const crypto=require('crypto');
const queryEncode=require('querystring').encode;
const request = require('request')
const {v4} = require("uuid")
const sign = require('jsonwebtoken').sign
var sort_info = new Array();
const mongoose = require('mongoose');
const config = require('./config/key');
const { json } = require('express');
const connect = mongoose.connect(config.mongoURI, {
useNewUrlParser: true, useUnifiedTopology: true
})
......@@ -16,22 +31,90 @@ const connect = mongoose.connect(config.mongoURI, {
.catch((err) => console.log(err));
var korean_name = new Object();
const access_key = process.env.access_key;
const secret_key = process.env.secret_key;
const server_url = "https://api.upbit.com"
function get_asset(){
const payload = {
access_key: access_key,
nonce: v4(),
}
const token = sign(payload, secret_key)
const options = {
method: "GET",
url: server_url + "/v1/accounts",
headers: {Authorization: `Bearer ${token}`},
}
return new Promise(resolve=>{
request(options,function(err,res,body){
if (err) throw new Error(err)
// test=res.json();
data=JSON.parse(body);
// console.log(data[0].currency)
data.filter(function(item){
if(item.currency=="PLA"){
resolve(item);
}
})
})
})
}
async function get_marketName() {
var data = new Array();
//전체 암호화폐 리스트 불러오기
let response = await fetch(url1, options)
let response = await fetch(`${server_url}/v1/market/all`, options)
.then(res => res.json())
.then(json => {
for (i in json) {
data.push(json[i].market);
korean_name[json[i].market] = json[i].korean_name;
}
})
return data;
}
async function transaction_coin(coin_name,side,volume,price,ord_type){
const body = {
market: coin_name,
side: side,
volume: volume,
price: price,
ord_type: ord_type,
}
//시장가 매수인 경우 price를 얼마치 살건지 입력
//시장가 매도인경우 volume에 몇개를 팔건지 입력
const query = queryEncode(body)
const hash = crypto.createHash('sha512')
const queryHash = hash.update(query, 'utf-8').digest('hex')
const payload = {
access_key: access_key,
nonce: v4(),
query_hash: queryHash,
query_hash_alg: 'SHA512',
}
const token = sign(payload, secret_key)
const options = {
method: "POST",
url: server_url + "/v1/orders",
headers: {Authorization: `Bearer ${token}`},
json: body
}
request(options, (error, response, body) => {
if (error) throw new Error(error)
console.log(body)
})
}
async function get_marketInfo() {
//각 암호화폐 정보 조회
var name_list = await get_marketName();
const url2 = `https://api.upbit.com/v1/ticker/?markets=${name_list}`;
const url2 = `${server_url}/v1/ticker/?markets=${name_list}`;
var arr = new Array();
let response2 = await fetch(url2, options)
.then(res => res.json())
......@@ -57,6 +140,7 @@ async function save_coin(arr) {
const coin = new Coin({
tid: i + 1,
name: arr[i][0],
korean_name: korean_name[arr[i][0]],
acc_trade_price_24h: arr[i][1],
current_price: arr[i][2]
});
......@@ -69,6 +153,21 @@ async function save_coin(arr) {
}
return true;
}
async function refresh_db() {
Coin.find()
.then(result => {
if (result.length !== 0) {
Coin.deleteMany({ tid: { $gt: 0 } }, (err, result) => {
if (err) {
console.log(err);
} else {
console.log(result);
}
})
}
save_coin(sort_info);
})
}
async function get_candle(minute, market) {
const url = `https://api.upbit.com/v1/candles/minutes/${minute}?market=${market}&count=1`;
var candle = new Array();
......@@ -77,87 +176,78 @@ async function get_candle(minute, market) {
.then(json => candle = json)
return candle;
}
app.get('/get_market', async (req, res) => {
var name_list = (await get_marketName());
var market_info = (await get_marketInfo(name_list));
sort_info = (await sort_data(market_info));
res.json(await save_coin(sort_info));
})
app.get('/get_candle', async (req, res) => {
Coin.find()
.then(result => {
result.forEach((item) => {
get_candle(5, item.name)
.then(result => {
Coin.findOneAndUpdate({ name: result[0].market }, { five_candle: result[0].trade_price }, { new: true }, (err, doc) => {
// console.log(doc);
})
})
})
});
})
async function refresh_db() {
Coin.find()
.then(result => {
if (result.length !== 0) {
Coin.deleteMany({ tid: { $gt: 0 } }, (err, result) => {
async function check_coin(t1) {
for (var i = 0; i < t1.length; i++) {
var candle = await get_candle(5, t1[i]);
await Coin.findOne({ name: candle[0].market }).then((result) => {
//가격이 떨어졌을때
if (result.current_price > candle[0].trade_price) {
Coin.findOneAndUpdate({ name: candle[0].market }, { current_price: candle[0].trade_price, $inc: { count: 1 } }, { new: true }, (err, result) => {
if (err) {
console.log(err);
} else {
console.log(result);
console.log("***" + result.korean_name + "은(는)" + result.count * 5 + "분 동안 하락중");
if(count>=3){
transaction_coin(result.name,"bid",null,"얼마치 살건지","price");
}
}
})
}//그대로 이거나 올랐을때
else {
Coin.findOneAndUpdate({ name: candle[0].market }, { current_price: candle[0].trade_price, count: 0 }, { new: true }, (err, result) => {
if (err) {
console.log(err);
} else {
//특정 조건...
transaction_coin(result.name,"ask","몇개를 팔건지",null,"market");
console.log(result.korean_name + "은(는)" + result.count * 5 + "분 동안 상승 혹은 정체중");
}
})
}
save_coin(sort_info);
})
}
}
async function repeat_check(t1) {
await Coin.find().then(result => {
async function latest_repeat(t1) {
await Coin.find().sort({ tid: 1 }).then(result => {
for (var key in result) {
t1.push(result[key].name)
}
})
setTimeout(() => {
setInterval(async () => {
for (var i = 0; i < t1.length; i++) {
// console.log(t1.length);
// console.log(t1[i]);
var candle = await get_candle(5, t1[i]);
// console.log(i+"번째 코인 가격 "+candle[0].trade_price);
await Coin.findOne({ name: candle[0].market }).then((result) => {
//가격이 떨어졌을때
if (result.current_price > candle[0].trade_price) {
Coin.updateOne({ name: candle[0].market }, { current_price: candle[0].trade_price, $inc: { count: 1 } }, (err, result) => {
if (err) {
console.log(err);
} else {
}
})
}//그대로 이거나 올랐을때
else {
Coin.updateOne({ name: candle[0].market }, { current_price: candle[0].trade_price, count: 0 }, (err, result) => {
if (err) {
console.log(err);
} else {
}
})
}
})
}
}, 600 * 5);
}, 600 * 5);
let check_time = setInterval(async () => {
let today = new Date();
let minutes = today.getMinutes();
let seconds = today.getSeconds();
// if (seconds == 0) {
if (minutes == 0 && seconds == 0) {
clearInterval(check_time);
sort_info = (await sort_data());
(await refresh_db());
console.log("현재 시간은 " + today.toLocaleTimeString());
var count=0;
let coin=setInterval(async () => {
let today = new Date();
let minutes=today.getMinutes();
let seconds=today.getSeconds();
console.log("현재 시간은 " + today.toLocaleTimeString());
await (check_coin(t1).then(count++));
//1시간마다 db 최신화...
if(count==12){
count=0;
sort_info=(await sort_data());
(await refresh_db());
console.log("db최신화");
}
}, 60000*5);
}
}, 1000);
}
app.listen(5000, async () => {
console.log('server start')
//coin 이름,가격,거래대금 저장
sort_info = (await sort_data());
//DB 최신화
(await refresh_db());
//coin 이름,가격,거래대금 저장 , DB 최신화 1시간마다 반복
//5분마다 현재 가격 가져와서 db랑 비교후 매수 매도 기준잡기
var t1 = new Array();
test_data = await (repeat_check(t1));
//반복
test_data=await (latest_repeat(t1));
//계좌 정보 db 최신화
console.log(await get_asset());
})
\ No newline at end of file
......
const mongoose=require('mongoose');
const userSchema=mongoose.Schema({
krw_balance:{
type:Number,
},
market:{
type:String,
},
count:{
type:Number,
},
avg_buy_price:{
type:Number
}
})
const User=mongoose.model("User",userSchema);
module.exports={User};
\ No newline at end of file