| | |
| | | <!DOCTYPE html><html lang=""><head><meta charset="utf-8"><meta http-equiv="X-UA-Compatible" content="IE=edge"><meta name="viewport" content="width=device-width,initial-scale=1"><link rel="icon" href="/whyc_admin/favicon.ico"><title>èæ¹çèæºæ
§å®æ¶å®å
¨é²èç³»ç»</title><link href="/whyc_admin/static/css/app.034e1a67.css" rel="preload" as="style"><link href="/whyc_admin/static/css/chunk-vendors.04c7bff3.css" rel="preload" as="style"><link href="/whyc_admin/static/js/app.c8651863.js" rel="preload" as="script"><link href="/whyc_admin/static/js/chunk-vendors.6d4f879a.js" rel="preload" as="script"><link href="/whyc_admin/static/css/chunk-vendors.04c7bff3.css" rel="stylesheet"><link href="/whyc_admin/static/css/app.034e1a67.css" rel="stylesheet"></head><body><noscript><strong>We're sorry but èæ¹çèæºæ
§å®æ¶å®å
¨é²èç³»ç» doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id="app"></div><script src="/whyc_admin/static/js/chunk-vendors.6d4f879a.js"></script><script src="/whyc_admin/static/js/app.c8651863.js"></script></body></html> |
| | | <!DOCTYPE html><html lang=""><head><meta charset="utf-8"><meta http-equiv="X-UA-Compatible" content="IE=edge"><meta name="viewport" content="width=device-width,initial-scale=1"><link rel="icon" href="/whyc_admin/favicon.ico"><title>title: process.env.VUE_APP_TITLE,</title><link href="/whyc_admin/static/css/app.e13cc487.css" rel="preload" as="style"><link href="/whyc_admin/static/css/chunk-vendors.04c7bff3.css" rel="preload" as="style"><link href="/whyc_admin/static/js/app.b07e2862.js" rel="preload" as="script"><link href="/whyc_admin/static/js/chunk-vendors.6d4f879a.js" rel="preload" as="script"><link href="/whyc_admin/static/css/chunk-vendors.04c7bff3.css" rel="stylesheet"><link href="/whyc_admin/static/css/app.e13cc487.css" rel="stylesheet"></head><body><noscript><strong>We're sorry but èæ¹çèæºæ
§å®æ¶å®å
¨é²èç³»ç» doesn't work properly without JavaScript enabled. Please enable it to continue.</strong></noscript><div id="app"></div><script src="/whyc_admin/static/js/chunk-vendors.6d4f879a.js"></script><script src="/whyc_admin/static/js/app.b07e2862.js"></script></body></html> |
| | |
| | | INSERT INTO `wuhuyancao`.`quartz_job` (`id`, `bean_name`, `params`, `cron_expres`, `state`, `remark`, `create_time`, `module`) VALUES (NULL, 'visitServiceJob', '{}', '0 0/5 * * * ? *', 1, 'ãæè·¯å¨ãå¼å¯å®æ¶è¿ç¨æ§å¶æè·¯å¨åé¸', '2023-07-26 13:17:17', 'autoCloseCmd'); |
| | | |
| | | |
| | | INSERT INTO `wuhuyancao`.`system_dict_data` (`ID`, `DICT_ID`, `CODE`, `LABEL`, `SORT`, `DISABLED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`, `REMARK`) VALUES (314, 18, 'yKSKuO0LoFf06jWGrwwuGudK', 'JDY_SECRET', 0, 0, 1, '2025-12-29 10:32:54', NULL, '2025-12-29 10:31:45', 0, 'æ°æ®æ¨éç§é¥'); |
| | | INSERT INTO `wuhuyancao`.`system_dict_data` (`ID`, `DICT_ID`, `CODE`, `LABEL`, `SORT`, `DISABLED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`, `REMARK`) VALUES (315, 18, 'https://api.jiandaoyun.com/api/v1/automation/tenant/6909b792324dc197821895d1/hooks/6909d0fbdb93695219faa27eb068192dc4a9532972993159', 'JDY_MEMBER_PUSH_STATUS_URL', 0, 0, 1, '2025-12-29 14:06:56', NULL, '2025-12-29 14:05:46', 0, 'ç®éäºäººåæ¨éå¤çç»æéç¥å°å'); |
| | | INSERT INTO `wuhuyancao`.`system_dict_data` (`ID`, `DICT_ID`, `CODE`, `LABEL`, `SORT`, `DISABLED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`, `REMARK`) VALUES (316, 1, 'èæ¹çèå
¬å¸', 'SYSTEM_TITLE', 0, 0, 1, '2025-12-30 14:49:57', NULL, '2025-12-30 14:48:47', 0, 'ç³»ç»ä¸»æ é¢'); |
| | | INSERT INTO `wuhuyancao`.`system_dict_data` (`ID`, `DICT_ID`, `CODE`, `LABEL`, `SORT`, `DISABLED`, `CREATE_USER`, `CREATE_TIME`, `UPDATE_USER`, `UPDATE_TIME`, `DELETED`, `REMARK`) VALUES (317, 1, 'æºæ
§ç©æµååºå®æ¶ä¸ä½åå¹³å°', 'SYSTEM_SUBTITLE', 0, 0, 1, '2025-12-30 14:50:40', NULL, '2025-12-30 14:49:30', 0, 'ç³»ç»å¯æ é¢'); |
| | | |
| | | |
| | | CREATE TABLE `device_data` ( |
| | | `ID` int NOT NULL AUTO_INCREMENT COMMENT '主é®', |
| | | `CREATOR` int DEFAULT NULL COMMENT 'å建人ç¼ç ', |
| | |
| | | * http ç¸å
³ç常é |
| | | */ |
| | | public class HttpConstant { |
| | | public static final String HOST = "https://api.jiandaoyun.com/api/"; |
| | | // public static final String HOST = "https://api.jiandaoyun.com/api/"; |
| | | // public static final String HOST = "https://lcdp.ahyc.com.cn:30443/api/"; |
| | | |
| | | /** |
| | | * é¨é¨ç¸å
³çæ¥å£åç¼ |
| | |
| | | /** |
| | | * API_KEY |
| | | */ |
| | | public static final String API_KEY = "JsmYomhn3dissp9ZJ6QeTpnH2xKoKZgw"; |
| | | // public static final String API_KEY = "JsmYomhn3dissp9ZJ6QeTpnH2xKoKZgw"; |
| | | |
| | | public static final String APP_ID = "APP_ID"; |
| | | |
| | |
| | | package com.doumee.core.jiandaoyun.model.http; |
| | | |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.doumee.core.jiandaoyun.util.LimitUtil; |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | |
| | | */ |
| | | public Map<String, Object> sendPostRequest(HttpRequestParam param) throws Exception { |
| | | if (param == null || StringUtils.isBlank(param.getPath())) { |
| | | throw new RuntimeException("ç¼ºå¤±åæ°ï¼"); |
| | | throw new Exception("ç¼ºå¤±åæ°ï¼"); |
| | | } |
| | | HttpClient client = getSSLHttpClient(); |
| | | Header[] headers = getHttpHeaders(this.getApiKey()); |
| | | String url = this.host + param.getPath(); |
| | | log.error("===ç®éäºæ¥å£urlï¼"+url); |
| | | HttpRequestBase request = new HttpPost(url); |
| | | |
| | | // 请æ±åæ° |
| | |
| | | result = (Map<String, Object>) mapper.readValue(response.getEntity().getContent(), Object.class); |
| | | } |
| | | if (statusCode >= 400) { |
| | | throw new RuntimeException("请æ±é误ï¼statusCode:" + statusCode + ",Error Code: " + result.get("code") + ", Error Msg: " + result.get("msg")); |
| | | log.error("===ç®éäºæ¥å£ï¼è¯·æ±é误ï¼statusCode:" + statusCode + ",Error Code: " + result.get("code") + ", Error Msg: " + result.get("msg")); |
| | | throw new Exception("请æ±é误ï¼statusCode:" + statusCode + ",Error Code: " + result.get("code") + ", Error Msg: " + result.get("msg")); |
| | | } else { |
| | | // å¤çè¿åç»æ |
| | | log.error("===ç®éäºæ¥å£ï¼è¯·æ±æåresult:" + JSONObject.toJSONString(result)); |
| | | return result; |
| | | } |
| | | } |
| | |
| | | private String sex; |
| | | private String job_date; |
| | | private String can_visit;//å¯æè®¿ ä¸å¯æè®¿ |
| | | private String master;//æ¯ å¦ |
| | | private String phone; |
| | | private String name; |
| | | private String idcardno; |
| | |
| | | spring: |
| | | profiles: |
| | | active: dev |
| | | active: pro |
| | | application: |
| | | name: system_gateway |
| | | # å®å
¨é
ç½® |
| | |
| | | public static final String JDY_CAR_SECRET = " JDY_CAR_SECRET"; |
| | | public static final String JDY_SECRET ="JDY_SECRET"; |
| | | public static final String JDY_MEMBER_PUSH_STATUS_URL ="JDY_MEMBER_PUSH_STATUS_URL"; |
| | | public static final String JDY_API_HOST = "API_HOST"; |
| | | |
| | | /** |
| | | * æä½ç±»åï¼ç¨äºåæ¥å£éªè¯åç» |
| | |
| | | public static final String LOCATION ="LOCATION" ; |
| | | public static final String API_KEY ="API_KEY" ; |
| | | public static final String JDY_CONFIG ="JDY_CONFIG" ; |
| | | public static final String JDY_COMPANY_ROOT_NO ="JDY_COMPANY_ROOT_NO" ; |
| | | public static final String CABINET_CONFIG ="CABINET_CONFIG" ; |
| | | public static final String BLOW_TIME ="BLOW_TIME" ; |
| | | public static final String PRESSURE ="PRESSURE" ; |
| | |
| | | private String companyPath; |
| | | @ApiModelProperty(value = "ç»ç»ä¿¡æ¯") |
| | | @TableField(exist = false) |
| | | private Company company; |
| | | private Company companyModel; |
| | | @ApiModelProperty(value = "è´è´£äººç¼ç ï¼å
³èmember)") |
| | | @TableField(exist = false) |
| | | private Integer headId; |
| | |
| | | spring: |
| | | profiles: |
| | | active: dev |
| | | active: pro |
| | | application: |
| | | name: systemTimer |
| | | # å®å
¨é
ç½® |
| | |
| | | spring: |
| | | profiles: |
| | | active: dev |
| | | active: pro |
| | | application: |
| | | name: visitsTimer |
| | | # å®å
¨é
ç½® |
| | |
| | | Map<String, String> parameterMap = parseParameter(request.getQueryString()); |
| | | String nonce = parameterMap.get("nonce"); |
| | | String timestamp = parameterMap.get("timestamp"); |
| | | String signature = getSignature(nonce, payload, systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.JDY_SECRET).getCode(), timestamp); |
| | | String signature = getSignature(nonce, payload, |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.JDY_SECRET).getCode(), timestamp); |
| | | log.error("ãç®éäºãæ°æ®æ¨é =========getRequestURIï¼{}\nï¼queryParamï¼{}\n,payload:{}\n,ç¾åï¼{}\n,æ£ç¡®ç¾å:{}\n",request.getRequestURI(),request.getQueryString(),payload,jdy,signature); |
| | | if (!signature.equals(jdy)) { |
| | | return null; |
| | |
| | | public static void main(String[] args) { |
| | | /* |
| | | */ |
| | | String url = "https://api.jiandaoyun.com/api/v1/automation/tenant/6909b792324dc197821895d1/hooks/6909d0fbdb93695219faa27eb068192dc4a9532972993159"; |
| | | String url = "https://lcdp.ahyc.com.cn:30443/api/v1/automation/tenant/61b6fb6080e9de2aa1df94d7/hooks/6954aca3cdf86954d2657433fb470ca1aabd108246925eca"; |
| | | JSONObject object = new JSONObject(); |
| | | object.put("status",0); |
| | | object.put("username","20251104160000" ); |
| | |
| | | @PostMapping("/create") |
| | | @CloudRequiredPermission("business:member:create") |
| | | public ApiResponse create(@RequestBody Member member,@RequestHeader(Constants.HEADER_USER_TOKEN) String token) { |
| | | if(Constants.formatIntegerNum(dataSyncConfig.getOrgUserDataOrigin()) == DataSyncConfig.origin.self){ |
| | | member.setLoginUserInfo(this.getLoginUser(token)); |
| | | Member insert = memberService.create(member); |
| | | //å建人è¸ä¿¡æ¯ |
| | | return ApiResponse.success("æä½æåï¼"); |
| | | }else{ |
| | | return ApiResponse.failed("对ä¸èµ·ï¼æ æéæä½ï¼"); |
| | | } |
| | | |
| | | } |
| | | |
| | | @PreventRepeat |
| | |
| | | spring: |
| | | profiles: |
| | | active: dev |
| | | active: pro |
| | | application: |
| | | name: visitsAdmin |
| | | # å®å
¨é
ç½® |
| | |
| | | private String idcard; |
| | | @ExcelColumn(name="å车åºåç§°" , value = "parkName",index = 8) |
| | | private String parkName; |
| | | @ExcelColumn(name="å¼å§æ¶é´" , value = "startTime",index =9) |
| | | private String startTime; |
| | | @ExcelColumn(name="ç»ææ¶é´" , value = "endTime",index = 10) |
| | | private String endTime; |
| | | // @ExcelColumn(name="å¼å§æ¶é´" , value = "startTime",index =9) |
| | | // private String startTime; |
| | | // @ExcelColumn(name="ç»ææ¶é´" , value = "endTime",index = 10) |
| | | // private String endTime; |
| | | } |
| | |
| | | import org.apache.commons.collections.CollectionUtils; |
| | | import org.apache.commons.lang3.StringUtils; |
| | | import org.apache.shiro.SecurityUtils; |
| | | import org.checkerframework.checker.units.qual.C; |
| | | import org.springframework.beans.BeanUtils; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | |
| | | return false; |
| | | } |
| | | |
| | | |
| | | private OrgAddRequest getOrgAddModel(Company c ) { |
| | | OrgAddRequest model = new OrgAddRequest(); |
| | |
| | | @Override |
| | | public String syncJdyCompany() { |
| | | //{ |
| | | // "dept_no": 1,//æ°å 1 ä¸ºæ ¹é¨é¨ç¼å·ã |
| | | // "dept_no": 1,//æ°å 1 ä¸ºæ ¹é¨é¨ç¼å·ã483636217ï¼èæ¹å¸å
¬å¸ |
| | | // "has_child": true |
| | | //} |
| | | DeptApiClient deptApiClient = new DeptApiClient(HttpConstant.API_KEY, HttpConstant.HOST); |
| | | DeptApiClient deptApiClient = new DeptApiClient(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.API_KEY).getCode() |
| | | ,systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.JDY_API_HOST).getCode()); |
| | | try { |
| | | Map<String, Object> result = deptApiClient.deptList(1,true,deptApiClient.getDefaultVersion()); |
| | | int root = 1; |
| | | try { |
| | | root = Integer.parseInt(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.JDY_COMPANY_ROOT_NO).getCode()); |
| | | }catch (Exception e){ |
| | | |
| | | } |
| | | Map<String, Object> result = deptApiClient.deptList(root,true,deptApiClient.getDefaultVersion()); |
| | | if(result!=null && result.get("departments")!=null ){ |
| | | TypeReference<List<DeptEntityModel>> typeReference = new TypeReference<List<DeptEntityModel>>(){}; |
| | | Object obj = result.get("departments"); |
| | |
| | | e.printStackTrace(); |
| | | throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(), "åæ¥æ°æ®å¼å¸¸ï¼"); |
| | | } |
| | | |
| | | return null; |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ´çéé忥 æ°å¢ç»ç»å¯¹è±¡ |
| | | * @return |
| | |
| | | private Company getUpdateCompanyModel(Company param, Company company) { |
| | | return syncDDEditCompanyModel(param,company); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * æ ¹æ®ERPID å¤ææ°æ®æ¯å¦å·²å¨éåéåå¨ |
| | |
| | | if(parent == null || Constants.equalsInteger(parent.getIsdeleted(),Constants.ONE)){ |
| | | parent =root; |
| | | } |
| | | /* if(Objects.nonNull(parent.getType())&&!Constants.equalsInteger(parent.getType(),-1)){ |
| | | /*if(Objects.nonNull(parent.getType())&&!Constants.equalsInteger(parent.getType(),-1)){ |
| | | if(!Constants.equalsInteger(company.getType(),parent.getType())){ |
| | | throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"对ä¸èµ·ï¼ç»ç»ä¿¡æ¯é误"); |
| | | } |
| | |
| | | import com.doumee.core.dingTalk.DingTalkStream; |
| | | import com.doumee.core.exception.BusinessException; |
| | | import com.doumee.core.haikang.model.HKConstants; |
| | | import com.doumee.core.jiandaoyun.api.arch.DeptApiClient; |
| | | import com.doumee.core.jiandaoyun.api.jdy.FormDataApiClient; |
| | | import com.doumee.core.jiandaoyun.model.form.FormDataCreateParam; |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.DateUtil; |
| | | import com.doumee.dao.business.*; |
| | |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ddUserIdList)){ |
| | | for (String ddUserId:ddUserIdList) { |
| | | this.getJDYData(warningEvent,ddUserId, |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.API_KEY).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.APPID).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.ENTRY_ID).getCode() |
| | | ); |
| | | } |
| | |
| | | * ç®éäºæ¶æ¯æ¨é å®å¶ |
| | | * @param warningEvent |
| | | * @param ddUserId æ¥æ¶äºº ééä¸»é® |
| | | * @param jdyApiKey ç®åäºAPIKEY |
| | | * @param appid åºç¨ID |
| | | * @param entryId 表åID |
| | | * @throws IOException |
| | | */ |
| | | public void getJDYData(WarningEvent warningEvent,String ddUserId,String jdyApiKey,String appid,String entryId) throws IOException { |
| | | Map<String,Object> map = new HashMap<>(); |
| | | map.put("app_id",appid); |
| | | map.put("entry_id",entryId); |
| | | map.put("is_start_workflow","false"); |
| | | map.put("is_start_trigger","true"); |
| | | map.put("data",this.getJdyChildData(warningEvent,ddUserId)); |
| | | |
| | | // OkHttpClient client = new OkHttpClient().newBuilder() |
| | | // .build(); |
| | | // MediaType mediaType = MediaType.parse("application/json"); |
| | | // RequestBody body = RequestBody.create(mediaType, JSONObject.toJSONString(map));//"{\"data\":{\"notice_time\":{\"value\":\"2025-12-23 04:56:29\"},\"title\":{\"value\":\"è·¨è¶ç产线\"},\"user\":{\"value\":\"1568490244651036\"},\"content\":{\"value\":\"è·¨è¶ç产线-èæ¹ç©æµä¸å¿åå´å¢è¿éä¸\"},\"notice_type\":{\"value\":\"è·¨è¶ç产线\"}},\"is_start_trigger\":\"true\",\"app_id\":\"6909d0fbdb93b068192dc4a9\",\"entry_id\":\"694a19ecf57e071788efc20b\",\"is_start_workflow\":\"false\"}"); |
| | | // log.error("ç®éäºåééç¥è¯·æ±ä¿¡æ¯" + JSONObject.toJSONString(map)); |
| | | // Request request = new Request.Builder() |
| | | // .url("https://api.jiandaoyun.com/api/v5/app/entry/data/create") |
| | | // .method("POST", body) |
| | | // .addHeader("Authorization", "Bearer "+jdyApiKey) |
| | | // .addHeader("Content-Type", "application/json") |
| | | // .build(); |
| | | // Response response = client.newCall(request).execute(); |
| | | // |
| | | // log.error("ç®éäºåééç¥è¿åä¿¡æ¯" + JSONObject.toJSONString(response)); |
| | | |
| | | public void getJDYData(WarningEvent warningEvent,String ddUserId , String entryId) { |
| | | try { |
| | | log.error("ç®éäºåééç¥è¿åä¿¡æ¯å¼å§" ); |
| | | FormDataApiClient apiClient = new FormDataApiClient(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.API_KEY).getCode() |
| | | ,systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.JDY_API_HOST).getCode()); |
| | | FormDataCreateParam param =new FormDataCreateParam(); |
| | | param.setData(this.getJdyChildData(warningEvent,ddUserId)); |
| | | param.setApp_id(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.APPID).getCode()); |
| | | param.setEntry_id(entryId); |
| | | param.setIs_start_trigger(false); |
| | | param.setIs_start_trigger(true); |
| | | Map<String, Object> response = apiClient.singleDataCreate(param,apiClient.getDefaultVersion()); |
| | | /* |
| | | Map<String,Object> map = new HashMap<>(); |
| | | map.put("app_id",appid); |
| | | map.put("entry_id",entryId); |
| | | map.put("is_start_workflow","false"); |
| | | map.put("is_start_trigger","true"); |
| | | map.put("data",this.getJdyChildData(warningEvent,ddUserId)); |
| | | OkHttpClient client = new OkHttpClient().newBuilder() |
| | | .build(); |
| | | MediaType mediaType = MediaType.parse("application/json"); |
| | | RequestBody body = RequestBody.create(mediaType, JSONObject.toJSONString(map));//"{\"data\":{\"notice_time\":{\"value\":\"2025-12-23 04:56:29\"},\"title\":{\"value\":\"è·¨è¶ç产线\"},\"user\":{\"value\":\"1568490244651036\"},\"content\":{\"value\":\"è·¨è¶ç产线-èæ¹ç©æµä¸å¿åå´å¢è¿éä¸\"},\"notice_type\":{\"value\":\"è·¨è¶ç产线\"}},\"is_start_trigger\":\"true\",\"app_id\":\"6909d0fbdb93b068192dc4a9\",\"entry_id\":\"694a19ecf57e071788efc20b\",\"is_start_workflow\":\"false\"}"); |
| | | log.error("ç®éäºåééç¥è¯·æ±ä¿¡æ¯" + JSONObject.toJSONString(map)); |
| | | Request request = new Request.Builder() |
| | | .url(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.JDY_API_HOST).getCode()+"v5/app/entry/data/create") |
| | | .method("POST", body) |
| | | .addHeader("Authorization", "Bearer "+jdyApiKey) |
| | | .addHeader("Content-Type", "application/json") |
| | | .build(); |
| | | Response response = client.newCall(request).execute();*/ |
| | | log.error("ç®éäºåééç¥è¿åä¿¡æ¯" + JSONObject.toJSONString(response)); |
| | | }catch (Exception e){ |
| | | log.error("ç®éäºåééç¥è¿åä¿¡æ¯å¼å¸¸ï¼" + e.getMessage()); |
| | | } |
| | | } |
| | | |
| | | |
| | |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ddUserIdList)){ |
| | | for (String ddUserId:ddUserIdList) { |
| | | this.getJDYData(warningEvent,ddUserId, |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.API_KEY).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.APPID).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.ENTRY_ID).getCode() |
| | | |
| | | ); |
| | |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ddUserIdList)){ |
| | | for (String ddUserId:ddUserIdList) { |
| | | impl.getJDYData(warningEvent,ddUserId, |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.API_KEY).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.APPID).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.ENTRY_ID).getCode() |
| | | |
| | | ); |
| | |
| | | Member insert = initAddMemberModel(member,loginUserInfo); |
| | | //æµ·åº·äººåæ°å¢ä¸å¡ |
| | | try { |
| | | // if(dealHkUserBiz(insert)){ |
| | | memberMapper.insert(insert); |
| | | //å建系ç»ç»éè´¦å·ï¼é»è®¤æ ä»»ä½è§è²ï¼ |
| | | // if(Constants.equalsInteger(member.getCompanyType(),Constants.ONE)){ |
| | | //妿æ¯å
é¨ç»ç»äººåï¼æ°å¢ç³»ç»ç»éè´¦å· |
| | | systemUserMapper.insert(createSystemUser(insert,systemDictDataBiz)); |
| | | //å¤çå¹è®æææä¸å¡ |
| | | dealTrainTIme(member,0,loginUserInfo); |
| | | if(dealHkUserBiz(insert)){ |
| | | insert.setHkStatus(Constants.ONE); |
| | | memberMapper.insert(insert); |
| | | //å建系ç»ç»éè´¦å·ï¼é»è®¤æ ä»»ä½è§è²ï¼ |
| | | // if(Constants.equalsInteger(member.getCompanyType(),Constants.ONE)){ |
| | | //妿æ¯å
é¨ç»ç»äººåï¼æ°å¢ç³»ç»ç»éè´¦å· |
| | | systemUserMapper.insert(createSystemUser(insert,systemDictDataBiz)); |
| | | //å¤çå¹è®æææä¸å¡ |
| | | dealTrainTIme(member,0,loginUserInfo); |
| | | // } |
| | | // }else{ |
| | | // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对ä¸èµ·ï¼å工信æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | // } |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对ä¸èµ·ï¼å工信æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | } |
| | | }catch (BusinessException e){ |
| | | //妿åçå¼å¸¸ï¼å é¤å·²ç»å建ç人åä¿¡æ¯ |
| | | deleteHkUserBiz(new String[]{insert.getHkId()}); |
| | |
| | | insert.setCanVisit(Constants.formatIntegerNum(member.getCanVisit()));//é»è®¤ä¸å¯è®¿é® |
| | | insert.setAuthStatus(Constants.ZERO); |
| | | insert.setName(member.getName()); |
| | | insert.setHkId(UUID.randomUUID().toString().replace("-","")); |
| | | // insert.setHkId(UUID.randomUUID().toString().replace("-","")); |
| | | insert.setHkStatus(Constants.ZERO); |
| | | insert.setSex(Constants.getSexByCardNo( member.getIdcardNo()));//æ ¹æ®èº«ä»½è¯å·è·åæ§å« |
| | | insert.setJobDate(member.getJobDate()); |
| | |
| | | .eq(Member::getIsdeleted,Constants.ZERO) ) >0){ |
| | | throw new BusinessException(ResponseStatus.DATA_EXISTS.getCode(), "ææºå·ã"+member.getPhone()+"ã已被使ç¨ï¼ä¸è½éå¤"); |
| | | } |
| | | Company company = member.getCompany()!=null ?member.getCompany(): companyMapper.selectById(member.getCompanyId()); |
| | | Company company = member.getCompanyModel()!=null ?member.getCompanyModel(): companyMapper.selectById(member.getCompanyId()); |
| | | if(company == null || Constants.equalsInteger(company.getIsdeleted(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»ç»ä¿¡æ¯å·²è¢«å é¤ï¼"); |
| | | } |
| | |
| | | } |
| | | if(member.getCompanyId()!=null && !Constants.equalsInteger(member.getCompanyId(),model.getCompanyId())){ |
| | | //妿ç»ç»åçåå |
| | | Company company = member.getCompany()!=null ?member.getCompany(): companyMapper.selectById(member.getCompanyId()); |
| | | Company company = member.getCompanyModel()!=null ?member.getCompanyModel(): companyMapper.selectById(member.getCompanyId()); |
| | | if(company == null || Constants.equalsInteger(company.getIsdeleted(),Constants.ONE)){ |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼è¯¥ç»ç»ä¿¡æ¯å·²è¢«å é¤ï¼è¯·å·æ°é¡µé¢éè¯ï¼"); |
| | | } |
| | |
| | | updateMember.setEditor(loginUserInfo!=null?loginUserInfo.getId():null); |
| | | updateMember.setEditDate(new Date()); |
| | | //æµ·åº·äººåæ°å¢ä¸å¡ |
| | | // if(dealHkUserForUpdateBiz(updateMember)){ |
| | | updateMember.setHkId(null); |
| | | updateMember.setAuthStatus(Constants.ZERO); |
| | | memberMapper.update(null,new UpdateWrapper<Member>().lambda() |
| | | .set(Member::getStartTime,null) |
| | | .set(Member::getEndTime,null) |
| | | .set(Member::getRoleId,null) |
| | | .set(StringUtils.isNotBlank(updateMember.getPhone()),Member::getPhone,updateMember.getPhone()) |
| | | .set(StringUtils.isNotBlank(updateMember.getName()),Member::getName,updateMember.getName()) |
| | | .set(Member::getEditDate,updateMember.getEditDate()) |
| | | .set(Member::getEditor,updateMember.getEditor()) |
| | | .set(StringUtils.isNotBlank(updateMember.getName()),Member::getPinyin,Constants.getChinesePingyin(updateMember.getName())) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardNo()),Member::getIdcardNo,updateMember.getIdcardNo()) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardDecode()),Member::getIdcardDecode,updateMember.getIdcardDecode()) |
| | | .set( Member::getAuthStatus,Constants.ZERO) |
| | | .set(updateMember.getHkStatus()!=null,Member::getHkStatus,updateMember.getHkStatus()) |
| | | .set(updateMember.getSex()!=null,Member::getSex,updateMember.getSex()) |
| | | .set(updateMember.getCanVisit()!=null,Member::getCanVisit,updateMember.getCanVisit()) |
| | | .set(updateMember.getFaceStatus()!=null,Member::getFaceStatus,updateMember.getFaceStatus()) |
| | | .set(updateMember.getHkDate()!=null,Member::getHkDate,updateMember.getHkDate()) |
| | | .set(updateMember.getHkDate()!=null,Member::getHkDate,updateMember.getHkDate()) |
| | | .set(StringUtils.isNotBlank(updateMember.getRemark()),Member::getRemark,updateMember.getRemark()) |
| | | .set(StringUtils.isNotBlank(updateMember.getFaceImg()),Member::getFaceImg,updateMember.getFaceImg()) |
| | | .set(updateMember.getFaceId()!=null,Member::getFaceId,updateMember.getFaceId()) |
| | | .set(updateMember.getCompanyId()!=null,Member::getCompanyId,updateMember.getCompanyId()) |
| | | .set(Member::getCode,updateMember.getCode()) |
| | | // .set(StringUtils.isNotBlank(updateMember.getCode()),Member::getCode,updateMember.getCode()) |
| | | .set( updateMember.getPositionId()!=null,Member::getPositionId,updateMember.getPositionId()) |
| | | .set( updateMember.getIsDangyuan()!=null,Member::getIsDangyuan,updateMember.getIsDangyuan()) |
| | | .set( updateMember.getJobDate()!=null,Member::getJobDate,updateMember.getJobDate()) |
| | | .eq(Member::getId,updateMember.getId())); |
| | | dealTrainTIme(updateMember,1,loginUserInfo); |
| | | cancelAllMemberEmpower(updateMember,memberRoleMapper,empowerMapper); |
| | | //è®°å½æä½æ¥å¿ |
| | | saveUserActionBiz(updateMember,loginUserInfo,Constants.UserActionType.EDIT,userActionJoinMapper,null); |
| | | // }else{ |
| | | // throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对ä¸èµ·ï¼å工信æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | // } |
| | | if(dealHkUserForUpdateBiz(updateMember)){ |
| | | updateMember.setHkStatus(Constants.ONE); |
| | | updateMember.setHkId(null); |
| | | updateMember.setAuthStatus(Constants.ZERO); |
| | | memberMapper.update(null,new UpdateWrapper<Member>().lambda() |
| | | .set(Member::getStartTime,null) |
| | | .set(Member::getEndTime,null) |
| | | .set(Member::getRoleId,null) |
| | | .set(StringUtils.isNotBlank(updateMember.getPhone()),Member::getPhone,updateMember.getPhone()) |
| | | .set(StringUtils.isNotBlank(updateMember.getName()),Member::getName,updateMember.getName()) |
| | | .set(Member::getEditDate,updateMember.getEditDate()) |
| | | .set(Member::getEditor,updateMember.getEditor()) |
| | | .set(StringUtils.isNotBlank(updateMember.getName()),Member::getPinyin,Constants.getChinesePingyin(updateMember.getName())) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardNo()),Member::getIdcardNo,updateMember.getIdcardNo()) |
| | | .set(StringUtils.isNotBlank(updateMember.getIdcardDecode()),Member::getIdcardDecode,updateMember.getIdcardDecode()) |
| | | .set( Member::getAuthStatus,Constants.ZERO) |
| | | .set(updateMember.getHkStatus()!=null,Member::getHkStatus,updateMember.getHkStatus()) |
| | | .set(updateMember.getSex()!=null,Member::getSex,updateMember.getSex()) |
| | | .set(updateMember.getCanVisit()!=null,Member::getCanVisit,updateMember.getCanVisit()) |
| | | .set(updateMember.getFaceStatus()!=null,Member::getFaceStatus,updateMember.getFaceStatus()) |
| | | .set(updateMember.getHkDate()!=null,Member::getHkDate,updateMember.getHkDate()) |
| | | .set(StringUtils.isNotBlank(updateMember.getRemark()),Member::getRemark,updateMember.getRemark()) |
| | | .set(StringUtils.isNotBlank(updateMember.getFaceImg()),Member::getFaceImg,updateMember.getFaceImg()) |
| | | .set(updateMember.getFaceId()!=null,Member::getFaceId,updateMember.getFaceId()) |
| | | .set(updateMember.getCompanyId()!=null,Member::getCompanyId,updateMember.getCompanyId()) |
| | | .set(Member::getCode,updateMember.getCode()) |
| | | // .set(StringUtils.isNotBlank(updateMember.getCode()),Member::getCode,updateMember.getCode()) |
| | | .set( updateMember.getPositionId()!=null,Member::getPositionId,updateMember.getPositionId()) |
| | | .set( updateMember.getIsDangyuan()!=null,Member::getIsDangyuan,updateMember.getIsDangyuan()) |
| | | .set( updateMember.getJobDate()!=null,Member::getJobDate,updateMember.getJobDate()) |
| | | .eq(Member::getId,updateMember.getId())); |
| | | dealTrainTIme(updateMember,1,loginUserInfo); |
| | | cancelAllMemberEmpower(updateMember,memberRoleMapper,empowerMapper); |
| | | //è®°å½æä½æ¥å¿ |
| | | saveUserActionBiz(updateMember,loginUserInfo,Constants.UserActionType.EDIT,userActionJoinMapper,null); |
| | | }else{ |
| | | throw new BusinessException(ResponseStatus.SERVER_ERROR.getCode(),"对ä¸èµ·ï¼å工信æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | } |
| | | } |
| | | |
| | | private void dealTrainTIme(Member updateMember, int i,LoginUserInfo loginUserInfo) { |
| | |
| | | .eq( Member::getType,Constants.TWO ) |
| | | .last("limit 1")); |
| | | } |
| | | boolean addOrEdit = false; |
| | | if(member == null){ |
| | | //æ°å¢äººå |
| | | if(data.getDeleter()!=null){ |
| | |
| | | } |
| | | member = getAddOrUpdateModelFromJDY(data,true); |
| | | this.create(member); |
| | | addOrEdit=true; |
| | | }else{ |
| | | //æ´æ°äººå |
| | | if(data.getDeleter()!=null){ |
| | |
| | | //æ´æ°äººåä¿¡æ¯ |
| | | Member updateMember =getAddOrUpdateModelFromJDY(data,false); |
| | | updateMember.setId(member.getId()); |
| | | addOrEdit=true; |
| | | this.updateById(updateMember); |
| | | } |
| | | } |
| | | if(addOrEdit && Constants.equalsInteger(member.getHeadStatus(),Constants.ONE) && member.getCompanyModel()!=null){ |
| | | //妿æ¯é¨é¨ä¸»ç®¡ |
| | | Company updateCom = new Company(); |
| | | updateCom.setHeadId(member.getId()); |
| | | updateCom.setId(member.getCompanyModel().getId()); |
| | | companyMapper.updateById(updateCom);//æ´æ°é¨é¨ä¸»ç®¡äººå |
| | | } |
| | | } |
| | | |
| | |
| | | } |
| | | if(StringUtils.isNotBlank(data.getCan_visit())){ |
| | | member.setCanVisit(StringUtils.equals(data.getCan_visit(),"å¯æè®¿")?1:0); |
| | | } |
| | | if(StringUtils.isNotBlank(data.getMaster())){ |
| | | member.setHeadStatus(StringUtils.equals(data.getMaster(),"æ¯")?1:0); |
| | | } |
| | | member.setErpId(data.getUsername()); |
| | | if(data.getDepartment()!=null){ |
| | |
| | | if(depart!=null){ |
| | | member.setCompanyId(depart.getId()); |
| | | } |
| | | member.setCompany(depart); |
| | | member.setCompanyModel(depart); |
| | | return member; |
| | | } |
| | | |
| | |
| | | |
| | | @Override |
| | | public String syncJdyUserInfo() { |
| | | DeptApiClient deptApiClient = new DeptApiClient(HttpConstant.API_KEY, HttpConstant.HOST); |
| | | DeptApiClient deptApiClient = new DeptApiClient(systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.API_KEY).getCode() |
| | | ,systemDictDataBiz.queryByCode(Constants.JDY_CONFIG, Constants.JDY_API_HOST).getCode()); |
| | | try { |
| | | Map<String, Object> result = deptApiClient.deptMemberList(1,true,deptApiClient.getDefaultVersion()); |
| | | if(result!=null && result.get("users")!=null ){ |
| | |
| | | throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对ä¸èµ·ï¼ç»å½ç»ä»¶å¤±è´¥ï¼è¯·ç¨åéè¯ï¼"); |
| | | } |
| | | //ä¼å
ä»ç¼ååæ°æ®ï¼å¦ææç¼åï¼ç´æ¥è¿åç¼åå°å |
| | | /*String cacheUrl = (String) redisTemplate.opsForValue().get(Constants.REDIS_HK_TOKEN_KEY+param.getUsername()+param.getLabel()); |
| | | /* |
| | | String cacheUrl = (String) redisTemplate.opsForValue().get(Constants.REDIS_HK_TOKEN_KEY+param.getUsername()+param.getLabel()); |
| | | if(StringUtils.isNotBlank(cacheUrl)){ |
| | | return cacheUrl; |
| | | }*/ |
| | |
| | | if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ddUserIdList)){ |
| | | for (String ddUserId:ddUserIdList) { |
| | | impl.getJDYData(warningEvent,ddUserId, |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.API_KEY).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.APPID).getCode(), |
| | | systemDictDataBiz.queryByCode(Constants.JDY_CONFIG,Constants.ENTRY_ID).getCode() |
| | | |
| | | ); |
| | |
| | | }else{ |
| | | noticeErpFail(c,Constants.ZERO,"人åä¿¡æ¯åæ¥å®é²å¹³å°å¤±è´¥ï¼è¯·ä¿®æ£åéè¯ï¼"); |
| | | c.setHkStatus(Constants.TWO); |
| | | c.setRemark("人åä¿¡æ¯åæ¥å®é²å¹³å°æ´æ°å¤±è´¥ï¼è¯·ä¿®æ£åéè¯ï¼ï¼"+(result!=null?result.getCode()+result.getMsg():"")); |
| | | String msg =(result!=null?result.getCode()+result.getMsg():""); |
| | | c.setRemark("人åä¿¡æ¯åæ¥å®é²å¹³å°æ´æ°å¤±è´¥ï¼è¯·ä¿®æ£åéè¯ï¼ï¼"+msg); |
| | | if(StringUtils.contains(msg,"Person Not Exists")){ |
| | | //人åä¿¡æ¯ä¸åå¨ï¼æ¸
空hkIdï¼éæ°æ·»å |
| | | c.setHkId("-"); |
| | | c.setHkStatus(Constants.ZERO); |
| | | } |
| | | } |
| | | c.setHkDate(date); |
| | | c.setEditDate(date); |