|
|
@@ -8,11 +8,9 @@ import com.simple.common.ResultData; |
|
|
import com.simple.domain.po.*; |
|
|
import com.simple.domain.po.*; |
|
|
import com.simple.enums.EnumCarCmd; |
|
|
import com.simple.enums.EnumCarCmd; |
|
|
import com.simple.enums.EnumCarVendor; |
|
|
import com.simple.enums.EnumCarVendor; |
|
|
|
|
|
import com.simple.enums.EnumCouponSendType; |
|
|
import com.simple.enums.EnumETCPCode; |
|
|
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.ETCPUtil; |
|
|
import com.simple.utils.TJDCarUtil; |
|
|
import com.simple.utils.TJDCarUtil; |
|
|
import io.swagger.annotations.ApiOperation; |
|
|
import io.swagger.annotations.ApiOperation; |
|
|
@@ -23,6 +21,7 @@ import org.springframework.web.bind.annotation.*; |
|
|
|
|
|
|
|
|
import java.util.Date; |
|
|
import java.util.Date; |
|
|
import java.util.HashMap; |
|
|
import java.util.HashMap; |
|
|
|
|
|
import java.util.List; |
|
|
import java.util.Map; |
|
|
import java.util.Map; |
|
|
|
|
|
|
|
|
@RestController |
|
|
@RestController |
|
|
@@ -47,6 +46,9 @@ public class WxCarCallBackController extends BaseController |
|
|
@Autowired |
|
|
@Autowired |
|
|
WxCarCmdLogService wxCarCmdLogService; |
|
|
WxCarCmdLogService wxCarCmdLogService; |
|
|
|
|
|
|
|
|
|
|
|
@Autowired |
|
|
|
|
|
WxCouponSendService wxCouponSendService; |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|
* ETCP 车辆入场通知 |
|
|
* ETCP 车辆入场通知 |
|
|
* { |
|
|
* { |
|
|
@@ -74,6 +76,7 @@ public class WxCarCallBackController extends BaseController |
|
|
wxCarCmdLog.setUpdateDate(currentDate); |
|
|
wxCarCmdLog.setUpdateDate(currentDate); |
|
|
|
|
|
|
|
|
String etcpParkId = paramMap.get("parkId"); |
|
|
String etcpParkId = paramMap.get("parkId"); |
|
|
|
|
|
String tenantId = "456"; |
|
|
WxPark parkQ = new WxPark(); |
|
|
WxPark parkQ = new WxPark(); |
|
|
parkQ.setVendorType(EnumCarVendor.CAR_ETCP.getCode()); |
|
|
parkQ.setVendorType(EnumCarVendor.CAR_ETCP.getCode()); |
|
|
parkQ.setParkId(etcpParkId); |
|
|
parkQ.setParkId(etcpParkId); |
|
|
@@ -82,6 +85,7 @@ public class WxCarCallBackController extends BaseController |
|
|
logger.error("etcpParkInCallback: ETCP车场未找到"+ etcpParkId); |
|
|
logger.error("etcpParkInCallback: ETCP车场未找到"+ etcpParkId); |
|
|
//return new Result(ErrorCode.CAR_PARK_NOT_FOUND.getCode(), "ETCP车场未找到"+ etcpParkId); |
|
|
//return new Result(ErrorCode.CAR_PARK_NOT_FOUND.getCode(), "ETCP车场未找到"+ etcpParkId); |
|
|
} else { |
|
|
} else { |
|
|
|
|
|
tenantId = park.getTenantId(); |
|
|
wxCarCmdLog.setTenantId(park.getTenantId()); |
|
|
wxCarCmdLog.setTenantId(park.getTenantId()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
@@ -92,7 +96,22 @@ public class WxCarCallBackController extends BaseController |
|
|
return new Result(ErrorCode.DB_FAIL.getCode(), "入库错误"+paramMap.toString()); |
|
|
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<WxCUserCar> 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()); |
|
|
return new Result(EnumETCPCode.SUCCESS.getCode(), EnumETCPCode.SUCCESS.getMessage()); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
|