苏州配置文件简化

张晓波

2023-10-19 6403707ab6b0d5442544c52bdcfd36a9fc5f307e

 hd/pipe/StaffManage/src/main/java/com/thhy/staff/modules/biz/face/service/impl/FaceServerImpl.java

@@ -20,6 +20,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.ArrayList;
import java.util.List;
@@ -111,11 +112,10 @@
            if(!StringUtils.isEmpty(userIds)){
                JSONArray jsonArray = JSONArray.parseArray(userIds);
                logger.info("成功通知结果解析数组"+jsonArray.toJSONString());
                String[] userIdArray = new String[]{userIds};
                if(userIds.contains(",")){
                    userIdArray = userIds.split(",");
                }
                userMapper.syncResult(1,userIdArray);

                List<String> userIdList = JSONArray.parseArray(userIds,String.class);

                userMapper.syncResult(1,userIdList);
            }
            JSONArray failJsonArray = reqJson.getJSONArray("failed");
            if(failJsonArray.size()>0){
@@ -153,4 +153,16 @@
        logger.info("查询人员"+perId+"："+content);
        MqUtils.createClient(emqxConfig,sns,content);
    }

    @Override
    @Transactional
    public void deleteNotify(String mess) {
        logger.info("删除人员通知"+mess);
        JSONObject jsonObject = JSON.parseObject(mess);
        if(jsonObject.containsKey("success")&&jsonObject.getBooleanValue("success")){
            JSONObject paramJson = jsonObject.getJSONObject("param");
            List<String> userIds = JSONArray.parseArray(paramJson.getString("userIds"),String.class);
            userMapper.syncResult(3,userIds);
        }
    }
}