diff --git a/base-buildpackage/src/main/java/com/hzya/frame/plugin/gm/SubjectAssBalancePlugin.java b/base-buildpackage/src/main/java/com/hzya/frame/plugin/gm/SubjectAssBalancePlugin.java index adb49862..82d0359a 100644 --- a/base-buildpackage/src/main/java/com/hzya/frame/plugin/gm/SubjectAssBalancePlugin.java +++ b/base-buildpackage/src/main/java/com/hzya/frame/plugin/gm/SubjectAssBalancePlugin.java @@ -119,39 +119,32 @@ public class SubjectAssBalancePlugin extends PluginBaseEntity { String subjCodes = "'54010501','54010601','54010701','220202','54010502','54010602','54010702'"; try { logger.info("调用:" + getPluginName() + "-插件"); - long a = System.currentTimeMillis(); - this.delete(); - long b = System.currentTimeMillis(); - System.out.println("清理耗时:" + (b - a)); MdmGmSubjectBalanceEntity mdmGmSubjectBalanceEntity = new MdmGmSubjectBalanceEntity(); mdmGmSubjectBalanceEntity.setPkCorp("1001"); mdmGmSubjectBalanceEntity.setSubjcodes(subjCodes); List mdmGmSubjectBalanceEntities = mdmGmSubjectBalanceDao.queryBalanceBySubjectCodesAndPkCorp(mdmGmSubjectBalanceEntity); - long c = System.currentTimeMillis(); - System.out.println("查询耗时:" + (c - b)); - List> batches = Lists.partition(mdmGmSubjectBalanceEntities, 500); - for (List batch : batches) { - mdmGmSubjectBalanceDao.saveList(batch); + if (mdmGmSubjectBalanceEntities != null && mdmGmSubjectBalanceEntities.size() != 0) { + this.delete(); + List> batches = Lists.partition(mdmGmSubjectBalanceEntities, 500); + for (List batch : batches) { + mdmGmSubjectBalanceDao.saveList(batch); + } + + //成功 + IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); + integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); + integrationTaskLivingDetailsEntity.setRootAppNewData(subjCodes); + integrationTaskLivingDetailsEntity.setNewTransmitInfo(subjCodes); + integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); + integrationTaskLivingDetailsEntity.setBusinessDate(now.toString()); + integrationTaskLivingDetailsEntity.setRootAppPk(now + " " + time); + integrationTaskLivingDetailsEntity.setRootAppBill(now + " " + time); + integrationTaskLivingDetailsEntity.setNewSystemPrimary(null); + integrationTaskLivingDetailsEntity.setNewSystemNumber(null); + integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); + saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); } - long d = System.currentTimeMillis(); - System.out.println("插入耗时:" + (d - c)); - System.out.println("总耗时:" + (d - a)); - - - //成功 - IntegrationTaskLivingDetailsEntity integrationTaskLivingDetailsEntity = new IntegrationTaskLivingDetailsEntity(); - integrationTaskLivingDetailsEntity.setNewState(ProfilesActiveConstant.LOG_STATUS_Y); - integrationTaskLivingDetailsEntity.setRootAppNewData(subjCodes); - integrationTaskLivingDetailsEntity.setNewTransmitInfo(subjCodes); - integrationTaskLivingDetailsEntity.setNewPushDate(new Date()); - integrationTaskLivingDetailsEntity.setBusinessDate(now.toString()); - integrationTaskLivingDetailsEntity.setRootAppPk(now + " " + time); - integrationTaskLivingDetailsEntity.setRootAppBill(now + " " + time); - integrationTaskLivingDetailsEntity.setNewSystemPrimary(null); - integrationTaskLivingDetailsEntity.setNewSystemNumber(null); - integrationTaskLivingDetailsEntity.setPluginId(getPluginId()); - saveOrUpdateBusinessLogUtil.saveOrUpdate(integrationTaskLivingDetailsEntity); } catch (Exception e) { e.printStackTrace();