|
|
@ -7,14 +7,15 @@ import com.yxt.anrui.base.common.enums.VehicleState; |
|
|
|
import com.yxt.anrui.buscenter.api.busdepositvehicle.AppBusDepositVehicleDetailVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busdepositvehicle.AppBusDepositVehicleListVo; |
|
|
|
import com.yxt.anrui.buscenter.api.busmaindeposit.BusMainDeposit; |
|
|
|
import com.yxt.messagecenter.api.message.MessageFeign; |
|
|
|
import com.yxt.messagecenter.api.message.OrderListMessageDto; |
|
|
|
import com.yxt.messagecenter.api.message.OrderMesageDto; |
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
import org.springframework.scheduling.annotation.Scheduled; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
import java.text.SimpleDateFormat; |
|
|
|
import java.util.Calendar; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.List; |
|
|
|
import java.util.*; |
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
/** |
|
|
@ -29,9 +30,11 @@ public class ScheduledService { |
|
|
|
private BusDepositVehicleService busDepositVehicleService; |
|
|
|
@Autowired |
|
|
|
private BaseVehicleFeign baseVehicleFeign; |
|
|
|
@Autowired |
|
|
|
private MessageFeign messageFeign; |
|
|
|
|
|
|
|
@Scheduled(cron = "0 0 0 * * ?") |
|
|
|
// @Scheduled(cron = "0 0/5 12 * * ?")
|
|
|
|
// @Scheduled(cron = "0 0/5 16 * * ?")
|
|
|
|
public void remindVehicle() { |
|
|
|
Date now = new Date(); |
|
|
|
//获取当前时间
|
|
|
@ -46,6 +49,8 @@ public class ScheduledService { |
|
|
|
//查询简易订单-车辆预定中
|
|
|
|
//查询修改日期包含该日期的已经通过的简易订车单
|
|
|
|
List<BusMainDeposit> strList = busDepositVehicleService.selectListByState(tomorrow); |
|
|
|
OrderMesageDto dto = new OrderMesageDto(); |
|
|
|
List<OrderListMessageDto> orderListMessageDtoList = new ArrayList<>(); |
|
|
|
for (BusMainDeposit strDeposit : strList) { |
|
|
|
String sid = strDeposit.getSid(); |
|
|
|
AppBusDepositVehicleDetailVo appBusDepositVehicleDetailVo = busDepositVehicleService.getReserveCarDetails(sid).getData(); |
|
|
@ -55,7 +60,29 @@ public class ScheduledService { |
|
|
|
busMainDepositUpdateQuery.setLockedState(VehicleState.LockEnum.UN_LOCK.getCode()); |
|
|
|
busMainDepositUpdateQuery.setLockedStateValue(VehicleState.LockEnum.UN_LOCK.getRemarks()); |
|
|
|
baseVehicleFeign.updateMainDepositByVinNo(busMainDepositUpdateQuery); |
|
|
|
//推送解锁提醒
|
|
|
|
OrderListMessageDto orderListMessageDto = new OrderListMessageDto(); |
|
|
|
orderListMessageDto.setBusinessSid(strDeposit.getSid());//业务sid
|
|
|
|
List<String> createBySidList = new ArrayList<>(); |
|
|
|
createBySidList.add(strDeposit.getCreateBySid()); |
|
|
|
orderListMessageDto.setCreateBySid(createBySidList);//接收人sid
|
|
|
|
Map<String, Object> appMaps = new HashMap<>(); |
|
|
|
appMaps.put("virtualOrderSid", strDeposit.getSid());//简易订单sid
|
|
|
|
orderListMessageDto.setModuleName("业务"); |
|
|
|
orderListMessageDto.setMsgTitle("简易订单-车辆预定解锁提醒"); |
|
|
|
List<String> vinList = appBusDepositVehicleDetailVo.getVehicleList().stream().map(v->v.getVin().substring(v.getVin().length()-8)).collect(Collectors.toList()).stream().distinct().collect(Collectors.toList()); |
|
|
|
String msgContent = "您在简易订单-车辆预定中预定的车架号:"+String.join(",",vinList)+"的"+vinList.size()+"台车现在已经解锁,如需继续预定请重新申请或在销售订单走销售流程。"; |
|
|
|
orderListMessageDto.setMsgContent(msgContent); |
|
|
|
orderListMessageDto.setMsgTargetUri("com.anrui.android.plugin.autoservice.activity.DetailVirtualOrderReserveCarActivity"); |
|
|
|
orderListMessageDto.setAppMap(appMaps); |
|
|
|
orderListMessageDto.setModuleSid("e25e13b5-f2ed-421f-bdb3-6f2eca2a3028"); |
|
|
|
orderListMessageDto.setApp_type("2"); |
|
|
|
orderListMessageDtoList.add(orderListMessageDto); |
|
|
|
|
|
|
|
} |
|
|
|
dto.setList(orderListMessageDtoList); |
|
|
|
messageFeign.sendOrderMessage(dto); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|