设计-直播间赠送礼物功能

curl 'https://live.douyin.com/webcast/gift/send/?aid=6383&live_id=1&device_platform=web&language=zh-CN&enter_from=web_live&cookie_enabled=true&screen_width=2048&screen_height=1152&browser_language=zh-CN&browser_platform=MacIntel&browser_name=Chrome&browser_version=107.0.0.0&browser_online=true&engine_name=Blink&engine_version=107.0.0.0&os_name=Mac+OS&os_version=10.15.7&cpu_core_num=8&device_memory=8&platform=PC&downlink=10&effective_type=4g&round_trip_time=50&channel=channel_pc_web&app_name=douyin_web&webid=7167235205950047744&user_agent=Mozilla%2F5.0+(Macintosh%3B+Intel+Mac+OS+X+10_15_7)+AppleWebKit%2F537.36+(KHTML,+like+Gecko)+Chrome%2F107.0.0.0+Safari%2F537.36&fp=verify_lam4f5i1_plZJSYeB_iUgU_4z2o_9JHF_d7Z0Z60sLg33&did=0&referer=https:%2F%2Flive.douyin.com%2F444452144000%3Fcover_type%3D0%26enter_from_merge%3Dweb_live%26enter_method%3Dweb_card%26game_name%3D%26is_recommend%3D1%26live_type%3Dgame%26more_detail%3D%26request_id%3D2022111814283801020916816201004237%26room_id%3D7167220081737468683%26stream_type%3Dvertical%26title_type%3D1%26web_live_page%3Dhot_live%26web_live_tab%3Dall&target=&device_id=7167235205950047744&msToken=aOEoMNHAEI98H45Z0n-zUTffiNgv7HNkGU0lwFptk-JBg00tEs0I74G4sYXgG670cAdhSmXNcKlRU3-QaxW7Pflt-p8YAmyU5eC3EGJQfp7Mk7JpmP_P&X-Bogus=DFSzswVL0qCmAcoQS8MuBN7TlqS8&_signature=_02B4Z6wo00001Heu8JQAAIDD43irmgubdKx3rvQAAH6ktTtRdH7gtQJWp3SjldUkeBB51lpkXUQ700UnFEXODUicQ0r1ccxSxq4OwWIjvxuNe8Acl-gJzChe99W43SojHkPp9aa82Qzi9VoTd2' \
 -H 'authority: live.douyin.com' \
 -H 'accept: application/json, text/plain, */*' \
 -H 'accept-language: zh-CN,zh;q=0.9,en;q=0.8,zh-TW;q=0.7' \
 -H 'content-type: application/x-www-form-urlencoded' \
 -H 'cookie: xgplayer_user_id=502915240928; csrf_session_id=f5161482adac52884f25a91fa758d7b0; ttcid=5cd5ff73751f4ab39911c85e57f9ca7479; passport_csrf_token=46e48d1e7b4df245f8caab8a34b64935; passport_csrf_token_default=46e48d1e7b4df245f8caab8a34b64935; home_can_add_dy_2_desktop=%220%22; n_mh=Qo43cptpX41bfwDmWyVyRUGMZnsucxhgcWJqKjjWkvI; sso_uid_tt=a84f8e3ae1f0c8301f5a882b05abe3f0; sso_uid_tt_ss=a84f8e3ae1f0c8301f5a882b05abe3f0; toutiao_sso_user=a28a6e92e7dc7d690b4f6b9a59077692; toutiao_sso_user_ss=a28a6e92e7dc7d690b4f6b9a59077692; passport_assist_user=Cjyr0IY04IJK-7Hxgl87vzPKZIfpFS29oAG2arITfMftUANM_d6SDxwAksiJEuVqZgZdE_BYyvcjLLGAQaYaSAo8zVwGiPnNM3S7eRNlXwMkuS7yNVm17pbNfKqXsXj3Rgk9Nm08DWh_PY0JRbH8FQeLxabRAoqM4bPJTzQ8EM_DoQ0Yia_WVCIBAxToQPk%3D; sid_ucp_sso_v1=1.0.0-KGIxM2FlNmE2MDdiNWE5MDA1YmIwZjg5OWVkNTUxMTBhMzdhYWE2OTIKHQjhrMGYrgIQt8vcmwYY7zEgDDDHuNHRBTgGQPQHGgJobCIgYTI4YTZlOTJlN2RjN2Q2OTBiNGY2YjlhNTkwNzc2OTI; ssid_ucp_sso_v1=1.0.0-KGIxM2FlNmE2MDdiNWE5MDA1YmIwZjg5OWVkNTUxMTBhMzdhYWE2OTIKHQjhrMGYrgIQt8vcmwYY7zEgDDDHuNHRBTgGQPQHGgJobCIgYTI4YTZlOTJlN2RjN2Q2OTBiNGY2YjlhNTkwNzc2OTI; passport_auth_status=ba24f5319c0f02c6232d484fd51c2187%2C; passport_auth_status_ss=ba24f5319c0f02c6232d484fd51c2187%2C; sid_guard=ea2e466c926c317f4f552f0d3982a458%7C1668752823%7C5184000%7CTue%2C+17-Jan-2023+06%3A27%3A03+GMT; uid_tt=23c596f546d448da13c0098152ef5d17; uid_tt_ss=23c596f546d448da13c0098152ef5d17; sid_tt=ea2e466c926c317f4f552f0d3982a458; sessionid=ea2e466c926c317f4f552f0d3982a458; sessionid_ss=ea2e466c926c317f4f552f0d3982a458; sid_ucp_v1=1.0.0-KDRiMzcyMDVkZmZhMWIxNjhjNDM4YjBiZDA4Y2E5ZTBmN2IxNTE1NjIKFwjhrMGYrgIQt8vcmwYY7zEgDDgGQPQHGgJsZiIgZWEyZTQ2NmM5MjZjMzE3ZjRmNTUyZjBkMzk4MmE0NTg; ssid_ucp_v1=1.0.0-KDRiMzcyMDVkZmZhMWIxNjhjNDM4YjBiZDA4Y2E5ZTBmN2IxNTE1NjIKFwjhrMGYrgIQt8vcmwYY7zEgDDgGQPQHGgJsZiIgZWEyZTQ2NmM5MjZjMzE3ZjRmNTUyZjBkMzk4MmE0NTg; FOLLOW_NUMBER_YELLOW_POINT_INFO=%22MS4wLjABAAAAt_v5oVMmcxuNnLLRzi6Ey1GKVQr_2XVFt2jPbkhZPI8%2F1668787200000%2F0%2F1668752826051%2F0%22; strategyABtestKey=%221668752909.101%22; __ac_nonce=06377261b0070042789c9; __ac_signature=_02B4Z6wo00f01JfP74gAAIDDAxm0hJMbmiiX7-sAAEaJTk9YXvYiEKlcYbhZnUTqyIVISJ6Z9uR3UEye00i7MfEP1dAywrmbnaQAIP3m1.7zOA8BmpqIWhyYJal-u6k6LMxVpsCtyakYsz3325; live_can_add_dy_2_desktop=%221%22; tt_scid=PpJHVbeNWnhY54EQ6vWraqXl5A8SZDtl3dn9JTaQQNLPo37ztPaJz.xoJHxyhNYScf8e; s_v_web_id=verify_lam4f5i1_plZJSYeB_iUgU_4z2o_9JHF_d7Z0Z60sLg33; ttwid=1%7C-XDacSDIgDIHmJqBxLj6Op91O91Ww4nvf96AveJpNeE%7C1668752951%7C0275ac24a410dd06b5f87dc4d84188f6eedaf20ed69cc9d0e979559df7df461e; download_guide=%223%2F20221118%22; odin_tt=3a02e4ad7a6c9042e1c42ece6d0d4a1aeeb37ed334f3450eb4adf57a6d0e09938523f8954816d90d557b27f5d3cbea85; msToken=1GTirdFSckP7H_txAPOKIMLWleKhlwccm-ts_3OviXegeQ2cr0B56jMAqfB3SqEGnxPEBjXRWsmg-sxVW3okb1s-acOAnBkIVDA_47g5aZFOqMKEzI-N; msToken=aOEoMNHAEI98H45Z0n-zUTffiNgv7HNkGU0lwFptk-JBg00tEs0I74G4sYXgG670cAdhSmXNcKlRU3-QaxW7Pflt-p8YAmyU5eC3EGJQfp7Mk7JpmP_P' \
 -H 'origin: https://live.douyin.com' \
 -H 'referer: https://live.douyin.com/444452144000' \
 -H 'sec-ch-ua: "Google Chrome";v="107", "Chromium";v="107", "Not=A?Brand";v="24"' \
 -H 'sec-ch-ua-mobile: ?0' \
 -H 'sec-ch-ua-platform: "macOS"' \
 -H 'sec-fetch-dest: empty' \
 -H 'sec-fetch-mode: cors' \
 -H 'sec-fetch-site: same-origin' \
 -H 'user-agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36' \
 -H 'x-secsdk-csrf-token: 000100000001c39118162052c6b50f6dadb067cc07c073c9b93f035ea22242c67c43f5951903172899f1bc355042' \
 --data-raw 'room_id=7167220081737468683&to_room_id=7167220081737468683&sec_to_user_id=MS4wLjABAAAAOgGR5D9qmmPglgaT08-30j8vnjeeAdmgXhJY_8Q7oLk&to_episode_id=0&send_type=4&send_scene=1&gift_source=0&buff_level=0&count=1&price=2&gift_id=2002&is_first_combo=true' \
 --compressed -iv

{
 "data": {
 "message": "Insufficient Fund",
 "prompts": "余额不足"
 },
 "extra": {
 "now": 1668755929438
 },
 "status_code": 40001
}

curl 'https://live.kuaishou.com/live_graphql' \
 -H 'Accept-Language: zh-CN,zh;q=0.9,en;q=0.8,zh-TW;q=0.7' \
 -H 'Connection: keep-alive' \
 -H 'Cookie: clientid=3; did=web_0d47b6546f1fd39fe4d1236703ae2b16; kuaishou.live.bfb1s=9b8f70844293bed778aade6e0a8f9942; client_key=65890b29; kpn=GAME_ZONE; userId=553458447; kuaishou.live.web_st=ChRrdWFpc2hvdS5saXZlLndlYi5zdBKgAV6EW8_dkcqveTyN6yy6uaMZd7O2c9rYOi19Fb3FhhOTPjtHtkb7lPQxQ4QaygTV0J-_Z0E7-4E5lFUZ2MRRzwjNAgbEEeSbf5duEVRtpGJnR_EEjJeZ3yyPMWPsJelIVcpSHGX02esKljXrWSXcbMWU709r4hxtaNHdMQtnvmLt1nijHxRE7lio0ZRYM5n-EK65VJq2EUpFqHFY_jFqxm0aEhrHsWfESUHgv806qk-5eqStgCIgOVwse70J74NPwA2TbGfOv-Ze0M-TVQJ0kHcHOHiTkKooBTAB; kuaishou.live.web_ph=75bafd83e69f9caf80b760c47f7b9c976d31; userId=553458447; ksliveShowClipTip=true' \
 -H 'Origin: https://live.kuaishou.com' \
 -H 'Referer: https://live.kuaishou.com/u/YiGe6666' \
 -H 'Sec-Fetch-Dest: empty' \
 -H 'Sec-Fetch-Mode: cors' \
 -H 'Sec-Fetch-Site: same-origin' \
 -H 'User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/107.0.0.0 Safari/537.36' \
 -H 'accept: */*' \
 -H 'content-type: application/json' \
 -H 'sec-ch-ua: "Google Chrome";v="107", "Chromium";v="107", "Not=A?Brand";v="24"' \
 -H 'sec-ch-ua-mobile: ?0' \
 -H 'sec-ch-ua-platform: "macOS"' \
 --data-raw '{"operationName":"SendTokenGift","variables":{"e":"UJfUx05OooLVLeaLzurAD7t0ycf7qHV57YPA64hWOh5Nslk4cNv5GCO5UIhUfygGimZNaBMDaQF7CWigSoxuOG4KmX6PBg7Nw/BxK3lCQ/MeVM8H3VRD7RIv7A9H4Zt+z/43c25jpTuaQrjLpxrWXzNYORIKJRjga9ZUGPCbNwatxYFMuVGEJcn8SZxFdd2rr1HMsQV2HXhl1PcILcXZ5fcnu7+VARIIj26snB4TOiQ=","iv":"yLelD2PBybOSK8LM","giftId":114,"liveStreamId":"sOuGkqrHrOs","count":1,"comboKey":"IZLFwC_9lDBi2YL6_1668754497884","giftToken":"CkMQj7b0hwIaNIECAoICgwLHAgmLAowCjQIOENsBnAGfAt8B4AEhoQLhAakCKXFysgLyAfYBtwL3AfgB+QEgNCi36OokEIzc0szIMBqQARbIi9FshY8J3yb72Pi3Kf3b4VlRZ8dHHr2d64OWA545YQ6SBsTaqA6ERQ9DQbGDCXK3L5MoVtVL/wy4cLlD+XTMYIYjEYUU/0IwTbvhrTXWdll64SIP1APvRQXCjDugMBShDAqlMCBPqREhchX0t8tXHhYO2h+h6k3+kwe3yAdSioapP7i5NxtuLxCFTYPiVA=="},"query":"mutation SendTokenGift($e: String, $iv: String, $giftId: Int, $liveStreamId: ID, $count: Int, $comboKey: String, $giftToken: String) {\n sendTokenGift(e: $e, iv: $iv, giftId: $giftId, liveStreamId: $liveStreamId, count: $count, comboKey: $comboKey, giftToken: $giftToken) {\n result\n ksCoin\n styleType\n __typename\n }\n}\n"}' \
 --compressed -iv

{
 "data": {
 "sendTokenGift": {
 "result": 1,//成功
 "ksCoin": 0,
 "styleType": null,
 "__typename": "SendGiftResult"
 }
 }
}

/* local mysql innodb(index B+TREE) */createdatabase`pay{$dbpartitions}`CREATETABLE`pay{$dbpartitions}`.`user_assert`(`userId`bigintunsignedNOTNULLDEFAULT'0',`assetCn`bigintunsignedNOTNULLDEFAULT'0',`assetType`tinyintunsignedNOTNULLDEFAULT'0',`version`bigintunsignedNOTNULLDEFAULT'0',`createdAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_assertType`(`userId`,`assetType`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4partitionbyhash(`userId`)partitions16;createtable`pay{$dbpartitions}`.`user_assert${tbpartitions}`like`user_assert`;/* create table add this for tidb tikv(index LSM-TREE) *//* eg: partitions*2^min(SHARD_ROW_ID_BITS,PRE_SPLIT_REGIONS) = 128 regions, echo regions 96MB(compressed) *//* if don't use regions, those regions will be recycled *//*T! SHARD_ROW_ID_BITS=4 PRE_SPLIT_REGIONS=3 */CREATETABLE`user_asset`(`userId`bigintunsignedNOTNULLDEFAULT'0',`assetCn`bigintunsignedNOTNULLDEFAULT'0',`assetType`tinyintunsignedNOTNULLDEFAULT'0',`version`bigintunsignedNOTNULLDEFAULT'0',`createdAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_assetType`(`userId`,`assetType`))DEFAULTCHARSET=utf8mb4SHARD_ROW_ID_BITS=4PRE_SPLIT_REGIONS=3partitionbyhash(`userId`)partitions16;showtableuser_assetregions;/* create db table for polardb-x innodb(index B+TREE) *//* PARTITION_MODE drds/sharding (db,table), auto/partitioning use partitioning *//* create database `pay` PARTITION_MODE=sharding; */createdatabase`pay`PARTITION_MODE=partitioning;CREATETABLE`pay`.`user_asset`(`userId`bigintunsignedNOTNULLDEFAULT'0',`assetCn`bigintunsignedNOTNULLDEFAULT'0',`assetType`tinyintunsignedNOTNULLDEFAULT'0',`version`bigintunsignedNOTNULLDEFAULT'0',`createdAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampNOTNULLDEFAULTCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_assetType`(`userId`,`assetType`))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4partitionbyhash(`userId`)partitions128;/*dbpartition by hash(`userId`) tbpartition by hash(`userId`) tbpartitions 16*/showtableinfofrom`pay`.`user_asset`;showtopologyfrom`pay`.`user_asset`;showrulefrom`pay`.`user_asset`;SHOWNODE;showdbstatus;showtablestatus;

SETAUTOCOMMIT=0;BEGIN;a=SELECTassetCnFROMuser_assetWHEREuserId={$userId}andassetType={$assetType}FORUPDATE;updateuser_assetsetassetCn=a.assetCn+{$incrCn}whereuserId={$userId}andassetType={$assetType};COMMIT;

a=SELECTassetCnFROMuser_assetWHEREuserId={$userId}andassetType={$assetType};#$oldAssetCn=a.assetCn#$newAssetCn=a.assetCn+$incrCn#if$newAssetCn>=0->updateupdateuser_assetsetassetCn={$newAssetCn}whereuserId={$userId}andassetType={$assetType}andassetCn={$oldAssetCn}

a=SELECTassetCn,versionFROMuser_assetWHEREuserId={$userId}andassetType={$assetType};#$oldAssetCn=a.assetCn#$oldVersion=a.version#$newAssetCn=a.assetCn+$incrCn#if$newAssetCn>=0->update#$newVersion=$oldVersion+1updateuser_assetsetassetCn={$newAssetCn}andversion={$newVersion}whereuserId={$userId}andassetType={$assetType}andversion={$oldVersion}

/* local mysql innodb(index B+TREE) */createtable`pay{$dbpartitions}`.`user_assert_record`(`userId`bigintunsignednotnulldefault'0',`opUserType`tinyintunsignednotnulldefault'0',`bizId`bigintunsignednotnulldefault'0',`bizType`tinyintunsignednotnulldefault'0',`objId`varchar(128)notnulldefault'',`eventId`varchar(128)notnulldefault'',`eventType`varchar(128)notnulldefault'',`record`varchar(256)notnulldefault'',`recordOp`varchar(64)notnulldefault'',`createdAt`timestampnotnullDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampnotnulldefaultCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_opUserType_event`(`userId`,`opUserType`,`eventId`))engine=InnoDBdefaultcharset=utf8mb4partitionbyhash(`userId`)PARTITIONS16;createtable`pay{$dbpartitions}`.`user_assert_record${tbpartitions}`like`user_assert_record`;/* create table add this for tidb tikv(index LSM-TREE) *//* eg: partitions*2^min(SHARD_ROW_ID_BITS,PRE_SPLIT_REGIONS) = 256 regions, echo regions 96MB(compressed) *//* if don't use regions, those regions will be recycled *//*T! SHARD_ROW_ID_BITS=4 PRE_SPLIT_REGIONS=5 */createtable`pay`.`user_asset_record`(`userId`bigintunsignednotnulldefault'0',`opUserType`tinyintunsignednotnulldefault'0',`bizId`bigintunsignednotnulldefault'0',`bizType`tinyintunsignednotnulldefault'0',`objId`varchar(128)notnulldefault'',`eventId`varchar(128)notnulldefault'',`eventType`varchar(128)notnulldefault'',`record`varchar(256)notnulldefault'',`recordOp`varchar(64)notnulldefault'',`createdAt`timestampnotnullDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampnotnulldefaultCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_opUserType_event`(`userId`,`opUserType`,`eventId`))engine=InnoDBdefaultcharset=utf8mb4SHARD_ROW_ID_BITS=4PRE_SPLIT_REGIONS=5PARTITIONBYHASH(`userId`)PARTITIONS16;showtableuser_asset_recordregions;/* create db table for polardb-x innodb(index B+TREE) or tokudb(index Fractal tree) or x-engine(index LSM-TREE) ,for this scene use innodb *//* PARTITION_MODE drds/sharding (db,table), auto/partitioning use partitioning *//* create database `pay` PARTITION_MODE=sharding; */createdatabase`pay`PARTITION_MODE=partitioning;createtable`pay`.`user_asset_record`(`userId`bigintunsignednotnulldefault'0',`opUserType`tinyintunsignednotnulldefault'0',`bizId`bigintunsignednotnulldefault'0',`bizType`tinyintunsignednotnulldefault'0',`objId`varchar(128)notnulldefault'',`eventId`varchar(128)notnulldefault'',`eventType`varchar(128)notnulldefault'',`record`varchar(256)notnulldefault'',`recordOp`varchar(64)notnulldefault'',`createdAt`timestampnotnullDEFAULTCURRENT_TIMESTAMP,`updatedAt`timestampnotnulldefaultCURRENT_TIMESTAMPONUPDATECURRENT_TIMESTAMP,UNIQUEKEY`uk_user_opUserType_event`(`userId`,`opUserType`,`eventId`))engine=InnoDB/*tokudb/xengine*/defaultPARTITIONBYHASH(`userId`)PARTITIONS256;/*dbpartition by hash(`userId`) tbpartition by hash(`userId`) tbpartitions 16*/showtableinfofrom`pay`.`user_asset_record`;showtopologyfrom`pay`.`user_asset_record`;showrulefrom`pay`.`user_asset_record`;SHOWNODE;showdbstatus;showtablestatus;

./mqadmin setConsumeMode -c DefaultCluster -t test -g testGroup -m POP -n namesrv:9876

NewPushConsumer -> GetOrNewRocketMQClient -> GetOrNewRocketMQClient-> 注册RegisterRequestFunc ReqResetConsumerOffset事件的回调func -> 触发 resetOffset -> ResetOffset-> resume -> doBalance -> updateProcessQueueTable写入拉去请求到prCH中
Start -> RegisterConsumer -> start
异步 select 轮训从prCh中获取拉去请求pr -> 异步 pullMessage(pr)->
	异步 select 轮训处理pr中的处理队列和消息队列 submitToConsume(pr.pq, pr.mq) (一个是顺序orderly处理,一个是普通currently处理)
	
	->pq.putMessage(msgs)从broker中请求的消息放入处理队列中的msgCh中
	
	->普通处理consumeMessageCurrently() -> pq.getMessages 从处理队列中的msgCh中获取消息-> 
		拉取到的一批消息会拆分成N(取决于consumeMessageBatchMaxSize)个小批消息subMsgs -> 
		异步 consumeInner(ctx,subMsgs) -> 调用业务定义的回调业务函数callback.f(ctx, subMsgs...)->
	处理完成返回响应

├── aws	-------------- use aws cloud develop, focus on biz logic by use lambda / step functions
│  └── cdk ------ deploy infrastructure ECS, VPC, EKS, S3, cache,db/search,mq etc for severless 
├── cloudwego	----------------- use cloudwego framwork develop
│  ├── common	----------------- biz common for idl,dto,dict enum; rpc service/client, pkg
│  │  ├── idl
│  │  ├── kitex_gen
│  │  │  ├── base
│  │  │  ├── common
│  │  │  └── payment
│  │  │  ├── base
│  │  │  ├── da
│  │  │  │  └── paymentservice
│  │  │  └── station
│  │  │  └── paymentservice
│  │  └── pkg
│  │  └── constants
│  ├── kitex-contrib ------------------------ kitex rpc framwork contrib (add new)
│  │  ├── gorm
│  │  └── obs-opentelemetry
│  │  └── logging
│  │  └── zap
│  └── payment		---------------------------- app payment have http ui/gateway, rpc station,da service/server
│  ├── bin		---- go build cmd output to bin
│  ├── build	---- makefile, dockerfile,docker-compose.yml to build, run
│  ├── cmd		---- main.go to load da/station/gw cmd to run
│  │  ├── da
│  │  ├── gw
│  │  └── station
│  ├── conf	---------- env biz config for local/dev/test/pre/stress/gray/prod 
│  │  ├── dev
│  │  ├── gray
│  │  ├── local
│  │  ├── pre
│  │  ├── prod
│  │  ├── stress
│  │  └── test
│  ├── data	-------------- sql data, encode/decode meta data
│  ├── docs	-------------- app help doc
│  ├── internal ----------- internal don't be used by out package, code biz logic
│  │  ├── da	------------------------ dal 
│  │  │  ├── consumer ---- event drive consumer
│  │  │  ├── dao ---- db table data persistence op
│  │  │  ├── domain ---- domain entries, interface, errors
│  │  │  │  └── mocks ---- mock for test
│  │  │  ├── model ---- table entry model 
│  │  │  ├── repository ---- impl domain db repository interface
│  │  │  │  └── mysql
│  │  │  └── usecase ----- biz logic use repositories 
│  │  ├── gw	------------------------ ui/gateway
│  │  │  └── middleware -------- middleware handle
│  │  └── station -------------------- biz logic station by using cache 
│  │  └── consumer ---- event drive consumer for cache
│  │  ├── domain ---- domain entries, interface, errors
│  │  ├── repository ---- impl domain cache, mq produce repository interface
│  │  │  ├── redis
│  │  │  │  └── lua
│  │  │  └── rmq
│  │  └── usecase ----- biz logic use repositories 
│  ├── manifests -------------- k8s/istio configmap,secret,deployment+service,ingress resource workload and traffic/flow control
│  │  ├── traffic
│  │  │  └── istio
│  │  └── workloads
│  └── pkg --------------------- app common pkg
│  ├── configparser
│  ├── constants
│  ├── injectors
│  ├── subscriber
│  ├── utils
│  │  ├── logutils
│  │  └── netutils
│  └── version 
├── kratos	----------------- use kratos framwork develop
└── opentelemetry-go-contrib ----- otel go contrib just for new one, if change, it's not origin, u can fork, go mod edit -replace