Browse Source

市北接口调用

feature/dangjian
lichao 3 years ago
parent
commit
cf48730d09
  1. 7
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/controller/PushToCityGridController.java
  2. 7
      esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java
  3. 2
      esua-epdc/epdc-module/epdc-message/epdc-message-server/pom.xml

7
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/controller/PushToCityGridController.java

@ -5,10 +5,7 @@ import com.elink.esua.epdc.dto.item.ItemHandleProcessDTO;
import com.elink.esua.epdc.dto.item.form.GetAbnormalDataFormDTO;
import com.elink.esua.epdc.modules.item.service.PushToCityGridService;
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;
import org.springframework.web.bind.annotation.*;
@RestController
@RequestMapping("PushToCity")
@ -104,7 +101,7 @@ public class PushToCityGridController {
* @Author: lichao
* @Date: 2023/5/4 14:14
*/
@PostMapping("receive")
@GetMapping("receive")
public Result receive(String processId) {
pushToCityGridService.receive(processId);
return new Result();

7
esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/PushToCityGridServiceImpl.java

@ -1425,6 +1425,9 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
if (item == null) {
return;
}
if (item.getState() == 1111){
return;
}
ReceiveResultDTO dto = new ReceiveResultDTO();
dto.setSqid(getSqid(item.getItemId()));
@ -1452,8 +1455,10 @@ public class PushToCityGridServiceImpl implements PushToCityGridService {
saveLog(item.getItemId(), item.getId(), "响应接收", PushToCityGridConstant.RECEIVE, JSONObject.toJSONString(dto), result);
item.setState(1111);
itemHandleProcessDao.updateById(item);
}
}
private void extracted(List<String> sqIdList, Integer itemState) {
//50个一组

2
esua-epdc/epdc-module/epdc-message/epdc-message-server/pom.xml

@ -217,7 +217,7 @@
<spring.datasource.druid.password>Elink@833066</spring.datasource.druid.password>
<!-- nacos -->
<nacos.register-enabled>true</nacos.register-enabled>
<nacos.server-addr>172.16.0.53:8848</nacos.server-addr>
<nacos.server-addr>192.168.203.32:8848</nacos.server-addr>
<nacos.ip></nacos.ip>
<nacos.namespace></nacos.namespace>
</properties>

Loading…
Cancel
Save