Compare commits
No commits in common. '7411141740bdbbae6d221505040625b68aafb331' and '8c474c6ca8f7105939ca1855d6ad87b3d9421027' have entirely different histories.
7411141740
...
8c474c6ca8
31 changed files with 166 additions and 1016 deletions
@ -1,16 +0,0 @@
@@ -1,16 +0,0 @@
|
||||
package apelet.tenantadmin.config; |
||||
|
||||
import org.springframework.context.annotation.Configuration; |
||||
import org.springframework.web.servlet.config.annotation.CorsRegistry; |
||||
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; |
||||
|
||||
@Configuration |
||||
public class CorsConfig implements WebMvcConfigurer { |
||||
@Override |
||||
public void addCorsMappings(CorsRegistry registry) { |
||||
registry.addMapping("/**") |
||||
.allowedOrigins("*") // 允许所有源
|
||||
.allowedMethods("*") // 允许所有请求方法
|
||||
.allowedHeaders("*"); // 允许所有请求头
|
||||
} |
||||
} |
||||
@ -1,141 +0,0 @@
@@ -1,141 +0,0 @@
|
||||
|
||||
package apelet.tenantadmin.tenant.controller; |
||||
|
||||
import apelet.common.core.annotation.MyRequestBody; |
||||
import apelet.common.core.exception.MyRuntimeException; |
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import cn.hutool.core.io.IoUtil; |
||||
import org.apache.poi.xwpf.usermodel.*; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.core.io.ClassPathResource; |
||||
import org.springframework.web.bind.annotation.*; |
||||
|
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.io.*; |
||||
import java.net.URLEncoder; |
||||
import java.nio.charset.StandardCharsets; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
import java.util.regex.Matcher; |
||||
import java.util.regex.Pattern; |
||||
|
||||
@RestController |
||||
@RequestMapping("/api/template") |
||||
public class DocxTemplateController { |
||||
|
||||
|
||||
@Autowired |
||||
private OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
|
||||
private static final Pattern PLACEHOLDER_PATTERN = Pattern.compile("\\$\\{(.+?)\\}"); |
||||
|
||||
/** |
||||
* 替换字符串中 ${key}，JDK8兼容 |
||||
*/ |
||||
private String replaceContent(String text, Map<String, Object> dataMap) { |
||||
if (text == null) return ""; |
||||
Matcher matcher = PLACEHOLDER_PATTERN.matcher(text); |
||||
StringBuffer sb = new StringBuffer(); |
||||
while (matcher.find()) { |
||||
String key = matcher.group(1).trim(); |
||||
Object val = dataMap.get(key); |
||||
String realVal = val == null ? "" : val.toString(); |
||||
matcher.appendReplacement(sb, Matcher.quoteReplacement(realVal)); |
||||
} |
||||
matcher.appendTail(sb); |
||||
return sb.toString(); |
||||
} |
||||
|
||||
@GetMapping("/downloadDocx") |
||||
public void downloadDocx(@RequestParam("id") String quotationId, HttpServletResponse response) { |
||||
XWPFDocument document = null; |
||||
InputStream templateIs = null; |
||||
OutputStream out = null; |
||||
try { |
||||
// 1. 查数据
|
||||
ObjectValue objectValue = ormGenDataSourceUtil.queryOne("quotation", quotationId); |
||||
Map<String, Object> hashMap = new HashMap<>(); |
||||
hashMap.put("name", objectValue.getString("name")); |
||||
hashMap.put("number", objectValue.getString("number")); |
||||
hashMap.put("create_time", objectValue.getString("create_time")); |
||||
hashMap.put("qty", objectValue.getObjectValue("qty")); |
||||
ObjectValue managerperson = objectValue.getObjectValue("managerperson"); |
||||
if(managerperson != null){ |
||||
managerperson = ormGenDataSourceUtil.queryOne(managerperson.getTableName(), managerperson.getString("id")); |
||||
hashMap.put("managerperson",1); |
||||
} |
||||
// 2. 读模板
|
||||
File file = new File("D:\\work\\xykj-project\\xhgl\\zz-resource\\quotation_template.docx"); |
||||
templateIs = new FileInputStream(file); |
||||
document = new XWPFDocument(templateIs); |
||||
// 3. 替换占位符
|
||||
replaceParagraph(document, hashMap); |
||||
replaceTable(document, hashMap); |
||||
// 4. 设置响应头 —— 关键！
|
||||
response.setContentType("application/vnd.openxmlformats-officedocument.wordprocessingml.document"); |
||||
response.setCharacterEncoding("UTF-8"); |
||||
String fileName = URLEncoder.encode("报价单.docx", StandardCharsets.UTF_8.name()) |
||||
.replaceAll("\\+", "%20"); |
||||
// 兼容各浏览器的文件名写法
|
||||
response.setHeader("Content-Disposition", |
||||
"attachment; filename=\"" + fileName + "\"; filename*=UTF-8''" + fileName); |
||||
response.setHeader("Pragma", "no-cache"); |
||||
response.setHeader("Cache-Control", "no-cache"); |
||||
response.setDateHeader("Expires", 0); |
||||
// 5. 写出
|
||||
out = response.getOutputStream(); |
||||
document.write(out); |
||||
out.flush(); |
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
throw new MyRuntimeException("导出失败: " + e.getMessage()); |
||||
} finally { |
||||
IoUtil.close(document); |
||||
IoUtil.close(templateIs); |
||||
IoUtil.close(out); |
||||
} |
||||
} |
||||
|
||||
|
||||
|
||||
|
||||
private void replaceParagraph(XWPFDocument document, Map<String, Object> dataMap) { |
||||
for (XWPFParagraph paragraph : document.getParagraphs()) { |
||||
String text = paragraph.getText(); |
||||
Matcher matcher = PLACEHOLDER_PATTERN.matcher(text); |
||||
if (!matcher.find()) { |
||||
continue; |
||||
} |
||||
//清空原有run
|
||||
for (XWPFRun run : paragraph.getRuns()) { |
||||
run.setText("", 0); |
||||
} |
||||
String newText = replaceContent(text, dataMap); |
||||
paragraph.createRun().setText(newText); |
||||
} |
||||
} |
||||
|
||||
private void replaceTable(XWPFDocument document, Map<String, Object> dataMap) { |
||||
for (XWPFTable table : document.getTables()) { |
||||
for (XWPFTableRow row : table.getRows()) { |
||||
for (XWPFTableCell cell : row.getTableCells()) { |
||||
for (XWPFParagraph paragraph : cell.getParagraphs()) { |
||||
String text = paragraph.getText(); |
||||
Matcher matcher = PLACEHOLDER_PATTERN.matcher(text); |
||||
if (!matcher.find()) { |
||||
continue; |
||||
} |
||||
for (XWPFRun run : paragraph.getRuns()) { |
||||
run.setText("", 0); |
||||
} |
||||
String newText = replaceContent(text, dataMap); |
||||
paragraph.createRun().setText(newText); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
|
||||
|
||||
} |
||||
@ -1,16 +0,0 @@
@@ -1,16 +0,0 @@
|
||||
package apelet.association.config; |
||||
|
||||
import lombok.Data; |
||||
import org.springframework.beans.factory.annotation.Value; |
||||
import org.springframework.context.annotation.Configuration; |
||||
|
||||
@Configuration |
||||
@Data |
||||
public class FrontendConfig { |
||||
|
||||
// @Value("${frontend.address}")
|
||||
public String address; |
||||
|
||||
|
||||
} |
||||
|
||||
@ -1,79 +0,0 @@
@@ -1,79 +0,0 @@
|
||||
package apelet.association.controller; |
||||
|
||||
import apelet.association.utils.WordDocUtil; |
||||
import apelet.common.core.annotation.NoAuthInterface; |
||||
import apelet.common.core.object.*; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.orm.impl.Filter; |
||||
import apelet.common.orm.impl.FilterItem; |
||||
import apelet.common.orm.impl.Selector; |
||||
import com.alibaba.fastjson.JSON; |
||||
import com.alibaba.fastjson.JSONObject; |
||||
import org.apache.commons.lang.StringUtils; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.web.bind.annotation.*; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
import javax.servlet.http.HttpServletResponse; |
||||
import java.net.URLEncoder; |
||||
import java.util.*; |
||||
import java.util.concurrent.atomic.AtomicInteger; |
||||
import java.util.stream.Collectors; |
||||
|
||||
|
||||
/** |
||||
* 课程管理 |
||||
*/ |
||||
@RestController |
||||
@RequestMapping("/tenantadmin/home") |
||||
public class HomeController { |
||||
|
||||
@Autowired |
||||
private OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
|
||||
@PostMapping("/homeData") |
||||
public ResponseResult<?> homeData() { |
||||
HashMap<String, Integer> map = new HashMap<>(); |
||||
//报名审核
|
||||
map.put("ApplicationReview", 0); |
||||
|
||||
//会费逾期
|
||||
ObjectCollection feePay = ormGenDataSourceUtil.query("membership_fee_pay", new Filter(), new Selector()); |
||||
ArrayList<Map> objects = new ArrayList<>(); |
||||
for (int i = 0; i < feePay.size(); i++) { |
||||
objects.add(feePay.getObject(i).getValues()); |
||||
} |
||||
Map<Object, List<Map>> parentMap = objects.stream().collect(Collectors.groupingBy(m -> m.get("parent_id"))); |
||||
AtomicInteger OverdueMembershipFees = new AtomicInteger(); |
||||
parentMap.forEach((k, v) -> { |
||||
// 是否存在任意一条 end_time > 当前时间
|
||||
boolean anyAfterNow = v.stream() |
||||
.anyMatch(m2 -> { |
||||
Object endTimeObj = m2.get("end_time"); |
||||
if(endTimeObj == null){ |
||||
return false; |
||||
} |
||||
Date endTime = (Date) endTimeObj; |
||||
// end_time > 当前时间
|
||||
return endTime.after(new Date()); |
||||
}); |
||||
if(anyAfterNow){ |
||||
OverdueMembershipFees.getAndIncrement(); |
||||
} |
||||
|
||||
}); |
||||
map.put("OverdueMembershipFees", OverdueMembershipFees.get()); |
||||
|
||||
|
||||
// 入会申请
|
||||
Filter filter = new Filter(); |
||||
filter.add(new FilterItem("billstatus", FilterItem.not_equals, "C")); |
||||
ObjectCollection membershipApply = ormGenDataSourceUtil.query("membership_apply", filter, new Selector()); |
||||
map.put("MembershipApplication", membershipApply.size()); |
||||
|
||||
return ResponseResult.success(map); |
||||
} |
||||
|
||||
|
||||
|
||||
} |
||||
@ -1,156 +0,0 @@
@@ -1,156 +0,0 @@
|
||||
package apelet.association.plugin.active; |
||||
|
||||
import apelet.association.utils.MyFileUtil; |
||||
import apelet.association.utils.QRCodeUtil; |
||||
import apelet.common.core.exception.MyRuntimeException; |
||||
import apelet.common.core.object.ObjectCollection; |
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.core.upload.UploadResponseInfo; |
||||
import apelet.common.core.util.ApplicationContextHolder; |
||||
import apelet.common.core.util.RsaUtil; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.online.abstractplugin.ListPlugin; |
||||
import apelet.common.online.dto.OnlineEventPluginExecuteDto; |
||||
import apelet.common.online.model.OnlineDatasource; |
||||
import apelet.common.online.model.OnlineTable; |
||||
import apelet.common.online.model.constant.AttributeEnum; |
||||
import apelet.common.online.service.OnlineDatasourceService; |
||||
import apelet.common.online.service.OnlineTableService; |
||||
import apelet.common.orm.impl.FilterItem; |
||||
import apelet.common.orm.impl.Selector; |
||||
import apelet.common.orm.impl.SelectorItem; |
||||
import cn.hutool.core.bean.BeanUtil; |
||||
import com.alibaba.fastjson.JSONObject; |
||||
import org.apache.commons.io.FileUtils; |
||||
import org.apache.commons.lang3.StringUtils; |
||||
import org.springframework.web.multipart.MultipartFile; |
||||
|
||||
import java.io.File; |
||||
import java.io.IOException; |
||||
import java.util.HashMap; |
||||
import java.util.List; |
||||
import java.util.Map; |
||||
import java.util.stream.Collectors; |
||||
|
||||
/** |
||||
* 活动详情 |
||||
*/ |
||||
public class ActivityInfoDetailsPlugin extends ListPlugin { |
||||
|
||||
|
||||
private final OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
private final MyFileUtil myFileUtil; |
||||
private final QRCodeUtil qrCodeUtil; |
||||
private final OnlineDatasourceService onlineDatasourceService; |
||||
private final OnlineTableService onlineTableService; |
||||
|
||||
|
||||
public ActivityInfoDetailsPlugin() { |
||||
myFileUtil = ApplicationContextHolder.getBean(MyFileUtil.class); |
||||
qrCodeUtil = ApplicationContextHolder.getBean(QRCodeUtil.class); |
||||
ormGenDataSourceUtil = ApplicationContextHolder.getBean(OrmGenDataSourceUtil.class); |
||||
onlineDatasourceService = ApplicationContextHolder.getBean(OnlineDatasourceService.class); |
||||
onlineTableService = ApplicationContextHolder.getBean(OnlineTableService.class); |
||||
} |
||||
|
||||
|
||||
@Override |
||||
public void formCreated(String widgetVariableName, ObjectValue objectValue) { |
||||
this.setWidgetAttribute("id", AttributeEnum.SHOW, false); |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void change(String widgetVariableName, ObjectValue objectValue) { |
||||
//添加 会员
|
||||
if (widgetVariableName.equals("table1786587576012")) { |
||||
ObjectCollection memberInvitations = objectValue.getObjectCollection("member_invitation"); |
||||
List<ObjectValue> collect = memberInvitations.stream().filter(f -> f.getString("rowkey").equals(objectValue.getString("rowkeysubset"))).collect(Collectors.toList()); |
||||
if (!collect.isEmpty()) { |
||||
ObjectValue memberInvitation = collect.get(0); |
||||
ObjectValue membershipApplyId = memberInvitation.getObjectValue("membership_apply_id"); |
||||
if (membershipApplyId == null) { |
||||
return; |
||||
} |
||||
ObjectValue membershipApply = ormGenDataSourceUtil.queryOne(membershipApplyId.getTableName(), membershipApplyId.getString("id")); |
||||
ObjectCollection applyEntry = membershipApply.getObjectCollection("membership_apply_entry"); |
||||
if (applyEntry == null) { |
||||
return; |
||||
} |
||||
ObjectValue entryObject = applyEntry.getObject(0); |
||||
this.setWidgetAttributeByEntry("table1786587576012", "unit_name", AttributeEnum.VALUE_CHANGE, membershipApply.getString("unit_name"), objectValue.getString("rowkeysubset")); |
||||
this.setWidgetAttributeByEntry("table1786587576012", "person", AttributeEnum.VALUE_CHANGE, entryObject.getString("contact_name"), objectValue.getString("rowkeysubset")); |
||||
this.setWidgetAttributeByEntry("table1786587576012", "phone", AttributeEnum.VALUE_CHANGE, entryObject.getString("contact_phone"), objectValue.getString("rowkeysubset")); |
||||
} |
||||
} |
||||
//专家邀请
|
||||
if(widgetVariableName.equals("table1786587648327")){ |
||||
ObjectCollection expertInvitations = objectValue.getObjectCollection("expert_invitation"); |
||||
List<ObjectValue> collect = expertInvitations.stream().filter(f -> f.getString("rowkey").equals(objectValue.getString("rowkeysubset"))).collect(Collectors.toList()); |
||||
if (!collect.isEmpty()) { |
||||
ObjectValue expertInvitation = collect.get(0); |
||||
ObjectValue expert = expertInvitation.getObjectValue("expert_id"); |
||||
expert = ormGenDataSourceUtil.queryOne(expert.getTableName(), expert.getString("id")); |
||||
this.setWidgetAttributeByEntry("table1786587648327", "person", AttributeEnum.VALUE_CHANGE, expert.getString("name"), objectValue.getString("rowkeysubset")); |
||||
this.setWidgetAttributeByEntry("table1786587648327", "phone", AttributeEnum.VALUE_CHANGE, expert.getString("phone"), objectValue.getString("rowkeysubset")); |
||||
} |
||||
} |
||||
//访客邀请
|
||||
if(widgetVariableName.equals("table1786587726532")){ |
||||
|
||||
} |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void buttonTriggered(String widgetVariableName, ObjectValue objectValue) { |
||||
// 生成报名二维码
|
||||
if (widgetVariableName.equals("button1786587153460")) { |
||||
String registrationQr = objectValue.getString("registration_qr"); |
||||
if (StringUtils.isNotEmpty(registrationQr)) { |
||||
this.showErrorMessage("当前已存在报名二维码, 请勿重复生成!!!"); |
||||
return; |
||||
} |
||||
OnlineEventPluginExecuteDto dto = getDto(); |
||||
String savePath = System.getProperty("user.dir") + "\\zz-resource\\qrcode"; |
||||
File QRFile = null; |
||||
try { |
||||
OnlineDatasource onlineDatasource = onlineDatasourceService.getById(dto.getModel().getDatasourceId()); |
||||
OnlineTable table = onlineTableService.getOnlineTableFromCache(onlineDatasource.getMasterTableId()); |
||||
// 生成 报名二维码
|
||||
long id = objectValue.getLong("id"); |
||||
|
||||
String url = "http://192.168.100.42:8099" + "/#/?" + |
||||
"loginName=" + "admin" + |
||||
"&password=" + "123456" + |
||||
"&entryId=" + "2087710350152568832" + |
||||
"&bindType=" + "1" + |
||||
"&onlineFormId=" + "2048951917157027840" + |
||||
"&activeId=" + id; |
||||
|
||||
byte[] checkInQr = qrCodeUtil.generateQrCode(url, 350, 350); |
||||
QRFile = MyFileUtil.writeToFile(checkInQr, savePath, "qrcode-" + System.currentTimeMillis() + ".png"); |
||||
MultipartFile checkInMultipart = MyFileUtil.readFileAsMultipartFile(QRFile, "image/png"); |
||||
UploadResponseInfo registrationQR = myFileUtil.uploadMyFile(table, "qr", true, checkInMultipart); |
||||
|
||||
String s = "[" + new JSONObject(BeanUtil.beanToMap(registrationQR)).toJSONString() + "]"; |
||||
this.setWidgetAttribute("registrationQr", AttributeEnum.VALUE_CHANGE, s); |
||||
this.setWidgetAttribute("qr", AttributeEnum.VALUE_CHANGE, s); |
||||
|
||||
objectValue.put("registration_qr", s); |
||||
objectValue.put("qr", s); |
||||
Selector selector = new Selector(); |
||||
selector.getList().add(new SelectorItem("registration_qr")); |
||||
ormGenDataSourceUtil.update(objectValue.getTableName(), objectValue, selector); |
||||
|
||||
} catch (Exception e) { |
||||
e.printStackTrace(); |
||||
throw new MyRuntimeException(e.getMessage()); |
||||
} finally { |
||||
QRFile.delete(); |
||||
} |
||||
|
||||
|
||||
} |
||||
} |
||||
} |
||||
@ -1,15 +0,0 @@
@@ -1,15 +0,0 @@
|
||||
package apelet.association.plugin.active; |
||||
|
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.online.plugin.EndOperationTransactionArgs; |
||||
import apelet.common.online.plugin.OperationServicePlugIn; |
||||
|
||||
public class ActivityRegistrationSavePlugin extends OperationServicePlugIn { |
||||
|
||||
|
||||
@Override |
||||
public void endOperationTransaction(EndOperationTransactionArgs e) { |
||||
ObjectValue objectValue = e.getModel(); |
||||
|
||||
} |
||||
} |
||||
@ -1,98 +0,0 @@
@@ -1,98 +0,0 @@
|
||||
package apelet.association.plugin.active; |
||||
|
||||
import apelet.common.core.exception.MyRuntimeException; |
||||
import apelet.common.core.object.ObjectCollection; |
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.core.util.ApplicationContextHolder; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.online.abstractplugin.ListPlugin; |
||||
import apelet.common.online.dto.OnlineEventPluginExecuteDto; |
||||
import apelet.common.online.model.constant.AttributeEnum; |
||||
import apelet.common.online.plugin.EndOperationTransactionArgs; |
||||
import apelet.common.online.plugin.OperationServicePlugIn; |
||||
import apelet.common.orm.impl.Filter; |
||||
import apelet.common.orm.impl.FilterItem; |
||||
import apelet.common.orm.impl.Selector; |
||||
import com.alibaba.fastjson.JSONObject; |
||||
|
||||
public class ActivityRegistrationUpdatePlugin extends ListPlugin { |
||||
|
||||
private OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
|
||||
public ActivityRegistrationUpdatePlugin() { |
||||
|
||||
ormGenDataSourceUtil = ApplicationContextHolder.getBean(OrmGenDataSourceUtil.class); |
||||
} |
||||
|
||||
@Override |
||||
public void formCreated(String widgetVariableName, ObjectValue objectValue) { |
||||
|
||||
setWidgetAttribute("id", AttributeEnum.SHOW, false); |
||||
|
||||
JSONObject eventparams = JSONObject.parseObject(objectValue.getString("eventparams")); |
||||
JSONObject jsonObject = eventparams.getJSONObject("urlParams"); |
||||
String activeId = jsonObject.getString("activeId"); |
||||
if(activeId == null){ |
||||
throw new MyRuntimeException("活动id不能为空"); |
||||
} |
||||
ObjectValue active = ormGenDataSourceUtil.queryOne("association_activity", activeId); |
||||
|
||||
this.setWidgetAttribute("name", AttributeEnum.VALUE_CHANGE, active.get("name")); |
||||
this.setWidgetAttribute("startDate", AttributeEnum.VALUE_CHANGE, active.get("start_time")); |
||||
this.setWidgetAttribute("endDate", AttributeEnum.VALUE_CHANGE, active.get("end_time")); |
||||
|
||||
this.setWidgetAttribute("parentId", AttributeEnum.VALUE_CHANGE, active.get("id")); |
||||
this.setWidgetAttribute("parentId", AttributeEnum.SHOW, false); |
||||
|
||||
} |
||||
|
||||
|
||||
@Override |
||||
public void buttonTriggered(String widgetVariableName, ObjectValue objectValue) { |
||||
|
||||
String unitName = objectValue.getString("unit_name"); |
||||
String person = objectValue.getString("person"); |
||||
String phone = objectValue.getString("phone"); |
||||
String parentId = objectValue.getString("parent_id"); |
||||
|
||||
Filter filter1 = new Filter(); |
||||
filter1.add(new FilterItem("unit_name", FilterItem.equals, unitName)); |
||||
filter1.add(new FilterItem("person", FilterItem.equals, person)); |
||||
filter1.add(new FilterItem("phone", FilterItem.equals, phone)); |
||||
filter1.add(new FilterItem("parent_id", FilterItem.equals, parentId)); |
||||
ObjectCollection collection = ormGenDataSourceUtil.query("activity_register", filter1, new Selector()); |
||||
if(!collection.isEmpty()){ |
||||
this.showWarningMessage("当前单位联系人已报名成功, 请勿重复提交!!!"); |
||||
this.cancelOperate(); |
||||
return; |
||||
} |
||||
ObjectValue activityRegister = new ObjectValue("activity_register"); |
||||
activityRegister.put("unit_name", unitName); |
||||
activityRegister.put("person", person); |
||||
activityRegister.put("phone", phone); |
||||
activityRegister.put("parent_id", parentId); |
||||
|
||||
Filter filter = new Filter(); |
||||
filter.add(new FilterItem("unit_name", FilterItem.equals, unitName)); |
||||
ObjectCollection membershipApplyList = ormGenDataSourceUtil.query("membership_apply", filter, new Selector()); |
||||
|
||||
filter = new Filter(); |
||||
filter.add(new FilterItem("name", FilterItem.equals, person)); |
||||
ObjectCollection expertManageList = ormGenDataSourceUtil.query("expert_manage", filter, new Selector()); |
||||
|
||||
if(membershipApplyList != null && !membershipApplyList.isEmpty()){ |
||||
ObjectValue object = membershipApplyList.getObject(0); |
||||
activityRegister.put("membership_apply_id", object); |
||||
}else if(expertManageList != null && !expertManageList.isEmpty()){ |
||||
ObjectValue object = expertManageList.getObject(0); |
||||
activityRegister.put("expert_manage_id", object); |
||||
} |
||||
try { |
||||
ormGenDataSourceUtil.addNew(activityRegister.getTableName(), activityRegister); |
||||
} catch (Exception e) { |
||||
throw new MyRuntimeException(e.getMessage()); |
||||
} |
||||
this.showMessage("保存成功"); |
||||
this.cancelOperate(); |
||||
} |
||||
} |
||||
@ -1,76 +0,0 @@
@@ -1,76 +0,0 @@
|
||||
package apelet.association.plugin.clueManage; |
||||
|
||||
import apelet.common.core.exception.MyRuntimeException; |
||||
import apelet.common.core.object.ObjectCollection; |
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.core.object.TokenData; |
||||
import apelet.common.core.util.ApplicationContextHolder; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.online.plugin.*; |
||||
import apelet.common.orm.impl.Selector; |
||||
import apelet.common.orm.impl.SelectorItem; |
||||
import cn.hutool.core.date.DateUtil; |
||||
import org.redisson.api.RBucket; |
||||
import org.redisson.api.RedissonClient; |
||||
|
||||
import java.time.LocalDate; |
||||
import java.time.LocalDateTime; |
||||
import java.time.temporal.ChronoUnit; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
import java.util.concurrent.TimeUnit; |
||||
|
||||
/** |
||||
* @ClassName: ClueActivateOpPlugin |
||||
* @Author: lihuangbin |
||||
* @Date: 2026/5/11 |
||||
* @Description: 激活放弃的线索 |
||||
*/ |
||||
|
||||
public class ClueSaveOpPlugin extends OperationServicePlugIn { |
||||
|
||||
private final OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
private final RedissonClient redissonClient; |
||||
|
||||
public ClueSaveOpPlugin() { |
||||
ormGenDataSourceUtil = ApplicationContextHolder.getBean(OrmGenDataSourceUtil.class); |
||||
redissonClient = ApplicationContextHolder.getBean(RedissonClient.class); |
||||
} |
||||
|
||||
|
||||
@Override |
||||
public void endOperationTransaction(EndOperationTransactionArgs e) { |
||||
ObjectValue objectValue = e.getModel(); |
||||
String redisKey = "clue -- " + DateUtil.today(); |
||||
RBucket<Map<Long, Map<Long, String>>> bucket = redissonClient.getBucket(redisKey); |
||||
Map<Long, Map<Long, String>> map; |
||||
// 修复：key存在则读取，不存在新建空map
|
||||
if (bucket.isExists()) { |
||||
map = bucket.get(); |
||||
} else { |
||||
map = new HashMap<>(); |
||||
} |
||||
Long userId = TokenData.takeFromRequest().getUserId(); |
||||
Map<Long, String> userClueMap = map.get(userId); |
||||
if (userClueMap == null || userClueMap.isEmpty()) { |
||||
userClueMap = new HashMap<>(); |
||||
} |
||||
String context = "完成线索, 名称: " +objectValue.getString("name") |
||||
+ ", 咨询内容: " + objectValue.getString("seek_info"); |
||||
userClueMap.put(objectValue.getLong("id"), context); |
||||
map.put(userId, userClueMap); |
||||
|
||||
bucket.set(map); |
||||
|
||||
// 判断：key不存在，写入同时设置过期；key已经存在，只更新value，**不修改TTL**
|
||||
if (!bucket.isExists()) { |
||||
// 计算到次日0点毫秒
|
||||
LocalDateTime tomorrowZero = LocalDate.now().plusDays(1).atStartOfDay(); |
||||
long expireMs = ChronoUnit.MILLIS.between(LocalDateTime.now(), tomorrowZero); |
||||
// 原子：只有key不存在才写入并设置过期
|
||||
bucket.expire(expireMs, TimeUnit.MILLISECONDS); |
||||
} |
||||
} |
||||
|
||||
|
||||
} |
||||
@ -1,72 +0,0 @@
@@ -1,72 +0,0 @@
|
||||
package apelet.association.plugin.member; |
||||
|
||||
import apelet.common.core.exception.MyRuntimeException; |
||||
import apelet.common.core.object.ObjectCollection; |
||||
import apelet.common.core.object.ObjectValue; |
||||
import apelet.common.core.util.ApplicationContextHolder; |
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.online.abstractplugin.ExecutePluginParent; |
||||
import apelet.common.online.dto.OnlineEventPluginExecuteDto; |
||||
import apelet.common.online.model.ShowParameter; |
||||
import apelet.common.online.model.constant.AttributeEnum; |
||||
import apelet.common.online.model.constant.ShowTypeEnum; |
||||
import apelet.common.online.model.constant.ViewStatus; |
||||
import apelet.common.orm.impl.Filter; |
||||
import apelet.common.orm.impl.FilterItem; |
||||
import apelet.common.orm.impl.Selector; |
||||
|
||||
import java.sql.Date; |
||||
import java.util.HashMap; |
||||
import java.util.Map; |
||||
|
||||
|
||||
public class MembershipFeePayPlugin extends ExecutePluginParent { |
||||
|
||||
private OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
|
||||
public MembershipFeePayPlugin(){ |
||||
ormGenDataSourceUtil = ApplicationContextHolder.getBean(OrmGenDataSourceUtil.class); |
||||
} |
||||
|
||||
@Override |
||||
public void formCreated(String widgetVariableName, ObjectValue objectValue) { |
||||
super.formCreated(widgetVariableName, objectValue); |
||||
OnlineEventPluginExecuteDto dto = getDto(); |
||||
Map eventParams = dto.getEventParams(); |
||||
if (eventParams != null) { |
||||
this.setWidgetAttribute("parentId", AttributeEnum.VALUE_CHANGE, eventParams.get("id")); |
||||
this.setWidgetAttribute("parentId", AttributeEnum.SHOW, false); |
||||
|
||||
this.setWidgetAttribute("membershipDate", AttributeEnum.VALUE_CHANGE, eventParams.get("create_time")); |
||||
this.setWidgetAttribute("membershipType", AttributeEnum.VALUE_CHANGE, eventParams.get("membership_type")); |
||||
} |
||||
|
||||
} |
||||
|
||||
@Override |
||||
public void buttonTriggered(String widgetVariableName, ObjectValue objectValue) { |
||||
if(widgetVariableName.equals("保存")){ |
||||
String parentId = objectValue.getString("parent_id"); |
||||
|
||||
Date startTime1= objectValue.getDate("membership_date"); |
||||
Date endTime1 = objectValue.getDate("end_time"); |
||||
|
||||
Filter filter = new Filter(); |
||||
filter.add(new FilterItem("parent_id", FilterItem.equals, parentId)); |
||||
ObjectCollection collection = ormGenDataSourceUtil.query(objectValue.getTableName(), filter, new Selector()); |
||||
for (int i = 0; i < collection.size(); i++) { |
||||
ObjectValue object = collection.getObject(i); |
||||
|
||||
Date startTime2= object.getDate("membership_date"); |
||||
Date endTime2 = object.getDate("end_time"); |
||||
// 判断 startTime - endTime 和 startTime2 - endTime2 是否存在交集
|
||||
|
||||
if (startTime1.before(endTime2) && startTime2.before(endTime1)) { |
||||
// 存在交集，抛出异常
|
||||
throw new MyRuntimeException("会费已缴纳, 请勿重复缴纳!!!"); |
||||
} |
||||
} |
||||
} |
||||
} |
||||
} |
||||
|
||||
@ -1,30 +0,0 @@
@@ -1,30 +0,0 @@
|
||||
package apelet.association.task; |
||||
|
||||
|
||||
import apelet.common.generator.utils.OrmGenDataSourceUtil; |
||||
import apelet.common.orm.impl.Filter; |
||||
import apelet.msgnotice.service.SystemMessageService; |
||||
import org.springframework.beans.factory.annotation.Autowired; |
||||
import org.springframework.scheduling.annotation.Scheduled; |
||||
import org.springframework.stereotype.Component; |
||||
|
||||
@Component |
||||
public class ContractPaymentReminderTask { |
||||
|
||||
// 提前 30 天提醒
|
||||
private static final int REMIND_BEFORE_DAYS = 7; |
||||
|
||||
@Autowired |
||||
private OrmGenDataSourceUtil ormGenDataSourceUtil; |
||||
|
||||
@Autowired |
||||
private SystemMessageService systemMessageService; |
||||
|
||||
@Scheduled(cron = "0 0 1 * * ?") |
||||
public void sendRemind() { |
||||
Filter filter = new Filter(); |
||||
|
||||
// ormGenDataSourceUtil.query("", )
|
||||
} |
||||
|
||||
} |
||||
@ -1,82 +0,0 @@
@@ -1,82 +0,0 @@
|
||||
package apelet.association.utils; |
||||
|
||||
import com.deepoove.poi.XWPFTemplate; |
||||
import com.deepoove.poi.config.Configure; |
||||
import com.deepoove.poi.data.PictureRenderData; |
||||
import com.deepoove.poi.data.PictureType; |
||||
import com.deepoove.poi.data.Pictures; |
||||
|
||||
import java.io.*; |
||||
import java.util.Map; |
||||
|
||||
public class WordDocUtil { |
||||
|
||||
/** |
||||
* 本地模板生成docx文件，输出到本地磁盘 |
||||
* |
||||
* @param templateLocalPath 本地模板绝对路径 |
||||
* @param outLocalPath 输出文件路径 |
||||
* @param dataMap 填充数据 |
||||
* @throws Exception IO异常 |
||||
*/ |
||||
public static void renderLocalDoc(String templateLocalPath, String outLocalPath, Map<String, Object> dataMap) throws Exception { |
||||
// 自动创建输出文件夹
|
||||
File outFile = new File(outLocalPath); |
||||
if (!outFile.getParentFile().exists()) { |
||||
outFile.getParentFile().mkdirs(); |
||||
} |
||||
Configure config = Configure.builder() |
||||
.buildGramer("#{", "}") |
||||
.build(); |
||||
try (InputStream templateIn = new FileInputStream(templateLocalPath); |
||||
OutputStream fileOut = new FileOutputStream(outLocalPath); |
||||
XWPFTemplate template = XWPFTemplate.compile(templateIn, config).render(dataMap)) { |
||||
template.write(fileOut); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* ✅【新增】模板渲染直接输出到输出流（用于浏览器下载，不生成本地临时文件） |
||||
* @param templateLocalPath 模板文件路径 |
||||
* @param outputStream response.getOutputStream() |
||||
* @param dataMap 填充数据 |
||||
* @throws Exception ex |
||||
*/ |
||||
public static void renderToOutputStream(String templateLocalPath, OutputStream outputStream, Map<String, Object> dataMap) throws Exception { |
||||
Configure config = Configure.builder() |
||||
.buildGramer("#{", "}") |
||||
.build(); |
||||
try (InputStream templateIn = new FileInputStream(templateLocalPath); |
||||
XWPFTemplate template = XWPFTemplate.compile(templateIn, config).render(dataMap)) { |
||||
template.write(outputStream); |
||||
} |
||||
} |
||||
|
||||
/** |
||||
* OSS/网络URL图片构建（签字图片专用） |
||||
* |
||||
* @param ossUrl OSS完整图片地址 https://xxx.oss-cn-beijing.aliyuncs.com/sign/sign001.png
|
||||
* @param widthCm 图片宽度 单位cm |
||||
* @param heightCm 图片高度 单位cm |
||||
* @return PictureRenderData |
||||
*/ |
||||
public static PictureRenderData getOssPic(String ossUrl, double widthCm, double heightCm) { |
||||
// poi‑tl size 参数单位是 像素，注意：不是厘米！！！
|
||||
return Pictures.ofUrl(ossUrl) |
||||
.size((int) widthCm, (int) heightCm) |
||||
.create(); |
||||
} |
||||
|
||||
// 本地图片（备用）
|
||||
public static PictureRenderData getLocalPic(String imgLocalPath, double width, double height) { |
||||
return Pictures.ofLocal(imgLocalPath).size((int) width, (int) height).create(); |
||||
} |
||||
|
||||
// base64图片（备用）
|
||||
public static PictureRenderData getBase64Pic(String base64Str, double width, double height) { |
||||
return Pictures.ofBase64(base64Str, PictureType.PNG) |
||||
.size((int) width, (int) height) |
||||
.create(); |
||||
} |
||||
|
||||
} |
||||
Loading…
Reference in new issue