添加二次报工

cl

2024-09-06 252f60a80998f2b50e5864c5ce087fac9a8d9ff8

 jcdm-main/src/main/java/com/jcdm/main/plcserver/sub/OPCUaSubscription.java

@@ -109,11 +109,11 @@
            if (Constants.RECORD_DATA.equals(tab)) {  //出入站
                if (Constants.ONE.equals(valueString)) {//入站
                    if(Constants.OP040_OP160.contains(device)){//人工工位
                        Object snCodeObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".SNCode").getValue();
                        if (ObjectUtil.isNull(snCodeObjcet)){
                        Object snCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".SNCode").getValue();
                        if (ObjectUtil.isNull(snCodeObject)){
                            miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build());
                        }else{
                            String productNum = snCodeObjcet.toString().trim();
                            String productNum = snCodeObject.toString().trim();
                            if(productNum.length()<10){
                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(12).build());
                            }else{
@@ -145,14 +145,14 @@
                            WebSocketUsers.sendMessageToUserByText(map.get(device), "END");
                        } else{//自动工位
                            //先判断是否有产品SN
                            Object snCodeObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".SNCode").getValue();
                            Object snCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".SNCode").getValue();
                            Object orderObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".WorkOrderNumber").getValue();
                            if (ObjectUtil.isNull(snCodeObjcet)){
                            if (ObjectUtil.isNull(snCodeObject)){
                                miloService.writeToOpcShort(ReadWriteEntity.builder().identifier(thoroughfare + "." + device + ".RecordDataDone").value(25).build());
                            }else {

                                Integer result = 21;
                                String snCode = snCodeObjcet.toString().trim();//产品SN
                                String snCode = snCodeObject.toString().trim();//产品SN
                                String orderNumber = orderObjcet.toString().trim();//工单号
                                if(snCode.length()<10){
                                    result = 22;
@@ -167,11 +167,11 @@
                                    if (ObjectUtil.isNotNull(stationStatusObjcet)) {
                                        String stationStatus = stationStatusObjcet.toString();
                                        if (Constants.OP010.equals(device)) {
                                            Object housingCodeObjcet = miloService.readFromOpcUa(thoroughfare + "." + device + ".HousingCode").getValue();//壳体条码，存到工单，返修用
                                            if (ObjectUtil.isNull(housingCodeObjcet)){
                                            Object housingCodeObject = miloService.readFromOpcUa(thoroughfare + "." + device + ".HousingCode").getValue();//壳体条码，存到工单，返修用
                                            if (ObjectUtil.isNull(housingCodeObject)){
                                                result = 25;
                                            }else{
                                                String housingCode = housingCodeObjcet.toString();//壳体条码，存到工单，返修用
                                                String housingCode = housingCodeObject.toString();//壳体条码，存到工单，返修用
                                                if(housingCode.length()<10){
                                                    result = 25;
                                                }else{
@@ -397,7 +397,7 @@
                JSONObject dataObject = jsonObject.getJSONObject("data");
                String code = jsonObject.getStr("code");
                // 判断接单是否成功
                if(code.equals("success")) {
                if("success".equals(code)) {
                    OmProductionOrdeInfo omProductionOrdeInfo = new OmProductionOrdeInfo();
                    omProductionOrdeInfo.setWorkOrderNo(dataObject.getStr("productionOrderNum"));
                    omProductionOrdeInfo.setProductNum(dataObject.getStr("productNum"));
@@ -460,27 +460,30 @@
     * 工厂MES报工
     * @param productNum  通道
     * @param stationCode 工位
     * @param confirmTime 物料号
     * @param confirmTime 时间
     * @throws Exception e
     */
    //{"code":"success","data":{"productNum":"LCV123456P0600036","stationCode":"1HZ01","resultCode":"S","resultText":"报工成功"},"message":"API调用成功"}
    public static void reportFactoryMes(String productNum, String stationCode, String confirmTime)
    public static void reportFactoryMes(String productNum,String stationCode,String confirmTime)
    {
        String result = "";
        String url = Constants.FACTORY_EMS_UAT_GET_RUL + "workReportResultFeedback?siteCode="+Constants.FACTORY_EMS_SITE_CODE+"&stationCode="+stationCode+"&productNum="+productNum+"&confirmTime="+confirmTime;
        try {
            CompletableFuture<Void> cp1 = CompletableFuture.runAsync(() -> {
                log.info("请求工厂MES报工：入参device{},productNum：{}", stationCode, productNum);
                String url = Constants.FACTORY_EMS_UAT_GET_RUL + "workReportResultFeedback?siteCode="+Constants.FACTORY_EMS_SITE_CODE+"&stationCode="+stationCode+"&productNum="+productNum+"&confirmTime="+confirmTime;
                HttpResponse response = HttpRequest.get(url).execute();
                /*HttpRequest httpRequest = HttpRequest.get(url);*/
                String result =  response.body();
                log.info("请求工厂MES报工：出参：{}", result);
            });

            log.info("执行工厂MES报工方法start，序列号{}工位号{}url{}",productNum,stationCode ,url);
            HttpResponse response = HttpRequest.get(url).execute();
            //HttpRequest httpRequest = HttpRequest.get(url);
            result =  response.body();
            log.info("执行工厂MES报工方法第一次end，序列号{}工位号{}返回数据{}",productNum,stationCode ,result);
        }catch (Exception e){
            throw new RuntimeException(e);
        }finally {
            if(result.isEmpty()){
                HttpResponse response = HttpRequest.get(url).execute();
                result =  response.body();
                log.info("执行工厂MES报工方法第二次end，序列号{}工位号{}返回数据{}",productNum,stationCode ,result);
            }
        }
    }

    public static String TightenTheConversionOkNg(String param){
        // 去除首尾的方括号，然后按照逗号分割字符串
        String[] parts = param.substring(1, param.length() - 1).split(",");