更新kettle

epdc-cloud-analysis/doc/kettle/screen_vaccination/疫苗接种情况-数量.ktr

@@ -574,8 +574,8 @@
       <schema/>
       <table>epdc_screen_vaccination_statistics</table>
       <key>
-        <name>TYPE_KEY</name>
+        <name>DEPT_ID</name>
-        <field>TYPE_KEY</field>
+        <field>DEPT_ID</field>
         <condition>=</condition>
         <name2/>
       </key>
@@ -603,6 +603,10 @@
         <name>VACCINATION_COMPLETED_NUM</name>
         <rename>VACCINATION_COMPLETED_NUM</rename>
       </value>
+      <value>
+        <name>DEPT_ID</name>
+        <rename>DEPT_ID</rename>
+      </value>
     </lookup>
     <attributes/>
     <cluster_schema/>
@@ -631,13 +635,22 @@
     </partitioning>
     <connection>esua_epdc_custom</connection>
     <sql>SELECT
-	'street_party' as TYPE_KEY,
+	'community_party' AS TYPE_KEY,
+	ui.DEPT_ID,
 	count(1) AS COMMUNITY_TOTAL_NUM,
 	count(
-		( ui.VACCINATION_NUM = 1 and ui.VACCINATION_STATE=1) or null
+		(
+			ui.VACCINATION_NUM = 1
+			AND ui.VACCINATION_STATE = 1
+		)
+		OR NULL
 	) AS ONE_SHOT_NUM,
 	count(
-		( ui.VACCINATION_NUM = 2 and ui.VACCINATION_STATE=1) or null
+		(
+			ui.VACCINATION_NUM = 2
+			AND ui.VACCINATION_STATE = 1
+		)
+		OR NULL
 	) AS TWO_SHOTS_NUM,
 	count(
 		CASE
@@ -664,12 +677,85 @@
 		END
 	) AS VACCINATION_COMPLETED_NUM
 FROM
-(select u.*,count(u.id)
+	(
-	from epidemic_user_info u
+		SELECT
-	left join epidemic_user_inout_record uir on u.ID_CARD=uir.ID_CARD and uir.DEL_FLAG='0'
+			u.*, count(u.id),
-WHERE u.DEL_FLAG = '0'
+			SUBSTRING_INDEX(hi.PARENT_DEPT_IDS, ',', - 1) AS DEPT_ID,
-and uir.LIVE_ADDRESS_NAME like '%榆山%'
+			SUBSTRING_INDEX(
-group by u.id)ui</sql>
+				hi.PARENT_DEPT_NAMES,
+				'-',
+				- 1
+			) AS DEPT_NAME
+		FROM
+			epidemic_user_info u
+		LEFT JOIN epdc_house_resident hr ON CONVERT (
+			hr.RESIDENT_ID,
+			UNSIGNED INTEGER
+		) = u.id
+		LEFT JOIN epdc_housing_information hi ON hi.id = hr.HOUSE_ID
+		WHERE
+			u.DEL_FLAG = '0'
+		AND hr.DEL_FLAG = '0'
+		AND hi.DEL_FLAG = '0'
+		GROUP BY
+			u.id
+	) ui
+GROUP BY
+	ui.DEPT_ID
+UNION ALL
+	SELECT
+		'street_party' AS TYPE_KEY,
+		'1258587398679126017' AS DEPT_ID,
+		count(1) AS COMMUNITY_TOTAL_NUM,
+		count(
+			(
+				ui.VACCINATION_NUM = 1
+				AND ui.VACCINATION_STATE = 1
+			)
+			OR NULL
+		) AS ONE_SHOT_NUM,
+		count(
+			(
+				ui.VACCINATION_NUM = 2
+				AND ui.VACCINATION_STATE = 1
+			)
+			OR NULL
+		) AS TWO_SHOTS_NUM,
+		count(
+			CASE
+			WHEN ui.VACCINATION_STATE = 0 THEN
+				1
+			ELSE
+				NULL
+			END
+		) AS NOT_VACCINATED_NUM,
+		count(
+			CASE
+			WHEN ui.VACCINATION_STATE = 1 THEN
+				1
+			ELSE
+				NULL
+			END
+		) AS BEING_VACCINATED_NUM,
+		count(
+			CASE
+			WHEN ui.VACCINATION_STATE = 2 THEN
+				1
+			ELSE
+				NULL
+			END
+		) AS VACCINATION_COMPLETED_NUM
+	FROM
+		(
+			SELECT
+				u.*, count(u.id)
+			FROM
+				epidemic_user_info u
+			WHERE
+				u.DEL_FLAG = '0'
+			GROUP BY
+				u.id
+		) ui</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>

epdc-cloud-analysis/doc/kettle/screen_vaccination/疫苗接种情况-街道部门.ktr

@@ -669,23 +669,57 @@
       <schema_name/>
     </partitioning>
     <connection>esua_epdc_admin</connection>
-    <sql>select REPLACE(MD5(UUID()),'-','') as ID,
+    <sql>SELECT
-	'street_party' as TYPE_KEY,
+	REPLACE (MD5(UUID()), '-', '') AS ID,
+	'street_party' AS TYPE_KEY,
 	di.LONGITUDE,
 	di.LATITUDE,
-			d.id as dept_id,
+	d.id AS dept_id,
-			 d.name as dept_name,
+	d. NAME AS dept_name,
 	'0' AS REVISION,
 	'0' AS DEL_FLAG,
 	'admin' AS CREATED_BY,
 	NOW() AS CREATED_TIME,
 	'admin' AS UPDATED_BY,
 	NOW() AS UPDATED_TIME
-from sys_dept d
+FROM
-left join sys_dept_info di on di.dept_id=d.id
+	sys_dept d
-where d.del_flag='0'
+LEFT JOIN sys_dept_info di ON di.dept_id = d.id
-			and d.type_key='street_party'
+WHERE
-			and d.id not in (select dept_id from sys_dept_config)</sql>
+	d.del_flag = '0'
+AND d.type_key = 'street_party'
+AND d.id NOT IN (
+	SELECT
+		dept_id
+	FROM
+		sys_dept_config
+)
+UNION ALL
+	SELECT
+		REPLACE (MD5(UUID()), '-', '') AS ID,
+		'community_party' AS TYPE_KEY,
+		di.LONGITUDE,
+		di.LATITUDE,
+		d.id AS dept_id,
+		d. NAME AS dept_name,
+		'0' AS REVISION,
+		'0' AS DEL_FLAG,
+		'admin' AS CREATED_BY,
+		NOW() AS CREATED_TIME,
+		'admin' AS UPDATED_BY,
+		NOW() AS UPDATED_TIME
+	FROM
+		sys_dept d
+	LEFT JOIN sys_dept_info di ON di.dept_id = d.id
+	WHERE
+		d.del_flag = '0'
+	AND d.type_key = 'community_party'
+	AND d.id NOT IN (
+		SELECT
+			dept_id
+		FROM
+			sys_dept_config
+	)</sql>
     <limit>0</limit>
     <lookup/>
     <execute_each_row>N</execute_each_row>