Commit c9c33bf13b0eac1d2f5b29352cfb3c0c0c7ab7f9

Authored by 姜超
1 parent 892040a7

feature(*): 门店数据上报

门店数据上报
fw-morax-sdk/pom.xml
... ... @@ -13,7 +13,7 @@
13 13 <artifactId>fw-morax-sdk</artifactId>
14 14 <packaging>jar</packaging>
15 15 <name>fw-morax-sdk</name>
16   - <version>2.0.0</version>
  16 + <version>2.0.1</version>
17 17  
18 18 <properties>
19 19 <hibernate.validator>5.3.6.Final</hibernate.validator>
... ...
fw-morax-service/src/main/java/cn/fw/morax/service/biz/kpi/IndicatorBizService.java
... ... @@ -328,7 +328,7 @@ public class IndicatorBizService {
328 328 ShopIndicatorBO bo = transferShopBo(r);
329 329 return JSONObject.toJSONString(bo);
330 330 }).toArray(String[]::new);
331   - BoundListOperations<String, String> opsList = stringRedisTemplate.boundListOps(getIndicatorKeyPref());
  331 + BoundListOperations<String, String> opsList = stringRedisTemplate.boundListOps(getIndicatorShopKeyPref());
332 332 opsList.rightPushAll(jsonArr);
333 333 }
334 334  
... ... @@ -340,7 +340,7 @@ public class IndicatorBizService {
340 340 ListOperations<String, String> opsForList = stringRedisTemplate.opsForList();
341 341 List<String> overflowsOrFailList = new ArrayList<>();
342 342 String jsonStr;
343   - while ((jsonStr = opsForList.leftPop(getIndicatorKeyPref())) != null) {
  343 + while ((jsonStr = opsForList.leftPop(getIndicatorShopKeyPref())) != null) {
344 344 final ShopIndicatorBO bo = JSONObject.parseObject(jsonStr, ShopIndicatorBO.class);
345 345 if (Objects.isNull(bo)) {
346 346 continue;
... ... @@ -361,7 +361,7 @@ public class IndicatorBizService {
361 361 }
362 362 }
363 363 if (!CollectionUtils.isEmpty(overflowsOrFailList)) {
364   - opsForList.rightPushAll(getIndicatorKeyPref(), overflowsOrFailList);
  364 + opsForList.rightPushAll(getIndicatorShopKeyPref(), overflowsOrFailList);
365 365 }
366 366 }
367 367  
... ...
... ... @@ -32,7 +32,7 @@
32 32 <mysql-connector-java.version>5.1.47</mysql-connector-java.version>
33 33 <HikariCP.version>3.3.1</HikariCP.version>
34 34 <!-- fw -->
35   - <fw.morax.sdk.version>2.0.0</fw.morax.sdk.version>
  35 + <fw.morax.sdk.version>2.0.1</fw.morax.sdk.version>
36 36 <rocketmq-spring-boot-starter.version>2.1.0</rocketmq-spring-boot-starter.version>
37 37 <redis.spring.boot.starter>2.0</redis.spring.boot.starter>
38 38 <fw-approval-sdk.version>1.0.0</fw-approval-sdk.version>
... ...