Commit 003151c3 authored by 赵啸非's avatar 赵啸非

修改部分接口返回参数

parent 24a6f2ae
...@@ -22,9 +22,6 @@ import java.util.HashMap; ...@@ -22,9 +22,6 @@ import java.util.HashMap;
@Slf4j @Slf4j
public class MqConsumer { public class MqConsumer {
@Autowired
private ApplyService applyService;
@Autowired @Autowired
private ComplexService complexService; private ComplexService complexService;
...@@ -36,7 +33,6 @@ public class MqConsumer { ...@@ -36,7 +33,6 @@ public class MqConsumer {
@JmsListener(destination = "${api.mq}", containerFactory = "jmsListenerContainerQueue") @JmsListener(destination = "${api.mq}", containerFactory = "jmsListenerContainerQueue")
public void receiveMsg(HashMap<String, String> text) { public void receiveMsg(HashMap<String, String> text) {
// log.info("receive msg==>{}", JSONUtil.toJsonStr(text));
RobotCaseRecord caseRecord = new RobotCaseRecord(); RobotCaseRecord caseRecord = new RobotCaseRecord();
caseRecord.setId(IdUtil.simpleUUID()); caseRecord.setId(IdUtil.simpleUUID());
caseRecord.setContent(text.get("content")); caseRecord.setContent(text.get("content"));
...@@ -45,20 +41,9 @@ public class MqConsumer { ...@@ -45,20 +41,9 @@ public class MqConsumer {
caseRecord.setUpdateTime(new Date()); caseRecord.setUpdateTime(new Date());
try { try {
robotApi.saveRecord(caseRecord); robotApi.saveRecord(caseRecord);
String content = text.get("content"); String content = text.get("content");
ReceiveMsgInfo receiveMsgInfo = JSON.parseObject(content, ReceiveMsgInfo.class); ReceiveMsgInfo receiveMsgInfo = JSON.parseObject(content, ReceiveMsgInfo.class);
complexService.windowApply(receiveMsgInfo);
// HashMap<String, Object> entries = JSONUtil.toBean(text.get("content"), HashMap.class);
// String apply = applyService.webApply(entries);
String apply = complexService.windowApply(receiveMsgInfo);
/* if (ObjectUtils.isEmpty(apply)) {
caseRecord.setSendFlag("2");
caseRecord.setMsg("success");
} else {
caseRecord.setSendFlag("1");
caseRecord.setMsg(apply);
}*/
robotApi.saveRecord(caseRecord); robotApi.saveRecord(caseRecord);
} catch (Exception e) { } catch (Exception e) {
caseRecord.setSendFlag("1"); caseRecord.setSendFlag("1");
...@@ -66,8 +51,5 @@ public class MqConsumer { ...@@ -66,8 +51,5 @@ public class MqConsumer {
robotApi.saveRecord(caseRecord); robotApi.saveRecord(caseRecord);
log.error(e.getMessage()); log.error(e.getMessage());
} }
} }
} }
...@@ -34,7 +34,6 @@ import java.util.Map; ...@@ -34,7 +34,6 @@ import java.util.Map;
@Slf4j @Slf4j
public class ComplexService extends PublicService { public class ComplexService extends PublicService {
@Autowired @Autowired
private OcrApi ocrApi; private OcrApi ocrApi;
...@@ -51,21 +50,17 @@ public class ComplexService extends PublicService { ...@@ -51,21 +50,17 @@ public class ComplexService extends PublicService {
* 综窗申报 * 综窗申报
*/ */
public String windowApply(ReceiveMsgInfo receiveMsgInfo) throws Exception { public String windowApply(ReceiveMsgInfo receiveMsgInfo) throws Exception {
logger.info(JSONUtil.toJsonStr(receiveMsgInfo)); logger.info(JSONUtil.toJsonStr(receiveMsgInfo));
Boolean success = receiveMsgInfo.getSuccess(); Boolean success = receiveMsgInfo.getSuccess();
if (success) { if (success) {
ComplexWindowAbstract complexWindowAbstract = ComplexWindowAbstract.newType(receiveMsgInfo.getItemCode()); ComplexWindowAbstract complexWindowAbstract = ComplexWindowAbstract.newType(receiveMsgInfo.getItemCode());
CommonData commonData = new CommonData(); CommonData commonData = new CommonData();
commonData.setRobertServerUrl(robertServerUrl); commonData.setRobertServerUrl(robertServerUrl);
commonData.setComplexServerUrl(complexServerUrl); commonData.setComplexServerUrl(complexServerUrl);
commonData.setDeviceLogo(deviceCode); commonData.setDeviceLogo(deviceCode);
commonData.setFileData(receiveMsgInfo.getFileData()); commonData.setFileData(receiveMsgInfo.getFileData());
//设置申请人信息 //设置申请人信息
Map<String, String> userData = receiveMsgInfo.getUserData(); Map<String, String> userData = receiveMsgInfo.getUserData();
//申请人信息 //申请人信息
commonData.setApplicantName(userData.getOrDefault("applicantName","")); commonData.setApplicantName(userData.getOrDefault("applicantName",""));
//申请人性别 //申请人性别
...@@ -76,20 +71,15 @@ public class ComplexService extends PublicService { ...@@ -76,20 +71,15 @@ public class ComplexService extends PublicService {
commonData.setApplicantPhone(userData.getOrDefault("applicantPhone","")); commonData.setApplicantPhone(userData.getOrDefault("applicantPhone",""));
//申请人证件 //申请人证件
commonData.setApplicantDocumentId("111"); commonData.setApplicantDocumentId("111");
//设置法人信息 //设置法人信息
commonData.setLegalName(userData.getOrDefault("legalName",""));//营业执照法人姓名 commonData.setLegalName(userData.getOrDefault("legalName",""));//营业执照法人姓名
commonData.setLegalIdNumber(userData.getOrDefault("legalIdNumber",""));//法人id号 commonData.setLegalIdNumber(userData.getOrDefault("legalIdNumber",""));//法人id号
commonData.setLegalSex(userData.getOrDefault("legalSex",""));//法人性别 commonData.setLegalSex(userData.getOrDefault("legalSex",""));//法人性别
commonData.setLegalDocumentId("111"); commonData.setLegalDocumentId("111");
//commonData.setUserMap();
complexWindowAbstract.doHandleWork(commonData); complexWindowAbstract.doHandleWork(commonData);
} else { } else {
log.info("预审事项未通过"); log.info("预审事项未通过");
} }
String result = "";//返回结果 String result = "";//返回结果
boolean check = true;//事项是否查找到,默认事项已经查找到 boolean check = true;//事项是否查找到,默认事项已经查找到
return result; return result;
......
...@@ -26,10 +26,6 @@ public abstract class AbstractComplexService implements IComplexMatterService { ...@@ -26,10 +26,6 @@ public abstract class AbstractComplexService implements IComplexMatterService {
//综窗接件token deviceCode--对应tokenMap //综窗接件token deviceCode--对应tokenMap
public static Map<String, String> tokenMap=new HashMap<>(); public static Map<String, String> tokenMap=new HashMap<>();
//综窗接件token
public String token;
@Override @Override
public String getToken(String deviceLogo) { public String getToken(String deviceLogo) {
try { try {
......
...@@ -60,9 +60,7 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -60,9 +60,7 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
String uploadApi = host + "common/uploadFileToFtp?conversionImage=Y"; String uploadApi = host + "common/uploadFileToFtp?conversionImage=Y";
HttpRequest request = HttpRequest.post(uploadApi); HttpRequest request = HttpRequest.post(uploadApi);
String deviceToken = checkToken(deviceLogo); String deviceToken = checkToken(deviceLogo);
request.form("file", bytes, fileName); request.form("file", bytes, fileName);
String uploadRest = request.header("X-Access-Token", deviceToken).execute().body(); String uploadRest = request.header("X-Access-Token", deviceToken).execute().body();
ComplexApiRest<String> complexApiRest = JSON.parseObject(uploadRest, new TypeReference<ComplexApiRest<String>>() { ComplexApiRest<String> complexApiRest = JSON.parseObject(uploadRest, new TypeReference<ComplexApiRest<String>>() {
...@@ -76,15 +74,12 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -76,15 +74,12 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
@Override @Override
public Rest<List<AcceptRspInfo>> accept(String deviceLogo, AcceptReq acceptReq) { public Rest<List<AcceptRspInfo>> accept(String deviceLogo, AcceptReq acceptReq) {
String deviceLoginApi = host + "self-device-info/acceptHandling"; String deviceLoginApi = host + "self-device-info/acceptHandling";
log.info("accept req==>{}",JSON.toJSONString(acceptReq)); log.info("accept req==>{}",JSON.toJSONString(acceptReq));
String deviceToken = checkToken(deviceLogo); String deviceToken = checkToken(deviceLogo);
String rest = HttpUtil.createPost(deviceLoginApi) String rest = HttpUtil.createPost(deviceLoginApi)
.header("X-Access-Token", deviceToken) .header("X-Access-Token", deviceToken)
.body(JSON.toJSONString(acceptReq)) .body(JSON.toJSONString(acceptReq))
.execute().body(); .execute().body();
log.info("accept resp==>{}",rest); log.info("accept resp==>{}",rest);
ComplexApiRest<List<AcceptRspInfo>> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<List<AcceptRspInfo>>>() { ComplexApiRest<List<AcceptRspInfo>> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<List<AcceptRspInfo>>>() {
}); });
...@@ -98,7 +93,6 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -98,7 +93,6 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
@Override @Override
public Rest<MatterListInfo> findMatters(String deviceLogo, ImplementationReq implementationReq) { public Rest<MatterListInfo> findMatters(String deviceLogo, ImplementationReq implementationReq) {
String mattersApi = host + "event-implementation/list"; String mattersApi = host + "event-implementation/list";
Map<String, String> paramMap = new HashMap<>(); Map<String, String> paramMap = new HashMap<>();
// 将Map中的属性值转为字符串 // 将Map中的属性值转为字符串
for (Map.Entry<String, Object> entry : BeanUtil.beanToMap(implementationReq, false, true).entrySet()) { for (Map.Entry<String, Object> entry : BeanUtil.beanToMap(implementationReq, false, true).entrySet()) {
...@@ -107,14 +101,11 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -107,14 +101,11 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
String stringValue = String.valueOf(value); String stringValue = String.valueOf(value);
paramMap.put(key, stringValue); paramMap.put(key, stringValue);
} }
String deviceToken = checkToken(deviceLogo); String deviceToken = checkToken(deviceLogo);
String rest = HttpUtil.createGet(mattersApi) String rest = HttpUtil.createGet(mattersApi)
.header("X-Access-Token", deviceToken) .header("X-Access-Token", deviceToken)
.formStr(paramMap) .formStr(paramMap)
.execute().body(); .execute().body();
ComplexApiRest<MatterListInfo> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<MatterListInfo>>() { ComplexApiRest<MatterListInfo> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<MatterListInfo>>() {
}); });
if (complexApiRest.getCode() == 200) { if (complexApiRest.getCode() == 200) {
...@@ -126,10 +117,8 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -126,10 +117,8 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
@Override @Override
public Rest<MatterWorkInfo> doWorkMatterSearch(String deviceLogo, String eventIds) { public Rest<MatterWorkInfo> doWorkMatterSearch(String deviceLogo, String eventIds) {
String mattersApi = host + "bus-situation-material/getSituationMaterialTreeByEventIds"; String mattersApi = host + "bus-situation-material/getSituationMaterialTreeByEventIds";
Map<String, String> paramMap = new HashMap<>(); Map<String, String> paramMap = new HashMap<>();
paramMap.put("eventIds", eventIds); paramMap.put("eventIds", eventIds);
String deviceToken = checkToken(deviceLogo); String deviceToken = checkToken(deviceLogo);
String rest = HttpUtil.createGet(mattersApi) String rest = HttpUtil.createGet(mattersApi)
.header("X-Access-Token", deviceToken) .header("X-Access-Token", deviceToken)
...@@ -151,17 +140,13 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements ...@@ -151,17 +140,13 @@ public class ComplexMatterServiceImpl extends AbstractComplexService implements
@Override @Override
public Rest<WorkInfo> getWorkMatter(String deviceLogo, String eventIds) { public Rest<WorkInfo> getWorkMatter(String deviceLogo, String eventIds) {
String mattersApi = host + "event-implementation/getDynamicFormByEventIds"; String mattersApi = host + "event-implementation/getDynamicFormByEventIds";
ArrayList<String> list = new ArrayList<>(); ArrayList<String> list = new ArrayList<>();
list.add(eventIds); list.add(eventIds);
String deviceToken = checkToken(deviceLogo); String deviceToken = checkToken(deviceLogo);
String rest = HttpUtil.createPost(mattersApi) String rest = HttpUtil.createPost(mattersApi)
.header("X-Access-Token", deviceToken) .header("X-Access-Token", deviceToken)
.body(JSON.toJSONString(list)) .body(JSON.toJSONString(list))
.execute().body(); .execute().body();
ComplexApiRest<WorkInfo> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<WorkInfo>>() { ComplexApiRest<WorkInfo> complexApiRest = JSON.parseObject(rest, new TypeReference<ComplexApiRest<WorkInfo>>() {
}); });
if (complexApiRest.getCode() == 200) { if (complexApiRest.getCode() == 200) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment