Skip to content

W
wangxiaolu-sfa-module-job
提交 038a7a0c authored 作者: 000516's avatar 000516
浏览文件
操作

回写勤策-经销商/门店大区，北京战区改为北京特区

上级 57c3164b 24153abb
隐藏空白字符变更
内嵌 并排
正在显示 包含 8 行增加 和 130 行删除
src/main/java/com/sfa/job/domain/feishu/entity/QinceMarketEmployee.java
浏览文件 @ 038a7a0c
......@@ -13,7 +13,7 @@ import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
/**
* 勤策-区域销售人员架构表，来源：https://wangxiaolu.feishu.cn/sheets/I076slXhlhY2RdtDetEc17ornYd?sheet=49e4ba
* 勤策-区域销售人员架构表，来源：https://wangxiaolu.feishu.cn/sheets/QIYlsvCL9hwmBJtJ7v5ctYVsnDF?sheet=3eadb4
* @TableName qince_market_employee
*/
@AllArgsConstructor
......
src/main/java/com/sfa/job/domain/qince/dao/IQinceDealerDao.java
浏览文件 @ 038a7a0c
package com.sfa.job.domain.qince.dao;
import com.sfa.job.pojo.qince.response.QinceDealerDto;
import java.util.List;
/**
* @author : liqiulin
* @date : 2025-04-24 15
......@@ -11,10 +7,4 @@ import java.util.List;
*/
public interface IQinceDealerDao {
List<QinceDealerDto> getPushQinceDealers();
List<QinceDealerDto> findModifyList(String dateStr);
List<QinceDealerDto> findListByManagerCode(String empNo);
}
src/main/java/com/sfa/job/domain/qince/dao/QinceDealerDaoImpl.java
浏览文件 @ 038a7a0c
package com.sfa.job.domain.qince.dao;
import cn.hutool.core.date.DateUtil;
import com.baomidou.dynamic.datasource.annotation.DS;
import com.sfa.common.core.utils.bean.BeanUtils;
import com.sfa.job.domain.qince.entity.QinceDealer;
import com.sfa.job.domain.qince.mapper.QinceDealerMapper;
import com.sfa.job.pojo.qince.response.QinceDealerDto;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import java.util.List;
/**
* @author : liqiulin
* @date : 2025-04-24 15
......@@ -23,22 +17,4 @@ public class QinceDealerDaoImpl implements IQinceDealerDao{
@Autowired
private QinceDealerMapper qinceDealerMapper;
@Override
public List<QinceDealerDto> getPushQinceDealers() {
String today = DateUtil.today();
List<QinceDealer> qinceDealers = qinceDealerMapper.pushQinceDealers(today);
return BeanUtils.transitionDtos(qinceDealers, QinceDealerDto.class);
}
@Override
public List<QinceDealerDto> findModifyList(String dateStr) {
List<QinceDealer> qinceDealers = qinceDealerMapper.findModifyList(dateStr);
return BeanUtils.transitionDtos(qinceDealers, QinceDealerDto.class);
}
@Override
public List<QinceDealerDto> findListByManagerCode(String empNo) {
List<QinceDealer> qinceDealers = qinceDealerMapper.findListByManagerCode(empNo);
return BeanUtils.transitionDtos(qinceDealers, QinceDealerDto.class);
}
}
src/main/java/com/sfa/job/domain/qince/mapper/QinceDealerMapper.java
浏览文件 @ 038a7a0c
package com.sfa.job.domain.qince.mapper;
import com.sfa.job.domain.qince.entity.QinceDealer;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.sfa.job.pojo.qince.response.QinceDealerDto;
import com.sfa.job.domain.qince.entity.QinceDealer;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author a02200059
* @description 针对表【qince_dealer(勤策-经销商表)】的数据库操作Mapper
......@@ -15,13 +12,6 @@ import java.util.List;
*/
@Repository
public interface QinceDealerMapper extends BaseMapper<QinceDealer> {
List<QinceDealer> pushQinceDealers(String today);
List<QinceDealer> findModifyList(String dateStr);
List<QinceDealer> findListByManagerCode(String empNo);
}
......
src/main/java/com/sfa/job/service/qince/impl/QinceDealerQueryServiceImpl.java
浏览文件 @ 038a7a0c
package com.sfa.job.service.qince.impl;
import cn.hutool.core.date.DatePattern;
import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.sfa.job.domain.feishu.dao.IQinceMarketEmployeeDao;
import com.sfa.job.domain.qince.dao.IQinceClienteleStoreDao;
import com.sfa.job.domain.qince.dao.IQinceDealerDao;
import com.sfa.job.domain.system.dao.ISysDeptDao;
import com.sfa.job.domain.system.dao.ISysUserDao;
import com.sfa.job.pojo.feishu.response.QinceMarketEmployeeDto;
import com.sfa.job.pojo.qince.response.QinceClienteleStoreDto;
import com.sfa.job.pojo.qince.response.QinceDealerDto;
import com.sfa.job.service.qince.IQinceDealerQueryService;
import com.sfa.job.util.QinCeUtils;
import lombok.extern.slf4j.Slf4j;
......@@ -32,9 +29,6 @@ import java.util.stream.Collectors;
@Slf4j
@Service
public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
@Autowired
private IQinceDealerDao qinceDealerDao;
@Autowired
private IQinceClienteleStoreDao qinceClienteleStoreDao;
@Autowired
......@@ -63,12 +57,14 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
/**
* 2. 反写勤策中的自定义字段：大区、战区
* BM0020 北京战区改为北京特区
*/
for (QinceMarketEmployeeDto mDto : mDtos) {
try {
Map<String, Object> ext1 = new HashMap<>();
String dqtq = "BM0020".equals(mDto.getDqDeptCode()) ? "北京特区" : deptMap.get(mDto.getDqDeptCode());
ext1.put("dealer_ext_key", "大区");
ext1.put("dealer_ext_value", deptMap.get(mDto.getDqDeptCode()));
ext1.put("dealer_ext_value",dqtq);
Map<String, Object> ext2 = new HashMap<>();
ext2.put("dealer_ext_key", "战区");
......@@ -85,7 +81,7 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
// 3. 反写当前经销商所负责门店信息：城市经理、战区经理、大区总监
List<QinceClienteleStoreDto> storeDtoList = qinceClienteleStoreDao.findListByDealerId(mDto.getDealerCode());
pushQinceStoreInfo(storeDtoList, deptMap.get(mDto.getDqDeptCode()), deptMap.get(mDto.getZqDeptCode()), mDto, userMap);
pushQinceStoreInfo(storeDtoList, dqtq, deptMap.get(mDto.getZqDeptCode()), mDto, userMap);
log.info("push qc 终端（架构/负责人）success：{}", storeDtoList.size());
} catch (RuntimeException e) {
......@@ -139,7 +135,8 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
continue;
}
List<QinceClienteleStoreDto> stores = storesEntry.getValue();
pushQinceStoreInfo(stores, deptMap.get(mDto.getDqDeptCode()), deptMap.get(mDto.getZqDeptCode()), mDto, userMap);
String dqtq = "BM0020".equals(mDto.getDqDeptCode()) ? "北京特区" : deptMap.get(mDto.getDqDeptCode());
pushQinceStoreInfo(stores, dqtq, deptMap.get(mDto.getZqDeptCode()), mDto, userMap);
log.info("push qc 终端（架构/负责人）success：{}：{}", mDto.getDealerName(),stores.size());
}
}
......@@ -156,7 +153,6 @@ public class QinceDealerQueryServiceImpl implements IQinceDealerQueryService {
exts.add(Maps.of("store_ext_key", "战区", "store_ext_value", zqDeptName));
params.put("store_waiqin_id", storeDto.getQcId());
// params.put("store_name", storeDto.getStoreName());
params.put("exts", exts);
String url = qinCeUtils.builderUrl(QinCeUtils.MODIFY_STORE, params);
......
src/main/resources/mapper/qince/QinceDealerMapper.xml
浏览文件 @ 038a7a0c
......@@ -6,82 +6,8 @@
<resultMap id="BaseResultMap" type="com.sfa.job.domain.qince.entity.QinceDealer">
<id property="id" column="id" jdbcType="INTEGER"/>
<result property="dqOrgQcId" column="dq_org_qc_id" jdbcType="VARCHAR"/>
<result property="dqOrgName" column="dq_org_name" jdbcType="VARCHAR"/>
<result property="zqOrgQcId" column="zq_org_qc_id" jdbcType="VARCHAR"/>
<result property="zqOrgName" column="zq_org_name" jdbcType="VARCHAR"/>
<result property="dealerDeptWaiqin365Id" column="dealer_dept_waiqin365_id" jdbcType="VARCHAR"/>
<result property="dealerDeptName" column="dealer_dept_name" jdbcType="VARCHAR"/>
<result property="dealerId" column="dealer_id" jdbcType="VARCHAR"/>
<result property="dealerName" column="dealer_name" jdbcType="VARCHAR"/>
<result property="dealerType" column="dealer_type" jdbcType="VARCHAR"/>
<result property="dealerStatus" column="dealer_status" jdbcType="CHAR"/>
<result property="dealerCooperateStatus" column="dealer_cooperate_status" jdbcType="CHAR"/>
<result property="createTime" column="create_time" jdbcType="TIMESTAMP"/>
<result property="ct" column="ct" jdbcType="TIMESTAMP"/>
<result property="mt" column="mt" jdbcType="TIMESTAMP"/>
</resultMap>
<resultMap id="PushQince" type="com.sfa.job.domain.qince.entity.QinceDealer">
<id property="id" column="id" jdbcType="INTEGER"/>
<result property="dqOrgQcId" column="dq_org_qc_id" jdbcType="VARCHAR"/>
<result property="dqOrgName" column="dq_org_name" jdbcType="VARCHAR"/>
<result property="zqOrgQcId" column="zq_org_qc_id" jdbcType="VARCHAR"/>
<result property="zqOrgName" column="zq_org_name" jdbcType="VARCHAR"/>
<result property="dealerId" column="dealer_id" jdbcType="VARCHAR"/>
<result property="dealerName" column="dealer_name" jdbcType="VARCHAR"/>
</resultMap>
<resultMap id="PushQince_2" type="com.sfa.job.domain.qince.entity.QinceDealer">
<result property="dqOrgName" column="dq_org_name" jdbcType="VARCHAR"/>
<result property="zqOrgName" column="zq_org_name" jdbcType="VARCHAR"/>
<result property="dealerId" column="dealer_id" jdbcType="VARCHAR"/>
<result property="dealerName" column="dealer_name" jdbcType="VARCHAR"/>
</resultMap>
<sql id="Base_Column_List">
id,dq_org_qc_id,dq_org_name,
zq_org_qc_id,zq_org_name,dealer_dept_waiqin365_id,
dealer_dept_name,dealer_id,dealer_name,
dealer_type,dealer_status,dealer_cooperate_status,
create_time,ct,mt
</sql>
<select id="pushQinceDealers" resultMap="PushQince">
select id,
dq_org_qc_id,
dq_org_name,
zq_org_qc_id,
zq_org_name,
dealer_id,
dealer_name
from qince_dealer
where dealer_cooperate_status = 1
and dealer_status = 1
and dealer_type = '经销商'
and dq_org_qc_id is not null
and zq_org_qc_id is not null
and DATE (mt) = #{today}
</select>
<!--
and DATE(mt) = #{dateStr};-->
<select id="findModifyList" resultMap="PushQince_2">
select dealer_id, dealer_name, dealer_manager, dealer_manager_code
from qince_dealer
where dealer_type = '经销商'
and dealer_cooperate_status = '1'
and dealer_status = '1'
and dealer_id = '000324'
</select>
<select id="findListByManagerCode" resultMap="PushQince">
select dq_org_name, zq_org_name, dealer_id, dealer_name
from qince_dealer
where dealer_type = '经销商'
and dealer_cooperate_status = '1'
and dealer_status = '1'
and dealer_manager_code = #{empNo}
</select>
</mapper>
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论