|
|
@@ -85,163 +85,180 @@ public class InsertServiceImpl implements InsertService {
|
|
|
for (int z = 0; z < list.size(); z++) {
|
|
|
String session_Key = list.get(z).get("tb_code").toString();
|
|
|
|
|
|
- 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_city,receiver_district" +
|
|
|
- ",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_city,receiver_district" +
|
|
|
- ",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());
|
|
|
+ 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("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");
|
|
|
+
|
|
|
+
|
|
|
+ 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);
|
|
|
+ trades = rsp.getTrades();
|
|
|
+ } catch (Exception e) {
|
|
|
+
|
|
|
+ logger.info( new SimpleDateFormat("YYYY-MM-DD hh24:mi:ss").format(new Date())+ this.getClass() + "淘宝未响应并返回订单数据");
|
|
|
}
|
|
|
|
|
|
- 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());
|
|
|
+ } else {
|
|
|
+ TaobaoClient client2 = new DefaultTaobaoClient("http://39.98.201.114:30001/router/rest", "31921866", "7121c52d4c9970ba08bf09e2f525acd0");
|
|
|
+ TradesSoldIncrementGetRequest req2 = new TradesSoldIncrementGetRequest(); //增量备份接口
|
|
|
+ req2.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");
|
|
|
+
|
|
|
+
|
|
|
+ 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() + "淘宝未响应并返回订单数据");
|
|
|
}
|
|
|
+ }
|
|
|
|
|
|
- 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() );
|
|
|
- }
|
|
|
+ List<String> insertSqlsList = new ArrayList<String>();
|
|
|
+
|
|
|
+ if (trades ==null || trades.size() == 0) {
|
|
|
+ logger.info(this.getClass() + " 未录入淘宝订单 ");
|
|
|
+ } else {
|
|
|
+ int L=0;
|
|
|
+ for (int i = 0; i < trades.size(); i++) {
|
|
|
+
|
|
|
+ /* 插入淘宝订单ID sa_tradeid 字段 alter table sale add sa_tradeid number; */
|
|
|
+
|
|
|
+ Long said = baseDao.queryForObject("select sale_seq.nextval from dual", Long.class);
|
|
|
+
|
|
|
+ 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());
|
|
|
+
|
|
|
+ } 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() );
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ String INSERTSALESql = "insert into sale( 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 "+trades.get(i).getDiscountFee() +",'"+trimNull(trades.get(i).getStatus() )+"','" + 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).getReceiverCity() ) + trimNull(trades.get(i).getReceiverDistrict() ) + 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).getPayment() ) + " , 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_CODE from sale WHERE SA_CODE= '" + trades.get(i).getTid() + "' ) 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++;
|
|
|
+
|
|
|
+ Long sdid = baseDao.queryForObject("select saledetail_seq.nextval from dual", Long.class);
|
|
|
+
|
|
|
+ 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() + " ' , " + sdid + " ," + said + " ,' " + sdid + " '," + k + "," + orders.get(j).getNumIid() + "," + 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 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);
|
|
|
+ }
|
|
|
|
|
|
- if(trades.get(i).getConsignTime() == null ) {
|
|
|
- consigntime = formatdx.format(trades.get(i).getCreated());
|
|
|
- } else {
|
|
|
- consigntime = formatdx.format( trades.get(i).getConsignTime() );
|
|
|
}
|
|
|
+ System.out.println(insertSqlsList);
|
|
|
+ try{
|
|
|
+ baseDao.execute(insertSqlsList);
|
|
|
+ baseDao.callProcedure("SP_UPDATE_SALE");
|
|
|
|
|
|
-// logger.info(createdtime);
|
|
|
-
|
|
|
-
|
|
|
- String INSERTSALESql = "insert into sale( 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 '"+trimNull(trades.get(i).getStatus() )+"','" + 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).getReceiverCity() ) + trimNull(trades.get(i).getReceiverDistrict() ) + 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).getPayment() ) + " , 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_CODE from sale WHERE SA_CODE= '" + trades.get(i).getTid() + "' ) 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).getPayment() +
|
|
|
- ",'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);
|
|
|
+ }catch (Exception e) {
|
|
|
+ logger.info( e.getMessage() );
|
|
|
}
|
|
|
|
|
|
}
|
|
|
- System.out.println(insertSqlsList);
|
|
|
- try{
|
|
|
- baseDao.execute(insertSqlsList);
|
|
|
- baseDao.callProcedure("SP_UPDATE_SALE");
|
|
|
-
|
|
|
- }catch (Exception e) {
|
|
|
- logger.info( e.getMessage() );
|
|
|
- }
|
|
|
-
|
|
|
- }
|
|
|
|
|
|
|
|
|
logger.info(this.getClass() + "插入销售明细成功");
|