Commit f111ce96 authored by hanbing's avatar hanbing

静态信息接口-路口数据完成

parent 0adc6970
...@@ -36,8 +36,7 @@ public class StaticInfoController { ...@@ -36,8 +36,7 @@ public class StaticInfoController {
outVO.setSystemAbbr(Constants.SYSTEM_ABBR); outVO.setSystemAbbr(Constants.SYSTEM_ABBR);
staticInfoService.crossBasicInfo(outVO); staticInfoService.crossBasicInfo(outVO);
// todo 返回值 return ResponseEntity.ok("success");
return null;
} }
} }
...@@ -3,10 +3,14 @@ package net.wanji.utc.mapper; ...@@ -3,10 +3,14 @@ package net.wanji.utc.mapper;
import net.wanji.utc.po.CrossInfoPO; import net.wanji.utc.po.CrossInfoPO;
import org.apache.ibatis.annotations.Param; import org.apache.ibatis.annotations.Param;
import java.util.List;
/** /**
* @author Kent HAN * @author Kent HAN
* @date 2022/11/15 14:57 * @date 2022/11/15 14:57
*/ */
public interface CrossInfoMapper { public interface CrossInfoMapper {
CrossInfoPO selectByPrimaryKey(@Param("key") String key); CrossInfoPO selectByPrimaryKey(@Param("key") String key);
void insertBatch(@Param("entities") List<CrossInfoPO> crossInfoPOList);
} }
package net.wanji.utc.service; package net.wanji.utc.service;
import net.wanji.utc.common.baseentity.BaseCrossInfo; import net.wanji.utc.common.baseentity.BaseCrossInfo;
import net.wanji.utc.common.genericentity.ManufacturerRes;
import net.wanji.utc.common.genericentity.OutVO; import net.wanji.utc.common.genericentity.OutVO;
import net.wanji.utc.vo.DetailCrossInfoVO;
public interface StaticInfoService { public interface StaticInfoService {
void crossBasicInfo(OutVO<BaseCrossInfo> outVO); ManufacturerRes<DetailCrossInfoVO> crossBasicInfo(OutVO<BaseCrossInfo> outVO);
} }
...@@ -2,6 +2,7 @@ package net.wanji.utc.service.impl; ...@@ -2,6 +2,7 @@ package net.wanji.utc.service.impl;
import net.wanji.utc.common.genericentity.ManufacturerRes; import net.wanji.utc.common.genericentity.ManufacturerRes;
import net.wanji.utc.common.typeenum.BasicEnum; import net.wanji.utc.common.typeenum.BasicEnum;
import net.wanji.utc.mapper.CrossInfoMapper;
import net.wanji.utc.po.CrossInfoPO; import net.wanji.utc.po.CrossInfoPO;
import net.wanji.utc.service.HkService; import net.wanji.utc.service.HkService;
import net.wanji.utc.service.StaticInfoService; import net.wanji.utc.service.StaticInfoService;
...@@ -23,9 +24,11 @@ import java.util.Objects; ...@@ -23,9 +24,11 @@ import java.util.Objects;
public class StaticInfoServiceImpl implements StaticInfoService { public class StaticInfoServiceImpl implements StaticInfoService {
@Autowired @Autowired
HkService hkService; HkService hkService;
@Autowired
CrossInfoMapper crossInfoMapper;
@Override @Override
public void crossBasicInfo(OutVO<BaseCrossInfo> outVO) { public ManufacturerRes<DetailCrossInfoVO> crossBasicInfo(OutVO<BaseCrossInfo> outVO) {
List<CrossInfoPO> crossInfoPOList = new ArrayList<>(); List<CrossInfoPO> crossInfoPOList = new ArrayList<>();
ManufacturerRes<DetailCrossInfoVO> res = new ManufacturerRes<>(); ManufacturerRes<DetailCrossInfoVO> res = new ManufacturerRes<>();
if (Objects.equals(BasicEnum.ManufacturerEnum.HK.getAbbr(), outVO.getManufacturerAbbr())) { if (Objects.equals(BasicEnum.ManufacturerEnum.HK.getAbbr(), outVO.getManufacturerAbbr())) {
...@@ -33,7 +36,11 @@ public class StaticInfoServiceImpl implements StaticInfoService { ...@@ -33,7 +36,11 @@ public class StaticInfoServiceImpl implements StaticInfoService {
} else { } else {
// todo 其他厂商 // todo 其他厂商
} }
//存储信号机信息
if (crossInfoPOList.size() == 0) {
return null;
}
crossInfoMapper.insertBatch(crossInfoPOList);
return res;
} }
} }
...@@ -16,6 +16,15 @@ ...@@ -16,6 +16,15 @@
<result property="gmtModified" column="gmt_modified"/> <result property="gmtModified" column="gmt_modified"/>
</resultMap> </resultMap>
<!-- 批量新增数据 -->
<insert id="insertBatch" keyProperty="id" useGeneratedKeys="true">
insert into t_cross_info(id,name,code,manufacturer_id,ip,port,location,version,model,install_time)
values
<foreach collection="entities" item="entity" separator=",">
(#{entity.id},#{entity.name},#{entity.code},#{entity.manufacturerId},#{entity.ip},#{entity.port},#{entity.location},#{entity.version},#{entity.model},#{entity.installTime})
</foreach>
</insert>
<select id="selectByPrimaryKey" resultMap="BaseResultMap"> <select id="selectByPrimaryKey" resultMap="BaseResultMap">
select select
id,name,code,manufacturer_id,ip,port,location,version,model,install_time,gmt_create,gmt_modified id,name,code,manufacturer_id,ip,port,location,version,model,install_time,gmt_create,gmt_modified
......
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