jiangjiazhi / regional-platform

Download as
Browse Code »

Commit 778a19d1d5d443ef98b76e191730144794e61464

Authored by litao
1 parent e1a3a1e7c4
Exists in master and in 6 other branches autism, dev, fengning, fengning2023-06-06, longhua, luanping

优惠券老数据处理

Showing 8 changed files with 1189 additions and 2 deletions

regional-etl/pom.xml View file @ 778a19d
... ... @@ -52,7 +52,7 @@
52 52 <dependency>
53 53 <groupId>com.alibaba</groupId>
54 54 <artifactId>druid</artifactId>
55   - <version>RELEASE</version>
  55 + <version>1.0.31</version>
56 56 </dependency>
57 57  
58 58 <dependency>
regional-etl/src/main/java/com/lyms/etl/dao/ICouponInfoDao.java View file @ 778a19d
... ... @@ -24,5 +24,7 @@
24 24 void saveHospitalGroup(HospitalCouponTemplateGroup hospitalCouponTemplateGroup);
25 25  
26 26 void batchSave(List<CouponInfo> commitList);
  27 +
  28 + List<String> findDistinctUserId();
27 29 }
regional-etl/src/main/java/com/lyms/etl/model/Patients.java View file @ 778a19d
Diff suppressed. Click to show
  1 +package com.lyms.etl.model;
  2 +
  3 +import com.lyms.etl.util.DateUtil;
  4 +import org.springframework.data.mongodb.core.mapping.Document;
  5 +import org.springframework.data.mongodb.core.mapping.Field;
  6 +
  7 +import java.util.Date;
  8 +import java.util.List;
  9 +import java.util.Objects;
  10 +
  11 +
  12 +@Document(collection="lyms_patient")
  13 +public class Patients {
  14 +
  15 + private static final long serialVersionUID = 1L;
  16 +
  17 + /**
  18 + * 身份证号码
  19 + */
  20 + private String cardNo;
  21 + /**
  22 + * 助产机构
  23 + */
  24 + @Field("deliverorg")
  25 + private String deliverOrg;
  26 + /**
  27 + * 分娩方式
  28 + */
  29 + @Field("duetype")
  30 + private String dueType;
  31 +
  32 + /******add by lqy begin*******/
  33 + //孕妇国籍Id
  34 + private String pcountryId;
  35 +
  36 + //孕妇民族Id
  37 + private String pnationId;
  38 +
  39 + //孕妇职业类别Id
  40 + private String pprofessionTypeId;
  41 +
  42 + //户籍类型Id
  43 + private String pcensusTypeId;
  44 +
  45 + //孕妇文化程度Id
  46 + private String plevelTypeId;
  47 +
  48 + //工作单位
  49 + private String pworkUnit;
  50 +
  51 + //居住类别Id
  52 + private String pliveTypeId;
  53 +
  54 + //证件类型Id
  55 + private String pcerteTypeId;
  56 +
  57 + //建档号
  58 + private String fileCode;
  59 + //建档医生
  60 + private String bookbuildingDoctor;
  61 +
  62 + //建档日期
  63 + private Date bookbuildingDate;
  64 +
  65 + //医院ID
  66 + private String hospitalId;
  67 +
  68 +
  69 + /***********丈夫信息***********/
  70 +
  71 + //证件号
  72 + private String hcertificateNum;
  73 + //证件类型Id
  74 + private String hcertificateTypeId;
  75 + //国籍Id
  76 + private String hcountryId;
  77 + //民族Id
  78 + private String hnationId;
  79 + //工作单位
  80 + private String hworkUnit;
  81 + //职业类别Id
  82 + private String hprofessionTypeId;
  83 +
  84 + //户籍地址
  85 + private String haddressRegister;
  86 + private String hprovinceRegisterId;
  87 + private String hcityRegisterId;
  88 + private String hareaRegisterId;
  89 + private String hstreetRegisterId;
  90 + /******add by lqy end *********/
  91 + /**
  92 + *孕妇户籍地址
  93 + */
  94 + private String address;
  95 + private String provinceId;
  96 + private String cityId;
  97 + private String areaId;
  98 + private String streetId;
  99 +
  100 + //服务状态
  101 + private Integer serviceStatus;
  102 +
  103 + //体验会员 0非会员 1会员
  104 + private Integer expVip;
  105 +
  106 + //会员截止时间
  107 + private Date vipEndTime;
  108 +
  109 + //备注
  110 + private String mremark;
  111 +
  112 + //分娩状态 0未终止妊娠 1终止妊娠
  113 + private Integer dueStatus;
  114 +
  115 + //建档类型 0 未分娩建档 1儿童建档时建档 2 自动分娩类型 3 转诊自动建档
  116 + private Integer buildType;
  117 +
  118 + /**
  119 + * 产后休养地
  120 + */
  121 + private String addressPostRest;
  122 + private String provincePostRestId;
  123 + private String cityPostRestId;
  124 + private String areaPostRestId;
  125 + private String streetPostRestId;
  126 +
  127 +
  128 + /**
  129 + * 孕妇居住地
  130 + */
  131 + private String addressRegister;
  132 + private String provinceRegisterId;
  133 + private String cityRegisterId;
  134 + private String areaRegisterId;
  135 + private String streetRegisterId;
  136 +
  137 + /**
  138 + * 社区id
  139 + */
  140 + private String communityId;
  141 + /**
  142 + * 是否访视
  143 + */
  144 + private Integer isVisit;
  145 +
  146 + private String id;
  147 +
  148 + private String username;
  149 +
  150 + private Integer crisis;
  151 +
  152 + private String avatar;
  153 + //预产期
  154 + private Date dueDate;
  155 + //末次月经
  156 + private Date lastMenses;
  157 + //分娩日期
  158 + private Date fmDate;
  159 +
  160 + @SuppressWarnings("unused")
  161 + private Integer age;
  162 +
  163 + private String phone;
  164 +
  165 + private String foreignId;
  166 +
  167 + private String publishId;
  168 +
  169 + private String publishName;
  170 + //数据来源id,用于区域隐藏建档
  171 + private String source;
  172 +
  173 + private Integer yn;
  174 +
  175 + private Date modified;
  176 +
  177 + private Date created;
  178 +
  179 + private Integer gender;
  180 +
  181 + private Date birth;
  182 + //1孕妇 3 产妇
  183 + private Integer type;
  184 +
  185 + private String foreignSubId;
  186 +
  187 + private String triageOrderNo;
  188 +
  189 + private Date nextCheckTime;
  190 +
  191 + private Integer patientLevel;
  192 + //最后一次产检医生职工ID
  193 + private String lastCheckEmployeeId;
  194 + //最后一次检查id
  195 + private Integer lastReportId;
  196 + //高危风险id
  197 + private List<String> riskFactorId;
  198 + //建档时高危风险id
  199 + private List<String> firstRiskFactorId;
  200 + //自定义的高危因素
  201 + private String oRiskFactor;
  202 + //风险等级颜色
  203 + private String riskLevelId;
  204 + //高危评分值
  205 + private Integer riskScore;
  206 + private Integer serviceType;
  207 + private Integer vip;
  208 + //最后一次检查医生名称
  209 + private String lastReportDoctorName;
  210 + private String mommyPatientId;
  211 + private String husbandName;
  212 + private String husbandPhone;
  213 + //丈夫生日
  214 + private Date husbandBirth;
  215 + private String vcCardNo;
  216 +
  217 + //丈夫文化程度Id
  218 + private String hlevelTypeId;
  219 +
  220 + //体验类型
  221 + private Integer expType;
  222 +
  223 + //person表主键
  224 + private String pid;
  225 + //是否隐藏 0 隐藏 1 显示
  226 + private String enable;
  227 + //最后一次高危时间
  228 + private Date lastRhTime;
  229 + //本院最后一次产检时间
  230 + private Date lastCTime;
  231 + //本院产后复查次数
  232 + private Integer postViewTimes;
  233 + //操作人
  234 + private Integer operator;
  235 +
  236 + // 分娩相关信息
  237 + // 分娩医院
  238 + private String fmHospital;
  239 + // 分娩年龄
  240 + private Integer fmAge;
  241 + // 分娩孕周
  242 + private Integer fmWeek;
  243 + // 分娩方式
  244 + private String fmType;
  245 +
  246 + private Integer isAutoFm;
  247 +
  248 + // 是否发放过优惠券
  249 + private boolean isSendCoupon;
  250 +
  251 + public Integer getIsAutoFm() {
  252 + return isAutoFm;
  253 + }
  254 +
  255 + public void setIsAutoFm(Integer isAutoFm) {
  256 + this.isAutoFm = isAutoFm;
  257 + }
  258 +
  259 + public String getFmHospital() {
  260 + return fmHospital;
  261 + }
  262 +
  263 + public void setFmHospital(String fmHospital) {
  264 + this.fmHospital = fmHospital;
  265 + }
  266 +
  267 + public Integer getFmAge() {
  268 + return fmAge;
  269 + }
  270 +
  271 + public void setFmAge(Integer fmAge) {
  272 + this.fmAge = fmAge;
  273 + }
  274 +
  275 + public Integer getFmWeek() {
  276 + return fmWeek;
  277 + }
  278 +
  279 + public void setFmWeek(Integer fmWeek) {
  280 + this.fmWeek = fmWeek;
  281 + }
  282 +
  283 + public String getFmType() {
  284 + return fmType;
  285 + }
  286 +
  287 + public void setFmType(String fmType) {
  288 + this.fmType = fmType;
  289 + }
  290 +
  291 + public String getSource() {
  292 + return source;
  293 + }
  294 +
  295 + public void setSource(String source) {
  296 + this.source = source;
  297 + }
  298 +
  299 + public String getoRiskFactor() {
  300 + return oRiskFactor;
  301 + }
  302 +
  303 + public void setoRiskFactor(String oRiskFactor) {
  304 + this.oRiskFactor = oRiskFactor;
  305 + }
  306 +
  307 + public Date getLastCTime() {
  308 + return lastCTime;
  309 + }
  310 +
  311 + public void setLastCTime(Date lastCTime) {
  312 + this.lastCTime = lastCTime;
  313 + }
  314 +
  315 + public Integer getPostViewTimes() {
  316 + return postViewTimes;
  317 + }
  318 +
  319 + public void setPostViewTimes(Integer postViewTimes) {
  320 + this.postViewTimes = postViewTimes;
  321 + }
  322 +
  323 + public Integer getOperator() {
  324 + return operator;
  325 + }
  326 +
  327 + public void setOperator(Integer operator) {
  328 + this.operator = operator;
  329 + }
  330 +
  331 + public Date getLastRhTime() {
  332 + return lastRhTime;
  333 + }
  334 +
  335 + public void setLastRhTime(Date lastRhTime) {
  336 + this.lastRhTime = lastRhTime;
  337 + }
  338 +
  339 + public String getEnable() {
  340 + return enable;
  341 + }
  342 +
  343 + public void setEnable(String enable) {
  344 + this.enable = enable;
  345 + }
  346 +
  347 + public Date getHusbandBirth() {
  348 + return husbandBirth;
  349 + }
  350 +
  351 + public void setHusbandBirth(Date husbandBirth) {
  352 + this.husbandBirth = husbandBirth;
  353 + }
  354 +
  355 + public String getPid() {
  356 + return pid;
  357 + }
  358 +
  359 + public void setPid(String pid) {
  360 + this.pid = pid;
  361 + }
  362 +
  363 + public Integer getExpType() {
  364 + return expType;
  365 + }
  366 +
  367 + public void setExpType(Integer expType) {
  368 + this.expType = expType;
  369 + }
  370 +
  371 + public String getPlevelTypeId() {
  372 + return plevelTypeId;
  373 + }
  374 +
  375 + public void setPlevelTypeId(String plevelTypeId) {
  376 + this.plevelTypeId = plevelTypeId;
  377 + }
  378 +
  379 + public String getHlevelTypeId() {
  380 + return hlevelTypeId;
  381 + }
  382 +
  383 + public void setHlevelTypeId(String hlevelTypeId) {
  384 + this.hlevelTypeId = hlevelTypeId;
  385 + }
  386 +
  387 + public Date getFmDate() {
  388 + return fmDate;
  389 + }
  390 +
  391 + public void setFmDate(Date fmDate) {
  392 + this.fmDate = fmDate;
  393 + }
  394 +
  395 + public List<String> getFirstRiskFactorId() {
  396 + return firstRiskFactorId;
  397 + }
  398 +
  399 + public void setFirstRiskFactorId(List<String> firstRiskFactorId) {
  400 + this.firstRiskFactorId = firstRiskFactorId;
  401 + }
  402 +
  403 + public List<String> getRiskFactorId() {
  404 + return riskFactorId;
  405 + }
  406 +
  407 + public void setRiskFactorId(List<String> riskFactorId) {
  408 + this.riskFactorId = riskFactorId;
  409 + }
  410 +
  411 + public String getRiskLevelId() {
  412 + return riskLevelId;
  413 + }
  414 +
  415 + public void setRiskLevelId(String riskLevelId) {
  416 + this.riskLevelId = riskLevelId;
  417 + }
  418 + public String getAddressPostRest() {
  419 + return addressPostRest;
  420 + }
  421 +
  422 + public void setAddressPostRest(String addressPostRest) {
  423 + this.addressPostRest = addressPostRest;
  424 + }
  425 +
  426 + public String getProvincePostRestId() {
  427 + return provincePostRestId;
  428 + }
  429 +
  430 + public void setProvincePostRestId(String provincePostRestId) {
  431 + this.provincePostRestId = provincePostRestId;
  432 + }
  433 +
  434 + public String getCityPostRestId() {
  435 + return cityPostRestId;
  436 + }
  437 +
  438 + public void setCityPostRestId(String cityPostRestId) {
  439 + this.cityPostRestId = cityPostRestId;
  440 + }
  441 +
  442 + public String getAreaPostRestId() {
  443 + return areaPostRestId;
  444 + }
  445 +
  446 + public void setAreaPostRestId(String areaPostRestId) {
  447 + this.areaPostRestId = areaPostRestId;
  448 + }
  449 + public Integer getRiskScore() {
  450 + return riskScore;
  451 + }
  452 +
  453 + public void setRiskScore(Integer riskScore) {
  454 + this.riskScore = riskScore;
  455 + }
  456 +
  457 + public String getVcCardNo() {
  458 + return vcCardNo;
  459 + }
  460 +
  461 + public void setVcCardNo(String vcCardNo) {
  462 + this.vcCardNo = vcCardNo;
  463 + }
  464 +
  465 + public String getHusbandName() {
  466 + return husbandName;
  467 + }
  468 +
  469 + public void setHusbandName(String husbandName) {
  470 + this.husbandName = husbandName;
  471 + }
  472 +
  473 + public String getHusbandPhone() {
  474 + return husbandPhone;
  475 + }
  476 +
  477 + public Integer getBuildType() {
  478 + return buildType;
  479 + }
  480 +
  481 + public void setBuildType(Integer buildType) {
  482 + this.buildType = buildType;
  483 + }
  484 +
  485 + public void setHusbandPhone(String husbandPhone) {
  486 + this.husbandPhone = husbandPhone;
  487 + }
  488 +
  489 + public String getMommyPatientId() {
  490 + return mommyPatientId;
  491 + }
  492 +
  493 + public void setMommyPatientId(String mommyPatientId) {
  494 + this.mommyPatientId = mommyPatientId;
  495 + }
  496 +
  497 + public String getLastCheckEmployeeId() {
  498 + return lastCheckEmployeeId;
  499 + }
  500 +
  501 + public void setLastCheckEmployeeId(String lastCheckEmployeeId) {
  502 + this.lastCheckEmployeeId = lastCheckEmployeeId;
  503 + }
  504 +
  505 + public String getLastReportDoctorName() {
  506 + return lastReportDoctorName;
  507 + }
  508 +
  509 + public void setLastReportDoctorName(String lastReportDoctorName) {
  510 + this.lastReportDoctorName = lastReportDoctorName;
  511 + }
  512 +
  513 + public String getAddressRegister() {
  514 + return addressRegister;
  515 + }
  516 +
  517 + public void setAddressRegister(String addressRegister) {
  518 + this.addressRegister = addressRegister;
  519 + }
  520 +
  521 + public String getProvinceRegisterId() {
  522 + return provinceRegisterId;
  523 + }
  524 +
  525 + public void setProvinceRegisterId(String provinceRegisterId) {
  526 + this.provinceRegisterId = provinceRegisterId;
  527 + }
  528 +
  529 + public String getCityRegisterId() {
  530 + return cityRegisterId;
  531 + }
  532 +
  533 + public void setCityRegisterId(String cityRegisterId) {
  534 + this.cityRegisterId = cityRegisterId;
  535 + }
  536 +
  537 + public String getAreaRegisterId() {
  538 + return areaRegisterId;
  539 + }
  540 +
  541 + public void setAreaRegisterId(String areaRegisterId) {
  542 + this.areaRegisterId = areaRegisterId;
  543 + }
  544 + public Integer getLastReportId() {
  545 + return lastReportId;
  546 + }
  547 +
  548 + public void setLastReportId(Integer lastReportId) {
  549 + this.lastReportId = lastReportId;
  550 + }
  551 +
  552 + public Integer getDueStatus() {
  553 + return dueStatus;
  554 + }
  555 +
  556 + public void setDueStatus(Integer dueStatus) {
  557 + this.dueStatus = dueStatus;
  558 + }
  559 +
  560 + public String getMremark() {
  561 + return mremark;
  562 + }
  563 +
  564 + public void setMremark(String mremark) {
  565 + this.mremark = mremark;
  566 + }
  567 +
  568 + public Integer getServiceStatus() {
  569 + return serviceStatus;
  570 + }
  571 +
  572 + public void setServiceStatus(Integer serviceStatus) {
  573 + this.serviceStatus = serviceStatus;
  574 + }
  575 +
  576 + public Integer getExpVip() {
  577 + return expVip;
  578 + }
  579 +
  580 + public void setExpVip(Integer expVip) {
  581 + this.expVip = expVip;
  582 + }
  583 +
  584 + public Date getVipEndTime() {
  585 + return vipEndTime;
  586 + }
  587 +
  588 + public void setVipEndTime(Date vipEndTime) {
  589 + this.vipEndTime = vipEndTime;
  590 + }
  591 +
  592 + public String getAreaId() {
  593 + return areaId;
  594 + }
  595 +
  596 + public void setAreaId(String areaId) {
  597 + this.areaId = areaId;
  598 + }
  599 +
  600 + public String getCityId() {
  601 + return cityId;
  602 + }
  603 +
  604 + public void setCityId(String cityId) {
  605 + this.cityId = cityId;
  606 + }
  607 +
  608 + public String getProvinceId() {
  609 + return provinceId;
  610 + }
  611 +
  612 + public void setProvinceId(String provinceId) {
  613 + this.provinceId = provinceId;
  614 + }
  615 +
  616 + public Integer getServiceType() {
  617 + return serviceType;
  618 + }
  619 +
  620 + public void setServiceType(Integer serviceType) {
  621 + this.serviceType = serviceType;
  622 + }
  623 +
  624 + public Integer getVip() {
  625 + return vip;
  626 + }
  627 +
  628 + public void setVip(Integer vip) {
  629 + this.vip = vip;
  630 + }
  631 +
  632 + public Integer getPatientLevel() {
  633 + return patientLevel;
  634 + }
  635 +
  636 + public void setPatientLevel(Integer patientLevel) {
  637 + this.patientLevel = patientLevel;
  638 + }
  639 +
  640 + public Date getNextCheckTime() {
  641 + return nextCheckTime;
  642 + }
  643 +
  644 + public void setNextCheckTime(Date nextCheckTime) {
  645 + this.nextCheckTime = nextCheckTime;
  646 + }
  647 +
  648 + public String getForeignSubId() {
  649 + return foreignSubId;
  650 + }
  651 +
  652 + public void setForeignSubId(String foreignSubId) {
  653 + this.foreignSubId = foreignSubId;
  654 + }
  655 +
  656 + public Integer getType() {
  657 + return type;
  658 + }
  659 +
  660 + public void setType(Integer type) {
  661 + this.type = type;
  662 + }
  663 +
  664 + public String getTriageOrderNo() {
  665 + return triageOrderNo;
  666 + }
  667 +
  668 + public void setTriageOrderNo(String triageOrderNo) {
  669 + this.triageOrderNo = triageOrderNo;
  670 + }
  671 +
  672 + public Integer getGender() {
  673 + return gender;
  674 + }
  675 +
  676 + public void setGender(Integer gender) {
  677 + this.gender = gender;
  678 + }
  679 +
  680 + public Date getBirth() {
  681 + return birth;
  682 + }
  683 +
  684 + public void setBirth(Date birth) {
  685 + this.birth = birth;
  686 + }
  687 +
  688 + public String getUsername() {
  689 + return username;
  690 + }
  691 +
  692 + public void setUsername(String username) {
  693 + this.username = username;
  694 +
  695 + }
  696 +
  697 + public Integer getCrisis() {
  698 + return crisis;
  699 + }
  700 +
  701 + public void setCrisis(Integer crisis) {
  702 + this.crisis = crisis;
  703 +
  704 + }
  705 +
  706 + public String getAvatar() {
  707 + return avatar;
  708 + }
  709 +
  710 + public void setAvatar(String avatar) {
  711 + this.avatar = avatar;
  712 +
  713 + }
  714 +
  715 + public Date getDueDate() {
  716 + return dueDate;
  717 + }
  718 +
  719 + public void setDueDate(Date dueDate) {
  720 + this.dueDate = dueDate;
  721 +
  722 + }
  723 +
  724 + public Date getLastMenses() {
  725 + return lastMenses;
  726 + }
  727 +
  728 + public void setLastMenses(Date lastMenses) {
  729 + this.lastMenses = lastMenses;
  730 +
  731 + }
  732 +
  733 + public Integer getAge() {
  734 + return DateUtil.getAge(birth);
  735 + }
  736 +
  737 + public void setAge(Integer age) {
  738 + this.age = age;
  739 +
  740 + }
  741 +
  742 + public String getPhone() {
  743 + return phone;
  744 + }
  745 +
  746 + public void setPhone(String phone) {
  747 + this.phone = phone;
  748 +
  749 + }
  750 +
  751 + public String getForeignId() {
  752 + return foreignId;
  753 + }
  754 +
  755 + public void setForeignId(String foreignId) {
  756 + this.foreignId = foreignId;
  757 +
  758 + }
  759 +
  760 + public String getId() {
  761 + return id;
  762 + }
  763 +
  764 + public void setId(String id) {
  765 + this.id = id;
  766 + }
  767 +
  768 + public String getPublishId() {
  769 + return publishId;
  770 + }
  771 +
  772 + public void setPublishId(String publishId) {
  773 + this.publishId = publishId;
  774 + }
  775 +
  776 + public String getPublishName() {
  777 + return publishName;
  778 + }
  779 +
  780 + public void setPublishName(String publishName) {
  781 + this.publishName = publishName;
  782 +
  783 + }
  784 +
  785 + public Integer getYn() {
  786 + return yn;
  787 + }
  788 +
  789 + public void setYn(Integer yn) {
  790 + this.yn = yn;
  791 +
  792 + }
  793 +
  794 + public Date getModified() {
  795 + return modified;
  796 + }
  797 +
  798 + public void setModified(Date modified) {
  799 + this.modified = modified;
  800 +
  801 + }
  802 +
  803 + public Date getCreated() {
  804 + return created;
  805 + }
  806 +
  807 + public void setCreated(Date created) {
  808 + this.created = created;
  809 + }
  810 +
  811 + public String getAddress() {
  812 + return address;
  813 + }
  814 +
  815 + public void setAddress(String address) {
  816 + this.address = address;
  817 + }
  818 +
  819 + public String getCardNo() {
  820 + return cardNo;
  821 + }
  822 +
  823 + public void setCardNo(String cardNo) {
  824 + this.cardNo = cardNo;
  825 + }
  826 +
  827 + public String getCommunityId() {
  828 + return communityId;
  829 + }
  830 +
  831 + public void setCommunityId(String communityId) {
  832 + this.communityId = communityId;
  833 + }
  834 +
  835 + public String getDeliverOrg() {
  836 + return deliverOrg;
  837 + }
  838 +
  839 + public void setDeliverOrg(String deliverOrg) {
  840 + this.deliverOrg = deliverOrg;
  841 + }
  842 +
  843 + public String getDueType() {
  844 + return dueType;
  845 + }
  846 +
  847 + public void setDueType(String dueType) {
  848 + this.dueType = dueType;
  849 + }
  850 +
  851 + public Integer getIsVisit() {
  852 + return isVisit;
  853 + }
  854 +
  855 + public void setIsVisit(Integer isVisit) {
  856 + this.isVisit = isVisit;
  857 + }
  858 +
  859 + public String getPcountryId() {
  860 + return pcountryId;
  861 + }
  862 +
  863 + public void setPcountryId(String pcountryId) {
  864 + this.pcountryId = pcountryId;
  865 + }
  866 +
  867 + public String getPnationId() {
  868 + return pnationId;
  869 + }
  870 +
  871 + public void setPnationId(String pnationId) {
  872 + this.pnationId = pnationId;
  873 + }
  874 +
  875 + public String getPprofessionTypeId() {
  876 + return pprofessionTypeId;
  877 + }
  878 +
  879 + public void setPprofessionTypeId(String pprofessionTypeId) {
  880 + this.pprofessionTypeId = pprofessionTypeId;
  881 + }
  882 +
  883 + public String getPcensusTypeId() {
  884 + return pcensusTypeId;
  885 + }
  886 +
  887 + public void setPcensusTypeId(String pcensusTypeId) {
  888 + this.pcensusTypeId = pcensusTypeId;
  889 + }
  890 +
  891 + public String getPworkUnit() {
  892 + return pworkUnit;
  893 + }
  894 +
  895 + public void setPworkUnit(String pworkUnit) {
  896 + this.pworkUnit = pworkUnit;
  897 + }
  898 +
  899 + public String getPliveTypeId() {
  900 + return pliveTypeId;
  901 + }
  902 +
  903 + public void setPliveTypeId(String pliveTypeId) {
  904 + this.pliveTypeId = pliveTypeId;
  905 + }
  906 +
  907 + public String getPcerteTypeId() {
  908 + return pcerteTypeId;
  909 + }
  910 +
  911 + public void setPcerteTypeId(String pcerteTypeId) {
  912 + this.pcerteTypeId = pcerteTypeId;
  913 + }
  914 +
  915 + public String getFileCode() {
  916 + return fileCode;
  917 + }
  918 +
  919 + public void setFileCode(String fileCode) {
  920 + this.fileCode = fileCode;
  921 + }
  922 +
  923 + public String getBookbuildingDoctor() {
  924 + return bookbuildingDoctor;
  925 + }
  926 +
  927 + public void setBookbuildingDoctor(String bookbuildingDoctor) {
  928 + this.bookbuildingDoctor = bookbuildingDoctor;
  929 + }
  930 +
  931 + public Date getBookbuildingDate() {
  932 + return bookbuildingDate;
  933 + }
  934 +
  935 + public void setBookbuildingDate(Date bookbuildingDate) {
  936 + this.bookbuildingDate = bookbuildingDate;
  937 + }
  938 +
  939 + public String getHcertificateNum() {
  940 + return hcertificateNum;
  941 + }
  942 +
  943 + public void setHcertificateNum(String hcertificateNum) {
  944 + this.hcertificateNum = hcertificateNum;
  945 + }
  946 +
  947 + public String getHcertificateTypeId() {
  948 + return hcertificateTypeId;
  949 + }
  950 +
  951 + public void setHcertificateTypeId(String hcertificateTypeId) {
  952 + this.hcertificateTypeId = hcertificateTypeId;
  953 + }
  954 +
  955 + public String getHcountryId() {
  956 + return hcountryId;
  957 + }
  958 +
  959 + public void setHcountryId(String hcountryId) {
  960 + this.hcountryId = hcountryId;
  961 + }
  962 +
  963 + public String getHnationId() {
  964 + return hnationId;
  965 + }
  966 +
  967 + public void setHnationId(String hnationId) {
  968 + this.hnationId = hnationId;
  969 + }
  970 +
  971 + public String getHworkUnit() {
  972 + return hworkUnit;
  973 + }
  974 +
  975 + public void setHworkUnit(String hworkUnit) {
  976 + this.hworkUnit = hworkUnit;
  977 + }
  978 +
  979 + public String getHprofessionTypeId() {
  980 + return hprofessionTypeId;
  981 + }
  982 +
  983 + public void setHprofessionTypeId(String hprofessionTypeId) {
  984 + this.hprofessionTypeId = hprofessionTypeId;
  985 + }
  986 +
  987 + public String getHaddressRegister() {
  988 + return haddressRegister;
  989 + }
  990 +
  991 + public void setHaddressRegister(String haddressRegister) {
  992 + this.haddressRegister = haddressRegister;
  993 + }
  994 +
  995 + public String getHprovinceRegisterId() {
  996 + return hprovinceRegisterId;
  997 + }
  998 +
  999 + public void setHprovinceRegisterId(String hprovinceRegisterId) {
  1000 + this.hprovinceRegisterId = hprovinceRegisterId;
  1001 + }
  1002 +
  1003 + public String getHcityRegisterId() {
  1004 + return hcityRegisterId;
  1005 + }
  1006 +
  1007 + public void setHcityRegisterId(String hcityRegisterId) {
  1008 + this.hcityRegisterId = hcityRegisterId;
  1009 + }
  1010 +
  1011 + public String getHareaRegisterId() {
  1012 + return hareaRegisterId;
  1013 + }
  1014 +
  1015 + public void setHareaRegisterId(String hareaRegisterId) {
  1016 + this.hareaRegisterId = hareaRegisterId;
  1017 + }
  1018 +
  1019 + public String getHospitalId() {
  1020 + return hospitalId;
  1021 + }
  1022 +
  1023 + public void setHospitalId(String hospitalId) {
  1024 + this.hospitalId = hospitalId;
  1025 + }
  1026 +
  1027 + public String getHstreetRegisterId() {
  1028 + return hstreetRegisterId;
  1029 + }
  1030 +
  1031 + public void setHstreetRegisterId(String hstreetRegisterId) {
  1032 + this.hstreetRegisterId = hstreetRegisterId;
  1033 + }
  1034 +
  1035 + public String getStreetId() {
  1036 + return streetId;
  1037 + }
  1038 +
  1039 + public void setStreetId(String streetId) {
  1040 + this.streetId = streetId;
  1041 + }
  1042 +
  1043 + public String getStreetPostRestId() {
  1044 + return streetPostRestId;
  1045 + }
  1046 +
  1047 + public void setStreetPostRestId(String streetPostRestId) {
  1048 + this.streetPostRestId = streetPostRestId;
  1049 + }
  1050 +
  1051 + public String getStreetRegisterId() {
  1052 + return streetRegisterId;
  1053 + }
  1054 +
  1055 + public void setStreetRegisterId(String streetRegisterId) {
  1056 + this.streetRegisterId = streetRegisterId;
  1057 + }
  1058 +
  1059 + public boolean isSendCoupon() {
  1060 + return isSendCoupon;
  1061 + }
  1062 +
  1063 + public void setSendCoupon(boolean sendCoupon) {
  1064 + isSendCoupon = sendCoupon;
  1065 + }
  1066 +
  1067 + @Override
  1068 + public boolean equals(Object o) {
  1069 + if (this == o) return true;
  1070 + if (o == null || getClass() != o.getClass()) return false;
  1071 + Patients patients = (Patients) o;
  1072 + return Objects.equals(id, patients.id);
  1073 + }
  1074 +
  1075 + @Override
  1076 + public int hashCode() {
  1077 + return Objects.hash(id);
  1078 + }
  1079 +}
regional-etl/src/main/java/com/lyms/etl/service/IPatientService.java View file @ 778a19d
  1 +package com.lyms.etl.service;
  2 +
  3 +/**
  4 + * @Author: litao
  5 + * @Date: 2017/6/26 0026
  6 + */
  7 +public interface IPatientService extends IInvokeHandler {
  8 +}
regional-etl/src/main/java/com/lyms/etl/service/impl/PatientServiceImpl.java View file @ 778a19d
  1 +package com.lyms.etl.service.impl;
  2 +
  3 +import com.lyms.etl.dao.ICouponInfoDao;
  4 +import com.lyms.etl.model.Patients;
  5 +import com.lyms.etl.service.IPatientService;
  6 +import org.springframework.beans.factory.annotation.Autowired;
  7 +import org.springframework.context.annotation.Profile;
  8 +import org.springframework.data.mongodb.core.MongoTemplate;
  9 +import org.springframework.data.mongodb.core.query.Criteria;
  10 +import org.springframework.data.mongodb.core.query.Query;
  11 +import org.springframework.data.mongodb.core.query.Update;
  12 +import org.springframework.stereotype.Service;
  13 +
  14 +import java.util.Arrays;
  15 +import java.util.List;
  16 +
  17 +/**
  18 + * @Author: litao
  19 + * @Date: 2017/6/26 0026
  20 + */
  21 +@Profile("patient")
  22 +@Service
  23 +public class PatientServiceImpl implements IPatientService {
  24 +
  25 + @Autowired
  26 + private ICouponInfoDao couponInfoDao;
  27 +
  28 + @Autowired
  29 + private MongoTemplate mongoTemplate;
  30 +
  31 + @Override
  32 + public void invoke() {
  33 + List<String> userIds = couponInfoDao.findDistinctUserId();
  34 + mongoTemplate.updateMulti(Query.query(Criteria.where("pid").in(userIds)), Update.update("isSendCoupon", true), Patients.class);
  35 + }
  36 +}
regional-etl/src/main/java/com/lyms/etl/util/DateUtil.java View file @ 778a19d
  1 +package com.lyms.etl.util;
  2 +
  3 +import java.util.Calendar;
  4 +import java.util.Date;
  5 +
  6 +public class DateUtil {
  7 + public static Integer getAge(Date birth) {
  8 + if(null==birth){
  9 + return null;
  10 + }
  11 + Calendar calendar= Calendar.getInstance();
  12 + Date date=new Date();
  13 + calendar.setTime(date);
  14 +
  15 + Calendar c1 = Calendar.getInstance();
  16 + Calendar c2 = Calendar.getInstance();
  17 + c1.setTime(date);
  18 + c2.setTime(birth);
  19 + int year1 = c1.get(Calendar.YEAR);
  20 + int year2 = c2.get(Calendar.YEAR);
  21 +
  22 + int mouth1 = c1.get(Calendar.MONTH);//0当前
  23 + int mouth2 = c2.get(Calendar.MONTH);//4
  24 + int i=0;
  25 + /* if(mouth2-mouth1>=0){
  26 + int days1 = c1.get(Calendar.DAY_OF_MONTH);//当前10
  27 + int days2 = c2.get(Calendar.DAY_OF_MONTH);//1
  28 + if(days1<days2){
  29 + i=i-1;
  30 + }else if(days1>days2){
  31 + }
  32 + }else if(mouth1-mouth2<0){
  33 + i=i-1;
  34 + }*/
  35 +
  36 + if(mouth2==mouth1){
  37 + int days1 = c1.get(Calendar.DAY_OF_MONTH);//当前10
  38 + int days2 = c2.get(Calendar.DAY_OF_MONTH);//1
  39 + if(days1<days2){
  40 + i=i-1;
  41 + }else if(days1>days2){
  42 +// i=i-1;
  43 + }
  44 + }else if(mouth2>mouth1){
  45 + i=i-1;
  46 + }
  47 +
  48 +
  49 +// if (birth == null) {
  50 +// return null;
  51 +// }
  52 +// Date now = new Date();
  53 +// long m = now.getTime() - birth.getTime();
  54 +// Long age = m / 31536000000L;
  55 +// return age.intValue();
  56 + return (Math.abs(year1 - year2)+i);
  57 + }
  58 +}
regional-etl/src/main/resources/application.properties View file @ 778a19d
... ... @@ -22,5 +22,5 @@
22 22 mybatis.mapperLocations=classpath:mappers/*.xml
23 23  
24 24 #spring.profiles.active=prod, etl
25   -spring.profiles.active=coupon
  25 +spring.profiles.active=patient
regional-etl/src/main/resources/mappers/CouponInfoMapper.xml View file @ 778a19d
... ... @@ -58,5 +58,9 @@
58 58 (#{item.id}, #{item.sequenceId}, #{item.createDate}, #{item.useDate}, #{item.userId}, #{item.createUserId}, #{item.couponTemplateId}, #{item.createHospitalId}, #{item.usedHospitalId}, #{item.status})
59 59 </foreach>
60 60 </insert>
  61 +
  62 + <select id="findDistinctUserId" resultType="string">
  63 + select distinct(user_id) from coupon_info
  64 + </select>
61 65 </mapper>