修复完成
This commit is contained in:
@@ -35,6 +35,9 @@ public class CmsDesign implements Serializable {
|
|||||||
@ApiModelProperty(value = "所属栏目ID")
|
@ApiModelProperty(value = "所属栏目ID")
|
||||||
private Integer categoryId;
|
private Integer categoryId;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "页面模型")
|
||||||
|
private String model;
|
||||||
|
|
||||||
@ApiModelProperty(value = "页面关键词")
|
@ApiModelProperty(value = "页面关键词")
|
||||||
private String keywords;
|
private String keywords;
|
||||||
|
|
||||||
|
|||||||
@@ -14,12 +14,15 @@
|
|||||||
<if test="param.name != null">
|
<if test="param.name != null">
|
||||||
AND a.name LIKE CONCAT('%', #{param.name}, '%')
|
AND a.name LIKE CONCAT('%', #{param.name}, '%')
|
||||||
</if>
|
</if>
|
||||||
<if test="param.lang != null">
|
<if test="param.lang != null">
|
||||||
AND a.lang = #{param.lang}
|
AND a.lang = #{param.lang}
|
||||||
</if>
|
</if>
|
||||||
<if test="param.categoryId != null">
|
<if test="param.categoryId != null">
|
||||||
AND a.category_id = #{param.categoryId}
|
AND a.category_id = #{param.categoryId}
|
||||||
</if>
|
</if>
|
||||||
|
<if test="param.model != null">
|
||||||
|
AND a.model = #{param.model}
|
||||||
|
</if>
|
||||||
<if test="param.keywords != null">
|
<if test="param.keywords != null">
|
||||||
AND a.keywords LIKE CONCAT('%', #{param.keywords}, '%')
|
AND a.keywords LIKE CONCAT('%', #{param.keywords}, '%')
|
||||||
</if>
|
</if>
|
||||||
|
|||||||
@@ -33,6 +33,9 @@ public class CmsDesignParam extends BaseParam {
|
|||||||
@QueryField(type = QueryType.EQ)
|
@QueryField(type = QueryType.EQ)
|
||||||
private Integer categoryId;
|
private Integer categoryId;
|
||||||
|
|
||||||
|
@ApiModelProperty(value = "页面模型")
|
||||||
|
private String model;
|
||||||
|
|
||||||
@ApiModelProperty(value = "页面关键词")
|
@ApiModelProperty(value = "页面关键词")
|
||||||
private String keywords;
|
private String keywords;
|
||||||
|
|
||||||
|
|||||||
@@ -14,57 +14,52 @@ import org.springframework.stereotype.Component;
|
|||||||
@Component
|
@Component
|
||||||
@ConfigurationProperties(prefix = "mqtt")
|
@ConfigurationProperties(prefix = "mqtt")
|
||||||
public class MqttProperties {
|
public class MqttProperties {
|
||||||
|
|
||||||
/**
|
|
||||||
* 是否启用MQTT服务
|
|
||||||
*/
|
|
||||||
private boolean enabled = true;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* MQTT服务器地址
|
* MQTT服务器地址
|
||||||
*/
|
*/
|
||||||
private String host = "tcp://127.0.0.1:1883";
|
private String host = "tcp://127.0.0.1:1883";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 用户名
|
* 用户名
|
||||||
*/
|
*/
|
||||||
private String username = "";
|
private String username = "";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 密码
|
* 密码
|
||||||
*/
|
*/
|
||||||
private String password = "";
|
private String password = "";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 客户端ID前缀
|
* 客户端ID前缀
|
||||||
*/
|
*/
|
||||||
private String clientIdPrefix = "mqtt_client_";
|
private String clientIdPrefix = "mqtt_client_";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 订阅主题
|
* 订阅主题
|
||||||
*/
|
*/
|
||||||
private String topic = "/SW_GPS/#";
|
private String topic = "/SW_GPS/#";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* QoS等级
|
* QoS等级
|
||||||
*/
|
*/
|
||||||
private int qos = 2;
|
private int qos = 2;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 连接超时时间(秒)
|
* 连接超时时间(秒)
|
||||||
*/
|
*/
|
||||||
private int connectionTimeout = 10;
|
private int connectionTimeout = 10;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 心跳间隔(秒)
|
* 心跳间隔(秒)
|
||||||
*/
|
*/
|
||||||
private int keepAliveInterval = 20;
|
private int keepAliveInterval = 20;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 是否自动重连
|
* 是否自动重连
|
||||||
*/
|
*/
|
||||||
private boolean autoReconnect = true;
|
private boolean autoReconnect = true;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* 是否清除会话
|
* 是否清除会话
|
||||||
*/
|
*/
|
||||||
|
|||||||
@@ -65,9 +65,9 @@ public class MybatisPlusConfig {
|
|||||||
"sys_dictionary",
|
"sys_dictionary",
|
||||||
"sys_dictionary_data",
|
"sys_dictionary_data",
|
||||||
"apps_test_data",
|
"apps_test_data",
|
||||||
"cms_lang",
|
"cms_lang"
|
||||||
"hjm_car",
|
// "hjm_car",
|
||||||
"hjm_fence"
|
// "hjm_fence"
|
||||||
// "cms_website"
|
// "cms_website"
|
||||||
// "sys_user"
|
// "sys_user"
|
||||||
// "cms_domain"
|
// "cms_domain"
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
package com.shengwei.iot.common.utils.mqtt;
|
package com.gxwebsoft.hjm.controller;
|
||||||
|
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
|||||||
@@ -38,12 +38,6 @@ public class MqttService {
|
|||||||
@PostConstruct
|
@PostConstruct
|
||||||
public void init() {
|
public void init() {
|
||||||
try {
|
try {
|
||||||
// 检查是否启用MQTT服务
|
|
||||||
if (!mqttProperties.isEnabled()) {
|
|
||||||
logger.info("MQTT服务已禁用,跳过初始化");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
logger.info("开始初始化MQTT服务...");
|
logger.info("开始初始化MQTT服务...");
|
||||||
|
|
||||||
// 验证配置属性
|
// 验证配置属性
|
||||||
|
|||||||
@@ -44,7 +44,7 @@ public class PushHjmFenceOutController extends BaseController {
|
|||||||
* @Scheduled(fixedDelay = 2000, initialDelay = 2000)
|
* @Scheduled(fixedDelay = 2000, initialDelay = 2000)
|
||||||
* @Scheduled(cron = "0 0 9 * * ?")
|
* @Scheduled(cron = "0 0 9 * * ?")
|
||||||
*/
|
*/
|
||||||
@Scheduled(cron = "0 0/10 * * * ?")
|
// @Scheduled(cron = "0 0/10 * * * ?")
|
||||||
public void index() {
|
public void index() {
|
||||||
final List<HjmCar> list = hjmCarService.list(new LambdaQueryWrapper<HjmCar>()
|
final List<HjmCar> list = hjmCarService.list(new LambdaQueryWrapper<HjmCar>()
|
||||||
.eq(HjmCar::getStatus, 1)
|
.eq(HjmCar::getStatus, 1)
|
||||||
|
|||||||
@@ -144,7 +144,7 @@ public class HouseInfoServiceImpl extends ServiceImpl<HouseInfoMapper, HouseInfo
|
|||||||
priceText += "/月";
|
priceText += "/月";
|
||||||
}
|
}
|
||||||
combiner.addTextElement(priceText, 26, 50, currentY)
|
combiner.addTextElement(priceText, 26, 50, currentY)
|
||||||
.setColor(java.awt.Color.RED)
|
.setColor(Color.RED)
|
||||||
.setCenter(true);
|
.setCenter(true);
|
||||||
currentY += lineHeight;
|
currentY += lineHeight;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -251,7 +251,7 @@ public class ProjectController extends BaseController {
|
|||||||
@ApiOperation("统计信息")
|
@ApiOperation("统计信息")
|
||||||
@GetMapping("/count")
|
@GetMapping("/count")
|
||||||
public ApiResult<Map<String, BigDecimal>> count() {
|
public ApiResult<Map<String, BigDecimal>> count() {
|
||||||
Map<String, java.math.BigDecimal> data = new HashMap<>();
|
Map<String, BigDecimal> data = new HashMap<>();
|
||||||
final User loginUser = getLoginUser();
|
final User loginUser = getLoginUser();
|
||||||
if (loginUser == null) {
|
if (loginUser == null) {
|
||||||
return fail("请先登录", null);
|
return fail("请先登录", null);
|
||||||
@@ -280,14 +280,14 @@ public class ProjectController extends BaseController {
|
|||||||
|
|
||||||
|
|
||||||
// TODO 今年已收续费总额
|
// TODO 今年已收续费总额
|
||||||
java.math.BigDecimal yearTotalPrice = projectService.sumMoney(new LambdaQueryWrapper<Project>()
|
BigDecimal yearTotalPrice = projectService.sumMoney(new LambdaQueryWrapper<Project>()
|
||||||
.between(Project::getUpdateTime, startOfYear, endOfYear)
|
.between(Project::getUpdateTime, startOfYear, endOfYear)
|
||||||
.eq(Project::getDeleted, 0)
|
.eq(Project::getDeleted, 0)
|
||||||
);
|
);
|
||||||
data.put("yearTotalPrice", yearTotalPrice);
|
data.put("yearTotalPrice", yearTotalPrice);
|
||||||
|
|
||||||
// TODO 去年已收续费总额
|
// TODO 去年已收续费总额
|
||||||
java.math.BigDecimal lastTotalPrice = projectService.sumMoney(new LambdaQueryWrapper<Project>()
|
BigDecimal lastTotalPrice = projectService.sumMoney(new LambdaQueryWrapper<Project>()
|
||||||
.between(Project::getUpdateTime, startOfLastYear, endOfLastYear)
|
.between(Project::getUpdateTime, startOfLastYear, endOfLastYear)
|
||||||
.eq(Project::getDeleted, 0)
|
.eq(Project::getDeleted, 0)
|
||||||
.eq(Project::getDeleted,0)
|
.eq(Project::getDeleted,0)
|
||||||
|
|||||||
@@ -173,7 +173,7 @@ public class ProjectRenewController extends BaseController {
|
|||||||
@ApiOperation("统计信息")
|
@ApiOperation("统计信息")
|
||||||
@GetMapping("/data")
|
@GetMapping("/data")
|
||||||
public ApiResult<Map<String, BigDecimal>> data(ProjectParam param) {
|
public ApiResult<Map<String, BigDecimal>> data(ProjectParam param) {
|
||||||
Map<String, java.math.BigDecimal> data = new HashMap<>();
|
Map<String, BigDecimal> data = new HashMap<>();
|
||||||
final User loginUser = getLoginUser();
|
final User loginUser = getLoginUser();
|
||||||
if (loginUser == null) {
|
if (loginUser == null) {
|
||||||
return fail("请先登录", null);
|
return fail("请先登录", null);
|
||||||
@@ -250,14 +250,14 @@ public class ProjectRenewController extends BaseController {
|
|||||||
data.put("monthTotalPrice", monthTotalPrice);
|
data.put("monthTotalPrice", monthTotalPrice);
|
||||||
|
|
||||||
// TODO 今年已收续费总额
|
// TODO 今年已收续费总额
|
||||||
java.math.BigDecimal yearTotalPrice = projectRenewService.sumMoney(new LambdaQueryWrapper<ProjectRenew>()
|
BigDecimal yearTotalPrice = projectRenewService.sumMoney(new LambdaQueryWrapper<ProjectRenew>()
|
||||||
.between(ProjectRenew::getCreateTime, startOfYear, endOfYear)
|
.between(ProjectRenew::getCreateTime, startOfYear, endOfYear)
|
||||||
.eq(ProjectRenew::getDeleted, 0)
|
.eq(ProjectRenew::getDeleted, 0)
|
||||||
);
|
);
|
||||||
data.put("yearTotalPrice", yearTotalPrice);
|
data.put("yearTotalPrice", yearTotalPrice);
|
||||||
|
|
||||||
// TODO 去年已收续费总额
|
// TODO 去年已收续费总额
|
||||||
java.math.BigDecimal lastTotalPrice = projectRenewService.sumMoney(new LambdaQueryWrapper<ProjectRenew>()
|
BigDecimal lastTotalPrice = projectRenewService.sumMoney(new LambdaQueryWrapper<ProjectRenew>()
|
||||||
.eq(ProjectRenew::getDeleted, 0)
|
.eq(ProjectRenew::getDeleted, 0)
|
||||||
.between(ProjectRenew::getEndTime, startOfLastYear, endOfLastYear));
|
.between(ProjectRenew::getEndTime, startOfLastYear, endOfLastYear));
|
||||||
// 去年已收续费总额
|
// 去年已收续费总额
|
||||||
|
|||||||
@@ -22,7 +22,7 @@ import java.util.List;
|
|||||||
* 收货地址控制器
|
* 收货地址控制器
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
@Api(tags = "收货地址管理")
|
@Api(tags = "收货地址管理")
|
||||||
@RestController
|
@RestController
|
||||||
@@ -31,6 +31,7 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
@Resource
|
@Resource
|
||||||
private ShopUserAddressService shopUserAddressService;
|
private ShopUserAddressService shopUserAddressService;
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:list')")
|
||||||
@ApiOperation("分页查询收货地址")
|
@ApiOperation("分页查询收货地址")
|
||||||
@GetMapping("/page")
|
@GetMapping("/page")
|
||||||
public ApiResult<PageResult<ShopUserAddress>> page(ShopUserAddressParam param) {
|
public ApiResult<PageResult<ShopUserAddress>> page(ShopUserAddressParam param) {
|
||||||
@@ -38,6 +39,7 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return success(shopUserAddressService.pageRel(param));
|
return success(shopUserAddressService.pageRel(param));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:list')")
|
||||||
@ApiOperation("查询全部收货地址")
|
@ApiOperation("查询全部收货地址")
|
||||||
@GetMapping()
|
@GetMapping()
|
||||||
public ApiResult<List<ShopUserAddress>> list(ShopUserAddressParam param) {
|
public ApiResult<List<ShopUserAddress>> list(ShopUserAddressParam param) {
|
||||||
@@ -53,6 +55,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return success(shopUserAddressService.getByIdRel(id));
|
return success(shopUserAddressService.getByIdRel(id));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:save')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("添加收货地址")
|
@ApiOperation("添加收货地址")
|
||||||
@PostMapping()
|
@PostMapping()
|
||||||
public ApiResult<?> save(@RequestBody ShopUserAddress shopUserAddress) {
|
public ApiResult<?> save(@RequestBody ShopUserAddress shopUserAddress) {
|
||||||
@@ -67,6 +71,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return fail("添加失败");
|
return fail("添加失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:update')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("修改收货地址")
|
@ApiOperation("修改收货地址")
|
||||||
@PutMapping()
|
@PutMapping()
|
||||||
public ApiResult<?> update(@RequestBody ShopUserAddress shopUserAddress) {
|
public ApiResult<?> update(@RequestBody ShopUserAddress shopUserAddress) {
|
||||||
@@ -76,6 +82,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return fail("修改失败");
|
return fail("修改失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:remove')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("删除收货地址")
|
@ApiOperation("删除收货地址")
|
||||||
@DeleteMapping("/{id}")
|
@DeleteMapping("/{id}")
|
||||||
public ApiResult<?> remove(@PathVariable("id") Integer id) {
|
public ApiResult<?> remove(@PathVariable("id") Integer id) {
|
||||||
@@ -85,6 +93,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return fail("删除失败");
|
return fail("删除失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:save')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("批量添加收货地址")
|
@ApiOperation("批量添加收货地址")
|
||||||
@PostMapping("/batch")
|
@PostMapping("/batch")
|
||||||
public ApiResult<?> saveBatch(@RequestBody List<ShopUserAddress> list) {
|
public ApiResult<?> saveBatch(@RequestBody List<ShopUserAddress> list) {
|
||||||
@@ -94,6 +104,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return fail("添加失败");
|
return fail("添加失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:update')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("批量修改收货地址")
|
@ApiOperation("批量修改收货地址")
|
||||||
@PutMapping("/batch")
|
@PutMapping("/batch")
|
||||||
public ApiResult<?> removeBatch(@RequestBody BatchParam<ShopUserAddress> batchParam) {
|
public ApiResult<?> removeBatch(@RequestBody BatchParam<ShopUserAddress> batchParam) {
|
||||||
@@ -103,6 +115,8 @@ public class ShopUserAddressController extends BaseController {
|
|||||||
return fail("修改失败");
|
return fail("修改失败");
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@PreAuthorize("hasAuthority('shop:shopUserAddress:remove')")
|
||||||
|
@OperationLog
|
||||||
@ApiOperation("批量删除收货地址")
|
@ApiOperation("批量删除收货地址")
|
||||||
@DeleteMapping("/batch")
|
@DeleteMapping("/batch")
|
||||||
public ApiResult<?> removeBatch(@RequestBody List<Integer> ids) {
|
public ApiResult<?> removeBatch(@RequestBody List<Integer> ids) {
|
||||||
|
|||||||
@@ -2,8 +2,9 @@ package com.gxwebsoft.shop.entity;
|
|||||||
|
|
||||||
import com.baomidou.mybatisplus.annotation.IdType;
|
import com.baomidou.mybatisplus.annotation.IdType;
|
||||||
import com.baomidou.mybatisplus.annotation.TableId;
|
import com.baomidou.mybatisplus.annotation.TableId;
|
||||||
import java.util.Date;
|
|
||||||
import java.io.Serializable;
|
import java.io.Serializable;
|
||||||
|
import java.util.Date;
|
||||||
|
|
||||||
import io.swagger.annotations.ApiModel;
|
import io.swagger.annotations.ApiModel;
|
||||||
import io.swagger.annotations.ApiModelProperty;
|
import io.swagger.annotations.ApiModelProperty;
|
||||||
import lombok.Data;
|
import lombok.Data;
|
||||||
@@ -13,7 +14,7 @@ import lombok.EqualsAndHashCode;
|
|||||||
* 收货地址
|
* 收货地址
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
@Data
|
@Data
|
||||||
@EqualsAndHashCode(callSuper = false)
|
@EqualsAndHashCode(callSuper = false)
|
||||||
|
|||||||
@@ -12,7 +12,7 @@ import java.util.List;
|
|||||||
* 收货地址Mapper
|
* 收货地址Mapper
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
public interface ShopUserAddressMapper extends BaseMapper<ShopUserAddress> {
|
public interface ShopUserAddressMapper extends BaseMapper<ShopUserAddress> {
|
||||||
|
|
||||||
|
|||||||
@@ -60,6 +60,7 @@
|
|||||||
</if>
|
</if>
|
||||||
<if test="param.keywords != null">
|
<if test="param.keywords != null">
|
||||||
AND (a.comments LIKE CONCAT('%', #{param.keywords}, '%')
|
AND (a.comments LIKE CONCAT('%', #{param.keywords}, '%')
|
||||||
|
OR a.phone = #{param.keywords}
|
||||||
)
|
)
|
||||||
</if>
|
</if>
|
||||||
</where>
|
</where>
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ import lombok.EqualsAndHashCode;
|
|||||||
* 收货地址查询参数
|
* 收货地址查询参数
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
@Data
|
@Data
|
||||||
@EqualsAndHashCode(callSuper = false)
|
@EqualsAndHashCode(callSuper = false)
|
||||||
|
|||||||
@@ -11,7 +11,7 @@ import java.util.List;
|
|||||||
* 收货地址Service
|
* 收货地址Service
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
public interface ShopUserAddressService extends IService<ShopUserAddress> {
|
public interface ShopUserAddressService extends IService<ShopUserAddress> {
|
||||||
|
|
||||||
|
|||||||
@@ -15,7 +15,7 @@ import java.util.List;
|
|||||||
* 收货地址Service实现
|
* 收货地址Service实现
|
||||||
*
|
*
|
||||||
* @author 科技小王子
|
* @author 科技小王子
|
||||||
* @since 2025-01-11 10:45:13
|
* @since 2025-07-22 23:06:40
|
||||||
*/
|
*/
|
||||||
@Service
|
@Service
|
||||||
public class ShopUserAddressServiceImpl extends ServiceImpl<ShopUserAddressMapper, ShopUserAddress> implements ShopUserAddressService {
|
public class ShopUserAddressServiceImpl extends ServiceImpl<ShopUserAddressMapper, ShopUserAddress> implements ShopUserAddressService {
|
||||||
|
|||||||
Reference in New Issue
Block a user