jidj před 5 roky
rodič
revize
e37f96a9b0

+ 11 - 0
pom.xml

@@ -56,6 +56,17 @@
56 56
 			<version>3.7</version>
57 57
 		</dependency>
58 58
 
59
+		<!-- feign -->
60
+		<dependency>
61
+			<groupId>org.springframework.cloud</groupId>
62
+			<artifactId>spring-cloud-starter-openfeign</artifactId>
63
+		</dependency>
64
+		<!-- hystrix 熔断-->
65
+		<dependency>
66
+			<groupId>org.springframework.cloud</groupId>
67
+			<artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
68
+		</dependency>
69
+
59 70
 		<!--log4j-->
60 71
 		<dependency>
61 72
 			<groupId>log4j</groupId>

+ 4 - 1
src/main/java/com/chinaitop/DepotQualitycheckApplication.java

@@ -1,14 +1,17 @@
1 1
 package com.chinaitop;
2 2
 
3
+import com.github.pagehelper.autoconfigure.PageHelperAutoConfiguration;
3 4
 import org.mybatis.spring.annotation.MapperScan;
4 5
 import org.springframework.boot.SpringApplication;
5 6
 import org.springframework.boot.autoconfigure.SpringBootApplication;
6 7
 import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
7 8
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
9
+import org.springframework.cloud.openfeign.EnableFeignClients;
8 10
 
9 11
 @EnableEurekaClient
12
+@EnableFeignClients
10 13
 @EnableDiscoveryClient
11
-@SpringBootApplication
14
+@SpringBootApplication(exclude = PageHelperAutoConfiguration.class)//配置mybatis的配置文件使用,否则报多个分页插件
12 15
 @MapperScan(basePackages = {"com.chinaitop.depot.*.mapper"})
13 16
 public class DepotQualitycheckApplication {
14 17
 

+ 21 - 0
src/main/java/com/chinaitop/HystrixClientFallback.java

@@ -0,0 +1,21 @@
1
+package com.chinaitop;
2
+
3
+import com.chinaitop.depot.feign.FeignBasicService;
4
+import org.slf4j.Logger;
5
+import org.slf4j.LoggerFactory;
6
+import org.springframework.stereotype.Component;
7
+
8
+/**
9
+ * 吉东杰
10
+ * 2020/7/30
11
+ */
12
+@Component
13
+public class HystrixClientFallback implements FeignBasicService {
14
+    private final static Logger logger = LoggerFactory.getLogger(HystrixClientFallback.class);
15
+
16
+
17
+    @Override
18
+    public void updateWarehouseCrkStatus(Integer wareId, String crk_status) {
19
+        logger.info("warehouseId: " + wareId + "warehouseStatus" + crk_status);
20
+    }
21
+}

+ 15 - 0
src/main/java/com/chinaitop/depot/feign/FeignBasicService.java

@@ -0,0 +1,15 @@
1
+package com.chinaitop.depot.feign;
2
+
3
+import org.springframework.cloud.openfeign.FeignClient;
4
+import org.springframework.web.bind.annotation.RequestMapping;
5
+import org.springframework.web.bind.annotation.RequestMethod;
6
+import org.springframework.web.bind.annotation.RequestParam;
7
+
8
+@FeignClient(name = "depot-basic")
9
+public interface FeignBasicService {
10
+
11
+    //远程调用,更新货位状态
12
+    @RequestMapping(value="/Warehouse/updateWarehouseCrkStatus", method=RequestMethod.POST)
13
+    void updateWarehouseCrkStatus(@RequestParam(value = "wareId") Integer wareId, @RequestParam(value = "crk_status") String crk_status);
14
+
15
+}

+ 4 - 2
src/main/java/com/chinaitop/depot/storage/mapper/StorageQualitycheckMapper.java

@@ -2,11 +2,11 @@ package com.chinaitop.depot.storage.mapper;
2 2
 
3 3
 import com.chinaitop.depot.storage.model.StorageQualitycheck;
4 4
 import com.chinaitop.depot.storage.model.StorageQualitycheckExample;
5
+import org.apache.ibatis.annotations.Param;
6
+
5 7
 import java.util.List;
6 8
 import java.util.Map;
7 9
 
8
-import org.apache.ibatis.annotations.Param;
9
-
10 10
 public interface StorageQualitycheckMapper {
11 11
     /**
12 12
      * This method was generated by MyBatis Generator.
@@ -129,4 +129,6 @@ public interface StorageQualitycheckMapper {
129 129
     List<Map<String, Object>> getAllQualityInfo(Map<String, Object> paramMap);
130 130
 
131 131
     List<Map<String, Object>> getAllFoodStocks(Map<String, Object> paramMap);
132
+
133
+    void updateByFlagType(StorageQualitycheck qualitycheck);
132 134
 }

+ 10 - 2
src/main/java/com/chinaitop/depot/storage/mapper/StorageQualitycheckMapper.xml

@@ -10,6 +10,7 @@
10 10
     <id column="id" property="id" jdbcType="INTEGER" />
11 11
     <result column="house_id" property="houseId" jdbcType="INTEGER" />
12 12
     <result column="warehouse_id" property="warehouseId" jdbcType="INTEGER" />
13
+    <result column="flag_type" property="flagType" jdbcType="INTEGER" />
13 14
     <result column="type" property="type" jdbcType="VARCHAR" />
14 15
     <result column="sub_type" property="subType" jdbcType="INTEGER" />
15 16
     <result column="sub_type_detailed" property="subTypeDetailed" jdbcType="INTEGER" />
@@ -188,7 +189,7 @@
188 189
     check_result_time, store_quality, is_pest, inspection_standard_basis, quality, seal_date, 
189 190
     seal_status, auth_code, org_id, history_status, intermixing_rate, smelltaste, transparency, 
190 191
     peroxide_value, smoke_point, reeze_test, residual_solvent, lead, total_arsenic, aflatoxin, 
191
-    butyl_phenol, updatetime, zblb, qydbh, qysj, qyqy, jdrxm, ypbh, sfzcccnx
192
+    butyl_phenol, updatetime, zblb, qydbh, qysj, qyqy, jdrxm, ypbh, sfzcccnx, flag_type
192 193
   </sql>
193 194
   <select id="selectByExample" resultMap="BaseResultMap" parameterType="com.chinaitop.depot.storage.model.StorageQualitycheckExample" >
194 195
     <!--
@@ -1770,7 +1771,7 @@
1770 1771
 
1771 1772
 
1772 1773
   <sql id="ExtBase_Column_List">
1773
-    sqk.id, sqk.house_id, sqk.warehouse_id, sqk.type, sqk.sub_type, sqk.sub_type_detailed, sqk.check_time, sqk.check_result,
1774
+    sqk.id, sqk.house_id, sqk.warehouse_id, sqk.type, sqk.sub_type, sqk.sub_type_detailed, sqk.check_time, sqk.check_result,sqk.flag_type,
1774 1775
     sqk.checker, sqk.level, sqk.capacity, sqk.water, sqk.impurity, sqk.mineral, sqk.badpart, sqk.colorsmell, sqk.keeper_advices,
1775 1776
     sqk.keeper_advices_time, sqk.keeper_advices_paint, sqk.chief_advices, sqk.chief_advices_time, sqk.chiet_advices_paint,
1776 1777
     sqk.vice_manager_advices, sqk.vice_manager_advices_time, sqk.vice_manager_advices_paint, sqk.manager_advices,
@@ -1994,4 +1995,11 @@
1994 1995
         LEFT JOIN basic_storehouse bs ON sfo.house_id = bs.storehouse_id
1995 1996
         LEFT JOIN org_info oi ON oi.org_id = sfo.org_id
1996 1997
   </select>
1998
+
1999
+  <update id="updateByFlagType" parameterType="com.chinaitop.depot.storage.model.StorageQualitycheck" >
2000
+    update storage_qualitycheck
2001
+    set flag_type = 1
2002
+    where house_id = #{houseId} and warehouse_id = #{warehouseId} and type = 0
2003
+  </update>
2004
+
1997 2005
 </mapper>

+ 11 - 2
src/main/java/com/chinaitop/depot/storage/model/StorageQualitycheck.java

@@ -759,6 +759,9 @@ public class StorageQualitycheck {
759 759
     private Integer acceptanceId;
760 760
     private String orgName;
761 761
 
762
+    //0 初检,1验收
763
+    private Integer flagType;
764
+
762 765
     private Integer foodbasicinfoId;
763 766
 
764 767
     //封仓业务字段
@@ -3105,6 +3108,12 @@ public class StorageQualitycheck {
3105 3108
 	public void setNotice(Integer notice) {
3106 3109
 		this.notice = notice;
3107 3110
 	}
3108
-    
3109
-    
3111
+
3112
+    public Integer getFlagType() {
3113
+        return flagType;
3114
+    }
3115
+
3116
+    public void setFlagType(Integer flagType) {
3117
+        this.flagType = flagType;
3118
+    }
3110 3119
 }

+ 9 - 0
src/main/java/com/chinaitop/depot/storage/service/impl/StorageFoodbasicInfoServiceImpl.java

@@ -1,6 +1,7 @@
1 1
 package com.chinaitop.depot.storage.service.impl;
2 2
 
3 3
 
4
+import com.chinaitop.depot.feign.FeignBasicService;
4 5
 import com.chinaitop.depot.storage.mapper.StorageFoodbasicInfoCheckMapper;
5 6
 import com.chinaitop.depot.storage.mapper.StorageFoodbasicinfoMapper;
6 7
 import com.chinaitop.depot.storage.mapper.StorageQualitycheckMapper;
@@ -36,6 +37,10 @@ public class StorageFoodbasicInfoServiceImpl implements StorageFoodbasicInfoServ
36 37
     @Resource
37 38
     private StorageFoodbasicInfoLocationService foodbasicInfoLocationService;
38 39
 
40
+    //远程调用
41
+    @Resource
42
+    private FeignBasicService whouseFeignClient;
43
+
39 44
     @Value("${web.upload-path}")
40 45
     private String rootPath;
41 46
 
@@ -86,6 +91,10 @@ public class StorageFoodbasicInfoServiceImpl implements StorageFoodbasicInfoServ
86 91
             StorageQualitycheck qualitycheckData =qualitycheckMapper.queryPrimaryKey(qualitycheckVo.getQualitycheckId());
87 92
             qualitycheck = qualitycheckData;
88 93
         }
94
+
95
+        //更新或为状态
96
+        whouseFeignClient.updateWarehouseCrkStatus(wareHouseId,"3");
97
+
89 98
         if(qualitycheck != null){
90 99
             foodbasicInfo.setWater(qualitycheck.getWater());//水分
91 100
             foodbasicInfo.setImpurity(qualitycheck.getImpurity());//杂质

+ 4 - 0
src/main/java/com/chinaitop/depot/storage/service/impl/StorageQualitycheckServiceImpl.java

@@ -38,6 +38,10 @@ public class StorageQualitycheckServiceImpl implements StorageQualitycheckServic
38 38
         Integer qualityCheckId=0;
39 39
 		if (qualitycheck.getId() == null) {
40 40
 			qualitycheckMapper.insertSelective(qualitycheck);// 新增数据
41
+            //如果验收,把页面验收隐藏
42
+            if("1".equals(qualitycheck.getType())){
43
+                qualitycheckMapper.updateByFlagType(qualitycheck);
44
+            }
41 45
             qualityCheckId = qualitycheck.getId();
42 46
         } else {
43 47
             qualitycheckMapper.updateByPrimaryKeySelective(qualitycheck);// 修改数据

+ 4 - 0
src/main/resources/bootstrap.yml

@@ -14,6 +14,10 @@ eureka:
14 14
     lease-renewal-interval-in-seconds: 10
15 15
     # 告知服务端30秒还未收到心跳的话,就将该服务移除列表(默认90s)
16 16
     lease-expiration-duration-in-seconds: 30
17
+feign:
18
+  hystrix:
19
+    enabled: true # 开启Feign熔断
20
+---
17 21
 
18 22
 spring:
19 23
   application: