zhousq
10 months ago
40 changed files with 456 additions and 1903 deletions
@ -0,0 +1,18 @@ |
|||
package com.lzbi.bill.domain; |
|||
|
|||
import com.alibaba.excel.metadata.data.CellData; |
|||
import lombok.EqualsAndHashCode; |
|||
import lombok.Getter; |
|||
import lombok.Setter; |
|||
|
|||
import java.util.Date; |
|||
|
|||
/** |
|||
* 读取公式数据 |
|||
*/ |
|||
@Getter |
|||
@Setter |
|||
@EqualsAndHashCode |
|||
public class CellDataReadFormulaData { |
|||
private CellData<String> string; |
|||
} |
|||
@ -0,0 +1,113 @@ |
|||
package com.lzbi.bill.listener; |
|||
|
|||
import cn.hutool.core.collection.CollectionUtil; |
|||
import cn.hutool.json.JSONArray; |
|||
import cn.hutool.json.JSONConfig; |
|||
import cn.hutool.json.JSONUtil; |
|||
import com.alibaba.excel.context.AnalysisContext; |
|||
import com.alibaba.excel.metadata.CellExtra; |
|||
import com.alibaba.excel.metadata.data.ReadCellData; |
|||
import com.alibaba.excel.read.listener.ReadListener; |
|||
import com.lzbi.draft.domain.vo.ProductionDailySheetVO; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
|
|||
import java.util.ArrayList; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
/** |
|||
* @author LWB |
|||
* @Description excel读取的监听器 |
|||
* 有个很重要的点 ExcelReadListener监听器 不能被spring管理，要每次读取excel都要new,然后里面用到spring可以构造方法传进去 |
|||
* 所以,如果需要传入spring管理的对象,要么按照文档中的说明,直接使用构造器传参进来,要么使用ThreadLocal线程级别的变量工具传参 |
|||
* 实际应用中,可能会需要传入很多的spring管理的对象,或者其他上下文参数,遇到这种情况,建议使用ThreadLocal来传递参数,简单,便捷,无需重复修改构造器 |
|||
* 如果是简单的传递个别上下文参数,也可以选用构造器传参的方式 |
|||
*/ |
|||
@Slf4j |
|||
public class CellDataReadFormulaListener implements ReadListener<Map<Integer, String>> { |
|||
|
|||
/** |
|||
* excel所有的sheet-row-cell数据 |
|||
*/ |
|||
private List<ProductionDailySheetVO> list; |
|||
|
|||
/** |
|||
* 每个sheet页的所有行 |
|||
*/ |
|||
private List<List<String>> rows; |
|||
|
|||
/** |
|||
* sheet页的号 |
|||
*/ |
|||
private Integer sheetNo; |
|||
|
|||
/** |
|||
* 行的长度 |
|||
*/ |
|||
private Integer rowLength; |
|||
|
|||
public CellDataReadFormulaListener () { |
|||
this.list = new ArrayList<>(); |
|||
} |
|||
|
|||
public List<ProductionDailySheetVO> getList() { |
|||
return list; |
|||
} |
|||
|
|||
@Override |
|||
public void onException(Exception exception, AnalysisContext context) throws Exception { |
|||
ReadListener.super.onException(exception, context); |
|||
} |
|||
|
|||
@Override |
|||
public void invokeHead(Map<Integer, ReadCellData<?>> headMap, AnalysisContext context) { |
|||
ReadListener.super.invokeHead(headMap, context); |
|||
} |
|||
|
|||
@Override |
|||
public void invoke(Map<Integer, String> data, AnalysisContext context) { |
|||
if (null != data) { |
|||
List<String> cells = new ArrayList<>(); |
|||
data.forEach((k, v) -> { |
|||
if ("系统指标名称".equals(v)) { |
|||
rowLength = data.size(); |
|||
} |
|||
}); |
|||
if (null != rowLength) { |
|||
for (int i = 0; i < rowLength; i++) { |
|||
if (StringUtils.isNotBlank(data.get(i))) { |
|||
cells.add(data.get(i)); |
|||
} else { |
|||
cells.add(""); |
|||
} |
|||
} |
|||
this.rows.add(cells); |
|||
} |
|||
} |
|||
} |
|||
|
|||
@Override |
|||
public void extra(CellExtra extra, AnalysisContext context) { |
|||
ReadListener.super.extra(extra, context); |
|||
} |
|||
|
|||
@Override |
|||
public void doAfterAllAnalysed(AnalysisContext context) { |
|||
if (CollectionUtil.isNotEmpty(this.rows)) { |
|||
JSONArray data = JSONUtil.parseArray(JSONUtil.toJsonStr(this.rows)); |
|||
list.add(new ProductionDailySheetVO(context.readSheetHolder().getSheetNo(), context.readSheetHolder().getSheetName(), data)); |
|||
} |
|||
this.rows = null; |
|||
this.rowLength = null; |
|||
} |
|||
|
|||
@Override |
|||
public boolean hasNext(AnalysisContext context) { |
|||
if (!context.readSheetHolder().getSheetNo().equals(this.sheetNo)) { |
|||
this.sheetNo = context.readSheetHolder().getSheetNo(); |
|||
this.rows = new ArrayList<>(); |
|||
} |
|||
return ReadListener.super.hasNext(context); |
|||
} |
|||
} |
|||
@ -1,97 +0,0 @@ |
|||
package com.lzbi.wechat.controller; |
|||
|
|||
import com.lzbi.common.core.domain.AjaxResult; |
|||
import com.lzbi.wechat.service.DeptService; |
|||
import com.lzbi.wechat.service.TargetService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.beans.factory.annotation.Qualifier; |
|||
import org.springframework.web.bind.annotation.GetMapping; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RequestParam; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
@RestController |
|||
@RequestMapping("/wechat/biz") |
|||
public class BizController { |
|||
|
|||
@Autowired |
|||
@Qualifier("wechatDeptService") |
|||
private DeptService deptService; |
|||
|
|||
@Autowired |
|||
private TargetService targetService; |
|||
|
|||
/** |
|||
* 获取自己所在部门 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/dept/self/list") |
|||
public AjaxResult getSelfDeptList() { |
|||
return AjaxResult.success(deptService.getSelfDeptList()); |
|||
} |
|||
|
|||
/** |
|||
* 获取下属部门列表 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/dept/children") |
|||
public AjaxResult getDeptChildren(@RequestParam("deptId") Long deptId) { |
|||
return AjaxResult.success(deptService.getDeptChildren(deptId)); |
|||
} |
|||
|
|||
/** |
|||
* 获取供热面积 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/heatRadiatingArea") |
|||
public AjaxResult getHeatRadiatingArea(@RequestParam("deptId") Long deptId, @RequestParam("date") String date) { |
|||
return AjaxResult.success(targetService.getHeatRadiatingArea(deptId, date)); |
|||
} |
|||
|
|||
/** |
|||
* 获取公司指标值 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/comany/target") |
|||
public AjaxResult getComanyTarget(@RequestParam("deptId") Long deptId, @RequestParam("date") String date) { |
|||
return AjaxResult.success(targetService.getComanyTarget(deptId, date)); |
|||
} |
|||
|
|||
/** |
|||
* 获取热源指标值 |
|||
* @param type 1、单日指标，2、累计指标 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/heatSource/target") |
|||
public AjaxResult getHeatSourceTarget(@RequestParam("deptId") Long deptId, @RequestParam("date") String date, @RequestParam("type") String type) { |
|||
return AjaxResult.success(targetService.getHeatSourceTarget(deptId, date, type)); |
|||
} |
|||
|
|||
/** |
|||
* 获取换热站参数 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/heatExchangeStation/params") |
|||
public AjaxResult getHeatExchangeStationParams(@RequestParam("deptId") Long deptId, @RequestParam("date") String date) { |
|||
return AjaxResult.success(targetService.getHeatExchangeStationParams(deptId)); |
|||
} |
|||
|
|||
/** |
|||
* 获取完成率 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/finishingRate") |
|||
public AjaxResult getFinishingRate(@RequestParam("deptId") Long deptId) { |
|||
return AjaxResult.success(targetService.getFinishingRate(deptId)); |
|||
} |
|||
|
|||
/** |
|||
* 获取完成率 |
|||
* @return |
|||
*/ |
|||
@GetMapping("/finishingRateLine") |
|||
public AjaxResult getFinishingRateLine(@RequestParam("deptId") Long deptId, @RequestParam("date") String date) { |
|||
return AjaxResult.success(targetService.finishingRateLine(deptId)); |
|||
} |
|||
|
|||
} |
|||
@ -1,33 +0,0 @@ |
|||
package com.lzbi.wechat.controller; |
|||
|
|||
import com.lzbi.common.constant.Constants; |
|||
import com.lzbi.common.core.domain.AjaxResult; |
|||
import com.lzbi.common.core.domain.model.LoginBody; |
|||
import com.lzbi.wechat.service.LoginService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestBody; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
@RestController |
|||
@RequestMapping("/wechat/biz/login") |
|||
public class LoginController { |
|||
|
|||
@Autowired |
|||
private LoginService loginService; |
|||
|
|||
/** |
|||
* 登录方法 |
|||
* |
|||
* @param loginBody 登录信息 |
|||
* @return 结果 |
|||
*/ |
|||
@PostMapping("/username") |
|||
public AjaxResult login(@RequestBody LoginBody loginBody) |
|||
{ |
|||
// 生成令牌
|
|||
return loginService.login(loginBody.getUsername(), loginBody.getPassword(), loginBody.getCode(), |
|||
loginBody.getUuid()); |
|||
} |
|||
} |
|||
@ -1,54 +0,0 @@ |
|||
package com.lzbi.wechat.controller; |
|||
|
|||
import com.lzbi.common.core.domain.AjaxResult; |
|||
import com.lzbi.wechat.domain.req.CodeLoginReq; |
|||
import com.lzbi.wechat.domain.req.PhoneNumberLoginReq; |
|||
import com.lzbi.wechat.domain.req.PhoneNumberReq; |
|||
import com.lzbi.wechat.service.WechatService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.validation.annotation.Validated; |
|||
import org.springframework.web.bind.annotation.PostMapping; |
|||
import org.springframework.web.bind.annotation.RequestBody; |
|||
import org.springframework.web.bind.annotation.RequestMapping; |
|||
import org.springframework.web.bind.annotation.RestController; |
|||
|
|||
/** |
|||
* 微信服务相关接口控制器 |
|||
*/ |
|||
@RestController |
|||
@RequestMapping("/wechat/server") |
|||
public class WechatController { |
|||
|
|||
@Autowired |
|||
private WechatService wechatService; |
|||
|
|||
/** |
|||
* 登录凭证登录 |
|||
* @param codeLoginReq |
|||
* @return |
|||
*/ |
|||
@PostMapping("/codeLogin") |
|||
public AjaxResult codeLogin(@Validated @RequestBody CodeLoginReq codeLoginReq) { |
|||
return AjaxResult.success("操作成功", wechatService.codeLogin(codeLoginReq)); |
|||
} |
|||
|
|||
/** |
|||
* 获取手机号 |
|||
* @param phoneNumberReq |
|||
* @return |
|||
*/ |
|||
@PostMapping("/phoneNumber") |
|||
public AjaxResult getPhoneNumber(@Validated @RequestBody PhoneNumberReq phoneNumberReq) { |
|||
return AjaxResult.success("操作成功", wechatService.getPhoneNumber(phoneNumberReq)); |
|||
} |
|||
|
|||
/** |
|||
* 手机号登录 |
|||
* @param phoneNumberLoginReq |
|||
* @return |
|||
*/ |
|||
@PostMapping("/phoneNumberLogin") |
|||
public AjaxResult phoneNumberLogin(@Validated @RequestBody PhoneNumberLoginReq phoneNumberLoginReq) { |
|||
return AjaxResult.success("操作成功", wechatService.phoneNumberLogin(phoneNumberLoginReq)); |
|||
} |
|||
} |
|||
@ -1,30 +0,0 @@ |
|||
package com.lzbi.wechat.domain; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 微信用户关系实体类 |
|||
*/ |
|||
@Data |
|||
public class SysWechat { |
|||
|
|||
/** |
|||
* id |
|||
*/ |
|||
private Long id; |
|||
/** |
|||
* 微信用户唯一标识 |
|||
*/ |
|||
private String openId; |
|||
/** |
|||
* 手机号 |
|||
*/ |
|||
private String phone; |
|||
|
|||
public SysWechat() {} |
|||
|
|||
public SysWechat(String openId, String phone) { |
|||
this.openId = openId; |
|||
this.phone = phone; |
|||
} |
|||
} |
|||
@ -1,31 +0,0 @@ |
|||
package com.lzbi.wechat.domain.dto; |
|||
|
|||
import com.lzbi.wechat.domain.vo.TargetVO; |
|||
import lombok.Data; |
|||
|
|||
import java.util.HashMap; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
|
|||
@Data |
|||
public class ParamsContrastDTO { |
|||
|
|||
/** |
|||
* 内部参数模板编码 |
|||
*/ |
|||
private String paramsModelCode; |
|||
/** |
|||
* 外部参数编码 |
|||
*/ |
|||
private String paramsCode; |
|||
/** |
|||
* 值 |
|||
*/ |
|||
private Double value; |
|||
|
|||
public static Map<String, ParamsContrastDTO> listTransitionMap(List<ParamsContrastDTO> list) { |
|||
Map<String, ParamsContrastDTO> map = new HashMap<>(); |
|||
list.forEach(obj -> map.put(obj.getParamsModelCode(), obj)); |
|||
return map; |
|||
} |
|||
} |
|||
@ -1,37 +0,0 @@ |
|||
package com.lzbi.wechat.domain.dto; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
import java.util.List; |
|||
|
|||
/** |
|||
* 查询指标值 |
|||
*/ |
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class TargetModelValueDTO { |
|||
|
|||
/** |
|||
* 指标模板编码列表 |
|||
*/ |
|||
private List<String> targetModelCodeList; |
|||
/** |
|||
* 部门id |
|||
*/ |
|||
private Long deptId; |
|||
/** |
|||
* 年 |
|||
*/ |
|||
private String year; |
|||
/** |
|||
* 月 |
|||
*/ |
|||
private String month; |
|||
/** |
|||
* 日 |
|||
*/ |
|||
private String day; |
|||
} |
|||
@ -1,18 +0,0 @@ |
|||
package com.lzbi.wechat.domain.req; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
|
|||
/** |
|||
* 微信授权登录请求参数 |
|||
*/ |
|||
@Data |
|||
public class CodeLoginReq { |
|||
|
|||
/** |
|||
* 登录时获取的 code，可通过wx.login获取 |
|||
*/ |
|||
@NotBlank(message = "登录凭证不能为空") |
|||
private String code; |
|||
} |
|||
@ -1,19 +0,0 @@ |
|||
package com.lzbi.wechat.domain.req; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 手机号登录请求参数 |
|||
*/ |
|||
@Data |
|||
public class PhoneNumberLoginReq { |
|||
|
|||
/** |
|||
* 手机号 |
|||
*/ |
|||
private String phone; |
|||
/** |
|||
* 微信用户唯一标识 |
|||
*/ |
|||
private String openId; |
|||
} |
|||
@ -1,18 +0,0 @@ |
|||
package com.lzbi.wechat.domain.req; |
|||
|
|||
import lombok.Data; |
|||
|
|||
import javax.validation.constraints.NotBlank; |
|||
|
|||
/** |
|||
* 获取手机号请求参数 |
|||
*/ |
|||
@Data |
|||
public class PhoneNumberReq { |
|||
|
|||
/** |
|||
* 手机号获取凭证 |
|||
*/ |
|||
@NotBlank(message = "手机号获取凭证不能为空") |
|||
private String code; |
|||
} |
|||
@ -1,14 +0,0 @@ |
|||
package com.lzbi.wechat.domain.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 获取接口调用凭据 |
|||
*/ |
|||
@Data |
|||
public class WechatAccessTokenResp extends WechatBaseResp { |
|||
|
|||
private String access_token; |
|||
|
|||
private Long expires_in; |
|||
} |
|||
@ -1,19 +0,0 @@ |
|||
package com.lzbi.wechat.domain.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 微信接口返回值 |
|||
*/ |
|||
@Data |
|||
public class WechatBaseResp { |
|||
|
|||
/** |
|||
* 错误码 |
|||
*/ |
|||
private Integer errcode; |
|||
/** |
|||
* 错误信息 |
|||
*/ |
|||
private String errmsg; |
|||
} |
|||
@ -1,23 +0,0 @@ |
|||
package com.lzbi.wechat.domain.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 微信登录凭证登录返回值 |
|||
*/ |
|||
@Data |
|||
public class WechatCodeLoginResp extends WechatBaseResp { |
|||
|
|||
/** |
|||
* 会话密钥 |
|||
*/ |
|||
private String session_key; |
|||
/** |
|||
* 用户在开放平台的唯一标识符，若当前小程序已绑定到微信开放平台账号下会返回 |
|||
*/ |
|||
private String unionid; |
|||
/** |
|||
* 用户唯一标识 |
|||
*/ |
|||
private String openid; |
|||
} |
|||
@ -1,28 +0,0 @@ |
|||
package com.lzbi.wechat.domain.resp; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 获取手机号返回值 |
|||
*/ |
|||
@Data |
|||
public class WechatPhoneNumberResp extends WechatBaseResp { |
|||
|
|||
/** |
|||
* 手机号信息 |
|||
*/ |
|||
private PhoneInfo phone_info; |
|||
|
|||
/** |
|||
* 手机号信息 |
|||
*/ |
|||
@Data |
|||
public static class PhoneInfo { |
|||
|
|||
private String phoneNumber; |
|||
|
|||
private String purePhoneNumber; |
|||
|
|||
private String countryCode; |
|||
} |
|||
} |
|||
@ -1,28 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class ChildDeptVO { |
|||
|
|||
/** |
|||
* 部门id |
|||
*/ |
|||
private Object deptId; |
|||
/** |
|||
* 部门名称 |
|||
*/ |
|||
private String deptName; |
|||
/** |
|||
* 一次网供温 |
|||
*/ |
|||
private Double temperatureSupply; |
|||
/** |
|||
* 一次网回温 |
|||
*/ |
|||
private Double temperatureComeBack; |
|||
} |
|||
@ -1,14 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 登录凭证登录返回值 |
|||
*/ |
|||
@Data |
|||
public class CodeLoginVO { |
|||
|
|||
private String token; |
|||
|
|||
private String openId; |
|||
} |
|||
@ -1,19 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.Data; |
|||
|
|||
/** |
|||
* 部门返回值 |
|||
*/ |
|||
@Data |
|||
public class DeptVO { |
|||
|
|||
/** |
|||
* 部门id |
|||
*/ |
|||
private Long value; |
|||
/** |
|||
* 部门名称 |
|||
*/ |
|||
private String label; |
|||
} |
|||
@ -1,22 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
import java.util.List; |
|||
|
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class FinishingRateVO { |
|||
|
|||
/** |
|||
* 指标怕名称列表 |
|||
*/ |
|||
private List<String> names; |
|||
/** |
|||
* 指标值列表 |
|||
*/ |
|||
private List<Double> values; |
|||
} |
|||
@ -1,25 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
/** |
|||
* 指标返回值 |
|||
*/ |
|||
@EqualsAndHashCode(callSuper = true) |
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class TargetPlanVO extends TargetVO { |
|||
|
|||
/** |
|||
* 指标模板编码 |
|||
*/ |
|||
private String targetCode; |
|||
/** |
|||
* 值 |
|||
*/ |
|||
Double value; |
|||
} |
|||
@ -1,36 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.EqualsAndHashCode; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
/** |
|||
* 指标返回值 |
|||
*/ |
|||
@EqualsAndHashCode(callSuper = true) |
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class TargetResultVO extends TargetVO { |
|||
|
|||
/** |
|||
* 指标名称 |
|||
*/ |
|||
private String targetName; |
|||
/** |
|||
* 指标单位 |
|||
*/ |
|||
private String targetUnit; |
|||
/** |
|||
* 值 |
|||
*/ |
|||
private Double value; |
|||
|
|||
public TargetResultVO (String targetCode, String targetName, String targetUnit, Double value) { |
|||
super(targetCode); |
|||
this.targetName = targetName; |
|||
this.targetUnit = targetUnit; |
|||
this.value = value; |
|||
} |
|||
} |
|||
@ -1,16 +0,0 @@ |
|||
package com.lzbi.wechat.domain.vo; |
|||
|
|||
import lombok.AllArgsConstructor; |
|||
import lombok.Data; |
|||
import lombok.NoArgsConstructor; |
|||
|
|||
@Data |
|||
@NoArgsConstructor |
|||
@AllArgsConstructor |
|||
public class TargetVO { |
|||
|
|||
/** |
|||
* 指标模板编码 |
|||
*/ |
|||
private String targetCode; |
|||
} |
|||
@ -1,45 +0,0 @@ |
|||
package com.lzbi.wechat.mapper; |
|||
|
|||
import com.lzbi.wechat.domain.SysWechat; |
|||
import org.apache.ibatis.annotations.Param; |
|||
|
|||
/** |
|||
* 微信用户关系数据访问层 |
|||
*/ |
|||
public interface SysWechatMapper { |
|||
|
|||
/** |
|||
* 查询微信用户关系 |
|||
* @param id |
|||
* @return |
|||
*/ |
|||
SysWechat selectSysWechatById(@Param("id") Long id); |
|||
|
|||
/** |
|||
* 查询微信用户关系 |
|||
* @param openId |
|||
* @return |
|||
*/ |
|||
SysWechat selectWechatByOpenId(@Param("openId") String openId); |
|||
|
|||
/** |
|||
* 增加微信用户关系 |
|||
* @param sysWechat |
|||
* @return |
|||
*/ |
|||
int insertSysWechat(SysWechat sysWechat); |
|||
|
|||
/** |
|||
* 修改微信用户关系 |
|||
* @param sysWechat |
|||
* @return |
|||
*/ |
|||
int updateSysWechat(SysWechat sysWechat); |
|||
|
|||
/** |
|||
* 删除微信用户关系 |
|||
* @param id |
|||
* @return |
|||
*/ |
|||
int deleteSysWechat(@Param("id") Long id); |
|||
} |
|||
@ -1,139 +0,0 @@ |
|||
package com.lzbi.wechat.service; |
|||
|
|||
import com.lzbi.asset.domain.DcBaseAssetInfo; |
|||
import com.lzbi.asset.mapper.DcBaseAssetInfoMapper; |
|||
import com.lzbi.asset.mapper.DcBusiWorkReadConfigMapper; |
|||
import com.lzbi.common.config.IotServerApiConfig; |
|||
import com.lzbi.common.constant.BizConstants; |
|||
import com.lzbi.common.core.domain.entity.SysDept; |
|||
import com.lzbi.common.core.domain.entity.SysRole; |
|||
import com.lzbi.common.core.domain.entity.SysUser; |
|||
import com.lzbi.common.core.domain.model.LoginUser; |
|||
import com.lzbi.common.utils.SecurityUtils; |
|||
import com.lzbi.system.service.ISysDeptService; |
|||
import com.lzbi.wechat.domain.dto.ParamsContrastDTO; |
|||
import com.lzbi.wechat.domain.vo.ChildDeptVO; |
|||
import com.lzbi.wechat.domain.vo.DeptVO; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.util.CollectionUtils; |
|||
import org.springframework.web.client.RestTemplate; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.util.ArrayList; |
|||
import java.util.HashMap; |
|||
import java.util.List; |
|||
import java.util.Map; |
|||
import java.util.stream.Collectors; |
|||
|
|||
@Slf4j |
|||
@Service("wechatDeptService") |
|||
public class DeptService { |
|||
|
|||
@Autowired |
|||
private ISysDeptService sysDeptService; |
|||
|
|||
@Resource |
|||
private DcBaseAssetInfoMapper dcBaseAssetInfoMapper; |
|||
|
|||
@Resource |
|||
private DcBusiWorkReadConfigMapper dcBusiWorkReadConfigMapper; |
|||
|
|||
@Autowired |
|||
private RestTemplate restTemplate; |
|||
|
|||
@Autowired |
|||
private IotServerApiConfig iotServerApiConfig; |
|||
|
|||
public List<DeptVO> getSelfDeptList() { |
|||
List<DeptVO> list = new ArrayList<>(); |
|||
LoginUser loginUser = SecurityUtils.getLoginUser(); |
|||
SysUser sysUser = loginUser.getUser(); |
|||
List<SysRole> roles = sysUser.getRoles(); |
|||
List<Long> roleIds = roles.stream().map(SysRole::getRoleId).collect(Collectors.toList()); |
|||
List<SysDept> sysDepts = sysDeptService.selectDeptListByRoleIds(roleIds); |
|||
if (!CollectionUtils.isEmpty(sysDepts)) { |
|||
list = sysDepts.stream().filter(sysDept -> { |
|||
if (BizConstants.DcDeptAttr.COMANY.equals(sysDept.getOrgType())) { |
|||
return true; |
|||
} else { |
|||
return false; |
|||
} |
|||
}).map(sysDept -> { |
|||
DeptVO deptVO = new DeptVO(); |
|||
deptVO.setValue(sysDept.getDeptId()); |
|||
deptVO.setLabel(sysDept.getDeptName()); |
|||
return deptVO; |
|||
}).collect(Collectors.toList()); |
|||
} |
|||
return list; |
|||
} |
|||
|
|||
public List<ChildDeptVO> getDeptChildren(Long deptId) { |
|||
List<ChildDeptVO> list = new ArrayList<>(); |
|||
SysDept selfDept = sysDeptService.selectDeptById(deptId); |
|||
String orgType = selfDept.getOrgType(); |
|||
if (BizConstants.DcDeptAttr.COMANY.equals(orgType)) { |
|||
SysDept params = new SysDept(); |
|||
params.setParentId(deptId); |
|||
params.setOrgType(BizConstants.DcDeptAttr.HEAT_SOURCE); |
|||
List<SysDept> sysDeptList = sysDeptService.selectDeptList(params); |
|||
if (!CollectionUtils.isEmpty(sysDeptList)) { |
|||
list = sysDeptList.stream().map(item -> { |
|||
ChildDeptVO childDeptVO = new ChildDeptVO(); |
|||
childDeptVO.setDeptId(item.getDeptId()); |
|||
childDeptVO.setDeptName(item.getDeptName()); |
|||
childDeptVO.setTemperatureSupply(80D); |
|||
childDeptVO.setTemperatureComeBack(53D); |
|||
return childDeptVO; |
|||
}).collect(Collectors.toList()); |
|||
} |
|||
getHeatSourceParamsValue(deptId); |
|||
} else { |
|||
DcBaseAssetInfo params = new DcBaseAssetInfo(); |
|||
params.setOrgId(deptId); |
|||
params.setAssetLevel(BizConstants.DcAssetLevel.HEAT_EXCHANGE_STATION); |
|||
List<DcBaseAssetInfo> assetInfoList = dcBaseAssetInfoMapper.selectDcBaseAssetInfoList(params); |
|||
if (!CollectionUtils.isEmpty(assetInfoList)) { |
|||
list = assetInfoList.stream().map(item -> { |
|||
ChildDeptVO childDeptVO = new ChildDeptVO(); |
|||
childDeptVO.setDeptId(item.getAssetCode()); |
|||
childDeptVO.setDeptName(item.getAssetName()); |
|||
childDeptVO.setTemperatureSupply(80D); |
|||
childDeptVO.setTemperatureComeBack(53D); |
|||
return childDeptVO; |
|||
}).collect(Collectors.toList()); |
|||
} |
|||
} |
|||
return list; |
|||
} |
|||
|
|||
/** |
|||
* 查询热源参数值 |
|||
* @param deptId |
|||
* @return |
|||
*/ |
|||
public Map<Long, Map<String, Double>> getHeatSourceParamsValue (Long deptId) { |
|||
Long userId = SecurityUtils.getUserId(); |
|||
List<String> targetModelCodeList = new ArrayList<>(); |
|||
targetModelCodeList.add("101"); |
|||
targetModelCodeList.add("102"); |
|||
DcBaseAssetInfo assetParams = new DcBaseAssetInfo(); |
|||
assetParams.setOrgId(deptId); |
|||
assetParams.setAssetLevel(BizConstants.DcAssetLevel.HEAT_EXCHANGE_STATION); |
|||
assetParams.setAssetType(BizConstants.DcAssetType.REPORT); |
|||
List<ParamsContrastDTO> paramsContrastDTOList = dcBusiWorkReadConfigMapper.selectDcBusiWorkReadConfigByAssetTarget(targetModelCodeList, assetParams); |
|||
if (!CollectionUtils.isEmpty(paramsContrastDTOList)) { |
|||
List<String> paramsCodeList = paramsContrastDTOList.stream().map(ParamsContrastDTO::getParamsCode).collect(Collectors.toList()); |
|||
Map<Long, Map<Object, List<String>>> req = new HashMap<>(); |
|||
Map<Object, List<String>> deptMap = new HashMap<>(); |
|||
deptMap.put(deptId, paramsCodeList); |
|||
req.put(userId, deptMap); |
|||
String resp = restTemplate.postForObject(iotServerApiConfig.getParamsValue(), req, String.class); |
|||
log.info("参数值：{}", resp); |
|||
} |
|||
|
|||
return null; |
|||
} |
|||
} |
|||
@ -1,181 +0,0 @@ |
|||
package com.lzbi.wechat.service; |
|||
|
|||
import com.lzbi.common.constant.CacheConstants; |
|||
import com.lzbi.common.constant.Constants; |
|||
import com.lzbi.common.constant.UserConstants; |
|||
import com.lzbi.common.core.domain.AjaxResult; |
|||
import com.lzbi.common.core.domain.entity.SysUser; |
|||
import com.lzbi.common.core.domain.model.LoginUser; |
|||
import com.lzbi.common.core.redis.RedisCache; |
|||
import com.lzbi.common.exception.ServiceException; |
|||
import com.lzbi.common.exception.user.*; |
|||
import com.lzbi.common.utils.DateUtils; |
|||
import com.lzbi.common.utils.MessageUtils; |
|||
import com.lzbi.common.utils.StringUtils; |
|||
import com.lzbi.common.utils.ip.IpUtils; |
|||
import com.lzbi.framework.manager.AsyncManager; |
|||
import com.lzbi.framework.manager.factory.AsyncFactory; |
|||
import com.lzbi.framework.security.context.AuthenticationContextHolder; |
|||
import com.lzbi.framework.web.service.TokenService; |
|||
import com.lzbi.system.service.ISysConfigService; |
|||
import com.lzbi.system.service.ISysUserService; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.security.authentication.AuthenticationManager; |
|||
import org.springframework.security.authentication.BadCredentialsException; |
|||
import org.springframework.security.authentication.UsernamePasswordAuthenticationToken; |
|||
import org.springframework.security.core.Authentication; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import javax.annotation.Resource; |
|||
|
|||
@Service |
|||
public class LoginService { |
|||
|
|||
@Autowired |
|||
private TokenService tokenService; |
|||
|
|||
@Resource |
|||
private AuthenticationManager authenticationManager; |
|||
|
|||
@Autowired |
|||
private RedisCache redisCache; |
|||
|
|||
@Autowired |
|||
private ISysUserService userService; |
|||
|
|||
@Autowired |
|||
private ISysConfigService configService; |
|||
|
|||
/** |
|||
* 登录验证 |
|||
* |
|||
* @param username 用户名 |
|||
* @param password 密码 |
|||
* @param code 验证码 |
|||
* @param uuid 唯一标识 |
|||
* @return 结果 |
|||
*/ |
|||
public AjaxResult login(String username, String password, String code, String uuid) |
|||
{ |
|||
AjaxResult ajax = AjaxResult.success(); |
|||
// 验证码校验
|
|||
validateCaptcha(username, code, uuid); |
|||
// 登录前置校验
|
|||
loginPreCheck(username, password); |
|||
// 用户验证
|
|||
Authentication authentication = null; |
|||
try |
|||
{ |
|||
UsernamePasswordAuthenticationToken authenticationToken = new UsernamePasswordAuthenticationToken(username, password); |
|||
AuthenticationContextHolder.setContext(authenticationToken); |
|||
// 该方法会去调用UserDetailsServiceImpl.loadUserByUsername
|
|||
authentication = authenticationManager.authenticate(authenticationToken); |
|||
} |
|||
catch (Exception e) |
|||
{ |
|||
if (e instanceof BadCredentialsException) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("user.password.not.match"))); |
|||
throw new UserPasswordNotMatchException(); |
|||
} |
|||
else |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, e.getMessage())); |
|||
throw new ServiceException(e.getMessage()); |
|||
} |
|||
} |
|||
finally |
|||
{ |
|||
AuthenticationContextHolder.clearContext(); |
|||
} |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_SUCCESS, MessageUtils.message("user.login.success"))); |
|||
LoginUser loginUser = (LoginUser) authentication.getPrincipal(); |
|||
SysUser user = loginUser.getUser(); |
|||
recordLoginInfo(loginUser.getUserId()); |
|||
// 生成token
|
|||
String token = tokenService.createToken(loginUser); |
|||
ajax.put(Constants.TOKEN, token); |
|||
ajax.put("nickName", user.getNickName()); |
|||
ajax.put("phone", user.getPhonenumber()); |
|||
return ajax; |
|||
} |
|||
|
|||
/** |
|||
* 校验验证码 |
|||
* |
|||
* @param username 用户名 |
|||
* @param code 验证码 |
|||
* @param uuid 唯一标识 |
|||
* @return 结果 |
|||
*/ |
|||
public void validateCaptcha(String username, String code, String uuid) |
|||
{ |
|||
boolean captchaEnabled = configService.selectCaptchaEnabled(); |
|||
if (captchaEnabled) |
|||
{ |
|||
String verifyKey = CacheConstants.CAPTCHA_CODE_KEY + StringUtils.nvl(uuid, ""); |
|||
String captcha = redisCache.getCacheObject(verifyKey); |
|||
redisCache.deleteObject(verifyKey); |
|||
if (captcha == null) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("user.jcaptcha.expire"))); |
|||
throw new CaptchaExpireException(); |
|||
} |
|||
if (!code.equalsIgnoreCase(captcha)) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("user.jcaptcha.error"))); |
|||
throw new CaptchaException(); |
|||
} |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 登录前置校验 |
|||
* @param username 用户名 |
|||
* @param password 用户密码 |
|||
*/ |
|||
public void loginPreCheck(String username, String password) |
|||
{ |
|||
// 用户名或密码为空 错误
|
|||
if (StringUtils.isEmpty(username) || StringUtils.isEmpty(password)) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("not.null"))); |
|||
throw new UserNotExistsException(); |
|||
} |
|||
// 密码如果不在指定范围内 错误
|
|||
if (password.length() < UserConstants.PASSWORD_MIN_LENGTH |
|||
|| password.length() > UserConstants.PASSWORD_MAX_LENGTH) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("user.password.not.match"))); |
|||
throw new UserPasswordNotMatchException(); |
|||
} |
|||
// 用户名不在指定范围内 错误
|
|||
if (username.length() < UserConstants.USERNAME_MIN_LENGTH |
|||
|| username.length() > UserConstants.USERNAME_MAX_LENGTH) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("user.password.not.match"))); |
|||
throw new UserPasswordNotMatchException(); |
|||
} |
|||
// IP黑名单校验
|
|||
String blackStr = configService.selectConfigByKey("sys.login.blackIPList"); |
|||
if (IpUtils.isMatchedIp(blackStr, IpUtils.getIpAddr())) |
|||
{ |
|||
AsyncManager.me().execute(AsyncFactory.recordLogininfor(username, Constants.LOGIN_FAIL, MessageUtils.message("login.blocked"))); |
|||
throw new BlackListException(); |
|||
} |
|||
} |
|||
|
|||
/** |
|||
* 记录登录信息 |
|||
* |
|||
* @param userId 用户ID |
|||
*/ |
|||
public void recordLoginInfo(Long userId) |
|||
{ |
|||
SysUser sysUser = new SysUser(); |
|||
sysUser.setUserId(userId); |
|||
sysUser.setLoginIp(IpUtils.getIpAddr()); |
|||
sysUser.setLoginDate(DateUtils.getNowDate()); |
|||
userService.updateUserProfile(sysUser); |
|||
} |
|||
} |
|||
@ -1,62 +0,0 @@ |
|||
package com.lzbi.wechat.service; |
|||
|
|||
import com.lzbi.wechat.domain.SysWechat; |
|||
import com.lzbi.wechat.mapper.SysWechatMapper; |
|||
import org.springframework.stereotype.Service; |
|||
|
|||
import javax.annotation.Resource; |
|||
|
|||
/** |
|||
* 微信用户关系业务访问层 |
|||
*/ |
|||
@Service |
|||
public class SysWechatService { |
|||
|
|||
@Resource |
|||
private SysWechatMapper sysWechatMapper; |
|||
|
|||
/** |
|||
* 查询微信用户关系 |
|||
* @param id |
|||
* @return |
|||
*/ |
|||
public SysWechat selectWechatById(Long id) { |
|||
return sysWechatMapper.selectSysWechatById(id); |
|||
} |
|||
|
|||
/** |
|||
* 查询微信用户关系 |
|||
* @param openId |
|||
* @return |
|||
*/ |
|||
public SysWechat selectWechatByOpenId(String openId) { |
|||
return sysWechatMapper.selectWechatByOpenId(openId); |
|||
} |
|||
|
|||
/** |
|||
* 增加微信用户关系 |
|||
* @param sysWechat |
|||
* @return |
|||
*/ |
|||
public int insertWechat(SysWechat sysWechat) { |
|||
return sysWechatMapper.insertSysWechat(sysWechat); |
|||
} |
|||
|
|||
/** |
|||
* 修改微信用户关系 |
|||
* @param sysWechat |
|||
* @return |
|||
*/ |
|||
public int updateWechat(SysWechat sysWechat) { |
|||
return sysWechatMapper.updateSysWechat(sysWechat); |
|||
} |
|||
|
|||
/** |
|||
* 删除微信用户关系 |
|||
* @param id |
|||
* @return |
|||
*/ |
|||
public int deleteWechat(Long id) { |
|||
return sysWechatMapper.deleteSysWechat(id); |
|||
} |
|||
} |
|||
@ -1,245 +0,0 @@ |
|||
package com.lzbi.wechat.service; |
|||
|
|||
import com.lzbi.asset.mapper.DcBaseAssetInfoMapper; |
|||
import com.lzbi.common.constant.BizConstants; |
|||
import com.lzbi.common.constant.TargetModelCodeConstants; |
|||
import com.lzbi.draft.mapper.DcBusiTargetDraftDaynewMapper; |
|||
import com.lzbi.draft.mapper.DcBusiTargetDraftMonthMapper; |
|||
import com.lzbi.system.service.ISysDeptService; |
|||
import com.lzbi.targetFolder.mapper.DcBaseAssetTargetMapper; |
|||
import com.lzbi.wechat.domain.dto.TargetModelValueDTO; |
|||
import com.lzbi.wechat.domain.vo.TargetPlanVO; |
|||
import com.lzbi.wechat.domain.vo.TargetResultVO; |
|||
import com.lzbi.wechat.domain.vo.TargetVO; |
|||
import org.apache.commons.lang3.StringUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.util.CollectionUtils; |
|||
|
|||
import javax.annotation.Resource; |
|||
import java.text.DecimalFormat; |
|||
import java.util.*; |
|||
import java.util.stream.Collectors; |
|||
|
|||
@Service |
|||
public class TargetService { |
|||
|
|||
@Autowired |
|||
private ISysDeptService sysDeptService; |
|||
|
|||
@Resource |
|||
private DcBaseAssetInfoMapper dcBaseAssetInfoMapper; |
|||
|
|||
@Resource |
|||
private DcBaseAssetTargetMapper dcBaseAssetTargetMapper; |
|||
|
|||
@Resource |
|||
private DcBusiTargetDraftDaynewMapper dcBusiTargetDraftDaynewMapper; |
|||
|
|||
@Resource |
|||
private DcBusiTargetDraftMonthMapper dcBusiTargetDraftMonthMapper; |
|||
|
|||
private TargetModelValueDTO buildeTargetModelValueDTO(List<String> targetModelCodeList, Long deptId, String date) { |
|||
String year = null; |
|||
String month = null; |
|||
String day = null; |
|||
if (StringUtils.isNotBlank(date)) { |
|||
String[] arr = date.split("-"); |
|||
if (arr.length == 3) { |
|||
year = arr[0]; |
|||
month = arr[1]; |
|||
day = arr[2]; |
|||
} else { |
|||
throw new RuntimeException("日期格式不正确"); |
|||
} |
|||
} |
|||
return new TargetModelValueDTO(targetModelCodeList, deptId, year, month, day); |
|||
} |
|||
|
|||
public Double getHeatRadiatingArea(Long deptId, String date) { |
|||
List<String> targetModelCodeList = new ArrayList<>(); |
|||
targetModelCodeList.add(TargetModelCodeConstants.总开栓面积); |
|||
TargetModelValueDTO targetModelValueDTO = buildeTargetModelValueDTO(targetModelCodeList, deptId, date); |
|||
List<TargetResultVO> targetResultVOList = dcBusiTargetDraftDaynewMapper.selectDayTargetModelValue(targetModelValueDTO); |
|||
Double result = null; |
|||
if (!CollectionUtils.isEmpty(targetResultVOList)) { |
|||
result = targetResultVOList.get(0).getValue(); |
|||
} |
|||
return result; |
|||
} |
|||
|
|||
public Map<String, TargetResultVO> getComanyTarget(Long deptId, String date) { |
|||
List<String> targetModelCodeList = new ArrayList<>(); |
|||
targetModelCodeList.add(TargetModelCodeConstants.总产热量); |
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网补水量); |
|||
targetModelCodeList.add(TargetModelCodeConstants.从大唐补一次网水量); |
|||
targetModelCodeList.add(TargetModelCodeConstants.总厂用电量); |
|||
targetModelCodeList.add(TargetModelCodeConstants.生产用标煤总量); |
|||
targetModelCodeList.add(TargetModelCodeConstants.热耗率); |
|||
TargetModelValueDTO targetModelValueDTO = buildeTargetModelValueDTO(targetModelCodeList, deptId, date); |
|||
List<TargetResultVO> targetResultVOList = dcBusiTargetDraftDaynewMapper.selectDayTargetModelValue(targetModelValueDTO); |
|||
Map<String, TargetResultVO> map = listTransitionMap(targetResultVOList); |
|||
TargetResultVO onceWater = map.get(TargetModelCodeConstants.一次网补水量); |
|||
TargetResultVO onceWater2 = map.get(TargetModelCodeConstants.从大唐补一次网水量); |
|||
if (null != onceWater.getValue() && null != onceWater2.getValue()) { |
|||
onceWater.setValue(onceWater.getValue() + onceWater2.getValue()); |
|||
} |
|||
map.remove(TargetModelCodeConstants.从大唐补一次网水量); |
|||
map.put(TargetModelCodeConstants.一次网补水量, onceWater); |
|||
return map; |
|||
} |
|||
|
|||
public Map<String, TargetResultVO> getHeatSourceTarget(Long deptId, String date, String type) { |
|||
List<String> targetModelCodeList = new ArrayList<>(); |
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网补水量); // 一次网水耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.从大唐补一次网水量); // 一次网水耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.总厂用电量); // 一次网电耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.生产用标煤总量); // 一次网煤耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.总产热量); // 总产热量
|
|||
targetModelCodeList.add(TargetModelCodeConstants.汽炉产汽量); // 总产气量
|
|||
targetModelCodeList.add(TargetModelCodeConstants.发电量); // 总发电量
|
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗水量); // 二次网总水耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗电量); // 二次网总电耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网供水温度); // 一次网供温
|
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网回水温度); // 一次网回温
|
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网耗水率); // 一次网水单耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.热源厂电耗率); // 一次网电单耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.单位面积耗标煤); // 一次网煤单耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗水率); // 二次网水单耗
|
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗电率); // 二次网电单耗
|
|||
TargetModelValueDTO targetModelValueDTO = buildeTargetModelValueDTO(targetModelCodeList, deptId, date); |
|||
Map<String, TargetResultVO> map; |
|||
if (BizConstants.TargetType.DAY.equals(type)) { |
|||
List<TargetResultVO> targetResultVOList = dcBusiTargetDraftDaynewMapper.selectDayTargetModelValue(targetModelValueDTO); |
|||
map = listTransitionMap(targetResultVOList); |
|||
} else { |
|||
List<TargetResultVO> targetResultVOList = dcBusiTargetDraftDaynewMapper.selectTotalTargetModelValue(targetModelValueDTO); |
|||
map = listTransitionMap(targetResultVOList); |
|||
} |
|||
TargetResultVO targetResultVO1 = map.get(TargetModelCodeConstants.一次网补水量); |
|||
TargetResultVO targetResultVO2 = map.get(TargetModelCodeConstants.从大唐补一次网水量); |
|||
if (null != targetResultVO1.getValue() && null != targetResultVO2.getValue()) { |
|||
targetResultVO1.setValue(targetResultVO1.getValue() + targetResultVO2.getValue()); |
|||
} else if (null == targetResultVO1.getValue() && null != targetResultVO2.getValue()) { |
|||
targetResultVO1.setValue(targetResultVO2.getValue()); |
|||
} |
|||
map.remove(TargetModelCodeConstants.从大唐补一次网水量); |
|||
return map; |
|||
} |
|||
|
|||
public Map<String, TargetResultVO> getHeatExchangeStationParams(Long deptId) { |
|||
Map<String, TargetResultVO> map = new HashMap<>(); |
|||
map.put("014", new TargetResultVO("014", "一次网回压", "Mpa", 14123123D)); |
|||
map.put("013", new TargetResultVO("013", "一次网供压", "Mpa", 2697D)); |
|||
map.put("011", new TargetResultVO("011", "一次网供温", "°C", 16791D)); |
|||
map.put("012", new TargetResultVO("012", "一次网回温", "°C", 11679D)); |
|||
map.put("007", new TargetResultVO("007", "瞬时流量", "m³/h", 8971D)); |
|||
map.put("008", new TargetResultVO("008", "瞬时热量", "kcal", 14123123D)); |
|||
map.put("009", new TargetResultVO("009", "累计热量", "kcal", 2697D)); |
|||
map.put("047", new TargetResultVO("047", "二次网供水压力", "Mpa", 16791D)); |
|||
map.put("048", new TargetResultVO("048", "二次网回水压力", "Mpa", 11679D)); |
|||
map.put("045", new TargetResultVO("045", "二次网供水温", "°C", 8971D)); |
|||
map.put("046", new TargetResultVO("046", "二次网回水温", "°C", 8971D)); |
|||
map.put("001", new TargetResultVO("001", "电调阀开度给定", "%", 14123123D)); |
|||
map.put("002", new TargetResultVO("002", "电调阀开度反馈", "%", 2697D)); |
|||
map.put("015", new TargetResultVO("015", "水箱水位计", "GJ", 16791D)); |
|||
map.put("004", new TargetResultVO("004", "电调阀控制模式选择", "GJ", 11679D)); |
|||
map.put("003", new TargetResultVO("003", "电调阀远控/就地", "°C", 8971D)); |
|||
map.put("044", new TargetResultVO("044", "二次网压差设定", "%", 14123123D)); |
|||
map.put("019", new TargetResultVO("019", "一次网管道泵上电", "", 2697D)); |
|||
map.put("020", new TargetResultVO("020", "一次网管道泵下电", "", 16791D)); |
|||
map.put("005", new TargetResultVO("005", "二次网供温设定", "", 16791D)); |
|||
map.put("018", new TargetResultVO("018", "一次网管道泵远控/就地", "", 16791D)); |
|||
map.put("021", new TargetResultVO("021", "一次网管道泵启动", "", 16791D)); |
|||
map.put("010", new TargetResultVO("010", "热量累计清零", "kwh", 16791D)); |
|||
map.put("017", new TargetResultVO("017", "总电表", "°C", 16791D)); |
|||
map.put("006", new TargetResultVO("006", "二次网供回水平均温设定", "m³", 16791D)); |
|||
map.put("031", new TargetResultVO("031", "水表（累计补水量）", "%", 16791D)); |
|||
map.put("023", new TargetResultVO("023", "一次网管道泵频率给定", "%", 16791D)); |
|||
map.put("028", new TargetResultVO("028", "一次网混水电调阀开度给定", "%", 16791D)); |
|||
map.put("029", new TargetResultVO("029", "一次网混水电调阀开度反馈", "", 16791D)); |
|||
map.put("035", new TargetResultVO("035", "补水泵1#故障状态", "m³", 16791D)); |
|||
map.put("032", new TargetResultVO("032", "水表（累计补水量清零）", "", 16791D)); |
|||
map.put("036", new TargetResultVO("036", "补水泵2#故障状态", "", 16791D)); |
|||
map.put("037", new TargetResultVO("037", "循环泵远控/就地选择", "", 16791D)); |
|||
map.put("038", new TargetResultVO("038", "循环泵1#/2#泵选择", "", 16791D)); |
|||
map.put("039", new TargetResultVO("039", "循环泵控制模式选择", "", 16791D)); |
|||
map.put("025", new TargetResultVO("025", "一次网管道泵运行/停止状态", "", 16791D)); |
|||
map.put("026", new TargetResultVO("026", "一次网管道泵故障状态", "", 16791D)); |
|||
map.put("027", new TargetResultVO("027", "一次网混水电调阀远控/就地", "", 16791D)); |
|||
map.put("033", new TargetResultVO("033", "补水泵1#运行/停止状态", "", 16791D)); |
|||
map.put("034", new TargetResultVO("034", "补水泵2#运行/停止状态", "", 16791D)); |
|||
map.put("040", new TargetResultVO("040", "循环泵变频上电", "", 16791D)); |
|||
map.put("041", new TargetResultVO("041", "循环泵变频下电", "", 16791D)); |
|||
map.put("042", new TargetResultVO("042", "循环泵变频启动", "", 16791D)); |
|||
map.put("043", new TargetResultVO("043", "循环泵变频停止", "", 16791D)); |
|||
map.put("022", new TargetResultVO("022", "一次网管道泵停止", "", 16791D)); |
|||
map.put("030", new TargetResultVO("030", "水表（瞬时补水量）", "m³", 16791D)); |
|||
map.put("066", new TargetResultVO("066", "一次网管道泵启/停", "", 16791D)); |
|||
map.put("024", new TargetResultVO("024", "一次网管道泵频率反馈", "", 16791D)); |
|||
return map; |
|||
} |
|||
|
|||
public List<List<Object>> getFinishingRate(Long deptId) { |
|||
List<List<Object>> list = new ArrayList<>(); |
|||
List<String> targetModelCodeList = new ArrayList<>(); |
|||
targetModelCodeList.add(TargetModelCodeConstants.一次网耗水率); |
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗水率); |
|||
targetModelCodeList.add(TargetModelCodeConstants.热源厂电耗率); |
|||
targetModelCodeList.add(TargetModelCodeConstants.二次网耗电率); |
|||
targetModelCodeList.add(TargetModelCodeConstants.单位面积耗标煤); |
|||
TargetModelValueDTO targetModelValueDTO = buildeTargetModelValueDTO(targetModelCodeList, deptId, null); |
|||
List<TargetResultVO> targetResultVOList = dcBusiTargetDraftDaynewMapper.selectTotalTargetModelValue(targetModelValueDTO); |
|||
List<TargetPlanVO> targetPlanVOList = dcBusiTargetDraftMonthMapper.selectTotalTargetModelPlanValue(targetModelValueDTO); |
|||
Map<String, TargetResultVO> targetValueMap = null; |
|||
Map<String, Double> targetPlanValueMap = null; |
|||
if (!CollectionUtils.isEmpty(targetResultVOList)) { |
|||
targetValueMap = listTransitionMap(targetResultVOList); |
|||
} |
|||
if (!CollectionUtils.isEmpty(targetPlanVOList)) { |
|||
targetPlanValueMap = targetPlanVOList.stream().collect(Collectors.toMap(TargetPlanVO::getTargetCode, TargetPlanVO::getValue)); |
|||
} |
|||
if (null == targetValueMap || null == targetPlanValueMap) { |
|||
throw new RuntimeException("无数据"); |
|||
} |
|||
List<Object> names = new ArrayList<>(); |
|||
names.add("name"); |
|||
List<Object> values = new ArrayList<>(); |
|||
values.add("总完成率"); |
|||
DecimalFormat decimalFormat = new DecimalFormat("#0.00"); |
|||
for (String targetModelCode : targetModelCodeList) { |
|||
TargetResultVO targetResultVO = targetValueMap.get(targetModelCode); |
|||
Double value = targetResultVO.getValue(); |
|||
Double planValue = targetPlanValueMap.get(targetModelCode); |
|||
if (null == planValue) { |
|||
continue; |
|||
} |
|||
names.add(targetResultVO.getTargetName()); |
|||
values.add(decimalFormat.format((value / planValue) * 100)); |
|||
} |
|||
list.add(names); |
|||
list.add(values); |
|||
return list; |
|||
} |
|||
|
|||
public List<List<Object>> finishingRateLine(Long deptId) { |
|||
List<List<Object>> list = new ArrayList<>(); |
|||
List<Object> list1 = Arrays.asList("product", "2012", "2013", "2014", "2015", "2016", "2017"); |
|||
List<Object> list2 = Arrays.asList("Milk Tea", 56.5, 82.1, 88.7, 70.1, 53.4, 85.1); |
|||
List<Object> list3 = Arrays.asList("Matcha Latte", 51.1, 51.4, 55.1, 53.3, 73.8, 68.7); |
|||
List<Object> list4 = Arrays.asList("Cheese Cocoa", 40.1, 62.2, 69.5, 36.4, 45.2, 32.5); |
|||
List<Object> list5 = Arrays.asList("Walnut Brownie", 25.2, 37.1, 41.2, 18, 33.9, 49.1); |
|||
list.add(list1); |
|||
list.add(list2); |
|||
list.add(list3); |
|||
list.add(list4); |
|||
list.add(list5); |
|||
return list; |
|||
} |
|||
|
|||
private <T extends TargetVO> Map<String, T> listTransitionMap(List<T> list) { |
|||
Map<String, T> map = new HashMap<>(); |
|||
list.forEach(obj -> map.put(obj.getTargetCode(), obj)); |
|||
return map; |
|||
} |
|||
} |
|||
@ -1,161 +0,0 @@ |
|||
package com.lzbi.wechat.service; |
|||
|
|||
import com.alibaba.fastjson2.JSONObject; |
|||
import com.lzbi.common.config.WechatConfig; |
|||
import com.lzbi.common.core.domain.entity.SysUser; |
|||
import com.lzbi.common.core.domain.model.LoginUser; |
|||
import com.lzbi.common.exception.ServiceException; |
|||
import com.lzbi.framework.web.service.SysLoginService; |
|||
import com.lzbi.framework.web.service.SysPermissionService; |
|||
import com.lzbi.framework.web.service.TokenService; |
|||
import com.lzbi.system.service.ISysUserService; |
|||
import com.lzbi.wechat.domain.SysWechat; |
|||
import com.lzbi.wechat.domain.resp.WechatAccessTokenResp; |
|||
import com.lzbi.wechat.domain.resp.WechatCodeLoginResp; |
|||
import com.lzbi.wechat.domain.resp.WechatPhoneNumberResp; |
|||
import com.lzbi.wechat.domain.req.CodeLoginReq; |
|||
import com.lzbi.wechat.domain.req.PhoneNumberLoginReq; |
|||
import com.lzbi.wechat.domain.req.PhoneNumberReq; |
|||
import com.lzbi.wechat.domain.vo.CodeLoginVO; |
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.apache.commons.lang3.ObjectUtils; |
|||
import org.springframework.beans.factory.annotation.Autowired; |
|||
import org.springframework.http.HttpEntity; |
|||
import org.springframework.http.HttpHeaders; |
|||
import org.springframework.http.MediaType; |
|||
import org.springframework.stereotype.Service; |
|||
import org.springframework.transaction.annotation.Transactional; |
|||
import org.springframework.web.client.RestTemplate; |
|||
|
|||
import java.util.HashMap; |
|||
import java.util.Map; |
|||
|
|||
/** |
|||
* 微信服务业务逻辑层 |
|||
*/ |
|||
@Slf4j |
|||
@Service |
|||
public class WechatService { |
|||
|
|||
@Autowired |
|||
private WechatConfig wechatConfig; |
|||
|
|||
@Autowired |
|||
private RestTemplate restTemplate; |
|||
|
|||
@Autowired |
|||
private SysWechatService sysWechatService; |
|||
|
|||
@Autowired |
|||
private ISysUserService sysUserService; |
|||
|
|||
@Autowired |
|||
private SysLoginService sysLoginService; |
|||
|
|||
@Autowired |
|||
private TokenService tokenService; |
|||
|
|||
@Autowired |
|||
private SysPermissionService permissionService; |
|||
|
|||
/** |
|||
* 登录凭证登录 |
|||
* |
|||
* @param codeLoginReq |
|||
* @return |
|||
*/ |
|||
public CodeLoginVO codeLogin(CodeLoginReq codeLoginReq) { |
|||
CodeLoginVO codeLoginVO = new CodeLoginVO(); |
|||
// 微信登录凭证登录请求，获取到open_id
|
|||
Map<String, Object> params = new HashMap<>(); |
|||
params.put("appid", wechatConfig.getAppId()); |
|||
params.put("secret", wechatConfig.getAppSecret()); |
|||
params.put("js_code", codeLoginReq.getCode()); |
|||
params.put("grant_type", "authorization_code"); |
|||
WechatCodeLoginResp resp = restTemplate.getForObject(wechatConfig.getCode2Session(), WechatCodeLoginResp.class, params); |
|||
if (ObjectUtils.isNotEmpty(resp) && 0L == resp.getErrcode()) { |
|||
String openid = resp.getOpenid(); |
|||
codeLoginVO.setOpenId(openid); |
|||
// 根据open_id到数据库中查询sysWechat信息
|
|||
SysWechat sysWechat = sysWechatService.selectWechatByOpenId(openid); |
|||
// 查询到了的话，执行登录操作，返回token
|
|||
if (ObjectUtils.isNotEmpty(sysWechat)) { |
|||
SysUser sysUser = sysUserService.selectUserByPhonenumber(sysWechat.getPhone()); |
|||
if (ObjectUtils.isNotEmpty(sysUser)) { |
|||
String token = this.getToken(sysUser); |
|||
codeLoginVO.setToken(token); |
|||
} |
|||
} |
|||
} else { |
|||
log.error("调用微信服务小程序登录接口时失败，{}， {}", resp.getErrcode(), resp.getErrmsg()); |
|||
throw new ServiceException(resp.getErrmsg(), resp.getErrcode()); |
|||
} |
|||
return codeLoginVO; |
|||
} |
|||
|
|||
@Transactional(rollbackFor = Exception.class) |
|||
public String phoneNumberLogin(PhoneNumberLoginReq phoneNumberLoginReq) { |
|||
// 微信和用户信息绑定
|
|||
SysWechat sysWechat = new SysWechat(phoneNumberLoginReq.getOpenId(), phoneNumberLoginReq.getPhone()); |
|||
int i = sysWechatService.insertWechat(sysWechat); |
|||
if (i > 0) { |
|||
// 获取token
|
|||
SysUser sysUser = sysUserService.selectUserByPhonenumber(sysWechat.getPhone()); |
|||
if (ObjectUtils.isNotEmpty(sysUser)) { |
|||
return this.getToken(sysUser); |
|||
} |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
/** |
|||
* 获取手机号 |
|||
* @param phoneNumberReq |
|||
* @return |
|||
*/ |
|||
public String getPhoneNumber(PhoneNumberReq phoneNumberReq) { |
|||
// 获取接口调用凭据
|
|||
Map<String, Object> getAccessTokenParams = new HashMap<>(); |
|||
getAccessTokenParams.put("appid", wechatConfig.getAppId()); |
|||
getAccessTokenParams.put("secret", wechatConfig.getAppSecret()); |
|||
getAccessTokenParams.put("grant_type", "client_credential"); |
|||
WechatAccessTokenResp wechatAccessTokenResp = restTemplate.getForObject(wechatConfig.getAccessToken(), WechatAccessTokenResp.class, getAccessTokenParams); |
|||
if (ObjectUtils.isNotEmpty(wechatAccessTokenResp) && null == wechatAccessTokenResp.getErrcode()) { |
|||
// 获取手机号
|
|||
String accessToken = wechatAccessTokenResp.getAccess_token(); |
|||
Map<String, Object> getPhoneNumberParams = new HashMap<>(); |
|||
getPhoneNumberParams.put("access_token", accessToken); |
|||
HttpHeaders headers = new HttpHeaders(); |
|||
headers.setContentType(MediaType.APPLICATION_JSON); |
|||
Map<String, Object> getPhoneNumberBody = new HashMap<>(); |
|||
getPhoneNumberBody.put("code", phoneNumberReq.getCode()); |
|||
HttpEntity<String> entity = new HttpEntity<>(JSONObject.toJSONString(getPhoneNumberBody), headers); |
|||
WechatPhoneNumberResp resp = restTemplate.postForObject(wechatConfig.getPhoneNumber(), entity, WechatPhoneNumberResp.class, getPhoneNumberParams); |
|||
if (ObjectUtils.isNotEmpty(resp) && 0L == resp.getErrcode()) { |
|||
if (null != resp.getPhone_info()) { |
|||
return resp.getPhone_info().getPurePhoneNumber(); |
|||
} |
|||
} else { |
|||
log.error("调用微信服务获取手机号接口时失败，{}， {}", resp.getErrcode(), resp.getErrmsg()); |
|||
throw new ServiceException(resp.getErrmsg(), resp.getErrcode()); |
|||
} |
|||
} else { |
|||
log.error("调用微信服务获取access_token接口时失败，{}， {}", wechatAccessTokenResp.getErrcode(), wechatAccessTokenResp.getErrmsg()); |
|||
throw new ServiceException(wechatAccessTokenResp.getErrmsg(), wechatAccessTokenResp.getErrcode()); |
|||
} |
|||
return null; |
|||
} |
|||
|
|||
/** |
|||
* 获取token |
|||
* @param sysUser |
|||
* @return |
|||
*/ |
|||
private String getToken(SysUser sysUser) { |
|||
LoginUser loginUser = new LoginUser(sysUser.getUserId(), sysUser.getDeptId(), sysUser, permissionService.getMenuPermission(sysUser)); |
|||
sysLoginService.recordLoginInfo(loginUser.getUserId()); |
|||
// 生成token
|
|||
return tokenService.createToken(loginUser); |
|||
} |
|||
|
|||
} |
|||
@ -1,149 +0,0 @@ |
|||
package com.lzbi.wechat.webSocket; |
|||
|
|||
import lombok.extern.slf4j.Slf4j; |
|||
import org.springframework.stereotype.Component; |
|||
|
|||
import javax.websocket.*; |
|||
import javax.websocket.server.PathParam; |
|||
import javax.websocket.server.ServerEndpoint; |
|||
import java.io.IOException; |
|||
import java.util.Map; |
|||
import java.util.concurrent.ConcurrentHashMap; |
|||
import java.util.concurrent.atomic.AtomicInteger; |
|||
|
|||
/** |
|||
* @ClassName HeatSourceServer |
|||
* @Description 热源列表服务 |
|||
* @Author lienbo |
|||
* @Date 2024/01/25 16:06 |
|||
* @Version V1.0 |
|||
*/ |
|||
@Component |
|||
@Slf4j |
|||
@ServerEndpoint("/ws/heatSourceList/{userId}/{deptId}") |
|||
public class HeatSourceServer { |
|||
|
|||
/** |
|||
* 静态变量，用来记录当前在线连接数，线程安全的类。 |
|||
*/ |
|||
private static AtomicInteger onlineSessionClientCount = new AtomicInteger(0); |
|||
|
|||
/** |
|||
* 存放所有在线的客户端 |
|||
*/ |
|||
private static Map<Long, Session> onlineSessionClientMap = new ConcurrentHashMap<>(); |
|||
|
|||
/** |
|||
* 存放所有在线的用户和要查询的组织id |
|||
*/ |
|||
private static Map<Long, Long> onlineUserDeptMap = new ConcurrentHashMap<>(); |
|||
|
|||
/** |
|||
* 连接建立成功调用的方法。由前端<code>new WebSocket</code>触发 |
|||
* |
|||
* @param userId 每次页面建立连接时传入到服务端的id，比如用户id等。可以自定义。 |
|||
* @param deptId 公司ID |
|||
* @param session 与某个客户端的连接会话，需要通过它来给客户端发送消息 |
|||
*/ |
|||
@OnOpen |
|||
public void onOpen(@PathParam("userId") Long userId, @PathParam("deptId") Long deptId, Session session) { |
|||
log.info("连接建立中 ==> session_id = {}，userId = {}，deptId = {}", session.getId(), userId, deptId); |
|||
onlineUserDeptMap.put(userId, deptId); |
|||
onlineSessionClientMap.put(userId, session); |
|||
//在线数加1
|
|||
onlineSessionClientCount.incrementAndGet(); |
|||
sendToOne(userId, "hello " + userId + " 您已连接成功"); |
|||
log.info("连接建立成功，当前在线数为：{} ==> 开始监听新连接：session_id = {}， sid = {},。", onlineSessionClientCount, session.getId(), userId); |
|||
} |
|||
|
|||
/** |
|||
* 连接关闭调用的方法。由前端<code>socket.close()</code>触发 |
|||
* |
|||
* @param userId |
|||
* @param session |
|||
*/ |
|||
@OnClose |
|||
public void onClose(@PathParam("userId") Long userId, Session session) { |
|||
// 从 Map中移除
|
|||
onlineSessionClientMap.remove(userId); |
|||
//在线数减1
|
|||
onlineSessionClientCount.decrementAndGet(); |
|||
log.info("连接关闭成功，当前在线数为：{} ==> 关闭该连接信息：session_id = {}， userId = {},。", onlineSessionClientCount, session.getId(), userId); |
|||
} |
|||
|
|||
/** |
|||
* 收到客户端消息后调用的方法。由前端<code>socket.send</code>触发 |
|||
* * 当服务端执行toSession.getAsyncRemote().sendText(xxx)后，前端的socket.onmessage得到监听。 |
|||
* |
|||
* @param message |
|||
* @param session |
|||
*/ |
|||
@OnMessage |
|||
public void onMessage(String message, Session session) throws IOException { |
|||
log.info("服务端收到客户端消息 ==>, message = {}", message); |
|||
session.getBasicRemote().sendText(message); |
|||
} |
|||
|
|||
/** |
|||
* 发生错误调用的方法 |
|||
* |
|||
* @param session |
|||
* @param error |
|||
*/ |
|||
@OnError |
|||
public void onError(Session session, Throwable error) { |
|||
log.error("WebSocket发生错误，错误信息为：" + error.getMessage()); |
|||
error.printStackTrace(); |
|||
} |
|||
|
|||
/** |
|||
* 功能描述: 发送移除黑名单消息 |
|||
* @param userId |
|||
* @Author: lienbo |
|||
* @Date: 2023/8/27 23:19 |
|||
* @return: void |
|||
*/ |
|||
public void sendRemoveBlackList(Long userId) { |
|||
log.info("发送移除黑名单消息 ==>, userId = {}", userId); |
|||
this.sendToOne(userId, "remove"); |
|||
} |
|||
|
|||
/** |
|||
* 群发消息 |
|||
* |
|||
* @param message 消息 |
|||
*/ |
|||
private void sendToAll(String message) { |
|||
// 遍历在线map集合
|
|||
onlineSessionClientMap.forEach((userId, toSession) -> { |
|||
log.info("服务端给客户端群发消息 ==> userId = {}, message = {}", userId, message); |
|||
toSession.getAsyncRemote().sendText(message); |
|||
}); |
|||
} |
|||
|
|||
/** |
|||
* 指定发送消息 |
|||
* |
|||
* @param userId |
|||
* @param message |
|||
*/ |
|||
private void sendToOne(Long userId, String message) { |
|||
// 通过sid查询map中是否存在
|
|||
Session toSession = onlineSessionClientMap.get(userId); |
|||
if (toSession == null) { |
|||
log.error("服务端给客户端发送消息 ==> userId = {} 不存在, message = {}", userId, message); |
|||
return; |
|||
} |
|||
// 异步发送
|
|||
log.info("服务端给客户端发送消息 ==> userId = {}, message = {}", userId, message); |
|||
toSession.getAsyncRemote().sendText(message); |
|||
/* |
|||
// 同步发送
|
|||
try { |
|||
toSession.getBasicRemote().sendText(message); |
|||
} catch (IOException e) { |
|||
log.error("发送消息失败，WebSocket IO异常"); |
|||
e.printStackTrace(); |
|||
}*/ |
|||
} |
|||
} |
|||
@ -1,26 +0,0 @@ |
|||
<?xml version="1.0" encoding="UTF-8" ?> |
|||
<!DOCTYPE mapper |
|||
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" |
|||
"http://mybatis.org/dtd/mybatis-3-mapper.dtd"> |
|||
<mapper namespace="com.lzbi.wechat.mapper.SysWechatMapper"> |
|||
|
|||
<select id="selectSysWechatById" resultType="com.lzbi.wechat.domain.SysWechat"> |
|||
select id, phone, app_id from sys_wechat where id = #{id} |
|||
</select> |
|||
|
|||
<select id="selectWechatByOpenId" resultType="com.lzbi.wechat.domain.SysWechat"> |
|||
select id, phone, app_id from sys_wechat where open_id = #{openId} |
|||
</select> |
|||
|
|||
<insert id="insertSysWechat" parameterType="com.lzbi.wechat.domain.SysWechat"> |
|||
insert into sys_wechat (open_id, phone) values (#{openId}, #{phone}) |
|||
</insert> |
|||
|
|||
<update id="updateSysWechat"> |
|||
update sys_wechat set open_id = #{openId}, phone = #{phone} where id = #{id} |
|||
</update> |
|||
|
|||
<delete id="deleteSysWechat"> |
|||
delete from sys_wechat where id = #{id} |
|||
</delete> |
|||
</mapper> |
|||
Loading…
Reference in new issue