zhenghuang
/
bsdgy-server
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

删除客户导购关系

Browse Source
dev_0531
yechenhao 5 years ago
parent 2e1bb516f1
commit 255a45a04f
2 changed files with 64 additions and 69 deletions
Show Stats Download Patch File Download Diff File

7
src/main/java/com/kiisoo/ic/customer/CustomerService.java
Unescape Escape View File

@ -230,16 +230,11 @@ public class CustomerService {
private void handleAddCustomer(TurnBackDTO turnBackDTOS) throws Exception { private void handleAddCustomer(TurnBackDTO turnBackDTOS) throws Exception {
log.info(new Gson().toJson(turnBackDTOS)); log.info(new Gson().toJson(turnBackDTOS));
OpCustomer opCustomer = null; OpCustomer opCustomer = null;
if (StringUtils.isBlank(turnBackDTOS.getWxData().getUnionId()) && StringUtils.isNotBlank(turnBackDTOS.getWxData().getUserId())) { if (StringUtils.isNotBlank(turnBackDTOS.getWxData().getUserId())) {
//此时说明是企业微信扫码添加 //此时说明是企业微信扫码添加
QueryWrapper<OpCustomer> customerWrapper = new QueryWrapper<>(); QueryWrapper<OpCustomer> customerWrapper = new QueryWrapper<>();
customerWrapper.eq("external_userid", turnBackDTOS.getWxData().getUserId()).last("limit 1"); customerWrapper.eq("external_userid", turnBackDTOS.getWxData().getUserId()).last("limit 1");
opCustomer = opCustomerDOMapper.selectOne(customerWrapper); opCustomer = opCustomerDOMapper.selectOne(customerWrapper);
} else if (StringUtils.isNotBlank(turnBackDTOS.getWxData().getUnionId()) && StringUtils.isNotBlank(turnBackDTOS.getWxData().getUserId())) {
//客户信息
QueryWrapper<OpCustomer> customerWrapper = new QueryWrapper<>();
customerWrapper.eq("wechat_uni_id", turnBackDTOS.getWxData().getUnionId()).last("limit 1");
opCustomer = opCustomerDOMapper.selectOne(customerWrapper);
} else { } else {
log.error("turn back error: " + turnBackDTOS.toString()); log.error("turn back error: " + turnBackDTOS.toString());
return; return;

126
src/main/java/com/kiisoo/ic/job/count/SyncCountJobService.java
Unescape Escape View File

@ -1,63 +1,63 @@
package com.kiisoo.ic.job.count; //package com.kiisoo.ic.job.count;
//
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; //import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.kiisoo.ic.system.entity.SysTaskDO; //import com.kiisoo.ic.system.entity.SysTaskDO;
import com.kiisoo.ic.system.mapper.SysTaskDOMapper; //import com.kiisoo.ic.system.mapper.SysTaskDOMapper;
import lombok.extern.slf4j.Slf4j; //import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired; //import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled; //import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component; //import org.springframework.stereotype.Component;
//
import java.text.SimpleDateFormat; //import java.text.SimpleDateFormat;
import java.util.Date; //import java.util.Date;
import java.util.Random; //import java.util.Random;
//
import static com.kiisoo.ic.system.constant.SysTaskConstant.*; //import static com.kiisoo.ic.system.constant.SysTaskConstant.*;
//
@Component //@Component
@Slf4j //@Slf4j
public class SyncCountJobService { //public class SyncCountJobService {
@Autowired // @Autowired
private CustomerCountJob customerDataJob; // private CustomerCountJob customerDataJob;
//
@Autowired // @Autowired
private SysTaskDOMapper sysTaskDOMapper; // private SysTaskDOMapper sysTaskDOMapper;
//
// @Scheduled(cron = "0 0/15 9/1 * * ??") //// @Scheduled(cron = "0 0/15 9/1 * * ??")
public void syncStoreCount(){ // public void syncStoreCount(){
try { // try {
int random = new Random().nextInt(100); // int random = new Random().nextInt(100);
Thread.sleep(random*100); // Thread.sleep(random*100);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:00"); // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:00");
QueryWrapper<SysTaskDO> qw = new QueryWrapper<>(); // QueryWrapper<SysTaskDO> qw = new QueryWrapper<>();
qw.eq("type",TASK_TYPE_STORE_COUNT).eq("create_time",sdf.format(new Date())).last("limit 1"); // qw.eq("type",TASK_TYPE_STORE_COUNT).eq("create_time",sdf.format(new Date())).last("limit 1");
SysTaskDO sysTaskDO = sysTaskDOMapper.selectOne(qw); // SysTaskDO sysTaskDO = sysTaskDOMapper.selectOne(qw);
if (sysTaskDO == null){ // if (sysTaskDO == null){
sysTaskDO = new SysTaskDO(TASK_NAME_STORE_COUNT,TASK_STATUS_RUNNING,TASK_TYPE_STORE_COUNT,new Date()); // sysTaskDO = new SysTaskDO(TASK_NAME_STORE_COUNT,TASK_STATUS_RUNNING,TASK_TYPE_STORE_COUNT,new Date());
sysTaskDOMapper.insert(sysTaskDO); // sysTaskDOMapper.insert(sysTaskDO);
customerDataJob.handle(false,sysTaskDO); // customerDataJob.handle(false,sysTaskDO);
} // }
}catch (Exception e){ // }catch (Exception e){
log.error("",e); // log.error("",e);
} // }
} // }
//
// @Scheduled(cron = "0 0 2 * * ?") //// @Scheduled(cron = "0 0 2 * * ?")
public void syncAllCount(){ // public void syncAllCount(){
try { // try {
int random = new Random().nextInt(100); // int random = new Random().nextInt(100);
Thread.sleep(random*100); // Thread.sleep(random*100);
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:00:00"); // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:00:00");
QueryWrapper<SysTaskDO> qw = new QueryWrapper<>(); // QueryWrapper<SysTaskDO> qw = new QueryWrapper<>();
qw.eq("type",TASK_TYPE_ALL_COUNT).eq("create_time",sdf.format(new Date())).last("limit 1"); // qw.eq("type",TASK_TYPE_ALL_COUNT).eq("create_time",sdf.format(new Date())).last("limit 1");
SysTaskDO sysTaskDO = sysTaskDOMapper.selectOne(qw); // SysTaskDO sysTaskDO = sysTaskDOMapper.selectOne(qw);
if (sysTaskDO == null){ // if (sysTaskDO == null){
sysTaskDO = new SysTaskDO(TASK_NAME_ALL_COUNT,TASK_STATUS_RUNNING,TASK_TYPE_ALL_COUNT,new Date()); // sysTaskDO = new SysTaskDO(TASK_NAME_ALL_COUNT,TASK_STATUS_RUNNING,TASK_TYPE_ALL_COUNT,new Date());
sysTaskDOMapper.insert(sysTaskDO); // sysTaskDOMapper.insert(sysTaskDO);
customerDataJob.handle(true,sysTaskDO); // customerDataJob.handle(true,sysTaskDO);
} // }
}catch (Exception e){ // }catch (Exception e){
log.error("",e); // log.error("",e);
} // }
} // }
} //}

Write Preview
Loading…
Cancel
Save