From 53d4cf6fa3394e65eb24ceb5c889139d8115a8e5 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=A2=81=E7=90=A6=E6=B6=9B?= Date: Sat, 12 Oct 2024 10:38:10 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E9=9B=B6=E4=BB=B6=E4=BF=A1?= =?UTF-8?q?=E6=81=AF-=E5=88=86=E9=A1=B5=E5=88=97=E8=A1=A8=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/LawsPartInfoController.java | 23 ++++++++++++++++- .../part/job/SyncPartPmmInfoPartDiffJob.java | 25 +++++++++++++++++++ .../laws/part/mapper/LawsPartInfoMapper.java | 5 ++++ .../part/mapper/xml/LawsPartInfoMapper.xml | 9 +++++++ .../part/service/ILawsPartInfoService.java | 8 ++++++ .../service/impl/LawsPartInfoServiceImpl.java | 24 ++++++++++++++++++ 6 files changed, 93 insertions(+), 1 deletion(-) create mode 100644 laws-modules/src/main/java/com/jero/modules/laws/part/job/SyncPartPmmInfoPartDiffJob.java diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/controller/LawsPartInfoController.java b/laws-modules/src/main/java/com/jero/modules/laws/part/controller/LawsPartInfoController.java index 48633003..0480be04 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/part/controller/LawsPartInfoController.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/controller/LawsPartInfoController.java @@ -1,5 +1,6 @@ package com.jero.modules.laws.part.controller; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport; import com.jero.common.api.vo.Result; import com.jero.common.aspect.annotation.AutoLog; @@ -10,6 +11,7 @@ import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; +import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import javax.annotation.Resource; @@ -27,7 +29,7 @@ public class LawsPartInfoController { private ILawsPartInfoService lawsPartInfoService; /** - * 分页列表查询 + * 列表查询 * * @param lawsPartInfo * @return @@ -40,4 +42,23 @@ public class LawsPartInfoController { List list = lawsPartInfoService.queryList(lawsPartInfo, req); return Result.OK(list); } + + /** + * 分页列表查询 + * + * @param lawsPartInfo + * @return + */ + @AutoLog(value = "业务支持-零件信息-分页列表查询") + @ApiOperation(value = "业务支持-零件信息-分页列表查询", notes = "业务支持-零件信息-分页列表查询") + @GetMapping(value = "/page") + @ApiOperationSupport(order = 1) + public Result> queryList(LawsPartInfo lawsPartInfo, + @RequestParam(name = "pageNo", defaultValue = "1") Integer pageNo, + @RequestParam(name = "pageSize", defaultValue = "10") Integer pageSize, + HttpServletRequest req) { + IPage list = lawsPartInfoService.queryPage(lawsPartInfo, pageNo, pageSize, req); + return Result.OK(list); + } + } diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/job/SyncPartPmmInfoPartDiffJob.java b/laws-modules/src/main/java/com/jero/modules/laws/part/job/SyncPartPmmInfoPartDiffJob.java new file mode 100644 index 00000000..49a299d2 --- /dev/null +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/job/SyncPartPmmInfoPartDiffJob.java @@ -0,0 +1,25 @@ +package com.jero.modules.laws.part.job; + +import com.jero.modules.laws.part.service.ILawsPartInfoService; +import lombok.extern.slf4j.Slf4j; +import org.quartz.Job; +import org.quartz.JobExecutionContext; +import org.quartz.JobExecutionException; + +import javax.annotation.Resource; + +/** + * 同步零件数据 + */ +@Slf4j +public class SyncPartPmmInfoPartDiffJob implements Job { + + @Resource + private ILawsPartInfoService lawsPartInfoService; + + @Override + public void execute(JobExecutionContext context) throws JobExecutionException { + lawsPartInfoService.truncatePartPmmInfoPartDiff(); + lawsPartInfoService.syncPartPmmInfoPartDiff(); + } +} diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/LawsPartInfoMapper.java b/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/LawsPartInfoMapper.java index a17fb7f4..4fa68e2a 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/LawsPartInfoMapper.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/LawsPartInfoMapper.java @@ -6,6 +6,11 @@ import com.jero.modules.laws.part.entity.LawsPartInfo; public interface LawsPartInfoMapper extends BaseMapper { + void truncatePartPmmInfoPartDiff(); + + void syncPartPmmInfoPartDiff(); + + } diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/xml/LawsPartInfoMapper.xml b/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/xml/LawsPartInfoMapper.xml index 9b284e39..d33dcd44 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/xml/LawsPartInfoMapper.xml +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/mapper/xml/LawsPartInfoMapper.xml @@ -4,4 +4,13 @@ "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> + + TRUNCATE TABLE ods_qr_cgbom_pmm_info_part_diff_df; + + + + insert into laws_part_pmm_partition_info(reg_part_name_cn,fnd_gpc) + (SELECT regpartnamecn as reg_part_name_cn,CONCAT(fna,upc) as fnd_gpc FROM `ods_qr_cgbom_pmm_partition_info_df` where fna is not null and upc is not null + and regpartnamecn is not null and regpartnamecn != '-' and regpartnamecn != '/' group by CONCAT(fna,upc)) + diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/service/ILawsPartInfoService.java b/laws-modules/src/main/java/com/jero/modules/laws/part/service/ILawsPartInfoService.java index bb6fc8e5..420df8f0 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/part/service/ILawsPartInfoService.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/service/ILawsPartInfoService.java @@ -1,7 +1,9 @@ package com.jero.modules.laws.part.service; +import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.service.IService; import com.jero.modules.laws.part.entity.LawsPartInfo; +import org.springframework.web.bind.annotation.RequestParam; import javax.servlet.http.HttpServletRequest; import java.util.List; @@ -9,4 +11,10 @@ import java.util.List; public interface ILawsPartInfoService extends IService { List queryList(LawsPartInfo lawsPartInfo, HttpServletRequest req); + + IPage queryPage(LawsPartInfo lawsPartInfo,Integer pageNo, Integer pageSize,HttpServletRequest req); + + void truncatePartPmmInfoPartDiff(); + + void syncPartPmmInfoPartDiff(); } diff --git a/laws-modules/src/main/java/com/jero/modules/laws/part/service/impl/LawsPartInfoServiceImpl.java b/laws-modules/src/main/java/com/jero/modules/laws/part/service/impl/LawsPartInfoServiceImpl.java index 5a7b1b94..6f249d92 100644 --- a/laws-modules/src/main/java/com/jero/modules/laws/part/service/impl/LawsPartInfoServiceImpl.java +++ b/laws-modules/src/main/java/com/jero/modules/laws/part/service/impl/LawsPartInfoServiceImpl.java @@ -1,6 +1,8 @@ package com.jero.modules.laws.part.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.jero.common.system.query.QueryGenerator; import com.jero.modules.laws.part.entity.LawsPartInfo; @@ -9,6 +11,7 @@ import com.jero.modules.laws.part.service.ILawsPartInfoService; import lombok.extern.slf4j.Slf4j; import org.springframework.stereotype.Service; +import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import java.util.List; @@ -18,12 +21,33 @@ import java.util.List; public class LawsPartInfoServiceImpl extends ServiceImpl implements ILawsPartInfoService { + @Resource + private LawsPartInfoMapper lawsPartInfoMapper; + @Override public List queryList(LawsPartInfo lawsPartInfo, HttpServletRequest req) { QueryWrapper queryWrapper = QueryGenerator.initQueryWrapper(lawsPartInfo, req.getParameterMap()); return list(queryWrapper); } + + @Override + public IPage queryPage(LawsPartInfo lawsPartInfo, Integer pageNo, Integer pageSize, HttpServletRequest req) { + QueryWrapper queryWrapper = + QueryGenerator.initQueryWrapper(lawsPartInfo, req.getParameterMap()); + Page page = new Page<>(pageNo, pageSize); + return page(page, queryWrapper); + } + + @Override + public void truncatePartPmmInfoPartDiff() { + lawsPartInfoMapper.truncatePartPmmInfoPartDiff(); + } + + @Override + public void syncPartPmmInfoPartDiff() { + lawsPartInfoMapper.syncPartPmmInfoPartDiff(); + } }