fix(raw): 8 张 inc_d ini where 用 COALESCE(update_time, create_time) 兜底

PG NULL 不可比较，update_time IS NULL 的行此前不进 raw inc_d；
存量 his_o 用 create_time 锚点，不受影响。

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

jobs/raw/prd/raw_prd_checklist_base_info_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.checklist_base_info
 column = id,code,year,sport,manufacturer,sets,display_name,type,num,use_num,status,remark,create_time,create_by,update_time,update_by,lot,del_flg,act_point_type,parent_id,sets_version,merchant_id,merchant_name,share,share_to_merchant,custom,panini_config_id,import_failure_cause,check_failure_cause,import_status,review_msg,sub_type,title,data_version,sport_blend,display_name_translations
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/prd/raw_prd_panini_checklist_base_info_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.panini_checklist_base_info
 column = id,code,year,sport,manufacturer,sets,sets_version,display_name,type,num,use_num,status,remark,lot,del_flg,carmichael_img_type,create_time,create_by,update_time,update_by,import_type,report_flag,base_config,base_price,min_reference_price,max_reference_price,prop1,prop2,prop3,prop4,data_version,first_sport,sets_display_name
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/prd/raw_prd_panini_checklist_version_config_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.panini_checklist_version_config
 column = id,panini_list_id,set_version,carmichael_img_type,import_type,report_flag,base_config,base_price,min_reference_price,max_reference_price,num,use_num,status,remark,del_flg,create_time,create_by,update_time,update_by,prop1,prop2,prop3,prop4,tag,display_name,presale_time,max_box,league,issuing_time,issuing_price,display_name_translations,sale_time,open_time
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/shp/raw_shp_tzy_merchant_info_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.tzy_merchant_info
 column = id,appid,user_id,username,name,status,remark,create_by,create_time,update_by,update_time,code,fans,sale_num,applet_auth,applet_lives_auth,applet_lives_role,commission_rate,prop_json,sort_rate,check_status,live_type,living_auth_config,goods_sold_num,hot_config,tag_config,mall_role,living_time,express_level,del_flg,group_show_name,main_business,min_card_num,dy_name,current_month_score,member_level,member_name,member_medal,prefer_valid_time,tag_id,show_status,point_type,refund_limit_day,open_act_discount,reputation_score,hide_stock,version,total_sold_num,shipping_cost_config,merchant_group_id
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/trd/raw_trd_card_group_info_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.card_group_info
 column = id,merchant_id,appid,name,code,status,specs,type,random_type,total_price,copies,unit_price,sold_copies,release_time,cycle,show_applet,title,msg,remark,create_time,update_by,update_time,order_quota_min,order_quota_max,user_quota_max,start_time,marketing_info,reviewmsg,lock,commission_rate,year,sport,manufacturer,sets,act,config,info_config,total_num,banner_end_time,add_banner,finished_time,display_name,group_sets_no,close_payment_time,confirm_send_time,close_payment_status,open_card,close_payment_record,group_full_time,live_create_time,live_start_time,live_end_time,report_start_time,report_end_time,report_review_num,report_review_first_time,report_review_end_time,review_hold_time,review_approval_time,review_num,config_json,free_flag,mer_name,change_type,act_price,act_config_json,real_sold_num,weight,hot_type,team_first,prop1,prop2,prop3,point_rate,point_max,point_min,list_id,list_code,mix_copies,sub_type,act_point_type,payment_method,payment_total_price,payment_commission,payment_finished_price,payment_remain_price,payment_online_price,exclusive,has_bg,merchant_sort,del_flg,del_time,review_account,act_id,sold_end_time,panini_list_id,hot_type_config,goods_type,report_flag,use_coupon,user_level,custom,gift_card_id,group_show_name,min_card_num,act_type,waring_type,compensation_status,point_type,first_act_config,gift_config,version,extra_prop,use_member_discount,merchant_open
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/trd/raw_trd_card_group_order_info_inc_d.ini

@@ -18,7 +18,7 @@ database = hobby_stocks
 table = public.card_group_order_info
 column = id,group_info_id,merchant_id,user_id,shipping_address_id,purchase_count,order_no,accounts_payable,actual_payment,payment_type,payment_time,coupon,discount,status,remark,create_time,create_by,update_time,update_by,payment_status,payment_status_desc,payment_success_time,del_flg,curier_company,refund_fee,refund_time,anonymous,pick_up_type,ship_time,refund_success_time,refund_recv_accout,refund_account,refund_request_source,card_price,act_price,goods_price_json,payment_sub_type,team_first,refuse_status,prop1,prop2,prop3,point,order_type,trade_amount,refund_type,refund_reason,evaluation,user_refund_time,refund_status,merchant_refund_reason,point_deduct,shipping_cost,merchant_remark,pay_record,order_sub_type,give_user_code,give_order_id,read_flag,give_num,invoice_id,combination_no,open_self,refund_desc,goods_allocate,close_payment_status,close_payment_time,finished_time,expire_time,settlement_amount,platform_coupon,platform_discount,discount_amount,member_discount,shipping_free_id,shipping_free_amount,discount_point,un_shipped_num,pre_un_shipped_num,wait_shipped_num,pre_wait_shipped_num,refuse_time,refuse_notice,pickup_time,waring_type,waring_status,point_type,delivery_end_time,serve_status,self_pickup_time,act_discount
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/usr/raw_usr_app_base_user_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.app_base_user
 column = id,appid,point,level,register_channel,status,del_flg,remark,create_by,create_time,update_by,update_time,username,growth_num,code,notify_flag,user_id,notify_type,face_verify,open_psd,refuse_pick_up,prop1,prop2,prop3,prop4,window_open,open_invoice,blacklist,id_card,member_level,member_name,current_month_growth,member_init_flag,member_keep_growth,register_ip_addr,register_addr,login_ip_addr,login_addr,notify_top_show,voice_reminder,vibrate_reminder,consume_amount,order_total_num,open_card_show,effects_type,live_config_json,cancel_verify_num,version,daily_limit,weekly_limit,monthly_limit,live_anonymous
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000

jobs/raw/usr/raw_usr_app_user_cert_info_inc_d.ini

@@ -14,7 +14,7 @@ database = hobby_stocks
 table = public.app_user_cert_info
 column = id,user_id,cert_birthday,cert_sex,cert_province,cert_city,version,status,del_flag,create_time,update_time
 columnType =
-where = update_time >= '${start_date}' AND update_time < '${stop_date}'
+where = COALESCE(update_time, create_time) >= '${start_date}' AND COALESCE(update_time, create_time) < '${stop_date}'
 querySql =
 splitPk = id
 fetchSize = 1000