uas-eis/src/main/java/com/uas/eis/task/SampleApplyTask.java

package com.uas.eis.task;

import com.uas.eis.beans.result.CrmQueryResult;
import com.uas.eis.dao.BaseDao;
import com.uas.eis.dao.SqlRowList;
import com.uas.eis.manager.CommonManager;
import com.uas.eis.utils.Constant;
import com.uas.eis.utils.DateUtil;
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 java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

@Component
@EnableAsync
@EnableScheduling
public class SampleApplyTask {

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

    @Autowired
    private BaseDao baseDao;
    @Autowired
    private CommonManager commonManager;

    @Scheduled(cron = "*/10 * * * * ?")
    public void syncSampleApply() {
        try {
            List<String> field_values = new ArrayList<>();
            SqlRowList rs = baseDao.queryForRowSet("select ml_syncTime from (select * from FXXKDockingErrorlog where 1=2 and nvl(ML_TYPE,' ')='样品申请主表下载' and ML_SYNCTIME is not null order by ml_date desc) where rownum=1");
            if(rs.next()){
                String ml_syncTime = rs.getGeneralString("ml_syncTime");
                field_values.add(ml_syncTime);
                //样品申请主表下载
                CrmQueryResult crmQueryResult = commonManager.queryCommon("create_time", field_values, "GT", "create_time", true, 5, "object_83m40__c", true);
                int errorCode = crmQueryResult.getErrorCode();
                if(errorCode == 0){
                    Map<String, Object> data = crmQueryResult.getData();
                    List<Map<String, Object>> dataList = (List<Map<String,Object>>) data.get("dataList");
                    //m:成功条数 n:失败条数
                    int m=0,n=0;
                    if(dataList.size()>0){
                        //最后(即最近)一次同步时间
                        Long create_time_Last = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("create_time").toString()).toPlainString());
                        for (int i = 0; i < dataList.size(); i++) {
                            Object _id = dataList.get(i).get("_id");
                            Object name = dataList.get(i).get("name");
                            SimpleDateFormat sdf = new SimpleDateFormat(Constant.YMD_HMS);
                            if(baseDao.checkIf("ProdInOutApply", "pi_code='" + name + "'")){
                                baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'样品申请编号已存在','样品申请主表下载','"+name+"')");
                                logger.info("异常信息：样品申请编号已存在");
                                n++;
                                continue;
                            }
                            try {
                                Object cu_code = baseDao.getFieldDataByCondition("customer", "max(cu_code) cu_code", "CU_FXXKID='" + dataList.get(i).get("field_l6W5b__c") + "'");
                                String cuCode =cu_code == null ? "" : cu_code.toString();

                                Object life_status = dataList.get(i).get("life_status");
                                Object record_type = dataList.get(i).get("record_type");
                                String lifeStatus = "normal".equals(life_status) ? "正常": (life_status==null? "" : life_status.toString());
                                String recordType = "default__c".equals(record_type) ? "预设业务类型": (record_type==null? "" : record_type.toString());
                                //负责人编号、名称
                                Map<String,Object> owner__r =(Map<String,Object>) dataList.get(i).get("owner__r");
                                Object owner_code = baseDao.getFieldDataByCondition("employee", "max(em_code) em_code", "em_name='" + owner__r.get("name") + "'");
                                //创建人编号、名称
                                Map<String,Object> created_by__r =(Map<String,Object>) dataList.get(i).get("created_by__r");
                                Object created_by_code = baseDao.getFieldDataByCondition("employee", "max(em_code) em_code", "em_name='" + created_by__r.get("name") + "'");
                                //最后更新人编号、名称
                                Map<String,Object> last_modified_by__r =(Map<String,Object>) dataList.get(i).get("last_modified_by__r");
                                Object last_modified_by_code = baseDao.getFieldDataByCondition("employee", "max(em_code) em_code", "em_name='" + last_modified_by__r.get("name") + "'");
                                //申请日期
                                Long field_lp4Q1__c = Long.parseLong(new BigDecimal(dataList.get(i).get("field_lp4Q1__c").toString()).toPlainString());
                                Long create_time = Long.parseLong(new BigDecimal(dataList.get(i).get("create_time").toString()).toPlainString());
                                Long last_modified_time = Long.parseLong(new BigDecimal(dataList.get(i).get("last_modified_time").toString()).toPlainString());
                                //客户联系人:pi_purposename 电话：pi_expresscode
                                int pi_id = baseDao.getSeqId("PRODINOUTAPPLY_SEQ");
                                String sql="insert into ProdInOutApply(pi_id,pi_code,pi_class,pi_date,pi_status,pi_statuscode,pi_cardcode,pi_title,pi_emcode,pi_emname,pi_recordman,pi_recorddate," +
                                        "pi_updateman,pi_updatedate,pi_purposename,pi_expresscode,pi_address,pi_field_Il1e1,pi_record_type,pi_life_status,PI_FXXKID)" +
                                        "values("+pi_id+",'"+name+"','其它出库申请单',"+DateUtil.parseDateToOracleString(Constant.YMD_HMS,sdf.parse(sdf.format(field_lp4Q1__c)))+"," +
                                        "'在录入','ENTERING','"+cuCode+"','"+dataList.get(i).get("field_l6W5b__c__r")+"','"+owner_code+"','"+owner__r.get("name")+"','"+ created_by__r.get("name")+"'," +
                                        DateUtil.parseDateToOracleString(Constant.YMD_HMS,sdf.parse(sdf.format(create_time)))+",'"+last_modified_by__r.get("name")+"',"+
                                        DateUtil.parseDateToOracleString(Constant.YMD_HMS,sdf.parse(sdf.format(last_modified_time)))+",'" +dataList.get(i).get("field_DzO73__c__r")+"',"+
                                        "'"+dataList.get(i).get("field_57196__c")+"','"+(dataList.get(i).get("field_6OcTn__c")==null?"":dataList.get(i).get("field_6OcTn__c"))+"','"+dataList.get(i).get("field_Il1e1__c")+"','"+recordType+"','"+lifeStatus+"','"+_id+"')";
                                baseDao.execute(sql);
                                //样品申请明细下载
                                syncSampleApplyDetail(_id.toString(),pi_id);
                                m++;
                            }catch (Exception e){
                                baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','样品申请主表下载','"+name+"')");
                                logger.info("异常信息："+e);
                                n++;
                            }
                        }
                        baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_syncTime) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'下载记录"+dataList.size()+"条，成功"+m+"条，失败"+n+"条','样品申请主表下载','"+create_time_Last+"')");
                    }
                }else{
                    baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','样品申请主表下载','')");
                    logger.info("异常信息："+crmQueryResult.getErrorMessage());
                }
            }
        }catch (Exception e){
            baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+e.getMessage()+"','样品申请主表下载','')");
            logger.info("异常信息："+e.getMessage());
            e.printStackTrace();
        }
    }

    private void syncSampleApplyDetail(String SampleApply_id,int pi_id){
        List<String> field_values_Detail = new ArrayList<>();
        field_values_Detail.add(SampleApply_id);
        try {
            CrmQueryResult crmQueryResult = commonManager.queryCommon("field_8019j__c", field_values_Detail, "EQ", "create_time", true, 5, "object_Q55Nj__c", true);
            int errorCode = crmQueryResult.getErrorCode();
            if(errorCode == 0){
                Map<String, Object> data = crmQueryResult.getData();
                List<Map<String, Object>> dataList = (List<Map<String,Object>>) data.get("dataList");
                //m:成功条数 n:失败条数
                int m=0,n=0;
                if(dataList.size()>0){
                    //最后(即最近)一次同步时间
                    Long create_time_Last = Long.parseLong(new BigDecimal(dataList.get(dataList.size()-1).get("create_time").toString()).toPlainString());
                    for (int i = 0; i < dataList.size(); i++) {
                        Object _id = dataList.get(i).get("_id");
                        Object name = dataList.get(i).get("name");
                        SimpleDateFormat sdf = new SimpleDateFormat(Constant.YMD_HMS);
                        if(baseDao.checkIf("ProdIOApplyDetail", "pd_code='" + name + "' and pd_piid="+pi_id)){
                            baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'样品申请明细编号已存在','样品申请明细表下载','"+name+"')");
                            logger.info("异常信息：样品申请明细编号已存在");
                            n++;
                            continue;
                        }
                        try {
                            //负责人编号、名称
                            Map<String,Object> owner__r =(Map<String,Object>) dataList.get(i).get("owner__r");
                            Object owner_code = baseDao.getFieldDataByCondition("employee", "max(em_code) em_code", "em_name='" + owner__r.get("name") + "'");

                            //客户联系人:pi_purposename 电话：pi_expresscode
                            String sql="insert into ProdIOApplyDetail(pd_id,pd_piid,pd_pdno,pd_code,pd_piclass,pd_picode,pd_ownercode,pd_owner,pd_prodcode,pd_detail,pd_sepc,pd_brand,pd_outqty,YPonhand,PD_FXXKID)" +
                                    "values(PRODIOAPPLYDETAIL_SEQ.nextval,"+pi_id+","+(i+1)+",'"+name+"','其它出库申请单','"+dataList.get(i).get("field_8019j__c__r")+"'," +
                                    "'"+owner_code+"','"+owner__r.get("name")+"','"+ (dataList.get(i).get("field_2Lq6Y__c")==null?"":dataList.get(i).get("field_2Lq6Y__c")) +"','"+(dataList.get(i).get(" field_utezf__c__r")==null?"":dataList.get(i).get(" field_utezf__c__r"))+"'," +
                                    "'"+(dataList.get(i).get("field_21Suz__c")==null?"":dataList.get(i).get("field_21Suz__c"))+"','"+(dataList.get(i).get("field_y5dz2__c")==null?"":dataList.get(i).get("field_y5dz2__c"))+"','" +dataList.get(i).get("field_7uspZ__c")+"',"+
                                    "'"+dataList.get(i).get("field_lzxe2__c")+"','"+_id+"')";
                            baseDao.execute(sql);
                            m++;
                        }catch (Exception e){
                            baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','样品申请明细表下载','"+name+"')");
                            logger.info("异常信息："+e);
                            n++;
                        }
                    }
                    baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_syncTime) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'下载记录"+dataList.size()+"条，成功"+m+"条，失败"+n+"条','样品申请明细表下载','"+create_time_Last+"')");
                }
            }else{
                baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+crmQueryResult.getErrorMessage()+"','样品申请明细表下载','')");
                logger.info("异常信息："+crmQueryResult.getErrorMessage());
            }
        }catch (Exception e){
            baseDao.execute("insert into FXXKDockingErrorlog(ml_id,ml_date,ml_result,ml_type,ml_code) values(FXXKDOCKINGERRORLOG_SEQ.nextval,sysdate,'"+e.getMessage()+"','样品申请明细表下载','')");
            logger.info("异常信息："+e.getMessage());
            e.printStackTrace();
        }

    }
}