diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/PatientsService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/PatientsService.java index ff8999f..3cdbd14 100644 --- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/PatientsService.java +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/PatientsService.java @@ -12,6 +12,8 @@ import com.lyms.platform.pojo.*; import com.lyms.platform.query.*; import org.apache.commons.collections.CollectionUtils; import org.apache.commons.lang.StringUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Sort; import org.springframework.stereotype.Service; @@ -24,7 +26,7 @@ import java.util.List; */ @Service public class PatientsService { - + private Logger logger = LoggerFactory.getLogger("SIEVE-JOB"); @Autowired private IPatientDao iPatientDao; @Autowired @@ -175,7 +177,7 @@ public class PatientsService { List patientses = iPatientDao.queryPatient(patientsQuery.convertToQuery()); int batchSize = 200; if (CollectionUtils.isNotEmpty(patientses)) { - LogUtil.taskInfo("add sieve form patent job size:" + patientses.size()); + logger.info("add sieve form patent job size:" + patientses.size()); int end = 0; List patient; for (int i = 0; i < patientses.size(); ) { @@ -508,6 +510,7 @@ public class PatientsService { } private class PatientWorker extends Thread { + private List patientses; private long startTime; @@ -518,13 +521,14 @@ public class PatientsService { @Override public void run() { - LogUtil.taskInfo("add sieve PatientWorker job :" + getName() + " start."); + logger.info("add sieve PatientWorker job :" + getName() + " start."); SieveQuery sieveQuery = new SieveQuery(); sieveQuery.setYn(YnEnums.YES.getId()); for (Patients patient : patientses) { sieveQuery.setParentId(patient.getId()); List list = sieveDao.queryList(sieveQuery.convertToQuery()); if (CollectionUtils.isEmpty(list)) { + logger.info("find sieve empty parentid:"+patient.getId()); SieveModel sieveModel = convertToModel(patient); sieveModel.setFrom("0"); SieveApplyOrderQuery sieveApplyOrderQuery=new SieveApplyOrderQuery(); @@ -546,7 +550,7 @@ public class PatientsService { sieveDao.addChanQianSieve(sieveModel); } } - LogUtil.taskInfo("add sieve PatientWorker job :" + getName() + " end.costTime :" + (System.currentTimeMillis() - startTime) + " ms."); + logger.info("add sieve PatientWorker job :" + getName() + " end.costTime :" + (System.currentTimeMillis() - startTime) + " ms."); } } } \ No newline at end of file