春风项目四线(合箱线、总装线)
wujian
2024-10-25 9906e6b188bf2c36dddc0d5adadbf02e69ea3e4b
jcdm-quartz/src/main/java/com/jcdm/quartz/task/RyTask.java
@@ -114,7 +114,7 @@
        if (CollUtil.isNotEmpty(bsOrderSchedulings)){
            BsOrderScheduling orderScheduling = bsOrderSchedulings.get(0);
            try {
                String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0010"));
                String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(),orderScheduling.getEngineNo(), "0010"));
                ev_meassage=ReceivingServices.xmlToJSON1(xmlResult);
                status = ReceivingServices.xmlToJSON3(xmlResult);
            } catch (Exception e) {
@@ -124,6 +124,7 @@
                orderScheduling.setReport10("1");
                int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling);
                logger.info("{}合箱报工成功",orderScheduling.getOrderNo());
                orderScheduling.setRemarks("合箱报工成功");
            }else {
                if(StringUtils.isEmpty(orderScheduling.getSpareField1())){
                    orderScheduling.setSpareField1("1");
@@ -136,12 +137,16 @@
                    }else {
                        orderScheduling.setSpareField1(String.valueOf(Integer.valueOf(orderScheduling.getSpareField1()) + 1));
                    }
                    if(status.equals("3")){
                        orderScheduling.setRemarks("合箱报工因为网络原因,报工失败");
                        logger.info("{}合箱报工因为网络原因,报工失败!",orderScheduling.getOrderNo());
                    } else{
                        orderScheduling.setRemarks("合箱报工失败"+ev_meassage);
                        logger.info("{}合箱报工失败,原因:{}",orderScheduling.getOrderNo(),ev_meassage);
                    }
                    bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling);
                }
                if(status.equals("3"))
                    logger.info("{}合箱报工因为网络原因,报工失败!",orderScheduling.getOrderNo());
                else
                    logger.info("{}合箱报工失败,原因:{}",orderScheduling.getOrderNo(),ev_meassage);
            }
        }
    }
@@ -155,7 +160,7 @@
        if (CollUtil.isNotEmpty(bsOrderSchedulings)){
            BsOrderScheduling orderScheduling = bsOrderSchedulings.get(0);
            try {
                String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), "0020"));
                String xmlResult = ReceivingServices.getInterfaceInformationXml(url, getProductionPlanInformationXml(orderScheduling.getOrderNo(), orderScheduling.getEngineNo(),"0020"));
                ev_meassage=ReceivingServices.xmlToJSON1(xmlResult);
                status = ReceivingServices.xmlToJSON3(xmlResult);
            } catch (Exception e) {
@@ -165,6 +170,7 @@
                orderScheduling.setReport20("1");
                int i = bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling);
                logger.info("{}总装报工成功",orderScheduling.getOrderNo());
                orderScheduling.setRemarks("总装报工成功");
            }else {
                if(StringUtils.isEmpty(orderScheduling.getSpareField2())){
                    orderScheduling.setSpareField2("1");
@@ -177,11 +183,14 @@
                    }else{
                        orderScheduling.setSpareField2(String.valueOf(Integer.valueOf(orderScheduling.getSpareField2()) + 1));
                    }
                    bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling);
                    if(status.equals("3"))
                    if(status.equals("3")){
                        logger.info("{}总装报工因为网络原因,报工失败!",orderScheduling.getOrderNo());
                    else
                        orderScheduling.setRemarks("总装报工因为网络原因,报工失败");
                    } else{
                        logger.info("{}总装报工失败,原因:{}",orderScheduling.getOrderNo(),ev_meassage);
                        orderScheduling.setRemarks("总装报工失败,"+ev_meassage);
                    }
                    bsOrderSchedulingService.updateBsOrderScheduling(orderScheduling);
                }
            }
        }
@@ -244,17 +253,18 @@
                    //更新
                    //判断是否需要更新
                    ProductNumTable productNumTable = collect1.get(0);
                    Integer hxOnlineNum = productNumTable.getHxOnlineNum();
                    Integer zzOnlineNum = productNumTable.getZzOnlineNum();
                    Integer zzOfflineNum = productNumTable.getZzOfflineNum();
                    if (!hxOnlineNum.equals((int)count1) || !zzOnlineNum.equals((int) count2) || !zzOfflineNum.equals((int)count3)){
                        //更新
                        productNumTable.setHxOnlineNum((int) count1);
                        productNumTable.setZzOnlineNum((int) count2);
                        productNumTable.setZzOfflineNum((int) count3);
                        productNumTable.setProductNumTheory(productNumTheory);
                        productNumTableService.updateProductNum(productNumTable);
                    }
//                    Integer hxOnlineNum = productNumTable.getHxOnlineNum();
//                    Integer zzOnlineNum = productNumTable.getZzOnlineNum();
//                    Integer zzOfflineNum = productNumTable.getZzOfflineNum();
//                    if (!hxOnlineNum.equals((int)count1) || !zzOnlineNum.equals((int) count2) || !zzOfflineNum.equals((int)count3)){
//
//                    }
                    //更新
                    productNumTable.setHxOnlineNum((int) count1);
                    productNumTable.setZzOnlineNum((int) count2);
                    productNumTable.setZzOfflineNum((int) count3);
                    productNumTable.setProductNumTheory(productNumTheory);
                    productNumTableService.updateProductNum(productNumTable);
                }
            }
            if (CollUtil.isNotEmpty(saveDate)){
@@ -377,13 +387,14 @@
        return productNumTheory;
    }
    public static String getProductionPlanInformationXml(String orderNo,String location){
    public static String getProductionPlanInformationXml(String orderNo,String engineNo,String location){
        String content = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:urn=\"urn:sap-com:document:sap:rfc:functions\">\n" +
                "   <soapenv:Header/>\n" +
                "   <soapenv:Body>\n" +
                "      <urn:ZPP_BC_001>\n" +
                "         <IV_AUFNR>"+orderNo+"</IV_AUFNR>\n" +
                "          <IV_VORNR>"+location+"</IV_VORNR>\n" +
                "          <IV_ZFDJM>"+engineNo+"</IV_ZFDJM>\n" +
                "           <IV_LMNGA>1</IV_LMNGA>\n" +
                "           <IV_XMNGA>0</IV_XMNGA>   \n" +
                "         <IV_STATU>1</IV_STATU>  \n" +