更改

gly-base-core/src/main/java/cn/com/taiji/core/repo/jpa/log/YgzInterfaceLogRepo.java

@@ -2,6 +2,7 @@ package cn.com.taiji.core.repo.jpa.log;
 
 import cn.com.taiji.common.repo.jpa.AbstractJpaRepo;
 import cn.com.taiji.core.entity.dict.InterfaceStatus;
+import cn.com.taiji.core.entity.dict.ygz.NioTransferType;
 import cn.com.taiji.core.entity.dict.ygz.YgzSendStatus;
 import cn.com.taiji.core.entity.log.YgzInterfaceLog;
 import org.springframework.data.jpa.repository.Query;
@@ -14,4 +15,5 @@ public interface YgzInterfaceLogRepo extends AbstractJpaRepo<YgzInterfaceLog, St
     YgzInterfaceLog findBy(String uniqueId, String ifCode, InterfaceStatus status, YgzSendStatus sendStatus);
     @Query(" from YgzInterfaceLog where sendStatus = ?1 and resendTimes < 5")
     List<YgzInterfaceLog> listBySendStatusLessThen5Times(YgzSendStatus sendStatus);
+    List<YgzInterfaceLog> findBySendStatusAndNioTransferType(YgzSendStatus sendStatus, NioTransferType nioTransferType);
 }

gly-base-core/src/main/java/cn/com/taiji/core/repo/jpa/ygz/DaspOfflineHasSendRepo.java

@@ -14,6 +14,8 @@ import java.util.List;
 
 public interface DaspOfflineHasSendRepo extends AbstractJpaRepo<DaspOfflineHasSend, String> {
 
+    List<DaspOfflineHasSend> findBySuccessAndOfflineSendType(Boolean success, OfflineSendType offlineSendType);
+
     @Query(" from DaspOfflineHasSend where ygzOperation=?1 and offlineSendType=?2 and currentSendStatus=?3 and sendTimes<5 ")
     List<DaspOfflineHasSend> listBy(Operation ygzOperation, OfflineSendType offlineSendType, int currentSendStatus);
     @Query(" from DaspOfflineHasSend where id=?1 and offlineSendType=?2 ")

zhywpt-service-ias/src/main/java/cn/com/taiji/ias/manager/ygz/nio/YgzParameterCorrectUtil.java

@@ -357,7 +357,7 @@ public class YgzParameterCorrectUtil extends AbstractManager {
         vehicleUpload.setAxleCount(axleCount);
         vehicleUpload.setAxleDistance(axleDistance);
         vehicleUpload.setAxleType(axleType);
-        vehicleUpload.setContact(contact);
+        vehicleUpload.setContact(contact.replace("(","").replace(")","").replace("（","").replace("）",""));
         vehicleUpload.setCustomer(customerInfo);
         vehicleUpload.setDataSource(dataSource);
         vehicleUpload.setEngineNum(engineNum);