|
|
@@ -123,4 +123,13 @@ public class EVController {
|
|
|
String updateSql="UPDATE s_interim_pay_certificate set status=2 where `status`=1 and id in(SELECT data_id from (SELECT DISTINCT data_id,count(1) zcount,SUM(if(`status`=2,1,0)) wcount from s_interim_task where `status`=2 GROUP BY data_id) c where c.zcount=c.wcount)";
|
|
|
jdbcTemplate.execute(updateSql);
|
|
|
}
|
|
|
+
|
|
|
+ @Scheduled(cron = "0 0 0/1 * * ?")
|
|
|
+ public void executeSql() {
|
|
|
+ String sql = "insert into u_task_batch(id,task_parallel_id,json_data,create_user,create_dept,create_time,update_user,update_time,status,is_deleted,nick_name,sign_format,sign_type) " +
|
|
|
+ "SELECT a.id, a.process_instance_id, json_object( 'approvalFileList', json_array(), 'approvalType', b.approval_type, 'comment', '', 'flag', 'OK', 'formDataId', b.form_data_id, 'parallelProcessInstanceId', a.parallel_process_instance_id, 'pass', TRUE, 'taskId', b.id ) AS json_data, " +
|
|
|
+ "a.task_user, a.create_dept, a.create_time, a.update_user, a.update_time, 1 AS STATUS, 0 AS is_deleted, a.task_user_name AS nick_name, 1 AS sign_format, 1 AS sign_type " +
|
|
|
+ "FROM u_task_parallel a, u_task b WHERE b.`status` IN ( 1, 2 ) AND a.process_instance_id = b.process_instance_id AND a.e_visa_content LIKE '%当前等待电签的批次较多%' AND not exists ( SELECT 1 FROM u_task_batch c WHERE JSON_EXTRACT( c.json_data, '$.parallelProcessInstanceId' ) = a.parallel_process_instance_id)";
|
|
|
+ jdbcTemplate.execute(sql);
|
|
|
+ }
|
|
|
}
|
lvy