From a6c3a9292668792766b293c8bb45ae34bdb3fa7e Mon Sep 17 00:00:00 2001 From: zhaowg3 Date: Wed, 9 Aug 2017 16:38:03 +0800 Subject: [PATCH] 增加消息队列发送 --- src/main/java/com/zteits/irain/portal/web/irain/UpdateFreeBerthController.java | 11 +++++++++++ 1 file changed, 11 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zteits/irain/portal/web/irain/UpdateFreeBerthController.java b/src/main/java/com/zteits/irain/portal/web/irain/UpdateFreeBerthController.java index e9f8338..e69162d 100644 --- a/src/main/java/com/zteits/irain/portal/web/irain/UpdateFreeBerthController.java +++ b/src/main/java/com/zteits/irain/portal/web/irain/UpdateFreeBerthController.java @@ -20,6 +20,8 @@ import com.alibaba.fastjson.JSONObject; import com.clouds.common.cache.park.ParkingLotCacheUtil; import com.clouds.common.cache.sys.SysCodeValueCacheUtil; import com.clouds.common.constants.CodeValKindEnum; +import com.clouds.common.constants.RedisKeyEnum; +import com.clouds.common.redis.RedisCacheUtil; import com.clouds.common.utils.ResultUtils; import com.clouds.common.web.vo.BizResultVO; import com.google.common.collect.Lists; @@ -62,6 +64,8 @@ public class UpdateFreeBerthController { private ParkLotIdleBerthsService parkLotIdleBerthsService; @Autowired private ParkingLotQueryService parkingLotQueryService; + @Autowired + private RedisCacheUtil redisCacheUtil; @ApiOperation("更新空闲车位总数") @@ -105,6 +109,13 @@ public class UpdateFreeBerthController { updaterequest.setSysCode(sysCode); int freeBerths = parkLotIdleBerthsService.updateAndGetIdleBerthByParkNo(updaterequest.getInoutTime(), updaterequest.getPlNo(), updaterequest.getType(), updaterequest.getFromType(), updaterequest.getFreeBerths()); logger.info("调用后场服务:更新车位总数", freeBerths); + //消息队列 + JSONObject jsonObject = new JSONObject(); + //空闲车位数 + jsonObject.put("freeBerths", (Integer)entry.getValue()); + //停车场编号 + jsonObject.put("plNo", entry.getKey()); + redisCacheUtil.convertAndSend(RedisKeyEnum.PARK_FREEBERTH_PLNO_FREEBERTH_TOPIC.key(),jsonObject); } logger.info("特殊处理-针对水岸天街左右更新空闲车位总数结束"); return new BizResultVO().setData(true); -- libgit2 0.21.4