Commit 7496386e authored by lilei's avatar lilei

高端定制注释

parent 9e68c8c7
...@@ -1753,7 +1753,7 @@ public class HighStockPositionServiceImpl extends ServiceImpl<HighStockPositionM ...@@ -1753,7 +1753,7 @@ public class HighStockPositionServiceImpl extends ServiceImpl<HighStockPositionM
result.setStockCount(num); result.setStockCount(num);
result.setList(list); result.setList(list);
} catch (Exception e) { } catch (Exception e) {
log.error("私人订制获取今日涨跌幅异常", e); log.error("高端订制获取今日涨跌幅异常", e);
} }
return result; return result;
} }
...@@ -1813,7 +1813,7 @@ public class HighStockPositionServiceImpl extends ServiceImpl<HighStockPositionM ...@@ -1813,7 +1813,7 @@ public class HighStockPositionServiceImpl extends ServiceImpl<HighStockPositionM
result.setStockCount(num); result.setStockCount(num);
result.setList(list); result.setList(list);
} catch (Exception e) { } catch (Exception e) {
log.error("私人订制获取实时代码查询异常", e); log.error("高端订制获取实时代码查询异常", e);
} }
return result; return result;
} }
......
...@@ -43,7 +43,7 @@ import static com.zfxftech.telmarket.common.constant.AdminConstant.MarketTypeEnu ...@@ -43,7 +43,7 @@ import static com.zfxftech.telmarket.common.constant.AdminConstant.MarketTypeEnu
@Component @Component
@Order(value = 1) @Order(value = 1)
/** /**
* 私人定制计算总市值、股票市值、持仓数量 * 高端定制计算总市值、股票市值、持仓数量
*/ */
public class HighStockPriceTask implements ApplicationRunner { public class HighStockPriceTask implements ApplicationRunner {
...@@ -60,7 +60,7 @@ public class HighStockPriceTask implements ApplicationRunner { ...@@ -60,7 +60,7 @@ public class HighStockPriceTask implements ApplicationRunner {
@Override @Override
public void run(ApplicationArguments args) throws Exception { public void run(ApplicationArguments args) throws Exception {
log.info("私人定制计算股票统计日志开始"); log.info("高端定制计算股票统计日志开始");
//log.info("私人定制计算股票统计日志开始配置更新开关状态:" + commonConfig.getStockPriceTask()); //log.info("私人定制计算股票统计日志开始配置更新开关状态:" + commonConfig.getStockPriceTask());
if (commonConfig.getStockPriceTask() != null && commonConfig.getStockPriceTask().equals("run")) { if (commonConfig.getStockPriceTask() != null && commonConfig.getStockPriceTask().equals("run")) {
//if (true) { //if (true) {
...@@ -78,7 +78,7 @@ public class HighStockPriceTask implements ApplicationRunner { ...@@ -78,7 +78,7 @@ public class HighStockPriceTask implements ApplicationRunner {
List<CompletableFuture<String>> futureList = new ArrayList<>(); List<CompletableFuture<String>> futureList = new ArrayList<>();
List<HighAccountProductRelation> accountProductRelations = accountProductRelationService.queryAll(); List<HighAccountProductRelation> accountProductRelations = accountProductRelationService.queryAll();
if (!ObjectUtils.isEmpty(accountProductRelations) && accountProductRelations.size() > 0) { if (!ObjectUtils.isEmpty(accountProductRelations) && accountProductRelations.size() > 0) {
log.info("私人定制计算股票统计数据大小:{}", accountProductRelations.size()); log.info("高端定制计算股票统计数据大小:{}", accountProductRelations.size());
Integer pageTOtl = accountProductRelations.size() % pageSize == 0 ? accountProductRelations.size() / pageSize : accountProductRelations.size() / pageSize + 1; Integer pageTOtl = accountProductRelations.size() % pageSize == 0 ? accountProductRelations.size() / pageSize : accountProductRelations.size() / pageSize + 1;
for (Integer i = 0; i < pageTOtl; i++) { for (Integer i = 0; i < pageTOtl; i++) {
...@@ -98,7 +98,7 @@ public class HighStockPriceTask implements ApplicationRunner { ...@@ -98,7 +98,7 @@ public class HighStockPriceTask implements ApplicationRunner {
return " "; return " ";
}, executorServicePersonal).handle((result, ex) -> { }, executorServicePersonal).handle((result, ex) -> {
if (null != ex) { if (null != ex) {
log.error("资管错误消息:{}", ex); log.error("高端定制错误消息:{}", ex);
return 0; return 0;
} else { } else {
return result; return result;
...@@ -112,7 +112,7 @@ public class HighStockPriceTask implements ApplicationRunner { ...@@ -112,7 +112,7 @@ public class HighStockPriceTask implements ApplicationRunner {
CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])); CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0]));
combinedFuture.get(); combinedFuture.get();
log.info("持仓统计--------主线程开始阻塞,消息发送完成--------"); log.info("持仓统计--------主线程开始阻塞,消息发送完成--------");
log.info("私人订制持仓统计,本次共计算" + (ObjectUtils.isEmpty(accountProductRelations) == true ? 0 : accountProductRelations.size()) + "持仓统计。耗时" + DateUtil.calculateTimeGapSecond(startTime, new Date()) + "秒"); log.info("高端定制持仓统计,本次共计算" + (ObjectUtils.isEmpty(accountProductRelations) == true ? 0 : accountProductRelations.size()) + "持仓统计。耗时" + DateUtil.calculateTimeGapSecond(startTime, new Date()) + "秒");
} catch (Exception e) { } catch (Exception e) {
log.error("持仓统计错误信息:{}", e); log.error("持仓统计错误信息:{}", e);
e.printStackTrace(); e.printStackTrace();
...@@ -200,7 +200,7 @@ public class HighStockPriceTask implements ApplicationRunner { ...@@ -200,7 +200,7 @@ public class HighStockPriceTask implements ApplicationRunner {
} }
} catch (Exception e) { } catch (Exception e) {
log.error("私人定制更新数据错误:{}", e); log.error("高端定制更新数据错误:{}", e);
} }
return productRelation; return productRelation;
} }
......
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