tags/yfai-mes-ext-v1.0
gsz 11 months ago
commit 3c910c4bfb

@ -1,5 +1,7 @@
package cn.estsh.i3plus.ext.mes.api.base; package cn.estsh.i3plus.ext.mes.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.MesPart; import cn.estsh.i3plus.pojo.mes.bean.MesPart;
import java.util.List; import java.util.List;
@ -14,4 +16,6 @@ public interface IMesPartService extends IBaseMesService<MesPart> {
MesPart getPartByPartNo(String partNo, String organizeCode); MesPart getPartByPartNo(String partNo, String organizeCode);
List<MesPart> findMesPartByPartNoList(List<String> partNoList, String organizeCode); List<MesPart> findMesPartByPartNoList(List<String> partNoList, String organizeCode);
ListPager<MesPart> queryMesPartByPagerExt(MesPart mesPart, Pager pager);
} }

@ -1,5 +1,7 @@
package cn.estsh.i3plus.ext.mes.api.base; package cn.estsh.i3plus.ext.mes.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.MesProductVersion; import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion;
/** /**
@ -9,5 +11,6 @@ import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion;
*/ */
public interface IMesProductVersionService extends IBaseMesService<MesProductVersion> { public interface IMesProductVersionService extends IBaseMesService<MesProductVersion> {
ListPager<MesProductVersion> queryMesProductVersionByPagerExt(MesProductVersion mesProductVersion, Pager pager);
} }

@ -1,9 +1,18 @@
package cn.estsh.i3plus.ext.mes.apiservice.controller.base; package cn.estsh.i3plus.ext.mes.apiservice.controller.base;
import cn.estsh.i3plus.ext.mes.api.base.IMesPartService;
import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant; import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant;
import cn.estsh.i3plus.pojo.mes.bean.MesArea; import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.mes.bean.MesPart; import cn.estsh.i3plus.pojo.mes.bean.MesPart;
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 io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
@ -14,4 +23,23 @@ import org.springframework.web.bind.annotation.RestController;
@RestController @RestController
@RequestMapping(MesCommonConstant.MES_YANFEN + "/mesPart") @RequestMapping(MesCommonConstant.MES_YANFEN + "/mesPart")
public class MesPartController extends BaseMesController<MesPart>{ public class MesPartController extends BaseMesController<MesPart>{
@Autowired
private IMesPartService mesPartService;
@ApiOperation(value = "查询物料信息", notes = "查询物料信息")
@GetMapping("/query-ext")
public ResultBean queryMesProdRuleByPager(MesPart mesPart, Pager pager){
try {
String organizeCode = AuthUtil.getOrganize().getOrganizeCode();
mesPart.setOrganizeCode(organizeCode);
return ResultBean.success("查询物料信息成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).
setListPager(mesPartService.queryMesPartByPagerExt(mesPart, pager));
} catch (ImppBusiException e) {
return ResultBean.fail(e);
} catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
} }

@ -1,8 +1,19 @@
package cn.estsh.i3plus.ext.mes.apiservice.controller.base; package cn.estsh.i3plus.ext.mes.apiservice.controller.base;
import cn.estsh.i3plus.ext.mes.api.base.IMesProductVersionService;
import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant; import cn.estsh.i3plus.ext.mes.pojo.constant.MesCommonConstant;
import cn.estsh.i3plus.pojo.base.bean.ListPager;
import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.enumutil.ResourceEnumUtil;
import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion; import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion;
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 io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
@Api("生产版本") @Api("生产版本")
@ -10,4 +21,24 @@ import org.springframework.web.bind.annotation.RestController;
@RequestMapping(MesCommonConstant.MES_YANFEN + "/mesProductVersion") @RequestMapping(MesCommonConstant.MES_YANFEN + "/mesProductVersion")
public class MesProductVersionController extends BaseMesController<MesProductVersion>{ public class MesProductVersionController extends BaseMesController<MesProductVersion>{
@Autowired
private IMesProductVersionService mesProductVersionService;
@ApiOperation(value = "查询生产版本", notes = "查询生产版本")
@GetMapping("/query-ext")
public ResultBean queryMesProdRuleByPager(MesProductVersion mesProductVersion, Pager pager){
try {
String organizeCode = AuthUtil.getOrganize().getOrganizeCode();
mesProductVersion.setOrganizeCode(organizeCode);
ListPager<MesProductVersion> productVersionListPager = mesProductVersionService.queryMesProductVersionByPagerExt(mesProductVersion, pager);
return ResultBean.success("查询生产版本成功").setCode(ResourceEnumUtil.MESSAGE.SUCCESS.getCode()).
setListPager(productVersionListPager);
} catch (ImppBusiException e) {
return ResultBean.fail(e);
} catch (Exception e) {
return ImppExceptionBuilder.newInstance().buildExceptionResult(e);
}
}
} }

@ -13,6 +13,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
import java.util.Arrays;
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
/* /*
@ -70,10 +71,10 @@ public class MesBtoJob extends BaseMesScheduleJob {
String organizeCode = (String) paramMap.get("organizeCode"); String organizeCode = (String) paramMap.get("organizeCode");
List<String> groupCodeList = (List<String>) paramMap.get("groupCode"); List<String> groupCodeList = (List<String>) paramMap.get("groupCode");
btoJobService.doCreateBto(organizeCode, groupCodeList); btoJobService.doCreateBto(organizeCode, groupCodeList);
LOGGER.info("缺陷告警配置job结束 ----- end"); LOGGER.info("BTO生成工单job结束 ----- end");
} catch (Exception e) { } catch (Exception e) {
LOGGER.error("SAP接口表数据同步作业任务结束e:{}", e.toString()); LOGGER.error("BTO生成工单e:{}", Arrays.toString(e.getStackTrace()));
} }
} }

@ -4,13 +4,17 @@ import cn.estsh.i3plus.ext.mes.api.base.IMesPartService;
import cn.estsh.i3plus.ext.mes.apiservice.unit.exception.MesException; import cn.estsh.i3plus.ext.mes.apiservice.unit.exception.MesException;
import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum;
import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; 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.enumutil.CommonEnumUtil;
import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack; import cn.estsh.i3plus.pojo.base.tool.DdlPreparedPack;
import cn.estsh.i3plus.pojo.mes.bean.MesPart; import cn.estsh.i3plus.pojo.mes.bean.MesPart;
import cn.estsh.i3plus.pojo.mes.bean.MesPartSap; import cn.estsh.i3plus.pojo.mes.repository.MesPartRepository;
import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder;
import cn.estsh.impp.framework.boot.util.ValidatorBean; import cn.estsh.impp.framework.boot.util.ValidatorBean;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils; import org.springframework.util.CollectionUtils;
@ -20,6 +24,9 @@ import java.util.List;
@Slf4j @Slf4j
public class MesPartService extends BaseMesService<MesPart> implements IMesPartService { public class MesPartService extends BaseMesService<MesPart> implements IMesPartService {
@Autowired
private MesPartRepository mesPartRepository;
protected void setPackQueryBean(MesPart bean, DdlPackBean packBean) { protected void setPackQueryBean(MesPart bean, DdlPackBean packBean) {
DdlPreparedPack.getStringLikerPack(bean.getPartNo(), "partNo", packBean); DdlPreparedPack.getStringLikerPack(bean.getPartNo(), "partNo", packBean);
DdlPreparedPack.getStringLikerPack(bean.getPartName(), "partName", packBean); DdlPreparedPack.getStringLikerPack(bean.getPartName(), "partName", packBean);
@ -49,6 +56,17 @@ public class MesPartService extends BaseMesService<MesPart> implements IMesPartS
return mesPartList; return mesPartList;
} }
@Override
public ListPager<MesPart> queryMesPartByPagerExt(MesPart mesPart, Pager pager) {
DdlPackBean partQueryPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(mesPart.getIsValid(), "isValid", partQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesPart.getPartNo(), "partNo", partQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesPart.getPartName(), "partName", partQueryPackBean);
pager = PagerHelper.getPager(pager, mesPartRepository.findByHqlWhereCount(partQueryPackBean));
List<MesPart> mesPartList = mesPartRepository.findByHqlWherePage(partQueryPackBean, pager);
return new ListPager<>(mesPartList, pager);
}
protected void onInsertBean(MesPart item) { protected void onInsertBean(MesPart item) {
// 数据校验 // 数据校验
ValidatorBean.checkNotNull(item.getPartNo(), "物料号不能为空"); ValidatorBean.checkNotNull(item.getPartNo(), "物料号不能为空");

@ -2,15 +2,25 @@ package cn.estsh.i3plus.ext.mes.apiservice.serviceimpl.base;
import cn.estsh.i3plus.ext.mes.api.base.IMesProductVersionService; import cn.estsh.i3plus.ext.mes.api.base.IMesProductVersionService;
import cn.estsh.i3plus.pojo.base.bean.DdlPackBean; 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.base.tool.DdlPreparedPack;
import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion; import cn.estsh.i3plus.pojo.mes.bean.MesProductVersion;
import cn.estsh.i3plus.pojo.mes.repository.MesProductVersionRepository;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import java.util.List;
@Service @Service
@Slf4j @Slf4j
public class MesProductVersionService extends BaseMesService<MesProductVersion> implements IMesProductVersionService { public class MesProductVersionService extends BaseMesService<MesProductVersion> implements IMesProductVersionService {
@Autowired
private MesProductVersionRepository mesProductVersionRepository;
@Override @Override
protected void setPackQueryBean(MesProductVersion bean, DdlPackBean packBean) { protected void setPackQueryBean(MesProductVersion bean, DdlPackBean packBean) {
DdlPreparedPack.getStringLikerPack(bean.getPartNo(),"partNo",packBean); DdlPreparedPack.getStringLikerPack(bean.getPartNo(),"partNo",packBean);
@ -21,4 +31,17 @@ public class MesProductVersionService extends BaseMesService<MesProductVersion>
DdlPreparedPack.getStringLikerPack(bean.getPartName(),"partName",packBean); DdlPreparedPack.getStringLikerPack(bean.getPartName(),"partName",packBean);
} }
@Override
public ListPager<MesProductVersion> queryMesProductVersionByPagerExt(MesProductVersion mesProductVersion, Pager pager) {
DdlPackBean productVersionQueryPackBean = DdlPackBean.getDdlPackBean();
DdlPreparedPack.getNumEqualPack(mesProductVersion.getIsValid(), "isValid", productVersionQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesProductVersion.getProductVersion(), "productVersion", productVersionQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesProductVersion.getPartNo(), "partNo", productVersionQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesProductVersion.getWorkCenterCode(), "workCenterCode", productVersionQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesProductVersion.getShipInventoryPoint(), "shipInventoryPoint", productVersionQueryPackBean);
DdlPreparedPack.getStringLikerPack(mesProductVersion.getReceiveInventoryPoint(), "receiveInventoryPoint", productVersionQueryPackBean);
pager = PagerHelper.getPager(pager, mesProductVersionRepository.findByHqlWhereCount(productVersionQueryPackBean));
List<MesProductVersion> mesProductVersions = mesProductVersionRepository.findByHqlWherePage(productVersionQueryPackBean, pager);
return new ListPager<>(mesProductVersions, pager);
}
} }

@ -56,13 +56,8 @@ public class MesWcEquipmentServiceImpl extends BaseMesService<MesWcEquipment> im
ValidatorBean.checkNotNull(item.getWorkCenterCode(), "工作中心代码不能为空"); ValidatorBean.checkNotNull(item.getWorkCenterCode(), "工作中心代码不能为空");
//校验数据是否存在 //校验数据是否存在
MesWcEquipment mesWcEquipmentDb = baseRDao.getById(item.getId()); MesWcEquipment mesWcEquipmentDb = baseRDao.getById(item.getId());
if (null == mesWcEquipmentDb || if (null == mesWcEquipmentDb || CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() == mesWcEquipmentDb.getIsDeleted()) {
(null != mesWcEquipmentDb && CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue() == mesWcEquipmentDb.getIsDeleted())) { MesException.throwMesBusiException("数据不存在");
throw ImppExceptionBuilder.newInstance()
.setSystemID(CommonEnumUtil.SOFT_TYPE.MES.getCode())
.setErrorCode(ImppExceptionEnum.VARIFY_EXCEPTION.getCode())
.setErrorDetail("数据不存在")
.build();
} }
//校验设备代码是否有效,校验设备是否已经绑定该工位,校验设备是否已经绑定其他生产线 //校验设备代码是否有效,校验设备是否已经绑定该工位,校验设备是否已经绑定其他生产线
this.checkSaveOrUpdateMesWcEquipment(item); this.checkSaveOrUpdateMesWcEquipment(item);

@ -97,8 +97,9 @@ public class MesTimeRoundnessService implements IRoundnessStrategy {
//获取生产零件信息 //获取生产零件信息
MesPartSap mesPartSap = getMesPart(detail.getProductPartNo(), detail.getOrganizeCode()); MesPartSap mesPartSap = getMesPart(detail.getProductPartNo(), detail.getOrganizeCode());
if (mesPartSap.getId() == null) { if (mesPartSap.getId() == null) {
log.info("零件生成组零件:{}找不到对应的零件信息", detail.getProductPartNo()); log.info("零件生生产组:{},生产零件:{}找不到对应的零件信息",partProdGroup.getPartProdGroupName(), detail.getProductPartNo());
throw ImppExceptionBuilder.newInstance().setErrorDetail("零件生成组零件:{}找不到对应的零件信息", detail.getProductPartNo()).build(); continue;
// throw ImppExceptionBuilder.newInstance().setErrorDetail("零件生成组零件:{}找不到对应的零件信息", detail.getProductPartNo()).build();
} }
MesWorkOrder mesWorkOrder = new MesWorkOrder(); MesWorkOrder mesWorkOrder = new MesWorkOrder();
//工单号生成规则 【工厂号+yyyyMMdd+5位流水】 //工单号生成规则 【工厂号+yyyyMMdd+5位流水】

Loading…
Cancel
Save