中台首页数据查询

leiSP-admin/src/main/java/com/sooka/web/controller/system/NumberUtils.java

@@ -19,6 +19,22 @@ public class NumberUtils {
      * @return
      */
     public static String amountConversion(int str){
+//        BigDecimal amount = new BigDecimal(str);
+//        if (amount == null) {
+//            return null;
+//        }
+//        if (amount.abs().compareTo(ONE_HUNDRED_THOUSAND) < 0) {
+//            //如果小于10万
+//            return amount.stripTrailingZeros().toPlainString();
+//        }
+//        if (amount.abs().compareTo(ONE_HUNDRED_MILLION) < 0) {
+//            //如果大于10万小于1亿
+//            return amount.divide(TEN_THOUSAND, 0, BigDecimal.ROUND_HALF_UP).stripTrailingZeros().toPlainString() + MILLION_UNIT;
+//        }
+//        return amount.divide(ONE_HUNDRED_MILLION, 0, BigDecimal.ROUND_HALF_UP).stripTrailingZeros().toPlainString() + BILLION_UNIT;
+        return amountConversion(Long.valueOf(str));
+    }
+    public static String amountConversion(Long str){
         BigDecimal amount = new BigDecimal(str);
         if (amount == null) {
             return null;

leiSP-admin/src/main/java/com/sooka/web/controller/system/SysIndexController.java

@@ -6,8 +6,7 @@ import com.sooka.apply.service.IIntRecordService;
 import com.sooka.common.utils.StringUtils;
 import com.sooka.system.domain.SysDept;
 import com.sooka.system.domain.TUInterfaceinfo;
-import com.sooka.system.service.ISysDeptService;
-import com.sooka.system.service.ITUInterfaceinfoService;
+import com.sooka.system.service.*;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.ModelMap;
@@ -17,8 +16,6 @@ import com.sooka.common.core.controller.BaseController;
 import com.sooka.framework.util.ShiroUtils;
 import com.sooka.system.domain.SysMenu;
 import com.sooka.system.domain.SysUser;
-import com.sooka.system.service.ISysConfigService;
-import com.sooka.system.service.ISysMenuService;
 
 /**
  * 首页 业务处理
@@ -35,6 +32,9 @@ public class SysIndexController extends BaseController
     private ISysConfigService configService;
 
     @Autowired
+    private ISysIndexService sysIndexService;
+
+    @Autowired
     private ITUInterfaceinfoService interfaceinfoService;
 
     @Autowired
@@ -67,8 +67,43 @@ public class SysIndexController extends BaseController
         return "skin";
     }
 
-    // 系统介绍
+    /**
+     * 系统首页
+     * @param mmap
+     * @return
+     */
     @GetMapping("/system/main")
+    public String sysMain(ModelMap mmap)
+    {
+        //系统版本
+        mmap.put("version", Global.getVersion());
+
+        //接口数量
+        mmap.put("count", sysIndexService.getInterfaceCountAll());
+        //调用频次
+        mmap.put("callFrequency", NumberUtils.amountConversion(sysIndexService.callFrequency()));
+        //归集频次
+        mmap.put("pushFrequency", NumberUtils.amountConversion(sysIndexService.pushFrequency()));
+        //共享频次
+        mmap.put("pullFrequency", NumberUtils.amountConversion(sysIndexService.pullFrequency()));
+        //接入部门
+        SysDept sysDept = new SysDept();
+        sysDept.setParentId(214L);
+        mmap.put("depts", sysIndexService.joinUpDepts(sysDept));
+
+        //接口故障
+        mmap.put("faultCount", sysIndexService.getInterfaceCountError());
+
+        //省接口申请频次
+        String[] arr = {"share_type_3","share_type_4"};
+        mmap.put("province", "[" + StringUtils.join(iIntRecordService.applyFrequency(arr), ",") + "]");
+        //市接口申请频次
+        String[] arr1 = {"share_type_1","share_type_2"};
+        mmap.put("city", "[" + StringUtils.join(iIntRecordService.applyFrequency(arr1), ",") + "]");
+        return "main";
+    }
+
+    // 系统介绍
     public String main(ModelMap mmap)
     {
         //接口数量

leiSP-admin/src/main/resources/templates/main.html

@@ -13,6 +13,7 @@
     <style type="text/css">
         /*新*/
         .ibox-left-th {
+            left: -10px;
             font-size: 16px;
             text-align: center;
             color: #fff;
@@ -31,6 +32,7 @@
         }
 
         .ibox-right-th {
+            left: -35px;
             float: right;
             font-size: 48px;
             color: #fff;
@@ -95,7 +97,7 @@
                 <h5>接口总数</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：个</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;left: 55px;display: block;height: 25px;right: -35px;">单位：个</span>
                 <span id="tj_interface_total">[[${count}]]</span>
             </div>
         </div>
@@ -106,7 +108,7 @@
                 <h5>调用频次</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：次</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: -35px;">单位：次</span>
                 <span id="tj_dypc">[[${callFrequency}]]</span>
             </div>
         </div>
@@ -117,7 +119,7 @@
                 <h5>归集频次</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：次</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: -35px;">单位：次</span>
                 <span id="tj_gjpc">[[${pushFrequency}]]</span>
             </div>
         </div>
@@ -128,7 +130,7 @@
                 <h5>共享频次</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：次</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: -35px;">单位：次</span>
                 <span id="tj_gxpc">[[${pullFrequency}]]</span>
             </div>
         </div>
@@ -139,7 +141,7 @@
                 <h5 >接入部门</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：个</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: -35px;">单位：个</span>
                 <span id="tj_jrbm">[[${depts}]]</span>
             </div>
         </div>
@@ -150,7 +152,7 @@
                 <h5>接口故障</h5>
             </div>
             <div class="col-sm-6 ibox-right-th">
-                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: 0px;">单位：个</span>
+                <span style="font-size: 14px;position: absolute;top: -50px;display: block;height: 25px;right: -35px;">单位：个</span>
                 <span id="tj_jkgz">[[${faultCount}]]</span>
             </div>
         </div>
@@ -298,7 +300,7 @@
     }
 
     $(document).ready(function () {
-        getVisualization();
+        // getVisualization();
         addToast();
     });
 </script>

mybusiness/src/main/java/com/sooka/system/mapper/SysIndexMapper.java

@@ -0,0 +1,41 @@
+package com.sooka.system.mapper;
+
+
+import com.sooka.system.domain.SysDept;
+
+/**
+ * 【系统首页】Mapper接口
+ *
+ * @author wangzhe
+ * @date 2023-06-27
+ */
+public interface SysIndexMapper {
+
+    /**
+     * 查询接口数量
+     */
+    public Integer getInterfaceCountAll();
+    /**
+     * 查询接口故障
+     */
+    public Integer getInterfaceCountError();
+
+    /**
+     * 接口调用频次
+     */
+    public Long callFrequency();
+    /**
+     * 接口归集频次
+     */
+    public Long pushFrequency();
+    /**
+     * 接口共享频次
+     */
+    public Long pullFrequency();
+
+    /**
+     * 查询接入部门
+     */
+    public Integer joinUpDepts(SysDept sysDept);
+
+}

mybusiness/src/main/java/com/sooka/system/service/ISysIndexService.java

@@ -0,0 +1,43 @@
+package com.sooka.system.service;
+
+import com.sooka.system.domain.SysDept;
+import com.sooka.system.domain.TUInterfaceinfo;
+
+import java.util.List;
+
+/**
+ * 【系统首页】Service接口
+ *
+ * @author wangzhe
+ * @date 2023-06-27
+ */
+public interface ISysIndexService
+{
+
+    /**
+     * 查询接口数量
+     */
+    public Integer getInterfaceCountAll();
+    /**
+     * 查询接口故障
+     */
+    public Integer getInterfaceCountError();
+
+    /**
+     * 接口调用频次
+     */
+    public Long callFrequency();
+    /**
+     * 接口归集频次
+     */
+    public Long pushFrequency();
+    /**
+     * 接口共享频次
+     */
+    public Long pullFrequency();
+
+    /**
+     * 查询接入部门
+     */
+    public Integer joinUpDepts(SysDept sysDept);
+}

mybusiness/src/main/java/com/sooka/system/service/impl/SysIndexServiceImpl.java

@@ -0,0 +1,69 @@
+package com.sooka.system.service.impl;
+
+import com.sooka.common.annotation.DataScope;
+import com.sooka.system.domain.SysDept;
+import com.sooka.system.mapper.SysIndexMapper;
+import com.sooka.system.service.ISysIndexService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+
+/**
+ * 【系统首页】Service业务层处理
+ *
+ * @author wangzhe
+ * @date 2023-06-27
+ */
+@Service
+public class SysIndexServiceImpl implements ISysIndexService
+{
+
+    @Resource
+    private SysIndexMapper sysIndexMapper;
+
+    /**
+     * 查询接口数量
+     */
+    @Override
+    public Integer getInterfaceCountAll(){
+        return sysIndexMapper.getInterfaceCountAll();
+    }
+    /**
+     * 查询接口故障
+     */
+    @Override
+    public Integer getInterfaceCountError(){
+        return sysIndexMapper.getInterfaceCountError();
+    }
+
+    /**
+     * 接口调用频次
+     */
+    @Override
+    public Long callFrequency(){
+        return sysIndexMapper.callFrequency();
+    }
+    /**
+     * 接口归集频次
+     */
+    @Override
+    public Long pushFrequency(){
+        return sysIndexMapper.pushFrequency();
+    }
+    /**
+     * 接口共享频次
+     */
+    @Override
+    public Long pullFrequency(){
+        return sysIndexMapper.pullFrequency();
+    }
+
+    /**
+     * 查询接入部门
+     */
+    @Override
+    @DataScope(deptAlias = "d")
+    public Integer joinUpDepts(SysDept sysDept){
+        return sysIndexMapper.joinUpDepts(sysDept);
+    }
+}

mybusiness/src/main/resources/mapper/system/SysIndexMapper.xml

@@ -0,0 +1,78 @@
+<?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.sooka.system.mapper.SysIndexMapper">
+
+    <select id="getInterfaceCountAll" resultType="java.lang.Integer">
+        select
+            count(id) count
+        from
+            t_u_interfaceinfo
+        where
+            del_flag = 0
+    </select>
+    <select id="getInterfaceCountError" resultType="java.lang.Integer">
+        select
+            count(id) count
+        from
+            t_u_interfaceinfo
+        where
+            status = 1
+            and del_flag = 0
+    </select>
+
+    <select id="callFrequency" resultType="java.lang.Long">
+        select
+            sum(callsuccnum) count
+        from
+            t_u_interfaceinfo
+            where
+            share_type in (
+                'share_type_1',
+                'share_type_3',
+                'share_type_4'
+            )
+    </select>
+    <select id="pushFrequency" resultType="java.lang.Long">
+        select
+            sum(callsuccnum) count
+        from
+            t_u_interfaceinfo
+        where
+            share_type in (
+                'share_type_2',
+                'share_type_3'
+            )
+    </select>
+    <select id="pullFrequency" resultType="java.lang.Long">
+        select
+            sum(callsuccnum) count
+        from
+            t_u_interfaceinfo
+        where
+            share_type in (
+                'share_type_1',
+                'share_type_4'
+            )
+    </select>
+
+    <select id="joinUpDepts" parameterType="com.sooka.system.domain.SysDept" resultType="java.lang.Integer">
+        select
+            count(d.dept_id)
+        from
+            sys_dept d
+        where
+            d.status = 0
+        and
+            d.del_flag = '0'
+        and
+            d.parent_id = #{parentId}
+        <!-- 数据范围过滤 -->
+        ${params.dataScope}
+    </select>
+
+
+
+
+</mapper>