Skip to content

M
map-parent
Commit 1df0cc63 by yangyang
Options

主题研判资金流提交

parent cf86ed2c
Showing with 612 additions and 1 deletions
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/BankCardNumPojo.java 0 → 100644
package com.founder.commonutils.model.newPublicEntity.ztypEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author zzj
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class BankCardNumPojo extends TradingTaskPojo {
/**
* 任务编号
*/
private String taskId;
/**
* 任务名称
*/
private String taskName;
/**
* 主键编号
*/
private String xxzjbh;
/**
* 本方卡号
*/
private String bfCardsNum;
/**
* 本方持卡人姓名
*/
private String bfCardsName;
/**
* 对方卡号
*/
private String dfCardsNum;
/**
* 对方持卡人姓名
*/
private String dfCardsName;
/**
* 交易时间 起始时间
*/
private String tradingTimeStart;
/**
* 交易时间 截至时间
*/
private String tradingTimeEnd;
/**
* 交易银行名称
*/
private String tradingBankName;
/**
* 交易金额
*/
private String transactionAmount;
/**
* 账户余额
*/
private String accountBalance;
/**
* 交易方式
*/
private String transactionMode;
/**
* 交易流水号
*/
private String transactionNumber;
/**
* 转入转出
*/
private String transferInOrOut;
/**
* 交易数
*/
private String transCount;
/**
* 周一交易数
*/
private String transCountMon;
/**
* 周二交易数
*/
private String transCountTues;
/**
* 周三交易数
*/
private String transCountWednes;
/**
* 周四交易数
*/
private String transCountThurs;
/**
* 周五交易数
*/
private String transCountFri;
/**
* 周六交易数
*/
private String transCountSatur;
/**
* 周日交易数
*/
private String transCountSun;
}
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/BankCardParamPojo.java 0 → 100644
package com.founder.commonutils.model.newPublicEntity.ztypEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import java.util.List;
/**
* @author zzj
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class BankCardParamPojo {
/**
* 任务id集合
*/
private List<String> taskIdList;
/**
* 当前页
*/
private int page;
/**
* 分页起始下标
*/
private int start;
/**
* 当前页显示数
*/
private int limit;
/**
* 交易时间规律统计-分析频次
*/
private String analysisFrequency;
/**
* 交易时间-起始时间
*/
private String tradingTimeStart;
/**
* 交易时间-截至时间
*/
private String tradingTimeEnd;
/**
* 本方银行卡号
*/
private String bfCardsNum;
/**
* 对方银行卡号
*/
private String dfCardsNum;
/**
* 数据类型 01交易详情，02交易时间规律统计，03交易地域规律统计，04交易频度规律统计，05交易习惯统计
*/
private String dataType;
/**
* 交易方
*/
private String traidParty;
/**
* 交易银行（地点)
*/
private String tradingBankName;
/**
* 共同关系数，可视化分析专用
*/
private String commonRelationshipNum;
/**
* 排序属性
*/
private String orderField;
}
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/TbZjlxxzx.java 0 → 100644
package com.founder.commonutils.model.newPublicEntity.ztypEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author jing
* @date 2021/11/16 -- 9:52
*/
@Data
@ApiModel(value = "TbZjlxxzx", description = "最新资金表")
public class TbZjlxxzx {
//本方卡号
@ApiModelProperty(value = "本方卡号")
private String bfkh;
//账号名称
@ApiModelProperty(value = "账号名称")
private String bfzhmc;
//对手卡号
@ApiModelProperty(value = "对手卡号")
private String dfkh;
//对手名称
@ApiModelProperty(value = "对手名称")
private String dfmc;
//交易时间
@ApiModelProperty(value = "交易时间")
private String jysj;
//转账金额
@ApiModelProperty(value = "转账金额")
private String zzje;
//余额
@ApiModelProperty(value = "余额")
private String zhye;
//进出标志
@ApiModelProperty(value = "进出标志")
private String jcbz;
//交易方式
@ApiModelProperty(value = "交易方式")
private String jyfs;
//交易流水号
@ApiModelProperty(value = "交易流水号")
private String jylsh;
@ApiModelProperty(value = "交易摘要")
private String jyzy;
//交易银行
@ApiModelProperty(value = "交易银行")
private String jyyh;
//信息主键编号
@ApiModelProperty(value = "信息主键编号")
private String xxzjbh;
//所属任务编号
@ApiModelProperty(value = "所属任务编号")
private String ssrwbh;
@ApiModelProperty(value = "当前页")
private int page;
@ApiModelProperty(value = "每页条数")
private int limit;
}
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/TbZxrwb.java 0 → 100644
package com.founder.commonutils.model.newPublicEntity.ztypEntity;
import io.swagger.annotations.ApiModel;
import io.swagger.annotations.ApiModelProperty;
import lombok.Data;
/**
* @author jing
* @date 2021/11/15 -- 17:06
*/
@Data
@ApiModel(value = "TbZxrwb", description = "任务表")
public class TbZxrwb{
//任务编号
@ApiModelProperty(value = "任务编号")
private String xxzjbh;
//任务名称
@ApiModelProperty(value = "任务名称")
private String zwmc;
//任务描述
@ApiModelProperty(value = "任务描述")
private String zwms;
@ApiModelProperty(value = "文件总数")
private int wjzs;
/**
* 本方卡号数量
*/
private int bfCardsCount;
/**
* 对方卡号数量
*/
private int dfCardsCount;
private String rwkssj;
private String rwjssj;
@ApiModelProperty(value = "当前页")
private int page;
@ApiModelProperty(value = "每页总数")
private int limit;
}
common/common_utils/src/main/java/com/founder/commonutils/model/newPublicEntity/ztypEntity/TradingTaskPojo.java 0 → 100644
package com.founder.commonutils.model.newPublicEntity.ztypEntity;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
/**
* @author zzj
*/
@Data
@NoArgsConstructor
@AllArgsConstructor
public class TradingTaskPojo {
/**
* 任务编号
*/
private String taskId;
/**
* 任务名称
*/
private String taskName;
/**
* 任务创建时间
*/
private String taskCreatedTime;
/**
* 本方卡号数量
*/
private String bfCardsCount;
/**
* 对方卡号数量
*/
private String dfCardsCount;
/**
* 交易银行数量
*/
private String bankCount;
/**
* 数据总量
*/
private String allDataCount;
/**
* 交易时间范围
*/
private String transactionRange;
/**
* 当前页
*/
private int page;
/**
* 分页每页数量
*/
private int limit;
}
service/publicapi/src/main/java/com/founder/publicapi/controller/ZtypService/ZtypController.java
package com.founder.publicapi.controller.ZtypService; package com.founder.publicapi.controller.ZtypService;
import com.founder.commonutils.model.newPublicEntity.*; import com.founder.commonutils.model.newPublicEntity.*;
import com.founder.commonutils.model.newPublicEntity.ztypEntity.AjypFxPojo; import com.founder.commonutils.model.newPublicEntity.ztypEntity.*;
import com.founder.commonutils.util.JwtUser; import com.founder.commonutils.util.JwtUser;
import com.founder.commonutils.util.KeyUtil; import com.founder.commonutils.util.KeyUtil;
import com.founder.publicapi.service.ZtypService; import com.founder.publicapi.service.ZtypService;
...@@ -13,7 +13,9 @@ import org.springframework.beans.factory.annotation.Autowired; ...@@ -13,7 +13,9 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*; import org.springframework.web.bind.annotation.*;
import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletRequest;
import java.text.ParseException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
...@@ -112,4 +114,109 @@ public class ZtypController { ...@@ -112,4 +114,109 @@ public class ZtypController {
Map<String, Object> resultMap = ztypService.getThfxAccompliceBythId(thbh, fxwd,commonRelationshipNum); Map<String, Object> resultMap = ztypService.getThfxAccompliceBythId(thbh, fxwd,commonRelationshipNum);
return R.ok().data(resultMap); return R.ok().data(resultMap);
}*/ }*/
@PostMapping("/selectJtrwList")
@ResponseBody
@ApiOperation(value = "查询具体任务的list集合", notes = "查询具体任务的list集合")
public R selectJtrwList(TbZxrwb tbZxrwb) {
try {
tbZxrwb.setPage((tbZxrwb.getPage()-1)*tbZxrwb.getLimit());
tbZxrwb.setLimit(tbZxrwb.getLimit());
Map<String, Object> map = new HashMap<>();
List<TbZxrwb> list = ztypService.getJtrwList(tbZxrwb);
int count = ztypService.getJtrwCount(tbZxrwb);
map.put("rows", list);
map.put("total", count);
return R.ok().data(map);
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
@PostMapping("/getTransactionStatistics")
@ResponseBody
@ApiOperation(value = "查询交易信息分析数据", notes = "查询交易信息分析数据")
public R getTransactionStatistics(BankCardNumPojo bankCard) {
Map<String, Object> result = ztypService.getTransactionStatistics(bankCard);
return R.ok().data(result);
}
@PostMapping("/getTransactionDetailByTaskId")
@ResponseBody
@ApiOperation(value = "获取任务的交易详情", notes = "获取任务的交易详情")
public R getTransactionDetailByTaskId(BankCardParamPojo requestParam) {
Map<String, Object> result = ztypService.getTransactionDetailByTaskId(requestParam);
return R.ok().data(result);
}
@PostMapping("/getTradingTimeStatistics")
@ResponseBody
@ApiOperation(value = "获取交易时间规律统计", notes = "获取交易时间规律统计")
public R getTradingTimeStatistics(BankCardParamPojo requestParam) throws ParseException {
Map<String, Object> result = ztypService.getTradingTimeStatistics(requestParam);
return R.ok().data(result);
}
@PostMapping("/getTradingLocationStatistics")
@ResponseBody
@ApiOperation(value = "获取交易地域规律统计", notes = "获取交易地域规律统计")
public R getTradingLocationStatistics(BankCardParamPojo requestParam) {
Map<String, Object> result = ztypService.getTradingLocationStatistics(requestParam);
return R.ok().data(result);
}
@PostMapping("/getTradingHabitStatistics")
@ResponseBody
@ApiOperation(value = "获取交易习惯分析统计", notes = "获取交易习惯分析统计")
public R getTradingHabitStatistics(BankCardParamPojo requestParam) {
Map<String, Object> result = ztypService.getTradingHabitStatistics(requestParam);
return R.ok().data(result);
}
@PostMapping("/getTradingFrequencyStatistics")
@ResponseBody
@ApiOperation(value = "获取交易频度分析统计", notes = "获取交易频度分析统计")
public R getTradingFrequencyStatistics(BankCardParamPojo requestParam) {
Map<String, Object> result = ztypService.getTradingFrequencyStatistics(requestParam);
return R.ok().data(result);
}
@PostMapping("/getTradingRelationship")
@ResponseBody
@ApiOperation(value = "获取交易关系可视化分析", notes = "获取交易关系可视化分析")
public R getTradingRelationship(BankCardParamPojo requestParam) {
Map<String, Object> result = ztypService.getTradingRelationship(requestParam);
return R.ok().data(result);
}
// 根据银行卡号查询资金流
@PostMapping("/selectJyxxjsList")
@ResponseBody
@ApiOperation(value = "查询交易信息检索的list集合", notes = "查询交易信息检索的list集合")
public R selectJyxxjsList(TbZjlxxzx tbZjlxxzx) {
try {
Map<String, Object> map = new HashMap<>();
if (tbZjlxxzx.getBfkh() == null || "".equals(tbZjlxxzx.getBfkh())) {
map.put("rows", new ArrayList<>());
map.put("total", 0);
return R.ok().data(map);
}
EasyUIPage easyUIPage = new EasyUIPage();
easyUIPage.setPage(tbZjlxxzx.getPage());
easyUIPage.setPagePara(tbZjlxxzx.getLimit());
int begin = easyUIPage.getBegin();
int end = easyUIPage.getEnd();
tbZjlxxzx.setPage(begin);
tbZjlxxzx.setLimit(end);
List<TbZjlxxzx> list = tbZjlxxServcie.selectJyxxjsList(tbZjlxxzx);
int total = tbZjlxxServcie.selectJyxxjsListCount(tbZjlxxzx);
map.put("rows", list);
map.put("total", total);
return R.ok().data(map);
} catch (Exception e) {
e.printStackTrace();
return R.error(e.getMessage());
}
}
} }
service/publicapi/src/main/java/com/founder/publicapi/mapper/mysqlMapper/xml/ZtypMapper.xml
...@@ -201,4 +201,146 @@ ...@@ -201,4 +201,146 @@
</if> </if>
</where> </where>
</select> </select>
<select id="queryAjypfxCount" resultType="java.lang.Integer">
select count(th.THBH)
from tb_yw_shse_th th
<where>
1 = 1
<if test="ajlx == '00'">
and th.thglxyrsl <![CDATA[>=]]> 3
and th.thglajsl <![CDATA[>=]]> 3
</if>
<if test="ajlx == '01'">
and th.thglxyrsl <![CDATA[>=]]> 3
and th.thglajsl = 2
</if>
<if test="ajlx == '10'">
and th.thglxyrsl = 2
and th.thglajsl <![CDATA[>=]]> 3
</if>
<if test="ajlx == '11'">
and th.thglxyrsl = 2
and th.thglajsl = 2
</if>
<if test="(ryxm != null and ryxm != '') or (hjd != null and hjd != '')">
and th.thbh in (select thxyr.thbh from tb_yw_shse_thglxyr thxyr
<where>
1 = 1
<if test="ryxm != null and ryxm != ''">
and thxyr.xm = #{ryxm}
</if>
<if test="hjd != null and hjd != ''">
and thxyr.hjddm = #{hjd}
</if>
</where>
)
</if>
<if test="(ladwdm != null and ladwdm != '') or (ajlbdm != null and ajlbdm != '') or (ajmc != null and ajmc != '')
or startDate != null or endDate != null">
and th.thbh in (
select thbh
from tb_yw_shse_thglasj thaj
<where>
1 = 1
<if test="ajlbdm != null and ajlbdm != ''">
and thaj.ajlbdm = #{ajlbdm}
</if>
<if test="ajmc != null and ajmc != ''">
thaj.ajmc like '%${ajmc}%'
</if>
<if test="startDate != null">
and thaj.larq >= #{startDate, jdbcType=DATE}
</if>
<if test="endDate != null">
and thaj.larq <![CDATA[<=]]> #{endDate, jdbcType=DATE}
</if>
<if test="ladwdm != null and ladwdm != ''">
and thaj.ladwdm in (SELECT code FROM sys_dictitem_xz WHERE code_lev1
=#{ladwdm, jdbcType=VARCHAR}
or code_lev2 =#{ladwdm, jdbcType=VARCHAR} or code_lev3 =#{ladwdm, jdbcType=VARCHAR}
or code_lev4 =#{ladwdm, jdbcType=VARCHAR} or code_lev5 =#{ladwdm, jdbcType=VARCHAR}
)
</if>
</where>
)
</if>
</where>
</select>
<select id="getThConnectPhoneList" resultType="java.util.Map">
select thxyr.ZJHM as "xyrZjhm", callInfo.DFHM as "dfhm"
from TB_YW_SHSE_THGLXYR thxyr
left join HD_CALL_LOG callLog on thxyr.ZJHM = callLog.CKRSFZH and callLog.SCBZ = 0
left join HD_CALL_INFO callInfo
on callLog.JZHM = callInfo.BJHM and callInfo.SCBZ = 0 and length(callInfo.START_TIME) = 16
where thxyr.THBH = #{ thbh,jdbcType= VARCHAR }
group by thxyr.ZJHM, callInfo.DFHM
</select>
<select id="getThConnectIpList" resultType="java.util.Map">
select thxyr.ZJHM as "xyrZjhm", netConn.TGR_IP as "dfip"
from TB_YW_SHSE_THGLXYR thxyr
left join TB_YW_NETWORK_CONN netConn on thxyr.ZJHM = netConn.XYR_ZJHM
where thxyr.THBH = #{ thbh,jdbcType= VARCHAR }
group by thxyr.ZJHM, netConn.TGR_IP
</select>
<select id="getThCashAccountList" resultType="java.util.Map">
select thxyr.ZJHM as "xyrZjhm", bankTrans.SKR_YHKH as "cashAccount"
from TB_YW_SHSE_THGLXYR thxyr
left join TB_YW_BANK_TRANS_INFO bankTrans on thxyr.ZJHM = bankTrans.XYR_ZJHM
where thxyr.THBH = #{ thbh,jdbcType= VARCHAR }
group by thxyr.ZJHM, bankTrans.SKR_YHKH;
</select>
<sql id="fwbsh-queryParam">
<if test="fwbsh.fwbshLb != null and fwbsh.fwbshLb != ''">
<choose>
<when test="fwbsh.fwbshLb == '99'">
and FWBSH_LB in ('qq', 'wx')
</when>
<otherwise>
and FWBSH_LB = #{fwbsh.fwbshLb,jdbcType=VARCHAR}
</otherwise>
</choose>
</if>
<if test="fwbsh.fwbshHm != null and fwbsh.fwbshHm != ''">
and instr(FWBSH_HM, #{fwbsh.fwbshHm,jdbcType=VARCHAR}) > 0
</if>
<if test="fwbsh.xxdjryGmsfhm != null and fwbsh.xxdjryGmsfhm != ''">
and XXDJRY_GMSFHM = #{fwbsh.xxdjryGmsfhm,jdbcType=VARCHAR}
</if>
<if test="fwbsh.unitcode != null and fwbsh.unitcode != ''">
and XXDJDW_GAJGJGDM = #{fwbsh.unitcode,jdbcType=VARCHAR}
</if>
<if test="fwbsh.unitcodeList != null and fwbsh.unitcodeList.size() > 0">
and
<foreach collection="unitcodeList" item="dws" open="(" close=")" separator=" or ">
XXDJDW_GAJGJGDM in
<foreach collection="dws" item="dw" separator="," open="(" close=")">
#{dw,jdbcType=VARCHAR}
</foreach>
</foreach>
</if>
</sql>
<sql id="fwbsh-queryColumn">
xxzjbh,
fwbsh_lb,
fwbsh_hm,
fwbsh_ms,
djsj,
xxdjdw_gajgjgdm,
xxdjdw_gajgmc,
xxdjry_xm,
xxdjry_gmsfhm,
xxdjry_lxdh,
xxczdw_gajgjgdm,
xxczdw_gajgmc,
xxczry_xm,
xxczry_gmsfhm,
gxsj,
xxlyms,
xxrsksj,
xxrbksj,
xxrsk_pdbz,
xxrbk_pdbz,
xxsc_pdbz,
(select name from SYS_DICTITEM where GROUPID = 'CODE_CBYP_BSHLX' and code = fwbsh_lb) as fwbshLbStr
</sql>
</mapper> </mapper>
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