Commit 4727aa1d authored by 叶剑飞's avatar 叶剑飞

delete file.

parent 01843eff
package com.chainself.crawler;
public class BinanceCrawler {
}
package com.chainself.crawler;
/**
* 火币爬虫
*
* @author yejianfei
*/
public class HuobiCrawler {
}
package com.chainself.crawler;
public class OkexCrawler {
}
package com.chainself.crawler;
public class ZbCrawler {
}
package com.chainself.dao;
import org.springframework.data.repository.CrudRepository;
import com.chainself.entity.Chain;
public interface ChainDao extends CrudRepository<Chain, Long> {
}
package com.chainself.dao;
import org.springframework.data.repository.CrudRepository;
import com.chainself.entity.UserChain;
public interface UserChainDao extends CrudRepository<UserChain, Long> {
}
package com.chainself.entity;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Entity
@Table(name = "chain")
public class Chain {
@Id
private Long id;
private String chain;// 参数代码
private String icon;// 参数名称
private String name;// 中文名称
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getChain() {
return chain;
}
public void setChain(String chain) {
this.chain = chain;
}
public String getIcon() {
return icon;
}
public void setIcon(String icon) {
this.icon = icon;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
package com.chainself.entity;
import javax.persistence.Entity;
import javax.persistence.Id;
import javax.persistence.Table;
@Entity
@Table(name = "user_chain")
public class UserChain {
@Id
private Long id;
private String chain;// 参数代码
private String icon;// 参数名称
private String name;// 中文名称
private String market;// 中文名称
private String priceUnit;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public String getChain() {
return chain;
}
public void setChain(String chain) {
this.chain = chain;
}
public String getIcon() {
return icon;
}
public void setIcon(String icon) {
this.icon = icon;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getMarket() {
return market;
}
public void setMarket(String market) {
this.market = market;
}
public String getPriceUnit() {
return priceUnit;
}
public void setPriceUnit(String priceUnit) {
this.priceUnit = priceUnit;
}
}
package com.chainself.main;
import java.util.Map.Entry;
import java.util.concurrent.ConcurrentHashMap;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
public class PriceCache {
private static ConcurrentHashMap<String, JSONObject> priceMap = new ConcurrentHashMap<String, JSONObject>();
public static JSONObject getPrice(String market, String chain, String unit) {
String key = (market + "_" + chain + unit).toLowerCase();
return priceMap.get(key);
}
private static void savePriceOpen() {
}
public static void initMap(String mapStr) {
long time0 = System.currentTimeMillis();
if (mapStr == null || mapStr.isEmpty()) {
return;
}
JSONObject json = JSON.parseObject(mapStr);
for (Entry<String, Object> jsonItem : json.entrySet()) {
String key = jsonItem.getKey();
JSONObject jsonValue = (JSONObject) jsonItem.getValue();
priceMap.put(key, jsonValue);
}
long time1 = System.currentTimeMillis();
System.out.println("initMap success,size=" + priceMap.size() + " time=" + (time1 - time0));
}
}
package com.chainself.service;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.chainself.dao.ChainDao;
import com.chainself.dao.UserChainDao;
import com.chainself.entity.UserChain;
@Component
@Transactional(readOnly = true)
public class ChainService {
@Autowired
private ChainDao chainDao;
@Autowired
private UserChainDao userChainDao;
public JSONArray findChainAll() {
return (JSONArray) JSON.toJSON(chainDao.findAll());
}
public List<UserChain> findUserChainAll() {
return (List<UserChain>) userChainDao.findAll();
}
}
package com.chainself.util;
import java.util.HashMap;
import spark.Filter;
import spark.Request;
import spark.Response;
import spark.Spark;
public class CorsFilter {
private final HashMap<String, String> corsHeaders = new HashMap<>();
public CorsFilter() {
corsHeaders.put("Access-Control-Allow-Methods", "GET,PUT,POST,DELETE,OPTIONS");
corsHeaders.put("Access-Control-Allow-Origin", "*");
corsHeaders.put("Access-Control-Allow-Headers",
"Content-Type,Authorization,X-Requested-With,Content-Length,Accept,Origin,");
corsHeaders.put("Access-Control-Allow-Credentials", "true");
}
public void apply() {
Filter filter = new Filter() {
@Override
public void handle(Request request, Response response) throws Exception {
corsHeaders.forEach((key, value) -> {
response.header(key, value);
});
}
};
Spark.after(filter);
}
}
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment