~yhj/HM_HD.git - Gitblit

package com.web.pda.gltPda_wdPda.service.internal;
 
import java.sql.CallableStatement;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import com.web.pda.gltPda_wdPda.service.OutPutService;
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 = "outPutService")
@Transactional(propagation = Propagation.REQUIRED)
public class OutPutImpl  implements OutPutService {
 
    @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_eq_getproc1");
        System.out.println(resultList);//001[1011-11,{ZBK2014042103-2{ZBK2014042103-2,1,admin,20000,
        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);
            }
            String[] list_strs = strs[1].split(",",-1);
          //封装数据
            Map<String, Object> map = new HashMap<>();
            if(list_strs.length > 4){
                map.put("station", list_strs[0]);
                map.put("classes", list_strs[2]);
                map.put("code", list_strs[3]);
                map.put("tqry", list_strs[4]);
                map.put("pqry", list_strs[5]);
                List arr = new ArrayList<>();
                String[] s1 = replaceNull(list_strs[1].split("\\{"));
                map.put("list", Arrays.asList(s1));
            }else{
                return ApiResponseResult.failure("返回参数格式不对:"+resultList);
            }
            return ApiResponseResult.success("获取数据成功！").data(map);
        }
        return ApiResponseResult.failure("没有数据！");
    }
    
    /**
     * 根据设备号获取信息
     * @param deviceNo
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterDeviceWinding(String deviceNo) throws Exception {
        if(StringUtils.isEmpty(deviceNo)){
            return ApiResponseResult.failure("设备号不能为空!");
        }
        List<String> resultList = this.doPrc(deviceNo,"prc_eq_getproc");
        System.out.println(resultList);//001[设备信息 ,
        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);
            }
            
            return ApiResponseResult.success("获取数据成功！");
        }
        return ApiResponseResult.failure("没有数据！");
    }
    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方法分割，得到数组
           str = sb.toString().split(";");
           return str;
    }
    
    @Override
    public ApiResponseResult afterCode(String param) throws Exception {
        // TODO Auto-generated method stub
        if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("工号不能为空!");
        }
        List<String> resultList = this.doPrc(param,"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+"");
            }
            return ApiResponseResult.success().data(strs[1]);
        }
        return null;
    }
    
    @Override
    public ApiResponseResult afterOrder(String param) throws Exception {
        // TODO Auto-generated method stub
        if(StringUtils.isEmpty(param)){
            return ApiResponseResult.failure("单号不能为空!");
        }
        List<String> resultList = this.doPrc(param,"Prc_Col_Tl01");
        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(Arrays.asList(strs[1].split(",",-1)));
        }
        return null;
    }
 
    /**
     * 根据设备号获取信息
     * @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_Check_Maratb");
        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(Arrays.asList(strs[1].split(",",-1)));
            
        }
        return ApiResponseResult.failure("没有数据！");
    }
    
    /**
     * 根据设备号获取信息(新)
     * 2022/12/14 lst add
     * @param barcode
     * @return
     * @throws Exception
     */
    @Override
    @Transactional
    public ApiResponseResult afterBarcoe_01(String barcode) throws Exception{
        if(StringUtils.isEmpty(barcode)){
            return ApiResponseResult.failure("物料号不能为空!");
        }
        List<String> resultList = this.doPrc(barcode,"Prc_Check_Maratb_01");
        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(Arrays.asList(strs[1].split(",",-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_tubu_put");
        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 afterBarcoeZP(String barcode) throws Exception {
        // TODO Auto-generated method stub
        if(StringUtils.isEmpty(barcode)){
            return ApiResponseResult.failure("物料号不能为空!");
        }
        List<String> resultList = this.doPrc(barcode,"Prc_Check_Marazp");
        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(Arrays.asList(strs[1].split(",",-1)));
            
        }
        return ApiResponseResult.failure("没有数据！");
    }
    
 
 
}