杜方 / CYTAndroid4.0

  package android_serialport_api.print_tool;
  
  import hdx.HdxUtil;
  
  import java.io.File;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.OutputStream;
  import java.io.UnsupportedEncodingException;
  import java.security.InvalidParameterException;
  import java.text.SimpleDateFormat;
  import java.util.Date;
  
  import android.annotation.SuppressLint;
  import android.app.ProgressDialog;
  import android.content.Context;
  import android.os.Handler;
  import android.os.Message;
  import android.os.PowerManager;
  import android.os.PowerManager.WakeLock;
  import android.view.WindowManager;
  import android.widget.Toast;
  import android_serialport_api.SerialPort;
  
  import com.ectrip.cyt.config.MyApp;
  import com.ectrip.cyt.constant.DeviceType;
  import com.ectrip.cyt.constant.LogoType;
  import com.ectrip.cyt.constant.constant;
  import com.ectrip.cyt.utils.LogUtil;
  import com.ectrip.cyt.utils.SharedPreferences2Obj;
  
  /**
   * @author jigo
   * 新版手持pos机
   */
  public class SerialNewHandlePortTool {
  	private WakeLock lock;
  	private static final String TAG = "SerialNewPortTool";
  
  	private Context context;
  
  	private final int ENABLE_BUTTON = 2;
  
  	private SerialPort mSerialPort = null;
  	protected OutputStream mOutputStream;
  	private InputStream mInputStream;
  	protected ReadThread mReadThread;
  	private int n = 0;
  	private int printer_status = 0;
  
  	private MyHandler handler;
  
  	private int printNum=1;
  
  	@SuppressWarnings("deprecation")
  	public void init(Context context,String contentStr) {
  		this.context=context;
  		if(handler==null){
  			handler = new MyHandler();
  		}
  		popUpDialog();
  		try {
  			HdxUtil.SwitchSerialFunction(HdxUtil.SERIAL_FUNCTION_PRINTER);
  		} catch (Throwable e) {
  			e.printStackTrace();
  			Toast.makeText(context, "不支持", Toast.LENGTH_LONG).show();
  			return;
  		}
  		PowerManager pm = (PowerManager) context
  				.getSystemService(Context.POWER_SERVICE);
  		lock = pm.newWakeLock(PowerManager.FULL_WAKE_LOCK, TAG);
  
  		new WriteThread(contentStr).start();
  	}
  
  	@SuppressLint("SimpleDateFormat") private class WriteThread extends Thread {
  		private String arr;
  
  		public WriteThread(String str) {
  			arr = str;
  		}
  
  		public void run() {
  			super.run();
  			try {
  				mSerialPort =getSerialPort();
  				mOutputStream = mSerialPort.getOutputStream();
  				mInputStream = mSerialPort.getInputStream();
  
  				/* Create a receiving thread */
  				mReadThread = new ReadThread();
  				mReadThread.start();
  			} catch (SecurityException e) {
  				// DisplayError(R.string.error_security);
  			} catch (IOException e) {
  				// DisplayError(R.string.error_unknown);
  			} catch (InvalidParameterException e) {
  				// DisplayError(R.string.error_configuration);
  			}
  			HdxUtil.SetPrinterPower(1);
  			lock.acquire();
  			try {
  				try {
  					sleep(500);
  				} catch (InterruptedException e) {
  					e.printStackTrace();
  				}
  				sendCommand(0x1B, 0x23, 0x23, 0x53, 0x4C, 0x41, 0x4E, 0x0f); // china
  				sendCommand(0x1B,0x32);//设置行间距
  //				for(int i=0;i<2;i++){
  //					sendCharacterDemo(arr);
  //					sendCommand(0x0a);
  //					sendCommand(0x1d, 0x56, 0x30);
  //					try {
  //						sleep(4000);
  //					} catch (InterruptedException e) {
  //						e.printStackTrace();
  //					}
  //				}
  
  				for (int x = 0; x < printNum; x++) {
  
  					if(x==1&&isStatistic.equals("1")){
  						break;
  					}
  
  					try {
  						if(isStatistic!=null&&isStatistic.equals("1")){
  							sendCharacterDemo("            统计信息"+"\n");
  							sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						}else{
  							sendCharacterDemo("            订单信息"+"\n");
  							sendCommand(0x1b, 0x33, 0x14, 0x0a);
  							// 当时重打小票的时候，多打一段字符
  
  							if (Select== 2) {
  								sendCharacterDemo("           (重打小票)");
  								sendCommand(0x1b, 0x33, 0x14, 0x0a);
  							}
  						}
  					} catch (Exception e) {
  						e.printStackTrace();
  					}
  
  					try {
  						sendCommand(0x1b, 0x33, 0x14, 0x0a); // 间隔
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					} catch (Exception e) {
  						e.printStackTrace();
  					}
  					sendCharacterDemo(arr);
  					sendCommand(0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					try {
  						sleep(1000);
  					} catch (InterruptedException e) {
  						e.printStackTrace();
  					}
  
  					if(isStatistic!=null&&isStatistic.equals("1")){
  
  					}else{
  						// 重打时间
  //						if (Select== 2) {
  //							SimpleDateFormat df = new SimpleDateFormat(
  //									"yyyy-MM-dd HH:mm:ss");// 设置日期格式
  //							sendCharacterDemo("重打时间：" + df.format(new Date()));
  //							sendCommand(0x1b, 0x33, 0x14, 0x0a);
  //						}
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCharacterDemo("取票人签名：");
  					}
  
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					if (constant.logoMark == LogoType.CYT.getValue()) {
  						sendCharacterDemo("---畅游通—智慧旅游O2O平台---");
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCharacterDemo("--------www.jingqu.cn---------");
  					} else if (constant.logoMark ==LogoType.QNE.getValue()) {
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  
  						sendCharacterDemo("---欢迎使用去哪儿网O2O系统---");
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCommand(0x1b, 0x33, 0x14, 0x0a);
  						sendCharacterDemo("--------www.qunar.com--------");
  					}
  					sendCharacterDemo("\n");
  					sendCharacterDemo("\n");
  					sendCharacterDemo("\n");
  					sendCharacterDemo("\n");
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					sendCommand(0x1b, 0x33, 0x14, 0x0a);
  					try {
  						sleep(2500);
  						if (isStatistic.equals("1")){
  							sleep(1500);
  						}
  					} catch (InterruptedException e) {
  						e.printStackTrace();
  					}
  				}
  			} finally {
  				lock.release();
  				//HdxUtil.SetPrinterPower(0);
  			}
  
  			handler.sendMessage(handler
  					.obtainMessage(ENABLE_BUTTON, 1, 0, null));
  		}
  	}
  
  	private void sendCharacterDemo(String arr) {
  		synchronized (MyApp.getInstance()) {
  			try {
  				mOutputStream.write(arr.getBytes("GBK"));
  			} catch (UnsupportedEncodingException e) {
  				e.printStackTrace();
  			} catch (IOException e) {
  				e.printStackTrace();
  			}
  		}
  	}
  
  	@SuppressLint("HandlerLeak")
  	private class MyHandler extends Handler {
  		public void handleMessage(Message msg) {
  			switch (msg.what) {
  				case ENABLE_BUTTON:
  					close();
  					break;
  				default:
  					break;
  			}
  		}
  	}
  
  	class ReadThread extends Thread {
  
  		@Override
  		public void run() {
  			super.run();
  			while(!isInterrupted()) {
  				int size;
  				try {
  					byte[] buffer = new byte[64];
  
  					if (mInputStream == null) return;
  					size = mInputStream.read(buffer);
  					if (size > 0) {
  						onDataReceived(buffer, size,n);
  					}
  				} catch (IOException e) {
  					e.printStackTrace();
  					return;
  				}
  			}
  		}
  	}
  
  	protected void onDataReceived(final byte[] buffer, final int size,
  								  final int n) {
  		printer_status = buffer[0];
  		LogUtil.e(TAG, "onDataReceived= " + printer_status);
  	}
  
  	private void sendCommand(int... command) {
  		try {
  			for (int i = 0; i < command.length; i++) {
  				mOutputStream.write(command[i]);
  				// Log.e(TAG,"command["+i+"] = "+Integer.toHexString(command[i]));
  			}
  		} catch (IOException e) {
  			e.printStackTrace();
  		}
  		// / sleep(1);
  	}
  
  	public void sleep(int ms) {
  
  		try {
  			java.lang.Thread.sleep(ms);
  		} catch (Exception e) {
  			e.printStackTrace();
  		}
  	}
  
  	public SerialPort getSerialPort() throws SecurityException, IOException,
  			InvalidParameterException {
  		if (mSerialPort == null) {
  			/* Read serial port parameters */
  			String path = "/dev/ttyS1";
  			;// sp.getString("DEVICE", "");
  			int baudrate = 115200;// Integer.decode(sp.getString("BAUDRATE",
  			// "-1"));
  
  			/* Check parameters */
  			if ((path.length() == 0) || (baudrate == -1)) {
  				// throw new InvalidParameterException();
  				/* use default value. Nirvana 0710 */
  				path = "/dev/ttyS1";
  				baudrate = 115200;
  			}
  
  			/* Open the serial port */
  			mSerialPort = new SerialPort(new File(path), baudrate, 0);
  		}
  		return mSerialPort;
  	}
  
  	public void closeSerialPort() {
  		if (mSerialPort != null) {
  			mSerialPort.close();
  			mSerialPort = null;
  		}
  	}
  
  	public void close(){
  		try {
  			if (mReadThread != null)
  				mReadThread.interrupt();
  		} catch (Exception e1) {
  			e1.printStackTrace();
  		}
  		try {
  			mSerialPort = null;
  		} catch (Exception e1) {
  			e1.printStackTrace();
  		}
  		try
  		{
  			mOutputStream.close();
  			mInputStream.close();
  		} catch (IOException e) {
  		}catch (Exception e) {
  		}
  		if(dialog!=null){
  			dialog.dismiss();
  		}
  	}
  
  	private ProgressDialog dialog;
  	private String isStatistic;
  	private Integer type;
  	private int Select = 0;
  	private void popUpDialog(){
  		try {
  			isStatistic=SharedPreferences2Obj.getInstance(context).
  					setName("SelectAction").getObject("isStatistic",String.class);   //非统计判断
  			type=SharedPreferences2Obj.getInstance(context).
  					setName("MachineType").getObject("type", Integer.class);
  			Select=SharedPreferences2Obj.getInstance(context).
  					setName("SelectAction").getObject("Select",Integer.class);
  			printNum = MyApp.getInstance().getPrintNum();
  		} catch (Exception e1) {
  			e1.printStackTrace();
  		}
  		if (dialog == null) {
  			// 显示ProgressDialog
  			dialog = new ProgressDialog(context);
  			dialog.setMessage("打印中...");
  			dialog.setCanceledOnTouchOutside(false);
  			dialog.setCancelable(false);
  			if (type==DeviceType.HANDSET.getValue()) {
  				dialog.getWindow()
  						.setType(
  								WindowManager.LayoutParams.TYPE_SYSTEM_ALERT);
  			}
  			try {
  				dialog.show();
  			} catch (Exception e) {
  				e.printStackTrace();
  			}
  		}else{
  			dialog.setMessage("打印中...");
  			dialog.show();
  		}
  	}
  }