package com.ld.igds.io.fzzy.command;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ld.igds.io.fzzy.ServerUtils;
|
import com.ld.igds.io.fzzy.dto.IoMessage;
|
import com.ld.igds.io.fzzy.dto.Req1001;
|
import com.ld.igds.io.fzzy.dto.Resp1002;
|
import com.ld.igds.io.request.QuantityRequest;
|
|
|
/**
|
* 命令生成
|
*
|
* @author vince
|
*/
|
public class CommandBuilder {
|
|
/**
|
* 下发配置
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build1001Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
Req1001 req1001 = new Req1001();
|
req1001.setHeight(request.getHeight().intValue());
|
req1001.setOrien(1);
|
req1001.setVoluWeight(request.getDensity().intValue());
|
req1001.setStorageType("01".equals(request.getDepotType()) ? 1 : 0);
|
|
req1001.setWeightAdd(request.getWeightAdd().intValue());
|
req1001.setVolumeAdd(request.getVolumeAdd().intValue());
|
if ("01".equals(request.getDepotType())) {
|
req1001.setStorageType(1);
|
req1001.setLength(Integer.parseInt((request.getLength() * 100.00) + ""));
|
req1001.setWidth(Integer.parseInt((request.getWidth() * 100.00) + ""));
|
} else {
|
req1001.setStorageType(0);
|
req1001.setRadius(Integer.parseInt((request.getWidth() * 100.00) + "")); //筒仓时候宽度当作半径
|
}
|
message.setContent(JSON.toJSONString(req1001));
|
message.setFunctionId(ServerUtils.FUNCTION_1001);
|
return message;
|
}
|
|
/**
|
* 回复时间
|
*
|
* @return
|
*/
|
public IoMessage build1002Message(IoMessage message) {
|
message.setFunctionId(ServerUtils.FUNCTION_1002);
|
Resp1002 resp1002 = new Resp1002();
|
resp1002.setTime(System.currentTimeMillis());
|
message.setContent(JSON.toJSONString(resp1002));
|
return message;
|
}
|
|
/**
|
* 回复登陆成功
|
*
|
* @return
|
*/
|
public IoMessage build1003Message(IoMessage message) {
|
message.setFunctionId(ServerUtils.FUNCTION_1003);
|
message.setContent(null);
|
return message;
|
}
|
|
/**
|
* 开始检测
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build2001Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
message.setFunctionId(ServerUtils.FUNCTION_2001);
|
return message;
|
}
|
|
/**
|
* 停止检测
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build2002Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
message.setFunctionId(ServerUtils.FUNCTION_2002);
|
return message;
|
}
|
|
/**
|
* 进度查询
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build2003Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
message.setFunctionId(ServerUtils.FUNCTION_2003);
|
return message;
|
}
|
|
/**
|
* 结果上报
|
*
|
* @param
|
* @return
|
*/
|
public IoMessage build2004Message(IoMessage message) {
|
message.setFunctionId(ServerUtils.FUNCTION_2004);
|
message.setContent(null);
|
return message;
|
}
|
|
/**
|
* 查询点位数据
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build2005Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
message.setFunctionId(ServerUtils.FUNCTION_2005);
|
return message;
|
}
|
|
/**
|
* 抓拍
|
*
|
* @param message
|
* @return
|
*/
|
public IoMessage build2006Message(IoMessage message) {
|
message.setFunctionId(ServerUtils.FUNCTION_2006);
|
message.setContent("");
|
return message;
|
}
|
|
/**
|
* 抓拍
|
*
|
* @param request
|
* @return
|
*/
|
public IoMessage build2006Message(QuantityRequest request) {
|
IoMessage message = new IoMessage();
|
// 调整信息
|
buildInfo(message, request);
|
message.setFunctionId(ServerUtils.FUNCTION_2006);
|
return message;
|
}
|
|
/**
|
* 心跳返回
|
*
|
* @param message
|
* @return
|
*/
|
public IoMessage build2007Message(IoMessage message) {
|
//message.setFunctionId(ServerUtils.FUNCTION_2007);
|
return message;
|
}
|
|
public void buildInfo(IoMessage message, QuantityRequest request) {
|
message.setSn(request.getSn());
|
message.setOrderId(ServerUtils.createOrderId());
|
message.setSign(ServerUtils.SIGN_DEFAULT);
|
message.setResult(ServerUtils.RESP_0);
|
message.setVersion(ServerUtils.VERSION_1);
|
}
|
|
/**
|
* 根据生成的命令，进行调整
|
*
|
* @param message
|
*/
|
public String build(IoMessage message) {
|
StringBuffer hexSb = new StringBuffer();
|
hexSb.append(ServerUtils.MSG_BEGIN);
|
hexSb.append(JSONObject.toJSONString(message));
|
hexSb.append((ServerUtils.MSG_END));
|
return hexSb.toString();
|
}
|
|
|
private static CommandBuilder instance = new CommandBuilder();
|
|
private CommandBuilder() {
|
}
|
|
public static CommandBuilder getInstance() {
|
return instance;
|
}
|
|
|
}
|
