diff --git a/bonus-auth/src/main/resources/bootstrap.yml b/bonus-auth/src/main/resources/bootstrap.yml index a37bb43..885ac29 100644 --- a/bonus-auth/src/main/resources/bootstrap.yml +++ b/bonus-auth/src/main/resources/bootstrap.yml @@ -5,7 +5,7 @@ spring: name: bonus-auth profiles: # 环境配置 - active: local + active: prod #加密组件 jasypt: diff --git a/bonus-gateway/src/main/resources/bootstrap-dev.yml b/bonus-gateway/src/main/resources/bootstrap-dev.yml index 5d90749..06bd4af 100644 --- a/bonus-gateway/src/main/resources/bootstrap-dev.yml +++ b/bonus-gateway/src/main/resources/bootstrap-dev.yml @@ -1,47 +1,43 @@ # Tomcat server: - port: 38080 + port: 18080 servlet: context-path: hd-real-name -# Spring spring: cloud: nacos: + username: nacos + password: nacos discovery: # 服务注册地址 server-addr: 192.168.0.14:8848 - namespace: huadong_realname_dev + namespace: huadong_realname_local + username: nacos + password: nacos config: # 配置中心地址 server-addr: 192.168.0.14:8848 - namespace: huadong_realname_dev + namespace: huadong_realname_local + # 配置文件格式 file-extension: yml # 共享配置 shared-configs: - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} - username: nacos - password: nacos sentinel: # 取消控制台懒加载 eager: true transport: # 控制台地址 - dashboard: 127.0.0.1:18858 + dashboard: 192.168.0.16:18858 # nacos配置持久化 datasource: ds1: nacos: - server-addr: 127.0.0.1:18848 - namespace: rela_name_system + server-addr: 192.168.0.16:18848 + namespace: bonus-ai dataId: sentinel-bonus-gateway groupId: DEFAULT_GROUP data-type: json rule-type: gw-flow - -#加密组件 -jasypt: - encryptor: - password: Encrypt - diff --git a/bonus-modules/bonus-bmw/src/main/resources/bootstrap-local.yml b/bonus-modules/bonus-bmw/src/main/resources/bootstrap-local.yml index 554a7ca..8136429 100644 --- a/bonus-modules/bonus-bmw/src/main/resources/bootstrap-local.yml +++ b/bonus-modules/bonus-bmw/src/main/resources/bootstrap-local.yml @@ -26,6 +26,6 @@ spring: jasypt: encryptor: password: Encrypt - +#人脸 face: - path: http://112.29.103.165:1616/faceIdentification + path: http://112.29.103.165:1616/faceIdentification \ No newline at end of file diff --git a/bonus-modules/bonus-bmw/src/main/resources/bootstrap.yml b/bonus-modules/bonus-bmw/src/main/resources/bootstrap.yml index 419c6d4..e231d0e 100644 --- a/bonus-modules/bonus-bmw/src/main/resources/bootstrap.yml +++ b/bonus-modules/bonus-bmw/src/main/resources/bootstrap.yml @@ -5,7 +5,7 @@ spring: name: bonus-bmw profiles: # 环境配置 - active: local + active: dev task: scheduling: pool: diff --git a/bonus-modules/bonus-job/src/main/resources/bootstrap.yml b/bonus-modules/bonus-job/src/main/resources/bootstrap.yml index 6ce661b..322e71f 100644 --- a/bonus-modules/bonus-job/src/main/resources/bootstrap.yml +++ b/bonus-modules/bonus-job/src/main/resources/bootstrap.yml @@ -5,7 +5,7 @@ spring: name: bonus-job profiles: # 环境配置 - active: local + active: prod #加密组件 jasypt: diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/handle/ReceiveCmd.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/handle/ReceiveCmd.java index 7518cde..9a1a893 100644 --- a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/handle/ReceiveCmd.java +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/handle/ReceiveCmd.java @@ -1,5 +1,6 @@ package com.bonus.urk.handle; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.collection.CollectionUtil; import com.bonus.common.core.urk.Constant; import com.bonus.common.core.urk.TaskStatusEnum; @@ -35,7 +36,7 @@ public class ReceiveCmd { try{ //查询是否有任务处于未下发状态 List taskList = service.selectCmdTaskList(deviceVo.getDevCode()); - if (CollectionUtil.isEmpty(taskList)) { + if (CollUtil.isEmpty(taskList)) { log.info("设备:{}, 没有执行任务", deviceVo.getDevCode()); resp.addHeader(Constant.DEVICE_HEADER_RESPONSE_CODE, Constant.ERROR_NO_CMD); return; diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/ResultMapper.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/ResultMapper.java index 6c36d88..9c9f7b0 100644 --- a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/ResultMapper.java +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/ResultMapper.java @@ -1,5 +1,6 @@ package com.bonus.urk.mapper; +import com.bonus.urk.vo.DevUserVo; import com.bonus.urk.vo.KqCmdTaskVo; import com.bonus.urk.vo.KqDevUserIdVo; import org.apache.ibatis.annotations.Mapper; @@ -64,4 +65,10 @@ public interface ResultMapper { void delKqDevUser(@Param("list") List userIds, @Param("deviceCode") String deviceCode); void insertKqDevUserList2(@Param("list") List userIds, @Param("deviceCode") String deviceCode); + + /** + * 考情机人员数据 + * @param list + */ + void addDeviceUserInfo(@Param("list")List list); } diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/TaskMapper.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/TaskMapper.java index 98f0e88..a7697c5 100644 --- a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/TaskMapper.java +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/mapper/TaskMapper.java @@ -13,6 +13,8 @@ import java.util.List; @Mapper public interface TaskMapper { + + List selectDelCmdTaskList(@Param("devCode") String devCode); /** * 查询待执行的设备指令 * @param devCode diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/service/ResultService.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/service/ResultService.java index e9dc4e5..8515ff8 100644 --- a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/service/ResultService.java +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/service/ResultService.java @@ -6,7 +6,11 @@ import com.alibaba.fastjson.JSONObject; import com.bonus.common.core.utils.StringUtils; import com.bonus.common.core.urk.CommonUtils; import com.bonus.common.core.urk.Constant; +import com.bonus.system.api.model.UploadFileVo; import com.bonus.urk.mapper.ResultMapper; +import com.bonus.urk.minio.UrkMinioService; +import com.bonus.urk.vo.DevUserVo; +import com.bonus.urk.vo.DeviceUserDto; import com.bonus.urk.vo.KqCmdTaskVo; import com.bonus.urk.vo.KqDevUserIdVo; import lombok.extern.slf4j.Slf4j; @@ -14,9 +18,11 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Service; +import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.UnsupportedEncodingException; +import java.util.ArrayList; import java.util.List; /** @@ -30,6 +36,9 @@ public class ResultService { @Autowired private ResultMapper mapper; + @Resource + private UrkMinioService fileService; + /** * 查询任务 记录 * @param asTransId @@ -161,6 +170,27 @@ public class ResultService { log.info("获取设备用户信息:{}", jsonStr); if(StringUtils.isNotBlank(jsonStr)) { //数据处理 + JSONObject json=JSON.parseObject(jsonStr); + List list=new ArrayList<>(); + JSONArray users=json.getJSONArray("users"); + for (int i=0;i userSends = mapper.getTaskUserList(task.getId()); - if(CollectionUtil.isEmpty(userSends)) { - String msg = "获取设备用户信息用户发送请求数据为空,不能处理"; - log.error(msg); - task.setTransStatus(TaskStatusEnum.ERROR.ordinal()); - task.setMsg(msg); - mapper.updateById(task); - return; + if(!CollUtil.isEmpty(userSends)) { + String[] userIds = userSends.toArray(new String[0]); + jsonObject.put("usersId", userIds); } - String[] userIds = userSends.toArray(new String[0]); - jsonObject.put("usersId", userIds); body = jsonObject.toString(); try { // head @@ -487,10 +482,16 @@ public class TaskService { } public List selectCmdTaskList(String devCode) { - List list= mapper.selectCmdTaskList(devCode); - if(StringUtils.isEmpty(list)){ - list= mapper.selectCmdBlockTask(devCode); + //优先查询删除的 + List list= mapper.selectDelCmdTaskList(devCode); + if(list==null || list.isEmpty()){ + list= mapper.selectCmdTaskList(devCode); + if(StringUtils.isEmpty(list)){ + list= mapper.selectCmdBlockTask(devCode); + } } + + return list; } } diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DevUserVo.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DevUserVo.java new file mode 100644 index 0000000..b543ad5 --- /dev/null +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DevUserVo.java @@ -0,0 +1,42 @@ +package com.bonus.urk.vo; + +import lombok.Data; + +@Data +public class DevUserVo { + /** + * 设备编码 + */ + private String deviceCode; + /** + * 用户id + */ + private String userId; + /** + * 图片路径 + */ + private String imagePath; + /** + * 名称 + */ + private String name; + /** + * 主键 + */ + private String id; + + /** + * 卡号 + */ + private String card; + /** + * 校验开始时间 + */ + private String vaildStart; + + /** + * 校验结束时间 + */ + private String vaildEnd; + +} diff --git a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DeviceUserDto.java b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DeviceUserDto.java index 549d653..2a188e7 100644 --- a/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DeviceUserDto.java +++ b/bonus-modules/bonus-urk/src/main/java/com/bonus/urk/vo/DeviceUserDto.java @@ -47,6 +47,7 @@ public class DeviceUserDto implements Serializable { private String vaildTimeStart; //HHmmss private String vaildTimeEnd; + private Integer photoEnroll; } diff --git a/bonus-modules/bonus-urk/src/main/resources/bootstrap-local.yml b/bonus-modules/bonus-urk/src/main/resources/bootstrap-local.yml index c7c02b8..995fbec 100644 --- a/bonus-modules/bonus-urk/src/main/resources/bootstrap-local.yml +++ b/bonus-modules/bonus-urk/src/main/resources/bootstrap-local.yml @@ -1,6 +1,6 @@ # Tomcat server: - port: 38085 + port: 38086 # Spring spring: cloud: diff --git a/bonus-modules/bonus-urk/src/main/resources/bootstrap.yml b/bonus-modules/bonus-urk/src/main/resources/bootstrap.yml index 0b39287..ea906d0 100644 --- a/bonus-modules/bonus-urk/src/main/resources/bootstrap.yml +++ b/bonus-modules/bonus-urk/src/main/resources/bootstrap.yml @@ -1,11 +1,14 @@ # Spring -spring: +spring: + servlet: + s application: + # 应用名称 name: bonus-urk profiles: # 环境配置 - active: local + active: prod task: scheduling: pool: diff --git a/bonus-modules/bonus-urk/src/main/resources/mapper/urk/ResultMapper.xml b/bonus-modules/bonus-urk/src/main/resources/mapper/urk/ResultMapper.xml index edc9a6e..aa65277 100644 --- a/bonus-modules/bonus-urk/src/main/resources/mapper/urk/ResultMapper.xml +++ b/bonus-modules/bonus-urk/src/main/resources/mapper/urk/ResultMapper.xml @@ -24,6 +24,14 @@ + + replace into kq_user_list( + id, user_id,user_name, user_phone, card, vaild_start, vaild_end,dev_code + )values + + (#{item.id},#{item.userId},#{item.name},#{item.imagePath},#{item.card},#{item.vaildStart},#{item.vaildEnd},#{item.deviceCode}) + + update kq_cmd_task set trans_status_update_time=#{updateTime},trans_status=#{transStatus} where id=#{id} diff --git a/bonus-modules/bonus-urk/src/main/resources/mapper/urk/TaskMapper.xml b/bonus-modules/bonus-urk/src/main/resources/mapper/urk/TaskMapper.xml index 43fa94a..f1936d5 100644 --- a/bonus-modules/bonus-urk/src/main/resources/mapper/urk/TaskMapper.xml +++ b/bonus-modules/bonus-urk/src/main/resources/mapper/urk/TaskMapper.xml @@ -14,6 +14,19 @@ ) + +