jiangjiazhi / regional-platform

Download as
Browse Code ยป

Commit ab27d4fcf91e1d35fb9d93dffda482c7bad2404a

Authored by baohanddd
1 parent dbbdc0f73c
Exists in master and in 8 other branches 0116, autism, dev, fengning, fengning2023-06-06, longhua, luanping, nobuildprocess

update login add first change pwd

Showing 2 changed files with 55 additions and 1 deletions

platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/MongoSyncService.java View file @ ab27d4f
... ... @@ -90,7 +90,7 @@
90 90 template.getDb().authenticate("platform", "platform123".toCharArray());
91 91 Query query = new MongoQuery(new MongoCondition("hospitalId", hospitalId, MongoOper.IS)).convertToMongoQuery();
92 92 for (Class cla:classList) {
93   - sb.append("start... ");
  93 + sb.append("sync start... ");
94 94 sb.append(cla.getName());
95 95 sb.append(" query size:");
96 96 List list = mongoTemplate.find(query, cla);
... ... @@ -107,6 +107,54 @@
107 107 } else {
108 108 Update update = MongoConvertHelper.convertToNativeUpdate(ReflectionUtils.getUpdateField(obj));
109 109 template.updateMulti(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), update, cla);
  110 + modified++;
  111 + }
  112 + }
  113 + }
  114 + sb.append(" insert:");
  115 + sb.append(insert);
  116 + sb.append(" modified:");
  117 + sb.append(modified);
  118 + sb.append("\r\n<br>");
  119 + }
  120 + return sb.toString();
  121 + } catch (Exception e) {
  122 + e.printStackTrace();
  123 + sb.append(e.getMessage());
  124 + return sb.toString();
  125 + }
  126 + }
  127 +
  128 + public String downloadByHospitalId(String hospitalId) {
  129 + if (org.apache.commons.lang.StringUtils.isBlank(hospitalId)) {
  130 + return "hospitalId is null";
  131 + }
  132 + StringBuffer sb = new StringBuffer();
  133 + List<Class> classList = new ArrayList<>();
  134 + classList.add(SmsTemplateModel.class);
  135 + try {
  136 + Mongo mongo = new Mongo("119.90.43.68", 27018);
  137 + MongoTemplate template = new MongoTemplate(mongo, "platform");
  138 + template.getDb().authenticate("platform", "platform123".toCharArray());
  139 + Query query = new MongoQuery(new MongoCondition("hospitalId", hospitalId, MongoOper.IS)).convertToMongoQuery();
  140 + for (Class cla:classList) {
  141 + sb.append("download start... ");
  142 + sb.append(cla.getName());
  143 + sb.append(" query size:");
  144 + List list = template.find(query, cla);
  145 + sb.append(list.size());
  146 + int insert = 0;
  147 + int modified = 0;
  148 + for (Object obj:list) {
  149 + String id = cla.getMethod("getId").invoke(obj).toString();
  150 + if (StringUtils.isNotBlank(id)) {
  151 + Object temp = mongoTemplate.findById(id, cla);
  152 + if (temp == null) {
  153 + mongoTemplate.insert(obj);
  154 + insert++;
  155 + } else {
  156 + Update update = MongoConvertHelper.convertToNativeUpdate(ReflectionUtils.getUpdateField(obj));
  157 + mongoTemplate.updateMulti(new MongoQuery(new MongoCondition("id", id, MongoOper.IS)).convertToMongoQuery(), update, cla);
110 158 modified++;
111 159 }
112 160 }
platform-operate-api/src/main/java/com/lyms/platform/operate/web/controller/MongoSyncController.java View file @ ab27d4f
... ... @@ -40,5 +40,11 @@
40 40 return mongoSyncService.syncByHospitalId(hospitalId);
41 41 }
42 42  
  43 + @ResponseBody
  44 + @RequestMapping(method = RequestMethod.GET,value = "/downloadByHospitalId")
  45 + public String downloadByHospitalId(String hospitalId){
  46 + return mongoSyncService.downloadByHospitalId(hospitalId);
  47 + }
  48 +
43 49 }