退房业务报表.sql

@@ -0,0 +1,48 @@
+
+select crc.id '合同ID', maintainer_sd.id '所属门店ID', maintainer_sd.name '所属门店', hhr.address '房源地址', mt_emp.name '合同维护人',
+	cri.name '租客姓名', crc.begin_time '合同开始日期', crc.end_time '合同结束日期', 
+	crc.quite_date '退租日期', crc.terminate_type '退租类型', crc.cancel_info '退租原因',
+	case when JSON_EXTRACT(crc.`cancel_info`, '$.paymentAccountType')=1 then '银联' 
+	when JSON_EXTRACT(crc.`cancel_info`, '$.paymentAccountType')=2 then '支付宝' 
+	when JSON_EXTRACT(crc.`cancel_info`, '$.paymentAccountType')=3 then '微信' end '退款途径',
+	REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.paymentAccount'), '"', ''), 'null', '') '退款账号',
+	CONCAT(REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.bankName'), '"', ''), 'null', ''), REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.bankNumber'), '"', ''), 'null', '')) '银行行号和开户银行',
+	REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.reason'), '"', ''), 'null', '') '退租备注',
+	REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.rejectName'), '"', ''), 'null', '') '退租操作人',
+	REPLACE(REPLACE(JSON_EXTRACT(crc.`cancel_info`, '$.rejectTime'), '"', ''), 'null', '') '退租时间',
+	_total.应收 '应收账单',
+	_total.应付 '应付账单',
+	_total.应付-_total.应收 '应退款金额',
+	_detail.info '财务退款备注',
+	IF(_flow_status.avg_status is null, '', IF(_flow_status.avg_status=1, '待审核', IF(_flow_status.avg_status=3, '审核通过', '部分审核通过'))) '审核状态',
+	IF(_flow_status.avg_status is null, '', IF(_flow_status.avg_status=3, '已退款', IF(_flow_status.avg_status>1, '已部分退款', '未退款'))) '退款信息'
+from yuxin_contract.cont_renter_contract crc 
+left join yuxin_house.hse_house_room hhr on hhr.is_delete=0 and hhr.id=crc.house_id
+left join yuxin_setting.setting_employee_dept maintainer_ed on maintainer_ed.emp_id=crc.maintainer_id and maintainer_ed.is_delete=0
+left join yuxin_setting.setting_department maintainer_sd on maintainer_sd.id=maintainer_ed.dept_id and maintainer_sd.is_delete=0
+left join yuxin_setting.setting_employee_info mt_emp on mt_emp.id=crc.maintainer_id and mt_emp.is_delete=0
+left join yuxin_contract.cont_renter_info cri on cri.is_delete=0 and cri.customer_type=1 and cri.contract_id=crc.id
+left join (
+    select bd.biz_id,
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.original_money) '应付',
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.occurred_money) '已付',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.original_money) '应收',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.occurred_money) '已收'
+    from yuxin_finance.fin_finance_bill_detail bd
+    where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2
+    group by bd.biz_id
+) _total on _total.biz_id= crc.id
+left join (
+	select bd.biz_id, GROUP_CONCAT(CONCAT(sd.name, bd.original_money)) 'info'
+	from yuxin_finance.fin_finance_bill_detail bd 
+	left join yuxin_setting.setting_dictionary sd on sd.id=bd.fee_subject_id
+	where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2 and bd.fee_direction=2
+	group by bd.biz_id 
+) _detail on _detail.biz_id=crc.id
+left join (
+	select bf.biz_id, avg(bf.audit_status) 'avg_status'
+	from yuxin_finance.fin_finance_bill_flow bf
+	where bf.is_delete=0 and bf.biz_type=2 and bf.bill_type=2 
+	group by bf.biz_id
+) _flow_status on _flow_status.biz_id=crc.id
+where crc.contract_status=3 and crc.is_delete=0

etl_bill_detail.py

@@ -33,15 +33,15 @@ cols = {
     'contract_dept_name': [NVARCHAR(50), '合同所属门店/部门'],
     'contract_id': [NVARCHAR(64), '合同ID'],
     'contract_no': [NVARCHAR(64), '合同编号'],
-    'contract_medium': [NVARCHAR(50), '合同类型'],
+    'contract_medium': [NVARCHAR(50), '合同类型【1-纸质,2-电子】'],
     'renter_name': [NVARCHAR(50), '租客姓名'],
     'renter_phone': [NVARCHAR(20), '租客手机号'],
-    'renter_id_type': [NVARCHAR(50), '租客证件类型'],
+    'renter_id_type': [NVARCHAR(50), '租客证件类型证件类型【1-身份证，2-护照，3-港澳通行证，4-台湾同胞证，5-军官证，6-驾驶证 7-社会信用代码'],
     'renter_id_number': [NVARCHAR(50), '租客证件号码'],
-    'sign_type': [NVARCHAR(50), '成交方式'],
+    'sign_type': [NVARCHAR(50), '成交方式【1-新签,2-续签,3-转租,4-换房】'],
     'contract_begin_date': [Date, '合同开始日期'],
     'contract_end_date': [Date, '合同结束日期'],
-    'payment_method': [NVARCHAR(50), '付款方式'],
+    'payment_method': [NVARCHAR(50), '付款方式【付款模式【1-提前付款天数,2-固定付款日期,3-提前1个月固定付款日期】'],
     'sign_date': [Date, '签约日期'],
     'signer_id': [NVARCHAR(64), '签约人ID'],
     'signer_name': [NVARCHAR(50), '签约人'],
@@ -286,7 +286,7 @@ def update_column_comment(conn, target_db):
 def etl():
     config = load_config()
 
-    target_db = 'bi_bill_detail_'
+    target_db = 'bi_finance_statement_'
 
     connection_string = 'mysql+pymysql://{username}:{pwd}@{host}:{port}/{db}?charset=utf8'\
         .format(username=config['mysql']['username'],

合同业务主表.sql

@@ -0,0 +1,108 @@
+select 
+	crc.tenant_id, 
+    hhb.dept_id '房源所属门店ID', house_sd.name '房源所属门店名称', hhr.address '房源地址', hhr.house_area '房源面积',
+    crc_sd.id '合同所属门店/部门ID', crc_sd.name '合同所属门店/部门',
+    crc.id '合同ID', crc.contract_no '合同编号', crc.maintainer_id '合同维护人ID', mt_emp.name '合同维护人',
+    cri.name '租客姓名', crc.begin_time '合同开始日期', crc.end_time '合同结束日期', DATEDIFF(crc.end_time, crc.begin_time)+1 '签约天数',
+    crc.`type` '合同类型', crc.sign_type '成交方式',
+                (CASE -- 11-待处理
+           WHEN crc.contract_status = 1 AND crc.contract_sub_status = 1 THEN 11
+               -- 12-待租客签字
+           WHEN crc.contract_status = 1 AND crc.contract_sub_status = 2
+                 and crc.sign_status = 1  THEN 12
+               -- 18-带租客实名
+           WHEN  crc.contract_status = 1 AND crc.contract_sub_status=2
+                 and crc.sign_status = 0    THEN 18
+               -- 21-待付款
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND
+                LENGTH(trim(crc.`down_payment_info`)) > 1 AND
+                JSON_EXTRACT(crc.`down_payment_info`, '$.status') = 0 THEN 21
+               -- 22-待租客确认
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND crc.is_sync_tenant = 1 THEN 22
+               -- 23-即将搬入
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND DATE(NOW()) < crc.begin_time THEN 23
+               -- 24-租约中
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND
+                LENGTH(trim(crc.`down_payment_info`)) > 1 AND
+                (JSON_EXTRACT(crc.`down_payment_info`, '$.status') = 1 AND DATE(NOW()) >= crc.begin_time AND
+                DATE(NOW()) < DATE_ADD(DATE(crc.end_time), INTERVAL 30 DAY) ) THEN 24
+               -- 25-即将到期
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND crc.`begin_time` <= DATE(NOW()) AND
+                 DATE(NOW()) >= DATE_ADD(DATE(crc.end_time), INTERVAL 30 DAY)
+                AND DATE(NOW())< DATE(crc.end_time)THEN 25
+               -- 26-已到期
+           WHEN crc.contract_status = 2 AND crc.transition_type != 1 AND DATE(NOW()) >= DATE(crc.end_time) THEN 26
+               -- 27-已续约
+           WHEN crc.contract_status = 2 AND crc.transition_type = 1 THEN 27
+               -- 31-正常退
+           WHEN crc.contract_status = 3 AND crc.terminate_type = 1 THEN 31
+               -- 32-违约退
+           WHEN crc.contract_status = 3 AND crc.terminate_type = 2 THEN 32
+               -- 41-已作废
+           WHEN crc.contract_status = 4 AND crc.invalid_type = 1 THEN 41
+               -- 42-已拒绝
+           WHEN crc.contract_status = 4 AND crc.invalid_type = 2 THEN 42
+               END) '合同状态',
+    crc.approval_status '审批状态',
+    0 'splitter',
+    IF((_deposit.应付-_deposit.已付), (_deposit.应付-_deposit.已付), 0) '押金余额',
+    IF((_total.应收), (_total.应收), 0) '应收总金额',
+    IF((_total.应付), (_total.应付), 0) '应付总金额',
+    IF((_this_month.应收), (_this_month.应收), 0) '截止至本月应收',
+    IF((_this_month.已收), (_this_month.已收), 0) '截止至本月已收',
+    IF((_this_month.应付), (_this_month.应付), 0) '截止至本月应付',
+    IF((_this_month.已付), (_this_month.已付), 0) '截止至本月已付',
+    IF((_this_month.应收-_this_month.已收), (_this_month.应收-_this_month.已收), 0) '截止至本月待收',
+    IF((_this_month.应付-_this_month.已付), (_this_month.应付-_this_month.已付), 0) '截止至本月待付',
+    IF((_over_due.应收-_over_due.已收), (_over_due.应收-_over_due.已收), 0) '截止至本日逾期待收'
+from yuxin_contract.cont_renter_contract crc
+left join yuxin_house.hse_house_room hhr on hhr.is_delete=0 and hhr.id=crc.house_id
+left join yuxin_house.hse_house_base hhb on hhb.is_delete=0 and hhb.id=crc.house_id
+left join yuxin_setting.setting_department house_sd on house_sd.id=hhb.dept_id and house_sd.is_delete=0
+left join yuxin_house.hse_community hc on hc.id=hhb.community_id and hc.is_delete=0
+left join yuxin_setting.setting_employee_dept crc_ed on crc_ed.emp_id=crc.maintainer_id and crc_ed.is_delete=0
+left join yuxin_setting.setting_department crc_sd on crc_sd.id=crc_ed.dept_id and crc_sd.is_delete=0
+left join yuxin_contract.cont_renter_info cri on cri.is_delete=0 and cri.customer_type=1 and cri.contract_id=crc.id
+left join yuxin_setting.setting_employee_info sign_emp on sign_emp.id=crc.sign_emp_id and sign_emp.is_delete=0
+left join yuxin_setting.setting_employee_info mt_emp on mt_emp.id=crc.maintainer_id and mt_emp.is_delete=0
+left join (
+    select bd.biz_id,
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.original_money) '应付',
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.occurred_money) '已付'
+    from yuxin_finance.fin_finance_bill_detail bd
+	left join yuxin_setting.setting_dictionary sd on sd.id=bd.fee_subject_id
+    where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2 and sd.label='FEESUBJECT@DEPOSIT'
+    group by bd.biz_id
+) _deposit on _deposit.biz_id= crc.id
+left join (
+    select bd.biz_id,
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.original_money) '应付',
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.occurred_money) '已付',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.original_money) '应收',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.occurred_money) '已收'
+    from yuxin_finance.fin_finance_bill_detail bd
+    where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2
+    group by bd.biz_id
+) _total on _total.biz_id= crc.id
+left join (
+    select bd.biz_id,
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.original_money) '应付',
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.occurred_money) '已付',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.original_money) '应收',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.occurred_money) '已收'
+    from yuxin_finance.fin_finance_bill_detail bd
+    where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2 and MONTH(bd.predict_time) = MONTH(CURRENT_DATE()) AND YEAR(bd.predict_time) = YEAR(CURRENT_DATE())
+    group by bd.biz_id
+) _this_month on _this_month.biz_id= crc.id
+left join (
+    select bd.biz_id,
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.original_money) '应付',
+    	SUM(IF(bd.fee_direction=1,0,1)*bd.occurred_money) '已付',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.original_money) '应收',
+    	SUM(IF(bd.fee_direction=1,1,0)*bd.occurred_money) '已收'
+    from yuxin_finance.fin_finance_bill_detail bd
+    where bd.is_valid=1 and bd.is_delete=0 and bd.biz_type=2 and bd.predict_time < CURRENT_DATE() and bd.not_occurred_money>0
+    group by bd.biz_id
+) _over_due on _over_due.biz_id= crc.id
+where crc.is_delete=0
+and crc.id='1593183025861980161'