Commit f3076eec by 周晓航

修改 接口 传参 key变动

parent a1b96d3a
...@@ -16,7 +16,7 @@ import java.util.Set; ...@@ -16,7 +16,7 @@ import java.util.Set;
@Builder @Builder
public class ReportStoreIdsRequestVo { public class ReportStoreIdsRequestVo {
String partnerCode; String partnerId;
Set<String> storeCodeList; Set<String> storeCodeList;
......
...@@ -27,6 +27,8 @@ import java.util.*; ...@@ -27,6 +27,8 @@ import java.util.*;
@Component @Component
public class OrderReportJobHandler { public class OrderReportJobHandler {
private static final String pattern_yyyy_MM_dd = "yyyy-MM-dd";
private static final String pattern_yyyyMMdd = "yyyyMMdd";
@Autowired @Autowired
private RedisCache redisCache; private RedisCache redisCache;
...@@ -35,7 +37,7 @@ public class OrderReportJobHandler { ...@@ -35,7 +37,7 @@ public class OrderReportJobHandler {
private StoreBackstageClient storeBackstageClient; private StoreBackstageClient storeBackstageClient;
public void sendYesterDayStoreMsg() { public void sendYesterDayStoreMsg() {
String date = getYesterdayString(); String date = getYesterdayString(pattern_yyyy_MM_dd);
BoundHashOperations<String, String, Set<String>> boundHashOperations = redisCache.getRedisTemplate().boundHashOps(RedisKeyConstant.KGD_NO_ORDER_STORE_DATE + date); BoundHashOperations<String, String, Set<String>> boundHashOperations = redisCache.getRedisTemplate().boundHashOps(RedisKeyConstant.KGD_NO_ORDER_STORE_DATE + date);
Map<String, Set<String>> entries = boundHashOperations.entries(); Map<String, Set<String>> entries = boundHashOperations.entries();
LogUtil.info("下单门店记录推送 entries", entries, null); LogUtil.info("下单门店记录推送 entries", entries, null);
...@@ -43,12 +45,12 @@ public class OrderReportJobHandler { ...@@ -43,12 +45,12 @@ public class OrderReportJobHandler {
// 推送门店 服务 // 推送门店 服务
List<ReportStoreIdsRequestVo> requestDto = new ArrayList<>(entries.size()); List<ReportStoreIdsRequestVo> requestDto = new ArrayList<>(entries.size());
entries.forEach((partnerId, storeIds) -> { entries.forEach((partnerId, storeIds) -> {
ReportStoreIdsRequestVo build = ReportStoreIdsRequestVo.builder().partnerCode(partnerId).storeCodeList(storeIds).build(); ReportStoreIdsRequestVo build = ReportStoreIdsRequestVo.builder().partnerId(partnerId).storeCodeList(storeIds).build();
requestDto.add(build); requestDto.add(build);
}); });
try { try {
// 发送服务 // 发送服务
PushOrderStoreDto pushOrderStoreDto = PushOrderStoreDto.builder().pushDate(date) PushOrderStoreDto pushOrderStoreDto = PushOrderStoreDto.builder().pushDate(getYesterdayString(pattern_yyyyMMdd))
.partnerList(requestDto) .partnerList(requestDto)
.build(); .build();
BaseResponse baseResponse = storeBackstageClient.pushOrderStore(pushOrderStoreDto); BaseResponse baseResponse = storeBackstageClient.pushOrderStore(pushOrderStoreDto);
...@@ -66,11 +68,11 @@ public class OrderReportJobHandler { ...@@ -66,11 +68,11 @@ public class OrderReportJobHandler {
* *
* @return * @return
*/ */
private String getYesterdayString() { private String getYesterdayString(String pattern) {
Calendar start = Calendar.getInstance(); Calendar start = Calendar.getInstance();
// 取昨天时间 // 取昨天时间
start.add(5, -1); start.add(5, -1);
SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd");//注意月份是MM SimpleDateFormat simpleDateFormat = new SimpleDateFormat(pattern);//注意月份是MM
return simpleDateFormat.format(start.getTime()); return simpleDateFormat.format(start.getTime());
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment