Merge branch 'dev' of zd_123/patient-co-management into dev

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/NewArticleBehaviorModel.java

@@ -0,0 +1,92 @@
package com.yihu.edu.entity.dataClean;
import javax.persistence.*;
import java.util.Date;
/**
 * Created by Administrator on 2017/12/25.
 */
@Entity
@Table(name = "user_behavior_copy")
public class NewArticleBehaviorModel {
    private int ID;
    private String articleId;
    private int behaviorAction;
    private String userId;
    private String cName;
    private Date insertTime;
    private String title;
    private int isOld;
    @Id
    @GeneratedValue(strategy=GenerationType.IDENTITY)
    public int getID() {
        return ID;
    }
    public void setID(int ID) {
        this.ID = ID;
    }
    @Column(name = "ArticleId")
    public String getArticleId() {
        return articleId;
    }
    public void setArticleId(String articleId) {
        this.articleId = articleId;
    }
    @Column(name = "BehaviorAction")
    public int getBehaviorAction() {
        return behaviorAction;
    }
    public void setBehaviorAction(int behaviorAction) {
        this.behaviorAction = behaviorAction;
    }
    @Column(name = "UserId")
    public String getUserId() {
        return userId;
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }
    @Column(name = "CName")
    public String getcName() {
        return cName;
    }
    public void setcName(String cName) {
        this.cName = cName;
    }
    @Column(name = "InsertTime")
    public Date getInsertTime() {
        return insertTime;
    }
    public void setInsertTime(Date insertTime) {
        this.insertTime = insertTime;
    }
    public String getTitle() {
        return title;
    }
    public void setTitle(String title) {
        this.title = title;
    }
    public int getIsOld() {
        return isOld;
    }
    public void setIsOld(int isOld) {
        this.isOld = isOld;
    }
}

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/NewArticleCollectModel.java

@@ -0,0 +1,169 @@
package com.yihu.edu.entity.dataClean;
import org.hibernate.annotations.GenericGenerator;
import javax.persistence.*;
import java.util.Date;
/**
 * Created by Administrator on 2017/9/29.
 */
@Entity
@Table(name = "user_articlecollection_copy")
public class NewArticleCollectModel {
    private  int ID;
    private String articleId;
    private int userType;
    private Date insertTime;
    private String userId;
    private String cName;
    private String orgName;
    private String orgId;
    private String articleCategoryId;
    private String articleCategoryName;
    private String url;
    private String title;
    private String content;
    private int isOld;
    @Id
    @GeneratedValue(strategy=GenerationType.IDENTITY)
    public int getID() {
        return ID;
    }
    public void setID(int ID) {
        this.ID = ID;
    }
    @Column(name = "ArticleId")
    public String getArticleId() {
        return articleId;
    }
    public void setArticleId(String articleId) {
        this.articleId = articleId;
    }
    @Column(name = "UserType")
    public int getUserType() {
        return userType;
    }
    public void setUserType(int userType) {
        this.userType = userType;
    }
    @Column(name = "InsertTime")
    public Date getInsertTime() {
        return insertTime;
    }
    public void setInsertTime(Date insertTime) {
        this.insertTime = insertTime;
    }
    @Column(name = "UserId")
    public String getUserId() {
        return userId;
    }
    public void setUserId(String userId) {
        this.userId = userId;
    }
    @Column(name = "CName")
    public String getcName() {
        return cName;
    }
    public void setcName(String cName) {
        this.cName = cName;
    }
    @Column(name = "OrgName")
    public String getOrgName() {
        return orgName;
    }
    public void setOrgName(String orgName) {
        this.orgName = orgName;
    }
    @Column(name = "OrgId")
    public String getOrgId() {
        return orgId;
    }
    public void setOrgId(String orgId) {
        this.orgId = orgId;
    }
    @Column(name = "ArticleCategoryId")
    public String getArticleCategoryId() {
        return articleCategoryId;
    }
    public void setArticleCategoryId(String articleCategoryId) {
        this.articleCategoryId = articleCategoryId;
    }
    @Column(name = "ArticleCategoryName")
    public String getArticleCategoryName() {
        return articleCategoryName;
    }
    public void setArticleCategoryName(String articleCategoryName) {
        this.articleCategoryName = articleCategoryName;
    }
    public String getUrl() {
        return url;
    }
    public void setUrl(String url) {
        this.url = url;
    }
    public String getTitle() {
        return title;
    }
    public void setTitle(String title) {
        this.title = title;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
    public int getIsOld() {
        return isOld;
    }
    public void setIsOld(int isOld) {
        this.isOld = isOld;
    }
}

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/NewArticleModel.java

@@ -0,0 +1,434 @@
package com.yihu.edu.entity.dataClean;
import com.yihu.wlyy.entity.IdEntity;
import org.hibernate.annotations.GenericGenerator;
import javax.persistence.*;
import java.util.Date;
/**
 * Created by zhangdan on 2017/9/29.
 */
@Entity
@Table(name = "org_article_copy")
public class NewArticleModel {
    //文章ID
    private String articleId;
    //文章标题
    private String articleTitle;
    //简介
    private String summary;
    //文章内容
    private String articleContent;
    //排序
    private int articleOrder;
    //1、正常、2删除
    private int articleState;
    //文章所属单位名称
    private String orgName;
    //文章来源（填写发布人所在的机构）
    private String articleSource;
    //文章所属单位ID
    private String orgId;
    //1、重要、2紧急
    private int articlelevel;
    //封面图
    private String articleCover;
    //插入时间
    private Date insertTime;
    //最后更新时间
    private Date updateTime;
    //创建人
    private String operatorName;
    //创建人ID
    private String operatorId;
    //1级类别id
    private String firstLevelCategoryId;
    //1级类别名称
    private String firstLevelCategoryName;
    //2级类别ID
    private String secondLevelCategoryId;
    //2级类别名称
    private String secondLevelCategoryName;
    //认证单位
    private String authentication;
    //认证单位ID
    private String authenticationId;
    //是否认证 1已认证0、未认证
    private int isAuthentication;
    //1、视频 2、图文3、音频、 4 、精选问答
    private String articleType;
    //操作人所在科室
    private String deptName;
    //等级职称
    private String titleLevel;
    //操作人头像
    private String operatorImg;
    private String lastOperatorId;
    private String lastOperatorName;
    private String operatorRoleCode;
    private String operatorRoleLevel;
    private int roleType;
    //使用范围（1、全市使用，2、全区使用，3、全社区使用）
    private int userScope;
    private String keyWord;
    private String url;
    private int isOld;
    @Column(name="ArticleId")
    @Id
    //@GeneratedValue(generator="system-uuid")
    //@GenericGenerator(name = "system-uuid", strategy = "uuid")
    public String getArticleId() {
        return articleId;
    }
    public void setArticleId(String articleId) {
        this.articleId = articleId;
    }
    @Column(name="ArticleTitle")
    public String getArticleTitle() {
        return articleTitle;
    }
    public void setArticleTitle(String articleTitle) {
        this.articleTitle = articleTitle;
    }
    @Column(name="Summary")
    public String getSummary() {
        return summary;
    }
    public void setSummary(String summary) {
        this.summary = summary;
    }
    @Column(name="ArticleContent")
    public String getArticleContent() {
        return articleContent;
    }
    public void setArticleContent(String articleContent) {
        this.articleContent = articleContent;
    }
    @Column(name="ArticleOrder")
    public int getArticleOrder() {
        return articleOrder;
    }
    public void setArticleOrder(int articleOrder) {
        this.articleOrder = articleOrder;
    }
    @Column(name="ArticleState")
    public int getArticleState() {
        return articleState;
    }
    public void setArticleState(int articleState) {
        this.articleState = articleState;
    }
    @Column(name="OrgName")
    public String getOrgName() {
        return orgName;
    }
    public void setOrgName(String orgName) {
        this.orgName = orgName;
    }
    @Column(name="ArticleSource")
    public String getArticleSource() {
        return articleSource;
    }
    public void setArticleSource(String articleSource) {
        this.articleSource = articleSource;
    }
    @Column(name="OrgId")
    public String getOrgId() {
        return orgId;
    }
    public void setOrgId(String orgId) {
        this.orgId = orgId;
    }
    @Column(name="Articlelevel")
    public int getArticlelevel() {
        return articlelevel;
    }
    public void setArticlelevel(int articlelevel) {
        this.articlelevel = articlelevel;
    }
    @Column(name="ArticleCover")
    public String getArticleCover() {
        return articleCover;
    }
    public void setArticleCover(String articleCover) {
        this.articleCover = articleCover;
    }
    @Column(name="InsertTime")
    public Date getInsertTime() {
        return insertTime;
    }
    public void setInsertTime(Date insertTime) {
        this.insertTime = insertTime;
    }
    @Column(name="UpdateTime")
    public Date getUpdateTime() {
        return updateTime;
    }
    public void setUpdateTime(Date updateTime) {
        this.updateTime = updateTime;
    }
    @Column(name="OperatorName")
    public String getOperatorName() {
        return operatorName;
    }
    public void setOperatorName(String operatorName) {
        this.operatorName = operatorName;
    }
    @Column(name="OperatorId")
    public String getOperatorId() {
        return operatorId;
    }
    public void setOperatorId(String operatorId) {
        this.operatorId = operatorId;
    }
    @Column(name="FirstLevelCategoryId")
    public String getFirstLevelCategoryId() {
        return firstLevelCategoryId;
    }
    public void setFirstLevelCategoryId(String firstLevelCategoryId) {
        this.firstLevelCategoryId = firstLevelCategoryId;
    }
    @Column(name="FirstLevelCategoryName")
    public String getFirstLevelCategoryName() {
        return firstLevelCategoryName;
    }
    public void setFirstLevelCategoryName(String firstLevelCategoryName) {
        this.firstLevelCategoryName = firstLevelCategoryName;
    }
    @Column(name="SecondLevelCategoryId")
    public String getSecondLevelCategoryId() {
        return secondLevelCategoryId;
    }
    public void setSecondLevelCategoryId(String secondLevelCategoryId) {
        this.secondLevelCategoryId = secondLevelCategoryId;
    }
    @Column(name="SecondLevelCategoryName")
    public String getSecondLevelCategoryName() {
        return secondLevelCategoryName;
    }
    public void setSecondLevelCategoryName(String secondLevelCategoryName) {
        this.secondLevelCategoryName = secondLevelCategoryName;
    }
    @Column(name="Authentication")
    public String getAuthentication() {
        return authentication;
    }
    public void setAuthentication(String authentication) {
        this.authentication = authentication;
    }
    @Column(name="AuthenticationId")
    public String getAuthenticationId() {
        return authenticationId;
    }
    public void setAuthenticationId(String authenticationId) {
        this.authenticationId = authenticationId;
    }
    @Column(name="IsAuthentication")
    public int getIsAuthentication() {
        return isAuthentication;
    }
    public void setIsAuthentication(int isAuthentication) {
        this.isAuthentication = isAuthentication;
    }
    @Column(name="ArticleType")
    public String getArticleType() {
        return articleType;
    }
    public void setArticleType(String articleType) {
        this.articleType = articleType;
    }
    @Column(name="DeptName")
    public String getDeptName() {
        return deptName;
    }
    public void setDeptName(String deptName) {
        this.deptName = deptName;
    }
    @Column(name="TitleLevel")
    public String getTitleLevel() {
        return titleLevel;
    }
    public void setTitleLevel(String titleLevel) {
        this.titleLevel = titleLevel;
    }
    @Column(name="OperatorImg")
    public String getOperatorImg() {
        return operatorImg;
    }
    public void setOperatorImg(String operatorImg) {
        this.operatorImg = operatorImg;
    }
    @Column(name="LastOperatorId")
    public String getLastOperatorId() {
        return lastOperatorId;
    }
    public void setLastOperatorId(String lastOperatorId) {
        this.lastOperatorId = lastOperatorId;
    }
    @Column(name="LastOperatorName")
    public String getLastOperatorName() {
        return lastOperatorName;
    }
    public void setLastOperatorName(String lastOperatorName) {
        this.lastOperatorName = lastOperatorName;
    }
    @Column(name="OperatorRoleCode")
    public String getOperatorRoleCode() {
        return operatorRoleCode;
    }
    public void setOperatorRoleCode(String operatorRoleCode) {
        this.operatorRoleCode = operatorRoleCode;
    }
    @Column(name="OperatorRoleLevel")
    public String getOperatorRoleLevel() {
        return operatorRoleLevel;
    }
    public void setOperatorRoleLevel(String operatorRoleLevel) {
        this.operatorRoleLevel = operatorRoleLevel;
    }
    @Column(name="RoleType")
    public int getRoleType() {
        return roleType;
    }
    public void setRoleType(int roleType) {
        this.roleType = roleType;
    }
    @Column(name="UserScope")
    public int getUserScope() {
        return userScope;
    }
    public void setUserScope(int userScope) {
        this.userScope = userScope;
    }
    @Column(name="KeyWord")
    public String getKeyWord() {
        return keyWord;
    }
    public void setKeyWord(String keyWord) {
        this.keyWord = keyWord;
    }
    @Column(name="URL")
    public String getUrl() {
        return url;
    }
    public void setUrl(String url) {
        this.url = url;
    }
    @Column(name = "IsOld")
    public int getIsOld() {
        return isOld;
    }
    public void setIsOld(int isOld) {
        this.isOld = isOld;
    }
}

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/OldArticleBehaviorModel.java

@@ -0,0 +1,46 @@
package com.yihu.edu.entity.dataClean;
import java.util.Date;
/**
 * Created by Administrator on 2017/12/25.
 */
public class OldArticleBehaviorModel {
    private String ArticleId;
    private int BehaviorAction;
    private String UserId;
    private Date InsertTime;
    public String getArticleId() {
        return ArticleId;
    }
    public void setArticleId(String articleId) {
        ArticleId = articleId;
    }
    public int getBehaviorAction() {
        return BehaviorAction;
    }
    public void setBehaviorAction(int behaviorAction) {
        BehaviorAction = behaviorAction;
    }
    public String getUserId() {
        return UserId;
    }
    public void setUserId(String userId) {
        UserId = userId;
    }
    public Date getInsertTime() {
        return InsertTime;
    }
    public void setInsertTime(Date insertTime) {
        InsertTime = insertTime;
    }
}

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/OldArticleCollectModel.java

@@ -0,0 +1,91 @@
package com.yihu.edu.entity.dataClean;
import java.util.Date;
/**
 * Created by Administrator on 2017/12/25.
 */
public class OldArticleCollectModel {
    private String UserId;
    private String ArticleId;
    private String url;
    private String title;
    private String content;
    private Date InsertTime;
    //1、医生 2、居民
    private int UserType;
    private String CName;
    public String getUserId() {
        return UserId;
    }
    public void setUserId(String userId) {
        UserId = userId;
    }
    public String getArticleId() {
        return ArticleId;
    }
    public void setArticleId(String articleId) {
        ArticleId = articleId;
    }
    public String getUrl() {
        return url;
    }
    public void setUrl(String url) {
        this.url = url;
    }
    public String getTitle() {
        return title;
    }
    public void setTitle(String title) {
        this.title = title;
    }
    public String getContent() {
        return content;
    }
    public void setContent(String content) {
        this.content = content;
    }
    public Date getInsertTime() {
        return InsertTime;
    }
    public void setInsertTime(Date insertTime) {
        InsertTime = insertTime;
    }
    public int getUserType() {
        return UserType;
    }
    public void setUserType(int userType) {
        UserType = userType;
    }
    public String getCName() {
        return CName;
    }
    public void setCName(String CName) {
        this.CName = CName;
    }
}

common/common-entity/src/main/java/com/yihu/edu/entity/dataClean/OldArticleModel.java

@@ -0,0 +1,100 @@
package com.yihu.edu.entity.dataClean;
import java.util.Date;
/**
 * Created by Administrator on 2017/12/25.
 */
public class OldArticleModel {
    private String ArticleId;
    private String ArticleTitle;
    private String Summary;
    private String ArticleContent;
    private String ArticleCover;
    private Date InsertTime;
    private Date UpdateTime;
    private int FirstLevelCategoryId;
    private String KeyWord;
    public String getArticleId() {
        return ArticleId;
    }
    public void setArticleId(String articleId) {
        ArticleId = articleId;
    }
    public String getArticleTitle() {
        return ArticleTitle;
    }
    public void setArticleTitle(String articleTitle) {
        ArticleTitle = articleTitle;
    }
    public String getSummary() {
        return Summary;
    }
    public void setSummary(String summary) {
        Summary = summary;
    }
    public String getArticleContent() {
        return ArticleContent;
    }
    public void setArticleContent(String articleContent) {
        ArticleContent = articleContent;
    }
    public String getArticleCover() {
        return ArticleCover;
    }
    public void setArticleCover(String articleCover) {
        ArticleCover = articleCover;
    }
    public Date getInsertTime() {
        return InsertTime;
    }
    public void setInsertTime(Date insertTime) {
        InsertTime = insertTime;
    }
    public Date getUpdateTime() {
        return UpdateTime;
    }
    public void setUpdateTime(Date updateTime) {
        UpdateTime = updateTime;
    }
    public int getFirstLevelCategoryId() {
        return FirstLevelCategoryId;
    }
    public void setFirstLevelCategoryId(int firstLevelCategoryId) {
        FirstLevelCategoryId = firstLevelCategoryId;
    }
    public String getKeyWord() {
        return KeyWord;
    }
    public void setKeyWord(String keyWord) {
        KeyWord = keyWord;
    }
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/config/jpa/JkEduJpa.java

@@ -0,0 +1,65 @@
package com.yihu.wlyy.config.jpa;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.JpaVendorAdapter;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.annotation.EnableTransactionManagement;
import javax.persistence.EntityManagerFactory;
import javax.sql.DataSource;
import java.util.Properties;
/**
 * Created by zhangdan on 2017/12/26.
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "jkehuEntityManagerFactory",
        transactionManagerRef = "jkehuTransactionManager",
        basePackages = {"com.yihu.wlyy.jkedu.repository"})  //设置Repository所在位置
public class JkEduJpa {
    @Autowired
    private HibernateProperties hibernateProperties;
    @Bean(name = "jkehuDataSource")
    @ConfigurationProperties(prefix="spring.datasource.jkedu")
    public DataSource jkeduDataSource() {
        return DataSourceBuilder.create().build();
    }
    @Bean(name = "jkehuEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary(
            @Qualifier("jkehuDataSource") DataSource dataSource) {
        LocalContainerEntityManagerFactoryBean emfb = new LocalContainerEntityManagerFactoryBean();
        emfb.setDataSource(dataSource);
        emfb.setPackagesToScan("com.yihu.edu.entity.dataClean");
        emfb.setPersistenceUnitName("jkedu");
        JpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        emfb.setJpaVendorAdapter(vendorAdapter);
        Properties properties = new Properties();
        properties.putAll(hibernateProperties.hibProperties());
        properties.put("hibernate.ejb.naming_strategy","org.hibernate.cfg.DefaultNamingStrategy");
        emfb.setJpaProperties(properties);
        return emfb;
    }
    @Bean(name = "jkehuTransactionManager")
    JpaTransactionManager transactionManagerSecondary(
            @Qualifier("jkehuEntityManagerFactory")EntityManagerFactory builder) {
        return new JpaTransactionManager(builder);
    }
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/jkedu/repository/JkeduArticleDao.java

@@ -0,0 +1,18 @@
package com.yihu.wlyy.jkedu.repository;
import com.yihu.device.entity.DevicePatientHealthIndex;
import com.yihu.edu.entity.dataClean.NewArticleModel;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import java.util.Date;
import java.util.List;
public interface JkeduArticleDao
		extends PagingAndSortingRepository<NewArticleModel, Long>, JpaSpecificationExecutor<NewArticleModel> {
	@Query("select n from NewArticleModel n where n.isOld=1")
	List<NewArticleModel> findOldArticle();
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/jkedu/repository/JkeduBehaviorArticleDao.java

@@ -0,0 +1,22 @@
package com.yihu.wlyy.jkedu.repository;
import com.yihu.edu.entity.dataClean.NewArticleBehaviorModel;
import com.yihu.edu.entity.dataClean.NewArticleCollectModel;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
public interface JkeduBehaviorArticleDao
		extends PagingAndSortingRepository<NewArticleBehaviorModel, Long>, JpaSpecificationExecutor<NewArticleBehaviorModel> {
	@Query("select n from NewArticleBehaviorModel n where n.isOld=1")
	List<NewArticleBehaviorModel> findOldArticleBehavior();
	@Modifying
	@Transactional
	@Query("delete from NewArticleBehaviorModel n where n.ID in (?1)")
	void deleteByIds(List ids);
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/jkedu/repository/JkeduCollectionArticleDao.java

@@ -0,0 +1,21 @@
package com.yihu.wlyy.jkedu.repository;
import com.yihu.edu.entity.dataClean.NewArticleCollectModel;
import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.transaction.annotation.Transactional;
import java.util.List;
public interface JkeduCollectionArticleDao
		extends PagingAndSortingRepository<NewArticleCollectModel, Long>, JpaSpecificationExecutor<NewArticleCollectModel> {
	@Query("select n.ID from NewArticleCollectModel n where n.isOld=1")
	List<Integer> findOldArticleCollection();
	@Modifying
	@Transactional
	@Query("delete from NewArticleCollectModel n where n.ID in (?1)")
	void deleteByIds(List ids);
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/repository/education/HealthEduArticleDao.java

@@ -15,4 +15,5 @@ public interface HealthEduArticleDao extends PagingAndSortingRepository<HealthEd
	@Query("SELECT a FROM HealthEduArticle a WHERE (a.title like ?1 or a.keyword like ?2) ORDER BY a.czrq DESC")
	Page<HealthEduArticle> list(String title, String keyword, Pageable pageRequest);
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/util/MapListUtils.java

@@ -1,8 +1,14 @@
package com.yihu.wlyy.util;
import com.google.common.collect.Lists;
import org.apache.commons.beanutils.BeanUtils;
import org.json.JSONArray;
import org.json.JSONObject;
import org.springframework.cglib.beans.BeanMap;
import java.beans.BeanInfo;
import java.beans.Introspector;
import java.beans.PropertyDescriptor;
import java.util.*;
/**
@@ -24,4 +30,72 @@ public class MapListUtils {
        }
        return l;
    }
    /**
     * 将map装换为javabean对象
     * @param map
     * @param bean
     * @return
     */
    public static <T> T mapToBean(Map<String, Object> map,T bean) {
        BeanMap beanMap = BeanMap.create(bean);
        beanMap.putAll(map);
        return bean;
    }
    /**
     * 将List<Map<String,Object>>转换为List<T>
     * @param maps
     * @param clazz
     * @return
     * @throws InstantiationException
     * @throws IllegalAccessException
     */
    public static <T> List<T> mapsToObjects(List<Map<String, Object>> maps,Class<T> clazz) throws InstantiationException, IllegalAccessException {
        List<T> list = Lists.newArrayList();
        if (maps != null && maps.size() > 0) {
            Map<String, Object> map = null;
            T bean = null;
            for (int i = 0,size = maps.size(); i < size; i++) {
                map = maps.get(i);
                bean = clazz.newInstance();
                bean = mapToBean(map, bean);
                list.add(bean);
            }
        }
        return list;
    }
    /**
     *
     * @param map
     * @param T
     * @param <T>
     * @return
     * @throws Exception
     */
    public static <T> T convertMap2Bean(Map map, Class T) throws Exception {
        if(map==null || map.size()==0){
            return null;
        }
        BeanInfo beanInfo = Introspector.getBeanInfo(T);
        T bean = (T)T.newInstance();
        PropertyDescriptor[] propertyDescriptors = beanInfo.getPropertyDescriptors();
        for (int i = 0, n = propertyDescriptors.length; i <n ; i++) {
            PropertyDescriptor descriptor = propertyDescriptors[i];
            String propertyName = descriptor.getName();
            String upperPropertyName = propertyName.toUpperCase();
            if (map.containsKey(upperPropertyName)) {
                Object value = map.get(upperPropertyName);
                //这个方法不会报参数类型不匹配的错误。
                BeanUtils.copyProperty(bean, propertyName, value);
                //用这个方法对int等类型会报参数类型不匹配错误，需要我们手动判断类型进行转换，比较麻烦。
                //descriptor.getWriteMethod().invoke(bean, value);
                //用这个方法对时间等类型会报参数类型不匹配错误，也需要我们手动判断类型进行转换，比较麻烦。
                //BeanUtils.setProperty(bean, propertyName, value);
            }
        }
        return bean;
    }
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/web/third/jkedu/controller/EduArticleController.java

@@ -3,6 +3,7 @@ package com.yihu.wlyy.web.third.jkedu.controller;
import com.alibaba.fastjson.JSON;
import com.yihu.wlyy.util.HttpUtil;
import com.yihu.wlyy.web.BaseController;
import com.yihu.wlyy.web.third.jkedu.service.EduArticleService;
import com.yihu.wlyy.web.third.jkedu.vo.ArticleModel;
import com.yihu.wlyy.web.third.jkedu.vo.base.ResultOneModel;
import com.yihu.wlyy.web.third.jkedu.vo.state.ErrorStateMessage;
@@ -33,6 +34,8 @@ public class EduArticleController extends BaseController{
    @Autowired
    private  HttpUtil HttpUtil;
    @Autowired
    private EduArticleService eduArticleService;
    @RequestMapping(value = "/getById",method = RequestMethod.POST)
    @ResponseBody
@@ -63,4 +66,59 @@ public class EduArticleController extends BaseController{
            return  new ResultOneModel(code,ErrorStateMessage.getMessge(code)+","+e.getMessage());
        }
    }
    @RequestMapping(value = "/getArticleListToNewDataBase",method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation("文章列表转移")
    public String getArticleListToNewDataBase(){
        boolean flag = eduArticleService.getArticleListToNewDataBase();
        if (flag){
            return write(200,"数据转移成功！");
        }else{
            return write(0,"数据转移失败！");
        }
    }
    @RequestMapping(value = "/getArticleCollectToNewDataBase",method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation("文章收藏转移")
    public String getArticleCollectToNewDataBase(){
        boolean flag = eduArticleService.getArticleCollectToNewDataBase();
        if (flag){
            return write(200,"数据转移成功！");
        }else{
            return write(0,"数据转移失败！");
        }
    }
    @RequestMapping(value = "/getArticleBehaviorToNewDataBase",method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation("文章行为转移")
    public String getArticleBehaviorToNewDataBase(){
        boolean flag = eduArticleService.getArticleBehaviorToNewDataBase();
        if (flag){
            return write(200,"数据转移成功！");
        }else{
            return write(0,"数据转移失败！");
        }
    }
    @RequestMapping(value = "/getArticleSendToEs",method = RequestMethod.POST)
    @ResponseBody
    @ApiOperation("已发送文章列表转移Es")
    public String getArticleSendToEs(){
        boolean flag = eduArticleService.getArticleSendedListToEs();
        if (flag){
            return write(200,"数据转移成功！");
        }else{
            return write(0,"数据转移失败！");
        }
    }
    @RequestMapping(value = "/save",method = RequestMethod.POST)
    @ResponseBody
    public String save(){
        eduArticleService.save();
        return "";
    }
}

patient-co/patient-co-wlyy/src/main/java/com/yihu/wlyy/web/third/jkedu/service/EduArticleService.java

@@ -0,0 +1,377 @@
package com.yihu.wlyy.web.third.jkedu.service;
import com.yihu.edu.entity.dataClean.*;
import com.yihu.es.entity.HealthEduArticlePatient;
import com.yihu.wlyy.config.es.ElastricSearchSave;
import com.yihu.wlyy.entity.doctor.profile.Doctor;
import com.yihu.wlyy.entity.education.HealthEduArticle;
import com.yihu.wlyy.entity.patient.Patient;
import com.yihu.wlyy.jkedu.repository.JkeduArticleDao;
import com.yihu.wlyy.jkedu.repository.JkeduBehaviorArticleDao;
import com.yihu.wlyy.jkedu.repository.JkeduCollectionArticleDao;
import com.yihu.wlyy.repository.doctor.DoctorDao;
import com.yihu.wlyy.repository.education.HealthEduArticleDao;
import com.yihu.wlyy.util.DateUtil;
import com.yihu.wlyy.util.MapListUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import java.util.*;
/**
 * Created by zhangdan on 2017/12/25.
 */
@Service
@Transactional(rollbackFor = Exception.class)
public class EduArticleService {
    @Autowired
    private JdbcTemplate jdbcTemplate;
    @Autowired
    private DoctorDao doctorDao;
    @Autowired
    private ElastricSearchSave elastricSearchSave;
    @Autowired
    private HealthEduArticleDao healthEduArticleDao;
    @Autowired
    private JkeduArticleDao jkeduArticleDao;
    @Autowired
    private JkeduCollectionArticleDao jkeduCollectionArticleDao;
    @Autowired
    private JkeduBehaviorArticleDao jkeduBehaviorArticleDao;
    @Value("${es.type.HealthEduArticlePatient}")
    private String esType;
    @Value("${es.index.HealthEduArticlePatient}")
    private String esIndex;
    private static int pageSize = 1000;
    /**
     * 健康教育文章列表转移
     * @return
     */
    public boolean getArticleListToNewDataBase(){
        boolean flag = true;
        //获取卫计委code
        String wjwSql = "select code AS wjwCode from wlyy_role WHERE  name LIKE '%厦门市卫生与计划生育委员会%' and LENGTH(code)=6";
        Map<String, Object> result = jdbcTemplate.queryForMap(wjwSql);
        String wjwCode = result.get("wjwCode") + "";
        //先将原来数据库的数据删除
        List<NewArticleModel> delOldList = jkeduArticleDao.findOldArticle();
        if (delOldList!=null && delOldList.size()>0){
            jkeduArticleDao.delete(delOldList);
        }
        //分页查询，执行插入
        String countSql = "select COUNT(1) AS num from wlyy_health_edu_article";
        Map<String,Object> countMap = jdbcTemplate.queryForMap(countSql);
        if (countMap!=null){
            int count = Integer.valueOf(String.valueOf(countMap.get("num")));
            double pageCount = Math.ceil(Double.valueOf(count)/Double.valueOf(pageSize));
            if (pageCount>0){
                String  sql ="SELECT code AS ArticleId,title AS ArticleTitle,summary AS Summary,content AS ArticleContent, " +
                        "url AS URL, czrq AS InsertTime, czrq AS UpdateTime,whea_type AS FirstLevelCategoryId," +
                        " keyword AS KeyWord FROM wlyy_health_edu_article limit ?,?";
                for (int i = 1;i<=pageCount;i++){
                    int start = (i-1)*pageSize;
                    //分页查询数据
                    List<Map<String,Object>>  list = jdbcTemplate.queryForList(sql,new Object[]{start,pageSize});
                    List<NewArticleModel> newList = new ArrayList<>();
                    try {
                        for (Map<String, Object> map : list) {
                            OldArticleModel oldArticleModel = new OldArticleModel();
                            NewArticleModel newArticleModel = new NewArticleModel();
                            //转换数据
                            oldArticleModel = MapListUtils.convertMap2Bean(map,OldArticleModel.class);
                            //@// TODO: 2017/12/25 完善数据
                            BeanUtils.copyProperties(oldArticleModel,newArticleModel);
                            newArticleModel.setArticleOrder(99);
                            newArticleModel.setArticleState(1);
                            newArticleModel.setOrgName("厦门市卫生与计划生育委员会");
                            //id
                            newArticleModel.setArticleSource(wjwCode);
                            newArticleModel.setArticlelevel(0);
                            newArticleModel.setOperatorName("厦门市卫生与计划生育委员会");
                            newArticleModel.setOperatorId(wjwCode);
                            newArticleModel.setAuthentication("厦门市卫生与计划生育委员会");
                            newArticleModel.setAuthenticationId(wjwCode);
                            newArticleModel.setIsAuthentication(1);
                            newArticleModel.setArticleType("2");
                            newArticleModel.setOperatorRoleCode("管理员code");
                            newArticleModel.setOperatorRoleLevel("管理员");
                            newArticleModel.setRoleType(2);
                            newArticleModel.setUserScope(1);
                            newArticleModel.setIsOld(1);
                            newList.add(newArticleModel);
                        }
                        //执行插入新数据库
                        jkeduArticleDao.save(newList);
                    }catch (Exception e){
                        e.printStackTrace();
                        flag = false;
                    }
                }
            }
        }
        return flag;
    }
    /**
     * 健康教育收藏列表转移
     * @return
     */
    public boolean getArticleCollectToNewDataBase(){
        boolean flag = true;
        try {
            //获取卫计委code
            String wjwSql = "select code AS wjwCode from wlyy_role WHERE  name LIKE '%厦门市卫生与计划生育委员会%' and LENGTH(code)=6";
            Map<String, Object> result = jdbcTemplate.queryForMap(wjwSql);
            String wjwCode = result.get("wjwCode") + "";
            //先将原来数据库的数据删除
            List<Integer> delOldList = jkeduCollectionArticleDao.findOldArticleCollection();
            if (delOldList!=null && delOldList.size()>0){
                int count = 1;
                double num = Math.ceil(Double.valueOf(delOldList.size())/1000.0);
                for (int i=0;i<num;i++){
                    List idsList = new ArrayList<>();
                    for (int j =0;j<1000;j++){
                        if (count<=delOldList.size()){
                            idsList.add(delOldList.get(j+i*1000));
                        }
                        count++;
                    }
                    jkeduCollectionArticleDao.deleteByIds(idsList);
                }
            }
            //先分页查询
            String countSql ="select COUNT(1) AS num from wlyy_health_edu_article_doctor";
            Map<String,Object> countMap = jdbcTemplate.queryForMap(countSql);
            if (countMap!=null){
                int count = Integer.valueOf(String.valueOf(countMap.get("num")));
                double pageCount = Math.ceil(Double.valueOf(count)/Double.valueOf(pageSize));
                if (pageCount>0) {
                    String  sql ="SELECT" +
                            " ad.doctor AS UserId," +
                            " ad.article AS ArticleId, " +
                            " ad.url, " +
                            " ad.title, " +
                            " ad.content, " +
                            " ad.czrq AS InsertTime, " +
                            " d.`name` AS CName " +
                            " FROM " +
                            " wlyy_health_edu_article_doctor ad " +
                            " LEFT JOIN wlyy_doctor d ON ad.doctor = d. CODE LIMIT  ?,?";
                    List<NewArticleCollectModel> newList = new ArrayList<>();
                    for (int i = 1; i <= pageCount; i++) {
                        int start = (i - 1) * pageSize;
                        //分页查询数据
                        List<Map<String,Object>>  list = jdbcTemplate.queryForList(sql,new Object[]{start,pageSize});
                        for (Map<String, Object> map : list) {
                            OldArticleCollectModel oldArticleCollectModel = new OldArticleCollectModel();
                            NewArticleCollectModel newArticleCollectModel = new NewArticleCollectModel();
                            oldArticleCollectModel = MapListUtils.convertMap2Bean(map,OldArticleCollectModel.class);
                            //@// TODO: 2017/12/25 完善数据
                            BeanUtils.copyProperties(oldArticleCollectModel,newArticleCollectModel);
                            newArticleCollectModel.setUserType(1);
                            newArticleCollectModel.setOrgName("厦门市卫生与计划生育委员会");
                            newArticleCollectModel.setOrgId(wjwCode);
                            newArticleCollectModel.setIsOld(1);
                            newList.add(newArticleCollectModel);
                        }
                        //跨数据库插入数据
                        jkeduCollectionArticleDao.save(newList);
                    }
                }
            }
        }catch (Exception e){
            e.printStackTrace();
            flag = false;
        }
        return flag;
    }
    /**
     * 转移健康教育行为
     * @return
     */
    public boolean getArticleBehaviorToNewDataBase(){
        boolean flag = true;
        try {
            //数量也许过大，分批次删除
            //先将原来数据库的数据删除
            List<NewArticleBehaviorModel> delOldList = jkeduBehaviorArticleDao.findOldArticleBehavior();
            if (delOldList!=null && delOldList.size()>0){
                int count = 1;
                double num = Math.ceil(Double.valueOf(delOldList.size())/1000.0);
                for (int i=0;i<num;i++){
                    List idsList = new ArrayList<>();
                    for (int j =0;j<1000;j++){
                        if (count<=delOldList.size()){
                            idsList.add(delOldList.get(j+i*1000).getID());
                        }
                        count++;
                    }
                    jkeduBehaviorArticleDao.deleteByIds(idsList);
                }
            }
            //分批次查询
            String countSql = "select COUNT(1) AS num from wlyy_health_edu_article_op_history";
            Map<String,Object> countMap = jdbcTemplate.queryForMap(countSql);
            if (countMap!=null) {
                int count = Integer.valueOf(String.valueOf(countMap.get("num")));
                double pageCount = Math.ceil(Double.valueOf(count) / Double.valueOf(pageSize));
                if (pageCount > 0) {
                    String  sql ="SELECT code AS ArticleId, status AS BehaviorAction,creater AS UserId," +
                            " created_time AS InsertTime FROM wlyy_health_edu_article_op_history limit ?,?";
                    List<NewArticleBehaviorModel> newList = new ArrayList<>();
                    //分页查询
                    for (int i = 1; i <= pageCount; i++) {
                        int start = (i - 1) * pageSize;
                        List<Map<String,Object>>  list = jdbcTemplate.queryForList(sql,new Object[]{start,pageSize});
                        for (Map<String, Object> map : list) {
                            OldArticleBehaviorModel oldArticleBehaviorModel = new OldArticleBehaviorModel();
                            NewArticleBehaviorModel newArticleBehaviorModel = new NewArticleBehaviorModel();
                            oldArticleBehaviorModel = MapListUtils.convertMap2Bean(map,OldArticleBehaviorModel.class);
                            //@// TODO: 2017/12/25 完善数据
                            BeanUtils.copyProperties(oldArticleBehaviorModel,newArticleBehaviorModel);
                            if (newArticleBehaviorModel.getBehaviorAction()==1){
                                newArticleBehaviorModel.setBehaviorAction(5);
                            }
                            newArticleBehaviorModel.setIsOld(1);
                            newList.add(newArticleBehaviorModel);
                        }
                        //跨数据库插入数据
                        jkeduBehaviorArticleDao.save(newList);
                    }
                }
            }
        }catch (Exception e){
            e.printStackTrace();
            flag = false;
        }
        return flag;
    }
    /**
     * 数据转移至Es
     * @return
     */
    public boolean getArticleSendedListToEs(){
        boolean flag = true;
        try{
            //获取卫计委code
            String sql = "select code AS wjwCode from wlyy_role WHERE  name LIKE '%厦门市卫生与计划生育委员会%' and LENGTH(code)=6";
            Map<String, Object> result = jdbcTemplate.queryForMap(sql);
            String wjwCode = result.get("wjwCode") + "";
            //转移到数据库的时候按照批次来聚合
            sql = "SELECT batch_no ,article,doctor,doctor_name,admin_team_code,czrq " +
                    " FROM wlyy_health_edu_article_patient " +
                    " WHERE  batch_no IS NOT NULL GROUP BY batch_no";
            List<Map<String,Object>> resultList = jdbcTemplate.queryForList(sql);
            if (CollectionUtils.isEmpty(resultList)){
                return flag;
            }
            for (Map<String, Object> map: resultList){
                List<Map<String,Object>> articleList = null;
                String batchNo = map.get("batch_no")+"";
                String article = map.get("article")+"";
                String doctorCode = map.get("doctor")+"";
                String adminTeamId = map.get("admin_team_code")+"";
                String  czrq =  map.get("czrq")+"";
                //同一个批次号只会有一篇文章
                String batchSql = "select * from wlyy_health_edu_article_patient where batch_no = '"+batchNo+"'";
                HealthEduArticlePatient healthEduArticlePatient = setDateToObj(batchSql,doctorCode,adminTeamId,wjwCode,batchNo,article,czrq);
                //保存到Es中
                elastricSearchSave.save(healthEduArticlePatient, esIndex, esType);
            }
        }catch (Exception e){
            e.printStackTrace();
            flag= false;
        }
        return flag;
    }
    public HealthEduArticlePatient setDateToObj(String batchSql,String doctorCode,String adminTeamId,String wjwCode,String batchNo,String article,String czrq)throws Exception{
        HealthEduArticlePatient healthEduArticlePatient = new HealthEduArticlePatient();
        //创建对象
        List<Map<String,Object>> articleList= jdbcTemplate.queryForList(batchSql);
        //放置患者集合
        if (!CollectionUtils.isEmpty(articleList)){
            List<Patient> patientList = new ArrayList<>();
            for (Map<String,Object> sendMap: articleList){
                patientList.add(new Patient(sendMap.get("patient")+""));
            }
            healthEduArticlePatient.setPatients(patientList);
        }
        Doctor doctor = doctorDao.findByCode(doctorCode);
        healthEduArticlePatient.setAdminTeamCode(Long.valueOf(adminTeamId));
        if (doctor!=null){
            healthEduArticlePatient.setDoctorCode(doctor.getCode());
            healthEduArticlePatient.setSendName(doctor.getCode());
            healthEduArticlePatient.setDoctorName(doctor.getName());
            healthEduArticlePatient.setSendType(1);
            healthEduArticlePatient.setHospital(doctor.getHospital());
            healthEduArticlePatient.setHospitalName(doctor.getHospitalName());
            healthEduArticlePatient.setTown(doctor.getTown());
            healthEduArticlePatient.setTownName(doctor.getTownName());
            healthEduArticlePatient.setSendLevel(doctor.getLevel() != null ? String.valueOf(doctor.getLevel()) : "");
            healthEduArticlePatient.setSendPic(doctor.getPhoto());
            healthEduArticlePatient.setSendSex(doctor.getSex() != null ? String.valueOf(doctor.getSex()) : "");
        }else{
            healthEduArticlePatient.setDoctorCode(wjwCode);
            healthEduArticlePatient.setSendName("厦门市卫生与计划生育委员会");
            healthEduArticlePatient.setDoctorName("厦门市卫生与计划生育委员会");
            healthEduArticlePatient.setSendType(2);
        }
        healthEduArticlePatient.setBatchNo(batchNo);
        Date czrqDate = DateUtil.strToDate(czrq);
        healthEduArticlePatient.setCreateTime(czrqDate);
        //获取文章详情
        HealthEduArticle healthEduArticle = healthEduArticleDao.findByCode(article);
        healthEduArticlePatient.setArticleId(healthEduArticle.getCode());
        healthEduArticlePatient.setAttachedTitle(healthEduArticle.getTitle());
        healthEduArticlePatient.setAttachedContent(healthEduArticle.getContent());
        healthEduArticlePatient.setArticleType("2");
        healthEduArticlePatient.setLevel("1");
        healthEduArticlePatient.setType("1");//文章
        //healthEduArticlePatient.setAttachedPic("");
        //healthEduArticlePatient.setAttachedMessage(sendMessage);
        //healthEduArticlePatient.setLevel1Type(article.get("firstLevelCategoryId") + "");
        //healthEduArticlePatient.setLevel2Type(article.get("secondLevelCategoryId") + "");
        return  healthEduArticlePatient;
    }
    @Transactional
    public void save(){
        NewArticleModel newArticleModel = new NewArticleModel();
        newArticleModel.setArticleId("123");
        newArticleModel.setArticleTitle("测试123");
        newArticleModel.setArticleContent("测试123内容");
        newArticleModel.setArticleState(1);
        newArticleModel.setIsAuthentication(1);
        newArticleModel.setArticleOrder(99);
        newArticleModel.setArticleState(1);
        newArticleModel.setOrgName("厦门市卫生与计划生育委员会");
        newArticleModel.setArticleSource("厦门市卫生与计划生育委员会");//id
        newArticleModel.setArticlelevel(0);
        newArticleModel.setOperatorName("厦门市卫生与计划生育委员会");
        newArticleModel.setOperatorId("");
        newArticleModel.setAuthentication("厦门市卫生与计划生育委员会");
        newArticleModel.setAuthenticationId("");
        newArticleModel.setIsAuthentication(1);
        newArticleModel.setArticleType("2");
        newArticleModel.setOperatorRoleCode("管理员code");
        newArticleModel.setOperatorRoleLevel("管理员");
        newArticleModel.setRoleType(2);
        newArticleModel.setUserScope(1);
        jkeduArticleDao.save(newArticleModel);
    }
}

patient-co/patient-co-wlyy/src/main/resources/application-dev.yml

@@ -11,6 +11,10 @@ spring:
      url: jdbc:mysql://172.19.103.77/device?useUnicode=true&characterEncoding=utf-8&autoReconnect=true
      username: root
      password: 123456
    jkedu:
      url: jdbc:mysql://172.19.103.77/jkedudb?useUnicode=true&characterEncoding=utf-8&autoReconnect=true
      username: root
      password: 123456
  redis:
    host: 172.19.103.88 # Redis server host.