大屏接口

src/main/java/com/kiisoo/ic/generalize/entity/PoiCustomerContactDataStat.java

@@ -26,6 +26,11 @@ public class PoiCustomerContactDataStat {
 	 * 门店id
 	 */
 	private Long storeId;
+
+	/**
+	 * id
+	 */
+	private Long regionId;
 	/**
 	 * 序号
 	 */

src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java

@@ -1,6 +1,9 @@
 package com.kiisoo.ic.job.detail;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.kiisoo.ic.customer.CustomerService;
+import com.kiisoo.ic.customer.entity.OpSellerCustomerRelation;
+import com.kiisoo.ic.customer.mapper.OpSellerCustomerRelationDOMapper;
 import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
 import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
 import com.kiisoo.ic.store.mapper.PoiStoreStaffDOMapper;
@@ -38,6 +41,9 @@ public class CustomerDataJob {
     @Autowired
     private PrivilageCpUserStoreDOMapper privilageCpUserStoreDOMapper;
 
+    @Autowired
+    private OpSellerCustomerRelationDOMapper opSellerCustomerRelationDOMapper;
+
     @Autowired
     private QWMailListManageService qwMailListManageService;
 
@@ -80,6 +86,16 @@ public class CustomerDataJob {
             String[] split = cpUserIds.split(",");
             List<String> cpUserIdList = Arrays.asList(split);
             for (String cpUserId : cpUserIdList) {
+                QueryWrapper<PrivilageCpUserDO> cpUserDOQueryWrapper = new QueryWrapper<>();
+                cpUserDOQueryWrapper.eq("cp_user_id",cpUserId).last("limit 1");
+                PrivilageCpUserDO privilageCpUserDO = privilageCpUserDOMapper.selectOne(cpUserDOQueryWrapper);
+                if (privilageCpUserDO == null){
+                    continue;
+                }
+                //删除原有的数据
+                QueryWrapper<OpSellerCustomerRelation> relationQueryWrapper = new QueryWrapper<>();
+                relationQueryWrapper.eq("type",3).eq("user_id",privilageCpUserDO.getId());
+                opSellerCustomerRelationDOMapper.delete(relationQueryWrapper);
                 Long storeId = privilageCpUserStoreDOMapper.selectOneByCpUserId(cpUserId);
                 producer.produceData(index,storeId,cpUserId);
                 index++;

src/main/java/com/kiisoo/ic/store/controller/StorePromotionDataController.java

@@ -128,6 +128,23 @@ public class StorePromotionDataController extends BaseController {
         }
     }
 
+    /**
+     * 将绑定在账号上的推广数据绑定到店铺上
+     * @param cpUserIds 企业微信账号  ',' 分割
+     * @return
+     */
+    @RequestMapping(value = "/behavior/translate",method = RequestMethod.POST)
+    @ResponseBody
+    public Map<String,Object> listUserBehaviorData(@RequestParam("cpUserIds") String cpUserIds){
+        try {
+            storePromotionDataService.translateDate(cpUserIds);
+            return data(null);
+        }catch (Exception e){
+            log.error("查询门店推广数据列表",e);
+            return fail();
+        }
+    }
+
     /**
      * 查询门店推广数据列表 手机端
      * @param userId

src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java

@@ -1,15 +1,18 @@
 package com.kiisoo.ic.store.service;
 
 import com.alibaba.fastjson.JSONObject;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import com.kiisoo.ic.common.utils.MD5FileUtil;
 import com.kiisoo.ic.common.utils.httpClientUtil.HttpClientUtil;
 import com.kiisoo.ic.common.utils.httpClientUtil.HttpResult;
 import com.kiisoo.ic.config.WxCpConfiguration;
+import com.kiisoo.ic.customer.entity.OpSellerCustomerRelation;
 import com.kiisoo.ic.customer.service.CustomerViewService;
 import com.kiisoo.ic.domain.mapper.PrivilageDomainEntityDOMapper;
 import com.kiisoo.ic.domain.service.PrivilageDomainService;
+import com.kiisoo.ic.employee.entity.PrivilageCpUserDO;
 import com.kiisoo.ic.employee.mapper.PrivilageCpUserDOMapper;
 import com.kiisoo.ic.generalize.entity.PoiCustomerContactDataStat;
 import com.kiisoo.ic.generalize.entity.PrivilageOrganizational;
@@ -333,6 +336,34 @@ public class StorePromotionDataService {
         return new PageInfo<>(results);
     }
 
+    public void translateDate(String cpUserIds){
+        String[] split = cpUserIds.split(",");
+        List<String> cpUserIdList = Arrays.asList(split);
+        for (String cpUserId : cpUserIdList) {
+            QueryWrapper<PrivilageCpUserDO> cpUserDOQueryWrapper = new QueryWrapper<>();
+            cpUserDOQueryWrapper.eq("cp_user_id",cpUserId).last("limit 1");
+            PrivilageCpUserDO privilageCpUserDO = privilageCpUserDOMapper.selectOne(cpUserDOQueryWrapper);
+            if (privilageCpUserDO == null){
+                continue;
+            }
+            Long storeId = privilageCpUserStoreDOMapper.selectOneByCpUserId(cpUserId);
+            if (storeId == null){
+                continue;
+            }
+            //删除原有的数据
+            QueryWrapper<PoiCustomerContactDataStat> poiCustomerContactDataStatQueryWrapper = new QueryWrapper<>();
+            poiCustomerContactDataStatQueryWrapper.isNull("store_id").eq("region_id",privilageCpUserDO.getId());
+            List<PoiCustomerContactDataStat> poiCustomerContactDataStats = poiCustomerContactDataStatMapper.selectList(poiCustomerContactDataStatQueryWrapper);
+            if (CollectionUtils.isNotEmpty(poiCustomerContactDataStats)){
+                poiCustomerContactDataStats.forEach(poiCustomerContactDataStat -> {
+                    poiCustomerContactDataStat.setRegionId(null);
+                    poiCustomerContactDataStat.setStoreId(storeId);
+                    poiCustomerContactDataStatMapper.updateById(poiCustomerContactDataStat);
+                });
+            }
+        }
+    }
+
     public void downloadUserBehaviorDataExcel(Long userId, Long companyId, Long shopId, Date startDate, Date endDate, HttpServletResponse response) throws IOException {
         Set<Long> shopIds = new HashSet<>();