Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

数据库字段修改&&接口异常恢复

Browse Source
This commit is contained in:
zhuxinyu
2023-04-07 15:33:20 +08:00
parent 5d6bc4678f
commit cdeb64b669
9 changed files with 19 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/controller/ProgramVersionController.java
View File

@@ -107,9 +107,9 @@ public class ProgramVersionController extends BaseController {
@PostMapping("/updateVersionFlag") @PostMapping("/updateVersionFlag")
@ApiOperation("修改程序版本状态") @ApiOperation("修改程序版本状态")
@ApiImplicitParam(name = "id", value = "终端版本id", required = true) @ApiImplicitParam(name = "id", value = "终端版本id", required = true)
public HttpResult updateVersionFlag(@RequestParam("id") String id) { public HttpResult updateVersionFlag(@RequestParam("id") String id, @RequestParam("versionFlag") Integer flag) {
String methodDescribe = getMethodDescribe("updateVersionFlag"); String methodDescribe = getMethodDescribe("updateVersionFlag");
boolean res = programService.updateVersionFlag(id); boolean res = programService.updateVersionFlag(id,flag);
if (res) { if (res) {
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);
} else { } else {

3
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/ProgramVersionMapper.java
View File

@@ -2,6 +2,7 @@ package com.njcn.device.pq.mapper;
import com.njcn.device.pq.pojo.vo.ShowVersionVO; import com.njcn.device.pq.pojo.vo.ShowVersionVO;
import com.njcn.device.pq.pojo.vo.VersionVO; import com.njcn.device.pq.pojo.vo.VersionVO;
import org.apache.ibatis.annotations.Param;
import java.util.List; import java.util.List;
@@ -23,7 +24,7 @@ public interface ProgramVersionMapper {
/** /**
* 修改程序版本状态 * 修改程序版本状态
*/ */
void updateVersionFlag(String id); void updateVersionFlag(Integer flag,String id);
/** /**
* 修改程序版本状态 * 修改程序版本状态
*/ */

6
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/LineMapper.xml
View File

@@ -787,7 +787,7 @@
INNER JOIN pq_device b ON vol.pid = b.id INNER JOIN pq_device b ON vol.pid = b.id
INNER JOIN pq_line sub ON dev.pid = sub.id INNER JOIN pq_line sub ON dev.pid = sub.id
INNER JOIN pq_line elc ON sub.pid = elc.id INNER JOIN pq_line elc ON sub.pid = elc.id
LEFT JOIN cld_month_flow m ON b.id = m.Line_Id LEFT JOIN cld_month_flow m ON b.id = m.Dev_Id
LEFT JOIN cld_dev_meal c ON b.id = c.line_id LEFT JOIN cld_dev_meal c ON b.id = c.line_id
LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id
@@ -825,7 +825,7 @@
INNER JOIN pq_device b ON vol.pid = b.id INNER JOIN pq_device b ON vol.pid = b.id
INNER JOIN pq_line sub ON dev.pid = sub.id INNER JOIN pq_line sub ON dev.pid = sub.id
INNER JOIN pq_line elc ON sub.pid = elc.id INNER JOIN pq_line elc ON sub.pid = elc.id
LEFT JOIN cld_month_flow m ON b.id = m.Line_Id LEFT JOIN cld_month_flow m ON b.id = m.Dev_Id
LEFT JOIN cld_dev_meal c ON b.id = c.line_id LEFT JOIN cld_dev_meal c ON b.id = c.line_id
LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id
@@ -854,7 +854,7 @@
ifnull(m.Actual_Value,0) statisValue ifnull(m.Actual_Value,0) statisValue
FROM pq_line a FROM pq_line a
INNER JOIN pq_device b ON a.id = b.id INNER JOIN pq_device b ON a.id = b.id
LEFT JOIN cld_month_flow m ON b.id = m.Line_Id LEFT JOIN cld_month_flow m ON b.id = m.Dev_Id
LEFT JOIN cld_dev_meal c ON b.id = c.line_id LEFT JOIN cld_dev_meal c ON b.id = c.line_id
LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id

2
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/ProgramVersionMapper.xml
View File

@@ -41,7 +41,7 @@
UPDATE UPDATE
cld_version cld_version
SET SET
Version_Flag = 0 Version_Flag = #{flag}
WHERE Id = #{id} WHERE Id = #{id}
</update> </update>

2
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/mapper/mapping/TerminalMaintainMapper.xml
View File

@@ -25,7 +25,7 @@ FROM
LEFT JOIN cld_dev_version f on a.id = f.line_id and f.flag = 1 and f.state = 1 LEFT JOIN cld_dev_version f on a.id = f.line_id and f.flag = 1 and f.state = 1
LEFT JOIN cld_version g on f.version_id = g.id LEFT JOIN cld_version g on f.version_id = g.id
LEFT JOIN LEFT JOIN
(select * from cld_month_flow where date_format(time_id,'%Y-%m' ) = date_format(CURRENT_TIME(),'%Y-%m')) mo on a.id = mo.line_id (select * from cld_month_flow where date_format(time_id,'%Y-%m' ) = date_format(CURRENT_TIME(),'%Y-%m')) mo on a.id = mo.Dev_Id
where a.id in where a.id in
<foreach collection="devIds" item="item" open="(" close=")" separator=","> <foreach collection="devIds" item="item" open="(" close=")" separator=",">
#{item} #{item}

2
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/ProgramVersionService.java
View File

@@ -37,7 +37,7 @@ public interface ProgramVersionService {
* 修改程序版本状态 * 修改程序版本状态
* @return * @return
*/ */
boolean updateVersionFlag(String id); boolean updateVersionFlag(String id, Integer flag);
/** /**
* 删除版本 * 删除版本
* @return * @return

7
pqs-device/pq-device/pq-device-boot/src/main/java/com/njcn/device/pq/service/impl/ProgramVersionServiceImpl.java
View File

@@ -138,8 +138,11 @@ public class ProgramVersionServiceImpl extends ServiceImpl<VersionMapper, Versio
@Override @Override
public boolean updateVersionFlag(String id) { public boolean updateVersionFlag(String id, Integer flag) {
programVersionMapper.updateVersionFlag(id); Version version = new Version();
version.setId(id);
version.setVersionFlag(flag);
versionMapper.updateById(version);
return true; return true;
} }

1
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/DeviceAbnormalStatisticsJob.java
View File

@@ -17,7 +17,6 @@ public class DeviceAbnormalStatisticsJob {
@XxlJob("deviceAbnormalStatisticsJob") @XxlJob("deviceAbnormalStatisticsJob")
public void deviceAbnormalStatisticsJob (){ public void deviceAbnormalStatisticsJob (){
// System.out.println("朱鑫宇定时任务");
String time = LocalDate.now().minusDays(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd")); String time = LocalDate.now().minusDays(1).format(DateTimeFormatter.ofPattern("yyyy-MM-dd"));
log.info("执行日期deviceAbnormalStatisticsJob===============>"+time); log.info("执行日期deviceAbnormalStatisticsJob===============>"+time);
DeviceAbnormaStatisticsParam param =new DeviceAbnormaStatisticsParam(); DeviceAbnormaStatisticsParam param =new DeviceAbnormaStatisticsParam();

8
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/harmonic/mapper/mysql/device/mapping/DeviceAbnormaStatisticsMapper.xml
View File

@@ -101,16 +101,16 @@
FROM FROM
( (
SELECT SELECT
cmf.Line_Id deviceId, cmf.Dev_Id deviceId,
IFNULL(d.flow, (select flow from cld_flow_meal where type = 0 and flag = 1)) + IFNULL(d1.flow, 0) flowMeal, IFNULL(d.flow, (select flow from cld_flow_meal where type = 0 and flag = 1)) + IFNULL(d1.flow, 0) flowMeal,
IFNULL(cmf.Actual_Value,0) actualValue, IFNULL(cmf.Actual_Value,0) actualValue,
rsod.online_min/1440 onlineRate rsod.online_min/1440 onlineRate
FROM cld_month_flow cmf FROM cld_month_flow cmf
LEFT JOIN cld_dev_meal c ON cmf.Line_Id = c.Line_Id LEFT JOIN cld_dev_meal c ON cmf.Dev_Id = c.Line_Id
LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id LEFT JOIN cld_flow_meal d ON c.Base_Meal_Id = d.id
LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id LEFT JOIN cld_flow_meal d1 ON c.Ream_Meal_Id = d1.id
LEFT JOIN r_stat_onlinerate_d rsod ON rsod.dev_index = cmf.Line_Id LEFT JOIN r_stat_onlinerate_d rsod ON rsod.dev_index = cmf.Dev_Id
WHERE cmf.Line_Id IN WHERE cmf.Dev_Id IN
<foreach collection="list" index="index" item="item" open="(" separator="," close=")"> <foreach collection="list" index="index" item="item" open="(" separator="," close=")">
#{item} #{item}
</foreach> </foreach>