统计分析透视

src/main/java/org/springblade/founder/tjfx/mapper/TjfxMapper.java

@@ -3,6 +3,7 @@ package org.springblade.founder.tjfx.mapper;
 import org.apache.ibatis.annotations.Mapper;
 import org.springblade.founder.tjfx.entity.AjtjParam;
 import org.springblade.founder.tjfx.entity.AjtjResult;
+import org.springblade.founder.tjfx.entity.TbStAsj;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
@@ -52,4 +53,25 @@ public interface TjfxMapper {
 	 * @return
 	 */
 	List<AjtjResult> getDxssjesfyuest(AjtjParam ajtjParam);
+
+	/**
+	 * 案件透视
+	 * @param ajtjParam
+	 * @return
+	 */
+	int getAjTsCount(AjtjParam ajtjParam);
+
+	/**
+	 * 案件透视
+	 * @param ajtjParam
+	 * @return
+	 */
+	List<TbStAsj> getAjTs(AjtjParam ajtjParam);
+	/**
+	 * 损失金额透视
+	 * @param ajtjParam
+	 * @return
+	 */
+	List<TbStAsj> getSsjeTs(AjtjParam ajtjParam);
+
 }

src/main/java/org/springblade/founder/tjfx/mapper/TjfxMapper.xml

@@ -16,9 +16,15 @@
         <if test="jabz!=null and jabz!='' and jabz == '1'.toString()"><!--破现案查询-->
             and to_char(asj.LARQ,'yyyy-mm-dd')=to_char(asj.ZCZJ_ZXSJ01,'yyyy-mm-dd')
         </if>
+        <if test="jabz!=null and jabz!='' and jabz == '1'.toString()"><!--破现案查询-->
+            and to_char(asj.LARQ,'yyyy-mm-dd')=to_char(asj.ZCZJ_ZXSJ01,'yyyy-mm-dd')
+        </if>
     </sql>
 
     <sql id="aj-condition">
+        <if test="pxzd!=null and pxzd!='' and pxzd == 'pa'.toString()"><!--破案条件-->
+            and asj.ZCJDDM = '0600'
+        </if>
         <if test="type!=null and type!='' and type == 'ww'.toString()"><!--文物-->
         and asj.ajlbdm in ('06040100','06040200','06040300','06040400','06040500','06040600','06040700')
         </if>
@@ -125,4 +131,64 @@
         <include refid="aj-condition"/>
         <include refid="common-condition"/>
     </select>
+
+    <sql id="aj-common-column">
+        asj.asjbh as asjbh,
+        (SELECT name FROM code_gxs WHERE code = asj.ladw_Gajgjgdm) AS ladwGajgmc,
+        asj.ZCZJ_ZXSJ01 AS zczjZxsj01,
+        asj.larq AS larq,
+        asj.asjfssj_Asjfskssj AS asjfssjAsjfskssj,
+        (SELECT name FROM sys_dictitem WHERE groupid = 'CODE_AJLB' AND code = asj.ajlbdm) as ajlbdm,
+        (SELECT name FROM sys_dictitem WHERE groupid = 'CODE_AJXZ' AND code = asj.zatz_jyqk) as zatzJyqk,
+        asj.ajmc AS ajmc,
+        asj.jyaq AS jyaq
+    </sql>
+
+    <!--案件透视-->
+    <select id="getAjTsCount" resultType="java.lang.Integer">
+        select count(1) from tb_st_asj asj
+        where asj.xxsc_pdbz='0'
+        <include refid="aj-condition"/>
+        <include refid="common-condition"/>
+    </select>
+    <select id="getAjTs" resultType="org.springblade.founder.tjfx.entity.TbStAsj">
+        <![CDATA[SELECT t.* FROM (
+        SELECT a.* , rownum r FROM (]]>
+        select
+        <include refid="aj-common-column"/>
+        from TB_ST_ASJ asj
+        where asj.xxsc_pdbz='0'
+        <include refid="aj-condition"/>
+        <include refid="common-condition"/>
+        order by asj.larq desc
+        <![CDATA[    )a
+        WHERE ROWNUM <= #{ end } ) t
+        WHERE r > #{ begin } ]]>
+    </select>
+
+    <!--损失金额-->
+    <select id="getSsjeTs" resultType="org.springblade.founder.tjfx.entity.TbStAsj">
+        <![CDATA[SELECT t.* FROM (
+        SELECT a.* , rownum r FROM (]]>
+        select
+        asj.asjbh as asjbh,
+        (SELECT name FROM code_gxs WHERE code = asj.ladw_Gajgjgdm) AS ladwGajgmc,
+        asj.ZCZJ_ZXSJ01 AS zczjZxsj01,
+        asj.larq AS larq,
+        asj.asjfssj_Asjfskssj AS asjfssjAsjfskssj,
+        (SELECT name FROM sys_dictitem WHERE groupid = 'CODE_AJLB' AND code = asj.ajlbdm) as ajlbdm,
+        (SELECT name FROM sys_dictitem WHERE groupid = 'CODE_AJXZ' AND code = asj.zatz_jyqk) as zatzJyqk,
+        asj.ajmc AS ajmc,
+        asj.jyaq AS jyaq,
+        asj.SSJZRMBY as ssjzrmby
+        from TB_ST_ASJ asj
+        where asj.xxsc_pdbz='0'
+        <include refid="aj-condition"/>
+        <include refid="common-condition"/>
+        order by asj.larq desc
+        <![CDATA[    )a
+        WHERE ROWNUM <= #{ end } ) t
+        WHERE r > #{ begin } ]]>
+    </select>
+
 </mapper>

src/main/java/org/springblade/founder/tjfx/service/TjfxService.java

@@ -21,4 +21,15 @@ public interface TjfxService {
 	R getDxssjesfyuest(AjtjParam ajtjParam , String type);
 	//电信网络诈骗损失金额数
 	List<LianTj> getDxssjes(AjtjParam ajtjParam , String type);
+
+
+	//案件立案分月分析
+	R getFats(AjtjParam ajtjParam);
+
+	//案件破案分月分析
+	R getPats(AjtjParam ajtjParam);
+	//破现案透视
+	R getPxats(AjtjParam ajtjParam);
+	//损失金额透视
+	R getSsjeTs(AjtjParam ajtjParam);
 }

src/main/java/org/springblade/founder/tjfx/service/impl/TjfxServiceImpl.java

@@ -5,11 +5,13 @@ import com.baomidou.dynamic.datasource.annotation.DS;
 import org.springblade.founder.tjfx.entity.AjtjParam;
 import org.springblade.founder.tjfx.entity.AjtjResult;
 import org.springblade.founder.tjfx.entity.LianTj;
+import org.springblade.founder.tjfx.entity.TbStAsj;
 import org.springblade.founder.tjfx.mapper.TjfxMapper;
 import org.springblade.founder.tjfx.service.TjfxService;
 import org.springblade.founder.utils.DateUtil;
 import org.springblade.founder.utils.NumberUtil;
 import org.springblade.founder.utils.R;
+import org.springblade.founder.utils.Utils;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -83,7 +85,9 @@ public class TjfxServiceImpl implements TjfxService {
 		ajtjParam.setType(type);
 		List<LianTj> tj=new ArrayList<>();
 		LianTj jntj=new LianTj();
+		jntj.setType("jn");
 		LianTj qntj=new LianTj();
+		qntj.setType("qn");
 		int lian= tjfxMapper.getFaCount(ajtjParam);
 		int poan= tjfxMapper.getPaCount(ajtjParam);
 		//现案
@@ -148,7 +152,9 @@ public class TjfxServiceImpl implements TjfxService {
 		ajtjParam.setType(type);
 		List<LianTj> tj=new ArrayList<>();
 		LianTj jntj=new LianTj();
+		jntj.setType("jn");
 		LianTj qntj=new LianTj();
+		qntj.setType("qn");
 		int jn= tjfxMapper.getDxssjes(ajtjParam);
 
 		AjtjParam qntjParam = new AjtjParam();
@@ -165,4 +171,39 @@ public class TjfxServiceImpl implements TjfxService {
 		return tj;
 	}
 
+	@Override
+	public R getFats(AjtjParam ajtjParam) {
+		int count = tjfxMapper.getAjTsCount(ajtjParam);
+		Utils.setOraclePageParams(ajtjParam);
+		List<TbStAsj> ajTs = tjfxMapper.getAjTs(ajtjParam);
+		return R.ok().data("rows",ajTs).data("total",count);
+
+	}
+
+	@Override
+	public R getPats(AjtjParam ajtjParam) {
+		ajtjParam.setPxzd("pa");
+		int count = tjfxMapper.getAjTsCount(ajtjParam);
+		Utils.setOraclePageParams(ajtjParam);
+		List<TbStAsj> ajTs = tjfxMapper.getAjTs(ajtjParam);
+		return R.ok().data("rows",ajTs).data("total",count);
+	}
+
+	@Override
+	public R getPxats(AjtjParam ajtjParam) {
+		ajtjParam.setJabz("1");
+		int count = tjfxMapper.getAjTsCount(ajtjParam);
+		Utils.setOraclePageParams(ajtjParam);
+		List<TbStAsj> ajTs = tjfxMapper.getAjTs(ajtjParam);
+		return R.ok().data("rows",ajTs).data("total",count);
+	}
+
+	@Override
+	public R getSsjeTs(AjtjParam ajtjParam) {
+		int count = tjfxMapper.getAjTsCount(ajtjParam);
+		Utils.setOraclePageParams(ajtjParam);
+		List<TbStAsj> ajTs = tjfxMapper.getSsjeTs(ajtjParam);
+		return R.ok().data("rows",ajTs).data("total",count);
+	}
+
 }

src/main/resources/application-dev.yml

@@ -11,9 +11,9 @@ spring:
     #    password: Hnxzxt
     #    database: 0
     #    ssl: false
-    host: 192.168.79.128
-    port: 6379
-    password:
+    host: 47.92.223.200
+    port: 7779
+    password: p!ssw0rd1
     database: 0
     ssl: false
     ##redis 集群环境配置