From 97cdb7f4c635d707abe9dd930c7b84a92cfff690 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 13 Aug 2020 19:02:30 +0800
Subject: [PATCH] 20200813 数据监控
---
src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringAdd.html | 72 +++++
src/main/java/com/xcong/excoin/modules/dataMonitoring/entity/DataMonitoringEntity.java | 64 ++++
src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/DataMonitoringController.java | 50 +++
src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/ViewController.java | 37 ++
src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringList.html | 156 ++++++++++++
src/main/java/com/xcong/excoin/modules/dataMonitoring/service/DataMonitoringService.java | 17 +
src/main/java/com/xcong/excoin/modules/dataMonitoring/service/impl/DataMonitoringServiceImpl.java | 248 +++++++++++++++++++
src/main/java/com/xcong/excoin/modules/dataMonitoring/mapper/DataMonitoringMapper.java | 34 ++
src/main/resources/mapper/modules/DataMonitoringMapper.xml | 88 ++++++
9 files changed, 766 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/DataMonitoringController.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/DataMonitoringController.java
new file mode 100644
index 0000000..753aea1
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/DataMonitoringController.java
@@ -0,0 +1,50 @@
+package com.xcong.excoin.modules.dataMonitoring.controller;
+
+import java.util.Map;
+
+import javax.validation.Valid;
+
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.xcong.excoin.common.controller.BaseController;
+import com.xcong.excoin.common.entity.FebsResponse;
+import com.xcong.excoin.common.entity.QueryRequest;
+import com.xcong.excoin.modules.dataMonitoring.entity.DataMonitoringEntity;
+import com.xcong.excoin.modules.dataMonitoring.service.DataMonitoringService;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Validated
+@RestController
+@RequiredArgsConstructor
+@RequestMapping(value = "/dataMonitoring")
+public class DataMonitoringController extends BaseController {
+
+ private final DataMonitoringService dataMonitoringService;
+
+ /**
+ * 数据监控---列表
+ * @return
+ */
+ @GetMapping("dataMonitoringList")
+ public FebsResponse dataMonitoringList(DataMonitoringEntity dataMonitoringEntity, QueryRequest request) {
+ Map<String, Object> data = getDataTable(dataMonitoringService.findDataMonitoringListInPage(dataMonitoringEntity, request));
+ return new FebsResponse().success().data(data);
+ }
+
+ /**
+ * 数据监控---数据更新
+ */
+ @PostMapping("dataMonitoringListUpdate")
+ public FebsResponse dataMonitoringListUpdate(@Valid DataMonitoringEntity dataMonitoringEntity) {
+ dataMonitoringService.dataMonitoringListUpdate(dataMonitoringEntity);
+ return new FebsResponse().success();
+ }
+
+}
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/ViewController.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/ViewController.java
new file mode 100644
index 0000000..7ba9697
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/controller/ViewController.java
@@ -0,0 +1,37 @@
+package com.xcong.excoin.modules.dataMonitoring.controller;
+
+import org.apache.shiro.authz.annotation.RequiresPermissions;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+
+import com.xcong.excoin.common.entity.FebsConstant;
+import com.xcong.excoin.common.utils.FebsUtil;
+
+import lombok.RequiredArgsConstructor;
+
+@Controller("dataMonitoringView")
+@RequestMapping(FebsConstant.VIEW_PREFIX + "modules/dataMonitoring")
+@RequiredArgsConstructor
+public class ViewController {
+
+ /**
+ * 数据监控列表
+ * @return
+ */
+ @GetMapping("dataMonitoringList")
+ @RequiresPermissions("dataMonitoringList:view")
+ public String traderUpdate() {
+ return FebsUtil.view("modules/dataMonitoring/dataMonitoringList");
+ }
+
+ /**
+ * 数据监控列表---更新
+ */
+ @GetMapping("dataMonitoringAdd")
+ @RequiresPermissions("dataMonitoringAdd:add")
+ public String helpCenterAdd() {
+ return FebsUtil.view("modules/dataMonitoring/dataMonitoringAdd");
+ }
+
+}
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/entity/DataMonitoringEntity.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/entity/DataMonitoringEntity.java
new file mode 100644
index 0000000..4b0a162
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/entity/DataMonitoringEntity.java
@@ -0,0 +1,64 @@
+package com.xcong.excoin.modules.dataMonitoring.entity;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.fasterxml.jackson.annotation.JsonFormat;
+
+import lombok.Data;
+
+/**
+ * 数据监控
+ */
+@Data
+@TableName("data_monitoring")
+public class DataMonitoringEntity {
+ //订单数
+ public static final int ORDER_COUNT_TODAY = 30;
+ //比例
+ public static final double ORDER_BILI_TODAY = 0.5;
+ //总盈亏
+ public static final String ORDER_ALLREWARD_TODAY = "500";
+
+ @TableId(value = "id",type = IdType.AUTO)
+ private Long id;
+
+ @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss", timezone = "GMT+8")
+ private Date createTime;
+
+ /**
+ * 会员ID
+ */
+ private Long memberId;
+ /**
+ * 当天订单总数
+ */
+ private int count;
+ /**
+ * 总盈亏
+ */
+ private BigDecimal reward;
+ /**
+ *不符合条件的订单数量
+ */
+ private int countOut;
+ /**
+ * 1:每日开仓数超过30 2:三分钟平仓操作订单超过每日总订单数的50% 3：订单总盈亏超过500
+ */
+ private int type;
+
+ @TableField(exist = false)
+ private String account;
+ @TableField(exist = false)
+ private String phone;
+ @TableField(exist = false)
+ private String email;
+
+ @TableField(exist = false)
+ private String orderType;
+
+}
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/mapper/DataMonitoringMapper.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/mapper/DataMonitoringMapper.java
new file mode 100644
index 0000000..42748b7
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/mapper/DataMonitoringMapper.java
@@ -0,0 +1,34 @@
+package com.xcong.excoin.modules.dataMonitoring.mapper;
+
+import java.util.List;
+
+import org.apache.ibatis.annotations.Param;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.xcong.excoin.modules.dataMonitoring.entity.DataMonitoringEntity;
+import com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity;
+import com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity;
+
+public interface DataMonitoringMapper extends BaseMapper<DataMonitoringEntity> {
+
+ IPage<DataMonitoringEntity> findDataMonitoringListInPage(Page<DataMonitoringEntity> page,
+ @Param("record") DataMonitoringEntity dataMonitoringEntity);
+
+ List<ContractHoldOrderEntity> selectContractHoldOrderListInToday(@Param("createTime")String format);
+
+ String selectContractHoldOrderAccountInToday(@Param("createTime")String format, @Param("memberId")long memberIdString);
+
+ List<ContractOrderEntity> selectContractOrderListInToday(String format);
+
+ String selectContractOrderAccountInToday(@Param("createTime")String format, @Param("memberId")long memberIdString);
+
+ List<ContractOrderEntity> selectContractOrderListLessThreeInToday(@Param("createTime")String format);
+
+ String selectContractOrderListLessThreeCountInToday(@Param("createTime")String format, @Param("memberId")long memberIdString);
+
+ String selectRewardratioForBasicRealDataBymid(@Param("memberId")Long id);
+
+
+}
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/DataMonitoringService.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/DataMonitoringService.java
new file mode 100644
index 0000000..403e754
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/DataMonitoringService.java
@@ -0,0 +1,17 @@
+package com.xcong.excoin.modules.dataMonitoring.service;
+
+import javax.validation.Valid;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xcong.excoin.common.entity.QueryRequest;
+import com.xcong.excoin.modules.dataMonitoring.entity.DataMonitoringEntity;
+
+public interface DataMonitoringService extends IService<DataMonitoringEntity> {
+
+ IPage<DataMonitoringEntity> findDataMonitoringListInPage(DataMonitoringEntity dataMonitoringEntity, QueryRequest request);
+
+ void dataMonitoringListUpdate(@Valid DataMonitoringEntity dataMonitoringEntity);
+
+
+}
diff --git a/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/impl/DataMonitoringServiceImpl.java b/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/impl/DataMonitoringServiceImpl.java
new file mode 100644
index 0000000..11a2cfd
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/modules/dataMonitoring/service/impl/DataMonitoringServiceImpl.java
@@ -0,0 +1,248 @@
+package com.xcong.excoin.modules.dataMonitoring.service.impl;
+
+import java.math.BigDecimal;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+
+import javax.validation.Valid;
+
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xcong.excoin.common.entity.QueryRequest;
+import com.xcong.excoin.modules.dataMonitoring.entity.DataMonitoringEntity;
+import com.xcong.excoin.modules.dataMonitoring.mapper.DataMonitoringMapper;
+import com.xcong.excoin.modules.dataMonitoring.service.DataMonitoringService;
+import com.xcong.excoin.modules.member.entity.MemberEntity;
+import com.xcong.excoin.modules.member.mapper.MemberMapper;
+import com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity;
+import com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.util.StrUtil;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class DataMonitoringServiceImpl extends ServiceImpl<DataMonitoringMapper, DataMonitoringEntity> implements DataMonitoringService {
+
+ private final DataMonitoringMapper dataMonitoringMapper;
+
+ private final MemberMapper memberMapper;
+
+ @Override
+ public IPage<DataMonitoringEntity> findDataMonitoringListInPage(DataMonitoringEntity dataMonitoringEntity,
+ QueryRequest request) {
+ Page<DataMonitoringEntity> page = new Page<>(request.getPageNum(), request.getPageSize());
+ IPage<DataMonitoringEntity> DataMonitoringEntitys = dataMonitoringMapper.findDataMonitoringListInPage(page, dataMonitoringEntity);
+ return DataMonitoringEntitys;
+ }
+
+ @Override
+ @Transactional
+ public void dataMonitoringListUpdate(@Valid DataMonitoringEntity dataMonitoringEntity) {
+ String orderType = dataMonitoringEntity.getOrderType();
+ //1---每日开仓数超过30(包含当前持仓和历史持仓)
+ if(StrUtil.isNotEmpty(orderType) && orderType.equals("1")) {
+
+ //获取【合约持仓订单表】
+ Date date = new Date();
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
+ String format = sdf.format(date);
+ List<ContractHoldOrderEntity> contractHoldOrderEntitys = dataMonitoringMapper.selectContractHoldOrderListInToday(format);
+ List<ContractOrderEntity> contractOrderEntitys = dataMonitoringMapper.selectContractOrderListInToday(format);
+
+ Set<Long> set = new HashSet<>();
+ //获取当前持仓的用户
+ if(CollUtil.isNotEmpty(contractHoldOrderEntitys)) {
+ for(ContractHoldOrderEntity contractHoldOrderEntity : contractHoldOrderEntitys) {
+ Long memberId = contractHoldOrderEntity.getMemberId();
+ set.add(memberId);
+ }
+ }
+ //获取今日历史订单数据
+ if(CollUtil.isNotEmpty(contractOrderEntitys)) {
+ for(ContractOrderEntity contractOrderEntity : contractOrderEntitys) {
+ Long memberId = contractOrderEntity.getMemberId();
+ set.add(memberId);
+ }
+ }
+ if(CollUtil.isNotEmpty(set)) {
+ for(long memberIdString : set) {
+ //获取每个用户的当前持仓数量
+ String count = dataMonitoringMapper.selectContractHoldOrderAccountInToday(format,memberIdString);
+ //获取每个用户的历史持仓数量
+ String countHistory = dataMonitoringMapper.selectContractOrderAccountInToday(format,memberIdString);
+ if(StrUtil.isNotEmpty(count)) {
+ int parseInt = Integer.parseInt(count);
+ int parseIntHistory = Integer.parseInt(countHistory);
+ int allOrder = parseInt + parseIntHistory;
+ if(allOrder >= DataMonitoringEntity.ORDER_COUNT_TODAY) {
+ //查询是否存在
+ Map<String, Object> columnMaps = new HashMap<>();
+ columnMaps.put("member_id", memberIdString);
+ columnMaps.put("type", 1);
+ List<DataMonitoringEntity> selectByMap = dataMonitoringMapper.selectByMap(columnMaps);
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ DataMonitoringEntity dataMonitoringOne = selectByMap.get(0);
+ dataMonitoringOne.setCount(allOrder);
+ dataMonitoringOne.setCreateTime(new Date());
+ dataMonitoringMapper.updateById(dataMonitoringOne);
+ }
+ DataMonitoringEntity dataMonitoring = new DataMonitoringEntity();
+ dataMonitoring.setMemberId(memberIdString);
+ dataMonitoring.setCount(allOrder);
+ dataMonitoring.setType(1);
+ dataMonitoring.setCreateTime(new Date());
+ dataMonitoringMapper.insert(dataMonitoring);
+ }
+ }
+ }
+ }
+ //2---三分钟平仓操作订单超过每日总订单数的50%
+ }else if(StrUtil.isNotEmpty(orderType) && orderType.equals("2")){
+ //获取【合约持仓订单表】
+ Date date = new Date();
+ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd 00:00:00");
+ String format = sdf.format(date);
+ List<ContractOrderEntity> contractOrderEntitys = dataMonitoringMapper.selectContractOrderListLessThreeInToday(format);
+
+ Set<Long> set = new HashSet<>();
+ //获取符合条件的今日历史订单数据
+ if(CollUtil.isNotEmpty(contractOrderEntitys)) {
+ for(ContractOrderEntity contractOderEntity : contractOrderEntitys) {
+ Long memberId = contractOderEntity.getMemberId();
+ set.add(memberId);
+ }
+ }
+ if(CollUtil.isNotEmpty(set)) {
+ for(long memberIdString : set) {
+ //获取每个用户的当前持仓数量
+ String count = dataMonitoringMapper.selectContractHoldOrderAccountInToday(format,memberIdString);
+ //获取每个用户的历史持仓数量
+ String countHistory = dataMonitoringMapper.selectContractOrderAccountInToday(format,memberIdString);
+ //符合条件的订单数量
+ String countIn = dataMonitoringMapper.selectContractOrderListLessThreeCountInToday(format,memberIdString);
+ if(StrUtil.isNotEmpty(countIn)) {
+ BigDecimal parse = new BigDecimal(count);
+ BigDecimal parseHistory = new BigDecimal(countHistory);
+ BigDecimal parseIn = new BigDecimal(countIn);
+ BigDecimal add = parse.add(parseHistory);
+ if(add.compareTo(BigDecimal.ZERO) > 0) {
+ BigDecimal divide = parseIn.divide(add,4,BigDecimal.ROUND_HALF_UP);
+ double s = divide.doubleValue();
+ if(s >= DataMonitoringEntity.ORDER_BILI_TODAY) {
+ //查询是否存在
+ Map<String, Object> columnMaps = new HashMap<>();
+ columnMaps.put("member_id", memberIdString);
+ columnMaps.put("type", 2);
+ List<DataMonitoringEntity> selectByMap = dataMonitoringMapper.selectByMap(columnMaps);
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ DataMonitoringEntity dataMonitoringTwo = selectByMap.get(0);
+ dataMonitoringTwo.setCount(add.intValue());
+ dataMonitoringTwo.setCountOut(parseIn.intValue());
+ dataMonitoringTwo.setCreateTime(new Date());
+ dataMonitoringMapper.updateById(dataMonitoringTwo);
+ }else {
+ DataMonitoringEntity dataMonitoring = new DataMonitoringEntity();
+ dataMonitoring.setMemberId(memberIdString);
+ dataMonitoring.setCount(add.intValue());
+ dataMonitoring.setCountOut(parseIn.intValue());
+ dataMonitoring.setType(2);
+ dataMonitoring.setCreateTime(new Date());
+ dataMonitoringMapper.insert(dataMonitoring);
+ }
+
+ }
+ }
+ }
+ }
+ }
+ //3：订单总盈亏超过500
+ }else if(StrUtil.isNotEmpty(orderType) && orderType.equals("3")){
+ Map<String, Object> columnMap = new HashMap<>();
+ List<MemberEntity> memberEntitys = memberMapper.selectByMap(columnMap);
+ if(CollUtil.isNotEmpty(memberEntitys)) {
+ for(MemberEntity memberEntity : memberEntitys) {
+ Long id = memberEntity.getId();
+ String rewardratioByMid = dataMonitoringMapper.selectRewardratioForBasicRealDataBymid(id);
+ BigDecimal subtract = new BigDecimal(rewardratioByMid).subtract(new BigDecimal(DataMonitoringEntity.ORDER_ALLREWARD_TODAY));
+ if(subtract.compareTo(BigDecimal.ZERO) > 0 ) {
+ //查询是否存在
+ Map<String, Object> columnMaps = new HashMap<>();
+ columnMaps.put("member_id", id);
+ columnMaps.put("type", 3);
+ List<DataMonitoringEntity> selectByMap = dataMonitoringMapper.selectByMap(columnMaps);
+ if(CollUtil.isNotEmpty(selectByMap)) {
+ DataMonitoringEntity dataMonitoringOld = selectByMap.get(0);
+ dataMonitoringOld.setReward(new BigDecimal(rewardratioByMid));
+ dataMonitoringOld.setCreateTime(new Date());
+ dataMonitoringMapper.updateById(dataMonitoringOld);
+ }else {
+ DataMonitoringEntity dataMonitoring = new DataMonitoringEntity();
+ dataMonitoring.setMemberId(id);
+ dataMonitoring.setReward(new BigDecimal(rewardratioByMid));
+ dataMonitoring.setType(3);
+ dataMonitoring.setCreateTime(new Date());
+ dataMonitoringMapper.insert(dataMonitoring);
+ }
+
+ }
+ }
+ }
+
+ }
+
+ }
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+}
diff --git a/src/main/resources/mapper/modules/DataMonitoringMapper.xml b/src/main/resources/mapper/modules/DataMonitoringMapper.xml
new file mode 100644
index 0000000..2745a2f
--- /dev/null
+++ b/src/main/resources/mapper/modules/DataMonitoringMapper.xml
@@ -0,0 +1,88 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xcong.excoin.modules.dataMonitoring.mapper.DataMonitoringMapper">
+
+ <select id="findDataMonitoringListInPage" resultType="com.xcong.excoin.modules.dataMonitoring.entity.DataMonitoringEntity">
+ select * from data_monitoring s left join member m on m.id = s.member_id
+ <where>
+ <if test="record != null" >
+ <if test="record.account!=null and record.account!=''">
+ and (m.phone = #{record.account} or m.email = #{record.account} or m.invite_id=#{record.account})
+ </if>
+ </if>
+ </where>
+ order by m.create_time desc
+ </select>
+
+ <select id="selectContractHoldOrderListInToday" resultType="com.xcong.excoin.modules.trademanage.entity.ContractHoldOrderEntity">
+ SELECT
+ *
+ FROM
+ contract_hold_order s
+ LEFT JOIN member m ON m.id = s.member_id
+ where s.create_time >= #{createTime}
+ </select>
+
+ <select id="selectContractOrderListInToday" resultType="com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity">
+ SELECT
+ *
+ FROM
+ contract_order s
+ LEFT JOIN member m ON m.id = s.member_id where s.create_time >= #{createTime}
+ </select>
+
+ <select id="selectContractHoldOrderAccountInToday" resultType="java.lang.String">
+ SELECT
+ COUNT(s.id)
+ FROM
+ contract_hold_order s
+ LEFT JOIN member m ON m.id = s.member_id where s.member_id = #{memberId} and s.create_time >= #{createTime}
+ </select>
+
+ <select id="selectContractOrderAccountInToday" resultType="java.lang.String">
+ SELECT
+ COUNT(s.id)
+ FROM
+ contract_order s
+ LEFT JOIN member m ON m.id = s.member_id
+ where
+ s.closing_type in (2,3,4,5,6,7,8,9)
+ and s.member_id = #{memberId}
+ and s.create_time >= #{createTime}
+ </select>
+
+ <select id="selectContractOrderListLessThreeInToday" resultType="com.xcong.excoin.modules.trademanage.entity.ContractOrderEntity">
+ SELECT
+ *
+ FROM
+ contract_order s
+ LEFT JOIN member m ON m.id = s.member_id
+ where s.create_time >= #{createTime} and (TIMESTAMPDIFF(MINUTE,s.opening_time,s.closing_time) <![CDATA[ <= ]]> 3)
+ </select>
+
+ <select id="selectContractOrderListLessThreeCountInToday" resultType="java.lang.String">
+ SELECT
+ COUNT(s.id)
+ FROM
+ contract_order s
+ LEFT JOIN member m ON m.id = s.member_id
+ where s.create_time >= #{createTime}
+ and TIMESTAMPDIFF(
+ MINUTE,
+ s.opening_time,
+ s.closing_time
+ ) <![CDATA[ <= ]]> 3
+ </select>
+
+ <select id="selectRewardratioForBasicRealDataBymid" resultType="java.lang.String">
+ SELECT
+ IFNULL(SUM(a.reward_amount), '0')
+ FROM
+ contract_order a
+ WHERE
+ a.closing_type IN (2,3,4, 5, 6, 7, 8, 9)
+ AND a.order_status = '1'
+ AND a.member_id = #{memberId}
+ </select>
+
+</mapper>
\ No newline at end of file
diff --git a/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringAdd.html b/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringAdd.html
new file mode 100644
index 0000000..7f41fbe
--- /dev/null
+++ b/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringAdd.html
@@ -0,0 +1,72 @@
+<style>
+ #user-add {
+ padding: 20px 25px 25px 0;
+ }
+
+ #user-add .layui-treeSelect .ztree li a, .ztree li span {
+ margin: 0 0 2px 3px !important;
+ }
+ #user-add #data-permission-tree-block {
+ border: 1px solid #eee;
+ border-radius: 2px;
+ padding: 3px 0;
+ }
+ #user-add .layui-treeSelect .ztree li span.button.switch {
+ top: 1px;
+ left: 3px;
+ }
+
+</style>
+<div class="layui-fluid" id="user-add">
+ <form class="layui-form" action="" lay-filter="user-add-form">
+ <div class="layui-form-item">
+ <label class="layui-form-label febs-form-item-require">情况如下：</label>
+ </div>
+ <div class="layui-form-item">
+ <div class="layui-input-block">
+ <input type="radio" name="orderType" value="1" title="每日开仓数超过30" checked="">
+ </div>
+ <div class="layui-input-block">
+ <input type="radio" name="orderType" value="2" title="三分钟平仓操作订单超过每日总订单数的50%">
+ </div>
+ <div class="layui-input-block">
+ <input type="radio" name="orderType" value="3" title="订单总盈亏超过500">
+ </div>
+ </div>
+ <div class="layui-form-item febs-hide">
+ <button class="layui-btn" lay-submit="" lay-filter="user-add-form-submit" id="submit"></button>
+ </div>
+ </form>
+</div>
+
+<script data-th-inline="javascript">
+layui.use(['febs', 'form', 'formSelects', 'validate', 'treeSelect', 'eleTree', 'laydate'], function () {
+ var $ = layui.$,
+ febs = layui.febs,
+ layer = layui.layer,
+ formSelects = layui.formSelects,
+ treeSelect = layui.treeSelect,
+ form = layui.form,
+ laydate = layui.laydate,
+ eleTree = layui.eleTree,
+ member = [[${member}]],
+ $view = $('#user-add'),
+ validate = layui.validate;
+
+ form.render();
+ laydate.render({
+ elem: '#febs-form-group-date'
+ });
+
+ formSelects.render();
+
+ form.on('submit(user-add-form-submit)', function (data) {
+ febs.post(ctx + 'dataMonitoring/dataMonitoringListUpdate', data.field, function () {
+ layer.closeAll();
+ febs.alert.success('更新成功');
+ $('#febs-user').find('#reset').click();
+ });
+ return false;
+ });
+ });
+</script>
\ No newline at end of file
diff --git a/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringList.html b/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringList.html
new file mode 100644
index 0000000..31f42cc
--- /dev/null
+++ b/src/main/resources/templates/febs/views/modules/dataMonitoring/dataMonitoringList.html
@@ -0,0 +1,156 @@
+<div class="layui-fluid layui-anim febs-anim" id="febs-user" lay-title="数据监控">
+ <div class="layui-row febs-container">
+ <div class="layui-col-md12">
+ <div class="layui-card">
+ <div class="layui-card-body febs-table-full">
+ <form class="layui-form layui-table-form" lay-filter="user-table-form">
+ <div class="layui-row">
+ <div class="layui-col-md10">
+ <div class="layui-form-item">
+ <div class="layui-inline">
+ <div class="layui-input-inline">
+ <input type="text" placeholder="手机号/邮箱/邀请码" name="account" autocomplete="off" class="layui-input">
+ </div>
+ </div>
+ </div>
+ </div>
+ <div class="layui-col-md2 layui-col-sm12 layui-col-xs12 table-action-area">
+ <div class="layui-btn layui-btn-sm layui-btn-primary febs-button-green-plain table-action" id="add">
+ 更新数据
+ </div>
+ <div class="layui-btn layui-btn-sm layui-btn-primary febs-button-blue-plain table-action" id="query">
+ <i class="layui-icon"></i>
+ </div>
+ <div class="layui-btn layui-btn-sm layui-btn-primary febs-button-green-plain table-action" id="reset">
+ <i class="layui-icon"></i>
+ </div>
+ </div>
+ </div>
+ </form>
+ <table lay-filter="userTable" lay-data="{id: 'userTable'}"></table>
+ </div>
+ </div>
+ </div>
+ </div>
+</div>
+<!-- 表格操作栏 start -->
+<script type="text/html" id="user-option">
+ <span shiro:lacksPermission="user:view,user:update,user:delete">
+ <span class="layui-badge-dot febs-bg-orange"></span> 无权限
+ </span>
+ <a lay-event="edit" shiro:hasPermission="user:update"><i
+ class="layui-icon febs-edit-area febs-blue"></i></a>
+</script>
+<!-- 表格操作栏 end -->
+<script data-th-inline="none" type="text/javascript">
+ // 引入组件并初始化
+ layui.use([ 'jquery', 'form', 'table', 'febs'], function () {
+ var $ = layui.jquery,
+ febs = layui.febs,
+ form = layui.form,
+ table = layui.table,
+ $view = $('#febs-user'),
+ $query = $view.find('#query'),
+ $add = $view.find('#add'),
+ $reset = $view.find('#reset'),
+ $searchForm = $view.find('form'),
+ sortObject = {field: 'phone', type: null},
+ tableIns;
+
+ form.render();
+
+ // 表格初始化
+ initTable();
+
+ // 初始化表格操作栏各个按钮功能
+ table.on('tool(userTable)', function (obj) {
+ var data = obj.data,
+ layEvent = obj.event;
+
+ if (layEvent === 'edit') {
+ febs.modal.open('交易员审核', 'modules/documentary/traderDetail/' + data.id, {
+ btn: ['确认', '取消'],
+ yes: function (index, layero) {
+ $('#user-update').find('#submit').trigger('click');
+ },
+ btn2: function () {
+ layer.closeAll();
+ }
+ });
+ }
+ if (layEvent === 'getOut') {
+ febs.modal.confirm('确认', '您是否要踢出该交易员？', function () {
+ confirmUsers(data.id);
+ });
+ }
+ });
+
+ function confirmUsers(id) {
+ febs.get(ctx + 'documentary/traderGetOut/' + id, null, function () {
+ febs.alert.success('踢出成功');
+ $query.click();
+ });
+ }
+
+ $add.on('click', function () {
+ febs.modal.open('更新数据', 'modules/dataMonitoring/dataMonitoringAdd/', {
+ btn: ['提交', '取消'],
+ yes: function (index, layero) {
+ $('#user-add').find('#submit').trigger('click');
+ },
+ btn2: function () {
+ layer.closeAll();
+ }
+ });
+ });
+
+
+ // 查询按钮
+ $query.on('click', function () {
+ var params = $.extend(getQueryParams(), {field: sortObject.field, order: sortObject.type});
+ tableIns.reload({where: params, page: {curr: 1}});
+ });
+
+ // 刷新按钮
+ $reset.on('click', function () {
+ $searchForm[0].reset();
+ tableIns.reload({where: getQueryParams(), page: {curr: 1}});
+ });
+
+ function initTable() {
+ tableIns = febs.table.init({
+ elem: $view.find('table'),
+ id: 'userTable',
+ url: ctx + 'dataMonitoring/dataMonitoringList',
+ cols: [[
+ {field: 'phone', title: '电话', minWidth: 80,align:'left'},
+ {field: 'email', title: '邮箱', minWidth: 80,align:'left'},
+ {field: 'reward', title: '总盈亏', minWidth: 80,align:'left'},
+ {field: 'count', title: '当天订单总数', minWidth: 80,align:'left'},
+ {field: 'countOut', title: '不符合条件的订单数量', minWidth: 100,align:'left'},
+ {field: 'createTime', title: '更新时间', minWidth: 100,align:'left'},
+ {field: 'type', title: '类别',
+ templet: function (d) {
+ if (d.type === 1) {
+ return '<span style="color:green;">每日开仓数超过30</span>'
+ } else if (d.type === 2) {
+ return '<span style="color:red;">三分钟平仓操作订单超过每日总订单数的50%</span>'
+ }else if (d.type === 3) {
+ return '<span style="color:red;">订单总盈亏超过500</span>'
+ }else{
+ return ''
+ }
+ }, minWidth: 200,align:'center'},
+ ]]
+ });
+ }
+
+ // 获取查询参数
+ function getQueryParams() {
+ return {
+ account: $searchForm.find('input[name="account"]').val().trim(),
+ };
+ }
+
+ })
+</script>
\ No newline at end of file
--
Gitblit v1.9.1