EMPT / location · 提交

转到一个项目

作者 朱兆平
提交 d600efa0321c3c230fb605fa781d9b0018d0bef9 2 个父辈 2a5ebce3 bf8f723f

Merge branch 'water_electricity' of 118.31.66.166:EMPT/location 

# Conflicts:
#	pom.xml
#	src/main/java/com/sunyo/energy/location/model/Location.java
#	src/main/resources/application.yml
#	src/main/resources/mapping/LocationMapper.xml
内嵌 并排对比
正在显示 26 个修改的文件 包含 1902 行增加 和 75 行删除
... ... @@ -33,16 +33,6 @@
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-websocket</artifactId>
<exclusions>
<exclusion>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.1.1</version>
... ... @@ -89,10 +79,16 @@
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.tianbo</groupId>
<artifactId>util</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<dependency>
<groupId>com.tianbo</groupId>
<artifactId>util</artifactId>
<version>1.0-SNAPSHOT</version>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<!--<dependency>-->
<!--<groupId>com.fasterxml.jackson.core</groupId>-->
... ...
... ... @@ -3,9 +3,13 @@ package com.sunyo.energy.location;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.scheduling.annotation.EnableScheduling;
@SpringBootApplication()
@EnableScheduling
@MapperScan("com.sunyo.energy.location.dao")
@ComponentScan("com.sunyo.energy.location")
public class BootApplication {
public static void main(String[] args) {
... ...
package com.sunyo.energy.location.controller;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.sunyo.energy.location.controller.response.ResultJson;
import com.sunyo.energy.location.dao.LocationMapper;
import com.sunyo.energy.location.model.Location;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
@RequestMapping("/location")
public class LocationController {
@Autowired
private LocationMapper locationMapper;
@RequestMapping(value="/list",method= RequestMethod.GET)
public ResultJson startActivityDemo(@RequestParam(value = "pageNum",required = false,defaultValue = "1")
int pageNum,
@RequestParam(value = "pageSize",required = false,defaultValue = "5")
int pageSize){
Page<Location> page = PageHelper.startPage(pageNum,pageSize);
List<Location> list= locationMapper.selectAll(0);
PageInfo<Location> result = new PageInfo<Location>(list);
return new ResultJson("200","success",result);
}
}
package com.sunyo.energy.location.controller;
import com.github.pagehelper.PageInfo;
import com.sunyo.energy.location.controller.response.ResultJson;
import com.sunyo.energy.location.model.PayRecords;
import com.sunyo.energy.location.service.PayOrderService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.models.auth.In;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
/**
* Created by XYH on 2019/12/16.
* 订单查询，新增，更新，删除
*/
@Api(description = "订单管理")
@RestController
@RequestMapping("/order")
public class PayOrderController {
@Autowired
PayOrderService payOrderService;
@ApiOperation(value = "查询缴费订单")
@RequestMapping("/list")
public PageInfo<PayRecords> getOrder(@RequestParam(value = "pageSize", required = false, defaultValue = "1") int pageSize,
@RequestParam(value = "pageNum", required = false, defaultValue = "5") int pageNum,
@RequestParam(value = "orderNumber",required = false) String orderNumber,
@RequestParam(value = "payTime", required = false) String payTime ){
return payOrderService.getOrder(pageSize, pageNum, orderNumber, payTime);
}
@ApiOperation(value = "新增缴费订单")
@PostMapping("/add")
public ResultJson addOrder(@RequestBody PayRecords records){
int mgs=0;
int result=payOrderService.addOrder(records);
if(result>0){
mgs=1;
}
return mgs==1?new ResultJson("200","新增订单成功"):new ResultJson("500","新增订单失败");
}
@ApiOperation(value = "更新缴费订单")
@PutMapping("/edi")
public ResultJson ediOrder(@RequestBody PayRecords records){
int mgs=0;
int result=payOrderService.ediOrder(records);
if(result>0){
mgs=1;
}
return mgs==1? new ResultJson("200","订单信息更新成功"):new ResultJson("500","订单信息更新失败");
}
@ApiOperation(value = "删除缴费订单")
@DeleteMapping("/del")
public ResultJson delOrder(@RequestBody PayRecords payRecords){
int mgs=0;
int result=payOrderService.delOrder(payRecords);
if(result>0){
mgs=1;
}
return mgs==1? new ResultJson("200","订单信息移出成功"):new ResultJson("500","订单信息删除失败");
}
}
... ...
package com.sunyo.energy.location.controller;
import com.github.pagehelper.PageInfo;
import com.sunyo.energy.location.model.PayRecords;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import com.sunyo.energy.location.service.WaterElectricityParameterService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@Api(description = "用户支付管理")
@RestController
@RequestMapping("/userPayOrder")
public class UserPayController {
@Autowired
private WaterElectricityParameterService waterElectricityParameterService;
@ApiOperation(value = "查询缴费订单")
@RequestMapping("/list")
public List userPayList(@RequestParam(value = "roomNumber", required = false) String roomNumber ){
return waterElectricityParameterService.userPayList(roomNumber);
}
}
... ...
package com.sunyo.energy.location.controller;
import com.sunyo.energy.location.controller.response.ResultJson;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import com.sunyo.energy.location.service.WaterElectricityParameterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import java.util.Date;
@RequestMapping("/electricity_meter")
@Controller
public class WaterElectricityParameterController {
@Autowired
private WaterElectricityParameterService waterElectricityParameterService;
/**
* 电表参数配置
*
*/
@RequestMapping("/add")
@ResponseBody
public ResultJson eetParam(ResultJson resultJson, WaterElectricityParameter waterElectricityParameter){
try {
if (waterElectricityParameterService.countOne(waterElectricityParameter.getEeId())>0){
resultJson.setCode("200");
return resultJson;
}else {
int i = waterElectricityParameterService.insertSelective(waterElectricityParameter);
if (i>0){
resultJson.setCode("200");
resultJson.setMsg("添加成功");
return resultJson;
}else {
resultJson.setCode("500");
resultJson.setMsg("网络异常");
return resultJson;
}
}
}catch (Exception e){
e.printStackTrace();
resultJson.setCode("500");
resultJson.setMsg("网络异常");
return resultJson;
}
}
/**
* 电表参数查询
*/
@RequestMapping("/getEEModel")
@ResponseBody
public WaterElectricityParameter getEEModel(@RequestParam(value = "eeId", required = false) String eeId){
WaterElectricityParameter oneElectricity = waterElectricityParameterService.findOneElectricity(eeId);
System.out.println("111");
return oneElectricity;
}
/**
* 电表参数编辑
*/
@RequestMapping("/edit")
@ResponseBody
public ResultJson edit(ResultJson resultJson, WaterElectricityParameter waterElectricityParameter){
try {
if (waterElectricityParameterService.updateByPrimaryKeySelective(waterElectricityParameter)>0){
resultJson.setCode("200");
return resultJson;
}else {
resultJson.setCode("500");
resultJson.setMsg("网络异常");
return resultJson;
}
}catch (Exception e){
e.printStackTrace();
resultJson.setCode("500");
resultJson.setMsg("网络异常");
return resultJson;
}
}
}
... ...
package com.sunyo.energy.location.controller;
import com.sunyo.energy.location.controller.response.ResultJson;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import com.sunyo.energy.location.model.WaterMeter;
import com.sunyo.energy.location.service.WaterMeterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
@RequestMapping("/water_meter")
public class WaterMeterController {
@Autowired
private WaterMeterService waterMeterService;
// /**
// * 水表实施信息入库
// * @param resultJson
// * @return
// */
// @RequestMapping("/realTime")
// @ResponseBody
// public ResultJson realTime(ResultJson resultJson){
// int i = waterMeterService.realTime();
// if (i>0){
// resultJson.setCode("200");
// resultJson.setMsg("操作成功");
// }else {
// resultJson.setCode("500");
// resultJson.setMsg("操作失败");
// }
//
// return resultJson;
// }
/**
* 水表单个实施信息查询
*/
@RequestMapping("/findRealTime")
@ResponseBody
public WaterMeter findRealTime(@RequestParam(value = "wmId", required = false) String wmId){
return waterMeterService.findRealTime(wmId);
}
}
... ...
package com.sunyo.energy.location.dao;
import com.sunyo.energy.location.model.Location;
import java.util.List;
public interface LocationMapper {
int deleteByPrimaryKey(Integer id);
int insert(Location record);
int insertSelective(Location record);
List<Location> selectByPrimaryKey(Integer id);
List<Location> selectAll(Integer id);
int updateByPrimaryKeySelective(Location record);
int updateByPrimaryKey(Location record);
}
\ No newline at end of file
package com.sunyo.energy.location.dao;
import com.sunyo.energy.location.model.PayRecords;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface PayRecordsMapper {
int deleteByPrimaryKey(Integer id);
int insert(PayRecords record);
int insertSelective(PayRecords record);
PayRecords selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(PayRecords record);
int updateByPrimaryKey(PayRecords record);
List<PayRecords> findAll(@Param(value = "orderNumber") String orderNumber,
@Param(value = "startTime") String startTime,
@Param(value = "endTime") String endTime);
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.dao;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import java.util.List;
public interface WaterElectricityParameterMapper {
int deleteByPrimaryKey(Integer id);
int insert(WaterElectricityParameter record);
int insertSelective(WaterElectricityParameter record);
WaterElectricityParameter selectByPrimaryKey(Integer id);
int updateByPrimaryKeySelective(WaterElectricityParameter record);
int updateByPrimaryKey(WaterElectricityParameter record);
int countOne(String eeId);
WaterElectricityParameter findOneElectricity(String eeId);
List<WaterElectricityParameter> userPayList(String roomNumber);
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.dao;
import com.sunyo.energy.location.model.WaterMeter;
public interface WaterMeterMapper {
int insert(WaterMeter record);
int insertSelective(WaterMeter record);
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.model;
import java.util.Date;
public class PayRecords {
private Integer id;
private Long payfees;
private Integer payuserid;
private Date paytime;
private Integer paylocationid;
private Boolean paystatus;
private Boolean paytype;
private Boolean payfesstype;
private String ordernumber;
private String reamke1;
private String reamke2;
private String reamke3;
private String reamke4;
private String payusername;
private String paylocationname;
private String paytypeaddress;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Long getPayfees() {
return payfees;
}
public void setPayfees(Long payfees) {
this.payfees = payfees;
}
public Integer getPayuserid() {
return payuserid;
}
public void setPayuserid(Integer payuserid) {
this.payuserid = payuserid;
}
public Date getPaytime() {
return paytime;
}
public void setPaytime(Date paytime) {
this.paytime = paytime;
}
public Integer getPaylocationid() {
return paylocationid;
}
public void setPaylocationid(Integer paylocationid) {
this.paylocationid = paylocationid;
}
public Boolean getPaystatus() {
return paystatus;
}
public void setPaystatus(Boolean paystatus) {
this.paystatus = paystatus;
}
public Boolean getPaytype() {
return paytype;
}
public void setPaytype(Boolean paytype) {
this.paytype = paytype;
}
public Boolean getPayfesstype() {
return payfesstype;
}
public void setPayfesstype(Boolean payfesstype) {
this.payfesstype = payfesstype;
}
public String getOrdernumber() {
return ordernumber;
}
public void setOrdernumber(String ordernumber) {
this.ordernumber = ordernumber == null ? null : ordernumber.trim();
}
public String getReamke1() {
return reamke1;
}
public void setReamke1(String reamke1) {
this.reamke1 = reamke1 == null ? null : reamke1.trim();
}
public String getReamke2() {
return reamke2;
}
public void setReamke2(String reamke2) {
this.reamke2 = reamke2 == null ? null : reamke2.trim();
}
public String getReamke3() {
return reamke3;
}
public void setReamke3(String reamke3) {
this.reamke3 = reamke3 == null ? null : reamke3.trim();
}
public String getReamke4() {
return reamke4;
}
public void setReamke4(String reamke4) {
this.reamke4 = reamke4 == null ? null : reamke4.trim();
}
public String getPayusername() {
return payusername;
}
public void setPayusername(String payusername) {
this.payusername = payusername == null ? null : payusername.trim();
}
public String getPaylocationname() {
return paylocationname;
}
public void setPaylocationname(String paylocationname) {
this.paylocationname = paylocationname == null ? null : paylocationname.trim();
}
public String getPaytypeaddress() {
return paytypeaddress;
}
public void setPaytypeaddress(String paytypeaddress) {
this.paytypeaddress = paytypeaddress == null ? null : paytypeaddress.trim();
}
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.model;
import java.util.Date;
public class WaterElectricityParameter {
private Integer id;
private Boolean prepaid;
private Boolean warningtrip;
private Long warningthreshold;
private Boolean overdraft;
private Long overdraftthreshold;
private Boolean waterload;
private Long water;
private Long power;
private String powerfactor;
private Boolean free;
private Long freeelectricitylimit;
private String freewater;
private String wmId;
private Date creattime;
private String eeId;
private String reamke2;
private String reamke3;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public Boolean getPrepaid() {
return prepaid;
}
public void setPrepaid(Boolean prepaid) {
this.prepaid = prepaid;
}
public Boolean getWarningtrip() {
return warningtrip;
}
public void setWarningtrip(Boolean warningtrip) {
this.warningtrip = warningtrip;
}
public Long getWarningthreshold() {
return warningthreshold;
}
public void setWarningthreshold(Long warningthreshold) {
this.warningthreshold = warningthreshold;
}
public Boolean getOverdraft() {
return overdraft;
}
public void setOverdraft(Boolean overdraft) {
this.overdraft = overdraft;
}
public Long getOverdraftthreshold() {
return overdraftthreshold;
}
public void setOverdraftthreshold(Long overdraftthreshold) {
this.overdraftthreshold = overdraftthreshold;
}
public Boolean getWaterload() {
return waterload;
}
public void setWaterload(Boolean waterload) {
this.waterload = waterload;
}
public Long getWater() {
return water;
}
public void setWater(Long water) {
this.water = water;
}
public Long getPower() {
return power;
}
public void setPower(Long power) {
this.power = power;
}
public String getPowerfactor() {
return powerfactor;
}
public void setPowerfactor(String powerfactor) {
this.powerfactor = powerfactor == null ? null : powerfactor.trim();
}
public Boolean getFree() {
return free;
}
public void setFree(Boolean free) {
this.free = free;
}
public Long getFreeelectricitylimit() {
return freeelectricitylimit;
}
public void setFreeelectricitylimit(Long freeelectricitylimit) {
this.freeelectricitylimit = freeelectricitylimit;
}
public String getFreewater() {
return freewater;
}
public void setFreewater(String freewater) {
this.freewater = freewater == null ? null : freewater.trim();
}
public String getWmId() {
return wmId;
}
public void setWmId(String wmId) {
this.wmId = wmId == null ? null : wmId.trim();
}
public Date getCreattime() {
return creattime;
}
public void setCreattime(Date creattime) {
this.creattime = creattime;
}
public String getEeId() {
return eeId;
}
public void setEeId(String eeId) {
this.eeId = eeId == null ? null : eeId.trim();
}
public String getReamke2() {
return reamke2;
}
public void setReamke2(String reamke2) {
this.reamke2 = reamke2 == null ? null : reamke2.trim();
}
public String getReamke3() {
return reamke3;
}
public void setReamke3(String reamke3) {
this.reamke3 = reamke3 == null ? null : reamke3.trim();
}
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.model;
import java.util.Date;
public class WaterMeter {
private String wmId;
private String wmSacc;
private String wmLacc;
private String wmRdtime;
private String wmFmstate;
private String wmErrmessage;
private String wmVoltage;
private String wmSignalpower;
private Date creattime;
private Date updatetime;
private String reamke1;
private String reamke2;
private String reamke3;
private String reamke4;
public String getWmId() {
return wmId;
}
public void setWmId(String wmId) {
this.wmId = wmId == null ? null : wmId.trim();
}
public String getWmSacc() {
return wmSacc;
}
public void setWmSacc(String wmSacc) {
this.wmSacc = wmSacc == null ? null : wmSacc.trim();
}
public String getWmLacc() {
return wmLacc;
}
public void setWmLacc(String wmLacc) {
this.wmLacc = wmLacc == null ? null : wmLacc.trim();
}
public String getWmRdtime() {
return wmRdtime;
}
public void setWmRdtime(String wmRdtime) {
this.wmRdtime = wmRdtime == null ? null : wmRdtime.trim();
}
public String getWmFmstate() {
return wmFmstate;
}
public void setWmFmstate(String wmFmstate) {
this.wmFmstate = wmFmstate == null ? null : wmFmstate.trim();
}
public String getWmErrmessage() {
return wmErrmessage;
}
public void setWmErrmessage(String wmErrmessage) {
this.wmErrmessage = wmErrmessage == null ? null : wmErrmessage.trim();
}
public String getWmVoltage() {
return wmVoltage;
}
public void setWmVoltage(String wmVoltage) {
this.wmVoltage = wmVoltage == null ? null : wmVoltage.trim();
}
public String getWmSignalpower() {
return wmSignalpower;
}
public void setWmSignalpower(String wmSignalpower) {
this.wmSignalpower = wmSignalpower == null ? null : wmSignalpower.trim();
}
public Date getCreattime() {
return creattime;
}
public void setCreattime(Date creattime) {
this.creattime = creattime;
}
public Date getUpdatetime() {
return updatetime;
}
public void setUpdatetime(Date updatetime) {
this.updatetime = updatetime;
}
public String getReamke1() {
return reamke1;
}
public void setReamke1(String reamke1) {
this.reamke1 = reamke1 == null ? null : reamke1.trim();
}
public String getReamke2() {
return reamke2;
}
public void setReamke2(String reamke2) {
this.reamke2 = reamke2 == null ? null : reamke2.trim();
}
public String getReamke3() {
return reamke3;
}
public void setReamke3(String reamke3) {
this.reamke3 = reamke3 == null ? null : reamke3.trim();
}
public String getReamke4() {
return reamke4;
}
public void setReamke4(String reamke4) {
this.reamke4 = reamke4 == null ? null : reamke4.trim();
}
}
\ No newline at end of file
... ...
package com.sunyo.energy.location.service;
import com.github.pagehelper.PageInfo;
import com.sunyo.energy.location.model.PayRecords;
/**
* Created by XYH on 2019/12/16.
*/
public interface PayOrderService {
PageInfo<PayRecords> getOrder(int pageSize, int pageNum, String orderNumber, String payTime);
int addOrder(PayRecords payRecords);
int ediOrder(PayRecords payRecords);
int delOrder(PayRecords payRecords);
}
... ...
package com.sunyo.energy.location.service;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import java.util.List;
public interface WaterElectricityParameterService {
int insertSelective(WaterElectricityParameter record);
int updateByPrimaryKeySelective(WaterElectricityParameter record);
int countOne(String eeId);
WaterElectricityParameter findOneElectricity(String eeId);
List userPayList(String roomNumber);
}
... ...
package com.sunyo.energy.location.service;
import com.sunyo.energy.location.model.WaterMeter;
public interface WaterMeterService {
int realTime();
WaterMeter findRealTime(String wmId);
}
... ...
package com.sunyo.energy.location.service.imp;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
import com.github.pagehelper.PageInfo;
import com.sunyo.energy.location.dao.PayRecordsMapper;
import com.sunyo.energy.location.model.PayRecords;
import com.sunyo.energy.location.service.PayOrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.List;
/**
* Created by XYH on 2019/12/16.
*/
@Service
public class PayOrderImpl implements PayOrderService {
@Autowired
PayRecordsMapper recordsMapper;
@Override
public PageInfo<PayRecords> getOrder(int pageSize, int pageNum, String orderNumber, String payTime) {
// 开始时间
String startTime = "";
// 结束时间
String endTime = "";
Page<PayRecords> page = PageHelper.startPage(pageNum,pageSize);
if (StringUtils.isEmpty(orderNumber)){
}else if (!orderNumber.contains("-")){
StringBuffer stringBuffer = new StringBuffer(orderNumber);
orderNumber = stringBuffer.insert(3, "-").toString();
}
if (!StringUtils.isEmpty(payTime) && !payTime.contains("undefined")){
String[] split = payTime.split(",");
startTime = split[0].toString();
endTime = split[1].toString();
}
List<PayRecords> list = recordsMapper.findAll(orderNumber, startTime, endTime);
PageInfo<PayRecords> result = new PageInfo<>(list);
return result;
}
@Override
public int addOrder(PayRecords payRecords) {
return recordsMapper.insert(payRecords);
}
@Override
public int ediOrder(PayRecords payRecords) {
return recordsMapper.updateByPrimaryKey(payRecords);
}
@Override
public int delOrder(PayRecords payRecords) {
return recordsMapper.deleteByPrimaryKey(payRecords.getId());
}
}
... ...
package com.sunyo.energy.location.service.imp;
import com.sunyo.energy.location.controller.response.ResultJson;
import com.sunyo.energy.location.dao.WaterElectricityParameterMapper;
import com.sunyo.energy.location.model.WaterElectricityParameter;
import com.sunyo.energy.location.service.WaterElectricityParameterService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;
import java.util.Date;
import java.util.List;
@Service
public class WaterElectricityParameterServiceImp implements WaterElectricityParameterService {
@Autowired
private WaterElectricityParameterMapper waterElectricityParameterMapper;
@Override
public int insertSelective(WaterElectricityParameter record) {
record.setCreattime(new Date());
return waterElectricityParameterMapper.insertSelective(record);
}
@Override
public int updateByPrimaryKeySelective(WaterElectricityParameter record) {
return waterElectricityParameterMapper.updateByPrimaryKeySelective(record);
}
@Override
public int countOne(String eeId) {
return waterElectricityParameterMapper.countOne(eeId);
}
@Override
public WaterElectricityParameter findOneElectricity(String eeId) {
try {
return waterElectricityParameterMapper.findOneElectricity(eeId);
}catch (Exception e){
return null;
}
}
@Override
public List userPayList(String roomNumber) {
return waterElectricityParameterMapper.userPayList(roomNumber);
}
}
... ...
package com.sunyo.energy.location.service.imp;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.sunyo.energy.location.dao.WaterMeterMapper;
import com.sunyo.energy.location.model.WaterMeter;
import com.sunyo.energy.location.service.WaterMeterService;
import com.sunyo.energy.location.utils.HttpsUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
@Service
public class WaterMeterServiceImp implements WaterMeterService {
@Autowired
private WaterMeterMapper waterMeterMapper;
@Override
@Scheduled(cron = "0 0 10 * * ?" )
public int realTime() {
try {
// 调用远程接口
String url = "http://123.56.159.203:8023/nowwmrd/getSelectNowwmrdbyProjectID";
Map<String, Object> datas = new HashMap<>();
datas.put("ProjectID", "33-99-00-00-00-00-01");
String s = HttpsUtils.httpRequest(url, datas);
JSONArray jsonArray = JSON.parseArray(s);
for (Object jsonObject:jsonArray){
WaterMeter waterMeter= new WaterMeter();
Map<String,Object> map = (Map)jsonObject;
if (!map.containsKey("state")){
waterMeter.setWmId(map.get("wm_id").toString());
waterMeter.setWmErrmessage(map.get("wm_errmessage").toString());
waterMeter.setWmFmstate(map.get("wm_fmstate").toString());
waterMeter.setWmSacc(map.get("wm_sacc").toString());
waterMeter.setWmLacc(map.get("wm_lacc").toString());
waterMeter.setWmRdtime(map.get("wm_rdtime").toString());
waterMeter.setWmSignalpower(map.get("wm_signalpower").toString());
waterMeter.setWmVoltage(map.get("wm_voltage").toString());
waterMeter.setCreattime(new Date());
waterMeterMapper.insertSelective(waterMeter);
}else {
if ("0".equals(map.get("state").toString())){
return 1;
}
return 0;
}
}
return 1;
}catch (Exception e){
e.printStackTrace();
return 0;
}
}
@Override
public WaterMeter findRealTime(String wmId) {
try {
// 调用远程接口http://123.56.159.203:8023/nowwmrd/getSelectNowwmrdbyMtId?MtId=68-74-40-34-05-29-55
String url = "http://123.56.159.203:8023/nowwmrd/getSelectNowwmrdbyMtId";
Map<String, Object> datas = new HashMap<>();
datas.put("MtId", wmId);
String s = HttpsUtils.httpRequest(url, datas);
JSONArray jsonArray = JSON.parseArray(s);
WaterMeter waterMeter= new WaterMeter();
for (Object jsonObject:jsonArray){
Map<String,Object> map = (Map)jsonObject;
if (!map.containsKey("state")){
waterMeter.setWmId(map.get("wm_id").toString());
waterMeter.setWmErrmessage(map.get("wm_errmessage").toString());
waterMeter.setWmFmstate(map.get("wm_fmstate").toString());
waterMeter.setWmSacc(map.get("wm_sacc").toString());
waterMeter.setWmLacc(map.get("wm_lacc").toString());
waterMeter.setWmRdtime(map.get("wm_rdtime").toString());
waterMeter.setWmSignalpower(map.get("wm_signalpower").toString());
waterMeter.setWmVoltage(map.get("wm_voltage").toString());
}
}
return waterMeter;
}catch (Exception e){
e.printStackTrace();
return new WaterMeter();
}
}
}
... ...
package com.sunyo.energy.location.utils;
import java.io.*;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import java.util.Map;
public class HttpsUtils {
/**
* java调用运程api公共方法
*
* @param requestUrl
* @param params
* @return
*/
@SuppressWarnings({"unchecked", "rawtypes"})
public static String httpRequest(String requestUrl, Map params) throws Exception {
// buffer用于接受返回的字符
StringBuffer buffer = new StringBuffer();
// 建立URL，把请求地址给补全，其中urlencode（）方法用于把params里的参数给取出来
URL url = new URL(requestUrl + "?" + urlencode(params));
// 打开http连接
HttpURLConnection httpUrlConn = (HttpURLConnection) url
.openConnection();
httpUrlConn.setDoInput(true);
httpUrlConn.setRequestMethod("GET");
httpUrlConn.connect();
// 获得输入
InputStream inputStream = httpUrlConn.getInputStream();
InputStreamReader inputStreamReader = new InputStreamReader(
inputStream, "utf-8");
BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
// 将bufferReader的值给放到buffer里
String str = null;
while ((str = bufferedReader.readLine()) != null) {
buffer.append(str);
}
// 关闭bufferReader和输入流
bufferedReader.close();
inputStreamReader.close();
inputStream.close();
inputStream = null;
// 断开连接
httpUrlConn.disconnect();
// 返回字符串
return buffer.toString();
}
/**
* 请求参数拼接（组装）
*
* @param data
* @return
*/
@SuppressWarnings("rawtypes")
public static String urlencode(Map<String, Object> data) {
// 将map里的参数变成像 showapi_appid=###&showapi_sign=###&的样子
StringBuilder sb = new StringBuilder();
for (Map.Entry i : data.entrySet()) {
try {
sb.append(i.getKey()).append("=")
.append(URLEncoder.encode(i.getValue() + "", "UTF-8"))
.append("&");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
}
return sb.toString();
}
/**
* 向指定 URL 发送POST方法的请求
*
* @param url 发送请求的 URL
* @param param 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return 所代表远程资源的响应结果
*/
public static String sendPostHttpRequest(String url, String param) {
PrintWriter out = null;
BufferedReader in = null;
String result = "";
try {
URL realUrl = new URL(url);
// 打开和URL之间的连接
URLConnection conn = realUrl.openConnection();
// 设置通用的请求属性
conn.setRequestProperty("accept", "*/*");
conn.setRequestProperty("connection", "Keep-Alive");
conn.setRequestProperty("user-agent",
"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
// 发送POST请求必须设置如下两行
conn.setDoOutput(true);
conn.setDoInput(true);
// 1.获取URLConnection对象对应的输出流
out = new PrintWriter(conn.getOutputStream());
// 2.中文有乱码的需要将PrintWriter改为如下
// out=new OutputStreamWriter(conn.getOutputStream(),"UTF-8")
// 发送请求参数
out.print(param);
// flush输出流的缓冲
out.flush();
// 定义BufferedReader输入流来读取URL的响应
in = new BufferedReader(
new InputStreamReader(conn.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println("发送 POST 请求出现异常！" + e);
e.printStackTrace();
}
// 使用finally块来关闭输出流、输入流
finally {
try {
if (out != null) {
out.close();
}
if (in != null) {
in.close();
}
} catch (IOException ex) {
ex.printStackTrace();
}
}
return result;
}
// 测试是否有效
// public static void main(String[] args) {
// // 接口地址
// String requestUrl = "http://localhost:8080/manifest/f5f5669bbdecefd3dacfaba194647c35";
// try {
//
// Map<String, Object> datas = new HashMap<>();
// datas.put("de_size", "dcdf38d9a5d6411985e49155481882f5");
// datas.put("waybillnomaster", "66611111111");
// datas.put("de_type", "001");
// datas.put("delivery_station", "001");
// datas.put("flightno", "CA9999");
// datas.put("flightdate", "2019-9-21 00:00:00");
// datas.put("originatingstation", "CGO");
// datas.put("destinationstation", "CGO");
// datas.put("totalpiece", "19");
// datas.put("totalweight", "19");
// datas.put("paymode", "PP");
// datas.put("customsstatus", "001");
// datas.put("customscode", "4604");
// datas.put("productname", "SHOUJI");
// datas.put("co_company", "测试");
// datas.put("co_address", "测试");
// datas.put("co_telephone", "00000000");
// datas.put("co_country", "CN");
// datas.put("sh_company", "测试");
// datas.put("sh_address", "测试");
// datas.put("sh_country", "CN");
// datas.put("sh_telephone", "0000000");
// datas.put("sh_city", "测试");
// datas.put("USER_ID", "1");
// datas.put("reach_station", "CGO");
// datas.put("de_volume", "000100003_MMM");
// datas.put("de_trstation", "APL，111");
//
// String param ="waybillnomaster=666-11111111&de_volume=66611111111_MMM&de_type=001&delivery_station=001&flightno=CV9765&flightdate=2019-12-20&originatingstation=CGO&destinationstation=ORD&totalpiece=1&totalweight=136.00&paymode=PP&customsstatus=001&customscode=4604&productname=CONSOL&co_company=DSV+AIR+%26+SEA+CO.%2c+LTD&co_address=8%269F%2c+RAFFLES+CITY+CHANGNING+OFFI.+TOWER+3%2c+NO.+1193+CHANGNING+RDSHANG&co_zipcode=200051&shpcusid=&shpaeo=&co_telephone=%2b86+21+33259800&co_country=CN&sh_company=ORD-DSV+AIR++SEA+INC&sh_address=1300+N+ARLINGTON+HEIGHTS+ROAD+SUITE+US&sh_zipcode=60143&cnecusid=&cneaeo=&sh_country=US&sh_telephone=8479568855&sh_fax=&sh_city=CHICAGO&USER_ID=1640&reach_station=ORD&de_trstation=BDX%2c111&de_packing=BDX%2c222&de_remarks=BDX%2c333&de_size=dcdf38d9a5d6411985e49155481882f5";
// String ss = HttpsUtils.sendPostHttpRequest(requestUrl, param);
// JSONArray jsonArray = JSON.parseArray(ss);
// } catch (Exception e) {
// e.printStackTrace();
// }
// }
}
... ...
... ... @@ -70,7 +70,7 @@ spring:
# password: vmvnv1v2
#spring datasource mysql，注意编码配置，缺少数据库编码配置容易引起中文入库乱码
#url: jdbc:mysql://127.0.0.1:3307/statistics?useUnicode=true&characterEncoding=utf8&nullCatalogMeansCurrent=true
url: jdbc:mysql://118.31.66.166:3306/EMPT?useUnicode=true&characterEncoding=utf8&nullCatalogMeansCurrent=true
url: jdbc:mysql://118.31.66.166:3306/EMPT?useUnicode=true&characterEncoding=utf8&nullCatalogMeansCurrent=true&serverTimezone=Asia/Shanghai
username: 110
password: QAHqCJf2kFYCLirM
driver-class-name: com.mysql.cj.jdbc.Driver
... ... @@ -102,10 +102,10 @@ spring:
eureka:
instance:
#eureka服务器页面中status的请求路径
status-page-url: http://${docker.server.ip}:${server.port}/
status-page-url: http://${eureka.instance.hostname}:${server.port}/
prefer-ip-address: true
instance-id: ${spring.cloud.client.ip-address}:${server.port}
# hostname: ${spring.cloud.client.ip-address}
hostname: ${spring.cloud.client.ip-address}
lease-renewal-interval-in-seconds: 15
lease-expiration-duration-in-seconds: 45
client:
... ... @@ -165,4 +165,4 @@ devops:
singlewindow-tcs-recept: D:\TCSSingleWindow\recive
tianbo-tcs-recept: D:\Data\Receive
cfps-subscribe-dir: D:\系统部署\imf_Warehouse_reader\xmlFromImf
#10079
#10079
\ No newline at end of file
... ...
... ... @@ -4,7 +4,7 @@
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">
<generatorConfiguration>
<!-- 数据库驱动:选择你的本地硬盘上面的数据库驱动包-->
<classPathEntry location="/Users/mrz/Downloads/mybatis-generator-core-1.3.2/lib/mysql-connector-java-5.1.25-bin.jar"/>
<classPathEntry location="/Users/shenhailong/.m2/repository/mysql/mysql-connector-java/5.1.30/mysql-connector-java-5.1.30.jar"/>
<!--<classPathEntry location="/Users/mrz/Documents/maven/ojdbc6.jar"/>-->
<context id="DB2Tables" targetRuntime="MyBatis3">
<commentGenerator>
... ... @@ -45,6 +45,6 @@
<property name="enableSubPackages" value="true"/>
</javaClientGenerator>
<!-- 要生成的表 tableName是数据库中的表名或视图名 domainObjectName是实体类名-->
<table tableName="location" domainObjectName="Location" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false"></table>
<table tableName="pay_records" domainObjectName="PayRecords" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="true"></table>
</context>
</generatorConfiguration>
\ No newline at end of file
... ...
<?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.sunyo.energy.location.dao.PayRecordsMapper" >
<resultMap id="BaseResultMap" type="com.sunyo.energy.location.model.PayRecords" >
<id column="id" property="id" jdbcType="INTEGER" />
<result column="payFees" property="payfees" jdbcType="DECIMAL" />
<result column="payUserId" property="payuserid" jdbcType="INTEGER" />
<result column="payTime" property="paytime" jdbcType="TIMESTAMP" />
<result column="payLocationId" property="paylocationid" jdbcType="INTEGER" />
<result column="payStatus" property="paystatus" jdbcType="BIT" />
<result column="payType" property="paytype" jdbcType="BIT" />
<result column="payFessType" property="payfesstype" jdbcType="BIT" />
<result column="orderNumber" property="ordernumber" jdbcType="VARCHAR" />
<result column="reamke1" property="reamke1" jdbcType="VARCHAR" />
<result column="reamke2" property="reamke2" jdbcType="VARCHAR" />
<result column="reamke3" property="reamke3" jdbcType="VARCHAR" />
<result column="reamke4" property="reamke4" jdbcType="VARCHAR" />
<result column="payUserName" property="payusername" jdbcType="VARCHAR" />
<result column="payLocationName" property="paylocationname" jdbcType="VARCHAR" />
<result column="payTypeAddress" property="paytypeaddress" jdbcType="VARCHAR" />
</resultMap>
<sql id="Base_Column_List" >
id, payFees, payUserId, payTime, payLocationId, payStatus, payType, payFessType,
orderNumber, reamke1, reamke2, reamke3, reamke4, payUserName, payLocationName, payTypeAddress
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select
<include refid="Base_Column_List" />
from pay_records
where id = #{id,jdbcType=INTEGER}
</select>
<select id="findAll" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from pay_records
where reamke1 = '0'
<if test="orderNumber != '' and orderNumber != null">
and orderNumber = #{orderNumber,jdbcType=VARCHAR}
</if>
<if test="startTime != '' and startTime != null">
and payTime &gt; #{startTime,jdbcType=VARCHAR}
</if>
<if test="endTime != '' and endTime != null">
and payTime &lt; #{endTime,jdbcType=VARCHAR}
</if>
order by payTime desc
</select>
<update id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
UPDATE pay_records
SET reamke1 = '1'
where id = #{id,jdbcType=INTEGER}
</update>
<insert id="insert" parameterType="com.sunyo.energy.location.model.PayRecords" >
insert into pay_records (id, payFees, payUserId,
payTime, payLocationId, payStatus,
payType, payFessType, orderNumber,
reamke1, reamke2, reamke3,
reamke4, payUserName, payLocationName,
payTypeAddress)
values (#{id,jdbcType=INTEGER}, #{payfees,jdbcType=DECIMAL}, #{payuserid,jdbcType=INTEGER},
#{paytime,jdbcType=TIMESTAMP}, #{paylocationid,jdbcType=INTEGER}, #{paystatus,jdbcType=BIT},
#{paytype,jdbcType=BIT}, #{payfesstype,jdbcType=BIT}, #{ordernumber,jdbcType=VARCHAR},
#{reamke1,jdbcType=VARCHAR}, #{reamke2,jdbcType=VARCHAR}, #{reamke3,jdbcType=VARCHAR},
#{reamke4,jdbcType=VARCHAR}, #{payusername,jdbcType=VARCHAR}, #{paylocationname,jdbcType=VARCHAR},
#{paytypeaddress,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.sunyo.energy.location.model.PayRecords" >
insert into pay_records
<trim prefix="(" suffix=")" suffixOverrides="," >
<if test="id != null" >
id,
</if>
<if test="payfees != null" >
payFees,
</if>
<if test="payuserid != null" >
payUserId,
</if>
<if test="paytime != null" >
payTime,
</if>
<if test="paylocationid != null" >
payLocationId,
</if>
<if test="paystatus != null" >
payStatus,
</if>
<if test="paytype != null" >
payType,
</if>
<if test="payfesstype != null" >
payFessType,
</if>
<if test="ordernumber != null" >
orderNumber,
</if>
<if test="reamke1 != null" >
reamke1,
</if>
<if test="reamke2 != null" >
reamke2,
</if>
<if test="reamke3 != null" >
reamke3,
</if>
<if test="reamke4 != null" >
reamke4,
</if>
<if test="payusername != null" >
payUserName,
</if>
<if test="paylocationname != null" >
payLocationName,
</if>
<if test="paytypeaddress != null" >
payTypeAddress,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="id != null" >
#{id,jdbcType=INTEGER},
</if>
<if test="payfees != null" >
#{payfees,jdbcType=DECIMAL},
</if>
<if test="payuserid != null" >
#{payuserid,jdbcType=INTEGER},
</if>
<if test="paytime != null" >
#{paytime,jdbcType=TIMESTAMP},
</if>
<if test="paylocationid != null" >
#{paylocationid,jdbcType=INTEGER},
</if>
<if test="paystatus != null" >
#{paystatus,jdbcType=BIT},
</if>
<if test="paytype != null" >
#{paytype,jdbcType=BIT},
</if>
<if test="payfesstype != null" >
#{payfesstype,jdbcType=BIT},
</if>
<if test="ordernumber != null" >
#{ordernumber,jdbcType=VARCHAR},
</if>
<if test="reamke1 != null" >
#{reamke1,jdbcType=VARCHAR},
</if>
<if test="reamke2 != null" >
#{reamke2,jdbcType=VARCHAR},
</if>
<if test="reamke3 != null" >
#{reamke3,jdbcType=VARCHAR},
</if>
<if test="reamke4 != null" >
#{reamke4,jdbcType=VARCHAR},
</if>
<if test="payusername != null" >
#{payusername,jdbcType=VARCHAR},
</if>
<if test="paylocationname != null" >
#{paylocationname,jdbcType=VARCHAR},
</if>
<if test="paytypeaddress != null" >
#{paytypeaddress,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.sunyo.energy.location.model.PayRecords" >
update pay_records
<set >
<if test="payfees != null" >
payFees = #{payfees,jdbcType=DECIMAL},
</if>
<if test="payuserid != null" >
payUserId = #{payuserid,jdbcType=INTEGER},
</if>
<if test="paytime != null" >
payTime = #{paytime,jdbcType=TIMESTAMP},
</if>
<if test="paylocationid != null" >
payLocationId = #{paylocationid,jdbcType=INTEGER},
</if>
<if test="paystatus != null" >
payStatus = #{paystatus,jdbcType=BIT},
</if>
<if test="paytype != null" >
payType = #{paytype,jdbcType=BIT},
</if>
<if test="payfesstype != null" >
payFessType = #{payfesstype,jdbcType=BIT},
</if>
<if test="ordernumber != null" >
orderNumber = #{ordernumber,jdbcType=VARCHAR},
</if>
<if test="reamke1 != null" >
reamke1 = #{reamke1,jdbcType=VARCHAR},
</if>
<if test="reamke2 != null" >
reamke2 = #{reamke2,jdbcType=VARCHAR},
</if>
<if test="reamke3 != null" >
reamke3 = #{reamke3,jdbcType=VARCHAR},
</if>
<if test="reamke4 != null" >
reamke4 = #{reamke4,jdbcType=VARCHAR},
</if>
<if test="payusername != null" >
payUserName = #{payusername,jdbcType=VARCHAR},
</if>
<if test="paylocationname != null" >
payLocationName = #{paylocationname,jdbcType=VARCHAR},
</if>
<if test="paytypeaddress != null" >
payTypeAddress = #{paytypeaddress,jdbcType=VARCHAR},
</if>
</set>
where id = #{id,jdbcType=INTEGER}
</update>
<update id="updateByPrimaryKey" parameterType="com.sunyo.energy.location.model.PayRecords" >
update pay_records
set payFees = #{payfees,jdbcType=DECIMAL},
payUserId = #{payuserid,jdbcType=INTEGER},
payTime = #{paytime,jdbcType=TIMESTAMP},
payLocationId = #{paylocationid,jdbcType=INTEGER},
payStatus = #{paystatus,jdbcType=BIT},
payType = #{paytype,jdbcType=BIT},
payFessType = #{payfesstype,jdbcType=BIT},
orderNumber = #{ordernumber,jdbcType=VARCHAR},
reamke1 = #{reamke1,jdbcType=VARCHAR},
reamke2 = #{reamke2,jdbcType=VARCHAR},
reamke3 = #{reamke3,jdbcType=VARCHAR},
reamke4 = #{reamke4,jdbcType=VARCHAR},
payUserName = #{payusername,jdbcType=VARCHAR},
payLocationName = #{paylocationname,jdbcType=VARCHAR},
payTypeAddress = #{paytypeaddress,jdbcType=VARCHAR}
where id = #{id,jdbcType=INTEGER}
</update>
</mapper>
\ No newline at end of file
... ...
<?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.sunyo.energy.location.dao.WaterElectricityParameterMapper" >
<resultMap id="BaseResultMap" type="com.sunyo.energy.location.model.WaterElectricityParameter" >
<id column="id" property="id" jdbcType="INTEGER" />
<result column="prepaid" property="prepaid" jdbcType="BIT" />
<result column="warningTrip" property="warningtrip" jdbcType="BIT" />
<result column="warningThreshold" property="warningthreshold" jdbcType="DECIMAL" />
<result column="overdraft" property="overdraft" jdbcType="BIT" />
<result column="overdraftThreshold" property="overdraftthreshold" jdbcType="DECIMAL" />
<result column="waterLoad" property="waterload" jdbcType="BIT" />
<result column="water" property="water" jdbcType="DECIMAL" />
<result column="power" property="power" jdbcType="DECIMAL" />
<result column="powerFactor" property="powerfactor" jdbcType="VARCHAR" />
<result column="free" property="free" jdbcType="BIT" />
<result column="freeElectricityLimit" property="freeelectricitylimit" jdbcType="DECIMAL" />
<result column="freeWater" property="freewater" jdbcType="VARCHAR" />
<result column="wm_id" property="wmId" jdbcType="VARCHAR" />
<result column="creatTime" property="creattime" jdbcType="TIMESTAMP" />
<result column="ee_id" property="eeId" jdbcType="VARCHAR" />
<result column="reamke2" property="reamke2" jdbcType="VARCHAR" />
<result column="reamke3" property="reamke3" jdbcType="VARCHAR" />
</resultMap>
<sql id="Base_Column_List" >
id, prepaid, warningTrip, warningThreshold, overdraft, overdraftThreshold, waterLoad,
water, power, powerFactor, free, freeElectricityLimit, freeWater, wm_id, creatTime,
ee_id, reamke2, reamke3
</sql>
<select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.Integer" >
select
<include refid="Base_Column_List" />
from water_electricity_parameter
where id = #{id,jdbcType=INTEGER}
</select>
<select id="countOne" parameterType="java.lang.String" resultType="int">
select count(*) from water_electricity_parameter where ee_id=#{value, jdbcType=VARCHAR}
</select>
<select id="findOneElectricity" resultMap="BaseResultMap" parameterType="java.lang.String">
select
<include refid="Base_Column_List"/>
from water_electricity_parameter where ee_id = #{value,jdbcType=VARCHAR}
</select>
<select id="userPayList" parameterType="java.lang.String" resultMap="BaseResultMap">
select
<include refid="Base_Column_List" />
from water_electricity_parameter
where reamke2 = #{value,jdbcType=INTEGER}
</select>
<delete id="deleteByPrimaryKey" parameterType="java.lang.Integer" >
delete from water_electricity_parameter
where id = #{id,jdbcType=INTEGER}
</delete>
<insert id="insert" parameterType="com.sunyo.energy.location.model.WaterElectricityParameter" >
insert into water_electricity_parameter (id, prepaid, warningTrip,
warningThreshold, overdraft, overdraftThreshold,
waterLoad, water, power,
powerFactor, free, freeElectricityLimit,
freeWater, wm_id, creatTime,
ee_id, reamke2, reamke3
)
values (#{id,jdbcType=INTEGER}, #{prepaid,jdbcType=BIT}, #{warningtrip,jdbcType=BIT},
#{warningthreshold,jdbcType=DECIMAL}, #{overdraft,jdbcType=BIT}, #{overdraftthreshold,jdbcType=DECIMAL},
#{waterload,jdbcType=BIT}, #{water,jdbcType=DECIMAL}, #{power,jdbcType=DECIMAL},
#{powerfactor,jdbcType=VARCHAR}, #{free,jdbcType=BIT}, #{freeelectricitylimit,jdbcType=DECIMAL},
#{freewater,jdbcType=VARCHAR}, #{wmId,jdbcType=VARCHAR}, #{creattime,jdbcType=TIMESTAMP},
#{eeId,jdbcType=VARCHAR}, #{reamke2,jdbcType=VARCHAR}, #{reamke3,jdbcType=VARCHAR}
)
</insert>
<insert id="insertSelective" parameterType="com.sunyo.energy.location.model.WaterElectricityParameter" >
insert into water_electricity_parameter
<trim prefix="(" suffix=")" suffixOverrides="," >
<if test="id != null" >
id,
</if>
<if test="prepaid != null" >
prepaid,
</if>
<if test="warningtrip != null" >
warningTrip,
</if>
<if test="warningthreshold != null" >
warningThreshold,
</if>
<if test="overdraft != null" >
overdraft,
</if>
<if test="overdraftthreshold != null" >
overdraftThreshold,
</if>
<if test="waterload != null" >
waterLoad,
</if>
<if test="water != null" >
water,
</if>
<if test="power != null" >
power,
</if>
<if test="powerfactor != null" >
powerFactor,
</if>
<if test="free != null" >
free,
</if>
<if test="freeelectricitylimit != null" >
freeElectricityLimit,
</if>
<if test="freewater != null" >
freeWater,
</if>
<if test="wmId != null" >
wm_id,
</if>
<if test="creattime != null" >
creatTime,
</if>
<if test="eeId != null" >
ee_id,
</if>
<if test="reamke2 != null" >
reamke2,
</if>
<if test="reamke3 != null" >
reamke3,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="id != null" >
#{id,jdbcType=INTEGER},
</if>
<if test="prepaid != null" >
#{prepaid,jdbcType=BIT},
</if>
<if test="warningtrip != null" >
#{warningtrip,jdbcType=BIT},
</if>
<if test="warningthreshold != null" >
#{warningthreshold,jdbcType=DECIMAL},
</if>
<if test="overdraft != null" >
#{overdraft,jdbcType=BIT},
</if>
<if test="overdraftthreshold != null" >
#{overdraftthreshold,jdbcType=DECIMAL},
</if>
<if test="waterload != null" >
#{waterload,jdbcType=BIT},
</if>
<if test="water != null" >
#{water,jdbcType=DECIMAL},
</if>
<if test="power != null" >
#{power,jdbcType=DECIMAL},
</if>
<if test="powerfactor != null" >
#{powerfactor,jdbcType=VARCHAR},
</if>
<if test="free != null" >
#{free,jdbcType=BIT},
</if>
<if test="freeelectricitylimit != null" >
#{freeelectricitylimit,jdbcType=DECIMAL},
</if>
<if test="freewater != null" >
#{freewater,jdbcType=VARCHAR},
</if>
<if test="wmId != null" >
#{wmId,jdbcType=VARCHAR},
</if>
<if test="creattime != null" >
#{creattime,jdbcType=TIMESTAMP},
</if>
<if test="eeId != null" >
#{eeId,jdbcType=VARCHAR},
</if>
<if test="reamke2 != null" >
#{reamke2,jdbcType=VARCHAR},
</if>
<if test="reamke3 != null" >
#{reamke3,jdbcType=VARCHAR},
</if>
</trim>
</insert>
<update id="updateByPrimaryKeySelective" parameterType="com.sunyo.energy.location.model.WaterElectricityParameter" >
update water_electricity_parameter
<set >
<if test="prepaid != null" >
prepaid = #{prepaid,jdbcType=BIT},
</if>
<if test="warningtrip != null" >
warningTrip = #{warningtrip,jdbcType=BIT},
</if>
<if test="warningthreshold != null" >
warningThreshold = #{warningthreshold,jdbcType=DECIMAL},
</if>
<if test="overdraft != null" >
overdraft = #{overdraft,jdbcType=BIT},
</if>
<if test="overdraftthreshold != null" >
overdraftThreshold = #{overdraftthreshold,jdbcType=DECIMAL},
</if>
<if test="waterload != null" >
waterLoad = #{waterload,jdbcType=BIT},
</if>
<if test="water != null" >
water = #{water,jdbcType=DECIMAL},
</if>
<if test="power != null" >
power = #{power,jdbcType=DECIMAL},
</if>
<if test="powerfactor != null" >
powerFactor = #{powerfactor,jdbcType=VARCHAR},
</if>
<if test="free != null" >
free = #{free,jdbcType=BIT},
</if>
<if test="freeelectricitylimit != null" >
freeElectricityLimit = #{freeelectricitylimit,jdbcType=DECIMAL},
</if>
<if test="freewater != null" >
freeWater = #{freewater,jdbcType=VARCHAR},
</if>
<if test="wmId != null" >
wm_id = #{wmId,jdbcType=VARCHAR},
</if>
<if test="creattime != null" >
creatTime = #{creattime,jdbcType=TIMESTAMP},
</if>
<if test="eeId != null" >
ee_id = #{eeId,jdbcType=VARCHAR},
</if>
<if test="reamke2 != null" >
reamke2 = #{reamke2,jdbcType=VARCHAR},
</if>
<if test="reamke3 != null" >
reamke3 = #{reamke3,jdbcType=VARCHAR},
</if>
</set>
where ee_id = #{eeId,jdbcType=INTEGER}
</update>
<update id="updateByPrimaryKey" parameterType="com.sunyo.energy.location.model.WaterElectricityParameter" >
update water_electricity_parameter
set prepaid = #{prepaid,jdbcType=BIT},
warningTrip = #{warningtrip,jdbcType=BIT},
warningThreshold = #{warningthreshold,jdbcType=DECIMAL},
overdraft = #{overdraft,jdbcType=BIT},
overdraftThreshold = #{overdraftthreshold,jdbcType=DECIMAL},
waterLoad = #{waterload,jdbcType=BIT},
water = #{water,jdbcType=DECIMAL},
power = #{power,jdbcType=DECIMAL},
powerFactor = #{powerfactor,jdbcType=VARCHAR},
free = #{free,jdbcType=BIT},
freeElectricityLimit = #{freeelectricitylimit,jdbcType=DECIMAL},
freeWater = #{freewater,jdbcType=VARCHAR},
wm_id = #{wmId,jdbcType=VARCHAR},
creatTime = #{creattime,jdbcType=TIMESTAMP},
ee_id = #{eeId,jdbcType=VARCHAR},
reamke2 = #{reamke2,jdbcType=VARCHAR},
reamke3 = #{reamke3,jdbcType=VARCHAR}
where id = #{id,jdbcType=INTEGER}
</update>
</mapper>
\ No newline at end of file
... ...
<?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.sunyo.energy.location.dao.WaterMeterMapper" >
<resultMap id="BaseResultMap" type="com.sunyo.energy.location.model.WaterMeter" >
<result column="wm_id" property="wmId" jdbcType="VARCHAR" />
<result column="wm_sacc" property="wmSacc" jdbcType="VARCHAR" />
<result column="wm_lacc" property="wmLacc" jdbcType="VARCHAR" />
<result column="wm_rdtime" property="wmRdtime" jdbcType="VARCHAR" />
<result column="wm_fmstate" property="wmFmstate" jdbcType="VARCHAR" />
<result column="wm_errmessage" property="wmErrmessage" jdbcType="VARCHAR" />
<result column="wm_voltage" property="wmVoltage" jdbcType="VARCHAR" />
<result column="wm_signalpower" property="wmSignalpower" jdbcType="VARCHAR" />
<result column="creatTime" property="creattime" jdbcType="TIMESTAMP" />
<result column="updateTime" property="updatetime" jdbcType="TIMESTAMP" />
<result column="reamke1" property="reamke1" jdbcType="VARCHAR" />
<result column="reamke2" property="reamke2" jdbcType="VARCHAR" />
<result column="reamke3" property="reamke3" jdbcType="VARCHAR" />
<result column="reamke4" property="reamke4" jdbcType="VARCHAR" />
</resultMap>
<insert id="insert" parameterType="com.sunyo.energy.location.model.WaterMeter" >
insert into water_meter (wm_id, wm_sacc, wm_lacc,
wm_rdtime, wm_fmstate, wm_errmessage,
wm_voltage, wm_signalpower, creatTime,
updateTime, reamke1, reamke2,
reamke3, reamke4)
values (#{wmId,jdbcType=VARCHAR}, #{wmSacc,jdbcType=VARCHAR}, #{wmLacc,jdbcType=VARCHAR},
#{wmRdtime,jdbcType=VARCHAR}, #{wmFmstate,jdbcType=VARCHAR}, #{wmErrmessage,jdbcType=VARCHAR},
#{wmVoltage,jdbcType=VARCHAR}, #{wmSignalpower,jdbcType=VARCHAR}, #{creattime,jdbcType=TIMESTAMP},
#{updatetime,jdbcType=TIMESTAMP}, #{reamke1,jdbcType=VARCHAR}, #{reamke2,jdbcType=VARCHAR},
#{reamke3,jdbcType=VARCHAR}, #{reamke4,jdbcType=VARCHAR})
</insert>
<insert id="insertSelective" parameterType="com.sunyo.energy.location.model.WaterMeter" >
insert into water_meter
<trim prefix="(" suffix=")" suffixOverrides="," >
<if test="wmId != null" >
wm_id,
</if>
<if test="wmSacc != null" >
wm_sacc,
</if>
<if test="wmLacc != null" >
wm_lacc,
</if>
<if test="wmRdtime != null" >
wm_rdtime,
</if>
<if test="wmFmstate != null" >
wm_fmstate,
</if>
<if test="wmErrmessage != null" >
wm_errmessage,
</if>
<if test="wmVoltage != null" >
wm_voltage,
</if>
<if test="wmSignalpower != null" >
wm_signalpower,
</if>
<if test="creattime != null" >
creatTime,
</if>
<if test="updatetime != null" >
updateTime,
</if>
<if test="reamke1 != null" >
reamke1,
</if>
<if test="reamke2 != null" >
reamke2,
</if>
<if test="reamke3 != null" >
reamke3,
</if>
<if test="reamke4 != null" >
reamke4,
</if>
</trim>
<trim prefix="values (" suffix=")" suffixOverrides="," >
<if test="wmId != null" >
#{wmId,jdbcType=VARCHAR},
</if>
<if test="wmSacc != null" >
#{wmSacc,jdbcType=VARCHAR},
</if>
<if test="wmLacc != null" >
#{wmLacc,jdbcType=VARCHAR},
</if>
<if test="wmRdtime != null" >
#{wmRdtime,jdbcType=VARCHAR},
</if>
<if test="wmFmstate != null" >
#{wmFmstate,jdbcType=VARCHAR},
</if>
<if test="wmErrmessage != null" >
#{wmErrmessage,jdbcType=VARCHAR},
</if>
<if test="wmVoltage != null" >
#{wmVoltage,jdbcType=VARCHAR},
</if>
<if test="wmSignalpower != null" >
#{wmSignalpower,jdbcType=VARCHAR},
</if>
<if test="creattime != null" >
#{creattime,jdbcType=TIMESTAMP},
</if>
<if test="updatetime != null" >
#{updatetime,jdbcType=TIMESTAMP},
</if>
<if test="reamke1 != null" >
#{reamke1,jdbcType=VARCHAR},
</if>
<if test="reamke2 != null" >
#{reamke2,jdbcType=VARCHAR},
</if>
<if test="reamke3 != null" >
#{reamke3,jdbcType=VARCHAR},
</if>
<if test="reamke4 != null" >
#{reamke4,jdbcType=VARCHAR},
</if>
</trim>
ON DUPLICATE KEY
UPDATE
wm_sacc = #{wmSacc,jdbcType=VARCHAR},
wm_lacc = #{wmLacc,jdbcType=VARCHAR},
wm_rdtime = #{wmRdtime,jdbcType=VARCHAR},
wm_fmstate = #{wmFmstate,jdbcType=VARCHAR},
wm_errmessage = #{wmErrmessage,jdbcType=VARCHAR},
wm_voltage = #{wmVoltage,jdbcType=VARCHAR},
wm_signalpower = #{wmSignalpower,jdbcType=VARCHAR},
creatTime = #{creattime,jdbcType=TIMESTAMP},
updateTime = #{updatetime,jdbcType=TIMESTAMP},
reamke1 = #{reamke1,jdbcType=VARCHAR},
reamke2 = #{reamke2,jdbcType=VARCHAR},
reamke3 = #{reamke3,jdbcType=VARCHAR},
reamke4 = #{reamke4,jdbcType=VARCHAR}
</insert>
</mapper>
\ No newline at end of file
... ...