1.风控

———— by qlm

src/main/java/com/xc/controller/RiskController.java

@@ -0,0 +1,77 @@
+package com.xc.controller;
+
+import com.github.pagehelper.PageInfo;
+import com.jfinal.plugin.activerecord.Db;
+import com.jfinal.plugin.activerecord.Record;
+import com.xc.common.ServerResponse;
+import com.xc.service.RiskService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.ResponseBody;
+
+import java.util.List;
+
+@Controller
+@RequestMapping({"/risk/"})
+public class RiskController {
+    private static final Logger log = LoggerFactory.getLogger(RiskController.class);
+
+
+    @Autowired
+    private RiskService riskService;
+
+    @RequestMapping({"view.do"})
+    @ResponseBody
+    public ServerResponse<PageInfo> view(
+            @RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
+            @RequestParam(value = "pageSize", defaultValue = "10") Integer pageSize
+    ) {
+        PageInfo pageInfo=riskService.getRiskInfoList(pageNum,pageSize);
+        return ServerResponse.createBySuccess(pageInfo);
+    }
+
+    @RequestMapping({"delete.do"})
+    @ResponseBody
+    public ServerResponse delete(String id) {
+        int data = Db.use("data").update("delete   risk_control_formula  where id = ? ", id);
+        return ServerResponse.createBySuccessMsg(data == 1 ? "true" : "false");
+    }
+
+    @RequestMapping({"save.do"})
+    @ResponseBody
+    public ServerResponse save(String code,    // 货币code(LINK)
+                       String codeName,    // 货币名称（LINK币）
+                       String minimumFluctuation,    // 最小波动
+                       String riskControl,    // 风控参数（+-*/）
+                       String status,    // 状态，0启动、1关闭
+                       String tocode    // 新币/股 code (GTC)
+    ) {
+
+        int data = Db.use("data").update("insert into risk_control_formula(code,codeName,minimumFluctuation,riskControl,status,tocode) " +
+                "values('" + code + "', '" + codeName + "','" + minimumFluctuation + "','" + riskControl + "','" + status + "','" + tocode + "')");
+        return ServerResponse.createBySuccessMsg(data == 1 ? "true" : "false");
+    }
+
+
+    @RequestMapping({"edit.do"})
+    @ResponseBody
+    public ServerResponse edit(String id,
+                       String code,    // 货币code(LINK)
+                       String codeName,    // 货币名称（LINK币）
+                       String minimumFluctuation,    // 最小波动
+                       String riskControl,    // 风控参数（+-*/）
+                       String status,    // 状态，0启动、1关闭
+                       String tocode    // 新币/股 code (GTC)
+    ) {
+
+        int data = Db.use("data").update("UPDATE risk_control_formula SET `code` = ? , `minimumFluctuation` = ?, `riskControl` = ?, " +
+                "`status` = ?, `codeName` = ?, `tocode` = ?  WHERE `id` = ? ", code, minimumFluctuation, riskControl, status, codeName, tocode, id);
+
+        return ServerResponse.createBySuccessMsg(data == 1 ? "true" : "false");
+    }
+
+}

src/main/java/com/xc/dao2/RiskMapper.java

@@ -0,0 +1,13 @@
+package com.xc.dao2;
+
+import com.xc.vo2.RiskVo;
+
+import java.util.List;
+
+public interface RiskMapper {
+
+    List<RiskVo> getview();
+
+
+
+}

src/main/java/com/xc/service/RiskService.java

@@ -0,0 +1,17 @@
+package com.xc.service;
+
+import com.github.pagehelper.PageInfo;
+import com.xc.common.ServerResponse;
+import com.xc.pojo.ProtocolInfo;
+import com.xc.pojo.ProtocolType;
+import com.xc.vo.protocol.ProtocolApiVo;
+
+import javax.servlet.http.HttpServletRequest;
+import java.util.List;
+
+public interface RiskService {
+
+
+    PageInfo getRiskInfoList( Integer pageNum, Integer pageSize);
+
+}

src/main/java/com/xc/service/impl/RiskServiceImpl.java

@@ -0,0 +1,48 @@
+package com.xc.service.impl;
+
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import com.xc.common.ServerResponse;
+import com.xc.dao.ProtocolMapper;
+import com.xc.dao.SiteAdminMapper;
+import com.xc.dao2.RiskMapper;
+import com.xc.pojo.ProtocolInfo;
+import com.xc.pojo.ProtocolType;
+import com.xc.pojo.SiteAdmin;
+import com.xc.service.ProtocolService;
+import com.xc.service.RiskService;
+import com.xc.utils.PropertiesUtil;
+import com.xc.utils.enumUtil.ProtocolTypeEnum;
+import com.xc.utils.redis.CookieUtils;
+import com.xc.utils.redis.JsonUtil;
+import com.xc.utils.redis.RedisShardedPoolUtils;
+import com.xc.vo.protocol.ProtocolAdminVo;
+import com.xc.vo.protocol.ProtocolApiVo;
+import com.xc.vo2.RiskVo;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+
+@Service("RiskService")
+public class RiskServiceImpl implements RiskService {
+
+
+    @Autowired
+    private RiskMapper riskMapper;
+
+    @Override
+    public PageInfo getRiskInfoList(Integer pageNum, Integer pageSize) {
+        PageHelper.startPage(pageNum,pageSize);
+        List<RiskVo> RiskVoList = new ArrayList<>();
+        List<RiskVo> riskInfoList = riskMapper.getview();
+        PageInfo pageInfo = new PageInfo(riskInfoList);
+        return pageInfo;
+    }
+}

src/main/java/com/xc/utils/websocket/WsClient.java

@@ -45,6 +45,7 @@ public class WsClient extends WebSocketClient {
             if(StringUtils.isNotBlank(arg0)){
                 // 存储信息至redis
                 //?
+
               //  System.out.println(arg0);
                 // 处理数据 并 推送给 客户
                 new WebSocketController().sendSysMsg("all",arg0);

src/main/java/com/xc/vo2/RiskVo.java

@@ -0,0 +1,15 @@
+package com.xc.vo2;
+
+import lombok.Data;
+
+@Data
+public class RiskVo {
+    private int  id;
+    private String code;
+    private String codeName;
+    private String minimumFluctuation;
+    private String riskControl;
+    private int status;
+    private String tocode;
+
+}

src/main/java/mappers2/RiskMapper.xml

@@ -0,0 +1,16 @@
+<?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.xc.dao2.RiskMapper" >
+
+    <select id="getview" resultType="com.xc.vo2.RiskVo">
+        select
+         *
+        from
+        risk_control_formula
+        where
+        1=1
+
+    </select>
+
+
+</mapper>