山西

Dockerfile

@@ -0,0 +1,5 @@
+FROM 192.168.123.25:31104/unis/java:8
+
+ADD ./target/depot-payment.jar /root
+CMD ["sh", "-c", "cd /root; java -Djava.security.egd=file:/dev/./urandom -jar /root/depot-payment.jar --depot-payment.server.enable-self-preservation=false"]
+EXPOSE 9015

pom.xml

@@ -0,0 +1,156 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+		 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>
+
+	<groupId>com.chinaitop</groupId>
+	<artifactId>depot-payment</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<name>depot-payment</name>
+	<description>Demo project for Spring Boot</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.0.3.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+		<java.version>1.8</java.version>
+		<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>org.mybatis.spring.boot</groupId>
+			<artifactId>mybatis-spring-boot-starter</artifactId>
+			<version>1.3.1</version>
+		</dependency>
+		<!-- 引入spring boot自带的pagehelper插件 -->
+		<dependency>
+			<groupId>com.github.pagehelper</groupId>
+			<artifactId>pagehelper-spring-boot-starter</artifactId>
+			<version>1.2.3</version>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
+		</dependency>
+		<dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-config</artifactId>
+        </dependency>
+		<!-- 导入eureka-server服务的依赖 -->
+		<!--<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-eureka-server</artifactId>
+		</dependency>-->
+
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+			<version>3.7</version>
+		</dependency>
+
+		<!-- swagger2 -->
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger2</artifactId>
+			<version>2.6.1</version>
+		</dependency>
+		<dependency>
+			<groupId>io.springfox</groupId>
+			<artifactId>springfox-swagger-ui</artifactId>
+			<version>2.6.1</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-data-redis</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.session</groupId>
+			<artifactId>spring-session-data-redis</artifactId>
+		</dependency>
+
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+        <dependency>
+            <groupId>org.mybatis.generator</groupId>
+            <artifactId>mybatis-generator-core</artifactId>
+            <version>1.3.2</version>
+            <scope>compile</scope>
+        </dependency>
+    </dependencies>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.springframework.cloud</groupId>
+				<artifactId>spring-cloud-dependencies</artifactId>
+				<version>${spring-cloud.version}</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+	<build>
+		<finalName>${project.artifactId}</finalName>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+			<plugin>
+				<groupId>org.apache.maven.plugins</groupId>
+				<artifactId>maven-surefire-plugin</artifactId>
+				<configuration>
+					<skip>true</skip>
+				</configuration>
+			</plugin>
+		</plugins>
+		<!-- 如果不添加此节点mybatis的mapper.xml文件都会被漏掉。 -->
+		<resources>
+			<resource>
+				<directory>src/main/java</directory>
+				<includes>
+					<include>**/*.properties</include>
+					<include>**/*.xml</include>
+				</includes>
+				<filtering>false</filtering>
+			</resource>
+			<resource>
+				<directory>src/main/resources</directory>
+			</resource>
+		</resources>
+	</build>
+
+	<repositories>
+		<repository>
+			<id>spring-milestones</id>
+			<name>Spring Milestones</name>
+			<url>https://repo.spring.io/milestone</url>
+			<snapshots>
+				<enabled>false</enabled>
+			</snapshots>
+		</repository>
+	</repositories>
+</project>

src/main/java/com/chinaitop/DatePermissionInterceptor.java

@@ -0,0 +1,159 @@
+package com.chinaitop;
+
+import com.chinaitop.depot.storage.utils.DataPolicyEngine;
+import com.chinaitop.depot.storage.utils.RedisUtil;
+import net.sf.jsqlparser.parser.CCJSqlParserUtil;
+import net.sf.jsqlparser.statement.Statement;
+import net.sf.jsqlparser.statement.select.Select;
+import net.sf.jsqlparser.util.TablesNamesFinder;
+import org.apache.commons.lang.ObjectUtils;
+import org.apache.ibatis.executor.statement.StatementHandler;
+import org.apache.ibatis.mapping.BoundSql;
+import org.apache.ibatis.mapping.MappedStatement;
+import org.apache.ibatis.plugin.*;
+import org.apache.ibatis.reflection.DefaultReflectorFactory;
+import org.apache.ibatis.reflection.MetaObject;
+import org.apache.ibatis.reflection.ReflectorFactory;
+import org.apache.ibatis.reflection.factory.DefaultObjectFactory;
+import org.apache.ibatis.reflection.factory.ObjectFactory;
+import org.apache.ibatis.reflection.wrapper.DefaultObjectWrapperFactory;
+import org.apache.ibatis.reflection.wrapper.ObjectWrapperFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.lang.reflect.Field;
+import java.sql.Connection;
+import java.util.HashSet;
+import java.util.List;
+import java.util.Properties;
+import java.util.Set;
+
+/**
+ * Sql执行时间记录拦截器
+ */
+@Intercepts({ @Signature(type = StatementHandler.class, method = "prepare", args = { Connection.class, Integer.class })})
+@Component
+public class DatePermissionInterceptor implements Interceptor {
+	
+	private static final ObjectFactory DEFAULT_OBJECT_FACTORY = new DefaultObjectFactory();
+    private static final ObjectWrapperFactory DEFAULT_OBJECT_WRAPPER_FACTORY = new DefaultObjectWrapperFactory();
+    private static final ReflectorFactory DEFAULT_REFLECTOR_FACTORY = new DefaultReflectorFactory();
+
+	@Autowired
+	private RedisUtil redisUtil;
+	
+	@Override
+	public Object intercept(Invocation invocation) throws Throwable {
+		
+		StatementHandler statementHandler = (StatementHandler) invocation.getTarget();
+        MetaObject metaStatementHandler = MetaObject.forObject(statementHandler, DEFAULT_OBJECT_FACTORY,
+                DEFAULT_OBJECT_WRAPPER_FACTORY, DEFAULT_REFLECTOR_FACTORY);
+        
+        MappedStatement mappedStatement = (MappedStatement) metaStatementHandler.getValue("delegate.mappedStatement");
+        
+		final BoundSql boundSql = statementHandler.getBoundSql();
+		String bouString = boundSql.getSql();// 获取执行sql 
+		
+		//sql是查询的才进行权限过滤且不过滤t_url_config表的数据
+	    if(mappedStatement.getSqlCommandType().toString().equals("select".toUpperCase()) && 
+	    		!bouString.contains("t_url_config")) {
+			//通过本地线程获取库id
+			Object threadLocalObj = DataPolicyEngine.get();
+			String orgId = null;
+			if(threadLocalObj != null) {
+				orgId = ObjectUtils.toString(threadLocalObj);
+			}
+			if(orgId!=null) {
+				//机构单独查询时使用递归查询，可以查询机构下级机构
+				if("com.chinaitop.depot.system.mapper.OrgInfoMapper.selectByExample".equals(mappedStatement.getId())) {
+					bouString = bouString.replaceAll("org_info", "(SELECT * from org_info"
+							+ " WHERE FIND_IN_SET(org_id,getChildrenOrg("+orgId+"))) org_info ");
+				}else {
+					//解析sql中的表名
+					Statement statement = CCJSqlParserUtil.parse(bouString);
+					Select selectStatement = (Select)statement;
+					TablesNamesFinder tablesNamesFinder = new TablesNamesFinder();
+					List<String> result = tablesNamesFinder.getTableList(selectStatement);
+					
+					Set<String> tableNames = new HashSet<String>();// 定义需要替换的table信息列表
+					//获取业务表信息数据
+					List<String> tableList = (List<String>)redisUtil.lGetAll("tableList").get(0);
+					for(int i=0;i<result.size();i++) {
+						for (int j = 0; j < tableList.size(); j++) {// 处理查看sql中是否有业务表
+							if (result.get(i).equals(ObjectUtils.toString(tableList.get(j)))) {// 是否存在业务表
+								tableNames.add(result.get(i));
+							}
+						}
+					}
+					
+					if (tableNames != null && tableNames.size() > 0) {// sql中存在业务表进行sql拼接数据重新检索
+						if(result.size() >= 2) {//sql中存在2张及以上表
+							for (String table : tableNames) {// 进行业务表的数据权限替换
+								table += " ";//表名后面加空格，防止两个表名一部分相似，导致替换出错
+								bouString = bouString.replaceAll(table, "(SELECT * from " + table
+										+ " WHERE org_id = '"+orgId+"') ");
+							}
+						}else {//sql中是单表
+							for (String table : tableNames) {// 进行业务表的数据权限替换
+								if(bouString.contains(table+" ")) {//防止是单表查询，表后面没有空格的时候替换不了
+									table += " ";//表名后面加空格，防止两个表名一部分相似，导致替换出错
+								}
+								bouString = bouString.replaceAll(table, "(SELECT * from " + table
+										+ " WHERE org_id = '"+orgId+"') "+table+" ");
+							}
+						}
+						
+						/*bouString = bouString.replaceAll(table, "(SELECT b.* from " + table
+						+ " b,user_business u WHERE b.org_id = u.org_id AND u .user_id ='"+userId+"' AND u.business_type = '"+table+"') ");*/
+						
+					}
+				}
+				
+				
+				//metaStatementHandler.setValue("delegate.boundSql.sql", bouString);
+				
+				Field field = getField(boundSql, "sql");
+				if (field != null) {
+					try {
+						field.setAccessible(true);
+						field.set(boundSql, bouString);
+					} catch (IllegalArgumentException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					} catch (IllegalAccessException e) {
+						// TODO Auto-generated catch block
+						e.printStackTrace();
+					}
+				}
+			}
+		
+	    }
+			
+		return invocation.proceed();
+		
+
+	}
+
+	private static Field getField(Object obj, String fieldName) {
+		Field field = null;
+		for (Class<?> clazz = obj.getClass(); clazz != Object.class; clazz = clazz.getSuperclass()) {
+			try {
+				field = clazz.getDeclaredField(fieldName);
+				break;
+			} catch (NoSuchFieldException e) {
+				// 这里不用做处理，子类没有该字段可能对应的父类有，都没有就返回null。
+			}
+		}
+		return field;
+	}
+
+	@Override
+	public Object plugin(Object target) {
+		return Plugin.wrap(target, this);
+	}
+
+	@Override
+	public void setProperties(Properties properties) {
+	}
+
+}

src/main/java/com/chinaitop/DepotPaymentApplication.java

@@ -0,0 +1,18 @@
+package com.chinaitop;
+
+import org.mybatis.spring.annotation.MapperScan;
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+@EnableEurekaClient
+@EnableDiscoveryClient
+@SpringBootApplication
+@MapperScan(basePackages = {"com.chinaitop.depot.*.mapper"})
+public class DepotPaymentApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(DepotPaymentApplication.class, args);
+	}
+}

src/main/java/com/chinaitop/HelloWebXml.java

@@ -0,0 +1,12 @@
+package com.chinaitop;
+ 
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.boot.web.servlet.support.SpringBootServletInitializer;
+
+public class HelloWebXml extends SpringBootServletInitializer {
+    @Override
+    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
+        return application.sources(DepotPaymentApplication.class);
+    }
+ 
+}

src/main/java/com/chinaitop/SwaggerConfig.java

@@ -0,0 +1,34 @@
+package com.chinaitop;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import springfox.documentation.builders.ApiInfoBuilder;
+import springfox.documentation.builders.PathSelectors;
+import springfox.documentation.builders.RequestHandlerSelectors;
+import springfox.documentation.service.ApiInfo;
+import springfox.documentation.spi.DocumentationType;
+import springfox.documentation.spring.web.plugins.Docket;
+import springfox.documentation.swagger2.annotations.EnableSwagger2;
+
+@Configuration
+@EnableSwagger2
+public class SwaggerConfig {
+
+    @Bean
+    public Docket createRestApi() {
+        return new Docket(DocumentationType.SWAGGER_2)
+                .apiInfo(apiInfo())
+                .select()
+                .apis(RequestHandlerSelectors.basePackage("com.chinaitop.depot.storage.controller"))
+                .paths(PathSelectors.any())
+                .build();
+    }
+    private ApiInfo apiInfo() {
+        return new ApiInfoBuilder()
+                .title("智能粮库管理平台api文档")
+                .description("费用管理")
+                .termsOfServiceUrl("http://192.168.80.25:9001")
+                .version("1.0")
+                .build();
+    }
+}

src/main/java/com/chinaitop/depot/storage/controller/StoragePayMentController.java

@@ -0,0 +1,151 @@
+package com.chinaitop.depot.storage.controller;
+
+import com.chinaitop.depot.storage.model.StoragePayment;
+import com.chinaitop.depot.storage.model.StoragePaymentExample;
+import com.chinaitop.depot.storage.service.StoragePayMentService;
+import com.chinaitop.depot.storage.utils.ParameterUtil;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.annotation.Resource;
+import java.io.IOException;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @auther mafy
+ * @createtime 2017/10/25 0025
+ * 费用管理类
+ */
+@RestController
+@RequestMapping(value = "/storagePayMent")
+@Api(value= "StoragePayMentController", description = "费用管理控制类")
+public class StoragePayMentController {
+
+    @Resource
+    private StoragePayMentService storagePayMentService;
+    /**
+     * 获取费用管理列表
+     * @param pageNum
+     * @param pageSize
+     * @param houseId
+     * @param searchStartDate
+     * @param searchEndDate
+     * @return
+     */
+    @RequestMapping(value = "/getpaymentList", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET)
+    @ApiOperation(value="查询费用管理列表", notes = "查询费用管理信息列表，支持分页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query"),
+            @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query"),
+            @ApiImplicitParam(name = "houseId", value = "仓房id", paramType = "query"),
+            @ApiImplicitParam(name = "type", value = "费用类型", paramType = "query"),
+            @ApiImplicitParam(name = "searchStartDate", value = "开始日期", paramType = "query"),
+            @ApiImplicitParam(name = "searchEndDate", value = "结束日期", paramType = "query")
+
+    })
+    public PageInfo<StoragePayment> getpaymentList(Integer pageNum, Integer pageSize, Integer houseId, Integer type, String searchStartDate, String searchEndDate){
+        StoragePaymentExample storagePaymentExample = new StoragePaymentExample();
+        StoragePaymentExample.Criteria criteria = storagePaymentExample.createCriteria();
+        if(ParameterUtil.isnotnull(houseId)){
+           criteria.andHouseIdEqualTo(houseId);
+        }
+        if(ParameterUtil.isnotnull(type)){
+            criteria.andTypeEqualTo(type);
+        }
+
+        if(ParameterUtil.isnotnull(searchStartDate) && ParameterUtil.isnotnull(searchEndDate)){
+            Date starDate = ParameterUtil.string2datetime(searchStartDate + " 00:00:00");
+            criteria.andPayTimeGreaterThanOrEqualTo(starDate);
+
+            Date endDate = ParameterUtil.string2datetime(searchEndDate + " 23:59:59");
+            criteria.andPayTimeLessThanOrEqualTo(endDate);
+        }
+
+        if (pageNum!=null && pageSize!=null) {
+            PageHelper.startPage(pageNum, pageSize);
+        }
+
+        List<StoragePayment> list = storagePayMentService.getlist(storagePaymentExample);
+        PageInfo<StoragePayment> pageInfo = new PageInfo<StoragePayment>(list);
+        return pageInfo;
+    }
+    /**
+     * 获取费用ById
+     * @return
+     */
+    @RequestMapping(value = "/getpaymentListById" ,produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET)
+    @ApiOperation(value="获取费用ById", notes = "获取费用ById")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "id", paramType = "query"),
+    })
+    public StoragePayment getpaymentListById(Integer id){
+        return storagePayMentService.getObjById(id);
+    }
+
+    /**
+     * 新增
+     * @param paymentJson
+     * @return
+     */
+    @RequestMapping(value = "edit" ,produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value="新增数据", notes = "新增数据")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "paymentJson", value = "JSON数据对象", paramType = "form"),
+            @ApiImplicitParam(name = "orgId", value = "登陆人id", paramType = "orgId"),
+    })
+    public Map<String,String> edit(String paymentJson,Integer orgId){
+        ObjectMapper mapper = new ObjectMapper();
+        try {
+            StoragePayment storagePayment = (StoragePayment) mapper.readValue(paymentJson, StoragePayment.class);
+            storagePayment.setOrgId(orgId);
+            if(ParameterUtil.isnotnull(storagePayment.getId())){
+                storagePayMentService.update(storagePayment);
+            }else{
+                storagePayMentService.insert(storagePayment);
+            }
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+        return null;
+    }
+
+    /**
+     * 移除
+     * @param id
+     * @return
+     */
+    @RequestMapping(value = "remove", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value="按ID删除费用信息", notes = "按ID删除费用信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "数据ID", paramType = "form")
+    })
+    public Map<String,String> remove(Integer id){
+        Map<String,String> map = new HashMap<String, String>();
+         storagePayMentService.remove(id);
+        map.put("status","success");
+        return map;
+    }
+}
+
+
+
+
+
+
+
+
+
+
+

src/main/java/com/chinaitop/depot/storage/mapper/StoragePaymentMapper.java

@@ -0,0 +1,33 @@
+package com.chinaitop.depot.storage.mapper;
+
+import com.chinaitop.depot.storage.model.StoragePayment;
+import com.chinaitop.depot.storage.model.StoragePaymentExample;
+import org.apache.ibatis.annotations.Param;
+
+import java.util.List;
+
+public interface StoragePaymentMapper {
+    int countByExample(StoragePaymentExample example);
+
+    int deleteByExample(StoragePaymentExample example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(StoragePayment record);
+
+    int insertSelective(StoragePayment record);
+
+    List<StoragePayment> selectByExample(StoragePaymentExample example);
+
+    StoragePayment selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") StoragePayment record, @Param("example") StoragePaymentExample example);
+
+    int updateByExample(@Param("record") StoragePayment record, @Param("example") StoragePaymentExample example);
+
+    int updateByPrimaryKeySelective(StoragePayment record);
+
+    int updateByPrimaryKey(StoragePayment record);
+
+    List<StoragePayment> queryByExample(StoragePaymentExample example);
+}

src/main/java/com/chinaitop/depot/storage/mapper/StoragePaymentMapper.xml

@@ -0,0 +1,346 @@
+<?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.chinaitop.depot.storage.mapper.StoragePaymentMapper">
+  <resultMap id="BaseResultMap" type="com.chinaitop.depot.storage.model.StoragePayment">
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="org_id" jdbcType="INTEGER" property="orgId" />
+    <result column="unit" jdbcType="VARCHAR" property="unit" />
+    <result column="house_id" jdbcType="INTEGER" property="houseId" />
+    <result column="recorder" jdbcType="VARCHAR" property="recorder" />
+    <result column="count" jdbcType="VARCHAR" property="count" />
+    <result column="type" jdbcType="INTEGER" property="type" />
+    <result column="sub_type" jdbcType="INTEGER" property="subType" />
+    <result column="pay_time" jdbcType="TIMESTAMP" property="payTime" />
+    <result column="price" jdbcType="VARCHAR" property="price" />
+    <result column="number" jdbcType="VARCHAR" property="number" />
+    <result column="pay_content" jdbcType="VARCHAR" property="payContent" />
+  </resultMap>
+  <sql id="Example_Where_Clause">
+    <where>
+      <foreach collection="oredCriteria" item="criteria" separator="or">
+        <if test="criteria.valid">
+          <trim prefix="(" prefixOverrides="and" suffix=")">
+            <foreach collection="criteria.criteria" item="criterion">
+              <choose>
+                <when test="criterion.noValue">
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue">
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue">
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue">
+                  and ${criterion.condition}
+                  <foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Update_By_Example_Where_Clause">
+    <where>
+      <foreach collection="example.oredCriteria" item="criteria" separator="or">
+        <if test="criteria.valid">
+          <trim prefix="(" prefixOverrides="and" suffix=")">
+            <foreach collection="criteria.criteria" item="criterion">
+              <choose>
+                <when test="criterion.noValue">
+                  and ${criterion.condition}
+                </when>
+                <when test="criterion.singleValue">
+                  and ${criterion.condition} #{criterion.value}
+                </when>
+                <when test="criterion.betweenValue">
+                  and ${criterion.condition} #{criterion.value} and #{criterion.secondValue}
+                </when>
+                <when test="criterion.listValue">
+                  and ${criterion.condition}
+                  <foreach close=")" collection="criterion.value" item="listItem" open="(" separator=",">
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Base_Column_List">
+    id, org_id, unit, house_id, recorder, count, type, sub_type, pay_time, price, number, 
+    pay_content
+  </sql>
+  <select id="selectByExample" parameterType="com.chinaitop.depot.storage.model.StoragePaymentExample" resultMap="BaseResultMap">
+    select
+    <if test="distinct">
+      distinct
+    </if>
+    <include refid="Base_Column_List" />
+    from storage_payment
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+    <if test="orderByClause != null">
+      order by ${orderByClause}
+    </if>
+  </select>
+  <select id="selectByPrimaryKey" parameterType="java.lang.Integer" resultMap="BaseResultMap">
+    select 
+    <include refid="Base_Column_List" />
+    from storage_payment
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
+    delete from storage_payment
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <delete id="deleteByExample" parameterType="com.chinaitop.depot.storage.model.StoragePaymentExample">
+    delete from storage_payment
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </delete>
+  <insert id="insert" parameterType="com.chinaitop.depot.storage.model.StoragePayment">
+    insert into storage_payment (id, org_id, unit, 
+      house_id, recorder, count, 
+      type, sub_type, pay_time, 
+      price, number, pay_content
+      )
+    values (#{id,jdbcType=INTEGER}, #{orgId,jdbcType=INTEGER}, #{unit,jdbcType=VARCHAR}, 
+      #{houseId,jdbcType=INTEGER}, #{recorder,jdbcType=VARCHAR}, #{count,jdbcType=VARCHAR}, 
+      #{type,jdbcType=INTEGER}, #{subType,jdbcType=INTEGER}, #{payTime,jdbcType=TIMESTAMP}, 
+      #{price,jdbcType=VARCHAR}, #{number,jdbcType=VARCHAR}, #{payContent,jdbcType=VARCHAR}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.chinaitop.depot.storage.model.StoragePayment">
+    insert into storage_payment
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="orgId != null">
+        org_id,
+      </if>
+      <if test="unit != null">
+        unit,
+      </if>
+      <if test="houseId != null">
+        house_id,
+      </if>
+      <if test="recorder != null">
+        recorder,
+      </if>
+      <if test="count != null">
+        count,
+      </if>
+      <if test="type != null">
+        type,
+      </if>
+      <if test="subType != null">
+        sub_type,
+      </if>
+      <if test="payTime != null">
+        pay_time,
+      </if>
+      <if test="price != null">
+        price,
+      </if>
+      <if test="number != null">
+        number,
+      </if>
+      <if test="payContent != null">
+        pay_content,
+      </if>
+    </trim>
+    <trim prefix="values (" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        #{id,jdbcType=INTEGER},
+      </if>
+      <if test="orgId != null">
+        #{orgId,jdbcType=INTEGER},
+      </if>
+      <if test="unit != null">
+        #{unit,jdbcType=VARCHAR},
+      </if>
+      <if test="houseId != null">
+        #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="recorder != null">
+        #{recorder,jdbcType=VARCHAR},
+      </if>
+      <if test="count != null">
+        #{count,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        #{type,jdbcType=INTEGER},
+      </if>
+      <if test="subType != null">
+        #{subType,jdbcType=INTEGER},
+      </if>
+      <if test="payTime != null">
+        #{payTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="price != null">
+        #{price,jdbcType=VARCHAR},
+      </if>
+      <if test="number != null">
+        #{number,jdbcType=VARCHAR},
+      </if>
+      <if test="payContent != null">
+        #{payContent,jdbcType=VARCHAR},
+      </if>
+    </trim>
+  </insert>
+  <select id="countByExample" parameterType="com.chinaitop.depot.storage.model.StoragePaymentExample" resultType="java.lang.Integer">
+    select count(*) from storage_payment
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </select>
+  <update id="updateByExampleSelective" parameterType="map">
+    update storage_payment
+    <set>
+      <if test="record.id != null">
+        id = #{record.id,jdbcType=INTEGER},
+      </if>
+      <if test="record.orgId != null">
+        org_id = #{record.orgId,jdbcType=INTEGER},
+      </if>
+      <if test="record.unit != null">
+        unit = #{record.unit,jdbcType=VARCHAR},
+      </if>
+      <if test="record.houseId != null">
+        house_id = #{record.houseId,jdbcType=INTEGER},
+      </if>
+      <if test="record.recorder != null">
+        recorder = #{record.recorder,jdbcType=VARCHAR},
+      </if>
+      <if test="record.count != null">
+        count = #{record.count,jdbcType=VARCHAR},
+      </if>
+      <if test="record.type != null">
+        type = #{record.type,jdbcType=INTEGER},
+      </if>
+      <if test="record.subType != null">
+        sub_type = #{record.subType,jdbcType=INTEGER},
+      </if>
+      <if test="record.payTime != null">
+        pay_time = #{record.payTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="record.price != null">
+        price = #{record.price,jdbcType=VARCHAR},
+      </if>
+      <if test="record.number != null">
+        number = #{record.number,jdbcType=VARCHAR},
+      </if>
+      <if test="record.payContent != null">
+        pay_content = #{record.payContent,jdbcType=VARCHAR},
+      </if>
+    </set>
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByExample" parameterType="map">
+    update storage_payment
+    set id = #{record.id,jdbcType=INTEGER},
+      org_id = #{record.orgId,jdbcType=INTEGER},
+      unit = #{record.unit,jdbcType=VARCHAR},
+      house_id = #{record.houseId,jdbcType=INTEGER},
+      recorder = #{record.recorder,jdbcType=VARCHAR},
+      count = #{record.count,jdbcType=VARCHAR},
+      type = #{record.type,jdbcType=INTEGER},
+      sub_type = #{record.subType,jdbcType=INTEGER},
+      pay_time = #{record.payTime,jdbcType=TIMESTAMP},
+      price = #{record.price,jdbcType=VARCHAR},
+      number = #{record.number,jdbcType=VARCHAR},
+      pay_content = #{record.payContent,jdbcType=VARCHAR}
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByPrimaryKeySelective" parameterType="com.chinaitop.depot.storage.model.StoragePayment">
+    update storage_payment
+    <set>
+      <if test="orgId != null">
+        org_id = #{orgId,jdbcType=INTEGER},
+      </if>
+      <if test="unit != null">
+        unit = #{unit,jdbcType=VARCHAR},
+      </if>
+      <if test="houseId != null">
+        house_id = #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="recorder != null">
+        recorder = #{recorder,jdbcType=VARCHAR},
+      </if>
+      <if test="count != null">
+        count = #{count,jdbcType=VARCHAR},
+      </if>
+      <if test="type != null">
+        type = #{type,jdbcType=INTEGER},
+      </if>
+      <if test="subType != null">
+        sub_type = #{subType,jdbcType=INTEGER},
+      </if>
+      <if test="payTime != null">
+        pay_time = #{payTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="price != null">
+        price = #{price,jdbcType=VARCHAR},
+      </if>
+      <if test="number != null">
+        number = #{number,jdbcType=VARCHAR},
+      </if>
+      <if test="payContent != null">
+        pay_content = #{payContent,jdbcType=VARCHAR},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.chinaitop.depot.storage.model.StoragePayment">
+    update storage_payment
+    set org_id = #{orgId,jdbcType=INTEGER},
+      unit = #{unit,jdbcType=VARCHAR},
+      house_id = #{houseId,jdbcType=INTEGER},
+      recorder = #{recorder,jdbcType=VARCHAR},
+      count = #{count,jdbcType=VARCHAR},
+      type = #{type,jdbcType=INTEGER},
+      sub_type = #{subType,jdbcType=INTEGER},
+      pay_time = #{payTime,jdbcType=TIMESTAMP},
+      price = #{price,jdbcType=VARCHAR},
+      number = #{number,jdbcType=VARCHAR},
+      pay_content = #{payContent,jdbcType=VARCHAR}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+
+  <sql id="ExtBase_Column_List">
+    spt.id, spt.org_id, spt.unit, spt.house_id, spt.recorder, spt.count, spt.type, spt.sub_type, spt.pay_time, spt.price, spt.number,
+    spt.pay_content
+  </sql>
+
+  <select id="queryByExample" parameterType="com.chinaitop.depot.storage.model.StoragePaymentExample" resultMap="BaseResultMap">
+    select
+    <if test="distinct">
+      distinct
+    </if>
+    <include refid="ExtBase_Column_List" />,
+    bs.storeHouse_name storehouseName
+    FROM storage_payment spt
+    LEFT JOIN basic_storehouse bs on bs.storehouse_id = spt.house_id
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+   <!--<if test="orderByClause != null">
+      order by ${orderByClause}
+    </if>-->
+    order by spt.pay_time DESC
+  </select>
+</mapper>

src/main/java/com/chinaitop/depot/storage/model/StoragePayment.java

@@ -0,0 +1,232 @@
+package com.chinaitop.depot.storage.model;
+
+import java.util.Date;
+
+public class StoragePayment {
+    private Integer id;
+
+    private Integer orgId;
+
+    private String unit;
+
+    private Integer houseId;
+
+    private String recorder;
+
+    private String count;
+
+    private Integer type;
+
+    private Integer subType;
+
+    private Date payTime;
+
+    private String price;
+
+    private String number;
+
+    private String payContent;
+
+    //业务字段
+    private String storehouseName;//仓房编号
+
+    /**
+     * ID
+     * @return id ID
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     * ID
+     * @param id ID
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    /**
+     * 库级id
+     * @return org_id 库级id
+     */
+    public Integer getOrgId() {
+        return orgId;
+    }
+
+    /**
+     * 库级id
+     * @param orgId 库级id
+     */
+    public void setOrgId(Integer orgId) {
+        this.orgId = orgId;
+    }
+
+    /**
+     * 单位
+     * @return unit 单位
+     */
+    public String getUnit() {
+        return unit;
+    }
+
+    /**
+     * 单位
+     * @param unit 单位
+     */
+    public void setUnit(String unit) {
+        this.unit = unit == null ? null : unit.trim();
+    }
+
+    /**
+     * 仓房ID
+     * @return house_id 仓房ID
+     */
+    public Integer getHouseId() {
+        return houseId;
+    }
+
+    /**
+     * 仓房ID
+     * @param houseId 仓房ID
+     */
+    public void setHouseId(Integer houseId) {
+        this.houseId = houseId;
+    }
+
+    /**
+     * 负责人
+     * @return recorder 负责人
+     */
+    public String getRecorder() {
+        return recorder;
+    }
+
+    /**
+     * 负责人
+     * @param recorder 负责人
+     */
+    public void setRecorder(String recorder) {
+        this.recorder = recorder == null ? null : recorder.trim();
+    }
+
+    /**
+     * 产生费用
+     * @return count 产生费用
+     */
+    public String getCount() {
+        return count;
+    }
+
+    /**
+     * 产生费用
+     * @param count 产生费用
+     */
+    public void setCount(String count) {
+        this.count = count == null ? null : count.trim();
+    }
+
+    /**
+     * 产生费用类型
+     * @return type 产生费用类型
+     */
+    public Integer getType() {
+        return type;
+    }
+
+    /**
+     * 产生费用类型
+     * @param type 产生费用类型
+     */
+    public void setType(Integer type) {
+        this.type = type;
+    }
+
+    /**
+     * 产生费用子类型
+     * @return sub_type 产生费用子类型
+     */
+    public Integer getSubType() {
+        return subType;
+    }
+
+    /**
+     * 产生费用子类型
+     * @param subType 产生费用子类型
+     */
+    public void setSubType(Integer subType) {
+        this.subType = subType;
+    }
+
+    /**
+     * 产生费用时间
+     * @return pay_time 产生费用时间
+     */
+    public Date getPayTime() {
+        return payTime;
+    }
+
+    /**
+     * 产生费用时间
+     * @param payTime 产生费用时间
+     */
+    public void setPayTime(Date payTime) {
+        this.payTime = payTime;
+    }
+
+    /**
+     * 单价
+     * @return price 单价
+     */
+    public String getPrice() {
+        return price;
+    }
+
+    /**
+     * 单价
+     * @param price 单价
+     */
+    public void setPrice(String price) {
+        this.price = price == null ? null : price.trim();
+    }
+
+    /**
+     * 数量
+     * @return number 数量
+     */
+    public String getNumber() {
+        return number;
+    }
+
+    /**
+     * 数量
+     * @param number 数量
+     */
+    public void setNumber(String number) {
+        this.number = number == null ? null : number.trim();
+    }
+
+    /**
+     * 费用产生的原因
+     * @return pay_content 费用产生的原因
+     */
+    public String getPayContent() {
+        return payContent;
+    }
+
+    /**
+     * 费用产生的原因
+     * @param payContent 费用产生的原因
+     */
+    public void setPayContent(String payContent) {
+        this.payContent = payContent == null ? null : payContent.trim();
+    }
+
+    public String getStorehouseName() {
+        return storehouseName;
+    }
+
+    public void setStorehouseName(String storehouseName) {
+        this.storehouseName = storehouseName;
+    }
+}

src/main/java/com/chinaitop/depot/storage/service/StoragePayMentService.java

@@ -0,0 +1,25 @@
+package com.chinaitop.depot.storage.service;
+
+import com.chinaitop.depot.storage.model.StoragePayment;
+import com.chinaitop.depot.storage.model.StoragePaymentExample;
+
+import java.util.List;
+
+/**
+ * @auther mafy
+ * @createtime 2017/10/25 0025
+ */
+public interface StoragePayMentService {
+
+    List<StoragePayment> getlist(StoragePaymentExample storagePaymentExample);
+
+    StoragePayment getObjById(Integer id);
+
+    void insert(StoragePayment storagePayment);
+
+    void update(StoragePayment storagePayment);
+
+    void remove(Integer id);
+
+
+}

src/main/java/com/chinaitop/depot/storage/service/impl/StoragePayMentServiceImpl.java

@@ -0,0 +1,45 @@
+package com.chinaitop.depot.storage.service.impl;
+
+import com.chinaitop.depot.storage.mapper.StoragePaymentMapper;
+import com.chinaitop.depot.storage.model.StoragePayment;
+import com.chinaitop.depot.storage.model.StoragePaymentExample;
+import com.chinaitop.depot.storage.service.StoragePayMentService;
+import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.util.List;
+
+/**
+ * @auther mafy
+ * @createtime 2017/10/25 0025
+ */
+@Service
+public class StoragePayMentServiceImpl implements StoragePayMentService {
+
+    @Resource
+    private StoragePaymentMapper storagePaymentMapper;
+    @Override
+    public List<StoragePayment> getlist(StoragePaymentExample storagePaymentExample) {
+        return storagePaymentMapper.queryByExample(storagePaymentExample);
+    }
+
+    @Override
+    public void insert(StoragePayment storagePayment) {
+        storagePaymentMapper.insertSelective(storagePayment);
+    }
+
+    @Override
+    public void update(StoragePayment storagePayment) {
+        storagePaymentMapper.updateByPrimaryKeySelective(storagePayment);
+    }
+
+    @Override
+    public void remove(Integer id) {
+        storagePaymentMapper.deleteByPrimaryKey(id);
+    }
+
+    @Override
+    public StoragePayment getObjById(Integer id) {
+        return storagePaymentMapper.selectByPrimaryKey(id);
+    }
+}

src/main/java/com/chinaitop/depot/storage/utils/CustomFilter.java

@@ -0,0 +1,38 @@
+package com.chinaitop.depot.storage.utils;
+
+import org.apache.commons.lang.ObjectUtils;
+
+import javax.servlet.*;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+
+public class CustomFilter implements Filter {
+
+	@Override
+    public void init(FilterConfig filterConfig) throws ServletException {
+ 
+    }
+	
+	@Override
+	public void doFilter(ServletRequest arg0, ServletResponse arg1, FilterChain arg2)
+			throws IOException, ServletException {
+		HttpServletRequest request = (HttpServletRequest) arg0;
+		HttpSession session = request.getSession();
+		String orgId = "";
+		if (session != null){
+			orgId = ObjectUtils.toString(session.getAttribute("orgId"),"");
+		}
+		if (!orgId.isEmpty()) {
+			DataPolicyEngine.set(orgId);
+		}
+		arg2.doFilter(arg0, arg1);
+		DataPolicyEngine.remove();
+	}
+	
+	@Override
+    public void destroy() {
+ 
+    }
+
+}

src/main/java/com/chinaitop/depot/storage/utils/DataPolicyEngine.java

@@ -0,0 +1,61 @@
+package com.chinaitop.depot.storage.utils;
+
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+
+/**
+ * 
+ * @author hf
+ * 
+ * @description 数据策略（数据权限控制使用）
+ * 
+ * 
+ */
+public class DataPolicyEngine {
+	//log信息输出对象
+	protected static final Log log = LogFactory.getLog(DataPolicyEngine.class); 
+
+	//本地线程，用于存储线程公共对象
+	private static ThreadLocal threadLocalSession = new ThreadLocal();
+	
+	
+	/**
+	 * @description 获取本地执行线程
+	 *
+	 * @return ThreadLocal 
+	 * 
+	 */
+	public static ThreadLocal getThreadLocalSession() {
+		return threadLocalSession;
+	}
+	
+	/**
+	 * @description 在线程内设置存储对象
+	 * 
+	 */
+	public static void set(Object obj) {
+		threadLocalSession.set(obj);
+
+	}
+	
+	/**
+	 * @description 获取在线程内设置存储的对象
+	 * 
+	 */
+	public static Object get() {
+		return threadLocalSession.get();
+
+	}
+
+	/**
+	 * @description 移除在线程内设置存储的对象
+	 * 
+	 */
+	public static void remove() {
+		threadLocalSession.remove();
+
+	}
+	
+	
+}

src/main/java/com/chinaitop/depot/storage/utils/ParameterUtil.java

@@ -0,0 +1,170 @@
+package com.chinaitop.depot.storage.utils;
+
+import java.io.BufferedInputStream;
+import java.io.InputStream;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+import java.util.Properties;
+
+public class ParameterUtil {
+
+    public static String getSysDateTime(){
+        String temp_str="";
+        Date dt = new Date();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        temp_str=sdf.format(dt);
+        System.out.println("获取当前时间"+temp_str);
+        return temp_str;
+    }
+    
+    public static String getDateYMDHMS(Date date) {
+    	String str = "";
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmss");
+        str=sdf.format(date);
+        System.out.println("获取当前时间"+str);
+        return str;
+    }
+    
+    public static String getSysDate(){
+        String temp_str="";
+        Date dt = new Date();
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
+        temp_str=sdf.format(dt);
+        return temp_str;
+    }
+
+    public static Date string2datetime(String dateTime){
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        Date date = null;
+        try {
+            date = dateFormat.parse(dateTime);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return date;
+    }
+    public static Date string2date(String dateTime){
+        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");
+        Date date = null;
+        try {
+            date = dateFormat.parse(dateTime);
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return date;
+    }
+
+    public static String date2string(Date date){
+        SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd");
+        String str=sdf.format(date);
+        return str;
+    }
+
+    /**
+     * 获取指定时间的时间戳
+     * @param datatime
+     * @return
+     */
+    public static String getTimeStamp(String datatime){
+        long timeStamp = 0;
+        SimpleDateFormat format =  new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        try {
+            Date date = format.parse(datatime);
+            timeStamp = date.getTime();
+        } catch (ParseException e) {
+            e.printStackTrace();
+        }
+        return String.valueOf(timeStamp);
+    }
+
+    /*
+     * 将时间戳转换为时间
+     */
+    public static String stampToDate(String s){
+        String res;
+        SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+        long lt = new Long(s);
+        Date date = new Date(lt);
+        res = simpleDateFormat.format(date);
+        return res;
+    }
+
+    public static void main(String[] args) {
+        System.out.println(stampToDate("1504689208643"));
+        System.out.println(getTimeStamp(getSysDateTime()));
+    }
+    public static String getBHS(String BHS){
+        String[] str = BHS.split(",");
+        StringBuffer sb = new StringBuffer();
+        for(int i=0;i<str.length;i++){
+            sb.append("'").append(str[i]).append("'").append(",");
+        }
+        String s=sb.toString();
+        String t=s.substring(0,s.length()-1);
+        return t;
+    }
+
+    //判断字段值是为空 不为空返回ture
+    public static boolean isnotnull(Object name){
+        return (null!=name&&!"".equals(name) && !"null".equals(name) && "null" != name);
+    }
+    
+    //判断字段值是为空,为空返回ture
+    public static boolean isnull(Object name){
+        return (null==name || "".equals(name) || "null".equals(name) || "null" == name);
+    }
+
+    //判断字段值是相等  相等返回ture
+    public static boolean isequal(Object name,Object value){
+        if(name==value||name.equals(value)){
+            return true;
+        }
+        return false;
+    }
+
+    /**
+     * 判断list和str数组是否全等
+     * @param list
+     * @param str
+     * @return
+     */
+    public static boolean isAllequal(List<String> list,String[] str){
+        boolean isbz = true;
+        for(int z=0;z<str.length;z++){
+            if(!isequal(list.get(z),str[z])){
+                isbz = false;
+                break;
+            }
+        }
+        return !isbz || !(str.length == list.size());
+    }
+
+    //判断字段值是否在某个集合里  在返回ture
+    public static boolean isallequal(Object name,String[] value){
+        for(int i=0;i<value.length;i++){
+            if(name==value[i]||name.equals(value[i])){
+                return true;
+            }
+        }
+        return false;
+    }
+
+    /**
+     * 从properties得到路径
+     * @param filePath
+     * @return
+     */
+    public static Properties readProperties(String filePath) {
+        Properties props = new Properties();
+        try {
+            InputStream in = new BufferedInputStream(ParameterUtil.class.getResourceAsStream(filePath));
+            props.load(in);
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return props;
+    }
+
+}

src/main/java/com/chinaitop/depot/storage/utils/RedisConfig.java

@@ -0,0 +1,61 @@
+package com.chinaitop.depot.storage.utils;
+
+import com.fasterxml.jackson.annotation.JsonAutoDetect;
+import com.fasterxml.jackson.annotation.PropertyAccessor;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.core.*;
+import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
+import org.springframework.data.redis.serializer.StringRedisSerializer;
+
+@Configuration
+public class RedisConfig {
+    @Autowired
+    private RedisConnectionFactory factory;
+
+    @Bean
+    public RedisTemplate<String, Object> redisTemplate() {
+        Jackson2JsonRedisSerializer<Object> jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<Object>(Object.class);
+        ObjectMapper om = new ObjectMapper();
+        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
+        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
+        jackson2JsonRedisSerializer.setObjectMapper(om);
+        RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
+        template.setConnectionFactory(factory);
+        template.setKeySerializer(new StringRedisSerializer());
+        template.setValueSerializer(jackson2JsonRedisSerializer);
+        template.setHashKeySerializer(jackson2JsonRedisSerializer);
+        template.setHashValueSerializer(jackson2JsonRedisSerializer);
+        template.setDefaultSerializer(new StringRedisSerializer());
+        template.afterPropertiesSet();
+        return template;
+    }
+
+    @Bean
+    public HashOperations<String, String, Object> hashOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForHash();
+    }
+
+    @Bean
+    public ValueOperations<String, String> valueOperations(RedisTemplate<String, String> redisTemplate) {
+        return redisTemplate.opsForValue();
+    }
+
+    @Bean
+    public ListOperations<String, Object> listOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForList();
+    }
+
+    @Bean
+    public SetOperations<String, Object> setOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForSet();
+    }
+
+    @Bean
+    public ZSetOperations<String, Object> zSetOperations(RedisTemplate<String, Object> redisTemplate) {
+        return redisTemplate.opsForZSet();
+    }
+}

src/main/java/com/chinaitop/depot/storage/utils/RedisUtil.java

@@ -0,0 +1,544 @@
+package com.chinaitop.depot.storage.utils;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.*;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+
+@Component
+public class RedisUtil {
+
+    @Autowired
+    private RedisTemplate<String, Object> redisTemplate;
+    @Autowired
+    private ValueOperations<String, String> valueOperations;
+    @Autowired
+    private HashOperations<String, String, Object> hashOperations;
+    @Autowired
+    private ListOperations<String, Object> listOperations;
+    @Autowired
+    private SetOperations<String, Object> setOperations;
+
+    //=============================common============================
+    /**
+     * 指定缓存失效时间
+     * @param key 键
+     * @param time 时间(秒)
+     * @return
+     */
+    public boolean expire(String key,long time){
+        try {
+            if(time>0){
+                redisTemplate.expire(key, time, TimeUnit.SECONDS);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据key 获取过期时间
+     * @param key 键 不能为null
+     * @return 时间(秒) 返回0代表为永久有效
+     */
+    public long getExpire(String key){
+        return redisTemplate.getExpire(key,TimeUnit.SECONDS);
+    }
+
+    /**
+     * 判断key是否存在
+     * @param key 键
+     * @return true 存在 false不存在
+     */
+    public boolean hasKey(String key){
+        try {
+            return redisTemplate.hasKey(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除缓存
+     * @param key 可以传一个值 或多个
+     */
+    @SuppressWarnings("unchecked")
+    public void del(String ... key){
+        if(key!=null&&key.length>0){
+            if(key.length==1){
+                redisTemplate.delete(key[0]);
+            }else{
+                redisTemplate.delete(CollectionUtils.arrayToList(key));
+            }
+        }
+    }
+
+    //============================String=============================
+    /**
+     * 普通缓存获取
+     * @param key 键
+     * @return 值
+     */
+    public Object get(String key){
+        return key==null?null:valueOperations.get(key);
+    }
+
+    /**
+     * 普通缓存放入
+     * @param key 键
+     * @param value 值
+     * @return true成功 false失败
+     */
+    public boolean set(String key,String value) {
+        try {
+            valueOperations.set(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+
+    }
+
+    /**
+     * 普通缓存放入并设置时间
+     * @param key 键
+     * @param value 值
+     * @param time 时间(秒) time要大于0 如果time小于等于0 将设置无限期
+     * @return true成功 false 失败
+     */
+    public boolean set(String key,String value,long time){
+        try {
+            if(time>0){
+                valueOperations.set(key, value, time, TimeUnit.SECONDS);
+            }else{
+                set(key, value);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 递增
+     * @param key 键
+     * @param by 要增加几(大于0)
+     * @return
+     */
+    public long incr(String key, long delta){
+        if(delta<0){
+            throw new RuntimeException("递增因子必须大于0");
+        }
+        return valueOperations.increment(key, delta);
+    }
+
+    /**
+     * 递减
+     * @param key 键
+     * @param by 要减少几(小于0)
+     * @return
+     */
+    public long decr(String key, long delta){
+        if(delta<0){
+            throw new RuntimeException("递减因子必须大于0");
+        }
+        return valueOperations.increment(key, -delta);
+    }
+
+    //================================Map=================================
+    /**
+     * HashGet
+     * @param key 键 不能为null
+     * @param item 项 不能为null
+     * @return 值
+     */
+    public Object hget(String key,String item){
+        return hashOperations.get(key, item);
+    }
+
+    /**
+     * 获取hashKey对应的所有键值
+     * @param key 键
+     * @return 对应的多个键值
+     */
+    public Map<String, Object> hmget(String key){
+        return hashOperations.entries(key);
+    }
+
+    /**
+     * HashSet
+     * @param key 键
+     * @param map 对应多个键值
+     * @return true 成功 false 失败
+     */
+    public boolean hmset(String key, Map<String,Object> map){
+        try {
+            hashOperations.putAll(key, map);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * HashSet 并设置时间
+     * @param key 键
+     * @param map 对应多个键值
+     * @param time 时间(秒)
+     * @return true成功 false失败
+     */
+    public boolean hmset(String key, Map<String,Object> map, long time){
+        try {
+            hashOperations.putAll(key, map);
+            if(time>0){
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     * @param key 键
+     * @param item 项
+     * @param value 值
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key,String item,Object value) {
+        try {
+            hashOperations.put(key, item, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 向一张hash表中放入数据,如果不存在将创建
+     * @param key 键
+     * @param item 项
+     * @param value 值
+     * @param time 时间(秒)  注意:如果已存在的hash表有时间,这里将会替换原有的时间
+     * @return true 成功 false失败
+     */
+    public boolean hset(String key,String item,Object value,long time) {
+        try {
+            hashOperations.put(key, item, value);
+            if(time>0){
+                expire(key, time);
+            }
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 删除hash表中的值
+     * @param key 键 不能为null
+     * @param item 项 可以使多个 不能为null
+     */
+    public void hdel(String key, Object... item){
+        hashOperations.delete(key,item);
+    }
+
+    /**
+     * 判断hash表中是否有该项的值
+     * @param key 键 不能为null
+     * @param item 项 不能为null
+     * @return true 存在 false不存在
+     */
+    public boolean hHasKey(String key, String item){
+        return hashOperations.hasKey(key, item);
+    }
+
+    /**
+     * hash递增 如果不存在,就会创建一个 并把新增后的值返回
+     * @param key 键
+     * @param item 项
+     * @param by 要增加几(大于0)
+     * @return
+     */
+    public double hincr(String key, String item,double by){
+        return hashOperations.increment(key, item, by);
+    }
+
+    /**
+     * hash递减
+     * @param key 键
+     * @param item 项
+     * @param by 要减少记(小于0)
+     * @return
+     */
+    public double hdecr(String key, String item,double by){
+        return hashOperations.increment(key, item,-by);
+    }
+
+    //============================set=============================
+    /**
+     * 根据key获取Set中的所有值
+     * @param key 键
+     * @return
+     */
+    public Set<Object> sGet(String key){
+        try {
+            return setOperations.members(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 根据value从一个set中查询,是否存在
+     * @param key 键
+     * @param value 值
+     * @return true 存在 false不存在
+     */
+    public boolean sHasKey(String key,Object value){
+        try {
+            return setOperations.isMember(key, value);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将数据放入set缓存
+     * @param key 键
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSet(String key, Object...values) {
+        try {
+            return setOperations.add(key, values);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 将set数据放入缓存
+     * @param key 键
+     * @param time 时间(秒)
+     * @param values 值 可以是多个
+     * @return 成功个数
+     */
+    public long sSetAndTime(String key,long time,Object...values) {
+        try {
+            Long count = setOperations.add(key, values);
+            if(time>0) expire(key, time);
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 获取set缓存的长度
+     * @param key 键
+     * @return
+     */
+    public long sGetSetSize(String key){
+        try {
+            return setOperations.size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 移除值为value的
+     * @param key 键
+     * @param values 值 可以是多个
+     * @return 移除的个数
+     */
+    public long setRemove(String key, Object ...values) {
+        try {
+            Long count = setOperations.remove(key, values);
+            return count;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+    //===============================list=================================
+
+    /**
+     * 获取list缓存的内容
+     * @param key 键
+     * @param start 开始
+     * @param end 结束  0 到 -1代表所有值
+     * @return
+     */
+    public List<Object> lGet(String key, long start, long end){
+        try {
+            return listOperations.range(key, start, end);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 获取list缓存的所有内容
+     * @param key
+     * @return
+     */
+    public List<Object> lGetAll(String key){
+        return lGet(key,0,-1);
+    }
+
+    /**
+     * 获取list缓存的长度
+     * @param key 键
+     * @return
+     */
+    public long lGetListSize(String key){
+        try {
+            return listOperations.size(key);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+
+    /**
+     * 通过索引 获取list中的值
+     * @param key 键
+     * @param index 索引  index>=0时， 0 表头，1 第二个元素，依次类推；index<0时，-1，表尾，-2倒数第二个元素，依次类推
+     * @return
+     */
+    public Object lGetIndex(String key,long index){
+        try {
+            return listOperations.index(key, index);
+        } catch (Exception e) {
+            e.printStackTrace();
+            return null;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     * @param key 键
+     * @param value 值
+     * @param time 时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, Object value) {
+        try {
+            listOperations.rightPush(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     * @param key 键
+     * @param value 值
+     * @param time 时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, Object value, long time) {
+        try {
+            listOperations.rightPush(key, value);
+            if (time > 0) expire(key, time);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     * @param key 键
+     * @param value 值
+     * @param time 时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, List<Object> value) {
+        try {
+            listOperations.rightPushAll(key, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 将list放入缓存
+     * @param key 键
+     * @param value 值
+     * @param time 时间(秒)
+     * @return
+     */
+    public boolean lSet(String key, List<Object> value, long time) {
+        try {
+            listOperations.rightPushAll(key, value);
+            if (time > 0) expire(key, time);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 根据索引修改list中的某条数据
+     * @param key 键
+     * @param index 索引
+     * @param value 值
+     * @return
+     */
+    public boolean lUpdateIndex(String key, long index,Object value) {
+        try {
+            listOperations.set(key, index, value);
+            return true;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return false;
+        }
+    }
+
+    /**
+     * 移除N个值为value
+     * @param key 键
+     * @param count 移除多少个
+     * @param value 值
+     * @return 移除的个数
+     */
+    public long lRemove(String key,long count,Object value) {
+        try {
+            Long remove = listOperations.remove(key, count, value);
+            return remove;
+        } catch (Exception e) {
+            e.printStackTrace();
+            return 0;
+        }
+    }
+}

src/main/java/com/chinaitop/depot/storage/utils/WebConfig.java

@@ -0,0 +1,40 @@
+package com.chinaitop.depot.storage.utils;
+
+import org.springframework.boot.web.servlet.FilterRegistrationBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * @desc 注册bean, 将自定义过滤器添加到过滤器链中
+ * @Author hf
+ * @date 2019/3/11
+ * @return
+ */
+@Configuration
+public class WebConfig {
+
+   /**
+    * 注册过滤器,有两种方式：
+    * 1) 使用 @Component 注解<br>
+    * 2) 添加到过滤器链中，此方式适用于使用第三方的过滤器。将过滤器写到 WebConfig 类中，如下：
+    */
+   @Bean
+   public FilterRegistrationBean filterRegistrationBean() {
+
+      FilterRegistrationBean registrationBean = new FilterRegistrationBean();
+
+      CustomFilter filter = new CustomFilter();
+      registrationBean.setFilter(filter);
+
+      //设置过滤器拦截请求
+      List<String> urls = new ArrayList<>();
+      urls.add("/*");
+      registrationBean.setUrlPatterns(urls);
+
+      return registrationBean;
+   }
+
+}

src/main/resources/bootstrap.yml

@@ -0,0 +1,47 @@
+server:
+  port: 9015
+  tomcat:
+    uri-encoding: utf-8
+
+# 注册中心配置
+eureka:
+  client:
+    service-url:
+      defaultZone: http://localhost:9001/eureka/
+  instance:
+    prefer-ip-address: true
+
+spring:
+  application:
+    name: depot-payment
+  # 数据库配置
+  datasource:
+    driver-class-name: com.mysql.jdbc.Driver
+    url: jdbc:mysql://192.168.123.98:3306/depot?useUnicode=true&characterEncoding=utf-8
+    username: root
+    password: 123456
+  # 缓存配置
+  session:
+    store-type: redis
+  redis:
+    database: 0
+    host: 192.168.123.98
+    port: 6666
+    password: depotredis
+    timeout: 3000
+    jedis:
+      pool:
+        max-active: 8
+        max-wait: -1
+        max-idle: 8
+        min-idle: 0
+  # 静态资源配置
+  resources:
+    static-locations: classpath:/META-INF/resources/,classpath:/resources/,classpath:/static/,classpath:/public/,file:${web.upload-path}
+
+web:
+  upload-path: /home
+
+  jackson:
+    date-format: yyyy-MM-dd
+    time-zone: GMT+8

src/test/java/com/chinaitop/DepotPaymentApplicationTests.java

@@ -0,0 +1,16 @@
+package com.chinaitop;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest
+public class DepotPaymentApplicationTests {
+
+	@Test
+	public void contextLoads() {
+	}
+
+}