Commit 78731fed by lihui.wang

第一次修改整合 框已搭建

parent 473e629e
......@@ -4,26 +4,50 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.freemud.job</groupId>
<artifactId>executor-sample-message</artifactId>
<artifactId>freemud-pay-push-message</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>executor-sample-message</name>
<name>freemud-pay-push-message</name>
<description>Demo project for Spring Boot</description>
<parent>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-executor-samples</artifactId>
<version>1.9.2-SNAPSHOT</version>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.7</java.version>
<java.version>1.8</java.version>
<javax.servlet-api.version>3.0.1</javax.servlet-api.version>
<jsp-api.version>2.2</jsp-api.version>
<spring.version>4.3.14.RELEASE</spring.version>
<jackson.version>2.9.4</jackson.version>
<aspectjweaver.version>1.8.13</aspectjweaver.version>
<slf4j-api.version>1.7.25</slf4j-api.version>
<freemarker.version>2.3.23</freemarker.version>
<junit.version>4.12</junit.version>
<jetty-server.version>9.2.24.v20180105</jetty-server.version>
<hessian.version>4.0.51</hessian.version>
<httpclient.version>4.5.5</httpclient.version>
<commons-exec.version>1.3</commons-exec.version>
<commons-collections4.version>4.1</commons-collections4.version>
<commons-lang3.version>3.7</commons-lang3.version>
<commons-email.version>1.5</commons-email.version>
<c3p0.version>0.9.5.2</c3p0.version>
<mysql-connector-java.version>5.1.45</mysql-connector-java.version>
<mybatis-spring.version>1.3.1</mybatis-spring.version>
<mybatis.version>3.4.5</mybatis.version>
<groovy-all.version>2.4.13</groovy-all.version>
<quartz.version>2.3.0</quartz.version>
<spring-boot.version>1.5.10.RELEASE</spring-boot.version>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
......@@ -77,7 +101,7 @@
<dependency>
<groupId>com.xuxueli</groupId>
<artifactId>xxl-job-core</artifactId>
<version>${project.parent.version}</version>
<version>1.9.1</version>
</dependency>
<dependency>
<groupId>tk.mybatis</groupId>
......@@ -114,6 +138,14 @@
</execution>
</executions>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<configuration>
<source>1.6</source>
<target>1.6</target>
</configuration>
</plugin>
</plugins>
</build>
......
package com.freemud.job;
package com.freemud.pay.job;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class ExecutorSampleMessageApplication {
public class PushMessageApplication {
public static void main(String[] args) {
SpringApplication.run(ExecutorSampleMessageApplication.class, args);
SpringApplication.run(PushMessageApplication.class, args);
}
}
package com.freemud.job.config;
package com.freemud.pay.job.config;
import com.xxl.job.core.executor.XxlJobExecutor;
import org.slf4j.Logger;
......@@ -14,7 +14,7 @@ import org.springframework.context.annotation.Configuration;
* @author xuxueli 2017-04-28
*/
@Configuration
@ComponentScan(basePackages = "com.freemud.job.jobhandler")
@ComponentScan(basePackages = "com.freemud.pay.job.jobhandler")
public class XxlJobConfig {
private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
......
package com.freemud.job.dao;
package com.freemud.pay.job.dao;
import tk.mybatis.mapper.common.BaseMapper;
import tk.mybatis.mapper.common.MySqlMapper;
......
package com.freemud.job.dao.dbModel;
import org.omg.CORBA.StringHolder;
package com.freemud.pay.job.dao.dbModel;
import javax.persistence.Column;
import javax.persistence.GeneratedValue;
......
package com.freemud.pay.job.dao.mapper;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PartnerDM;
public interface PartnerDMMapper extends IBaseDao<PartnerDM> {
}
\ No newline at end of file
package com.freemud.job.dao.mapper;
package com.freemud.pay.job.dao.mapper;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.dbModel.PayDM;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayDM;
/**
* All rights Reserved, Designed By www.freemud.cn
......
package com.freemud.job.dao.mapper;
package com.freemud.pay.job.dao.mapper;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.dbModel.PayMessageDM;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.PayMessageDM;
/**
* All rights Reserved, Designed By www.freemud.cn
......
package com.freemud.job.dao.repository;
package com.freemud.pay.job.dao.repository;
import com.freemud.job.dao.dbModel.BaseModel;
import com.freemud.pay.job.dao.dbModel.BaseModel;
import java.util.List;
......
package com.freemud.job.dao.repository.Impl;
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.dbModel.BaseModel;
import com.freemud.job.dao.repository.IBaseRepository;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.dbModel.BaseModel;
import com.freemud.pay.job.dao.repository.IBaseRepository;
import java.util.List;
......@@ -22,6 +22,7 @@ import java.util.List;
public abstract class BaseRepositoryImpl implements IBaseRepository {
protected abstract IBaseDao getDao();
@Override
public <T extends BaseModel> T insert(T model) {
getDao().insert(model);
......
package com.freemud.job.dao.repository.Impl;
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.mapper.PartnerDMMapper;
import com.freemud.job.dao.repository.IPartnerRepository;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.mapper.PartnerDMMapper;
import com.freemud.pay.job.dao.repository.IPartnerRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
......
package com.freemud.job.dao.repository.Impl;
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.mapper.PayMessageDMMapper;
import com.freemud.job.dao.repository.IPayMessageRepository;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.mapper.PayMessageDMMapper;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
......
package com.freemud.job.dao.repository.Impl;
package com.freemud.pay.job.dao.repository.Impl;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.mapper.PayDMMapper;
import com.freemud.job.dao.repository.IPayMessageRepository;
import com.freemud.pay.job.dao.IBaseDao;
import com.freemud.pay.job.dao.mapper.PayDMMapper;
import com.freemud.pay.job.dao.repository.IPayMessageRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Primary;
import org.springframework.stereotype.Repository;
......
package com.freemud.job.jobhandler;
package com.freemud.pay.job.jobhandler;
import com.alibaba.fastjson.JSON;
import com.freemud.job.entity.vo.request.BaseParam;
import com.freemud.job.service.IPayMessageService;
import com.freemud.pay.job.entity.BaseParam;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import netscape.javascript.JSObject;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
/**
......
package com.freemud.job.service;
package com.freemud.pay.job.service;
import com.freemud.job.dao.dbModel.PartnerDM;
import com.freemud.pay.job.dao.dbModel.PartnerDM;
import java.util.List;
......
package com.freemud.job.service.impl;
package com.freemud.pay.job.service.impl;
import com.freemud.job.dao.dbModel.PartnerDM;
import com.freemud.job.dao.repository.IPartnerRepository;
import com.freemud.job.service.IPartnerService;
import com.freemud.pay.job.dao.dbModel.PartnerDM;
import com.freemud.pay.job.dao.repository.IPartnerRepository;
import com.freemud.pay.job.service.IPartnerService;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
......
package com.freemud.job.service.impl;
package com.freemud.pay.job.service.impl;
import com.freemud.job.service.IPayMessageService;
import com.freemud.pay.job.service.IPayMessageService;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -14,7 +15,7 @@ import com.freemud.job.service.IPayMessageService;
* 注意:本内容仅限于上海非码科技内部传阅,禁止外泄以及用于其他的商业目
*/
public class PayMessageServiceImpl implements IPayMessageService {
@Override
public void pushMessage() {
}
......
package com.freemud.job.service.impl;
package com.freemud.pay.job.service.impl;
import com.freemud.job.service.IPayService;
import com.freemud.pay.job.service.IPayService;
/**
* All rights Reserved, Designed By www.freemud.cn
......@@ -13,5 +14,5 @@ import com.freemud.job.service.IPayService;
* @Copyright: 2017 www.freemud.cn Inc. All rights reserved.
* 注意:本内容仅限于上海非码科技内部传阅,禁止外泄以及用于其他的商业目
*/
public class PayServiceImpl implements IPayService{
public class PayServiceImpl implements IPayService {
}
\ No newline at end of file
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.freemud.job.dao.mapper.PartnerDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.job.dao.dbModel.PartnerDM" >
<mapper namespace="com.freemud.pay.job.dao.mapper.PartnerDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PartnerDM" >
<id property="id" column="ID" />
<result property="partnerName" column="PartnerName" />
<result property="ourAccountPartner" column="OurAccount_Partner" />
......
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.freemud.job.dao.mapper.PayDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.job.dao.dbModel.PayDM" >
<mapper namespace="com.freemud.pay.job.dao.mapper.PayDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayDM" >
<id property="id" column="ID" />
<result property="storeId" column="Store_Id" />
<result property="stationId" column="Station_Id" />
......
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.freemud.job.dao.mapper.PayMessageDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.job.dao.dbModel.PayMessageDM" >
<mapper namespace="com.freemud.pay.job.dao.mapper.PayMessageDMMapper" >
<resultMap id="BaseResultMap" type="com.freemud.pay.job.dao.dbModel.PayMessageDM" >
<id property="id" column="ID" />
<result property="partnerId" column="PartnerId" />
<result property="fmId" column="FmId" />
......
package com.freemud.job;
package com.freemud.pay.job;
import org.junit.Test;
import org.junit.runner.RunWith;
......@@ -7,7 +7,7 @@ import org.springframework.test.context.junit4.SpringRunner;
@RunWith(SpringRunner.class)
@SpringBootTest
public class ExecutorSampleMessageApplicationTests {
public class PushMessageApplicationTests {
@Test
public void contextLoads() {
......
......@@ -14,6 +14,7 @@
<module>xxl-job-core</module>
<module>xxl-job-admin</module>
<module>xxl-job-executor-samples</module>
<module>freemud-pay-module/freemud-pay-push-message</module>
</modules>
<properties>
......
package com.freemud.job.dao.mapper;
import com.freemud.job.dao.IBaseDao;
import com.freemud.job.dao.dbModel.PartnerDM;
public interface PartnerDMMapper extends IBaseDao<PartnerDM> {
}
\ No newline at end of file
package com.freemud.job.jobhandler;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import org.springframework.stereotype.Component;
import java.util.concurrent.TimeUnit;
/**
* 任务Handler示例(Bean模式)
*
* 开发步骤:
* 1、继承"IJobHandler":“com.xxl.job.core.handler.IJobHandler”;
* 2、注册到Spring容器:添加“@Component”注解,被Spring容器扫描为Bean实例;
* 3、注册到执行器工厂:添加“@JobHandler(value="自定义jobhandler名称")”注解,注解value值对应的是调度中心新建任务的JobHandler属性的值。
* 4、执行日志:需要通过 "XxlJobLogger.log" 打印执行日志;
*
* @author xuxueli 2015-12-19 19:43:36
*/
@JobHandler(value="demoJobHandler")
@Component
public class DemoJobHandler extends IJobHandler {
@Override
public ReturnT<String> execute(String param) throws Exception {
XxlJobLogger.log("XXL-JOB, Hello World.");
for (int i = 0; i < 5; i++) {
XxlJobLogger.log("beat at:" + i);
TimeUnit.SECONDS.sleep(2);
}
return SUCCESS;
}
}
package com.freemud.job.jobhandler;
import com.xxl.job.core.biz.model.ReturnT;
import com.xxl.job.core.handler.IJobHandler;
import com.xxl.job.core.handler.annotation.JobHandler;
import com.xxl.job.core.log.XxlJobLogger;
import com.xxl.job.core.util.ShardingUtil;
import org.springframework.stereotype.Service;
/**
* 分片广播任务
*
* @author xuxueli 2017-07-25 20:56:50
*/
@JobHandler(value="shardingJobHandler")
@Service
public class ShardingJobHandler extends IJobHandler {
@Override
public ReturnT<String> execute(String param) throws Exception {
// 分片参数
ShardingUtil.ShardingVO shardingVO = ShardingUtil.getShardingVo();
XxlJobLogger.log("分片参数:当前分片序号 = {}, 总分片数 = {}", shardingVO.getIndex(), shardingVO.getTotal());
// 业务逻辑
for (int i = 0; i < shardingVO.getTotal(); i++) {
if (i == shardingVO.getIndex()) {
XxlJobLogger.log("第 {} 片, 命中分片开始处理", i);
} else {
XxlJobLogger.log("第 {} 片, 忽略", i);
}
}
return SUCCESS;
}
}
package com.freemud.job.vo;
/**
* All rights Reserved, Designed By www.freemud.cn
*
* @title: BaseResponse
* @package: com.freemud.backend.pay.vo
* @description: ${TODO}(用一句话描述该文件做什么)
* @author: dengjie<jie.deng @ freemud.cn>
* @date: 2018/8/31 18:05
* @version: v1.0
* @copyright: 2018 www.freemud.cn Inc. All rights reserved.
* 注意:本内容仅限于上海非码科技内部传阅,禁止外泄以及用于其他的商业目的
*/
//
//import io.swagger.annotations.ApiModel;
//import io.swagger.annotations.ApiModelProperty;
//
//@ApiModel(description= "返回响应数据")
public class BaseResponse<T> {
public Integer getReturn_code() {
return return_code;
}
public void setReturn_code(Integer return_code) {
this.return_code = return_code;
}
public String getReturn_msg() {
return return_msg;
}
public void setReturn_msg(String return_msg) {
this.return_msg = return_msg;
}
public T getReturn_data() {
return return_data;
}
public void setReturn_data(T data) {
this.return_data = data;
}
// @ApiModelProperty(value = "成功编号")
private Integer return_code;
// @ApiModelProperty(value = "成功消息")
private String return_msg;
// @ApiModelProperty(value = "返回对象")
private T return_data;
public BaseResponse(Integer return_code, String return_msg) {
this.return_code = return_code;
this.return_msg = return_msg;
}
public BaseResponse() {
this.return_code = return_code;
this.return_msg = return_msg;
}
}
#server:
# port: 6300
#
#spring:
# datasource:
# password: zhuihutest@freemud
# url: jdbc:sqlserver://115.159.142.32:9528;databasename=zhuihu
# username: zhuihutest
# driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
#server:
# port: 8081
#logging:
# config=classpath: logback.xml
#xxl:
# job:
# admin:
# addresses: http://115.159.142.32:9080/xxl-job-admin/
#xxl:
# job:
# executor:
# appname: xxl-job-executor-sample
# port: 9999
# logpath: /data/applogs/xxl-job/jobhandler
# logretentiondays: -1
#spring:
# datasource:
# password: zhuihutest@freemud
# url: jdbc:sqlserver://115.159.142.32:9528
# username: zhuihutest
# driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver
#
#
#
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment