|
|
@@ -9,6 +9,7 @@ import cn.hutool.core.util.XmlUtil;
|
|
|
import cn.hutool.json.JSONException;
|
|
|
import cn.hutool.json.JSONObject;
|
|
|
import cn.hutool.json.JSONUtil;
|
|
|
+import com.emato.file.tunnel.common.constant.MessageTypeEnum;
|
|
|
import com.emato.file.tunnel.common.dto.CustomsClearanceHandleDto;
|
|
|
import com.emato.file.tunnel.common.response.Result;
|
|
|
import com.emato.file.tunnel.config.properties.CPortProperties;
|
|
|
@@ -22,6 +23,7 @@ import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
|
|
|
import org.springframework.amqp.support.AmqpHeaders;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.messaging.handler.annotation.Header;
|
|
|
+import org.springframework.util.StringUtils;
|
|
|
|
|
|
import java.io.File;
|
|
|
import java.io.IOException;
|
|
|
@@ -72,7 +74,7 @@ public class ReportMessageListener implements MessageListener, ChannelAwareMessa
|
|
|
channel.basicAck(tag, false);
|
|
|
|
|
|
// 写入文件成功, 只有清单才发送, 发送清关时效性: 报文到达深关通目录时间
|
|
|
- if (cPortProperties.getCeb621()) {
|
|
|
+ if (StringUtils.hasLength(msgFileName) && msgFileName.contains(MessageTypeEnum.CEB621.getType())) {
|
|
|
sendClearance(orderSn);
|
|
|
}
|
|
|
|
lihuiming