Merge remote-tracking branch 'origin/master'

# Conflicts:
#	smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/schedule/RefreshJob.java

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/controller/web/HpAppointmentController.java

+package cn.sh.stc.sict.theme.hphy.controller.web;
+
+
+import cn.sh.stc.sict.theme.hphy.service.HpAppointmentService;
+import com.baomidou.mybatisplus.extension.api.ApiController;
+import io.swagger.annotations.Api;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * [黄浦]预约记录(HpAppointment)维护接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:57
+ */
+@Api(value = "[黄浦]预约记录维护接口", tags = "[黄浦]预约记录维护接口")
+@RestController
+@RequestMapping("hpAppointment")
+@AllArgsConstructor
+public class HpAppointmentController extends ApiController {
+    /**
+     * 服务对象
+     */
+    private final HpAppointmentService hpAppointmentService;
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/controller/web/HpDeptInfoController.java

+package cn.sh.stc.sict.theme.hphy.controller.web;
+
+
+import cn.sh.stc.sict.theme.hphy.service.HpDeptInfoService;
+import com.baomidou.mybatisplus.extension.api.ApiController;
+import io.swagger.annotations.Api;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * (HpDeptInfo)维护接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+@Api(value = "维护接口", tags = "维护接口")
+@RestController
+@RequestMapping("hpDeptInfo")
+@AllArgsConstructor
+public class HpDeptInfoController extends ApiController {
+    /**
+     * 服务对象
+     */
+    private final HpDeptInfoService hpDeptInfoService;
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/controller/web/HpDocInfoController.java

+package cn.sh.stc.sict.theme.hphy.controller.web;
+
+
+import cn.sh.stc.sict.theme.hphy.service.HpDocInfoService;
+import com.baomidou.mybatisplus.extension.api.ApiController;
+import io.swagger.annotations.Api;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * (HpDocInfo)维护接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+@Api(value = "维护接口", tags = "维护接口")
+@RestController
+@RequestMapping("hpDocInfo")
+@AllArgsConstructor
+public class HpDocInfoController extends ApiController {
+    /**
+     * 服务对象
+     */
+    private final HpDocInfoService hpDocInfoService;
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/controller/web/HpHosInfoController.java

+package cn.sh.stc.sict.theme.hphy.controller.web;
+
+
+import cn.sh.stc.sict.theme.hphy.service.HpHosInfoService;
+import com.baomidou.mybatisplus.extension.api.ApiController;
+import io.swagger.annotations.Api;
+import lombok.AllArgsConstructor;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * (HpHosInfo)维护接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:36:00
+ */
+@Api(value = "维护接口", tags = "维护接口")
+@RestController
+@RequestMapping("hpHosInfo")
+@AllArgsConstructor
+public class HpHosInfoController extends ApiController {
+    /**
+     * 服务对象
+     */
+    private final HpHosInfoService hpHosInfoService;
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/dao/HpAppointmentMapper.java

+package cn.sh.stc.sict.theme.hphy.dao;
+
+import cn.sh.stc.sict.theme.hphy.model.HpAppointment;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * [黄浦]预约记录(HpAppointment)表数据库访问层
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:56
+ */
+public interface HpAppointmentMapper extends BaseMapper<HpAppointment> {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/dao/HpDeptInfoMapper.java

+package cn.sh.stc.sict.theme.hphy.dao;
+
+import cn.sh.stc.sict.theme.hphy.model.HpDeptInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * (HpDeptInfo)表数据库访问层
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+public interface HpDeptInfoMapper extends BaseMapper<HpDeptInfo> {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/dao/HpDocInfoMapper.java

+package cn.sh.stc.sict.theme.hphy.dao;
+
+import cn.sh.stc.sict.theme.hphy.model.HpDocInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * (HpDocInfo)表数据库访问层
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+public interface HpDocInfoMapper extends BaseMapper<HpDocInfo> {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/dao/HpHosInfoMapper.java

+package cn.sh.stc.sict.theme.hphy.dao;
+
+import cn.sh.stc.sict.theme.hphy.model.HpHosInfo;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+
+/**
+ * (HpHosInfo)表数据库访问层
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+public interface HpHosInfoMapper extends BaseMapper<HpHosInfo> {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/model/HpAppointment.java

+package cn.sh.stc.sict.theme.hphy.model;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * [黄浦]预约记录(HpAppointment)表实体类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:38:37
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class HpAppointment extends Model<HpAppointment> {
+    //id
+    @TableId
+    @ApiModelProperty(hidden = false, value = "id")
+    private Long id;
+    //医院代码    
+    @ApiModelProperty(hidden = false, value = "医院代码")
+    private String hosOrgCode;
+    //一级科室代码    
+    @ApiModelProperty(hidden = false, value = "一级科室代码")
+    private String oneDeptCode;
+    //二级科室代码    
+    @ApiModelProperty(hidden = false, value = "二级科室代码")
+    private String deptCode;
+    //预约类型：1-医生 2-门诊    
+    @ApiModelProperty(hidden = false, value = "预约类型：1-医生 2-门诊")
+    private String orderType;
+    //医生|门诊代码    
+    @ApiModelProperty(hidden = false, value = "医生|门诊代码")
+    private String resourceCode;
+    //预约渠道方式：1-官网 2-微信 3-app 4-支付宝 5-电话 6-转诊预约 7-(1+1+1)转诊预约 8-现场预约 0-其他    
+    @ApiModelProperty(hidden = false, value = "预约渠道方式：1-官网 2-微信 3-app 4-支付宝 5-电话 6-转诊预约 7-(1+1+1)转诊预约 8-现场预约 0-其他")
+    private String channelCode;
+    //排班id    
+    @ApiModelProperty(hidden = false, value = "排班id")
+    private String scheduleId;
+    //号源id    
+    @ApiModelProperty(hidden = false, value = "号源id")
+    private String numSourceId;
+    //支付方式    
+    @ApiModelProperty(hidden = false, value = "支付方式")
+    private String payMode;
+    //预约患者类型    
+    @ApiModelProperty(hidden = false, value = "预约患者类型")
+    private String patientType;
+    //1+1+1 签约编号    
+    @ApiModelProperty(hidden = false, value = "1+1+1 签约编号")
+    private String patientId;
+    //就诊人卡号    
+    @ApiModelProperty(hidden = false, value = "就诊人卡号")
+    private String mediCardId;
+    //就诊人卡类型    
+    @ApiModelProperty(hidden = false, value = "就诊人卡类型")
+    private String mediCardType;
+    //就诊人证件类型    
+    @ApiModelProperty(hidden = false, value = "就诊人证件类型")
+    private String userCardType;
+    //就诊人证件号码    
+    @ApiModelProperty(hidden = false, value = "就诊人证件号码")
+    private String userCardId;
+    //就诊人姓名    
+    @ApiModelProperty(hidden = false, value = "就诊人姓名")
+    private String userName;
+    //手机号码    
+    @ApiModelProperty(hidden = false, value = "手机号码")
+    private String userPhone;
+    //就诊人性别    
+    @ApiModelProperty(hidden = false, value = "就诊人性别")
+    private String userSex;
+    //就诊人出生日期    
+    @ApiModelProperty(hidden = false, value = "就诊人出生日期")
+    private String userBd;
+    //就诊人联系地址    
+    @ApiModelProperty(hidden = false, value = "就诊人联系地址")
+    private String userContAdd;
+    //预约人证件类型    
+    @ApiModelProperty(hidden = false, value = "预约人证件类型")
+    private String replaceUserCardType;
+    //预约人证件号码    
+    @ApiModelProperty(hidden = false, value = "预约人证件号码")
+    private String replaceUserCardId;
+    //预约人姓名    
+    @ApiModelProperty(hidden = false, value = "预约人姓名")
+    private String replaceUserName;
+    //ip地址    
+    @ApiModelProperty(hidden = false, value = "ip地址")
+    private String ipAddr;
+    //mac地址    
+    @ApiModelProperty(hidden = false, value = "mac地址")
+    private String macAddr;
+    //预约转诊转出机构代码(1+1+1预约转诊专用)    
+    @ApiModelProperty(hidden = false, value = "预约转诊转出机构代码(1+1+1预约转诊专用)")
+    private String outHospitalCode;
+    //预约转诊转出机构本地转诊id    
+    @ApiModelProperty(hidden = false, value = "预约转诊转出机构本地转诊id")
+    private String outOrderId;
+    //号源日期    
+    @ApiModelProperty(hidden = false, value = "号源日期")
+    private String numSourceDate;
+    //就诊_开始时段    
+    @ApiModelProperty(hidden = false, value = "就诊_开始时段")
+    private String startTime;
+    //就诊_结束时段    
+    @ApiModelProperty(hidden = false, value = "就诊_结束时段")
+    private String endTime;
+    //预约平台类型    
+    @ApiModelProperty(hidden = false, value = "预约平台类型")
+    private String platformType;
+    //预约平台菜吗    
+    @ApiModelProperty(hidden = false, value = "预约平台菜吗")
+    private String platformCode;
+    //预约渠道描述    
+    @ApiModelProperty(hidden = false, value = "预约渠道描述")
+    private String channelName;
+    //号源来源    
+    @ApiModelProperty(hidden = false, value = "号源来源")
+    private String numSourceFrom;
+
+
+    /**
+     * 获取主键值
+     *
+     * @return 主键值
+     */
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/model/HpDeptInfo.java

+package cn.sh.stc.sict.theme.hphy.model;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * (HpDeptInfo)表实体类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:57
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class HpDeptInfo extends Model<HpDeptInfo> {
+    @TableId
+    @ApiModelProperty(hidden = false, value = "id")
+    private Long id;
+    @ApiModelProperty(hidden = false, value = "医院代码")
+    private String hosOrgCode;
+    @ApiModelProperty(hidden = false, value = "一级科室代码")
+    private String oneDeptCode;
+    @ApiModelProperty(hidden = false, value = "二级科室代码")
+    private String deptCode;
+    @ApiModelProperty(hidden = false, value = "医院名称")
+    private String hosName;
+    @ApiModelProperty(hidden = false, value = "一级科室名称")
+    private String oneDeptName;
+    @ApiModelProperty(hidden = false, value = "二级科室名称")
+    private String deptName;
+    @ApiModelProperty(hidden = false, value = "标准二级科室代码")
+    private String normdeptCode;
+    @ApiModelProperty(hidden = false, value = "标准二级科室名称")
+    private String normdeptName;
+    @ApiModelProperty(hidden = false, value = "科室简介")
+    private String deptDesc;
+    @ApiModelProperty(hidden = false, value = "科室级别：1-一级，2-二级")
+    private Byte deptLevel;
+    @ApiModelProperty(hidden = false, value = "显示次序")
+    private String indexNo;
+
+
+    /**
+     * 获取主键值
+     *
+     * @return 主键值
+     */
+    @Override
+    protected Serializable pkVal() {
+        return this.id;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/model/HpDocInfo.java

+package cn.sh.stc.sict.theme.hphy.model;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * (HpDocInfo)表实体类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class HpDocInfo extends Model<HpDocInfo> {
+    @TableId
+    @ApiModelProperty(hidden = false, value = "医生资源代码")
+    private String resourceCode;
+    @ApiModelProperty(hidden = false, value = "医院代码")
+    private String hosOrgCode;
+    @ApiModelProperty(hidden = false, value = "一级科室代码")
+    private String oneDeptCode;
+    @ApiModelProperty(hidden = false, value = "二级科室代码")
+    private String deptCode;
+    @ApiModelProperty(hidden = false, value = "医院名称")
+    private String hosName;
+    @ApiModelProperty(hidden = false, value = "一级科室名称")
+    private String oneDeptName;
+    @ApiModelProperty(hidden = false, value = "二级科室名称")
+    private String deptName;
+    @ApiModelProperty(hidden = false, value = "医生资源姓名")
+    private String resourceName;
+    @ApiModelProperty(hidden = false, value = "医生职称")
+    private String doctTile;
+    @ApiModelProperty(hidden = false, value = "证件类型")
+    private String personType;
+    @ApiModelProperty(hidden = false, value = "证件号")
+    private String personId;
+    @ApiModelProperty(hidden = false, value = "医生头像")
+    private String doctImg;
+    @ApiModelProperty(hidden = false, value = "医生性别")
+    private String doctSex;
+    @ApiModelProperty(hidden = false, value = "医生简介")
+    private String doctInfo;
+    @ApiModelProperty(hidden = false, value = "医生特长")
+    private String doctSpecialty;
+    @ApiModelProperty(hidden = false, value = "展示次序")
+    private String indexNo;
+
+
+    /**
+     * 获取主键值
+     *
+     * @return 主键值
+     */
+    @Override
+    protected Serializable pkVal() {
+        return this.resourceCode;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/model/HpHosInfo.java

+package cn.sh.stc.sict.theme.hphy.model;
+
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.extension.activerecord.Model;
+import io.swagger.annotations.ApiModelProperty;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+
+import java.io.Serializable;
+
+/**
+ * (HpHosInfo)表实体类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class HpHosInfo extends Model<HpHosInfo> {
+    @TableId
+    @ApiModelProperty(hidden = false, value = "医院代码")
+    private String hosOrgCode;
+    @ApiModelProperty(hidden = false, value = "卫生机构(组织)代码")
+    private String orgCode;
+    @ApiModelProperty(hidden = false, value = "医院名称")
+    private String hosName;
+    @ApiModelProperty(hidden = false, value = "医院地址")
+    private String hospitalAdd;
+    @ApiModelProperty(hidden = false, value = "预约挂号须知")
+    private String hospitalRule;
+    @ApiModelProperty(hidden = false, value = "医院网址")
+    private String hospitalWeb;
+    @ApiModelProperty(hidden = false, value = "交通指南")
+    private String trafficGuide;
+    @ApiModelProperty(hidden = false, value = "医院简介")
+    private String hospitalDesc;
+    @ApiModelProperty(hidden = false, value = "联系电话")
+    private String hospitalTel;
+    @ApiModelProperty(hidden = false, value = "医院级别")
+    private String hospitalGrade;
+    @ApiModelProperty(hidden = false, value = "医院等级")
+    private String hospitalLevel;
+    @ApiModelProperty(hidden = false, value = "医院类别")
+    private String hospitalType;
+    @ApiModelProperty(hidden = false, value = "支付方式")
+    private String payMode;
+    @ApiModelProperty(hidden = false, value = "预约方式")
+    private String orderMode;
+    @ApiModelProperty(hidden = false, value = "是否支持分时段")
+    private String isSpTime;
+    @ApiModelProperty(hidden = false, value = "医院简称")
+    private String shortName;
+    @ApiModelProperty(hidden = false, value = "医院属性")
+    private String orgSort;
+    @ApiModelProperty(hidden = false, value = "所属区代码")
+    private String hospitalArea;
+    @ApiModelProperty(hidden = false, value = "医院图片")
+    private String hospitalImage;
+
+
+    /**
+     * 获取主键值
+     *
+     * @return 主键值
+     */
+    @Override
+    protected Serializable pkVal() {
+        return this.hosOrgCode;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/schedule/RefreshJob.java

 package cn.sh.stc.sict.theme.hphy.schedule;
 
+import cn.hutool.core.collection.CollectionUtil;
+import cn.sh.stc.sict.theme.hphy.model.HpDeptInfo;
+import cn.sh.stc.sict.theme.hphy.model.HpDocInfo;
+import cn.sh.stc.sict.theme.hphy.model.HpHosInfo;
+import cn.sh.stc.sict.theme.hphy.service.HpDeptInfoService;
+import cn.sh.stc.sict.theme.hphy.service.HpDocInfoService;
+import cn.sh.stc.sict.theme.hphy.service.HpHosInfoService;
+import cn.sh.stc.sict.theme.hphy.wd.DeptInfo;
+import cn.sh.stc.sict.theme.hphy.wd.DoctInfo;
 import cn.sh.stc.sict.theme.hphy.wd.HosInfo;
 import cn.sh.stc.sict.theme.hphy.wd.WanDaHttpUtil;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import ma.glasnost.orika.MapperFactory;
+import ma.glasnost.orika.impl.DefaultMapperFactory;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
+import java.util.ArrayList;
 import java.util.List;
 
 /**
@@ -14,27 +28,142 @@ import java.util.List;
  * 3. 每周更新医生信息
  * 4. 每天更新可预约信息
  */
+@Slf4j
 @Component
+@AllArgsConstructor
 public class RefreshJob {
 
+    private final HpHosInfoService hpHosInfoService;
+    private final HpDeptInfoService deptInfoService;
+    private final HpDocInfoService docInfoService;
+
+    private static final byte TOP_DEPT = 1;
+    private static final byte TWO_DEPT = 2;
+
+    @Scheduled(cron = "0 44 13 * * ?")
+    public void updateHosp(){
+        HosInfo hosInfo = new HosInfo();
+        List<HosInfo> list = WanDaHttpUtil.getHospitalInfo(hosInfo);
+
+        if (CollectionUtil.isEmpty(list)){
+            return;
+        }
+
+        MapperFactory factory = new DefaultMapperFactory.Builder().build();
+        List<HpHosInfo> hpHosInfos = factory.getMapperFacade().mapAsList(list, HpHosInfo.class);
+
+        for (HpHosInfo hpHosInfo : hpHosInfos) {
+            saveOrUpdateHospital(hpHosInfo);
+        }
+    }
+
+    private void saveOrUpdateHospital(HpHosInfo hpHosInfo){
+        try {
+            if (hpHosInfoService.hospitalExist(hpHosInfo.getHosOrgCode())){
+                hpHosInfoService.updateById(hpHosInfo);
+            }else {
+                hpHosInfoService.save(hpHosInfo);
+            }
+        }catch (Exception e){
+            log.error("医院保存出错：{}", hpHosInfo);
+            log.error(e.getMessage(), e);
+        }
+    }
+
 //    @Scheduled(cron = "")
-//    public void updateHosp(){
-//        HosInfo hosInfo = new HosInfo();
-//        List<HosInfo> list = WanDaHttpUtil.getHospitalInfo(hosInfo);
-//    }
-//
-//    @Scheduled(cron = "")
-//    public void updateDeptTop(){
-//
-//    }
-//
-//    @Scheduled(cron = "")
-//    public void updateDeptTwo(){
-//
-//    }
-//
+    public void updateDept(){
+        List<HpHosInfo> hospitals = hpHosInfoService.list();
+        if (CollectionUtil.isEmpty(hospitals)){
+            return;
+        }
+
+        // TODO 获取一级科室
+        MapperFactory factory = new DefaultMapperFactory.Builder().build();
+        for (HpHosInfo hospital : hospitals) {
+            saveOrUpdateTopDept(hospital.getHosOrgCode(), factory);
+        }
+
+        // TODO 获取二级科室
+
+    }
+
+    private void saveOrUpdateTopDept(String hosOrgCode, MapperFactory factory){
+        List<DeptInfo> deptInfos = WanDaHttpUtil.getDeptInfoTop(new HosInfo(hosOrgCode));
+        if (CollectionUtil.isEmpty(deptInfos)){
+            return;
+        }
+
+        List<HpDeptInfo> hpDeptInfos = cloneTopDept(deptInfos);
+
+
+    }
+
+
+
 //    @Scheduled(cron = "")
-//    public void updateDocInfo(){
-//
-//    }
+    public void updateDeptTwo(){
+
+    }
+
+    @Scheduled(cron = "0 42 14 * * ?")
+    public void updateDocInfo(){
+        List<HpHosInfo> list = hpHosInfoService.list();
+
+        if (CollectionUtil.isEmpty(list)){
+            return;
+        }
+
+        MapperFactory factory = new DefaultMapperFactory.Builder().build();
+        for (HpHosInfo hpHosInfo : list) {
+            saveOrUpdateDoctor(hpHosInfo.getHosOrgCode(), factory);
+        }
+
+    }
+
+    private void saveOrUpdateDoctor(String hosOrgCode, MapperFactory factory){
+        List<DoctInfo> doctInfos = WanDaHttpUtil.getDoctInfo(new DeptInfo(hosOrgCode));
+
+        if (CollectionUtil.isEmpty(doctInfos)){
+            return;
+        }
+
+        List<HpDocInfo> docInfos = factory.getMapperFacade().mapAsList(doctInfos, HpDocInfo.class);
+
+        for (HpDocInfo docInfo : docInfos) {
+            saveOrUpdateDoctor(docInfo);
+        }
+    }
+
+    private void saveOrUpdateDoctor(HpDocInfo docInfo){
+        try {
+            if (docInfoService.doctorExist(docInfo.getResourceCode())){
+                docInfoService.updateById(docInfo);
+            }else {
+                docInfoService.save(docInfo);
+            }
+        }catch (Exception e){
+            log.error("医生信息保存出错：{}", docInfo);
+        }
+    }
+
+    private List<HpDeptInfo> cloneTopDept(List<DeptInfo> deptInfos){
+        List<HpDeptInfo> hpDeptInfos = new ArrayList<>();
+        for (DeptInfo deptInfo : deptInfos) {
+            HpDeptInfo hpDeptInfo = new HpDeptInfo();
+            hpDeptInfo.setHosOrgCode(deptInfo.getHosOrgCode());
+            hpDeptInfo.setOneDeptCode(deptInfo.getDeptCode());
+            hpDeptInfo.setHosName(deptInfo.getHosName());
+            hpDeptInfo.setOneDeptName(deptInfo.getDeptName());
+            hpDeptInfo.setNormdeptCode(deptInfo.getNormdeptCode());
+            hpDeptInfo.setNormdeptName(deptInfo.getNormdeptName());
+            hpDeptInfo.setDeptDesc(deptInfo.getDeptDesc());
+            hpDeptInfo.setDeptLevel(TOP_DEPT);
+            hpDeptInfo.setIndexNo(deptInfo.getIndexNo());
+
+            hpDeptInfos.add(hpDeptInfo);
+        }
+
+        return hpDeptInfos;
+    }
+
 }

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/HpAppointmentService.java

+package cn.sh.stc.sict.theme.hphy.service;
+
+import cn.sh.stc.sict.theme.hphy.model.HpAppointment;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * [黄浦]预约记录(HpAppointment)表服务接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:56
+ */
+public interface HpAppointmentService extends IService<HpAppointment> {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/HpDeptInfoService.java

+package cn.sh.stc.sict.theme.hphy.service;
+
+import cn.sh.stc.sict.theme.hphy.model.HpDeptInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * (HpDeptInfo)表服务接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+public interface HpDeptInfoService extends IService<HpDeptInfo> {
+
+
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/HpDocInfoService.java

+package cn.sh.stc.sict.theme.hphy.service;
+
+import cn.sh.stc.sict.theme.hphy.model.HpDocInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * (HpDocInfo)表服务接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+public interface HpDocInfoService extends IService<HpDocInfo> {
+
+    /**
+     * 根据医生的资源id判断医生是否存在
+     * @param resourceCode
+     * @return true-存在；false-不存在
+     */
+    boolean doctorExist(String resourceCode);
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/HpHosInfoService.java

+package cn.sh.stc.sict.theme.hphy.service;
+
+import cn.sh.stc.sict.theme.hphy.model.HpHosInfo;
+import com.baomidou.mybatisplus.extension.service.IService;
+
+/**
+ * (HpHosInfo)表服务接口
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+public interface HpHosInfoService extends IService<HpHosInfo> {
+    /**
+     * 根据机构代码查询医院是否存在
+     * @param hosOrgCode
+     * @return true-存在；false-不存在
+     */
+    boolean hospitalExist(String hosOrgCode);
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/impl/HpAppointmentServiceImpl.java

+package cn.sh.stc.sict.theme.hphy.service.impl;
+
+import cn.sh.stc.sict.theme.hphy.dao.HpAppointmentMapper;
+import cn.sh.stc.sict.theme.hphy.model.HpAppointment;
+import cn.sh.stc.sict.theme.hphy.service.HpAppointmentService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * [黄浦]预约记录(HpAppointment)表服务实现类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:56
+ */
+@Service("hpAppointmentService")
+public class HpAppointmentServiceImpl extends ServiceImpl<HpAppointmentMapper, HpAppointment> implements HpAppointmentService {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/impl/HpDeptInfoServiceImpl.java

+package cn.sh.stc.sict.theme.hphy.service.impl;
+
+import cn.sh.stc.sict.theme.hphy.dao.HpDeptInfoMapper;
+import cn.sh.stc.sict.theme.hphy.model.HpDeptInfo;
+import cn.sh.stc.sict.theme.hphy.service.HpDeptInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * (HpDeptInfo)表服务实现类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:58
+ */
+@Service("hpDeptInfoService")
+public class HpDeptInfoServiceImpl extends ServiceImpl<HpDeptInfoMapper, HpDeptInfo> implements HpDeptInfoService {
+
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/impl/HpDocInfoServiceImpl.java

+package cn.sh.stc.sict.theme.hphy.service.impl;
+
+import cn.sh.stc.sict.theme.hphy.dao.HpDocInfoMapper;
+import cn.sh.stc.sict.theme.hphy.model.HpDocInfo;
+import cn.sh.stc.sict.theme.hphy.service.HpDocInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * (HpDocInfo)表服务实现类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:35:59
+ */
+@Service("hpDocInfoService")
+public class HpDocInfoServiceImpl extends ServiceImpl<HpDocInfoMapper, HpDocInfo> implements HpDocInfoService {
+
+    @Override
+    public boolean doctorExist(String resourceCode) {
+        return this.getById(resourceCode) != null;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/service/impl/HpHosInfoServiceImpl.java

+package cn.sh.stc.sict.theme.hphy.service.impl;
+
+import cn.sh.stc.sict.theme.hphy.dao.HpHosInfoMapper;
+import cn.sh.stc.sict.theme.hphy.model.HpHosInfo;
+import cn.sh.stc.sict.theme.hphy.service.HpHosInfoService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.stereotype.Service;
+
+/**
+ * (HpHosInfo)表服务实现类
+ *
+ * @author makejava
+ * @since 2021-01-28 10:36:00
+ */
+@Service("hpHosInfoService")
+public class HpHosInfoServiceImpl extends ServiceImpl<HpHosInfoMapper, HpHosInfo> implements HpHosInfoService {
+
+    @Override
+    public boolean hospitalExist(String hosOrgCode) {
+        return this.getById(hosOrgCode) != null;
+    }
+}
\ No newline at end of file

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/wd/DeptInfo.java

 package cn.sh.stc.sict.theme.hphy.wd;
 
+import cn.hutool.core.util.StrUtil;
 import com.thoughtworks.xstream.annotations.XStreamAlias;
 import lombok.Data;
 
@@ -16,4 +17,9 @@ public class DeptInfo {
     public String indexNo;
     public String oneDeptCode;
     public String oneDeptName;
+
+    public DeptInfo(String hosOrgCode){
+        this.hosOrgCode = hosOrgCode;
+    }
+    public DeptInfo(){}
 }

smart-health-modules/theme-schema/src/main/java/cn/sh/stc/sict/theme/hphy/wd/HosInfo.java

@@ -28,4 +28,9 @@ public class HosInfo {
     public String orgSort;
     public String hospitalArea;
     public String hospitalImage;
+
+    public HosInfo(){}
+    public HosInfo(String hosOrgCode){
+        this.hosOrgCode = hosOrgCode;
+    }
 }

smart-health-modules/theme-schema/src/main/resources/mapper/HpAppointmentMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.sh.stc.sict.theme.hphy.dao.HpAppointmentMapper">
+
+    <resultMap type="cn.sh.stc.sict.theme.hphy.model.HpAppointment" id="HpAppointmentMap">
+        <result property="id" column="id" jdbcType="INTEGER"/>
+        <result property="hosOrgCode" column="hos_org_code" jdbcType="VARCHAR"/>
+        <result property="oneDeptCode" column="one_dept_code" jdbcType="VARCHAR"/>
+        <result property="deptCode" column="dept_code" jdbcType="VARCHAR"/>
+        <result property="orderType" column="order_type" jdbcType="VARCHAR"/>
+        <result property="resourceCode" column="resource_code" jdbcType="VARCHAR"/>
+        <result property="channelCode" column="channel_code" jdbcType="VARCHAR"/>
+        <result property="scheduleId" column="schedule_id" jdbcType="VARCHAR"/>
+        <result property="numSourceId" column="num_source_id" jdbcType="VARCHAR"/>
+        <result property="payMode" column="pay_mode" jdbcType="VARCHAR"/>
+        <result property="patientType" column="patient_type" jdbcType="VARCHAR"/>
+        <result property="patientId" column="patient_id" jdbcType="VARCHAR"/>
+        <result property="mediCardId" column="medi_card_id" jdbcType="VARCHAR"/>
+        <result property="mediCardType" column="medi_card_type" jdbcType="VARCHAR"/>
+        <result property="userCardType" column="user_card_type" jdbcType="VARCHAR"/>
+        <result property="userCardId" column="user_card_id" jdbcType="VARCHAR"/>
+        <result property="userName" column="user_name" jdbcType="VARCHAR"/>
+        <result property="userPhone" column="user_phone" jdbcType="VARCHAR"/>
+        <result property="userSex" column="user_sex" jdbcType="VARCHAR"/>
+        <result property="userBd" column="user_BD" jdbcType="VARCHAR"/>
+        <result property="userContAdd" column="user_cont_add" jdbcType="VARCHAR"/>
+        <result property="replaceUserCardType" column="replace_user_card_type" jdbcType="VARCHAR"/>
+        <result property="replaceUserCardId" column="replace_user_card_id" jdbcType="VARCHAR"/>
+        <result property="replaceUserName" column="replace_user_name" jdbcType="VARCHAR"/>
+        <result property="ipAddr" column="ip_addr" jdbcType="VARCHAR"/>
+        <result property="macAddr" column="mac_addr" jdbcType="VARCHAR"/>
+        <result property="outHospitalCode" column="out_hospital_code" jdbcType="VARCHAR"/>
+        <result property="outOrderId" column="out_order_id" jdbcType="VARCHAR"/>
+        <result property="numSourceDate" column="num_source_date" jdbcType="VARCHAR"/>
+        <result property="startTime" column="start_time" jdbcType="VARCHAR"/>
+        <result property="endTime" column="end_time" jdbcType="VARCHAR"/>
+        <result property="platformType" column="platform_type" jdbcType="VARCHAR"/>
+        <result property="platformCode" column="platform_code" jdbcType="VARCHAR"/>
+        <result property="channelName" column="channel_name" jdbcType="VARCHAR"/>
+        <result property="numSourceFrom" column="num_source_from" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id, hos_org_code, one_dept_code, dept_code, order_type, resource_code, channel_code, schedule_id, num_source_id, pay_mode, patient_type, patient_id, medi_card_id, medi_card_type, user_card_type, user_card_id, user_name, user_phone, user_sex, user_BD, user_cont_add, replace_user_card_type, replace_user_card_id, replace_user_name, ip_addr, mac_addr, out_hospital_code, out_order_id, num_source_date, start_time, end_time, platform_type, platform_code, channel_name, num_source_from     </sql>
+</mapper>
\ No newline at end of file

smart-health-modules/theme-schema/src/main/resources/mapper/HpDeptInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.sh.stc.sict.theme.hphy.dao.HpDeptInfoMapper">
+
+    <resultMap type="cn.sh.stc.sict.theme.hphy.model.HpDeptInfo" id="HpDeptInfoMap">
+        <result property="id" column="id" jdbcType="INTEGER"/>
+        <result property="hosOrgCode" column="hos_org_code" jdbcType="VARCHAR"/>
+        <result property="oneDeptCode" column="one_dept_code" jdbcType="VARCHAR"/>
+        <result property="deptCode" column="dept_code" jdbcType="VARCHAR"/>
+        <result property="hosName" column="hos_name" jdbcType="VARCHAR"/>
+        <result property="oneDeptName" column="one_dept_name" jdbcType="VARCHAR"/>
+        <result property="deptName" column="dept_name" jdbcType="VARCHAR"/>
+        <result property="normdeptCode" column="normdept_code" jdbcType="VARCHAR"/>
+        <result property="normdeptName" column="normdept_name" jdbcType="VARCHAR"/>
+        <result property="deptDesc" column="dept_desc" jdbcType="VARCHAR"/>
+        <result property="indexNo" column="index_no" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id, hos_org_code, one_dept_code, dept_code, hos_name, one_dept_name, dept_name, normdept_code, normdept_name, dept_desc, index_no     </sql>
+</mapper>
\ No newline at end of file

smart-health-modules/theme-schema/src/main/resources/mapper/HpDocInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.sh.stc.sict.theme.hphy.dao.HpDocInfoMapper">
+
+    <resultMap type="cn.sh.stc.sict.theme.hphy.model.HpDocInfo" id="HpDocInfoMap">
+        <result property="resourceCode" column="resource_code" jdbcType="VARCHAR"/>
+        <result property="hosOrgCode" column="hos_org_code" jdbcType="VARCHAR"/>
+        <result property="oneDeptCode" column="one_dept_code" jdbcType="VARCHAR"/>
+        <result property="deptCode" column="dept_code" jdbcType="VARCHAR"/>
+        <result property="hosName" column="hos_name" jdbcType="VARCHAR"/>
+        <result property="oneDeptName" column="one_dept_name" jdbcType="VARCHAR"/>
+        <result property="deptName" column="dept_name" jdbcType="VARCHAR"/>
+        <result property="resourceName" column="resource_name" jdbcType="VARCHAR"/>
+        <result property="doctTile" column="doct_tile" jdbcType="VARCHAR"/>
+        <result property="personType" column="person_type" jdbcType="VARCHAR"/>
+        <result property="personId" column="person_id" jdbcType="VARCHAR"/>
+        <result property="doctImg" column="doct_img" jdbcType="VARCHAR"/>
+        <result property="doctSex" column="doct_sex" jdbcType="VARCHAR"/>
+        <result property="doctInfo" column="doct_info" jdbcType="VARCHAR"/>
+        <result property="doctSpecialty" column="doct_specialty" jdbcType="VARCHAR"/>
+        <result property="indexNo" column="index_no" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        resource_code, hos_org_code, one_dept_code, dept_code, hos_name, one_dept_name, dept_name, resource_name, doct_tile, person_type, person_id, doct_img, doct_sex, doct_info, doct_specialty, index_no     </sql>
+</mapper>
\ No newline at end of file

smart-health-modules/theme-schema/src/main/resources/mapper/HpHosInfoMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.sh.stc.sict.theme.hphy.dao.HpHosInfoMapper">
+
+    <resultMap type="cn.sh.stc.sict.theme.hphy.model.HpHosInfo" id="HpHosInfoMap">
+        <result property="hosOrgCode" column="hos_org_code" jdbcType="VARCHAR"/>
+        <result property="orgCode" column="org_code" jdbcType="VARCHAR"/>
+        <result property="hosName" column="hos_name" jdbcType="VARCHAR"/>
+        <result property="hospitalAdd" column="hospital_add" jdbcType="VARCHAR"/>
+        <result property="hospitalRule" column="hospital_rule" jdbcType="VARCHAR"/>
+        <result property="hospitalWeb" column="hospital_web" jdbcType="VARCHAR"/>
+        <result property="trafficGuide" column="traffic_guide" jdbcType="VARCHAR"/>
+        <result property="hospitalDesc" column="hospital_desc" jdbcType="VARCHAR"/>
+        <result property="hospitalTel" column="hospital_tel" jdbcType="VARCHAR"/>
+        <result property="hospitalGrade" column="hospital_grade" jdbcType="VARCHAR"/>
+        <result property="hospitalLevel" column="hospital_level" jdbcType="VARCHAR"/>
+        <result property="hospitalType" column="hospital_type" jdbcType="VARCHAR"/>
+        <result property="payMode" column="pay_mode" jdbcType="VARCHAR"/>
+        <result property="orderMode" column="order_mode" jdbcType="VARCHAR"/>
+        <result property="isSpTime" column="is_sp_time" jdbcType="OTHER"/>
+        <result property="shortName" column="short_name" jdbcType="VARCHAR"/>
+        <result property="orgSort" column="org_sort" jdbcType="VARCHAR"/>
+        <result property="hospitalArea" column="hospital_area" jdbcType="VARCHAR"/>
+        <result property="hospitalImage" column="hospital_image" jdbcType="VARCHAR"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        hos_org_code, org_code, hos_name, hospital_add, hospital_rule, hospital_web, traffic_guide, hospital_desc, hospital_tel, hospital_grade, hospital_level, hospital_type, pay_mode, order_mode, is_sp_time, short_name, org_sort, hospital_area, hospital_image     </sql>
+</mapper>
\ No newline at end of file