|
@ -17,6 +17,7 @@ import org.quartz.JobDataMap;
|
|
|
import org.quartz.JobExecutionContext;
|
|
|
import org.quartz.JobExecutionException;
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
import org.springframework.context.annotation.Scope;
|
|
|
import org.springframework.jdbc.core.BeanPropertyRowMapper;
|
|
|
import org.springframework.jdbc.core.JdbcTemplate;
|
|
|
import org.springframework.stereotype.Component;
|
|
@ -32,6 +33,7 @@ import java.util.*;
|
|
|
* 每天的签约到达量统计
|
|
|
*/
|
|
|
@Component
|
|
|
@Scope("prototype")
|
|
|
public class AllSignJob implements Job {
|
|
|
private WlyyQuotaVO wlyyQuota;//指标对象
|
|
|
private WlyyJobConfigVO wlyyJobConfig;//配置对象
|
|
@ -122,9 +124,10 @@ public class AllSignJob implements Job {
|
|
|
String sql=" select id,code,idcard,hospital,admin_team_code,expenses_status from wlyy_sign_family a where a.type =2 and a.status >= 1 and expenses_status=1 and a.apply_date< '"+dateTemp+"' limit "+start+","+pageSize ;
|
|
|
signFamilys = jdbcTemplate.query(sql,new BeanPropertyRowMapper(SignFamily .class)); // signFamilyDao.findByJiatingSignYesterday(dateTemp);
|
|
|
//数据过滤清洗出脏数据 -----------start
|
|
|
int i=0;
|
|
|
int i=0;
|
|
|
for (SignFamily signFamily : signFamilys) {
|
|
|
allsize++;
|
|
|
i++;
|
|
|
ETLModel etlModel = new ETLModel();
|
|
|
String orgCode = signFamily.getHospital();
|
|
|
if (StringUtils.isEmpty(orgCode)) {
|