勤策拉取门店信息到本地

src/main/java/com/wangxiaolu/promotion/controller/user/QinCeDataTaskController.java

@@ -34,5 +34,13 @@ public class QinCeDataTaskController {
         qinCeDataTaskService.employeeSyncTask();
     }
 
+    /**
+     * 同步[终端数据]
+     */
+    @GetMapping("/shops")
+    public void shopDetailAllTask(){
+        qinCeDataTaskService.shopDetailAllTask();
+    }
+
 
 }

src/main/java/com/wangxiaolu/promotion/domain/user/dao/QinCeClienteleShopDao.java

+package com.wangxiaolu.promotion.domain.user.dao;
+
+import com.alibaba.fastjson.JSONArray;
+
+/**
+ * @author : liqiulin
+ * @date : 2024-04-22 16
+ * @describe :
+ */
+public interface QinCeClienteleShopDao {
+
+    /**
+     * 勤策人员数据同步
+     */
+    void shopDetailAllTask(JSONArray responseDatas);
+}

src/main/java/com/wangxiaolu/promotion/domain/user/dao/QinCeEmployeeDao.java

@@ -10,7 +10,7 @@ import com.alibaba.fastjson.JSONArray;
 public interface QinCeEmployeeDao {
 
     /**
-     * 勤微人员数据同步
+     * 勤策人员数据同步
      */
     void employeeSyncTask(JSONArray responseDatas);
 }

src/main/java/com/wangxiaolu/promotion/domain/user/dao/impl/QinCeClienteleShopDaoImpl.java

+package com.wangxiaolu.promotion.domain.user.dao.impl;
+
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.wangxiaolu.promotion.domain.user.dao.QinCeClienteleShopDao;
+import com.wangxiaolu.promotion.domain.user.mapper.QinCeClienteleShopMapper;
+import com.wangxiaolu.promotion.domain.user.mapper.entity.QinCeClienteleShopDO;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+/**
+ * @author : liqiulin
+ * @date : 2024-04-22 16
+ * @describe :
+ */
+@Slf4j
+@Service
+public class QinCeClienteleShopDaoImpl implements QinCeClienteleShopDao {
+
+    @Autowired
+    QinCeClienteleShopMapper qinCeClienteleShopMapper;
+
+    @Override
+    public void shopDetailAllTask(JSONArray responseDatas) {
+        LambdaQueryWrapper<QinCeClienteleShopDO> qw = new LambdaQueryWrapper<>();
+
+        for (Object responseData : responseDatas) {
+            qw.clear();
+
+            QinCeClienteleShopDO qinCeShopDO = JSONObject.parseObject(responseData.toString(), QinCeClienteleShopDO.class);
+            qw.eq(QinCeClienteleShopDO::getQcId, qinCeShopDO.getQcId());
+            QinCeClienteleShopDO doExist = qinCeClienteleShopMapper.selectOne(qw);
+
+            if (Objects.isNull(doExist)) {
+                qinCeClienteleShopMapper.insert(qinCeShopDO);
+            } else {
+                qinCeShopDO.setId(doExist.getId());
+                qinCeClienteleShopMapper.updateById(qinCeShopDO);
+            }
+        }
+
+    }
+}

src/main/java/com/wangxiaolu/promotion/domain/user/mapper/QinCeClienteleShopMapper.java

+package com.wangxiaolu.promotion.domain.user.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.wangxiaolu.promotion.domain.user.mapper.entity.QinCeClienteleShopDO;
+import org.apache.ibatis.annotations.Mapper;
+import org.springframework.stereotype.Repository;
+
+/**
+* @author a02200059
+* @description 针对表【qc_clientele_shop(勤策-客户管理-终端)】的数据库操作Mapper
+* @createDate 2024-04-22 16:42:53
+* @Entity com.wangxiaolu.promotion.domain.user.mapper.entity.QcClienteleShop
+*/
+@Mapper
+@Repository
+public interface QinCeClienteleShopMapper extends BaseMapper<QinCeClienteleShopDO> {
+}
+
+
+
+

src/main/java/com/wangxiaolu/promotion/domain/user/mapper/entity/QinCeClienteleShopDO.java

+package com.wangxiaolu.promotion.domain.user.mapper.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
+import java.io.Serializable;
+import java.util.Date;
+import lombok.Data;
+
+/**
+ * 勤策-客户管理-终端
+ * @TableName qc_clientele_shop
+ */
+@TableName(value ="qince_clientele_shop")
+@Data
+public class QinCeClienteleShopDO implements Serializable {
+    /**
+     * 主键id
+     */
+    @TableId(type = IdType.AUTO)
+    private Long id;
+
+    /**
+     * 勤策的门店唯一ID
+     */
+    private String qcId;
+
+    /**
+     * 源于第三方系统的门店唯一ID
+     */
+    private String storeId;
+
+    /**
+     * 创建人id，来源勤策员工唯一ID
+     */
+    private String creatorWaiqinId;
+
+    /**
+     * 创建人名称
+     */
+    private String creatorName;
+
+    /**
+     * 创建人id，来源第三方系统的唯一ID
+     */
+    private String creatorId;
+
+    /**
+     * 退回原因
+     */
+    private String returnPoolReason;
+
+    /**
+     * 门店名称
+     */
+    private String storeName;
+
+    /**
+     * 门店编码
+     */
+    private String storeCode;
+
+    /**
+     * 门店经理,多门店经理名称间以“,”分隔
+     */
+    private String storeManager;
+
+    /**
+     * 勤策门店经理id。第三方唯一标识，多门店经理id间以“,”分隔
+     */
+    private String storeManagerId;
+
+    /**
+     * 勤策门店经理id。勤策唯一标识，多门店经理id间以“,”分隔。store_manager_waiqin365_id、store_manager_id、store_manager如果同时存在，优先级依次降低
+     */
+    private String storeManagerWaiqin365Id;
+
+    /**
+     * 门店类型名称
+     */
+    private String storeType;
+
+    /**
+     * 门店类型编码
+     */
+    private String storeTypeCode;
+
+    /**
+     * 门店类型id
+     */
+    private String storeTypeId;
+
+    /**
+     * 勤策门店等级ID
+     */
+    private String storeLevelId;
+
+    /**
+     * 门店等级名称
+     */
+    private String storeLevel;
+
+    /**
+     * 勤策门店所属部门ID
+     */
+    private String storeDeptWaiqin365Id;
+
+    /**
+     * 门店所属部门，来源第三方系统的唯一标识和部门信息中org_id对应
+     */
+    private String storeDeptId;
+
+    /**
+     * 门店部门名称
+     */
+    private String storeDeptName;
+
+    /**
+     * 门店所属销售区域，此字段为 销售区域的最末级结构
+     */
+    private String storeDistrict;
+
+    /**
+     * 门店所属销售区域，此字段为销售区域的完整层级结构，多层级间以“,”分隔。 如：华中大区,南京分区,秦淮社区
+     */
+    private String storeDistrictFullPath;
+
+    /**
+     * 门店所属销售区域ID，来源于勤策的销售区域唯一ID
+     */
+    private String storeDistrictWaiqin365Id;
+
+    /**
+     * 第三方销售区域id
+     */
+    private String storeThirdDistrictId;
+
+    /**
+     * 门店所属行政区域-省份名称，如：北京市、江苏省
+     */
+    private String storeMssProvince;
+
+    /**
+     * 门店所属行政区域-省份编码，如：110000、320000
+     */
+    private String storeMssProvinceCode;
+
+    /**
+     * 门店所属行政区域-城市名称，如：南京市
+     */
+    private String storeMssCity;
+
+    /**
+     * 门店所属行政区域-城市编码，如：320100
+     */
+    private String storeMssCityCode;
+
+    /**
+     * 门店所属行政区域-区县名称，如：鼓楼区
+     */
+    private String storeMssArea;
+
+    /**
+     * 门店所属行政区域-区县编码，如：320106
+     */
+    private String storeMssAreaCode;
+
+    /**
+     * 门店所属行政区域-乡镇街道名称，如：宁海路街道
+     */
+    private String storeMssStreet;
+
+    /**
+     * 门店所属行政区域-乡镇街道编码，如：320106001
+     */
+    private String storeMssStreetCode;
+
+    /**
+     * 门店所在地址
+     */
+    private String storeAddr;
+
+    /**
+     * 勤策合作状态ID
+     */
+    private String storeCooperateStatusId;
+
+    /**
+     * 合作状态编码。0：终止合作，1：合作中，2：未合作，3：有意向
+     */
+    private String storeCooperateStatus;
+
+    /**
+     * 门店所属连锁品牌
+     */
+    private String storeKaSys;
+
+    /**
+     * 门店电话，如：02544550010或025-44550010
+     */
+    private String storeTel;
+
+    /**
+     * 门店传真，如：02544550010或025-44550010
+     */
+    private String storeFax;
+
+    /**
+     * 门店邮编
+     */
+    private String storePost;
+
+    /**
+     * 门店备注
+     */
+    private String storeRemarks;
+
+    /**
+     * 商圈等级
+     */
+    private String tradingareaBig;
+
+    /**
+     * 商圈标签
+     */
+    private String tradingarea;
+
+    /**
+     * 商圈等级编码
+     */
+    private String tradingareaLevelCode;
+
+    /**
+     * 商圈等级名称
+     */
+    private String tradingareaLevelName;
+
+    /**
+     * 勤策销售区域id。此字段从2021年8月01日起，对新创建第三方应用不再返回真实store_district_id，使用store_district_waiqin365_id代替store_district_id
+     */
+    private String storeDistrictId;
+
+    /**
+     * 门店所属销售区域编码，来源于勤策的销售区域编码。
+     */
+    private String storeDistrictCode;
+
+    /**
+     * 销售区域创建时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String storeDistrictCreateTime;
+
+    /**
+     * 销售区域修改时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String storeDistrictModifyTime;
+
+    /**
+     * 销售区域创建人
+     */
+    private String storeDistrictCreatorName;
+
+    /**
+     * 销售区域修改人
+     */
+    private String storeDistrictModifyierName;
+
+    /**
+     * 销售区域状态。1：正常，0：删除。默认值为1
+     */
+    private String storeDistrictStatus;
+
+    /**
+     * 勤策客户层级id。“-1”表示是根节点
+     */
+    private String storeRelLevelId;
+
+    /**
+     * 门店分层标签名称。多分层标签名称以“,”分隔
+     */
+    private String storeLabel;
+
+    /**
+     * 门店分层标签id。多分层标签id以“,”分隔
+     */
+    private String storeLabelId;
+
+    /**
+     * 门店协助员唯一标识。多协助员唯一标识以“,”分隔
+     */
+    private String storeAssistantId;
+
+    /**
+     * 门店协助员名称。多协助员名称以“,”分隔
+     */
+    private String storeAssistantName;
+
+    /**
+     * 门店道路信息
+     */
+    private String storeRoadMsg;
+
+    /**
+     * 门店门牌号信息
+     */
+    private String storeHouseNumber;
+
+    /**
+     * 门店营业执照信息
+     */
+    private String storeLiscenceName;
+
+    /**
+     * 门店工商注册号信息
+     */
+    private String storeRegistrationNo;
+
+    /**
+     * 门店注册日期。格式：yyyy-MM-dd
+     */
+    private String storeRegistrationDate;
+
+    /**
+     * 门店经营者信息
+     */
+    private String storeOperator;
+
+    /**
+     * 是否直接交易客户。0：是，1：否
+     */
+    private String storeSaleDirect;
+
+    /**
+     * 门店修改时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String storeModifyTime;
+
+    /**
+     * 门店修改人名称
+     */
+    private String storeModifyierName;
+
+    /**
+     * 新增门店最终审批通过时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String storeCreateApprovalTime;
+
+    /**
+     * 修改客户审批通过时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String storeModifyApprovalTime;
+
+    /**
+     * 创建方式
+     */
+    private String storeSourceType;
+
+    /**
+     * 门店营业面积
+     */
+    private String storeSellingArea;
+
+    /**
+     * 门店收银台个数
+     */
+    private String storeCashiersNum;
+
+    /**
+     * 门店货架组数
+     */
+    private String storeShelfNum;
+
+    /**
+     * 门店总排面数
+     */
+    private String storeTotalNum;
+
+    /**
+     * 门店本品排面数
+     */
+    private String storeSelfProductNum;
+
+    /**
+     * 门店营业开始时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private Date storeOpenTime;
+
+    /**
+     * 门店营业结束时间。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private Date storeCloseTime;
+
+    /**
+     * 门店门头照信息，多个以“,”号隔开
+     */
+    private String storePictures;
+
+    /**
+     * 门店营业执照信息，多个以“,”号隔开
+     */
+    private String storeLiscence;
+
+    /**
+     * 门店客户经理编码，即为员工登录账号，多客户经理唯一标识间以英文“,”隔开
+     */
+    private String storeManagerCode;
+
+    /**
+     * 创建人编码
+     */
+    private String storeCreatorCode;
+
+    /**
+     * 修改人编码，取最新修改记录操作人
+     */
+    private String storeModifierCode;
+
+    /**
+     * 门店审批状态。1：待审批，2：审批打回，3：审批通过
+     */
+    private String storeApprovalStatus;
+
+    /**
+     * 门店删除状态。0：删除，1：正常
+     */
+    private String storeStatus;
+
+    /**
+     * 创建日期。格式：yyyy-MM-dd HH:mm:ss
+     */
+    private String createTime;
+
+    @TableField(exist = false)
+    private static final long serialVersionUID = 1L;
+}
\ No newline at end of file

src/main/java/com/wangxiaolu/promotion/domain/user/mapper/entity/QinCeDepartmentDO.java

@@ -13,7 +13,7 @@ import java.util.Date;
 /**
  * @author : liqiulin
  * @date : 2024-03-29 15
- * @describe : 勤策-组织架构-dto
+ * @describe : 勤策-组织架构
  */
 @TableName(value ="qince_department")
 @Data

src/main/java/com/wangxiaolu/promotion/service/user/QinCeDataTaskService.java

@@ -9,4 +9,7 @@ public interface QinCeDataTaskService {
     void departmentSyncTask();
 
     void employeeSyncTask();
+
+    void shopDetailAllTask();
+
 }

src/main/java/com/wangxiaolu/promotion/service/user/impl/QinCeDataTaskServiceImpl.java

@@ -2,6 +2,7 @@ package com.wangxiaolu.promotion.service.user.impl;
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.wangxiaolu.promotion.domain.user.dao.QinCeClienteleShopDao;
 import com.wangxiaolu.promotion.domain.user.dao.QinCeDepartmentDao;
 import com.wangxiaolu.promotion.domain.user.dao.QinCeEmployeeDao;
 import com.wangxiaolu.promotion.service.user.QinCeDataTaskService;
@@ -22,18 +23,20 @@ import java.util.Map;
 @Service
 public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
 
+    @Autowired
+    QinCeUtils qinCeUtils;
     @Autowired
     QinCeDepartmentDao qinCeDepartmentDao;
     @Autowired
     QinCeEmployeeDao qinCeEmployeeDao;
     @Autowired
-    QinCeUtils qinCeUtils;
+    QinCeClienteleShopDao qinCeClienteleShopDao;
 
     @Override
     public void departmentSyncTask() {
         // 查询组织架构参数、创建url
         Map<String, Object> params = qinCeUtils.queryOrgParam();
-        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_ORGANIZATION,params);
+        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_ORGANIZATION, params);
 
         // 发起请求、接收结果
         JSONObject resultJson = OkHttp.post(url, params);
@@ -51,7 +54,7 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
     public void employeeSyncTask() {
         // 查询组织架构参数、创建url
         Map<String, Object> params = qinCeUtils.queryEmployeeParam(false);
-        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE,params);
+        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_EMPLOYEE, params);
 
         // 发起请求、接收结果
         JSONObject resultJson = OkHttp.post(url, params);
@@ -64,4 +67,24 @@ public class QinCeDataTaskServiceImpl implements QinCeDataTaskService {
         qinCeEmployeeDao.employeeSyncTask(responseDatas);
 
     }
+
+    /**
+     * 同步[终端数据]
+     */
+    @Override
+    public void shopDetailAllTask() {
+        Map<String, Object> params = qinCeUtils.queryShopParam();
+        String url = qinCeUtils.builderUrl(QinCeUtils.QUERY_SHORE, params);
+
+        // 发起请求、接收结果
+        JSONObject resultJson = OkHttp.post(url, params);
+        JSONArray responseDatas = resultJson.getJSONArray("response_data");
+        if (responseDatas.size() <= 0) {
+            log.error("勤策-同步人员数据，未查询到数据");
+            return;
+        }
+
+        log.info("勤策-同步终端数据，查询到数据「{}」条", responseDatas.size());
+        qinCeClienteleShopDao.shopDetailAllTask(responseDatas);
+    }
 }

src/main/java/com/wangxiaolu/promotion/utils/QinCeUtils.java

@@ -34,6 +34,8 @@ public class QinCeUtils {
     public static final String QUERY_ORGANIZATION = "/api/organization/v1/queryOrganization/";
     // 员工列表
     public static final String QUERY_EMPLOYEE = "/api/employee/v3/queryEmployee/";
+    // 终端（商店）列表
+    public static final String QUERY_SHORE = "/api/store/v1/queryStore/";
 
     public String builderUrl(String sidepath, Map<String, Object> params) {
         String msgId = UUID.randomUUID().toString();
@@ -45,7 +47,7 @@ public class QinCeUtils {
     }
 
     /**
-     * 查询部门参数
+     * 查询[部门]参数
      */
     public Map<String, Object> queryOrgParam() {
         Map<String, Object> params = new HashMap<>();
@@ -60,7 +62,7 @@ public class QinCeUtils {
     }
 
     /**
-     * 查询人员参数
+     * 查询[人员]参数
      */
     public Map<String, Object> queryEmployeeParam(boolean queryId) {
         Map<String, Object> params = new HashMap<>();
@@ -88,13 +90,40 @@ public class QinCeUtils {
         return params;
     }
 
+    /**
+     * 查询[客户管理-终端]参数
+     */
+    public Map<String, Object> queryShopParam() {
+        HashMap<String, Object> params = new HashMap<>();
+        // 分页页码，默认1
+        params.put("page_number","1");
+        // 记录状态。0：已删除，1：正常
+        // 0：已删除:客户回收站中的终端数据
+        params.put("status","");
+        // 勤策的门店唯一ID
+        params.put("id","");
+        // 来源于第三方系统的门店唯一ID，对应新增门店 (store_id)字段，只有当数据来源于新增接口时才有值，如果数据从勤策系统中直接创建则该字段值为空。 如果两个值同时存在则优先顺序为store_waiqin_id、store_id
+        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_type","");
+        // 门店所属销售区域，此字段需要销售区域的完整层级结构， 多层级间以“,”分隔，如：华中大区,南京分区,秦淮社区
+        params.put("store_district","");
+        return params;
+    }
 
     private String getDigest(Map<String, Object> params, Long currentTimeMillis) {
         String json = "";
         if (!CollectionUtils.isEmpty(params)) {
             json = JSONObject.toJSONString(params);
         }
-        System.out.println(json + "|" + APP_KEY + "|" + currentTimeMillis);
         String digest = DigestUtils.md5Hex(json + "|" + APP_KEY + "|" + currentTimeMillis);
         return digest;
     }

src/test/java/com/wangxiaolu/promotion/controller/user/QinCeDataTaskControllerTest.java

@@ -29,4 +29,9 @@ class QinCeDataTaskControllerTest {
     void employeeTask() {
         qinCeDataTaskController.employeeTask();
     }
+
+    @Test
+    void shopDetailAllTask() {
+        qinCeDataTaskController.shopDetailAllTask();
+    }
 }
\ No newline at end of file