日常笔记

TransactionAttributeSourcePointcut pointcut

AdvisedSupport advised 包含advisor, advisor里面包含advice

Object[] specificInterceptors = getAdvicesAndAdvisorsForBean(beanClass, beanName, targetSource);
Object proxy = createProxy(beanClass, beanName, specificInterceptors, targetSource);

aopUtils for循环Advisor canApply(candidate, clazz)

canApply(candidate.getPointcut(), targetClass, hasIntroductions)

Pointcut.getMethodMatcher().matches(method, targetClass),
找出符合条件的advisor加入到createProxy

org.springframework.transaction.interceptor.TransactionProxyFactoryBean
的afterpropertiesSet会创建目标类的代理类，用asm包创建cglib代理，enhancer.create. 代理类里有切面逻辑织入器，

父类--静态代码块
子类--静态代码块
父类--非静态代码块
父类--构造函数
子类--非静态代码块
子类--构造函数

PRO_IDENT_RS_PRODUCE_DISTB
9

select /*+parallel(d,8)*/
trunc(d.insert_tm), count(1)
from tt_rms_src partition(TT_RMS_SRC_P20170605) d
where d.data_type = '21'
group by trunc(d.insert_tm);

--bill量
select /*+index(t,IDX_TT_BILL_FLG_TM)*/trunc(t.recive_tm, 'hh24'), count(1)
from tt_bill t
where t.recive_tm > sysdate - 2
group by trunc(t.recive_tm, 'hh24')
order by 1 desc

select trunc(d.insert_tm, 'mi'), count(1)
from tt_rms_src partition(TT_RMS_SRC_P20170612) d
where d.data_type = '67'
and d.insert_tm > sysdate - 1 / 24
group by trunc(d.insert_tm, 'mi');

alter table tt_issue_recv add info varchar2(1000);

SELECT *
FROM V$SQL t where t.SQL_TEXT like '%delete from TT_RMS_SRC%';

SELECT * FROM TABLE(SYS.DBMS_XPLAN.DISPLAY_CURSOR('fkck7w678bqz9',0));
alter table TBILLTRACE modify acc VARCHAR2(50);
alter table TBILLTRACE modify bc VARCHAR2(50);
alter table TBILLTRACE modify bzdno VARCHAR2(50);
alter table TBILLTRACE_BACKUP modify acc VARCHAR2(50);
alter table TBILLTRACE_BACKUP modify bc VARCHAR2(50);
alter table TBILLTRACE_BACKUP modify bzdno VARCHAR2(50);

insert into tl_ocr_address(id, waybill_no, ocr_addr, insert_tm)
values(SEQ_TL_OCR_ADDRESS.NEXTVAL, '029102930192', '测试地址', sysdate );

create sequence SEQ_TL_OCR_ADDRESS minvalue 1 maxvalue 999999999999999999999 start
with 1000 increment by 1 cache 20;

save_addrckin_buff_data('699000663999','18302938291','xxxxx地址','010',
sysdate-1,'010W',0,'010WB',1,0,0,'755','T6','',1);

insert into tm_param_cache(id,param_name, param_value,param_module,is_delete, msg)
values((select max(id) from tm_param_cache), 'ocrCity','','int_o', 0,'ocr地址生效进港城市');

加密机新jar包替换
新的逃生模式支持配置日志文件目录配置
正常方式根据cfg.ini文件配置的日志文件目录生成，一般制定error级别就可以。

getThreadFactory().newThread(this);

dubbo:

事务管理:
manager: spring-config_datasource-tx.xml
<tx:advice id="dataAdvice" transaction-manager="transactionManager">
<tx:attributes>
<tx:method name="insert*" propagation="REQUIRED" />
<tx:method name="delete*" propagation="REQUIRED" />
<tx:method name="update*" propagation="REQUIRED" />
<tx:method name="save*" propagation="REQUIRED" />
<tx:method name="edit*" propagation="REQUIRED" />
<tx:method name="add*" propagation="REQUIRED" />
<tx:method name="select*" propagation="SUPPORTS" />
<tx:method name="query*" propagation="SUPPORTS" />
<tx:method name="get*" propagation="SUPPORTS" />
</tx:attributes>
</tx:advice>

<aop:config>
<aop:pointcut id="dataPointcut" expression="execution(* com.sf.trtmstask.task.manager.impl.*.*(..))" />
<aop:advisor pointcut-ref="dataPointcut" advice-ref="dataAdvice" />
</aop:config>

暴露服务使用的协议现在有两种：dubbo,reset:
使用dubbo暴露服务的只能由dubbo客户端调用。

1. int_dc_load 去掉bill发送到STORM的代码 tt_bill TtBillOutKafkaTaskDao;
删掉配置文件中的
#清单出港数据开关
ttBillOutSwitch=KAFKA
删除回写6消费配置bill_pushasou_switch=###

bill通过process_bill_data处理成进出港数据下发。
删除outidenter模块
OutIdentRsLocal tt_as_out_ident 出港数据发送到STORM代码删掉。对应tm_data_transfer_multi_config配置也删掉

AreaOutIdentRs tt_area_out_ident 出港数据发送到STORM代码删掉。对应tm_data_transfer_multi_config配置也删掉

WrongBillDist TT_BILL_WRONG_DIST

删掉#全网广播数据开关
ttGlobalAsOutSwitch=KAFKA TT_BILL_WRONG_DIST

多线程下发不需要类似于storm_kafka的开关，只需要配置即可。

删除config.properties中配置：
#-----------------------全网广播出港数据-----------------------
#全网广播出港数据-生产者
produce_topic_globalasoutident=SSS_HB_ZZC_AS_OUT
produce_globalasoutident_poolSize=5
produce_globalasoutident_topicTokens=SSS_HB_ZZC_AS_OUT:376*ufSQ

#出港数据-生产者
produce_topic_ttasoutident=SSS_HB_STORM_HHT_AS_OUT
produce_ttasoutident_poolSize=5
produce_ttasoutident_topicTokens=SSS_HB_STORM_HHT_AS_OUT:Q0r^Aa@$

#片区出港数据-生产者
produce_topic_ttareaoutident=SSS_HB_STORM_HHT_AREA_OUT
produce_ttareaoutident_poolSize=5
produce_ttareaoutident_topicTokens=SSS_HB_STORM_HHT_AREA_OUT:Sl96Wn^W

2.去掉小件包出港数据发送到STORM的代码 TT_BAG_HHT_OUT BagHhtOutTaskDao; 这些数据会被存储过程处理成出港数据。

去掉tt_bag_hht 单线程或者多线程下发到分中心STORM

删掉config.properties的配置：bagHhtOutTaskSwitch

#小件包生成出港数据-消费者(回写)
consume_topic_ttBagHhtOut=SSS_HB_STORM_BAG_HHT_OUT
consume_thread_count_ttBagHhtOut=5
consume_url_ttBagHhtOut=http://mom-mon-sssnew.int.sfdc.com.cn:1080/mom-mon/monitor/requestService.pub
consume_clusterName_ttBagHhtOut=sssnew
consume_systemIdToken_ttBagHhtOut=SSSNEW_STORE_HB_KAFKA:*5UgCS!7

##小件包生成出港数据TT_HHT_OUT下发试点中转场
baghhtOut_switch=755W,769W,571W

#小件包生成出港数据-生产者
produce_topic_bagHhtOut=SSS_HB_STORM_BAG_HHT_OUT
produce_poolSize_bagHhtOut=5
produce_topicTokens_bagHhtOut=SSS_HB_STORM_BAG_HHT_OUT:$yH9*y9G

删掉配置表baghht的配置，不支持多线程下发到KAFKA

3.billhasrchd 删掉单线程和多线程发到分中心STORM , 删掉多线程配置
删掉配置
produce_topic_billhasreached=SSS_HB_STORM_BILLHASRRECHED
produce_billhasreached_poolSize=5
produce_billhasreached_topicTokens=SSS_HB_STORM_BILLHASRRECHED:3$!7qfKe

4.hht tt_bar_hht
删除配置：
#700,701出港数据 生产者
produce_topic_sgsasouthht=SSS_HB_STORM_BAR_HHT
produce_sgsasouthht_poolSize=5
produce_sgsasouthht_topicTokens=SSS_HB_STORM_BAR_HHT:9!WWF!pJ

#700,701巴枪出港数据开关
ttBarHHtOutSwitch=KAFKA
tt_hht
删除配置：
#50,51巴枪出港数据 生产者
produce_topic_barrecordhht=SSS_HB_STORM_HHT_AS_OUT
produce_barrecordhht_poolSize=5
produce_barrecordhht_topicTokens=SSS_HB_STORM_HHT_AS_OUT:Q0r^Aa@$
ttHHtOutrecordhhtSwitch=KAFKA

tt_exchange:
删除配置：
#转飞出港数据 生产者
produce_topic_asoutexchange=SSS_HB_STORM_EXCHANGE
produce_asoutexchange_poolSize=5
produce_asoutexchange_topicTokens=SSS_HB_STORM_EXCHANGE:8JcYQV$e

#转飞数据开关
ttExchangeOutSwitch=KAFKA

删除回写对应配置:
#700,701巴枪出港数据接收通过MINA过度-消费者
consume_topic_sgsbarhhtpushasout=SSS_HB_STORM_BAR_HHT
consume_thread_count_sgsbarhhtpushasout=5
consume_url_sgsbarhhtpushasout=http://mom-mon-sssnew.int.sfdc.com.cn:1080/mom-mon/monitor/requestService.pub
consume_clusterName_sgsbarhhtpushasout=sssnew
consume_systemIdToken_sgsbarhhtpushasout=SSSNEW_STORE_HB_KAFKA:*5UgCS!7

#sgs_bar_hht_push_asout_switch=716W

tt_hht
删除配置：consume_thread_count_barrecordhhtpushasout
consume_topic_barrecordhhtpushasout=SSS_HB_STORM_HHT_AS_OUT
consume_thread_count_barrecordhhtpushasout=5
consume_url_barrecordhhtpushasout=http://mom-mon-sssnew.int.sfdc.com.cn:1080/mom-mon/monitor/requestService.pub
consume_clusterName_barrecordhhtpushasout=sssnew
consume_systemIdToken_barrecordhhtpushasout=SSSNEW_STORE_HB_KAFKA:*5UgCS!7
bar_record_hht_push_asout_switch

tt_exchange
删除配置：exchange_push_asout_switch
consume_topic_ttexchangepushasout=SSS_HB_STORM_EXCHANGE
consume_thread_count_ttexchangepushasout=5
consume_url_ttexchangepushasout=http://mom-mon-sssnew.int.sfdc.com.cn:1080/mom-mon/monitor/requestService.pub
consume_clusterName_ttexchangepushasout=sssnew
consume_systemIdToken_ttexchangepushasout=SSSNEW_STORE_HB_KAFKA:*5UgCS!7
consume_clusterName_ttexchangepushasout

5.tt_ident_rs_distb
删除配置：
produce_topic_identrsdistb
inidentrs.pageSize

删除多线程配置表数据

6.删掉进港，出港数据下发
7.tt_issue_recv
删掉多线程下发配置

删除配置：
produce_topic_issueRecv

8.tt_telhis_dist
删除配置：
produce_topic_telhisDist
删除对应多线程配置

9.TT_IDENT_RS_FULL
删除配置produce_identrsfull_poolSize

删除回写配置：
identrsfull_switch
consume_topic_identrsfull

TT_IDENT_RS_FULL_MID
删除配置：
identRsFullSwitch