jsowell-charger-web/jsowell-quartz/src/main/java/com/jsowell/quartz/task/JsowellTask.java

package com.jsowell.quartz.task;

import com.jsowell.common.util.DateUtils;
import com.jsowell.pile.domain.OrderBasicInfo;
import com.jsowell.pile.service.IOrderBasicInfoService;
import com.jsowell.pile.service.IPileBillingTemplateService;
import com.jsowell.pile.vo.web.BillingTemplateVO;
import com.jsowell.service.OrderService;
import com.jsowell.service.PileRemoteService;
import org.apache.commons.collections4.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.util.Date;
import java.util.List;

@Component("jsowellTask")
public class JsowellTask {

	private final Logger log = LoggerFactory.getLogger(JsowellTask.class);

	@Autowired
	private IOrderBasicInfoService orderBasicInfoService;

	@Autowired
	private OrderService orderService;

	@Autowired
	private IPileBillingTemplateService pileBillingTemplateService;

	@Autowired
	private PileRemoteService pileRemoteService;

	/**
	 * 关闭15分钟未支付的订单
	 * close15MinutesOfUnpaidOrders
	 */
	public void close15MinutesOfUnpaidOrders() {
		// log.info("关闭15分钟未支付的订单");
		orderBasicInfoService.close15MinutesOfUnpaidOrders();
	}

	/**
	 * 关闭启动失败的订单
	 * 订单支付成功，在15分钟内未启动，
	 */
	public void closeStartFailedOrder() {
		// 查询出最近2天支付成功，并且订单状态为未启动的订单
		String startTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, DateUtils.addDays(new Date(), -2));
		String endTime = DateUtils.parseDateToStr(DateUtils.YYYY_MM_DD_HH_MM_SS, new Date());
		orderBasicInfoService.closeStartFailedOrder(startTime, endTime);
	}

	/**
	 * 查询预约充电的订单并启动
	 */
	public void appointmentOrderStart() {
		// 查询出 已支付 设置预约充电 未启动 的订单
		LocalDateTime now = LocalDateTime.now();
		List<OrderBasicInfo> list = orderBasicInfoService.getAppointmentOrder(now);
		if (CollectionUtils.isEmpty(list)) {
			return;
		}
		for (OrderBasicInfo orderInfo : list) {
			String pileSn = orderInfo.getPileSn();
			// 发送启动充电指令前，再次下发计费模板
			BillingTemplateVO billingTemplateVO = pileBillingTemplateService.selectBillingTemplateDetailByPileSn(pileSn);
			if (billingTemplateVO != null) {
				pileRemoteService.publishPileBillingTemplate(pileSn, billingTemplateVO);
			}
			// 发送启动指令
			pileRemoteService.remoteStartCharging(pileSn, orderInfo.getConnectorCode(), orderInfo.getTransactionCode(), orderInfo.getPayAmount());
		}
	}
}