Merge branch 'master' of http://begitlab.chubanyun.me/rays/pcloud-common-parent

pcloud-common-config/src/main/resources.prod/bootstrap.yml

@@ -10,9 +10,26 @@ spring:
     loadbalancer:
       retry:
         enabled: true
+  datasource:
+    type: com.alibaba.druid.pool.DruidDataSource
+    driver-class-name: com.mysql.jdbc.Driver
+    initialSize: 2
+    minIdle: 5
+    maxActive: 50
+    maxWait: 60000
+    timeBetweenEvictionRunsMillis: 3000
+    minEvictableIdleTimeMillis: 3600000
+    validationQuery: SELECT 'x' FROM DUAL
+    testWhileIdle: true
+    testOnBorrow: false
+    testOnReturn: false
+    poolPreparedStatements: true
+    maxPoolPreparedStatementPerConnectionSize: 20
+    connectionPropertiesNew: config.decrypt=true;config.decrypt.key=${spring.datasource.publicKey}
+    filtersNew: config        
   metrics:
     influx:
-      uri: http://192.168.83.241:8086/write
+      uri: http://192.168.89.200:8086/write
       step: PT10S
       db: ${spring.application.name}
       enabled: true
@@ -32,7 +49,7 @@ spring:
       retry:
         max-attempts: 3  # 最大重试次数
         enabled: true # 是否开启消费者重试（为false时关闭消费者重试，这时消费端代码异常会一直重复收到消息）
-        initial-interval: 5000 # 重试间隔时间（单位毫秒）
+        initial-interval: 300000 # 重试间隔时间（单位毫秒）
       default-requeue-rejected: true # 重试次数超过上面的设置之后是否丢弃（false不丢弃时需要写相应代码将该消息加入死信队列）      
   data:
     solr:

pcloud-common-config/src/main/resources.prod/public_system.properties

@@ -87,3 +87,5 @@ uedThirdPartyOrderUrl=https://rayscloud.chubanyun.net
 system.env = pro
 
 jsbj.agent.id = 1000009100
+
+product.parentTutor.proLabelId = 7461
\ No newline at end of file

pcloud-common-config/src/main/resources.uat/bootstrap.yml

@@ -10,9 +10,26 @@ spring:
     loadbalancer:
       retry:
         enabled: true
+  datasource:
+    type: com.alibaba.druid.pool.DruidDataSource
+    driver-class-name: com.mysql.jdbc.Driver
+    initialSize: 2
+    minIdle: 5
+    maxActive: 50
+    maxWait: 60000
+    timeBetweenEvictionRunsMillis: 3000
+    minEvictableIdleTimeMillis: 3600000
+    validationQuery: SELECT 'x' FROM DUAL
+    testWhileIdle: true
+    testOnBorrow: false
+    testOnReturn: false
+    poolPreparedStatements: true
+    maxPoolPreparedStatementPerConnectionSize: 20
+    connectionPropertiesNew: config.decrypt=true;config.decrypt.key=${spring.datasource.publicKey}
+    filtersNew: config        
   metrics:
     influx:
-      uri: http://192.168.83.241:8086/write
+      uri: http://192.168.89.200:8086/write
       step: PT10S
       db: ${spring.application.name}
       enabled: false
@@ -32,7 +49,7 @@ spring:
       retry:
         max-attempts: 3  # 最大重试次数
         enabled: true # 是否开启消费者重试（为false时关闭消费者重试，这时消费端代码异常会一直重复收到消息）
-        initial-interval: 5000 # 重试间隔时间（单位毫秒）
+        initial-interval: 300000 # 重试间隔时间（单位毫秒）
       default-requeue-rejected: true # 重试次数超过上面的设置之后是否丢弃（false不丢弃时需要写相应代码将该消息加入死信队列）
   data:
     solr:

pcloud-common-config/src/main/resources.uat/public_system.properties

@@ -89,3 +89,5 @@ uedThirdPartyOrderUrl=http://deveapi.chubanyun.net
 system.env = uat
 
 jsbj.agent.id = 12829
+
+product.parentTutor.proLabelId = 812
\ No newline at end of file

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/BacklogQueueBiz.java

+package com.pcloud.common.core.biz;
+
+import com.pcloud.common.core.dto.BacklogQueueDto;
+import com.pcloud.common.exceptions.BizException;
+
+/**
+ * @描述：待办事项统计队列
+ * @作者：zhuyajie
+ * @创建时间：10:33 2018/10/31
+ * @版本：1.0
+ */
+public interface BacklogQueueBiz {
+
+    /**
+     * 发送待办事项
+     * @param backlogQueueDto
+     */
+    public void sendBacklogQueue(BacklogQueueDto backlogQueueDto)throws BizException;
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/biz/BacklogQueueBizImpl.java

+package com.pcloud.common.core.biz;
+
+import com.pcloud.common.core.aspect.ParamLog;
+import com.pcloud.common.core.constant.MQQueueConstant;
+import com.pcloud.common.core.dto.BacklogQueueDto;
+import com.pcloud.common.exceptions.BizException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.amqp.core.AmqpTemplate;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * @描述：待办事务统计
+ * @作者：zhuyajie
+ * @创建时间：10:46 2018/10/31
+ * @版本：1.0
+ */
+@Component("backlogQueueBiz")
+public class BacklogQueueBizImpl implements BacklogQueueBiz {
+    private final static Logger logger = LoggerFactory.getLogger(BacklogQueueBizImpl.class);
+
+    @Autowired
+    private AmqpTemplate amqpTemplate;
+
+    @Override
+    @ParamLog("发送待办事务通知")
+    public void sendBacklogQueue(BacklogQueueDto backlogQueueDto) throws BizException{
+        if (backlogQueueDto == null) {
+            throw BizException.PARAM_IS_NULL;
+        }
+        try {
+             amqpTemplate.convertAndSend(MQQueueConstant.BACKLOG, backlogQueueDto);
+        } catch (Exception e) {
+            logger.error("发送失败，" + e.getMessage() + "," + backlogQueueDto.toString(), e);
+            throw BizException.SEND_QUEUE_FAIL;
+        }
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/AppTypeEnum.java

@@ -77,7 +77,12 @@ public enum AppTypeEnum {
 	/**
 	 * 打卡
 	 */
-	CLOCK("clock");
+	CLOCK("clock"),
+
+    /**
+     * 伴读魔法箱
+     */
+    AUDIO_MAGIC("magic");
 	
 	
 	

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/ConvertEnum.java

@@ -88,7 +88,12 @@ public enum ConvertEnum {
 	/**
 	 * 音频纯听
 	 */
-    AUDIO_LISTEN("AUDIO_LISTEN");
+	AUDIO_LISTEN("AUDIO_LISTEN"),
+
+	/**
+	 * 音频魔法箱
+	 */
+	AUDIO_MAGIC("AUDIO_MAGIC");
 
 	/**
 	 * 值

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQQueueConstant.java

@@ -16,6 +16,11 @@ public class MQQueueConstant {
 	public static final String TEMPLATE = "templateQueue";
 
 	/**
+	 * 音频配音(MP3)
+	 */
+	public static final String DUBBING = "dubbingQueue";
+
+	/**
 	 * 文件转码(PDF、OFFICE)
 	 */
 	public static final String TRANSCODE = "transcodeQueue";
@@ -86,6 +91,11 @@ public class MQQueueConstant {
 	public static final String CONVERT_TO_AUDIOLESSON = "convert2AudioLessonQueue";
 
 	/**
+	 * 文件转码结束(音视频)->音频课/纯听
+	 */
+	public static final String CONVERT_TO_AUDIOMAGIC = "convert2AudioMagicQueue";
+
+	/**
 	 * 数据埋点
 	 */
 	public static final String FRONT_EVENT = "frontEventQueue";
@@ -150,4 +160,9 @@ public class MQQueueConstant {
 	 */
 	public static final String DEAD = "rays.dlq";
 
+	/**
+	 * 待办事项数量统计
+	 */
+	public static final String BACKLOG = "backlogQueue";
+
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/MQTopicProducer.java

@@ -17,6 +17,11 @@ public class MQTopicProducer {
     public static final String FILE_TRANSCODE = "topic.fileTranscode";
 
 	/**
+	 * 音频配音结束(MP3)
+	 */
+	public static final String FILE_DUBBING = "topic.fileDubbing";
+
+	/**
 	 * 报名新增用户
 	 */
 	public static final String BM_ADD_USER = "topic.bmAddUser";
@@ -70,7 +75,14 @@ public class MQTopicProducer {
      * TIP
      */
     public static final String TIP = "topic.tip";
-
+    /**
+     * 打赏给读者
+     */
+    public static final String TIP_FOR_WECHAT_USER = "topic.tipForWechatUser";
+	/**
+	 * GENUINE
+	 */
+	public static final String GENUINE = "topic.genuine";
 	/**
      * 订单完成
      */
@@ -267,6 +279,11 @@ public class MQTopicProducer {
     public static final String RECORD_USER_HABIT = "topic.recordUserHabit";
 
 	/**
+	 * 扫码
+	 */
+	public static final String SCAN_QRCODE = "topic.scanQrcode";
+
+	/**
 	 * topic交换机名称(勿改)
 	 */
 	public static final String EXCHAGE = "rays.topic";
@@ -275,4 +292,14 @@ public class MQTopicProducer {
      * 更新图书封面图
      */
     public static final String UPDATE_BOOK_COVERIMG = "topic.updateBookCoverImg";
+
+    /**
+     * 微信用户关系
+     */
+    public static final String WECHAT_RELATE_INFO = "topic.wechatRelateInfo";
+
+	/**
+	 * 更新用户头像
+	 */
+	public static final String UPDATE_USER_HEADURL = "topic.updateUserHeadUrl";
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/ProductTypeConstant.java

@@ -223,6 +223,21 @@ public class ProductTypeConstant {
     public static final String EBOOK_APP = "EBOOK_APP";
 
     /**
+     * 亲子伴读魔法箱
+     */
+    public static final String AUDIO_MAGIC = "AUDIO_MAGIC";
+
+    /**
+     * 音频课
+     */
+    public static final String AUDIO_SCHEDULE = "AUDIO_SCHEDULE";
+
+    /**
+     * 音频课程
+     */
+    public static final String AUDIO_COURSE = "AUDIO_COURSE";
+
+    /**
      * 热门作品类型
      */
     public static final String[] HOT_PRODUCT_TYPE = {QA, PDF, VIDEO, PRETEST};
@@ -231,7 +246,7 @@ public class ProductTypeConstant {
      * 资源型作品（免费即可体验）
      */
     public static final String[] RESOURCE_PRODUCT = {AUDIO, VIDEO, PDF, EBOOK, ALBUM, PRETEST, QANEWS,
-            FORMAT, WORD, ARTICLE, LISTEN, SCHEDULE, PBMUSIC, TUTORIAL, VIDEO_SCHEDULE};
+            FORMAT, WORD, ARTICLE, LISTEN, SCHEDULE, PBMUSIC, TUTORIAL, VIDEO_SCHEDULE, AUDIO_SCHEDULE};
 
     /**
      * 参与促销激励作品
@@ -248,11 +263,16 @@ public class ProductTypeConstant {
      * 应用型作品（伴随应用使用）
      */
     public static final String[] APP_PRODUCT = {LOOK, LIVE, TUTOR, GROUP, ZSCORE, VOTE, CLOCK, TEST, AUDIOAPP, ANSWER,
-            EF, MUSIC, VIDEO_COURSE, PRETESTAPP, AUDIO_RESOURCE, QA_APP, EBOOK_APP};
+            EF, MUSIC, VIDEO_COURSE, PRETESTAPP, AUDIO_RESOURCE, QA_APP, EBOOK_APP, AUDIO_MAGIC};
 
     /**
      * 数据平台埋点型作品
      */
     public static final String[] TRACK_PRODUCT = {COMMON, AUDIO, VIDEO, PDF, EBOOK, BOOK, MATCH, ALBUM, NUMBER, MEMBER,
             PRETEST, QANEWS, REVIEW, TOOL, QS, FORMAT, WORD, ARTICLE};
+
+    /**
+     * 作品下资源来源于content中心的作品
+     */
+    public static final String[] RESOURCE_CONTENT_PRODUCT = {AUDIO,VIDEO,BOOK,LISTEN,PDF,ALBUM,FORMAT,EBOOK};
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/RoleCodeEnum.java

@@ -14,7 +14,8 @@ public enum RoleCodeEnum {
 	merchant("merchant"), 	// 商户
 	channel("channel"), 	// 渠道
 	agent("agent"), 		// 代理
-	adviser("adviser"); 	// 顾问
+	adviser("adviser"), 	// 顾问
+	platform("platform"); 	// 平台
 
 	/**
 	 * 值

pcloud-common-core/src/main/java/com/pcloud/common/core/constant/WeektaskCode.java

@@ -48,6 +48,8 @@ public enum WeektaskCode {
     UPDATE_BOOK_INFO("update_book_info"),
     //调整应用顺序
     SET_STEP("set_step"),
+    //确定回复
+    DEFINITE_REPLY("definite_reply"),
     /**
      * -------通用埋点------
      */
@@ -139,6 +141,15 @@ public enum WeektaskCode {
     C_PUBLISH_DYNAMIC("c_publish_dynamic"),
 	  //专题问答设置免费
     SET_FREE("set_free"),
+    //选择性格心理类场景
+    CREATE_TEST_CHARACTER("create_test_character"),
+    //选择知识抢答类场景
+    CREATE_TEST_RESPONDER("create_test_responder"),
+    //读者圈中加入直播课程
+    W_POST_LIVEAPP_NOTE("w_post_liveapp_note"),
+    //创建专题扩展应用新增栏目
+    NEW_COLUMN("new_column"),
+
     //----------------------------------成就任务-------------------
     /**
      * 读者在读者圈中发动态
@@ -651,6 +662,62 @@ public enum WeektaskCode {
      *创建抽奖应用
      */
     W5_CREATE_DRAW_APP("w5_create_draw_app"),
+    /**
+     *预览效果
+     */
+    W5_CONFIGURE_NEWS("w5_configure_news"),
+    /**
+     *分享排名
+     */
+    W5_SHARE_RANK("w5_share_rank"),
+    /**
+     * 新增性格心理类场景应用(周E3)
+     */
+    W5_CREATE_TEST_CHARACTER("w5_create_test_character"),
+    /**
+     * 新增知识抢答类场景应用（周F3）
+     */
+    W5_CREATE_TEST_RESPONDER("w5_create_test_responder"),
+    /**
+     * 新建直播课应用（周E4）
+     */
+    W5_CREATE_RELATE_LIVEAPP("w5_create_relate_liveapp"),
+    /**
+     * 新建读者交流圈应用（周E5）
+     */
+    W5_CREATE_RELATE_GROUP("w5_create_relate_group"),
+    /**
+     * 新建读书卡片应用（周E6）
+     */
+    W5_CREATE_BOOKCARD("w5_create_bookcard"),
+    /**
+     * 新建电子书应用（周E7）
+     */
+    W5_CREATE_EBOOK("w5_create_ebook"),
+    /**
+     * 新建分数排名应用（周F6）
+     */
+    W5_CREATE_SCORE_APP("w5_create_score_app"),
+    /**
+     * 新建专题扩展应用（周F7）
+     */
+    W5_CREATE_SPECIAL_APP("w5_create_special_app"),
+    /**
+     * 新建作者留言应用（周F8）
+     */
+    W5_CREATE_VOICE_APP("w5_create_voice_app"),
+    /**
+     * 新建报名应用（周F9）
+     */
+    W5_CREATE_BM_APP("w5_create_bm_app"),
+    /**
+     * 新建专家咨询应用（周F4）
+     */
+    W5_CREATE_QA_APP("w5_create_qa_app"),
+    /**
+     *体验专家咨询应用（周F5）
+     */
+    W5_EXPERIENCE_CONSULTING("w5_experience_consulting"),
     ;
 
     public final String code;

pcloud-common-core/src/main/java/com/pcloud/common/core/datasource/DataSourceConfig.java

@@ -16,6 +16,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Primary;
@@ -25,65 +26,48 @@ import org.springframework.jdbc.datasource.DataSourceTransactionManager;
 import com.alibaba.druid.pool.DruidDataSource;
 
 @Configuration
-@MapperScan(basePackages = DataSourceConfig.PACKAGE,sqlSessionFactoryRef = "sqlSessionFactory")
+@ConfigurationProperties(prefix = "spring.datasource")
+@MapperScan(basePackages = DataSourceConfig.PACKAGE, sqlSessionFactoryRef = "sqlSessionFactory")
 public class DataSourceConfig {
 	private Logger logger = LoggerFactory.getLogger(DataSourceConfig.class);
 
 	static final String PACKAGE = "com.pcloud.common.core.dao";
 
-    @Value("${spring.datasource.url}")
-    private String dbUrl;
+	private String url;
 
-    @Value("${spring.datasource.type}")
-    private String dbType;
+	private String type;
 
-    @Value("${spring.datasource.username}")
 	private String username;
 
-    @Value("${spring.datasource.password}")
 	private String password;
 
-    @Value("${spring.datasource.driver-class-name}")
 	private String driverClassName;
 
-    @Value("${spring.datasource.initialSize}")
 	private int initialSize;
 
-    @Value("${spring.datasource.minIdle}")
 	private int minIdle;
 
-    @Value("${spring.datasource.maxActive}")
 	private int maxActive;
 
-    @Value("${spring.datasource.maxWait}")
 	private int maxWait;
 
-    @Value("${spring.datasource.timeBetweenEvictionRunsMillis}")
 	private int timeBetweenEvictionRunsMillis;
 
-    @Value("${spring.datasource.minEvictableIdleTimeMillis}")
 	private int minEvictableIdleTimeMillis;
 
-    @Value("${spring.datasource.validationQuery}")
 	private String validationQuery;
 
-    @Value("${spring.datasource.testWhileIdle}")
 	private boolean testWhileIdle;
 
-    @Value("${spring.datasource.testOnBorrow}")
 	private boolean testOnBorrow;
 
-    @Value("${spring.datasource.testOnReturn}")
 	private boolean testOnReturn;
 
-    @Value("${spring.datasource.poolPreparedStatements}")
 	private boolean poolPreparedStatements;
 
-    @Value("${spring.datasource.filters}")
-    private String filters;
+	private String filtersNew;
 
-    @Value("${spring.datasource.connectionProperties}")
-    private String connectionProperties;
+	private String connectionPropertiesNew;
 
 	@Value("${mybatis.mapper-locations}")
 	private String mapperLocations;
@@ -91,22 +75,22 @@ public class DataSourceConfig {
 	@Value("${mybatis.type-aliases-package}")
 	private String typeAliasesPackage;
 
-//    @Value("${spring.datasource.useGlobalDataSourceStat}")
-//    private boolean useGlobalDataSourceStat;
-//
-//    @Value("${spring.datasource.druidLoginName}")
-//    private String druidLoginName;
-//
-//    @Value("${spring.datasource.druidPassword}")
-//    private String druidPassword;
-
-    @Bean(name="druidDataSource")
-    @Primary //不要漏了这
-    public DataSource dataSource(){
+	// @Value("${spring.datasource.useGlobalDataSourceStat}")
+	// private boolean useGlobalDataSourceStat;
+	//
+	// @Value("${spring.datasource.druidLoginName}")
+	// private String druidLoginName;
+	//
+	// @Value("${spring.datasource.druidPassword}")
+	// private String druidPassword;
+
+	@Bean(name = "druidDataSource")
+	@Primary // 不要漏了这
+	public DataSource dataSource() {
 		DruidDataSource datasource = new DruidDataSource();
 		try {
-            datasource.setUrl(this.dbUrl);
-            datasource.setDbType(dbType);
+			datasource.setUrl(url);
+			datasource.setDbType(type);
 			datasource.setUsername(username);
 			datasource.setPassword(password);
 			datasource.setDriverClassName(driverClassName);
@@ -121,9 +105,9 @@ public class DataSourceConfig {
 			datasource.setTestOnBorrow(testOnBorrow);
 			datasource.setTestOnReturn(testOnReturn);
 			datasource.setPoolPreparedStatements(poolPreparedStatements);
-            datasource.setFilters(filters);
-            datasource.setConnectionProperties(connectionProperties);
-//            datasource.setUseGlobalDataSourceStat(useGlobalDataSourceStat);
+			datasource.setFilters(filtersNew);
+			datasource.setConnectionProperties(connectionPropertiesNew);
+			// datasource.setUseGlobalDataSourceStat(useGlobalDataSourceStat);
 			ArrayList<String> arr = new ArrayList<>();
 			arr.add("set names utf8mb4;");
 			datasource.setConnectionInitSqls(arr);
@@ -139,7 +123,6 @@ public class DataSourceConfig {
 		return new DataSourceTransactionManager(dataSource());
 	}
 
-
 	@Bean(name = "sqlSessionFactory")
 	@Autowired
 	public SqlSessionFactory sqlSessionFactory(ExecutorInterceptor interceptor) throws Exception {
@@ -149,7 +132,7 @@ public class DataSourceConfig {
 		sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(mapperLocations));
 		sessionFactoryBean.setVfs(SpringBootVFS.class);
 		sessionFactoryBean.setTypeAliasesPackage(typeAliasesPackage);
-        sessionFactoryBean.setPlugins(new Interceptor[]{interceptor});
+		sessionFactoryBean.setPlugins(new Interceptor[] { interceptor });
 		return sessionFactoryBean.getObject();
 	}
 
@@ -160,4 +143,165 @@ public class DataSourceConfig {
 		final SqlSessionTemplate sessionFactoryBean = new SqlSessionTemplate(sqlSessionFactory(interceptor));
 		return sessionFactoryBean;
 	}
+
+	public String getUrl() {
+		return url;
+	}
+
+	public void setUrl(String url) {
+		this.url = url;
+	}
+
+	public String getType() {
+		return type;
+	}
+
+	public void setType(String type) {
+		this.type = type;
+	}
+
+	public String getUsername() {
+		return username;
+	}
+
+	public void setUsername(String username) {
+		this.username = username;
+	}
+
+	public String getPassword() {
+		return password;
+	}
+
+	public void setPassword(String password) {
+		this.password = password;
+	}
+
+	public String getDriverClassName() {
+		return driverClassName;
+	}
+
+	public void setDriverClassName(String driverClassName) {
+		this.driverClassName = driverClassName;
+	}
+
+	public int getInitialSize() {
+		return initialSize;
+	}
+
+	public void setInitialSize(int initialSize) {
+		this.initialSize = initialSize;
+	}
+
+	public int getMinIdle() {
+		return minIdle;
+	}
+
+	public void setMinIdle(int minIdle) {
+		this.minIdle = minIdle;
+	}
+
+	public int getMaxActive() {
+		return maxActive;
+	}
+
+	public void setMaxActive(int maxActive) {
+		this.maxActive = maxActive;
+	}
+
+	public int getMaxWait() {
+		return maxWait;
+	}
+
+	public void setMaxWait(int maxWait) {
+		this.maxWait = maxWait;
+	}
+
+	public int getTimeBetweenEvictionRunsMillis() {
+		return timeBetweenEvictionRunsMillis;
+	}
+
+	public void setTimeBetweenEvictionRunsMillis(int timeBetweenEvictionRunsMillis) {
+		this.timeBetweenEvictionRunsMillis = timeBetweenEvictionRunsMillis;
+	}
+
+	public int getMinEvictableIdleTimeMillis() {
+		return minEvictableIdleTimeMillis;
+	}
+
+	public void setMinEvictableIdleTimeMillis(int minEvictableIdleTimeMillis) {
+		this.minEvictableIdleTimeMillis = minEvictableIdleTimeMillis;
+	}
+
+	public String getValidationQuery() {
+		return validationQuery;
+	}
+
+	public void setValidationQuery(String validationQuery) {
+		this.validationQuery = validationQuery;
+	}
+
+	public boolean isTestWhileIdle() {
+		return testWhileIdle;
+	}
+
+	public void setTestWhileIdle(boolean testWhileIdle) {
+		this.testWhileIdle = testWhileIdle;
+	}
+
+	public boolean isTestOnBorrow() {
+		return testOnBorrow;
+	}
+
+	public void setTestOnBorrow(boolean testOnBorrow) {
+		this.testOnBorrow = testOnBorrow;
+	}
+
+	public boolean isTestOnReturn() {
+		return testOnReturn;
+	}
+
+	public void setTestOnReturn(boolean testOnReturn) {
+		this.testOnReturn = testOnReturn;
+	}
+
+	public boolean isPoolPreparedStatements() {
+		return poolPreparedStatements;
+	}
+
+	public void setPoolPreparedStatements(boolean poolPreparedStatements) {
+		this.poolPreparedStatements = poolPreparedStatements;
+	}
+
+	public String getFiltersNew() {
+		return filtersNew;
+	}
+
+	public void setFiltersNew(String filtersNew) {
+		this.filtersNew = filtersNew;
+	}
+
+	public String getConnectionPropertiesNew() {
+		return connectionPropertiesNew;
+	}
+
+	public void setConnectionPropertiesNew(String connectionPropertiesNew) {
+		this.connectionPropertiesNew = connectionPropertiesNew;
+	}
+
+	public String getMapperLocations() {
+		return mapperLocations;
+	}
+
+	public void setMapperLocations(String mapperLocations) {
+		this.mapperLocations = mapperLocations;
+	}
+
+	public String getTypeAliasesPackage() {
+		return typeAliasesPackage;
+	}
+
+	public void setTypeAliasesPackage(String typeAliasesPackage) {
+		this.typeAliasesPackage = typeAliasesPackage;
+	}
+
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/BacklogQueueDto.java

+package com.pcloud.common.core.dto;
+
+import java.io.Serializable;
+
+/**
+ * @描述：待办事务统计
+ * @作者：zhuyajie
+ * @创建时间：10:36 2018/10/31
+ * @版本：1.0
+ */
+public class BacklogQueueDto implements Serializable{
+
+    /**
+     * 编辑id
+     */
+    private Long adviserId;
+
+    /**
+     * 应用id或商品id
+     */
+    private Long targetId;
+    /**
+     *类型（APP/PRODUCT）
+     */
+    private String targetType;
+    /**
+     *封面图
+     */
+    private String coverImg;
+    /**
+     *标题
+     */
+    private String title;
+    /**
+     *待审核/确认数量
+     */
+    private Integer waitCount;
+    /**
+     *新动态数量
+     */
+    private Integer newCount;
+    /**
+     *应用/商品类型编码
+     */
+    private String typeCode;
+
+    public Long getAdviserId() {
+        return adviserId;
+    }
+
+    public void setAdviserId(Long adviserId) {
+        this.adviserId = adviserId;
+    }
+
+    public Long getTargetId() {
+        return targetId;
+    }
+
+    public void setTargetId(Long targetId) {
+        this.targetId = targetId;
+    }
+
+    public String getTargetType() {
+        return targetType;
+    }
+
+    public void setTargetType(String targetType) {
+        this.targetType = targetType;
+    }
+
+    public String getCoverImg() {
+        return coverImg;
+    }
+
+    public void setCoverImg(String coverImg) {
+        this.coverImg = coverImg;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public Integer getWaitCount() {
+        return waitCount;
+    }
+
+    public void setWaitCount(Integer waitCount) {
+        this.waitCount = waitCount;
+    }
+
+    public Integer getNewCount() {
+        return newCount;
+    }
+
+    public void setNewCount(Integer newCount) {
+        this.newCount = newCount;
+    }
+
+    public String getTypeCode() {
+        return typeCode;
+    }
+
+    public void setTypeCode(String typeCode) {
+        this.typeCode = typeCode;
+    }
+
+    @Override
+    public String toString() {
+        return "BacklogQueueDto{" +
+                "adviserId=" + adviserId +
+                ", targetId=" + targetId +
+                ", targetType='" + targetType + '\'' +
+                ", coverImg='" + coverImg + '\'' +
+                ", title='" + title + '\'' +
+                ", waitCount=" + waitCount +
+                ", newCount=" + newCount +
+                ", typeCode='" + typeCode + '\'' +
+                '}';
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/ConvertQueueDto.java

@@ -9,6 +9,7 @@ import java.io.Serializable;
 
 /**
  * @描述：
+ * 
  * @作者：songx
  * @创建时间：2017年2月27日,上午11:23:29 @版本：1.0
  */
@@ -41,6 +42,11 @@ public class ConvertQueueDto implements Serializable {
 	private String customType;
 
 	/**
+	 * 视频截图时间点
+	 */
+	private int snapshotTime;
+
+	/**
 	 * 来源标识
 	 */
 	private Long fromId;
@@ -90,6 +96,14 @@ public class ConvertQueueDto implements Serializable {
 	 */
 	private String m3u8Url;
 
+	public int getSnapshotTime() {
+		return snapshotTime;
+	}
+
+	public void setSnapshotTime(int snapshotTime) {
+		this.snapshotTime = snapshotTime;
+	}
+
 	public String getCustomType() {
 		return customType;
 	}
@@ -186,7 +200,8 @@ public class ConvertQueueDto implements Serializable {
 	}
 
 	/**
-     * @param fileUrl The fileUrl to set.
+	 * @param fileUrl
+	 *            The fileUrl to set.
 	 */
 	public void setFileUrl(String fileUrl) {
 		this.fileUrl = fileUrl;
@@ -200,7 +215,8 @@ public class ConvertQueueDto implements Serializable {
 	}
 
 	/**
-     * @param fileSize The fileSize to set.
+	 * @param fileSize
+	 *            The fileSize to set.
 	 */
 	public void setFileSize(Long fileSize) {
 		this.fileSize = fileSize;

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/SendAppMessageDto.java

@@ -32,6 +32,14 @@ public class SendAppMessageDto implements Serializable{
 	 * 模板参数
 	 */
 	private Map<String, Object> paramKeyMap;
+	/**
+	 * 设备类型
+	 */
+	private String deviceType;
+	/**
+	 * 应用id
+	 */
+	private Long appId;
 	
 	public String getRegistrationId() {
 		return registrationId;
@@ -64,12 +72,35 @@ public class SendAppMessageDto implements Serializable{
 	public void setIsNow(Boolean isNow) {
 		this.isNow = isNow;
 	}
+
+	public String getDeviceType() {
+		return deviceType;
+	}
+
+	public void setDeviceType(String deviceType) {
+		this.deviceType = deviceType;
+	}
+
+	public Long getAppId() {
+		return appId;
+	}
+
+	public void setAppId(Long appId) {
+		this.appId = appId;
+	}
+
 	@Override
 	public String toString() {
-		return "SendAppMessageDto [registrationId=" + registrationId + ", adviserId=" + adviserId + ", typeCode="
-				+ typeCode + ", isNow=" + isNow + ", paramKeyMap=" + paramKeyMap + "]";
+		return "SendAppMessageDto{" +
+				"registrationId='" + registrationId + '\'' +
+				", adviserId=" + adviserId +
+				", typeCode='" + typeCode + '\'' +
+				", isNow=" + isNow +
+				", paramKeyMap=" + paramKeyMap +
+				", deviceType='" + deviceType + '\'' +
+				", appId=" + appId +
+				'}';
 	}
 
 
-	
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/dubbing/AudioDTO.java

+/**
+ * 
+ */
+package com.pcloud.common.core.dto.dubbing;
+
+import java.io.Serializable;
+
+import com.alibaba.fastjson.JSONObject;
+
+/**
+ * 
+ * @author：songx
+ * @date：2018年12月5日,下午5:07:40
+ */
+public class AudioDTO implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 1217229671463911762L;
+
+	/**
+	 * 文件名称
+	 */
+	private String fileName;
+
+	/**
+	 * 时长
+	 */
+	private int duration;
+
+	/**
+	 * 文件地址
+	 */
+	private String fileUrl;
+
+	/**
+	 * 文件大小
+	 */
+	private long fileSize;
+
+	/**
+	 * 语音文件插入时间点
+	 */
+	private int start;
+
+	/**
+	 * id
+	 */
+	private int id;
+
+	public long getFileSize() {
+		return fileSize;
+	}
+
+	public void setFileSize(long fileSize) {
+		this.fileSize = fileSize;
+	}
+
+	public int getId() {
+		return id;
+	}
+
+	public void setId(int id) {
+		this.id = id;
+	}
+
+	public String getFileName() {
+		return fileName;
+	}
+
+	public void setFileName(String fileName) {
+		this.fileName = fileName;
+	}
+
+	public int getDuration() {
+		return duration;
+	}
+
+	public void setDuration(int duration) {
+		this.duration = duration;
+	}
+
+	public String getFileUrl() {
+		return fileUrl;
+	}
+
+	public void setFileUrl(String fileUrl) {
+		this.fileUrl = fileUrl;
+	}
+
+	public int getStart() {
+		return start;
+	}
+
+	public void setStart(int start) {
+		this.start = start;
+	}
+
+	@Override
+	public String toString() {
+		return "DubbingResultDTO : " + JSONObject.toJSONString(this);
+	}
+
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/dubbing/DubbingDTO.java

+package com.pcloud.common.core.dto.dubbing;
+
+import java.io.Serializable;
+import java.util.List;
+
+import com.alibaba.fastjson.JSONObject;
+
+/**
+ * 绘本配音资源DTO
+ * 
+ * @author：songx
+ * @date：2018年12月5日,上午10:07:26
+ */
+public class DubbingDTO implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = -5639047705106025465L;
+
+	/**
+	 * 用户添加的问题文本(不超过5条)
+	 */
+	private List<SpeechDTO> speechDTOs;
+
+	/**
+	 * 待合成的背景音乐URL(不超过4条)
+	 */
+	private String[] bgms;
+
+	/**
+	 * 录音文件地址
+	 */
+	private String soundUrl;
+
+	/**
+	 * 来源类型
+	 */
+	private String fromType;
+
+	/**
+	 * 导语
+	 */
+	private String beforeText;
+
+	/**
+	 * 结束语
+	 */
+	private String afterText;
+
+	/**
+	 * 应用ID
+	 */
+	private Long appId;
+
+	/**
+	 * 编辑ID
+	 */
+	private Long adviserId;
+
+	/**
+	 * 音乐ID
+	 */
+	private Long musicId;
+
+	public String getSoundUrl() {
+		return soundUrl;
+	}
+
+	public void setSoundUrl(String soundUrl) {
+		this.soundUrl = soundUrl;
+	}
+
+	public String getFromType() {
+		return fromType;
+	}
+
+	public void setFromType(String fromType) {
+		this.fromType = fromType;
+	}
+
+	public String getBeforeText() {
+		return beforeText;
+	}
+
+	public void setBeforeText(String beforeText) {
+		this.beforeText = beforeText;
+	}
+
+	public String getAfterText() {
+		return afterText;
+	}
+
+	public void setAfterText(String afterText) {
+		this.afterText = afterText;
+	}
+
+	public Long getAppId() {
+		return appId;
+	}
+
+	public void setAppId(Long appId) {
+		this.appId = appId;
+	}
+
+	public Long getAdviserId() {
+		return adviserId;
+	}
+
+	public void setAdviserId(Long adviserId) {
+		this.adviserId = adviserId;
+	}
+
+	public Long getMusicId() {
+		return musicId;
+	}
+
+	public void setMusicId(Long musicId) {
+		this.musicId = musicId;
+	}
+
+	public List<SpeechDTO> getSpeechDTOs() {
+		return speechDTOs;
+	}
+
+	public void setSpeechDTOs(List<SpeechDTO> speechDTOs) {
+		this.speechDTOs = speechDTOs;
+	}
+
+	public String[] getBgms() {
+		return bgms;
+	}
+
+	public void setBgms(String[] bgms) {
+		this.bgms = bgms;
+	}
+
+	@Override
+	public String toString() {
+		return "DubbingDTO : " + JSONObject.toJSONString(this);
+	}
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/dubbing/DubbingResultDTO.java

+package com.pcloud.common.core.dto.dubbing;
+
+import com.alibaba.fastjson.JSONObject;
+import com.pcloud.common.core.dto.dubbing.AudioDTO;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 绘本配音资源DTO
+ * 
+ * @author：songx
+ * @date：2018年12月5日,上午10:07:26
+ */
+public class DubbingResultDTO implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = 2458000180158610651L;
+
+	/**
+	 * 来源类型
+	 */
+	private String fromType;
+
+	/**
+	 * 语音文件
+	 */
+	private List<AudioDTO> speechs;
+
+	/**
+	 * 混合音频
+	 */
+	private AudioDTO mixAudio;
+
+	/**
+	 * 应用ID
+	 */
+	private Long appId;
+
+	/**
+	 * 编辑ID
+	 */
+	private Long adviserId;
+
+	/**
+	 * 音乐ID
+	 */
+	private Long musicId;
+
+	public String getFromType() {
+		return fromType;
+	}
+
+	public void setFromType(String fromType) {
+		this.fromType = fromType;
+	}
+
+	public Long getAppId() {
+		return appId;
+	}
+
+	public void setAppId(Long appId) {
+		this.appId = appId;
+	}
+
+	public Long getAdviserId() {
+		return adviserId;
+	}
+
+	public void setAdviserId(Long adviserId) {
+		this.adviserId = adviserId;
+	}
+
+	public Long getMusicId() {
+		return musicId;
+	}
+
+	public void setMusicId(Long musicId) {
+		this.musicId = musicId;
+	}
+
+	public List<AudioDTO> getSpeechs() {
+		return speechs;
+	}
+
+	public void setSpeechs(List<AudioDTO> speechs) {
+		this.speechs = speechs;
+	}
+
+	public AudioDTO getMixAudio() {
+		return mixAudio;
+	}
+
+	public void setMixAudio(AudioDTO mixAudio) {
+		this.mixAudio = mixAudio;
+	}
+
+	@Override
+	public String toString() {
+		return "DubbingResultDTO : " + JSONObject.toJSONString(this);
+	}
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/dto/dubbing/SpeechDTO.java

+/**
+ * 
+ */
+package com.pcloud.common.core.dto.dubbing;
+
+import java.io.Serializable;
+
+import com.alibaba.fastjson.JSONObject;
+
+/**
+ * 
+ * @author：songx
+ * @date：2018年12月5日,下午5:05:57
+ */
+public class SpeechDTO implements Serializable{
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = -5054460976926789378L;
+
+	/**
+	 * 文本内容
+	 */
+	private String text;
+
+	/**
+	 * id
+	 */
+	private int id;
+
+	public String getText() {
+		return text;
+	}
+
+	public void setText(String text) {
+		this.text = text;
+	}
+
+	public int getId() {
+		return id;
+	}
+
+	public void setId(int id) {
+		this.id = id;
+	}
+
+	@Override
+	public String toString() {
+		return "SpeechDTO : " + JSONObject.toJSONString(this);
+	}
+
+}
\ No newline at end of file

pcloud-common-core/src/main/java/com/pcloud/common/core/enums/BacklogTypeEnum.java

+package com.pcloud.common.core.enums;
+
+/**
+ * @描述：代办事务类型
+ * @作者：zhuyajie
+ * @创建时间：10:54 2018/10/31
+ * @版本：1.0
+ */
+public enum BacklogTypeEnum {
+    /**
+     * 应用
+     */
+    APP("APP"),
+
+    /**
+     * 作品
+     */
+    PRODUCT("PRODUCT");
+
+    private String value;
+
+    public String getValue() {
+        return value;
+    }
+
+    BacklogTypeEnum(String value) {
+        this.value = value;
+    }
+}

pcloud-common-core/src/main/java/com/pcloud/common/core/enums/TranscodeFromEnum.java

@@ -42,7 +42,17 @@ public enum TranscodeFromEnum {
 	/**
 	 * 直播
 	 */
-	LIVE_HOMEWORD("LIVE_HOMEWORD");
+	LIVE_HOMEWORD("LIVE_HOMEWORD"),
+
+	/**
+	 * 音频
+	 */
+	AUDIOAPP_PDF("AUDIOAPP_PDF"),
+
+	/**
+	 * 文件管理中心
+	 */
+	CONVERT_PDF("CONVERT_PDF");
 
 	/**
 	 * 值

pcloud-common-core/src/main/java/com/pcloud/common/core/exception/GlobalExceptionHandler.java

@@ -9,7 +9,10 @@ import org.slf4j.LoggerFactory;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.converter.HttpMessageNotReadableException;
+import org.springframework.validation.BindingResult;
+import org.springframework.validation.FieldError;
 import org.springframework.web.HttpRequestMethodNotSupportedException;
+import org.springframework.web.bind.MethodArgumentNotValidException;
 import org.springframework.web.bind.ServletRequestBindingException;
 import org.springframework.web.bind.annotation.ControllerAdvice;
 import org.springframework.web.bind.annotation.ExceptionHandler;
@@ -22,6 +25,8 @@ import com.pcloud.common.permission.PermissionException;
 import feign.FeignException;
 import org.springframework.web.method.annotation.MethodArgumentTypeMismatchException;
 
+import java.util.List;
+
 /**
  * 
  * @描述：异常集中处理
@@ -92,6 +97,23 @@ public class GlobalExceptionHandler {
 			LOGGER.warn("【响应未结束】" + exception.getMessage(), exception);
 			return new ResponseEntity<>("响应未结束!", HttpStatus.OK);
 		}
+		else if (exception instanceof MethodArgumentNotValidException) {
+			LOGGER.info("【参数异常】" + exception.getMessage(), exception);
+			MethodArgumentNotValidException methodArgumentNotValidException = (MethodArgumentNotValidException) exception;
+			ResponseDto<Object> responseDto = new ResponseDto<>();
+			BindingResult bindingResult = methodArgumentNotValidException.getBindingResult();
+			String resultMessage = "参数异常:";
+			List<FieldError> fieldErrors = bindingResult.getFieldErrors();
+			for (int i = 0;i<fieldErrors.size();i++) {
+				if(fieldErrors.size()==1 || i == fieldErrors.size()-1){
+					resultMessage += fieldErrors.get(i).getDefaultMessage();
+				}else {
+					resultMessage += fieldErrors.get(i).getDefaultMessage() + ", ";
+				}
+			}
+			responseDto.setMessage(resultMessage);
+			return new ResponseEntity<>(responseDto, HttpStatus.OK);
+		}
 		// 业务异常
 		else if (exception instanceof BizException) {
 			LOGGER.info("【业务异常】" + exception.getMessage(), exception);

pcloud-common/pom.xml

@@ -178,6 +178,10 @@
 			<artifactId>httpcore</artifactId>
 		</dependency>
 		<dependency>
+			<groupId>org.apache.httpcomponents</groupId>
+			<artifactId>httpmime</artifactId>
+		</dependency>
+		<dependency>
 			<groupId>redis.clients</groupId>
 			<artifactId>jedis</artifactId>
 		</dependency>
@@ -291,13 +295,6 @@
 			<artifactId>aliyun-java-sdk-mts</artifactId>
 		</dependency>
 
-		<!-- solr add by gaop at 2018-4-23 11:33:47 -->
-		<dependency>
-			<groupId>org.springframework.data</groupId>
-			<artifactId>spring-data-solr</artifactId>
-		</dependency>
-		<!-- end -->
-
 		<!-- Jackson Begin -->
 		<dependency>
 			<groupId>org.codehaus.jackson</groupId>
@@ -387,6 +384,12 @@
 			<version>2.0</version>
 		</dependency>
 
+		<!-- util sdk -->
+		<dependency>
+			<groupId>com.dcg.sdk</groupId>
+			<artifactId>util-sdk</artifactId>
+			<version>1.0.0</version>
+		</dependency>
 	</dependencies>
 
 </project>

pcloud-common/src/main/java/com/pcloud/common/entity/BasePageRequestVO.java

+package com.pcloud.common.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+
+/**
+ * @author peidawei
+ * @version 1.0.0
+ * @package com.pcloud.common.entity
+ * @className BasePageRequestVO
+ * @description 分页请求VO基类
+ * @date 2018年11月29日 下午 14:46
+ */
+@ApiModel("分页请求VO基类")
+public class BasePageRequestVO implements Serializable {
+    private static final long serialVersionUID = -4034188768789093041L;
+
+    @ApiModelProperty(hidden = true)
+    private Long userId;
+
+    @ApiModelProperty("每页多少条")
+    private Integer numPerPage;
+
+    @ApiModelProperty("当前页")
+    private Integer currentPage;
+
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
+
+    public Integer getNumPerPage() {
+        return numPerPage;
+    }
+
+    public void setNumPerPage(Integer numPerPage) {
+        this.numPerPage = numPerPage;
+    }
+
+    public Integer getCurrentPage() {
+        return currentPage;
+    }
+
+    public void setCurrentPage(Integer currentPage) {
+        this.currentPage = currentPage;
+    }
+}

pcloud-common/src/main/java/com/pcloud/common/entity/BaseRequestVO.java

+package com.pcloud.common.entity;
+
+import io.swagger.annotations.ApiModel;
+import io.swagger.annotations.ApiModelProperty;
+
+import java.io.Serializable;
+
+/**
+ * @author peidawei
+ * @version 1.0.0
+ * @package com.pcloud.common.entity
+ * @className BaseRequestVO
+ * @description 请求VO基类
+ * @date 2018年11月29日 下午 14:44
+ */
+@ApiModel("请求VO基类")
+public class BaseRequestVO implements Serializable {
+    private static final long serialVersionUID = -1078697162056973900L;
+
+    @ApiModelProperty(hidden = true)
+    private Long userId;
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public void setUserId(Long userId) {
+        this.userId = userId;
+    }
+}

pcloud-common/src/main/java/com/pcloud/common/enums/AppTypeEnum.java

@@ -54,7 +54,8 @@ public enum AppTypeEnum {
     WISH("WISH"),// 愿望单
     LIVEAPP("LIVEAPP"),         //直播3.0
     TASTETEST("TASTETEST"),    //趣味测试
-    VIDEO_CLASSIC("VIDEO_CLASSIC");     //经典版视频
+    VIDEO_CLASSIC("VIDEO_CLASSIC"),     //经典版视频
+    AUDIO_MAGIC("AUDIO_MAGIC"); //音频伴读魔法箱
 
     /**
      * 枚举转换

pcloud-common/src/main/java/com/pcloud/common/enums/QrcodeTypeEnum.java

+package com.pcloud.common.enums;
+
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author lily
+ * @date 2018/12/6 11:36
+ */
+public enum QrcodeTypeEnum {
+
+    MAGIC("AUDIO_MAGIC", 0, "听画书", "AUDIO_MAGIC", "APP", true),
+
+    REWARD("CLOCK", 1, "打卡书", "REWARD", "APP", true),
+
+    PREVIEW_APP("VIDEO", 2, "预习课", "PREVIEW", "APP", true),
+
+    PREVIEW_PRODUCT("VIDEO_SCHEDULE", 3, "预习课", "PREVIEW", "PRODUCT", true),
+
+    ZSCORE("ZSCORE", 4, "查分书", "ZSCORE", "APP", true);
+    /**
+     * 类型
+     */
+    private String type;
+
+    private Integer value;
+
+    private String description;
+
+    private String scene;
+
+    private String typeCode;
+
+    private Boolean isNeedCover;
+
+    public static final Map<String, QrcodeTypeEnum> QRCODE_TYPE_MAP = new HashMap<>();
+
+    QrcodeTypeEnum(String type, Integer value, String description, String scene, String typeCode, Boolean isNeedCover) {
+        this.type = type;
+        this.value = value;
+        this.description = description;
+        this.scene = scene;
+        this.typeCode = typeCode;
+        this.isNeedCover = isNeedCover;
+    }
+
+    static {
+        Arrays.asList(values()).forEach((m) -> {
+            QRCODE_TYPE_MAP.put(m.type, m);
+        });
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public Integer getValue() {
+        return value;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public String getScene() {
+        return scene;
+    }
+
+    public String getTypeCode() {
+        return typeCode;
+    }
+
+    public Boolean getNeedCover() {
+        return isNeedCover;
+    }
+}

pcloud-common/src/main/java/com/pcloud/common/utils/FileUtils.java

@@ -97,60 +97,71 @@ public class FileUtils {
 	public final static String TEXT = "TEXT";
 
 	/**
+	 * OFFICE
+	 */
+	public final static String OFFICE = "OFFICE";
+
+	/**
 	 * PDF文件格式
 	 */
-    public static final String[] PDF_GATHER = {"PDF"};
+	public static final String[] PDF_GATHER = { "PDF" };
 
 	/**
 	 * XML文件格式
 	 */
-    public static final String[] XML_GATHER = {"XML"};
+	public static final String[] XML_GATHER = { "XML" };
 
 	/**
 	 * 图片文件格式
 	 */
-    public static final String[] IMAGE_GATHER = {"BMP", "JPG", "GIF", "PNG", "PCX", "TIF", "JPEG", "SVG"};
+	public static final String[] IMAGE_GATHER = { "BMP", "JPG", "GIF", "PNG", "PCX", "TIF", "JPEG", "SVG", "WEBP" };
 
 	/**
 	 * 音頻文件格式 【"LRC" 为歌词字幕（这里作为音頻文件上传）】
 	 */
-    public static final String[] AUDIO_GATHER = {"AMR", "MP3", "WMA", "WAV", "AAC", "APE", "M4A"};
+	public static final String[] AUDIO_GATHER = { "AMR", "MP3", "WMA", "WAV", "AAC", "APE", "M4A" };
 
 	/**
 	 * 視頻文件格式 【"SRT", "SSA", "SMI", "SUB" 为视频“外挂型”字幕（这里作为视频文件上传）】
 	 */
-    public static final String[] VIDEO_GATHER = {"MPG", "MPEG", "AVI", "MOV", "ASF", "WMV", "NAVI", "3GP", "MKV",
-            "FLV", "F4V", "RMVB", "RM", "MP4", "SRT", "SSA", "SMI", "SUB", "ASX", "M3U8"};
+	public static final String[] VIDEO_GATHER = { "MPG", "MPEG", "AVI", "MOV", "ASF", "WMV", "NAVI", "3GP", "MKV",
+			"FLV", "F4V", "RMVB", "RM", "MP4", "SRT", "SSA", "SMI", "SUB", "ASX", "M3U8" };
 
 	/**
 	 * 压缩包文件格式
 	 */
-    public static final String[] COMPRESS_GATHER = {"RAR", "ZIP"};
+	public static final String[] COMPRESS_GATHER = { "RAR", "ZIP" };
 
 	/**
 	 * 文件格式
 	 */
-    public static final String[] TEXT_GATHER = {"TXT", "LRC"};
+	public static final String[] TEXT_GATHER = { "TXT", "LRC" };
 
 	/**
 	 * 编辑器格式
 	 */
-    public static final String[] EDITOR_GATHER = {"DOC", "DOCX", "XLS", "XLSX", "PPT", "PPTX"};
+	public static final String[] EDITOR_GATHER = { "DOC", "DOCX", "XLS", "XLSX", "PPT", "PPTX" };
 
 	/**
 	 * word格式
 	 */
-    public static final String[] WORD_GATHER = {"DOC", "DOCX"};
+	public static final String[] WORD_GATHER = { "DOC", "DOCX" };
 
 	/**
 	 * excel格式
 	 */
-    public static final String[] EXCEL_GATHER = {"XLS", "XLSX", "XLSM", "XLT", "XLTX", "XLTM", "CSV"};
+	public static final String[] EXCEL_GATHER = { "XLS", "XLSX", "XLSM", "XLT", "XLTX", "XLTM", "CSV" };
 
 	/**
 	 * PPT格式
 	 */
-    public static final String[] PPT_GATHER = {"PPT", "PPTX"};
+	public static final String[] PPT_GATHER = { "PPT", "PPTX" };
+
+	/**
+	 * office
+	 */
+	public static final String[] OFFICE_GATHER = { "DOC", "DOCX", "PPT", "PPTX", "XLS", "XLSX", "XLSM", "XLT", "XLTX",
+			"XLTM", "CSV" };
 
 	/**
 	 * 根据文件类型获取文件分类
@@ -190,17 +201,22 @@ public class FileUtils {
 		if (Arrays.asList(EDITOR_GATHER).contains(fileType.toUpperCase())) {
 			return EDITOR;
 		}
-        // COMPRESS
+		// TEXT
 		if (Arrays.asList(TEXT_GATHER).contains(fileType.toUpperCase())) {
 			return TEXT;
 		}
+		// OFFICE
+		if (Arrays.asList(OFFICE_GATHER).contains(fileType.toUpperCase())) {
+			return OFFICE;
+		}
 		return null;
 	}
 
 	/**
 	 * 传入文件夹路径，该方法能够实现创建整个路径
 	 *
-     * @param path 文件夹路径，不包含文件名称及后缀名
+	 * @param path
+	 *            文件夹路径，不包含文件名称及后缀名
 	 */
 	public static boolean isDir(String filePath) {
 		if (StringUtil.isEmpty(filePath)) {
@@ -864,6 +880,7 @@ public class FileUtils {
 			lines.forEach(line -> {
 				result.append(line + System.lineSeparator());
 			});
+			lines.close();
 		} catch (Exception e) {
 			LOGGER.error("【文件工具】读取文件内容8.<ERROR>:" + e.getMessage(), e);
 		} finally {
@@ -877,7 +894,8 @@ public class FileUtils {
 	 * 文件剪切,网络路径、按文件大小的百分比
 	 *
 	 * @param url
-     * @param percent 1~100的整数
+	 * @param percent
+	 *            1~100的整数
 	 * @return 返回剪切后上传后的文件路径
 	 * @throws BizException
 	 */
@@ -908,7 +926,8 @@ public class FileUtils {
 	 * 文件剪切,本地路径、按百分比
 	 *
 	 * @param inputFile
-     * @param cutPercent 1~100的整数
+	 * @param cutPercent
+	 *            1~100的整数
 	 * @return 返回本地路径地址
 	 * @throws BizException
 	 */
@@ -926,8 +945,10 @@ public class FileUtils {
 	/**
 	 * 文件剪切
 	 *
-     * @param inputFile 待剪切的文件
-     * @param cutLength 剪切长度(Byte)
+	 * @param inputFile
+	 *            待剪切的文件
+	 * @param cutLength
+	 *            剪切长度(Byte)
 	 */
 	public static String clipByLength(File inputFile, long cutLength) throws BizException {
 		LOGGER.info("【文件API】文件剪切.<START>.[cutLength]=" + cutLength);

pcloud-common/src/main/java/com/pcloud/common/utils/ImageUtils.java

@@ -14,9 +14,12 @@ import javax.imageio.ImageIO;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import com.dcg.util.StringUtils;
 import com.itextpdf.text.Image;
 import com.pcloud.common.constant.AliyunConstant;
+import com.pcloud.common.constant.FilePathConst;
 import com.pcloud.common.constant.ImageConstant;
+import com.pcloud.common.entity.UploadResultInfo;
 import com.pcloud.common.enums.ImageEnum;
 import com.pcloud.common.exceptions.BizException;
 import com.pcloud.common.exceptions.FileException;
@@ -688,4 +691,37 @@ public class ImageUtils {
 		return size;
 	}
 
+	/**
+	 * 上传的图片转换成webpO
+	 * 
+	 * @param localFilePath
+	 *            源文件的本地路径
+	 * @param httpUrl
+	 *            源文件上传后的路径，主要用于子文件上传时对应http文件路径
+	 */
+	public static UploadResultInfo toWebp(String fileUrl) {
+		String fileNameAll = FileUtils.getFileNameAll(fileUrl);
+		String localFilePath = FilePathConst.DOWNLOAD_PATH + fileNameAll;
+		FileUtils.downloadFileFromUrl(fileUrl, localFilePath);
+		String tragetPath = null;
+		try {
+			tragetPath = com.dcg.util.ImageUtils.transcodeToWebp(localFilePath, 80);
+		} catch (Exception e) {
+			LOGGER.error("【IMAGE】图片转换成webp失败:" + e.getMessage(), e);
+			return null;
+		}
+		if (StringUtils.isEmpty(tragetPath)) {
+			return null;
+		}
+		try {
+			return OssUtils.uploadLocalFile4Child(tragetPath, fileUrl);
+		} catch (Exception e) {
+			LOGGER.error("【IMAGE】图片转换成webp,上传失败:" + e.getMessage(), e);
+		} finally {
+			FileUtils.deleteFile(localFilePath);
+			FileUtils.deleteFile(tragetPath);
+		}
+		return null;
+	}
+
 }

pcloud-common/src/main/java/com/pcloud/common/utils/PictureUtil.java

@@ -213,7 +213,7 @@ public class PictureUtil {
             header.put("Content-Type", "application/json");
             Map<String,String>param = new HashMap<>();
             param.put("htmlCode",html);
-            String postResult = HttpKit.post("http://192.168.92.111:8214/transcode/htm2img/jpg", JSON.toJSONString(param));
+            String postResult = HttpKit.post("http://192.168.1.7:8216/transcode/htm2img/jpg", JSON.toJSONString(param));
             Map map = JSONUtils.jsonToMap(postResult, String.class, String.class);
             String pic = (String)map.get("data");
             BufferedImage bookPicImage = ImageIO.read(new URL(pic));

pcloud-common/src/main/java/com/pcloud/common/utils/QrcodeUtils.java

@@ -21,6 +21,7 @@ import java.util.Map;
 import javax.imageio.ImageIO;
 import javax.swing.ImageIcon;
 
+import com.pcloud.common.utils.cache.redis.JedisClusterUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -215,6 +216,42 @@ public class QrcodeUtils {
 	}
 
 	/**
+	 * 创建二维码
+	 *
+	 * @param url
+	 *            二维码响应地址
+	 * @return
+	 * @throws Exception
+	 */
+	public static String createWithMargin(String url, Integer marginNum) throws BizException {
+
+		String key = "createWithMargin:"+url+"_"+marginNum;
+		if(JedisClusterUtils.exists(key)){
+			String s = JedisClusterUtils.get(key);
+			return s;
+		}else {
+			LOGGER.info("【二维码】创建二维码,<START>.[url]=" + url);
+			Map<EncodeHintType, Object> hints = new HashMap<EncodeHintType, Object>();
+			hints.put(EncodeHintType.CHARACTER_SET, "UTF-8");
+			hints.put(EncodeHintType.ERROR_CORRECTION, level);
+			hints.put(EncodeHintType.MARGIN, marginNum); // 设置白边
+			try {
+				// 生成矩阵
+				BitMatrix bitMatrix = new MultiFormatWriter().encode(url, BarcodeFormat.QR_CODE, ImageConstant.QRCODE_WITH,
+						ImageConstant.QRCODE_HEIGHT, hints);
+				BufferedImage bufferedImage = toBufferedImage(bitMatrix, onColor);
+				bufferedImage.flush();
+				String s = uploadImage(bufferedImage);
+				JedisClusterUtils.set(key,s,24*3600);
+				return s;
+			} catch (Exception e) {
+				LOGGER.error("【二维码】创建二维码失败,<ERROR>:" + e.getMessage(), e);
+				throw new FileException(FileException.FILE_UPLOAD_FAILURE, "创建二维码失败");
+			}
+		}
+	}
+
+	/**
 	 * 创建带颜色的二维码
 	 * @param url
 	 * @param onColor

pcloud-common/src/main/java/com/pcloud/common/utils/ResultUtils.java

@@ -18,6 +18,26 @@ import com.pcloud.common.page.PageBeanNew;
 public class ResultUtils {
 
 	/**
+	 * 单个对象实例化
+	 * 
+	 * @param t
+	 * @param clazz
+	 * @return
+	 * @author songx
+	 * @date 2019年1月14日,下午7:32:35
+	 */
+	public static <T> T object(T t, Class<T> clazz) {
+		if (t == null) {
+			return null;
+		}
+		try {
+			return clazz.newInstance();
+		} catch (Exception e) {
+		}
+		return null;
+	}
+
+	/**
 	 * 集合查询结果判断
 	 *
 	 * @param lists

pcloud-common/src/main/java/com/pcloud/common/utils/cookie/Cookie.java

@@ -12,6 +12,7 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.pcloud.common.exceptions.BizException;
+import com.pcloud.common.utils.NumberUtil;
 import com.pcloud.common.utils.string.StringUtil;
 
 /**
@@ -125,25 +126,25 @@ public class Cookie {
                 String[] channel = userInfoArry[i].split("=");
                 String channelId = channel[channel.length - 1];
                 userInfos.put("channelId", StringUtil.isEmpty(channelId) || "undefined".equalsIgnoreCase(channelId)
-                        || "null".equalsIgnoreCase(channelId) ? null : Long.valueOf(channelId));
+                        || "null".equalsIgnoreCase(channelId) ? null : NumberUtil.toLong(channelId));
             }
             if (userInfoArry[i].contains("officialAccountsId")) {
                 String[] wechat = userInfoArry[i].split("=");
                 String officialAccountsId = wechat[wechat.length - 1];
                 userInfos.put("officialAccountsId", StringUtil.isEmpty(officialAccountsId) || "undefined".equalsIgnoreCase(officialAccountsId)
-                        || "null".equalsIgnoreCase(officialAccountsId) ? null : Long.valueOf(officialAccountsId));
+                        || "null".equalsIgnoreCase(officialAccountsId) ? null : NumberUtil.toLong(officialAccountsId));
             }
             if (userInfoArry[i].contains("wechatUserId")) {
                 String[] user = userInfoArry[i].split("=");
                 String wechatUserId = user[user.length - 1];
                 userInfos.put("wechatUserId", StringUtil.isEmpty(wechatUserId) || "undefined".equalsIgnoreCase(wechatUserId)
-                        || "null".equalsIgnoreCase(wechatUserId) ? null : Long.valueOf(wechatUserId));
+                        || "null".equalsIgnoreCase(wechatUserId) ? null : NumberUtil.toLong(wechatUserId));
             }
             if (userInfoArry[i].contains("partyId")) {
                 String[] party = userInfoArry[i].split("=");
                 String partyId = party[party.length - 1];
                 userInfos.put("partyId", StringUtil.isEmpty(partyId) || "undefined".equalsIgnoreCase(partyId) || "null".equalsIgnoreCase(partyId)
-                        ? null : Long.valueOf(partyId));
+                        ? null : NumberUtil.toLong(partyId));
             }
             // editBy TC cookie里面需要带上顾问,systemCode,是否系统,场景值
             // modify by songx at 2017-05-17 如果值为undefined或者null直接跳过
@@ -151,7 +152,7 @@ public class Cookie {
                 String[] adviser = userInfoArry[i].split("=");
                 String adviserId = adviser[adviser.length - 1];
                 userInfos.put("adviserId", StringUtil.isEmpty(adviserId) || "undefined".equalsIgnoreCase(adviserId) || "null".equalsIgnoreCase(adviserId)
-                        ? null : Long.valueOf(adviserId));
+                        ? null : NumberUtil.toLong(adviserId));
             }
             if (userInfoArry[i].contains("systemCode")) {
                 String[] systemCode = userInfoArry[i].split("=");
@@ -168,25 +169,25 @@ public class Cookie {
                 String[] scene = userInfoArry[i].split("=");
                 String sceneId = scene[scene.length - 1];
                 userInfos.put("sceneId", StringUtil.isEmpty(sceneId) || "undefined".equalsIgnoreCase(sceneId) || "null".equalsIgnoreCase(sceneId) ? null
-                        : Long.valueOf(sceneId));
+                        : NumberUtil.toLong(sceneId));
             }
             if (userInfoArry[i].contains("userId")) {
                 String[] userLogin = userInfoArry[i].split("=");
                 String userId = userLogin[userLogin.length - 1];
                 userInfos.put("userId", StringUtil.isEmpty(userId) || "undefined".equalsIgnoreCase(userId) || "null".equalsIgnoreCase(userId) ? null
-                        : Long.valueOf(userId));
+                        : NumberUtil.toLong(userId));
             }
             if (userInfoArry[i].contains("merchantMemberId")) {
                 String[] merchant = userInfoArry[i].split("=");
                 String merchantMemberId = merchant[merchant.length - 1];
                 userInfos.put("merchantMemberId", StringUtil.isEmpty(merchantMemberId) || "undefined".equalsIgnoreCase(merchantMemberId)
-                        || "null".equalsIgnoreCase(merchantMemberId) ? null : Long.valueOf(merchantMemberId));
+                        || "null".equalsIgnoreCase(merchantMemberId) ? null : NumberUtil.toLong(merchantMemberId));
             }
             if (userInfoArry[i].contains("agentMemberId")) {
                 String[] merchant = userInfoArry[i].split("=");
                 String agentMemberId = merchant[merchant.length - 1];
                 userInfos.put("agentMemberId", StringUtil.isEmpty(agentMemberId) || "undefined".equalsIgnoreCase(agentMemberId)
-                        || "null".equalsIgnoreCase(agentMemberId) ? null : Long.valueOf(agentMemberId));
+                        || "null".equalsIgnoreCase(agentMemberId) ? null : NumberUtil.toLong(agentMemberId));
             }
             // add by gaop
             if (userInfoArry[i].contains(PREVIEW_TYPE)) {
@@ -205,13 +206,13 @@ public class Cookie {
                 String[] firstTD = userInfoArry[i].split("=");
                 String code = firstTD[firstTD.length - 1];
                 userInfos.put(FIRST_TD, StringUtil.isEmpty(code) || "undefined".equalsIgnoreCase(code) || "null".equalsIgnoreCase(code) ? null
-                        : Long.valueOf(code));
+                        : NumberUtil.toLong(code));
             }
             if (userInfoArry[i].contains(SECOND_TD)) {
                 String[] secondTD = userInfoArry[i].split("=");
                 String code = secondTD[secondTD.length - 1];
                 userInfos.put(SECOND_TD, StringUtil.isEmpty(code) || "undefined".equalsIgnoreCase(code) || "null".equalsIgnoreCase(code) ? null
-                        : Long.valueOf(code));
+                        : NumberUtil.toLong(code));
             }
         }
         return userInfos;
@@ -226,7 +227,7 @@ public class Cookie {
      */
     public static Long getId(String userInfo, String type) throws BizException {
         String value = getString(userInfo, type);
-        return StringUtil.isEmpty(value) || "undefined".equalsIgnoreCase(value) || "null".equalsIgnoreCase(value) ? null : Long.valueOf(value);
+        return StringUtil.isEmpty(value) || "undefined".equalsIgnoreCase(value) || "null".equalsIgnoreCase(value) ? null : NumberUtil.toLong(value);
     }
 
     /**

pcloud-common/src/main/java/com/pcloud/common/utils/export/word/WordDataExportor.java

@@ -127,6 +127,47 @@ public class WordDataExportor {
     }
 
     /**
+     * 生成word
+     * @param dataMap
+     * @param templateName
+     * @return
+     * @author linweibin
+     * @date 2017年5月22日 下午5:22:38
+     */
+    @SuppressWarnings("deprecation")
+    public static void generateWord(Class clazz, Map<String, Object> dataMap, String templateName, File tmpdir, String fileName) {
+        logger.info("开始生成word+++");
+        try {
+            // 创建配置实例
+            Configuration configuration = new Configuration();
+
+            // 设置编码
+            configuration.setDefaultEncoding("UTF-8");
+
+            // 获取template文件路径
+            configuration.setClassForTemplateLoading(clazz, "/template");
+
+            // 获取模板
+            Template template = configuration.getTemplate(templateName);
+
+            // 输出文件
+            File outFile = new File(tmpdir, fileName);
+
+            // 将模板和数据模型合并生成文件
+            Writer out = new BufferedWriter(new OutputStreamWriter(new FileOutputStream(outFile), "UTF-8"));
+
+            // 生成文件
+            template.process(dataMap, out);
+            logger.info("生成word+++成功");
+            // 关闭流
+            out.flush();
+            out.close();
+        } catch (Exception e) {
+            logger.error("生成word异常+++" + e.getMessage(), e);
+        }
+    }
+
+    /**
      * 生成随机文件名
      * @return
      * @author linweibin

pcloud-common/src/main/java/com/pcloud/common/utils/httpclient/UrlUtils.java

@@ -40,6 +40,11 @@ public class UrlUtils {
 	private static final String REQUEST_URL2 = "https://rays.5rs.me/convert/v1.0/url/shorten";
 
 	/**
+	 * 自定义生成 MD5 加密字符传前的混合 KEY
+	 */
+	public static final String PRIVATE_KEY = "lgsc1205";
+
+	/**
 	 * 获取短链接(新浪)
 	 *
 	 * @param long_url
@@ -112,13 +117,13 @@ public class UrlUtils {
 		HttpPost httpPost = new HttpPost(REQUEST_URL2);
 		String resContent = null;
 		try {
-            //设置参数到请求对象中
+			// 设置参数到请求对象中
 			JSONObject jsonObject = new JSONObject();
 			jsonObject.put("originUrl", long_url);
 			StringEntity stringEntity = new StringEntity(jsonObject.toJSONString(), Charset.forName("UTF-8"));
 			httpPost.setEntity(stringEntity);
-            //设置header信息
-            //指定报文头【Content-type】、【User-Agent】
+			// 设置header信息
+			// 指定报文头【Content-type】、【User-Agent】
 			httpPost.setHeader("Content-type", "application/json;charset=UTF-8");
 			CloseableHttpResponse response = httpclient.execute(httpPost);
 			// 获取响应实体
@@ -134,27 +139,32 @@ public class UrlUtils {
 	}
 
 	/**
-     * 缩短链接
+	 * 对传入的链接进行加密
 	 * 
 	 * @param url
 	 * @return
 	 */
 	public static String[] shortenUrl(String url) {
-        // 可以自定义生成 MD5 加密字符传前的混合 KEY
-        String key = "lgsc1205";
+		// 对传入网址进行 MD5 加密
+		String hex = MD5.getMD5Str(PRIVATE_KEY + url);
+		return shortenUrlMd5(hex);
+	}
+
+	/**
+	 * 缩短链接
+	 *
+	 * @param url
+	 * @return
+	 */
+	public static String[] shortenUrlMd5(String hex) {
 		// 要使用生成 URL 的字符
-        String[] chars = new String[]{"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p",
+		String[] chars = new String[] { "a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n", "o", "p",
 				"q", "r", "s", "t", "u", "v", "w", "x", "y", "z", "0", "1", "2", "3", "4", "5", "6", "7", "8", "9", "A",
 				"B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T", "U", "V",
-                "W", "X", "Y", "Z"
-
-        };
-        // 对传入网址进行 MD5 加密
-        String hex = MD5.getMD5Str(key + url);
+				"W", "X", "Y", "Z" };
 
 		String[] resUrl = new String[4];
 		for (int i = 0; i < 4; i++) {
-
 			// 把加密字符按照 8 位一组 16 进制与 0x3FFFFFFF 进行位与运算
 			String sTempSubString = hex.substring(i * 8, i * 8 + 8);
 

pcloud-common/src/main/java/com/pcloud/common/utils/rsa/MD5.java

@@ -10,8 +10,6 @@ import org.slf4j.LoggerFactory;
 
 import com.pcloud.common.utils.string.StringUtil;
 
-
-
 /**
  * MD5
  */
@@ -66,7 +64,20 @@ public class MD5 {
 			else
 				md5StrBuff.append(Integer.toHexString(0xFF & byteArray[i]));
 		}
-		return md5StrBuff.toString().toUpperCase();
+		return md5StrBuff.toString();
+	}
+
+	/**
+	 * MD5字符串，全大写
+	 * 
+	 * @param str
+	 * @return
+	 */
+	public static String getMD5StrUpper(String str) {
+		if (StringUtil.isEmpty(str)) {
+			return str;
+		}
+		return getMD5Str(str).toUpperCase();
 	}
 
 	/**
@@ -111,7 +122,7 @@ public class MD5 {
 		return md5StrBuff.toString().toUpperCase();
 	}
 
-	public static void main(String[] args){
+	public static void main(String[] args) {
 		System.out.println(MD5.getMD5Str("chenjianhua"));
 		System.out.println(DigestUtils.md5Hex("chenjianhua").toUpperCase());
 

pcloud-common/src/main/java/com/pcloud/common/utils/string/StringTools.java

@@ -613,7 +613,26 @@ public class StringTools {
 	 * @param array
 	 * @return
 	 */
-	public static boolean equalss(String str, String[] array) {
+	public static boolean equalss(String str, String... array) {
+		if (StringUtil.isEmpty(str) || array == null) {
+			return false;
+		}
+		for (String s : array) {
+			if (str.equals(s)) {
+				return true;
+			}
+		}
+		return false;
+	}
+
+	/**
+	 * 判断字符是否在数组中存在。如果数组为null则返回false
+	 * 
+	 * @param str
+	 * @param array
+	 * @return
+	 */
+	public static boolean equalss(String str, List<String> array) {
 		if (StringUtil.isEmpty(str) || array == null) {
 			return false;
 		}

pcloud-common/src/main/java/com/pcloud/common/utils/zip/CompressUtils.java

@@ -120,8 +120,8 @@ public class CompressUtils {
         if (ListUtils.isEmpty(fileUrlList)) {
             return null;
         }
-        zipName = FileUtils.formatName(zipName);
-        String tempZipName = zipName + "_" + LocalDateUtils.getYmdhmss();
+        String zipNameFormat = FileUtils.formatName(zipName);
+        String tempZipName = zipNameFormat + "_" + LocalDateUtils.getYmdhmss();
         String zipFilePath = ZIP_FILE_PATH + tempZipName + ".zip";
         // 检查临时文件夹是否存在，不存在就创建
         String fileFolderPath = FILE_LOCAL_PATH + tempZipName;
@@ -141,7 +141,7 @@ public class CompressUtils {
             FileUtils.isDir(ZIP_FILE_PATH);
             CompressUtils.zip(fileFolderPath, zipFilePath);
             // 上传文件到服务器中
-            uploadResultInfo = OssUtils.uploadLocalFile4CustomName(zipFilePath, zipName);
+            uploadResultInfo = OssUtils.uploadLocalFile4CustomName(zipFilePath, zipNameFormat);
             uploadResultInfo.setFileName(zipName);
         } catch (Exception e) {
             LOGGER.error("【压缩】压缩失败,<ERROR>:" + e.getMessage(), e);

pcloud-common/src/main/java/com/pcloud/common/vo/BaseVO.java

+/**
+ * 
+ */
+package com.pcloud.common.vo;
+
+import java.io.Serializable;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+
+/**
+ * VO父类
+ * 
+ * @author：songx
+ * @date：2019年1月14日,下午8:53:01
+ */
+@JsonInclude(value = Include.NON_NULL)
+public class BaseVO implements Serializable {
+
+	/**
+	 * 
+	 */
+	private static final long serialVersionUID = -5943734920212204836L;
+
+}

pcloud-solr/pom.xml

+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xmlns="http://maven.apache.org/POM/4.0.0"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.pcloud.common</groupId>
+        <artifactId>pcloud-common-parent</artifactId>
+        <version>2.1.0-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>pcloud-solr</artifactId>
+    <packaging>jar</packaging>
+    <version>${pcloud-solr.version}</version>
+
+    <name>pcloud-solr</name>
+	<url>http://maven.apache.org</url>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>com.pcloud.common</groupId>
+			<artifactId>pcloud-common-config</artifactId>
+			<version>${pcloud-common-config.version}</version>
+		</dependency>
+
+        <!-- solr add by gaop at 2018-4-23 11:33:47 -->
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-solr</artifactId>
+            <version>${spring.data.solr.version}</version>
+        </dependency>
+
+		<!-- Spring Cloud Begin -->
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-config</artifactId>
+		</dependency>
+		<!-- Spring Cloud End -->
+
+		<!-- Common Dependency Begin -->
+		<dependency>
+			<groupId>org.slf4j</groupId>
+			<artifactId>slf4j-api</artifactId>
+            <version>1.7.18</version>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+            <version>3.4</version>
+		</dependency>
+		<dependency>
+			<groupId>com.alibaba</groupId>
+			<artifactId>fastjson</artifactId>
+            <version>1.2.38</version>
+		</dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-collections4</artifactId>
+            <version>4.1</version>
+        </dependency>
+		<!-- Common Dependency End -->
+
+	</dependencies>
+
+</project>

pcloud-common/src/main/java/com/pcloud/common/utils/solr/SolrDto.java → pcloud-solr/src/main/java/com/pcloud/solr/SolrDto.java

-package com.pcloud.common.utils.solr;
+package com.pcloud.solr;
 
 import java.io.Serializable;
 import java.util.Calendar;

pcloud-common/src/main/java/com/pcloud/common/utils/solr/SolrQueryParam.java → pcloud-solr/src/main/java/com/pcloud/solr/SolrQueryParam.java

-package com.pcloud.common.utils.solr;
+package com.pcloud.solr;
 
 import java.util.List;
 import java.util.Map;

pcloud-common/src/main/java/com/pcloud/common/utils/solr/SolrResult.java → pcloud-solr/src/main/java/com/pcloud/solr/SolrResult.java

-package com.pcloud.common.utils.solr;
+package com.pcloud.solr;
 
 import java.io.Serializable;
 import java.util.List;
@@ -8,7 +8,7 @@ import java.util.List;
  * @author PENG
  * @date 2018/4/24
  */
-public class SolrResult implements Serializable {
+public class SolrResult<T> implements Serializable {
 
     private static final long serialVersionUID = 1195918725820896691L;
 
@@ -25,7 +25,7 @@ public class SolrResult implements Serializable {
     /**
      * 查询结果列表
      */
-    private List<SolrDto> list;
+    private List<T> list;
 
     public Integer getTotalCount() {
         return totalCount;
@@ -43,11 +43,11 @@ public class SolrResult implements Serializable {
         this.maxScore = maxScore;
     }
 
-    public List<SolrDto> getList() {
+    public List<T> getList() {
         return list;
     }
 
-    public void setList(List<SolrDto> list) {
+    public void setList(List<T> list) {
         this.list = list;
     }
 

pom.xml

@@ -18,6 +18,7 @@
 		<module>pcloud-common-config</module>
 		<module>pcloud-common</module>
 		<module>pcloud-common-core</module>
+		<module>pcloud-solr</module>
 	</modules>
 	<packaging>pom</packaging>
 
@@ -47,6 +48,7 @@
 				<pcloud-common.version>2.1.0-RELEASE</pcloud-common.version>
 				<pcloud-common-config.version>2.1.0-RELEASE</pcloud-common-config.version>
 				<pcloud-common-core.version>2.1.0-RELEASE</pcloud-common-core.version>
+				<pcloud-solr.version>2.1.0-RELEASE</pcloud-solr.version>
 			</properties>
 		</profile>
 		<!-- 压测环境 -->
@@ -68,6 +70,7 @@
 				<pcloud-common.version>2.1.0-RELEASE</pcloud-common.version>
 				<pcloud-common-config.version>2.1.0-RELEASE</pcloud-common-config.version>
 				<pcloud-common-core.version>2.1.0-RELEASE</pcloud-common-core.version>
+				<pcloud-solr.version>2.1.0-RELEASE</pcloud-solr.version>
 			</properties>
 		</profile>
 		<!-- 生产环境 RAYS -->
@@ -89,6 +92,7 @@
 				<pcloud-common.version>2.1.1-RELEASE</pcloud-common.version>
 				<pcloud-common-config.version>2.1.1-RELEASE</pcloud-common-config.version>
 				<pcloud-common-core.version>2.1.1-RELEASE</pcloud-common-core.version>
+				<pcloud-solr.version>2.1.1-RELEASE</pcloud-solr.version>
 			</properties>
 		</profile>
 	</profiles>
@@ -227,6 +231,11 @@
 				<version>4.4.6</version>
 			</dependency>
 			<dependency>
+				<groupId>org.apache.httpcomponents</groupId>
+				<artifactId>httpmime</artifactId>
+				<version>4.5.3</version>
+			</dependency>
+			<dependency>
 				<groupId>redis.clients</groupId>
 				<artifactId>jedis</artifactId>
 				<version>2.9.0</version>
@@ -303,13 +312,6 @@
 			</dependency>
 			<!-- end -->
 
-			<!-- solr add by gaop at 2018-4-23 11:33:47 -->
-			<dependency>
-				<groupId>org.springframework.data</groupId>
-				<artifactId>spring-data-solr</artifactId>
-				<version>${spring.data.solr.version}</version>
-			</dependency>
-
 			<!-- Jackson Begin -->
 			<dependency>
 				<groupId>org.codehaus.jackson</groupId>