diff --git a/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java index 373b11a..2c0f79d 100644 --- a/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java +++ b/src/main/java/com/ssf/mysqloracletest/domain/JcjJjxxViewMysql.java @@ -5,6 +5,7 @@ import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.annotation.TableName; import lombok.Data; + import java.io.Serializable; /** @@ -783,4 +784,13 @@ public class JcjJjxxViewMysql implements Serializable { @TableField(value = "STATUS") private String STATUS; + + @TableField(exist = false) + private String LEFTTOPLONGITUDE; + @TableField(exist = false) + private String RIGHTBOTTOMLONGITUDE; + @TableField(exist = false) + private String RIGHTBOTTOMLATITUDE; + @TableField(exist = false) + private String LEFTTOPLATITUDE; } \ No newline at end of file diff --git a/src/main/java/com/ssf/mysqloracletest/mapper/JcjJxxViewMysqlMapper.java b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJxxViewMysqlMapper.java index 264e582..639f63b 100644 --- a/src/main/java/com/ssf/mysqloracletest/mapper/JcjJxxViewMysqlMapper.java +++ b/src/main/java/com/ssf/mysqloracletest/mapper/JcjJxxViewMysqlMapper.java @@ -15,4 +15,6 @@ public interface JcjJxxViewMysqlMapper extends BaseMapper { public JcjJjxxViewMysql selectRecordOrderByRksj(); public int countJjxx(); + + public JcjJjxxViewMysql selectloaction(JcjJjxxViewMysql bean); } diff --git a/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java index b485a53..da4b36c 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java +++ b/src/main/java/com/ssf/mysqloracletest/service/JcjJjxxViewMysqlService.java @@ -19,4 +19,6 @@ public interface JcjJjxxViewMysqlService extends IService{ public int countJjxx(); + public JcjJjxxViewMysql selectloaction(JcjJjxxViewMysql bean); + } diff --git a/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java index 619b6a1..0efda50 100644 --- a/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java +++ b/src/main/java/com/ssf/mysqloracletest/service/impl/JcjJjxxViewMysqlServiceImpl.java @@ -7,6 +7,7 @@ import com.ssf.mysqloracletest.mapper.JcjJxxViewMysqlMapper; import com.ssf.mysqloracletest.service.JcjJjxxViewMysqlService; import lombok.RequiredArgsConstructor; import org.springframework.stereotype.Service; +import org.springframework.transaction.annotation.Transactional; /** * @author 10503 @@ -16,7 +17,7 @@ import org.springframework.stereotype.Service; @Service @DS("mysql") @RequiredArgsConstructor -public class JcjJjxxViewMysqlServiceImpl extends ServiceImpl implements JcjJjxxViewMysqlService { +public class JcjJjxxViewMysqlServiceImpl extends ServiceImpl implements JcjJjxxViewMysqlService { private final JcjJxxViewMysqlMapper jcxxMapper; @@ -44,6 +45,12 @@ public class JcjJjxxViewMysqlServiceImpl extends ServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.isNull("STATUS"); @@ -80,34 +79,38 @@ public class AlarmInfoTask { private void cleanJjxx(JcjJjxxViewMysql bean) { JcjJjxxViewMysql jjxxViewMysqlCp = new JcjJjxxViewMysql(); + jjxxViewMysqlCp.setLEFTTOPLONGITUDE("120.423914"); + jjxxViewMysqlCp.setRIGHTBOTTOMLONGITUDE("120.439581"); + jjxxViewMysqlCp.setRIGHTBOTTOMLATITUDE("33.823756"); + jjxxViewMysqlCp.setLEFTTOPLATITUDE("33.833082"); + JcjJjxxViewMysql selectloaction = jjxxViewMysqlService.selectloaction(jjxxViewMysqlCp); try { - BeanUtils.copyProperties(bean, jjxxViewMysqlCp); - JcjJjxxViewMysql jwd = jjxxViewMysqlService.selectJcjJxxByJJBH(bean.getJJBH()); + BeanUtils.copyProperties(bean, selectloaction); + JcjJjxxViewMysql jwd = jjxxViewMysqlService.selectJcjJxxByJJBH(selectloaction.getJJBH()); MetaAlarmInfo alarmInfo = new MetaAlarmInfo(); //设置目标字段的值 //alarm_code<-----JJBH 接警编号 - alarmInfo.setAlarmCode(jjxxViewMysqlCp.getJJBH()); + alarmInfo.setAlarmCode(selectloaction.getJJBH()); //police_receiver_name<-----JJRXM接警人姓名 - alarmInfo.setPoliceReceiverName(jjxxViewMysqlCp.getJJRXM()); + alarmInfo.setPoliceReceiverName(selectloaction.getJJRXM()); //alarm_response_time<-----JJRQSJ接警日期时间 - alarmInfo.setAlarmResponseTime(jjxxViewMysqlCp.getJJRQSJ()); + alarmInfo.setAlarmResponseTime(selectloaction.getJJRQSJ()); //alarm_response_content<-----BJNR接警报警内容 - alarmInfo.setAlarmResponseContent(jjxxViewMysqlCp.getBJNR()); + alarmInfo.setAlarmResponseContent(selectloaction.getBJNR()); //informant_name<-----BJR接警报警人 - alarmInfo.setInformantName(jjxxViewMysqlCp.getBJR()); + alarmInfo.setInformantName(selectloaction.getBJR()); //informant_time<-----BJDHSJ接警报警时间 - alarmInfo.setInformantTime(jjxxViewMysqlCp.getBJDHSJ()); + alarmInfo.setInformantTime(selectloaction.getBJDHSJ()); //informant_phone<-----LXDH接警报警人联系电话 - alarmInfo.setInformantPhone(jjxxViewMysqlCp.getLXDH()); + alarmInfo.setInformantPhone(selectloaction.getLXDH()); //alarm_response_type<-----BJLXMC报警类型名称 - alarmInfo.setAlarmResponseTypeName(jjxxViewMysqlCp.getBJLXMC()); + alarmInfo.setAlarmResponseTypeName(selectloaction.getBJLXMC()); //alarm_address<-----SFDD接警事发地址 - alarmInfo.setAlarmAddress(jjxxViewMysqlCp.getSFDD()); + alarmInfo.setAlarmAddress(selectloaction.getSFDD()); //alarm_response_unit<-----JJDWMC接警单位名称 - alarmInfo.setAlarmResponseUnit(jjxxViewMysqlCp.getJJDWMC()); + alarmInfo.setAlarmResponseUnit(selectloaction.getJJDWMC()); if (jwd.getGIS_Y() != null) { - //latitude(纬度)<-----WDZB纬度坐标 alarmInfo.setLatitude(NumKit.checkBigDecimal(jwd.getGIS_Y())); } @@ -120,14 +123,14 @@ public class AlarmInfoTask { boolean b = alarmInfoService.save(alarmInfo); if (b) { - jjxxViewMysqlCp.setSTATUS("1"); - jjxxViewMysqlService.updateJjxxByJJBH(jjxxViewMysqlCp); + selectloaction.setSTATUS("1"); + jjxxViewMysqlService.updateJjxxByJJBH(selectloaction); logger.info("状态修改为：1"); } } catch (Exception e) { logger.info(StringKit.getTrace(e)); - jjxxViewMysqlCp.setSTATUS("2"); - jjxxViewMysqlService.updateJjxxByJJBH(jjxxViewMysqlCp); + selectloaction.setSTATUS("2"); + jjxxViewMysqlService.updateJjxxByJJBH(selectloaction); logger.info("状态修改为：2"); } } diff --git a/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml index f4eb9d1..3f3cafd 100644 --- a/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml +++ b/src/main/resources/mapper/JcjJjxxViewMysqlMapper.xml @@ -134,6 +134,10 @@ + + + + select * - from jcj_jjxx_view order by ws_rksj desc limit 1; + from jcj_jjxx_view + order by ws_rksj desc + limit 1; + +