shiyang / regional-platform

Download as
Browse Code »

Commit aea1e127bb295807ec22be0722e0f8519e88bd80

Authored by hanshaofeng
1 parent ce0d2beb65
Exists in master and in 1 other branch nobuildprocess

add insert synclog

Showing 20 changed files with 424 additions and 506 deletions

platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/ISyncDataDao.java View file @ aea1e12
  1 +package com.lyms.platform.biz.dal;
  2 +
  3 +import com.lyms.platform.common.dao.operator.MongoQuery;
  4 +import com.lyms.platform.common.dao.operator.Page;
  5 +import com.lyms.platform.common.pojo.SyncDataModel;
  6 +
  7 +import java.util.List;
  8 +
  9 +/**
  10 + * Created by Administrator on 2016/9/20.
  11 + */
  12 +public interface ISyncDataDao {
  13 +
  14 + public SyncDataModel addSyncData(SyncDataModel obj);
  15 +
  16 + public void updateSyncData(SyncDataModel obj, String id);
  17 +
  18 + public void deleteSyncData(String id);
  19 +
  20 + public SyncDataModel getSyncData(String id);
  21 +
  22 + public int querySyncDataModelCount(MongoQuery query);
  23 +
  24 + public List<SyncDataModel> querySyncData(MongoQuery query);
  25 +
  26 + public Page<SyncDataModel> findPage(MongoQuery query);
  27 +
  28 + public void addSyncData(String action, Object data, String id);
  29 +
  30 +}
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/dal/impl/SyncDataDaoImpl.java View file @ aea1e12
  1 +package com.lyms.platform.biz.dal.impl;
  2 +
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
  4 +import com.lyms.platform.common.dao.BaseMongoDAOImpl;
  5 +import com.lyms.platform.common.dao.operator.MongoCondition;
  6 +import com.lyms.platform.common.dao.operator.MongoOper;
  7 +import com.lyms.platform.common.dao.operator.MongoQuery;
  8 +import com.lyms.platform.common.dao.operator.Page;
  9 +import com.lyms.platform.common.pojo.SyncDataModel;
  10 +import org.bson.types.ObjectId;
  11 +import org.springframework.stereotype.Repository;
  12 +
  13 +import java.util.List;
  14 +
  15 +/**
  16 + * Created by Administrator on 2016/9/20.
  17 + */
  18 +@Repository("syncDataDao")
  19 +public class SyncDataDaoImpl extends BaseMongoDAOImpl<SyncDataModel> implements ISyncDataDao {
  20 +
  21 + @Override
  22 + public SyncDataModel addSyncData(SyncDataModel obj) {
  23 + return save(obj);
  24 + }
  25 +
  26 + @Override
  27 + public void updateSyncData(SyncDataModel obj, String id) {
  28 + update(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), obj);
  29 + }
  30 +
  31 + @Override
  32 + public void deleteSyncData(String id) {
  33 + boolean check = ObjectId.isValid(id);
  34 + if (check) {
  35 + delete(new MongoQuery(new MongoCondition("id", new ObjectId(id), MongoOper.IS)).convertToMongoQuery());
  36 + }
  37 + }
  38 +
  39 + @Override
  40 + public SyncDataModel getSyncData(String id) {
  41 + return findById(id);
  42 + }
  43 +
  44 + @Override
  45 + public int querySyncDataModelCount(MongoQuery query) {
  46 + return (int)count(query.convertToMongoQuery());
  47 + }
  48 +
  49 + @Override
  50 + public List<SyncDataModel> querySyncData(MongoQuery query) {
  51 + return find(query.convertToMongoQuery());
  52 + }
  53 +
  54 + @Override
  55 + public Page<SyncDataModel> findPage(MongoQuery query) {
  56 + return findPage(query.convertToMongoQuery());
  57 + }
  58 +}
platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/SyncDataService.java View file @ aea1e12
  1 +package com.lyms.platform.biz.service;
  2 +
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
  4 +import com.lyms.platform.common.dao.operator.MongoQuery;
  5 +import com.lyms.platform.common.pojo.SyncDataModel;
  6 +import com.lyms.platform.query.SyncDataQuery;
  7 +import org.apache.commons.lang.StringUtils;
  8 +import org.springframework.beans.factory.annotation.Autowired;
  9 +import org.springframework.data.domain.Sort;
  10 +import org.springframework.stereotype.Service;
  11 +
  12 +import java.util.List;
  13 +
  14 +/**
  15 + * Created by Administrator on 2016/9/20.
  16 + */
  17 +@Service
  18 +public class SyncDataService {
  19 +
  20 + @Autowired
  21 + private ISyncDataDao iSyncDataDao;
  22 +
  23 + public SyncDataModel addSyncData(SyncDataModel obj) {
  24 + return iSyncDataDao.addSyncData(obj);
  25 + }
  26 +
  27 + public void updateSyncData(SyncDataModel obj) {
  28 + iSyncDataDao.updateSyncData(obj, obj.getId());
  29 + }
  30 +
  31 + public List<SyncDataModel> querySyncData(SyncDataQuery syncDataQuery) {
  32 + MongoQuery query = syncDataQuery.convertToQuery();
  33 + if (StringUtils.isNotEmpty(syncDataQuery.getNeed())) {
  34 + syncDataQuery.mysqlBuild(iSyncDataDao.querySyncDataModelCount(syncDataQuery.convertToQuery()));
  35 + query.start(syncDataQuery.getOffset()).end(syncDataQuery.getLimit());
  36 + }
  37 +
  38 + return iSyncDataDao.querySyncData(query.addOrder(Sort.Direction.ASC, "created"));
  39 + }
  40 +
  41 +}
platform-biz-service/pom.xml View file @ aea1e12
... ... @@ -21,6 +21,11 @@
21 21 <artifactId>platform-dal</artifactId>
22 22 <version>${project.version}</version>
23 23 </dependency>
  24 + <dependency>
  25 + <groupId>com.lyms.core</groupId>
  26 + <artifactId>platform-biz-patient-service</artifactId>
  27 + <version>${project.version}</version>
  28 + </dependency>
24 29 </dependencies>
25 30 <build>
26 31 <plugins>
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/DepartmentsServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterDepartmentsMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
11 12  
... ... @@ -18,90 +19,41 @@
18 19 @Autowired
19 20 private MasterDepartmentsMapper masterDepartmentsMapper;
20 21  
21   - public DepartmentsMapper getslaveMapper() {
22   - Object obj1 = getBean(DepartmentsMapper.class);
23   - if (null != obj1) {
24   - DepartmentsMapper masterUsersMapper = (DepartmentsMapper) obj1;
25   - return masterUsersMapper;
26   - }
27   - return null;
28   - }
  22 + @Autowired
  23 + private ISyncDataDao iSyncDataDao;
29 24  
30 25 @Override
31 26 public void addDepartments(Departments obj) {
32 27 masterDepartmentsMapper.addDepartments(obj);
33   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
34   - if (null != masterDepartmentsMapper) {
35   - if (null == obj.getId()) {
36   - throw new BusinessException();
37   - }
38   - masterDepartmentsMapper.addDepartments(obj);
39   - }
  28 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
40 29 }
41 30  
42 31 @Override
43 32 public void updateDepartments(Departments obj) {
44 33 masterDepartmentsMapper.updateDepartments(obj);
45   -
46   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
47   - if (null != masterDepartmentsMapper) {
48   - masterDepartmentsMapper.updateDepartments(obj);
49   - }
  34 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
50 35 }
51 36  
52 37 @Override
53 38 public void deleteDepartments(Integer id) {
54 39 masterDepartmentsMapper.deleteDepartments(id);
55   -
56   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
57   - if (null != masterDepartmentsMapper) {
58   - masterDepartmentsMapper.deleteDepartments(id);
59   - }
  40 + iSyncDataDao.addSyncData("MysqlDel", new Departments(), id.toString());
60 41 }
61 42  
62 43 @Override
63 44 public Departments getDepartments(Integer id) {
64   - if (getStartUpModel()) {
65   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
66   - if (null != masterDepartmentsMapper) {
67   - return masterDepartmentsMapper.getDepartments(id);
68   - }
69   - }
70   -
71 45 return masterDepartmentsMapper.getDepartments(id);
72 46 }
73 47  
74 48 @Override
75 49 public int queryDepartmentsCount(DepartmentsQuery query) {
76   - if (getStartUpModel()) {
77   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
78   - if (null != masterDepartmentsMapper) {
79   - return masterDepartmentsMapper.queryDepartmentsCount(query);
80   - }
81   - }
82 50 return masterDepartmentsMapper.queryDepartmentsCount(query);
83 51 }
84 52  
85 53 @Override
86 54 public List<Departments> queryDepartments(DepartmentsQuery query) {
87 55 if (query.getNeed() != null) {
88   - int count = 0;
89   - if (getStartUpModel()) {
90   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
91   - if (null != masterDepartmentsMapper) {
92   - count= masterDepartmentsMapper.queryDepartmentsCount(query);
93   - }
94   - }else {
95   - count=masterDepartmentsMapper.queryDepartmentsCount(query);
96   - }
97   - query.mysqlBuild(count);
98   - }
99   -
100   - if (getStartUpModel()) {
101   - DepartmentsMapper masterDepartmentsMapper = getslaveMapper();
102   - if (null != masterDepartmentsMapper) {
103   - return masterDepartmentsMapper.queryDepartments(query);
104   - }
  56 + query.mysqlBuild(masterDepartmentsMapper.queryDepartmentsCount(query));
105 57 }
106 58 return masterDepartmentsMapper.queryDepartments(query);
107 59 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/OrganizationServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.enums.OrganizationTypeEnum;
4 5 import com.lyms.platform.common.exception.BusinessException;
5 6 import com.lyms.platform.permission.DataAccessLayerService;
6 7  
7 8  
8 9  
9 10  
10 11  
... ... @@ -21,60 +22,31 @@
21 22 @Autowired
22 23 private MasterOrganizationMapper masterOrganizationMapper;
23 24  
24   - public OrganizationMapper getSlaveMapper() {
25   - Object obj1 = getBean(OrganizationMapper.class);
26   - if (null != obj1) {
27   - OrganizationMapper masterUsersMapper = (OrganizationMapper) obj1;
28   - return masterUsersMapper;
29   - }
30   - return null;
31   - }
  25 + @Autowired
  26 + private ISyncDataDao iSyncDataDao;
32 27  
33 28 @Override
34 29 public Integer addOrganization(Organization obj) {
35   -
36 30 masterOrganizationMapper.addOrganization(obj);
37   -
38   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
39   - if (null != masterOrganizationMapper) {
40   - if (null == obj.getId()) {
41   - throw new BusinessException();
42   - }
43   - masterOrganizationMapper.addOrganization(obj);
44   - }
  31 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
45 32 return obj.getId();
46 33 }
47 34  
48 35 @Override
49 36 public void updateOrganization(Organization obj) {
50 37 masterOrganizationMapper.updateOrganization(obj);
51   -
52   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
53   - if (null != masterOrganizationMapper) {
54   - masterOrganizationMapper.updateOrganization(obj);
55   - }
  38 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
56 39 }
57 40  
58 41 @Override
59 42 public void deleteOrganization(Integer id) {
60 43 masterOrganizationMapper.deleteOrganization(id);
61   -
62   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
63   - if (null != masterOrganizationMapper) {
64   - masterOrganizationMapper.deleteOrganization(id);
65   - }
  44 + iSyncDataDao.addSyncData("MysqlDel", new Organization(), id.toString());
66 45 }
67 46  
68 47 @Override
69 48 public Organization getOrganization(Integer id) {
70   - Organization organization = null;
71   - if (getStartUpModel()) {
72   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
73   - organization= masterOrganizationMapper.getOrganization(id);
74   - } else {
75   - organization = masterOrganizationMapper.getOrganization(id);
76   - }
77   -
  49 + Organization organization = masterOrganizationMapper.getOrganization(id);
78 50 if (null != organization) {
79 51 //设置机构类型 1 医院 0 公司
80 52 if (null != organization.getType()) {
81 53  
82 54  
... ... @@ -93,35 +65,15 @@
93 65  
94 66 @Override
95 67 public int queryOrganizationCount(OrganizationQuery query) {
96   - if (getStartUpModel()) {
97   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
98   - return masterOrganizationMapper.queryOrganizationCount(query);
99   - }
100 68 return masterOrganizationMapper.queryOrganizationCount(query);
101 69 }
102 70  
103 71 @Override
104 72 public List<Organization> queryOrganization(OrganizationQuery query) {
105 73 if (query.getNeed() != null) {
106   - int count = 0;
107   - if (getStartUpModel()) {
108   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
109   - count = masterOrganizationMapper.queryOrganizationCount(query);
110   - } else {
111   - count = masterOrganizationMapper.queryOrganizationCount(query);
112   - }
113   -
114   -
115   - query.mysqlBuild(count);
  74 + query.mysqlBuild( masterOrganizationMapper.queryOrganizationCount(query));
116 75 }
117   - List<Organization> organizations = null;
118   - if (getStartUpModel()) {
119   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
120   - organizations = masterOrganizationMapper.queryOrganization(query);
121   - } else {
122   - organizations = masterOrganizationMapper.queryOrganization(query);
123   - }
124   -
  76 + List<Organization> organizations = masterOrganizationMapper.queryOrganization(query);
125 77 if (CollectionUtils.isNotEmpty(organizations)) {
126 78 for (Organization organization : organizations) {
127 79 if (null != organization) {
128 80  
... ... @@ -144,19 +96,11 @@
144 96 }
145 97  
146 98 public List<String> queryProvinceIdByOrgId(List<Integer> orgId) {
147   - if (getStartUpModel()) {
148   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
149   - return masterOrganizationMapper.queryProvinceIdByOrgId(orgId);
150   - }
151 99 return masterOrganizationMapper.queryProvinceIdByOrgId(orgId);
152 100 }
153 101  
154 102  
155 103 public List<Organization> queryHospital() {
156   - if (getStartUpModel()) {
157   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
158   - return masterOrganizationMapper.queryHospital();
159   - }
160 104 return masterOrganizationMapper.queryHospital();
161 105 }
162 106  
... ... @@ -167,13 +111,7 @@
167 111 }
168 112  
169 113 List<Organization> results = new ArrayList<>();
170   - List<Organization> organizations = null;
171   - if (getStartUpModel()) {
172   - OrganizationMapper masterOrganizationMapper = getSlaveMapper();
173   - organizations = masterOrganizationMapper.queryOrganization(query);
174   - } else {
175   - organizations = masterOrganizationMapper.queryOrganization(query);
176   - }
  114 + List<Organization> organizations = masterOrganizationMapper.queryOrganization(query);
177 115  
178 116 if (CollectionUtils.isNotEmpty(organizations)) {
179 117 for (Organization organization : organizations) {
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/PermissionsServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterPermissionsMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
11 12  
... ... @@ -18,66 +19,33 @@
18 19 @Autowired
19 20 private MasterPermissionsMapper permissionsMapper;
20 21  
21   - public PermissionsMapper getSlaveMapper() {
22   - Object obj1 = getBean(PermissionsMapper.class);
23   - if (null != obj1) {
24   - PermissionsMapper masterUsersMapper = (PermissionsMapper) obj1;
25   - return masterUsersMapper;
26   - }
27   - return null;
28   - }
  22 + @Autowired
  23 + private ISyncDataDao iSyncDataDao;
29 24  
30 25 @Override
31 26 public void addPermissions(Permissions obj) {
32 27 permissionsMapper.addPermissions(obj);
33   -
34   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
35   - if (null != masterPermissionsMapper) {
36   - if (null == obj.getId()) {
37   - throw new BusinessException();
38   - }
39   - masterPermissionsMapper.addPermissions(obj);
40   - }
  28 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
41 29 }
42 30  
43 31 @Override
44 32 public void updatePermissions(Permissions obj) {
45 33 permissionsMapper.updatePermissions(obj);
46   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
47   - if (null != masterPermissionsMapper) {
48   - masterPermissionsMapper.updatePermissions(obj);
49   - }
  34 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
50 35 }
51 36  
52 37 @Override
53 38 public void deletePermissions(Integer id) {
54   -
55 39 permissionsMapper.deletePermissions(id);
56   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
57   - if (null != masterPermissionsMapper) {
58   - masterPermissionsMapper.deletePermissions(id);
59   - }
60 40 }
61 41  
62 42 @Override
63 43 public Permissions getPermissions(Integer id) {
64   - if (getStartUpModel()) {
65   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
66   - if (null != masterPermissionsMapper) {
67   - return masterPermissionsMapper.getPermissions(id);
68   - }
69   - }
70 44 return permissionsMapper.getPermissions(id);
71 45 }
72 46  
73 47 @Override
74 48 public int queryPermissionsCount(PermissionsQuery query) {
75   - if (getStartUpModel()) {
76   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
77   - if (null != masterPermissionsMapper) {
78   - return masterPermissionsMapper.queryPermissionsCount(query);
79   - }
80   - }
81 49 return permissionsMapper.queryPermissionsCount(query);
82 50 }
83 51  
84 52  
85 53  
... ... @@ -86,33 +54,14 @@
86 54 if (query.getNeed() != null) {
87 55 query.mysqlBuild(queryPermissionsCount(query));
88 56 }
89   - if (getStartUpModel()) {
90   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
91   - if (null != masterPermissionsMapper) {
92   - return masterPermissionsMapper.queryPermissions(query);
93   - }
94   - }
95 57 return permissionsMapper.queryPermissions(query);
96 58 }
97 59  
98 60 public List<Permissions> queryPermissionByRoleIds(List<Integer> roleIds) {
99   - if (getStartUpModel()) {
100   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
101   - if (null != masterPermissionsMapper) {
102   - return masterPermissionsMapper.queryPermissionByRoleIds(roleIds);
103   - }
104   - }
105   -
106 61 return permissionsMapper.queryPermissionByRoleIds(roleIds);
107 62 }
108 63  
109 64 public List<Permissions> queryPermissionByRoleIds1(Integer roleIds) {
110   - if (getStartUpModel()) {
111   - PermissionsMapper masterPermissionsMapper = getSlaveMapper();
112   - if (null != masterPermissionsMapper) {
113   - return masterPermissionsMapper.queryPermissionByRoleIds1(roleIds);
114   - }
115   - }
116 65 return permissionsMapper.queryPermissionByRoleIds1(roleIds);
117 66 }
118 67 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RegionsServiceImpl.java View file @ aea1e12
... ... @@ -19,46 +19,19 @@
19 19 @Autowired
20 20 private MasterRegionsMapper masterRegionsMapper;
21 21  
22   -
23   - public RegionsMapper getslaveMapper() {
24   - Object obj1 = getBean(RegionsMapper.class);
25   - if (null != obj1) {
26   - RegionsMapper masterUsersMapper = (RegionsMapper) obj1;
27   - return masterUsersMapper;
28   - }
29   - return null;
30   - }
31   -
32 22 @Override
33 23 public void addRegions(Regions obj) {
34 24 masterRegionsMapper.addRegions(obj);
35   - RegionsMapper masterPermissionsMapper = getslaveMapper();
36   - if (null != masterPermissionsMapper) {
37   - if (null == obj.getId()) {
38   - throw new BusinessException();
39   - }
40   - masterPermissionsMapper.addRegions(obj);
41   - }
42 25 }
43 26  
44 27 @Override
45 28 public void updateRegions(Regions obj) {
46 29 masterRegionsMapper.updateRegions(obj);
47   -
48   - RegionsMapper masterPermissionsMapper = getslaveMapper();
49   - if (null != masterPermissionsMapper) {
50   - masterPermissionsMapper.updateRegions(obj);
51   - }
52 30 }
53 31  
54 32 @Override
55 33 public void deleteRegions(Integer id) {
56 34 masterRegionsMapper.deleteRegions(id);
57   -
58   - RegionsMapper masterPermissionsMapper = getslaveMapper();
59   - if (null != masterPermissionsMapper) {
60   - masterPermissionsMapper.deleteRegions(id);
61   - }
62 35 }
63 36  
64 37 @Override
65 38  
... ... @@ -66,25 +39,11 @@
66 39 if (id == null) {
67 40 return null;
68 41 }
69   - if (getStartUpModel()) {
70   - RegionsMapper masterPermissionsMapper = getslaveMapper();
71   - if (null != masterPermissionsMapper) {
72   - return masterPermissionsMapper.getRegions(id);
73   - }
74   - }
75 42 return masterRegionsMapper.getRegions(id);
76 43 }
77 44  
78 45 @Override
79 46 public int queryRegionsCount(RegionsQuery query) {
80   -
81   - if (getStartUpModel()) {
82   - RegionsMapper masterPermissionsMapper = getslaveMapper();
83   - if (null != masterPermissionsMapper) {
84   - return masterPermissionsMapper.queryRegionsCount(query);
85   - }
86   - }
87   -
88 47 return masterRegionsMapper.queryRegionsCount(query);
89 48 }
90 49  
... ... @@ -92,12 +51,6 @@
92 51 public List<Regions> queryRegions(RegionsQuery query) {
93 52 if (query.getNeed() != null) {
94 53 query.mysqlBuild(queryRegionsCount(query));
95   - }
96   - if (getStartUpModel()) {
97   - RegionsMapper masterPermissionsMapper = getslaveMapper();
98   - if (null != masterPermissionsMapper) {
99   - return masterPermissionsMapper.queryRegions(query);
100   - }
101 54 }
102 55 return masterRegionsMapper.queryRegions(query);
103 56 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolePermissionMapsServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterRolePermissionMapsMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
11 12  
... ... @@ -18,68 +19,33 @@
18 19 @Autowired
19 20 private MasterRolePermissionMapsMapper rolePermissionMapsMapper;
20 21  
  22 + @Autowired
  23 + private ISyncDataDao iSyncDataDao;
21 24  
22   - public RolePermissionMapsMapper getslaveMapper() {
23   - Object obj1 = getBean(RolePermissionMapsMapper.class);
24   - if (null != obj1) {
25   - RolePermissionMapsMapper masterUsersMapper = (RolePermissionMapsMapper) obj1;
26   - return masterUsersMapper;
27   - }
28   - return null;
29   - }
30   -
31   -
32 25 @Override
33 26 public void addRolePermissionMaps(RolePermissionMaps obj) {
34 27 rolePermissionMapsMapper.addRolePermissionMaps(obj);
35   -
36   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
37   - if (null != masterRolePermissionMapsMapper) {
38   - if (null == obj.getId()) {
39   - throw new BusinessException();
40   - }
41   - masterRolePermissionMapsMapper.addRolePermissionMaps(obj);
42   - }
  28 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
43 29 }
44 30  
45 31 @Override
46 32 public void updateRolePermissionMaps(RolePermissionMaps obj) {
47 33 rolePermissionMapsMapper.updateRolePermissionMaps(obj);
48   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
49   - if (null != masterRolePermissionMapsMapper) {
50   - masterRolePermissionMapsMapper.updateRolePermissionMaps(obj);
51   - }
  34 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
52 35 }
53 36  
54 37 @Override
55 38 public void deleteRolePermissionMaps(Integer id) {
56 39 rolePermissionMapsMapper.deleteRolePermissionMaps(id);
57   -
58   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
59   - if (null != masterRolePermissionMapsMapper) {
60   - masterRolePermissionMapsMapper.deleteRolePermissionMaps(id);
61   - }
62 40 }
63 41  
64 42 @Override
65 43 public RolePermissionMaps getRolePermissionMaps(Integer id) {
66   - if (getStartUpModel()) {
67   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
68   - if (null != masterRolePermissionMapsMapper) {
69   - return masterRolePermissionMapsMapper.getRolePermissionMaps(id);
70   - }
71   - }
72 44 return rolePermissionMapsMapper.getRolePermissionMaps(id);
73 45 }
74 46  
75 47 @Override
76 48 public int queryRolePermissionMapsCount(RolePermissionMapsQuery query) {
77   - if (getStartUpModel()) {
78   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
79   - if (null != masterRolePermissionMapsMapper) {
80   - return masterRolePermissionMapsMapper.queryRolePermissionMapsCount(query);
81   - }
82   - }
83 49 return rolePermissionMapsMapper.queryRolePermissionMapsCount(query);
84 50 }
85 51  
86 52  
... ... @@ -88,22 +54,11 @@
88 54 if (query.getNeed() != null) {
89 55 query.mysqlBuild(queryRolePermissionMapsCount(query));
90 56 }
91   - if (getStartUpModel()) {
92   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
93   - if (null != masterRolePermissionMapsMapper) {
94   - return masterRolePermissionMapsMapper.queryRolePermissionMaps(query);
95   - }
96   - }
97 57 return rolePermissionMapsMapper.queryRolePermissionMaps(query);
98 58 }
99 59  
100 60 public void updateRoleByRoleId(Integer roleId) {
101 61 rolePermissionMapsMapper.updateRoleByRoleId(roleId);
102   -
103   - RolePermissionMapsMapper masterRolePermissionMapsMapper = getslaveMapper();
104   - if (null != masterRolePermissionMapsMapper) {
105   - masterRolePermissionMapsMapper.updateRoleByRoleId(roleId);
106   - }
107 62 }
108 63 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/RolesServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterRolesMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
... ... @@ -18,66 +19,34 @@
18 19 @Autowired
19 20 private MasterRolesMapper rolesMapper;
20 21  
21   - public RolesMapper getSlaveMapper() {
22   - Object obj1 = getBean(RolesMapper.class);
23   - if (null != obj1) {
24   - RolesMapper masterUsersMapper = (RolesMapper) obj1;
25   - return masterUsersMapper;
26   - }
27   - return null;
28   - }
  22 + @Autowired
  23 + private ISyncDataDao iSyncDataDao;
29 24  
30 25 @Override
31 26 public void addRoles(Roles obj) {
32 27 rolesMapper.addRoles(obj);
33   -
34   - RolesMapper masterRolesMapper = getSlaveMapper();
35   - if (null != masterRolesMapper) {
36   - if (null == obj.getId()) {
37   - throw new BusinessException();
38   - }
39   - masterRolesMapper.addRoles(obj);
40   - }
  28 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
41 29 }
42 30  
43 31 @Override
44 32 public void updateRoles(Roles obj) {
45 33 rolesMapper.updateRoles(obj);
46   - RolesMapper masterRolesMapper = getSlaveMapper();
47   - if (null != masterRolesMapper) {
48   - masterRolesMapper.updateRoles(obj);
49   - }
  34 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
50 35 }
51 36  
52 37 @Override
53 38 public void deleteRoles(Integer id) {
54 39 rolesMapper.deleteRoles(id);
55   - RolesMapper masterRolesMapper = getSlaveMapper();
56   - if (null != masterRolesMapper) {
57   - masterRolesMapper.deleteRoles(id);
58   - }
  40 +// iSyncDataDao.addSyncData("MysqlDel", new Roles(), id.toString());
59 41 }
60 42  
61 43 @Override
62 44 public Roles getRoles(Integer id) {
63   -
64   - if (getStartUpModel()) {
65   - RolesMapper masterRolesMapper = getSlaveMapper();
66   - if (null != masterRolesMapper) {
67   - return masterRolesMapper.getRoles(id);
68   - }
69   - }
70 45 return rolesMapper.getRoles(id);
71 46 }
72 47  
73 48 @Override
74 49 public int queryRolesCount(RolesQuery query) {
75   - if (getStartUpModel()) {
76   - RolesMapper masterRolesMapper = getSlaveMapper();
77   - if (null != masterRolesMapper) {
78   - return masterRolesMapper.queryRolesCount(query);
79   - }
80   - }
81 50 return rolesMapper.queryRolesCount(query);
82 51 }
83 52  
... ... @@ -85,13 +54,6 @@
85 54 public List<Roles> queryRoles(RolesQuery query) {
86 55 if (query.getNeed() != null) {
87 56 query.mysqlBuild(queryRolesCount(query));
88   - }
89   -
90   - if (getStartUpModel()) {
91   - RolesMapper masterRolesMapper = getSlaveMapper();
92   - if (null != masterRolesMapper) {
93   - return masterRolesMapper.queryRoles(query);
94   - }
95 57 }
96 58 return rolesMapper.queryRoles(query);
97 59 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserOrganizationMapsServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterUserOrganizationMapsMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
... ... @@ -18,62 +19,33 @@
18 19 @Autowired
19 20 private MasterUserOrganizationMapsMapper userOrganizationMapsMapper;
20 21  
21   - public UserOrganizationMapsMapper getSlaveMapper() {
22   - Object obj1 = getBean(UserOrganizationMapsMapper.class);
23   - if (null != obj1) {
24   - UserOrganizationMapsMapper masterUsersMapper = (UserOrganizationMapsMapper) obj1;
25   - return masterUsersMapper;
26   - }
27   - return null;
28   - }
  22 + @Autowired
  23 + private ISyncDataDao iSyncDataDao;
29 24  
30 25 @Override
31 26 public void addUserOrganizationMaps(UserOrganizationMaps obj) {
32 27 userOrganizationMapsMapper.addUserOrganizationMaps(obj);
33   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
34   - if(null!=masterUserOrganizationMapsMapper){
35   - if(null==obj.getId()){
36   - throw new BusinessException();
37   - }
38   - masterUserOrganizationMapsMapper.addUserOrganizationMaps(obj);
39   - }
  28 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
40 29 }
41 30  
42 31 @Override
43 32 public void updateUserOrganizationMaps(UserOrganizationMaps obj) {
44 33 userOrganizationMapsMapper.updateUserOrganizationMaps(obj);
45   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
46   - if(null!=masterUserOrganizationMapsMapper){
47   - masterUserOrganizationMapsMapper.updateUserOrganizationMaps(obj);
48   - }
  34 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
49 35 }
50 36  
51 37 @Override
52 38 public void deleteUserOrganizationMaps(Integer id) {
53 39 userOrganizationMapsMapper.deleteUserOrganizationMaps(id);
54   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
55   - if(null!=masterUserOrganizationMapsMapper){
56   - masterUserOrganizationMapsMapper.deleteUserOrganizationMaps(id);
57   - }
58 40 }
59 41  
60 42 @Override
61 43 public UserOrganizationMaps getUserOrganizationMaps(Integer id) {
62   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
63   - if(null!=masterUserOrganizationMapsMapper){
64   - return masterUserOrganizationMapsMapper.getUserOrganizationMaps(id);
65   - }
66 44 return userOrganizationMapsMapper.getUserOrganizationMaps(id);
67 45 }
68 46  
69 47 @Override
70 48 public int queryUserOrganizationMapsCount(UserOrganizationMapsQuery query) {
71   - if(getStartUpModel()){
72   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
73   - if(null!=masterUserOrganizationMapsMapper){
74   - return masterUserOrganizationMapsMapper.queryUserOrganizationMapsCount(query);
75   - }
76   - }
77 49 return userOrganizationMapsMapper.queryUserOrganizationMapsCount(query);
78 50 }
79 51  
... ... @@ -81,12 +53,6 @@
81 53 public List<UserOrganizationMaps> queryUserOrganizationMaps(UserOrganizationMapsQuery query) {
82 54 if (query.getNeed() != null) {
83 55 query.mysqlBuild(queryUserOrganizationMapsCount(query));
84   - }
85   - if(getStartUpModel()){
86   - UserOrganizationMapsMapper masterUserOrganizationMapsMapper = getSlaveMapper();
87   - if(null!=masterUserOrganizationMapsMapper){
88   - return masterUserOrganizationMapsMapper.queryUserOrganizationMaps(query);
89   - }
90 56 }
91 57 return userOrganizationMapsMapper.queryUserOrganizationMaps(query);
92 58 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UserRoleMapsServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterDepartmentsMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
11 12  
12 13  
13 14  
14 15  
... ... @@ -19,109 +20,49 @@
19 20 @Autowired
20 21 private MasterUserRoleMapsMapper userRoleMapsMapper;
21 22  
22   - public UserRoleMapsMapper getSlaveMapper() {
23   - Object obj1 = getBean(UserRoleMapsMapper.class);
24   - if (null != obj1) {
25   - UserRoleMapsMapper masterUsersMapper = (UserRoleMapsMapper) obj1;
26   - return masterUsersMapper;
27   - }
28   - return null;
29   - }
  23 + @Autowired
  24 + private ISyncDataDao iSyncDataDao;
30 25  
31 26 @Override
32 27 public void addUserRoleMaps(UserRoleMaps obj) {
33 28 userRoleMapsMapper.addUserRoleMaps(obj);
34   -
35   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
36   - if (null != masterUserRoleMapsMapper) {
37   - if (null == obj.getId()) {
38   - throw new BusinessException();
39   - }
40   - masterUserRoleMapsMapper.addUserRoleMaps(obj);
41   - }
  29 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
42 30 }
43 31  
44 32 @Override
45 33 public void updateUserRoleMaps(UserRoleMaps obj) {
46 34 userRoleMapsMapper.updateUserRoleMaps(obj);
47   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
48   - if (null != masterUserRoleMapsMapper) {
49   - masterUserRoleMapsMapper.updateUserRoleMaps(obj);
50   - }
  35 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
51 36 }
52 37  
53 38 @Override
54 39 public void deleteUserRoleMaps(Integer id) {
55 40 userRoleMapsMapper.deleteUserRoleMaps(id);
56   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
57   - if (null != masterUserRoleMapsMapper) {
58   - masterUserRoleMapsMapper.deleteUserRoleMaps(id);
59   - }
60 41 }
61 42  
62 43 @Override
63 44 public UserRoleMaps getUserRoleMaps(Integer id) {
64   - if (getStartUpModel()) {
65   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
66   - if (null != masterUserRoleMapsMapper) {
67   - return masterUserRoleMapsMapper.getUserRoleMaps(id);
68   - }
69   - }
70 45 return userRoleMapsMapper.getUserRoleMaps(id);
71 46 }
72 47  
73 48 @Override
74 49 public int queryUserRoleMapsCount(UserRoleMapsQuery query) {
75   - if (getStartUpModel()) {
76   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
77   - if (null != masterUserRoleMapsMapper) {
78   - return masterUserRoleMapsMapper.queryUserRoleMapsCount(query);
79   - }
80   - }
81 50 return userRoleMapsMapper.queryUserRoleMapsCount(query);
82 51 }
83 52  
84 53 public List<Integer> queryUserRoleList(UserRoleMapsQuery query) {
85   - if (getStartUpModel()) {
86   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
87   - if (null != masterUserRoleMapsMapper) {
88   - return masterUserRoleMapsMapper.queryUserRoleList(query);
89   - }
90   - }
91 54 return userRoleMapsMapper.queryUserRoleList(query);
92 55 }
93 56  
94 57 @Override
95 58 public List<UserRoleMaps> queryUserRoleMaps(UserRoleMapsQuery query) {
96 59 if (query.getNeed() != null) {
97   - int count = 0;
98   - if (getStartUpModel()) {
99   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
100   - if (null != masterUserRoleMapsMapper) {
101   - count = masterUserRoleMapsMapper.queryUserRoleMapsCount(query);
102   - }
103   - } else {
104   - count = userRoleMapsMapper.queryUserRoleMapsCount(query);
105   - }
106   -
107   - query.mysqlBuild(count);
  60 + query.mysqlBuild(userRoleMapsMapper.queryUserRoleMapsCount(query));
108 61 }
109   - if (getStartUpModel()) {
110   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
111   - if (null != masterUserRoleMapsMapper) {
112   - return masterUserRoleMapsMapper.queryUserRoleMaps(query);
113   - }
114   - }
115 62 return userRoleMapsMapper.queryUserRoleMaps(query);
116 63 }
117 64  
118 65 public List<String> queryUserRoleName(Integer id) {
119   - if (getStartUpModel()) {
120   - UserRoleMapsMapper masterUserRoleMapsMapper = getSlaveMapper();
121   - if (null != masterUserRoleMapsMapper) {
122   - return masterUserRoleMapsMapper.queryUserRoleName(id);
123   - }
124   - }
125 66 return userRoleMapsMapper.queryUserRoleName(id);
126 67 }
127 68 }
platform-biz-service/src/main/java/com/lyms/platform/permission/service/impl/UsersServiceImpl.java View file @ aea1e12
1 1 package com.lyms.platform.permission.service.impl;
2 2  
  3 +import com.lyms.platform.biz.dal.ISyncDataDao;
3 4 import com.lyms.platform.common.exception.BusinessException;
4 5 import com.lyms.platform.permission.DataAccessLayerService;
5 6 import com.lyms.platform.permission.dao.master.MasterUsersMapper;
6 7  
7 8  
8 9  
9 10  
10 11  
11 12  
12 13  
... ... @@ -19,66 +20,34 @@
19 20 @Autowired
20 21 private MasterUsersMapper usersMapper;
21 22  
22   - private UsersMapper getMaster() {
23   - Object obj1 = getBean(UsersMapper.class);
24   - if (null != obj1) {
25   - UsersMapper masterUsersMapper = (UsersMapper) obj1;
26   - return masterUsersMapper;
27   - }
28   - return null;
29   - }
  23 + @Autowired
  24 + private ISyncDataDao iSyncDataDao;
30 25  
31   -
32 26 @Override
33 27 public void addUsers(Users obj) {
34 28 usersMapper.addUsers(obj);
35   - UsersMapper masterUsersMapper = getMaster();
36   - if (null != masterUsersMapper) {
37   - if (null == obj.getId()) {
38   - throw new BusinessException();
39   - }
40   - masterUsersMapper.addUsers(obj);
41   - }
  29 + iSyncDataDao.addSyncData("MysqlAdd", obj, obj.getId().toString());
42 30 }
43 31  
44 32 @Override
45 33 public void updateUsers(Users obj) {
46 34 usersMapper.updateUsers(obj);
47   - UsersMapper masterUsersMapper = getMaster();
48   - if (null != masterUsersMapper) {
49   - masterUsersMapper.updateUsers(obj);
50   - }
  35 + iSyncDataDao.addSyncData("MysqlUpdate", obj, obj.getId().toString());
51 36 }
52 37  
53 38 @Override
54 39 public void deleteUsers(Integer id) {
55   -
56   - UsersMapper masterUsersMapper = getMaster();
57   - if (null != masterUsersMapper) {
58   - masterUsersMapper.deleteUsers(id);
59   - }
60 40 usersMapper.deleteUsers(id);
  41 + iSyncDataDao.addSyncData("MysqlDel", new Users(), id.toString());
61 42 }
62 43  
63 44 @Override
64 45 public Users getUsers(Integer id) {
65   - if (getStartUpModel()) {
66   - UsersMapper masterUsersMapper = getMaster();
67   - if (null != masterUsersMapper) {
68   - return masterUsersMapper.getUsers(id);
69   - }
70   - }
71 46 return usersMapper.getUsers(id);
72 47 }
73 48  
74 49 @Override
75 50 public int queryUsersCount(UsersQuery query) {
76   - if (getStartUpModel()) {
77   - UsersMapper masterUsersMapper = getMaster();
78   - if (null != masterUsersMapper) {
79   - return masterUsersMapper.queryUsersCount(query);
80   - }
81   - }
82 51 return usersMapper.queryUsersCount(query);
83 52 }
84 53  
85 54  
86 55  
87 56  
... ... @@ -87,53 +56,21 @@
87 56 if (query.getNeed() != null) {
88 57 query.mysqlBuild(queryUsersCount(query));
89 58 }
90   -
91   - if (getStartUpModel()) {
92   - UsersMapper masterUsersMapper = getMaster();
93   - if (null != masterUsersMapper) {
94   - return masterUsersMapper.queryUsers(query);
95   - }
96   - }
97   -
98 59 return usersMapper.queryUsers(query);
99 60 }
100 61  
101 62 @Override
102 63 public List<Users> queryUsers2(UsersQuery query) {
103 64 if (query.getNeed() != null) {
104   - int count = 0;
105   - if (getStartUpModel()) {
106   - UsersMapper masterUsersMapper = getMaster();
107   - if (null != masterUsersMapper) {
108   - count = masterUsersMapper.queryUsersCount2(query);
109   - }
110   - } else {
111   - count=usersMapper.queryUsersCount2(query);
112   - }
113   - query.mysqlBuild(count);
  65 + query.mysqlBuild(usersMapper.queryUsersCount2(query));
114 66 }
115   - if (getStartUpModel()) {
116   - UsersMapper masterUsersMapper = getMaster();
117   - if (null != masterUsersMapper) {
118   - return masterUsersMapper.queryUsers2(query);
119   - }
120   - }
121 67 return usersMapper.queryUsers2(query);
122 68 }
123 69  
124 70  
125 71 @Override
126 72 public Users getUsersByLoginCenterId(Integer id) {
127   -
128   - List<Users> list=null;
129   - if (getStartUpModel()) {
130   - UsersMapper masterUsersMapper = getMaster();
131   - if (null != masterUsersMapper) {
132   - list= masterUsersMapper.getUsersByLoginCenterId(id);
133   - }
134   - }else{
135   - list = usersMapper.getUsersByLoginCenterId(id);
136   - }
  73 + List<Users> list=usersMapper.getUsersByLoginCenterId(id);
137 74 if (CollectionUtils.isNotEmpty(list)) {
138 75 return list.get(0);
139 76 }
platform-common/src/main/java/com/lyms/platform/common/dao/BaseMongoDAOImpl.java View file @ aea1e12
1 1 package com.lyms.platform.common.dao;
2 2  
3 3 import com.lyms.platform.common.dao.operator.Page;
4   -import com.lyms.platform.common.utils.MongoConvertHelper;
5   -import com.lyms.platform.common.utils.MongoSyncUtil;
6   -import com.lyms.platform.common.utils.ReflectionUtils;
  4 +import com.lyms.platform.common.pojo.SyncDataModel;
  5 +import com.lyms.platform.common.utils.*;
7 6 import org.apache.commons.collections.CollectionUtils;
  7 +import org.apache.commons.lang.*;
8 8 import org.springframework.beans.factory.annotation.Autowired;
9 9 import org.springframework.data.mongodb.core.MongoTemplate;
10 10 import org.springframework.data.mongodb.core.query.Query;
... ... @@ -12,6 +12,7 @@
12 12 import org.springframework.util.Assert;
13 13  
14 14 import java.util.Collection;
  15 +import java.util.Date;
15 16 import java.util.List;
16 17  
17 18 public class BaseMongoDAOImpl<T> implements BaseMongoDAO<T> {
... ... @@ -52,7 +53,7 @@
52 53 mongoTemplate.updateMulti(query, update, this.getEntityClass());
53 54 Object id = query.getQueryObject().get("id");
54 55 if (id != null) {
55   - MongoSyncUtil.sync("UPDATE", obj, id.toString());
  56 + addSyncData("UPDATE", obj, id.toString());
56 57 }
57 58 }
58 59  
... ... @@ -60,7 +61,7 @@
60 61 public T save(T entity) {
61 62 Assert.notNull(entity, "execute insert method must not null.");
62 63 mongoTemplate.insert(entity);
63   - MongoSyncUtil.sync("ADD", entity, "");
  64 + addSyncData("ADD", entity, "");
64 65 return entity;
65 66 }
66 67  
... ... @@ -106,7 +107,7 @@
106 107 public void delete(Query query) {
107 108 Object id = query.getQueryObject().get("id");
108 109 if (id != null) {
109   - MongoSyncUtil.sync("DELETE", "", id.toString());
  110 + addSyncData("DELETE", this.getEntityClass(), id.toString());
110 111 }
111 112 mongoTemplate.findAllAndRemove(query, this.getEntityClass());
112 113 }
... ... @@ -139,6 +140,34 @@
139 140 Assert.notNull(update, "execute findAndModify method must not null.update:" + update);
140 141 mongoTemplate.updateMulti(query,update,this.getEntityClass());
141 142 }
  143 +
  144 + public static String mongo_crypto_key = Config.getItem("mongo_crypto_key", "0");
  145 + public static String mongo_sync = Config.getItem("mongo_sync", "0");
  146 + public void addSyncData(String action, Object data, String id) {
  147 + if ("1".equals(mongo_sync)) {
  148 + try {
  149 + if (action.startsWith("Mysql")) {
  150 + return;
  151 + }
  152 + SyncDataModel model = new SyncDataModel();
  153 + model.setAction(action);
  154 + if (null != data) {
  155 + model.setClassName(LymsEncodeUtil.aesEncrypt(data.getClass().getName(), mongo_crypto_key));
  156 + model.setJsonData(LymsEncodeUtil.aesEncrypt(JsonUtil.obj2JsonString(data), mongo_crypto_key));
  157 + }
  158 + model.setCreated(new Date());
  159 + model.setModified(model.getCreated());
  160 + if (org.apache.commons.lang.StringUtils.isNotBlank(id)) {
  161 + model.setDataId(LymsEncodeUtil.aesEncrypt(id, mongo_crypto_key));
  162 + }
  163 + model.setStatus(1);
  164 + mongoTemplate.insert(model);
  165 + } catch (Exception e) {
  166 + e.printStackTrace();
  167 + }
  168 + }
  169 + }
  170 +
142 171 /**
143 172 * 获取需要操作的实体类class
144 173 *
platform-common/src/main/java/com/lyms/platform/common/pojo/SyncDataModel.java View file @ aea1e12
  1 +package com.lyms.platform.common.pojo;
  2 +
  3 +import com.lyms.platform.common.result.BaseModel;
  4 +import org.springframework.data.mongodb.core.mapping.Document;
  5 +
  6 +import java.util.Date;
  7 +
  8 +/**
  9 + * Created by Administrator on 2016/9/20.
  10 + */
  11 +@Document(collection = "lyms_sync_data")
  12 +public class SyncDataModel extends BaseModel {
  13 +
  14 + private static final long serialVersionUID = 1L;
  15 +
  16 + private Date created;
  17 + private Date modified;
  18 + private String id;
  19 + private String action;
  20 + private String className;
  21 + private String jsonData;
  22 + private String dataId;
  23 + private Integer status;
  24 +
  25 + public Integer getStatus() {
  26 + return status;
  27 + }
  28 +
  29 + public void setStatus(Integer status) {
  30 + this.status = status;
  31 + }
  32 +
  33 + public Date getCreated() {
  34 + return created;
  35 + }
  36 +
  37 + public void setCreated(Date created) {
  38 + this.created = created;
  39 + }
  40 +
  41 + public Date getModified() {
  42 + return modified;
  43 + }
  44 +
  45 + public void setModified(Date modified) {
  46 + this.modified = modified;
  47 + }
  48 +
  49 + public String getId() {
  50 + return id;
  51 + }
  52 +
  53 + public void setId(String id) {
  54 + this.id = id;
  55 + }
  56 +
  57 + public String getAction() {
  58 + return action;
  59 + }
  60 +
  61 + public void setAction(String action) {
  62 + this.action = action;
  63 + }
  64 +
  65 + public String getClassName() {
  66 + return className;
  67 + }
  68 +
  69 + public void setClassName(String className) {
  70 + this.className = className;
  71 + }
  72 +
  73 + public String getJsonData() {
  74 + return jsonData;
  75 + }
  76 +
  77 + public void setJsonData(String jsonData) {
  78 + this.jsonData = jsonData;
  79 + }
  80 +
  81 + public String getDataId() {
  82 + return dataId;
  83 + }
  84 +
  85 + public void setDataId(String dataId) {
  86 + this.dataId = dataId;
  87 + }
  88 +}
platform-dal/src/main/java/com/lyms/platform/query/SyncDataQuery.java View file @ aea1e12
  1 +package com.lyms.platform.query;
  2 +
  3 +import com.lyms.platform.common.base.IConvertToNativeQuery;
  4 +import com.lyms.platform.common.dao.BaseQuery;
  5 +import com.lyms.platform.common.dao.operator.MongoCondition;
  6 +import com.lyms.platform.common.dao.operator.MongoOper;
  7 +import com.lyms.platform.common.dao.operator.MongoQuery;
  8 +
  9 +/**
  10 + * Created by Administrator on 2016/9/20.
  11 + */
  12 +public class SyncDataQuery extends BaseQuery implements IConvertToNativeQuery {
  13 +
  14 + private Integer status;
  15 +
  16 + public Integer getStatus() {
  17 + return status;
  18 + }
  19 +
  20 + public void setStatus(Integer status) {
  21 + this.status = status;
  22 + }
  23 +
  24 + @Override
  25 + public MongoQuery convertToQuery() {
  26 + MongoCondition condition = MongoCondition.newInstance();
  27 + condition.and("status", status, MongoOper.IS);
  28 + return condition.toMongoQuery();
  29 + }
  30 +}
platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/ConnTools.java View file @ aea1e12
  1 +package com.lyms.hospitalapi.qinglongxian;
  2 +
  3 +import java.sql.Connection;
  4 +import java.sql.DriverManager;
  5 +import java.sql.SQLException;
  6 +
  7 +/**
  8 + * Created by Administrator on 2016/9/9 0009.
  9 + */
  10 +public class ConnTools {
  11 + private static String hisDirverClassName = "oracle.jdbc.driver.OracleDriver";
  12 + private static String hisUrl = "jdbc:oracle:thin:@192.190.10.11:1521:xlsyy";
  13 + private static String hisUser = "mmbb";
  14 + private static String hisPassword = "mmbb";
  15 +
  16 + private static String pacsDirverClassName = "oracle.jdbc.driver.OracleDriver";
  17 + private static String pacsUrl = "jdbc:oracle:thin:@172.0.1.17:1521:ris";
  18 + private static String pacsUser = "YunYing";
  19 + private static String pacsPassword = "maroland";
  20 +
  21 + private static String lisDirverClassName = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
  22 + private static String lisUrl = "jdbc:sqlserver://172.0.1.20:1433; DatabaseName=rmlis6";
  23 + private static String lisUser = "sa";
  24 + private static String lisPassword = "skhis168";
  25 +
  26 + public static Connection makeHisConnection() {
  27 + Connection conn = null;
  28 + try {
  29 + Class.forName(hisDirverClassName);
  30 + } catch (ClassNotFoundException e) {
  31 + e.printStackTrace();
  32 + }
  33 + try {
  34 + conn = DriverManager.getConnection(hisUrl, hisUser, hisPassword);
  35 + } catch (SQLException e) {
  36 + e.printStackTrace();
  37 + }
  38 + return conn;
  39 + }
  40 +
  41 + public static Connection makePacsConnection() {
  42 + Connection conn = null;
  43 + try {
  44 + Class.forName(pacsDirverClassName);
  45 + } catch (ClassNotFoundException e) {
  46 + e.printStackTrace();
  47 + }
  48 + try {
  49 + conn = DriverManager.getConnection(pacsUrl, pacsUser, pacsPassword);
  50 + } catch (SQLException e) {
  51 + e.printStackTrace();
  52 + }
  53 + return conn;
  54 + }
  55 +
  56 + public static Connection makeLisConnection() {
  57 + Connection conn = null;
  58 + try {
  59 + Class.forName(lisDirverClassName);
  60 + } catch (ClassNotFoundException e) {
  61 + e.printStackTrace();
  62 + }
  63 + try {
  64 + conn = DriverManager.getConnection(lisUrl, lisUser, lisPassword);
  65 + } catch (SQLException e) {
  66 + e.printStackTrace();
  67 + }
  68 + return conn;
  69 + }
  70 +
  71 +
  72 +}
platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/QingLongXianHisService.java View file @ aea1e12
  1 +package com.lyms.hospitalapi.qinglongxian;
  2 +
  3 +import org.springframework.stereotype.Service;
  4 +
  5 +/**
  6 + * Created by Administrator on 2016/9/20.
  7 + */
  8 +@Service("qingLongXianHisService")
  9 +public class QingLongXianHisService {
  10 +}
platform-operate-api/src/main/java/com/lyms/hospitalapi/qinglongxian/README.TXT View file @ aea1e12
  1 +版本三
  2 +青龙县医院
platform-operate-api/src/main/resources/config.properties View file @ aea1e12
... ... @@ -4,6 +4,6 @@
4 4 #区域平台访问短信中心的token
5 5 center_token=e0c56363-00d6-42ee-bbe0-23c553583062
6 6  
7   -#His系统版本 0：未使用，1：桓台，2：新乐
  7 +#His系统版本 0：未使用，1：桓台，2：新乐，3：青龙县医院
8 8 his_version=0