开启梦天的推送测试

blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/feign/MtOrderMainClinet.java

@@ -38,30 +38,31 @@ public class MtOrderMainClinet implements IMtOrderMainClinet {
 	private RabbitTemplate rabbitTemplate;
 	@Autowired
 	private IMtFactoryDataService mtFactoryDataService;
+
 	@Override
 	@GetMapping(TOP)
 	public R sendOrderPackageScan(String orderPackageCode, String operationTime, String distributionContactId, String distributionContactCode, String destinationWarehouse) throws NoSuchAlgorithmException, JsonProcessingException {
 		log.info(">>>>>>> 签收扫描 start");
 
-		Map<String,Object> map = new HashMap<>();
+		Map<String, Object> map = new HashMap<>();
 
 		JSONObject jsonObject = new JSONObject();
-		jsonObject.put("orderPackageCode",orderPackageCode);
-		jsonObject.put("operationTime",operationTime);
-		jsonObject.put("distributionContactId",distributionContactId);
-		jsonObject.put("distributionContactCode",distributionContactCode);
-		jsonObject.put("destinationWarehouse",destinationWarehouse);
-		map.put("messageData",jsonObject.toJSONString());
+		jsonObject.put("orderPackageCode", orderPackageCode);
+		jsonObject.put("operationTime", operationTime);
+		jsonObject.put("distributionContactId", distributionContactId);
+		jsonObject.put("distributionContactCode", distributionContactCode);
+		jsonObject.put("destinationWarehouse", destinationWarehouse);
+		map.put("messageData", jsonObject.toJSONString());
 
-		log.info(">>>>>>>>>>>>>>>>> 司机扫描 {}", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss.SSS"));
+		log.info(">>>>>>>>>>>>>>>>> 司机扫描 {}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS"));
 
 
-	/*	rabbitTemplate.convertAndSend(RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_EXCHANGE,RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_ROUTING, map,message -> {
+		rabbitTemplate.convertAndSend(RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_EXCHANGE, RabbitConstant.MT_BUSINESS_DATA_2_FACTORY_ROUTING, map, message -> {
 			message.getMessageProperties()
 				.setHeader("x-delay", 5000);
 			return message;
-		});*/
-		log.info(">>>>>>>>>>>>>>>>> 司机扫描 {}", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss.SSS"));
+		});
+		log.info(">>>>>>>>>>>>>>>>> 司机扫描 {}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS"));
 
 
 		return R.success("");
@@ -72,16 +73,16 @@ public class MtOrderMainClinet implements IMtOrderMainClinet {
 	@PostMapping(SENDRECEIVEINFOBYNEWSYSTEM)
 	public R sendReceiveInfoByNewSystem(MtReceiveDTO mtReceiveDTO) throws NoSuchAlgorithmException, JsonProcessingException {
 		log.info(">>>>>>> 文员复核 start");
-		Map<String,Object> map = new HashMap<>();
+		Map<String, Object> map = new HashMap<>();
 		String mes = JSONObject.toJSONString(mtReceiveDTO);
-		map.put("messageData",mes);
-		log.info(">>>>>>>>>>>>>>>>> 文员复核 {}", DateUtil.format(new Date(),"yyyy-MM-dd HH:mm:ss.SSS"));
+		map.put("messageData", mes);
+		log.info(">>>>>>>>>>>>>>>>> 文员复核 {}", DateUtil.format(new Date(), "yyyy-MM-dd HH:mm:ss.SSS"));
 
-	/*	rabbitTemplate.convertAndSend(RabbitConstant.MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_EXCHANGE,RabbitConstant.MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_ROUTING, map,message -> {
+		rabbitTemplate.convertAndSend(RabbitConstant.MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_EXCHANGE, RabbitConstant.MT_BUSINESS_DATA_CLERK_CHECK_2_FACTORY_ROUTING, map, message -> {
 			message.getMessageProperties()
 				.setHeader("x-delay", 5000);
 			return message;
-		});*/
+		});
 
 		return R.success("");