hzya
/
kangarooDataCenterV3
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge branch 'dev' of http://ufidahz.com.cn:9015/root/kangarooDataCenterV3 into kunb

This commit is contained in:
yuqh 2024-08-14 11:05:01 +08:00
parent e4ea65a730 3b7571a3b1
commit c3f969541b
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
service/src/main/java/com/hzya/frame/grpU8/nxproof/controlindex/service/impl/ControlIndexServiceImpl.java
View File

@ -28,9 +28,9 @@ public class ControlIndexServiceImpl implements IControlIndexService {
private IGbiZbsyrecDao gbiZbsyrecDao; private IGbiZbsyrecDao gbiZbsyrecDao;
@Autowired @Autowired
private IOerDjmlDao oerDjmlDao; private IOerDjmlDao oerDjmlDao;
@Autowired /*@Autowired
@Qualifier("sqlSessionMaster") @Qualifier("sqlSessionMaster")
private SqlSession sqlSession; private SqlSession sqlSession;*/
//查询数据库表状态为1的数据，写入指标执行表 //查询数据库表状态为1的数据，写入指标执行表
@Override @Override
public String queryControlIndexByStatus(String stauts) { public String queryControlIndexByStatus(String stauts) {
@ -43,7 +43,7 @@ public class ControlIndexServiceImpl implements IControlIndexService {
case "1": case "1":
logger.info("========开始查询数据库表状态为1的数据========"); logger.info("========开始查询数据库表状态为1的数据========");
controlIndexEntity.setZT("1"); controlIndexEntity.setZT("1");
controlIndexEntities= sqlSession.selectList("ControlIndexEntity_list_base", controlIndexEntity); // controlIndexEntities= sqlSession.selectList("ControlIndexEntity_list_base", controlIndexEntity);
logger.info("根据状态为1查询出来的数据有{}条",controlIndexEntities.size()); logger.info("根据状态为1查询出来的数据有{}条",controlIndexEntities.size());
if(CollUtil.isNotEmpty(controlIndexEntities) && controlIndexEntities.size()>0){ if(CollUtil.isNotEmpty(controlIndexEntities) && controlIndexEntities.size()>0){
for (ControlIndexEntity indexEntity : controlIndexEntities) { for (ControlIndexEntity indexEntity : controlIndexEntities) {
@ -90,7 +90,7 @@ public class ControlIndexServiceImpl implements IControlIndexService {
//修改T_ZCCW_CONTROLINDEX的指标同步状态为1 //修改T_ZCCW_CONTROLINDEX的指标同步状态为1
indexEntity.setZBTBZT("1"); indexEntity.setZBTBZT("1");
logger.info("保存中开始根据验收单号:{},会计年度:{},指标id：{}更新指标同步状态",indexEntity.getYSDH(),indexEntity.getKJND(),indexEntity.getZBID()); logger.info("保存中开始根据验收单号:{},会计年度:{},指标id：{}更新指标同步状态",indexEntity.getYSDH(),indexEntity.getKJND(),indexEntity.getZBID());
sqlSession.update("ControlIndexEntity_update",indexEntity); // sqlSession.update("ControlIndexEntity_update",indexEntity);
} }
}catch (Exception e){ }catch (Exception e){
logger.info("指标占用失败:{}",e.getMessage()); logger.info("指标占用失败:{}",e.getMessage());
@ -107,7 +107,7 @@ public class ControlIndexServiceImpl implements IControlIndexService {
case "3": case "3":
logger.info("========开始查询数据库表状态为3的数据========"); logger.info("========开始查询数据库表状态为3的数据========");
controlIndexEntity.setZT("3"); controlIndexEntity.setZT("3");
controlIndexEntities= sqlSession.selectList("ControlIndexEntity_list_base", controlIndexEntity); // controlIndexEntities= sqlSession.selectList("ControlIndexEntity_list_base", controlIndexEntity);
logger.info("根据状态为3查询出来的数据有{}条",controlIndexEntities.size()); logger.info("根据状态为3查询出来的数据有{}条",controlIndexEntities.size());
if(CollUtil.isNotEmpty(controlIndexEntities) && controlIndexEntities.size()>0){ if(CollUtil.isNotEmpty(controlIndexEntities) && controlIndexEntities.size()>0){
for (ControlIndexEntity indexEntity : controlIndexEntities) { for (ControlIndexEntity indexEntity : controlIndexEntities) {
@ -135,7 +135,7 @@ public class ControlIndexServiceImpl implements IControlIndexService {
//修改T_ZCCW_CONTROLINDEX的指标同步状态为1 //修改T_ZCCW_CONTROLINDEX的指标同步状态为1
indexEntity.setZBTBZT("1"); indexEntity.setZBTBZT("1");
logger.info("删除中开始根据验收单号:{},会计年度:{},指标id：{}更新指标同步状态",indexEntity.getYSDH(),indexEntity.getKJND(),indexEntity.getZBID()); logger.info("删除中开始根据验收单号:{},会计年度:{},指标id：{}更新指标同步状态",indexEntity.getYSDH(),indexEntity.getKJND(),indexEntity.getZBID());
sqlSession.update("ControlIndexEntity_update",indexEntity); // sqlSession.update("ControlIndexEntity_update",indexEntity);
} }
}catch (Exception e){ }catch (Exception e){
logger.info("指标删除失败:{}",e.getMessage()); logger.info("指标删除失败:{}",e.getMessage());