package com.slcf.filter;
|
|
import java.io.BufferedReader;
|
import java.io.InputStreamReader;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URL;
|
|
import javax.annotation.Resource;
|
|
import org.activiti.engine.impl.transformer.IntegerToString;
|
import org.apache.log4j.Logger;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import com.slcf.bean.AllBean;
|
import com.slcf.pojo.WaitPakInBean;
|
import com.slcf.pojo.WaitPakOutBean;
|
import com.slcf.service.WaitPakInService;
|
import com.slcf.service.WaitPakOutService;
|
import com.slcf.service.impl.WaitPakInServiceImpl;
|
import com.slcf.util.Constants;
|
import com.slcf.util.SpringBeanUtils;
|
|
import net.sf.json.JSONArray;
|
import net.sf.json.JSONObject;
|
import sun.misc.BASE64Encoder;
|
|
/**
|
* 回报，处理与sap交互数据
|
* @author admin
|
* @Date 2020-02-17
|
*/
|
//@Service
|
public class UpdateThread extends Thread {//implements Runnable{
|
// @Resource
|
// WaitPakInService waitPakInService;
|
// @Resource
|
// WaitPakOutService waitPakOutService;
|
// @Resource
|
// private static WaitPakInServiceImpl waitPakInService;
|
|
Logger logger=Logger.getLogger(UpdateThread.class);
|
|
public static int count=0;
|
|
private WaitPakInService waitPakInService;
|
public WaitPakInService getWaitPakInService() {
|
return waitPakInService;
|
}
|
public void setWaitPakInService(WaitPakInService waitPakInService) {
|
this.waitPakInService = waitPakInService;
|
}
|
|
private WaitPakOutService waitPakOutService;
|
public WaitPakOutService getWaitPakOutService() {
|
return waitPakOutService;
|
}
|
public void setWaitPakOutService(WaitPakOutService waitPakOutService) {
|
this.waitPakOutService = waitPakOutService;
|
}
|
|
public void run() {
|
waitPakInService = getWaitPakInService();
|
waitPakOutService = getWaitPakOutService();
|
while(true) {
|
try {
|
updateWaitPakInData();
|
sendPickPrintCmd();
|
updateWaitPakOutData();
|
// updateWaitCheckData();
|
Thread.sleep(5000);
|
} catch (InterruptedException e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
|
/**
|
* 处理入库通知档数据
|
*/
|
private void updateWaitPakInData() {
|
try {
|
// logger.info("waitIn:" + count++);
|
WaitPakInBean waitPakInBean = waitPakInService.queryWaitPakInFnh();
|
if(waitPakInBean!=null) {
|
String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/AsrsTrSet";
|
int result = sendPakInStatus(httpUrl,waitPakInBean);
|
}
|
}catch(Exception e) {
|
logger.error("SAP Error updateWaitPakInData---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}
|
}
|
|
/**
|
* 入库完成，调用sap接口上传完成信息
|
*/
|
private int sendPakInStatus(String httpUrl,WaitPakInBean waitPakIn) {
|
int result = 0;
|
// String token = getXCsrfToken(httpUrl);
|
String input = Constants.SAP_USER + ":" + Constants.SAP_PASSWORD;//"ZHANGX:654321";
|
BASE64Encoder base = new BASE64Encoder();
|
String encodedPassword;
|
String token="";
|
String session_value="";
|
|
HttpURLConnection connection1 = null;
|
try {
|
encodedPassword = base.encode(input.getBytes("UTF-8"));
|
URL url1 = new URL(httpUrl);
|
connection1 = (HttpURLConnection) url1.openConnection();
|
connection1.setDoOutput(true);
|
connection1.setDoInput(true);
|
connection1.setConnectTimeout(30000);
|
connection1.setReadTimeout(30000);
|
connection1.setRequestMethod("GET");
|
connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection1.setRequestProperty("x-csrf-token","Fetch");
|
|
|
String sessionCookie = connection1.getHeaderField("Set-Cookie");
|
if(sessionCookie==null || sessionCookie.length()<1)
|
{
|
logger.error("SAP ERROR-----调用上架完成接口，get请求获取cookie失败");
|
return result;
|
}
|
String[] sessionId = sessionCookie.split(";");
|
session_value = sessionId[0];
|
token = connection1.getHeaderField("x-csrf-token");
|
// Map<String, List<String>> map = connection1.getHeaderFields();
|
// token = map.get("x-csrf-token").toString();
|
} catch (Exception e1) {
|
logger.error("SAP ERROR-----调用上架完成接口1，get请求获取cookie失败。" + e1.getMessage());
|
// e1.printStackTrace();
|
}finally {
|
if(connection1!=null){
|
connection1.disconnect();
|
}
|
}
|
|
try {
|
JSONObject jsObj = new JSONObject();
|
JSONArray arr = new JSONArray();
|
for(int i=0;i<1;i++) {
|
JSONObject json = new JSONObject();
|
json.put("lgnum",waitPakIn.getLgnum());
|
json.put("tbnum",Long.toString(waitPakIn.getTbnum()));
|
json.put("tbpos",Integer.toString(waitPakIn.getTbpos()));
|
json.put("zmatid",waitPakIn.getZmatid());
|
|
json.put("anfme",Double.toString(waitPakIn.getAnfme()));
|
json.put("altme",waitPakIn.getAltme());
|
json.put("nltyp","A01");
|
json.put("nlber","001");
|
json.put("nlpla",waitPakIn.getLoc_no());
|
arr.add(json);
|
}
|
jsObj.put("item", arr);
|
byte[] buff = jsObj.toString().getBytes();
|
int buffLen = buff.length;
|
//创建连接
|
HttpURLConnection connection = null;
|
try {
|
// String input = "ZHANGX:654321";
|
// BASE64Encoder base = new BASE64Encoder();
|
// String encodedPassword = base.encode(input.getBytes("UTF-8"));
|
|
URL url = new URL(httpUrl);
|
connection = (HttpURLConnection) url.openConnection();
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setRequestMethod("POST");
|
connection.setConnectTimeout(30000);
|
connection.setReadTimeout(30000);
|
// connection.setUseCaches(false);
|
// connection.setInstanceFollowRedirects(true);
|
// connection.setRequestProperty("Content-Type","text/json;charset=gb2312");
|
connection.setRequestProperty("Cookie", session_value);
|
connection.setRequestProperty("Content-Type","application/json");
|
connection.setRequestProperty("Accept","application/json");
|
connection.setRequestProperty("Accept-Language","zh-CN,zh;q=0.9,en;q=0.8");
|
connection.setRequestProperty("Content-Length","" + buffLen);
|
// connection.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection.setRequestProperty("x-csrf-token",token);
|
|
//POST请求
|
OutputStream out = connection.getOutputStream();
|
out.write(buff);
|
out.close();
|
|
//读取响应
|
BufferedReader reader = new BufferedReader(new InputStreamReader(
|
connection.getInputStream()));
|
String lines;
|
StringBuffer sb = new StringBuffer("");
|
while ((lines = reader.readLine()) != null) {
|
lines = new String(lines.getBytes(), "utf-8");
|
sb.append(lines);
|
}
|
// logger.error("SAP INFO-----调用上架完成接口，返回JSON数据：" + sb.toString());
|
// System.out.println(sb.toString());
|
JSONObject json = JSONObject.fromObject(sb.toString());
|
String d = json.get("d").toString();
|
JSONObject jsonD = JSONObject.fromObject(d);
|
String Item = jsonD.get("item").toString();
|
JSONObject jsonItem = JSONObject.fromObject(Item);
|
String results = jsonItem.get("results").toString();
|
JSONArray array = JSONArray.fromObject(results);
|
|
if(array.size()>0) {
|
for(int i=0;i<array.size();i++){
|
JSONObject job = array.getJSONObject(i);
|
String zstatus = job.get("zstatus").toString();
|
// String message = job.get("message").toString();
|
String message="";
|
try {
|
message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
|
// logger.error("SAP TEST-----数据：" + message);
|
}catch(Exception em) {
|
}
|
if(zstatus.equals("s") || message.contains("已经完全提供")) {//上报SAP成功,转历史档
|
// if(zstatus.equals("s")) {
|
waitPakIn.setIo_status("Y");
|
waitPakInService.upWaitPakIn(waitPakIn);
|
waitPakInService.moveToLog(waitPakIn);
|
}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
|
waitPakIn.setIo_status("X");
|
waitPakIn.setMemo(message);
|
waitPakInService.upWaitPakIn(waitPakIn);
|
}
|
// System.out.println("zstatus信息.." + zstatus);
|
// System.out.println("message信息.." + message);
|
}
|
}
|
result = 1;
|
}catch (Exception e) {
|
waitPakIn.setIo_status("X");
|
waitPakIn.setMemo(e.getMessage());
|
waitPakInService.upWaitPakIn(waitPakIn);
|
logger.error("SAP Error sendPakInStatus--"+waitPakIn.getMatnr()+"---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}finally {
|
if(connection!=null){
|
connection.disconnect();
|
}
|
}
|
}catch (Exception e) {
|
waitPakIn.setIo_status("X");
|
waitPakIn.setMemo(e.getMessage());
|
waitPakInService.upWaitPakIn(waitPakIn);
|
logger.error("SAP Error sendPakInStatus--"+waitPakIn.getMatnr()+"---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}
|
return result;
|
}
|
|
/**
|
* 处理出库通知档数据
|
*/
|
private void updateWaitPakOutData() {
|
try {
|
// logger.info("waitOut:" + count++);
|
WaitPakOutBean waitPakOutBean = waitPakOutService.queryWaitPakOutFnh();
|
if(waitPakOutBean!=null) {
|
String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/ToConHeadSet";
|
int result = sendPakOutStatus(httpUrl,waitPakOutBean);
|
}
|
}catch(Exception e) {
|
logger.error("SAP Error updateWaitPakOutData---" + e.getMessage());
|
}
|
}
|
|
/**
|
* 出库完成，调用sap接口上传完成信息
|
*/
|
private int sendPakOutStatus(String httpUrl,WaitPakOutBean waitPakOut) {
|
int result = 0;
|
// String token = getXCsrfToken(httpUrl);
|
String input = Constants.SAP_USER + ":" + Constants.SAP_PASSWORD;//"ZHANGX:654321";
|
BASE64Encoder base = new BASE64Encoder();
|
String encodedPassword;
|
String token="";
|
String session_value="";
|
|
HttpURLConnection connection1 = null;
|
try {
|
encodedPassword = base.encode(input.getBytes("UTF-8"));
|
URL url1 = new URL(httpUrl);
|
connection1 = (HttpURLConnection) url1.openConnection();
|
connection1.setDoOutput(true);
|
connection1.setDoInput(true);
|
connection1.setConnectTimeout(30000);
|
connection1.setReadTimeout(30000);
|
connection1.setRequestMethod("GET");
|
connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection1.setRequestProperty("x-csrf-token","Fetch");
|
String sessionCookie = connection1.getHeaderField("Set-Cookie");
|
if(sessionCookie==null || sessionCookie.length()<1)
|
{
|
logger.error("调用下架完成接口，get请求获取cookie失败");
|
return result;
|
}
|
String[] sessionId = sessionCookie.split(";");
|
session_value = sessionId[0];
|
token = connection1.getHeaderField("x-csrf-token");
|
|
// Map<String, List<String>> map = connection1.getHeaderFields();
|
// token = map.get("x-csrf-token").toString();
|
} catch (Exception e1) {
|
logger.error("调用下架完成接口，get请求获取cookie失败" + e1.getMessage());
|
// e1.printStackTrace();
|
}finally{
|
if(connection1!=null){
|
connection1.disconnect();
|
}
|
}
|
|
try {
|
JSONObject jsObj = new JSONObject();
|
JSONArray arr = new JSONArray();
|
for(int i=0;i<1;i++) {
|
JSONObject json = new JSONObject();
|
json.put("lgnum",waitPakOut.getLgnum());
|
json.put("tanum",Long.toString(waitPakOut.getTanum()));
|
json.put("tapos",Integer.toString(waitPakOut.getTapos()));
|
|
double nista = waitPakOut.getNista();
|
// if(nista>0)
|
if(nista>=-1 && (int)nista!=0)
|
{
|
double vsolm = waitPakOut.getVsolm();
|
if( (int)nista == -1 ) {
|
nista=0;
|
}
|
double ndifa = vsolm - nista;
|
json.put("nista",Double.toString(nista)); //实际数量
|
json.put("ndifa",Double.toString(ndifa)); //差异数量
|
}
|
json.put("altme",waitPakOut.getMeins());
|
json.put("nltyp","A01");
|
// json.put("nlpla",waitPakOut.getNlpla());
|
json.put("arbpl","A01-01");
|
arr.add(json);
|
}
|
int action = 3;
|
if(waitPakOut.getAction()==1 && waitPakOut.getPrnstatus()==2) {
|
action = 1;
|
}
|
jsObj.put("trart", Integer.toString(action));
|
jsObj.put("item", arr);
|
byte[] buff = jsObj.toString().getBytes();
|
int buffLen = buff.length;
|
//创建连接
|
HttpURLConnection connection = null;
|
try {
|
// String input = "ZHANGX:654321";
|
// BASE64Encoder base = new BASE64Encoder();
|
// String encodedPassword = base.encode(input.getBytes("UTF-8"));
|
|
URL url = new URL(httpUrl);
|
connection = (HttpURLConnection) url.openConnection();
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setConnectTimeout(30000);
|
connection.setReadTimeout(30000);
|
connection.setRequestMethod("POST");
|
// connection.setUseCaches(false);
|
// connection.setInstanceFollowRedirects(true);
|
// connection.setRequestProperty("Content-Type","text/json;charset=gb2312");
|
connection.setRequestProperty("Cookie", session_value);
|
connection.setRequestProperty("Content-Type","application/json");
|
connection.setRequestProperty("Accept","application/json");
|
connection.setRequestProperty("Accept-Language","zh-CN,zh;q=0.9,en;q=0.8");
|
connection.setRequestProperty("Content-Length","" + buffLen);
|
// connection.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection.setRequestProperty("x-csrf-token",token);
|
|
//POST请求
|
OutputStream out = connection.getOutputStream();
|
out.write(buff);
|
out.close();
|
|
//读取响应
|
BufferedReader reader = new BufferedReader(new InputStreamReader(
|
connection.getInputStream()));
|
String lines;
|
StringBuffer sb = new StringBuffer("");
|
while ((lines = reader.readLine()) != null) {
|
lines = new String(lines.getBytes(), "utf-8");
|
sb.append(lines);
|
}
|
// System.out.println(sb.toString());
|
JSONObject json = JSONObject.fromObject(sb.toString());
|
String d = json.get("d").toString();
|
JSONObject jsonD = JSONObject.fromObject(d);
|
String Item = jsonD.get("item").toString();
|
JSONObject jsonItem = JSONObject.fromObject(Item);
|
String results = jsonItem.get("results").toString();
|
JSONArray array = JSONArray.fromObject(results);
|
|
if(array.size()>0) {
|
for(int i=0;i<array.size();i++){
|
JSONObject job = array.getJSONObject(i);
|
String zstatus = job.get("zstatus").toString();
|
// String message = job.get("message").toString();
|
String message="";
|
try {
|
message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
|
}catch(Exception em) {
|
}
|
if(zstatus.equals("s") || message.contains("已经完全提供") || message.contains("已确认")) {
|
// if(zstatus.equals("s")) {//上报SAP成功,转历史档
|
waitPakOut.setIo_status("Y");
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
waitPakOutService.moveToLog(waitPakOut);
|
}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
|
waitPakOut.setIo_status("X");
|
waitPakOut.setMemo(message);
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("SAP返回异常时，ASRS提交的json--" + jsObj.toString());
|
}
|
// System.out.println("zstatus信息.." + zstatus);
|
// System.out.println("message信息.." + message);
|
}
|
}
|
result = 1;
|
}catch (Exception e) {
|
waitPakOut.setIo_status("X");
|
waitPakOut.setMemo(e.getMessage());
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("出库通知档回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}finally{
|
if(connection!=null){
|
connection.disconnect();
|
}
|
}
|
}catch (Exception e) {
|
waitPakOut.setIo_status("X");
|
waitPakOut.setMemo(e.getMessage());
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("出库通知档回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}
|
return result;
|
}
|
|
/**
|
* 处理打印标签需求
|
*/
|
private void sendPickPrintCmd() {
|
try {
|
WaitPakOutBean waitPakOutBean = waitPakOutService.getWaitPakOutPrint();
|
if(waitPakOutBean!=null) {
|
String httpUrl = Constants.SAP_URL + "/sap/opu/odata/SAP/Z_WM_H5_SRV/ToConHeadSet";
|
int result = sendPrinCommand(httpUrl,waitPakOutBean);
|
}
|
}catch(Exception e) {
|
logger.error("SAP Error updateWaitPakOutData---" + e.getMessage());
|
}
|
}
|
|
/**
|
* 拣料站，调用SAP打印标签接口,action=2
|
*/
|
private int sendPrinCommand(String httpUrl,WaitPakOutBean waitPakOut) {
|
int result = 0;
|
// String token = getXCsrfToken(httpUrl);
|
String input = Constants.SAP_USER + ":" + Constants.SAP_PASSWORD;//"ZHANGX:654321";
|
BASE64Encoder base = new BASE64Encoder();
|
String encodedPassword;
|
String token="";
|
String session_value="";
|
|
HttpURLConnection connection1 = null;
|
try {
|
// logger.error("sendPrinCommand-----调用打印接口" + waitPakOut.getMaktx());
|
encodedPassword = base.encode(input.getBytes("UTF-8"));
|
URL url1 = new URL(httpUrl);
|
connection1 = (HttpURLConnection) url1.openConnection();
|
connection1.setDoOutput(true);
|
connection1.setDoInput(true);
|
connection1.setConnectTimeout(30000);
|
connection1.setReadTimeout(30000);
|
connection1.setRequestMethod("GET");
|
connection1.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection1.setRequestProperty("x-csrf-token","Fetch");
|
String sessionCookie = connection1.getHeaderField("Set-Cookie");
|
if(sessionCookie==null || sessionCookie.length()<1)
|
{
|
logger.error("调用打印接口，get请求获取cookie失败");
|
return result;
|
}
|
String[] sessionId = sessionCookie.split(";");
|
session_value = sessionId[0];
|
token = connection1.getHeaderField("x-csrf-token");
|
// Map<String, List<String>> map = connection1.getHeaderFields();
|
// token = map.get("x-csrf-token").toString();
|
} catch (Exception e1) {
|
logger.error("sendPrinCommand1-----调用打印接口请求cookie失败" + waitPakOut.getMaktx() + e1.getMessage());
|
e1.printStackTrace();
|
}finally{
|
if(connection1!=null){
|
connection1.disconnect();
|
}
|
}
|
|
try {
|
// logger.error("sendPrinCommand2-----开始调用打印接口" + waitPakOut.getMaktx());
|
JSONObject jsObj = new JSONObject();
|
JSONArray arr = new JSONArray();
|
for(int i=0;i<1;i++) {
|
JSONObject json = new JSONObject();
|
json.put("lgnum",waitPakOut.getLgnum());
|
json.put("tanum",Long.toString(waitPakOut.getTanum()));
|
json.put("tapos",Integer.toString(waitPakOut.getTapos()));
|
|
double nista = waitPakOut.getNista();
|
if(nista>0)
|
{
|
double vsolm = waitPakOut.getVsolm();
|
double ndifa = vsolm - nista;
|
json.put("nista",Double.toString(nista)); //实际数量
|
json.put("ndifa",Double.toString(ndifa)); //差异数量
|
}
|
json.put("altme",waitPakOut.getMeins());
|
json.put("nltyp","A01");
|
// json.put("nlpla",waitPakOut.getNlpla());
|
json.put("arbpl","A01-01");
|
arr.add(json);
|
}
|
jsObj.put("trart", "2");
|
jsObj.put("item", arr);
|
byte[] buff = jsObj.toString().getBytes();
|
int buffLen = buff.length;
|
//创建连接
|
HttpURLConnection connection = null;
|
try {
|
// String input = "ZHANGX:654321";
|
// BASE64Encoder base = new BASE64Encoder();
|
// String encodedPassword = base.encode(input.getBytes("UTF-8"));
|
|
URL url = new URL(httpUrl);
|
connection = (HttpURLConnection) url.openConnection();
|
connection.setDoOutput(true);
|
connection.setDoInput(true);
|
connection.setConnectTimeout(30000);
|
connection.setReadTimeout(30000);
|
connection.setRequestMethod("POST");
|
// connection.setUseCaches(false);
|
// connection.setInstanceFollowRedirects(true);
|
// connection.setRequestProperty("Content-Type","text/json;charset=gb2312");
|
connection.setRequestProperty("Cookie", session_value);
|
connection.setRequestProperty("Content-Type","application/json");
|
connection.setRequestProperty("Accept","application/json");
|
connection.setRequestProperty("Accept-Language","zh-CN,zh;q=0.9,en;q=0.8");
|
connection.setRequestProperty("Content-Length","" + buffLen);
|
// connection.setRequestProperty("Authorization", "Basic " + encodedPassword);
|
connection.setRequestProperty("x-csrf-token",token);
|
|
//POST请求
|
OutputStream out = connection.getOutputStream();
|
out.write(buff);
|
out.close();
|
// logger.error("sendPrinCommand3-----调用打印接口" + waitPakOut.getMaktx());
|
//读取响应
|
BufferedReader reader = new BufferedReader(new InputStreamReader(
|
connection.getInputStream()));
|
String lines;
|
StringBuffer sb = new StringBuffer("");
|
while ((lines = reader.readLine()) != null) {
|
lines = new String(lines.getBytes(), "utf-8");
|
sb.append(lines);
|
}
|
// System.out.println(sb.toString());
|
JSONObject json = JSONObject.fromObject(sb.toString());
|
String d = json.get("d").toString();
|
JSONObject jsonD = JSONObject.fromObject(d);
|
String Item = jsonD.get("item").toString();
|
JSONObject jsonItem = JSONObject.fromObject(Item);
|
String results = jsonItem.get("results").toString();
|
JSONArray array = JSONArray.fromObject(results);
|
logger.error("sendPrinCommand4-----调用打印接口" + waitPakOut.getMaktx());
|
if(array.size()>0) {
|
for(int i=0;i<array.size();i++){
|
JSONObject job = array.getJSONObject(i);
|
String zstatus = job.get("zstatus").toString();
|
// String message = job.get("message").toString();
|
String message="";
|
try {
|
message = java.net.URLDecoder.decode(job.get("message").toString(), "utf-8");
|
}catch(Exception em) {
|
}
|
if(zstatus.equals("s") || message.contains("已经完全提供")) {
|
// if(zstatus.equals("s")) {//上报SAP成功,转历史档
|
waitPakOut.setAction(1); //模式变为1单独确认
|
waitPakOut.setPrnstatus(2); //打印完成
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("sendPrinCommand5---调用打印接口成功，请求json数据--" + jsObj.toString());
|
logger.info("sendPrinCommand5---调用打印接口成功，返回json数据--" + sb.toString());
|
}else if(zstatus.equals("e")) {//上报SAP失败,更新io_status=X
|
waitPakOut.setPrnstatus(3); //打印失败
|
waitPakOut.setMemo(message);
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("sendPrinCommand6---调用打印接口失败，请求json数据--" + message);
|
}
|
}
|
}
|
result = 1;
|
}catch (Exception e) {
|
waitPakOut.setPrnstatus(3); //打印失败
|
waitPakOut.setMemo(e.getMessage());
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("sendPrinCommand7---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}finally{
|
if(connection!=null){
|
connection.disconnect();
|
}
|
}
|
}catch (Exception e) {
|
waitPakOut.setPrnstatus(3); //打印失败
|
waitPakOut.setMemo(e.getMessage());
|
waitPakOutService.upWaitPakOut(waitPakOut,0);
|
logger.error("sendPrinCommand8---调用打印接口回报异常--"+waitPakOut.getMatnr() + "---" + e.getMessage());
|
// System.out.println(e.getMessage());
|
}
|
return result;
|
}
|
|
/**
|
* 处理盘点通知档数据
|
*/
|
private void updateWaitCheckData() {
|
try {
|
// logger.info("waitCheck:" + count++);
|
}catch(Exception e) {
|
|
}
|
}
|
|
public static void main(String[] args) {
|
UpdateThread Thread1=new UpdateThread();
|
Thread mThread1=new Thread(Thread1,"线程1");
|
// Thread mThread2=new Thread(Thread1,"线程2");
|
// Thread mThread3=new Thread(Thread1,"线程3");
|
mThread1.start();
|
// mThread2.start();
|
// mThread3.start();
|
}
|
}
|
