Commit 2dd7b7da authored by chenzhao's avatar chenzhao

修复 api 兼容人大金仓

parent eac01e5a
......@@ -4,7 +4,10 @@ import com.baomidou.mybatisplus.annotation.FieldFill;
import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.yeejoin.amos.boot.biz.config.BitTypeHandler;
import lombok.Data;
import org.apache.ibatis.type.BigDecimalTypeHandler;
import org.apache.ibatis.type.BigIntegerTypeHandler;
import java.io.Serializable;
import java.util.Date;
......@@ -34,7 +37,7 @@ public class BaseEntity implements Serializable{
/**
* 是否删除
*/
@TableField(value = "is_delete")
@TableField(value = "is_delete",typeHandler = BitTypeHandler.class)
public Boolean isDelete=false;
}
package com.yeejoin.amos.boot.biz.config;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import org.apache.ibatis.type.MappedJdbcTypes;
@MappedJdbcTypes(JdbcType.BIT)
public class BitTypeHandler extends BaseTypeHandler<Boolean> {
@Override
public void setNonNullParameter(PreparedStatement ps, int i, Boolean parameter, JdbcType jdbcType)
throws SQLException {
//原生的boolean会再sql上加上引号比如'0'或者'1',人大金仓不支持,支持不带引号的
//ps.setBoolean(i, parameter);
ps.setInt(i, parameter?1:0);
}
@Override
public Boolean getNullableResult(ResultSet rs, String columnName) throws SQLException {
return rs.getBoolean(columnName);
}
@Override
public Boolean getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
return rs.getBoolean(columnIndex);
}
@Override
public Boolean getNullableResult(java.sql.CallableStatement cs, int columnIndex) throws SQLException {
return cs.getBoolean(columnIndex);
}
}
......@@ -31,7 +31,7 @@ import java.util.List;
* @date 2024-01-16
*/
@RestController
@Api(tags = "Api")
@Api(tags = "并网Api")
@RequestMapping(value = "/basic-grid-acceptance")
public class BasicGridAcceptanceController extends BaseController {
......
......@@ -28,7 +28,7 @@ import java.util.List;
* @date 2023-08-22
*/
@RestController
@Api(tags = "Api")
@Api(tags = "合同模板Api")
@RequestMapping(value = "/contract-template")
public class ContractTemplateController extends BaseController {
......
......@@ -33,7 +33,7 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
* @date 2024-04-01
*/
@RestController
@Api(tags = "Api")
@Api(tags = "投融资Api")
@RequestMapping(value = "/financing-info")
public class FinancingInfoController extends BaseController {
......
......@@ -46,7 +46,7 @@ import java.util.stream.Collectors;
* @date 2023-08-21
*/
@RestController
@Api(tags = "Api")
@Api(tags = "农户合同Api")
@RequestMapping(value = "/household-contract")
@Slf4j
public class HouseholdContractController extends BaseController {
......
......@@ -24,7 +24,7 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
* @date 2024-06-18
*/
@RestController
@Api(tags = "投融审核表Api")
@Api(tags = "发货管理审核表Api")
@RequestMapping(value = "/hygf-preparation-money-auditing")
public class HygfPreparationMoneyAuditingController extends BaseController {
......
......@@ -24,7 +24,7 @@ import org.typroject.tyboot.core.foundation.enumeration.UserType;
* @date 2024-07-02
*/
@RestController
@Api(tags = "Api")
@Api(tags = "发货管理 补货单Api")
@RequestMapping(value = "/hygf-replenishment")
public class HygfReplenishmentController extends BaseController {
......
......@@ -27,7 +27,7 @@ import java.util.Map;
* @date 2023-07-15
*/
@RestController
@Api(tags = "Api")
@Api(tags = "电站管理Api")
@RequestMapping(value = "/power-station")
public class PowerStationController extends BaseController {
......
......@@ -88,6 +88,8 @@ public class QiyuesuoController extends BaseController {
ContractFillMapper contractFillMapper;
@Autowired
PeasantHouseholdServiceImpl peasantHouseholdServiceImpl;
@Autowired
HygfContractCallRecordMapper hygfContractCallRecordMapper;
@TycloudOperation(ApiLevel = UserType.AGENCY, needAuth = false)
@ApiOperation(httpMethod = "POST", value = "个人token", notes = "个人token")
......@@ -168,6 +170,16 @@ public class QiyuesuoController extends BaseController {
String data = this.aesDerypt(content, secretKey);
System.out.println("契约锁回调接口解析数据" + data);
CallbackDto CallbackDto = JSON.parseObject(data, CallbackDto.class);
HygfContractCallRecord hygfContractCallRecord = new HygfContractCallRecord();
try {
hygfContractCallRecord.setContractId(CallbackDto.getContractId());
hygfContractCallRecord.setRecDate(new Date());
hygfContractCallRecord.setData(JSON.toJSONString(CallbackDto));
hygfContractCallRecordMapper.insert(hygfContractCallRecord);
}catch (Exception e){
log.info("合同记录表保存失败,合同id"+CallbackDto.getContractId());
}
if ("PERSONAL".equals(CallbackDto.getCallbackType())) {
......@@ -228,7 +240,12 @@ public class QiyuesuoController extends BaseController {
}
}
try {
hygfContractCallRecord.setStatus("success");
hygfContractCallRecordMapper.updateById(hygfContractCallRecord);
}catch (Exception e){
log.info("状态更新失败,合同id:"+CallbackDto.getContractId());
}
} catch (Exception e) {
e.printStackTrace();
throw new BadRequest("契约锁回调失败");
......
......@@ -36,7 +36,7 @@ import java.util.List;
* @date 2023-08-29
*/
@RestController
@Api(tags = "Api")
@Api(tags = "区域公司Api")
@RequestMapping(value = "/regional-companies")
public class RegionalCompaniesController extends BaseController {
......
......@@ -23,7 +23,7 @@ import java.util.List;
* @date 2023-08-23
*/
@RestController
@Api(tags = "Api")
@Api(tags = "盖章信息Api")
@RequestMapping(value = "/seal-dictionary")
public class SealDictionaryController extends BaseController {
......
......@@ -162,7 +162,6 @@ public class UnitInfoServiceImpl extends BaseService<UnitInfoDto,UnitInfo,UnitIn
}
@Override
@Transactional
public UnitRegisterDto registerUnit(UnitRegisterDto model) {
UnitInfoDto regUnitInfo = model.getUnitInfoDto();
......
......@@ -226,4 +226,24 @@ cheduled.crons=0 10 0 * * ?
dealer.appcode.manage=studio_normalapp_5155413,studio_normalapp_5133538
dealer.appcode.role=1767363928842571777
dealer.amosDealerId=1767820997374775298
\ No newline at end of file
dealer.amosDealerId=1767820997374775298
#Seata Config
seata.tx-service-group=hygf-seata
seata.service.grouplist.hygf-seata=47.92.234.253:8091
# Seata 配置
seata.enabled=true
seata.enable-auto-data-source-proxy=false
seata.datasource.autoproxy.datasource-proxy-mode=original
seata.datasource.autoproxy.enabled=true
seata.datasource.autoproxy.data-source-names=mysql
## 47环境 排除es报错引进无用配置 业务未实际使用es
spring.elasticsearch.rest.uris=http://47.92.234.253:9200
spring.elasticsearch.rest.connection-timeout=30000
spring.elasticsearch.rest.username=elastic
spring.elasticsearch.rest.password=123456
spring.elasticsearch.rest.read-timeout=30000
\ No newline at end of file
......@@ -490,9 +490,10 @@ public class MonitorFanIdxController extends BaseController {
SimpleDateFormat myFmt2 = new SimpleDateFormat("yyyy");
String monthy = myFmt2.format(new Date());
QueryWrapper<StationPlan> wrapper = new QueryWrapper<>();
wrapper.select(" monthly ,sum(value) value ");
wrapper.select("sum(value) as value ,monthly");
wrapper.eq("year", monthy);
wrapper.eq("station_basic_id", stationBasic.getSequenceNbr());
wrapper.groupBy("monthly");
List<Map<String, Object>> list1 = StationPlanMapper.selectMaps(wrapper);
Double sumValue = list1 != null && !list1.isEmpty() ? (Double) list1.get(0).get("value") : 0;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment