From bf2fbd9f3e90dd2ef508c5944ae63491397b42ae Mon Sep 17 00:00:00 2001
From: LSH
Date: 星期六, 04 十一月 2023 10:35:26 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/crm/manager/task/handler/CstmrCopyHandler.java | 64 ++++++++++++++++
src/main/java/com/zy/crm/manager/entity/Cstmr.java | 19 ++++
src/main/java/com/zy/crm/manager/task/AbstractHandler.java | 30 +++++++
src/main/java/com/zy/crm/manager/task/core/ReturnT.java | 65 ++++++++++++++++
src/main/java/com/zy/crm/manager/task/CstmrCopyScheduler.java | 28 +++++++
src/main/java/com/zy/crm/manager/task/core/AsrsException.java | 16 ++++
6 files changed, 222 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/crm/manager/entity/Cstmr.java b/src/main/java/com/zy/crm/manager/entity/Cstmr.java
index 1964642..750f58b 100644
--- a/src/main/java/com/zy/crm/manager/entity/Cstmr.java
+++ b/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;
diff --git a/src/main/java/com/zy/crm/manager/task/AbstractHandler.java b/src/main/java/com/zy/crm/manager/task/AbstractHandler.java
new file mode 100644
index 0000000..8b8e864
--- /dev/null
+++ b/src/main/java/com/zy/crm/manager/task/AbstractHandler.java
@@ -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));
+ }
+
+}
diff --git a/src/main/java/com/zy/crm/manager/task/CstmrCopyScheduler.java b/src/main/java/com/zy/crm/manager/task/CstmrCopyScheduler.java
new file mode 100644
index 0000000..f54c586
--- /dev/null
+++ b/src/main/java/com/zy/crm/manager/task/CstmrCopyScheduler.java
@@ -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();
+ }
+
+}
diff --git a/src/main/java/com/zy/crm/manager/task/core/AsrsException.java b/src/main/java/com/zy/crm/manager/task/core/AsrsException.java
new file mode 100644
index 0000000..8619072
--- /dev/null
+++ b/src/main/java/com/zy/crm/manager/task/core/AsrsException.java
@@ -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);
+ }
+
+}
diff --git a/src/main/java/com/zy/crm/manager/task/core/ReturnT.java b/src/main/java/com/zy/crm/manager/task/core/ReturnT.java
new file mode 100644
index 0000000..349ba0e
--- /dev/null
+++ b/src/main/java/com/zy/crm/manager/task/core/ReturnT.java
@@ -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 + "]";
+ }
+
+}
diff --git a/src/main/java/com/zy/crm/manager/task/handler/CstmrCopyHandler.java b/src/main/java/com/zy/crm/manager/task/handler/CstmrCopyHandler.java
new file mode 100644
index 0000000..73ad12f
--- /dev/null
+++ b/src/main/java/com/zy/crm/manager/task/handler/CstmrCopyHandler.java
@@ -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;
+ }
+
+}
--
Gitblit v1.9.1