OP080A-cmt/src/com/mes/ui/DataUtil.java

package com.mes.ui;

import com.alibaba.fastjson2.JSONObject;
import com.mes.netty.NettyClient;
import com.mes.util.DateLocalUtils;
import com.mes.util.JdbcUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.*;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.Properties;

public class DataUtil {
    public static final Logger log = LoggerFactory.getLogger(DataUtil.class);
    public static Boolean synrTcp(NettyClient nettyClient,String mes_gw){
        try{
            //TCP连接后，直接先发同步报文
            String start = "aaaabbbbbABW";
            String msgType = "SYNR";
            String gw = "GW"+DataUtil.rightPad(mes_gw, 6);
            String da = "DA" + DateLocalUtils.getCurrentDate();
            String zt = "ZT" + DateLocalUtils.getCurrentTimeHMS();
            String synr_str = start + msgType + gw + da + zt;
            //插入报文本地数据
            String gy = "";
            String sn = "";
            JdbcUtils.insertData(gw, gy, synr_str, msgType, sn);

            nettyClient.run(synr_str);

            return true;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean heartBeat(NettyClient nettyClient,String mes_gw){
        try{
            //TCP连接后，直接先发同步报文
            String start = "aaaabbbbbABW";
            String msgType = "AXTW";
            String gw = "GW"+DataUtil.rightPad(mes_gw, 6);
            String da = "DA" + DateLocalUtils.getCurrentDate();
            String zt = "ZT" + DateLocalUtils.getCurrentTimeHMS();
            String axtw_str = start + msgType + gw + da + zt;
            //插入报文本地数据
            String gy = "";
            String sn = "";
            JdbcUtils.insertData(gw, gy, axtw_str, msgType, sn);
            nettyClient.future.channel().writeAndFlush(axtw_str);

            return true;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean checkQuality(NettyClient nettyClient, String sn, String user,String op){
        try{
            String msgType = "AQDW";
            String gy = "100000";
            Boolean aqdw_str = sendMessage(nettyClient,msgType,gy,"",sn,"",user,"00","",op);
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean startWork(NettyClient nettyClient,String sn,String user,String op){
        try{
            String msgType = "MKSW";
            String gy = "";
            Boolean aqdw_str = sendMessage(nettyClient,msgType,gy,"",sn,"",user,"00","",op);
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean bindUser(NettyClient nettyClient,String sn,String user){
        try{
            String msgType = "MBDW";
            String gy = "400001";
            String param = rightPad(user, 36);
            Boolean aqdw_str = sendMessage(nettyClient,msgType,gy,"",sn,"",user,"01",param,"");
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean bindWarehouse(NettyClient nettyClient,String sn,String wsn,String user,String craft){
        try{
            String msgType = "MBDW";
            String param = rightPad(wsn, 36);
            Boolean aqdw_str = sendMessage(nettyClient,msgType,craft,"",sn,"",user,"01",param,"");
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean unBindWarehouse(NettyClient nettyClient,String sn,String wsn,String user,String craft){
        try{
            String msgType = "MJBW";
            String param = rightPad(wsn, 36);
            Boolean aqdw_str = sendMessage(nettyClient,msgType,craft,"",sn,"",user,"01",param,"");
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

    public static Boolean sendQuality(NettyClient nettyClient,String sn,String ret,String user,String op){
//        return false;
        try{
            String msgType = "MQDW";
            String gy = "100000";
            String param = "";
            Boolean aqdw_str = sendMessage(nettyClient,msgType,gy,"",sn,ret,user,"00",param,op);
            return aqdw_str;
        }catch (Exception e){
            return false;
        }
    }

//    public static Boolean sendQuality(String sn,String result,String user,String op){
//        try{
//            String msgType = "MQDW";
//            String craft = "100000";
//            String lx = "";
//            String paramNums = "00";
//            String params = "";
//
//            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
//            Properties pro = new Properties();
//            BufferedReader br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
//            pro.load(br);
//            String gw = "GW"+rightPad(pro.getProperty("mes.gw")+op, 6);
//            String start = "aaaabbbbbABW";
//            String gy = "GY" + rightPad(craft, 6);
//            String reslx = "LX" + rightPad(lx, 2);
//            String id = pro.getProperty("mes.line_sn") + rightPad(sn, 36);
//            String rs = "RS"+ rightPad(result, 2);
//            String da = "DA" + DateLocalUtils.getCurrentDate();
//            String zt = "ZT" + DateLocalUtils.getCurrentTimeHMS();
//            String yh = "YH" + rightPad(user, 20);
//            String aqdw_str = start + msgType + gw + gy + reslx + id + rs + da + zt + yh + paramNums + params;
//            JdbcUtils.insertData(gw, gy, aqdw_str, msgType, sn);
//            JdbcUtils.insertSubmitRecord(gw, sn, aqdw_str);
//            return true;
//        }catch (Exception e){
//            return false;
//        }
//    }

    /**
     * 按工位标识映射上传工位号：
     * gwflag=A：A面->OP080A，B面->OP080B
     * gwflag=B：A面->OP080C，B面->OP080D
     */
    public static String buildGwOprno(String mesGw, String sideOp){
        String gw = mesGw == null ? "" : mesGw.trim();
        String op = sideOp == null ? "" : sideOp;
        if("B".equals(MesClient.mes_gwflag)){
            if("A".equals(op)){
                op = "C";
            }else if("B".equals(op)){
                op = "D";
            }
        }
        return rightPad(gw + op, 6);
    }

    public static Boolean sendMessage(NettyClient nettyClient,String msgType,String craft,String lx,String sn,String result,String user,String paramNums,String params,String op){
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);

            // 080A机：AB面上传OP080A/OP080B；080B机：AB面上传OP080C/OP080D
            if(MesClient.mes_gwflag != null && MesClient.mes_gwflag.equals("B")){
                if(op.equals("A")){
                    op = "C";
                }else if(op.equals("B")){
                    op = "D";
                }
            }

            String gw = "GW"+rightPad(pro.getProperty("mes.gw")+op, 6);
            String start = "aaaabbbbbABW";
            String gy = "GY" + rightPad(craft, 6);
            String reslx = "LX" + rightPad(lx, 2);
            String id = pro.getProperty("mes.line_sn") + rightPad(sn, 36);
            String rs = "RS"+ rightPad(result, 2);
            String da = "DA" + DateLocalUtils.getCurrentDate();
            String zt = "ZT" + DateLocalUtils.getCurrentTimeHMS();
            String yh = "YH" + rightPad(user, 20);
            String aqdw_str = start + msgType + gw + gy + reslx + id + rs + da + zt + yh + paramNums + params;
            System.out.println("message="+aqdw_str);
            JdbcUtils.insertData(gw, gy, aqdw_str, msgType, sn);
            log.info("SEND:"+aqdw_str);
            nettyClient.future.channel().writeAndFlush(aqdw_str);
            return true;
        }catch (Exception e){
            return false;
        }
    }

    public static String rightPad(final String str, final int size) {
        if (str == null) {
            return null;
        }

        String strret = str;
        if(str.length() > size){
            strret = str.substring(0,size);
        }
        return String.format("%-"+size+"s", strret);
    }

    public static JSONObject upParams(String upparams) {
        try{
            String enconding = "UTF-8";    //涓嶇windows杩樻槸linux閮芥槸UTF-8
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            //閬垮厤涓枃涔辩爜
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesProductCmt/batchsave";
            String params = "__ajax=json&params="+upparams;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }

    public static JSONObject getBindMaterail() {
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String lineSn = pro.getProperty("mes.line_sn").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesLineProcessMaterial/materials";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }

    public static JSONObject saveBindMaterail(String batchSn,String craft,String materialId,String type) {
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String lineSn = pro.getProperty("mes.line_sn").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesMaterialPrebind/bind";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&batchSn="+batchSn+"&craft="+craft+"&materialId="+materialId+"&type="+type;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }

    public static JSONObject saveGzCheck(String content,String userCode) {
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String lineSn = pro.getProperty("mes.line_sn").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesProcessCheckGz/submit";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&createBy="+userCode;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }

    public static String doPost(String httpUrl, String param) {
        HttpURLConnection connection = null;
        InputStream is = null;
        OutputStream os = null;
        BufferedReader br = null;
        String result = null;
        try {
            URL url = new URL(httpUrl);
            connection = (HttpURLConnection) url.openConnection();
            connection.setRequestMethod("POST");
            connection.setConnectTimeout(15000);
            connection.setReadTimeout(60000);
            connection.setDoOutput(true);
            connection.setDoInput(true);
            connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
            connection.setRequestProperty("Authorization", "Bearer da3efcbf-0845-4fe3-8aba-ee040be542c0");
            os = connection.getOutputStream();
            os.write(param.getBytes());
            if (connection.getResponseCode() == 200) {
                is = connection.getInputStream();
                br = new BufferedReader(new InputStreamReader(is, "UTF-8"));
                StringBuffer sbf = new StringBuffer();
                String temp = null;
                while ((temp = br.readLine()) != null) {
                    sbf.append(temp);
                    sbf.append("\r\n");
                }
                result = sbf.toString();
            }
        } catch (MalformedURLException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (null != br) {
                try {
                    br.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != os) {
                try {
                    os.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            if (null != is) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
            connection.disconnect();
        }
        return result;
    }

    public static JSONObject bindWarehouseData(String sn,String wsn,String userCode,String craft){
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String lineSn = pro.getProperty("mes.line_sn").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesProductRecord/bindWarehouse";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&ucode="+userCode+"&sn="+sn+"&wsn="+wsn+"&craft="+craft;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }

    /**
     * HTTP绑定压铸件二维码到工艺号400002的materiel_sn（同步等待返回）
     */
    public static JSONObject bindYzjHttp(String sn, String materielSn, String user, String craft){
        try{
            String mes_server_ip = MesClient.mes_server_ip;
            String oprno = MesClient.mes_gw == null ? "" : MesClient.mes_gw.trim();
            String lineSn = MesClient.mes_line_sn == null ? "" : MesClient.mes_line_sn.trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesProductRecord/bindYzj";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&sn="+sn+"&result=OK&ucode="+user
                    + "&craft="+craft+"&wsn="+materielSn;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result == null || result.trim().isEmpty() || result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            e.printStackTrace();
            return null;
        }
    }

    public static JSONObject unBindWarehouseData(String sn,String wsn,String userCode,String craft){
        try{
            String enconding = "UTF-8";
            InputStream is = ClassLoader.getSystemResourceAsStream("config/config.properties");
            Properties pro = new Properties();
            BufferedReader br = new BufferedReader(new InputStreamReader(is, enconding));
            pro.load(br);
            String mes_server_ip = pro.getProperty("mes.server_ip");
            String oprno = pro.getProperty("mes.gw").trim();
            String lineSn = pro.getProperty("mes.line_sn").trim();
            String url = "http://"+mes_server_ip+":8980/js/a/mes/mesProductRecord/unBindWarehouse";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&ucode="+userCode+"&sn="+sn+"&wsn="+wsn+"&craft="+craft;
            System.out.println("params="+params);
            String result = doPost(url,params);
            System.out.println("result="+result);

            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            return null;
        }
    }
}