通知回调接口

kmall-admin/src/main/java/com/kmall/admin/controller/OrderProcessRecordExternalController.java

@@ -2,6 +2,7 @@ package com.kmall.admin.controller;
 
 import com.alibaba.fastjson.JSON;
 import com.kmall.admin.entity.OrderProcessRecordEntity;
+import com.kmall.admin.entity.OrderProcessRecordHkEntity;
 import com.kmall.admin.fromcomm.service.SysConfigService;
 import com.kmall.admin.haikong.utils.Message;
 import com.kmall.admin.haikong.utils.OutRequestMessage;
@@ -42,7 +43,7 @@ public class OrderProcessRecordExternalController {
     @PostMapping("/hkNotice")
     public Message hknoticeMsg(@RequestBody OutRequestMessage outRequestMessage) {
         try{
-            List<OrderProcessRecordEntity> orderProcessRecordList  = JacksonUtil.fromStringJson(outRequestMessage.getData(), List.class);
+            OrderProcessRecordHkEntity orderProcessRecordHkEntity  = JacksonUtil.fromStringJson(outRequestMessage.getData(), OrderProcessRecordHkEntity.class);
             //签名验证
             String strSign =outRequestMessage.getSign()==null?"":outRequestMessage.getSign();
             String timestamp = outRequestMessage.getTimestamp()==null?"":outRequestMessage.getTimestamp();
@@ -55,6 +56,7 @@ public class OrderProcessRecordExternalController {
             if(!strSign.equals(checkMsg(timestamp,key))){
                 return Message.error("1003","签名错误");
             }
+            List<OrderProcessRecordEntity> orderProcessRecordList = orderProcessRecordHkEntity.getRecordHkList();
             if(orderProcessRecordList.size()>dataNum){
                 return Message.error("1003","通知数据最多"+dataNum+"条，请分批通知");
             }
@@ -73,11 +75,5 @@ public class OrderProcessRecordExternalController {
         }
     }
 
-    @RequestMapping("/users")
-    public String test() {
-        return "qwqwq";
-    }
-
-
 
 }

kmall-admin/src/main/java/com/kmall/admin/entity/OrderProcessRecordHkEntity.java

@@ -0,0 +1,14 @@
+package com.kmall.admin.entity;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+@Data
+public class OrderProcessRecordHkEntity implements Serializable{
+
+    private static final long serialVersionUID = 1L;
+
+    List<OrderProcessRecordEntity> recordHkList;
+}

kmall-admin/src/main/java/com/kmall/admin/haikong/utils/Message.java

@@ -18,7 +18,6 @@ public class Message implements Serializable {
 
 	private static final long serialVersionUID = 4081619286503989887L;
 
-	private boolean isSuccess;
 
 	/**
 	 * 消息代码 , 由使用者自由发挥
@@ -28,10 +27,6 @@ public class Message implements Serializable {
 	 * 消息内容体 , 由使用者自由发挥
 	 */
 	private String msg;
-	/**
-	 * 扩展
-	 */
-	private Object extend;
 
 	private Message() {
 	}
@@ -42,12 +37,6 @@ public class Message implements Serializable {
 	public String getMsg() {
 		return msg;
 	}
-	public Object getExtend() {
-		return extend;
-	}
-	public boolean isSuccess() {
-		return isSuccess;
-	}
 
 	public static Builder builder() {
 		return new Builder();
@@ -141,10 +130,8 @@ public class Message implements Serializable {
 
 		public Message build() {
 			Message message = new Message();
-			message.isSuccess = this.isSuccess;
 			message.code = this.code;
 			message.msg = this.msg;
-			message.extend = this.extend;
 			return message;
 		}
 

kmall-admin/src/main/java/com/kmall/admin/haikong/utils/ResponseMessage.java

@@ -48,7 +48,7 @@ public class ResponseMessage {
     public static ResponseMessage transResponseMessage(Object object) {
         if (object instanceof Message) {
             Message message = (Message) object;
-            return new Builder(message.getCode(), message.getMsg(), message.getExtend(), Object.class).build();
+            return new Builder(message.getCode(), message.getMsg(), Object.class).build();
         } else if (object instanceof Result) {
             Result result = (Result) object;
             return new Builder(result.getCode(), result.getMsg(), result.getData(), Object.class).build();

kmall-admin/src/main/java/com/kmall/admin/service/impl/OrderProcessRecordServiceImpl.java

@@ -173,7 +173,7 @@ public class OrderProcessRecordServiceImpl implements OrderProcessRecordService
                orderProcessRecordDao.updateHkNoticeMsg(orderProcessRecordList);
            }
        }catch (Exception e){
-           logger.error("saveHkNoticeMsg-------[海控通知回调接口插入错误]"+ JSON.toJSONString(orderProcessRecordList));
+           logger.error("saveHkNoticeMsg---海控通知回调接口插入错误="+ JSON.toJSONString(orderProcessRecordList),e);
            return Message.success("1001","参数错误");
        }
         return Message.success("1002","通知成功");

kmall-admin/src/main/resources/mybatis/mapper/OrderProcessRecordDao.xml

@@ -326,7 +326,7 @@ select
 		from mall_order_process_record
 		where
 		<if test="list != null">
-			and order_sn in
+			 order_sn in
 			<foreach collection="list" item="item" open="(" separator="," close=")">
 				#{item.orderSn}
 			</foreach>