存储数据

main
sunhao 2 weeks ago
parent 4907538eea
commit 7e353dd8a9

@ -129,6 +129,8 @@ public class SubController {
private static List<PmSlabSpecBtDO> plistPmSlabSpecBtDO;
//板坯信息表
private static List<PmPdSlabInfoDO> plistPmPdSlabInfoDO; //TODO 需要添加此表信息的查询
//合约信息
private static List<QdToPoOrderDO> plistQdToPoOrderDO; //TODO 需要添加此表信息的查询
//TODO 需要添加 QD_TO_PO_ORDER 的查询记录
private static Date now;
@ -275,7 +277,7 @@ public class SubController {
//region ***多线程获取基础数据***
// 创建线程池
ExecutorService executorService = Executors.newFixedThreadPool(29);
ExecutorService executorService = Executors.newFixedThreadPool(31);
//初始化方案
Loader.loadNativeLibraries();
@ -481,6 +483,18 @@ public class SubController {
return null;
});
//30板坯信息
tasks.add(() -> {
plistPmPdSlabInfoDO = subService.getPmPdSlabInfo();
return null;
});
//31合约信息
tasks.add(() -> {
plistQdToPoOrderDO = subService.getQdToPoOrder();
return null;
});
// 执行所有任务
try {
executorService.invokeAll(tasks);
@ -516,6 +530,8 @@ public class SubController {
logger.info("26:钢种配置信息:" + plistpmRetainStDO.size());
logger.info("27:仓库配置信息:" + plistpmRetainStackDO.size());
logger.info("28:自动组板配置信息:" + plistpmAutoSubSettingDO.size());
logger.info("29:板坯生产信息:" + plistPmPdSlabInfoDO.size());
logger.info("30:订单合约信息信息:" + plistQdToPoOrderDO.size());
logger.info("获取基础数据完成");
if (plistpmAutoSubSettingDO.size()>0)

@ -96,4 +96,8 @@ public interface SubMapper extends BaseMapper<Map> {
List<PmRetainStDO> getPmRetainSt();
List<PmRetainStackDO> getPmRetainStack();
List<PmPdSlabInfoDO> getPmPdSlabInfo();
List<QdToPoOrderDO> getQdToPoOrder();
}

@ -93,4 +93,8 @@ public interface SubService {
List<PmRetainStDO> getPmRetainSt();
List<PmRetainStackDO> getPmRetainStack();
List<PmPdSlabInfoDO> getPmPdSlabInfo();
List<QdToPoOrderDO> getQdToPoOrder();
}

@ -233,5 +233,15 @@ public class SubServiceImpl implements SubService {
return subMapper.getPmRetainStack();
}
@Override
public List<PmPdSlabInfoDO> getPmPdSlabInfo() {
return subMapper.getPmPdSlabInfo();
}
@Override
public List<QdToPoOrderDO> getQdToPoOrder() {
return subMapper.getQdToPoOrder();
}
}

@ -46,6 +46,31 @@
</select>
<select id="getPmPdSlabInfo" resultType="net.xdclass.shopmanager.model.PmPdSlabInfoDO">
SELECT DISTINCT PPSI.*
FROM XISC_MM.MM_SLAB MS --MM_SLAB 板坯表
LEFT JOIN PM_PD_SLAB PPS ON PPS.SLAB_NO = MS.SLAB_NO --PM_PD_SLAB 组板板坯表
LEFT JOIN PM_PD_SLAB_INFO PPSI ON PPSI.SLAB_NO = MS.SLAB_NO --PM_PD_SLAB 组板板坯表
LEFT JOIN PM_PD_CONST_BT PPCB ON PPCB.ROLL_LINE_NO = SUBSTR(MS.MSC_LINE_NO, 3, 2)
WHERE 1 = 1
AND MS.MSC_LINE_NO = '1030' --5米轧线
-- AND MS.SLAB_NO = 'C50015130500'
AND MS.SLAB_NO = 'C50015130100'
-- AND ((SELECT SUM(NVL(P1.NEED_SLAB_WT,0)) FROM PM_PD_SLAB P1 WHERE P1.SLAB_NO = MS.SLAB_NO)= MS.SLAB_ACT_WGT
-- OR (SELECT SUM(NVl(P1.NEED_SLAB_WT,0)) FROM PM_PD_SLAB P1 WHERE P1.SLAB_NO = MS.SLAB_NO) = 0)--重量相同
-- AND SUBSTR(MS.NEXT_WHOLE_BACKLOG_CODE,2,1) !='B' --全程工序代码第二位不能是B不嫩是火切工序
-- AND MS.SLAB_STATUS ='29' --在制余材
-- AND MS.COMPLEX_DECIDE_CODE !='4'--废品
-- AND SUBSTR(MS.SLAB_NO,1,1) NOT IN ('F','E') --复合/叠轧坯,不能组板
-- AND NVL(MS.PONO,' ')=' '
-- AND NVL(MS.ST_NO,' ')=' '
-- AND NVL(MS.SLAB_ACT_THK,0.001)>0.001
-- AND NVL(MS.SLAB_ACT_WID,0.001)>0.001
-- AND NVL(MS.SLAB_ACT_LEN,0.001)>0.001
-- AND (NVL(MS.SLAB_ACT_WGT,0.001)>0.001 OR NVL(MS.SLAB_GROSS_WGT,0.001)>0.001)
</select>
<select id="getOrderInfo" resultType="net.xdclass.shopmanager.model.PmProContDO">
SELECT ppc.* FROM PM_PRO_CONT ppc
@ -66,6 +91,27 @@
</select>
<select id="getQdToPoOrder" resultType="net.xdclass.shopmanager.model.QdToPoOrderDO">
SELECT QTPO.* FROM PM_PRO_CONT ppc
LEFT JOIN XISC_CT.CT_MAIN CM ON PPC.ORDER_NO = CM.ORDER_NO
LEFT JOIN XISC_QD.QD_TO_PO_ORDER QTPO ON QTPO.ORDER_NO = PPC.ORDER_NO
LEFT JOIN PM_PRO_CONT_PROD_ATTR ppcpa ON ppcpa.ORDER_NO = ppc.ORDER_NO
LEFT JOIN PM_CONT_MSC_TECH PCMT ON PCMT.ORDER_NO = ppc.ORDER_NO
AND ppc.PRO_CONT_ID = pcmt.PRO_CONT_ID
AND cm.MSC_LINE_NO = pcmt.MSC_LINE_NO --PM_PRO_CONT没有MSC_LINE_NO
WHERE 1=1
-- AND ppc.ORDER_NO='522484Q020'
<!-- AND PCMT.FUR_TYPE ='C' &#45;&#45;加热炉类型 C 没有注解C和S 都代表什么-->
<!-- AND cm.ORDER_STATUS >=40 AND cm.ORDER_STATUS <67-->
<!-- AND ppcpa.ORDER_TYPE_CODE <> 'QFH'-->
<!-- AND PPC.ON_PD_FLAG <>1 &#45;&#45;不用验证操作者-->
<!-- AND PPC.PD_LACK_QTY >0 &#45;&#45;欠量大于0-->
<!-- AND PPC.PD_HOLD_FLAG <>1 &#45;&#45; 不能封锁状态-->
<!-- AND pcmt.ROLL_DIRECT_CODE ='L'&#45;&#45;轧制方向代码-->
</select>
<!--生产合同产品属性表-->
<select id="getPmProCountProdAttr" resultType="net.xdclass.shopmanager.model.PmProContProdAttrDO">

@ -79,7 +79,7 @@ public class MyBatisPlusGenerator {
.setDriverName("oracle.jdbc.OracleDriver")
.setUrl("jdbc:oracle:thin:@172.18.15.50:1521/momdev")
.setUsername("xisc_pm")
.setUsername("xisc_qd")
.setPassword("HZERO1234");
@ -94,9 +94,9 @@ public class MyBatisPlusGenerator {
//使用lombok
.setEntityLombokModel(true)
//.setInclude("QE_TQ_HEATCHE_STAND_RESULT","QE_TQ_PONO_WAIT_TEST","QE_TQ_SLAB_MACRO_RESULT")
// .setInclude("QE_TQ_HEATCHE_STAND_RESULT","QE_TQ_PONO_WAIT_TEST","QE_TQ_SLAB_MACRO_RESULT")
.setInclude("PM_AUTO_SUB_SETTING")
.setInclude("QD_TO_PO_ORDER")
// 生成的表, 支持多表一起生成,以数组形式填写
//TODO TODO TODO TODO 两个方式,直接写,或者使用命令行输入

Loading…
Cancel
Save