.

Dockerfile

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

pom.xml

@@ -0,0 +1,152 @@
+<?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-number-manage</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <packaging>jar</packaging>
+
+    <name>depot-number-manage</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>
+        <!-- web模块 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <!-- test模块 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+        <!-- mysql -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+        </dependency>
+        <!-- mybatis -->
+        <dependency>
+            <groupId>org.mybatis.spring.boot</groupId>
+            <artifactId>mybatis-spring-boot-starter</artifactId>
+            <version>1.3.1</version>
+        </dependency>
+        <!-- 导入eureka-server服务的依赖 -->
+        <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>
+        <!-- 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>
+        <!-- 引入spring boot自带的pagehelper插件 -->
+        <dependency>
+            <groupId>com.github.pagehelper</groupId>
+            <artifactId>pagehelper-spring-boot-starter</artifactId>
+            <version>1.2.3</version>
+        </dependency>
+        <!-- commons工具类jar -->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.7</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>
+    </dependencies>
+
+    <!-- 导入Spring Cloud的依赖管理 -->
+   <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>
+        <!-- 配置资源节点 -->
+        <resources>
+            <resource>
+                <directory>src/main/java</directory>
+                <includes>
+                    <include>**/*.xml</include>
+                </includes>
+            </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,152 @@
+package com.chinaitop;
+
+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/DepotNumbermanageApplication.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;
+
+@SpringBootApplication
+@EnableDiscoveryClient
+@EnableEurekaClient
+@MapperScan(basePackages = {"com.chinaitop.depot.mapper"})
+public class DepotNumbermanageApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(DepotNumbermanageApplication.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(DepotNumbermanageApplication.class);
+    }
+ 
+}

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

@@ -0,0 +1,35 @@
+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.controller"))
+                .paths(PathSelectors.any())
+                .build();
+    }
+    private ApiInfo apiInfo() {
+        return new ApiInfoBuilder()
+                .title("智能粮库管理平台api文档")
+                .description("数量管理")
+                .termsOfServiceUrl("http://10.10.1.25:9001")
+                .version("1.0")
+                .build();
+    }
+
+}

src/main/java/com/chinaitop/depot/controller/StorageProfitlossSheetController.java

@@ -0,0 +1,196 @@
+package com.chinaitop.depot.controller;
+
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+
+import org.apache.commons.lang.ObjectUtils;
+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.alibaba.fastjson.JSONObject;
+import com.chinaitop.depot.model.StorageProfitlossSheet;
+import com.chinaitop.depot.model.StorageProfitlossSheetExample;
+import com.chinaitop.depot.service.StorageProfitlossSheetService;
+import com.chinaitop.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;
+
+/**
+ * @author qingsong.han
+ * @description: 损益单管理
+ * @create 2018-06-27 11:03
+ */
+@RestController
+@RequestMapping(value = "/storageSheet")
+@Api(value = "StorageProfitlossSheetController", description = "损益单管理类")
+public class StorageProfitlossSheetController {
+    @Resource
+    private StorageProfitlossSheetService storageProfitlossSheetService;
+
+    /**
+     * 损益单管理列表
+     *
+     * @param pageNum
+     * @param pageSize
+     * @return pageInfo
+     */
+    @RequestMapping(value = "/getList", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiOperation(value = "损益单管理列表", notes = "损益单管理列表信息, 支持分页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query", defaultValue = "1"),
+            @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query", defaultValue = "10"),
+            @ApiImplicitParam(name = "houseId", value = "仓房id", paramType = "query"),
+            @ApiImplicitParam(name = "warehouseId", value = "货位号id", paramType = "query"),
+            @ApiImplicitParam(name = "searchStartDate", value = "条件搜索开始日期(例:2018-07-04)", paramType = "query"),
+            @ApiImplicitParam(name = "searchEndDate", value = "条件搜索结束日期(例:2018-07-04)", paramType = "query")
+    })
+    public PageInfo<StorageProfitlossSheet> getpaymentList(HttpServletRequest request, Integer pageNum, Integer pageSize, Integer houseId, Integer warehouseId, String searchStartDate, String searchEndDate) {
+        StorageProfitlossSheetExample example = new StorageProfitlossSheetExample();
+        //查询对象条件查询
+        StorageProfitlossSheetExample.Criteria createCriteria = example.createCriteria();
+        if (null != houseId) {
+            createCriteria.andHouseIdEqualTo(houseId);
+        }
+        if (null != warehouseId) {
+            createCriteria.andWarehouseIdEqualTo(warehouseId);
+        }
+        if (ParameterUtil.isnotnull(searchStartDate) && ParameterUtil.isnotnull(searchEndDate)) {
+            createCriteria.andFillTimeBetween(ParameterUtil.string2datetime(searchStartDate+ParameterUtil.startTime), ParameterUtil.string2datetime(searchEndDate+ParameterUtil.endTime));
+        }
+        String orgId = ObjectUtils.toString(request.getSession().getAttribute("orgId"));
+        createCriteria.andOrgIdEqualTo(orgId);
+        
+        //分页
+        PageHelper.startPage(pageNum, pageSize);
+        example.setOrderByClause("fill_time desc, id desc");
+        List<StorageProfitlossSheet> list = storageProfitlossSheetService.queryByExample(example);
+        PageInfo<StorageProfitlossSheet> pageInfo = new PageInfo<StorageProfitlossSheet>(list);
+        return pageInfo;
+    }
+
+    /**
+     * 根据仓号，货位号查询实际库存
+     * @param pageNum
+     * @param pageSize
+     * @param houseId
+     * @param warehouseId
+     * @return pageInfo
+     */
+    @RequestMapping(value = "/getLists", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+    @ApiOperation(value = "获取上一次的损益单", notes = "获取上一次的损益单列表信息, 支持分页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query", defaultValue = "1"),
+            @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query", defaultValue = "10"),
+            @ApiImplicitParam(name = "houseId", value = "仓房id", paramType = "query"),
+            @ApiImplicitParam(name = "warehouseId", value = "货位号id", paramType = "query")
+    })
+    public PageInfo<StorageProfitlossSheet> getpaymentLists(Integer pageNum, Integer pageSize, Integer houseId, Integer warehouseId) {
+        StorageProfitlossSheetExample example = new StorageProfitlossSheetExample();
+        StorageProfitlossSheetExample.Criteria createCriteria = example.createCriteria();
+        //查询条件
+        if (null != houseId && null != warehouseId) {
+            createCriteria.andHouseIdEqualTo(houseId);
+            createCriteria.andWarehouseIdEqualTo(warehouseId);
+            PageHelper.startPage(pageNum, pageSize);
+            example.setOrderByClause("fill_time desc, id desc");
+            List<StorageProfitlossSheet> list = storageProfitlossSheetService.queryByExample(example);
+            PageInfo<StorageProfitlossSheet> pageInfo = new PageInfo<StorageProfitlossSheet>(list);
+
+            return pageInfo;
+        }
+        return null;
+
+    }
+
+    /**
+     * 保存方法
+     *
+     * @param storageProfitlossSheetJson
+     * @return
+     */
+    @RequestMapping(value = "/save", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value = "损益单管理新增列表", notes = "损益单管理新增信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "storageProfitlossSheetJson", value = "数据对象", paramType = "form"),
+            @ApiImplicitParam(name = "storageProfitlossSheetJson", value = "数据对象", paramType = "form")
+    })
+    public Map<String, Object> save(String storageProfitlossSheetJson, String userInfo) {
+        //登录用户名
+        JSONObject user = null;
+        String realName = "";
+        String orgId = "";
+        if (null != userInfo && !"".equals(userInfo)) {
+        	user = JSONObject.parseObject(userInfo);
+        	realName = user.get("realName") == null?"":user.get("realName").toString();
+        	orgId = user.get("orgId") == null?"":user.get("orgId").toString();
+        }
+        Map<String, Object> modelMap = new HashMap<>();
+        try {
+            // JSON字符串转对象
+            ObjectMapper mapper = new ObjectMapper();
+            StorageProfitlossSheet storageProfitlossSheets = mapper.readValue(storageProfitlossSheetJson, StorageProfitlossSheet.class);
+            storageProfitlossSheets.setOrgId(orgId);
+            if (storageProfitlossSheets.getId() == null) {
+                storageProfitlossSheetService.add(storageProfitlossSheets, realName); //使用到userInfo.realName
+            } else {
+                storageProfitlossSheetService.update(storageProfitlossSheets);
+            }
+            modelMap.put("status", "success");
+        } catch (Exception e) {
+            modelMap.put("status", "error");
+            e.printStackTrace();
+        }
+        return modelMap;
+    }
+
+    /**
+     * 根据id查询
+     *
+     * @param id 主键
+     * @return
+     */
+    @RequestMapping(value = "/edit", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.GET)
+    @ApiOperation(value = "损益单管理查看", notes = "损益单管理查看信息")
+    @ApiImplicitParam(name = "id", value = "修改信息id", paramType = "query")
+    public StorageProfitlossSheet edit(Integer id) {
+        StorageProfitlossSheet storageProfitlossSheet = new StorageProfitlossSheet();
+        if (id != null) {
+            storageProfitlossSheet = storageProfitlossSheetService.findById(id);
+        }
+        return storageProfitlossSheet;
+    }
+
+    /**
+     * 删除(同时删除流程)
+     *
+     * @param id 主键
+     * @return
+     * @throws IOException
+     */
+    @RequestMapping(value = "/remove", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value = "损益单管理删除", notes = "损益单管理删除列表信息")
+    @ApiImplicitParam(name = "integerId", value = "删除的信息Id", paramType = "form")
+    public Map<String, Object> remove(Integer id) {
+        Map<String, Object> modelMap = new HashMap<>();
+        if (id != null) {
+            storageProfitlossSheetService.remove(id);
+            modelMap.put("status", "success");
+        } else {
+            modelMap.put("status", "error");
+        }
+        return modelMap;
+    }
+}

src/main/java/com/chinaitop/depot/mapper/StorageProfitlossSheetMapper.java

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

src/main/java/com/chinaitop/depot/mapper/StorageProfitlossSheetMapper.xml

@@ -0,0 +1,401 @@
+<?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.mapper.StorageProfitlossSheetMapper" >
+  <resultMap id="BaseResultMap" type="com.chinaitop.depot.model.StorageProfitlossSheet" >
+    <id column="id" property="id" jdbcType="INTEGER" />
+    <result column="org_id" property="orgId" jdbcType="VARCHAR" />
+    <result column="house_id" property="houseId" jdbcType="INTEGER" />
+    <result column="warehouse_id" property="warehouseId" jdbcType="INTEGER" />
+    <result column="lsxz_id" property="lsxzId" jdbcType="INTEGER" />
+    <result column="grain_kind" property="grainKind" jdbcType="INTEGER" />
+    <result column="grain_grade" property="grainGrade" jdbcType="INTEGER" />
+    <result column="income_tonnage" property="incomeTonnage" jdbcType="VARCHAR" />
+    <result column="inventory_year" property="inventoryYear" jdbcType="INTEGER" />
+    <result column="loss_type" property="lossType" jdbcType="INTEGER" />
+    <result column="profit_ratio" property="profitRatio" jdbcType="VARCHAR" />
+    <result column="actual_stock" property="actualStock" jdbcType="VARCHAR" />
+    <result column="production_year" property="productionYear" jdbcType="INTEGER" />
+    <result column="remark" property="remark" jdbcType="VARCHAR" />
+    <result column="fill_time" property="fillTime" jdbcType="TIMESTAMP" />
+    <result column="fill_person" property="fillPerson" jdbcType="VARCHAR" />
+    <result column="updatetime" property="updatetime" jdbcType="TIMESTAMP" />
+  </resultMap>
+  <sql id="Example_Where_Clause" >
+    <where >
+      <foreach collection="oredCriteria" item="criteria" separator="or" >
+        <if test="criteria.valid" >
+          <trim prefix="(" suffix=")" prefixOverrides="and" >
+            <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 collection="criterion.value" item="listItem" open="(" close=")" 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="(" suffix=")" prefixOverrides="and" >
+            <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 collection="criterion.value" item="listItem" open="(" close=")" separator="," >
+                    #{listItem}
+                  </foreach>
+                </when>
+              </choose>
+            </foreach>
+          </trim>
+        </if>
+      </foreach>
+    </where>
+  </sql>
+  <sql id="Base_Column_List" >
+    id, org_id, house_id, warehouse_id, lsxz_id, grain_kind, grain_grade, income_tonnage, 
+    inventory_year, loss_type, profit_ratio, actual_stock, production_year, remark, fill_time, 
+    fill_person, updatetime
+  </sql>
+  <select id="selectByExample" resultMap="BaseResultMap" parameterType="com.chinaitop.depot.model.StorageProfitlossSheetExample" >
+    select
+    <if test="distinct" >
+      distinct
+    </if>
+    <include refid="Base_Column_List" />
+    from storage_profitloss_sheet
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+    <if test="orderByClause != null" >
+      order by ${orderByClause}
+    </if>
+  </select>
+  <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
+    select 
+    <include refid="Base_Column_List" />
+    from storage_profitloss_sheet
+    where id = #{id,jdbcType=INTEGER}
+  </select>
+  <delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
+    delete from storage_profitloss_sheet
+    where id = #{id,jdbcType=INTEGER}
+  </delete>
+  <delete id="deleteByExample" parameterType="com.chinaitop.depot.model.StorageProfitlossSheetExample" >
+    delete from storage_profitloss_sheet
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+  </delete>
+  <insert id="insert" parameterType="com.chinaitop.depot.model.StorageProfitlossSheet" >
+    insert into storage_profitloss_sheet (id, org_id, house_id, 
+      warehouse_id, lsxz_id, grain_kind, 
+      grain_grade, income_tonnage, inventory_year, 
+      loss_type, profit_ratio, actual_stock, 
+      production_year, remark, fill_time, 
+      fill_person, updatetime)
+    values (#{id,jdbcType=INTEGER}, #{orgId,jdbcType=VARCHAR}, #{houseId,jdbcType=INTEGER}, 
+      #{warehouseId,jdbcType=INTEGER}, #{lsxzId,jdbcType=INTEGER}, #{grainKind,jdbcType=INTEGER}, 
+      #{grainGrade,jdbcType=INTEGER}, #{incomeTonnage,jdbcType=VARCHAR}, #{inventoryYear,jdbcType=INTEGER}, 
+      #{lossType,jdbcType=INTEGER}, #{profitRatio,jdbcType=VARCHAR}, #{actualStock,jdbcType=VARCHAR}, 
+      #{productionYear,jdbcType=INTEGER}, #{remark,jdbcType=VARCHAR}, #{fillTime,jdbcType=TIMESTAMP}, 
+      #{fillPerson,jdbcType=VARCHAR}, #{updatetime,jdbcType=TIMESTAMP})
+  </insert>
+  <insert id="insertSelective" parameterType="com.chinaitop.depot.model.StorageProfitlossSheet" >
+    insert into storage_profitloss_sheet
+    <trim prefix="(" suffix=")" suffixOverrides="," >
+      <if test="id != null" >
+        id,
+      </if>
+      <if test="orgId != null" >
+        org_id,
+      </if>
+      <if test="houseId != null" >
+        house_id,
+      </if>
+      <if test="warehouseId != null" >
+        warehouse_id,
+      </if>
+      <if test="lsxzId != null" >
+        lsxz_id,
+      </if>
+      <if test="grainKind != null" >
+        grain_kind,
+      </if>
+      <if test="grainGrade != null" >
+        grain_grade,
+      </if>
+      <if test="incomeTonnage != null" >
+        income_tonnage,
+      </if>
+      <if test="inventoryYear != null" >
+        inventory_year,
+      </if>
+      <if test="lossType != null" >
+        loss_type,
+      </if>
+      <if test="profitRatio != null" >
+        profit_ratio,
+      </if>
+      <if test="actualStock != null" >
+        actual_stock,
+      </if>
+      <if test="productionYear != null" >
+        production_year,
+      </if>
+      <if test="remark != null" >
+        remark,
+      </if>
+      <if test="fillTime != null" >
+        fill_time,
+      </if>
+      <if test="fillPerson != null" >
+        fill_person,
+      </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=VARCHAR},
+      </if>
+      <if test="houseId != null" >
+        #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="warehouseId != null" >
+        #{warehouseId,jdbcType=INTEGER},
+      </if>
+      <if test="lsxzId != null" >
+        #{lsxzId,jdbcType=INTEGER},
+      </if>
+      <if test="grainKind != null" >
+        #{grainKind,jdbcType=INTEGER},
+      </if>
+      <if test="grainGrade != null" >
+        #{grainGrade,jdbcType=INTEGER},
+      </if>
+      <if test="incomeTonnage != null" >
+        #{incomeTonnage,jdbcType=VARCHAR},
+      </if>
+      <if test="inventoryYear != null" >
+        #{inventoryYear,jdbcType=INTEGER},
+      </if>
+      <if test="lossType != null" >
+        #{lossType,jdbcType=INTEGER},
+      </if>
+      <if test="profitRatio != null" >
+        #{profitRatio,jdbcType=VARCHAR},
+      </if>
+      <if test="actualStock != null" >
+        #{actualStock,jdbcType=VARCHAR},
+      </if>
+      <if test="productionYear != null" >
+        #{productionYear,jdbcType=INTEGER},
+      </if>
+      <if test="remark != null" >
+        #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="fillTime != null" >
+        #{fillTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="fillPerson != null" >
+        #{fillPerson,jdbcType=VARCHAR},
+      </if>
+      <if test="updatetime != null" >
+        #{updatetime,jdbcType=TIMESTAMP},
+      </if>
+    </trim>
+  </insert>
+  <select id="countByExample" parameterType="com.chinaitop.depot.model.StorageProfitlossSheetExample" resultType="java.lang.Integer" >
+    select count(*) from storage_profitloss_sheet
+    <if test="_parameter != null" >
+      <include refid="Example_Where_Clause" />
+    </if>
+  </select>
+  <update id="updateByExampleSelective" parameterType="map" >
+    update storage_profitloss_sheet
+    <set >
+      <if test="record.id != null" >
+        id = #{record.id,jdbcType=INTEGER},
+      </if>
+      <if test="record.orgId != null" >
+        org_id = #{record.orgId,jdbcType=VARCHAR},
+      </if>
+      <if test="record.houseId != null" >
+        house_id = #{record.houseId,jdbcType=INTEGER},
+      </if>
+      <if test="record.warehouseId != null" >
+        warehouse_id = #{record.warehouseId,jdbcType=INTEGER},
+      </if>
+      <if test="record.lsxzId != null" >
+        lsxz_id = #{record.lsxzId,jdbcType=INTEGER},
+      </if>
+      <if test="record.grainKind != null" >
+        grain_kind = #{record.grainKind,jdbcType=INTEGER},
+      </if>
+      <if test="record.grainGrade != null" >
+        grain_grade = #{record.grainGrade,jdbcType=INTEGER},
+      </if>
+      <if test="record.incomeTonnage != null" >
+        income_tonnage = #{record.incomeTonnage,jdbcType=VARCHAR},
+      </if>
+      <if test="record.inventoryYear != null" >
+        inventory_year = #{record.inventoryYear,jdbcType=INTEGER},
+      </if>
+      <if test="record.lossType != null" >
+        loss_type = #{record.lossType,jdbcType=INTEGER},
+      </if>
+      <if test="record.profitRatio != null" >
+        profit_ratio = #{record.profitRatio,jdbcType=VARCHAR},
+      </if>
+      <if test="record.actualStock != null" >
+        actual_stock = #{record.actualStock,jdbcType=VARCHAR},
+      </if>
+      <if test="record.productionYear != null" >
+        production_year = #{record.productionYear,jdbcType=INTEGER},
+      </if>
+      <if test="record.remark != null" >
+        remark = #{record.remark,jdbcType=VARCHAR},
+      </if>
+      <if test="record.fillTime != null" >
+        fill_time = #{record.fillTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="record.fillPerson != null" >
+        fill_person = #{record.fillPerson,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_profitloss_sheet
+    set id = #{record.id,jdbcType=INTEGER},
+      org_id = #{record.orgId,jdbcType=VARCHAR},
+      house_id = #{record.houseId,jdbcType=INTEGER},
+      warehouse_id = #{record.warehouseId,jdbcType=INTEGER},
+      lsxz_id = #{record.lsxzId,jdbcType=INTEGER},
+      grain_kind = #{record.grainKind,jdbcType=INTEGER},
+      grain_grade = #{record.grainGrade,jdbcType=INTEGER},
+      income_tonnage = #{record.incomeTonnage,jdbcType=VARCHAR},
+      inventory_year = #{record.inventoryYear,jdbcType=INTEGER},
+      loss_type = #{record.lossType,jdbcType=INTEGER},
+      profit_ratio = #{record.profitRatio,jdbcType=VARCHAR},
+      actual_stock = #{record.actualStock,jdbcType=VARCHAR},
+      production_year = #{record.productionYear,jdbcType=INTEGER},
+      remark = #{record.remark,jdbcType=VARCHAR},
+      fill_time = #{record.fillTime,jdbcType=TIMESTAMP},
+      fill_person = #{record.fillPerson,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.model.StorageProfitlossSheet" >
+    update storage_profitloss_sheet
+    <set >
+      <if test="orgId != null" >
+        org_id = #{orgId,jdbcType=VARCHAR},
+      </if>
+      <if test="houseId != null" >
+        house_id = #{houseId,jdbcType=INTEGER},
+      </if>
+      <if test="warehouseId != null" >
+        warehouse_id = #{warehouseId,jdbcType=INTEGER},
+      </if>
+      <if test="lsxzId != null" >
+        lsxz_id = #{lsxzId,jdbcType=INTEGER},
+      </if>
+      <if test="grainKind != null" >
+        grain_kind = #{grainKind,jdbcType=INTEGER},
+      </if>
+      <if test="grainGrade != null" >
+        grain_grade = #{grainGrade,jdbcType=INTEGER},
+      </if>
+      <if test="incomeTonnage != null" >
+        income_tonnage = #{incomeTonnage,jdbcType=VARCHAR},
+      </if>
+      <if test="inventoryYear != null" >
+        inventory_year = #{inventoryYear,jdbcType=INTEGER},
+      </if>
+      <if test="lossType != null" >
+        loss_type = #{lossType,jdbcType=INTEGER},
+      </if>
+      <if test="profitRatio != null" >
+        profit_ratio = #{profitRatio,jdbcType=VARCHAR},
+      </if>
+      <if test="actualStock != null" >
+        actual_stock = #{actualStock,jdbcType=VARCHAR},
+      </if>
+      <if test="productionYear != null" >
+        production_year = #{productionYear,jdbcType=INTEGER},
+      </if>
+      <if test="remark != null" >
+        remark = #{remark,jdbcType=VARCHAR},
+      </if>
+      <if test="fillTime != null" >
+        fill_time = #{fillTime,jdbcType=TIMESTAMP},
+      </if>
+      <if test="fillPerson != null" >
+        fill_person = #{fillPerson,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.model.StorageProfitlossSheet" >
+    update storage_profitloss_sheet
+    set org_id = #{orgId,jdbcType=VARCHAR},
+      house_id = #{houseId,jdbcType=INTEGER},
+      warehouse_id = #{warehouseId,jdbcType=INTEGER},
+      lsxz_id = #{lsxzId,jdbcType=INTEGER},
+      grain_kind = #{grainKind,jdbcType=INTEGER},
+      grain_grade = #{grainGrade,jdbcType=INTEGER},
+      income_tonnage = #{incomeTonnage,jdbcType=VARCHAR},
+      inventory_year = #{inventoryYear,jdbcType=INTEGER},
+      loss_type = #{lossType,jdbcType=INTEGER},
+      profit_ratio = #{profitRatio,jdbcType=VARCHAR},
+      actual_stock = #{actualStock,jdbcType=VARCHAR},
+      production_year = #{productionYear,jdbcType=INTEGER},
+      remark = #{remark,jdbcType=VARCHAR},
+      fill_time = #{fillTime,jdbcType=TIMESTAMP},
+      fill_person = #{fillPerson,jdbcType=VARCHAR},
+      updatetime = #{updatetime,jdbcType=TIMESTAMP}
+    where id = #{id,jdbcType=INTEGER}
+  </update>
+</mapper>

src/main/java/com/chinaitop/depot/model/StorageProfitlossSheet.java

@@ -0,0 +1,175 @@
+package com.chinaitop.depot.model;
+
+import java.util.Date;
+
+public class StorageProfitlossSheet {
+    private Integer id;
+
+    private String orgId;
+
+    private Integer houseId;
+
+    private Integer warehouseId;
+
+    private Integer lsxzId;
+
+    private Integer grainKind;
+
+    private Integer grainGrade;
+
+    private String incomeTonnage;
+
+    private Integer inventoryYear;
+
+    private Integer lossType;
+
+    private String profitRatio;
+
+    private String actualStock;
+
+    private Integer productionYear;
+
+    private String remark;
+
+    private Date fillTime;
+
+    private String fillPerson;
+
+    private Date updatetime;
+
+    public Integer getId() {
+        return id;
+    }
+
+    public void setId(Integer id) {
+        this.id = id;
+    }
+
+    public String getOrgId() {
+        return orgId;
+    }
+
+    public void setOrgId(String orgId) {
+        this.orgId = orgId == null ? null : orgId.trim();
+    }
+
+    public Integer getHouseId() {
+        return houseId;
+    }
+
+    public void setHouseId(Integer houseId) {
+        this.houseId = houseId;
+    }
+
+    public Integer getWarehouseId() {
+        return warehouseId;
+    }
+
+    public void setWarehouseId(Integer warehouseId) {
+        this.warehouseId = warehouseId;
+    }
+
+    public Integer getLsxzId() {
+        return lsxzId;
+    }
+
+    public void setLsxzId(Integer lsxzId) {
+        this.lsxzId = lsxzId;
+    }
+
+    public Integer getGrainKind() {
+        return grainKind;
+    }
+
+    public void setGrainKind(Integer grainKind) {
+        this.grainKind = grainKind;
+    }
+
+    public Integer getGrainGrade() {
+        return grainGrade;
+    }
+
+    public void setGrainGrade(Integer grainGrade) {
+        this.grainGrade = grainGrade;
+    }
+
+    public String getIncomeTonnage() {
+        return incomeTonnage;
+    }
+
+    public void setIncomeTonnage(String incomeTonnage) {
+        this.incomeTonnage = incomeTonnage == null ? null : incomeTonnage.trim();
+    }
+
+    public Integer getInventoryYear() {
+        return inventoryYear;
+    }
+
+    public void setInventoryYear(Integer inventoryYear) {
+        this.inventoryYear = inventoryYear;
+    }
+
+    public Integer getLossType() {
+        return lossType;
+    }
+
+    public void setLossType(Integer lossType) {
+        this.lossType = lossType;
+    }
+
+    public String getProfitRatio() {
+        return profitRatio;
+    }
+
+    public void setProfitRatio(String profitRatio) {
+        this.profitRatio = profitRatio == null ? null : profitRatio.trim();
+    }
+
+    public String getActualStock() {
+        return actualStock;
+    }
+
+    public void setActualStock(String actualStock) {
+        this.actualStock = actualStock == null ? null : actualStock.trim();
+    }
+
+    public Integer getProductionYear() {
+        return productionYear;
+    }
+
+    public void setProductionYear(Integer productionYear) {
+        this.productionYear = productionYear;
+    }
+
+    public String getRemark() {
+        return remark;
+    }
+
+    public void setRemark(String remark) {
+        this.remark = remark == null ? null : remark.trim();
+    }
+
+    public Date getFillTime() {
+        return fillTime;
+    }
+
+    public void setFillTime(Date fillTime) {
+        this.fillTime = fillTime;
+    }
+
+    public String getFillPerson() {
+        return fillPerson;
+    }
+
+    public void setFillPerson(String fillPerson) {
+        this.fillPerson = fillPerson == null ? null : fillPerson.trim();
+    }
+
+    public Date getUpdatetime() {
+        return updatetime;
+    }
+
+    public void setUpdatetime(Date updatetime) {
+        this.updatetime = updatetime;
+    }
+}

src/main/java/com/chinaitop/depot/service/StorageProfitlossSheetService.java

@@ -0,0 +1,24 @@
+package com.chinaitop.depot.service;
+
+
+import com.chinaitop.depot.model.StorageProfitlossSheet;
+import com.chinaitop.depot.model.StorageProfitlossSheetExample;
+
+import java.util.List;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2018-06-27 11:13
+ */
+public interface StorageProfitlossSheetService {
+    List<StorageProfitlossSheet> queryByExample(StorageProfitlossSheetExample example);
+
+    StorageProfitlossSheet findById(Integer id);
+
+    void add(StorageProfitlossSheet plan, String realName);
+
+    void update(StorageProfitlossSheet plan);
+
+    void remove(Integer id);
+}

src/main/java/com/chinaitop/depot/service/impl/StorageProfitlossSheetServiceImpl.java

@@ -0,0 +1,54 @@
+package com.chinaitop.depot.service.impl;
+
+import com.chinaitop.depot.mapper.StorageProfitlossSheetMapper;
+import com.chinaitop.depot.model.StorageProfitlossSheet;
+import com.chinaitop.depot.model.StorageProfitlossSheetExample;
+import com.chinaitop.depot.service.StorageProfitlossSheetService;
+import org.springframework.stereotype.Service;
+import javax.annotation.Resource;
+import java.util.Date;
+import java.util.List;
+
+/**
+ * @auther xujh
+ */
+@Service
+public class StorageProfitlossSheetServiceImpl implements StorageProfitlossSheetService {
+	@Resource
+	private StorageProfitlossSheetMapper storageProfitlossSheetMapper;
+
+	/**
+	 * 损益单管理列表
+	 * @param example
+	 * @return
+	 */
+	@Override
+	public List<StorageProfitlossSheet> queryByExample(StorageProfitlossSheetExample example) {
+		return storageProfitlossSheetMapper.selectByExample(example);
+	}
+
+	@Override
+	public StorageProfitlossSheet findById(Integer id) {
+		return storageProfitlossSheetMapper.selectByPrimaryKey(id);
+	}
+
+	@Override
+	public void add(StorageProfitlossSheet storageProfitlossSheet, String realName) {
+    	storageProfitlossSheet.setFillPerson(realName);
+    	storageProfitlossSheet.setFillTime(new Date());
+		storageProfitlossSheetMapper.insertSelective(storageProfitlossSheet);
+
+	}
+
+	@Override
+	public void update(StorageProfitlossSheet storageProfitlossSheet) {
+		storageProfitlossSheetMapper.updateByPrimaryKeySelective(storageProfitlossSheet);
+		
+	}
+
+	@Override
+	public void remove(Integer id) {
+		storageProfitlossSheetMapper.deleteByPrimaryKey(id);
+	}
+
+}

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/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/java/com/chinaitop/utils/PageUtils.java

@@ -0,0 +1,113 @@
+package com.chinaitop.utils;
+
+import com.github.pagehelper.Page;
+import com.github.pagehelper.PageInfo;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class PageUtils {
+	
+	public static <T> PageInfo<T> page(List<T> list, Integer pageNum, Integer pageSize) {
+		
+		if(pageNum <= 0) {
+			pageNum = 0;
+		} else {
+			pageNum --;
+		}
+		
+    	int totalCount = list.size();
+        int pageCount;
+        int m = totalCount % pageSize;
+
+        if (m > 0) {
+            pageCount = totalCount / pageSize + 1;
+        } else {
+            pageCount = totalCount / pageSize;
+        }
+
+        List<List<T>> totalList = new ArrayList<List<T>>();
+        for (int i = 1; i <= pageCount; i++) {
+            if (m == 0) {
+                List<T> subList = list.subList((i - 1) * pageSize, pageSize * (i));
+                totalList.add(subList);
+            } else {
+                if (i == pageCount) {
+                    List<T> subList = list.subList((i - 1) * pageSize, totalCount);
+                    totalList.add(subList);
+                } else {
+                    List<T> subList = list.subList((i - 1) * pageSize, pageSize * i);
+                    totalList.add(subList);
+                }
+            }
+        }
+        
+        List<T> result = totalList.get(pageNum);
+        int count = list.size();
+        int size = totalList.size();
+        PageInfo<T> pageInfo =new PageInfo<T>((List<T>) result, size);
+        pageInfo.setPages(size);
+        pageInfo.setTotal(count);
+        System.out.println("总条数：" + count);
+        System.out.println("总页数：" + size);
+        return pageInfo;
+    }
+	
+	
+	public static <T> PageInfo<T> page2(List<T> list, Integer pageNum, Integer pageSize) {
+		
+		if(pageNum <= 0) {
+			pageNum = 0;
+		} else {
+			pageNum --;
+		}
+		
+    	int totalCount = list.size();
+        int pageCount;
+        int m = totalCount % pageSize;
+
+        if (m > 0) {
+            pageCount = totalCount / pageSize + 1;
+        } else {
+            pageCount = totalCount / pageSize;
+        }
+
+        List<List<T>> totalList = new ArrayList<List<T>>();
+        for (int i = 1; i <= pageCount; i++) {
+            if (m == 0) {
+                List<T> subList = list.subList((i - 1) * pageSize, pageSize * (i));
+                totalList.add(subList);
+            } else {
+                if (i == pageCount) {
+                    List<T> subList = list.subList((i - 1) * pageSize, totalCount);
+                    totalList.add(subList);
+                } else {
+                    List<T> subList = list.subList((i - 1) * pageSize, pageSize * i);
+                    totalList.add(subList);
+                }
+            }
+        }
+        if(!totalList.isEmpty()){
+        	List<T> result = totalList.get(pageNum);
+        	Page<T> page = new Page<T>();
+        	for (T t : result) {
+        		page.add(t);
+        	}
+        	int count = list.size();
+        	int size = totalList.size();
+        	
+        	page.setPages(size);
+        	page.setPageNum(pageNum + 1);
+        	page.setPageSize(pageSize);
+        	page.setTotal(count);
+        	page.setStartRow(pageNum*pageSize);
+        	
+        	PageInfo<T> pageInfo =new PageInfo<T>(page, size);
+        	System.out.println("总条数：" + count);
+        	System.out.println("总页数：" + size);
+        	return pageInfo;
+        }
+		return null;
+    }
+
+}

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

@@ -0,0 +1,173 @@
+package com.chinaitop.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 startTime = " 00:00:00";
+    public static String endTime = " 23:59:59";
+
+    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/resources/bootstrap.yml

@@ -0,0 +1,51 @@
+server:
+  port: 9011
+  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-number-manage
+  # 数据库配置
+  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/test/java/com/chinaitop/DepotNumbermanageApplicationTests.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 DepotNumbermanageApplicationTests {
+
+    @Test
+    public void contextLoads() {
+    }
+
+}