From 8a281053bd4230f26c7cdf9e14248c1c4ab72568 Mon Sep 17 00:00:00 2001 From: yechenhao Date: Thu, 21 May 2020 02:24:19 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A4=A7=E5=B1=8F=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/PoiCustomerContactDataStat.java | 5 +++ .../kiisoo/ic/job/detail/CustomerDataJob.java | 16 ++++++++++ .../StorePromotionDataController.java | 17 ++++++++++ .../service/StorePromotionDataService.java | 31 +++++++++++++++++++ 4 files changed, 69 insertions(+) diff --git a/src/main/java/com/kiisoo/ic/generalize/entity/PoiCustomerContactDataStat.java b/src/main/java/com/kiisoo/ic/generalize/entity/PoiCustomerContactDataStat.java index bf874d5..9c53227 100644 --- a/src/main/java/com/kiisoo/ic/generalize/entity/PoiCustomerContactDataStat.java +++ b/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; /** * 序号 */ diff --git a/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java b/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java index 332e4c8..e1ffe19 100644 --- a/src/main/java/com/kiisoo/ic/job/detail/CustomerDataJob.java +++ b/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 cpUserIdList = Arrays.asList(split); for (String cpUserId : cpUserIdList) { + QueryWrapper cpUserDOQueryWrapper = new QueryWrapper<>(); + cpUserDOQueryWrapper.eq("cp_user_id",cpUserId).last("limit 1"); + PrivilageCpUserDO privilageCpUserDO = privilageCpUserDOMapper.selectOne(cpUserDOQueryWrapper); + if (privilageCpUserDO == null){ + continue; + } + //删除原有的数据 + QueryWrapper 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++; diff --git a/src/main/java/com/kiisoo/ic/store/controller/StorePromotionDataController.java b/src/main/java/com/kiisoo/ic/store/controller/StorePromotionDataController.java index 1597d2c..ab6a1da 100644 --- a/src/main/java/com/kiisoo/ic/store/controller/StorePromotionDataController.java +++ b/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 listUserBehaviorData(@RequestParam("cpUserIds") String cpUserIds){ + try { + storePromotionDataService.translateDate(cpUserIds); + return data(null); + }catch (Exception e){ + log.error("查询门店推广数据列表",e); + return fail(); + } + } + /** * 查询门店推广数据列表 手机端 * @param userId diff --git a/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java b/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java index 46734af..77fe5e8 100644 --- a/src/main/java/com/kiisoo/ic/store/service/StorePromotionDataService.java +++ b/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 cpUserIdList = Arrays.asList(split); + for (String cpUserId : cpUserIdList) { + QueryWrapper 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 poiCustomerContactDataStatQueryWrapper = new QueryWrapper<>(); + poiCustomerContactDataStatQueryWrapper.isNull("store_id").eq("region_id",privilageCpUserDO.getId()); + List 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 shopIds = new HashSet<>();