| | |
| | | @ResponseBody |
| | | public ServerResponse getStockAiList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum, |
| | | @RequestParam(value = "pageSize", defaultValue = "5") int pageSize, |
| | | @RequestParam(value = "stockName") String stockName) { |
| | | @RequestParam(value = "stockName", required = false) String stockName) { |
| | | return stockAiService.getStockAiList(pageNum, pageSize, stockName); |
| | | } |
| | | |
| | |
| | | /** |
| | | * 同步系统所需要的股票 |
| | | */ |
| | | @Scheduled(cron = "0 0/1 * * * ?") |
| | | @Scheduled(cron = "0 0/3 * * * ?") |
| | | public void syncINStockData() { |
| | | |
| | | if (syncINStockData.get()) { // 判断任务是否在处理中 |
| | |
| | | System.out.println("tw" + message); |
| | | return; |
| | | } |
| | | System.out.println("tw2" + message); |
| | | //System.out.println("tw2" + message); |
| | | Map<String, String> stringObjectMap = jsonToMap(message); |
| | | StockRealTimeBean stockRealTimeBean = new StockRealTimeBean(); |
| | | stockRealTimeBean.setPid(stringObjectMap.get("Id").toString()); |
| | |
| | | System.out.println("hk" + message); |
| | | return; |
| | | } |
| | | System.out.println("hk2" + message); |
| | | //System.out.println("hk2" + message); |
| | | Map<String, String> stringObjectMap = jsonToMap(message); |
| | | StockRealTimeBean stockRealTimeBean = new StockRealTimeBean(); |
| | | stockRealTimeBean.setPid(stringObjectMap.get("Id").toString()); |
| | |
| | | ftp.user=ftp_stock |
| | | ftp.pass=123456 |
| | | ftp.address =/www/wwwroot/ftp_stock/ |
| | | ftp.server.http.prefix=https://img.kuspitai.com/ |
| | | ftp.server.http.prefix=https://img.yanshiz.com/ |
| | | |
| | | redis1.ip=localhost |
| | | redis1.port=6379 |
| | | redis1.port=6380 |
| | | redis1.pwd= |
| | | redis1.timeout=10000 |
| | | redis.max.total=50 |
| | |
| | | # 开发环境配置 |
| | | server: |
| | | # 服务器的HTTP端口,默认为8090 |
| | | port: 8091 |
| | | port: 8219 |
| | | tomcat: |
| | | # tomcat的URI编码 |
| | | uri-encoding: UTF-8 |
| | |
| | | # 地址 |
| | | host: localhost |
| | | # 端口,默认为6379 |
| | | port: 6379 |
| | | port: 6380 |
| | | # 数据库索引 |
| | | database: 0 |
| | | # 密码 |
| | |
| | | datasource: |
| | | type: com.alibaba.druid.pool.DruidDataSource |
| | | driverClassName: com.mysql.cj.jdbc.Driver |
| | | url: jdbc:mysql://127.0.0.1:3306/stock_ci?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8 |
| | | url: jdbc:mysql://127.0.0.1:6306/stock_ci?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8 |
| | | # url: jdbc:mysql://127.0.0.1:3306/cgstock?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8 |
| | | username: root |
| | | username: stock_ci |
| | | password: 123456 |
| | | druid: |
| | | # 初始连接数 |