From 9069f74be2b8eee1ec803f724bddbb30fae5817a Mon Sep 17 00:00:00 2001 From: liquanyu Date: Wed, 7 Mar 2018 09:28:17 +0800 Subject: [PATCH] mysql --- .../platform/biz/service/AntExRecordService.java | 1 + .../lyms/platform/biz/service/SyncDataService.java | 18 +++++++++++- .../platform/common/pojo/SyncMysqlDataModel.java | 33 ++++++++++++++++++++++ .../java/com/lyms/platform/pojo/AntExChuModel.java | 11 ++++++++ .../com/lyms/platform/pojo/AntExRecordModel.java | 11 ++++++++ .../com/lyms/platform/query/AntExRecordQuery.java | 10 +++++++ .../operate/web/facade/AntExRecordFacade.java | 5 ++++ .../web/request/AntExManagerQueryRequest.java | 10 +++++++ .../operate/web/request/AntExcAddRequest.java | 13 +++++++++ 9 files changed, 111 insertions(+), 1 deletion(-) create mode 100644 platform-common/src/main/java/com/lyms/platform/common/pojo/SyncMysqlDataModel.java diff --git a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/AntExRecordService.java b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/AntExRecordService.java index 65b6135..b1c84a8 100644 --- a/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/AntExRecordService.java +++ b/platform-biz-patient-service/src/main/java/com/lyms/platform/biz/service/AntExRecordService.java @@ -263,6 +263,7 @@ public class AntExRecordService { antExRecordModel.setBarCode(antExChuModel.getBarCode()); antExRecordModel.setCheckTime(antExChuModel.getCheckTime()); antExRecordModel.setNextCheckTime(antExChuModel.getNextCheckTime()); + antExRecordModel.setFirst(antExChuModel.getFirst()); //高危信息 List li = null; 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 index 58956fb..aefa39e 100644 --- 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 @@ -3,7 +3,10 @@ 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.common.pojo.SyncMysqlDataModel; +import com.lyms.platform.common.utils.JsonUtil; import com.lyms.platform.query.SyncDataQuery; +import org.apache.commons.codec.binary.Base64; import org.apache.commons.lang.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.domain.Sort; @@ -58,6 +61,19 @@ public class SyncDataService { return iSyncDataDao.querySyncData(query.addOrder(Sort.Direction.ASC, "created")); } + public boolean savePostMysql(String sql ,String sqlId) { + SyncMysqlDataModel syncMysqlDataModel = new SyncMysqlDataModel(); + syncMysqlDataModel.setSql(Base64.encodeBase64String(sql.getBytes())); + syncMysqlDataModel.setSqlId(sqlId); - + SyncDataModel model = new SyncDataModel(); + model.setStatus(1); + model.setJsonData(JsonUtil.obj2JsonString(model)); + model.setAction("POSTMYSQL"); + model.setCreated(new Date()); + model.setClassName("syncmysql"); + model.setModified(model.getCreated()); + iSyncDataDao.addSyncData(model); + return true; + } } diff --git a/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncMysqlDataModel.java b/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncMysqlDataModel.java new file mode 100644 index 0000000..263c482 --- /dev/null +++ b/platform-common/src/main/java/com/lyms/platform/common/pojo/SyncMysqlDataModel.java @@ -0,0 +1,33 @@ +package com.lyms.platform.common.pojo; + + +import com.lyms.platform.common.result.BaseModel; + + + +/** + * Created by Administrator on 2016/9/20. + */ +public class SyncMysqlDataModel extends BaseModel { + + private static final long serialVersionUID = 27531300010L; + + private String sql; + private String sqlId; + + public String getSql() { + return sql; + } + + public void setSql(String sql) { + this.sql = sql; + } + + public String getSqlId() { + return sqlId; + } + + public void setSqlId(String sqlId) { + this.sqlId = sqlId; + } +} diff --git a/platform-dal/src/main/java/com/lyms/platform/pojo/AntExChuModel.java b/platform-dal/src/main/java/com/lyms/platform/pojo/AntExChuModel.java index ecafd2d..73cce01 100644 --- a/platform-dal/src/main/java/com/lyms/platform/pojo/AntExChuModel.java +++ b/platform-dal/src/main/java/com/lyms/platform/pojo/AntExChuModel.java @@ -21,10 +21,21 @@ public class AntExChuModel extends BaseModel { private String genRemark; // 一般检查备注 private String gynRemark; // 妇科检查备注 + private Integer first; // 1否 2 是，是否当前医院第一次初诊 德州需求 + //该字段是针对聊城东昌区妇幼保健医院保存当天孕妇的lis检查项 private String lisCheckItems; + + public Integer getFirst() { + return first; + } + + public void setFirst(Integer first) { + this.first = first; + } + public String getLisCheckItems() { return lisCheckItems; } diff --git a/platform-dal/src/main/java/com/lyms/platform/pojo/AntExRecordModel.java b/platform-dal/src/main/java/com/lyms/platform/pojo/AntExRecordModel.java index 169b3a7..d07d3f9 100644 --- a/platform-dal/src/main/java/com/lyms/platform/pojo/AntExRecordModel.java +++ b/platform-dal/src/main/java/com/lyms/platform/pojo/AntExRecordModel.java @@ -84,6 +84,17 @@ public class AntExRecordModel extends BaseModel { // 1 表示在上面各个孕周范围内的第一次检查，2或者空表示 不是 private Integer isFirst; + + private Integer first; // 1否 2 是，是否当前医院第一次初诊 德州需求 + + public Integer getFirst() { + return first; + } + + public void setFirst(Integer first) { + this.first = first; + } + public Integer getIsFirst() { return isFirst; } diff --git a/platform-dal/src/main/java/com/lyms/platform/query/AntExRecordQuery.java b/platform-dal/src/main/java/com/lyms/platform/query/AntExRecordQuery.java index 18719ec..e4b849e 100644 --- a/platform-dal/src/main/java/com/lyms/platform/query/AntExRecordQuery.java +++ b/platform-dal/src/main/java/com/lyms/platform/query/AntExRecordQuery.java @@ -41,6 +41,16 @@ public class AntExRecordQuery extends BaseQuery implements IConvertToNativeQuery //是否范围孕周 private boolean isRangeWeek; + private Integer first; // 1否 2 是，是否当前医院第一次初诊 德州需求 + + + public Integer getFirst() { + return first; + } + + public void setFirst(Integer first) { + this.first = first; + } public boolean isRangeWeek() { return isRangeWeek; diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/AntExRecordFacade.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/AntExRecordFacade.java index 4ec6376..cae75e5 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/AntExRecordFacade.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/facade/AntExRecordFacade.java @@ -101,6 +101,11 @@ public class AntExRecordFacade { antExRecordQuery.setCityId(antExManagerQueryRequest.getCityId()); antExRecordQuery.setAreaId(antExManagerQueryRequest.getAreaId()); antExRecordQuery.setStreetId(antExManagerQueryRequest.getStreetId()); + if (antExManagerQueryRequest.getFirst() != null && antExManagerQueryRequest.getFirst() == 2) + { + antExRecordQuery.setFirst(antExManagerQueryRequest.getFirst()); + } + //产检日期 diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExManagerQueryRequest.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExManagerQueryRequest.java index 4834820..e028ad4 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExManagerQueryRequest.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExManagerQueryRequest.java @@ -75,6 +75,16 @@ public class AntExManagerQueryRequest extends BasePageQueryRequest { //查询号 private String queryNo; + private Integer first; // 1否 2 是，是否当前医院第一次初诊 德州需求 + + public Integer getFirst() { + return first; + } + + public void setFirst(Integer first) { + this.first = first; + } + public String getQueryNo() { return queryNo; } diff --git a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExcAddRequest.java b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExcAddRequest.java index f4b1457..c3500ed 100644 --- a/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExcAddRequest.java +++ b/platform-operate-api/src/main/java/com/lyms/platform/operate/web/request/AntExcAddRequest.java @@ -24,9 +24,20 @@ public class AntExcAddRequest implements IBasicRequestConvert { private String genRemark; // 一般检查备注 private String gynRemark; // 妇科检查备注 + + private Integer first; // 1否 2 是，是否当前医院第一次初诊 德州需求 + //该字段是针对聊城东昌区妇幼保健医院保存当天孕妇的lis检查项 private String lisCheckItems; + public Integer getFirst() { + return first; + } + + public void setFirst(Integer first) { + this.first = first; + } + public String getLisCheckItems() { return lisCheckItems; } @@ -1491,6 +1502,8 @@ public class AntExcAddRequest implements IBasicRequestConvert { antExChuModel.setJzxgyhwmkt(jzxgyhwmkt); antExChuModel.setEdema(edema); + antExChuModel.setFirst(first); + return antExChuModel; } -- 1.8.3.1