uas-eis/src/main/java/com/uas/eis/serviceImpl/InsertServiceImpl.java

package com.uas.eis.serviceImpl;


import com.taobao.api.DefaultTaobaoClient;
import com.taobao.api.TaobaoClient;
import com.taobao.api.domain.Order;
import com.taobao.api.domain.Trade;
import com.taobao.api.internal.util.StringUtils;
import com.uas.eis.dao.BaseDao;
import com.uas.eis.service.InsertService;
import net.sf.json.JSON;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import oracle.sql.DATE;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;

import java.text.SimpleDateFormat;
import com.uas.eis.utils.DateUtil;
import java.util.*;

import com.taobao.api.request.TradesSoldGetRequest;
import com.taobao.api.response.TradesSoldGetResponse;

import com.taobao.api.request.TradesSoldIncrementGetRequest;
import com.taobao.api.response.TradesSoldIncrementGetResponse;

import com.uas.eis.utils.HttpUtil;
import com.uas.eis.utils.HttpUtil.Response;


@Service
public class InsertServiceImpl implements InsertService {
    // TOP服务地址，正式环境需要设置为http://gw.api.taobao.com/router/rest
    public static final String serverUrl = "gw.api.taobao.com/router/rest";
    // private static final String serverUrl = "http://gw.api.tbsandbox.com/router/rest";
    public static final String appKey = "31921866"; // 可替换为您的沙箱环境应用的appKey         /* 待修改 */
    public static final String appSecret = "7121c52d4c9970ba08bf09e2f525acd0"; // 可替换为您的沙箱环境应用的appSecret   /* 待修改 */
    //    public static final String sessionKey = "61024291979328cd09f0ba138f79236d66bd313f3364cf148715824"; // 必须替换为沙箱账号授权得到的真实有效sessionKey    /* 待修改 */
    public static Logger logger = Logger.getLogger(InsertServiceImpl.class);

    @Autowired
    private BaseDao baseDao;

    @Override
    public String Insert(String code, String param) {


        try {

            Timer timer = new Timer();//实例化Timer类
            timer.schedule(new TimerTask() {
                public void run() {
                    getAllDate();
                }
            }, 600000);//10分钟
        } catch (Exception e) {
            logger.info(this.getClass() + "服务挂掉");
            return e.getMessage();
        }
        return null;
    }

    public  String trimNull(String str){
        if("".equals(str)||str==null||"null".equals(str)){
            return "";
        }else{
            return str.trim();
        }
    }

    @Autowired
    @Scheduled(cron = "0 0 0/1 * * ?")
    public void getAllDate() {

//        1.无淘宝自动抓取的 订单 ，则正常备份历史订单
//          有淘宝自动抓取的 订单 ，则调用增量备份
        List<Trade> trades = new ArrayList<Trade>();
        String sa_remark = baseDao.queryForObject("select distinct sa_remark from sale where sa_remark ='淘宝自动抓取' ", String.class);
        String session_Key = baseDao.queryForObject(" select  tb_code from ( select  row_number() over( order by tb_date desc ) xuhao , tb_code from tbauthorization ) where xuhao=1 ", String.class);
        if (sa_remark == null || sa_remark == "") {
            TaobaoClient client = new DefaultTaobaoClient("http://39.98.201.114:30001/router/rest", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
            TradesSoldGetRequest req = new TradesSoldGetRequest();  //正常备份接口
            req.setFields("tid,type,status,payment,orders,rx_audit_status,trades,receiver_name,receiver_mobile,created,buyer_nick,receiver_state" +
                    ",receiver_address,shipping_type,o2o_guide_name,modified,end_time,post_fee,payment,total_fee,consign_time,sku_properties_name,seller_nick");


            req.setStartCreated(StringUtils.parseDateTime("1990-01-01 00:00:00"));

            Date date = new Date();
            Calendar calendar = Calendar.getInstance();
            calendar.setTime(new Date());
            calendar.set(Calendar.HOUR_OF_DAY, 23);
            calendar.set(Calendar.MINUTE, 59);
            calendar.set(Calendar.SECOND, 59);
            Date endtime = calendar.getTime();

            req.setEndCreated(endtime);

            try {
                TradesSoldGetResponse rsp = client.execute(req, session_Key);
//                TradesSoldGetResponse rsp = client.execute(req,"6101610227ce2081f21253411b0073fcb18b38a3a1b314f48715824");
                trades = rsp.getTrades();
            } catch (Exception e) {

                logger.info(  new SimpleDateFormat("YYYY-MM-DD hh24:mi:ss").format(new Date())+ this.getClass() + "淘宝未响应并返回订单数据");
            }

        } else {
            TaobaoClient client2 = new DefaultTaobaoClient("http://39.98.201.114:30001/router/rest", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
            TradesSoldIncrementGetRequest req2 = new TradesSoldIncrementGetRequest();  //增量备份接口
            req2.setFields("tid,type,status,payment,orders,rx_audit_status,trades,receiver_name,receiver_mobile,created,buyer_nick,receiver_state" +
                    ",receiver_address,shipping_type,o2o_guide_name,modified,end_time,post_fee,payment,total_fee,consign_time,sku_properties_name,seller_nick");

            Date date2 = new Date();
            Calendar calendar2 = Calendar.getInstance();
            calendar2.setTime(new Date());

            calendar2.set(Calendar.HOUR_OF_DAY, 0);
            calendar2.set(Calendar.MINUTE, 0);
            calendar2.set(Calendar.SECOND, 0);
            Date zero = calendar2.getTime();

            req2.setStartModified(zero);

            calendar2.set(Calendar.HOUR_OF_DAY, 23);
            calendar2.set(Calendar.MINUTE, 59);
            calendar2.set(Calendar.SECOND, 59);
            Date endtime = calendar2.getTime();

            req2.setEndModified(endtime);
            try {
                TradesSoldIncrementGetResponse rsp2 = client2.execute(req2, session_Key);
                trades = rsp2.getTrades();
            } catch (Exception e) {
                logger.info(this.getClass() + "淘宝未响应并返回订单数据");
            }
        }


        List<String> insertSqlsList = new ArrayList<String>();

        if (trades ==null || trades.size() == 0) {
            logger.info(this.getClass() + " 未录入淘宝订单 ");
        } else {
            int L=0; //SDID 不能重复，得自增1次
            for (int i = 0; i < trades.size(); i++) {

                //
                /*  插入淘宝订单ID  sa_tradeid 字段 alter table sale  add sa_tradeid number; */
//                logger.info(trades.get(i).getEndTime());
//                logger.info(new DATE());
                Long said = baseDao.queryForObject("select sale_seq.nextval from dual", Long.class);
                said = said + i ;
                String sa_code = baseDao.sGetMaxNumber("Sale", 2);
                SimpleDateFormat formatdx = new SimpleDateFormat("yyyy-MM-dd HH:MM:ss");
                String createdtime="2020-11-25";
                if(trades.get(i).getCreated() == null ) {
                    createdtime =   formatdx.format(new DATE());
//                    createdtime = new SimpleDateFormat("YYYY-MM-DD HH:mm:ss").format(new DATE());
                } else {
                    createdtime = formatdx.format(trades.get(i).getCreated());
                }

                String modified="2020-11-25";
                if(trades.get(i).getModified() == null ) {
                    modified = formatdx.format(trades.get(i).getCreated());
                } else {
                    modified = formatdx.format(trades.get(i).getModified());
                }

                String end_time="2020-11-25";
                if(trades.get(i).getEndTime() == null ) {
                    end_time = formatdx.format(trades.get(i).getCreated());
                } else {
                    end_time =  formatdx.format( trades.get(i).getEndTime() );
                }

                String consigntime="2020-11-25";
                if(trades.get(i).getConsignTime() == null ) {
                    consigntime = formatdx.format(trades.get(i).getCreated());
                } else {
                    consigntime = formatdx.format( trades.get(i).getConsignTime() );
                }

                if(trades.get(i).getConsignTime() == null ) {
                    consigntime = formatdx.format(trades.get(i).getCreated());
                } else {
                    consigntime = formatdx.format( trades.get(i).getConsignTime() );
                }

//                logger.info(createdtime);


                    String INSERTSALESql = "insert into sale(  sa_sellernick,sa_custcode,sa_paymentscode,SA_TAOBAOID,sa_payments,sa_custname,sa_kind,sa_wwh_user,sa_need15,sa_id,sa_tradeid,sa_code,sa_date,sa_recorder,sa_recorddate,sa_currency,sa_rate" +
                        ",sa_apcustname,sa_shcustname,sa_toplace" +
                        ",sa_transport,sa_seller,sa_updatedate" +
                        ",sa_enddate,sa_statuscode,sa_status,sa_fare,sa_total" +
                        ",sa_recamount,sa_plandelivery,sa_printstatuscode,sa_remark)" +
                        "  SELECT  ' " + trimNull(trades.get(i).getSellerNick() ) + " ', 'GN0008358','P001', "   + trades.get(i).getTid() + " , '现结','HLK淘宝','国内标准销售订单', ' " +trimNull( trades.get(i).getReceiverName() ) + "  ' , ' " + trimNull(trades.get(i).getReceiverMobile()) + " ' , " + said + "," + trades.get(i).getTid() + "," + trades.get(i).getTid()
                        + " , to_date (  '" + createdtime + "' ,'YYYY-MM-DD hh24:mi:ss') , '管理员',sysdate,'RMB','1','"
                        + trimNull(trades.get(i).getReceiverName() )+ "','" + trimNull( trades.get(i).getBuyerNick() )+ "','" + trimNull(trades.get(i).getReceiverState() ) + "  || " + trimNull( trades.get(i).getReceiverAddress() )+ "  ', '  "
                        + trimNull( trades.get(i).getShippingType() ) + "  ', ' " + trimNull (trades.get(i).getO2oGuideName() ) + "  ', to_date ( '" + modified
                        + "','YYYY-MM-DD hh24:mi:ss') , to_date ( '" +end_time + "','YYYY-MM-DD hh24:mi:ss') ,'ENTERING','在录入'," + trimNull( trades.get(i).getPostFee() )+ "," +trimNull( trades.get(i).getPayment() ) + ","
                        + trimNull(trades.get(i).getTotalFee() ) + " , to_date ( '" +consigntime + "','YYYY-MM-DD hh24:mi:ss') ,'unprint', '淘宝自动抓取'   FROM DUAL  " +
                        " WHERE ' " + trimNull(trades.get(i).getStatus() )  + " ' NOT IN  ( 'TRADE_NO_CREATE_PAY','WAIT_BUYER_PAY','PAY_PENDING' )    AND  NOT EXISTS ( select sa_id from sale WHERE SA_iD=" + said +  " )    AND  NOT EXISTS ( select SA_TAOBAOID from sale WHERE SA_TAOBAOID=" + trades.get(i).getTid() + "   )  ";
                insertSqlsList.add(INSERTSALESql);

                List<Order> orders = trades.get(i).getOrders();
                for (int j = 0; j < orders.size(); j++) {
                    int k = j + 1;
                    L++;
                    //sd_enddate  ,sd_senddate ,to_date('  "+orders.get(j).getEndTime()+ "','yyyy-MM-dd hh24:mi:ss'),to_date('" +orders.get(j).getConsignTime()+"','yyyy-MM-dd hh24:mi:ss'),
                    //
                    Long sdid = baseDao.queryForObject("select saledetail_seq.nextval from dual", Long.class);
                    sdid = sdid +L;
                    String INSERTSALEDETAILSql = "insert into saledetail(SD_PROPERTIES,sd_remark,sd_id,sd_said,sd_code,sd_detno,sd_prodcode,sd_qty,sd_price,sd_total" +
                            ",sd_statuscode,sd_status,sd_discount )" +
                            "  SELECT  ' " + trimNull ( orders.get(j).getSkuPropertiesName() ) + " ' ,  ' " + orders.get(j).getTitle() + " ' , "  + sdid + " ," + said + "  ,' " +  sdid + " '," + k + "," + orders.get(j).getNumIid() + "," + orders.get(j).getNum() + "," + orders.get(j).getPrice() + " ," + orders.get(j).getTotalFee() +
                            ",'ENTERING','在录入', " + trimNull(orders.get(j).getDiscountFee() ) + " FROM DUAL   WHERE NOT EXISTS ( select sd_id from saledetail " +
                            "WHERE  ' " + trimNull(trades.get(i).getStatus() )  + " ' NOT IN  ( 'TRADE_NO_CREATE_PAY','WAIT_BUYER_PAY','PAY_PENDING' )    AND  sd_id=" + sdid + "  )  AND  NOT EXISTS ( select sd_id from  sale left join  saledetail on sa_id=sd_said " +
                            "WHERE SA_TAOBAOID = " + trades.get(i).getTid() +  "  and sd_detno = "  + k +" )  ";
                    insertSqlsList.add(INSERTSALEDETAILSql);
                }

            }
            System.out.println(insertSqlsList);
            try{
                baseDao.execute(insertSqlsList);
                baseDao.callProcedure("SP_UPDATE_SALE");

            }catch (Exception e) {
                logger.info( e.getMessage() );
            }




            logger.info(this.getClass() + "插入销售明细成功");
        }

    }

}