package com.uas.eis.task;

import com.alibaba.fastjson.JSON;
import com.uas.eis.dao.BaseDao;
import com.uas.eis.dao.SqlRowList;
import com.uas.eis.task.httpclient.X5JsonHttpClient;
import com.uas.eis.utils.Configuration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;
import java.text.SimpleDateFormat;
import java.util.*;

/**
 * @Author chenwei
 * @Date 2022-06-14
 */
@Component
@EnableAsync
@EnableScheduling
public class SyncProductWIPTask {

    @Autowired
    private BaseDao baseDao;
    @Resource(name = "configuration")
    private Configuration configuration;

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    @Scheduled(cron = "0 0/1 * * * ?")
    public void SyncProductWIP() {
        System.out.println("13434");
        X5JsonHttpClient x5JsonHttpClient = new X5JsonHttpClient(configuration.getX5appid(),configuration.getX5appkey(),configuration.getX5ProductWIPUrl(),baseDao);
        Map<String,Object> data = new HashMap<>();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        String format = sf.format(new Date());
        System.out.println("format:"+format);
        data.put("request_time",format);
        List<Map<String,Object>> list = new ArrayList<>();
        String Sql="select * from (select rownum rn, A.* from (select ct_code,CUSTOMTABLEDETAIL.* from CUSTOMTABLE left join CUSTOMTABLEDETAIL on ct_id=cd_ctid " +
                "                 where  ct_caller='XiaoMiProductWIP' order by cd_detno) A) where rn<=2 and rn>=1";
        SqlRowList rs = baseDao.queryForRowSet(Sql);
        while (rs.next()){
            Map<String,Object> map = new HashMap<>();
            map.put("factory_code",configuration.getX5vendercode());
            map.put("component_code",rs.getGeneralString("cd_varchar50_1"));
            map.put("process",rs.getGeneralString("cd_varchar50_2"));
            map.put("line_id",rs.getGeneralString("cd_varchar50_3"));
            map.put("site_name",rs.getGeneralString("cd_varchar50_4"));
            map.put("wip_num",rs.getInt("cd_number_1"));
            map.put("project_name",rs.getGeneralString("cd_varchar50_5"));
            map.put("product_code",rs.getGeneralDouble("cd_varchar50_6"));
            map.put("fact_date",rs.getGeneralString("cd_varchar50_7"));
            list.add(map);
        }
        data.put("data",list);
        System.out.println("1啊"+data);
        System.out.println("2啊"+ JSON.toJSONString(data));
        if(list.size()>0){
            x5JsonHttpClient.post(data,"ProductWIP");
        }
    }
}