mesclient-Workstation1/src/com/mes/ui/DataUtil.java

package com.mes.ui;

import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
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.net.URLEncoder;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

public class DataUtil {
    public static final Logger log = LoggerFactory.getLogger(DataUtil.class);

    //删除当前工位工件码
    public static JSONObject delCurSn(String oprno,String serverIp,String lineSn){
        try {
            String url = "http://"+serverIp+":8980/js/a/mes/mesProductRecord/cancelCurSn";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&__sid="+MesClient.sessionid;
            JSONObject result = JSONObject.parseObject(doPost(url, params));
//            log.info("请求参数："+params);
            return result;
        } catch (Exception e) {
            log.info("e="+e.getMessage());
            return null;
        }
    }

    //获取当前工位工件码
    public static JSONObject getCurSn(String oprno,String serverIp,String lineSn){
        try {
            String url = "http://"+serverIp+":8980/js/a/mes/mesProductRecord/getCurSn";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&__sid="+MesClient.sessionid;
            JSONObject result = JSONObject.parseObject(doPost(url, params));
//            log.info("请求参数："+params);
            return result;
        } catch (Exception e) {
            log.info("e="+e.getMessage());
            return null;
        }
    }

    public static JSONObject checkQuality(String sn, String user){
        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();
            return checkQuality(sn, user, oprno, lineSn, mes_server_ip);
        }catch (Exception e){
            log.info("e="+e.getMessage());
            return null;
        }
    }

    public static JSONObject checkQuality(String sn, String user, String oprno, String lineSn, String serverIp){
        try{
            String url = "http://"+serverIp+":8980/js/a/mes/mesProductRecord/pccheck";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&sn="+sn+"&ucode="+user+"&__sid="+MesClient.sessionid;
            log.info("params="+params);
            String result = doPost(url,params);
            log.info("result="+result);
            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                JdbcUtils.insertData(oprno, "100000", params, "AQDW", sn);
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            log.info("e="+e.getMessage());
            return null;
        }
    }

    public static JSONObject sendQuality(String sn,String ret,String user){
        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();
            return sendQuality(sn, ret, user, oprno, lineSn, mes_server_ip);
        }catch (Exception e){
            log.info("e="+e.getMessage());
            return null;
        }
    }

    public static JSONObject sendQuality(String sn, String ret, String user, String oprno, String lineSn, String serverIp){
        try{
            String url = "http://"+serverIp+":8980/js/a/mes/mesProductRecord/pcresult";
            String params = "__ajax=json&oprno="+oprno+"&lineSn="+lineSn+"&sn="+sn+"&result="+ret+"&ucode="+user+"&__sid="+MesClient.sessionid;
            log.info("params="+params);
            String result = doPost(url,params);
            log.info("result="+result);
            System.out.println("请求参数"+params);
            if(result.equalsIgnoreCase("false")) {
                return null;
            }else {
                JdbcUtils.insertData(oprno, "100000", params, "MQDW", sn);
                return JSONObject.parseObject(result);
            }
        }catch (Exception e){
            log.info("e="+e.getMessage());
            return null;
        }
    }

    // 保存 PLC 读取到的点焊/焊接参数，复用后端 mesProductArcWelding/batchsave 接口。
    public static JSONObject saveWeldingParams(String sn, String oprno, String lineSn, String serverIp, String content) {
        try {
            if (content == null || content.trim().isEmpty()) {
                log.info("焊接参数为空，不上传，工位=" + oprno + "，工件码=" + sn);
                return null;
            }

            String url = "http://" + serverIp + ":8980/js/a/mes/mesProductArcWelding/batchsave";
            JSONArray paramsArray = new JSONArray();
            JSONObject item = new JSONObject();
            item.put("sn", sn);
            item.put("oprno", oprno);
            item.put("lineSn", lineSn);
            item.put("content", content);
            paramsArray.add(item);

            String params = "__ajax=json&__sid=" + urlEncode(MesClient.sessionid)
                    + "&params=" + urlEncode(paramsArray.toJSONString());
            log.info("上传焊接参数：" + paramsArray.toJSONString());
            String result = doPost(url, params);
            log.info("上传焊接参数结果：" + result);
            if (result == null || result.equalsIgnoreCase("false")) {
                return null;
            }
            return JSONObject.parseObject(result);
        } catch (Exception e) {
            log.info("上传焊接参数异常：" + e.getMessage());
            return null;
        }
    }

    private static String urlEncode(String value) throws UnsupportedEncodingException {
        return URLEncoder.encode(value == null ? "" : value, "UTF-8");
    }

    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 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 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;
    }

    /**
     * 查询工作记录
     * @param oprno 工位号（空则查所有工位）
     * @param sn 工件码（可选，用于搜索）
     * @param pageNo 页码
     * @param pageSize 每页条数
     * @return 工作记录响应
     */
    public static WorkRecordResp getWorkRecordList(String oprno, String sn, int pageNo, int pageSize) {
        WorkRecordResp resp = new WorkRecordResp();
        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 lineSn = pro.getProperty("mes.line_sn").trim();
            
            String url = "http://" + mes_server_ip + ":8980/js/a/mes/mesProductRecord/ ";
            StringBuilder params = new StringBuilder();
            params.append("__ajax=json");
            params.append("&lineSn=").append(lineSn);
            params.append("&pageNo=").append(pageNo);
            params.append("&pageSize=").append(pageSize);
            
            if (oprno != null && !oprno.isEmpty()) {
                params.append("&oprno=").append(oprno);
            }
            // 注意：不传auto参数，这样"所有工位"查询时会返回整条产线所有工位的数据
            if (sn != null && !sn.isEmpty()) {
                params.append("&sn=").append(sn);
            }
            
            log.info("查询工作记录: url=" + url + ", params=" + params.toString());
            String result = doPost(url, params.toString());
            log.info("查询工作记录结果: result=" + result);
            
            if (result == null || result.trim().isEmpty()) {
                resp.setResult(false);
                resp.setMessage("请求返回空结果");
                return resp;
            }
            
            JSONObject jsonObj = JSONObject.parseObject(result);
            if (jsonObj == null) {
                resp.setResult(false);
                resp.setMessage("解析响应失败");
                return resp;
            }
            
            resp.setResult(true);
            resp.setPageNo(jsonObj.getIntValue("pageNo"));
            resp.setPageSize(jsonObj.getIntValue("pageSize"));
            resp.setCount(jsonObj.getLongValue("count"));
            
            List<WorkRecordData> list = new ArrayList<>();
            JSONArray listArray = jsonObj.getJSONArray("list");
            if (listArray != null) {
                for (int i = 0; i < listArray.size(); i++) {
                    JSONObject item = listArray.getJSONObject(i);
                    WorkRecordData data = new WorkRecordData();
                    data.setId(item.getString("id"));
                    data.setSn(item.getString("sn"));
                    data.setOprno(item.getString("oprno"));
                    data.setUpdateBy(item.getString("updateBy"));
                    data.setUpdateDate(item.getString("updateDate"));
                    data.setContent(item.getString("content"));
                    list.add(data);
                }
            }
            resp.setList(list);
            
        } catch (Exception e) {
            log.error("查询工作记录异常: " + e.getMessage());
            e.printStackTrace();
            resp.setResult(false);
            resp.setMessage("查询异常: " + e.getMessage());
        }
        return resp;
    }

    /**
     * 查询点检记录
     * @param oprno 工位号
     * @param pageNo 页码
     * @param pageSize 每页条数
     * @return 点检记录响应
     */
    public static CheckRecordResp getCheckRecordList(String oprno, int pageNo, int pageSize) {
        CheckRecordResp resp = new CheckRecordResp();
        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 lineSn = pro.getProperty("mes.line_sn").trim();
            
            String url = "http://" + mes_server_ip + ":8980/js/a/mes/mesCheckRecord/list";
            StringBuilder params = new StringBuilder();
            params.append("__ajax=json");
            params.append("&lineSn=").append(lineSn);
            params.append("&oprno=").append(oprno);
            params.append("&pageNo=").append(pageNo);
            params.append("&pageSize=").append(pageSize);
            
            log.info("查询点检记录: url=" + url + ", params=" + params.toString());
            String result = doPost(url, params.toString());
            log.info("查询点检记录结果: result=" + result);
            
            if (result == null || result.trim().isEmpty()) {
                resp.setResult(false);
                resp.setMessage("请求返回空结果");
                return resp;
            }
            
            JSONObject jsonObj = JSONObject.parseObject(result);
            if (jsonObj == null) {
                resp.setResult(false);
                resp.setMessage("解析响应失败");
                return resp;
            }
            
            resp.setResult(true);
            resp.setPageNo(jsonObj.getIntValue("pageNo"));
            resp.setPageSize(jsonObj.getIntValue("pageSize"));
            resp.setCount(jsonObj.getLongValue("count"));
            
            List<CheckRecordData> list = new ArrayList<>();
            JSONArray listArray = jsonObj.getJSONArray("list");
            if (listArray != null) {
                for (int i = 0; i < listArray.size(); i++) {
                    JSONObject item = listArray.getJSONObject(i);
                    CheckRecordData data = new CheckRecordData();
                    data.setId(item.getString("id"));
                    data.setCheckItem(item.getString("checkItem"));
                    data.setCheckResult(item.getString("checkResult"));
                    data.setUpdateBy(item.getString("updateBy"));
                    data.setUpdateDate(item.getString("updateDate"));
                    list.add(data);
                }
            }
            resp.setList(list);
            
        } catch (Exception e) {
            log.error("查询点检记录异常: " + e.getMessage());
            e.printStackTrace();
            resp.setResult(false);
            resp.setMessage("查询异常: " + e.getMessage());
        }
        return resp;
    }
}