勤策-同步终端store数据异常做跳过处理

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

@@ -33,6 +33,7 @@ public class QinCeClienteleStoreDaoImpl implements QinCeClienteleStoreDao {
 
     /**
      * 拉取信息
+     *
      * @param responseDatas 信息json格式数据
      */
     @Override
@@ -42,6 +43,7 @@ public class QinCeClienteleStoreDaoImpl implements QinCeClienteleStoreDao {
         for (Object responseData : responseDatas) {
             qw.clear();
 
+            try {
                 QinCeClienteleStoreDO qinCeShopDO = JSONObject.parseObject(responseData.toString(), QinCeClienteleStoreDO.class);
                 qw.eq(QinCeClienteleStoreDO::getQcId, qinCeShopDO.getQcId());
                 QinCeClienteleStoreDO doExist = qinCeClienteleStoreMapper.selectOne(qw);
@@ -52,12 +54,19 @@ public class QinCeClienteleStoreDaoImpl implements QinCeClienteleStoreDao {
                     qinCeShopDO.setId(doExist.getId());
                     qinCeClienteleStoreMapper.updateById(qinCeShopDO);
                 }
+            } catch (Exception e) {
+                log.error("勤策-同步终端store数据异常，异常数据：{}", responseData);
+                log.error("勤策-同步终端store数据异常\n{}", e.getMessage());
             }
 
         }
 
+
+    }
+
     /**
      * 查询门店列表
+     *
      * @param storeWrapper 查询条件
      */
     @Override
@@ -85,35 +94,35 @@ public class QinCeClienteleStoreDaoImpl implements QinCeClienteleStoreDao {
         return transitionDto(qinCeClienteleStoreDO);
     }
 
-    private LambdaQueryWrapper<QinCeClienteleStoreDO> builderQueryWrapper(StoreWrapper storeWrapper){
+    private LambdaQueryWrapper<QinCeClienteleStoreDO> builderQueryWrapper(StoreWrapper storeWrapper) {
         LambdaQueryWrapper<QinCeClienteleStoreDO> qw = new LambdaQueryWrapper<>();
         // 默认查询有效数据 >>> 门店删除状态。0：删除，1：正常：store_status = 1
-        qw.eq(QinCeClienteleStoreDO::getStoreStatus,storeWrapper.getStoreStatus());
+        qw.eq(QinCeClienteleStoreDO::getStoreStatus, storeWrapper.getStoreStatus());
         // 默认查询有效数据 >>> 门店审批状态。1：待审批，2：审批打回，3：审批通过：store_approval_status = 3
-        qw.eq(QinCeClienteleStoreDO::getStoreApprovalStatus,storeWrapper.getStoreApprovalStatus());
+        qw.eq(QinCeClienteleStoreDO::getStoreApprovalStatus, storeWrapper.getStoreApprovalStatus());
 
         // 按qcId查询
-        if (StringUtils.isNotBlank(storeWrapper.getQcId())){
-            qw.eq(QinCeClienteleStoreDO::getQcId,storeWrapper.getQcId());
+        if (StringUtils.isNotBlank(storeWrapper.getQcId())) {
+            qw.eq(QinCeClienteleStoreDO::getQcId, storeWrapper.getQcId());
             return qw;
         }
         // 按门店名称模糊查询
-        if (StringUtils.isNotBlank(storeWrapper.getStoreNameVague())){
-            qw.like(QinCeClienteleStoreDO::getStoreName,storeWrapper.getStoreNameVague());
+        if (StringUtils.isNotBlank(storeWrapper.getStoreNameVague())) {
+            qw.like(QinCeClienteleStoreDO::getStoreName, storeWrapper.getStoreNameVague());
         }
         return qw;
     }
 
 
-
     /**
      * DO to DTO (单个对象)
+     *
      * @param storeDO DO对象
      * @return DTO对象
      */
-    private QinCeClienteleStoreDto transitionDto(QinCeClienteleStoreDO storeDO){
+    private QinCeClienteleStoreDto transitionDto(QinCeClienteleStoreDO storeDO) {
         QinCeClienteleStoreDto storedDto = null;
-        if (!Objects.isNull(storeDO)){
+        if (!Objects.isNull(storeDO)) {
             storedDto = new QinCeClienteleStoreDto();
             BeanUtils.copyProperties(storeDO, storedDto);
         }
@@ -135,7 +144,4 @@ public class QinCeClienteleStoreDaoImpl implements QinCeClienteleStoreDao {
     }
 
 
-
-
-
 }