eCoWorksV3.git - Gitblit

xinyb

2024-08-30 f5cc47742dd3d2f2ffd8443ffc82a912683f7824

提交 \| 用户 \| age
385e2d	1	package com.yc.crm.mail.action;
X	2
	3	import com.yc.crm.mail.entity.T482106Entity;
	4	import com.yc.crm.mail.service.MailBlackListIfc;
	5	import com.yc.crm.mail.util.AllBackMsg;
	6	import com.yc.entity.DataSourceEntity;
	7	import com.yc.multiData.MultiDataSource;
	8	import com.yc.multiData.SpObserver;
	9	import com.yc.utils.SessionKey;
	10	import org.apache.commons.lang3.StringUtils;
	11	import org.springframework.beans.factory.annotation.Autowired;
	12	import org.springframework.web.bind.annotation.*;
	13
	14	import javax.servlet.http.HttpServletRequest;
	15	import javax.servlet.http.HttpServletResponse;
	16	import javax.servlet.http.HttpSession;
	17	import java.util.List;
	18
	19	/**
	20	* @BelongsProject: eCoWorksV3
	21	* @BelongsPackage: com.yc.crm.mail.action
	22	* @author: xinyb
	23	* @CreateTime: 2024-08-19 15:33
	24	* @Description: 邮件黑名单
	25	*/
	26	@CrossOrigin
	27	@RestController
	28	@RequestMapping("/crm/mail/blacklist")
	29	public class MailBlacklist {
	30
	31	@Autowired
	32	MailBlackListIfc mailBlackListIfc;
	33
	34	/**
	35	* 添加黑名单
	36	*
	37	* @param BlackList
	38	* @param request
	39	* @param response
	40	* @return
	41	*/
	42	@PostMapping("/addBlackList.do")
	43	public AllBackMsg addBlackList(@RequestBody T482106Entity BlackList, HttpServletRequest request, HttpServletResponse response) {
	44	AllBackMsg msg = new AllBackMsg();
	45	try {
	46
	47	HttpSession session = request.getSession();
	48	String companyId = (String) session.getAttribute(SessionKey.COMPANY_ID);
	49	String companyName = (String) session.getAttribute(SessionKey.COMPANY_NAME);
	50	String userCode = (String) session.getAttribute(SessionKey.USERCODE);
	51	String userName = (String) session.getAttribute(SessionKey.USER_NAME);
	52	BlackList.setCompanyId(companyId);
	53	BlackList.setCompanyName(companyName);
	54	BlackList.setUserCode(userCode);
	55	BlackList.setUserName(userName);
	56	DataSourceEntity dataSource = MultiDataSource.getDataSourceMap(request);//获取数据源
	57	SpObserver.setDBtoInstance("_" + dataSource.getDbId());
	58	mailBlackListIfc.saveBlackList(BlackList);
	59	msg.setSuccess("执行成功", "已保存");
	60	} catch (Exception e) {
	61	msg.setError("执行出错", e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
	62	} finally {
	63	SpObserver.setDBtoInstance();
	64	}
	65	return msg;
	66	}
	67
	68	/**
	69	* 修改黑名单
	70	*
	71	* @param BlackList
	72	* @param request
	73	* @param response
	74	* @return
	75	*/
	76	@PostMapping("/updateBlackList.do")
3c2c1b	77	public AllBackMsg updateBlackList(@RequestBody T482106Entity BlackList, HttpServletRequest request, HttpServletResponse response) {
385e2d	78	AllBackMsg msg = new AllBackMsg();
X	79	try {
f5cc47	80	if(BlackList.getBlackId()==0){
X	81	msg.setFail("获取不到黑名单ID，请检查");
	82	return msg;
	83	}
385e2d	84	HttpSession session = request.getSession();
f5cc47	85	String userCode = (String) session.getAttribute(SessionKey.USERCODE);
X	86	if(StringUtils.isBlank(userCode)){
	87	msg.setFail("登录用户已过期，请检查");
	88	return msg;
	89	}
	90	BlackList.setUserCode(userCode);
385e2d	91	DataSourceEntity dataSource = MultiDataSource.getDataSourceMap(request);//获取数据源
X	92	SpObserver.setDBtoInstance("_" + dataSource.getDbId());
	93	mailBlackListIfc.updateBlackList(BlackList);
f5cc47	94	msg.setOk("已更新");
385e2d	95	} catch (Exception e) {
f5cc47	96	msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
385e2d	97	} finally {
X	98	SpObserver.setDBtoInstance();
	99	}
	100	return msg;
	101	}
	102
	103	/**
	104	* 删除黑名单
	105	*
	106	* @param blackId
	107	* @param request
	108	* @param response
	109	* @return
	110	*/
f5cc47	111	@PostMapping("/deleteBlackList.do")
3c2c1b	112	public AllBackMsg deleteBlackList(@RequestParam(defaultValue = "0") Integer blackId, HttpServletRequest request, HttpServletResponse response) {
385e2d	113	AllBackMsg msg = new AllBackMsg();
X	114	try {
	115	if (blackId == 0) {
	116	msg.setFail("黑名单ID获取不到");
	117	return msg;
	118	}
	119	HttpSession session = request.getSession();
	120	String userCode = (String) session.getAttribute(SessionKey.USERCODE);
f5cc47	121	if(StringUtils.isBlank(userCode)){
X	122	msg.setFail("登录用户已过期，请检查");
	123	return msg;
	124	}
385e2d	125	DataSourceEntity dataSource = MultiDataSource.getDataSourceMap(request);//获取数据源
X	126	SpObserver.setDBtoInstance("_" + dataSource.getDbId());
f5cc47	127	Integer cont = mailBlackListIfc.deleteBlackList(userCode,blackId);
385e2d	128	if (cont > 0) {
f5cc47	129	msg.setOk("已删除");
385e2d	130	}
X	131	} catch (Exception e) {
f5cc47	132	msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
385e2d	133	} finally {
X	134	SpObserver.setDBtoInstance();
	135	}
	136	return msg;
	137	}
	138
	139	/**
	140	* @param search 搜索
	141	* @param request
	142	* @param response
	143	* @return
	144	*/
3c2c1b	145	@GetMapping("/getBlackList.do")
X	146	public AllBackMsg getSignature(String search, HttpServletRequest request, HttpServletResponse response) {
385e2d	147	AllBackMsg msg = new AllBackMsg();
X	148	try {
	149	HttpSession session = request.getSession();
	150	String userCode = (String) session.getAttribute(SessionKey.USERCODE);
f5cc47	151	if(StringUtils.isBlank(userCode)){
X	152	msg.setFail("登录用户已过期，请检查");
	153	return msg;
	154	}
385e2d	155	DataSourceEntity dataSource = MultiDataSource.getDataSourceMap(request);//获取数据源
X	156	SpObserver.setDBtoInstance("_" + dataSource.getDbId());
f5cc47	157	List<T482106Entity> list = mailBlackListIfc.getBlackList(userCode,search);
385e2d	158	msg.setSuccess("执行成功", list);
X	159	} catch (Exception e) {
f5cc47	160	msg.setFail(e.getCause() != null ? e.getCause().getMessage() : e.getMessage());
385e2d	161	} finally {
X	162	SpObserver.setDBtoInstance();
	163	}
	164	return msg;
	165	}
	166	}