package com.yami.trading.admin.task.cms;

import cn.hutool.core.bean.BeanUtil;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.yami.trading.admin.facade.MachineTranslationService;
import com.yami.trading.bean.cms.Infomation;
import com.yami.trading.common.config.ThreadPoolComponent;
import com.yami.trading.common.util.StringUtils;
import com.yami.trading.dao.cms.InfomationMapper;
import com.yami.trading.huobi.hobi.internal.XueQiuDataServiceImpl;
import com.yami.trading.service.cms.InfomationService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.util.List;

@Component
public class XueQiuInfomationGet {
    @Autowired
    private ThreadPoolComponent threadPoolComponent;
    @Autowired
    private InfomationService infomationService;

    @Autowired
    private MachineTranslationService translationService;
    @Autowired
    private XueQiuDataServiceImpl xueQiuDataService;

//    @Scheduled(cron = "0 0/30 * ? * *")  雪球
//    public void crawl(){
//        xueQiuDataService.getInformation();
//    }

    @Scheduled(cron = "0 */5 * ? * *")
    public void translate(){
        QueryWrapper<Infomation> queryWrapper = new QueryWrapper<>();
        queryWrapper.isNull("translate");
        queryWrapper.eq("lang", "zh-CN");
        List<Infomation> list = infomationService.list(queryWrapper);
        for(Infomation infomation : list){

            threadPoolComponent.getExecutor().execute(() ->{
                String description = infomation.getDescription();
                String source = infomation.getSource();
                Infomation infomationEn = BeanUtil.copyProperties(infomation, Infomation.class);
                infomationEn.setUuid(null);
                if(StringUtils.isNotEmpty(description)){
                    String translate = translationService.translate(description);
                    if(translate == null){
                        return;
                    }
                    infomationEn.setDescription(translate);
                }
                if(StringUtils.isNotEmpty(source)){
                    String translate = translationService.translate(source);
                    if(translate == null){
                        return;
                    }
                    infomationEn.setSource(translate);
                }
                infomationEn.setLang("en");
                infomationService.save(infomationEn);
                infomation.setTranslate("1");
                infomationService.updateById(infomation);
            });

        }

    }
}