等级接口

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

@@ -8,6 +8,7 @@ import com.chinaitop.depot.storage.service.StorageQualitycheckService;
 import com.chinaitop.depot.storage.service.StorageQualitycheckSonService;
 import com.chinaitop.depot.storage.utils.DataSynchronization;
 import com.chinaitop.depot.storage.utils.ParameterUtil;
+import com.chinaitop.depot.storage.utils.createKC;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.github.pagehelper.PageHelper;
@@ -18,6 +19,7 @@ import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import org.apache.commons.lang.ObjectUtils;
 import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestMethod;
@@ -26,10 +28,7 @@ import org.springframework.web.bind.annotation.RestController;
 import javax.annotation.Resource;
 import java.io.IOException;
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 
 /**
  * Created by product on 2017/10/11.
@@ -47,6 +46,10 @@ public class StorageQualitycheckController {
     @Resource
     private StorageQualitycheckInspectionService qualitycheckInspectionService;
 
+    // 获取ip地址
+    @Value("${crk-webservice}")
+    private String url;
+
     /**
      * 封仓管理中查询出未封仓的质量管理信息，已经封仓的不要展示
      * 分页获取
@@ -660,6 +663,56 @@ public class StorageQualitycheckController {
         return pageInfo;
     }
 
+    /**
+     *
+     * @param houseId
+     * @param warehouseId
+     * @param orgId
+     * @param level
+     * @param crk_ip
+     * @return
+     */
+    @RequestMapping(value="/updateLevel", produces = MediaType.APPLICATION_JSON_VALUE, method = RequestMethod.POST)
+    @ApiOperation(value="修改数据", notes = "修改数据")
+    @ApiImplicitParams({
+            @ApiImplicitParam(name = "houseId", value = "仓房油罐id", paramType = "query"),
+            @ApiImplicitParam(name = "warehouseId", value = "货位id", paramType = "query"),
+            @ApiImplicitParam(name = "orgId", value = "单位id", paramType = "query"),
+            @ApiImplicitParam(name = "level", value = "等级", paramType = "query"),
+            @ApiImplicitParam(name = "crk_ip", value = "出入库连接IP", paramType = "query")
+    })
+    public Map<String, Object>  updateLevel(String houseId, String warehouseId, String orgId, String level, String crk_ip) {
+
+        Map<String, Object> modelMap = new HashMap<String, Object>();
+        String crk_adr = "";
+        try {
+            Object[] parameters = new Object[5];
+            parameters[0] = orgId + "";
+            parameters[1] = houseId + "";
+            parameters[2] = warehouseId + "";
+            parameters[3] = level + "";
+            parameters[4] = 2 + ""; //1:新增；2：修改；3：删除
+            crk_adr = crk_ip+url;
+
+            String str = createKC.createKC("ChangeGrainGrade", crk_adr, parameters);
+
+            /* *****end******/
+            if ("true".equals(str)) {
+                modelMap.put("status", "success");
+            } else {
+                modelMap.put("status", "error");
+                modelMap.put("msg", "等级修改失败");
+                return modelMap;
+            }
+
+        } catch (Exception e) {
+            e.printStackTrace();
+            modelMap.put("status", "error");
+            modelMap.put("msg", "等级修改失败");
+        }
+        return modelMap;
+    }
+
     //质检信息主表同步
     @RequestMapping("/qualityMainSynchronization")
     public void qualityMainSynchronization() {