提交 7a964a27 authored 作者: 000516's avatar 000516 提交者: Coding

终端勤策终端数据由全量数据改为每天同步一周内修改过的数据

终端勤策终端数据由全量数据改为每天同步一周内修改过的数据
...@@ -13,7 +13,7 @@ ...@@ -13,7 +13,7 @@
<groupId>com.wangxiaolu</groupId> <groupId>com.wangxiaolu</groupId>
<artifactId>wangxiaolu-promotion-service</artifactId> <artifactId>wangxiaolu-promotion-service</artifactId>
<version>0.1.0</version> <version>0.1.1</version>
<name>wangxiaolu-promotion-service</name> <name>wangxiaolu-promotion-service</name>
<description>promotion-service</description> <description>promotion-service</description>
......
...@@ -109,6 +109,7 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService { ...@@ -109,6 +109,7 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
} }
private boolean booleanshopDetailPage(Integer pageNum) { private boolean booleanshopDetailPage(Integer pageNum) {
// 查找一周内修改或新增的数据
Map<String, Object> params = qinCeUtils.queryShopParam(pageNum); Map<String, Object> params = qinCeUtils.queryShopParam(pageNum);
String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_SHORE, params); String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_SHORE, params);
...@@ -116,11 +117,11 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService { ...@@ -116,11 +117,11 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
JSONObject resultJson = OkHttp.postQC(url, params); JSONObject resultJson = OkHttp.postQC(url, params);
JSONArray responseDatas = resultJson.getJSONArray("response_data"); JSONArray responseDatas = resultJson.getJSONArray("response_data");
if (responseDatas.size() <= 0) { if (responseDatas.size() <= 0) {
log.error("勤策-同步终端store数据,未查询到数据"); log.error("勤策-同步一周内修改过的终端store数据,未查询到数据");
return false; return false;
} }
log.info("勤策-同步终端store数据,查询到第{}页数据「{}」条", pageNum, responseDatas.size()); log.info("勤策-同步一周内修改过的终端store数据,查询到第{}页数据「{}」条", pageNum, responseDatas.size());
qinCeClienteleShopDao.shopDetailAllTask(responseDatas); qinCeClienteleShopDao.shopDetailAllTask(responseDatas);
promotionStoreDao.qinceShopDetailAllTask(responseDatas); promotionStoreDao.qinceShopDetailAllTask(responseDatas);
return true; return true;
......
package com.wangxiaolu.promotion.utils; package com.wangxiaolu.promotion.utils;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.format.DatePrinter;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.codec.digest.DigestUtils; import org.apache.commons.codec.digest.DigestUtils;
...@@ -124,25 +128,11 @@ public class QinCeUtils { ...@@ -124,25 +128,11 @@ public class QinCeUtils {
HashMap<String, Object> params = new HashMap<>(); HashMap<String, Object> params = new HashMap<>();
// 分页页码,默认1 // 分页页码,默认1
params.put("page_number", pageNum); params.put("page_number", pageNum);
// 记录状态。0:已删除,1:正常 // 记录状态。0:已删除(客户回收站中的终端数据),1:正常
// 0:已删除:客户回收站中的终端数据
params.put("status", "1"); params.put("status", "1");
// 勤策的门店唯一ID // after_modify_date:更新时间之后,查询更新时间之后的门店数据。格式:yyyy-MM-dd HH:mm:SS
params.put("id", ""); DateTime dateTime = DateUtil.offsetDay(new Date(), -7);
// 来源于第三方系统的门店唯一ID,对应新增门店 (store_id)字段,只有当数据来源于新增接口时才有值,如果数据从勤策系统中直接创建则该字段值为空。 如果两个值同时存在则优先顺序为store_waiqin_id、store_id params.put("after_modify_date", DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
params.put("store_id", "");
// 门店名称,唯一
params.put("store_name", "");
// 门店编码
params.put("store_code", "");
// 根据门店客户经理标识查询
params.put("store_manager_id", "");
// 门店类型编码,store_type、store_type_code如果同时存在优先取store_type_code
params.put("store_type_code", "");
// 门店类型
params.put("store_status", "1");
// 门店审批状态。1:待审批,2:审批打回,3:审批通过
params.put("store_approval_status", "3");
return params; return params;
} }
......
package com.wangxiaolu.promotion.utils; package com.wangxiaolu.promotion.utils;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.junit.runner.RunWith; import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;
...@@ -23,4 +26,9 @@ class DateUtilsTest { ...@@ -23,4 +26,9 @@ class DateUtilsTest {
boolean b = DateUtils.parseTime(new Date(), "16:00:00", "16:30:00"); boolean b = DateUtils.parseTime(new Date(), "16:00:00", "16:30:00");
System.out.println("是否在时间范围内:" + b); System.out.println("是否在时间范围内:" + b);
} }
public static void main(String[] args) {
DateTime dateTime = DateUtil.offsetDay(new Date(), -7);
System.out.println(DateUtil.format(dateTime, DatePattern.NORM_DATETIME_PATTERN));
}
} }
\ No newline at end of file
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论