jiaxin.lin
/
i3plus-mes-yfai
forked from I3-YF/i3plus-mes-yfai
1
0
Fork 0
Code Pull Requests Activity

新增看板

Browse Source
uat-temp-nht-2503040000-seres
jason 2 months ago
parent 6f292e8842
commit fe6ba8e8cf
2 changed files with 22 additions and 8 deletions
Show Stats Download Patch File Download Diff File

28
modules/i3plus-ext-mes-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/apiservice/serviceimpl/report/MesCimSeresReportServiceImpl.java
Unescape Escape View File

@ -1,7 +1,9 @@
package cn.estsh.i3plus.ext.mes.apiservice.serviceimpl.report; package cn.estsh.i3plus.ext.mes.apiservice.serviceimpl.report;
import cn.estsh.i3plus.ext.mes.api.base.IMesConfigService;
import cn.estsh.i3plus.ext.mes.api.busi.report.IMesCimSeresReportService; import cn.estsh.i3plus.ext.mes.api.busi.report.IMesCimSeresReportService;
import cn.estsh.i3plus.ext.mes.pojo.model.MesDefectRecordModel; import cn.estsh.i3plus.ext.mes.apiservice.utils.MesException;
import cn.estsh.i3plus.ext.mes.pojo.util.MesExtConstWords;
import cn.estsh.i3plus.platform.common.tool.TimeTool; import cn.estsh.i3plus.platform.common.tool.TimeTool;
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.bean.ListPager;
@ -9,10 +11,14 @@ import cn.estsh.i3plus.pojo.base.common.Pager;
import cn.estsh.i3plus.pojo.base.common.PagerHelper; 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.MesConfig;
import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresJisQueue; import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresJisQueue;
import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresJisVinOverPoint; import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresJisVinOverPoint;
import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresSrmRunSheetJis; import cn.estsh.i3plus.pojo.mes.bean.seres.MesCimSeresSrmRunSheetJis;
import cn.estsh.i3plus.pojo.mes.model.report.*; import cn.estsh.i3plus.pojo.mes.model.report.DataTwoDimensionalModel;
import cn.estsh.i3plus.pojo.mes.model.report.MesCimSeresJisQueueRequest;
import cn.estsh.i3plus.pojo.mes.model.report.MesCimSeresJisQueueSummaryRequest;
import cn.estsh.i3plus.pojo.mes.model.report.MesCimSeresJisQueueSummaryResponse;
import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresJisQueueRepository; import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresJisQueueRepository;
import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresJisVinOverPointRepository; import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresJisVinOverPointRepository;
import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresSrmRunSheetJisRepository; import cn.estsh.i3plus.pojo.mes.repository.seres.IMesCimSeresSrmRunSheetJisRepository;
@ -37,6 +43,8 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
private IMesCimSeresJisQueueRepository queueJisRDao; private IMesCimSeresJisQueueRepository queueJisRDao;
@Autowired @Autowired
private IMesCimSeresJisVinOverPointRepository overPointJisRDao; private IMesCimSeresJisVinOverPointRepository overPointJisRDao;
@Autowired
private IMesConfigService mesConfigService;
@Override @Override
public ListPager<MesCimSeresSrmRunSheetJis> querySrmSunSheetJisLogByPager(Integer status, Pager pager) { public ListPager<MesCimSeresSrmRunSheetJis> querySrmSunSheetJisLogByPager(Integer status, Pager pager) {
@ -56,7 +64,7 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
DdlPackBean packBean = DdlPackBean.getDdlPackBean(organizeCode); DdlPackBean packBean = DdlPackBean.getDdlPackBean(organizeCode);
DdlPreparedPack.getInPackList(ids, "id", packBean); DdlPreparedPack.getInPackList(ids, "id", packBean);
runSheetJisRDao.updateByProperties(new String[]{"status","modifyUser","modifyDatetime"},new Object[]{MesExtEnumUtil.CIM_SERES_JIS_STATUS.WAIT_CHECK, username, TimeTool.getNowTime(true)}, packBean); runSheetJisRDao.updateByProperties(new String[]{"status","modifyUser","modifyDatetime"},new Object[]{MesExtEnumUtil.CIM_SERES_JIS_STATUS.WAIT_CHECK.getValue(), username, TimeTool.getNowTime(true)}, packBean);
} }
@Override @Override
@ -77,7 +85,7 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
DdlPackBean packBean = DdlPackBean.getDdlPackBean(organizeCode); DdlPackBean packBean = DdlPackBean.getDdlPackBean(organizeCode);
DdlPreparedPack.getInPackList(ids, "id", packBean); DdlPreparedPack.getInPackList(ids, "id", packBean);
queueJisRDao.updateByProperties(new String[]{"checkStatus","modifyUser","modifyDatetime"},new Object[]{MesExtEnumUtil.CIM_SERES_JIS_STATUS.WAIT_CHECK, username, TimeTool.getNowTime(true)}, packBean); queueJisRDao.updateByProperties(new String[]{"checkStatus","modifyUser","modifyDatetime"},new Object[]{MesExtEnumUtil.CIM_SERES_JIS_STATUS.WAIT_CHECK.getValue(), username, TimeTool.getNowTime(true)}, packBean);
} }
@Override @Override
@ -251,6 +259,10 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
@Override @Override
public ListPager<DataTwoDimensionalModel> queryTwoDimensionalByPager(DataTwoDimensionalModel request, Pager pager) { public ListPager<DataTwoDimensionalModel> queryTwoDimensionalByPager(DataTwoDimensionalModel request, Pager pager) {
final String organizeCode = AuthUtil.getOrganize().getOrganizeCode(); final String organizeCode = AuthUtil.getOrganize().getOrganizeCode();
MesConfig shippingGroupConfig = mesConfigService.getCfgValueByCode(organizeCode, MesExtConstWords.TWO_DIMENSIONAL_SHIPPING_GROUP_CODE);
if (shippingGroupConfig == null || StringUtils.isEmpty(shippingGroupConfig.getCfgValue())){
MesException.throwMesBusiException("未维护赛力斯数据二维表发运组编码【TWO_DIMENSIONAL_SHIPPING_GROUP_CODE】");
}
StringBuilder hql = new StringBuilder(); StringBuilder hql = new StringBuilder();
hql.append(" from mes_cim_seres_jis_rfid AA join ("); hql.append(" from mes_cim_seres_jis_rfid AA join (");
@ -270,14 +282,14 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
StringBuilder countQueryHql= new StringBuilder(); StringBuilder countQueryHql= new StringBuilder();
countQueryHql.append("select count(1) "); countQueryHql.append("select count(1) ");
Query countQuery = entityManager.createNativeQuery(countQueryHql.append(hql).toString()); Query countQuery = entityManager.createNativeQuery(countQueryHql.append(hql).toString());
packTwoDimensional(countQuery, request, organizeCode); packTwoDimensional(countQuery, request, shippingGroupConfig.getCfgValue(), organizeCode);
//本次查询满足条件的总数 //本次查询满足条件的总数
int count = Integer.parseInt(String.valueOf(countQuery.getSingleResult())); int count = Integer.parseInt(String.valueOf(countQuery.getSingleResult()));
StringBuilder dataQueryHql = new StringBuilder(); StringBuilder dataQueryHql = new StringBuilder();
dataQueryHql.append(" select BB.shipping_code, BB.cust_info_seq, BB.vin, csn, CONCAT(LEFT(rfid,114), UPPER('326312JSG1DJ05')) as rfid, AA.create_date_time"); dataQueryHql.append(" select BB.shipping_code, BB.cust_info_seq, BB.vin, csn, CONCAT(LEFT(rfid,114), UPPER('326312JSG1DJ05')) as rfid, AA.create_date_time");
Query dataQuery = entityManager.createNativeQuery(dataQueryHql.append(hql).toString()); Query dataQuery = entityManager.createNativeQuery(dataQueryHql.append(hql).toString());
packTwoDimensional(dataQuery, request, organizeCode); packTwoDimensional(dataQuery, request, shippingGroupConfig.getCfgValue(), organizeCode);
pager = PagerHelper.getPager(pager, count); pager = PagerHelper.getPager(pager, count);
//查询本页数据 //查询本页数据
@ -306,11 +318,11 @@ public class MesCimSeresReportServiceImpl implements IMesCimSeresReportService {
return new ListPager<>(modelList, pager); return new ListPager<>(modelList, pager);
} }
private void packTwoDimensional(Query query, DataTwoDimensionalModel request, String organizeCode) { private void packTwoDimensional(Query query, DataTwoDimensionalModel request, String shippingGroupCode, String organizeCode) {
query.setParameter("organizeCode", organizeCode) query.setParameter("organizeCode", organizeCode)
.setParameter("isValid", CommonEnumUtil.VALID) .setParameter("isValid", CommonEnumUtil.VALID)
.setParameter("isDeleted", CommonEnumUtil.FALSE); .setParameter("isDeleted", CommonEnumUtil.FALSE);
query.setParameter("shippingGroupCode", request.getShippingGroupCode()); query.setParameter("shippingGroupCode", shippingGroupCode);
if (!StringUtils.isEmpty(request.getShippingCode())){ if (!StringUtils.isEmpty(request.getShippingCode())){
query.setParameter("shippingCode", request.getShippingCode()); query.setParameter("shippingCode", request.getShippingCode());
} }

2
modules/i3plus-ext-mes-pojo/src/main/java/cn/estsh/i3plus/ext/mes/pojo/util/MesExtConstWords.java
Unescape Escape View File

@ -455,4 +455,6 @@ public class MesExtConstWords {
//排序线不能做报工调整ESD属性类型 //排序线不能做报工调整ESD属性类型
public static final String NOT_ALLOW_WRITE_OFF = "NOT_ALLOW_WRITE_OFF"; public static final String NOT_ALLOW_WRITE_OFF = "NOT_ALLOW_WRITE_OFF";
//赛力斯数据二维表发运组编码
public static final String TWO_DIMENSIONAL_SHIPPING_GROUP_CODE = "TWO_DIMENSIONAL_SHIPPING_GROUP_CODE";
} }

Write Preview
Loading…
Cancel
Save