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

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) */
create database `pay{$dbpartitions}`
CREATE TABLE `pay{$dbpartitions}`.`user_assert`
(
    `userId` bigint unsigned NOT NULL DEFAULT '0',
    `assetCn` bigint unsigned NOT NULL DEFAULT '0',
    `assetType` tinyint unsigned NOT NULL DEFAULT '0',
    `version` bigint unsigned NOT NULL DEFAULT '0',
    `createdAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_assertType` (`userId`,`assetType`)
) ENGINE=InnoDB  DEFAULT CHARSET=utf8mb4 partition by hash ( `userId` ) partitions 16;
create table `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 */
CREATE TABLE `user_asset`
(
    `userId` bigint unsigned NOT NULL DEFAULT '0',
    `assetCn` bigint unsigned NOT NULL DEFAULT '0',
    `assetType` tinyint unsigned NOT NULL DEFAULT '0',
    `version` bigint unsigned NOT NULL DEFAULT '0',
    `createdAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_assetType` (`userId`,`assetType`)
) DEFAULT CHARSET=utf8mb4 SHARD_ROW_ID_BITS=4 PRE_SPLIT_REGIONS=3 partition by hash ( `userId` ) partitions 16;
show table user_asset regions;


/* 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; */
create database `pay` PARTITION_MODE=partitioning;
CREATE TABLE `pay`.`user_asset`
(
    `userId` bigint unsigned NOT NULL DEFAULT '0',
    `assetCn` bigint unsigned NOT NULL DEFAULT '0',
    `assetType` tinyint unsigned NOT NULL DEFAULT '0',
    `version` bigint unsigned NOT NULL DEFAULT '0',
    `createdAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_assetType` (`userId`,`assetType`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 partition by hash ( `userId` ) partitions 128;
/*dbpartition by hash(`userId`) tbpartition by hash(`userId`) tbpartitions 16*/

show table info from `pay`.`user_asset`;
show topology from `pay`.`user_asset`;
show rule from `pay`.`user_asset`;
SHOW NODE;
show db status;
show table status;

SET AUTOCOMMIT=0; 
BEGIN；
   a = SELECT assetCn FROM user_asset WHERE userId={$userId} and assetType={$assetType} FOR UPDATE;  
   update user_asset set assetCn=a.assetCn+{$incrCn} where userId={$userId} and assetType={$assetType}; 
COMMIT;

a = SELECT assetCn FROM user_asset WHERE userId={$userId} and assetType={$assetType};
#$oldAssetCn = a.assetCn
#$newAssetCn = a.assetCn+$incrCn
#if $newAssetCn>=0 ->update
update user_asset set assetCn={$newAssetCn} where userId={$userId} and assetType={$assetType} and assetCn = {$oldAssetCn} 

a = SELECT assetCn,version FROM user_asset WHERE userId={$userId} and assetType={$assetType};
#$oldAssetCn = a.assetCn
#$oldVersion = a.version
#$newAssetCn = a.assetCn+$incrCn
#if $newAssetCn>=0 ->update
#$newVersion = $oldVersion+1
update user_asset set assetCn={$newAssetCn} and version={$newVersion} where userId={$userId} and assetType={$assetType} and version = {$oldVersion} 

/* local mysql innodb(index B+TREE) */
create table `pay{$dbpartitions}`.`user_assert_record`
(
    `userId` bigint unsigned not null default '0',
    `opUserType` tinyint unsigned not null default '0',
    `bizId` bigint unsigned not null default '0',
    `bizType` tinyint unsigned not null default '0',
    `objId` varchar(128) not null default '',
    `eventId` varchar(128) not null default '',
    `eventType` varchar(128) not null default '',
    `record` varchar(256) not null default '',
    `recordOp` varchar(64) not null default '',
    `createdAt` timestamp not null  DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp not null default CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_opUserType_event` (`userId`,`opUserType`,`eventId`)
)engine=InnoDB default charset=utf8mb4 partition by hash(`userId`) PARTITIONS 16 ;
create table `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 */
create table `pay`.`user_asset_record`
(
    `userId` bigint unsigned not null default '0',
    `opUserType` tinyint unsigned not null default '0',
    `bizId` bigint unsigned not null default '0',
    `bizType` tinyint unsigned not null default '0',
    `objId` varchar(128) not null default '',
    `eventId` varchar(128) not null default '',
    `eventType` varchar(128) not null default '',
    `record` varchar(256) not null default '',
    `recordOp` varchar(64) not null default '',
    `createdAt` timestamp not null  DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp not null default CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_opUserType_event` (`userId`,`opUserType`,`eventId`)
)engine=InnoDB default charset=utf8mb4 SHARD_ROW_ID_BITS=4 PRE_SPLIT_REGIONS=5
    PARTITION BY HASH (`userId`) PARTITIONS 16;
show table user_asset_record regions;


/* 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; */
create database `pay` PARTITION_MODE=partitioning;
create table `pay`.`user_asset_record`
(
    `userId` bigint unsigned not null default '0',
    `opUserType` tinyint unsigned not null default '0',
    `bizId` bigint unsigned not null default '0',
    `bizType` tinyint unsigned not null default '0',
    `objId` varchar(128) not null default '',
    `eventId` varchar(128) not null default '',
    `eventType` varchar(128) not null default '',
    `record` varchar(256) not null default '',
    `recordOp` varchar(64) not null default '',
    `createdAt` timestamp not null  DEFAULT CURRENT_TIMESTAMP,
    `updatedAt` timestamp not null default CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
    UNIQUE KEY `uk_user_opUserType_event` (`userId`,`opUserType`,`eventId`)
)engine=InnoDB /*tokudb/xengine*/ default PARTITION BY HASH (`userId`) PARTITIONS 256;
/*dbpartition by hash(`userId`) tbpartition by hash(`userId`) tbpartitions 16*/

show table info from `pay`.`user_asset_record`;
show topology from `pay`.`user_asset_record`;
show rule from `pay`.`user_asset_record`;
SHOW NODE;
show db status;
show table status;

./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