diff --git a/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnService.java b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnService.java new file mode 100644 index 0000000..7199a26 --- /dev/null +++ b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnService.java @@ -0,0 +1,18 @@ +package cn.estsh.i3plus.ext.mes.pcn.api.base; + +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.mes.bean.MesContainerSn; + +/** + * @Description : 容器条码-业务方法 + * @Reference : + * @Author : logic + * @CreateDate : 2025/6/16 10:43 + * @Modify: + **/ +public interface IMesContainerSnService { + + ListPager queryMesContainerSnByPager(MesContainerSn mesContainerSn, Pager pager); + +} diff --git a/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnStationService.java b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnStationService.java new file mode 100644 index 0000000..fe1d40a --- /dev/null +++ b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/base/IMesContainerSnStationService.java @@ -0,0 +1,28 @@ +package cn.estsh.i3plus.ext.mes.pcn.api.base; + +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.mes.bean.MesContainerSnStation; + +import java.util.List; + +/** + * @Description : 容器条码与站点关系表-业务方法 + * @Reference : + * @Author : logic + * @CreateDate : 2025/6/13 09:16 + * @Modify: + **/ +public interface IMesContainerSnStationService { + + ListPager queryPager(MesContainerSnStation mesContainerSnStation, Pager pager); + + void doInsert(MesContainerSnStation mesContainerSnStation, String userName); + + void doUpdate(MesContainerSnStation mesContainerSnStation, String userName); + + void doUpdateIsValid(List idList, Integer status, String organizeCode, String userName); + + void deleteWeaklyByIds(List idList, String organizeCode, String userName); + +} diff --git a/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/busi/IMesStationService.java b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/busi/IMesStationService.java index 6788591..12abcd9 100644 --- a/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/busi/IMesStationService.java +++ b/modules/i3plus-ext-mes-pcn-api/src/main/java/cn/estsh/i3plus/ext/mes/pcn/api/busi/IMesStationService.java @@ -1,8 +1,12 @@ package cn.estsh.i3plus.ext.mes.pcn.api.busi; +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; import cn.estsh.i3plus.pojo.mes.bean.MesStation; import io.swagger.annotations.ApiOperation; +import java.util.List; + /** * @Description : 站点信息 * @Reference : @@ -18,5 +22,9 @@ public interface IMesStationService { @ApiOperation("校验站点信息根据设备代码") MesStation checkMesStationByEquipmentCode(String organizeCode,String equipmentCode); + @ApiOperation("查询站点信息中所有的设备代码") + List queryAllEquipmentCodeFromMesStation(String organizeCode); + + ListPager queryMesStationByPager(MesStation mesStation, Pager pager); } diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/base/MesContainerSnStationController.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/base/MesContainerSnStationController.java new file mode 100644 index 0000000..4936ed7 --- /dev/null +++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/base/MesContainerSnStationController.java @@ -0,0 +1,123 @@ +package cn.estsh.i3plus.ext.mes.pcn.apiservice.controller.base; + +import cn.estsh.i3plus.ext.mes.pcn.api.base.IMesContainerSnStationService; +import cn.estsh.i3plus.ext.mes.pcn.pojo.constant.MesCommonConstant; +import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; +import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil; +import cn.estsh.i3plus.pojo.mes.bean.MesContainerSnStation; +import cn.estsh.impp.framework.boot.auth.AuthUtil; +import cn.estsh.impp.framework.boot.exception.ImppBusiException; +import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; +import cn.estsh.impp.framework.boot.util.ResultBean; +import cn.estsh.impp.framework.boot.util.ValidatorBean; +import io.swagger.annotations.Api; +import io.swagger.annotations.ApiOperation; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.web.bind.annotation.*; + +import java.util.Arrays; +import java.util.List; + +/** + * @Description : 容器条码与站点关系表 + * @Reference : + * @Author : logic + * @CreateDate : 2025/6/13 09:15 + * @Modify: + **/ +@RestController +@Api(tags = "容器条码与站点关系表") +@RequestMapping(MesCommonConstant.MES_YANFEN + "/mes-container-sn-station") +public class MesContainerSnStationController { + + @Autowired + private IMesContainerSnStationService mesContainerSnStationService; + + @GetMapping("/query") + @ApiOperation(value = "查询") + public ResultBean queryPager(MesContainerSnStation mesContainerSnStation, Pager pager) { + try { + ValidatorBean.checkNotNull(mesContainerSnStation.getOrganizeCode(), "工厂代码为空"); + return ResultBean.success("查询成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).setListPager( + mesContainerSnStationService.queryPager(mesContainerSnStation, pager)); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @PostMapping("/insert") + @ApiOperation(value = "新增") + public ResultBean doInsert(@RequestBody MesContainerSnStation mesContainerSnStation) { + try { + String userName = AuthUtil.getSessionUser().getUserName(); + ValidatorBean.checkNotNull(mesContainerSnStation.getOrganizeCode(), "工厂代码为空"); + mesContainerSnStationService.doInsert(mesContainerSnStation, userName); + return ResultBean.success("新增成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @PostMapping("/update") + @ApiOperation(value = "编辑") + public ResultBean doUpdate(@RequestBody MesContainerSnStation mesContainerSnStation) { + try { + String userName = AuthUtil.getSessionUser().getUserName(); + ValidatorBean.checkNotNull(mesContainerSnStation.getOrganizeCode(), "工厂代码为空"); + mesContainerSnStationService.doUpdate(mesContainerSnStation, userName); + return ResultBean.success("编辑成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @PutMapping("/update-isValid-by-id") + @ApiOperation(value = "批量根据id启用或禁用") + public ResultBean doUpdateIsValid(Long[] idList, Integer isValid, String organizeCode) { + try { + ValidatorBean.checkNotNull(organizeCode, "工厂代码为空"); + ValidatorBean.checkNotNull(idList, "请选择需要删除的信息"); + List ids = Arrays.asList(idList); + if (isValid != CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() && + isValid != CommonEnumUtil.TRUE_OR_FALSE.FALSE.getValue()) { + throw ImppExceptionBuilder.newInstance() + .setSystemID(CommonEnumUtil.SOFT_TYPE.MES_PCN.getCode()) + .setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode()) + .setErrorDetail("状态值不符合要求,不允许操作"). + build(); + } + String userName = AuthUtil.getSessionUser().getUserName(); + mesContainerSnStationService.doUpdateIsValid(ids, isValid, organizeCode, userName); + return ResultBean.success("批量根据id启用或禁用成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @PutMapping(value = "/delete-weakly") + @ApiOperation(value = "批量软删除信息") + public ResultBean batchDeleteWeaklyByIds(@RequestBody Long[] idList, String organizeCode) { + try { + ValidatorBean.checkNotNull(idList, "请选择需要删除的信息"); + ValidatorBean.checkNotNull(organizeCode, "工厂代码为空"); + List ids = Arrays.asList(idList); + String userName = AuthUtil.getSessionUser().getUserName(); + mesContainerSnStationService.deleteWeaklyByIds(ids, organizeCode, userName); + return ResultBean.success("批量删除信息成功") + .setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()); + } catch (ImppBusiException e) { + return ResultBean.fail(e); + } + } + +} diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/busi/MesBusiController.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/busi/MesBusiController.java index 03f802d..fdc5109 100644 --- a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/busi/MesBusiController.java +++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/controller/busi/MesBusiController.java @@ -1,16 +1,16 @@ package cn.estsh.i3plus.ext.mes.pcn.apiservice.controller.busi; +import cn.estsh.i3plus.ext.mes.pcn.api.base.IMesContainerSnService; import cn.estsh.i3plus.ext.mes.pcn.api.base.IMesEquipmentExtService; import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesConfigService; import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesProduceSnExtService; import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesProductionRecordService; +import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesStationService; import cn.estsh.i3plus.ext.mes.pcn.apiservice.util.MesPcnException; import cn.estsh.i3plus.ext.mes.pcn.pojo.constant.MesCommonConstant; +import cn.estsh.i3plus.pojo.base.bean.ListPager; import cn.estsh.i3plus.pojo.base.common.Pager; -import cn.estsh.i3plus.pojo.mes.bean.MesConfig; -import cn.estsh.i3plus.pojo.mes.bean.MesEquipment; -import cn.estsh.i3plus.pojo.mes.bean.MesProduceSn; -import cn.estsh.i3plus.pojo.mes.bean.MesProductionRecord; +import cn.estsh.i3plus.pojo.mes.bean.*; import cn.estsh.impp.framework.boot.exception.ImppBusiException; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; import cn.estsh.impp.framework.boot.util.ResultBean; @@ -23,6 +23,7 @@ import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; +import java.util.List; import java.util.Objects; /** @@ -50,6 +51,12 @@ public class MesBusiController { @Autowired private IMesEquipmentExtService mesEquipmentExtService; + @Autowired + private IMesStationService mesStationService; + + @Autowired + private IMesContainerSnService mesContainerSnService; + @GetMapping("/mesProduceSn/query") @ApiOperation(value = "查询条码信息") public ResultBean queryMesProduceSn(MesProduceSn mesProduceSn, Pager pager) { @@ -107,4 +114,47 @@ public class MesBusiController { return ImppExceptionBuilder.newInstance().buildExceptionResult(e); } } + + @GetMapping("/mesStation/query-all-equipment-code-from-mes-station") + @ApiOperation(value = "查询站点信息中所有的设备代码") + public ResultBean queryAllEquipmentCodeFromMesStation(String organizeCode) { + try { + ValidatorBean.checkNotNull(organizeCode, "工厂代码不能为空"); + List equipmentCodeList = mesStationService.queryAllEquipmentCodeFromMesStation(organizeCode); + return ResultBean.success("查询站点信息中所有的设备代码成功").setResultList(equipmentCodeList); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @GetMapping("/mesStation/query-mes-station-by-pager") + @ApiOperation(value = "分页查询站点信息") + public ResultBean queryMesEquipment(MesStation mesStation, Pager pager) { + try { + ValidatorBean.checkNotNull(mesStation.getOrganizeCode(), "工厂代码不能为空"); + ListPager mesStationByPager = mesStationService.queryMesStationByPager(mesStation, pager); + return ResultBean.success("分页查询站点信息成功").setListPager(mesStationByPager); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + + @GetMapping("/mesContainerSn/query-mes-container-sn-by-pager") + @ApiOperation(value = "分页查询容器条码") + public ResultBean queryMesContainerSnByPager(MesContainerSn mesContainerSn, Pager pager) { + try { + ValidatorBean.checkNotNull(mesContainerSn.getOrganizeCode(), "工厂代码不能为空"); + ListPager mesContainerSnListPager = mesContainerSnService.queryMesContainerSnByPager(mesContainerSn, pager); + return ResultBean.success("分页查询容器条码成功").setListPager(mesContainerSnListPager); + } catch (ImppBusiException imppException) { + return ResultBean.fail(imppException); + } catch (Exception e) { + return ImppExceptionBuilder.newInstance().buildExceptionResult(e); + } + } + } diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnServiceImpl.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnServiceImpl.java new file mode 100644 index 0000000..c995315 --- /dev/null +++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnServiceImpl.java @@ -0,0 +1,41 @@ +package cn.estsh.i3plus.ext.mes.pcn.apiservice.serviceimpl.base; + +import cn.estsh.i3plus.ext.mes.pcn.api.base.IMesContainerSnService; +import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.base.common.PagerHelper; +import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack; +import cn.estsh.i3plus.pojo.mes.bean.MesContainerSn; +import cn.estsh.i3plus.pojo.mes.repository.MesContainerSnRepository; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * @Description : 容器条码-业务方法实现 + * @Reference : + * @Author : logic + * @CreateDate : 2025/6/16 10:44 + * @Modify: + **/ +@Service +@Slf4j +public class MesContainerSnServiceImpl implements IMesContainerSnService { + + @Autowired + private MesContainerSnRepository mesContainerSnRepository; + + @Override + public ListPager queryMesContainerSnByPager(MesContainerSn mesContainerSn, Pager pager) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(mesContainerSn.getOrganizeCode()); + DdlPreparedPack.getStringEqualPack(mesContainerSn.getContainerTypeCode(), "containerTypeCode", ddlPackBean); + DdlPreparedPack.getStringEqualPack(mesContainerSn.getContainerSn(), "containerSn", ddlPackBean); + pager = PagerHelper.getPager(pager, mesContainerSnRepository.findByHqlWhereCount(ddlPackBean)); + List containerSnList = mesContainerSnRepository.findByHqlWherePage(ddlPackBean, pager); + return new ListPager<>(containerSnList, pager); + } + +} diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnStationServiceImpl.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnStationServiceImpl.java new file mode 100644 index 0000000..7cb375d --- /dev/null +++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/base/MesContainerSnStationServiceImpl.java @@ -0,0 +1,101 @@ +package cn.estsh.i3plus.ext.mes.pcn.apiservice.serviceimpl.base; + +import cn.estsh.i3plus.platform.common.convert.ConvertBean; +import cn.estsh.i3plus.platform.common.tool.TimeTool; +import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.base.common.PagerHelper; +import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; +import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack; +import cn.estsh.i3plus.pojo.mes.bean.MesContainerSnStation; +import cn.estsh.i3plus.pojo.mes.repository.MesContainerSnStationRepository; +import lombok.extern.slf4j.Slf4j; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.stereotype.Service; +import cn.estsh.i3plus.ext.mes.pcn.api.base.IMesContainerSnStationService; +import org.springframework.util.CollectionUtils; + +import java.util.List; +import java.util.Objects; + +/** + * @Description : 容器条码与站点关系表-业务方法实现 + * @Reference : + * @Author : logic + * @CreateDate : 2025/6/13 09:16 + * @Modify: + **/ +@Slf4j +@Service +public class MesContainerSnStationServiceImpl implements IMesContainerSnStationService { + + @Autowired + private MesContainerSnStationRepository mesContainerSnStationRepository; + + @Override + public ListPager queryPager(MesContainerSnStation mesContainerSnStation, Pager pager) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(mesContainerSnStation.getOrganizeCode()); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getEquipmentCode(), "equipmentCode", ddlPackBean); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getStation(), "station", ddlPackBean); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getContainerSn(), "containerSn", ddlPackBean); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getPartNo(), "partNo", ddlPackBean); + pager = PagerHelper.getPager(pager, mesContainerSnStationRepository.findByHqlWhereCount(ddlPackBean)); + List containerSnStationList = mesContainerSnStationRepository.findByHqlWherePage(ddlPackBean, pager); + return new ListPager<>(containerSnStationList, pager); + } + + @Override + public void doInsert(MesContainerSnStation mesContainerSnStation, String userName) { + //根据站点 + 设备代码的组合查询现有数据中最大的顺序号,新增数据的顺序号在最大值的基础上加一 + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(mesContainerSnStation.getOrganizeCode()); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getEquipmentCode(), "equipmentCode", ddlPackBean); + DdlPreparedPack.getStringEqualPack(mesContainerSnStation.getStation(), "station", ddlPackBean); + DdlPreparedPack.getOrderByPack( + new Object[]{CommonEnumUtil.ASC_OR_DESC.DESC.getValue()}, + new String[]{"seq"}, ddlPackBean); + List oldContainerSnStationList = + mesContainerSnStationRepository.findByHqlTopWhere(ddlPackBean, 1); + Integer seq; + if (CollectionUtils.isEmpty(oldContainerSnStationList)) { + seq = 1; + }else { + if (Objects.isNull(oldContainerSnStationList.get(0)) || + Objects.isNull(oldContainerSnStationList.get(0).getSeq())) { + seq = 1; + }else { + seq = oldContainerSnStationList.get(0).getSeq() + 1; + } + } + mesContainerSnStation.setSeq(seq); + ConvertBean.saveOrUpdate(mesContainerSnStation, userName); + mesContainerSnStationRepository.insert(mesContainerSnStation); + } + + @Override + public void doUpdate(MesContainerSnStation mesContainerSnStation, String userName) { + ConvertBean.saveOrUpdate(mesContainerSnStation, userName); + mesContainerSnStationRepository.update(mesContainerSnStation); + } + + @Override + public void doUpdateIsValid(List idList, Integer status, String organizeCode, String userName) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(organizeCode); + DdlPreparedPack.getInPackList(idList, "id", ddlPackBean); + mesContainerSnStationRepository.updateByProperties( + new String[]{"modifyUser", "modifyDatetime", "isValid"}, + new Object[]{userName, TimeTool.getNowTime(true), status }, + ddlPackBean); + } + + @Override + public void deleteWeaklyByIds(List idList, String organizeCode, String userName) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(organizeCode); + DdlPreparedPack.getInPackList(idList, "id", ddlPackBean); + mesContainerSnStationRepository.updateByProperties( + new String[]{"modifyUser", "modifyDatetime", "isDeleted"}, + new Object[]{userName, TimeTool.getNowTime(true), CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()}, + ddlPackBean); + } + +} diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/busi/MesStationServiceImpl.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/busi/MesStationServiceImpl.java index 27100d7..e3c67c1 100644 --- a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/busi/MesStationServiceImpl.java +++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/serviceimpl/busi/MesStationServiceImpl.java @@ -3,14 +3,23 @@ package cn.estsh.i3plus.ext.mes.pcn.apiservice.serviceimpl.busi; import cn.estsh.i3plus.ext.mes.pcn.api.busi.IMesStationService; import cn.estsh.i3plus.ext.mes.pcn.apiservice.util.MesPcnException; import cn.estsh.i3plus.ext.mes.pcn.pojo.util.MesPcnExtConstWords; +import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; +import cn.estsh.i3plus.pojo.base.bean.ListPager; +import cn.estsh.i3plus.pojo.base.common.Pager; +import cn.estsh.i3plus.pojo.base.common.PagerHelper; import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; +import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack; import cn.estsh.i3plus.pojo.base.util.StringUtil; import cn.estsh.i3plus.pojo.mes.bean.MesStation; import cn.estsh.i3plus.pojo.mes.repository.MesStationRepository; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import org.springframework.util.CollectionUtils; +import java.util.ArrayList; +import java.util.List; import java.util.Objects; +import java.util.stream.Collectors; /** * @Description : 站点信息 @@ -44,4 +53,29 @@ public class MesStationServiceImpl implements IMesStationService { } return mesStation; } + + @Override + public List queryAllEquipmentCodeFromMesStation(String organizeCode) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(organizeCode); + List mesStationList = mesStationRepository.findByHqlWhere(ddlPackBean); + List equipmentCodeList = new ArrayList<>(); + if (CollectionUtils.isEmpty(mesStationList)) { + return equipmentCodeList; + }else { + equipmentCodeList = mesStationList.stream().map(MesStation::getEquipmentCode).distinct().collect(Collectors.toList()); + return equipmentCodeList; + } + } + + @Override + public ListPager queryMesStationByPager(MesStation mesStation, Pager pager) { + DdlPackBean ddlPackBean = DdlPackBean.getDdlPackBean(mesStation.getOrganizeCode()); + DdlPreparedPack.getStringLikerPack(mesStation.getStation(), "station", ddlPackBean); + DdlPreparedPack.getNumEqualPack(mesStation.getStationType(), "stationType", ddlPackBean); + DdlPreparedPack.getStringLikerPack(mesStation.getEquipmentCode(), "equipmentCode", ddlPackBean); + pager = PagerHelper.getPager(pager, mesStationRepository.findByHqlWhereCount(ddlPackBean)); + List mesStationList = mesStationRepository.findByHqlWherePage(ddlPackBean, pager); + return new ListPager<>(mesStationList, pager); + } + }