wangxianzhang
4 years ago
134 changed files with 2094 additions and 349 deletions
@ -0,0 +1,35 @@ |
|||
package com.epmet.commons.tools.feign; |
|||
|
|||
import feign.RequestInterceptor; |
|||
import feign.RequestTemplate; |
|||
import org.springframework.web.context.request.RequestAttributes; |
|||
import org.springframework.web.context.request.RequestContextHolder; |
|||
import org.springframework.web.context.request.ServletRequestAttributes; |
|||
|
|||
import javax.servlet.http.HttpServletRequest; |
|||
import java.util.Enumeration; |
|||
|
|||
|
|||
public class EpmetBaseRequestInterceptor implements RequestInterceptor { |
|||
|
|||
@Override |
|||
public void apply(RequestTemplate template) { |
|||
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes(); |
|||
if (requestAttributes == null) { |
|||
return; |
|||
} |
|||
|
|||
HttpServletRequest request = ((ServletRequestAttributes) requestAttributes).getRequest(); |
|||
Enumeration<String> headerNames = request.getHeaderNames(); |
|||
if (headerNames != null) { |
|||
while (headerNames.hasMoreElements()) { |
|||
String name = headerNames.nextElement(); |
|||
Enumeration<String> values = request.getHeaders(name); |
|||
while (values.hasMoreElements()) { |
|||
String value = values.nextElement(); |
|||
template.header(name, value); |
|||
} |
|||
} |
|||
} |
|||
} |
|||
} |
|||
@ -1,2 +1,2 @@ |
|||
/*ALTER TABLE dim_agency ADD COLUMN AGENCY_DIM_TYPE VARCHAR(10) NOT NULL COMMENT '机关维度类型。self:机关本身自己,all:机关自己+下级+网格+部门等';*/ |
|||
#ALTER TABLE dim_agency ADD COLUMN AGENCY_DIM_TYPE VARCHAR(10) NOT NULL COMMENT '机关维度类型。self:机关本身自己,all:机关自己+下级+网格+部门等'; |
|||
select 1; |
|||
@ -0,0 +1,59 @@ |
|||
/** |
|||
* Copyright (c) 2018 人人开源 All rights reserved. |
|||
* |
|||
* https://www.renren.io
|
|||
* |
|||
* 版权所有，侵权必究！ |
|||
*/ |
|||
|
|||
package com.epmet.config; |
|||
|
|||
import com.epmet.commons.tools.constant.AppClientConstant; |
|||
import com.epmet.commons.tools.feign.EpmetBaseRequestInterceptor; |
|||
import feign.RequestInterceptor; |
|||
import feign.RequestTemplate; |
|||
import org.springframework.context.annotation.Bean; |
|||
import org.springframework.context.annotation.Configuration; |
|||
|
|||
/** |
|||
* Feign调用，携带header |
|||
* |
|||
* @author Mark sunlightcs@gmail.com |
|||
* @since 1.0.0 |
|||
*/ |
|||
@Configuration |
|||
public class JobFeignConfig { |
|||
|
|||
@Bean |
|||
RequestInterceptor requestInterceptor() { |
|||
return new JobRequestInterceptor(); |
|||
} |
|||
|
|||
class JobRequestInterceptor extends EpmetBaseRequestInterceptor { |
|||
@Override |
|||
public void apply(RequestTemplate template) { |
|||
super.apply(template); |
|||
|
|||
// job服务自己生成流水号
|
|||
template.header(AppClientConstant.TRANSACTION_SERIAL_KEY, generateTransactionSerial()); |
|||
} |
|||
|
|||
/** |
|||
* 获取事务流水号 |
|||
* |
|||
* @return |
|||
*/ |
|||
public String generateTransactionSerial() { |
|||
String[] letterPool = {"a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "l", "m", "n" |
|||
, "o", "p", "q", "r", "s", "t", "u", "v", "w", "x", "y", "z"}; |
|||
|
|||
StringBuilder sb = new StringBuilder(); |
|||
for (int i = 0; i < 2; i++) { |
|||
sb.append(letterPool[(int) (Math.random() * 25)]); |
|||
} |
|||
|
|||
sb.append(System.currentTimeMillis()); |
|||
return sb.toString(); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,68 @@ |
|||
package com.epmet.controller; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.service.OssService; |
|||
import org.apache.commons.io.FileUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.mock.web.MockMultipartFile; |
|||
import org.springframework.web.bind.annotation.*; |
|||
import org.springframework.web.multipart.MultipartFile; |
|||
|
|||
import java.io.*; |
|||
import java.net.Inet4Address; |
|||
import java.net.InetAddress; |
|||
import java.net.UnknownHostException; |
|||
|
|||
@RestController |
|||
@RequestMapping("test") |
|||
public class TestController { |
|||
|
|||
@Autowired |
|||
private OssService ossService; |
|||
|
|||
@PostMapping("local-upload") |
|||
public Result localUpload(@RequestPart("file") MultipartFile file, @RequestParam("fileName") String fileName) { |
|||
|
|||
final File tempFile = new File("/opt/upload_files/" + fileName); |
|||
|
|||
try(InputStream inputStream = file.getInputStream()) { |
|||
FileUtils.copyInputStreamToFile(inputStream, tempFile); |
|||
} catch (IOException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
return new Result(); |
|||
} |
|||
|
|||
@PostMapping("upload2aliyun") |
|||
public Result upload2aliyun(@RequestParam("fileName") String fileName) { |
|||
try (final FileInputStream fis = new FileInputStream("/opt/upload_files/" + fileName)) { |
|||
final MockMultipartFile mockMultipartFile = new MockMultipartFile(fileName, fis); |
|||
return ossService.uploadImg(mockMultipartFile, null); |
|||
} catch (FileNotFoundException e) { |
|||
e.printStackTrace(); |
|||
} catch (IOException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
return new Result(); |
|||
} |
|||
|
|||
/** |
|||
* @Description ribbon测试 |
|||
* @return |
|||
* @author wxz |
|||
* @date 2021.08.05 16:28 |
|||
*/ |
|||
@PostMapping("test-ribbon-rcv/{sleep}") |
|||
public Result testRibbonRcv(@PathVariable("sleep") Long sleep) { |
|||
InetAddress localHost = null; |
|||
try { |
|||
Thread.sleep(sleep); |
|||
localHost = Inet4Address.getLocalHost(); |
|||
} catch (UnknownHostException e) { |
|||
e.printStackTrace(); |
|||
} catch (InterruptedException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
return new Result().ok(localHost); |
|||
} |
|||
} |
|||
@ -0,0 +1,26 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotEmpty; |
|||
import javax.validation.constraints.NotNull; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 区块链：创建项目form dto |
|||
*/ |
|||
@Data |
|||
public class BlockChainCreateProjectFormDTO { |
|||
|
|||
@NotNull(message = "项目信息不能为空") |
|||
private BlockChainProjectFormDTO project; |
|||
|
|||
@NotNull(message = "处理进展信息不能为空") |
|||
private BlockChainProjectProcessFormDTO process; |
|||
|
|||
@NotNull(message = "指派的人员列表信息不能为空") |
|||
@NotEmpty(message = "指派的人员列表信息不能为空") |
|||
private List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs; |
|||
|
|||
} |
|||
|
|||
@ -0,0 +1,21 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotNull; |
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 区块链：项目处理进展信息 |
|||
*/ |
|||
@Data |
|||
public class BlockChainProcessProjectFormDTO { |
|||
|
|||
@NotNull(message = "处理进展信息不能为空") |
|||
private BlockChainProjectProcessFormDTO process; |
|||
|
|||
private List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs; |
|||
|
|||
// 处理人信息更新
|
|||
private BlockChainProjectProcessAssignedStaffFormDTO handledStaff; |
|||
} |
|||
@ -0,0 +1,63 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 区块链项目信息formdto |
|||
*/ |
|||
@Data |
|||
public class BlockChainProjectFormDTO { |
|||
@NotBlank(message = "项目ID必填") |
|||
private String projectId; |
|||
|
|||
@NotBlank(message = "客户ID必填") |
|||
private String customerId; |
|||
|
|||
// 客户名称
|
|||
private String customerName; |
|||
|
|||
@NotBlank(message = "标题必填") |
|||
private String title; |
|||
|
|||
@NotBlank(message = "组织ID必填") |
|||
private String agencyId; |
|||
|
|||
// 组织名称
|
|||
private String agencyName; |
|||
|
|||
@NotBlank(message = "项目来源必填") |
|||
private String origin; |
|||
|
|||
@NotBlank(message = "项目来源ID必填") |
|||
private String originId; |
|||
|
|||
@NotBlank(message = "项目状态必填") |
|||
private String status; |
|||
|
|||
@NotBlank(message = "关闭状态必填") |
|||
private String closeStatus; |
|||
|
|||
@NotBlank(message = "组织ID PATH必填") |
|||
private String orgIdPath; |
|||
|
|||
@NotBlank(message = "定位必填") |
|||
private String locateAddress; |
|||
|
|||
@NotBlank(message = "经度必填") |
|||
private String locateLongitude; |
|||
|
|||
@NotBlank(message = "维度必填") |
|||
private String locateDimension; |
|||
|
|||
@NotBlank(message = "创建时间必填") |
|||
private Date createdTime; |
|||
|
|||
@NotBlank(message = "创建者ID必填") |
|||
private String createdBy; |
|||
|
|||
// 创建者名字
|
|||
private String createrName; |
|||
} |
|||
@ -0,0 +1,64 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 区块链：指派的项目处理人员 form dto |
|||
*/ |
|||
@Data |
|||
public class BlockChainProjectProcessAssignedStaffFormDTO { |
|||
@NotBlank(message = "ID必填") |
|||
private String id; |
|||
|
|||
@NotBlank(message = "进展ID必填") |
|||
private String processId; |
|||
|
|||
@NotBlank(message = "项目ID必填") |
|||
private String projectId; |
|||
|
|||
@NotBlank(message = "客户ID必填") |
|||
private String customerId; |
|||
|
|||
@NotBlank(message = "组织ID必填") |
|||
private String orgId; |
|||
|
|||
//组织名称
|
|||
private String orgName; |
|||
|
|||
@NotBlank(message = "部门ID必填") |
|||
private String departmentId; |
|||
|
|||
@NotBlank(message = "网格ID必填") |
|||
private String gridId; |
|||
|
|||
// 网格名称
|
|||
private String gridName; |
|||
|
|||
@NotBlank(message = "组织ID PATH必填") |
|||
private String orgIdPath; |
|||
|
|||
@NotBlank(message = "人员ID必填") |
|||
private String staffId; |
|||
|
|||
// 指派的用户名字
|
|||
private String staffName; |
|||
|
|||
@NotBlank(message = "部门名称必填") |
|||
private String departmentName; |
|||
|
|||
@NotBlank(message = "是否处理必填") |
|||
private String isHandle; |
|||
|
|||
@NotBlank(message = "创建者ID必填") |
|||
private String createdBy; |
|||
|
|||
@NotBlank(message = "创建时间必填") |
|||
private Date createdTime; |
|||
|
|||
// 创建者名字
|
|||
private String createrName; |
|||
|
|||
} |
|||
@ -0,0 +1,85 @@ |
|||
package com.epmet.dto.form; |
|||
|
|||
|
|||
import lombok.Data; |
|||
|
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
|
|||
import javax.validation.constraints.NotNull; |
|||
|
|||
import java.util.Date; |
|||
|
|||
|
|||
/** |
|||
* 区块链：项目处理form dto |
|||
*/ |
|||
@Data |
|||
public class BlockChainProjectProcessFormDTO { |
|||
@NotBlank(message = "处理ID必填") |
|||
private String processId; |
|||
|
|||
@NotBlank(message = "项目ID必填") |
|||
private String projectId; |
|||
|
|||
@NotBlank(message = "客户ID必填") |
|||
private String customerId; |
|||
|
|||
@NotBlank(message = "部门名称必填") |
|||
private String departmentName; |
|||
|
|||
@NotBlank(message = "组织ID必填") |
|||
private String agencyId; |
|||
|
|||
// 组织的ID
|
|||
private String agencyName; |
|||
|
|||
@NotBlank(message = "部门ID必填") |
|||
private String departmentId; |
|||
|
|||
@NotBlank(message = "网格ID必填") |
|||
private String gridId; |
|||
|
|||
// 网格的名称
|
|||
private String gridName; |
|||
|
|||
@NotBlank(message = "组织ID PATH必填") |
|||
private String orgIdPath; |
|||
|
|||
@NotBlank(message = "处理人员ID必填") |
|||
private String staffId; |
|||
|
|||
// 工作人员名字
|
|||
private String staffName; |
|||
|
|||
@NotBlank(message = "操作类型必填") |
|||
private String operation; |
|||
|
|||
@NotBlank(message = "操作名称必填") |
|||
private String operationName; |
|||
|
|||
@NotBlank(message = "公开答复必填") |
|||
private String publicReply; |
|||
|
|||
@NotBlank(message = "内部备注必填必填") |
|||
private String internalRemark; |
|||
|
|||
@NotNull(message = "结束时间必填") |
|||
private Date endTime; |
|||
|
|||
@NotNull(message = "是否发送到外部系统必填") |
|||
private Integer isSend; |
|||
|
|||
@NotNull(message = "耗费天数必填") |
|||
private String costWorkDays; |
|||
|
|||
@NotBlank(message = "创建者ID必填") |
|||
private String createdBy; |
|||
|
|||
// 创建者名字
|
|||
private String createrName; |
|||
|
|||
@NotNull(message = "创建时间必填") |
|||
private Date createdTime; |
|||
|
|||
} |
|||
@ -0,0 +1,47 @@ |
|||
package com.epmet.controller; |
|||
|
|||
import com.epmet.commons.tools.utils.Result; |
|||
import com.epmet.commons.tools.validator.ValidatorUtils; |
|||
import com.epmet.dto.form.BlockChainCreateProjectFormDTO; |
|||
import com.epmet.dto.form.BlockChainProcessProjectFormDTO; |
|||
import com.epmet.service.BlockChainProjectService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestBody; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
/** |
|||
* 区块链project相关controller |
|||
*/ |
|||
@RestController |
|||
@RequestMapping("/blockchain/project") |
|||
public class BlockChainProjectController { |
|||
|
|||
@Autowired |
|||
private BlockChainProjectService blockChainProjectService; |
|||
|
|||
/** |
|||
* 立项 |
|||
* @param input |
|||
* @return |
|||
*/ |
|||
@PostMapping("create") |
|||
public Result blockChainCreateProject(@RequestBody BlockChainCreateProjectFormDTO input) { |
|||
ValidatorUtils.validateEntity(input); |
|||
blockChainProjectService.blockChainCreateProject(input); |
|||
return new Result(); |
|||
} |
|||
|
|||
/** |
|||
* 处理进展 |
|||
* @param input |
|||
* @return |
|||
*/ |
|||
@PostMapping("process") |
|||
public Result blockChainProcessProject(@RequestBody BlockChainProcessProjectFormDTO input) { |
|||
ValidatorUtils.validateEntity(input); |
|||
blockChainProjectService.blockChainProcessProject(input); |
|||
return new Result(); |
|||
} |
|||
} |
|||
@ -0,0 +1,98 @@ |
|||
package com.epmet.mq.producer; |
|||
|
|||
import com.epmet.commons.tools.exception.ExceptionUtils; |
|||
import com.epmet.mq.properties.RocketMQProperties; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.rocketmq.acl.common.AclClientRPCHook; |
|||
import org.apache.rocketmq.acl.common.SessionCredentials; |
|||
import org.apache.rocketmq.client.exception.MQClientException; |
|||
import org.apache.rocketmq.client.producer.DefaultMQProducer; |
|||
import org.apache.rocketmq.client.producer.SendResult; |
|||
import org.apache.rocketmq.client.producer.SendStatus; |
|||
import org.apache.rocketmq.common.message.Message; |
|||
import org.apache.rocketmq.remoting.common.RemotingHelper; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import javax.annotation.PostConstruct; |
|||
import javax.annotation.PreDestroy; |
|||
|
|||
/** |
|||
* @Description 描述 |
|||
* @Author wangxianzhang |
|||
* @Date 2021/11/26 12:33 下午 |
|||
* @Version 1.0 |
|||
*/ |
|||
@Component |
|||
@Slf4j |
|||
public class BlockChainProducer { |
|||
|
|||
/** |
|||
* topic |
|||
*/ |
|||
public static final String TOPIC_PROJECT = "project"; |
|||
public static final String TOPIC_AUTH = "auth"; |
|||
|
|||
/** |
|||
* tag |
|||
*/ |
|||
public static final String TAG_SEND_PROJECT = "send_project"; |
|||
// 发送处理进展
|
|||
public static final String TAG_SEND_PROCESS = "send_process"; |
|||
// 发送流转过程中被指派的人员
|
|||
public static final String TAG_SEND_ASSIGNED_STAFFS = "send_assigned_staffs"; |
|||
// 发送处理完成的人员
|
|||
public static final String TAG_SEND_HANDLED_STAFF = "send_handled_staff"; |
|||
|
|||
/** |
|||
* 组 |
|||
*/ |
|||
public static final String GROUP_EPMET_CLOUD_PROJECT_SENDER = "epmet_cloud_project_sender"; |
|||
|
|||
private DefaultMQProducer producer; |
|||
|
|||
@Autowired |
|||
private RocketMQProperties rocketMQProperties; |
|||
|
|||
@PostConstruct |
|||
private void postConstruct() { |
|||
try { |
|||
producer = new DefaultMQProducer(GROUP_EPMET_CLOUD_PROJECT_SENDER, |
|||
new AclClientRPCHook(new SessionCredentials(rocketMQProperties.getBlockChain().getAccessKey(), rocketMQProperties.getBlockChain().getSecretKey()))); |
|||
producer.setNamesrvAddr(rocketMQProperties.getBlockChain().getNameServer()); |
|||
producer.start(); |
|||
} catch (MQClientException e) { |
|||
e.printStackTrace(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 销毁producer |
|||
*/ |
|||
@PreDestroy |
|||
private void preDestroy() { |
|||
producer.shutdown(); |
|||
} |
|||
|
|||
/** |
|||
* 发送消息 |
|||
* |
|||
* @param topic |
|||
* @param tag |
|||
*/ |
|||
public void sendMsg(String topic, String tag, String content) { |
|||
try { |
|||
Message msg = new Message(topic, tag, content.getBytes(RemotingHelper.DEFAULT_CHARSET)); |
|||
SendResult sendResult = producer.send(msg); |
|||
if (SendStatus.SEND_OK == sendResult.getSendStatus() |
|||
|| SendStatus.SLAVE_NOT_AVAILABLE == sendResult.getSendStatus()) { |
|||
log.info("消息发送区块链MQ成功, topic:{}, tag:{}, content:{}", topic, tag, content); |
|||
} else { |
|||
log.error("消息发送区块链MQ失败, topic:{}, tag:{}, content:{}, status: {}", topic, tag, content, sendResult.getSendStatus()); |
|||
} |
|||
} catch (Exception e) { |
|||
log.error("消息发送区块链MQ出错, topic:{}, tag:{}, content:{}, 错误信息:{]", topic, tag, content, ExceptionUtils.getErrorStackTrace(e)); |
|||
} |
|||
} |
|||
|
|||
} |
|||
@ -0,0 +1,33 @@ |
|||
package com.epmet.mq.properties; |
|||
|
|||
import lombok.Data; |
|||
import org.springframework.boot.context.properties.ConfigurationProperties; |
|||
|
|||
/** |
|||
* @Description 描述 |
|||
* @Author wangxianzhang |
|||
* @Date 2021/11/26 10:03 上午 |
|||
* @Version 1.0 |
|||
*/ |
|||
@ConfigurationProperties(prefix = "rocketmq") |
|||
@Data |
|||
public class RocketMQProperties { |
|||
|
|||
// 这里必须new出对象来才能成功封装
|
|||
private EpmetCloudInnerProperties epmetCloudInner = new EpmetCloudInnerProperties(); |
|||
private BlockChainProperties blockChain = new BlockChainProperties(); |
|||
|
|||
@Data |
|||
public class EpmetCloudInnerProperties { |
|||
private Boolean enable; |
|||
private String nameServer; |
|||
} |
|||
|
|||
@Data |
|||
public class BlockChainProperties { |
|||
private Boolean enable; |
|||
private String nameServer; |
|||
private String accessKey; |
|||
private String secretKey; |
|||
} |
|||
} |
|||
@ -0,0 +1,14 @@ |
|||
package com.epmet.service; |
|||
|
|||
import com.epmet.dto.form.BlockChainCreateProjectFormDTO; |
|||
import com.epmet.dto.form.BlockChainProcessProjectFormDTO; |
|||
|
|||
/** |
|||
* 区块链：项目service |
|||
*/ |
|||
public interface BlockChainProjectService { |
|||
|
|||
void blockChainCreateProject(BlockChainCreateProjectFormDTO input); |
|||
void blockChainProcessProject(BlockChainProcessProjectFormDTO input); |
|||
|
|||
} |
|||
@ -0,0 +1,204 @@ |
|||
package com.epmet.service.impl; |
|||
|
|||
import com.alibaba.fastjson.JSON; |
|||
import com.epmet.commons.tools.constant.ServiceConstant; |
|||
import com.epmet.commons.tools.exception.EpmetErrorCode; |
|||
import com.epmet.commons.tools.feign.ResultDataResolver; |
|||
import com.epmet.dto.CustomerAgencyDTO; |
|||
import com.epmet.dto.CustomerDTO; |
|||
import com.epmet.dto.CustomerGridDTO; |
|||
import com.epmet.dto.CustomerStaffDTO; |
|||
import com.epmet.dto.form.*; |
|||
import com.epmet.feign.EpmetUserOpenFeignClient; |
|||
import com.epmet.feign.GovOrgOpenFeignClient; |
|||
import com.epmet.feign.OperCrmOpenFeignClient; |
|||
import com.epmet.mq.producer.BlockChainProducer; |
|||
import com.epmet.mq.properties.RocketMQProperties; |
|||
import com.epmet.service.BlockChainProjectService; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.List; |
|||
import java.util.Optional; |
|||
|
|||
/** |
|||
* @Description 描述 |
|||
* @Author wangxianzhang |
|||
* @Date 2021/11/26 9:59 上午 |
|||
* @Version 1.0 |
|||
*/ |
|||
@Service |
|||
public class BlockChainProjectServiceImpl implements BlockChainProjectService, ResultDataResolver { |
|||
|
|||
@Autowired |
|||
private BlockChainProducer blockChainProducer; |
|||
|
|||
@Autowired |
|||
private OperCrmOpenFeignClient operCrmOpenFeignClient; |
|||
|
|||
@Autowired |
|||
private GovOrgOpenFeignClient govOrgOpenFeignClient; |
|||
|
|||
@Autowired |
|||
private EpmetUserOpenFeignClient userOpenFeignClient; |
|||
|
|||
@Override |
|||
public void blockChainCreateProject(BlockChainCreateProjectFormDTO input) { |
|||
|
|||
BlockChainProjectFormDTO project = input.getProject(); |
|||
BlockChainProjectProcessFormDTO process = input.getProcess(); |
|||
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs = input.getAssignedStaffs(); |
|||
|
|||
fill(project, process, assignedStaffs, null); |
|||
|
|||
String projectString = JSON.toJSONString(project); |
|||
String processString = JSON.toJSONString(process); |
|||
String assignedStaffsString = JSON.toJSONString(assignedStaffs); |
|||
|
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROJECT, projectString); |
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROCESS, processString); |
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_ASSIGNED_STAFFS, assignedStaffsString); |
|||
} |
|||
|
|||
/** |
|||
* 填充数据 |
|||
* @param project |
|||
* @param process |
|||
*/ |
|||
private void fill(BlockChainProjectFormDTO project, BlockChainProjectProcessFormDTO process, |
|||
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs, BlockChainProjectProcessAssignedStaffFormDTO handledStaff) { |
|||
|
|||
// 一.填充project信息
|
|||
|
|||
if (project != null) { |
|||
// 客户信息
|
|||
CustomerDTO customerDTO = new CustomerDTO(); |
|||
customerDTO.setId(project.getCustomerId()); |
|||
CustomerDTO customerInfo = getResultDataOrThrowsException(operCrmOpenFeignClient.getCustomerInfo(customerDTO), |
|||
ServiceConstant.EPMET_THIRD_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询客户信息失败", null); |
|||
|
|||
// 组织信息
|
|||
CustomerAgencyDTO agencyInfo = getResultDataOrThrowsException(govOrgOpenFeignClient.getAgencyById(project.getAgencyId()), |
|||
ServiceConstant.GOV_ORG_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询Agency信息失败", null); |
|||
|
|||
// 用户信息
|
|||
CustomerStaffDTO customerStaffDTO = new CustomerStaffDTO(); |
|||
customerStaffDTO.setUserId(project.getCreatedBy()); |
|||
CustomerStaffDTO staffInfo = getResultDataOrThrowsException(userOpenFeignClient.getCustomerStaffInfoByUserId(customerStaffDTO), |
|||
ServiceConstant.EPMET_USER_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询用户信息失败", null); |
|||
|
|||
project.setCustomerName(customerInfo.getCustomerName()); |
|||
project.setAgencyName(agencyInfo.getOrganizationName()); |
|||
Optional.of(staffInfo).ifPresent((staff) -> project.setCreaterName(staff.getRealName())); |
|||
} |
|||
|
|||
// 二.填充进展信息
|
|||
|
|||
if (process != null) { |
|||
|
|||
if (StringUtils.isNotBlank(process.getAgencyId())) { |
|||
// 组织信息
|
|||
CustomerAgencyDTO processAgencyInfo = getResultDataOrThrowsException(govOrgOpenFeignClient.getAgencyById(process.getAgencyId()), |
|||
ServiceConstant.GOV_ORG_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询处理节点Agency信息失败", null); |
|||
|
|||
process.setAgencyName(processAgencyInfo.getOrganizationName()); |
|||
} |
|||
|
|||
// 网格信息
|
|||
if (StringUtils.isNotBlank(process.getGridId())) { |
|||
CustomerGridFormDTO processGridFormDTO = new CustomerGridFormDTO(); |
|||
processGridFormDTO.setGridId(process.getGridId()); |
|||
CustomerGridDTO processGridInfo = getResultDataOrThrowsException(govOrgOpenFeignClient.getCustomerGridByGridId(processGridFormDTO), |
|||
ServiceConstant.GOV_ORG_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询处理节点网格信息失败", null); |
|||
|
|||
Optional.of(processGridInfo).ifPresent((grid) -> process.setGridName(grid.getGridName())); |
|||
} |
|||
|
|||
// 用户信息
|
|||
CustomerStaffDTO processCustomerStaffDTO = new CustomerStaffDTO(); |
|||
processCustomerStaffDTO.setUserId(process.getStaffId()); |
|||
CustomerStaffDTO processStaffInfo = getResultDataOrThrowsException(userOpenFeignClient.getCustomerStaffInfoByUserId(processCustomerStaffDTO), |
|||
ServiceConstant.EPMET_USER_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询处理节点用户信息失败", null); |
|||
|
|||
process.setStaffName(processStaffInfo.getRealName()); |
|||
process.setCreatedBy(processStaffInfo.getRealName()); |
|||
|
|||
} |
|||
|
|||
// 三.填充指派用户信息
|
|||
if (assignedStaffs != null) { |
|||
for (BlockChainProjectProcessAssignedStaffFormDTO assignedStaff : assignedStaffs) { |
|||
fillAssignedStaffInfo(assignedStaff); |
|||
} |
|||
} |
|||
|
|||
// 4.填充当前处理人信息
|
|||
if (handledStaff != null) { |
|||
fillAssignedStaffInfo(handledStaff); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 填充被指派人的信息 |
|||
* @param assignedStaff |
|||
*/ |
|||
private void fillAssignedStaffInfo(BlockChainProjectProcessAssignedStaffFormDTO assignedStaff) { |
|||
// 组织信息
|
|||
if (StringUtils.isNotBlank(assignedStaff.getOrgId())) { |
|||
CustomerAgencyDTO assignedStaffAgencyInfo = getResultDataOrThrowsException(govOrgOpenFeignClient.getAgencyById(assignedStaff.getOrgId()), |
|||
ServiceConstant.GOV_ORG_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询指派人员组织信息失败", null); |
|||
|
|||
assignedStaff.setOrgName(assignedStaffAgencyInfo.getOrganizationName()); |
|||
} |
|||
|
|||
// 网格信息
|
|||
if (StringUtils.isNotBlank(assignedStaff.getGridId())) { |
|||
CustomerGridFormDTO assignedStaffGridFormDTO = new CustomerGridFormDTO(); |
|||
assignedStaffGridFormDTO.setGridId(assignedStaff.getGridId()); |
|||
CustomerGridDTO assignedStaffProcessGridInfo = getResultDataOrThrowsException(govOrgOpenFeignClient.getCustomerGridByGridId(assignedStaffGridFormDTO), |
|||
ServiceConstant.GOV_ORG_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询指派人员网格信息失败", null); |
|||
|
|||
Optional.of(assignedStaffProcessGridInfo).ifPresent((gridOfStaff) -> assignedStaff.setGridName(gridOfStaff.getGridName())); |
|||
} |
|||
|
|||
// 指派用户
|
|||
CustomerStaffDTO assignedStaffDTO = new CustomerStaffDTO(); |
|||
assignedStaffDTO.setUserId(assignedStaff.getStaffId()); |
|||
CustomerStaffDTO assignedStaffInfo = getResultDataOrThrowsException(userOpenFeignClient.getCustomerStaffInfoByUserId(assignedStaffDTO), |
|||
ServiceConstant.EPMET_USER_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询指派用户信息失败", null); |
|||
|
|||
assignedStaff.setStaffName(assignedStaffInfo.getRealName()); |
|||
|
|||
// 创建者
|
|||
CustomerStaffDTO createStaffDTO = new CustomerStaffDTO(); |
|||
createStaffDTO.setUserId(assignedStaff.getCreatedBy()); |
|||
CustomerStaffDTO createStaffInfo = getResultDataOrThrowsException(userOpenFeignClient.getCustomerStaffInfoByUserId(createStaffDTO), |
|||
ServiceConstant.EPMET_USER_SERVER, EpmetErrorCode.SERVER_ERROR.getCode(), "【项目信息上链】查询指派用户信息失败", null); |
|||
|
|||
Optional.of(createStaffInfo).ifPresent((createStaff) -> assignedStaff.setCreaterName(createStaffInfo.getRealName())); |
|||
} |
|||
|
|||
@Override |
|||
public void blockChainProcessProject(BlockChainProcessProjectFormDTO input) { |
|||
|
|||
BlockChainProjectProcessFormDTO process = input.getProcess(); |
|||
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs = input.getAssignedStaffs(); |
|||
BlockChainProjectProcessAssignedStaffFormDTO handledStaff = input.getHandledStaff(); |
|||
|
|||
fill(null, process, assignedStaffs, handledStaff); |
|||
|
|||
String processString = JSON.toJSONString(process); |
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_PROCESS, processString); |
|||
|
|||
if (assignedStaffs != null && assignedStaffs.size() > 0) { |
|||
String assignedStaffsString = JSON.toJSONString(assignedStaffs); |
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_ASSIGNED_STAFFS, assignedStaffsString); |
|||
} |
|||
|
|||
if (handledStaff != null) { |
|||
String handledStaffString = JSON.toJSONString(handledStaff); |
|||
blockChainProducer.sendMsg(BlockChainProducer.TOPIC_PROJECT, BlockChainProducer.TAG_SEND_HANDLED_STAFF, handledStaffString); |
|||
} |
|||
} |
|||
} |
|||
@ -0,0 +1,20 @@ |
|||
package com.epmet.service; |
|||
|
|||
import com.epmet.entity.ProjectEntity; |
|||
import com.epmet.entity.ProjectProcessEntity; |
|||
import com.epmet.entity.ProjectStaffEntity; |
|||
|
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 上链service接口 |
|||
*/ |
|||
public interface BlockChainUploadService { |
|||
|
|||
/** |
|||
* 数据上链 |
|||
* @param processEntity 处理进展entity |
|||
* @param assignedStaffEntities 指派给的工作人员entity |
|||
*/ |
|||
void send2BlockChain(ProjectEntity projectEntity, ProjectProcessEntity processEntity, List<ProjectStaffEntity> assignedStaffEntities, String projectStaffId); |
|||
} |
|||
@ -0,0 +1,147 @@ |
|||
package com.epmet.service.impl; |
|||
|
|||
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
|||
import com.epmet.dao.ProjectStaffDao; |
|||
import com.epmet.dto.form.*; |
|||
import com.epmet.entity.ProjectEntity; |
|||
import com.epmet.entity.ProjectProcessEntity; |
|||
import com.epmet.entity.ProjectStaffEntity; |
|||
import com.epmet.feign.EpmetThirdOpenFeignClient; |
|||
import com.epmet.service.BlockChainUploadService; |
|||
import org.apache.commons.collections4.CollectionUtils; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.List; |
|||
import java.util.stream.Collectors; |
|||
|
|||
/** |
|||
* 区块链上链service实现 |
|||
*/ |
|||
@Service |
|||
public class BlockChainUploadServiceImpl implements BlockChainUploadService { |
|||
|
|||
@Autowired |
|||
private EpmetThirdOpenFeignClient thirdOpenFeignClient; |
|||
|
|||
@Autowired |
|||
private ProjectStaffDao projectStaffDao; |
|||
|
|||
/** |
|||
* 数据上链 |
|||
* @param processEntity 处理进展entity |
|||
* @param assignedStaffEntities 指派给的工作人员entity |
|||
*/ |
|||
public void send2BlockChain(ProjectEntity projectEntity, ProjectProcessEntity processEntity, List<ProjectStaffEntity> assignedStaffEntities, String projectStaffId) { |
|||
|
|||
// 1.项目主信息
|
|||
BlockChainProjectFormDTO project = null; |
|||
|
|||
if (projectEntity != null) { |
|||
project = new BlockChainProjectFormDTO(); |
|||
project.setAgencyId(projectEntity.getAgencyId()); |
|||
project.setProjectId(projectEntity.getId()); |
|||
project.setCustomerId(projectEntity.getCustomerId()); |
|||
project.setCreatedBy(projectEntity.getCreatedBy()); |
|||
project.setCreatedTime(projectEntity.getCreatedTime()); |
|||
project.setCloseStatus(projectEntity.getClosedStatus()); |
|||
project.setLocateAddress(projectEntity.getLocateAddress()); |
|||
project.setLocateDimension(projectEntity.getLocateDimension()); |
|||
project.setLocateLongitude(projectEntity.getLocateLongitude()); |
|||
project.setOrgIdPath(projectEntity.getOrgIdPath()); |
|||
project.setOrigin(projectEntity.getOrigin()); |
|||
project.setOriginId(projectEntity.getOriginId()); |
|||
project.setStatus(projectEntity.getStatus()); |
|||
project.setTitle(projectEntity.getTitle()); |
|||
} |
|||
|
|||
// 2.项目处理进展
|
|||
BlockChainProjectProcessFormDTO process = new BlockChainProjectProcessFormDTO(); |
|||
process.setProcessId(processEntity.getId()); |
|||
process.setCreatedBy(processEntity.getCreatedBy()); |
|||
process.setCreatedTime(processEntity.getCreatedTime()); |
|||
process.setCostWorkDays(processEntity.getCostWorkdays()); |
|||
process.setAgencyId(processEntity.getAgencyId()); |
|||
process.setCustomerId(processEntity.getCustomerId()); |
|||
process.setDepartmentId(processEntity.getDepartmentId()); |
|||
process.setDepartmentName(processEntity.getDepartmentName()); |
|||
process.setEndTime(processEntity.getEndTime()); |
|||
process.setGridId(processEntity.getGridId()); |
|||
process.setInternalRemark(processEntity.getInternalRemark()); |
|||
process.setIsSend(processEntity.getIsSend()); |
|||
process.setOperation(processEntity.getOperation()); |
|||
process.setOperationName(processEntity.getOperationName()); |
|||
process.setOrgIdPath(processEntity.getOrgIdPath()); |
|||
process.setProjectId(processEntity.getProjectId()); |
|||
process.setPublicReply(processEntity.getPublicReply()); |
|||
process.setStaffId(processEntity.getStaffId()); |
|||
|
|||
if (assignedStaffEntities == null) { |
|||
LambdaQueryWrapper<ProjectStaffEntity> query = new LambdaQueryWrapper<>(); |
|||
query.eq(ProjectStaffEntity::getProcessId, process.getProjectId()); |
|||
assignedStaffEntities = projectStaffDao.selectList(query); |
|||
} |
|||
|
|||
if (CollectionUtils.isEmpty(assignedStaffEntities)) { |
|||
assignedStaffEntities = new ArrayList<>(); |
|||
} |
|||
|
|||
// 3.指派人员列表
|
|||
List<BlockChainProjectProcessAssignedStaffFormDTO> assignedStaffs = assignedStaffEntities.stream().map(e -> { |
|||
BlockChainProjectProcessAssignedStaffFormDTO assignedStaff = new BlockChainProjectProcessAssignedStaffFormDTO(); |
|||
assignedStaff.setStaffId(e.getStaffId()); |
|||
assignedStaff.setCreatedBy(e.getCreatedBy()); |
|||
assignedStaff.setCustomerId(e.getCustomerId()); |
|||
assignedStaff.setCreatedTime(e.getCreatedTime()); |
|||
assignedStaff.setProcessId(e.getProcessId()); |
|||
assignedStaff.setDepartmentId(e.getDepartmentId()); |
|||
assignedStaff.setDepartmentName(e.getDepartmentName()); |
|||
assignedStaff.setGridId(e.getGridId()); |
|||
assignedStaff.setId(e.getId()); |
|||
assignedStaff.setIsHandle(e.getIsHandle()); |
|||
assignedStaff.setOrgId(e.getOrgId()); |
|||
assignedStaff.setOrgIdPath(e.getOrgIdPath()); |
|||
assignedStaff.setProjectId(e.getProjectId()); |
|||
return assignedStaff; |
|||
}).collect(Collectors.toList()); |
|||
|
|||
// 4.当前处理人
|
|||
BlockChainProjectProcessAssignedStaffFormDTO handledStaff = null; |
|||
if (StringUtils.isNotBlank(projectStaffId)) { |
|||
ProjectStaffEntity handledStaffEntity = projectStaffDao.selectById(projectStaffId); |
|||
|
|||
handledStaff = new BlockChainProjectProcessAssignedStaffFormDTO(); |
|||
handledStaff.setStaffId(handledStaffEntity.getStaffId()); |
|||
handledStaff.setCreatedBy(handledStaffEntity.getCreatedBy()); |
|||
handledStaff.setCustomerId(handledStaffEntity.getCustomerId()); |
|||
handledStaff.setCreatedTime(handledStaffEntity.getCreatedTime()); |
|||
handledStaff.setProcessId(handledStaffEntity.getProcessId()); |
|||
handledStaff.setDepartmentId(handledStaffEntity.getDepartmentId()); |
|||
handledStaff.setDepartmentName(handledStaffEntity.getDepartmentName()); |
|||
handledStaff.setGridId(handledStaffEntity.getGridId()); |
|||
handledStaff.setId(handledStaffEntity.getId()); |
|||
handledStaff.setIsHandle(handledStaffEntity.getIsHandle()); |
|||
handledStaff.setOrgId(handledStaffEntity.getOrgId()); |
|||
handledStaff.setOrgIdPath(handledStaffEntity.getOrgIdPath()); |
|||
handledStaff.setProjectId(handledStaffEntity.getProjectId()); |
|||
} |
|||
|
|||
if (project == null) { |
|||
// 处理
|
|||
BlockChainProcessProjectFormDTO processForm = new BlockChainProcessProjectFormDTO(); |
|||
processForm.setProcess(process); |
|||
processForm.setAssignedStaffs(assignedStaffs); |
|||
processForm.setHandledStaff(handledStaff); |
|||
thirdOpenFeignClient.blockChainProcessProject(processForm); |
|||
} else { |
|||
// 立项
|
|||
BlockChainCreateProjectFormDTO createForm = new BlockChainCreateProjectFormDTO(); |
|||
createForm.setProject(project); |
|||
createForm.setProcess(process); |
|||
createForm.setAssignedStaffs(assignedStaffs); |
|||
thirdOpenFeignClient.blockChainCreateProject(createForm); |
|||
} |
|||
} |
|||
} |
|||
Some files were not shown because too many files changed in this diff
Loading…
Reference in new issue