|
...
|
...
|
@@ -7,11 +7,20 @@ import com.sy.crossDomain.buildBarCode; |
|
|
|
import com.sy.model.GatherInfo;
|
|
|
|
import com.sy.model.LandBusinessTypeList;
|
|
|
|
import com.sy.model.LandRoadVe;
|
|
|
|
import com.sy.model.RESMESSAGE;
|
|
|
|
import com.sy.service.LandBusListService;
|
|
|
|
import com.sy.service.LandRoadVeService;
|
|
|
|
import com.sy.service.ResMessageService;
|
|
|
|
import com.sy.socket.CommandClient;
|
|
|
|
import com.sy.utils.FileTool;
|
|
|
|
import org.apache.http.HttpEntity;
|
|
|
|
import org.apache.http.HttpResponse;
|
|
|
|
import org.apache.http.client.HttpClient;
|
|
|
|
import org.apache.http.client.methods.HttpGet;
|
|
|
|
import org.apache.http.impl.client.DefaultHttpClient;
|
|
|
|
import org.apache.http.util.EntityUtils;
|
|
|
|
import org.apache.log4j.Logger;
|
|
|
|
import org.apache.log4j.PropertyConfigurator;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.stereotype.Component;
|
|
|
|
|
|
...
|
...
|
@@ -19,13 +28,13 @@ import javax.annotation.PostConstruct; |
|
|
|
import java.io.BufferedReader;
|
|
|
|
import java.io.IOException;
|
|
|
|
import java.io.InputStreamReader;
|
|
|
|
import java.math.BigDecimal;
|
|
|
|
import java.net.MalformedURLException;
|
|
|
|
import java.net.URL;
|
|
|
|
import java.net.URLConnection;
|
|
|
|
import java.text.DecimalFormat;
|
|
|
|
import java.text.NumberFormat;
|
|
|
|
import java.text.ParseException;
|
|
|
|
import java.util.Date;
|
|
|
|
import java.util.List;
|
|
|
|
import java.util.Map;
|
|
|
|
|
|
...
|
...
|
@@ -40,6 +49,9 @@ public class LogicOperation { |
|
|
|
@Autowired
|
|
|
|
private LandRoadVeService veService;
|
|
|
|
|
|
|
|
@Autowired
|
|
|
|
private ResMessageService resMessageService;
|
|
|
|
|
|
|
|
private static LogicOperation logic;
|
|
|
|
|
|
|
|
//读取配置文件里的载重与称重的可控范围
|
|
...
|
...
|
@@ -48,16 +60,19 @@ public class LogicOperation { |
|
|
|
//逻辑判断后的结果定义
|
|
|
|
private static String PERMITTHOUGH = "直接放行";
|
|
|
|
private static String GROWSSEXCETION = "禁止通行，重量不在可控范围";
|
|
|
|
private static String NORECORD = "车辆未备案";
|
|
|
|
private static String NORECORD = "车辆未备案或者识别错误，车牌号：";
|
|
|
|
private static String INPUTSTATION = "此车辆未做进站申请";
|
|
|
|
private static String ENTERSTATION = "此车辆未做出站申请";
|
|
|
|
private static String ISVALID = "二维码已失效或者此车辆未做出入申请";
|
|
|
|
private static String ISVALID = "二维码数据异常，请使用正确的二维码数据";
|
|
|
|
private static String ERRORWT="出起始场站的重量和进目的场站的重量不一致";
|
|
|
|
private static String IEPORSE="无相对应进出场申请";
|
|
|
|
|
|
|
|
@PostConstruct
|
|
|
|
public void init() {
|
|
|
|
logic = this;
|
|
|
|
logic.listService = this.listService;
|
|
|
|
logic.veService = this.veService;
|
|
|
|
logic.resMessageService = this.resMessageService;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
...
|
...
|
@@ -65,60 +80,157 @@ public class LogicOperation { |
|
|
|
* @Result 计算卡口采集数据并发送报文
|
|
|
|
*/
|
|
|
|
public static boolean operation(GatherInfo info) {
|
|
|
|
PropertyConfigurator.configure("config/log4j.properties");
|
|
|
|
boolean result = false;
|
|
|
|
if(info.getBarcode()==null || info.getBarcode().length()<=0 ){
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
BigDecimal grosswt = info.getGrosswt();
|
|
|
|
//转为double类型
|
|
|
|
double growssWt = grosswt.doubleValue();
|
|
|
|
String ietype = info.getIetype();
|
|
|
|
List<LandBusinessTypeList> lists = null;
|
|
|
|
double growssWt = info.getGrosswt().doubleValue();
|
|
|
|
String vaName = info.getVename();
|
|
|
|
if(vaName==null || vaName.length()<=0 ){
|
|
|
|
if (vaName.length() <= 0) {
|
|
|
|
CommandClient.Client(info, NORECORD + vaName);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
LandRoadVe ve = logic.veService.selectByFrameNo(vaName);
|
|
|
|
LandBusinessTypeList list = logic.listService.selectForOne(info.getVename(),info.getBarcode(),info.getAreaid
|
|
|
|
(),info.getChnlno(),info.getIetype());
|
|
|
|
if("0".equals(list.getIsvalid())){
|
|
|
|
if (ve == null) {
|
|
|
|
CommandClient.Client(info, NORECORD + vaName);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
LandBusinessTypeList list = logic.listService.selectForOne(info.getVename(), info.getBarcode(), info.getAreaid
|
|
|
|
(), info.getChnlno(), info.getIetype());
|
|
|
|
if(list == null) {
|
|
|
|
CommandClient.Client(info, IEPORSE);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
//判断是否失效
|
|
|
|
if ("0".equals(list.getIsvalid())) {
|
|
|
|
//获取总重
|
|
|
|
double goodsWt = 0.0;
|
|
|
|
if (list.getMasterList()!=null || list.getMasterList().length()>0 ) {
|
|
|
|
goodsWt = GoodsWt(list.getMasterList(), info.getIetype());
|
|
|
|
if (list.getMasterList() != null || list.getMasterList().length() > 0) {
|
|
|
|
String type = null;
|
|
|
|
if ("进口提货".equals(list.getBusinesstype()) || "分拨业务".equals(list.getBusinesstype())) {
|
|
|
|
type = "I";
|
|
|
|
}
|
|
|
|
if ("出口送货".equals(list.getBusinesstype()) || "调拨业务".equals(list.getBusinesstype())) {
|
|
|
|
type = "E";
|
|
|
|
}
|
|
|
|
logger.info("=======================>>>>>>>>>>" + type + "<<<<<<<<<<========================");
|
|
|
|
goodsWt = GoodsWt(list.getMasterList(), type);
|
|
|
|
}
|
|
|
|
//车自重
|
|
|
|
double selfWt = Double.parseDouble(ve.getSelfWt());
|
|
|
|
if (sendBw(info, growssWt, selfWt, goodsWt)) {
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if (!logic.checkFlag(growssWt, (selfWt+goodsWt))) {
|
|
|
|
List<LandBusinessTypeList> typeLists = logic.listService.selectMessageId(list.getMassageId());
|
|
|
|
for (int i = 0; i < typeLists.size(); i++) {
|
|
|
|
|
|
|
|
if ("进口提货".equals(list.getBusinesstype())) {
|
|
|
|
if ("E".equals(list.getTurnoverflag())) {
|
|
|
|
if ("I".equals(typeLists.get(i).getTurnoverflag()) && typeLists.get(i).getContrastflag() != null) {
|
|
|
|
selfWt = typeLists.get(i).getAislewt() > 1 ? typeLists.get(i).getAislewt() : selfWt;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if ("出口送货".equals(list.getBusinesstype())){
|
|
|
|
if ("E".equals(list.getTurnoverflag())) {
|
|
|
|
if ("I".equals(typeLists.get(i).getTurnoverflag()) && typeLists.get(i).getContrastflag() != null) {
|
|
|
|
if("1".equals(list.getIsfull())){
|
|
|
|
if(list.getMasterList().length()>0){
|
|
|
|
selfWt = typeLists.get(i).getAislewt()-Double.parseDouble(typeLists.get(i).getRemark());
|
|
|
|
}else {
|
|
|
|
selfWt=growssWt;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
if(list.getBusinesstype().endsWith("流转")){
|
|
|
|
if(list.getMasterList().length()>0){
|
|
|
|
if ("E".equals(list.getTurnoverflag())) {
|
|
|
|
if ("I".equals(typeLists.get(i).getTurnoverflag()) && typeLists.get(i).getContrastflag() != null) {
|
|
|
|
selfWt = typeLists.get(i).getAislewt() > 1 ? typeLists.get(i).getAislewt() : selfWt;
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if ("I".equals(list.getTurnoverflag())) {
|
|
|
|
if ("E".equals(typeLists.get(i).getTurnoverflag()) && typeLists.get(i).getContrastflag() != null) {
|
|
|
|
if(!logic.checkFlag(growssWt,typeLists.get(i).getAislewt())){
|
|
|
|
logger.info("-------->>>>>>>>出起始场站的重量和进目的场站的总量不一致<<<<<<<<--------");
|
|
|
|
CommandClient.Client(info, ERRORWT);
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
boolean check = checkResult(growssWt, selfWt, goodsWt);
|
|
|
|
boolean checkMainfest = logic.checkManifest(list.getMasterList());
|
|
|
|
boolean checkResult = false;
|
|
|
|
|
|
|
|
if ("E".equals(list.getTurnoverflag())) {
|
|
|
|
checkResult = checkMainfest || check;
|
|
|
|
} else {
|
|
|
|
checkResult = check || checkMainfest;
|
|
|
|
}
|
|
|
|
|
|
|
|
//宽进
|
|
|
|
if ("I".equals(info.getIetype())) {
|
|
|
|
if (check == false && checkResult == false) {
|
|
|
|
checkResult = true;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
logger.info("重量校验结果："+check+"，运单校验结果："+checkMainfest+",最终校验结果："+checkResult);
|
|
|
|
|
|
|
|
if (sendBw(info, checkResult)) {
|
|
|
|
if ("I".equals(info.getIetype())) {
|
|
|
|
System.out.println(info.getGrosswt().doubleValue());
|
|
|
|
list.setAislewt(info.getGrosswt().doubleValue());
|
|
|
|
list.setUpdateDate(new Date());
|
|
|
|
list.setRemark(String.format("%.1f",goodsWt));
|
|
|
|
list.setContrastflag("已进站");
|
|
|
|
logic.checkData(list);
|
|
|
|
} else {
|
|
|
|
list.setAislewt(info.getGrosswt().doubleValue());
|
|
|
|
list.setUpdateDate(new Date());
|
|
|
|
list.setRemark(String.format("%.1f",goodsWt));
|
|
|
|
list.setContrastflag("已出站");
|
|
|
|
logic.checkData(list);
|
|
|
|
}
|
|
|
|
logic.listService.updateById(list);
|
|
|
|
int row = logic.listService.updateById(list);
|
|
|
|
System.out.println(row);
|
|
|
|
List<LandBusinessTypeList> businessTypeLists = logic.listService.selectByBarcode(info.getBarcode());
|
|
|
|
int count = 0;
|
|
|
|
for(int i=0; i<businessTypeLists.size(); i++){
|
|
|
|
for (int i = 0; i < businessTypeLists.size(); i++) {
|
|
|
|
String flag1 = businessTypeLists.get(i).getContrastflag();
|
|
|
|
if(flag1 != null){
|
|
|
|
if (flag1 != null) {
|
|
|
|
count++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if("货物流转".equals(list.getBusinesstype())){
|
|
|
|
if(count==4){
|
|
|
|
if (list.getBusinesstype().indexOf("业务") > 0) {
|
|
|
|
if (count == 4) {
|
|
|
|
buildBarCode.cancleBarCode(vaName);
|
|
|
|
logic.listService.updateByBarcode(info.getBarcode());
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
if(count==2){
|
|
|
|
} else {
|
|
|
|
if (count == 2) {
|
|
|
|
buildBarCode.cancleBarCode(vaName);
|
|
|
|
logic.listService.updateByBarcode(info.getBarcode());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result = true;
|
|
|
|
}
|
|
|
|
}else{
|
|
|
|
CommandClient.Client(info, ISVALID);
|
|
|
|
} else {
|
|
|
|
sendError(info);
|
|
|
|
logger.error("------->>>>>>>二维码数据异常，请使用正确的二维码数据<<<<<<<-----");
|
|
|
|
}
|
|
|
|
|
|
|
|
return result;
|
|
|
|
}
|
|
|
|
|
|
...
|
...
|
@@ -136,20 +248,21 @@ public class LogicOperation { |
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 校验载重和称重是否在合理的范围
|
|
|
|
*
|
|
|
|
* @Param grossWt 地磅称重
|
|
|
|
* @Param wt 车辆自重
|
|
|
|
* @Param goodsWt 货物总重
|
|
|
|
* @Result 获取运单重量
|
|
|
|
*/
|
|
|
|
//校验载重和称重是否在合理的范围
|
|
|
|
public static boolean checkResult(double grossWt, double wt, double goodsWt) {
|
|
|
|
DecimalFormat df=new DecimalFormat("0.00");
|
|
|
|
DecimalFormat df = new DecimalFormat("0.00");
|
|
|
|
boolean flag = false;
|
|
|
|
double result = 0.0;
|
|
|
|
if (goodsWt > 0) {
|
|
|
|
result = Double.parseDouble(df.format(Math.abs((goodsWt+wt-grossWt)/grossWt)));
|
|
|
|
result = Double.parseDouble(df.format(Math.abs((goodsWt + wt - grossWt)) / grossWt));
|
|
|
|
} else {
|
|
|
|
result = Double.parseDouble(df.format(Math.abs((grossWt - wt)/grossWt)));
|
|
|
|
result = Double.parseDouble(df.format(Math.abs((grossWt - wt)) / grossWt));
|
|
|
|
}
|
|
|
|
if (result <= valueDob()) {
|
|
|
|
flag = true;
|
|
...
|
...
|
@@ -173,6 +286,31 @@ public class LogicOperation { |
|
|
|
return sum;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 查询运单是否全部放行
|
|
|
|
*
|
|
|
|
* @param manifestList
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public boolean checkManifest(String manifestList) {
|
|
|
|
if (manifestList.length() < 1) return false;
|
|
|
|
manifestList = manifestList.replace("-", "");
|
|
|
|
String[] maifest = manifestList.split(",");
|
|
|
|
boolean flag = false;
|
|
|
|
int count = 0;
|
|
|
|
for (int i = 0; i < maifest.length; i++) {
|
|
|
|
RESMESSAGE resmessage = logic.resMessageService.selectByManifest(maifest[i]);
|
|
|
|
if(resmessage !=null){
|
|
|
|
if ("11".equals(resmessage.getResponsecode())) {
|
|
|
|
count++;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (count == maifest.length) {
|
|
|
|
flag = true;
|
|
|
|
}
|
|
|
|
return flag;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* @Param waybill 主单号
|
|
...
|
...
|
@@ -180,7 +318,9 @@ public class LogicOperation { |
|
|
|
* @Result 获取运单重量
|
|
|
|
*/
|
|
|
|
public static double getGrossWt(String waybill, String imp) {
|
|
|
|
String url = "http://tjfx.15miaoo.com:8003/tj/orig/orig?waybill=" + waybill + "&imp=" + imp;
|
|
|
|
// logger.info("进入获取重量action");
|
|
|
|
String url = "http://10.50.3.64:8080/tj/orig/orig?waybill=" + waybill + "&imp=" + imp;
|
|
|
|
// String url = "http://tjfx.15miaoo.com:8003/tj/orig/orig=" + waybill + "&imp=" + imp;
|
|
|
|
StringBuilder json = new StringBuilder();
|
|
|
|
Map map = null;
|
|
|
|
double bg = 0;
|
|
...
|
...
|
@@ -192,37 +332,121 @@ public class LogicOperation { |
|
|
|
while ((inputLine = in.readLine()) != null) {
|
|
|
|
json.append(inputLine);
|
|
|
|
}
|
|
|
|
// logger.info("返回数据：" + json);
|
|
|
|
JSONArray array = JSONArray.parseArray(json.toString());
|
|
|
|
for (int i = 0; i < array.size(); i++) {
|
|
|
|
map = JSON.parseObject(array.getString(i));
|
|
|
|
if (map.get("receiptinformation").toString().startsWith("41301") || map.get("receiptinformation")
|
|
|
|
.toString().startsWith("41106")) {
|
|
|
|
bg = Double.parseDouble((String) map.get("totalweight"));
|
|
|
|
return bg;
|
|
|
|
System.out.println(map);
|
|
|
|
if(map.containsKey("receiptinformation")){
|
|
|
|
if (map.get("receiptinformation").toString().startsWith("41301") || map.get("receiptinformation")
|
|
|
|
.toString().startsWith("41106") || map.get("receiptinformation")
|
|
|
|
.toString().startsWith("31301") || map.get("receiptinformation")
|
|
|
|
.toString().startsWith("31106") || map.get("receiptinformation")
|
|
|
|
.toString().indexOf("提运单放行")!=-1) {
|
|
|
|
bg = Double.parseDouble((String) map.get("totalweight"));
|
|
|
|
logger.info("for循环取重量：" + bg);
|
|
|
|
return bg;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
// logger.info("访问返回的数据重量：" + bg);
|
|
|
|
in.close();
|
|
|
|
} catch (MalformedURLException e) {
|
|
|
|
e.getMessage();
|
|
|
|
// logger.info(e.toString());
|
|
|
|
} catch (IOException e) {
|
|
|
|
e.getMessage();
|
|
|
|
// logger.info(e.toString());
|
|
|
|
}
|
|
|
|
return bg;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 给码头发送卡口数据
|
|
|
|
*
|
|
|
|
* @param stationCode
|
|
|
|
* @param carNo
|
|
|
|
* @param IEtype
|
|
|
|
*/
|
|
|
|
public static void sendData(String stationCode, String carNo, boolean IEtype) {
|
|
|
|
String url = "http://10.50.3.73:8080/air-api/car/channelCar?stationCode=" + stationCode + "&carNo=" + carNo + "&isPickup=" + IEtype;
|
|
|
|
try {
|
|
|
|
HttpClient httpClient = new DefaultHttpClient();
|
|
|
|
HttpGet httpGet = new HttpGet(url);
|
|
|
|
HttpResponse httpResponse = httpClient.execute(httpGet);
|
|
|
|
HttpEntity entity = httpResponse.getEntity();
|
|
|
|
String entityStr = EntityUtils.toString(entity);
|
|
|
|
logger.info("------------>>>>>>>>>>>>>>发送车辆信息：{stationCode：" + stationCode + ",carNo:" + carNo + ",isPickup:" + IEtype + "}");
|
|
|
|
logger.info("------------>>>>>>>>>>>>>>响应返回内容:" + entityStr + "<<<<<<<<<<<<-----------");
|
|
|
|
} catch (Exception e) {
|
|
|
|
logger.info(e.toString());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 给码头发送卡口数据
|
|
|
|
*
|
|
|
|
* @param list
|
|
|
|
*/
|
|
|
|
public void checkData(LandBusinessTypeList list) {
|
|
|
|
String sationCode = null;
|
|
|
|
boolean flag = false;
|
|
|
|
if ("出口送货".equals(list.getBusinesstype()) || "出口流转".equals(list.getBusinesstype())) {
|
|
|
|
flag = false;
|
|
|
|
}
|
|
|
|
if ("进口提货".equals(list.getBusinesstype()) || "进口流转".equals(list.getBusinesstype())) {
|
|
|
|
flag = true;
|
|
|
|
}
|
|
|
|
if ("4604000000".equals(list.getEndstation())) {
|
|
|
|
if ("I".equals(list.getTurnoverflag())) {
|
|
|
|
sationCode = "HK05";
|
|
|
|
} else {
|
|
|
|
sationCode = "HK06";
|
|
|
|
}
|
|
|
|
}
|
|
|
|
sendData(sationCode, list.getTrailerFrameNo(), flag);
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 校验重量并发送报文
|
|
|
|
*/
|
|
|
|
|
|
|
|
public static boolean sendBw(GatherInfo info, double growsswWt, double selfWt, double goodsWt) {
|
|
|
|
public static boolean sendBw(GatherInfo info, boolean check) {
|
|
|
|
boolean flag = false;
|
|
|
|
if (checkResult(growsswWt, selfWt, goodsWt)) {
|
|
|
|
if (check) {
|
|
|
|
CommandClient.Client(info, PERMITTHOUGH);
|
|
|
|
logger.info("=============>>>>>>>>放行报文发送成功<<<<<<<<<==============");
|
|
|
|
flag = true;
|
|
|
|
} else {
|
|
|
|
CommandClient.Client(info, GROWSSEXCETION);
|
|
|
|
logger.info("=============>>>>>>>>重量异常报文发送成功<<<<<<<<<==============");
|
|
|
|
}
|
|
|
|
return flag;
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 排除当前系统问题发送错误commandInfo
|
|
|
|
*/
|
|
|
|
public static void sendError(GatherInfo info) {
|
|
|
|
CommandClient.Client(info, ISVALID);
|
|
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 判断空车车与地磅称重是否在合理范围
|
|
|
|
*
|
|
|
|
* @param grossWt
|
|
|
|
* @param wt
|
|
|
|
* @return
|
|
|
|
*/
|
|
|
|
public boolean checkFlag(double grossWt, double wt) {
|
|
|
|
DecimalFormat df = new DecimalFormat("0.00");
|
|
|
|
boolean flag = false;
|
|
|
|
double reult = Double.parseDouble(df.format(Math.abs((grossWt - wt)) / grossWt));
|
|
|
|
if (reult <= valueDob()) {
|
|
|
|
flag = true;
|
|
|
|
}
|
|
|
|
return flag;
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
} |
...
|
...
|
|
