通风

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

@@ -0,0 +1,107 @@
+package com.chinaitop.depot.storage.controller;
+
+import com.chinaitop.depot.storage.model.TVentilationOperation;
+import com.chinaitop.depot.storage.service.VentilationOperationService;
+import com.chinaitop.depot.unissoft.model.ResponseEntity;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiImplicitParam;
+import io.swagger.annotations.ApiImplicitParams;
+import io.swagger.annotations.ApiOperation;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+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 java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+@RestController
+@RequestMapping(value = "/intelligents/VentilationOperationController")
+@Api(value = "VentilationOperationController", description = "通风作业")
+public class VentilationOperationController {
+
+    @Autowired
+    private VentilationOperationService ventilationOperationService;
+
+   
+    @RequestMapping(value = "/getList", method = RequestMethod.GET)
+    @ApiOperation(value = "查询 通风作业列表", notes = "查询 通风作业列表，支持分页")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "pageNum", value = "页码", paramType = "query"),
+            @ApiImplicitParam(name = "pageSize", value = "每页条数", paramType = "query"),
+            @ApiImplicitParam(name = "orgId", value = "库点编码", paramType = "query"),
+            @ApiImplicitParam(name = "vcfcode", value = "仓库名称", paramType = "query")
+    })
+   public ResponseEntity<PageInfo<TVentilationOperation>> getList(Integer pageNum, Integer pageSize, String orgId, String cfbh,String cfmc) {
+        List<TVentilationOperation> list = null;
+        try {
+            list = ventilationOperationService.getList(pageNum,pageSize,orgId,cfbh,cfmc);
+        } catch (Exception e) {
+            e.printStackTrace();
+            ResponseEntity.failed(e.getMessage());
+        }
+        PageInfo<TVentilationOperation> pageInfo = new PageInfo<TVentilationOperation>(list);
+        /*if(pageInfo.getList()!=null && pageInfo.getList().size()>0){
+        	pageInfo.setStartRow(pageInfo.getStartRow()+1);
+        	pageInfo.setEndRow(pageInfo.getEndRow()+1);
+        }*/
+        return ResponseEntity.ok(pageInfo);
+    }
+
+    
+    @RequestMapping(value = "/getById", method = RequestMethod.POST)
+    @ApiOperation(value = "根据id查询信息", notes = "根据id查询信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "id", paramType = "query")
+    })
+    public ResponseEntity<TVentilationOperation> getById(String id) {
+    	TVentilationOperation tVentilationOperation = null;
+        if (StringUtils.isNotBlank(id)) {
+        	tVentilationOperation = ventilationOperationService.getById(id);
+        } else {
+            return ResponseEntity.failed("ID数据有误!");
+        }
+        return ResponseEntity.ok(tVentilationOperation);
+    }
+
+    @RequestMapping(value = "/save", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value = "数据更新与添加", notes = "数据更新与添加")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "ventilationOperationJson", value = "表数据json串", paramType = "form")
+    })
+    public ResponseEntity save(String ventilationOperationJson) {
+        try {
+        	ventilationOperationService.save(ventilationOperationJson);
+        } catch (Exception e) {
+            e.printStackTrace();
+            ResponseEntity.failed(e.getMessage());
+        }
+        return ResponseEntity.ok();
+    }
+
+    @RequestMapping(value = "/deleteById", method = RequestMethod.POST)
+    @ApiOperation(value = "根据id删除信息", notes = "根据id删除信息")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "id", value = "粮情id", paramType = "query"),
+            @ApiImplicitParam(name = "aerationParamJson", value = "通风参数json字符串", paramType = "query")
+    })
+    public ResponseEntity deleteById(String id) {
+        if (StringUtils.isNotBlank(id)) {
+            int count = ventilationOperationService.deleteById(id);
+            if (count > 0) {
+                return ResponseEntity.ok();
+            } else {
+                return ResponseEntity.failed("删除失败!");
+            }
+        }
+        return ResponseEntity.failed("ID数据有误!");
+    }
+
+    
+    
+}

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

@@ -0,0 +1,97 @@
+package com.chinaitop.depot.storage.mapper;
+
+import java.util.List;
+import org.apache.ibatis.annotations.Param;
+
+import com.chinaitop.depot.storage.model.TVentilationOperation;
+import com.chinaitop.depot.storage.model.TVentilationOperationExample;
+
+public interface TVentilationOperationMapper {
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int countByExample(TVentilationOperationExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int deleteByExample(TVentilationOperationExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int deleteByPrimaryKey(String id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int insert(TVentilationOperation record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int insertSelective(TVentilationOperation record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    List<TVentilationOperation> selectByExample(TVentilationOperationExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    TVentilationOperation selectByPrimaryKey(String id);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int updateByExampleSelective(@Param("record") TVentilationOperation record, @Param("example") TVentilationOperationExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int updateByExample(@Param("record") TVentilationOperation record, @Param("example") TVentilationOperationExample example);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int updateByPrimaryKeySelective(TVentilationOperation record);
+
+    /**
+     * This method was generated by MyBatis Generator.
+     * This method corresponds to the database table t_ventilation_operation
+     *
+     * @mbggenerated Sun Jun 28 17:44:27 CST 2020
+     */
+    int updateByPrimaryKey(TVentilationOperation record);
+}

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

@@ -0,0 +1,19 @@
+package com.chinaitop.depot.storage.service;
+
+import java.util.List;
+
+import com.chinaitop.depot.storage.model.TVentilationOperation;
+
+public interface VentilationOperationService {
+
+	List<TVentilationOperation> getList(Integer pageNum, Integer pageSize,String orgId, String cfbh,String cfmc);
+
+	TVentilationOperation getById(String id);
+
+	void save(String ventilationOperationJson);
+
+	int deleteById(String id);
+
+    
+
+}

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

@@ -0,0 +1,83 @@
+package com.chinaitop.depot.storage.service.impl;
+
+import java.util.List;
+
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.chinaitop.depot.storage.mapper.TVentilationOperationMapper;
+import com.chinaitop.depot.storage.model.TVentilationOperation;
+import com.chinaitop.depot.storage.model.TVentilationOperationExample;
+import com.chinaitop.depot.storage.service.VentilationOperationService;
+import com.chinaitop.depot.unissoft.model.UuidUtils;
+import com.github.pagehelper.PageHelper;
+
+@Service
+public class VentilationOperationServiceImpl implements VentilationOperationService {
+    @Autowired
+    private TVentilationOperationMapper tVentilationOperationMapper;
+
+	@Override
+	public List<TVentilationOperation> getList(Integer pageNum, Integer pageSize,String orgId, String cfbh,String cfmc) {
+		TVentilationOperationExample tVentilationOperationExample = new TVentilationOperationExample();
+		tVentilationOperationExample.setDistinct(true);
+		TVentilationOperationExample.Criteria criteria = tVentilationOperationExample.createCriteria();
+        if (StringUtils.isNotEmpty(cfbh)) {
+            criteria.andCfbhEqualTo(cfbh);
+        }
+        if (StringUtils.isNotEmpty(cfmc)) {
+        	criteria.andCfmcEqualTo(cfmc);
+        }
+        if (StringUtils.isNotEmpty(orgId)) {
+        	criteria.andOrgIdEqualTo(Integer.parseInt(orgId));
+        }
+        tVentilationOperationExample.setOrderByClause("djrq desc");
+        if (null != pageNum && null != pageSize) {
+            PageHelper.startPage(pageNum, pageSize);
+        }
+        return tVentilationOperationMapper.selectByExample(tVentilationOperationExample);
+	}
+
+	@Override
+	public TVentilationOperation getById(String id) {
+		// TODO Auto-generated method stub
+		return tVentilationOperationMapper.selectByPrimaryKey(id);
+	}
+
+	@Override
+	public void save(String ventilationOperationJson) {
+		// TODO Auto-generated method stub
+		if (StringUtils.isNotBlank(ventilationOperationJson)) {
+			
+			TVentilationOperation tVentilationOperation;
+			
+			try {
+				JSONObject jsonObject = JSON.parseObject(ventilationOperationJson);
+				 tVentilationOperation = JSONObject.toJavaObject(jsonObject , TVentilationOperation.class);
+				if (StringUtils.isNotBlank(tVentilationOperation.getId())) {
+					tVentilationOperationMapper.updateByPrimaryKeySelective(tVentilationOperation);
+	            } else {
+	            	tVentilationOperation.setId(UuidUtils.getCode());
+	            	tVentilationOperationMapper.insert(tVentilationOperation);
+	            }
+			
+			} catch (Exception e) {
+				// TODO Auto-generated catch block
+				e.printStackTrace();
+			}
+			
+        }
+	}
+
+	@Override
+	public int deleteById(String id) {
+		// TODO Auto-generated method stub
+		return tVentilationOperationMapper.deleteByPrimaryKey(id);
+	}
+
+	
+
+}

src/main/java/com/chinaitop/depot/unissoft/model/UuidUtils.java

@@ -0,0 +1,21 @@
+package com.chinaitop.depot.unissoft.model;
+
+import java.util.UUID;
+
+/**
+ * @author qingsong.han
+ * @description:
+ * @create 2020-07-02 17:37
+ */
+public class UuidUtils {
+
+    /**
+     * 生成32位随机数
+     *
+     * @return 返回32位随机数
+     */
+    public static String getCode() {
+        UUID uuid = UUID.randomUUID();
+        return uuid.toString().replace("-", "");
+    }
+}