update 法规采购流程

This commit is contained in:
liao
2023-11-29 20:34:37 +08:00
parent e558e91ecc
commit 4cbf399b15
3 changed files with 86 additions and 6 deletions
@@ -143,12 +143,74 @@ public class ProcessFbEntryChangeServiceImpl extends ServiceImpl<ProcessFbEntryC
lawsCommonService.commonAdd(objectMap);
} else {
// 如果是标准法规变更流程
// 发送消息
sendMsg(objectMap);
lawsCommonService.commonEdit(objectMap);
}
log.info("《标准法规入库/变更流程》结束,流程名称:{}", basicProcessInfoDTO.getProcessName());
}
}
/**
* @Author: liao
* @Date: 2023/11/29 16:55
* @Description: 发消息
**/
private void sendMsg(Map<String, Object> objectMap) {
String module = (String) objectMap.get(FieldCommon.MODULE);
String id = (String) objectMap.get("id");
Map<String, Object> oldMap = lawsCommonService.getByIdAndModule(id, module, "2", null);
String replaced = (String) objectMap.get(FieldCommon.REPLACED_STANDARD); // 代替标准
String reference = (String) objectMap.get(FieldCommon.REFERENCE_STANDARD); // 引用标准
String replacedOld = (String) oldMap.get(FieldCommon.REPLACED_STANDARD); // 代替标准
String referenceOld = (String) oldMap.get(FieldCommon.REFERENCE_STANDARD); // 引用标准
if (StringUtils.isNotBlank(replaced) && !replaced.equals(replacedOld)) { // 代替标准
String content = getContent(objectMap, oldMap, module);
}
if (StringUtils.isNotBlank(reference) && !reference.equals(referenceOld)) { // 引用标准
String content = getContent(objectMap, oldMap, module);
}
}
/**
* @Author: liao
* @Date: 2023/11/29 17:48
* @Description: 得到变更内容
**/
private String getContent(Map<String, Object> objectMap, Map<String, Object> oldMap, String module) {
// 获取要操作的表名
String tableName = TableNameEnum.getTableName(module);
// 获取全部字段
List<LawsTag> fieldList = lawsCommonMapper.getFieldList(tableName);
// 筛选出表单显示的
fieldList = fieldList.stream().filter(lawsTag -> YesOrNoEnum.YES.getInteger()
.equals(lawsTag.getIsShowFormCreate())).collect(Collectors.toList());
// 组装更新内容
StringBuilder recordBuffer = new StringBuilder();
recordBuffer.append("变更前");
StringBuilder recordBuffer2 = new StringBuilder();
recordBuffer2.append("变更后");
for (Map.Entry<String, Object> entryMap : objectMap.entrySet()) {
String key = entryMap.getKey();
String value = "";
if (!Objects.isNull(entryMap.getValue())) {
value = (String) entryMap.getValue();
}
// 添加更新记录
lawsCommonService.addUpdateRecord(fieldList, oldMap, recordBuffer, recordBuffer2, key, value);
}
recordBuffer.deleteCharAt(recordBuffer.length()-1);
recordBuffer2.deleteCharAt(recordBuffer2.length()-1);
recordBuffer.append("");
recordBuffer.append(recordBuffer2);
return recordBuffer.toString();
}
/**
* @Author: liao
* @Date: 2023/11/6 15:23
@@ -71,6 +71,15 @@ public interface ILawsCommonService {
**/
String commonEdit(Map<String, Object> parameterMap);
/**
* @Author: liao
* @Date: 2023/11/29 16:11
* @Description: 更新语句
**/
void addUpdateRecord(List<LawsTag> fieldList, Map<String, Object> oldDataMap,
StringBuilder recordBuffer, StringBuilder recordBuffer2,
String key, String value);
/**
* @Author: liao
* @Date: 2023/8/24 10:41
@@ -799,7 +799,7 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
}
// 添加更新记录
addUpdateRecord(fieldList, oldDataMap, recordBuffer, key, value);
addUpdateRecord(fieldList, oldDataMap, recordBuffer, null, key, value);
// 拼接更新sql语句
jointUpdateFieldAndValue(fieldList, updateBuilder, key, value, id, standardNumber);
@@ -860,8 +860,10 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
* @Date: 2023/9/12 15:40
* @Description: 添加更新记录
**/
private void addUpdateRecord(List<LawsTag> fieldList, Map<String, Object> oldDataMap,
StringBuilder recordBuffer, String key, String value) {
@Override
public void addUpdateRecord(List<LawsTag> fieldList, Map<String, Object> oldDataMap,
StringBuilder recordBuffer, StringBuilder recordBuffer2,
String key, String value) {
String oldValue = "";
if (!Objects.isNull(oldDataMap.get(key))) oldValue = (String) oldDataMap.get(key);
@@ -997,9 +999,16 @@ public class LawsCommonServiceImpl implements ILawsCommonService {
// 如果新旧值不一样
if (!oldValue.equals(value)) {
recordBuffer.append(FieldCommon.QUOTE + lawsTag.getDbFieldTxt() + FieldCommon.QUOTE + "");
recordBuffer.append(FieldCommon.QUOTE + oldValue + FieldCommon.QUOTE + "改为");
recordBuffer.append(FieldCommon.QUOTE + value + FieldCommon.QUOTE + "");
if (recordBuffer2 == null) { // 标准编辑
recordBuffer.append(FieldCommon.QUOTE + lawsTag.getDbFieldTxt() + FieldCommon.QUOTE + "");
recordBuffer.append(FieldCommon.QUOTE + oldValue + FieldCommon.QUOTE + "改为");
recordBuffer.append(FieldCommon.QUOTE + value + FieldCommon.QUOTE + "");
} else { // 法规变更流程
recordBuffer.append("[" + lawsTag.getDbFieldTxt() + "]" + "");
recordBuffer.append("[" + oldValue + "]" + "");
recordBuffer2.append("[" + lawsTag.getDbFieldTxt() + "]" + "");
recordBuffer2.append("[" + value + "]" + "");
}
}
}