msb_52843
/
dalong_mall
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/develop_risk' into develop_risk

Browse Source
master
james.zhao 6 years ago
parent b5e44dbfc5 5daa8ab0b3
commit 511904767c
4 changed files with 56 additions and 76 deletions
Show Stats Download Patch File Download Diff File

2
src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/RiskBusinessService.java
Unescape View File

@ -45,7 +45,7 @@ public interface RiskBusinessService {
* 新增风险事件 * 新增风险事件
* @param params * @param params
*/ */
void addRiskEvent(JSONObject params); void addRiskEvent(JSONObject params, JSONObject manager);
/** /**
* 更新事件 * 更新事件

12
src/main/java/au/com/royalpay/payment/manage/riskbusiness/core/impl/RiskBusinessServiceImpl.java
Unescape View File

@ -124,7 +124,7 @@ public class RiskBusinessServiceImpl implements RiskBusinessService {
} }
@Override @Override
public void addRiskEvent(JSONObject params) { public void addRiskEvent(JSONObject params, JSONObject manager) {
// 通用号调单不需要填写client_moniker // 通用号调单不需要填写client_moniker
JSONObject client = null; JSONObject client = null;
String clientMoniker = params.getString("client_moniker"); String clientMoniker = params.getString("client_moniker");
@ -134,6 +134,14 @@ public class RiskBusinessServiceImpl implements RiskBusinessService {
throw new InvalidShortIdException(); throw new InvalidShortIdException();
} }
} }
params.put("fillin_id", manager.getString("manager_id"));
params.put("fillin_person", manager.getString("display_name"));
String orderIds = params.getString("order_ids");
if (StringUtils.isNotBlank(orderIds)) {
orderIds = orderIds.trim().replace("，", ",");
params.put("order_ids", orderIds);
}
riskEventMapper.save(params); riskEventMapper.save(params);
} }
@ -152,7 +160,7 @@ public class RiskBusinessServiceImpl implements RiskBusinessService {
param.put("orderby_type", "update_time"); param.put("orderby_type", "update_time");
JSONObject riskMaterial = getRiskMaterial(param); JSONObject riskMaterial = getRiskMaterial(param);
try { try {
String downloadFilename = clientMoniker + "_audit_materials_" + DateFormatUtils.format(new Date(), "dd/MM/yyyy HH:mm:ss").toString() + ".zip";// 文件的名称 String downloadFilename = clientMoniker + "_audit_materials_" + DateFormatUtils.format(new Date(), "dd/MM/yyyy HH:mm:ss").toString() + ".zip";
response.setContentType("application/octet-stream"); response.setContentType("application/octet-stream");
response.setHeader("Content-Disposition", "attachment;filename=" + downloadFilename); response.setHeader("Content-Disposition", "attachment;filename=" + downloadFilename);
ZipOutputStream zos = new ZipOutputStream(response.getOutputStream()); ZipOutputStream zos = new ZipOutputStream(response.getOutputStream());

9
src/main/java/au/com/royalpay/payment/manage/riskbusiness/web/RiskBusinessController.java
Unescape View File

@ -55,14 +55,7 @@ public class RiskBusinessController {
@PostMapping(value = "events") @PostMapping(value = "events")
public void RegisterRiskEvent(@RequestBody JSONObject params, public void RegisterRiskEvent(@RequestBody JSONObject params,
@ModelAttribute(CommonConsts.MANAGER_STATUS) JSONObject manager) { @ModelAttribute(CommonConsts.MANAGER_STATUS) JSONObject manager) {
params.put("fillin_id", manager.getString("manager_id")); riskBusinessService.addRiskEvent(params, manager);
params.put("fillin_person", manager.getString("display_name"));
String orderIds = params.getString("order_ids");
if (StringUtils.isNotBlank(orderIds)) {
orderIds = orderIds.trim().replace("，", ",");
params.put("order_ids", orderIds);
}
riskBusinessService.addRiskEvent(params);
} }
@PutMapping(value = "events") @PutMapping(value = "events")

109
src/main/ui/static/analysis/risk_business.js
Unescape View File

@ -28,13 +28,14 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
"2": "BD已提交材料，等待审核", "2": "BD已提交材料，等待审核",
"3": "材料审核通过", "3": "材料审核通过",
"4": "材料审核不通过，已打回", "4": "材料审核不通过，已打回",
"5": "已处理", "5": "已处理"
}; };
var emailStatusMap = { var emailStatusMap = {
"0": "未发送", "0": "未发送",
"1": "已发送", "1": "已发送",
"2": "打回并已发送" "2": "打回并已发送",
"3": "已发送催促邮件"
}; };
var app = angular.module('riskBusinessApp', ['ui.router']); var app = angular.module('riskBusinessApp', ['ui.router']);
@ -73,6 +74,7 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
$scope.pagination = {}; $scope.pagination = {};
$scope.params = {}; $scope.params = {};
// 加载风险注册事件
$scope.loadRiskEvents = function (page) { $scope.loadRiskEvents = function (page) {
var params = angular.copy($scope.params); var params = angular.copy($scope.params);
params.page = page || $scope.pagination.page || 1; params.page = page || $scope.pagination.page || 1;
@ -94,6 +96,7 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
$scope.orderTypes = orderTypesMap; $scope.orderTypes = orderTypesMap;
$scope.riskEvent = riskEvent.data; $scope.riskEvent = riskEvent.data;
// 获取数据库中对应的渠道字段
var orderChannel = 'enable_'; var orderChannel = 'enable_';
if ($scope.riskEvent.order_type == 1) { if ($scope.riskEvent.order_type == 1) {
orderChannel += 'wechat'; orderChannel += 'wechat';
@ -164,27 +167,8 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
* 关停渠道 * 关停渠道
* @param orderType 调单类型 * @param orderType 调单类型
* @param channelFlag * @param channelFlag
* @param temporaryFlag 是否临时关闭 * @param temporaryFlag 是否临时关停
*/
$scope.updateChannel = function (orderType, channelFlag, temporaryFlag) {
var channel;
if (orderType == "1")
channel = 'wechat';
else if (orderType == "2")
channel = 'alipay';
$http.put('/sys/partners/' + $scope.riskEvent.client_moniker + '/channels/' + channel + '/permission', {allow: channelFlag}).then(function () {
$state.reload('analysis_monitoring.riskEvent_detail');
}, function (resp) {
commonDialog.alert({
title: 'Failed to change ' + channel + ' channel permission status',
content: resp.data.message,
type: 'error'
})
});
};*/
$scope.updateChannel = function (orderType, channelFlag, temporaryFlag) { $scope.updateChannel = function (orderType, channelFlag, temporaryFlag) {
var channel; var channel;
if (orderType == "1") if (orderType == "1")
@ -192,33 +176,37 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
else if (orderType == "2") else if (orderType == "2")
channel = 'alipay'; channel = 'alipay';
$scope.riskEvent.temporary_close_channel = temporaryFlag; $scope.riskEvent.temporary_close_channel = temporaryFlag;
$http.put('/risk/business/channel/' + channel + '/permission/' + channelFlag, $scope.riskEvent).then(function () { commonDialog.confirm({
title: 'Warning',
$state.reload('analysis_monitoring.riskEvent_detail'); content: 'Are you sure?'
}, function (resp) { }).then(function () {
commonDialog.alert({ $http.put('/risk/business/channel/' + channel + '/permission/' + channelFlag, $scope.riskEvent).then(function () {
title: 'Failed to change ' + channel + ' channel permission status', $state.reload('analysis_monitoring.riskEvent_detail');
content: resp.data.message, }, function (resp) {
type: 'error' commonDialog.alert({
}) title: 'Failed to change ' + channel + ' channel permission status',
}); content: resp.data.message,
type: 'error'
})
});
})
}; };
// 关停商户 // 关停商户
$scope.updateClient = function(isValid, temporaryFlag) { $scope.updateClient = function(isValid, temporaryFlag) {
$scope.riskEvent.temporary_close_merchant = temporaryFlag; $scope.riskEvent.temporary_close_merchant = temporaryFlag;
$http.put('/risk/business/partner/' + isValid, $scope.riskEvent).then(function () { commonDialog.confirm({
$state.reload('analysis_monitoring.riskEvent_detail'); title: 'Warning',
}, function (resp) { content: 'Are you sure?'
commonDialog.alert({title: 'Error', content: resp.data.message, type: 'error'}); }).then(function () {
$http.put('/risk/business/partner/' + isValid, $scope.riskEvent).then(function () {
$state.reload('analysis_monitoring.riskEvent_detail');
}, function (resp) {
commonDialog.alert({title: 'Error', content: resp.data.message, type: 'error'});
})
}) })
}; };
// 获取riskEvent详细信息
$scope.loadRiskEventDetail = function(riskId) {
$http.get('/risk/business/events/' + riskId)
}
$scope.resendUploadEmail = function () { $scope.resendUploadEmail = function () {
commonDialog.confirm({ commonDialog.confirm({
title: 'Warning', title: 'Warning',
@ -242,8 +230,7 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
// 一键下载功能 // 一键下载功能
$scope.downloadAsZip = function () { $scope.downloadAsZip = function () {
var url = '/risk/business/' + $scope.riskEvent.risk_id + '/download/materialsAsZIP'; return '/risk/business/' + $scope.riskEvent.risk_id + '/download/materialsAsZIP';
return url;
}; };
// 加载提交材料 // 加载提交材料
@ -264,29 +251,21 @@ define(['angular', 'jquery', 'uiRouter', './monitoring/analysis-monitoring'],
// 材料审核 // 材料审核
$scope.auditMaterial = function(auditType) { $scope.auditMaterial = function(auditType) {
var url = '/risk/business/events';
if (auditType == 4) {
url = '/risk/business/' + $scope.riskEvent.risk_id + '/refuse'
}
$scope.riskEvent.result_type = auditType; $scope.riskEvent.result_type = auditType;
// 后面把url当做参数传递进去，删除重复的代码 $http.put(url, $scope.riskEvent).then(function (resp) {
if (auditType == 3) { $state.go('^', {}, {reload: true});
$http.put('/risk/business/events', $scope.riskEvent).then(function (resp) { }, function (resp) {
$state.go('^', {}, {reload: true}); commonDialog.alert({
}, function (resp) { title: 'Error',
commonDialog.alert({ content: resp.data.message,
title: 'Error', type: 'error'
content: resp.data.message,
type: 'error'
});
});
} else if (auditType == 4) {
$http.put('/risk/business/' + $scope.riskEvent.risk_id + '/refuse').then(function(resp) {
$state.go('^', {}, {reload: true});
}, function (resp) {
commonDialog.alert({
title: 'Error',
content: resp.data.message,
type: 'error'
});
}); });
} });
} }
} }

Write Preview
Loading…
Cancel
Save