diff --git a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/controller/cms/CmsJobController.java b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/controller/cms/CmsJobController.java index 2ddeed8..0942cb4 100644 --- a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/controller/cms/CmsJobController.java +++ b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/controller/cms/CmsJobController.java @@ -346,6 +346,12 @@ public class CmsJobController extends BaseController if (job.getJobContactList() == null) { job.setJobContactList(new ArrayList<>()); } - return toAjax(jobService.insertJob(job)); + Integer total=jobService.getTotals(job); + int totalNum = total != null ? total : 0; + System.out.println("岗位条数======================"+totalNum); + if (totalNum == 0) { + return toAjax(jobService.insertJob(job)); + } + return AjaxResult.success("此岗位已存在!"); } } diff --git a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/mapper/JobMapper.java b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/mapper/JobMapper.java index d53ded3..f5951db 100644 --- a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/mapper/JobMapper.java +++ b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/mapper/JobMapper.java @@ -58,4 +58,6 @@ public interface JobMapper extends BaseMapper * @return */ Job getJobInfo(Long jobId); + + Integer getTotals(Job job); } diff --git a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/IJobService.java b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/IJobService.java index 6fc2826..7c95b89 100644 --- a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/IJobService.java +++ b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/IJobService.java @@ -103,4 +103,11 @@ public interface IJobService public Job selectHttpJobByJobId(Long jobId, HttpServletRequest request); public List selectHttpJobList(Job job,HttpServletRequest request); + + /** + * 获取微信抓取的重复数据条数 + * @param job + * @return + */ + public Integer getTotals(Job job); } diff --git a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/impl/JobServiceImpl.java b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/impl/JobServiceImpl.java index 47bbee6..bfc4ab6 100644 --- a/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/impl/JobServiceImpl.java +++ b/ruoyi-bussiness/src/main/java/com/ruoyi/cms/service/impl/JobServiceImpl.java @@ -357,13 +357,13 @@ public class JobServiceImpl extends ServiceImpl implements IJobSe { int insert = jobMapper.insert(job); //todo 线程池管理 - Thread thread = new Thread(() -> { - VectorJob jobVector = jobMapper.selectVectorJob(job.getJobId()); - jobVector.setJobUrl("http://39.98.44.136/app#/packageA/pages/post/post?jobId="+job.getJobId()); - String jsonBody = JSONUtil.toJsonStr(jobVector); - HttpUtil.post("http://39.98.44.136:6004/insert_vector", jsonBody); - }); - thread.start(); +// Thread thread = new Thread(() -> { +// VectorJob jobVector = jobMapper.selectVectorJob(job.getJobId()); +// jobVector.setJobUrl("http://39.98.44.136/app#/packageA/pages/post/post?jobId="+job.getJobId()); +// String jsonBody = JSONUtil.toJsonStr(jobVector); +// HttpUtil.post("http://39.98.44.136:6004/insert_vector", jsonBody); +// }); +// thread.start(); if(insert>0){ //添加联系人 List jobContactList = job.getJobContactList() != null ? job.getJobContactList() : Collections.emptyList(); @@ -1132,4 +1132,9 @@ public class JobServiceImpl extends ServiceImpl implements IJobSe params.put("offset", offset*batchSize); return jobMapper.selectAllJob(params); } + + @Override + public Integer getTotals(Job job) { + return jobMapper.getTotals(job); + } } diff --git a/ruoyi-bussiness/src/main/resources/mapper/app/JobMapper.xml b/ruoyi-bussiness/src/main/resources/mapper/app/JobMapper.xml index 75f2302..39d2a84 100644 --- a/ruoyi-bussiness/src/main/resources/mapper/app/JobMapper.xml +++ b/ruoyi-bussiness/src/main/resources/mapper/app/JobMapper.xml @@ -331,4 +331,22 @@ left join company as c on c.company_id = j.company_id and j.del_flag='0' and j.job_id=#{jobId} and c.del_flag='0' limit 1 + + + \ No newline at end of file