Commit 72b37200 authored by Administrator's avatar Administrator

-

Signed-off-by: Administrator's avatarAdministrator <admin@example.com>
parent 332b71b1
package com.dsk.jsk.service;
import org.springframework.stereotype.Service;
/**
* @ClassName JskCompanyRelationTableV1Service
* @Description 1
* @Author Dgm
* @Date 2023/12/13 10:48
* @Version
*/
@Service
public class JskCompanyRelationTableV1Service {
}
...@@ -43,8 +43,8 @@ public class MonitorController { ...@@ -43,8 +43,8 @@ public class MonitorController {
*@date: 2023/12/9 9:29 *@date: 2023/12/9 9:29
*/ */
@GetMapping(value = "push/rulesSelect") @GetMapping(value = "push/rulesSelect")
public R rulesSelect(PushMonitorCompanyAddVo addVo) { public R rulesSelect(PushMonitorRulesSelectVo selectVo) {
return monitorService.rulesSelect(addVo); return monitorService.rulesSelect(selectVo);
} }
/*** /***
...@@ -83,18 +83,6 @@ public class MonitorController { ...@@ -83,18 +83,6 @@ public class MonitorController {
return monitorService.companyDynamicPage(pageVo); return monitorService.companyDynamicPage(pageVo);
} }
/***
*@Description: 监控动态详情
*@Param:
*@return: com.dsk.common.core.domain.R
*@Author: Dgm
*@date: 2023/12/9 9:29
*/
@PostMapping(value = "company/dynamicDetail")
public R companyDynamicDetail(@RequestBody PushMonitorDynamicDetailVo detailVo) {
return monitorService.companyDynamicDetail(detailVo);
}
/*** /***
*@Description: 监控报告 分页 *@Description: 监控报告 分页
*@Param: *@Param:
...@@ -155,4 +143,16 @@ public class MonitorController { ...@@ -155,4 +143,16 @@ public class MonitorController {
return monitorService.systemImport(file, importAddVo); return monitorService.systemImport(file, importAddVo);
} }
/***
*@Description: 详情
*@Param:
*@return: java.lang.String
*@Author: Dgm
*@date: 2022/6/14 10:45
*/
@RequestMapping("/system/detail")
public R systemDetail(@RequestBody PushMonitorSystemDetailVo detailVo){
return monitorService.systemDetail(detailVo);
}
} }
...@@ -25,7 +25,7 @@ public class PushMonitorRules implements Serializable { ...@@ -25,7 +25,7 @@ public class PushMonitorRules implements Serializable {
/** /**
* 创建人Id * 创建人Id
*/ */
private Long userId = 98L; private Long userId = 7324L;
/** /**
* 风险类型,多个逗号隔开 * 风险类型,多个逗号隔开
......
...@@ -14,7 +14,7 @@ public class ConditionVo { ...@@ -14,7 +14,7 @@ public class ConditionVo {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
/** /**
* 条件查询企业id * 条件查询企业id
*/ */
......
...@@ -18,7 +18,7 @@ public class PushMonitorCompanyAddVo { ...@@ -18,7 +18,7 @@ public class PushMonitorCompanyAddVo {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
/** /**
* 多个企业id数组 * 多个企业id数组
*/ */
......
...@@ -17,7 +17,7 @@ public class PushMonitorCompanyCancelVo { ...@@ -17,7 +17,7 @@ public class PushMonitorCompanyCancelVo {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
/** /**
* 多个企业id数组 * 多个企业id数组
*/ */
......
...@@ -17,7 +17,7 @@ public class PushMonitorCompanyImportAddVo { ...@@ -17,7 +17,7 @@ public class PushMonitorCompanyImportAddVo {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
/** /**
* 多个企业id数组 * 多个企业id数组
*/ */
......
...@@ -20,5 +20,5 @@ public class PushMonitorCompanyPageVo extends BasePage { ...@@ -20,5 +20,5 @@ public class PushMonitorCompanyPageVo extends BasePage {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
} }
...@@ -16,7 +16,7 @@ public class PushMonitorDynamicPageVo extends BasePage { ...@@ -16,7 +16,7 @@ public class PushMonitorDynamicPageVo extends BasePage {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
private ConditionVo condition; private ConditionVo condition;
} }
...@@ -20,5 +20,5 @@ public class PushMonitorReportPageVo extends BasePage { ...@@ -20,5 +20,5 @@ public class PushMonitorReportPageVo extends BasePage {
/** /**
* 用户id * 用户id
*/ */
private Long userId = 98L; private Long userId = 7324L;
} }
...@@ -14,5 +14,5 @@ public class PushMonitorRulesDetailVo { ...@@ -14,5 +14,5 @@ public class PushMonitorRulesDetailVo {
/** /**
* 创建人Id * 创建人Id
*/ */
private Long userId = 98L; private Long userId = 7324L;
} }
package com.dsk.monitor.domain.vo;
import lombok.Data;
import java.util.List;
/**
* @ClassName PushMonitorRulesSelectVo
* @Description 监控 下拉
* @Author Dgm
* @Date 2023/12/9 11:05
* @Version
*/
@Data
public class PushMonitorRulesSelectVo {
/**
* 用户id
*/
private Long userId = 7324L;
/**
* 系统来源
*/
private String sysType = "ZJYJ";
}
package com.dsk.monitor.domain.vo;
import lombok.Data;
/**
* @ClassName PushMonitorSystemDetail
* @Description 详情
* @Author Dgm
* @Date 2023/5/23 14:05
* @Version
*/
public class PushMonitorSystemDetailVo {
/**
* 监控维度名称
*/
private String dimensionName;
/**
* 来源Id
*/
private String sourceId;
/**
* eid
*/
private String eid;
/**
* uid
*/
private String uId;
/**
* md5Id
*/
private String md5Id;
/**
* objId
*/
private String objId;
public String getDimensionName() {
return dimensionName;
}
public void setDimensionName(String dimensionName) {
this.dimensionName = dimensionName;
}
public String getSourceId() {
return sourceId;
}
public void setSourceId(String sourceId) {
this.sourceId = sourceId;
}
public String getEid() {
return eid;
}
public void setEid(String eid) {
this.eid = eid;
}
public String getuId() {
return uId;
}
public void setuId(String uId) {
this.uId = uId;
}
public String getMd5Id() {
return md5Id;
}
public void setMd5Id(String md5Id) {
this.md5Id = md5Id;
}
public String getObjId() {
return objId;
}
public void setObjId(String objId) {
this.objId = objId;
}
public PushMonitorSystemDetailVo() {
}
public PushMonitorSystemDetailVo(String eid, String uId, String md5Id, String objId) {
this.eid = eid;
this.uId = uId;
this.md5Id = md5Id;
this.objId = objId;
}
@Override
public String toString() {
return "PushMonitorSystemDetailVo{" +
"dimensionName='" + dimensionName + '\'' +
", sourceId='" + sourceId + '\'' +
", eid='" + eid + '\'' +
", uId='" + uId + '\'' +
", md5Id='" + md5Id + '\'' +
", objId='" + objId + '\'' +
'}';
}
}
...@@ -30,7 +30,7 @@ public interface MonitorService { ...@@ -30,7 +30,7 @@ public interface MonitorService {
*@Author: Dgm *@Author: Dgm
*@date: 2023/12/9 10:03 *@date: 2023/12/9 10:03
*/ */
R rulesSelect(PushMonitorCompanyAddVo addVo); R rulesSelect(PushMonitorRulesSelectVo addVo);
/*** /***
*@Description: 保存监控规则信息 *@Description: 保存监控规则信息
...@@ -60,15 +60,6 @@ public interface MonitorService { ...@@ -60,15 +60,6 @@ public interface MonitorService {
*/ */
TableDataInfo companyDynamicPage(PushMonitorDynamicPageVo pageVo) throws Exception; TableDataInfo companyDynamicPage(PushMonitorDynamicPageVo pageVo) throws Exception;
/***
*@Description: 监控动态详情
*@Param: detailVo 信息
*@return: R
*@Author: Dgm
*@date: 2023/12/9 10:03
*/
R companyDynamicDetail(PushMonitorDynamicDetailVo detailVo);
/*** /***
*@Description: 监控报告 *@Description: 监控报告
*@Param: pageVo 信息 *@Param: pageVo 信息
...@@ -114,4 +105,13 @@ public interface MonitorService { ...@@ -114,4 +105,13 @@ public interface MonitorService {
*@date: 2023/12/9 10:03 *@date: 2023/12/9 10:03
*/ */
R systemImport(MultipartFile file, PushMonitorCompanyImportAddVo importAddVo) throws Exception; R systemImport(MultipartFile file, PushMonitorCompanyImportAddVo importAddVo) throws Exception;
/***
*@Description: 动态详情
*@Param: cancelVo 信息
*@return: R
*@Author: Dgm
*@date: 2023/12/9 10:03
*/
R systemDetail(PushMonitorSystemDetailVo importAddVo);
} }
...@@ -7,7 +7,6 @@ import com.dsk.common.core.domain.R; ...@@ -7,7 +7,6 @@ import com.dsk.common.core.domain.R;
import com.dsk.common.core.page.TableDataInfo; import com.dsk.common.core.page.TableDataInfo;
import com.dsk.common.helper.LoginHelper; import com.dsk.common.helper.LoginHelper;
import com.dsk.common.utils.redis.RedisUtils; import com.dsk.common.utils.redis.RedisUtils;
import com.dsk.monitor.domain.dto.PushMonitorInfo;
import com.dsk.monitor.domain.dto.PushMonitorRules; import com.dsk.monitor.domain.dto.PushMonitorRules;
import com.dsk.monitor.domain.vo.*; import com.dsk.monitor.domain.vo.*;
import com.dsk.monitor.mapper.PushMonitorInfoMapper; import com.dsk.monitor.mapper.PushMonitorInfoMapper;
...@@ -52,14 +51,17 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -52,14 +51,17 @@ public class MonitorServiceImpl implements MonitorService {
} }
@Override @Override
public R rulesSelect(PushMonitorCompanyAddVo addVo) { public R rulesSelect(PushMonitorRulesSelectVo addVo) {
Long userId = LoginHelper.getUserId();
if (ObjectUtil.isNotEmpty(userId)) {
addVo.setUserId(userId);
}
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/supplier/system/queryDimensionEnum", BeanUtil.beanToMap(addVo, false, false)); Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/supplier/system/queryDimensionEnum", BeanUtil.beanToMap(addVo, false, false));
return BeanUtil.toBean(map, R.class); return BeanUtil.toBean(map, R.class);
} }
@Override @Override
public R insertRules(PushMonitorRulesVo monitorRulesDto) { public R insertRules(PushMonitorRulesVo monitorRulesDto) {
// todo 20231211 规则是否与使用登录人强关联
Long userId = LoginHelper.getUserId(); Long userId = LoginHelper.getUserId();
if (ObjectUtil.isNotEmpty(userId)) { if (ObjectUtil.isNotEmpty(userId)) {
monitorRulesDto.setUserId(userId); monitorRulesDto.setUserId(userId);
...@@ -99,14 +101,6 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -99,14 +101,6 @@ public class MonitorServiceImpl implements MonitorService {
return dskOpenApiUtil.responsePage(map); return dskOpenApiUtil.responsePage(map);
} }
@Override
public R companyDynamicDetail(PushMonitorDynamicDetailVo detailVo) {
QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("source_id", detailVo.getSourceId());
PushMonitorInfo detail = monitorInfoMapper.selectOne(queryWrapper);
return R.ok(detail);
}
@Override @Override
public TableDataInfo reportPage(PushMonitorReportPageVo pageVo) throws Exception { public TableDataInfo reportPage(PushMonitorReportPageVo pageVo) throws Exception {
Long userId = LoginHelper.getUserId(); Long userId = LoginHelper.getUserId();
...@@ -219,4 +213,79 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -219,4 +213,79 @@ public class MonitorServiceImpl implements MonitorService {
return BeanUtil.toBean(map, R.class); return BeanUtil.toBean(map, R.class);
} }
@Override
public R systemDetail(PushMonitorSystemDetailVo cancelVo) {
String dimensionName = cancelVo.getDimensionName();
cancelVo = getDetailVo(cancelVo);
Map<String, Object> map = new HashMap<>();
switch (dimensionName) {
case "新增经营异常":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/abnormalDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增股权冻结":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/judicialFreezesDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增被执行人":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/executedPersonsDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增失信被执行人":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/executedDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增法院公告":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/noticesDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增裁判文书":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/lawsuitsDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
case "新增开庭公告":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/kaiTingDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
default:
break;
}
return BeanUtil.toBean(map, R.class);
}
public PushMonitorSystemDetailVo getDetailVo(PushMonitorSystemDetailVo detailVo) {
String value1 = null;
String value2 = null;
String sourceId = detailVo.getSourceId();
String[] arr = sourceId.split("_");
if (arr.length > 1) {
value1 = (arr[0]);
value2 = (arr[1]);
}
if (arr.length > 0) {
value1 = (arr[0]);
}
String dimensionName = detailVo.getDimensionName();
switch (dimensionName) {
case "新增经营异常":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2);
break;
case "新增股权冻结":
detailVo = new PushMonitorSystemDetailVo(value1, value2, null,null);
break;
case "新增被执行人":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,null);
break;
case "新增失信被执行人":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,null);
break;
case "新增法院公告":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2);
break;
case "新增裁判文书":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2);
break;
case "新增开庭公告":
detailVo = new PushMonitorSystemDetailVo(value1, null, value2,null);
break;
default:
break;
}
return detailVo;
}
} }
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