Commit e5ec7863 authored by 施翔轲's avatar 施翔轲

【优化】库内供应商数据导入相关

parent b46723ba
...@@ -69,7 +69,7 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -69,7 +69,7 @@ public class MonitorServiceImpl implements MonitorService {
} }
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("user_id", monitorRulesDto.getUserId()); queryWrapper.eq("user_id", monitorRulesDto.getUserId());
PushMonitorRules detail = rulesMapper.selectOne(queryWrapper); PushMonitorRules detail = rulesMapper.selectOne(queryWrapper);
if (ObjectUtil.isEmpty(detail)) { if (ObjectUtil.isEmpty(detail)) {
rulesMapper.insert(monitorRulesDto); rulesMapper.insert(monitorRulesDto);
} else { } else {
...@@ -87,7 +87,7 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -87,7 +87,7 @@ public class MonitorServiceImpl implements MonitorService {
} }
QueryWrapper queryWrapper = new QueryWrapper(); QueryWrapper queryWrapper = new QueryWrapper();
queryWrapper.eq("user_id", detailVo.getUserId()); queryWrapper.eq("user_id", detailVo.getUserId());
PushMonitorRules detail = rulesMapper.selectOne(queryWrapper); PushMonitorRules detail = rulesMapper.selectOne(queryWrapper);
return R.ok(detail); return R.ok(detail);
} }
...@@ -99,14 +99,14 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -99,14 +99,14 @@ public class MonitorServiceImpl implements MonitorService {
pageVo.getCondition().setUserId(userId); pageVo.getCondition().setUserId(userId);
} }
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/info/companyDynamicList", BeanUtil.beanToMap(pageVo, false, false)); Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/info/companyDynamicList", BeanUtil.beanToMap(pageVo, false, false));
log.info("companyDynamicPage=============================>"+map); log.info("companyDynamicPage=============================>" + map);
return dskOpenApiUtil.responsePageT(map); return dskOpenApiUtil.responsePageT(map);
} }
@Override @Override
public Map<String, Object> companyDynamicPageScheduled(PushMonitorDynamicPageVo pageVo) throws Exception { public Map<String, Object> companyDynamicPageScheduled(PushMonitorDynamicPageVo pageVo) throws Exception {
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/info/companyDynamicList", BeanUtil.beanToMap(pageVo, false, false)); Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/company/info/companyDynamicList", BeanUtil.beanToMap(pageVo, false, false));
log.info("companyDynamicPage=============================>"+map); log.info("companyDynamicPage=============================>" + map);
return map; return map;
} }
...@@ -183,10 +183,10 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -183,10 +183,10 @@ public class MonitorServiceImpl implements MonitorService {
} }
//如果文件不存在 则文件上传失败 //如果文件不存在 则文件上传失败
if (file == null){ if (file == null) {
return R.fail("操作失敗,数据异常,請使用正确的模板"); return R.fail("操作失敗,数据异常,請使用正确的模板");
} }
if (file.isEmpty()){ if (file.isEmpty()) {
return R.fail("操作失敗,数据异常,請使用正确的模板"); return R.fail("操作失敗,数据异常,請使用正确的模板");
} }
...@@ -197,14 +197,14 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -197,14 +197,14 @@ public class MonitorServiceImpl implements MonitorService {
//得到最后一行的行号 //得到最后一行的行号
int lastRowNum = sheet.getLastRowNum(); int lastRowNum = sheet.getLastRowNum();
//如果总行数小于等于2 (没有数据)提示数据异常 //如果总行数小于等于2 (没有数据)提示数据异常
if ((lastRowNum) < 1){ if ((lastRowNum) < 1) {
return R.fail("未提供有效数据,请确认!"); return R.fail("未提供有效数据,请确认!");
} }
//进行excel格式判定 //进行excel格式判定
String name = sheet.getRow(2).getCell(0) + ""; String name = sheet.getRow(2).getCell(0) + "";
//只要其中一个不满足则格式有误 //只要其中一个不满足则格式有误
if (!"企业名称".equals(name)){ if (!"企业名称".equals(name)) {
return R.fail("操作失败,数据异常,请使用正确的模板"); return R.fail("操作失败,数据异常,请使用正确的模板");
} }
//行列皆从0开始 //行列皆从0开始
...@@ -219,7 +219,7 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -219,7 +219,7 @@ public class MonitorServiceImpl implements MonitorService {
companyList.add(companyNameStr); companyList.add(companyNameStr);
} }
} catch (Exception e) { } catch (Exception e) {
log.error("",e.getMessage()); log.error("", e.getMessage());
} finally { } finally {
RedisUtils.hasValueDelete(lockKey, value); RedisUtils.hasValueDelete(lockKey, value);
} }
...@@ -261,6 +261,9 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -261,6 +261,9 @@ public class MonitorServiceImpl implements MonitorService {
case "新增开庭公告": case "新增开庭公告":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/kaiTingDetail", BeanUtil.beanToMap(cancelVo, false, false)); map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/kaiTingDetail", BeanUtil.beanToMap(cancelVo, false, false));
break; break;
case "行政处罚":
map = dskOpenApiUtil.requestBody("/operate/enterpriseCredit/xingZhengDetail", BeanUtil.beanToMap(cancelVo, false, false));
break;
default: default:
break; break;
} }
...@@ -289,25 +292,25 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -289,25 +292,25 @@ public class MonitorServiceImpl implements MonitorService {
String dimensionName = detailVo.getDimensionName(); String dimensionName = detailVo.getDimensionName();
switch (dimensionName) { switch (dimensionName) {
case "新增经营异常": case "新增经营异常":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2); detailVo = new PushMonitorSystemDetailVo(value1, null, null, value2);
break; break;
case "新增股权冻结": case "新增股权冻结":
detailVo = new PushMonitorSystemDetailVo(value1, value2, null,null); detailVo = new PushMonitorSystemDetailVo(value1, value2, null, null);
break; break;
case "新增被执行人": case "新增被执行人":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,null); detailVo = new PushMonitorSystemDetailVo(value1, null, null, null);
break; break;
case "新增失信被执行人": case "新增失信被执行人":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,null); detailVo = new PushMonitorSystemDetailVo(value1, null, null, null);
break; break;
case "新增法院公告": case "新增法院公告":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2); detailVo = new PushMonitorSystemDetailVo(value1, null, null, value2);
break; break;
case "新增裁判文书": case "新增裁判文书":
detailVo = new PushMonitorSystemDetailVo(value1, null, null,value2); detailVo = new PushMonitorSystemDetailVo(value1, null, null, value2);
break; break;
case "新增开庭公告": case "新增开庭公告":
detailVo = new PushMonitorSystemDetailVo(value1, null, value2,null); detailVo = new PushMonitorSystemDetailVo(value1, null, value2, null);
break; break;
default: default:
break; break;
...@@ -318,7 +321,7 @@ public class MonitorServiceImpl implements MonitorService { ...@@ -318,7 +321,7 @@ public class MonitorServiceImpl implements MonitorService {
@Override @Override
public Map<String, Object> settingHoliday(PushSettingHolidayVo holidayVo) throws Exception { public Map<String, Object> settingHoliday(PushSettingHolidayVo holidayVo) throws Exception {
Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/push/settingHoliday", BeanUtil.beanToMap(holidayVo, false, false)); Map<String, Object> map = dskOpenApiUtil.requestBody("/operate/monitor/push/settingHoliday", BeanUtil.beanToMap(holidayVo, false, false));
log.info("companyDynamicPage=============================>"+map); log.info("companyDynamicPage=============================>" + map);
return map; return map;
} }
} }
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