升级接口

src/main/java/com/steerinfo/dil/mapper/AmsNotUploadedEasMapper.java

@@ -4,6 +4,7 @@ import com.steerinfo.dil.model.AmsNotUploadedEas;
 import com.steerinfo.framework.mapper.IBaseMapper;
 import org.apache.ibatis.annotations.Mapper;
 
+
 import java.util.List;
 import java.util.Map;
 

src/main/java/com/steerinfo/dil/service/impl/KDWebserviceUtil.java → src/main/java/com/steerinfo/dil/service/impl/KDWebServiceServiceImpl.java

@@ -14,19 +14,20 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 
+
 import java.util.List;
 import java.util.Map;
 
 /**
  * @ author    :TXF
- * @ time      :2022/2/10 10:07
+ * @ time      :2022/2/14 21:02
  */
 
 @Service
-public class KDWebserviceUtil {
+public class KDWebServiceServiceImpl {
 
     @Autowired
-    private AmsNotUploadedEasMapper amsNotUploadedEasMapper;
+    AmsNotUploadedEasMapper amsNotUploadedEasMapper;
 
     /**
      *
@@ -111,9 +112,9 @@ public class KDWebserviceUtil {
     public int addNotUploadedEASResult(Map<String, Object> map) {
         AmsNotUploadedEas amsNotUploadedEas = new AmsNotUploadedEas();
         //查询该订单是否已存在
-        String orderId = (String) map.get("orderId");
+        String orderId = String.valueOf(map.get("orderId"));
         String isExistsOrderId = amsNotUploadedEasMapper.getIsExistsOrderId(orderId);
-        if(isExistsOrderId == null){
+        if(isExistsOrderId != null){
             return 0;
         }
         amsNotUploadedEas.setId(orderId);
@@ -158,71 +159,3 @@ public class KDWebserviceUtil {
 
 }
 
-
-
-
-
-
-/**
- * 封装的访问webservice的工具类:（有局限性，数据量小的xml报文可用，较大则会出现stackoverflow的异常）
- *
- * @param reqXML
- *            请求的xml
- * @param endPoint
- *            webservice的路径除去?wsdl:例如：http://1.202.235.66:7002/webService/PartsService（没有?wsdl）
- * @param namespace
- *            名称空间
- * @param method
- *            方法名称
- * @return	返回报文结果(xml)
- */
-//    public static String loadWebService(String reqXML, String endPoint, String namespace, String method) {
-//        String responseXml = "";
-//        RPCServiceClient serviceClient = null;
-//        try {
-//            /* 调用理赔系统的接口 */
-//            String nameSpace = namespace;
-//            QName qname = new QName(nameSpace, method);
-//            serviceClient = new RPCServiceClient();
-//            Options options = serviceClient.getOptions();
-//            EndpointReference targetEPR = new EndpointReference(endPoint);
-//            options.setTo(targetEPR);
-//            options.setTimeOutInMilliSeconds(30000);
-//            Object[] rtnObjs = serviceClient.invokeBlocking(qname, new Object[] { reqXML },
-//                    new Class[] { String.class });
-//            responseXml = rtnObjs[0].toString();
-//        } catch (Exception e) {
-//            e.toString();
-//        }
-//        return responseXml;
-//    }
-
-/**
- * axis方式访问webservice
- *
- * @param
- *            请求的xml的报文
- * @param
- *            webservice的wsdl地址,例如：http://1.202.235.66:7002/webService/PartsService?wsdl
- * @param
- *            调用方法的命名空间
- * @param
- *            调用的方法名
- * @return 返回调用的报文(xml)
- *
- */
-//    public static String invokRemoveWSDLByAxis(String reqXML, String endPoint, String namespace, String method) {
-//        String responseXML = "";
-//        Service service = new Service();
-//        try {
-//            Call call = (Call) service.createCall();
-//            call.setTargetEndpointAddress(endPoint);
-//            call.setOperationName(new javax.xml.namespace.QName(namespace, method));
-//            call.addParameter("arg0", XMLType.XSD_STRING, ParameterMode.IN);
-//            call.setReturnType(XMLType.XSD_STRING);
-//            responseXML = (String) call.invoke(new Object[] { reqXML });
-//        } catch (Exception e) {
-//            e.printStackTrace();
-//        }
-//        return responseXML;
-//    }

src/main/java/com/steerinfo/dil/service/impl/TmstruckWeightResultServiceImpl.java

@@ -34,6 +34,9 @@ import java.math.BigDecimal;
 @Service(value = "tmstruckWeightResultService")
 public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultService {
 
+    @Autowired
+    KDWebServiceServiceImpl KDWebServiceServiceImpl;
+
     @Autowired
     TmstruckWeightResultMapper tmstruckWeightResultMapper;
 
@@ -471,7 +474,7 @@ public class TmstruckWeightResultServiceImpl implements ITmstruckWeightResultSer
         //将map数据全放进mesMap中
         map.putAll(mesMap);
         //访问金蝶接口
-        new KDWebserviceUtil().sendMesToKD(map);
+        KDWebServiceServiceImpl.sendMesToKD(map);
     }
 
     /**

src/main/resources/com/steerinfo/dil/mapper/AmsNotUploadedEasMapper.xml

@@ -529,7 +529,7 @@
   <select id="getAllNotUploadedEasMes" resultType="java.util.Map">
     select
            t.ORDER_ID "orderId",
-           t.NO "no",
+           t.NO "No",
            t.RESULT_POUND_NO    "resultPoundNo",
            t.CAPACITY_NUMBER    "capacityNumber",
            t.RESULT_CROSS_CALCULATE_NUMBER  "resultCrossCalculateNumber",