|
|
@@ -0,0 +1,161 @@
|
|
|
+package com.uas.eis.task;
|
|
|
+
|
|
|
+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.request.TopOaidDecryptRequest;
|
|
|
+import com.taobao.api.request.TradesSoldGetRequest;
|
|
|
+import com.taobao.api.response.TopOaidDecryptResponse;
|
|
|
+import com.taobao.api.response.TradesSoldGetResponse;
|
|
|
+import com.uas.eis.core.config.TaoBaoConfig;
|
|
|
+import com.uas.eis.dao.BaseDao;
|
|
|
+import com.uas.eis.utils.DateUtil;
|
|
|
+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.Component;
|
|
|
+
|
|
|
+
|
|
|
+import java.util.*;
|
|
|
+
|
|
|
+
|
|
|
+@Component
|
|
|
+public class TaoBaoDownLoadTask {
|
|
|
+
|
|
|
+ public static Logger logger = Logger.getLogger(TaoBaoDownLoadTask.class);
|
|
|
+
|
|
|
+ @Autowired
|
|
|
+ private TaoBaoConfig taoBaoConfig;
|
|
|
+ @Autowired
|
|
|
+ private BaseDao baseDao;
|
|
|
+ /**
|
|
|
+ * 下载订单
|
|
|
+ * */
|
|
|
+ @Scheduled(cron = "0 0/10 * * * ?")
|
|
|
+ public void DownLoadOrder(){
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 有效店铺
|
|
|
+ * */
|
|
|
+ List<Map<String,Object>> shopList = baseDao.queryForList("SELECT TB_CODE,TB_LASTSYNCDATE from TBAUTHORIZATION ORDER BY TB_CODE ASC");
|
|
|
+ logger.info("Start downLoad SaleOrder---");
|
|
|
+ TaobaoClient client = new DefaultTaobaoClient(taoBaoConfig.getServerUrl(), taoBaoConfig.getAppKey(), taoBaoConfig.getAppSecret());
|
|
|
+ TradesSoldGetRequest req = new TradesSoldGetRequest();
|
|
|
+ req.setFields("total_results,has_next,trades,seller_nick,pic_path,payment,seller_rate,post_fee,receiver_name,receiver_state,receiver_address,receiver_zip,receiver_mobile"+
|
|
|
+ ",receiver_phone,consign_time,received_payment,receiver_country,receiver_town,order_tax_fee,shop_pick,tid,num,num_iid,status,title,type,price,discount_fee"+
|
|
|
+ ",total_fee,created,pay_time,modified,end_time,seller_flag,buyer_nick,has_buyer_message,credit_card_fee,step_trade_status,step_paid_fee,mark_desc,shipping_type"+
|
|
|
+ ",adjust_fee,trade_from,service_orders,oid,item_oid,service_id,service_detail_url,num,price,payment,title,total_fee,buyer_nick,refund_id,seller_nick,pic_path"+
|
|
|
+ ",tmser_spu_code,oid_str,buyer_rate,receiver_city,receiver_district,o2o,o2o_guide_id,o2o_delivery,orders,item_meal_name,pic_path,seller_nick,buyer_nick,refund_status,outer_iid,snapshot_url,snapshot,timeout_action_time,buyer_rate,seller_rate"+
|
|
|
+ ",seller_type,cid,sub_order_tax_fee,sub_order_tax_rate,oid,status,title,item_oid,type,sku_properties_name,order_attr,shipping_type"+
|
|
|
+ ",md_qualification,customization,inv_type,shipper,f_type,f_status,f_term,assembly_rela,cl_down_payment,cl_month_payment,cl_tail_payment"+
|
|
|
+ ",cl_installment_num,cal_penalty,cl_service_fee,cl_car_taker,cl_car_taker_phone,cl_car_taker_i_d_num,cl_car_taker_id_num,down_payment"+
|
|
|
+ ",down_payment_ratio,month_payment,tail_payment,installment_num,penalty,service_fee,oid_str,nr_reduce_inv_fail,sort_info"+
|
|
|
+ ",rt_omni_outer_sc_id,rt_omni_sc_id,modify_address,ti_modify_address_time,omni_jxs_outerid,propoint,brand_light_shop_source,special_refund_type"+
|
|
|
+ ",extend_info,service_type,threepl_timing,is_o2o_passport,delivery_time,sign_time");
|
|
|
+ shopList.stream().forEach(shop -> {
|
|
|
+ List<String> executeSQLS = new ArrayList<>();
|
|
|
+ String sessionKey = String.valueOf(shop.get("TB_CODE"));
|
|
|
+ Calendar calendar = Calendar.getInstance();
|
|
|
+ calendar.setTime(DateUtil.parse(String.valueOf(shop.get("TB_LASTSYNCDATE")),"yyyy-MM-dd HH:mm:ss"));
|
|
|
+ calendar.add(Calendar.DATE, -1);
|
|
|
+ Date date = new Date();
|
|
|
+ req.setStartCreated(calendar.getTime());
|
|
|
+ req.setEndCreated(date);
|
|
|
+ try {
|
|
|
+ TradesSoldGetResponse rsp = client.execute(req, sessionKey);
|
|
|
+ List<Trade> trades = rsp.getTrades();
|
|
|
+ logger.info("店铺获取单数"+trades.size());
|
|
|
+ for(Trade trade: trades){
|
|
|
+ formatTrade(trade, sessionKey, executeSQLS);
|
|
|
+ }
|
|
|
+ baseDao.execute(executeSQLS);
|
|
|
+ //更新当前店铺的最近更新时间
|
|
|
+ baseDao.updateByCondition("TBAUTHORIZATION","TB_LASTSYNCDATE=to_date ( '" + DateUtil.format(date, DateUtil.FORMAT_YMD_HMS) + "','YYYY-MM-DD hh24:mi:ss') ","TB_CODE ='"+sessionKey+"'");
|
|
|
+ } catch (Exception e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ logger.info("淘宝未响应并返回订单数据");
|
|
|
+ }
|
|
|
+ });
|
|
|
+ //部分信息处理
|
|
|
+ baseDao.callProcedure("SP_UPDATE_SALEINFO");
|
|
|
+ }
|
|
|
+ private void formatTrade(Trade trade ,String sessionKey, List<String> executeSqls){
|
|
|
+ String oaid=trade.getOaid();
|
|
|
+ String tid=trade.getTid().toString();
|
|
|
+ boolean isEXISTS = baseDao.checkIf("SALE", "SA_CODE='"+tid+"'");
|
|
|
+ if(isEXISTS) {
|
|
|
+ return;
|
|
|
+ }
|
|
|
+ TopOaidDecryptRequest req= new TopOaidDecryptRequest();
|
|
|
+ List<TopOaidDecryptRequest.ReceiverQuery> queryList = new ArrayList<TopOaidDecryptRequest.ReceiverQuery>();
|
|
|
+ TopOaidDecryptRequest.ReceiverQuery receiverQuery = new TopOaidDecryptRequest.ReceiverQuery();
|
|
|
+ receiverQuery.setOaid(oaid);
|
|
|
+ receiverQuery.setTid(tid);
|
|
|
+ receiverQuery.setScene("1001");
|
|
|
+ queryList.add(receiverQuery);
|
|
|
+ req.setQueryList(queryList);
|
|
|
+
|
|
|
+ TaobaoClient client = new DefaultTaobaoClient(taoBaoConfig.getServerUrl(), taoBaoConfig.getAppKey(), taoBaoConfig.getAppSecret());
|
|
|
+ String name_oaid=trimNull(trade.getReceiverName() );
|
|
|
+ String receiver_mobile=trimNull(trade.getReceiverMobile() );
|
|
|
+ String address=trimNull(trade.getReceiverState() ) + trimNull(trade.getReceiverCity() ) + trimNull(trade.getReceiverDistrict() ) + trimNull(trade.getReceiverAddress() );
|
|
|
+ if(oaid!=null) {
|
|
|
+ try {
|
|
|
+ TopOaidDecryptResponse rep = client.execute(req, sessionKey);
|
|
|
+ name_oaid = rep.getReceiverList().get(0).getName();
|
|
|
+ receiver_mobile=rep.getReceiverList().get(0).getMobile();
|
|
|
+ address=trimNull(rep.getReceiverList().get(0).getState() ) + trimNull(rep.getReceiverList().get(0).getCity() ) + trimNull(rep.getReceiverList().get(0).getDistrict() ) + trimNull( rep.getReceiverList().get(0).getAddressDetail() );
|
|
|
+ } catch (Exception e) {
|
|
|
+ logger.info("淘宝返回敏感信息失败,"+e.getMessage());
|
|
|
+ }
|
|
|
+ }
|
|
|
+ name_oaid=name_oaid.replaceAll("'","");
|
|
|
+ String modified = DateUtil.format((trade.getModified() == null ? trade.getCreated() : trade.getModified()), DateUtil.FORMAT_YMD_HMS);
|
|
|
+ String end_time = DateUtil.format((trade.getEndTime() == null ? trade.getCreated() : trade.getEndTime()), DateUtil.FORMAT_YMD_HMS);
|
|
|
+ String consigntime = DateUtil.format((trade.getConsignTime() == null ? trade.getCreated() : trade.getConsignTime()), DateUtil.FORMAT_YMD_HMS);
|
|
|
+ Long said = baseDao.queryForObject("select sale_seq.nextval from dual", Long.class);
|
|
|
+ if(!"TRADE_NO_CREATE_PAY".equals(trade.getStatus())
|
|
|
+ &&!"WAIT_BUYER_PAY".equals(trade.getStatus())
|
|
|
+ &&!"PAY_PENDING".equals(trade.getStatus())
|
|
|
+ &&!"WAIT_BUYER_CONFIRM_GOODS".equals(trade.getStatus())
|
|
|
+ &&!"TRADE_CLOSED_BY_TAOBAO".equals(trade.getStatus())
|
|
|
+ &&!"TRADE_CLOSED".equals(trade.getStatus())
|
|
|
+ &&!"TRADE_FINISHED".equals(trade.getStatus())) {
|
|
|
+ executeSqls.add("INSERT INTO SALESECRETINFO(SAID, NAME,MOBILE, PLACE) SELECT "+said+",pkg_security.encrypt_data('"+taoBaoConfig.getPublicKey()+"','"+name_oaid+"')," +
|
|
|
+ "pkg_security.encrypt_data('"+taoBaoConfig.getPublicKey()+"','"+receiver_mobile+"'), pkg_security.encrypt_data('"+taoBaoConfig.getPublicKey()+"','"+address+"') FROM DUAL");
|
|
|
+ String INSERTSALESql = "insert into sale( SA_NEEDUPDATE,SA_DISCOUNTFEE,SA_TRADESTATUS, 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_need9,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 1," + trade.getDiscountFee() + ",'" + trimNull(trade.getStatus()) + "',replace( nvl( '" + trimNull(trade.getSellerNick()) + " ' ,'静夜思solong'),' ',''), 'GN0008358','P001', " + trade.getTid() + " , '现结','HLK淘宝','国内标准销售订单', ' " + trimNull(name_oaid) + " ' , ' " + trimNull(receiver_mobile) + " ' , " + said + "," + trade.getTid() + "," + trade.getTid()
|
|
|
+ + " , to_date ( '" + end_time + "' ,'YYYY-MM-DD hh24:mi:ss') , '管理员',sysdate,'RMB','1','"
|
|
|
+ + trimNull(name_oaid) + "','" + trimNull(trade.getBuyerNick()) + "','" + address.replaceAll("'", "") + " ', ' "
|
|
|
+ + trimNull(trade.getShippingType()) + " ', ' " + trimNull(trade.getO2oGuideName()) + " ', to_date ( '" + modified
|
|
|
+ + "','YYYY-MM-DD hh24:mi:ss') , to_date ( '" + end_time + "','YYYY-MM-DD hh24:mi:ss') ,'ENTERING','在录入'," + trimNull(trade.getPostFee()) + "," + trimNull(trade.getPayment()) + ","
|
|
|
+ + trimNull(trade.getPayment()) + " , to_date ( '" + consigntime + "','YYYY-MM-DD hh24:mi:ss') ,'unprint', '淘宝自动抓取' FROM DUAL " +
|
|
|
+ " WHERE NOT EXISTS ( select 1 from sale WHERE SA_TAOBAOID=" + trade.getTid() + " ) ";
|
|
|
+
|
|
|
+ executeSqls.add(INSERTSALESql);
|
|
|
+ List<Order> orders = trade.getOrders();
|
|
|
+ for (int j = 0; j < orders.size(); j++) {
|
|
|
+ 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,SD_DIVIDE_ORDER_FEE,SD_PART_MJZ_DISCOUNT )" +
|
|
|
+ " SELECT ' " + trimNull(orders.get(j).getSkuPropertiesName()) + " ' , ' " + orders.get(j).getTitle() + " ' , saledetail_seq.nextval ," + said + " ,' " + trade.getTid() + " '," + (j+1) + ",'" + trimNull(orders.get(j).getOuterIid()) + "'," + orders.get(j).getNum() + "," + orders.get(j).getPrice() + " ," + orders.get(j).getPayment() +
|
|
|
+ ",'ENTERING','在录入', " + orders.get(j).getDiscountFee() + "," + orders.get(j).getDivideOrderFee() + "," + orders.get(j).getPartMjzDiscount() + " FROM DUAL WHERE NOT EXISTS ( select sd_id from sale left join saledetail on sa_id=sd_said " +
|
|
|
+ "WHERE SD_CODE = '" + tid + "' and sd_detno = " + (j+1) + " ) ";
|
|
|
+ executeSqls.add(INSERTSALEDETAILSql);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ public String trimNull(String str){
|
|
|
+ if("".equals(str)||str==null||"null".equals(str)){
|
|
|
+ return "";
|
|
|
+ }else{
|
|
|
+ return str.trim();
|
|
|
+ }
|
|
|
+ }
|
|
|
+}
|
zhouy