~yhj/XM_HD.git - Gitblit

package com.web.pda.gltPda_wdPda.service.internal;
 
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import com.web.pda.gltPda_wdPda.service.GlueService;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.dao.DataAccessException;
import org.springframework.jdbc.core.CallableStatementCallback;
import org.springframework.jdbc.core.CallableStatementCreator;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
 
import com.app.base.data.ApiResponseResult;
 
@Service(value = "GlueService")
@Transactional(propagation = Propagation.REQUIRED)
public class GlueImpl implements GlueService {
 
    @Autowired
    private JdbcTemplate jdbcTemplate;
 
    /**
     * 根据设备号获取信息
     * @param device
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterDevice(String device) throws Exception {
        if(StringUtils.isEmpty(device)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
 
        //获取数据
        List<Object> delList = getDelListRf("10000", "1000", device, "App_Zhijiao_Shebei_Enter");
        String s2 = delList.get(0).toString();//resultList.get(0).substring(0);
        String[] delStrs = s2.split("\\[");
        if(delStrs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s2);
        }
        //判断取值是否成功
        String delStr = delStrs[0];
        if(delStr.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s2);
        }
        //封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("list", delList.get(1));
 
        return ApiResponseResult.success("获取数据成功！").data(map);
    }
 
    /**
     * 根据工位获取信息
     * @param station
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterStation(String station) throws Exception{
        if(StringUtils.isEmpty(station)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
 
        List<String> resultList = this.doPrc(station, "Prc_Check_ProcLine");
        System.out.println(resultList);
 
        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取列表
            //例如：001[FJ001-1,{A05<A05>[A06<A06>
            //String station = "";
            List<Map> list = new ArrayList<>();
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] orderArray = strs[1].split(",");
            if(orderArray.length < 1){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] orderArray1 = replaceNull(orderArray[1].split("\\{"));
            if(orderArray1 != null && orderArray1.length > 0){
                //数据转换
                for(String st:orderArray1){
                    String[] strs1 = st.split("\\[");
                    for(String st1:strs1){
                        String[] strs2 = st1.split("<");
                        Map m = new HashMap();
                        m.put("key", strs2[0]);
                        m.put("name", strs2[1].substring(0, strs2[1].length() - 1));
                        list.add(m);
                    }
                }
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            //map.put("station", station);
            map.put("list", list);
 
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
 
 
        return null;
    }
 
    /**
     * 根据工号获取信息
     * @param userCode
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterJob(String userCode) throws Exception{
        if(StringUtils.isEmpty(userCode)){
            return ApiResponseResult.failure("工号不能为空!");
        }
 
        List<String> resultList = this.doPrc(userCode, "Prc_Check_Gonghao");
        System.out.println(resultList);
        
        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取信息
            String classes = "";
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            classes = strs[1];
 
            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("classes", classes);//班次
 
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
 
        return ApiResponseResult.failure("获取数据失败！");
    }
 
    /**
     * 根据工单获取信息
     * @param order
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterOrder(String order) throws Exception{
        if(StringUtils.isEmpty(order)){
            return ApiResponseResult.failure("工单不能为空!");
        }
 
        List<String> resultList = this.doPrc(order, "Prc_Zhijiao_Peifang");
        System.out.println(resultList);
 
        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //获取信息
            String orderNo = "";
            if(StringUtils.isEmpty(strs[1])){
                return ApiResponseResult.failure("获取数据失败：" + resultList);
            }
            String[] tempArray = strs[1].split(",");
            if(tempArray.length > 0){
                orderNo = tempArray[0];
            }
 
            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("orderNo", orderNo);//计划数量(用“，”隔开)
 
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
 
        return ApiResponseResult.failure("获取数据失败！");
    }
 
    /**
     * 根据批量获取信息
     * @param param
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterBatch(String param) throws Exception{
        if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("批量不能为空!");
        }
 
        List<String> resultList = this.doPrc(param, "Prc_Zhijiao_Put");
        System.out.println(resultList);
        
        if(resultList.size() > 0){
            String s = resultList.get(0).toString();//resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("系统错误：" + resultList);
            }
            //封装数据
            Map<String, Object> map = new HashMap<>();
            map.put("remark", strs[1]);
 
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
 
        return ApiResponseResult.failure("获取数据失败！");
    }
 
    /**
     * 删除
     * @param order
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult delete(String order) throws Exception{
        if(StringUtils.isEmpty(order)){
            return ApiResponseResult.failure("工单不能为空！");
        }
 
        List<String> resultList = this.doPrc(order, "Prc_Zhijiao_Del");
 
        if(resultList.size() > 0){
            String s = resultList.get(0).substring(0);
            String[] strs = s.split("\\[");
            if(strs.length < 1){
                return ApiResponseResult.failure("返回值的格式不正确：" + resultList);
            }
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("002")){
                return ApiResponseResult.failure("删除数据失败：" + resultList);
            }
 
            return ApiResponseResult.success("删除数据成功！");
        }
 
        return ApiResponseResult.failure("删除数据失败！");
    }
 
    /**
     * 获取删除列表数据
     * @param device
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult getDelList(String device) throws Exception{
        if(StringUtils.isEmpty(device)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
 
        //获取数据
        List<Object> delList = getDelListRf("10000", "1000", device, "App_Zhijiao_Shebei_Select");
        String s2 = delList.get(0).toString();//resultList.get(0).substring(0);
        String[] delStrs = s2.split("\\[");
        if(delStrs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s2);
        }
        //判断取值是否成功
        String delStr = delStrs[0];
        if(delStr.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s2);
        }
        //封装数据
        Map<String, Object> map = new HashMap<>();
        map.put("list", delList.get(1));
 
        return ApiResponseResult.success("获取数据成功！").data(map);
    }
 
    /**
     * 获取列表
     * @param device
     * @param page
     * @return
     * @throws Exception
     */
    @Override
    public ApiResponseResult getList(String device, int page) throws Exception {
        List<Object> a  = this.getAllListRf("10000", "1000",device,5,page,"App_ZhiJiao_Shebei_Selecthis");
        String s = a.get(0).toString();//resultList.get(0).substring(0);
        String[] strs = s.split("\\[");
        if(strs.length < 1){
            return ApiResponseResult.failure("返回值的格式不正确：" + s);
        }
        //判断取值是否成功
        String str = strs[0];
        if(str.equals("002")){
            return ApiResponseResult.failure("系统错误：" + s);
        }
 
        return ApiResponseResult.success().data(a.get(1));
    }
 
    //执行存
    public List<String> doPrc(String param,String prc_name){
        List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call "+prc_name+"(?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, param);
                cs.registerOutParameter(2,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
                return cs;
            }
        }, new CallableStatementCallback() {
            public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
                List<String> result = new ArrayList<String>();
                cs.execute();
                result.add(getEmpty(cs.getString(2)));
                return result;
            }
        });
 
        return resultList;
    }
    //值为"null"或者null转换成""
    private String getEmpty(String str){
        if(str == null){
            return "";
        }
        if(StringUtils.equals("null", str)){
            return "";
        }
        return str;
    }
    //去除List数组中为空的元素
    private String[] replaceNull(String[] str){
        //用StringBuffer来存放数组中的非空元素，用“;”分隔
        StringBuffer sb = new StringBuffer();
        for(int i=0; i<str.length; i++) {
            if("".equals(str[i])) {
                continue;
            }
            sb.append(str[i]);
            if(i != str.length - 1) {
                sb.append(";");
            }
        }
        //用String的split方法分割，得到数组
        if(StringUtils.isEmpty(sb)){
            return null;
        }
        str = sb.toString().split(";");
        return str;
    }
 
    //执行存储获取数据1
    public List<Object> getDelListRf(String factory,String company,String in_str,String prc_name) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call "+prc_name+"(?,?,?,?,?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, factory);
                cs.setString(2, company);
                cs.setString(3, in_str);
                cs.registerOutParameter(4,java.sql.Types.INTEGER);// 注册输出参数 返回类型
                cs.registerOutParameter(5,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
                cs.registerOutParameter(6,-10);// 注册输出参数 返回类型
                return cs;
            }
        }, new CallableStatementCallback() {
            public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
                List<Object> result = new ArrayList<Object>();
                cs.execute();
                result.add(cs.getString(5));
 
                String[] strs = cs.getString(5).split("\\[");
                //判断取值是否成功
                String str = strs[0];
                if(str.equals("001")){
                    //游标处理
                    ResultSet rs = (ResultSet)cs.getObject(6);
                    List l = new ArrayList();
 
                    while(rs.next()){
                        Map m = new HashMap();
                        m.put("MID", rs.getString("MID"));
                        m.put("FPEIFANG", rs.getString("FPEIFANG"));
                        m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
                        m.put("LOT_NO", rs.getString("LOT_NO"));
                        l.add(m);
                    }
                    result.add(l);
                }
 
                return result;
            }
        });
        return resultList;
    }
 
    //执行存储获取数据2
    public List<Object> getAllListRf(String factory,String company,String in_str,int page,int size,String prc_name) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
        @Override
        public CallableStatement createCallableStatement(Connection con) throws SQLException {
        String storedProc = "{call "+prc_name+"(?,?,?,?,?,?,?,?)}";// 调用的sql
        CallableStatement cs = con.prepareCall(storedProc);
        cs.setString(1, factory);
        cs.setString(2, company);
        cs.setString(3, in_str);
        cs.setInt(4, page);
        cs.setInt(5, size);
        cs.registerOutParameter(6,java.sql.Types.INTEGER);// 注册输出参数 返回类型
        cs.registerOutParameter(7,java.sql.Types.VARCHAR);// 注册输出参数 返回类型
        cs.registerOutParameter(8,-10);// 注册输出参数 返回类型
        return cs;
        }
        }, new CallableStatementCallback() {
        public Object doInCallableStatement(CallableStatement cs) throws SQLException, DataAccessException {
            List<Object> result = new ArrayList<Object>();
            cs.execute();
            result.add(cs.getString(7));
            
            String[] strs = cs.getString(7).split("\\[");
            //判断取值是否成功
            String str = strs[0];
            if(str.equals("001")){
                //游标处理
                ResultSet rs = (ResultSet)cs.getObject(8);
                List l = new ArrayList();
    
                while(rs.next()){
                    Map m = new HashMap();
                    m.put("MID", rs.getString("MID"));
                    m.put("FPEIFANG", rs.getString("FPEIFANG"));
                    m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
                    m.put("LOT_NO", rs.getString("LOT_NO"));
                    m.put("CREATE_DATE", rs.getString("CREATE_DATE"));
                    l.add(m);
                     }
                result.add(l);
            }
    
            return result;
            }
        });
        return resultList;
        }
 
}