| | |
| | | import com.yami.trading.bean.data.domain.Realtime; |
| | | import com.yami.trading.common.http.HttpHelper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import javax.crypto.Mac; |
| | |
| | | //封装行情缓存 |
| | | Realtime realtime = new Realtime(); |
| | | String symbol = item.getString("s"); |
| | | realtime.setSymbol(symbol); |
| | | realtime.setSymbol(StringUtils.substringAfter(symbol, ":")); |
| | | JSONArray data = item.getJSONArray("d"); |
| | | realtime.setName(data.get(1) != null ? (String) data.get(1) : ""); |
| | | realtime.setTs(DateTime.now().getTime()); |