From 76018156590b08e78afc95b9fd366fa5253c8ec7 Mon Sep 17 00:00:00 2001 From: "Stormeye.Wu" Date: Tue, 4 Sep 2018 16:18:07 +0800 Subject: [PATCH] =?UTF-8?q?[=E5=81=9C=E8=BD=A6=E5=8F=91=E5=88=B8][?= =?UTF-8?q?=E6=96=B0=E5=A2=9E]:=E5=81=9C=E8=BD=A6=E5=8F=91=E5=88=B8?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9E=E7=8E=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../controller/WxCarCallBackController.java | 29 ++++++++++++--- .../com/simple/enums/EnumCouponSendType.java | 37 +++++++++++++++++++ 2 files changed, 61 insertions(+), 5 deletions(-) create mode 100644 mallinkService/src/main/java/com/simple/enums/EnumCouponSendType.java diff --git a/mallinkAdmin/src/main/java/com/simple/controller/WxCarCallBackController.java b/mallinkAdmin/src/main/java/com/simple/controller/WxCarCallBackController.java index 3307ae6d4..87ced4cb8 100644 --- a/mallinkAdmin/src/main/java/com/simple/controller/WxCarCallBackController.java +++ b/mallinkAdmin/src/main/java/com/simple/controller/WxCarCallBackController.java @@ -8,11 +8,9 @@ import com.simple.common.ResultData; import com.simple.domain.po.*; import com.simple.enums.EnumCarCmd; import com.simple.enums.EnumCarVendor; +import com.simple.enums.EnumCouponSendType; import com.simple.enums.EnumETCPCode; -import com.simple.service.WxCUserCarService; -import com.simple.service.WxCarCmdLogService; -import com.simple.service.WxMerchantService; -import com.simple.service.WxParkService; +import com.simple.service.*; import com.simple.utils.ETCPUtil; import com.simple.utils.TJDCarUtil; import io.swagger.annotations.ApiOperation; @@ -23,6 +21,7 @@ import org.springframework.web.bind.annotation.*; import java.util.Date; import java.util.HashMap; +import java.util.List; import java.util.Map; @RestController @@ -47,6 +46,9 @@ public class WxCarCallBackController extends BaseController @Autowired WxCarCmdLogService wxCarCmdLogService; + @Autowired + WxCouponSendService wxCouponSendService; + /** * ETCP 车辆入场通知 * { @@ -74,6 +76,7 @@ public class WxCarCallBackController extends BaseController wxCarCmdLog.setUpdateDate(currentDate); String etcpParkId = paramMap.get("parkId"); + String tenantId = "456"; WxPark parkQ = new WxPark(); parkQ.setVendorType(EnumCarVendor.CAR_ETCP.getCode()); parkQ.setParkId(etcpParkId); @@ -82,6 +85,7 @@ public class WxCarCallBackController extends BaseController logger.error("etcpParkInCallback: ETCP车场未找到"+ etcpParkId); //return new Result(ErrorCode.CAR_PARK_NOT_FOUND.getCode(), "ETCP车场未找到"+ etcpParkId); } else { + tenantId = park.getTenantId(); wxCarCmdLog.setTenantId(park.getTenantId()); } @@ -92,7 +96,22 @@ public class WxCarCallBackController extends BaseController return new Result(ErrorCode.DB_FAIL.getCode(), "入库错误"+paramMap.toString()); } - // TODO 发起 营销 -- 短信 + // 停车发券 + String carNumber = paramMap.get("plateNumber"); + if (!StringUtils.isBlank(carNumber)) { + // 根据车牌查找用户 + WxCUserCar userCarQ = new WxCUserCar(); + userCarQ.setTenantId(tenantId); + userCarQ.setCarNumber(carNumber); + userCarQ.setVendorType(EnumCarVendor.CAR_ETCP.getCode()); + // TODO 可能多用户关联同一张车牌 + List userCarList = wxCUserCarService.getList(userCarQ); + for(WxCUserCar userCar: userCarList) { + wxCouponSendService.sendCouponToUser(tenantId, userCar.getCUserId(), EnumCouponSendType.CAR_STOP.getCode()); + } + } + + return new Result(EnumETCPCode.SUCCESS.getCode(), EnumETCPCode.SUCCESS.getMessage()); } diff --git a/mallinkService/src/main/java/com/simple/enums/EnumCouponSendType.java b/mallinkService/src/main/java/com/simple/enums/EnumCouponSendType.java new file mode 100644 index 000000000..4cca85f76 --- /dev/null +++ b/mallinkService/src/main/java/com/simple/enums/EnumCouponSendType.java @@ -0,0 +1,37 @@ +package com.simple.enums; + +/** + * Created by Stormeye on 2018/08/09. + */ +public enum EnumCouponSendType { + + // 2:停车发券 3:核销发券 + CAR_STOP(2, "停车发券"), + COUPON_VERIFY(3, "核销发券") + ; + + public static EnumCouponSendType getEnum(Integer code) { + for (EnumCouponSendType value : values()) { + if (value.getCode().equals(code)) { + return value; + } + } + return null; + } + + private Integer code; + private String message; + + EnumCouponSendType(Integer code, String message) { + this.code = code; + this.message = message; + } + + public Integer getCode() { + return code; + } + + public String getMessage() { + return message; + } +}