Commit 0e6ea1e3 authored by 陈家荣's avatar 陈家荣

更新数据同步时间为凌晨1点

parent aa226ee8
...@@ -415,6 +415,9 @@ public class KolonMemberServiceImpl implements KolonMemberService { ...@@ -415,6 +415,9 @@ public class KolonMemberServiceImpl implements KolonMemberService {
String sourse = member.user.sourse; String sourse = member.user.sourse;
//获取shopID //获取shopID
String shopId = sourse.substring(sourse.lastIndexOf("_") + 1, sourse.length()); String shopId = sourse.substring(sourse.lastIndexOf("_") + 1, sourse.length());
if(Util.isNotNull(shopId) && shopId.equals("self")){
return channelCode;
}else{
MongoPiShop mongoPiShop = mongoPiShopRepository.findFirstById(shopId); MongoPiShop mongoPiShop = mongoPiShopRepository.findFirstById(shopId);
if(Util.isNotNull(mongoPiShop)){ if(Util.isNotNull(mongoPiShop)){
channelCode = mongoPiShop.shopCode; channelCode = mongoPiShop.shopCode;
...@@ -422,6 +425,7 @@ public class KolonMemberServiceImpl implements KolonMemberService { ...@@ -422,6 +425,7 @@ public class KolonMemberServiceImpl implements KolonMemberService {
LOGGER.warn("kolon获取门店编号出错,没有找到ID为【"+shopId+"】门店"); LOGGER.warn("kolon获取门店编号出错,没有找到ID为【"+shopId+"】门店");
} }
} }
}
return channelCode; return channelCode;
} }
......
...@@ -43,7 +43,7 @@ public class FtpScheduledTask { ...@@ -43,7 +43,7 @@ public class FtpScheduledTask {
} }
// 每天凌晨1:00触发 // 每天凌晨1:00触发
@Scheduled(cron = "0 35 12 * * ?") @Scheduled(cron = "0 00 1 * * ?")
public void scheduledWriteTask() { public void scheduledWriteTask() {
writeCSVFile(); writeCSVFile();
} }
......
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