~yhj/XM_HD.git - Gitblit

package com.web.pda.gltPda_wdPda.service.internal;
 
import com.app.base.data.ApiResponseResult;
import com.web.pda.gltPda_wdPda.service.GlueInputService;
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 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;
 
@Service(value = "GlueInputService")
@Transactional(propagation = Propagation.REQUIRED)
public class GlueInputImpl implements GlueInputService {
 
    @Autowired
    private JdbcTemplate jdbcTemplate;
 
    /**
     * 根据设备号获取信息
     * @param deviceNo
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterDevice(String deviceNo) throws Exception {
        if(StringUtils.isEmpty(deviceNo)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
        List<String> resultList = this.doPrc(deviceNo,"Prc_Jiaoban_eq");
        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+"");
            }
            //获取列表
            if(strs.length <1 ){
                return ApiResponseResult.failure("长度解析发生错误:"+resultList);
            }
          List arr = new ArrayList<>();
            String[] list_strs = strs[1].split("‖");
            /*  for(int i=0;i<list_strs.length-1;i++){
                String[] map_strs = list_strs[i].split("＠");
                if(map_strs.length > 1){
                    Map map = new HashMap();
                    map.put("order", map_strs[0]);
                    map.put("qty", map_strs[1]);
                    map.put("pqty", map_strs[2]);
                    arr.add(map);
                }
            }*/
 
            //封装数据
            Map<String, Object> map = new HashMap<>();
            //map.put("list", arr);
            map.put("list", this.getAfterDeviceListRf("10000", "1000", deviceNo, 100, 1).get(0));
            if(list_strs.length >0){
                String[] last = list_strs[list_strs.length-1].split("＠",-1);
                if(last.length < 4){
                    map.put("station", "");
                    map.put("code", "");
                    map.put("classes", "");
                    map.put("remark", "");
                    return ApiResponseResult.success("返回数据格式不正确，无法显示正确数据！").data(map);
                }
                map.put("station", last[0]);
                map.put("code", last[1]);
                map.put("classes", last[2]);
                map.put("remark", last[3]);
            }
            
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
 
        return ApiResponseResult.failure("没有数据！");
    }
    public List<Object> getAfterDeviceListRf(String factory,String company,String in_str,int page,int size) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call App_Zhijiao_Listcurr(?,?,?,?,?,?,?,?)}";// 调用的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();
                if(cs.getString(6).toString().endsWith("0")){
                    //游标处理
                    ResultSet rs = (ResultSet)cs.getObject(8);
                    List l = new ArrayList();
 
                    while(rs.next()){
                        Map m = new HashMap();
                        m.put("ID", rs.getString("ID"));
                        m.put("LOT_NO", rs.getString("LOT_NO"));
                        m.put("FPEIFANG", rs.getString("FPEIFANG"));
                        m.put("FPUT_QTY", rs.getString("FPUT_QTY"));
                        m.put("CREATE_DATE", rs.getString("CREATE_DATE"));
                        m.put("CREATE_BY", rs.getString("CREATE_BY"));
                        l.add(m);
                    }
                    result.add(l);
                }
 
                return result;
            }
        });
        return resultList;
 
    }
 
    /**
     * 根据设备号获取信息
     * @param barcode
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterBarcoe(String barcode) throws Exception{
        if(StringUtils.isEmpty(barcode)){
            return ApiResponseResult.failure("物料号不能为空!");
        }
        List<String> resultList = this.doPrc(barcode,"Prc_Zhijiao_Mara");
        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+"");
            }
            return ApiResponseResult.success().data(strs[1]);
 
        }
        return ApiResponseResult.failure("没有数据！");
    }
 
 
    /**
     * 根据工单获取信息
     * @param param
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterQty(String param) throws Exception{
        //模块名称[字段名[登录帐号[工位[工号[班次[工单号[批量[设备[物料[用量
        //工单号[批量为空
        if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("数量不能为空!");
        }
        List<String> resultList = this.doPrc(param,"Prc_Zhijiang_Put_NTsk");
        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+"");
            }
            return ApiResponseResult.success().data(strs[1]);
        }
 
        return ApiResponseResult.failure("没有数据！");
 
    }
 
 
    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(cs.getString(2));
                return result;
            }
        });
 
        return resultList;
    }
 
    @Override
    public ApiResponseResult getList(String device, int page) throws Exception {
        // TODO Auto-generated method stub
        List<Object> a  = this.getListRf("10000", "1000",device,5,page);
        if(!a.get(0).toString().equals("0")){
            return ApiResponseResult.failure(a.get(1).toString());
        }
 
        return ApiResponseResult.success().data(a.get(2));
    }
 
    public List<Object> getListRf(String factory,String company,String in_str,int page,int size) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call App_Zhijiao_Listhead(?,?,?,?,?,?,?,?)}";// 调用的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(6));
                result.add(cs.getString(7));
                if(cs.getString(6).toString().endsWith("0")){
                    //游标处理
                    ResultSet rs = (ResultSet)cs.getObject(8);
                    List l = new ArrayList();
 
                    while(rs.next()){
                        Map m = new HashMap();
                        m.put("ID", getEmpty(rs.getString("ID")));
                        m.put("LOT_NO", getEmpty(rs.getString("LOT_NO")));
                        m.put("FPEIFANG", getEmpty(rs.getString("FPEIFANG")));
                        m.put("FPUT_QTY", getEmpty(rs.getString("FPUT_QTY")));
                        m.put("CREATE_DATE", getEmpty(rs.getString("CREATE_DATE")));
                        m.put("CREATE_BY", getEmpty(rs.getString("CREATE_BY")));
                        l.add(m);
                    }
                    result.add(l);
                }
 
 
                return result;
            }
        });
        return resultList;
 
    }
 
    @Override
    public ApiResponseResult delete(String pid) throws Exception {
        // TODO Auto-generated method stub
        if(StringUtils.isEmpty(pid)){
            return ApiResponseResult.failure("ID不能为空!");
        }
        List<String> a = this.doDeletePrc("10000", "1000", Integer.parseInt(pid));
        if(a.get(0).equals("1")){
            return ApiResponseResult.failure(a.get(1));
        }
 
        return ApiResponseResult.success(a.get(1));
    }
    public List<String> doDeletePrc(String factory,String company,int pid){
        List<String> resultList = (List<String>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call Prc_Batch_Del_Barcode_peiliao(?,?,?,?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, factory);
                cs.setString(2, company);
                cs.setInt(3, pid);
                cs.registerOutParameter(4,java.sql.Types.INTEGER);// 注册输出参数 返回类型
                cs.registerOutParameter(5,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(cs.getString(4));
                result.add(cs.getString(5));
                return result;
            }
        });
 
        return resultList;
    }
    @Override
    public ApiResponseResult getDetailList(String pid) throws Exception {
        // TODO Auto-generated method stub
         List<Object> a  = this.getDetailListRf("10000", "1000",pid);
            if(!a.get(0).toString().equals("0")){
                return ApiResponseResult.failure(a.get(1).toString());
            }
 
            return ApiResponseResult.success().data(a.get(2));
    }
    public List<Object> getDetailListRf(String factory,String company,String pid) {
        List<Object> resultList = (List<Object>) jdbcTemplate.execute(new CallableStatementCreator() {
            @Override
            public CallableStatement createCallableStatement(Connection con) throws SQLException {
                String storedProc = "{call App_Zhijiao_Listdetail(?,?,?,?,?,?)}";// 调用的sql
                CallableStatement cs = con.prepareCall(storedProc);
                cs.setString(1, factory);
                cs.setString(2, company);
                cs.setString(3, pid);
                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(4));
                result.add(cs.getString(5));
                if(cs.getString(4).toString().endsWith("0")){
                    //游标处理
                    ResultSet rs = (ResultSet)cs.getObject(6);
                    List l = new ArrayList();
 
                    while(rs.next()){
                        Map m = new HashMap();
                        m.put("QUANTITY", getEmpty(rs.getString("QUANTITY")));
                        m.put("ITEM_NAME", getEmpty(rs.getString("ITEM_NAME")));
                        m.put("ITEM_BARCODE", getEmpty(rs.getString("ITEM_BARCODE")));
                        l.add(m);
                    }
                    result.add(l);
                }
 
                return result;
            }
        });
        return resultList;
 
    }
     //值为"null"或者null转换成""
    private String getEmpty(String str){
        if(str == null){
            return "";
        }
        if(StringUtils.equals("null", str)){
            return "";
        }
 
        String[] strs = str.split("\\.");
        if(strs.length > 0){
            if(strs[0].equals("") || strs[0]==null){
                return "0"+str;
            }
        }
        return str;
    }
 
    
}