|
@@ -9,6 +9,7 @@ import java.util.Map;
|
|
|
import java.util.concurrent.locks.Lock;
|
|
|
import java.util.concurrent.locks.ReentrantLock;
|
|
|
|
|
|
+import com.fasterxml.jackson.core.JsonProcessingException;
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper;
|
|
|
import com.iamberry.wechat.core.entity.admin.ShopSystemRule;
|
|
|
import com.iamberry.wechat.core.entity.order.Order;
|
|
@@ -142,6 +143,22 @@ public class MQTask implements InitializingBean {
|
|
|
logger.info("------------task invoke success-----------");
|
|
|
}
|
|
|
|
|
|
+ /*public static void main(String[] args) {
|
|
|
+ Map<String, Object> orderData = new HashMap<String, Object>();
|
|
|
+ Map<String, String> requestData = new HashMap<String, String>();
|
|
|
+ com.fasterxml.jackson.databind.ObjectMapper mapper = new ObjectMapper();
|
|
|
+ orderData.put("orderId", 11);
|
|
|
+ orderData.put("sd_id", 1);
|
|
|
+ requestData.put("app_act", "rst.trade.logistics.get");
|
|
|
+ String orderDataStr = null;
|
|
|
+ try {
|
|
|
+ orderDataStr = mapper.writeValueAsString(orderData);
|
|
|
+ } catch (JsonProcessingException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ requestData.put("info", orderDataStr);
|
|
|
+ System.out.println("app_act==:" + requestData.get("app_act") + "info==:" + requestData.get("info"));
|
|
|
+ }*/
|
|
|
/**
|
|
|
* 根据订单号拉取物流信息
|
|
|
* @throws Exception
|