.

Dockerfile

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

pom.xml

@@ -0,0 +1,162 @@
+<?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-keeper-account</artifactId>
+	<version>0.0.1-SNAPSHOT</version>
+	<packaging>jar</packaging>
+
+	<name>depot-keeper-account</name>
+	<description>Demo project for Spring Boot</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>2.0.0.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.M8</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>
+		<dependency>
+			<groupId>mysql</groupId>
+			<artifactId>mysql-connector-java</artifactId>
+		</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>
+
+		<dependency>
+			<groupId>org.apache.commons</groupId>
+			<artifactId>commons-lang3</artifactId>
+		</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-test</artifactId>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>org.apache.poi</groupId>
+			<artifactId>poi-ooxml</artifactId>
+			<version>3.9</version>
+		</dependency>
+		<!-- 阿里巴巴json -->
+		<dependency>
+		    <groupId>com.alibaba</groupId>
+		    <artifactId>fastjson</artifactId>
+		    <version>1.2.37</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>
+        <!-- 加载mybatis逆向生成工具包 -->
+        <dependency>
+		    <groupId>org.mybatis.generator</groupId>
+		    <artifactId>mybatis-generator-core</artifactId>
+		    <!-- 注意版本.这里我使用的是1.3.2 -->
+		    <version>1.3.2</version>
+		</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-war-plugin</artifactId>
+            	<version>2.6</version>
+            	<configuration>
+                	<failOnMissingWebXml>false</failOnMissingWebXml>
+            	</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/depot/DatePermissionInterceptor.java

@@ -0,0 +1,152 @@
+package com.chinaitop.depot;
+
+import com.chinaitop.depot.utils.DataPolicyEngine;
+import com.chinaitop.depot.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是查询的才进行权限过滤
+	    if(mappedStatement.getSqlCommandType().toString().equals("select".toUpperCase())) {
+	    
+			//通过本地线程获取库id
+			Object threadLocalObj = DataPolicyEngine.get();
+			String orgId = null;
+			if(threadLocalObj != null) {
+				orgId = ObjectUtils.toString(threadLocalObj);
+			}
+			if(orgId!=null) {
+				//解析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/depot/DepotKeeperAccountApplication.java

@@ -0,0 +1,19 @@
+package com.chinaitop.depot;
+
+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 DepotKeeperAccountApplication {
+
+	public static void main(String[] args) {
+		SpringApplication.run(DepotKeeperAccountApplication.class, args);
+	}
+}

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

@@ -0,0 +1,12 @@
+package com.chinaitop.depot;
+ 
+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(DepotKeeperAccountApplication.class);
+    }
+ 
+}

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

@@ -0,0 +1,35 @@
+package com.chinaitop.depot;
+
+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.keeperAccount.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/keeperAccount/controller/StorageAccountRecordController.java

@@ -0,0 +1,118 @@
+package com.chinaitop.depot.keeperAccount.controller;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.Resource;
+
+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 com.chinaitop.depot.keeperAccount.model.StorageAccountRecord;
+import com.chinaitop.depot.keeperAccount.service.StorageAccountRecordService;
+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;
+
+@RestController
+@RequestMapping(value="/StorageAccountRecord")
+@Api(value= "StorageAccountRecordController", description = "保管账记账控制类")
+public class StorageAccountRecordController {
+
+	@Resource
+	private StorageAccountRecordService recordService;
+
+	@RequestMapping(value="/sumAccountList", 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="lspz", value="粮食品种", paramType="query"),
+    	@ApiImplicitParam(name="lsxz", value="粮食性质", paramType="query"),
+    	@ApiImplicitParam(name="startDate", value="起始时间", paramType="query"),
+    	@ApiImplicitParam(name="endDate", value="结束时间", paramType="query")
+    })
+	public PageInfo<Map<String, Object>> sumAccountList(Integer pageNum, Integer pageSize, 
+			Integer lspz, Integer lsxz, String startDate, String endDate) {
+		Map<String, Object> map = new HashMap<String, Object>();
+		if (lspz != null) {
+			map.put("pz", lspz+"");
+		}
+		if (lsxz != null) {
+			map.put("hwxz", lsxz+"");
+		}
+		if (pageNum!=null && pageSize!=null) {
+			PageHelper.startPage(pageNum, pageSize);
+		}
+		List<Map<String, Object>> list = recordService.selectKeepSumAccountData(map);
+		if (null != list && list.size() > 0) {
+			Map<String, Object> kcsl_map = null;
+			List<Map<String, Object>> kcsl_list = null;
+			for (Map<String, Object> obj : list) {
+				kcsl_map = new HashMap<String, Object>();
+				kcsl_map.put("pz", obj.get("lspz"));
+				kcsl_map.put("hwxz", obj.get("hwxz"));
+				kcsl_map.put("rq", obj.get("rq"));
+				kcsl_list = recordService.selectKCSL(kcsl_map);
+				if (null != kcsl_list && kcsl_list.size() > 0) {
+					obj.put("kcsl", kcsl_list.get(0).get("kcsl"));
+				}
+			}
+		}
+		PageInfo<Map<String, Object>> pageInfo = new PageInfo<Map<String, Object>>(list);
+		return pageInfo;
+	}
+
+	@RequestMapping(value = "/edit", produces = MediaType.APPLICATION_JSON_VALUE, method=RequestMethod.GET)
+	@ApiOperation(value="查询一条记账数据", notes = "查询一条记账数据")
+    @ApiImplicitParams({
+    	@ApiImplicitParam(name="houseId", value="仓房ID", paramType="query"),
+    	@ApiImplicitParam(name="wareId", value="货位ID", paramType="query"),
+    	@ApiImplicitParam(name="hwxz", value="粮食性质", paramType="query"),
+    	@ApiImplicitParam(name="lspz", value="粮食品种", paramType="query"),
+    	@ApiImplicitParam(name="rq", value="日期", paramType="query"),
+    	@ApiImplicitParam(name="accountType", value="记账类型", paramType="query")
+    })
+	public Map<String, Object> edit(Integer houseId, Integer wareId, Integer hwxz, Integer lspz, String rq, Integer accountType) {
+		Map<String, Object> map = new HashMap<String, Object>();
+		
+		map = recordService.selectOrCheckStorageAccountRecord(houseId, wareId, hwxz, lspz, rq, accountType, map);
+
+		return map;
+	}
+
+	@RequestMapping(value = "/update", produces = MediaType.APPLICATION_JSON_VALUE, method=RequestMethod.POST)
+	@ApiOperation(value="记账", notes = "记账")
+    @ApiImplicitParams({
+    	@ApiImplicitParam(name="recordJson", value="数据集", paramType="form"),
+    	@ApiImplicitParam(name="accountType", value="记账类型", paramType="form"),
+    	@ApiImplicitParam(name="orgId", value="单位ID", paramType="form")
+    })
+	public Map<String, Object> update(String recordJson, Integer accountType, Integer orgId) {
+		Map<String, Object> map = new HashMap<String, Object>();
+		ObjectMapper mapper = new ObjectMapper();
+		try {
+			StorageAccountRecord record = mapper.readValue(recordJson, StorageAccountRecord.class);
+			if (record.getId() == null) {
+				record.setAccountType(accountType);
+				record.setOrgId(orgId);
+				recordService.add(record);
+			} else {
+				recordService.update(record);
+			}
+			map.put("status", "success");
+			map.put("msg", "保存成功！");
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		return map;
+	}
+}

src/main/java/com/chinaitop/depot/keeperAccount/mapper/StorageAccountRecordMapper.java

@@ -0,0 +1,46 @@
+package com.chinaitop.depot.keeperAccount.mapper;
+
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecord;
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample;
+import java.util.List;
+import java.util.Map;
+
+import org.apache.ibatis.annotations.Param;
+
+public interface StorageAccountRecordMapper {
+    int countByExample(StorageAccountRecordExample example);
+
+    int deleteByExample(StorageAccountRecordExample example);
+
+    int deleteByPrimaryKey(Integer id);
+
+    int insert(StorageAccountRecord record);
+
+    int insertSelective(StorageAccountRecord record);
+
+    List<StorageAccountRecord> selectByExample(StorageAccountRecordExample example);
+
+    StorageAccountRecord selectByPrimaryKey(Integer id);
+
+    int updateByExampleSelective(@Param("record") StorageAccountRecord record, @Param("example") StorageAccountRecordExample example);
+
+    int updateByExample(@Param("record") StorageAccountRecord record, @Param("example") StorageAccountRecordExample example);
+
+    int updateByPrimaryKeySelective(StorageAccountRecord record);
+
+    int updateByPrimaryKey(StorageAccountRecord record);
+
+    /**
+     * 保管总账查询列表
+     * @param map
+     * @return
+     */
+    List<Map<String, Object>> selectKeepSumAccount(Map<String, Object> map);
+
+    /**
+     * 查询保管总账查询列表的库存数量
+     * @param map
+     * @return
+     */
+    List<Map<String, Object>> selectKCSL(Map<String, Object> map);
+}

src/main/java/com/chinaitop/depot/keeperAccount/mapper/StorageAccountRecordMapper.xml

@@ -0,0 +1,505 @@
+<?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.keeperAccount.mapper.StorageAccountRecordMapper">
+  <resultMap id="BaseResultMap" type="com.chinaitop.depot.keeperAccount.model.StorageAccountRecord">
+    <id column="id" jdbcType="INTEGER" property="id" />
+    <result column="org_id" jdbcType="INTEGER" property="orgId" />
+    <result column="account_type" jdbcType="INTEGER" property="accountType" />
+    <result column="house_id" jdbcType="INTEGER" property="houseId" />
+    <result column="ware_id" jdbcType="INTEGER" property="wareId" />
+    <result column="record_unite" jdbcType="VARCHAR" property="recordUnite" />
+    <result column="lspz" jdbcType="INTEGER" property="lspz" />
+    <result column="hwxz" jdbcType="INTEGER" property="hwxz" />
+    <result column="level" jdbcType="INTEGER" property="level" />
+    <result column="rq" jdbcType="VARCHAR" property="rq" />
+    <result column="rq_date" jdbcType="TIMESTAMP" property="rqDate" />
+    <result column="srsl" jdbcType="DECIMAL" property="srsl" />
+    <result column="zcsl" jdbcType="DECIMAL" property="zcsl" />
+    <result column="kcsl" jdbcType="DECIMAL" property="kcsl" />
+    <result column="remark" jdbcType="VARCHAR" property="remark" />
+    <result column="accounting_person" jdbcType="VARCHAR" property="accountingPerson" />
+    <result column="accounting_date" jdbcType="TIMESTAMP" property="accountingDate" />
+    <result column="auditor" jdbcType="VARCHAR" property="auditor" />
+    <result column="auditor_date" jdbcType="TIMESTAMP" property="auditorDate" />
+    <result column="auditor_opinion" jdbcType="VARCHAR" property="auditorOpinion" />
+    <result column="updatetime" jdbcType="TIMESTAMP" property="updatetime" />
+  </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, account_type, house_id, ware_id, record_unite, lspz, hwxz, level, rq, 
+    rq_date, srsl, zcsl, kcsl, remark, accounting_person, accounting_date, auditor, auditor_date, 
+    auditor_opinion, updatetime
+  </sql>
+  <select id="selectByExample" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample" resultMap="BaseResultMap">
+    select
+    <if test="distinct">
+      distinct
+    </if>
+    <include refid="Base_Column_List" />
+    from storage_account_record
+    <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_account_record
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer">
+    delete from storage_account_record
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <delete id="deleteByExample" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample">
+    delete from storage_account_record
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </delete>
+  <insert id="insert" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecord">
+    insert into storage_account_record (id, org_id, account_type, 
+      house_id, ware_id, record_unite, 
+      lspz, hwxz, level, 
+      rq, rq_date, srsl, 
+      zcsl, kcsl, remark, 
+      accounting_person, accounting_date, auditor, 
+      auditor_date, auditor_opinion, updatetime
+      )
+    values (#{id,jdbcType=INTEGER}, #{orgId,jdbcType=INTEGER}, #{accountType,jdbcType=INTEGER}, 
+      #{houseId,jdbcType=INTEGER}, #{wareId,jdbcType=INTEGER}, #{recordUnite,jdbcType=VARCHAR}, 
+      #{lspz,jdbcType=INTEGER}, #{hwxz,jdbcType=INTEGER}, #{level,jdbcType=INTEGER}, 
+      #{rq,jdbcType=VARCHAR}, #{rqDate,jdbcType=TIMESTAMP}, #{srsl,jdbcType=DECIMAL}, 
+      #{zcsl,jdbcType=DECIMAL}, #{kcsl,jdbcType=DECIMAL}, #{remark,jdbcType=VARCHAR}, 
+      #{accountingPerson,jdbcType=VARCHAR}, #{accountingDate,jdbcType=TIMESTAMP}, #{auditor,jdbcType=VARCHAR}, 
+      #{auditorDate,jdbcType=TIMESTAMP}, #{auditorOpinion,jdbcType=VARCHAR}, #{updatetime,jdbcType=TIMESTAMP}
+      )
+  </insert>
+  <insert id="insertSelective" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecord">
+    insert into storage_account_record
+    <trim prefix="(" suffix=")" suffixOverrides=",">
+      <if test="id != null">
+        id,
+      </if>
+      <if test="orgId != null">
+        org_id,
+      </if>
+      <if test="accountType != null">
+        account_type,
+      </if>
+      <if test="houseId != null">
+        house_id,
+      </if>
+      <if test="wareId != null">
+        ware_id,
+      </if>
+      <if test="recordUnite != null">
+        record_unite,
+      </if>
+      <if test="lspz != null">
+        lspz,
+      </if>
+      <if test="hwxz != null">
+        hwxz,
+      </if>
+      <if test="level != null">
+        level,
+      </if>
+      <if test="rq != null">
+        rq,
+      </if>
+      <if test="rqDate != null">
+        rq_date,
+      </if>
+      <if test="srsl != null">
+        srsl,
+      </if>
+      <if test="zcsl != null">
+        zcsl,
+      </if>
+      <if test="kcsl != null">
+        kcsl,
+      </if>
+      <if test="remark != null">
+        remark,
+      </if>
+      <if test="accountingPerson != null">
+        accounting_person,
+      </if>
+      <if test="accountingDate != null">
+        accounting_date,
+      </if>
+      <if test="auditor != null">
+        auditor,
+      </if>
+      <if test="auditorDate != null">
+        auditor_date,
+      </if>
+      <if test="auditorOpinion != null">
+        auditor_opinion,
+      </if>
+      <if test="updatetime != null">
+        updatetime,
+      </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="accountType != null">
+        #{accountType,jdbcType=INTEGER},
+      </if>
+      <if test="houseId != null">
+        #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="wareId != null">
+        #{wareId,jdbcType=INTEGER},
+      </if>
+      <if test="recordUnite != null">
+        #{recordUnite,jdbcType=VARCHAR},
+      </if>
+      <if test="lspz != null">
+        #{lspz,jdbcType=INTEGER},
+      </if>
+      <if test="hwxz != null">
+        #{hwxz,jdbcType=INTEGER},
+      </if>
+      <if test="level != null">
+        #{level,jdbcType=INTEGER},
+      </if>
+      <if test="rq != null">
+        #{rq,jdbcType=VARCHAR},
+      </if>
+      <if test="rqDate != null">
+        #{rqDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="srsl != null">
+        #{srsl,jdbcType=DECIMAL},
+      </if>
+      <if test="zcsl != null">
+        #{zcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="kcsl != null">
+        #{kcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="remark != null">
+        #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="accountingPerson != null">
+        #{accountingPerson,jdbcType=VARCHAR},
+      </if>
+      <if test="accountingDate != null">
+        #{accountingDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="auditor != null">
+        #{auditor,jdbcType=VARCHAR},
+      </if>
+      <if test="auditorDate != null">
+        #{auditorDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="auditorOpinion != null">
+        #{auditorOpinion,jdbcType=VARCHAR},
+      </if>
+      <if test="updatetime != null">
+        #{updatetime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <select id="countByExample" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample" resultType="java.lang.Integer">
+    select count(*) from storage_account_record
+    <if test="_parameter != null">
+      <include refid="Example_Where_Clause" />
+    </if>
+  </select>
+  <update id="updateByExampleSelective" parameterType="map">
+    update storage_account_record
+    <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.accountType != null">
+        account_type = #{record.accountType,jdbcType=INTEGER},
+      </if>
+      <if test="record.houseId != null">
+        house_id = #{record.houseId,jdbcType=INTEGER},
+      </if>
+      <if test="record.wareId != null">
+        ware_id = #{record.wareId,jdbcType=INTEGER},
+      </if>
+      <if test="record.recordUnite != null">
+        record_unite = #{record.recordUnite,jdbcType=VARCHAR},
+      </if>
+      <if test="record.lspz != null">
+        lspz = #{record.lspz,jdbcType=INTEGER},
+      </if>
+      <if test="record.hwxz != null">
+        hwxz = #{record.hwxz,jdbcType=INTEGER},
+      </if>
+      <if test="record.level != null">
+        level = #{record.level,jdbcType=INTEGER},
+      </if>
+      <if test="record.rq != null">
+        rq = #{record.rq,jdbcType=VARCHAR},
+      </if>
+      <if test="record.rqDate != null">
+        rq_date = #{record.rqDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="record.srsl != null">
+        srsl = #{record.srsl,jdbcType=DECIMAL},
+      </if>
+      <if test="record.zcsl != null">
+        zcsl = #{record.zcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="record.kcsl != null">
+        kcsl = #{record.kcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="record.remark != null">
+        remark = #{record.remark,jdbcType=VARCHAR},
+      </if>
+      <if test="record.accountingPerson != null">
+        accounting_person = #{record.accountingPerson,jdbcType=VARCHAR},
+      </if>
+      <if test="record.accountingDate != null">
+        accounting_date = #{record.accountingDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="record.auditor != null">
+        auditor = #{record.auditor,jdbcType=VARCHAR},
+      </if>
+      <if test="record.auditorDate != null">
+        auditor_date = #{record.auditorDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="record.auditorOpinion != null">
+        auditor_opinion = #{record.auditorOpinion,jdbcType=VARCHAR},
+      </if>
+      <if test="record.updatetime != null">
+        updatetime = #{record.updatetime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByExample" parameterType="map">
+    update storage_account_record
+    set id = #{record.id,jdbcType=INTEGER},
+      org_id = #{record.orgId,jdbcType=INTEGER},
+      account_type = #{record.accountType,jdbcType=INTEGER},
+      house_id = #{record.houseId,jdbcType=INTEGER},
+      ware_id = #{record.wareId,jdbcType=INTEGER},
+      record_unite = #{record.recordUnite,jdbcType=VARCHAR},
+      lspz = #{record.lspz,jdbcType=INTEGER},
+      hwxz = #{record.hwxz,jdbcType=INTEGER},
+      level = #{record.level,jdbcType=INTEGER},
+      rq = #{record.rq,jdbcType=VARCHAR},
+      rq_date = #{record.rqDate,jdbcType=TIMESTAMP},
+      srsl = #{record.srsl,jdbcType=DECIMAL},
+      zcsl = #{record.zcsl,jdbcType=DECIMAL},
+      kcsl = #{record.kcsl,jdbcType=DECIMAL},
+      remark = #{record.remark,jdbcType=VARCHAR},
+      accounting_person = #{record.accountingPerson,jdbcType=VARCHAR},
+      accounting_date = #{record.accountingDate,jdbcType=TIMESTAMP},
+      auditor = #{record.auditor,jdbcType=VARCHAR},
+      auditor_date = #{record.auditorDate,jdbcType=TIMESTAMP},
+      auditor_opinion = #{record.auditorOpinion,jdbcType=VARCHAR},
+      updatetime = #{record.updatetime,jdbcType=TIMESTAMP}
+    <if test="_parameter != null">
+      <include refid="Update_By_Example_Where_Clause" />
+    </if>
+  </update>
+  <update id="updateByPrimaryKeySelective" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecord">
+    update storage_account_record
+    <set>
+      <if test="orgId != null">
+        org_id = #{orgId,jdbcType=INTEGER},
+      </if>
+      <if test="accountType != null">
+        account_type = #{accountType,jdbcType=INTEGER},
+      </if>
+      <if test="houseId != null">
+        house_id = #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="wareId != null">
+        ware_id = #{wareId,jdbcType=INTEGER},
+      </if>
+      <if test="recordUnite != null">
+        record_unite = #{recordUnite,jdbcType=VARCHAR},
+      </if>
+      <if test="lspz != null">
+        lspz = #{lspz,jdbcType=INTEGER},
+      </if>
+      <if test="hwxz != null">
+        hwxz = #{hwxz,jdbcType=INTEGER},
+      </if>
+      <if test="level != null">
+        level = #{level,jdbcType=INTEGER},
+      </if>
+      <if test="rq != null">
+        rq = #{rq,jdbcType=VARCHAR},
+      </if>
+      <if test="rqDate != null">
+        rq_date = #{rqDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="srsl != null">
+        srsl = #{srsl,jdbcType=DECIMAL},
+      </if>
+      <if test="zcsl != null">
+        zcsl = #{zcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="kcsl != null">
+        kcsl = #{kcsl,jdbcType=DECIMAL},
+      </if>
+      <if test="remark != null">
+        remark = #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="accountingPerson != null">
+        accounting_person = #{accountingPerson,jdbcType=VARCHAR},
+      </if>
+      <if test="accountingDate != null">
+        accounting_date = #{accountingDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="auditor != null">
+        auditor = #{auditor,jdbcType=VARCHAR},
+      </if>
+      <if test="auditorDate != null">
+        auditor_date = #{auditorDate,jdbcType=TIMESTAMP},
+      </if>
+      <if test="auditorOpinion != null">
+        auditor_opinion = #{auditorOpinion,jdbcType=VARCHAR},
+      </if>
+      <if test="updatetime != null">
+        updatetime = #{updatetime,jdbcType=TIMESTAMP},
+      </if>
+    </set>
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <update id="updateByPrimaryKey" parameterType="com.chinaitop.depot.keeperAccount.model.StorageAccountRecord">
+    update storage_account_record
+    set org_id = #{orgId,jdbcType=INTEGER},
+      account_type = #{accountType,jdbcType=INTEGER},
+      house_id = #{houseId,jdbcType=INTEGER},
+      ware_id = #{wareId,jdbcType=INTEGER},
+      record_unite = #{recordUnite,jdbcType=VARCHAR},
+      lspz = #{lspz,jdbcType=INTEGER},
+      hwxz = #{hwxz,jdbcType=INTEGER},
+      level = #{level,jdbcType=INTEGER},
+      rq = #{rq,jdbcType=VARCHAR},
+      rq_date = #{rqDate,jdbcType=TIMESTAMP},
+      srsl = #{srsl,jdbcType=DECIMAL},
+      zcsl = #{zcsl,jdbcType=DECIMAL},
+      kcsl = #{kcsl,jdbcType=DECIMAL},
+      remark = #{remark,jdbcType=VARCHAR},
+      accounting_person = #{accountingPerson,jdbcType=VARCHAR},
+      accounting_date = #{accountingDate,jdbcType=TIMESTAMP},
+      auditor = #{auditor,jdbcType=VARCHAR},
+      auditor_date = #{auditorDate,jdbcType=TIMESTAMP},
+      auditor_opinion = #{auditorOpinion,jdbcType=VARCHAR},
+      updatetime = #{updatetime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+  <!-- 保管总账查询列表 -->
+  <select id="selectKeepSumAccount" parameterType="java.util.Map" resultType="java.util.Map">
+	SELECT 
+		fcbgz.hwxz, fcbgz.lspz, DATE_FORMAT(fcbgz.rq,'%Y-%m') as rq, sum(fcbgz.srsl) as srsl, 
+		sum(fcbgz.zcsl) as zcsl, (sum(fcbgz.srsl)-sum(fcbgz.zcsl)) as kcsl 
+	FROM (
+		SELECT * FROM storage_account_record where 1=1 AND account_type=0 AND auditor_date IS NOT NULL 
+		<if test="pz != null">
+	        and lspz = #{pz} 
+	    </if>
+	    <if test="hwxz != null">
+	        and hwxz = #{hwxz} 
+	    </if>
+	) fcbgz 
+	group by fcbgz.hwxz, fcbgz.lspz, DATE_FORMAT(fcbgz.rq,'%Y-%m') 
+	order by fcbgz.rq
+  </select>
+  <!-- 查询保管总账查询列表的库存数量 -->
+  <select id="selectKCSL" parameterType="java.util.Map" resultType="java.util.Map">
+	SELECT c.lspz AS lspz,c.hwxz AS hwxz,SUM(c.kcsl) as kcsl FROM 
+	(
+	SELECT b.house_id,b.ware_id,b.lspz,b.hwxz,DATE_FORMAT(b.rq, '%Y-%m') AS rq,kcsl FROM ( SELECT * FROM storage_account_record ORDER BY rq DESC) b
+		WHERE 1=1 
+		<if test="rq != null">
+			AND DATE_FORMAT(b.rq, '%Y-%m') = #{rq} 
+		</if>
+		AND b.account_type = 0 
+		AND auditor_date IS NOT NULL 
+		GROUP BY b.house_id,b.ware_id,b.lspz,b.hwxz 
+		ORDER BY b.house_id,b.ware_id 
+	) c
+	WHERE 1=1 
+	<if test="pz != null">
+        and c.lspz = #{pz} 
+    </if>
+    <if test="hwxz != null">
+        and c.hwxz = #{hwxz} 
+    </if>
+	GROUP BY c.lspz,c.hwxz,c.rq
+  </select>
+</mapper>

src/main/java/com/chinaitop/depot/keeperAccount/model/StorageAccountRecord.java

@@ -0,0 +1,384 @@
+package com.chinaitop.depot.keeperAccount.model;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+public class StorageAccountRecord {
+    private Integer id;
+
+    private Integer orgId;
+
+    private Integer accountType;
+
+    private Integer houseId;
+
+    private Integer wareId;
+
+    private String recordUnite;
+
+    private Integer lspz;
+
+    private Integer hwxz;
+
+    private Integer level;
+
+    private String rq;
+
+    private Date rqDate;
+
+    private BigDecimal srsl;
+
+    private BigDecimal zcsl;
+
+    private BigDecimal kcsl;
+
+    private String remark;
+
+    private String accountingPerson;
+
+    private Date accountingDate;
+
+    private String auditor;
+
+    private Date auditorDate;
+
+    private String auditorOpinion;
+
+    private Date updatetime;
+
+    /**
+     * 主键编号
+     * @return id 主键编号
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     * 主键编号
+     * @param 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;
+    }
+
+    /**
+     * 账目类型(0分仓账，1总账)
+     * @return account_type 账目类型(0分仓账，1总账)
+     */
+    public Integer getAccountType() {
+        return accountType;
+    }
+
+    /**
+     * 账目类型(0分仓账，1总账)
+     * @param accountType 账目类型(0分仓账，1总账)
+     */
+    public void setAccountType(Integer accountType) {
+        this.accountType = accountType;
+    }
+
+    /**
+     * 仓房ID
+     * @return house_id 仓房ID
+     */
+    public Integer getHouseId() {
+        return houseId;
+    }
+
+    /**
+     * 仓房ID
+     * @param houseId 仓房ID
+     */
+    public void setHouseId(Integer houseId) {
+        this.houseId = houseId;
+    }
+
+    /**
+     * 货位ID
+     * @return ware_id 货位ID
+     */
+    public Integer getWareId() {
+        return wareId;
+    }
+
+    /**
+     * 货位ID
+     * @param wareId 货位ID
+     */
+    public void setWareId(Integer wareId) {
+        this.wareId = wareId;
+    }
+
+    /**
+     * 粮权单位
+     * @return record_unite 粮权单位
+     */
+    public String getRecordUnite() {
+        return recordUnite;
+    }
+
+    /**
+     * 粮权单位
+     * @param recordUnite 粮权单位
+     */
+    public void setRecordUnite(String recordUnite) {
+        this.recordUnite = recordUnite == null ? null : recordUnite.trim();
+    }
+
+    /**
+     * 粮食品种
+     * @return lspz 粮食品种
+     */
+    public Integer getLspz() {
+        return lspz;
+    }
+
+    /**
+     * 粮食品种
+     * @param lspz 粮食品种
+     */
+    public void setLspz(Integer lspz) {
+        this.lspz = lspz;
+    }
+
+    /**
+     * 货物性质
+     * @return hwxz 货物性质
+     */
+    public Integer getHwxz() {
+        return hwxz;
+    }
+
+    /**
+     * 货物性质
+     * @param hwxz 货物性质
+     */
+    public void setHwxz(Integer hwxz) {
+        this.hwxz = hwxz;
+    }
+
+    /**
+     * 粮食等级
+     * @return level 粮食等级
+     */
+    public Integer getLevel() {
+        return level;
+    }
+
+    /**
+     * 粮食等级
+     * @param level 粮食等级
+     */
+    public void setLevel(Integer level) {
+        this.level = level;
+    }
+
+    /**
+     * 日期(总账)
+     * @return rq 日期(总账)
+     */
+    public String getRq() {
+        return rq;
+    }
+
+    /**
+     * 日期(总账)
+     * @param rq 日期(总账)
+     */
+    public void setRq(String rq) {
+        this.rq = rq == null ? null : rq.trim();
+    }
+
+    /**
+     * 日期(分仓账)
+     * @return rq_date 日期(分仓账)
+     */
+    public Date getRqDate() {
+        return rqDate;
+    }
+
+    /**
+     * 日期(分仓账)
+     * @param rqDate 日期(分仓账)
+     */
+    public void setRqDate(Date rqDate) {
+        this.rqDate = rqDate;
+    }
+
+    /**
+     * 收入数量
+     * @return srsl 收入数量
+     */
+    public BigDecimal getSrsl() {
+        return srsl;
+    }
+
+    /**
+     * 收入数量
+     * @param srsl 收入数量
+     */
+    public void setSrsl(BigDecimal srsl) {
+        this.srsl = srsl;
+    }
+
+    /**
+     * 支出数量
+     * @return zcsl 支出数量
+     */
+    public BigDecimal getZcsl() {
+        return zcsl;
+    }
+
+    /**
+     * 支出数量
+     * @param zcsl 支出数量
+     */
+    public void setZcsl(BigDecimal zcsl) {
+        this.zcsl = zcsl;
+    }
+
+    /**
+     * 库存数量
+     * @return kcsl 库存数量
+     */
+    public BigDecimal getKcsl() {
+        return kcsl;
+    }
+
+    /**
+     * 库存数量
+     * @param kcsl 库存数量
+     */
+    public void setKcsl(BigDecimal kcsl) {
+        this.kcsl = kcsl;
+    }
+
+    /**
+     * 摘要
+     * @return remark 摘要
+     */
+    public String getRemark() {
+        return remark;
+    }
+
+    /**
+     * 摘要
+     * @param remark 摘要
+     */
+    public void setRemark(String remark) {
+        this.remark = remark == null ? null : remark.trim();
+    }
+
+    /**
+     * 记账人
+     * @return accounting_person 记账人
+     */
+    public String getAccountingPerson() {
+        return accountingPerson;
+    }
+
+    /**
+     * 记账人
+     * @param accountingPerson 记账人
+     */
+    public void setAccountingPerson(String accountingPerson) {
+        this.accountingPerson = accountingPerson == null ? null : accountingPerson.trim();
+    }
+
+    /**
+     * 记账时间
+     * @return accounting_date 记账时间
+     */
+    public Date getAccountingDate() {
+        return accountingDate;
+    }
+
+    /**
+     * 记账时间
+     * @param accountingDate 记账时间
+     */
+    public void setAccountingDate(Date accountingDate) {
+        this.accountingDate = accountingDate;
+    }
+
+    /**
+     * 审核人
+     * @return auditor 审核人
+     */
+    public String getAuditor() {
+        return auditor;
+    }
+
+    /**
+     * 审核人
+     * @param auditor 审核人
+     */
+    public void setAuditor(String auditor) {
+        this.auditor = auditor == null ? null : auditor.trim();
+    }
+
+    /**
+     * 审核时间
+     * @return auditor_date 审核时间
+     */
+    public Date getAuditorDate() {
+        return auditorDate;
+    }
+
+    /**
+     * 审核时间
+     * @param auditorDate 审核时间
+     */
+    public void setAuditorDate(Date auditorDate) {
+        this.auditorDate = auditorDate;
+    }
+
+    /**
+     * 审核意见
+     * @return auditor_opinion 审核意见
+     */
+    public String getAuditorOpinion() {
+        return auditorOpinion;
+    }
+
+    /**
+     * 审核意见
+     * @param auditorOpinion 审核意见
+     */
+    public void setAuditorOpinion(String auditorOpinion) {
+        this.auditorOpinion = auditorOpinion == null ? null : auditorOpinion.trim();
+    }
+
+    /**
+     * 
+     * @return updatetime 
+     */
+    public Date getUpdatetime() {
+        return updatetime;
+    }
+
+    /**
+     * 
+     * @param updatetime 
+     */
+    public void setUpdatetime(Date updatetime) {
+        this.updatetime = updatetime;
+    }
+}

src/main/java/com/chinaitop/depot/keeperAccount/service/StorageAccountRecordService.java

@@ -0,0 +1,65 @@
+package com.chinaitop.depot.keeperAccount.service;
+
+import java.util.List;
+import java.util.Map;
+
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecord;
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample;
+
+public interface StorageAccountRecordService {
+
+	/**
+	 * 新增
+	 * 
+	 * @param record
+	 *            数据对象
+	 */
+	void add(StorageAccountRecord record);
+
+	/**
+	 * 修改
+	 * 
+	 * @param record
+	 *            数据对象
+	 */
+	void update(StorageAccountRecord record);
+
+	/**
+	 * 按条件查询数据
+	 * 
+	 * @param example
+	 *            条件
+	 * @return
+	 */
+	List<StorageAccountRecord> findByConditon(StorageAccountRecordExample example);
+
+	/**
+	 * 查询数据
+	 * 
+	 * @param houseId 仓房ID
+	 * @param wareId 货位ID
+	 * @param hwxz 货物性质
+	 * @param lspz lspz
+	 * @param rq 日期
+	 * @param map 返回对象
+	 * @return
+	 */
+	Map<String, Object> selectOrCheckStorageAccountRecord(Integer houseId, Integer wareId, Integer hwxz, Integer lspz,
+			String rq, Integer accountType, Map<String, Object> map);
+
+	/**
+	 * 保管总账列表
+	 * 
+	 * @param map
+	 * @return
+	 */
+	List<Map<String, Object>> selectKeepSumAccountData(Map<String, Object> map);
+
+	/**
+	 * 查询保管总账查询列表的库存数量
+	 * 
+	 * @param map
+	 * @return
+	 */
+	List<Map<String, Object>> selectKCSL(Map<String, Object> map);
+}

src/main/java/com/chinaitop/depot/keeperAccount/service/impl/StorageAccountRecordServiceImpl.java

@@ -0,0 +1,79 @@
+package com.chinaitop.depot.keeperAccount.service.impl;
+
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.Resource;
+
+import org.springframework.stereotype.Service;
+
+import com.chinaitop.depot.keeperAccount.mapper.StorageAccountRecordMapper;
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecord;
+import com.chinaitop.depot.keeperAccount.model.StorageAccountRecordExample;
+import com.chinaitop.depot.keeperAccount.service.StorageAccountRecordService;
+
+@Service
+public class StorageAccountRecordServiceImpl implements StorageAccountRecordService {
+
+	@Resource
+	private StorageAccountRecordMapper mapper;
+
+	@Override
+	public void add(StorageAccountRecord record) {
+		mapper.insertSelective(record);
+	}
+
+	@Override
+	public void update(StorageAccountRecord record) {
+		mapper.updateByPrimaryKeySelective(record);
+	}
+
+	@Override
+	public List<StorageAccountRecord> findByConditon(StorageAccountRecordExample example) {
+		return mapper.selectByExample(example);
+	}
+
+	@Override
+	public Map<String, Object> selectOrCheckStorageAccountRecord(Integer houseId, Integer wareId, Integer hwxz,
+			Integer lspz, String rq, Integer accountType, Map<String, Object> map) {
+		
+		StorageAccountRecord record = null;
+		StorageAccountRecordExample example = new StorageAccountRecordExample();
+		StorageAccountRecordExample.Criteria criteria = example.createCriteria();
+		if (houseId != null) {
+			criteria.andHouseIdEqualTo(houseId);
+		}
+		if (wareId != null) {
+			criteria.andWareIdEqualTo(wareId);
+		}
+		criteria.andHwxzEqualTo(hwxz);
+		criteria.andLspzEqualTo(lspz);
+		criteria.andAccountTypeEqualTo(accountType);
+		if (accountType == 1) {
+			criteria.andRqEqualTo(rq);
+		} else {
+			criteria.andRqEqualTo(rq);
+		}
+
+		List<StorageAccountRecord> list = mapper.selectByExample(example);
+		if (null != list && list.size() > 0) {
+			record = list.get(0);
+		} else {
+			record = new StorageAccountRecord();
+		}
+		map.put("obj", record);
+
+		return map;
+	}
+
+	@Override
+	public List<Map<String, Object>> selectKeepSumAccountData(Map<String, Object> map) {
+		return mapper.selectKeepSumAccount(map);
+	}
+
+	@Override
+	public List<Map<String, Object>> selectKCSL(Map<String, Object> map) {
+		return mapper.selectKCSL(map);
+	}
+
+}

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

@@ -0,0 +1,44 @@
+package com.chinaitop.depot.utils;
+
+import java.io.IOException;
+
+import javax.servlet.Filter;
+import javax.servlet.FilterChain;
+import javax.servlet.FilterConfig;
+import javax.servlet.ServletException;
+import javax.servlet.ServletRequest;
+import javax.servlet.ServletResponse;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpSession;
+
+import org.apache.commons.lang.ObjectUtils;
+
+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/utils/DataPolicyEngine.java

@@ -0,0 +1,61 @@
+package com.chinaitop.depot.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/utils/GeneratorSqlmap.java

@@ -0,0 +1,38 @@
+package com.chinaitop.depot.utils;
+
+import org.mybatis.generator.api.MyBatisGenerator;
+import org.mybatis.generator.config.Configuration;
+import org.mybatis.generator.config.xml.ConfigurationParser;
+import org.mybatis.generator.internal.DefaultShellCallback;
+
+import java.io.File;
+import java.util.ArrayList;
+import java.util.List;
+
+public class GeneratorSqlmap {
+
+	public void generator() throws Exception{
+
+		List<String> warnings = new ArrayList<String>();
+		boolean overwrite = true;
+		//指定 逆向工程配置文件(写自己电脑的路径)
+		File configFile = new File("D:\\git_local\\depot-keeper-account\\src\\main\\resources\\generatorConfig.xml");
+		ConfigurationParser cp = new ConfigurationParser(warnings);
+		Configuration config = cp.parseConfiguration(configFile);
+		DefaultShellCallback callback = new DefaultShellCallback(overwrite);
+		MyBatisGenerator myBatisGenerator = new MyBatisGenerator(config,
+				callback, warnings);
+		myBatisGenerator.generate(null);
+
+	} 
+	public static void main(String[] args) throws Exception {
+		try {
+			GeneratorSqlmap generatorSqlmap = new GeneratorSqlmap();
+			generatorSqlmap.generator();
+		} catch (Exception e) {
+			e.printStackTrace();
+		}
+		
+	}
+
+}

src/main/java/com/chinaitop/depot/utils/MyCommentGenerator.java

@@ -0,0 +1,242 @@
+package com.chinaitop.depot.utils;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Properties;
+
+import static org.mybatis.generator.internal.util.StringUtility.isTrue;
+import org.mybatis.generator.api.CommentGenerator;
+import org.mybatis.generator.api.IntrospectedColumn;
+import org.mybatis.generator.api.IntrospectedTable;
+import org.mybatis.generator.api.dom.java.CompilationUnit;
+import org.mybatis.generator.api.dom.java.Field;
+import org.mybatis.generator.api.dom.java.InnerClass;
+import org.mybatis.generator.api.dom.java.InnerEnum;
+import org.mybatis.generator.api.dom.java.JavaElement;
+import org.mybatis.generator.api.dom.java.Method;
+import org.mybatis.generator.api.dom.java.Parameter;
+import org.mybatis.generator.api.dom.xml.XmlElement;
+import org.mybatis.generator.config.MergeConstants;
+import org.mybatis.generator.config.PropertyRegistry;
+
+public class MyCommentGenerator implements CommentGenerator {
+
+	private Properties properties;
+	private Properties systemPro;
+	private boolean suppressDate;
+	private boolean suppressAllComments;
+	private String currentDateStr;
+
+	public MyCommentGenerator() {
+	    super();
+	    properties = new Properties();
+	    systemPro = System.getProperties();
+	    suppressDate = false;
+	    suppressAllComments = false;
+	    currentDateStr = (new SimpleDateFormat("yyyy-MM-dd")).format(new Date());
+	}
+
+	
+	@Override
+	public void addClassComment(InnerClass innerClass, IntrospectedTable introspectedTable) {
+		if (suppressAllComments) {
+	        return;
+	    }
+	    StringBuilder sb = new StringBuilder();
+	    innerClass.addJavaDocLine("/**");
+	    sb.append(" * ");
+	    sb.append(introspectedTable.getFullyQualifiedTable());
+	    sb.append(" ");
+	    sb.append(getDateString());
+	    innerClass.addJavaDocLine(sb.toString());
+	    innerClass.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addClassComment(InnerClass innerClass, IntrospectedTable introspectedTable, boolean arg2) {
+		if (suppressAllComments) {
+	        return;
+	    }
+
+	    StringBuilder sb = new StringBuilder();
+
+	    innerClass.addJavaDocLine("/**");
+	    sb.append(" * ");
+	    sb.append(introspectedTable.getFullyQualifiedTable());
+	    innerClass.addJavaDocLine(sb.toString());
+
+	    sb.setLength(0);
+	    sb.append(" * @author ");
+	    sb.append(systemPro.getProperty("user.name"));
+	    sb.append(" ");
+	    sb.append(currentDateStr);
+
+	    //      addJavadocTag(innerClass, markAsDoNotDelete);
+
+	    innerClass.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addComment(XmlElement arg0) {
+		return;
+	}
+
+	@Override
+	public void addConfigurationProperties(Properties properties) {
+		this.properties.putAll(properties);
+
+	    suppressDate = isTrue(properties.getProperty(PropertyRegistry.COMMENT_GENERATOR_SUPPRESS_DATE));
+
+	    suppressAllComments = isTrue(properties.getProperty(PropertyRegistry.COMMENT_GENERATOR_SUPPRESS_ALL_COMMENTS));
+
+	}
+	
+	/**
+	 * This method adds the custom javadoc tag for. You may do nothing if you do
+	 * not wish to include the Javadoc tag - however, if you do not include the
+	 * Javadoc tag then the Java merge capability of the eclipse plugin will
+	 * break.
+	 * 
+	 * @param javaElement
+	 *            the java element
+	 */
+	protected void addJavadocTag(JavaElement javaElement, boolean markAsDoNotDelete) {
+	    javaElement.addJavaDocLine(" *");
+	    StringBuilder sb = new StringBuilder();
+	    sb.append(" * ");
+	    sb.append(MergeConstants.NEW_ELEMENT_TAG);
+	    if (markAsDoNotDelete) {
+	        sb.append(" do_not_delete_during_merge");
+	    }
+	    String s = getDateString();
+	    if (s != null) {
+	        sb.append(' ');
+	        sb.append(s);
+	    }
+	    javaElement.addJavaDocLine(sb.toString());
+	}
+	
+	protected String getDateString() {
+	    String result = null;
+	    if (!suppressDate) {
+	        result = currentDateStr;
+	    }
+	    return result;
+	}
+
+
+	@Override
+	public void addEnumComment(InnerEnum innerEnum, IntrospectedTable introspectedTable) {
+		if (suppressAllComments) {
+	        return;
+	    }
+
+	    StringBuilder sb = new StringBuilder();
+
+	    innerEnum.addJavaDocLine("/**");
+	    //      addJavadocTag(innerEnum, false);
+	    sb.append(" * ");
+	    sb.append(introspectedTable.getFullyQualifiedTable());
+	    innerEnum.addJavaDocLine(sb.toString());
+	    innerEnum.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addFieldComment(Field field, IntrospectedTable introspectedTable) {
+		if (suppressAllComments) {
+	        return;
+	    }
+
+	    StringBuilder sb = new StringBuilder();
+
+	    field.addJavaDocLine("/**");
+	    sb.append(" * ");
+	    sb.append(introspectedTable.getFullyQualifiedTable());
+	    field.addJavaDocLine(sb.toString());
+	    field.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addFieldComment(Field arg0, IntrospectedTable arg1, IntrospectedColumn arg2) {
+		// TODO Auto-generated method stub
+
+	}
+
+	@Override
+	public void addGeneralMethodComment(Method arg0, IntrospectedTable arg1) {
+		if (suppressAllComments) {
+	        return;
+	    }
+	    //      method.addJavaDocLine("/**");
+	    //      addJavadocTag(method, false);
+	    //      method.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addGetterComment(Method method, IntrospectedTable arg1, IntrospectedColumn introspectedColumn) {
+		if (suppressAllComments) {
+	        return;
+	    }
+
+	    method.addJavaDocLine("/**");
+
+	    StringBuilder sb = new StringBuilder();
+	    sb.append(" * ");
+	    sb.append(introspectedColumn.getRemarks());
+	    method.addJavaDocLine(sb.toString());
+
+	    sb.setLength(0);
+	    sb.append(" * @return ");
+	    sb.append(introspectedColumn.getActualColumnName());
+	    sb.append(" ");
+	    sb.append(introspectedColumn.getRemarks());
+	    method.addJavaDocLine(sb.toString());
+
+	    //      addJavadocTag(method, false);
+
+	    method.addJavaDocLine(" */");
+
+	}
+
+	@Override
+	public void addJavaFileComment(CompilationUnit arg0) {
+		return;
+	}
+
+	@Override
+	public void addRootComment(XmlElement arg0) {
+		return;
+	}
+
+	@Override
+	public void addSetterComment(Method method, IntrospectedTable arg1, IntrospectedColumn introspectedColumn) {
+		if (suppressAllComments) {
+	        return;
+	    }
+
+
+	    method.addJavaDocLine("/**");
+	    StringBuilder sb = new StringBuilder();
+	    sb.append(" * ");
+	    sb.append(introspectedColumn.getRemarks());
+	    method.addJavaDocLine(sb.toString());
+
+	    Parameter parm = method.getParameters().get(0);
+	    sb.setLength(0);
+	    sb.append(" * @param ");
+	    sb.append(parm.getName());
+	    sb.append(" ");
+	    sb.append(introspectedColumn.getRemarks());
+	    method.addJavaDocLine(sb.toString());
+
+	    //      addJavadocTag(method, false);
+
+	    method.addJavaDocLine(" */");
+
+	}
+
+}

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

@@ -0,0 +1,66 @@
+package com.chinaitop.depot.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.HashOperations;
+import org.springframework.data.redis.core.ListOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.SetOperations;
+import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.data.redis.core.ZSetOperations;
+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/utils/RedisUtil.java

@@ -0,0 +1,547 @@
+package com.chinaitop.depot.utils;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.concurrent.TimeUnit;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.data.redis.core.HashOperations;
+import org.springframework.data.redis.core.ListOperations;
+import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.SetOperations;
+import org.springframework.data.redis.core.ValueOperations;
+import org.springframework.stereotype.Component;
+import org.springframework.util.CollectionUtils;
+
+@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/utils/WebConfig.java

@@ -0,0 +1,39 @@
+package com.chinaitop.depot.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,51 @@
+server:
+  port: 9008
+  tomcat:
+    uri-encoding: utf-8
+
+# 注册中心配置
+eureka:
+  client:
+    service-url:
+      defaultZone: http://eureka-depot-yn:9001/eureka/
+  instance:
+    prefer-ip-address: true
+    # 每隔10s发送一次心跳(默认30s)
+    lease-renewal-interval-in-seconds: 10
+    # 告知服务端30秒还未收到心跳的话，就将该服务移除列表(默认90s)
+    lease-expiration-duration-in-seconds: 30
+
+spring:
+  application:
+    name: depot-keeper-house
+  # 数据库配置
+  datasource:
+    driver-class-name: com.mysql.jdbc.Driver
+    url: jdbc:mysql://192.168.123.38:3306/depot_yunnan?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/depot/depot-web/apache-tomcat-8.0.53/webapps/ROOT/WEB-INF/classes/static
+
+  jackson:
+    date-format: yyyy-MM-dd
+    time-zone: GMT+8

src/main/resources/generatorConfig.xml

@@ -0,0 +1,58 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE generatorConfiguration
+  PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
+  "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
+
+<generatorConfiguration>
+	<context id="testTables" targetRuntime="MyBatis3">
+		<!-- 生成注释时，必须加type="MyCommentGenerator" -->
+		<commentGenerator type="com.chinaitop.depot.utils.MyCommentGenerator">
+			<!-- 是否去除自动生成的注释 true：是 ： false:否 -->
+			<property name="suppressAllComments" value="false" />
+		</commentGenerator>
+		
+		<!--数据库连接的信息：驱动类、连接地址、用户名、密码 -->
+		<jdbcConnection 
+			driverClass="com.mysql.jdbc.Driver"
+			connectionURL="jdbc:mysql://192.168.123.98:3306/depot" 
+			userId="root"
+			password="123456">
+		</jdbcConnection>
+		
+		<!-- 默认false，把JDBC DECIMAL 和 NUMERIC 类型解析为 Integer，为 true时把JDBC DECIMAL 和 
+			NUMERIC 类型解析为java.math.BigDecimal -->
+		<javaTypeResolver>
+			<property name="forceBigDecimals" value="false" />
+		</javaTypeResolver>
+
+		<!-- targetProject:生成PO类的位置 -->
+		<javaModelGenerator targetPackage="com.chinaitop.depot.keeperAccount.model"
+			targetProject=".\src\main\java">
+			<!-- enableSubPackages:是否让schema作为包的后缀 -->
+			<property name="enableSubPackages" value="false" />
+			<!-- 从数据库返回的值被清理前后的空格 -->
+			<property name="trimStrings" value="true" />
+		</javaModelGenerator>
+		
+        <!-- targetProject:mapper映射文件生成的位置 -->
+		<sqlMapGenerator targetPackage="com.chinaitop.depot.keeperAccount.mapper" 
+			targetProject=".\src\main\java">
+			<!-- enableSubPackages:是否让schema作为包的后缀 -->
+			<property name="enableSubPackages" value="false" />
+		</sqlMapGenerator>
+		
+		<!-- targetPackage：mapper接口生成的位置 -->
+		<javaClientGenerator type="XMLMAPPER"
+			targetPackage="com.chinaitop.depot.keeperAccount.mapper" 
+			targetProject=".\src\main\java">
+			<!-- enableSubPackages:是否让schema作为包的后缀 -->
+			<property name="enableSubPackages" value="false" />
+		</javaClientGenerator>
+		
+		<!-- 指定要反向生成的数据库表 -->
+		<table schema="" tableName="storage_account_record"></table>
+<!-- 		<table schema="" tableName="basic_process_sub"></table> -->
+<!-- 		<table schema="" tableName="basic_process_contrail"></table> -->
+
+	</context>
+</generatorConfiguration>