#中间表对接

LSH

2023-01-03 4c2984960840cf1ceac0a1562029900ded0c14ac

#中间表对接

 src/main/java/com/zy/ints/task/scheduler/ErpDetTbScheduler.java

@@ -33,12 +33,12 @@
    @Scheduled(cron = "${erp.refreshtime}")
    public void InOrOutOrder() {
        if (!erpEnabled) return;
        String sqlSelecterpDetTb = "select bill_no as billNo,prd_no as prdNo,iokindid,add_id as addId,qty,prd_mark as prdMark,wh,billdate,status,temp1,temp2,temp3 from erp_det_tb where 1=1";
        String sqlUpDateerpDetTbOne = "update erp_det_tb set status=1 where prd_no=";
        String sqlUpDateerpDetTbTwo = "update erp_det_tb set status=2 where prd_no=";
        String sqlSelectErpDetTb = "select bill_no as billNo,prd_no as prdNo,iokindid,add_id as addId,qty,prd_mark as prdMark,wh,billdate,status,temp1,temp2,temp3 from erp_det_tb where 1=1";
        String sqlUpDateErpDetTbOne = "update erp_det_tb set status=1 where prd_no=";
        String sqlUpDateErpDetTbTwo = "update erp_det_tb set status=2 where prd_no=";

        try {
            List<ErpDetTb> erpDetTbs = erpSqlServer.select(sqlSelecterpDetTb, ErpDetTb.class);
            List<ErpDetTb> erpDetTbs = erpSqlServer.select(sqlSelectErpDetTb, ErpDetTb.class);
            if (erpDetTbs.size() > 0){
                for (ErpDetTb erpDetTb:erpDetTbs){
                    Integer status = erpDetTb.getStatus();

 src/main/java/com/zy/ints/task/scheduler/ErpLkScheduler.java

@@ -30,12 +30,12 @@
    @Scheduled(cron = "${erp.refreshtime}")
    public void InOrOutOrder() {
        if (!erpEnabled) return;
        String sqlSelecterpLk = "select prd_no as prdNo,prd_mark as prdMark,qty,wh,status,temp1,temp2,temp3 from bas_erp_lk where 1=1";
        String sqlUpDateerpLkOne = "update bas_erp_lk set status=1 where prd_no=";
        String sqlUpDateerpLkTwo = "update bas_erp_lk set status=2 where prd_no=";
        String sqlSelectErpLk = "select prd_no as prdNo,prd_mark as prdMark,qty,wh,status,temp1,temp2,temp3 from bas_erp_lk where 1=1";
        String sqlUpDateErpLkOne = "update bas_erp_lk set status=1 where prd_no=";
        String sqlUpDateErpLkTwo = "update bas_erp_lk set status=2 where prd_no=";

        try {
            List<ErpLk> erpLks = erpSqlServer.select(sqlSelecterpLk, ErpLk.class);
            List<ErpLk> erpLks = erpSqlServer.select(sqlSelectErpLk, ErpLk.class);
            if (erpLks.size() > 0){
                for (ErpLk erpLk:erpLks){
                    Integer status = erpLk.getStatus();

 src/main/java/com/zy/ints/task/scheduler/LkDetTbScheduler.java

@@ -30,12 +30,12 @@
    @Scheduled(cron = "${erp.refreshtime}")
    public void InOrOutOrder() {
        if (!erpEnabled) return;
        String sqlSelectlkDetTb = "select bill_no as billNo,prd_no as prdNo,iokindid,add_id as addId,qty,prd_mark as prdMark,wh,billdate,status,temp1,temp2,temp3 from lk_det_tb where 1=1";
        String sqlUpDatelkDetTbOne = "update lk_det_tb set status=1 where prd_no=";
        String sqlUpDatelkDetTbTwo = "update lk_det_tb set status=2 where prd_no=";
        String sqlSelectLkDetTb = "select bill_no as billNo,prd_no as prdNo,iokindid,add_id as addId,qty,prd_mark as prdMark,wh,billdate,status,temp1,temp2,temp3 from lk_det_tb where 1=1";
        String sqlUpDateLkDetTbOne = "update lk_det_tb set status=1 where prd_no=";
        String sqlUpDateLkDetTbTwo = "update lk_det_tb set status=2 where prd_no=";

        try {
            List<LkDetTb> lkDetTbs = erpSqlServer.select(sqlSelectlkDetTb, LkDetTb.class);
            List<LkDetTb> lkDetTbs = erpSqlServer.select(sqlSelectLkDetTb, LkDetTb.class);
            if (lkDetTbs.size() > 0){
                for (LkDetTb lkDetTb:lkDetTbs){
                    Integer status = lkDetTb.getStatus();