diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISyncDataDao.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISyncDataDao.java new file mode 100644 index 0000000..28780f6 --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISyncDataDao.java @@ -0,0 +1,30 @@ +package com.lyms.platform.biz.dal; + +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.common.dao.operator.Page; +import com.lyms.platform.common.pojo.SyncDataModel; + +import java.util.List; + +/** + * Created by Administrator on 2016/9/20. + */ +public interface ISyncDataDao { + + public SyncDataModel addSyncData(SyncDataModel obj); + + public void updateSyncData(SyncDataModel obj, String id); + + public void deleteSyncData(String id); + + public SyncDataModel getSyncData(String id); + + public int querySyncDataModelCount(MongoQuery query); + + public List querySyncData(MongoQuery query); + + public Page findPage(MongoQuery query); + + public void addSyncData(String action, Object data, String id); + +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SyncDataDaoImpl.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SyncDataDaoImpl.java new file mode 100644 index 0000000..a117198 --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SyncDataDaoImpl.java @@ -0,0 +1,58 @@ +package com.lyms.platform.biz.dal.impl; + +import com.lyms.platform.biz.dal.ISyncDataDao; +import com.lyms.platform.common.dao.BaseMongoDAOImpl; +import com.lyms.platform.common.dao.operator.MongoCondition; +import com.lyms.platform.common.dao.operator.MongoOper; +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.common.dao.operator.Page; +import com.lyms.platform.common.pojo.SyncDataModel; +import org.bson.types.ObjectId; +import org.springframework.stereotype.Repository; + +import java.util.List; + +/** + * Created by Administrator on 2016/9/20. + */ +@Repository("syncDataDao") +public class SyncDataDaoImpl extends BaseMongoDAOImpl implements ISyncDataDao { + + @Override + public SyncDataModel addSyncData(SyncDataModel obj) { + return save(obj); + } + + @Override + public void updateSyncData(SyncDataModel obj, String id) { + update(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), obj); + } + + @Override + public void deleteSyncData(String id) { + boolean check = ObjectId.isValid(id); + if (check) { + delete(new MongoQuery(new MongoCondition("id", new ObjectId(id), MongoOper.IS)).convertToMongoQuery()); + } + } + + @Override + public SyncDataModel getSyncData(String id) { + return findById(id); + } + + @Override + public int querySyncDataModelCount(MongoQuery query) { + return (int)count(query.convertToMongoQuery()); + } + + @Override + public List querySyncData(MongoQuery query) { + return find(query.convertToMongoQuery()); + } + + @Override + public Page findPage(MongoQuery query) { + return findPage(query.convertToMongoQuery()); + } +} diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SyncDataService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SyncDataService.java new file mode 100644 index 0000000..3bc3dfe --- /dev/null +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SyncDataService.java @@ -0,0 +1,41 @@ +package com.lyms.platform.biz.service; + +import com.lyms.platform.biz.dal.ISyncDataDao; +import com.lyms.platform.common.dao.operator.MongoQuery; +import com.lyms.platform.common.pojo.SyncDataModel; +import com.lyms.platform.query.SyncDataQuery; +import org.apache.commons.lang.StringUtils; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.data.domain.Sort; +import org.springframework.stereotype.Service; + +import java.util.List; + +/** + * Created by Administrator on 2016/9/20. + */ +@Service +public class SyncDataService { + + @Autowired + private ISyncDataDao iSyncDataDao; + + public SyncDataModel addSyncData(SyncDataModel obj) { + return iSyncDataDao.addSyncData(obj); + } + + public void updateSyncData(SyncDataModel obj) { + iSyncDataDao.updateSyncData(obj, obj.getId()); + } + + public List querySyncData(SyncDataQuery syncDataQuery) { + MongoQuery query = syncDataQuery.convertToQuery(); + if (StringUtils.isNotEmpty(syncDataQuery.getNeed())) { + syncDataQuery.mysqlBuild(iSyncDataDao.querySyncDataModelCount(syncDataQuery.convertToQuery())); + query.start(syncDataQuery.getOffset()).end(syncDataQuery.getLimit()); + } + + return iSyncDataDao.querySyncData(query.addOrder(Sort.Direction.ASC, "created")); + } + +} diff --git a/platform-biz-service/pom.xml b/platform-biz-service/pom.xml index 5818424..00eca97 100644 --- a/platform-biz-service/pom.xml +++ b/platform-biz-service/pom.xml @@ -21,6 +21,11 @@ platform-dal ${project.version} + + com.lyms.core + platform-biz-patient-service + ${project.version} + diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/DepartmentsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/DepartmentsServiceImpl.java index f9547bf..d40670d 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/DepartmentsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/DepartmentsServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterDepartmentsMapper; @@ -18,90 +19,41 @@ public class DepartmentsServiceImpl extends DataAccessLayerService implements De @Autowired private MasterDepartmentsMapper masterDepartmentsMapper; - public DepartmentsMapper getslaveMapper() { - Object obj1 = getBean(DepartmentsMapper.class); - if (null != obj1) { - DepartmentsMapper masterUsersMapper = (DepartmentsMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addDepartments(Departments obj) { masterDepartmentsMapper.addDepartments(obj); - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterDepartmentsMapper.addDepartments(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateDepartments(Departments obj) { masterDepartmentsMapper.updateDepartments(obj); - - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - masterDepartmentsMapper.updateDepartments(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteDepartments(Integer id) { masterDepartmentsMapper.deleteDepartments(id); - - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - masterDepartmentsMapper.deleteDepartments(id); - } + iSyncDataDao.addSyncData("MysqlDel", new Departments(), id.toString()); } @Override public Departments getDepartments(Integer id) { - if (getStartUpModel()) { - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - return masterDepartmentsMapper.getDepartments(id); - } - } - return masterDepartmentsMapper.getDepartments(id); } @Override public int queryDepartmentsCount(DepartmentsQuery query) { - if (getStartUpModel()) { - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - return masterDepartmentsMapper.queryDepartmentsCount(query); - } - } return masterDepartmentsMapper.queryDepartmentsCount(query); } @Override public List queryDepartments(DepartmentsQuery query) { if (query.getNeed() != null) { - int count = 0; - if (getStartUpModel()) { - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - count= masterDepartmentsMapper.queryDepartmentsCount(query); - } - }else { - count=masterDepartmentsMapper.queryDepartmentsCount(query); - } - query.mysqlBuild(count); - } - - if (getStartUpModel()) { - DepartmentsMapper masterDepartmentsMapper = getslaveMapper(); - if (null != masterDepartmentsMapper) { - return masterDepartmentsMapper.queryDepartments(query); - } + query.mysqlBuild(masterDepartmentsMapper.queryDepartmentsCount(query)); } return masterDepartmentsMapper.queryDepartments(query); } diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/OrganizationServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/OrganizationServiceImpl.java index 47e0c5b..0593838 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/OrganizationServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/OrganizationServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.enums.OrganizationTypeEnum; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; @@ -21,60 +22,31 @@ public class OrganizationServiceImpl extends DataAccessLayerService implements O @Autowired private MasterOrganizationMapper masterOrganizationMapper; - public OrganizationMapper getSlaveMapper() { - Object obj1 = getBean(OrganizationMapper.class); - if (null != obj1) { - OrganizationMapper masterUsersMapper = (OrganizationMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public Integer addOrganization(Organization obj) { - masterOrganizationMapper.addOrganization(obj); - - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - if (null != masterOrganizationMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterOrganizationMapper.addOrganization(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); return obj.getId(); } @Override public void updateOrganization(Organization obj) { masterOrganizationMapper.updateOrganization(obj); - - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - if (null != masterOrganizationMapper) { - masterOrganizationMapper.updateOrganization(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteOrganization(Integer id) { masterOrganizationMapper.deleteOrganization(id); - - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - if (null != masterOrganizationMapper) { - masterOrganizationMapper.deleteOrganization(id); - } + iSyncDataDao.addSyncData("MysqlDel", new Organization(), id.toString()); } @Override public Organization getOrganization(Integer id) { - Organization organization = null; - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - organization= masterOrganizationMapper.getOrganization(id); - } else { - organization = masterOrganizationMapper.getOrganization(id); - } - + Organization organization = masterOrganizationMapper.getOrganization(id); if (null != organization) { //设置机构类型 1 医院 0 公司 if (null != organization.getType()) { @@ -93,35 +65,15 @@ public class OrganizationServiceImpl extends DataAccessLayerService implements O @Override public int queryOrganizationCount(OrganizationQuery query) { - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - return masterOrganizationMapper.queryOrganizationCount(query); - } return masterOrganizationMapper.queryOrganizationCount(query); } @Override public List queryOrganization(OrganizationQuery query) { if (query.getNeed() != null) { - int count = 0; - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - count = masterOrganizationMapper.queryOrganizationCount(query); - } else { - count = masterOrganizationMapper.queryOrganizationCount(query); - } - - - query.mysqlBuild(count); + query.mysqlBuild( masterOrganizationMapper.queryOrganizationCount(query)); } - List organizations = null; - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - organizations = masterOrganizationMapper.queryOrganization(query); - } else { - organizations = masterOrganizationMapper.queryOrganization(query); - } - + List organizations = masterOrganizationMapper.queryOrganization(query); if (CollectionUtils.isNotEmpty(organizations)) { for (Organization organization : organizations) { if (null != organization) { @@ -144,19 +96,11 @@ public class OrganizationServiceImpl extends DataAccessLayerService implements O } public List queryProvinceIdByOrgId(List orgId) { - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - return masterOrganizationMapper.queryProvinceIdByOrgId(orgId); - } return masterOrganizationMapper.queryProvinceIdByOrgId(orgId); } public List queryHospital() { - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - return masterOrganizationMapper.queryHospital(); - } return masterOrganizationMapper.queryHospital(); } @@ -167,13 +111,7 @@ public class OrganizationServiceImpl extends DataAccessLayerService implements O } List results = new ArrayList<>(); - List organizations = null; - if (getStartUpModel()) { - OrganizationMapper masterOrganizationMapper = getSlaveMapper(); - organizations = masterOrganizationMapper.queryOrganization(query); - } else { - organizations = masterOrganizationMapper.queryOrganization(query); - } + List organizations = masterOrganizationMapper.queryOrganization(query); if (CollectionUtils.isNotEmpty(organizations)) { for (Organization organization : organizations) { diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PermissionsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PermissionsServiceImpl.java index b892b38..1cfcc14 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PermissionsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PermissionsServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterPermissionsMapper; @@ -18,66 +19,33 @@ public class PermissionsServiceImpl extends DataAccessLayerService implements Pe @Autowired private MasterPermissionsMapper permissionsMapper; - public PermissionsMapper getSlaveMapper() { - Object obj1 = getBean(PermissionsMapper.class); - if (null != obj1) { - PermissionsMapper masterUsersMapper = (PermissionsMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addPermissions(Permissions obj) { permissionsMapper.addPermissions(obj); - - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterPermissionsMapper.addPermissions(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updatePermissions(Permissions obj) { permissionsMapper.updatePermissions(obj); - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - masterPermissionsMapper.updatePermissions(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deletePermissions(Integer id) { - permissionsMapper.deletePermissions(id); - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - masterPermissionsMapper.deletePermissions(id); - } } @Override public Permissions getPermissions(Integer id) { - if (getStartUpModel()) { - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.getPermissions(id); - } - } return permissionsMapper.getPermissions(id); } @Override public int queryPermissionsCount(PermissionsQuery query) { - if (getStartUpModel()) { - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryPermissionsCount(query); - } - } return permissionsMapper.queryPermissionsCount(query); } @@ -86,33 +54,14 @@ public class PermissionsServiceImpl extends DataAccessLayerService implements Pe if (query.getNeed() != null) { query.mysqlBuild(queryPermissionsCount(query)); } - if (getStartUpModel()) { - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryPermissions(query); - } - } return permissionsMapper.queryPermissions(query); } public List queryPermissionByRoleIds(List roleIds) { - if (getStartUpModel()) { - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryPermissionByRoleIds(roleIds); - } - } - return permissionsMapper.queryPermissionByRoleIds(roleIds); } public List queryPermissionByRoleIds1(Integer roleIds) { - if (getStartUpModel()) { - PermissionsMapper masterPermissionsMapper = getSlaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryPermissionByRoleIds1(roleIds); - } - } return permissionsMapper.queryPermissionByRoleIds1(roleIds); } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RegionsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RegionsServiceImpl.java index 13d85ea..0cc3a46 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RegionsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RegionsServiceImpl.java @@ -19,46 +19,19 @@ public class RegionsServiceImpl extends DataAccessLayerService implements Region @Autowired private MasterRegionsMapper masterRegionsMapper; - - public RegionsMapper getslaveMapper() { - Object obj1 = getBean(RegionsMapper.class); - if (null != obj1) { - RegionsMapper masterUsersMapper = (RegionsMapper) obj1; - return masterUsersMapper; - } - return null; - } - @Override public void addRegions(Regions obj) { masterRegionsMapper.addRegions(obj); - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterPermissionsMapper.addRegions(obj); - } } @Override public void updateRegions(Regions obj) { masterRegionsMapper.updateRegions(obj); - - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - masterPermissionsMapper.updateRegions(obj); - } } @Override public void deleteRegions(Integer id) { masterRegionsMapper.deleteRegions(id); - - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - masterPermissionsMapper.deleteRegions(id); - } } @Override @@ -66,25 +39,11 @@ public class RegionsServiceImpl extends DataAccessLayerService implements Region if (id == null) { return null; } - if (getStartUpModel()) { - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.getRegions(id); - } - } return masterRegionsMapper.getRegions(id); } @Override public int queryRegionsCount(RegionsQuery query) { - - if (getStartUpModel()) { - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryRegionsCount(query); - } - } - return masterRegionsMapper.queryRegionsCount(query); } @@ -93,12 +52,6 @@ public class RegionsServiceImpl extends DataAccessLayerService implements Region if (query.getNeed() != null) { query.mysqlBuild(queryRegionsCount(query)); } - if (getStartUpModel()) { - RegionsMapper masterPermissionsMapper = getslaveMapper(); - if (null != masterPermissionsMapper) { - return masterPermissionsMapper.queryRegions(query); - } - } return masterRegionsMapper.queryRegions(query); } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolePermissionMapsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolePermissionMapsServiceImpl.java index 782fcc2..fe8d13e 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolePermissionMapsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolePermissionMapsServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterRolePermissionMapsMapper; @@ -18,68 +19,33 @@ public class RolePermissionMapsServiceImpl extends DataAccessLayerService implem @Autowired private MasterRolePermissionMapsMapper rolePermissionMapsMapper; - - public RolePermissionMapsMapper getslaveMapper() { - Object obj1 = getBean(RolePermissionMapsMapper.class); - if (null != obj1) { - RolePermissionMapsMapper masterUsersMapper = (RolePermissionMapsMapper) obj1; - return masterUsersMapper; - } - return null; - } - + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addRolePermissionMaps(RolePermissionMaps obj) { rolePermissionMapsMapper.addRolePermissionMaps(obj); - - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterRolePermissionMapsMapper.addRolePermissionMaps(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateRolePermissionMaps(RolePermissionMaps obj) { rolePermissionMapsMapper.updateRolePermissionMaps(obj); - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - masterRolePermissionMapsMapper.updateRolePermissionMaps(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteRolePermissionMaps(Integer id) { rolePermissionMapsMapper.deleteRolePermissionMaps(id); - - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - masterRolePermissionMapsMapper.deleteRolePermissionMaps(id); - } } @Override public RolePermissionMaps getRolePermissionMaps(Integer id) { - if (getStartUpModel()) { - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - return masterRolePermissionMapsMapper.getRolePermissionMaps(id); - } - } return rolePermissionMapsMapper.getRolePermissionMaps(id); } @Override public int queryRolePermissionMapsCount(RolePermissionMapsQuery query) { - if (getStartUpModel()) { - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - return masterRolePermissionMapsMapper.queryRolePermissionMapsCount(query); - } - } return rolePermissionMapsMapper.queryRolePermissionMapsCount(query); } @@ -88,21 +54,10 @@ public class RolePermissionMapsServiceImpl extends DataAccessLayerService implem if (query.getNeed() != null) { query.mysqlBuild(queryRolePermissionMapsCount(query)); } - if (getStartUpModel()) { - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - return masterRolePermissionMapsMapper.queryRolePermissionMaps(query); - } - } return rolePermissionMapsMapper.queryRolePermissionMaps(query); } public void updateRoleByRoleId(Integer roleId) { rolePermissionMapsMapper.updateRoleByRoleId(roleId); - - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper(); - if (null != masterRolePermissionMapsMapper) { - masterRolePermissionMapsMapper.updateRoleByRoleId(roleId); - } } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolesServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolesServiceImpl.java index ff359f2..8b98ce1 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolesServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolesServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterRolesMapper; @@ -18,66 +19,34 @@ public class RolesServiceImpl extends DataAccessLayerService implements RolesSer @Autowired private MasterRolesMapper rolesMapper; - public RolesMapper getSlaveMapper() { - Object obj1 = getBean(RolesMapper.class); - if (null != obj1) { - RolesMapper masterUsersMapper = (RolesMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addRoles(Roles obj) { rolesMapper.addRoles(obj); - - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterRolesMapper.addRoles(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateRoles(Roles obj) { rolesMapper.updateRoles(obj); - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - masterRolesMapper.updateRoles(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteRoles(Integer id) { rolesMapper.deleteRoles(id); - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - masterRolesMapper.deleteRoles(id); - } +// iSyncDataDao.addSyncData("MysqlDel", new Roles(), id.toString()); } @Override public Roles getRoles(Integer id) { - - if (getStartUpModel()) { - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - return masterRolesMapper.getRoles(id); - } - } return rolesMapper.getRoles(id); } @Override public int queryRolesCount(RolesQuery query) { - if (getStartUpModel()) { - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - return masterRolesMapper.queryRolesCount(query); - } - } return rolesMapper.queryRolesCount(query); } @@ -86,13 +55,6 @@ public class RolesServiceImpl extends DataAccessLayerService implements RolesSer if (query.getNeed() != null) { query.mysqlBuild(queryRolesCount(query)); } - - if (getStartUpModel()) { - RolesMapper masterRolesMapper = getSlaveMapper(); - if (null != masterRolesMapper) { - return masterRolesMapper.queryRoles(query); - } - } return rolesMapper.queryRoles(query); } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserOrganizationMapsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserOrganizationMapsServiceImpl.java index 3d1601f..0c50e3d 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserOrganizationMapsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserOrganizationMapsServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterUserOrganizationMapsMapper; @@ -18,62 +19,33 @@ public class UserOrganizationMapsServiceImpl extends DataAccessLayerService impl @Autowired private MasterUserOrganizationMapsMapper userOrganizationMapsMapper; - public UserOrganizationMapsMapper getSlaveMapper() { - Object obj1 = getBean(UserOrganizationMapsMapper.class); - if (null != obj1) { - UserOrganizationMapsMapper masterUsersMapper = (UserOrganizationMapsMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addUserOrganizationMaps(UserOrganizationMaps obj) { userOrganizationMapsMapper.addUserOrganizationMaps(obj); - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - if(null==obj.getId()){ - throw new BusinessException(); - } - masterUserOrganizationMapsMapper.addUserOrganizationMaps(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateUserOrganizationMaps(UserOrganizationMaps obj) { userOrganizationMapsMapper.updateUserOrganizationMaps(obj); - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - masterUserOrganizationMapsMapper.updateUserOrganizationMaps(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteUserOrganizationMaps(Integer id) { userOrganizationMapsMapper.deleteUserOrganizationMaps(id); - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - masterUserOrganizationMapsMapper.deleteUserOrganizationMaps(id); - } } @Override public UserOrganizationMaps getUserOrganizationMaps(Integer id) { - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - return masterUserOrganizationMapsMapper.getUserOrganizationMaps(id); - } return userOrganizationMapsMapper.getUserOrganizationMaps(id); } @Override public int queryUserOrganizationMapsCount(UserOrganizationMapsQuery query) { - if(getStartUpModel()){ - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - return masterUserOrganizationMapsMapper.queryUserOrganizationMapsCount(query); - } - } return userOrganizationMapsMapper.queryUserOrganizationMapsCount(query); } @@ -82,12 +54,6 @@ public class UserOrganizationMapsServiceImpl extends DataAccessLayerService impl if (query.getNeed() != null) { query.mysqlBuild(queryUserOrganizationMapsCount(query)); } - if(getStartUpModel()){ - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper(); - if(null!=masterUserOrganizationMapsMapper){ - return masterUserOrganizationMapsMapper.queryUserOrganizationMaps(query); - } - } return userOrganizationMapsMapper.queryUserOrganizationMaps(query); } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserRoleMapsServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserRoleMapsServiceImpl.java index 5aaa4b9..91cdcec 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserRoleMapsServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserRoleMapsServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterDepartmentsMapper; @@ -19,109 +20,49 @@ public class UserRoleMapsServiceImpl extends DataAccessLayerService implements U @Autowired private MasterUserRoleMapsMapper userRoleMapsMapper; - public UserRoleMapsMapper getSlaveMapper() { - Object obj1 = getBean(UserRoleMapsMapper.class); - if (null != obj1) { - UserRoleMapsMapper masterUsersMapper = (UserRoleMapsMapper) obj1; - return masterUsersMapper; - } - return null; - } + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addUserRoleMaps(UserRoleMaps obj) { userRoleMapsMapper.addUserRoleMaps(obj); - - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterUserRoleMapsMapper.addUserRoleMaps(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateUserRoleMaps(UserRoleMaps obj) { userRoleMapsMapper.updateUserRoleMaps(obj); - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - masterUserRoleMapsMapper.updateUserRoleMaps(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteUserRoleMaps(Integer id) { userRoleMapsMapper.deleteUserRoleMaps(id); - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - masterUserRoleMapsMapper.deleteUserRoleMaps(id); - } } @Override public UserRoleMaps getUserRoleMaps(Integer id) { - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - return masterUserRoleMapsMapper.getUserRoleMaps(id); - } - } return userRoleMapsMapper.getUserRoleMaps(id); } @Override public int queryUserRoleMapsCount(UserRoleMapsQuery query) { - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - return masterUserRoleMapsMapper.queryUserRoleMapsCount(query); - } - } return userRoleMapsMapper.queryUserRoleMapsCount(query); } public List queryUserRoleList(UserRoleMapsQuery query) { - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - return masterUserRoleMapsMapper.queryUserRoleList(query); - } - } return userRoleMapsMapper.queryUserRoleList(query); } @Override public List queryUserRoleMaps(UserRoleMapsQuery query) { if (query.getNeed() != null) { - int count = 0; - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - count = masterUserRoleMapsMapper.queryUserRoleMapsCount(query); - } - } else { - count = userRoleMapsMapper.queryUserRoleMapsCount(query); - } - - query.mysqlBuild(count); - } - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - return masterUserRoleMapsMapper.queryUserRoleMaps(query); - } + query.mysqlBuild(userRoleMapsMapper.queryUserRoleMapsCount(query)); } return userRoleMapsMapper.queryUserRoleMaps(query); } public List queryUserRoleName(Integer id) { - if (getStartUpModel()) { - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper(); - if (null != masterUserRoleMapsMapper) { - return masterUserRoleMapsMapper.queryUserRoleName(id); - } - } return userRoleMapsMapper.queryUserRoleName(id); } } \ No newline at end of file diff --git a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UsersServiceImpl.java b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UsersServiceImpl.java index e27c7f8..8f654e6 100644 --- a/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UsersServiceImpl.java +++ b/platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UsersServiceImpl.java @@ -1,5 +1,6 @@ package com.lyms.platform.permission.service.impl; +import com.lyms.platform.biz.dal.ISyncDataDao; import com.lyms.platform.common.exception.BusinessException; import com.lyms.platform.permission.DataAccessLayerService; import com.lyms.platform.permission.dao.master.MasterUsersMapper; @@ -19,66 +20,34 @@ public class UsersServiceImpl extends DataAccessLayerService implements UsersSer @Autowired private MasterUsersMapper usersMapper; - private UsersMapper getMaster() { - Object obj1 = getBean(UsersMapper.class); - if (null != obj1) { - UsersMapper masterUsersMapper = (UsersMapper) obj1; - return masterUsersMapper; - } - return null; - } - + @Autowired + private ISyncDataDao iSyncDataDao; @Override public void addUsers(Users obj) { usersMapper.addUsers(obj); - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - if (null == obj.getId()) { - throw new BusinessException(); - } - masterUsersMapper.addUsers(obj); - } + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString()); } @Override public void updateUsers(Users obj) { usersMapper.updateUsers(obj); - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - masterUsersMapper.updateUsers(obj); - } + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString()); } @Override public void deleteUsers(Integer id) { - - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - masterUsersMapper.deleteUsers(id); - } usersMapper.deleteUsers(id); + iSyncDataDao.addSyncData("MysqlDel", new Users(), id.toString()); } @Override public Users getUsers(Integer id) { - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - return masterUsersMapper.getUsers(id); - } - } return usersMapper.getUsers(id); } @Override public int queryUsersCount(UsersQuery query) { - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - return masterUsersMapper.queryUsersCount(query); - } - } return usersMapper.queryUsersCount(query); } @@ -87,36 +56,13 @@ public class UsersServiceImpl extends DataAccessLayerService implements UsersSer if (query.getNeed() != null) { query.mysqlBuild(queryUsersCount(query)); } - - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - return masterUsersMapper.queryUsers(query); - } - } - return usersMapper.queryUsers(query); } @Override public List queryUsers2(UsersQuery query) { if (query.getNeed() != null) { - int count = 0; - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - count = masterUsersMapper.queryUsersCount2(query); - } - } else { - count=usersMapper.queryUsersCount2(query); - } - query.mysqlBuild(count); - } - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - return masterUsersMapper.queryUsers2(query); - } + query.mysqlBuild(usersMapper.queryUsersCount2(query)); } return usersMapper.queryUsers2(query); } @@ -124,16 +70,7 @@ public class UsersServiceImpl extends DataAccessLayerService implements UsersSer @Override public Users getUsersByLoginCenterId(Integer id) { - - List list=null; - if (getStartUpModel()) { - UsersMapper masterUsersMapper = getMaster(); - if (null != masterUsersMapper) { - list= masterUsersMapper.getUsersByLoginCenterId(id); - } - }else{ - list = usersMapper.getUsersByLoginCenterId(id); - } + List list=usersMapper.getUsersByLoginCenterId(id); if (CollectionUtils.isNotEmpty(list)) { return list.get(0); } diff --git a/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java b/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java index e8d2203..7074ad3 100644 --- a/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java +++ b/platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java @@ -1,10 +1,10 @@ package com.lyms.platform.common.dao; import com.lyms.platform.common.dao.operator.Page; -import com.lyms.platform.common.utils.MongoConvertHelper; -import com.lyms.platform.common.utils.MongoSyncUtil; -import com.lyms.platform.common.utils.ReflectionUtils; +import com.lyms.platform.common.pojo.SyncDataModel; +import com.lyms.platform.common.utils.*; import org.apache.commons.collections.CollectionUtils; +import org.apache.commons.lang.*; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.mongodb.core.MongoTemplate; import org.springframework.data.mongodb.core.query.Query; @@ -12,6 +12,7 @@ import org.springframework.data.mongodb.core.query.Update; import org.springframework.util.Assert; import java.util.Collection; +import java.util.Date; import java.util.List; public class BaseMongoDAOImpl implements BaseMongoDAO { @@ -52,7 +53,7 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { mongoTemplate.updateMulti(query, update, this.getEntityClass()); Object id = query.getQueryObject().get("id"); if (id != null) { - MongoSyncUtil.sync("UPDATE", obj, id.toString()); + addSyncData("UPDATE", obj, id.toString()); } } @@ -60,7 +61,7 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { public T save(T entity) { Assert.notNull(entity, "execute insert method must not null."); mongoTemplate.insert(entity); - MongoSyncUtil.sync("ADD", entity, ""); + addSyncData("ADD", entity, ""); return entity; } @@ -106,7 +107,7 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { public void delete(Query query) { Object id = query.getQueryObject().get("id"); if (id != null) { - MongoSyncUtil.sync("DELETE", "", id.toString()); + addSyncData("DELETE", this.getEntityClass(), id.toString()); } mongoTemplate.findAllAndRemove(query, this.getEntityClass()); } @@ -139,6 +140,34 @@ public class BaseMongoDAOImpl implements BaseMongoDAO { Assert.notNull(update, "execute findAndModify method must not null.update:" + update); mongoTemplate.updateMulti(query,update,this.getEntityClass()); } + + public static String mongo_crypto_key = Config.getItem("mongo_crypto_key", "0"); + public static String mongo_sync = Config.getItem("mongo_sync", "0"); + public void addSyncData(String action, Object data, String id) { + if ("1".equals(mongo_sync)) { + try { + if (action.startsWith("Mysql")) { + return; + } + SyncDataModel model = new SyncDataModel(); + model.setAction(action); + if (null != data) { + model.setClassName(LymsEncodeUtil.aesEncrypt(data.getClass().getName(), mongo_crypto_key)); + model.setJsonData(LymsEncodeUtil.aesEncrypt(JsonUtil.obj2JsonString(data), mongo_crypto_key)); + } + model.setCreated(new Date()); + model.setModified(model.getCreated()); + if (org.apache.commons.lang.StringUtils.isNotBlank(id)) { + model.setDataId(LymsEncodeUtil.aesEncrypt(id, mongo_crypto_key)); + } + model.setStatus(1); + mongoTemplate.insert(model); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + /** * 获取需要操作的实体类class * diff --git a/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncDataModel.java b/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncDataModel.java new file mode 100644 index 0000000..0159d7c --- /dev/null +++ b/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncDataModel.java @@ -0,0 +1,88 @@ +package com.lyms.platform.common.pojo; + +import com.lyms.platform.common.result.BaseModel; +import org.springframework.data.mongodb.core.mapping.Document; + +import java.util.Date; + +/** + * Created by Administrator on 2016/9/20. + */ +@Document(collection = "lyms_sync_data") +public class SyncDataModel extends BaseModel { + + private static final long serialVersionUID = 1L; + + private Date created; + private Date modified; + private String id; + private String action; + private String className; + private String jsonData; + private String dataId; + private Integer status; + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + + public Date getCreated() { + return created; + } + + public void setCreated(Date created) { + this.created = created; + } + + public Date getModified() { + return modified; + } + + public void setModified(Date modified) { + this.modified = modified; + } + + public String getId() { + return id; + } + + public void setId(String id) { + this.id = id; + } + + public String getAction() { + return action; + } + + public void setAction(String action) { + this.action = action; + } + + public String getClassName() { + return className; + } + + public void setClassName(String className) { + this.className = className; + } + + public String getJsonData() { + return jsonData; + } + + public void setJsonData(String jsonData) { + this.jsonData = jsonData; + } + + public String getDataId() { + return dataId; + } + + public void setDataId(String dataId) { + this.dataId = dataId; + } +} diff --git a/platform-dal/src/main/java/com/lyms/platform/query/SyncDataQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/SyncDataQuery.java new file mode 100644 index 0000000..5824069 --- /dev/null +++ b/platform-dal/src/main/java/com/lyms/platform/query/SyncDataQuery.java @@ -0,0 +1,30 @@ +package com.lyms.platform.query; + +import com.lyms.platform.common.base.IConvertToNativeQuery; +import com.lyms.platform.common.dao.BaseQuery; +import com.lyms.platform.common.dao.operator.MongoCondition; +import com.lyms.platform.common.dao.operator.MongoOper; +import com.lyms.platform.common.dao.operator.MongoQuery; + +/** + * Created by Administrator on 2016/9/20. + */ +public class SyncDataQuery extends BaseQuery implements IConvertToNativeQuery { + + private Integer status; + + public Integer getStatus() { + return status; + } + + public void setStatus(Integer status) { + this.status = status; + } + + @Override + public MongoQuery convertToQuery() { + MongoCondition condition = MongoCondition.newInstance(); + condition.and("status", status, MongoOper.IS); + return condition.toMongoQuery(); + } +} diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/ConnTools.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/ConnTools.java new file mode 100644 index 0000000..ce6e57e --- /dev/null +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/ConnTools.java @@ -0,0 +1,72 @@ +package com.lyms.hospitalapi.qinglongxian; + +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.SQLException; + +/** + * Created by Administrator on 2016/9/9 0009. + */ +public class ConnTools { + private static String hisDirverClassName = "oracle.jdbc.driver.OracleDriver"; + private static String hisUrl = "jdbc:oracle:thin:@192.190.10.11:1521:xlsyy"; + private static String hisUser = "mmbb"; + private static String hisPassword = "mmbb"; + + private static String pacsDirverClassName = "oracle.jdbc.driver.OracleDriver"; + private static String pacsUrl = "jdbc:oracle:thin:@172.0.1.17:1521:ris"; + private static String pacsUser = "YunYing"; + private static String pacsPassword = "maroland"; + + private static String lisDirverClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver"; + private static String lisUrl = "jdbc:sqlserver://172.0.1.20:1433; DatabaseName=rmlis6"; + private static String lisUser = "sa"; + private static String lisPassword = "skhis168"; + + public static Connection makeHisConnection() { + Connection conn = null; + try { + Class.forName(hisDirverClassName); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + try { + conn = DriverManager.getConnection(hisUrl, hisUser, hisPassword); + } catch (SQLException e) { + e.printStackTrace(); + } + return conn; + } + + public static Connection makePacsConnection() { + Connection conn = null; + try { + Class.forName(pacsDirverClassName); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + try { + conn = DriverManager.getConnection(pacsUrl, pacsUser, pacsPassword); + } catch (SQLException e) { + e.printStackTrace(); + } + return conn; + } + + public static Connection makeLisConnection() { + Connection conn = null; + try { + Class.forName(lisDirverClassName); + } catch (ClassNotFoundException e) { + e.printStackTrace(); + } + try { + conn = DriverManager.getConnection(lisUrl, lisUser, lisPassword); + } catch (SQLException e) { + e.printStackTrace(); + } + return conn; + } + + +} diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/QingLongXianHisService.java b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/QingLongXianHisService.java new file mode 100644 index 0000000..6ab1ee8 --- /dev/null +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/QingLongXianHisService.java @@ -0,0 +1,10 @@ +package com.lyms.hospitalapi.qinglongxian; + +import org.springframework.stereotype.Service; + +/** + * Created by Administrator on 2016/9/20. + */ +@Service("qingLongXianHisService") +public class QingLongXianHisService { +} diff --git a/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/README.TXT b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/README.TXT new file mode 100644 index 0000000..da43f2c --- /dev/null +++ b/platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/README.TXT @@ -0,0 +1,2 @@ +版本三 +青龙县医院 \ No newline at end of file diff --git a/platform-operate-api/src/main/resources/config.properties b/platform-operate-api/src/main/resources/config.properties index 1ab1c40..c930a60 100644 --- a/platform-operate-api/src/main/resources/config.properties +++ b/platform-operate-api/src/main/resources/config.properties @@ -4,7 +4,7 @@ center_base_url=http://sms.api.stage.platform.healthbaby.com.cn/v1/ #区域平台访问短信中心的token center_token=e0c56363-00d6-42ee-bbe0-23c553583062 -#His系统版本 0：未使用，1：桓台，2：新乐 +#His系统版本 0：未使用，1：桓台，2：新乐，3：青龙县医院 his_version=0