#

LSH

2023-11-04 bf2fbd9f3e90dd2ef508c5944ae63491397b42ae

#

 src/main/java/com/zy/crm/manager/entity/Cstmr.java

@@ -254,6 +254,25 @@

    public Cstmr() {}

    public Cstmr(Cstmr cstmr) {
        this.hostId = cstmr.getHostId();
        this.deptId = cstmr.getDeptId();
        this.userId = cstmr.getUserId();
        this.cstmrType = cstmr.getCstmrType();
        this.director = cstmr.getDirector();
        this.province = cstmr.getProvince();
        this.city = cstmr.getCity();
        this.district = cstmr.getDistrict();
        this.town = cstmr.getTown();
        this.addr = cstmr.getAddr();
        this.type = cstmr.getType();
        this.status = cstmr.getStatus();
        this.createBy = cstmr.getCreateBy();
        this.createTime = cstmr.getCreateTime();
        this.updateBy = cstmr.getUpdateBy();
        this.updateTime = cstmr.getUpdateTime();
    }

    public Cstmr(Long hostId,Long deptId,Long userId,Long cstmrType,String uuid,String name,String simple,String rela,String tel,String contacts,String remarks,Long director,String province,String city,String district,String town,String addr,Integer type,String files,Integer status,Long createBy,Date createTime,Long updateBy,Date updateTime,String memo) {
        this.hostId = hostId;
        this.deptId = deptId;

 src/main/java/com/zy/crm/manager/task/AbstractHandler.java

New file
@@ -0,0 +1,30 @@
package com.zy.crm.manager.task;

import com.core.exception.CoolException;
import com.zy.crm.manager.task.core.ReturnT;
import lombok.extern.slf4j.Slf4j;

import java.text.MessageFormat;

/**
 * Created by vincent on 2020/7/4
 */
@Slf4j
public abstract class AbstractHandler<T> {

    public final ReturnT<T> SUCCESS = new ReturnT<>(200, null);
    public final ReturnT<T> FAIL = new ReturnT<>(500, null);

//    protected abstract ReturnT<T> start();

    protected void exceptionHandle(String errorMsg){
        log.error(errorMsg);
        exceptionHandle(errorMsg, (Object) null);
    }

    protected void exceptionHandle(String errorMsg, Object... args){
        log.error(errorMsg);
        throw new CoolException(MessageFormat.format(errorMsg, args));
    }

}

 src/main/java/com/zy/crm/manager/task/CstmrCopyScheduler.java

New file
@@ -0,0 +1,28 @@
package com.zy.crm.manager.task;

import com.zy.crm.manager.service.CstmrService;
import com.zy.crm.manager.task.core.ReturnT;
import com.zy.crm.manager.task.handler.CstmrCopyHandler;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

/**
 * Created by vincent on 2023/11/04
 */
@Slf4j
@Component
public class CstmrCopyScheduler {

    @Autowired
    private CstmrService cstmrService;
    @Autowired
    private CstmrCopyHandler cstmrCopyHandler;

//    @Scheduled(cron = "0/3 * * * * ? ")
    private void execute() {
        ReturnT<String> result = cstmrCopyHandler.start();
    }

}

 src/main/java/com/zy/crm/manager/task/core/AsrsException.java

New file
@@ -0,0 +1,16 @@
package com.zy.crm.manager.task.core;

/**
 * Created by vincent on 2020/7/7
 */
public class AsrsException extends RuntimeException {

    public AsrsException(Throwable e) {
        super(e);
    }

    public AsrsException(String message) {
        super(message);
    }

}

 src/main/java/com/zy/crm/manager/task/core/ReturnT.java

New file
@@ -0,0 +1,65 @@
package com.zy.crm.manager.task.core;

import java.io.Serializable;

/**
 * Created by vincent on 2020/7/7
 */
public class ReturnT<T> implements Serializable {

    public static final long serialVersionUID = 42L;
    public static final int SUCCESS_CODE = 200;
    public static final int FAIL_CODE = 500;
    private int code;
    private String msg;
    private T content;

    public ReturnT() {
    }

    public ReturnT(int code, String msg) {
        this.code = code;
        this.msg = msg;
    }

    public ReturnT(T content) {
        this.code = 200;
        this.content = content;
    }

    public boolean isSuccess(){
        return this.code == 200;
    }

    public int getCode() {
        return this.code;
    }

    public ReturnT<T> setCode(int code) {
        this.code = code;
        return this;
    }

    public String getMsg() {
        return this.msg;
    }

    public ReturnT<T> setMsg(String msg) {
        this.msg = msg;
        return this;
    }

    public T getContent() {
        return this.content;
    }

    public ReturnT<T> setContent(T content) {
        this.content = content;
        return this;
    }

    public String toString() {
        return "ReturnT [code=" + this.code + ", msg=" + this.msg + ", content=" + this.content + "]";
    }

}

 src/main/java/com/zy/crm/manager/task/handler/CstmrCopyHandler.java

New file
@@ -0,0 +1,64 @@
package com.zy.crm.manager.task.handler;

import com.core.common.Cools;
import com.core.common.R;
import com.core.exception.CoolException;
import com.zy.crm.manager.controller.CstmrController;
import com.zy.crm.manager.entity.Cstmr;
import com.zy.crm.manager.mapper.CstmrMapper;
import com.zy.crm.manager.service.CstmrService;
import com.zy.crm.manager.task.AbstractHandler;
import com.zy.crm.manager.task.core.ReturnT;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;

/**
 * Created by vincent on 2020/7/6
 */
@Slf4j
@Service
public class CstmrCopyHandler extends AbstractHandler<String> {
    @Autowired
    private CstmrService cstmrService;
    @Autowired
    private CstmrController cstmrController;
    @Autowired
    private CstmrMapper cstmrMapper;


    @Transactional
    public ReturnT<String> start() {
        try {
            Long hostId = 1L;
//            List<Cstmr> cstmrs = cstmrMapper.selectCopyList();
            List<Cstmr> cstmrs = new ArrayList<>();
            for (Cstmr cstmr33 : cstmrs){
                Cstmr cstmr13 = cstmrService.selectByName(hostId,cstmr33.getName());
                if (Cools.isEmpty(cstmr13)){
                    Cstmr cstmr23 = cstmrService.selectById(186);
                    Cstmr cstmr = new Cstmr(cstmr23);
                    cstmr.setName(cstmr33.getName());
                    cstmr.setUuid(cstmrService.getUuid(hostId));
                    cstmrService.insert(cstmr);
                }
            }


        } catch (Exception e) {
            log.error("fail", e);
            e.printStackTrace();
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            return FAIL.setMsg(e.getMessage());
        }
        return SUCCESS;
    }

}