package com.qs.serve.task;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.qs.serve.modules.tzc.common.TzPolicyItemStatus;
import com.qs.serve.modules.tzc.entity.TzcPolicyItem;
import com.qs.serve.modules.tzc.service.TzcPolicyApplicationService;
import com.qs.serve.modules.tzc.service.TzcPolicyItemService;
import com.qs.serve.modules.tzc.service.TzcPolicyService;
import lombok.AllArgsConstructor;
import org.springframework.stereotype.Component;
import java.util.List;
/**
 * 政策同步方法
 * @author YenHex
 * @since 2023/3/11
 */
@Component
@AllArgsConstructor
public class TzcPolicyTask {

    private TzcPolicyService policyService;
    private TzcPolicyItemService policyItemService;
    private TzcPolicyApplicationService policyApplicationService;

    /**
     * 同步数据到销路通
     */
    public void syncPolicyToXlt(){
        LambdaQueryWrapper<TzcPolicyItem> itemLqw = new LambdaQueryWrapper<>();
        itemLqw.select(TzcPolicyItem::getId);
        itemLqw.eq(TzcPolicyItem::getPolicyItemStatus,TzPolicyItemStatus.Status_1_PassSuccess);
        List<TzcPolicyItem> policyItemList = policyItemService.list(itemLqw);
        for (TzcPolicyItem policyItem : policyItemList) {
            policyApplicationService.syncPolicyItem(policyItem.getId());
        }
    }

}